Video Thumbnails

model Zipline {
  featuresThumbnailsEnabled       Boolean @default(true)
  featuresThumbnailsNumberThreads Int     @default(4)
  featuresThumbnailsFormat        String  @default("jpg")
  
  tasksThumbnailsInterval         String  @default("30m")
  tasksCleanThumbnailsInterval    String  @default("1d")
}

export default function thumbnails(prisma: typeof globalThis.__db__) {
  return async function (this: IntervalTask, rerun = false) {
    // Find worker threads for thumbnail generation
    const thumbnailWorkers = this.tasks.tasks.filter(
      (x) => 'worker' in x && x.id.startsWith('thumbnail'),
    ) as unknown as WorkerTask[];
    
    if (!thumbnailWorkers.length) return;
    
    // Find videos that need thumbnails
    const thumbnailNeeded = await prisma.file.findMany({
      where: {
        ...(rerun ? {} : { thumbnail: { is: null } }),
        type: {
          startsWith: 'video/',
        },
      },
    });
    
    if (!thumbnailNeeded.length) return;
    
    // Distribute work across workers
    let workerIndex = 0;
    for (const file of thumbnailNeeded) {
      thumbToWorker.push({
        id: file.id,
        worker: workerIndex,
      });
      
      workerIndex = (workerIndex + 1) % thumbnailWorkers.length;
    }
    
    // Send work to each worker
    for (let i = 0; i !== thumbnailWorkers.length; ++i) {
      if (!ids[i].length) continue;
      
      thumbnailWorkers[i].worker!.postMessage({
        type: 0,
        data: ids[i],
      });
    }
  };
}

model Thumbnail {
  id        String   @id @default(cuid())
  createdAt DateTime @default(now())
  updatedAt DateTime @updatedAt
  
  path String  // Path to thumbnail file
  
  file   File   @relation(fields: [fileId], references: [id])
  fileId String
  
  @@unique([fileId])
}

model File {
  id        String    @id @default(cuid())
  name      String
  type      String    // e.g., "video/mp4"
  
  thumbnail Thumbnail?
}

interface WorkerTask {
  id: string;
  worker: Worker;  // Node.js Worker thread
}

// Example: 4 threads processing 12 videos
// Worker 0: videos [1, 5, 9]
// Worker 1: videos [2, 6, 10]
// Worker 2: videos [3, 7, 11]
// Worker 3: videos [4, 8, 12]

.thumbnail.[fileId].[format]

// Find thumbnails on filesystem
const fsThumbnails = await datasource.list({ prefix: '.thumbnail.' });

// Find thumbnails in database
const dbThumbnails = await prisma.thumbnail.findMany();

// Remove orphaned thumbnails (in filesystem but not in DB)
for (const path of fsThumbnails) {
  const existsInDb = dbThumbnails.some(t => t.path === path);
  if (!existsInDb) {
    await datasource.delete(path);
  }
}

// Remove orphaned DB entries (in DB but not in filesystem)
for (const thumb of dbThumbnails) {
  const existsOnFs = fsThumbnails.includes(thumb.path);
  if (!existsOnFs) {
    await prisma.thumbnail.delete({ where: { id: thumb.id } });
  }
}

{
  "id": "clx1234567890",
  "name": "video.mp4",
  "type": "video/mp4",
  "size": 52428800,
  "thumbnail": {
    "id": "clx9876543210",
    "path": ".thumbnail.clx1234567890.jpg",
    "createdAt": "2024-01-20T10:35:00.000Z"
  }
}

https://your-domain.com/u/.thumbnail.clx1234567890.jpg

// Call the task with rerun=true
await thumbnails(prisma).call(intervalTask, true);