/*! Top-level Messenger Packets
*/

use tox_binary_io::*;

mod conference;
mod file_transfer;

mod online;
mod action;
mod offline;
mod message;
mod nickname;
mod msi;
mod typing;
mod user_status;
mod status_message;

pub use self::online::*;
pub use self::action::*;
pub use self::offline::*;
pub use self::message::*;
pub use self::nickname::*;
pub use self::msi::*;
pub use self::typing::*;
pub use self::user_status::*;
pub use self::status_message::*;

pub use crate::messenger::conference::Packet as ConferencePacket;
pub use crate::messenger::file_transfer::Packet as FileTransferPacket;

use nom::{
    named,
    do_parse,
    tag,
    call,
    alt,
    map,
    map_res,
    many_till,
    switch,
    value,
    verify,
};

use cookie_factory::{
    do_gen,
    gen_slice,
    gen_call,
    gen_cond,
    gen_be_u8,
    gen_le_u8,
};

/** Messenger packet enum that encapsulates all types of Messenger packets.
*/
#[derive(Clone, Debug, Eq, PartialEq)]
pub enum Packet {
    /// [`Online`](./struct.Online.html) structure.
    Online(Online),
    /// [`Action`](./struct.Action.html) structure.
    Action(Action),
    /// [`Offline`](./struct.Offline.html) structure.
    Offline(Offline),
    /// [`Message`](./struct.Message.html) structure.
    Message(Message),
    /// [`Nickname`](./struct.Nickname.html) structure.
    Nickname(Nickname),
    /// [`UserStatus`](./struct.UserStatus.html) structure.
    UserStatus(UserStatus),
    /// [`Typing`](./struct.Typing.html) structure.
    Typing(Typing),
    /// [`StatusMessage`](./struct.StatusMessage.html) structure.
    StatusMessage(StatusMessage),
    /// [`Msi`](./struct.Msi.html) structure.
    Msi(Msi),
    /// Packets of conference.
    Conference(ConferencePacket),
    /// Packets of file transfer.
    FileTransfer(FileTransferPacket),
}

impl ToBytes for Packet {
    fn to_bytes<'a>(&self, buf: (&'a mut [u8], usize)) -> Result<(&'a mut [u8], usize), GenError> {
        match *self {
            Packet::Online(ref p) => p.to_bytes(buf),
            Packet::Action(ref p) => p.to_bytes(buf),
            Packet::Offline(ref p) => p.to_bytes(buf),
            Packet::Message(ref p) => p.to_bytes(buf),
            Packet::Nickname(ref p) => p.to_bytes(buf),
            Packet::UserStatus(ref p) => p.to_bytes(buf),
            Packet::Typing(ref p) => p.to_bytes(buf),
            Packet::Msi(ref p) => p.to_bytes(buf),
            Packet::StatusMessage(ref p) => p.to_bytes(buf),
            Packet::Conference(ref p) => p.to_bytes(buf),
            Packet::FileTransfer(ref p) => p.to_bytes(buf),
        }
    }
}

impl FromBytes for Packet {
    named!(from_bytes<Packet>, alt!(
        map!(Online::from_bytes, Packet::Online) |
        map!(Action::from_bytes, Packet::Action) |
        map!(Offline::from_bytes, Packet::Offline) |
        map!(Nickname::from_bytes, Packet::Nickname) |
        map!(Message::from_bytes, Packet::Message) |
        map!(UserStatus::from_bytes, Packet::UserStatus) |
        map!(Msi::from_bytes, Packet::Msi) |
        map!(StatusMessage::from_bytes, Packet::StatusMessage) |
        map!(Typing::from_bytes, Packet::Typing) |
        map!(ConferencePacket::from_bytes, Packet::Conference) |
        map!(FileTransferPacket::from_bytes, Packet::FileTransfer)
    ));
}

#[cfg(test)]
mod tests {
    use super::*;
    use crate::messenger::conference::{ConferenceType, ConferenceUID, Invite};
    use crate::messenger::file_transfer::{FileControl, TransferDirection, ControlType};

    encode_decode_test!(
        tox_crypto::crypto_init().unwrap(),
        packet_online_encode_decode,
        Packet::Online(Online)
    );

    encode_decode_test!(
        tox_crypto::crypto_init().unwrap(),
        packet_action_encode_decode,
        Packet::Action(Action::new("1234".to_string()))
    );

    encode_decode_test!(
        tox_crypto::crypto_init().unwrap(),
        packet_offline_encode_decode,
        Packet::Offline(Offline)
    );

    encode_decode_test!(
        tox_crypto::crypto_init().unwrap(),
        packet_message_encode_decode,
        Packet::Message(Message::new("1234".to_string()))
    );

    encode_decode_test!(
        tox_crypto::crypto_init().unwrap(),
        packet_nickname_encode_decode,
        Packet::Nickname(Nickname::new("1234".to_string()))
    );

    encode_decode_test!(
        tox_crypto::crypto_init().unwrap(),
        packet_user_status_encode_decode,
        Packet::UserStatus(UserStatus::new(PeerStatus::Busy))
    );

    encode_decode_test!(
        tox_crypto::crypto_init().unwrap(),
        packet_typing_encode_decode,
        Packet::Typing(Typing::new(TypingStatus::NotTyping))
    );

    // FIXME: uncomment
    // encode_decode_test!(
    //     packet_msi_encode_decode,
    //     Packet::Msi(Msi::new(RequestKind::Init, None, CapabilitiesKind::SEND_AUDIO))
    // );

    encode_decode_test!(
        tox_crypto::crypto_init().unwrap(),
        packet_status_message_encode_decode,
        Packet::StatusMessage(StatusMessage::new("1234".to_string()))
    );

    encode_decode_test!(
        tox_crypto::crypto_init().unwrap(),
        packet_conference_encode_decode,
        Packet::Conference(ConferencePacket::Invite(Invite::new(1, ConferenceType::Text, ConferenceUID::random())))
    );

    encode_decode_test!(
        tox_crypto::crypto_init().unwrap(),
        packet_file_transfer_encode_decode,
        Packet::FileTransfer(FileTransferPacket::FileControl(FileControl::new(TransferDirection::Send, 1, ControlType::Seek(100))))
    );
}