allow retrieving message exception in callback closes #18

Author: RTAkland

gradle.properties

@@ -6,7 +6,7 @@ kotlin.incremental.native=true
 org.gradle.test.skip=true
 kotlin.native.enableKlibsCrossCompilation=true
 SONATYPE_AUTOMATIC_RELEASE=true
-libVersion=3.3.3-alpha1
+libVersion=3.3.3
 #systemProp.http.proxyHost=127.0.0.1
 #systemProp.http.proxyPort=12334
 #systemProp.https.proxyHost=127.0.0.1

ronebot-onebot-v11/src/commonMain/kotlin/cn/rtast/rob/event/packed/MessageErrorEvent.kt

@@ -0,0 +1,39 @@
+/*
+ * Copyright © 2026 RTAkland
+ * Date: 2026/2/12 16:02
+ * Open Source Under Apache-2.0 License
+ * https://www.apache.org/licenses/LICENSE-2.0
+ */
+
+
+package cn.rtast.rob.event.packed
+
+import cn.rtast.rob.actionable.MessageActionable
+import cn.rtast.rob.event.OneBotEvent
+import cn.rtast.rob.event.raw.message.BaseMessage
+import cn.rtast.rob.event.raw.message.GroupMessage
+import cn.rtast.rob.event.raw.message.PrivateMessage
+import cn.rtast.rob.onebot.OneBotAction
+
+public sealed interface MessageErrorEvent<T : BaseMessage> {
+    public val message: T
+    public val exception: Exception
+}
+
+/**
+ * 精确到某一条群聊消息的错误事件
+ */
+public data class GroupMessageErrorEvent(
+    override val action: OneBotAction,
+    override val message: GroupMessage,
+    override val exception: Exception,
+) : OneBotEvent, MessageErrorEvent<GroupMessage>, MessageActionable by message
+
+/**
+ * 精确到某一条私聊消息的错误事件
+ */
+public data class PrivateMessageErrorEvent(
+    override val action: OneBotAction,
+    override val message: PrivateMessage,
+    override val exception: Exception,
+) : OneBotEvent, MessageErrorEvent<PrivateMessage>, MessageActionable by message

ronebot-onebot-v11/src/commonMain/kotlin/cn/rtast/rob/onebot/OneBotListener.kt

@@ -7,7 +7,9 @@
 
 package cn.rtast.rob.onebot
 
+import cn.rtast.rob.event.packed.GroupMessageErrorEvent
 import cn.rtast.rob.event.packed.MessageTimeoutEvent
+import cn.rtast.rob.event.packed.PrivateMessageErrorEvent
 import cn.rtast.rob.event.raw.file.RawFileEvent
 import cn.rtast.rob.event.raw.group.*
 import cn.rtast.rob.event.raw.internal.RawWebsocketCloseEvent
@@ -23,7 +25,6 @@ import cn.rtast.rob.event.raw.onebot.RawHeartBeatEvent
 import cn.rtast.rob.event.raw.request.AddFriendRequestEvent
 import cn.rtast.rob.event.raw.request.BeInviteGroupRequestEvent
 import cn.rtast.rob.event.raw.request.JoinGroupRequestEvent
-import kotlin.jvm.JvmSynthetic
 
 public interface OneBotListener {
 
@@ -206,4 +207,14 @@ public interface OneBotListener {
      * Bot在私聊中被戳一戳触发此事件
      */
     public suspend fun onPrivatePokeSelf(event: RawPokeEvent) {}
+
+    /**
+     * 精确到某一条群聊消息的错误事件
+     */
+    public suspend fun onGroupMessageError(event: GroupMessageErrorEvent) {}
+
+    /**
+     * 精确到某一条私聊消息的错误事件
+     */
+    public suspend fun onPrivateMessageError(event: PrivateMessageErrorEvent) {}
 }

ronebot-onebot-v11/src/commonMain/kotlin/cn/rtast/rob/util/MessageHandler.kt

@@ -107,24 +107,39 @@ internal class MessageHandler(
                         ).apply { action = botInstance.action }
                         msg.sender = newSenderWithGroupId
                         if (msg.groupId !in botInstance.listenedGroups && botInstance.listenedGroups.isNotEmpty()) return
-                        botInstance.dispatchEvent(GroupMessageEvent(botInstance.action, msg))
-                        listener.onGroupMessage(msg)
-                        OneBotFactory.commandManager.handleGroup(msg)
+                        try {
+                            botInstance.dispatchEvent(GroupMessageEvent(botInstance.action, msg))
+                            listener.onGroupMessage(msg)
+                            OneBotFactory.commandManager.handleGroup(msg)
+                        } catch (e: Exception) {
+                            @Suppress("LocalVariableName")
+                            val _event = GroupMessageErrorEvent(botInstance.action, msg, e)
+                            botInstance.dispatchEvent(_event)
+                            listener.onGroupMessageError(_event)
+                        }
                     }
 
                     InboundMessageType.private -> {
                         val msg = message.fromJson<PrivateMessage>()
                         msg.sessionId = Uuid.random()
                         msg.action = botInstance.action
                         msg.sender.action = botInstance.action
-                        botInstance.dispatchEvent(PrivateMessageEvent(botInstance.action, msg))
-                        listener.onPrivateMessage(msg)
-                        OneBotFactory.commandManager.handlePrivate(msg)
+                        try {
+                            botInstance.dispatchEvent(PrivateMessageEvent(botInstance.action, msg))
+                            listener.onPrivateMessage(msg)
+                            OneBotFactory.commandManager.handlePrivate(msg)
+                        } catch (e: Exception) {
+                            @Suppress("LocalVariableName")
+                            val _event = PrivateMessageErrorEvent(botInstance.action, msg, e)
+                            botInstance.dispatchEvent(_event)
+                            listener.onPrivateMessageError(_event)
+                        }
                     }
 
                     null -> listener.onRawMessage(botInstance.action, message)
                 }
                 return
+
             }
 
             if (serializedMessage.postType == PostType.request) {

ronebot-onebot-v11/src/jvmTest/kotlin/test/TestClient.kt

@@ -11,13 +11,12 @@ import cn.rtast.rob.OneBotFactory
 import cn.rtast.rob.annotations.ExperimentalROneBotApi
 import cn.rtast.rob.command.BaseCommand
 import cn.rtast.rob.entity.toResource
-import cn.rtast.rob.event.packed.GroupMessageEvent
+import cn.rtast.rob.event.packed.GroupMessageErrorEvent
+import cn.rtast.rob.event.packed.PrivateMessageErrorEvent
 import cn.rtast.rob.event.raw.internal.RawWebsocketErrorEvent
 import cn.rtast.rob.event.raw.message.GroupMessage
 import cn.rtast.rob.event.raw.message.PrivateMessage
 import cn.rtast.rob.event.raw.message.text
-import cn.rtast.rob.event.subscribe
-import cn.rtast.rob.hooking.Hookable
 import cn.rtast.rob.onebot.OneBotListener
 import cn.rtast.rob.onebot.dsl.image
 import cn.rtast.rob.onebot.dsl.text
@@ -81,14 +80,22 @@ class TestClient {
                     throw RuntimeException("test exception")
                 }
 
+                override suspend fun onPrivateMessage(message: PrivateMessage) {
+                    throw RuntimeException("priv ex")
+                }
+
                 override suspend fun onWebsocketErrorEvent(event: RawWebsocketErrorEvent) {
                     println(event.exception)
                 }
+
+                override suspend fun onGroupMessageError(event: GroupMessageErrorEvent) {
+                    println("msg err ${event.message} ${event.exception}")
+                }
+
+                override suspend fun onPrivateMessageError(event: PrivateMessageErrorEvent) {
+                    println("priv msg err ${event.message} ${event.exception}")
+                }
             }, logLevel = LogLevel.DEBUG)
-            instance1.subscribe<GroupMessageEvent> {
-                println("sub")
-            }
-            instance1.action.setGroupRequest("1770816695582896", "invite")
             instance1.addListeningGroup(qqGroupId)
             OneBotFactory.commandManager.register(TestCommand())
             while (true) {