1 files changed, 65 insertions, 0 deletions
diff --git a/Software/Visual_Studio/PPC/Tango.PPC.UI/ThreadLoading/DefaultThreadLoadingService.cs b/Software/Visual_Studio/PPC/Tango.PPC.UI/ThreadLoading/DefaultThreadLoadingService.cs
new file mode 100644
index 000000000..a6479da63
--- /dev/null
+++ b/Software/Visual_Studio/PPC/Tango.PPC.UI/ThreadLoading/DefaultThreadLoadingService.cs
@@ -0,0 +1,65 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using Tango.Integration.Operation;
+using Tango.PPC.Common.Connection;
+using Tango.PPC.Common.Notifications;
+using Tango.PPC.Common.Threading;
+using Tango.PPC.Common.ThreadLoading;
+using Tango.PPC.UI.Dialogs;
+
+namespace Tango.PPC.UI.ThreadLoading
+{
+    public class DefaultThreadLoadingService : IThreadLoadingService
+    {
+        private INotificationProvider _notificationsProvider;
+        private IMachineProvider _machineProvider;
+        private IDispatcherProvider _dispatcher;
+        private bool _dialogShown;
+
+        public DefaultThreadLoadingService(INotificationProvider notificationsProvider, IMachineProvider machineProvider, IDispatcherProvider dispatcher)
+        {
+            _notificationsProvider = notificationsProvider;
+            _machineProvider = machineProvider;
+            _dispatcher = dispatcher;
+            _machineProvider.MachineOperator.ThreadLoadingStatusChanged += MachineOperator_ThreadLoadingStatusChanged;
+        }
+
+        private void MachineOperator_ThreadLoadingStatusChanged(object sender, PMR.ThreadLoading.StartThreadLoadingResponse e)
+        {
+            if (!_dialogShown && e.State != PMR.ThreadLoading.ThreadLoadingState.None)
+            {
+                _dialogShown = true;
+                _dispatcher.Invoke(async () =>
+                {
+                    await _notificationsProvider.ShowDialog<ThreadLoadingViewVM>(new ThreadLoadingViewVM());
+                    _dialogShown = false;
+                });
+            }
+        }
+
+        public async void StartThreadLoadingWizard()
+        {
+            _dialogShown = true;
+            await _notificationsProvider.ShowDialog<ThreadLoadingViewVM>(new ThreadLoadingViewVM(true));
+            _dialogShown = false;
+        }
+
+        public async void StartThreadBreakWizard()
+        {
+            if (!_dialogShown)
+            {
+                _dialogShown = true;
+                var vm = await _notificationsProvider.ShowDialog<ThreadBreakViewVM>();
+                _dialogShown = false;
+
+                if (vm.Result == ThreadBreakViewVM.ThreadBreakWizardResult.StartThreadLoading)
+                {
+                    StartThreadLoadingWizard();
+                }
+            }
+        }
+    }
+}