Class ExportController

src/Features/Export/ExportController.cs:26–436

}

[ApiController, IsAuthenticated, HasReadAccessToApp]
[ResponseCache(NoStore = true, Location = ResponseCacheLocation.None)]
public partial class ExportController(IQueryClient queryClient, ILogger<ExportController> logger) : Controller
{
    private readonly IQueryClient _queryClient = queryClient ?? throw new ArgumentNullException(nameof(queryClient));
    private readonly ILogger<ExportController> _logger = logger;

    [HttpGet("/api/_export/usage")]
    public async Task<IActionResult> MonthlyUsage([FromQuery] string buildMode, [FromQuery] string appId, CancellationToken cancellationToken)
    {
        var rows = await _queryClient.NamedQueryAsync<MonthlyUsage>("monthly_usage__v1", new {
            app_id = GetAppId(buildMode, appId)
        }, cancellationToken);

        if (buildMode.Equals("debug", StringComparison.OrdinalIgnoreCase))
        {
            return Ok(rows.Take(5));
        }

        return Ok(rows);
    }

    [HttpGet("/api/_export/download")]
    public async Task<IActionResult> Download([FromQuery] DownloadRequest body)
    {
        if (!body.StartDate.HasValue || !body.EndDate.HasValue)
        {
            return BadRequest();
        }

        var startDate = body.StartDate.Value;
        var endDate = body.EndDate.Value;

        var (formatName, contentType, fileExtension) = GetFormat(body.Format);
        var appName = UnsafeCharacters().Replace(body.AppName, "").ToLower();
        var fileName = $"{appName}-{body.BuildMode.ToLower()}-{startDate:yyyy-MM-dd}.{fileExtension}";

        var countQuery = $@"SELECT COUNT(*) as event_count
                       FROM events
                       WHERE app_id = '{GetAppId(body.BuildMode, body.AppId)}'
                       AND timestamp BETWEEN '{startDate:yyyy-MM-dd HH:mm:ss}' AND '{endDate:yyyy-MM-dd HH:mm:ss}'
                       FORMAT JSON";

        using var stream = await _queryClient.StreamResponseAsync(countQuery, HttpContext.RequestAborted);
        long eventCount = 0;
        using var reader = new StreamReader(stream);
        var jsonString = await reader.ReadToEndAsync();
        using var doc = JsonDocument.Parse(jsonString);
        var root = doc.RootElement;

        if (root.TryGetProperty("data", out JsonElement data) &&
            data.GetArrayLength() > 0 &&
            data[0].TryGetProperty("event_count", out JsonElement countElement))
        {
            switch (countElement.ValueKind)
            {
                case JsonValueKind.Number:
                    _ = countElement.TryGetInt64(out eventCount);