first test

Author: shivanshtalwar

.gitignore

@@ -0,0 +1,3 @@
+node_modules
+package-lock.json
+dist

.gitignore copy

@@ -0,0 +1,3 @@
+node_modules/
+.idea/
+js/node_modules

.npmignore

@@ -0,0 +1,8 @@
+node_modules/
+.idea/
+js/node_modules
+docs/
+examples/
+janus-gateway/
+build_janus.sh
+

bin/linux/janus

@@ -0,0 +1,2 @@
+node_modules
+package-lock.json

bin/linux/janus-cfgconv

@@ -0,0 +1,14 @@
+import { JanusPPRecJs } from 'janus-pp-rec-js'
+import { dirname } from 'path'
+import { fileURLToPath } from 'url'
+import { join } from 'path'
+const __dirname = dirname(fileURLToPath(import.meta.url))
+const mjrFilePath = join(
+    __dirname,
+    'recordings/0a2c4fae3b5e38d6b0fdad6ea014b293-peer-audio.mjr'
+)
+const wavFilePath = join(
+    __dirname,
+    'recordings/0a2c4fae3b5e38d6b0fdad6ea014b293-peer-audio.wav'
+)
+JanusPPRecJs.createWavFromMjr(mjrFilePath, wavFilePath)

bin/linux/janus-pp-rec

@@ -0,0 +1,14 @@
+{
+  "name": "dev",
+  "version": "1.0.0",
+  "description": "",
+  "main": "index.js",
+  "scripts": {
+    "start": "node index.js"
+  },
+  "author": "",
+  "license": "ISC",
+  "dependencies": {
+    "janus-pp-rec-js": "file:../janus-pp-rec-js-1.0.0.tgz"
+  }
+}

bin/linux/mjr2pcap

@@ -0,0 +1,56 @@
+{
+    "name": "janus-pp-rec-js",
+    "version": "1.0.0",
+    "description": "a simple js wrapper around janus-pp-rec which is used to convert mjr files to one of playable media format",
+    "repository": {
+        "type": "git",
+        "url": "git+https://github.com/flutterjanus/janus-pp-rec-js.git"
+    },
+    "bugs": {
+        "url": "https://github.com/flutterjanus/janus-pp-rec-js/issues"
+    },
+    "homepage": "https://github.com/flutterjanus/janus-pp-rec-js#readme",
+    "typings": "dist",
+    "main": "dist/index.js",
+    "scripts": {
+        "build": "tsc",
+        "doc": "npx typedoc src/index.ts"
+    },
+    "keywords": [
+        "janusjs",
+        "webrtc",
+        "janus-gateway",
+        "videoroom",
+        "sip"
+    ],
+    "files": [
+        "dist/*",
+        "bin"
+    ],
+    "author": "[email protected]",
+    "license": "ISC",
+    "dependencies": {
+        "@ffmpeg-installer/ffmpeg": "^1.1.0",
+        "aigle": "1.14.1",
+        "child_process": "^1.0.2",
+        "fluent-ffmpeg": "^2.1.3",
+        "lodash": "4.17.21",
+        "rxjs": "^7.5.5",
+        "typedoc": "0.22.15",
+        "webrtc-adapter": "8.1.1"
+    },
+    "devDependencies": {
+        "@types/es6-promise": "3.3.0",
+        "@types/lodash": "4.14.182",
+        "@types/node": "^20.14.7",
+        "typescript": "^5.5.2"
+    },
+    "prettier": {
+        "trailingComma": "es5",
+        "tabWidth": 4,
+        "proseWrap": "preserve",
+        "printWidth": 80,
+        "semi": false,
+        "singleQuote": true
+    }
+}

dev/.gitignore

@@ -0,0 +1,33 @@
+import _ from "lodash";
+import ffmpegPath from "@ffmpeg-installer/ffmpeg";
+import ffmpeg from "fluent-ffmpeg";
+import { spawnObservable } from "./spawn.js";
+
+ffmpeg.setFfmpegPath(ffmpegPath.path);
+
+export function addBufferOutput(bufferOutputs, bufferString, maxBufferSize = 50) {
+  const newBufferOutputs = [...bufferOutputs, bufferString];
+  if (newBufferOutputs.length > maxBufferSize) {
+    newBufferOutputs.shift(); // Remove the oldest element (from the beginning of the array)
+  }
+  return newBufferOutputs;
+}
+
+export const downMixAudioFiles = (outputFilePath, ...inputFilePaths) => {
+  return new Promise((resolve, reject) => {
+    const command = ffmpeg();
+    _.each(inputFilePaths, (path) => {
+      command.addInput(path);
+    });
+    command
+      .complexFilter([`amix=inputs=${_.size(inputFilePaths)}:duration=longest`])
+      .output(outputFilePath)
+      .on("error", (err) => {
+        reject(err);
+      })
+      .on("end", function (err, stdout, stderr) {
+        resolve(true);
+      })
+      .run();
+  });
+};

dev/index.js

@@ -0,0 +1,2 @@
+export * from './spawn'
+export * from './converter'

dev/package.json

@@ -0,0 +1,34 @@
+import { Subject } from "rxjs";
+import { spawn, SpawnOptionsWithoutStdio } from "child_process";
+
+export const spawnObservable = (cmd, args, spawnOptions: SpawnOptionsWithoutStdio = { shell: true }) => {
+    const observable = new Subject();
+    const errorObservable = new Subject();
+    const writeObservable = new Subject();
+
+    const runCommand = spawn(cmd, args, spawnOptions);
+    writeObservable.subscribe({
+        next: (data) => {
+            runCommand.stdin.write(data);
+        },
+    });
+    runCommand.stdout.on("close", (code) => {
+        observable.complete();
+    });
+
+    runCommand.stdout.on("data", (data) => {
+        if (data) {
+            observable.next(data.toString());
+        }
+    });
+    runCommand.stderr.on("close", (code) => {
+        errorObservable.complete();
+    });
+
+    runCommand.stderr.on("data", (data) => {
+        if (data) {
+            errorObservable.next(data.toString());
+        }
+    });
+    return { errorObservable, events: observable.asObservable(), sender: writeObservable };
+};

dev/recordings/0a2c4fae3b5e38d6b0fdad6ea014b293-peer-audio.mjr

@@ -0,0 +1,42 @@
+import _ from 'lodash'
+import { addBufferOutput, spawnObservable } from './core'
+import { dirname } from 'path';
+import { fileURLToPath } from 'url';
+import { join } from 'path'
+const __dirname = dirname(fileURLToPath(import.meta.url));
+
+export class JanusPPRecJs {
+    static async createWavFromMjr(mjrPath: string, wavPath: string) {
+        const { events: converter, errorObservable } = spawnObservable(`janus-pp-rec`, [mjrPath, wavPath], {
+            shell: true,
+            cwd: join(__dirname, "../bin/linux")
+        });
+        return new Promise((resolve, reject) => {
+            let outputBuffer = [];
+            let errorBuffer = [];
+            errorObservable.subscribe({
+                next(data) {
+                    errorBuffer = addBufferOutput(errorBuffer, data, 100);
+                },
+                complete() {
+                    console.log(errorBuffer);
+                    reject({ error: _.join(errorBuffer, " ") });
+                },
+            });
+            converter.subscribe({
+                next(data) {
+                    outputBuffer = addBufferOutput(outputBuffer, data, 100);
+                },
+                complete() {
+                    const outputs = _.join(outputBuffer, " ");
+                    console.log(outputs);
+                    if (outputs.includes("No destination file") || outputs.includes("ERR")) {
+                        reject({ error: "bad mjr file" });
+                    }
+                    resolve(true);
+                },
+            });
+        });
+    };
+
+}

dev/recordings/0a2c4fae3b5e38d6b0fdad6ea014b293-user-audio.mjr

@@ -0,0 +1,19 @@
+{
+    "compilerOptions": {
+        "outDir": "./dist/",
+        "experimentalDecorators": true,
+        "noImplicitAny": false,
+        "module": "ESNext",
+        "allowSyntheticDefaultImports": true,
+        "target": "es5",
+        "types": ["node"],
+        "declarationMap": true,
+        "declaration": true,
+        "allowJs": true,
+        "moduleResolution": "node",
+        "lib": ["ES5", "ES2015", "DOM", "ScriptHost"]
+    },
+    "typeRoots": ["node_modules/@types"],
+    "include": ["src/**/*"],
+    "exclude": ["node_modules", "janus-gateway"]
+}