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

// 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 error.response?.status !== 200; // Retry only on non-200 status codes
  },
  onRetry: (retryCount, error, requestConfig) => {
    logger.warn({ retryCount, error, requestConfig }, `Retrying webhook call, attempt ${retryCount}`);
  },
});

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

module.exports = { callWebhook };