import type db from '@admin/db'
import { entityVersions } from '@admin/db/schema'
import { and, eq, inArray } from 'drizzle-orm'

type EntityVersionClient = Parameters<Parameters<typeof db.transaction>[0]>[0]

export async function deleteEntityVersions(
  client: EntityVersionClient,
  entityType: string,
  entityIds: string[]
): Promise<void> {
  if (entityIds.length === 0) return

  await client
    .delete(entityVersions)
    .where(
      and(eq(entityVersions.entityType, entityType), inArray(entityVersions.entityId, entityIds))
    )
}