Assistance Needed for Implementing Transactions with Drizzle-ORM and Postgres in Effect-TS

import type { PgRemoteDatabase } from "drizzle-orm/pg-proxy";
// Define the runInTx function as a service
export class RunInTx extends Effect.Service<{
  runInTx: <A, E>(
    e: (tx: Parameters<PgRemoteDatabase<Record<string, never>>['transaction']>[0]) => Effect.Effect<A, E>
  ) => Effect.Effect<A, E | DrizzleDatabaseError>;
}>()("app/RunInTx", {
  effect: Effect.gen(function*() {
    const db = yield* PgDrizzle;

    const runInTx = <A, E>(
      e: (
        tx: Parameters<Parameters<typeof db.transaction>[0]>[0],
      ) => Effect.Effect<A, E>,
    ) =>
      Effect.async<A, E | DrizzleDatabaseError>((resume) => {
        db.transaction((tx) => e(tx).pipe(Effect.runPromiseExit))
          .then((result) => resume(result))
          .catch((e) =>
            resume(Effect.fail(new DrizzleDatabaseError({ inner: e }))),
          );
      });

    return { runInTx } as const;
  }),

  // Inject PgDrizzle layer dependency
  dependencies: [DatabaseLive],
}) { }