import { after } from "next/server";

import { processPendingBackupJobs } from "@/infrastructure/backup/backup-processor";
import { getDatabase } from "@/infrastructure/database/client";
import { logError } from "@/infrastructure/logging/logger";

export function schedulePendingBackupProcessing(): void {
  after(async () => {
    try {
      await processPendingBackupJobs(getDatabase());
    } catch {
      logError("backup.worker_failed", { errorCode: "BACKUP_WORKER_FAILED" });
    }
  });
}