		@@ -13,5 +13,4 @@ "use strict";
		const util_js_1 = require("./util.js");
		const debug = (0, debug_1.default)('mongoChangeStream');
		const debug = (0, debug_1.default)('mongochangestream');
		const keyPrefix = 'mongoChangeStream';
		const getCollectionKey = (collection) => `${collection.dbName}:${collection.collectionName}`;
		/**
		@@ -21,3 +20,3 @@ * Get Redis keys used for the given collection.
		const getKeys = (collection) => {
		const collectionKey = getCollectionKey(collection);
		const collectionKey = (0, util_js_1.getCollectionKey)(collection);
		const scanPrefix = `${keyPrefix}:${collectionKey}`;
		@@ -24,0 +23,0 @@ const scanCompletedKey = `${scanPrefix}:initialScanCompletedOn`;

dist/util.d.ts

		@@ -0,1 +1,2 @@
		import { Collection } from 'mongodb';
		import _ from 'lodash/fp.js';
		@@ -8,1 +9,2 @@ export declare const setDefaults: (keys: string[], val: any) => Record<string, any>;
		export declare const omitFieldForUpdate: (omitPaths: string[]) => _.LodashUpdate1x3;
		export declare const getCollectionKey: (collection: Collection) => string;

dist/util.js

		@@ -6,3 +6,3 @@ "use strict";
		Object.defineProperty(exports, "__esModule", { value: true });
		exports.omitFieldForUpdate = exports.omitFields = exports.generatePipelineFromOmit = exports.setDefaults = void 0;
		exports.getCollectionKey = exports.omitFieldForUpdate = exports.omitFields = exports.generatePipelineFromOmit = exports.setDefaults = void 0;
		const fp_js_1 = __importDefault(require("lodash/fp.js"));
		@@ -29,1 +29,3 @@ const setDefaults = (keys, val) => {
		exports.omitFieldForUpdate = omitFieldForUpdate;
		const getCollectionKey = (collection) => `${collection.dbName}:${collection.collectionName}`;
		exports.getCollectionKey = getCollectionKey;

package.json

		{
		"name": "mongochangestream",
		"version": "0.14.0",
		"version": "0.15.0",
		"description": "Sync MongoDB collections via change streams into any database.",
		@@ -5,0 +5,0 @@ "author": "GovSpend",

README.md

		@@ -18,2 +18,8 @@ # Mongo Change Stream

		This library uses `debug`. To enable you can do something like:

		```
		DEBUG=mongochangestream node myfile.js
		```

		```typescript
		@@ -20,0 +26,0 @@ import { ChangeStreamDocument, MongoClient } from 'mongodb'

src/mongoChangeStream.ts

		@@ -20,2 +20,3 @@ import _ from 'lodash/fp.js'
		generatePipelineFromOmit,
		getCollectionKey,
		omitFieldForUpdate,
		@@ -25,9 +26,6 @@ setDefaults,

		const debug = _debug('mongoChangeStream')
		const debug = _debug('mongochangestream')

		const keyPrefix = 'mongoChangeStream'

		const getCollectionKey = (collection: Collection) =>
		`${collection.dbName}:${collection.collectionName}`

		/**
		@@ -34,0 +32,0 @@ * Get Redis keys used for the given collection.

src/util.ts

		@@ -0,1 +1,2 @@
		import { Collection } from 'mongodb'
		import _ from 'lodash/fp.js'
		@@ -26,1 +27,4 @@
		_.update('updateDescription.updatedFields', omitFields(omitPaths))

		export const getCollectionKey = (collection: Collection) =>
		`${collection.dbName}:${collection.collectionName}`

mongochangestream - npm Package Compare versions

New alerts