import { Bot, Context, session } from 'grammy';

@Injectable()
export class BotService {
  private readonly bot: Bot<Context>;
  private readonly logger = new Logger(BotService.name);
  private readonly WEB_APP_LINK: string;
  private readonly CHANNEL_ID: string;

  constructor(
    private readonly configService: ConfigService,
    private readonly usersService: UsersService,
  ) {
    const telegramBotKey = this.configService.get<string>('TELEGRAM_BOT_KEY');
    this.WEB_APP_LINK = this.configService.get<string>('WEB_APP_LINK') || '';
    this.bot = new Bot<Context>(telegramBotKey || '');
    this.CHANNEL_ID =
      this.configService.get<string>('TELEGRAM_CHANNEL_ID') || '';
  }
  async isUserSubscribed(tgUserId: string): Promise<boolean> {
    try {
      const member = await this.bot.api.getChatMember(
        this.CHANNEL_ID,
        +tgUserId,
      );
      return (
        member.status === 'administrator' ||
        member.status === 'member' ||
        member.status === 'creator'
      );
    } catch (error) {
      if (error.code === 400) {
        return false;
      }
      this.logger.error(`Ошибка при проверке подписки: ${error.message}`);
      throw error;
    }
  }

  async initializeBot() {
    // Middleware для сессий, (admin, superadmin)
    this.bot.use(session({ initial: () => ({}) }));

    this.bot.command('start', async (ctx) => {
      //Опишите как хотите. Тут оставил пример как нахожу пользователя
      const user = await this.usersService.findOneByTgId(tgUserId);
    });

    this.bot.catch((err) => {
      this.logger.error(`Ошибка в боте: ${err.error}`);
      // Можете добавить уведомление об ошибке
    });

    // Запуск бота
    this.bot.start();
    this.logger.log('Telegram-бот запущен');
  }
}