libraries: Add the OneBot v11 channel

app/build.gradle.kts

@@ -13,6 +13,8 @@ dependencies {
     implementation(project(":libraries:commands"))
     implementation(project(":libraries:channels:telegram"))
     implementation(project(":libraries:channel-common"))
+    implementation(project(":libraries:channels:onebot"))
+    implementation(project(":libraries:channels:qqbot"))
     implementation(project(":libraries:provider-common"))
     implementation(project(":libraries:providers:openai-compatible"))
     implementation(project(":libraries:providers:openai-responses"))

app/src/dist/config/alexandrite.example.json

@@ -29,5 +29,37 @@
         "enabled": false
       }
     }
+  },
+  "channels": {
+    "onebot": {
+      "enabled": false,
+      "settings": {
+        "eventQueueCapacity": 1024
+      },
+      "instances": {
+        "main": {
+          "transport": "ws_reverse",
+          "listenHost": "127.0.0.1",
+          "listenPort": 8080,
+          "allowedChats": [],
+          "admins": [],
+          "approvalMinutes": 10
+        }
+      }
+    },
+    "qqbot": {
+      "enabled": false,
+      "instances": {
+        "main": {
+          "appId": "10000",
+          "appSecret": "replace-with-the-app-secret",
+          "apiBase": "https://api.bot.qq.com",
+          "intents": 33554432,
+          "streaming": true,
+          "approvalMinutes": 10,
+          "admins": []
+        }
+      }
+    }
   }
 }

app/src/main/resources/alexandrite/app-i18n/alexandrite-channel-onebot/zh-CN.properties

@@ -0,0 +1,86 @@
+approval.title=需要批准（#{id}）
+approval.agent=智能体：{agent}
+approval.chat=聊天：{chat}
+approval.requester=发起人：{requester}
+approval.reason=原因：{reason}
+approval.tool=工具：{tool}（{risk}）
+approval.file=文件：{path}
+approval.directory=目录：{directory}
+approval.program=程序：{program}
+approval.program_unknown=未找到
+approval.opaque=不透明：变石看不到这个程序运行了什么。
+approval.arguments=参数：
+approval.answer=回复本条消息，发送 /approve 或 /deny。
+approval.always_rule=永久允许将授予：{rule}
+approval.outcome_allowed=批准 {id} 已由 {name} 允许。
+approval.outcome_allowed_always=批准 {id} 已由 {name} 永久允许，同时授予 {rule}。
+approval.outcome_denied=批准 {id} 已由 {name} 拒绝。
+approval.outcome_expired=批准 {id} 已过期，无人应答。
+approval.outcome_withdrawn=批准 {id} 已撤回，不再等待应答。
+approval.admins_only=只有本实例的管理员可以应答。
+approval.not_pending=该请求已不再等待应答。
+approval.nothing_waits=本聊天没有等待中的批准请求。
+approval.list_title=本聊天等待中的批准请求：
+approval.list_entry=- {id}  {tool}  {reason}
+approval.list_hint=回复其中一条消息，发送 /approve 或 /deny。
+approval.several=这没有指出唯一的请求：{ids}。请写出所需那一个的完整 id。
+refused.admin=只有本实例的管理员可以使用 /{command}。
+refused.admin_here=只有本实例的管理员可以在本聊天使用 /{command}。
+pairing.code=本聊天尚未与变石配对。请把配对码 {code} 交给运维方，该码 {minutes} 分钟内有效。
+activity.verb.read.present=正在读取
+activity.verb.read.past=读取了
+activity.verb.list.present=正在列出
+activity.verb.list.past=列出了
+activity.verb.search.present=正在进行
+activity.verb.search.past=进行了
+activity.verb.edit.present=正在编辑
+activity.verb.edit.past=编辑了
+activity.verb.delete.present=正在删除
+activity.verb.delete.past=删除了
+activity.verb.move.present=正在移动
+activity.verb.move.past=移动了
+activity.verb.execute.present=正在运行
+activity.verb.execute.past=运行了
+activity.verb.fetch.present=正在获取
+activity.verb.fetch.past=获取了
+activity.verb.think.present=正在思考
+activity.verb.think.past=思考了
+activity.verb.other.present=正在使用
+activity.verb.other.past=使用了
+activity.noun.read.one={count} 个文件
+activity.noun.read.many={count} 个文件
+activity.noun.list.one={count} 个目录
+activity.noun.list.many={count} 个目录
+activity.noun.search.one={count} 次搜索
+activity.noun.search.many={count} 次搜索
+activity.noun.edit.one={count} 个文件
+activity.noun.edit.many={count} 个文件
+activity.noun.delete.one={count} 个文件
+activity.noun.delete.many={count} 个文件
+activity.noun.move.one={count} 个文件
+activity.noun.move.many={count} 个文件
+activity.noun.execute.one={count} 条命令
+activity.noun.execute.many={count} 条命令
+activity.noun.fetch.one={count} 个网页
+activity.noun.fetch.many={count} 个网页
+activity.noun.think.one={count} 步
+activity.noun.think.many={count} 步
+activity.noun.other.one={count} 个工具
+activity.noun.other.many={count} 个工具
+activity.verb.send.present=正在发送
+activity.verb.send.past=发送了
+activity.noun.send.one={count} 个文件
+activity.noun.send.many={count} 个文件
+activity.summary.not_run=未执行：{noun}
+activity.omitted.one=较早的 {count} 项已省略
+activity.omitted.many=较早的 {count} 项已省略
+activity.call.waiting_approval=等待批准：{tool} {title}
+activity.call.not_run=未执行：{tool} {title}
+activity.call.backgrounded=已转入后台：{tool} {title}
+activity.call.exit=退出码 {code}
+activity.call.failed=失败
+activity.call.diff=+{added} -{removed}
+activity.delegate.present=正在委派给 {agent}
+activity.delegate.past=已委派给 {agent}
+activity.call.by_agent={agent} · {line}
+approval.always_rules=永久允许将授予：{rules}

app/src/main/resources/alexandrite/app-i18n/alexandrite-channel-qqbot/zh-CN.properties

@@ -0,0 +1,16 @@
+approval.title=需要批准（#{id}）
+approval.tool=工具：{tool}（{risk}）
+approval.reason=原因：{reason}
+approval.arguments=参数：
+approval.allow=允许
+approval.deny=拒绝
+approval.always=始终允许：{rule}
+approval.allowed=已允许（#{id}）
+approval.denied=已拒绝（#{id}）
+approval.expired=审批 #{id} 已过期
+approval.admins_only=只有管理员可以处理这条审批。
+approval.nothing_waiting=没有等待中的这条审批。
+approval.unreachable=没能把这条审批发给任何管理员。
+refused.admin=只有本实例的管理员可以使用 /{command}。
+refused.admin_here=只有本实例的管理员可以在本聊天使用 /{command}。
+approval.always_short=始终

app/src/test/kotlin/org/unitedsoftware/alexandrite/app/AppTextsTest.kt

@@ -75,6 +75,8 @@ class AppTextsTest {
                 "alexandrite-automation-heartbeat",
                 "alexandrite-automation-schedule",
                 "alexandrite-channel-telegram",
+                "alexandrite-channel-onebot",
+                "alexandrite-channel-qqbot",
                 "alexandrite-commands",
                 "alexandrite-mcp",
             ),

gradle/libs.versions.toml

@@ -11,6 +11,7 @@ logback = "1.6.5"
 junit = "6.1.3"
 kctfork = "0.14.0"
 poko = "0.23.2"
+java-websocket = "1.6.0"
 jline = "3.30.17"
 maven-publish = "0.37.0"
 
@@ -37,6 +38,7 @@ jline-terminal-jni = { module = "org.jline:jline-terminal-jni", version.ref = "j
 junit-bom = { module = "org.junit:junit-bom", version.ref = "junit" }
 junit-jupiter = { module = "org.junit.jupiter:junit-jupiter" }
 junit-platform-launcher = { module = "org.junit.platform:junit-platform-launcher" }
+java-websocket = { module = "org.java-websocket:Java-WebSocket", version.ref = "java-websocket" }
 
 [plugins]
 kotlin-jvm = { id = "org.jetbrains.kotlin.jvm", version.ref = "kotlin" }

libraries/agent/src/main/kotlin/org/unitedsoftware/alexandrite/agent/tool/AgentToolContext.kt

@@ -9,6 +9,7 @@ import org.unitedsoftware.alexandrite.agent.sandbox.CallSandboxes
 import org.unitedsoftware.alexandrite.agent.trust.CallTrust
 import org.unitedsoftware.alexandrite.agent.trust.TurnTaint
 import org.unitedsoftware.alexandrite.agent.workspace.Workspaces
+import org.unitedsoftware.alexandrite.sdk.chat.ChannelMessageRef
 import org.unitedsoftware.alexandrite.sdk.chat.ToolCallId
 import org.unitedsoftware.alexandrite.sdk.chat.TurnInfo
 import org.unitedsoftware.alexandrite.sdk.chat.TurnKind
@@ -32,6 +33,8 @@ internal class AgentToolContext(
     private val directories: ConversationDirectories,
     clearance: Clearance?,
     val taint: TurnTaint,
+    /** The message of the channel this turn answers, which a tool that acts on it is given. */
+    trigger: ChannelMessageRef?,
     /** What a sub-agent run that the call starts takes from its turn, null outside a turn. */
     val delegating: DelegatingTurn? = null,
     /** Whether the call's review asked for it to run as a background job from its start. */
@@ -85,6 +88,8 @@ internal class AgentToolContext(
     override val workspace: Path?
         get() = workspaces.paths[turn.agent]
 
+    override val trigger: ChannelMessageRef? = trigger
+
     override val conversationDirectory: Path
         get() = directories.path(turn)
 

libraries/agent/src/main/kotlin/org/unitedsoftware/alexandrite/agent/tool/ToolExecutor.kt

@@ -29,6 +29,7 @@ import org.unitedsoftware.alexandrite.agent.workspace.Workspaces
 import org.unitedsoftware.alexandrite.internal.text.fittingLength
 import org.unitedsoftware.alexandrite.sdk.channel.ToolCallStatus
 import org.unitedsoftware.alexandrite.sdk.channel.TurnEvent
+import org.unitedsoftware.alexandrite.sdk.chat.ChannelMessageRef
 import org.unitedsoftware.alexandrite.sdk.chat.TurnInfo
 import org.unitedsoftware.alexandrite.sdk.di.Singleton
 import org.unitedsoftware.alexandrite.sdk.permission.ClearanceKind
@@ -93,6 +94,7 @@ internal class ToolExecutor(
         callable: Set<String>,
         taint: TurnTaint,
         calls: TurnCalls,
+        trigger: ChannelMessageRef?,
     ): ToolCallEnd {
         val tool = tools[call.name]
             ?: return ended(call, "No tool named '${call.name}' is offered.", NotRunReason.UNKNOWN_TOOL, calls)
@@ -102,7 +104,16 @@ internal class ToolExecutor(
         val arguments = call.parseArguments()
             ?: return ended(call, "The arguments are not a JSON object.", NotRunReason.INVALID_ARGUMENTS, calls)
         val limit = tool.definition.timeout?.let { maxOf(timeout, it + DECLARED_TIMEOUT_GRACE) } ?: timeout
-        val reviewing = AgentToolContext(turn, call.id, workspaces, directories, null, taint, sandboxes = sandboxes)
+        val reviewing = AgentToolContext(
+            turn,
+            call.id,
+            workspaces,
+            directories,
+            null,
+            taint,
+            trigger,
+            sandboxes = sandboxes,
+        )
         val admission = try {
             gate.admit(GateCall(turn, call, tool, arguments, limit, taint, reviewing, calls))
         } finally {
@@ -125,6 +136,7 @@ internal class ToolExecutor(
                     directories,
                     admission.clearance,
                     taint,
+                    trigger,
                     delegating,
                     startsInBackground = admission.background && tool !is InTurnTool,
                     granting = { grants.grant(turn, tool) },

libraries/agent/src/main/kotlin/org/unitedsoftware/alexandrite/agent/turn/AgentTurnRunner.kt

@@ -1043,6 +1043,7 @@ internal class AgentTurnRunner(
                                     callable,
                                     taint,
                                     tracked,
+                                    plan.trigger,
                                 )
                                 reads.reason(turn, call.name, end.tainting)?.let { taint.mark(it) }
                                 taint.record()

libraries/agent/src/test/kotlin/org/unitedsoftware/alexandrite/agent/job/JobsTest.kt

@@ -95,7 +95,7 @@ class JobsTest {
             NoTaintLedger,
         )
         val name = tool.definition.name
-        return executor.execute(turn, call, mapOf(name to tool), timeout, setOf(name), taint, DirectCalls)
+        return executor.execute(turn, call, mapOf(name to tool), timeout, setOf(name), taint, DirectCalls, null)
     }
 
     private suspend fun recorded(): Set<RunId> = JobRecords(records.of("alexandrite-agent")).all().keys

libraries/agent/src/test/kotlin/org/unitedsoftware/alexandrite/agent/permission/PermissionStatusToolTest.kt

@@ -90,6 +90,7 @@ class PermissionStatusToolTest {
         ConversationDirectories(ConventionalAgentPlaces(hostPaths(null)), settings("{}")),
         null,
         taint,
+        null,
     )
 
     private suspend fun status(

libraries/agent/src/test/kotlin/org/unitedsoftware/alexandrite/agent/tool/ToolExecutorTest.kt

@@ -126,7 +126,7 @@ class ToolExecutorTest {
 
     private suspend fun ToolExecutor.executed(tool: Tool, timeout: Duration = 120.seconds): ToolCallEnd {
         val name = tool.definition.name
-        return execute(turn, call, mapOf(name to tool), timeout, setOf(name), taint, DirectCalls)
+        return execute(turn, call, mapOf(name to tool), timeout, setOf(name), taint, DirectCalls, null)
     }
 
     private fun ToolResultEntry.text(): String = content.joinToString("") { (it as TextPart).text }
@@ -158,7 +158,7 @@ class ToolExecutorTest {
                 val edits = ToolCallPart(ToolCallId("call-1"), "fs.edit", "{}")
                 executor(
                     gate,
-                ).execute(turn, edits, mapOf("fs.edit" to edit), 120.seconds, setOf("fs.edit"), taint, calls)
+                ).execute(turn, edits, mapOf("fs.edit" to edit), 120.seconds, setOf("fs.edit"), taint, calls, null)
                 ended.single()
             }
 

libraries/channels/onebot/build.gradle.kts

@@ -0,0 +1,18 @@
+plugins {
+    id("alexandrite.kotlin-library")
+    id("alexandrite.kotlin-serialization")
+}
+
+description = "The OneBot v11 channel of Alexandrite"
+
+dependencies {
+    implementation(project(":libraries:channel-common"))
+    api(project(":libraries:plugin-sdk"))
+    implementation(project(":libraries:internal"))
+
+    // The client and the server of the Websocket transports, of which the JDK offers a client only.
+    implementation(libs.java.websocket)
+
+    testImplementation(project(":libraries:testkit"))
+    testImplementation(libs.logback.classic)
+}

libraries/channels/onebot/src/main/kotlin/org/unitedsoftware/alexandrite/channel/onebot/OneBotPlugin.kt

@@ -0,0 +1,7 @@
+package org.unitedsoftware.alexandrite.channel.onebot
+
+import org.unitedsoftware.alexandrite.sdk.plugin.Plugin
+
+/** The OneBot v11 channel plugin, which talks to an external OneBot implementation such as NapCat. */
+@Plugin(name = "OneBot", description = "OneBot v11 channel")
+internal class OneBotPlugin