PushNotificationService.cs

using EDaler;
using NeuroAccessMaui.Resources.Languages;
using NeuroFeatures;
using System.Text;
using Waher.Content;
using Waher.Networking.XMPP;
using Waher.Networking.XMPP.Contracts;
using Waher.Networking.XMPP.Provisioning;
using Waher.Networking.XMPP.Push;
using Waher.Runtime.Inventory;
using Waher.Runtime.Settings;
 
namespace NeuroAccessMaui.Services.Push
{
    [Singleton]
    public class PushNotificationService : LoadableService, IPushNotificationService
    {
        private readonly Dictionary<PushMessagingService, string> tokens = [];
        private DateTime lastTokenCheck = DateTime.MinValue;
 
        public PushNotificationService()
        {
        }
 
        public async Task NewToken(TokenInformation TokenInformation)
        {
            if (!string.IsNullOrEmpty(TokenInformation.Token))
            {
                lock (this.tokens)
                {
                    this.tokens[TokenInformation.Service] = TokenInformation.Token;
                }
 
                await ServiceRef.XmppService.NewPushNotificationToken(TokenInformation);
 
                try
                {
                    this.OnNewToken?.Invoke(this, new TokenEventArgs(TokenInformation.Service, TokenInformation.Token, TokenInformation.ClientType));
                }
                catch (Exception ex)
                {
                    ServiceRef.LogService.LogException(ex);
                }
            }
        }
 
        public event TokenEventHandler? OnNewToken;
 
        public bool TryGetToken(PushMessagingService Source, out string? Token)
        {
            lock (this.tokens)
            {
                return this.tokens.TryGetValue(Source, out Token);
            }
        }
 
        private static async Task<bool> ForceTokenReport(TokenInformation TokenInformation)
        {
            string OldToken = await RuntimeSettings.GetAsync(Constants.Settings.PushNotificationToken, string.Empty);
            DateTime ReportDate = await RuntimeSettings.GetAsync(Constants.Settings.PushNotificationReportDate, DateTime.MinValue);
 
            return (DateTime.UtcNow.Subtract(ReportDate).TotalDays > 7) || (TokenInformation.Token != OldToken);
        }
 
        public async Task CheckPushNotificationToken(TokenInformation? TokenInformation)
        {
            try
            {
                DateTime Now = DateTime.Now;
 
                if (ServiceRef.XmppService.IsOnline &&
                    ServiceRef.XmppService.SupportsPushNotification &&
                    Now.Subtract(this.lastTokenCheck).TotalHours >= 1)
                {
                    this.lastTokenCheck = Now;
 
                    if (TokenInformation is null)
                    {
                        TokenInformation = await ServiceRef.PlatformSpecific.GetPushNotificationToken();
                        if (string.IsNullOrEmpty(TokenInformation.Token))
                            return;
                    }
 
                    bool ForceReport = await ForceTokenReport(TokenInformation);
 
                    string Version = AppInfo.VersionString + "." + AppInfo.BuildString;
                    string PrevVersion = await RuntimeSettings.GetAsync(Constants.Settings.PushNotificationConfigurationVersion, string.Empty);
                    bool IsVersionChanged = Version != PrevVersion;
 
                    if (IsVersionChanged || ForceReport)
                    {
                        string? Token = TokenInformation.Token;
 
                        if (!string.IsNullOrEmpty(Token))
                        {
                            PushMessagingService Service = TokenInformation.Service;
                            ClientType ClientType = TokenInformation.ClientType;
                            await ServiceRef.XmppService.ReportNewPushNotificationToken(Token, Service, ClientType);
 
                            await RuntimeSettings.SetAsync(Constants.Settings.PushNotificationToken, TokenInformation.Token);
                            await RuntimeSettings.SetAsync(Constants.Settings.PushNotificationReportDate, DateTime.UtcNow);
                        }
                    }
 
                    if (IsVersionChanged)
                    {
                        // it will force the rules update if somehing goes wrong.
                        await RuntimeSettings.SetAsync(Constants.Settings.PushNotificationConfigurationVersion, string.Empty);
                        await ServiceRef.XmppService.ClearPushNotificationRules();
 
                        #region Message Rules
 
                        // Push Notification Rule, for chat messages received when offline:
 
                        StringBuilder Content = new();
 
                        Content.Append("FromJid:=GetAttribute(Stanza,'from');");
                        Content.Append("ToJid:=GetAttribute(Stanza,'to');");
                        Content.Append("FriendlyName:=RosterName(ToJid,FromJid);");
                        Content.Append("Content:=GetElement(Stanza,'content');");
                        Content.Append("{'myTitle':'");
                        Content.Append(JSON.Encode(ServiceRef.Localizer[nameof(AppResources.MessageFrom)]));
                        Content.Append(" ' + FriendlyName,");
                        Content.Append("'myBody':InnerText(GetElement(Stanza,'body')),");
                        Content.Append("'fromJid':FromJid,");
                        Content.Append("'rosterName':FriendlyName,");
                        //Content.Append("'isObject':false,");
                        Content.Append("'isObject':exists(Content) and !empty(Markdown:= InnerText(Content)) and (Left(Markdown,2)='![' or (Left(Markdown,3)='```' and Right(Markdown,3)='```')),");
                        Content.Append("'channelId':'");
                        Content.Append(Constants.PushChannels.Messages);
                        Content.Append("',");
                        Content.Append("'content_available':true}");
 
                        await ServiceRef.XmppService.AddPushNotificationRule(MessageType.Chat, string.Empty, string.Empty,
                            Constants.PushChannels.Messages, "Stanza", string.Empty, Content.ToString());
 
                        #endregion
 
                        #region Petitions
 
                        // Push Notification Rule, for Identity Petition requests when offline.
 
                        Content.Clear();
                        Content.Append("E:=GetElement(Stanza,'petitionIdentityMsg');");
                        Content.Append("ToJid:=GetAttribute(Stanza,'to');");
                        Content.Append("FromJid:=GetAttribute(E,'from');");
                        Content.Append("FriendlyName:=RosterName(ToJid,FromJid);");
                        Content.Append("{'myTitle':'");
                        Content.Append(JSON.Encode(ServiceRef.Localizer[nameof(AppResources.PetitionFrom)]));
                        Content.Append(" ' + FriendlyName,");
                        Content.Append("'myBody':GetAttribute(E,'purpose'),");
                        Content.Append("'fromJid':FromJid,");
                        Content.Append("'rosterName':FriendlyName,");
                        Content.Append("'channelId':'");
                        Content.Append(Constants.PushChannels.Petitions);
                        Content.Append("',");
                        Content.Append("'content_available':true}");
 
                        await ServiceRef.XmppService.AddPushNotificationRule(MessageType.Normal, "petitionIdentityMsg", ContractsClient.NamespaceLegalIdentitiesCurrent,
                            Constants.PushChannels.Petitions, "Stanza", string.Empty, Content.ToString());
 
                        // Push Notification Rule, for Contract Petition requests when offline.
 
                        Content.Clear();
                        Content.Append("E:=GetElement(Stanza,'petitionContractMsg');");
                        Content.Append("ToJid:=GetAttribute(Stanza,'to');");
                        Content.Append("FromJid:=GetAttribute(E,'from');");
                        Content.Append("FriendlyName:=RosterName(ToJid,FromJid);");
                        Content.Append("{'myTitle':'");
                        Content.Append(JSON.Encode(ServiceRef.Localizer[nameof(AppResources.PetitionFrom)]));
                        Content.Append(" ' + FriendlyName,");
                        Content.Append("'myBody':GetAttribute(E,'purpose'),");
                        Content.Append("'fromJid':FromJid,");
                        Content.Append("'rosterName':FriendlyName,");
                        Content.Append("'channelId':'");
                        Content.Append(Constants.PushChannels.Petitions);
                        Content.Append("',");
                        Content.Append("'content_available':true}");
 
                        await ServiceRef.XmppService.AddPushNotificationRule(MessageType.Normal, "petitionContractMsg", ContractsClient.NamespaceSmartContractsCurrent,
                            Constants.PushChannels.Petitions, "Stanza", string.Empty, Content.ToString());
 
                        // Push Notification Rule, for Signature Petition requests when offline.
 
                        Content.Clear();
                        Content.Append("E:=GetElement(Stanza,'petitionSignatureMsg');");
                        Content.Append("ToJid:=GetAttribute(Stanza,'to');");
                        Content.Append("FromJid:=GetAttribute(E,'from');");
                        Content.Append("FriendlyName:=RosterName(ToJid,FromJid);");
                        Content.Append("{'myTitle':'");
                        Content.Append(JSON.Encode(ServiceRef.Localizer[nameof(AppResources.PetitionFrom)]));
                        Content.Append(" ' + FriendlyName,");
                        Content.Append("'myBody':GetAttribute(E,'purpose'),");
                        Content.Append("'fromJid':FromJid,");
                        Content.Append("'rosterName':FriendlyName,");
                        Content.Append("'channelId':'");
                        Content.Append(Constants.PushChannels.Petitions);
                        Content.Append("',");
                        Content.Append("'content_available':true}");
 
                        await ServiceRef.XmppService.AddPushNotificationRule(MessageType.Normal, "petitionSignatureMsg", ContractsClient.NamespaceLegalIdentitiesCurrent,
                            Constants.PushChannels.Petitions, "Stanza", string.Empty, Content.ToString());
 
                        #endregion
 
                        #region Identities
 
                        // Push Notification Rule, for Identity Update events when offline.
 
                        Content.Clear();
                        Content.Append("E:=GetElement(Stanza,'identity');");
                        Content.Append("{'myTitle':'");
                        Content.Append(JSON.Encode(ServiceRef.Localizer[nameof(AppResources.IdentityUpdated)]));
                        Content.Append("',");
                        Content.Append("'legalId':GetAttribute(E,'id'),");
                        Content.Append("'channelId':'");
                        Content.Append(Constants.PushChannels.Identities);
                        Content.Append("',");
                        Content.Append("'content_available':true}");
 
                        await ServiceRef.XmppService.AddPushNotificationRule(MessageType.Normal, "identity", ContractsClient.NamespaceLegalIdentitiesCurrent,
                            Constants.PushChannels.Identities, "Stanza", string.Empty, Content.ToString());
 
                        #endregion
 
                        #region Contracts
 
                        // Push Notification Rule, for Contract Creation events when offline.
 
                        Content.Clear();
                        Content.Append("E:=GetElement(Stanza,'contractCreated');");
                        Content.Append("{'myTitle':'");
                        Content.Append(JSON.Encode(ServiceRef.Localizer[nameof(AppResources.ContractCreated)]));
                        Content.Append("',");
                        Content.Append("'contractId':GetAttribute(E,'contractId'),");
                        Content.Append("'channelId':'");
                        Content.Append(Constants.PushChannels.Contracts);
                        Content.Append("',");
                        Content.Append("'content_available':true}");
 
                        await ServiceRef.XmppService.AddPushNotificationRule(MessageType.Normal, "contractCreated", ContractsClient.NamespaceSmartContractsCurrent,
                            Constants.PushChannels.Contracts, "Stanza", string.Empty, Content.ToString());
 
                        // Push Notification Rule, for Contract Signature events when offline.
 
                        Content.Clear();
                        Content.Append("E:=GetElement(Stanza,'contractSigned');");
                        Content.Append("{'myTitle':'");
                        Content.Append(JSON.Encode(ServiceRef.Localizer[nameof(AppResources.ContractSigned)]));
                        Content.Append("',");
                        Content.Append("'contractId':GetAttribute(E,'contractId'),");
                        Content.Append("'legalId':GetAttribute(E,'legalId'),");
                        Content.Append("'channelId':'");
                        Content.Append(Constants.PushChannels.Contracts);
                        Content.Append("',");
                        Content.Append("'content_available':true}");
 
                        await ServiceRef.XmppService.AddPushNotificationRule(MessageType.Normal, "contractSigned", ContractsClient.NamespaceSmartContractsCurrent,
                            Constants.PushChannels.Contracts, "Stanza", string.Empty, Content.ToString());
 
                        // Push Notification Rule, for Contract Update events when offline.
 
                        Content.Clear();
                        Content.Append("E:=GetElement(Stanza,'contractUpdated');");
                        Content.Append("{'myTitle':'");
                        Content.Append(JSON.Encode(ServiceRef.Localizer[nameof(AppResources.ContractUpdated)]));
                        Content.Append("',");
                        Content.Append("'contractId':GetAttribute(E,'contractId'),");
                        Content.Append("'channelId':'");
                        Content.Append(Constants.PushChannels.Contracts);
                        Content.Append("',");
                        Content.Append("'content_available':true}");
 
                        await ServiceRef.XmppService.AddPushNotificationRule(MessageType.Normal, "contractUpdated", ContractsClient.NamespaceSmartContractsCurrent,
                            Constants.PushChannels.Contracts, "Stanza", string.Empty, Content.ToString());
 
                        // Push Notification Rule, for Contract Deletion events when offline.
 
                        Content.Clear();
                        Content.Append("E:=GetElement(Stanza,'contractDeleted');");
                        Content.Append("{'myTitle':'");
                        Content.Append(JSON.Encode(ServiceRef.Localizer[nameof(AppResources.ContractDeleted)]));
                        Content.Append("',");
                        Content.Append("'contractId':GetAttribute(E,'contractId'),");
                        Content.Append("'channelId':'");
                        Content.Append(Constants.PushChannels.Contracts);
                        Content.Append("',");
                        Content.Append("'content_available':true}");
 
                        await ServiceRef.XmppService.AddPushNotificationRule(MessageType.Normal, "contractDeleted", ContractsClient.NamespaceSmartContractsCurrent,
                            Constants.PushChannels.Contracts, "Stanza", string.Empty, Content.ToString());
 
                        // Push Notification Rule, for Contract Proposal events when offline.
 
                        Content.Clear();
                        Content.Append("E:=GetElement(Stanza,'contractProposal');");
                        Content.Append("{'myTitle':'");
                        Content.Append(JSON.Encode(ServiceRef.Localizer[nameof(AppResources.ContractProposed)]));
                        Content.Append("',");
                        Content.Append("'myBody':GetAttribute(E,'message'),");
                        Content.Append("'contractId':Num(GetAttribute(E,'contractId')),");
                        Content.Append("'role':Num(GetAttribute(E,'role')),");
                        Content.Append("'channelId':'");
                        Content.Append(Constants.PushChannels.Contracts);
                        Content.Append("',");
                        Content.Append("'content_available':true}");
 
                        await ServiceRef.XmppService.AddPushNotificationRule(MessageType.Normal, "contractProposal", ContractsClient.NamespaceSmartContractsCurrent,
                            Constants.PushChannels.Contracts, "Stanza", string.Empty, Content.ToString());
 
                        #endregion
 
                        #region eDaler
 
                        // Push Notification Rule, for eDaler balance updates when offline.
 
                        Content.Clear();
                        Content.Append("E:=GetElement(Stanza,'balance');");
                        Content.Append("{'myTitle':'");
                        Content.Append(JSON.Encode(ServiceRef.Localizer[nameof(AppResources.BalanceUpdated)]));
                        Content.Append("',");
                        Content.Append("'amount':Num(GetAttribute(E,'amount')),");
                        Content.Append("'currency':GetAttribute(E,'currency'),");
                        Content.Append("'timestamp':DateTime(GetAttribute(E,'timestamp')),");
                        Content.Append("'channelId':'");
                        Content.Append(Constants.PushChannels.EDaler);
                        Content.Append("',");
                        Content.Append("'content_available':true}");
 
                        await ServiceRef.XmppService.AddPushNotificationRule(MessageType.Normal, "balance", EDalerClient.NamespaceEDaler,
                            Constants.PushChannels.EDaler, "Stanza", string.Empty, Content.ToString());
 
                        #endregion
 
                        #region Neuro-Features
 
                        // Push Notification Rule, for token additions when offline.
 
                        Content.Clear();
                        Content.Append("E:=GetElement(Stanza,'tokenAdded');");
                        Content.Append("E2:=GetElement(E,'token');");
                        Content.Append("{'myTitle':'");
                        Content.Append(JSON.Encode(ServiceRef.Localizer[nameof(AppResources.TokenAdded)]));
                        Content.Append("',");
                        Content.Append("'myBody':GetAttribute(E2,'friendlyName'),");
                        Content.Append("'value':Num(GetAttribute(E2,'value')),");
                        Content.Append("'currency':GetAttribute(E2,'currency'),");
                        Content.Append("'channelId':'");
                        Content.Append(Constants.PushChannels.Tokens);
                        Content.Append("',");
                        Content.Append("'content_available':true}");
 
                        await ServiceRef.XmppService.AddPushNotificationRule(MessageType.Normal, "tokenAdded", NeuroFeaturesClient.NamespaceNeuroFeatures,
                            Constants.PushChannels.Tokens, "Stanza", string.Empty, Content.ToString());
 
                        // Push Notification Rule, for token removals when offline.
 
                        Content.Clear();
                        Content.Append("E:=GetElement(Stanza,'tokenRemoved');");
                        Content.Append("E2:=GetElement(E,'token');");
                        Content.Append("{'myTitle':'");
                        Content.Append(JSON.Encode(ServiceRef.Localizer[nameof(AppResources.TokenRemoved)]));
                        Content.Append("',");
                        Content.Append("'myBody':GetAttribute(E2,'friendlyName'),");
                        Content.Append("'value':Num(GetAttribute(E2,'value')),");
                        Content.Append("'currency':GetAttribute(E2,'currency'),");
                        Content.Append("'channelId':'");
                        Content.Append(Constants.PushChannels.Tokens);
                        Content.Append("',");
                        Content.Append("'content_available':true}");
 
                        await ServiceRef.XmppService.AddPushNotificationRule(MessageType.Normal, "tokenRemoved", NeuroFeaturesClient.NamespaceNeuroFeatures,
                            Constants.PushChannels.Tokens, "Stanza", string.Empty, Content.ToString());
 
                        #endregion
 
                        #region Provisioning
 
                        // Push Notification Rule, for friendship requests from things when offline.
 
                        Content.Clear();
                        Content.Append("ToJid:=GetAttribute(Stanza,'to');");
                        Content.Append("E:=GetElement(Stanza,'isFriend');");
                        Content.Append("RemoteJid:=GetAttribute(E,'remoteJid');");
                        Content.Append("{'myTitle':'");
                        Content.Append(JSON.Encode(ServiceRef.Localizer[nameof(AppResources.AccessRequest)]));
                        Content.Append("',");
                        Content.Append("'myBody':RosterName(ToJid,RemoteJid),");
                        Content.Append("'remoteJid':RemoteJid,");
                        Content.Append("'jid':GetAttribute(E,'jid'),");
                        Content.Append("'key':GetAttribute(E,'key'),");
                        Content.Append("'q':'isFriend',");
                        Content.Append("'channelId':'");
                        Content.Append(Constants.PushChannels.Provisioning);
                        Content.Append("',");
                        Content.Append("'content_available':true}");
 
                        await ServiceRef.XmppService.AddPushNotificationRule(MessageType.Normal, "isFriend", ProvisioningClient.NamespaceProvisioningOwnerCurrent,
                            Constants.PushChannels.Provisioning, "Stanza", string.Empty, Content.ToString());
 
                        // Push Notification Rule, for readout requests from things when offline.
 
                        Content.Clear();
                        Content.Append("ToJid:=GetAttribute(Stanza,'to');");
                        Content.Append("E:=GetElement(Stanza,'canRead');");
                        Content.Append("RemoteJid:=GetAttribute(E,'remoteJid');");
                        Content.Append("{'myTitle':'");
                        Content.Append(JSON.Encode(ServiceRef.Localizer[nameof(AppResources.ReadRequest)]));
                        Content.Append("',");
                        Content.Append("'myBody':RosterName(ToJid,RemoteJid),");
                        Content.Append("'remoteJid':RemoteJid,");
                        Content.Append("'jid':GetAttribute(E,'jid'),");
                        Content.Append("'key':GetAttribute(E,'key'),");
                        Content.Append("'q':'canRead',");
                        Content.Append("'channelId':'");
                        Content.Append(Constants.PushChannels.Provisioning);
                        Content.Append("',");
                        Content.Append("'content_available':true}");
 
                        await ServiceRef.XmppService.AddPushNotificationRule(MessageType.Normal, "canRead", ProvisioningClient.NamespaceProvisioningOwnerCurrent,
                            Constants.PushChannels.Provisioning, "Stanza", string.Empty, Content.ToString());
 
                        // Push Notification Rule, for control requests from things when offline.
 
                        Content.Clear();
                        Content.Append("ToJid:=GetAttribute(Stanza,'to');");
                        Content.Append("E:=GetElement(Stanza,'canControl');");
                        Content.Append("RemoteJid:=GetAttribute(E,'remoteJid');");
                        Content.Append("{'myTitle':'");
                        Content.Append(JSON.Encode(ServiceRef.Localizer[nameof(AppResources.ControlRequest)]));
                        Content.Append("',");
                        Content.Append("'myBody':RosterName(ToJid,RemoteJid),");
                        Content.Append("'remoteJid':RemoteJid,");
                        Content.Append("'jid':GetAttribute(E,'jid'),");
                        Content.Append("'key':GetAttribute(E,'key'),");
                        Content.Append("'q':'canControl',");
                        Content.Append("'channelId':'");
                        Content.Append(Constants.PushChannels.Provisioning);
                        Content.Append("',");
                        Content.Append("'content_available':true}");
 
                        await ServiceRef.XmppService.AddPushNotificationRule(MessageType.Normal, "canControl", ProvisioningClient.NamespaceProvisioningOwnerCurrent,
                            Constants.PushChannels.Provisioning, "Stanza", string.Empty, Content.ToString());
 
                        #endregion
 
                        await RuntimeSettings.SetAsync(Constants.Settings.PushNotificationConfigurationVersion, Version);
                    }
                }
            }
            catch (Exception ex)
            {
                ServiceRef.LogService.LogException(ex);
            }
        }
    }
}