app.ts

import 'dotenv/config';
import { SocksProxyAgent } from 'socks-proxy-agent';
import { start } from './bot/start';
import { connect as mongoConnect } from './db_connect';
import { resubscribeInvoices } from './ln';
import { logger } from './logger';
import { Telegraf } from 'telegraf';
import { delay } from './util';
import { imageCache } from './util/imageCache';
import { createIndexes } from './models/indexes';
import { CommunityContext } from './bot/modules/community/communityContext';

(async () => {
  process.on('unhandledRejection', e => {
    if (e) {
      logger.error(`Unhandled Rejection: ${e}`);
    }
  });

  process.on('uncaughtException', e => {
    if (e) {
      logger.error(`Uncaught Exception: ${e}`);
    }
  });

  const mongoose = mongoConnect();
  mongoose.connection
    .once('open', async () => {
      logger.info('Connected to Mongo instance.');

      // Create database indexes for optimized queries
      await createIndexes();

      // Initialize image cache for faster order creation
      await imageCache.initialize();

      // Use configurable bot handler timeout, default to 60 seconds
      const handlerTimeout = parseInt(
        process.env.BOT_HANDLER_TIMEOUT || '60000',
      );
      let options: Partial<Telegraf.Options<CommunityContext>> = {
        handlerTimeout,
      };
      if (process.env.SOCKS_PROXY_HOST) {
        const agent = new SocksProxyAgent(process.env.SOCKS_PROXY_HOST);
        options = {
          ...options,
          telegram: {
            agent: agent as any,
          },
        };
      }
      const bot = start(String(process.env.BOT_TOKEN), options);
      // Wait 1 seconds before try to resubscribe hold invoices
      await delay(1000);
      await resubscribeInvoices(bot);
    })
    .on('error', (error: Error) =>
      logger.error(`Error connecting to Mongo: ${error}`),
    );
})();