https://app.sundaysky.com/client/backgroundMutation.BU4o3Ftb.js

1
2!function(){try{var e="undefined"!=typeof window?window:"undefined"!=typeof global?global:"undefined"!=typeof globalThis?globalThis:"undefined"!=typeof self?self:{},n=(new e.Error).stack;n&&(e._sentryDebugIds=e._sentryDebugIds||{},e._sentryDebugIds[n]="33a5a771-9888-5028-919f-e2a0b7a1a76f")}catch(e){}}();
3import { Gn as v4 } from "./vendor~index~newNavigation~AccountTierManagementPage~AdminContainer~AISystemPromptManager~C~hh2h6ti1.CxCdS9_4.js";
4import { Rr as getApolloClient, _n as localEditorCloudIndicatorVar, r as reportInfoToSplunk, yi as CloudIndicatorState } from "./logReportUtils.Ca-hg6bk.js";
5import { Ro as GqlClientStatus } from "./graphqlClient.B8mBnpI6.js";
6//#region client/components/editor/Nooks/BackgroundMutation/backgroundMutation.ts
7var MUTATION_KEEPALIVE_TIMEOUT = 6e4;
8var mutationsMap = /* @__PURE__ */ new Map();
9var getBackgroundMutation = (mutationId) => {
10	return mutationsMap.get(mutationId);
11};
12var getBackgroundMutationOnSuccess = (mutationId) => {
13	return getBackgroundMutation(mutationId)?.callbacks?.onSuccess;
14};
15var getBackgroundMutationOnFailure = (mutationId) => {
16	return getBackgroundMutation(mutationId)?.callbacks?.onFailure;
17};
18var getBackgroundMutationOnProgress = (mutationId) => {
19	return getBackgroundMutation(mutationId)?.callbacks?.onProgress;
20};

21var unsubscribeBackgroundMutation = (mutationId) => {
22	const mutation = getBackgroundMutation(mutationId);
23	if (mutation) mutation.subscription.unsubscribe();
24};
25var removeBackgroundMutation = (mutationId) => {
26	unsubscribeBackgroundMutation(mutationId);
27	mutationsMap.delete(mutationId);
28};
29var registerMutation = (mutationId, callbacks, subscription) => {
30	mutationsMap.set(mutationId, {
31		callbacks,
32		subscription
33	});
34};
35function createSubscription(subscriptionOptions) {
36	const createTimeout = (timeoutId) => {
37		if (timeoutId) clearTimeout(timeoutId);
38		return setTimeout(() => {
39			const subscriptionName = (subscriptionOptions?.query?.definitions?.[0])?.name?.value ?? "N/A";
40			const variables = subscriptionOptions?.variables ?? "N/A";
41			reportInfoToSplunk(`Subscription "${subscriptionName}" did not send keep alive for ${MUTATION_KEEPALIVE_TIMEOUT}ms`, { variables });
42		}, MUTATION_KEEPALIVE_TIMEOUT);
43	};
44	let timeoutId = createTimeout();
45	return getApolloClient().subscribe(subscriptionOptions).subscribe((payload) => {
46		const payloadData = Object.values(payload.data)[0];
47		if (payloadData) {
48			const { status, mutationId } = payloadData;
49			switch (status) {
50				case GqlClientStatus.KEEP_ALIVE:
51					timeoutId = createTimeout(timeoutId);
52					break;
53				case GqlClientStatus.PENDING: {
54					const onProgress = getBackgroundMutationOnProgress(mutationId);
55					if (onProgress) onProgress(payloadData);
56					break;
57				}
58				case GqlClientStatus.PARTIAL_SUCCESS:
59				case GqlClientStatus.SUCCESS: {
60					clearTimeout(timeoutId);
61					const onSuccess = getBackgroundMutationOnSuccess(mutationId);
62					if (onSuccess) onSuccess(payloadData);
63					removeBackgroundMutation(mutationId);
64					break;
65				}
66				case GqlClientStatus.ERROR: {
67					clearTimeout(timeoutId);
68					const onFailure = getBackgroundMutationOnFailure(mutationId);
69					if (onFailure) {
70						onFailure(payloadData);
71						localEditorCloudIndicatorVar(CloudIndicatorState.ACTION_ERROR);
72					}
73					removeBackgroundMutation(mutationId);
74					break;
75				}
76			}
77		}
78	});
79}
80function executeBackgroundMutation(options, subscriptionOptions, callbacks, existingMutationId) {
81	const mutationId = existingMutationId ?? v4();
82	const { mutate } = getApolloClient();
83	registerMutation(mutationId, callbacks, createSubscription(subscriptionOptions));
84	return mutate({
85		mutation: options.mutation,
86		variables: {
87			...options.variables,
88			mutationId
89		}
90	});
91}
92//#endregion
93export { executeBackgroundMutation as t };
94
95//# sourceMappingURL=backgroundMutation.BU4o3Ftb.js.map
96//# debugId=33a5a771-9888-5028-919f-e2a0b7a1a76f