@thecolvinco/nodejs-amqplib - npm Package Compare versions

Comparing version 0.0.3 to 0.0.4

dist/main.d.ts

@@ -6,3 +6,4 @@ import { Connection } from 'amqplib';
 import producer from './utils/producer';
+import { createEvent, createCommand } from './utils/message';
 declare const amqpConnect: (connectionString: string) => Promise<Connection>;
-export { amqpConnect, retryable, deadLetter, worker, producer, };
+export { amqpConnect, retryable, deadLetter, worker, producer, createEvent, createCommand, };

dist/main.esm.js

@@ -201,2 +201,46 @@ import { connect } from 'amqplib';
 
+const parse = ({
+  payload,
+  meta,
+  type
+}) => {
+  const {
+    company,
+    context,
+    version,
+    entity,
+    name
+  } = meta;
+  const message = {
+    occurred_on: Date.now(),
+    payload,
+    name: `${company}.${context}.${version}.${type}.${entity}.${name}`
+  };
+  return JSON.stringify(message);
+};
+
+const createEvent = ({
+  payload,
+  meta
+}) => {
+  const message = parse({
+    payload,
+    meta,
+    type: 'event'
+  });
+  return JSON.stringify(message);
+};
+
+const createCommand = ({
+  payload,
+  meta
+}) => {
+  const message = parse({
+    payload,
+    meta,
+    type: 'command'
+  });
+  return JSON.stringify(message);
+};
+
 const amqpConnect = connectionString => {
@@ -206,3 +250,3 @@ return connect(connectionString);
 
-export { amqpConnect, deadLetter, producer, retryable, worker };
+export { amqpConnect, createCommand, createEvent, deadLetter, producer, retryable, worker };
 //# sourceMappingURL=main.esm.js.map

dist/main.js

@@ -201,2 +201,46 @@ var amqplib = require('amqplib');
 
+const parse = ({
+  payload,
+  meta,
+  type
+}) => {
+  const {
+    company,
+    context,
+    version,
+    entity,
+    name
+  } = meta;
+  const message = {
+    occurred_on: Date.now(),
+    payload,
+    name: `${company}.${context}.${version}.${type}.${entity}.${name}`
+  };
+  return JSON.stringify(message);
+};
+
+const createEvent = ({
+  payload,
+  meta
+}) => {
+  const message = parse({
+    payload,
+    meta,
+    type: 'event'
+  });
+  return JSON.stringify(message);
+};
+
+const createCommand = ({
+  payload,
+  meta
+}) => {
+  const message = parse({
+    payload,
+    meta,
+    type: 'command'
+  });
+  return JSON.stringify(message);
+};
+
 const amqpConnect = connectionString => {
@@ -207,2 +251,4 @@ return amqplib.connect(connectionString);
 exports.amqpConnect = amqpConnect;
+exports.createCommand = createCommand;
+exports.createEvent = createEvent;
 exports.deadLetter = deadLetter;
@@ -209,0 +255,0 @@ exports.producer = producer;

dist/main.modern.js

@@ -126,2 +126,46 @@ import { connect } from 'amqplib';
 
+const parse = ({
+  payload,
+  meta,
+  type
+}) => {
+  const {
+    company,
+    context,
+    version,
+    entity,
+    name
+  } = meta;
+  const message = {
+    occurred_on: Date.now(),
+    payload,
+    name: `${company}.${context}.${version}.${type}.${entity}.${name}`
+  };
+  return JSON.stringify(message);
+};
+
+const createEvent = ({
+  payload,
+  meta
+}) => {
+  const message = parse({
+    payload,
+    meta,
+    type: 'event'
+  });
+  return JSON.stringify(message);
+};
+
+const createCommand = ({
+  payload,
+  meta
+}) => {
+  const message = parse({
+    payload,
+    meta,
+    type: 'command'
+  });
+  return JSON.stringify(message);
+};
+
 const amqpConnect = connectionString => {
@@ -131,3 +175,3 @@ return connect(connectionString);
 
-export { amqpConnect, deadLetter, producer, retryable, worker };
+export { amqpConnect, createCommand, createEvent, deadLetter, producer, retryable, worker };
 //# sourceMappingURL=main.modern.js.map

dist/main.umd.js

@@ -204,2 +204,46 @@ (function (global, factory) {
 
+  const parse = ({
+    payload,
+    meta,
+    type
+  }) => {
+    const {
+      company,
+      context,
+      version,
+      entity,
+      name
+    } = meta;
+    const message = {
+      occurred_on: Date.now(),
+      payload,
+      name: `${company}.${context}.${version}.${type}.${entity}.${name}`
+    };
+    return JSON.stringify(message);
+  };
+
+  const createEvent = ({
+    payload,
+    meta
+  }) => {
+    const message = parse({
+      payload,
+      meta,
+      type: 'event'
+    });
+    return JSON.stringify(message);
+  };
+
+  const createCommand = ({
+    payload,
+    meta
+  }) => {
+    const message = parse({
+      payload,
+      meta,
+      type: 'command'
+    });
+    return JSON.stringify(message);
+  };
+
   const amqpConnect = connectionString => {
@@ -210,2 +254,4 @@ return amqplib.connect(connectionString);
   exports.amqpConnect = amqpConnect;
+  exports.createCommand = createCommand;
+  exports.createEvent = createEvent;
   exports.deadLetter = deadLetter;
@@ -212,0 +258,0 @@ exports.producer = producer;

package.json

 {
   "name": "@thecolvinco/nodejs-amqplib",
   "description": "RabbitMQ abstraction with some utils",
-  "version": "0.0.3",
+  "version": "0.0.4",
   "source": "src/main.ts",
@@ -6,0 +6,0 @@ "main": "dist/main.umd.js",

No alert changes

Improved metrics

Total package byte prevSize

71595

increased by17.88%

Number of package files

17

increased by6.25%

Lines of code

879

increased by24.5%

No dependency changes