Class LokiLogClient

worker/src/adapters/loki-log.adapter.ts:25–81

}

export class LokiLogClient implements LokiPushClient {
  constructor(private readonly config: LokiLogClientConfig) {}

  async push(labels: Record<string, string>, lines: LokiStreamLine[]): Promise<void> {
    if (lines.length === 0) {
      return;
    }

    const url = this.resolveUrl('/loki/api/v1/push');
    const headers: Record<string, string> = {
      'Content-Type': 'application/json',
    };

    if (this.config.tenantId) {
      headers['X-Scope-OrgID'] = this.config.tenantId;
    }

    if (this.config.username && this.config.password) {
      const credentials = Buffer.from(`${this.config.username}:${this.config.password}`).toString(
        'base64',
      );
      headers.Authorization = `Basic ${credentials}`;
    }

    const body = JSON.stringify({
      streams: [
        {
          stream: labels,
          values: lines.map((line) => [this.toNanoseconds(line.timestamp), line.message]),
        },
      ],
    });

    const response = await fetch(url, {
      method: 'POST',
      headers,
      body,
    });

    if (!response.ok) {
      const errorText = await response.text();
      throw new ServiceError(`Loki push failed: ${errorText}`, {
        statusCode: response.status,
        details: { statusText: response.statusText, errorText },
      });
    }
  }

  private resolveUrl(path: string): string {
    const base = this.config.baseUrl.replace(/\/+$/, '');
    return `${base}${path}`;
  }

  private toNanoseconds(date: Date): string {
    return (BigInt(date.getTime()) * 1000000n).toString();
  }
}