ColorMiraiNetty.cs

using DotNetty.Buffers;
using DotNetty.Codecs;
using DotNetty.Transport.Bootstrapping;
using DotNetty.Transport.Channels;
using DotNetty.Transport.Channels.Sockets;
using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Text;
using System.Threading;

namespace ColoryrSDK;

internal static class PackDecode
{
    public static string ReadString(this IByteBuffer buff)
    {
        return buff.ReadString(buff.ReadInt(), Encoding.UTF8);
    }
    public static List<long> ReadLongList(this IByteBuffer buff)
    {
        var list = new List<long>();
        int a = buff.ReadInt();
        for (int i = 0; i < a; i++)
        {
            list.Add(buff.ReadLong());
        }
        return list;
    }
    public static List<string> ReadStringList(this IByteBuffer buff)
    {
        var list = new List<string>();
        int a = buff.ReadInt();
        for (int i = 0; i < a; i++)
        {
            list.Add(buff.ReadString());
        }
        return list;
    }
    public static ReMemberInfoPack ReadMemberInfoPack(this IByteBuffer buff)
    {
        return new()
        {
            id = buff.ReadLong(),
            fid = buff.ReadLong(),
            nick = buff.ReadString(),
            img = buff.ReadString(),
            per = (MemberPermission)buff.ReadInt(),
            nameCard = buff.ReadString(),
            specialTitle = buff.ReadString(),
            avatarUrl = buff.ReadString(),
            muteTimeRemaining = buff.ReadInt(),
            joinTimestamp = buff.ReadInt(),
            lastSpeakTimestamp = buff.ReadInt(),
            uuid = buff.ReadString()
        };
    }
    public static ReFriendInfoPack ReadFriendInfoPack(this IByteBuffer buff)
    {
        return new()
        {
            id = buff.ReadLong(),
            img = buff.ReadString(),
            remark = buff.ReadString(),
            userProfile = new()
            {
                nickname = buff.ReadString(),
                email = buff.ReadString(),
                age = buff.ReadInt(),
                qLevel = buff.ReadInt(),
                sex = (Sex)buff.ReadInt(),
                sign = buff.ReadString()
            },
            uuid = buff.ReadString()
        };
    }
    public static GroupFileInfo ReadGroupFileInfo(this IByteBuffer buff)
    {
        return new()
        {
            name = buff.ReadString(),
            id = buff.ReadString(),
            absolutePath = buff.ReadString(),
            isFile = buff.ReadBoolean(),
            isFolder = buff.ReadBoolean(),
            size = buff.ReadLong(),
            uploaderId = buff.ReadLong(),
            uploadTime = buff.ReadLong(),
            lastModifyTime = buff.ReadLong(),
            expiryTime = buff.ReadLong(),
            sha1 = buff.ReadString(),
            md5 = buff.ReadString()
        };
    }
    public static GroupAnnouncement ReadGroupAnnouncement(this IByteBuffer buff)
    {
        return new()
        {
            senderId = buff.ReadLong(),
            fid = buff.ReadString(),
            allConfirmed = buff.ReadBoolean(),
            confirmedMembersCount = buff.ReadInt(),
            publicationTime = buff.ReadLong(),
            content = buff.ReadString(),
            image = buff.ReadString(),
            sendToNewMember = buff.ReadBoolean(),
            isPinned = buff.ReadBoolean(),
            showEditCard = buff.ReadBoolean(),
            showPopup = buff.ReadBoolean(),
            requireConfirmation = buff.ReadBoolean()
        };
    }
    public static GroupInfo ReadGroupInfo(this IByteBuffer buff)
    {
        return new()
        {
            id = buff.ReadLong(),
            name = buff.ReadString(),
            img = buff.ReadString(),
            oid = buff.ReadLong(),
            per = (MemberPermission)buff.ReadInt()
        };
    }
    public static List<long> StartPack(this IByteBuffer buff)
    {
        int a = buff.ReadInt();
        List<long> list = new();
        for (int i = 0; i < a; i++)
        {
            list.Add(buff.ReadLong());
        }
        return list;
    }
    public static ReListGroupPack ListGroupPack(this IByteBuffer buff)
    {
        ReListGroupPack pack = new()
        {
            qq = buff.ReadLong(),
            groups = new()
        };
        int a = buff.ReadInt();
        for (int i = 0; i < a; i++)
        {
            pack.groups.Add(buff.ReadGroupInfo());
        }
        pack.uuid = buff.ReadString();
        return pack;
    }
    public static ReListFriendPack ListFriendPack(this IByteBuffer buff)
    {
        ReListFriendPack pack = new()
        {
            qq = buff.ReadLong(),
            friends = new()
        };
        int a = buff.ReadInt();
        for (int i = 0; i < a; i++)
        {
            pack.friends.Add(buff.ReadFriendInfoPack());
        }
        pack.uuid = buff.ReadString();
        return pack;
    }
    public static ReListMemberPack ListMemberPack(this IByteBuffer buff)
    {
        ReListMemberPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            members = new()
        };
        int a = buff.ReadInt();
        for (int i = 0; i < a; i++)
        {
            pack.members.Add(buff.ReadMemberInfoPack());
        }
        pack.uuid = buff.ReadString();
        return pack;
    }
    public static ReGroupSettingPack GroupSettingPack(this IByteBuffer buff)
    {
        ReGroupSettingPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            setting = new()
            {
                isMuteAll = buff.ReadBoolean(),
                isAllowMemberInvite = buff.ReadBoolean(),
                isAutoApproveEnabled = buff.ReadBoolean(),
                isAnonymousChatEnabled = buff.ReadBoolean()
            },
            uuid = buff.ReadString()
        };
        return pack;
    }
    public static GetImageUrlPack GetImageUrlPack(this IByteBuffer buff)
    {
        GetImageUrlPack pack = new()
        {
            qq = buff.ReadLong(),
            uuid = buff.ReadString()
        };
        return pack;
    }
    public static ReMemberInfoPack MemberInfoPack(this IByteBuffer buff)
    {
        long qq = buff.ReadLong();
        var pack = buff.ReadMemberInfoPack();
        pack.qq = qq;
        return pack;
    }
    public static ReFriendInfoPack FriendInfoPack(this IByteBuffer buff)
    {
        long qq = buff.ReadLong();
        var pack = buff.ReadFriendInfoPack();
        pack.qq = qq;
        pack.uuid = buff.ReadString();
        return pack;
    }
    public static ReGroupFilesPack GroupFilesPack(this IByteBuffer buff)
    {
        ReGroupFilesPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            files = new()
        };
        int a = buff.ReadInt();
        for (int i = 0; i < a; i++)
        {
            pack.files.Add(buff.ReadGroupFileInfo());
        }
        pack.uuid = buff.ReadString();
        return pack;
    }
    public static ReGroupAnnouncementsPack GroupAnnouncementsPack(this IByteBuffer buff)
    {
        ReGroupAnnouncementsPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            list = new()
        };
        int a = buff.ReadInt();
        for (int i = 0; i < a; i++)
        {
            pack.list.Add(buff.ReadGroupAnnouncement());
        }
        pack.uuid = buff.ReadString();
        return pack;
    }
    public static BeforeImageUploadPack BeforeImageUploadPack(this IByteBuffer buff)
    {
        BeforeImageUploadPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            name = buff.ReadString()
        };
        return pack;
    }
    public static BotAvatarChangedPack BotAvatarChangedPack(this IByteBuffer buff)
    {
        BotAvatarChangedPack pack = new()
        {
            qq = buff.ReadLong()
        };
        return pack;
    }
    public static BotGroupPermissionChangePack BotGroupPermissionChangePack(this IByteBuffer buff)
    {
        BotGroupPermissionChangePack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            old = (MemberPermission)buff.ReadInt(),
            now = (MemberPermission)buff.ReadInt()
        };
        return pack;
    }
    public static BotInvitedJoinGroupRequestEventPack BotInvitedJoinGroupRequestEventPack(this IByteBuffer buff)
    {
        BotInvitedJoinGroupRequestEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            fid = buff.ReadLong(),
            eventid = buff.ReadLong()
        };
        return pack;
    }
    public static BotJoinGroupEventAPack BotJoinGroupEventAPack(this IByteBuffer buff)
    {
        BotJoinGroupEventAPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong()
        };
        return pack;
    }
    public static BotJoinGroupEventBPack BotJoinGroupEventBPack(this IByteBuffer buff)
    {
        BotJoinGroupEventBPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            fid = buff.ReadLong()
        };
        return pack;
    }
    public static BotLeaveEventAPack BotLeaveEventAPack(this IByteBuffer buff)
    {
        BotLeaveEventAPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong()
        };
        return pack;
    }
    public static BotLeaveEventBPack BotLeaveEventBPack(this IByteBuffer buff)
    {
        BotLeaveEventBPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            fid = buff.ReadLong()
        };
        return pack;
    }
    public static BotMuteEventPack BotMuteEventPack(this IByteBuffer buff)
    {
        BotMuteEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            fid = buff.ReadLong(),
            time = buff.ReadInt()
        };
        return pack;
    }
    public static BotOfflineEventAPack BotOfflineEventAPack(this IByteBuffer buff)
    {
        BotOfflineEventAPack pack = new()
        {
            qq = buff.ReadLong(),
            message = buff.ReadString()
        };
        return pack;
    }
    public static BotOfflineEventBPack BotOfflineEventBPack(this IByteBuffer buff)
    {
        BotOfflineEventBPack pack = new()
        {
            qq = buff.ReadLong(),
            message = buff.ReadString(),
            title = buff.ReadString()
        };
        return pack;
    }
    public static BotOfflineEventCPack BotOfflineEventCPack(this IByteBuffer buff)
    {
        BotOfflineEventCPack pack = new()
        {
            qq = buff.ReadLong()
        };
        return pack;
    }
    public static BotOnlineEventPack BotOnlineEventPack(this IByteBuffer buff)
    {
        BotOnlineEventPack pack = new()
        {
            qq = buff.ReadLong()
        };
        return pack;
    }
    public static BotReloginEventPack BotReloginEventPack(this IByteBuffer buff)
    {
        BotReloginEventPack pack = new()
        {
            qq = buff.ReadLong(),
            message = buff.ReadString()
        };
        return pack;
    }
    public static BotUnmuteEventPack BotUnmuteEventPack(this IByteBuffer buff)
    {
        BotUnmuteEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            fid = buff.ReadLong()
        };
        return pack;
    }
    public static FriendAddEventPack FriendAddEventPack(this IByteBuffer buff)
    {
        FriendAddEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            nick = buff.ReadString()
        };
        return pack;
    }
    public static FriendAvatarChangedEventPack FriendAvatarChangedEventPack(this IByteBuffer buff)
    {
        FriendAvatarChangedEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            url = buff.ReadString()
        };
        return pack;
    }
    public static FriendDeleteEventPack FriendDeleteEventPack(this IByteBuffer buff)
    {
        FriendDeleteEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong()
        };
        return pack;
    }
    public static FriendMessagePostSendEventPack FriendMessagePostSendEventPack(this IByteBuffer buff)
    {
        FriendMessagePostSendEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            res = buff.ReadBoolean(),
            message = buff.ReadStringList(),
            error = buff.ReadString()
        };
        return pack;
    }
    public static FriendMessagePreSendEventPack FriendMessagePreSendEventPack(this IByteBuffer buff)
    {
        FriendMessagePreSendEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            message = buff.ReadStringList()
        };
        return pack;
    }
    public static FriendRemarkChangeEventPack FriendRemarkChangeEventPack(this IByteBuffer buff)
    {
        FriendRemarkChangeEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            old = buff.ReadString(),
            now = buff.ReadString()
        };
        return pack;
    }
    public static GroupAllowAnonymousChatEventPack GroupAllowAnonymousChatEventPack(this IByteBuffer buff)
    {
        GroupAllowAnonymousChatEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            old = buff.ReadBoolean(),
            now = buff.ReadBoolean()
        };
        return pack;
    }
    public static GroupAllowConfessTalkEventPack GroupAllowConfessTalkEventPack(this IByteBuffer buff)
    {
        GroupAllowConfessTalkEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            old = buff.ReadBoolean(),
            now = buff.ReadBoolean()
        };
        return pack;
    }
    public static GroupAllowMemberInviteEventPack GroupAllowMemberInviteEventPack(this IByteBuffer buff)
    {
        GroupAllowMemberInviteEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            old = buff.ReadBoolean(),
            now = buff.ReadBoolean()
        };
        return pack;
    }
    //public static GroupEntranceAnnouncementChangeEventPack GroupEntranceAnnouncementChangeEventPack(this IByteBuffer buff)
    //{
    //    GroupEntranceAnnouncementChangeEventPack pack = new()
    //    {
    //        qq = buff.ReadLong(),
    //        id = buff.ReadLong(),
    //        fid = buff.ReadLong(),
    //        old = buff.ReadBoolean(),
    //        now = buff.ReadBoolean()
    //    };
    //    return pack;
    //}
    public static GroupMessagePostSendEventPack GroupMessagePostSendEventPack(this IByteBuffer buff)
    {
        GroupMessagePostSendEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            res = buff.ReadBoolean(),
            message = buff.ReadStringList(),
            error = buff.ReadString()
        };
        return pack;
    }
    public static GroupMessagePreSendEventPack GroupMessagePreSendEventPack(this IByteBuffer buff)
    {
        GroupMessagePreSendEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            message = buff.ReadStringList()
        };
        return pack;
    }
    public static GroupMuteAllEventPack GroupMuteAllEventPack(this IByteBuffer buff)
    {
        GroupMuteAllEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            fid = buff.ReadLong(),
            old = buff.ReadBoolean(),
            now = buff.ReadBoolean()
        };
        return pack;
    }
    public static GroupNameChangeEventPack GroupNameChangeEventPack(this IByteBuffer buff)
    {
        GroupNameChangeEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            fid = buff.ReadLong(),
            old = buff.ReadString(),
            now = buff.ReadString()
        };
        return pack;
    }
    public static ImageUploadEventAPack ImageUploadEventAPack(this IByteBuffer buff)
    {
        ImageUploadEventAPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            fid = buff.ReadLong(),
            uuid = buff.ReadString()
        };
        return pack;
    }
    public static ImageUploadEventBPack ImageUploadEventBPack(this IByteBuffer buff)
    {
        ImageUploadEventBPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            index = buff.ReadInt(),
            name = buff.ReadString(),
            error = buff.ReadString()
        };
        return pack;
    }
    public static MemberCardChangeEventPack MemberCardChangeEventPack(this IByteBuffer buff)
    {
        MemberCardChangeEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            old = buff.ReadString(),
            now = buff.ReadString()
        };
        return pack;
    }
    public static InviteMemberJoinEventPack InviteMemberJoinEventPack(this IByteBuffer buff)
    {
        InviteMemberJoinEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            fid = buff.ReadLong(),
            name = buff.ReadString(),
            ifid = buff.ReadLong(),
            iname = buff.ReadString()
        };
        return pack;
    }
    public static MemberJoinEventPack MemberJoinEventPack(this IByteBuffer buff)
    {
        MemberJoinEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            fid = buff.ReadLong(),
            name = buff.ReadString()
        };
        return pack;
    }
    public static MemberJoinRequestEventPack MemberJoinRequestEventPack(this IByteBuffer buff)
    {
        MemberJoinRequestEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            fid = buff.ReadLong(),
            qif = buff.ReadLong(),
            message = buff.ReadString(),
            eventid = buff.ReadLong()
        };
        return pack;
    }
    public static MemberLeaveEventAPack MemberLeaveEventAPack(this IByteBuffer buff)
    {
        MemberLeaveEventAPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            fid = buff.ReadLong(),
            eid = buff.ReadLong()
        };
        return pack;
    }
    public static MemberLeaveEventBPack MemberLeaveEventBPack(this IByteBuffer buff)
    {
        MemberLeaveEventBPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            fid = buff.ReadLong()
        };
        return pack;
    }
    public static MemberMuteEventPack MemberMuteEventPack(this IByteBuffer buff)
    {
        MemberMuteEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            fid = buff.ReadLong(),
            eid = buff.ReadLong(),
            time = buff.ReadInt()
        };
        return pack;
    }
    public static MemberPermissionChangeEventPack MemberPermissionChangeEventPack(this IByteBuffer buff)
    {
        MemberPermissionChangeEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            fid = buff.ReadLong(),
            old = (MemberPermission)buff.ReadInt(),
            now = (MemberPermission)buff.ReadInt()
        };
        return pack;
    }
    public static MemberSpecialTitleChangeEventPack MemberSpecialTitleChangeEventPack(this IByteBuffer buff)
    {
        MemberSpecialTitleChangeEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            fid = buff.ReadLong(),
            old = buff.ReadString(),
            now = buff.ReadString()
        };
        return pack;
    }
    public static MemberUnmuteEventPack MemberUnmuteEventPack(this IByteBuffer buff)
    {
        MemberUnmuteEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            fid = buff.ReadLong(),
            eid = buff.ReadLong()
        };
        return pack;
    }
    public static MessageRecallEventAPack MessageRecallEventAPack(this IByteBuffer buff)
    {
        MessageRecallEventAPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            time = buff.ReadInt()
        };
        int a = buff.ReadInt();
        pack.mid = new int[a];
        for (int i = 0; i < a; i++)
        {
            pack.mid[i] = buff.ReadInt();
        }
        return pack;
    }
    public static MessageRecallEventBPack MessageRecallEventBPack(this IByteBuffer buff)
    {
        MessageRecallEventBPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            time = buff.ReadInt(),
            fid = buff.ReadLong(),
            oid = buff.ReadLong()
        };
        int a = buff.ReadInt();
        pack.mid = new int[a];
        for (int i = 0; i < a; i++)
        {
            pack.mid[i] = buff.ReadInt();
        }
        return pack;
    }
    public static NewFriendRequestEventPack NewFriendRequestEventPack(this IByteBuffer buff)
    {
        NewFriendRequestEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            message = buff.ReadString(),
            eventid = buff.ReadLong()
        };
        return pack;
    }
    public static TempMessagePostSendEventPack TempMessagePostSendEventPack(this IByteBuffer buff)
    {
        TempMessagePostSendEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            res = buff.ReadBoolean(),
            message = buff.ReadStringList(),
            error = buff.ReadString()
        };
        return pack;
    }
    public static TempMessagePreSendEventPack TempMessagePreSendEventPack(this IByteBuffer buff)
    {
        return new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            message = buff.ReadStringList()
        };
    }
    public static GroupMessageEventPack GroupMessageEventPack(this IByteBuffer buff)
    {
        GroupMessageEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            fid = buff.ReadLong(),
            name = buff.ReadString(),
            permission = (MemberPermission)buff.ReadInt(),
            message = buff.ReadStringList()
        };
        return pack;
    }
    public static TempMessageEventPack TempMessageEventPack(this IByteBuffer buff)
    {
        TempMessageEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            fid = buff.ReadLong(),
            name = buff.ReadString(),
            permission = (MemberPermission)buff.ReadInt(),
            message = buff.ReadStringList(),
            time = buff.ReadInt()
        };
        return pack;
    }
    public static FriendMessageEventPack FriendMessageEventPack(this IByteBuffer buff)
    {
        FriendMessageEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            name = buff.ReadString(),
            message = buff.ReadStringList(),
            time = buff.ReadInt()
        };
        return pack;
    }
    public static FriendInputStatusChangedEventPack FriendInputStatusChangedEventPack(this IByteBuffer buff)
    {
        FriendInputStatusChangedEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            input = buff.ReadBoolean()
        };
        return pack;
    }
    public static FriendNickChangedEventPack FriendNickChangedEventPack(this IByteBuffer buff)
    {
        FriendNickChangedEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            old = buff.ReadString(),
            now = buff.ReadString()
        };
        return pack;
    }
    public static MemberJoinRetrieveEventPack MemberJoinRetrieveEventPack(this IByteBuffer buff)
    {
        MemberJoinRetrieveEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            fid = buff.ReadLong()
        };
        return pack;
    }
    public static BotJoinGroupEventRetrieveEventPack BotJoinGroupEventRetrieveEventPack(this IByteBuffer buff)
    {
        BotJoinGroupEventRetrieveEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong()
        };
        return pack;
    }
    public static NudgedEventPack NudgedEventPack(this IByteBuffer buff)
    {
        NudgedEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            fid = buff.ReadLong(),
            aid = buff.ReadLong(),
            action = buff.ReadString(),
            suffix = buff.ReadString()
        };
        return pack;
    }
    public static GroupTalkativeChangePack GroupTalkativeChangePack(this IByteBuffer buff)
    {
        return new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            old = buff.ReadLong(),
            now = buff.ReadLong()
        };
    }
    public static OtherClientOnlineEventPack OtherClientOnlineEventPack(this IByteBuffer buff)
    {
        OtherClientOnlineEventPack pack = new()
        {
            qq = buff.ReadLong(),
            appId = buff.ReadInt(),
            kind = buff.ReadString(),
            platform = buff.ReadString(),
            deviceName = buff.ReadString(),
            deviceKind = buff.ReadString()
        };
        return pack;
    }
    public static OtherClientOfflineEventPack OtherClientOfflineEventPack(this IByteBuffer buff)
    {
        OtherClientOfflineEventPack pack = new()
        {
            qq = buff.ReadLong(),
            appId = buff.ReadInt(),
            platform = buff.ReadString(),
            deviceName = buff.ReadString(),
            deviceKind = buff.ReadString()
        };
        return pack;
    }
    public static OtherClientMessageEventPack OtherClientMessageEventPack(this IByteBuffer buff)
    {
        OtherClientMessageEventPack pack = new()
        {
            qq = buff.ReadLong(),
            appId = buff.ReadInt(),
            platform = buff.ReadString(),
            deviceName = buff.ReadString(),
            deviceKind = buff.ReadString(),
            message = buff.ReadStringList()
        };
        return pack;
    }
    public static GroupMessageSyncEventPack GroupMessageSyncEventPack(this IByteBuffer buff)
    {
        GroupMessageSyncEventPack pack = new()
        {
            qq = buff.ReadLong(),
            time = buff.ReadInt(),
            message = buff.ReadStringList()
        };
        return pack;
    }
    public static GroupDisbandPack GroupDisbandPack(this IByteBuffer buff)
    {
        GroupDisbandPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong()
        };
        return pack;
    }
    public static StrangerMessageEventPack StrangerMessageEventPack(this IByteBuffer buff)
    {
        StrangerMessageEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            name = buff.ReadString(),
            message = buff.ReadStringList(),
            time = buff.ReadInt()
        };
        return pack;
    }
    public static StrangerMessagePreSendEventPack StrangerMessagePreSendEventPack(this IByteBuffer buff)
    {
        StrangerMessagePreSendEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            message = buff.ReadStringList()
        };
        return pack;
    }
    public static StrangerMessagePostSendEventPack StrangerMessagePostSendEventPack(this IByteBuffer buff)
    {
        StrangerMessagePostSendEventPack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            res = buff.ReadBoolean(),
            message = buff.ReadStringList(),
            error = buff.ReadString()
        };
        return pack;
    }
    public static StrangerRelationChangePack StrangerRelationChangePack(this IByteBuffer buff)
    {
        StrangerRelationChangePack pack = new()
        {
            qq = buff.ReadLong(),
            id = buff.ReadLong(),
            type = buff.ReadInt()
        };
        return pack;
    }
}

internal static class PackEncode
{
    public static IByteBuffer WriteString(this IByteBuffer buff, string data)
    {
        var temp = Encoding.UTF8.GetBytes(data);
        buff.WriteBytes1(temp);
        return buff;
    }
    public static IByteBuffer WriteStringList(this IByteBuffer buff, List<string> list)
    {
        buff.WriteInt(list.Count);
        foreach (var item in list)
        {
            buff.WriteString(item);
        }
        return buff;
    }
    public static IByteBuffer WriteLongList(this IByteBuffer buff, List<long> list)
    {
        buff.WriteInt(list.Count);
        foreach (var item in list)
        {
            buff.WriteLong(item);
        }
        return buff;
    }
    public static IByteBuffer WriteBytes1(this IByteBuffer buff, byte[] data)
    {
        buff.WriteInt(data.Length);
        buff.WriteBytes(data, 0, data.Length);
        return buff;
    }

    public static IByteBuffer ToPack(this StartPack pack)
    {
        if (pack.qqList == null)
            pack.qqList = new();
        if (pack.groups == null)
            pack.groups = new();
        if (pack.reg == null)
            pack.reg = new();
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(0)
            .WriteString(pack.name)
            .WriteInt(pack.reg.Count);
        foreach (var item in pack.reg)
        {
            buff.WriteInt(item);
        }
        buff.WriteLongList(pack.groups)
            .WriteLongList(pack.qqList)
            .WriteLong(pack.qq);
        return buff;
    }
    public static IByteBuffer ToPack(this SendGroupMessagePack pack)
    {
        if (pack.ids == null)
            pack.ids = new();
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(52)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteStringList(pack.message)
            .WriteLongList(pack.ids);

        return buff;
    }
    public static IByteBuffer ToPack(this SendGroupPrivateMessagePack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(53)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteLong(pack.fid)
            .WriteStringList(pack.message);

        return buff;
    }
    public static IByteBuffer ToPack(this SendFriendMessagePack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(54)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteStringList(pack.message)
            .WriteLongList(pack.ids);

        return buff;
    }
    public static IByteBuffer ToPack(this GetPack pack, byte index)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(index).WriteLong(pack.qq).WriteString(pack.uuid);

        return buff;
    }
    public static IByteBuffer ToPack(this GroupGetMemberInfoPack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(57)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteString(pack.uuid);

        return buff;
    }
    public static IByteBuffer ToPack(this GroupGetSettingPack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(58)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteString(pack.uuid);

        return buff;
    }
    public static IByteBuffer ToPack(this EventCallPack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(59)
            .WriteLong(pack.qq)
            .WriteLong(pack.eventid)
            .WriteInt(pack.dofun)
            .WriteStringList(pack.arg);

        return buff;
    }
    public static IByteBuffer ToPack(this SendGroupImagePack pack)
    {
        if (pack.data == null)
            pack.data = Array.Empty<byte>();
        if (pack.ids == null)
            pack.ids = new();
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(61)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteBytes1(pack.data)
            .WriteLongList(pack.ids);

        return buff;
    }
    public static IByteBuffer ToPack(this SendGroupPrivateImagePack pack)
    {
        if (pack.data == null)
            pack.data = Array.Empty<byte>();
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(62)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteLong(pack.fid)
            .WriteBytes1(pack.data);

        return buff;
    }
    public static IByteBuffer ToPack(this SendFriendImagePack pack)
    {
        if (pack.data == null)
            pack.data = Array.Empty<byte>();
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(63)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteBytes1(pack.data);

        return buff;
    }
    public static IByteBuffer ToPack(this GroupKickMemberPack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(64)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteLong(pack.fid)
            .WriteBoolean(pack.black);

        return buff;
    }
    public static IByteBuffer ToPack(this GroupMuteMemberPack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(65)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteLong(pack.fid)
            .WriteInt(pack.time);

        return buff;
    }
    public static IByteBuffer ToPack(this GroupUnmuteMemberPack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(66)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteLong(pack.fid);

        return buff;
    }
    public static IByteBuffer ToPack(this GroupMuteAllPack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(67)
            .WriteLong(pack.qq)
            .WriteLong(pack.id);

        return buff;
    }
    public static IByteBuffer ToPack(this GroupUnmuteAllPack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(68)
            .WriteLong(pack.qq)
            .WriteLong(pack.id);

        return buff;
    }
    public static IByteBuffer ToPack(this GroupSetMemberCardPack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(69)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteLong(pack.fid)
            .WriteString(pack.card);

        return buff;
    }
    public static IByteBuffer ToPack(this GroupSetNamePack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(70)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteString(pack.name);

        return buff;
    }
    public static IByteBuffer ToPack(this ReCallMessagePack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(71)
            .WriteLong(pack.qq)
            .WriteInt(pack.id);

        return buff;
    }
    public static IByteBuffer ToPack(this SendGroupSoundPack pack)
    {
        if (pack.data == null)
            pack.data = Array.Empty<byte>();
        if (pack.ids == null)
            pack.ids = new();
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(74)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteBytes1(pack.data)
            .WriteLongList(pack.ids);

        return buff;
    }
    public static IByteBuffer ToPack(this SendGroupImageFilePack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(75)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteString(pack.file)
            .WriteLongList(pack.ids);

        return buff;
    }
    public static IByteBuffer ToPack(this SendGroupPrivateImageFilePack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(76)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteLong(pack.fid)
            .WriteString(pack.file);

        return buff;
    }
    public static IByteBuffer ToPack(this SendFriendImageFilePack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(77)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteLongList(pack.ids);

        return buff;
    }
    public static IByteBuffer ToPack(this SendGroupSoundFilePack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(78)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteString(pack.file)
            .WriteLongList(pack.ids);

        return buff;
    }
    public static IByteBuffer ToPack(this SendFriendNudgePack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(83)
            .WriteLong(pack.qq)
            .WriteLong(pack.id);

        return buff;
    }
    public static IByteBuffer ToPack(this SendGroupMemberNudgePack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(84)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteLong(pack.fid);

        return buff;
    }
    public static IByteBuffer ToPack(this GetImageUrlPack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(90)
            .WriteLong(pack.qq)
            .WriteString(pack.uuid);

        return buff;
    }
    public static IByteBuffer ToPack(this GetMemberInfoPack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(91)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteLong(pack.fid)
            .WriteString(pack.uuid);

        return buff;
    }
    public static IByteBuffer ToPack(this GetFriendInfoPack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(92)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteString(pack.uuid);

        return buff;
    }
    public static IByteBuffer ToPack(this SendMusicSharePack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(93)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteLong(pack.fid)
            .WriteInt(pack.type)
            .WriteInt(pack.type1)
            .WriteString(pack.title)
            .WriteString(pack.summary)
            .WriteString(pack.jumpUrl)
            .WriteString(pack.pictureUrl)
            .WriteString(pack.musicUrl);

        return buff;
    }
    public static IByteBuffer ToPack(this GroupSetEssenceMessagePack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(94)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteInt(pack.mid);

        return buff;
    }
    public static IByteBuffer ToPack(this MessageBuffPack pack)
    {
        if (pack.imgData == null)
            pack.imgData = Array.Empty<byte>();
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(95)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteLong(pack.fid)
            .WriteInt(pack.type)
            .WriteBoolean(pack.send)
            .WriteStringList(pack.text)
            .WriteString(pack.imgurl)
            .WriteBytes1(pack.imgData);

        return buff;
    }
    public static IByteBuffer ToPack(this SendFriendDicePack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteInt(pack.dice);

        return buff;
    }
    public static IByteBuffer ToPack(this SendGroupDicePack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(97)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteInt(pack.dice);

        return buff;
    }
    public static IByteBuffer ToPack(this SendGroupPrivateDicePack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(98)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteLong(pack.fid)
            .WriteInt(pack.dice);

        return buff;
    }
    public static IByteBuffer ToPack(this GroupAddFilePack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(99)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteString(pack.file)
            .WriteString(pack.name);

        return buff;
    }
    public static IByteBuffer ToPack(this GroupDeleteFilePack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(100)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteString(pack.fid);

        return buff;
    }
    public static IByteBuffer ToPack(this GroupGetFilesPack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(101)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteString(pack.uuid);

        return buff;
    }
    public static IByteBuffer ToPack(this GroupMoveFilePack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(102)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteString(pack.fid)
            .WriteString(pack.dir);

        return buff;
    }
    public static IByteBuffer ToPack(this GroupRenameFilePack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(103)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteString(pack.fid)
            .WriteString(pack.now);

        return buff;
    }
    public static IByteBuffer ToPack(this GroupAddDirPack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(104)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteString(pack.dir);

        return buff;
    }
    public static IByteBuffer ToPack(this GroupDeleteDirPack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(105)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteString(pack.dir);

        return buff;
    }
    public static IByteBuffer ToPack(this GroupRenameDirPack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(106)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteString(pack.old)
            .WriteString(pack.now);

        return buff;
    }
    public static IByteBuffer ToPack(this GroupDownloadFilePack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(107)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteString(pack.fid)
            .WriteString(pack.dir);

        return buff;
    }
    public static IByteBuffer ToPack(this GroupSetAdminPack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(108)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteLong(pack.fid)
            .WriteBoolean(pack.type);

        return buff;
    }
    public static IByteBuffer ToPack(this GroupGetAnnouncementsPack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(109)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteString(pack.uuid);

        return buff;
    }
    public static IByteBuffer ToPack(this GroupAddAnnouncementPack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(110)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteString(pack.imageFile)
            .WriteBoolean(pack.sendToNewMember)
            .WriteBoolean(pack.isPinned)
            .WriteBoolean(pack.showEditCard)
            .WriteBoolean(pack.showPopup)
            .WriteBoolean(pack.requireConfirmation)
            .WriteString(pack.text);

        return buff;
    }
    public static IByteBuffer ToPack(this GroupDeleteAnnouncementPack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(111)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteString(pack.fid);

        return buff;
    }
    public static IByteBuffer ToPack(this SendFriendSoundFilePack pack)
    {
        if (pack.ids == null)
            pack.ids = new();
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(112)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteString(pack.file)
            .WriteLongList(pack.ids);

        return buff;
    }
    public static IByteBuffer ToPack(this GroupSetAllowMemberInvitePack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(114)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteBoolean(pack.enable);

        return buff;
    }
    public static IByteBuffer ToPack(this GroupSetAnonymousChatEnabledPack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(115)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteBoolean(pack.enable);

        return buff;
    }
    public static IByteBuffer ToPack(this SendStrangerMessagePack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(117)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteStringList(pack.message);

        return buff;
    }
    public static IByteBuffer ToPack(this SendStrangerImageFilePack pack)
    {
        if (pack.ids == null)
            pack.ids = new();
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(118)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteString(pack.file)
            .WriteLongList(pack.ids);

        return buff;
    }
    public static IByteBuffer ToPack(this SendStrangerDicePack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(119)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteInt(pack.dice);

        return buff;
    }
    public static IByteBuffer ToPack(this SendStrangerNudgePack pack)
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(120)
            .WriteLong(pack.qq)
            .WriteLong(pack.id);

        return buff;
    }
    public static IByteBuffer ToPack(this SendStrangerSoundFilePack pack)
    {
        if (pack.ids == null)
            pack.ids = new();
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(121)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteString(pack.file)
            .WriteLongList(pack.ids);

        return buff;
    }
    public static IByteBuffer ToPack(this SendFriendSoundPack pack)
    {
        if (pack.data == null)
            pack.data = Array.Empty<byte>();
        if (pack.ids == null)
            pack.ids = new();
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(126)
            .WriteLong(pack.qq)
            .WriteLong(pack.id)
            .WriteBytes1(pack.data)
            .WriteLongList(pack.ids);

        return buff;
    }
    public static IByteBuffer TestPack()
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(60);
        return buff;
    }
}

internal class ColorMiraiNetty : IColorMiraiPipe
{
    public RobotSDK Robot;

    private record PackTask
    {
        public PackBase pack;
        public byte index;
    }
    private ConcurrentBag<PackTask> queue1;
    private ConcurrentBag<IByteBuffer> queue2;
    
    private Thread thread;
    private MultithreadEventLoopGroup group;
    private IChannel client;
    private Bootstrap bootstrap;

    public ColorMiraiNetty(RobotSDK robot)
    {
        Robot = robot;
        queue1 = new();
        queue2 = new();
        thread = new(Read);

        group = new MultithreadEventLoopGroup();
    }

    private void Read()
    {
        int time = 0;
        while (Robot.IsRun)
        {
            try
            {
                Thread.Sleep(50);
                if (!Robot.IsConnect)
                {
                    ReConnect();
                    Robot.IsFirst = false;
                    Robot.Times = 0;
                    Robot.RobotStateEvent.Invoke(StateType.Connect);
                }
                else if (queue2.TryTake(out var item))
                {
                    if (item == null)
                    {
                        continue;
                    }
                    byte index = item.ReadByte();
                    if (index == 60)
                        continue;
                    PackBase pack = null;
                    switch (index)
                    {
                        case 1:
                            pack = item.BeforeImageUploadPack();
                            break;
                        case 2:
                            pack = item.BotAvatarChangedPack();
                            break;
                        case 3:
                            pack = item.BotGroupPermissionChangePack();
                            break;
                        case 4:
                            pack = item.BotInvitedJoinGroupRequestEventPack();
                            break;
                        case 5:
                            pack = item.BotJoinGroupEventAPack();
                            break;
                        case 6:
                            pack = item.BotJoinGroupEventBPack();
                            break;
                        case 7:
                            pack = item.BotLeaveEventAPack();
                            break;
                        case 8:
                            pack = item.BotLeaveEventBPack();
                            break;
                        case 9:
                            pack = item.BotMuteEventPack();
                            break;
                        case 10:
                            pack = item.BotOfflineEventAPack();
                            break;
                        case 11:
                            pack = item.BotOfflineEventBPack();
                            break;
                        case 12:
                            pack = item.BotOfflineEventAPack();
                            break;
                        case 13:
                            pack = item.BotOfflineEventAPack();
                            break;
                        case 14:
                            pack = item.BotOfflineEventCPack();
                            break;
                        case 15:
                            pack = item.BotOnlineEventPack();
                            break;
                        case 16:
                            pack = item.BotReloginEventPack();
                            break;
                        case 17:
                            pack = item.BotUnmuteEventPack();
                            break;
                        case 18:
                            pack = item.FriendAddEventPack();
                            break;
                        case 19:
                            pack = item.FriendAvatarChangedEventPack();
                            break;
                        case 20:
                            pack = item.FriendDeleteEventPack();
                            break;
                        case 21:
                            pack = item.FriendMessagePostSendEventPack();
                            break;
                        case 22:
                            pack = item.FriendMessagePreSendEventPack();
                            break;
                        case 23:
                            pack = item.FriendRemarkChangeEventPack();
                            break;
                        case 24:
                            pack = item.GroupAllowAnonymousChatEventPack();
                            break;
                        case 25:
                            pack = item.GroupAllowConfessTalkEventPack();
                            break;
                        case 26:
                            pack = item.GroupAllowMemberInviteEventPack();
                            break;
                        //case 27:
                        //    pack = item.GroupEntranceAnnouncementChangeEventPack();
                        //    break;
                        case 28:
                            pack = item.GroupMessagePostSendEventPack();
                            break;
                        case 29:
                            pack = item.GroupMessagePreSendEventPack();
                            break;
                        case 30:
                            pack = item.GroupMuteAllEventPack();
                            break;
                        case 31:
                            pack = item.GroupNameChangeEventPack();
                            break;
                        case 32:
                            pack = item.ImageUploadEventAPack();
                            break;
                        case 33:
                            pack = item.ImageUploadEventBPack();
                            break;
                        case 34:
                            pack = item.MemberCardChangeEventPack();
                            break;
                        case 35:
                            pack = item.InviteMemberJoinEventPack();
                            break;
                        case 36:
                            pack = item.MemberJoinEventPack();
                            break;
                        case 37:
                            pack = item.MemberJoinRequestEventPack();
                            break;
                        case 38:
                            pack = item.MemberLeaveEventAPack();
                            break;
                        case 39:
                            pack = item.MemberLeaveEventBPack();
                            break;
                        case 40:
                            pack = item.MemberMuteEventPack();
                            break;
                        case 41:
                            pack = item.MemberPermissionChangeEventPack();
                            break;
                        case 42:
                            pack = item.MemberSpecialTitleChangeEventPack();
                            break;
                        case 43:
                            pack = item.MemberUnmuteEventPack();
                            break;
                        case 44:
                            pack = item.MessageRecallEventAPack();
                            break;
                        case 45:
                            pack = item.MessageRecallEventBPack();
                            break;
                        case 46:
                            pack = item.NewFriendRequestEventPack();
                            break;
                        case 47:
                            pack = item.TempMessagePostSendEventPack();
                            break;
                        case 48:
                            pack = item.TempMessagePreSendEventPack();
                            break;
                        case 49:
                            pack = item.GroupMessageEventPack();
                            break;
                        case 50:
                            pack = item.TempMessageEventPack();
                            break;
                        case 51:
                            pack = item.FriendMessageEventPack();
                            break;
                        case 55:
                            pack = item.ListGroupPack();
                            break;
                        case 56:
                            pack = item.ListFriendPack();
                            break;
                        case 57:
                            pack = item.ListMemberPack();
                            break;
                        case 58:
                            pack = item.GroupSettingPack();
                            break;
                        case 72:
                            pack = item.FriendInputStatusChangedEventPack();
                            break;
                        case 73:
                            pack = item.FriendNickChangedEventPack();
                            break;
                        case 79:
                            pack = item.MemberJoinRetrieveEventPack();
                            break;
                        case 80:
                            pack = item.BotJoinGroupEventRetrieveEventPack();
                            break;
                        case 81:
                            pack = item.NudgedEventPack();
                            break;
                        case 82:
                            pack = item.NudgedEventPack();
                            break;
                        case 85:
                            pack = item.GroupTalkativeChangePack();
                            break;
                        case 86:
                            pack = item.OtherClientOnlineEventPack();
                            break;
                        case 87:
                            pack = item.OtherClientOfflineEventPack();
                            break;
                        case 88:
                            pack = item.OtherClientMessageEventPack();
                            break;
                        case 89:
                            pack = item.GroupMessageSyncEventPack();
                            break;
                        case 90:
                            pack = item.GetImageUrlPack();
                            break;
                        case 91:
                            pack = item.MemberInfoPack();
                            break;
                        case 92:
                            pack = item.FriendInfoPack();
                            break;
                        case 101:
                            pack = item.GroupFilesPack();
                            break;
                        case 109:
                            pack = item.GroupAnnouncementsPack();
                            break;
                        case 113:
                            pack = item.GroupDisbandPack();
                            break;
                        case 116:
                            pack = item.StrangerMessageEventPack();
                            break;
                        case 122:
                            pack = item.StrangerMessagePreSendEventPack();
                            break;
                        case 123:
                            pack = item.StrangerMessagePostSendEventPack();
                            break;
                        case 124:
                            pack = item.StrangerRelationChangePack();
                            break;
                        case 125:
                            pack = item.StrangerRelationChangePack();
                            break;
                    }

                    Robot.AddRead(pack, index);
                }
                else if (Robot.Config.Check && time >= 20)
                {
                    time = 0;
                    AddSend(null, 60);
                }
                else if (queue1.TryTake(out PackTask item1))
                {
                    IByteBuffer pack = null;
                    switch (item1.index)
                    {
                        case 52:
                            pack = (item1.pack as SendGroupMessagePack).ToPack();
                            break;
                        case 53:
                            pack = (item1.pack as SendGroupPrivateMessagePack).ToPack();
                            break;
                        case 54:
                            pack = (item1.pack as SendFriendMessagePack).ToPack();
                            break;
                        case 55:
                            pack = (item1.pack as GetPack).ToPack(55);
                            break;
                        case 56:
                            pack = (item1.pack as GetPack).ToPack(56);
                            break;
                        case 57:
                            pack = (item1.pack as GroupGetMemberInfoPack).ToPack();
                            break;
                        case 58:
                            pack = (item1.pack as GroupGetSettingPack).ToPack();
                            break;
                        case 59:
                            pack = (item1.pack as EventCallPack).ToPack();
                            break;
                        case 60:
                            pack = PackEncode.TestPack();
                            break;
                        case 61:
                            pack = (item1.pack as SendGroupImagePack).ToPack();
                            break;
                        case 62:
                            pack = (item1.pack as SendGroupPrivateImagePack).ToPack();
                            break;
                        case 63:
                            pack = (item1.pack as SendFriendImagePack).ToPack();
                            break;
                        case 64:
                            pack = (item1.pack as GroupKickMemberPack).ToPack();
                            break;
                        case 65:
                            pack = (item1.pack as GroupMuteMemberPack).ToPack();
                            break;
                        case 66:
                            pack = (item1.pack as GroupUnmuteMemberPack).ToPack();
                            break;
                        case 67:
                            pack = (item1.pack as GroupMuteAllPack).ToPack();
                            break;
                        case 68:
                            pack = (item1.pack as GroupUnmuteAllPack).ToPack();
                            break;
                        case 69:
                            pack = (item1.pack as GroupSetMemberCardPack).ToPack();
                            break;
                        case 70:
                            pack = (item1.pack as GroupSetNamePack).ToPack();
                            break;
                        case 71:
                            pack = (item1.pack as ReCallMessagePack).ToPack();
                            break;
                        case 74:
                            pack = (item1.pack as SendGroupSoundPack).ToPack();
                            break;
                        case 75:
                            pack = (item1.pack as SendGroupImageFilePack).ToPack();
                            break;
                        case 76:
                            pack = (item1.pack as SendGroupPrivateImageFilePack).ToPack();
                            break;
                        case 77:
                            pack = (item1.pack as SendFriendImageFilePack).ToPack();
                            break;
                        case 78:
                            pack = (item1.pack as SendGroupSoundFilePack).ToPack();
                            break;
                        case 83:
                            pack = (item1.pack as SendFriendNudgePack).ToPack();
                            break;
                        case 84:
                            pack = (item1.pack as SendGroupMemberNudgePack).ToPack();
                            break;
                        case 90:
                            pack = (item1.pack as GetImageUrlPack).ToPack();
                            break;
                        case 91:
                            pack = (item1.pack as GetMemberInfoPack).ToPack();
                            break;
                        case 92:
                            pack = (item1.pack as GetFriendInfoPack).ToPack();
                            break;
                        case 93:
                            pack = (item1.pack as SendMusicSharePack).ToPack();
                            break;
                        case 94:
                            pack = (item1.pack as GroupSetEssenceMessagePack).ToPack();
                            break;
                        case 95:
                            pack = (item1.pack as MessageBuffPack).ToPack();
                            break;
                        case 96:
                            pack = (item1.pack as SendFriendDicePack).ToPack();
                            break;
                        case 97:
                            pack = (item1.pack as SendGroupDicePack).ToPack();
                            break;
                        case 98:
                            pack = (item1.pack as SendGroupPrivateDicePack).ToPack();
                            break;
                        case 99:
                            pack = (item1.pack as GroupAddFilePack).ToPack();
                            break;
                        case 100:
                            pack = (item1.pack as GroupDeleteFilePack).ToPack();
                            break;
                        case 101:
                            pack = (item1.pack as GroupGetFilesPack).ToPack();
                            break;
                        case 102:
                            pack = (item1.pack as GroupMoveFilePack).ToPack();
                            break;
                        case 103:
                            pack = (item1.pack as GroupRenameFilePack).ToPack();
                            break;
                        case 104:
                            pack = (item1.pack as GroupAddDirPack).ToPack();
                            break;
                        case 105:
                            pack = (item1.pack as GroupDeleteDirPack).ToPack();
                            break;
                        case 106:
                            pack = (item1.pack as GroupRenameDirPack).ToPack();
                            break;
                        case 107:
                            pack = (item1.pack as GroupDownloadFilePack).ToPack();
                            break;
                        case 108:
                            pack = (item1.pack as GroupSetAdminPack).ToPack();
                            break;
                        case 109:
                            pack = (item1.pack as GroupGetAnnouncementsPack).ToPack();
                            break;
                        case 110:
                            pack = (item1.pack as GroupAddAnnouncementPack).ToPack();
                            break;
                        case 111:
                            pack = (item1.pack as GroupDeleteAnnouncementPack).ToPack();
                            break;
                        case 112:
                            pack = (item1.pack as SendFriendSoundFilePack).ToPack();
                            break;
                        case 114:
                            pack = (item1.pack as GroupSetAllowMemberInvitePack).ToPack();
                            break;
                        case 115:
                            pack = (item1.pack as GroupSetAnonymousChatEnabledPack).ToPack();
                            break;
                        case 117:
                            pack = (item1.pack as SendStrangerMessagePack).ToPack();
                            break;
                        case 118:
                            pack = (item1.pack as SendStrangerImageFilePack).ToPack();
                            break;
                        case 119:
                            pack = (item1.pack as SendStrangerDicePack).ToPack();
                            break;
                        case 120:
                            pack = (item1.pack as SendStrangerNudgePack).ToPack();
                            break;
                        case 121:
                            pack = (item1.pack as SendStrangerSoundFilePack).ToPack();
                            break;
                        case 126:
                            pack = (item1.pack as SendFriendSoundPack).ToPack();
                            break;
                    }
                    if (pack != null)
                    {
                        client.WriteAndFlushAsync(pack);
                    }
                }
                time++;
            }
            catch (Exception e)
            {
                Robot.IsConnect = false;
                Robot.RobotStateEvent.Invoke(StateType.Disconnect);
                if (Robot.IsFirst)
                {
                    Robot.IsRun = false;
                    Robot.LogError("机器人连接失败");
                }
                else
                {
                    Robot.Times++;
                    if (Robot.Times == 10)
                    {
                        Robot.IsRun = false;
                        Robot.LogError("重连失败次数过多");
                    }
                    Robot.LogError("机器人连接失败");
                    Robot.LogError(e);
                    Robot.IsConnect = false;
                    Robot.LogError($"机器人{Robot.Config.Time}毫秒后重连");
                    Thread.Sleep(Robot.Config.Time);
                    Robot.LogError("机器人重连中");
                }
            }
        }
    }

    public void AddSend(PackBase pack, byte index)
    {
        queue1.Add(new PackTask
        {
            pack = pack,
            index = index
        });
    }

    internal void AddReadPack(IByteBuffer pack) 
    {
        queue2.Add(pack);
    }

    public void ReConnect()
    {
        if (client != null)
        {
            client.CloseAsync().Wait();
            client.DeregisterAsync().Wait();
        }

        queue2.Clear();

        Robot.RobotStateEvent.Invoke(StateType.Connecting);

        bootstrap = new Bootstrap();
        bootstrap
            .Group(group)
            .Channel<TcpSocketChannel>()
            .Handler(new ActionChannelInitializer<ISocketChannel>(channel =>
            {
                IChannelPipeline pipeline = channel.Pipeline;
                pipeline.AddLast(new LengthFieldPrepender(4))
                        .AddLast(new LengthFieldBasedFrameDecoder(1024 * 500, 0, 4, 0, 4))
                        .AddLast(new ClientHandler(this));
            }));
        client = bootstrap.ConnectAsync(Robot.Config.IP, Robot.Config.Port).Result;

        var pack = Robot.PackStart.ToPack();

        client.WriteAndFlushAsync(pack).Wait();

        while (!queue2.TryTake(out pack))
        {
            Thread.Sleep(10);
        }

        Robot.QQs = pack.StartPack();

        queue1.Clear();
        Robot.LogOut("机器人已连接");
        Robot.IsConnect = true;
    }

    public void SendStop()
    {
        IByteBuffer buff = Unpooled.Buffer();
        buff.WriteByte(127);
        client.WriteAndFlushAsync(buff).Wait();
    }

    public void StartRead()
    {
        thread.Start();
    }

    public void Stop()
    {
        Robot.IsConnect = false;
        Robot.RobotStateEvent.Invoke(StateType.Disconnect);
        client.CloseAsync().Wait();
    }
}

internal class ClientHandler : ChannelHandlerAdapter
{
    private ColorMiraiNetty netty;
    internal ClientHandler(ColorMiraiNetty netty)
    {
        this.netty = netty;
    }

    public override void ChannelRead(IChannelHandlerContext context, object message)
    {
        var byteBuffer = message as IByteBuffer;
        netty.AddReadPack(byteBuffer);
    }

    public override void ChannelInactive(IChannelHandlerContext context)
    {
        netty.Robot.IsConnect = false;
        netty.Robot.RobotStateEvent.Invoke(StateType.Disconnect);
    }

    public override void ChannelReadComplete(IChannelHandlerContext context) => context.Flush();

    public override void ExceptionCaught(IChannelHandlerContext context, Exception exception)
    {
        netty.Robot.IsConnect = false;
        netty.Robot.RobotStateEvent.Invoke(StateType.Disconnect);
        context.CloseAsync();
    }
}