基础知识
Koishi 通过适配器插件来实现对不同聊天平台的支持。
一方面,适配器插件需要接收来自聊天平台的消息,并将其转换为 Koishi 的标准格式并触发会话事件;另一方面,对于来自 Koishi 内部的请求,适配器也需要将其转换为聊天平台的格式并发送出去。我们可以简单地将这两个过程概括成「接收」和「发送」。
在 Koishi 中,尽管适配器要处理的逻辑随着平台的不同而变化,但本质上所有适配器的结构都是类似的:通过实现 Bot
类完成发送的功能,而通过实现 Adapter
类完成接收的功能。我们先介绍一些与跨平台相关的核心概念,随后将给出一个最简单的适配器插件示例。
Concepts de base
在我们开始之前,先来了解一些与跨平台相关的核心概念。
平台 (Platform) 是指聊天平台,比如 Discord、Telegram 等。同一平台内的用户间具有相互发送消息的能力,而不同平台的用户间则没有。对于 Rocket Chat 这一类可自建的聊天平台而言,每个独立的自建服务器都视为不同的平台。
机器人 (Bot) 是指由 Koishi 操控的平台用户。这里的用户可以是真实用户,也可以是部分平台专门提供的机器人用户。其他用户通过与机器人进行交互来体验 Koishi 的各项功能。
适配器 (Adapter) 是指实现了平台协议,能够让机器人接入平台的插件。通常来说一个适配器实例对应了一个机器人用户,同时启用多个适配器就实现了多个机器人的同时接入。
消息 (Message) 是字面意义上的消息。通常是文本或富文本格式的,有时也会包含图片、语音等媒体资源。在 Koishi 中,消息通过消息元素进行统一编码。
频道 (Channel) 是消息的集合。一个频道包含了具备时间、逻辑顺序的一系列消息。频道又分为私聊频道和群聊频道,其中私聊频道有且仅有两人参与,而群聊频道可以有任意多人参与。
群组 (Guild) 是平台用户的集合。一个群组通常会同时包含一组用户和频道,并通过权限机制让其中的部分用户进行管理。在部分平台中,群组和群聊频道的概念恰好是重合的 (例如 QQ):一个群组内有且仅有一个群聊频道。私聊频道不属于任何群组。
REPL 适配器
下面展示的插件是 REPL 适配器,它可以接收来自命令行的消息,并把 Koishi 的回复同样输出到命令行中。你可以在 这个仓库 查看它的源码。
REPL 的意思是 Read-Eval-Print-Loop (读取-求值-输出-循环),是一种交互式环境。
REPL 适配器有三个文件。首先来看入口文件 index.ts
,它什么事都没做:
import ReplBot from './bot'
export default ReplBot
接下来是 bot.ts
。我们可以看到它实现了 sendMessage
方法,用来发送消息:
import { Bot, Context, h, Schema } from 'koishi'
import { EOL } from 'os'
import ReplAdapter from './adapter'
export interface Config {}
export const Config: Schema<Config> = Schema.object({})
export default class ReplBot extends Bot {
constructor(ctx: Context, config: Config) {
super(ctx, config)
this.platform = 'repl'
this.selfId = 'koishi'
ctx.plugin(ReplAdapter, this)
}
async createMessage(channelId: string, content: h.Fragment) {
process.stdout.write(h('', content).toString(true))
process.stdout.write(EOL)
return []
}
}
最后是 adapter.ts
,它创建了一个 readline 接口,用于接收消息并生成会话:
import { Adapter, Context } from 'koishi'
import { createInterface } from 'readline'
import ReplBot from './bot'
export default class ReplAdapter extends Adapter<ReplBot> {
rl = createInterface({
input: process.stdin,
})
async start(bot: ReplBot) {
bot.online()
this.rl.on('line', (line) => {
const session = bot.session()
session.type = 'message'
session.userId = 'repl'
session.channelId = 'repl'
session.isDirect = true
session.content = line
bot.dispatch(session)
})
}
async stop(bot: ReplBot) {
this.rl.close()
}
}
真实的聊天平台当然会比命令行交互复杂得多,但你仍然可以使用相同的结构来实现它们。在接下来的几节中,我们会进一步介绍适配器插件的更多设计细节。