Notify.cs

using System.Collections.Generic;
using System.Text;
using System.Text.RegularExpressions;
using System.Threading.Tasks;
using Waher.Networking.XMPP;
using Waher.Persistence;
 
namespace Waher.Service.IoTBroker.Admin.Feedback
{
    public class Notify : CommandRegEx
    {
        public Notify()
            : base("^notify(\\s+(?'SubCommand'(add|remove)))?(\\s+(([^@/<>'\\\"\\s]+)@)([^@/<> '\\\"\\s]+))*$")
        {
        }
 
        public override string Name => "Notify";
 
        public override async Task Execute(ChatState State, string[] Arguments, string OrgMessage, Match Details,
            ResponseCallbackHandler ResponseCallback)
        {
            int i = 0;
            int c = Arguments.Length;
 
            if (c == 0)
            {
                StringBuilder Markdown = new StringBuilder();
                bool First = true;
 
                foreach (CaseInsensitiveString Jid in IoTGateway.Setup.NotificationConfiguration.Instance.Addresses)
                {
                    if (First)
                        First = false;
                    else
                        Markdown.Append("; ");
 
                    Markdown.Append('`');
                    Markdown.Append(Jid);
                    Markdown.Append('`');
                }
 
                await ResponseCallback(Markdown.ToString(), string.Empty);
            }
            else
            {
                List<CaseInsensitiveString> Addresses = new List<CaseInsensitiveString>();
                List<CaseInsensitiveString> AddressesOrg = new List<CaseInsensitiveString>();
                CaseInsensitiveString BareSenderJid = XmppClient.GetBareJID(State.To);
                bool IsFromBareJid = XmppClient.BareJidRegEx.IsMatch(BareSenderJid.LowerCase);
                bool ContainsSelf = false;
                bool Remove = false;
                bool Relative = false;
                bool Updated = false;
 
                switch (Arguments[0].ToLower())
                {
                    case "add":
                        i++;
                        Relative = true;
                        break;
 
                    case "remove":
                        i++;
                        Remove = true;
                        Relative = true;
                        break;
                }
 
                foreach (CaseInsensitiveString Jid in IoTGateway.Setup.NotificationConfiguration.Instance.Addresses)
                    AddressesOrg.Add(Jid);
 
                if (Relative)
                    Addresses.AddRange(AddressesOrg);
 
                while (i < c)
                {
                    string JID = Arguments[i++];
                    CaseInsensitiveString cs = (CaseInsensitiveString)JID;
                    if (cs == IoTGateway.Gateway.XmppClient.BareJID)
                        continue;
 
                    if (Remove)
                    {
                        if (Addresses.Remove(cs))
                            Updated = true;
                    }
                    else
                    {
                        if (!Addresses.Contains(cs))
                        {
                            Addresses.Add(cs);
 
                            if (Relative || !AddressesOrg.Contains(cs))
                                Updated = true;
                        }
                    }
                }
 
                foreach (CaseInsensitiveString Jid in Addresses)
                {
                    if (Jid == BareSenderJid)
                        ContainsSelf = true;
                }
 
                if (ContainsSelf || !IsFromBareJid)
                {
                    IoTGateway.Setup.NotificationConfiguration.Instance.Addresses = Addresses.ToArray();
                    await Persistence.Database.Update(IoTGateway.Setup.NotificationConfiguration.Instance);
 
                    if (Updated)
                        await ResponseCallback("Notification list updated.", string.Empty);
                    else
                        await ResponseCallback("Notification list up to date.", string.Empty);
                }
                else
                    await XmppServerModule.SendErrorMessage("Must be included: " + BareSenderJid, string.Empty, ResponseCallback);
            }
        }
 
        public override HelpItem[] GetHelp()
        {
            return new HelpItem[]
            {
                new HelpItem("notify", "Lists recipients of JIDs that will be notified of events on the broker. They also have access to chat admin interface."),
                new HelpItem("notify[ JID[ JID2[...]]]", "Sets the recipients of notifications, and those with access to chat admin interface. You cannot remove yourself from the list."),
                new HelpItem("notify add [ JID[ JID2[...]]]", "Adds new recipients to the list of notification recipients."),
                new HelpItem("notify remove [ JID[ JID2[...]]]", "Removes recipients from the list of notification recipients.")
            };
        }
    }
}