Function batchDeleteByWorkspaceAndTimestamp

apps/sim/lib/cleanup/batch-delete.ts:199–224

({
  tableDef,
  workspaceIdCol,
  timestampCol,
  workspaceIds,
  retentionDate,
  tableName,
  requireTimestampNotNull = false,
  ...rest
}: BatchDeleteOptions)

 * when there's no per-row side effect (e.g. no S3 files to clean up alongside).
 */
export async function batchDeleteByWorkspaceAndTimestamp({
  tableDef,
  workspaceIdCol,
  timestampCol,
  workspaceIds,
  retentionDate,
  tableName,
  requireTimestampNotNull = false,
  ...rest
}: BatchDeleteOptions): Promise<TableCleanupResult> {
  return chunkedBatchDelete({
    tableDef,
    workspaceIds,
    tableName,
    selectChunk: (chunkIds, limit) => {
      const predicates = [inArray(workspaceIdCol, chunkIds), lt(timestampCol, retentionDate)]
      if (requireTimestampNotNull) predicates.push(isNotNull(timestampCol))
      return db
        .select({ id: sql<string>`id` })
        .from(tableDef)
        .where(and(...predicates))
        .limit(limit)
    },
    ...rest,
  })
}

/**
 * Delete by explicit ID list, chunked so each statement is its own transaction.