Function startLocalCallbackSession

apps/desktop/src/utils/auth.ts:124–171

(signal: AbortSignal)

}

async function startLocalCallbackSession(signal: AbortSignal) {
	await invoke("plugin:oauth|stop").catch(() => {});

	const port: string = await invoke("plugin:oauth|start", {
		config: {
			response: callbackTemplate,
			headers: {
				"Content-Type": "text/html; charset=utf-8",
				"Cache-Control": "no-store, no-cache, must-revalidate",
				Pragma: "no-cache",
			},
			cleanup: true,
		},
	});

	let settled = false;
	let stopListening: (() => void) | undefined;
	let resolvePromise: (data: AuthParams | null) => void = () => {};

	const complete = new Promise<AuthParams | null>((resolve) => {
		resolvePromise = resolve;
	});

	const settle = (value: AuthParams | null) => {
		if (settled) return;
		settled = true;
		resolvePromise(value);
	};

	stopListening = await listen("oauth://url", (data: { payload: string }) => {
		if (!(data.payload.includes("token") || data.payload.includes("api_key"))) {
			return;
		}

		settle(parseAuthParams(new URL(data.payload)));
	});

	const dispose = async () => {
		stopListening?.();
		stopListening = undefined;
		settle(null);
		await invoke("plugin:oauth|stop").catch(() => {});
	};

	signal.addEventListener("abort", () => void dispose(), { once: true });

	return { port, complete, dispose };
}

async function startDeepLinkSession(signal: AbortSignal) {
	let settled = false;