Update with new module client (#32)

Author: formulahendry

content/dotnet-template-azure-iot-edge-module/CSharp/Program.cs

@@ -17,13 +17,10 @@ class Program
 
         static void Main(string[] args)
         {
-            // The Edge runtime gives us the connection string we need -- it is injected as an environment variable
-            string connectionString = Environment.GetEnvironmentVariable("EdgeHubConnectionString");
-
             // Cert verification is not yet fully functional when using Windows OS for the container
             bool bypassCertVerification = RuntimeInformation.IsOSPlatform(OSPlatform.Windows);
             if (!bypassCertVerification) InstallCert();
-            Init(connectionString, bypassCertVerification).Wait();
+            Init(bypassCertVerification).Wait();
 
             // Wait until the app unloads or is cancelled
             var cts = new CancellationTokenSource();
@@ -72,10 +69,8 @@ static void InstallCert()
         /// Initializes the DeviceClient and sets up the callback to receive
         /// messages containing temperature information
         /// </summary>
-        static async Task Init(string connectionString, bool bypassCertVerification = false)
+        static async Task Init(bool bypassCertVerification = false)
         {
-            Console.WriteLine("Connection String {0}", connectionString);
-
             MqttTransportSettings mqttSetting = new MqttTransportSettings(TransportType.Mqtt_Tcp_Only);
             // During dev you might want to bypass the cert verification. It is highly recommended to verify certs systematically in production
             if (bypassCertVerification)
@@ -85,7 +80,7 @@ static async Task Init(string connectionString, bool bypassCertVerification = fa
             ITransportSettings[] settings = { mqttSetting };
 
             // Open a connection to the Edge runtime
-            DeviceClient ioTHubModuleClient = DeviceClient.CreateFromConnectionString(connectionString, settings);
+            ModuleClient ioTHubModuleClient = await ModuleClient.CreateFromEnvironmentAsync(settings);
             await ioTHubModuleClient.OpenAsync();
             Console.WriteLine("IoT Hub module client initialized.");
 
@@ -102,8 +97,8 @@ static async Task<MessageResponse> PipeMessage(Message message, object userConte
         {
             int counterValue = Interlocked.Increment(ref counter);
 
-            var deviceClient = userContext as DeviceClient;
-            if (deviceClient == null)
+            var moduleClient = userContext as ModuleClient;
+            if (moduleClient == null)
             {
                 throw new InvalidOperationException("UserContext doesn't contain " + "expected values");
             }
@@ -119,7 +114,7 @@ static async Task<MessageResponse> PipeMessage(Message message, object userConte
                 {
                     pipeMessage.Properties.Add(prop.Key, prop.Value);
                 }
-                await deviceClient.SendEventAsync("output1", pipeMessage);
+                await moduleClient.SendEventAsync("output1", pipeMessage);
                 Console.WriteLine("Received message sent");
             }
             return MessageResponse.Completed;

content/dotnet-template-azure-iot-edge-module/CSharp/SampleModule.csproj

@@ -7,10 +7,11 @@
   <PropertyGroup Condition="'$(Configuration)|$(TargetFramework)|$(Platform)'=='Debug|netcoreapp2.0|AnyCPU'">
     <TreatWarningsAsErrors>True</TreatWarningsAsErrors>
     <TreatSpecificWarningsAsErrors />
+    <RestoreSources>https://api.nuget.org/v3/index.json;https://www.myget.org/F/aziot-device-sdk/api/v3/index.json</RestoreSources>
   </PropertyGroup>
 
   <ItemGroup>
-    <PackageReference Include="Microsoft.Azure.Devices.Client" Version="1.6.0-preview-001" />
+    <PackageReference Include="Microsoft.Azure.Devices.Client" Version="1.17.0-preview-009" />
     <PackageReference Include="Microsoft.Extensions.Configuration" Version="2.0.0-preview2-final" />
     <PackageReference Include="Microsoft.Extensions.Configuration.Abstractions" Version="2.0.0-preview2-final" />
     <PackageReference Include="Microsoft.Extensions.Configuration.Binder" Version="2.0.0-preview2-final" />