Errors

bun add @absolutejs/errors

import { Effect } from "effect";
import { status } from "elysia";
import { createErrorTracker, createMemoryIssueStore } from "@absolutejs/errors";
import { tracerOrNoop } from "@absolutejs/telemetry";

const errors = createErrorTracker({
  audit: broker, // @absolutejs/audit
  tracer: tracerOrNoop(otelProvider, "app"),
  store: createMemoryIssueStore(), // or @absolutejs/errors-postgres
  project: "acme",
  release: process.env.RELEASE,
  environment: "production",
  onIssue: (r) => alert(r.issue), // only on new / regression
});

// Effect API (primary):
const outcome = await Effect.runPromise(
  errors.capture(e, {
    tenant,
    target: `order_${orderId}`,
    tags: { component: "billing" },
  }),
);

// Promise edge (for Promise-world consumers) — identical outcome:
const out = await errors.captureException(e);

if (out.failures.length > 0) {
  for (const f of out.failures) {
    switch (f._tag) {
      case "StoreFailure":
        retryLater(f.cause);
        break; // f.cause: IssueStoreError
      case "AuditSinkFailure":
        page("audit lost", f.cause);
        break;
      case "TracerFailure":
      case "OnIssueFailure":
      case "FingerprintFailure":
        /* tolerate */ break;
    }
  }
}
return status(
  "Internal Server Error",
  `Request failed. Reference: ${out.fingerprint}`,
);

createErrorTracker(options?: {
  audit?: { append: (event) => Promise<void> | void };
  tracer?: { startSpan?: (name) => Span };
  store?: IssueStore;          // durable "Issues" surface
  project?: string;            // default 'default'
  onIssue?: (r: IssueUpsertResult) => void | Promise<void>;  // new/regression only
  release?: string;
  environment?: string;
  fingerprint?: (error: Error, context: ErrorContext) => string | Promise<string>;
  maxRecent?: number;          // default 100
  maxFingerprints?: number;    // default 1000
  clock?: () => number;
}) => ErrorTracker

import { Effect } from 'effect';
import {
	createErrorTracker,
	createMemoryIssueStore
} from '@absolutejs/errors';

const errors = createErrorTracker({
	environment: 'production',
	onIssue: (r) => alert(r.issue), // fires only on new / regression
	project: 'acme',
	release: process.env.RELEASE,
	store: createMemoryIssueStore() // or @absolutejs/errors-postgres
});

// Effect API (primary):
const outcome = await Effect.runPromise(
	errors.capture(e, {
		tags: { component: 'billing' },
		target: `order_${orderId}`,
		tenant
	})
);

// Promise edge — identical outcome:
const out = await errors.captureException(e);

if (out.failures.length > 0) {
	for (const f of out.failures) {
		switch (f._tag) {
			case 'StoreFailure':
				retryLater(f.cause); // f.cause: IssueStoreError
				break;
			case 'AuditSinkFailure':
				page('audit lost', f.cause);
				break;
			case 'TracerFailure':
			case 'OnIssueFailure':
			case 'FingerprintFailure':
				break; // tolerate
		}
	}
}

return new Response(`error ${out.fingerprint}`, { status: 500 });