New Case Study:See how Anthropic automated 95% of dependency reviews with Socket.Learn More
Socket
Sign inDemoInstall
Socket

@upstash/qstash

Package Overview
Dependencies
Maintainers
6
Versions
211
Alerts
File Explorer

Advanced tools

Socket logo

Install Socket

Detect and block malicious and high-risk dependencies

Install

@upstash/qstash - npm Package Compare versions

Comparing version 2.1.11-canary to 2.1.11

dist/chunk-EROSIHWE.js

41

dist/index.js

@@ -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

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

npm

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc