finish gateway websocket example

1 files changed, 66 insertions, 4 deletions

diff --git a/client/components/home/ping.jsx b/client/components/home/ping.jsx
index dd891af..6166921 100644
--- a/client/components/home/ping.jsx
+++ b/client/components/home/ping.jsx
@@ -1,12 +1,74 @@
-import { useState } from 'react';
+import { useState, useEffect, useRef, useContext } from 'react';
 import { Button } from '../common/button';
+import { io } from 'socket.io-client';
+import { AuthContext } from '../../utils/auth_context';
 
 export const Ping = () => {
   const [pings, setPings] = useState([]);
   const [key, setKey] = useState('defaultkey');
+  const [currentRoom, setCurrentRoom] = useState(null);
+  const [authToken] = useContext(AuthContext);
+  const [socket, setSocket] = useState(null);
+
+  useEffect(() => {
+    // instantiates a socket object and initiates the connection...
+    // you probably want to make sure you are only doing this in one component at a time.
+    const socket = io({
+      auth: { token: authToken },
+      query: { message: 'I am the query ' },
+    });
+
+    // adds an event listener to the connection event
+    socket.on('connect', () => {
+      setSocket(socket);
+    });
+
+    // adds event listener to the disconnection event
+    socket.on('disconnect', () => {
+      console.log('Disconnected');
+    });
+
+    // recieved a pong event from the server
+    socket.on('pong', (data) => {
+      console.log('Recieved pong', data);
+    });
+
+    // IMPORTANT! Unregister from all events when the component unmounts and disconnect.
+    return () => {
+      socket.off('connect');
+      socket.off('disconnect');
+      socket.off('pong');
+      socket.disconnect();
+    };
+  }, []);
+
+  useEffect(() => {
+    // if our token changes we need to tell the socket also
+    if (socket) {
+      // this is a little weird because we are modifying this object in memory
+      // i dunno a better way to do this though...
+      socket.auth.token = authToken;
+    }
+  }, [authToken]);
+
+  if (!socket) return 'Loading...';
+
+  const sendPing = () => {
+    // sends a ping to the server to be broadcast to everybody in the room
+    currentRoom && socket.emit('ping', { currentRoom });
+  };
+
+  const joinRoom = () => {
+    // tells the server to remove the current client from the current room and add them to the new room
+    socket.emit('join-room', { currentRoom, newRoom: key }, (response) => {
+      console.log(response);
+      setCurrentRoom(response.room);
+    });
+  };
+
   return (
     <>
-      <header>Ping</header>
+      <header>Ping: {currentRoom || '(No room joined)'}</header>
       <section>
         <input
           type="text"
@@ -14,8 +76,8 @@ export const Ping = () => {
           value={key}
           onChange={(e) => setKey(e.target.value)}
         />
-        <Button>Ping Connect</Button>
-        <Button>Send Ping</Button>
+        <Button onClick={joinRoom}>Connect To Room</Button>
+        <Button onClick={sendPing}>Send Ping</Button>
       </section>
     </>
   );