updates for SM 2.0

Author: bustardcelly

index.html

@@ -63,6 +63,20 @@
           'background: #fff; color: #222'
         )
         console.log('')
+        console.log(
+          '%c [sm] ' +
+            '%c       : The optional flag to notify the client that it will be connecting over a Stream Manager deployment. Default: `false`',
+          'background: #222; color: #ebefd0',
+          'background: #fff; color: #222'
+        )
+        console.log('')
+        console.log(
+          '%c [nodegroup] ' +
+            '%c       : The optional node group name to be used in a Stream Manager deployment. Default: `undefined`',
+          'background: #222; color: #ebefd0',
+          'background: #fff; color: #222'
+        )
+        console.log('')
         console.log(
           '%c [vod] ' +
             '%c       : The option to allow for live seek controls of the main stream. Default: `true`',

script/main.js

@@ -41,6 +41,7 @@ const {
   abrLow,
   abrHigh,
   streamManager,
+  nodeGroup,
   debugMode,
   intro,
   streams: streamsQueryList,
@@ -65,6 +66,13 @@ const baseConfig = {
   app: app || 'live',
 }
 
+// Optional node group configuration for Stream Manager 2.0.
+if (streamManager) {
+  baseConfig.connectionParams = {
+    nodeGroup: nodeGroup || 'default',
+  }
+}
+
 /**
  * Loads and parses the JSON payload from the scriptURL to determine the list of streams to display.
  * @param {String} scriptURL
@@ -78,17 +86,38 @@ const getStreamMapFromScriptURL = async (scriptURL) => {
   // * [ <string> ]
   // * [ { name: <string> } ]
   // * [ { name: <string>, label: <string> } ]
+  // * [ { streamGuid: <string>, nodeRole: <string> } ]
   // * { <string>: <string> }
   if (Object.prototype.toString.call(json) === '[object Array]') {
     json.forEach((item) => {
+      // SM 1.0 stream list payload.
       if (typeof item === 'object' && item.name) {
         if (!item.type || (item.type && item.type !== 'origin')) {
           list.push({
             label: item.label || item.name,
             streamName: item.name,
           })
         }
+      } else if (typeof item === 'object' && item.streamGuid) {
+        // SM 2.0 stream list payload >
+        // If nodeRole matches /^edge/
+        if (item.nodeRole && item.nodeRole.match(/^edge/)) {
+          const guid = item.streamGuid
+          // Split the stream name after the last / in the streamGuid.
+          let parts = guid.split('/')
+          if (parts.length > 1) {
+            const streamName = parts.pop()
+            const context = parts.join('/')
+            if (context === app) {
+              list.push({
+                label: streamName,
+                streamName,
+              })
+            }
+          }
+        }
       } else if (typeof item === 'string') {
+        // streams.jsp payload >
         list.push({ label: item, streamName: item })
       }
     })

script/url-util.js

@@ -40,6 +40,7 @@ const paramExclude = [
   'debug',
   'embed',
   'sm',
+  'nodegroup',
   'abr',
   'abrlow',
   'abrhigh',
@@ -82,6 +83,7 @@ export const query = () => {
   const abrLowOpt = searchParams.get('abrlow')
   const abrHighOpt = searchParams.get('abrhigh')
   const smOpt = searchParams.get('sm')
+  const nodeGroupOpt = searchParams.get('nodegroup')
   const vodOpt = searchParams.get('vod')
   const demoOpt = searchParams.get('demo')
   const debugOpt = searchParams.get('debug')
@@ -95,7 +97,7 @@ export const query = () => {
     : undefined
   let app = searchParams.get('app')
     ? decodeURIComponent(searchParams.get('app'))
-    : undefined
+    : 'live'
   const vodBase = searchParams.get('vodbase')
     ? decodeURIComponent(searchParams.get('vodbase'))
     : undefined
@@ -126,6 +128,7 @@ export const query = () => {
     abrLow,
     abrHigh,
     streamManager,
+    nodeGroup: nodeGroupOpt,
     streams,
     demoMode,
     debugMode,