Add support for input gone

Author: martenrichter

src/av/components/framing.js

@@ -324,6 +324,11 @@ export class AVDeFramer extends BasicDeframer {
     this.reset()
 
     this.inspectframe = null
+    this.goneCallback = undefined
+  }
+
+  setGoneCallback(cb) {
+    this.goneCallback = cb
   }
 
   setFrameInspector(inspector) {
@@ -434,8 +439,14 @@ export class AVDeFramer extends BasicDeframer {
         this.pendingDecoderConfig = obj.data
         this.decoderConfig = obj.data
         break
+      case 'gone':
+        console.log('AVDeFramer gone received')
+        if (this.goneCallback) {
+          this.goneCallback()
+        }
+        break
       default:
-        throw new Error('Unknown bson task')
+        console.log('AVDeFramer Unknown bson task', obj.task, obj)
     }
   }
 

src/av/worker/processors.js

@@ -1105,9 +1105,11 @@ export class AVOutputProcessor extends AVProcessor {
     super(args)
 
     this.qualityInspect = this.qualityInspect.bind(this)
+    this.inputGone = this.inputGone.bind(this)
 
     this.deframer = new AVDeFramer(/* { type: 'video' } */)
     this.deframer.setFrameInspector(this.qualityInspect)
+    this.deframer.setGoneCallback(this.inputGone)
     this.inputctrlframer = new BsonFramer()
     this.streamSrc = null
     this.streamSrcRes = null
@@ -1371,9 +1373,19 @@ export class AVOutputProcessor extends AVProcessor {
     }
   }
 
-  async setSrcId(id) {
+  inputGone() {
+    console.log(
+      'Input gone, simulate a setSrcId to trigger new ticketing',
+      this.srcid
+    )
+    this.setSrcId(this.srcid, true).catch((error) => {
+      console.log('inputGone setSrcId problem', error)
+    })
+  }
+
+  async setSrcId(id, forceChange) {
     // dest is our id
-    const changed = this.srcid !== id
+    const changed = this.srcid !== id || !!forceChange
     this.srcid = id
     console.log('srcId', id, this.datatype, changed)
     if (changed) {