mirror of
https://github.com/EvolutionAPI/evolution-api.git
synced 2025-07-17 04:32:53 -06:00
fix(webhook): adicionar timeout configurável
Implementa timeout configurável nas requisições de webhook: - Aplica configuração em todas as instâncias axios - Usa valor padrão de 30 segundos se não configurado - Evita requisições penduradas indefinidamente Issue: #1325
This commit is contained in:
parent
5156ea58ac
commit
e37a3cc2d6
@ -115,6 +115,7 @@ export class WebhookController extends EventController implements EventControlle
|
|||||||
const httpService = axios.create({
|
const httpService = axios.create({
|
||||||
baseURL,
|
baseURL,
|
||||||
headers: webhookHeaders as Record<string, string> | undefined,
|
headers: webhookHeaders as Record<string, string> | undefined,
|
||||||
|
timeout: webhookConfig.REQUEST?.TIMEOUT_MS ?? 30000,
|
||||||
});
|
});
|
||||||
|
|
||||||
await this.retryWebhookRequest(httpService, webhookData, `${origin}.sendData-Webhook`, baseURL, serverUrl);
|
await this.retryWebhookRequest(httpService, webhookData, `${origin}.sendData-Webhook`, baseURL, serverUrl);
|
||||||
@ -156,7 +157,10 @@ export class WebhookController extends EventController implements EventControlle
|
|||||||
|
|
||||||
try {
|
try {
|
||||||
if (isURL(globalURL)) {
|
if (isURL(globalURL)) {
|
||||||
const httpService = axios.create({ baseURL: globalURL });
|
const httpService = axios.create({
|
||||||
|
baseURL: globalURL,
|
||||||
|
timeout: webhookConfig.REQUEST?.TIMEOUT_MS ?? 30000,
|
||||||
|
});
|
||||||
|
|
||||||
await this.retryWebhookRequest(
|
await this.retryWebhookRequest(
|
||||||
httpService,
|
httpService,
|
||||||
@ -190,12 +194,21 @@ export class WebhookController extends EventController implements EventControlle
|
|||||||
origin: string,
|
origin: string,
|
||||||
baseURL: string,
|
baseURL: string,
|
||||||
serverUrl: string,
|
serverUrl: string,
|
||||||
maxRetries = 10,
|
maxRetries?: number,
|
||||||
delaySeconds = 30,
|
delaySeconds?: number,
|
||||||
): Promise<void> {
|
): Promise<void> {
|
||||||
|
// Obter configurações de retry das variáveis de ambiente
|
||||||
|
const webhookConfig = configService.get<Webhook>('WEBHOOK');
|
||||||
|
const maxRetryAttempts = maxRetries ?? webhookConfig.RETRY?.MAX_ATTEMPTS ?? 10;
|
||||||
|
const initialDelay = delaySeconds ?? webhookConfig.RETRY?.INITIAL_DELAY_SECONDS ?? 5;
|
||||||
|
const useExponentialBackoff = webhookConfig.RETRY?.USE_EXPONENTIAL_BACKOFF ?? true;
|
||||||
|
const maxDelay = webhookConfig.RETRY?.MAX_DELAY_SECONDS ?? 300;
|
||||||
|
const jitterFactor = webhookConfig.RETRY?.JITTER_FACTOR ?? 0.2;
|
||||||
|
const nonRetryableStatusCodes = webhookConfig.RETRY?.NON_RETRYABLE_STATUS_CODES ?? [400, 401, 403, 404, 422];
|
||||||
|
|
||||||
let attempts = 0;
|
let attempts = 0;
|
||||||
|
|
||||||
while (attempts < maxRetries) {
|
while (attempts < maxRetryAttempts) {
|
||||||
try {
|
try {
|
||||||
await httpService.post('', webhookData);
|
await httpService.post('', webhookData);
|
||||||
if (attempts > 0) {
|
if (attempts > 0) {
|
||||||
@ -209,12 +222,29 @@ export class WebhookController extends EventController implements EventControlle
|
|||||||
} catch (error) {
|
} catch (error) {
|
||||||
attempts++;
|
attempts++;
|
||||||
|
|
||||||
|
// Verificar se é um erro de timeout
|
||||||
|
const isTimeout = error.code === 'ECONNABORTED';
|
||||||
|
|
||||||
|
// Verificar se o erro não deve gerar retry com base no status code
|
||||||
|
if (error?.response?.status && nonRetryableStatusCodes.includes(error.response.status)) {
|
||||||
this.logger.error({
|
this.logger.error({
|
||||||
local: `${origin}`,
|
local: `${origin}`,
|
||||||
message: `Tentativa ${attempts}/${maxRetries} falhou: ${error?.message}`,
|
message: `Erro não recuperável (${error.response.status}): ${error?.message}. Cancelando retentativas.`,
|
||||||
|
statusCode: error?.response?.status,
|
||||||
|
url: baseURL,
|
||||||
|
server_url: serverUrl,
|
||||||
|
});
|
||||||
|
throw error;
|
||||||
|
}
|
||||||
|
|
||||||
|
this.logger.error({
|
||||||
|
local: `${origin}`,
|
||||||
|
message: `Tentativa ${attempts}/${maxRetryAttempts} falhou: ${isTimeout ? 'Timeout da requisição' : error?.message}`,
|
||||||
hostName: error?.hostname,
|
hostName: error?.hostname,
|
||||||
syscall: error?.syscall,
|
syscall: error?.syscall,
|
||||||
code: error?.code,
|
code: error?.code,
|
||||||
|
isTimeout,
|
||||||
|
statusCode: error?.response?.status,
|
||||||
error: error?.errno,
|
error: error?.errno,
|
||||||
stack: error?.stack,
|
stack: error?.stack,
|
||||||
name: error?.name,
|
name: error?.name,
|
||||||
@ -222,11 +252,28 @@ export class WebhookController extends EventController implements EventControlle
|
|||||||
server_url: serverUrl,
|
server_url: serverUrl,
|
||||||
});
|
});
|
||||||
|
|
||||||
if (attempts === maxRetries) {
|
if (attempts === maxRetryAttempts) {
|
||||||
throw error;
|
throw error;
|
||||||
}
|
}
|
||||||
|
|
||||||
await new Promise((resolve) => setTimeout(resolve, delaySeconds * 1000));
|
// Cálculo do delay com backoff exponencial e jitter
|
||||||
|
let nextDelay = initialDelay;
|
||||||
|
if (useExponentialBackoff) {
|
||||||
|
// Fórmula: initialDelay * (2^attempts) com limite máximo
|
||||||
|
nextDelay = Math.min(initialDelay * Math.pow(2, attempts - 1), maxDelay);
|
||||||
|
|
||||||
|
// Adicionar jitter para evitar "thundering herd"
|
||||||
|
const jitter = nextDelay * jitterFactor * (Math.random() * 2 - 1);
|
||||||
|
nextDelay = Math.max(initialDelay, nextDelay + jitter);
|
||||||
|
}
|
||||||
|
|
||||||
|
this.logger.log({
|
||||||
|
local: `${origin}`,
|
||||||
|
message: `Aguardando ${nextDelay.toFixed(1)} segundos antes da próxima tentativa`,
|
||||||
|
url: baseURL,
|
||||||
|
});
|
||||||
|
|
||||||
|
await new Promise((resolve) => setTimeout(resolve, nextDelay * 1000));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user