diff --git a/server/src/index.ts b/server/src/index.ts index 90da983..99d67ad 100644 --- a/server/src/index.ts +++ b/server/src/index.ts @@ -941,6 +941,8 @@ app.post('/api/volume', (req: Request, res: Response) => { // Kein aktiver Player: nur persistieren für nächste Wiedergabe persistedState.volumes[guildId] = safeVolume; writePersistedState(persistedState); + // Broadcast neue Lautstärke an alle Clients + sseBroadcast({ type: 'volume', guildId, volume: safeVolume }); return res.json({ ok: true, volume: safeVolume, persistedOnly: true }); } state.currentVolume = safeVolume; @@ -950,6 +952,8 @@ app.post('/api/volume', (req: Request, res: Response) => { } persistedState.volumes[guildId] = safeVolume; writePersistedState(persistedState); + // Broadcast neue Lautstärke an alle Clients + sseBroadcast({ type: 'volume', guildId, volume: safeVolume }); return res.json({ ok: true, volume: safeVolume }); } catch (e: any) { console.error('Volume-Fehler:', e); @@ -1075,7 +1079,7 @@ app.get('/api/events', (req: Request, res: Response) => { // Snapshot senden try { - res.write(`data: ${JSON.stringify({ type: 'snapshot', party: Array.from(partyActive), selected: persistedState.selectedChannels ?? {} })}\n\n`); + res.write(`data: ${JSON.stringify({ type: 'snapshot', party: Array.from(partyActive), selected: persistedState.selectedChannels ?? {}, volumes: persistedState.volumes ?? {} })}\n\n`); } catch {} // Ping, damit Proxies die Verbindung offen halten diff --git a/web/src/App.tsx b/web/src/App.tsx index ca441a9..6b7899c 100644 --- a/web/src/App.tsx +++ b/web/src/App.tsx @@ -106,6 +106,15 @@ export default function App() { setSelected(newVal); } } catch {} + try { + const vols = msg?.volumes || {}; + const cur = selectedRef.current || ''; + const gid = cur ? cur.split(':')[0] : ''; + if (gid && typeof vols[gid] === 'number') { + const v = vols[gid]; + setVolume(v); + } + } catch {} } else if (msg?.type === 'channel') { try { const gid = msg.guildId; @@ -116,6 +125,16 @@ export default function App() { if (curGid === gid) setSelected(`${gid}:${cid}`); } } catch {} + } else if (msg?.type === 'volume') { + try { + const gid = msg.guildId; + const v = msg.volume; + const cur = selectedRef.current || ''; + const curGid = cur ? cur.split(':')[0] : ''; + if (gid && curGid === gid && typeof v === 'number') { + setVolume(v); + } + } catch {} } }); return () => { try { unsub(); } catch {} };