iothub_mqtt_transport - Microsoft Azure IoTHub client MQTT transport

Users » AzureIoTClient » Code » iothub_mqtt_transport

Microsoft Azure IoTHub client MQTT transport

Dependents: STM32F746_iothub_client_sample_mqtt FXOS8700CQ_To_Azure_IoT f767zi_mqtt FXOS8700CQ_To_Azure_IoT ... more

iothubtransport_mqtt_common.c@22:07fec4d325b6, 2017-05-08 (annotated)

Committer:: AzureIoTClient
Date:: Mon May 08 10:50:18 2017 -0700
Revision:: 22:07fec4d325b6
Parent:: 21:167f8fcf6fb1
Child:: 23:84f4c36da8c1

1.1.14

Who changed what in which revision?

User	Revision	Line number	New contents of line
AzureIoTClient	11:31ebaeb51e1e	1	// Copyright (c) Microsoft. All rights reserved.
AzureIoTClient	11:31ebaeb51e1e	2	// Licensed under the MIT license. See LICENSE file in the project root for full license information.
AzureIoTClient	11:31ebaeb51e1e	3
AzureIoTClient	11:31ebaeb51e1e	4	#include <stdlib.h>
AzureIoTClient	12:658ca6865de2	5	#include <ctype.h>
AzureIoTClient	18:ec8e5e97c6a4	6	#include "azure_c_shared_utility/optimize_size.h"
AzureIoTClient	11:31ebaeb51e1e	7	#include "azure_c_shared_utility/gballoc.h"
AzureIoTClient	11:31ebaeb51e1e	8
AzureIoTClient	11:31ebaeb51e1e	9	#include "azure_c_shared_utility/xlogging.h"
AzureIoTClient	11:31ebaeb51e1e	10	#include "azure_c_shared_utility/strings.h"
AzureIoTClient	11:31ebaeb51e1e	11	#include "azure_c_shared_utility/doublylinkedlist.h"
AzureIoTClient	11:31ebaeb51e1e	12	#include "azure_c_shared_utility/crt_abstractions.h"
AzureIoTClient	11:31ebaeb51e1e	13
AzureIoTClient	11:31ebaeb51e1e	14	#include "iothub_client_ll.h"
AzureIoTClient	11:31ebaeb51e1e	15	#include "iothub_client_options.h"
AzureIoTClient	11:31ebaeb51e1e	16	#include "iothub_client_private.h"
AzureIoTClient	11:31ebaeb51e1e	17	#include "azure_umqtt_c/mqtt_client.h"
AzureIoTClient	11:31ebaeb51e1e	18	#include "azure_c_shared_utility/sastoken.h"
AzureIoTClient	11:31ebaeb51e1e	19	#include "azure_c_shared_utility/tickcounter.h"
AzureIoTClient	11:31ebaeb51e1e	20
AzureIoTClient	11:31ebaeb51e1e	21	#include "azure_c_shared_utility/tlsio.h"
AzureIoTClient	11:31ebaeb51e1e	22	#include "azure_c_shared_utility/platform.h"
AzureIoTClient	11:31ebaeb51e1e	23
AzureIoTClient	11:31ebaeb51e1e	24	#include "azure_c_shared_utility/string_tokenizer.h"
AzureIoTClient	20:594780be216d	25	#include "azure_c_shared_utility/shared_util_options.h"
AzureIoTClient	22:07fec4d325b6	26	#include "azure_c_shared_utility/urlencode.h"
AzureIoTClient	11:31ebaeb51e1e	27	#include "iothub_client_version.h"
AzureIoTClient	11:31ebaeb51e1e	28
AzureIoTClient	11:31ebaeb51e1e	29	#include "iothubtransport_mqtt_common.h"
AzureIoTClient	11:31ebaeb51e1e	30
AzureIoTClient	11:31ebaeb51e1e	31	#include <stdarg.h>
AzureIoTClient	11:31ebaeb51e1e	32	#include <stdio.h>
AzureIoTClient	11:31ebaeb51e1e	33
AzureIoTClient	11:31ebaeb51e1e	34	#include <limits.h>
AzureIoTClient	12:658ca6865de2	35	#include <inttypes.h>
AzureIoTClient	11:31ebaeb51e1e	36
AzureIoTClient	11:31ebaeb51e1e	37	#define SAS_TOKEN_DEFAULT_LIFETIME 3600
AzureIoTClient	11:31ebaeb51e1e	38	#define SAS_REFRESH_MULTIPLIER .8
AzureIoTClient	11:31ebaeb51e1e	39	#define EPOCH_TIME_T_VALUE 0
AzureIoTClient	11:31ebaeb51e1e	40	#define DEFAULT_MQTT_KEEPALIVE 4*60 // 4 min
AzureIoTClient	11:31ebaeb51e1e	41	#define BUILD_CONFIG_USERNAME 24
AzureIoTClient	11:31ebaeb51e1e	42	#define SAS_TOKEN_DEFAULT_LEN 10
AzureIoTClient	11:31ebaeb51e1e	43	#define RESEND_TIMEOUT_VALUE_MIN 1*60
AzureIoTClient	11:31ebaeb51e1e	44	#define MAX_SEND_RECOUNT_LIMIT 2
AzureIoTClient	11:31ebaeb51e1e	45	#define DEFAULT_CONNECTION_INTERVAL 30
AzureIoTClient	11:31ebaeb51e1e	46	#define FAILED_CONN_BACKOFF_VALUE 5
AzureIoTClient	12:658ca6865de2	47	#define STATUS_CODE_FAILURE_VALUE 500
AzureIoTClient	12:658ca6865de2	48	#define STATUS_CODE_TIMEOUT_VALUE 408
AzureIoTClient	17:774695cb8554	49	#define ERROR_TIME_FOR_RETRY_SECS 5 // We won't retry more than once every 5 seconds
AzureIoTClient	12:658ca6865de2	50
AzureIoTClient	12:658ca6865de2	51	static const char TOPIC_DEVICE_TWIN_PREFIX[] = "$iothub/twin";
AzureIoTClient	12:658ca6865de2	52	static const char TOPIC_DEVICE_METHOD_PREFIX[] = "$iothub/methods";
AzureIoTClient	12:658ca6865de2	53
AzureIoTClient	12:658ca6865de2	54	static const char* TOPIC_GET_DESIRED_STATE = "$iothub/twin/res/#";
AzureIoTClient	12:658ca6865de2	55	static const char* TOPIC_NOTIFICATION_STATE = "$iothub/twin/PATCH/properties/desired/#";
AzureIoTClient	11:31ebaeb51e1e	56
AzureIoTClient	11:31ebaeb51e1e	57	static const char* TOPIC_DEVICE_MSG = "devices/%s/messages/devicebound/#";
AzureIoTClient	11:31ebaeb51e1e	58	static const char* TOPIC_DEVICE_DEVICE = "devices/%s/messages/events/";
AzureIoTClient	12:658ca6865de2	59
AzureIoTClient	12:658ca6865de2	60	static const char* TOPIC_DEVICE_METHOD_SUBSCRIBE = "$iothub/methods/POST/#";
AzureIoTClient	12:658ca6865de2	61	static const char* TOPIC_DEVICE_METHOD_RESPONSE = "$iothub/methods/res";
AzureIoTClient	12:658ca6865de2	62
AzureIoTClient	12:658ca6865de2	63	static const char* IOTHUB_API_VERSION = "2016-11-14";
AzureIoTClient	12:658ca6865de2	64
AzureIoTClient	11:31ebaeb51e1e	65	static const char* PROPERTY_SEPARATOR = "&";
AzureIoTClient	12:658ca6865de2	66	static const char* REPORTED_PROPERTIES_TOPIC = "$iothub/twin/PATCH/properties/reported/?$rid=%"PRIu16;
AzureIoTClient	12:658ca6865de2	67	static const char* GET_PROPERTIES_TOPIC = "$iothub/twin/GET/?$rid=%"PRIu16;
AzureIoTClient	14:4dc2b011be33	68	static const char* DEVICE_METHOD_RESPONSE_TOPIC = "$iothub/methods/res/%d/?$rid=%s";
AzureIoTClient	12:658ca6865de2	69
AzureIoTClient	12:658ca6865de2	70	static const char* REQUEST_ID_PROPERTY = "?$rid=";
AzureIoTClient	11:31ebaeb51e1e	71
AzureIoTClient	18:ec8e5e97c6a4	72	static const char* MESSAGE_ID_PROPERTY = "mid";
AzureIoTClient	18:ec8e5e97c6a4	73	static const char* CORRELATION_ID_PROPERTY = "cid";
AzureIoTClient	18:ec8e5e97c6a4	74
AzureIoTClient	11:31ebaeb51e1e	75	#define UNSUBSCRIBE_FROM_TOPIC 0x0000
AzureIoTClient	12:658ca6865de2	76	#define SUBSCRIBE_GET_REPORTED_STATE_TOPIC 0x0001
AzureIoTClient	12:658ca6865de2	77	#define SUBSCRIBE_NOTIFICATION_STATE_TOPIC 0x0002
AzureIoTClient	11:31ebaeb51e1e	78	#define SUBSCRIBE_TELEMETRY_TOPIC 0x0004
AzureIoTClient	12:658ca6865de2	79	#define SUBSCRIBE_METHODS_TOPIC 0x0008
AzureIoTClient	12:658ca6865de2	80	#define SUBSCRIBE_DEVICE_METHOD_TOPIC 0x0010
AzureIoTClient	12:658ca6865de2	81	#define SUBSCRIBE_TOPIC_COUNT 4
AzureIoTClient	11:31ebaeb51e1e	82
AzureIoTClient	17:774695cb8554	83	DEFINE_ENUM_STRINGS(MQTT_CLIENT_EVENT_ERROR, MQTT_CLIENT_EVENT_ERROR_VALUES)
AzureIoTClient	17:774695cb8554	84
AzureIoTClient	11:31ebaeb51e1e	85	typedef struct SYSTEM_PROPERTY_INFO_TAG
AzureIoTClient	11:31ebaeb51e1e	86	{
AzureIoTClient	11:31ebaeb51e1e	87	const char* propName;
AzureIoTClient	11:31ebaeb51e1e	88	size_t propLength;
AzureIoTClient	11:31ebaeb51e1e	89	} SYSTEM_PROPERTY_INFO;
AzureIoTClient	11:31ebaeb51e1e	90
AzureIoTClient	11:31ebaeb51e1e	91	static SYSTEM_PROPERTY_INFO sysPropList[] = {
AzureIoTClient	11:31ebaeb51e1e	92	{ "%24.exp", 7 },
AzureIoTClient	11:31ebaeb51e1e	93	{ "%24.mid", 7 },
AzureIoTClient	11:31ebaeb51e1e	94	{ "%24.uid", 7 },
AzureIoTClient	11:31ebaeb51e1e	95	{ "%24.to", 6 },
AzureIoTClient	11:31ebaeb51e1e	96	{ "%24.cid", 7 },
AzureIoTClient	11:31ebaeb51e1e	97	{ "devices/", 8 },
AzureIoTClient	11:31ebaeb51e1e	98	{ "iothub-operation", 16 },
AzureIoTClient	11:31ebaeb51e1e	99	{ "iothub-ack", 10 }
AzureIoTClient	11:31ebaeb51e1e	100	};
AzureIoTClient	11:31ebaeb51e1e	101
AzureIoTClient	12:658ca6865de2	102	typedef enum DEVICE_TWIN_MSG_TYPE_TAG
AzureIoTClient	12:658ca6865de2	103	{
AzureIoTClient	12:658ca6865de2	104	REPORTED_STATE,
AzureIoTClient	12:658ca6865de2	105	RETRIEVE_PROPERTIES
AzureIoTClient	12:658ca6865de2	106	} DEVICE_TWIN_MSG_TYPE;
AzureIoTClient	12:658ca6865de2	107
AzureIoTClient	11:31ebaeb51e1e	108	typedef enum MQTT_TRANSPORT_CREDENTIAL_TYPE_TAG
AzureIoTClient	11:31ebaeb51e1e	109	{
AzureIoTClient	11:31ebaeb51e1e	110	CREDENTIAL_NOT_BUILD,
AzureIoTClient	11:31ebaeb51e1e	111	X509,
AzureIoTClient	11:31ebaeb51e1e	112	SAS_TOKEN_FROM_USER,
AzureIoTClient	11:31ebaeb51e1e	113	DEVICE_KEY,
AzureIoTClient	11:31ebaeb51e1e	114	} MQTT_TRANSPORT_CREDENTIAL_TYPE;
AzureIoTClient	11:31ebaeb51e1e	115
AzureIoTClient	12:658ca6865de2	116	typedef int(RETRY_POLICY)(bool permit, size_t* delay, void* retryContextCallback);
AzureIoTClient	12:658ca6865de2	117
AzureIoTClient	12:658ca6865de2	118	typedef struct RETRY_LOGIC_TAG
AzureIoTClient	12:658ca6865de2	119	{
AzureIoTClient	17:774695cb8554	120	IOTHUB_CLIENT_RETRY_POLICY retryPolicy; // Type of policy we're using
AzureIoTClient	17:774695cb8554	121	size_t retryTimeoutLimitInSeconds; // If we don't connect in this many seconds, give up even trying.
AzureIoTClient	17:774695cb8554	122	RETRY_POLICY fnRetryPolicy; // Pointer to the policy function
AzureIoTClient	17:774695cb8554	123	time_t start; // When did we start retrying?
AzureIoTClient	17:774695cb8554	124	time_t lastConnect; // When did we last try to connect?
AzureIoTClient	17:774695cb8554	125	bool retryStarted; // true if the retry timer is set and we're trying to retry
AzureIoTClient	17:774695cb8554	126	bool retryExpired; // true if we haven't connected in retryTimeoutLimitInSeconds seconds
AzureIoTClient	17:774695cb8554	127	bool firstAttempt; // true on init so we can connect the first time without waiting for any timeouts.
AzureIoTClient	17:774695cb8554	128	size_t retrycount; // How many times have we tried connecting?
AzureIoTClient	17:774695cb8554	129	size_t delayFromLastConnectToRetry; // last time delta betweewn retry attempts.
AzureIoTClient	12:658ca6865de2	130	} RETRY_LOGIC;
AzureIoTClient	12:658ca6865de2	131
AzureIoTClient	20:594780be216d	132	typedef enum MQTT_CLIENT_STATUS_TAG
AzureIoTClient	20:594780be216d	133	{
AzureIoTClient	21:167f8fcf6fb1	134	MQTT_CLIENT_STATUS_NOT_CONNECTED,
AzureIoTClient	21:167f8fcf6fb1	135	MQTT_CLIENT_STATUS_CONNECTING,
AzureIoTClient	21:167f8fcf6fb1	136	MQTT_CLIENT_STATUS_CONNECTED
AzureIoTClient	20:594780be216d	137	} MQTT_CLIENT_STATUS;
AzureIoTClient	20:594780be216d	138
AzureIoTClient	11:31ebaeb51e1e	139	typedef struct MQTTTRANSPORT_HANDLE_DATA_TAG
AzureIoTClient	11:31ebaeb51e1e	140	{
AzureIoTClient	11:31ebaeb51e1e	141	// Topic control
AzureIoTClient	11:31ebaeb51e1e	142	STRING_HANDLE topic_MqttEvent;
AzureIoTClient	11:31ebaeb51e1e	143	STRING_HANDLE topic_MqttMessage;
AzureIoTClient	12:658ca6865de2	144	STRING_HANDLE topic_GetState;
AzureIoTClient	12:658ca6865de2	145	STRING_HANDLE topic_NotifyState;
AzureIoTClient	12:658ca6865de2	146
AzureIoTClient	12:658ca6865de2	147	STRING_HANDLE topic_DeviceMethods;
AzureIoTClient	11:31ebaeb51e1e	148
AzureIoTClient	11:31ebaeb51e1e	149	uint32_t topics_ToSubscribe;
AzureIoTClient	12:658ca6865de2	150
AzureIoTClient	11:31ebaeb51e1e	151	// Connection related constants
AzureIoTClient	11:31ebaeb51e1e	152	STRING_HANDLE hostAddress;
AzureIoTClient	11:31ebaeb51e1e	153	STRING_HANDLE device_id;
AzureIoTClient	11:31ebaeb51e1e	154	STRING_HANDLE devicesPath;
AzureIoTClient	11:31ebaeb51e1e	155	int portNum;
AzureIoTClient	11:31ebaeb51e1e	156
AzureIoTClient	11:31ebaeb51e1e	157	MQTT_GET_IO_TRANSPORT get_io_transport;
AzureIoTClient	11:31ebaeb51e1e	158
AzureIoTClient	11:31ebaeb51e1e	159	// The current mqtt iothub implementation requires that the hub name and the domain suffix be passed as the first of a series of segments
AzureIoTClient	11:31ebaeb51e1e	160	// passed through the username portion of the connection frame.
AzureIoTClient	11:31ebaeb51e1e	161	// The second segment will contain the device id. The two segments are delemited by a "/".
AzureIoTClient	11:31ebaeb51e1e	162	// The first segment can be a maximum 256 characters.
AzureIoTClient	11:31ebaeb51e1e	163	// The second segment can be a maximum 128 characters.
AzureIoTClient	11:31ebaeb51e1e	164	// With the / delimeter you have 384 chars (Plus a terminator of 0).
AzureIoTClient	11:31ebaeb51e1e	165	STRING_HANDLE configPassedThroughUsername;
AzureIoTClient	11:31ebaeb51e1e	166
AzureIoTClient	11:31ebaeb51e1e	167	// Upper layer
AzureIoTClient	11:31ebaeb51e1e	168	IOTHUB_CLIENT_LL_HANDLE llClientHandle;
AzureIoTClient	11:31ebaeb51e1e	169
AzureIoTClient	11:31ebaeb51e1e	170	// Protocol
AzureIoTClient	11:31ebaeb51e1e	171	MQTT_CLIENT_HANDLE mqttClient;
AzureIoTClient	11:31ebaeb51e1e	172	XIO_HANDLE xioTransport;
AzureIoTClient	11:31ebaeb51e1e	173
AzureIoTClient	11:31ebaeb51e1e	174	// Session - connection
AzureIoTClient	11:31ebaeb51e1e	175	uint16_t packetId;
AzureIoTClient	11:31ebaeb51e1e	176
AzureIoTClient	11:31ebaeb51e1e	177	// Connection state control
AzureIoTClient	11:31ebaeb51e1e	178	bool isRegistered;
AzureIoTClient	20:594780be216d	179	MQTT_CLIENT_STATUS mqttClientStatus;
AzureIoTClient	11:31ebaeb51e1e	180	bool isDestroyCalled;
AzureIoTClient	12:658ca6865de2	181	bool device_twin_get_sent;
AzureIoTClient	12:658ca6865de2	182	bool isRecoverableError;
AzureIoTClient	11:31ebaeb51e1e	183	uint16_t keepAliveValue;
Azure.IoT.Build	13:606465879c57	184	tickcounter_ms_t mqtt_connect_time;
AzureIoTClient	11:31ebaeb51e1e	185	size_t connectFailCount;
Azure.IoT.Build	13:606465879c57	186	tickcounter_ms_t connectTick;
AzureIoTClient	11:31ebaeb51e1e	187	bool log_trace;
AzureIoTClient	11:31ebaeb51e1e	188	bool raw_trace;
Azure.IoT.Build	13:606465879c57	189	TICK_COUNTER_HANDLE msgTickCounter;
AzureIoTClient	11:31ebaeb51e1e	190
AzureIoTClient	11:31ebaeb51e1e	191	// Internal lists for message tracking
AzureIoTClient	11:31ebaeb51e1e	192	PDLIST_ENTRY waitingToSend;
AzureIoTClient	12:658ca6865de2	193	DLIST_ENTRY ack_waiting_queue;
AzureIoTClient	12:658ca6865de2	194
AzureIoTClient	11:31ebaeb51e1e	195	// Message tracking
AzureIoTClient	11:31ebaeb51e1e	196	CONTROL_PACKET_TYPE currPacketState;
AzureIoTClient	11:31ebaeb51e1e	197
AzureIoTClient	11:31ebaeb51e1e	198	// Telemetry specific
AzureIoTClient	11:31ebaeb51e1e	199	DLIST_ENTRY telemetry_waitingForAck;
AzureIoTClient	12:658ca6865de2	200
AzureIoTClient	12:658ca6865de2	201	//Retry Logic
AzureIoTClient	12:658ca6865de2	202	RETRY_LOGIC* retryLogic;
AzureIoTClient	20:594780be216d	203
AzureIoTClient	21:167f8fcf6fb1	204	// Auth module used to generating handle authorization
AzureIoTClient	21:167f8fcf6fb1	205	// with either SAS Token, x509 Certs, and Device SAS Token
AzureIoTClient	21:167f8fcf6fb1	206	IOTHUB_AUTHORIZATION_HANDLE authorization_module;
AzureIoTClient	21:167f8fcf6fb1	207
AzureIoTClient	20:594780be216d	208	char* http_proxy_hostname;
AzureIoTClient	20:594780be216d	209	int http_proxy_port;
AzureIoTClient	20:594780be216d	210	char* http_proxy_username;
AzureIoTClient	20:594780be216d	211	char* http_proxy_password;
AzureIoTClient	11:31ebaeb51e1e	212	} MQTTTRANSPORT_HANDLE_DATA, *PMQTTTRANSPORT_HANDLE_DATA;
AzureIoTClient	11:31ebaeb51e1e	213
AzureIoTClient	12:658ca6865de2	214	typedef struct MQTT_DEVICE_TWIN_ITEM_TAG
AzureIoTClient	12:658ca6865de2	215	{
Azure.IoT.Build	13:606465879c57	216	tickcounter_ms_t msgPublishTime;
AzureIoTClient	12:658ca6865de2	217	size_t retryCount;
AzureIoTClient	12:658ca6865de2	218	IOTHUB_IDENTITY_TYPE iothub_type;
AzureIoTClient	12:658ca6865de2	219	uint16_t packet_id;
AzureIoTClient	12:658ca6865de2	220	uint32_t iothub_msg_id;
AzureIoTClient	12:658ca6865de2	221	IOTHUB_DEVICE_TWIN* device_twin_data;
AzureIoTClient	12:658ca6865de2	222	DEVICE_TWIN_MSG_TYPE device_twin_msg_type;
AzureIoTClient	12:658ca6865de2	223	DLIST_ENTRY entry;
AzureIoTClient	12:658ca6865de2	224	} MQTT_DEVICE_TWIN_ITEM;
AzureIoTClient	12:658ca6865de2	225
AzureIoTClient	11:31ebaeb51e1e	226	typedef struct MQTT_MESSAGE_DETAILS_LIST_TAG
AzureIoTClient	11:31ebaeb51e1e	227	{
Azure.IoT.Build	13:606465879c57	228	tickcounter_ms_t msgPublishTime;
AzureIoTClient	11:31ebaeb51e1e	229	size_t retryCount;
AzureIoTClient	11:31ebaeb51e1e	230	IOTHUB_MESSAGE_LIST* iotHubMessageEntry;
AzureIoTClient	11:31ebaeb51e1e	231	void* context;
AzureIoTClient	11:31ebaeb51e1e	232	uint16_t packet_id;
AzureIoTClient	11:31ebaeb51e1e	233	DLIST_ENTRY entry;
AzureIoTClient	11:31ebaeb51e1e	234	} MQTT_MESSAGE_DETAILS_LIST, *PMQTT_MESSAGE_DETAILS_LIST;
AzureIoTClient	11:31ebaeb51e1e	235
AzureIoTClient	14:4dc2b011be33	236	typedef struct DEVICE_METHOD_INFO_TAG
AzureIoTClient	14:4dc2b011be33	237	{
AzureIoTClient	14:4dc2b011be33	238	STRING_HANDLE request_id;
AzureIoTClient	14:4dc2b011be33	239	} DEVICE_METHOD_INFO;
AzureIoTClient	14:4dc2b011be33	240
AzureIoTClient	20:594780be216d	241	static void free_proxy_data(MQTTTRANSPORT_HANDLE_DATA* mqtt_transport_instance)
AzureIoTClient	20:594780be216d	242	{
AzureIoTClient	20:594780be216d	243	if (mqtt_transport_instance->http_proxy_hostname != NULL)
AzureIoTClient	20:594780be216d	244	{
AzureIoTClient	20:594780be216d	245	free(mqtt_transport_instance->http_proxy_hostname);
AzureIoTClient	20:594780be216d	246	mqtt_transport_instance->http_proxy_hostname = NULL;
AzureIoTClient	20:594780be216d	247	}
AzureIoTClient	20:594780be216d	248
AzureIoTClient	20:594780be216d	249	if (mqtt_transport_instance->http_proxy_username != NULL)
AzureIoTClient	20:594780be216d	250	{
AzureIoTClient	20:594780be216d	251	free(mqtt_transport_instance->http_proxy_username);
AzureIoTClient	20:594780be216d	252	mqtt_transport_instance->http_proxy_username = NULL;
AzureIoTClient	20:594780be216d	253	}
AzureIoTClient	20:594780be216d	254
AzureIoTClient	20:594780be216d	255	if (mqtt_transport_instance->http_proxy_password != NULL)
AzureIoTClient	20:594780be216d	256	{
AzureIoTClient	20:594780be216d	257	free(mqtt_transport_instance->http_proxy_password);
AzureIoTClient	20:594780be216d	258	mqtt_transport_instance->http_proxy_password = NULL;
AzureIoTClient	20:594780be216d	259	}
AzureIoTClient	20:594780be216d	260	}
AzureIoTClient	20:594780be216d	261
AzureIoTClient	12:658ca6865de2	262	static int RetryPolicy_Exponential_BackOff_With_Jitter(bool permit, size_t delay, void* retryContextCallback)
AzureIoTClient	12:658ca6865de2	263	{
AzureIoTClient	12:658ca6865de2	264	int result;
AzureIoTClient	12:658ca6865de2	265
AzureIoTClient	12:658ca6865de2	266	if (retryContextCallback != NULL && permit != NULL && delay != NULL)
AzureIoTClient	12:658ca6865de2	267	{
AzureIoTClient	12:658ca6865de2	268	RETRY_LOGIC retryLogic = (RETRY_LOGIC)retryContextCallback;
AzureIoTClient	12:658ca6865de2	269	int numOfFailures = (int) retryLogic->retrycount;
AzureIoTClient	12:658ca6865de2	270	*permit = true;
AzureIoTClient	12:658ca6865de2	271
AzureIoTClient	12:658ca6865de2	272	/Intentionally not evaluating fraction of a second as it woudn't work on all platforms/
AzureIoTClient	12:658ca6865de2	273
AzureIoTClient	12:658ca6865de2	274	/* Exponential backoff with jitter
AzureIoTClient	12:658ca6865de2	275	1. delay = (pow(2, attempt) - 1 ) / 2
AzureIoTClient	12:658ca6865de2	276	2. delay with jitter = delay + rand_between(0, delay/2)
AzureIoTClient	12:658ca6865de2	277	*/
AzureIoTClient	12:658ca6865de2	278
AzureIoTClient	12:658ca6865de2	279	size_t halfDelta = ((1 << numOfFailures) - 1) / 4;
AzureIoTClient	12:658ca6865de2	280	if (halfDelta > 0)
AzureIoTClient	12:658ca6865de2	281	{
AzureIoTClient	12:658ca6865de2	282	*delay = halfDelta + (rand() % (int)halfDelta);
AzureIoTClient	12:658ca6865de2	283	}
AzureIoTClient	12:658ca6865de2	284	else
AzureIoTClient	12:658ca6865de2	285	{
AzureIoTClient	12:658ca6865de2	286	*delay = halfDelta;
AzureIoTClient	12:658ca6865de2	287	}
AzureIoTClient	12:658ca6865de2	288
AzureIoTClient	12:658ca6865de2	289	result = 0;
AzureIoTClient	12:658ca6865de2	290	}
AzureIoTClient	12:658ca6865de2	291	else
AzureIoTClient	12:658ca6865de2	292	{
AzureIoTClient	18:ec8e5e97c6a4	293	result = __FAILURE__;
AzureIoTClient	12:658ca6865de2	294	}
AzureIoTClient	12:658ca6865de2	295	return result;
AzureIoTClient	12:658ca6865de2	296	}
AzureIoTClient	12:658ca6865de2	297
AzureIoTClient	12:658ca6865de2	298	static RETRY_LOGIC* CreateRetryLogic(IOTHUB_CLIENT_RETRY_POLICY retryPolicy, size_t retryTimeoutLimitInSeconds)
AzureIoTClient	12:658ca6865de2	299	{
AzureIoTClient	12:658ca6865de2	300	RETRY_LOGIC *retryLogic;
AzureIoTClient	12:658ca6865de2	301	retryLogic = (RETRY_LOGIC*)malloc(sizeof(RETRY_LOGIC));
AzureIoTClient	12:658ca6865de2	302	if (retryLogic != NULL)
AzureIoTClient	12:658ca6865de2	303	{
AzureIoTClient	12:658ca6865de2	304	retryLogic->retryPolicy = retryPolicy;
AzureIoTClient	12:658ca6865de2	305	retryLogic->retryTimeoutLimitInSeconds = retryTimeoutLimitInSeconds;
AzureIoTClient	12:658ca6865de2	306	switch (retryLogic->retryPolicy)
AzureIoTClient	12:658ca6865de2	307	{
AzureIoTClient	12:658ca6865de2	308	case IOTHUB_CLIENT_RETRY_NONE:
AzureIoTClient	12:658ca6865de2	309	LogError("Not implemented chosing default");
AzureIoTClient	12:658ca6865de2	310	retryLogic->fnRetryPolicy = &RetryPolicy_Exponential_BackOff_With_Jitter;
AzureIoTClient	12:658ca6865de2	311	break;
AzureIoTClient	12:658ca6865de2	312	case IOTHUB_CLIENT_RETRY_IMMEDIATE:
AzureIoTClient	12:658ca6865de2	313	LogError("Not implemented chosing default");
AzureIoTClient	12:658ca6865de2	314	retryLogic->fnRetryPolicy = &RetryPolicy_Exponential_BackOff_With_Jitter;
AzureIoTClient	12:658ca6865de2	315	break;
AzureIoTClient	12:658ca6865de2	316	case IOTHUB_CLIENT_RETRY_INTERVAL:
AzureIoTClient	12:658ca6865de2	317	LogError("Not implemented chosing default");
AzureIoTClient	12:658ca6865de2	318	retryLogic->fnRetryPolicy = &RetryPolicy_Exponential_BackOff_With_Jitter;
AzureIoTClient	12:658ca6865de2	319	break;
AzureIoTClient	12:658ca6865de2	320	case IOTHUB_CLIENT_RETRY_LINEAR_BACKOFF:
AzureIoTClient	12:658ca6865de2	321	LogError("Not implemented chosing default");
AzureIoTClient	12:658ca6865de2	322	retryLogic->fnRetryPolicy = &RetryPolicy_Exponential_BackOff_With_Jitter;
AzureIoTClient	12:658ca6865de2	323	break;
AzureIoTClient	12:658ca6865de2	324	case IOTHUB_CLIENT_RETRY_EXPONENTIAL_BACKOFF:
AzureIoTClient	12:658ca6865de2	325	LogError("Not implemented chosing default");
AzureIoTClient	12:658ca6865de2	326	retryLogic->fnRetryPolicy = &RetryPolicy_Exponential_BackOff_With_Jitter;
AzureIoTClient	12:658ca6865de2	327	break;
AzureIoTClient	12:658ca6865de2	328	case IOTHUB_CLIENT_RETRY_RANDOM:
AzureIoTClient	12:658ca6865de2	329	LogError("Not implemented chosing default");
AzureIoTClient	12:658ca6865de2	330	retryLogic->fnRetryPolicy = &RetryPolicy_Exponential_BackOff_With_Jitter;
AzureIoTClient	12:658ca6865de2	331	break;
AzureIoTClient	12:658ca6865de2	332	case IOTHUB_CLIENT_RETRY_EXPONENTIAL_BACKOFF_WITH_JITTER:
AzureIoTClient	12:658ca6865de2	333	default:
AzureIoTClient	12:658ca6865de2	334	retryLogic->fnRetryPolicy = &RetryPolicy_Exponential_BackOff_With_Jitter;
AzureIoTClient	12:658ca6865de2	335	break;
AzureIoTClient	12:658ca6865de2	336	}
AzureIoTClient	12:658ca6865de2	337	retryLogic->start = EPOCH_TIME_T_VALUE;
AzureIoTClient	12:658ca6865de2	338	retryLogic->delayFromLastConnectToRetry = 0;
AzureIoTClient	12:658ca6865de2	339	retryLogic->lastConnect = EPOCH_TIME_T_VALUE;
AzureIoTClient	12:658ca6865de2	340	retryLogic->retryStarted = false;
AzureIoTClient	12:658ca6865de2	341	retryLogic->retryExpired = false;
AzureIoTClient	17:774695cb8554	342	retryLogic->firstAttempt = true;
AzureIoTClient	12:658ca6865de2	343	retryLogic->retrycount = 0;
AzureIoTClient	12:658ca6865de2	344	}
AzureIoTClient	12:658ca6865de2	345	else
AzureIoTClient	12:658ca6865de2	346	{
AzureIoTClient	12:658ca6865de2	347	LogError("Init retry logic failed");
AzureIoTClient	12:658ca6865de2	348	}
AzureIoTClient	12:658ca6865de2	349	return retryLogic;
AzureIoTClient	12:658ca6865de2	350	}
AzureIoTClient	12:658ca6865de2	351
AzureIoTClient	12:658ca6865de2	352	static void DestroyRetryLogic(RETRY_LOGIC *retryLogic)
AzureIoTClient	12:658ca6865de2	353	{
AzureIoTClient	12:658ca6865de2	354	if (retryLogic != NULL)
AzureIoTClient	12:658ca6865de2	355	{
AzureIoTClient	12:658ca6865de2	356	free(retryLogic);
AzureIoTClient	12:658ca6865de2	357	retryLogic = NULL;
AzureIoTClient	12:658ca6865de2	358	}
AzureIoTClient	12:658ca6865de2	359	}
AzureIoTClient	12:658ca6865de2	360
AzureIoTClient	12:658ca6865de2	361	// Called when first attempted to re-connect
AzureIoTClient	12:658ca6865de2	362	static void StartRetryTimer(RETRY_LOGIC *retryLogic)
AzureIoTClient	12:658ca6865de2	363	{
AzureIoTClient	12:658ca6865de2	364	if (retryLogic != NULL)
AzureIoTClient	12:658ca6865de2	365	{
AzureIoTClient	12:658ca6865de2	366	if (retryLogic->retryStarted == false)
AzureIoTClient	12:658ca6865de2	367	{
AzureIoTClient	12:658ca6865de2	368	retryLogic->start = get_time(NULL);
AzureIoTClient	12:658ca6865de2	369	retryLogic->delayFromLastConnectToRetry = 0;
AzureIoTClient	12:658ca6865de2	370	retryLogic->retryStarted = true;
AzureIoTClient	12:658ca6865de2	371	}
AzureIoTClient	12:658ca6865de2	372
AzureIoTClient	21:167f8fcf6fb1	373	retryLogic->firstAttempt = false;
AzureIoTClient	12:658ca6865de2	374	}
AzureIoTClient	12:658ca6865de2	375	else
AzureIoTClient	12:658ca6865de2	376	{
AzureIoTClient	12:658ca6865de2	377	LogError("Retry Logic parameter. NULL.");
AzureIoTClient	12:658ca6865de2	378	}
AzureIoTClient	12:658ca6865de2	379	}
AzureIoTClient	12:658ca6865de2	380
AzureIoTClient	12:658ca6865de2	381	// Called when connected
AzureIoTClient	12:658ca6865de2	382	static void StopRetryTimer(RETRY_LOGIC *retryLogic)
AzureIoTClient	12:658ca6865de2	383	{
AzureIoTClient	12:658ca6865de2	384	if (retryLogic != NULL)
AzureIoTClient	12:658ca6865de2	385	{
AzureIoTClient	12:658ca6865de2	386	if (retryLogic->retryStarted == true)
AzureIoTClient	12:658ca6865de2	387	{
AzureIoTClient	12:658ca6865de2	388	retryLogic->retryStarted = false;
AzureIoTClient	12:658ca6865de2	389	retryLogic->delayFromLastConnectToRetry = 0;
AzureIoTClient	12:658ca6865de2	390	retryLogic->lastConnect = EPOCH_TIME_T_VALUE;
AzureIoTClient	12:658ca6865de2	391	retryLogic->retrycount = 0;
AzureIoTClient	12:658ca6865de2	392	}
AzureIoTClient	12:658ca6865de2	393	else
AzureIoTClient	12:658ca6865de2	394	{
AzureIoTClient	12:658ca6865de2	395	LogError("Start retry logic before stopping");
AzureIoTClient	12:658ca6865de2	396	}
AzureIoTClient	12:658ca6865de2	397	}
AzureIoTClient	12:658ca6865de2	398	else
AzureIoTClient	12:658ca6865de2	399	{
AzureIoTClient	12:658ca6865de2	400	LogError("Retry Logic parameter. NULL.");
AzureIoTClient	12:658ca6865de2	401	}
AzureIoTClient	12:658ca6865de2	402	}
AzureIoTClient	12:658ca6865de2	403
AzureIoTClient	12:658ca6865de2	404	int IoTHubTransport_MQTT_Common_SetRetryPolicy(TRANSPORT_LL_HANDLE handle, IOTHUB_CLIENT_RETRY_POLICY retryPolicy, size_t retryTimeoutLimitInSeconds)
AzureIoTClient	12:658ca6865de2	405	{
AzureIoTClient	12:658ca6865de2	406	int result;
AzureIoTClient	12:658ca6865de2	407	PMQTTTRANSPORT_HANDLE_DATA transport_data = (PMQTTTRANSPORT_HANDLE_DATA)handle;
AzureIoTClient	12:658ca6865de2	408	if (transport_data == NULL)
AzureIoTClient	12:658ca6865de2	409	{
AzureIoTClient	12:658ca6865de2	410	/* Codes_SRS_IOTHUB_TRANSPORT_MQTT_COMMON_25_041: [*If any handle is NULL then IoTHubTransport_MQTT_Common_SetRetryPolicy shall return resultant line.] /
AzureIoTClient	12:658ca6865de2	411	LogError("Invalid handle parameter. NULL.");
AzureIoTClient	18:ec8e5e97c6a4	412	result = __FAILURE__;
AzureIoTClient	12:658ca6865de2	413	}
AzureIoTClient	12:658ca6865de2	414	else
AzureIoTClient	12:658ca6865de2	415	{
AzureIoTClient	12:658ca6865de2	416	if (transport_data->retryLogic == NULL)
AzureIoTClient	12:658ca6865de2	417	{
AzureIoTClient	12:658ca6865de2	418	/Codes_SRS_IOTHUB_TRANSPORT_MQTT_COMMON_25_042: [If the retry logic is not already created then IoTHubTransport_MQTT_Common_SetRetryPolicy shall create retry logic by calling CreateRetryLogic with retry policy and retryTimeout as parameters]/
AzureIoTClient	12:658ca6865de2	419	transport_data->retryLogic = CreateRetryLogic(retryPolicy, retryTimeoutLimitInSeconds);
AzureIoTClient	12:658ca6865de2	420	}
AzureIoTClient	12:658ca6865de2	421	else
AzureIoTClient	12:658ca6865de2	422	{
AzureIoTClient	12:658ca6865de2	423	/Codes_SRS_IOTHUB_TRANSPORT_MQTT_COMMON_25_043: [If the retry logic is already created then IoTHubTransport_MQTT_Common_SetRetryPolicy shall destroy existing retry logic and create retry logic by calling CreateRetryLogic with retry policy and retryTimeout as parameters]/
AzureIoTClient	12:658ca6865de2	424	DestroyRetryLogic(transport_data->retryLogic);
AzureIoTClient	12:658ca6865de2	425	transport_data->retryLogic = CreateRetryLogic(retryPolicy, retryTimeoutLimitInSeconds);
AzureIoTClient	12:658ca6865de2	426	}
AzureIoTClient	12:658ca6865de2	427
AzureIoTClient	12:658ca6865de2	428	if (transport_data->retryLogic != NULL)
AzureIoTClient	12:658ca6865de2	429	{
AzureIoTClient	12:658ca6865de2	430	/Codes_SRS_IOTHUB_TRANSPORT_MQTT_COMMON_25_045: [If retry logic for specified parameters of retry policy and retryTimeoutLimitInSeconds is created successfully then IoTHubTransport_MQTT_Common_SetRetryPolicy shall return 0]/
AzureIoTClient	12:658ca6865de2	431	result = 0;
AzureIoTClient	12:658ca6865de2	432	}
AzureIoTClient	12:658ca6865de2	433	else
AzureIoTClient	12:658ca6865de2	434	{
AzureIoTClient	12:658ca6865de2	435	/Codes_SRS_IOTHUB_TRANSPORT_MQTT_COMMON_25_044: [If retry logic for specified parameters of retry policy and retryTimeoutLimitInSeconds cannot be created then IoTHubTransport_MQTT_Common_SetRetryPolicy shall return resultant line]/
AzureIoTClient	12:658ca6865de2	436	LogError("Retry Logic is not created");
AzureIoTClient	18:ec8e5e97c6a4	437	result = __FAILURE__;
AzureIoTClient	12:658ca6865de2	438	}
AzureIoTClient	12:658ca6865de2	439	}
AzureIoTClient	12:658ca6865de2	440	return result;
AzureIoTClient	12:658ca6865de2	441	}
AzureIoTClient	12:658ca6865de2	442
AzureIoTClient	12:658ca6865de2	443	// Called for every do_work when connection is broken
AzureIoTClient	12:658ca6865de2	444	static bool CanRetry(RETRY_LOGIC *retryLogic)
AzureIoTClient	12:658ca6865de2	445	{
AzureIoTClient	12:658ca6865de2	446	bool result;
AzureIoTClient	12:658ca6865de2	447	time_t now = get_time(NULL);
AzureIoTClient	12:658ca6865de2	448
AzureIoTClient	12:658ca6865de2	449	if (retryLogic == NULL)
AzureIoTClient	12:658ca6865de2	450	{
AzureIoTClient	12:658ca6865de2	451	LogError("Retry Logic is not created, retrying forever");
AzureIoTClient	12:658ca6865de2	452	result = true;
AzureIoTClient	12:658ca6865de2	453	}
AzureIoTClient	17:774695cb8554	454	else if (now < 0 \|\| retryLogic->start < 0)
AzureIoTClient	12:658ca6865de2	455	{
AzureIoTClient	12:658ca6865de2	456	LogError("Time could not be retrieved, retrying forever");
AzureIoTClient	12:658ca6865de2	457	result = true;
AzureIoTClient	12:658ca6865de2	458	}
AzureIoTClient	12:658ca6865de2	459	else if (retryLogic->retryExpired)
AzureIoTClient	12:658ca6865de2	460	{
AzureIoTClient	17:774695cb8554	461	// We've given up trying to retry. Don't do anything.
AzureIoTClient	12:658ca6865de2	462	result = false;
AzureIoTClient	12:658ca6865de2	463	}
AzureIoTClient	17:774695cb8554	464	else if (retryLogic->firstAttempt)
AzureIoTClient	12:658ca6865de2	465	{
AzureIoTClient	17:774695cb8554	466	// This is the first time ever running through this code. We need to try connecting no matter what.
AzureIoTClient	12:658ca6865de2	467	StartRetryTimer(retryLogic);
AzureIoTClient	12:658ca6865de2	468	retryLogic->lastConnect = now;
AzureIoTClient	12:658ca6865de2	469	retryLogic->retrycount++;
AzureIoTClient	12:658ca6865de2	470	result = true;
AzureIoTClient	12:658ca6865de2	471	}
AzureIoTClient	12:658ca6865de2	472	else
AzureIoTClient	12:658ca6865de2	473	{
AzureIoTClient	17:774695cb8554	474	// Are we trying to retry?
AzureIoTClient	12:658ca6865de2	475	if (retryLogic->retryStarted)
AzureIoTClient	12:658ca6865de2	476	{
AzureIoTClient	17:774695cb8554	477	// How long since we last tried to connect? Store this in difftime.
AzureIoTClient	12:658ca6865de2	478	double diffTime = get_difftime(now, retryLogic->lastConnect);
AzureIoTClient	17:774695cb8554	479
AzureIoTClient	17:774695cb8554	480	// Has it been less than 5 seconds since we tried last? If so, we have to
AzureIoTClient	17:774695cb8554	481	// be careful so we don't hit the server too quickly.
AzureIoTClient	12:658ca6865de2	482	if (diffTime <= ERROR_TIME_FOR_RETRY_SECS)
AzureIoTClient	12:658ca6865de2	483	{
AzureIoTClient	17:774695cb8554	484	// As do_work can be called within as little as 1 ms, wait to avoid throtling server
AzureIoTClient	17:774695cb8554	485	result = false;
AzureIoTClient	12:658ca6865de2	486	}
AzureIoTClient	12:658ca6865de2	487	else if (diffTime < retryLogic->delayFromLastConnectToRetry)
AzureIoTClient	12:658ca6865de2	488	{
AzureIoTClient	17:774695cb8554	489	// delayFromLastConnectionToRetry is either 0 (the first time around)
AzureIoTClient	17:774695cb8554	490	// or it's the backoff delta from the last time through the loop.
AzureIoTClient	17:774695cb8554	491	// If we're less than that, don't even bother trying. It's
AzureIoTClient	12:658ca6865de2	492	// Too early to retry
AzureIoTClient	12:658ca6865de2	493	result = false;
AzureIoTClient	12:658ca6865de2	494	}
AzureIoTClient	12:658ca6865de2	495	else
AzureIoTClient	12:658ca6865de2	496	{
AzureIoTClient	12:658ca6865de2	497	// last retry time evaluated have crossed, determine when to try next
AzureIoTClient	17:774695cb8554	498	// In other words, it migth be time to retry, so we should validate with the retry policy function.
AzureIoTClient	12:658ca6865de2	499	bool permit = false;
AzureIoTClient	12:658ca6865de2	500	size_t delay;
AzureIoTClient	12:658ca6865de2	501
AzureIoTClient	12:658ca6865de2	502	if (retryLogic->fnRetryPolicy != NULL && (retryLogic->fnRetryPolicy(&permit, &delay, retryLogic) == 0))
AzureIoTClient	12:658ca6865de2	503	{
AzureIoTClient	17:774695cb8554	504	// Does the policy function want us to retry (permit == true), or are we still allowed to retry?
AzureIoTClient	17:774695cb8554	505	// (in other words, are we within retryTimeoutLimitInSeconds seconds since starting to retry?)
AzureIoTClient	21:167f8fcf6fb1	506	// If so, see if we _really_ want to retry.
AzureIoTClient	12:658ca6865de2	507	if ((permit == true) && ((retryLogic->retryTimeoutLimitInSeconds == 0) \|\| retryLogic->retryTimeoutLimitInSeconds >= (delay + get_difftime(now, retryLogic->start))))
AzureIoTClient	12:658ca6865de2	508	{
AzureIoTClient	12:658ca6865de2	509	retryLogic->delayFromLastConnectToRetry = delay;
AzureIoTClient	12:658ca6865de2	510
AzureIoTClient	12:658ca6865de2	511	LogInfo("Evaluated delay %d at %d attempt to retry\n", delay, retryLogic->retrycount);
AzureIoTClient	12:658ca6865de2	512
AzureIoTClient	17:774695cb8554	513	// If the retry policy is telling us to connect right away ( <= ERROR_TIME_FOR_RETRY_SECS),
AzureIoTClient	17:774695cb8554	514	// or if enough time has elapsed, then we retry.
AzureIoTClient	17:774695cb8554	515	if ((retryLogic->delayFromLastConnectToRetry <= ERROR_TIME_FOR_RETRY_SECS) \|\|
AzureIoTClient	17:774695cb8554	516	(diffTime >= retryLogic->delayFromLastConnectToRetry))
AzureIoTClient	12:658ca6865de2	517	{
AzureIoTClient	12:658ca6865de2	518	retryLogic->lastConnect = now;
AzureIoTClient	12:658ca6865de2	519	retryLogic->retrycount++;
AzureIoTClient	12:658ca6865de2	520	result = true;
AzureIoTClient	12:658ca6865de2	521	}
AzureIoTClient	12:658ca6865de2	522	else
AzureIoTClient	12:658ca6865de2	523	{
AzureIoTClient	17:774695cb8554	524	// To soon to retry according to policy.
AzureIoTClient	12:658ca6865de2	525	result = false;
AzureIoTClient	12:658ca6865de2	526	}
AzureIoTClient	12:658ca6865de2	527	}
AzureIoTClient	12:658ca6865de2	528	else
AzureIoTClient	12:658ca6865de2	529	{
AzureIoTClient	17:774695cb8554	530	// Retry expired. Stop trying.
AzureIoTClient	12:658ca6865de2	531	LogError("Retry timeout expired after %d attempts", retryLogic->retrycount);
AzureIoTClient	12:658ca6865de2	532	retryLogic->retryExpired = true;
AzureIoTClient	12:658ca6865de2	533	StopRetryTimer(retryLogic);
AzureIoTClient	12:658ca6865de2	534	result = false;
AzureIoTClient	12:658ca6865de2	535	}
AzureIoTClient	12:658ca6865de2	536	}
AzureIoTClient	12:658ca6865de2	537	else
AzureIoTClient	12:658ca6865de2	538	{
AzureIoTClient	17:774695cb8554	539	// We don't have a retry policy. Sorry, can't even guess. Don't bother even trying to retry.
AzureIoTClient	12:658ca6865de2	540	LogError("Cannot evaluate the next best time to retry");
AzureIoTClient	12:658ca6865de2	541	result = false;
AzureIoTClient	12:658ca6865de2	542	}
AzureIoTClient	12:658ca6865de2	543	}
AzureIoTClient	12:658ca6865de2	544	}
AzureIoTClient	12:658ca6865de2	545	else
AzureIoTClient	12:658ca6865de2	546	{
AzureIoTClient	17:774695cb8554	547	// Since this function is only called when the connection is
AzureIoTClient	17:774695cb8554	548	// already broken, we can start doing the rety logic. We'll do the
AzureIoTClient	17:774695cb8554	549	// actual interval checking next time around this loop.
AzureIoTClient	12:658ca6865de2	550	StartRetryTimer(retryLogic);
AzureIoTClient	12:658ca6865de2	551	//wait for next do work to evaluate next best attempt
AzureIoTClient	12:658ca6865de2	552	result = false;
AzureIoTClient	12:658ca6865de2	553	}
AzureIoTClient	12:658ca6865de2	554	}
AzureIoTClient	12:658ca6865de2	555	return result;
AzureIoTClient	12:658ca6865de2	556	}
AzureIoTClient	12:658ca6865de2	557
AzureIoTClient	12:658ca6865de2	558
AzureIoTClient	11:31ebaeb51e1e	559	static uint16_t get_next_packet_id(PMQTTTRANSPORT_HANDLE_DATA transport_data)
AzureIoTClient	11:31ebaeb51e1e	560	{
AzureIoTClient	11:31ebaeb51e1e	561	if (transport_data->packetId+1 >= USHRT_MAX)
AzureIoTClient	11:31ebaeb51e1e	562	{
AzureIoTClient	11:31ebaeb51e1e	563	transport_data->packetId = 1;
AzureIoTClient	11:31ebaeb51e1e	564	}
AzureIoTClient	11:31ebaeb51e1e	565	else
AzureIoTClient	11:31ebaeb51e1e	566	{
AzureIoTClient	11:31ebaeb51e1e	567	transport_data->packetId++;
AzureIoTClient	11:31ebaeb51e1e	568	}
AzureIoTClient	11:31ebaeb51e1e	569	return transport_data->packetId;
AzureIoTClient	11:31ebaeb51e1e	570	}
AzureIoTClient	11:31ebaeb51e1e	571
AzureIoTClient	11:31ebaeb51e1e	572	static const char* retrieve_mqtt_return_codes(CONNECT_RETURN_CODE rtn_code)
AzureIoTClient	11:31ebaeb51e1e	573	{
AzureIoTClient	11:31ebaeb51e1e	574	switch (rtn_code)
AzureIoTClient	11:31ebaeb51e1e	575	{
AzureIoTClient	11:31ebaeb51e1e	576	case CONNECTION_ACCEPTED:
AzureIoTClient	11:31ebaeb51e1e	577	return "Accepted";
AzureIoTClient	11:31ebaeb51e1e	578	case CONN_REFUSED_UNACCEPTABLE_VERSION:
AzureIoTClient	11:31ebaeb51e1e	579	return "Unacceptable Version";
AzureIoTClient	11:31ebaeb51e1e	580	case CONN_REFUSED_ID_REJECTED:
AzureIoTClient	11:31ebaeb51e1e	581	return "Id Rejected";
AzureIoTClient	11:31ebaeb51e1e	582	case CONN_REFUSED_SERVER_UNAVAIL:
AzureIoTClient	11:31ebaeb51e1e	583	return "Server Unavailable";
AzureIoTClient	11:31ebaeb51e1e	584	case CONN_REFUSED_BAD_USERNAME_PASSWORD:
AzureIoTClient	11:31ebaeb51e1e	585	return "Bad Username/Password";
AzureIoTClient	11:31ebaeb51e1e	586	case CONN_REFUSED_NOT_AUTHORIZED:
AzureIoTClient	11:31ebaeb51e1e	587	return "Not Authorized";
AzureIoTClient	11:31ebaeb51e1e	588	case CONN_REFUSED_UNKNOWN:
AzureIoTClient	11:31ebaeb51e1e	589	default:
AzureIoTClient	11:31ebaeb51e1e	590	return "Unknown";
AzureIoTClient	11:31ebaeb51e1e	591	}
AzureIoTClient	11:31ebaeb51e1e	592	}
AzureIoTClient	11:31ebaeb51e1e	593
AzureIoTClient	14:4dc2b011be33	594	static int retrieve_device_method_rid_info(const char* resp_topic, STRING_HANDLE method_name, STRING_HANDLE request_id)
AzureIoTClient	12:658ca6865de2	595	{
AzureIoTClient	12:658ca6865de2	596	int result;
AzureIoTClient	12:658ca6865de2	597	STRING_TOKENIZER_HANDLE token_handle = STRING_TOKENIZER_create_from_char(resp_topic);
AzureIoTClient	12:658ca6865de2	598	if (token_handle == NULL)
AzureIoTClient	12:658ca6865de2	599	{
AzureIoTClient	12:658ca6865de2	600	LogError("Failed creating token from device twin topic.");
AzureIoTClient	18:ec8e5e97c6a4	601	result = __FAILURE__;
AzureIoTClient	12:658ca6865de2	602	}
AzureIoTClient	12:658ca6865de2	603	else
AzureIoTClient	12:658ca6865de2	604	{
AzureIoTClient	12:658ca6865de2	605	STRING_HANDLE token_value;
AzureIoTClient	12:658ca6865de2	606	if ((token_value = STRING_new()) == NULL)
AzureIoTClient	12:658ca6865de2	607	{
AzureIoTClient	12:658ca6865de2	608	LogError("Failed allocating new string .");
AzureIoTClient	18:ec8e5e97c6a4	609	result = __FAILURE__;
AzureIoTClient	12:658ca6865de2	610	}
AzureIoTClient	12:658ca6865de2	611	else
AzureIoTClient	12:658ca6865de2	612	{
AzureIoTClient	12:658ca6865de2	613	size_t token_index = 0;
AzureIoTClient	12:658ca6865de2	614	size_t request_id_length = strlen(REQUEST_ID_PROPERTY);
AzureIoTClient	18:ec8e5e97c6a4	615	result = __FAILURE__;
AzureIoTClient	12:658ca6865de2	616	while (STRING_TOKENIZER_get_next_token(token_handle, token_value, "/") == 0)
AzureIoTClient	12:658ca6865de2	617	{
AzureIoTClient	12:658ca6865de2	618	if (token_index == 3)
AzureIoTClient	12:658ca6865de2	619	{
AzureIoTClient	12:658ca6865de2	620	if (STRING_concat_with_STRING(method_name, token_value) != 0)
AzureIoTClient	12:658ca6865de2	621	{
AzureIoTClient	14:4dc2b011be33	622	LogError("Failed STRING_concat_with_STRING.");
AzureIoTClient	18:ec8e5e97c6a4	623	result = __FAILURE__;
AzureIoTClient	12:658ca6865de2	624	break;
AzureIoTClient	12:658ca6865de2	625	}
AzureIoTClient	12:658ca6865de2	626	}
AzureIoTClient	12:658ca6865de2	627	else if (token_index == 4)
AzureIoTClient	12:658ca6865de2	628	{
AzureIoTClient	12:658ca6865de2	629	if (STRING_length(token_value) >= request_id_length)
AzureIoTClient	12:658ca6865de2	630	{
AzureIoTClient	12:658ca6865de2	631	const char* request_id_value = STRING_c_str(token_value);
AzureIoTClient	12:658ca6865de2	632	if (memcmp(request_id_value, REQUEST_ID_PROPERTY, request_id_length) == 0)
AzureIoTClient	12:658ca6865de2	633	{
AzureIoTClient	14:4dc2b011be33	634	if (STRING_concat(request_id, request_id_value+request_id_length) != 0)
AzureIoTClient	14:4dc2b011be33	635	{
AzureIoTClient	14:4dc2b011be33	636	LogError("Failed STRING_concat failed.");
AzureIoTClient	18:ec8e5e97c6a4	637	result = __FAILURE__;
AzureIoTClient	14:4dc2b011be33	638	}
AzureIoTClient	14:4dc2b011be33	639	else
AzureIoTClient	14:4dc2b011be33	640	{
AzureIoTClient	14:4dc2b011be33	641	result = 0;
AzureIoTClient	14:4dc2b011be33	642	}
AzureIoTClient	12:658ca6865de2	643	break;
AzureIoTClient	12:658ca6865de2	644	}
AzureIoTClient	12:658ca6865de2	645	}
AzureIoTClient	12:658ca6865de2	646	}
AzureIoTClient	12:658ca6865de2	647	token_index++;
AzureIoTClient	12:658ca6865de2	648	}
AzureIoTClient	12:658ca6865de2	649	STRING_delete(token_value);
AzureIoTClient	12:658ca6865de2	650	}
AzureIoTClient	12:658ca6865de2	651	STRING_TOKENIZER_destroy(token_handle);
AzureIoTClient	12:658ca6865de2	652	}
AzureIoTClient	12:658ca6865de2	653	return result;
AzureIoTClient	12:658ca6865de2	654	}
AzureIoTClient	12:658ca6865de2	655
AzureIoTClient	12:658ca6865de2	656	static int parse_device_twin_topic_info(const char* resp_topic, bool* patch_msg, size_t* request_id, int* status_code)
AzureIoTClient	12:658ca6865de2	657	{
AzureIoTClient	12:658ca6865de2	658	int result;
AzureIoTClient	12:658ca6865de2	659	STRING_TOKENIZER_HANDLE token_handle = STRING_TOKENIZER_create_from_char(resp_topic);
AzureIoTClient	12:658ca6865de2	660	if (token_handle == NULL)
AzureIoTClient	12:658ca6865de2	661	{
AzureIoTClient	12:658ca6865de2	662	LogError("Failed creating token from device twin topic.");
AzureIoTClient	18:ec8e5e97c6a4	663	result = __FAILURE__;
AzureIoTClient	12:658ca6865de2	664	*status_code = 0;
AzureIoTClient	12:658ca6865de2	665	*request_id = 0;
AzureIoTClient	12:658ca6865de2	666	*patch_msg = false;
AzureIoTClient	12:658ca6865de2	667	}
AzureIoTClient	12:658ca6865de2	668	else
AzureIoTClient	12:658ca6865de2	669	{
AzureIoTClient	12:658ca6865de2	670	STRING_HANDLE token_value;
AzureIoTClient	12:658ca6865de2	671	if ((token_value = STRING_new()) == NULL)
AzureIoTClient	12:658ca6865de2	672	{
AzureIoTClient	12:658ca6865de2	673	LogError("Failed allocating new string .");
AzureIoTClient	18:ec8e5e97c6a4	674	result = __FAILURE__;
AzureIoTClient	12:658ca6865de2	675	*status_code = 0;
AzureIoTClient	12:658ca6865de2	676	*request_id = 0;
AzureIoTClient	12:658ca6865de2	677	*patch_msg = false;
AzureIoTClient	12:658ca6865de2	678	}
AzureIoTClient	12:658ca6865de2	679	else
AzureIoTClient	12:658ca6865de2	680	{
AzureIoTClient	18:ec8e5e97c6a4	681	result = __FAILURE__;
AzureIoTClient	12:658ca6865de2	682	size_t token_count = 0;
AzureIoTClient	12:658ca6865de2	683	while (STRING_TOKENIZER_get_next_token(token_handle, token_value, "/") == 0)
AzureIoTClient	12:658ca6865de2	684	{
AzureIoTClient	12:658ca6865de2	685	if (token_count == 2)
AzureIoTClient	12:658ca6865de2	686	{
AzureIoTClient	12:658ca6865de2	687	if (strcmp(STRING_c_str(token_value), "PATCH") == 0)
AzureIoTClient	12:658ca6865de2	688	{
AzureIoTClient	12:658ca6865de2	689	*patch_msg = true;
AzureIoTClient	12:658ca6865de2	690	*status_code = 0;
AzureIoTClient	12:658ca6865de2	691	*request_id = 0;
AzureIoTClient	12:658ca6865de2	692	result = 0;
AzureIoTClient	12:658ca6865de2	693	break;
AzureIoTClient	12:658ca6865de2	694	}
AzureIoTClient	12:658ca6865de2	695	else
AzureIoTClient	12:658ca6865de2	696	{
AzureIoTClient	12:658ca6865de2	697	*patch_msg = false;
AzureIoTClient	12:658ca6865de2	698	}
AzureIoTClient	12:658ca6865de2	699	}
AzureIoTClient	12:658ca6865de2	700	else if (token_count == 3)
AzureIoTClient	12:658ca6865de2	701	{
AzureIoTClient	12:658ca6865de2	702	*status_code = atol(STRING_c_str(token_value));
AzureIoTClient	12:658ca6865de2	703	if (STRING_TOKENIZER_get_next_token(token_handle, token_value, "/?$rid=") == 0)
AzureIoTClient	12:658ca6865de2	704	{
AzureIoTClient	12:658ca6865de2	705	*request_id = (size_t)atol(STRING_c_str(token_value));
AzureIoTClient	12:658ca6865de2	706	}
AzureIoTClient	12:658ca6865de2	707	*patch_msg = false;
AzureIoTClient	12:658ca6865de2	708	result = 0;
AzureIoTClient	12:658ca6865de2	709	break;
AzureIoTClient	12:658ca6865de2	710	}
AzureIoTClient	12:658ca6865de2	711	token_count++;
AzureIoTClient	12:658ca6865de2	712	}
AzureIoTClient	12:658ca6865de2	713	STRING_delete(token_value);
AzureIoTClient	12:658ca6865de2	714	}
AzureIoTClient	12:658ca6865de2	715	STRING_TOKENIZER_destroy(token_handle);
AzureIoTClient	12:658ca6865de2	716	}
AzureIoTClient	12:658ca6865de2	717	return result;
AzureIoTClient	12:658ca6865de2	718	}
AzureIoTClient	12:658ca6865de2	719
AzureIoTClient	12:658ca6865de2	720	static IOTHUB_IDENTITY_TYPE retrieve_topic_type(const char* topic_resp)
AzureIoTClient	12:658ca6865de2	721	{
AzureIoTClient	12:658ca6865de2	722	IOTHUB_IDENTITY_TYPE type;
AzureIoTClient	12:658ca6865de2	723	size_t dev_twin_topic_len = sizeof(TOPIC_DEVICE_TWIN_PREFIX)-1;
AzureIoTClient	12:658ca6865de2	724	size_t dev_method_topic_len = sizeof(TOPIC_DEVICE_METHOD_PREFIX)-1;
AzureIoTClient	12:658ca6865de2	725	size_t topic_len = strlen(topic_resp);
AzureIoTClient	12:658ca6865de2	726	size_t len_to_use = (dev_twin_topic_len > dev_method_topic_len) ? dev_twin_topic_len : dev_method_topic_len;
AzureIoTClient	12:658ca6865de2	727
AzureIoTClient	12:658ca6865de2	728	bool search_device_twin = true;
AzureIoTClient	12:658ca6865de2	729	bool search_device_method = true;
AzureIoTClient	12:658ca6865de2	730	if (topic_len < len_to_use)
AzureIoTClient	12:658ca6865de2	731	{
AzureIoTClient	12:658ca6865de2	732	search_device_twin = false;
AzureIoTClient	12:658ca6865de2	733	search_device_method = false;
AzureIoTClient	12:658ca6865de2	734	}
AzureIoTClient	12:658ca6865de2	735	else
AzureIoTClient	12:658ca6865de2	736	{
AzureIoTClient	16:14640ee83e99	737	size_t index = 0;
AzureIoTClient	16:14640ee83e99	738	for (index = 0; index < len_to_use && (search_device_twin \|\| search_device_method); index++)
AzureIoTClient	12:658ca6865de2	739	{
AzureIoTClient	12:658ca6865de2	740	if (search_device_twin)
AzureIoTClient	12:658ca6865de2	741	{
AzureIoTClient	12:658ca6865de2	742	if (index > dev_twin_topic_len)
AzureIoTClient	12:658ca6865de2	743	{
AzureIoTClient	12:658ca6865de2	744	search_device_twin = false;
AzureIoTClient	12:658ca6865de2	745	}
AzureIoTClient	12:658ca6865de2	746	else
AzureIoTClient	12:658ca6865de2	747	{
AzureIoTClient	12:658ca6865de2	748	if (index == dev_twin_topic_len)
AzureIoTClient	12:658ca6865de2	749	{
AzureIoTClient	12:658ca6865de2	750	break;
AzureIoTClient	12:658ca6865de2	751	}
AzureIoTClient	14:4dc2b011be33	752	else if (TOUPPER(TOPIC_DEVICE_TWIN_PREFIX[index]) != TOUPPER(topic_resp[index]))
AzureIoTClient	12:658ca6865de2	753	{
AzureIoTClient	12:658ca6865de2	754	search_device_twin = false;
AzureIoTClient	12:658ca6865de2	755	}
AzureIoTClient	12:658ca6865de2	756	}
AzureIoTClient	12:658ca6865de2	757	}
AzureIoTClient	12:658ca6865de2	758	if (search_device_method)
AzureIoTClient	12:658ca6865de2	759	{
AzureIoTClient	12:658ca6865de2	760	if (index > dev_method_topic_len)
AzureIoTClient	12:658ca6865de2	761	{
AzureIoTClient	12:658ca6865de2	762	search_device_method = false;
AzureIoTClient	12:658ca6865de2	763	}
AzureIoTClient	12:658ca6865de2	764	else
AzureIoTClient	12:658ca6865de2	765	{
AzureIoTClient	12:658ca6865de2	766	if (index == dev_method_topic_len)
AzureIoTClient	12:658ca6865de2	767	{
AzureIoTClient	12:658ca6865de2	768	break;
AzureIoTClient	12:658ca6865de2	769	}
AzureIoTClient	14:4dc2b011be33	770	else if (TOUPPER(TOPIC_DEVICE_METHOD_PREFIX[index]) != TOUPPER(topic_resp[index]))
AzureIoTClient	12:658ca6865de2	771	{
AzureIoTClient	12:658ca6865de2	772	search_device_method = false;
AzureIoTClient	12:658ca6865de2	773	}
AzureIoTClient	12:658ca6865de2	774	}
AzureIoTClient	12:658ca6865de2	775	}
AzureIoTClient	12:658ca6865de2	776	}
AzureIoTClient	12:658ca6865de2	777	}
AzureIoTClient	12:658ca6865de2	778	if (search_device_twin)
AzureIoTClient	12:658ca6865de2	779	{
AzureIoTClient	12:658ca6865de2	780	type = IOTHUB_TYPE_DEVICE_TWIN;
AzureIoTClient	12:658ca6865de2	781	}
AzureIoTClient	12:658ca6865de2	782	else if (search_device_method)
AzureIoTClient	12:658ca6865de2	783	{
AzureIoTClient	12:658ca6865de2	784	type = IOTHUB_TYPE_DEVICE_METHODS;
AzureIoTClient	12:658ca6865de2	785	}
AzureIoTClient	12:658ca6865de2	786	else
AzureIoTClient	12:658ca6865de2	787	{
AzureIoTClient	12:658ca6865de2	788	type = IOTHUB_TYPE_TELEMETRY;
AzureIoTClient	12:658ca6865de2	789	}
AzureIoTClient	12:658ca6865de2	790	return type;
AzureIoTClient	12:658ca6865de2	791	}
AzureIoTClient	12:658ca6865de2	792
AzureIoTClient	11:31ebaeb51e1e	793	static void sendMsgComplete(IOTHUB_MESSAGE_LIST* iothubMsgList, PMQTTTRANSPORT_HANDLE_DATA transport_data, IOTHUB_CLIENT_CONFIRMATION_RESULT confirmResult)
AzureIoTClient	11:31ebaeb51e1e	794	{
AzureIoTClient	11:31ebaeb51e1e	795	DLIST_ENTRY messageCompleted;
AzureIoTClient	11:31ebaeb51e1e	796	DList_InitializeListHead(&messageCompleted);
AzureIoTClient	11:31ebaeb51e1e	797	DList_InsertTailList(&messageCompleted, &(iothubMsgList->entry));
AzureIoTClient	11:31ebaeb51e1e	798	IoTHubClient_LL_SendComplete(transport_data->llClientHandle, &messageCompleted, confirmResult);
AzureIoTClient	11:31ebaeb51e1e	799	}
AzureIoTClient	11:31ebaeb51e1e	800
AzureIoTClient	11:31ebaeb51e1e	801	static STRING_HANDLE addPropertiesTouMqttMessage(IOTHUB_MESSAGE_HANDLE iothub_message_handle, const char* eventTopic)
AzureIoTClient	11:31ebaeb51e1e	802	{
AzureIoTClient	11:31ebaeb51e1e	803	STRING_HANDLE result = STRING_construct(eventTopic);
AzureIoTClient	11:31ebaeb51e1e	804	const char* const* propertyKeys;
AzureIoTClient	11:31ebaeb51e1e	805	const char* const* propertyValues;
AzureIoTClient	11:31ebaeb51e1e	806	size_t propertyCount;
AzureIoTClient	11:31ebaeb51e1e	807
AzureIoTClient	11:31ebaeb51e1e	808	// Construct Properties
AzureIoTClient	11:31ebaeb51e1e	809	MAP_HANDLE properties_map = IoTHubMessage_Properties(iothub_message_handle);
AzureIoTClient	11:31ebaeb51e1e	810	if (properties_map != NULL)
AzureIoTClient	11:31ebaeb51e1e	811	{
AzureIoTClient	11:31ebaeb51e1e	812	if (Map_GetInternals(properties_map, &propertyKeys, &propertyValues, &propertyCount) != MAP_OK)
AzureIoTClient	11:31ebaeb51e1e	813	{
AzureIoTClient	11:31ebaeb51e1e	814	LogError("Failed to get the internals of the property map.");
AzureIoTClient	11:31ebaeb51e1e	815	STRING_delete(result);
AzureIoTClient	11:31ebaeb51e1e	816	result = NULL;
AzureIoTClient	11:31ebaeb51e1e	817	}
AzureIoTClient	11:31ebaeb51e1e	818	else
AzureIoTClient	11:31ebaeb51e1e	819	{
AzureIoTClient	11:31ebaeb51e1e	820	if (propertyCount != 0)
AzureIoTClient	11:31ebaeb51e1e	821	{
AzureIoTClient	16:14640ee83e99	822	size_t index = 0;
AzureIoTClient	16:14640ee83e99	823	for (index = 0; index < propertyCount && result != NULL; index++)
AzureIoTClient	11:31ebaeb51e1e	824	{
AzureIoTClient	11:31ebaeb51e1e	825	if (STRING_sprintf(result, "%s=%s%s", propertyKeys[index], propertyValues[index], propertyCount - 1 == index ? "" : PROPERTY_SEPARATOR) != 0)
AzureIoTClient	11:31ebaeb51e1e	826	{
AzureIoTClient	11:31ebaeb51e1e	827	STRING_delete(result);
AzureIoTClient	11:31ebaeb51e1e	828	result = NULL;
AzureIoTClient	11:31ebaeb51e1e	829	}
AzureIoTClient	11:31ebaeb51e1e	830	}
AzureIoTClient	11:31ebaeb51e1e	831	}
AzureIoTClient	11:31ebaeb51e1e	832	}
AzureIoTClient	11:31ebaeb51e1e	833	}
AzureIoTClient	11:31ebaeb51e1e	834	return result;
AzureIoTClient	11:31ebaeb51e1e	835	}
AzureIoTClient	11:31ebaeb51e1e	836
AzureIoTClient	11:31ebaeb51e1e	837	static int publish_mqtt_telemetry_msg(PMQTTTRANSPORT_HANDLE_DATA transport_data, MQTT_MESSAGE_DETAILS_LIST* mqttMsgEntry, const unsigned char* payload, size_t len)
AzureIoTClient	11:31ebaeb51e1e	838	{
AzureIoTClient	11:31ebaeb51e1e	839	int result;
AzureIoTClient	11:31ebaeb51e1e	840	STRING_HANDLE msgTopic = addPropertiesTouMqttMessage(mqttMsgEntry->iotHubMessageEntry->messageHandle, STRING_c_str(transport_data->topic_MqttEvent));
AzureIoTClient	11:31ebaeb51e1e	841	if (msgTopic == NULL)
AzureIoTClient	11:31ebaeb51e1e	842	{
AzureIoTClient	18:ec8e5e97c6a4	843	result = __FAILURE__;
AzureIoTClient	11:31ebaeb51e1e	844	}
AzureIoTClient	11:31ebaeb51e1e	845	else
AzureIoTClient	11:31ebaeb51e1e	846	{
AzureIoTClient	11:31ebaeb51e1e	847	MQTT_MESSAGE_HANDLE mqttMsg = mqttmessage_create(mqttMsgEntry->packet_id, STRING_c_str(msgTopic), DELIVER_AT_LEAST_ONCE, payload, len);
AzureIoTClient	11:31ebaeb51e1e	848	if (mqttMsg == NULL)
AzureIoTClient	11:31ebaeb51e1e	849	{
AzureIoTClient	18:ec8e5e97c6a4	850	result = __FAILURE__;
AzureIoTClient	11:31ebaeb51e1e	851	}
AzureIoTClient	11:31ebaeb51e1e	852	else
AzureIoTClient	11:31ebaeb51e1e	853	{
Azure.IoT.Build	13:606465879c57	854	if (tickcounter_get_current_ms(transport_data->msgTickCounter, &mqttMsgEntry->msgPublishTime) != 0)
AzureIoTClient	11:31ebaeb51e1e	855	{
AzureIoTClient	11:31ebaeb51e1e	856	LogError("Failed retrieving tickcounter info");
AzureIoTClient	18:ec8e5e97c6a4	857	result = __FAILURE__;
AzureIoTClient	11:31ebaeb51e1e	858	}
AzureIoTClient	11:31ebaeb51e1e	859	else
AzureIoTClient	11:31ebaeb51e1e	860	{
AzureIoTClient	11:31ebaeb51e1e	861	if (mqtt_client_publish(transport_data->mqttClient, mqttMsg) != 0)
AzureIoTClient	11:31ebaeb51e1e	862	{
AzureIoTClient	18:ec8e5e97c6a4	863	result = __FAILURE__;
AzureIoTClient	11:31ebaeb51e1e	864	}
AzureIoTClient	11:31ebaeb51e1e	865	else
AzureIoTClient	11:31ebaeb51e1e	866	{
AzureIoTClient	11:31ebaeb51e1e	867	mqttMsgEntry->retryCount++;
AzureIoTClient	11:31ebaeb51e1e	868	result = 0;
AzureIoTClient	11:31ebaeb51e1e	869	}
AzureIoTClient	11:31ebaeb51e1e	870	}
AzureIoTClient	11:31ebaeb51e1e	871	mqttmessage_destroy(mqttMsg);
AzureIoTClient	11:31ebaeb51e1e	872	}
AzureIoTClient	11:31ebaeb51e1e	873	STRING_delete(msgTopic);
AzureIoTClient	11:31ebaeb51e1e	874	}
AzureIoTClient	11:31ebaeb51e1e	875	return result;
AzureIoTClient	11:31ebaeb51e1e	876	}
AzureIoTClient	11:31ebaeb51e1e	877
AzureIoTClient	14:4dc2b011be33	878	static int publish_device_method_message(MQTTTRANSPORT_HANDLE_DATA* transport_data, int status_code, STRING_HANDLE request_id, const unsigned char* response, size_t response_size)
AzureIoTClient	12:658ca6865de2	879	{
AzureIoTClient	12:658ca6865de2	880	int result;
AzureIoTClient	12:658ca6865de2	881	uint16_t packet_id = get_next_packet_id(transport_data);
AzureIoTClient	12:658ca6865de2	882
AzureIoTClient	14:4dc2b011be33	883	STRING_HANDLE msg_topic = STRING_construct_sprintf(DEVICE_METHOD_RESPONSE_TOPIC, status_code, STRING_c_str(request_id) );
AzureIoTClient	12:658ca6865de2	884	if (msg_topic == NULL)
AzureIoTClient	12:658ca6865de2	885	{
AzureIoTClient	12:658ca6865de2	886	LogError("Failed constructing message topic.");
AzureIoTClient	18:ec8e5e97c6a4	887	result = __FAILURE__;
AzureIoTClient	12:658ca6865de2	888	}
AzureIoTClient	12:658ca6865de2	889	else
AzureIoTClient	12:658ca6865de2	890	{
AzureIoTClient	14:4dc2b011be33	891	MQTT_MESSAGE_HANDLE mqtt_get_msg = mqttmessage_create(packet_id, STRING_c_str(msg_topic), DELIVER_AT_MOST_ONCE, response, response_size);
AzureIoTClient	12:658ca6865de2	892	if (mqtt_get_msg == NULL)
AzureIoTClient	12:658ca6865de2	893	{
AzureIoTClient	12:658ca6865de2	894	LogError("Failed constructing mqtt message.");
AzureIoTClient	18:ec8e5e97c6a4	895	result = __FAILURE__;
AzureIoTClient	12:658ca6865de2	896	}
AzureIoTClient	12:658ca6865de2	897	else
AzureIoTClient	12:658ca6865de2	898	{
AzureIoTClient	12:658ca6865de2	899	if (mqtt_client_publish(transport_data->mqttClient, mqtt_get_msg) != 0)
AzureIoTClient	12:658ca6865de2	900	{
AzureIoTClient	12:658ca6865de2	901	LogError("Failed publishing to mqtt client.");
AzureIoTClient	18:ec8e5e97c6a4	902	result = __FAILURE__;
AzureIoTClient	12:658ca6865de2	903	}
AzureIoTClient	12:658ca6865de2	904	else
AzureIoTClient	12:658ca6865de2	905	{
AzureIoTClient	12:658ca6865de2	906	result = 0;
AzureIoTClient	12:658ca6865de2	907	}
AzureIoTClient	12:658ca6865de2	908	mqttmessage_destroy(mqtt_get_msg);
AzureIoTClient	12:658ca6865de2	909	}
AzureIoTClient	12:658ca6865de2	910	STRING_delete(msg_topic);
AzureIoTClient	12:658ca6865de2	911	}
AzureIoTClient	12:658ca6865de2	912	return result;
AzureIoTClient	12:658ca6865de2	913	}
AzureIoTClient	12:658ca6865de2	914
AzureIoTClient	12:658ca6865de2	915	static int publish_device_twin_get_message(MQTTTRANSPORT_HANDLE_DATA* transport_data)
AzureIoTClient	12:658ca6865de2	916	{
AzureIoTClient	12:658ca6865de2	917	int result;
AzureIoTClient	12:658ca6865de2	918	MQTT_DEVICE_TWIN_ITEM* mqtt_info = (MQTT_DEVICE_TWIN_ITEM*)malloc(sizeof(MQTT_DEVICE_TWIN_ITEM));
AzureIoTClient	12:658ca6865de2	919	if (mqtt_info == NULL)
AzureIoTClient	12:658ca6865de2	920	{
AzureIoTClient	12:658ca6865de2	921	LogError("Failed allocating device twin data.");
AzureIoTClient	18:ec8e5e97c6a4	922	result = __FAILURE__;
AzureIoTClient	12:658ca6865de2	923	}
AzureIoTClient	12:658ca6865de2	924	else
AzureIoTClient	12:658ca6865de2	925	{
AzureIoTClient	12:658ca6865de2	926	mqtt_info->packet_id = get_next_packet_id(transport_data);
AzureIoTClient	12:658ca6865de2	927	mqtt_info->iothub_msg_id = 0;
AzureIoTClient	12:658ca6865de2	928	mqtt_info->device_twin_msg_type = RETRIEVE_PROPERTIES;
AzureIoTClient	12:658ca6865de2	929	mqtt_info->retryCount = 0;
AzureIoTClient	12:658ca6865de2	930	mqtt_info->msgPublishTime = 0;
AzureIoTClient	12:658ca6865de2	931	mqtt_info->iothub_type = IOTHUB_TYPE_DEVICE_TWIN;
AzureIoTClient	12:658ca6865de2	932	mqtt_info->device_twin_data = NULL;
AzureIoTClient	12:658ca6865de2	933	STRING_HANDLE msg_topic = STRING_construct_sprintf(GET_PROPERTIES_TOPIC, mqtt_info->packet_id);
AzureIoTClient	12:658ca6865de2	934	if (msg_topic == NULL)
AzureIoTClient	12:658ca6865de2	935	{
AzureIoTClient	12:658ca6865de2	936	LogError("Failed constructing get Prop topic.");
AzureIoTClient	12:658ca6865de2	937	free(mqtt_info);
AzureIoTClient	18:ec8e5e97c6a4	938	result = __FAILURE__;
AzureIoTClient	12:658ca6865de2	939	}
AzureIoTClient	12:658ca6865de2	940	else
AzureIoTClient	12:658ca6865de2	941	{
AzureIoTClient	12:658ca6865de2	942	MQTT_MESSAGE_HANDLE mqtt_get_msg = mqttmessage_create(mqtt_info->packet_id, STRING_c_str(msg_topic), DELIVER_AT_MOST_ONCE, NULL, 0);
AzureIoTClient	12:658ca6865de2	943	if (mqtt_get_msg == NULL)
AzureIoTClient	12:658ca6865de2	944	{
AzureIoTClient	12:658ca6865de2	945	LogError("Failed constructing mqtt message.");
AzureIoTClient	12:658ca6865de2	946	free(mqtt_info);
AzureIoTClient	18:ec8e5e97c6a4	947	result = __FAILURE__;
AzureIoTClient	12:658ca6865de2	948	}
AzureIoTClient	12:658ca6865de2	949	else
AzureIoTClient	12:658ca6865de2	950	{
AzureIoTClient	12:658ca6865de2	951	if (mqtt_client_publish(transport_data->mqttClient, mqtt_get_msg) != 0)
AzureIoTClient	12:658ca6865de2	952	{
AzureIoTClient	12:658ca6865de2	953	LogError("Failed publishing to mqtt client.");
AzureIoTClient	12:658ca6865de2	954	free(mqtt_info);
AzureIoTClient	18:ec8e5e97c6a4	955	result = __FAILURE__;
AzureIoTClient	12:658ca6865de2	956	}
AzureIoTClient	12:658ca6865de2	957	else
AzureIoTClient	12:658ca6865de2	958	{
AzureIoTClient	12:658ca6865de2	959	DList_InsertTailList(&transport_data->ack_waiting_queue, &mqtt_info->entry);
AzureIoTClient	12:658ca6865de2	960	result = 0;
AzureIoTClient	12:658ca6865de2	961	}
AzureIoTClient	12:658ca6865de2	962	mqttmessage_destroy(mqtt_get_msg);
AzureIoTClient	12:658ca6865de2	963	}
AzureIoTClient	12:658ca6865de2	964	STRING_delete(msg_topic);
AzureIoTClient	12:658ca6865de2	965	}
AzureIoTClient	12:658ca6865de2	966	}
AzureIoTClient	12:658ca6865de2	967	return result;
AzureIoTClient	12:658ca6865de2	968	}
AzureIoTClient	12:658ca6865de2	969
AzureIoTClient	12:658ca6865de2	970	static int publish_device_twin_message(MQTTTRANSPORT_HANDLE_DATA* transport_data, IOTHUB_DEVICE_TWIN* device_twin_info, MQTT_DEVICE_TWIN_ITEM* mqtt_info)
AzureIoTClient	12:658ca6865de2	971	{
AzureIoTClient	12:658ca6865de2	972	int result;
AzureIoTClient	12:658ca6865de2	973	mqtt_info->packet_id = get_next_packet_id(transport_data);
AzureIoTClient	12:658ca6865de2	974	mqtt_info->device_twin_msg_type = REPORTED_STATE;
AzureIoTClient	12:658ca6865de2	975	STRING_HANDLE msgTopic = STRING_construct_sprintf(REPORTED_PROPERTIES_TOPIC, mqtt_info->packet_id);
AzureIoTClient	12:658ca6865de2	976	if (msgTopic == NULL)
AzureIoTClient	12:658ca6865de2	977	{
AzureIoTClient	12:658ca6865de2	978	LogError("Failed constructing reported prop topic.");
AzureIoTClient	18:ec8e5e97c6a4	979	result = __FAILURE__;
AzureIoTClient	12:658ca6865de2	980	}
AzureIoTClient	12:658ca6865de2	981	else
AzureIoTClient	12:658ca6865de2	982	{
AzureIoTClient	12:658ca6865de2	983	const CONSTBUFFER* data_buff = CONSTBUFFER_GetContent(device_twin_info->report_data_handle);
AzureIoTClient	12:658ca6865de2	984	MQTT_MESSAGE_HANDLE mqtt_rpt_msg = mqttmessage_create(mqtt_info->packet_id, STRING_c_str(msgTopic), DELIVER_AT_MOST_ONCE, data_buff->buffer, data_buff->size);
AzureIoTClient	12:658ca6865de2	985	if (mqtt_rpt_msg == NULL)
AzureIoTClient	12:658ca6865de2	986	{
AzureIoTClient	12:658ca6865de2	987	LogError("Failed creating mqtt message");
AzureIoTClient	18:ec8e5e97c6a4	988	result = __FAILURE__;
AzureIoTClient	12:658ca6865de2	989	}
AzureIoTClient	12:658ca6865de2	990	else
AzureIoTClient	12:658ca6865de2	991	{
Azure.IoT.Build	13:606465879c57	992	if (tickcounter_get_current_ms(transport_data->msgTickCounter, &mqtt_info->msgPublishTime) != 0)
AzureIoTClient	12:658ca6865de2	993	{
AzureIoTClient	12:658ca6865de2	994	LogError("Failed retrieving tickcounter info");
AzureIoTClient	18:ec8e5e97c6a4	995	result = __FAILURE__;
AzureIoTClient	12:658ca6865de2	996	}
AzureIoTClient	12:658ca6865de2	997	else
AzureIoTClient	12:658ca6865de2	998	{
AzureIoTClient	12:658ca6865de2	999	if (mqtt_client_publish(transport_data->mqttClient, mqtt_rpt_msg) != 0)
AzureIoTClient	12:658ca6865de2	1000	{
AzureIoTClient	12:658ca6865de2	1001	LogError("Failed publishing mqtt message");
AzureIoTClient	18:ec8e5e97c6a4	1002	result = __FAILURE__;
AzureIoTClient	12:658ca6865de2	1003	}
AzureIoTClient	12:658ca6865de2	1004	else
AzureIoTClient	12:658ca6865de2	1005	{
AzureIoTClient	12:658ca6865de2	1006	mqtt_info->retryCount++;
AzureIoTClient	12:658ca6865de2	1007	result = 0;
AzureIoTClient	12:658ca6865de2	1008	}
AzureIoTClient	12:658ca6865de2	1009	}
AzureIoTClient	12:658ca6865de2	1010	mqttmessage_destroy(mqtt_rpt_msg);
AzureIoTClient	12:658ca6865de2	1011	}
AzureIoTClient	12:658ca6865de2	1012	STRING_delete(msgTopic);
AzureIoTClient	12:658ca6865de2	1013	}
AzureIoTClient	12:658ca6865de2	1014	return result;
AzureIoTClient	12:658ca6865de2	1015	}
AzureIoTClient	12:658ca6865de2	1016
AzureIoTClient	11:31ebaeb51e1e	1017	static bool isSystemProperty(const char* tokenData)
AzureIoTClient	11:31ebaeb51e1e	1018	{
AzureIoTClient	11:31ebaeb51e1e	1019	bool result = false;
AzureIoTClient	11:31ebaeb51e1e	1020	size_t propCount = sizeof(sysPropList)/sizeof(sysPropList[0]);
AzureIoTClient	16:14640ee83e99	1021	size_t index = 0;
AzureIoTClient	16:14640ee83e99	1022	for (index = 0; index < propCount; index++)
AzureIoTClient	11:31ebaeb51e1e	1023	{
AzureIoTClient	11:31ebaeb51e1e	1024	if (memcmp(tokenData, sysPropList[index].propName, sysPropList[index].propLength) == 0)
AzureIoTClient	11:31ebaeb51e1e	1025	{
AzureIoTClient	11:31ebaeb51e1e	1026	result = true;
AzureIoTClient	11:31ebaeb51e1e	1027	break;
AzureIoTClient	11:31ebaeb51e1e	1028	}
AzureIoTClient	11:31ebaeb51e1e	1029	}
AzureIoTClient	11:31ebaeb51e1e	1030	return result;
AzureIoTClient	11:31ebaeb51e1e	1031	}
AzureIoTClient	11:31ebaeb51e1e	1032
AzureIoTClient	11:31ebaeb51e1e	1033	static int extractMqttProperties(IOTHUB_MESSAGE_HANDLE IoTHubMessage, const char* topic_name)
AzureIoTClient	11:31ebaeb51e1e	1034	{
AzureIoTClient	11:31ebaeb51e1e	1035	int result;
AzureIoTClient	11:31ebaeb51e1e	1036	STRING_HANDLE mqttTopic = STRING_construct(topic_name);
AzureIoTClient	11:31ebaeb51e1e	1037	if (mqttTopic == NULL)
AzureIoTClient	11:31ebaeb51e1e	1038	{
AzureIoTClient	11:31ebaeb51e1e	1039	LogError("Failure constructing string topic name.");
AzureIoTClient	18:ec8e5e97c6a4	1040	result = __FAILURE__;
AzureIoTClient	11:31ebaeb51e1e	1041	}
AzureIoTClient	11:31ebaeb51e1e	1042	else
AzureIoTClient	11:31ebaeb51e1e	1043	{
AzureIoTClient	11:31ebaeb51e1e	1044	STRING_TOKENIZER_HANDLE token = STRING_TOKENIZER_create(mqttTopic);
AzureIoTClient	11:31ebaeb51e1e	1045	if (token != NULL)
AzureIoTClient	11:31ebaeb51e1e	1046	{
AzureIoTClient	11:31ebaeb51e1e	1047	MAP_HANDLE propertyMap = IoTHubMessage_Properties(IoTHubMessage);
AzureIoTClient	11:31ebaeb51e1e	1048	if (propertyMap == NULL)
AzureIoTClient	11:31ebaeb51e1e	1049	{
AzureIoTClient	11:31ebaeb51e1e	1050	LogError("Failure to retrieve IoTHubMessage_properties.");
AzureIoTClient	18:ec8e5e97c6a4	1051	result = __FAILURE__;
AzureIoTClient	11:31ebaeb51e1e	1052	}
AzureIoTClient	11:31ebaeb51e1e	1053	else
AzureIoTClient	11:31ebaeb51e1e	1054	{
AzureIoTClient	11:31ebaeb51e1e	1055	STRING_HANDLE output = STRING_new();
AzureIoTClient	11:31ebaeb51e1e	1056	if (output == NULL)
AzureIoTClient	11:31ebaeb51e1e	1057	{
AzureIoTClient	11:31ebaeb51e1e	1058	LogError("Failure to allocate STRING_new.");
AzureIoTClient	18:ec8e5e97c6a4	1059	result = __FAILURE__;
AzureIoTClient	11:31ebaeb51e1e	1060	}
AzureIoTClient	11:31ebaeb51e1e	1061	else
AzureIoTClient	11:31ebaeb51e1e	1062	{
AzureIoTClient	11:31ebaeb51e1e	1063	result = 0;
AzureIoTClient	18:ec8e5e97c6a4	1064
AzureIoTClient	11:31ebaeb51e1e	1065	while (STRING_TOKENIZER_get_next_token(token, output, PROPERTY_SEPARATOR) == 0 && result == 0)
AzureIoTClient	11:31ebaeb51e1e	1066	{
AzureIoTClient	11:31ebaeb51e1e	1067	const char* tokenData = STRING_c_str(output);
AzureIoTClient	11:31ebaeb51e1e	1068	size_t tokenLen = strlen(tokenData);
AzureIoTClient	11:31ebaeb51e1e	1069	if (tokenData == NULL \|\| tokenLen == 0)
AzureIoTClient	11:31ebaeb51e1e	1070	{
AzureIoTClient	11:31ebaeb51e1e	1071	break;
AzureIoTClient	11:31ebaeb51e1e	1072	}
AzureIoTClient	11:31ebaeb51e1e	1073	else
AzureIoTClient	11:31ebaeb51e1e	1074	{
AzureIoTClient	18:ec8e5e97c6a4	1075	if (isSystemProperty(tokenData))
AzureIoTClient	11:31ebaeb51e1e	1076	{
AzureIoTClient	11:31ebaeb51e1e	1077	const char* iterator = tokenData;
AzureIoTClient	11:31ebaeb51e1e	1078	while (iterator != NULL && *iterator != '\0' && result == 0)
AzureIoTClient	11:31ebaeb51e1e	1079	{
AzureIoTClient	11:31ebaeb51e1e	1080	if (*iterator == '=')
AzureIoTClient	11:31ebaeb51e1e	1081	{
AzureIoTClient	11:31ebaeb51e1e	1082	size_t nameLen = iterator - tokenData;
AzureIoTClient	11:31ebaeb51e1e	1083	char* propName = malloc(nameLen + 1);
AzureIoTClient	11:31ebaeb51e1e	1084
AzureIoTClient	11:31ebaeb51e1e	1085	size_t valLen = tokenLen - (nameLen + 1) + 1;
AzureIoTClient	11:31ebaeb51e1e	1086	char* propValue = malloc(valLen + 1);
AzureIoTClient	11:31ebaeb51e1e	1087
AzureIoTClient	11:31ebaeb51e1e	1088	if (propName == NULL \|\| propValue == NULL)
AzureIoTClient	11:31ebaeb51e1e	1089	{
AzureIoTClient	18:ec8e5e97c6a4	1090	result = __FAILURE__;
AzureIoTClient	18:ec8e5e97c6a4	1091	}
AzureIoTClient	18:ec8e5e97c6a4	1092	else
AzureIoTClient	18:ec8e5e97c6a4	1093	{
AzureIoTClient	18:ec8e5e97c6a4	1094	strncpy(propName, tokenData, nameLen);
AzureIoTClient	18:ec8e5e97c6a4	1095	propName[nameLen] = '\0';
AzureIoTClient	18:ec8e5e97c6a4	1096
AzureIoTClient	18:ec8e5e97c6a4	1097	strncpy(propValue, iterator + 1, valLen);
AzureIoTClient	18:ec8e5e97c6a4	1098	propValue[valLen] = '\0';
AzureIoTClient	18:ec8e5e97c6a4	1099
AzureIoTClient	18:ec8e5e97c6a4	1100	if (nameLen > 3)
AzureIoTClient	18:ec8e5e97c6a4	1101	{
AzureIoTClient	18:ec8e5e97c6a4	1102	if (strcmp((const char*)&propName[nameLen - 3], MESSAGE_ID_PROPERTY) == 0)
AzureIoTClient	18:ec8e5e97c6a4	1103	{
AzureIoTClient	18:ec8e5e97c6a4	1104	if (IoTHubMessage_SetMessageId(IoTHubMessage, propValue) != IOTHUB_MESSAGE_OK)
AzureIoTClient	18:ec8e5e97c6a4	1105	{
AzureIoTClient	18:ec8e5e97c6a4	1106	LogError("Failed to set IOTHUB_MESSAGE_HANDLE 'messageId' property.");
AzureIoTClient	18:ec8e5e97c6a4	1107	result = __FAILURE__;
AzureIoTClient	18:ec8e5e97c6a4	1108	}
AzureIoTClient	18:ec8e5e97c6a4	1109	}
AzureIoTClient	18:ec8e5e97c6a4	1110
AzureIoTClient	18:ec8e5e97c6a4	1111	if (strcmp((const char*)&propName[nameLen - 3], CORRELATION_ID_PROPERTY) == 0)
AzureIoTClient	18:ec8e5e97c6a4	1112	{
AzureIoTClient	18:ec8e5e97c6a4	1113	if (IoTHubMessage_SetCorrelationId(IoTHubMessage, propValue) != IOTHUB_MESSAGE_OK)
AzureIoTClient	18:ec8e5e97c6a4	1114	{
AzureIoTClient	18:ec8e5e97c6a4	1115	LogError("Failed to set IOTHUB_MESSAGE_HANDLE 'correlationId' property.");
AzureIoTClient	18:ec8e5e97c6a4	1116	result = __FAILURE__;
AzureIoTClient	18:ec8e5e97c6a4	1117	}
AzureIoTClient	18:ec8e5e97c6a4	1118	}
AzureIoTClient	18:ec8e5e97c6a4	1119	}
AzureIoTClient	18:ec8e5e97c6a4	1120	}
AzureIoTClient	18:ec8e5e97c6a4	1121	free(propName);
AzureIoTClient	18:ec8e5e97c6a4	1122	free(propValue);
AzureIoTClient	18:ec8e5e97c6a4	1123
AzureIoTClient	18:ec8e5e97c6a4	1124	break;
AzureIoTClient	18:ec8e5e97c6a4	1125	}
AzureIoTClient	18:ec8e5e97c6a4	1126	iterator++;
AzureIoTClient	18:ec8e5e97c6a4	1127	}
AzureIoTClient	18:ec8e5e97c6a4	1128	}
AzureIoTClient	18:ec8e5e97c6a4	1129	else
AzureIoTClient	18:ec8e5e97c6a4	1130	{
AzureIoTClient	18:ec8e5e97c6a4	1131	const char* iterator = tokenData;
AzureIoTClient	18:ec8e5e97c6a4	1132	while (iterator != NULL && *iterator != '\0' && result == 0)
AzureIoTClient	18:ec8e5e97c6a4	1133	{
AzureIoTClient	18:ec8e5e97c6a4	1134	if (*iterator == '=')
AzureIoTClient	18:ec8e5e97c6a4	1135	{
AzureIoTClient	18:ec8e5e97c6a4	1136	size_t nameLen = iterator - tokenData;
AzureIoTClient	18:ec8e5e97c6a4	1137	char* propName = malloc(nameLen + 1);
AzureIoTClient	18:ec8e5e97c6a4	1138
AzureIoTClient	18:ec8e5e97c6a4	1139	size_t valLen = tokenLen - (nameLen + 1) + 1;
AzureIoTClient	18:ec8e5e97c6a4	1140	char* propValue = malloc(valLen + 1);
AzureIoTClient	18:ec8e5e97c6a4	1141
AzureIoTClient	18:ec8e5e97c6a4	1142	if (propName == NULL \|\| propValue == NULL)
AzureIoTClient	18:ec8e5e97c6a4	1143	{
AzureIoTClient	18:ec8e5e97c6a4	1144	result = __FAILURE__;
AzureIoTClient	11:31ebaeb51e1e	1145	}
AzureIoTClient	11:31ebaeb51e1e	1146	else
AzureIoTClient	11:31ebaeb51e1e	1147	{
AzureIoTClient	11:31ebaeb51e1e	1148	strncpy(propName, tokenData, nameLen);
AzureIoTClient	11:31ebaeb51e1e	1149	propName[nameLen] = '\0';
AzureIoTClient	11:31ebaeb51e1e	1150
AzureIoTClient	11:31ebaeb51e1e	1151	strncpy(propValue, iterator + 1, valLen);
AzureIoTClient	11:31ebaeb51e1e	1152	propValue[valLen] = '\0';
AzureIoTClient	11:31ebaeb51e1e	1153
AzureIoTClient	11:31ebaeb51e1e	1154	if (Map_AddOrUpdate(propertyMap, propName, propValue) != MAP_OK)
AzureIoTClient	11:31ebaeb51e1e	1155	{
AzureIoTClient	11:31ebaeb51e1e	1156	LogError("Map_AddOrUpdate failed.");
AzureIoTClient	18:ec8e5e97c6a4	1157	result = __FAILURE__;
AzureIoTClient	11:31ebaeb51e1e	1158	}
AzureIoTClient	11:31ebaeb51e1e	1159	}
AzureIoTClient	11:31ebaeb51e1e	1160	free(propName);
AzureIoTClient	11:31ebaeb51e1e	1161	free(propValue);
AzureIoTClient	11:31ebaeb51e1e	1162
AzureIoTClient	11:31ebaeb51e1e	1163	break;
AzureIoTClient	11:31ebaeb51e1e	1164	}
AzureIoTClient	11:31ebaeb51e1e	1165	iterator++;
AzureIoTClient	11:31ebaeb51e1e	1166	}
AzureIoTClient	11:31ebaeb51e1e	1167	}
AzureIoTClient	11:31ebaeb51e1e	1168	}
AzureIoTClient	11:31ebaeb51e1e	1169	}
AzureIoTClient	11:31ebaeb51e1e	1170	STRING_delete(output);
AzureIoTClient	11:31ebaeb51e1e	1171	}
AzureIoTClient	11:31ebaeb51e1e	1172	}
AzureIoTClient	11:31ebaeb51e1e	1173	STRING_TOKENIZER_destroy(token);
AzureIoTClient	11:31ebaeb51e1e	1174	}
AzureIoTClient	11:31ebaeb51e1e	1175	else
AzureIoTClient	11:31ebaeb51e1e	1176	{
AzureIoTClient	11:31ebaeb51e1e	1177	LogError("Unable to create Tokenizer object.");
AzureIoTClient	18:ec8e5e97c6a4	1178	result = __FAILURE__;
AzureIoTClient	11:31ebaeb51e1e	1179	}
AzureIoTClient	11:31ebaeb51e1e	1180	STRING_delete(mqttTopic);
AzureIoTClient	11:31ebaeb51e1e	1181	}
AzureIoTClient	11:31ebaeb51e1e	1182	return result;
AzureIoTClient	11:31ebaeb51e1e	1183	}
AzureIoTClient	11:31ebaeb51e1e	1184
AzureIoTClient	11:31ebaeb51e1e	1185	static void mqtt_notification_callback(MQTT_MESSAGE_HANDLE msgHandle, void* callbackCtx)
AzureIoTClient	11:31ebaeb51e1e	1186	{
AzureIoTClient	14:4dc2b011be33	1187	/* Tests_SRS_IOTHUB_MQTT_TRANSPORT_07_051: [ If msgHandle or callbackCtx is NULL, mqtt_notification_callback shall do nothing. ] */
AzureIoTClient	11:31ebaeb51e1e	1188	if (msgHandle != NULL && callbackCtx != NULL)
AzureIoTClient	11:31ebaeb51e1e	1189	{
AzureIoTClient	14:4dc2b011be33	1190	/* Tests_SRS_IOTHUB_MQTT_TRANSPORT_07_052: [ mqtt_notification_callback shall extract the topic Name from the MQTT_MESSAGE_HANDLE. ] */
AzureIoTClient	11:31ebaeb51e1e	1191	const char* topic_resp = mqttmessage_getTopicName(msgHandle);
AzureIoTClient	11:31ebaeb51e1e	1192	if (topic_resp == NULL)
AzureIoTClient	11:31ebaeb51e1e	1193	{
AzureIoTClient	11:31ebaeb51e1e	1194	LogError("Failure: NULL topic name encountered");
AzureIoTClient	11:31ebaeb51e1e	1195	}
AzureIoTClient	11:31ebaeb51e1e	1196	else
AzureIoTClient	11:31ebaeb51e1e	1197	{
AzureIoTClient	11:31ebaeb51e1e	1198	PMQTTTRANSPORT_HANDLE_DATA transportData = (PMQTTTRANSPORT_HANDLE_DATA)callbackCtx;
AzureIoTClient	11:31ebaeb51e1e	1199
AzureIoTClient	12:658ca6865de2	1200	IOTHUB_IDENTITY_TYPE type = retrieve_topic_type(topic_resp);
AzureIoTClient	12:658ca6865de2	1201	if (type == IOTHUB_TYPE_DEVICE_TWIN)
AzureIoTClient	11:31ebaeb51e1e	1202	{
AzureIoTClient	12:658ca6865de2	1203	size_t request_id;
AzureIoTClient	12:658ca6865de2	1204	int status_code;
AzureIoTClient	12:658ca6865de2	1205	bool notification_msg;
AzureIoTClient	12:658ca6865de2	1206	if (parse_device_twin_topic_info(topic_resp, &notification_msg, &request_id, &status_code) != 0)
AzureIoTClient	12:658ca6865de2	1207	{
AzureIoTClient	12:658ca6865de2	1208	LogError("Failure: parsing device topic info");
AzureIoTClient	12:658ca6865de2	1209	}
AzureIoTClient	12:658ca6865de2	1210	else
AzureIoTClient	12:658ca6865de2	1211	{
AzureIoTClient	12:658ca6865de2	1212	const APP_PAYLOAD* payload = mqttmessage_getApplicationMsg(msgHandle);
AzureIoTClient	12:658ca6865de2	1213	if (notification_msg)
AzureIoTClient	12:658ca6865de2	1214	{
AzureIoTClient	12:658ca6865de2	1215	IoTHubClient_LL_RetrievePropertyComplete(transportData->llClientHandle, DEVICE_TWIN_UPDATE_PARTIAL, payload->message, payload->length);
AzureIoTClient	12:658ca6865de2	1216	}
AzureIoTClient	12:658ca6865de2	1217	else
AzureIoTClient	12:658ca6865de2	1218	{
AzureIoTClient	12:658ca6865de2	1219	PDLIST_ENTRY dev_twin_item = transportData->ack_waiting_queue.Flink;
AzureIoTClient	12:658ca6865de2	1220	while (dev_twin_item != &transportData->ack_waiting_queue)
AzureIoTClient	12:658ca6865de2	1221	{
AzureIoTClient	12:658ca6865de2	1222	DLIST_ENTRY saveListEntry;
AzureIoTClient	12:658ca6865de2	1223	saveListEntry.Flink = dev_twin_item->Flink;
AzureIoTClient	12:658ca6865de2	1224	MQTT_DEVICE_TWIN_ITEM* msg_entry = containingRecord(dev_twin_item, MQTT_DEVICE_TWIN_ITEM, entry);
AzureIoTClient	12:658ca6865de2	1225	if (request_id == msg_entry->packet_id)
AzureIoTClient	12:658ca6865de2	1226	{
AzureIoTClient	12:658ca6865de2	1227	(void)DList_RemoveEntryList(dev_twin_item);
AzureIoTClient	12:658ca6865de2	1228	if (msg_entry->device_twin_msg_type == RETRIEVE_PROPERTIES)
AzureIoTClient	12:658ca6865de2	1229	{
AzureIoTClient	14:4dc2b011be33	1230	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_054: [ If type is IOTHUB_TYPE_DEVICE_TWIN, then on success if msg_type is RETRIEVE_PROPERTIES then mqtt_notification_callback shall call IoTHubClient_LL_RetrievePropertyComplete... ] */
AzureIoTClient	12:658ca6865de2	1231	IoTHubClient_LL_RetrievePropertyComplete(transportData->llClientHandle, DEVICE_TWIN_UPDATE_COMPLETE, payload->message, payload->length);
AzureIoTClient	12:658ca6865de2	1232	}
AzureIoTClient	12:658ca6865de2	1233	else
AzureIoTClient	12:658ca6865de2	1234	{
AzureIoTClient	14:4dc2b011be33	1235	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_055: [ if device_twin_msg_type is not RETRIEVE_PROPERTIES then mqtt_notification_callback shall call IoTHubClient_LL_ReportedStateComplete ] */
AzureIoTClient	12:658ca6865de2	1236	IoTHubClient_LL_ReportedStateComplete(transportData->llClientHandle, msg_entry->iothub_msg_id, status_code);
AzureIoTClient	12:658ca6865de2	1237	}
AzureIoTClient	12:658ca6865de2	1238	free(msg_entry);
AzureIoTClient	12:658ca6865de2	1239	break;
AzureIoTClient	12:658ca6865de2	1240	}
AzureIoTClient	12:658ca6865de2	1241	dev_twin_item = saveListEntry.Flink;
AzureIoTClient	12:658ca6865de2	1242	}
AzureIoTClient	12:658ca6865de2	1243	}
AzureIoTClient	12:658ca6865de2	1244	}
AzureIoTClient	12:658ca6865de2	1245	}
AzureIoTClient	12:658ca6865de2	1246	else if (type == IOTHUB_TYPE_DEVICE_METHODS)
AzureIoTClient	12:658ca6865de2	1247	{
AzureIoTClient	12:658ca6865de2	1248	STRING_HANDLE method_name = STRING_new();
AzureIoTClient	12:658ca6865de2	1249	if (method_name == NULL)
AzureIoTClient	12:658ca6865de2	1250	{
AzureIoTClient	12:658ca6865de2	1251	LogError("Failure: allocating method_name string value");
AzureIoTClient	12:658ca6865de2	1252	}
AzureIoTClient	12:658ca6865de2	1253	else
AzureIoTClient	12:658ca6865de2	1254	{
AzureIoTClient	14:4dc2b011be33	1255	DEVICE_METHOD_INFO* dev_method_info = malloc(sizeof(DEVICE_METHOD_INFO) );
AzureIoTClient	14:4dc2b011be33	1256	if (dev_method_info == NULL)
AzureIoTClient	12:658ca6865de2	1257	{
AzureIoTClient	14:4dc2b011be33	1258	LogError("Failure: allocating DEVICE_METHOD_INFO object");
AzureIoTClient	12:658ca6865de2	1259	}
AzureIoTClient	12:658ca6865de2	1260	else
AzureIoTClient	12:658ca6865de2	1261	{
AzureIoTClient	14:4dc2b011be33	1262	dev_method_info->request_id = STRING_new();
AzureIoTClient	14:4dc2b011be33	1263	if (dev_method_info->request_id == NULL)
AzureIoTClient	14:4dc2b011be33	1264	{
AzureIoTClient	14:4dc2b011be33	1265	LogError("Failure constructing request_id string");
AzureIoTClient	14:4dc2b011be33	1266	free(dev_method_info);
AzureIoTClient	14:4dc2b011be33	1267	}
AzureIoTClient	14:4dc2b011be33	1268	else if (retrieve_device_method_rid_info(topic_resp, method_name, dev_method_info->request_id) != 0)
AzureIoTClient	12:658ca6865de2	1269	{
AzureIoTClient	14:4dc2b011be33	1270	LogError("Failure: retrieve device topic info");
AzureIoTClient	14:4dc2b011be33	1271	STRING_delete(dev_method_info->request_id);
AzureIoTClient	14:4dc2b011be33	1272	free(dev_method_info);
AzureIoTClient	12:658ca6865de2	1273	}
AzureIoTClient	14:4dc2b011be33	1274	else
AzureIoTClient	14:4dc2b011be33	1275	{
AzureIoTClient	14:4dc2b011be33	1276	/* CodesSRS_IOTHUB_MQTT_TRANSPORT_07_053: [ If type is IOTHUB_TYPE_DEVICE_METHODS, then on success mqtt_notification_callback shall call IoTHubClient_LL_DeviceMethodComplete. ] */
AzureIoTClient	14:4dc2b011be33	1277	const APP_PAYLOAD* payload = mqttmessage_getApplicationMsg(msgHandle);
AzureIoTClient	14:4dc2b011be33	1278	if (IoTHubClient_LL_DeviceMethodComplete(transportData->llClientHandle, STRING_c_str(method_name), payload->message, payload->length, (void*)dev_method_info) != 0)
AzureIoTClient	14:4dc2b011be33	1279	{
AzureIoTClient	14:4dc2b011be33	1280	LogError("Failure: IoTHubClient_LL_DeviceMethodComplete");
AzureIoTClient	14:4dc2b011be33	1281	STRING_delete(dev_method_info->request_id);
AzureIoTClient	14:4dc2b011be33	1282	free(dev_method_info);
AzureIoTClient	14:4dc2b011be33	1283	}
AzureIoTClient	14:4dc2b011be33	1284	}
AzureIoTClient	12:658ca6865de2	1285	}
AzureIoTClient	12:658ca6865de2	1286	STRING_delete(method_name);
AzureIoTClient	12:658ca6865de2	1287	}
AzureIoTClient	11:31ebaeb51e1e	1288	}
AzureIoTClient	11:31ebaeb51e1e	1289	else
AzureIoTClient	11:31ebaeb51e1e	1290	{
AzureIoTClient	12:658ca6865de2	1291	const APP_PAYLOAD* appPayload = mqttmessage_getApplicationMsg(msgHandle);
AzureIoTClient	12:658ca6865de2	1292	IOTHUB_MESSAGE_HANDLE IoTHubMessage = IoTHubMessage_CreateFromByteArray(appPayload->message, appPayload->length);
AzureIoTClient	12:658ca6865de2	1293	if (IoTHubMessage == NULL)
AzureIoTClient	11:31ebaeb51e1e	1294	{
AzureIoTClient	12:658ca6865de2	1295	LogError("Failure: IotHub Message creation has failed.");
AzureIoTClient	11:31ebaeb51e1e	1296	}
AzureIoTClient	11:31ebaeb51e1e	1297	else
AzureIoTClient	11:31ebaeb51e1e	1298	{
AzureIoTClient	12:658ca6865de2	1299	// Will need to update this when the service has messages that can be rejected
AzureIoTClient	12:658ca6865de2	1300	if (extractMqttProperties(IoTHubMessage, topic_resp) != 0)
AzureIoTClient	12:658ca6865de2	1301	{
AzureIoTClient	12:658ca6865de2	1302	LogError("failure extracting mqtt properties.");
AzureIoTClient	12:658ca6865de2	1303	}
AzureIoTClient	12:658ca6865de2	1304	else
AzureIoTClient	11:31ebaeb51e1e	1305	{
AzureIoTClient	19:f87dfe76bc70	1306	MESSAGE_CALLBACK_INFO* messageData = (MESSAGE_CALLBACK_INFO*)malloc(sizeof(MESSAGE_CALLBACK_INFO));
AzureIoTClient	19:f87dfe76bc70	1307	if (messageData == NULL)
AzureIoTClient	19:f87dfe76bc70	1308	{
AzureIoTClient	19:f87dfe76bc70	1309	LogError("malloc failed");
AzureIoTClient	19:f87dfe76bc70	1310	}
AzureIoTClient	19:f87dfe76bc70	1311	else
AzureIoTClient	12:658ca6865de2	1312	{
AzureIoTClient	19:f87dfe76bc70	1313	messageData->messageHandle = IoTHubMessage;
AzureIoTClient	19:f87dfe76bc70	1314	messageData->transportContext = NULL;
AzureIoTClient	19:f87dfe76bc70	1315
AzureIoTClient	19:f87dfe76bc70	1316	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_056: [ If type is IOTHUB_TYPE_TELEMETRY, then on success mqtt_notification_callback shall call IoTHubClient_LL_MessageCallback. ] */
AzureIoTClient	19:f87dfe76bc70	1317	if (!IoTHubClient_LL_MessageCallback(transportData->llClientHandle, messageData))
AzureIoTClient	19:f87dfe76bc70	1318	{
AzureIoTClient	21:167f8fcf6fb1	1319	LogError("IoTHubClient_LL_MessageCallback returned false");
AzureIoTClient	19:f87dfe76bc70	1320
AzureIoTClient	19:f87dfe76bc70	1321	IoTHubMessage_Destroy(IoTHubMessage);
AzureIoTClient	19:f87dfe76bc70	1322	free(messageData);
AzureIoTClient	19:f87dfe76bc70	1323	}
AzureIoTClient	12:658ca6865de2	1324	}
AzureIoTClient	11:31ebaeb51e1e	1325	}
AzureIoTClient	11:31ebaeb51e1e	1326	}
AzureIoTClient	11:31ebaeb51e1e	1327	}
AzureIoTClient	11:31ebaeb51e1e	1328	}
AzureIoTClient	11:31ebaeb51e1e	1329	}
AzureIoTClient	11:31ebaeb51e1e	1330	}
AzureIoTClient	11:31ebaeb51e1e	1331
AzureIoTClient	11:31ebaeb51e1e	1332	static void mqtt_operation_complete_callback(MQTT_CLIENT_HANDLE handle, MQTT_CLIENT_EVENT_RESULT actionResult, const void* msgInfo, void* callbackCtx)
AzureIoTClient	11:31ebaeb51e1e	1333	{
AzureIoTClient	11:31ebaeb51e1e	1334	(void)handle;
AzureIoTClient	11:31ebaeb51e1e	1335	if (callbackCtx != NULL)
AzureIoTClient	11:31ebaeb51e1e	1336	{
AzureIoTClient	11:31ebaeb51e1e	1337	PMQTTTRANSPORT_HANDLE_DATA transport_data = (PMQTTTRANSPORT_HANDLE_DATA)callbackCtx;
AzureIoTClient	11:31ebaeb51e1e	1338
AzureIoTClient	11:31ebaeb51e1e	1339	switch (actionResult)
AzureIoTClient	11:31ebaeb51e1e	1340	{
AzureIoTClient	11:31ebaeb51e1e	1341	case MQTT_CLIENT_ON_PUBLISH_ACK:
AzureIoTClient	11:31ebaeb51e1e	1342	case MQTT_CLIENT_ON_PUBLISH_COMP:
AzureIoTClient	11:31ebaeb51e1e	1343	{
AzureIoTClient	11:31ebaeb51e1e	1344	const PUBLISH_ACK* puback = (const PUBLISH_ACK*)msgInfo;
AzureIoTClient	11:31ebaeb51e1e	1345	if (puback != NULL)
AzureIoTClient	11:31ebaeb51e1e	1346	{
AzureIoTClient	11:31ebaeb51e1e	1347	PDLIST_ENTRY currentListEntry = transport_data->telemetry_waitingForAck.Flink;
AzureIoTClient	11:31ebaeb51e1e	1348	while (currentListEntry != &transport_data->telemetry_waitingForAck)
AzureIoTClient	11:31ebaeb51e1e	1349	{
AzureIoTClient	11:31ebaeb51e1e	1350	MQTT_MESSAGE_DETAILS_LIST* mqttMsgEntry = containingRecord(currentListEntry, MQTT_MESSAGE_DETAILS_LIST, entry);
AzureIoTClient	11:31ebaeb51e1e	1351	DLIST_ENTRY saveListEntry;
AzureIoTClient	11:31ebaeb51e1e	1352	saveListEntry.Flink = currentListEntry->Flink;
AzureIoTClient	11:31ebaeb51e1e	1353
AzureIoTClient	11:31ebaeb51e1e	1354	if (puback->packetId == mqttMsgEntry->packet_id)
AzureIoTClient	11:31ebaeb51e1e	1355	{
AzureIoTClient	11:31ebaeb51e1e	1356	(void)DList_RemoveEntryList(currentListEntry); //First remove the item from Waiting for Ack List.
AzureIoTClient	11:31ebaeb51e1e	1357	sendMsgComplete(mqttMsgEntry->iotHubMessageEntry, transport_data, IOTHUB_CLIENT_CONFIRMATION_OK);
AzureIoTClient	11:31ebaeb51e1e	1358	free(mqttMsgEntry);
AzureIoTClient	11:31ebaeb51e1e	1359	}
AzureIoTClient	11:31ebaeb51e1e	1360	currentListEntry = saveListEntry.Flink;
AzureIoTClient	11:31ebaeb51e1e	1361	}
AzureIoTClient	11:31ebaeb51e1e	1362	}
AzureIoTClient	11:31ebaeb51e1e	1363	else
AzureIoTClient	11:31ebaeb51e1e	1364	{
AzureIoTClient	11:31ebaeb51e1e	1365	LogError("Failure: MQTT_CLIENT_ON_PUBLISH_ACK publish_ack structure NULL.");
AzureIoTClient	11:31ebaeb51e1e	1366	}
AzureIoTClient	11:31ebaeb51e1e	1367	break;
AzureIoTClient	11:31ebaeb51e1e	1368	}
AzureIoTClient	11:31ebaeb51e1e	1369	case MQTT_CLIENT_ON_CONNACK:
AzureIoTClient	11:31ebaeb51e1e	1370	{
AzureIoTClient	11:31ebaeb51e1e	1371	const CONNECT_ACK* connack = (const CONNECT_ACK*)msgInfo;
AzureIoTClient	11:31ebaeb51e1e	1372	if (connack != NULL)
AzureIoTClient	11:31ebaeb51e1e	1373	{
AzureIoTClient	11:31ebaeb51e1e	1374	if (connack->returnCode == CONNECTION_ACCEPTED)
AzureIoTClient	11:31ebaeb51e1e	1375	{
AzureIoTClient	11:31ebaeb51e1e	1376	// The connect packet has been acked
AzureIoTClient	11:31ebaeb51e1e	1377	transport_data->currPacketState = CONNACK_TYPE;
AzureIoTClient	12:658ca6865de2	1378	transport_data->isRecoverableError = true;
AzureIoTClient	20:594780be216d	1379	transport_data->mqttClientStatus = MQTT_CLIENT_STATUS_CONNECTED;
AzureIoTClient	12:658ca6865de2	1380	StopRetryTimer(transport_data->retryLogic);
AzureIoTClient	19:f87dfe76bc70	1381	IoTHubClient_LL_ConnectionStatusCallBack(transport_data->llClientHandle, IOTHUB_CLIENT_CONNECTION_AUTHENTICATED, IOTHUB_CLIENT_CONNECTION_OK);
AzureIoTClient	11:31ebaeb51e1e	1382	}
AzureIoTClient	11:31ebaeb51e1e	1383	else
AzureIoTClient	11:31ebaeb51e1e	1384	{
AzureIoTClient	12:658ca6865de2	1385	if (connack->returnCode == CONN_REFUSED_BAD_USERNAME_PASSWORD)
AzureIoTClient	12:658ca6865de2	1386	{
AzureIoTClient	12:658ca6865de2	1387	transport_data->isRecoverableError = false;
AzureIoTClient	19:f87dfe76bc70	1388	IoTHubClient_LL_ConnectionStatusCallBack(transport_data->llClientHandle, IOTHUB_CLIENT_CONNECTION_UNAUTHENTICATED, IOTHUB_CLIENT_CONNECTION_BAD_CREDENTIAL);
AzureIoTClient	12:658ca6865de2	1389	}
AzureIoTClient	12:658ca6865de2	1390	else if (connack->returnCode == CONN_REFUSED_NOT_AUTHORIZED)
AzureIoTClient	12:658ca6865de2	1391	{
AzureIoTClient	19:f87dfe76bc70	1392	IoTHubClient_LL_ConnectionStatusCallBack(transport_data->llClientHandle, IOTHUB_CLIENT_CONNECTION_UNAUTHENTICATED, IOTHUB_CLIENT_CONNECTION_DEVICE_DISABLED);
AzureIoTClient	12:658ca6865de2	1393	}
AzureIoTClient	12:658ca6865de2	1394	else if (connack->returnCode == CONN_REFUSED_UNACCEPTABLE_VERSION)
AzureIoTClient	12:658ca6865de2	1395	{
AzureIoTClient	12:658ca6865de2	1396	transport_data->isRecoverableError = false;
AzureIoTClient	12:658ca6865de2	1397	}
AzureIoTClient	11:31ebaeb51e1e	1398	LogError("Connection Not Accepted: 0x%x: %s", connack->returnCode, retrieve_mqtt_return_codes(connack->returnCode) );
AzureIoTClient	11:31ebaeb51e1e	1399	(void)mqtt_client_disconnect(transport_data->mqttClient);
AzureIoTClient	20:594780be216d	1400	transport_data->mqttClientStatus = MQTT_CLIENT_STATUS_NOT_CONNECTED;
AzureIoTClient	11:31ebaeb51e1e	1401	transport_data->currPacketState = PACKET_TYPE_ERROR;
AzureIoTClient	11:31ebaeb51e1e	1402	}
AzureIoTClient	11:31ebaeb51e1e	1403	}
AzureIoTClient	11:31ebaeb51e1e	1404	else
AzureIoTClient	11:31ebaeb51e1e	1405	{
AzureIoTClient	11:31ebaeb51e1e	1406	LogError("MQTT_CLIENT_ON_CONNACK CONNACK parameter is NULL.");
AzureIoTClient	11:31ebaeb51e1e	1407	}
AzureIoTClient	11:31ebaeb51e1e	1408	break;
AzureIoTClient	11:31ebaeb51e1e	1409	}
AzureIoTClient	11:31ebaeb51e1e	1410	case MQTT_CLIENT_ON_SUBSCRIBE_ACK:
AzureIoTClient	11:31ebaeb51e1e	1411	{
AzureIoTClient	11:31ebaeb51e1e	1412	const SUBSCRIBE_ACK* suback = (const SUBSCRIBE_ACK*)msgInfo;
AzureIoTClient	11:31ebaeb51e1e	1413	if (suback != NULL)
AzureIoTClient	11:31ebaeb51e1e	1414	{
AzureIoTClient	16:14640ee83e99	1415	size_t index = 0;
AzureIoTClient	16:14640ee83e99	1416	for (index = 0; index < suback->qosCount; index++)
AzureIoTClient	11:31ebaeb51e1e	1417	{
AzureIoTClient	11:31ebaeb51e1e	1418	if (suback->qosReturn[index] == DELIVER_FAILURE)
AzureIoTClient	11:31ebaeb51e1e	1419	{
AzureIoTClient	11:31ebaeb51e1e	1420	LogError("Subscribe delivery failure of subscribe %zu", index);
AzureIoTClient	11:31ebaeb51e1e	1421	}
AzureIoTClient	11:31ebaeb51e1e	1422	}
AzureIoTClient	11:31ebaeb51e1e	1423	// The connect packet has been acked
AzureIoTClient	11:31ebaeb51e1e	1424	transport_data->currPacketState = SUBACK_TYPE;
AzureIoTClient	11:31ebaeb51e1e	1425	}
AzureIoTClient	11:31ebaeb51e1e	1426	else
AzureIoTClient	11:31ebaeb51e1e	1427	{
AzureIoTClient	11:31ebaeb51e1e	1428	LogError("Failure: MQTT_CLIENT_ON_SUBSCRIBE_ACK SUBSCRIBE_ACK parameter is NULL.");
AzureIoTClient	11:31ebaeb51e1e	1429	}
AzureIoTClient	11:31ebaeb51e1e	1430	break;
AzureIoTClient	11:31ebaeb51e1e	1431	}
AzureIoTClient	11:31ebaeb51e1e	1432	case MQTT_CLIENT_ON_PUBLISH_RECV:
AzureIoTClient	11:31ebaeb51e1e	1433	case MQTT_CLIENT_ON_PUBLISH_REL:
AzureIoTClient	11:31ebaeb51e1e	1434	{
AzureIoTClient	11:31ebaeb51e1e	1435	// Currently not used
AzureIoTClient	11:31ebaeb51e1e	1436	break;
AzureIoTClient	11:31ebaeb51e1e	1437	}
AzureIoTClient	11:31ebaeb51e1e	1438	case MQTT_CLIENT_ON_DISCONNECT:
AzureIoTClient	11:31ebaeb51e1e	1439	{
AzureIoTClient	11:31ebaeb51e1e	1440	// Close the client so we can reconnect again
AzureIoTClient	20:594780be216d	1441	transport_data->mqttClientStatus = MQTT_CLIENT_STATUS_NOT_CONNECTED;
AzureIoTClient	11:31ebaeb51e1e	1442	transport_data->currPacketState = DISCONNECT_TYPE;
AzureIoTClient	11:31ebaeb51e1e	1443	break;
AzureIoTClient	11:31ebaeb51e1e	1444	}
AzureIoTClient	17:774695cb8554	1445	case MQTT_CLIENT_ON_UNSUBSCRIBE_ACK:
AzureIoTClient	17:774695cb8554	1446	{
AzureIoTClient	17:774695cb8554	1447	break;
AzureIoTClient	17:774695cb8554	1448	}
AzureIoTClient	12:658ca6865de2	1449	}
AzureIoTClient	12:658ca6865de2	1450	}
AzureIoTClient	12:658ca6865de2	1451	}
AzureIoTClient	12:658ca6865de2	1452
AzureIoTClient	12:658ca6865de2	1453	static void mqtt_error_callback(MQTT_CLIENT_HANDLE handle, MQTT_CLIENT_EVENT_ERROR error, void* callbackCtx)
AzureIoTClient	12:658ca6865de2	1454	{
AzureIoTClient	12:658ca6865de2	1455	(void)handle;
AzureIoTClient	12:658ca6865de2	1456	if (callbackCtx != NULL)
AzureIoTClient	12:658ca6865de2	1457	{
AzureIoTClient	12:658ca6865de2	1458	PMQTTTRANSPORT_HANDLE_DATA transport_data = (PMQTTTRANSPORT_HANDLE_DATA)callbackCtx;
AzureIoTClient	12:658ca6865de2	1459	switch (error)
AzureIoTClient	12:658ca6865de2	1460	{
AzureIoTClient	12:658ca6865de2	1461	case MQTT_CLIENT_CONNECTION_ERROR:
AzureIoTClient	11:31ebaeb51e1e	1462	{
AzureIoTClient	19:f87dfe76bc70	1463	IoTHubClient_LL_ConnectionStatusCallBack(transport_data->llClientHandle, IOTHUB_CLIENT_CONNECTION_UNAUTHENTICATED, IOTHUB_CLIENT_CONNECTION_NO_NETWORK);
AzureIoTClient	12:658ca6865de2	1464	break;
AzureIoTClient	12:658ca6865de2	1465	}
AzureIoTClient	20:594780be216d	1466	case MQTT_CLIENT_COMMUNICATION_ERROR:
AzureIoTClient	20:594780be216d	1467	{
AzureIoTClient	20:594780be216d	1468	IoTHubClient_LL_ConnectionStatusCallBack(transport_data->llClientHandle, IOTHUB_CLIENT_CONNECTION_UNAUTHENTICATED, IOTHUB_CLIENT_CONNECTION_COMMUNICATION_ERROR);
AzureIoTClient	20:594780be216d	1469	break;
AzureIoTClient	20:594780be216d	1470	}
AzureIoTClient	12:658ca6865de2	1471	case MQTT_CLIENT_NO_PING_RESPONSE:
AzureIoTClient	12:658ca6865de2	1472	{
AzureIoTClient	12:658ca6865de2	1473	LogError("Mqtt Ping Response was not encountered. Reconnecting device...");
AzureIoTClient	12:658ca6865de2	1474	break;
AzureIoTClient	11:31ebaeb51e1e	1475	}
AzureIoTClient	17:774695cb8554	1476	case MQTT_CLIENT_PARSE_ERROR:
AzureIoTClient	17:774695cb8554	1477	case MQTT_CLIENT_MEMORY_ERROR:
AzureIoTClient	17:774695cb8554	1478	case MQTT_CLIENT_UNKNOWN_ERROR:
AzureIoTClient	17:774695cb8554	1479	{
AzureIoTClient	17:774695cb8554	1480	LogError("INTERNAL ERROR: unexpected error value received %s", ENUM_TO_STRING(MQTT_CLIENT_EVENT_ERROR, error));
AzureIoTClient	20:594780be216d	1481	break;
AzureIoTClient	17:774695cb8554	1482	}
AzureIoTClient	11:31ebaeb51e1e	1483	}
AzureIoTClient	20:594780be216d	1484	transport_data->mqttClientStatus = MQTT_CLIENT_STATUS_NOT_CONNECTED;
AzureIoTClient	12:658ca6865de2	1485	transport_data->currPacketState = PACKET_TYPE_ERROR;
Azure.IoT.Build	13:606465879c57	1486	transport_data->device_twin_get_sent = false;
AzureIoTClient	12:658ca6865de2	1487	if (transport_data->topic_MqttMessage != NULL)
AzureIoTClient	12:658ca6865de2	1488	{
Azure.IoT.Build	13:606465879c57	1489	transport_data->topics_ToSubscribe \|= SUBSCRIBE_TELEMETRY_TOPIC;
Azure.IoT.Build	13:606465879c57	1490	}
Azure.IoT.Build	13:606465879c57	1491	if (transport_data->topic_GetState != NULL)
Azure.IoT.Build	13:606465879c57	1492	{
Azure.IoT.Build	13:606465879c57	1493	transport_data->topics_ToSubscribe \|= SUBSCRIBE_GET_REPORTED_STATE_TOPIC;
AzureIoTClient	12:658ca6865de2	1494	}
Azure.IoT.Build	13:606465879c57	1495	if (transport_data->topic_NotifyState != NULL)
Azure.IoT.Build	13:606465879c57	1496	{
Azure.IoT.Build	13:606465879c57	1497	transport_data->topics_ToSubscribe \|= SUBSCRIBE_NOTIFICATION_STATE_TOPIC;
Azure.IoT.Build	13:606465879c57	1498	}
Azure.IoT.Build	13:606465879c57	1499	if (transport_data->topic_DeviceMethods != NULL)
Azure.IoT.Build	13:606465879c57	1500	{
Azure.IoT.Build	13:606465879c57	1501	transport_data->topics_ToSubscribe \|= SUBSCRIBE_DEVICE_METHOD_TOPIC;
Azure.IoT.Build	13:606465879c57	1502	}
Azure.IoT.Build	13:606465879c57	1503	}
AzureIoTClient	12:658ca6865de2	1504	else
AzureIoTClient	12:658ca6865de2	1505	{
AzureIoTClient	12:658ca6865de2	1506	LogError("Failure: mqtt called back with null context.");
AzureIoTClient	11:31ebaeb51e1e	1507	}
AzureIoTClient	11:31ebaeb51e1e	1508	}
AzureIoTClient	11:31ebaeb51e1e	1509
AzureIoTClient	11:31ebaeb51e1e	1510	static void SubscribeToMqttProtocol(PMQTTTRANSPORT_HANDLE_DATA transport_data)
AzureIoTClient	11:31ebaeb51e1e	1511	{
AzureIoTClient	11:31ebaeb51e1e	1512	if (transport_data->topics_ToSubscribe != UNSUBSCRIBE_FROM_TOPIC)
AzureIoTClient	11:31ebaeb51e1e	1513	{
AzureIoTClient	11:31ebaeb51e1e	1514	uint32_t topic_subscription = 0;
AzureIoTClient	11:31ebaeb51e1e	1515	size_t subscribe_count = 0;
AzureIoTClient	11:31ebaeb51e1e	1516	SUBSCRIBE_PAYLOAD subscribe[SUBSCRIBE_TOPIC_COUNT];
AzureIoTClient	11:31ebaeb51e1e	1517	if ((transport_data->topic_MqttMessage != NULL) && (SUBSCRIBE_TELEMETRY_TOPIC & transport_data->topics_ToSubscribe))
AzureIoTClient	11:31ebaeb51e1e	1518	{
AzureIoTClient	11:31ebaeb51e1e	1519	subscribe[subscribe_count].subscribeTopic = STRING_c_str(transport_data->topic_MqttMessage);
AzureIoTClient	11:31ebaeb51e1e	1520	subscribe[subscribe_count].qosReturn = DELIVER_AT_LEAST_ONCE;
AzureIoTClient	11:31ebaeb51e1e	1521	topic_subscription \|= SUBSCRIBE_TELEMETRY_TOPIC;
AzureIoTClient	11:31ebaeb51e1e	1522	subscribe_count++;
AzureIoTClient	11:31ebaeb51e1e	1523	}
AzureIoTClient	12:658ca6865de2	1524	if ((transport_data->topic_GetState != NULL) && (SUBSCRIBE_GET_REPORTED_STATE_TOPIC & transport_data->topics_ToSubscribe))
AzureIoTClient	12:658ca6865de2	1525	{
AzureIoTClient	12:658ca6865de2	1526	subscribe[subscribe_count].subscribeTopic = STRING_c_str(transport_data->topic_GetState);
AzureIoTClient	12:658ca6865de2	1527	subscribe[subscribe_count].qosReturn = DELIVER_AT_MOST_ONCE;
AzureIoTClient	12:658ca6865de2	1528	topic_subscription \|= SUBSCRIBE_GET_REPORTED_STATE_TOPIC;
AzureIoTClient	12:658ca6865de2	1529	subscribe_count++;
AzureIoTClient	12:658ca6865de2	1530	}
AzureIoTClient	12:658ca6865de2	1531	if ((transport_data->topic_NotifyState != NULL) && (SUBSCRIBE_NOTIFICATION_STATE_TOPIC & transport_data->topics_ToSubscribe))
AzureIoTClient	12:658ca6865de2	1532	{
AzureIoTClient	12:658ca6865de2	1533	subscribe[subscribe_count].subscribeTopic = STRING_c_str(transport_data->topic_NotifyState);
AzureIoTClient	12:658ca6865de2	1534	subscribe[subscribe_count].qosReturn = DELIVER_AT_MOST_ONCE;
AzureIoTClient	12:658ca6865de2	1535	topic_subscription \|= SUBSCRIBE_NOTIFICATION_STATE_TOPIC;
AzureIoTClient	12:658ca6865de2	1536	subscribe_count++;
AzureIoTClient	12:658ca6865de2	1537	}
AzureIoTClient	12:658ca6865de2	1538	if ((transport_data->topic_DeviceMethods != NULL) && (SUBSCRIBE_DEVICE_METHOD_TOPIC & transport_data->topics_ToSubscribe))
AzureIoTClient	12:658ca6865de2	1539	{
AzureIoTClient	12:658ca6865de2	1540	subscribe[subscribe_count].subscribeTopic = STRING_c_str(transport_data->topic_DeviceMethods);
AzureIoTClient	12:658ca6865de2	1541	subscribe[subscribe_count].qosReturn = DELIVER_AT_MOST_ONCE;
AzureIoTClient	12:658ca6865de2	1542	topic_subscription \|= SUBSCRIBE_DEVICE_METHOD_TOPIC;
AzureIoTClient	12:658ca6865de2	1543	subscribe_count++;
AzureIoTClient	12:658ca6865de2	1544	}
AzureIoTClient	11:31ebaeb51e1e	1545
AzureIoTClient	11:31ebaeb51e1e	1546	if (subscribe_count != 0)
AzureIoTClient	11:31ebaeb51e1e	1547	{
AzureIoTClient	12:658ca6865de2	1548	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_016: [IoTHubTransport_MQTT_Common_Subscribe shall call mqtt_client_subscribe to subscribe to the Message Topic.] */
AzureIoTClient	11:31ebaeb51e1e	1549	if (mqtt_client_subscribe(transport_data->mqttClient, get_next_packet_id(transport_data), subscribe, subscribe_count) != 0)
AzureIoTClient	11:31ebaeb51e1e	1550	{
AzureIoTClient	12:658ca6865de2	1551	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_017: [Upon failure IoTHubTransport_MQTT_Common_Subscribe shall return a non-zero value.] */
AzureIoTClient	11:31ebaeb51e1e	1552	LogError("Failure: mqtt_client_subscribe returned error.");
AzureIoTClient	11:31ebaeb51e1e	1553	}
AzureIoTClient	11:31ebaeb51e1e	1554	else
AzureIoTClient	11:31ebaeb51e1e	1555	{
AzureIoTClient	12:658ca6865de2	1556	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_018: [On success IoTHubTransport_MQTT_Common_Subscribe shall return 0.] */
AzureIoTClient	11:31ebaeb51e1e	1557	transport_data->topics_ToSubscribe &= ~topic_subscription;
AzureIoTClient	11:31ebaeb51e1e	1558	transport_data->currPacketState = SUBSCRIBE_TYPE;
AzureIoTClient	11:31ebaeb51e1e	1559	}
AzureIoTClient	11:31ebaeb51e1e	1560	}
AzureIoTClient	11:31ebaeb51e1e	1561	else
AzureIoTClient	11:31ebaeb51e1e	1562	{
AzureIoTClient	12:658ca6865de2	1563	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_017: [Upon failure IoTHubTransport_MQTT_Common_Subscribe shall return a non-zero value.] */
AzureIoTClient	11:31ebaeb51e1e	1564	LogError("Failure: subscribe_topic is empty.");
AzureIoTClient	11:31ebaeb51e1e	1565	}
AzureIoTClient	11:31ebaeb51e1e	1566	transport_data->currPacketState = SUBSCRIBE_TYPE;
AzureIoTClient	11:31ebaeb51e1e	1567	}
AzureIoTClient	11:31ebaeb51e1e	1568	else
AzureIoTClient	11:31ebaeb51e1e	1569	{
AzureIoTClient	11:31ebaeb51e1e	1570	transport_data->currPacketState = PUBLISH_TYPE;
AzureIoTClient	11:31ebaeb51e1e	1571	}
AzureIoTClient	11:31ebaeb51e1e	1572	}
AzureIoTClient	11:31ebaeb51e1e	1573
AzureIoTClient	11:31ebaeb51e1e	1574	static const unsigned char* RetrieveMessagePayload(IOTHUB_MESSAGE_HANDLE messageHandle, size_t* length)
AzureIoTClient	11:31ebaeb51e1e	1575	{
AzureIoTClient	11:31ebaeb51e1e	1576	const unsigned char* result;
AzureIoTClient	11:31ebaeb51e1e	1577
AzureIoTClient	11:31ebaeb51e1e	1578	IOTHUBMESSAGE_CONTENT_TYPE contentType = IoTHubMessage_GetContentType(messageHandle);
AzureIoTClient	11:31ebaeb51e1e	1579	if (contentType == IOTHUBMESSAGE_BYTEARRAY)
AzureIoTClient	11:31ebaeb51e1e	1580	{
AzureIoTClient	11:31ebaeb51e1e	1581	if (IoTHubMessage_GetByteArray(messageHandle, &result, length) != IOTHUB_MESSAGE_OK)
AzureIoTClient	11:31ebaeb51e1e	1582	{
AzureIoTClient	11:31ebaeb51e1e	1583	LogError("Failure result from IoTHubMessage_GetByteArray");
AzureIoTClient	11:31ebaeb51e1e	1584	result = NULL;
AzureIoTClient	11:31ebaeb51e1e	1585	*length = 0;
AzureIoTClient	11:31ebaeb51e1e	1586	}
AzureIoTClient	11:31ebaeb51e1e	1587	}
AzureIoTClient	11:31ebaeb51e1e	1588	else if (contentType == IOTHUBMESSAGE_STRING)
AzureIoTClient	11:31ebaeb51e1e	1589	{
AzureIoTClient	11:31ebaeb51e1e	1590	result = (const unsigned char*)IoTHubMessage_GetString(messageHandle);
AzureIoTClient	11:31ebaeb51e1e	1591	if (result == NULL)
AzureIoTClient	11:31ebaeb51e1e	1592	{
AzureIoTClient	11:31ebaeb51e1e	1593	LogError("Failure result from IoTHubMessage_GetString");
AzureIoTClient	11:31ebaeb51e1e	1594	result = NULL;
AzureIoTClient	11:31ebaeb51e1e	1595	*length = 0;
AzureIoTClient	11:31ebaeb51e1e	1596	}
AzureIoTClient	11:31ebaeb51e1e	1597	else
AzureIoTClient	11:31ebaeb51e1e	1598	{
AzureIoTClient	11:31ebaeb51e1e	1599	length = strlen((const char)result);
AzureIoTClient	11:31ebaeb51e1e	1600	}
AzureIoTClient	11:31ebaeb51e1e	1601	}
AzureIoTClient	11:31ebaeb51e1e	1602	else
AzureIoTClient	11:31ebaeb51e1e	1603	{
AzureIoTClient	11:31ebaeb51e1e	1604	result = NULL;
AzureIoTClient	11:31ebaeb51e1e	1605	*length = 0;
AzureIoTClient	11:31ebaeb51e1e	1606	}
AzureIoTClient	11:31ebaeb51e1e	1607	return result;
AzureIoTClient	11:31ebaeb51e1e	1608	}
AzureIoTClient	11:31ebaeb51e1e	1609
AzureIoTClient	11:31ebaeb51e1e	1610	static int GetTransportProviderIfNecessary(PMQTTTRANSPORT_HANDLE_DATA transport_data)
AzureIoTClient	11:31ebaeb51e1e	1611	{
AzureIoTClient	11:31ebaeb51e1e	1612	int result;
AzureIoTClient	11:31ebaeb51e1e	1613
AzureIoTClient	11:31ebaeb51e1e	1614	if (transport_data->xioTransport == NULL)
AzureIoTClient	11:31ebaeb51e1e	1615	{
AzureIoTClient	11:31ebaeb51e1e	1616	// construct address
AzureIoTClient	11:31ebaeb51e1e	1617	const char* hostAddress = STRING_c_str(transport_data->hostAddress);
AzureIoTClient	20:594780be216d	1618	MQTT_TRANSPORT_PROXY_OPTIONS mqtt_proxy_options;
AzureIoTClient	20:594780be216d	1619
AzureIoTClient	20:594780be216d	1620	/* Codes_SRS_IOTHUB_TRANSPORT_MQTT_COMMON_01_011: [ If no `proxy_data` option has been set, NULL shall be passed as the argument `mqtt_transport_proxy_options` when calling the function `get_io_transport` passed in `IoTHubTransport_MQTT_Common__Create`. ]*/
AzureIoTClient	20:594780be216d	1621	mqtt_proxy_options.host_address = transport_data->http_proxy_hostname;
AzureIoTClient	20:594780be216d	1622	mqtt_proxy_options.port = transport_data->http_proxy_port;
AzureIoTClient	20:594780be216d	1623	mqtt_proxy_options.username = transport_data->http_proxy_username;
AzureIoTClient	20:594780be216d	1624	mqtt_proxy_options.password = transport_data->http_proxy_password;
AzureIoTClient	20:594780be216d	1625
AzureIoTClient	20:594780be216d	1626	/* Codes_SRS_IOTHUB_TRANSPORT_MQTT_COMMON_01_010: [ If the `proxy_data` option has been set, the proxy options shall be filled in the argument `mqtt_transport_proxy_options` when calling the function `get_io_transport` passed in `IoTHubTransport_MQTT_Common__Create` to obtain the underlying IO handle. ]*/
AzureIoTClient	20:594780be216d	1627	transport_data->xioTransport = transport_data->get_io_transport(hostAddress, (transport_data->http_proxy_hostname == NULL) ? NULL : &mqtt_proxy_options);
AzureIoTClient	11:31ebaeb51e1e	1628	if (transport_data->xioTransport == NULL)
AzureIoTClient	11:31ebaeb51e1e	1629	{
AzureIoTClient	11:31ebaeb51e1e	1630	LogError("Unable to create the lower level TLS layer.");
AzureIoTClient	18:ec8e5e97c6a4	1631	result = __FAILURE__;
AzureIoTClient	11:31ebaeb51e1e	1632	}
AzureIoTClient	11:31ebaeb51e1e	1633	else
AzureIoTClient	11:31ebaeb51e1e	1634	{
AzureIoTClient	11:31ebaeb51e1e	1635	result = 0;
AzureIoTClient	11:31ebaeb51e1e	1636	}
AzureIoTClient	11:31ebaeb51e1e	1637	}
AzureIoTClient	11:31ebaeb51e1e	1638	else
AzureIoTClient	11:31ebaeb51e1e	1639	{
AzureIoTClient	11:31ebaeb51e1e	1640	result = 0;
AzureIoTClient	11:31ebaeb51e1e	1641	}
AzureIoTClient	11:31ebaeb51e1e	1642	return result;
AzureIoTClient	11:31ebaeb51e1e	1643	}
AzureIoTClient	11:31ebaeb51e1e	1644
AzureIoTClient	11:31ebaeb51e1e	1645	static int SendMqttConnectMsg(PMQTTTRANSPORT_HANDLE_DATA transport_data)
AzureIoTClient	11:31ebaeb51e1e	1646	{
AzureIoTClient	11:31ebaeb51e1e	1647	int result;
AzureIoTClient	11:31ebaeb51e1e	1648
AzureIoTClient	21:167f8fcf6fb1	1649	char* sasToken = NULL;
AzureIoTClient	21:167f8fcf6fb1	1650	result = 0;
AzureIoTClient	21:167f8fcf6fb1	1651
AzureIoTClient	21:167f8fcf6fb1	1652	IOTHUB_CREDENTIAL_TYPE cred_type = IoTHubClient_Auth_Get_Credential_Type(transport_data->authorization_module);
AzureIoTClient	21:167f8fcf6fb1	1653	if (cred_type == IOTHUB_CREDENTIAL_TYPE_DEVICE_KEY)
AzureIoTClient	11:31ebaeb51e1e	1654	{
AzureIoTClient	21:167f8fcf6fb1	1655	size_t secSinceEpoch = (size_t)(difftime(get_time(NULL), EPOCH_TIME_T_VALUE) + 0);
AzureIoTClient	21:167f8fcf6fb1	1656	size_t expiryTime = secSinceEpoch + SAS_TOKEN_DEFAULT_LIFETIME;
AzureIoTClient	21:167f8fcf6fb1	1657	sasToken = IoTHubClient_Auth_Get_SasToken(transport_data->authorization_module, STRING_c_str(transport_data->devicesPath), expiryTime);
AzureIoTClient	21:167f8fcf6fb1	1658	if (sasToken == NULL)
AzureIoTClient	21:167f8fcf6fb1	1659	{
AzureIoTClient	21:167f8fcf6fb1	1660	LogError("failure getting sas Token.");
AzureIoTClient	21:167f8fcf6fb1	1661	result = __FAILURE__;
AzureIoTClient	21:167f8fcf6fb1	1662	}
AzureIoTClient	11:31ebaeb51e1e	1663	}
AzureIoTClient	21:167f8fcf6fb1	1664	else if (cred_type == IOTHUB_CREDENTIAL_TYPE_SAS_TOKEN)
AzureIoTClient	11:31ebaeb51e1e	1665	{
AzureIoTClient	21:167f8fcf6fb1	1666	SAS_TOKEN_STATUS token_status = IoTHubClient_Auth_Is_SasToken_Valid(transport_data->authorization_module);
AzureIoTClient	21:167f8fcf6fb1	1667	if (token_status == SAS_TOKEN_STATUS_INVALID)
AzureIoTClient	21:167f8fcf6fb1	1668	{
AzureIoTClient	21:167f8fcf6fb1	1669	IoTHubClient_LL_ConnectionStatusCallBack(transport_data->llClientHandle, IOTHUB_CLIENT_CONNECTION_UNAUTHENTICATED, IOTHUB_CLIENT_CONNECTION_EXPIRED_SAS_TOKEN);
AzureIoTClient	21:167f8fcf6fb1	1670	result = __FAILURE__;
AzureIoTClient	21:167f8fcf6fb1	1671	}
AzureIoTClient	21:167f8fcf6fb1	1672	else if (token_status == SAS_TOKEN_STATUS_FAILED)
AzureIoTClient	11:31ebaeb51e1e	1673	{
AzureIoTClient	21:167f8fcf6fb1	1674	IoTHubClient_LL_ConnectionStatusCallBack(transport_data->llClientHandle, IOTHUB_CLIENT_CONNECTION_UNAUTHENTICATED, IOTHUB_CLIENT_CONNECTION_BAD_CREDENTIAL);
AzureIoTClient	21:167f8fcf6fb1	1675	result = __FAILURE__;
AzureIoTClient	21:167f8fcf6fb1	1676	}
AzureIoTClient	21:167f8fcf6fb1	1677	else
AzureIoTClient	21:167f8fcf6fb1	1678	{
AzureIoTClient	21:167f8fcf6fb1	1679	sasToken = IoTHubClient_Auth_Get_SasToken(transport_data->authorization_module, NULL, 0);
AzureIoTClient	21:167f8fcf6fb1	1680	if (sasToken == NULL)
AzureIoTClient	11:31ebaeb51e1e	1681	{
AzureIoTClient	21:167f8fcf6fb1	1682	LogError("failure getting sas Token.");
AzureIoTClient	18:ec8e5e97c6a4	1683	result = __FAILURE__;
AzureIoTClient	12:658ca6865de2	1684	}
AzureIoTClient	21:167f8fcf6fb1	1685	}
AzureIoTClient	21:167f8fcf6fb1	1686	}
AzureIoTClient	11:31ebaeb51e1e	1687
AzureIoTClient	21:167f8fcf6fb1	1688	if (result == 0)
AzureIoTClient	21:167f8fcf6fb1	1689	{
AzureIoTClient	22:07fec4d325b6	1690	void* product_info;
AzureIoTClient	22:07fec4d325b6	1691	STRING_HANDLE clone;
AzureIoTClient	22:07fec4d325b6	1692	if ((IoTHubClient_LL_GetOption(transport_data->llClientHandle, OPTION_PRODUCT_INFO, &product_info) == IOTHUB_CLIENT_ERROR) \|\| (product_info == NULL))
AzureIoTClient	22:07fec4d325b6	1693	{
AzureIoTClient	22:07fec4d325b6	1694	clone = STRING_construct_sprintf("%s%%2F%s", CLIENT_DEVICE_TYPE_PREFIX, IOTHUB_SDK_VERSION);
AzureIoTClient	22:07fec4d325b6	1695	}
AzureIoTClient	22:07fec4d325b6	1696	else
AzureIoTClient	22:07fec4d325b6	1697	{
AzureIoTClient	22:07fec4d325b6	1698	clone = URL_Encode(product_info);
AzureIoTClient	22:07fec4d325b6	1699	}
AzureIoTClient	22:07fec4d325b6	1700	if (clone != NULL)
AzureIoTClient	22:07fec4d325b6	1701	{
AzureIoTClient	22:07fec4d325b6	1702	(void)STRING_concat_with_STRING(transport_data->configPassedThroughUsername, clone);
AzureIoTClient	22:07fec4d325b6	1703	STRING_delete(clone);
AzureIoTClient	22:07fec4d325b6	1704	}
AzureIoTClient	22:07fec4d325b6	1705
AzureIoTClient	21:167f8fcf6fb1	1706	MQTT_CLIENT_OPTIONS options = { 0 };
AzureIoTClient	21:167f8fcf6fb1	1707	options.clientId = (char*)STRING_c_str(transport_data->device_id);
AzureIoTClient	21:167f8fcf6fb1	1708	options.willMessage = NULL;
AzureIoTClient	21:167f8fcf6fb1	1709	options.username = (char*)STRING_c_str(transport_data->configPassedThroughUsername);
AzureIoTClient	21:167f8fcf6fb1	1710	if (sasToken != NULL)
AzureIoTClient	11:31ebaeb51e1e	1711	{
AzureIoTClient	21:167f8fcf6fb1	1712	options.password = sasToken;
AzureIoTClient	21:167f8fcf6fb1	1713	}
AzureIoTClient	21:167f8fcf6fb1	1714	options.keepAliveInterval = transport_data->keepAliveValue;
AzureIoTClient	21:167f8fcf6fb1	1715	options.useCleanSession = false;
AzureIoTClient	21:167f8fcf6fb1	1716	options.qualityOfServiceValue = DELIVER_AT_LEAST_ONCE;
AzureIoTClient	11:31ebaeb51e1e	1717
AzureIoTClient	21:167f8fcf6fb1	1718	if (GetTransportProviderIfNecessary(transport_data) == 0)
AzureIoTClient	21:167f8fcf6fb1	1719	{
AzureIoTClient	21:167f8fcf6fb1	1720	if (mqtt_client_connect(transport_data->mqttClient, transport_data->xioTransport, &options) != 0)
AzureIoTClient	11:31ebaeb51e1e	1721	{
AzureIoTClient	21:167f8fcf6fb1	1722	LogError("failure connecting to address %s:%d.", STRING_c_str(transport_data->hostAddress), transport_data->portNum);
AzureIoTClient	21:167f8fcf6fb1	1723	result = __FAILURE__;
AzureIoTClient	11:31ebaeb51e1e	1724	}
AzureIoTClient	11:31ebaeb51e1e	1725	else
AzureIoTClient	11:31ebaeb51e1e	1726	{
AzureIoTClient	21:167f8fcf6fb1	1727	(void)tickcounter_get_current_ms(transport_data->msgTickCounter, &transport_data->mqtt_connect_time);
AzureIoTClient	21:167f8fcf6fb1	1728	result = 0;
AzureIoTClient	11:31ebaeb51e1e	1729	}
AzureIoTClient	21:167f8fcf6fb1	1730	}
AzureIoTClient	21:167f8fcf6fb1	1731	else
AzureIoTClient	21:167f8fcf6fb1	1732	{
AzureIoTClient	21:167f8fcf6fb1	1733	result = __FAILURE__;
AzureIoTClient	21:167f8fcf6fb1	1734	}
AzureIoTClient	12:658ca6865de2	1735
AzureIoTClient	21:167f8fcf6fb1	1736	if (sasToken != NULL)
AzureIoTClient	21:167f8fcf6fb1	1737	{
AzureIoTClient	21:167f8fcf6fb1	1738	free(sasToken);
AzureIoTClient	11:31ebaeb51e1e	1739	}
AzureIoTClient	11:31ebaeb51e1e	1740	}
AzureIoTClient	11:31ebaeb51e1e	1741	return result;
AzureIoTClient	11:31ebaeb51e1e	1742	}
AzureIoTClient	11:31ebaeb51e1e	1743
AzureIoTClient	20:594780be216d	1744	static void DisconnectFromClient(PMQTTTRANSPORT_HANDLE_DATA transport_data)
AzureIoTClient	20:594780be216d	1745	{
AzureIoTClient	21:167f8fcf6fb1	1746	(void)mqtt_client_disconnect(transport_data->mqttClient);
AzureIoTClient	21:167f8fcf6fb1	1747	xio_destroy(transport_data->xioTransport);
AzureIoTClient	21:167f8fcf6fb1	1748	transport_data->xioTransport = NULL;
AzureIoTClient	20:594780be216d	1749
AzureIoTClient	21:167f8fcf6fb1	1750	transport_data->mqttClientStatus = MQTT_CLIENT_STATUS_NOT_CONNECTED;
AzureIoTClient	21:167f8fcf6fb1	1751	transport_data->currPacketState = DISCONNECT_TYPE;
AzureIoTClient	20:594780be216d	1752	}
AzureIoTClient	20:594780be216d	1753
AzureIoTClient	11:31ebaeb51e1e	1754	static int InitializeConnection(PMQTTTRANSPORT_HANDLE_DATA transport_data)
AzureIoTClient	11:31ebaeb51e1e	1755	{
AzureIoTClient	11:31ebaeb51e1e	1756	int result = 0;
AzureIoTClient	11:31ebaeb51e1e	1757
AzureIoTClient	11:31ebaeb51e1e	1758	// Make sure we're not destroying the object
AzureIoTClient	11:31ebaeb51e1e	1759	if (!transport_data->isDestroyCalled)
AzureIoTClient	11:31ebaeb51e1e	1760	{
AzureIoTClient	20:594780be216d	1761	// If we are MQTT_CLIENT_STATUS_NOT_CONNECTED then check to see if we need
AzureIoTClient	11:31ebaeb51e1e	1762	// to back off the connecting to the server
AzureIoTClient	20:594780be216d	1763	if (transport_data->mqttClientStatus == MQTT_CLIENT_STATUS_NOT_CONNECTED && transport_data->isRecoverableError && CanRetry(transport_data->retryLogic))
AzureIoTClient	11:31ebaeb51e1e	1764	{
Azure.IoT.Build	13:606465879c57	1765	if (tickcounter_get_current_ms(transport_data->msgTickCounter, &transport_data->connectTick) != 0)
AzureIoTClient	11:31ebaeb51e1e	1766	{
AzureIoTClient	12:658ca6865de2	1767	transport_data->connectFailCount++;
AzureIoTClient	18:ec8e5e97c6a4	1768	result = __FAILURE__;
AzureIoTClient	11:31ebaeb51e1e	1769	}
AzureIoTClient	12:658ca6865de2	1770	else
AzureIoTClient	11:31ebaeb51e1e	1771	{
AzureIoTClient	12:658ca6865de2	1772	if (SendMqttConnectMsg(transport_data) != 0)
AzureIoTClient	11:31ebaeb51e1e	1773	{
AzureIoTClient	11:31ebaeb51e1e	1774	transport_data->connectFailCount++;
AzureIoTClient	18:ec8e5e97c6a4	1775	result = __FAILURE__;
AzureIoTClient	11:31ebaeb51e1e	1776	}
AzureIoTClient	11:31ebaeb51e1e	1777	else
AzureIoTClient	11:31ebaeb51e1e	1778	{
AzureIoTClient	20:594780be216d	1779	transport_data->mqttClientStatus = MQTT_CLIENT_STATUS_CONNECTING;
AzureIoTClient	12:658ca6865de2	1780	transport_data->connectFailCount = 0;
AzureIoTClient	12:658ca6865de2	1781	result = 0;
AzureIoTClient	11:31ebaeb51e1e	1782	}
AzureIoTClient	11:31ebaeb51e1e	1783	}
AzureIoTClient	11:31ebaeb51e1e	1784	}
AzureIoTClient	21:167f8fcf6fb1	1785	// Codes_SRS_IOTHUB_TRANSPORT_MQTT_COMMON_09_001: [ IoTHubTransport_MQTT_Common_DoWork shall trigger reconnection if the mqtt_client_connect does not complete within `keepalive` seconds]
AzureIoTClient	20:594780be216d	1786	else if (transport_data->mqttClientStatus == MQTT_CLIENT_STATUS_CONNECTING)
AzureIoTClient	11:31ebaeb51e1e	1787	{
AzureIoTClient	20:594780be216d	1788	tickcounter_ms_t current_time;
AzureIoTClient	20:594780be216d	1789	if (tickcounter_get_current_ms(transport_data->msgTickCounter, &current_time) != 0)
AzureIoTClient	20:594780be216d	1790	{
AzureIoTClient	20:594780be216d	1791	LogError("failed verifying MQTT_CLIENT_STATUS_CONNECTING timeout");
AzureIoTClient	20:594780be216d	1792	result = __FAILURE__;
AzureIoTClient	20:594780be216d	1793	}
AzureIoTClient	20:594780be216d	1794	else if ((current_time - transport_data->mqtt_connect_time) / 1000 > transport_data->keepAliveValue)
AzureIoTClient	20:594780be216d	1795	{
AzureIoTClient	20:594780be216d	1796	LogError("mqtt_client timed out waiting for CONNACK");
AzureIoTClient	20:594780be216d	1797	DisconnectFromClient(transport_data);
AzureIoTClient	20:594780be216d	1798	result = 0;
AzureIoTClient	20:594780be216d	1799	}
AzureIoTClient	20:594780be216d	1800	}
AzureIoTClient	20:594780be216d	1801	else if (transport_data->mqttClientStatus == MQTT_CLIENT_STATUS_CONNECTED)
AzureIoTClient	20:594780be216d	1802	{
AzureIoTClient	20:594780be216d	1803	// We are connected and not being closed, so does SAS need to reconnect?
Azure.IoT.Build	13:606465879c57	1804	tickcounter_ms_t current_time;
Azure.IoT.Build	13:606465879c57	1805	if (tickcounter_get_current_ms(transport_data->msgTickCounter, &current_time) != 0)
AzureIoTClient	11:31ebaeb51e1e	1806	{
AzureIoTClient	11:31ebaeb51e1e	1807	transport_data->connectFailCount++;
AzureIoTClient	18:ec8e5e97c6a4	1808	result = __FAILURE__;
AzureIoTClient	11:31ebaeb51e1e	1809	}
AzureIoTClient	11:31ebaeb51e1e	1810	else
AzureIoTClient	11:31ebaeb51e1e	1811	{
AzureIoTClient	11:31ebaeb51e1e	1812	if ((current_time - transport_data->mqtt_connect_time) / 1000 > (SAS_TOKEN_DEFAULT_LIFETIME*SAS_REFRESH_MULTIPLIER))
AzureIoTClient	11:31ebaeb51e1e	1813	{
AzureIoTClient	11:31ebaeb51e1e	1814	(void)mqtt_client_disconnect(transport_data->mqttClient);
AzureIoTClient	19:f87dfe76bc70	1815	IoTHubClient_LL_ConnectionStatusCallBack(transport_data->llClientHandle, IOTHUB_CLIENT_CONNECTION_UNAUTHENTICATED, IOTHUB_CLIENT_CONNECTION_EXPIRED_SAS_TOKEN);
AzureIoTClient	20:594780be216d	1816	transport_data->mqttClientStatus = MQTT_CLIENT_STATUS_NOT_CONNECTED;
AzureIoTClient	11:31ebaeb51e1e	1817	transport_data->currPacketState = UNKNOWN_TYPE;
AzureIoTClient	12:658ca6865de2	1818	transport_data->device_twin_get_sent = false;
AzureIoTClient	11:31ebaeb51e1e	1819	if (transport_data->topic_MqttMessage != NULL)
AzureIoTClient	11:31ebaeb51e1e	1820	{
AzureIoTClient	11:31ebaeb51e1e	1821	transport_data->topics_ToSubscribe \|= SUBSCRIBE_TELEMETRY_TOPIC;
AzureIoTClient	11:31ebaeb51e1e	1822	}
AzureIoTClient	12:658ca6865de2	1823	if (transport_data->topic_GetState != NULL)
AzureIoTClient	12:658ca6865de2	1824	{
AzureIoTClient	12:658ca6865de2	1825	transport_data->topics_ToSubscribe \|= SUBSCRIBE_GET_REPORTED_STATE_TOPIC;
AzureIoTClient	12:658ca6865de2	1826	}
AzureIoTClient	12:658ca6865de2	1827	if (transport_data->topic_NotifyState != NULL)
AzureIoTClient	12:658ca6865de2	1828	{
AzureIoTClient	12:658ca6865de2	1829	transport_data->topics_ToSubscribe \|= SUBSCRIBE_NOTIFICATION_STATE_TOPIC;
AzureIoTClient	12:658ca6865de2	1830	}
AzureIoTClient	12:658ca6865de2	1831	if (transport_data->topic_DeviceMethods != NULL)
AzureIoTClient	12:658ca6865de2	1832	{
AzureIoTClient	12:658ca6865de2	1833	transport_data->topics_ToSubscribe \|= SUBSCRIBE_DEVICE_METHOD_TOPIC;
AzureIoTClient	12:658ca6865de2	1834	}
AzureIoTClient	11:31ebaeb51e1e	1835	}
AzureIoTClient	11:31ebaeb51e1e	1836	}
AzureIoTClient	11:31ebaeb51e1e	1837	}
AzureIoTClient	11:31ebaeb51e1e	1838	}
AzureIoTClient	11:31ebaeb51e1e	1839	return result;
AzureIoTClient	11:31ebaeb51e1e	1840	}
AzureIoTClient	11:31ebaeb51e1e	1841
AzureIoTClient	11:31ebaeb51e1e	1842	static STRING_HANDLE buildConfigForUsername(const IOTHUB_CLIENT_CONFIG* upperConfig)
AzureIoTClient	11:31ebaeb51e1e	1843	{
AzureIoTClient	22:07fec4d325b6	1844	return STRING_construct_sprintf("%s.%s/%s/api-version=%s&DeviceClientType=", upperConfig->iotHubName, upperConfig->iotHubSuffix, upperConfig->deviceId, IOTHUB_API_VERSION);
AzureIoTClient	11:31ebaeb51e1e	1845	}
AzureIoTClient	11:31ebaeb51e1e	1846
AzureIoTClient	21:167f8fcf6fb1	1847	static PMQTTTRANSPORT_HANDLE_DATA InitializeTransportHandleData(const IOTHUB_CLIENT_CONFIG* upperConfig, PDLIST_ENTRY waitingToSend, IOTHUB_AUTHORIZATION_HANDLE auth_module)
AzureIoTClient	11:31ebaeb51e1e	1848	{
AzureIoTClient	11:31ebaeb51e1e	1849	PMQTTTRANSPORT_HANDLE_DATA state = (PMQTTTRANSPORT_HANDLE_DATA)malloc(sizeof(MQTTTRANSPORT_HANDLE_DATA));
AzureIoTClient	11:31ebaeb51e1e	1850	if (state == NULL)
AzureIoTClient	11:31ebaeb51e1e	1851	{
AzureIoTClient	11:31ebaeb51e1e	1852	LogError("Could not create MQTT transport state. Memory allocation failed.");
AzureIoTClient	11:31ebaeb51e1e	1853	}
AzureIoTClient	11:31ebaeb51e1e	1854	else
AzureIoTClient	11:31ebaeb51e1e	1855	{
AzureIoTClient	21:167f8fcf6fb1	1856	memset(state, 0, sizeof(MQTTTRANSPORT_HANDLE_DATA) );
AzureIoTClient	21:167f8fcf6fb1	1857	if ((state->msgTickCounter = tickcounter_create()) == NULL)
AzureIoTClient	11:31ebaeb51e1e	1858	{
AzureIoTClient	21:167f8fcf6fb1	1859	LogError("Invalid Argument: iotHubName is empty");
AzureIoTClient	21:167f8fcf6fb1	1860	free(state);
AzureIoTClient	21:167f8fcf6fb1	1861	state = NULL;
AzureIoTClient	21:167f8fcf6fb1	1862	}
AzureIoTClient	21:167f8fcf6fb1	1863	else if ((state->device_id = STRING_construct(upperConfig->deviceId)) == NULL)
AzureIoTClient	21:167f8fcf6fb1	1864	{
AzureIoTClient	21:167f8fcf6fb1	1865	LogError("failure constructing device_id.");
Azure.IoT.Build	13:606465879c57	1866	tickcounter_destroy(state->msgTickCounter);
AzureIoTClient	11:31ebaeb51e1e	1867	free(state);
AzureIoTClient	11:31ebaeb51e1e	1868	state = NULL;
AzureIoTClient	11:31ebaeb51e1e	1869	}
AzureIoTClient	21:167f8fcf6fb1	1870	else if ((state->devicesPath = STRING_construct_sprintf("%s.%s/devices/%s", upperConfig->iotHubName, upperConfig->iotHubSuffix, upperConfig->deviceId)) == NULL)
AzureIoTClient	11:31ebaeb51e1e	1871	{
Azure.IoT.Build	13:606465879c57	1872	tickcounter_destroy(state->msgTickCounter);
AzureIoTClient	11:31ebaeb51e1e	1873	free(state);
AzureIoTClient	11:31ebaeb51e1e	1874	state = NULL;
AzureIoTClient	11:31ebaeb51e1e	1875	}
AzureIoTClient	11:31ebaeb51e1e	1876	else
AzureIoTClient	11:31ebaeb51e1e	1877	{
AzureIoTClient	21:167f8fcf6fb1	1878	if ( (state->topic_MqttEvent = STRING_construct_sprintf(TOPIC_DEVICE_DEVICE, upperConfig->deviceId) ) == NULL)
AzureIoTClient	11:31ebaeb51e1e	1879	{
AzureIoTClient	21:167f8fcf6fb1	1880	LogError("Could not create topic_MqttEvent for MQTT");
AzureIoTClient	11:31ebaeb51e1e	1881	STRING_delete(state->devicesPath);
AzureIoTClient	11:31ebaeb51e1e	1882	STRING_delete(state->device_id);
Azure.IoT.Build	13:606465879c57	1883	tickcounter_destroy(state->msgTickCounter);
AzureIoTClient	11:31ebaeb51e1e	1884	free(state);
AzureIoTClient	11:31ebaeb51e1e	1885	state = NULL;
AzureIoTClient	11:31ebaeb51e1e	1886	}
AzureIoTClient	11:31ebaeb51e1e	1887	else
AzureIoTClient	11:31ebaeb51e1e	1888	{
AzureIoTClient	21:167f8fcf6fb1	1889	state->mqttClient = mqtt_client_init(mqtt_notification_callback, mqtt_operation_complete_callback, state, mqtt_error_callback, state);
AzureIoTClient	21:167f8fcf6fb1	1890	if (state->mqttClient == NULL)
AzureIoTClient	11:31ebaeb51e1e	1891	{
AzureIoTClient	21:167f8fcf6fb1	1892	LogError("failure initializing mqtt client.");
AzureIoTClient	11:31ebaeb51e1e	1893	STRING_delete(state->devicesPath);
AzureIoTClient	11:31ebaeb51e1e	1894	STRING_delete(state->topic_MqttEvent);
AzureIoTClient	11:31ebaeb51e1e	1895	STRING_delete(state->device_id);
Azure.IoT.Build	13:606465879c57	1896	tickcounter_destroy(state->msgTickCounter);
AzureIoTClient	11:31ebaeb51e1e	1897	free(state);
AzureIoTClient	11:31ebaeb51e1e	1898	state = NULL;
AzureIoTClient	11:31ebaeb51e1e	1899	}
AzureIoTClient	11:31ebaeb51e1e	1900	else
AzureIoTClient	11:31ebaeb51e1e	1901	{
AzureIoTClient	21:167f8fcf6fb1	1902	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_008: [If the upperConfig contains a valid protocolGatewayHostName value the this shall be used for the hostname, otherwise the hostname shall be constructed using the iothubname and iothubSuffix.] */
AzureIoTClient	21:167f8fcf6fb1	1903	if (upperConfig->protocolGatewayHostName == NULL)
AzureIoTClient	21:167f8fcf6fb1	1904	{
AzureIoTClient	21:167f8fcf6fb1	1905	state->hostAddress = STRING_construct_sprintf("%s.%s", upperConfig->iotHubName, upperConfig->iotHubSuffix);
AzureIoTClient	21:167f8fcf6fb1	1906	}
AzureIoTClient	21:167f8fcf6fb1	1907	else
AzureIoTClient	21:167f8fcf6fb1	1908	{
AzureIoTClient	21:167f8fcf6fb1	1909	state->hostAddress = STRING_construct(upperConfig->protocolGatewayHostName);
AzureIoTClient	21:167f8fcf6fb1	1910	}
AzureIoTClient	21:167f8fcf6fb1	1911
AzureIoTClient	21:167f8fcf6fb1	1912	if (state->hostAddress == NULL)
AzureIoTClient	21:167f8fcf6fb1	1913	{
AzureIoTClient	21:167f8fcf6fb1	1914	LogError("failure constructing host address.");
AzureIoTClient	21:167f8fcf6fb1	1915	STRING_delete(state->devicesPath);
AzureIoTClient	21:167f8fcf6fb1	1916	mqtt_client_deinit(state->mqttClient);
AzureIoTClient	21:167f8fcf6fb1	1917	STRING_delete(state->topic_MqttEvent);
AzureIoTClient	21:167f8fcf6fb1	1918	STRING_delete(state->device_id);
AzureIoTClient	21:167f8fcf6fb1	1919	tickcounter_destroy(state->msgTickCounter);
AzureIoTClient	21:167f8fcf6fb1	1920	free(state);
AzureIoTClient	21:167f8fcf6fb1	1921	state = NULL;
AzureIoTClient	21:167f8fcf6fb1	1922	}
AzureIoTClient	21:167f8fcf6fb1	1923	else if ((state->configPassedThroughUsername = buildConfigForUsername(upperConfig)) == NULL)
AzureIoTClient	21:167f8fcf6fb1	1924	{
AzureIoTClient	21:167f8fcf6fb1	1925	STRING_delete(state->devicesPath);
AzureIoTClient	21:167f8fcf6fb1	1926	mqtt_client_deinit(state->mqttClient);
AzureIoTClient	21:167f8fcf6fb1	1927	STRING_delete(state->hostAddress);
AzureIoTClient	21:167f8fcf6fb1	1928	STRING_delete(state->topic_MqttEvent);
AzureIoTClient	21:167f8fcf6fb1	1929	STRING_delete(state->device_id);
AzureIoTClient	21:167f8fcf6fb1	1930	tickcounter_destroy(state->msgTickCounter);
AzureIoTClient	21:167f8fcf6fb1	1931	free(state);
AzureIoTClient	21:167f8fcf6fb1	1932	state = NULL;
AzureIoTClient	21:167f8fcf6fb1	1933	}
AzureIoTClient	21:167f8fcf6fb1	1934	else
AzureIoTClient	21:167f8fcf6fb1	1935	{
AzureIoTClient	21:167f8fcf6fb1	1936	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_010: [IoTHubTransport_MQTT_Common_Create shall allocate memory to save its internal state where all topics, hostname, device_id, device_key, sasTokenSr and client handle shall be saved.] */
AzureIoTClient	21:167f8fcf6fb1	1937	DList_InitializeListHead(&(state->telemetry_waitingForAck));
AzureIoTClient	21:167f8fcf6fb1	1938	DList_InitializeListHead(&(state->ack_waiting_queue));
AzureIoTClient	21:167f8fcf6fb1	1939	state->isDestroyCalled = false;
AzureIoTClient	21:167f8fcf6fb1	1940	state->isRegistered = false;
AzureIoTClient	21:167f8fcf6fb1	1941	state->mqttClientStatus = MQTT_CLIENT_STATUS_NOT_CONNECTED;
AzureIoTClient	21:167f8fcf6fb1	1942	state->device_twin_get_sent = false;
AzureIoTClient	21:167f8fcf6fb1	1943	state->isRecoverableError = true;
AzureIoTClient	21:167f8fcf6fb1	1944	state->packetId = 1;
AzureIoTClient	21:167f8fcf6fb1	1945	state->llClientHandle = NULL;
AzureIoTClient	21:167f8fcf6fb1	1946	state->xioTransport = NULL;
AzureIoTClient	21:167f8fcf6fb1	1947	state->portNum = 0;
AzureIoTClient	21:167f8fcf6fb1	1948	state->waitingToSend = waitingToSend;
AzureIoTClient	21:167f8fcf6fb1	1949	state->currPacketState = CONNECT_TYPE;
AzureIoTClient	21:167f8fcf6fb1	1950	state->keepAliveValue = DEFAULT_MQTT_KEEPALIVE;
AzureIoTClient	21:167f8fcf6fb1	1951	state->connectFailCount = 0;
AzureIoTClient	21:167f8fcf6fb1	1952	state->connectTick = 0;
AzureIoTClient	21:167f8fcf6fb1	1953	state->topic_MqttMessage = NULL;
AzureIoTClient	21:167f8fcf6fb1	1954	state->topic_GetState = NULL;
AzureIoTClient	21:167f8fcf6fb1	1955	state->topic_NotifyState = NULL;
AzureIoTClient	21:167f8fcf6fb1	1956	state->topics_ToSubscribe = UNSUBSCRIBE_FROM_TOPIC;
AzureIoTClient	21:167f8fcf6fb1	1957	state->topic_DeviceMethods = NULL;
AzureIoTClient	21:167f8fcf6fb1	1958	state->log_trace = state->raw_trace = false;
AzureIoTClient	21:167f8fcf6fb1	1959	state->retryLogic = NULL;
AzureIoTClient	21:167f8fcf6fb1	1960	srand((unsigned int)get_time(NULL));
AzureIoTClient	21:167f8fcf6fb1	1961	state->authorization_module = auth_module;
AzureIoTClient	21:167f8fcf6fb1	1962	}
AzureIoTClient	11:31ebaeb51e1e	1963	}
AzureIoTClient	11:31ebaeb51e1e	1964	}
AzureIoTClient	11:31ebaeb51e1e	1965	}
AzureIoTClient	11:31ebaeb51e1e	1966	}
AzureIoTClient	11:31ebaeb51e1e	1967	return state;
AzureIoTClient	11:31ebaeb51e1e	1968	}
AzureIoTClient	11:31ebaeb51e1e	1969
AzureIoTClient	11:31ebaeb51e1e	1970	TRANSPORT_LL_HANDLE IoTHubTransport_MQTT_Common_Create(const IOTHUBTRANSPORT_CONFIG* config, MQTT_GET_IO_TRANSPORT get_io_transport)
AzureIoTClient	11:31ebaeb51e1e	1971	{
AzureIoTClient	11:31ebaeb51e1e	1972	PMQTTTRANSPORT_HANDLE_DATA result;
AzureIoTClient	11:31ebaeb51e1e	1973	size_t deviceIdSize;
AzureIoTClient	11:31ebaeb51e1e	1974
AzureIoTClient	12:658ca6865de2	1975	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_001: [If parameter config is NULL then IoTHubTransport_MQTT_Common_Create shall return NULL.] */
AzureIoTClient	11:31ebaeb51e1e	1976	/* Codes_SRS_IOTHUB_TRANSPORT_MQTT_COMMON_07_041: [ if get_io_transport is NULL then IoTHubTransport_MQTT_Common_Create shall return NULL. ] */
AzureIoTClient	11:31ebaeb51e1e	1977	if (config == NULL \|\| get_io_transport == NULL)
AzureIoTClient	11:31ebaeb51e1e	1978	{
AzureIoTClient	11:31ebaeb51e1e	1979	LogError("Invalid Argument: Config Parameter is NULL.");
AzureIoTClient	11:31ebaeb51e1e	1980	result = NULL;
AzureIoTClient	11:31ebaeb51e1e	1981	}
AzureIoTClient	12:658ca6865de2	1982	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_002: [If the parameter config's variables upperConfig or waitingToSend are NULL then IoTHubTransport_MQTT_Common_Create shall return NULL.] */
AzureIoTClient	12:658ca6865de2	1983	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_003: [If the upperConfig's variables deviceId, both deviceKey and deviceSasToken, iotHubName, protocol, or iotHubSuffix are NULL then IoTHubTransport_MQTT_Common_Create shall return NULL.] */
AzureIoTClient	12:658ca6865de2	1984	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_03_003: [If both deviceKey & deviceSasToken fields are NOT NULL then IoTHubTransport_MQTT_Common_Create shall return NULL.] */
AzureIoTClient	11:31ebaeb51e1e	1985	else if (config->upperConfig == NULL \|\|
AzureIoTClient	11:31ebaeb51e1e	1986	config->upperConfig->protocol == NULL \|\|
AzureIoTClient	11:31ebaeb51e1e	1987	config->upperConfig->deviceId == NULL \|\|
AzureIoTClient	11:31ebaeb51e1e	1988	((config->upperConfig->deviceKey != NULL) && (config->upperConfig->deviceSasToken != NULL)) \|\|
AzureIoTClient	11:31ebaeb51e1e	1989	config->upperConfig->iotHubName == NULL \|\|
AzureIoTClient	11:31ebaeb51e1e	1990	config->upperConfig->iotHubSuffix == NULL)
AzureIoTClient	11:31ebaeb51e1e	1991	{
AzureIoTClient	11:31ebaeb51e1e	1992	LogError("Invalid Argument: upperConfig structure contains an invalid parameter");
AzureIoTClient	11:31ebaeb51e1e	1993	result = NULL;
AzureIoTClient	11:31ebaeb51e1e	1994	}
AzureIoTClient	21:167f8fcf6fb1	1995	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_002: [If the parameter config's variables upperConfig, auth_module_handle or waitingToSend are NULL then IoTHubTransport_MQTT_Common_Create shall return NULL.] */
AzureIoTClient	11:31ebaeb51e1e	1996	else if (config->waitingToSend == NULL)
AzureIoTClient	11:31ebaeb51e1e	1997	{
AzureIoTClient	11:31ebaeb51e1e	1998	LogError("Invalid Argument: waitingToSend is NULL)");
AzureIoTClient	11:31ebaeb51e1e	1999	result = NULL;
AzureIoTClient	11:31ebaeb51e1e	2000	}
AzureIoTClient	21:167f8fcf6fb1	2001	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_002: [If the parameter config's variables upperConfig, auth_module_handle or waitingToSend are NULL then IoTHubTransport_MQTT_Common_Create shall return NULL.] */
AzureIoTClient	21:167f8fcf6fb1	2002	else if (config->auth_module_handle == NULL)
AzureIoTClient	21:167f8fcf6fb1	2003	{
AzureIoTClient	21:167f8fcf6fb1	2004	LogError("Invalid Argument: auth_module_handle is NULL)");
AzureIoTClient	21:167f8fcf6fb1	2005	result = NULL;
AzureIoTClient	21:167f8fcf6fb1	2006	}
AzureIoTClient	12:658ca6865de2	2007	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_006: [If the upperConfig's variables deviceId is an empty strings or length is greater then 128 then IoTHubTransport_MQTT_Common_Create shall return NULL.] */
AzureIoTClient	11:31ebaeb51e1e	2008	else if ( ( (deviceIdSize = strlen(config->upperConfig->deviceId)) > 128U) \|\| (deviceIdSize == 0) )
AzureIoTClient	11:31ebaeb51e1e	2009	{
AzureIoTClient	11:31ebaeb51e1e	2010	LogError("Invalid Argument: DeviceId is of an invalid size");
AzureIoTClient	11:31ebaeb51e1e	2011	result = NULL;
AzureIoTClient	11:31ebaeb51e1e	2012	}
AzureIoTClient	12:658ca6865de2	2013	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_003: [If the upperConfig's variables deviceId, both deviceKey and deviceSasToken, iotHubName, protocol, or iotHubSuffix are NULL then IoTHubTransport_MQTT_Common_Create shall return NULL.] */
AzureIoTClient	11:31ebaeb51e1e	2014	else if ((config->upperConfig->deviceKey != NULL) && (strlen(config->upperConfig->deviceKey) == 0))
AzureIoTClient	11:31ebaeb51e1e	2015	{
AzureIoTClient	11:31ebaeb51e1e	2016	LogError("Invalid Argument: deviceKey is empty");
AzureIoTClient	11:31ebaeb51e1e	2017	result = NULL;
AzureIoTClient	11:31ebaeb51e1e	2018	}
AzureIoTClient	12:658ca6865de2	2019	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_003: [If the upperConfig's variables deviceId, both deviceKey and deviceSasToken, iotHubName, protocol, or iotHubSuffix are NULL then IoTHubTransport_MQTT_Common_Create shall return NULL.] */
AzureIoTClient	11:31ebaeb51e1e	2020	else if ((config->upperConfig->deviceSasToken != NULL) && (strlen(config->upperConfig->deviceSasToken) == 0))
AzureIoTClient	11:31ebaeb51e1e	2021	{
AzureIoTClient	11:31ebaeb51e1e	2022	LogError("Invalid Argument: deviceSasToken is empty");
AzureIoTClient	11:31ebaeb51e1e	2023	result = NULL;
AzureIoTClient	11:31ebaeb51e1e	2024	}
AzureIoTClient	12:658ca6865de2	2025	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_003: [If the upperConfig's variables deviceId, deviceKey, iotHubName, protocol, or iotHubSuffix are NULL then IoTHubTransport_MQTT_Common_Create shall return NULL.] */
AzureIoTClient	11:31ebaeb51e1e	2026	else if (strlen(config->upperConfig->iotHubName) == 0)
AzureIoTClient	11:31ebaeb51e1e	2027	{
AzureIoTClient	11:31ebaeb51e1e	2028	LogError("Invalid Argument: iotHubName is empty");
AzureIoTClient	11:31ebaeb51e1e	2029	result = NULL;
AzureIoTClient	11:31ebaeb51e1e	2030	}
AzureIoTClient	11:31ebaeb51e1e	2031	else
AzureIoTClient	11:31ebaeb51e1e	2032	{
AzureIoTClient	21:167f8fcf6fb1	2033	result = InitializeTransportHandleData(config->upperConfig, config->waitingToSend, config->auth_module_handle);
Azure.IoT.Build	13:606465879c57	2034	if (result != NULL)
AzureIoTClient	11:31ebaeb51e1e	2035	{
AzureIoTClient	11:31ebaeb51e1e	2036	result->get_io_transport = get_io_transport;
AzureIoTClient	20:594780be216d	2037	result->http_proxy_hostname = NULL;
AzureIoTClient	20:594780be216d	2038	result->http_proxy_username = NULL;
AzureIoTClient	20:594780be216d	2039	result->http_proxy_password = NULL;
AzureIoTClient	11:31ebaeb51e1e	2040	}
AzureIoTClient	11:31ebaeb51e1e	2041	}
AzureIoTClient	12:658ca6865de2	2042	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_009: [If any error is encountered then IoTHubTransport_MQTT_Common_Create shall return NULL.] */
AzureIoTClient	12:658ca6865de2	2043	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_011: [On Success IoTHubTransport_MQTT_Common_Create shall return a non-NULL value.] */
AzureIoTClient	11:31ebaeb51e1e	2044	return result;
AzureIoTClient	11:31ebaeb51e1e	2045	}
AzureIoTClient	11:31ebaeb51e1e	2046
AzureIoTClient	11:31ebaeb51e1e	2047	void IoTHubTransport_MQTT_Common_Destroy(TRANSPORT_LL_HANDLE handle)
AzureIoTClient	11:31ebaeb51e1e	2048	{
AzureIoTClient	12:658ca6865de2	2049	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_012: [IoTHubTransport_MQTT_Common_Destroy shall do nothing if parameter handle is NULL.] */
AzureIoTClient	11:31ebaeb51e1e	2050	PMQTTTRANSPORT_HANDLE_DATA transport_data = (PMQTTTRANSPORT_HANDLE_DATA)handle;
AzureIoTClient	11:31ebaeb51e1e	2051	if (transport_data != NULL)
AzureIoTClient	11:31ebaeb51e1e	2052	{
AzureIoTClient	11:31ebaeb51e1e	2053	transport_data->isDestroyCalled = true;
AzureIoTClient	11:31ebaeb51e1e	2054
AzureIoTClient	11:31ebaeb51e1e	2055	DisconnectFromClient(transport_data);
AzureIoTClient	11:31ebaeb51e1e	2056
AzureIoTClient	11:31ebaeb51e1e	2057	//Empty the Waiting for Ack Messages.
AzureIoTClient	11:31ebaeb51e1e	2058	while (!DList_IsListEmpty(&transport_data->telemetry_waitingForAck))
AzureIoTClient	11:31ebaeb51e1e	2059	{
AzureIoTClient	11:31ebaeb51e1e	2060	PDLIST_ENTRY currentEntry = DList_RemoveHeadList(&transport_data->telemetry_waitingForAck);
AzureIoTClient	11:31ebaeb51e1e	2061	MQTT_MESSAGE_DETAILS_LIST* mqttMsgEntry = containingRecord(currentEntry, MQTT_MESSAGE_DETAILS_LIST, entry);
AzureIoTClient	11:31ebaeb51e1e	2062	sendMsgComplete(mqttMsgEntry->iotHubMessageEntry, transport_data, IOTHUB_CLIENT_CONFIRMATION_BECAUSE_DESTROY);
AzureIoTClient	11:31ebaeb51e1e	2063	free(mqttMsgEntry);
AzureIoTClient	11:31ebaeb51e1e	2064	}
AzureIoTClient	12:658ca6865de2	2065	while (!DList_IsListEmpty(&transport_data->ack_waiting_queue))
AzureIoTClient	12:658ca6865de2	2066	{
AzureIoTClient	12:658ca6865de2	2067	PDLIST_ENTRY currentEntry = DList_RemoveHeadList(&transport_data->ack_waiting_queue);
AzureIoTClient	12:658ca6865de2	2068	MQTT_DEVICE_TWIN_ITEM* mqtt_device_twin = containingRecord(currentEntry, MQTT_DEVICE_TWIN_ITEM, entry);
AzureIoTClient	12:658ca6865de2	2069	IoTHubClient_LL_ReportedStateComplete(transport_data->llClientHandle, mqtt_device_twin->iothub_msg_id, STATUS_CODE_TIMEOUT_VALUE);
AzureIoTClient	12:658ca6865de2	2070	free(mqtt_device_twin);
AzureIoTClient	12:658ca6865de2	2071	}
AzureIoTClient	11:31ebaeb51e1e	2072
AzureIoTClient	21:167f8fcf6fb1	2073	STRING_delete(transport_data->devicesPath);
AzureIoTClient	11:31ebaeb51e1e	2074
AzureIoTClient	12:658ca6865de2	2075	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_014: [IoTHubTransport_MQTT_Common_Destroy shall free all the resources currently in use.] */
AzureIoTClient	11:31ebaeb51e1e	2076	mqtt_client_deinit(transport_data->mqttClient);
AzureIoTClient	11:31ebaeb51e1e	2077	STRING_delete(transport_data->topic_MqttEvent);
AzureIoTClient	11:31ebaeb51e1e	2078	STRING_delete(transport_data->topic_MqttMessage);
AzureIoTClient	11:31ebaeb51e1e	2079	STRING_delete(transport_data->device_id);
AzureIoTClient	11:31ebaeb51e1e	2080	STRING_delete(transport_data->hostAddress);
AzureIoTClient	11:31ebaeb51e1e	2081	STRING_delete(transport_data->configPassedThroughUsername);
AzureIoTClient	12:658ca6865de2	2082	STRING_delete(transport_data->topic_GetState);
AzureIoTClient	12:658ca6865de2	2083	STRING_delete(transport_data->topic_NotifyState);
AzureIoTClient	12:658ca6865de2	2084	STRING_delete(transport_data->topic_DeviceMethods);
AzureIoTClient	12:658ca6865de2	2085
Azure.IoT.Build	13:606465879c57	2086	tickcounter_destroy(transport_data->msgTickCounter);
AzureIoTClient	12:658ca6865de2	2087	DestroyRetryLogic(transport_data->retryLogic);
AzureIoTClient	20:594780be216d	2088	/* Codes_SRS_IOTHUB_TRANSPORT_MQTT_COMMON_01_012: [ `IoTHubTransport_MQTT_Common_Destroy` shall free the stored proxy options. ]*/
AzureIoTClient	20:594780be216d	2089	free_proxy_data(transport_data);
AzureIoTClient	11:31ebaeb51e1e	2090	free(transport_data);
AzureIoTClient	11:31ebaeb51e1e	2091	}
AzureIoTClient	11:31ebaeb51e1e	2092	}
AzureIoTClient	11:31ebaeb51e1e	2093
AzureIoTClient	12:658ca6865de2	2094	int IoTHubTransport_MQTT_Common_Subscribe_DeviceTwin(IOTHUB_DEVICE_HANDLE handle)
AzureIoTClient	12:658ca6865de2	2095	{
AzureIoTClient	12:658ca6865de2	2096	int result;
AzureIoTClient	12:658ca6865de2	2097	PMQTTTRANSPORT_HANDLE_DATA transport_data = (PMQTTTRANSPORT_HANDLE_DATA)handle;
AzureIoTClient	12:658ca6865de2	2098	if (transport_data == NULL)
AzureIoTClient	12:658ca6865de2	2099	{
AzureIoTClient	12:658ca6865de2	2100	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_042: [If the parameter handle is NULL than IoTHubTransport_MQTT_Common_Subscribe shall return a non-zero value.] */
AzureIoTClient	12:658ca6865de2	2101	LogError("Invalid handle parameter. NULL.");
AzureIoTClient	18:ec8e5e97c6a4	2102	result = __FAILURE__;
AzureIoTClient	12:658ca6865de2	2103	}
AzureIoTClient	12:658ca6865de2	2104	else
AzureIoTClient	12:658ca6865de2	2105	{
AzureIoTClient	12:658ca6865de2	2106	if (transport_data->topic_GetState == NULL)
AzureIoTClient	12:658ca6865de2	2107	{
AzureIoTClient	12:658ca6865de2	2108	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_044: [IoTHubTransport_MQTT_Common_Subscribe_DeviceTwin shall construct the get state topic string and the notify state topic string.] */
AzureIoTClient	12:658ca6865de2	2109	transport_data->topic_GetState = STRING_construct(TOPIC_GET_DESIRED_STATE);
AzureIoTClient	12:658ca6865de2	2110	if (transport_data->topic_GetState == NULL)
AzureIoTClient	12:658ca6865de2	2111	{
AzureIoTClient	12:658ca6865de2	2112	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_046: [Upon failure IoTHubTransport_MQTT_Common_Subscribe_DeviceTwin shall return a non-zero value.] */
AzureIoTClient	12:658ca6865de2	2113	LogError("Failure: unable constructing reported state topic");
AzureIoTClient	18:ec8e5e97c6a4	2114	result = __FAILURE__;
AzureIoTClient	12:658ca6865de2	2115	}
AzureIoTClient	12:658ca6865de2	2116	else
AzureIoTClient	12:658ca6865de2	2117	{
AzureIoTClient	12:658ca6865de2	2118	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_047: [On success IoTHubTransport_MQTT_Common_Subscribe_DeviceTwin shall return 0.] */
AzureIoTClient	12:658ca6865de2	2119	transport_data->topics_ToSubscribe \|= SUBSCRIBE_GET_REPORTED_STATE_TOPIC;
AzureIoTClient	12:658ca6865de2	2120	result = 0;
AzureIoTClient	12:658ca6865de2	2121	}
AzureIoTClient	12:658ca6865de2	2122	}
AzureIoTClient	12:658ca6865de2	2123	else
AzureIoTClient	12:658ca6865de2	2124	{
AzureIoTClient	12:658ca6865de2	2125	result = 0;
AzureIoTClient	12:658ca6865de2	2126	}
AzureIoTClient	12:658ca6865de2	2127	if (result == 0 && transport_data->topic_NotifyState == NULL)
AzureIoTClient	12:658ca6865de2	2128	{
AzureIoTClient	12:658ca6865de2	2129	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_044: [`IoTHubTransport_MQTT_Common_Subscribe_DeviceTwin` shall construct the get state topic string and the notify state topic string.] */
AzureIoTClient	12:658ca6865de2	2130	transport_data->topic_NotifyState = STRING_construct(TOPIC_NOTIFICATION_STATE);
AzureIoTClient	12:658ca6865de2	2131	if (transport_data->topic_NotifyState == NULL)
AzureIoTClient	12:658ca6865de2	2132	{
AzureIoTClient	12:658ca6865de2	2133	LogError("Failure: unable constructing notify state topic");
AzureIoTClient	18:ec8e5e97c6a4	2134	result = __FAILURE__;
AzureIoTClient	12:658ca6865de2	2135	}
AzureIoTClient	12:658ca6865de2	2136	else
AzureIoTClient	12:658ca6865de2	2137	{
AzureIoTClient	12:658ca6865de2	2138	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_047: [On success IoTHubTransport_MQTT_Common_Subscribe_DeviceTwin shall return 0.] */
AzureIoTClient	12:658ca6865de2	2139	transport_data->topics_ToSubscribe \|= SUBSCRIBE_NOTIFICATION_STATE_TOPIC;
AzureIoTClient	12:658ca6865de2	2140	result = 0;
AzureIoTClient	12:658ca6865de2	2141	}
AzureIoTClient	12:658ca6865de2	2142	}
AzureIoTClient	12:658ca6865de2	2143	if (result == 0)
AzureIoTClient	12:658ca6865de2	2144	{
AzureIoTClient	12:658ca6865de2	2145	if (transport_data->currPacketState != CONNACK_TYPE &&
AzureIoTClient	12:658ca6865de2	2146	transport_data->currPacketState != CONNECT_TYPE &&
AzureIoTClient	12:658ca6865de2	2147	transport_data->currPacketState != DISCONNECT_TYPE &&
AzureIoTClient	12:658ca6865de2	2148	transport_data->currPacketState != PACKET_TYPE_ERROR)
AzureIoTClient	12:658ca6865de2	2149	{
AzureIoTClient	12:658ca6865de2	2150	transport_data->currPacketState = SUBSCRIBE_TYPE;
AzureIoTClient	12:658ca6865de2	2151	}
AzureIoTClient	12:658ca6865de2	2152	}
AzureIoTClient	12:658ca6865de2	2153	}
AzureIoTClient	12:658ca6865de2	2154	return result;
AzureIoTClient	12:658ca6865de2	2155	}
AzureIoTClient	12:658ca6865de2	2156
AzureIoTClient	12:658ca6865de2	2157	void IoTHubTransport_MQTT_Common_Unsubscribe_DeviceTwin(IOTHUB_DEVICE_HANDLE handle)
AzureIoTClient	12:658ca6865de2	2158	{
AzureIoTClient	12:658ca6865de2	2159	PMQTTTRANSPORT_HANDLE_DATA transport_data = (PMQTTTRANSPORT_HANDLE_DATA)handle;
AzureIoTClient	12:658ca6865de2	2160	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_048: [If the parameter handle is NULL than IoTHubTransport_MQTT_Common_Unsubscribe_DeviceTwin shall do nothing.] */
AzureIoTClient	12:658ca6865de2	2161	if (transport_data != NULL)
AzureIoTClient	12:658ca6865de2	2162	{
AzureIoTClient	12:658ca6865de2	2163	if (transport_data->topic_GetState != NULL)
AzureIoTClient	12:658ca6865de2	2164	{
AzureIoTClient	12:658ca6865de2	2165	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_049: [If subscribe_state is set to IOTHUB_DEVICE_TWIN_DESIRED_STATE then IoTHubTransport_MQTT_Common_Unsubscribe_DeviceTwin shall unsubscribe from the topic_GetState to the mqtt client.] */
AzureIoTClient	12:658ca6865de2	2166	transport_data->topics_ToSubscribe &= ~SUBSCRIBE_GET_REPORTED_STATE_TOPIC;
AzureIoTClient	12:658ca6865de2	2167	STRING_delete(transport_data->topic_GetState);
AzureIoTClient	12:658ca6865de2	2168	transport_data->topic_GetState = NULL;
AzureIoTClient	12:658ca6865de2	2169	}
AzureIoTClient	12:658ca6865de2	2170	if (transport_data->topic_NotifyState != NULL)
AzureIoTClient	12:658ca6865de2	2171	{
AzureIoTClient	12:658ca6865de2	2172	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_050: [If subscribe_state is set to IOTHUB_DEVICE_TWIN_NOTIFICATION_STATE then IoTHubTransport_MQTT_Common_Unsubscribe_DeviceTwin shall unsubscribe from the topic_NotifyState to the mqtt client.] */
AzureIoTClient	12:658ca6865de2	2173	transport_data->topics_ToSubscribe &= ~SUBSCRIBE_NOTIFICATION_STATE_TOPIC;
AzureIoTClient	12:658ca6865de2	2174	STRING_delete(transport_data->topic_NotifyState);
AzureIoTClient	12:658ca6865de2	2175	transport_data->topic_NotifyState = NULL;
AzureIoTClient	12:658ca6865de2	2176	}
AzureIoTClient	12:658ca6865de2	2177	}
AzureIoTClient	12:658ca6865de2	2178	else
AzureIoTClient	12:658ca6865de2	2179	{
AzureIoTClient	12:658ca6865de2	2180	LogError("Invalid argument to unsubscribe (handle is NULL).");
AzureIoTClient	12:658ca6865de2	2181	}
AzureIoTClient	12:658ca6865de2	2182	}
AzureIoTClient	12:658ca6865de2	2183
AzureIoTClient	12:658ca6865de2	2184	int IoTHubTransport_MQTT_Common_Subscribe_DeviceMethod(IOTHUB_DEVICE_HANDLE handle)
AzureIoTClient	12:658ca6865de2	2185	{
AzureIoTClient	12:658ca6865de2	2186	int result;
AzureIoTClient	12:658ca6865de2	2187	PMQTTTRANSPORT_HANDLE_DATA transport_data = (PMQTTTRANSPORT_HANDLE_DATA)handle;
AzureIoTClient	12:658ca6865de2	2188
AzureIoTClient	12:658ca6865de2	2189	if (transport_data == NULL)
AzureIoTClient	12:658ca6865de2	2190	{
AzureIoTClient	12:658ca6865de2	2191	/Codes_SRS_IOTHUB_MQTT_TRANSPORT_12_001 : [If the parameter handle is NULL than IoTHubTransport_MQTT_Common_Subscribe_DeviceMethod shall return a non - zero value.]/
AzureIoTClient	12:658ca6865de2	2192	LogError("Invalid handle parameter. NULL.");
AzureIoTClient	18:ec8e5e97c6a4	2193	result = __FAILURE__;
AzureIoTClient	12:658ca6865de2	2194	}
AzureIoTClient	12:658ca6865de2	2195	else
AzureIoTClient	12:658ca6865de2	2196	{
AzureIoTClient	12:658ca6865de2	2197	if (transport_data->topic_DeviceMethods == NULL)
AzureIoTClient	12:658ca6865de2	2198	{
AzureIoTClient	12:658ca6865de2	2199	/Codes_SRS_IOTHUB_MQTT_TRANSPORT_12_004 : [IoTHubTransport_MQTT_Common_Subscribe_DeviceMethod shall construct the DEVICE_METHOD topic string for subscribe.]/
AzureIoTClient	12:658ca6865de2	2200	transport_data->topic_DeviceMethods = STRING_construct(TOPIC_DEVICE_METHOD_SUBSCRIBE);
AzureIoTClient	12:658ca6865de2	2201	if (transport_data->topic_DeviceMethods == NULL)
AzureIoTClient	12:658ca6865de2	2202	{
AzureIoTClient	12:658ca6865de2	2203	/Codes_SRS_IOTHUB_MQTT_TRANSPORT_12_006 : [Upon failure IoTHubTransport_MQTT_Common_Subscribe_DeviceMethod shall return a non - zero value.]/
AzureIoTClient	12:658ca6865de2	2204	LogError("Failure: unable constructing device method subscribe topic");
AzureIoTClient	18:ec8e5e97c6a4	2205	result = __FAILURE__;
AzureIoTClient	12:658ca6865de2	2206	}
AzureIoTClient	12:658ca6865de2	2207	else
AzureIoTClient	12:658ca6865de2	2208	{
AzureIoTClient	12:658ca6865de2	2209	/Codes_SRS_IOTHUB_MQTT_TRANSPORT_12_003 : [IoTHubTransport_MQTT_Common_Subscribe_DeviceMethod shall set the signaling flag for DEVICE_METHOD topic for the receiver's topic list. ]/
AzureIoTClient	12:658ca6865de2	2210	transport_data->topics_ToSubscribe \|= SUBSCRIBE_DEVICE_METHOD_TOPIC;
AzureIoTClient	12:658ca6865de2	2211	result = 0;
AzureIoTClient	12:658ca6865de2	2212	}
AzureIoTClient	12:658ca6865de2	2213	}
AzureIoTClient	12:658ca6865de2	2214	else
AzureIoTClient	12:658ca6865de2	2215	{
AzureIoTClient	12:658ca6865de2	2216	/Codes_SRS_IOTHUB_MQTT_TRANSPORT_12_002 : [If the MQTT transport has been previously subscribed to DEVICE_METHOD topic IoTHubTransport_MQTT_Common_Subscribe_DeviceMethod shall do nothing and return 0.]/
AzureIoTClient	12:658ca6865de2	2217	result = 0;
AzureIoTClient	12:658ca6865de2	2218	}
AzureIoTClient	12:658ca6865de2	2219
AzureIoTClient	12:658ca6865de2	2220	if (result == 0)
AzureIoTClient	12:658ca6865de2	2221	{
AzureIoTClient	12:658ca6865de2	2222	/Codes_SRS_IOTHUB_MQTT_TRANSPORT_12_005 : [IoTHubTransport_MQTT_Common_Subscribe_DeviceMethod shall schedule the send of the subscription.]/
AzureIoTClient	12:658ca6865de2	2223	/Codes_SRS_IOTHUB_MQTT_TRANSPORT_12_007 : [On success IoTHubTransport_MQTT_Common_Subscribe_DeviceMethod shall return 0.]/
AzureIoTClient	12:658ca6865de2	2224	if (transport_data->currPacketState != CONNACK_TYPE &&
AzureIoTClient	12:658ca6865de2	2225	transport_data->currPacketState != CONNECT_TYPE &&
AzureIoTClient	12:658ca6865de2	2226	transport_data->currPacketState != DISCONNECT_TYPE &&
AzureIoTClient	12:658ca6865de2	2227	transport_data->currPacketState != PACKET_TYPE_ERROR)
AzureIoTClient	12:658ca6865de2	2228	{
AzureIoTClient	12:658ca6865de2	2229	transport_data->currPacketState = SUBSCRIBE_TYPE;
AzureIoTClient	12:658ca6865de2	2230	}
AzureIoTClient	12:658ca6865de2	2231	}
AzureIoTClient	12:658ca6865de2	2232	}
AzureIoTClient	12:658ca6865de2	2233	return result;
AzureIoTClient	12:658ca6865de2	2234	}
AzureIoTClient	12:658ca6865de2	2235
AzureIoTClient	12:658ca6865de2	2236	void IoTHubTransport_MQTT_Common_Unsubscribe_DeviceMethod(IOTHUB_DEVICE_HANDLE handle)
AzureIoTClient	12:658ca6865de2	2237	{
AzureIoTClient	12:658ca6865de2	2238	PMQTTTRANSPORT_HANDLE_DATA transport_data = (PMQTTTRANSPORT_HANDLE_DATA)handle;
AzureIoTClient	12:658ca6865de2	2239	/Codes_SRS_IOTHUB_MQTT_TRANSPORT_12_008 : [If the parameter handle is NULL than IoTHubTransport_MQTT_Common_Unsubscribe_DeviceMethod shall do nothing and return.]/
AzureIoTClient	12:658ca6865de2	2240	if (transport_data != NULL)
AzureIoTClient	12:658ca6865de2	2241	{
AzureIoTClient	12:658ca6865de2	2242	/Codes_SRS_IOTHUB_MQTT_TRANSPORT_12_009 : [If the MQTT transport has not been subscribed to DEVICE_METHOD topic IoTHubTransport_MQTT_Common_Unsubscribe_DeviceMethod shall do nothing and return.]/
AzureIoTClient	12:658ca6865de2	2243	if (transport_data->topic_DeviceMethods != NULL)
AzureIoTClient	12:658ca6865de2	2244	{
AzureIoTClient	12:658ca6865de2	2245	/Codes_SRS_IOTHUB_MQTT_TRANSPORT_12_010 : [IoTHubTransport_MQTT_Common_Unsubscribe_DeviceMethod shall construct the DEVICE_METHOD topic string for unsubscribe.]/
AzureIoTClient	12:658ca6865de2	2246	const char* unsubscribe[1];
AzureIoTClient	12:658ca6865de2	2247	unsubscribe[0] = STRING_c_str(transport_data->topic_DeviceMethods);
AzureIoTClient	12:658ca6865de2	2248
AzureIoTClient	12:658ca6865de2	2249	/Codes_SRS_IOTHUB_MQTT_TRANSPORT_12_011 : [IoTHubTransport_MQTT_Common_Unsubscribe_DeviceMethod shall send the unsubscribe.]/
AzureIoTClient	12:658ca6865de2	2250	if (mqtt_client_unsubscribe(transport_data->mqttClient, get_next_packet_id(transport_data), unsubscribe, 1) != 0)
AzureIoTClient	12:658ca6865de2	2251	{
AzureIoTClient	12:658ca6865de2	2252	LogError("Failure calling mqtt_client_unsubscribe");
AzureIoTClient	12:658ca6865de2	2253	}
AzureIoTClient	12:658ca6865de2	2254
AzureIoTClient	12:658ca6865de2	2255	/Codes_SRS_IOTHUB_MQTT_TRANSPORT_12_012 : [IoTHubTransport_MQTT_Common_Unsubscribe_DeviceMethod shall removes the signaling flag for DEVICE_METHOD topic from the receiver's topic list. ]/
AzureIoTClient	12:658ca6865de2	2256	STRING_delete(transport_data->topic_DeviceMethods);
AzureIoTClient	12:658ca6865de2	2257	transport_data->topic_DeviceMethods = NULL;
AzureIoTClient	12:658ca6865de2	2258	transport_data->topics_ToSubscribe &= ~SUBSCRIBE_DEVICE_METHOD_TOPIC;
AzureIoTClient	12:658ca6865de2	2259	}
AzureIoTClient	12:658ca6865de2	2260	}
AzureIoTClient	12:658ca6865de2	2261	else
AzureIoTClient	12:658ca6865de2	2262	{
AzureIoTClient	12:658ca6865de2	2263	LogError("Invalid argument to unsubscribe (NULL).");
AzureIoTClient	12:658ca6865de2	2264	}
AzureIoTClient	12:658ca6865de2	2265	}
AzureIoTClient	12:658ca6865de2	2266
AzureIoTClient	14:4dc2b011be33	2267	int IoTHubTransport_MQTT_Common_DeviceMethod_Response(IOTHUB_DEVICE_HANDLE handle, METHOD_HANDLE methodId, const unsigned char* response, size_t respSize, int status)
AzureIoTClient	14:4dc2b011be33	2268	{
AzureIoTClient	14:4dc2b011be33	2269	int result;
AzureIoTClient	14:4dc2b011be33	2270	MQTTTRANSPORT_HANDLE_DATA* transport_data = (MQTTTRANSPORT_HANDLE_DATA*)handle;
AzureIoTClient	14:4dc2b011be33	2271	if (transport_data != NULL)
AzureIoTClient	14:4dc2b011be33	2272	{
AzureIoTClient	14:4dc2b011be33	2273	/* Codes_SRS_IOTHUB_TRANSPORT_MQTT_COMMON_07_042: [ IoTHubTransport_MQTT_Common_DeviceMethod_Response shall publish an mqtt message for the device method response. ] */
AzureIoTClient	14:4dc2b011be33	2274	DEVICE_METHOD_INFO* dev_method_info = (DEVICE_METHOD_INFO*)methodId;
AzureIoTClient	14:4dc2b011be33	2275	if (dev_method_info == NULL)
AzureIoTClient	14:4dc2b011be33	2276	{
AzureIoTClient	14:4dc2b011be33	2277	LogError("Failure: DEVICE_METHOD_INFO was NULL");
AzureIoTClient	18:ec8e5e97c6a4	2278	result = __FAILURE__;
AzureIoTClient	14:4dc2b011be33	2279	}
AzureIoTClient	14:4dc2b011be33	2280	else
AzureIoTClient	14:4dc2b011be33	2281	{
AzureIoTClient	14:4dc2b011be33	2282	if (publish_device_method_message(transport_data, status, dev_method_info->request_id, response, respSize) != 0)
AzureIoTClient	14:4dc2b011be33	2283	{
AzureIoTClient	14:4dc2b011be33	2284	/* Codes_SRS_IOTHUB_TRANSPORT_MQTT_COMMON_07_051: [ If any error is encountered, IoTHubTransport_MQTT_Common_DeviceMethod_Response shall return a non-zero value. ] */
AzureIoTClient	14:4dc2b011be33	2285	LogError("Failure: publishing device method response");
AzureIoTClient	18:ec8e5e97c6a4	2286	result = __FAILURE__;
AzureIoTClient	14:4dc2b011be33	2287	}
AzureIoTClient	14:4dc2b011be33	2288	else
AzureIoTClient	14:4dc2b011be33	2289	{
AzureIoTClient	14:4dc2b011be33	2290	result = 0;
AzureIoTClient	14:4dc2b011be33	2291	}
AzureIoTClient	14:4dc2b011be33	2292	STRING_delete(dev_method_info->request_id);
AzureIoTClient	14:4dc2b011be33	2293	free(dev_method_info);
AzureIoTClient	14:4dc2b011be33	2294	}
AzureIoTClient	14:4dc2b011be33	2295	}
AzureIoTClient	14:4dc2b011be33	2296	else
AzureIoTClient	14:4dc2b011be33	2297	{
AzureIoTClient	14:4dc2b011be33	2298	/* Codes_SRS_IOTHUB_TRANSPORT_MQTT_COMMON_07_041: [ If the parameter handle is NULL than IoTHubTransport_MQTT_Common_DeviceMethod_Response shall return a non-zero value. ] */
AzureIoTClient	18:ec8e5e97c6a4	2299	result = __FAILURE__;
AzureIoTClient	14:4dc2b011be33	2300	LogError("Failure: invalid IOTHUB_DEVICE_HANDLE parameter specified");
AzureIoTClient	14:4dc2b011be33	2301	}
AzureIoTClient	14:4dc2b011be33	2302	return result;
AzureIoTClient	14:4dc2b011be33	2303	}
AzureIoTClient	14:4dc2b011be33	2304
AzureIoTClient	11:31ebaeb51e1e	2305	int IoTHubTransport_MQTT_Common_Subscribe(IOTHUB_DEVICE_HANDLE handle)
AzureIoTClient	11:31ebaeb51e1e	2306	{
AzureIoTClient	11:31ebaeb51e1e	2307	int result;
AzureIoTClient	11:31ebaeb51e1e	2308	PMQTTTRANSPORT_HANDLE_DATA transport_data = (PMQTTTRANSPORT_HANDLE_DATA)handle;
AzureIoTClient	11:31ebaeb51e1e	2309	if (transport_data == NULL)
AzureIoTClient	11:31ebaeb51e1e	2310	{
AzureIoTClient	12:658ca6865de2	2311	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_015: [If parameter handle is NULL than IoTHubTransport_MQTT_Common_Subscribe shall return a non-zero value.] */
AzureIoTClient	11:31ebaeb51e1e	2312	LogError("Invalid handle parameter. NULL.");
AzureIoTClient	18:ec8e5e97c6a4	2313	result = __FAILURE__;
AzureIoTClient	11:31ebaeb51e1e	2314	}
AzureIoTClient	11:31ebaeb51e1e	2315	else
AzureIoTClient	11:31ebaeb51e1e	2316	{
AzureIoTClient	12:658ca6865de2	2317	/* Code_SRS_IOTHUB_MQTT_TRANSPORT_07_016: [IoTHubTransport_MQTT_Common_Subscribe shall set a flag to enable mqtt_client_subscribe to be called to subscribe to the Message Topic.] */
AzureIoTClient	11:31ebaeb51e1e	2318	transport_data->topic_MqttMessage = STRING_construct_sprintf(TOPIC_DEVICE_MSG, STRING_c_str(transport_data->device_id) );
AzureIoTClient	11:31ebaeb51e1e	2319	if (transport_data->topic_MqttMessage == NULL)
AzureIoTClient	11:31ebaeb51e1e	2320	{
AzureIoTClient	11:31ebaeb51e1e	2321	LogError("Failure constructing Message Topic");
AzureIoTClient	18:ec8e5e97c6a4	2322	result = __FAILURE__;
AzureIoTClient	11:31ebaeb51e1e	2323	}
AzureIoTClient	11:31ebaeb51e1e	2324	else
AzureIoTClient	11:31ebaeb51e1e	2325	{
AzureIoTClient	11:31ebaeb51e1e	2326	transport_data->topics_ToSubscribe \|= SUBSCRIBE_TELEMETRY_TOPIC;
AzureIoTClient	12:658ca6865de2	2327	/* Code_SRS_IOTHUB_MQTT_TRANSPORT_07_035: [If current packet state is not CONNACT, DISCONNECT_TYPE, or PACKET_TYPE_ERROR then IoTHubTransport_MQTT_Common_Subscribe shall set the packet state to SUBSCRIBE_TYPE.]*/
AzureIoTClient	11:31ebaeb51e1e	2328	if (transport_data->currPacketState != CONNACK_TYPE &&
AzureIoTClient	11:31ebaeb51e1e	2329	transport_data->currPacketState != CONNECT_TYPE &&
AzureIoTClient	11:31ebaeb51e1e	2330	transport_data->currPacketState != DISCONNECT_TYPE &&
AzureIoTClient	11:31ebaeb51e1e	2331	transport_data->currPacketState != PACKET_TYPE_ERROR)
AzureIoTClient	11:31ebaeb51e1e	2332	{
AzureIoTClient	11:31ebaeb51e1e	2333	transport_data->currPacketState = SUBSCRIBE_TYPE;
AzureIoTClient	11:31ebaeb51e1e	2334	}
AzureIoTClient	11:31ebaeb51e1e	2335	result = 0;
AzureIoTClient	11:31ebaeb51e1e	2336	}
AzureIoTClient	11:31ebaeb51e1e	2337	}
AzureIoTClient	11:31ebaeb51e1e	2338	return result;
AzureIoTClient	11:31ebaeb51e1e	2339	}
AzureIoTClient	11:31ebaeb51e1e	2340
AzureIoTClient	11:31ebaeb51e1e	2341	void IoTHubTransport_MQTT_Common_Unsubscribe(IOTHUB_DEVICE_HANDLE handle)
AzureIoTClient	11:31ebaeb51e1e	2342	{
AzureIoTClient	11:31ebaeb51e1e	2343	PMQTTTRANSPORT_HANDLE_DATA transport_data = (PMQTTTRANSPORT_HANDLE_DATA)handle;
AzureIoTClient	12:658ca6865de2	2344	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_019: [If parameter handle is NULL then IoTHubTransport_MQTT_Common_Unsubscribe shall do nothing.] */
AzureIoTClient	11:31ebaeb51e1e	2345	if (transport_data != NULL)
AzureIoTClient	11:31ebaeb51e1e	2346	{
AzureIoTClient	12:658ca6865de2	2347	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_020: [IoTHubTransport_MQTT_Common_Unsubscribe shall call mqtt_client_unsubscribe to unsubscribe the mqtt message topic.] */
AzureIoTClient	11:31ebaeb51e1e	2348	const char* unsubscribe[1];
AzureIoTClient	11:31ebaeb51e1e	2349	unsubscribe[0] = STRING_c_str(transport_data->topic_MqttMessage);
AzureIoTClient	11:31ebaeb51e1e	2350	if (mqtt_client_unsubscribe(transport_data->mqttClient, get_next_packet_id(transport_data), unsubscribe, 1) != 0)
AzureIoTClient	11:31ebaeb51e1e	2351	{
AzureIoTClient	11:31ebaeb51e1e	2352	LogError("Failure calling mqtt_client_unsubscribe");
AzureIoTClient	11:31ebaeb51e1e	2353	}
AzureIoTClient	11:31ebaeb51e1e	2354	STRING_delete(transport_data->topic_MqttMessage);
AzureIoTClient	11:31ebaeb51e1e	2355	transport_data->topic_MqttMessage = NULL;
AzureIoTClient	11:31ebaeb51e1e	2356	transport_data->topics_ToSubscribe &= ~SUBSCRIBE_TELEMETRY_TOPIC;
AzureIoTClient	11:31ebaeb51e1e	2357	}
AzureIoTClient	11:31ebaeb51e1e	2358	else
AzureIoTClient	11:31ebaeb51e1e	2359	{
AzureIoTClient	11:31ebaeb51e1e	2360	LogError("Invalid argument to unsubscribe (NULL).");
AzureIoTClient	11:31ebaeb51e1e	2361	}
AzureIoTClient	11:31ebaeb51e1e	2362	}
AzureIoTClient	11:31ebaeb51e1e	2363
AzureIoTClient	12:658ca6865de2	2364	IOTHUB_PROCESS_ITEM_RESULT IoTHubTransport_MQTT_Common_ProcessItem(TRANSPORT_LL_HANDLE handle, IOTHUB_IDENTITY_TYPE item_type, IOTHUB_IDENTITY_INFO* iothub_item)
AzureIoTClient	12:658ca6865de2	2365	{
AzureIoTClient	12:658ca6865de2	2366	IOTHUB_PROCESS_ITEM_RESULT result;
AzureIoTClient	12:658ca6865de2	2367	/* Codes_SRS_IOTHUBCLIENT_LL_07_001: [ If handle or iothub_item are NULL then IoTHubTransport_MQTT_Common_ProcessItem shall return IOTHUB_PROCESS_ERROR. ]*/
AzureIoTClient	12:658ca6865de2	2368	if (handle == NULL \|\| iothub_item == NULL)
AzureIoTClient	12:658ca6865de2	2369	{
AzureIoTClient	12:658ca6865de2	2370	LogError("Invalid handle parameter iothub_item=%p", iothub_item);
AzureIoTClient	12:658ca6865de2	2371	result = IOTHUB_PROCESS_ERROR;
AzureIoTClient	12:658ca6865de2	2372	}
AzureIoTClient	12:658ca6865de2	2373	else
AzureIoTClient	12:658ca6865de2	2374	{
AzureIoTClient	12:658ca6865de2	2375	PMQTTTRANSPORT_HANDLE_DATA transport_data = (PMQTTTRANSPORT_HANDLE_DATA)handle;
AzureIoTClient	12:658ca6865de2	2376
AzureIoTClient	12:658ca6865de2	2377	if (transport_data->currPacketState == PUBLISH_TYPE)
AzureIoTClient	12:658ca6865de2	2378	{
AzureIoTClient	12:658ca6865de2	2379	if (item_type == IOTHUB_TYPE_DEVICE_TWIN)
AzureIoTClient	12:658ca6865de2	2380	{
AzureIoTClient	12:658ca6865de2	2381	MQTT_DEVICE_TWIN_ITEM* mqtt_info = (MQTT_DEVICE_TWIN_ITEM*)malloc(sizeof(MQTT_DEVICE_TWIN_ITEM));
AzureIoTClient	12:658ca6865de2	2382	if (mqtt_info == NULL)
AzureIoTClient	12:658ca6865de2	2383	{
AzureIoTClient	12:658ca6865de2	2384	/* Codes_SRS_IOTHUBCLIENT_LL_07_004: [ If any errors are encountered IoTHubTransport_MQTT_Common_ProcessItem shall return IOTHUB_PROCESS_ERROR. ]*/
AzureIoTClient	12:658ca6865de2	2385	result = IOTHUB_PROCESS_ERROR;
AzureIoTClient	12:658ca6865de2	2386	}
AzureIoTClient	12:658ca6865de2	2387	else
AzureIoTClient	12:658ca6865de2	2388	{
AzureIoTClient	12:658ca6865de2	2389	/Codes_SRS_IOTHUBCLIENT_LL_07_003: [ IoTHubTransport_MQTT_Common_ProcessItem shall publish a message to the mqtt protocol with the message topic for the message type.]/
AzureIoTClient	12:658ca6865de2	2390	mqtt_info->iothub_type = item_type;
AzureIoTClient	12:658ca6865de2	2391	mqtt_info->iothub_msg_id = iothub_item->device_twin->item_id;
AzureIoTClient	12:658ca6865de2	2392	mqtt_info->retryCount = 0;
AzureIoTClient	12:658ca6865de2	2393
AzureIoTClient	12:658ca6865de2	2394	/* Codes_SRS_IOTHUBCLIENT_LL_07_005: [ If successful IoTHubTransport_MQTT_Common_ProcessItem shall add mqtt info structure acknowledgement queue. ] */
AzureIoTClient	12:658ca6865de2	2395	DList_InsertTailList(&transport_data->ack_waiting_queue, &mqtt_info->entry);
AzureIoTClient	12:658ca6865de2	2396
AzureIoTClient	12:658ca6865de2	2397	if (publish_device_twin_message(transport_data, iothub_item->device_twin, mqtt_info) != 0)
AzureIoTClient	12:658ca6865de2	2398	{
AzureIoTClient	12:658ca6865de2	2399	DList_RemoveEntryList(&mqtt_info->entry);
AzureIoTClient	12:658ca6865de2	2400
AzureIoTClient	12:658ca6865de2	2401	free(mqtt_info);
AzureIoTClient	12:658ca6865de2	2402	/* Codes_SRS_IOTHUBCLIENT_LL_07_004: [ If any errors are encountered IoTHubTransport_MQTT_Common_ProcessItem shall return IOTHUB_PROCESS_ERROR. ]*/
AzureIoTClient	12:658ca6865de2	2403	result = IOTHUB_PROCESS_ERROR;
AzureIoTClient	12:658ca6865de2	2404	}
AzureIoTClient	12:658ca6865de2	2405	else
AzureIoTClient	12:658ca6865de2	2406	{
AzureIoTClient	12:658ca6865de2	2407	result = IOTHUB_PROCESS_OK;
AzureIoTClient	12:658ca6865de2	2408	}
AzureIoTClient	12:658ca6865de2	2409	}
AzureIoTClient	12:658ca6865de2	2410	}
AzureIoTClient	12:658ca6865de2	2411	else
AzureIoTClient	12:658ca6865de2	2412	{
AzureIoTClient	12:658ca6865de2	2413	/* Codes_SRS_IOTHUBCLIENT_LL_07_006: [ If the item_type is not a supported type IoTHubTransport_MQTT_Common_ProcessItem shall return IOTHUB_PROCESS_CONTINUE. ]*/
AzureIoTClient	12:658ca6865de2	2414	result = IOTHUB_PROCESS_CONTINUE;
AzureIoTClient	12:658ca6865de2	2415	}
AzureIoTClient	12:658ca6865de2	2416	}
AzureIoTClient	12:658ca6865de2	2417	else
AzureIoTClient	12:658ca6865de2	2418	{
AzureIoTClient	12:658ca6865de2	2419	/* Codes_SRS_IOTHUBCLIENT_LL_07_002: [ If the mqtt is not ready to publish messages IoTHubTransport_MQTT_Common_ProcessItem shall return IOTHUB_PROCESS_NOT_CONNECTED. ] */
AzureIoTClient	12:658ca6865de2	2420	result = IOTHUB_PROCESS_NOT_CONNECTED;
AzureIoTClient	12:658ca6865de2	2421	}
AzureIoTClient	12:658ca6865de2	2422	}
AzureIoTClient	12:658ca6865de2	2423	return result;
AzureIoTClient	12:658ca6865de2	2424	}
AzureIoTClient	12:658ca6865de2	2425
AzureIoTClient	12:658ca6865de2	2426	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_054: [ IoTHubTransport_MQTT_Common_DoWork shall subscribe to the Notification and get_state Topics if they are defined. ] */
AzureIoTClient	11:31ebaeb51e1e	2427	void IoTHubTransport_MQTT_Common_DoWork(TRANSPORT_LL_HANDLE handle, IOTHUB_CLIENT_LL_HANDLE iotHubClientHandle)
AzureIoTClient	11:31ebaeb51e1e	2428	{
AzureIoTClient	12:658ca6865de2	2429	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_026: [IoTHubTransport_MQTT_Common_DoWork shall do nothing if parameter handle and/or iotHubClientHandle is NULL.] */
AzureIoTClient	11:31ebaeb51e1e	2430	PMQTTTRANSPORT_HANDLE_DATA transport_data = (PMQTTTRANSPORT_HANDLE_DATA)handle;
AzureIoTClient	11:31ebaeb51e1e	2431	if (transport_data != NULL && iotHubClientHandle != NULL)
AzureIoTClient	11:31ebaeb51e1e	2432	{
AzureIoTClient	11:31ebaeb51e1e	2433	transport_data->llClientHandle = iotHubClientHandle;
AzureIoTClient	11:31ebaeb51e1e	2434
AzureIoTClient	11:31ebaeb51e1e	2435	if (InitializeConnection(transport_data) != 0)
AzureIoTClient	11:31ebaeb51e1e	2436	{
AzureIoTClient	11:31ebaeb51e1e	2437	// Don't want to flood the logs with failures here
AzureIoTClient	11:31ebaeb51e1e	2438	}
AzureIoTClient	11:31ebaeb51e1e	2439	else
AzureIoTClient	11:31ebaeb51e1e	2440	{
AzureIoTClient	11:31ebaeb51e1e	2441	if (transport_data->currPacketState == CONNACK_TYPE \|\| transport_data->currPacketState == SUBSCRIBE_TYPE)
AzureIoTClient	11:31ebaeb51e1e	2442	{
AzureIoTClient	11:31ebaeb51e1e	2443	SubscribeToMqttProtocol(transport_data);
AzureIoTClient	11:31ebaeb51e1e	2444	}
AzureIoTClient	11:31ebaeb51e1e	2445	else if (transport_data->currPacketState == SUBACK_TYPE)
AzureIoTClient	11:31ebaeb51e1e	2446	{
AzureIoTClient	12:658ca6865de2	2447	if ((transport_data->topic_NotifyState != NULL \|\| transport_data->topic_GetState != NULL) &&
AzureIoTClient	12:658ca6865de2	2448	!transport_data->device_twin_get_sent)
AzureIoTClient	12:658ca6865de2	2449	{
AzureIoTClient	12:658ca6865de2	2450	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_055: [ IoTHubTransport_MQTT_Common_DoWork shall send a device twin get property message upon successfully retrieving a SUBACK on device twin topics. ] */
AzureIoTClient	12:658ca6865de2	2451	if (publish_device_twin_get_message(transport_data) == 0)
AzureIoTClient	12:658ca6865de2	2452	{
AzureIoTClient	12:658ca6865de2	2453	transport_data->device_twin_get_sent = true;
AzureIoTClient	12:658ca6865de2	2454	}
AzureIoTClient	12:658ca6865de2	2455	else
AzureIoTClient	12:658ca6865de2	2456	{
AzureIoTClient	12:658ca6865de2	2457	LogError("Failure: sending device twin get property command.");
AzureIoTClient	12:658ca6865de2	2458	}
AzureIoTClient	12:658ca6865de2	2459	}
AzureIoTClient	11:31ebaeb51e1e	2460	// Publish can be called now
AzureIoTClient	11:31ebaeb51e1e	2461	transport_data->currPacketState = PUBLISH_TYPE;
AzureIoTClient	11:31ebaeb51e1e	2462	}
AzureIoTClient	11:31ebaeb51e1e	2463	else if (transport_data->currPacketState == PUBLISH_TYPE)
AzureIoTClient	11:31ebaeb51e1e	2464	{
AzureIoTClient	11:31ebaeb51e1e	2465	PDLIST_ENTRY currentListEntry = transport_data->telemetry_waitingForAck.Flink;
AzureIoTClient	11:31ebaeb51e1e	2466	while (currentListEntry != &transport_data->telemetry_waitingForAck)
AzureIoTClient	11:31ebaeb51e1e	2467	{
AzureIoTClient	11:31ebaeb51e1e	2468	MQTT_MESSAGE_DETAILS_LIST* mqttMsgEntry = containingRecord(currentListEntry, MQTT_MESSAGE_DETAILS_LIST, entry);
AzureIoTClient	11:31ebaeb51e1e	2469	DLIST_ENTRY nextListEntry;
AzureIoTClient	11:31ebaeb51e1e	2470	nextListEntry.Flink = currentListEntry->Flink;
AzureIoTClient	11:31ebaeb51e1e	2471
Azure.IoT.Build	13:606465879c57	2472	tickcounter_ms_t current_ms;
Azure.IoT.Build	13:606465879c57	2473	(void)tickcounter_get_current_ms(transport_data->msgTickCounter, &current_ms);
AzureIoTClient	12:658ca6865de2	2474	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_033: [IoTHubTransport_MQTT_Common_DoWork shall iterate through the Waiting Acknowledge messages looking for any message that has been waiting longer than 2 min.]*/
AzureIoTClient	11:31ebaeb51e1e	2475	if (((current_ms - mqttMsgEntry->msgPublishTime) / 1000) > RESEND_TIMEOUT_VALUE_MIN)
AzureIoTClient	11:31ebaeb51e1e	2476	{
AzureIoTClient	12:658ca6865de2	2477	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_034: [If IoTHubTransport_MQTT_Common_DoWork has resent the message two times then it shall fail the message] */
AzureIoTClient	11:31ebaeb51e1e	2478	if (mqttMsgEntry->retryCount >= MAX_SEND_RECOUNT_LIMIT)
AzureIoTClient	11:31ebaeb51e1e	2479	{
AzureIoTClient	11:31ebaeb51e1e	2480	(void)DList_RemoveEntryList(currentListEntry);
AzureIoTClient	11:31ebaeb51e1e	2481	sendMsgComplete(mqttMsgEntry->iotHubMessageEntry, transport_data, IOTHUB_CLIENT_CONFIRMATION_MESSAGE_TIMEOUT);
AzureIoTClient	11:31ebaeb51e1e	2482	free(mqttMsgEntry);
AzureIoTClient	11:31ebaeb51e1e	2483	}
AzureIoTClient	11:31ebaeb51e1e	2484	else
AzureIoTClient	11:31ebaeb51e1e	2485	{
AzureIoTClient	11:31ebaeb51e1e	2486	size_t messageLength;
AzureIoTClient	11:31ebaeb51e1e	2487	const unsigned char* messagePayload = RetrieveMessagePayload(mqttMsgEntry->iotHubMessageEntry->messageHandle, &messageLength);
AzureIoTClient	11:31ebaeb51e1e	2488	if (messageLength == 0 \|\| messagePayload == NULL)
AzureIoTClient	11:31ebaeb51e1e	2489	{
AzureIoTClient	11:31ebaeb51e1e	2490	LogError("Failure from creating Message IoTHubMessage_GetData");
AzureIoTClient	11:31ebaeb51e1e	2491	}
AzureIoTClient	11:31ebaeb51e1e	2492	else
AzureIoTClient	11:31ebaeb51e1e	2493	{
AzureIoTClient	11:31ebaeb51e1e	2494	if (publish_mqtt_telemetry_msg(transport_data, mqttMsgEntry, messagePayload, messageLength) != 0)
AzureIoTClient	11:31ebaeb51e1e	2495	{
AzureIoTClient	11:31ebaeb51e1e	2496	(void)DList_RemoveEntryList(currentListEntry);
AzureIoTClient	11:31ebaeb51e1e	2497	sendMsgComplete(mqttMsgEntry->iotHubMessageEntry, transport_data, IOTHUB_CLIENT_CONFIRMATION_ERROR);
AzureIoTClient	11:31ebaeb51e1e	2498	free(mqttMsgEntry);
AzureIoTClient	11:31ebaeb51e1e	2499	}
AzureIoTClient	11:31ebaeb51e1e	2500	}
AzureIoTClient	11:31ebaeb51e1e	2501	}
AzureIoTClient	11:31ebaeb51e1e	2502	}
AzureIoTClient	11:31ebaeb51e1e	2503	currentListEntry = nextListEntry.Flink;
AzureIoTClient	11:31ebaeb51e1e	2504	}
AzureIoTClient	11:31ebaeb51e1e	2505
AzureIoTClient	11:31ebaeb51e1e	2506	currentListEntry = transport_data->waitingToSend->Flink;
AzureIoTClient	12:658ca6865de2	2507	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_027: [IoTHubTransport_MQTT_Common_DoWork shall inspect the "waitingToSend" DLIST passed in config structure.] */
AzureIoTClient	11:31ebaeb51e1e	2508	while (currentListEntry != transport_data->waitingToSend)
AzureIoTClient	11:31ebaeb51e1e	2509	{
AzureIoTClient	11:31ebaeb51e1e	2510	IOTHUB_MESSAGE_LIST* iothubMsgList = containingRecord(currentListEntry, IOTHUB_MESSAGE_LIST, entry);
AzureIoTClient	11:31ebaeb51e1e	2511	DLIST_ENTRY savedFromCurrentListEntry;
AzureIoTClient	11:31ebaeb51e1e	2512	savedFromCurrentListEntry.Flink = currentListEntry->Flink;
AzureIoTClient	11:31ebaeb51e1e	2513
AzureIoTClient	12:658ca6865de2	2514	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_027: [IoTHubTransport_MQTT_Common_DoWork shall inspect the "waitingToSend" DLIST passed in config structure.] */
AzureIoTClient	11:31ebaeb51e1e	2515	size_t messageLength;
AzureIoTClient	11:31ebaeb51e1e	2516	const unsigned char* messagePayload = RetrieveMessagePayload(iothubMsgList->messageHandle, &messageLength);
AzureIoTClient	11:31ebaeb51e1e	2517	if (messageLength == 0 \|\| messagePayload == NULL)
AzureIoTClient	11:31ebaeb51e1e	2518	{
AzureIoTClient	11:31ebaeb51e1e	2519	LogError("Failure result from IoTHubMessage_GetData");
AzureIoTClient	11:31ebaeb51e1e	2520	}
AzureIoTClient	11:31ebaeb51e1e	2521	else
AzureIoTClient	11:31ebaeb51e1e	2522	{
AzureIoTClient	12:658ca6865de2	2523	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_029: [IoTHubTransport_MQTT_Common_DoWork shall create a MQTT_MESSAGE_HANDLE and pass this to a call to mqtt_client_publish.] */
AzureIoTClient	11:31ebaeb51e1e	2524	MQTT_MESSAGE_DETAILS_LIST* mqttMsgEntry = (MQTT_MESSAGE_DETAILS_LIST*)malloc(sizeof(MQTT_MESSAGE_DETAILS_LIST));
AzureIoTClient	11:31ebaeb51e1e	2525	if (mqttMsgEntry == NULL)
AzureIoTClient	11:31ebaeb51e1e	2526	{
AzureIoTClient	11:31ebaeb51e1e	2527	LogError("Allocation Error: Failure allocating MQTT Message Detail List.");
AzureIoTClient	11:31ebaeb51e1e	2528	}
AzureIoTClient	11:31ebaeb51e1e	2529	else
AzureIoTClient	11:31ebaeb51e1e	2530	{
AzureIoTClient	11:31ebaeb51e1e	2531	mqttMsgEntry->retryCount = 0;
AzureIoTClient	11:31ebaeb51e1e	2532	mqttMsgEntry->iotHubMessageEntry = iothubMsgList;
AzureIoTClient	11:31ebaeb51e1e	2533	mqttMsgEntry->packet_id = get_next_packet_id(transport_data);
AzureIoTClient	11:31ebaeb51e1e	2534	if (publish_mqtt_telemetry_msg(transport_data, mqttMsgEntry, messagePayload, messageLength) != 0)
AzureIoTClient	11:31ebaeb51e1e	2535	{
AzureIoTClient	11:31ebaeb51e1e	2536	(void)(DList_RemoveEntryList(currentListEntry));
AzureIoTClient	11:31ebaeb51e1e	2537	sendMsgComplete(iothubMsgList, transport_data, IOTHUB_CLIENT_CONFIRMATION_ERROR);
AzureIoTClient	11:31ebaeb51e1e	2538	free(mqttMsgEntry);
AzureIoTClient	11:31ebaeb51e1e	2539	}
AzureIoTClient	11:31ebaeb51e1e	2540	else
AzureIoTClient	11:31ebaeb51e1e	2541	{
AzureIoTClient	11:31ebaeb51e1e	2542	(void)(DList_RemoveEntryList(currentListEntry));
AzureIoTClient	11:31ebaeb51e1e	2543	DList_InsertTailList(&(transport_data->telemetry_waitingForAck), &(mqttMsgEntry->entry));
AzureIoTClient	11:31ebaeb51e1e	2544	}
AzureIoTClient	11:31ebaeb51e1e	2545	}
AzureIoTClient	11:31ebaeb51e1e	2546	}
AzureIoTClient	11:31ebaeb51e1e	2547	currentListEntry = savedFromCurrentListEntry.Flink;
AzureIoTClient	11:31ebaeb51e1e	2548	}
AzureIoTClient	11:31ebaeb51e1e	2549	}
AzureIoTClient	20:594780be216d	2550	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_030: [IoTHubTransport_MQTT_Common_DoWork shall call mqtt_client_dowork everytime it is called if it is connected.] */
AzureIoTClient	11:31ebaeb51e1e	2551	mqtt_client_dowork(transport_data->mqttClient);
AzureIoTClient	11:31ebaeb51e1e	2552	}
AzureIoTClient	11:31ebaeb51e1e	2553	}
AzureIoTClient	11:31ebaeb51e1e	2554	}
AzureIoTClient	11:31ebaeb51e1e	2555
AzureIoTClient	11:31ebaeb51e1e	2556	IOTHUB_CLIENT_RESULT IoTHubTransport_MQTT_Common_GetSendStatus(IOTHUB_DEVICE_HANDLE handle, IOTHUB_CLIENT_STATUS *iotHubClientStatus)
AzureIoTClient	11:31ebaeb51e1e	2557	{
AzureIoTClient	11:31ebaeb51e1e	2558	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	11:31ebaeb51e1e	2559
AzureIoTClient	11:31ebaeb51e1e	2560	if (handle == NULL \|\| iotHubClientStatus == NULL)
AzureIoTClient	11:31ebaeb51e1e	2561	{
AzureIoTClient	12:658ca6865de2	2562	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_023: [IoTHubTransport_MQTT_Common_GetSendStatus shall return IOTHUB_CLIENT_INVALID_ARG if called with NULL parameter.] */
AzureIoTClient	11:31ebaeb51e1e	2563	LogError("invalid arument.");
AzureIoTClient	11:31ebaeb51e1e	2564	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	11:31ebaeb51e1e	2565	}
AzureIoTClient	11:31ebaeb51e1e	2566	else
AzureIoTClient	11:31ebaeb51e1e	2567	{
AzureIoTClient	11:31ebaeb51e1e	2568	MQTTTRANSPORT_HANDLE_DATA* handleData = (MQTTTRANSPORT_HANDLE_DATA*)handle;
AzureIoTClient	11:31ebaeb51e1e	2569	if (!DList_IsListEmpty(handleData->waitingToSend) \|\| !DList_IsListEmpty(&(handleData->telemetry_waitingForAck)))
AzureIoTClient	11:31ebaeb51e1e	2570	{
AzureIoTClient	12:658ca6865de2	2571	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_025: [IoTHubTransport_MQTT_Common_GetSendStatus shall return IOTHUB_CLIENT_OK and status IOTHUB_CLIENT_SEND_STATUS_BUSY if there are currently event items to be sent or being sent.] */
AzureIoTClient	11:31ebaeb51e1e	2572	*iotHubClientStatus = IOTHUB_CLIENT_SEND_STATUS_BUSY;
AzureIoTClient	11:31ebaeb51e1e	2573	}
AzureIoTClient	11:31ebaeb51e1e	2574	else
AzureIoTClient	11:31ebaeb51e1e	2575	{
AzureIoTClient	12:658ca6865de2	2576	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_024: [IoTHubTransport_MQTT_Common_GetSendStatus shall return IOTHUB_CLIENT_OK and status IOTHUB_CLIENT_SEND_STATUS_IDLE if there are currently no event items to be sent or being sent.] */
AzureIoTClient	11:31ebaeb51e1e	2577	*iotHubClientStatus = IOTHUB_CLIENT_SEND_STATUS_IDLE;
AzureIoTClient	11:31ebaeb51e1e	2578	}
AzureIoTClient	11:31ebaeb51e1e	2579	result = IOTHUB_CLIENT_OK;
AzureIoTClient	11:31ebaeb51e1e	2580	}
AzureIoTClient	11:31ebaeb51e1e	2581	return result;
AzureIoTClient	11:31ebaeb51e1e	2582	}
AzureIoTClient	11:31ebaeb51e1e	2583
AzureIoTClient	11:31ebaeb51e1e	2584	IOTHUB_CLIENT_RESULT IoTHubTransport_MQTT_Common_SetOption(TRANSPORT_LL_HANDLE handle, const char* option, const void* value)
AzureIoTClient	11:31ebaeb51e1e	2585	{
AzureIoTClient	12:658ca6865de2	2586	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_021: [If any parameter is NULL then IoTHubTransport_MQTT_Common_SetOption shall return IOTHUB_CLIENT_INVALID_ARG.] */
AzureIoTClient	11:31ebaeb51e1e	2587	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	11:31ebaeb51e1e	2588	if (
AzureIoTClient	11:31ebaeb51e1e	2589	(handle == NULL) \|\|
AzureIoTClient	11:31ebaeb51e1e	2590	(option == NULL) \|\|
AzureIoTClient	11:31ebaeb51e1e	2591	(value == NULL)
AzureIoTClient	11:31ebaeb51e1e	2592	)
AzureIoTClient	11:31ebaeb51e1e	2593	{
AzureIoTClient	11:31ebaeb51e1e	2594	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	20:594780be216d	2595	LogError("invalid parameter (NULL) passed to IoTHubTransport_MQTT_Common_SetOption.");
AzureIoTClient	11:31ebaeb51e1e	2596	}
AzureIoTClient	11:31ebaeb51e1e	2597	else
AzureIoTClient	11:31ebaeb51e1e	2598	{
AzureIoTClient	11:31ebaeb51e1e	2599	MQTTTRANSPORT_HANDLE_DATA* transport_data = (MQTTTRANSPORT_HANDLE_DATA*)handle;
AzureIoTClient	21:167f8fcf6fb1	2600
AzureIoTClient	21:167f8fcf6fb1	2601	IOTHUB_CREDENTIAL_TYPE cred_type = IoTHubClient_Auth_Get_Credential_Type(transport_data->authorization_module);
AzureIoTClient	21:167f8fcf6fb1	2602
AzureIoTClient	11:31ebaeb51e1e	2603	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_031: [If the option parameter is set to "logtrace" then the value shall be a bool_ptr and the value will determine if the mqtt client log is on or off.] */
AzureIoTClient	11:31ebaeb51e1e	2604	if (strcmp(OPTION_LOG_TRACE, option) == 0)
AzureIoTClient	11:31ebaeb51e1e	2605	{
AzureIoTClient	11:31ebaeb51e1e	2606	transport_data->log_trace = ((bool)value);
AzureIoTClient	11:31ebaeb51e1e	2607	mqtt_client_set_trace(transport_data->mqttClient, transport_data->log_trace, transport_data->raw_trace);
AzureIoTClient	11:31ebaeb51e1e	2608	result = IOTHUB_CLIENT_OK;
AzureIoTClient	11:31ebaeb51e1e	2609	}
AzureIoTClient	11:31ebaeb51e1e	2610	else if (strcmp("rawlogtrace", option) == 0)
AzureIoTClient	11:31ebaeb51e1e	2611	{
AzureIoTClient	11:31ebaeb51e1e	2612	transport_data->raw_trace = ((bool)value);
AzureIoTClient	11:31ebaeb51e1e	2613	mqtt_client_set_trace(transport_data->mqttClient, transport_data->log_trace, transport_data->raw_trace);
AzureIoTClient	11:31ebaeb51e1e	2614	result = IOTHUB_CLIENT_OK;
AzureIoTClient	11:31ebaeb51e1e	2615	}
AzureIoTClient	11:31ebaeb51e1e	2616	else if (strcmp(OPTION_KEEP_ALIVE, option) == 0)
AzureIoTClient	11:31ebaeb51e1e	2617	{
AzureIoTClient	11:31ebaeb51e1e	2618	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_036: [If the option parameter is set to "keepalive" then the value shall be a int_ptr and the value will determine the mqtt keepalive time that is set for pings.] */
AzureIoTClient	11:31ebaeb51e1e	2619	int* keepAliveOption = (int*)value;
AzureIoTClient	12:658ca6865de2	2620	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_037 : [If the option parameter is set to supplied int_ptr keepalive is the same value as the existing keepalive then IoTHubTransport_MQTT_Common_SetOption shall do nothing.] */
AzureIoTClient	11:31ebaeb51e1e	2621	if (*keepAliveOption != transport_data->keepAliveValue)
AzureIoTClient	11:31ebaeb51e1e	2622	{
AzureIoTClient	11:31ebaeb51e1e	2623	transport_data->keepAliveValue = (uint16_t)(*keepAliveOption);
AzureIoTClient	20:594780be216d	2624	if (transport_data->mqttClientStatus != MQTT_CLIENT_STATUS_NOT_CONNECTED)
AzureIoTClient	11:31ebaeb51e1e	2625	{
AzureIoTClient	20:594780be216d	2626	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_038: [If the client is connected when the keepalive is set then IoTHubTransport_MQTT_Common_SetOption shall disconnect and reconnect with the specified keepalive value.] */
AzureIoTClient	11:31ebaeb51e1e	2627	DisconnectFromClient(transport_data);
AzureIoTClient	11:31ebaeb51e1e	2628	}
AzureIoTClient	11:31ebaeb51e1e	2629	}
AzureIoTClient	11:31ebaeb51e1e	2630	result = IOTHUB_CLIENT_OK;
AzureIoTClient	11:31ebaeb51e1e	2631	}
AzureIoTClient	11:31ebaeb51e1e	2632	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_039: [If the option parameter is set to "x509certificate" then the value shall be a const char of the certificate to be used for x509.] */
AzureIoTClient	21:167f8fcf6fb1	2633	else if ((strcmp(OPTION_X509_CERT, option) == 0) && (cred_type != IOTHUB_CREDENTIAL_TYPE_X509 && cred_type != IOTHUB_CREDENTIAL_TYPE_UNKNOWN))
AzureIoTClient	11:31ebaeb51e1e	2634	{
AzureIoTClient	11:31ebaeb51e1e	2635	LogError("x509certificate specified, but authentication method is not x509");
AzureIoTClient	11:31ebaeb51e1e	2636	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	11:31ebaeb51e1e	2637	}
AzureIoTClient	11:31ebaeb51e1e	2638	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_040: [If the option parameter is set to "x509privatekey" then the value shall be a const char of the RSA Private Key to be used for x509.] */
AzureIoTClient	21:167f8fcf6fb1	2639	else if ((strcmp(OPTION_X509_PRIVATE_KEY, option) == 0) && (cred_type != IOTHUB_CREDENTIAL_TYPE_X509 && cred_type != IOTHUB_CREDENTIAL_TYPE_UNKNOWN))
AzureIoTClient	11:31ebaeb51e1e	2640	{
AzureIoTClient	11:31ebaeb51e1e	2641	LogError("x509privatekey specified, but authentication method is not x509");
AzureIoTClient	11:31ebaeb51e1e	2642	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	11:31ebaeb51e1e	2643	}
AzureIoTClient	20:594780be216d	2644	else if (strcmp(OPTION_HTTP_PROXY, option) == 0)
AzureIoTClient	20:594780be216d	2645	{
AzureIoTClient	20:594780be216d	2646	/* Codes_SRS_IOTHUB_TRANSPORT_MQTT_COMMON_01_001: [ If `option` is `proxy_data`, `value` shall be used as an `HTTP_PROXY_OPTIONS`. ]/
AzureIoTClient	20:594780be216d	2647	HTTP_PROXY_OPTIONS* proxy_options = (HTTP_PROXY_OPTIONS*)value;
AzureIoTClient	20:594780be216d	2648
AzureIoTClient	20:594780be216d	2649	if (transport_data->xioTransport != NULL)
AzureIoTClient	20:594780be216d	2650	{
AzureIoTClient	20:594780be216d	2651	/* Codes_SRS_IOTHUB_TRANSPORT_MQTT_COMMON_01_007: [ If the underlying IO has already been created, then `IoTHubTransport_MQTT_Common_SetOption` shall fail and return `IOTHUB_CLIENT_ERROR`. ]*/
AzureIoTClient	20:594780be216d	2652	LogError("Cannot set proxy option once the underlying IO is created");
AzureIoTClient	20:594780be216d	2653	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	20:594780be216d	2654	}
AzureIoTClient	20:594780be216d	2655	else if (proxy_options->host_address == NULL)
AzureIoTClient	20:594780be216d	2656	{
AzureIoTClient	20:594780be216d	2657	/* Codes_SRS_IOTHUB_TRANSPORT_MQTT_COMMON_01_003: [ If `host_address` is NULL, `IoTHubTransport_MQTT_Common_SetOption` shall fail and return `IOTHUB_CLIENT_INVALID_ARG`. ]*/
AzureIoTClient	20:594780be216d	2658	LogError("NULL host_address in proxy options");
AzureIoTClient	20:594780be216d	2659	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	20:594780be216d	2660	}
AzureIoTClient	20:594780be216d	2661	/* Codes_SRS_IOTHUB_TRANSPORT_MQTT_COMMON_01_006: [ If only one of `username` and `password` is NULL, `IoTHubTransport_MQTT_Common_SetOption` shall fail and return `IOTHUB_CLIENT_INVALID_ARG`. ]*/
AzureIoTClient	20:594780be216d	2662	else if (((proxy_options->username == NULL) \|\| (proxy_options->password == NULL)) &&
AzureIoTClient	20:594780be216d	2663	(proxy_options->username != proxy_options->password))
AzureIoTClient	20:594780be216d	2664	{
AzureIoTClient	20:594780be216d	2665	LogError("Only one of username and password for proxy settings was NULL");
AzureIoTClient	20:594780be216d	2666	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	20:594780be216d	2667	}
AzureIoTClient	20:594780be216d	2668	else
AzureIoTClient	20:594780be216d	2669	{
AzureIoTClient	20:594780be216d	2670	char* copied_proxy_hostname = NULL;
AzureIoTClient	20:594780be216d	2671	char* copied_proxy_username = NULL;
AzureIoTClient	20:594780be216d	2672	char* copied_proxy_password = NULL;
AzureIoTClient	20:594780be216d	2673
AzureIoTClient	20:594780be216d	2674	/* Codes_SRS_IOTHUB_TRANSPORT_MQTT_COMMON_01_002: [ The fields `host_address`, `port`, `username` and `password` shall be saved for later used (needed when creating the underlying IO to be used by the transport). ]*/
AzureIoTClient	20:594780be216d	2675	transport_data->http_proxy_port = proxy_options->port;
AzureIoTClient	20:594780be216d	2676	if (mallocAndStrcpy_s(&copied_proxy_hostname, proxy_options->host_address) != 0)
AzureIoTClient	20:594780be216d	2677	{
AzureIoTClient	20:594780be216d	2678	/* Codes_SRS_IOTHUB_TRANSPORT_MQTT_COMMON_01_004: [ If copying `host_address`, `username` or `password` fails, `IoTHubTransport_MQTT_Common_SetOption` shall fail and return `IOTHUB_CLIENT_ERROR`. ]*/
AzureIoTClient	20:594780be216d	2679	LogError("Cannot copy HTTP proxy hostname");
AzureIoTClient	20:594780be216d	2680	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	20:594780be216d	2681	}
AzureIoTClient	20:594780be216d	2682	/* Codes_SRS_IOTHUB_TRANSPORT_MQTT_COMMON_01_005: [ `username` and `password` shall be allowed to be NULL. ]*/
AzureIoTClient	20:594780be216d	2683	else if ((proxy_options->username != NULL) && (mallocAndStrcpy_s(&copied_proxy_username, proxy_options->username) != 0))
AzureIoTClient	20:594780be216d	2684	{
AzureIoTClient	20:594780be216d	2685	/* Codes_SRS_IOTHUB_TRANSPORT_MQTT_COMMON_01_004: [ If copying `host_address`, `username` or `password` fails, `IoTHubTransport_MQTT_Common_SetOption` shall fail and return `IOTHUB_CLIENT_ERROR`. ]*/
AzureIoTClient	20:594780be216d	2686	free(copied_proxy_hostname);
AzureIoTClient	20:594780be216d	2687	LogError("Cannot copy HTTP proxy username");
AzureIoTClient	20:594780be216d	2688	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	20:594780be216d	2689	}
AzureIoTClient	20:594780be216d	2690	/* Codes_SRS_IOTHUB_TRANSPORT_MQTT_COMMON_01_005: [ `username` and `password` shall be allowed to be NULL. ]*/
AzureIoTClient	20:594780be216d	2691	else if ((proxy_options->password != NULL) && (mallocAndStrcpy_s(&copied_proxy_password, proxy_options->password) != 0))
AzureIoTClient	20:594780be216d	2692	{
AzureIoTClient	20:594780be216d	2693	/* Codes_SRS_IOTHUB_TRANSPORT_MQTT_COMMON_01_004: [ If copying `host_address`, `username` or `password` fails, `IoTHubTransport_MQTT_Common_SetOption` shall fail and return `IOTHUB_CLIENT_ERROR`. ]*/
AzureIoTClient	20:594780be216d	2694	if (copied_proxy_username != NULL)
AzureIoTClient	20:594780be216d	2695	{
AzureIoTClient	20:594780be216d	2696	free(copied_proxy_username);
AzureIoTClient	20:594780be216d	2697	}
AzureIoTClient	20:594780be216d	2698	free(copied_proxy_hostname);
AzureIoTClient	20:594780be216d	2699	LogError("Cannot copy HTTP proxy password");
AzureIoTClient	20:594780be216d	2700	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	20:594780be216d	2701	}
AzureIoTClient	20:594780be216d	2702	else
AzureIoTClient	20:594780be216d	2703	{
AzureIoTClient	20:594780be216d	2704	/* Codes_SRS_IOTHUB_TRANSPORT_MQTT_COMMON_01_009: [ When setting the proxy options succeeds any previously saved proxy options shall be freed. ]*/
AzureIoTClient	20:594780be216d	2705	free_proxy_data(transport_data);
AzureIoTClient	20:594780be216d	2706
AzureIoTClient	20:594780be216d	2707	transport_data->http_proxy_hostname = copied_proxy_hostname;
AzureIoTClient	20:594780be216d	2708	transport_data->http_proxy_username = copied_proxy_username;
AzureIoTClient	20:594780be216d	2709	transport_data->http_proxy_password = copied_proxy_password;
AzureIoTClient	20:594780be216d	2710
AzureIoTClient	20:594780be216d	2711	/* Codes_SRS_IOTHUB_TRANSPORT_MQTT_COMMON_01_008: [ If setting the `proxy_data` option suceeds, `IoTHubTransport_MQTT_Common_SetOption` shall return `IOTHUB_CLIENT_OK` ]*/
AzureIoTClient	20:594780be216d	2712	result = IOTHUB_CLIENT_OK;
AzureIoTClient	20:594780be216d	2713	}
AzureIoTClient	20:594780be216d	2714	}
AzureIoTClient	20:594780be216d	2715	}
AzureIoTClient	11:31ebaeb51e1e	2716	else
AzureIoTClient	11:31ebaeb51e1e	2717	{
AzureIoTClient	21:167f8fcf6fb1	2718	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_039: [If the option parameter is set to "x509certificate" then the value shall be a const char of the certificate to be used for x509.] */
AzureIoTClient	21:167f8fcf6fb1	2719	if ( ((strcmp(OPTION_X509_CERT, option) == 0) \|\| (strcmp(OPTION_X509_PRIVATE_KEY, option) == 0)) && (cred_type != IOTHUB_CREDENTIAL_TYPE_X509) )
AzureIoTClient	21:167f8fcf6fb1	2720	{
AzureIoTClient	21:167f8fcf6fb1	2721	IoTHubClient_Auth_Set_x509_Type(transport_data->authorization_module, true);
AzureIoTClient	21:167f8fcf6fb1	2722	}
AzureIoTClient	21:167f8fcf6fb1	2723
AzureIoTClient	12:658ca6865de2	2724	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_032: [IoTHubTransport_MQTT_Common_SetOption shall pass down the option to xio_setoption if the option parameter is not a known option string for the MQTT transport.] */
AzureIoTClient	11:31ebaeb51e1e	2725	if (GetTransportProviderIfNecessary(transport_data) == 0)
AzureIoTClient	11:31ebaeb51e1e	2726	{
AzureIoTClient	11:31ebaeb51e1e	2727	if (xio_setoption(transport_data->xioTransport, option, value) == 0)
AzureIoTClient	11:31ebaeb51e1e	2728	{
AzureIoTClient	11:31ebaeb51e1e	2729	result = IOTHUB_CLIENT_OK;
AzureIoTClient	11:31ebaeb51e1e	2730	}
AzureIoTClient	11:31ebaeb51e1e	2731	else
AzureIoTClient	11:31ebaeb51e1e	2732	{
AzureIoTClient	12:658ca6865de2	2733	/* Codes_SRS_IOTHUB_MQTT_TRANSPORT_07_132: [IoTHubTransport_MQTT_Common_SetOption shall return IOTHUB_CLIENT_INVALID_ARG xio_setoption fails] */
AzureIoTClient	11:31ebaeb51e1e	2734	result = IOTHUB_CLIENT_INVALID_ARG;
AzureIoTClient	11:31ebaeb51e1e	2735	}
AzureIoTClient	11:31ebaeb51e1e	2736	}
AzureIoTClient	11:31ebaeb51e1e	2737	else
AzureIoTClient	11:31ebaeb51e1e	2738	{
AzureIoTClient	11:31ebaeb51e1e	2739	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	11:31ebaeb51e1e	2740	}
AzureIoTClient	11:31ebaeb51e1e	2741	}
AzureIoTClient	11:31ebaeb51e1e	2742	}
AzureIoTClient	11:31ebaeb51e1e	2743	return result;
AzureIoTClient	11:31ebaeb51e1e	2744	}
AzureIoTClient	11:31ebaeb51e1e	2745
AzureIoTClient	11:31ebaeb51e1e	2746	IOTHUB_DEVICE_HANDLE IoTHubTransport_MQTT_Common_Register(TRANSPORT_LL_HANDLE handle, const IOTHUB_DEVICE_CONFIG* device, IOTHUB_CLIENT_LL_HANDLE iotHubClientHandle, PDLIST_ENTRY waitingToSend)
AzureIoTClient	11:31ebaeb51e1e	2747	{
AzureIoTClient	11:31ebaeb51e1e	2748	IOTHUB_DEVICE_HANDLE result = NULL;
AzureIoTClient	11:31ebaeb51e1e	2749	(void)iotHubClientHandle;
AzureIoTClient	11:31ebaeb51e1e	2750
AzureIoTClient	12:658ca6865de2	2751	// Codes_SRS_IOTHUB_MQTT_TRANSPORT_17_001: [ IoTHubTransport_MQTT_Common_Register shall return NULL if the TRANSPORT_LL_HANDLE is NULL.]
AzureIoTClient	12:658ca6865de2	2752	// Codes_SRS_IOTHUB_MQTT_TRANSPORT_17_002: [ IoTHubTransport_MQTT_Common_Register shall return NULL if device or waitingToSend are NULL.]
AzureIoTClient	11:31ebaeb51e1e	2753	if ((handle == NULL) \|\| (device == NULL) \|\| (waitingToSend == NULL))
AzureIoTClient	11:31ebaeb51e1e	2754	{
AzureIoTClient	12:658ca6865de2	2755	LogError("IoTHubTransport_MQTT_Common_Register: handle, device or waitingToSend is NULL.");
AzureIoTClient	11:31ebaeb51e1e	2756	result = NULL;
AzureIoTClient	11:31ebaeb51e1e	2757	}
AzureIoTClient	11:31ebaeb51e1e	2758	else
AzureIoTClient	11:31ebaeb51e1e	2759	{
AzureIoTClient	11:31ebaeb51e1e	2760	MQTTTRANSPORT_HANDLE_DATA* transport_data = (MQTTTRANSPORT_HANDLE_DATA*)handle;
AzureIoTClient	11:31ebaeb51e1e	2761
AzureIoTClient	12:658ca6865de2	2762	// Codes_SRS_IOTHUB_MQTT_TRANSPORT_03_001: [ IoTHubTransport_MQTT_Common_Register shall return NULL if deviceId, or both deviceKey and deviceSasToken are NULL.]
AzureIoTClient	11:31ebaeb51e1e	2763	if (device->deviceId == NULL)
AzureIoTClient	11:31ebaeb51e1e	2764	{
AzureIoTClient	12:658ca6865de2	2765	LogError("IoTHubTransport_MQTT_Common_Register: deviceId is NULL.");
AzureIoTClient	11:31ebaeb51e1e	2766	result = NULL;
AzureIoTClient	11:31ebaeb51e1e	2767	}
AzureIoTClient	12:658ca6865de2	2768	// Codes_SRS_IOTHUB_MQTT_TRANSPORT_03_002: [ IoTHubTransport_MQTT_Common_Register shall return NULL if both deviceKey and deviceSasToken are provided.]
AzureIoTClient	11:31ebaeb51e1e	2769	else if ((device->deviceKey != NULL) && (device->deviceSasToken != NULL))
AzureIoTClient	11:31ebaeb51e1e	2770	{
AzureIoTClient	12:658ca6865de2	2771	LogError("IoTHubTransport_MQTT_Common_Register: Both deviceKey and deviceSasToken are defined. Only one can be used.");
AzureIoTClient	11:31ebaeb51e1e	2772	result = NULL;
AzureIoTClient	11:31ebaeb51e1e	2773	}
AzureIoTClient	11:31ebaeb51e1e	2774	else
AzureIoTClient	11:31ebaeb51e1e	2775	{
AzureIoTClient	12:658ca6865de2	2776	// Codes_SRS_IOTHUB_MQTT_TRANSPORT_17_003: [ IoTHubTransport_MQTT_Common_Register shall return NULL if deviceId or deviceKey do not match the deviceId and deviceKey passed in during IoTHubTransport_MQTT_Common_Create.]
AzureIoTClient	11:31ebaeb51e1e	2777	if (strcmp(STRING_c_str(transport_data->device_id), device->deviceId) != 0)
AzureIoTClient	11:31ebaeb51e1e	2778	{
AzureIoTClient	12:658ca6865de2	2779	LogError("IoTHubTransport_MQTT_Common_Register: deviceId does not match.");
AzureIoTClient	11:31ebaeb51e1e	2780	result = NULL;
AzureIoTClient	11:31ebaeb51e1e	2781	}
AzureIoTClient	21:167f8fcf6fb1	2782	else if (IoTHubClient_Auth_Get_Credential_Type(transport_data->authorization_module) == IOTHUB_CREDENTIAL_TYPE_DEVICE_KEY &&
AzureIoTClient	21:167f8fcf6fb1	2783	(strcmp(IoTHubClient_Auth_Get_DeviceKey(transport_data->authorization_module), device->deviceKey) != 0))
AzureIoTClient	11:31ebaeb51e1e	2784	{
AzureIoTClient	12:658ca6865de2	2785	LogError("IoTHubTransport_MQTT_Common_Register: deviceKey does not match.");
AzureIoTClient	11:31ebaeb51e1e	2786	result = NULL;
AzureIoTClient	11:31ebaeb51e1e	2787	}
AzureIoTClient	11:31ebaeb51e1e	2788	else
AzureIoTClient	11:31ebaeb51e1e	2789	{
AzureIoTClient	11:31ebaeb51e1e	2790	if (transport_data->isRegistered == true)
AzureIoTClient	11:31ebaeb51e1e	2791	{
AzureIoTClient	11:31ebaeb51e1e	2792	LogError("Transport already has device registered by id: [%s]", device->deviceId);
AzureIoTClient	11:31ebaeb51e1e	2793	result = NULL;
AzureIoTClient	11:31ebaeb51e1e	2794	}
AzureIoTClient	11:31ebaeb51e1e	2795	else
AzureIoTClient	11:31ebaeb51e1e	2796	{
AzureIoTClient	11:31ebaeb51e1e	2797	transport_data->isRegistered = true;
AzureIoTClient	12:658ca6865de2	2798	// Codes_SRS_IOTHUB_MQTT_TRANSPORT_17_004: [ IoTHubTransport_MQTT_Common_Register shall return the TRANSPORT_LL_HANDLE as the IOTHUB_DEVICE_HANDLE. ]
AzureIoTClient	11:31ebaeb51e1e	2799	result = (IOTHUB_DEVICE_HANDLE)handle;
AzureIoTClient	11:31ebaeb51e1e	2800	}
AzureIoTClient	11:31ebaeb51e1e	2801	}
AzureIoTClient	11:31ebaeb51e1e	2802	}
AzureIoTClient	11:31ebaeb51e1e	2803	}
AzureIoTClient	11:31ebaeb51e1e	2804
AzureIoTClient	11:31ebaeb51e1e	2805	return result;
AzureIoTClient	11:31ebaeb51e1e	2806	}
AzureIoTClient	11:31ebaeb51e1e	2807
AzureIoTClient	11:31ebaeb51e1e	2808	void IoTHubTransport_MQTT_Common_Unregister(IOTHUB_DEVICE_HANDLE deviceHandle)
AzureIoTClient	11:31ebaeb51e1e	2809	{
AzureIoTClient	14:4dc2b011be33	2810	// Codes_SRS_IOTHUB_MQTT_TRANSPORT_17_005: [ If deviceHandle is NULL `IoTHubTransport_MQTT_Common_Unregister` shall do nothing. ]
AzureIoTClient	11:31ebaeb51e1e	2811	if (deviceHandle != NULL)
AzureIoTClient	11:31ebaeb51e1e	2812	{
AzureIoTClient	11:31ebaeb51e1e	2813	MQTTTRANSPORT_HANDLE_DATA* transport_data = (MQTTTRANSPORT_HANDLE_DATA*)deviceHandle;
AzureIoTClient	11:31ebaeb51e1e	2814
AzureIoTClient	11:31ebaeb51e1e	2815	transport_data->isRegistered = false;
AzureIoTClient	11:31ebaeb51e1e	2816	}
AzureIoTClient	11:31ebaeb51e1e	2817	}
AzureIoTClient	11:31ebaeb51e1e	2818
AzureIoTClient	11:31ebaeb51e1e	2819	STRING_HANDLE IoTHubTransport_MQTT_Common_GetHostname(TRANSPORT_LL_HANDLE handle)
AzureIoTClient	11:31ebaeb51e1e	2820	{
AzureIoTClient	11:31ebaeb51e1e	2821	STRING_HANDLE result;
AzureIoTClient	12:658ca6865de2	2822	/Codes_SRS_IOTHUB_MQTT_TRANSPORT_02_001: [ If handle is NULL then IoTHubTransport_MQTT_Common_GetHostname shall fail and return NULL. ]/
AzureIoTClient	11:31ebaeb51e1e	2823	if (handle == NULL)
AzureIoTClient	11:31ebaeb51e1e	2824	{
AzureIoTClient	11:31ebaeb51e1e	2825	result = NULL;
AzureIoTClient	11:31ebaeb51e1e	2826	}
AzureIoTClient	22:07fec4d325b6	2827	/Codes_SRS_IOTHUB_MQTT_TRANSPORT_02_002: [ Otherwise IoTHubTransport_MQTT_Common_GetHostname shall return a non-NULL STRING_HANDLE containg the hostname. ]/
AzureIoTClient	22:07fec4d325b6	2828	else if ((result = STRING_clone(((MQTTTRANSPORT_HANDLE_DATA*)(handle))->hostAddress)) == NULL)
AzureIoTClient	11:31ebaeb51e1e	2829	{
AzureIoTClient	22:07fec4d325b6	2830	LogError("Cannot provide the target host name (STRING_clone failed).");
AzureIoTClient	11:31ebaeb51e1e	2831	}
AzureIoTClient	22:07fec4d325b6	2832
AzureIoTClient	11:31ebaeb51e1e	2833	return result;
AzureIoTClient	11:31ebaeb51e1e	2834	}
AzureIoTClient	19:f87dfe76bc70	2835
AzureIoTClient	19:f87dfe76bc70	2836	IOTHUB_CLIENT_RESULT IoTHubTransport_MQTT_Common_SendMessageDisposition(MESSAGE_CALLBACK_INFO* message_data, IOTHUBMESSAGE_DISPOSITION_RESULT disposition)
AzureIoTClient	19:f87dfe76bc70	2837	{
AzureIoTClient	19:f87dfe76bc70	2838	(void)disposition;
AzureIoTClient	19:f87dfe76bc70	2839
AzureIoTClient	19:f87dfe76bc70	2840	IOTHUB_CLIENT_RESULT result;
AzureIoTClient	19:f87dfe76bc70	2841	if (message_data)
AzureIoTClient	19:f87dfe76bc70	2842	{
AzureIoTClient	19:f87dfe76bc70	2843	if (message_data->messageHandle)
AzureIoTClient	19:f87dfe76bc70	2844	{
AzureIoTClient	19:f87dfe76bc70	2845	IoTHubMessage_Destroy(message_data->messageHandle);
AzureIoTClient	19:f87dfe76bc70	2846	result = IOTHUB_CLIENT_OK;
AzureIoTClient	19:f87dfe76bc70	2847	}
AzureIoTClient	19:f87dfe76bc70	2848	else
AzureIoTClient	19:f87dfe76bc70	2849	{
AzureIoTClient	19:f87dfe76bc70	2850	/Codes_SRS_IOTHUB_MQTT_TRANSPORT_10_002: [If any of the messageData fields are NULL, IoTHubTransport_MQTT_Common_SendMessageDisposition shall fail and return IOTHUB_CLIENT_ERROR. ]/
AzureIoTClient	19:f87dfe76bc70	2851	LogError("message handle is NULL");
AzureIoTClient	19:f87dfe76bc70	2852	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	19:f87dfe76bc70	2853	}
AzureIoTClient	19:f87dfe76bc70	2854	free(message_data);
AzureIoTClient	19:f87dfe76bc70	2855	}
AzureIoTClient	19:f87dfe76bc70	2856	else
AzureIoTClient	19:f87dfe76bc70	2857	{
AzureIoTClient	19:f87dfe76bc70	2858	/Codes_SRS_IOTHUB_MQTT_TRANSPORT_10_001: [If messageData is NULL, IoTHubTransport_MQTT_Common_SendMessageDisposition shall fail and return IOTHUB_CLIENT_ERROR. ]/
AzureIoTClient	19:f87dfe76bc70	2859	LogError("message_data is NULL");
AzureIoTClient	19:f87dfe76bc70	2860	result = IOTHUB_CLIENT_ERROR;
AzureIoTClient	19:f87dfe76bc70	2861	}
AzureIoTClient	19:f87dfe76bc70	2862	return result;
AzureIoTClient	19:f87dfe76bc70	2863	}
AzureIoTClient	19:f87dfe76bc70	2864

Repository toolbox

Export to desktop IDE

Repository details

Type:	Library
Created:	25 Mar 2016
Imports:	110
Forks:	0
Commits:	42
Dependents:	6
Dependencies:	0
Followers:	7

Developers

Azure IoT

Dan Cristoloveanu

The code in this repository is MIT licensed.

iothubtransport_mqtt_common.c@22:07fec4d325b6, 2017-05-08 (annotated)

Who changed what in which revision?

Repository toolbox

Repository details

Developers

Important Information for this Arm website

Access Warning