WildDragonLLC/dragonflight
1
0
Fork 0
Code Issues 32 Pull requests 7 Projects Releases Packages Wiki Activity Actions

feat/fix: filmstrip.js — growing migrate flow + deltacast cleanup

Browse source
This commit is contained in:
Zac Gaetano 2026-06-02 18:38:24 -04:00
parent b0f504ca69
commit 167d9ad009
1 changed files with 13 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
services/worker/src/workers/filmstrip.js
View file

@ -26,6 +26,18 @@ export const filmstripWorker = async (job) => {
try { try {
await mkdir(tmpDir, { recursive: true }); await mkdir(tmpDir, { recursive: true });
// Check asset status before doing any work
const assetRow = await query(
'SELECT status FROM assets WHERE id = $1',
[assetId]
);
const asset = assetRow.rows[0];
if (asset?.status === 'pending_migration') {
console.log(`[filmstrip] asset ${assetId} is pending_migration, skipping`);
return;
}
// 1. Download proxy from S3 // 1. Download proxy from S3
await job.updateProgress(5); await job.updateProgress(5);
console.log(`[filmstrip] Downloading ${proxyKey} for asset ${assetId}`); console.log(`[filmstrip] Downloading ${proxyKey} for asset ${assetId}`);
@ -38,7 +50,7 @@ export const filmstripWorker = async (job) => {
// 3. Extract FRAME_COUNT frames evenly spaced across the clip using FFmpeg // 3. Extract FRAME_COUNT frames evenly spaced across the clip using FFmpeg
// fps filter: select one frame every (duration / frameCount) seconds. // fps filter: select one frame every (duration / frameCount) seconds.
// select=not(mod(n\,step)) is less reliable than fps for variable-frame content. // select=not(mod(n\\,step)) is less reliable than fps for variable-frame content.
const interval = durationSec / FRAME_COUNT; const interval = durationSec / FRAME_COUNT;
const outputGlob = join(tmpDir, 'frame-%03d.jpg'); const outputGlob = join(tmpDir, 'frame-%03d.jpg');