using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Tango.Core;
using Tango.Core.DI;
using Tango.FSE.Common.Connection;
using Tango.FSE.Common.Notifications;
using Tango.FSE.Common.Performance;
using Tango.PPC.Shared.Performance;

namespace Tango.FSE.UI.Performance
{
    /// <summary>
    /// Represents the <see cref="IPerformanceProvider"/> default implementation.
    /// </summary>
    /// <seealso cref="Tango.Core.ExtendedObject" />
    /// <seealso cref="Tango.FSE.Common.Performance.IPerformanceProvider" />
    [TangoCreateWhenRegistered]
    public class DefaultPerformanceProvider : ExtendedObject, IPerformanceProvider
    {
        /// <summary>
        /// Gets or sets the machine provider.
        /// </summary>
        private IMachineProvider MachineProvider { get; set; }

        [TangoInject]
        private INotificationProvider NotificationProvider { get; set; }

        /// <summary>
        /// Occurs when a new performance monitoring frame is available.
        /// </summary>
        public event EventHandler<PerformancePackageEventArgs> PerformancePackageAvailable;

        /// <summary>
        /// Initializes a new instance of the <see cref="DefaultPerformanceProvider"/> class.
        /// </summary>
        /// <param name="machineProvider">The machine provider.</param>
        public DefaultPerformanceProvider(IMachineProvider machineProvider)
        {
            MachineProvider = machineProvider;
            MachineProvider.MachineConnected += MachineProvider_MachineConnected;
        }

        private void MachineProvider_MachineConnected(object sender, MachineConnectedEventArgs e)
        {
            if (MachineProvider.ConnectionType.IsRemote())
            {
                LogManager.Log("Starting remote PPC performance provider. Sending continuous performance updates request...");

                try
                {
                    MachineProvider.MachineOperator.SendGenericContinuousRequest<StartPerformanceUpdatesRequest, StartPerformanceUpdatesResponse>(new StartPerformanceUpdatesRequest()).Subscribe((response) =>
                    {
                        OnPerformancePackageAvailable(response.Package);
                    }, (ex) =>
                    {
                        if (!(ex is Transport.TransporterDisconnectedException))
                        {
                            LogManager.Log(ex, "Error starting remote PPC performance updates.");
                            NotificationProvider.PushErrorReportingSnackbar(ex, "PPC Module Error", "Error starting remote PPC performance updates.");
                        }
                    }, () =>
                    {
                    //Do nothing.
                });
                }
                catch (Exception ex)
                {
                    LogManager.Log(ex, "Error starting remote PPC performance updates.");
                    NotificationProvider.PushErrorReportingSnackbar(ex, "PPC Module Error", "Error starting remote PPC performance updates.");
                }
            }
        }

        protected virtual void OnPerformancePackageAvailable(PerformancePackage package)
        {
            PerformancePackageAvailable?.Invoke(this, new PerformancePackageEventArgs() { Package = package });
        }
    }
}