Merge pull request #9 from AttunixCorp/master

ESP8266 (Huzzah and Thing Dev) and SAMD (Feather M0) remote monitorin…

Author: obsoleted

examples/esp8266/command_center/command_center.ino

@@ -0,0 +1,75 @@
+// Copyright (c) Microsoft. All rights reserved.
+// Licensed under the MIT license. See LICENSE file in the project root for full license information.
+
+// This example only works with Arduino IDE 1.6.8 or later.
+
+#include <ESP8266WiFi.h>
+#include <time.h>
+#include "command_center_http.h"
+
+
+const char ssid[] = "[SSID]"; //  your WiFi SSID (name)
+const char pass[] = "[PASSWORD]";    // your WiFi password (use for WPA, or use as key for WEP)
+const char connectionString[] = "HostName=[HubName].azure-devices.net;DeviceId=[DeviceName];SharedAccessKey=[KEY]";
+
+int status = WL_IDLE_STATUS;
+
+///////////////////////////////////////////////////////////////////////////////////////////////////
+void setup() {
+    initSerial();
+    initWifi();
+    initTime();
+
+    // This function doesn't exit.
+    simplesample_http_run();
+}
+
+///////////////////////////////////////////////////////////////////////////////////////////////////
+void loop() {
+  // Not used.
+}
+
+///////////////////////////////////////////////////////////////////////////////////////////////////
+void initSerial() {
+    // Start serial and initialize stdout
+    Serial.begin(115200);
+    Serial.setDebugOutput(true);
+}
+
+///////////////////////////////////////////////////////////////////////////////////////////////////
+void initWifi() {
+    // Attempt to connect to Wifi network:
+    Serial.print("Attempting to connect to SSID: ");
+    Serial.println(ssid);
+
+    // Connect to WPA/WPA2 network. Change this line if using open or WEP network:
+    status = WiFi.begin(ssid, pass);
+
+    while (WiFi.status() != WL_CONNECTED) {
+        delay(500);
+        Serial.print(".");
+    }
+
+    Serial.println("Connected to wifi");
+}
+
+///////////////////////////////////////////////////////////////////////////////////////////////////
+void initTime() {
+    time_t epochTime;
+
+    configTime(0, 0, "pool.ntp.org", "time.nist.gov");
+
+    while (true) {
+        epochTime = time(NULL);
+
+        if (epochTime == 0) {
+            Serial.println("Fetching NTP epoch time failed! Waiting 2 seconds to retry.");
+            delay(2000);
+        } else {
+            Serial.print("Fetched NTP epoch time is: ");
+            Serial.println(epochTime);
+            break;
+        }
+    }
+}
+

examples/esp8266/command_center/command_center_http.c

@@ -0,0 +1,314 @@
+///////////////////////////////////////////////////////////////////////////////////////////////////
+// Copyright (c) Microsoft. All rights reserved.
+// Licensed under the MIT license. See LICENSE file in the project root for full license information.
+
+#include <stdlib.h>
+
+#include <stdio.h>
+#include <stdint.h>
+#include <pgmspace.h>
+#include <Arduino.h>
+#include <time.h>
+
+#include "dht22.h"
+#include "command_center_http.h"
+
+/* This sample uses the _LL APIs of iothub_client for example purposes.
+That does not mean that HTTP only works with the _LL APIs.
+Simply changing the using the convenience layer (functions not having _LL)
+and removing calls to _DoWork will yield the same results. */
+
+#include "AzureIoT.h"
+
+
+//static const char* connectionString = "HostName=[host].azure-devices.net;DeviceId=[device];SharedAccessKey=[key]";
+static const char connectionString[] = "HostName=[host].azure-devices.net;DeviceId=[device];SharedAccessKey=[key]";
+
+static int redLedPin = 12;
+static int redLedState = LOW;
+static int greenLedPin = 13;
+static int greenLedState = LOW;
+
+// Define the Model
+BEGIN_NAMESPACE(WeatherStation);
+
+DECLARE_MODEL(ContosoAnemometer,
+WITH_DATA(ascii_char_ptr, DeviceId),
+WITH_DATA(ascii_char_ptr, EventTime),
+WITH_DATA(int, WindSpeed),
+WITH_DATA(int, MTemperature),
+WITH_DATA(int, Humidity),
+WITH_ACTION(TurnFanOn),
+WITH_ACTION(TurnFanOff),
+WITH_ACTION(SetAirResistance, int, Position)
+);
+
+END_NAMESPACE(WeatherStation);
+
+DEFINE_ENUM_STRINGS(IOTHUB_CLIENT_CONFIRMATION_RESULT, IOTHUB_CLIENT_CONFIRMATION_RESULT_VALUES)
+
+EXECUTE_COMMAND_RESULT TurnFanOn(ContosoAnemometer* device)
+{
+    (void)device;
+
+    LogInfo("Toggling red LED.\r\n");
+    if (redLedState != LOW)
+    {
+        redLedState = LOW;
+    }
+    else
+    {
+        redLedState = HIGH;
+    }
+    digitalWrite(redLedPin, redLedState);
+
+    return EXECUTE_COMMAND_SUCCESS;
+}
+
+EXECUTE_COMMAND_RESULT TurnFanOff(ContosoAnemometer* device)
+{
+    (void)device;
+
+    LogInfo("Toggling green LED.\r\n");
+    if (greenLedState != LOW)
+    {
+        greenLedState = LOW;
+    }
+    else
+    {
+        greenLedState = HIGH;
+    }
+    digitalWrite(greenLedPin, greenLedState);
+
+    return EXECUTE_COMMAND_SUCCESS;
+}
+
+EXECUTE_COMMAND_RESULT SetAirResistance(ContosoAnemometer* device, int Position)
+{
+    (void)device;
+    LogInfo("Setting Air Resistance Position to %d.\r\n", Position);
+    return EXECUTE_COMMAND_SUCCESS;
+}
+
+void sendCallback(IOTHUB_CLIENT_CONFIRMATION_RESULT result, void* userContextCallback)
+{
+    int messageTrackingId = (intptr_t)userContextCallback;
+
+    LogInfo("Message Id: %d Received.\r\n", messageTrackingId);
+
+    LogInfo("Result Call Back Called! Result is: %s \r\n", ENUM_TO_STRING(IOTHUB_CLIENT_CONFIRMATION_RESULT, result));
+}
+
+static void sendMessage(IOTHUB_CLIENT_LL_HANDLE iotHubClientHandle, const unsigned char* buffer, size_t size)
+{
+    static unsigned int messageTrackingId;
+    IOTHUB_MESSAGE_HANDLE messageHandle = IoTHubMessage_CreateFromByteArray(buffer, size);
+    if (messageHandle == NULL)
+    {
+        LogInfo("unable to create a new IoTHubMessage\r\n");
+    }
+    else
+    {
+        if (IoTHubClient_LL_SendEventAsync(iotHubClientHandle, messageHandle, sendCallback, (void*)(uintptr_t)messageTrackingId) != IOTHUB_CLIENT_OK)
+        {
+            LogInfo("failed to hand over the message to IoTHubClient");
+        }
+        else
+        {
+            LogInfo("IoTHubClient accepted the message for delivery\r\n");
+        }
+        IoTHubMessage_Destroy(messageHandle);
+    }
+    free((void*)buffer);
+    messageTrackingId++;
+}
+
+/*this function "links" IoTHub to the serialization library*/
+static IOTHUBMESSAGE_DISPOSITION_RESULT IoTHubMessage(IOTHUB_MESSAGE_HANDLE message, void* userContextCallback)
+{
+    IOTHUBMESSAGE_DISPOSITION_RESULT result;
+    const unsigned char* buffer;
+    size_t size;
+    if (IoTHubMessage_GetByteArray(message, &buffer, &size) != IOTHUB_MESSAGE_OK)
+    {
+        LogInfo("unable to IoTHubMessage_GetByteArray\r\n");
+        result = EXECUTE_COMMAND_ERROR;
+    }
+    else
+    {
+        /*buffer is not zero terminated*/
+        char* temp = malloc(size + 1);
+        if (temp == NULL)
+        {
+            LogInfo("failed to malloc\r\n");
+            result = EXECUTE_COMMAND_ERROR;
+        }
+        else
+        {
+            memcpy(temp, buffer, size);
+            temp[size] = '\0';
+            EXECUTE_COMMAND_RESULT executeCommandResult = EXECUTE_COMMAND(userContextCallback, temp);
+            result =
+                (executeCommandResult == EXECUTE_COMMAND_ERROR) ? IOTHUBMESSAGE_ABANDONED :
+                (executeCommandResult == EXECUTE_COMMAND_SUCCESS) ? IOTHUBMESSAGE_ACCEPTED :
+                IOTHUBMESSAGE_REJECTED;
+            free(temp);
+        }
+    }
+    return result;
+}
+
+void simplesample_http_run(void)
+{
+    initDht();
+
+    digitalWrite(redLedPin, redLedState);
+    pinMode(redLedPin, OUTPUT);
+    
+    digitalWrite(greenLedPin, greenLedState);
+    pinMode(greenLedPin, OUTPUT);
+
+    if (serializer_init(NULL) != SERIALIZER_OK)
+    {
+        LogInfo("Failed on serializer_init\r\n");
+    }
+    else
+    {
+        IOTHUB_CLIENT_LL_HANDLE iotHubClientHandle = IoTHubClient_LL_CreateFromConnectionString(connectionString, HTTP_Protocol);
+        srand((unsigned int)time(NULL));
+        int avgWindSpeed = 10.0;
+
+        if (iotHubClientHandle == NULL)
+        {
+            LogInfo("Failed on IoTHubClient_LL_Create\r\n");
+        }
+        else
+        {
+            unsigned int minimumPollingTime = 9; /*because it can poll "after 9 seconds" polls will happen effectively at ~10 seconds*/
+            if (IoTHubClient_LL_SetOption(iotHubClientHandle, "MinimumPollingTime", &minimumPollingTime) != IOTHUB_CLIENT_OK)
+            {
+                LogInfo("failure to set option \"MinimumPollingTime\"\r\n");
+            }
+
+#ifdef MBED_BUILD_TIMESTAMP
+            // For mbed add the certificate information
+            if (IoTHubClient_LL_SetOption(iotHubClientHandle, "TrustedCerts", certificates) != IOTHUB_CLIENT_OK)
+            {
+                LogInfo("failure to set option \"TrustedCerts\"\r\n");
+            }
+#endif // MBED_BUILD_TIMESTAMP
+
+            ContosoAnemometer* myWeather = CREATE_MODEL_INSTANCE(WeatherStation, ContosoAnemometer);
+            if (myWeather == NULL)
+            {
+                LogInfo("Failed on CREATE_MODEL_INSTANCE\r\n");
+            }
+            else
+            {
+                if (IoTHubClient_LL_SetMessageCallback(iotHubClientHandle, IoTHubMessage, myWeather) != IOTHUB_CLIENT_OK)
+                {
+                    LogInfo("unable to IoTHubClient_SetMessageCallback\r\n");
+                }
+                else
+                {
+                    myWeather->DeviceId = "myFirstDevice";
+                    myWeather->WindSpeed = avgWindSpeed + (rand() % 4 + 2);
+                    {
+                        unsigned char* destination;
+                        size_t destinationSize;
+                        if (SERIALIZE(&destination, &destinationSize, myWeather->DeviceId, myWeather->WindSpeed) != IOT_AGENT_OK)
+                        {
+                            LogInfo("Failed to serialize\r\n");
+                        }
+                        else
+                        {
+                            IOTHUB_MESSAGE_HANDLE messageHandle = IoTHubMessage_CreateFromByteArray(destination, destinationSize);
+                            if (messageHandle == NULL)
+                            {
+                                LogInfo("unable to create a new IoTHubMessage\r\n");
+                            }
+                            else
+                            {
+                                if (IoTHubClient_LL_SendEventAsync(iotHubClientHandle, messageHandle, sendCallback, (void*)1) != IOTHUB_CLIENT_OK)
+                                {
+                                    LogInfo("failed to hand over the message to IoTHubClient\r\n");
+                                }
+                                else
+                                {
+                                    LogInfo("IoTHubClient accepted the message for delivery\r\n");
+                                }
+
+                                IoTHubMessage_Destroy(messageHandle);
+                            }
+                            free(destination);
+                        }
+                    }
+
+                    /* wait for commands */
+                    long Prev_time_ms = millis();
+                    char buff[11];
+                    int timeNow = 0;
+
+                    while (1)
+                    {
+                        long Curr_time_ms = millis();
+                        if (Curr_time_ms >= Prev_time_ms + 5000)
+                        {
+                            Prev_time_ms = Curr_time_ms;
+                            
+                            timeNow = (int)time(NULL);
+                            sprintf(buff, "%d", timeNow);
+
+                            float Temp_c__f, Humi_pct__f;
+                            getNextSample(&Temp_c__f, &Humi_pct__f);
+                            myWeather->DeviceId = "myFirstDevice";
+                            myWeather->EventTime = timeNow;
+                            myWeather->WindSpeed = avgWindSpeed + (rand() % 4 + 2);
+                            myWeather->MTemperature = (int)Temp_c__f;
+                            myWeather->Humidity = (int)Humi_pct__f;
+                            {
+                                unsigned char* destination;
+                                size_t destinationSize;
+                                if (SERIALIZE(&destination, &destinationSize, myWeather->DeviceId, myWeather->EventTime, myWeather->WindSpeed, myWeather->MTemperature, myWeather->Humidity) != IOT_AGENT_OK)
+                                {
+                                    LogInfo("Failed to serialize\r\n");
+                                }
+                                else
+                                {
+                                    IOTHUB_MESSAGE_HANDLE messageHandle = IoTHubMessage_CreateFromByteArray(destination, destinationSize);
+                                    if (messageHandle == NULL)
+                                    {
+                                        LogInfo("unable to create a new IoTHubMessage\r\n");
+                                    }
+                                    else
+                                    {
+                                        if (IoTHubClient_LL_SendEventAsync(iotHubClientHandle, messageHandle, sendCallback, (void*)1) != IOTHUB_CLIENT_OK)
+                                        {
+                                            LogInfo("failed to hand over the message to IoTHubClient\r\n");
+                                        }
+                                        else
+                                        {
+                                            LogInfo("IoTHubClient accepted the message for delivery\r\n");
+                                        }
+        
+                                        IoTHubMessage_Destroy(messageHandle);
+                                    }
+                                    free(destination);
+                                }
+                            }
+                        }
+                        
+                        IoTHubClient_LL_DoWork(iotHubClientHandle);
+                        ThreadAPI_Sleep(100);
+                    }
+                }
+
+                DESTROY_MODEL_INSTANCE(myWeather);
+            }
+            IoTHubClient_LL_Destroy(iotHubClientHandle);
+        }
+        serializer_deinit();
+    }
+}
+
+