AK-21/Graphite-Industrial-Intelligence

1const require_chunk = require('./chunk-DWy1uDak.cjs');2const require_objectSpread2$1 = require('./objectSpread2-Bsvh_OqM.cjs');3const require_TRPCClientError = require('./TRPCClientError-CQrTQLrk.cjs');4const require_httpUtils = require('./httpUtils-wv2o-njD.cjs');5const __trpc_server_observable = require_chunk.__toESM(require("@trpc/server/observable"));6const __trpc_server_unstable_core_do_not_import = require_chunk.__toESM(require("@trpc/server/unstable-core-do-not-import"));7 8//#region src/links/internals/contentTypes.ts9function isOctetType(input) {10	return input instanceof Uint8Array || input instanceof Blob;11}12function isFormData(input) {13	return input instanceof FormData;14}15function isNonJsonSerializable(input) {16	return isOctetType(input) || isFormData(input);17}18 19//#endregion20//#region src/links/httpLink.ts21var import_objectSpread2 = require_chunk.__toESM(require_objectSpread2$1.require_objectSpread2(), 1);22const universalRequester = (opts) => {23	if ("input" in opts) {24		const { input } = opts;25		if (isFormData(input)) {26			if (opts.type !== "mutation" && opts.methodOverride !== "POST") throw new Error("FormData is only supported for mutations");27			return require_httpUtils.httpRequest((0, import_objectSpread2.default)((0, import_objectSpread2.default)({}, opts), {}, {28				contentTypeHeader: void 0,29				getUrl: require_httpUtils.getUrl,30				getBody: () => input31			}));32		}33		if (isOctetType(input)) {34			if (opts.type !== "mutation" && opts.methodOverride !== "POST") throw new Error("Octet type input is only supported for mutations");35			return require_httpUtils.httpRequest((0, import_objectSpread2.default)((0, import_objectSpread2.default)({}, opts), {}, {36				contentTypeHeader: "application/octet-stream",37				getUrl: require_httpUtils.getUrl,38				getBody: () => input39			}));40		}41	}42	return require_httpUtils.jsonHttpRequester(opts);43};44/**45* @see https://trpc.io/docs/client/links/httpLink46*/47function httpLink(opts) {48	const resolvedOpts = require_httpUtils.resolveHTTPLinkOptions(opts);49	return () => {50		return (operationOpts) => {51			const { op } = operationOpts;52			return (0, __trpc_server_observable.observable)((observer) => {53				const { path, input, type } = op;54				/* istanbul ignore if -- @preserve */55				if (type === "subscription") throw new Error("Subscriptions are unsupported by `httpLink` - use `httpSubscriptionLink` or `wsLink`");56				const request = universalRequester((0, import_objectSpread2.default)((0, import_objectSpread2.default)({}, resolvedOpts), {}, {57					type,58					path,59					input,60					signal: op.signal,61					headers() {62						if (!opts.headers) return {};63						if (typeof opts.headers === "function") return opts.headers({ op });64						return opts.headers;65					}66				}));67				let meta = void 0;68				request.then((res) => {69					meta = res.meta;70					const transformed = (0, __trpc_server_unstable_core_do_not_import.transformResult)(res.json, resolvedOpts.transformer.output);71					if (!transformed.ok) {72						observer.error(require_TRPCClientError.TRPCClientError.from(transformed.error, { meta }));73						return;74					}75					observer.next({76						context: res.meta,77						result: transformed.result78					});79					observer.complete();80				}).catch((cause) => {81					observer.error(require_TRPCClientError.TRPCClientError.from(cause, { meta }));82				});83				return () => {};84			});85		};86	};87}88 89//#endregion90Object.defineProperty(exports, 'httpLink', {91  enumerable: true,92  get: function () {93    return httpLink;94  }95});96Object.defineProperty(exports, 'isFormData', {97  enumerable: true,98  get: function () {99    return isFormData;100  }101});102Object.defineProperty(exports, 'isNonJsonSerializable', {103  enumerable: true,104  get: function () {105    return isNonJsonSerializable;106  }107});108Object.defineProperty(exports, 'isOctetType', {109  enumerable: true,110  get: function () {111    return isOctetType;112  }113});