[IMP] wip

Author: ThanhDodeurOdoo

src/models/recorder.ts

@@ -25,9 +25,11 @@ export class Recorder extends EventEmitter {
 
     async start() {
         if (this.state === RECORDER_STATE.STOPPED) {
-            const { path, sealFolder }  = getFolder();
-            this.destPath = path;
-            this.once("stopped", sealFolder);
+            const folder  = getFolder();
+            this.destPath = folder.path;
+            this.once("stopped", ({ name }) => {
+                folder.seal(name);
+            });
             this.state = RECORDER_STATE.STARTED;
              logger.trace("TO IMPLEMENT");
              // TODO ffmpeg instance creation for recording to destPath with proper name, start, build timestamps object
@@ -39,7 +41,7 @@ export class Recorder extends EventEmitter {
     async stop() {
         if (this.state === RECORDER_STATE.STARTED) {
             logger.trace("TO IMPLEMENT");
-            this.emit("stopped");
+            this.emit("stopped", { name: "test" });
             // TODO ffmpeg instance stop, cleanup,
             // only resolve promise and switch state when completely ready to start a new recording.
             this.state = RECORDER_STATE.STOPPED;

src/services/resources.ts

@@ -7,13 +7,16 @@ import { PortLimitReachedError } from "#src/utils/errors.ts";
 import os from "node:os";
 
 const availablePorts: Set<number> = new Set();
+let unique = 1;
 
 export interface RtcWorker extends mediasoup.types.Worker {
     appData: {
         webRtcServer?: mediasoup.types.WebRtcServer;
     };
 }
 
+// TODO maybe write some docstring, file used to manage resources such as folders, workers, ports
+
 const logger = new Logger("RESOURCES");
 const workers = new Set<RtcWorker>();
 const tempDir = os.tmpdir() + "/ongoing_recordings";
@@ -86,27 +89,39 @@ export async function getWorker(): Promise<mediasoup.types.Worker> {
     return leastUsedWorker;
 }
 
-export function getFolder() {
-    const tempName = `${Date.now()}`;
-    const path = `${tempDir}/${tempName}`;
-    // TODO we may want to track these temp folders to remove them periodically (although os.tempDir() has already such a mechanism)
-    return {
-        path,
-        sealFolder: (name: string = tempName) => {
-            // TODO move whatever is in path to
-            console.log(`${config.recording.directory}/${name}`);
-        },
+class Folder {
+    path: string;
+
+    constructor(path: string) {
+        this.path = path;
+    }
+
+    seal(name: string) {
+        console.trace(`TO IMPLEMENT, MOVING TO ${config.recording.directory}/${name}`);
     }
 }
 
-export function getPort(): number {
-    const port = availablePorts.values().next().value;
-    if (!port) {
-        throw new PortLimitReachedError();
+export function getFolder(): Folder {
+    return new Folder(`${tempDir}/${Date.now()}-${unique++}`);
+}
+
+class DynamicPort {
+    number: number;
+
+    constructor(number: number) {
+        availablePorts.delete(number);
+        this.number = number;
+    }
+
+    release() {
+        availablePorts.add(this.number);
     }
-    return port;
 }
 
-export function releasePort(port: number) {
-    availablePorts.add(port);
+export function getPort(): DynamicPort {
+    const number = availablePorts.values().next().value;
+    if (!number) {
+        throw new PortLimitReachedError();
+    }
+    return new DynamicPort(number);
 }