hereconnect/services/tg-bot/src/bot/index.ts

import { Bot, session } from "grammy";
import { conversations, createConversation } from "@grammyjs/conversations";
import { startHealthServer } from "@hereconnect/lib-service-health-checkserver";
import { MyContext } from "../types/myContext";
import { env } from "../config/env";
import { CouchDBStorageAdapter } from "./storageAdapters/CouchDBStorageAdapter";
import { loadUserMiddleware } from "./middleware/loadUser";
import { tgBotSessionsDb } from "../dbs";
import { setupCommands } from "./commands/setupCommands";
import { startCommand } from "./commands/start";
import { helpCommand } from "./commands/help";
import { newCommand } from "./commands/new";
import { manageCommand } from "./commands/manage";
import { callbackQueryHandler } from "./callbackHandlers";
import { newQRCodeConversation } from "./conversations/newQRCodeConversation";

const abortController = new AbortController();

const storage = new CouchDBStorageAdapter(tgBotSessionsDb, {
  softDelete: true,
  type: "tg_bot_session",
});

// Инициализируем бота с нужным типом контекста
const bot = new Bot<MyContext>(env.TELEGRAM_BOT_TOKEN, {
  client: {
    baseFetchConfig: {
      signal: abortController.signal,
    },
  },
});

// Подключаем сессии. По необходимости определите initial state для сессии
bot.use(session({ storage, initial: () => ({}) }));

// Подключаем conversations для многошаговых сценариев
bot.use(conversations());
bot.use(createConversation(newQRCodeConversation, "newQRCodeConversation"));

// Middleware для загрузки или создания пользователя
bot.use(loadUserMiddleware);

// Регистрация команд
bot.command("start", startCommand);
bot.command("help", helpCommand);
bot.command("new", newCommand);
bot.command("manage", manageCommand);

// Обработка callback_query
bot.on("callback_query:data", callbackQueryHandler);

(async () => {
  // Установка команд
  await setupCommands(bot);

  // Запуск бота
  bot.start();

  await startHealthServer(abortController);

  console.log("Бот запущен!");
})();

export { bot };