Merge remote-tracking branch 'origin/main'

# Conflicts:
#	package.json
#	src/consumer/redis-messaging.consumer.ts

Author: Sebastian-Iwanczyszyn

.github/workflows/ci.yaml

@@ -0,0 +1,31 @@
+name: Check CI
+
+on:
+  pull_request:
+    types: [opened, edited, synchronize]
+
+permissions:
+  pull-requests: read
+  contents: read
+
+jobs:
+  ci:
+    runs-on: ubuntu-latest
+
+    steps:
+      - name: Checkout code
+        uses: actions/checkout@v4
+
+      - name: Use Node.js
+        uses: actions/setup-node@v4
+        with:
+          node-version: 23
+
+      - name: Install dependencies
+        run: yarn
+
+      - name: Build project
+        run: yarn build
+
+      - name: Run CI
+        run: yarn ci

.gitignore

@@ -4,6 +4,8 @@
 /node_modules
 /build
 
+yarn.lock
+package-lock.json
 # Logs
 logs
 *.log

package.json

@@ -35,22 +35,22 @@
   ],
   "scripts": {
     "build": "nest build",
-    "format": "prettier --write \"src/**/*.ts\" \"test/**/*.ts\"",
+    "prettier": "prettier --check \"src/**/*.ts\"",
+    "prettier:fix": "prettier --write \"src/**/*.ts\"",
     "start": "nest start",
     "start:dev": "nest start --watch",
     "start:debug": "nest start --debug --watch",
     "start:prod": "node dist/main",
     "lint": "eslint \"{src,apps,libs,test}/**/*.ts\" --fix",
+    "ci": "yarn prettier",
     "test": "jest",
     "test:watch": "jest --watch",
     "test:cov": "jest --coverage",
     "test:debug": "node --inspect-brk -r tsconfig-paths/register -r ts-node/register node_modules/.bin/jest --runInBand",
     "test:e2e": "jest --config ./test/jest-e2e.json"
   },
   "dependencies": {
-    "@semantic-release/github": "^11.0.3",
-    "bullmq": "^5.52.2",
-    "semantic-release": "^24.2.5"
+    "bullmq": "^5.52.2"
   },
   "peerDependencies": {
     "@nestjs/common": "^10.x||^11.x",
@@ -60,11 +60,15 @@
     "rxjs": "^7.x"
   },
   "devDependencies": {
+    "reflect-metadata": "^0.2.0",
+    "rxjs": "^7.x",
+    "@nestjs/common": "^10.0.0",
+    "@nestjs/core": "^10.0.0",
+    "semantic-release": "^24.2.5",
+    "@semantic-release/github": "^11.0.3",
     "@nestjs/cli": "^10.0.0",
     "@nestjs/schematics": "^10.0.0",
     "@nestjs/testing": "^10.0.0",
-    "@nestjs/core": "^10.0.0",
-    "@nestjs/common": "^10.0.0",
     "@nestjstools/messaging": "^3.0.0",
     "@types/express": "^5.0.0",
     "@types/jest": "^29.5.2",

src/channel/redis.channel-config.ts

@@ -3,6 +3,11 @@ import { ChannelConfig } from '@nestjstools/messaging';
 export class RedisChannelConfig extends ChannelConfig {
   public readonly connection: Connection;
   public readonly queue: string;
+  /**
+   * @description
+   * This prefix is not used as RedisOptions keyPrefix, it is used as prefix for BullMQ
+   * Read more: https://github.com/taskforcesh/bullmq/issues/1219#issuecomment-1113903785
+   */
   public readonly keyPrefix?: string;
 
   constructor({

src/consumer/redis-messaging.consumer.ts

@@ -38,6 +38,8 @@ export class RedisMessagingConsumer
     errored: ConsumerDispatchedMessageError,
     channel: RedisChannel,
   ): Promise<void> {
+    void errored;
+    void channel;
     return Promise.resolve();
   }
 

src/message-bus/redis-message.bus.ts

@@ -8,6 +8,9 @@ export class RedisMessageBus implements IMessageBus {
   constructor(private readonly redisChannel: RedisChannel) {}
 
   async dispatch(message: RoutingMessage): Promise<void> {
-    await this.redisChannel.queue.add(message.messageRoutingKey, message.message);
+    await this.redisChannel.queue.add(
+      message.messageRoutingKey,
+      message.message,
+    );
   }
 }

test/app.e2e-spec.ts

@@ -2,7 +2,7 @@
   "compilerOptions": {
     "module": "commonjs",
     "declaration": true,
-    "removeComments": true,
+    "removeComments": false,
     "emitDecoratorMetadata": true,
     "experimentalDecorators": true,
     "allowSyntheticDefaultImports": true,