fix stale message filtering. now has a utc/local mismatch somehow.

microsoft · Apr 25, 2019 · 11fd080 · 11fd080
1 parent ac59fd9
commit 11fd080
Showing 1 changed file with 8 additions and 5 deletions.
diff --git a/Samples/EdgeModules/Gpio/CS/ConsoleDotNetCoreGPIO/AzureConnection.cs b/Samples/EdgeModules/Gpio/CS/ConsoleDotNetCoreGPIO/AzureConnection.cs
@@ -79,12 +79,13 @@ private static async Task<MessageResponse> OnFruitMessageReceived(Message msg, o
             }
             if (originalEventUTC >= module._lastFruitUTC)
             {
-                Log.WriteLine("FruitMsgHandler invoking event. original event UTC {0}", originalEventUTC.ToString("o"));
+                Log.WriteLine("FruitMsgHandler invoking event. original event UTC {0} prev {1}", originalEventUTC.ToString("o"), module._lastFruitUTC.ToString("o"));
                 await Task.Run(() => module.FruitChanged?.Invoke(module, fruitMsg.FruitSeen));
+                module._lastFruitUTC = originalEventUTC;
             }
             else
             {
-                Log.WriteLine("FruitMsgHandler ignoring stale message. original event UTC {1}", originalEventUTC.ToString("o"));
+                Log.WriteLine("FruitMsgHandler ignoring stale message. original event UTC {0} prev {1}", originalEventUTC.ToString("o"), module._lastFruitUTC.ToString("o"));
             }
             return MessageResponse.Completed;
         }
@@ -135,12 +136,14 @@ private Task<MethodResponse> SetFruit(MethodRequest req, Object context)
             }
             if (originalEventUTC >= _lastFruitUTC)
             {
-                Log.WriteLine("SetFruit invoking event. original event UTC {0}", originalEventUTC.ToString("o"));
+                Log.WriteLine("SetFruit invoking event. original event UTC {0} prev {1}", originalEventUTC.ToString("o"), _lastFruitUTC.ToString("o"));
                 AzureModule module = (AzureModule)context;
                 module.FruitChanged?.Invoke(module, fruitMsg.FruitSeen);
-            }  else
+                _lastFruitUTC = originalEventUTC;
+            }
+            else
             {
-                Log.WriteLine("SetFruit ignoring stale message. original event UTC {1}", originalEventUTC.ToString("o"));
+                Log.WriteLine("SetFruit ignoring stale message. original event UTC {0} prev {1}", originalEventUTC.ToString("o"), _lastFruitUTC.ToString("o"));
             }
             // Acknowlege the direct method call with a 200 success message
             string result = "{\"result\":\"Executed direct method: " + req.Name + "\"}";