import { and, eq, lt } from 'drizzle-orm';

import { db } from '../db/client';
import { recordings } from '../db/schema';

const STALE_RECORDING_SECONDS = Number(process.env.RECORDING_STALE_SECONDS ?? 60 * 30);

export const startRecordingsWorker = (): void => {
  const intervalMs = Number(process.env.RECORDING_WORKER_INTERVAL_MS ?? 30_000);

  setInterval(() => {
    reconcileStaleRecordings().catch((error) => {
      console.error('recordings worker failed', error);
    });
  }, intervalMs);
};

const reconcileStaleRecordings = async (): Promise<void> => {
  const staleBefore = new Date(Date.now() - STALE_RECORDING_SECONDS * 1000);

  const stale = await db.query.recordings.findMany({
    where: and(eq(recordings.status, 'awaiting_upload'), lt(recordings.createdAt, staleBefore)),
    limit: 100,
  });

  for (const recording of stale) {
    await db
      .update(recordings)
      .set({
        status: 'failed',
        error: 'recording upload timeout',
        updatedAt: new Date(),
      })
      .where(eq(recordings.id, recording.id));
  }
};