Function streamingProblemEvent

packages/server/src/http/error-response.ts:189–252

(
  status: HttpErrorStatus,
  type: ProblemType,
  title: string,
  options: StreamingErrorOptions = {},
)

}

export function streamingProblemEvent(
  status: HttpErrorStatus,
  type: ProblemType,
  title: string,
  options: StreamingErrorOptions = {},
): StreamingProblemEvent {
  const instance = options.instance ?? `urn:uuid:${randomUUID()}`;
  const problem: ProblemDetails = {
    type,
    title,
    status,
    instance,
    detail: options.detail ?? undefined,
  };
  const event: StreamingProblemEvent = { type: 'error', problem };
  const validated = StreamingProblemEventSchema.safeParse(event);
  if (!validated.success) {
    log().error(
      {
        event: 'api.streaming.malformed-envelope',
        issues: validated.error.issues,
        body: event,
        handler: options.handler,
        originalStatus: status,
      },
      'streamingProblemEvent produced an invalid StreamingProblemEvent — returning fallback',
    );
    const fallbackStatus = 500 as const;
    apiErrorCounter().add(1, {
      type: 'urn:ok:error:internal-server-error',
      ...(options.handler ? { handler: options.handler } : {}),
    });
    return {
      type: 'error',
      problem: {
        type: 'urn:ok:error:internal-server-error',
        title: 'Internal server error.',
        status: fallbackStatus,
        instance,
      },
    };
  }

  apiErrorCounter().add(1, {
    type,
    ...(options.handler ? { handler: options.handler } : {}),
  });

  const logLevel = status >= 500 ? 'error' : 'warn';
  log()[logLevel](
    {
      event: 'api.streaming.error',
      instance,
      type,
      status,
      handler: options.handler,
      detail: options.detail,
      err: options.cause,