EventSinkToSniffer.cs

using System;
using System.Collections.Generic;
using System.Text;
using System.Threading.Tasks;
using Waher.Events;
using Waher.Networking.Sniffers;
 
namespace Waher.Service.IoTBroker.Sources.Reports.Events
{
    public class EventSinkToSniffer : EventSink
    {
        private readonly ISniffer sniffer;
 
        public EventSinkToSniffer(ISniffer Sniffer)
            : base(Guid.NewGuid().ToString())
        {
            this.sniffer = Sniffer;
        }
 
        public ISniffer Sniffer => this.sniffer;
 
        public override Task Queue(Event Event)
        {
            StringBuilder sb = new StringBuilder();
            bool First = true;
 
            sb.Append(Event.Message);
            this.Append(sb, "Object", Event.Object, ref First);
            this.Append(sb, "Actor", Event.Actor, ref First);
            this.Append(sb, "EventId", Event.EventId, ref First);
            this.Append(sb, "Facility", Event.Facility, ref First);
            this.Append(sb, "Module", Event.Module, ref First);
            this.Append(sb, "StackTrace", Event.StackTrace, ref First);
 
            if (!(Event.Tags is null))
            {
                foreach (KeyValuePair<string, object> P in Event.Tags)
                    this.Append(sb, P.Key, P.Value?.ToString(), ref First);
            }
 
            string Message = sb.ToString();
 
            switch (Event.Type)
            {
                case EventType.Informational:
                case EventType.Notice:
                case EventType.Debug:
                default:
                    this.sniffer.Information(Event.Timestamp, Message);
                    break;
 
                case EventType.Warning:
                    this.sniffer.Warning(Event.Timestamp, Message);
                    break;
 
                case EventType.Error:
                    this.sniffer.Error(Event.Timestamp, Message);
                    break;
 
                case EventType.Alert:
                case EventType.Critical:
                case EventType.Emergency:
                    this.sniffer.Exception(Event.Timestamp, Message);
                    break;
            }
 
            return Task.CompletedTask;
        }
 
        private void Append(StringBuilder sb, string Key, string Value, ref bool First)
        {
            if (!string.IsNullOrEmpty(Value))
            {
                if (First)
                {
                    First = false;
                    sb.AppendLine();
                }
 
                sb.AppendLine();
                sb.Append(Key);
                sb.Append(": ");
                sb.Append(Value);
            }
        }
 
    }
}