using System.Diagnostics;

namespace GB5Shared.Telemetry;

/// <summary>
/// Central registry of all <see cref="ActivitySource"/> instances used across the GB5 platform.
/// Every feature area has its own named source so traces can be filtered and searched by domain
/// (e.g. show only "GB5.Dapr.Publish" or "GB5.Database" spans in Jaeger / Zipkin).
/// </summary>
public static class GB5ActivitySources
{
    private const string Prefix = "GB5";
    private const string Version = "1.0";

    /// <summary>FastEndpoints API handler spans — one per endpoint invocation.</summary>
    public static readonly ActivitySource Endpoints = new($"{Prefix}.Endpoints", Version);

    /// <summary>Dapr pub/sub outbound — publishing events to a topic.</summary>
    public static readonly ActivitySource DaprPublish = new($"{Prefix}.Dapr.Publish", Version);

    /// <summary>Dapr pub/sub inbound — consuming events from a topic subscription.</summary>
    public static readonly ActivitySource DaprSubscribe = new($"{Prefix}.Dapr.Subscribe", Version);

    /// <summary>Database query and command spans (Dapper / EF Core / raw SQL).</summary>
    public static readonly ActivitySource Database = new($"{Prefix}.Database", Version);

    /// <summary>Quartz scheduler job execution spans.</summary>
    public static readonly ActivitySource Scheduler = new($"{Prefix}.Scheduler", Version);

    /// <summary>IHostedService background processing spans.</summary>
    public static readonly ActivitySource Background = new($"{Prefix}.Background", Version);

    /// <summary>Dapr state-store cache read / write / delete spans.</summary>
    public static readonly ActivitySource Cache = new($"{Prefix}.Cache", Version);

    /// <summary>Named HTTP client outbound calls (ReportClient, sysjob, BatchExecution, webhooks).</summary>
    public static readonly ActivitySource HttpClient = new($"{Prefix}.HttpClient", Version);

    /// <summary>WIP (Work-in-Progress) approval dispatching and replay spans.</summary>
    public static readonly ActivitySource Wip = new($"{Prefix}.Wip", Version);

    /// <summary>Transactional outbox reliable-messaging spans.</summary>
    public static readonly ActivitySource Outbox = new($"{Prefix}.Outbox", Version);

    /// <summary>Email, SMS, Webhook, Report, and all other action handler spans.</summary>
    public static readonly ActivitySource ActionProcessor = new($"{Prefix}.ActionProcessor", Version);

    /// <summary>Qualifier pipeline spans — DB_ENRICH, validation, enrichment, derivation steps.</summary>
    public static readonly ActivitySource Qualifier = new($"{Prefix}.Qualifier", Version);

    /// <summary>
    /// Entity save pipeline spans — covers the full ExecuteSaveAsync flow in
    /// <c>BaseEntityAppService</c>: transaction, qualifier steps, persist, workflow,
    /// outbox write, and direct Dapr publish.
    /// </summary>
    public static readonly ActivitySource EntitySave = new($"{Prefix}.EntitySave", Version);

    /// <summary>
    /// Workflow action outcome spans — covers Approve (final), Reject, and Return outcome
    /// event publishing in <c>WorkFlowBLL.WorkFlowActions</c>: direct Dapr publish and
    /// outbox write for each workflow outcome so email/SMS actions can be configured via
    /// MACTION without additional code per entity type.
    /// </summary>
    public static readonly ActivitySource WorkflowAction = new($"{Prefix}.WorkflowAction", Version);

    /// <summary>
    /// Explicit BLL/service-layer processing section spans opened via <see cref="GB5Trace.BeginSection"/>.
    /// Use for complex processing pipelines where named child spans improve trace readability
    /// beyond what <c>ILogger</c> events alone provide — e.g. qualification steps, bulk operations,
    /// approval dispatch sub-flows.
    /// </summary>
    public static readonly ActivitySource Processing = new($"{Prefix}.Processing", Version);

    /// <summary>
    /// GOP AIExtract node calls to the external Enterprise AI engine — distinct from the
    /// generic <see cref="HttpClient"/> source so AI-capability calls (classification gate
    /// outcome, target agent slug, engine executionId for cross-system correlation) are
    /// filterable on their own in a trace backend, same reasoning as <see cref="Qualifier"/>
    /// and <see cref="EntitySave"/> getting their own sources once they became real capabilities.
    /// </summary>
    public static readonly ActivitySource AICapability = new($"{Prefix}.AICapability", Version);

    /// <summary>
    /// All GB5 source names in a single array, used by <c>AddGB5Telemetry</c> to register
    /// every source with the OpenTelemetry TracerProvider in a single loop.
    /// </summary>
    internal static readonly string[] AllSourceNames =
    [
        Endpoints.Name,
        DaprPublish.Name,
        DaprSubscribe.Name,
        Database.Name,
        Scheduler.Name,
        Background.Name,
        Cache.Name,
        HttpClient.Name,
        Wip.Name,
        Outbox.Name,
        ActionProcessor.Name,
        Qualifier.Name,
        EntitySave.Name,
        WorkflowAction.Name,
        Processing.Name,
        AICapability.Name,
    ];
}