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@40:e79ee1341949, 2017-08-25 (annotated)

Committer:
AzureIoTClient
Date:
Fri Aug 25 11:22:00 2017 -0700
Revision:
40:e79ee1341949
Parent:
34:51d158b409d2
Child:
41:71c01aa3df1a
1.1.22

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 23:2c6779675a01 14 static int addPropertiesTouAMQPMessage(IOTHUB_MESSAGE_HANDLE iothub_message_handle, MESSAGE_HANDLE uamqp_message)
AzureIoTClient 23:2c6779675a01 15 {
AzureIoTClient 23:2c6779675a01 16 int result = RESULT_OK;
AzureIoTClient 23:2c6779675a01 17 const char* messageId;
AzureIoTClient 23:2c6779675a01 18 const char* correlationId;
AzureIoTClient 40:e79ee1341949 19 const char* contentType;
AzureIoTClient 40:e79ee1341949 20 const char* contentEncoding;
AzureIoTClient 40:e79ee1341949 21
AzureIoTClient 23:2c6779675a01 22 PROPERTIES_HANDLE uamqp_message_properties = NULL;
AzureIoTClient 23:2c6779675a01 23 int api_call_result;
AzureIoTClient 23:2c6779675a01 24
AzureIoTClient 23:2c6779675a01 25 // Codes_SRS_UAMQP_MESSAGING_09_060: [The uAMQP message properties shall be retrieved using message_get_properties().]
AzureIoTClient 23:2c6779675a01 26 if ((api_call_result = message_get_properties(uamqp_message, &uamqp_message_properties)) != 0)
AzureIoTClient 23:2c6779675a01 27 {
AzureIoTClient 23:2c6779675a01 28 // Codes_SRS_UAMQP_MESSAGING_09_061: [If message_get_properties() fails, message_create_from_iothub_message() shall fail and return immediately.]
AzureIoTClient 23:2c6779675a01 29 LogError("Failed to get properties map from uAMQP message (error code %d).", api_call_result);
AzureIoTClient 29:7e8852b14e3b 30 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 31 }
AzureIoTClient 23:2c6779675a01 32 // Codes_SRS_UAMQP_MESSAGING_09_062: [If UAMQP message properties were not present then a new properties container shall be created using properties_create()]
AzureIoTClient 23:2c6779675a01 33 else if (uamqp_message_properties == NULL &&
AzureIoTClient 23:2c6779675a01 34 (uamqp_message_properties = properties_create()) == NULL)
AzureIoTClient 23:2c6779675a01 35 {
AzureIoTClient 23:2c6779675a01 36 // Codes_SRS_UAMQP_MESSAGING_09_063: [If properties_create() fails, message_create_from_iothub_message() shall fail and return immediately.]
AzureIoTClient 23:2c6779675a01 37 LogError("Failed to create properties map for uAMQP message (error code %d).", api_call_result);
AzureIoTClient 29:7e8852b14e3b 38 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 39 }
AzureIoTClient 23:2c6779675a01 40 else
AzureIoTClient 23:2c6779675a01 41 {
AzureIoTClient 23:2c6779675a01 42 // Codes_SRS_UAMQP_MESSAGING_09_064: [Message-id from the IOTHUB_MESSAGE shall be read using IoTHubMessage_GetMessageId()]
AzureIoTClient 23:2c6779675a01 43 // Codes_SRS_UAMQP_MESSAGING_09_065: [As message-id is optional field, if it is not set on the IOTHUB_MESSAGE, message_create_from_iothub_message() shall ignore it and continue normally.]
AzureIoTClient 23:2c6779675a01 44 if ((messageId = IoTHubMessage_GetMessageId(iothub_message_handle)) != NULL)
AzureIoTClient 23:2c6779675a01 45 {
AzureIoTClient 23:2c6779675a01 46 // Codes_SRS_UAMQP_MESSAGING_09_066: [The message-id value shall be stored on a AMQP_VALUE using amqpvalue_create_string()]
AzureIoTClient 23:2c6779675a01 47 AMQP_VALUE uamqp_message_id;
AzureIoTClient 23:2c6779675a01 48 if ((uamqp_message_id = amqpvalue_create_string(messageId)) == NULL)
AzureIoTClient 23:2c6779675a01 49 {
AzureIoTClient 23:2c6779675a01 50 // Codes_SRS_UAMQP_MESSAGING_09_067: [If amqpvalue_create_string() fails, message_create_from_iothub_message() shall fail and return immediately.]
AzureIoTClient 23:2c6779675a01 51 LogError("Failed to create an AMQP_VALUE for the messageId property value.");
AzureIoTClient 29:7e8852b14e3b 52 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 53 }
AzureIoTClient 23:2c6779675a01 54 else
AzureIoTClient 23:2c6779675a01 55 {
AzureIoTClient 23:2c6779675a01 56 // Codes_SRS_UAMQP_MESSAGING_09_068: [The message-id AMQP_VALUE shall be set on the uAMQP message using properties_set_message_id()]
AzureIoTClient 23:2c6779675a01 57 if ((api_call_result = properties_set_message_id(uamqp_message_properties, uamqp_message_id)) != 0)
AzureIoTClient 23:2c6779675a01 58 {
AzureIoTClient 23:2c6779675a01 59 // Codes_SRS_UAMQP_MESSAGING_09_069: [If properties_set_message_id() fails, message_create_from_iothub_message() shall fail and return immediately.]
AzureIoTClient 23:2c6779675a01 60 LogInfo("Failed to set value of uAMQP message 'message-id' property (%d).", api_call_result);
AzureIoTClient 29:7e8852b14e3b 61 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 62 }
AzureIoTClient 23:2c6779675a01 63 // Codes_SRS_UAMQP_MESSAGING_09_070: [The uAMQP message-id AMQP_VALUE instance shall be destroyed using amqpvalue_destroy().]
AzureIoTClient 23:2c6779675a01 64 amqpvalue_destroy(uamqp_message_id);
AzureIoTClient 23:2c6779675a01 65 }
AzureIoTClient 23:2c6779675a01 66 }
AzureIoTClient 23:2c6779675a01 67
AzureIoTClient 23:2c6779675a01 68 // Codes_SRS_UAMQP_MESSAGING_09_071: [Correlation-id from the IOTHUB_MESSAGE shall be read using IoTHubMessage_GetCorrelationId()]
AzureIoTClient 23:2c6779675a01 69 // Codes_SRS_UAMQP_MESSAGING_09_072: [As correlation-id is optional field, if it is not set on the IOTHUB_MESSAGE, message_create_from_iothub_message() shall ignore it and continue normally.]
AzureIoTClient 40:e79ee1341949 70 if (result == RESULT_OK && (correlationId = IoTHubMessage_GetCorrelationId(iothub_message_handle)) != NULL)
AzureIoTClient 23:2c6779675a01 71 {
AzureIoTClient 23:2c6779675a01 72 // Codes_SRS_UAMQP_MESSAGING_09_073: [The correlation-id value shall be stored on a AMQP_VALUE using amqpvalue_create_string()]
AzureIoTClient 23:2c6779675a01 73 AMQP_VALUE uamqp_correlation_id;
AzureIoTClient 23:2c6779675a01 74 if ((uamqp_correlation_id = amqpvalue_create_string(correlationId)) == NULL)
AzureIoTClient 23:2c6779675a01 75 {
AzureIoTClient 23:2c6779675a01 76 // Codes_SRS_UAMQP_MESSAGING_09_074: [If amqpvalue_create_string() fails, message_create_from_iothub_message() shall fail and return immediately.]
AzureIoTClient 23:2c6779675a01 77 LogError("Failed to create an AMQP_VALUE for the messageId property value.");
AzureIoTClient 29:7e8852b14e3b 78 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 79 }
AzureIoTClient 23:2c6779675a01 80 else
AzureIoTClient 23:2c6779675a01 81 {
AzureIoTClient 23:2c6779675a01 82 // Codes_SRS_UAMQP_MESSAGING_09_075: [The correlation-id AMQP_VALUE shall be set on the uAMQP message using properties_set_correlation_id()]
AzureIoTClient 23:2c6779675a01 83 if ((api_call_result = properties_set_correlation_id(uamqp_message_properties, uamqp_correlation_id)) != 0)
AzureIoTClient 23:2c6779675a01 84 {
AzureIoTClient 23:2c6779675a01 85 // Codes_SRS_UAMQP_MESSAGING_09_076: [If properties_set_correlation_id() fails, message_create_from_iothub_message() shall fail and return immediately.]
AzureIoTClient 40:e79ee1341949 86 LogInfo("Failed to set value of uAMQP message 'correlation-id' property (%d).", api_call_result);
AzureIoTClient 29:7e8852b14e3b 87 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 88 }
AzureIoTClient 23:2c6779675a01 89
AzureIoTClient 23:2c6779675a01 90 // Codes_SRS_UAMQP_MESSAGING_09_077: [The uAMQP correlation-id AMQP_VALUE instance shall be destroyed using amqpvalue_destroy().]
AzureIoTClient 23:2c6779675a01 91 amqpvalue_destroy(uamqp_correlation_id);
AzureIoTClient 23:2c6779675a01 92 }
AzureIoTClient 23:2c6779675a01 93 }
AzureIoTClient 40:e79ee1341949 94
AzureIoTClient 40:e79ee1341949 95 // Codes_SRS_UAMQP_MESSAGING_09_106: [If the IOTHUB_MESSAGE contains property `content-type`, it shall be set on the uAMQP message]
AzureIoTClient 40:e79ee1341949 96 if (result == RESULT_OK && (contentType = IoTHubMessage_GetContentTypeSystemProperty(iothub_message_handle)) != NULL)
AzureIoTClient 40:e79ee1341949 97 {
AzureIoTClient 40:e79ee1341949 98 if ((api_call_result = properties_set_content_type(uamqp_message_properties, contentType)) != 0)
AzureIoTClient 40:e79ee1341949 99 {
AzureIoTClient 40:e79ee1341949 100 LogInfo("Failed to set value of uAMQP message 'content-type' property (%d).", api_call_result);
AzureIoTClient 40:e79ee1341949 101 // Codes_SRS_UAMQP_MESSAGING_09_108: [If setting the `content-type` property on uAMQP message fails, message_create_from_iothub_message() shall fail and return immediately.]
AzureIoTClient 40:e79ee1341949 102 result = __FAILURE__;
AzureIoTClient 40:e79ee1341949 103 }
AzureIoTClient 40:e79ee1341949 104 }
AzureIoTClient 40:e79ee1341949 105
AzureIoTClient 40:e79ee1341949 106 // Codes_SRS_UAMQP_MESSAGING_09_109: [If the IOTHUB_MESSAGE contains property `content-encoding`, it shall be set on the uAMQP message]
AzureIoTClient 40:e79ee1341949 107 if (result == RESULT_OK && (contentEncoding = IoTHubMessage_GetContentEncodingSystemProperty(iothub_message_handle)) != NULL)
AzureIoTClient 40:e79ee1341949 108 {
AzureIoTClient 40:e79ee1341949 109 if ((api_call_result = properties_set_content_encoding(uamqp_message_properties, contentEncoding)) != 0)
AzureIoTClient 40:e79ee1341949 110 {
AzureIoTClient 40:e79ee1341949 111 LogInfo("Failed to set value of uAMQP message 'content-encoding' property (%d).", api_call_result);
AzureIoTClient 40:e79ee1341949 112 // Codes_SRS_UAMQP_MESSAGING_09_111: [If setting the `content-encoding` property on uAMQP message fails, message_create_from_iothub_message() shall fail and return immediately.]
AzureIoTClient 40:e79ee1341949 113 result = __FAILURE__;
AzureIoTClient 40:e79ee1341949 114 }
AzureIoTClient 40:e79ee1341949 115 }
AzureIoTClient 40:e79ee1341949 116
AzureIoTClient 23:2c6779675a01 117 // Codes_SRS_UAMQP_MESSAGING_09_078: [The updated PROPERTIES_HANDLE instance shall be set on the uAMQP message using message_set_properties()]
AzureIoTClient 40:e79ee1341949 118 if (result == RESULT_OK && (api_call_result = message_set_properties(uamqp_message, uamqp_message_properties)) != 0)
AzureIoTClient 23:2c6779675a01 119 {
AzureIoTClient 23:2c6779675a01 120 // Codes_SRS_UAMQP_MESSAGING_09_079: [If message_set_properties() fails, message_create_from_iothub_message() shall fail and return immediately.]
AzureIoTClient 23:2c6779675a01 121 LogError("Failed to set properties map on uAMQP message (error code %d).", api_call_result);
AzureIoTClient 29:7e8852b14e3b 122 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 123 }
AzureIoTClient 23:2c6779675a01 124 }
AzureIoTClient 23:2c6779675a01 125
AzureIoTClient 23:2c6779675a01 126 // Codes_SRS_UAMQP_MESSAGING_09_099: [The uAMQP message properties (obtained with message_get_properties()) shall be destroyed by calling properties_destroy().]
AzureIoTClient 23:2c6779675a01 127 properties_destroy(uamqp_message_properties);
AzureIoTClient 23:2c6779675a01 128
AzureIoTClient 23:2c6779675a01 129 return result;
AzureIoTClient 23:2c6779675a01 130 }
AzureIoTClient 23:2c6779675a01 131
AzureIoTClient 23:2c6779675a01 132 static int addApplicationPropertiesTouAMQPMessage(IOTHUB_MESSAGE_HANDLE iothub_message_handle, MESSAGE_HANDLE uamqp_message)
AzureIoTClient 23:2c6779675a01 133 {
AzureIoTClient 23:2c6779675a01 134 int result = RESULT_OK;
AzureIoTClient 23:2c6779675a01 135 MAP_HANDLE properties_map;
AzureIoTClient 23:2c6779675a01 136 const char* const* propertyKeys;
AzureIoTClient 23:2c6779675a01 137 const char* const* propertyValues;
AzureIoTClient 23:2c6779675a01 138 size_t propertyCount = 0;
AzureIoTClient 23:2c6779675a01 139
AzureIoTClient 23:2c6779675a01 140 // Codes_SRS_UAMQP_MESSAGING_09_080: [The IOTHUB_MESSAGE_HANDLE properties shall be obtained by calling IoTHubMessage_Properties.]
AzureIoTClient 23:2c6779675a01 141 if ((properties_map = IoTHubMessage_Properties(iothub_message_handle)) == NULL)
AzureIoTClient 23:2c6779675a01 142 {
AzureIoTClient 23:2c6779675a01 143 // Codes_SRS_UAMQP_MESSAGING_09_081: [If IoTHubMessage_Properties() fails, message_create_from_iothub_message() shall fail and return immediately..]
AzureIoTClient 23:2c6779675a01 144 LogError("Failed to get property map from IoTHub message.");
AzureIoTClient 29:7e8852b14e3b 145 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 146 }
AzureIoTClient 23:2c6779675a01 147 // Codes_SRS_UAMQP_MESSAGING_09_082: [The actual keys and values, as well as the number of properties shall be obtained by calling Map_GetInternals on the handle obtained from IoTHubMessage_Properties.]
AzureIoTClient 23:2c6779675a01 148 else if (Map_GetInternals(properties_map, &propertyKeys, &propertyValues, &propertyCount) != MAP_OK)
AzureIoTClient 23:2c6779675a01 149 {
AzureIoTClient 23:2c6779675a01 150 // Codes_SRS_UAMQP_MESSAGING_09_083: [If Map_GetInternals fails, message_create_from_iothub_message() shall fail and return immediately..]
AzureIoTClient 23:2c6779675a01 151 LogError("Failed to get the internals of the property map.");
AzureIoTClient 29:7e8852b14e3b 152 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 153 }
AzureIoTClient 23:2c6779675a01 154 else
AzureIoTClient 23:2c6779675a01 155 {
AzureIoTClient 23:2c6779675a01 156 // Codes_SRS_UAMQP_MESSAGING_09_085: [If the number of properties is greater than 0, message_create_from_iothub_message() shall iterate through all the properties and add them to the uAMQP message.]
AzureIoTClient 23:2c6779675a01 157 if (propertyCount != 0)
AzureIoTClient 23:2c6779675a01 158 {
AzureIoTClient 23:2c6779675a01 159 size_t i;
AzureIoTClient 23:2c6779675a01 160 AMQP_VALUE uamqp_map;
AzureIoTClient 23:2c6779675a01 161
AzureIoTClient 23:2c6779675a01 162 // Codes_SRS_UAMQP_MESSAGING_09_086: [A uAMQP property map shall be created by calling amqpvalue_create_map().]
AzureIoTClient 23:2c6779675a01 163 if ((uamqp_map = amqpvalue_create_map()) == NULL)
AzureIoTClient 23:2c6779675a01 164 {
AzureIoTClient 23:2c6779675a01 165 // Codes_SRS_UAMQP_MESSAGING_09_087: [If amqpvalue_create_map() fails, message_create_from_iothub_message() shall fail and return immediately.]
AzureIoTClient 23:2c6779675a01 166 LogError("Failed to create uAMQP map for the properties.");
AzureIoTClient 29:7e8852b14e3b 167 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 168 }
AzureIoTClient 23:2c6779675a01 169 else
AzureIoTClient 23:2c6779675a01 170 {
AzureIoTClient 23:2c6779675a01 171 for (i = 0; result == RESULT_OK && i < propertyCount; i++)
AzureIoTClient 23:2c6779675a01 172 {
AzureIoTClient 23:2c6779675a01 173 AMQP_VALUE map_key_value = NULL;
AzureIoTClient 23:2c6779675a01 174 AMQP_VALUE map_value_value = NULL;
AzureIoTClient 23:2c6779675a01 175
AzureIoTClient 23:2c6779675a01 176 // Codes_SRS_UAMQP_MESSAGING_09_088: [An AMQP_VALUE instance shall be created using amqpvalue_create_string() to hold each uAMQP property name.]
AzureIoTClient 23:2c6779675a01 177 if ((map_key_value = amqpvalue_create_string(propertyKeys[i])) == NULL)
AzureIoTClient 23:2c6779675a01 178 {
AzureIoTClient 23:2c6779675a01 179 // Codes_SRS_UAMQP_MESSAGING_09_089: [If amqpvalue_create_string() fails, message_create_from_iothub_message() shall fail and return immediately..]
AzureIoTClient 23:2c6779675a01 180 LogError("Failed to create uAMQP property key name.");
AzureIoTClient 29:7e8852b14e3b 181 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 182 }
AzureIoTClient 23:2c6779675a01 183 // Codes_SRS_UAMQP_MESSAGING_09_090: [An AMQP_VALUE instance shall be created using amqpvalue_create_string() to hold each uAMQP property value.]
AzureIoTClient 23:2c6779675a01 184 else if ((map_value_value = amqpvalue_create_string(propertyValues[i])) == NULL)
AzureIoTClient 23:2c6779675a01 185 {
AzureIoTClient 23:2c6779675a01 186 // Codes_SRS_UAMQP_MESSAGING_09_091: [If amqpvalue_create_string() fails, message_create_from_iothub_message() shall fail and return immediately..]
AzureIoTClient 23:2c6779675a01 187 LogError("Failed to create uAMQP property key value.");
AzureIoTClient 29:7e8852b14e3b 188 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 189 }
AzureIoTClient 23:2c6779675a01 190 // Codes_SRS_UAMQP_MESSAGING_09_092: [The property name and value (AMQP_VALUE instances) shall be added to the uAMQP property map by calling amqpvalue_map_set_value().]
AzureIoTClient 23:2c6779675a01 191 else if (amqpvalue_set_map_value(uamqp_map, map_key_value, map_value_value) != 0)
AzureIoTClient 23:2c6779675a01 192 {
AzureIoTClient 23:2c6779675a01 193 // Codes_SRS_UAMQP_MESSAGING_09_093: [If amqpvalue_map_set_value() fails, message_create_from_iothub_message() shall fail and return immediately..]
AzureIoTClient 23:2c6779675a01 194 LogError("Failed to set key/value into the the uAMQP property map.");
AzureIoTClient 29:7e8852b14e3b 195 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 196 }
AzureIoTClient 23:2c6779675a01 197
AzureIoTClient 23:2c6779675a01 198 // Codes_SRS_UAMQP_MESSAGING_09_094: [After adding the property name and value to the uAMQP property map, both AMQP_VALUE instances shall be destroyed using amqpvalue_destroy().]
AzureIoTClient 23:2c6779675a01 199 if (map_key_value != NULL)
AzureIoTClient 23:2c6779675a01 200 amqpvalue_destroy(map_key_value);
AzureIoTClient 23:2c6779675a01 201
AzureIoTClient 23:2c6779675a01 202 if (map_value_value != NULL)
AzureIoTClient 23:2c6779675a01 203 amqpvalue_destroy(map_value_value);
AzureIoTClient 23:2c6779675a01 204 }
AzureIoTClient 23:2c6779675a01 205
AzureIoTClient 23:2c6779675a01 206 if (result == RESULT_OK)
AzureIoTClient 23:2c6779675a01 207 {
AzureIoTClient 23:2c6779675a01 208 // Codes_SRS_UAMQP_MESSAGING_09_095: [If no errors occurred processing the properties, the uAMQP properties map shall be set on the uAMQP message by calling message_set_application_properties().]
AzureIoTClient 23:2c6779675a01 209 if (message_set_application_properties(uamqp_message, uamqp_map) != 0)
AzureIoTClient 23:2c6779675a01 210 {
AzureIoTClient 23:2c6779675a01 211 // Codes_SRS_UAMQP_MESSAGING_09_096: [If message_set_application_properties() fails, message_create_from_iothub_message() shall fail and return immediately..]
AzureIoTClient 23:2c6779675a01 212 LogError("Failed to transfer the message properties to the uAMQP message.");
AzureIoTClient 29:7e8852b14e3b 213 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 214 }
AzureIoTClient 23:2c6779675a01 215 else
AzureIoTClient 23:2c6779675a01 216 {
AzureIoTClient 23:2c6779675a01 217 result = RESULT_OK;
AzureIoTClient 23:2c6779675a01 218 }
AzureIoTClient 23:2c6779675a01 219 }
AzureIoTClient 23:2c6779675a01 220
AzureIoTClient 23:2c6779675a01 221 // Codes_SRS_UAMQP_MESSAGING_09_097: [The uAMQP properties map shall be destroyed using amqpvalue_destroy().]
AzureIoTClient 23:2c6779675a01 222 amqpvalue_destroy(uamqp_map);
AzureIoTClient 23:2c6779675a01 223 }
AzureIoTClient 23:2c6779675a01 224 }
AzureIoTClient 23:2c6779675a01 225 else
AzureIoTClient 23:2c6779675a01 226 {
AzureIoTClient 23:2c6779675a01 227 // Codes_SRS_UAMQP_MESSAGING_09_084: [If the number of properties is 0, no application properties shall be set on the uAMQP message and message_create_from_iothub_message() shall return with success.]
AzureIoTClient 23:2c6779675a01 228 result = RESULT_OK;
AzureIoTClient 23:2c6779675a01 229 }
AzureIoTClient 23:2c6779675a01 230 }
AzureIoTClient 23:2c6779675a01 231
AzureIoTClient 23:2c6779675a01 232 return result;
AzureIoTClient 23:2c6779675a01 233 }
AzureIoTClient 23:2c6779675a01 234
AzureIoTClient 23:2c6779675a01 235 static int readPropertiesFromuAMQPMessage(IOTHUB_MESSAGE_HANDLE iothub_message_handle, MESSAGE_HANDLE uamqp_message)
AzureIoTClient 23:2c6779675a01 236 {
AzureIoTClient 23:2c6779675a01 237 int return_value;
AzureIoTClient 23:2c6779675a01 238 PROPERTIES_HANDLE uamqp_message_properties;
AzureIoTClient 23:2c6779675a01 239 AMQP_VALUE uamqp_message_property;
AzureIoTClient 23:2c6779675a01 240 const char* uamqp_message_property_value;
AzureIoTClient 23:2c6779675a01 241 int api_call_result;
AzureIoTClient 23:2c6779675a01 242
AzureIoTClient 23:2c6779675a01 243 // Codes_SRS_UAMQP_MESSAGING_09_008: [The uAMQP message properties shall be retrieved using message_get_properties().]
AzureIoTClient 23:2c6779675a01 244 if ((api_call_result = message_get_properties(uamqp_message, &uamqp_message_properties)) != 0)
AzureIoTClient 23:2c6779675a01 245 {
AzureIoTClient 23:2c6779675a01 246 // Codes_SRS_UAMQP_MESSAGING_09_009: [If message_get_properties() fails, IoTHubMessage_CreateFromuAMQPMessage shall fail and return immediately.]
AzureIoTClient 23:2c6779675a01 247 LogError("Failed to get property properties map from uAMQP message (error code %d).", api_call_result);
AzureIoTClient 29:7e8852b14e3b 248 return_value = __FAILURE__;
AzureIoTClient 23:2c6779675a01 249 }
AzureIoTClient 40:e79ee1341949 250 else
AzureIoTClient 40:e79ee1341949 251 {
AzureIoTClient 40:e79ee1341949 252 return_value = 0; // Properties 'message-id' and 'correlation-id' are optional according to the AMQP 1.0 spec.
AzureIoTClient 40:e79ee1341949 253
AzureIoTClient 40:e79ee1341949 254 // 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 255 if ((api_call_result = properties_get_message_id(uamqp_message_properties, &uamqp_message_property)) != 0)
AzureIoTClient 40:e79ee1341949 256 {
AzureIoTClient 40:e79ee1341949 257 // Codes_SRS_UAMQP_MESSAGING_09_011: [If properties_get_message_id fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.]
AzureIoTClient 40:e79ee1341949 258 LogInfo("Failed to get value of uAMQP message 'message-id' property (%d). No failure, since it is optional.", api_call_result);
AzureIoTClient 40:e79ee1341949 259 }
AzureIoTClient 40:e79ee1341949 260 // Codes_SRS_UAMQP_MESSAGING_09_012: [The type of the message-id property value shall be obtained using amqpvalue_get_type().]
AzureIoTClient 40:e79ee1341949 261 // Codes_SRS_UAMQP_MESSAGING_09_013: [If the type of the message-id property value is AMQP_TYPE_NULL, IoTHubMessage_CreateFromuAMQPMessage() shall skip processing the message-id (as it is optional) and continue normally.]
AzureIoTClient 40:e79ee1341949 262 else if (amqpvalue_get_type(uamqp_message_property) != AMQP_TYPE_NULL)
AzureIoTClient 40:e79ee1341949 263 {
AzureIoTClient 40:e79ee1341949 264 // 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 265 if ((api_call_result = amqpvalue_get_string(uamqp_message_property, &uamqp_message_property_value)) != 0)
AzureIoTClient 40:e79ee1341949 266 {
AzureIoTClient 40:e79ee1341949 267 // Codes_SRS_UAMQP_MESSAGING_09_015: [If amqpvalue_get_string fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.]
AzureIoTClient 40:e79ee1341949 268 LogError("Failed to get value of uAMQP message 'message-id' property (%d).", api_call_result);
AzureIoTClient 40:e79ee1341949 269 return_value = __FAILURE__;
AzureIoTClient 40:e79ee1341949 270 }
AzureIoTClient 40:e79ee1341949 271 // 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 272 else if (IoTHubMessage_SetMessageId(iothub_message_handle, uamqp_message_property_value) != IOTHUB_MESSAGE_OK)
AzureIoTClient 40:e79ee1341949 273 {
AzureIoTClient 40:e79ee1341949 274 // Codes_SRS_UAMQP_MESSAGING_09_017: [If IoTHubMessage_SetMessageId fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.]
AzureIoTClient 40:e79ee1341949 275 LogError("Failed to set IOTHUB_MESSAGE_HANDLE 'message-id' property.");
AzureIoTClient 40:e79ee1341949 276 return_value = __FAILURE__;
AzureIoTClient 40:e79ee1341949 277 }
AzureIoTClient 40:e79ee1341949 278 }
AzureIoTClient 23:2c6779675a01 279
AzureIoTClient 40:e79ee1341949 280 // 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 281 if ((api_call_result = properties_get_correlation_id(uamqp_message_properties, &uamqp_message_property)) != 0)
AzureIoTClient 40:e79ee1341949 282 {
AzureIoTClient 40:e79ee1341949 283 // Codes_SRS_UAMQP_MESSAGING_09_019: [If properties_get_correlation_id() fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.]
AzureIoTClient 40:e79ee1341949 284 LogError("Failed to get value of uAMQP message 'correlation-id' property (%d). No failure, since it is optional.", api_call_result);
AzureIoTClient 40:e79ee1341949 285 }
AzureIoTClient 40:e79ee1341949 286 // Codes_SRS_UAMQP_MESSAGING_09_020: [The type of the correlation-id property value shall be obtained using amqpvalue_get_type().]
AzureIoTClient 40:e79ee1341949 287 // 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 40:e79ee1341949 288 else if (amqpvalue_get_type(uamqp_message_property) != AMQP_TYPE_NULL)
AzureIoTClient 40:e79ee1341949 289 {
AzureIoTClient 40:e79ee1341949 290 // 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 291 if ((api_call_result = amqpvalue_get_string(uamqp_message_property, &uamqp_message_property_value)) != 0)
AzureIoTClient 40:e79ee1341949 292 {
AzureIoTClient 40:e79ee1341949 293 // Codes_SRS_UAMQP_MESSAGING_09_023: [If amqpvalue_get_string fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.]
AzureIoTClient 40:e79ee1341949 294 LogError("Failed to get value of uAMQP message 'correlation-id' property (%d).", api_call_result);
AzureIoTClient 40:e79ee1341949 295 return_value = __FAILURE__;
AzureIoTClient 40:e79ee1341949 296 }
AzureIoTClient 40:e79ee1341949 297 // 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 298 else if (IoTHubMessage_SetCorrelationId(iothub_message_handle, uamqp_message_property_value) != IOTHUB_MESSAGE_OK)
AzureIoTClient 40:e79ee1341949 299 {
AzureIoTClient 40:e79ee1341949 300 // Codes_SRS_UAMQP_MESSAGING_09_025: [If IoTHubMessage_SetCorrelationId fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.]
AzureIoTClient 40:e79ee1341949 301 LogError("Failed to set IOTHUB_MESSAGE_HANDLE 'correlation-id' property.");
AzureIoTClient 40:e79ee1341949 302 return_value = __FAILURE__;
AzureIoTClient 40:e79ee1341949 303 }
AzureIoTClient 40:e79ee1341949 304 }
AzureIoTClient 23:2c6779675a01 305
AzureIoTClient 40:e79ee1341949 306 uamqp_message_property_value = NULL;
AzureIoTClient 40:e79ee1341949 307
AzureIoTClient 40:e79ee1341949 308 // Codes_SRS_UAMQP_MESSAGING_09_100: [If the uamqp message contains property `content-type`, it shall be set on IOTHUB_MESSAGE_HANDLE]
AzureIoTClient 40:e79ee1341949 309 if (properties_get_content_type(uamqp_message_properties, &uamqp_message_property_value) == 0 && uamqp_message_property_value != NULL)
AzureIoTClient 40:e79ee1341949 310 {
AzureIoTClient 40:e79ee1341949 311 if (IoTHubMessage_SetContentTypeSystemProperty(iothub_message_handle, uamqp_message_property_value) != IOTHUB_MESSAGE_OK)
AzureIoTClient 40:e79ee1341949 312 {
AzureIoTClient 40:e79ee1341949 313 // Codes_SRS_UAMQP_MESSAGING_09_102: [If setting the `content-type` property on IOTHUB_MESSAGE_HANDLE fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.]
AzureIoTClient 40:e79ee1341949 314 LogError("Failed to set IOTHUB_MESSAGE_HANDLE 'content-type' property.");
AzureIoTClient 40:e79ee1341949 315 return_value = __FAILURE__;
AzureIoTClient 40:e79ee1341949 316 }
AzureIoTClient 40:e79ee1341949 317 }
AzureIoTClient 40:e79ee1341949 318
AzureIoTClient 40:e79ee1341949 319 uamqp_message_property_value = NULL;
AzureIoTClient 40:e79ee1341949 320
AzureIoTClient 40:e79ee1341949 321 // Codes_SRS_UAMQP_MESSAGING_09_103: [If the uAMQP message contains property `content-encoding`, it shall be set on IOTHUB_MESSAGE_HANDLE]
AzureIoTClient 40:e79ee1341949 322 if (properties_get_content_encoding(uamqp_message_properties, &uamqp_message_property_value) == 0 && uamqp_message_property_value != NULL)
AzureIoTClient 40:e79ee1341949 323 {
AzureIoTClient 40:e79ee1341949 324 if (IoTHubMessage_SetContentEncodingSystemProperty(iothub_message_handle, uamqp_message_property_value) != IOTHUB_MESSAGE_OK)
AzureIoTClient 40:e79ee1341949 325 {
AzureIoTClient 40:e79ee1341949 326 // Codes_SRS_UAMQP_MESSAGING_09_105: [If setting the `content-encoding` property on IOTHUB_MESSAGE_HANDLE fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.]
AzureIoTClient 40:e79ee1341949 327 LogError("Failed to set IOTHUB_MESSAGE_HANDLE 'content-encoding' property.");
AzureIoTClient 40:e79ee1341949 328 return_value = __FAILURE__;
AzureIoTClient 40:e79ee1341949 329 }
AzureIoTClient 40:e79ee1341949 330 }
AzureIoTClient 40:e79ee1341949 331
AzureIoTClient 23:2c6779675a01 332 // Codes_SRS_UAMQP_MESSAGING_09_026: [IoTHubMessage_CreateFromuAMQPMessage() shall destroy the uAMQP message properties (obtained with message_get_properties()) by calling properties_destroy().]
AzureIoTClient 23:2c6779675a01 333 properties_destroy(uamqp_message_properties);
AzureIoTClient 23:2c6779675a01 334 }
AzureIoTClient 23:2c6779675a01 335
AzureIoTClient 23:2c6779675a01 336 return return_value;
AzureIoTClient 23:2c6779675a01 337 }
AzureIoTClient 23:2c6779675a01 338
AzureIoTClient 23:2c6779675a01 339 static int readApplicationPropertiesFromuAMQPMessage(IOTHUB_MESSAGE_HANDLE iothub_message_handle, MESSAGE_HANDLE uamqp_message)
AzureIoTClient 23:2c6779675a01 340 {
AzureIoTClient 23:2c6779675a01 341 int result;
AzureIoTClient 23:2c6779675a01 342 AMQP_VALUE uamqp_app_properties = NULL;
AzureIoTClient 23:2c6779675a01 343 AMQP_VALUE uamqp_app_properties_ipdv = NULL;
AzureIoTClient 23:2c6779675a01 344 uint32_t property_count = 0;
AzureIoTClient 23:2c6779675a01 345 MAP_HANDLE iothub_message_properties_map;
AzureIoTClient 23:2c6779675a01 346
AzureIoTClient 23:2c6779675a01 347 // Codes_SRS_UAMQP_MESSAGING_09_027: [The IOTHUB_MESSAGE_HANDLE properties shall be retrieved using IoTHubMessage_Properties.]
AzureIoTClient 23:2c6779675a01 348 if ((iothub_message_properties_map = IoTHubMessage_Properties(iothub_message_handle)) == NULL)
AzureIoTClient 23:2c6779675a01 349 {
AzureIoTClient 23:2c6779675a01 350 // Codes_SRS_UAMQP_MESSAGING_09_028: [If IoTHubMessage_Properties fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.]
AzureIoTClient 23:2c6779675a01 351 LogError("Failed to get property map from IoTHub message.");
AzureIoTClient 29:7e8852b14e3b 352 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 353 }
AzureIoTClient 23:2c6779675a01 354 // Codes_SRS_UAMQP_MESSAGING_09_029: [The uAMQP message application properties shall be retrieved using message_get_application_properties.]
AzureIoTClient 23:2c6779675a01 355 else if ((result = message_get_application_properties(uamqp_message, &uamqp_app_properties)) != 0)
AzureIoTClient 23:2c6779675a01 356 {
AzureIoTClient 23:2c6779675a01 357 // Codes_SRS_UAMQP_MESSAGING_09_030: [If message_get_application_properties fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.]
AzureIoTClient 23:2c6779675a01 358 LogError("Failed reading the incoming uAMQP message properties (return code %d).", result);
AzureIoTClient 29:7e8852b14e3b 359 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 360 }
AzureIoTClient 23:2c6779675a01 361 else
AzureIoTClient 23:2c6779675a01 362 {
AzureIoTClient 23:2c6779675a01 363 // Codes_SRS_UAMQP_MESSAGING_09_031: [If message_get_application_properties succeeds but returns a NULL application properties map (there are no properties), IoTHubMessage_CreateFromuAMQPMessage() shall skip processing the properties and continue normally.]
AzureIoTClient 23:2c6779675a01 364 if (uamqp_app_properties == NULL)
AzureIoTClient 23:2c6779675a01 365 {
AzureIoTClient 23:2c6779675a01 366 result = 0;
AzureIoTClient 23:2c6779675a01 367 }
AzureIoTClient 23:2c6779675a01 368 else
AzureIoTClient 23:2c6779675a01 369 {
AzureIoTClient 23:2c6779675a01 370 // 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 23:2c6779675a01 371 if ((uamqp_app_properties_ipdv = amqpvalue_get_inplace_described_value(uamqp_app_properties)) == NULL)
AzureIoTClient 23:2c6779675a01 372 {
AzureIoTClient 23:2c6779675a01 373 // Codes_SRS_UAMQP_MESSAGING_09_033: [If amqpvalue_get_inplace_described_value fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.]
AzureIoTClient 23:2c6779675a01 374 LogError("Failed getting the map of uAMQP message application properties (return code %d).", result);
AzureIoTClient 29:7e8852b14e3b 375 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 376 }
AzureIoTClient 23:2c6779675a01 377 // 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 23:2c6779675a01 378 else if ((result = amqpvalue_get_map_pair_count(uamqp_app_properties_ipdv, &property_count)) != 0)
AzureIoTClient 23:2c6779675a01 379 {
AzureIoTClient 23:2c6779675a01 380 // Codes_SRS_UAMQP_MESSAGING_09_035: [If amqpvalue_get_map_pair_count fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.]
AzureIoTClient 23:2c6779675a01 381 LogError("Failed reading the number of values in the uAMQP property map (return code %d).", result);
AzureIoTClient 29:7e8852b14e3b 382 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 383 }
AzureIoTClient 23:2c6779675a01 384 else
AzureIoTClient 23:2c6779675a01 385 {
AzureIoTClient 23:2c6779675a01 386 // Codes_SRS_UAMQP_MESSAGING_09_036: [IoTHubMessage_CreateFromuAMQPMessage() shall iterate through each uAMQP application property and add it to IOTHUB_MESSAGE_HANDLE properties.]
AzureIoTClient 23:2c6779675a01 387 uint32_t i;
AzureIoTClient 23:2c6779675a01 388 for (i = 0; result == RESULT_OK && i < property_count; i++)
AzureIoTClient 23:2c6779675a01 389 {
AzureIoTClient 23:2c6779675a01 390 AMQP_VALUE map_key_name = NULL;
AzureIoTClient 23:2c6779675a01 391 AMQP_VALUE map_key_value = NULL;
AzureIoTClient 23:2c6779675a01 392 const char *key_name;
AzureIoTClient 23:2c6779675a01 393 const char* key_value;
AzureIoTClient 23:2c6779675a01 394
AzureIoTClient 23:2c6779675a01 395 // Codes_SRS_UAMQP_MESSAGING_09_037: [The uAMQP application property name and value shall be obtained using amqpvalue_get_map_key_value_pair.]
AzureIoTClient 23:2c6779675a01 396 if ((result = amqpvalue_get_map_key_value_pair(uamqp_app_properties_ipdv, i, &map_key_name, &map_key_value)) != 0)
AzureIoTClient 23:2c6779675a01 397 {
AzureIoTClient 23:2c6779675a01 398 // Codes_SRS_UAMQP_MESSAGING_09_038: [If amqpvalue_get_map_key_value_pair fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.]
AzureIoTClient 23:2c6779675a01 399 LogError("Failed reading the key/value pair from the uAMQP property map (return code %d).", result);
AzureIoTClient 29:7e8852b14e3b 400 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 401 }
AzureIoTClient 23:2c6779675a01 402
AzureIoTClient 23:2c6779675a01 403 // Codes_SRS_UAMQP_MESSAGING_09_039: [The uAMQP application property name shall be extracted as string using amqpvalue_get_string.]
AzureIoTClient 23:2c6779675a01 404 else if ((result = amqpvalue_get_string(map_key_name, &key_name)) != 0)
AzureIoTClient 23:2c6779675a01 405 {
AzureIoTClient 23:2c6779675a01 406 // Codes_SRS_UAMQP_MESSAGING_09_040: [If amqpvalue_get_string fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.]
AzureIoTClient 23:2c6779675a01 407 LogError("Failed parsing the uAMQP property name (return code %d).", result);
AzureIoTClient 29:7e8852b14e3b 408 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 409 }
AzureIoTClient 23:2c6779675a01 410 // Codes_SRS_UAMQP_MESSAGING_09_041: [The uAMQP application property value shall be extracted as string using amqpvalue_get_string.]
AzureIoTClient 23:2c6779675a01 411 else if ((result = amqpvalue_get_string(map_key_value, &key_value)) != 0)
AzureIoTClient 23:2c6779675a01 412 {
AzureIoTClient 23:2c6779675a01 413 // Codes_SRS_UAMQP_MESSAGING_09_042: [If amqpvalue_get_string fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.]
AzureIoTClient 23:2c6779675a01 414 LogError("Failed parsing the uAMQP property value (return code %d).", result);
AzureIoTClient 29:7e8852b14e3b 415 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 416 }
AzureIoTClient 23:2c6779675a01 417 // Codes_SRS_UAMQP_MESSAGING_09_043: [The application property name and value shall be added to IOTHUB_MESSAGE_HANDLE properties using Map_AddOrUpdate.]
AzureIoTClient 23:2c6779675a01 418 else if (Map_AddOrUpdate(iothub_message_properties_map, key_name, key_value) != MAP_OK)
AzureIoTClient 23:2c6779675a01 419 {
AzureIoTClient 23:2c6779675a01 420 // Codes_SRS_UAMQP_MESSAGING_09_044: [If Map_AddOrUpdate fails, IoTHubMessage_CreateFromuAMQPMessage() shall fail and return immediately.]
AzureIoTClient 23:2c6779675a01 421 LogError("Failed to add/update IoTHub message property map.");
AzureIoTClient 29:7e8852b14e3b 422 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 423 }
AzureIoTClient 23:2c6779675a01 424
AzureIoTClient 23:2c6779675a01 425 // Codes_SRS_UAMQP_MESSAGING_09_045: [IoTHubMessage_CreateFromuAMQPMessage() shall destroy the uAMQP message property name and value (obtained with amqpvalue_get_string) by calling amqpvalue_destroy().]
AzureIoTClient 23:2c6779675a01 426 if (map_key_name != NULL)
AzureIoTClient 23:2c6779675a01 427 {
AzureIoTClient 23:2c6779675a01 428 amqpvalue_destroy(map_key_name);
AzureIoTClient 23:2c6779675a01 429 }
AzureIoTClient 23:2c6779675a01 430
AzureIoTClient 23:2c6779675a01 431 if (map_key_value != NULL)
AzureIoTClient 23:2c6779675a01 432 {
AzureIoTClient 23:2c6779675a01 433 amqpvalue_destroy(map_key_value);
AzureIoTClient 23:2c6779675a01 434 }
AzureIoTClient 23:2c6779675a01 435 }
AzureIoTClient 23:2c6779675a01 436 }
AzureIoTClient 23:2c6779675a01 437
AzureIoTClient 23:2c6779675a01 438 // Codes_SRS_UAMQP_MESSAGING_09_046: [IoTHubMessage_CreateFromuAMQPMessage() shall destroy the uAMQP message property (obtained with message_get_application_properties) by calling amqpvalue_destroy().]
AzureIoTClient 23:2c6779675a01 439 amqpvalue_destroy(uamqp_app_properties);
AzureIoTClient 23:2c6779675a01 440 }
AzureIoTClient 23:2c6779675a01 441 }
AzureIoTClient 23:2c6779675a01 442
AzureIoTClient 23:2c6779675a01 443 return result;
AzureIoTClient 23:2c6779675a01 444 }
AzureIoTClient 23:2c6779675a01 445
AzureIoTClient 23:2c6779675a01 446 int IoTHubMessage_CreateFromUamqpMessage(MESSAGE_HANDLE uamqp_message, IOTHUB_MESSAGE_HANDLE* iothubclient_message)
AzureIoTClient 23:2c6779675a01 447 {
AzureIoTClient 29:7e8852b14e3b 448 int result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 449
AzureIoTClient 23:2c6779675a01 450 IOTHUB_MESSAGE_HANDLE iothub_message = NULL;
AzureIoTClient 23:2c6779675a01 451 MESSAGE_BODY_TYPE body_type;
AzureIoTClient 23:2c6779675a01 452
AzureIoTClient 23:2c6779675a01 453 // Codes_SRS_UAMQP_MESSAGING_09_001: [The body type of the uAMQP message shall be retrieved using message_get_body_type().]
AzureIoTClient 23:2c6779675a01 454 if (message_get_body_type(uamqp_message, &body_type) != 0)
AzureIoTClient 23:2c6779675a01 455 {
AzureIoTClient 23:2c6779675a01 456 // Codes_SRS_UAMQP_MESSAGING_09_002: [If message_get_body_type() fails, IoTHubMessage_CreateFromuAMQPMessage shall fail and return immediately.]
AzureIoTClient 23:2c6779675a01 457 LogError("Failed to get the type of the uamqp message.");
AzureIoTClient 29:7e8852b14e3b 458 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 459 }
AzureIoTClient 23:2c6779675a01 460 else
AzureIoTClient 23:2c6779675a01 461 {
AzureIoTClient 23:2c6779675a01 462 // 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 23:2c6779675a01 463 if (body_type == MESSAGE_BODY_TYPE_DATA)
AzureIoTClient 23:2c6779675a01 464 {
AzureIoTClient 23:2c6779675a01 465 // Codes_SRS_UAMQP_MESSAGING_09_004: [The uAMQP message body data shall be retrieved using message_get_body_amqp_data().]
AzureIoTClient 23:2c6779675a01 466 BINARY_DATA binary_data;
AzureIoTClient 34:51d158b409d2 467 if (message_get_body_amqp_data_in_place(uamqp_message, 0, &binary_data) != 0)
AzureIoTClient 23:2c6779675a01 468 {
AzureIoTClient 23:2c6779675a01 469 // Codes_SRS_UAMQP_MESSAGING_09_005: [If message_get_body_amqp_data() fails, IoTHubMessage_CreateFromuAMQPMessage shall fail and return immediately.]
AzureIoTClient 23:2c6779675a01 470 LogError("Failed to get the body of the uamqp message.");
AzureIoTClient 29:7e8852b14e3b 471 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 472 }
AzureIoTClient 23:2c6779675a01 473 // Codes_SRS_UAMQP_MESSAGING_09_006: [The IOTHUB_MESSAGE instance shall be created using IoTHubMessage_CreateFromByteArray(), passing the uAMQP body bytes as parameter.]
AzureIoTClient 23:2c6779675a01 474 else if ((iothub_message = IoTHubMessage_CreateFromByteArray(binary_data.bytes, binary_data.length)) == NULL)
AzureIoTClient 23:2c6779675a01 475 {
AzureIoTClient 23:2c6779675a01 476 // Codes_SRS_UAMQP_MESSAGING_09_007: [If IoTHubMessage_CreateFromByteArray() fails, IoTHubMessage_CreateFromuAMQPMessage shall fail and return immediately.]
AzureIoTClient 23:2c6779675a01 477 LogError("Failed creating the IOTHUB_MESSAGE_HANDLE instance (IoTHubMessage_CreateFromByteArray failed).");
AzureIoTClient 29:7e8852b14e3b 478 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 479 }
AzureIoTClient 23:2c6779675a01 480 }
AzureIoTClient 23:2c6779675a01 481 }
AzureIoTClient 23:2c6779675a01 482
AzureIoTClient 23:2c6779675a01 483 if (iothub_message != NULL)
AzureIoTClient 23:2c6779675a01 484 {
AzureIoTClient 23:2c6779675a01 485 if (readPropertiesFromuAMQPMessage(iothub_message, uamqp_message) != RESULT_OK)
AzureIoTClient 23:2c6779675a01 486 {
AzureIoTClient 23:2c6779675a01 487 LogError("Failed reading properties of the uamqp message.");
AzureIoTClient 23:2c6779675a01 488 IoTHubMessage_Destroy(iothub_message);
AzureIoTClient 29:7e8852b14e3b 489 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 490 }
AzureIoTClient 23:2c6779675a01 491 else if (readApplicationPropertiesFromuAMQPMessage(iothub_message, uamqp_message) != RESULT_OK)
AzureIoTClient 23:2c6779675a01 492 {
AzureIoTClient 23:2c6779675a01 493 LogError("Failed reading application properties of the uamqp message.");
AzureIoTClient 23:2c6779675a01 494 IoTHubMessage_Destroy(iothub_message);
AzureIoTClient 29:7e8852b14e3b 495 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 496 }
AzureIoTClient 23:2c6779675a01 497 else
AzureIoTClient 23:2c6779675a01 498 {
AzureIoTClient 23:2c6779675a01 499 *iothubclient_message = iothub_message;
AzureIoTClient 23:2c6779675a01 500 result = RESULT_OK;
AzureIoTClient 23:2c6779675a01 501 }
AzureIoTClient 23:2c6779675a01 502 }
AzureIoTClient 23:2c6779675a01 503
AzureIoTClient 23:2c6779675a01 504 return result;
AzureIoTClient 23:2c6779675a01 505 }
AzureIoTClient 23:2c6779675a01 506
AzureIoTClient 23:2c6779675a01 507 int message_create_from_iothub_message(IOTHUB_MESSAGE_HANDLE iothub_message, MESSAGE_HANDLE* uamqp_message)
AzureIoTClient 23:2c6779675a01 508 {
AzureIoTClient 29:7e8852b14e3b 509 int result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 510 // Codes_SRS_UAMQP_MESSAGING_09_047: [The content type of the IOTHUB_MESSAGE_HANDLE instance shall be obtained using IoTHubMessage_GetContentType().]
AzureIoTClient 23:2c6779675a01 511 IOTHUBMESSAGE_CONTENT_TYPE contentType = IoTHubMessage_GetContentType(iothub_message);
AzureIoTClient 23:2c6779675a01 512 const char* messageContent = NULL;
AzureIoTClient 23:2c6779675a01 513 size_t messageContentSize = 0;
AzureIoTClient 23:2c6779675a01 514 MESSAGE_HANDLE uamqp_message_tmp = NULL;
AzureIoTClient 23:2c6779675a01 515
AzureIoTClient 23:2c6779675a01 516 // Codes_SRS_UAMQP_MESSAGING_09_048: [If the content type of the IOTHUB_MESSAGE_HANDLE instance is IOTHUBMESSAGE_BYTEARRAY, the content shall be obtained using IoTHubMessage_GetByteArray().]
AzureIoTClient 23:2c6779675a01 517 if (contentType == IOTHUBMESSAGE_BYTEARRAY &&
AzureIoTClient 23:2c6779675a01 518 IoTHubMessage_GetByteArray(iothub_message, (const unsigned char **)&messageContent, &messageContentSize) != IOTHUB_MESSAGE_OK)
AzureIoTClient 23:2c6779675a01 519 {
AzureIoTClient 23:2c6779675a01 520 // Codes_SRS_UAMQP_MESSAGING_09_049: [If IoTHubMessage_GetByteArray() fails, message_create_from_iothub_message() shall fail and return.]
AzureIoTClient 23:2c6779675a01 521 LogError("Failed getting the BYTE array representation of the IOTHUB_MESSAGE_HANDLE instance.");
AzureIoTClient 29:7e8852b14e3b 522 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 523 }
AzureIoTClient 23:2c6779675a01 524 // Codes_SRS_UAMQP_MESSAGING_09_050: [If the content type of the IOTHUB_MESSAGE_HANDLE instance is IOTHUBMESSAGE_STRING, the content shall be obtained using IoTHubMessage_GetString().]
AzureIoTClient 23:2c6779675a01 525 else if (contentType == IOTHUBMESSAGE_STRING &&
AzureIoTClient 23:2c6779675a01 526 ((messageContent = IoTHubMessage_GetString(iothub_message)) == NULL))
AzureIoTClient 23:2c6779675a01 527 {
AzureIoTClient 23:2c6779675a01 528 // Codes_SRS_UAMQP_MESSAGING_09_051: [If IoTHubMessage_GetString() fails, message_create_from_iothub_message() shall fail and return.]
AzureIoTClient 23:2c6779675a01 529 LogError("Failed getting the STRING representation of the IOTHUB_MESSAGE_HANDLE instance.");
AzureIoTClient 29:7e8852b14e3b 530 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 531 }
AzureIoTClient 23:2c6779675a01 532 // Codes_SRS_UAMQP_MESSAGING_09_052: [If the content type of the IOTHUB_MESSAGE_HANDLE instance is IOTHUBMESSAGE_UNKNOWN, message_create_from_iothub_message() shall fail and return.]
AzureIoTClient 23:2c6779675a01 533 else if (contentType == IOTHUBMESSAGE_UNKNOWN)
AzureIoTClient 23:2c6779675a01 534 {
AzureIoTClient 23:2c6779675a01 535 LogError("Cannot parse IOTHUB_MESSAGE_HANDLE with content type IOTHUBMESSAGE_UNKNOWN.");
AzureIoTClient 29:7e8852b14e3b 536 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 537 }
AzureIoTClient 23:2c6779675a01 538 // Codes_SRS_UAMQP_MESSAGING_09_053: [A uAMQP MESSAGE_HANDLE shall be created using message_create().]
AzureIoTClient 23:2c6779675a01 539 else if ((uamqp_message_tmp = message_create()) == NULL)
AzureIoTClient 23:2c6779675a01 540 {
AzureIoTClient 23:2c6779675a01 541 // Codes_SRS_UAMQP_MESSAGING_09_054: [If message_create() fails, message_create_from_iothub_message() shall fail and return.]
AzureIoTClient 23:2c6779675a01 542 LogError("Failed allocating the uAMQP message.");
AzureIoTClient 29:7e8852b14e3b 543 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 544 }
AzureIoTClient 23:2c6779675a01 545 else
AzureIoTClient 23:2c6779675a01 546 {
AzureIoTClient 23:2c6779675a01 547 // Codes_SRS_UAMQP_MESSAGING_09_055: [The IOTHUB_MESSAGE instance content bytes and size shall be stored on a BINARY_DATA structure.]
AzureIoTClient 23:2c6779675a01 548 BINARY_DATA binary_data;
AzureIoTClient 23:2c6779675a01 549
AzureIoTClient 23:2c6779675a01 550 if (contentType == IOTHUBMESSAGE_STRING)
AzureIoTClient 23:2c6779675a01 551 {
AzureIoTClient 23:2c6779675a01 552 messageContentSize = strlen(messageContent);
AzureIoTClient 23:2c6779675a01 553 }
AzureIoTClient 23:2c6779675a01 554
AzureIoTClient 23:2c6779675a01 555 binary_data.bytes = (const unsigned char *)messageContent;
AzureIoTClient 23:2c6779675a01 556 binary_data.length = messageContentSize;
AzureIoTClient 23:2c6779675a01 557
AzureIoTClient 23:2c6779675a01 558 // Codes_SRS_UAMQP_MESSAGING_09_056: [The BINARY_DATA instance shall be set as the uAMQP message body using message_add_body_amqp_data().]
AzureIoTClient 23:2c6779675a01 559 if (message_add_body_amqp_data(uamqp_message_tmp, binary_data) != RESULT_OK)
AzureIoTClient 23:2c6779675a01 560 {
AzureIoTClient 23:2c6779675a01 561 // Codes_SRS_UAMQP_MESSAGING_09_057: [If message_add_body_amqp_data() fails, message_create_from_iothub_message() shall fail and return.]
AzureIoTClient 23:2c6779675a01 562 LogError("Failed setting the body of the uAMQP message.");
AzureIoTClient 29:7e8852b14e3b 563 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 564 }
AzureIoTClient 23:2c6779675a01 565 else if (addPropertiesTouAMQPMessage(iothub_message, uamqp_message_tmp) != RESULT_OK)
AzureIoTClient 23:2c6779675a01 566 {
AzureIoTClient 23:2c6779675a01 567 LogError("Failed setting properties of the uAMQP message.");
AzureIoTClient 29:7e8852b14e3b 568 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 569 }
AzureIoTClient 23:2c6779675a01 570 else if (addApplicationPropertiesTouAMQPMessage(iothub_message, uamqp_message_tmp) != RESULT_OK)
AzureIoTClient 23:2c6779675a01 571 {
AzureIoTClient 23:2c6779675a01 572 LogError("Failed setting application properties of the uAMQP message.");
AzureIoTClient 29:7e8852b14e3b 573 result = __FAILURE__;
AzureIoTClient 23:2c6779675a01 574 }
AzureIoTClient 23:2c6779675a01 575 else
AzureIoTClient 23:2c6779675a01 576 {
AzureIoTClient 23:2c6779675a01 577 // Codes_SRS_UAMQP_MESSAGING_09_058: [The uAMQP message created by message_create_from_iothub_message() shall be returned only if no failures occurr.]
AzureIoTClient 23:2c6779675a01 578 *uamqp_message = uamqp_message_tmp;
AzureIoTClient 23:2c6779675a01 579 // Codes_SRS_UAMQP_MESSAGING_09_098: [If no errors occurr, message_create_from_iothub_message() shall return 0 (success).]
AzureIoTClient 23:2c6779675a01 580 result = RESULT_OK;
AzureIoTClient 23:2c6779675a01 581 }
AzureIoTClient 23:2c6779675a01 582 // Codes_SRS_UAMQP_MESSAGING_09_059: [If message_create_from_iothub_message() fails, the uAMQP message (created with message_create()) shall be destroyed.]
AzureIoTClient 23:2c6779675a01 583 if (result != RESULT_OK)
AzureIoTClient 23:2c6779675a01 584 {
AzureIoTClient 23:2c6779675a01 585 message_destroy(uamqp_message_tmp);
AzureIoTClient 23:2c6779675a01 586 }
AzureIoTClient 23:2c6779675a01 587 }
AzureIoTClient 23:2c6779675a01 588
AzureIoTClient 23:2c6779675a01 589 return result;
AzureIoTClient 23:2c6779675a01 590 }