From 3646952acc46d1d16e792f1a72c293a0150c4494 Mon Sep 17 00:00:00 2001
From: Valeri Karpov <val@karpov.io>
Date: Thu, 11 Jul 2024 13:25:21 -0400
Subject: [PATCH] fix(model): handle `transactionAsyncLocalStorage` option with
 `insertMany()`

Fix #14738
---
 lib/model.js                   | 5 +++++
 test/docs/transactions.test.js | 5 +++++
 2 files changed, 10 insertions(+)

diff --git a/lib/model.js b/lib/model.js
index 9cd7a14d6de..767c8e67121 100644
--- a/lib/model.js
+++ b/lib/model.js
@@ -2838,6 +2838,11 @@ Model.$__insertMany = function(arr, options, callback) {
   const throwOnValidationError = typeof options.throwOnValidationError === 'boolean' ? options.throwOnValidationError : false;
   const lean = !!options.lean;
 
+  const asyncLocalStorage = this.db.base.transactionAsyncLocalStorage?.getStore();
+  if ((!options || !options.hasOwnProperty('session')) && asyncLocalStorage?.session != null) {
+    options = { ...options, session: asyncLocalStorage.session };
+  }
+
   if (!Array.isArray(arr)) {
     arr = [arr];
   }
diff --git a/test/docs/transactions.test.js b/test/docs/transactions.test.js
index b68996d86a0..ab41a7063bc 100644
--- a/test/docs/transactions.test.js
+++ b/test/docs/transactions.test.js
@@ -388,6 +388,8 @@ describe('transactions', function() {
           }();
           assert.equal(doc.name, 'test_transactionAsyncLocalStorage');
 
+          await Test.insertMany([{ name: 'bar' }]);
+
           throw new Error('Oops!');
         }),
         /Oops!/
@@ -397,6 +399,9 @@ describe('transactions', function() {
 
       exists = await Test.exists({ name: 'foo' });
       assert.ok(!exists);
+
+      exists = await Test.exists({ name: 'bar' });
+      assert.ok(!exists);
     });
   });