feat: 支持注册自定义事件解析器

Author: ForteScarlet

build.gradle.kts

@@ -138,6 +138,9 @@ apiValidation {
             "love.forte.simbot.annotations.InternalSimbotAPI",
             "love.forte.simbot.component.onebot.common.annotations.ApiResultConstructor",
             "love.forte.simbot.component.onebot.common.annotations.SourceEventConstructor",
+
+            // CustomEventResolver
+            "love.forte.simbot.component.onebot.v11.core.event.ExperimentalCustomEventResolverApi"
         ),
     )
 

buildSrc/src/main/kotlin/P.kt

@@ -37,8 +37,8 @@ object P {
         override val description: String get() = DESCRIPTION
         override val homepage: String get() = HOMEPAGE
 
-        const val VERSION = "1.7.0"
-        const val NEXT_VERSION = "1.7.1"
+        const val VERSION = "1.8.0"
+        const val NEXT_VERSION = "1.8.0"
 
         override val snapshotVersion = "$NEXT_VERSION-SNAPSHOT"
         override val version = if (isSnapshot()) snapshotVersion else VERSION

simbot-component-onebot-v11/simbot-component-onebot-v11-core/build.gradle.kts

@@ -59,10 +59,21 @@ kotlin {
     applyTier3(supportKtorClient = true)
 
     sourceSets {
+        configureEach {
+            if (this.name == "jvmMain") {
+                dependencies {
+                    compileOnly(libs.simbot.api)
+                }
+            } else {
+                dependencies {
+                    implementation(libs.simbot.api)
+                }
+            }
+        }
         commonMain.dependencies {
             // JVM compileOnly
-            implementation(libs.simbot.api)
-            implementation(libs.jetbrains.annotations)
+            // implementation(libs.simbot.api)
+            api(libs.jetbrains.annotations)
 
             api(libs.simbot.common.annotations)
             implementation(libs.simbot.common.atomic)
@@ -92,9 +103,11 @@ kotlin {
 
         jvmMain {
             dependencies {
-                compileOnly(libs.simbot.api)
-                compileOnly(libs.ktor.client.contentNegotiation)
-                compileOnly(libs.jetbrains.annotations)
+                // api(libs.simbot.api)
+                // api(libs.jetbrains.annotations)
+                // compileOnly(libs.simbot.api)
+                // compileOnly(libs.ktor.client.contentNegotiation)
+                // compileOnly(libs.jetbrains.annotations)
             }
         }
 
@@ -105,10 +118,14 @@ kotlin {
             implementation(libs.log4j.slf4j2)
             implementation(libs.kotlinPoet)
             implementation(libs.kotlinx.coroutines.reactor)
-            api(libs.ktor.client.java)
+            implementation(libs.ktor.client.java)
             implementation(libs.ktor.server.netty)
             implementation(libs.ktor.server.ws)
         }
+
+        appleTest.dependencies {
+            implementation(libs.ktor.client.darwin)
+        }
     }
 }
 

simbot-component-onebot-v11/simbot-component-onebot-v11-core/src/commonMain/kotlin/love/forte/simbot/component/onebot/v11/core/api/OneBotApi.kt

@@ -52,7 +52,7 @@ public interface OneBotApi<T : Any> {
     public val resultDeserializer: DeserializationStrategy<T>
 
     /**
-     * 预期结果 [OneBotApi] 类型的反序列化器。
+     * 预期结果 [OneBotApiResult] 类型的反序列化器。
      */
     public val apiResultDeserializer: DeserializationStrategy<OneBotApiResult<T>>
 

simbot-component-onebot-v11/simbot-component-onebot-v11-core/src/commonMain/kotlin/love/forte/simbot/component/onebot/v11/core/bot/OneBotBot.kt

@@ -43,6 +43,7 @@ import love.forte.simbot.component.onebot.v11.message.OneBotMessageContent
 import love.forte.simbot.event.EventResult
 import love.forte.simbot.message.MessageReference
 import love.forte.simbot.suspendrunner.ST
+import org.intellij.lang.annotations.Language
 import kotlin.coroutines.CoroutineContext
 import kotlin.jvm.JvmSynthetic
 
@@ -200,14 +201,14 @@ public interface OneBotBot : Bot, OneBotApiExecutable {
      *
      * @throws IllegalArgumentException 如果事件解析失败
      */
-    public fun push(rawEvent: String): Flow<EventResult>
+    public fun push(@Language("json") rawEvent: String): Flow<EventResult>
 
     /**
      * 直接推送一个外部的原始事件字符串，并在异步任务中处理事件。
      *
      * @throws IllegalArgumentException 如果事件解析失败
      */
-    public fun pushAndLaunch(rawEvent: String): Job =
+    public fun pushAndLaunch(@Language("json") rawEvent: String): Job =
         push(rawEvent).launchIn(this)
 
     /**

simbot-component-onebot-v11/simbot-component-onebot-v11-core/src/commonMain/kotlin/love/forte/simbot/component/onebot/v11/core/bot/OneBotBotConfiguration.kt

@@ -21,12 +21,17 @@ import io.ktor.client.*
 import io.ktor.client.engine.*
 import io.ktor.client.plugins.*
 import io.ktor.http.*
+import kotlinx.serialization.DeserializationStrategy
 import kotlinx.serialization.modules.SerializersModule
 import kotlinx.serialization.modules.overwriteWith
 import love.forte.simbot.common.function.ConfigurerFunction
 import love.forte.simbot.common.function.invokeBy
 import love.forte.simbot.component.onebot.common.annotations.ExperimentalOneBotAPI
+import love.forte.simbot.component.onebot.v11.core.event.CustomEventResolver
+import love.forte.simbot.component.onebot.v11.core.event.CustomKotlinSerializationEventResolver
+import love.forte.simbot.component.onebot.v11.core.event.ExperimentalCustomEventResolverApi
 import love.forte.simbot.component.onebot.v11.message.segment.OneBotImage
+import love.forte.simbot.event.Event
 import love.forte.simbot.resource.Resource
 import kotlin.coroutines.CoroutineContext
 import kotlin.coroutines.EmptyCoroutineContext
@@ -252,4 +257,54 @@ public class OneBotBotConfiguration {
     public fun defaultImageAdditionalParams(params: OneBotImage.AdditionalParams?) {
         defaultImageAdditionalParamsProvider = { params }
     }
+
+    /**
+     *
+     * @since 1.8.0
+     */
+    @ExperimentalCustomEventResolverApi
+    internal val customEventResolvers: MutableList<CustomEventResolver> = mutableListOf()
+
+    /**
+     * 注册一个 [CustomEventResolver]。
+     * @since 1.8.0
+     */
+    @ExperimentalCustomEventResolverApi
+    public fun addCustomEventResolver(customEventResolver: CustomEventResolver) {
+        customEventResolvers.add(customEventResolver)
+    }
+}
+
+/**
+ * 添加一个 [CustomKotlinSerializationEventResolver]。
+ *
+ * @see OneBotBotConfiguration.addCustomEventResolver
+ * @since 1.8.0
+ */
+@ExperimentalCustomEventResolverApi
+public fun OneBotBotConfiguration.addCustomKotlinSerializationEventResolver(resolver: CustomKotlinSerializationEventResolver) {
+    addCustomEventResolver(resolver)
+}
+
+/**
+ * 添加一个 [CustomKotlinSerializationEventResolver]。
+ * 原则上通过 `postType` 和 `subType` 可以定位唯一一个事件类型。
+ *
+ * @see OneBotBotConfiguration.addCustomEventResolver
+ * @since 1.8.0
+ */
+@ExperimentalCustomEventResolverApi
+public inline fun OneBotBotConfiguration.addCustomKotlinSerializationEventResolver(
+    postType: String,
+    subType: String,
+    crossinline deserializationStrategy: () -> DeserializationStrategy<Event>
+) {
+    addCustomKotlinSerializationEventResolver { context ->
+        val rawEventResolveResult = context.rawEventResolveResult
+        if (rawEventResolveResult.postType == postType && rawEventResolveResult.subType == subType) {
+            deserializationStrategy()
+        } else {
+            null
+        }
+    }
 }