Send C2D (Cloud-to-Device) message to device (#11)

0x1306e6d · web-flow · commit 05ac09c65763 · 2019-10-15T22:14:22.000+09:00
* Add C2D (Cloud-to-Device) message callback

* Add Microsoft.Azure.Devices extension package

* Send a C2D message to the configured device
diff --git a/arduino/arduino.ino b/arduino/arduino.ino
@@ -60,12 +60,42 @@ void initTime()
 static IOTHUB_CLIENT_LL_HANDLE iotHubClientHandle = NULL;
 static unsigned int iotHubMessageTrackingId = 0;
 
+IOTHUBMESSAGE_DISPOSITION_RESULT receiveMessageCallback(IOTHUB_MESSAGE_HANDLE message, void *userContextCallback)
+{
+  const unsigned char *buffer;
+  size_t bufferSize;
+
+  if (IoTHubMessage_GetByteArray(message, &buffer, &bufferSize) == IOTHUB_MESSAGE_OK)
+  {
+    char *command = (char *)malloc(bufferSize + 1);
+    if (command == NULL)
+    {
+      return IOTHUBMESSAGE_ABANDONED;
+    }
+
+    strncpy(command, (const char *)buffer, bufferSize);
+    command[bufferSize] = '\0';
+    Serial.print("receiveMessageCallback: ");
+    Serial.println(command);
+
+    free(command);
+
+    return IOTHUBMESSAGE_ACCEPTED;
+  }
+  else
+  {
+    return IOTHUBMESSAGE_REJECTED;
+  }
+}
+
 void initIoTHubClient()
 {
   iotHubClientHandle = IoTHubClient_LL_CreateFromConnectionString(IOTHUB_CONNECTION_STRING, MQTT_Protocol);
   if (iotHubClientHandle != NULL)
   {
     Serial.println("IoTHubClient_LL_CreateFromConnectionString OK");
+
+    IoTHubClient_LL_SetMessageCallback(iotHubClientHandle, receiveMessageCallback, NULL);
   }
   else
   {
diff --git a/function/function.proj b/function/function.proj
@@ -0,0 +1,9 @@
+<Project Sdk="Microsoft.NET.Sdk">
+    <PropertyGroup>
+        <TargetFramework>netstandard2.0</TargetFramework>
+    </PropertyGroup>
+
+    <ItemGroup>
+        <PackageReference Include="Microsoft.Azure.Devices" Version="1.17.1" />
+    </ItemGroup>
+</Project>
diff --git a/function/run.csx b/function/run.csx
@@ -4,6 +4,7 @@
 
 using System;
 using System.Text;
+using Microsoft.Azure.Devices;
 using Microsoft.Azure.EventHubs;
 using Newtonsoft.Json;
 using Newtonsoft.Json.Linq;
@@ -26,6 +27,14 @@ using SendGrid.Helpers.Mail;
         humidity = humidity,
     };
 
+    string connectionString = System.Environment.GetEnvironmentVariable("iotHubConnectionString");
+    string deviceId = System.Environment.GetEnvironmentVariable("iotHubDeviceId");
+    using (ServiceClient serviceClient = ServiceClient.CreateFromConnectionString(connectionString))
+    {
+        Message commandMessage = new Message(Encoding.UTF8.GetBytes("hello world!"));
+        serviceClient.SendAsync(deviceId, commandMessage).Wait();
+    }
+
     SendGridMessage message = new SendGridMessage();
     message.AddTo(new  EmailAddress("{Your Email To Send}"));
     message.AddContent("text/plain", $"Temperature: {temperature}, Humidity: {humidity}");
