如何在 Nestjs 中使用 Cron 和 Telegraf-bot？答案

【问题标题】：How to work with Cron and Telegraf-bot in Nestjs?如何在 Nestjs 中使用 Cron 和 Telegraf-bot？
【发布时间】：2022-03-05 11:31:17
【问题描述】：

我在我的 Nestjs 应用程序中使用来自 @nestjs/schedule 的 Telegraf 和 cron。

下面你可以看到我的app.module：

import { Module } from '@nestjs/common';
import { BotModule } from 'src/bot/bot.module';
import { TypeOrmModule } from '@nestjs/typeorm';
import { getConnectionOptions } from 'typeorm';
import { ConfigModule } from '@nestjs/config';
import { ScheduleModule } from '@nestjs/schedule';

@Module({
  imports: [
    BotModule,
    ScheduleModule.forRoot(),
    ConfigModule.forRoot({
      isGlobal: true
    }),
    TypeOrmModule.forRootAsync({
      useFactory: async () =>
        Object.assign(await getConnectionOptions(), {
          autoLoadEntities: true
        })
    })
  ]
})
export class AppModule {}

bot.module:

import { Module } from '@nestjs/common';
import { BotService } from 'src/bot/bot.service';
import { TelegrafModule } from 'nestjs-telegraf';
import { TypeOrmModule } from '@nestjs/typeorm';
import { TelegramBot } from './entities/bot.entity';

@Module({
  imports: [
    TypeOrmModule.forFeature([TelegramBot]),
    TelegrafModule.forRootAsync({
      useFactory: () => ({
        token: process.env.BOT_TELEGRAM_TOKEN
      })
    })
  ],
  providers: [BotService]
})
export class BotModule {}

bot.service：

import { Cron } from '@nestjs/schedule';
import { InjectRepository } from '@nestjs/typeorm';
import { On, Update } from 'nestjs-telegraf';
import { Context } from 'telegraf';
import { Repository } from 'typeorm';
import { TelegramBot } from './entities/bot.entity';

@Update()
export class BotService {
  constructor(
    @InjectRepository(TelegramBot)
    private telegramRepo: Repository<TelegramBot>
  ) {}

  @On('message')
  @Cron('*/30 * * * * *')
  async message(ctx: Context): Promise<void> {
    await ctx.reply('Hello there');
  }
}

我的主要目标是每 30 秒从机器人接收到聊天消息：“Hello there”，但相反，我在终端中什么也没收到和消息：

[Nest] 47039   - 15/09/2021, 15:39:30   [Scheduler] TypeError: Cannot read property 'reply' of undefined +30005ms
[Nest] 47039   - 15/09/2021, 15:40:00   [Scheduler] TypeError: Cannot read property 'reply' of undefined +29997ms
[Nest] 47039   - 15/09/2021, 15:40:30   [Scheduler] TypeError: Cannot read property 'reply' of undefined +29995ms
[Nest] 47039   - 15/09/2021, 15:41:00   [Scheduler] TypeError: Cannot read property 'reply' of undefined +30003ms
[Nest] 47039   - 15/09/2021, 15:41:30   [Scheduler] TypeError: Cannot read property 'reply' of undefined +29999ms
[Nest] 47039   - 15/09/2021, 15:42:00   [Scheduler] TypeError: Cannot read property 'reply' of undefined +30002ms

那么如何使用 Cron 与 Telegram bot 一起正常工作？

【问题讨论】：

ctx 是什么？你没有定义它
ctx - 是包含 Context 类和 Telegram Api 方法的数据
好吧，你必须将它导入到你的服务中

标签： node.js cron nestjs telegram-bot telegraf

【解决方案1】：

您的解决方案的主要问题是您无法在该场景中使用上下文。这是一个如何做到这一点的示例。

import { Injectable } from '@nestjs/common';
import { Cron, CronExpression } from "@nestjs/schedule";
import { Telegram } from 'telegraf';

@Injectable()
export class CronService {
  private readonly bot: Telegram = new Telegram(process.env.BOT_TOKEN);

  constructor() {}

  @Cron(CronExpression.EVERY_30_SECONDS)
  async runCronEvery30Seconds() {
    await this.bot.sendMessage('chat ID','Hello there');
  }

}

【讨论】：