fix(queue): use QueueOptions type in opts attribute

taskforcesh · Mar 21, 2024 · cfa1e55 · cfa1e55
1 parent a73cf32
commit cfa1e55
Showing 1 changed file with 8 additions and 5 deletions.
diff --git a/src/classes/queue.ts b/src/classes/queue.ts
@@ -95,6 +95,7 @@ export class Queue<
 > extends QueueGetters<DataType, ResultType, NameType> {
   token = v4();
   jobsOpts: BaseJobOptions;
+  opts: QueueOptions;
   private _repeat?: Repeat;
 
   constructor(
@@ -116,11 +117,7 @@ export class Queue<
     this.waitUntilReady()
       .then(client => {
         if (!this.closing) {
-          client.hset(
-            this.keys.meta,
-            'opts.maxLenEvents',
-            opts?.streams?.events?.maxLen ?? 10000,
-          );
+          client.hmset(this.keys.meta, this.metaValues);
         }
       })
       .catch(err => {
@@ -167,6 +164,12 @@ export class Queue<
     return { ...this.jobsOpts };
   }
 
+  get metaValues(): Record<string, string | number> {
+    return {
+      'opts.maxLenEvents': this.opts?.streams?.events?.maxLen ?? 10000,
+    };
+  }
+
   get repeat(): Promise<Repeat> {
     return new Promise<Repeat>(async resolve => {
       if (!this._repeat) {