1 files changed, 29 insertions, 1 deletions
diff --git a/Software/Visual_Studio/Tango.Integration/Operation/MachineOperator.cs b/Software/Visual_Studio/Tango.Integration/Operation/MachineOperator.cs
index 93320c646..bce386bfe 100644
--- a/Software/Visual_Studio/Tango.Integration/Operation/MachineOperator.cs
+++ b/Software/Visual_Studio/Tango.Integration/Operation/MachineOperator.cs
@@ -85,6 +85,7 @@ namespace Tango.Integration.Operation
         private DateTime? _jobUploadingStartDate;
         private DateTime? _jobHeatingStartDate;
         private DateTime? _jobActualStartDate;
+        private List<Event> _emulatedEvents;
 
         public static String EmbeddedLogsFolder { get; private set; }
         public static String EmbeddedLogsTag { get; private set; }
@@ -124,6 +125,7 @@ namespace Tango.Integration.Operation
         /// </summary>
         public MachineOperator() : base()
         {
+            _emulatedEvents = new List<Event>();
             ComponentName = $"Machine Operator {_component_counter++}";
             DeviceInformation = new DeviceInformation();
             MachineEventsStateProvider = new DefaultMachineEventsStateProvider();
@@ -957,7 +959,17 @@ namespace Tango.Integration.Operation
         {
             if (MachineEventsStateProvider != null)
             {
-                MachineEventsStateProvider.ApplyEvents(response.Events);
+                var events = response.Events;
+
+                foreach (var emulated in _emulatedEvents)
+                {
+                    if (!events.Any(x => x.Type == emulated.Type))
+                    {
+                        events.Add(emulated);
+                    }
+                }
+
+                MachineEventsStateProvider.ApplyEvents(events);
             }
 
             EventsNotification?.Invoke(this, response);
@@ -1373,6 +1385,7 @@ namespace Tango.Integration.Operation
             if (MachineEventsStateProvider != null)
             {
                 LogManager.Log("Resetting active events...");
+                _emulatedEvents.Clear();
                 MachineEventsStateProvider.Reset();
             }
         }
@@ -4154,6 +4167,21 @@ namespace Tango.Integration.Operation
             }, new TransportRequestConfig() { ShouldLog = true, Timeout = TimeSpan.FromSeconds(20) });
         }
 
+        /// <summary>
+        /// Emulates a hardware event that will last for the specified timeout.
+        /// </summary>
+        /// <param name="ev">Type of the event.</param>
+        /// <param name="timeout">The timeout.</param>
+        public async void PushEmulatedEvent(Event ev, TimeSpan timeout)
+        {
+            if (!_emulatedEvents.Exists(x => x.Type == ev.Type))
+            {
+                _emulatedEvents.Add(ev);
+                await Task.Delay(timeout);
+                _emulatedEvents.Remove(ev);
+            }
+        }
+
         #endregion
     }
 }