import * as Sentry from "@sentry/node";
import axios from "axios";

import {APIError} from "../errors";
import {logger} from "../logger";
// Convenience method to send data to a Slack webhook.
export async function sendToSlack(
  text: string,
  {
    slackChannel,
    shouldThrow = false,
    env,
  }: {slackChannel?: string; shouldThrow?: boolean; env?: string} = {}
) {
  // since Slack now requires a webhook for each channel, we need to store them in the environment
  // as an object, so we can look them up by channel name.
  const slackWebhooksString = process.env.SLACK_WEBHOOKS;
  if (!slackWebhooksString) {
    logger.debug("You must set SLACK_WEBHOOKS in the environment to use sendToSlack.");
    return;
  }
  const slackWebhooks = JSON.parse(slackWebhooksString ?? "{}");

  const channel = slackChannel ?? "default";

  const slackWebhookUrl = slackWebhooks[channel] ?? slackWebhooks.default;

  if (!slackWebhookUrl) {
    Sentry.captureException(
      new Error(`No webhook url set in env for ${channel}. Slack message not sent`)
    );
    logger.debug(`No webhook url set in env for ${channel}.`);
    return;
  }

  let formattedText = text;
  if (env) {
    formattedText = `[${env.toUpperCase()}] ${text}`;
  }

  try {
    await axios.post(slackWebhookUrl, {
      text: formattedText,
    });
  } catch (error: any) {
    logger.error(`Error posting to slack: ${error.text ?? error.message}`);
    Sentry.captureException(error);
    if (shouldThrow) {
      throw new APIError({
        status: 500,
        title: `Error posting to slack: ${error.text ?? error.message}`,
      });
    }
  }
}