feat: integrate smb public instance (#9)

* fix: added ssrcs from answer

* feat: config env vars

* chore: fix service name

---------

Co-authored-by: Jonas Birmé <jonas.birme@eyevinn.se>

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",

readme.md

@@ -1,4 +1,4 @@
-# {{Name}}
+# intercom-manager
 
 <!--
 

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<{

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) {

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));