Major updates to the SDK workflow

Signed-off-by: Fabien Lavocat <[email protected]>

Author: FabienLavocat

package-lock.json

@@ -83,12 +83,6 @@
     "eslint-plugin-promise": "^6.6.0",
     "husky": "^4.3.8",
     "install": "^0.13.0",
-    "jest": "^29.4.1",
-    "jest-cucumber": "^3.0.1",
-    "jest-environment-jsdom": "^29.7.0",
-    "jest-environment-node": "^29.4.1",
-    "jest-puppeteer": "^9.0.1",
-    "jest-websocket-mock": "^2.2.0",
     "jsdom": "~22.1.0",
     "lint-staged": "^10.5.4",
     "mock-socket": "^9.0.3",

package.json

@@ -1,10 +1,10 @@
-import { View, Director, Logger } from '@nx-millicast/millicast-sdk'
+import { Viewer, Director, Logger, LayersEventPayload } from '@nx-millicast/millicast-sdk'
 import { DirectorSubscriberOptions } from 'packages/millicast-sdk/src/types/Director.types'
 
 window.Logger = Logger
 
 if (import.meta.env.MILLICAST_DIRECTOR_ENDPOINT) {
-  Director.setEndpoint(import.meta.env.MILLICAST_DIRECTOR_ENDPOINT)
+  Director.endpoint = import.meta.env.MILLICAST_DIRECTOR_ENDPOINT
 }
 
 const addStream = (stream) => {
@@ -20,21 +20,19 @@ const removeStream = () => {
 }
 
 const subscribe = async (streamName, streamAccountId) => {
-  const options: DirectorSubscriberOptions = { streamName, streamAccountId }
-  const tokenGenerator = () => Director.getSubscriber(options)
-  const millicastView = new View(tokenGenerator)
-  millicastView.on('broadcastEvent', (event) => {
-    const layers = event.data.layers !== null ? event.data.layers : {}
-    if (event.name === 'layers' && Object.keys(layers).length <= 0) {
-      // call play logic or being reconnect interval
-      close().then(() => {
-        subscribe(streamName, streamAccountId)
-      })
-      console.error('Feed no longer found.')
-    }
-  })
+  const millicastView = new Viewer({ streamName, streamAccountId })
+  // millicastView.on('layers', (event: LayersEventPayload) => {
+  //   const layers = event.layers !== null ? event.layers : {}
+  //   if (Object.keys(layers).length <= 0) {
+  //     // call play logic or being reconnect interval
+  //     close().then(() => {
+  //       subscribe(streamName, streamAccountId)
+  //     })
+  //     console.error('Feed no longer found.')
+  //   }
+  // })
 
-  millicastView.on('newTrack', (event) => {
+  millicastView.on('track', (event) => {
     addStream(event.streams[0])
   })