1 files changed, 153 insertions, 0 deletions
diff --git a/Software/Visual_Studio/PPC/Tango.PPC.Common/RemoteJob/DefaultRemoteJobService.cs b/Software/Visual_Studio/PPC/Tango.PPC.Common/RemoteJob/DefaultRemoteJobService.cs
new file mode 100644
index 000000000..33e002950
--- /dev/null
+++ b/Software/Visual_Studio/PPC/Tango.PPC.Common/RemoteJob/DefaultRemoteJobService.cs
@@ -0,0 +1,153 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using Tango.BL.DTO;
+using Tango.Core;
+using Tango.Core.DI;
+using Tango.Integration.ExternalBridge;
+using Tango.Integration.Operation;
+using Tango.PPC.Common.Connection;
+using Tango.PPC.Common.ExternalBridge;
+using Tango.PPC.Shared.Jobs;
+
+namespace Tango.PPC.Common.RemoteJob
+{
+    [TangoCreateWhenRegistered]
+    public class DefaultRemoteJobService : IRemoteJobService, IExternalBridgeRequestHandler
+    {
+        private class RunningJobUpdateClient
+        {
+            public String Token { get; set; }
+            public ExternalBridgeReceiver Receiver { get; set; }
+            public bool JobSent { get; set; }
+        }
+
+        private List<RunningJobUpdateClient> _clients;
+        private JobHandler _handler;
+
+        public bool Enabled { get; set; } = true;
+
+        private IMachineProvider MachineProvider { get; set; }
+
+        public DefaultRemoteJobService(IPPCExternalBridgeService externalBridge, IMachineProvider machineProvider)
+        {
+            externalBridge.RegisterRequestHandler(this);
+
+            MachineProvider = machineProvider;
+
+            _clients = new List<RunningJobUpdateClient>();
+            MachineProvider.MachineOperator.PrintingStarted += MachineOperator_PrintingStarted;
+        }
+
+        private async void MachineOperator_PrintingStarted(object sender, Integration.Operation.PrintingEventArgs e)
+        {
+            _handler = e.JobHandler;
+
+            e.JobHandler.StatusChanged += JobHandler_StatusChanged;
+            e.JobHandler.Stopped += JobHandler_Stopped;
+
+            var jobDTO = JobDTO.FromObservable(e.Job);
+            var processParametersDTO = ProcessParametersTableDTO.FromObservable(_handler.ProcessParameters);
+
+            foreach (var client in _clients.ToList())
+            {
+                try
+                {
+                    RemoteJobProgress progress = new RemoteJobProgress();
+                    progress.Stage = RemoteJobStage.Started;
+                    progress.JobStatus = _handler.JobStatus;
+
+                    await client.Receiver.SendGenericResponse(new RemoteJobUpdateResponse()
+                    {
+                        Job = jobDTO,
+                        ProcessParameters = processParametersDTO,
+                        Progress = progress
+                    }, client.Token);
+
+                    client.JobSent = true;
+                }
+                catch { }
+            }
+        }
+
+        private async void JobHandler_StatusChanged(object sender, RunningJobStatus e)
+        {
+            foreach (var client in _clients.ToList().Where(x => x.JobSent))
+            {
+                try
+                {
+                    await client.Receiver.SendGenericResponse(new RemoteJobUpdateResponse()
+                    {
+                        Progress = GetJobProgress(_handler)
+                    }, client.Token);
+                }
+                catch { }
+            }
+        }
+
+        private async void JobHandler_Stopped(object sender, EventArgs e)
+        {
+            foreach (var client in _clients.ToList().Where(x => x.JobSent))
+            {
+                try
+                {
+                    await client.Receiver.SendGenericResponse(new RemoteJobUpdateResponse()
+                    {
+                        Progress = GetJobProgress(_handler),
+                    }, client.Token);
+
+                    client.JobSent = false;
+                }
+                catch { }
+            }
+        }
+
+        private RemoteJobProgress GetJobProgress(JobHandler handler)
+        {
+            RemoteJobStage stage = RemoteJobStage.Running;
+
+            if (_handler.Status.IsCanceled)
+            {
+                stage = RemoteJobStage.Aborted;
+            }
+            else if (_handler.Status.IsCompleted)
+            {
+                stage = RemoteJobStage.Completed;
+            }
+            else if (_handler.Status.IsFailed)
+            {
+                stage = RemoteJobStage.Failed;
+            }
+
+            return new RemoteJobProgress()
+            {
+                Stage = stage,
+                JobStatus = handler.JobStatus,
+            };
+        }
+
+        [ExternalBridgeRequestHandlerMethod(typeof(RemoteJobUpdateRequest), RequestHandlerLoggingMode.LogRequestName)]
+        public async Task OnRunningJobUpdateRequest(RemoteJobUpdateRequest request, String token, ExternalBridgeReceiver receiver)
+        {
+            this.ThrowIfDisabled();
+
+            if (!_clients.ToList().Exists(x => x.Receiver == receiver))
+            {
+                _clients.Add(new RunningJobUpdateClient()
+                {
+                    Receiver = receiver,
+                    Token = token
+                });
+            }
+
+            await receiver.SendGenericResponse(new RemoteJobUpdateResponse(), token);
+        }
+
+        public void OnReceiverDisconnected(ExternalBridgeReceiver receiver)
+        {
+            _clients.RemoveAll(x => x.Receiver == receiver);
+        }
+    }
+}