using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Tango.BL;
using Tango.SQLExaminer;

namespace Tango.PPC.DataSynchronizer.CLI 
{
    class Program
    {
        static void Main(string[] args)  
        { 
            DataSynchronizer synchronizer = new DataSynchronizer();
            synchronizer.Synchronize();
            Console.ReadLine();
        }
    }

    public class DataSynchronizer
    {
        private const String REMOTE_ADDRESS = "twine.database.windows.net";
        private const String REMOTE_CATALOG = "Tango_DEV"; //Tango_TEST
        private const String REMOTE_USER_NAME = "Roy";
        private const String REMOTE_PASSWORD = "Aa123456";

        private const String LOCAL_ADDRESS = "localhost\\SQLPPC";
        private const String LOCAL_CATALOG = "Tango"; //Tango_TEST

        private const String MACHINE_SERIAL_NUMBER = "ROY_X1"; //ROY_TEST_MACHINE

        private Core.DataSource source;
        private Core.DataSource target;
        private String machineGuid;

        public void Synchronize()
        {
            try
            {
                Console.WriteLine("Starting PPC data synchronization...");

                source = new Core.DataSource();
                source.IntegratedSecurity = false;
                source.Address = REMOTE_ADDRESS;
                source.Catalog = REMOTE_CATALOG;
                source.UserName = REMOTE_USER_NAME;
                source.Password = REMOTE_PASSWORD;

                using (ObservablesContext db = ObservablesContext.CreateDefault(source))
                {
                    machineGuid = db.Machines.Where(x => x.SerialNumber == MACHINE_SERIAL_NUMBER).Take(1).Select(x => x.Guid).First();
                }

                target = new Core.DataSource();
                target.Address = LOCAL_ADDRESS;
                target.Catalog = LOCAL_CATALOG;

                OverrideData();
                UpdateMachine();
                //ProvisionMachine();

                Console.ForegroundColor = ConsoleColor.Green;
                Console.WriteLine("Synchronization Completed Successfully.");
            }
            catch (Exception ex)
            {
                Console.ForegroundColor = ConsoleColor.Red;
                Console.WriteLine(ex.ToString());
            }
        }

        private void OverrideData()
        {
            Console.WriteLine("Executing override data script...");

            ExaminerConfigurationBuilder builder = new ExaminerConfigurationBuilder(ExaminerConfigurationType.OverrideData);
            builder.SetSource(source).SetTarget(target).Synchronize();
            var process = new ExaminerProcess(builder.Build(), ExaminerProcessType.Data);
            process.Progress += (x, msg) =>
            {
                if (msg != null && !msg.Contains("SQL Examiner"))
                {
                    Console.WriteLine(msg);
                }
            };
            var result = process.Execute().Result;

            if (result.ExitCode != ExaminerProcessExitCode.Success)  
            {
                throw new InvalidOperationException(result.Output);
            }
        }

        private void UpdateMachine()
        {
            Console.WriteLine("Executing update machine script...");

            ExaminerConfigurationBuilder builder = new ExaminerConfigurationBuilder(ExaminerConfigurationType.UpdateMachine);
            builder.SetSource(source).SetTarget(target).SetMachineSerialNumber(machineGuid).Synchronize();
            var process = new ExaminerProcess(builder.Build(), ExaminerProcessType.Data);
            process.Progress += (x, msg) =>
            {
                if (msg != null && !msg.Contains("SQL Examiner"))
                {
                    Console.WriteLine(msg);
                }
            };
            var result = process.Execute().Result;

            if (result.ExitCode != ExaminerProcessExitCode.Success)
            {
                throw new InvalidOperationException(result.Output);
            }
        }

        private void ProvisionMachine()
        {
            Console.WriteLine("Executing provision machine script...");

            ExaminerConfigurationBuilder builder = new ExaminerConfigurationBuilder(ExaminerConfigurationType.ProvisionMachine);
            builder.SetSource(source).SetTarget(target).SetMachineSerialNumber(MACHINE_SERIAL_NUMBER).Synchronize();
            var process = new ExaminerProcess(builder.Build(), ExaminerProcessType.Data);
            process.Progress += (x, msg) =>
            {
                if (msg != null && !msg.Contains("SQL Examiner"))
                {
                    Console.WriteLine(msg);
                }
            };
            var result = process.Execute().Result;

            if (result.ExitCode != ExaminerProcessExitCode.Success)
            {
                throw new InvalidOperationException(result.Output);
            }
        }
    }
}