Add Nitro telemetry CLI commands

src/Nitro/CommandLine/src/CommandLine/Commands/Telemetry/Arguments/AttributeKeyArgument.cs

@@ -0,0 +1,10 @@
+namespace ChilliCream.Nitro.CommandLine.Commands.Telemetry.Arguments;
+
+internal sealed class AttributeKeyArgument : Argument<string>
+{
+    public AttributeKeyArgument() : base("key")
+    {
+        Description = "The attribute key";
+        Arity = ArgumentArity.ExactlyOne;
+    }
+}

src/Nitro/CommandLine/src/CommandLine/Commands/Telemetry/Arguments/LogIdArgument.cs

@@ -0,0 +1,10 @@
+namespace ChilliCream.Nitro.CommandLine.Commands.Telemetry.Arguments;
+
+internal sealed class LogIdArgument : Argument<string>
+{
+    public LogIdArgument() : base("log-id")
+    {
+        Description = "The log ID";
+        Arity = ArgumentArity.ExactlyOne;
+    }
+}

src/Nitro/CommandLine/src/CommandLine/Commands/Telemetry/Arguments/ServiceNameArgument.cs

@@ -0,0 +1,10 @@
+namespace ChilliCream.Nitro.CommandLine.Commands.Telemetry.Arguments;
+
+internal sealed class ServiceNameArgument : Argument<string>
+{
+    public ServiceNameArgument() : base("name")
+    {
+        Description = "The service name";
+        Arity = ArgumentArity.ExactlyOne;
+    }
+}

src/Nitro/CommandLine/src/CommandLine/Commands/Telemetry/Arguments/TraceIdArgument.cs

@@ -0,0 +1,10 @@
+namespace ChilliCream.Nitro.CommandLine.Commands.Telemetry.Arguments;
+
+internal sealed class TraceIdArgument : Argument<string>
+{
+    public TraceIdArgument() : base("trace-id")
+    {
+        Description = "The trace ID";
+        Arity = ArgumentArity.ExactlyOne;
+    }
+}

src/Nitro/CommandLine/src/CommandLine/Commands/Telemetry/Attributes/AttributesCommand.cs

@@ -0,0 +1,12 @@
+namespace ChilliCream.Nitro.CommandLine.Commands.Telemetry.Attributes;
+
+internal sealed class AttributesCommand : Command
+{
+    public AttributesCommand() : base("attributes")
+    {
+        Description = "Inspect telemetry attributes.";
+
+        Subcommands.Add(new ListAttributeKeysCommand());
+        Subcommands.Add(new ListAttributeValuesCommand());
+    }
+}

src/Nitro/CommandLine/src/CommandLine/Commands/Telemetry/Attributes/ListAttributeKeysCommand.cs

@@ -0,0 +1,75 @@
+using ChilliCream.Nitro.Client.Telemetry;
+using ChilliCream.Nitro.Client.Telemetry.Models;
+using ChilliCream.Nitro.CommandLine.Commands.Telemetry.Options;
+using ChilliCream.Nitro.CommandLine.Helpers;
+using ChilliCream.Nitro.CommandLine.Results;
+using ChilliCream.Nitro.CommandLine.Services.Sessions;
+
+namespace ChilliCream.Nitro.CommandLine.Commands.Telemetry.Attributes;
+
+internal sealed class ListAttributeKeysCommand : Command
+{
+    public ListAttributeKeysCommand() : base("keys")
+    {
+        Description = "List telemetry attribute keys.";
+
+        Options.Add(Opt<AttributeSignalOption>.Instance);
+        Options.Add(Opt<AttributeKindsOption>.Instance);
+        Options.Add(Opt<AttributeKeySearchOption>.Instance);
+        Options.Add(Opt<TelemetrySinceOption>.Instance);
+        Options.Add(Opt<TelemetryUntilOption>.Instance);
+        Options.Add(Opt<TelemetryLimitOption>.Instance);
+        Options.Add(Opt<OptionalCursorOption>.Instance);
+
+        TelemetryCommandOptions.AddOptions(this);
+
+        TelemetryCommandOptions.AddTimeRangeValidator(this);
+
+        this.AddExamples("telemetry attributes keys --signal traces");
+
+        this.SetActionWithExceptionHandling(ExecuteAsync);
+    }
+
+    private static async Task<int> ExecuteAsync(
+        ICommandServices services,
+        ParseResult parseResult,
+        CancellationToken cancellationToken)
+    {
+        var client = services.GetRequiredService<ITelemetryClient>();
+        var sessionService = services.GetRequiredService<ISessionService>();
+        var resultHolder = services.GetRequiredService<IResultHolder>();
+
+        parseResult.AssertHasAuthentication(sessionService);
+
+        var workspaceId = parseResult.GetWorkspaceId(sessionService);
+
+        var signal = parseResult.GetRequiredValue(Opt<AttributeSignalOption>.Instance);
+        var kinds = parseResult.GetValue(Opt<AttributeKindsOption>.Instance);
+        var search = parseResult.GetValue(Opt<AttributeKeySearchOption>.Instance);
+        var since = parseResult.GetValue(Opt<TelemetrySinceOption>.Instance);
+        var until = parseResult.GetValue(Opt<TelemetryUntilOption>.Instance);
+        var cursor = parseResult.GetValue(Opt<OptionalCursorOption>.Instance);
+        var limit = parseResult.GetValue(Opt<TelemetryLimitOption>.Instance) ?? 50;
+
+        var page = await client.ListAttributeKeysAsync(
+            workspaceId,
+            signal,
+            kinds,
+            search,
+            since,
+            until,
+            limit,
+            cursor,
+            cancellationToken);
+
+        var items = page.Items.Select(AttributeKeyListItem.From).ToArray();
+        resultHolder.SetResult(new PaginatedListResult<AttributeKeyListItem>(items, page.EndCursor));
+
+        return ExitCodes.Success;
+    }
+
+    internal sealed record AttributeKeyListItem(string Key, string Kind)
+    {
+        public static AttributeKeyListItem From(AttributeKeyRow key) => new(key.Path, key.Kind);
+    }
+}

src/Nitro/CommandLine/src/CommandLine/Commands/Telemetry/Attributes/ListAttributeValuesCommand.cs

@@ -0,0 +1,104 @@
+using System.Globalization;
+using ChilliCream.Nitro.Client.Telemetry;
+using ChilliCream.Nitro.Client.Telemetry.Models;
+using ChilliCream.Nitro.CommandLine.Commands.Telemetry.Arguments;
+using ChilliCream.Nitro.CommandLine.Commands.Telemetry.Options;
+using ChilliCream.Nitro.CommandLine.Helpers;
+using ChilliCream.Nitro.CommandLine.Results;
+using ChilliCream.Nitro.CommandLine.Services.Sessions;
+
+namespace ChilliCream.Nitro.CommandLine.Commands.Telemetry.Attributes;
+
+internal sealed class ListAttributeValuesCommand : Command
+{
+    public ListAttributeValuesCommand() : base("values")
+    {
+        Description = "List telemetry attribute values.";
+
+        Arguments.Add(Opt<AttributeKeyArgument>.Instance);
+        Options.Add(Opt<AttributeSignalOption>.Instance);
+        Options.Add(Opt<AttributeKindOption>.Instance);
+        Options.Add(Opt<AttributeValueSearchOption>.Instance);
+        Options.Add(Opt<TelemetrySinceOption>.Instance);
+        Options.Add(Opt<TelemetryUntilOption>.Instance);
+        Options.Add(Opt<TelemetryLimitOption>.Instance);
+        Options.Add(Opt<OptionalCursorOption>.Instance);
+
+        TelemetryCommandOptions.AddOptions(this);
+
+        TelemetryCommandOptions.AddTimeRangeValidator(this);
+
+        this.AddExamples("telemetry attributes values service.name --signal traces");
+
+        this.SetActionWithExceptionHandling(ExecuteAsync);
+    }
+
+    private static async Task<int> ExecuteAsync(
+        ICommandServices services,
+        ParseResult parseResult,
+        CancellationToken cancellationToken)
+    {
+        var client = services.GetRequiredService<ITelemetryClient>();
+        var sessionService = services.GetRequiredService<ISessionService>();
+        var resultHolder = services.GetRequiredService<IResultHolder>();
+
+        parseResult.AssertHasAuthentication(sessionService);
+
+        var workspaceId = parseResult.GetWorkspaceId(sessionService);
+
+        var key = parseResult.GetRequiredValue(Opt<AttributeKeyArgument>.Instance);
+        var signal = parseResult.GetRequiredValue(Opt<AttributeSignalOption>.Instance);
+        var kind = parseResult.GetValue(Opt<AttributeKindOption>.Instance);
+        var search = parseResult.GetValue(Opt<AttributeValueSearchOption>.Instance);
+        var since = parseResult.GetValue(Opt<TelemetrySinceOption>.Instance);
+        var until = parseResult.GetValue(Opt<TelemetryUntilOption>.Instance);
+        var cursor = parseResult.GetValue(Opt<OptionalCursorOption>.Instance);
+        var limit = parseResult.GetValue(Opt<TelemetryLimitOption>.Instance) ?? 50;
+
+        var page = await client.ListAttributeValuesAsync(
+            workspaceId,
+            signal,
+            key,
+            kind,
+            search,
+            since,
+            until,
+            limit,
+            cursor,
+            cancellationToken);
+
+        var items = page.Items.Select(AttributeValueListItem.From).ToArray();
+        resultHolder.SetResult(new PaginatedListResult<AttributeValueListItem>(items, page.EndCursor));
+
+        return ExitCodes.Success;
+    }
+
+    internal sealed record AttributeValueListItem(string Value)
+    {
+        public static AttributeValueListItem From(AttributeValue value)
+        {
+            if (value.String is { } stringValue)
+            {
+                return new AttributeValueListItem(stringValue);
+            }
+
+            if (value.Int is { } intValue)
+            {
+                return new AttributeValueListItem(intValue.ToString(CultureInfo.InvariantCulture));
+            }
+
+            if (value.Float is { } floatValue)
+            {
+                return new AttributeValueListItem(floatValue.ToString(CultureInfo.InvariantCulture));
+            }
+
+            return new AttributeValueListItem(
+                value.Boolean switch
+                {
+                    true => "true",
+                    false => "false",
+                    _ => string.Empty
+                });
+        }
+    }
+}