Merge pull request #202 from upstash/feature/scheduleToQueue

DX-1384 Schedule to queues

src/client/schedules.test.ts

@@ -1,4 +1,3 @@
-/* eslint-disable @typescript-eslint/no-magic-numbers */
 /* eslint-disable @typescript-eslint/no-non-null-assertion */
 import { afterEach, describe, expect, test } from "bun:test";
 import { Client } from "./client";
@@ -32,6 +31,7 @@ describe("Schedules", () => {
         failureCallback: "https://example.com/failure",
         delay: 10,
         retries: 5,
+        queueName: "scheduleQueue",
         cron: "*/10 * * * * ",
       });
 
@@ -51,6 +51,7 @@ describe("Schedules", () => {
           delay: 10,
           callback: "https://example.com",
           failureCallback: "https://example.com/failure",
+          queueName: "scheduleQueue",
         }) as Schedule
       );
 

src/client/schedules.ts

@@ -18,6 +18,7 @@ export type Schedule = {
   failureCallback?: string;
   callerIp?: string;
   isPaused: boolean;
+  queueName?: string;
 };
 
 export type CreateScheduleRequest = {
@@ -108,11 +109,16 @@ export type CreateScheduleRequest = {
   /**
    * Schedule id to use.
    *
-   * Can be used to updatine the settings of an existing schedule.
+   * Can be used to update the settings of an existing schedule.
    *
    * @default undefined
    */
   scheduleId?: string;
+
+  /**
+   * Queue name to schedule the message over.
+   */
+  queueName?: string;
 };
 
 export class Schedules {
@@ -177,6 +183,10 @@ export class Schedules {
       headers.set("Upstash-Schedule-Id", request.scheduleId);
     }
 
+    if (request.queueName !== undefined) {
+      headers.set("Upstash-Queue-Name", request.queueName);
+    }
+
     return await this.http.request({
       method: "POST",
       headers,