Function cleanDatabase

apps/api/tests/helpers/db.ts:154–166

()

 * flake-deadlocks.
 */
export const cleanDatabase = async (): Promise<void> => {
  await db.transaction(async (tx) => {
    await tx.execute(
      sql`SELECT pg_advisory_xact_lock(${sql.raw(
        String(CLEANUP_ADVISORY_LOCK_KEY)
      )})`
    );

    for (const table of CLEANUP_TARGETS) {
      await tx.execute(sql.raw(`DELETE FROM ${table}`));
    }
  });
};

/** Re-export the live `db` for convenience inside test files. */
export { db };