Global-sales/wai-server/core/webhook/index.js

const axios = require('axios');
const { default: axiosRetry } = require('axios-retry');
const webhookUrl = require('../../config').webhook;
const { logger, getUserLogger } = require('../../utils/logger.util');

// 5s, 10s, 20s, 30s, 1m, 15m, 30m, 1h
const retryDelays = [5000, 10000, 20000, 30000, 300000, 900000, 1800000, 3600000];
axiosRetry(axios, {
  retries: 1, // Number of retries
  retryDelay: retryCount => {
    const delayIndex = Math.min(retryCount - 1, retryDelays.length - 1);
    const delay = retryDelays[delayIndex];
    logger.warn(`retry attempt: ${retryCount}, delay: ${delay / 1000}s`);
    return delay;
  },
  retryCondition: error => {
    return false; // error.response?.status !== 200; // Retry only on non-200 status codes
  },
  onRetry: (retryCount, error, requestConfig) => {
    logger.warn({ retryCount, error: error.message, }, `Retrying webhook call, attempt ${retryCount}`);
  },
});

async function callWebhook(messageData) {
  try {
    if (!webhookUrl) {
      logger.error('no webhook url provided\n', messageData);
      return;
    }
    getUserLogger(messageData.whatsAppNo).info({ webhookUrl, messageData });
    await axios.post(webhookUrl, messageData);
  } catch (error) {
    logger.error(JSON.stringify({ webhookUrl, messageData, error: error.message }, undefined, 2), 'Error calling webhook');
  }
}

module.exports = { callWebhook };