Huge News!Announcing our $40M Series B led by Abstract Ventures.Learn More →
@upstash/qstash
Advanced tools
@upstash/qstash - npm Package Compare versions
Comparing version 2.7.14 to 2.7.15
@@ -1,2 +0,2 @@ | ||
| import { a3 as RouteFunction, a4 as WorkflowServeOptions } from './client-kxUsvnWj.js'; | ||
| import { a3 as RouteFunction, a4 as WorkflowServeOptions } from './client-RORrka04.js'; | ||
| import 'neverthrow'; | ||
@@ -3,0 +3,0 @@ |
| import * as h3 from 'h3'; | ||
| import { H3Event } from 'h3'; | ||
| import { a3 as RouteFunction, a4 as WorkflowServeOptions } from './client-kxUsvnWj.js'; | ||
| import { a3 as RouteFunction, a4 as WorkflowServeOptions } from './client-RORrka04.js'; | ||
| import 'neverthrow'; | ||
@@ -5,0 +5,0 @@ |
| import { Context } from 'hono'; | ||
| import { a3 as RouteFunction, a4 as WorkflowServeOptions } from './client-kxUsvnWj.js'; | ||
| import { a3 as RouteFunction, a4 as WorkflowServeOptions } from './client-RORrka04.js'; | ||
| import 'neverthrow'; | ||
@@ -4,0 +4,0 @@ |
@@ -1,3 +0,3 @@ | ||
| import { R as RateLimit, C as ChatRateLimit, S as Step, F as FailureFunctionPayload } from './client-kxUsvnWj.js'; | ||
| export { A as AddEndpointsRequest, $ as AnalyticsConfig, a0 as AnalyticsSetup, B as BodyInit, y as Chat, D as ChatCompletion, I as ChatCompletionChunk, z as ChatCompletionMessage, T as ChatRequest, f as Client, n as CreateScheduleRequest, p as Endpoint, t as Event, u as EventPayload, E as EventsRequest, v as GetEventsPayload, G as GetEventsResponse, H as HTTPMethods, w as HeadersInit, M as Message, k as MessagePayload, l as Messages, O as OpenAIChatModel, N as PromptChatRequest, _ as ProviderReturnType, P as PublishBatchRequest, e as PublishJsonRequest, d as PublishRequest, j as PublishResponse, g as PublishToApiResponse, i as PublishToUrlGroupsResponse, h as PublishToUrlResponse, Q as QueueRequest, c as Receiver, a as ReceiverConfig, q as RemoveEndpointsRequest, x as RequestOptions, m as Schedule, o as Schedules, b as SignatureError, s as State, K as StreamDisabled, J as StreamEnabled, L as StreamParameter, U as UrlGroup, r as UrlGroups, V as VerifyRequest, W as WithCursor, X as custom, Y as openai, a2 as resend, a1 as setupAnalytics, Z as upstash } from './client-kxUsvnWj.js'; | ||
| import { R as RateLimit, C as ChatRateLimit, S as Step, F as FailureFunctionPayload, L as LLMOwner, B as BaseProvider, E as EmailOwner, P as ProviderInfo } from './client-RORrka04.js'; | ||
| export { A as AddEndpointsRequest, y as BodyInit, I as Chat, K as ChatCompletion, N as ChatCompletionChunk, J as ChatCompletionMessage, _ as ChatRequest, h as Client, p as CreateScheduleRequest, r as Endpoint, v as Event, w as EventPayload, g as EventsRequest, x as GetEventsPayload, G as GetEventsResponse, H as HTTPMethods, z as HeadersInit, M as Message, m as MessagePayload, n as Messages, Y as OpenAIChatModel, Z as PromptChatRequest, d as PublishBatchRequest, f as PublishJsonRequest, e as PublishRequest, l as PublishResponse, i as PublishToApiResponse, k as PublishToUrlGroupsResponse, j as PublishToUrlResponse, Q as QueueRequest, c as Receiver, a as ReceiverConfig, s as RemoveEndpointsRequest, D as RequestOptions, o as Schedule, q as Schedules, b as SignatureError, u as State, T as StreamDisabled, O as StreamEnabled, X as StreamParameter, U as UrlGroup, t as UrlGroups, V as VerifyRequest, W as WithCursor, a1 as anthropic, a2 as custom, a0 as openai, $ as upstash } from './client-RORrka04.js'; | ||
| import 'neverthrow'; | ||
@@ -67,2 +67,25 @@ | ||
| export { ChatRateLimit, QStashWorkflowAbort, QStashWorkflowError, QstashChatRatelimitError, QstashDailyRatelimitError, QstashError, QstashRatelimitError, RateLimit, decodeBase64, formatWorkflowError }; | ||
| type AnalyticsConfig = { | ||
| name: "helicone"; | ||
| token: string; | ||
| }; | ||
| type AnalyticsSetup = { | ||
| baseURL?: string; | ||
| defaultHeaders?: Record<string, string | undefined>; | ||
| }; | ||
| declare const setupAnalytics: (analytics: AnalyticsConfig | undefined, providerApiKey: string, providerBaseUrl?: string, provider?: LLMOwner) => AnalyticsSetup; | ||
| declare class EmailProvider extends BaseProvider<"email", EmailOwner> { | ||
| readonly apiKind = "email"; | ||
| readonly batch: boolean; | ||
| constructor(baseUrl: string, token: string, owner: EmailOwner, batch: boolean); | ||
| getRoute(): string[]; | ||
| getHeaders(_options: unknown): Record<string, string>; | ||
| onFinish(providerInfo: ProviderInfo, _options: unknown): ProviderInfo; | ||
| } | ||
| declare const resend: ({ token, batch, }: { | ||
| token: string; | ||
| batch?: boolean; | ||
| }) => EmailProvider; | ||
| export { ChatRateLimit, QStashWorkflowAbort, QStashWorkflowError, QstashChatRatelimitError, QstashDailyRatelimitError, QstashError, QstashRatelimitError, RateLimit, decodeBase64, formatWorkflowError, resend, setupAnalytics }; |
328
index.js
@@ -46,2 +46,3 @@ "use strict"; | ||
| UrlGroups: () => UrlGroups, | ||
| anthropic: () => anthropic, | ||
| custom: () => custom, | ||
@@ -117,10 +118,2 @@ decodeBase64: () => decodeBase64, | ||
| // src/client/api/utils.ts | ||
| var appendAPIOptions = (request, headers) => { | ||
| if (request.api?.name === "email") { | ||
| headers.set("Authorization", request.api.provider.token); | ||
| request.method = request.method ?? "POST"; | ||
| } | ||
| }; | ||
| // src/client/dlq.ts | ||
@@ -273,3 +266,3 @@ var DLQ = class { | ||
| } : { | ||
| attempts: config.retry?.retries ? config.retry.retries + 1 : 5, | ||
| attempts: config.retry?.retries ?? 5, | ||
| backoff: config.retry?.backoff ?? ((retryCount) => Math.exp(retryCount) * 50) | ||
@@ -319,3 +312,3 @@ }; | ||
| let error = void 0; | ||
| for (let index = 0; index < this.retry.attempts; index++) { | ||
| for (let index = 0; index <= this.retry.attempts; index++) { | ||
| try { | ||
@@ -326,3 +319,5 @@ response = await fetch(url.toString(), requestOptions); | ||
| error = error_; | ||
| await new Promise((r) => setTimeout(r, this.retry.backoff(index))); | ||
| if (index < this.retry.attempts) { | ||
| await new Promise((r) => setTimeout(r, this.retry.backoff(index))); | ||
| } | ||
| } | ||
@@ -424,33 +419,2 @@ } | ||
| }; | ||
| var upstash = () => { | ||
| return { | ||
| owner: "upstash", | ||
| baseUrl: "https://qstash.upstash.io/llm", | ||
| token: "", | ||
| organization: void 0 | ||
| }; | ||
| }; | ||
| var openai = ({ | ||
| token, | ||
| organization | ||
| }) => { | ||
| return { | ||
| token, | ||
| owner: "openai", | ||
| baseUrl: "https://api.openai.com", | ||
| organization | ||
| }; | ||
| }; | ||
| var custom = ({ | ||
| baseUrl, | ||
| token | ||
| }) => { | ||
| const trimmedBaseUrl = baseUrl.replace(/\/(v1\/)?chat\/completions$/, ""); | ||
| return { | ||
| token, | ||
| owner: "custom", | ||
| baseUrl: trimmedBaseUrl, | ||
| organization: void 0 | ||
| }; | ||
| }; | ||
@@ -531,3 +495,2 @@ // src/client/llm/chat.ts | ||
| */ | ||
| // eslint-disable-next-line @typescript-eslint/require-await | ||
| createThirdParty = async (request) => { | ||
@@ -593,59 +556,2 @@ const { baseUrl, token, owner, organization } = request.provider; | ||
| // src/client/llm/utils.ts | ||
| function appendLLMOptionsIfNeeded(request, headers, http) { | ||
| if (request.api?.name === "email" || !request.api) | ||
| return; | ||
| const provider = request.api.provider; | ||
| const analytics = request.api.analytics; | ||
| if (provider?.owner === "upstash") { | ||
| handleUpstashProvider(request, headers, http, analytics); | ||
| return; | ||
| } | ||
| if (!("provider" in request.api)) | ||
| return; | ||
| const { baseUrl, token } = validateProviderConfig(provider); | ||
| const analyticsConfig = analytics ? setupAnalytics({ name: analytics.name, token: analytics.token }, token, baseUrl, "custom") : void 0; | ||
| if (analyticsConfig) { | ||
| setAnalyticsHeaders(headers, analyticsConfig); | ||
| request.url = analyticsConfig.baseURL; | ||
| } else { | ||
| request.url = `${baseUrl}/v1/chat/completions`; | ||
| headers.set("Authorization", `Bearer ${token}`); | ||
| } | ||
| } | ||
| function handleUpstashProvider(request, headers, http, analytics) { | ||
| if (analytics) { | ||
| const analyticsConfig = setupAnalytics( | ||
| { name: analytics.name, token: analytics.token }, | ||
| //@ts-expect-error hacky way to get bearer token | ||
| String(http.authorization).split("Bearer ")[1], | ||
| request.api?.provider?.baseUrl, | ||
| "upstash" | ||
| ); | ||
| setAnalyticsHeaders(headers, analyticsConfig); | ||
| request.url = analyticsConfig.baseURL; | ||
| } else { | ||
| request.api = { name: "llm" }; | ||
| } | ||
| } | ||
| function validateProviderConfig(provider) { | ||
| if (!provider?.baseUrl) | ||
| throw new Error("baseUrl cannot be empty or undefined!"); | ||
| if (!provider.token) | ||
| throw new Error("token cannot be empty or undefined!"); | ||
| return { baseUrl: provider.baseUrl, token: provider.token }; | ||
| } | ||
| function setAnalyticsHeaders(headers, analyticsConfig) { | ||
| headers.set("Helicone-Auth", analyticsConfig.defaultHeaders?.["Helicone-Auth"] ?? ""); | ||
| headers.set("Authorization", analyticsConfig.defaultHeaders?.Authorization ?? ""); | ||
| if (analyticsConfig.defaultHeaders?.["Helicone-Target-Url"]) { | ||
| headers.set("Helicone-Target-Url", analyticsConfig.defaultHeaders["Helicone-Target-Url"]); | ||
| } | ||
| } | ||
| function ensureCallbackPresent(request) { | ||
| if (request.api?.name === "llm" && !request.callback) { | ||
| throw new TypeError("Callback cannot be undefined when using LLM"); | ||
| } | ||
| } | ||
| // src/client/messages.ts | ||
@@ -699,2 +605,156 @@ var Messages = class { | ||
| // src/client/api/base.ts | ||
| var BaseProvider = class { | ||
| baseUrl; | ||
| token; | ||
| owner; | ||
| constructor(baseUrl, token, owner) { | ||
| this.baseUrl = baseUrl; | ||
| this.token = token; | ||
| this.owner = owner; | ||
| } | ||
| getUrl() { | ||
| return `${this.baseUrl}/${this.getRoute().join("/")}`; | ||
| } | ||
| }; | ||
| // src/client/api/llm.ts | ||
| var LLMProvider = class extends BaseProvider { | ||
| apiKind = "llm"; | ||
| organization; | ||
| constructor(baseUrl, token, owner, organization) { | ||
| super(baseUrl, token, owner); | ||
| this.organization = organization; | ||
| } | ||
| getRoute() { | ||
| return this.owner === "anthropic" ? ["v1", "messages"] : ["v1", "chat", "completions"]; | ||
| } | ||
| getHeaders(options) { | ||
| if (this.owner === "upstash" && !options.analytics) { | ||
| return {}; | ||
| } | ||
| const header = this.owner === "anthropic" ? "x-api-key" : "authorization"; | ||
| const headerValue = this.owner === "anthropic" ? this.token : `Bearer ${this.token}`; | ||
| const headers = { [header]: headerValue }; | ||
| if (this.owner === "openai" && this.organization) { | ||
| headers["OpenAI-Organization"] = this.organization; | ||
| } | ||
| return headers; | ||
| } | ||
| /** | ||
| * Checks if callback exists and adds analytics in place if it's set. | ||
| * | ||
| * @param request | ||
| * @param options | ||
| */ | ||
| onFinish(providerInfo, options) { | ||
| if (options.analytics) { | ||
| return updateWithAnalytics(providerInfo, options.analytics); | ||
| } | ||
| return providerInfo; | ||
| } | ||
| }; | ||
| var upstash = () => { | ||
| return new LLMProvider("https://qstash.upstash.io/llm", "", "upstash"); | ||
| }; | ||
| var openai = ({ | ||
| token, | ||
| organization | ||
| }) => { | ||
| return new LLMProvider("https://api.openai.com", token, "openai", organization); | ||
| }; | ||
| var anthropic = ({ token }) => { | ||
| return new LLMProvider("https://api.anthropic.com", token, "anthropic"); | ||
| }; | ||
| var custom = ({ | ||
| baseUrl, | ||
| token | ||
| }) => { | ||
| const trimmedBaseUrl = baseUrl.replace(/\/(v1\/)?chat\/completions$/, ""); | ||
| return new LLMProvider(trimmedBaseUrl, token, "custom"); | ||
| }; | ||
| // src/client/api/utils.ts | ||
| var getProviderInfo = (api, upstashToken) => { | ||
| const { name, provider, ...parameters } = api; | ||
| const finalProvider = provider ?? upstash(); | ||
| if (finalProvider.owner === "upstash" && !finalProvider.token) { | ||
| finalProvider.token = upstashToken; | ||
| } | ||
| if (!finalProvider.baseUrl) | ||
| throw new TypeError("baseUrl cannot be empty or undefined!"); | ||
| if (!finalProvider.token) | ||
| throw new TypeError("token cannot be empty or undefined!"); | ||
| if (finalProvider.apiKind !== name) { | ||
| throw new TypeError( | ||
| `Unexpected api name. Expected '${finalProvider.apiKind}', received ${name}` | ||
| ); | ||
| } | ||
| const providerInfo = { | ||
| url: finalProvider.getUrl(), | ||
| baseUrl: finalProvider.baseUrl, | ||
| route: finalProvider.getRoute(), | ||
| appendHeaders: finalProvider.getHeaders(parameters), | ||
| owner: finalProvider.owner | ||
| }; | ||
| return finalProvider.onFinish(providerInfo, parameters); | ||
| }; | ||
| var processApi = (request, upstashToken) => { | ||
| if (!request.api) { | ||
| return request; | ||
| } | ||
| const { url, appendHeaders, owner } = getProviderInfo(request.api, upstashToken); | ||
| if (request.api.name === "llm") { | ||
| const callback = request.callback; | ||
| if (!callback) { | ||
| throw new TypeError("Callback cannot be undefined when using LLM api."); | ||
| } | ||
| return { | ||
| ...request, | ||
| // @ts-expect-error undici header conflict | ||
| headers: new Headers({ | ||
| ...request.headers, | ||
| ...appendHeaders | ||
| }), | ||
| ...owner === "upstash" && !request.api.analytics ? { api: { name: "llm" }, url: void 0, callback } : { url, api: void 0 } | ||
| }; | ||
| } else { | ||
| return { | ||
| ...request, | ||
| // @ts-expect-error undici header conflict | ||
| headers: new Headers({ | ||
| ...request.headers, | ||
| ...appendHeaders | ||
| }), | ||
| url, | ||
| api: void 0 | ||
| }; | ||
| } | ||
| }; | ||
| function updateWithAnalytics(providerInfo, analytics) { | ||
| switch (analytics.name) { | ||
| case "helicone": { | ||
| providerInfo.appendHeaders["Helicone-Auth"] = `Bearer ${analytics.token}`; | ||
| if (providerInfo.owner === "upstash") { | ||
| updateProviderInfo(providerInfo, "https://qstash.helicone.ai", [ | ||
| "llm", | ||
| ...providerInfo.route | ||
| ]); | ||
| } else { | ||
| providerInfo.appendHeaders["Helicone-Target-Url"] = providerInfo.baseUrl; | ||
| updateProviderInfo(providerInfo, "https://gateway.helicone.ai", providerInfo.route); | ||
| } | ||
| return providerInfo; | ||
| } | ||
| default: { | ||
| throw new Error("Unknown analytics provider"); | ||
| } | ||
| } | ||
| } | ||
| function updateProviderInfo(providerInfo, baseUrl, route) { | ||
| providerInfo.baseUrl = baseUrl; | ||
| providerInfo.route = route; | ||
| providerInfo.url = `${baseUrl}/${route.join("/")}`; | ||
| } | ||
| // src/client/utils.ts | ||
@@ -732,3 +792,3 @@ var isIgnoredHeader = (header) => { | ||
| } | ||
| if (request.contentBasedDeduplication !== void 0) { | ||
| if (request.contentBasedDeduplication) { | ||
| headers.set("Upstash-Content-Based-Deduplication", "true"); | ||
@@ -759,5 +819,6 @@ } | ||
| if (request.api?.name === "llm") | ||
| return `api/${request.api.name}`; | ||
| return `api/llm`; | ||
| if (request.api?.name === "email") { | ||
| return request.api.provider.baseUrl; | ||
| const providerInfo = getProviderInfo(request.api, "not-needed"); | ||
| return providerInfo.baseUrl; | ||
| } | ||
@@ -874,8 +935,8 @@ throw new QstashError(`Failed to infer request path for ${JSON.stringify(request)}`); | ||
| headers.set("Content-Type", "application/json"); | ||
| ensureCallbackPresent(request); | ||
| appendLLMOptionsIfNeeded(request, headers, this.http); | ||
| appendAPIOptions(request, headers); | ||
| request.headers = headers; | ||
| const upstashToken = String(this.http.authorization).split("Bearer ")[1]; | ||
| const nonApiRequest = processApi(request, upstashToken); | ||
| const response = await this.enqueue({ | ||
| ...request, | ||
| body: JSON.stringify(request.body), | ||
| ...nonApiRequest, | ||
| body: JSON.stringify(nonApiRequest.body), | ||
| headers | ||
@@ -1209,9 +1270,8 @@ }); | ||
| headers.set("Content-Type", "application/json"); | ||
| ensureCallbackPresent(request); | ||
| appendLLMOptionsIfNeeded(request, headers, this.http); | ||
| appendAPIOptions(request, headers); | ||
| request.headers = headers; | ||
| const upstashToken = String(this.http.authorization).split("Bearer ")[1]; | ||
| const nonApiRequest = processApi(request, upstashToken); | ||
| const response = await this.publish({ | ||
| ...request, | ||
| headers, | ||
| body: JSON.stringify(request.body) | ||
| ...nonApiRequest, | ||
| body: JSON.stringify(nonApiRequest.body) | ||
| }); | ||
@@ -1250,3 +1310,3 @@ return response; | ||
| async batchJSON(request) { | ||
| for (const message of request) { | ||
| const batchPayload = request.map((message) => { | ||
| if ("body" in message) { | ||
@@ -1256,8 +1316,8 @@ message.body = JSON.stringify(message.body); | ||
| message.headers = new Headers(message.headers); | ||
| ensureCallbackPresent(message); | ||
| appendLLMOptionsIfNeeded(message, message.headers, this.http); | ||
| appendAPIOptions(message, message.headers); | ||
| message.headers.set("Content-Type", "application/json"); | ||
| } | ||
| const response = await this.batch(request); | ||
| const upstashToken = String(this.http.authorization).split("Bearer ")[1]; | ||
| const nonApiMessage = processApi(message, upstashToken); | ||
| nonApiMessage.headers.set("Content-Type", "application/json"); | ||
| return nonApiMessage; | ||
| }); | ||
| const response = await this.batch(batchPayload); | ||
| return response; | ||
@@ -1319,2 +1379,21 @@ } | ||
| // src/client/api/email.ts | ||
| var EmailProvider = class extends BaseProvider { | ||
| apiKind = "email"; | ||
| batch; | ||
| constructor(baseUrl, token, owner, batch) { | ||
| super(baseUrl, token, owner); | ||
| this.batch = batch; | ||
| } | ||
| getRoute() { | ||
| return this.batch ? ["emails", "batch"] : ["emails"]; | ||
| } | ||
| getHeaders(_options) { | ||
| return { | ||
| "upstash-forward-authorization": `Bearer ${this.token}` | ||
| }; | ||
| } | ||
| onFinish(providerInfo, _options) { | ||
| return providerInfo; | ||
| } | ||
| }; | ||
| var resend = ({ | ||
@@ -1324,7 +1403,3 @@ token, | ||
| }) => { | ||
| return { | ||
| owner: "resend", | ||
| baseUrl: `https://api.resend.com/emails${batch ? "/batch" : ""}`, | ||
| token | ||
| }; | ||
| return new EmailProvider("https://api.resend.com", token, "resend", batch); | ||
| }; | ||
@@ -1346,2 +1421,3 @@ // Annotate the CommonJS export names for ESM import in node: | ||
| UrlGroups, | ||
| anthropic, | ||
| custom, | ||
@@ -1348,0 +1424,0 @@ decodeBase64, |
| import { NextApiHandler } from 'next'; | ||
| import { NextRequest, NextFetchEvent } from 'next/server'; | ||
| import { a3 as RouteFunction, a4 as WorkflowServeOptions } from './client-kxUsvnWj.js'; | ||
| import { a3 as RouteFunction, a4 as WorkflowServeOptions } from './client-RORrka04.js'; | ||
| import 'neverthrow'; | ||
@@ -5,0 +5,0 @@ |
@@ -1,1 +0,1 @@ | ||
| {"version":"v2.7.14","name":"@upstash/qstash","description":"Official Typescript client for QStash","author":"Andreas Thomas <dev@chronark.com>","license":"MIT","homepage":"https://github.com/upstash/sdk-qstash-ts#readme","repository":{"type":"git","url":"git+https://github.com/upstash/sdk-qstash-ts.git"},"bugs":{"url":"https://github.com/upstash/sdk-qstash-ts/issues"},"main":"./index.js","module":"./index.mjs","types":"./index.d.ts","files":["./*"],"exports":{".":{"import":"./index.mjs","require":"./index.js"},"./dist/nextjs":{"import":"./nextjs.mjs","require":"./nextjs.js"},"./nextjs":{"import":"./nextjs.mjs","require":"./nextjs.js"},"./h3":{"import":"./h3.mjs","require":"./h3.js"},"./nuxt":{"import":"./nuxt.mjs","require":"./nuxt.js"},"./svelte":{"import":"./svelte.mjs","require":"./svelte.js"},"./solidjs":{"import":"./solidjs.mjs","require":"./solidjs.js"},"./workflow":{"import":"./workflow.mjs","require":"./workflow.js"},"./hono":{"import":"./hono.mjs","require":"./hono.js"},"./cloudflare":{"import":"./cloudflare.mjs","require":"./cloudflare.js"}},"keywords":["qstash","queue","events","serverless","upstash"],"scripts":{"build":"tsup && cp README.md ./dist/ && cp package.json ./dist/ && cp LICENSE ./dist/","test":"bun test src","fmt":"prettier --write .","lint":"tsc && eslint \"{src,platforms}/**/*.{js,ts,tsx}\" --quiet --fix","check-exports":"bun run build && cd dist && attw -P"},"devDependencies":{"@commitlint/cli":"^19.2.2","@commitlint/config-conventional":"^19.2.2","@eslint/eslintrc":"^3.1.0","@eslint/js":"^9.10.0","@solidjs/start":"^1.0.6","@sveltejs/kit":"^2.5.18","@types/bun":"^1.1.1","@types/crypto-js":"^4.2.0","@typescript-eslint/eslint-plugin":"^8.4.0","@typescript-eslint/parser":"^8.4.0","ai":"^3.1.28","bun-types":"^1.1.7","eslint":"^9.10.0","eslint-plugin-unicorn":"^51.0.1","h3":"^1.12.0","hono":"^4.5.8","husky":"^9.0.10","next":"^14.0.2","prettier":"^3.2.5","tsup":"latest","typescript":"^5.4.5","undici-types":"^6.16.0","vitest":"latest"},"dependencies":{"crypto-js":">=4.2.0","jose":"^5.2.3","neverthrow":"^7.0.1"}} | ||
| {"version":"v2.7.15","name":"@upstash/qstash","description":"Official Typescript client for QStash","author":"Andreas Thomas <dev@chronark.com>","license":"MIT","homepage":"https://github.com/upstash/sdk-qstash-ts#readme","repository":{"type":"git","url":"git+https://github.com/upstash/sdk-qstash-ts.git"},"bugs":{"url":"https://github.com/upstash/sdk-qstash-ts/issues"},"main":"./index.js","module":"./index.mjs","types":"./index.d.ts","files":["./*"],"exports":{".":{"import":"./index.mjs","require":"./index.js"},"./dist/nextjs":{"import":"./nextjs.mjs","require":"./nextjs.js"},"./nextjs":{"import":"./nextjs.mjs","require":"./nextjs.js"},"./h3":{"import":"./h3.mjs","require":"./h3.js"},"./nuxt":{"import":"./nuxt.mjs","require":"./nuxt.js"},"./svelte":{"import":"./svelte.mjs","require":"./svelte.js"},"./solidjs":{"import":"./solidjs.mjs","require":"./solidjs.js"},"./workflow":{"import":"./workflow.mjs","require":"./workflow.js"},"./hono":{"import":"./hono.mjs","require":"./hono.js"},"./cloudflare":{"import":"./cloudflare.mjs","require":"./cloudflare.js"}},"keywords":["qstash","queue","events","serverless","upstash"],"scripts":{"build":"tsup && cp README.md ./dist/ && cp package.json ./dist/ && cp LICENSE ./dist/","test":"bun test src","fmt":"prettier --write .","lint":"tsc && eslint \"{src,platforms}/**/*.{js,ts,tsx}\" --quiet --fix","check-exports":"bun run build && cd dist && attw -P"},"devDependencies":{"@commitlint/cli":"^19.2.2","@commitlint/config-conventional":"^19.2.2","@eslint/eslintrc":"^3.1.0","@eslint/js":"^9.10.0","@solidjs/start":"^1.0.6","@sveltejs/kit":"^2.5.18","@types/bun":"^1.1.1","@types/crypto-js":"^4.2.0","@typescript-eslint/eslint-plugin":"^8.4.0","@typescript-eslint/parser":"^8.4.0","ai":"^3.1.28","bun-types":"^1.1.7","eslint":"^9.10.0","eslint-plugin-unicorn":"^51.0.1","h3":"^1.12.0","hono":"^4.5.8","husky":"^9.0.10","next":"^14.0.2","prettier":"^3.2.5","tsup":"latest","typescript":"^5.4.5","undici-types":"^6.16.0","vitest":"latest"},"dependencies":{"crypto-js":">=4.2.0","jose":"^5.2.3","neverthrow":"^7.0.1"}} |
| import { APIHandler, APIEvent } from '@solidjs/start/server'; | ||
| import { a3 as RouteFunction, a4 as WorkflowServeOptions } from './client-kxUsvnWj.js'; | ||
| import { a3 as RouteFunction, a4 as WorkflowServeOptions } from './client-RORrka04.js'; | ||
| import 'neverthrow'; | ||
@@ -4,0 +4,0 @@ |
| import { RequestHandler } from '@sveltejs/kit'; | ||
| import { a3 as RouteFunction, a4 as WorkflowServeOptions } from './client-kxUsvnWj.js'; | ||
| import { a3 as RouteFunction, a4 as WorkflowServeOptions } from './client-RORrka04.js'; | ||
| import 'neverthrow'; | ||
@@ -4,0 +4,0 @@ |
@@ -1,2 +0,2 @@ | ||
| export { ag as AsyncStepFunction, a9 as DisabledWorkflowContext, F as FailureFunctionPayload, aj as FinishCondition, al as LogLevel, ai as ParallelCallState, ae as RawStep, ak as RequiredExceptFields, a3 as RouteFunction, S as Step, ah as StepFunction, ad as StepType, ac as StepTypes, af as SyncStepFunction, a5 as Workflow, aa as WorkflowClient, a8 as WorkflowContext, an as WorkflowLogger, am as WorkflowLoggerOptions, ab as WorkflowReceiver, a4 as WorkflowServeOptions, a6 as processOptions, a7 as serve } from './client-kxUsvnWj.js'; | ||
| export { ag as AsyncStepFunction, a9 as DisabledWorkflowContext, F as FailureFunctionPayload, aj as FinishCondition, al as LogLevel, ai as ParallelCallState, ae as RawStep, ak as RequiredExceptFields, a3 as RouteFunction, S as Step, ah as StepFunction, ad as StepType, ac as StepTypes, af as SyncStepFunction, a5 as Workflow, aa as WorkflowClient, a8 as WorkflowContext, an as WorkflowLogger, am as WorkflowLoggerOptions, ab as WorkflowReceiver, a4 as WorkflowServeOptions, a6 as processOptions, a7 as serve } from './client-RORrka04.js'; | ||
| import 'neverthrow'; |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is too big to display
Sorry, the diff of this file is not supported yet
New alerts
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
Fixed alerts
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
Improved metrics
- Total package byte prevSize
- increased by2.34%
904940
- Lines of code
- increased by2.81%
26819
No dependency changes