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@42:c2eaa912a28c, 2017-09-25 (annotated)

Committer:
AzureIoTClient
Date:
Mon Sep 25 13:37:09 2017 -0700
Revision:
42:c2eaa912a28c
Parent:
41:71c01aa3df1a
Child:
43:3da2d93bb955
1.1.24

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 41:71c01aa3df1a 27 static int encode_callback(void* context, const unsigned char* bytes, size_t length)
AzureIoTClient 23:2c6779675a01 28 {
AzureIoTClient 41:71c01aa3df1a 29 BINARY_DATA* message_body_binary = (BINARY_DATA*)context;
AzureIoTClient 41:71c01aa3df1a 30 (void)memcpy((unsigned char*)message_body_binary->bytes + message_body_binary->length, bytes, length);
AzureIoTClient 41:71c01aa3df1a 31 message_body_binary->length += length;
AzureIoTClient 41:71c01aa3df1a 32 return 0;
AzureIoTClient 41:71c01aa3df1a 33 }
AzureIoTClient 40:e79ee1341949 34
AzureIoTClient 41:71c01aa3df1a 35 // Codes_SRS_UAMQP_MESSAGING_31_112: [If optional message-id is present in the message, encode it into the AMQP message.]
AzureIoTClient 41:71c01aa3df1a 36 static int set_message_id_if_needed(IOTHUB_MESSAGE_HANDLE messageHandle, PROPERTIES_HANDLE uamqp_message_properties)
AzureIoTClient 41:71c01aa3df1a 37 {
AzureIoTClient 41:71c01aa3df1a 38 int result;
AzureIoTClient 41:71c01aa3df1a 39 const char* messageId;
AzureIoTClient 23:2c6779675a01 40
AzureIoTClient 41:71c01aa3df1a 41 if (NULL != (messageId = IoTHubMessage_GetMessageId(messageHandle)))
AzureIoTClient 41:71c01aa3df1a 42 {
AzureIoTClient 41:71c01aa3df1a 43 AMQP_VALUE uamqp_message_id;
AzureIoTClient 23:2c6779675a01 44
AzureIoTClient 41:71c01aa3df1a 45 if ((uamqp_message_id = amqpvalue_create_string(messageId)) == NULL)
AzureIoTClient 41:71c01aa3df1a 46 {
AzureIoTClient 41:71c01aa3df1a 47 LogError("Failed amqpvalue_create_string for message_id");
AzureIoTClient 41:71c01aa3df1a 48 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 49 }
AzureIoTClient 41:71c01aa3df1a 50 else if (properties_set_message_id(uamqp_message_properties, uamqp_message_id) != 0)
AzureIoTClient 40:e79ee1341949 51 {
AzureIoTClient 41:71c01aa3df1a 52 LogError("Failed properties_set_message_id");
AzureIoTClient 41:71c01aa3df1a 53 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 54 }
AzureIoTClient 41:71c01aa3df1a 55 else
AzureIoTClient 41:71c01aa3df1a 56 {
AzureIoTClient 41:71c01aa3df1a 57 result = RESULT_OK;
AzureIoTClient 40:e79ee1341949 58 }
AzureIoTClient 40:e79ee1341949 59
AzureIoTClient 41:71c01aa3df1a 60 if (NULL != uamqp_message_id)
AzureIoTClient 40:e79ee1341949 61 {
AzureIoTClient 41:71c01aa3df1a 62 amqpvalue_destroy(uamqp_message_id);
AzureIoTClient 41:71c01aa3df1a 63 }
AzureIoTClient 41:71c01aa3df1a 64 }
AzureIoTClient 41:71c01aa3df1a 65 else
AzureIoTClient 41:71c01aa3df1a 66 {
AzureIoTClient 41:71c01aa3df1a 67 result = RESULT_OK;
AzureIoTClient 41:71c01aa3df1a 68 }
AzureIoTClient 41:71c01aa3df1a 69
AzureIoTClient 41:71c01aa3df1a 70 return result;
AzureIoTClient 41:71c01aa3df1a 71 }
AzureIoTClient 41:71c01aa3df1a 72
AzureIoTClient 41:71c01aa3df1a 73 // Codes_SRS_UAMQP_MESSAGING_31_113: [If optional correlation-id is present in the message, encode it into the AMQP message.]
AzureIoTClient 41:71c01aa3df1a 74 static int set_message_correlation_id_if_needed(IOTHUB_MESSAGE_HANDLE messageHandle, PROPERTIES_HANDLE uamqp_message_properties)
AzureIoTClient 41:71c01aa3df1a 75 {
AzureIoTClient 41:71c01aa3df1a 76 int result;
AzureIoTClient 41:71c01aa3df1a 77 const char* correlationId;
AzureIoTClient 41:71c01aa3df1a 78
AzureIoTClient 41:71c01aa3df1a 79 if (NULL != (correlationId = IoTHubMessage_GetCorrelationId(messageHandle)))
AzureIoTClient 41:71c01aa3df1a 80 {
AzureIoTClient 41:71c01aa3df1a 81 AMQP_VALUE uamqp_correlation_id;
AzureIoTClient 41:71c01aa3df1a 82
AzureIoTClient 41:71c01aa3df1a 83 if ((uamqp_correlation_id = amqpvalue_create_string(correlationId)) == NULL)
AzureIoTClient 41:71c01aa3df1a 84 {
AzureIoTClient 41:71c01aa3df1a 85 LogError("Failed amqpvalue_create_string for message_id");
AzureIoTClient 41:71c01aa3df1a 86 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 87 }
AzureIoTClient 41:71c01aa3df1a 88 else if (properties_set_correlation_id(uamqp_message_properties, uamqp_correlation_id) != 0)
AzureIoTClient 41:71c01aa3df1a 89 {
AzureIoTClient 41:71c01aa3df1a 90 LogError("Failed properties_set_correlation_id");
AzureIoTClient 41:71c01aa3df1a 91 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 92 }
AzureIoTClient 41:71c01aa3df1a 93 else
AzureIoTClient 41:71c01aa3df1a 94 {
AzureIoTClient 41:71c01aa3df1a 95 result = RESULT_OK;
AzureIoTClient 40:e79ee1341949 96 }
AzureIoTClient 40:e79ee1341949 97
AzureIoTClient 41:71c01aa3df1a 98 if (uamqp_correlation_id != NULL)
AzureIoTClient 41:71c01aa3df1a 99 {
AzureIoTClient 41:71c01aa3df1a 100 amqpvalue_destroy(uamqp_correlation_id);
AzureIoTClient 41:71c01aa3df1a 101 }
AzureIoTClient 41:71c01aa3df1a 102 }
AzureIoTClient 41:71c01aa3df1a 103 else
AzureIoTClient 41:71c01aa3df1a 104 {
AzureIoTClient 41:71c01aa3df1a 105 result = RESULT_OK;
AzureIoTClient 41:71c01aa3df1a 106 }
AzureIoTClient 41:71c01aa3df1a 107
AzureIoTClient 41:71c01aa3df1a 108 return result;
AzureIoTClient 41:71c01aa3df1a 109 }
AzureIoTClient 41:71c01aa3df1a 110
AzureIoTClient 41:71c01aa3df1a 111 // Codes_SRS_UAMQP_MESSAGING_31_114: [If optional content-type is present in the message, encode it into the AMQP message.]
AzureIoTClient 41:71c01aa3df1a 112 static int set_message_content_type_if_needed(IOTHUB_MESSAGE_HANDLE messageHandle, PROPERTIES_HANDLE uamqp_message_properties)
AzureIoTClient 41:71c01aa3df1a 113 {
AzureIoTClient 41:71c01aa3df1a 114 int result;
AzureIoTClient 41:71c01aa3df1a 115 const char* content_type;
AzureIoTClient 41:71c01aa3df1a 116
AzureIoTClient 41:71c01aa3df1a 117 if ((content_type = IoTHubMessage_GetContentTypeSystemProperty(messageHandle)) != NULL)
AzureIoTClient 41:71c01aa3df1a 118 {
AzureIoTClient 41:71c01aa3df1a 119 if (properties_set_content_type(uamqp_message_properties, content_type) != 0)
AzureIoTClient 41:71c01aa3df1a 120 {
AzureIoTClient 41:71c01aa3df1a 121 LogError("Failed properties_set_content_type");
AzureIoTClient 41:71c01aa3df1a 122 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 123 }
AzureIoTClient 41:71c01aa3df1a 124 else
AzureIoTClient 41:71c01aa3df1a 125 {
AzureIoTClient 41:71c01aa3df1a 126 result = RESULT_OK;
AzureIoTClient 41:71c01aa3df1a 127 }
AzureIoTClient 41:71c01aa3df1a 128 }
AzureIoTClient 41:71c01aa3df1a 129 else
AzureIoTClient 41:71c01aa3df1a 130 {
AzureIoTClient 41:71c01aa3df1a 131 result = RESULT_OK;
AzureIoTClient 41:71c01aa3df1a 132 }
AzureIoTClient 41:71c01aa3df1a 133
AzureIoTClient 41:71c01aa3df1a 134 return result;
AzureIoTClient 41:71c01aa3df1a 135 }
AzureIoTClient 41:71c01aa3df1a 136
AzureIoTClient 41:71c01aa3df1a 137 // Codes_SRS_UAMQP_MESSAGING_31_115: [If optional content-encoding is present in the message, encode it into the AMQP message.]
AzureIoTClient 41:71c01aa3df1a 138 static int set_message_content_encoding_if_needed(IOTHUB_MESSAGE_HANDLE messageHandle, PROPERTIES_HANDLE uamqp_message_properties)
AzureIoTClient 41:71c01aa3df1a 139 {
AzureIoTClient 41:71c01aa3df1a 140 int result;
AzureIoTClient 41:71c01aa3df1a 141 const char* content_encoding;
AzureIoTClient 23:2c6779675a01 142
AzureIoTClient 41:71c01aa3df1a 143 if ((content_encoding = IoTHubMessage_GetContentEncodingSystemProperty(messageHandle)) != NULL)
AzureIoTClient 41:71c01aa3df1a 144 {
AzureIoTClient 41:71c01aa3df1a 145 if (properties_set_content_encoding(uamqp_message_properties, content_encoding) != 0)
AzureIoTClient 41:71c01aa3df1a 146 {
AzureIoTClient 41:71c01aa3df1a 147 LogError("Failed properties_set_content_encoding");
AzureIoTClient 41:71c01aa3df1a 148 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 149 }
AzureIoTClient 41:71c01aa3df1a 150 else
AzureIoTClient 41:71c01aa3df1a 151 {
AzureIoTClient 41:71c01aa3df1a 152 result = RESULT_OK;
AzureIoTClient 41:71c01aa3df1a 153 }
AzureIoTClient 41:71c01aa3df1a 154 }
AzureIoTClient 41:71c01aa3df1a 155 else
AzureIoTClient 41:71c01aa3df1a 156 {
AzureIoTClient 41:71c01aa3df1a 157 result = RESULT_OK;
AzureIoTClient 41:71c01aa3df1a 158 }
AzureIoTClient 41:71c01aa3df1a 159
AzureIoTClient 41:71c01aa3df1a 160 return result;
AzureIoTClient 41:71c01aa3df1a 161 }
AzureIoTClient 41:71c01aa3df1a 162
AzureIoTClient 41:71c01aa3df1a 163
AzureIoTClient 41:71c01aa3df1a 164 // 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 165 static int create_message_properties_to_encode(IOTHUB_MESSAGE_HANDLE messageHandle, AMQP_VALUE *message_properties, size_t *message_properties_length)
AzureIoTClient 41:71c01aa3df1a 166 {
AzureIoTClient 41:71c01aa3df1a 167 PROPERTIES_HANDLE uamqp_message_properties = NULL;
AzureIoTClient 41:71c01aa3df1a 168 int result;
AzureIoTClient 23:2c6779675a01 169
AzureIoTClient 41:71c01aa3df1a 170 if ((uamqp_message_properties = properties_create()) == NULL)
AzureIoTClient 41:71c01aa3df1a 171 {
AzureIoTClient 41:71c01aa3df1a 172 LogError("Failed on properties_create()");
AzureIoTClient 41:71c01aa3df1a 173 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 174 }
AzureIoTClient 41:71c01aa3df1a 175 else if (set_message_id_if_needed(messageHandle, uamqp_message_properties) != RESULT_OK)
AzureIoTClient 41:71c01aa3df1a 176 {
AzureIoTClient 41:71c01aa3df1a 177 LogError("Failed on set_message_id_if_needed()");
AzureIoTClient 41:71c01aa3df1a 178 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 179 }
AzureIoTClient 41:71c01aa3df1a 180 else if (set_message_correlation_id_if_needed(messageHandle, uamqp_message_properties) != RESULT_OK)
AzureIoTClient 41:71c01aa3df1a 181 {
AzureIoTClient 41:71c01aa3df1a 182 LogError("Failed on set_message_correlation_id_if_needed()");
AzureIoTClient 41:71c01aa3df1a 183 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 184 }
AzureIoTClient 41:71c01aa3df1a 185 else if (set_message_content_type_if_needed(messageHandle, uamqp_message_properties) != RESULT_OK)
AzureIoTClient 41:71c01aa3df1a 186 {
AzureIoTClient 41:71c01aa3df1a 187 LogError("Failed on set_message_content_type_if_needed()");
AzureIoTClient 41:71c01aa3df1a 188 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 189 }
AzureIoTClient 41:71c01aa3df1a 190 else if (set_message_content_encoding_if_needed(messageHandle, uamqp_message_properties) != RESULT_OK)
AzureIoTClient 41:71c01aa3df1a 191 {
AzureIoTClient 41:71c01aa3df1a 192 LogError("Failed on set_message_content_encoding_if_needed()");
AzureIoTClient 41:71c01aa3df1a 193 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 194 }
AzureIoTClient 41:71c01aa3df1a 195 else if ((*message_properties = amqpvalue_create_properties(uamqp_message_properties)) == NULL)
AzureIoTClient 41:71c01aa3df1a 196 {
AzureIoTClient 41:71c01aa3df1a 197 LogError("Failed on amqpvalue_create_properties()");
AzureIoTClient 41:71c01aa3df1a 198 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 199 }
AzureIoTClient 41:71c01aa3df1a 200 else if ((amqpvalue_get_encoded_size(*message_properties, message_properties_length)) != 0)
AzureIoTClient 41:71c01aa3df1a 201 {
AzureIoTClient 41:71c01aa3df1a 202 LogError("Failed on amqpvalue_get_encoded_size()");
AzureIoTClient 41:71c01aa3df1a 203 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 204 }
AzureIoTClient 41:71c01aa3df1a 205 else
AzureIoTClient 41:71c01aa3df1a 206 {
AzureIoTClient 41:71c01aa3df1a 207 result = RESULT_OK;
AzureIoTClient 41:71c01aa3df1a 208 }
AzureIoTClient 41:71c01aa3df1a 209
AzureIoTClient 41:71c01aa3df1a 210 if (NULL != uamqp_message_properties)
AzureIoTClient 41:71c01aa3df1a 211 {
AzureIoTClient 41:71c01aa3df1a 212 properties_destroy(uamqp_message_properties);
AzureIoTClient 41:71c01aa3df1a 213 }
AzureIoTClient 41:71c01aa3df1a 214
AzureIoTClient 41:71c01aa3df1a 215 return result;
AzureIoTClient 23:2c6779675a01 216 }
AzureIoTClient 23:2c6779675a01 217
AzureIoTClient 41:71c01aa3df1a 218 // 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 219 static int create_application_properties_to_encode(IOTHUB_MESSAGE_HANDLE messageHandle, AMQP_VALUE *application_properties, size_t *application_properties_length)
AzureIoTClient 23:2c6779675a01 220 {
AzureIoTClient 41:71c01aa3df1a 221 MAP_HANDLE properties_map;
AzureIoTClient 41:71c01aa3df1a 222 const char* const* property_keys;
AzureIoTClient 41:71c01aa3df1a 223 const char* const* property_values;
AzureIoTClient 41:71c01aa3df1a 224 size_t property_count = 0;
AzureIoTClient 41:71c01aa3df1a 225 AMQP_VALUE uamqp_properties_map = NULL;
AzureIoTClient 41:71c01aa3df1a 226 int result;
AzureIoTClient 41:71c01aa3df1a 227
AzureIoTClient 41:71c01aa3df1a 228 if ((properties_map = IoTHubMessage_Properties(messageHandle)) == NULL)
AzureIoTClient 41:71c01aa3df1a 229 {
AzureIoTClient 41:71c01aa3df1a 230 LogError("Failed to get property map from IoTHub message.");
AzureIoTClient 41:71c01aa3df1a 231 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 232 }
AzureIoTClient 41:71c01aa3df1a 233 else if (Map_GetInternals(properties_map, &property_keys, &property_values, &property_count) != 0)
AzureIoTClient 41:71c01aa3df1a 234 {
AzureIoTClient 41:71c01aa3df1a 235 LogError("Failed reading the incoming uAMQP message properties");
AzureIoTClient 41:71c01aa3df1a 236 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 237 }
AzureIoTClient 41:71c01aa3df1a 238 else if (property_count > 0)
AzureIoTClient 41:71c01aa3df1a 239 {
AzureIoTClient 41:71c01aa3df1a 240 size_t i;
AzureIoTClient 41:71c01aa3df1a 241 if ((uamqp_properties_map = amqpvalue_create_map()) == NULL)
AzureIoTClient 41:71c01aa3df1a 242 {
AzureIoTClient 41:71c01aa3df1a 243 LogError("amqpvalue_create_map failed");
AzureIoTClient 41:71c01aa3df1a 244 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 245 }
AzureIoTClient 41:71c01aa3df1a 246 else
AzureIoTClient 41:71c01aa3df1a 247 {
AzureIoTClient 41:71c01aa3df1a 248 result = RESULT_OK;
AzureIoTClient 41:71c01aa3df1a 249
AzureIoTClient 41:71c01aa3df1a 250 for (i = 0; i < property_count; i++)
AzureIoTClient 41:71c01aa3df1a 251 {
AzureIoTClient 41:71c01aa3df1a 252 AMQP_VALUE map_property_key;
AzureIoTClient 41:71c01aa3df1a 253 AMQP_VALUE map_property_value;
AzureIoTClient 41:71c01aa3df1a 254
AzureIoTClient 41:71c01aa3df1a 255 if ((map_property_key = amqpvalue_create_string(property_keys[i])) == NULL)
AzureIoTClient 41:71c01aa3df1a 256 {
AzureIoTClient 41:71c01aa3df1a 257 LogError("Failed amqpvalue_create_string for key");
AzureIoTClient 41:71c01aa3df1a 258 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 259 break;
AzureIoTClient 41:71c01aa3df1a 260 }
AzureIoTClient 23:2c6779675a01 261
AzureIoTClient 41:71c01aa3df1a 262 if ((map_property_value = amqpvalue_create_string(property_values[i])) == NULL)
AzureIoTClient 41:71c01aa3df1a 263 {
AzureIoTClient 41:71c01aa3df1a 264 LogError("Failed amqpvalue_create_string for value");
AzureIoTClient 41:71c01aa3df1a 265 amqpvalue_destroy(map_property_key);
AzureIoTClient 41:71c01aa3df1a 266 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 267 break;
AzureIoTClient 41:71c01aa3df1a 268 }
AzureIoTClient 41:71c01aa3df1a 269
AzureIoTClient 41:71c01aa3df1a 270 if (amqpvalue_set_map_value(uamqp_properties_map, map_property_key, map_property_value) != 0)
AzureIoTClient 41:71c01aa3df1a 271 {
AzureIoTClient 41:71c01aa3df1a 272 LogError("Failed amqpvalue_set_map_value");
AzureIoTClient 41:71c01aa3df1a 273 amqpvalue_destroy(map_property_key);
AzureIoTClient 41:71c01aa3df1a 274 amqpvalue_destroy(map_property_value);
AzureIoTClient 41:71c01aa3df1a 275 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 276 break;
AzureIoTClient 41:71c01aa3df1a 277 }
AzureIoTClient 41:71c01aa3df1a 278
AzureIoTClient 41:71c01aa3df1a 279 amqpvalue_destroy(map_property_key);
AzureIoTClient 41:71c01aa3df1a 280 amqpvalue_destroy(map_property_value);
AzureIoTClient 41:71c01aa3df1a 281 }
AzureIoTClient 23:2c6779675a01 282
AzureIoTClient 41:71c01aa3df1a 283 if (RESULT_OK == result)
AzureIoTClient 41:71c01aa3df1a 284 {
AzureIoTClient 41:71c01aa3df1a 285 if ((*application_properties = amqpvalue_create_application_properties(uamqp_properties_map)) == NULL)
AzureIoTClient 41:71c01aa3df1a 286 {
AzureIoTClient 41:71c01aa3df1a 287 LogError("Failed amqpvalue_create_application_properties");
AzureIoTClient 41:71c01aa3df1a 288 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 289 }
AzureIoTClient 41:71c01aa3df1a 290 else if (amqpvalue_get_encoded_size(*application_properties, application_properties_length) != 0)
AzureIoTClient 41:71c01aa3df1a 291 {
AzureIoTClient 41:71c01aa3df1a 292 LogError("Failed amqpvalue_get_encoded_size");
AzureIoTClient 41:71c01aa3df1a 293 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 294 }
AzureIoTClient 41:71c01aa3df1a 295 }
AzureIoTClient 41:71c01aa3df1a 296 }
AzureIoTClient 41:71c01aa3df1a 297 }
AzureIoTClient 41:71c01aa3df1a 298 else
AzureIoTClient 41:71c01aa3df1a 299 {
AzureIoTClient 41:71c01aa3df1a 300 result = RESULT_OK;
AzureIoTClient 41:71c01aa3df1a 301 }
AzureIoTClient 41:71c01aa3df1a 302
AzureIoTClient 41:71c01aa3df1a 303 if (NULL != uamqp_properties_map)
AzureIoTClient 41:71c01aa3df1a 304 {
AzureIoTClient 41:71c01aa3df1a 305 amqpvalue_destroy(uamqp_properties_map);
AzureIoTClient 41:71c01aa3df1a 306 }
AzureIoTClient 41:71c01aa3df1a 307
AzureIoTClient 41:71c01aa3df1a 308 return result;
AzureIoTClient 41:71c01aa3df1a 309 }
AzureIoTClient 41:71c01aa3df1a 310
AzureIoTClient 41:71c01aa3df1a 311
AzureIoTClient 41:71c01aa3df1a 312 // 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 313 static int create_data_to_encode(IOTHUB_MESSAGE_HANDLE messageHandle, AMQP_VALUE *data_value, size_t *data_length)
AzureIoTClient 41:71c01aa3df1a 314 {
AzureIoTClient 41:71c01aa3df1a 315 int result;
AzureIoTClient 41:71c01aa3df1a 316
AzureIoTClient 41:71c01aa3df1a 317 IOTHUBMESSAGE_CONTENT_TYPE contentType = IoTHubMessage_GetContentType(messageHandle);
AzureIoTClient 41:71c01aa3df1a 318 const char* messageContent = NULL;
AzureIoTClient 41:71c01aa3df1a 319 size_t messageContentSize = 0;
AzureIoTClient 23:2c6779675a01 320
AzureIoTClient 41:71c01aa3df1a 321 if ((contentType == IOTHUBMESSAGE_BYTEARRAY) &&
AzureIoTClient 41:71c01aa3df1a 322 IoTHubMessage_GetByteArray(messageHandle, (const unsigned char **)&messageContent, &messageContentSize) != IOTHUB_MESSAGE_OK)
AzureIoTClient 41:71c01aa3df1a 323 {
AzureIoTClient 41:71c01aa3df1a 324 LogError("Failed getting the BYTE array representation of the IOTHUB_MESSAGE_HANDLE instance.");
AzureIoTClient 41:71c01aa3df1a 325 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 326 }
AzureIoTClient 41:71c01aa3df1a 327 else if ((contentType == IOTHUBMESSAGE_STRING) &&
AzureIoTClient 41:71c01aa3df1a 328 ((messageContent = IoTHubMessage_GetString(messageHandle)) == NULL))
AzureIoTClient 41:71c01aa3df1a 329 {
AzureIoTClient 41:71c01aa3df1a 330 LogError("Failed getting the STRING representation of the IOTHUB_MESSAGE_HANDLE instance.");
AzureIoTClient 41:71c01aa3df1a 331 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 332 }
AzureIoTClient 41:71c01aa3df1a 333 else if (contentType == IOTHUBMESSAGE_UNKNOWN)
AzureIoTClient 41:71c01aa3df1a 334 {
AzureIoTClient 41:71c01aa3df1a 335 LogError("Cannot parse IOTHUB_MESSAGE_HANDLE with content type IOTHUBMESSAGE_UNKNOWN.");
AzureIoTClient 41:71c01aa3df1a 336 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 337 }
AzureIoTClient 41:71c01aa3df1a 338 else
AzureIoTClient 41:71c01aa3df1a 339 {
AzureIoTClient 41:71c01aa3df1a 340 if (contentType == IOTHUBMESSAGE_STRING)
AzureIoTClient 41:71c01aa3df1a 341 {
AzureIoTClient 41:71c01aa3df1a 342 messageContentSize = strlen(messageContent);
AzureIoTClient 41:71c01aa3df1a 343 }
AzureIoTClient 41:71c01aa3df1a 344
AzureIoTClient 41:71c01aa3df1a 345 data bin_data;
AzureIoTClient 41:71c01aa3df1a 346 bin_data.bytes = (const unsigned char *)messageContent;
AzureIoTClient 41:71c01aa3df1a 347 bin_data.length = (uint32_t)messageContentSize;
AzureIoTClient 23:2c6779675a01 348
AzureIoTClient 41:71c01aa3df1a 349 if ((*data_value = amqpvalue_create_data(bin_data)) == NULL)
AzureIoTClient 41:71c01aa3df1a 350 {
AzureIoTClient 41:71c01aa3df1a 351 LogError("amqpvalue_create_data failed");
AzureIoTClient 41:71c01aa3df1a 352 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 353 }
AzureIoTClient 41:71c01aa3df1a 354 else if (amqpvalue_get_encoded_size(*data_value, data_length) != 0)
AzureIoTClient 41:71c01aa3df1a 355 {
AzureIoTClient 41:71c01aa3df1a 356 LogError("amqpvalue_get_encoded_size failed");
AzureIoTClient 41:71c01aa3df1a 357 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 358 }
AzureIoTClient 41:71c01aa3df1a 359 else
AzureIoTClient 41:71c01aa3df1a 360 {
AzureIoTClient 41:71c01aa3df1a 361 result = RESULT_OK;
AzureIoTClient 41:71c01aa3df1a 362 }
AzureIoTClient 41:71c01aa3df1a 363 }
AzureIoTClient 41:71c01aa3df1a 364
AzureIoTClient 41:71c01aa3df1a 365 return result;
AzureIoTClient 41:71c01aa3df1a 366 }
AzureIoTClient 41:71c01aa3df1a 367
AzureIoTClient 41:71c01aa3df1a 368 // Codes_SRS_UAMQP_MESSAGING_31_120: [Create a blob that contains AMQP encoding of IOTHUB_MESSAGE_HANDLE.]
AzureIoTClient 41:71c01aa3df1a 369 // Codes_SRS_UAMQP_MESSAGING_31_121: [Any errors during `message_create_uamqp_encoding_from_iothub_message` stop processing on this message.]
AzureIoTClient 41:71c01aa3df1a 370 int message_create_uamqp_encoding_from_iothub_message(IOTHUB_MESSAGE_HANDLE message_handle, BINARY_DATA* body_binary_data)
AzureIoTClient 41:71c01aa3df1a 371 {
AzureIoTClient 41:71c01aa3df1a 372 int result;
AzureIoTClient 41:71c01aa3df1a 373
AzureIoTClient 41:71c01aa3df1a 374 AMQP_VALUE message_properties = NULL;
AzureIoTClient 41:71c01aa3df1a 375 AMQP_VALUE application_properties = NULL;
AzureIoTClient 41:71c01aa3df1a 376 AMQP_VALUE data_value = NULL;
AzureIoTClient 41:71c01aa3df1a 377 size_t message_properties_length = 0;
AzureIoTClient 41:71c01aa3df1a 378 size_t application_properties_length = 0;
AzureIoTClient 41:71c01aa3df1a 379 size_t data_length = 0;
AzureIoTClient 23:2c6779675a01 380
AzureIoTClient 41:71c01aa3df1a 381 body_binary_data->bytes = NULL;
AzureIoTClient 41:71c01aa3df1a 382 body_binary_data->length = 0;
AzureIoTClient 23:2c6779675a01 383
AzureIoTClient 41:71c01aa3df1a 384 if (create_message_properties_to_encode(message_handle, &message_properties, &message_properties_length) != RESULT_OK)
AzureIoTClient 41:71c01aa3df1a 385 {
AzureIoTClient 41:71c01aa3df1a 386 LogError("create_message_properties_to_encode() failed");
AzureIoTClient 41:71c01aa3df1a 387 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 388 }
AzureIoTClient 41:71c01aa3df1a 389 else if (create_application_properties_to_encode(message_handle, &application_properties, &application_properties_length) != RESULT_OK)
AzureIoTClient 41:71c01aa3df1a 390 {
AzureIoTClient 41:71c01aa3df1a 391 LogError("create_application_properties_to_encode() failed");
AzureIoTClient 41:71c01aa3df1a 392 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 393 }
AzureIoTClient 41:71c01aa3df1a 394 else if (create_data_to_encode(message_handle, &data_value, &data_length) != RESULT_OK)
AzureIoTClient 41:71c01aa3df1a 395 {
AzureIoTClient 41:71c01aa3df1a 396 LogError("create_data_to_encode() failed");
AzureIoTClient 41:71c01aa3df1a 397 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 398 }
AzureIoTClient 41:71c01aa3df1a 399 else if ((body_binary_data->bytes = malloc(message_properties_length + application_properties_length + data_length)) == NULL)
AzureIoTClient 41:71c01aa3df1a 400 {
AzureIoTClient 41:71c01aa3df1a 401 LogError("malloc of %d bytes failed", message_properties_length + application_properties_length + data_length);
AzureIoTClient 41:71c01aa3df1a 402 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 403 }
AzureIoTClient 41:71c01aa3df1a 404 // Codes_SRS_UAMQP_MESSAGING_31_119: [Invoke underlying AMQP encode routines on data waiting to be encoded.]
AzureIoTClient 41:71c01aa3df1a 405 else if (amqpvalue_encode(message_properties, &encode_callback, body_binary_data) != RESULT_OK)
AzureIoTClient 41:71c01aa3df1a 406 {
AzureIoTClient 41:71c01aa3df1a 407 LogError("amqpvalue_encode() for message properties failed");
AzureIoTClient 41:71c01aa3df1a 408 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 409 }
AzureIoTClient 41:71c01aa3df1a 410 else if ((application_properties_length > 0) && (amqpvalue_encode(application_properties, &encode_callback, body_binary_data) != RESULT_OK))
AzureIoTClient 41:71c01aa3df1a 411 {
AzureIoTClient 41:71c01aa3df1a 412 LogError("amqpvalue_encode() for application properties failed");
AzureIoTClient 41:71c01aa3df1a 413 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 414 }
AzureIoTClient 41:71c01aa3df1a 415 else if (RESULT_OK != amqpvalue_encode(data_value, &encode_callback, body_binary_data))
AzureIoTClient 41:71c01aa3df1a 416 {
AzureIoTClient 41:71c01aa3df1a 417 LogError("amqpvalue_encode() for data value failed");
AzureIoTClient 41:71c01aa3df1a 418 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 419 }
AzureIoTClient 41:71c01aa3df1a 420 else
AzureIoTClient 41:71c01aa3df1a 421 {
AzureIoTClient 41:71c01aa3df1a 422 body_binary_data->length = message_properties_length + application_properties_length + data_length;
AzureIoTClient 41:71c01aa3df1a 423 result = RESULT_OK;
AzureIoTClient 41:71c01aa3df1a 424 }
AzureIoTClient 23:2c6779675a01 425
AzureIoTClient 41:71c01aa3df1a 426 if (NULL != data_value)
AzureIoTClient 41:71c01aa3df1a 427 {
AzureIoTClient 41:71c01aa3df1a 428 amqpvalue_destroy(data_value);
AzureIoTClient 41:71c01aa3df1a 429 }
AzureIoTClient 23:2c6779675a01 430
AzureIoTClient 41:71c01aa3df1a 431 if (NULL != application_properties)
AzureIoTClient 41:71c01aa3df1a 432 {
AzureIoTClient 41:71c01aa3df1a 433 amqpvalue_destroy(application_properties);
AzureIoTClient 41:71c01aa3df1a 434 }
AzureIoTClient 41:71c01aa3df1a 435
AzureIoTClient 41:71c01aa3df1a 436 if (NULL != message_properties)
AzureIoTClient 41:71c01aa3df1a 437 {
AzureIoTClient 41:71c01aa3df1a 438 amqpvalue_destroy(message_properties);
AzureIoTClient 41:71c01aa3df1a 439 }
AzureIoTClient 41:71c01aa3df1a 440
AzureIoTClient 41:71c01aa3df1a 441 return result;
AzureIoTClient 23:2c6779675a01 442 }
AzureIoTClient 23:2c6779675a01 443
AzureIoTClient 23:2c6779675a01 444 static int readPropertiesFromuAMQPMessage(IOTHUB_MESSAGE_HANDLE iothub_message_handle, MESSAGE_HANDLE uamqp_message)
AzureIoTClient 23:2c6779675a01 445 {
AzureIoTClient 42:c2eaa912a28c 446 int result;
AzureIoTClient 41:71c01aa3df1a 447 PROPERTIES_HANDLE uamqp_message_properties;
AzureIoTClient 41:71c01aa3df1a 448 AMQP_VALUE uamqp_message_property;
AzureIoTClient 23:2c6779675a01 449
AzureIoTClient 41:71c01aa3df1a 450 // Codes_SRS_UAMQP_MESSAGING_09_008: [The uAMQP message properties shall be retrieved using message_get_properties().]
AzureIoTClient 42:c2eaa912a28c 451 if (message_get_properties(uamqp_message, &uamqp_message_properties) != 0)
AzureIoTClient 41:71c01aa3df1a 452 {
AzureIoTClient 41:71c01aa3df1a 453 // 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 454 LogError("Failed to get property properties map from uAMQP message.");
AzureIoTClient 42:c2eaa912a28c 455 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 456 }
AzureIoTClient 40:e79ee1341949 457 else
AzureIoTClient 40:e79ee1341949 458 {
AzureIoTClient 42:c2eaa912a28c 459 result = RESULT_OK; // Properties 'message-id' and 'correlation-id' are optional according to the AMQP 1.0 spec.
AzureIoTClient 40:e79ee1341949 460
AzureIoTClient 40:e79ee1341949 461 // Codes_SRS_UAMQP_MESSAGING_09_010: [The message-id property shall be read from the uAMQP message by calling properties_get_message_id.]
AzureIoTClient 42:c2eaa912a28c 462 if (properties_get_message_id(uamqp_message_properties, &uamqp_message_property) != 0 || uamqp_message_property == NULL)
AzureIoTClient 40:e79ee1341949 463 {
AzureIoTClient 41:71c01aa3df1a 464 // Codes_SRS_UAMQP_MESSAGING_09_011: [If properties_get_message_id fails, message_create_IoTHubMessage_from_uamqp_message() shall fail and return immediately.]
AzureIoTClient 40:e79ee1341949 465 }
AzureIoTClient 42:c2eaa912a28c 466 else
AzureIoTClient 40:e79ee1341949 467 {
AzureIoTClient 42:c2eaa912a28c 468 // Codes_SRS_UAMQP_MESSAGING_09_012: [The type of the message-id property value shall be obtained using amqpvalue_get_type().]
AzureIoTClient 42:c2eaa912a28c 469 AMQP_TYPE value_type = amqpvalue_get_type(uamqp_message_property);
AzureIoTClient 42:c2eaa912a28c 470
AzureIoTClient 42:c2eaa912a28c 471 // 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 42:c2eaa912a28c 472 if (value_type != AMQP_TYPE_NULL)
AzureIoTClient 40:e79ee1341949 473 {
AzureIoTClient 42:c2eaa912a28c 474
AzureIoTClient 42:c2eaa912a28c 475 char* string_value;
AzureIoTClient 42:c2eaa912a28c 476 char string_buffer[MESSAGE_ID_MAX_SIZE];
AzureIoTClient 42:c2eaa912a28c 477
AzureIoTClient 42:c2eaa912a28c 478 memset(string_buffer, 0, MESSAGE_ID_MAX_SIZE);
AzureIoTClient 42:c2eaa912a28c 479
AzureIoTClient 42:c2eaa912a28c 480 if (value_type == AMQP_TYPE_STRING)
AzureIoTClient 42:c2eaa912a28c 481 {
AzureIoTClient 42:c2eaa912a28c 482 // Codes_SRS_UAMQP_MESSAGING_09_014: [The message-id value shall be retrieved from the AMQP_VALUE as char sequence]
AzureIoTClient 42:c2eaa912a28c 483 if (amqpvalue_get_string(uamqp_message_property, (const char**)(&string_value)) != 0)
AzureIoTClient 42:c2eaa912a28c 484 {
AzureIoTClient 42:c2eaa912a28c 485 // 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 42:c2eaa912a28c 486 LogError("Failed to get value of uAMQP message 'message-id' property (string)");
AzureIoTClient 42:c2eaa912a28c 487 string_value = NULL;
AzureIoTClient 42:c2eaa912a28c 488 result = __FAILURE__;
AzureIoTClient 42:c2eaa912a28c 489 }
AzureIoTClient 42:c2eaa912a28c 490 }
AzureIoTClient 42:c2eaa912a28c 491 else if (value_type == AMQP_TYPE_ULONG)
AzureIoTClient 42:c2eaa912a28c 492 {
AzureIoTClient 42:c2eaa912a28c 493 uint64_t ulong_value;
AzureIoTClient 42:c2eaa912a28c 494
AzureIoTClient 42:c2eaa912a28c 495 // Codes_SRS_UAMQP_MESSAGING_09_014: [The message-id value shall be retrieved from the AMQP_VALUE as char sequence]
AzureIoTClient 42:c2eaa912a28c 496 if (amqpvalue_get_ulong(uamqp_message_property, &ulong_value) != 0)
AzureIoTClient 42:c2eaa912a28c 497 {
AzureIoTClient 42:c2eaa912a28c 498 // 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 42:c2eaa912a28c 499 LogError("Failed to get value of uAMQP message 'message-id' property (ulong)");
AzureIoTClient 42:c2eaa912a28c 500 string_value = NULL;
AzureIoTClient 42:c2eaa912a28c 501 result = __FAILURE__;
AzureIoTClient 42:c2eaa912a28c 502 }
AzureIoTClient 42:c2eaa912a28c 503 else if (sprintf(string_buffer, "%" PRIu64, ulong_value) < 0)
AzureIoTClient 42:c2eaa912a28c 504 {
AzureIoTClient 42:c2eaa912a28c 505 LogError("Failed converting 'message-id' (ulong) to string");
AzureIoTClient 42:c2eaa912a28c 506 string_value = NULL;
AzureIoTClient 42:c2eaa912a28c 507 result = __FAILURE__;
AzureIoTClient 42:c2eaa912a28c 508 }
AzureIoTClient 42:c2eaa912a28c 509 else
AzureIoTClient 42:c2eaa912a28c 510 {
AzureIoTClient 42:c2eaa912a28c 511 string_value = string_buffer;
AzureIoTClient 42:c2eaa912a28c 512 }
AzureIoTClient 42:c2eaa912a28c 513 }
AzureIoTClient 42:c2eaa912a28c 514 else if (value_type == AMQP_TYPE_UUID)
AzureIoTClient 42:c2eaa912a28c 515 {
AzureIoTClient 42:c2eaa912a28c 516 uuid uuid_value;
AzureIoTClient 42:c2eaa912a28c 517
AzureIoTClient 42:c2eaa912a28c 518 // Codes_SRS_UAMQP_MESSAGING_09_014: [The message-id value shall be retrieved from the AMQP_VALUE as char sequence]
AzureIoTClient 42:c2eaa912a28c 519 if (amqpvalue_get_uuid(uamqp_message_property, &uuid_value) != 0)
AzureIoTClient 42:c2eaa912a28c 520 {
AzureIoTClient 42:c2eaa912a28c 521 // 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 42:c2eaa912a28c 522 LogError("Failed to get value of uAMQP message 'message-id' property (UUID)");
AzureIoTClient 42:c2eaa912a28c 523 string_value = NULL;
AzureIoTClient 42:c2eaa912a28c 524 result = __FAILURE__;
AzureIoTClient 42:c2eaa912a28c 525 }
AzureIoTClient 42:c2eaa912a28c 526 else if ((string_value = UUID_to_string((UUID*)uuid_value)) == NULL)
AzureIoTClient 42:c2eaa912a28c 527 {
AzureIoTClient 42:c2eaa912a28c 528 // 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 42:c2eaa912a28c 529 LogError("Failed to get the string representation of 'message-id' UUID");
AzureIoTClient 42:c2eaa912a28c 530 string_value = NULL;
AzureIoTClient 42:c2eaa912a28c 531 result = __FAILURE__;
AzureIoTClient 42:c2eaa912a28c 532 }
AzureIoTClient 42:c2eaa912a28c 533 else
AzureIoTClient 42:c2eaa912a28c 534 {
AzureIoTClient 42:c2eaa912a28c 535 (void)memcpy(string_buffer, string_value, sizeof(char) * strlen(string_value));
AzureIoTClient 42:c2eaa912a28c 536 free(string_value);
AzureIoTClient 42:c2eaa912a28c 537 string_value = string_buffer;
AzureIoTClient 42:c2eaa912a28c 538 }
AzureIoTClient 42:c2eaa912a28c 539 }
AzureIoTClient 42:c2eaa912a28c 540 else
AzureIoTClient 42:c2eaa912a28c 541 {
AzureIoTClient 42:c2eaa912a28c 542 LogError("Unrecognized type for message-id (%d)", value_type);
AzureIoTClient 42:c2eaa912a28c 543 string_value = NULL;
AzureIoTClient 42:c2eaa912a28c 544 result = __FAILURE__;
AzureIoTClient 42:c2eaa912a28c 545 }
AzureIoTClient 42:c2eaa912a28c 546
AzureIoTClient 42:c2eaa912a28c 547 if (string_value != NULL)
AzureIoTClient 42:c2eaa912a28c 548 {
AzureIoTClient 42:c2eaa912a28c 549 // 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 42:c2eaa912a28c 550 if (IoTHubMessage_SetMessageId(iothub_message_handle, string_value) != IOTHUB_MESSAGE_OK)
AzureIoTClient 42:c2eaa912a28c 551 {
AzureIoTClient 42:c2eaa912a28c 552 // Codes_SRS_UAMQP_MESSAGING_09_017: [If IoTHubMessage_SetMessageId fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.]
AzureIoTClient 42:c2eaa912a28c 553 LogError("Failed to set IOTHUB_MESSAGE_HANDLE 'message-id' property.");
AzureIoTClient 42:c2eaa912a28c 554 result = __FAILURE__;
AzureIoTClient 42:c2eaa912a28c 555 }
AzureIoTClient 42:c2eaa912a28c 556 }
AzureIoTClient 40:e79ee1341949 557 }
AzureIoTClient 40:e79ee1341949 558 }
AzureIoTClient 23:2c6779675a01 559
AzureIoTClient 40:e79ee1341949 560 // Codes_SRS_UAMQP_MESSAGING_09_018: [The correlation-id property shall be read from the uAMQP message by calling properties_get_correlation_id.]
AzureIoTClient 42:c2eaa912a28c 561 if (properties_get_correlation_id(uamqp_message_properties, &uamqp_message_property) != 0 || uamqp_message_property == NULL)
AzureIoTClient 40:e79ee1341949 562 {
AzureIoTClient 41:71c01aa3df1a 563 // Codes_SRS_UAMQP_MESSAGING_09_019: [If properties_get_correlation_id() fails, message_create_IoTHubMessage_from_uamqp_message() shall fail and return immediately.]
AzureIoTClient 40:e79ee1341949 564 }
AzureIoTClient 42:c2eaa912a28c 565 else
AzureIoTClient 40:e79ee1341949 566 {
AzureIoTClient 42:c2eaa912a28c 567 // Codes_SRS_UAMQP_MESSAGING_09_020: [The type of the correlation-id property value shall be obtained using amqpvalue_get_type().]
AzureIoTClient 42:c2eaa912a28c 568 AMQP_TYPE value_type = amqpvalue_get_type(uamqp_message_property);
AzureIoTClient 42:c2eaa912a28c 569
AzureIoTClient 42:c2eaa912a28c 570 // 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 42:c2eaa912a28c 571 if (value_type != AMQP_TYPE_NULL)
AzureIoTClient 40:e79ee1341949 572 {
AzureIoTClient 42:c2eaa912a28c 573 char* string_value;
AzureIoTClient 42:c2eaa912a28c 574 char string_buffer[MESSAGE_ID_MAX_SIZE];
AzureIoTClient 42:c2eaa912a28c 575
AzureIoTClient 42:c2eaa912a28c 576 memset(string_buffer, 0, MESSAGE_ID_MAX_SIZE);
AzureIoTClient 42:c2eaa912a28c 577
AzureIoTClient 42:c2eaa912a28c 578 if (value_type == AMQP_TYPE_STRING)
AzureIoTClient 42:c2eaa912a28c 579 {
AzureIoTClient 42:c2eaa912a28c 580 // Codes_SRS_UAMQP_MESSAGING_09_022: [The correlation-id value shall be retrieved from the AMQP_VALUE as char sequence]
AzureIoTClient 42:c2eaa912a28c 581 if (amqpvalue_get_string(uamqp_message_property, (const char**)(&string_value)) != 0)
AzureIoTClient 42:c2eaa912a28c 582 {
AzureIoTClient 42:c2eaa912a28c 583 // 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 42:c2eaa912a28c 584 LogError("Failed to get value of uAMQP message 'correlation-id' property (string)");
AzureIoTClient 42:c2eaa912a28c 585 string_value = NULL;
AzureIoTClient 42:c2eaa912a28c 586 result = __FAILURE__;
AzureIoTClient 42:c2eaa912a28c 587 }
AzureIoTClient 42:c2eaa912a28c 588 }
AzureIoTClient 42:c2eaa912a28c 589 else if (value_type == AMQP_TYPE_ULONG)
AzureIoTClient 42:c2eaa912a28c 590 {
AzureIoTClient 42:c2eaa912a28c 591 uint64_t ulong_value;
AzureIoTClient 42:c2eaa912a28c 592
AzureIoTClient 42:c2eaa912a28c 593 // Codes_SRS_UAMQP_MESSAGING_09_022: [The correlation-id value shall be retrieved from the AMQP_VALUE as char sequence]
AzureIoTClient 42:c2eaa912a28c 594 if (amqpvalue_get_ulong(uamqp_message_property, &ulong_value) != 0)
AzureIoTClient 42:c2eaa912a28c 595 {
AzureIoTClient 42:c2eaa912a28c 596 // 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 42:c2eaa912a28c 597 LogError("Failed to get value of uAMQP message 'correlation-id' property (ulong)");
AzureIoTClient 42:c2eaa912a28c 598 string_value = NULL;
AzureIoTClient 42:c2eaa912a28c 599 result = __FAILURE__;
AzureIoTClient 42:c2eaa912a28c 600 }
AzureIoTClient 42:c2eaa912a28c 601 else if (sprintf(string_buffer, "%" PRIu64, ulong_value) < 0)
AzureIoTClient 42:c2eaa912a28c 602 {
AzureIoTClient 42:c2eaa912a28c 603 LogError("Failed converting 'correlation-id' (ulong) to string");
AzureIoTClient 42:c2eaa912a28c 604 string_value = NULL;
AzureIoTClient 42:c2eaa912a28c 605 result = __FAILURE__;
AzureIoTClient 42:c2eaa912a28c 606 }
AzureIoTClient 42:c2eaa912a28c 607 else
AzureIoTClient 42:c2eaa912a28c 608 {
AzureIoTClient 42:c2eaa912a28c 609 string_value = string_buffer;
AzureIoTClient 42:c2eaa912a28c 610 }
AzureIoTClient 42:c2eaa912a28c 611 }
AzureIoTClient 42:c2eaa912a28c 612 else if (value_type == AMQP_TYPE_UUID)
AzureIoTClient 42:c2eaa912a28c 613 {
AzureIoTClient 42:c2eaa912a28c 614 uuid uuid_value;
AzureIoTClient 42:c2eaa912a28c 615
AzureIoTClient 42:c2eaa912a28c 616 // Codes_SRS_UAMQP_MESSAGING_09_022: [The correlation-id value shall be retrieved from the AMQP_VALUE as char sequence]
AzureIoTClient 42:c2eaa912a28c 617 if (amqpvalue_get_uuid(uamqp_message_property, &uuid_value) != 0)
AzureIoTClient 42:c2eaa912a28c 618 {
AzureIoTClient 42:c2eaa912a28c 619 // 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 42:c2eaa912a28c 620 LogError("Failed to get value of uAMQP message 'correlation-id' property (UUID)");
AzureIoTClient 42:c2eaa912a28c 621 string_value = NULL;
AzureIoTClient 42:c2eaa912a28c 622 result = __FAILURE__;
AzureIoTClient 42:c2eaa912a28c 623 }
AzureIoTClient 42:c2eaa912a28c 624 else if ((string_value = UUID_to_string((UUID*)uuid_value)) == NULL)
AzureIoTClient 42:c2eaa912a28c 625 {
AzureIoTClient 42:c2eaa912a28c 626 // 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 42:c2eaa912a28c 627 LogError("Failed to get the string representation of 'correlation-id' UUID");
AzureIoTClient 42:c2eaa912a28c 628 string_value = NULL;
AzureIoTClient 42:c2eaa912a28c 629 result = __FAILURE__;
AzureIoTClient 42:c2eaa912a28c 630 }
AzureIoTClient 42:c2eaa912a28c 631 else
AzureIoTClient 42:c2eaa912a28c 632 {
AzureIoTClient 42:c2eaa912a28c 633 (void)memcpy(string_buffer, string_value, sizeof(char) * strlen(string_value));
AzureIoTClient 42:c2eaa912a28c 634 free(string_value);
AzureIoTClient 42:c2eaa912a28c 635 string_value = string_buffer;
AzureIoTClient 42:c2eaa912a28c 636 }
AzureIoTClient 42:c2eaa912a28c 637 }
AzureIoTClient 42:c2eaa912a28c 638 else
AzureIoTClient 42:c2eaa912a28c 639 {
AzureIoTClient 42:c2eaa912a28c 640 LogError("Unrecognized type for correlation-id (%d)", value_type);
AzureIoTClient 42:c2eaa912a28c 641 string_value = NULL;
AzureIoTClient 42:c2eaa912a28c 642 result = __FAILURE__;
AzureIoTClient 42:c2eaa912a28c 643 }
AzureIoTClient 42:c2eaa912a28c 644
AzureIoTClient 42:c2eaa912a28c 645 if (string_value != NULL)
AzureIoTClient 42:c2eaa912a28c 646 {
AzureIoTClient 42:c2eaa912a28c 647 // 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 42:c2eaa912a28c 648 if (IoTHubMessage_SetCorrelationId(iothub_message_handle, string_value) != IOTHUB_MESSAGE_OK)
AzureIoTClient 42:c2eaa912a28c 649 {
AzureIoTClient 42:c2eaa912a28c 650 // Codes_SRS_UAMQP_MESSAGING_09_025: [If IoTHubMessage_SetCorrelationId fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.]
AzureIoTClient 42:c2eaa912a28c 651 LogError("Failed to set IOTHUB_MESSAGE_HANDLE 'correlation-id' property.");
AzureIoTClient 42:c2eaa912a28c 652 result = __FAILURE__;
AzureIoTClient 42:c2eaa912a28c 653 }
AzureIoTClient 42:c2eaa912a28c 654 }
AzureIoTClient 40:e79ee1341949 655 }
AzureIoTClient 40:e79ee1341949 656 }
AzureIoTClient 42:c2eaa912a28c 657
AzureIoTClient 41:71c01aa3df1a 658 // 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 659 properties_destroy(uamqp_message_properties);
AzureIoTClient 41:71c01aa3df1a 660 }
AzureIoTClient 40:e79ee1341949 661
AzureIoTClient 42:c2eaa912a28c 662 return result;
AzureIoTClient 23:2c6779675a01 663 }
AzureIoTClient 23:2c6779675a01 664
AzureIoTClient 23:2c6779675a01 665 static int readApplicationPropertiesFromuAMQPMessage(IOTHUB_MESSAGE_HANDLE iothub_message_handle, MESSAGE_HANDLE uamqp_message)
AzureIoTClient 23:2c6779675a01 666 {
AzureIoTClient 41:71c01aa3df1a 667 int result;
AzureIoTClient 41:71c01aa3df1a 668 AMQP_VALUE uamqp_app_properties = NULL;
AzureIoTClient 41:71c01aa3df1a 669 AMQP_VALUE uamqp_app_properties_ipdv = NULL;
AzureIoTClient 41:71c01aa3df1a 670 uint32_t property_count = 0;
AzureIoTClient 41:71c01aa3df1a 671 MAP_HANDLE iothub_message_properties_map;
AzureIoTClient 23:2c6779675a01 672
AzureIoTClient 41:71c01aa3df1a 673 // Codes_SRS_UAMQP_MESSAGING_09_027: [The IOTHUB_MESSAGE_HANDLE properties shall be retrieved using IoTHubMessage_Properties.]
AzureIoTClient 41:71c01aa3df1a 674 if ((iothub_message_properties_map = IoTHubMessage_Properties(iothub_message_handle)) == NULL)
AzureIoTClient 41:71c01aa3df1a 675 {
AzureIoTClient 41:71c01aa3df1a 676 // Codes_SRS_UAMQP_MESSAGING_09_028: [If IoTHubMessage_Properties fails, message_create_IoTHubMessage_from_uamqp_message() shall fail and return immediately.]
AzureIoTClient 41:71c01aa3df1a 677 LogError("Failed to get property map from IoTHub message.");
AzureIoTClient 41:71c01aa3df1a 678 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 679 }
AzureIoTClient 41:71c01aa3df1a 680 // Codes_SRS_UAMQP_MESSAGING_09_029: [The uAMQP message application properties shall be retrieved using message_get_application_properties.]
AzureIoTClient 41:71c01aa3df1a 681 else if ((result = message_get_application_properties(uamqp_message, &uamqp_app_properties)) != 0)
AzureIoTClient 41:71c01aa3df1a 682 {
AzureIoTClient 41:71c01aa3df1a 683 // 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 684 LogError("Failed reading the incoming uAMQP message properties (return code %d).", result);
AzureIoTClient 41:71c01aa3df1a 685 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 686 }
AzureIoTClient 41:71c01aa3df1a 687 else
AzureIoTClient 41:71c01aa3df1a 688 {
AzureIoTClient 41:71c01aa3df1a 689 // 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 690 if (uamqp_app_properties == NULL)
AzureIoTClient 41:71c01aa3df1a 691 {
AzureIoTClient 41:71c01aa3df1a 692 result = 0;
AzureIoTClient 41:71c01aa3df1a 693 }
AzureIoTClient 41:71c01aa3df1a 694 else
AzureIoTClient 41:71c01aa3df1a 695 {
AzureIoTClient 41:71c01aa3df1a 696 // 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 697 if ((uamqp_app_properties_ipdv = amqpvalue_get_inplace_described_value(uamqp_app_properties)) == NULL)
AzureIoTClient 41:71c01aa3df1a 698 {
AzureIoTClient 41:71c01aa3df1a 699 // 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 700 LogError("Failed getting the map of uAMQP message application properties (return code %d).", result);
AzureIoTClient 41:71c01aa3df1a 701 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 702 }
AzureIoTClient 41:71c01aa3df1a 703 // 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 704 else if ((result = amqpvalue_get_map_pair_count(uamqp_app_properties_ipdv, &property_count)) != 0)
AzureIoTClient 41:71c01aa3df1a 705 {
AzureIoTClient 41:71c01aa3df1a 706 // 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 707 LogError("Failed reading the number of values in the uAMQP property map (return code %d).", result);
AzureIoTClient 41:71c01aa3df1a 708 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 709 }
AzureIoTClient 41:71c01aa3df1a 710 else
AzureIoTClient 41:71c01aa3df1a 711 {
AzureIoTClient 41:71c01aa3df1a 712 // 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 713 uint32_t i;
AzureIoTClient 41:71c01aa3df1a 714 for (i = 0; result == RESULT_OK && i < property_count; i++)
AzureIoTClient 41:71c01aa3df1a 715 {
AzureIoTClient 41:71c01aa3df1a 716 AMQP_VALUE map_key_name = NULL;
AzureIoTClient 41:71c01aa3df1a 717 AMQP_VALUE map_key_value = NULL;
AzureIoTClient 41:71c01aa3df1a 718 const char *key_name;
AzureIoTClient 41:71c01aa3df1a 719 const char* key_value;
AzureIoTClient 23:2c6779675a01 720
AzureIoTClient 41:71c01aa3df1a 721 // 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 722 if ((result = amqpvalue_get_map_key_value_pair(uamqp_app_properties_ipdv, i, &map_key_name, &map_key_value)) != 0)
AzureIoTClient 41:71c01aa3df1a 723 {
AzureIoTClient 41:71c01aa3df1a 724 // 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 725 LogError("Failed reading the key/value pair from the uAMQP property map (return code %d).", result);
AzureIoTClient 41:71c01aa3df1a 726 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 727 }
AzureIoTClient 23:2c6779675a01 728
AzureIoTClient 41:71c01aa3df1a 729 // Codes_SRS_UAMQP_MESSAGING_09_039: [The uAMQP application property name shall be extracted as string using amqpvalue_get_string.]
AzureIoTClient 41:71c01aa3df1a 730 else if ((result = amqpvalue_get_string(map_key_name, &key_name)) != 0)
AzureIoTClient 41:71c01aa3df1a 731 {
AzureIoTClient 41:71c01aa3df1a 732 // 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 733 LogError("Failed parsing the uAMQP property name (return code %d).", result);
AzureIoTClient 41:71c01aa3df1a 734 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 735 }
AzureIoTClient 41:71c01aa3df1a 736 // Codes_SRS_UAMQP_MESSAGING_09_041: [The uAMQP application property value shall be extracted as string using amqpvalue_get_string.]
AzureIoTClient 41:71c01aa3df1a 737 else if ((result = amqpvalue_get_string(map_key_value, &key_value)) != 0)
AzureIoTClient 41:71c01aa3df1a 738 {
AzureIoTClient 41:71c01aa3df1a 739 // 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 740 LogError("Failed parsing the uAMQP property value (return code %d).", result);
AzureIoTClient 41:71c01aa3df1a 741 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 742 }
AzureIoTClient 41:71c01aa3df1a 743 // 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 744 else if (Map_AddOrUpdate(iothub_message_properties_map, key_name, key_value) != MAP_OK)
AzureIoTClient 41:71c01aa3df1a 745 {
AzureIoTClient 41:71c01aa3df1a 746 // Codes_SRS_UAMQP_MESSAGING_09_044: [If Map_AddOrUpdate fails, message_create_IoTHubMessage_from_uamqp_message() shall fail and return immediately.]
AzureIoTClient 41:71c01aa3df1a 747 LogError("Failed to add/update IoTHub message property map.");
AzureIoTClient 41:71c01aa3df1a 748 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 749 }
AzureIoTClient 23:2c6779675a01 750
AzureIoTClient 41:71c01aa3df1a 751 // 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 752 if (map_key_name != NULL)
AzureIoTClient 41:71c01aa3df1a 753 {
AzureIoTClient 41:71c01aa3df1a 754 amqpvalue_destroy(map_key_name);
AzureIoTClient 41:71c01aa3df1a 755 }
AzureIoTClient 23:2c6779675a01 756
AzureIoTClient 41:71c01aa3df1a 757 if (map_key_value != NULL)
AzureIoTClient 41:71c01aa3df1a 758 {
AzureIoTClient 41:71c01aa3df1a 759 amqpvalue_destroy(map_key_value);
AzureIoTClient 41:71c01aa3df1a 760 }
AzureIoTClient 41:71c01aa3df1a 761 }
AzureIoTClient 41:71c01aa3df1a 762 }
AzureIoTClient 23:2c6779675a01 763
AzureIoTClient 41:71c01aa3df1a 764 // 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 765 amqpvalue_destroy(uamqp_app_properties);
AzureIoTClient 41:71c01aa3df1a 766 }
AzureIoTClient 41:71c01aa3df1a 767 }
AzureIoTClient 23:2c6779675a01 768
AzureIoTClient 41:71c01aa3df1a 769 return result;
AzureIoTClient 23:2c6779675a01 770 }
AzureIoTClient 23:2c6779675a01 771
AzureIoTClient 41:71c01aa3df1a 772 int message_create_IoTHubMessage_from_uamqp_message(MESSAGE_HANDLE uamqp_message, IOTHUB_MESSAGE_HANDLE* iothubclient_message)
AzureIoTClient 23:2c6779675a01 773 {
AzureIoTClient 41:71c01aa3df1a 774 int result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 775
AzureIoTClient 41:71c01aa3df1a 776 IOTHUB_MESSAGE_HANDLE iothub_message = NULL;
AzureIoTClient 41:71c01aa3df1a 777 MESSAGE_BODY_TYPE body_type;
AzureIoTClient 23:2c6779675a01 778
AzureIoTClient 41:71c01aa3df1a 779 // Codes_SRS_UAMQP_MESSAGING_09_001: [The body type of the uAMQP message shall be retrieved using message_get_body_type().]
AzureIoTClient 41:71c01aa3df1a 780 if (message_get_body_type(uamqp_message, &body_type) != 0)
AzureIoTClient 41:71c01aa3df1a 781 {
AzureIoTClient 41:71c01aa3df1a 782 // 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 783 LogError("Failed to get the type of the uamqp message.");
AzureIoTClient 41:71c01aa3df1a 784 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 785 }
AzureIoTClient 41:71c01aa3df1a 786 else
AzureIoTClient 41:71c01aa3df1a 787 {
AzureIoTClient 41:71c01aa3df1a 788 // 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 789 if (body_type == MESSAGE_BODY_TYPE_DATA)
AzureIoTClient 41:71c01aa3df1a 790 {
AzureIoTClient 41:71c01aa3df1a 791 // Codes_SRS_UAMQP_MESSAGING_09_004: [The uAMQP message body data shall be retrieved using message_get_body_amqp_data().]
AzureIoTClient 41:71c01aa3df1a 792 BINARY_DATA binary_data;
AzureIoTClient 41:71c01aa3df1a 793 if (message_get_body_amqp_data_in_place(uamqp_message, 0, &binary_data) != 0)
AzureIoTClient 41:71c01aa3df1a 794 {
AzureIoTClient 41:71c01aa3df1a 795 // 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 796 LogError("Failed to get the body of the uamqp message.");
AzureIoTClient 41:71c01aa3df1a 797 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 798 }
AzureIoTClient 41:71c01aa3df1a 799 // 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 800 else if ((iothub_message = IoTHubMessage_CreateFromByteArray(binary_data.bytes, binary_data.length)) == NULL)
AzureIoTClient 41:71c01aa3df1a 801 {
AzureIoTClient 41:71c01aa3df1a 802 // Codes_SRS_UAMQP_MESSAGING_09_007: [If IoTHubMessage_CreateFromByteArray() fails, message_create_IoTHubMessage_from_uamqp_message shall fail and return immediately.]
AzureIoTClient 41:71c01aa3df1a 803 LogError("Failed creating the IOTHUB_MESSAGE_HANDLE instance (IoTHubMessage_CreateFromByteArray failed).");
AzureIoTClient 41:71c01aa3df1a 804 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 805 }
AzureIoTClient 41:71c01aa3df1a 806 }
AzureIoTClient 41:71c01aa3df1a 807 }
AzureIoTClient 23:2c6779675a01 808
AzureIoTClient 41:71c01aa3df1a 809 if (iothub_message != NULL)
AzureIoTClient 41:71c01aa3df1a 810 {
AzureIoTClient 41:71c01aa3df1a 811 if (readPropertiesFromuAMQPMessage(iothub_message, uamqp_message) != RESULT_OK)
AzureIoTClient 41:71c01aa3df1a 812 {
AzureIoTClient 41:71c01aa3df1a 813 LogError("Failed reading properties of the uamqp message.");
AzureIoTClient 41:71c01aa3df1a 814 IoTHubMessage_Destroy(iothub_message);
AzureIoTClient 41:71c01aa3df1a 815 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 816 }
AzureIoTClient 41:71c01aa3df1a 817 else if (readApplicationPropertiesFromuAMQPMessage(iothub_message, uamqp_message) != RESULT_OK)
AzureIoTClient 41:71c01aa3df1a 818 {
AzureIoTClient 41:71c01aa3df1a 819 LogError("Failed reading application properties of the uamqp message.");
AzureIoTClient 41:71c01aa3df1a 820 IoTHubMessage_Destroy(iothub_message);
AzureIoTClient 41:71c01aa3df1a 821 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 822 }
AzureIoTClient 41:71c01aa3df1a 823 else
AzureIoTClient 41:71c01aa3df1a 824 {
AzureIoTClient 41:71c01aa3df1a 825 *iothubclient_message = iothub_message;
AzureIoTClient 41:71c01aa3df1a 826 result = RESULT_OK;
AzureIoTClient 41:71c01aa3df1a 827 }
AzureIoTClient 41:71c01aa3df1a 828 }
AzureIoTClient 23:2c6779675a01 829
AzureIoTClient 41:71c01aa3df1a 830 return result;
AzureIoTClient 23:2c6779675a01 831 }
AzureIoTClient 23:2c6779675a01 832