[Core & Milky] Implement Core's RecallGroupMessage and Milky's recall_group_message

Author: NoirHare

Lagrange.Core/Common/Interface/MessageExt.cs

@@ -10,19 +10,19 @@ public static Task<BotMessage> SendFriendMessage(this BotContext context, long f
 
     public static Task<BotMessage> SendGroupMessage(this BotContext context, long groupUin, MessageChain chain)
         => context.EventContext.GetLogic<MessagingLogic>().SendGroupMessage(groupUin, chain);
-    
+
     public static Task<List<BotMessage>> GetGroupMessage(this BotContext context, long groupUin, ulong startSequence, ulong endSequence)
         => context.EventContext.GetLogic<MessagingLogic>().GetGroupMessage(groupUin, startSequence, endSequence);
-    
+
     public static Task<List<BotMessage>> GetRoamMessage(this BotContext context, long friendUin, uint timestamp, uint count)
         => context.EventContext.GetLogic<MessagingLogic>().GetRoamMessage(friendUin, timestamp, count);
-    
+
     public static Task<List<BotMessage>> GetRoamMessage(this BotContext context, BotMessage target, uint count)
     {
         uint timestamp = (uint)new DateTimeOffset(target.Time).ToUnixTimeSeconds();
         return context.EventContext.GetLogic<MessagingLogic>().GetRoamMessage(target.Contact.Uin, timestamp, count);
     }
-    
+
     public static Task<List<BotMessage>> GetC2CMessage(this BotContext context, long peerUin, ulong startSequence, ulong endSequence)
         => context.EventContext.GetLogic<MessagingLogic>().GetC2CMessage(peerUin, startSequence, endSequence);
 
@@ -32,6 +32,9 @@ public static Task<List<BotMessage>> GetC2CMessage(this BotContext context, long
     public static Task<string> SendGroupFile(this BotContext context, long groupUin, Stream fileStream, string? fileName = null, string parentDirectory = "/")
         => context.EventContext.GetLogic<OperationLogic>().SendGroupFile(groupUin, fileStream, fileName, parentDirectory);
 
+    public static Task RecallGroupMessage(this BotContext context, long groupUin, ulong sequence)
+        => context.EventContext.GetLogic<MessagingLogic>().RecallGroupMessage(groupUin, sequence);
+
     public static Task<string> GroupFSDownload(this BotContext context, long groupUin, string fileId)
         => context.EventContext.GetLogic<OperationLogic>().GroupFSDownload(groupUin, fileId);
 
@@ -49,13 +52,13 @@ public static Task SendGroupNudge(this BotContext context, long peerUin, long ta
 
     public static Task GroupSetSpecialTitle(this BotContext context, long groupUin, long targetUin, string title)
         => context.EventContext.GetLogic<OperationLogic>().GroupSetSpecialTitle(groupUin, targetUin, title);
-    
+
     public static Task GroupMemberRename(this BotContext context, long groupUin, long targetUin, string name)
         => context.EventContext.GetLogic<OperationLogic>().GroupMemberRename(groupUin, targetUin, name);
 
     public static Task GroupRename(this BotContext context, long groupUin, string name)
         => context.EventContext.GetLogic<OperationLogic>().GroupRename(groupUin, name);
-    
+
     public static Task GroupQuit(this BotContext context, long groupUin)
         => context.EventContext.GetLogic<OperationLogic>().GroupQuit(groupUin);
 }

Lagrange.Core/Internal/Events/Message/GroupRecallMsgEvent.cs

@@ -0,0 +1,12 @@
+using Lagrange.Core.Internal.Packets.Message;
+
+namespace Lagrange.Core.Internal.Events.Message;
+
+internal class GroupRecallMsgEventReq(long groupUin, ulong sequence) : ProtocolEvent
+{
+    public long GroupUin { get; } = groupUin;
+
+    public ulong Sequence { get; } = sequence;
+}
+
+internal class GroupRecallMsgEventResp : ProtocolEvent;

Lagrange.Core/Internal/Logic/MessagingLogic.cs

@@ -30,7 +30,7 @@ public async Task<List<BotMessage>> GetRoamMessage(long peerUin, uint time, uint
         foreach (var chain in result.Chains) messages.Add(await Parse(chain));
         return messages;
     }
-    
+
     public async Task<List<BotMessage>> GetC2CMessage(long peerUin, ulong startSequence, ulong endSequence)
     {
         string peerUid = context.CacheContext.ResolveCachedUid(peerUin) ?? throw new InvalidTargetException(peerUin);
@@ -71,6 +71,11 @@ public async Task<BotMessage> SendGroupMessage(long groupUin, MessageChain chain
         return message;
     }
 
+    public Task RecallGroupMessage(long groupUin, ulong sequence)
+    {
+        return context.EventContext.SendEvent<GroupRecallMsgEventResp>(new GroupRecallMsgEventReq(groupUin, sequence)).AsTask();
+    }
+
     private async Task<BotMessage> BuildMessage(MessageChain chain, BotContact contact, BotContact receiver)
     {
         uint random = (uint)Random.Shared.Next();

Lagrange.Core/Internal/Packets/Message/SsoGroupRecallMsg.cs

@@ -0,0 +1,36 @@
+#pragma warning disable CS8618
+
+using Lagrange.Proto;
+
+namespace Lagrange.Core.Internal.Packets.Message;
+
+/// <summary>
+/// trpc.msg.msg_svc.MsgService.SsoGroupRecallMsg
+/// </summary>
+[ProtoPackable]
+internal partial class SsoGroupRecallMsgReq
+{
+    [ProtoMember(1)] public uint Type { get; set; } // 1
+
+    [ProtoMember(2)] public long GroupUin { get; set; }
+
+    [ProtoMember(3)] public SsoGroupRecallMsgReqField3 Field3 { get; set; }
+
+    [ProtoMember(4)] public SsoGroupRecallMsgReqField4 Field4 { get; set; }
+}
+
+[ProtoPackable]
+internal partial class SsoGroupRecallMsgReqField3
+{
+    [ProtoMember(1)] public ulong Sequence { get; set; }
+
+    [ProtoMember(2)] public uint Random { get; set; }
+
+    [ProtoMember(3)] public uint Field3 { get; set; } // 0
+}
+
+[ProtoPackable]
+internal partial class SsoGroupRecallMsgReqField4
+{
+    [ProtoMember(1)] public uint Field1 { get; set; } // 0
+}

Lagrange.Core/Internal/Services/Message/SsoGroupRecallMsgService.cs

@@ -0,0 +1,35 @@
+using Lagrange.Core.Common;
+using Lagrange.Core.Exceptions;
+using Lagrange.Core.Internal.Events;
+using Lagrange.Core.Internal.Events.Message;
+using Lagrange.Core.Internal.Packets.Message;
+using Lagrange.Core.Utility;
+
+namespace Lagrange.Core.Internal.Services.Message;
+
+[Service("trpc.msg.msg_svc.MsgService.SsoGroupRecallMsg")]
+[EventSubscribe<GroupRecallMsgEventReq>(Protocols.All)]
+internal class SsoGroupRecallMsgService : BaseService<GroupRecallMsgEventReq, GroupRecallMsgEventResp>
+{
+    protected override ValueTask<ReadOnlyMemory<byte>> Build(GroupRecallMsgEventReq input, BotContext context)
+    {
+        var request = new SsoGroupRecallMsgReq
+        {
+            Type = 1,
+            GroupUin = input.GroupUin,
+            Field3 = new SsoGroupRecallMsgReqField3
+            {
+                Sequence = input.Sequence,
+                Field3 = 0
+            },
+            Field4 = new SsoGroupRecallMsgReqField4 { Field1 = 0 }
+        };
+
+        return ValueTask.FromResult(ProtoHelper.Serialize(request));
+    }
+
+    protected override ValueTask<GroupRecallMsgEventResp> Parse(ReadOnlyMemory<byte> input, BotContext context)
+    {
+        return ValueTask.FromResult(new GroupRecallMsgEventResp());
+    }
+}

Lagrange.Milky/Api/Handler/Message/RecallGroupMessageHandler.cs

@@ -0,0 +1,28 @@
+
+using System.Text.Json.Serialization;
+using Lagrange.Core;
+using Lagrange.Core.Common.Interface;
+
+namespace Lagrange.Milky.Api.Handler.Message;
+
+[Api("recall_group_message")]
+public class RecallGroupMessageHandler(BotContext bot) : IEmptyResultApiHandler<RecallGroupMessageParameter>
+{
+    private readonly BotContext _bot = bot;
+
+    public Task HandleAsync(RecallGroupMessageParameter parameter, CancellationToken token)
+    {
+        return _bot.RecallGroupMessage(parameter.GroupId, (ulong)parameter.MessageSeq);
+    }
+}
+
+public class RecallGroupMessageParameter(long groupId, long messageSeq)
+{
+    [JsonRequired]
+    [JsonPropertyName("group_id")]
+    public long GroupId { get; init; } = groupId;
+
+    [JsonRequired]
+    [JsonPropertyName("message_seq")]
+    public long MessageSeq { get; init; } = messageSeq;
+}

Lagrange.Milky/Utility/JsonUtility.cs

@@ -78,6 +78,8 @@ public static partial class JsonUtility
     // get_resource_temp_url
     [JsonSerializable(typeof(GetResourceTempUrlParameter))]
     [JsonSerializable(typeof(GetResourceTempUrlResult))]
+    // recall_group_message
+    [JsonSerializable(typeof(RecallGroupMessageParameter))]
     // == friend ==
     // send_friend_nudge
     [JsonSerializable(typeof(SendFriendNudgeParameter))]