feat: implement time for constructed outgoing forwards

Author: Wesley-Young

acidify-core/src/commonMain/kotlin/org/ntqqrev/acidify/message/BotOutgoingMessageBuilder.kt

@@ -8,6 +8,7 @@ import org.ntqqrev.acidify.common.AcidifyDsl
 import org.ntqqrev.acidify.common.MediaSource
 import org.ntqqrev.acidify.common.MediaSource.Companion.toMediaSource
 import kotlin.js.JsName
+import kotlin.time.Clock
 
 /**
  * 构建发送消息
@@ -175,11 +176,13 @@ class BotOutgoingMessageBuilder {
          * 添加一个伪造合并转发消息
          * @param senderUin 该消息的发送者 QQ 号
          * @param senderName 该消息的发送者昵称
+         * @param timestamp 该消息的 Unix 事件戳（秒）
          * @param block 构建该消息的内容
          */
         inline fun node(
             senderUin: Long,
             senderName: String,
+            timestamp: Long = Clock.System.now().epochSeconds,
             block: BotOutgoingMessageBuilder.() -> Unit
         ) {
             val messageBuilder = BotOutgoingMessageBuilder()
@@ -188,7 +191,8 @@ class BotOutgoingMessageBuilder {
                 BotOutgoingSegment.Forward.Node(
                     senderUin,
                     senderName,
-                    messageBuilder.segments
+                    messageBuilder.segments,
+                    timestamp,
                 )
             )
         }

acidify-core/src/commonMain/kotlin/org/ntqqrev/acidify/message/BotOutgoingSegment.kt

@@ -4,6 +4,7 @@ import org.ntqqrev.acidify.common.MediaSource
 import org.ntqqrev.acidify.common.MediaSource.Companion.toMediaSource
 import kotlin.js.JsExport
 import kotlin.js.JsName
+import kotlin.time.Clock
 
 /**
  * 发送消息段
@@ -185,11 +186,13 @@ sealed class BotOutgoingSegment {
          * @property senderUin 发送者 QQ 号
          * @property senderName 发送者名称
          * @property segments 消息内容
+         * @property timestamp 消息的 Unix 事件戳（秒）
          */
         data class Node(
             val senderUin: Long,
             val senderName: String,
             val segments: List<BotOutgoingSegment>,
+            val timestamp: Long = Clock.System.now().epochSeconds,
         )
     }
 

acidify-core/src/commonMain/kotlin/org/ntqqrev/acidify/message/internal/MessageBuildingContext.kt

@@ -29,7 +29,6 @@ import org.ntqqrev.acidify.internal.util.pbEncode
 import org.ntqqrev.acidify.message.BotOutgoingSegment
 import org.ntqqrev.acidify.message.MessageScene
 import kotlin.random.Random
-import kotlin.time.Clock
 
 internal class MessageBuildingContext(
     val bot: AbstractBot,
@@ -556,7 +555,7 @@ internal class MessageBuildingContext(
                     },
                     random = Random.nextInt(),
                     sequence = fakeSequence,
-                    time = Clock.System.now().epochSeconds,
+                    time = timestamp,
                     clientSequence = fakeSequence,
                     msgUid = Random.nextLong(1000000000000, 9999999999999),
                     forwardExt = ContentHead.Forward(

acidify-core/src/jsMain/kotlin/org/ntqqrev/acidify/js/JsBotForwardBlockBuilder.kt

@@ -1,6 +1,7 @@
 package org.ntqqrev.acidify.js
 
 import org.ntqqrev.acidify.message.BotOutgoingMessageBuilder
+import kotlin.time.Clock
 
 @JsExport
 @JsName("BotForwardBlockBuilder")
@@ -11,11 +12,13 @@ class JsBotForwardBlockBuilder internal constructor(
     fun node(
         senderUin: Long,
         senderName: String,
-        block: (JsBotOutgoingMessageBuilder) -> Unit
+        block: (JsBotOutgoingMessageBuilder) -> Unit,
+        timestamp: Long = Clock.System.now().epochSeconds
     ) {
         underlying.node(
             senderUin,
-            senderName
+            senderName,
+            timestamp,
         ) {
             val b = JsBotOutgoingMessageBuilder(this)
             block(b)

acidify-milky/src/commonMain/kotlin/org/ntqqrev/acidify/milky/transform/MessageTransform.kt

@@ -14,6 +14,7 @@ import org.ntqqrev.acidify.milky.MediaSourceScope
 import org.ntqqrev.acidify.milky.MilkyContext
 import org.ntqqrev.acidify.milky.tracked
 import org.ntqqrev.milky.*
+import kotlin.time.Clock
 
 suspend fun MilkyContext.transformIncomingMessage(msg: BotIncomingMessage): IncomingMessage? {
     val bot = application.dependencies.resolve<AbstractBot>()
@@ -282,7 +283,8 @@ suspend fun MilkyContext.transformOutgoingSegment(
                     senderName = msg.senderName,
                     segments = msg.segments.map { seg ->
                         async { transformOutgoingSegment(scene, peerUin, seg) }
-                    }.awaitAll()
+                    }.awaitAll(),
+                    timestamp = msg.time ?: Clock.System.now().epochSeconds,
                 )
             }
             BotOutgoingSegment.Forward(