AK-21/Graphite-Industrial-Intelligence
0
1const require_chunk = require('./chunk-DWy1uDak.cjs');2const require_splitLink = require('./splitLink-BMgxggng.cjs');3const require_objectSpread2$1 = require('./objectSpread2-Bsvh_OqM.cjs');4const require_TRPCClientError = require('./TRPCClientError-CQrTQLrk.cjs');5const require_httpUtils = require('./httpUtils-wv2o-njD.cjs');6const require_httpLink = require('./httpLink-B8Iv31Ee.cjs');7const require_httpBatchLink = require('./httpBatchLink-BGZRsGNf.cjs');8const require_unstable_internals = require('./unstable-internals-M84gUQCV.cjs');9const require_loggerLink = require('./loggerLink-CuYvRzyH.cjs');10const require_wsLink = require('./wsLink-CobRSm6C.cjs');11const __trpc_server_observable = require_chunk.__toESM(require("@trpc/server/observable"));12const __trpc_server_unstable_core_do_not_import = require_chunk.__toESM(require("@trpc/server/unstable-core-do-not-import"));13const __trpc_server = require_chunk.__toESM(require("@trpc/server"));14const __trpc_server_rpc = require_chunk.__toESM(require("@trpc/server/rpc"));15 16//#region src/internals/TRPCUntypedClient.ts17var import_defineProperty = require_chunk.__toESM(require_objectSpread2$1.require_defineProperty(), 1);18var import_objectSpread2$4 = require_chunk.__toESM(require_objectSpread2$1.require_objectSpread2(), 1);19var TRPCUntypedClient = class {20 constructor(opts) {21 (0, import_defineProperty.default)(this, "links", void 0);22 (0, import_defineProperty.default)(this, "runtime", void 0);23 (0, import_defineProperty.default)(this, "requestId", void 0);24 this.requestId = 0;25 this.runtime = {};26 this.links = opts.links.map((link) => link(this.runtime));27 }28 $request(opts) {29 var _opts$context;30 const chain$ = require_splitLink.createChain({31 links: this.links,32 op: (0, import_objectSpread2$4.default)((0, import_objectSpread2$4.default)({}, opts), {}, {33 context: (_opts$context = opts.context) !== null && _opts$context !== void 0 ? _opts$context : {},34 id: ++this.requestId35 })36 });37 return chain$.pipe((0, __trpc_server_observable.share)());38 }39 async requestAsPromise(opts) {40 var _this = this;41 try {42 const req$ = _this.$request(opts);43 const envelope = await (0, __trpc_server_observable.observableToPromise)(req$);44 const data = envelope.result.data;45 return data;46 } catch (err) {47 throw require_TRPCClientError.TRPCClientError.from(err);48 }49 }50 query(path, input, opts) {51 return this.requestAsPromise({52 type: "query",53 path,54 input,55 context: opts === null || opts === void 0 ? void 0 : opts.context,56 signal: opts === null || opts === void 0 ? void 0 : opts.signal57 });58 }59 mutation(path, input, opts) {60 return this.requestAsPromise({61 type: "mutation",62 path,63 input,64 context: opts === null || opts === void 0 ? void 0 : opts.context,65 signal: opts === null || opts === void 0 ? void 0 : opts.signal66 });67 }68 subscription(path, input, opts) {69 const observable$ = this.$request({70 type: "subscription",71 path,72 input,73 context: opts.context,74 signal: opts.signal75 });76 return observable$.subscribe({77 next(envelope) {78 switch (envelope.result.type) {79 case "state": {80 var _opts$onConnectionSta;81 (_opts$onConnectionSta = opts.onConnectionStateChange) === null || _opts$onConnectionSta === void 0 || _opts$onConnectionSta.call(opts, envelope.result);82 break;83 }84 case "started": {85 var _opts$onStarted;86 (_opts$onStarted = opts.onStarted) === null || _opts$onStarted === void 0 || _opts$onStarted.call(opts, { context: envelope.context });87 break;88 }89 case "stopped": {90 var _opts$onStopped;91 (_opts$onStopped = opts.onStopped) === null || _opts$onStopped === void 0 || _opts$onStopped.call(opts);92 break;93 }94 case "data":95 case void 0: {96 var _opts$onData;97 (_opts$onData = opts.onData) === null || _opts$onData === void 0 || _opts$onData.call(opts, envelope.result.data);98 break;99 }100 }101 },102 error(err) {103 var _opts$onError;104 (_opts$onError = opts.onError) === null || _opts$onError === void 0 || _opts$onError.call(opts, err);105 },106 complete() {107 var _opts$onComplete;108 (_opts$onComplete = opts.onComplete) === null || _opts$onComplete === void 0 || _opts$onComplete.call(opts);109 }110 });111 }112};113 114//#endregion115//#region src/createTRPCUntypedClient.ts116function createTRPCUntypedClient(opts) {117 return new TRPCUntypedClient(opts);118}119 120//#endregion121//#region src/createTRPCClient.ts122const untypedClientSymbol = Symbol.for("trpc_untypedClient");123const clientCallTypeMap = {124 query: "query",125 mutate: "mutation",126 subscribe: "subscription"127};128/** @internal */129const clientCallTypeToProcedureType = (clientCallType) => {130 return clientCallTypeMap[clientCallType];131};132/**133* @internal134*/135function createTRPCClientProxy(client) {136 const proxy = (0, __trpc_server_unstable_core_do_not_import.createRecursiveProxy)(({ path, args }) => {137 const pathCopy = [...path];138 const procedureType = clientCallTypeToProcedureType(pathCopy.pop());139 const fullPath = pathCopy.join(".");140 return client[procedureType](fullPath, ...args);141 });142 return (0, __trpc_server_unstable_core_do_not_import.createFlatProxy)((key) => {143 if (key === untypedClientSymbol) return client;144 return proxy[key];145 });146}147function createTRPCClient(opts) {148 const client = new TRPCUntypedClient(opts);149 const proxy = createTRPCClientProxy(client);150 return proxy;151}152/**153* Get an untyped client from a proxy client154* @internal155*/156function getUntypedClient(client) {157 return client[untypedClientSymbol];158}159 160//#endregion161//#region src/links/httpBatchStreamLink.ts162var import_objectSpread2$3 = require_chunk.__toESM(require_objectSpread2$1.require_objectSpread2(), 1);163/**164* @see https://trpc.io/docs/client/links/httpBatchStreamLink165*/166function httpBatchStreamLink(opts) {167 var _opts$maxURLLength, _opts$maxItems;168 const resolvedOpts = require_httpUtils.resolveHTTPLinkOptions(opts);169 const maxURLLength = (_opts$maxURLLength = opts.maxURLLength) !== null && _opts$maxURLLength !== void 0 ? _opts$maxURLLength : Infinity;170 const maxItems = (_opts$maxItems = opts.maxItems) !== null && _opts$maxItems !== void 0 ? _opts$maxItems : Infinity;171 return () => {172 const batchLoader = (type) => {173 return {174 validate(batchOps) {175 if (maxURLLength === Infinity && maxItems === Infinity) return true;176 if (batchOps.length > maxItems) return false;177 const path = batchOps.map((op) => op.path).join(",");178 const inputs = batchOps.map((op) => op.input);179 const url = require_httpUtils.getUrl((0, import_objectSpread2$3.default)((0, import_objectSpread2$3.default)({}, resolvedOpts), {}, {180 type,181 path,182 inputs,183 signal: null184 }));185 return url.length <= maxURLLength;186 },187 async fetch(batchOps) {188 var _opts$streamHeader;189 const path = batchOps.map((op) => op.path).join(",");190 const inputs = batchOps.map((op) => op.input);191 const batchSignals = require_httpBatchLink.allAbortSignals(...batchOps.map((op) => op.signal));192 const abortController = new AbortController();193 const responsePromise = require_httpUtils.fetchHTTPResponse((0, import_objectSpread2$3.default)((0, import_objectSpread2$3.default)({}, resolvedOpts), {}, {194 signal: require_httpBatchLink.raceAbortSignals(batchSignals, abortController.signal),195 type,196 contentTypeHeader: "application/json",197 trpcAcceptHeader: "application/jsonl",198 trpcAcceptHeaderKey: (_opts$streamHeader = opts.streamHeader) !== null && _opts$streamHeader !== void 0 ? _opts$streamHeader : "trpc-accept",199 getUrl: require_httpUtils.getUrl,200 getBody: require_httpUtils.getBody,201 inputs,202 path,203 headers() {204 if (!opts.headers) return {};205 if (typeof opts.headers === "function") return opts.headers({ opList: batchOps });206 return opts.headers;207 }208 }));209 const res = await responsePromise;210 if (!res.ok) {211 const json = await res.json();212 if ("error" in json) json.error = resolvedOpts.transformer.output.deserialize(json.error);213 return batchOps.map(() => Promise.resolve({214 json,215 meta: { response: res }216 }));217 }218 const [head] = await (0, __trpc_server_unstable_core_do_not_import.jsonlStreamConsumer)({219 from: res.body,220 deserialize: (data) => resolvedOpts.transformer.output.deserialize(data),221 formatError(opts$1) {222 const error = opts$1.error;223 return require_TRPCClientError.TRPCClientError.from({ error });224 },225 abortController226 });227 const promises = Object.keys(batchOps).map(async (key) => {228 let json = await Promise.resolve(head[key]);229 if ("result" in json) {230 /**231 * Not very pretty, but we need to unwrap nested data as promises232 * Our stream producer will only resolve top-level async values or async values that are directly nested in another async value233 */234 const result = await Promise.resolve(json.result);235 json = { result: { data: await Promise.resolve(result.data) } };236 }237 return {238 json,239 meta: { response: res }240 };241 });242 return promises;243 }244 };245 };246 const query = require_httpBatchLink.dataLoader(batchLoader("query"));247 const mutation = require_httpBatchLink.dataLoader(batchLoader("mutation"));248 const loaders = {249 query,250 mutation251 };252 return ({ op }) => {253 return (0, __trpc_server_observable.observable)((observer) => {254 /* istanbul ignore if -- @preserve */255 if (op.type === "subscription") throw new Error("Subscriptions are unsupported by `httpBatchStreamLink` - use `httpSubscriptionLink` or `wsLink`");256 const loader = loaders[op.type];257 const promise = loader.load(op);258 let _res = void 0;259 promise.then((res) => {260 _res = res;261 if ("error" in res.json) {262 observer.error(require_TRPCClientError.TRPCClientError.from(res.json, { meta: res.meta }));263 return;264 } else if ("result" in res.json) {265 observer.next({266 context: res.meta,267 result: res.json.result268 });269 observer.complete();270 return;271 }272 observer.complete();273 }).catch((err) => {274 observer.error(require_TRPCClientError.TRPCClientError.from(err, { meta: _res === null || _res === void 0 ? void 0 : _res.meta }));275 });276 return () => {};277 });278 };279 };280}281/**282* @deprecated use {@link httpBatchStreamLink} instead283*/284const unstable_httpBatchStreamLink = httpBatchStreamLink;285 286//#endregion287//#region src/internals/inputWithTrackedEventId.ts288var import_objectSpread2$2 = require_chunk.__toESM(require_objectSpread2$1.require_objectSpread2(), 1);289function inputWithTrackedEventId(input, lastEventId) {290 if (!lastEventId) return input;291 if (input != null && typeof input !== "object") return input;292 return (0, import_objectSpread2$2.default)((0, import_objectSpread2$2.default)({}, input !== null && input !== void 0 ? input : {}), {}, { lastEventId });293}294 295//#endregion296//#region ../../node_modules/.pnpm/@oxc-project+runtime@0.72.2/node_modules/@oxc-project/runtime/src/helpers/asyncIterator.js297var require_asyncIterator = require_chunk.__commonJS({ "../../node_modules/.pnpm/@oxc-project+runtime@0.72.2/node_modules/@oxc-project/runtime/src/helpers/asyncIterator.js"(exports, module) {298 function _asyncIterator$1(r) {299 var n, t, o, e = 2;300 for ("undefined" != typeof Symbol && (t = Symbol.asyncIterator, o = Symbol.iterator); e--;) {301 if (t && null != (n = r[t])) return n.call(r);302 if (o && null != (n = r[o])) return new AsyncFromSyncIterator(n.call(r));303 t = "@@asyncIterator", o = "@@iterator";304 }305 throw new TypeError("Object is not async iterable");306 }307 function AsyncFromSyncIterator(r) {308 function AsyncFromSyncIteratorContinuation(r$1) {309 if (Object(r$1) !== r$1) return Promise.reject(new TypeError(r$1 + " is not an object."));310 var n = r$1.done;311 return Promise.resolve(r$1.value).then(function(r$2) {312 return {313 value: r$2,314 done: n315 };316 });317 }318 return AsyncFromSyncIterator = function AsyncFromSyncIterator$1(r$1) {319 this.s = r$1, this.n = r$1.next;320 }, AsyncFromSyncIterator.prototype = {321 s: null,322 n: null,323 next: function next() {324 return AsyncFromSyncIteratorContinuation(this.n.apply(this.s, arguments));325 },326 "return": function _return(r$1) {327 var n = this.s["return"];328 return void 0 === n ? Promise.resolve({329 value: r$1,330 done: !0331 }) : AsyncFromSyncIteratorContinuation(n.apply(this.s, arguments));332 },333 "throw": function _throw(r$1) {334 var n = this.s["return"];335 return void 0 === n ? Promise.reject(r$1) : AsyncFromSyncIteratorContinuation(n.apply(this.s, arguments));336 }337 }, new AsyncFromSyncIterator(r);338 }339 module.exports = _asyncIterator$1, module.exports.__esModule = true, module.exports["default"] = module.exports;340} });341 342//#endregion343//#region src/links/httpSubscriptionLink.ts344var import_asyncIterator = require_chunk.__toESM(require_asyncIterator(), 1);345async function urlWithConnectionParams(opts) {346 let url = await require_wsLink.resultOf(opts.url);347 if (opts.connectionParams) {348 const params = await require_wsLink.resultOf(opts.connectionParams);349 const prefix = url.includes("?") ? "&" : "?";350 url += prefix + "connectionParams=" + encodeURIComponent(JSON.stringify(params));351 }352 return url;353}354/**355* @see https://trpc.io/docs/client/links/httpSubscriptionLink356*/357function httpSubscriptionLink(opts) {358 const transformer = require_unstable_internals.getTransformer(opts.transformer);359 return () => {360 return ({ op }) => {361 return (0, __trpc_server_observable.observable)((observer) => {362 var _opts$EventSource;363 const { type, path, input } = op;364 /* istanbul ignore if -- @preserve */365 if (type !== "subscription") throw new Error("httpSubscriptionLink only supports subscriptions");366 let lastEventId = void 0;367 const ac = new AbortController();368 const signal = require_httpBatchLink.raceAbortSignals(op.signal, ac.signal);369 const eventSourceStream = (0, __trpc_server_unstable_core_do_not_import.sseStreamConsumer)({370 url: async () => require_httpUtils.getUrl({371 transformer,372 url: await urlWithConnectionParams(opts),373 input: inputWithTrackedEventId(input, lastEventId),374 path,375 type,376 signal: null377 }),378 init: () => require_wsLink.resultOf(opts.eventSourceOptions, { op }),379 signal,380 deserialize: (data) => transformer.output.deserialize(data),381 EventSource: (_opts$EventSource = opts.EventSource) !== null && _opts$EventSource !== void 0 ? _opts$EventSource : globalThis.EventSource382 });383 const connectionState = (0, __trpc_server_observable.behaviorSubject)({384 type: "state",385 state: "connecting",386 error: null387 });388 const connectionSub = connectionState.subscribe({ next(state) {389 observer.next({ result: state });390 } });391 (0, __trpc_server_unstable_core_do_not_import.run)(async () => {392 var _iteratorAbruptCompletion = false;393 var _didIteratorError = false;394 var _iteratorError;395 try {396 for (var _iterator = (0, import_asyncIterator.default)(eventSourceStream), _step; _iteratorAbruptCompletion = !(_step = await _iterator.next()).done; _iteratorAbruptCompletion = false) {397 const chunk = _step.value;398 switch (chunk.type) {399 case "ping": break;400 case "data":401 const chunkData = chunk.data;402 let result;403 if (chunkData.id) {404 lastEventId = chunkData.id;405 result = {406 id: chunkData.id,407 data: chunkData408 };409 } else result = { data: chunkData.data };410 observer.next({411 result,412 context: { eventSource: chunk.eventSource }413 });414 break;415 case "connected": {416 observer.next({417 result: { type: "started" },418 context: { eventSource: chunk.eventSource }419 });420 connectionState.next({421 type: "state",422 state: "pending",423 error: null424 });425 break;426 }427 case "serialized-error": {428 const error = require_TRPCClientError.TRPCClientError.from({ error: chunk.error });429 if (__trpc_server_unstable_core_do_not_import.retryableRpcCodes.includes(chunk.error.code)) {430 connectionState.next({431 type: "state",432 state: "connecting",433 error434 });435 break;436 }437 throw error;438 }439 case "connecting": {440 const lastState = connectionState.get();441 const error = chunk.event && require_TRPCClientError.TRPCClientError.from(chunk.event);442 if (!error && lastState.state === "connecting") break;443 connectionState.next({444 type: "state",445 state: "connecting",446 error447 });448 break;449 }450 case "timeout": connectionState.next({451 type: "state",452 state: "connecting",453 error: new require_TRPCClientError.TRPCClientError(`Timeout of ${chunk.ms}ms reached while waiting for a response`)454 });455 }456 }457 } catch (err) {458 _didIteratorError = true;459 _iteratorError = err;460 } finally {461 try {462 if (_iteratorAbruptCompletion && _iterator.return != null) await _iterator.return();463 } finally {464 if (_didIteratorError) throw _iteratorError;465 }466 }467 observer.next({ result: { type: "stopped" } });468 connectionState.next({469 type: "state",470 state: "idle",471 error: null472 });473 observer.complete();474 }).catch((error) => {475 observer.error(require_TRPCClientError.TRPCClientError.from(error));476 });477 return () => {478 observer.complete();479 ac.abort();480 connectionSub.unsubscribe();481 };482 });483 };484 };485}486/**487* @deprecated use {@link httpSubscriptionLink} instead488*/489const unstable_httpSubscriptionLink = httpSubscriptionLink;490 491//#endregion492//#region src/links/retryLink.ts493var import_objectSpread2$1 = require_chunk.__toESM(require_objectSpread2$1.require_objectSpread2(), 1);494/**495* @see https://trpc.io/docs/v11/client/links/retryLink496*/497function retryLink(opts) {498 return () => {499 return (callOpts) => {500 return (0, __trpc_server_observable.observable)((observer) => {501 let next$;502 let callNextTimeout = void 0;503 let lastEventId = void 0;504 attempt(1);505 function opWithLastEventId() {506 const op = callOpts.op;507 if (!lastEventId) return op;508 return (0, import_objectSpread2$1.default)((0, import_objectSpread2$1.default)({}, op), {}, { input: inputWithTrackedEventId(op.input, lastEventId) });509 }510 function attempt(attempts) {511 const op = opWithLastEventId();512 next$ = callOpts.next(op).subscribe({513 error(error) {514 var _opts$retryDelayMs, _opts$retryDelayMs2;515 const shouldRetry = opts.retry({516 op,517 attempts,518 error519 });520 if (!shouldRetry) {521 observer.error(error);522 return;523 }524 const delayMs = (_opts$retryDelayMs = (_opts$retryDelayMs2 = opts.retryDelayMs) === null || _opts$retryDelayMs2 === void 0 ? void 0 : _opts$retryDelayMs2.call(opts, attempts)) !== null && _opts$retryDelayMs !== void 0 ? _opts$retryDelayMs : 0;525 if (delayMs <= 0) {526 attempt(attempts + 1);527 return;528 }529 callNextTimeout = setTimeout(() => attempt(attempts + 1), delayMs);530 },531 next(envelope) {532 if ((!envelope.result.type || envelope.result.type === "data") && envelope.result.id) lastEventId = envelope.result.id;533 observer.next(envelope);534 },535 complete() {536 observer.complete();537 }538 });539 }540 return () => {541 next$.unsubscribe();542 clearTimeout(callNextTimeout);543 };544 });545 };546 };547}548 549//#endregion550//#region ../../node_modules/.pnpm/@oxc-project+runtime@0.72.2/node_modules/@oxc-project/runtime/src/helpers/usingCtx.js551var require_usingCtx = require_chunk.__commonJS({ "../../node_modules/.pnpm/@oxc-project+runtime@0.72.2/node_modules/@oxc-project/runtime/src/helpers/usingCtx.js"(exports, module) {552 function _usingCtx() {553 var r = "function" == typeof SuppressedError ? SuppressedError : function(r$1, e$1) {554 var n$1 = Error();555 return n$1.name = "SuppressedError", n$1.error = r$1, n$1.suppressed = e$1, n$1;556 }, e = {}, n = [];557 function using(r$1, e$1) {558 if (null != e$1) {559 if (Object(e$1) !== e$1) throw new TypeError("using declarations can only be used with objects, functions, null, or undefined.");560 if (r$1) var o = e$1[Symbol.asyncDispose || Symbol["for"]("Symbol.asyncDispose")];561 if (void 0 === o && (o = e$1[Symbol.dispose || Symbol["for"]("Symbol.dispose")], r$1)) var t = o;562 if ("function" != typeof o) throw new TypeError("Object is not disposable.");563 t && (o = function o$1() {564 try {565 t.call(e$1);566 } catch (r$2) {567 return Promise.reject(r$2);568 }569 }), n.push({570 v: e$1,571 d: o,572 a: r$1573 });574 } else r$1 && n.push({575 d: e$1,576 a: r$1577 });578 return e$1;579 }580 return {581 e,582 u: using.bind(null, !1),583 a: using.bind(null, !0),584 d: function d() {585 var o, t = this.e, s = 0;586 function next() {587 for (; o = n.pop();) try {588 if (!o.a && 1 === s) return s = 0, n.push(o), Promise.resolve().then(next);589 if (o.d) {590 var r$1 = o.d.call(o.v);591 if (o.a) return s |= 2, Promise.resolve(r$1).then(next, err);592 } else s |= 1;593 } catch (r$2) {594 return err(r$2);595 }596 if (1 === s) return t !== e ? Promise.reject(t) : Promise.resolve();597 if (t !== e) throw t;598 }599 function err(n$1) {600 return t = t !== e ? new r(n$1, t) : n$1, next();601 }602 return next();603 }604 };605 }606 module.exports = _usingCtx, module.exports.__esModule = true, module.exports["default"] = module.exports;607} });608 609//#endregion610//#region ../../node_modules/.pnpm/@oxc-project+runtime@0.72.2/node_modules/@oxc-project/runtime/src/helpers/OverloadYield.js611var require_OverloadYield = require_chunk.__commonJS({ "../../node_modules/.pnpm/@oxc-project+runtime@0.72.2/node_modules/@oxc-project/runtime/src/helpers/OverloadYield.js"(exports, module) {612 function _OverloadYield(e, d) {613 this.v = e, this.k = d;614 }615 module.exports = _OverloadYield, module.exports.__esModule = true, module.exports["default"] = module.exports;616} });617 618//#endregion619//#region ../../node_modules/.pnpm/@oxc-project+runtime@0.72.2/node_modules/@oxc-project/runtime/src/helpers/awaitAsyncGenerator.js620var require_awaitAsyncGenerator = require_chunk.__commonJS({ "../../node_modules/.pnpm/@oxc-project+runtime@0.72.2/node_modules/@oxc-project/runtime/src/helpers/awaitAsyncGenerator.js"(exports, module) {621 var OverloadYield$1 = require_OverloadYield();622 function _awaitAsyncGenerator$1(e) {623 return new OverloadYield$1(e, 0);624 }625 module.exports = _awaitAsyncGenerator$1, module.exports.__esModule = true, module.exports["default"] = module.exports;626} });627 628//#endregion629//#region ../../node_modules/.pnpm/@oxc-project+runtime@0.72.2/node_modules/@oxc-project/runtime/src/helpers/wrapAsyncGenerator.js630var require_wrapAsyncGenerator = require_chunk.__commonJS({ "../../node_modules/.pnpm/@oxc-project+runtime@0.72.2/node_modules/@oxc-project/runtime/src/helpers/wrapAsyncGenerator.js"(exports, module) {631 var OverloadYield = require_OverloadYield();632 function _wrapAsyncGenerator$1(e) {633 return function() {634 return new AsyncGenerator(e.apply(this, arguments));635 };636 }637 function AsyncGenerator(e) {638 var r, t;639 function resume(r$1, t$1) {640 try {641 var n = e[r$1](t$1), o = n.value, u = o instanceof OverloadYield;642 Promise.resolve(u ? o.v : o).then(function(t$2) {643 if (u) {644 var i = "return" === r$1 ? "return" : "next";645 if (!o.k || t$2.done) return resume(i, t$2);646 t$2 = e[i](t$2).value;647 }648 settle(n.done ? "return" : "normal", t$2);649 }, function(e$1) {650 resume("throw", e$1);651 });652 } catch (e$1) {653 settle("throw", e$1);654 }655 }656 function settle(e$1, n) {657 switch (e$1) {658 case "return":659 r.resolve({660 value: n,661 done: !0662 });663 break;664 case "throw":665 r.reject(n);666 break;667 default: r.resolve({668 value: n,669 done: !1670 });671 }672 (r = r.next) ? resume(r.key, r.arg) : t = null;673 }674 this._invoke = function(e$1, n) {675 return new Promise(function(o, u) {676 var i = {677 key: e$1,678 arg: n,679 resolve: o,680 reject: u,681 next: null682 };683 t ? t = t.next = i : (r = t = i, resume(e$1, n));684 });685 }, "function" != typeof e["return"] && (this["return"] = void 0);686 }687 AsyncGenerator.prototype["function" == typeof Symbol && Symbol.asyncIterator || "@@asyncIterator"] = function() {688 return this;689 }, AsyncGenerator.prototype.next = function(e) {690 return this._invoke("next", e);691 }, AsyncGenerator.prototype["throw"] = function(e) {692 return this._invoke("throw", e);693 }, AsyncGenerator.prototype["return"] = function(e) {694 return this._invoke("return", e);695 };696 module.exports = _wrapAsyncGenerator$1, module.exports.__esModule = true, module.exports["default"] = module.exports;697} });698 699//#endregion700//#region src/links/localLink.ts701var import_usingCtx = require_chunk.__toESM(require_usingCtx(), 1);702var import_awaitAsyncGenerator = require_chunk.__toESM(require_awaitAsyncGenerator(), 1);703var import_wrapAsyncGenerator = require_chunk.__toESM(require_wrapAsyncGenerator(), 1);704var import_objectSpread2 = require_chunk.__toESM(require_objectSpread2$1.require_objectSpread2(), 1);705/**706* localLink is a terminating link that allows you to make tRPC procedure calls directly in your application without going through HTTP.707*708* @see https://trpc.io/docs/links/localLink709*/710function unstable_localLink(opts) {711 const transformer = require_unstable_internals.getTransformer(opts.transformer);712 const transformChunk = (chunk) => {713 if (opts.transformer) return chunk;714 if (chunk === void 0) return chunk;715 const serialized = JSON.stringify(transformer.input.serialize(chunk));716 const deserialized = JSON.parse(transformer.output.deserialize(serialized));717 return deserialized;718 };719 return () => ({ op }) => (0, __trpc_server_observable.observable)((observer) => {720 let ctx = void 0;721 const ac = new AbortController();722 const signal = require_httpBatchLink.raceAbortSignals(op.signal, ac.signal);723 const signalPromise = require_httpBatchLink.abortSignalToPromise(signal);724 signalPromise.catch(() => {});725 let input = op.input;726 async function runProcedure(newInput) {727 input = newInput;728 ctx = await opts.createContext();729 return (0, __trpc_server_unstable_core_do_not_import.callProcedure)({730 router: opts.router,731 path: op.path,732 getRawInput: async () => newInput,733 ctx,734 type: op.type,735 signal,736 batchIndex: 0737 });738 }739 function onErrorCallback(cause) {740 var _opts$onError;741 if ((0, __trpc_server_unstable_core_do_not_import.isAbortError)(cause)) return;742 (_opts$onError = opts.onError) === null || _opts$onError === void 0 || _opts$onError.call(opts, {743 error: (0, __trpc_server.getTRPCErrorFromUnknown)(cause),744 type: op.type,745 path: op.path,746 input,747 ctx748 });749 }750 function coerceToTRPCClientError(cause) {751 if (require_TRPCClientError.isTRPCClientError(cause)) return cause;752 const error = (0, __trpc_server.getTRPCErrorFromUnknown)(cause);753 const shape = (0, __trpc_server.getTRPCErrorShape)({754 config: opts.router._def._config,755 ctx,756 error,757 input,758 path: op.path,759 type: op.type760 });761 return require_TRPCClientError.TRPCClientError.from({ error: transformChunk(shape) }, { cause: cause instanceof Error ? cause : void 0 });762 }763 (0, __trpc_server_unstable_core_do_not_import.run)(async () => {764 switch (op.type) {765 case "query":766 case "mutation": {767 const result = await runProcedure(op.input);768 if (!(0, __trpc_server_unstable_core_do_not_import.isAsyncIterable)(result)) {769 observer.next({ result: { data: transformChunk(result) } });770 observer.complete();771 break;772 }773 observer.next({ result: { data: (0, import_wrapAsyncGenerator.default)(function* () {774 try {775 var _usingCtx$1 = (0, import_usingCtx.default)();776 const iterator = _usingCtx$1.a((0, __trpc_server_unstable_core_do_not_import.iteratorResource)(result));777 const _finally = _usingCtx$1.u((0, __trpc_server_unstable_core_do_not_import.makeResource)({}, () => {778 observer.complete();779 }));780 try {781 while (true) {782 const res = yield (0, import_awaitAsyncGenerator.default)(Promise.race([iterator.next(), signalPromise]));783 if (res.done) return transformChunk(res.value);784 yield transformChunk(res.value);785 }786 } catch (cause) {787 onErrorCallback(cause);788 throw coerceToTRPCClientError(cause);789 }790 } catch (_) {791 _usingCtx$1.e = _;792 } finally {793 yield (0, import_awaitAsyncGenerator.default)(_usingCtx$1.d());794 }795 })() } });796 break;797 }798 case "subscription": try {799 var _usingCtx3 = (0, import_usingCtx.default)();800 const connectionState = (0, __trpc_server_observable.behaviorSubject)({801 type: "state",802 state: "connecting",803 error: null804 });805 const connectionSub = connectionState.subscribe({ next(state) {806 observer.next({ result: state });807 } });808 let lastEventId = void 0;809 const _finally = _usingCtx3.u((0, __trpc_server_unstable_core_do_not_import.makeResource)({}, async () => {810 observer.complete();811 connectionState.next({812 type: "state",813 state: "idle",814 error: null815 });816 connectionSub.unsubscribe();817 }));818 while (true) try {819 var _usingCtx4 = (0, import_usingCtx.default)();820 const result = await runProcedure(inputWithTrackedEventId(op.input, lastEventId));821 if (!(0, __trpc_server_unstable_core_do_not_import.isAsyncIterable)(result)) throw new Error("Expected an async iterable");822 const iterator = _usingCtx4.a((0, __trpc_server_unstable_core_do_not_import.iteratorResource)(result));823 observer.next({ result: { type: "started" } });824 connectionState.next({825 type: "state",826 state: "pending",827 error: null828 });829 while (true) {830 let res;831 try {832 res = await Promise.race([iterator.next(), signalPromise]);833 } catch (cause) {834 if ((0, __trpc_server_unstable_core_do_not_import.isAbortError)(cause)) return;835 const error = (0, __trpc_server.getTRPCErrorFromUnknown)(cause);836 if (!__trpc_server_unstable_core_do_not_import.retryableRpcCodes.includes(__trpc_server_rpc.TRPC_ERROR_CODES_BY_KEY[error.code])) throw coerceToTRPCClientError(error);837 onErrorCallback(error);838 connectionState.next({839 type: "state",840 state: "connecting",841 error: coerceToTRPCClientError(error)842 });843 break;844 }845 if (res.done) return;846 let chunk;847 if ((0, __trpc_server.isTrackedEnvelope)(res.value)) {848 lastEventId = res.value[0];849 chunk = {850 id: res.value[0],851 data: {852 id: res.value[0],853 data: res.value[1]854 }855 };856 } else chunk = { data: res.value };857 observer.next({ result: (0, import_objectSpread2.default)((0, import_objectSpread2.default)({}, chunk), {}, { data: transformChunk(chunk.data) }) });858 }859 } catch (_) {860 _usingCtx4.e = _;861 } finally {862 await _usingCtx4.d();863 }864 break;865 } catch (_) {866 _usingCtx3.e = _;867 } finally {868 _usingCtx3.d();869 }870 }871 }).catch((cause) => {872 onErrorCallback(cause);873 observer.error(coerceToTRPCClientError(cause));874 });875 return () => {876 ac.abort();877 };878 });879}880/**881* @deprecated Renamed to `unstable_localLink`. This alias will be removed in a future major release.882*/883const experimental_localLink = unstable_localLink;884 885//#endregion886exports.TRPCClientError = require_TRPCClientError.TRPCClientError;887exports.TRPCUntypedClient = TRPCUntypedClient;888exports.clientCallTypeToProcedureType = clientCallTypeToProcedureType;889exports.createTRPCClient = createTRPCClient;890exports.createTRPCClientProxy = createTRPCClientProxy;891exports.createTRPCProxyClient = createTRPCClient;892exports.createTRPCUntypedClient = createTRPCUntypedClient;893exports.createWSClient = require_wsLink.createWSClient;894exports.experimental_localLink = experimental_localLink;895exports.getFetch = require_httpUtils.getFetch;896exports.getUntypedClient = getUntypedClient;897exports.httpBatchLink = require_httpBatchLink.httpBatchLink;898exports.httpBatchStreamLink = httpBatchStreamLink;899exports.httpLink = require_httpLink.httpLink;900exports.httpSubscriptionLink = httpSubscriptionLink;901exports.isFormData = require_httpLink.isFormData;902exports.isNonJsonSerializable = require_httpLink.isNonJsonSerializable;903exports.isOctetType = require_httpLink.isOctetType;904exports.isTRPCClientError = require_TRPCClientError.isTRPCClientError;905exports.jsonEncoder = require_wsLink.jsonEncoder;906exports.loggerLink = require_loggerLink.loggerLink;907exports.retryLink = retryLink;908exports.splitLink = require_splitLink.splitLink;909exports.unstable_httpBatchStreamLink = unstable_httpBatchStreamLink;910exports.unstable_httpSubscriptionLink = unstable_httpSubscriptionLink;911exports.unstable_localLink = unstable_localLink;912exports.wsLink = require_wsLink.wsLink;