WireMock.Net-wiremock/src/WireMock.Net/Server/WireMockServer.LogEntries.cs

using System;
using System.Collections;
using System.Collections.Generic;
using System.Collections.ObjectModel;
using System.Collections.Specialized;
using System.Linq;
using JetBrains.Annotations;
using WireMock.Logging;
using WireMock.Matchers;
using WireMock.Matchers.Request;

namespace WireMock.Server
{
    public partial class WireMockServer
    {
        /// <inheritdoc cref="IWireMockServer.LogEntriesChanged" />
        [PublicAPI]
        public event NotifyCollectionChangedEventHandler LogEntriesChanged
        {
            add
            {
                _options.LogEntries.CollectionChanged += (sender, eventRecordArgs) =>
                {
                    try
                    {
                        value(sender, eventRecordArgs);
                    }
                    catch (Exception exception)
                    {
                        _options.Logger.Error("Error calling the LogEntriesChanged event handler: {0}", exception.Message);
                    }
                };
            }

            remove => _options.LogEntries.CollectionChanged -= value;
        }

        /// <inheritdoc cref="IWireMockServer.LogEntries" />
        [PublicAPI]
        public IEnumerable<ILogEntry> LogEntries => new ReadOnlyCollection<LogEntry>(_options.LogEntries.ToList());

        /// <summary>
        /// The search log-entries based on matchers.
        /// </summary>
        /// <param name="matchers">The matchers.</param>
        /// <returns>The <see cref="IEnumerable"/>.</returns>
        [PublicAPI]
        public IEnumerable<LogEntry> FindLogEntries([NotNull] params IRequestMatcher[] matchers)
        {
            var results = new Dictionary<LogEntry, RequestMatchResult>();

            foreach (var log in _options.LogEntries.ToList())
            {
                var requestMatchResult = new RequestMatchResult();
                foreach (var matcher in matchers)
                {
                    matcher.GetMatchingScore(log.RequestMessage, requestMatchResult);
                }

                if (requestMatchResult.AverageTotalScore > MatchScores.AlmostPerfect)
                {
                    results.Add(log, requestMatchResult);
                }
            }

            return new ReadOnlyCollection<LogEntry>(results.OrderBy(x => x.Value).Select(x => x.Key).ToList());
        }

        /// <inheritdoc cref="IWireMockServer.ResetLogEntries" />
        [PublicAPI]
        public void ResetLogEntries()
        {
            _options.LogEntries.Clear();
        }

        /// <inheritdoc cref="IWireMockServer.DeleteLogEntry" />
        [PublicAPI]
        public bool DeleteLogEntry(Guid guid)
        {
            // Check a logentry exists with the same GUID, if so, remove it.
            var existing = _options.LogEntries.ToList().FirstOrDefault(m => m.Guid == guid);
            if (existing != null)
            {
                _options.LogEntries.Remove(existing);
                return true;
            }

            return false;
        }
    }
}