From 60a2e0e700988fe80f043c079679ab81a684c973 Mon Sep 17 00:00:00 2001
From: Oliver Shin <46743737+oshinongit@users.noreply.github.com>
Date: Tue, 28 Nov 2023 11:54:37 +0100
Subject: [PATCH] feat: integrate smb public instance (#9)
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

* fix: added ssrcs from answer

* feat: config env vars

* chore: fix service name

---------

Co-authored-by: Jonas Birmé <jonas.birme@eyevinn.se>
---
 package-lock.json      | 12 ++++++++++++
 package.json           |  1 +
 readme.md              |  2 +-
 src/api_productions.ts | 22 +++++++++++++++++++---
 src/server.ts          |  4 ++--
 src/smb.ts             |  1 +
 6 files changed, 36 insertions(+), 6 deletions(-)

diff --git a/package-lock.json b/package-lock.json
index 92b6d4e..d130d33 100644
--- a/package-lock.json
+++ b/package-lock.json
@@ -14,6 +14,7 @@
         "@fastify/swagger-ui": "^1.5.0",
         "@fastify/type-provider-typebox": "^2.4.0",
         "@sinclair/typebox": "^0.25.24",
+        "dotenv": "^16.3.1",
         "fastify": "4.23.2",
         "nodemon": "^2.0.20",
         "sdp-transform": "^2.14.1",
@@ -3035,6 +3036,17 @@
         "node": ">=8"
       }
     },
+    "node_modules/dotenv": {
+      "version": "16.3.1",
+      "resolved": "https://registry.npmjs.org/dotenv/-/dotenv-16.3.1.tgz",
+      "integrity": "sha512-IPzF4w4/Rd94bA9imS68tZBaYyBWSCE47V1RGuMrB94iyTOIEwRmVL2x/4An+6mETpLrKJ5hQkB8W4kFAadeIQ==",
+      "engines": {
+        "node": ">=12"
+      },
+      "funding": {
+        "url": "https://github.com/motdotla/dotenv?sponsor=1"
+      }
+    },
     "node_modules/electron-to-chromium": {
       "version": "1.4.576",
       "resolved": "https://registry.npmjs.org/electron-to-chromium/-/electron-to-chromium-1.4.576.tgz",
diff --git a/package.json b/package.json
index 13499fa..7eac7a5 100644
--- a/package.json
+++ b/package.json
@@ -21,6 +21,7 @@
     "@fastify/swagger-ui": "^1.5.0",
     "@fastify/type-provider-typebox": "^2.4.0",
     "@sinclair/typebox": "^0.25.24",
+    "dotenv": "^16.3.1",
     "fastify": "4.23.2",
     "nodemon": "^2.0.20",
     "sdp-transform": "^2.14.1",
diff --git a/readme.md b/readme.md
index d3a7f50..7361db0 100644
--- a/readme.md
+++ b/readme.md
@@ -1,4 +1,4 @@
-# {{Name}}
+# intercom-manager
 
 <!--
 
diff --git a/src/api_productions.ts b/src/api_productions.ts
index d98b235..0cfe49c 100644
--- a/src/api_productions.ts
+++ b/src/api_productions.ts
@@ -5,13 +5,17 @@ import { SmbProtocol, SmbEndpointDescription } from './smb';
 import { ProductionManager } from './production_manager';
 import { Connection } from './connection';
 import { write, parse } from 'sdp-transform';
+import dotenv from 'dotenv';
+dotenv.config();
 
 type NewProduction = Static<typeof NewProduction>;
 type Production = Static<typeof Production>;
 type Line = Static<typeof Line>;
 
 const productionManager = new ProductionManager();
-const ENDPOINT_IDLE_TIMEOUT_S = 600;
+const ENDPOINT_IDLE_TIMEOUT_S: string =
+  process.env.ENDPOINT_IDLE_TIMEOUT_S ?? '180';
+const SMB_ADDRESS: string = process.env.SMB_ADDRESS ?? 'http://localhost:8080';
 
 function generateOffer(
   endpoint: SmbEndpointDescription,
@@ -71,7 +75,7 @@ async function createEndpoint(
     endpointId,
     audio,
     data,
-    ENDPOINT_IDLE_TIMEOUT_S
+    parseInt(ENDPOINT_IDLE_TIMEOUT_S, 10)
   );
   return endpoint;
 }
@@ -99,6 +103,18 @@ async function handleAnswerRequest(
 
   const parsedAnswer = parse(answer);
   const answerMediaDescription = parsedAnswer.media[0];
+  if (parsedAnswer.media[1].ssrcs) {
+    let parsedSsrcs = parsedAnswer.media[1].ssrcs[0].id;
+    if (typeof parsedSsrcs === 'string') {
+      parsedSsrcs = parseInt(parsedSsrcs, 10);
+    }
+    endpointDescription.audio.ssrcs.push(parsedSsrcs);
+  }
+  if (endpointDescription.audio.ssrcs.length === 0) {
+    throw new Error(
+      'Missing audio ssrcs when handling sdp answer from endpoint'
+    );
+  }
 
   const transport = endpointDescription['bundle-transport'];
   if (!transport) {
@@ -181,7 +197,7 @@ function getLine(productionLines: Line[], name: string): Line {
 }
 
 const apiProductions: FastifyPluginCallback = (fastify, opts, next) => {
-  const smbServerUrl = 'http://localhost:8080/conferences/';
+  const smbServerUrl = SMB_ADDRESS + '/conferences/';
   const smb = new SmbProtocol();
 
   fastify.post<{
diff --git a/src/server.ts b/src/server.ts
index bcdb4ca..ec8d894 100644
--- a/src/server.ts
+++ b/src/server.ts
@@ -1,8 +1,8 @@
 import api from './api';
 
-const server = api({ title: '@eyevinn/typescript-nodejs' });
+const server = api({ title: 'intercom-manager' });
 
-const PORT = process.env.PORT ? Number(process.env.PORT) : 8001;
+const PORT = process.env.PORT ? Number(process.env.PORT) : 8000;
 
 server.listen({ port: PORT, host: '0.0.0.0' }, (err, address) => {
   if (err) {
diff --git a/src/smb.ts b/src/smb.ts
index fad8f46..769c4a0 100644
--- a/src/smb.ts
+++ b/src/smb.ts
@@ -165,6 +165,7 @@ export class SmbProtocol {
       },
       body: JSON.stringify(request)
     });
+    console.log(request);
 
     if (!response.ok) {
       console.log(JSON.stringify(request));