Describe what you changed

lib/room.ts

@@ -78,5 +78,7 @@ export const createNewRoom = async (roomId: string, socketId: string) => {
       lastSync: new Date().getTime() / 1000,
     },
     users: [],
+    // Initialize chat log for in-room chat feature
+    chatLog: [],
   })
 }

lib/sockets.ts

@@ -0,0 +1,85 @@
+import {
+  MediaElement,
+  PlayerState,
+  Playlist,
+  RoomState,
+  UserState,
+  ChatMessage,
+} from "./types"
+import io, { Socket } from "socket.io-client"
+
+export interface ServerToClientEvents {
+  playlistUpdate: (playlist: Playlist) => void
+  userUpdates: (users: UserState[]) => void
+  update: (room: RoomState) => void
+
+  // Chat events
+  chatNew: (msg: ChatMessage) => void
+  chatHistory: (msgs: ChatMessage[]) => void
+}
+
+export interface ClientToServerEvents {
+  playItemFromPlaylist: (index: number) => void
+  updatePlaylist: (playlist: Playlist) => void
+  updatePlayer: (player: PlayerState) => void
+  updatePlaying: (playing: MediaElement) => void
+  updateUser: (user: UserState) => void
+
+  setPaused: (paused: boolean) => void
+  setLoop: (loop: boolean) => void
+  setProgress: (progress: number) => void
+  setPlaybackRate: (playbackRate: number) => void
+
+  seek: (progress: number) => void
+  playUrl: (src: string) => void
+  playAgain: () => void
+  playEnded: () => void
+  fetch: () => void
+  error: () => void
+
+  // Chat: client -> server
+  chatMessage: (text: string) => void
+}
+
+export function playItemFromPlaylist(
+  socket: Socket<ServerToClientEvents, ClientToServerEvents>,
+  playlist: Playlist,
+  index: number
+) {
+  if (
+    typeof playlist.items[index] === "undefined" ||
+    playlist.items[index] === null
+  ) {
+    console.error("Impossible to play", index, "from", playlist)
+    return
+  }
+  socket.emit("playItemFromPlaylist", index)
+}
+
+export function createClientSocket(roomId: string) {
+  console.log("Trying to join room", roomId)
+  const socket = io({
+    query: {
+      roomId,
+    },
+    transports: ["websocket"],
+    path: "/api/socketio",
+  })
+
+  socket.on("connect", () => {
+    console.log("Established ws connection to io server", socket.id)
+  })
+
+  socket.on("disconnect", (reason) => {
+    if (!["io client disconnect", "io server disconnect"].includes(reason)) {
+      console.error(
+        "Socket connection closed due to:",
+        reason,
+        "socket:",
+        socket
+      )
+    }
+  })
+
+  return socket
+}

lib/types.ts

@@ -62,6 +62,17 @@ export interface CommandLog {
   time: number
 }
 
+/**
+ * Chat message structure for in-room chat
+ */
+export interface ChatMessage {
+  id: string       // unique id per message
+  userId: string   // sender socket/user id
+  name: string     // sender display name
+  text: string     // message text
+  ts: number       // timestamp (ms since epoch)
+}
+
 export interface RoomState {
   serverTime: number
   id: string
@@ -69,4 +80,5 @@ export interface RoomState {
   users: UserState[]
   targetState: TargetState
   commandHistory: CommandLog[]
+  chatLog?: ChatMessage[] // optional to keep backward compatibility
 }