Function reportFor

e2e/cloud/storage-error-report-shape.test.ts:186–219

(traceId: string)

 * id, so it is THIS request's report and not a neighbour's.
 */
const reportFor = (traceId: string): Effect.Effect<FiledReport, string> =>
  Effect.sync(() => {
    const lines = readServerLog().split("\n");
    const correlated = lines.findLastIndex(
      (line) =>
        line.includes('"event":"sentry_before_send_otel_correlation"') &&
        line.includes(`"sentry_event_id":"${traceId}"`),
    );
    if (correlated === -1) return undefined;
    const reported = lines
      .slice(0, correlated)
      .findLastIndex((line) => line.startsWith(REPORT_PREFIX));
    if (reported === -1) return undefined;
    const block = [
      lines[reported]!.slice(REPORT_PREFIX.length),
      ...lines.slice(reported + 1, correlated),
    ];
    const end = block.slice(1).findIndex((line) => STACK_FRAME.test(line));
    return {
      headline: block
        .slice(0, end === -1 ? 1 : end + 1)
        .join("\n")
        .trimEnd(),
      full: block.join("\n"),
    };
  }).pipe(
    Effect.filterOrFail(
      (report): report is FiledReport => report !== undefined,
      () => `no error report joined to trace id ${traceId} in the server log`,
    ),
    // The log is a file the dev stack appends to; the write lands moments after
    // the response. Poll rather than sleep (~20s ceiling).
    Effect.retry(Schedule.both(Schedule.spaced("500 millis"), Schedule.recurs(40))),
  );

scenario(
  "Storage · a rejected write is reported without its SQL or the caller's data",