chore: Update package name and version; enhance RedisChannelConfig connection options

Author: kastov

package.json

@@ -1,6 +1,6 @@
 {
-  "name": "@nestjstools/messaging-redis-extension",
-  "version": "1.2.2",
+  "name": "@kastov/messaging-redis-extension",
+  "version": "1.3.0",
   "description": "Extension to handle messages and dispatch them over Redis",
   "author": "Sebastian Iwanczyszyn",
   "private": false,
@@ -106,4 +106,4 @@
     "coverageDirectory": "../coverage",
     "testEnvironment": "node"
   }
-}
+}

src/channel/redis.channel-config.ts

@@ -38,8 +38,14 @@ export class RedisChannelConfig extends ChannelConfig {
 }
 
 interface Connection {
-  host: string;
-  port: number;
+  connectionOpts:
+    | {
+        host: string;
+        port: number;
+      }
+    | {
+        path: string;
+      };
   password?: string;
   db?: number;
 }

src/channel/redis.channel-factory.ts

@@ -5,9 +5,7 @@ import { RedisChannelConfig } from './redis.channel-config';
 
 @Injectable()
 @ChannelFactory(RedisChannelConfig)
-export class RedisChannelFactory
-  implements IChannelFactory<RedisChannelConfig>
-{
+export class RedisChannelFactory implements IChannelFactory<RedisChannelConfig> {
   create(channelConfig: RedisChannelConfig): RedisChannel {
     return new RedisChannel(channelConfig);
   }

src/channel/redis.channel.ts

@@ -9,7 +9,11 @@ export class RedisChannel extends Channel<RedisChannelConfig> {
   constructor(config: RedisChannelConfig) {
     super(config);
     this.queue = new Queue(config.queue, {
-      connection: this.config.connection,
+      connection: {
+        ...this.config.connection.connectionOpts,
+        password: this.config.connection.password,
+        db: this.config.connection.db,
+      },
       prefix: config.keyPrefix,
       defaultJobOptions: {
         removeOnComplete: config.bullJobOptions?.removeOnComplete,