refactor(core): rename signal to transformer

Author: Wesley-Young

acidify-core/src/commonMain/kotlin/org/ntqqrev/acidify/AbstractBot.kt

@@ -18,8 +18,8 @@ import org.ntqqrev.acidify.entity.BotFriend
 import org.ntqqrev.acidify.entity.BotGroup
 import org.ntqqrev.acidify.entity.internal.BotEntityCache
 import org.ntqqrev.acidify.event.AcidifyEvent
-import org.ntqqrev.acidify.event.internal.KickSignal
-import org.ntqqrev.acidify.event.internal.MsgPushSignal
+import org.ntqqrev.acidify.event.internal.KickTransformer
+import org.ntqqrev.acidify.event.internal.MsgPushTransformer
 import org.ntqqrev.acidify.internal.AbstractClient
 import org.ntqqrev.acidify.logging.LogHandler
 import org.ntqqrev.acidify.logging.LogLevel
@@ -40,9 +40,9 @@ sealed class AbstractBot(
         extraBufferCapacity = 100,
         onBufferOverflow = BufferOverflow.DROP_OLDEST
     )
-    internal val signals = listOf(
-        MsgPushSignal,
-        KickSignal
+    internal val transformers = listOf(
+        MsgPushTransformer,
+        KickTransformer
     ).associateBy { it.cmd }
     internal lateinit var faceDetailMapMut: Map<String, BotFaceDetail>
     internal var eventCollectJob: Job? = null

acidify-core/src/commonMain/kotlin/org/ntqqrev/acidify/SystemOps.kt

@@ -27,14 +27,14 @@ suspend fun AbstractBot.online(preloadContacts: Boolean = false) {
     eventCollectJob = launch {
         while (currentCoroutineContext().isActive) {
             val sso = client.pushChannel.receive()
-            val signal = signals[sso.command]
-            if (signal != null) {
+            val transformer = transformers[sso.command]
+            if (transformer != null) {
                 try {
-                    val parsed = signal.parse(this@online, sso.response)
-                    logger.v { "由 ${sso.command} 解析出事件：$parsed" }
+                    val parsed = transformer.parse(this@online, sso.response)
+                    logger.v { "由推送 ${sso.command} 解析出事件：$parsed" }
                     parsed.forEach { sharedEventFlow.emit(it) }
                 } catch (e: Exception) {
-                    logger.e(e) { "处理信令 ${sso.command} 时出现错误" }
+                    logger.e(e) { "处理推送 ${sso.command} 时出现错误" }
                 }
             }
         }

…acidify/event/internal/AbstractSignal.kt …fy/event/internal/AbstractTransformer.ktacidify-core/src/commonMain/kotlin/org/ntqqrev/acidify/event/internal/AbstractSignal.kt renamed to acidify-core/src/commonMain/kotlin/org/ntqqrev/acidify/event/internal/AbstractTransformer.kt acidify-core/src/commonMain/kotlin/org/ntqqrev/acidify/event/internal/AbstractSignal.kt renamed to acidify-core/src/commonMain/kotlin/org/ntqqrev/acidify/event/internal/AbstractTransformer.kt

@@ -3,6 +3,6 @@ package org.ntqqrev.acidify.event.internal
 import org.ntqqrev.acidify.AbstractBot
 import org.ntqqrev.acidify.event.AcidifyEvent
 
-internal abstract class AbstractSignal(val cmd: String) {
+internal abstract class AbstractTransformer(val cmd: String) {
     abstract suspend fun parse(bot: AbstractBot, payload: ByteArray): List<AcidifyEvent>
 }

…rev/acidify/event/internal/KickSignal.kt …cidify/event/internal/KickTransformer.ktacidify-core/src/commonMain/kotlin/org/ntqqrev/acidify/event/internal/KickSignal.kt renamed to acidify-core/src/commonMain/kotlin/org/ntqqrev/acidify/event/internal/KickTransformer.kt acidify-core/src/commonMain/kotlin/org/ntqqrev/acidify/event/internal/KickSignal.kt renamed to acidify-core/src/commonMain/kotlin/org/ntqqrev/acidify/event/internal/KickTransformer.kt

@@ -6,7 +6,7 @@ import org.ntqqrev.acidify.event.BotOfflineEvent
 import org.ntqqrev.acidify.internal.proto.system.KickNT
 import org.ntqqrev.acidify.internal.util.pbDecode
 
-internal object KickSignal : AbstractSignal("trpc.qq_new_tech.status_svc.StatusService.KickNT") {
+internal object KickTransformer : AbstractTransformer("trpc.qq_new_tech.status_svc.StatusService.KickNT") {
     override suspend fun parse(bot: AbstractBot, payload: ByteArray): List<AcidifyEvent> {
         val kickNT = payload.pbDecode<KickNT>()
         return listOf(

…/acidify/event/internal/MsgPushSignal.kt …ify/event/internal/MsgPushTransformer.ktacidify-core/src/commonMain/kotlin/org/ntqqrev/acidify/event/internal/MsgPushSignal.kt renamed to acidify-core/src/commonMain/kotlin/org/ntqqrev/acidify/event/internal/MsgPushTransformer.kt acidify-core/src/commonMain/kotlin/org/ntqqrev/acidify/event/internal/MsgPushSignal.kt renamed to acidify-core/src/commonMain/kotlin/org/ntqqrev/acidify/event/internal/MsgPushTransformer.kt

@@ -23,7 +23,7 @@ import org.ntqqrev.acidify.struct.RequestState
 import kotlin.time.Clock
 
 @Suppress("duplicatedCode")
-internal object MsgPushSignal : AbstractSignal("trpc.msg.olpush.OlPushService.MsgPush") {
+internal object MsgPushTransformer : AbstractTransformer("trpc.msg.olpush.OlPushService.MsgPush") {
     override suspend fun parse(bot: AbstractBot, payload: ByteArray): List<AcidifyEvent> {
         val commonMsg = payload.pbDecode<PushMsg>().message
         val contentHead = commonMsg.contentHead