main.ts

/*
ChannelActions Bot
Telegram: @ChannelActionsBot

(c) Aditya, https://xditya.me
*/

import config from "$env";
import composer from "./src/modules/mod.ts";
import { MyContext } from "./src/core/types.ts";
import { sessionsCollection } from "./src/database/sessionsDb.ts";
import i18n from "./src/core/i18n.ts";

import { serve } from "server";
import {
  Bot,
  GrammyError,
  HttpError,
  session,
  webhookCallback,
} from "grammy/mod.ts";
import { autoQuote } from "autoQuote";
import { hydrate } from "hydrate";
import { MongoDBAdapter } from "mongo_sessions";
import { conversations, createConversation } from "conversations";
import { inputWelcomeMsg } from "./src/helpers/conversationHelpers.ts";
import { run } from "grammy_runner";

await i18n.loadLocalesDir("locales");

// initialize the bot
const bot = new Bot<MyContext>(config.BOT_TOKEN);
await bot.init();

bot.use(hydrate());
bot.use(autoQuote);
bot.use(
  session({
    initial: () => ({}),
    storage: new MongoDBAdapter({ collection: sessionsCollection }),
  }),
);
bot.use(i18n);
bot.use(conversations());
bot.use(createConversation(inputWelcomeMsg));
bot.use(composer);

bot.catch((err) => {
  const ctx = err.ctx;
  console.error(`Error while handling update ${ctx.update.update_id}:`);
  const e = err.error;
  if (e instanceof GrammyError) {
    console.error("Error in request:", e.description);
  } else if (e instanceof HttpError) {
    console.error("Could not contact Telegram:", e);
  } else {
    console.error("Unknown error:", e);
  }
});

if (Deno.args[0] == "--polling") {
  console.info(`Started as @${bot.botInfo.username} on long polling.`);

  // we use grammy's runner for concurrency
  // basically, on local hosts, for broadcast plugin
  // to work without killing the main bot process.

  const runner = run(bot, undefined, {
    allowed_updates: ["chat_join_request", "message", "callback_query"],
  });
  const stopRunner = () => runner.isRunning() && runner.stop();
  Deno.addSignalListener("SIGINT", stopRunner);
  Deno.addSignalListener(
    Deno.build.os != "windows" ? "SIGTERM" : "SIGINT",
    () => stopRunner,
  );
} else {
  console.info(`Started as @${bot.botInfo.username} on webhooks.`);

  const handleUpdate = webhookCallback(bot, "std/http");
  serve(async (req) => {
    if (req.method === "POST") {
      const url = new URL(req.url);
      if (url.pathname.slice(1) === bot.token) {
        try {
          return await handleUpdate(req);
        } catch (err) {
          console.error(err);
        }
      }
    }
    return new Response("Welcome!");
  });
}

export default bot;