PPC.Common Logs and comments!

1 files changed, 78 insertions, 11 deletions

diff --git a/Software/Visual_Studio/PPC/Tango.PPC.Common/MachineSetup/MachineSetupManager.cs b/Software/Visual_Studio/PPC/Tango.PPC.Common/MachineSetup/MachineSetupManager.cs
index 01f828c3f..14cdeb3f2 100644
--- a/Software/Visual_Studio/PPC/Tango.PPC.Common/MachineSetup/MachineSetupManager.cs
+++ b/Software/Visual_Studio/PPC/Tango.PPC.Common/MachineSetup/MachineSetupManager.cs
@@ -21,14 +21,33 @@ using Tango.Transport.Web;
 
 namespace Tango.PPC.Common.MachineSetup
 {
+    /// <summary>
+    /// Represents the PPC machine setup manager.
+    /// </summary>
+    /// <seealso cref="Tango.Core.ExtendedObject" />
+    /// <seealso cref="Tango.PPC.Common.MachineSetup.IMachineSetupManager" />
     public class MachineSetupManager : ExtendedObject, IMachineSetupManager
     {
-        private IPPCApplicationManager _applicationManager;
+        #region Events
 
+        /// <summary>
+        /// Occurs when there is a text log message available.
+        /// </summary>
         public event EventHandler<string> ProgressLog;
+
+        /// <summary>
+        /// Occurs when the <see cref="CurrentStep" /> has changed.
+        /// </summary>
         public event EventHandler<MachineSetupSteps> ProgressStep;
 
+        #endregion
+
+        #region Properties
+
         private MachineSetupSteps _currentStep;
+        /// <summary>
+        /// Gets the current setup step.
+        /// </summary>
         public MachineSetupSteps CurrentStep
         {
             get { return _currentStep; }
@@ -39,11 +58,15 @@ namespace Tango.PPC.Common.MachineSetup
                     _currentStep = value;
                     RaisePropertyChangedAuto();
                     ProgressStep?.Invoke(this, _currentStep);
+                    LogManager.Log("Machine Setup Manager Step: " + value.ToString());
                 }
             }
         }
 
         private double _downloadProgress;
+        /// <summary>
+        /// Gets the downloading packages step progress.
+        /// </summary>
         public double DownloadingPackagesProgress
         {
             get { return _downloadProgress; }
@@ -51,27 +74,39 @@ namespace Tango.PPC.Common.MachineSetup
         }
 
         private String _updatingPackagesStatus;
+        /// <summary>
+        /// Gets the downloading packages step status.
+        /// </summary>
         public String DownloadingPackagesStatus
         {
             get { return _updatingPackagesStatus; }
             set { _updatingPackagesStatus = value; RaisePropertyChangedAuto(); }
         }
 
-        public MachineSetupManager(IPPCApplicationManager applicationManager)
-        {
-            _applicationManager = applicationManager;
-        }
+        #endregion
+
+        #region Public Methods
 
+        /// <summary>
+        /// Performs a machine setup using the specified serial number and machine service address.
+        /// </summary>
+        /// <param name="serialNumber">The serial number.</param>
+        /// <param name="machineServiceAddress">The machine service address.</param>
+        /// <returns></returns>
         public Task<MachineSetupResult> Setup(string serialNumber, string machineServiceAddress)
         {
             return Task.Factory.StartNew<MachineSetupResult>(() =>
             {
 
+                LogManager.Log($"Starting machine setup for serial number {serialNumber}...");
+
                 //Connect to machine service and get matching packages for this machine.
                 CurrentStep = MachineSetupSteps.DownloadingPackage;
                 DownloadingPackagesProgress = 0;
                 DownloadingPackagesStatus = "Connecting to machine service...";
 
+                LogManager.Log($"Connecting to machine service on {machineServiceAddress}...");
+
                 MachineSetupRequest request = new MachineSetupRequest();
                 request.SerialNumber = serialNumber;
 
@@ -82,15 +117,23 @@ namespace Tango.PPC.Common.MachineSetup
                     setup_response = http.Post<MachineSetupRequest, MachineSetupResponse>(machineServiceAddress + "/api/Synchronization/MachineSetup", request).Result;
                 }
 
+                LogManager.Log($"Machine setup response received: {Environment.NewLine}{setup_response.ToJsonString()}");
+
                 //Create temporary folders for packages.
                 var _newPackageTempFolder = TemporaryManager.CreateFolder();
                 _newPackageTempFolder.Persist = true;
 
+                LogManager.Log($"Temporary package folder created: {_newPackageTempFolder}.");
+
                 //Download software package.
                 var tempFile = TemporaryManager.CreateFile(".zip");
 
+                LogManager.Log($"Temporary package zip file created: {tempFile}.");
+
                 DownloadingPackagesStatus = "Downloading software package...";
 
+                LogManager.Log("Downloading software package...");
+
                 int fileSize = 0;
                 DownloadingPackagesProgress = 0;
 
@@ -98,23 +141,24 @@ namespace Tango.PPC.Common.MachineSetup
                 {
                     InvokeUINow(() =>
                     {
-                        Thread.Sleep(10);
+                        Thread.Sleep(10); //TODO: this is necessary only for visibility...
                         DownloadingPackagesProgress = ((double)current / (double)fileSize) * 100d;
                     });
                 }))
                 {
                     using (FtpClient ftp = new FtpClient(setup_response.FtpAddress, setup_response.FtpUserName, setup_response.FtpPassword))
                     {
-                        LogManager.Log("Connecting to FTP site: " + setup_response.FtpAddress);
+                        LogManager.Log("FTP: Connecting to site: " + setup_response.FtpAddress);
                         ftp.ConnectAsync().Wait();
-                        LogManager.Log("Retrieving download size...");
+                        LogManager.Log("FTP: Retrieving download size...");
                         fileSize = (int)ftp.GetFileSize(setup_response.FtpFilePath);
-                        LogManager.Log("Download size: " + fileSize + " bytes.");
-                        LogManager.Log("Starting download...");
+                        LogManager.Log("FTP: Download size: " + fileSize + " bytes.");
+                        LogManager.Log("FTP: Starting download...");
                         ftp.DownloadAsync(fs, setup_response.FtpFilePath).Wait();
                     }
                 }
 
+                LogManager.Log("Extracting downloaded zip file...");
                 //Extract software package.
                 ZipFile.ExtractToDirectory(tempFile, _newPackageTempFolder);
 
@@ -126,17 +170,25 @@ namespace Tango.PPC.Common.MachineSetup
                 String localAddress = SettingsManager.Default.GetOrCreate<CoreSettings>().DataBaseSource;
                 String remote_address = setup_response.DbAddress;
 
+                LogManager.Log($"Synchronizing database '{remote_address}\\{db_name}' => '{localAddress}\\{db_name}'...");
+
+                LogManager.Log("Initializing database manager...");
                 DbManager db = DbManager.FromAddressAndName(localAddress, db_name);
 
+                LogManager.Log("Checking Tango database exists on the local machine...");
                 if (!db.Exists(db_name))
                 {
                     throw new InvalidProgramException("Database tango does not exists.");
                 }
 
+                LogManager.Log("Clearing database...");
                 db.ClearDb();
 
+                LogManager.Log("Disposing database manager.");
                 db.Dispose();
 
+                LogManager.Log($"Initializing {nameof(ExaminerSequenceConfigurationRunner)}...");
+
                 ExaminerSequenceConfigurationRunner runner = new ExaminerSequenceConfigurationRunner(
                     Path.Combine(_newPackageTempFolder, "Synchronization Scripts", "config.xml"),
                     Path.Combine(_newPackageTempFolder, "Synchronization Scripts"),
@@ -157,11 +209,14 @@ namespace Tango.PPC.Common.MachineSetup
 
                 runner.Log += (x, msg) =>
                 {
+                    LogManager.Log(msg);
                     ProgressLog.Invoke(this, msg);
                 };
 
                 runner.ScriptExecuting += (x, item) =>
                 {
+                    LogManager.Log($"Executing script {item.ToString()}...");
+
                     if (item.Type == ExaminerSequenceItemType.Data && item.RequiresSerialNumber)
                     {
                         CurrentStep = MachineSetupSteps.SynchronizingMachineConfiguration;
@@ -172,7 +227,17 @@ namespace Tango.PPC.Common.MachineSetup
                     }
                 };
 
-                runner.Run().Wait();
+                LogManager.Log("Starting synchronization process...");
+
+                try
+                {
+                    runner.Run().Wait();
+                    LogManager.Log("Synchronization completed successfully!");
+                }
+                catch (Exception ex)
+                {
+                    throw LogManager.Log(ex, "Setup manager error while trying to synchronize database.");
+                }
 
                 return new MachineSetupResult()
                 {
@@ -180,5 +245,7 @@ namespace Tango.PPC.Common.MachineSetup
                 };
             });
         }
+
+        #endregion
     }
 }