Update connection options

taskvalve · Dec 4, 2023 · e652efa · e652efa
1 parent 6cb7db5
commit e652efa
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 5 deletions.
diff --git a/README.md b/README.md
@@ -3,14 +3,14 @@
 ## Setup
 
 ```typescript
-import * as taskvalve from "https://deno.land/x/taskvalve@1.0.4/mod.ts"
+import * as taskvalve from "https://deno.land/x/taskvalve@1.0.5/mod.ts"
 import { load } from "https://deno.land/std@0.204.0/dotenv/mod.ts"
 
 const env = await load()
 
 const crypto = new taskvalve.DefaultCrypto(env['APP_NAME'], env['APP_KEY'])
 const model = new taskvalve.model.MySQL(crypto, env['DB_HOST'], env['DB_PORT'], env['DB_NAME'], env['DB_USER'], env['DB_PASS'])
-const queue = new taskvalve.queue.Redis(crypto, model, env['REDIS_HOST'], env['REDIS_PORT'])
+const queue = new taskvalve.queue.Redis(crypto, model, env['REDIS_HOST'], env['REDIS_PORT'], env['REDIS_USER'], env['REDIS_PASS'])
 
 const workflow = new taskvalve.WorkflowStub(queue)
 ```
@@ -49,12 +49,12 @@ const queue = new taskvalve.queue.PostgreSQL(crypto, model, env['DB_HOST'], env[
 
 ```typescript
 const model = new taskvalve.model.MySQL(crypto, env['DB_HOST'], env['DB_PORT'], env['DB_NAME'], env['DB_USER'], env['DB_PASS'])
-const queue = new taskvalve.queue.Redis(crypto, model, env['REDIS_HOST'], env['REDIS_PORT'])
+const queue = new taskvalve.queue.Redis(crypto, model, env['REDIS_HOST'], env['REDIS_PORT'], env['REDIS_USER'], env['REDIS_PASS'])
 ```
 
 ## PostgreSQL
 
 ```typescript
 const model = new taskvalve.model.PostgreSQL(crypto, env['DB_HOST'], env['DB_PORT'], env['DB_NAME'], env['DB_USER'], env['DB_PASS'])
-const queue = new taskvalve.queue.Redis(crypto, model, env['REDIS_HOST'], env['REDIS_PORT'])
+const queue = new taskvalve.queue.Redis(crypto, model, env['REDIS_HOST'], env['REDIS_PORT'], env['REDIS_USER'], env['REDIS_PASS'])
 ```
diff --git a/queue/redis.ts b/queue/redis.ts
@@ -15,6 +15,8 @@ export class Redis implements IQueue {
         private model: IModel,
         private hostname: string = 'redis',
         private port: number = 6379,
+        private username?: string,
+        private password?: string,
         public connection: string = 'redis',
         public queue: string = 'default'
     ) {}
@@ -30,7 +32,9 @@ export class Redis implements IQueue {
 
         const redis = await connect({
             hostname: this.hostname,
-            port: this.port
+            port: this.port,
+            username: this.username,
+            password: this.password
         })
 
         const { iv, data, mac } = await this.crypto.encrypt(command({