fn test_message_id_conversion()

in sdk/core/azure_core_amqp/src/fe2o3/messaging/message_fields.rs [53:122]


fn test_message_id_conversion() {
    use azure_core::Uuid;
    {
        let message_id = fe2o3_amqp_types::messaging::MessageId::String("test".into());
        let amqp_message_id: AmqpMessageId = message_id.clone().into();
        assert_eq!(amqp_message_id, AmqpMessageId::String("test".into()));
        let fe2o3_message_id: fe2o3_amqp_types::messaging::MessageId = amqp_message_id.into();
        assert_eq!(fe2o3_message_id, message_id);
    }

    {
        let uuid = Uuid::new_v4();
        let message_id = fe2o3_amqp_types::messaging::MessageId::Uuid(uuid.into());
        let amqp_message_id: AmqpMessageId = message_id.clone().into();
        assert_eq!(amqp_message_id, AmqpMessageId::from(uuid));

        let fe2o3_message_id: fe2o3_amqp_types::messaging::MessageId = amqp_message_id.into();
        assert_eq!(fe2o3_message_id, message_id);
    }

    {
        let message_id = fe2o3_amqp_types::messaging::MessageId::Binary(vec![1, 2, 3].into());
        let amqp_message_id: AmqpMessageId = message_id.clone().into();
        assert_eq!(amqp_message_id, AmqpMessageId::Binary(vec![1, 2, 3]));
        let fe2o3_message_id: fe2o3_amqp_types::messaging::MessageId = amqp_message_id.into();
        assert_eq!(fe2o3_message_id, message_id);
    }

    {
        let message_id = fe2o3_amqp_types::messaging::MessageId::Ulong(1);
        let amqp_message_id: AmqpMessageId = message_id.clone().into();
        assert_eq!(amqp_message_id, AmqpMessageId::Ulong(1));
        let fe2o3_message_id: fe2o3_amqp_types::messaging::MessageId = amqp_message_id.into();
        assert_eq!(fe2o3_message_id, message_id);
    }

    {
        let amqp_message_id = AmqpMessageId::String("test".into());
        let message_id: fe2o3_amqp_types::messaging::MessageId = amqp_message_id.clone().into();
        assert_eq!(
            message_id,
            fe2o3_amqp_types::messaging::MessageId::String("test".into())
        );
        let amqp_round_trip: AmqpMessageId = message_id.into();
        assert_eq!(amqp_round_trip, amqp_message_id);
    }
    {
        let uuid = Uuid::new_v4();
        let amqp_message_id = AmqpMessageId::from(uuid);
        let message_id: fe2o3_amqp_types::messaging::MessageId = amqp_message_id.clone().into();
        assert_eq!(
            message_id,
            fe2o3_amqp_types::messaging::MessageId::Uuid(fe2o3_amqp_types::primitives::Uuid::from(
                uuid
            ))
        );
        let amqp_round_trip: AmqpMessageId = message_id.into();
        assert_eq!(amqp_round_trip, amqp_message_id);
    }
    {
        let amqp_message_id = AmqpMessageId::Binary(vec![1, 2, 3]);
        let message_id: fe2o3_amqp_types::messaging::MessageId = amqp_message_id.clone().into();
        assert_eq!(
            message_id,
            fe2o3_amqp_types::messaging::MessageId::Binary(vec![1, 2, 3].into())
        );
        let amqp_round_trip: AmqpMessageId = message_id.into();
        assert_eq!(amqp_round_trip, amqp_message_id);
    }
}