using BodyshopPartner.Models;
using BodyshopPartner.Utils.Growls;
using GraphQL.Client;
using GraphQL.Common.Request;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using System;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.ComponentModel;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Windows;
using Firebase.Auth;

namespace BodyshopPartner.ViewModels
{
    public partial class MainViewModel : BaseViewModel
    {
        private static NLog.Logger logger = NLog.LogManager.GetCurrentClassLogger();

        public MainViewModel()
        {
            logger.Trace("Main VM constructed.");

            BackgroundWorker bw = new BackgroundWorker();
            bw.DoWork += bw_InitVm;
            bw.WorkerReportsProgress = true;
            bw.ProgressChanged += Bw_ProgressChanged;
            bw.RunWorkerCompleted += Bw_RunWorkerCompleted;
            bw.RunWorkerAsync();

            Growler = new GrowlNotification(this);
            Utils.JobProcessingQueue.SetGrowler(Growler);
        }

        private void Bw_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
        {
            ((BackgroundWorker)sender).Dispose();
            Progress = 0;
        }

        private void Bw_ProgressChanged(object sender, ProgressChangedEventArgs e)
        {
            Progress = e.ProgressPercentage;

            logger.Trace("Starting monitors if able to.");
            if (StartFolderMonitorsCommand.CanExecute(null))
                StartFolderMonitorsCommand.Execute(null);
            MonitoringPaths.CollectionChanged += MonitoringPathsChanged;
        }

        private void bw_InitVm(object sender, DoWorkEventArgs e)
        {
            BackgroundWorker _callingThread = sender as BackgroundWorker;
            _callingThread.ReportProgress(1);

            //Restore list of paths, convert to monitor object.
            List<string> listOfPaths = Properties.Settings.Default.MonitoringPaths;
            if (listOfPaths == null) listOfPaths = new List<string>();
            foreach (var p in listOfPaths)
            {
                MonitoringPaths.Add(new Models.Monitor() { FilePath = p });
            }

            _callingThread.ReportProgress(30);

            _updateCheckTimer.Elapsed += _updateTimer_Elapsed;
            _updateCheckTimer.AutoReset = true;
            _updateCheckTimer.Start();

            _callingThread.ReportProgress(50);
            //Cannot use await.
            LoadBodyshopData().Wait(); ;

            _callingThread.ReportProgress(80);

            Utils.HTTPServer.InitHttpServer();

            logger.Debug("VM Init Complete");
            _callingThread.ReportProgress(100);
        }

        private async void _updateTimer_Elapsed(object sender, System.Timers.ElapsedEventArgs e)
        {
            if (await Utils.UpdateHandler.AreUpdatesAvailable())
            {
                await Utils.UpdateHandler.ApplyUpdates(Progress, Progress);
            }
        }

        private void MonitoringPathsChanged(object sender, System.Collections.Specialized.NotifyCollectionChangedEventArgs e)
        {
            IndeterminateLoading = true;
            StopAllFolderMonitors();
            StartAllFolderMonitors();
            IndeterminateLoading = false;
        }

        public void AddFolderMonitoringPath()
        {
            var dialog = new Ookii.Dialogs.Wpf.VistaFolderBrowserDialog();
            if (dialog.ShowDialog().GetValueOrDefault())
            {
                logger.Debug("Adding folder {0} to monitoring paths.", dialog.SelectedPath);
                MonitoringPaths.Add(new Models.Monitor() { FilePath = dialog.SelectedPath });
                Properties.Settings.Default.MonitoringPaths = MonitoringPaths.Select(x => x.FilePath).ToList(); ;
                Properties.Settings.Default.Save();
            }
        }

        public void RemoveFolderMonitoringPath(Monitor m)
        {
            logger.Debug("Removing folder {0} to monitoring paths.", m.FilePath);
            m.StopMonitor();
            MonitoringPaths.Remove(m);
            Properties.Settings.Default.MonitoringPaths = MonitoringPaths.Select(x => x.FilePath).ToList();
            Properties.Settings.Default.Save();
        }

        public void StartAllFolderMonitors()
        {
            IndeterminateLoading = true;
            if (MonitoringPaths.Count > 0)
                foreach (var m in MonitoringPaths)
                {
                    m.StopMonitor();
                }

            foreach (var p in MonitoringPaths)
            {
                p.StartMonitor();
            }
            IndeterminateLoading = false;
        }

        public void StopAllFolderMonitors()
        {
            IndeterminateLoading = true;
            if (MonitoringPaths.Count > 0)
                foreach (var m in MonitoringPaths)
                {
                    m.StopMonitor();
                }
            IndeterminateLoading = false;
        }

        public async Task LoadBodyshopData()
        {
            var r = new GraphQLRequest
            {
                Query = @"query QUERY_BODYSHOPS {
                                                  bodyshops {
                                                    shopname
                                                    id
                                                    region_config
                                                    associations {
                                                      id
                                                      active
                                                    }
                                                  }
                                                }"
            };

            var Data = await Utils.GraphQL.ExecuteQuery(r);
            if (Data != null)
            {
                ShopData = Data.bodyshops.ToObject<ObservableCollection<Bodyshop>>();
            }
            string SettingsSelectedShopUuid = Properties.Settings.Default.LastSelectedShop;
            if (string.IsNullOrEmpty(SettingsSelectedShopUuid))
            {
                ActiveShop = ShopData[0] ?? null;
                Properties.Settings.Default.LastSelectedShop = ShopData[0].Id ?? null;
                Properties.Settings.Default.Save();
            }
            else
            {
                ActiveShop = ShopData.Where(_ => _.Id == SettingsSelectedShopUuid).FirstOrDefault();
            }
        }

        public async Task SetActiveBodyshop()
        {
            IndeterminateLoading = true;
            foreach (var s in ShopData)
            {
                if (s.Id == ActiveShop.Id) s.AssociationActive = true;
                else s.AssociationActive = false;
                var r = new GraphQLRequest
                {
                    Query = @"
                        mutation UPDATE_ASSOCIATION($assocId: uuid, $assocActive: Boolean) {
                            update_associations(where: {id: {_eq: $assocId}}, _set: {active: $assocActive}) {
                                returning {
                                    id
                                    active
                                }
                            }
                        }
            ",
                    Variables = new
                    {
                        assocId = s.AssociationId,
                        assocActive = s.AssociationActive
                    }
                };
                await Utils.GraphQL.ExecuteQuery(r);
            }
            Properties.Settings.Default.LastSelectedShop = ActiveShop.Id;
            Properties.Settings.Default.Save();
            Utils.AppMetaData.ActiveShopId = ActiveShop.Id;
            Utils.AppMetaData.ShopRegion = ActiveShop.RegionConfig;
            IndeterminateLoading = false;
        }

        private FirebaseAuthLink al = BodyshopPartner.Utils.Auth.authlink;
        public async Task TestGql()
        {
            //Notification _n = new Notification()
            //{
            //    Id = 123,
            //    Title = "This is a title",
            //    Subtitle = "Subtitle",
            //    Message = "Somethin"
            //};
            //Growler.AddNotification(_n);

            Console.WriteLine(al.FirebaseToken);
            FirebaseAuthLink t = await al.GetFreshAuthAsync();
            Console.WriteLine(t.FirebaseToken);

            //var r = new GraphQLRequest
            //{
            //    Query = @"query MyQuery($key: String!) {
            //                masterdata(where: {key: {_eq: $key}}) {
            //                value
            //                key
            //                }
            //                }",
            //    Variables = new
            //    {
            //        key = Utils.AppMetaData.ShopRegion + "_ciecaopcodes"
            //    }
            //};
            //var data = await Utils.GraphQL.ExecuteQuery(r);

            ////var t = Newtonsoft.Json.JsonConvert.DeserializeObject<List<dynamic>>(data.masterdata[0].value.Value);
            //Utils.AppMetaData.CiecaOpCodes = JObject.Parse(data.masterdata[0].value.Value);

            //try
            //{
            //    var aa = Utils.AppMetaData.CiecaOpCodes.Property("OP1").Children();
            //    var cc = Utils.AppMetaData.CiecaOpCodes["OP1"]["desc"].Value;
            //    var ab = Utils.AppMetaData.CiecaOpCodes.Property("OP1.desc");

            //}
            //catch (Exception EX)
            //{
            //    logger.Warn("Err");
            //}

        }
    }
}