AK-21/Graphite-Industrial-Intelligence

1import { TRPCConnectionState } from "./subscriptions.d-Dlr1nWGD.mjs";2import { FetchEsque, HTTPHeaders, NativeFetchEsque, Operation, OperationContext, OperationLink, OperationResultEnvelope, OperationResultObservable, OperationResultObserver, TRPCClientError, TRPCClientErrorBase, TRPCClientErrorLike, TRPCClientRuntime, TRPCFetch, TRPCLink, TRPCProcedureOptions, isFormData, isNonJsonSerializable, isOctetType, isTRPCClientError } from "./types.d-sRNtuQA-.mjs";3import { TransformerOptions } from "./unstable-internals.d-BOmV7EK1.mjs";4import "./httpUtils.d-yYSKGhiS.mjs";5import { HTTPBatchLinkOptions, httpBatchLink } from "./httpBatchLink.d-B6vCg-F-.mjs";6import { HTTPLinkOptions, httpLink } from "./httpLink.d-CVOTlkUT.mjs";7import { LoggerLinkOptions, loggerLink } from "./loggerLink.d-DBRq_5Gd.mjs";8import { splitLink } from "./splitLink.d-BKr9eE0o.mjs";9import { Encoder, TRPCWebSocketClient, UrlOptionsWithConnectionParams, WebSocketClientOptions, WebSocketLinkOptions, createWSClient, jsonEncoder, wsLink } from "./wsLink.d-DCqbZKOH.mjs";10import { Unsubscribable } from "@trpc/server/observable";11import { AnyClientTypes, AnyProcedure, AnyRouter, ErrorHandlerOptions, EventSourceLike, InferrableClientTypes, ProcedureType, RouterRecord, TypeError, inferAsyncIterableYield, inferClientTypes, inferProcedureInput, inferRouterContext, inferTransformedProcedureOutput } from "@trpc/server/unstable-core-do-not-import";12import { AnyRouter as AnyRouter$1 } from "@trpc/server";13 14//#region src/internals/TRPCUntypedClient.d.ts15interface TRPCRequestOptions {16  /**17   * Pass additional context to links18   */19  context?: OperationContext;20  signal?: AbortSignal;21}22interface TRPCSubscriptionObserver<TValue, TError> {23  onStarted: (opts: {24    context: OperationContext | undefined;25  }) => void;26  onData: (value: inferAsyncIterableYield<TValue>) => void;27  onError: (err: TError) => void;28  onStopped: () => void;29  onComplete: () => void;30  onConnectionStateChange: (state: TRPCConnectionState<TError>) => void;31}32/** @internal */33type CreateTRPCClientOptions<TRouter extends InferrableClientTypes> = {34  links: TRPCLink<TRouter>[];35  transformer?: TypeError<'The transformer property has moved to httpLink/httpBatchLink/wsLink'>;36};37declare class TRPCUntypedClient<TInferrable extends InferrableClientTypes> {38  private readonly links;39  readonly runtime: TRPCClientRuntime;40  private requestId;41  constructor(opts: CreateTRPCClientOptions<TInferrable>);42  private $request;43  private requestAsPromise;44  query(path: string, input?: unknown, opts?: TRPCRequestOptions): Promise<unknown>;45  mutation(path: string, input?: unknown, opts?: TRPCRequestOptions): Promise<unknown>;46  subscription(path: string, input: unknown, opts: Partial<TRPCSubscriptionObserver<unknown, TRPCClientError<AnyRouter>>> & TRPCRequestOptions): Unsubscribable;47}48//# sourceMappingURL=TRPCUntypedClient.d.ts.map49//#endregion50//#region src/createTRPCUntypedClient.d.ts51declare function createTRPCUntypedClient<TRouter extends AnyRouter>(opts: CreateTRPCClientOptions<TRouter>): TRPCUntypedClient<TRouter>;52//#endregion53//#region src/createTRPCClient.d.ts54/**55 * @public56 * @deprecated use {@link TRPCClient} instead, will be removed in v1257 **/58type inferRouterClient<TRouter extends AnyRouter> = TRPCClient<TRouter>;59/**60 * @public61 * @deprecated use {@link TRPCClient} instead, will be removed in v1262 **/63type CreateTRPCClient<TRouter extends AnyRouter> = TRPCClient<TRouter>;64declare const untypedClientSymbol: unique symbol;65/**66 * @public67 **/68type TRPCClient<TRouter extends AnyRouter> = DecoratedProcedureRecord<{69  transformer: TRouter['_def']['_config']['$types']['transformer'];70  errorShape: TRouter['_def']['_config']['$types']['errorShape'];71}, TRouter['_def']['record']> & {72  [untypedClientSymbol]: TRPCUntypedClient<TRouter>;73};74/** @internal */75type TRPCResolverDef = {76  input: any;77  output: any;78  transformer: boolean;79  errorShape: any;80};81type coerceAsyncGeneratorToIterable<T> = T extends AsyncGenerator<infer $T, infer $Return, infer $Next> ? AsyncIterable<$T, $Return, $Next> : T;82/** @internal */83type Resolver<TDef extends TRPCResolverDef> = (input: TDef['input'], opts?: TRPCProcedureOptions) => Promise<coerceAsyncGeneratorToIterable<TDef['output']>>;84/** @internal */85type SubscriptionResolver<TDef extends TRPCResolverDef> = (input: TDef['input'], opts: Partial<TRPCSubscriptionObserver<TDef['output'], TRPCClientError<TDef>>> & TRPCProcedureOptions) => Unsubscribable;86type DecorateProcedure<TType extends ProcedureType, TDef extends TRPCResolverDef> = TType extends 'query' ? {87  query: Resolver<TDef>;88} : TType extends 'mutation' ? {89  mutate: Resolver<TDef>;90} : TType extends 'subscription' ? {91  subscribe: SubscriptionResolver<TDef>;92} : never;93/**94 * @internal95 */96type DecoratedProcedureRecord<TRoot extends InferrableClientTypes, TRecord extends RouterRecord> = { [TKey in keyof TRecord]: TRecord[TKey] extends infer $Value ? $Value extends AnyProcedure ? DecorateProcedure<$Value['_def']['type'], {97  input: inferProcedureInput<$Value>;98  output: inferTransformedProcedureOutput<inferClientTypes<TRoot>, $Value>;99  errorShape: inferClientTypes<TRoot>['errorShape'];100  transformer: inferClientTypes<TRoot>['transformer'];101}> : $Value extends RouterRecord ? DecoratedProcedureRecord<TRoot, $Value> : never : never };102/** @internal */103declare const clientCallTypeToProcedureType: (clientCallType: string) => ProcedureType;104/**105 * @internal106 */107declare function createTRPCClientProxy<TRouter extends AnyRouter>(client: TRPCUntypedClient<TRouter>): TRPCClient<TRouter>;108declare function createTRPCClient<TRouter extends AnyRouter>(opts: CreateTRPCClientOptions<TRouter>): TRPCClient<TRouter>;109/**110 * Get an untyped client from a proxy client111 * @internal112 */113declare function getUntypedClient<TRouter extends AnyRouter>(client: TRPCClient<TRouter>): TRPCUntypedClient<TRouter>;114//#endregion115//#region src/getFetch.d.ts116declare function getFetch(customFetchImpl?: FetchEsque | NativeFetchEsque): FetchEsque;117//# sourceMappingURL=getFetch.d.ts.map118 119//#endregion120//#region src/links/httpBatchStreamLink.d.ts121type HTTPBatchStreamLinkOptions<TRoot extends AnyClientTypes> = HTTPBatchLinkOptions<TRoot> & {122  /**123   * Which header to use to signal the server that the client wants a streaming response.124   * - `'trpc-accept'` (default): sends `trpc-accept: application/jsonl` header125   * - `'accept'`: sends `Accept: application/jsonl` header, which can avoid CORS preflight for cross-origin streaming queries. Be aware that `application/jsonl` is not an official MIME type and so this is not completely spec-compliant - you should test that your infrastructure supports this value.126   * @default 'trpc-accept'127   */128  streamHeader?: 'trpc-accept' | 'accept';129};130/**131 * @see https://trpc.io/docs/client/links/httpBatchStreamLink132 */133declare function httpBatchStreamLink<TRouter extends AnyRouter$1>(opts: HTTPBatchStreamLinkOptions<TRouter['_def']['_config']['$types']>): TRPCLink<TRouter>;134/**135 * @deprecated use {@link httpBatchStreamLink} instead136 */137declare const unstable_httpBatchStreamLink: typeof httpBatchStreamLink;138//# sourceMappingURL=httpBatchStreamLink.d.ts.map139//#endregion140//#region src/links/httpSubscriptionLink.d.ts141type HTTPSubscriptionLinkOptions<TRoot extends AnyClientTypes, TEventSource extends EventSourceLike.AnyConstructor = typeof EventSource> = {142  /**143   * EventSource ponyfill144   */145  EventSource?: TEventSource;146  /**147   * EventSource options or a callback that returns them148   */149  eventSourceOptions?: EventSourceLike.InitDictOf<TEventSource> | ((opts: {150    op: Operation;151  }) => EventSourceLike.InitDictOf<TEventSource> | Promise<EventSourceLike.InitDictOf<TEventSource>>);152} & TransformerOptions<TRoot> & UrlOptionsWithConnectionParams;153/**154 * @see https://trpc.io/docs/client/links/httpSubscriptionLink155 */156declare function httpSubscriptionLink<TInferrable extends InferrableClientTypes, TEventSource extends EventSourceLike.AnyConstructor>(opts: HTTPSubscriptionLinkOptions<inferClientTypes<TInferrable>, TEventSource>): TRPCLink<TInferrable>;157/**158 * @deprecated use {@link httpSubscriptionLink} instead159 */160declare const unstable_httpSubscriptionLink: typeof httpSubscriptionLink;161//#endregion162//#region src/links/retryLink.d.ts163interface RetryLinkOptions<TInferrable extends InferrableClientTypes> {164  /**165   * The retry function166   */167  retry: (opts: RetryFnOptions<TInferrable>) => boolean;168  /**169   * The delay between retries in ms (defaults to 0)170   */171  retryDelayMs?: (attempt: number) => number;172}173interface RetryFnOptions<TInferrable extends InferrableClientTypes> {174  /**175   * The operation that failed176   */177  op: Operation;178  /**179   * The error that occurred180   */181  error: TRPCClientError<TInferrable>;182  /**183   * The number of attempts that have been made (including the first call)184   */185  attempts: number;186}187/**188 * @see https://trpc.io/docs/v11/client/links/retryLink189 */190declare function retryLink<TInferrable extends InferrableClientTypes>(opts: RetryLinkOptions<TInferrable>): TRPCLink<TInferrable>;191//#endregion192//#region src/links/localLink.d.ts193type LocalLinkOptions<TRouter extends AnyRouter> = {194  router: TRouter;195  createContext: () => Promise<inferRouterContext<TRouter>>;196  onError?: (opts: ErrorHandlerOptions<inferRouterContext<TRouter>>) => void;197} & TransformerOptions<inferClientTypes<TRouter>>;198/**199 * localLink is a terminating link that allows you to make tRPC procedure calls directly in your application without going through HTTP.200 *201 * @see https://trpc.io/docs/links/localLink202 */203declare function unstable_localLink<TRouter extends AnyRouter>(opts: LocalLinkOptions<TRouter>): TRPCLink<TRouter>;204/**205 * @deprecated Renamed to `unstable_localLink`. This alias will be removed in a future major release.206 */207declare const experimental_localLink: typeof unstable_localLink;208//# sourceMappingURL=localLink.d.ts.map209 210//#endregion211export { CreateTRPCClient, CreateTRPCClientOptions, Encoder, HTTPBatchLinkOptions, HTTPBatchStreamLinkOptions, HTTPHeaders, HTTPLinkOptions, LocalLinkOptions, LoggerLinkOptions, Operation, OperationContext, OperationLink, OperationResultEnvelope, OperationResultObservable, OperationResultObserver, Resolver, SubscriptionResolver, TRPCClient, TRPCClientError, TRPCClientErrorBase, TRPCClientErrorLike, TRPCClientRuntime, TRPCFetch, TRPCLink, TRPCProcedureOptions, TRPCRequestOptions, TRPCResolverDef, TRPCUntypedClient, TRPCWebSocketClient, WebSocketClientOptions, WebSocketLinkOptions, clientCallTypeToProcedureType, createTRPCClient, createTRPCClientProxy, createTRPCClient as createTRPCProxyClient, createTRPCUntypedClient, createWSClient, experimental_localLink, getFetch, getUntypedClient, httpBatchLink, httpBatchStreamLink, httpLink, httpSubscriptionLink, inferRouterClient, inferRouterClient as inferRouterProxyClient, isFormData, isNonJsonSerializable, isOctetType, isTRPCClientError, jsonEncoder, loggerLink, retryLink, splitLink, unstable_httpBatchStreamLink, unstable_httpSubscriptionLink, unstable_localLink, wsLink };212//# sourceMappingURL=index.d.mts.map