use crate::raw::*;
use crate::Result;
use std::collections::HashMap;

// Ts3 uses just whatever is available in the DB system, could be i32 or i64, though every foreign key is unsigned..
pub type ServerId = u64;
pub type ServerGroupID = u64;
pub type ChannelId = u64;
/// Temporary, per connection ID of a client, reused upon disconnect.  
/// Not to be confused with a client database, myteamspeak or identity ID.
pub type ClientId = u16;
/// Server interal ID for client, not it's Identity / MyTeamspeak ID.
pub type ClientDBId = u64;
pub type ChannelGroupId = u64;
/// CRC32 checksum of the channel icon, but received as i64 instead of u64, except when using `clientdbinfo`
pub type IconHash = i64;

/// Server Group returned from `server_group_list`. Field names are according to the query protocol.
#[derive(Debug)]
pub struct ServerGroup {
    /// Identifier for this server group
    pub sgid: ServerGroupID,
    pub name: String,
    /// Group type: template,regular,query
    /// `type` use `r#type` to specify in rust
    pub r#type: i32,
    pub iconid: IconHash,
    // whether group is stored to DB
    pub savedb: bool,
}

impl ServerGroup {
    /// Create struct from raw line-data assuming no unescaping was performed
    pub(crate) fn from_raw(mut data: HashMap<String, Option<String>>) -> Result<Self> {
        let sgid = int_val_parser(&mut data, "sgid")?;
        let name = string_val_parser(&mut data, "name")?;
        let r#type = int_val_parser(&mut data, "type")?;
        let iconid = int_val_parser(&mut data, "iconid")?;
        let savedb = bool_val_parser(&mut data, "savedb")?;

        Ok(ServerGroup {
            sgid,
            name,
            r#type,
            iconid,
            savedb,
        })
    }
}

#[derive(Debug)]
pub struct OnlineClient {
    pub clid: ClientId,
    pub cid: ChannelId,
    pub client_database_id: ClientDBId,
    pub client_nickname: String,
    /// 0 For normal client, 1 for query
    pub client_type: i8,
}

impl OnlineClient {
    pub(crate) fn from_raw(mut data: HashMap<String, Option<String>>) -> Result<Self> {
        let clid = int_val_parser(&mut data, "clid")?;
        let cid = int_val_parser(&mut data, "cid")?;
        let client_database_id = int_val_parser(&mut data, "client_database_id")?;
        let client_nickname: String = string_val_parser(&mut data, "client_nickname")?;
        let client_type = int_val_parser(&mut data, "client_type")?;

        Ok(OnlineClient {
            clid,
            cid,
            client_database_id,
            client_nickname,
            client_type,
        })
    }
}

#[derive(Debug)]
pub struct OnlineClientFull {
    pub clid: ClientId,
    pub cid: ChannelId,
    pub client_database_id: ClientDBId,
    pub client_nickname: String,
    /// 0 For normal client, 1 for query
    pub client_type: i8,
    pub client_away: bool,
    pub client_away_message: Option<String>,
    pub client_flag_talking: bool,
    pub client_input_muted: bool,
    pub client_output_muted: bool,
    pub client_input_hardware: bool,
    pub client_output_hardware: bool,
    pub client_talk_power: i32,
    pub client_is_talker: bool,
    pub client_is_priority_speaker: bool,
    pub client_is_recording: bool,
    pub client_is_channel_commander: bool,
    pub client_unique_identifier: String,
    pub client_servergroups: Vec<ServerGroupID>,
    pub client_channel_group_id: ChannelGroupId,
    pub client_channel_group_inherited_channel_id: ChannelGroupId,
    pub client_version: String,
    pub client_platform: String,
    pub client_idle_time: i64,
    pub client_created: i64,
    pub client_lastconnected: i64,
    pub client_country: String,
    pub connection_client_ip: String,
    pub client_badges: Option<String>, // TODO: CHECK TYPE
}

impl OnlineClientFull {
    pub(crate) fn from_raw(mut data: HashMap<String, Option<String>>) -> Result<Self> {
        let clid = int_val_parser(&mut data, "clid")?;
        let cid = int_val_parser(&mut data, "cid")?;
        let client_database_id = int_val_parser(&mut data, "client_database_id")?;
        let client_nickname: String = string_val_parser(&mut data, "client_nickname")?;
        let client_type = int_val_parser(&mut data, "client_type")?;

        let client_away = bool_val_parser(&mut data, "client_away")?;
        let client_away_message = string_val_parser_opt(&mut data, "client_away_message")?;
        let client_flag_talking = bool_val_parser(&mut data, "client_flag_talking")?;
        let client_input_muted = bool_val_parser(&mut data, "client_input_muted")?;
        let client_output_muted = bool_val_parser(&mut data, "client_output_muted")?;
        let client_input_hardware = bool_val_parser(&mut data, "client_input_hardware")?;
        let client_output_hardware = bool_val_parser(&mut data, "client_output_hardware")?;
        let client_talk_power = int_val_parser(&mut data, "client_talk_power")?;
        let client_is_talker = bool_val_parser(&mut data, "client_is_talker")?;
        let client_is_priority_speaker = bool_val_parser(&mut data, "client_is_priority_speaker")?;
        let client_is_recording = bool_val_parser(&mut data, "client_is_recording")?;
        let client_is_channel_commander =
            bool_val_parser(&mut data, "client_is_channel_commander")?;
        let client_unique_identifier = string_val_parser(&mut data, "client_unique_identifier")?;
        let client_servergroups = int_list_val_parser(&mut data, "client_servergroups")?;
        let client_channel_group_id = int_val_parser(&mut data, "client_channel_group_id")?;
        let client_channel_group_inherited_channel_id =
            int_val_parser(&mut data, "client_channel_group_inherited_channel_id")?;
        let client_version = string_val_parser(&mut data, "client_version")?;
        let client_platform = string_val_parser(&mut data, "client_platform")?;
        let client_idle_time = int_val_parser(&mut data, "client_idle_time")?;
        let client_created = int_val_parser(&mut data, "client_created")?;
        let client_lastconnected = int_val_parser(&mut data, "client_lastconnected")?;
        let client_country = string_val_parser(&mut data, "client_country")?;
        let connection_client_ip = string_val_parser(&mut data, "connection_client_ip")?;
        let client_badges = string_val_parser_opt(&mut data, "client_badges")?;

        Ok(OnlineClientFull {
            clid,
            cid,
            client_database_id,
            client_nickname,
            client_type,
            client_away,
            client_away_message,
            client_flag_talking,
            client_input_muted,
            client_output_muted,
            client_input_hardware,
            client_output_hardware,
            client_talk_power,
            client_is_talker,
            client_is_priority_speaker,
            client_is_recording,
            client_is_channel_commander,
            client_unique_identifier,
            client_servergroups,
            client_channel_group_id,
            client_channel_group_inherited_channel_id,
            client_version,
            client_platform,
            client_idle_time,
            client_created,
            client_lastconnected,
            client_country,
            connection_client_ip,
            client_badges,
        })
    }
}

#[derive(Debug)]
pub struct Channel {
    /// Channel ID
    pub cid: ChannelId,
    /// Channel parent, 0 for server
    pub pid: ChannelId,
    /// ID of the channel
    pub channel_order: ChannelId,
    pub channel_name: String,
    pub total_clients: i32,
    pub channel_needed_subscribe_power: i32,
}

impl Channel {
    pub(crate) fn from_raw(mut data: HashMap<String, Option<String>>) -> Result<Self> {
        let cid = int_val_parser(&mut data, "cid")?;
        let pid = int_val_parser(&mut data, "pid")?;
        let channel_order = int_val_parser(&mut data, "channel_order")?;
        let channel_name: String = string_val_parser(&mut data, "channel_name")?;
        let total_clients = int_val_parser(&mut data, "total_clients")?;
        let channel_needed_subscribe_power =
            int_val_parser(&mut data, "channel_needed_subscribe_power")?;

        Ok(Channel {
            cid,
            pid,
            channel_order,
            channel_name,
            total_clients,
            channel_needed_subscribe_power,
        })
    }
}

#[derive(Debug)]
pub struct ChannelFull {
    /// Channel ID
    pub cid: ChannelId,
    /// Channel parent
    pub pid: ChannelId,
    /// ID of the channel
    pub channel_order: ChannelId,
    pub channel_name: String,
    pub total_clients: i32,
    pub channel_needed_subscribe_power: i32,
    pub channel_topic: Option<String>,
    pub channel_flag_default: bool,
    pub channel_flag_password: bool,
    pub channel_flag_permanent: bool,
    pub channel_flag_semi_permanent: bool,
    pub channel_codec: i32,
    pub channel_codec_quality: u8,
    pub channel_needed_talk_power: i32,
    pub channel_icon_id: IconHash,
    pub seconds_empty: i64,
    pub total_clients_family: i32,
    pub channel_maxclients: i32,
    pub channel_maxfamilyclients: i32,
}

impl ChannelFull {
    pub(crate) fn from_raw(mut data: HashMap<String, Option<String>>) -> Result<Self> {
        let cid = int_val_parser(&mut data, "cid")?;
        let pid = int_val_parser(&mut data, "pid")?;
        let channel_order = int_val_parser(&mut data, "channel_order")?;
        let channel_name: String = string_val_parser(&mut data, "channel_name")?;
        let total_clients = int_val_parser(&mut data, "total_clients")?;
        let channel_needed_subscribe_power =
            int_val_parser(&mut data, "channel_needed_subscribe_power")?;

        let channel_topic = string_val_parser_opt(&mut data, "channel_topic")?;
        let channel_flag_default = bool_val_parser(&mut data, "channel_flag_default")?;
        let channel_flag_password = bool_val_parser(&mut data, "channel_flag_password")?;
        let channel_flag_permanent = bool_val_parser(&mut data, "channel_flag_permanent")?;
        let channel_flag_semi_permanent =
            bool_val_parser(&mut data, "channel_flag_semi_permanent")?;
        let channel_codec = int_val_parser(&mut data, "channel_codec")?;
        let channel_codec_quality = int_val_parser(&mut data, "channel_codec_quality")?;
        let channel_needed_talk_power = int_val_parser(&mut data, "channel_needed_talk_power")?;
        let channel_icon_id = int_val_parser(&mut data, "channel_icon_id")?;
        let seconds_empty = int_val_parser(&mut data, "seconds_empty")?;
        let total_clients_family = int_val_parser(&mut data, "total_clients_family")?;
        let channel_maxclients = int_val_parser(&mut data, "channel_maxclients")?;
        let channel_maxfamilyclients = int_val_parser(&mut data, "channel_maxfamilyclients")?;

        Ok(ChannelFull {
            cid,
            pid,
            channel_order,
            channel_name,
            total_clients,
            channel_needed_subscribe_power,
            channel_topic,
            channel_flag_default,
            channel_flag_password,
            channel_flag_permanent,
            channel_flag_semi_permanent,
            channel_codec,
            channel_codec_quality,
            channel_needed_talk_power,
            channel_icon_id,
            seconds_empty,
            total_clients_family,
            channel_maxclients,
            channel_maxfamilyclients,
        })
    }
}

/// This struct defines the values of a channel that are changeable
/// The difference to [ChannelFull] is that this does not contain values that are not changeable like
#[derive(Debug, Default)]
pub struct ChannelEdit {
    /// The channel name
    ///
    /// **Note** Has to be unique or else it might fail!
    pub channel_name: Option<String>,
    /// See [ChannelLife]
    pub channel_life: Option<ChannelLife>,
    /// The parent channel id.
    /// If set, the channel becomes a Sub-Channel
    pub pid: Option<ChannelId>,
    /// The channel after which this channel gets placed
    pub channel_order: Option<ChannelId>,
    pub channel_topic: Option<String>,
    pub channel_password: Option<String>,
    pub channel_maxclients: Option<i32>,
    pub channel_maxfamilyclients: Option<i32>,
    pub channel_flag_default: bool,
    pub channel_codec: Option<i32>,
    pub channel_codec_quality: Option<u8>,
    pub channel_needed_talk_power: Option<i32>,
    pub channel_icon_id: Option<IconHash>,
}

/// This defines when/if the channel gets automatically removed
#[derive(Debug)]
pub enum ChannelLife {
    /// Permanent channel
    Permanent,
    /// Semi-Permanent channel (gets removed after server restart)
    SemiPermanent,
    /// Temporary channel (gets removed if empty)
    Temporary,
}

impl ChannelEdit {
    pub(crate) fn to_raw(&self) -> String {
        let mut result = String::new();

        if let Some(x) = &self.channel_name {
            result += &format!(" channel_name={}", &escape_arg(x));
        }
        if let Some(x) = &self.channel_life {
            match x {
                ChannelLife::Permanent => result += &format!(" channel_flag_permanent={}", 1),
                ChannelLife::SemiPermanent => {
                    result += &format!(" channel_flag_semi_permanent={}", 1)
                }
                ChannelLife::Temporary => result += &format!(" channel_flag_temporary={}", 1),
            }
        }
        if let Some(x) = self.pid {
            result += &format!(" cpid={}", x);
        }
        if let Some(x) = self.channel_order {
            result += &format!(" channel_order={}", x);
        }
        if let Some(x) = &self.channel_topic {
            result += &format!(" channel_topic={}", &escape_arg(x));
        }
        if let Some(x) = &self.channel_password {
            result += &format!(" channel_password={}", &escape_arg(x));
        }
        if let Some(x) = self.channel_maxclients {
            result += &format!(" channel_maxclients={}", x);
        }
        if let Some(x) = self.channel_maxfamilyclients {
            result += &format!(" channel_maxfamilyclients={}", x);
        }
        if self.channel_flag_default {
            result += &format!(" channel_flag_default={}", 1);
        }
        if let Some(x) = self.channel_codec {
            result += &format!(" channel_codec={}", x);
        }
        if let Some(x) = self.channel_codec_quality {
            result += &format!(" channel_codec_quality={}", x);
        }
        if let Some(x) = self.channel_needed_talk_power {
            result += &format!(" channel_needed_talk_power={}", x);
        }
        if let Some(x) = self.channel_icon_id {
            result += &format!(" channel_icon_id={}", x);
        }

        result
    }
}

impl From<&ChannelFull> for ChannelEdit {
    fn from(c: &ChannelFull) -> Self {
        let channel_life;
        if c.channel_flag_permanent {
            channel_life = ChannelLife::Permanent;
        } else if c.channel_flag_semi_permanent {
            channel_life = ChannelLife::SemiPermanent;
        } else {
            channel_life = ChannelLife::Temporary;
        }

        Self {
            channel_name: c.channel_name.clone().into(),
            channel_life: Some(channel_life),
            pid: c.pid.into(),
            channel_order: c.channel_order.into(),
            channel_topic: c.channel_topic.clone(),
            channel_password: None,
            channel_maxclients: c.channel_maxclients.into(),
            channel_maxfamilyclients: c.channel_maxfamilyclients.into(),
            channel_flag_default: c.channel_flag_default,
            channel_codec: c.channel_codec.into(),
            channel_codec_quality: c.channel_codec_quality.into(),
            channel_needed_talk_power: c.channel_needed_talk_power.into(),
            channel_icon_id: c.channel_icon_id.into(),
        }
    }
}

impl Default for ChannelLife {
    fn default() -> Self {
        Self::Temporary
    }
}

/// Server error response
#[derive(Debug)]
pub struct ErrorResponse {
    /// Error ID
    pub id: usize,
    /// Error message
    pub msg: String,
}

impl ErrorResponse {
    // courtesy of https://yat.qa/resources/server-error-codes/
    /// Returns error name if existing
    pub fn error_name(&self) -> Option<&'static str> {
        match self.id {
            0 => Some("unknown error code"),
            1 => Some("undefined error"),
            2 => Some("not implemented"),
            5 => Some("library time limit reached"),
            256 => Some("command not found"),
            257 => Some("unable to bind network port"),
            258 => Some("no network port available"),
            512 => Some("invalid clientID"),
            513 => Some("nickname is already in use"),
            514 => Some("invalid error code"),
            515 => Some("max clients protocol limit reached"),
            516 => Some("invalid client type"),
            517 => Some("already subscribed"),
            518 => Some("not logged in"),
            519 => Some("could not validate client identity"),
            520 => Some("invalid loginname or password"),
            521 => Some("too many clones already connected"),
            522 => Some("client version outdated, please update"),
            523 => Some("client is online"),
            524 => Some("client is flooding"),
            525 => Some("client is modified"),
            526 => Some("can not verify client at this moment"),
            527 => Some("client is not permitted to log in"),
            528 => Some("client is not subscribed to the channel"),
            768 => Some("invalid channelID"),
            769 => Some("max channels protocol limit reached"),
            770 => Some("already member of channel"),
            771 => Some("channel name is already in use"),
            772 => Some("channel not empty"),
            773 => Some("can not delete default channel"),
            774 => Some("default channel requires permanent"),
            775 => Some("invalid channel flags"),
            776 => Some("permanent channel can not be child of non permanent channel"),
            777 => Some("channel maxclient reached"),
            778 => Some("channel maxfamily reached"),
            779 => Some("invalid channel order"),
            780 => Some("channel does not support filetransfers"),
            781 => Some("invalid channel password"),
            782 => Some("channel is private channel"),
            783 => Some("invalid security hash supplied by client"),
            1024 => Some("invalid serverID"),
            1025 => Some("server is running"),
            1026 => Some("server is shutting down"),
            1027 => Some("server maxclient reached"),
            1028 => Some("invalid server password"),
            1029 => Some("deployment active"),
            1030 => Some("unable to stop own server in your connection class"),
            1031 => Some("server is virtual"),
            1032 => Some("server wrong machineID"),
            1033 => Some("server is not running"),
            1034 => Some("server is booting up"),
            1035 => Some("server got an invalid status for this operation"),
            1036 => Some("server modal quit"),
            1037 => Some("server version is too old for command"),
            1040 => Some("server blacklisted"),
            1280 => Some("database error"),
            1281 => Some("database empty result set"),
            1282 => Some("database duplicate entry"),
            1283 => Some("database no modifications"),
            1284 => Some("database invalid constraint"),
            1285 => Some("database reinvoke command"),
            1536 => Some("invalid quote"),
            1537 => Some("invalid parameter count"),
            1538 => Some("invalid parameter"),
            1539 => Some("parameter not found"),
            1540 => Some("convert error"),
            1541 => Some("invalid parameter size"),
            1542 => Some("missing required parameter"),
            1543 => Some("invalid checksum"),
            1792 => Some("virtual server got a critical error"),
            1793 => Some("Connection lost"),
            1794 => Some("not connected"),
            1795 => Some("no cached connection info"),
            1796 => Some("currently not possible"),
            1797 => Some("failed connection initialization"),
            1798 => Some("could not resolve hostname"),
            1799 => Some("invalid server connection handler ID"),
            1800 => Some("could not initialize Input Manager"),
            1801 => Some("client library not initialized"),
            1802 => Some("server library not initialized"),
            1803 => Some("too many whisper targets"),
            1804 => Some("no whisper targets found"),
            2048 => Some("invalid file name"),
            2049 => Some("invalid file permissions"),
            2050 => Some("file already exists"),
            2051 => Some("file not found"),
            2052 => Some("file input/output error"),
            2053 => Some("invalid file transfer ID"),
            2054 => Some("invalid file path"),
            2055 => Some("no files available"),
            2056 => Some("overwrite excludes resume"),
            2057 => Some("invalid file size"),
            2058 => Some("file already in use"),
            2059 => Some("could not open file transfer connection"),
            2060 => Some("no space left on device (disk full?)"),
            2061 => Some("file exceeds file system's maximum file size"),
            2062 => Some("file transfer connection timeout"),
            2063 => Some("lost file transfer connection"),
            2064 => Some("file exceeds supplied file size"),
            2065 => Some("file transfer complete"),
            2066 => Some("file transfer canceled"),
            2067 => Some("file transfer interrupted"),
            2068 => Some("file transfer server quota exceeded"),
            2069 => Some("file transfer client quota exceeded"),
            2070 => Some("file transfer reset"),
            2071 => Some("file transfer limit reached"),
            2304 => Some("preprocessor disabled"),
            2305 => Some("internal preprocessor"),
            2306 => Some("internal encoder"),
            2307 => Some("internal playback"),
            2308 => Some("no capture device available"),
            2309 => Some("no playback device available"),
            2310 => Some("could not open capture device"),
            2311 => Some("could not open playback device"),
            2312 => Some("ServerConnectionHandler has a device registered"),
            2313 => Some("invalid capture device"),
            2314 => Some("invalid clayback device"),
            2315 => Some("invalid wave file"),
            2316 => Some("wave file type not supported"),
            2317 => Some("could not open wave file"),
            2318 => Some("internal capture"),
            2319 => Some("device still in use"),
            2320 => Some("device already registerred"),
            2321 => Some("device not registered/known"),
            2322 => Some("unsupported frequency"),
            2323 => Some("invalid channel count"),
            2324 => Some("read error in wave"),
            2325 => Some("sound need more data"),
            2326 => Some("sound device was busy"),
            2327 => Some("there is no sound data for this period"),
            2328 => {
                Some("Channelmask set bits count (speakers) is not the same as channel (count)")
            }
            2560 => Some("invalid group ID"),
            2561 => Some("duplicate entry"),
            2562 => Some("invalid permission ID"),
            2563 => Some("empty result set"),
            2564 => Some("access to default group is forbidden"),
            2565 => Some("invalid size"),
            2566 => Some("invalid value"),
            2567 => Some("group is not empty"),
            2568 => Some("insufficient client permissions"),
            2569 => Some("insufficient group modify power"),
            2570 => Some("insufficient permission modify power"),
            2571 => Some("template group is currently used"),
            2572 => Some("permission error"),
            2816 => Some("virtualserver limit reached"),
            2817 => Some("max slot limit reached"),
            2818 => Some("license file not found"),
            2819 => Some("license date not ok"),
            2820 => Some("unable to connect to accounting server"),
            2821 => Some("unknown accounting error"),
            2822 => Some("accounting server error"),
            2823 => Some("instance limit reached"),
            2824 => Some("instance check error"),
            2825 => Some("license file invalid"),
            2826 => Some("virtualserver is running elsewhere"),
            2827 => Some("virtualserver running in same instance already"),
            2828 => Some("virtualserver already started"),
            2829 => Some("virtualserver not started"),
            3072 => Some("invalid message id"),
            3328 => Some("invalid ban id"),
            3329 => Some("connection failed, you are banned"),
            3330 => Some("rename failed, new name is banned"),
            3331 => Some("flood ban"),
            3584 => Some("unable to initialize tts"),
            3840 => Some("invalid privilege key"),
            4352 => Some("invalid password"),
            4353 => Some("invalid request"),
            4354 => Some("no (more) slots available"),
            4355 => Some("pool missing"),
            4356 => Some("pool unknown"),
            4357 => Some("unknown ip location (perhaps LAN ip?)"),
            4358 => Some("internal error (tried exceeded)"),
            4359 => Some("too many slots requested"),
            4360 => Some("too many reserved"),
            4361 => Some("could not connect to provisioning server"),
            4368 => Some("authentication server not connected"),
            4369 => Some("authentication data too large"),
            4370 => Some("already initialized"),
            4371 => Some("not initialized"),
            4372 => Some("already connecting"),
            4373 => Some("already connected"),
            4375 => Some("io_error"),
            _ => None,
        }
    }
}

impl std::fmt::Display for ErrorResponse {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        if let Some(descr) = self.error_name() {
            writeln!(f, "Error {}: {}, msg: {}", self.id, descr, self.msg)
        } else {
            writeln!(f, "Unknown Error code {}, msg: {}", self.id, self.msg)
        }
    }
}