portabase/src/lib/tasks/cleaning/index.ts

import {db} from "@/db";
import {and, eq, isNotNull, isNull} from "drizzle-orm";
import * as drizzleDb from "@/db";
import {withUpdatedAt} from "@/db/utils";

export const backupCleanTask = async () => {
    try {
        const backups = await db.query.backup.findMany({
            where: and(
                isNotNull(drizzleDb.schemas.backup.deletedAt),
                eq(drizzleDb.schemas.backup.status, "ongoing")
            )
        });

        console.log(`Backups to clean: ${backups.length}`);

        for (const backup of backups) {
            await db.update(drizzleDb.schemas.backup).set(withUpdatedAt({
                status: "failed",
            }))
                .where(eq(drizzleDb.schemas.backup.id, backup.id));
        }

    } catch (e: any) {
        console.error("Backup cleanup failed:", e);
        throw e;
    }
};