add demo mode (#11)

Author: tariknz

src/app/bridge/iracingSdk/iracingSdkBridge.ts

@@ -1,50 +1,65 @@
 import { IRacingSDK } from 'irsdk-node';
 import { TelemetrySink } from './telemetrySink';
 import { OverlayManager } from 'src/app/overlayManager';
+import type { IrSdkBridge, Session, Telemetry } from '@irdashies/types';
 
 const TIMEOUT = 1000;
 
 export async function publishIRacingSDKEvents(
   telemetrySink: TelemetrySink,
   overlayManager: OverlayManager
-) {
+): Promise<IrSdkBridge> {
   console.log('Loading iRacing SDK bridge...');
 
-  setInterval(async () => {
+  let shouldStop = false;
+  const runningStateInterval = setInterval(async () => {
     const isSimRunning = await IRacingSDK.IsSimRunning();
     console.log('Sending running state to window', isSimRunning);
     overlayManager.publishMessage('runningState', isSimRunning);
   }, 2000);
 
-  while (true) {
-    if (await IRacingSDK.IsSimRunning()) {
-      console.log('iRacing is running');
-      const sdk = new IRacingSDK();
-      sdk.autoEnableTelemetry = true;
+  // Start the telemetry loop in the background
+  (async () => {
+    while (!shouldStop) {
+      if (await IRacingSDK.IsSimRunning()) {
+        console.log('iRacing is running');
+        const sdk = new IRacingSDK();
+        sdk.autoEnableTelemetry = true;
 
-      await sdk.ready();
+        await sdk.ready();
 
-      while (sdk.waitForData(TIMEOUT)) {
-        const telemetry = sdk.getTelemetry();
-        const session = sdk.getSessionData();
-        await new Promise((resolve) => setTimeout(resolve, 1000 / 60));
+        while (!shouldStop && sdk.waitForData(TIMEOUT)) {
+          const telemetry = sdk.getTelemetry();
+          const session = sdk.getSessionData();
+          await new Promise((resolve) => setTimeout(resolve, 1000 / 60));
 
-        if (telemetry) {
-          overlayManager.publishMessage('telemetry', telemetry);
-          telemetrySink.addTelemetry(telemetry);
-        }
+          if (telemetry) {
+            overlayManager.publishMessage('telemetry', telemetry);
+            telemetrySink.addTelemetry(telemetry);
+          }
 
-        if (session) {
-          overlayManager.publishMessage('sessionData', session);
-          telemetrySink.addSession(session);
+          if (session) {
+            overlayManager.publishMessage('sessionData', session);
+            telemetrySink.addSession(session);
+          }
         }
+
+        console.log('iRacing is no longer publishing telemetry');
+      } else {
+        console.log('iRacing is not running');
       }
 
-      console.log('iRacing is no longer publishing telemetry');
-    } else {
-      console.log('iRacing is not running');
+      await new Promise((resolve) => setTimeout(resolve, TIMEOUT));
     }
+  })();
 
-    await new Promise((resolve) => setTimeout(resolve, TIMEOUT));
-  }
+  return {
+    onTelemetry: (callback: (value: Telemetry) => void) => callback({} as Telemetry),
+    onSessionData: (callback: (value: Session) => void) => callback({} as Session),
+    onRunningState: (callback: (value: boolean) => void) => callback(false),
+    stop: () => {
+      shouldStop = true;
+      clearInterval(runningStateInterval);
+    }
+  };
 }

src/app/bridge/iracingSdk/mock-data/mockSdkBridge.ts

@@ -18,4 +18,5 @@ export async function publishIRacingSDKEvents(
   bridge.onRunningState((running) => {
     overlayManager.publishMessage('runningState', running);
   });
+  return bridge;
 }