@upstash/qstash
Advanced tools
Comparing version 2.1.11-canary to 2.1.11
@@ -7,3 +7,3 @@ "use strict";Object.defineProperty(exports, "__esModule", {value: true}); | ||
var _chunkEQTYEU4Ujs = require('./chunk-EQTYEU4U.js'); | ||
var _chunkEROSIHWEjs = require('./chunk-EROSIHWE.js'); | ||
@@ -19,3 +19,3 @@ // src/client/dlq.ts | ||
listMessages(opts) { | ||
return _chunkEQTYEU4Ujs.__async.call(void 0, this, null, function* () { | ||
return _chunkEROSIHWEjs.__async.call(void 0, this, null, function* () { | ||
return yield this.http.request({ | ||
@@ -32,3 +32,3 @@ method: "GET", | ||
delete(dlqMessageId) { | ||
return _chunkEQTYEU4Ujs.__async.call(void 0, this, null, function* () { | ||
return _chunkEROSIHWEjs.__async.call(void 0, this, null, function* () { | ||
return yield this.http.request({ | ||
@@ -76,3 +76,3 @@ method: "DELETE", | ||
request(req) { | ||
return _chunkEQTYEU4Ujs.__async.call(void 0, this, null, function* () { | ||
return _chunkEROSIHWEjs.__async.call(void 0, this, null, function* () { | ||
var _a; | ||
@@ -138,3 +138,3 @@ const headers = new Headers(req.headers); | ||
get(messageId) { | ||
return _chunkEQTYEU4Ujs.__async.call(void 0, this, null, function* () { | ||
return _chunkEROSIHWEjs.__async.call(void 0, this, null, function* () { | ||
return yield this.http.request({ | ||
@@ -150,3 +150,3 @@ method: "GET", | ||
delete(messageId) { | ||
return _chunkEQTYEU4Ujs.__async.call(void 0, this, null, function* () { | ||
return _chunkEROSIHWEjs.__async.call(void 0, this, null, function* () { | ||
return yield this.http.request({ | ||
@@ -170,3 +170,3 @@ method: "DELETE", | ||
create(req) { | ||
return _chunkEQTYEU4Ujs.__async.call(void 0, this, null, function* () { | ||
return _chunkEROSIHWEjs.__async.call(void 0, this, null, function* () { | ||
const headers = new Headers(req.headers); | ||
@@ -204,3 +204,3 @@ if (!headers.has("Content-Type")) { | ||
get(scheduleId) { | ||
return _chunkEQTYEU4Ujs.__async.call(void 0, this, null, function* () { | ||
return _chunkEROSIHWEjs.__async.call(void 0, this, null, function* () { | ||
return yield this.http.request({ | ||
@@ -216,3 +216,3 @@ method: "GET", | ||
list() { | ||
return _chunkEQTYEU4Ujs.__async.call(void 0, this, null, function* () { | ||
return _chunkEROSIHWEjs.__async.call(void 0, this, null, function* () { | ||
return yield this.http.request({ | ||
@@ -228,3 +228,3 @@ method: "GET", | ||
delete(scheduleId) { | ||
return _chunkEQTYEU4Ujs.__async.call(void 0, this, null, function* () { | ||
return _chunkEROSIHWEjs.__async.call(void 0, this, null, function* () { | ||
return yield this.http.request({ | ||
@@ -248,3 +248,3 @@ method: "DELETE", | ||
addEndpoints(req) { | ||
return _chunkEQTYEU4Ujs.__async.call(void 0, this, null, function* () { | ||
return _chunkEROSIHWEjs.__async.call(void 0, this, null, function* () { | ||
yield this.http.request({ | ||
@@ -263,3 +263,3 @@ method: "POST", | ||
removeEndpoints(req) { | ||
return _chunkEQTYEU4Ujs.__async.call(void 0, this, null, function* () { | ||
return _chunkEROSIHWEjs.__async.call(void 0, this, null, function* () { | ||
yield this.http.request({ | ||
@@ -278,3 +278,3 @@ method: "DELETE", | ||
list() { | ||
return _chunkEQTYEU4Ujs.__async.call(void 0, this, null, function* () { | ||
return _chunkEROSIHWEjs.__async.call(void 0, this, null, function* () { | ||
return yield this.http.request({ | ||
@@ -290,3 +290,3 @@ method: "GET", | ||
get(name) { | ||
return _chunkEQTYEU4Ujs.__async.call(void 0, this, null, function* () { | ||
return _chunkEROSIHWEjs.__async.call(void 0, this, null, function* () { | ||
return yield this.http.request({ | ||
@@ -302,3 +302,3 @@ method: "GET", | ||
delete(name) { | ||
return _chunkEQTYEU4Ujs.__async.call(void 0, this, null, function* () { | ||
return _chunkEROSIHWEjs.__async.call(void 0, this, null, function* () { | ||
return yield this.http.request({ | ||
@@ -355,3 +355,3 @@ method: "DELETE", | ||
publish(req) { | ||
return _chunkEQTYEU4Ujs.__async.call(void 0, this, null, function* () { | ||
return _chunkEROSIHWEjs.__async.call(void 0, this, null, function* () { | ||
var _a, _b; | ||
@@ -395,6 +395,6 @@ const headers = new Headers(req.headers); | ||
publishJSON(req) { | ||
return _chunkEQTYEU4Ujs.__async.call(void 0, this, null, function* () { | ||
return _chunkEROSIHWEjs.__async.call(void 0, this, null, function* () { | ||
const headers = new Headers(req.headers); | ||
headers.set("Content-Type", "application/json"); | ||
const res = yield this.publish(_chunkEQTYEU4Ujs.__spreadProps.call(void 0, _chunkEQTYEU4Ujs.__spreadValues.call(void 0, {}, req), { | ||
const res = yield this.publish(_chunkEROSIHWEjs.__spreadProps.call(void 0, _chunkEROSIHWEjs.__spreadValues.call(void 0, {}, req), { | ||
headers, | ||
@@ -426,3 +426,3 @@ body: JSON.stringify(req.body) | ||
events(req) { | ||
return _chunkEQTYEU4Ujs.__async.call(void 0, this, null, function* () { | ||
return _chunkEROSIHWEjs.__async.call(void 0, this, null, function* () { | ||
const query = {}; | ||
@@ -450,3 +450,2 @@ if ((req == null ? void 0 : req.cursor) && req.cursor > 0) { | ||
exports.Client = Client; exports.Messages = Messages; exports.QstashError = QstashError; exports.QstashRatelimitError = QstashRatelimitError; exports.Receiver = _chunkEQTYEU4Ujs.Receiver; exports.Schedules = Schedules; exports.SignatureError = _chunkEQTYEU4Ujs.SignatureError; exports.Topics = Topics; | ||
//# sourceMappingURL=index.js.map | ||
exports.Client = Client; exports.Messages = Messages; exports.QstashError = QstashError; exports.QstashRatelimitError = QstashRatelimitError; exports.Receiver = _chunkEROSIHWEjs.Receiver; exports.Schedules = Schedules; exports.SignatureError = _chunkEROSIHWEjs.SignatureError; exports.Topics = Topics; |
@@ -5,3 +5,3 @@ "use strict";Object.defineProperty(exports, "__esModule", {value: true}); | ||
var _chunkEQTYEU4Ujs = require('./chunk-EQTYEU4U.js'); | ||
var _chunkEROSIHWEjs = require('./chunk-EROSIHWE.js'); | ||
@@ -24,7 +24,7 @@ // src/nextjs.ts | ||
} | ||
const receiver = new (0, _chunkEQTYEU4Ujs.Receiver)({ | ||
const receiver = new (0, _chunkEROSIHWEjs.Receiver)({ | ||
currentSigningKey, | ||
nextSigningKey | ||
}); | ||
return (req, res) => _chunkEQTYEU4Ujs.__async.call(void 0, this, null, function* () { | ||
return (req, res) => _chunkEROSIHWEjs.__async.call(void 0, this, null, function* () { | ||
const signature = req.headers["upstash-signature"]; | ||
@@ -42,3 +42,3 @@ if (!signature) { | ||
try { | ||
for (var iter = _chunkEQTYEU4Ujs.__forAwait.call(void 0, req), more, temp, error; more = !(temp = yield iter.next()).done; more = false) { | ||
for (var iter = _chunkEROSIHWEjs.__forAwait.call(void 0, req), more, temp, error; more = !(temp = yield iter.next()).done; more = false) { | ||
const chunk = temp.value; | ||
@@ -95,7 +95,7 @@ chunks.push(typeof chunk === "string" ? Buffer.from(chunk) : chunk); | ||
} | ||
const receiver = new (0, _chunkEQTYEU4Ujs.Receiver)({ | ||
const receiver = new (0, _chunkEROSIHWEjs.Receiver)({ | ||
currentSigningKey, | ||
nextSigningKey | ||
}); | ||
return (req, nfe) => _chunkEQTYEU4Ujs.__async.call(void 0, this, null, function* () { | ||
return (req, nfe) => _chunkEROSIHWEjs.__async.call(void 0, this, null, function* () { | ||
const reqClone = req.clone(); | ||
@@ -137,2 +137,1 @@ const signature = req.headers.get("upstash-signature"); | ||
exports.verifySignature = verifySignature; exports.verifySignatureEdge = verifySignatureEdge; | ||
//# sourceMappingURL=nextjs.js.map |
{ | ||
"name": "@upstash/qstash", | ||
"version": "v2.1.11-canary", | ||
"version": "v2.1.11", | ||
"description": "Official Typescript client for QStash", | ||
@@ -5,0 +5,0 @@ "repository": { |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Manifest confusion
Supply chain riskThis package has inconsistent metadata. This could be malicious or caused by an error when publishing the package.
Found 1 instance in 1 package
Manifest confusion
Supply chain riskThis package has inconsistent metadata. This could be malicious or caused by an error when publishing the package.
Found 1 instance in 1 package
No v1
QualityPackage is not semver >=1. This means it is not stable and does not support ^ ranges.
Found 1 instance in 1 package
0
78774
13