upstream-rocketchat/apps/meteor/server/lib/omnichannel/webhooks.ts

import { serverFetch as fetch } from '@rocket.chat/server-fetch';
import type { Response } from '@rocket.chat/server-fetch';

import { webhooksLogger } from './logger';
import { settings } from '../../settings';
import { metrics } from '../metrics';

const isRetryable = (status: number): boolean => status >= 500 || status === 429;

export async function sendRequest(
	postData: {
		type: string;
		[key: string]: any;
	},
	attempts = 5,
	cb?: (response: Response) => Promise<void>,
) {
	const timeout = settings.get<number>('Livechat_http_timeout');
	const secretToken = settings.get<string>('Livechat_secret_token');
	const webhookUrl = settings.get<string>('Livechat_webhookUrl');
	try {
		webhooksLogger.debug({ msg: 'Sending webhook request', postData });
		const result = await fetch(webhookUrl, {
			method: 'POST',
			headers: {
				...(secretToken && { 'X-RocketChat-Livechat-Token': secretToken }),
			},
			body: postData,
			timeout,
			// SECURITY: Webhooks can only be configured by users with enough privileges. It's ok to disable this check here.
			ignoreSsrfValidation: true,
			size: 10 * 1024 * 1024,
		});

		if (result.status === 200) {
			metrics.totalLivechatWebhooksSuccess.inc();
			metrics.totalLivechatWebhooksSuccessTotal.inc();
			await cb?.(result);
			return result;
		}

		if (!isRetryable(result.status)) {
			webhooksLogger.error({
				msg: 'Non-retryable error response from webhook',
				webhookUrl,
				status: result.status,
				response: await result.text(),
			});
			metrics.totalLivechatWebhooksFailures.inc();
			metrics.totalLivechatWebhooksFailuresTotal.inc();
			return;
		}

		metrics.totalLivechatWebhooksFailures.inc();
		metrics.totalLivechatWebhooksFailuresTotal.inc();
		throw new Error(await result.text());
	} catch (err) {
		const retryAfter = timeout * 4;
		webhooksLogger.debug({
			msg: 'Error response on retry',
			attempt: 6 - attempts,
			err,
			newAttemptAfterSeconds: retryAfter / 1000,
			webhookUrl,
		});
		const remainingAttempts = attempts - 1;
		// try 5 times after 20 seconds each
		if (!remainingAttempts) {
			webhooksLogger.error({ msg: 'Omnichannel webhook call failed. Max attempts reached' });
			return;
		}

		setTimeout(async () => {
			await sendRequest(postData, remainingAttempts, cb);
		}, retryAfter);
	}
}