Function searchSpans

e2e/src/surfaces/telemetry.ts:41–59

(query: SpanQuery)

export const makeTelemetrySurface = (motelUrl: string): TelemetrySurface => {
  const searchSpans = (query: SpanQuery) =>
    Effect.gen(function* () {
      const params = new URLSearchParams({ lookback: "15m", limit: "100" });
      if (query.operation) params.set("operation", query.operation);
      if (query.traceId) params.set("traceId", query.traceId);
      for (const [key, value] of Object.entries(query.attributes ?? {})) {
        params.set(`attr.${key}`, value);
      }
      const response = yield* Effect.promise(() => fetch(`${motelUrl}/api/spans/search?${params}`));
      if (!response.ok) {
        return yield* Effect.fail(
          `motel span search responded ${response.status}: ${yield* Effect.promise(() => response.text())}`,
        );
      }
      const body = (yield* Effect.promise(() => response.json())) as {
        readonly data?: readonly ExportedSpan[];
      };
      return body.data ?? [];
    });

  return {
    searchSpans,