[Core] Implemented MultiMsgEntity

Linwenxuan04 · Linwenxuan04 · commit b2a00c039eda · 2025-05-29T15:23:22.000+08:00
diff --git a/Lagrange.Core/Internal/Context/CacheContext.cs b/Lagrange.Core/Internal/Context/CacheContext.cs
@@ -67,7 +67,8 @@ public async Task<List<BotFriendCategory>> GetCategories(bool refresh = false)
         if (_groups == null) Interlocked.Exchange(ref _groups, await FetchGroups());
         var groups = _groups;
         
-        var group = groups.First(g => g.GroupUin == groupUin);
+        var group = groups.FirstOrDefault(g => g.GroupUin == groupUin);
+        if (group == null) return null;
 
         if (!_members.TryGetValue(groupUin, out var members))
         {
diff --git a/Lagrange.Core/Internal/Events/Message/LongMsgSendEvent.cs b/Lagrange.Core/Internal/Events/Message/LongMsgSendEvent.cs
@@ -3,11 +3,9 @@
 
 namespace Lagrange.Core.Internal.Events.Message;
 
-internal class LongMsgSendEventReq(BotContact contact, long? groupUin, List<BotMessage> messages) : ProtocolEvent
+internal class LongMsgSendEventReq(BotContact receiver, List<BotMessage> messages) : ProtocolEvent
 {
-    public BotContact Contact { get; } = contact;
-    
-    public long? GroupUin { get; } = groupUin;
+    public BotContact Receiver { get; } = receiver;
     
     public List<BotMessage> Messages { get; } = messages;
 }
diff --git a/Lagrange.Core/Internal/Packets/Message/Elem.cs b/Lagrange.Core/Internal/Packets/Message/Elem.cs
@@ -12,10 +12,14 @@ internal partial class Elem
     
     [ProtoMember(8)] public CustomFace? CustomFace { get; set; }
     
+    [ProtoMember(12)] public RichMsg? RichMsg { get; set; }
+    
     [ProtoMember(19)] public VideoFile? VideoFile { get; set; }
     
     [ProtoMember(45)] public SourceMsg? SrcMsg { get; set; }
     
+    [ProtoMember(51)] public LightAppElem? LightAppElem { get; set; }
+    
     [ProtoMember(53)] public CommonElem? CommonElem { get; set; }
 }
 
@@ -203,6 +207,22 @@ public partial class PbReserve2
     }
 }
 
+[ProtoPackable]
+internal partial class RichMsg
+{
+    [ProtoMember(1)] public ReadOnlyMemory<byte> BytesTemplate1 { get; set; } // Xml模板一
+    
+    [ProtoMember(2)] public uint ServiceId { get; set; } // 对应的业务标识
+    
+    [ProtoMember(3)] public ReadOnlyMemory<byte> BytesMsgResid { get; set; } // 长消息resid
+    
+    [ProtoMember(4)] public uint Rand { get; set; } // 需要删除的消息 rand 值
+    
+    [ProtoMember(5)] public uint Seq { get; set; } // 需要删除的消息 seq 
+    
+    [ProtoMember(6)] public uint Flags { get; set; } // bit 0:消息是否来自UrlCache; bit 1:是否包含video标签; bit 2:来自公众帐号的video结构化消息; bit 3:消息在urlencode模块从url转成richmsg
+}
+
 [ProtoPackable]
 internal partial class VideoFile
 {
@@ -281,6 +301,14 @@ internal partial class SourceMsg
     [ProtoMember(11)] public ReadOnlyMemory<byte> TroopName { get; set; } // 单独回复原消息群名
 }
 
+[ProtoPackable]
+internal partial class LightAppElem
+{
+    [ProtoMember(1)] public ReadOnlyMemory<byte> BytesData { get; set; } // LightApp数据
+
+    [ProtoMember(2)] public byte[] BytesMsgResid { get; set; } // 长消息resid
+}
+
 [ProtoPackable]
 internal partial class CommonElem
 {
diff --git a/Lagrange.Core/Internal/Packets/Message/NTMessageCommon.cs b/Lagrange.Core/Internal/Packets/Message/NTMessageCommon.cs
@@ -105,7 +105,7 @@ internal partial class MessageBody
 {
     [ProtoMember(1)] public RichText RichText { get; set; } = new();
 
-    [ProtoMember(2)] public ReadOnlyMemory<byte> MsgContent { get; set; }
+    [ProtoMember(2)] public ReadOnlyMemory<byte>? MsgContent { get; set; }
 
     [ProtoMember(3)] public byte[]? MsgEncryptContent { get; set; }
 }
diff --git a/Lagrange.Core/Internal/Packets/Service/LightApp.cs b/Lagrange.Core/Internal/Packets/Service/LightApp.cs
@@ -18,7 +18,7 @@ public class LightApp
 
     [JsonPropertyName("meta")] public JsonObject Meta { get; set; }
     
-    [JsonPropertyName("extra")] public Extra? Extra { get; set; }
+    [JsonPropertyName("extra")] public string? Extra { get; set; }
 
     [JsonPropertyName("prompt")] public string Prompt { get; set; }
 
@@ -32,29 +32,21 @@ public class LightApp
 [Serializable]
 public class Config
 {
-    [JsonPropertyName("autosize")] public bool Autosize { get; set; }
+    [JsonPropertyName("autosize")] public int Autosize { get; set; }
     
-    [JsonPropertyName("ctime")] public long Ctime { get; set; }
+    // [JsonPropertyName("ctime")] public long Ctime { get; set; }
     
     [JsonPropertyName("token")] public string Token { get; set; }
 
     [JsonPropertyName("type")] public string Type { get; set; }
     
     [JsonPropertyName("forward")] public int Forward { get; set; }
     
-    [JsonPropertyName("height")] public int Height { get; set; }
+    [JsonPropertyName("round")] public int Round { get; set; }
+    
+    // [JsonPropertyName("height")] public int Height { get; set; }
     
     [JsonPropertyName("width")] public int Width { get; set; }
     
-    [JsonPropertyName("showsender")] public int ShowSender { get; set; }
-}
-
-[Serializable]
-public class Extra
-{
-    [JsonPropertyName("app_type")] public int AppType { get; set; }
-
-    [JsonPropertyName("appid")] public int AppId { get; set; }
-
-    [JsonPropertyName("uin")] public uint Uin { get; set; }
+    // [JsonPropertyName("showsender")] public int ShowSender { get; set; }
 }
diff --git a/Lagrange.Core/Internal/Services/Message/LongMsgRecvService.cs b/Lagrange.Core/Internal/Services/Message/LongMsgRecvService.cs
@@ -26,7 +26,7 @@ protected override ValueTask<ReadOnlyMemory<byte>> Build(LongMsgRecvEventReq inp
             },
             Attr = new LongMsgAttr
             {
-                SubCmd = context.Config.Protocol.IsAndroid() ? 3u : 4u, // 1 -> Android 2 -> NTPC 0 -> Undefined
+                SubCmd = context.Config.Protocol.IsAndroid() ? 3u : 2u, // 1 -> Android 2 -> NTPC 0 -> Undefined
                 ClientType = context.Config.Protocol switch
                 {
                     Protocols.Windows or Protocols.MacOs or Protocols.Linux => 1u,
@@ -56,10 +56,10 @@ protected override async ValueTask<LongMsgRecvEventResp> Parse(ReadOnlyMemory<by
     {
         var rsp = ProtoHelper.Deserialize<LongMsgInterfaceRsp>(input.Span);
         
+        await using var src = new MemoryStream(rsp.RecvRsp.Payload);
         await using var dest = new MemoryStream();
-        await using var gzip = new GZipStream(dest, CompressionMode.Compress);
-        gzip.Write(rsp.RecvRsp.Payload);
-        gzip.Close();
+        await using var gzip = new GZipStream(src, CompressionMode.Decompress);
+        await gzip.CopyToAsync(dest);
         var decompressedContent = dest.ToArray();
 
         var logic = context.EventContext.GetLogic<MessagingLogic>();
diff --git a/Lagrange.Core/Internal/Services/Message/LongMsgSendService.cs b/Lagrange.Core/Internal/Services/Message/LongMsgSendService.cs
@@ -1,5 +1,6 @@
 using System.IO.Compression;
 using Lagrange.Core.Common;
+using Lagrange.Core.Common.Entity;
 using Lagrange.Core.Internal.Events;
 using Lagrange.Core.Internal.Events.Message;
 using Lagrange.Core.Internal.Logic;
@@ -22,17 +23,10 @@ protected override async ValueTask<ReadOnlyMemory<byte>> Build(LongMsgSendEventR
             var fakeMsg = await context.EventContext.GetLogic<MessagingLogic>().BuildFake(msg);
             messages.Add(fakeMsg);
         }
-        
+
         var content = new PbMultiMsgTransmit
         {
-            Items =
-            [
-                new PbMultiMsgItem
-                {
-                    FileName = "MultiMsg", 
-                    Buffer = new PbMultiMsgNew { Msg = messages }
-                }
-            ]
+            Items = [new PbMultiMsgItem { FileName = "MultiMsg", Buffer = new PbMultiMsgNew { Msg = messages } }]
         };
         
         await using var dest = new MemoryStream();
@@ -45,9 +39,9 @@ protected override async ValueTask<ReadOnlyMemory<byte>> Build(LongMsgSendEventR
         {
             SendReq = new LongMsgSendReq
             {
-                MsgType = input.GroupUin is null ? 1u : 3u, // 4 for wpamsg, 5 for grpmsg temp
-                PeerInfo = new LongMsgPeerInfo { PeerUid = input.Contact.Uid },
-                GroupUin = input.GroupUin ?? 0,
+                MsgType = input.Receiver is not BotGroup ? 1u : 3u, // 4 for wpamsg, 5 for grpmsg temp
+                PeerInfo = new LongMsgPeerInfo { PeerUid = input.Receiver.Uid },
+                GroupUin = input.Receiver is BotGroup group ? group.Uin : 0,
                 Payload = compressedContent
             },
             Attr = new LongMsgAttr
diff --git a/Lagrange.Core/Message/Entities/IMessageEntity.cs b/Lagrange.Core/Message/Entities/IMessageEntity.cs
@@ -11,4 +11,6 @@ public interface IMessageEntity
     internal Elem[] Build();
 
     internal IMessageEntity? Parse(List<Elem> elements, Elem target);
+
+    internal string ToPreviewString();
 }
diff --git a/Lagrange.Core/Message/Entities/ImageEntity.cs b/Lagrange.Core/Message/Entities/ImageEntity.cs
@@ -53,7 +53,8 @@ public override async Task Postprocess(BotContext context, BotMessage message)
         
         FileUrl = result.Url;
     }
-    
+
+    public override string ToPreviewString() => Summary;
     internal override Elem[] Build()
     {
         if (_compat == null)
diff --git a/Lagrange.Core/Message/Entities/MentionEntity.cs b/Lagrange.Core/Message/Entities/MentionEntity.cs
@@ -41,6 +41,8 @@ async Task IMessageEntity.Preprocess(BotContext context, BotMessage message)
             Uid = contact.Uid;
         }
     }
+    
+    string IMessageEntity.ToPreviewString() => Display;
 
     Elem[] IMessageEntity.Build()
     {
diff --git a/Lagrange.Core/Message/Entities/MultiMsgEntity.cs b/Lagrange.Core/Message/Entities/MultiMsgEntity.cs
@@ -0,0 +1,127 @@
+using System.IO.Compression;
+using System.Text.Json.Nodes;
+using System.Xml;
+using Lagrange.Core.Common.Entity;
+using Lagrange.Core.Internal.Events.Message;
+using Lagrange.Core.Internal.Packets.Message;
+using Lagrange.Core.Internal.Packets.Service;
+using Lagrange.Core.Utility;
+
+namespace Lagrange.Core.Message.Entities;
+
+public class MultiMsgEntity(string? resId) : IMessageEntity
+{
+    public List<BotMessage> Messages { get; } = [];
+    
+    public string? ResId { get; private set; } = resId;
+    
+    public MultiMsgEntity(List<BotMessage> messages) : this(default(string))
+    {
+        Messages = messages;
+    }
+    
+    public MultiMsgEntity() : this(default(string)) { }
+
+    public async Task Preprocess(BotContext context, BotMessage message)
+    {
+        if (string.IsNullOrEmpty(ResId))
+        {
+            var result = await context.EventContext.SendEvent<LongMsgSendEventResp>(new LongMsgSendEventReq(message.Receiver, Messages));
+            ResId = result.ResId;
+
+        }
+    }
+    
+    public async Task Postprocess(BotContext context, BotMessage message)
+    {
+        if (string.IsNullOrEmpty(ResId)) return;
+
+        bool isGroup = message.Contact is BotGroupMember;
+        var result = await context.EventContext.SendEvent<LongMsgRecvEventResp>(new LongMsgRecvEventReq(isGroup, ResId));
+        Messages.Clear();
+        Messages.AddRange(result.Messages);
+    }
+    
+    string IMessageEntity.ToPreviewString() => "[聊天记录]";
+
+    Elem[] IMessageEntity.Build()
+    {
+        if (string.IsNullOrEmpty(ResId)) return [];
+        
+        int count = Math.Clamp(Messages.Count, 0, 4);
+        string guid = Guid.NewGuid().ToString();
+        var extra = new JsonObject { { "filename", guid }, { "tsum", count } };
+        var news = new JsonArray(Messages[..count].Select(x => new JsonObject { { "text", $"{x.Contact.Nickname}: {string.Join(' ', x.Entities.Select(e => e.ToPreviewString()))}" } }).Cast<JsonNode>().ToArray());
+        var detail = new JsonObject
+        {
+            { "news", news },
+            { "resid", ResId },
+            { "source", "聊天记录" },
+            { "summary", $"查看{count}条转发消息" },
+            { "uniseq", guid }
+        };
+
+        var lightApp = new LightApp
+        {
+            App = "com.tencent.multimsg",
+            Config = new Config
+            {
+                Autosize = 1,
+                Forward = 1,
+                Round = 1,
+                Type = "normal",
+                Width = 300
+            },
+            Meta = new JsonObject { { "detail", detail } },
+            Desc = "[聊天记录]",
+            Extra = JsonHelper.Serialize(extra),
+            Prompt = "[聊天记录]",
+            Ver = "0.0.0.5",
+            View = "contact"
+        };
+        
+        var data = JsonHelper.SerializeToUtf8Bytes(lightApp).Span;
+        using var dest = new MemoryStream();
+        dest.WriteByte(0x01);
+        using var zlib = new ZLibStream(dest, CompressionLevel.Optimal, true);
+        zlib.Write(data);
+        zlib.Close();
+
+        return [new Elem { LightAppElem = new LightAppElem { BytesData = dest.ToArray() } }];
+    }
+
+    IMessageEntity? IMessageEntity.Parse(List<Elem> elements, Elem target)
+    {
+        if (target.RichMsg is { ServiceId: 35 } richMsg)
+        {
+            using var source = new MemoryStream();
+            using var dest = new MemoryStream();
+            using var inflate = new DeflateStream(source, CompressionMode.Decompress);
+            source.Write(richMsg.BytesTemplate1.Span[3..^4]);
+            source.Seek(0, SeekOrigin.Begin);
+            
+            inflate.CopyTo(dest);
+            dest.Seek(0, SeekOrigin.Begin);
+            
+            using var xmlReader = XmlReader.Create(dest);
+            xmlReader.Read();
+            
+            var doc = new XmlDocument();
+            doc.Load(xmlReader);
+            return new MultiMsgEntity(doc["msg"]?.Attributes["m_resid"]?.Value ?? string.Empty);
+        }
+
+        return null;
+    }
+
+    private static byte[] Adler32(ReadOnlySpan<byte> data)
+    {
+        uint a = 1, b = 0;
+        foreach (byte t in data)
+        {
+            a = (a + t) % 65521;
+            b = (b + a) % 65521;
+        }
+        return BitConverter.GetBytes((a << 16) | b);
+    }
+}
diff --git a/Lagrange.Core/Message/Entities/RecordEntity.cs b/Lagrange.Core/Message/Entities/RecordEntity.cs
@@ -47,6 +47,8 @@ public override async Task Postprocess(BotContext context, BotMessage message)
         FileUrl = result.Url;
     }
 
+    public override string ToPreviewString() => $"[语音] {RecordLength}\"";
+
     internal override Elem[] Build() =>
     [
         new()
diff --git a/Lagrange.Core/Message/Entities/ReplyEntity.cs b/Lagrange.Core/Message/Entities/ReplyEntity.cs
@@ -35,6 +35,8 @@ async Task IMessageEntity.Postprocess(BotContext context, BotMessage message)
     }
     
     public ReplyEntity() { }
+    
+    string IMessageEntity.ToPreviewString() => string.Empty;
 
     Elem[] IMessageEntity.Build()
     {
diff --git a/Lagrange.Core/Message/Entities/RichMediaEntityBase.cs b/Lagrange.Core/Message/Entities/RichMediaEntityBase.cs
@@ -51,7 +51,11 @@ private protected set
     
     internal abstract IMessageEntity? Parse(List<Elem> elements, Elem target);
     
+    public abstract string ToPreviewString();
+    
     Elem[] IMessageEntity.Build() => Build();
 
     IMessageEntity? IMessageEntity.Parse(List<Elem> elements, Elem target) => Parse(elements, target);
+    
+    string IMessageEntity.ToPreviewString() => ToPreviewString();
 }
diff --git a/Lagrange.Core/Message/Entities/TextEntity.cs b/Lagrange.Core/Message/Entities/TextEntity.cs
@@ -16,6 +16,8 @@ Elem[] IMessageEntity.Build()
         ];
     }
     
+    string IMessageEntity.ToPreviewString() => Text;
+    
     IMessageEntity? IMessageEntity.Parse(List<Elem> elements, Elem target)
     {
         return target.Text is ({ Attr6Buf: null } or { Attr6Buf.Length: 0 }) and ({ PbReserve.Length: 0 })
diff --git a/Lagrange.Core/Message/Entities/VideoEntity.cs b/Lagrange.Core/Message/Entities/VideoEntity.cs
diff --git a/Lagrange.Core/Message/MessageBuilder.cs b/Lagrange.Core/Message/MessageBuilder.cs
diff --git a/Lagrange.Core/Utility/JsonHelper.cs b/Lagrange.Core/Utility/JsonHelper.cs

Original file line number	Diff line number	Diff line change
`@@ -67,7 +67,8 @@ public async Task<List<BotFriendCategory>> GetCategories(bool refresh = false)`
`67`	`67`	`if (_groups == null) Interlocked.Exchange(ref _groups, await FetchGroups());`
`68`	`68`	`var groups = _groups;`
`69`	`69`
`70`		`- var group = groups.First(g => g.GroupUin == groupUin);`
	`70`	`+ var group = groups.FirstOrDefault(g => g.GroupUin == groupUin);`
	`71`	`+ if (group == null) return null;`
`71`	`72`
`72`	`73`	`if (!_members.TryGetValue(groupUin, out var members))`
`73`	`74`	`{`
Original file line number	Diff line number	Diff line change
`@@ -3,11 +3,9 @@`
`3`	`3`
`4`	`4`	`namespace Lagrange.Core.Internal.Events.Message;`
`5`	`5`
`6`		`-internal class LongMsgSendEventReq(BotContact contact, long? groupUin, List<BotMessage> messages) : ProtocolEvent`
	`6`	`+internal class LongMsgSendEventReq(BotContact receiver, List<BotMessage> messages) : ProtocolEvent`
`7`	`7`	`{`
`8`		`- public BotContact Contact { get; } = contact;`
`9`		`-`
`10`		`- public long? GroupUin { get; } = groupUin;`
	`8`	`+ public BotContact Receiver { get; } = receiver;`
`11`	`9`
`12`	`10`	`public List<BotMessage> Messages { get; } = messages;`
`13`	`11`	`}`
Original file line number	Diff line number	Diff line change
`@@ -105,7 +105,7 @@ internal partial class MessageBody`
`105`	`105`	`{`
`106`	`106`	`[ProtoMember(1)] public RichText RichText { get; set; } = new();`
`107`	`107`
`108`		`- [ProtoMember(2)] public ReadOnlyMemory<byte> MsgContent { get; set; }`
	`108`	`+ [ProtoMember(2)] public ReadOnlyMemory<byte>? MsgContent { get; set; }`
`109`	`109`
`110`	`110`	`[ProtoMember(3)] public byte[]? MsgEncryptContent { get; set; }`
`111`	`111`	`}`
Original file line number	Diff line number	Diff line change
`@@ -11,4 +11,6 @@ public interface IMessageEntity`
`11`	`11`	`internal Elem[] Build();`
`12`	`12`
`13`	`13`	`internal IMessageEntity? Parse(List<Elem> elements, Elem target);`
	`14`	`+`
	`15`	`+ internal string ToPreviewString();`
`14`	`16`	`}`
Original file line number	Diff line number	Diff line change
`@@ -53,7 +53,8 @@ public override async Task Postprocess(BotContext context, BotMessage message)`
`53`	`53`
`54`	`54`	`FileUrl = result.Url;`
`55`	`55`	`}`
`56`		`-`
	`56`	`+`
	`57`	`+ public override string ToPreviewString() => Summary;`
`57`	`58`	`internal override Elem[] Build()`
`58`	`59`	`{`
`59`	`60`	`if (_compat == null)`
Original file line number	Diff line number	Diff line change
`@@ -41,6 +41,8 @@ async Task IMessageEntity.Preprocess(BotContext context, BotMessage message)`
`41`	`41`	`Uid = contact.Uid;`
`42`	`42`	`}`
`43`	`43`	`}`
	`44`	`+`
	`45`	`+ string IMessageEntity.ToPreviewString() => Display;`
`44`	`46`
`45`	`47`	`Elem[] IMessageEntity.Build()`
`46`	`48`	`{`