Dieter Graef / Mbed 2 deprecated STM32F746_iothub_client_sample_mqtt

port of the azure client sample mqtt for the NUCLEO STM32F746ZG platform

Dependencies:   F7_Ethernet NTPClient azure_c_shared_utility azure_umqtt_c iothub_client iothub_mqtt_transport mbed-rtos mbed wolfSSL

Fork of iothub_client_sample_mqtt by Azure IoT

iothub_client_sample_mqtt.c@6:02304619a9fa, 2016-04-24 (annotated)

Committer:
AzureIoTClient
Date:
Sun Apr 24 16:42:15 2016 -0700
Revision:
6:02304619a9fa
Parent:
2:65c172c36cf5
Child:
7:02bc67ebbe23
1.0.5

Who changed what in which revision?

UserRevisionLine numberNew contents of line
Azure.IoT Build 2:65c172c36cf5 1 // Copyright (c) Microsoft. All rights reserved.
Azure.IoT Build 2:65c172c36cf5 2 // Licensed under the MIT license. See LICENSE file in the project root for full license information.
Azure.IoT Build 2:65c172c36cf5 3
Azure.IoT Build 2:65c172c36cf5 4 #include <stdio.h>
Azure.IoT Build 2:65c172c36cf5 5 #include <stdlib.h>
Azure.IoT Build 2:65c172c36cf5 6
Azure.IoT Build 2:65c172c36cf5 7 #include "iothub_client.h"
Azure.IoT Build 2:65c172c36cf5 8 #include "iothub_message.h"
AzureIoTClient 6:02304619a9fa 9 #include "azure_c_shared_utility/threadapi.h"
AzureIoTClient 6:02304619a9fa 10 #include "azure_c_shared_utility/crt_abstractions.h"
Azure.IoT Build 2:65c172c36cf5 11 #include "iothubtransportmqtt.h"
AzureIoTClient 6:02304619a9fa 12 #include "azure_c_shared_utility/platform.h"
Azure.IoT Build 2:65c172c36cf5 13
Azure.IoT Build 2:65c172c36cf5 14 #ifdef MBED_BUILD_TIMESTAMP
Azure.IoT Build 2:65c172c36cf5 15 #include "certs.h"
Azure.IoT Build 2:65c172c36cf5 16 #endif // MBED_BUILD_TIMESTAMP
Azure.IoT Build 2:65c172c36cf5 17
Azure.IoT Build 2:65c172c36cf5 18 static const char* connectionString = "[device connection string]";
Azure.IoT Build 2:65c172c36cf5 19
Azure.IoT Build 2:65c172c36cf5 20 static int callbackCounter;
Azure.IoT Build 2:65c172c36cf5 21 static char msgText[1024];
AzureIoTClient 6:02304619a9fa 22 static char propText[1024];
Azure.IoT Build 2:65c172c36cf5 23 #define MESSAGE_COUNT 5
Azure.IoT Build 2:65c172c36cf5 24 static bool continueRunning;
Azure.IoT Build 2:65c172c36cf5 25
Azure.IoT Build 2:65c172c36cf5 26 DEFINE_ENUM_STRINGS(IOTHUB_CLIENT_CONFIRMATION_RESULT, IOTHUB_CLIENT_CONFIRMATION_RESULT_VALUES);
Azure.IoT Build 2:65c172c36cf5 27
Azure.IoT Build 2:65c172c36cf5 28 typedef struct EVENT_INSTANCE_TAG
Azure.IoT Build 2:65c172c36cf5 29 {
Azure.IoT Build 2:65c172c36cf5 30 IOTHUB_MESSAGE_HANDLE messageHandle;
Azure.IoT Build 2:65c172c36cf5 31 int messageTrackingId; // For tracking the messages within the user callback.
Azure.IoT Build 2:65c172c36cf5 32 } EVENT_INSTANCE;
Azure.IoT Build 2:65c172c36cf5 33
Azure.IoT Build 2:65c172c36cf5 34
Azure.IoT Build 2:65c172c36cf5 35 static IOTHUBMESSAGE_DISPOSITION_RESULT ReceiveMessageCallback(IOTHUB_MESSAGE_HANDLE message, void* userContextCallback)
Azure.IoT Build 2:65c172c36cf5 36 {
Azure.IoT Build 2:65c172c36cf5 37 int* counter = (int*)userContextCallback;
Azure.IoT Build 2:65c172c36cf5 38 const char* buffer;
Azure.IoT Build 2:65c172c36cf5 39 size_t size;
Azure.IoT Build 2:65c172c36cf5 40 if (IoTHubMessage_GetByteArray(message, (const unsigned char**)&buffer, &size) != IOTHUB_MESSAGE_OK)
Azure.IoT Build 2:65c172c36cf5 41 {
Azure.IoT Build 2:65c172c36cf5 42 (void)printf("unable to retrieve the message data\r\n");
Azure.IoT Build 2:65c172c36cf5 43 }
Azure.IoT Build 2:65c172c36cf5 44 else
Azure.IoT Build 2:65c172c36cf5 45 {
Azure.IoT Build 2:65c172c36cf5 46 (void)printf("Received Message [%d] with Data: <<<%.*s>>> & Size=%d\r\n", *counter, (int)size, buffer, (int)size);
Azure.IoT Build 2:65c172c36cf5 47 // If we receive the work 'quit' then we stop running
Azure.IoT Build 2:65c172c36cf5 48 if (memcmp(buffer, "quit", size) == 0)
Azure.IoT Build 2:65c172c36cf5 49 {
Azure.IoT Build 2:65c172c36cf5 50 continueRunning = false;
Azure.IoT Build 2:65c172c36cf5 51 }
Azure.IoT Build 2:65c172c36cf5 52 }
Azure.IoT Build 2:65c172c36cf5 53
Azure.IoT Build 2:65c172c36cf5 54 // Retrieve properties from the message
Azure.IoT Build 2:65c172c36cf5 55 MAP_HANDLE mapProperties = IoTHubMessage_Properties(message);
Azure.IoT Build 2:65c172c36cf5 56 if (mapProperties != NULL)
Azure.IoT Build 2:65c172c36cf5 57 {
Azure.IoT Build 2:65c172c36cf5 58 const char*const* keys;
Azure.IoT Build 2:65c172c36cf5 59 const char*const* values;
Azure.IoT Build 2:65c172c36cf5 60 size_t propertyCount = 0;
Azure.IoT Build 2:65c172c36cf5 61 if (Map_GetInternals(mapProperties, &keys, &values, &propertyCount) == MAP_OK)
Azure.IoT Build 2:65c172c36cf5 62 {
Azure.IoT Build 2:65c172c36cf5 63 if (propertyCount > 0)
Azure.IoT Build 2:65c172c36cf5 64 {
Azure.IoT Build 2:65c172c36cf5 65 for (size_t index = 0; index < propertyCount; index++)
Azure.IoT Build 2:65c172c36cf5 66 {
Azure.IoT Build 2:65c172c36cf5 67 (void)printf("\tKey: %s Value: %s\r\n", keys[index], values[index]);
Azure.IoT Build 2:65c172c36cf5 68 }
Azure.IoT Build 2:65c172c36cf5 69 (void)printf("\r\n");
Azure.IoT Build 2:65c172c36cf5 70 }
Azure.IoT Build 2:65c172c36cf5 71 }
Azure.IoT Build 2:65c172c36cf5 72 }
Azure.IoT Build 2:65c172c36cf5 73
Azure.IoT Build 2:65c172c36cf5 74 /* Some device specific action code goes here... */
Azure.IoT Build 2:65c172c36cf5 75 (*counter)++;
Azure.IoT Build 2:65c172c36cf5 76 return IOTHUBMESSAGE_ACCEPTED;
Azure.IoT Build 2:65c172c36cf5 77 }
Azure.IoT Build 2:65c172c36cf5 78
Azure.IoT Build 2:65c172c36cf5 79 static void SendConfirmationCallback(IOTHUB_CLIENT_CONFIRMATION_RESULT result, void* userContextCallback)
Azure.IoT Build 2:65c172c36cf5 80 {
Azure.IoT Build 2:65c172c36cf5 81 EVENT_INSTANCE* eventInstance = (EVENT_INSTANCE*)userContextCallback;
Azure.IoT Build 2:65c172c36cf5 82 (void)printf("Confirmation[%d] received for message tracking id = %d with result = %s\r\n", callbackCounter, eventInstance->messageTrackingId, ENUM_TO_STRING(IOTHUB_CLIENT_CONFIRMATION_RESULT, result));
Azure.IoT Build 2:65c172c36cf5 83 /* Some device specific action code goes here... */
Azure.IoT Build 2:65c172c36cf5 84 callbackCounter++;
Azure.IoT Build 2:65c172c36cf5 85 IoTHubMessage_Destroy(eventInstance->messageHandle);
Azure.IoT Build 2:65c172c36cf5 86 }
Azure.IoT Build 2:65c172c36cf5 87
Azure.IoT Build 2:65c172c36cf5 88 void iothub_client_sample_mqtt_run(void)
Azure.IoT Build 2:65c172c36cf5 89 {
Azure.IoT Build 2:65c172c36cf5 90 IOTHUB_CLIENT_LL_HANDLE iotHubClientHandle;
Azure.IoT Build 2:65c172c36cf5 91
Azure.IoT Build 2:65c172c36cf5 92 EVENT_INSTANCE messages[MESSAGE_COUNT];
Azure.IoT Build 2:65c172c36cf5 93
Azure.IoT Build 2:65c172c36cf5 94 continueRunning = true;
Azure.IoT Build 2:65c172c36cf5 95 srand((unsigned int)time(NULL));
Azure.IoT Build 2:65c172c36cf5 96 double avgWindSpeed = 10.0;
Azure.IoT Build 2:65c172c36cf5 97
Azure.IoT Build 2:65c172c36cf5 98 callbackCounter = 0;
Azure.IoT Build 2:65c172c36cf5 99 int receiveContext = 0;
Azure.IoT Build 2:65c172c36cf5 100
Azure.IoT Build 2:65c172c36cf5 101 if (platform_init() != 0)
Azure.IoT Build 2:65c172c36cf5 102 {
Azure.IoT Build 2:65c172c36cf5 103 (void)printf("Failed to initialize the platform.\r\n");
Azure.IoT Build 2:65c172c36cf5 104 }
Azure.IoT Build 2:65c172c36cf5 105 else
Azure.IoT Build 2:65c172c36cf5 106 {
Azure.IoT Build 2:65c172c36cf5 107 (void)printf("Starting the IoTHub client sample MQTT...\r\n");
Azure.IoT Build 2:65c172c36cf5 108
Azure.IoT Build 2:65c172c36cf5 109 if ((iotHubClientHandle = IoTHubClient_LL_CreateFromConnectionString(connectionString, MQTT_Protocol)) == NULL)
Azure.IoT Build 2:65c172c36cf5 110 {
Azure.IoT Build 2:65c172c36cf5 111 (void)printf("ERROR: iotHubClientHandle is NULL!\r\n");
Azure.IoT Build 2:65c172c36cf5 112 }
Azure.IoT Build 2:65c172c36cf5 113 else
Azure.IoT Build 2:65c172c36cf5 114 {
Azure.IoT Build 2:65c172c36cf5 115 bool traceOn = true;
Azure.IoT Build 2:65c172c36cf5 116 IoTHubClient_LL_SetOption(iotHubClientHandle, "logtrace", &traceOn);
Azure.IoT Build 2:65c172c36cf5 117
Azure.IoT Build 2:65c172c36cf5 118 #ifdef MBED_BUILD_TIMESTAMP
Azure.IoT Build 2:65c172c36cf5 119 // For mbed add the certificate information
Azure.IoT Build 2:65c172c36cf5 120 if (IoTHubClient_LL_SetOption(iotHubClientHandle, "TrustedCerts", certificates) != IOTHUB_CLIENT_OK)
Azure.IoT Build 2:65c172c36cf5 121 {
Azure.IoT Build 2:65c172c36cf5 122 printf("failure to set option \"TrustedCerts\"\r\n");
Azure.IoT Build 2:65c172c36cf5 123 }
Azure.IoT Build 2:65c172c36cf5 124 #endif // MBED_BUILD_TIMESTAMP
Azure.IoT Build 2:65c172c36cf5 125
Azure.IoT Build 2:65c172c36cf5 126 /* Setting Message call back, so we can receive Commands. */
Azure.IoT Build 2:65c172c36cf5 127 if (IoTHubClient_LL_SetMessageCallback(iotHubClientHandle, ReceiveMessageCallback, &receiveContext) != IOTHUB_CLIENT_OK)
Azure.IoT Build 2:65c172c36cf5 128 {
Azure.IoT Build 2:65c172c36cf5 129 (void)printf("ERROR: IoTHubClient_LL_SetMessageCallback..........FAILED!\r\n");
Azure.IoT Build 2:65c172c36cf5 130 }
Azure.IoT Build 2:65c172c36cf5 131 else
Azure.IoT Build 2:65c172c36cf5 132 {
Azure.IoT Build 2:65c172c36cf5 133 (void)printf("IoTHubClient_LL_SetMessageCallback...successful.\r\n");
Azure.IoT Build 2:65c172c36cf5 134
Azure.IoT Build 2:65c172c36cf5 135 /* Now that we are ready to receive commands, let's send some messages */
Azure.IoT Build 2:65c172c36cf5 136 for (size_t i = 0; i < MESSAGE_COUNT; i++)
Azure.IoT Build 2:65c172c36cf5 137 {
Azure.IoT Build 2:65c172c36cf5 138 sprintf_s(msgText, sizeof(msgText), "{\"deviceId\":\"myFirstDevice\",\"windSpeed\":%.2f}", avgWindSpeed + (rand() % 4 + 2));
Azure.IoT Build 2:65c172c36cf5 139 if ((messages[i].messageHandle = IoTHubMessage_CreateFromByteArray((const unsigned char*)msgText, strlen(msgText))) == NULL)
Azure.IoT Build 2:65c172c36cf5 140 {
Azure.IoT Build 2:65c172c36cf5 141 (void)printf("ERROR: iotHubMessageHandle is NULL!\r\n");
Azure.IoT Build 2:65c172c36cf5 142 }
Azure.IoT Build 2:65c172c36cf5 143 else
Azure.IoT Build 2:65c172c36cf5 144 {
Azure.IoT Build 2:65c172c36cf5 145 messages[i].messageTrackingId = i;
AzureIoTClient 6:02304619a9fa 146 MAP_HANDLE propMap = IoTHubMessage_Properties(messages[i].messageHandle);
AzureIoTClient 6:02304619a9fa 147 sprintf_s(propText, sizeof(propText), "PropMsg_%d", i);
AzureIoTClient 6:02304619a9fa 148 if (Map_AddOrUpdate(propMap, "PropName", propText) != MAP_OK)
AzureIoTClient 6:02304619a9fa 149 {
AzureIoTClient 6:02304619a9fa 150 (void)printf("ERROR: Map_AddOrUpdate Failed!\r\n");
AzureIoTClient 6:02304619a9fa 151 }
Azure.IoT Build 2:65c172c36cf5 152
Azure.IoT Build 2:65c172c36cf5 153 if (IoTHubClient_LL_SendEventAsync(iotHubClientHandle, messages[i].messageHandle, SendConfirmationCallback, &messages[i]) != IOTHUB_CLIENT_OK)
Azure.IoT Build 2:65c172c36cf5 154 {
Azure.IoT Build 2:65c172c36cf5 155 (void)printf("ERROR: IoTHubClient_LL_SendEventAsync..........FAILED!\r\n");
Azure.IoT Build 2:65c172c36cf5 156 }
Azure.IoT Build 2:65c172c36cf5 157 else
Azure.IoT Build 2:65c172c36cf5 158 {
Azure.IoT Build 2:65c172c36cf5 159 (void)printf("IoTHubClient_LL_SendEventAsync accepted message [%d] for transmission to IoT Hub.\r\n", (int)i);
Azure.IoT Build 2:65c172c36cf5 160 }
Azure.IoT Build 2:65c172c36cf5 161
Azure.IoT Build 2:65c172c36cf5 162 }
Azure.IoT Build 2:65c172c36cf5 163 }
Azure.IoT Build 2:65c172c36cf5 164 }
Azure.IoT Build 2:65c172c36cf5 165
Azure.IoT Build 2:65c172c36cf5 166 /* Wait for Commands. */
Azure.IoT Build 2:65c172c36cf5 167 while (continueRunning)
Azure.IoT Build 2:65c172c36cf5 168 {
Azure.IoT Build 2:65c172c36cf5 169 IoTHubClient_LL_DoWork(iotHubClientHandle);
Azure.IoT Build 2:65c172c36cf5 170 ThreadAPI_Sleep(1);
Azure.IoT Build 2:65c172c36cf5 171 }
Azure.IoT Build 2:65c172c36cf5 172 IoTHubClient_LL_Destroy(iotHubClientHandle);
Azure.IoT Build 2:65c172c36cf5 173 }
Azure.IoT Build 2:65c172c36cf5 174 platform_deinit();
Azure.IoT Build 2:65c172c36cf5 175 }
Azure.IoT Build 2:65c172c36cf5 176 }