From cc0283ef395103fe98465130355b7fdfda463868 Mon Sep 17 00:00:00 2001
From: Koushik Dutta <koushd@gmail.com>
Date: Sun, 2 Jul 2023 08:47:10 -0700
Subject: [PATCH] videoanalysis: add pipeline hang logging

---
 plugins/objectdetector/package-lock.json |  4 +--
 plugins/objectdetector/package.json      |  2 +-
 plugins/objectdetector/src/main.ts       | 32 ++++++++++++++----------
 3 files changed, 22 insertions(+), 16 deletions(-)

diff --git a/plugins/objectdetector/package-lock.json b/plugins/objectdetector/package-lock.json
index 3cdc62484..9c27be9f4 100644
--- a/plugins/objectdetector/package-lock.json
+++ b/plugins/objectdetector/package-lock.json
@@ -1,12 +1,12 @@
 {
    "name": "@scrypted/objectdetector",
-   "version": "0.0.152",
+   "version": "0.0.153",
    "lockfileVersion": 2,
    "requires": true,
    "packages": {
       "": {
          "name": "@scrypted/objectdetector",
-         "version": "0.0.152",
+         "version": "0.0.153",
          "license": "Apache-2.0",
          "dependencies": {
             "@scrypted/common": "file:../../common",
diff --git a/plugins/objectdetector/package.json b/plugins/objectdetector/package.json
index 92fcfc1c9..c649605a5 100644
--- a/plugins/objectdetector/package.json
+++ b/plugins/objectdetector/package.json
@@ -1,6 +1,6 @@
 {
    "name": "@scrypted/objectdetector",
-   "version": "0.0.152",
+   "version": "0.0.153",
    "description": "Scrypted Video Analysis Plugin. Installed alongside a detection service like OpenCV or TensorFlow.",
    "author": "Scrypted",
    "license": "Apache-2.0",
diff --git a/plugins/objectdetector/src/main.ts b/plugins/objectdetector/src/main.ts
index 7cfc52d05..71417f99f 100644
--- a/plugins/objectdetector/src/main.ts
+++ b/plugins/objectdetector/src/main.ts
@@ -279,7 +279,7 @@ class ObjectDetectionMixin extends SettingsMixinDeviceBase<VideoCamera & Camera
     }
   }
 
-  getCurrrentFrameGenerator(snapshotPipeline: boolean) {
+  getCurrentFrameGenerator(snapshotPipeline: boolean) {
     let frameGenerator: string = this.frameGenerator;
     if (!this.hasMotionType && snapshotPipeline) {
       frameGenerator = 'Snapshot';
@@ -356,18 +356,24 @@ class ObjectDetectionMixin extends SettingsMixinDeviceBase<VideoCamera & Camera
         // ask rebroadcast to mute audio, not needed.
         audio: null,
       });
+      updatePipelineStatus('generateVideoFrames');
 
-      return await videoFrameGenerator.generateVideoFrames(stream, {
-        queue: 0,
-        fps: this.hasMotionType ? 4 : undefined,
-        // this seems to be unused now?
-        resize: this.model?.inputSize ? {
-          width: this.model.inputSize[0],
-          height: this.model.inputSize[1],
-        } : undefined,
-        // this seems to be unused now?
-        format: this.model?.inputFormat,
-      });
+      try {
+        return await videoFrameGenerator.generateVideoFrames(stream, {
+          queue: 0,
+          fps: this.hasMotionType ? 4 : undefined,
+          // this seems to be unused now?
+          resize: this.model?.inputSize ? {
+            width: this.model.inputSize[0],
+            height: this.model.inputSize[1],
+          } : undefined,
+          // this seems to be unused now?
+          format: this.model?.inputFormat,
+        });
+      }
+      finally {
+        updatePipelineStatus('waiting first result');
+      }
     }
   }
 
@@ -419,7 +425,7 @@ class ObjectDetectionMixin extends SettingsMixinDeviceBase<VideoCamera & Camera
 
     let longObjectDetectionWarning = false;
 
-    const frameGenerator = this.getCurrrentFrameGenerator(options.snapshotPipeline);
+    const frameGenerator = this.getCurrentFrameGenerator(options.snapshotPipeline);
     for await (const detected of
       await sdk.connectRPCObject(
         await this.objectDetection.generateObjectDetections(