@upstash/qstash - npm Package Compare versions

Comparing version 2.1.2 to 2.1.3

./dist/index.js

@@ -181,7 +181,24 @@ "use strict";Object.defineProperty(exports, "__esModule", {value: true});
     return _chunkEQTYEU4Ujs.__async.call(void 0, this, null, function* () {
+      const headers = new Headers(req.headers);
+      if (!headers.has("Content-Type")) {
+        headers.set("Content-Type", "application/json");
+      }
+      headers.set("Upstash-Cron", req.cron);
+      if (typeof req.method !== "undefined") {
+        headers.set("Upstash-Method", req.method);
+      }
+      if (typeof req.delay !== "undefined") {
+        headers.set("Upstash-Delay", `${req.delay.toFixed()}s`);
+      }
+      if (typeof req.retries !== "undefined") {
+        headers.set("Upstash-Retries", req.retries.toFixed());
+      }
+      if (typeof req.callback !== "undefined") {
+        headers.set("Upstash-Callback", req.callback);
+      }
       return yield this.http.request({
         method: "POST",
-        headers: { "Content-Type": "application/json" },
-        path: ["v2", "schedules"],
-        body: JSON.stringify(req)
+        headers,
+        path: ["v2", "schedules", req.destination],
+        body: req.body
       });
@@ -188,0 +205,0 @@ });

dist/index.d.ts

@@ -297,5 +297,3 @@ /**
     /**
-     * Optionally specify a cron expression to repeatedly send this message to the destination.
-     *
-     * @default undefined
+     * Specify a cron expression to repeatedly send this message to the destination.
      */
@@ -302,0 +300,0 @@ cron: string;

dist/index.js

@@ -181,7 +181,24 @@ "use strict";Object.defineProperty(exports, "__esModule", {value: true});
     return _chunkEQTYEU4Ujs.__async.call(void 0, this, null, function* () {
+      const headers = new Headers(req.headers);
+      if (!headers.has("Content-Type")) {
+        headers.set("Content-Type", "application/json");
+      }
+      headers.set("Upstash-Cron", req.cron);
+      if (typeof req.method !== "undefined") {
+        headers.set("Upstash-Method", req.method);
+      }
+      if (typeof req.delay !== "undefined") {
+        headers.set("Upstash-Delay", `${req.delay.toFixed()}s`);
+      }
+      if (typeof req.retries !== "undefined") {
+        headers.set("Upstash-Retries", req.retries.toFixed());
+      }
+      if (typeof req.callback !== "undefined") {
+        headers.set("Upstash-Callback", req.callback);
+      }
       return yield this.http.request({
         method: "POST",
-        headers: { "Content-Type": "application/json" },
-        path: ["v2", "schedules"],
-        body: JSON.stringify(req)
+        headers,
+        path: ["v2", "schedules", req.destination],
+        body: req.body
       });
@@ -188,0 +205,0 @@ });

package.json

 {
   "name": "@upstash/qstash",
-  "version": "2.1.2",
+  "version": "2.1.3",
   "description": "Official Typescript client for QStash",
@@ -5,0 +5,0 @@ "repository": {

No alert changes

Improved metrics

Total package byte prevSize

162861

increased by2.44%

Lines of code

2193

increased by2.29%

No dependency changes