@upstash/qstash - npm Package Compare versions

Comparing version 2.0.0-canary.18 to 2.0.0-canary.19

./dist/index.js

@@ -97,5 +97,3 @@ "use strict";Object.defineProperty(exports, "__esModule", {value: true}); function _interopRequireWildcard(obj) { if (obj && obj.__esModule) { return obj; } else { var newObj = {}; if (obj != null) { for (var key in obj) { if (Object.prototype.hasOwnProperty.call(obj, key)) { newObj[key] = obj[key]; } } } newObj.default = obj; return newObj; } }var __defProp = Object.defineProperty;
       if (p.body.replace(padding, "") !== bodyHash.replace(padding, "")) {
-        throw new SignatureError(
-          `body hash does not match, want: ${p.body}, got: ${bodyHash}`
-        );
+        throw new SignatureError(`body hash does not match, want: ${p.body}, got: ${bodyHash}`);
       }
@@ -439,3 +437,3 @@ return true;
 var _server = require('next/server');
-function verifyNextjsServerlessSignature(handler, config) {
+function verifySignature(handler, config) {
   var _a, _b;
@@ -509,3 +507,3 @@ const currentSigningKey = (_a = config == null ? void 0 : config.currentSigningKey) != null ? _a : process.env.QSTASH_CURRENT_SIGNING_KEY;
 }
-function verifyNextjsEdgeSignature(handler, config) {
+function verifySignatureEdge(handler, config) {
   var _a, _b;
@@ -529,5 +527,8 @@ const currentSigningKey = (_a = config == null ? void 0 : config.currentSigningKey) != null ? _a : process.env.QSTASH_CURRENT_SIGNING_KEY;
   return (req, nfe) => __async(this, null, function* () {
+    const reqClone = req.clone();
     const signature = req.headers.get("upstash-signature");
     if (!signature) {
-      return new (0, _server.NextResponse)(new TextEncoder().encode("`Upstash-Signature` header is missing"), { status: 403 });
+      return new (0, _server.NextResponse)(new TextEncoder().encode("`Upstash-Signature` header is missing"), {
+        status: 403
+      });
     }
@@ -556,4 +557,3 @@ if (typeof signature !== "string") {
     }
-    const copy = new (0, _server.NextRequest)(__spreadProps(__spreadValues({}, req), { body: parsedBody }));
-    return handler(copy, nfe);
+    return handler(reqClone, nfe);
   });
@@ -571,3 +571,3 @@ }
 
-exports.Client = Client; exports.Messages = Messages; exports.QstashError = QstashError; exports.Receiver = Receiver; exports.Schedules = Schedules; exports.SignatureError = SignatureError; exports.Topics = Topics; exports.verifyNextjsEdgeSignature = verifyNextjsEdgeSignature; exports.verifyNextjsServerlessSignature = verifyNextjsServerlessSignature;
+exports.Client = Client; exports.Messages = Messages; exports.QstashError = QstashError; exports.Receiver = Receiver; exports.Schedules = Schedules; exports.SignatureError = SignatureError; exports.Topics = Topics; exports.verifySignature = verifySignature; exports.verifySignatureEdge = verifySignatureEdge;
 //# sourceMappingURL=index.js.map

dist/index.d.ts

@@ -505,5 +505,5 @@ import { NextApiHandler } from 'next';
 };
-declare function verifyNextjsServerlessSignature(handler: NextApiHandler, config?: VerifySignaturConfig): NextApiHandler;
-declare function verifyNextjsEdgeSignature(handler: (req: NextRequest, nfe: NextFetchEvent) => NextResponse | Promise<NextResponse>, config?: VerifySignaturConfig): (req: NextRequest, nfe: NextFetchEvent) => Promise<NextResponse<unknown>>;
+declare function verifySignature(handler: NextApiHandler, config?: VerifySignaturConfig): NextApiHandler;
+declare function verifySignatureEdge(handler: (req: NextRequest, nfe: NextFetchEvent) => NextResponse | Promise<NextResponse>, config?: VerifySignaturConfig): (req: NextRequest, nfe: NextFetchEvent) => Promise<NextResponse<unknown>>;
 
-export { AddEndpointsRequest, Client, CreateScheduleRequest, Endpoint, Event, EventsRequest, GetEventsResponse, Messages, PublishJsonRequest, PublishRequest, QstashError, Receiver, ReceiverConfig, RemoveEndpointsRequest, Schedule, Schedules, SignatureError, State, Topic, Topics, VerifyRequest, VerifySignaturConfig, WithCursor, verifyNextjsEdgeSignature, verifyNextjsServerlessSignature };
+export { AddEndpointsRequest, Client, CreateScheduleRequest, Endpoint, Event, EventsRequest, GetEventsResponse, Messages, PublishJsonRequest, PublishRequest, QstashError, Receiver, ReceiverConfig, RemoveEndpointsRequest, Schedule, Schedules, SignatureError, State, Topic, Topics, VerifyRequest, VerifySignaturConfig, WithCursor, verifySignature, verifySignatureEdge };

dist/index.js

@@ -97,5 +97,3 @@ "use strict";Object.defineProperty(exports, "__esModule", {value: true}); function _interopRequireWildcard(obj) { if (obj && obj.__esModule) { return obj; } else { var newObj = {}; if (obj != null) { for (var key in obj) { if (Object.prototype.hasOwnProperty.call(obj, key)) { newObj[key] = obj[key]; } } } newObj.default = obj; return newObj; } }var __defProp = Object.defineProperty;
       if (p.body.replace(padding, "") !== bodyHash.replace(padding, "")) {
-        throw new SignatureError(
-          `body hash does not match, want: ${p.body}, got: ${bodyHash}`
-        );
+        throw new SignatureError(`body hash does not match, want: ${p.body}, got: ${bodyHash}`);
       }
@@ -439,3 +437,3 @@ return true;
 var _server = require('next/server');
-function verifyNextjsServerlessSignature(handler, config) {
+function verifySignature(handler, config) {
   var _a, _b;
@@ -509,3 +507,3 @@ const currentSigningKey = (_a = config == null ? void 0 : config.currentSigningKey) != null ? _a : process.env.QSTASH_CURRENT_SIGNING_KEY;
 }
-function verifyNextjsEdgeSignature(handler, config) {
+function verifySignatureEdge(handler, config) {
   var _a, _b;
@@ -529,5 +527,8 @@ const currentSigningKey = (_a = config == null ? void 0 : config.currentSigningKey) != null ? _a : process.env.QSTASH_CURRENT_SIGNING_KEY;
   return (req, nfe) => __async(this, null, function* () {
+    const reqClone = req.clone();
     const signature = req.headers.get("upstash-signature");
     if (!signature) {
-      return new (0, _server.NextResponse)(new TextEncoder().encode("`Upstash-Signature` header is missing"), { status: 403 });
+      return new (0, _server.NextResponse)(new TextEncoder().encode("`Upstash-Signature` header is missing"), {
+        status: 403
+      });
     }
@@ -556,4 +557,3 @@ if (typeof signature !== "string") {
     }
-    const copy = new (0, _server.NextRequest)(__spreadProps(__spreadValues({}, req), { body: parsedBody }));
-    return handler(copy, nfe);
+    return handler(reqClone, nfe);
   });
@@ -571,3 +571,3 @@ }
 
-exports.Client = Client; exports.Messages = Messages; exports.QstashError = QstashError; exports.Receiver = Receiver; exports.Schedules = Schedules; exports.SignatureError = SignatureError; exports.Topics = Topics; exports.verifyNextjsEdgeSignature = verifyNextjsEdgeSignature; exports.verifyNextjsServerlessSignature = verifyNextjsServerlessSignature;
+exports.Client = Client; exports.Messages = Messages; exports.QstashError = QstashError; exports.Receiver = Receiver; exports.Schedules = Schedules; exports.SignatureError = SignatureError; exports.Topics = Topics; exports.verifySignature = verifySignature; exports.verifySignatureEdge = verifySignatureEdge;
 //# sourceMappingURL=index.js.map

package.json

 {
   "name": "@upstash/qstash",
-  "version": "2.0.0-canary.18",
+  "version": "2.0.0-canary.19",
   "description": "Official Typescript client for QStash",
@@ -42,4 +42,4 @@ "repository": {
     "build": "tsup",
-    "fmt": "pnpm rome check . --apply-suggested && pnpm rome format . --write"
+    "fmt": "pnpm rome check . --apply-unsafe && pnpm rome format . --write"
   }
 }

No alert changes

Worsened metrics

Total package byte prevSize

152980

decreased by-0.51%

No dependency changes