Microsoft Azure IoTHub client AMQP transport
Dependents: sht15_remote_monitoring RobotArmDemo iothub_client_sample_amqp iothub_client_sample_amqp ... more
This library implements the AMQP transport for Microsoft Azure IoTHub client. The code is replicated from https://github.com/Azure/azure-iot-sdks
uamqp_messaging.c@34:51d158b409d2, 2017-05-08 (annotated)
- Committer:
- AzureIoTClient
- Date:
- Mon May 08 10:49:54 2017 -0700
- Revision:
- 34:51d158b409d2
- Parent:
- 29:7e8852b14e3b
- Child:
- 40:e79ee1341949
1.1.14
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
AzureIoTClient | 23:2c6779675a01 | 1 | // Copyright (c) Microsoft. All rights reserved. |
AzureIoTClient | 23:2c6779675a01 | 2 | // Licensed under the MIT license. See LICENSE file in the project root for full license information. |
AzureIoTClient | 23:2c6779675a01 | 3 | #include <stdlib.h> |
AzureIoTClient | 23:2c6779675a01 | 4 | #include "uamqp_messaging.h" |
AzureIoTClient | 29:7e8852b14e3b | 5 | #include "azure_c_shared_utility/optimize_size.h" |
AzureIoTClient | 23:2c6779675a01 | 6 | #include "azure_c_shared_utility/xlogging.h" |
AzureIoTClient | 23:2c6779675a01 | 7 | #include "azure_uamqp_c/message.h" |
AzureIoTClient | 23:2c6779675a01 | 8 | #include "azure_uamqp_c/amqpvalue.h" |
AzureIoTClient | 23:2c6779675a01 | 9 | #include "iothub_message.h" |
AzureIoTClient | 23:2c6779675a01 | 10 | #ifndef RESULT_OK |
AzureIoTClient | 23:2c6779675a01 | 11 | #define RESULT_OK 0 |
AzureIoTClient | 23:2c6779675a01 | 12 | #endif |
AzureIoTClient | 23:2c6779675a01 | 13 | |
AzureIoTClient | 23:2c6779675a01 | 14 | static int addPropertiesTouAMQPMessage(IOTHUB_MESSAGE_HANDLE iothub_message_handle, MESSAGE_HANDLE uamqp_message) |
AzureIoTClient | 23:2c6779675a01 | 15 | { |
AzureIoTClient | 23:2c6779675a01 | 16 | int result = RESULT_OK; |
AzureIoTClient | 23:2c6779675a01 | 17 | const char* messageId; |
AzureIoTClient | 23:2c6779675a01 | 18 | const char* correlationId; |
AzureIoTClient | 23:2c6779675a01 | 19 | PROPERTIES_HANDLE uamqp_message_properties = NULL; |
AzureIoTClient | 23:2c6779675a01 | 20 | int api_call_result; |
AzureIoTClient | 23:2c6779675a01 | 21 | |
AzureIoTClient | 23:2c6779675a01 | 22 | // Codes_SRS_UAMQP_MESSAGING_09_060: [The uAMQP message properties shall be retrieved using message_get_properties().] |
AzureIoTClient | 23:2c6779675a01 | 23 | if ((api_call_result = message_get_properties(uamqp_message, &uamqp_message_properties)) != 0) |
AzureIoTClient | 23:2c6779675a01 | 24 | { |
AzureIoTClient | 23:2c6779675a01 | 25 | // Codes_SRS_UAMQP_MESSAGING_09_061: [If message_get_properties() fails, message_create_from_iothub_message() shall fail and return immediately.] |
AzureIoTClient | 23:2c6779675a01 | 26 | LogError("Failed to get properties map from uAMQP message (error code %d).", api_call_result); |
AzureIoTClient | 29:7e8852b14e3b | 27 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 28 | } |
AzureIoTClient | 23:2c6779675a01 | 29 | // Codes_SRS_UAMQP_MESSAGING_09_062: [If UAMQP message properties were not present then a new properties container shall be created using properties_create()] |
AzureIoTClient | 23:2c6779675a01 | 30 | else if (uamqp_message_properties == NULL && |
AzureIoTClient | 23:2c6779675a01 | 31 | (uamqp_message_properties = properties_create()) == NULL) |
AzureIoTClient | 23:2c6779675a01 | 32 | { |
AzureIoTClient | 23:2c6779675a01 | 33 | // Codes_SRS_UAMQP_MESSAGING_09_063: [If properties_create() fails, message_create_from_iothub_message() shall fail and return immediately.] |
AzureIoTClient | 23:2c6779675a01 | 34 | LogError("Failed to create properties map for uAMQP message (error code %d).", api_call_result); |
AzureIoTClient | 29:7e8852b14e3b | 35 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 36 | } |
AzureIoTClient | 23:2c6779675a01 | 37 | else |
AzureIoTClient | 23:2c6779675a01 | 38 | { |
AzureIoTClient | 23:2c6779675a01 | 39 | // Codes_SRS_UAMQP_MESSAGING_09_064: [Message-id from the IOTHUB_MESSAGE shall be read using IoTHubMessage_GetMessageId()] |
AzureIoTClient | 23:2c6779675a01 | 40 | // Codes_SRS_UAMQP_MESSAGING_09_065: [As message-id is optional field, if it is not set on the IOTHUB_MESSAGE, message_create_from_iothub_message() shall ignore it and continue normally.] |
AzureIoTClient | 23:2c6779675a01 | 41 | if ((messageId = IoTHubMessage_GetMessageId(iothub_message_handle)) != NULL) |
AzureIoTClient | 23:2c6779675a01 | 42 | { |
AzureIoTClient | 23:2c6779675a01 | 43 | // Codes_SRS_UAMQP_MESSAGING_09_066: [The message-id value shall be stored on a AMQP_VALUE using amqpvalue_create_string()] |
AzureIoTClient | 23:2c6779675a01 | 44 | AMQP_VALUE uamqp_message_id; |
AzureIoTClient | 23:2c6779675a01 | 45 | if ((uamqp_message_id = amqpvalue_create_string(messageId)) == NULL) |
AzureIoTClient | 23:2c6779675a01 | 46 | { |
AzureIoTClient | 23:2c6779675a01 | 47 | // Codes_SRS_UAMQP_MESSAGING_09_067: [If amqpvalue_create_string() fails, message_create_from_iothub_message() shall fail and return immediately.] |
AzureIoTClient | 23:2c6779675a01 | 48 | LogError("Failed to create an AMQP_VALUE for the messageId property value."); |
AzureIoTClient | 29:7e8852b14e3b | 49 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 50 | } |
AzureIoTClient | 23:2c6779675a01 | 51 | else |
AzureIoTClient | 23:2c6779675a01 | 52 | { |
AzureIoTClient | 23:2c6779675a01 | 53 | // Codes_SRS_UAMQP_MESSAGING_09_068: [The message-id AMQP_VALUE shall be set on the uAMQP message using properties_set_message_id()] |
AzureIoTClient | 23:2c6779675a01 | 54 | if ((api_call_result = properties_set_message_id(uamqp_message_properties, uamqp_message_id)) != 0) |
AzureIoTClient | 23:2c6779675a01 | 55 | { |
AzureIoTClient | 23:2c6779675a01 | 56 | // Codes_SRS_UAMQP_MESSAGING_09_069: [If properties_set_message_id() fails, message_create_from_iothub_message() shall fail and return immediately.] |
AzureIoTClient | 23:2c6779675a01 | 57 | LogInfo("Failed to set value of uAMQP message 'message-id' property (%d).", api_call_result); |
AzureIoTClient | 29:7e8852b14e3b | 58 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 59 | } |
AzureIoTClient | 23:2c6779675a01 | 60 | // Codes_SRS_UAMQP_MESSAGING_09_070: [The uAMQP message-id AMQP_VALUE instance shall be destroyed using amqpvalue_destroy().] |
AzureIoTClient | 23:2c6779675a01 | 61 | amqpvalue_destroy(uamqp_message_id); |
AzureIoTClient | 23:2c6779675a01 | 62 | } |
AzureIoTClient | 23:2c6779675a01 | 63 | } |
AzureIoTClient | 23:2c6779675a01 | 64 | |
AzureIoTClient | 23:2c6779675a01 | 65 | // Codes_SRS_UAMQP_MESSAGING_09_071: [Correlation-id from the IOTHUB_MESSAGE shall be read using IoTHubMessage_GetCorrelationId()] |
AzureIoTClient | 23:2c6779675a01 | 66 | // Codes_SRS_UAMQP_MESSAGING_09_072: [As correlation-id is optional field, if it is not set on the IOTHUB_MESSAGE, message_create_from_iothub_message() shall ignore it and continue normally.] |
AzureIoTClient | 23:2c6779675a01 | 67 | if ((correlationId = IoTHubMessage_GetCorrelationId(iothub_message_handle)) != NULL) |
AzureIoTClient | 23:2c6779675a01 | 68 | { |
AzureIoTClient | 23:2c6779675a01 | 69 | // Codes_SRS_UAMQP_MESSAGING_09_073: [The correlation-id value shall be stored on a AMQP_VALUE using amqpvalue_create_string()] |
AzureIoTClient | 23:2c6779675a01 | 70 | AMQP_VALUE uamqp_correlation_id; |
AzureIoTClient | 23:2c6779675a01 | 71 | if ((uamqp_correlation_id = amqpvalue_create_string(correlationId)) == NULL) |
AzureIoTClient | 23:2c6779675a01 | 72 | { |
AzureIoTClient | 23:2c6779675a01 | 73 | // Codes_SRS_UAMQP_MESSAGING_09_074: [If amqpvalue_create_string() fails, message_create_from_iothub_message() shall fail and return immediately.] |
AzureIoTClient | 23:2c6779675a01 | 74 | LogError("Failed to create an AMQP_VALUE for the messageId property value."); |
AzureIoTClient | 29:7e8852b14e3b | 75 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 76 | } |
AzureIoTClient | 23:2c6779675a01 | 77 | else |
AzureIoTClient | 23:2c6779675a01 | 78 | { |
AzureIoTClient | 23:2c6779675a01 | 79 | // Codes_SRS_UAMQP_MESSAGING_09_075: [The correlation-id AMQP_VALUE shall be set on the uAMQP message using properties_set_correlation_id()] |
AzureIoTClient | 23:2c6779675a01 | 80 | if ((api_call_result = properties_set_correlation_id(uamqp_message_properties, uamqp_correlation_id)) != 0) |
AzureIoTClient | 23:2c6779675a01 | 81 | { |
AzureIoTClient | 23:2c6779675a01 | 82 | // Codes_SRS_UAMQP_MESSAGING_09_076: [If properties_set_correlation_id() fails, message_create_from_iothub_message() shall fail and return immediately.] |
AzureIoTClient | 23:2c6779675a01 | 83 | LogInfo("Failed to set value of uAMQP message 'message-id' property (%d).", api_call_result); |
AzureIoTClient | 29:7e8852b14e3b | 84 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 85 | } |
AzureIoTClient | 23:2c6779675a01 | 86 | |
AzureIoTClient | 23:2c6779675a01 | 87 | // Codes_SRS_UAMQP_MESSAGING_09_077: [The uAMQP correlation-id AMQP_VALUE instance shall be destroyed using amqpvalue_destroy().] |
AzureIoTClient | 23:2c6779675a01 | 88 | amqpvalue_destroy(uamqp_correlation_id); |
AzureIoTClient | 23:2c6779675a01 | 89 | } |
AzureIoTClient | 23:2c6779675a01 | 90 | } |
AzureIoTClient | 23:2c6779675a01 | 91 | // Codes_SRS_UAMQP_MESSAGING_09_078: [The updated PROPERTIES_HANDLE instance shall be set on the uAMQP message using message_set_properties()] |
AzureIoTClient | 23:2c6779675a01 | 92 | if ((api_call_result = message_set_properties(uamqp_message, uamqp_message_properties)) != 0) |
AzureIoTClient | 23:2c6779675a01 | 93 | { |
AzureIoTClient | 23:2c6779675a01 | 94 | // Codes_SRS_UAMQP_MESSAGING_09_079: [If message_set_properties() fails, message_create_from_iothub_message() shall fail and return immediately.] |
AzureIoTClient | 23:2c6779675a01 | 95 | LogError("Failed to set properties map on uAMQP message (error code %d).", api_call_result); |
AzureIoTClient | 29:7e8852b14e3b | 96 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 97 | } |
AzureIoTClient | 23:2c6779675a01 | 98 | } |
AzureIoTClient | 23:2c6779675a01 | 99 | |
AzureIoTClient | 23:2c6779675a01 | 100 | // Codes_SRS_UAMQP_MESSAGING_09_099: [The uAMQP message properties (obtained with message_get_properties()) shall be destroyed by calling properties_destroy().] |
AzureIoTClient | 23:2c6779675a01 | 101 | properties_destroy(uamqp_message_properties); |
AzureIoTClient | 23:2c6779675a01 | 102 | |
AzureIoTClient | 23:2c6779675a01 | 103 | return result; |
AzureIoTClient | 23:2c6779675a01 | 104 | } |
AzureIoTClient | 23:2c6779675a01 | 105 | |
AzureIoTClient | 23:2c6779675a01 | 106 | static int addApplicationPropertiesTouAMQPMessage(IOTHUB_MESSAGE_HANDLE iothub_message_handle, MESSAGE_HANDLE uamqp_message) |
AzureIoTClient | 23:2c6779675a01 | 107 | { |
AzureIoTClient | 23:2c6779675a01 | 108 | int result = RESULT_OK; |
AzureIoTClient | 23:2c6779675a01 | 109 | MAP_HANDLE properties_map; |
AzureIoTClient | 23:2c6779675a01 | 110 | const char* const* propertyKeys; |
AzureIoTClient | 23:2c6779675a01 | 111 | const char* const* propertyValues; |
AzureIoTClient | 23:2c6779675a01 | 112 | size_t propertyCount = 0; |
AzureIoTClient | 23:2c6779675a01 | 113 | |
AzureIoTClient | 23:2c6779675a01 | 114 | // Codes_SRS_UAMQP_MESSAGING_09_080: [The IOTHUB_MESSAGE_HANDLE properties shall be obtained by calling IoTHubMessage_Properties.] |
AzureIoTClient | 23:2c6779675a01 | 115 | if ((properties_map = IoTHubMessage_Properties(iothub_message_handle)) == NULL) |
AzureIoTClient | 23:2c6779675a01 | 116 | { |
AzureIoTClient | 23:2c6779675a01 | 117 | // Codes_SRS_UAMQP_MESSAGING_09_081: [If IoTHubMessage_Properties() fails, message_create_from_iothub_message() shall fail and return immediately..] |
AzureIoTClient | 23:2c6779675a01 | 118 | LogError("Failed to get property map from IoTHub message."); |
AzureIoTClient | 29:7e8852b14e3b | 119 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 120 | } |
AzureIoTClient | 23:2c6779675a01 | 121 | // Codes_SRS_UAMQP_MESSAGING_09_082: [The actual keys and values, as well as the number of properties shall be obtained by calling Map_GetInternals on the handle obtained from IoTHubMessage_Properties.] |
AzureIoTClient | 23:2c6779675a01 | 122 | else if (Map_GetInternals(properties_map, &propertyKeys, &propertyValues, &propertyCount) != MAP_OK) |
AzureIoTClient | 23:2c6779675a01 | 123 | { |
AzureIoTClient | 23:2c6779675a01 | 124 | // Codes_SRS_UAMQP_MESSAGING_09_083: [If Map_GetInternals fails, message_create_from_iothub_message() shall fail and return immediately..] |
AzureIoTClient | 23:2c6779675a01 | 125 | LogError("Failed to get the internals of the property map."); |
AzureIoTClient | 29:7e8852b14e3b | 126 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 127 | } |
AzureIoTClient | 23:2c6779675a01 | 128 | else |
AzureIoTClient | 23:2c6779675a01 | 129 | { |
AzureIoTClient | 23:2c6779675a01 | 130 | // Codes_SRS_UAMQP_MESSAGING_09_085: [If the number of properties is greater than 0, message_create_from_iothub_message() shall iterate through all the properties and add them to the uAMQP message.] |
AzureIoTClient | 23:2c6779675a01 | 131 | if (propertyCount != 0) |
AzureIoTClient | 23:2c6779675a01 | 132 | { |
AzureIoTClient | 23:2c6779675a01 | 133 | size_t i; |
AzureIoTClient | 23:2c6779675a01 | 134 | AMQP_VALUE uamqp_map; |
AzureIoTClient | 23:2c6779675a01 | 135 | |
AzureIoTClient | 23:2c6779675a01 | 136 | // Codes_SRS_UAMQP_MESSAGING_09_086: [A uAMQP property map shall be created by calling amqpvalue_create_map().] |
AzureIoTClient | 23:2c6779675a01 | 137 | if ((uamqp_map = amqpvalue_create_map()) == NULL) |
AzureIoTClient | 23:2c6779675a01 | 138 | { |
AzureIoTClient | 23:2c6779675a01 | 139 | // Codes_SRS_UAMQP_MESSAGING_09_087: [If amqpvalue_create_map() fails, message_create_from_iothub_message() shall fail and return immediately.] |
AzureIoTClient | 23:2c6779675a01 | 140 | LogError("Failed to create uAMQP map for the properties."); |
AzureIoTClient | 29:7e8852b14e3b | 141 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 142 | } |
AzureIoTClient | 23:2c6779675a01 | 143 | else |
AzureIoTClient | 23:2c6779675a01 | 144 | { |
AzureIoTClient | 23:2c6779675a01 | 145 | for (i = 0; result == RESULT_OK && i < propertyCount; i++) |
AzureIoTClient | 23:2c6779675a01 | 146 | { |
AzureIoTClient | 23:2c6779675a01 | 147 | AMQP_VALUE map_key_value = NULL; |
AzureIoTClient | 23:2c6779675a01 | 148 | AMQP_VALUE map_value_value = NULL; |
AzureIoTClient | 23:2c6779675a01 | 149 | |
AzureIoTClient | 23:2c6779675a01 | 150 | // Codes_SRS_UAMQP_MESSAGING_09_088: [An AMQP_VALUE instance shall be created using amqpvalue_create_string() to hold each uAMQP property name.] |
AzureIoTClient | 23:2c6779675a01 | 151 | if ((map_key_value = amqpvalue_create_string(propertyKeys[i])) == NULL) |
AzureIoTClient | 23:2c6779675a01 | 152 | { |
AzureIoTClient | 23:2c6779675a01 | 153 | // Codes_SRS_UAMQP_MESSAGING_09_089: [If amqpvalue_create_string() fails, message_create_from_iothub_message() shall fail and return immediately..] |
AzureIoTClient | 23:2c6779675a01 | 154 | LogError("Failed to create uAMQP property key name."); |
AzureIoTClient | 29:7e8852b14e3b | 155 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 156 | } |
AzureIoTClient | 23:2c6779675a01 | 157 | // Codes_SRS_UAMQP_MESSAGING_09_090: [An AMQP_VALUE instance shall be created using amqpvalue_create_string() to hold each uAMQP property value.] |
AzureIoTClient | 23:2c6779675a01 | 158 | else if ((map_value_value = amqpvalue_create_string(propertyValues[i])) == NULL) |
AzureIoTClient | 23:2c6779675a01 | 159 | { |
AzureIoTClient | 23:2c6779675a01 | 160 | // Codes_SRS_UAMQP_MESSAGING_09_091: [If amqpvalue_create_string() fails, message_create_from_iothub_message() shall fail and return immediately..] |
AzureIoTClient | 23:2c6779675a01 | 161 | LogError("Failed to create uAMQP property key value."); |
AzureIoTClient | 29:7e8852b14e3b | 162 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 163 | } |
AzureIoTClient | 23:2c6779675a01 | 164 | // Codes_SRS_UAMQP_MESSAGING_09_092: [The property name and value (AMQP_VALUE instances) shall be added to the uAMQP property map by calling amqpvalue_map_set_value().] |
AzureIoTClient | 23:2c6779675a01 | 165 | else if (amqpvalue_set_map_value(uamqp_map, map_key_value, map_value_value) != 0) |
AzureIoTClient | 23:2c6779675a01 | 166 | { |
AzureIoTClient | 23:2c6779675a01 | 167 | // Codes_SRS_UAMQP_MESSAGING_09_093: [If amqpvalue_map_set_value() fails, message_create_from_iothub_message() shall fail and return immediately..] |
AzureIoTClient | 23:2c6779675a01 | 168 | LogError("Failed to set key/value into the the uAMQP property map."); |
AzureIoTClient | 29:7e8852b14e3b | 169 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 170 | } |
AzureIoTClient | 23:2c6779675a01 | 171 | |
AzureIoTClient | 23:2c6779675a01 | 172 | // Codes_SRS_UAMQP_MESSAGING_09_094: [After adding the property name and value to the uAMQP property map, both AMQP_VALUE instances shall be destroyed using amqpvalue_destroy().] |
AzureIoTClient | 23:2c6779675a01 | 173 | if (map_key_value != NULL) |
AzureIoTClient | 23:2c6779675a01 | 174 | amqpvalue_destroy(map_key_value); |
AzureIoTClient | 23:2c6779675a01 | 175 | |
AzureIoTClient | 23:2c6779675a01 | 176 | if (map_value_value != NULL) |
AzureIoTClient | 23:2c6779675a01 | 177 | amqpvalue_destroy(map_value_value); |
AzureIoTClient | 23:2c6779675a01 | 178 | } |
AzureIoTClient | 23:2c6779675a01 | 179 | |
AzureIoTClient | 23:2c6779675a01 | 180 | if (result == RESULT_OK) |
AzureIoTClient | 23:2c6779675a01 | 181 | { |
AzureIoTClient | 23:2c6779675a01 | 182 | // Codes_SRS_UAMQP_MESSAGING_09_095: [If no errors occurred processing the properties, the uAMQP properties map shall be set on the uAMQP message by calling message_set_application_properties().] |
AzureIoTClient | 23:2c6779675a01 | 183 | if (message_set_application_properties(uamqp_message, uamqp_map) != 0) |
AzureIoTClient | 23:2c6779675a01 | 184 | { |
AzureIoTClient | 23:2c6779675a01 | 185 | // Codes_SRS_UAMQP_MESSAGING_09_096: [If message_set_application_properties() fails, message_create_from_iothub_message() shall fail and return immediately..] |
AzureIoTClient | 23:2c6779675a01 | 186 | LogError("Failed to transfer the message properties to the uAMQP message."); |
AzureIoTClient | 29:7e8852b14e3b | 187 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 188 | } |
AzureIoTClient | 23:2c6779675a01 | 189 | else |
AzureIoTClient | 23:2c6779675a01 | 190 | { |
AzureIoTClient | 23:2c6779675a01 | 191 | result = RESULT_OK; |
AzureIoTClient | 23:2c6779675a01 | 192 | } |
AzureIoTClient | 23:2c6779675a01 | 193 | } |
AzureIoTClient | 23:2c6779675a01 | 194 | |
AzureIoTClient | 23:2c6779675a01 | 195 | // Codes_SRS_UAMQP_MESSAGING_09_097: [The uAMQP properties map shall be destroyed using amqpvalue_destroy().] |
AzureIoTClient | 23:2c6779675a01 | 196 | amqpvalue_destroy(uamqp_map); |
AzureIoTClient | 23:2c6779675a01 | 197 | } |
AzureIoTClient | 23:2c6779675a01 | 198 | } |
AzureIoTClient | 23:2c6779675a01 | 199 | else |
AzureIoTClient | 23:2c6779675a01 | 200 | { |
AzureIoTClient | 23:2c6779675a01 | 201 | // Codes_SRS_UAMQP_MESSAGING_09_084: [If the number of properties is 0, no application properties shall be set on the uAMQP message and message_create_from_iothub_message() shall return with success.] |
AzureIoTClient | 23:2c6779675a01 | 202 | result = RESULT_OK; |
AzureIoTClient | 23:2c6779675a01 | 203 | } |
AzureIoTClient | 23:2c6779675a01 | 204 | } |
AzureIoTClient | 23:2c6779675a01 | 205 | |
AzureIoTClient | 23:2c6779675a01 | 206 | return result; |
AzureIoTClient | 23:2c6779675a01 | 207 | } |
AzureIoTClient | 23:2c6779675a01 | 208 | |
AzureIoTClient | 23:2c6779675a01 | 209 | static int readPropertiesFromuAMQPMessage(IOTHUB_MESSAGE_HANDLE iothub_message_handle, MESSAGE_HANDLE uamqp_message) |
AzureIoTClient | 23:2c6779675a01 | 210 | { |
AzureIoTClient | 23:2c6779675a01 | 211 | int return_value; |
AzureIoTClient | 23:2c6779675a01 | 212 | PROPERTIES_HANDLE uamqp_message_properties; |
AzureIoTClient | 23:2c6779675a01 | 213 | AMQP_VALUE uamqp_message_property; |
AzureIoTClient | 23:2c6779675a01 | 214 | const char* uamqp_message_property_value; |
AzureIoTClient | 23:2c6779675a01 | 215 | int api_call_result; |
AzureIoTClient | 23:2c6779675a01 | 216 | |
AzureIoTClient | 23:2c6779675a01 | 217 | // Codes_SRS_UAMQP_MESSAGING_09_008: [The uAMQP message properties shall be retrieved using message_get_properties().] |
AzureIoTClient | 23:2c6779675a01 | 218 | if ((api_call_result = message_get_properties(uamqp_message, &uamqp_message_properties)) != 0) |
AzureIoTClient | 23:2c6779675a01 | 219 | { |
AzureIoTClient | 23:2c6779675a01 | 220 | // Codes_SRS_UAMQP_MESSAGING_09_009: [If message_get_properties() fails, IoTHubMessage_CreateFromuAMQPMessage shall fail and return immediately.] |
AzureIoTClient | 23:2c6779675a01 | 221 | LogError("Failed to get property properties map from uAMQP message (error code %d).", api_call_result); |
AzureIoTClient | 29:7e8852b14e3b | 222 | return_value = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 223 | } |
AzureIoTClient | 23:2c6779675a01 | 224 | else |
AzureIoTClient | 23:2c6779675a01 | 225 | { |
AzureIoTClient | 23:2c6779675a01 | 226 | return_value = 0; // Properties 'message-id' and 'correlation-id' are optional according to the AMQP 1.0 spec. |
AzureIoTClient | 23:2c6779675a01 | 227 | |
AzureIoTClient | 23:2c6779675a01 | 228 | // Codes_SRS_UAMQP_MESSAGING_09_010: [The message-id property shall be read from the uAMQP message by calling properties_get_message_id.] |
AzureIoTClient | 23:2c6779675a01 | 229 | if ((api_call_result = properties_get_message_id(uamqp_message_properties, &uamqp_message_property)) != 0) |
AzureIoTClient | 23:2c6779675a01 | 230 | { |
AzureIoTClient | 23:2c6779675a01 | 231 | // Codes_SRS_UAMQP_MESSAGING_09_011: [If properties_get_message_id fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.] |
AzureIoTClient | 23:2c6779675a01 | 232 | LogInfo("Failed to get value of uAMQP message 'message-id' property (%d). No failure, since it is optional.", api_call_result); |
AzureIoTClient | 23:2c6779675a01 | 233 | } |
AzureIoTClient | 23:2c6779675a01 | 234 | // Codes_SRS_UAMQP_MESSAGING_09_012: [The type of the message-id property value shall be obtained using amqpvalue_get_type().] |
AzureIoTClient | 23:2c6779675a01 | 235 | // Codes_SRS_UAMQP_MESSAGING_09_013: [If the type of the message-id property value is AMQP_TYPE_NULL, IoTHubMessage_CreateFromuAMQPMessage() shall skip processing the message-id (as it is optional) and continue normally.] |
AzureIoTClient | 23:2c6779675a01 | 236 | else if (amqpvalue_get_type(uamqp_message_property) != AMQP_TYPE_NULL) |
AzureIoTClient | 23:2c6779675a01 | 237 | { |
AzureIoTClient | 23:2c6779675a01 | 238 | // Codes_SRS_UAMQP_MESSAGING_09_014: [The message-id value shall be retrieved from the AMQP_VALUE as char* by calling amqpvalue_get_string().] |
AzureIoTClient | 23:2c6779675a01 | 239 | if ((api_call_result = amqpvalue_get_string(uamqp_message_property, &uamqp_message_property_value)) != 0) |
AzureIoTClient | 23:2c6779675a01 | 240 | { |
AzureIoTClient | 23:2c6779675a01 | 241 | // Codes_SRS_UAMQP_MESSAGING_09_015: [If amqpvalue_get_string fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.] |
AzureIoTClient | 23:2c6779675a01 | 242 | LogError("Failed to get value of uAMQP message 'message-id' property (%d).", api_call_result); |
AzureIoTClient | 29:7e8852b14e3b | 243 | return_value = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 244 | } |
AzureIoTClient | 23:2c6779675a01 | 245 | // Codes_SRS_UAMQP_MESSAGING_09_016: [The message-id property shall be set on the IOTHUB_MESSAGE_HANDLE instance by calling IoTHubMessage_SetMessageId(), passing the value read from the uAMQP message.] |
AzureIoTClient | 23:2c6779675a01 | 246 | else if (IoTHubMessage_SetMessageId(iothub_message_handle, uamqp_message_property_value) != IOTHUB_MESSAGE_OK) |
AzureIoTClient | 23:2c6779675a01 | 247 | { |
AzureIoTClient | 23:2c6779675a01 | 248 | // Codes_SRS_UAMQP_MESSAGING_09_017: [If IoTHubMessage_SetMessageId fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.] |
AzureIoTClient | 23:2c6779675a01 | 249 | LogError("Failed to set IOTHUB_MESSAGE_HANDLE 'message-id' property."); |
AzureIoTClient | 29:7e8852b14e3b | 250 | return_value = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 251 | } |
AzureIoTClient | 23:2c6779675a01 | 252 | } |
AzureIoTClient | 23:2c6779675a01 | 253 | |
AzureIoTClient | 23:2c6779675a01 | 254 | // Codes_SRS_UAMQP_MESSAGING_09_018: [The correlation-id property shall be read from the uAMQP message by calling properties_get_correlation_id.] |
AzureIoTClient | 23:2c6779675a01 | 255 | if ((api_call_result = properties_get_correlation_id(uamqp_message_properties, &uamqp_message_property)) != 0) |
AzureIoTClient | 23:2c6779675a01 | 256 | { |
AzureIoTClient | 23:2c6779675a01 | 257 | // Codes_SRS_UAMQP_MESSAGING_09_019: [If properties_get_correlation_id() fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.] |
AzureIoTClient | 23:2c6779675a01 | 258 | LogError("Failed to get value of uAMQP message 'correlation-id' property (%d). No failure, since it is optional.", api_call_result); |
AzureIoTClient | 23:2c6779675a01 | 259 | } |
AzureIoTClient | 23:2c6779675a01 | 260 | // Codes_SRS_UAMQP_MESSAGING_09_020: [The type of the correlation-id property value shall be obtained using amqpvalue_get_type().] |
AzureIoTClient | 23:2c6779675a01 | 261 | // Codes_SRS_UAMQP_MESSAGING_09_021: [If the type of the correlation-id property value is AMQP_TYPE_NULL, IoTHubMessage_CreateFromuAMQPMessage() shall skip processing the correlation-id (as it is optional) and continue normally.] |
AzureIoTClient | 23:2c6779675a01 | 262 | else if (amqpvalue_get_type(uamqp_message_property) != AMQP_TYPE_NULL) |
AzureIoTClient | 23:2c6779675a01 | 263 | { |
AzureIoTClient | 23:2c6779675a01 | 264 | // Codes_SRS_UAMQP_MESSAGING_09_022: [The correlation-id value shall be retrieved from the AMQP_VALUE as char* by calling amqpvalue_get_string.] |
AzureIoTClient | 23:2c6779675a01 | 265 | if ((api_call_result = amqpvalue_get_string(uamqp_message_property, &uamqp_message_property_value)) != 0) |
AzureIoTClient | 23:2c6779675a01 | 266 | { |
AzureIoTClient | 23:2c6779675a01 | 267 | // Codes_SRS_UAMQP_MESSAGING_09_023: [If amqpvalue_get_string fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.] |
AzureIoTClient | 23:2c6779675a01 | 268 | LogError("Failed to get value of uAMQP message 'correlation-id' property (%d).", api_call_result); |
AzureIoTClient | 29:7e8852b14e3b | 269 | return_value = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 270 | } |
AzureIoTClient | 23:2c6779675a01 | 271 | // Codes_SRS_UAMQP_MESSAGING_09_024: [The correlation-id property shall be set on the IOTHUB_MESSAGE_HANDLE by calling IoTHubMessage_SetCorrelationId, passing the value read from the uAMQP message.] |
AzureIoTClient | 23:2c6779675a01 | 272 | else if (IoTHubMessage_SetCorrelationId(iothub_message_handle, uamqp_message_property_value) != IOTHUB_MESSAGE_OK) |
AzureIoTClient | 23:2c6779675a01 | 273 | { |
AzureIoTClient | 23:2c6779675a01 | 274 | // Codes_SRS_UAMQP_MESSAGING_09_025: [If IoTHubMessage_SetCorrelationId fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.] |
AzureIoTClient | 23:2c6779675a01 | 275 | LogError("Failed to set IOTHUB_MESSAGE_HANDLE 'correlation-id' property."); |
AzureIoTClient | 29:7e8852b14e3b | 276 | return_value = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 277 | } |
AzureIoTClient | 23:2c6779675a01 | 278 | } |
AzureIoTClient | 23:2c6779675a01 | 279 | // Codes_SRS_UAMQP_MESSAGING_09_026: [IoTHubMessage_CreateFromuAMQPMessage() shall destroy the uAMQP message properties (obtained with message_get_properties()) by calling properties_destroy().] |
AzureIoTClient | 23:2c6779675a01 | 280 | properties_destroy(uamqp_message_properties); |
AzureIoTClient | 23:2c6779675a01 | 281 | } |
AzureIoTClient | 23:2c6779675a01 | 282 | |
AzureIoTClient | 23:2c6779675a01 | 283 | return return_value; |
AzureIoTClient | 23:2c6779675a01 | 284 | } |
AzureIoTClient | 23:2c6779675a01 | 285 | |
AzureIoTClient | 23:2c6779675a01 | 286 | static int readApplicationPropertiesFromuAMQPMessage(IOTHUB_MESSAGE_HANDLE iothub_message_handle, MESSAGE_HANDLE uamqp_message) |
AzureIoTClient | 23:2c6779675a01 | 287 | { |
AzureIoTClient | 23:2c6779675a01 | 288 | int result; |
AzureIoTClient | 23:2c6779675a01 | 289 | AMQP_VALUE uamqp_app_properties = NULL; |
AzureIoTClient | 23:2c6779675a01 | 290 | AMQP_VALUE uamqp_app_properties_ipdv = NULL; |
AzureIoTClient | 23:2c6779675a01 | 291 | uint32_t property_count = 0; |
AzureIoTClient | 23:2c6779675a01 | 292 | MAP_HANDLE iothub_message_properties_map; |
AzureIoTClient | 23:2c6779675a01 | 293 | |
AzureIoTClient | 23:2c6779675a01 | 294 | // Codes_SRS_UAMQP_MESSAGING_09_027: [The IOTHUB_MESSAGE_HANDLE properties shall be retrieved using IoTHubMessage_Properties.] |
AzureIoTClient | 23:2c6779675a01 | 295 | if ((iothub_message_properties_map = IoTHubMessage_Properties(iothub_message_handle)) == NULL) |
AzureIoTClient | 23:2c6779675a01 | 296 | { |
AzureIoTClient | 23:2c6779675a01 | 297 | // Codes_SRS_UAMQP_MESSAGING_09_028: [If IoTHubMessage_Properties fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.] |
AzureIoTClient | 23:2c6779675a01 | 298 | LogError("Failed to get property map from IoTHub message."); |
AzureIoTClient | 29:7e8852b14e3b | 299 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 300 | } |
AzureIoTClient | 23:2c6779675a01 | 301 | // Codes_SRS_UAMQP_MESSAGING_09_029: [The uAMQP message application properties shall be retrieved using message_get_application_properties.] |
AzureIoTClient | 23:2c6779675a01 | 302 | else if ((result = message_get_application_properties(uamqp_message, &uamqp_app_properties)) != 0) |
AzureIoTClient | 23:2c6779675a01 | 303 | { |
AzureIoTClient | 23:2c6779675a01 | 304 | // Codes_SRS_UAMQP_MESSAGING_09_030: [If message_get_application_properties fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.] |
AzureIoTClient | 23:2c6779675a01 | 305 | LogError("Failed reading the incoming uAMQP message properties (return code %d).", result); |
AzureIoTClient | 29:7e8852b14e3b | 306 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 307 | } |
AzureIoTClient | 23:2c6779675a01 | 308 | else |
AzureIoTClient | 23:2c6779675a01 | 309 | { |
AzureIoTClient | 23:2c6779675a01 | 310 | // Codes_SRS_UAMQP_MESSAGING_09_031: [If message_get_application_properties succeeds but returns a NULL application properties map (there are no properties), IoTHubMessage_CreateFromuAMQPMessage() shall skip processing the properties and continue normally.] |
AzureIoTClient | 23:2c6779675a01 | 311 | if (uamqp_app_properties == NULL) |
AzureIoTClient | 23:2c6779675a01 | 312 | { |
AzureIoTClient | 23:2c6779675a01 | 313 | result = 0; |
AzureIoTClient | 23:2c6779675a01 | 314 | } |
AzureIoTClient | 23:2c6779675a01 | 315 | else |
AzureIoTClient | 23:2c6779675a01 | 316 | { |
AzureIoTClient | 23:2c6779675a01 | 317 | // Codes_SRS_UAMQP_MESSAGING_09_032: [The actual uAMQP message application properties should be extracted from the result of message_get_application_properties using amqpvalue_get_inplace_described_value.] |
AzureIoTClient | 23:2c6779675a01 | 318 | if ((uamqp_app_properties_ipdv = amqpvalue_get_inplace_described_value(uamqp_app_properties)) == NULL) |
AzureIoTClient | 23:2c6779675a01 | 319 | { |
AzureIoTClient | 23:2c6779675a01 | 320 | // Codes_SRS_UAMQP_MESSAGING_09_033: [If amqpvalue_get_inplace_described_value fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.] |
AzureIoTClient | 23:2c6779675a01 | 321 | LogError("Failed getting the map of uAMQP message application properties (return code %d).", result); |
AzureIoTClient | 29:7e8852b14e3b | 322 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 323 | } |
AzureIoTClient | 23:2c6779675a01 | 324 | // Codes_SRS_UAMQP_MESSAGING_09_034: [The number of items in the uAMQP message application properties shall be obtained using amqpvalue_get_map_pair_count.] |
AzureIoTClient | 23:2c6779675a01 | 325 | else if ((result = amqpvalue_get_map_pair_count(uamqp_app_properties_ipdv, &property_count)) != 0) |
AzureIoTClient | 23:2c6779675a01 | 326 | { |
AzureIoTClient | 23:2c6779675a01 | 327 | // Codes_SRS_UAMQP_MESSAGING_09_035: [If amqpvalue_get_map_pair_count fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.] |
AzureIoTClient | 23:2c6779675a01 | 328 | LogError("Failed reading the number of values in the uAMQP property map (return code %d).", result); |
AzureIoTClient | 29:7e8852b14e3b | 329 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 330 | } |
AzureIoTClient | 23:2c6779675a01 | 331 | else |
AzureIoTClient | 23:2c6779675a01 | 332 | { |
AzureIoTClient | 23:2c6779675a01 | 333 | // Codes_SRS_UAMQP_MESSAGING_09_036: [IoTHubMessage_CreateFromuAMQPMessage() shall iterate through each uAMQP application property and add it to IOTHUB_MESSAGE_HANDLE properties.] |
AzureIoTClient | 23:2c6779675a01 | 334 | uint32_t i; |
AzureIoTClient | 23:2c6779675a01 | 335 | for (i = 0; result == RESULT_OK && i < property_count; i++) |
AzureIoTClient | 23:2c6779675a01 | 336 | { |
AzureIoTClient | 23:2c6779675a01 | 337 | AMQP_VALUE map_key_name = NULL; |
AzureIoTClient | 23:2c6779675a01 | 338 | AMQP_VALUE map_key_value = NULL; |
AzureIoTClient | 23:2c6779675a01 | 339 | const char *key_name; |
AzureIoTClient | 23:2c6779675a01 | 340 | const char* key_value; |
AzureIoTClient | 23:2c6779675a01 | 341 | |
AzureIoTClient | 23:2c6779675a01 | 342 | // Codes_SRS_UAMQP_MESSAGING_09_037: [The uAMQP application property name and value shall be obtained using amqpvalue_get_map_key_value_pair.] |
AzureIoTClient | 23:2c6779675a01 | 343 | if ((result = amqpvalue_get_map_key_value_pair(uamqp_app_properties_ipdv, i, &map_key_name, &map_key_value)) != 0) |
AzureIoTClient | 23:2c6779675a01 | 344 | { |
AzureIoTClient | 23:2c6779675a01 | 345 | // Codes_SRS_UAMQP_MESSAGING_09_038: [If amqpvalue_get_map_key_value_pair fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.] |
AzureIoTClient | 23:2c6779675a01 | 346 | LogError("Failed reading the key/value pair from the uAMQP property map (return code %d).", result); |
AzureIoTClient | 29:7e8852b14e3b | 347 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 348 | } |
AzureIoTClient | 23:2c6779675a01 | 349 | |
AzureIoTClient | 23:2c6779675a01 | 350 | // Codes_SRS_UAMQP_MESSAGING_09_039: [The uAMQP application property name shall be extracted as string using amqpvalue_get_string.] |
AzureIoTClient | 23:2c6779675a01 | 351 | else if ((result = amqpvalue_get_string(map_key_name, &key_name)) != 0) |
AzureIoTClient | 23:2c6779675a01 | 352 | { |
AzureIoTClient | 23:2c6779675a01 | 353 | // Codes_SRS_UAMQP_MESSAGING_09_040: [If amqpvalue_get_string fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.] |
AzureIoTClient | 23:2c6779675a01 | 354 | LogError("Failed parsing the uAMQP property name (return code %d).", result); |
AzureIoTClient | 29:7e8852b14e3b | 355 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 356 | } |
AzureIoTClient | 23:2c6779675a01 | 357 | // Codes_SRS_UAMQP_MESSAGING_09_041: [The uAMQP application property value shall be extracted as string using amqpvalue_get_string.] |
AzureIoTClient | 23:2c6779675a01 | 358 | else if ((result = amqpvalue_get_string(map_key_value, &key_value)) != 0) |
AzureIoTClient | 23:2c6779675a01 | 359 | { |
AzureIoTClient | 23:2c6779675a01 | 360 | // Codes_SRS_UAMQP_MESSAGING_09_042: [If amqpvalue_get_string fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.] |
AzureIoTClient | 23:2c6779675a01 | 361 | LogError("Failed parsing the uAMQP property value (return code %d).", result); |
AzureIoTClient | 29:7e8852b14e3b | 362 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 363 | } |
AzureIoTClient | 23:2c6779675a01 | 364 | // Codes_SRS_UAMQP_MESSAGING_09_043: [The application property name and value shall be added to IOTHUB_MESSAGE_HANDLE properties using Map_AddOrUpdate.] |
AzureIoTClient | 23:2c6779675a01 | 365 | else if (Map_AddOrUpdate(iothub_message_properties_map, key_name, key_value) != MAP_OK) |
AzureIoTClient | 23:2c6779675a01 | 366 | { |
AzureIoTClient | 23:2c6779675a01 | 367 | // Codes_SRS_UAMQP_MESSAGING_09_044: [If Map_AddOrUpdate fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.] |
AzureIoTClient | 23:2c6779675a01 | 368 | LogError("Failed to add/update IoTHub message property map."); |
AzureIoTClient | 29:7e8852b14e3b | 369 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 370 | } |
AzureIoTClient | 23:2c6779675a01 | 371 | |
AzureIoTClient | 23:2c6779675a01 | 372 | // Codes_SRS_UAMQP_MESSAGING_09_045: [IoTHubMessage_CreateFromuAMQPMessage() shall destroy the uAMQP message property name and value (obtained with amqpvalue_get_string) by calling amqpvalue_destroy().] |
AzureIoTClient | 23:2c6779675a01 | 373 | if (map_key_name != NULL) |
AzureIoTClient | 23:2c6779675a01 | 374 | { |
AzureIoTClient | 23:2c6779675a01 | 375 | amqpvalue_destroy(map_key_name); |
AzureIoTClient | 23:2c6779675a01 | 376 | } |
AzureIoTClient | 23:2c6779675a01 | 377 | |
AzureIoTClient | 23:2c6779675a01 | 378 | if (map_key_value != NULL) |
AzureIoTClient | 23:2c6779675a01 | 379 | { |
AzureIoTClient | 23:2c6779675a01 | 380 | amqpvalue_destroy(map_key_value); |
AzureIoTClient | 23:2c6779675a01 | 381 | } |
AzureIoTClient | 23:2c6779675a01 | 382 | } |
AzureIoTClient | 23:2c6779675a01 | 383 | } |
AzureIoTClient | 23:2c6779675a01 | 384 | |
AzureIoTClient | 23:2c6779675a01 | 385 | // Codes_SRS_UAMQP_MESSAGING_09_046: [IoTHubMessage_CreateFromuAMQPMessage() shall destroy the uAMQP message property (obtained with message_get_application_properties) by calling amqpvalue_destroy().] |
AzureIoTClient | 23:2c6779675a01 | 386 | amqpvalue_destroy(uamqp_app_properties); |
AzureIoTClient | 23:2c6779675a01 | 387 | } |
AzureIoTClient | 23:2c6779675a01 | 388 | } |
AzureIoTClient | 23:2c6779675a01 | 389 | |
AzureIoTClient | 23:2c6779675a01 | 390 | return result; |
AzureIoTClient | 23:2c6779675a01 | 391 | } |
AzureIoTClient | 23:2c6779675a01 | 392 | |
AzureIoTClient | 23:2c6779675a01 | 393 | int IoTHubMessage_CreateFromUamqpMessage(MESSAGE_HANDLE uamqp_message, IOTHUB_MESSAGE_HANDLE* iothubclient_message) |
AzureIoTClient | 23:2c6779675a01 | 394 | { |
AzureIoTClient | 29:7e8852b14e3b | 395 | int result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 396 | |
AzureIoTClient | 23:2c6779675a01 | 397 | IOTHUB_MESSAGE_HANDLE iothub_message = NULL; |
AzureIoTClient | 23:2c6779675a01 | 398 | MESSAGE_BODY_TYPE body_type; |
AzureIoTClient | 23:2c6779675a01 | 399 | |
AzureIoTClient | 23:2c6779675a01 | 400 | // Codes_SRS_UAMQP_MESSAGING_09_001: [The body type of the uAMQP message shall be retrieved using message_get_body_type().] |
AzureIoTClient | 23:2c6779675a01 | 401 | if (message_get_body_type(uamqp_message, &body_type) != 0) |
AzureIoTClient | 23:2c6779675a01 | 402 | { |
AzureIoTClient | 23:2c6779675a01 | 403 | // Codes_SRS_UAMQP_MESSAGING_09_002: [If message_get_body_type() fails, IoTHubMessage_CreateFromuAMQPMessage shall fail and return immediately.] |
AzureIoTClient | 23:2c6779675a01 | 404 | LogError("Failed to get the type of the uamqp message."); |
AzureIoTClient | 29:7e8852b14e3b | 405 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 406 | } |
AzureIoTClient | 23:2c6779675a01 | 407 | else |
AzureIoTClient | 23:2c6779675a01 | 408 | { |
AzureIoTClient | 23:2c6779675a01 | 409 | // Codes_SRS_UAMQP_MESSAGING_09_003: [If the uAMQP message body type is MESSAGE_BODY_TYPE_DATA, the body data shall be treated as binary data.] |
AzureIoTClient | 23:2c6779675a01 | 410 | if (body_type == MESSAGE_BODY_TYPE_DATA) |
AzureIoTClient | 23:2c6779675a01 | 411 | { |
AzureIoTClient | 23:2c6779675a01 | 412 | // Codes_SRS_UAMQP_MESSAGING_09_004: [The uAMQP message body data shall be retrieved using message_get_body_amqp_data().] |
AzureIoTClient | 23:2c6779675a01 | 413 | BINARY_DATA binary_data; |
AzureIoTClient | 34:51d158b409d2 | 414 | if (message_get_body_amqp_data_in_place(uamqp_message, 0, &binary_data) != 0) |
AzureIoTClient | 23:2c6779675a01 | 415 | { |
AzureIoTClient | 23:2c6779675a01 | 416 | // Codes_SRS_UAMQP_MESSAGING_09_005: [If message_get_body_amqp_data() fails, IoTHubMessage_CreateFromuAMQPMessage shall fail and return immediately.] |
AzureIoTClient | 23:2c6779675a01 | 417 | LogError("Failed to get the body of the uamqp message."); |
AzureIoTClient | 29:7e8852b14e3b | 418 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 419 | } |
AzureIoTClient | 23:2c6779675a01 | 420 | // Codes_SRS_UAMQP_MESSAGING_09_006: [The IOTHUB_MESSAGE instance shall be created using IoTHubMessage_CreateFromByteArray(), passing the uAMQP body bytes as parameter.] |
AzureIoTClient | 23:2c6779675a01 | 421 | else if ((iothub_message = IoTHubMessage_CreateFromByteArray(binary_data.bytes, binary_data.length)) == NULL) |
AzureIoTClient | 23:2c6779675a01 | 422 | { |
AzureIoTClient | 23:2c6779675a01 | 423 | // Codes_SRS_UAMQP_MESSAGING_09_007: [If IoTHubMessage_CreateFromByteArray() fails, IoTHubMessage_CreateFromuAMQPMessage shall fail and return immediately.] |
AzureIoTClient | 23:2c6779675a01 | 424 | LogError("Failed creating the IOTHUB_MESSAGE_HANDLE instance (IoTHubMessage_CreateFromByteArray failed)."); |
AzureIoTClient | 29:7e8852b14e3b | 425 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 426 | } |
AzureIoTClient | 23:2c6779675a01 | 427 | } |
AzureIoTClient | 23:2c6779675a01 | 428 | } |
AzureIoTClient | 23:2c6779675a01 | 429 | |
AzureIoTClient | 23:2c6779675a01 | 430 | if (iothub_message != NULL) |
AzureIoTClient | 23:2c6779675a01 | 431 | { |
AzureIoTClient | 23:2c6779675a01 | 432 | if (readPropertiesFromuAMQPMessage(iothub_message, uamqp_message) != RESULT_OK) |
AzureIoTClient | 23:2c6779675a01 | 433 | { |
AzureIoTClient | 23:2c6779675a01 | 434 | LogError("Failed reading properties of the uamqp message."); |
AzureIoTClient | 23:2c6779675a01 | 435 | IoTHubMessage_Destroy(iothub_message); |
AzureIoTClient | 29:7e8852b14e3b | 436 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 437 | } |
AzureIoTClient | 23:2c6779675a01 | 438 | else if (readApplicationPropertiesFromuAMQPMessage(iothub_message, uamqp_message) != RESULT_OK) |
AzureIoTClient | 23:2c6779675a01 | 439 | { |
AzureIoTClient | 23:2c6779675a01 | 440 | LogError("Failed reading application properties of the uamqp message."); |
AzureIoTClient | 23:2c6779675a01 | 441 | IoTHubMessage_Destroy(iothub_message); |
AzureIoTClient | 29:7e8852b14e3b | 442 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 443 | } |
AzureIoTClient | 23:2c6779675a01 | 444 | else |
AzureIoTClient | 23:2c6779675a01 | 445 | { |
AzureIoTClient | 23:2c6779675a01 | 446 | *iothubclient_message = iothub_message; |
AzureIoTClient | 23:2c6779675a01 | 447 | result = RESULT_OK; |
AzureIoTClient | 23:2c6779675a01 | 448 | } |
AzureIoTClient | 23:2c6779675a01 | 449 | } |
AzureIoTClient | 23:2c6779675a01 | 450 | |
AzureIoTClient | 23:2c6779675a01 | 451 | return result; |
AzureIoTClient | 23:2c6779675a01 | 452 | } |
AzureIoTClient | 23:2c6779675a01 | 453 | |
AzureIoTClient | 23:2c6779675a01 | 454 | int message_create_from_iothub_message(IOTHUB_MESSAGE_HANDLE iothub_message, MESSAGE_HANDLE* uamqp_message) |
AzureIoTClient | 23:2c6779675a01 | 455 | { |
AzureIoTClient | 29:7e8852b14e3b | 456 | int result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 457 | // Codes_SRS_UAMQP_MESSAGING_09_047: [The content type of the IOTHUB_MESSAGE_HANDLE instance shall be obtained using IoTHubMessage_GetContentType().] |
AzureIoTClient | 23:2c6779675a01 | 458 | IOTHUBMESSAGE_CONTENT_TYPE contentType = IoTHubMessage_GetContentType(iothub_message); |
AzureIoTClient | 23:2c6779675a01 | 459 | const char* messageContent = NULL; |
AzureIoTClient | 23:2c6779675a01 | 460 | size_t messageContentSize = 0; |
AzureIoTClient | 23:2c6779675a01 | 461 | MESSAGE_HANDLE uamqp_message_tmp = NULL; |
AzureIoTClient | 23:2c6779675a01 | 462 | |
AzureIoTClient | 23:2c6779675a01 | 463 | // Codes_SRS_UAMQP_MESSAGING_09_048: [If the content type of the IOTHUB_MESSAGE_HANDLE instance is IOTHUBMESSAGE_BYTEARRAY, the content shall be obtained using IoTHubMessage_GetByteArray().] |
AzureIoTClient | 23:2c6779675a01 | 464 | if (contentType == IOTHUBMESSAGE_BYTEARRAY && |
AzureIoTClient | 23:2c6779675a01 | 465 | IoTHubMessage_GetByteArray(iothub_message, (const unsigned char **)&messageContent, &messageContentSize) != IOTHUB_MESSAGE_OK) |
AzureIoTClient | 23:2c6779675a01 | 466 | { |
AzureIoTClient | 23:2c6779675a01 | 467 | // Codes_SRS_UAMQP_MESSAGING_09_049: [If IoTHubMessage_GetByteArray() fails, message_create_from_iothub_message() shall fail and return.] |
AzureIoTClient | 23:2c6779675a01 | 468 | LogError("Failed getting the BYTE array representation of the IOTHUB_MESSAGE_HANDLE instance."); |
AzureIoTClient | 29:7e8852b14e3b | 469 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 470 | } |
AzureIoTClient | 23:2c6779675a01 | 471 | // Codes_SRS_UAMQP_MESSAGING_09_050: [If the content type of the IOTHUB_MESSAGE_HANDLE instance is IOTHUBMESSAGE_STRING, the content shall be obtained using IoTHubMessage_GetString().] |
AzureIoTClient | 23:2c6779675a01 | 472 | else if (contentType == IOTHUBMESSAGE_STRING && |
AzureIoTClient | 23:2c6779675a01 | 473 | ((messageContent = IoTHubMessage_GetString(iothub_message)) == NULL)) |
AzureIoTClient | 23:2c6779675a01 | 474 | { |
AzureIoTClient | 23:2c6779675a01 | 475 | // Codes_SRS_UAMQP_MESSAGING_09_051: [If IoTHubMessage_GetString() fails, message_create_from_iothub_message() shall fail and return.] |
AzureIoTClient | 23:2c6779675a01 | 476 | LogError("Failed getting the STRING representation of the IOTHUB_MESSAGE_HANDLE instance."); |
AzureIoTClient | 29:7e8852b14e3b | 477 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 478 | } |
AzureIoTClient | 23:2c6779675a01 | 479 | // Codes_SRS_UAMQP_MESSAGING_09_052: [If the content type of the IOTHUB_MESSAGE_HANDLE instance is IOTHUBMESSAGE_UNKNOWN, message_create_from_iothub_message() shall fail and return.] |
AzureIoTClient | 23:2c6779675a01 | 480 | else if (contentType == IOTHUBMESSAGE_UNKNOWN) |
AzureIoTClient | 23:2c6779675a01 | 481 | { |
AzureIoTClient | 23:2c6779675a01 | 482 | LogError("Cannot parse IOTHUB_MESSAGE_HANDLE with content type IOTHUBMESSAGE_UNKNOWN."); |
AzureIoTClient | 29:7e8852b14e3b | 483 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 484 | } |
AzureIoTClient | 23:2c6779675a01 | 485 | // Codes_SRS_UAMQP_MESSAGING_09_053: [A uAMQP MESSAGE_HANDLE shall be created using message_create().] |
AzureIoTClient | 23:2c6779675a01 | 486 | else if ((uamqp_message_tmp = message_create()) == NULL) |
AzureIoTClient | 23:2c6779675a01 | 487 | { |
AzureIoTClient | 23:2c6779675a01 | 488 | // Codes_SRS_UAMQP_MESSAGING_09_054: [If message_create() fails, message_create_from_iothub_message() shall fail and return.] |
AzureIoTClient | 23:2c6779675a01 | 489 | LogError("Failed allocating the uAMQP message."); |
AzureIoTClient | 29:7e8852b14e3b | 490 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 491 | } |
AzureIoTClient | 23:2c6779675a01 | 492 | else |
AzureIoTClient | 23:2c6779675a01 | 493 | { |
AzureIoTClient | 23:2c6779675a01 | 494 | // Codes_SRS_UAMQP_MESSAGING_09_055: [The IOTHUB_MESSAGE instance content bytes and size shall be stored on a BINARY_DATA structure.] |
AzureIoTClient | 23:2c6779675a01 | 495 | BINARY_DATA binary_data; |
AzureIoTClient | 23:2c6779675a01 | 496 | |
AzureIoTClient | 23:2c6779675a01 | 497 | if (contentType == IOTHUBMESSAGE_STRING) |
AzureIoTClient | 23:2c6779675a01 | 498 | { |
AzureIoTClient | 23:2c6779675a01 | 499 | messageContentSize = strlen(messageContent); |
AzureIoTClient | 23:2c6779675a01 | 500 | } |
AzureIoTClient | 23:2c6779675a01 | 501 | |
AzureIoTClient | 23:2c6779675a01 | 502 | binary_data.bytes = (const unsigned char *)messageContent; |
AzureIoTClient | 23:2c6779675a01 | 503 | binary_data.length = messageContentSize; |
AzureIoTClient | 23:2c6779675a01 | 504 | |
AzureIoTClient | 23:2c6779675a01 | 505 | // Codes_SRS_UAMQP_MESSAGING_09_056: [The BINARY_DATA instance shall be set as the uAMQP message body using message_add_body_amqp_data().] |
AzureIoTClient | 23:2c6779675a01 | 506 | if (message_add_body_amqp_data(uamqp_message_tmp, binary_data) != RESULT_OK) |
AzureIoTClient | 23:2c6779675a01 | 507 | { |
AzureIoTClient | 23:2c6779675a01 | 508 | // Codes_SRS_UAMQP_MESSAGING_09_057: [If message_add_body_amqp_data() fails, message_create_from_iothub_message() shall fail and return.] |
AzureIoTClient | 23:2c6779675a01 | 509 | LogError("Failed setting the body of the uAMQP message."); |
AzureIoTClient | 29:7e8852b14e3b | 510 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 511 | } |
AzureIoTClient | 23:2c6779675a01 | 512 | else if (addPropertiesTouAMQPMessage(iothub_message, uamqp_message_tmp) != RESULT_OK) |
AzureIoTClient | 23:2c6779675a01 | 513 | { |
AzureIoTClient | 23:2c6779675a01 | 514 | LogError("Failed setting properties of the uAMQP message."); |
AzureIoTClient | 29:7e8852b14e3b | 515 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 516 | } |
AzureIoTClient | 23:2c6779675a01 | 517 | else if (addApplicationPropertiesTouAMQPMessage(iothub_message, uamqp_message_tmp) != RESULT_OK) |
AzureIoTClient | 23:2c6779675a01 | 518 | { |
AzureIoTClient | 23:2c6779675a01 | 519 | LogError("Failed setting application properties of the uAMQP message."); |
AzureIoTClient | 29:7e8852b14e3b | 520 | result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 521 | } |
AzureIoTClient | 23:2c6779675a01 | 522 | else |
AzureIoTClient | 23:2c6779675a01 | 523 | { |
AzureIoTClient | 23:2c6779675a01 | 524 | // Codes_SRS_UAMQP_MESSAGING_09_058: [The uAMQP message created by message_create_from_iothub_message() shall be returned only if no failures occurr.] |
AzureIoTClient | 23:2c6779675a01 | 525 | *uamqp_message = uamqp_message_tmp; |
AzureIoTClient | 23:2c6779675a01 | 526 | // Codes_SRS_UAMQP_MESSAGING_09_098: [If no errors occurr, message_create_from_iothub_message() shall return 0 (success).] |
AzureIoTClient | 23:2c6779675a01 | 527 | result = RESULT_OK; |
AzureIoTClient | 23:2c6779675a01 | 528 | } |
AzureIoTClient | 23:2c6779675a01 | 529 | // Codes_SRS_UAMQP_MESSAGING_09_059: [If message_create_from_iothub_message() fails, the uAMQP message (created with message_create()) shall be destroyed.] |
AzureIoTClient | 23:2c6779675a01 | 530 | if (result != RESULT_OK) |
AzureIoTClient | 23:2c6779675a01 | 531 | { |
AzureIoTClient | 23:2c6779675a01 | 532 | message_destroy(uamqp_message_tmp); |
AzureIoTClient | 23:2c6779675a01 | 533 | } |
AzureIoTClient | 23:2c6779675a01 | 534 | } |
AzureIoTClient | 23:2c6779675a01 | 535 | |
AzureIoTClient | 23:2c6779675a01 | 536 | return result; |
AzureIoTClient | 23:2c6779675a01 | 537 | } |