use super::message_ops::Sealed;
use super::{Message, MessageKind, MessageOps, OptionKind};
use crate::bus_listener::BusEvent;
use crate::ids::{BusListenerCookie, ObjectId, ServiceId};
use crate::message_deserializer::{MessageDeserializeError, MessageWithoutValueDeserializer};
use crate::message_serializer::{MessageSerializeError, MessageSerializer};
use crate::serialized_value::SerializedValueSlice;
use bytes::BytesMut;
use num_enum::{IntoPrimitive, TryFromPrimitive};

#[derive(Debug, Copy, Clone, PartialEq, Eq)]
#[cfg_attr(feature = "fuzzing", derive(arbitrary::Arbitrary))]
pub struct EmitBusEvent {
    pub cookie: Option<BusListenerCookie>,
    pub event: BusEvent,
}

impl MessageOps for EmitBusEvent {
    fn kind(&self) -> MessageKind {
        MessageKind::EmitBusEvent
    }

    fn serialize_message(self) -> Result<BytesMut, MessageSerializeError> {
        let mut serializer = MessageSerializer::without_value(MessageKind::EmitBusEvent);

        match self.cookie {
            Some(cookie) => {
                serializer.put_discriminant_u8(OptionKind::Some);
                serializer.put_uuid(cookie.0);
            }

            None => serializer.put_discriminant_u8(OptionKind::None),
        }

        match self.event {
            BusEvent::ObjectCreated(object) => {
                serializer.put_discriminant_u8(BusEventKind::ObjectCreated);
                serializer.put_uuid(object.uuid.0);
                serializer.put_uuid(object.cookie.0);
            }

            BusEvent::ObjectDestroyed(object) => {
                serializer.put_discriminant_u8(BusEventKind::ObjectDestroyed);
                serializer.put_uuid(object.uuid.0);
                serializer.put_uuid(object.cookie.0);
            }

            BusEvent::ServiceCreated(service) => {
                serializer.put_discriminant_u8(BusEventKind::ServiceCreated);
                serializer.put_uuid(service.object_id.uuid.0);
                serializer.put_uuid(service.object_id.cookie.0);
                serializer.put_uuid(service.uuid.0);
                serializer.put_uuid(service.cookie.0);
            }

            BusEvent::ServiceDestroyed(service) => {
                serializer.put_discriminant_u8(BusEventKind::ServiceDestroyed);
                serializer.put_uuid(service.object_id.uuid.0);
                serializer.put_uuid(service.object_id.cookie.0);
                serializer.put_uuid(service.uuid.0);
                serializer.put_uuid(service.cookie.0);
            }
        }

        serializer.finish()
    }

    fn deserialize_message(buf: BytesMut) -> Result<Self, MessageDeserializeError> {
        let mut deserializer =
            MessageWithoutValueDeserializer::new(buf, MessageKind::EmitBusEvent)?;

        let cookie = match deserializer.try_get_discriminant_u8()? {
            OptionKind::Some => deserializer
                .try_get_uuid()
                .map(BusListenerCookie::from)
                .map(Some)?,

            OptionKind::None => None,
        };

        let event = match deserializer.try_get_discriminant_u8()? {
            BusEventKind::ObjectCreated => {
                let object_uuid = deserializer.try_get_uuid()?.into();
                let object_cookie = deserializer.try_get_uuid()?.into();

                BusEvent::ObjectCreated(ObjectId::new(object_uuid, object_cookie))
            }

            BusEventKind::ObjectDestroyed => {
                let object_uuid = deserializer.try_get_uuid()?.into();
                let object_cookie = deserializer.try_get_uuid()?.into();

                BusEvent::ObjectDestroyed(ObjectId::new(object_uuid, object_cookie))
            }

            BusEventKind::ServiceCreated => {
                let object_uuid = deserializer.try_get_uuid()?.into();
                let object_cookie = deserializer.try_get_uuid()?.into();
                let service_uuid = deserializer.try_get_uuid()?.into();
                let service_cookie = deserializer.try_get_uuid()?.into();

                BusEvent::ServiceCreated(ServiceId::new(
                    ObjectId::new(object_uuid, object_cookie),
                    service_uuid,
                    service_cookie,
                ))
            }

            BusEventKind::ServiceDestroyed => {
                let object_uuid = deserializer.try_get_uuid()?.into();
                let object_cookie = deserializer.try_get_uuid()?.into();
                let service_uuid = deserializer.try_get_uuid()?.into();
                let service_cookie = deserializer.try_get_uuid()?.into();

                BusEvent::ServiceDestroyed(ServiceId::new(
                    ObjectId::new(object_uuid, object_cookie),
                    service_uuid,
                    service_cookie,
                ))
            }
        };

        deserializer.finish()?;

        Ok(Self { cookie, event })
    }

    fn value(&self) -> Option<&SerializedValueSlice> {
        None
    }
}

impl Sealed for EmitBusEvent {}

impl From<EmitBusEvent> for Message {
    fn from(msg: EmitBusEvent) -> Self {
        Self::EmitBusEvent(msg)
    }
}

#[cfg(test)]
mod test {
    use super::super::test::{assert_deserialize_eq, assert_serialize_eq};
    use super::super::Message;
    use super::EmitBusEvent;
    use crate::bus_listener::BusEvent;
    use crate::ids::{BusListenerCookie, ObjectId, ServiceId};
    use uuid::uuid;

    #[test]
    fn object_created_without_cookie() {
        let serialized = [
            39, 0, 0, 0, 44, 0, 0, 0x3f, 0x5e, 0xb6, 0x03, 0xce, 0x4b, 0x4c, 0x48, 0xbc, 0x5e,
            0x90, 0x90, 0x7f, 0x55, 0xab, 0x8a, 0x03, 0xdb, 0xbf, 0xa4, 0x44, 0x76, 0x49, 0x30,
            0xa4, 0xd7, 0x28, 0x32, 0x6e, 0xfd, 0x7f, 0xc7,
        ];

        let msg = EmitBusEvent {
            cookie: None,
            event: BusEvent::ObjectCreated(ObjectId::new(
                uuid!("3f5eb603-ce4b-4c48-bc5e-90907f55ab8a").into(),
                uuid!("03dbbfa4-4476-4930-a4d7-28326efd7fc7").into(),
            )),
        };
        assert_serialize_eq(&msg, serialized);
        assert_deserialize_eq(&msg, serialized);

        let msg = Message::EmitBusEvent(msg);
        assert_serialize_eq(&msg, serialized);
        assert_deserialize_eq(&msg, serialized);
    }

    #[test]
    fn object_destroyed_without_cookie() {
        let serialized = [
            39, 0, 0, 0, 44, 0, 1, 0x3f, 0x5e, 0xb6, 0x03, 0xce, 0x4b, 0x4c, 0x48, 0xbc, 0x5e,
            0x90, 0x90, 0x7f, 0x55, 0xab, 0x8a, 0x03, 0xdb, 0xbf, 0xa4, 0x44, 0x76, 0x49, 0x30,
            0xa4, 0xd7, 0x28, 0x32, 0x6e, 0xfd, 0x7f, 0xc7,
        ];

        let msg = EmitBusEvent {
            cookie: None,
            event: BusEvent::ObjectDestroyed(ObjectId::new(
                uuid!("3f5eb603-ce4b-4c48-bc5e-90907f55ab8a").into(),
                uuid!("03dbbfa4-4476-4930-a4d7-28326efd7fc7").into(),
            )),
        };
        assert_serialize_eq(&msg, serialized);
        assert_deserialize_eq(&msg, serialized);

        let msg = Message::EmitBusEvent(msg);
        assert_serialize_eq(&msg, serialized);
        assert_deserialize_eq(&msg, serialized);
    }

    #[test]
    fn service_created_without_cookie() {
        let serialized = [
            71, 0, 0, 0, 44, 0, 2, 0x3f, 0x5e, 0xb6, 0x03, 0xce, 0x4b, 0x4c, 0x48, 0xbc, 0x5e,
            0x90, 0x90, 0x7f, 0x55, 0xab, 0x8a, 0x03, 0xdb, 0xbf, 0xa4, 0x44, 0x76, 0x49, 0x30,
            0xa4, 0xd7, 0x28, 0x32, 0x6e, 0xfd, 0x7f, 0xc7, 0xaf, 0xfc, 0xb7, 0x9b, 0xe9, 0x9c,
            0x47, 0x84, 0x95, 0xe0, 0x0d, 0xc9, 0x9f, 0xcb, 0xa8, 0xff, 0x37, 0x22, 0x74, 0x6e,
            0x76, 0xa8, 0x41, 0x31, 0x98, 0x32, 0x42, 0xc4, 0x78, 0x3f, 0x89, 0x97,
        ];

        let msg = EmitBusEvent {
            cookie: None,
            event: BusEvent::ServiceCreated(ServiceId::new(
                ObjectId::new(
                    uuid!("3f5eb603-ce4b-4c48-bc5e-90907f55ab8a").into(),
                    uuid!("03dbbfa4-4476-4930-a4d7-28326efd7fc7").into(),
                ),
                uuid!("affcb79b-e99c-4784-95e0-0dc99fcba8ff").into(),
                uuid!("3722746e-76a8-4131-9832-42c4783f8997").into(),
            )),
        };
        assert_serialize_eq(&msg, serialized);
        assert_deserialize_eq(&msg, serialized);

        let msg = Message::EmitBusEvent(msg);
        assert_serialize_eq(&msg, serialized);
        assert_deserialize_eq(&msg, serialized);
    }

    #[test]
    fn service_destroyed_without_cookie() {
        let serialized = [
            71, 0, 0, 0, 44, 0, 3, 0x3f, 0x5e, 0xb6, 0x03, 0xce, 0x4b, 0x4c, 0x48, 0xbc, 0x5e,
            0x90, 0x90, 0x7f, 0x55, 0xab, 0x8a, 0x03, 0xdb, 0xbf, 0xa4, 0x44, 0x76, 0x49, 0x30,
            0xa4, 0xd7, 0x28, 0x32, 0x6e, 0xfd, 0x7f, 0xc7, 0xaf, 0xfc, 0xb7, 0x9b, 0xe9, 0x9c,
            0x47, 0x84, 0x95, 0xe0, 0x0d, 0xc9, 0x9f, 0xcb, 0xa8, 0xff, 0x37, 0x22, 0x74, 0x6e,
            0x76, 0xa8, 0x41, 0x31, 0x98, 0x32, 0x42, 0xc4, 0x78, 0x3f, 0x89, 0x97,
        ];

        let msg = EmitBusEvent {
            cookie: None,
            event: BusEvent::ServiceDestroyed(ServiceId::new(
                ObjectId::new(
                    uuid!("3f5eb603-ce4b-4c48-bc5e-90907f55ab8a").into(),
                    uuid!("03dbbfa4-4476-4930-a4d7-28326efd7fc7").into(),
                ),
                uuid!("affcb79b-e99c-4784-95e0-0dc99fcba8ff").into(),
                uuid!("3722746e-76a8-4131-9832-42c4783f8997").into(),
            )),
        };
        assert_serialize_eq(&msg, serialized);
        assert_deserialize_eq(&msg, serialized);

        let msg = Message::EmitBusEvent(msg);
        assert_serialize_eq(&msg, serialized);
        assert_deserialize_eq(&msg, serialized);
    }

    #[test]
    fn object_created_with_cookie() {
        let serialized = [
            55, 0, 0, 0, 44, 1, 0xb6, 0x6c, 0x03, 0x07, 0x85, 0xcf, 0x4a, 0x7c, 0x8a, 0xcf, 0x6e,
            0x99, 0xd0, 0xf4, 0x07, 0xb7, 0, 0x3f, 0x5e, 0xb6, 0x03, 0xce, 0x4b, 0x4c, 0x48, 0xbc,
            0x5e, 0x90, 0x90, 0x7f, 0x55, 0xab, 0x8a, 0x03, 0xdb, 0xbf, 0xa4, 0x44, 0x76, 0x49,
            0x30, 0xa4, 0xd7, 0x28, 0x32, 0x6e, 0xfd, 0x7f, 0xc7,
        ];

        let msg = EmitBusEvent {
            cookie: Some(BusListenerCookie(uuid!(
                "b66c0307-85cf-4a7c-8acf-6e99d0f407b7"
            ))),
            event: BusEvent::ObjectCreated(ObjectId::new(
                uuid!("3f5eb603-ce4b-4c48-bc5e-90907f55ab8a").into(),
                uuid!("03dbbfa4-4476-4930-a4d7-28326efd7fc7").into(),
            )),
        };
        assert_serialize_eq(&msg, serialized);
        assert_deserialize_eq(&msg, serialized);

        let msg = Message::EmitBusEvent(msg);
        assert_serialize_eq(&msg, serialized);
        assert_deserialize_eq(&msg, serialized);
    }

    #[test]
    fn object_destroyed_with_cookie() {
        let serialized = [
            55, 0, 0, 0, 44, 1, 0xb6, 0x6c, 0x03, 0x07, 0x85, 0xcf, 0x4a, 0x7c, 0x8a, 0xcf, 0x6e,
            0x99, 0xd0, 0xf4, 0x07, 0xb7, 1, 0x3f, 0x5e, 0xb6, 0x03, 0xce, 0x4b, 0x4c, 0x48, 0xbc,
            0x5e, 0x90, 0x90, 0x7f, 0x55, 0xab, 0x8a, 0x03, 0xdb, 0xbf, 0xa4, 0x44, 0x76, 0x49,
            0x30, 0xa4, 0xd7, 0x28, 0x32, 0x6e, 0xfd, 0x7f, 0xc7,
        ];

        let msg = EmitBusEvent {
            cookie: Some(BusListenerCookie(uuid!(
                "b66c0307-85cf-4a7c-8acf-6e99d0f407b7"
            ))),
            event: BusEvent::ObjectDestroyed(ObjectId::new(
                uuid!("3f5eb603-ce4b-4c48-bc5e-90907f55ab8a").into(),
                uuid!("03dbbfa4-4476-4930-a4d7-28326efd7fc7").into(),
            )),
        };
        assert_serialize_eq(&msg, serialized);
        assert_deserialize_eq(&msg, serialized);

        let msg = Message::EmitBusEvent(msg);
        assert_serialize_eq(&msg, serialized);
        assert_deserialize_eq(&msg, serialized);
    }

    #[test]
    fn service_created_with_cookie() {
        let serialized = [
            87, 0, 0, 0, 44, 1, 0xb6, 0x6c, 0x03, 0x07, 0x85, 0xcf, 0x4a, 0x7c, 0x8a, 0xcf, 0x6e,
            0x99, 0xd0, 0xf4, 0x07, 0xb7, 2, 0x3f, 0x5e, 0xb6, 0x03, 0xce, 0x4b, 0x4c, 0x48, 0xbc,
            0x5e, 0x90, 0x90, 0x7f, 0x55, 0xab, 0x8a, 0x03, 0xdb, 0xbf, 0xa4, 0x44, 0x76, 0x49,
            0x30, 0xa4, 0xd7, 0x28, 0x32, 0x6e, 0xfd, 0x7f, 0xc7, 0xaf, 0xfc, 0xb7, 0x9b, 0xe9,
            0x9c, 0x47, 0x84, 0x95, 0xe0, 0x0d, 0xc9, 0x9f, 0xcb, 0xa8, 0xff, 0x37, 0x22, 0x74,
            0x6e, 0x76, 0xa8, 0x41, 0x31, 0x98, 0x32, 0x42, 0xc4, 0x78, 0x3f, 0x89, 0x97,
        ];

        let msg = EmitBusEvent {
            cookie: Some(BusListenerCookie(uuid!(
                "b66c0307-85cf-4a7c-8acf-6e99d0f407b7"
            ))),
            event: BusEvent::ServiceCreated(ServiceId::new(
                ObjectId::new(
                    uuid!("3f5eb603-ce4b-4c48-bc5e-90907f55ab8a").into(),
                    uuid!("03dbbfa4-4476-4930-a4d7-28326efd7fc7").into(),
                ),
                uuid!("affcb79b-e99c-4784-95e0-0dc99fcba8ff").into(),
                uuid!("3722746e-76a8-4131-9832-42c4783f8997").into(),
            )),
        };
        assert_serialize_eq(&msg, serialized);
        assert_deserialize_eq(&msg, serialized);

        let msg = Message::EmitBusEvent(msg);
        assert_serialize_eq(&msg, serialized);
        assert_deserialize_eq(&msg, serialized);
    }

    #[test]
    fn service_destroyed_with_cookie() {
        let serialized = [
            87, 0, 0, 0, 44, 1, 0xb6, 0x6c, 0x03, 0x07, 0x85, 0xcf, 0x4a, 0x7c, 0x8a, 0xcf, 0x6e,
            0x99, 0xd0, 0xf4, 0x07, 0xb7, 3, 0x3f, 0x5e, 0xb6, 0x03, 0xce, 0x4b, 0x4c, 0x48, 0xbc,
            0x5e, 0x90, 0x90, 0x7f, 0x55, 0xab, 0x8a, 0x03, 0xdb, 0xbf, 0xa4, 0x44, 0x76, 0x49,
            0x30, 0xa4, 0xd7, 0x28, 0x32, 0x6e, 0xfd, 0x7f, 0xc7, 0xaf, 0xfc, 0xb7, 0x9b, 0xe9,
            0x9c, 0x47, 0x84, 0x95, 0xe0, 0x0d, 0xc9, 0x9f, 0xcb, 0xa8, 0xff, 0x37, 0x22, 0x74,
            0x6e, 0x76, 0xa8, 0x41, 0x31, 0x98, 0x32, 0x42, 0xc4, 0x78, 0x3f, 0x89, 0x97,
        ];

        let msg = EmitBusEvent {
            cookie: Some(BusListenerCookie(uuid!(
                "b66c0307-85cf-4a7c-8acf-6e99d0f407b7"
            ))),
            event: BusEvent::ServiceDestroyed(ServiceId::new(
                ObjectId::new(
                    uuid!("3f5eb603-ce4b-4c48-bc5e-90907f55ab8a").into(),
                    uuid!("03dbbfa4-4476-4930-a4d7-28326efd7fc7").into(),
                ),
                uuid!("affcb79b-e99c-4784-95e0-0dc99fcba8ff").into(),
                uuid!("3722746e-76a8-4131-9832-42c4783f8997").into(),
            )),
        };
        assert_serialize_eq(&msg, serialized);
        assert_deserialize_eq(&msg, serialized);

        let msg = Message::EmitBusEvent(msg);
        assert_serialize_eq(&msg, serialized);
        assert_deserialize_eq(&msg, serialized);
    }
}

#[derive(Debug, Copy, Clone, PartialEq, Eq, IntoPrimitive, TryFromPrimitive)]
#[repr(u8)]
enum BusEventKind {
    ObjectCreated = 0,
    ObjectDestroyed = 1,
    ServiceCreated = 2,
    ServiceDestroyed = 3,
}