ProviderClient.Subagents.cs

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

using Lilith.Core.Scenarios;

namespace Lilith.Core.Providers;

public abstract partial class ProviderClient
{
    public SubagentRegistry Subagents { get; } = new();
    private volatile bool _showSubagentOutput;
    public bool ShowSubagentOutput { get => _showSubagentOutput; set => _showSubagentOutput = value; }
    public event Action<SubagentOutput>? SubagentOutput;

    private void ReportSubagent(ScenarioProgress progress)
    {
        var output = SubagentRegistry.Present(progress, Subagents.Observe(progress), ShowSubagentOutput);
        if (output is null) return;
        Logger.WriteLine("Subagent " + output.AgentId, output.IsSummary ? output.Text : output.Kind + ": " + output.Text, LogColors.Cyan);
        if (SubagentOutput is not { } handlers) return;
        foreach (var handler in handlers.GetInvocationList().Cast<Action<SubagentOutput>>())
            try { handler(output); }
            catch (Exception ex) { Logger.WriteWarning("Subagent", "Output observer failed: " + ex.Message); }
    }
}