val bot = BotFactory.create(TOKEN) { coroutineContext = Dispatchers.IO // 可选地配置 engine，比如配置一个代理 apiClientEngine = CIO.create { proxy = ProxyBuilder.http("http://127.0.0.1:7790") } // 配置 longPolling 的值即代表启用主动拉取事件的形式，*类似于*其他组件中那种 ws 接收事件的方式。 // 不配置、配置为 `null` 则代表不启用。 longPolling = LongPolling( limit = 100, timeout = 10.minutes.inWholeSeconds.toInt(), allowedUpdates = setOf(UpdateValues.MESSAGE_NAME) ) } // 使用 `subscribe` 订阅所有事件、根据类型（以及名称）订阅事件 bot.subscribe { event -> println("Event: $event") } // 使用 onXxx 根据某个具体事件的扩展来订阅事件，等同于订阅一个对应类型、名称的事件。 // 比如此处，订阅事件类型为 `Message` 且事件名为 `"message"` 的事件。 bot.onMessage { event, message -> println("event: ${event}") println("message: ${message}") } // 启动并挂起bot bot.start() bot.join()

val bot = ... bot.start() // 假设你使用 Kror Server embeddedServer(Netty, port = 80) { routing { get ("/YOUR_ROUTE") { // The `Update` JSON string. val raw = call.receiveText() // Push `Update` to bot. Maybe in try-catch? Myabe in launch { ... } ? bot.pushUpdate(Update.decodeFromRawJson(raw), raw) // respond a result to Telegram call.respondText("""{"ok":true}""") } } }.start(wait = true)