add ivf postprocessing

src/app.ts

@@ -23,7 +23,7 @@ import {
   stopRandomActivateAudio,
   stopUpdateSystemStats,
 } from './utils'
-import { calculateVmafScore } from './vmaf'
+import { calculateVmafScore, fixIvfFiles } from './vmaf'
 
 const log = logger('app')
 
@@ -182,6 +182,11 @@ async function main(): Promise<void> {
     console.log('Exiting...')
 
     await stopApplication()
+
+    if (config.postProcessVideoRecordings && config.serverData) {
+      await fixIvfFiles(config.serverData, config.vmafKeepSourceFiles)
+    }
+
     process.exit(0)
   }
   registerExitHandler(() => stop())

src/config.ts

@@ -680,6 +680,13 @@ alert will be successful only when at least 95% of the checks pass.`,
     env: 'SERVER_DATA',
     arg: 'server-data',
   },
+  postProcessVideoRecordings: {
+    doc: `When true, it post-processes the video recordings stored into the \`serverData\` directory.`,
+    format: 'Boolean',
+    default: false,
+    env: 'POST_PROCESS_VIDEO_RECORDINGS',
+    arg: 'post-process-video-recordings',
+  },
   vmafPath: {
     doc: `When set, it runs the VMAF calculator for the videos saved under the provided directory path.`,
     format: String,

src/vmaf.ts

@@ -321,7 +321,7 @@ export async function fixIvfFiles(
   vmafKeepSourceFiles = true,
 ) {
   const files = await await getFiles(vmafPath, '.ivf.raw')
-  log.debug(`fixIvfFiles files=${files}`)
+  log.info(`fixIvfFiles files=${files}`)
 
   const reference = new Map<string, string>()
   const degraded = new Map<string, string[]>()
@@ -346,6 +346,7 @@ export async function fixIvfFiles(
       log.error(`fixIvfFrames error: ${(err as Error).message}`)
     }
   }
+  log.info(`fixIvfFiles done`)
 
   return { reference, degraded }
 }