ThingRegistryOrchestratorService.cs

using NeuroAccessMaui.Resources.Languages;
using NeuroAccessMaui.Services.Contacts;
using NeuroAccessMaui.Services.UI;
using NeuroAccessMaui.UI.Pages.Things.MyThings;
using NeuroAccessMaui.UI.Pages.Things.ViewClaimThing;
using NeuroAccessMaui.UI.Pages.Things.ViewThing;
using Waher.Networking.XMPP.Contracts;
using Waher.Networking.XMPP.Provisioning;
using Waher.Persistence;
using Waher.Runtime.Inventory;
 
namespace NeuroAccessMaui.Services.ThingRegistries
{
    [Singleton]
    internal class ThingRegistryOrchestratorService : LoadableService, IThingRegistryOrchestratorService
    {
        public ThingRegistryOrchestratorService()
        {
        }
 
        public override Task Load(bool isResuming, CancellationToken cancellationToken)
        {
            if (this.BeginLoad(isResuming, cancellationToken))
                this.EndLoad(true);
 
            return Task.CompletedTask;
        }
 
        public override Task Unload()
        {
            if (this.BeginUnload())
                this.EndUnload();
 
            return Task.CompletedTask;
        }
 
        #region Event Handlers
 
        #endregion
 
        public Task OpenClaimDevice(string Uri)
        {
            MainThread.BeginInvokeOnMainThread(async () =>
            {
                await ServiceRef.UiService.GoToAsync(nameof(ViewClaimThingPage), new ViewClaimThingNavigationArgs(Uri));
            });
 
            return Task.CompletedTask;
        }
 
        public async Task OpenSearchDevices(string Uri)
        {
            try
            {
                (SearchResultThing[] Things, string? RegistryJid) = await ServiceRef.XmppService.SearchAll(Uri);
 
                switch (Things.Length)
                {
                    case 0:
                        await ServiceRef.UiService.DisplayAlert(ServiceRef.Localizer[nameof(AppResources.ErrorTitle)],
                            ServiceRef.Localizer[nameof(AppResources.NoThingsFound)]);
                        break;
 
                    case 1:
                        SearchResultThing Thing = Things[0];
 
                        MainThread.BeginInvokeOnMainThread(async () =>
                        {
                            Property[] Properties = ViewClaimThingViewModel.ToProperties(Thing.Tags);
 
                            ContactInfo ContactInfo = await ContactInfo.FindByBareJid(Thing.Jid, Thing.Node.SourceId, Thing.Node.Partition, Thing.Node.NodeId);
                            ContactInfo ??= new ContactInfo()
                            {
                                AllowSubscriptionFrom = false,
                                BareJid = Thing.Jid,
                                IsThing = true,
                                LegalId = string.Empty,
                                LegalIdentity = null,
                                FriendlyName = ViewClaimThingViewModel.GetFriendlyName(Properties) ?? string.Empty,
                                MetaData = Properties,
                                SourceId = Thing.Node.SourceId,
                                Partition = Thing.Node.Partition,
                                NodeId = Thing.Node.NodeId,
                                Owner = false,
                                RegistryJid = RegistryJid,
                                SubscribeTo = null
                            };
 
                            await ServiceRef.UiService.GoToAsync(nameof(ViewThingPage), new ViewThingNavigationArgs(ContactInfo,
                                MyThingsViewModel.GetNotificationEvents(ContactInfo) ?? []));
                        });
                        break;
 
                    default:
                        throw new NotImplementedException("Multiple devices were returned. Feature not implemented.");
                        // TODO: Search result list view
                }
            }
            catch (Exception ex)
            {
                await ServiceRef.UiService.DisplayException(ex);
            }
        }
 
        public async Task OpenDeviceReference(string Uri)
        {
            try
            {
                if (!ServiceRef.XmppService.TryDecodeIoTDiscoDirectURI(Uri, out string? Jid, out string? SourceId,
                    out string? NodeId, out string? PartitionId, out MetaDataTag[]? Tags))
                {
                    throw new InvalidOperationException("Not a direct reference URI.");
                }
 
                Property[] Properties = ViewClaimThingViewModel.ToProperties(Tags);
                ContactInfo Info = await ContactInfo.FindByBareJid(Jid, SourceId ?? string.Empty,
                    PartitionId ?? string.Empty, NodeId ?? string.Empty);
 
                if (Info is null)
                {
                    Info = new ContactInfo()
                    {
                        AllowSubscriptionFrom = false,
                        BareJid = Jid,
                        IsThing = true,
                        LegalId = string.Empty,
                        LegalIdentity = null,
                        FriendlyName = ViewClaimThingViewModel.GetFriendlyName(Properties) ?? Jid,
                        MetaData = Properties,
                        SourceId = SourceId ?? string.Empty,
                        Partition = PartitionId ?? string.Empty,
                        NodeId = NodeId ?? string.Empty,
                        Owner = false,
                        RegistryJid = ServiceRef.XmppService.RegistryServiceJid,
                        SubscribeTo = null
                    };
 
                    foreach (MetaDataTag Tag in Tags)
                    {
                        if (Tag.Name.Equals("R", StringComparison.OrdinalIgnoreCase))
                            Info.RegistryJid = Tag.StringValue;
                    }
                }
                else if (!(Info.IsThing ?? false))
                {
                    Info.MetaData = Merge(Info.MetaData, Properties);
                    Info.IsThing = true;
 
                    await Database.Update(Info);
                }
 
                ViewThingNavigationArgs Args = new(Info, MyThingsViewModel.GetNotificationEvents(Info) ?? []);
 
                await ServiceRef.UiService.GoToAsync(nameof(ViewThingPage), Args, BackMethod.CurrentPage);
            }
            catch (Exception ex)
            {
                await ServiceRef.UiService.DisplayException(ex);
            }
        }
 
        private static Property[]? Merge(Property[]? Stored, Property[]? FromUri)
        {
            Dictionary<string, Property> Merged = [];
            bool Changed = false;
 
            if (Stored is not null)
            {
                foreach (Property P in Stored)
                    Merged[P.Name] = P;
            }
 
            if (FromUri is not null)
            {
                foreach (Property P in FromUri)
                {
                    if (!Merged.TryGetValue(P.Name, out Property? P2) || P2.Value != P.Value)
                    {
                        Merged[P.Name] = P;
                        Changed = true;
                    }
                }
            }
 
            if (!Changed)
                return Stored;
 
            Property[] Result = new Property[Merged.Count];
            Merged.Values.CopyTo(Result, 0);
 
            return Result;
        }
 
    }
}