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@46:c688c75b63b9, 2017-12-15 (annotated)
- Committer:
- AzureIoTClient
- Date:
- Fri Dec 15 14:08:19 2017 -0800
- Revision:
- 46:c688c75b63b9
- Parent:
- 43:3da2d93bb955
- Child:
- 50:f3a92c6c6534
1.1.29
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 | 42:c2eaa912a28c | 3 | #ifdef __cplusplus |
AzureIoTClient | 42:c2eaa912a28c | 4 | #include <cstdlib> |
AzureIoTClient | 42:c2eaa912a28c | 5 | #include <cstdint> |
AzureIoTClient | 42:c2eaa912a28c | 6 | #include <cinttypes> |
AzureIoTClient | 42:c2eaa912a28c | 7 | #else |
AzureIoTClient | 23:2c6779675a01 | 8 | #include <stdlib.h> |
AzureIoTClient | 42:c2eaa912a28c | 9 | #include <stdint.h> |
AzureIoTClient | 42:c2eaa912a28c | 10 | #include <inttypes.h> |
AzureIoTClient | 42:c2eaa912a28c | 11 | #endif |
AzureIoTClient | 42:c2eaa912a28c | 12 | |
AzureIoTClient | 23:2c6779675a01 | 13 | #include "uamqp_messaging.h" |
AzureIoTClient | 42:c2eaa912a28c | 14 | #include "azure_c_shared_utility/gballoc.h" |
AzureIoTClient | 29:7e8852b14e3b | 15 | #include "azure_c_shared_utility/optimize_size.h" |
AzureIoTClient | 23:2c6779675a01 | 16 | #include "azure_c_shared_utility/xlogging.h" |
AzureIoTClient | 42:c2eaa912a28c | 17 | #include "azure_c_shared_utility/uuid.h" |
AzureIoTClient | 23:2c6779675a01 | 18 | #include "azure_uamqp_c/message.h" |
AzureIoTClient | 23:2c6779675a01 | 19 | #include "azure_uamqp_c/amqpvalue.h" |
AzureIoTClient | 23:2c6779675a01 | 20 | #include "iothub_message.h" |
AzureIoTClient | 23:2c6779675a01 | 21 | #ifndef RESULT_OK |
AzureIoTClient | 23:2c6779675a01 | 22 | #define RESULT_OK 0 |
AzureIoTClient | 23:2c6779675a01 | 23 | #endif |
AzureIoTClient | 23:2c6779675a01 | 24 | |
AzureIoTClient | 42:c2eaa912a28c | 25 | #define MESSAGE_ID_MAX_SIZE 128 |
AzureIoTClient | 42:c2eaa912a28c | 26 | |
AzureIoTClient | 43:3da2d93bb955 | 27 | #define AMQP_DIAGNOSTIC_ID_KEY "Diagnostic-Id" |
AzureIoTClient | 43:3da2d93bb955 | 28 | #define AMQP_DIAGNOSTIC_CONTEXT_KEY "Correlation-Context" |
AzureIoTClient | 43:3da2d93bb955 | 29 | #define AMQP_DIAGNOSTIC_CREATION_TIME_UTC_KEY "creationtimeutc" |
AzureIoTClient | 43:3da2d93bb955 | 30 | |
AzureIoTClient | 41:71c01aa3df1a | 31 | static int encode_callback(void* context, const unsigned char* bytes, size_t length) |
AzureIoTClient | 23:2c6779675a01 | 32 | { |
AzureIoTClient | 41:71c01aa3df1a | 33 | BINARY_DATA* message_body_binary = (BINARY_DATA*)context; |
AzureIoTClient | 41:71c01aa3df1a | 34 | (void)memcpy((unsigned char*)message_body_binary->bytes + message_body_binary->length, bytes, length); |
AzureIoTClient | 41:71c01aa3df1a | 35 | message_body_binary->length += length; |
AzureIoTClient | 41:71c01aa3df1a | 36 | return 0; |
AzureIoTClient | 41:71c01aa3df1a | 37 | } |
AzureIoTClient | 40:e79ee1341949 | 38 | |
AzureIoTClient | 41:71c01aa3df1a | 39 | // Codes_SRS_UAMQP_MESSAGING_31_112: [If optional message-id is present in the message, encode it into the AMQP message.] |
AzureIoTClient | 41:71c01aa3df1a | 40 | static int set_message_id_if_needed(IOTHUB_MESSAGE_HANDLE messageHandle, PROPERTIES_HANDLE uamqp_message_properties) |
AzureIoTClient | 41:71c01aa3df1a | 41 | { |
AzureIoTClient | 41:71c01aa3df1a | 42 | int result; |
AzureIoTClient | 41:71c01aa3df1a | 43 | const char* messageId; |
AzureIoTClient | 23:2c6779675a01 | 44 | |
AzureIoTClient | 41:71c01aa3df1a | 45 | if (NULL != (messageId = IoTHubMessage_GetMessageId(messageHandle))) |
AzureIoTClient | 41:71c01aa3df1a | 46 | { |
AzureIoTClient | 41:71c01aa3df1a | 47 | AMQP_VALUE uamqp_message_id; |
AzureIoTClient | 23:2c6779675a01 | 48 | |
AzureIoTClient | 41:71c01aa3df1a | 49 | if ((uamqp_message_id = amqpvalue_create_string(messageId)) == NULL) |
AzureIoTClient | 41:71c01aa3df1a | 50 | { |
AzureIoTClient | 41:71c01aa3df1a | 51 | LogError("Failed amqpvalue_create_string for message_id"); |
AzureIoTClient | 41:71c01aa3df1a | 52 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 53 | } |
AzureIoTClient | 41:71c01aa3df1a | 54 | else if (properties_set_message_id(uamqp_message_properties, uamqp_message_id) != 0) |
AzureIoTClient | 40:e79ee1341949 | 55 | { |
AzureIoTClient | 41:71c01aa3df1a | 56 | LogError("Failed properties_set_message_id"); |
AzureIoTClient | 41:71c01aa3df1a | 57 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 58 | } |
AzureIoTClient | 41:71c01aa3df1a | 59 | else |
AzureIoTClient | 41:71c01aa3df1a | 60 | { |
AzureIoTClient | 41:71c01aa3df1a | 61 | result = RESULT_OK; |
AzureIoTClient | 40:e79ee1341949 | 62 | } |
AzureIoTClient | 40:e79ee1341949 | 63 | |
AzureIoTClient | 41:71c01aa3df1a | 64 | if (NULL != uamqp_message_id) |
AzureIoTClient | 40:e79ee1341949 | 65 | { |
AzureIoTClient | 41:71c01aa3df1a | 66 | amqpvalue_destroy(uamqp_message_id); |
AzureIoTClient | 41:71c01aa3df1a | 67 | } |
AzureIoTClient | 41:71c01aa3df1a | 68 | } |
AzureIoTClient | 41:71c01aa3df1a | 69 | else |
AzureIoTClient | 41:71c01aa3df1a | 70 | { |
AzureIoTClient | 41:71c01aa3df1a | 71 | result = RESULT_OK; |
AzureIoTClient | 41:71c01aa3df1a | 72 | } |
AzureIoTClient | 41:71c01aa3df1a | 73 | |
AzureIoTClient | 41:71c01aa3df1a | 74 | return result; |
AzureIoTClient | 41:71c01aa3df1a | 75 | } |
AzureIoTClient | 41:71c01aa3df1a | 76 | |
AzureIoTClient | 41:71c01aa3df1a | 77 | // Codes_SRS_UAMQP_MESSAGING_31_113: [If optional correlation-id is present in the message, encode it into the AMQP message.] |
AzureIoTClient | 41:71c01aa3df1a | 78 | static int set_message_correlation_id_if_needed(IOTHUB_MESSAGE_HANDLE messageHandle, PROPERTIES_HANDLE uamqp_message_properties) |
AzureIoTClient | 41:71c01aa3df1a | 79 | { |
AzureIoTClient | 41:71c01aa3df1a | 80 | int result; |
AzureIoTClient | 41:71c01aa3df1a | 81 | const char* correlationId; |
AzureIoTClient | 41:71c01aa3df1a | 82 | |
AzureIoTClient | 41:71c01aa3df1a | 83 | if (NULL != (correlationId = IoTHubMessage_GetCorrelationId(messageHandle))) |
AzureIoTClient | 41:71c01aa3df1a | 84 | { |
AzureIoTClient | 41:71c01aa3df1a | 85 | AMQP_VALUE uamqp_correlation_id; |
AzureIoTClient | 41:71c01aa3df1a | 86 | |
AzureIoTClient | 41:71c01aa3df1a | 87 | if ((uamqp_correlation_id = amqpvalue_create_string(correlationId)) == NULL) |
AzureIoTClient | 41:71c01aa3df1a | 88 | { |
AzureIoTClient | 41:71c01aa3df1a | 89 | LogError("Failed amqpvalue_create_string for message_id"); |
AzureIoTClient | 41:71c01aa3df1a | 90 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 91 | } |
AzureIoTClient | 41:71c01aa3df1a | 92 | else if (properties_set_correlation_id(uamqp_message_properties, uamqp_correlation_id) != 0) |
AzureIoTClient | 41:71c01aa3df1a | 93 | { |
AzureIoTClient | 41:71c01aa3df1a | 94 | LogError("Failed properties_set_correlation_id"); |
AzureIoTClient | 41:71c01aa3df1a | 95 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 96 | } |
AzureIoTClient | 41:71c01aa3df1a | 97 | else |
AzureIoTClient | 41:71c01aa3df1a | 98 | { |
AzureIoTClient | 41:71c01aa3df1a | 99 | result = RESULT_OK; |
AzureIoTClient | 40:e79ee1341949 | 100 | } |
AzureIoTClient | 40:e79ee1341949 | 101 | |
AzureIoTClient | 41:71c01aa3df1a | 102 | if (uamqp_correlation_id != NULL) |
AzureIoTClient | 41:71c01aa3df1a | 103 | { |
AzureIoTClient | 41:71c01aa3df1a | 104 | amqpvalue_destroy(uamqp_correlation_id); |
AzureIoTClient | 41:71c01aa3df1a | 105 | } |
AzureIoTClient | 41:71c01aa3df1a | 106 | } |
AzureIoTClient | 41:71c01aa3df1a | 107 | else |
AzureIoTClient | 41:71c01aa3df1a | 108 | { |
AzureIoTClient | 41:71c01aa3df1a | 109 | result = RESULT_OK; |
AzureIoTClient | 41:71c01aa3df1a | 110 | } |
AzureIoTClient | 41:71c01aa3df1a | 111 | |
AzureIoTClient | 41:71c01aa3df1a | 112 | return result; |
AzureIoTClient | 41:71c01aa3df1a | 113 | } |
AzureIoTClient | 41:71c01aa3df1a | 114 | |
AzureIoTClient | 41:71c01aa3df1a | 115 | // Codes_SRS_UAMQP_MESSAGING_31_114: [If optional content-type is present in the message, encode it into the AMQP message.] |
AzureIoTClient | 41:71c01aa3df1a | 116 | static int set_message_content_type_if_needed(IOTHUB_MESSAGE_HANDLE messageHandle, PROPERTIES_HANDLE uamqp_message_properties) |
AzureIoTClient | 41:71c01aa3df1a | 117 | { |
AzureIoTClient | 41:71c01aa3df1a | 118 | int result; |
AzureIoTClient | 41:71c01aa3df1a | 119 | const char* content_type; |
AzureIoTClient | 41:71c01aa3df1a | 120 | |
AzureIoTClient | 41:71c01aa3df1a | 121 | if ((content_type = IoTHubMessage_GetContentTypeSystemProperty(messageHandle)) != NULL) |
AzureIoTClient | 41:71c01aa3df1a | 122 | { |
AzureIoTClient | 41:71c01aa3df1a | 123 | if (properties_set_content_type(uamqp_message_properties, content_type) != 0) |
AzureIoTClient | 41:71c01aa3df1a | 124 | { |
AzureIoTClient | 41:71c01aa3df1a | 125 | LogError("Failed properties_set_content_type"); |
AzureIoTClient | 41:71c01aa3df1a | 126 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 127 | } |
AzureIoTClient | 41:71c01aa3df1a | 128 | else |
AzureIoTClient | 41:71c01aa3df1a | 129 | { |
AzureIoTClient | 41:71c01aa3df1a | 130 | result = RESULT_OK; |
AzureIoTClient | 41:71c01aa3df1a | 131 | } |
AzureIoTClient | 41:71c01aa3df1a | 132 | } |
AzureIoTClient | 41:71c01aa3df1a | 133 | else |
AzureIoTClient | 41:71c01aa3df1a | 134 | { |
AzureIoTClient | 41:71c01aa3df1a | 135 | result = RESULT_OK; |
AzureIoTClient | 41:71c01aa3df1a | 136 | } |
AzureIoTClient | 41:71c01aa3df1a | 137 | |
AzureIoTClient | 41:71c01aa3df1a | 138 | return result; |
AzureIoTClient | 41:71c01aa3df1a | 139 | } |
AzureIoTClient | 41:71c01aa3df1a | 140 | |
AzureIoTClient | 41:71c01aa3df1a | 141 | // Codes_SRS_UAMQP_MESSAGING_31_115: [If optional content-encoding is present in the message, encode it into the AMQP message.] |
AzureIoTClient | 41:71c01aa3df1a | 142 | static int set_message_content_encoding_if_needed(IOTHUB_MESSAGE_HANDLE messageHandle, PROPERTIES_HANDLE uamqp_message_properties) |
AzureIoTClient | 41:71c01aa3df1a | 143 | { |
AzureIoTClient | 41:71c01aa3df1a | 144 | int result; |
AzureIoTClient | 41:71c01aa3df1a | 145 | const char* content_encoding; |
AzureIoTClient | 23:2c6779675a01 | 146 | |
AzureIoTClient | 41:71c01aa3df1a | 147 | if ((content_encoding = IoTHubMessage_GetContentEncodingSystemProperty(messageHandle)) != NULL) |
AzureIoTClient | 41:71c01aa3df1a | 148 | { |
AzureIoTClient | 41:71c01aa3df1a | 149 | if (properties_set_content_encoding(uamqp_message_properties, content_encoding) != 0) |
AzureIoTClient | 41:71c01aa3df1a | 150 | { |
AzureIoTClient | 41:71c01aa3df1a | 151 | LogError("Failed properties_set_content_encoding"); |
AzureIoTClient | 41:71c01aa3df1a | 152 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 153 | } |
AzureIoTClient | 41:71c01aa3df1a | 154 | else |
AzureIoTClient | 41:71c01aa3df1a | 155 | { |
AzureIoTClient | 41:71c01aa3df1a | 156 | result = RESULT_OK; |
AzureIoTClient | 41:71c01aa3df1a | 157 | } |
AzureIoTClient | 41:71c01aa3df1a | 158 | } |
AzureIoTClient | 41:71c01aa3df1a | 159 | else |
AzureIoTClient | 41:71c01aa3df1a | 160 | { |
AzureIoTClient | 41:71c01aa3df1a | 161 | result = RESULT_OK; |
AzureIoTClient | 41:71c01aa3df1a | 162 | } |
AzureIoTClient | 41:71c01aa3df1a | 163 | |
AzureIoTClient | 41:71c01aa3df1a | 164 | return result; |
AzureIoTClient | 41:71c01aa3df1a | 165 | } |
AzureIoTClient | 41:71c01aa3df1a | 166 | |
AzureIoTClient | 41:71c01aa3df1a | 167 | |
AzureIoTClient | 41:71c01aa3df1a | 168 | // Codes_SRS_UAMQP_MESSAGING_31_116: [Gets message properties associated with the IOTHUB_MESSAGE_HANDLE to encode, returning the properties and their encoded length.] |
AzureIoTClient | 41:71c01aa3df1a | 169 | static int create_message_properties_to_encode(IOTHUB_MESSAGE_HANDLE messageHandle, AMQP_VALUE *message_properties, size_t *message_properties_length) |
AzureIoTClient | 41:71c01aa3df1a | 170 | { |
AzureIoTClient | 41:71c01aa3df1a | 171 | PROPERTIES_HANDLE uamqp_message_properties = NULL; |
AzureIoTClient | 41:71c01aa3df1a | 172 | int result; |
AzureIoTClient | 23:2c6779675a01 | 173 | |
AzureIoTClient | 41:71c01aa3df1a | 174 | if ((uamqp_message_properties = properties_create()) == NULL) |
AzureIoTClient | 41:71c01aa3df1a | 175 | { |
AzureIoTClient | 41:71c01aa3df1a | 176 | LogError("Failed on properties_create()"); |
AzureIoTClient | 41:71c01aa3df1a | 177 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 178 | } |
AzureIoTClient | 41:71c01aa3df1a | 179 | else if (set_message_id_if_needed(messageHandle, uamqp_message_properties) != RESULT_OK) |
AzureIoTClient | 41:71c01aa3df1a | 180 | { |
AzureIoTClient | 41:71c01aa3df1a | 181 | LogError("Failed on set_message_id_if_needed()"); |
AzureIoTClient | 41:71c01aa3df1a | 182 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 183 | } |
AzureIoTClient | 41:71c01aa3df1a | 184 | else if (set_message_correlation_id_if_needed(messageHandle, uamqp_message_properties) != RESULT_OK) |
AzureIoTClient | 41:71c01aa3df1a | 185 | { |
AzureIoTClient | 41:71c01aa3df1a | 186 | LogError("Failed on set_message_correlation_id_if_needed()"); |
AzureIoTClient | 41:71c01aa3df1a | 187 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 188 | } |
AzureIoTClient | 41:71c01aa3df1a | 189 | else if (set_message_content_type_if_needed(messageHandle, uamqp_message_properties) != RESULT_OK) |
AzureIoTClient | 41:71c01aa3df1a | 190 | { |
AzureIoTClient | 41:71c01aa3df1a | 191 | LogError("Failed on set_message_content_type_if_needed()"); |
AzureIoTClient | 41:71c01aa3df1a | 192 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 193 | } |
AzureIoTClient | 41:71c01aa3df1a | 194 | else if (set_message_content_encoding_if_needed(messageHandle, uamqp_message_properties) != RESULT_OK) |
AzureIoTClient | 41:71c01aa3df1a | 195 | { |
AzureIoTClient | 41:71c01aa3df1a | 196 | LogError("Failed on set_message_content_encoding_if_needed()"); |
AzureIoTClient | 41:71c01aa3df1a | 197 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 198 | } |
AzureIoTClient | 41:71c01aa3df1a | 199 | else if ((*message_properties = amqpvalue_create_properties(uamqp_message_properties)) == NULL) |
AzureIoTClient | 41:71c01aa3df1a | 200 | { |
AzureIoTClient | 41:71c01aa3df1a | 201 | LogError("Failed on amqpvalue_create_properties()"); |
AzureIoTClient | 41:71c01aa3df1a | 202 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 203 | } |
AzureIoTClient | 41:71c01aa3df1a | 204 | else if ((amqpvalue_get_encoded_size(*message_properties, message_properties_length)) != 0) |
AzureIoTClient | 41:71c01aa3df1a | 205 | { |
AzureIoTClient | 41:71c01aa3df1a | 206 | LogError("Failed on amqpvalue_get_encoded_size()"); |
AzureIoTClient | 41:71c01aa3df1a | 207 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 208 | } |
AzureIoTClient | 41:71c01aa3df1a | 209 | else |
AzureIoTClient | 41:71c01aa3df1a | 210 | { |
AzureIoTClient | 41:71c01aa3df1a | 211 | result = RESULT_OK; |
AzureIoTClient | 41:71c01aa3df1a | 212 | } |
AzureIoTClient | 41:71c01aa3df1a | 213 | |
AzureIoTClient | 41:71c01aa3df1a | 214 | if (NULL != uamqp_message_properties) |
AzureIoTClient | 41:71c01aa3df1a | 215 | { |
AzureIoTClient | 41:71c01aa3df1a | 216 | properties_destroy(uamqp_message_properties); |
AzureIoTClient | 41:71c01aa3df1a | 217 | } |
AzureIoTClient | 41:71c01aa3df1a | 218 | |
AzureIoTClient | 41:71c01aa3df1a | 219 | return result; |
AzureIoTClient | 23:2c6779675a01 | 220 | } |
AzureIoTClient | 23:2c6779675a01 | 221 | |
AzureIoTClient | 46:c688c75b63b9 | 222 | // Adds fault injection properties to an AMQP message. |
AzureIoTClient | 46:c688c75b63b9 | 223 | static int add_fault_injection_properties(MESSAGE_HANDLE message_batch_container, const char* const* property_keys, const char* const* property_values, size_t property_count) |
AzureIoTClient | 46:c688c75b63b9 | 224 | { |
AzureIoTClient | 46:c688c75b63b9 | 225 | int result; |
AzureIoTClient | 46:c688c75b63b9 | 226 | AMQP_VALUE uamqp_map; |
AzureIoTClient | 46:c688c75b63b9 | 227 | |
AzureIoTClient | 46:c688c75b63b9 | 228 | if ((uamqp_map = amqpvalue_create_map()) == NULL) |
AzureIoTClient | 46:c688c75b63b9 | 229 | { |
AzureIoTClient | 46:c688c75b63b9 | 230 | LogError("Failed to create uAMQP map for the properties."); |
AzureIoTClient | 46:c688c75b63b9 | 231 | result = __FAILURE__; |
AzureIoTClient | 46:c688c75b63b9 | 232 | } |
AzureIoTClient | 46:c688c75b63b9 | 233 | else |
AzureIoTClient | 46:c688c75b63b9 | 234 | { |
AzureIoTClient | 46:c688c75b63b9 | 235 | result = RESULT_OK; |
AzureIoTClient | 46:c688c75b63b9 | 236 | |
AzureIoTClient | 46:c688c75b63b9 | 237 | for (size_t i = 0; result == RESULT_OK && i < property_count; i++) |
AzureIoTClient | 46:c688c75b63b9 | 238 | { |
AzureIoTClient | 46:c688c75b63b9 | 239 | AMQP_VALUE map_key_value = NULL; |
AzureIoTClient | 46:c688c75b63b9 | 240 | AMQP_VALUE map_value_value = NULL; |
AzureIoTClient | 46:c688c75b63b9 | 241 | |
AzureIoTClient | 46:c688c75b63b9 | 242 | if ((map_key_value = amqpvalue_create_string(property_keys[i])) == NULL) |
AzureIoTClient | 46:c688c75b63b9 | 243 | { |
AzureIoTClient | 46:c688c75b63b9 | 244 | LogError("Failed to create uAMQP property key name."); |
AzureIoTClient | 46:c688c75b63b9 | 245 | result = __FAILURE__; |
AzureIoTClient | 46:c688c75b63b9 | 246 | } |
AzureIoTClient | 46:c688c75b63b9 | 247 | else if ((map_value_value = amqpvalue_create_string(property_values[i])) == NULL) |
AzureIoTClient | 46:c688c75b63b9 | 248 | { |
AzureIoTClient | 46:c688c75b63b9 | 249 | LogError("Failed to create uAMQP property key value."); |
AzureIoTClient | 46:c688c75b63b9 | 250 | result = __FAILURE__; |
AzureIoTClient | 46:c688c75b63b9 | 251 | } |
AzureIoTClient | 46:c688c75b63b9 | 252 | else if (amqpvalue_set_map_value(uamqp_map, map_key_value, map_value_value) != 0) |
AzureIoTClient | 46:c688c75b63b9 | 253 | { |
AzureIoTClient | 46:c688c75b63b9 | 254 | LogError("Failed to set key/value into the the uAMQP property map."); |
AzureIoTClient | 46:c688c75b63b9 | 255 | result = __FAILURE__; |
AzureIoTClient | 46:c688c75b63b9 | 256 | } |
AzureIoTClient | 46:c688c75b63b9 | 257 | |
AzureIoTClient | 46:c688c75b63b9 | 258 | if (map_key_value != NULL) |
AzureIoTClient | 46:c688c75b63b9 | 259 | amqpvalue_destroy(map_key_value); |
AzureIoTClient | 46:c688c75b63b9 | 260 | |
AzureIoTClient | 46:c688c75b63b9 | 261 | if (map_value_value != NULL) |
AzureIoTClient | 46:c688c75b63b9 | 262 | amqpvalue_destroy(map_value_value); |
AzureIoTClient | 46:c688c75b63b9 | 263 | } |
AzureIoTClient | 46:c688c75b63b9 | 264 | |
AzureIoTClient | 46:c688c75b63b9 | 265 | if (result == RESULT_OK) |
AzureIoTClient | 46:c688c75b63b9 | 266 | { |
AzureIoTClient | 46:c688c75b63b9 | 267 | if (message_set_application_properties(message_batch_container, uamqp_map) != 0) |
AzureIoTClient | 46:c688c75b63b9 | 268 | { |
AzureIoTClient | 46:c688c75b63b9 | 269 | LogError("Failed to transfer the message properties to the uAMQP message."); |
AzureIoTClient | 46:c688c75b63b9 | 270 | result = __FAILURE__; |
AzureIoTClient | 46:c688c75b63b9 | 271 | } |
AzureIoTClient | 46:c688c75b63b9 | 272 | else |
AzureIoTClient | 46:c688c75b63b9 | 273 | { |
AzureIoTClient | 46:c688c75b63b9 | 274 | result = RESULT_OK; |
AzureIoTClient | 46:c688c75b63b9 | 275 | } |
AzureIoTClient | 46:c688c75b63b9 | 276 | } |
AzureIoTClient | 46:c688c75b63b9 | 277 | amqpvalue_destroy(uamqp_map); |
AzureIoTClient | 46:c688c75b63b9 | 278 | } |
AzureIoTClient | 46:c688c75b63b9 | 279 | |
AzureIoTClient | 46:c688c75b63b9 | 280 | return result; |
AzureIoTClient | 46:c688c75b63b9 | 281 | } |
AzureIoTClient | 46:c688c75b63b9 | 282 | |
AzureIoTClient | 46:c688c75b63b9 | 283 | // To test AMQP fault injection, we currently must have the error properties be specified on the batch_container |
AzureIoTClient | 46:c688c75b63b9 | 284 | // (not one of the messages sent in this container). As the SDK layer does not support options for configuring |
AzureIoTClient | 46:c688c75b63b9 | 285 | // this envelope (this is AMQP/batching specific), we will instead intercept fault messages and apply to the container. |
AzureIoTClient | 46:c688c75b63b9 | 286 | static int override_fault_injection_properties_if_needed(MESSAGE_HANDLE message_batch_container, const char* const* property_keys, const char* const* property_values, size_t property_count, bool *override_for_fault_injection) |
AzureIoTClient | 46:c688c75b63b9 | 287 | { |
AzureIoTClient | 46:c688c75b63b9 | 288 | int result; |
AzureIoTClient | 46:c688c75b63b9 | 289 | |
AzureIoTClient | 46:c688c75b63b9 | 290 | if ((property_count == 0) || (strcmp(property_keys[0], "AzIoTHub_FaultOperationType") != 0)) |
AzureIoTClient | 46:c688c75b63b9 | 291 | { |
AzureIoTClient | 46:c688c75b63b9 | 292 | *override_for_fault_injection = false; |
AzureIoTClient | 46:c688c75b63b9 | 293 | result = RESULT_OK; |
AzureIoTClient | 46:c688c75b63b9 | 294 | } |
AzureIoTClient | 46:c688c75b63b9 | 295 | else |
AzureIoTClient | 46:c688c75b63b9 | 296 | { |
AzureIoTClient | 46:c688c75b63b9 | 297 | *override_for_fault_injection = true; |
AzureIoTClient | 46:c688c75b63b9 | 298 | result = add_fault_injection_properties(message_batch_container, property_keys, property_values, property_count); |
AzureIoTClient | 46:c688c75b63b9 | 299 | } |
AzureIoTClient | 46:c688c75b63b9 | 300 | |
AzureIoTClient | 46:c688c75b63b9 | 301 | return result; |
AzureIoTClient | 46:c688c75b63b9 | 302 | } |
AzureIoTClient | 46:c688c75b63b9 | 303 | |
AzureIoTClient | 41:71c01aa3df1a | 304 | // Codes_SRS_UAMQP_MESSAGING_31_117: [Get application message properties associated with the IOTHUB_MESSAGE_HANDLE to encode, returning the properties and their encoded length.] |
AzureIoTClient | 46:c688c75b63b9 | 305 | static int create_application_properties_to_encode(MESSAGE_HANDLE message_batch_container, IOTHUB_MESSAGE_HANDLE messageHandle, AMQP_VALUE *application_properties, size_t *application_properties_length) |
AzureIoTClient | 23:2c6779675a01 | 306 | { |
AzureIoTClient | 41:71c01aa3df1a | 307 | MAP_HANDLE properties_map; |
AzureIoTClient | 41:71c01aa3df1a | 308 | const char* const* property_keys; |
AzureIoTClient | 41:71c01aa3df1a | 309 | const char* const* property_values; |
AzureIoTClient | 41:71c01aa3df1a | 310 | size_t property_count = 0; |
AzureIoTClient | 41:71c01aa3df1a | 311 | AMQP_VALUE uamqp_properties_map = NULL; |
AzureIoTClient | 41:71c01aa3df1a | 312 | int result; |
AzureIoTClient | 41:71c01aa3df1a | 313 | |
AzureIoTClient | 41:71c01aa3df1a | 314 | if ((properties_map = IoTHubMessage_Properties(messageHandle)) == NULL) |
AzureIoTClient | 41:71c01aa3df1a | 315 | { |
AzureIoTClient | 41:71c01aa3df1a | 316 | LogError("Failed to get property map from IoTHub message."); |
AzureIoTClient | 41:71c01aa3df1a | 317 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 318 | } |
AzureIoTClient | 41:71c01aa3df1a | 319 | else if (Map_GetInternals(properties_map, &property_keys, &property_values, &property_count) != 0) |
AzureIoTClient | 41:71c01aa3df1a | 320 | { |
AzureIoTClient | 41:71c01aa3df1a | 321 | LogError("Failed reading the incoming uAMQP message properties"); |
AzureIoTClient | 41:71c01aa3df1a | 322 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 323 | } |
AzureIoTClient | 41:71c01aa3df1a | 324 | else if (property_count > 0) |
AzureIoTClient | 41:71c01aa3df1a | 325 | { |
AzureIoTClient | 41:71c01aa3df1a | 326 | size_t i; |
AzureIoTClient | 41:71c01aa3df1a | 327 | if ((uamqp_properties_map = amqpvalue_create_map()) == NULL) |
AzureIoTClient | 41:71c01aa3df1a | 328 | { |
AzureIoTClient | 41:71c01aa3df1a | 329 | LogError("amqpvalue_create_map failed"); |
AzureIoTClient | 41:71c01aa3df1a | 330 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 331 | } |
AzureIoTClient | 41:71c01aa3df1a | 332 | else |
AzureIoTClient | 41:71c01aa3df1a | 333 | { |
AzureIoTClient | 46:c688c75b63b9 | 334 | bool override_for_fault_injection = false; |
AzureIoTClient | 46:c688c75b63b9 | 335 | result = override_fault_injection_properties_if_needed(message_batch_container, property_keys, property_values, property_count, &override_for_fault_injection); |
AzureIoTClient | 41:71c01aa3df1a | 336 | |
AzureIoTClient | 46:c688c75b63b9 | 337 | if (override_for_fault_injection == false) |
AzureIoTClient | 41:71c01aa3df1a | 338 | { |
AzureIoTClient | 46:c688c75b63b9 | 339 | for (i = 0; i < property_count; i++) |
AzureIoTClient | 41:71c01aa3df1a | 340 | { |
AzureIoTClient | 46:c688c75b63b9 | 341 | AMQP_VALUE map_property_key; |
AzureIoTClient | 46:c688c75b63b9 | 342 | AMQP_VALUE map_property_value; |
AzureIoTClient | 46:c688c75b63b9 | 343 | |
AzureIoTClient | 46:c688c75b63b9 | 344 | if ((map_property_key = amqpvalue_create_string(property_keys[i])) == NULL) |
AzureIoTClient | 46:c688c75b63b9 | 345 | { |
AzureIoTClient | 46:c688c75b63b9 | 346 | LogError("Failed amqpvalue_create_string for key"); |
AzureIoTClient | 46:c688c75b63b9 | 347 | result = __FAILURE__; |
AzureIoTClient | 46:c688c75b63b9 | 348 | break; |
AzureIoTClient | 46:c688c75b63b9 | 349 | } |
AzureIoTClient | 23:2c6779675a01 | 350 | |
AzureIoTClient | 46:c688c75b63b9 | 351 | if ((map_property_value = amqpvalue_create_string(property_values[i])) == NULL) |
AzureIoTClient | 46:c688c75b63b9 | 352 | { |
AzureIoTClient | 46:c688c75b63b9 | 353 | LogError("Failed amqpvalue_create_string for value"); |
AzureIoTClient | 46:c688c75b63b9 | 354 | amqpvalue_destroy(map_property_key); |
AzureIoTClient | 46:c688c75b63b9 | 355 | result = __FAILURE__; |
AzureIoTClient | 46:c688c75b63b9 | 356 | break; |
AzureIoTClient | 46:c688c75b63b9 | 357 | } |
AzureIoTClient | 46:c688c75b63b9 | 358 | |
AzureIoTClient | 46:c688c75b63b9 | 359 | if (amqpvalue_set_map_value(uamqp_properties_map, map_property_key, map_property_value) != 0) |
AzureIoTClient | 46:c688c75b63b9 | 360 | { |
AzureIoTClient | 46:c688c75b63b9 | 361 | LogError("Failed amqpvalue_set_map_value"); |
AzureIoTClient | 46:c688c75b63b9 | 362 | amqpvalue_destroy(map_property_key); |
AzureIoTClient | 46:c688c75b63b9 | 363 | amqpvalue_destroy(map_property_value); |
AzureIoTClient | 46:c688c75b63b9 | 364 | result = __FAILURE__; |
AzureIoTClient | 46:c688c75b63b9 | 365 | break; |
AzureIoTClient | 46:c688c75b63b9 | 366 | } |
AzureIoTClient | 46:c688c75b63b9 | 367 | |
AzureIoTClient | 41:71c01aa3df1a | 368 | amqpvalue_destroy(map_property_key); |
AzureIoTClient | 46:c688c75b63b9 | 369 | amqpvalue_destroy(map_property_value); |
AzureIoTClient | 41:71c01aa3df1a | 370 | } |
AzureIoTClient | 41:71c01aa3df1a | 371 | |
AzureIoTClient | 46:c688c75b63b9 | 372 | if (RESULT_OK == result) |
AzureIoTClient | 41:71c01aa3df1a | 373 | { |
AzureIoTClient | 46:c688c75b63b9 | 374 | if ((*application_properties = amqpvalue_create_application_properties(uamqp_properties_map)) == NULL) |
AzureIoTClient | 46:c688c75b63b9 | 375 | { |
AzureIoTClient | 46:c688c75b63b9 | 376 | LogError("Failed amqpvalue_create_application_properties"); |
AzureIoTClient | 46:c688c75b63b9 | 377 | result = __FAILURE__; |
AzureIoTClient | 46:c688c75b63b9 | 378 | } |
AzureIoTClient | 46:c688c75b63b9 | 379 | else if (amqpvalue_get_encoded_size(*application_properties, application_properties_length) != 0) |
AzureIoTClient | 46:c688c75b63b9 | 380 | { |
AzureIoTClient | 46:c688c75b63b9 | 381 | LogError("Failed amqpvalue_get_encoded_size"); |
AzureIoTClient | 46:c688c75b63b9 | 382 | result = __FAILURE__; |
AzureIoTClient | 46:c688c75b63b9 | 383 | } |
AzureIoTClient | 41:71c01aa3df1a | 384 | } |
AzureIoTClient | 41:71c01aa3df1a | 385 | } |
AzureIoTClient | 41:71c01aa3df1a | 386 | } |
AzureIoTClient | 41:71c01aa3df1a | 387 | } |
AzureIoTClient | 41:71c01aa3df1a | 388 | else |
AzureIoTClient | 41:71c01aa3df1a | 389 | { |
AzureIoTClient | 41:71c01aa3df1a | 390 | result = RESULT_OK; |
AzureIoTClient | 41:71c01aa3df1a | 391 | } |
AzureIoTClient | 41:71c01aa3df1a | 392 | |
AzureIoTClient | 41:71c01aa3df1a | 393 | if (NULL != uamqp_properties_map) |
AzureIoTClient | 41:71c01aa3df1a | 394 | { |
AzureIoTClient | 41:71c01aa3df1a | 395 | amqpvalue_destroy(uamqp_properties_map); |
AzureIoTClient | 41:71c01aa3df1a | 396 | } |
AzureIoTClient | 41:71c01aa3df1a | 397 | |
AzureIoTClient | 41:71c01aa3df1a | 398 | return result; |
AzureIoTClient | 41:71c01aa3df1a | 399 | } |
AzureIoTClient | 41:71c01aa3df1a | 400 | |
AzureIoTClient | 43:3da2d93bb955 | 401 | static int add_map_item(AMQP_VALUE map, const char* name, const char* value) |
AzureIoTClient | 43:3da2d93bb955 | 402 | { |
AzureIoTClient | 43:3da2d93bb955 | 403 | int result; |
AzureIoTClient | 43:3da2d93bb955 | 404 | AMQP_VALUE amqp_value_name; |
AzureIoTClient | 43:3da2d93bb955 | 405 | |
AzureIoTClient | 43:3da2d93bb955 | 406 | if ((amqp_value_name = amqpvalue_create_symbol(name)) == NULL) |
AzureIoTClient | 43:3da2d93bb955 | 407 | { |
AzureIoTClient | 43:3da2d93bb955 | 408 | LogError("Failed creating AMQP_VALUE for name"); |
AzureIoTClient | 43:3da2d93bb955 | 409 | result = __FAILURE__; |
AzureIoTClient | 43:3da2d93bb955 | 410 | } |
AzureIoTClient | 43:3da2d93bb955 | 411 | else |
AzureIoTClient | 43:3da2d93bb955 | 412 | { |
AzureIoTClient | 43:3da2d93bb955 | 413 | AMQP_VALUE amqp_value_value = NULL; |
AzureIoTClient | 43:3da2d93bb955 | 414 | |
AzureIoTClient | 43:3da2d93bb955 | 415 | if (value == NULL && (amqp_value_value = amqpvalue_create_null()) == NULL) |
AzureIoTClient | 43:3da2d93bb955 | 416 | { |
AzureIoTClient | 43:3da2d93bb955 | 417 | LogError("Failed creating AMQP_VALUE for NULL value"); |
AzureIoTClient | 43:3da2d93bb955 | 418 | result = __FAILURE__; |
AzureIoTClient | 43:3da2d93bb955 | 419 | } |
AzureIoTClient | 43:3da2d93bb955 | 420 | else if (value != NULL && (amqp_value_value = amqpvalue_create_string(value)) == NULL) |
AzureIoTClient | 43:3da2d93bb955 | 421 | { |
AzureIoTClient | 43:3da2d93bb955 | 422 | LogError("Failed creating AMQP_VALUE for value"); |
AzureIoTClient | 43:3da2d93bb955 | 423 | result = __FAILURE__; |
AzureIoTClient | 43:3da2d93bb955 | 424 | } |
AzureIoTClient | 43:3da2d93bb955 | 425 | else |
AzureIoTClient | 43:3da2d93bb955 | 426 | { |
AzureIoTClient | 43:3da2d93bb955 | 427 | if (amqpvalue_set_map_value(map, amqp_value_name, amqp_value_value) != 0) |
AzureIoTClient | 43:3da2d93bb955 | 428 | { |
AzureIoTClient | 43:3da2d93bb955 | 429 | LogError("Failed adding key/value pair to map"); |
AzureIoTClient | 43:3da2d93bb955 | 430 | result = __FAILURE__; |
AzureIoTClient | 43:3da2d93bb955 | 431 | } |
AzureIoTClient | 43:3da2d93bb955 | 432 | else |
AzureIoTClient | 43:3da2d93bb955 | 433 | { |
AzureIoTClient | 43:3da2d93bb955 | 434 | result = RESULT_OK; |
AzureIoTClient | 43:3da2d93bb955 | 435 | } |
AzureIoTClient | 43:3da2d93bb955 | 436 | |
AzureIoTClient | 43:3da2d93bb955 | 437 | amqpvalue_destroy(amqp_value_value); |
AzureIoTClient | 43:3da2d93bb955 | 438 | } |
AzureIoTClient | 43:3da2d93bb955 | 439 | |
AzureIoTClient | 43:3da2d93bb955 | 440 | amqpvalue_destroy(amqp_value_name); |
AzureIoTClient | 43:3da2d93bb955 | 441 | } |
AzureIoTClient | 43:3da2d93bb955 | 442 | |
AzureIoTClient | 43:3da2d93bb955 | 443 | return result; |
AzureIoTClient | 43:3da2d93bb955 | 444 | } |
AzureIoTClient | 43:3da2d93bb955 | 445 | |
AzureIoTClient | 43:3da2d93bb955 | 446 | static int create_message_annotations_to_encode(IOTHUB_MESSAGE_HANDLE messageHandle, AMQP_VALUE *message_annotations, size_t *message_annotations_length) |
AzureIoTClient | 43:3da2d93bb955 | 447 | { |
AzureIoTClient | 43:3da2d93bb955 | 448 | AMQP_VALUE message_annotations_map = NULL; |
AzureIoTClient | 43:3da2d93bb955 | 449 | int result; |
AzureIoTClient | 43:3da2d93bb955 | 450 | const IOTHUB_MESSAGE_DIAGNOSTIC_PROPERTY_DATA* diagnosticData; |
AzureIoTClient | 43:3da2d93bb955 | 451 | |
AzureIoTClient | 43:3da2d93bb955 | 452 | if ((diagnosticData = IoTHubMessage_GetDiagnosticPropertyData(messageHandle)) != NULL && |
AzureIoTClient | 43:3da2d93bb955 | 453 | diagnosticData->diagnosticId != NULL && diagnosticData->diagnosticCreationTimeUtc != NULL) |
AzureIoTClient | 43:3da2d93bb955 | 454 | { |
AzureIoTClient | 43:3da2d93bb955 | 455 | // Codes_SRS_UAMQP_MESSAGING_32_001: [If optional diagnostic properties are present in the iot hub message, encode them into the AMQP message as annotation properties. Errors stop processing on this message.] |
AzureIoTClient | 43:3da2d93bb955 | 456 | if ((message_annotations_map = amqpvalue_create_map()) == NULL) |
AzureIoTClient | 43:3da2d93bb955 | 457 | { |
AzureIoTClient | 43:3da2d93bb955 | 458 | LogError("Failed amqpvalue_create_map for annotations"); |
AzureIoTClient | 43:3da2d93bb955 | 459 | result = __FAILURE__; |
AzureIoTClient | 43:3da2d93bb955 | 460 | } |
AzureIoTClient | 43:3da2d93bb955 | 461 | else |
AzureIoTClient | 43:3da2d93bb955 | 462 | { |
AzureIoTClient | 43:3da2d93bb955 | 463 | char* diagContextBuffer = NULL; |
AzureIoTClient | 43:3da2d93bb955 | 464 | |
AzureIoTClient | 43:3da2d93bb955 | 465 | if (add_map_item(message_annotations_map, AMQP_DIAGNOSTIC_ID_KEY, diagnosticData->diagnosticId) != RESULT_OK) |
AzureIoTClient | 43:3da2d93bb955 | 466 | { |
AzureIoTClient | 43:3da2d93bb955 | 467 | LogError("Failed adding diagnostic id"); |
AzureIoTClient | 43:3da2d93bb955 | 468 | result = __FAILURE__; |
AzureIoTClient | 43:3da2d93bb955 | 469 | } |
AzureIoTClient | 43:3da2d93bb955 | 470 | else if ((diagContextBuffer = (char*)malloc(strlen(AMQP_DIAGNOSTIC_CREATION_TIME_UTC_KEY) + 1 |
AzureIoTClient | 43:3da2d93bb955 | 471 | + strlen(diagnosticData->diagnosticCreationTimeUtc) + 1)) == NULL) |
AzureIoTClient | 43:3da2d93bb955 | 472 | { |
AzureIoTClient | 43:3da2d93bb955 | 473 | LogError("Failed malloc for diagnostic context"); |
AzureIoTClient | 43:3da2d93bb955 | 474 | result = __FAILURE__; |
AzureIoTClient | 43:3da2d93bb955 | 475 | } |
AzureIoTClient | 43:3da2d93bb955 | 476 | else if (sprintf(diagContextBuffer, "%s=%s", AMQP_DIAGNOSTIC_CREATION_TIME_UTC_KEY, diagnosticData->diagnosticCreationTimeUtc) < 0) |
AzureIoTClient | 43:3da2d93bb955 | 477 | { |
AzureIoTClient | 43:3da2d93bb955 | 478 | LogError("Failed sprintf diagnostic context"); |
AzureIoTClient | 43:3da2d93bb955 | 479 | result = __FAILURE__; |
AzureIoTClient | 43:3da2d93bb955 | 480 | } |
AzureIoTClient | 43:3da2d93bb955 | 481 | else if (add_map_item(message_annotations_map, AMQP_DIAGNOSTIC_CONTEXT_KEY, diagContextBuffer) != RESULT_OK) |
AzureIoTClient | 43:3da2d93bb955 | 482 | { |
AzureIoTClient | 43:3da2d93bb955 | 483 | LogError("Failed adding diagnostic context"); |
AzureIoTClient | 43:3da2d93bb955 | 484 | result = __FAILURE__; |
AzureIoTClient | 43:3da2d93bb955 | 485 | } |
AzureIoTClient | 43:3da2d93bb955 | 486 | else if((*message_annotations = amqpvalue_create_message_annotations(message_annotations_map)) == NULL) |
AzureIoTClient | 43:3da2d93bb955 | 487 | { |
AzureIoTClient | 43:3da2d93bb955 | 488 | LogError("Failed creating message annotations"); |
AzureIoTClient | 43:3da2d93bb955 | 489 | result = __FAILURE__; |
AzureIoTClient | 43:3da2d93bb955 | 490 | } |
AzureIoTClient | 43:3da2d93bb955 | 491 | else if (amqpvalue_get_encoded_size(*message_annotations, message_annotations_length) != 0) |
AzureIoTClient | 43:3da2d93bb955 | 492 | { |
AzureIoTClient | 43:3da2d93bb955 | 493 | LogError("Failed getting size of annotations"); |
AzureIoTClient | 43:3da2d93bb955 | 494 | result = __FAILURE__; |
AzureIoTClient | 43:3da2d93bb955 | 495 | } |
AzureIoTClient | 43:3da2d93bb955 | 496 | else |
AzureIoTClient | 43:3da2d93bb955 | 497 | { |
AzureIoTClient | 43:3da2d93bb955 | 498 | result = RESULT_OK; |
AzureIoTClient | 43:3da2d93bb955 | 499 | } |
AzureIoTClient | 43:3da2d93bb955 | 500 | |
AzureIoTClient | 43:3da2d93bb955 | 501 | free(diagContextBuffer); |
AzureIoTClient | 43:3da2d93bb955 | 502 | amqpvalue_destroy(message_annotations_map); |
AzureIoTClient | 43:3da2d93bb955 | 503 | } |
AzureIoTClient | 43:3da2d93bb955 | 504 | } |
AzureIoTClient | 43:3da2d93bb955 | 505 | else |
AzureIoTClient | 43:3da2d93bb955 | 506 | { |
AzureIoTClient | 43:3da2d93bb955 | 507 | // Codes_SRS_UAMQP_MESSAGING_32_002: [If optional diagnostic properties are not present in the iot hub message, no error should happen.] |
AzureIoTClient | 43:3da2d93bb955 | 508 | result = RESULT_OK; |
AzureIoTClient | 43:3da2d93bb955 | 509 | } |
AzureIoTClient | 43:3da2d93bb955 | 510 | |
AzureIoTClient | 43:3da2d93bb955 | 511 | return result; |
AzureIoTClient | 43:3da2d93bb955 | 512 | } |
AzureIoTClient | 41:71c01aa3df1a | 513 | |
AzureIoTClient | 41:71c01aa3df1a | 514 | // Codes_SRS_UAMQP_MESSAGING_31_118: [Gets data associated with IOTHUB_MESSAGE_HANDLE to encode, either from underlying byte array or string format.] |
AzureIoTClient | 41:71c01aa3df1a | 515 | static int create_data_to_encode(IOTHUB_MESSAGE_HANDLE messageHandle, AMQP_VALUE *data_value, size_t *data_length) |
AzureIoTClient | 41:71c01aa3df1a | 516 | { |
AzureIoTClient | 41:71c01aa3df1a | 517 | int result; |
AzureIoTClient | 41:71c01aa3df1a | 518 | |
AzureIoTClient | 41:71c01aa3df1a | 519 | IOTHUBMESSAGE_CONTENT_TYPE contentType = IoTHubMessage_GetContentType(messageHandle); |
AzureIoTClient | 41:71c01aa3df1a | 520 | const char* messageContent = NULL; |
AzureIoTClient | 41:71c01aa3df1a | 521 | size_t messageContentSize = 0; |
AzureIoTClient | 23:2c6779675a01 | 522 | |
AzureIoTClient | 41:71c01aa3df1a | 523 | if ((contentType == IOTHUBMESSAGE_BYTEARRAY) && |
AzureIoTClient | 41:71c01aa3df1a | 524 | IoTHubMessage_GetByteArray(messageHandle, (const unsigned char **)&messageContent, &messageContentSize) != IOTHUB_MESSAGE_OK) |
AzureIoTClient | 41:71c01aa3df1a | 525 | { |
AzureIoTClient | 41:71c01aa3df1a | 526 | LogError("Failed getting the BYTE array representation of the IOTHUB_MESSAGE_HANDLE instance."); |
AzureIoTClient | 41:71c01aa3df1a | 527 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 528 | } |
AzureIoTClient | 41:71c01aa3df1a | 529 | else if ((contentType == IOTHUBMESSAGE_STRING) && |
AzureIoTClient | 41:71c01aa3df1a | 530 | ((messageContent = IoTHubMessage_GetString(messageHandle)) == NULL)) |
AzureIoTClient | 41:71c01aa3df1a | 531 | { |
AzureIoTClient | 41:71c01aa3df1a | 532 | LogError("Failed getting the STRING representation of the IOTHUB_MESSAGE_HANDLE instance."); |
AzureIoTClient | 41:71c01aa3df1a | 533 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 534 | } |
AzureIoTClient | 41:71c01aa3df1a | 535 | else if (contentType == IOTHUBMESSAGE_UNKNOWN) |
AzureIoTClient | 41:71c01aa3df1a | 536 | { |
AzureIoTClient | 41:71c01aa3df1a | 537 | LogError("Cannot parse IOTHUB_MESSAGE_HANDLE with content type IOTHUBMESSAGE_UNKNOWN."); |
AzureIoTClient | 41:71c01aa3df1a | 538 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 539 | } |
AzureIoTClient | 41:71c01aa3df1a | 540 | else |
AzureIoTClient | 41:71c01aa3df1a | 541 | { |
AzureIoTClient | 41:71c01aa3df1a | 542 | if (contentType == IOTHUBMESSAGE_STRING) |
AzureIoTClient | 41:71c01aa3df1a | 543 | { |
AzureIoTClient | 41:71c01aa3df1a | 544 | messageContentSize = strlen(messageContent); |
AzureIoTClient | 41:71c01aa3df1a | 545 | } |
AzureIoTClient | 41:71c01aa3df1a | 546 | |
AzureIoTClient | 41:71c01aa3df1a | 547 | data bin_data; |
AzureIoTClient | 41:71c01aa3df1a | 548 | bin_data.bytes = (const unsigned char *)messageContent; |
AzureIoTClient | 41:71c01aa3df1a | 549 | bin_data.length = (uint32_t)messageContentSize; |
AzureIoTClient | 23:2c6779675a01 | 550 | |
AzureIoTClient | 41:71c01aa3df1a | 551 | if ((*data_value = amqpvalue_create_data(bin_data)) == NULL) |
AzureIoTClient | 41:71c01aa3df1a | 552 | { |
AzureIoTClient | 41:71c01aa3df1a | 553 | LogError("amqpvalue_create_data failed"); |
AzureIoTClient | 41:71c01aa3df1a | 554 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 555 | } |
AzureIoTClient | 41:71c01aa3df1a | 556 | else if (amqpvalue_get_encoded_size(*data_value, data_length) != 0) |
AzureIoTClient | 41:71c01aa3df1a | 557 | { |
AzureIoTClient | 41:71c01aa3df1a | 558 | LogError("amqpvalue_get_encoded_size failed"); |
AzureIoTClient | 41:71c01aa3df1a | 559 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 560 | } |
AzureIoTClient | 41:71c01aa3df1a | 561 | else |
AzureIoTClient | 41:71c01aa3df1a | 562 | { |
AzureIoTClient | 41:71c01aa3df1a | 563 | result = RESULT_OK; |
AzureIoTClient | 41:71c01aa3df1a | 564 | } |
AzureIoTClient | 41:71c01aa3df1a | 565 | } |
AzureIoTClient | 41:71c01aa3df1a | 566 | |
AzureIoTClient | 41:71c01aa3df1a | 567 | return result; |
AzureIoTClient | 41:71c01aa3df1a | 568 | } |
AzureIoTClient | 41:71c01aa3df1a | 569 | |
AzureIoTClient | 41:71c01aa3df1a | 570 | // Codes_SRS_UAMQP_MESSAGING_31_120: [Create a blob that contains AMQP encoding of IOTHUB_MESSAGE_HANDLE.] |
AzureIoTClient | 41:71c01aa3df1a | 571 | // Codes_SRS_UAMQP_MESSAGING_31_121: [Any errors during `message_create_uamqp_encoding_from_iothub_message` stop processing on this message.] |
AzureIoTClient | 46:c688c75b63b9 | 572 | int message_create_uamqp_encoding_from_iothub_message(MESSAGE_HANDLE message_batch_container, IOTHUB_MESSAGE_HANDLE message_handle, BINARY_DATA* body_binary_data) |
AzureIoTClient | 41:71c01aa3df1a | 573 | { |
AzureIoTClient | 41:71c01aa3df1a | 574 | int result; |
AzureIoTClient | 41:71c01aa3df1a | 575 | |
AzureIoTClient | 41:71c01aa3df1a | 576 | AMQP_VALUE message_properties = NULL; |
AzureIoTClient | 41:71c01aa3df1a | 577 | AMQP_VALUE application_properties = NULL; |
AzureIoTClient | 43:3da2d93bb955 | 578 | AMQP_VALUE message_annotations = NULL; |
AzureIoTClient | 41:71c01aa3df1a | 579 | AMQP_VALUE data_value = NULL; |
AzureIoTClient | 41:71c01aa3df1a | 580 | size_t message_properties_length = 0; |
AzureIoTClient | 41:71c01aa3df1a | 581 | size_t application_properties_length = 0; |
AzureIoTClient | 43:3da2d93bb955 | 582 | size_t message_annotations_length = 0; |
AzureIoTClient | 41:71c01aa3df1a | 583 | size_t data_length = 0; |
AzureIoTClient | 23:2c6779675a01 | 584 | |
AzureIoTClient | 41:71c01aa3df1a | 585 | body_binary_data->bytes = NULL; |
AzureIoTClient | 41:71c01aa3df1a | 586 | body_binary_data->length = 0; |
AzureIoTClient | 23:2c6779675a01 | 587 | |
AzureIoTClient | 41:71c01aa3df1a | 588 | if (create_message_properties_to_encode(message_handle, &message_properties, &message_properties_length) != RESULT_OK) |
AzureIoTClient | 41:71c01aa3df1a | 589 | { |
AzureIoTClient | 41:71c01aa3df1a | 590 | LogError("create_message_properties_to_encode() failed"); |
AzureIoTClient | 41:71c01aa3df1a | 591 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 592 | } |
AzureIoTClient | 46:c688c75b63b9 | 593 | else if (create_application_properties_to_encode(message_batch_container, message_handle, &application_properties, &application_properties_length) != RESULT_OK) |
AzureIoTClient | 41:71c01aa3df1a | 594 | { |
AzureIoTClient | 41:71c01aa3df1a | 595 | LogError("create_application_properties_to_encode() failed"); |
AzureIoTClient | 41:71c01aa3df1a | 596 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 597 | } |
AzureIoTClient | 43:3da2d93bb955 | 598 | else if (create_message_annotations_to_encode(message_handle, &message_annotations, &message_annotations_length) != RESULT_OK) |
AzureIoTClient | 43:3da2d93bb955 | 599 | { |
AzureIoTClient | 43:3da2d93bb955 | 600 | LogError("create_message_annotations_to_encode() failed"); |
AzureIoTClient | 43:3da2d93bb955 | 601 | result = __FAILURE__; |
AzureIoTClient | 43:3da2d93bb955 | 602 | } |
AzureIoTClient | 41:71c01aa3df1a | 603 | else if (create_data_to_encode(message_handle, &data_value, &data_length) != RESULT_OK) |
AzureIoTClient | 41:71c01aa3df1a | 604 | { |
AzureIoTClient | 41:71c01aa3df1a | 605 | LogError("create_data_to_encode() failed"); |
AzureIoTClient | 41:71c01aa3df1a | 606 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 607 | } |
AzureIoTClient | 43:3da2d93bb955 | 608 | else if ((body_binary_data->bytes = malloc(message_properties_length + application_properties_length + data_length + message_annotations_length)) == NULL) |
AzureIoTClient | 41:71c01aa3df1a | 609 | { |
AzureIoTClient | 43:3da2d93bb955 | 610 | LogError("malloc of %d bytes failed", message_properties_length + application_properties_length + data_length + message_annotations_length); |
AzureIoTClient | 41:71c01aa3df1a | 611 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 612 | } |
AzureIoTClient | 41:71c01aa3df1a | 613 | // Codes_SRS_UAMQP_MESSAGING_31_119: [Invoke underlying AMQP encode routines on data waiting to be encoded.] |
AzureIoTClient | 41:71c01aa3df1a | 614 | else if (amqpvalue_encode(message_properties, &encode_callback, body_binary_data) != RESULT_OK) |
AzureIoTClient | 41:71c01aa3df1a | 615 | { |
AzureIoTClient | 41:71c01aa3df1a | 616 | LogError("amqpvalue_encode() for message properties failed"); |
AzureIoTClient | 41:71c01aa3df1a | 617 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 618 | } |
AzureIoTClient | 41:71c01aa3df1a | 619 | else if ((application_properties_length > 0) && (amqpvalue_encode(application_properties, &encode_callback, body_binary_data) != RESULT_OK)) |
AzureIoTClient | 41:71c01aa3df1a | 620 | { |
AzureIoTClient | 41:71c01aa3df1a | 621 | LogError("amqpvalue_encode() for application properties failed"); |
AzureIoTClient | 41:71c01aa3df1a | 622 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 623 | } |
AzureIoTClient | 43:3da2d93bb955 | 624 | else if (message_annotations_length > 0 && amqpvalue_encode(message_annotations, &encode_callback, body_binary_data) != RESULT_OK) |
AzureIoTClient | 43:3da2d93bb955 | 625 | { |
AzureIoTClient | 43:3da2d93bb955 | 626 | LogError("amqpvalue_encode() for message annotations failed"); |
AzureIoTClient | 43:3da2d93bb955 | 627 | result = __FAILURE__; |
AzureIoTClient | 43:3da2d93bb955 | 628 | } |
AzureIoTClient | 41:71c01aa3df1a | 629 | else if (RESULT_OK != amqpvalue_encode(data_value, &encode_callback, body_binary_data)) |
AzureIoTClient | 41:71c01aa3df1a | 630 | { |
AzureIoTClient | 41:71c01aa3df1a | 631 | LogError("amqpvalue_encode() for data value failed"); |
AzureIoTClient | 41:71c01aa3df1a | 632 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 633 | } |
AzureIoTClient | 41:71c01aa3df1a | 634 | else |
AzureIoTClient | 41:71c01aa3df1a | 635 | { |
AzureIoTClient | 43:3da2d93bb955 | 636 | body_binary_data->length = message_properties_length + application_properties_length + data_length + message_annotations_length; |
AzureIoTClient | 41:71c01aa3df1a | 637 | result = RESULT_OK; |
AzureIoTClient | 41:71c01aa3df1a | 638 | } |
AzureIoTClient | 23:2c6779675a01 | 639 | |
AzureIoTClient | 41:71c01aa3df1a | 640 | if (NULL != data_value) |
AzureIoTClient | 41:71c01aa3df1a | 641 | { |
AzureIoTClient | 41:71c01aa3df1a | 642 | amqpvalue_destroy(data_value); |
AzureIoTClient | 41:71c01aa3df1a | 643 | } |
AzureIoTClient | 23:2c6779675a01 | 644 | |
AzureIoTClient | 41:71c01aa3df1a | 645 | if (NULL != application_properties) |
AzureIoTClient | 41:71c01aa3df1a | 646 | { |
AzureIoTClient | 41:71c01aa3df1a | 647 | amqpvalue_destroy(application_properties); |
AzureIoTClient | 41:71c01aa3df1a | 648 | } |
AzureIoTClient | 41:71c01aa3df1a | 649 | |
AzureIoTClient | 43:3da2d93bb955 | 650 | if (NULL != message_annotations) |
AzureIoTClient | 43:3da2d93bb955 | 651 | { |
AzureIoTClient | 43:3da2d93bb955 | 652 | amqpvalue_destroy(message_annotations); |
AzureIoTClient | 43:3da2d93bb955 | 653 | } |
AzureIoTClient | 43:3da2d93bb955 | 654 | |
AzureIoTClient | 41:71c01aa3df1a | 655 | if (NULL != message_properties) |
AzureIoTClient | 41:71c01aa3df1a | 656 | { |
AzureIoTClient | 41:71c01aa3df1a | 657 | amqpvalue_destroy(message_properties); |
AzureIoTClient | 41:71c01aa3df1a | 658 | } |
AzureIoTClient | 41:71c01aa3df1a | 659 | |
AzureIoTClient | 41:71c01aa3df1a | 660 | return result; |
AzureIoTClient | 23:2c6779675a01 | 661 | } |
AzureIoTClient | 23:2c6779675a01 | 662 | |
AzureIoTClient | 43:3da2d93bb955 | 663 | static int readMessageIdFromuAQMPMessage(IOTHUB_MESSAGE_HANDLE iothub_message_handle, PROPERTIES_HANDLE uamqp_message_properties) |
AzureIoTClient | 43:3da2d93bb955 | 664 | { |
AzureIoTClient | 43:3da2d93bb955 | 665 | int result; |
AzureIoTClient | 43:3da2d93bb955 | 666 | AMQP_VALUE uamqp_message_property; |
AzureIoTClient | 43:3da2d93bb955 | 667 | |
AzureIoTClient | 43:3da2d93bb955 | 668 | // Codes_SRS_UAMQP_MESSAGING_09_010: [The message-id property shall be read from the uAMQP message by calling properties_get_message_id.] |
AzureIoTClient | 43:3da2d93bb955 | 669 | if (properties_get_message_id(uamqp_message_properties, &uamqp_message_property) != 0 || uamqp_message_property == NULL) |
AzureIoTClient | 43:3da2d93bb955 | 670 | { |
AzureIoTClient | 43:3da2d93bb955 | 671 | // Codes_SRS_UAMQP_MESSAGING_09_011: [If the uAMQP message does not contain property `message ID`, it shall be skipped as it is optional.] |
AzureIoTClient | 43:3da2d93bb955 | 672 | result = RESULT_OK; |
AzureIoTClient | 43:3da2d93bb955 | 673 | } |
AzureIoTClient | 43:3da2d93bb955 | 674 | else |
AzureIoTClient | 43:3da2d93bb955 | 675 | { |
AzureIoTClient | 43:3da2d93bb955 | 676 | // Codes_SRS_UAMQP_MESSAGING_09_012: [The type of the message-id property value shall be obtained using amqpvalue_get_type().] |
AzureIoTClient | 43:3da2d93bb955 | 677 | AMQP_TYPE value_type = amqpvalue_get_type(uamqp_message_property); |
AzureIoTClient | 43:3da2d93bb955 | 678 | |
AzureIoTClient | 43:3da2d93bb955 | 679 | // Codes_SRS_UAMQP_MESSAGING_09_013: [If the type of the message-id property value is AMQP_TYPE_NULL, message_create_IoTHubMessage_from_uamqp_message() shall skip processing the message-id (as it is optional) and continue normally.] |
AzureIoTClient | 43:3da2d93bb955 | 680 | if (value_type != AMQP_TYPE_NULL) |
AzureIoTClient | 43:3da2d93bb955 | 681 | { |
AzureIoTClient | 43:3da2d93bb955 | 682 | |
AzureIoTClient | 43:3da2d93bb955 | 683 | char* string_value; |
AzureIoTClient | 43:3da2d93bb955 | 684 | char string_buffer[MESSAGE_ID_MAX_SIZE]; |
AzureIoTClient | 43:3da2d93bb955 | 685 | bool free_string_value = false; |
AzureIoTClient | 43:3da2d93bb955 | 686 | |
AzureIoTClient | 43:3da2d93bb955 | 687 | memset(string_buffer, 0, MESSAGE_ID_MAX_SIZE); |
AzureIoTClient | 43:3da2d93bb955 | 688 | |
AzureIoTClient | 43:3da2d93bb955 | 689 | if (value_type == AMQP_TYPE_STRING) |
AzureIoTClient | 43:3da2d93bb955 | 690 | { |
AzureIoTClient | 43:3da2d93bb955 | 691 | // Codes_SRS_UAMQP_MESSAGING_09_014: [The message-id value shall be retrieved from the AMQP_VALUE as char sequence] |
AzureIoTClient | 43:3da2d93bb955 | 692 | if (amqpvalue_get_string(uamqp_message_property, (const char**)(&string_value)) != 0) |
AzureIoTClient | 43:3da2d93bb955 | 693 | { |
AzureIoTClient | 43:3da2d93bb955 | 694 | // Codes_SRS_UAMQP_MESSAGING_09_015: [If message-id fails to be obtained, message_create_IoTHubMessage_from_uamqp_message() shall fail and return immediately.] |
AzureIoTClient | 43:3da2d93bb955 | 695 | LogError("Failed to get value of uAMQP message 'message-id' property (string)"); |
AzureIoTClient | 43:3da2d93bb955 | 696 | string_value = NULL; |
AzureIoTClient | 43:3da2d93bb955 | 697 | } |
AzureIoTClient | 43:3da2d93bb955 | 698 | } |
AzureIoTClient | 43:3da2d93bb955 | 699 | else if (value_type == AMQP_TYPE_ULONG) |
AzureIoTClient | 43:3da2d93bb955 | 700 | { |
AzureIoTClient | 43:3da2d93bb955 | 701 | uint64_t ulong_value; |
AzureIoTClient | 43:3da2d93bb955 | 702 | |
AzureIoTClient | 43:3da2d93bb955 | 703 | // Codes_SRS_UAMQP_MESSAGING_09_014: [The message-id value shall be retrieved from the AMQP_VALUE as char sequence] |
AzureIoTClient | 43:3da2d93bb955 | 704 | if (amqpvalue_get_ulong(uamqp_message_property, &ulong_value) != 0) |
AzureIoTClient | 43:3da2d93bb955 | 705 | { |
AzureIoTClient | 43:3da2d93bb955 | 706 | // Codes_SRS_UAMQP_MESSAGING_09_015: [If message-id fails to be obtained, message_create_IoTHubMessage_from_uamqp_message() shall fail and return immediately.] |
AzureIoTClient | 43:3da2d93bb955 | 707 | LogError("Failed to get value of uAMQP message 'message-id' property (ulong)"); |
AzureIoTClient | 43:3da2d93bb955 | 708 | string_value = NULL; |
AzureIoTClient | 43:3da2d93bb955 | 709 | } |
AzureIoTClient | 43:3da2d93bb955 | 710 | else if (sprintf(string_buffer, "%" PRIu64, ulong_value) < 0) |
AzureIoTClient | 43:3da2d93bb955 | 711 | { |
AzureIoTClient | 43:3da2d93bb955 | 712 | LogError("Failed converting 'message-id' (ulong) to string"); |
AzureIoTClient | 43:3da2d93bb955 | 713 | string_value = NULL; |
AzureIoTClient | 43:3da2d93bb955 | 714 | } |
AzureIoTClient | 43:3da2d93bb955 | 715 | else |
AzureIoTClient | 43:3da2d93bb955 | 716 | { |
AzureIoTClient | 43:3da2d93bb955 | 717 | string_value = string_buffer; |
AzureIoTClient | 43:3da2d93bb955 | 718 | } |
AzureIoTClient | 43:3da2d93bb955 | 719 | } |
AzureIoTClient | 43:3da2d93bb955 | 720 | else if (value_type == AMQP_TYPE_UUID) |
AzureIoTClient | 43:3da2d93bb955 | 721 | { |
AzureIoTClient | 43:3da2d93bb955 | 722 | uuid uuid_value; |
AzureIoTClient | 43:3da2d93bb955 | 723 | |
AzureIoTClient | 43:3da2d93bb955 | 724 | // Codes_SRS_UAMQP_MESSAGING_09_014: [The message-id value shall be retrieved from the AMQP_VALUE as char sequence] |
AzureIoTClient | 43:3da2d93bb955 | 725 | if (amqpvalue_get_uuid(uamqp_message_property, &uuid_value) != 0) |
AzureIoTClient | 43:3da2d93bb955 | 726 | { |
AzureIoTClient | 43:3da2d93bb955 | 727 | // Codes_SRS_UAMQP_MESSAGING_09_015: [If message-id fails to be obtained, message_create_IoTHubMessage_from_uamqp_message() shall fail and return immediately.] |
AzureIoTClient | 43:3da2d93bb955 | 728 | LogError("Failed to get value of uAMQP message 'message-id' property (UUID)"); |
AzureIoTClient | 43:3da2d93bb955 | 729 | string_value = NULL; |
AzureIoTClient | 43:3da2d93bb955 | 730 | } |
AzureIoTClient | 43:3da2d93bb955 | 731 | else if ((string_value = UUID_to_string((UUID*)uuid_value)) == NULL) |
AzureIoTClient | 43:3da2d93bb955 | 732 | { |
AzureIoTClient | 43:3da2d93bb955 | 733 | // Codes_SRS_UAMQP_MESSAGING_09_015: [If message-id fails to be obtained, message_create_IoTHubMessage_from_uamqp_message() shall fail and return immediately.] |
AzureIoTClient | 43:3da2d93bb955 | 734 | LogError("Failed to get the string representation of 'message-id' UUID"); |
AzureIoTClient | 43:3da2d93bb955 | 735 | string_value = NULL; |
AzureIoTClient | 43:3da2d93bb955 | 736 | } |
AzureIoTClient | 43:3da2d93bb955 | 737 | else |
AzureIoTClient | 43:3da2d93bb955 | 738 | { |
AzureIoTClient | 43:3da2d93bb955 | 739 | free_string_value = true; |
AzureIoTClient | 43:3da2d93bb955 | 740 | } |
AzureIoTClient | 43:3da2d93bb955 | 741 | } |
AzureIoTClient | 43:3da2d93bb955 | 742 | else |
AzureIoTClient | 43:3da2d93bb955 | 743 | { |
AzureIoTClient | 43:3da2d93bb955 | 744 | LogError("Unrecognized type for message-id (%d)", value_type); |
AzureIoTClient | 43:3da2d93bb955 | 745 | string_value = NULL; |
AzureIoTClient | 43:3da2d93bb955 | 746 | } |
AzureIoTClient | 43:3da2d93bb955 | 747 | |
AzureIoTClient | 43:3da2d93bb955 | 748 | if (string_value != NULL) |
AzureIoTClient | 43:3da2d93bb955 | 749 | { |
AzureIoTClient | 43:3da2d93bb955 | 750 | // 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 | 43:3da2d93bb955 | 751 | if (IoTHubMessage_SetMessageId(iothub_message_handle, string_value) != IOTHUB_MESSAGE_OK) |
AzureIoTClient | 43:3da2d93bb955 | 752 | { |
AzureIoTClient | 43:3da2d93bb955 | 753 | // Codes_SRS_UAMQP_MESSAGING_09_017: [If IoTHubMessage_SetMessageId fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.] |
AzureIoTClient | 43:3da2d93bb955 | 754 | LogError("Failed to set IOTHUB_MESSAGE_HANDLE 'message-id' property."); |
AzureIoTClient | 43:3da2d93bb955 | 755 | result = __FAILURE__; |
AzureIoTClient | 43:3da2d93bb955 | 756 | } |
AzureIoTClient | 43:3da2d93bb955 | 757 | else |
AzureIoTClient | 43:3da2d93bb955 | 758 | { |
AzureIoTClient | 43:3da2d93bb955 | 759 | result = RESULT_OK; |
AzureIoTClient | 43:3da2d93bb955 | 760 | } |
AzureIoTClient | 43:3da2d93bb955 | 761 | |
AzureIoTClient | 43:3da2d93bb955 | 762 | if (free_string_value) |
AzureIoTClient | 43:3da2d93bb955 | 763 | { |
AzureIoTClient | 43:3da2d93bb955 | 764 | // Only certain code paths allocate this. |
AzureIoTClient | 43:3da2d93bb955 | 765 | free(string_value); |
AzureIoTClient | 43:3da2d93bb955 | 766 | } |
AzureIoTClient | 43:3da2d93bb955 | 767 | } |
AzureIoTClient | 43:3da2d93bb955 | 768 | else |
AzureIoTClient | 43:3da2d93bb955 | 769 | { |
AzureIoTClient | 43:3da2d93bb955 | 770 | LogError("Unexpected null string for message-id"); |
AzureIoTClient | 43:3da2d93bb955 | 771 | result = __FAILURE__; |
AzureIoTClient | 43:3da2d93bb955 | 772 | } |
AzureIoTClient | 43:3da2d93bb955 | 773 | } |
AzureIoTClient | 43:3da2d93bb955 | 774 | else |
AzureIoTClient | 43:3da2d93bb955 | 775 | { |
AzureIoTClient | 43:3da2d93bb955 | 776 | result = RESULT_OK; |
AzureIoTClient | 43:3da2d93bb955 | 777 | } |
AzureIoTClient | 43:3da2d93bb955 | 778 | } |
AzureIoTClient | 43:3da2d93bb955 | 779 | |
AzureIoTClient | 43:3da2d93bb955 | 780 | return result; |
AzureIoTClient | 43:3da2d93bb955 | 781 | } |
AzureIoTClient | 43:3da2d93bb955 | 782 | |
AzureIoTClient | 43:3da2d93bb955 | 783 | static int readCorrelationIdFromuAQMPMessage(IOTHUB_MESSAGE_HANDLE iothub_message_handle, PROPERTIES_HANDLE uamqp_message_properties) |
AzureIoTClient | 43:3da2d93bb955 | 784 | { |
AzureIoTClient | 43:3da2d93bb955 | 785 | int result; |
AzureIoTClient | 43:3da2d93bb955 | 786 | AMQP_VALUE uamqp_message_property; |
AzureIoTClient | 43:3da2d93bb955 | 787 | |
AzureIoTClient | 43:3da2d93bb955 | 788 | // Codes_SRS_UAMQP_MESSAGING_09_018: [The correlation-id property shall be read from the uAMQP message by calling properties_get_correlation_id.] |
AzureIoTClient | 43:3da2d93bb955 | 789 | if (properties_get_correlation_id(uamqp_message_properties, &uamqp_message_property) != 0 || uamqp_message_property == NULL) |
AzureIoTClient | 43:3da2d93bb955 | 790 | { |
AzureIoTClient | 43:3da2d93bb955 | 791 | // Codes_SRS_UAMQP_MESSAGING_09_019: [If the uAMQP message does not contain property `correlation ID`, it shall be skipped as it is optional.] |
AzureIoTClient | 43:3da2d93bb955 | 792 | result = RESULT_OK; |
AzureIoTClient | 43:3da2d93bb955 | 793 | } |
AzureIoTClient | 43:3da2d93bb955 | 794 | else |
AzureIoTClient | 43:3da2d93bb955 | 795 | { |
AzureIoTClient | 43:3da2d93bb955 | 796 | // Codes_SRS_UAMQP_MESSAGING_09_020: [The type of the correlation-id property value shall be obtained using amqpvalue_get_type().] |
AzureIoTClient | 43:3da2d93bb955 | 797 | AMQP_TYPE value_type = amqpvalue_get_type(uamqp_message_property); |
AzureIoTClient | 43:3da2d93bb955 | 798 | |
AzureIoTClient | 43:3da2d93bb955 | 799 | // 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 | 43:3da2d93bb955 | 800 | if (value_type != AMQP_TYPE_NULL) |
AzureIoTClient | 43:3da2d93bb955 | 801 | { |
AzureIoTClient | 43:3da2d93bb955 | 802 | char* string_value; |
AzureIoTClient | 43:3da2d93bb955 | 803 | char string_buffer[MESSAGE_ID_MAX_SIZE]; |
AzureIoTClient | 43:3da2d93bb955 | 804 | bool free_string_value = false; |
AzureIoTClient | 43:3da2d93bb955 | 805 | |
AzureIoTClient | 43:3da2d93bb955 | 806 | memset(string_buffer, 0, MESSAGE_ID_MAX_SIZE); |
AzureIoTClient | 43:3da2d93bb955 | 807 | |
AzureIoTClient | 43:3da2d93bb955 | 808 | if (value_type == AMQP_TYPE_STRING) |
AzureIoTClient | 43:3da2d93bb955 | 809 | { |
AzureIoTClient | 43:3da2d93bb955 | 810 | // Codes_SRS_UAMQP_MESSAGING_09_022: [The correlation-id value shall be retrieved from the AMQP_VALUE as char sequence] |
AzureIoTClient | 43:3da2d93bb955 | 811 | if (amqpvalue_get_string(uamqp_message_property, (const char**)(&string_value)) != 0) |
AzureIoTClient | 43:3da2d93bb955 | 812 | { |
AzureIoTClient | 43:3da2d93bb955 | 813 | // Codes_SRS_UAMQP_MESSAGING_09_023: [If correlation-id fails to be obtained, message_create_IoTHubMessage_from_uamqp_message() shall fail and return immediately.] |
AzureIoTClient | 43:3da2d93bb955 | 814 | LogError("Failed to get value of uAMQP message 'correlation-id' property (string)"); |
AzureIoTClient | 43:3da2d93bb955 | 815 | string_value = NULL; |
AzureIoTClient | 43:3da2d93bb955 | 816 | result = __FAILURE__; |
AzureIoTClient | 43:3da2d93bb955 | 817 | } |
AzureIoTClient | 43:3da2d93bb955 | 818 | } |
AzureIoTClient | 43:3da2d93bb955 | 819 | else if (value_type == AMQP_TYPE_ULONG) |
AzureIoTClient | 43:3da2d93bb955 | 820 | { |
AzureIoTClient | 43:3da2d93bb955 | 821 | uint64_t ulong_value; |
AzureIoTClient | 43:3da2d93bb955 | 822 | |
AzureIoTClient | 43:3da2d93bb955 | 823 | // Codes_SRS_UAMQP_MESSAGING_09_022: [The correlation-id value shall be retrieved from the AMQP_VALUE as char sequence] |
AzureIoTClient | 43:3da2d93bb955 | 824 | if (amqpvalue_get_ulong(uamqp_message_property, &ulong_value) != 0) |
AzureIoTClient | 43:3da2d93bb955 | 825 | { |
AzureIoTClient | 43:3da2d93bb955 | 826 | // Codes_SRS_UAMQP_MESSAGING_09_023: [If correlation-id fails to be obtained, message_create_IoTHubMessage_from_uamqp_message() shall fail and return immediately.] |
AzureIoTClient | 43:3da2d93bb955 | 827 | LogError("Failed to get value of uAMQP message 'correlation-id' property (ulong)"); |
AzureIoTClient | 43:3da2d93bb955 | 828 | string_value = NULL; |
AzureIoTClient | 43:3da2d93bb955 | 829 | result = __FAILURE__; |
AzureIoTClient | 43:3da2d93bb955 | 830 | } |
AzureIoTClient | 43:3da2d93bb955 | 831 | else if (sprintf(string_buffer, "%" PRIu64, ulong_value) < 0) |
AzureIoTClient | 43:3da2d93bb955 | 832 | { |
AzureIoTClient | 43:3da2d93bb955 | 833 | LogError("Failed converting 'correlation-id' (ulong) to string"); |
AzureIoTClient | 43:3da2d93bb955 | 834 | string_value = NULL; |
AzureIoTClient | 43:3da2d93bb955 | 835 | result = __FAILURE__; |
AzureIoTClient | 43:3da2d93bb955 | 836 | } |
AzureIoTClient | 43:3da2d93bb955 | 837 | else |
AzureIoTClient | 43:3da2d93bb955 | 838 | { |
AzureIoTClient | 43:3da2d93bb955 | 839 | string_value = string_buffer; |
AzureIoTClient | 43:3da2d93bb955 | 840 | } |
AzureIoTClient | 43:3da2d93bb955 | 841 | } |
AzureIoTClient | 43:3da2d93bb955 | 842 | else if (value_type == AMQP_TYPE_UUID) |
AzureIoTClient | 43:3da2d93bb955 | 843 | { |
AzureIoTClient | 43:3da2d93bb955 | 844 | uuid uuid_value; |
AzureIoTClient | 43:3da2d93bb955 | 845 | |
AzureIoTClient | 43:3da2d93bb955 | 846 | // Codes_SRS_UAMQP_MESSAGING_09_022: [The correlation-id value shall be retrieved from the AMQP_VALUE as char sequence] |
AzureIoTClient | 43:3da2d93bb955 | 847 | if (amqpvalue_get_uuid(uamqp_message_property, &uuid_value) != 0) |
AzureIoTClient | 43:3da2d93bb955 | 848 | { |
AzureIoTClient | 43:3da2d93bb955 | 849 | // Codes_SRS_UAMQP_MESSAGING_09_023: [If correlation-id fails to be obtained, message_create_IoTHubMessage_from_uamqp_message() shall fail and return immediately.] |
AzureIoTClient | 43:3da2d93bb955 | 850 | LogError("Failed to get value of uAMQP message 'correlation-id' property (UUID)"); |
AzureIoTClient | 43:3da2d93bb955 | 851 | string_value = NULL; |
AzureIoTClient | 43:3da2d93bb955 | 852 | result = __FAILURE__; |
AzureIoTClient | 43:3da2d93bb955 | 853 | } |
AzureIoTClient | 43:3da2d93bb955 | 854 | else if ((string_value = UUID_to_string((UUID*)uuid_value)) == NULL) |
AzureIoTClient | 43:3da2d93bb955 | 855 | { |
AzureIoTClient | 43:3da2d93bb955 | 856 | // Codes_SRS_UAMQP_MESSAGING_09_023: [If correlation-id fails to be obtained, message_create_IoTHubMessage_from_uamqp_message() shall fail and return immediately.] |
AzureIoTClient | 43:3da2d93bb955 | 857 | LogError("Failed to get the string representation of 'correlation-id' UUID"); |
AzureIoTClient | 43:3da2d93bb955 | 858 | string_value = NULL; |
AzureIoTClient | 43:3da2d93bb955 | 859 | result = __FAILURE__; |
AzureIoTClient | 43:3da2d93bb955 | 860 | } |
AzureIoTClient | 43:3da2d93bb955 | 861 | else |
AzureIoTClient | 43:3da2d93bb955 | 862 | { |
AzureIoTClient | 43:3da2d93bb955 | 863 | free_string_value = true; |
AzureIoTClient | 43:3da2d93bb955 | 864 | } |
AzureIoTClient | 43:3da2d93bb955 | 865 | } |
AzureIoTClient | 43:3da2d93bb955 | 866 | else |
AzureIoTClient | 43:3da2d93bb955 | 867 | { |
AzureIoTClient | 43:3da2d93bb955 | 868 | LogError("Unrecognized type for correlation-id (%d)", value_type); |
AzureIoTClient | 43:3da2d93bb955 | 869 | string_value = NULL; |
AzureIoTClient | 43:3da2d93bb955 | 870 | result = __FAILURE__; |
AzureIoTClient | 43:3da2d93bb955 | 871 | } |
AzureIoTClient | 43:3da2d93bb955 | 872 | |
AzureIoTClient | 43:3da2d93bb955 | 873 | if (string_value != NULL) |
AzureIoTClient | 43:3da2d93bb955 | 874 | { |
AzureIoTClient | 43:3da2d93bb955 | 875 | // 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 | 43:3da2d93bb955 | 876 | if (IoTHubMessage_SetCorrelationId(iothub_message_handle, string_value) != IOTHUB_MESSAGE_OK) |
AzureIoTClient | 43:3da2d93bb955 | 877 | { |
AzureIoTClient | 43:3da2d93bb955 | 878 | // Codes_SRS_UAMQP_MESSAGING_09_025: [If IoTHubMessage_SetCorrelationId fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.] |
AzureIoTClient | 43:3da2d93bb955 | 879 | LogError("Failed to set IOTHUB_MESSAGE_HANDLE 'correlation-id' property."); |
AzureIoTClient | 43:3da2d93bb955 | 880 | result = __FAILURE__; |
AzureIoTClient | 43:3da2d93bb955 | 881 | } |
AzureIoTClient | 43:3da2d93bb955 | 882 | else |
AzureIoTClient | 43:3da2d93bb955 | 883 | { |
AzureIoTClient | 43:3da2d93bb955 | 884 | result = RESULT_OK; |
AzureIoTClient | 43:3da2d93bb955 | 885 | } |
AzureIoTClient | 43:3da2d93bb955 | 886 | |
AzureIoTClient | 43:3da2d93bb955 | 887 | if (free_string_value) |
AzureIoTClient | 43:3da2d93bb955 | 888 | { |
AzureIoTClient | 43:3da2d93bb955 | 889 | // Only certain code paths allocate this. |
AzureIoTClient | 43:3da2d93bb955 | 890 | free(string_value); |
AzureIoTClient | 43:3da2d93bb955 | 891 | } |
AzureIoTClient | 43:3da2d93bb955 | 892 | } |
AzureIoTClient | 43:3da2d93bb955 | 893 | else |
AzureIoTClient | 43:3da2d93bb955 | 894 | { |
AzureIoTClient | 43:3da2d93bb955 | 895 | LogError("Unexpected null string for correlation-id"); |
AzureIoTClient | 43:3da2d93bb955 | 896 | result = __FAILURE__; |
AzureIoTClient | 43:3da2d93bb955 | 897 | } |
AzureIoTClient | 43:3da2d93bb955 | 898 | } |
AzureIoTClient | 43:3da2d93bb955 | 899 | else |
AzureIoTClient | 43:3da2d93bb955 | 900 | { |
AzureIoTClient | 43:3da2d93bb955 | 901 | result = RESULT_OK; |
AzureIoTClient | 43:3da2d93bb955 | 902 | } |
AzureIoTClient | 43:3da2d93bb955 | 903 | } |
AzureIoTClient | 43:3da2d93bb955 | 904 | |
AzureIoTClient | 43:3da2d93bb955 | 905 | return result; |
AzureIoTClient | 43:3da2d93bb955 | 906 | } |
AzureIoTClient | 43:3da2d93bb955 | 907 | |
AzureIoTClient | 23:2c6779675a01 | 908 | static int readPropertiesFromuAMQPMessage(IOTHUB_MESSAGE_HANDLE iothub_message_handle, MESSAGE_HANDLE uamqp_message) |
AzureIoTClient | 23:2c6779675a01 | 909 | { |
AzureIoTClient | 42:c2eaa912a28c | 910 | int result; |
AzureIoTClient | 41:71c01aa3df1a | 911 | PROPERTIES_HANDLE uamqp_message_properties; |
AzureIoTClient | 23:2c6779675a01 | 912 | |
AzureIoTClient | 41:71c01aa3df1a | 913 | // Codes_SRS_UAMQP_MESSAGING_09_008: [The uAMQP message properties shall be retrieved using message_get_properties().] |
AzureIoTClient | 42:c2eaa912a28c | 914 | if (message_get_properties(uamqp_message, &uamqp_message_properties) != 0) |
AzureIoTClient | 41:71c01aa3df1a | 915 | { |
AzureIoTClient | 41:71c01aa3df1a | 916 | // Codes_SRS_UAMQP_MESSAGING_09_009: [If message_get_properties() fails, message_create_IoTHubMessage_from_uamqp_message shall fail and return immediately.] |
AzureIoTClient | 42:c2eaa912a28c | 917 | LogError("Failed to get property properties map from uAMQP message."); |
AzureIoTClient | 42:c2eaa912a28c | 918 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 919 | } |
AzureIoTClient | 40:e79ee1341949 | 920 | else |
AzureIoTClient | 40:e79ee1341949 | 921 | { |
AzureIoTClient | 42:c2eaa912a28c | 922 | result = RESULT_OK; // Properties 'message-id' and 'correlation-id' are optional according to the AMQP 1.0 spec. |
AzureIoTClient | 40:e79ee1341949 | 923 | |
AzureIoTClient | 43:3da2d93bb955 | 924 | if (readMessageIdFromuAQMPMessage(iothub_message_handle, uamqp_message_properties) != RESULT_OK) |
AzureIoTClient | 40:e79ee1341949 | 925 | { |
AzureIoTClient | 43:3da2d93bb955 | 926 | LogError("Failed readMessageIdFromuAQMPMessage."); |
AzureIoTClient | 43:3da2d93bb955 | 927 | result = __FAILURE__; |
AzureIoTClient | 43:3da2d93bb955 | 928 | } |
AzureIoTClient | 43:3da2d93bb955 | 929 | else if (readCorrelationIdFromuAQMPMessage(iothub_message_handle, uamqp_message_properties) != RESULT_OK) |
AzureIoTClient | 43:3da2d93bb955 | 930 | { |
AzureIoTClient | 43:3da2d93bb955 | 931 | LogError("Failed readPropertiesFromuAMQPMessage."); |
AzureIoTClient | 43:3da2d93bb955 | 932 | result = __FAILURE__; |
AzureIoTClient | 40:e79ee1341949 | 933 | } |
AzureIoTClient | 42:c2eaa912a28c | 934 | else |
AzureIoTClient | 40:e79ee1341949 | 935 | { |
AzureIoTClient | 43:3da2d93bb955 | 936 | const char* uamqp_message_property_value = NULL; |
AzureIoTClient | 42:c2eaa912a28c | 937 | |
AzureIoTClient | 43:3da2d93bb955 | 938 | // Codes_SRS_UAMQP_MESSAGING_09_100: [If the uAMQP message contains property `content-type`, it shall be set on IOTHUB_MESSAGE_HANDLE] |
AzureIoTClient | 43:3da2d93bb955 | 939 | // Codes_SRS_UAMQP_MESSAGING_31_122: [If the uAMQP message does not contain property `content-type`, it shall be skipped as it is optional] |
AzureIoTClient | 43:3da2d93bb955 | 940 | if (properties_get_content_type(uamqp_message_properties, &uamqp_message_property_value) == 0 && uamqp_message_property_value != NULL) |
AzureIoTClient | 43:3da2d93bb955 | 941 | { |
AzureIoTClient | 43:3da2d93bb955 | 942 | if (IoTHubMessage_SetContentTypeSystemProperty(iothub_message_handle, uamqp_message_property_value) != IOTHUB_MESSAGE_OK) |
AzureIoTClient | 42:c2eaa912a28c | 943 | { |
AzureIoTClient | 43:3da2d93bb955 | 944 | // Codes_SRS_UAMQP_MESSAGING_09_102: [If setting the `content-type` property on IOTHUB_MESSAGE_HANDLE fails, readPropertiesFromuAMQPMessage() shall fail and return immediately.] |
AzureIoTClient | 43:3da2d93bb955 | 945 | LogError("Failed to set IOTHUB_MESSAGE_HANDLE 'content-type' property."); |
AzureIoTClient | 42:c2eaa912a28c | 946 | result = __FAILURE__; |
AzureIoTClient | 42:c2eaa912a28c | 947 | } |
AzureIoTClient | 40:e79ee1341949 | 948 | } |
AzureIoTClient | 43:3da2d93bb955 | 949 | |
AzureIoTClient | 43:3da2d93bb955 | 950 | uamqp_message_property_value = NULL; |
AzureIoTClient | 42:c2eaa912a28c | 951 | |
AzureIoTClient | 43:3da2d93bb955 | 952 | // Codes_SRS_UAMQP_MESSAGING_09_103: [If the uAMQP message contains property `content-encoding`, it shall be set on IOTHUB_MESSAGE_HANDLE] |
AzureIoTClient | 43:3da2d93bb955 | 953 | // Codes_SRS_UAMQP_MESSAGING_31_123: [If the uAMQP message does not contain property `content-encoding`, it shall be skipped as it is optional] |
AzureIoTClient | 43:3da2d93bb955 | 954 | if (properties_get_content_encoding(uamqp_message_properties, &uamqp_message_property_value) == 0 && uamqp_message_property_value != NULL) |
AzureIoTClient | 43:3da2d93bb955 | 955 | { |
AzureIoTClient | 43:3da2d93bb955 | 956 | if (IoTHubMessage_SetContentEncodingSystemProperty(iothub_message_handle, uamqp_message_property_value) != IOTHUB_MESSAGE_OK) |
AzureIoTClient | 42:c2eaa912a28c | 957 | { |
AzureIoTClient | 43:3da2d93bb955 | 958 | // Codes_SRS_UAMQP_MESSAGING_09_105: [If setting the `content-encoding` property on IOTHUB_MESSAGE_HANDLE fails, readPropertiesFromuAMQPMessage() shall fail and return immediately.] |
AzureIoTClient | 43:3da2d93bb955 | 959 | LogError("Failed to set IOTHUB_MESSAGE_HANDLE 'content-encoding' property."); |
AzureIoTClient | 42:c2eaa912a28c | 960 | result = __FAILURE__; |
AzureIoTClient | 42:c2eaa912a28c | 961 | } |
AzureIoTClient | 40:e79ee1341949 | 962 | } |
AzureIoTClient | 40:e79ee1341949 | 963 | } |
AzureIoTClient | 42:c2eaa912a28c | 964 | |
AzureIoTClient | 41:71c01aa3df1a | 965 | // Codes_SRS_UAMQP_MESSAGING_09_026: [message_create_IoTHubMessage_from_uamqp_message() shall destroy the uAMQP message properties (obtained with message_get_properties()) by calling properties_destroy().] |
AzureIoTClient | 41:71c01aa3df1a | 966 | properties_destroy(uamqp_message_properties); |
AzureIoTClient | 41:71c01aa3df1a | 967 | } |
AzureIoTClient | 40:e79ee1341949 | 968 | |
AzureIoTClient | 42:c2eaa912a28c | 969 | return result; |
AzureIoTClient | 23:2c6779675a01 | 970 | } |
AzureIoTClient | 23:2c6779675a01 | 971 | |
AzureIoTClient | 23:2c6779675a01 | 972 | static int readApplicationPropertiesFromuAMQPMessage(IOTHUB_MESSAGE_HANDLE iothub_message_handle, MESSAGE_HANDLE uamqp_message) |
AzureIoTClient | 23:2c6779675a01 | 973 | { |
AzureIoTClient | 41:71c01aa3df1a | 974 | int result; |
AzureIoTClient | 41:71c01aa3df1a | 975 | AMQP_VALUE uamqp_app_properties = NULL; |
AzureIoTClient | 41:71c01aa3df1a | 976 | AMQP_VALUE uamqp_app_properties_ipdv = NULL; |
AzureIoTClient | 41:71c01aa3df1a | 977 | uint32_t property_count = 0; |
AzureIoTClient | 41:71c01aa3df1a | 978 | MAP_HANDLE iothub_message_properties_map; |
AzureIoTClient | 23:2c6779675a01 | 979 | |
AzureIoTClient | 41:71c01aa3df1a | 980 | // Codes_SRS_UAMQP_MESSAGING_09_027: [The IOTHUB_MESSAGE_HANDLE properties shall be retrieved using IoTHubMessage_Properties.] |
AzureIoTClient | 41:71c01aa3df1a | 981 | if ((iothub_message_properties_map = IoTHubMessage_Properties(iothub_message_handle)) == NULL) |
AzureIoTClient | 41:71c01aa3df1a | 982 | { |
AzureIoTClient | 41:71c01aa3df1a | 983 | // Codes_SRS_UAMQP_MESSAGING_09_028: [If IoTHubMessage_Properties fails, message_create_IoTHubMessage_from_uamqp_message() shall fail and return immediately.] |
AzureIoTClient | 41:71c01aa3df1a | 984 | LogError("Failed to get property map from IoTHub message."); |
AzureIoTClient | 41:71c01aa3df1a | 985 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 986 | } |
AzureIoTClient | 41:71c01aa3df1a | 987 | // Codes_SRS_UAMQP_MESSAGING_09_029: [The uAMQP message application properties shall be retrieved using message_get_application_properties.] |
AzureIoTClient | 41:71c01aa3df1a | 988 | else if ((result = message_get_application_properties(uamqp_message, &uamqp_app_properties)) != 0) |
AzureIoTClient | 41:71c01aa3df1a | 989 | { |
AzureIoTClient | 41:71c01aa3df1a | 990 | // Codes_SRS_UAMQP_MESSAGING_09_030: [If message_get_application_properties fails, message_create_IoTHubMessage_from_uamqp_message() shall fail and return immediately.] |
AzureIoTClient | 41:71c01aa3df1a | 991 | LogError("Failed reading the incoming uAMQP message properties (return code %d).", result); |
AzureIoTClient | 41:71c01aa3df1a | 992 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 993 | } |
AzureIoTClient | 41:71c01aa3df1a | 994 | else |
AzureIoTClient | 41:71c01aa3df1a | 995 | { |
AzureIoTClient | 41:71c01aa3df1a | 996 | // Codes_SRS_UAMQP_MESSAGING_09_031: [If message_get_application_properties succeeds but returns a NULL application properties map (there are no properties), message_create_IoTHubMessage_from_uamqp_message() shall skip processing the properties and continue normally.] |
AzureIoTClient | 41:71c01aa3df1a | 997 | if (uamqp_app_properties == NULL) |
AzureIoTClient | 41:71c01aa3df1a | 998 | { |
AzureIoTClient | 41:71c01aa3df1a | 999 | result = 0; |
AzureIoTClient | 41:71c01aa3df1a | 1000 | } |
AzureIoTClient | 41:71c01aa3df1a | 1001 | else |
AzureIoTClient | 41:71c01aa3df1a | 1002 | { |
AzureIoTClient | 41:71c01aa3df1a | 1003 | // 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 | 41:71c01aa3df1a | 1004 | if ((uamqp_app_properties_ipdv = amqpvalue_get_inplace_described_value(uamqp_app_properties)) == NULL) |
AzureIoTClient | 41:71c01aa3df1a | 1005 | { |
AzureIoTClient | 41:71c01aa3df1a | 1006 | // Codes_SRS_UAMQP_MESSAGING_09_033: [If amqpvalue_get_inplace_described_value fails, message_create_IoTHubMessage_from_uamqp_message() shall fail and return immediately.] |
AzureIoTClient | 41:71c01aa3df1a | 1007 | LogError("Failed getting the map of uAMQP message application properties (return code %d).", result); |
AzureIoTClient | 41:71c01aa3df1a | 1008 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 1009 | } |
AzureIoTClient | 41:71c01aa3df1a | 1010 | // 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 | 41:71c01aa3df1a | 1011 | else if ((result = amqpvalue_get_map_pair_count(uamqp_app_properties_ipdv, &property_count)) != 0) |
AzureIoTClient | 41:71c01aa3df1a | 1012 | { |
AzureIoTClient | 41:71c01aa3df1a | 1013 | // Codes_SRS_UAMQP_MESSAGING_09_035: [If amqpvalue_get_map_pair_count fails, message_create_IoTHubMessage_from_uamqp_message() shall fail and return immediately.] |
AzureIoTClient | 41:71c01aa3df1a | 1014 | LogError("Failed reading the number of values in the uAMQP property map (return code %d).", result); |
AzureIoTClient | 41:71c01aa3df1a | 1015 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 1016 | } |
AzureIoTClient | 41:71c01aa3df1a | 1017 | else |
AzureIoTClient | 41:71c01aa3df1a | 1018 | { |
AzureIoTClient | 41:71c01aa3df1a | 1019 | // Codes_SRS_UAMQP_MESSAGING_09_036: [message_create_IoTHubMessage_from_uamqp_message() shall iterate through each uAMQP application property and add it to IOTHUB_MESSAGE_HANDLE properties.] |
AzureIoTClient | 41:71c01aa3df1a | 1020 | uint32_t i; |
AzureIoTClient | 41:71c01aa3df1a | 1021 | for (i = 0; result == RESULT_OK && i < property_count; i++) |
AzureIoTClient | 41:71c01aa3df1a | 1022 | { |
AzureIoTClient | 41:71c01aa3df1a | 1023 | AMQP_VALUE map_key_name = NULL; |
AzureIoTClient | 41:71c01aa3df1a | 1024 | AMQP_VALUE map_key_value = NULL; |
AzureIoTClient | 41:71c01aa3df1a | 1025 | const char *key_name; |
AzureIoTClient | 41:71c01aa3df1a | 1026 | const char* key_value; |
AzureIoTClient | 23:2c6779675a01 | 1027 | |
AzureIoTClient | 41:71c01aa3df1a | 1028 | // Codes_SRS_UAMQP_MESSAGING_09_037: [The uAMQP application property name and value shall be obtained using amqpvalue_get_map_key_value_pair.] |
AzureIoTClient | 41:71c01aa3df1a | 1029 | if ((result = amqpvalue_get_map_key_value_pair(uamqp_app_properties_ipdv, i, &map_key_name, &map_key_value)) != 0) |
AzureIoTClient | 41:71c01aa3df1a | 1030 | { |
AzureIoTClient | 41:71c01aa3df1a | 1031 | // Codes_SRS_UAMQP_MESSAGING_09_038: [If amqpvalue_get_map_key_value_pair fails, message_create_IoTHubMessage_from_uamqp_message() shall fail and return immediately.] |
AzureIoTClient | 41:71c01aa3df1a | 1032 | LogError("Failed reading the key/value pair from the uAMQP property map (return code %d).", result); |
AzureIoTClient | 41:71c01aa3df1a | 1033 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 1034 | } |
AzureIoTClient | 23:2c6779675a01 | 1035 | |
AzureIoTClient | 41:71c01aa3df1a | 1036 | // Codes_SRS_UAMQP_MESSAGING_09_039: [The uAMQP application property name shall be extracted as string using amqpvalue_get_string.] |
AzureIoTClient | 41:71c01aa3df1a | 1037 | else if ((result = amqpvalue_get_string(map_key_name, &key_name)) != 0) |
AzureIoTClient | 41:71c01aa3df1a | 1038 | { |
AzureIoTClient | 41:71c01aa3df1a | 1039 | // Codes_SRS_UAMQP_MESSAGING_09_040: [If amqpvalue_get_string fails, message_create_IoTHubMessage_from_uamqp_message() shall fail and return immediately.] |
AzureIoTClient | 41:71c01aa3df1a | 1040 | LogError("Failed parsing the uAMQP property name (return code %d).", result); |
AzureIoTClient | 41:71c01aa3df1a | 1041 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 1042 | } |
AzureIoTClient | 41:71c01aa3df1a | 1043 | // Codes_SRS_UAMQP_MESSAGING_09_041: [The uAMQP application property value shall be extracted as string using amqpvalue_get_string.] |
AzureIoTClient | 41:71c01aa3df1a | 1044 | else if ((result = amqpvalue_get_string(map_key_value, &key_value)) != 0) |
AzureIoTClient | 41:71c01aa3df1a | 1045 | { |
AzureIoTClient | 41:71c01aa3df1a | 1046 | // Codes_SRS_UAMQP_MESSAGING_09_042: [If amqpvalue_get_string fails, message_create_IoTHubMessage_from_uamqp_message() shall fail and return immediately.] |
AzureIoTClient | 41:71c01aa3df1a | 1047 | LogError("Failed parsing the uAMQP property value (return code %d).", result); |
AzureIoTClient | 41:71c01aa3df1a | 1048 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 1049 | } |
AzureIoTClient | 41:71c01aa3df1a | 1050 | // Codes_SRS_UAMQP_MESSAGING_09_043: [The application property name and value shall be added to IOTHUB_MESSAGE_HANDLE properties using Map_AddOrUpdate.] |
AzureIoTClient | 41:71c01aa3df1a | 1051 | else if (Map_AddOrUpdate(iothub_message_properties_map, key_name, key_value) != MAP_OK) |
AzureIoTClient | 41:71c01aa3df1a | 1052 | { |
AzureIoTClient | 41:71c01aa3df1a | 1053 | // Codes_SRS_UAMQP_MESSAGING_09_044: [If Map_AddOrUpdate fails, message_create_IoTHubMessage_from_uamqp_message() shall fail and return immediately.] |
AzureIoTClient | 41:71c01aa3df1a | 1054 | LogError("Failed to add/update IoTHub message property map."); |
AzureIoTClient | 41:71c01aa3df1a | 1055 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 1056 | } |
AzureIoTClient | 23:2c6779675a01 | 1057 | |
AzureIoTClient | 41:71c01aa3df1a | 1058 | // Codes_SRS_UAMQP_MESSAGING_09_045: [message_create_IoTHubMessage_from_uamqp_message() shall destroy the uAMQP message property name and value (obtained with amqpvalue_get_string) by calling amqpvalue_destroy().] |
AzureIoTClient | 41:71c01aa3df1a | 1059 | if (map_key_name != NULL) |
AzureIoTClient | 41:71c01aa3df1a | 1060 | { |
AzureIoTClient | 41:71c01aa3df1a | 1061 | amqpvalue_destroy(map_key_name); |
AzureIoTClient | 41:71c01aa3df1a | 1062 | } |
AzureIoTClient | 23:2c6779675a01 | 1063 | |
AzureIoTClient | 41:71c01aa3df1a | 1064 | if (map_key_value != NULL) |
AzureIoTClient | 41:71c01aa3df1a | 1065 | { |
AzureIoTClient | 41:71c01aa3df1a | 1066 | amqpvalue_destroy(map_key_value); |
AzureIoTClient | 41:71c01aa3df1a | 1067 | } |
AzureIoTClient | 41:71c01aa3df1a | 1068 | } |
AzureIoTClient | 41:71c01aa3df1a | 1069 | } |
AzureIoTClient | 23:2c6779675a01 | 1070 | |
AzureIoTClient | 41:71c01aa3df1a | 1071 | // Codes_SRS_UAMQP_MESSAGING_09_046: [message_create_IoTHubMessage_from_uamqp_message() shall destroy the uAMQP message property (obtained with message_get_application_properties) by calling amqpvalue_destroy().] |
AzureIoTClient | 41:71c01aa3df1a | 1072 | amqpvalue_destroy(uamqp_app_properties); |
AzureIoTClient | 41:71c01aa3df1a | 1073 | } |
AzureIoTClient | 41:71c01aa3df1a | 1074 | } |
AzureIoTClient | 23:2c6779675a01 | 1075 | |
AzureIoTClient | 41:71c01aa3df1a | 1076 | return result; |
AzureIoTClient | 23:2c6779675a01 | 1077 | } |
AzureIoTClient | 23:2c6779675a01 | 1078 | |
AzureIoTClient | 41:71c01aa3df1a | 1079 | int message_create_IoTHubMessage_from_uamqp_message(MESSAGE_HANDLE uamqp_message, IOTHUB_MESSAGE_HANDLE* iothubclient_message) |
AzureIoTClient | 23:2c6779675a01 | 1080 | { |
AzureIoTClient | 41:71c01aa3df1a | 1081 | int result = __FAILURE__; |
AzureIoTClient | 23:2c6779675a01 | 1082 | |
AzureIoTClient | 41:71c01aa3df1a | 1083 | IOTHUB_MESSAGE_HANDLE iothub_message = NULL; |
AzureIoTClient | 41:71c01aa3df1a | 1084 | MESSAGE_BODY_TYPE body_type; |
AzureIoTClient | 23:2c6779675a01 | 1085 | |
AzureIoTClient | 41:71c01aa3df1a | 1086 | // Codes_SRS_UAMQP_MESSAGING_09_001: [The body type of the uAMQP message shall be retrieved using message_get_body_type().] |
AzureIoTClient | 41:71c01aa3df1a | 1087 | if (message_get_body_type(uamqp_message, &body_type) != 0) |
AzureIoTClient | 41:71c01aa3df1a | 1088 | { |
AzureIoTClient | 41:71c01aa3df1a | 1089 | // Codes_SRS_UAMQP_MESSAGING_09_002: [If message_get_body_type() fails, message_create_IoTHubMessage_from_uamqp_message shall fail and return immediately.] |
AzureIoTClient | 41:71c01aa3df1a | 1090 | LogError("Failed to get the type of the uamqp message."); |
AzureIoTClient | 41:71c01aa3df1a | 1091 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 1092 | } |
AzureIoTClient | 41:71c01aa3df1a | 1093 | else |
AzureIoTClient | 41:71c01aa3df1a | 1094 | { |
AzureIoTClient | 41:71c01aa3df1a | 1095 | // 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 | 41:71c01aa3df1a | 1096 | if (body_type == MESSAGE_BODY_TYPE_DATA) |
AzureIoTClient | 41:71c01aa3df1a | 1097 | { |
AzureIoTClient | 41:71c01aa3df1a | 1098 | // Codes_SRS_UAMQP_MESSAGING_09_004: [The uAMQP message body data shall be retrieved using message_get_body_amqp_data().] |
AzureIoTClient | 41:71c01aa3df1a | 1099 | BINARY_DATA binary_data; |
AzureIoTClient | 41:71c01aa3df1a | 1100 | if (message_get_body_amqp_data_in_place(uamqp_message, 0, &binary_data) != 0) |
AzureIoTClient | 41:71c01aa3df1a | 1101 | { |
AzureIoTClient | 41:71c01aa3df1a | 1102 | // Codes_SRS_UAMQP_MESSAGING_09_005: [If message_get_body_amqp_data() fails, message_create_IoTHubMessage_from_uamqp_message shall fail and return immediately.] |
AzureIoTClient | 41:71c01aa3df1a | 1103 | LogError("Failed to get the body of the uamqp message."); |
AzureIoTClient | 41:71c01aa3df1a | 1104 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 1105 | } |
AzureIoTClient | 41:71c01aa3df1a | 1106 | // Codes_SRS_UAMQP_MESSAGING_09_006: [The IOTHUB_MESSAGE instance shall be created using IoTHubMessage_CreateFromByteArray(), passing the uAMQP body bytes as parameter.] |
AzureIoTClient | 41:71c01aa3df1a | 1107 | else if ((iothub_message = IoTHubMessage_CreateFromByteArray(binary_data.bytes, binary_data.length)) == NULL) |
AzureIoTClient | 41:71c01aa3df1a | 1108 | { |
AzureIoTClient | 41:71c01aa3df1a | 1109 | // Codes_SRS_UAMQP_MESSAGING_09_007: [If IoTHubMessage_CreateFromByteArray() fails, message_create_IoTHubMessage_from_uamqp_message shall fail and return immediately.] |
AzureIoTClient | 41:71c01aa3df1a | 1110 | LogError("Failed creating the IOTHUB_MESSAGE_HANDLE instance (IoTHubMessage_CreateFromByteArray failed)."); |
AzureIoTClient | 41:71c01aa3df1a | 1111 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 1112 | } |
AzureIoTClient | 41:71c01aa3df1a | 1113 | } |
AzureIoTClient | 41:71c01aa3df1a | 1114 | } |
AzureIoTClient | 23:2c6779675a01 | 1115 | |
AzureIoTClient | 41:71c01aa3df1a | 1116 | if (iothub_message != NULL) |
AzureIoTClient | 41:71c01aa3df1a | 1117 | { |
AzureIoTClient | 41:71c01aa3df1a | 1118 | if (readPropertiesFromuAMQPMessage(iothub_message, uamqp_message) != RESULT_OK) |
AzureIoTClient | 41:71c01aa3df1a | 1119 | { |
AzureIoTClient | 41:71c01aa3df1a | 1120 | LogError("Failed reading properties of the uamqp message."); |
AzureIoTClient | 41:71c01aa3df1a | 1121 | IoTHubMessage_Destroy(iothub_message); |
AzureIoTClient | 41:71c01aa3df1a | 1122 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 1123 | } |
AzureIoTClient | 41:71c01aa3df1a | 1124 | else if (readApplicationPropertiesFromuAMQPMessage(iothub_message, uamqp_message) != RESULT_OK) |
AzureIoTClient | 41:71c01aa3df1a | 1125 | { |
AzureIoTClient | 41:71c01aa3df1a | 1126 | LogError("Failed reading application properties of the uamqp message."); |
AzureIoTClient | 41:71c01aa3df1a | 1127 | IoTHubMessage_Destroy(iothub_message); |
AzureIoTClient | 41:71c01aa3df1a | 1128 | result = __FAILURE__; |
AzureIoTClient | 41:71c01aa3df1a | 1129 | } |
AzureIoTClient | 41:71c01aa3df1a | 1130 | else |
AzureIoTClient | 41:71c01aa3df1a | 1131 | { |
AzureIoTClient | 41:71c01aa3df1a | 1132 | *iothubclient_message = iothub_message; |
AzureIoTClient | 41:71c01aa3df1a | 1133 | result = RESULT_OK; |
AzureIoTClient | 41:71c01aa3df1a | 1134 | } |
AzureIoTClient | 41:71c01aa3df1a | 1135 | } |
AzureIoTClient | 23:2c6779675a01 | 1136 | |
AzureIoTClient | 41:71c01aa3df1a | 1137 | return result; |
AzureIoTClient | 23:2c6779675a01 | 1138 | } |
AzureIoTClient | 23:2c6779675a01 | 1139 |