// Cascade delete all files when a project is deleted
triggers.register("projects", async (ctx, change) => {
    if (change.operation === "delete") {
        // Get files with pagination
        const { continueCursor, page } = await ctx.db
            .query("files")
            .withIndex("by_project_id", (q) => q.eq("projectId", change.id))
            .paginate({ numItems: 1000, cursor: null });

        // Delete files
        await asyncMap(page, (file) => ctx.db.delete(file._id));

        // Continue deleting files if there are more
        if (continueCursor) {
            await ctx.scheduler.runAfter(0, internal.helpers.batch.batchDeleteFiles, {
                projectId: change.id,
                cursor: continueCursor,
                numItems: 1000,
            });
        }
    }
});

export const batchDeleteFiles = internalMutation({
    args: {
        cursor: v.string(),
        projectId: v.id("projects"),
        numItems: v.number(),
    },
    handler: async (ctx, { projectId, cursor, numItems }) => {
        // Get the files
        const { page, continueCursor } = await ctx.db
            .query("files")
            .withIndex("by_project_id", (q) => q.eq("projectId", projectId))
            .paginate({
                numItems,
                cursor,
            });

        // Delete files
        await asyncMap(page, (file) => ctx.db.delete(file._id));

        if (continueCursor) {
            await ctx.scheduler.runAfter(0, internal.helpers.batch.batchDeleteFiles, {
                projectId,
                cursor: continueCursor,
                numItems,
            });
        }
    },
});

// Cascade delete all files when a project is deleted
triggers.register("projects", async (ctx, change) => {
    if (change.operation === "delete") {
        // Get files with pagination
        const { continueCursor, page } = await ctx.db
            .query("files")
            .withIndex("by_project_id", (q) => q.eq("projectId", change.id))
            .paginate({ numItems: 1000, cursor: null });

        // Delete files
        await asyncMap(page, (file) => ctx.db.delete(file._id));

        // Continue deleting files if there are more
        if (continueCursor) {
            await ctx.scheduler.runAfter(0, internal.helpers.batch.batchDeleteFiles, {
                projectId: change.id,
                cursor: continueCursor,
                numItems: 1000,
            });
        }
    }
});

export const batchDeleteFiles = internalMutation({
    args: {
        cursor: v.string(),
        projectId: v.id("projects"),
        numItems: v.number(),
    },
    handler: async (ctx, { projectId, cursor, numItems }) => {
        // Get the files
        const { page, continueCursor } = await ctx.db
            .query("files")
            .withIndex("by_project_id", (q) => q.eq("projectId", projectId))
            .paginate({
                numItems,
                cursor,
            });

        // Delete files
        await asyncMap(page, (file) => ctx.db.delete(file._id));

        if (continueCursor) {
            await ctx.scheduler.runAfter(0, internal.helpers.batch.batchDeleteFiles, {
                projectId,
                cursor: continueCursor,
                numItems,
            });
        }
    },
});