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@41:71c01aa3df1a, 2017-09-11 (annotated)

Committer:
AzureIoTClient
Date:
Mon Sep 11 09:22:16 2017 -0700
Revision:
41:71c01aa3df1a
Parent:
40:e79ee1341949
Child:
42:c2eaa912a28c
1.1.23

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 23:2c6779675a01 3 #include <stdlib.h>
AzureIoTClient 23:2c6779675a01 4 #include "uamqp_messaging.h"
AzureIoTClient 29:7e8852b14e3b 5 #include "azure_c_shared_utility/optimize_size.h"
AzureIoTClient 23:2c6779675a01 6 #include "azure_c_shared_utility/xlogging.h"
AzureIoTClient 23:2c6779675a01 7 #include "azure_uamqp_c/message.h"
AzureIoTClient 23:2c6779675a01 8 #include "azure_uamqp_c/amqpvalue.h"
AzureIoTClient 23:2c6779675a01 9 #include "iothub_message.h"
AzureIoTClient 23:2c6779675a01 10 #ifndef RESULT_OK
AzureIoTClient 23:2c6779675a01 11 #define RESULT_OK 0
AzureIoTClient 23:2c6779675a01 12 #endif
AzureIoTClient 23:2c6779675a01 13
AzureIoTClient 41:71c01aa3df1a 14 static int encode_callback(void* context, const unsigned char* bytes, size_t length)
AzureIoTClient 23:2c6779675a01 15 {
AzureIoTClient 41:71c01aa3df1a 16 BINARY_DATA* message_body_binary = (BINARY_DATA*)context;
AzureIoTClient 41:71c01aa3df1a 17 (void)memcpy((unsigned char*)message_body_binary->bytes + message_body_binary->length, bytes, length);
AzureIoTClient 41:71c01aa3df1a 18 message_body_binary->length += length;
AzureIoTClient 41:71c01aa3df1a 19 return 0;
AzureIoTClient 41:71c01aa3df1a 20 }
AzureIoTClient 40:e79ee1341949 21
AzureIoTClient 41:71c01aa3df1a 22 // Codes_SRS_UAMQP_MESSAGING_31_112: [If optional message-id is present in the message, encode it into the AMQP message.]
AzureIoTClient 41:71c01aa3df1a 23 static int set_message_id_if_needed(IOTHUB_MESSAGE_HANDLE messageHandle, PROPERTIES_HANDLE uamqp_message_properties)
AzureIoTClient 41:71c01aa3df1a 24 {
AzureIoTClient 41:71c01aa3df1a 25 int result;
AzureIoTClient 41:71c01aa3df1a 26 const char* messageId;
AzureIoTClient 23:2c6779675a01 27
AzureIoTClient 41:71c01aa3df1a 28 if (NULL != (messageId = IoTHubMessage_GetMessageId(messageHandle)))
AzureIoTClient 41:71c01aa3df1a 29 {
AzureIoTClient 41:71c01aa3df1a 30 AMQP_VALUE uamqp_message_id;
AzureIoTClient 23:2c6779675a01 31
AzureIoTClient 41:71c01aa3df1a 32 if ((uamqp_message_id = amqpvalue_create_string(messageId)) == NULL)
AzureIoTClient 41:71c01aa3df1a 33 {
AzureIoTClient 41:71c01aa3df1a 34 LogError("Failed amqpvalue_create_string for message_id");
AzureIoTClient 41:71c01aa3df1a 35 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 36 }
AzureIoTClient 41:71c01aa3df1a 37 else if (properties_set_message_id(uamqp_message_properties, uamqp_message_id) != 0)
AzureIoTClient 40:e79ee1341949 38 {
AzureIoTClient 41:71c01aa3df1a 39 LogError("Failed properties_set_message_id");
AzureIoTClient 41:71c01aa3df1a 40 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 41 }
AzureIoTClient 41:71c01aa3df1a 42 else
AzureIoTClient 41:71c01aa3df1a 43 {
AzureIoTClient 41:71c01aa3df1a 44 result = RESULT_OK;
AzureIoTClient 40:e79ee1341949 45 }
AzureIoTClient 40:e79ee1341949 46
AzureIoTClient 41:71c01aa3df1a 47 if (NULL != uamqp_message_id)
AzureIoTClient 40:e79ee1341949 48 {
AzureIoTClient 41:71c01aa3df1a 49 amqpvalue_destroy(uamqp_message_id);
AzureIoTClient 41:71c01aa3df1a 50 }
AzureIoTClient 41:71c01aa3df1a 51 }
AzureIoTClient 41:71c01aa3df1a 52 else
AzureIoTClient 41:71c01aa3df1a 53 {
AzureIoTClient 41:71c01aa3df1a 54 result = RESULT_OK;
AzureIoTClient 41:71c01aa3df1a 55 }
AzureIoTClient 41:71c01aa3df1a 56
AzureIoTClient 41:71c01aa3df1a 57 return result;
AzureIoTClient 41:71c01aa3df1a 58 }
AzureIoTClient 41:71c01aa3df1a 59
AzureIoTClient 41:71c01aa3df1a 60 // Codes_SRS_UAMQP_MESSAGING_31_113: [If optional correlation-id is present in the message, encode it into the AMQP message.]
AzureIoTClient 41:71c01aa3df1a 61 static int set_message_correlation_id_if_needed(IOTHUB_MESSAGE_HANDLE messageHandle, PROPERTIES_HANDLE uamqp_message_properties)
AzureIoTClient 41:71c01aa3df1a 62 {
AzureIoTClient 41:71c01aa3df1a 63 int result;
AzureIoTClient 41:71c01aa3df1a 64 const char* correlationId;
AzureIoTClient 41:71c01aa3df1a 65
AzureIoTClient 41:71c01aa3df1a 66 if (NULL != (correlationId = IoTHubMessage_GetCorrelationId(messageHandle)))
AzureIoTClient 41:71c01aa3df1a 67 {
AzureIoTClient 41:71c01aa3df1a 68 AMQP_VALUE uamqp_correlation_id;
AzureIoTClient 41:71c01aa3df1a 69
AzureIoTClient 41:71c01aa3df1a 70 if ((uamqp_correlation_id = amqpvalue_create_string(correlationId)) == NULL)
AzureIoTClient 41:71c01aa3df1a 71 {
AzureIoTClient 41:71c01aa3df1a 72 LogError("Failed amqpvalue_create_string for message_id");
AzureIoTClient 41:71c01aa3df1a 73 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 74 }
AzureIoTClient 41:71c01aa3df1a 75 else if (properties_set_correlation_id(uamqp_message_properties, uamqp_correlation_id) != 0)
AzureIoTClient 41:71c01aa3df1a 76 {
AzureIoTClient 41:71c01aa3df1a 77 LogError("Failed properties_set_correlation_id");
AzureIoTClient 41:71c01aa3df1a 78 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 79 }
AzureIoTClient 41:71c01aa3df1a 80 else
AzureIoTClient 41:71c01aa3df1a 81 {
AzureIoTClient 41:71c01aa3df1a 82 result = RESULT_OK;
AzureIoTClient 40:e79ee1341949 83 }
AzureIoTClient 40:e79ee1341949 84
AzureIoTClient 41:71c01aa3df1a 85 if (uamqp_correlation_id != NULL)
AzureIoTClient 41:71c01aa3df1a 86 {
AzureIoTClient 41:71c01aa3df1a 87 amqpvalue_destroy(uamqp_correlation_id);
AzureIoTClient 41:71c01aa3df1a 88 }
AzureIoTClient 41:71c01aa3df1a 89 }
AzureIoTClient 41:71c01aa3df1a 90 else
AzureIoTClient 41:71c01aa3df1a 91 {
AzureIoTClient 41:71c01aa3df1a 92 result = RESULT_OK;
AzureIoTClient 41:71c01aa3df1a 93 }
AzureIoTClient 41:71c01aa3df1a 94
AzureIoTClient 41:71c01aa3df1a 95 return result;
AzureIoTClient 41:71c01aa3df1a 96 }
AzureIoTClient 41:71c01aa3df1a 97
AzureIoTClient 41:71c01aa3df1a 98 // Codes_SRS_UAMQP_MESSAGING_31_114: [If optional content-type is present in the message, encode it into the AMQP message.]
AzureIoTClient 41:71c01aa3df1a 99 static int set_message_content_type_if_needed(IOTHUB_MESSAGE_HANDLE messageHandle, PROPERTIES_HANDLE uamqp_message_properties)
AzureIoTClient 41:71c01aa3df1a 100 {
AzureIoTClient 41:71c01aa3df1a 101 int result;
AzureIoTClient 41:71c01aa3df1a 102 const char* content_type;
AzureIoTClient 41:71c01aa3df1a 103
AzureIoTClient 41:71c01aa3df1a 104 if ((content_type = IoTHubMessage_GetContentTypeSystemProperty(messageHandle)) != NULL)
AzureIoTClient 41:71c01aa3df1a 105 {
AzureIoTClient 41:71c01aa3df1a 106 if (properties_set_content_type(uamqp_message_properties, content_type) != 0)
AzureIoTClient 41:71c01aa3df1a 107 {
AzureIoTClient 41:71c01aa3df1a 108 LogError("Failed properties_set_content_type");
AzureIoTClient 41:71c01aa3df1a 109 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 110 }
AzureIoTClient 41:71c01aa3df1a 111 else
AzureIoTClient 41:71c01aa3df1a 112 {
AzureIoTClient 41:71c01aa3df1a 113 result = RESULT_OK;
AzureIoTClient 41:71c01aa3df1a 114 }
AzureIoTClient 41:71c01aa3df1a 115 }
AzureIoTClient 41:71c01aa3df1a 116 else
AzureIoTClient 41:71c01aa3df1a 117 {
AzureIoTClient 41:71c01aa3df1a 118 result = RESULT_OK;
AzureIoTClient 41:71c01aa3df1a 119 }
AzureIoTClient 41:71c01aa3df1a 120
AzureIoTClient 41:71c01aa3df1a 121 return result;
AzureIoTClient 41:71c01aa3df1a 122 }
AzureIoTClient 41:71c01aa3df1a 123
AzureIoTClient 41:71c01aa3df1a 124 // Codes_SRS_UAMQP_MESSAGING_31_115: [If optional content-encoding is present in the message, encode it into the AMQP message.]
AzureIoTClient 41:71c01aa3df1a 125 static int set_message_content_encoding_if_needed(IOTHUB_MESSAGE_HANDLE messageHandle, PROPERTIES_HANDLE uamqp_message_properties)
AzureIoTClient 41:71c01aa3df1a 126 {
AzureIoTClient 41:71c01aa3df1a 127 int result;
AzureIoTClient 41:71c01aa3df1a 128 const char* content_encoding;
AzureIoTClient 23:2c6779675a01 129
AzureIoTClient 41:71c01aa3df1a 130 if ((content_encoding = IoTHubMessage_GetContentEncodingSystemProperty(messageHandle)) != NULL)
AzureIoTClient 41:71c01aa3df1a 131 {
AzureIoTClient 41:71c01aa3df1a 132 if (properties_set_content_encoding(uamqp_message_properties, content_encoding) != 0)
AzureIoTClient 41:71c01aa3df1a 133 {
AzureIoTClient 41:71c01aa3df1a 134 LogError("Failed properties_set_content_encoding");
AzureIoTClient 41:71c01aa3df1a 135 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 136 }
AzureIoTClient 41:71c01aa3df1a 137 else
AzureIoTClient 41:71c01aa3df1a 138 {
AzureIoTClient 41:71c01aa3df1a 139 result = RESULT_OK;
AzureIoTClient 41:71c01aa3df1a 140 }
AzureIoTClient 41:71c01aa3df1a 141 }
AzureIoTClient 41:71c01aa3df1a 142 else
AzureIoTClient 41:71c01aa3df1a 143 {
AzureIoTClient 41:71c01aa3df1a 144 result = RESULT_OK;
AzureIoTClient 41:71c01aa3df1a 145 }
AzureIoTClient 41:71c01aa3df1a 146
AzureIoTClient 41:71c01aa3df1a 147 return result;
AzureIoTClient 41:71c01aa3df1a 148 }
AzureIoTClient 41:71c01aa3df1a 149
AzureIoTClient 41:71c01aa3df1a 150
AzureIoTClient 41:71c01aa3df1a 151 // 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 152 static int create_message_properties_to_encode(IOTHUB_MESSAGE_HANDLE messageHandle, AMQP_VALUE *message_properties, size_t *message_properties_length)
AzureIoTClient 41:71c01aa3df1a 153 {
AzureIoTClient 41:71c01aa3df1a 154 PROPERTIES_HANDLE uamqp_message_properties = NULL;
AzureIoTClient 41:71c01aa3df1a 155 int result;
AzureIoTClient 23:2c6779675a01 156
AzureIoTClient 41:71c01aa3df1a 157 if ((uamqp_message_properties = properties_create()) == NULL)
AzureIoTClient 41:71c01aa3df1a 158 {
AzureIoTClient 41:71c01aa3df1a 159 LogError("Failed on properties_create()");
AzureIoTClient 41:71c01aa3df1a 160 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 161 }
AzureIoTClient 41:71c01aa3df1a 162 else if (set_message_id_if_needed(messageHandle, uamqp_message_properties) != RESULT_OK)
AzureIoTClient 41:71c01aa3df1a 163 {
AzureIoTClient 41:71c01aa3df1a 164 LogError("Failed on set_message_id_if_needed()");
AzureIoTClient 41:71c01aa3df1a 165 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 166 }
AzureIoTClient 41:71c01aa3df1a 167 else if (set_message_correlation_id_if_needed(messageHandle, uamqp_message_properties) != RESULT_OK)
AzureIoTClient 41:71c01aa3df1a 168 {
AzureIoTClient 41:71c01aa3df1a 169 LogError("Failed on set_message_correlation_id_if_needed()");
AzureIoTClient 41:71c01aa3df1a 170 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 171 }
AzureIoTClient 41:71c01aa3df1a 172 else if (set_message_content_type_if_needed(messageHandle, uamqp_message_properties) != RESULT_OK)
AzureIoTClient 41:71c01aa3df1a 173 {
AzureIoTClient 41:71c01aa3df1a 174 LogError("Failed on set_message_content_type_if_needed()");
AzureIoTClient 41:71c01aa3df1a 175 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 176 }
AzureIoTClient 41:71c01aa3df1a 177 else if (set_message_content_encoding_if_needed(messageHandle, uamqp_message_properties) != RESULT_OK)
AzureIoTClient 41:71c01aa3df1a 178 {
AzureIoTClient 41:71c01aa3df1a 179 LogError("Failed on set_message_content_encoding_if_needed()");
AzureIoTClient 41:71c01aa3df1a 180 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 181 }
AzureIoTClient 41:71c01aa3df1a 182 else if ((*message_properties = amqpvalue_create_properties(uamqp_message_properties)) == NULL)
AzureIoTClient 41:71c01aa3df1a 183 {
AzureIoTClient 41:71c01aa3df1a 184 LogError("Failed on amqpvalue_create_properties()");
AzureIoTClient 41:71c01aa3df1a 185 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 186 }
AzureIoTClient 41:71c01aa3df1a 187 else if ((amqpvalue_get_encoded_size(*message_properties, message_properties_length)) != 0)
AzureIoTClient 41:71c01aa3df1a 188 {
AzureIoTClient 41:71c01aa3df1a 189 LogError("Failed on amqpvalue_get_encoded_size()");
AzureIoTClient 41:71c01aa3df1a 190 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 191 }
AzureIoTClient 41:71c01aa3df1a 192 else
AzureIoTClient 41:71c01aa3df1a 193 {
AzureIoTClient 41:71c01aa3df1a 194 result = RESULT_OK;
AzureIoTClient 41:71c01aa3df1a 195 }
AzureIoTClient 41:71c01aa3df1a 196
AzureIoTClient 41:71c01aa3df1a 197 if (NULL != uamqp_message_properties)
AzureIoTClient 41:71c01aa3df1a 198 {
AzureIoTClient 41:71c01aa3df1a 199 properties_destroy(uamqp_message_properties);
AzureIoTClient 41:71c01aa3df1a 200 }
AzureIoTClient 41:71c01aa3df1a 201
AzureIoTClient 41:71c01aa3df1a 202 return result;
AzureIoTClient 23:2c6779675a01 203 }
AzureIoTClient 23:2c6779675a01 204
AzureIoTClient 41:71c01aa3df1a 205 // 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 206 static int create_application_properties_to_encode(IOTHUB_MESSAGE_HANDLE messageHandle, AMQP_VALUE *application_properties, size_t *application_properties_length)
AzureIoTClient 23:2c6779675a01 207 {
AzureIoTClient 41:71c01aa3df1a 208 MAP_HANDLE properties_map;
AzureIoTClient 41:71c01aa3df1a 209 const char* const* property_keys;
AzureIoTClient 41:71c01aa3df1a 210 const char* const* property_values;
AzureIoTClient 41:71c01aa3df1a 211 size_t property_count = 0;
AzureIoTClient 41:71c01aa3df1a 212 AMQP_VALUE uamqp_properties_map = NULL;
AzureIoTClient 41:71c01aa3df1a 213 int result;
AzureIoTClient 41:71c01aa3df1a 214
AzureIoTClient 41:71c01aa3df1a 215 if ((properties_map = IoTHubMessage_Properties(messageHandle)) == NULL)
AzureIoTClient 41:71c01aa3df1a 216 {
AzureIoTClient 41:71c01aa3df1a 217 LogError("Failed to get property map from IoTHub message.");
AzureIoTClient 41:71c01aa3df1a 218 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 219 }
AzureIoTClient 41:71c01aa3df1a 220 else if (Map_GetInternals(properties_map, &property_keys, &property_values, &property_count) != 0)
AzureIoTClient 41:71c01aa3df1a 221 {
AzureIoTClient 41:71c01aa3df1a 222 LogError("Failed reading the incoming uAMQP message properties");
AzureIoTClient 41:71c01aa3df1a 223 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 224 }
AzureIoTClient 41:71c01aa3df1a 225 else if (property_count > 0)
AzureIoTClient 41:71c01aa3df1a 226 {
AzureIoTClient 41:71c01aa3df1a 227 size_t i;
AzureIoTClient 41:71c01aa3df1a 228 if ((uamqp_properties_map = amqpvalue_create_map()) == NULL)
AzureIoTClient 41:71c01aa3df1a 229 {
AzureIoTClient 41:71c01aa3df1a 230 LogError("amqpvalue_create_map failed");
AzureIoTClient 41:71c01aa3df1a 231 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 232 }
AzureIoTClient 41:71c01aa3df1a 233 else
AzureIoTClient 41:71c01aa3df1a 234 {
AzureIoTClient 41:71c01aa3df1a 235 result = RESULT_OK;
AzureIoTClient 41:71c01aa3df1a 236
AzureIoTClient 41:71c01aa3df1a 237 for (i = 0; i < property_count; i++)
AzureIoTClient 41:71c01aa3df1a 238 {
AzureIoTClient 41:71c01aa3df1a 239 AMQP_VALUE map_property_key;
AzureIoTClient 41:71c01aa3df1a 240 AMQP_VALUE map_property_value;
AzureIoTClient 41:71c01aa3df1a 241
AzureIoTClient 41:71c01aa3df1a 242 if ((map_property_key = amqpvalue_create_string(property_keys[i])) == NULL)
AzureIoTClient 41:71c01aa3df1a 243 {
AzureIoTClient 41:71c01aa3df1a 244 LogError("Failed amqpvalue_create_string for key");
AzureIoTClient 41:71c01aa3df1a 245 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 246 break;
AzureIoTClient 41:71c01aa3df1a 247 }
AzureIoTClient 23:2c6779675a01 248
AzureIoTClient 41:71c01aa3df1a 249 if ((map_property_value = amqpvalue_create_string(property_values[i])) == NULL)
AzureIoTClient 41:71c01aa3df1a 250 {
AzureIoTClient 41:71c01aa3df1a 251 LogError("Failed amqpvalue_create_string for value");
AzureIoTClient 41:71c01aa3df1a 252 amqpvalue_destroy(map_property_key);
AzureIoTClient 41:71c01aa3df1a 253 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 254 break;
AzureIoTClient 41:71c01aa3df1a 255 }
AzureIoTClient 41:71c01aa3df1a 256
AzureIoTClient 41:71c01aa3df1a 257 if (amqpvalue_set_map_value(uamqp_properties_map, map_property_key, map_property_value) != 0)
AzureIoTClient 41:71c01aa3df1a 258 {
AzureIoTClient 41:71c01aa3df1a 259 LogError("Failed amqpvalue_set_map_value");
AzureIoTClient 41:71c01aa3df1a 260 amqpvalue_destroy(map_property_key);
AzureIoTClient 41:71c01aa3df1a 261 amqpvalue_destroy(map_property_value);
AzureIoTClient 41:71c01aa3df1a 262 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 263 break;
AzureIoTClient 41:71c01aa3df1a 264 }
AzureIoTClient 41:71c01aa3df1a 265
AzureIoTClient 41:71c01aa3df1a 266 amqpvalue_destroy(map_property_key);
AzureIoTClient 41:71c01aa3df1a 267 amqpvalue_destroy(map_property_value);
AzureIoTClient 41:71c01aa3df1a 268 }
AzureIoTClient 23:2c6779675a01 269
AzureIoTClient 41:71c01aa3df1a 270 if (RESULT_OK == result)
AzureIoTClient 41:71c01aa3df1a 271 {
AzureIoTClient 41:71c01aa3df1a 272 if ((*application_properties = amqpvalue_create_application_properties(uamqp_properties_map)) == NULL)
AzureIoTClient 41:71c01aa3df1a 273 {
AzureIoTClient 41:71c01aa3df1a 274 LogError("Failed amqpvalue_create_application_properties");
AzureIoTClient 41:71c01aa3df1a 275 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 276 }
AzureIoTClient 41:71c01aa3df1a 277 else if (amqpvalue_get_encoded_size(*application_properties, application_properties_length) != 0)
AzureIoTClient 41:71c01aa3df1a 278 {
AzureIoTClient 41:71c01aa3df1a 279 LogError("Failed amqpvalue_get_encoded_size");
AzureIoTClient 41:71c01aa3df1a 280 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 281 }
AzureIoTClient 41:71c01aa3df1a 282 }
AzureIoTClient 41:71c01aa3df1a 283 }
AzureIoTClient 41:71c01aa3df1a 284 }
AzureIoTClient 41:71c01aa3df1a 285 else
AzureIoTClient 41:71c01aa3df1a 286 {
AzureIoTClient 41:71c01aa3df1a 287 result = RESULT_OK;
AzureIoTClient 41:71c01aa3df1a 288 }
AzureIoTClient 41:71c01aa3df1a 289
AzureIoTClient 41:71c01aa3df1a 290 if (NULL != uamqp_properties_map)
AzureIoTClient 41:71c01aa3df1a 291 {
AzureIoTClient 41:71c01aa3df1a 292 amqpvalue_destroy(uamqp_properties_map);
AzureIoTClient 41:71c01aa3df1a 293 }
AzureIoTClient 41:71c01aa3df1a 294
AzureIoTClient 41:71c01aa3df1a 295 return result;
AzureIoTClient 41:71c01aa3df1a 296 }
AzureIoTClient 41:71c01aa3df1a 297
AzureIoTClient 41:71c01aa3df1a 298
AzureIoTClient 41:71c01aa3df1a 299 // 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 300 static int create_data_to_encode(IOTHUB_MESSAGE_HANDLE messageHandle, AMQP_VALUE *data_value, size_t *data_length)
AzureIoTClient 41:71c01aa3df1a 301 {
AzureIoTClient 41:71c01aa3df1a 302 int result;
AzureIoTClient 41:71c01aa3df1a 303
AzureIoTClient 41:71c01aa3df1a 304 IOTHUBMESSAGE_CONTENT_TYPE contentType = IoTHubMessage_GetContentType(messageHandle);
AzureIoTClient 41:71c01aa3df1a 305 const char* messageContent = NULL;
AzureIoTClient 41:71c01aa3df1a 306 size_t messageContentSize = 0;
AzureIoTClient 23:2c6779675a01 307
AzureIoTClient 41:71c01aa3df1a 308 if ((contentType == IOTHUBMESSAGE_BYTEARRAY) &&
AzureIoTClient 41:71c01aa3df1a 309 IoTHubMessage_GetByteArray(messageHandle, (const unsigned char **)&messageContent, &messageContentSize) != IOTHUB_MESSAGE_OK)
AzureIoTClient 41:71c01aa3df1a 310 {
AzureIoTClient 41:71c01aa3df1a 311 LogError("Failed getting the BYTE array representation of the IOTHUB_MESSAGE_HANDLE instance.");
AzureIoTClient 41:71c01aa3df1a 312 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 313 }
AzureIoTClient 41:71c01aa3df1a 314 else if ((contentType == IOTHUBMESSAGE_STRING) &&
AzureIoTClient 41:71c01aa3df1a 315 ((messageContent = IoTHubMessage_GetString(messageHandle)) == NULL))
AzureIoTClient 41:71c01aa3df1a 316 {
AzureIoTClient 41:71c01aa3df1a 317 LogError("Failed getting the STRING representation of the IOTHUB_MESSAGE_HANDLE instance.");
AzureIoTClient 41:71c01aa3df1a 318 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 319 }
AzureIoTClient 41:71c01aa3df1a 320 else if (contentType == IOTHUBMESSAGE_UNKNOWN)
AzureIoTClient 41:71c01aa3df1a 321 {
AzureIoTClient 41:71c01aa3df1a 322 LogError("Cannot parse IOTHUB_MESSAGE_HANDLE with content type IOTHUBMESSAGE_UNKNOWN.");
AzureIoTClient 41:71c01aa3df1a 323 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 324 }
AzureIoTClient 41:71c01aa3df1a 325 else
AzureIoTClient 41:71c01aa3df1a 326 {
AzureIoTClient 41:71c01aa3df1a 327 if (contentType == IOTHUBMESSAGE_STRING)
AzureIoTClient 41:71c01aa3df1a 328 {
AzureIoTClient 41:71c01aa3df1a 329 messageContentSize = strlen(messageContent);
AzureIoTClient 41:71c01aa3df1a 330 }
AzureIoTClient 41:71c01aa3df1a 331
AzureIoTClient 41:71c01aa3df1a 332 data bin_data;
AzureIoTClient 41:71c01aa3df1a 333 bin_data.bytes = (const unsigned char *)messageContent;
AzureIoTClient 41:71c01aa3df1a 334 bin_data.length = (uint32_t)messageContentSize;
AzureIoTClient 23:2c6779675a01 335
AzureIoTClient 41:71c01aa3df1a 336 if ((*data_value = amqpvalue_create_data(bin_data)) == NULL)
AzureIoTClient 41:71c01aa3df1a 337 {
AzureIoTClient 41:71c01aa3df1a 338 LogError("amqpvalue_create_data failed");
AzureIoTClient 41:71c01aa3df1a 339 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 340 }
AzureIoTClient 41:71c01aa3df1a 341 else if (amqpvalue_get_encoded_size(*data_value, data_length) != 0)
AzureIoTClient 41:71c01aa3df1a 342 {
AzureIoTClient 41:71c01aa3df1a 343 LogError("amqpvalue_get_encoded_size failed");
AzureIoTClient 41:71c01aa3df1a 344 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 345 }
AzureIoTClient 41:71c01aa3df1a 346 else
AzureIoTClient 41:71c01aa3df1a 347 {
AzureIoTClient 41:71c01aa3df1a 348 result = RESULT_OK;
AzureIoTClient 41:71c01aa3df1a 349 }
AzureIoTClient 41:71c01aa3df1a 350 }
AzureIoTClient 41:71c01aa3df1a 351
AzureIoTClient 41:71c01aa3df1a 352 return result;
AzureIoTClient 41:71c01aa3df1a 353 }
AzureIoTClient 41:71c01aa3df1a 354
AzureIoTClient 41:71c01aa3df1a 355 // Codes_SRS_UAMQP_MESSAGING_31_120: [Create a blob that contains AMQP encoding of IOTHUB_MESSAGE_HANDLE.]
AzureIoTClient 41:71c01aa3df1a 356 // Codes_SRS_UAMQP_MESSAGING_31_121: [Any errors during `message_create_uamqp_encoding_from_iothub_message` stop processing on this message.]
AzureIoTClient 41:71c01aa3df1a 357 int message_create_uamqp_encoding_from_iothub_message(IOTHUB_MESSAGE_HANDLE message_handle, BINARY_DATA* body_binary_data)
AzureIoTClient 41:71c01aa3df1a 358 {
AzureIoTClient 41:71c01aa3df1a 359 int result;
AzureIoTClient 41:71c01aa3df1a 360
AzureIoTClient 41:71c01aa3df1a 361 AMQP_VALUE message_properties = NULL;
AzureIoTClient 41:71c01aa3df1a 362 AMQP_VALUE application_properties = NULL;
AzureIoTClient 41:71c01aa3df1a 363 AMQP_VALUE data_value = NULL;
AzureIoTClient 41:71c01aa3df1a 364 size_t message_properties_length = 0;
AzureIoTClient 41:71c01aa3df1a 365 size_t application_properties_length = 0;
AzureIoTClient 41:71c01aa3df1a 366 size_t data_length = 0;
AzureIoTClient 23:2c6779675a01 367
AzureIoTClient 41:71c01aa3df1a 368 body_binary_data->bytes = NULL;
AzureIoTClient 41:71c01aa3df1a 369 body_binary_data->length = 0;
AzureIoTClient 23:2c6779675a01 370
AzureIoTClient 41:71c01aa3df1a 371 if (create_message_properties_to_encode(message_handle, &message_properties, &message_properties_length) != RESULT_OK)
AzureIoTClient 41:71c01aa3df1a 372 {
AzureIoTClient 41:71c01aa3df1a 373 LogError("create_message_properties_to_encode() failed");
AzureIoTClient 41:71c01aa3df1a 374 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 375 }
AzureIoTClient 41:71c01aa3df1a 376 else if (create_application_properties_to_encode(message_handle, &application_properties, &application_properties_length) != RESULT_OK)
AzureIoTClient 41:71c01aa3df1a 377 {
AzureIoTClient 41:71c01aa3df1a 378 LogError("create_application_properties_to_encode() failed");
AzureIoTClient 41:71c01aa3df1a 379 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 380 }
AzureIoTClient 41:71c01aa3df1a 381 else if (create_data_to_encode(message_handle, &data_value, &data_length) != RESULT_OK)
AzureIoTClient 41:71c01aa3df1a 382 {
AzureIoTClient 41:71c01aa3df1a 383 LogError("create_data_to_encode() failed");
AzureIoTClient 41:71c01aa3df1a 384 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 385 }
AzureIoTClient 41:71c01aa3df1a 386 else if ((body_binary_data->bytes = malloc(message_properties_length + application_properties_length + data_length)) == NULL)
AzureIoTClient 41:71c01aa3df1a 387 {
AzureIoTClient 41:71c01aa3df1a 388 LogError("malloc of %d bytes failed", message_properties_length + application_properties_length + data_length);
AzureIoTClient 41:71c01aa3df1a 389 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 390 }
AzureIoTClient 41:71c01aa3df1a 391 // Codes_SRS_UAMQP_MESSAGING_31_119: [Invoke underlying AMQP encode routines on data waiting to be encoded.]
AzureIoTClient 41:71c01aa3df1a 392 else if (amqpvalue_encode(message_properties, &encode_callback, body_binary_data) != RESULT_OK)
AzureIoTClient 41:71c01aa3df1a 393 {
AzureIoTClient 41:71c01aa3df1a 394 LogError("amqpvalue_encode() for message properties failed");
AzureIoTClient 41:71c01aa3df1a 395 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 396 }
AzureIoTClient 41:71c01aa3df1a 397 else if ((application_properties_length > 0) && (amqpvalue_encode(application_properties, &encode_callback, body_binary_data) != RESULT_OK))
AzureIoTClient 41:71c01aa3df1a 398 {
AzureIoTClient 41:71c01aa3df1a 399 LogError("amqpvalue_encode() for application properties failed");
AzureIoTClient 41:71c01aa3df1a 400 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 401 }
AzureIoTClient 41:71c01aa3df1a 402 else if (RESULT_OK != amqpvalue_encode(data_value, &encode_callback, body_binary_data))
AzureIoTClient 41:71c01aa3df1a 403 {
AzureIoTClient 41:71c01aa3df1a 404 LogError("amqpvalue_encode() for data value failed");
AzureIoTClient 41:71c01aa3df1a 405 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 406 }
AzureIoTClient 41:71c01aa3df1a 407 else
AzureIoTClient 41:71c01aa3df1a 408 {
AzureIoTClient 41:71c01aa3df1a 409 body_binary_data->length = message_properties_length + application_properties_length + data_length;
AzureIoTClient 41:71c01aa3df1a 410 result = RESULT_OK;
AzureIoTClient 41:71c01aa3df1a 411 }
AzureIoTClient 23:2c6779675a01 412
AzureIoTClient 41:71c01aa3df1a 413 if (NULL != data_value)
AzureIoTClient 41:71c01aa3df1a 414 {
AzureIoTClient 41:71c01aa3df1a 415 amqpvalue_destroy(data_value);
AzureIoTClient 41:71c01aa3df1a 416 }
AzureIoTClient 23:2c6779675a01 417
AzureIoTClient 41:71c01aa3df1a 418 if (NULL != application_properties)
AzureIoTClient 41:71c01aa3df1a 419 {
AzureIoTClient 41:71c01aa3df1a 420 amqpvalue_destroy(application_properties);
AzureIoTClient 41:71c01aa3df1a 421 }
AzureIoTClient 41:71c01aa3df1a 422
AzureIoTClient 41:71c01aa3df1a 423 if (NULL != message_properties)
AzureIoTClient 41:71c01aa3df1a 424 {
AzureIoTClient 41:71c01aa3df1a 425 amqpvalue_destroy(message_properties);
AzureIoTClient 41:71c01aa3df1a 426 }
AzureIoTClient 41:71c01aa3df1a 427
AzureIoTClient 41:71c01aa3df1a 428 return result;
AzureIoTClient 23:2c6779675a01 429 }
AzureIoTClient 23:2c6779675a01 430
AzureIoTClient 23:2c6779675a01 431 static int readPropertiesFromuAMQPMessage(IOTHUB_MESSAGE_HANDLE iothub_message_handle, MESSAGE_HANDLE uamqp_message)
AzureIoTClient 23:2c6779675a01 432 {
AzureIoTClient 41:71c01aa3df1a 433 int return_value;
AzureIoTClient 41:71c01aa3df1a 434 PROPERTIES_HANDLE uamqp_message_properties;
AzureIoTClient 41:71c01aa3df1a 435 AMQP_VALUE uamqp_message_property;
AzureIoTClient 41:71c01aa3df1a 436 const char* uamqp_message_property_value;
AzureIoTClient 41:71c01aa3df1a 437 int api_call_result;
AzureIoTClient 23:2c6779675a01 438
AzureIoTClient 41:71c01aa3df1a 439 // Codes_SRS_UAMQP_MESSAGING_09_008: [The uAMQP message properties shall be retrieved using message_get_properties().]
AzureIoTClient 41:71c01aa3df1a 440 if ((api_call_result = message_get_properties(uamqp_message, &uamqp_message_properties)) != 0)
AzureIoTClient 41:71c01aa3df1a 441 {
AzureIoTClient 41:71c01aa3df1a 442 // Codes_SRS_UAMQP_MESSAGING_09_009: [If message_get_properties() fails, message_create_IoTHubMessage_from_uamqp_message shall fail and return immediately.]
AzureIoTClient 41:71c01aa3df1a 443 LogError("Failed to get property properties map from uAMQP message (error code %d).", api_call_result);
AzureIoTClient 41:71c01aa3df1a 444 return_value = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 445 }
AzureIoTClient 40:e79ee1341949 446 else
AzureIoTClient 40:e79ee1341949 447 {
AzureIoTClient 40:e79ee1341949 448 return_value = 0; // Properties 'message-id' and 'correlation-id' are optional according to the AMQP 1.0 spec.
AzureIoTClient 40:e79ee1341949 449
AzureIoTClient 40:e79ee1341949 450 // Codes_SRS_UAMQP_MESSAGING_09_010: [The message-id property shall be read from the uAMQP message by calling properties_get_message_id.]
AzureIoTClient 40:e79ee1341949 451 if ((api_call_result = properties_get_message_id(uamqp_message_properties, &uamqp_message_property)) != 0)
AzureIoTClient 40:e79ee1341949 452 {
AzureIoTClient 41:71c01aa3df1a 453 // 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 454 LogInfo("Failed to get value of uAMQP message 'message-id' property (%d). No failure, since it is optional.", api_call_result);
AzureIoTClient 40:e79ee1341949 455 }
AzureIoTClient 40:e79ee1341949 456 // Codes_SRS_UAMQP_MESSAGING_09_012: [The type of the message-id property value shall be obtained using amqpvalue_get_type().]
AzureIoTClient 41:71c01aa3df1a 457 // 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 40:e79ee1341949 458 else if (amqpvalue_get_type(uamqp_message_property) != AMQP_TYPE_NULL)
AzureIoTClient 40:e79ee1341949 459 {
AzureIoTClient 40:e79ee1341949 460 // Codes_SRS_UAMQP_MESSAGING_09_014: [The message-id value shall be retrieved from the AMQP_VALUE as char* by calling amqpvalue_get_string().]
AzureIoTClient 40:e79ee1341949 461 if ((api_call_result = amqpvalue_get_string(uamqp_message_property, &uamqp_message_property_value)) != 0)
AzureIoTClient 40:e79ee1341949 462 {
AzureIoTClient 41:71c01aa3df1a 463 // Codes_SRS_UAMQP_MESSAGING_09_015: [If amqpvalue_get_string fails, message_create_IoTHubMessage_from_uamqp_message() shall fail and return immediately.]
AzureIoTClient 40:e79ee1341949 464 LogError("Failed to get value of uAMQP message 'message-id' property (%d).", api_call_result);
AzureIoTClient 40:e79ee1341949 465 return_value = __FAILURE__;
AzureIoTClient 40:e79ee1341949 466 }
AzureIoTClient 40:e79ee1341949 467 // 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 40:e79ee1341949 468 else if (IoTHubMessage_SetMessageId(iothub_message_handle, uamqp_message_property_value) != IOTHUB_MESSAGE_OK)
AzureIoTClient 40:e79ee1341949 469 {
AzureIoTClient 41:71c01aa3df1a 470 // Codes_SRS_UAMQP_MESSAGING_09_017: [If IoTHubMessage_SetMessageId fails, message_create_IoTHubMessage_from_uamqp_message() shall fail and return immediately.]
AzureIoTClient 40:e79ee1341949 471 LogError("Failed to set IOTHUB_MESSAGE_HANDLE 'message-id' property.");
AzureIoTClient 40:e79ee1341949 472 return_value = __FAILURE__;
AzureIoTClient 40:e79ee1341949 473 }
AzureIoTClient 40:e79ee1341949 474 }
AzureIoTClient 23:2c6779675a01 475
AzureIoTClient 40:e79ee1341949 476 // Codes_SRS_UAMQP_MESSAGING_09_018: [The correlation-id property shall be read from the uAMQP message by calling properties_get_correlation_id.]
AzureIoTClient 40:e79ee1341949 477 if ((api_call_result = properties_get_correlation_id(uamqp_message_properties, &uamqp_message_property)) != 0)
AzureIoTClient 40:e79ee1341949 478 {
AzureIoTClient 41:71c01aa3df1a 479 // 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 480 LogError("Failed to get value of uAMQP message 'correlation-id' property (%d). No failure, since it is optional.", api_call_result);
AzureIoTClient 40:e79ee1341949 481 }
AzureIoTClient 40:e79ee1341949 482 // Codes_SRS_UAMQP_MESSAGING_09_020: [The type of the correlation-id property value shall be obtained using amqpvalue_get_type().]
AzureIoTClient 41:71c01aa3df1a 483 // Codes_SRS_UAMQP_MESSAGING_09_021: [If the type of the correlation-id property value is AMQP_TYPE_NULL, message_create_IoTHubMessage_from_uamqp_message() shall skip processing the correlation-id (as it is optional) and continue normally.]
AzureIoTClient 40:e79ee1341949 484 else if (amqpvalue_get_type(uamqp_message_property) != AMQP_TYPE_NULL)
AzureIoTClient 40:e79ee1341949 485 {
AzureIoTClient 40:e79ee1341949 486 // Codes_SRS_UAMQP_MESSAGING_09_022: [The correlation-id value shall be retrieved from the AMQP_VALUE as char* by calling amqpvalue_get_string.]
AzureIoTClient 40:e79ee1341949 487 if ((api_call_result = amqpvalue_get_string(uamqp_message_property, &uamqp_message_property_value)) != 0)
AzureIoTClient 40:e79ee1341949 488 {
AzureIoTClient 41:71c01aa3df1a 489 // Codes_SRS_UAMQP_MESSAGING_09_023: [If amqpvalue_get_string fails, message_create_IoTHubMessage_from_uamqp_message() shall fail and return immediately.]
AzureIoTClient 40:e79ee1341949 490 LogError("Failed to get value of uAMQP message 'correlation-id' property (%d).", api_call_result);
AzureIoTClient 40:e79ee1341949 491 return_value = __FAILURE__;
AzureIoTClient 40:e79ee1341949 492 }
AzureIoTClient 40:e79ee1341949 493 // 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 40:e79ee1341949 494 else if (IoTHubMessage_SetCorrelationId(iothub_message_handle, uamqp_message_property_value) != IOTHUB_MESSAGE_OK)
AzureIoTClient 40:e79ee1341949 495 {
AzureIoTClient 41:71c01aa3df1a 496 // Codes_SRS_UAMQP_MESSAGING_09_025: [If IoTHubMessage_SetCorrelationId fails, message_create_IoTHubMessage_from_uamqp_message() shall fail and return immediately.]
AzureIoTClient 40:e79ee1341949 497 LogError("Failed to set IOTHUB_MESSAGE_HANDLE 'correlation-id' property.");
AzureIoTClient 40:e79ee1341949 498 return_value = __FAILURE__;
AzureIoTClient 40:e79ee1341949 499 }
AzureIoTClient 40:e79ee1341949 500 }
AzureIoTClient 41:71c01aa3df1a 501 // 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 502 properties_destroy(uamqp_message_properties);
AzureIoTClient 41:71c01aa3df1a 503 }
AzureIoTClient 40:e79ee1341949 504
AzureIoTClient 41:71c01aa3df1a 505 return return_value;
AzureIoTClient 23:2c6779675a01 506 }
AzureIoTClient 23:2c6779675a01 507
AzureIoTClient 23:2c6779675a01 508 static int readApplicationPropertiesFromuAMQPMessage(IOTHUB_MESSAGE_HANDLE iothub_message_handle, MESSAGE_HANDLE uamqp_message)
AzureIoTClient 23:2c6779675a01 509 {
AzureIoTClient 41:71c01aa3df1a 510 int result;
AzureIoTClient 41:71c01aa3df1a 511 AMQP_VALUE uamqp_app_properties = NULL;
AzureIoTClient 41:71c01aa3df1a 512 AMQP_VALUE uamqp_app_properties_ipdv = NULL;
AzureIoTClient 41:71c01aa3df1a 513 uint32_t property_count = 0;
AzureIoTClient 41:71c01aa3df1a 514 MAP_HANDLE iothub_message_properties_map;
AzureIoTClient 23:2c6779675a01 515
AzureIoTClient 41:71c01aa3df1a 516 // Codes_SRS_UAMQP_MESSAGING_09_027: [The IOTHUB_MESSAGE_HANDLE properties shall be retrieved using IoTHubMessage_Properties.]
AzureIoTClient 41:71c01aa3df1a 517 if ((iothub_message_properties_map = IoTHubMessage_Properties(iothub_message_handle)) == NULL)
AzureIoTClient 41:71c01aa3df1a 518 {
AzureIoTClient 41:71c01aa3df1a 519 // Codes_SRS_UAMQP_MESSAGING_09_028: [If IoTHubMessage_Properties fails, message_create_IoTHubMessage_from_uamqp_message() shall fail and return immediately.]
AzureIoTClient 41:71c01aa3df1a 520 LogError("Failed to get property map from IoTHub message.");
AzureIoTClient 41:71c01aa3df1a 521 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 522 }
AzureIoTClient 41:71c01aa3df1a 523 // Codes_SRS_UAMQP_MESSAGING_09_029: [The uAMQP message application properties shall be retrieved using message_get_application_properties.]
AzureIoTClient 41:71c01aa3df1a 524 else if ((result = message_get_application_properties(uamqp_message, &uamqp_app_properties)) != 0)
AzureIoTClient 41:71c01aa3df1a 525 {
AzureIoTClient 41:71c01aa3df1a 526 // 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 527 LogError("Failed reading the incoming uAMQP message properties (return code %d).", result);
AzureIoTClient 41:71c01aa3df1a 528 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 529 }
AzureIoTClient 41:71c01aa3df1a 530 else
AzureIoTClient 41:71c01aa3df1a 531 {
AzureIoTClient 41:71c01aa3df1a 532 // 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 533 if (uamqp_app_properties == NULL)
AzureIoTClient 41:71c01aa3df1a 534 {
AzureIoTClient 41:71c01aa3df1a 535 result = 0;
AzureIoTClient 41:71c01aa3df1a 536 }
AzureIoTClient 41:71c01aa3df1a 537 else
AzureIoTClient 41:71c01aa3df1a 538 {
AzureIoTClient 41:71c01aa3df1a 539 // 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 540 if ((uamqp_app_properties_ipdv = amqpvalue_get_inplace_described_value(uamqp_app_properties)) == NULL)
AzureIoTClient 41:71c01aa3df1a 541 {
AzureIoTClient 41:71c01aa3df1a 542 // 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 543 LogError("Failed getting the map of uAMQP message application properties (return code %d).", result);
AzureIoTClient 41:71c01aa3df1a 544 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 545 }
AzureIoTClient 41:71c01aa3df1a 546 // 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 547 else if ((result = amqpvalue_get_map_pair_count(uamqp_app_properties_ipdv, &property_count)) != 0)
AzureIoTClient 41:71c01aa3df1a 548 {
AzureIoTClient 41:71c01aa3df1a 549 // 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 550 LogError("Failed reading the number of values in the uAMQP property map (return code %d).", result);
AzureIoTClient 41:71c01aa3df1a 551 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 552 }
AzureIoTClient 41:71c01aa3df1a 553 else
AzureIoTClient 41:71c01aa3df1a 554 {
AzureIoTClient 41:71c01aa3df1a 555 // 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 556 uint32_t i;
AzureIoTClient 41:71c01aa3df1a 557 for (i = 0; result == RESULT_OK && i < property_count; i++)
AzureIoTClient 41:71c01aa3df1a 558 {
AzureIoTClient 41:71c01aa3df1a 559 AMQP_VALUE map_key_name = NULL;
AzureIoTClient 41:71c01aa3df1a 560 AMQP_VALUE map_key_value = NULL;
AzureIoTClient 41:71c01aa3df1a 561 const char *key_name;
AzureIoTClient 41:71c01aa3df1a 562 const char* key_value;
AzureIoTClient 23:2c6779675a01 563
AzureIoTClient 41:71c01aa3df1a 564 // 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 565 if ((result = amqpvalue_get_map_key_value_pair(uamqp_app_properties_ipdv, i, &map_key_name, &map_key_value)) != 0)
AzureIoTClient 41:71c01aa3df1a 566 {
AzureIoTClient 41:71c01aa3df1a 567 // 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 568 LogError("Failed reading the key/value pair from the uAMQP property map (return code %d).", result);
AzureIoTClient 41:71c01aa3df1a 569 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 570 }
AzureIoTClient 23:2c6779675a01 571
AzureIoTClient 41:71c01aa3df1a 572 // Codes_SRS_UAMQP_MESSAGING_09_039: [The uAMQP application property name shall be extracted as string using amqpvalue_get_string.]
AzureIoTClient 41:71c01aa3df1a 573 else if ((result = amqpvalue_get_string(map_key_name, &key_name)) != 0)
AzureIoTClient 41:71c01aa3df1a 574 {
AzureIoTClient 41:71c01aa3df1a 575 // 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 576 LogError("Failed parsing the uAMQP property name (return code %d).", result);
AzureIoTClient 41:71c01aa3df1a 577 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 578 }
AzureIoTClient 41:71c01aa3df1a 579 // Codes_SRS_UAMQP_MESSAGING_09_041: [The uAMQP application property value shall be extracted as string using amqpvalue_get_string.]
AzureIoTClient 41:71c01aa3df1a 580 else if ((result = amqpvalue_get_string(map_key_value, &key_value)) != 0)
AzureIoTClient 41:71c01aa3df1a 581 {
AzureIoTClient 41:71c01aa3df1a 582 // 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 583 LogError("Failed parsing the uAMQP property value (return code %d).", result);
AzureIoTClient 41:71c01aa3df1a 584 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 585 }
AzureIoTClient 41:71c01aa3df1a 586 // 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 587 else if (Map_AddOrUpdate(iothub_message_properties_map, key_name, key_value) != MAP_OK)
AzureIoTClient 41:71c01aa3df1a 588 {
AzureIoTClient 41:71c01aa3df1a 589 // Codes_SRS_UAMQP_MESSAGING_09_044: [If Map_AddOrUpdate fails, message_create_IoTHubMessage_from_uamqp_message() shall fail and return immediately.]
AzureIoTClient 41:71c01aa3df1a 590 LogError("Failed to add/update IoTHub message property map.");
AzureIoTClient 41:71c01aa3df1a 591 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 592 }
AzureIoTClient 23:2c6779675a01 593
AzureIoTClient 41:71c01aa3df1a 594 // 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 595 if (map_key_name != NULL)
AzureIoTClient 41:71c01aa3df1a 596 {
AzureIoTClient 41:71c01aa3df1a 597 amqpvalue_destroy(map_key_name);
AzureIoTClient 41:71c01aa3df1a 598 }
AzureIoTClient 23:2c6779675a01 599
AzureIoTClient 41:71c01aa3df1a 600 if (map_key_value != NULL)
AzureIoTClient 41:71c01aa3df1a 601 {
AzureIoTClient 41:71c01aa3df1a 602 amqpvalue_destroy(map_key_value);
AzureIoTClient 41:71c01aa3df1a 603 }
AzureIoTClient 41:71c01aa3df1a 604 }
AzureIoTClient 41:71c01aa3df1a 605 }
AzureIoTClient 23:2c6779675a01 606
AzureIoTClient 41:71c01aa3df1a 607 // 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 608 amqpvalue_destroy(uamqp_app_properties);
AzureIoTClient 41:71c01aa3df1a 609 }
AzureIoTClient 41:71c01aa3df1a 610 }
AzureIoTClient 23:2c6779675a01 611
AzureIoTClient 41:71c01aa3df1a 612 return result;
AzureIoTClient 23:2c6779675a01 613 }
AzureIoTClient 23:2c6779675a01 614
AzureIoTClient 41:71c01aa3df1a 615 int message_create_IoTHubMessage_from_uamqp_message(MESSAGE_HANDLE uamqp_message, IOTHUB_MESSAGE_HANDLE* iothubclient_message)
AzureIoTClient 23:2c6779675a01 616 {
AzureIoTClient 41:71c01aa3df1a 617 int result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 618
AzureIoTClient 41:71c01aa3df1a 619 IOTHUB_MESSAGE_HANDLE iothub_message = NULL;
AzureIoTClient 41:71c01aa3df1a 620 MESSAGE_BODY_TYPE body_type;
AzureIoTClient 23:2c6779675a01 621
AzureIoTClient 41:71c01aa3df1a 622 // Codes_SRS_UAMQP_MESSAGING_09_001: [The body type of the uAMQP message shall be retrieved using message_get_body_type().]
AzureIoTClient 41:71c01aa3df1a 623 if (message_get_body_type(uamqp_message, &body_type) != 0)
AzureIoTClient 41:71c01aa3df1a 624 {
AzureIoTClient 41:71c01aa3df1a 625 // 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 626 LogError("Failed to get the type of the uamqp message.");
AzureIoTClient 41:71c01aa3df1a 627 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 628 }
AzureIoTClient 41:71c01aa3df1a 629 else
AzureIoTClient 41:71c01aa3df1a 630 {
AzureIoTClient 41:71c01aa3df1a 631 // 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 632 if (body_type == MESSAGE_BODY_TYPE_DATA)
AzureIoTClient 41:71c01aa3df1a 633 {
AzureIoTClient 41:71c01aa3df1a 634 // Codes_SRS_UAMQP_MESSAGING_09_004: [The uAMQP message body data shall be retrieved using message_get_body_amqp_data().]
AzureIoTClient 41:71c01aa3df1a 635 BINARY_DATA binary_data;
AzureIoTClient 41:71c01aa3df1a 636 if (message_get_body_amqp_data_in_place(uamqp_message, 0, &binary_data) != 0)
AzureIoTClient 41:71c01aa3df1a 637 {
AzureIoTClient 41:71c01aa3df1a 638 // 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 639 LogError("Failed to get the body of the uamqp message.");
AzureIoTClient 41:71c01aa3df1a 640 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 641 }
AzureIoTClient 41:71c01aa3df1a 642 // 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 643 else if ((iothub_message = IoTHubMessage_CreateFromByteArray(binary_data.bytes, binary_data.length)) == NULL)
AzureIoTClient 41:71c01aa3df1a 644 {
AzureIoTClient 41:71c01aa3df1a 645 // Codes_SRS_UAMQP_MESSAGING_09_007: [If IoTHubMessage_CreateFromByteArray() fails, message_create_IoTHubMessage_from_uamqp_message shall fail and return immediately.]
AzureIoTClient 41:71c01aa3df1a 646 LogError("Failed creating the IOTHUB_MESSAGE_HANDLE instance (IoTHubMessage_CreateFromByteArray failed).");
AzureIoTClient 41:71c01aa3df1a 647 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 648 }
AzureIoTClient 41:71c01aa3df1a 649 }
AzureIoTClient 41:71c01aa3df1a 650 }
AzureIoTClient 23:2c6779675a01 651
AzureIoTClient 41:71c01aa3df1a 652 if (iothub_message != NULL)
AzureIoTClient 41:71c01aa3df1a 653 {
AzureIoTClient 41:71c01aa3df1a 654 if (readPropertiesFromuAMQPMessage(iothub_message, uamqp_message) != RESULT_OK)
AzureIoTClient 41:71c01aa3df1a 655 {
AzureIoTClient 41:71c01aa3df1a 656 LogError("Failed reading properties of the uamqp message.");
AzureIoTClient 41:71c01aa3df1a 657 IoTHubMessage_Destroy(iothub_message);
AzureIoTClient 41:71c01aa3df1a 658 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 659 }
AzureIoTClient 41:71c01aa3df1a 660 else if (readApplicationPropertiesFromuAMQPMessage(iothub_message, uamqp_message) != RESULT_OK)
AzureIoTClient 41:71c01aa3df1a 661 {
AzureIoTClient 41:71c01aa3df1a 662 LogError("Failed reading application properties of the uamqp message.");
AzureIoTClient 41:71c01aa3df1a 663 IoTHubMessage_Destroy(iothub_message);
AzureIoTClient 41:71c01aa3df1a 664 result = __FAILURE__;
AzureIoTClient 41:71c01aa3df1a 665 }
AzureIoTClient 41:71c01aa3df1a 666 else
AzureIoTClient 41:71c01aa3df1a 667 {
AzureIoTClient 41:71c01aa3df1a 668 *iothubclient_message = iothub_message;
AzureIoTClient 41:71c01aa3df1a 669 result = RESULT_OK;
AzureIoTClient 41:71c01aa3df1a 670 }
AzureIoTClient 41:71c01aa3df1a 671 }
AzureIoTClient 23:2c6779675a01 672
AzureIoTClient 41:71c01aa3df1a 673 return result;
AzureIoTClient 23:2c6779675a01 674 }
AzureIoTClient 23:2c6779675a01 675