add shitty game browser

client/src/components/auth.rs

@@ -35,10 +35,7 @@ pub fn Auth() -> impl IntoView {
         <div class="p-1">
             <h2 class="text-2xl">Sign in:</h2>
             <p>Username:</p>
-            <form
+            <form onsubmit="return false" on:submit=send_login>
-                onsubmit="return false"
-                on:submit=send_login
-            >
                 <input
                     class="w-96 font-mono rounded-sm bg-slate-900 text-slate-200"
                     placeholder=move || username.get()

client/src/components/browser.rs

@@ -0,0 +1,39 @@
+use crate::components::websocket::WebSocketContext;
+use leptos::*;
+use leptos_use::core::ConnectionReadyState;
+use lib::models::GamesUpdate;
+
+#[component]
+pub fn Browser() -> impl IntoView {
+    let websocket = expect_context::<WebSocketContext>();
+    let game_update_context = expect_context::<ReadSignal<Option<GamesUpdate>>>();
+
+    let (active_games, set_active_games) = create_signal::<Vec<String>>(vec![]);
+
+    create_effect(move |_| {
+        game_update_context.with(move |games| {
+            if let Some(games) = games {
+                set_active_games(games.games.clone());
+                logging::log!("{:#?}",active_games());
+            }
+        })
+    });
+
+    // Clear games list on disconnect
+    create_effect(move |_| {
+        websocket.ready_state.with(move |status| {
+            if *status == ConnectionReadyState::Closed {
+                set_active_games(vec![]);
+            }
+        })
+    });
+
+    view! {
+        <div class="p-1">
+            <ul>
+                <h2 class="text-2xl">Game Browser</h2>
+                {move || active_games().into_iter().map(|n| view! { <li>{n}</li> }).collect_view()}
+            </ul>
+        </div>
+    }
+}

client/src/components/chat.rs

@@ -111,10 +111,7 @@ pub fn Chat() -> impl IntoView {
 
             <br/>
             <span>
-            <form
+                <form onsubmit="return false" on:submit=send_message>
-                onsubmit="return false"
-                on:submit=send_message
-            >
                     <input
                         class="w-80 h-11 font-mono rounded-sm bg-slate-900 text-slate-200"
                         placeholder="talk shit..."

client/src/components/mod.rs

@@ -1,4 +1,5 @@
 pub mod auth;
+pub mod browser;
 pub mod chat;
 pub mod debug;
 pub mod websocket;

client/src/components/websocket.rs

@@ -73,11 +73,13 @@ pub fn Websocket() -> impl IntoView {
     let (user_update, set_user_update) = create_signal::<Option<UserUpdate>>(Option::None);
     let (chat_update, set_chat_update) = create_signal::<Option<ChatUpdate>>(Option::None);
     let (chat_message, set_chat_message) = create_signal::<Option<ChatMessage>>(Option::None);
+    let (active_games, set_active_games) = create_signal::<Option<GamesUpdate>>(Option::None);
 
     provide_context::<ReadSignal<Option<Game>>>(game_object);
     provide_context::<ReadSignal<Option<UserUpdate>>>(user_update);
     provide_context::<ReadSignal<Option<ChatUpdate>>>(chat_update);
     provide_context::<ReadSignal<Option<ChatMessage>>>(chat_message);
+    provide_context::<ReadSignal<Option<GamesUpdate>>>(active_games);
     provide_context::<ReadSignal<Option<ServerStateSummary>>>(state_summary);
 
     // Message handler
@@ -96,6 +98,8 @@ pub fn Websocket() -> impl IntoView {
                     set_user_update(Some(user_update));
                 } else if let Ok(chat_update) = from_str::<ChatUpdate>(message) {
                     set_chat_update(Some(chat_update));
+                } else if let Ok(games_update) = from_str::<GamesUpdate>(message) {
+                    set_active_games(Some(games_update));
                 } else {
                     logging::log!("Unhandled message: {}", message);
                 }

client/src/pages/home.rs

@@ -1,4 +1,5 @@
 use crate::components::auth::*;
+use crate::components::browser::*;
 use crate::components::chat::*;
 use crate::components::debug::*;
 use crate::components::websocket::*;
@@ -34,6 +35,8 @@ pub fn Home() -> impl IntoView {
                     <hr/>
                     <Auth/>
                     <hr/>
+                    <Browser/>
+                    <hr/>
                     <Chat/>
                     <hr/>
                     <Debug/>

lib/src/models.rs

@@ -1,5 +1,11 @@
 use serde::{Deserialize, Serialize};
 
+/// Games update
+#[derive(Serialize, Deserialize, Debug)]
+pub struct GamesUpdate {
+    pub games: Vec<String>,
+}
+
 /// Chat update
 #[derive(Serialize, Deserialize, Debug)]
 pub struct ChatUpdate {
@@ -7,7 +13,6 @@ pub struct ChatUpdate {
     pub users: Vec<String>,
 }
 
-
 /// User update
 #[derive(Serialize, Deserialize, Debug)]
 pub struct UserUpdate {
@@ -21,7 +26,7 @@ pub struct UserLogIn {
 }
 
 /// Chat message
-#[derive(Clone, Serialize, Deserialize, Debug)]
+#[derive(Serialize, Deserialize, Debug)]
 pub struct ChatMessage {
     pub text: String,
 }

server/src/api.rs

@@ -41,6 +41,16 @@ fn generate_chat_update(state: &Arc<AppState>) -> ChatUpdate {
     }
 }
 
+fn generate_games_update(state: &Arc<AppState>) -> GamesUpdate {
+    let mut names = vec![];
+
+    for game in state.games.lock().unwrap().iter() {
+        names.push(game.name.clone());
+    }
+
+    GamesUpdate { games: names }
+}
+
 pub async fn on_websocket_connection(stream: WebSocket, state: Arc<AppState>, addr: SocketAddr) {
     // Add User to users
     let new_user = User {
@@ -80,6 +90,11 @@ pub async fn on_websocket_connection(stream: WebSocket, state: Arc<AppState>, ad
             to_string(&server_sum_update(&state)).unwrap(),
         ))
         .await;
+    let _ = &sender
+        .send(Message::Text(
+            to_string(&generate_games_update(&state)).unwrap(),
+        ))
+        .await;
 
     // ANNOUNCE THY PRESENCE
     let msg = ChatMessage {

server/src/api/message_handler.rs

@@ -21,6 +21,7 @@ pub async fn message_handler(message: Message, state: &Arc<AppState>, addr: Sock
                         tracing::error!("Failed to convert Game object to JSON.")
                     }
                     state.games.lock().unwrap().push(new_game_object);
+                    let _ = tx.send(to_string(&generate_games_update(state)).unwrap());
                     let _ = tx.send(to_string(&server_sum_update(state)).unwrap());
                     // let _update = tx.send(motd());
                 } else {
@@ -33,7 +34,13 @@ pub async fn message_handler(message: Message, state: &Arc<AppState>, addr: Sock
             } else if let Ok(user_log_in) = serde_json::from_str::<UserLogIn>(&text) {
                 let old_name = state.users.lock().unwrap().get(&addr).unwrap().name.clone();
                 let new_name = user_log_in.username.clone();
-                state.users.lock().unwrap().get_mut(&addr).unwrap().change_name(user_log_in.username);
+                state
+                    .users
+                    .lock()
+                    .unwrap()
+                    .get_mut(&addr)
+                    .unwrap()
+                    .change_name(user_log_in.username);
                 let msg = format! {
                 "{0} changed name to {1}.",
                 old_name,
@@ -62,7 +69,10 @@ pub async fn message_handler(message: Message, state: &Arc<AppState>, addr: Sock
                 tracing::debug!("close received without close frame")
             }
             let msg = ChatMessage {
-                text: format!("{0} left.", state.users.lock().unwrap().get(&addr).unwrap().name),
+                text: format!(
+                    "{0} left.",
+                    state.users.lock().unwrap().get(&addr).unwrap().name
+                ),
             };
             tracing::debug!("{}", msg.text);
             let _ = tx.send(to_string::<ChatMessage>(&msg).unwrap());