@defer/client - npm Package Compare versions

Comparing version 1.6.0-alpha-20230627172525-6f08bfa to 1.6.0-alpha-20230628182657-a7b1727

cjs/constants.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
 exports.RETRY_MAX_ATTEMPTS_PLACEHOLDER = exports.INTERNAL_VERSION = void 0;
-exports.INTERNAL_VERSION = 4;
+exports.INTERNAL_VERSION = 5;
 exports.RETRY_MAX_ATTEMPTS_PLACEHOLDER = 13;

cjs/httpClient.js

@@ -8,3 +8,3 @@ "use strict";
 const fetch_1 = require("@whatwg-node/fetch");
-const url_1 = require("url");
+const node_url_1 = require("node:url");
 const errors_js_1 = require("./errors.js");
@@ -20,3 +20,3 @@ const version_js_1 = __importDefault(require("./version.js"));
         try {
-            endpoint = new url_1.URL(path, apiEndpoint);
+            endpoint = new node_url_1.URL(path, apiEndpoint);
         }
@@ -23,0 +23,0 @@ catch (error) {

cjs/index.js

@@ -6,5 +6,5 @@ "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.awaitResult = exports.addMetadata = exports.delay = exports.defer = exports.deferEnabled = exports.configure = exports.__httpClient = exports.__database = exports.useDeferRoute = exports.asNextRoute = void 0;
+exports.awaitResult = exports.addMetadata = exports.delay = exports.defer = exports.getExecution = exports.deferEnabled = exports.configure = void 0;
+const parse_duration_1 = __importDefault(require("parse-duration"));
 const uuid_1 = require("uuid");
-const parse_duration_1 = __importDefault(require("parse-duration"));
 const constants_js_1 = require("./constants.js");
@@ -14,13 +14,10 @@ const client_js_1 = require("./client.js");
 const httpClient_js_1 = require("./httpClient.js");
-var asNextRoute_1 = require("./next/asNextRoute");
-Object.defineProperty(exports, "asNextRoute", { enumerable: true, get: function () { return asNextRoute_1.asNextRoute; } });
-var useDeferRoute_1 = require("./next/useDeferRoute");
-Object.defineProperty(exports, "useDeferRoute", { enumerable: true, get: function () { return useDeferRoute_1.useDeferRoute; } });
 const withDelay = (dt, delay) => new Date(dt.getTime() + (0, parse_duration_1.default)(delay));
-exports.__database = new Map();
+const __database = new Map();
 let __accessToken = process.env["DEFER_TOKEN"];
 let __endpoint = process.env["DEFER_ENDPOINT"] || "https://api.defer.run";
 let __verbose = false;
+let __httpClient;
 if (__accessToken)
-    exports.__httpClient = (0, httpClient_js_1.makeHTTPClient)(__endpoint, __accessToken);
+    __httpClient = (0, httpClient_js_1.makeHTTPClient)(__endpoint, __accessToken);
 function configure(opts = {}) {
@@ -34,3 +31,3 @@ if (opts.accessToken)
     if (__accessToken)
-        exports.__httpClient = (0, httpClient_js_1.makeHTTPClient)(__endpoint, __accessToken);
+        __httpClient = (0, httpClient_js_1.makeHTTPClient)(__endpoint, __accessToken);
     return;
@@ -66,5 +63,14 @@ }
     const response = { id, state, result };
-    exports.__database.set(id, response);
+    __database.set(id, response);
     return response;
 }
+async function getExecution(id) {
+    if (__httpClient)
+        return (0, client_js_1.fetchExecution)(__httpClient, { id });
+    const response = __database.get(id);
+    if (response)
+        return Promise.resolve(response);
+    throw new errors_js_1.APIError("execution not found", "");
+}
+exports.getExecution = getExecution;
 function defaultRetryPolicy() {
@@ -91,4 +97,4 @@ return {
         }
-        if (exports.__httpClient) {
-            return (0, client_js_1.enqueueExecution)(exports.__httpClient, {
+        if (__httpClient) {
+            return (0, client_js_1.enqueueExecution)(__httpClient, {
                 name: fn.name,
@@ -103,3 +109,3 @@ arguments: functionArguments,
         const id = (0, uuid_1.v4)();
-        exports.__database.set(id, { id: id, state: "running" });
+        __database.set(id, { id: id, state: "running" });
         execLocally(id, fn, functionArguments);
@@ -185,3 +191,3 @@ return { id };
             console.log(`[defer.run][${fn.name}] invoked.`);
-        if (exports.__httpClient) {
+        if (__httpClient) {
             let scheduleFor;
@@ -195,3 +201,3 @@ if (delay instanceof Date) {
             }
-            return (0, client_js_1.enqueueExecution)(exports.__httpClient, {
+            return (0, client_js_1.enqueueExecution)(__httpClient, {
                 name: fn.name,
@@ -206,3 +212,3 @@ arguments: functionArguments,
         const id = (0, uuid_1.v4)();
-        exports.__database.set(id, { id: id, state: "running" });
+        __database.set(id, { id: id, state: "running" });
         execLocally(id, fn, functionArguments);
@@ -241,3 +247,3 @@ return { id };
             console.log(`[defer.run][${fn.name}] invoked.`);
-        if (exports.__httpClient) {
+        if (__httpClient) {
             let scheduleFor;
@@ -255,3 +261,3 @@ const delay = deferFn.__execOptions?.delay;
             }
-            return (0, client_js_1.enqueueExecution)(exports.__httpClient, {
+            return (0, client_js_1.enqueueExecution)(__httpClient, {
                 name: fn.name,
@@ -266,3 +272,3 @@ arguments: functionArguments,
         const id = (0, uuid_1.v4)();
-        exports.__database.set(id, { id: id, state: "running" });
+        __database.set(id, { id: id, state: "running" });
         execLocally(id, fn, functionArguments);
@@ -298,4 +304,4 @@ return { id };
     let response;
-    if (exports.__httpClient) {
-        const { id } = await (0, client_js_1.enqueueExecution)(exports.__httpClient, {
+    if (__httpClient) {
+        const { id } = await (0, client_js_1.enqueueExecution)(__httpClient, {
             name: fnName,
@@ -306,7 +312,7 @@ arguments: functionArguments,
         });
-        response = await (0, client_js_1.waitExecutionResult)(exports.__httpClient, { id: id });
+        response = await (0, client_js_1.waitExecutionResult)(__httpClient, { id: id });
     }
     else {
         const id = (0, uuid_1.v4)();
-        exports.__database.set(id, { id: id, state: "running" });
+        __database.set(id, { id: id, state: "running" });
         response = await execLocally(id, fn, functionArguments);
@@ -313,0 +319,0 @@ }

cjs/version.js

 "use strict";
 Object.defineProperty(exports, "__esModule", { value: true });
-exports.default = "1.6.0-alpha-20230627172525-6f08bfa";
+exports.default = "1.6.0-alpha-20230628182657-a7b1727";

esm/constants.js

@@ -1,2 +0,2 @@
-export const INTERNAL_VERSION = 4;
+export const INTERNAL_VERSION = 5;
 export const RETRY_MAX_ATTEMPTS_PLACEHOLDER = 13;

esm/httpClient.js

 import { fetch } from "@whatwg-node/fetch";
-import { URL } from "url";
+import { URL } from "node:url";
 import { APIError, ClientError, HTTPRequestError, errorMessage, } from "./errors.js";
@@ -4,0 +4,0 @@ import VERSION from "./version.js";

esm/index.js

@@ -0,15 +1,13 @@
+import parseDuration from "parse-duration";
 import { v4 as randomUUID } from "uuid";
-import parseDuration from "parse-duration";
 import { INTERNAL_VERSION, RETRY_MAX_ATTEMPTS_PLACEHOLDER, } from "./constants.js";
-import { enqueueExecution, waitExecutionResult, } from "./client.js";
-import { DeferError } from "./errors.js";
+import { enqueueExecution, fetchExecution, waitExecutionResult, } from "./client.js";
+import { APIError, DeferError } from "./errors.js";
 import { makeHTTPClient } from "./httpClient.js";
-export { asNextRoute } from "./next/asNextRoute";
-export { useDeferRoute } from "./next/useDeferRoute";
 const withDelay = (dt, delay) => new Date(dt.getTime() + parseDuration(delay));
-export const __database = new Map();
+const __database = new Map();
 let __accessToken = process.env["DEFER_TOKEN"];
 let __endpoint = process.env["DEFER_ENDPOINT"] || "https://api.defer.run";
 let __verbose = false;
-export let __httpClient;
+let __httpClient;
 if (__accessToken)
@@ -57,2 +55,10 @@ __httpClient = makeHTTPClient(__endpoint, __accessToken);
 }
+export async function getExecution(id) {
+    if (__httpClient)
+        return fetchExecution(__httpClient, { id });
+    const response = __database.get(id);
+    if (response)
+        return Promise.resolve(response);
+    throw new APIError("execution not found", "");
+}
 function defaultRetryPolicy() {
@@ -59,0 +65,0 @@ return {

esm/version.js

@@ -1,1 +0,1 @@
-export default "1.6.0-alpha-20230627172525-6f08bfa";
+export default "1.6.0-alpha-20230628182657-a7b1727";

package.json

 {
   "name": "@defer/client",
-  "version": "1.6.0-alpha-20230627172525-6f08bfa",
+  "version": "1.6.0-alpha-20230628182657-a7b1727",
   "description": "Zero infrastructure NodeJS background jobs",
-  "peerDependencies": {
-    "next": "^13.4.7",
-    "react": "^18.2.0"
-  },
   "dependencies": {
-    "@whatwg-node/fetch": "^0.9.7",
+    "@whatwg-node/fetch": "^0.2.9",
     "parse-duration": "^1.0.2",
@@ -17,5 +13,2 @@ "uuid": "^9.0.0"
   "license": "ISC",
-  "engines": {
-    "node": ">16.0.0"
-  },
   "main": "cjs/index.js",
@@ -22,0 +15,0 @@ "module": "esm/index.js",

typings/client.d.ts

@@ -15,12 +15,12 @@ import type { HTTPClient } from "./httpClient.js";
 }
-export type ExecutionState = "running" | "created" | "failed" | "succeed" | "started";
-export interface FetchExecutionResponse<R = any> {
+export declare type ExecutionState = "running" | "created" | "failed" | "succeed";
+export interface FetchExecutionResponse {
     id: string;
     state: ExecutionState;
-    result?: R;
+    result?: any;
 }
-export type PoolExecutionRequest = FetchExecutionRequest;
-export type PoolExecutionResponse = FetchExecutionResponse;
+export declare type PoolExecutionRequest = FetchExecutionRequest;
+export declare type PoolExecutionResponse = FetchExecutionResponse;
 export declare function enqueueExecution(client: HTTPClient, request: EnqueueExecutionRequest): Promise<EnqueueExecutionResponse>;
 export declare function fetchExecution(client: HTTPClient, request: FetchExecutionRequest): Promise<FetchExecutionResponse>;
 export declare function waitExecutionResult(client: HTTPClient, request: PoolExecutionRequest): Promise<PoolExecutionResponse>;

typings/constants.d.ts

@@ -1,2 +0,2 @@
-export declare const INTERNAL_VERSION = 4;
+export declare const INTERNAL_VERSION = 5;
 export declare const RETRY_MAX_ATTEMPTS_PLACEHOLDER = 13;

typings/httpClient.d.ts

@@ -1,2 +0,2 @@
-export type HTTPClient = ReturnType<typeof makeHTTPClient>;
+export declare type HTTPClient = ReturnType<typeof makeHTTPClient>;
 export declare function makeHTTPClient(apiEndpoint: string, accessToken: string, clientOptions?: RequestInit): <T>(method: string, path: string, body?: string | null) => Promise<T>;

typings/index.d.ts

 import { Units } from "parse-duration";
-import { EnqueueExecutionResponse, ExecutionState } from "./client.js";
-import { HTTPClient } from "./httpClient.js";
-export { DeferNextRoute, asNextRoute } from "./next/asNextRoute";
-export { UseDeferRoute, useDeferRoute } from "./next/useDeferRoute";
+import { EnqueueExecutionResponse, FetchExecutionResponse } from "./client.js";
 interface Options {
@@ -11,12 +8,7 @@ accessToken?: string;
 }
-export declare const __database: Map<string, {
-    id: string;
-    state: ExecutionState;
-    result?: any;
-}>;
-export declare let __httpClient: HTTPClient | undefined;
 export declare function configure(opts?: Options): void;
 export declare const deferEnabled: () => boolean;
-export type UnPromise<F> = F extends Promise<infer R> ? R : F;
-export type DelayString = `${string}${Units}`;
+export declare function getExecution(id: string): Promise<FetchExecutionResponse>;
+export declare type UnPromise<F> = F extends Promise<infer R> ? R : F;
+export declare type DelayString = `${string}${Units}`;
 export interface Metadata {
@@ -29,7 +21,6 @@ [key: string]: string;
 }
-export type DeferRetFnParameters<F extends (...args: any | undefined) => Promise<any>> = [...first: Parameters<F>, options: DeferExecutionOptions];
-type Enumerate<N extends number, Acc extends number[] = []> = Acc["length"] extends N ? Acc[number] : Enumerate<N, [...Acc, Acc["length"]]>;
-type Range<F extends number, T extends number> = Exclude<Enumerate<T>, Enumerate<F>>;
-export type Concurrency = Range<0, 51>;
-export type NextRouteString = `/api/${string}`;
+export declare type DeferRetFnParameters<F extends (...args: any | undefined) => Promise<any>> = [...first: Parameters<F>, options: DeferExecutionOptions];
+declare type Enumerate<N extends number, Acc extends number[] = []> = Acc["length"] extends N ? Acc[number] : Enumerate<N, [...Acc, Acc["length"]]>;
+declare type Range<F extends number, T extends number> = Exclude<Enumerate<T>, Enumerate<F>>;
+export declare type Concurrency = Range<0, 51>;
 export interface HasDeferMetadata {
@@ -41,2 +32,3 @@ __metadata: {
         concurrency?: Concurrency | undefined;
+        maxDuration?: number | undefined;
     };
@@ -104,1 +96,2 @@ }
 export declare const awaitResult: DeferAwaitResult;
+export {};

typings/version.d.ts

@@ -1,2 +0,2 @@
-declare const _default: "1.6.0-alpha-20230627172525-6f08bfa";
+declare const _default: "1.6.0-alpha-20230628182657-a7b1727";
 export default _default;

No alert changes

Improved metrics

Dependency count

3

decreased by-40%

Number of medium supply chain risk alerts

1

decreased by-80%

Worsened metrics

Total package byte prevSize

50643

decreased by-20.26%

Number of package files

32

decreased by-27.27%

Lines of code

1206

decreased by-18.18%

Dependency changes

• + Added@fastify/busboy@2.1.1(transitive)

• + Added@peculiar/asn1-schema@2.3.15(transitive)

• + Added@peculiar/json-schema@1.1.12(transitive)

• + Added@peculiar/webcrypto@1.5.0(transitive)

• + Added@whatwg-node/fetch@0.2.9(transitive)

• + Addedabort-controller@3.0.0(transitive)

• + Addedasn1js@3.0.5(transitive)

• + Addedevent-target-polyfill@0.0.3(transitive)

• + Addedevent-target-shim@5.0.1(transitive)

• + Addedform-data-encoder@1.9.0(transitive)

• + Addedformdata-node@4.4.1(transitive)

• + Addednode-domexception@1.0.0(transitive)

• + Addednode-fetch@2.7.0(transitive)

• + Addedpvtsutils@1.3.6(transitive)

• + Addedpvutils@1.1.3(transitive)

• + Addedtr46@0.0.3(transitive)

• + Addedundici@5.28.5(transitive)

• + Addedweb-streams-polyfill@3.3.34.0.0-beta.3(transitive)

• + Addedwebcrypto-core@1.8.1(transitive)

• + Addedwebidl-conversions@3.0.1(transitive)

• + Addedwhatwg-url@5.0.0(transitive)

• - Removed@kamilkisiela/fast-url-parser@1.1.4(transitive)

• - Removed@next/env@13.5.8(transitive)

• - Removed@next/swc-darwin-arm64@13.5.8(transitive)

• - Removed@next/swc-darwin-x64@13.5.8(transitive)

• - Removed@next/swc-linux-arm64-gnu@13.5.8(transitive)

• - Removed@next/swc-linux-arm64-musl@13.5.8(transitive)

• - Removed@next/swc-linux-x64-gnu@13.5.8(transitive)

• - Removed@next/swc-linux-x64-musl@13.5.8(transitive)

• - Removed@next/swc-win32-arm64-msvc@13.5.8(transitive)

• - Removed@next/swc-win32-ia32-msvc@13.5.8(transitive)

• - Removed@next/swc-win32-x64-msvc@13.5.8(transitive)

• - Removed@swc/helpers@0.5.2(transitive)

• - Removed@whatwg-node/fetch@0.9.23(transitive)

• - Removed@whatwg-node/node-fetch@0.6.0(transitive)

• - Removedcaniuse-lite@1.0.30001695(transitive)

• - Removedclient-only@0.0.1(transitive)

• - Removedfast-decode-uri-component@1.0.1(transitive)

• - Removedfast-querystring@1.1.2(transitive)

• - Removedglob-to-regexp@0.4.1(transitive)

• - Removedgraceful-fs@4.2.11(transitive)

• - Removedjs-tokens@4.0.0(transitive)

• - Removedloose-envify@1.4.0(transitive)

• - Removednanoid@3.3.8(transitive)

• - Removednext@13.5.8(transitive)

• - Removedpicocolors@1.1.1(transitive)

• - Removedpostcss@8.4.31(transitive)

• - Removedreact@18.3.1(transitive)

• - Removedreact-dom@18.3.1(transitive)

• - Removedscheduler@0.23.2(transitive)

• - Removedsource-map-js@1.2.1(transitive)

• - Removedstyled-jsx@5.1.1(transitive)

• - Removedurlpattern-polyfill@10.0.0(transitive)

• - Removedwatchpack@2.4.0(transitive)

• Updated@whatwg-node/fetch@^0.2.9