[IMP] wip

Author: ThanhDodeurOdoo

src/config.ts

@@ -65,9 +65,9 @@ export const HTTP_INTERFACE: string = process.env.HTTP_INTERFACE || "0.0.0.0";
 export const PORT: number = Number(process.env.PORT) || 8070;
 
 /**
- * Whether the recording feature is enabled, true by default.
+ * Whether the recording feature is enabled, false by default.
  */
-export const RECORDING: boolean = !FALSY_INPUT.has(process.env.RECORDING!);
+export const RECORDING: boolean = Boolean(process.env.RECORDING);
 
 /**
  * The number of workers to spawn (up to core limits) to manage RTC servers.
@@ -215,6 +215,7 @@ export const recording = Object.freeze({
     screenLimit: 1,
 });
 
+// TODO: This should probably be env variable, and at least documented so that deployment can open these ports.
 export const dynamicPorts = Object.freeze({
     min: 50000,
     max: 59999,

src/models/recorder.ts

@@ -32,20 +32,29 @@ export class Recorder extends EventEmitter {
              logger.trace("TO IMPLEMENT");
              // TODO ffmpeg instance creation for recording to destPath with proper name, start, build timestamps object
         }
-
+        this._record();
         return { state: this.state };
     }
 
     async stop() {
         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 };
     }
+
+    /**
+     * @param video whether we want to record videos or not (will always record audio)
+     */
+    _record(video: boolean = false) {
+        console.trace(`TO IMPLEMENT: recording channel ${this.channel.name}, video: ${video}`);
+        // iterate all producers on all sessions of the channel, create a ffmpeg for each,
+        // save them on a map by session id+type.
+        // check if recording for that session id+type is already in progress
+        // add listener to the channel for producer creation (and closure).
+    }
 }

src/services/resources.ts

@@ -3,6 +3,10 @@ import type { WebRtcServerOptions } from "mediasoup/node/lib/types";
 
 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";
+
+const availablePorts: Set<number> = new Set();
 
 export interface RtcWorker extends mediasoup.types.Worker {
     appData: {
@@ -12,6 +16,7 @@ export interface RtcWorker extends mediasoup.types.Worker {
 
 const logger = new Logger("RESOURCES");
 const workers = new Set<RtcWorker>();
+const tempDir = os.tmpdir() + "/ongoing_recordings";
 
 export async function start(): Promise<void> {
     logger.info("starting...");
@@ -22,6 +27,10 @@ export async function start(): Promise<void> {
     logger.info(
         `transport(RTC) layer at ${config.PUBLIC_IP}:${config.RTC_MIN_PORT}-${config.RTC_MAX_PORT}`
     );
+    for (let i = config.dynamicPorts.min; i <= config.dynamicPorts.max; i++) {
+        availablePorts.add(i);
+    }
+    logger.info(`${availablePorts.size} dynamic ports available [${config.dynamicPorts.min}-${config.dynamicPorts.max}]`);
 }
 
 export function close(): void {
@@ -78,18 +87,26 @@ export async function getWorker(): Promise<mediasoup.types.Worker> {
 }
 
 export function getFolder() {
-    // create a temp folder at a path, returns the path and a function to seal the folder
+    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: () => {
-            // move the content into a permanent folder location so it can easily be retrieved for processing later
-            // or directly forward for transcription
+        path,
+        sealFolder: (name: string = tempName) => {
+            // TODO move whatever is in path to
+            console.log(`${config.recording.directory}/${name}`);
         },
     }
 }
 
-export function getPort() {
+export function getPort(): number {
+    const port = availablePorts.values().next().value;
+    if (!port) {
+        throw new PortLimitReachedError();
+    }
+    return port;
 }
 
 export function releasePort(port: number) {
+    availablePorts.add(port);
 }

src/utils/errors.ts

@@ -5,3 +5,7 @@ export class AuthenticationError extends Error {
 export class OvercrowdedError extends Error {
     name = "OvercrowdedError";
 }
+
+export class PortLimitReachedError extends Error {
+    name = "PortLimitReachedError";
+}