[Core] Implement Forward Message Segment Send

Author: kengwang

Lagrange.Milky/Entity/Segment/ForwardSegment.cs

@@ -12,4 +12,25 @@ public class ForwardIncomingSegmentData(string forwardId)
 {
     [JsonPropertyName("forward_id")]
     public string ForwardId { get; } = forwardId;
+}
+
+public class ForwardOutgoingSegment(ForwardOutgoingSegmentData data) : OutgoingSegmentBase<ForwardOutgoingSegmentData>(data) { }
+
+public class ForwardOutgoingSegmentData(ForwardOutgoingSegmentDataItem[] messages)
+{
+    [JsonRequired]
+    [JsonPropertyName("messages")]
+    public ForwardOutgoingSegmentDataItem[] Messages { get; init; } = messages;
+}
+
+public class ForwardOutgoingSegmentDataItem(long userId, string senderName, IOutgoingSegment[] segments)
+{
+    [JsonPropertyName("user_id")]
+    public long UserId { get; init; } = userId;
+
+    [JsonPropertyName("sender_name")]
+    public string SenderName { get; init; } = senderName;
+
+    [JsonPropertyName("segments")]
+    public IOutgoingSegment[] Segments { get; init; } = segments;
 }

Lagrange.Milky/Entity/Segment/ISegment.cs

@@ -30,7 +30,7 @@ public interface IIncomingSegment
 [JsonDerivedType(typeof(ImageOutgoingSegment), typeDiscriminator: "image")]
 [JsonDerivedType(typeof(RecordOutgoingSegment), typeDiscriminator: "record")]
 [JsonDerivedType(typeof(VideoOutgoingSegment), typeDiscriminator: "video")]
-// [JsonDerivedType(typeof(ForwardOutgoingSegment), typeDiscriminator: "forward")]
+[JsonDerivedType(typeof(ForwardOutgoingSegment), typeDiscriminator: "forward")]
 public interface IOutgoingSegment
 {
     object? Data { get; }

Lagrange.Milky/README.md

@@ -154,7 +154,7 @@ Current Milky version: [77c6cbd](https://github.com/SaltifyDev/milky/tree/77c6cb
 - [x] image
 - [x] record
 - [ ] video
-- [ ] forward
+- [x] forward
 
 #### forward
 

Lagrange.Milky/Utility/EntityConvert.Segment.cs

@@ -121,7 +121,7 @@ await _resolver.ToMemoryStreamAsync(video.Data.Uri, token),
             video.Data.ThumbUri != null ? await _resolver.ToMemoryStreamAsync(video.Data.ThumbUri, token) : null,
             disposeOnCompletion: true
         ),
-        // TODO: ForwardOutgoingSegment
+        ForwardOutgoingSegment forwardOutgoingSegment => await BuildMultiMsgEntityAsync(forwardOutgoingSegment.Data.Messages, token),
         _ => throw new NotSupportedException(),
     };
 
@@ -141,4 +141,17 @@ private async Task<IMessageEntity> ReplyFriendSegmentAsync(ReplyOutgoingSegment
 
         return new ReplyEntity(message);
     }
+
+    private async Task<MultiMsgEntity> BuildMultiMsgEntityAsync(IReadOnlyList<ForwardOutgoingSegmentDataItem> data, CancellationToken token)
+    {
+        var multiMsgEntity = new MultiMsgEntity();
+        foreach (var segment in data)
+        {
+            var msgChain = await FakeSegmentsAsync(segment.Segments, token);
+            var msg = BotMessage.CreateCustomFriend(segment.UserId, segment.SenderName, 0, string.Empty, DateTime.Now, msgChain);
+            multiMsgEntity.Messages.Add(msg);
+        }
+
+        return multiMsgEntity;
+    }
 }