[WIP] discuss: folder move

Author: ThanhDodeurOdoo

src/client.ts

@@ -261,6 +261,9 @@ export class SfuClient extends EventTarget {
         return stats;
     }
     async startRecording() {
+        if (this.state !== SfuClientState.CONNECTED) {
+            throw new Error("InvalidState");
+        }
         return this._bus?.request(
             {
                 name: CLIENT_REQUEST.START_RECORDING,
@@ -270,6 +273,9 @@ export class SfuClient extends EventTarget {
     }
 
     async stopRecording() {
+        if (this.state !== SfuClientState.CONNECTED) {
+            throw new Error("InvalidState");
+        }
         return this._bus?.request(
             {
                 name: CLIENT_REQUEST.STOP_RECORDING,

src/models/recorder.ts

@@ -1,6 +1,7 @@
 import { EventEmitter } from "node:events";
 import type { Channel } from "./channel";
 import { getFolder } from "#src/services/resources.ts";
+import type { Folder } from "#src/services/resources.ts";
 import { Logger } from "#src/utils/utils.ts";
 
 export enum RECORDER_STATE {
@@ -12,8 +13,8 @@ const logger = new Logger("RECORDER");
 export class Recorder extends EventEmitter {
     channel: Channel;
     state: RECORDER_STATE = RECORDER_STATE.STOPPED;
+    folder: Folder | undefined;
     ffmpeg = null;
-    destPath: string | undefined;
     /** Path to which the final recording will be uploaded to */
     recordingAddress: string;
 
@@ -25,14 +26,10 @@ export class Recorder extends EventEmitter {
 
     async start() {
         if (this.state === RECORDER_STATE.STOPPED) {
-            const folder  = getFolder();
-            this.destPath = folder.path;
-            this.once("stopped", ({ name }) => {
-                folder.seal(name);
-            });
+            this.folder  = getFolder();
             this.state = RECORDER_STATE.STARTED;
              logger.trace("TO IMPLEMENT");
-             // TODO ffmpeg instance creation for recording to destPath with proper name, start, build timestamps object
+             // TODO ffmpeg instance creation for recording to folder.path with proper name, start, build timestamps object
         }
         this._record();
         return { state: this.state };
@@ -41,7 +38,8 @@ export class Recorder extends EventEmitter {
     async stop() {
         if (this.state === RECORDER_STATE.STARTED) {
             logger.trace("TO IMPLEMENT");
-            this.emit("stopped", { name: "test" });
+            await this.folder!.seal("test-name");
+            this.folder = undefined;
             // 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

@@ -5,6 +5,8 @@ import * as config from "#src/config.ts";
 import { Logger } from "#src/utils/utils.ts";
 import { PortLimitReachedError } from "#src/utils/errors.ts";
 import os from "node:os";
+import fs from "node:fs/promises";
+import path from "node:path";
 
 const availablePorts: Set<number> = new Set();
 let unique = 1;
@@ -89,15 +91,18 @@ export async function getWorker(): Promise<mediasoup.types.Worker> {
     return leastUsedWorker;
 }
 
-class Folder {
+export class Folder {
     path: string;
 
     constructor(path: string) {
         this.path = path;
     }
 
-    seal(name: string) {
-        console.trace(`TO IMPLEMENT, MOVING TO ${config.recording.directory}/${name}`);
+    async seal(name: string) {
+        const destinationPath = path.join(config.recording.directory, name);
+        await fs.rename(this.path, destinationPath);
+        this.path = destinationPath;
+        logger.verbose(`Moved folder from ${this.path} to ${destinationPath}`);
     }
 }