prism/public/integration.js

async function handleAuthForm(form, endpoint, statusId, getPayload) {
	const status = document.getElementById(statusId);
	const btn = form.querySelector('button[type="submit"]');
	const showError = (msg) => {
		status.textContent = `Error: ${msg}`;
		status.className = 'auth-status error';
		btn.disabled = false;
	};

	btn.disabled = true;

	try {
		const formData = new FormData(form);
		const response = await fetch(endpoint, {
			method: 'POST',
			headers: { 'Content-Type': 'application/json' },
			body: JSON.stringify(getPayload(formData, form)),
		});

		if (response.ok) {
			location.reload();
		} else {
			const error = await response.json();
			showError(error.error || 'Failed to save');
		}
	} catch (err) {
		showError(err.message);
	}
}

// biome-ignore lint/correctness/noUnusedVariables: called from HTML onsubmit
async function submitTelegramAuth(e) {
	e.preventDefault();
	await handleAuthForm(
		e.target,
		'/api/telegram/auth',
		'telegram-auth-status',
		(fd) => ({
			bot_token: fd.get('bot_token'),
			chat_id: fd.get('chat_id'),
		}),
	);
}

// biome-ignore lint/correctness/noUnusedVariables: called from HTML onsubmit
async function submitTelegramChatId(e) {
	e.preventDefault();
	await handleAuthForm(
		e.target,
		'/api/telegram/auth',
		'telegram-chatid-status',
		(fd, form) => ({
			bot_token: form.dataset.botToken,
			chat_id: fd.get('chat_id'),
		}),
	);
}

// biome-ignore lint/correctness/noUnusedVariables: called from HTML onsubmit
async function submitProtonAuth(e) {
	e.preventDefault();
	await handleAuthForm(
		e.target,
		'/api/proton/auth',
		'proton-auth-status',
		(fd) => ({
			email: fd.get('email'),
			password: fd.get('password'),
			totp: fd.get('totp'),
		}),
	);
}

let signalLinkingPoll = null;

// biome-ignore lint/correctness/noUnusedVariables: called from HTML onclick
async function linkSignal(btn) {
	const qrContainer = document.getElementById('signal-qr-container');
	const qrCode = document.getElementById('signal-qr-code');
	const showQrError = (msg) => {
		qrContainer.innerHTML = `<p class="channel-not-configured">Error: ${msg}</p>`;
		qrContainer.style.display = 'block';
		btn.style.display = 'inline-block';
	};

	btn.style.display = 'none';
	qrContainer.style.display = 'none';

	try {
		const response = await fetch('/api/signal/link', {
			method: 'POST',
			headers: { 'Content-Type': 'application/json' },
			body: JSON.stringify({ device_name: 'Prism' }),
		});

		if (!response.ok) {
			const error = await response.json();
			showQrError(error.error || 'Failed to generate link');
			return;
		}

		const data = await response.json();
		const qrUrl = `https://api.qrserver.com/v1/create-qr-code/?size=400x400&data=${encodeURIComponent(data.qr_code)}`;
		qrCode.src = qrUrl;
		qrContainer.style.display = 'block';

		signalLinkingPoll = setInterval(async () => {
			try {
				const statusResp = await fetch('/api/signal/status');
				const statusData = await statusResp.json();

				if (statusData.linked) {
					clearInterval(signalLinkingPoll);
					qrContainer.innerHTML =
						'<p class="auth-status success">Linked! Refreshing...</p>';
					setTimeout(() => location.reload(), 1000);
				}
			} catch (err) {
				console.error('Status check failed:', err);
			}
		}, 2000);
	} catch (err) {
		showQrError(err.message);
	}
}

// biome-ignore lint/correctness/noUnusedVariables: called from HTML onclick
async function deleteTelegram(btn) {
	if (!confirm('Unlink Telegram integration?')) return;

	btn.disabled = true;

	try {
		const response = await fetch('/api/telegram/auth', { method: 'DELETE' });

		if (response.ok) {
			location.reload();
		} else {
			const error = await response.json();
			alert(`Error: ${error.error || 'Failed to unlink integration'}`);
			btn.disabled = false;
		}
	} catch (err) {
		alert(`Error: ${err.message}`);
		btn.disabled = false;
	}
}

// biome-ignore lint/correctness/noUnusedVariables: called from HTML onclick
async function deleteProton(btn) {
	if (!confirm('Unlink Proton Mail integration?')) return;

	btn.disabled = true;

	try {
		const response = await fetch('/api/proton/auth', { method: 'DELETE' });

		if (response.ok) {
			location.reload();
		} else {
			const error = await response.json();
			alert(`Error: ${error.error || 'Failed to unlink integration'}`);
			btn.disabled = false;
		}
	} catch (err) {
		alert(`Error: ${err.message}`);
		btn.disabled = false;
	}
}