keyboard.ts

import { type OrderStatus, resetPostDate, updatePostStatus } from "./db.ts";
import { Composer, InlineKeyboard } from "grammy";
import { updateList } from "./list.ts";
import { kv } from "./mod.ts";

// Status names
const statusEnum = {
  new_: "🆕 Новый",
  work: "🛠️ В работе",
  out: "📤 Готовые",
  recent: "🕒 Недавно выданный",
};

// Generate keyboard
export const generateKeyboard = (id: number, status: OrderStatus) => {
  const keyboard = new InlineKeyboard();

  switch (status) {
    case "new_":
      keyboard.text("В работу →", `work-${id}`).row();
      break;
    case "work":
      keyboard
        .text("← В новые", `new-${id}`)
        .row()
        .text("Готов →", `out-${id}`)
        .row();
      break;
    case "out":
      keyboard
        .text("← В работу", `work-${id}`)
        .row()
        .text("Выдать →", `recent-${id}`)
        .row();
      break;
    case "recent":
      keyboard.text("← В готовые", `out-${id}`).row();
      break;
  }

  keyboard.text("Сбросить дату", `reset-${id}`);

  return keyboard;
};

// Generate text above keyboard XD
export const generateText = (status: OrderStatus) => {
  return statusEnum[status];
};

export const keyboardComposer = new Composer();

// Status changes
keyboardComposer.callbackQuery(/new-[0-9]+/, async (ctx) => {
  const postId = Number(ctx.callbackQuery.data.split("-")[1]);
  await updatePostStatus(postId, "new_");
  await ctx.editMessageText(generateText("new_"), {
    reply_markup: generateKeyboard(postId, "new_"),
  });
  await updateList();
  if (!ctx.chat) return;
  await ctx.api.sendMessage(
    ctx.chat.id,
    "🆕 Новый (" + ctx.from.first_name + ")",
    {
      reply_parameters: {
        message_id:
          ctx.callbackQuery.message?.reply_to_message?.message_id || 0,
      },
      disable_notification: true,
    },
  );
  await ctx.answerCallbackQuery();
});

keyboardComposer.callbackQuery(/work-[0-9]+/, async (ctx) => {
  const postId = Number(ctx.callbackQuery.data.split("-")[1]);
  await updatePostStatus(postId, "work");
  await ctx.editMessageText(generateText("work"), {
    reply_markup: generateKeyboard(postId, "work"),
  });
  await updateList();
  if (!ctx.chat) return;
  await ctx.api.sendMessage(
    ctx.chat.id,
    "🛠️ В работе (" + ctx.from.first_name + ")",
    {
      reply_parameters: {
        message_id:
          ctx.callbackQuery.message?.reply_to_message?.message_id || 0,
      },
      disable_notification: true,
    },
  );
  await ctx.answerCallbackQuery();
});

keyboardComposer.callbackQuery(/out-[0-9]+/, async (ctx) => {
  const postId = Number(ctx.callbackQuery.data.split("-")[1]);
  await updatePostStatus(postId, "out");
  await ctx.editMessageText(generateText("out"), {
    reply_markup: generateKeyboard(postId, "out"),
  });
  await updateList();
  if (!ctx.chat) return;
  await ctx.api.sendMessage(
    ctx.chat.id,
    "📤 Готовый (" + ctx.from.first_name + ")",
    {
      reply_parameters: {
        message_id:
          ctx.callbackQuery.message?.reply_to_message?.message_id || 0,
      },
      disable_notification: true,
    },
  );
  await ctx.answerCallbackQuery();
});

keyboardComposer.callbackQuery(/recent-[0-9]+/, async (ctx) => {
  const postId = Number(ctx.callbackQuery.data.split("-")[1]);
  await updatePostStatus(postId, "recent");
  await ctx.editMessageText(generateText("recent"), {
    reply_markup: generateKeyboard(postId, "recent"),
  });
  await updateList();
  await requestRecentDelete(postId); // ESPECIALLY FOR RECENT
  if (!ctx.chat) return;
  await ctx.api.sendMessage(
    ctx.chat.id,
    "🕒 Недавно выданный (" + ctx.from.first_name + ")",
    {
      reply_parameters: {
        message_id:
          ctx.callbackQuery.message?.reply_to_message?.message_id || 0,
      },
      disable_notification: true,
    },
  );
  await ctx.answerCallbackQuery();
});

keyboardComposer.callbackQuery(/reset-[0-9]+/, async (ctx) => {
  const postId = Number(ctx.callbackQuery.data.split("-")[1]);
  await resetPostDate(postId);
  try {
    await updateList();
    await ctx.answerCallbackQuery();
  } catch {
    await ctx.answerCallbackQuery();
  }
});

// hehe
const requestRecentDelete = async (postId: number) => {
  await kv.enqueue(postId, { delay: 2 * 24 * 60 * 60 * 1000 });
};