Feature/routing keys (#29) (#30)

* add custom routing key option

* bump version

---------

Co-authored-by: Santiago Sanchez <ssd170@gmail.com>

Author: acrontum-sanchez

.gitignore

@@ -1,3 +1,5 @@
 node_modules
 /lib
 /coverage
+.vscode
+.idea

package-lock.json

@@ -1,12 +1,12 @@
 {
   "name": "q-wrapper",
-  "version": "1.0.4",
+  "version": "1.0.8",
   "description": "A TypeScript npm package that manages queue connections and operations with amqplib.",
   "main": "lib/index.js",
   "types": "lib/index.d.ts",
   "scripts": {
     "test": "jest --config jestconfig.json",
-    "build": "tsc -d --declarationDir lib",
+    "build": "tsc --build",
     "build:watch": "tsc --watch",
     "format": "prettier --write \"src/**/*.ts\" \"src/**/*.js\"",
     "lint": "tslint -p tsconfig.json",
@@ -30,17 +30,17 @@
   "author": "sanchez@acrontum.de",
   "license": "MIT",
   "devDependencies": {
-    "@types/amqplib": "^0.8.2",
-    "@types/jest": "^25.1.2",
-    "jest": "^25.1.0",
+    "@types/amqplib": "^0.10.1",
+    "@types/jest": "^29.4.0",
+    "jest": "^29.4.2",
     "prettier": "^1.19.1",
-    "ts-jest": "^25.2.1",
-    "tslint": "^6.0.0",
+    "ts-jest": "^29.0.5",
+    "tslint": "^6.1.3",
     "tslint-config-prettier": "^1.18.0",
-    "typescript": "^3.7.5"
+    "typescript": "^4.3.5"
   },
   "dependencies": {
-    "amqplib": "^0.8.0"
+    "amqplib": "^0.10.3"
   },
   "files": [
     "lib/**/*"

package.json

@@ -1,29 +1,27 @@
 import { QWrapperDomain, QWrapperSettings } from '..';
+import { ExchangeType } from '../models/QWrapperSettings';
 
 const settings: QWrapperSettings = {
-  exchange: 'test_dsd_exchange',
+  exchange: 'amq.fanout',
   connection: {
     protocol: 'amqp',
     hostname: 'localhost',
     port: 5672,
-    username: 'guest',
-    password: 'guest',
-    locale: 'en_US',
-    frameMax: 0,
-    heartbeat: 0,
-    vhost: '/',
+    username: 'admin',
+    password: 'admin',
+    vhost: 'vhost',
   },
-  queue: 'test_dsd_queue',
-  exchangeType: 'fanout',
+  queue: 'myqueue.events',
+  exchangeType: ExchangeType.fanout,
   reconnect: false,
-  dleExchange: 'test_dsd_dead_exchange',
-  dleQueue: 'test_dsd_dead_letter',
+  dleExchange: 'amq.fanout',
+  dleQueue: 'myqueue.dle_events',
 };
 
 test('Queue manager constructor string url', done => {
   const qw = new QWrapperDomain({
     ...settings,
-    connection: 'amqp://localhost',
+    connection: 'amqp://admin:admin@localhost:5672/vhost',
   });
   done();
 });

src/__tests__/QWrapperDomain.test.ts

@@ -91,7 +91,8 @@ export class QWrapperDomain {
           });
           console.info(`${packageName} Queue: '${this._settings.queue}' asserted successfully`);
 
-          this._channel.bindQueue(this._settings.queue, this._settings.exchange, this._settings.queue);
+          const routingKey = this._settings.routingKey ? this._settings.routingKey : this._settings.queue;
+          this._channel.bindQueue(this._settings.queue, this._settings.exchange, routingKey);
 
           this._channel.prefetch(this._settings.prefetch || 1);
 

src/demo.ts

@@ -1,14 +1,21 @@
 import { ConnectionOptions } from './ConnectionOptions';
 
+export enum ExchangeType {
+  direct = 'direct',
+  topic = 'topic',
+  fanout = 'fanout',
+}
+
 export interface QWrapperSettings {
   connection: string | ConnectionOptions;
-  queue: string;
+  dleExchange?: string;
+  dleQueue: string;
   exchange: string;
-  exchangeType: string;
+  exchangeType: ExchangeType | string;
+  prefetch?: number;
+  queue: string;
+  reconnect?: boolean;
+  routingKey?: string;
   verboseLogging?: boolean;
   veryVerboseLogging?: boolean;
-  reconnect?: boolean;
-  prefetch?: number;
-  dleQueue: string;
-  dleExchange?: string;
 }

src/domains/QWrapperDomain.ts

@@ -1,10 +1,11 @@
 {
   "compilerOptions": {
-    "target": "ES2018",
-    "module": "commonjs",
     "declaration": true,
+    "module": "commonjs",
     "outDir": "./lib",
-    "strict": true
+    "rootDir": "src",
+    "strict": true,
+    "target": "ES2020",
   },
   "include": ["src"],
   "exclude": [