import { ApprovalWorkflow } from "@/interfaces/approval.workflow";
import client from "@/lib/mongodb";

const db = client.db(process.env.MONGODB_DB);

export const getApprovalWorkflows = async (ids?: string[]) => {
	return await db
		.collection("approval-workflows")
		.find<ApprovalWorkflow>(ids ? { id: { $in: ids } } : {})
		.toArray();
};

export const getApprovalWorkflow = async (id: string) => {
	return await db.collection("approval-workflows").findOne<ApprovalWorkflow>({ id });
};

export const createApprovalWorkflow = async (workflow: ApprovalWorkflow) => {
	await db.collection("approval-workflows").insertOne(workflow);
}

export const createApprovalWorkflows = async (workflows: ApprovalWorkflow[]) => {
	if (workflows.length === 0) return;
	await db.collection<ApprovalWorkflow>("approval-workflows").insertMany(workflows);
};