Function makeTelemetrySurface

e2e/src/surfaces/telemetry.ts:40–75

(motelUrl: string)

}

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,
    expectSpan: (query) =>
      searchSpans(query).pipe(
        Effect.filterOrFail(
          (spans) => spans.length > 0,
          () => `no exported span matched ${JSON.stringify(query)}`,
        ),
        Effect.map((spans) => spans[0]!),
        // ~20s ceiling (40 × 500ms): BatchSpanProcessor flushes ~1s after the
        // request and the dev stack drains on waitUntil; slower is a real bug.
        Effect.retry(Schedule.both(Schedule.spaced("500 millis"), Schedule.recurs(40))),
      ),
  };
};