Azure IoT / iothub_amqp_transport

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@43:3da2d93bb955, 2017-10-21 (annotated)

Committer:
AzureIoTClient
Date:
Sat Oct 21 20:10:24 2017 +0000
Revision:
43:3da2d93bb955
Parent:
42:c2eaa912a28c
Child:
46:c688c75b63b9
1.1.26

Who changed what in which revision?

UserRevisionLine numberNew 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 41:71c01aa3df1a 222 // 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 41:71c01aa3df1a 223 static int create_application_properties_to_encode(IOTHUB_MESSAGE_HANDLE messageHandle, AMQP_VALUE *application_properties, size_t *application_properties_length)
AzureIoTClient 23:2c6779675a01 224 {
AzureIoTClient 41:71c01aa3df1a 225 MAP_HANDLE properties_map;
AzureIoTClient 41:71c01aa3df1a 226 const char* const* property_keys;
AzureIoTClient 41:71c01aa3df1a 227 const char* const* property_values;
AzureIoTClient 41:71c01aa3df1a 228 size_t property_count = 0;
AzureIoTClient 41:71c01aa3df1a 229 AMQP_VALUE uamqp_properties_map = NULL;
AzureIoTClient 41:71c01aa3df1a 230 int result;
AzureIoTClient 41:71c01aa3df1a 231
AzureIoTClient 41:71c01aa3df1a 232 if ((properties_map = IoTHubMessage_Properties(messageHandle)) == NULL)
AzureIoTClient 41:71c01aa3df1a 233 {
AzureIoTClient 41:71c01aa3df1a 234 LogError("Failed to get property map from IoTHub message.");
AzureIoTClient 41:71c01aa3df1a 235 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 236 }
AzureIoTClient 41:71c01aa3df1a 237 else if (Map_GetInternals(properties_map, &property_keys, &property_values, &property_count) != 0)
AzureIoTClient 41:71c01aa3df1a 238 {
AzureIoTClient 41:71c01aa3df1a 239 LogError("Failed reading the incoming uAMQP message properties");
AzureIoTClient 41:71c01aa3df1a 240 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 241 }
AzureIoTClient 41:71c01aa3df1a 242 else if (property_count > 0)
AzureIoTClient 41:71c01aa3df1a 243 {
AzureIoTClient 41:71c01aa3df1a 244 size_t i;
AzureIoTClient 41:71c01aa3df1a 245 if ((uamqp_properties_map = amqpvalue_create_map()) == NULL)
AzureIoTClient 41:71c01aa3df1a 246 {
AzureIoTClient 41:71c01aa3df1a 247 LogError("amqpvalue_create_map failed");
AzureIoTClient 41:71c01aa3df1a 248 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 249 }
AzureIoTClient 41:71c01aa3df1a 250 else
AzureIoTClient 41:71c01aa3df1a 251 {
AzureIoTClient 41:71c01aa3df1a 252 result = RESULT_OK;
AzureIoTClient 41:71c01aa3df1a 253
AzureIoTClient 41:71c01aa3df1a 254 for (i = 0; i < property_count; i++)
AzureIoTClient 41:71c01aa3df1a 255 {
AzureIoTClient 41:71c01aa3df1a 256 AMQP_VALUE map_property_key;
AzureIoTClient 41:71c01aa3df1a 257 AMQP_VALUE map_property_value;
AzureIoTClient 41:71c01aa3df1a 258
AzureIoTClient 41:71c01aa3df1a 259 if ((map_property_key = amqpvalue_create_string(property_keys[i])) == NULL)
AzureIoTClient 41:71c01aa3df1a 260 {
AzureIoTClient 41:71c01aa3df1a 261 LogError("Failed amqpvalue_create_string for key");
AzureIoTClient 41:71c01aa3df1a 262 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 263 break;
AzureIoTClient 41:71c01aa3df1a 264 }
AzureIoTClient 23:2c6779675a01 265
AzureIoTClient 41:71c01aa3df1a 266 if ((map_property_value = amqpvalue_create_string(property_values[i])) == NULL)
AzureIoTClient 41:71c01aa3df1a 267 {
AzureIoTClient 41:71c01aa3df1a 268 LogError("Failed amqpvalue_create_string for value");
AzureIoTClient 41:71c01aa3df1a 269 amqpvalue_destroy(map_property_key);
AzureIoTClient 41:71c01aa3df1a 270 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 271 break;
AzureIoTClient 41:71c01aa3df1a 272 }
AzureIoTClient 41:71c01aa3df1a 273
AzureIoTClient 41:71c01aa3df1a 274 if (amqpvalue_set_map_value(uamqp_properties_map, map_property_key, map_property_value) != 0)
AzureIoTClient 41:71c01aa3df1a 275 {
AzureIoTClient 41:71c01aa3df1a 276 LogError("Failed amqpvalue_set_map_value");
AzureIoTClient 41:71c01aa3df1a 277 amqpvalue_destroy(map_property_key);
AzureIoTClient 41:71c01aa3df1a 278 amqpvalue_destroy(map_property_value);
AzureIoTClient 41:71c01aa3df1a 279 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 280 break;
AzureIoTClient 41:71c01aa3df1a 281 }
AzureIoTClient 41:71c01aa3df1a 282
AzureIoTClient 41:71c01aa3df1a 283 amqpvalue_destroy(map_property_key);
AzureIoTClient 41:71c01aa3df1a 284 amqpvalue_destroy(map_property_value);
AzureIoTClient 41:71c01aa3df1a 285 }
AzureIoTClient 23:2c6779675a01 286
AzureIoTClient 41:71c01aa3df1a 287 if (RESULT_OK == result)
AzureIoTClient 41:71c01aa3df1a 288 {
AzureIoTClient 41:71c01aa3df1a 289 if ((*application_properties = amqpvalue_create_application_properties(uamqp_properties_map)) == NULL)
AzureIoTClient 41:71c01aa3df1a 290 {
AzureIoTClient 41:71c01aa3df1a 291 LogError("Failed amqpvalue_create_application_properties");
AzureIoTClient 41:71c01aa3df1a 292 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 293 }
AzureIoTClient 41:71c01aa3df1a 294 else if (amqpvalue_get_encoded_size(*application_properties, application_properties_length) != 0)
AzureIoTClient 41:71c01aa3df1a 295 {
AzureIoTClient 41:71c01aa3df1a 296 LogError("Failed amqpvalue_get_encoded_size");
AzureIoTClient 41:71c01aa3df1a 297 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 298 }
AzureIoTClient 41:71c01aa3df1a 299 }
AzureIoTClient 41:71c01aa3df1a 300 }
AzureIoTClient 41:71c01aa3df1a 301 }
AzureIoTClient 41:71c01aa3df1a 302 else
AzureIoTClient 41:71c01aa3df1a 303 {
AzureIoTClient 41:71c01aa3df1a 304 result = RESULT_OK;
AzureIoTClient 41:71c01aa3df1a 305 }
AzureIoTClient 41:71c01aa3df1a 306
AzureIoTClient 41:71c01aa3df1a 307 if (NULL != uamqp_properties_map)
AzureIoTClient 41:71c01aa3df1a 308 {
AzureIoTClient 41:71c01aa3df1a 309 amqpvalue_destroy(uamqp_properties_map);
AzureIoTClient 41:71c01aa3df1a 310 }
AzureIoTClient 41:71c01aa3df1a 311
AzureIoTClient 41:71c01aa3df1a 312 return result;
AzureIoTClient 41:71c01aa3df1a 313 }
AzureIoTClient 41:71c01aa3df1a 314
AzureIoTClient 43:3da2d93bb955 315 static int add_map_item(AMQP_VALUE map, const char* name, const char* value)
AzureIoTClient 43:3da2d93bb955 316 {
AzureIoTClient 43:3da2d93bb955 317 int result;
AzureIoTClient 43:3da2d93bb955 318 AMQP_VALUE amqp_value_name;
AzureIoTClient 43:3da2d93bb955 319
AzureIoTClient 43:3da2d93bb955 320 if ((amqp_value_name = amqpvalue_create_symbol(name)) == NULL)
AzureIoTClient 43:3da2d93bb955 321 {
AzureIoTClient 43:3da2d93bb955 322 LogError("Failed creating AMQP_VALUE for name");
AzureIoTClient 43:3da2d93bb955 323 result = __FAILURE__;
AzureIoTClient 43:3da2d93bb955 324 }
AzureIoTClient 43:3da2d93bb955 325 else
AzureIoTClient 43:3da2d93bb955 326 {
AzureIoTClient 43:3da2d93bb955 327 AMQP_VALUE amqp_value_value = NULL;
AzureIoTClient 43:3da2d93bb955 328
AzureIoTClient 43:3da2d93bb955 329 if (value == NULL && (amqp_value_value = amqpvalue_create_null()) == NULL)
AzureIoTClient 43:3da2d93bb955 330 {
AzureIoTClient 43:3da2d93bb955 331 LogError("Failed creating AMQP_VALUE for NULL value");
AzureIoTClient 43:3da2d93bb955 332 result = __FAILURE__;
AzureIoTClient 43:3da2d93bb955 333 }
AzureIoTClient 43:3da2d93bb955 334 else if (value != NULL && (amqp_value_value = amqpvalue_create_string(value)) == NULL)
AzureIoTClient 43:3da2d93bb955 335 {
AzureIoTClient 43:3da2d93bb955 336 LogError("Failed creating AMQP_VALUE for value");
AzureIoTClient 43:3da2d93bb955 337 result = __FAILURE__;
AzureIoTClient 43:3da2d93bb955 338 }
AzureIoTClient 43:3da2d93bb955 339 else
AzureIoTClient 43:3da2d93bb955 340 {
AzureIoTClient 43:3da2d93bb955 341 if (amqpvalue_set_map_value(map, amqp_value_name, amqp_value_value) != 0)
AzureIoTClient 43:3da2d93bb955 342 {
AzureIoTClient 43:3da2d93bb955 343 LogError("Failed adding key/value pair to map");
AzureIoTClient 43:3da2d93bb955 344 result = __FAILURE__;
AzureIoTClient 43:3da2d93bb955 345 }
AzureIoTClient 43:3da2d93bb955 346 else
AzureIoTClient 43:3da2d93bb955 347 {
AzureIoTClient 43:3da2d93bb955 348 result = RESULT_OK;
AzureIoTClient 43:3da2d93bb955 349 }
AzureIoTClient 43:3da2d93bb955 350
AzureIoTClient 43:3da2d93bb955 351 amqpvalue_destroy(amqp_value_value);
AzureIoTClient 43:3da2d93bb955 352 }
AzureIoTClient 43:3da2d93bb955 353
AzureIoTClient 43:3da2d93bb955 354 amqpvalue_destroy(amqp_value_name);
AzureIoTClient 43:3da2d93bb955 355 }
AzureIoTClient 43:3da2d93bb955 356
AzureIoTClient 43:3da2d93bb955 357 return result;
AzureIoTClient 43:3da2d93bb955 358 }
AzureIoTClient 43:3da2d93bb955 359
AzureIoTClient 43:3da2d93bb955 360 static int create_message_annotations_to_encode(IOTHUB_MESSAGE_HANDLE messageHandle, AMQP_VALUE *message_annotations, size_t *message_annotations_length)
AzureIoTClient 43:3da2d93bb955 361 {
AzureIoTClient 43:3da2d93bb955 362 AMQP_VALUE message_annotations_map = NULL;
AzureIoTClient 43:3da2d93bb955 363 int result;
AzureIoTClient 43:3da2d93bb955 364 const IOTHUB_MESSAGE_DIAGNOSTIC_PROPERTY_DATA* diagnosticData;
AzureIoTClient 43:3da2d93bb955 365
AzureIoTClient 43:3da2d93bb955 366 if ((diagnosticData = IoTHubMessage_GetDiagnosticPropertyData(messageHandle)) != NULL &&
AzureIoTClient 43:3da2d93bb955 367 diagnosticData->diagnosticId != NULL && diagnosticData->diagnosticCreationTimeUtc != NULL)
AzureIoTClient 43:3da2d93bb955 368 {
AzureIoTClient 43:3da2d93bb955 369 // 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 370 if ((message_annotations_map = amqpvalue_create_map()) == NULL)
AzureIoTClient 43:3da2d93bb955 371 {
AzureIoTClient 43:3da2d93bb955 372 LogError("Failed amqpvalue_create_map for annotations");
AzureIoTClient 43:3da2d93bb955 373 result = __FAILURE__;
AzureIoTClient 43:3da2d93bb955 374 }
AzureIoTClient 43:3da2d93bb955 375 else
AzureIoTClient 43:3da2d93bb955 376 {
AzureIoTClient 43:3da2d93bb955 377 char* diagContextBuffer = NULL;
AzureIoTClient 43:3da2d93bb955 378
AzureIoTClient 43:3da2d93bb955 379 if (add_map_item(message_annotations_map, AMQP_DIAGNOSTIC_ID_KEY, diagnosticData->diagnosticId) != RESULT_OK)
AzureIoTClient 43:3da2d93bb955 380 {
AzureIoTClient 43:3da2d93bb955 381 LogError("Failed adding diagnostic id");
AzureIoTClient 43:3da2d93bb955 382 result = __FAILURE__;
AzureIoTClient 43:3da2d93bb955 383 }
AzureIoTClient 43:3da2d93bb955 384 else if ((diagContextBuffer = (char*)malloc(strlen(AMQP_DIAGNOSTIC_CREATION_TIME_UTC_KEY) + 1
AzureIoTClient 43:3da2d93bb955 385 + strlen(diagnosticData->diagnosticCreationTimeUtc) + 1)) == NULL)
AzureIoTClient 43:3da2d93bb955 386 {
AzureIoTClient 43:3da2d93bb955 387 LogError("Failed malloc for diagnostic context");
AzureIoTClient 43:3da2d93bb955 388 result = __FAILURE__;
AzureIoTClient 43:3da2d93bb955 389 }
AzureIoTClient 43:3da2d93bb955 390 else if (sprintf(diagContextBuffer, "%s=%s", AMQP_DIAGNOSTIC_CREATION_TIME_UTC_KEY, diagnosticData->diagnosticCreationTimeUtc) < 0)
AzureIoTClient 43:3da2d93bb955 391 {
AzureIoTClient 43:3da2d93bb955 392 LogError("Failed sprintf diagnostic context");
AzureIoTClient 43:3da2d93bb955 393 result = __FAILURE__;
AzureIoTClient 43:3da2d93bb955 394 }
AzureIoTClient 43:3da2d93bb955 395 else if (add_map_item(message_annotations_map, AMQP_DIAGNOSTIC_CONTEXT_KEY, diagContextBuffer) != RESULT_OK)
AzureIoTClient 43:3da2d93bb955 396 {
AzureIoTClient 43:3da2d93bb955 397 LogError("Failed adding diagnostic context");
AzureIoTClient 43:3da2d93bb955 398 result = __FAILURE__;
AzureIoTClient 43:3da2d93bb955 399 }
AzureIoTClient 43:3da2d93bb955 400 else if((*message_annotations = amqpvalue_create_message_annotations(message_annotations_map)) == NULL)
AzureIoTClient 43:3da2d93bb955 401 {
AzureIoTClient 43:3da2d93bb955 402 LogError("Failed creating message annotations");
AzureIoTClient 43:3da2d93bb955 403 result = __FAILURE__;
AzureIoTClient 43:3da2d93bb955 404 }
AzureIoTClient 43:3da2d93bb955 405 else if (amqpvalue_get_encoded_size(*message_annotations, message_annotations_length) != 0)
AzureIoTClient 43:3da2d93bb955 406 {
AzureIoTClient 43:3da2d93bb955 407 LogError("Failed getting size of annotations");
AzureIoTClient 43:3da2d93bb955 408 result = __FAILURE__;
AzureIoTClient 43:3da2d93bb955 409 }
AzureIoTClient 43:3da2d93bb955 410 else
AzureIoTClient 43:3da2d93bb955 411 {
AzureIoTClient 43:3da2d93bb955 412 result = RESULT_OK;
AzureIoTClient 43:3da2d93bb955 413 }
AzureIoTClient 43:3da2d93bb955 414
AzureIoTClient 43:3da2d93bb955 415 free(diagContextBuffer);
AzureIoTClient 43:3da2d93bb955 416 amqpvalue_destroy(message_annotations_map);
AzureIoTClient 43:3da2d93bb955 417 }
AzureIoTClient 43:3da2d93bb955 418 }
AzureIoTClient 43:3da2d93bb955 419 else
AzureIoTClient 43:3da2d93bb955 420 {
AzureIoTClient 43:3da2d93bb955 421 // 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 422 result = RESULT_OK;
AzureIoTClient 43:3da2d93bb955 423 }
AzureIoTClient 43:3da2d93bb955 424
AzureIoTClient 43:3da2d93bb955 425 return result;
AzureIoTClient 43:3da2d93bb955 426 }
AzureIoTClient 41:71c01aa3df1a 427
AzureIoTClient 41:71c01aa3df1a 428 // 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 429 static int create_data_to_encode(IOTHUB_MESSAGE_HANDLE messageHandle, AMQP_VALUE *data_value, size_t *data_length)
AzureIoTClient 41:71c01aa3df1a 430 {
AzureIoTClient 41:71c01aa3df1a 431 int result;
AzureIoTClient 41:71c01aa3df1a 432
AzureIoTClient 41:71c01aa3df1a 433 IOTHUBMESSAGE_CONTENT_TYPE contentType = IoTHubMessage_GetContentType(messageHandle);
AzureIoTClient 41:71c01aa3df1a 434 const char* messageContent = NULL;
AzureIoTClient 41:71c01aa3df1a 435 size_t messageContentSize = 0;
AzureIoTClient 23:2c6779675a01 436
AzureIoTClient 41:71c01aa3df1a 437 if ((contentType == IOTHUBMESSAGE_BYTEARRAY) &&
AzureIoTClient 41:71c01aa3df1a 438 IoTHubMessage_GetByteArray(messageHandle, (const unsigned char **)&messageContent, &messageContentSize) != IOTHUB_MESSAGE_OK)
AzureIoTClient 41:71c01aa3df1a 439 {
AzureIoTClient 41:71c01aa3df1a 440 LogError("Failed getting the BYTE array representation of the IOTHUB_MESSAGE_HANDLE instance.");
AzureIoTClient 41:71c01aa3df1a 441 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 442 }
AzureIoTClient 41:71c01aa3df1a 443 else if ((contentType == IOTHUBMESSAGE_STRING) &&
AzureIoTClient 41:71c01aa3df1a 444 ((messageContent = IoTHubMessage_GetString(messageHandle)) == NULL))
AzureIoTClient 41:71c01aa3df1a 445 {
AzureIoTClient 41:71c01aa3df1a 446 LogError("Failed getting the STRING representation of the IOTHUB_MESSAGE_HANDLE instance.");
AzureIoTClient 41:71c01aa3df1a 447 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 448 }
AzureIoTClient 41:71c01aa3df1a 449 else if (contentType == IOTHUBMESSAGE_UNKNOWN)
AzureIoTClient 41:71c01aa3df1a 450 {
AzureIoTClient 41:71c01aa3df1a 451 LogError("Cannot parse IOTHUB_MESSAGE_HANDLE with content type IOTHUBMESSAGE_UNKNOWN.");
AzureIoTClient 41:71c01aa3df1a 452 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 453 }
AzureIoTClient 41:71c01aa3df1a 454 else
AzureIoTClient 41:71c01aa3df1a 455 {
AzureIoTClient 41:71c01aa3df1a 456 if (contentType == IOTHUBMESSAGE_STRING)
AzureIoTClient 41:71c01aa3df1a 457 {
AzureIoTClient 41:71c01aa3df1a 458 messageContentSize = strlen(messageContent);
AzureIoTClient 41:71c01aa3df1a 459 }
AzureIoTClient 41:71c01aa3df1a 460
AzureIoTClient 41:71c01aa3df1a 461 data bin_data;
AzureIoTClient 41:71c01aa3df1a 462 bin_data.bytes = (const unsigned char *)messageContent;
AzureIoTClient 41:71c01aa3df1a 463 bin_data.length = (uint32_t)messageContentSize;
AzureIoTClient 23:2c6779675a01 464
AzureIoTClient 41:71c01aa3df1a 465 if ((*data_value = amqpvalue_create_data(bin_data)) == NULL)
AzureIoTClient 41:71c01aa3df1a 466 {
AzureIoTClient 41:71c01aa3df1a 467 LogError("amqpvalue_create_data failed");
AzureIoTClient 41:71c01aa3df1a 468 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 469 }
AzureIoTClient 41:71c01aa3df1a 470 else if (amqpvalue_get_encoded_size(*data_value, data_length) != 0)
AzureIoTClient 41:71c01aa3df1a 471 {
AzureIoTClient 41:71c01aa3df1a 472 LogError("amqpvalue_get_encoded_size failed");
AzureIoTClient 41:71c01aa3df1a 473 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 474 }
AzureIoTClient 41:71c01aa3df1a 475 else
AzureIoTClient 41:71c01aa3df1a 476 {
AzureIoTClient 41:71c01aa3df1a 477 result = RESULT_OK;
AzureIoTClient 41:71c01aa3df1a 478 }
AzureIoTClient 41:71c01aa3df1a 479 }
AzureIoTClient 41:71c01aa3df1a 480
AzureIoTClient 41:71c01aa3df1a 481 return result;
AzureIoTClient 41:71c01aa3df1a 482 }
AzureIoTClient 41:71c01aa3df1a 483
AzureIoTClient 41:71c01aa3df1a 484 // Codes_SRS_UAMQP_MESSAGING_31_120: [Create a blob that contains AMQP encoding of IOTHUB_MESSAGE_HANDLE.]
AzureIoTClient 41:71c01aa3df1a 485 // Codes_SRS_UAMQP_MESSAGING_31_121: [Any errors during `message_create_uamqp_encoding_from_iothub_message` stop processing on this message.]
AzureIoTClient 41:71c01aa3df1a 486 int message_create_uamqp_encoding_from_iothub_message(IOTHUB_MESSAGE_HANDLE message_handle, BINARY_DATA* body_binary_data)
AzureIoTClient 41:71c01aa3df1a 487 {
AzureIoTClient 41:71c01aa3df1a 488 int result;
AzureIoTClient 41:71c01aa3df1a 489
AzureIoTClient 41:71c01aa3df1a 490 AMQP_VALUE message_properties = NULL;
AzureIoTClient 41:71c01aa3df1a 491 AMQP_VALUE application_properties = NULL;
AzureIoTClient 43:3da2d93bb955 492 AMQP_VALUE message_annotations = NULL;
AzureIoTClient 41:71c01aa3df1a 493 AMQP_VALUE data_value = NULL;
AzureIoTClient 41:71c01aa3df1a 494 size_t message_properties_length = 0;
AzureIoTClient 41:71c01aa3df1a 495 size_t application_properties_length = 0;
AzureIoTClient 43:3da2d93bb955 496 size_t message_annotations_length = 0;
AzureIoTClient 41:71c01aa3df1a 497 size_t data_length = 0;
AzureIoTClient 23:2c6779675a01 498
AzureIoTClient 41:71c01aa3df1a 499 body_binary_data->bytes = NULL;
AzureIoTClient 41:71c01aa3df1a 500 body_binary_data->length = 0;
AzureIoTClient 23:2c6779675a01 501
AzureIoTClient 41:71c01aa3df1a 502 if (create_message_properties_to_encode(message_handle, &message_properties, &message_properties_length) != RESULT_OK)
AzureIoTClient 41:71c01aa3df1a 503 {
AzureIoTClient 41:71c01aa3df1a 504 LogError("create_message_properties_to_encode() failed");
AzureIoTClient 41:71c01aa3df1a 505 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 506 }
AzureIoTClient 41:71c01aa3df1a 507 else if (create_application_properties_to_encode(message_handle, &application_properties, &application_properties_length) != RESULT_OK)
AzureIoTClient 41:71c01aa3df1a 508 {
AzureIoTClient 41:71c01aa3df1a 509 LogError("create_application_properties_to_encode() failed");
AzureIoTClient 41:71c01aa3df1a 510 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 511 }
AzureIoTClient 43:3da2d93bb955 512 else if (create_message_annotations_to_encode(message_handle, &message_annotations, &message_annotations_length) != RESULT_OK)
AzureIoTClient 43:3da2d93bb955 513 {
AzureIoTClient 43:3da2d93bb955 514 LogError("create_message_annotations_to_encode() failed");
AzureIoTClient 43:3da2d93bb955 515 result = __FAILURE__;
AzureIoTClient 43:3da2d93bb955 516 }
AzureIoTClient 41:71c01aa3df1a 517 else if (create_data_to_encode(message_handle, &data_value, &data_length) != RESULT_OK)
AzureIoTClient 41:71c01aa3df1a 518 {
AzureIoTClient 41:71c01aa3df1a 519 LogError("create_data_to_encode() failed");
AzureIoTClient 41:71c01aa3df1a 520 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 521 }
AzureIoTClient 43:3da2d93bb955 522 else if ((body_binary_data->bytes = malloc(message_properties_length + application_properties_length + data_length + message_annotations_length)) == NULL)
AzureIoTClient 41:71c01aa3df1a 523 {
AzureIoTClient 43:3da2d93bb955 524 LogError("malloc of %d bytes failed", message_properties_length + application_properties_length + data_length + message_annotations_length);
AzureIoTClient 41:71c01aa3df1a 525 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 526 }
AzureIoTClient 41:71c01aa3df1a 527 // Codes_SRS_UAMQP_MESSAGING_31_119: [Invoke underlying AMQP encode routines on data waiting to be encoded.]
AzureIoTClient 41:71c01aa3df1a 528 else if (amqpvalue_encode(message_properties, &encode_callback, body_binary_data) != RESULT_OK)
AzureIoTClient 41:71c01aa3df1a 529 {
AzureIoTClient 41:71c01aa3df1a 530 LogError("amqpvalue_encode() for message properties failed");
AzureIoTClient 41:71c01aa3df1a 531 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 532 }
AzureIoTClient 41:71c01aa3df1a 533 else if ((application_properties_length > 0) && (amqpvalue_encode(application_properties, &encode_callback, body_binary_data) != RESULT_OK))
AzureIoTClient 41:71c01aa3df1a 534 {
AzureIoTClient 41:71c01aa3df1a 535 LogError("amqpvalue_encode() for application properties failed");
AzureIoTClient 41:71c01aa3df1a 536 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 537 }
AzureIoTClient 43:3da2d93bb955 538 else if (message_annotations_length > 0 && amqpvalue_encode(message_annotations, &encode_callback, body_binary_data) != RESULT_OK)
AzureIoTClient 43:3da2d93bb955 539 {
AzureIoTClient 43:3da2d93bb955 540 LogError("amqpvalue_encode() for message annotations failed");
AzureIoTClient 43:3da2d93bb955 541 result = __FAILURE__;
AzureIoTClient 43:3da2d93bb955 542 }
AzureIoTClient 41:71c01aa3df1a 543 else if (RESULT_OK != amqpvalue_encode(data_value, &encode_callback, body_binary_data))
AzureIoTClient 41:71c01aa3df1a 544 {
AzureIoTClient 41:71c01aa3df1a 545 LogError("amqpvalue_encode() for data value failed");
AzureIoTClient 41:71c01aa3df1a 546 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 547 }
AzureIoTClient 41:71c01aa3df1a 548 else
AzureIoTClient 41:71c01aa3df1a 549 {
AzureIoTClient 43:3da2d93bb955 550 body_binary_data->length = message_properties_length + application_properties_length + data_length + message_annotations_length;
AzureIoTClient 41:71c01aa3df1a 551 result = RESULT_OK;
AzureIoTClient 41:71c01aa3df1a 552 }
AzureIoTClient 23:2c6779675a01 553
AzureIoTClient 41:71c01aa3df1a 554 if (NULL != data_value)
AzureIoTClient 41:71c01aa3df1a 555 {
AzureIoTClient 41:71c01aa3df1a 556 amqpvalue_destroy(data_value);
AzureIoTClient 41:71c01aa3df1a 557 }
AzureIoTClient 23:2c6779675a01 558
AzureIoTClient 41:71c01aa3df1a 559 if (NULL != application_properties)
AzureIoTClient 41:71c01aa3df1a 560 {
AzureIoTClient 41:71c01aa3df1a 561 amqpvalue_destroy(application_properties);
AzureIoTClient 41:71c01aa3df1a 562 }
AzureIoTClient 41:71c01aa3df1a 563
AzureIoTClient 43:3da2d93bb955 564 if (NULL != message_annotations)
AzureIoTClient 43:3da2d93bb955 565 {
AzureIoTClient 43:3da2d93bb955 566 amqpvalue_destroy(message_annotations);
AzureIoTClient 43:3da2d93bb955 567 }
AzureIoTClient 43:3da2d93bb955 568
AzureIoTClient 41:71c01aa3df1a 569 if (NULL != message_properties)
AzureIoTClient 41:71c01aa3df1a 570 {
AzureIoTClient 41:71c01aa3df1a 571 amqpvalue_destroy(message_properties);
AzureIoTClient 41:71c01aa3df1a 572 }
AzureIoTClient 41:71c01aa3df1a 573
AzureIoTClient 41:71c01aa3df1a 574 return result;
AzureIoTClient 23:2c6779675a01 575 }
AzureIoTClient 23:2c6779675a01 576
AzureIoTClient 43:3da2d93bb955 577 static int readMessageIdFromuAQMPMessage(IOTHUB_MESSAGE_HANDLE iothub_message_handle, PROPERTIES_HANDLE uamqp_message_properties)
AzureIoTClient 43:3da2d93bb955 578 {
AzureIoTClient 43:3da2d93bb955 579 int result;
AzureIoTClient 43:3da2d93bb955 580 AMQP_VALUE uamqp_message_property;
AzureIoTClient 43:3da2d93bb955 581
AzureIoTClient 43:3da2d93bb955 582 // 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 583 if (properties_get_message_id(uamqp_message_properties, &uamqp_message_property) != 0 || uamqp_message_property == NULL)
AzureIoTClient 43:3da2d93bb955 584 {
AzureIoTClient 43:3da2d93bb955 585 // 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 586 result = RESULT_OK;
AzureIoTClient 43:3da2d93bb955 587 }
AzureIoTClient 43:3da2d93bb955 588 else
AzureIoTClient 43:3da2d93bb955 589 {
AzureIoTClient 43:3da2d93bb955 590 // Codes_SRS_UAMQP_MESSAGING_09_012: [The type of the message-id property value shall be obtained using amqpvalue_get_type().]
AzureIoTClient 43:3da2d93bb955 591 AMQP_TYPE value_type = amqpvalue_get_type(uamqp_message_property);
AzureIoTClient 43:3da2d93bb955 592
AzureIoTClient 43:3da2d93bb955 593 // 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 594 if (value_type != AMQP_TYPE_NULL)
AzureIoTClient 43:3da2d93bb955 595 {
AzureIoTClient 43:3da2d93bb955 596
AzureIoTClient 43:3da2d93bb955 597 char* string_value;
AzureIoTClient 43:3da2d93bb955 598 char string_buffer[MESSAGE_ID_MAX_SIZE];
AzureIoTClient 43:3da2d93bb955 599 bool free_string_value = false;
AzureIoTClient 43:3da2d93bb955 600
AzureIoTClient 43:3da2d93bb955 601 memset(string_buffer, 0, MESSAGE_ID_MAX_SIZE);
AzureIoTClient 43:3da2d93bb955 602
AzureIoTClient 43:3da2d93bb955 603 if (value_type == AMQP_TYPE_STRING)
AzureIoTClient 43:3da2d93bb955 604 {
AzureIoTClient 43:3da2d93bb955 605 // Codes_SRS_UAMQP_MESSAGING_09_014: [The message-id value shall be retrieved from the AMQP_VALUE as char sequence]
AzureIoTClient 43:3da2d93bb955 606 if (amqpvalue_get_string(uamqp_message_property, (const char**)(&string_value)) != 0)
AzureIoTClient 43:3da2d93bb955 607 {
AzureIoTClient 43:3da2d93bb955 608 // 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 609 LogError("Failed to get value of uAMQP message 'message-id' property (string)");
AzureIoTClient 43:3da2d93bb955 610 string_value = NULL;
AzureIoTClient 43:3da2d93bb955 611 }
AzureIoTClient 43:3da2d93bb955 612 }
AzureIoTClient 43:3da2d93bb955 613 else if (value_type == AMQP_TYPE_ULONG)
AzureIoTClient 43:3da2d93bb955 614 {
AzureIoTClient 43:3da2d93bb955 615 uint64_t ulong_value;
AzureIoTClient 43:3da2d93bb955 616
AzureIoTClient 43:3da2d93bb955 617 // Codes_SRS_UAMQP_MESSAGING_09_014: [The message-id value shall be retrieved from the AMQP_VALUE as char sequence]
AzureIoTClient 43:3da2d93bb955 618 if (amqpvalue_get_ulong(uamqp_message_property, &ulong_value) != 0)
AzureIoTClient 43:3da2d93bb955 619 {
AzureIoTClient 43:3da2d93bb955 620 // 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 621 LogError("Failed to get value of uAMQP message 'message-id' property (ulong)");
AzureIoTClient 43:3da2d93bb955 622 string_value = NULL;
AzureIoTClient 43:3da2d93bb955 623 }
AzureIoTClient 43:3da2d93bb955 624 else if (sprintf(string_buffer, "%" PRIu64, ulong_value) < 0)
AzureIoTClient 43:3da2d93bb955 625 {
AzureIoTClient 43:3da2d93bb955 626 LogError("Failed converting 'message-id' (ulong) to string");
AzureIoTClient 43:3da2d93bb955 627 string_value = NULL;
AzureIoTClient 43:3da2d93bb955 628 }
AzureIoTClient 43:3da2d93bb955 629 else
AzureIoTClient 43:3da2d93bb955 630 {
AzureIoTClient 43:3da2d93bb955 631 string_value = string_buffer;
AzureIoTClient 43:3da2d93bb955 632 }
AzureIoTClient 43:3da2d93bb955 633 }
AzureIoTClient 43:3da2d93bb955 634 else if (value_type == AMQP_TYPE_UUID)
AzureIoTClient 43:3da2d93bb955 635 {
AzureIoTClient 43:3da2d93bb955 636 uuid uuid_value;
AzureIoTClient 43:3da2d93bb955 637
AzureIoTClient 43:3da2d93bb955 638 // Codes_SRS_UAMQP_MESSAGING_09_014: [The message-id value shall be retrieved from the AMQP_VALUE as char sequence]
AzureIoTClient 43:3da2d93bb955 639 if (amqpvalue_get_uuid(uamqp_message_property, &uuid_value) != 0)
AzureIoTClient 43:3da2d93bb955 640 {
AzureIoTClient 43:3da2d93bb955 641 // 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 642 LogError("Failed to get value of uAMQP message 'message-id' property (UUID)");
AzureIoTClient 43:3da2d93bb955 643 string_value = NULL;
AzureIoTClient 43:3da2d93bb955 644 }
AzureIoTClient 43:3da2d93bb955 645 else if ((string_value = UUID_to_string((UUID*)uuid_value)) == NULL)
AzureIoTClient 43:3da2d93bb955 646 {
AzureIoTClient 43:3da2d93bb955 647 // 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 648 LogError("Failed to get the string representation of 'message-id' UUID");
AzureIoTClient 43:3da2d93bb955 649 string_value = NULL;
AzureIoTClient 43:3da2d93bb955 650 }
AzureIoTClient 43:3da2d93bb955 651 else
AzureIoTClient 43:3da2d93bb955 652 {
AzureIoTClient 43:3da2d93bb955 653 free_string_value = true;
AzureIoTClient 43:3da2d93bb955 654 }
AzureIoTClient 43:3da2d93bb955 655 }
AzureIoTClient 43:3da2d93bb955 656 else
AzureIoTClient 43:3da2d93bb955 657 {
AzureIoTClient 43:3da2d93bb955 658 LogError("Unrecognized type for message-id (%d)", value_type);
AzureIoTClient 43:3da2d93bb955 659 string_value = NULL;
AzureIoTClient 43:3da2d93bb955 660 }
AzureIoTClient 43:3da2d93bb955 661
AzureIoTClient 43:3da2d93bb955 662 if (string_value != NULL)
AzureIoTClient 43:3da2d93bb955 663 {
AzureIoTClient 43:3da2d93bb955 664 // 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 665 if (IoTHubMessage_SetMessageId(iothub_message_handle, string_value) != IOTHUB_MESSAGE_OK)
AzureIoTClient 43:3da2d93bb955 666 {
AzureIoTClient 43:3da2d93bb955 667 // Codes_SRS_UAMQP_MESSAGING_09_017: [If IoTHubMessage_SetMessageId fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.]
AzureIoTClient 43:3da2d93bb955 668 LogError("Failed to set IOTHUB_MESSAGE_HANDLE 'message-id' property.");
AzureIoTClient 43:3da2d93bb955 669 result = __FAILURE__;
AzureIoTClient 43:3da2d93bb955 670 }
AzureIoTClient 43:3da2d93bb955 671 else
AzureIoTClient 43:3da2d93bb955 672 {
AzureIoTClient 43:3da2d93bb955 673 result = RESULT_OK;
AzureIoTClient 43:3da2d93bb955 674 }
AzureIoTClient 43:3da2d93bb955 675
AzureIoTClient 43:3da2d93bb955 676 if (free_string_value)
AzureIoTClient 43:3da2d93bb955 677 {
AzureIoTClient 43:3da2d93bb955 678 // Only certain code paths allocate this.
AzureIoTClient 43:3da2d93bb955 679 free(string_value);
AzureIoTClient 43:3da2d93bb955 680 }
AzureIoTClient 43:3da2d93bb955 681 }
AzureIoTClient 43:3da2d93bb955 682 else
AzureIoTClient 43:3da2d93bb955 683 {
AzureIoTClient 43:3da2d93bb955 684 LogError("Unexpected null string for message-id");
AzureIoTClient 43:3da2d93bb955 685 result = __FAILURE__;
AzureIoTClient 43:3da2d93bb955 686 }
AzureIoTClient 43:3da2d93bb955 687 }
AzureIoTClient 43:3da2d93bb955 688 else
AzureIoTClient 43:3da2d93bb955 689 {
AzureIoTClient 43:3da2d93bb955 690 result = RESULT_OK;
AzureIoTClient 43:3da2d93bb955 691 }
AzureIoTClient 43:3da2d93bb955 692 }
AzureIoTClient 43:3da2d93bb955 693
AzureIoTClient 43:3da2d93bb955 694 return result;
AzureIoTClient 43:3da2d93bb955 695 }
AzureIoTClient 43:3da2d93bb955 696
AzureIoTClient 43:3da2d93bb955 697 static int readCorrelationIdFromuAQMPMessage(IOTHUB_MESSAGE_HANDLE iothub_message_handle, PROPERTIES_HANDLE uamqp_message_properties)
AzureIoTClient 43:3da2d93bb955 698 {
AzureIoTClient 43:3da2d93bb955 699 int result;
AzureIoTClient 43:3da2d93bb955 700 AMQP_VALUE uamqp_message_property;
AzureIoTClient 43:3da2d93bb955 701
AzureIoTClient 43:3da2d93bb955 702 // 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 703 if (properties_get_correlation_id(uamqp_message_properties, &uamqp_message_property) != 0 || uamqp_message_property == NULL)
AzureIoTClient 43:3da2d93bb955 704 {
AzureIoTClient 43:3da2d93bb955 705 // 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 706 result = RESULT_OK;
AzureIoTClient 43:3da2d93bb955 707 }
AzureIoTClient 43:3da2d93bb955 708 else
AzureIoTClient 43:3da2d93bb955 709 {
AzureIoTClient 43:3da2d93bb955 710 // Codes_SRS_UAMQP_MESSAGING_09_020: [The type of the correlation-id property value shall be obtained using amqpvalue_get_type().]
AzureIoTClient 43:3da2d93bb955 711 AMQP_TYPE value_type = amqpvalue_get_type(uamqp_message_property);
AzureIoTClient 43:3da2d93bb955 712
AzureIoTClient 43:3da2d93bb955 713 // 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 714 if (value_type != AMQP_TYPE_NULL)
AzureIoTClient 43:3da2d93bb955 715 {
AzureIoTClient 43:3da2d93bb955 716 char* string_value;
AzureIoTClient 43:3da2d93bb955 717 char string_buffer[MESSAGE_ID_MAX_SIZE];
AzureIoTClient 43:3da2d93bb955 718 bool free_string_value = false;
AzureIoTClient 43:3da2d93bb955 719
AzureIoTClient 43:3da2d93bb955 720 memset(string_buffer, 0, MESSAGE_ID_MAX_SIZE);
AzureIoTClient 43:3da2d93bb955 721
AzureIoTClient 43:3da2d93bb955 722 if (value_type == AMQP_TYPE_STRING)
AzureIoTClient 43:3da2d93bb955 723 {
AzureIoTClient 43:3da2d93bb955 724 // Codes_SRS_UAMQP_MESSAGING_09_022: [The correlation-id value shall be retrieved from the AMQP_VALUE as char sequence]
AzureIoTClient 43:3da2d93bb955 725 if (amqpvalue_get_string(uamqp_message_property, (const char**)(&string_value)) != 0)
AzureIoTClient 43:3da2d93bb955 726 {
AzureIoTClient 43:3da2d93bb955 727 // 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 728 LogError("Failed to get value of uAMQP message 'correlation-id' property (string)");
AzureIoTClient 43:3da2d93bb955 729 string_value = NULL;
AzureIoTClient 43:3da2d93bb955 730 result = __FAILURE__;
AzureIoTClient 43:3da2d93bb955 731 }
AzureIoTClient 43:3da2d93bb955 732 }
AzureIoTClient 43:3da2d93bb955 733 else if (value_type == AMQP_TYPE_ULONG)
AzureIoTClient 43:3da2d93bb955 734 {
AzureIoTClient 43:3da2d93bb955 735 uint64_t ulong_value;
AzureIoTClient 43:3da2d93bb955 736
AzureIoTClient 43:3da2d93bb955 737 // Codes_SRS_UAMQP_MESSAGING_09_022: [The correlation-id value shall be retrieved from the AMQP_VALUE as char sequence]
AzureIoTClient 43:3da2d93bb955 738 if (amqpvalue_get_ulong(uamqp_message_property, &ulong_value) != 0)
AzureIoTClient 43:3da2d93bb955 739 {
AzureIoTClient 43:3da2d93bb955 740 // 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 741 LogError("Failed to get value of uAMQP message 'correlation-id' property (ulong)");
AzureIoTClient 43:3da2d93bb955 742 string_value = NULL;
AzureIoTClient 43:3da2d93bb955 743 result = __FAILURE__;
AzureIoTClient 43:3da2d93bb955 744 }
AzureIoTClient 43:3da2d93bb955 745 else if (sprintf(string_buffer, "%" PRIu64, ulong_value) < 0)
AzureIoTClient 43:3da2d93bb955 746 {
AzureIoTClient 43:3da2d93bb955 747 LogError("Failed converting 'correlation-id' (ulong) to string");
AzureIoTClient 43:3da2d93bb955 748 string_value = NULL;
AzureIoTClient 43:3da2d93bb955 749 result = __FAILURE__;
AzureIoTClient 43:3da2d93bb955 750 }
AzureIoTClient 43:3da2d93bb955 751 else
AzureIoTClient 43:3da2d93bb955 752 {
AzureIoTClient 43:3da2d93bb955 753 string_value = string_buffer;
AzureIoTClient 43:3da2d93bb955 754 }
AzureIoTClient 43:3da2d93bb955 755 }
AzureIoTClient 43:3da2d93bb955 756 else if (value_type == AMQP_TYPE_UUID)
AzureIoTClient 43:3da2d93bb955 757 {
AzureIoTClient 43:3da2d93bb955 758 uuid uuid_value;
AzureIoTClient 43:3da2d93bb955 759
AzureIoTClient 43:3da2d93bb955 760 // Codes_SRS_UAMQP_MESSAGING_09_022: [The correlation-id value shall be retrieved from the AMQP_VALUE as char sequence]
AzureIoTClient 43:3da2d93bb955 761 if (amqpvalue_get_uuid(uamqp_message_property, &uuid_value) != 0)
AzureIoTClient 43:3da2d93bb955 762 {
AzureIoTClient 43:3da2d93bb955 763 // 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 764 LogError("Failed to get value of uAMQP message 'correlation-id' property (UUID)");
AzureIoTClient 43:3da2d93bb955 765 string_value = NULL;
AzureIoTClient 43:3da2d93bb955 766 result = __FAILURE__;
AzureIoTClient 43:3da2d93bb955 767 }
AzureIoTClient 43:3da2d93bb955 768 else if ((string_value = UUID_to_string((UUID*)uuid_value)) == NULL)
AzureIoTClient 43:3da2d93bb955 769 {
AzureIoTClient 43:3da2d93bb955 770 // 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 771 LogError("Failed to get the string representation of 'correlation-id' UUID");
AzureIoTClient 43:3da2d93bb955 772 string_value = NULL;
AzureIoTClient 43:3da2d93bb955 773 result = __FAILURE__;
AzureIoTClient 43:3da2d93bb955 774 }
AzureIoTClient 43:3da2d93bb955 775 else
AzureIoTClient 43:3da2d93bb955 776 {
AzureIoTClient 43:3da2d93bb955 777 free_string_value = true;
AzureIoTClient 43:3da2d93bb955 778 }
AzureIoTClient 43:3da2d93bb955 779 }
AzureIoTClient 43:3da2d93bb955 780 else
AzureIoTClient 43:3da2d93bb955 781 {
AzureIoTClient 43:3da2d93bb955 782 LogError("Unrecognized type for correlation-id (%d)", value_type);
AzureIoTClient 43:3da2d93bb955 783 string_value = NULL;
AzureIoTClient 43:3da2d93bb955 784 result = __FAILURE__;
AzureIoTClient 43:3da2d93bb955 785 }
AzureIoTClient 43:3da2d93bb955 786
AzureIoTClient 43:3da2d93bb955 787 if (string_value != NULL)
AzureIoTClient 43:3da2d93bb955 788 {
AzureIoTClient 43:3da2d93bb955 789 // 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 790 if (IoTHubMessage_SetCorrelationId(iothub_message_handle, string_value) != IOTHUB_MESSAGE_OK)
AzureIoTClient 43:3da2d93bb955 791 {
AzureIoTClient 43:3da2d93bb955 792 // Codes_SRS_UAMQP_MESSAGING_09_025: [If IoTHubMessage_SetCorrelationId fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.]
AzureIoTClient 43:3da2d93bb955 793 LogError("Failed to set IOTHUB_MESSAGE_HANDLE 'correlation-id' property.");
AzureIoTClient 43:3da2d93bb955 794 result = __FAILURE__;
AzureIoTClient 43:3da2d93bb955 795 }
AzureIoTClient 43:3da2d93bb955 796 else
AzureIoTClient 43:3da2d93bb955 797 {
AzureIoTClient 43:3da2d93bb955 798 result = RESULT_OK;
AzureIoTClient 43:3da2d93bb955 799 }
AzureIoTClient 43:3da2d93bb955 800
AzureIoTClient 43:3da2d93bb955 801 if (free_string_value)
AzureIoTClient 43:3da2d93bb955 802 {
AzureIoTClient 43:3da2d93bb955 803 // Only certain code paths allocate this.
AzureIoTClient 43:3da2d93bb955 804 free(string_value);
AzureIoTClient 43:3da2d93bb955 805 }
AzureIoTClient 43:3da2d93bb955 806 }
AzureIoTClient 43:3da2d93bb955 807 else
AzureIoTClient 43:3da2d93bb955 808 {
AzureIoTClient 43:3da2d93bb955 809 LogError("Unexpected null string for correlation-id");
AzureIoTClient 43:3da2d93bb955 810 result = __FAILURE__;
AzureIoTClient 43:3da2d93bb955 811 }
AzureIoTClient 43:3da2d93bb955 812 }
AzureIoTClient 43:3da2d93bb955 813 else
AzureIoTClient 43:3da2d93bb955 814 {
AzureIoTClient 43:3da2d93bb955 815 result = RESULT_OK;
AzureIoTClient 43:3da2d93bb955 816 }
AzureIoTClient 43:3da2d93bb955 817 }
AzureIoTClient 43:3da2d93bb955 818
AzureIoTClient 43:3da2d93bb955 819 return result;
AzureIoTClient 43:3da2d93bb955 820 }
AzureIoTClient 43:3da2d93bb955 821
AzureIoTClient 23:2c6779675a01 822 static int readPropertiesFromuAMQPMessage(IOTHUB_MESSAGE_HANDLE iothub_message_handle, MESSAGE_HANDLE uamqp_message)
AzureIoTClient 23:2c6779675a01 823 {
AzureIoTClient 42:c2eaa912a28c 824 int result;
AzureIoTClient 41:71c01aa3df1a 825 PROPERTIES_HANDLE uamqp_message_properties;
AzureIoTClient 23:2c6779675a01 826
AzureIoTClient 41:71c01aa3df1a 827 // Codes_SRS_UAMQP_MESSAGING_09_008: [The uAMQP message properties shall be retrieved using message_get_properties().]
AzureIoTClient 42:c2eaa912a28c 828 if (message_get_properties(uamqp_message, &uamqp_message_properties) != 0)
AzureIoTClient 41:71c01aa3df1a 829 {
AzureIoTClient 41:71c01aa3df1a 830 // 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 831 LogError("Failed to get property properties map from uAMQP message.");
AzureIoTClient 42:c2eaa912a28c 832 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 833 }
AzureIoTClient 40:e79ee1341949 834 else
AzureIoTClient 40:e79ee1341949 835 {
AzureIoTClient 42:c2eaa912a28c 836 result = RESULT_OK; // Properties 'message-id' and 'correlation-id' are optional according to the AMQP 1.0 spec.
AzureIoTClient 40:e79ee1341949 837
AzureIoTClient 43:3da2d93bb955 838 if (readMessageIdFromuAQMPMessage(iothub_message_handle, uamqp_message_properties) != RESULT_OK)
AzureIoTClient 40:e79ee1341949 839 {
AzureIoTClient 43:3da2d93bb955 840 LogError("Failed readMessageIdFromuAQMPMessage.");
AzureIoTClient 43:3da2d93bb955 841 result = __FAILURE__;
AzureIoTClient 43:3da2d93bb955 842 }
AzureIoTClient 43:3da2d93bb955 843 else if (readCorrelationIdFromuAQMPMessage(iothub_message_handle, uamqp_message_properties) != RESULT_OK)
AzureIoTClient 43:3da2d93bb955 844 {
AzureIoTClient 43:3da2d93bb955 845 LogError("Failed readPropertiesFromuAMQPMessage.");
AzureIoTClient 43:3da2d93bb955 846 result = __FAILURE__;
AzureIoTClient 40:e79ee1341949 847 }
AzureIoTClient 42:c2eaa912a28c 848 else
AzureIoTClient 40:e79ee1341949 849 {
AzureIoTClient 43:3da2d93bb955 850 const char* uamqp_message_property_value = NULL;
AzureIoTClient 42:c2eaa912a28c 851
AzureIoTClient 43:3da2d93bb955 852 // 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 853 // 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 854 if (properties_get_content_type(uamqp_message_properties, &uamqp_message_property_value) == 0 && uamqp_message_property_value != NULL)
AzureIoTClient 43:3da2d93bb955 855 {
AzureIoTClient 43:3da2d93bb955 856 if (IoTHubMessage_SetContentTypeSystemProperty(iothub_message_handle, uamqp_message_property_value) != IOTHUB_MESSAGE_OK)
AzureIoTClient 42:c2eaa912a28c 857 {
AzureIoTClient 43:3da2d93bb955 858 // 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 859 LogError("Failed to set IOTHUB_MESSAGE_HANDLE 'content-type' property.");
AzureIoTClient 42:c2eaa912a28c 860 result = __FAILURE__;
AzureIoTClient 42:c2eaa912a28c 861 }
AzureIoTClient 40:e79ee1341949 862 }
AzureIoTClient 43:3da2d93bb955 863
AzureIoTClient 43:3da2d93bb955 864 uamqp_message_property_value = NULL;
AzureIoTClient 42:c2eaa912a28c 865
AzureIoTClient 43:3da2d93bb955 866 // 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 867 // 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 868 if (properties_get_content_encoding(uamqp_message_properties, &uamqp_message_property_value) == 0 && uamqp_message_property_value != NULL)
AzureIoTClient 43:3da2d93bb955 869 {
AzureIoTClient 43:3da2d93bb955 870 if (IoTHubMessage_SetContentEncodingSystemProperty(iothub_message_handle, uamqp_message_property_value) != IOTHUB_MESSAGE_OK)
AzureIoTClient 42:c2eaa912a28c 871 {
AzureIoTClient 43:3da2d93bb955 872 // 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 873 LogError("Failed to set IOTHUB_MESSAGE_HANDLE 'content-encoding' property.");
AzureIoTClient 42:c2eaa912a28c 874 result = __FAILURE__;
AzureIoTClient 42:c2eaa912a28c 875 }
AzureIoTClient 40:e79ee1341949 876 }
AzureIoTClient 40:e79ee1341949 877 }
AzureIoTClient 42:c2eaa912a28c 878
AzureIoTClient 41:71c01aa3df1a 879 // 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 880 properties_destroy(uamqp_message_properties);
AzureIoTClient 41:71c01aa3df1a 881 }
AzureIoTClient 40:e79ee1341949 882
AzureIoTClient 42:c2eaa912a28c 883 return result;
AzureIoTClient 23:2c6779675a01 884 }
AzureIoTClient 23:2c6779675a01 885
AzureIoTClient 23:2c6779675a01 886 static int readApplicationPropertiesFromuAMQPMessage(IOTHUB_MESSAGE_HANDLE iothub_message_handle, MESSAGE_HANDLE uamqp_message)
AzureIoTClient 23:2c6779675a01 887 {
AzureIoTClient 41:71c01aa3df1a 888 int result;
AzureIoTClient 41:71c01aa3df1a 889 AMQP_VALUE uamqp_app_properties = NULL;
AzureIoTClient 41:71c01aa3df1a 890 AMQP_VALUE uamqp_app_properties_ipdv = NULL;
AzureIoTClient 41:71c01aa3df1a 891 uint32_t property_count = 0;
AzureIoTClient 41:71c01aa3df1a 892 MAP_HANDLE iothub_message_properties_map;
AzureIoTClient 23:2c6779675a01 893
AzureIoTClient 41:71c01aa3df1a 894 // Codes_SRS_UAMQP_MESSAGING_09_027: [The IOTHUB_MESSAGE_HANDLE properties shall be retrieved using IoTHubMessage_Properties.]
AzureIoTClient 41:71c01aa3df1a 895 if ((iothub_message_properties_map = IoTHubMessage_Properties(iothub_message_handle)) == NULL)
AzureIoTClient 41:71c01aa3df1a 896 {
AzureIoTClient 41:71c01aa3df1a 897 // Codes_SRS_UAMQP_MESSAGING_09_028: [If IoTHubMessage_Properties fails, message_create_IoTHubMessage_from_uamqp_message() shall fail and return immediately.]
AzureIoTClient 41:71c01aa3df1a 898 LogError("Failed to get property map from IoTHub message.");
AzureIoTClient 41:71c01aa3df1a 899 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 900 }
AzureIoTClient 41:71c01aa3df1a 901 // Codes_SRS_UAMQP_MESSAGING_09_029: [The uAMQP message application properties shall be retrieved using message_get_application_properties.]
AzureIoTClient 41:71c01aa3df1a 902 else if ((result = message_get_application_properties(uamqp_message, &uamqp_app_properties)) != 0)
AzureIoTClient 41:71c01aa3df1a 903 {
AzureIoTClient 41:71c01aa3df1a 904 // 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 905 LogError("Failed reading the incoming uAMQP message properties (return code %d).", result);
AzureIoTClient 41:71c01aa3df1a 906 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 907 }
AzureIoTClient 41:71c01aa3df1a 908 else
AzureIoTClient 41:71c01aa3df1a 909 {
AzureIoTClient 41:71c01aa3df1a 910 // 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 911 if (uamqp_app_properties == NULL)
AzureIoTClient 41:71c01aa3df1a 912 {
AzureIoTClient 41:71c01aa3df1a 913 result = 0;
AzureIoTClient 41:71c01aa3df1a 914 }
AzureIoTClient 41:71c01aa3df1a 915 else
AzureIoTClient 41:71c01aa3df1a 916 {
AzureIoTClient 41:71c01aa3df1a 917 // 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 918 if ((uamqp_app_properties_ipdv = amqpvalue_get_inplace_described_value(uamqp_app_properties)) == NULL)
AzureIoTClient 41:71c01aa3df1a 919 {
AzureIoTClient 41:71c01aa3df1a 920 // 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 921 LogError("Failed getting the map of uAMQP message application properties (return code %d).", result);
AzureIoTClient 41:71c01aa3df1a 922 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 923 }
AzureIoTClient 41:71c01aa3df1a 924 // 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 925 else if ((result = amqpvalue_get_map_pair_count(uamqp_app_properties_ipdv, &property_count)) != 0)
AzureIoTClient 41:71c01aa3df1a 926 {
AzureIoTClient 41:71c01aa3df1a 927 // 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 928 LogError("Failed reading the number of values in the uAMQP property map (return code %d).", result);
AzureIoTClient 41:71c01aa3df1a 929 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 930 }
AzureIoTClient 41:71c01aa3df1a 931 else
AzureIoTClient 41:71c01aa3df1a 932 {
AzureIoTClient 41:71c01aa3df1a 933 // 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 934 uint32_t i;
AzureIoTClient 41:71c01aa3df1a 935 for (i = 0; result == RESULT_OK && i < property_count; i++)
AzureIoTClient 41:71c01aa3df1a 936 {
AzureIoTClient 41:71c01aa3df1a 937 AMQP_VALUE map_key_name = NULL;
AzureIoTClient 41:71c01aa3df1a 938 AMQP_VALUE map_key_value = NULL;
AzureIoTClient 41:71c01aa3df1a 939 const char *key_name;
AzureIoTClient 41:71c01aa3df1a 940 const char* key_value;
AzureIoTClient 23:2c6779675a01 941
AzureIoTClient 41:71c01aa3df1a 942 // 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 943 if ((result = amqpvalue_get_map_key_value_pair(uamqp_app_properties_ipdv, i, &map_key_name, &map_key_value)) != 0)
AzureIoTClient 41:71c01aa3df1a 944 {
AzureIoTClient 41:71c01aa3df1a 945 // 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 946 LogError("Failed reading the key/value pair from the uAMQP property map (return code %d).", result);
AzureIoTClient 41:71c01aa3df1a 947 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 948 }
AzureIoTClient 23:2c6779675a01 949
AzureIoTClient 41:71c01aa3df1a 950 // Codes_SRS_UAMQP_MESSAGING_09_039: [The uAMQP application property name shall be extracted as string using amqpvalue_get_string.]
AzureIoTClient 41:71c01aa3df1a 951 else if ((result = amqpvalue_get_string(map_key_name, &key_name)) != 0)
AzureIoTClient 41:71c01aa3df1a 952 {
AzureIoTClient 41:71c01aa3df1a 953 // 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 954 LogError("Failed parsing the uAMQP property name (return code %d).", result);
AzureIoTClient 41:71c01aa3df1a 955 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 956 }
AzureIoTClient 41:71c01aa3df1a 957 // Codes_SRS_UAMQP_MESSAGING_09_041: [The uAMQP application property value shall be extracted as string using amqpvalue_get_string.]
AzureIoTClient 41:71c01aa3df1a 958 else if ((result = amqpvalue_get_string(map_key_value, &key_value)) != 0)
AzureIoTClient 41:71c01aa3df1a 959 {
AzureIoTClient 41:71c01aa3df1a 960 // 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 961 LogError("Failed parsing the uAMQP property value (return code %d).", result);
AzureIoTClient 41:71c01aa3df1a 962 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 963 }
AzureIoTClient 41:71c01aa3df1a 964 // 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 965 else if (Map_AddOrUpdate(iothub_message_properties_map, key_name, key_value) != MAP_OK)
AzureIoTClient 41:71c01aa3df1a 966 {
AzureIoTClient 41:71c01aa3df1a 967 // Codes_SRS_UAMQP_MESSAGING_09_044: [If Map_AddOrUpdate fails, message_create_IoTHubMessage_from_uamqp_message() shall fail and return immediately.]
AzureIoTClient 41:71c01aa3df1a 968 LogError("Failed to add/update IoTHub message property map.");
AzureIoTClient 41:71c01aa3df1a 969 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 970 }
AzureIoTClient 23:2c6779675a01 971
AzureIoTClient 41:71c01aa3df1a 972 // 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 973 if (map_key_name != NULL)
AzureIoTClient 41:71c01aa3df1a 974 {
AzureIoTClient 41:71c01aa3df1a 975 amqpvalue_destroy(map_key_name);
AzureIoTClient 41:71c01aa3df1a 976 }
AzureIoTClient 23:2c6779675a01 977
AzureIoTClient 41:71c01aa3df1a 978 if (map_key_value != NULL)
AzureIoTClient 41:71c01aa3df1a 979 {
AzureIoTClient 41:71c01aa3df1a 980 amqpvalue_destroy(map_key_value);
AzureIoTClient 41:71c01aa3df1a 981 }
AzureIoTClient 41:71c01aa3df1a 982 }
AzureIoTClient 41:71c01aa3df1a 983 }
AzureIoTClient 23:2c6779675a01 984
AzureIoTClient 41:71c01aa3df1a 985 // 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 986 amqpvalue_destroy(uamqp_app_properties);
AzureIoTClient 41:71c01aa3df1a 987 }
AzureIoTClient 41:71c01aa3df1a 988 }
AzureIoTClient 23:2c6779675a01 989
AzureIoTClient 41:71c01aa3df1a 990 return result;
AzureIoTClient 23:2c6779675a01 991 }
AzureIoTClient 23:2c6779675a01 992
AzureIoTClient 41:71c01aa3df1a 993 int message_create_IoTHubMessage_from_uamqp_message(MESSAGE_HANDLE uamqp_message, IOTHUB_MESSAGE_HANDLE* iothubclient_message)
AzureIoTClient 23:2c6779675a01 994 {
AzureIoTClient 41:71c01aa3df1a 995 int result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 996
AzureIoTClient 41:71c01aa3df1a 997 IOTHUB_MESSAGE_HANDLE iothub_message = NULL;
AzureIoTClient 41:71c01aa3df1a 998 MESSAGE_BODY_TYPE body_type;
AzureIoTClient 23:2c6779675a01 999
AzureIoTClient 41:71c01aa3df1a 1000 // Codes_SRS_UAMQP_MESSAGING_09_001: [The body type of the uAMQP message shall be retrieved using message_get_body_type().]
AzureIoTClient 41:71c01aa3df1a 1001 if (message_get_body_type(uamqp_message, &body_type) != 0)
AzureIoTClient 41:71c01aa3df1a 1002 {
AzureIoTClient 41:71c01aa3df1a 1003 // 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 1004 LogError("Failed to get the type of the uamqp message.");
AzureIoTClient 41:71c01aa3df1a 1005 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 1006 }
AzureIoTClient 41:71c01aa3df1a 1007 else
AzureIoTClient 41:71c01aa3df1a 1008 {
AzureIoTClient 41:71c01aa3df1a 1009 // 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 1010 if (body_type == MESSAGE_BODY_TYPE_DATA)
AzureIoTClient 41:71c01aa3df1a 1011 {
AzureIoTClient 41:71c01aa3df1a 1012 // Codes_SRS_UAMQP_MESSAGING_09_004: [The uAMQP message body data shall be retrieved using message_get_body_amqp_data().]
AzureIoTClient 41:71c01aa3df1a 1013 BINARY_DATA binary_data;
AzureIoTClient 41:71c01aa3df1a 1014 if (message_get_body_amqp_data_in_place(uamqp_message, 0, &binary_data) != 0)
AzureIoTClient 41:71c01aa3df1a 1015 {
AzureIoTClient 41:71c01aa3df1a 1016 // 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 1017 LogError("Failed to get the body of the uamqp message.");
AzureIoTClient 41:71c01aa3df1a 1018 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 1019 }
AzureIoTClient 41:71c01aa3df1a 1020 // 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 1021 else if ((iothub_message = IoTHubMessage_CreateFromByteArray(binary_data.bytes, binary_data.length)) == NULL)
AzureIoTClient 41:71c01aa3df1a 1022 {
AzureIoTClient 41:71c01aa3df1a 1023 // Codes_SRS_UAMQP_MESSAGING_09_007: [If IoTHubMessage_CreateFromByteArray() fails, message_create_IoTHubMessage_from_uamqp_message shall fail and return immediately.]
AzureIoTClient 41:71c01aa3df1a 1024 LogError("Failed creating the IOTHUB_MESSAGE_HANDLE instance (IoTHubMessage_CreateFromByteArray failed).");
AzureIoTClient 41:71c01aa3df1a 1025 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 1026 }
AzureIoTClient 41:71c01aa3df1a 1027 }
AzureIoTClient 41:71c01aa3df1a 1028 }
AzureIoTClient 23:2c6779675a01 1029
AzureIoTClient 41:71c01aa3df1a 1030 if (iothub_message != NULL)
AzureIoTClient 41:71c01aa3df1a 1031 {
AzureIoTClient 41:71c01aa3df1a 1032 if (readPropertiesFromuAMQPMessage(iothub_message, uamqp_message) != RESULT_OK)
AzureIoTClient 41:71c01aa3df1a 1033 {
AzureIoTClient 41:71c01aa3df1a 1034 LogError("Failed reading properties of the uamqp message.");
AzureIoTClient 41:71c01aa3df1a 1035 IoTHubMessage_Destroy(iothub_message);
AzureIoTClient 41:71c01aa3df1a 1036 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 1037 }
AzureIoTClient 41:71c01aa3df1a 1038 else if (readApplicationPropertiesFromuAMQPMessage(iothub_message, uamqp_message) != RESULT_OK)
AzureIoTClient 41:71c01aa3df1a 1039 {
AzureIoTClient 41:71c01aa3df1a 1040 LogError("Failed reading application properties of the uamqp message.");
AzureIoTClient 41:71c01aa3df1a 1041 IoTHubMessage_Destroy(iothub_message);
AzureIoTClient 41:71c01aa3df1a 1042 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 1043 }
AzureIoTClient 41:71c01aa3df1a 1044 else
AzureIoTClient 41:71c01aa3df1a 1045 {
AzureIoTClient 41:71c01aa3df1a 1046 *iothubclient_message = iothub_message;
AzureIoTClient 41:71c01aa3df1a 1047 result = RESULT_OK;
AzureIoTClient 41:71c01aa3df1a 1048 }
AzureIoTClient 41:71c01aa3df1a 1049 }
AzureIoTClient 23:2c6779675a01 1050
AzureIoTClient 41:71c01aa3df1a 1051 return result;
AzureIoTClient 23:2c6779675a01 1052 }
AzureIoTClient 23:2c6779675a01 1053