PluginDelegator.cs

Go to the documentation of this file.

using System;
 
namespace Hermod.PluginFramework {
 
    using Config;
    using Core.Commands.Results;
    using Core.Delegation;
    using Serilog;
 
    public class PluginDelegator: IPluginDelegator {
 
        internal IPlugin Plugin { get; }
        internal ILogger? Logger { get; }
 
        public PluginDelegator(IPlugin plugin, ILogger? logger = null) {
            Plugin = plugin;
            Logger = logger;
        }
 
        #region IMessageReceived
        public event MessageReceivedEventHandler? MessageReceived;
 
        internal void OnMessageReceived(MessageReceivedEventArgs e) => MessageReceived?.Invoke(this, e);
        #endregion
 
        public void SubscribeTopic(string topicName) => PluginRegistry.Instance.AddSubscription(Plugin, topicName);
 
        public void SubscribeTopics(params string[] topics) {
            foreach (var topic in topics) {
                try { PluginRegistry.Instance.AddSubscription(Plugin, topic); } catch (Exception ex) {
                    Error($"Subscription failed: {ex.Message}");
                    Debug($"Stacktrace: {ex.StackTrace}");
                }
            }
        }
 
        public void UnsubscribeTopic(string topicName) => PluginRegistry.Instance.RemoveSubscription(Plugin, topicName);
 
        public void PublishMessage(string topic, object? message) => PluginRegistry.Instance.OnMessagePublished(topic, message);
 
        public ICommandResult ExecuteCommand(params string[] command) => PluginRegistry.Instance.ExecuteCommand(command);
 
        public void Information(string? msg) => Logger?.Information($"[{ Plugin.PluginName }] {msg}");
 
        public void Debug(string? msg) => Logger?.Debug($"[{ Plugin.PluginName }] {msg}");
 
        public void Error(string? msg) => Logger?.Error($"[{ Plugin.PluginName }] {msg}");
 
        public void Warning(string? msg) => Logger?.Warning($"[{ Plugin.PluginName }] {msg}");
 
        public void Trace(string? msg) => Logger?.Verbose($"[{ Plugin.PluginName }] {msg}");
 
        public T GetApplicationConfig<T>(string config) => ConfigManager.Instance.GetConfig<T>(config);
 
        public bool TryGetApplicationConfig<T>(string config, out T? value) {
            try {
                value = GetApplicationConfig<T>(config);
            } catch {
                value = default;
                return false;
            }
 
            return true;
        }
    }
}