index.js

const express = require('express');
const TelegramBot = require('node-telegram-bot-api');
const { Message } = require("./lib/message");
const env = require("./env");
const path = require("path"); 
const prefix = (!env.HANDLERS || env.HANDLERS.trim() === 'null' || env.HANDLERS.trim() === 'false') ? '' : env.HANDLERS.trim();
const fs = require("fs");
const cmds = require("./lib/events");
let regex = new RegExp("^(" + prefix.replace(/[-\/\\^$*+?.()|[\]{}]/g, '\\$&') + ")(\\s)(.+)");


const app = express();
const port = process.env.PORT || 3000;

const client = new TelegramBot(env.TOKEN, { polling: true });
console.log("Bot started!");

console.log("🔀 Installing Plugins...");

fs.readdirSync(path.join(__dirname, "/plugins")).forEach((plugin) => {
  if (path.extname(plugin).toLowerCase() === ".js") {
    try {
      const pluginPath = path.join(__dirname, "/plugins/", plugin);
      require(pluginPath); 
      console.log(`Folder loaded: ${plugin}`); 
    } catch (e) {
      console.error(`Error in loading folder ${plugin}:`, e);
      fs.unlinkSync(path.join(__dirname, '/plugins/', plugin)); 
    }
  }
});

console.log("✅ Plugins Installed!");


client.onText(/\/start (.+)/, async (msg, match) => {
  try {
    const message = new Message(client, msg, prefix);
    if (!message.admin) {
      await message.send("<b>Ask admin for sudo to use Doraemon</b> \n\n <i>Your ID: " + msg.chat.id + "</i> \n <b>Admin: <a href=\"https://wa.me/917025673121\">Loki-Xer</a></b>", {
        parse_mode: "HTML",
        disable_web_page_preview: true
      });
    }
  } catch (error) {
    console.error("An error occurred:", error);
  }
});


client.on('message', async (msg) => {
  try {
    if (!msg) return;
    const message = new Message(client, msg, prefix);
    if (message.isBot) return;
    if (message.text.startsWith(prefix) && message.text[1] === " ") {
      message.text = message.text.replace(regex, '$1$3');
    }
    if (message.admin) {
      if (message.text.startsWith(">")) {
        let m = message;
        const code = message.text.slice(1).trim();
        try {
            let evaled = await eval(`(async () => { ${code} })()`);
            if (typeof evaled !== "string") evaled = require("util").inspect(evaled);
            return await message.send(evaled);
        } catch (error) {
            return await message.send(`${error.message}`);
        }
      }
    }

    for (const command of cmds.commands) {
      if (typeof command.pattern === 'string' && command.pattern.replace(/[^a-zA-Z0-9-+]/g, '')) {
       if (command.fromAdmin && !message.admin) return;
        const EventCmd = prefix + command.pattern.replace(/[^a-zA-Z0-9-+]/g, ''); 
        if (message.text.toLowerCase().startsWith(EventCmd)) {
          try {
            message.command = EventCmd.replace(prefix, "").trim();
            message.match = message.text.toLowerCase().replace(message.command, '').replace(prefix, "").trim();
            await command.function(message, message.match, client);
          } catch (e) {
            console.log(e);
          }
        }
      }
    }
   

    console.log("[TG BOT MESSAGE]");
    console.log(new Date());
    console.log(message.user.firstName);
    console.log(msg.text);

  } catch (error) {
    console.error('Error handling message:', error);
  }
});

client.on('callback_query', async (callbackQuery) => {
  try {
    const message = new Message(client, callbackQuery.message, prefix);
    message.action = prefix + callbackQuery.data;
    for (const command of cmds.commands) {
        if (typeof command.pattern === 'string' && command.pattern.replace(/[^a-zA-Z0-9-+]/g, '')) {
          if (command.fromAdmin && !message.admin) return;
          const EventCmd = prefix + command.pattern.replace(/[^a-zA-Z0-9-+]/g, ''); 
          if (message.action.toLowerCase().startsWith(EventCmd)) {
            try {
              message.command = EventCmd.replace(prefix, "").trim();
              message.match = message.action.toLowerCase().replace(message.command, '').replace(prefix, "").trim();
              await command.function(message, message.match, client);
            } catch (e) {
              console.log(e);
            }
          }
        }
      }
    
    console.log("[TG BOT CALLBACK QUERY]");
    console.log(new Date());
    console.log(message.user.firstName);
    console.log(callbackQuery.data);

  } catch (error) {
    console.error('Error handling callback query:', error);
  }
});

app.listen(port, () => {
  console.log(`Server is running on port ${port}`);
});