Implemented continuous request timeouts.

Implemented continuous request abort exception.
Added log object for real time logs.
Some work on PPC & Machine Studio.

1 files changed, 77 insertions, 0 deletions

diff --git a/Software/Visual_Studio/PPC/Tango.PPC.Common/Connection/DefaultMachineProvider.cs b/Software/Visual_Studio/PPC/Tango.PPC.Common/Connection/DefaultMachineProvider.cs
new file mode 100644
index 000000000..636a73d3c
--- /dev/null
+++ b/Software/Visual_Studio/PPC/Tango.PPC.Common/Connection/DefaultMachineProvider.cs
@@ -0,0 +1,77 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using Tango.BL;
+using Tango.BL.Entities;
+using Tango.Core;
+using Tango.Integration.Operation;
+using Tango.PMR.Connection;
+using Tango.Transport.Adapters;
+
+namespace Tango.PPC.Common.Connection
+{
+    public class DefaultMachineProvider : ExtendedObject, IMachineProvider
+    {
+        private bool _isInitialized;
+
+        public event EventHandler<MachineOperatorChangedEventArgs> MachineOperatorChanged;
+
+        private Machine _machine;
+        public Machine Machine
+        {
+            get
+            {
+                return _machine;
+            }
+            private set
+            {
+                _machine = value;
+                RaisePropertyChangedAuto();
+            }
+        }
+
+        private IMachineOperator _machineOperator;
+        public IMachineOperator MachineOperator
+        {
+            get
+            {
+                return _machineOperator;
+            }
+            private set
+            {
+                var oldOperator = _machineOperator;
+                _machineOperator = value;
+                OnMachineOperatorChanged(oldOperator, _machineOperator);
+                RaisePropertyChangedAuto();
+            }
+        }
+
+        protected virtual void OnMachineOperatorChanged(IMachineOperator oldOperator, IMachineOperator newOperator)
+        {
+            MachineOperatorChanged?.Invoke(this, new MachineOperatorChangedEventArgs(oldOperator, newOperator));
+        }
+
+        public void Init()
+        {
+            if (!_isInitialized)
+            {
+                _isInitialized = true;
+
+                Machine = ObservablesEntitiesAdapter.Instance.Machines.FirstOrDefault();
+                ConnectToMachine();
+            }
+        }
+
+        private async void ConnectToMachine()
+        {
+            Transport.Discovery.UsbCommunicationScanner<ConnectRequest, ConnectResponse> scanner = new Transport.Discovery.UsbCommunicationScanner<ConnectRequest, ConnectResponse>(UsbSerialBaudRates.BR_9600);
+            var response = await scanner.Scan(new ConnectRequest() { Password = "1234" }, TimeSpan.FromSeconds(10));
+
+            var machine = new MachineOperator(response.Adapter);
+            await machine.Connect();
+            MachineOperator = machine;
+        }
+    }
+}