InMemoryLogStore.cs

이 파일의 문서화 페이지로 가기

using System;
using System.Collections.Generic;
using System.Linq;
using Dreamine.Logging.Interfaces;
using Dreamine.Logging.Models;
 
namespace Dreamine.Logging.Services
{
    public sealed class InMemoryLogStore : IDreamineLogStore, IDreamineLogSink
    {
        private readonly object _syncRoot = new();
        private readonly Queue<DreamineLogEntry> _entries;
        private readonly int _capacity;

        public event EventHandler<DreamineLogEntry>? LogAdded;

        public InMemoryLogStore()
            : this(1000)
        {
        }

        public InMemoryLogStore(int capacity)
        {
            _capacity = capacity <= 0 ? 1000 : capacity;
            _entries = new Queue<DreamineLogEntry>(_capacity);
        }

        public IReadOnlyList<DreamineLogEntry> GetEntries()
        {
            lock (_syncRoot)
            {
                return _entries.ToArray();
            }
        }

        public void Add(DreamineLogEntry entry)
        {
            ArgumentNullException.ThrowIfNull(entry);
 
            lock (_syncRoot)
            {
                _entries.Enqueue(entry);
 
                while (_entries.Count > _capacity)
                {
                    _entries.Dequeue();
                }
            }
 
            // Fire outside the lock to avoid reentrancy/deadlock if a handler
            // calls back into the store.
            LogAdded?.Invoke(this, entry);
        }

        public void Clear()
        {
            lock (_syncRoot)
            {
                _entries.Clear();
            }
        }

        public void Write(DreamineLogEntry entry)
        {
            Add(entry);
        }
    }
}