Added Smelter.stats() to the smelter-node package

Author: JBRS307

ts/examples/node-examples/src/audio.tsx

@@ -4,6 +4,10 @@ import { downloadAllAssets, ffplayStartRtmpServerAsync } from './utils';
 import path from 'path';
 import { useState, useEffect } from 'react';
 
+function sleep(ms: number): Promise<void> {
+  return new Promise(resolve => setTimeout(resolve, ms));
+}
+
 function ExampleApp() {
   const [streamWithAudio, setStream] = useState('input_1');
   useEffect(() => {
@@ -85,5 +89,12 @@ async function run() {
   });
 
   await smelter.start();
+
+  while (true) {
+    await sleep(1000);
+    console.clear();
+    let json_string = await smelter.stats();
+    console.dir(json_string, { depth: null });
+  }
 }
 void run();

ts/smelter-core/src/api.ts

@@ -160,7 +160,6 @@ export class ApiClient {
     return this.serverManager.sendRequest({
       method: 'GET',
       route: `/stats`,
-      body: {},
     })
   }
 }

ts/smelter-core/src/index.ts

@@ -2,7 +2,7 @@ import * as Output from './api/output';
 import * as Input from './api/input';
 
 export { Output, Input };
-export { ApiClient, ApiRequest, MultipartRequest, RegisterInputResponse } from './api';
+export { ApiClient, ApiRequest, MultipartRequest, RegisterInputResponse, StatsResponse } from './api';
 export { Smelter } from './live/compositor';
 export { OfflineSmelter } from './offline/compositor';
 export { SmelterManager, SetupInstanceOptions } from './smelterManager';

ts/smelter-node/src/api.ts

@@ -44,3 +44,5 @@ export type RegisterWhipServerInputResponse = {
   bearerToken: string;
   endpointRoute: string;
 };
+
+export type { StatsResponse } from '@swmansion/smelter-core';

ts/smelter-node/src/live/compositor.ts

@@ -3,7 +3,7 @@ import FormData from 'form-data';
 import fetch from 'node-fetch';
 import type { Renderers } from '@swmansion/smelter';
 import type { SmelterManager } from '@swmansion/smelter-core';
-import { StateGuard, Smelter as CoreSmelter } from '@swmansion/smelter-core';
+import { StateGuard, Smelter as CoreSmelter, type StatsResponse } from '@swmansion/smelter-core';
 
 import LocallySpawnedInstance from '../manager/locallySpawnedInstance';
 import { createLogger } from '../logger';
@@ -179,4 +179,10 @@ export default class Smelter {
       await this.coreSmelter.terminate();
     });
   }
+
+  public async stats(): Promise<StatsResponse> {
+    return await this.scheduler.run(async () => {
+      return this.coreSmelter.stats();
+    });
+  }
 }