fix: add loops to restart

Author: RyanPotat

eslint.config.mjs

@@ -21,32 +21,32 @@ export default [
   ...compat.extends('plugin:@typescript-eslint/recommended'),
   ...compat.extends('airbnb-base/legacy'),
   {
-  plugins: {
-    '@typescript-eslint': typescriptEslint,
-  },
+    plugins: {
+      '@typescript-eslint': typescriptEslint,
+    },
 
-  languageOptions: {
+    languageOptions: {
       globals: {
-          ...globals.browser,
-          ...Object.fromEntries(Object.entries(globals.commonjs).map(([key]) => [key, 'off'])),
+        ...globals.browser,
+        ...Object.fromEntries(Object.entries(globals.commonjs).map(([key]) => [key, 'off'])),
       },
 
       parser: tsParser,
       ecmaVersion: 2025,
       sourceType: 'module',
 
       parserOptions: {
-          requireConfigFile: false,
-          babelOptions: { plugins: ['@typescript-eslint/eslint-plugin'] },
+        requireConfigFile: false,
+        babelOptions: { plugins: ['@typescript-eslint/eslint-plugin'] },
       },
-  },
+    },
 
-  rules: {
+    rules: {
       strict: ['error', 'global'],
 
       quotes: ['error', 'single', {
-          allowTemplateLiterals: true,
-          avoidEscape: true,
+        allowTemplateLiterals: true,
+        avoidEscape: true,
       }],
 
       'no-eval': 'off',
@@ -55,7 +55,7 @@ export default [
       'no-plusplus': 'off',
 
       'no-unused-vars': ['error', {
-          argsIgnorePattern: 'client|msg',
+        argsIgnorePattern: 'client|msg',
       }],
 
       'no-await-in-loop': 'off',
@@ -95,7 +95,8 @@ export default [
         exports: 'always-multiline',
         functions: 'always-multiline',
       }],
+    },
+  }, {
+    files: ['tests/**/*', '**/*.d.ts'],
   },
-}, {
-  files: ['tests/**/*', '**/*.d.ts'],
-}];
+];

src/broker.ts

@@ -56,6 +56,8 @@ export class NatsClient {
       throw new Error('NATS client not initialized');
     }
 
+    setInterval(() => this.page?.reload(), 10 * 60 * 60 * 1000);
+
     return this.#client;
   }
 
@@ -137,23 +139,6 @@ export class NatsClient {
     return id;
   }
 
-  private async toString(something: any): Promise<string> {
-    if (something instanceof Error) {
-      return something.constructor.name + ': ' + something.message;
-    }
-    if (something instanceof Promise) {
-      return something.then(toString);
-    }
-    if (Array.isArray(something)) {
-      return something.map(this.toString).join(', ');
-    }
-    if (typeof something === 'function' || typeof something === 'symbol') {
-      return something.toString();
-    }
-
-    return JSON.stringify(something);
-  }
-
   public parseMessage<T = any>(data: Uint8Array): T {
     let message: any;
     try {

src/index.ts

@@ -24,6 +24,8 @@ class Streamer {
 
   private restarting = false;
 
+  private restartLoop: NodeJS.Timeout | undefined;
+
   private restartCount = 0;
 
   private clientListener: CDPSession | undefined;
@@ -175,6 +177,16 @@ class Streamer {
       Logger.error('FFmpeg error:', (err as Error).message);
     });
 
+    if (this.restartLoop) {
+      clearInterval(this.restartLoop);
+    }
+
+    this.restartLoop = setInterval(() => {
+      this.restartStream().catch((err) => {
+        Logger.error('Error during restart loop:', (err as Error).message);
+      });
+    }, 48 * 60 * 60 * 1000); // Restart every 2 days.
+
     return ffmpeg;
   }