feat(streaming): integrate native external streamer MVP

opennow-stable/package.json

@@ -16,7 +16,8 @@
   "main": "dist-electron/main/index.js",
   "scripts": {
     "dev": "electron-vite dev",
-    "build": "electron-vite build",
+    "build:native-runtime": "cargo build --manifest-path ../opennow-streamer/Cargo.toml --release && node ./scripts/bundle-native-runtime.mjs",
+    "build": "npm run build:native-runtime && electron-vite build",
     "preview": "electron-vite preview",
     "dist": "npm run build && cross-env CSC_IDENTITY_AUTO_DISCOVERY=false electron-builder",
     "dist:signed": "npm run build && electron-builder",
@@ -61,7 +62,11 @@
     "files": [
       "dist/**",
       "dist-electron/**",
-      "package.json"
+      "package.json",
+      "resources/bin/**"
+    ],
+    "extraResources": [
+      { "from": "resources/bin", "to": "bin" }
     ],
     "asar": true,
     "win": {

opennow-stable/scripts/bundle-native-runtime.mjs

@@ -0,0 +1,43 @@
+import { cpSync, existsSync, mkdirSync, realpathSync } from 'node:fs';
+import { dirname, join, resolve } from 'node:path';
+import { fileURLToPath } from 'node:url';
+import { execFileSync } from 'node:child_process';
+
+const __filename = fileURLToPath(import.meta.url);
+const __dirname = dirname(__filename);
+const repoRoot = resolve(__dirname, '../..');
+const outDir = resolve(repoRoot, 'opennow-stable/resources/bin');
+mkdirSync(outDir, { recursive: true });
+
+const exeSuffix = process.platform === 'win32' ? '.exe' : '';
+const streamerCandidates = [
+  resolve(repoRoot, `opennow-streamer/target/release/opennow-streamer${exeSuffix}`),
+  resolve(repoRoot, `opennow-streamer/target/debug/opennow-streamer${exeSuffix}`),
+];
+const streamer = streamerCandidates.find((p) => existsSync(p));
+if (!streamer) {
+  throw new Error(`Missing opennow-streamer binary. Build it first: ${streamerCandidates.join(', ')}`);
+}
+cpSync(streamer, join(outDir, `opennow-streamer${exeSuffix}`));
+
+if (process.platform === 'linux') {
+  const sdlLibDir = execFileSync('pkg-config', ['--variable=libdir', 'sdl2'], { encoding: 'utf8' }).trim();
+  const sdlCandidates = [
+    join(sdlLibDir, 'libSDL2-2.0.so.0'),
+    '/lib/x86_64-linux-gnu/libSDL2-2.0.so.0',
+    '/usr/lib/x86_64-linux-gnu/libSDL2-2.0.so.0',
+  ];
+  const sdlLib = sdlCandidates.find((candidate) => existsSync(candidate));
+  if (!sdlLib) {
+    throw new Error(`Missing libSDL2-2.0.so.0. Checked: ${sdlCandidates.join(', ')}`);
+  }
+  cpSync(realpathSync(sdlLib), join(outDir, 'libSDL2-2.0.so.0'));
+}
+
+const ffmpegEnv = process.env.OPENNOW_FFMPEG_BIN;
+const ffmpeg = ffmpegEnv || execFileSync(process.platform === 'win32' ? 'where' : 'which', ['ffmpeg'], { encoding: 'utf8' }).split(/\r?\n/).find(Boolean);
+if (!ffmpeg || !existsSync(ffmpeg)) {
+  throw new Error('Missing ffmpeg binary. Set OPENNOW_FFMPEG_BIN or ensure ffmpeg is on PATH.');
+}
+cpSync(ffmpeg, join(outDir, `ffmpeg${exeSuffix}`));
+console.log(`Bundled native runtime into ${outDir}`);

opennow-stable/src/main/index.ts

@@ -70,6 +70,7 @@ import {
 } from "./gfn/games";
 import { fetchSubscription, fetchDynamicRegions } from "./gfn/subscription";
 import { GfnSignalingClient } from "./gfn/signaling";
+import { StreamerManager } from "./services/streamerManager";
 import { isSessionError, SessionError, GfnErrorCode } from "./gfn/errorCodes";
 
 const __filename = fileURLToPath(import.meta.url);
@@ -187,6 +188,7 @@ let signalingClient: GfnSignalingClient | null = null;
 let signalingClientKey: string | null = null;
 let authService: AuthService;
 let settingsManager: SettingsManager;
+let streamerManager: StreamerManager;
 const SCREENSHOT_LIMIT = 60;
 
 function getScreenshotDirectory(): string {
@@ -481,9 +483,16 @@ async function listRecordings(): Promise<RecordingEntry[]> {
 }
 
 function emitToRenderer(event: MainToRendererSignalingEvent): void {
-  if (mainWindow && !mainWindow.isDestroyed()) {
-    mainWindow.webContents.send(IPC_CHANNELS.SIGNALING_EVENT, event);
-  }
+  void streamerManager?.forwardSignalingEvent(event).then((handled) => {
+    if (!handled && mainWindow && !mainWindow.isDestroyed()) {
+      mainWindow.webContents.send(IPC_CHANNELS.SIGNALING_EVENT, event);
+    }
+  }).catch((error) => {
+    console.error("[Streamer] Failed to forward signaling event:", error);
+    if (mainWindow && !mainWindow.isDestroyed()) {
+      mainWindow.webContents.send(IPC_CHANNELS.SIGNALING_EVENT, event);
+    }
+  });
 }
 
 async function createMainWindow(): Promise<void> {
@@ -769,6 +778,14 @@ function registerIpcHandlers(): void {
     return signalingClient.requestKeyframe(payload);
   });
 
+  ipcMain.handle(IPC_CHANNELS.STREAMER_START, async (_event, payload) => {
+    await streamerManager.start(payload);
+  });
+
+  ipcMain.handle(IPC_CHANNELS.STREAMER_STOP, async (): Promise<void> => {
+    await streamerManager.stop();
+  });
+
   // Toggle fullscreen via IPC (for completeness)
   ipcMain.handle(IPC_CHANNELS.TOGGLE_FULLSCREEN, async () => {
     if (mainWindow && !mainWindow.isDestroyed()) {
@@ -1153,6 +1170,19 @@ app.whenReady().then(async () => {
   await authService.initialize();
 
   settingsManager = getSettingsManager();
+  streamerManager = new StreamerManager(
+    () => mainWindow,
+    {
+      sendAnswer: async (payload) => {
+        if (!signalingClient) throw new Error("Signaling is not connected");
+        await signalingClient.sendAnswer(payload);
+      },
+      sendIceCandidate: async (payload) => {
+        if (!signalingClient) throw new Error("Signaling is not connected");
+        await signalingClient.sendIceCandidate(payload);
+      },
+    },
+  );
 
   // Request microphone permission on macOS at startup
   if (process.platform === "darwin") {
@@ -1247,6 +1277,7 @@ app.on("window-all-closed", () => {
 
 app.on("before-quit", () => {
   refreshScheduler.stop();
+  void streamerManager?.stop();
   signalingClient?.disconnect();
   signalingClient = null;
   signalingClientKey = null;