Make task args optional

Author: alanhamlett

src/childWorker.ts

@@ -115,7 +115,7 @@ export class WakaQChildWorker {
     }
   }
 
-  private async _executeTask(task: Task, variables: unknown, queue?: WakaQueue) {
+  private async _executeTask(task: Task, variables?: unknown, queue?: WakaQueue) {
     this._sendPingToParent(task.name, queue?.name);
     this.logger.debug(`running with args ${variables}`);
     if (this.wakaq.beforeTaskStartedCallback) await this.wakaq.beforeTaskStartedCallback(task);

src/task.ts

@@ -14,7 +14,7 @@ export class Task<TData = unknown> {
 
   constructor(
     wakaq: WakaQ,
-    fn: (variables: TData) => Promise<void>,
+    fn: (variables?: TData) => Promise<void>,
     name?: string,
     queue?: WakaQueue | string,
     softTimeout?: Duration,
@@ -42,16 +42,16 @@ export class Task<TData = unknown> {
   /*
   Run task in the background.
   */
-  public async enqueue(variables: TData) {
+  public async enqueue(variables?: TData) {
     return await this.wakaq.enqueueAtEnd(this.name, variables, this.queue);
   }
 
   /*
   Run task in the background after eta.
   */
-  public async enqueueAfterDelay(eta: Duration | Date | number, ...args: any[]) {
+  public async enqueueAfterDelay(eta: Duration | Date | number, variables?: TData) {
     const etaVerified = typeof eta === 'number' ? Duration.second(eta) : eta;
-    return await this.wakaq.enqueueWithEta(this.name, args, etaVerified, this.queue);
+    return await this.wakaq.enqueueWithEta(this.name, variables, etaVerified, this.queue);
   }
 
   /*
@@ -60,7 +60,7 @@ export class Task<TData = unknown> {
   Only runs the task once per worker parent daemon, no matter the worker's concurrency.
   Returns the number of workers the task was sent to.
   */
-  public async broadcast(...args: any[]): Promise<number> {
-    return await this.wakaq.broadcast(this.name, args);
+  public async broadcast(variables?: TData): Promise<number> {
+    return await this.wakaq.broadcast(this.name, variables);
   }
 }

src/wakaq.ts

@@ -215,7 +215,7 @@ export class WakaQ {
   Returns the new Task with methods enqueue(), enqueueAfterDelay,
   and broadcast().
   */
-  public task<TData = unknown>(fn: (variables: TData) => Promise<void>, params?: RegisterTaskParams): Task<TData> {
+  public task<TData = unknown>(fn: (variables?: TData) => Promise<void>, params?: RegisterTaskParams): Task<TData> {
     const task = new Task(this, fn, params?.name, params?.queue, params?.softTimeout, params?.hardTimeout, params?.maxRetries);
     if (this.tasks.has(task.name)) {
       this.logger?.error(`Duplicate task name: ${task.name}`);

src/worker.ts

@@ -291,7 +291,7 @@ export class WakaQWorker {
     }
   }
 
-  private async _executeTask(task: Task, variables: unknown, queue?: WakaQueue) {
+  private async _executeTask(task: Task, variables?: unknown, queue?: WakaQueue) {
     this.logger.debug(`running with args ${variables}`);
     if (this.wakaq.beforeTaskStartedCallback) this.wakaq.beforeTaskStartedCallback(task);
     try {