feat: add repeater and poke function impl

src/Bot/BotInstance.cs

@@ -1,5 +1,4 @@
-using DXKumaBot.Bot.Lagrange;
-using DXKumaBot.Bot.Telegram;
+using DXKumaBot.Bot.EventArg;
 using DXKumaBot.Functions;
 using DXKumaBot.Utils;
 
@@ -11,6 +10,7 @@ public sealed class BotInstance(Config config)
     private readonly TgBot _tgBot = new(config.Telegram);
 
     public static event AsyncEventHandler<MessageReceivedEventArgs>? MessageReceived;
+    public static event AsyncEventHandler<PokedEventArgs>? Poked;
 
     private static void RegisterFunctions()
     {
@@ -19,17 +19,22 @@ private static void RegisterFunctions()
         Cum cum = new();
         Roll roll = new();
         EatBreak eatBreak = new();
+        Repeater repeater = new();
+        Poke poke = new();
 
         loveYou.Register();
         wannaCao.Register();
         cum.Register();
         roll.Register();
         eatBreak.Register();
+        repeater.Register();
+        poke.Register();
     }
 
     private void RegisterEvents()
     {
         _qqBot.MessageReceived += MessageReceived;
+        _qqBot.Poked += Poked;
         _tgBot.MessageReceived += MessageReceived;
     }
 

src/Bot/EventArg/BotEventArgsBase.cs

@@ -0,0 +1,8 @@
+using DXKumaBot.Bot.Message;
+
+namespace DXKumaBot.Bot.EventArg;
+
+public abstract class BotEventArgsBase : EventArgs
+{
+    public abstract BotMessage Message { get; }
+}

src/Bot/EventArg/MessageRecivedEventArgs.cs

@@ -0,0 +1,20 @@
+using DXKumaBot.Bot.Message;
+using Lagrange.Core.Event.EventArg;
+using TgMessage = Telegram.Bot.Types.Message;
+
+namespace DXKumaBot.Bot.EventArg;
+
+public sealed class MessageReceivedEventArgs : BotEventArgsBase
+{
+    public MessageReceivedEventArgs(IBot bot, GroupMessageEvent message)
+    {
+        Message = new(bot, message.Chain);
+    }
+
+    public MessageReceivedEventArgs(IBot bot, TgMessage message)
+    {
+        Message = new(bot, message);
+    }
+
+    public override BotMessage Message { get; }
+}

src/Bot/EventArg/PokedEventArgs.cs

@@ -0,0 +1,9 @@
+using DXKumaBot.Bot.Message;
+using Lagrange.Core.Event.EventArg;
+
+namespace DXKumaBot.Bot.EventArg;
+
+public sealed class PokedEventArgs(QqBot bot, GroupPokeEvent message) : BotEventArgsBase
+{
+    public override BotMessage Message { get; } = new(bot, message.GroupUin);
+}

src/Bot/IBot.cs

@@ -1,12 +1,9 @@
 using DXKumaBot.Bot.Message;
-using DXKumaBot.Utils;
-using Lagrange.Core.Event.EventArg;
 using TgMessage = Telegram.Bot.Types.Message;
 
 namespace DXKumaBot.Bot;
 
 public interface IBot
 {
-    Task SendMessageAsync(MessageReceivedEventArgs messageToReply, MessagePair messages,
-        Possible<GroupMessageEvent, TgMessage>? source);
+    Task SendMessageAsync(MessagePair messages, BotMessage source, bool noReply);
 }

src/Bot/Message/BotMessage.cs

@@ -0,0 +1,54 @@
+using Lagrange.Core.Message;
+using TgMessage = Telegram.Bot.Types.Message;
+
+namespace DXKumaBot.Bot.Message;
+
+public sealed class BotMessage
+{
+    private readonly IBot _bot;
+    private readonly uint? _groupId;
+
+    public BotMessage(IBot bot, MessageChain message)
+    {
+        _bot = bot;
+        QqMessage = message;
+        SourceType = MessageSource.Qq;
+    }
+
+    public BotMessage(IBot bot, uint groupId)
+    {
+        _bot = bot;
+        _groupId = groupId;
+        SourceType = MessageSource.Qq;
+    }
+
+    public BotMessage(IBot bot, TgMessage message)
+    {
+        _bot = bot;
+        TgMessage = message;
+        SourceType = MessageSource.Telegram;
+    }
+
+    public MessageChain? QqMessage { get; }
+    public TgMessage? TgMessage { get; }
+    public MessageSource SourceType { get; }
+
+    public string Text => SourceType switch
+    {
+        MessageSource.Qq => QqMessage?.ToPreviewText(),
+        MessageSource.Telegram => TgMessage?.Text,
+        _ => throw new ArgumentOutOfRangeException(nameof(SourceType), SourceType, null)
+    } ?? throw new NullReferenceException();
+
+    public long ChatId => _groupId ?? SourceType switch
+    {
+        MessageSource.Qq => QqMessage?.GroupUin,
+        MessageSource.Telegram => TgMessage?.Chat.Id,
+        _ => throw new ArgumentOutOfRangeException(nameof(SourceType), SourceType, null)
+    } ?? throw new NullReferenceException();
+
+    public async Task Reply(MessagePair messages, bool noReply = false)
+    {
+        await _bot.SendMessageAsync(messages, this, noReply);
+    }
+}

src/Bot/Message/MediaMessage.cs

@@ -1,6 +1,6 @@
 namespace DXKumaBot.Bot.Message;
 
-public class MediaMessage(MediaType type, string path)
+public sealed class MediaMessage(MediaType type, string path)
 {
     public MediaType Type { get; } = type;
 

src/Bot/Message/MessagePair.cs

@@ -1,6 +1,6 @@
 namespace DXKumaBot.Bot.Message;
 
-public class MessagePair
+public sealed class MessagePair
 {
     public MessagePair(TextMessage message)
     {

src/Bot/Message/MessageSource.cs

@@ -0,0 +1,7 @@
+namespace DXKumaBot.Bot.Message;
+
+public enum MessageSource
+{
+    Qq,
+    Telegram
+}

src/Bot/Message/TextMessage.cs

@@ -1,6 +1,6 @@
 namespace DXKumaBot.Bot.Message;
 
-public class TextMessage
+public sealed class TextMessage
 {
     public required string Text { get; set; }
 

src/Bot/Lagrange/QQBot.cs → src/Bot/QQBot.cs

@@ -1,18 +1,17 @@
+using DXKumaBot.Bot.EventArg;
 using DXKumaBot.Bot.Message;
 using DXKumaBot.Utils;
 using Lagrange.Core;
 using Lagrange.Core.Common;
 using Lagrange.Core.Common.Interface;
 using Lagrange.Core.Common.Interface.Api;
-using Lagrange.Core.Event.EventArg;
 using Lagrange.Core.Message;
 using System.Text.Json;
 using System.Text.Json.Serialization;
-using TgMessage = Telegram.Bot.Types.Message;
 
-namespace DXKumaBot.Bot.Lagrange;
+namespace DXKumaBot.Bot;
 
-public class QqBot : IBot
+public sealed class QqBot : IBot
 {
     private readonly BotContext _bot;
     private readonly BotKeystore? _keyStore;
@@ -21,25 +20,19 @@ public QqBot()
     {
         BotDeviceInfo deviceInfo = GetDeviceInfo();
         _keyStore = LoadKeystore();
-        _bot = BotFactory.Create(new()
-        {
-            UseIPv6Network = false,
-            GetOptimumServer = true,
-            AutoReconnect = true,
-            Protocol = Protocols.Linux,
-            CustomSignProvider = new CustomSignProvider()
-        }, deviceInfo, _keyStore ?? new BotKeystore());
+        _bot = BotFactory.Create(new(), deviceInfo, _keyStore ?? new BotKeystore());
     }
 
-    public async Task SendMessageAsync(MessageReceivedEventArgs messageToReply, MessagePair messages,
-        Possible<GroupMessageEvent, TgMessage>? source = null)
+    public async Task SendMessageAsync(MessagePair messages, BotMessage source, bool noReply)
     {
-        await SendMessageAsync(messageToReply.QqMessage!.Chain.GroupUin, messages.Text!, messages.Media,
-            source is null ? default : ((GroupMessageEvent?)source)?.Chain);
+        await SendMessageAsync(Convert.ToUInt32(source.ChatId), messages.Text!, messages.Media,
+            noReply ? default : source.QqMessage);
     }
 
     public event AsyncEventHandler<MessageReceivedEventArgs>? MessageReceived;
 
+    public event AsyncEventHandler<PokedEventArgs>? Poked;
+
     private void RegisterEvents()
     {
 #if DEBUG
@@ -57,6 +50,15 @@ private void RegisterEvents()
 
             await MessageReceived.Invoke(sender, new(this, args));
         };
+        _bot.Invoker.OnGroupPokeEvent += async (sender, args) =>
+        {
+            if (Poked is null)
+            {
+                return;
+            }
+
+            await Poked.Invoke(sender, new(this, args));
+        };
     }
 
     public async Task RunAsync()