PluginRegistry.Delegation.cs

Go to the documentation of this file.

using System;
 
namespace Hermod.PluginFramework {
 
    using Core.Commands.Results;
    using Core.Delegation;
    using Core.Exceptions;
    using System.Text.RegularExpressions;
 
    partial class PluginRegistry {
 
        internal Dictionary<string, List<IPlugin>> TopicSubscriptions { get; } = new Dictionary<string, List<IPlugin>>();
 
        internal void AddSubscription(IPlugin plugin, string topic) {
            if (!TopicIsValid(ref topic)) {
                throw new MalformedTopicException(topic, "The topic is invalid!");
            }
 
            if (!TopicSubscriptions.ContainsKey(topic)) {
                TopicSubscriptions.Add(topic, new List<IPlugin>());
            }
 
            var subList = TopicSubscriptions[topic];
            if (subList.Contains(plugin)) { return; }
 
            subList.Add(plugin);
        }
 
        internal void RemoveSubscription(IPlugin plugin, string topic) {
            if (!TopicIsValid(ref topic)) {
                throw new MalformedTopicException(topic, "The topic is invalid!");
            }
 
            if (!TopicSubscriptions.ContainsKey(topic)) { return; }
 
            var subList = TopicSubscriptions[topic];
            if (!subList.Contains(plugin)) { return; }
 
            subList.Remove(plugin);
        }
 
        [GeneratedRegex("^[A-z0-9-_Ä-ü]+$", RegexOptions.Compiled | RegexOptions.IgnoreCase | RegexOptions.CultureInvariant)]
        public static partial Regex TopicRegex();
 
        bool TopicIsValid(ref string topic) {
            if (
                string.IsNullOrEmpty(topic)         ||
                string.IsNullOrWhiteSpace(topic)    ||
                topic[0] != '/'                     ||
                topic.EndsWith('/')
            ) {
                return false;
            }
 
            var splitTopic = topic.Split('/').Where(x => x != "/").Where(x => !TopicRegex().IsMatch(x));
 
            return splitTopic.Count() > 0;
        }
 
        internal void OnMessagePublished(string topic, object? message) {
            if (!TopicIsValid(ref topic)) { throw new MalformedTopicException(topic, "The given topic is invalid!"); }
 
            if (!TopicSubscriptions.ContainsKey(topic)) {
                TopicSubscriptions.Add(topic, new List<IPlugin>());
                return; // this may change in the future.
            }
 
            var eventArgs = new MessageReceivedEventArgs(topic, message);
            foreach (var subscriber in TopicSubscriptions[topic]) {
                PluginDelegators.FirstOrDefault(p => p.Plugin == subscriber)?.OnMessageReceived(eventArgs);
            }
        }
 
        internal ICommandResult ExecuteCommand(params string[] commands) {
            throw new NotImplementedException();
        }
 
    }
}