mongo2elastic - npm Package Compare versions

Comparing version 0.39.1 to 0.40.0

CHANGELOG.md

@@ -0,1 +1,5 @@
+# 0.40.0
+
+- Remove `updateDescription` since it is not needed and may cause a `BSONObjectTooLarge` error.
+
 # 0.39.1
@@ -2,0 +6,0 @@

dist/syncData.d.ts

@@ -13,3 +13,3 @@ import type { Collection } from 'mongodb';
      */
-    processChangeStream: (options?: QueueOptions & ChangeStreamOptions) => Promise<{
+    processChangeStream: (options: QueueOptions & ChangeStreamOptions) => Promise<{
         start: () => Promise<void>;
@@ -16,0 +16,0 @@ stop: () => Promise<void>;

dist/syncData.js

@@ -143,3 +143,9 @@ import _ from 'lodash/fp.js';
     };
-    const processChangeStream = (options) => sync.processChangeStream(processChangeStreamRecords, options);
+    const processChangeStream = (options) => sync.processChangeStream(processChangeStreamRecords, {
+        ...options,
+        pipeline: [
+            { $unset: ['updateDescription'] },
+            ...(options?.pipeline ?? []),
+        ],
+    });
     const runInitialScan = (options) => sync.runInitialScan(processRecords, options);
@@ -146,0 +152,0 @@ return {

package.json

 {
   "name": "mongo2elastic",
-  "version": "0.39.1",
+  "version": "0.40.0",
   "description": "Sync MongoDB collections to Elasticsearch",
@@ -5,0 +5,0 @@ "main": "dist/index.js",

src/syncData.ts

@@ -175,4 +175,10 @@ import _ from 'lodash/fp.js'
 
-  const processChangeStream = (options?: QueueOptions & ChangeStreamOptions) =>
-    sync.processChangeStream(processChangeStreamRecords, options)
+  const processChangeStream = (options: QueueOptions & ChangeStreamOptions) =>
+    sync.processChangeStream(processChangeStreamRecords, {
+      ...options,
+      pipeline: [
+        { $unset: ['updateDescription'] },
+        ...(options?.pipeline ?? []),
+      ],
+    })
   const runInitialScan = (options?: QueueOptions & ScanOptions) =>
@@ -179,0 +185,0 @@ sync.runInitialScan(processRecords, options)

No alert changes

Improved metrics

Total package byte prevSize

58748

increased by0.64%

Lines of code

1545

increased by0.78%

No dependency changes