@collexx/rabbitmq - npm Package Compare versions

Comparing version 0.0.1 to 0.0.2

dist/collexx-rabbitmq.module.js

@@ -36,4 +36,2 @@ "use strict";
                     const options = await optionsFactory();
-                    console.log('rabbit1');
-                    console.log(options.url);
                     return new collexx_rabbitmqmq_service_1.RmqService(options, cacheManager);
@@ -40,0 +38,0 @@ },

dist/collexx-rabbitmqmq.service.js

@@ -27,3 +27,2 @@ "use strict";
         this.on = (queue, callback) => {
-            console.log(`new handler registered ${queue.QUEUE.QUEUE_NAME}`);
             this.handlers[queue.QUEUE.QUEUE_NAME] = callback;
@@ -134,5 +133,2 @@ };
             }
-            console.log('네임');
-            console.log(channelName);
-            console.log(this.configChannels[channelName]);
             const createdChannel = await this.connection.createChannel();
@@ -144,3 +140,2 @@ await createdChannel.prefetch(this.configChannels[channelName].prefetch);
             createdChannel.on('close', () => {
-                console.log(`[AMQP] channel ${channelName} closed`);
             });
@@ -166,5 +161,2 @@ return createdChannel;
                 await channel.assertExchange('dlx', 'direct', { durable: true });
-                console.log('하하');
-                console.log(QUEUE.EXCHANGE.name);
-                console.log(QUEUE.QUEUE_NAME);
                 await channel.bindQueue(QUEUE.QUEUE_NAME, QUEUE.EXCHANGE.name, QUEUE.QUEUE_NAME);
@@ -190,3 +182,3 @@ await channel.bindQueue(QUEUE.QUEUE_NAME + '_dlq', 'dlx', QUEUE.QUEUE_NAME + '_dlq');
                 if (err) {
-                    console.log(err);
+                    console.error(err);
                 }
@@ -201,3 +193,2 @@ return resolve(ok);
             default: {
-                console.log(queue.QUEUE.EXCHANGE.type);
                 break;
@@ -209,3 +200,3 @@ }
                 if (err) {
-                    console.log(err);
+                    console.error(err);
                 }
@@ -217,3 +208,2 @@ return resolve(ok);
     async consumer(queue) {
-        console.log('CONSUMING....', queue.QUEUE.QUEUE_NAME);
         const channel = this.channels[queue.CHANNEL_NAME];
@@ -228,3 +218,3 @@ if (!channel) {
                 if ((0, helpers_1.isNil)(result) || (0, helpers_1.isNil)(handler)) {
-                    console.log(`no handler for ${queue.QUEUE.QUEUE_NAME} or result is null`);
+                    console.error(`no handler for ${queue.QUEUE.QUEUE_NAME} or result is null`);
                     return;
@@ -237,6 +227,4 @@ }
             catch (error) {
-                console.log(error);
-                console.log('에러가발생함');
+                console.error(error);
                 const content = JSON.parse(result.content.toString())[0];
-                console.log(content);
                 await channel.nack(result, false, false);
@@ -243,0 +231,0 @@ }

package.json

 {
   "name": "@collexx/rabbitmq",
-  "version": "0.0.1",
+  "version": "0.0.2",
   "description": "Collexx Package",
@@ -42,2 +42,3 @@ "author": "collexx",
     "cache-manager": "^5.2.1",
+    "dotenv": "^16.0.3",
     "reflect-metadata": "^0.1.13",
@@ -55,2 +56,3 @@ "rxjs": "^7.2.0"
     "@types/supertest": "^2.0.11",
+    "@types/uuid": "^9.0.1",
     "@typescript-eslint/eslint-plugin": "^5.0.0",
@@ -57,0 +59,0 @@ "@typescript-eslint/parser": "^5.0.0",

src/collexx-rabbitmq.module.ts

@@ -40,4 +40,4 @@ import {
           const options = await optionsFactory();
-          console.log('rabbit1');
-          console.log(options.url);
+          // console.log('rabbit1');
+          // console.log(options.url);
           return new RmqService(options, cacheManager);
@@ -44,0 +44,0 @@ },

src/collexx-rabbitmqmq.service.ts

@@ -173,5 +173,5 @@ import { Channel, ConfirmChannel, connect, Connection, Options } from 'amqplib';
       }
-      console.log('네임');
-      console.log(channelName);
-      console.log(this.configChannels[channelName]);
+      // console.log('네임');
+      // console.log(channelName);
+      // console.log(this.configChannels[channelName]);
       const createdChannel = await this.connection.createChannel();
@@ -189,3 +189,3 @@ await createdChannel.prefetch(this.configChannels[channelName].prefetch);
       createdChannel.on('close', () => {
-        console.log(`[AMQP] channel ${channelName} closed`);
+        // console.log(`[AMQP] channel ${channelName} closed`);
       });
@@ -222,5 +222,5 @@
 
-        console.log('하하');
-        console.log(QUEUE.EXCHANGE.name);
-        console.log(QUEUE.QUEUE_NAME);
+        // console.log('하하');
+        // console.log(QUEUE.EXCHANGE.name);
+        // console.log(QUEUE.QUEUE_NAME);
         await channel.bindQueue(
@@ -280,3 +280,3 @@ QUEUE.QUEUE_NAME,
           if (err) {
-            console.log(err);
+            console.error(err);
           }
@@ -304,3 +304,3 @@
       default: {
-        console.log(queue.QUEUE.EXCHANGE.type);
+        // console.log(queue.QUEUE.EXCHANGE.type);
         break;
@@ -318,3 +318,3 @@ }
           if (err) {
-            console.log(err);
+            console.error(err);
           }
@@ -333,3 +333,3 @@
   private async consumer(queue: IPublish) {
-    console.log('CONSUMING....', queue.QUEUE.QUEUE_NAME);
+    // console.log('CONSUMING....', queue.QUEUE.QUEUE_NAME);
     const channel = this.channels[queue.CHANNEL_NAME];
@@ -347,3 +347,3 @@ if (!channel) {
         if (isNil(result) || isNil(handler)) {
-          console.log(
+          console.error(
             `no handler for ${queue.QUEUE.QUEUE_NAME} or result is null`,
@@ -358,6 +358,6 @@ );
       } catch (error) {
-        console.log(error);
-        console.log('에러가발생함');
+        console.error(error);
+        // console.log('에러가발생함');
         const content = JSON.parse(result.content.toString())[0];
-        console.log(content);
+        // console.log(content);
         //todo 여기서 에러 처리 필요
@@ -384,5 +384,5 @@ // const consumeErrorCount = await this.cacheManager.get(result.properties.messageId);
   public on = (queue: IPublish, callback: (result: any) => void) => {
-    console.log(`new handler registered ${queue.QUEUE.QUEUE_NAME}`);
+    // console.log(`new handler registered ${queue.QUEUE.QUEUE_NAME}`);
     this.handlers[queue.QUEUE.QUEUE_NAME] = callback;
   };
 }

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

Major refactor

Supply chain risk

Package has recently undergone a major refactor. It may be unstable or indicate significant internal changes. Use caution when updating to versions that include significant changes.

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

729638

increased by356.31%

Number of package files

74

increased by2.78%

Lines of code

16431

increased by1072.81%

Worsened metrics

Dependency count

8

increased by14.29%

Dev dependency count

23

increased by4.55%

Number of medium supply chain risk alerts

1

increased byInfinity%

Dependency changes

• + Addeddotenv@^16.0.3

• + Addeddotenv@16.4.5(transitive)