using Microsoft.Azure.Management.AppService.Fluent;
using Microsoft.Azure.Management.Fluent;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows;
using Tango.AzureUtils.Environment;
using Tango.AzureUtils.Logging;
using Tango.Core.Commands;
using Tango.SharedUI.Components;

namespace Tango.AzureUtils.UI.ViewModels
{
    public class EnvironmentLogStreamViewVM : AzureDashboardViewModel
    {
        private LogStreamManager _logStreamManager;

        private List<IWebAppBase> _deploymentSlots;
        public List<IWebAppBase> DeploymentSlots
        {
            get { return _deploymentSlots; }
            set { _deploymentSlots = value; RaisePropertyChangedAuto(); }
        }

        private IWebAppBase _selectedDeploymentSlot;
        public IWebAppBase SelectedDeploymentSlot
        {
            get { return _selectedDeploymentSlot; }
            set { _selectedDeploymentSlot = value; RaisePropertyChangedAuto(); }
        }

        private TextController _log;
        public TextController Log
        {
            get { return _log; }
            set { _log = value; RaisePropertyChangedAuto(); }
        }

        private bool _isStarted;
        public bool IsStarted
        {
            get { return _isStarted; }
            set { _isStarted = value; RaisePropertyChangedAuto(); InvalidateRelayCommands(); }
        }

        public RelayCommand StartCommand { get; set; }

        public RelayCommand StopCommand { get; set; }

        public RelayCommand ClearCommand { get; set; }

        public EnvironmentLogStreamViewVM()
        {
            Log = new TextController();

            StartCommand = new RelayCommand(Start,() => !IsStarted);
            StopCommand = new RelayCommand(Stop, () => IsStarted);
            ClearCommand = new RelayCommand(Clear);
        }

        public override void OnAuthenticated(IAzure azure, List<IWebAppBase> apps)
        {
            DeploymentSlots = apps.ToList();
            SelectedDeploymentSlot = DeploymentSlots.SingleOrDefault(x => x.Name.EndsWith("DEV"));

            _logStreamManager = new LogStreamManager(azure);
            _logStreamManager.ConfirmationRequired += ConfirmationHandler;
            _logStreamManager.Progress += ProgressHandler;
            _logStreamManager.LogAvailable += _logStreamManager_LogAvailable;
        }

        private void _logStreamManager_LogAvailable(object sender, string msg)
        {
            Log.WriteLine(msg);
        }

        private void Clear()
        {
            Log.Clear();
        }

        private void Stop()
        {
            IsStarted = false;
            _logStreamManager.StopLogStreaming();
        }

        private async void Start()
        {
            if (SelectedDeploymentSlot != null && _logStreamManager != null)
            {
                try
                {
                    IsStarted = true;
                    Log.Clear();
                    await _logStreamManager.StartLogStreamingAsync(SelectedDeploymentSlot);
                }
                catch
                {
                    IsStarted = false;
                }
            }
        }
    }
}