track video duration right after recordins stops

Author: jankalthoefer

app/services/highlighter/cut-highlight-clips.ts

@@ -5,7 +5,7 @@ import { FFMPEG_EXE, FFPROBE_EXE } from './constants';
 import { IHighlight } from './models/ai-highlighter.models';
 import path from 'path';
 
-async function getVideoDuration(filePath: string): Promise<number> {
+export async function getVideoDuration(filePath: string): Promise<number> {
   const { stdout } = await execa(FFPROBE_EXE, [
     '-v',
     'error',

app/services/highlighter/index.ts

@@ -67,7 +67,7 @@ import {
 } from './models/ai-highlighter.models';
 import { HighlighterViews } from './highlighter-views';
 import { startRendering } from './rendering/start-rendering';
-import { cutHighlightClips } from './cut-highlight-clips';
+import { cutHighlightClips, getVideoDuration } from './cut-highlight-clips';
 import { reduce } from 'lodash';
 import { extractDateTimeFromPath, fileExists } from './file-utils';
 import { addVerticalFilterToExportOptions } from './vertical-export';
@@ -449,12 +449,28 @@ export class HighlighterService extends PersistentStatefulService<IHighlighterSt
     });
 
     this.streamingService.latestRecordingPath.subscribe(path => {
+      // Check if recording is immediately available
+      getVideoDuration(path)
+        .then(duration => {
+          if (isNaN(duration)) {
+            duration = -1;
+          }
+          this.usageStatisticsService.recordAnalyticsEvent('AIHighlighter', {
+            type: 'FinishRecording',
+            duration,
+          });
+          console.log('Successfully got duration', duration);
+        })
+        .catch(error => {
+          console.error('Failed getting duration right after the recoding.', error);
+        });
+
       if (!aiRecordingInProgress) {
         return;
       }
 
       aiRecordingInProgress = false;
-      this.detectAndClipAiHighlights(path, streamInfo);
+      this.detectAndClipAiHighlights(path, streamInfo, true);
 
       this.navigationService.actions.navigate(
         'Highlighter',
@@ -1186,6 +1202,7 @@ export class HighlighterService extends PersistentStatefulService<IHighlighterSt
   async detectAndClipAiHighlights(
     filePath: string,
     streamInfo: IStreamInfoForAiHighlighter,
+    delayStart = false,
   ): Promise<void> {
     if (this.aiHighlighterFeatureEnabled === false) {
       console.log('HighlighterService: Not enabled');
@@ -1246,6 +1263,10 @@ export class HighlighterService extends PersistentStatefulService<IHighlighterSt
 
     console.log('🔄 HighlighterData');
     try {
+      if (delayStart) {
+        await this.wait(5000);
+      }
+
       const highlighterResponse = await getHighlightClips(
         filePath,
         this.userService.getLocalUserId(),
@@ -1492,4 +1513,13 @@ export class HighlighterService extends PersistentStatefulService<IHighlighterSt
 
     return id;
   }
+
+  /**
+   * Utility function that returns a promise that resolves after a specified delay
+   * @param ms Delay in milliseconds
+   * @returns Promise that resolves after the delay
+   */
+  wait(ms: number): Promise<void> {
+    return new Promise<void>(resolve => setTimeout(resolve, ms));
+  }
 }