fix(drizzle): surface connection errors in beginTransaction instead of hanging forever

packages/drizzle/src/transactions/beginTransaction.ts

@@ -17,6 +17,7 @@ export const beginTransaction: BeginTransaction = async function beginTransactio
     let transaction: DrizzleTransaction
 
     let transactionReady: () => void
+    let transactionFailed: (err: unknown) => void
 
     // Await initialization here
     // Prevent race conditions where the adapter may be
@@ -44,13 +45,17 @@ export const beginTransaction: BeginTransaction = async function beginTransactio
           transactionReady()
         })
       }, options || this.transactionOptions)
-      .catch(() => {
-        // swallow
+      .catch((err) => {
+        // Connection failed before callback ran - reject instead of hanging forever
+        transactionFailed(err)
       })
 
     // Need to wait until the transaction is ready
     // before binding its `resolve` and `reject` methods below
-    await new Promise<void>((resolve) => (transactionReady = resolve))
+    await new Promise<void>((res, rej) => {
+      transactionReady = res
+      transactionFailed = rej
+    })
 
     this.sessions[id] = {
       db: transaction,

test/database/int.spec.ts

@@ -2167,6 +2167,46 @@
         })
       }
 
+      it(
+        'should throw error when beginTransaction fails to connect (drizzle)',
+        { db: 'drizzle' },
+        async () => {
+          const db = payload.db as unknown as Record<string, unknown>
+          const originalDrizzle = db.drizzle
+          try {
+            db.drizzle = {
+              transaction: () => Promise.reject(new Error('connection refused')),
+            }
+
+            await expect(() => payload.db.beginTransaction()).rejects.toThrow(/connection refused/)
+          } finally {
+            db.drizzle = originalDrizzle
+          }
+        },
+      )
+
+      it(
+        'should throw error when beginTransaction fails to connect (mongo)',
+        { db: 'mongo' },
+        async () => {
+          const db = payload.db as unknown as Record<string, unknown>
+          const originalConnection = db.connection
+          try {
+            db.connection = {
+              getClient: () => ({
+                startSession: () => {
+                  throw new Error('connection refused')
+                },
+              }),
+            }
+
+            await expect(() => payload.db.beginTransaction()).rejects.toThrow(/connection refused/)
+          } finally {
+            db.connection = originalConnection
+          }
+        },
+      )
+
       describe('disableTransaction', () => {
         let disabledTransactionPost
         beforeAll(async () => {