Honor go-live destination subsets per session

Author: rndrntwrk

src/actions/legacyCompat.test.ts

@@ -149,7 +149,22 @@ describe('legacyCompatibilityActions', () => {
 
     assert.equal(ok, true);
     assert.equal(updateCalls.length, 1);
-    assert.equal(toggleCalls.length, 1);
+    assert.ok(
+      toggleCalls.some(
+        (call) =>
+          call.platformId === 'twitch' &&
+          call.enabled === true &&
+          call.sessionId === 'session-1',
+      ),
+    );
+    assert.ok(
+      toggleCalls.some(
+        (call) =>
+          call.platformId === 'custom' &&
+          call.enabled === false &&
+          call.sessionId === 'session-1',
+      ),
+    );
     assert.equal(stopCalls.length, 0);
     assert.match(requestedUrls[0] ?? '', /\/stream\/start$/);
     assert.match(requestedUrls[1] ?? '', /\/stream\/status$/);
@@ -162,10 +177,18 @@ describe('legacyCompatibilityActions', () => {
     assert.equal(lastPayload.content?.success, true);
     assert.equal(lastPayload.content?.data?.cloudflareConnected, true);
     assert.equal(lastPayload.content?.data?.cfSessionId, 'cf-session-1');
-    assert.equal(
-      (lastPayload.content?.data?.destinationSync as { applied?: unknown[] } | undefined)?.applied
-        ?.length,
-      1,
+    const destinationSync = lastPayload.content?.data?.destinationSync as
+      | { applied?: Array<{ platformId?: string; enabled?: boolean }> }
+      | undefined;
+    assert.ok(
+      destinationSync?.applied?.some(
+        (entry) => entry.platformId === 'twitch' && entry.enabled === true,
+      ),
+    );
+    assert.ok(
+      destinationSync?.applied?.some(
+        (entry) => entry.platformId === 'custom' && entry.enabled === false,
+      ),
     );
     },
   );

src/actions/legacyCompat.ts

@@ -492,6 +492,9 @@ async function applyConfiguredDestinations(
     platformId,
     error: 'unsupported_platform',
   }));
+  const deselectedMappings = requestedPlatformSet.size > 0
+    ? DESTINATION_MAPPINGS.filter((mapping) => !requestedPlatformSet.has(mapping.platformId))
+    : [];
 
   for (const mapping of mappings) {
     const enabled =
@@ -536,8 +539,24 @@ async function applyConfiguredDestinations(
     }
   }
 
+  for (const mapping of deselectedMappings) {
+    try {
+      await service.togglePlatform(mapping.platformId, false, sessionId);
+      applied.push({
+        platformId: mapping.platformId,
+        enabled: false,
+        configured: false,
+      });
+    } catch (error) {
+      failed.push({
+        platformId: mapping.platformId,
+        error: `session_disable_failed: ${(error as Error).message}`,
+      });
+    }
+  }
+
   return {
-    attempted: mappings.length + unsupported.length,
+    attempted: mappings.length + unsupported.length + deselectedMappings.length,
     applied,
     skipped,
     failed,