aboutsummaryrefslogtreecommitdiffstats
path: root/vanilla/node_modules/vitest/dist/chunks/worker.d.Dyxm8DEL.d.ts
diff options
context:
space:
mode:
Diffstat (limited to 'vanilla/node_modules/vitest/dist/chunks/worker.d.Dyxm8DEL.d.ts')
-rw-r--r--vanilla/node_modules/vitest/dist/chunks/worker.d.Dyxm8DEL.d.ts255
1 files changed, 255 insertions, 0 deletions
diff --git a/vanilla/node_modules/vitest/dist/chunks/worker.d.Dyxm8DEL.d.ts b/vanilla/node_modules/vitest/dist/chunks/worker.d.Dyxm8DEL.d.ts
new file mode 100644
index 0000000..3177880
--- /dev/null
+++ b/vanilla/node_modules/vitest/dist/chunks/worker.d.Dyxm8DEL.d.ts
@@ -0,0 +1,255 @@
+import { FileSpecification, Task, CancelReason } from '@vitest/runner';
+import { EvaluatedModules } from 'vite/module-runner';
+import { S as SerializedConfig } from './config.d.Cy95HiCx.js';
+import { E as Environment } from './environment.d.CrsxCzP1.js';
+import { R as RuntimeRPC, a as RunnerRPC } from './rpc.d.RH3apGEf.js';
+
+//#region src/messages.d.ts
+declare const TYPE_REQUEST: "q";
+interface RpcRequest {
+ /**
+ * Type
+ */
+ t: typeof TYPE_REQUEST;
+ /**
+ * ID
+ */
+ i?: string;
+ /**
+ * Method
+ */
+ m: string;
+ /**
+ * Arguments
+ */
+ a: any[];
+ /**
+ * Optional
+ */
+ o?: boolean;
+}
+//#endregion
+//#region src/utils.d.ts
+type ArgumentsType<T> = T extends ((...args: infer A) => any) ? A : never;
+type ReturnType<T> = T extends ((...args: any) => infer R) ? R : never;
+type Thenable<T> = T | PromiseLike<T>;
+//#endregion
+//#region src/main.d.ts
+type PromisifyFn<T> = ReturnType<T> extends Promise<any> ? T : (...args: ArgumentsType<T>) => Promise<Awaited<ReturnType<T>>>;
+type BirpcResolver<This> = (this: This, name: string, resolved: (...args: unknown[]) => unknown) => Thenable<((...args: any[]) => any) | undefined>;
+interface ChannelOptions {
+ /**
+ * Function to post raw message
+ */
+ post: (data: any, ...extras: any[]) => Thenable<any>;
+ /**
+ * Listener to receive raw message
+ */
+ on: (fn: (data: any, ...extras: any[]) => void) => Thenable<any>;
+ /**
+ * Clear the listener when `$close` is called
+ */
+ off?: (fn: (data: any, ...extras: any[]) => void) => Thenable<any>;
+ /**
+ * Custom function to serialize data
+ *
+ * by default it passes the data as-is
+ */
+ serialize?: (data: any) => any;
+ /**
+ * Custom function to deserialize data
+ *
+ * by default it passes the data as-is
+ */
+ deserialize?: (data: any) => any;
+ /**
+ * Call the methods with the RPC context or the original functions object
+ */
+ bind?: 'rpc' | 'functions';
+ /**
+ * Custom meta data to attached to the RPC instance's `$meta` property
+ */
+ meta?: any;
+}
+interface EventOptions<RemoteFunctions extends object = Record<string, unknown>, LocalFunctions extends object = Record<string, unknown>, Proxify extends boolean = true> {
+ /**
+ * Names of remote functions that do not need response.
+ */
+ eventNames?: (keyof RemoteFunctions)[];
+ /**
+ * Maximum timeout for waiting for response, in milliseconds.
+ *
+ * @default 60_000
+ */
+ timeout?: number;
+ /**
+ * Whether to proxy the remote functions.
+ *
+ * When `proxify` is false, calling the remote function
+ * with `rpc.$call('method', ...args)` instead of `rpc.method(...args)`
+ * explicitly is required.
+ *
+ * @default true
+ */
+ proxify?: Proxify;
+ /**
+ * Custom resolver to resolve function to be called
+ *
+ * For advanced use cases only
+ */
+ resolver?: BirpcResolver<BirpcReturn<RemoteFunctions, LocalFunctions, Proxify>>;
+ /**
+ * Hook triggered before an event is sent to the remote
+ *
+ * @param req - Request parameters
+ * @param next - Function to continue the request
+ * @param resolve - Function to resolve the response directly
+ */
+ onRequest?: (this: BirpcReturn<RemoteFunctions, LocalFunctions, Proxify>, req: RpcRequest, next: (req?: RpcRequest) => Promise<any>, resolve: (res: any) => void) => void | Promise<void>;
+ /**
+ * Custom error handler for errors occurred in local functions being called
+ *
+ * @returns `true` to prevent the error from being thrown
+ */
+ onFunctionError?: (this: BirpcReturn<RemoteFunctions, LocalFunctions, Proxify>, error: Error, functionName: string, args: any[]) => boolean | void;
+ /**
+ * Custom error handler for errors occurred during serialization or messsaging
+ *
+ * @returns `true` to prevent the error from being thrown
+ */
+ onGeneralError?: (this: BirpcReturn<RemoteFunctions, LocalFunctions, Proxify>, error: Error, functionName?: string, args?: any[]) => boolean | void;
+ /**
+ * Custom error handler for timeouts
+ *
+ * @returns `true` to prevent the error from being thrown
+ */
+ onTimeoutError?: (this: BirpcReturn<RemoteFunctions, LocalFunctions, Proxify>, functionName: string, args: any[]) => boolean | void;
+}
+type BirpcOptions<RemoteFunctions extends object = Record<string, unknown>, LocalFunctions extends object = Record<string, unknown>, Proxify extends boolean = true> = EventOptions<RemoteFunctions, LocalFunctions, Proxify> & ChannelOptions;
+type BirpcFn<T> = PromisifyFn<T> & {
+ /**
+ * Send event without asking for response
+ */
+ asEvent: (...args: ArgumentsType<T>) => Promise<void>;
+};
+interface BirpcReturnBuiltin<RemoteFunctions, LocalFunctions = Record<string, unknown>> {
+ /**
+ * Raw functions object
+ */
+ $functions: LocalFunctions;
+ /**
+ * Whether the RPC is closed
+ */
+ readonly $closed: boolean;
+ /**
+ * Custom meta data attached to the RPC instance
+ */
+ readonly $meta: any;
+ /**
+ * Close the RPC connection
+ */
+ $close: (error?: Error) => void;
+ /**
+ * Reject pending calls
+ */
+ $rejectPendingCalls: (handler?: PendingCallHandler) => Promise<void>[];
+ /**
+ * Call the remote function and wait for the result.
+ * An alternative to directly calling the function
+ */
+ $call: <K$1 extends keyof RemoteFunctions>(method: K$1, ...args: ArgumentsType<RemoteFunctions[K$1]>) => Promise<Awaited<ReturnType<RemoteFunctions[K$1]>>>;
+ /**
+ * Same as `$call`, but returns `undefined` if the function is not defined on the remote side.
+ */
+ $callOptional: <K$1 extends keyof RemoteFunctions>(method: K$1, ...args: ArgumentsType<RemoteFunctions[K$1]>) => Promise<Awaited<ReturnType<RemoteFunctions[K$1]> | undefined>>;
+ /**
+ * Send event without asking for response
+ */
+ $callEvent: <K$1 extends keyof RemoteFunctions>(method: K$1, ...args: ArgumentsType<RemoteFunctions[K$1]>) => Promise<void>;
+ /**
+ * Call the remote function with the raw options.
+ */
+ $callRaw: (options: {
+ method: string;
+ args: unknown[];
+ event?: boolean;
+ optional?: boolean;
+ }) => Promise<Awaited<ReturnType<any>>[]>;
+}
+type ProxifiedRemoteFunctions<RemoteFunctions extends object = Record<string, unknown>> = { [K in keyof RemoteFunctions]: BirpcFn<RemoteFunctions[K]> };
+type BirpcReturn<RemoteFunctions extends object = Record<string, unknown>, LocalFunctions extends object = Record<string, unknown>, Proxify extends boolean = true> = Proxify extends true ? ProxifiedRemoteFunctions<RemoteFunctions> & BirpcReturnBuiltin<RemoteFunctions, LocalFunctions> : BirpcReturnBuiltin<RemoteFunctions, LocalFunctions>;
+type PendingCallHandler = (options: Pick<PromiseEntry, 'method' | 'reject'>) => void | Promise<void>;
+interface PromiseEntry {
+ resolve: (arg: any) => void;
+ reject: (error: any) => void;
+ method: string;
+ timeoutId?: ReturnType<typeof setTimeout>;
+}
+declare const setTimeout: typeof globalThis.setTimeout;
+
+type WorkerRPC = BirpcReturn<RuntimeRPC, RunnerRPC>;
+interface ContextTestEnvironment {
+ name: string;
+ options: Record<string, any> | null;
+}
+interface WorkerTestEnvironment {
+ name: string;
+ options: Record<string, any> | null;
+}
+type TestExecutionMethod = "run" | "collect";
+interface WorkerExecuteContext {
+ files: FileSpecification[];
+ providedContext: Record<string, any>;
+ invalidates?: string[];
+ environment: ContextTestEnvironment;
+ /** Exposed to test runner as `VITEST_WORKER_ID`. Value is unique per each isolated worker. */
+ workerId: number;
+}
+interface ContextRPC {
+ pool: string;
+ config: SerializedConfig;
+ projectName: string;
+ environment: WorkerTestEnvironment;
+ rpc: WorkerRPC;
+ files: FileSpecification[];
+ providedContext: Record<string, any>;
+ invalidates?: string[];
+ /** Exposed to test runner as `VITEST_WORKER_ID`. Value is unique per each isolated worker. */
+ workerId: number;
+}
+interface WorkerSetupContext {
+ environment: WorkerTestEnvironment;
+ pool: string;
+ config: SerializedConfig;
+ projectName: string;
+ rpc: WorkerRPC;
+}
+interface WorkerGlobalState {
+ ctx: ContextRPC;
+ config: SerializedConfig;
+ rpc: WorkerRPC;
+ current?: Task;
+ filepath?: string;
+ metaEnv: {
+ [key: string]: any;
+ BASE_URL: string;
+ MODE: string;
+ DEV: boolean;
+ PROD: boolean;
+ SSR: boolean;
+ };
+ environment: Environment;
+ evaluatedModules: EvaluatedModules;
+ resolvingModules: Set<string>;
+ moduleExecutionInfo: Map<string, any>;
+ onCancel: (listener: (reason: CancelReason) => unknown) => void;
+ onCleanup: (listener: () => unknown) => void;
+ providedContext: Record<string, any>;
+ durations: {
+ environment: number;
+ prepare: number;
+ };
+ onFilterStackTrace?: (trace: string) => string;
+}
+
+export type { BirpcOptions as B, ContextRPC as C, TestExecutionMethod as T, WorkerGlobalState as W, WorkerSetupContext as a, BirpcReturn as b, ContextTestEnvironment as c, WorkerExecuteContext as d, WorkerTestEnvironment as e };