[wip] recorder/task

Implement dynamic FFMPEG management for audio recording with explicit task events and standardized parameter handling.

Author: ThanhDodeurOdoo

src/models/ffmpeg.ts

@@ -1,8 +1,12 @@
 import { EventEmitter } from "node:events";
 
+let currentId = 0;
+
 export class FFMPEG extends EventEmitter {
+    id: number;
     constructor() {
         super();
+        this.id = currentId++ % 999999;
     }
 
     async kill() {}

src/models/recorder.ts

@@ -1,7 +1,7 @@
 import { EventEmitter } from "node:events";
 
 import { getFolder, type Folder } from "#src/services/resources.ts";
-import { RecordingTask } from "#src/models/recording_task.ts";
+import { RecordingTask, type RecordingParameters } from "#src/models/recording_task.ts";
 import { Logger } from "#src/utils/utils.ts";
 
 import type { Channel } from "#src/models/channel";
@@ -108,7 +108,6 @@ export class Recorder extends EventEmitter {
         this.isRecording = false;
         this.isTranscribing = false;
         this.state = RECORDER_STATE.STOPPING;
-        // remove all listener from the channel
         // TODO name
         const name = "test-folder-name";
         const results = await this.stopTasks();
@@ -130,14 +129,7 @@ export class Recorder extends EventEmitter {
         if (!session) {
             return;
         }
-        this.tasks.set(
-            session.id,
-            new RecordingTask(session, {
-                audio: this.isRecording || this.isTranscribing,
-                camera: this.isRecording,
-                screen: this.isRecording
-            })
-        );
+        this.tasks.set(session.id, new RecordingTask(session, this.getTaskParameters()));
     }
 
     private onSessionLeave(id: SessionId) {
@@ -173,10 +165,9 @@ export class Recorder extends EventEmitter {
     }
 
     private async update() {
+        const params = this.getTaskParameters();
         for (const task of this.tasks.values()) {
-            task.audio = this.isRecording || this.isTranscribing;
-            task.camera = this.isRecording;
-            task.screen = this.isRecording;
+            Object.assign(task, params);
         }
     }
 
@@ -185,10 +176,7 @@ export class Recorder extends EventEmitter {
         this.folder = getFolder();
         logger.trace(`TO IMPLEMENT: recording channel ${this.channel.name}`);
         for (const [sessionId, session] of this.channel.sessions) {
-            this.tasks.set(
-                sessionId,
-                new RecordingTask(session, { audio: true, camera: true, screen: true })
-            );
+            this.tasks.set(sessionId, new RecordingTask(session, this.getTaskParameters()));
         }
         this.channel.on("sessionJoin", this.onSessionJoin);
         this.channel.on("sessionLeave", this.onSessionLeave);
@@ -202,4 +190,12 @@ export class Recorder extends EventEmitter {
         this.tasks.clear();
         return Promise.allSettled(proms);
     }
+
+    private getTaskParameters(): RecordingParameters {
+        return {
+            audio: this.isRecording || this.isTranscribing,
+            camera: this.isRecording,
+            screen: this.isRecording
+        };
+    }
 }

src/models/recording_task.ts

@@ -7,6 +7,21 @@ import { FFMPEG } from "#src/models/ffmpeg.ts";
 
 import type { PlainTransport } from "mediasoup/node/lib/PlainTransportTypes";
 
+export type RecordingParameters = {
+    audio: boolean;
+    camera: boolean;
+    screen: boolean;
+};
+
+export enum RECORDING_TASK_EVENT {
+    AUDIO_STARTED = "audio-started",
+    AUDIO_STOPPED = "audio-stopped",
+    CAMERA_STARTED = "camera-started",
+    CAMERA_STOPPED = "camera-stopped",
+    SCREEN_STARTED = "screen-started",
+    SCREEN_STOPPED = "screen-stopped"
+}
+
 const logger = new Logger("RECORDING_TASK");
 
 export class RecordingTask extends EventEmitter {
@@ -37,8 +52,14 @@ export class RecordingTask extends EventEmitter {
             `TO IMPLEMENT: recording task for session ${this.session.id} - audio: ${value}`
         );
         logger.debug(`rtp: ${this._audioRTP}, ffmpeg: ${this._audioFFFMPEG}`);
-        // await record(audio)
-        // if (this.isStopped) { cleanup(audio) };
+        if (this._audio) {
+            this._audioFFFMPEG = new FFMPEG(); // should take RTP info as param
+            this.emit(RECORDING_TASK_EVENT.AUDIO_STARTED, this._audioFFFMPEG.id);
+        } else if (this._audioFFFMPEG) {
+            this.emit(RECORDING_TASK_EVENT.AUDIO_STOPPED, this._audioFFFMPEG.id);
+            this._audioFFFMPEG.kill();
+            this._audioFFFMPEG = undefined;
+        }
     }
     set camera(value: boolean) {
         if (value === this._camera || this.isStopped) {
@@ -61,10 +82,7 @@ export class RecordingTask extends EventEmitter {
         logger.debug(`rtp: ${this._screenRTP}, ffmpeg: ${this._screenFFMPEG}`);
     }
 
-    constructor(
-        session: Session,
-        { audio, camera, screen }: { audio?: boolean; camera?: boolean; screen?: boolean } = {}
-    ) {
+    constructor(session: Session, { audio, camera, screen }: RecordingParameters) {
         super();
         this.session = session;
         this._audio = audio ?? false;