using System;
using Microsoft.VisualStudio.TestTools.UnitTesting;
using Realisable.Data.Interop45;
using Realisable.Data.Transform;
using Realisable.JobDefinition;
using Realisable.Resources;
using Realisable.Utils;
using Realisable.Utils.DTO;
using Realisable.Utils.OM;

namespace Realisable.Connectors.Shopify.Test
{
    /// <summary>
    ///     Provides an abstract class for instantiating and processing connector datasets.
    ///     Every test should inherit from this class.
    /// </summary>
    [TestClass]
    public abstract class ConnectorTest
    {
        /// <summary>
        ///     The id of the Job Definition created as part of the unit tests.
        /// </summary>
        public const string JOBDEF_ID = "SHOPIFYTEST";

        /// <summary>
        ///     The name of the Job Definition created as part of the unit tests.
        /// </summary>
        public const string JOBDEF_NAME = "ConnectorTest";

        /// <summary>
        ///     A number used to signify the instance of the test. Leave as default as it a placeholder used in a live scenario.
        /// </summary>
        public const int INSTANCE_ID = 9977;

        protected JobDefinition.JobDefinition _jobDef;

        [TestInitialize]
        public void TestInitialise()
        {
            //Create the JobDefinition object so it's available to all.
            _jobDef = CreateJobDef();

            //Setup the NHibernate session so data can be from the IMan database.
            SessionBuilderFactory.GetBuilder(SessionBuilderType.ThreadStatic).OpenSession();
        }

        [TestCleanup]
        public void TestClose()
        {
            SessionBuilderFactory.GetBuilder(SessionBuilderType.ThreadStatic).CloseSession();
        }

        /// <summary>
        ///     Creates a JobDefinition so the Connector's transformDefiniton can be added.
        /// </summary>
        /// <returns></returns>
        public JobDefinition.JobDefinition CreateJobDef()
        {
            var result = new JobDefinition.JobDefinition();
            result.JobName = JOBDEF_NAME;
            return result;
        }

        /// <summary>
        ///     Creates a TransformDefinition object containing the metadata for importing Customer for the Sample connector.
        /// </summary>
        /// <returns></returns>
        protected TransformDefinition CreatePushStyleTransformDefTransposeImport(string importType)
        {
            // Create the resultant object.
            TransformDefinition result = CreatePushStyleTransformDef(TestConstants.CONNECTOR_SYSTEM, importType, Resources.eERPUpdateOperation.eUpdateInsert);

            //Need to do this through the MetaExtender otherwise it's not possible to debug the code (due to the same assembly being loaded from different paths).
            var metaExtender = ConnectorFactory.GetExtender(TestConstants.ASSEMBLY_NAME, false);
            metaExtender.ConnectorSettings = new SystemConnectorDTO(TestConstants.CONNECTOR_SYSTEM);
            SystemImport systemImport = metaExtender.MetaDataDocument[importType];

            result.TransposeSystemImport(systemImport, TranspositionOptions.CreateMissingRecords | TranspositionOptions.CreateMissingFields);

            return result;
        }


        /// <summary>
        ///     Creates a TransformDefinition object for a Push Style Connector.
        /// </summary>
        /// <param name="systemConnectorId">The id for the System Connector used to retrieve the connection properties.</param>
        /// <param name="impType">The import type.</param>
        /// <param name="updateOp">The update operation.</param>
        /// <returns></returns>
        protected TransformDefinition CreatePushStyleTransformDef(string systemConnectorId, string impType,
                                                                  eERPUpdateOperation updateOp)
        {
            TransformDefinition result = _jobDef.CreateTransform();
            ITransformSetup tfmSetup = new CustomConnectorTransformSetup();
            tfmSetup.InitialiseTransform(result);

            //Set the options for the connector.
            result.Options.SetProperty(GlobalResources.SYS_CONNECT_TRAN_TYPE_OPT, impType,
                                       false);
            result.Options.SetProperty(GlobalResources.SYS_CONNECT_SYSID_OPT, systemConnectorId, false);
            result.Options.SetProperty(GlobalResources.SYS_CONNECT_UPDATE_OP_OPT, Convert.ToInt32(updateOp).ToString(),
                                       false);
            result.Options.SetProperty(GlobalResources.CUS_CONNECT_ASSEMBLY_NAME_OPT, TestConstants.ASSEMBLY_NAME, false);

            result.AuditDefinition.ErrorAction = eTransformErrorAction.eTransformErrorActionAbort;

            return result;
        }

        /// <summary>
        ///     Creates a TransformDefinition object for a Pull Style connector.
        /// </summary>
        /// <param name="systemConnectorId">The id for the System Connector used to retrieve the connection properties.</param>
        /// <param name="importDataType">The type of data being retrieved.</param>
        /// <returns>The constructed TransformDefinition object.</returns>
        protected TransformDefinition CreatePullStyleTransformDef(string systemConnectorId, string importDataType)
        {
            TransformDefinition result = _jobDef.CreateTransform();

            ITransformSetup tfmSetup = new CustomReaderSetup();
            tfmSetup.InitialiseTransform(result);

            // Set the options for the Reader definition. 
            result.Options.SetProperty(GlobalResources.SYS_CONNECT_TRAN_TYPE_OPT, importDataType, false);
            result.Options.SetProperty(GlobalResources.SYS_CONNECT_SYSID_OPT, systemConnectorId, false);
            result.Options.SetProperty(GlobalResources.CUS_CONNECT_ASSEMBLY_NAME_OPT, TestConstants.ASSEMBLY_NAME, false);

            result.AuditDefinition.ErrorAction = eTransformErrorAction.eTransformErrorActionAbort;

            return result;
        }

        protected TransformDefinition CreatePullStyleTransformDef(string systemConnectorId, string importDataType, bool transposeImport)
        {
            TransformDefinition result = _jobDef.CreateTransform(null, RandomUtils.RandomString(5, true), TransformTypes.eRead, (int)eInputReaderType.eCustomReader);

            ITransformSetup tfmSetup = new CustomReaderSetup();
            tfmSetup.InitialiseTransform(result);

            // Set the options for the Reader definition. 
            result.Options.SetProperty(GlobalResources.SYS_CONNECT_TRAN_TYPE_OPT, importDataType, false);
            result.Options.SetProperty(GlobalResources.SYS_CONNECT_SYSID_OPT, systemConnectorId, false);
            result.Options.SetProperty(GlobalResources.CUS_CONNECT_ASSEMBLY_NAME_OPT, TestConstants.ASSEMBLY_NAME, false);

            result.AuditDefinition.ErrorAction = eTransformErrorAction.eTransformErrorActionAbort;

            if (transposeImport)
            {
                //Need to do this through the MetaExtender otherwise it's not possible to debug the code (due to the same assembly being loaded from different paths).
                var metaExtender = ConnectorFactory.GetExtender(TestConstants.ASSEMBLY_NAME, true);
                metaExtender.ConnectorSettings = new SystemConnectorDTO(TestConstants.CONNECTOR_SYSTEM);
                SystemImport systemImport = metaExtender.MetaDataDocument[importDataType];

                result.TransposeSystemImport(systemImport, TranspositionOptions.RecordAttributes | TranspositionOptions.CreateMissingRecords | TranspositionOptions.CreateMissingFields);
            }

            return result;
        }       


        /// <summary>
        ///     Processes a Push Style dataset by instantiating the ITransformInterop object and making the appropriate calls.
        /// </summary>
        /// <param name="transactionFactory">The transaction factory containing the dataset.</param>
        protected void ProcessTransactions(TransactionFactory transactionFactory)
        {
            TransformDefinition tfmDef = transactionFactory.TransformDefinition;

            //Obtain the system connector.
            SystemConnectorDTO connectorDTO = new SystemConnectorDTO(tfmDef.Options.GetProperty(GlobalResources.SYS_CONNECT_SYSID_OPT));

            //Get the updateOperation.
            eERPUpdateOperation updateOperation = tfmDef.Options.GetProperty<eERPUpdateOperation>(GlobalResources.SYS_CONNECT_UPDATE_OP_OPT);

            //Create the ITransformProcess object implemented by the connector.
            PushDataInterop import = new PushDataInterop();

            //Now initialise.
            import.Initialise(tfmDef, transactionFactory.CreateTransactionIterator(), false, tfmDef.AuditDefinition.ErrorAction, updateOperation, connectorDTO, new AuditProxy());
            
            //Run the actual import.
            import.Process();
        }

        /// <summary>
        ///     Process a Push Style dataset where the data contains a known error. Used to test exceptional test cases.
        /// </summary>
        /// <param name="transactionFactory">The transaction factory containing the dataset.</param>
        /// <typeparam name="T">The type of exception expected.</typeparam>
        protected void ProcessExceptionalTransactions<T>(TransactionFactory transactionFactory) where T : Exception
        {
            //Run the actual import using AssetExternsions.Throws method.
            AssertExtensions.Throws<T>(() => ProcessTransactions(transactionFactory));
        }
    }
}