[IMP] fixup

Author: ThanhDodeurOdoo

src/models/ffmpeg.ts

@@ -0,0 +1,8 @@
+import { EventEmitter } from "node:events";
+
+export class FFMPEG extends EventEmitter {
+
+    constructor() {
+        super();
+    }
+}

src/models/recorder.ts

@@ -1,13 +1,19 @@
-import {EventEmitter} from "node:events";
+import { EventEmitter } from "node:events";
 import type { Channel } from "./channel";
-import {Logger} from "#src/utils/utils.ts";
+import { getFolder } from "#src/services/resources";
+import { Logger } from "#src/utils/utils.ts";
 
+export enum RECORDER_STATE {
+    STARTED = "started",
+    STOPPED = "stopped",
+}
 const logger = new Logger("RECORDER");
 
 export class Recorder extends EventEmitter {
     channel: Channel;
-    state: "started" | "stopped" = "stopped";
+    state: RECORDER_STATE = RECORDER_STATE.STOPPED;
     ffmpeg = null;
+    destPath: string | undefined;
     /** Path to which the final recording will be uploaded to */
     recordingAddress: string;
 
@@ -18,16 +24,28 @@ export class Recorder extends EventEmitter {
     }
 
     async start() {
-        this.state = "started";
-        logger.trace("TO IMPLEMENT");
-        // TODO ffmpeg instance creation, start
+        if (this.state === RECORDER_STATE.STOPPED) {
+            const { path, sealFolder }  = getFolder();
+            this.destPath = path;
+            this.once("stopped", sealFolder);
+            this.state = RECORDER_STATE.STARTED;
+             logger.trace("TO IMPLEMENT");
+             // TODO ffmpeg instance creation for recording to destPath with proper name, start, build timestamps object
+        }
+
         return { state: this.state };
     }
 
     async stop() {
-        this.state = "stopped";
-        logger.trace("TO IMPLEMENT");
-        // TODO ffmpeg instance stop, cleanup, save,...
+        if (this.state === RECORDER_STATE.STARTED) {
+
+            logger.trace("TO IMPLEMENT");
+            this.emit("stopped");
+            // TODO ffmpeg instance stop, cleanup,
+            // only resolve promise and switch state when completely ready to start a new recording.
+            this.state = RECORDER_STATE.STOPPED;
+        }
+
         return { state: this.state };
     }
 }

src/services/resources.ts

@@ -0,0 +1,16 @@
+export async function start(): Promise<void> {
+    // monitors server resources, generate workers to build the streams from the permanent folders
+}
+export async function stop(): Promise<void> {
+}
+
+export function getFolder() {
+    // create a temp folder at a path, returns the path and a function to seal the folder
+    return {
+        path: "",
+        sealFolder: () => {
+            // move the content into a permanent folder location so it can easily be retrieved for processing later
+            // or directly forward for transcription
+        },
+    }
+}