IntentService.cs

using System.Collections.Concurrent;
using System.Threading.Tasks;
using ExCSS;
using NeuroAccessMaui.Services.Nfc;
using Waher.Events;
using Waher.Runtime.Inventory;
 
namespace NeuroAccessMaui.Services.Intents
{
    [Singleton]
    public class IntentService : IIntentService
    {
        // Thread-safe queue for storing incoming intents. Usually there will always be only one or none intents in the queue.
        // ConcurrentQueue might not be needed, but this is not performance-critical code.
        private ConcurrentQueue<AppIntent> intentQueue = new();
 
        public void QueueIntent(AppIntent intent)
        {
            try
            {
                this.intentQueue.Enqueue(intent);
            }
            catch (Exception Ex)
            {
                ServiceRef.LogService.LogException(Ex);
            }
        }
 
        public async Task ProcessQueuedIntentsAsync()
        {
            try
            {
                while (this.intentQueue.TryDequeue(out AppIntent? Intent))
                {
                    await this.ProcessIntentAsync(Intent);
                }
            }
            catch (Exception Ex)
            {
                ServiceRef.LogService.LogException(Ex);
            }
        }
 
        public async Task ProcessIntentAsync(AppIntent intent)
        {
            try
            {
                switch (intent.Action)
                {
                    case Constants.IntentActions.OpenUrl:
                        if (!string.IsNullOrEmpty(intent.Data))
                        {
                            // Process a url.
                            if (App.Current is not null)
                                await App.Current.InitCompleted;
                            App.OpenUrlSync(intent.Data);
                        }
                        break;
 
                    case Constants.IntentActions.NfcTagDiscovered:
                        if (intent.Payload is NfcTag NfcTag)
                        {
                            // Resolve your shared NFC service and pass the NFC tag.
                            INfcService NfcService = App.Instantiate<INfcService>();
                            await NfcService.TagDetected(NfcTag);
                        }
                        break;
 
                    default:
                        ServiceRef.LogService.LogWarning($"Unhandled intent action: {intent.Action}");
                        break;
                }
            }
            catch (Exception Ex)
            {
                ServiceRef.LogService.LogException(Ex);
            }
        }
 
        public async Task<string?> TryGetAndDequeueOnboardingUrl()
        {
            ConcurrentQueue<AppIntent> newIntents = new();
 
            string? OnboardingUrl = null;
 
            while (this.intentQueue.TryDequeue(out AppIntent? Intent))
            {
                if (Intent.Action == Constants.IntentActions.OpenUrl)
                {
                    if (!string.IsNullOrEmpty(Intent.Data) && string.Equals(Constants.UriSchemes.GetScheme(Intent.Data), Constants.UriSchemes.Onboarding, StringComparison.OrdinalIgnoreCase))
                    {
                        OnboardingUrl = Intent.Data;
                        continue;
                    }
                }
 
                newIntents.Enqueue(Intent);
            }
 
            this.intentQueue = newIntents;
            return OnboardingUrl;
        }
    }
}