From fdcd53d149cdc8a8cd1ab94b67dd0ce8f7b1b397 Mon Sep 17 00:00:00 2001
From: asepharyana <superaseph@gmail.com>
Date: Wed, 2 Sep 2026 02:26:26 +0700
Subject: [PATCH] =?UTF-8?q?debug(video):=20enhanced=20diag=20=E2=80=94=20R?=
 =?UTF-8?q?EADY=20sessions.voice=20+=20broadcaster=5Fuser=5Fids=20+=20all?=
 =?UTF-8?q?=20raw=20types?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Dump all WS raw event types after 10s (see if GUILD_CREATE exists at all),
and log broadcaster_user_ids + sessions.voice from READY payload.
Selfbot may RESUME (skip GUILD_CREATE) — voice data may only be in READY.
---
 .../modules/voice-recording/videoRecorder.ts  | 33 +++++++++++++++++--
 1 file changed, 31 insertions(+), 2 deletions(-)

diff --git a/services/discord-gateway/src/modules/voice-recording/videoRecorder.ts b/services/discord-gateway/src/modules/voice-recording/videoRecorder.ts
index c2021982..f040d280 100644
--- a/services/discord-gateway/src/modules/voice-recording/videoRecorder.ts
+++ b/services/discord-gateway/src/modules/voice-recording/videoRecorder.ts
@@ -58,6 +58,9 @@ const pendingGuildCreateVoiceStates = new Map<
 
 let _client: Client | undefined;
 let _listenerAttached = false;
+// DIAG: collect all raw event types for ~10s after first raw event
+const _allRawTypes = new Set<string>();
+let _rawDiagLogged = false;
 /** Resolved at runtime from config (kept default as fallback). */
 let _recordingsDir = "/var/lib/gmw/recordings";
 
@@ -72,6 +75,8 @@ export function __resetVideoRecorderState(): void {
   pendingGuildCreateVoiceStates.clear();
   _listenerAttached = false;
   _client = undefined;
+  _allRawTypes.clear();
+  _rawDiagLogged = false;
 }
 
 /**
@@ -102,13 +107,30 @@ export function setVideoRecorderClient(client: Client | undefined) {
       d?: { voice_states?: unknown; id?: unknown };
     } | null;
     if (!p?.t) return;
-    // DIAG: log every raw event type once until we see GUILD_CREATE shape.
+    // DIAG: log all event types seen after READY (belt-and-suspenders)
+    if (_allRawTypes.size < 50) _allRawTypes.add(p.t);
+    // DIAG: after 10s, dump all raw types seen
+    if (!_rawDiagLogged) {
+      _rawDiagLogged = true;
+      setTimeout(() => {
+        logger.info(
+          { rawEventTypes: [..._allRawTypes].sort() },
+          "RAW DIAG: all WS raw event types (10s snapshot)",
+        );
+      }, 10_000);
+    }
+    // Log significant events
     if (
       p.t === "GUILD_CREATE" ||
       p.t === "READY" ||
-      p.t === "GUILD_MEMBERS_CHUNK"
+      p.t === "GUILD_MEMBERS_CHUNK" ||
+      (p.t.startsWith("GUILD") && !p.t.includes("UPDATE"))
     ) {
       const d = p.d as Record<string, unknown>;
+      const dAny = d as unknown as {
+        broadcaster_user_ids?: unknown;
+        sessions?: unknown;
+      };
       logger.info(
         {
           rawType: p.t,
@@ -116,6 +138,13 @@ export function setVideoRecorderClient(client: Client | undefined) {
           voiceStatesCount: Array.isArray(d?.voice_states)
             ? (d.voice_states as unknown[]).length
             : -1,
+          broadcasterUserIds: dAny.broadcaster_user_ids,
+          sessionVoice: Array.isArray(dAny.sessions)
+            ? (dAny.sessions as Array<{ voice?: unknown; session_id?: unknown }>)
+                .map((s) => s.voice)
+                .filter(Boolean)
+                .slice(0, 5)
+            : undefined,
           dKeys: Object.keys(d ?? {}).slice(0, 10),
         },
         "RAW diag: GUILD_CREATE/READY/GUILD_MEMBERS_CHUNK",