Merge pull request #56 from dimiboi/events-propagation-fix

alexkarcher-msft · web-flow · commit 19de1f2a2e07 · 2020-11-09T08:42:42.000-08:00
Fixed propagation of digital twin events through the graph
diff --git a/AdtSampleApp/SampleFunctionsApp/AdtUtilities.cs b/AdtSampleApp/SampleFunctionsApp/AdtUtilities.cs
@@ -57,7 +57,7 @@ public static async Task UpdateTwinPropertyAsync(DigitalTwinsClient client, stri
             try
             {
                 var updateTwinData = new JsonPatchDocument();
-                updateTwinData.AppendAdd(propertyPath, value);
+                updateTwinData.AppendReplace(propertyPath, value);
 
                 log.LogInformation($"UpdateTwinPropertyAsync sending {updateTwinData}");
                 await client.UpdateDigitalTwinAsync(twinId, updateTwinData);
diff --git a/AdtSampleApp/SampleFunctionsApp/ProcessHubToDTEvents.cs b/AdtSampleApp/SampleFunctionsApp/ProcessHubToDTEvents.cs
@@ -47,7 +47,7 @@ public async void Run([EventGridTrigger]EventGridEvent eventGridEvent, ILogger l
 
                 //Update twin using device temperature
                 var updateTwinData = new JsonPatchDocument();
-                updateTwinData.AppendAdd("/Temperature", temperature.Value<double>());
+                updateTwinData.AppendReplace("/Temperature", temperature.Value<double>());
                 await client.UpdateDigitalTwinAsync(deviceId, updateTwinData);
             }
         }

Original file line number	Diff line number	Diff line change
`@@ -57,7 +57,7 @@ public static async Task UpdateTwinPropertyAsync(DigitalTwinsClient client, stri`
`57`	`57`	`try`
`58`	`58`	`{`
`59`	`59`	`var updateTwinData = new JsonPatchDocument();`
`60`		`- updateTwinData.AppendAdd(propertyPath, value);`
	`60`	`+ updateTwinData.AppendReplace(propertyPath, value);`
`61`	`61`
`62`	`62`	`log.LogInformation($"UpdateTwinPropertyAsync sending {updateTwinData}");`
`63`	`63`	`await client.UpdateDigitalTwinAsync(twinId, updateTwinData);`
Original file line number	Diff line number	Diff line change
`@@ -47,7 +47,7 @@ public async void Run([EventGridTrigger]EventGridEvent eventGridEvent, ILogger l`
`47`	`47`
`48`	`48`	`//Update twin using device temperature`
`49`	`49`	`var updateTwinData = new JsonPatchDocument();`
`50`		`- updateTwinData.AppendAdd("/Temperature", temperature.Value<double>());`
	`50`	`+ updateTwinData.AppendReplace("/Temperature", temperature.Value<double>());`
`51`	`51`	`await client.UpdateDigitalTwinAsync(deviceId, updateTwinData);`
`52`	`52`	`}`
`53`	`53`	`}`