Rocket.Chat/apps/meteor/app/livechat/server/lib/webhooks.ts

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

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

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,
		});

		if (result.status === 200) {
			metrics.totalLivechatWebhooksSuccess.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();
			return;
		}

		metrics.totalLivechatWebhooksFailures.inc();
		throw new Error(await result.text());
	} catch (err) {
		const retryAfter = timeout * 4;
		webhooksLogger.debug({ msg: `Error response on ${6 - attempts} try ->`, 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);
	}
}