UiService.cs

//#define PROFILING
 
using IdApp.Cv;
using IdApp.Cv.ColorModels;
using NeuroAccessMaui.Exceptions;
using NeuroAccessMaui.Resources.Languages;
using NeuroAccessMaui.Services.UI.Tasks;
using NeuroAccessMaui.UI.Pages;
using NeuroAccessMaui.UI.Popups;
using SkiaSharp;
using Svg.Skia;
using System.Collections.Concurrent;
using System.Collections.ObjectModel;
using System.Diagnostics;
using System.Diagnostics.CodeAnalysis;
using Waher.Networking.XMPP.StanzaErrors;
using Waher.Events;
using Waher.Runtime.Inventory;
 
#if PROFILING
using Waher.Runtime.Profiling;
#endif
 
namespace NeuroAccessMaui.Services.UI
{
    [Singleton]
    public class UiService : LoadableService, IUiService
    {
        private readonly Dictionary<string, NavigationArgs> navigationArgsMap = [];
        private readonly ConcurrentQueue<UiTask> taskQueue = new();
        private NavigationArgs? latestArguments = null;
        private bool isExecutingUiTasks = false;
        private bool isNavigating = false;
 
        public UiService()
        {
        }
 
        #region UI-tasks
 
        private void AddTask(UiTask Task)
        {
            this.taskQueue.Enqueue(Task);
 
            if (!this.isExecutingUiTasks)
            {
                this.isExecutingUiTasks = true;
 
                MainThread.BeginInvokeOnMainThread(async () =>
                {
                    await this.ProcessAllTasks();
                });
            }
        }
 
        private async Task ProcessAllTasks()
        {
            try
            {
                do
                {
                    if (this.taskQueue.TryDequeue(out UiTask? Task))
                        await Task.Execute();
                }
                while (!this.taskQueue.IsEmpty);
            }
            finally
            {
                this.isExecutingUiTasks = false;
            }
        }
 
        #endregion
 
        #region DisplayAlert
 
        public Task<bool> DisplayAlert(string Title, string Message, string? Accept = null, string? Cancel = null)
        {
            DisplayAlert Task = new(Title, Message, Accept, Cancel);
            this.AddTask(Task);
            return Task.CompletionSource.Task;
        }
 
        public Task DisplayException(Exception Exception, string? Title = null)
        {
            Exception = Log.UnnestException(Exception);
 
            return this.DisplayAlert(
                Title ?? ServiceRef.Localizer[nameof(AppResources.SomethingWentWrong)], GetUserFriendlyMessage(Exception),
                ServiceRef.Localizer[nameof(AppResources.Ok)]);
        }
 
        private static string GetUserFriendlyMessage(Exception? Exception)
        {
            if (Exception is null)
                return ServiceRef.Localizer[nameof(AppResources.ErrorTitle)];
 
            Exception? Current = Exception;
 
            while (Current is not null)
            {
                if (Current is MissingNetworkException)
                    return ServiceRef.Localizer[nameof(AppResources.ThereIsNoNetwork)];
 
                if (Current is TimeoutException)
                    return ServiceRef.Localizer[nameof(AppResources.RequestTimedOut)];
 
                if (Current is TaskCanceledException || Current is OperationCanceledException)
                    return ServiceRef.Localizer[nameof(AppResources.RequestWasCancelled)];
 
                if (Current is RecipientUnavailableException)
                    return ServiceRef.Localizer[nameof(AppResources.ServiceUnavailable)];
 
                if (Current is NotAuthorizedException || Current is UnauthorizedAccessException)
                    return ServiceRef.Localizer[nameof(AppResources.NotAuthorized)];
 
                if (Current is NotAllowedException)
                    return ServiceRef.Localizer[nameof(AppResources.ActionNotAllowed)];
 
                if (Current is InternalServerErrorException)
                    return ServiceRef.Localizer[nameof(AppResources.ServiceUnavailable)];
 
                Current = Current.InnerException;
            }
 
            return ServiceRef.Localizer[nameof(AppResources.SomethingWentWrong)];
        }
 
        #endregion
 
        #region DisplayPrompt
 
        public Task<string?> DisplayPrompt(string Title, string Message, string? Accept = null, string? Cancel = null)
        {
            DisplayPrompt Task = new(Title, Message, Accept, Cancel);
            this.AddTask(Task);
            return Task.CompletionSource.Task;
        }
 
        #endregion
 
        #region Screen shots
 
        public async Task<ImageSource?> TakeBlurredScreenshotAsync()
        {
            try
            {
#if PROFILING
                Profiler Profiler = new("Blur", ProfilerThreadType.Sequential);
 
                Profiler.Start();
                Profiler.NewState("Capture");
#endif
                IScreenshotResult? Screen = await Screenshot.CaptureAsync();
                if (Screen is null)
                    return null;
 
#if PROFILING
                Profiler.NewState("PNG");
#endif
                //Read screenshot
                using Stream PngStream = await Screen.OpenReadAsync(ScreenshotFormat.Png, 20);
 
#if PROFILING
                Profiler.NewState("SKBitmap");
#endif
                // Original SKBitmap from PNG stream
                SKBitmap OriginalBitmap = SKBitmap.FromImage(SKImage.FromEncodedData(PngStream));
 
#if PROFILING
                Profiler.NewState("Scale");
#endif
                // Desired width and height for the downscaled image
                int DesiredWidth = OriginalBitmap.Width / 4;   //Reduce the width by a quarter
                int DesiredHeight = OriginalBitmap.Height / 4; //Reduce the height by a quarter
 
                // Create an SKImageInfo with the desired width, height, and color type of the original
                SKImageInfo ResizedInfo = new(DesiredWidth, DesiredHeight, SKColorType.Gray8);
 
                // Create a new SKBitmap for the downscaled image
                SKBitmap ResizedBitmap = OriginalBitmap.Resize(ResizedInfo, SKFilterQuality.Medium);
 
#if PROFILING
                Profiler.NewState("Prepare");
#endif
                //Blur image
                IMatrix RezisedMatrix = Bitmaps.FromBitmap(ResizedBitmap);
                IMatrix GreyChannelMatrix = RezisedMatrix.GrayScale();
 
#if PROFILING
                Profiler.NewState("Blur 5x5");
#endif
                IMatrix NewMatrix = IdApp.Cv.Transformations.Convolutions.ConvolutionOperations.Blur(GreyChannelMatrix, 5);
 
#if PROFILING
                Profiler.NewState("Blur2");
#endif
                NewMatrix = IdApp.Cv.Transformations.Convolutions.ConvolutionOperations.Blur(NewMatrix, 5);
 
#if PROFILING
                Profiler.NewState("Encode");
#endif
                // Continue with the blurring and encoding to PNG as before
                byte[] Blurred = Bitmaps.EncodeAsPng(NewMatrix);
                ImageSource BlurredScreen = ImageSource.FromStream(() => new MemoryStream(Blurred));
 
#if PROFILING
                Profiler.Stop();
 
                string TimingUml = Profiler.ExportPlantUml(TimeUnit.MilliSeconds);
 
                await App.SendAlert("```uml\r\n" + TimingUml + "\r\n```", "text/markdown");
#endif
                return BlurredScreen;
            }
            catch (Exception ex)
            {
                ServiceRef.LogService.LogException(ex);
                return null;
            }
        }
 
        public async Task<ImageSource?> TakeScreenshotAsync()
        {
            try
            {
                IScreenshotResult? Result = await Screenshot.CaptureAsync();
                if (Result is null)
                    return null;
 
                // Read the stream into a memory stream or byte array
                using Stream Stream = await Result.OpenReadAsync();
                MemoryStream MemoryStream = new();
                await Stream.CopyToAsync(MemoryStream);
                byte[] Bytes = MemoryStream.ToArray();
 
                // Return a new MemoryStream based on the byte array for each invocation
                return ImageSource.FromStream(() => new MemoryStream(Bytes));
            }
            catch (Exception ex)
            {
                ServiceRef.LogService.LogException(ex);
                return null;
            }
        }
 
        #endregion
 
        #region Navigation
 
 
 
        public Page CurrentPage => Shell.Current.CurrentPage;
 
        public override Task Load(bool IsResuming, CancellationToken CancellationToken)
        {
            if (this.BeginLoad(IsResuming, CancellationToken))
            {
                try
                {
                    Application? Application = Application.Current;
 
                    if (Application is not null)
                    {
                        Application.PropertyChanging += this.OnApplicationPropertyChanging;
                        Application.PropertyChanged += this.OnApplicationPropertyChanged;
                    }
 
                    this.SubscribeToShellNavigatingIfNecessary(Application);
 
                    this.EndLoad(true);
                }
                catch (Exception ex)
                {
                    ServiceRef.LogService.LogException(ex);
                    this.EndLoad(false);
                }
            }
 
 
            return Task.CompletedTask;
        }
 
        public override Task Unload()
        {
            if (this.BeginUnload())
            {
                try
                {
                    Application? Application = Application.Current;
                    if (Application is not null)
                    {
                        this.UnsubscribeFromShellNavigatingIfNecessary(Application);
                        Application.PropertyChanged -= this.OnApplicationPropertyChanged;
                        Application.PropertyChanging -= this.OnApplicationPropertyChanging;
                    }
                }
                catch (Exception ex)
                {
                    ServiceRef.LogService.LogException(ex);
                }
 
                this.EndUnload();
            }
 
            return Task.CompletedTask;
        }
 
 
        public Task GoToAsync(string Route, BackMethod BackMethod = BackMethod.Inherited, string? UniqueId = null)
        {
            // No args navigation will create a default navigation arguments
            return this.GoToAsync<NavigationArgs>(Route, null, BackMethod, UniqueId);
        }
 
        public async Task GoToAsync<TArgs>(string Route, TArgs? Args, BackMethod BackMethod = BackMethod.Inherited, string? UniqueId = null) where TArgs : NavigationArgs, new()
        {
            await MainThread.InvokeOnMainThreadAsync(async () =>
            {
                ServiceRef.PlatformSpecific.HideKeyboard();
 
                // Get the parent's navigation arguments
                NavigationArgs? ParentArgs = this.GetCurrentNavigationArgs();
 
                // Create a default navigation arguments if Args are null
                NavigationArgs NavigationArgs = Args ?? new();
 
                NavigationArgs.SetBackArguments(ParentArgs, BackMethod, UniqueId);
                this.PushArgs(Route, NavigationArgs);
 
                if (!string.IsNullOrEmpty(UniqueId))
                    Route += "?UniqueId=" + UniqueId;
 
                try
                {
                    this.isNavigating = true;
                    await Shell.Current.GoToAsync(Route, NavigationArgs.Animated);
                }
                catch (Exception ex)
                {
                    ex = Log.UnnestException(ex);
                    ServiceRef.LogService.LogException(ex);
                    string ExtraInfo = Environment.NewLine + ex.Message;
 
                    await ServiceRef.UiService.DisplayAlert(
                        ServiceRef.Localizer[nameof(AppResources.ErrorTitle)],
                        ServiceRef.Localizer[nameof(AppResources.FailedToNavigateToPage), Route, ExtraInfo]);
                }
                finally
                {
                    this.isNavigating = false;
                    NavigationArgs.NavigationCompletionSource.TrySetResult(true);
                }
            });
        }
 
        public async Task GoBackAsync(bool Animate = true)
        {
            try
            {
                NavigationArgs? NavigationArgs = this.GetCurrentNavigationArgs();
 
                if (NavigationArgs is not null) // the main view?
                {
                    string BackRoute = NavigationArgs.GetBackRoute();
 
                    this.isNavigating = true;
                    await Shell.Current.GoToAsync(BackRoute, Animate);
                }
                else
                {
                    ShellNavigationState State = Shell.Current.CurrentState;
                    if (Uri.TryCreate(State.Location, "..", out Uri? BackLocation))
                        await Shell.Current.GoToAsync(BackLocation);
                    else
                        await Shell.Current.GoToAsync(Constants.Pages.MainPage);
                }
            }
            catch (Exception ex)
            {
                ServiceRef.LogService.LogException(ex);
 
                await ServiceRef.UiService.DisplayAlert(
                    ServiceRef.Localizer[nameof(AppResources.ErrorTitle)],
                    ServiceRef.Localizer[nameof(AppResources.FailedToClosePage)]);
            }
            finally
            {
                this.isNavigating = false;
            }
        }
 
        public TArgs? PopLatestArgs<TArgs>()
            where TArgs : NavigationArgs, new()
        {
            if (this.latestArguments is TArgs Result)
            {
                this.latestArguments = null;
                return Result;
            }
            else
                return null;
        }
 
        public TArgs? TryGetArgs<TArgs>(string? UniqueId = null)
            where TArgs : NavigationArgs, new()
        {
            if (this.TryGetArgs(out TArgs? Result, UniqueId))
                return Result;
            else
                return null;
        }
 
        public bool TryGetArgs<TArgs>([NotNullWhen(true)] out TArgs? Args, string? UniqueId = null)
            where TArgs : NavigationArgs, new()
        {
            NavigationArgs? NavigationArgs = null;
 
            if (this.CurrentPage is Page Page)
            {
                NavigationArgs = this.TryGetArgs(Page.GetType().Name, UniqueId);
                string Route = Routing.GetRoute(Page);
                NavigationArgs ??= this.TryGetArgs(Route, UniqueId);
                /*
                                if ((NavigationArgs is null) && (UniqueId is null) &&
                                    (Page is BaseContentPage BasePage) && (BasePage.UniqueId is not null))
                                {
                                    return this.TryGetArgs(out Args, BasePage.UniqueId);
                                }
                */
            }
 
            if (NavigationArgs is TArgs TArgsArgs)
                Args = TArgsArgs;
            else
                Args = null;
 
            return (Args is not null);
        }
 
        private NavigationArgs? GetCurrentNavigationArgs()
        {
            this.TryGetArgs(out NavigationArgs? Args);
            return Args;
        }
 
        private void OnApplicationPropertyChanged(object? Sender, System.ComponentModel.PropertyChangedEventArgs Args)
        {
            if (Args.PropertyName == nameof(Application.MainPage))
                this.SubscribeToShellNavigatingIfNecessary((Application?)Sender);
        }
 
        private void OnApplicationPropertyChanging(object? Sender, PropertyChangingEventArgs Args)
        {
            if (Args.PropertyName == nameof(Application.MainPage))
                this.UnsubscribeFromShellNavigatingIfNecessary((Application?)Sender);
        }
 
        private void SubscribeToShellNavigatingIfNecessary(Application? Application)
        {
            if (Application?.MainPage is Shell Shell)
                Shell.Navigating += this.Shell_Navigating;
        }
 
        private void UnsubscribeFromShellNavigatingIfNecessary(Application? Application)
        {
            if (Application?.MainPage is Shell Shell)
                Shell.Navigating -= this.Shell_Navigating;
        }
 
        private void Shell_Navigating(object? Sender, ShellNavigatingEventArgs e)
        {
            try
            {
                if ((e.Source == ShellNavigationSource.Pop) && e.CanCancel && !this.isNavigating)
                {
                    e.Cancel();
 
                    MainThread.BeginInvokeOnMainThread(async () =>
                    {
                        await this.GoBackAsync();
                    });
                }
            }
            catch (Exception ex)
            {
                ServiceRef.LogService.LogException(ex);
            }
        }
 
        private static bool TryGetPageName(string Route, [NotNullWhen(true)] out string? PageName)
        {
            PageName = null;
 
            if (!string.IsNullOrWhiteSpace(Route))
            {
                PageName = Route.TrimStart('.', '/');
                return !string.IsNullOrWhiteSpace(PageName);
            }
 
            return false;
        }
 
        private void PushArgs(string Route, NavigationArgs Args)
        {
            this.latestArguments = Args;
 
            if (TryGetPageName(Route, out string? PageName))
            {
                if (Args is not null)
                {
                    string? UniqueId = Args.UniqueId;
 
                    if (!string.IsNullOrEmpty(UniqueId))
                        PageName += "?UniqueId=" + UniqueId;
 
                    this.navigationArgsMap[PageName] = Args;
                }
                else
                    this.navigationArgsMap.Remove(PageName);
            }
        }
 
        private NavigationArgs? TryGetArgs(string Route, string? UniqueId)
        {
            if (!string.IsNullOrEmpty(UniqueId))
                Route += "?UniqueId=" + UniqueId;
 
            if (TryGetPageName(Route, out string? PageName) &&
                this.navigationArgsMap.TryGetValue(PageName, out NavigationArgs? Args))
            {
                return Args;
            }
 
            return null;
        }
 
        #endregion
        #region Image
        public async Task<ImageSource?> ConvertSvgUriToImageSource(string svgUri)
        {
            try
            {
                //Fetch image
                using HttpClient HttpClient = new();
                using HttpResponseMessage Response = await HttpClient.GetAsync(svgUri);
                if (!Response.IsSuccessStatusCode)
                    return null;
 
                // Load SVG image
                byte[] ContentBytes = await Response.Content.ReadAsByteArrayAsync();
                SKSvg Svg = new();
                using (MemoryStream Stream = new(ContentBytes))
                {
                    Svg.Load(Stream);
                }
 
                //Check that the svg was parsed correct
                if (Svg.Picture is null)
                    return null;
 
                using (MemoryStream Stream = new())
                {
                    if (Svg.Picture.ToImage(Stream, SKColor.Parse("#00FFFFFF"), SKEncodedImageFormat.Png, 100, 1, 1, SKColorType.Rgba8888, SKAlphaType.Premul, SKColorSpace.CreateSrgb()))
                        return ImageSource.FromStream(() => new MemoryStream(Stream.ToArray()));
                    return null;
                }
            }
            catch (Exception ex)
            {
                ServiceRef.LogService.LogException(ex);
                return null;
            }
 
        }
        #endregion
    }
}