VmsDashboardStateService.cs

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

using Dreamine.Hybrid.Interfaces;
using DreamineVMS.Models;
using DreamineVMS.Services.Cameras;
using DreamineVMS.Services.Runtime;
using DreamineVMS.States;
 
namespace DreamineVMS.Services.Dashboard;

public sealed class VmsDashboardStateService : IVmsDashboardStateService, IDisposable
{
    private readonly IVmsCameraRepository _repository;
    private readonly ICameraRuntimeStateService _runtimeState;
    private readonly IHybridStateStore<VmsDashboardState> _stateStore;
    private readonly object _gate = new();
    private bool _isStarted;
    private bool _isDisposed;

    public VmsDashboardStateService(
        IVmsCameraRepository repository,
        ICameraRuntimeStateService runtimeState,
        IHybridStateStore<VmsDashboardState> stateStore)
    {
        _repository = repository ?? throw new ArgumentNullException(nameof(repository));
        _runtimeState = runtimeState ?? throw new ArgumentNullException(nameof(runtimeState));
        _stateStore = stateStore ?? throw new ArgumentNullException(nameof(stateStore));
    }

    public void Start()
    {
        lock (_gate)
        {
            if (_isStarted || _isDisposed)
            {
                return;
            }
 
            _runtimeState.StateChanged += OnRuntimeStateChanged;
            _isStarted = true;
        }
 
        // 시작 시 1회 초기 동기화.
        Refresh("VMS application started.");
    }

    public void Refresh(string? lastEvent = null)
    {
        if (_isDisposed)
        {
            return;
        }
 
        IReadOnlyList<CameraDevice> cameras = _repository.GetAll();
        IReadOnlyList<CameraRuntimeState> states = _runtimeState.GetAll();
 
        int connectedCount = states.Count(state => state.State == CameraConnectionState.Connected);
 
        VmsDashboardState previous = _stateStore.State;
        string finalLastEvent = lastEvent ?? previous.LastEvent;
 
        _stateStore.SetState(new VmsDashboardState
        {
            TotalCameraCount = cameras.Count,
            ConnectedCameraCount = connectedCount,
            RecordingCameraCount = 0,
            LastEvent = finalLastEvent,
            LastUpdated = DateTimeOffset.Now
        });
    }

    public void Dispose()
    {
        lock (_gate)
        {
            if (_isDisposed)
            {
                return;
            }
 
            if (_isStarted)
            {
                _runtimeState.StateChanged -= OnRuntimeStateChanged;
                _isStarted = false;
            }
 
            _isDisposed = true;
        }
    }

    private void OnRuntimeStateChanged(object? sender, CameraRuntimeState e)
    {
        Refresh(e.LastMessage);
    }
}