@thecolvinco/nodejs-messenger - npm Package Compare versions

Comparing version 1.0.2 to 1.0.3

dist/main.esm.js

@@ -1,6 +0,25 @@
-import { v4 } from 'uuid';
-import { connect } from 'amqplib';
-import { EventEmitter } from 'events';
-import { resolve } from 'path';
+function _interopNamespace(e) {
+  if (e && e.__esModule) { return e; } else {
+    var n = {};
+    if (e) {
+      Object.keys(e).forEach(function (k) {
+        var d = Object.getOwnPropertyDescriptor(e, k);
+        Object.defineProperty(n, k, d.get ? d : {
+          enumerable: true,
+          get: function () {
+            return e[k];
+          }
+        });
+      });
+    }
+    n['default'] = e;
+    return n;
+  }
+}
 
+var uuid = require('uuid');
+var amqplib = require('amqplib');
+var events = require('events');
+var path = require('path');
+
 const parse = ({
@@ -20,3 +39,3 @@ payload,
     data: {
-      messageId: v4(),
+      messageId: uuid.v4(),
       occurredOn: Date.now(),
@@ -223,3 +242,3 @@ attributes: payload,
 const amqpConnect = connectionString => {
-  return connect(connectionString);
+  return amqplib.connect(connectionString);
 };
@@ -340,3 +359,3 @@
 
-class DomainEventEmitter extends EventEmitter {
+class DomainEventEmitter extends events.EventEmitter {
   on(eventName, originalFunction) {
@@ -364,3 +383,3 @@ const decoratedFunction = async ({
 
-class CommandEmitter extends EventEmitter {
+class CommandEmitter extends events.EventEmitter {
   on(eventName, originalFunction) {
@@ -396,3 +415,3 @@ const decoratedFunction = async ({
     commandsPath.forEach(async commandPath => {
-      const resolvedModule = await import(resolve(commandPath.trim()));
+      const resolvedModule = await new Promise(function (resolve) { resolve(_interopNamespace(require(path.resolve(commandPath.trim())))); });
       const Command = resolvedModule['default'];
@@ -417,4 +436,4 @@ emitter.on(eventName, message => {
   }) {
-    const resolvedHandlerModule = await import(resolve(handlerPath.trim()));
-    const resolvedCommandModule = await import(resolve(handlerPath.replace('Handler', '').trim()));
+    const resolvedHandlerModule = await new Promise(function (resolve) { resolve(_interopNamespace(require(path.resolve(handlerPath.trim())))); });
+    const resolvedCommandModule = await new Promise(function (resolve) { resolve(_interopNamespace(require(path.resolve(handlerPath.replace('Handler', '').trim())))); });
     const Handler = resolvedHandlerModule['default'];
@@ -740,3 +759,19 @@ const Command = resolvedCommandModule['default'];
 
-export { CommandConsumer, CommandEmitter, DomainEventConsumer, DomainEventEmitter, EventDispatcher, amqpConnect, commandSubscriber, createCommand, createEvent, deadLetter, domainEventSubscriber, producer, pubSubInitialization, retryable, toJSON, transportsInitialization, worker };
+exports.CommandConsumer = CommandConsumer;
+exports.CommandEmitter = CommandEmitter;
+exports.DomainEventConsumer = DomainEventConsumer;
+exports.DomainEventEmitter = DomainEventEmitter;
+exports.EventDispatcher = EventDispatcher;
+exports.amqpConnect = amqpConnect;
+exports.commandSubscriber = commandSubscriber;
+exports.createCommand = createCommand;
+exports.createEvent = createEvent;
+exports.deadLetter = deadLetter;
+exports.domainEventSubscriber = domainEventSubscriber;
+exports.producer = producer;
+exports.pubSubInitialization = pubSubInitialization;
+exports.retryable = retryable;
+exports.toJSON = toJSON;
+exports.transportsInitialization = transportsInitialization;
+exports.worker = worker;
 //# sourceMappingURL=main.esm.js.map

package.json

 {
   "name": "@thecolvinco/nodejs-messenger",
   "description": "Message library for nodejs applications",
-  "version": "1.0.2",
+  "version": "1.0.3",
   "source": "src/main.ts",
-  "main": "dist/main.umd.js",
+  "main": "dist/main.esm.js",
   "types": "dist/main.d.ts",
@@ -8,0 +8,0 @@ "keywords": [

No alert changes

Improved metrics

Total package byte prevSize

395607

increased by70.31%

Number of package files

38

increased by18.75%

Lines of code

4901

increased by70.95%

Worsened metrics

Number of low supply chain risk alerts

6

increased by100%

No dependency changes