use bytes::{BufMut, BytesMut};

use super::*;
use crate::command::common::PbToBytes;
use crate::pb;
use crate::protocol::packet::Packet;

impl super::super::super::Engine {
    // OidbSvc.0x4ff_9_IMCore
    pub fn build_update_profile_detail_packet(&self, profile: ProfileDetailUpdate) -> Packet {
        let mut w = BytesMut::new();
        w.put_u32(self.uin() as u32);
        w.put_u8(0);
        w.put_u16(profile.0.len() as u16);
        for (tag, value) in profile.0 {
            w.put_u16(tag);
            w.put_u16(value.len() as u16);
            w.put_slice(&value);
        }
        let payload = self.transport.encode_oidb_packet(0x4ff, 9, w.freeze());
        self.uni_packet("OidbSvc.0x4ff_9_IMCore", payload)
    }

    // OidbSvc.0x88d_0
    pub fn build_group_info_request_packet(&self, group_codes: Vec<i64>) -> Packet {
        let body = pb::oidb::D88dReqBody {
            app_id: Some(self.transport.version.app_id),
            req_group_info: group_codes
                .into_iter()
                .map(|group_code| pb::oidb::ReqGroupInfo {
                    group_code: Some(group_code as u64),
                    stgroupinfo: Some(pb::oidb::D88dGroupInfo {
                        group_owner: Some(0),
                        group_uin: Some(0),
                        group_create_time: Some(0),
                        group_flag: Some(0),
                        group_member_max_num: Some(0),
                        group_member_num: Some(0),
                        group_option: Some(0),
                        group_level: Some(0),
                        group_face: Some(0),
                        group_name: Some(vec![]),
                        group_memo: Some(vec![]),
                        group_finger_memo: Some(vec![]),
                        group_last_msg_time: Some(0),
                        group_cur_msg_seq: Some(0),
                        group_question: Some(vec![]),
                        group_answer: Some(vec![]),
                        group_grade: Some(0),
                        active_member_num: Some(0),
                        head_portrait_seq: Some(0),
                        msg_head_portrait: Some(pb::oidb::D88dGroupHeadPortrait::default()),
                        st_group_ex_info: Some(pb::oidb::D88dGroupExInfoOnly::default()),
                        group_sec_level: Some(0),
                        cmduin_privilege: Some(0),
                        no_finger_open_flag: Some(0),
                        no_code_finger_open_flag: Some(0),
                        ..Default::default()
                    }),
                    ..Default::default()
                })
                .collect(),
            pc_client_version: Some(0),
        };
        let payload = self.transport.encode_oidb_packet(0x88d, 0, body.to_bytes());
        self.uni_packet("OidbSvc.0x88d_0", payload)
    }

    // OidbSvc.0x570_8
    pub fn build_group_mute_packet(
        &self,
        group_code: i64,
        member_uin: i64,
        duration: u32,
    ) -> Packet {
        let mut w = BytesMut::new();
        w.put_u32(group_code as u32);
        w.put_u8(32);
        w.put_u16(1);
        w.put_u32(member_uin as u32);
        w.put_u32(duration);
        let payload = self.transport.encode_oidb_packet(0x570, 8, w.freeze());
        self.uni_packet("OidbSvc.0x570_8", payload)
    }

    // OidbSvc.0x89a_0
    fn build_group_operation_packet(&self, body: pb::oidb::D89aReqBody) -> Packet {
        let payload = self.transport.encode_oidb_packet(0x89a, 0, body.to_bytes());
        self.uni_packet("OidbSvc.0x89a_0", payload)
    }

    // OidbSvc.0x89a_0
    pub fn build_group_mute_all_packet(&self, group_code: i64, mute: bool) -> Packet {
        let shut_up_time: i32 = if mute { 268435455 } else { 0 };
        let body = pb::oidb::D89aReqBody {
            group_code,
            st_group_info: Some(pb::oidb::D89aGroupinfo {
                shutup_time: Some(pb::oidb::d89a_groupinfo::ShutupTime::Val(shut_up_time)),
                ..Default::default()
            }),
            ..Default::default()
        };
        self.build_group_operation_packet(body)
    }

    // OidbSvc.0x89a_0
    pub fn build_group_name_update_packet(&self, group_code: i64, name: String) -> Packet {
        let body = pb::oidb::D89aReqBody {
            group_code,
            st_group_info: Some(pb::oidb::D89aGroupinfo {
                ing_group_name: name.as_bytes().to_vec(),
                ..Default::default()
            }),
            ..Default::default()
        };
        self.build_group_operation_packet(body)
    }

    // OidbSvc.0x89a_0
    pub fn build_group_memo_update_packet(&self, group_code: i64, memo: String) -> Packet {
        let body = pb::oidb::D89aReqBody {
            group_code,
            st_group_info: Some(pb::oidb::D89aGroupinfo {
                ing_group_memo: memo.as_bytes().to_vec(),
                ..Default::default()
            }),
            ..Default::default()
        };
        self.build_group_operation_packet(body)
    }

    // OidbSvc.0x8a0_0
    pub fn build_group_kick_packet(
        &self,
        group_code: i64,
        member_uins: Vec<i64>,
        kick_msg: &str,
        block: bool,
    ) -> Packet {
        let flag_block = if block { 1 } else { 0 };
        let body = pb::oidb::D8a0ReqBody {
            opt_uint64_group_code: group_code,
            msg_kick_list: member_uins
                .into_iter()
                .map(|member_uin| pb::oidb::D8a0KickMemberInfo {
                    opt_uint32_operate: 5,
                    opt_uint64_member_uin: member_uin,
                    opt_uint32_flag: flag_block,
                    ..Default::default()
                })
                .collect(),
            kick_msg: kick_msg.as_bytes().to_vec(),
            ..Default::default()
        };
        let payload = self.transport.encode_oidb_packet(0x8a0, 0, body.to_bytes());
        self.uni_packet("OidbSvc.0x8a0_0", payload)
    }

    // OidbSvc.0xed3
    pub fn build_group_poke_packet(&self, group_code: i64, target: i64) -> Packet {
        let body = pb::oidb::Ded3ReqBody {
            to_uin: target,
            group_code,
            ..Default::default()
        };
        let payload = self.transport.encode_oidb_packet(0xed3, 1, body.to_bytes());
        self.uni_packet("OidbSvc.0xed3", payload)
    }

    // OidbSvc.0xed3
    pub fn build_friend_poke_packet(&self, target: i64) -> Packet {
        let body = pb::oidb::Ded3ReqBody {
            to_uin: target,
            aio_uin: target,
            ..Default::default()
        };
        let payload = self.transport.encode_oidb_packet(0xed3, 1, body.to_bytes());
        self.uni_packet("OidbSvc.0xed3", payload)
    }

    // OidbSvc.0x55c_1
    pub fn build_group_admin_set_packet(&self, group_code: i64, member: i64, flag: bool) -> Packet {
        let mut w = BytesMut::new();
        w.put_u32(group_code as u32);
        w.put_u32(member as u32);
        w.put_u8(if flag { 0x01 } else { 0x00 });
        let payload = self.transport.encode_oidb_packet(0x55c, 1, w.freeze());
        self.uni_packet("OidbSvc.0x55c_1", payload)
    }

    // OidbSvc.0x758
    pub fn build_group_invite_packet(&self, group_code: i64, uin: i64) -> Packet {
        let body = pb::oidb::D758ReqBody {
            join_group_code: Some(group_code as u64),
            be_invited_uin_info: vec![pb::oidb::InviteUinInfo {
                uin: Some(uin as u64),
                ..Default::default()
            }],
            ..Default::default()
        };
        let payload = self.transport.encode_oidb_packet(0x758, 1, body.to_bytes());
        self.uni_packet("OidbSvc.0x758", payload)
    }

    // OidbSvc.0x8a7_0
    pub fn build_group_at_all_remain_request_packet(&self, group_code: i64) -> Packet {
        let body = pb::oidb::D8a7ReqBody {
            sub_cmd: Some(1),
            limit_interval_type_for_uin: Some(2),
            limit_interval_type_for_group: Some(1),
            uin: Some(self.uin() as u64),
            group_code: Some(group_code as u64),
        };
        let payload = self.transport.encode_oidb_packet(0x8a7, 0, body.to_bytes());
        self.uni_packet("OidbSvc.0x8a7_0", payload)
    }

    // OidbSvc.0x8fc_2
    pub fn build_edit_special_title_packet(
        &self,
        group_code: i64,
        member_uin: i64,
        new_title: String,
    ) -> Packet {
        let body = pb::oidb::D8fcReqBody {
            group_code: Some(group_code),
            mem_level_info: vec![pb::oidb::D8fcMemberInfo {
                uin: Some(member_uin),
                uin_name: Some(new_title.as_bytes().to_vec()),
                special_title: Some(new_title.as_bytes().to_vec()),
                special_title_expire_time: Some(-1),
                ..Default::default()
            }],
            ..Default::default()
        };
        let payload = self.transport.encode_oidb_packet(0x8fc, 2, body.to_bytes());
        self.uni_packet("OidbSvc.0x8fc_2", payload)
    }

    // OidbSvc.0x990
    pub fn build_translate_request_packet(
        &self,
        src_language: String,
        dst_language: String,
        src_text_list: Vec<String>,
    ) -> Packet {
        let body = pb::oidb::TranslateReqBody {
            batch_translate_req: Some(pb::oidb::BatchTranslateReq {
                src_language,
                dst_language,
                src_text_list,
            }),
        };
        let payload = self.transport.encode_oidb_packet(0x990, 2, body.to_bytes());
        self.uni_packet("OidbSvc.0x990", payload)
    }

    // OidbSvc.0xeac
    pub fn build_essence_msg_operate_packet(
        &self,
        group_code: i64,
        msg_seq: i32,
        msg_rand: i32,
        flag: bool,
    ) -> Packet {
        let body = pb::oidb::EacReqBody {
            group_code: Some(group_code as u64),
            seq: Some(msg_seq as u32),
            random: Some(msg_rand as u32),
        };
        let payload =
            self.transport
                .encode_oidb_packet(0xeac, if flag { 1 } else { 2 }, body.to_bytes());
        self.uni_packet("OidbSvc.0xeac", payload)
    }

    // OidbSvc.0xe07_0
    pub fn build_image_ocr_request_packet(
        &self,
        url: String,
        md5: String,
        size: i32,
        wight: i32,
        height: i32,
    ) -> Packet {
        let body = pb::oidb::De07ReqBody {
            version: 1,
            entrance: 3,
            ocr_req_body: Some(pb::oidb::OcrReqBody {
                image_url: url,
                origin_md5: md5.clone(),
                after_compress_md5: md5,
                after_compress_file_size: size,
                after_compress_height: height,
                after_compress_weight: wight,
                ..Default::default()
            }),
            ..Default::default()
        };
        let payload = self.transport.encode_oidb_packet(0xe07, 0, body.to_bytes());
        self.uni_packet("OidbSvc.0xe07_0", payload)
    }

    pub fn build_share_music_request_packet(
        &self,
        share_target: ShareTarget,
        music_share: MusicShare,
        music_version: MusicVersion,
    ) -> Packet {
        let body = pb::oidb::Db77ReqBody {
            app_id: music_version.app_id,
            app_type: music_version.app_type,
            msg_style: if music_share.music_url.is_empty() {
                0
            } else {
                4
            },
            client_info: Some(pb::oidb::Db77ClientInfo {
                platform: music_version.platform,
                sdk_version: music_version.sdk_version.into(),
                android_package_name: music_version.package_name.into(),
                android_signature: music_version.signature.into(),
                ..Default::default()
            }),
            send_type: share_target.send_type(),
            recv_uin: match share_target {
                ShareTarget::Friend(uin) => uin as u64,
                ShareTarget::Group(code) => code as u64,
                ShareTarget::Guild { channel_id, .. } => channel_id,
            },
            rich_msg_body: Some(pb::oidb::Db77RichMsgBody {
                title: music_share.title,
                summary: music_share.summary,
                brief: music_share.brief,
                url: music_share.url,
                picture_url: music_share.picture_url,
                music_url: music_share.music_url,
                ..Default::default()
            }),
            recv_guild_id: if let ShareTarget::Guild { guild_id, .. } = share_target {
                guild_id
            } else {
                0
            },
            ..Default::default()
        };
        let payload = self.transport.encode_oidb_packet(0xb77, 9, body.to_bytes());
        self.uni_packet("OidbSvc.0xb77_9", payload)
    }

    pub fn build_share_link_request_packet(
        &self,
        share_target: ShareTarget,
        link_share: LinkShare,
    ) -> Packet {
        let body = pb::oidb::Db77ReqBody {
            app_id: 100446242,
            app_type: 1,
            msg_style: 0,
            client_info: Some(pb::oidb::Db77ClientInfo {
                platform: 1,
                sdk_version: "0.0.0".into(),
                android_package_name: "com.tencent.mtt".into(),
                android_signature: "d8391a394d4a179e6fe7bdb8a301258b".into(),
                ..Default::default()
            }),
            send_type: share_target.send_type(),
            recv_uin: match share_target {
                ShareTarget::Friend(uin) => uin as u64,
                ShareTarget::Group(code) => code as u64,
                ShareTarget::Guild { channel_id, .. } => channel_id,
            },
            rich_msg_body: Some(pb::oidb::Db77RichMsgBody {
                summary: link_share.summary.unwrap_or_default(),
                brief: link_share
                    .brief
                    .unwrap_or_else(|| format!("[分享] {}", link_share.title)),
                title: link_share.title,
                url: link_share.url,
                picture_url: link_share.picture_url.unwrap_or_else(|| "none".into()), // "none" will use default icon
                music_url: String::new(),
                action: String::new(),
            }),
            recv_guild_id: if let ShareTarget::Guild { guild_id, .. } = share_target {
                guild_id
            } else {
                0
            },
            ..Default::default()
        };
        let payload = self.transport.encode_oidb_packet(0xb77, 9, body.to_bytes());
        self.uni_packet("OidbSvc.0xb77_9", payload)
    }

    // OidbSvc.0x899_0
    pub fn build_get_group_admin_list_request_packet(&self, group_code: u64) -> Packet {
        let body = pb::cmd0x899::ReqBody {
            group_code: Some(group_code),
            start_uin: Some(0),
            identify_flag: Some(2),
            memberlist_opt: Some(pb::cmd0x899::Memberlist {
                member_uin: Some(0),
                privilege: Some(1),
                ..Default::default()
            }),
            ..Default::default()
        };
        let payload = self.transport.encode_oidb_packet(0x899, 0, body.to_bytes());
        self.uni_packet("OidbSvc.0x899_0", payload)
    }

    // OidbSvc.0xeb7
    pub fn build_group_sign_in_packet(&self, group_code: i64) -> Packet {
        let body = pb::oidb::Deb7ReqBody {
            sign_in_write_req: Some(pb::oidb::StSignInWriteReq {
                uid: Some(self.uin().to_string()),
                group_id: Some(group_code.to_string()),
                client_version: Some(self.transport.version.sort_version_name.to_string()),
            }),
            ..Default::default()
        };
        let payload = self.transport.encode_oidb_packet(0xeb7, 1, body.to_bytes());
        self.uni_packet("OidbSvc.0xeb7", payload)
    }
    // OidbSvc.0x6d8_1
    pub fn build_group_file_list_request_packet(
        &self,
        group_code: u64,
        folder_id: String,
        start_index: u32,
    ) -> Packet {
        let body = pb::oidb::D6d8ReqBody {
            file_list_info_req: Some(pb::oidb::GetFileListReqBody {
                group_code: Some(group_code),
                app_id: Some(3),
                folder_id: Some(folder_id),
                file_count: Some(20),
                all_file_count: Some(0),
                req_from: Some(3),
                sort_by: Some(1),
                filter_code: Some(0),
                uin: Some(0),
                start_index: Some(start_index),
                context: None,
                ..Default::default()
            }),
            ..Default::default()
        };
        let payload = self.transport.encode_oidb_packet(0x6d8, 1, body.to_bytes());
        self.uni_packet("OidbSvc.0x6d8_1", payload)
    }
    // OidbSvc.0x6d6_2
    pub fn build_group_file_download_request_packet(
        &self,
        group_code: i64,
        file_id: String,
        bus_id: i32,
    ) -> Packet {
        let body = pb::oidb::D6d6ReqBody {
            download_file_req: Some(pb::oidb::DownloadFileReqBody {
                file_id: Some(file_id),
                group_code: Some(group_code),
                app_id: Some(3),
                bus_id: Some(bus_id),
                ..Default::default()
            }),
            ..Default::default()
        };
        let payload = self.transport.encode_oidb_packet(1750, 2, body.to_bytes());
        self.uni_packet("OidbSvc.0x6d6_2", payload)
    }
    // OidbSvc.0x6d8_1
    pub fn build_group_file_count_request_packet(&self, group_code: u64) -> Packet {
        let body = pb::oidb::D6d8ReqBody {
            group_file_count_req: Some(pb::oidb::GetFileCountReqBody {
                group_code: Some(group_code),
                app_id: Some(3),
                bus_id: Some(0),
            }),
            ..Default::default()
        };
        let payload = self.transport.encode_oidb_packet(0x6d8, 2, body.to_bytes());
        self.uni_packet("OidbSvc.0x6d8_1", payload)
    }
}