IBKRTrader/src/IBKRTrader.Core/Workers/WorkerEngine.cs

using System.Collections.Concurrent;
using System.ComponentModel;
using IBKRTrader.Core.Logging;

namespace IBKRTrader.Core.Workers;

/// <summary>
/// Leichtgewichtige Registry über alle Worker/Services. Start/Stop übernimmt der Generic Host
/// (jeder Worker ist ein <see cref="Microsoft.Extensions.Hosting.IHostedService"/>). Diese Klasse
/// stellt die live-bindbare Liste für die Workers-Ansicht bereit und erlaubt den manuellen Trigger.
/// </summary>
public class WorkerEngine
{
    private readonly ConcurrentDictionary<string, IWorker> _registry = new();

    /// <summary>
    /// Live-bindbare Liste für die Workers-Ansicht. Die Liste selbst ändert sich zur Laufzeit
    /// nicht – die Worker werden hier einmal registriert; was sich ändert, meldet
    /// <see cref="WorkerInfo"/> über INotifyPropertyChanged.
    /// </summary>
    public BindingList<WorkerInfo> WorkerInfos { get; } = [];

    public WorkerEngine(IEnumerable<IWorker> workers, LoggingService logger)
    {
        foreach (var worker in workers)
        {
            _registry[worker.Name] = worker;
            WorkerInfos.Add(worker.Info);
        }
        logger.Info("Core", $"WorkerEngine: {_registry.Count} Worker/Services registriert.");
    }

    /// <summary>Löst einen sofortigen manuellen Run des benannten Workers aus.</summary>
    public async Task TriggerWorkerAsync(string name)
    {
        if (_registry.TryGetValue(name, out var worker))
            await worker.TriggerAsync();
    }
}