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@57:56ac1346c70d, 2018-10-04 (annotated)

Committer:
AzureIoTClient
Date:
Thu Oct 04 09:14:47 2018 -0700
Revision:
57:56ac1346c70d
Parent:
56:8704100b3b54 
1.2.10

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