From 3f3160406f93e793d909f6fb0fb7c2e0ab7f334d Mon Sep 17 00:00:00 2001
From: "SPRINX0\\prochazka" <jan.prochazka@sprinx.com>
Date: Mon, 3 Mar 2025 16:05:12 +0100
Subject: [PATCH] propagate error in mongo stream

---
 plugins/dbgate-plugin-mongo/src/backend/driver.js | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/plugins/dbgate-plugin-mongo/src/backend/driver.js b/plugins/dbgate-plugin-mongo/src/backend/driver.js
index 23aca12b6..9c10ba8eb 100644
--- a/plugins/dbgate-plugin-mongo/src/backend/driver.js
+++ b/plugins/dbgate-plugin-mongo/src/backend/driver.js
@@ -266,6 +266,11 @@ const driver = {
       pass.write(transformMongoData(row));
     });
 
+    // propagate error
+    cursorStream.on('error', (err) => {
+      pass.emit('error', err);
+    });
+
     // Called once the cursor is fully read
     cursorStream.on('end', () => {
       pass.emit('end');