CanControlViewModel.cs

using CommunityToolkit.Mvvm.ComponentModel;
using CommunityToolkit.Mvvm.Input;
using NeuroAccessMaui.Resources.Languages;
using NeuroAccessMaui.Services;
using NeuroAccessMaui.Services.Contacts;
using NeuroAccessMaui.Services.Notification;
using NeuroAccessMaui.Services.Notification.Things;
using NeuroAccessMaui.UI.Pages.Things.CanRead;
using NeuroAccessMaui.UI.Pages.Things.IsFriend;
using NeuroAccessMaui.UI.Pages.Things.ViewClaimThing;
using System.Collections.ObjectModel;
using System.ComponentModel;
using Waher.Networking.XMPP;
using Waher.Networking.XMPP.Contracts;
using Waher.Networking.XMPP.Provisioning;
using Waher.Persistence;
using Waher.Things;
 
namespace NeuroAccessMaui.UI.Pages.Things.CanControl
{
    public partial class CanControlViewModel : XmppViewModel
    {
        private readonly NotificationEvent? @event;
        private readonly CanControlNavigationArgs? navigationArguments;
 
        public CanControlViewModel(CanControlNavigationArgs? Args)
            : base()
        {
            this.navigationArguments = Args;
 
            this.Tags = [];
            this.CallerTags = [];
            this.Parameters = [];
            this.RuleRanges = [];
 
            if (Args is not null)
            {
                this.@event = Args.Event;
                this.BareJid = Args.BareJid;
                this.FriendlyName = Args.FriendlyName;
                this.RemoteJid = Args.RemoteJid;
                this.RemoteFriendlyName = Args.RemoteFriendlyName;
                this.Key = Args.Key;
                this.ProvisioningService = Args.ProvisioningService;
                this.NodeId = Args.NodeId;
                this.SourceId = Args.SourceId;
                this.PartitionId = Args.PartitionId;
 
                if (this.FriendlyName == this.BareJid)
                    this.FriendlyName = ServiceRef.Localizer[nameof(AppResources.NotAvailable)];
 
                this.RemoteFriendlyNameAvailable = this.RemoteFriendlyName != this.RemoteJid;
                if (!this.RemoteFriendlyNameAvailable)
                    this.RemoteFriendlyName = ServiceRef.Localizer[nameof(AppResources.NotAvailable)];
            }
        }
 
        protected override async Task OnInitialize()
        {
            await base.OnInitialize();
 
            if (this.navigationArguments is not null)
            {
                this.Tags.Clear();
                this.CallerTags.Clear();
 
                ContactInfo Thing = await ContactInfo.FindByBareJid(this.BareJid ?? string.Empty);
                if (Thing?.MetaData is not null)
                {
                    foreach (Property Tag in Thing.MetaData)
                        this.Tags.Add(new HumanReadableTag(Tag));
                }
 
                ContactInfo Caller = await ContactInfo.FindByBareJid(this.RemoteJid ?? string.Empty);
                this.CallerInContactsList = Caller is not null;
                if (Caller?.MetaData is not null)
                {
                    foreach (Property Tag in Caller.MetaData)
                        this.CallerTags.Add(new HumanReadableTag(Tag));
                }
 
                if (this.navigationArguments.UserTokens is not null && this.navigationArguments.UserTokens.Length > 0)
                {
                    foreach (ProvisioningToken Token in this.navigationArguments.UserTokens)
                        this.CallerTags.Add(new HumanReadableTag(new Property(ServiceRef.Localizer[nameof(AppResources.User)], Token.FriendlyName ?? Token.Token)));
 
                    this.HasUser = true;
                }
 
                if (this.navigationArguments.ServiceTokens is not null && this.navigationArguments.ServiceTokens.Length > 0)
                {
                    foreach (ProvisioningToken Token in this.navigationArguments.ServiceTokens)
                        this.CallerTags.Add(new HumanReadableTag(new Property(ServiceRef.Localizer[nameof(AppResources.Service)], Token.FriendlyName ?? Token.Token)));
 
                    this.HasService = true;
                }
 
                if (this.navigationArguments.DeviceTokens is not null && this.navigationArguments.DeviceTokens.Length > 0)
                {
                    foreach (ProvisioningToken Token in this.navigationArguments.DeviceTokens)
                        this.CallerTags.Add(new HumanReadableTag(new Property(ServiceRef.Localizer[nameof(AppResources.Device)], Token.FriendlyName ?? Token.Token)));
 
                    this.HasDevice = true;
                }
 
                this.Parameters.Clear();
 
                SortedDictionary<string, bool> PermittedParameters = [];
                string[]? AllParameters = this.navigationArguments.AllParameters;
 
                if (AllParameters is null && !string.IsNullOrEmpty(this.BareJid))
                {
                    AllParameters = await CanControlNotificationEvent.GetAvailableParameterNames(this.BareJid,
                        new ThingReference(this.NodeId, this.SourceId, this.PartitionId));
 
                    if (AllParameters is not null && this.navigationArguments?.Event is not null)
                    {
                        this.navigationArguments.Event.AllParameters = AllParameters;
                        await Database.Update(this.navigationArguments.Event);
                    }
                }
 
                bool AllParametersPermitted = this.navigationArguments?.Parameters is null;
 
                if (AllParameters is not null)
                {
                    foreach (string Parameter in AllParameters)
                        PermittedParameters[Parameter] = AllParametersPermitted;
                }
 
                if (!AllParametersPermitted && this.navigationArguments?.Parameters is not null)
                {
                    foreach (string Parameter in this.navigationArguments.Parameters)
                        PermittedParameters[Parameter] = true;
                }
 
                foreach (KeyValuePair<string, bool> P in PermittedParameters)
                {
                    FieldReference Parameter = new(P.Key, P.Value);
                    this.Parameters.Add(Parameter);
                }
 
                this.RuleRanges.Clear();
                this.RuleRanges.Add(new RuleRangeModel(RuleRange.Caller, ServiceRef.Localizer[nameof(AppResources.CallerOnly)]));
 
                if (this.HasUser)
                    this.RuleRanges.Add(new RuleRangeModel("User", ServiceRef.Localizer[nameof(AppResources.ToUser)]));
 
                if (this.HasUser)
                    this.RuleRanges.Add(new RuleRangeModel("Service", ServiceRef.Localizer[nameof(AppResources.ToService)]));
 
                if (this.HasUser)
                    this.RuleRanges.Add(new RuleRangeModel("Device", ServiceRef.Localizer[nameof(AppResources.ToDevice)]));
 
                this.RuleRanges.Add(new RuleRangeModel(RuleRange.Domain, ServiceRef.Localizer[nameof(AppResources.EntireDomain), XmppClient.GetDomain(this.RemoteJid)]));
                this.RuleRanges.Add(new RuleRangeModel(RuleRange.All, ServiceRef.Localizer[nameof(AppResources.Everyone)]));
 
                this.SelectedRuleRangeIndex = 0;
            }
        }
 
        #region Properties
 
        public ObservableCollection<HumanReadableTag> Tags { get; }
 
        public ObservableCollection<HumanReadableTag> CallerTags { get; }
 
        public ObservableCollection<FieldReference> Parameters { get; }
 
        public ObservableCollection<RuleRangeModel> RuleRanges { get; }
 
        [ObservableProperty]
        private string? bareJid;
 
        [ObservableProperty]
        private string? friendlyName;
 
        [ObservableProperty]
        private string? remoteJid;
 
 
        [ObservableProperty]
        private string? remoteFriendlyName;
 
        [ObservableProperty]
        private bool remoteFriendlyNameAvailable;
 
        [ObservableProperty]
        private string? key;
 
        [ObservableProperty]
        private bool hasUser;
 
        [ObservableProperty]
        private bool hasService;
 
        [ObservableProperty]
        private bool hasDevice;
 
        [ObservableProperty]
        private string? provisioningService;
 
        [ObservableProperty]
        private bool callerInContactsList;
 
        [ObservableProperty]
        private int selectedRuleRangeIndex;
 
        [ObservableProperty]
        private string? nodeId;
 
        [ObservableProperty]
        private string? sourceId;
 
        [ObservableProperty]
        private string? partitionId;
 
        #endregion
 
        [RelayCommand]
        private static Task Click(object obj)
        {
            if (obj is HumanReadableTag Tag)
                return ViewClaimThingViewModel.LabelClicked(Tag.Name, Tag.Value, Tag.LocalizedValue);
            else if (obj is string s)
                return ViewClaimThingViewModel.LabelClicked(string.Empty, s, s);
            else
                return Task.CompletedTask;
        }
 
        [RelayCommand]
        private async Task AddContact()
        {
            if (!this.CallerInContactsList)
            {
                ContactInfo Info = new()
                {
                    BareJid = this.RemoteJid,
                    FriendlyName = (this.RemoteFriendlyNameAvailable ? this.RemoteFriendlyName : this.RemoteJid) ?? string.Empty
                };
 
                await Database.Insert(Info);
 
                this.CallerInContactsList = true;
            }
        }
 
        [RelayCommand]
        private async Task RemoveContact()
        {
            if (this.CallerInContactsList && !string.IsNullOrEmpty(this.RemoteJid))
            {
                ContactInfo Info = await ContactInfo.FindByBareJid(this.RemoteJid);
                if (Info is not null)
                    await Database.Delete(Info);
 
                this.CallerInContactsList = false;
            }
        }
 
        [RelayCommand(CanExecute = nameof(CanExecuteAccept))]
        private void Accept()
        {
            this.Respond(true);
        }
 
        protected override void OnPropertyChanged(PropertyChangedEventArgs e)
        {
            base.OnPropertyChanged(e);
 
            switch (e.PropertyName)
            {
                case nameof(this.IsConnected):
                    this.AcceptCommand.NotifyCanExecuteChanged();
                    break;
            }
        }
 
        private bool CanExecuteAccept()
        {
            if (!this.IsConnected)
                return false;
 
            foreach (FieldReference Parameter in this.Parameters)
            {
                if (Parameter.Permitted)
                    return true;
            }
 
            return false;
        }
 
        [RelayCommand(CanExecute = nameof(IsConnected))]
        private void Reject()
        {
            this.Respond(false);
        }
 
        private void Respond(bool Accepts)
        {
            if (this.SelectedRuleRangeIndex >= 0)
            {
                RuleRangeModel Range = this.RuleRanges[this.SelectedRuleRangeIndex];
                ThingReference Thing = new(this.NodeId, this.SourceId, this.PartitionId);
 
                if (Range.RuleRange is RuleRange RuleRange)
                {
                    ControlRequestResolver Resolver = new(this.BareJid!, this.RemoteFriendlyName ?? string.Empty, RuleRange);
 
                    switch (RuleRange)
                    {
                        case RuleRange.Caller:
                        default:
                            ServiceRef.XmppService.CanControlResponseCaller(this.ProvisioningService ?? ServiceRef.TagProfile.ProvisioningJid ?? string.Empty,
                                this.BareJid!, this.RemoteJid!, this.Key!, Accepts, this.GetParameters(), Thing, this.ResponseHandler, Resolver);
                            break;
 
                        case RuleRange.Domain:
                            ServiceRef.XmppService.CanControlResponseDomain(this.ProvisioningService ?? ServiceRef.TagProfile.ProvisioningJid ?? string.Empty,
                                this.BareJid!, this.RemoteJid!, this.Key!, Accepts, this.GetParameters(), Thing, this.ResponseHandler, Resolver);
                            break;
 
                        case RuleRange.All:
                            ServiceRef.XmppService.CanControlResponseAll(this.ProvisioningService ?? ServiceRef.TagProfile.ProvisioningJid ?? string.Empty,
                                this.BareJid!, this.RemoteJid!, this.Key!, Accepts, this.GetParameters(), Thing, this.ResponseHandler, Resolver);
                            break;
 
                    }
                }
                else if (Range.RuleRange is ProvisioningToken Token)
                {
                    ControlRequestResolver Resolver = new(this.BareJid!, this.RemoteFriendlyName ?? string.Empty, Token);
 
                    switch (Token.Type)
                    {
                        case TokenType.User:
                            ServiceRef.XmppService.CanControlResponseUser(this.ProvisioningService ?? ServiceRef.TagProfile.ProvisioningJid ?? string.Empty,
                                this.BareJid!, this.RemoteJid!, this.Key!, Accepts, this.GetParameters(), Token.Token, Thing, this.ResponseHandler, Resolver);
                            break;
 
                        case TokenType.Service:
                            ServiceRef.XmppService.CanControlResponseService(this.ProvisioningService ?? ServiceRef.TagProfile.ProvisioningJid ?? string.Empty,
                                this.BareJid!, this.RemoteJid!, this.Key!, Accepts, this.GetParameters(), Token.Token, Thing, this.ResponseHandler, Resolver);
                            break;
 
                        case TokenType.Device:
                            ServiceRef.XmppService.CanControlResponseDevice(this.ProvisioningService ?? ServiceRef.TagProfile.ProvisioningJid ?? string.Empty,
                                this.BareJid!, this.RemoteJid!, this.Key!, Accepts, this.GetParameters(), Token.Token, Thing, this.ResponseHandler, Resolver);
                            break;
                    }
                }
            }
        }
 
        private string[]? GetParameters()
        {
            List<string> Result = [];
            bool AllPermitted = true;
 
            foreach (FieldReference Parameter in this.Parameters)
            {
                if (Parameter.Permitted)
                    Result.Add(Parameter.Name);
                else
                    AllPermitted = false;
            }
 
            if (AllPermitted)
                return null;
            else
                return [.. Result];
        }
 
        private async Task ResponseHandler(object? Sender, IqResultEventArgs e)
        {
            if (e.Ok)
            {
                if (this.@event is not null)
                    await ServiceRef.NotificationService.DeleteEvents(this.@event);
 
                await ServiceRef.NotificationService.DeleteResolvedEvents((IEventResolver)e.State);
 
                MainThread.BeginInvokeOnMainThread(async () =>
                {
                    await this.GoBack();
                });
            }
            else
            {
                MainThread.BeginInvokeOnMainThread(async () => await ServiceRef.UiService.DisplayException(e.StanzaError ??
                    new Exception(ServiceRef.Localizer[nameof(AppResources.UnableToRespond)])));
            }
        }
 
        [RelayCommand]
        private async Task Ignore()
        {
            if (this.@event is not null)
                await ServiceRef.NotificationService.DeleteEvents(this.@event);
 
            await this.GoBack();
        }
 
        [RelayCommand]
        private void AllParameters()
        {
            foreach (FieldReference Parameter in this.Parameters)
                Parameter.Permitted = true;
        }
 
        [RelayCommand]
        private void NoParameters()
        {
            foreach (FieldReference Parameter in this.Parameters)
                Parameter.Permitted = false;
        }
 
    }
}