//*******************************************************************************************************
//  FileReplicationProvider.cs - Gbtc
//
//  Tennessee Valley Authority, 2009
//  No copyright is claimed pursuant to 17 USC § 105.  All Other Rights Reserved.
//
//  Code Modification History:
//  -----------------------------------------------------------------------------------------------------
//  11/05/2009 - Pinal C. Patel
//       Generated original version of source code.
//
//*******************************************************************************************************

using System;
using System.Linq;
using Microsoft.Synchronization;
using Microsoft.Synchronization.Files;
using TVA;
using TVA.Historian.Replication;
using TVA.IO;

namespace NERC.PCS.Replication
{
    /// <summary>
    /// Represents a provider of replication for the <see cref="TVA.Historian.IArchive"/> to a file system folder/share using file-base synchronization.
    /// </summary>
    public class FileReplicationProvider : ReplicationProviderBase
    {
        #region [ Constructors ]

        /// <summary>
        /// Initializes a new instance of the <see cref="FileReplicationProvider"/> class.
        /// </summary>
        public FileReplicationProvider()
            : base()
        {
        }

        #endregion

        #region [ Methods ]

        /// <summary>
        /// Replicates the <see cref="TVA.Historian.IArchive"/>.
        /// </summary>
        protected override void ReplicateArchive()
        {
            // Connect to remote share if specified.
            string archiveLocation = ArchiveLocation;
            string replicaLocation = ReplicaLocation;
            if (replicaLocation.StartsWith(@"\\") && replicaLocation.Contains(':') && replicaLocation.Contains('@'))
            {
                // Format: \\[<domain>\]<username>:<password>@<network share>
                string share = @"\\" + replicaLocation.Substring(replicaLocation.IndexOf('@') + 1);
                string login = replicaLocation.Substring(2, replicaLocation.IndexOf(':') - 2);
                string password = replicaLocation.Substring(replicaLocation.IndexOf(':') + 1, replicaLocation.IndexOf('@') - replicaLocation.IndexOf(':') - 1);

                replicaLocation = share;
                string[] loginParts = login.Split('\\');
                if (loginParts.Length == 2)
                    FilePath.ConnectToNetworkShare(replicaLocation, loginParts[0], password, loginParts[1]);
                else
                    FilePath.ConnectToNetworkShare(replicaLocation, login, password, Environment.UserDomainName);
            }

            FileSyncProvider syncSource = null;
            FileSyncProvider syncDestination = null;
            try
            {
                // Setup file synchronization filter.
                FileSyncScopeFilter synchFilter = new FileSyncScopeFilter();
                synchFilter.FileNameIncludes.Add("*_to_*.d");

                // Setup file synchronization providers.
                syncSource = new FileSyncProvider(archiveLocation, synchFilter, FileSyncOptions.CompareFileStreams);
                syncDestination = new FileSyncProvider(replicaLocation, synchFilter, FileSyncOptions.CompareFileStreams);
                syncDestination.ApplyingChange += SyncDestination_ApplyingChange;
                syncDestination.AppliedChange += SyncDestination_AppliedChange;

                // Setup and start file synchronization agent.
                SyncOrchestrator syncAgent = new SyncOrchestrator();
                syncAgent.LocalProvider = syncSource;
                syncAgent.RemoteProvider = syncDestination;
                syncAgent.Direction = SyncDirectionOrder.Upload;
                syncAgent.Synchronize();
            }
            finally
            {
                // Release resource used by synchronization providers.
                if (syncSource != null)
                    syncSource.Dispose();

                if (syncDestination != null)
                    syncDestination.Dispose();
            }
        }

        private void SyncDestination_ApplyingChange(object sender, ApplyingChangeEventArgs e)
        {
            // Skip synchronization for deletes and renames.
            if (e.ChangeType == ChangeType.Delete || e.ChangeType == ChangeType.Rename)
                e.SkipChange = true;
        }

        private void SyncDestination_AppliedChange(object sender, AppliedChangeEventArgs e)
        {
            // Provide an update for the replication progress.
            OnReplicationProgress(new ProcessProgress<int>("ReplicateArchive", e.NewFilePath, 1, 1));
        }

        #endregion
    }
}