fix: linter

DIY0R · Jun 22, 2024 · bccb83b · bccb83b
1 parent ee5ce3d
commit bccb83b
Show file tree

Hide file tree

Showing 4 changed files with 21 additions and 32 deletions.
diff --git a/.eslintrc.js b/.eslintrc.js
@@ -6,10 +6,7 @@ module.exports = {
     sourceType: 'module',
   },
   plugins: ['@typescript-eslint/eslint-plugin'],
-  extends: [
-    'plugin:@typescript-eslint/recommended',
-    'plugin:prettier/recommended',
-  ],
+  extends: ['plugin:@typescript-eslint/recommended', 'prettier'],
   root: true,
   env: {
     node: true,
@@ -20,12 +17,7 @@ module.exports = {
     '@typescript-eslint/interface-name-prefix': 'off',
     '@typescript-eslint/explicit-function-return-type': 'off',
     '@typescript-eslint/explicit-module-boundary-types': 'off',
+    '@typescript-eslint/no-unused-vars': 'off',
     '@typescript-eslint/no-explicit-any': 'off',
   },
-  'prettier/prettier': [
-    'error',
-    {
-      endOfLine: 'auto',
-    },
-  ],
 };
diff --git a/.prettierrc b/.prettierrc
@@ -1,4 +1,6 @@
 {
   "singleQuote": true,
-  "trailingComma": "all"
+  "trailingComma": "all",
+  "endOfLine": "auto"
+
 }
diff --git a/lib/rmq.service.ts b/lib/rmq.service.ts
@@ -6,12 +6,7 @@ import {
   OnModuleInit,
 } from '@nestjs/common';
 
-import {
-  IMessageBroker,
-  IPublishOptions,
-  ImqService,
-  TypeQueue,
-} from './interfaces';
+import { IMessageBroker, IPublishOptions, TypeQueue } from './interfaces';
 import { IMetaTegsMap } from './interfaces/metategs';
 import {
   DEFAULT_TIMEOUT,
@@ -45,7 +40,7 @@ export class RmqService implements OnModuleInit, OnModuleDestroy {
     private readonly rmqNestjsConnectService: RmqNestjsConnectService,
     private readonly metaTegsScannerService: MetaTegsScannerService,
     @Inject(RMQ_BROKER_OPTIONS) private options: IMessageBroker,
-    @Inject(RMQ_APP_OPTIONS) private appOptions: IAppOptions
+    @Inject(RMQ_APP_OPTIONS) private appOptions: IAppOptions,
   ) {
     this.logger = appOptions.logger
       ? appOptions.logger
@@ -62,7 +57,7 @@ export class RmqService implements OnModuleInit, OnModuleDestroy {
   public async notify<IMessage>(
     topic: string,
     message: IMessage,
-    options?: IPublishOptions
+    options?: IPublishOptions,
   ) {
     await this.initializationCheck();
     this.rmqNestjsConnectService.publish({
@@ -80,7 +75,7 @@ export class RmqService implements OnModuleInit, OnModuleDestroy {
   public async send<IMessage, IReply>(
     topic: string,
     message: IMessage,
-    options?: IPublishOptions
+    options?: IPublishOptions,
   ): Promise<IReply> {
     await this.initializationCheck();
     if (!this.replyToQueue) return this.logger.error(INDICATE_ERROR);
@@ -115,7 +110,7 @@ export class RmqService implements OnModuleInit, OnModuleDestroy {
     if (!message) return;
     const consumeFunction = this.rmqMessageTegs.get(message.fields.routingKey);
     const result = await consumeFunction(
-      JSON.parse(message.content.toString())
+      JSON.parse(message.content.toString()),
     );
     if (message.properties.replyTo) {
       await this.rmqNestjsConnectService.sendToReplyQueue({
@@ -127,7 +122,7 @@ export class RmqService implements OnModuleInit, OnModuleDestroy {
     this.rmqNestjsConnectService.ack(message);
   }
   private async listenReplyQueue(
-    message: ConsumeMessage | null
+    message: ConsumeMessage | null,
   ): Promise<void> {
     if (message.properties.correlationId) {
       this.sendResponseEmitter.emit(message.properties.correlationId, message);
@@ -136,7 +131,7 @@ export class RmqService implements OnModuleInit, OnModuleDestroy {
 
   private async init() {
     this.exchange = await this.rmqNestjsConnectService.assertExchange(
-      this.options.exchange
+      this.options.exchange,
     );
     if (this.options.replyTo) await this.assertReplyQueueBind();
     await this.bindQueueExchange();
@@ -145,11 +140,11 @@ export class RmqService implements OnModuleInit, OnModuleDestroy {
     if (!this.options.queue || !this.rmqMessageTegs?.size)
       return this.logger.warn(
         this.options.targetModuleName,
-        INOF_NOT_FULL_OPTIONS
+        INOF_NOT_FULL_OPTIONS,
       );
     const queue = await this.rmqNestjsConnectService.assertQueue(
       TypeQueue.QUEUE,
-      this.options.queue
+      this.options.queue,
     );
     this.rmqMessageTegs.forEach(async (_, key) => {
       await this.rmqNestjsConnectService.bindQueue({
@@ -160,24 +155,24 @@ export class RmqService implements OnModuleInit, OnModuleDestroy {
     });
     await this.rmqNestjsConnectService.listenQueue(
       this.options.queue.queue,
-      this.listenQueue.bind(this)
+      this.listenQueue.bind(this),
     );
   }
 
   private async assertReplyQueueBind() {
     this.replyToQueue = await this.rmqNestjsConnectService.assertQueue(
       TypeQueue.REPLY_QUEUE,
-      { queue: '', options: this.options.replyTo }
+      { queue: '', options: this.options.replyTo },
     );
     await this.rmqNestjsConnectService.listenReplyQueue(
       this.replyToQueue.queue,
-      this.listenReplyQueue.bind(this)
+      this.listenReplyQueue.bind(this),
     );
   }
   private async initializationCheck() {
     if (this.isInitialized) return;
     await new Promise<void>((resolve) =>
-      setTimeout(resolve, INITIALIZATION_STEP_DELAY)
+      setTimeout(resolve, INITIALIZATION_STEP_DELAY),
     );
     await this.initializationCheck();
   }

diff --git a/tsconfig.json b/tsconfig.json
@@ -19,15 +19,15 @@
     "noFallthroughCasesInSwitch": false,
     "paths": {
       "rmq-nestjs/rmq-nestjs": [
-        "lib/rmq-nestjs/src"
+        "lib/"
       ],
       "rmq-nestjs/rmq-nestjs/*": [
-        "lib/rmq-nestjs/src/*"
+        "lib/*"
       ]
     }
   },
   "include": [
-    "src/**/*.ts",
+    "lib/**/*.ts",
     "test/**/*.ts"
   ],
   "exclude": [