mongochangestream - npm Package Compare versions

Comparing version 0.23.0 to 0.24.0

CHANGELOG.md

@@ -0,1 +1,5 @@
+# 0.24.0
+
+- Use `eventemitter3`.
+
 # 0.23.0
@@ -2,0 +6,0 @@

dist/mongoChangeStream.d.ts

@@ -1,2 +0,1 @@
-/// <reference types="node" />
 import _ from 'lodash/fp.js';
@@ -7,3 +6,3 @@ import { Collection, Document, ObjectId, Db } from 'mongodb';
 import { QueueOptions } from 'prom-utils';
-import events from 'node:events';
+import EventEmitter from 'eventemitter3';
 export declare const defaultSortField: {
@@ -57,3 +56,3 @@ field: string;
         stop: () => void;
-        emitter: events;
+        emitter: EventEmitter<"change", any>;
     }>;
@@ -60,0 +59,0 @@ /**

dist/mongoChangeStream.js

@@ -13,3 +13,3 @@ "use strict";
 const util_js_1 = require("./util.js");
-const node_events_1 = __importDefault(require("node:events"));
+const eventemitter3_1 = __importDefault(require("eventemitter3"));
 const ms_1 = __importDefault(require("ms"));
@@ -175,3 +175,3 @@ const debug = (0, debug_1.default)('mongochangestream');
         const maybeRemoveMetadata = (0, util_js_1.when)(shouldRemoveMetadata, util_js_1.removeMetadata);
-        const emitter = new node_events_1.default.EventEmitter();
+        const emitter = new eventemitter3_1.default();
         let timer;
@@ -178,0 +178,0 @@ // Check for a cached schema

dist/types.d.ts

@@ -20,1 +20,2 @@ import { ChangeStreamDocument, ChangeStreamInsertDocument } from 'mongodb';
 export declare type JSONSchema = JSONSchema4 | JSONSchema6 | JSONSchema7;
+export declare type Events = 'change';

package.json

 {
   "name": "mongochangestream",
-  "version": "0.23.0",
+  "version": "0.24.0",
   "description": "Sync MongoDB collections via change streams into any database.",
@@ -45,2 +45,3 @@ "author": "GovSpend",
     "debug": "^4.3.4",
+    "eventemitter3": "^4.0.7",
     "lodash": "^4.17.21",
@@ -47,0 +48,0 @@ "ms": "^2.1.3",

src/mongoChangeStream.ts

@@ -12,2 +12,3 @@ import _ from 'lodash/fp.js'
 import {
+  Events,
   SyncOptions,
@@ -31,3 +32,3 @@ ProcessRecord,
 } from './util.js'
-import events from 'node:events'
+import EventEmitter from 'eventemitter3'
 import ms from 'ms'
@@ -226,3 +227,3 @@
 
-    const emitter = new events.EventEmitter()
+    const emitter = new EventEmitter<Events>()
     let timer: NodeJS.Timer
@@ -229,0 +230,0 @@ // Check for a cached schema

src/types.ts

@@ -28,1 +28,3 @@ import { ChangeStreamDocument, ChangeStreamInsertDocument } from 'mongodb'
 export type JSONSchema = JSONSchema4 | JSONSchema6 | JSONSchema7
+
+export type Events = 'change'

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

41099

increased by0.35%

Lines of code

890

increased by0.23%

Worsened metrics

Dependency count

9

increased by12.5%

Dependency changes

• + Addedeventemitter3@^4.0.7

• + Addedeventemitter3@4.0.7(transitive)