path: root/Software/Visual_Studio/PPC/Tango.PPC.Common/Connection/DefaultMachineProvider.cs

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.Integration.ExternalBridge;
using Tango.PMR.Connection;
using Tango.Transport.Adapters;
using Tango.Settings;
using Tango.Logging;
using Tango.BL.Builders;
using Tango.Core.DI;
using Tango.PPC.Common.Messages;
using Tango.Emulations.Emulators;
using Tango.Transport.Transporters;
using Tango.Integration;
using Tango.Transport;
using System.Threading;

namespace Tango.PPC.Common.Connection
{
    /// <summary>
    /// Represents the default <see cref="IMachineProvider"/>.
    /// </summary>
    /// <seealso cref="Tango.Core.ExtendedObject" />
    /// <seealso cref="Tango.PPC.Common.Connection.IMachineProvider" />
    public class DefaultMachineProvider : ExtendedObject, IMachineProvider
    {
        private bool _isInitialized;
        private Thread _connection_thread;

        /// <summary>
        /// Occurs when current <see cref="IMachineOperator" /> has changed.
        /// </summary>
        public event EventHandler<MachineOperatorChangedEventArgs> MachineOperatorChanged;

        private Machine _machine;
        /// <summary>
        /// Gets the database machine entity associated with the current machine.
        /// </summary>
        public Machine Machine
        {
            get
            {
                return _machine;
            }
            private set
            {
                _machine = value;
                RaisePropertyChangedAuto();
            }
        }

        private IMachineOperator _machineOperator;
        /// <summary>
        /// Gets the machine operator.
        /// </summary>
        public IMachineOperator MachineOperator
        {
            get
            {
                return _machineOperator;
            }
            private set
            {
                var oldOperator = _machineOperator;
                _machineOperator = value;
                OnMachineOperatorChanged(oldOperator, _machineOperator);
                RaisePropertyChangedAuto();
            }
        }

        /// <summary>
        /// Called when the machine operator has been changed
        /// </summary>
        /// <param name="oldOperator">The old operator.</param>
        /// <param name="newOperator">The new operator.</param>
        protected virtual void OnMachineOperatorChanged(IMachineOperator oldOperator, IMachineOperator newOperator)
        {
            MachineOperatorChanged?.Invoke(this, new MachineOperatorChangedEventArgs(oldOperator, newOperator));
        }

        /// <summary>
        /// Initializes a new instance of the <see cref="DefaultMachineProvider"/> class.
        /// </summary>
        public DefaultMachineProvider()
        {
            MachineOperator = new MachineOperator();
            MachineOperator.EnableEventsNotification = true;
            MachineOperator.EnableJobResume = true;
            MachineOperator.UseKeepAlive = true;
            MachineOperator.EnableDiagnostics = false;
            MachineOperator.EnableEmbeddedDebugging = false;
        }

        private async void ConnectionThreadMethod()
        {
            while (true)
            {
                if (MachineOperator.State != TransportComponentState.Connected)
                {
                    try
                    {
                        LogManager.Log("Starting machine connection procedure...");

                        var settings = SettingsManager.Default.GetOrCreate<PPCSettings>();

                        if (!Machine.IsDemo)
                        {
                            if (String.IsNullOrWhiteSpace(settings.EmbeddedComPort))
                            {
                                TimeSpan timeout = TimeSpan.FromSeconds(SettingsManager.Default.GetOrCreate<PPCSettings>().MachineScanningTimeoutSeconds);

                                LogManager.Log("Scanning for machine on available serial ports...");
                                Transport.Discovery.UsbCommunicationScanner<ConnectRequest, ConnectResponse> scanner = new Transport.Discovery.UsbCommunicationScanner<ConnectRequest, ConnectResponse>(UsbSerialBaudRates.BR_115200);
                                var response = await scanner.Scan(new ConnectRequest() { Password = "1234" }, timeout);

                                LogManager.Log("Machine discovered on port: " + response.Adapter.Address);
                                LogManager.Log("Device Information:");
                                LogManager.Log(response.Response.DeviceInformation.ToJsonString());

                                LogManager.Log("Disconnecting machine operator...");
                                await MachineOperator.Disconnect();
                                MachineOperator.Adapter = response.Adapter;
                                MachineOperator.JobHandlingMode = JobHandlerModes.SettingUp;
                                LogManager.Log("Connecting machine operator...");
                                MachineOperatorChanged?.Invoke(this, new MachineOperatorChangedEventArgs(MachineOperator, MachineOperator));
                                await MachineOperator.Connect();


                                await Task.Delay(1000);
                                await MachineOperator.UploadHardwareConfiguration(Machine.Configuration.HardwareVersion, Machine.Configuration);
                            }
                            else
                            {
                                LogManager.Log($"Connecting to machine on {settings.EmbeddedComPort}...");

                                UsbTransportAdapter adapter = new UsbTransportAdapter(settings.EmbeddedComPort, UsbSerialBaudRates.BR_115200);
                                MachineOperator.Adapter = adapter;
                                MachineOperator.JobHandlingMode = JobHandlerModes.SettingUp;
                                MachineOperatorChanged?.Invoke(this, new MachineOperatorChangedEventArgs(MachineOperator, MachineOperator));
                                await MachineOperator.Connect();

                                await Task.Delay(1000);
                                await MachineOperator.UploadHardwareConfiguration(Machine.Configuration.HardwareVersion, Machine.Configuration);
                            }
                        }
                        else
                        {
                            LogManager.Log("Application in demo mode!");

                            var emulator_channel_name = "emulator-" + Guid.NewGuid().ToString();

                            LogManager.Log("Starting embedded emulator...");
                            MachineEmulator emulator = new MachineEmulator(new BasicTransporter(new MemoryTransportAdapter(emulator_channel_name)));
                            await emulator.Start();

                            LogManager.Log("Emulator started. Connecting to emulator...");

                            MemoryTransportAdapter adapter = new MemoryTransportAdapter(emulator_channel_name);
                            MachineOperator.Adapter = adapter;
                            MachineOperator.JobHandlingMode = JobHandlerModes.SettingUp;
                            LogManager.Log("Connecting machine operator...");
                            MachineOperatorChanged?.Invoke(this, new MachineOperatorChangedEventArgs(MachineOperator, MachineOperator));
                            await MachineOperator.Connect();

                            await Task.Delay(1000);
                            await MachineOperator.UploadHardwareConfiguration(Machine.Configuration.HardwareVersion, Machine.Configuration);
                        }
                    }
                    catch (Exception ex)
                    {
                        LogManager.Log(ex, "Error while trying to scan and connect to the machine.");
                    }
                }

                Thread.Sleep(5000);
            }
        }

        /// <summary>
        /// Initializes this machine provider start machine port scanning and connection.
        /// </summary>
        public void Init(Machine machine)
        {
            if (!_isInitialized)
            {
                LogManager.Log("Initializing machine operator...");

                _isInitialized = true;

                LogManager.Log("Retrieving first machine database entry...");

                Machine = machine;

                if (Machine != null)
                {
                    LogManager.Log("First machine entry found. Machine serial number is: " + Machine.SerialNumber + ".");
                    ConnectToMachine();
                }
                else
                {
                    LogManager.Log("No machine entry found on database. Could not connect to the embedded device!", LogCategory.Error);
                }
            }
        }

        /// <summary>
        /// Tries to connect to the machine by scanning all available serial ports.
        /// The timeout for a scan cycle is specified on <see cref="PPCSettings.MachineScanningTimeoutSeconds"/>.
        /// </summary>
        private void ConnectToMachine()
        {
            if (_connection_thread == null)
            {
                _connection_thread = new Thread(ConnectionThreadMethod);
                _connection_thread.IsBackground = true;
                _connection_thread.Start();
            }
        }

        /// <summary>
        /// Saves the machine settings.
        /// </summary>
        /// <returns></returns>
        public async Task SaveMachine()
        {
            await Machine.GetDbContext().SaveChangesAsync();
            TangoMessenger.Default.Send(new MachineSettingsSavedMessage() { Machine = Machine });
        }

        /// <summary>
        /// Creates and connects a machine operator with no continuous requests at all.
        /// </summary>
        /// <returns></returns>
        public static async Task<IMachineOperator> CreateMinimalMachineOperator(Action<String> onProgress = null)
        {
            LogManager.Default.Log("Creating minimal machine operator...");

            var machineOperator = new MachineOperator();
            machineOperator.EnableDiagnostics = false;
            machineOperator.EnableEmbeddedDebugging = false;
            machineOperator.EnableEventsNotification = false;
            machineOperator.EnableJobResume = false;

            LogManager.Default.Log("Starting machine connection procedure...");

            var settings = SettingsManager.Default.GetOrCreate<PPCSettings>();

            if (String.IsNullOrWhiteSpace(settings.EmbeddedComPort))
            {
                TimeSpan timeout = TimeSpan.FromSeconds(SettingsManager.Default.GetOrCreate<PPCSettings>().MachineScanningTimeoutSeconds);

                onProgress?.Invoke("Scanning for the machine...");
                LogManager.Default.Log("Scanning for machine on available serial ports...");
                Transport.Discovery.UsbCommunicationScanner<ConnectRequest, ConnectResponse> scanner = new Transport.Discovery.UsbCommunicationScanner<ConnectRequest, ConnectResponse>(UsbSerialBaudRates.BR_115200);
                var response = await scanner.Scan(new ConnectRequest() { Password = "1234" }, timeout);

                onProgress?.Invoke("Machine discovered on port: " + response.Adapter.Address);
                LogManager.Default.Log("Machine discovered on port: " + response.Adapter.Address);
                LogManager.Default.Log("Device Information:");
                LogManager.Default.Log(response.Response.DeviceInformation.ToJsonString());

                machineOperator.Adapter = response.Adapter;
                machineOperator.JobHandlingMode = JobHandlerModes.SettingUp;
                LogManager.Default.Log("Connecting machine operator...");

                onProgress?.Invoke("Connecting machine operator...");
                await machineOperator.Connect();
            }
            else
            {
                LogManager.Default.Log($"Connecting to machine on {settings.EmbeddedComPort}...");

                onProgress?.Invoke($"Connecting to machine on {settings.EmbeddedComPort}...");
                UsbTransportAdapter adapter = new UsbTransportAdapter(settings.EmbeddedComPort, UsbSerialBaudRates.BR_115200);
                machineOperator.Adapter = adapter;
                machineOperator.JobHandlingMode = JobHandlerModes.SettingUp;
                await machineOperator.Connect();
            }

            return machineOperator;
        }
    }
}