Flutter Telegram Bot集成插件dart_telegram_bot的使用

dart_telegram_bot 是一个用于 Dart 的 Telegram Bot API 包装库，支持原生、Flutter 和 JS。以下是该库的基本用法示例和一些高级功能。

安装

首先，在你的 pubspec.yaml 文件中添加依赖：

dependencies:
  dart_telegram_bot: ^latest_version

然后运行 flutter pub get 来安装包。

基本用法

以下是一个简单的回声机器人示例：

import 'package:dart_telegram_bot/dart_telegram_bot.dart';
import 'package:dart_telegram_bot/telegram_entities.dart';

void main() {
  Bot(
    token: 'YOUR_BOT_TOKEN',
    onReady: (bot) => bot.start(clean: true),
  ).onUpdate((bot, update) async {
    if (update.message != null && update.message!.text != null) {
      bot.sendMessage(ChatID(update.message!.chat.id), update.message!.text!);
    }
  });
}

错误处理

为了处理启动失败的情况，可以添加 onStartFailed 回调：

void main() {
  Bot(
    token: 'YOUR_BOT_TOKEN',
    onReady: (bot) => bot.start(clean: true),
    onStartFailed: (bot, e, s) => print('Start failed: $e'),
  );
}

过滤更新类型

你可以选择性地允许或禁止某些类型的更新：

void main() {
  Bot(
    token: 'YOUR_BOT_TOKEN',
    onReady: (bot) => bot.start(clean: true),
    allowedUpdates: UpdateType.allBut([UpdateType.channelPost]), // 允许所有但频道帖子
    // 或者只允许特定类型的更新
    // allowedUpdates: [UpdateType.message, UpdateType.editedMessage],
  );
}

面向对象编程（OOP）方法

你也可以通过继承 Bot 类来创建更复杂的机器人：

class MyBot extends Bot {
  MyBot(String token) : super(token: token);

  [@override](/user/override)
  Future onReady(Bot bot) async {
    print('Bot ${bot.name} is ready');
    await start(clean: true);
  }

  [@override](/user/override)
  Future onStartFailed(Bot bot, Object err, StackTrace st) async {
    print('Bot failed to start: $err');
  }

  Future updateHandler(Bot bot, Update update) async {
    if (update.message != null && update.message!.text != null) {
      bot.sendMessage(ChatID(update.message!.chat.id), update.message!.text!);
    }
  }
}

void main() {
  MyBot('YOUR_BOT_TOKEN').onUpdate(updateHandler);
}

完整示例 Demo

下面是一个完整的示例，展示了如何处理命令和停止机器人：

import 'dart:io';

import 'package:dart_telegram_bot/dart_telegram_bot.dart';
import 'package:dart_telegram_bot/telegram_entities.dart';

class MyBot extends Bot {
  MyBot(String token) : super(token: token);

  Future<void> onBotCommand(Bot bot, Update update) async {
    var args = BotCommandParser.fromMessage(update.message!)?.args;
    if (args == null || args.isEmpty) {
      return bot.sendMessage(
        ChatID(update.message!.chat.id),
        'No arguments provided',
      );
    }

    if (args.length < 2) {
      return bot.sendMessage(
        ChatID(update.message!.chat.id),
        'Not enough arguments provided',
      );
    }

    // 处理正确的参数
  }

  [@override](/user/override)
  Future<void> onReady(Bot bot) async {
    print('Bot ${bot.name} is ready');
    onCommand('my_command', onBotCommand);
    await start(clean: true);
  }
}

void main() async {
  var token = Platform.environment['BOT_TOKEN']!;

  /// 使用 OOP 方法
  MyBot(token);

  /// 或者直接初始化并传递回调函数
  Future<void> onUpdate(Bot bot, Update update) async {
    if (update.message?.text == 'stop') {
      await bot.sendMessage(ChatID(update.message!.chat.id), 'Stopping...');
      bot.stop();
    }
  }

  Future<void> onReady(Bot bot) async {
    print('Bot ${bot.name} is ready');
    bot.onUpdate(onUpdate);
    await bot.start(clean: true);
  }

  Bot(
    token: token,
    onReady: onReady,
    onStartFailed: (bot, e, s) => print('Start failed: $e'),
    allowedUpdates: UpdateType.allBut([UpdateType.channelPost]),
  );
}