SendOrderToErpMinionBlock.cs

namespace Sitecore.Commerce.Connectors.MYERP.Plugin.Pipelines.Blocks
{
    using System;
    using System.Threading.Tasks;

    using Sitecore.Commerce.Connectors.MYERP.Plugin.Erp;
    using Sitecore.Commerce.Core;
    using Sitecore.Commerce.Plugin.Customers;
    using Sitecore.Commerce.Plugin.Orders;
    using Sitecore.Framework.Conditions;
    using Sitecore.Framework.Pipelines;

    /// <summary>
    /// The process orders minion block.
    /// </summary>
    public class SendOrderToErpMinionBlock : PipelineBlock<Order, Order, CommercePipelineExecutionContext>
    {
        /// <summary>
        /// The _persistEntityPipeline.
        /// </summary>
        private readonly IPersistEntityPipeline _persistEntityPipeline;

        /// <summary>
        /// The _find entity pipeline.
        /// </summary>
        private readonly IFindEntityPipeline _findEntityPipeline;

        /// <summary>
        /// The service provider.
        /// </summary>
        private readonly IServiceProvider serviceProvider;

        /// <summary>
        /// The get customer pipeline.
        /// </summary>
        private readonly IGetCustomerPipeline getCustomerPipeline;

        /// <summary>
        /// Initializes a new instance of the <see cref="SendOrderToErpMinionBlock"/> class.
        /// </summary>
        /// <param name="persistEntityPipeline">
        /// The persist entity pipeline.
        /// </param>
        /// <param name="findEntityPipeline">
        /// The find entity pipeline.
        /// </param>
        /// <param name="getCustomerPipeline">
        /// The get customer pipeline.
        /// </param>
        /// <param name="serviceProvider">
        /// The service provider.
        /// </param>
        public SendOrderToErpMinionBlock(IPersistEntityPipeline persistEntityPipeline, IFindEntityPipeline findEntityPipeline, IGetCustomerPipeline getCustomerPipeline, IServiceProvider serviceProvider)
        {
            this._persistEntityPipeline = persistEntityPipeline;
            this._findEntityPipeline = findEntityPipeline;
            this.getCustomerPipeline = getCustomerPipeline;
            this.serviceProvider = serviceProvider;
        }

        /// <summary>
        /// The run.
        /// </summary>
        /// <param name="arg">
        /// The argument.
        /// </param>
        /// <param name="context">
        /// The context.
        /// </param>
        /// <returns>
        /// The <see cref="Task"/>.
        /// </returns>
        public override async Task<Order> Run(Order arg, CommercePipelineExecutionContext context)
        {
            Condition.Requires(arg).IsNotNull("The argument can not be null");
            var integrationHelper = new IntegrationHelper(this._persistEntityPipeline, this._findEntityPipeline, this.serviceProvider, this.getCustomerPipeline);
            var returnedOrder = await integrationHelper.TranslateOrderAndSendToErp(arg, context);
            return returnedOrder;
        }
    }
}