import { telegramDataSchema } from "@openstatus/db/src/schema";
import type { NotificationContext } from "@openstatus/notification-base";

export const sendAlert = async ({
  monitor,
  notification,
  statusCode,
  message,
}: NotificationContext) => {
  const notificationData = telegramDataSchema.parse(
    JSON.parse(notification.data),
  );
  const { name } = monitor;

  const body = `Your monitor ${name} / ${monitor.url} is down with ${
    statusCode ? `status code ${statusCode}` : `error: ${message}`
  }`;

  await sendMessage({
    chatId: notificationData.telegram.chatId,
    message: body,
  });
};

export const sendRecovery = async ({
  monitor,
  notification,
}: NotificationContext) => {
  const notificationData = telegramDataSchema.parse(
    JSON.parse(notification.data),
  );
  const { name } = monitor;

  const body = `Your monitor ${name} / ${monitor.url} is up again`;
  await sendMessage({
    chatId: notificationData.telegram.chatId,
    message: body,
  });
};

export const sendDegraded = async ({
  monitor,
  notification,
}: NotificationContext) => {
  const notificationData = telegramDataSchema.parse(
    JSON.parse(notification.data),
  );
  const { name } = monitor;

  const body = `Your monitor ${name} / ${monitor.url} is degraded `;

  await sendMessage({
    chatId: notificationData.telegram.chatId,
    message: body,
  });
};

export const sendTest = async ({ chatId }: { chatId: string }) => {
  try {
    await sendMessage({
      chatId,
      message: "This is a test message from OpenStatus. You are good to go!",
    });
  } catch (err) {
    console.log(err);
    return false;
  }
  return true;
};

export async function sendMessage({
  chatId,
  message,
}: {
  chatId: string;
  message: string;
}) {
  if (!process.env.TELEGRAM_BOT_TOKEN) {
    throw new Error("TELEGRAM_BOT_TOKEN is not set");
  }
  const res = await fetch(
    `https://api.telegram.org/bot${process.env.TELEGRAM_BOT_TOKEN}/sendMessage?chat_id=${chatId}&text=${message}`,
  );
  if (!res.ok) {
    throw new Error(`Failed to send telegram message: ${res.statusText}`);
  }
  return res;
}