feat: add music sync room feature and bump version to 1.2.0

1. 新增音乐同步房间功能，支持共享播放列表和同步播放控制
2. 更新README文档，添加音乐同步房间的功能说明
3. 扩展RoomType类型，新增'music'枚举值
4. 定义音乐同步相关的类型接口MusicQueueItem和MusicSyncState
5. 添加音乐同步相关的websocket事件处理和广播逻辑
6. 将服务端版本号更新至1.2.0

Author: tgs9915

README.md

@@ -9,6 +9,7 @@
 ## 功能特性
 
 - 🎬 多人同步观影（播放/暂停/跳转同步）
+- 🎵 音乐同步房间（共享播放列表、同步播放控制）
 - 🖥️ 屏幕共享房间（实时共享桌面/窗口）
 - 💬 实时聊天系统
 - 🎙️ 语音通话（WebRTC）

package.json

@@ -1,6 +1,6 @@
 {
   "name": "watch-room-server",
-  "version": "1.1.0",
+  "version": "1.2.0",
   "description": "Standalone watch room server for MoonTVPlus",
   "main": "dist/index.js",
   "type": "module",

src/index.ts

@@ -61,7 +61,7 @@ app.get('/stats', (req, res) => {
 app.get('/', (_req, res) => {
   res.json({
     name: 'Watch Room Server',
-    version: '1.1.0',
+    version: '1.2.0',
     description: 'Standalone watch room server for MoonTVPlus',
     endpoints: {
       health: '/health',

src/types.ts

@@ -12,7 +12,7 @@ export type RTCIceCandidateInit = {
   sdpMid?: string | null;
 };
 
-export type RoomType = 'sync' | 'screen';
+export type RoomType = 'sync' | 'screen' | 'music';
 
 export interface ScreenState {
   type: 'screen';
@@ -22,6 +22,29 @@ export interface ScreenState {
   startedAt?: number;
 }
 
+export interface MusicQueueItem {
+  id: string;
+  name: string;
+  artist: string;
+  album?: string;
+  pic?: string;
+  platform: string;
+  songmid?: string;
+  duration?: number;
+  durationText?: string;
+}
+
+export interface MusicSyncState {
+  type: 'music';
+  song: MusicQueueItem;
+  nextSong: MusicQueueItem | null;
+  currentTime: number;
+  isPlaying: boolean;
+  quality: string;
+  playMode: 'loop' | 'single' | 'random';
+  updatedAt: number;
+}
+
 export interface Room {
   id: string;
   name: string;
@@ -33,7 +56,7 @@ export interface Room {
   ownerName: string;
   ownerToken: string;
   memberCount: number;
-  currentState: PlayState | LiveState | ScreenState | null;
+  currentState: PlayState | LiveState | ScreenState | MusicSyncState | null;
   createdAt: number;
   lastOwnerHeartbeat: number;
 }
@@ -102,6 +125,12 @@ export interface ServerToClientEvents {
   'screen:offer': (data: { userId: string; offer: RTCSessionDescriptionInit }) => void;
   'screen:answer': (data: { userId: string; answer: RTCSessionDescriptionInit }) => void;
   'screen:ice': (data: { userId: string; candidate: RTCIceCandidateInit }) => void;
+  'music:change': (state: MusicSyncState) => void;
+  'music:update': (state: MusicSyncState) => void;
+  'music:play': (state: MusicSyncState) => void;
+  'music:pause': (state: MusicSyncState) => void;
+  'music:seek': (state: MusicSyncState) => void;
+  'music:queue': (state: MusicSyncState) => void;
   'chat:message': (message: ChatMessage) => void;
   'voice:offer': (data: { userId: string; offer: RTCSessionDescriptionInit }) => void;
   'voice:answer': (data: { userId: string; answer: RTCSessionDescriptionInit }) => void;
@@ -159,6 +188,13 @@ export interface ClientToServerEvents {
   'screen:answer': (data: { targetUserId: string; answer: RTCSessionDescriptionInit }) => void;
   'screen:ice': (data: { targetUserId: string; candidate: RTCIceCandidateInit }) => void;
 
+  'music:change': (state: MusicSyncState) => void;
+  'music:update': (state: MusicSyncState) => void;
+  'music:play': (state: MusicSyncState) => void;
+  'music:pause': (state: MusicSyncState) => void;
+  'music:seek': (state: MusicSyncState) => void;
+  'music:queue': (state: MusicSyncState) => void;
+
   'chat:message': (data: { content: string; type: 'text' | 'emoji' }) => void;
 
   'voice:offer': (data: { targetUserId: string; offer: RTCSessionDescriptionInit }) => void;

src/watch-room-server.ts

@@ -344,6 +344,78 @@ export class WatchRoomServer {
         });
       });
 
+      socket.on('music:change', (state) => {
+        const roomInfo = this.socketToRoom.get(socket.id);
+        if (!roomInfo || !roomInfo.isOwner) return;
+
+        const room = this.rooms.get(roomInfo.roomId);
+        if (room?.roomType === 'music') {
+          room.currentState = state;
+          this.rooms.set(roomInfo.roomId, room);
+          socket.to(roomInfo.roomId).emit('music:change', state);
+        }
+      });
+
+      socket.on('music:update', (state) => {
+        const roomInfo = this.socketToRoom.get(socket.id);
+        if (!roomInfo || !roomInfo.isOwner) return;
+
+        const room = this.rooms.get(roomInfo.roomId);
+        if (room?.roomType === 'music') {
+          room.currentState = state;
+          this.rooms.set(roomInfo.roomId, room);
+          socket.to(roomInfo.roomId).emit('music:update', state);
+        }
+      });
+
+      socket.on('music:queue', (state) => {
+        const roomInfo = this.socketToRoom.get(socket.id);
+        if (!roomInfo || !roomInfo.isOwner) return;
+
+        const room = this.rooms.get(roomInfo.roomId);
+        if (room?.roomType === 'music') {
+          room.currentState = state;
+          this.rooms.set(roomInfo.roomId, room);
+          socket.to(roomInfo.roomId).emit('music:queue', state);
+        }
+      });
+
+      socket.on('music:play', (state) => {
+        const roomInfo = this.socketToRoom.get(socket.id);
+        if (!roomInfo || !roomInfo.isOwner) return;
+
+        const room = this.rooms.get(roomInfo.roomId);
+        if (room?.roomType === 'music') {
+          room.currentState = state;
+          this.rooms.set(roomInfo.roomId, room);
+          socket.to(roomInfo.roomId).emit('music:play', state);
+        }
+      });
+
+      socket.on('music:pause', (state) => {
+        const roomInfo = this.socketToRoom.get(socket.id);
+        if (!roomInfo || !roomInfo.isOwner) return;
+
+        const room = this.rooms.get(roomInfo.roomId);
+        if (room?.roomType === 'music') {
+          room.currentState = state;
+          this.rooms.set(roomInfo.roomId, room);
+          socket.to(roomInfo.roomId).emit('music:pause', state);
+        }
+      });
+
+      socket.on('music:seek', (state) => {
+        const roomInfo = this.socketToRoom.get(socket.id);
+        if (!roomInfo || !roomInfo.isOwner) return;
+
+        const room = this.rooms.get(roomInfo.roomId);
+        if (room?.roomType === 'music') {
+          room.currentState = state;
+          this.rooms.set(roomInfo.roomId, room);
+          socket.to(roomInfo.roomId).emit('music:seek', state);
+        }
+      });
+
       // 聊天消息
       socket.on('chat:message', (data) => {
         const roomInfo = this.socketToRoom.get(socket.id);