Makabaka 1.1.2

<div align="center">

<img width="160" src="logo.jpg" alt="logo">

Makabaka

一个基于 OneBot-11标准 的、适配于 Lagrange.Onebot 的、C# .NET Standard 2.1 的异步机器人开发框架。

</div>

说明

本项目将持续跟进 Lagrange.Core 项目进度。由于 Lagrange.Core 项目仍在开发当中，可能有部分功能暂未支持。
如果对该项目有任何问题，欢迎在 Issues 中提出。

安装

Makabaka 已发布到 NuGet ，可以通过NuGet包管理器搜索并安装到工程。
或者，可以直接去 Releases 中下载 .nupkg 文件。

已适配内容

<Details> <Summary>消息类型</Summary>

</Details>

<Details> <Summary>API</Summary>

</Details>

<Details> <Summary>事件</Summary>

</Details>

<Details> <Summary>适配器</Summary>

</Details>

画饼充饥

• 没饼画了
• 添加Http-Post支持
• 添加反向WebSocket支持
• 添加正向WebSocket支持

代码示例

<Details> <Summary>正向/反向WebSocket</Summary>

using Makabaka.Models.API.Responses;
using Makabaka.Models.EventArgs;
using Makabaka.Models.Messages;
using Makabaka.Services;
using Serilog;

namespace Test
{
    internal class Program
    {
        private static IService _service;

        static async Task Main(string[] args)
        {
            Log.Logger = new LoggerConfiguration() // Serilog包
                .MinimumLevel.Debug() // 日志等级
                .WriteTo.Console() // 日志输出
                .CreateLogger(); // 配置日志

            _service = ServiceFactory.CreateForwardWebSocketService(new() // 创建正向WebSocket服务
            {
                AccessToken = "114514", // 适配器的access_token，用于认证
                Host = "127.0.0.1", // 服务器地址
                Port = "8080", // 服务器端口
            });

            // 注册事件
            _service.OnLifeCycle += OnLifeCycle; // 生命周期事件
            _service.OnGroupMessage += OnGroupMessage; // 群消息事件

            await _service.StartAsync(); // 启动服务
            await _service.WaitAsync(); // 等待服务关闭

            //await _service.StopAsync(); // 关闭服务，可以放在任何地方（放这里其实没用，前面在等待服务关闭）
        }

        private static async void OnGroupMessage(object? sender, GroupMessageEventArgs e)
        {
            if (e.Message == "测试") // 接收到“测试”
            {
                APIResponse<MessageIdInfo> response = await e.Session.SendGroupMessageAsync(e.GroupId, new TextSegment("耶")); // 发送“耶”
                // APIResponse<MessageIdInfo> response = await e.Reply(new TextSegment("耶")); // 此处也可以直接使用e.Reply()回复消息
                response.EnsureSuccess(); // 确保发送成功了
                MessageIdInfo info = response; // 这里可以隐式转换
                                               // 因此，如果你用不到APIResponse<T>，可以把两行省略成一行：
                                               // MessageIdInfo info = await e.Session.SendGroupMessageAsync(e.GroupId, new TextSegment("耶"));
                                               // 效果是一样的
                Log.Information($"消息ID：{info.MessageId}"); // 输出消息ID
            }
        }

        private static async void OnLifeCycle(object? sender, LifeCycleEventArgs e)
        {
            LoginInfo info = await e.Session.GetLoginInfoAsync(); // 获取登录信息
            Log.Information($"当前登录账号：[{info.UserId}]{info.Nickname}");
        }
    }
}

</Details>

<Details> <Summary>HttpPost（目前Lagrange.Core暂未支持，不推荐使用）</Summary>

using Makabaka.Models.EventArgs;
using Makabaka.Models.FastActions;
using Makabaka.Models.Messages;
using Makabaka.Services;
using Serilog;
using XeronBot.Configurations;

namespace XeronBot
{
    internal class Program
    {
        private static IPassiveService _service;

        static async Task Main(string[] args)
        {
            Log.Logger = new LoggerConfiguration() // Serilog包
                .MinimumLevel.Verbose() // 日志等级
                .WriteTo.Console() // 日志输出
                .CreateLogger(); // 配置日志

            _service = ServiceFactory.CreateHttpPostService(new() // 创建正向WebSocket服务
            {
                AccessToken = "114514", // 适配器的secret，用于认证
                Host = "127.0.0.1", // 服务器地址
                Port = "8080", // 服务器端口
            });

            // 注册事件
            _service.OnLifeCycle += OnLifeCycle; // 生命周期事件
            _service.OnGroupMessage += OnGroupMessage; // 群消息事件

            await _service.StartAsync(); // 启动服务
            await _service.WaitAsync(); // 等待服务关闭

            //await _service.StopAsync(); // 关闭服务，可以放在任何地方（放这里其实没用，前面在等待服务关闭）
        }

        private static async Task<IFastAction> OnGroupMessage(object? sender, GroupMessageEventArgs e)
        {
            if (e.Message == "测试") // 接收到“测试”
            {
                return new GroupMessageFastAction(message: new TextSegment("耶")); // 快速操作，回复“耶”
            }

            // 注意：由于 HttpPost 的特殊性， e.Session 永远为 null
            // 也就是说，您将无法使用 e.Session 进行主动操作
            // 故不推荐使用 HttpPost

            await Task.CompletedTask; // 强制异步

            return null; // 如果不需要快速操作，返回null
        }

        private static async Task<IFastAction> OnLifeCycle(object? sender, LifeCycleEventArgs e)
        {
            // TODO: ...

            await Task.CompletedTask; // 强制异步

            return null; // 如果不需要快速操作，返回null
        }
    }
}

</Details>

开源协议

GPL-3.0 license

特别声明

• 本项目完全免费，仅供学习、娱乐使用，请勿运用于商业、非法用途。
• 因使用者使用不当而造成的法律责任，由使用者本人承担。