Method queryLoki

backend/src/trace/log-stream.service.ts:183–224

(record: WorkflowLogStreamRecord, limit: number)

  }

  private async queryLoki(record: WorkflowLogStreamRecord, limit: number): Promise<LokiEntry[]> {
    const selector = this.buildSelector(this.normalizeLabels(record.labels));
    const start = this.toNanoseconds(record.firstTimestamp);
    const end = this.toNanoseconds(record.lastTimestamp);

    const params = new URLSearchParams({
      query: selector,
      start,
      end,
      direction: 'forward',
      limit: limit.toString(),
    });

    const response = await fetch(this.resolveUrl(`/loki/api/v1/query_range?${params.toString()}`), {
      method: 'GET',
      headers: this.buildHeaders(),
    });

    if (!response.ok) {
      const errorText = await response.text();
      throw new ServiceUnavailableException(
        `Loki query failed: ${response.status} ${response.statusText} - ${errorText}`,
      );
    }

    const payload = (await response.json()) as {
      data?: { result?: { values?: [string, string][] }[] };
    };

    const entries: LokiEntry[] = [];
    const results = payload.data?.result ?? [];
    for (const result of results) {
      for (const [timestamp, message] of result.values ?? []) {
        entries.push({
          timestamp: this.fromNanoseconds(timestamp),
          message,
        });
      }
    }

    return entries;
  }

  private async queryLokiTimeRange(
    selector: string,