From d9ead78083ad20c7939b7397e0b59d6a8a5c4c30 Mon Sep 17 00:00:00 2001
From: JellyBrick <shlee1503@naver.com>
Date: Mon, 12 May 2025 08:25:17 +0900
Subject: [PATCH] fix(music-together): fix data integrity

---
 src/plugins/music-together/index.ts | 19 +++++++++++++++----
 1 file changed, 15 insertions(+), 4 deletions(-)

diff --git a/src/plugins/music-together/index.ts b/src/plugins/music-together/index.ts
index 38064f2b..6234318a 100644
--- a/src/plugins/music-together/index.ts
+++ b/src/plugins/music-together/index.ts
@@ -218,7 +218,12 @@ export default createPlugin<
 
         switch (event.type) {
           case 'ADD_SONGS': {
-            if (conn && this.permission === 'host-only') return;
+            if (conn && this.permission === 'host-only') {
+              await this.connection?.broadcast('SYNC_QUEUE', {
+                videoList: this.queue?.videoList ?? [],
+              });
+              return;
+            }
 
             const videoList: VideoData[] = event.payload.videoList.map(
               (it) => ({
@@ -232,10 +237,18 @@ export default createPlugin<
               ...event.payload,
               videoList,
             });
+            await this.connection?.broadcast('SYNC_QUEUE', {
+              videoList,
+            });
             break;
           }
           case 'REMOVE_SONG': {
-            if (conn && this.permission === 'host-only') return;
+            if (conn && this.permission === 'host-only') {
+              await this.connection?.broadcast('SYNC_QUEUE', {
+                videoList: this.queue?.videoList ?? [],
+              });
+              return;
+            }
 
             this.queue?.removeVideo(event.payload.index);
             await this.connection?.broadcast('REMOVE_SONG', event.payload);
@@ -385,7 +398,6 @@ export default createPlugin<
                 ownerId: it.ownerId ?? this.connection!.id,
               })),
             });
-            await this.connection?.broadcast('SYNC_QUEUE', undefined);
             break;
           }
           case 'REMOVE_SONG': {
@@ -394,7 +406,6 @@ export default createPlugin<
           }
           case 'MOVE_SONG': {
             await this.connection?.broadcast('MOVE_SONG', event.payload);
-            await this.connection?.broadcast('SYNC_QUEUE', undefined);
             break;
           }
           case 'SYNC_PROGRESS': {