inspection

Import

Import

import * as api from "@fungi.computer/carrier/inspection";

Exports

Kind	Export	Description
Cclass	DeliveryInspectionError	Stable inspection errors never include stored cargo or raw SQL failures.
Ttype alias	DeliveryInspectionPageQuery	An email receipt page uses the same producer-key pagination.
Ttype alias	DeliveryInspectionQuery	Input to one producer-local inspection. Cursors are producer keys, without storage prefixes.
Ttype alias	PostReceiptSummary	Metadata for one retained Post row.
Ttype alias	PostInspectionPage	One read of producer-local Post dispatch evidence.
Ttype alias	CarrierInspectionPage	One read of aggregate email dispatch evidence.
constconstant	DeliveryInspectionPageQuerySchema	One bounded scan; an empty filtered page can still have a continuation.
constconstant	DeliveryInspectionQuerySchema	Post can filter dead letters while scanning at most one bounded page.
constconstant	PostReceiptSummarySchema	Dispatch evidence deliberately omits the address and event.
constconstant	PostInspectionPageSchema	Bounded evidence with an explicit distinction between empty and uninitialized storage.
constconstant	CarrierReceiptSummarySchema	Aggregate email evidence without bodies, headers or recipient addresses.
constconstant	CarrierInspectionPageSchema	Carrier’s bounded metadata page; unavailable storage is never reported as empty.
fnfunction	createDeliveryInspection()	Read existing storage without opening a sender, initializing tables, repairing jobs or arming a wake. The trusted host must admit an operator before calling.

DeliveryInspectionErrorCclass

Stable inspection errors never include stored cargo or raw SQL failures.

Extends

• Error

Constructors

Constructor

Signature

new DeliveryInspectionError(code): DeliveryInspectionError;

Parameters

Parameter	Type
code	"unavailable" | "invalid_query"

Returns

DeliveryInspectionError

Overrides

Signature

Error.constructor;

Properties

code

Signature

readonly code: "unavailable" | "invalid_query";

DeliveryInspectionPageQueryTtype alias

Signature

type DeliveryInspectionPageQuery = Schema.Codec.Encoded<
  typeof DeliveryInspectionPageQuerySchema
>;

An email receipt page uses the same producer-key pagination.

---

DeliveryInspectionQueryTtype alias

Signature

type DeliveryInspectionQuery = Schema.Codec.Encoded<
  typeof DeliveryInspectionQuerySchema
>;

Input to one producer-local inspection. Cursors are producer keys, without storage prefixes.

---

PostReceiptSummaryTtype alias

Signature

type PostReceiptSummary = Schema.Schema.Type<typeof PostReceiptSummarySchema>;

Metadata for one retained Post row.

---

PostInspectionPageTtype alias

Signature

type PostInspectionPage = Schema.Schema.Type<typeof PostInspectionPageSchema>;

One read of producer-local Post dispatch evidence.

---

CarrierInspectionPageTtype alias

Signature

type CarrierInspectionPage = Schema.Schema.Type<
  typeof CarrierInspectionPageSchema
>;

One read of aggregate email dispatch evidence.

DeliveryInspectionPageQuerySchemaconstconstant

Signature

const DeliveryInspectionPageQuerySchema: Struct<{
  limit: withDecodingDefaultType<Int, never>;
  after: optional<String>;
}>;

One bounded scan; an empty filtered page can still have a continuation.

---

DeliveryInspectionQuerySchemaconstconstant

Signature

const DeliveryInspectionQuerySchema: Struct<{
  limit: withDecodingDefaultType<Int, never>;
  after: optional<String>;
  view: Literals<readonly ["receipts", "deadLetters"]>;
}>;

Post can filter dead letters while scanning at most one bounded page.

---

PostReceiptSummarySchemaconstconstant

Signature

const PostReceiptSummarySchema: Union<
  readonly [
    Struct<{
      key: String;
      state: Literal<"delivered">;
    }>,
    Struct<{
      key: String;
      state: Literal<"pending">;
      kind: String;
      attempts: Int;
      nextAttemptAt: Number;
    }>,
    Struct<{
      key: String;
      state: Literal<"dead">;
      kind: String;
      attempts: Int;
      reason: Literals<readonly ["refused", "exhausted", "expired"]>;
    }>,
  ]
>;

Dispatch evidence deliberately omits the address and event.

---

PostInspectionPageSchemaconstconstant

Signature

const PostInspectionPageSchema: Union<readonly [Struct<{
  status: Literal<"uninitialized">;
}>, Struct<{
  status: Literal<"available">;
  records: $Array<Union<readonly [Struct<{
     key: String;
     state: Literal<"delivered">;
   }>, Struct<{
     key: String;
     state: Literal<"pending">;
     kind: String;
     attempts: Int;
     nextAttemptAt: Number;
   }>, Struct<{
     key: String;
     state: Literal<"dead">;
     kind: String;
     attempts: Int;
     reason: Literals<readonly [..., ..., ...]>;
  }>]>>;
  nextCursor: NullOr<String>;
}>]>;

Bounded evidence with an explicit distinction between empty and uninitialized storage.

---

CarrierReceiptSummarySchemaconstconstant

Signature

const CarrierReceiptSummarySchema: Struct<{
  id: String;
  status: Literals<
    readonly [
      "queued",
      "dispatching",
      "provider_accepted",
      "outcome_unknown",
      "rejected",
      "refused",
      "expired",
      "superseded",
    ]
  >;
  attempts: Int;
  retryAt: NullOr<Number>;
  providerMessageId: optional<NonEmptyString>;
  providerRejection: optional<
    Struct<{
      code: NonEmptyString;
      class: Literals<readonly ["permanent", "temporary"]>;
    }>
  >;
}>;

Aggregate email evidence without bodies, headers or recipient addresses.

---

CarrierInspectionPageSchemaconstconstant

Signature

const CarrierInspectionPageSchema: Union<readonly [Struct<{
  status: Literal<"uninitialized">;
}>, Struct<{
  status: Literal<"available">;
  records: $Array<Struct<{
     id: String;
     status: Literals<readonly ["queued", "dispatching", "provider_accepted", "outcome_unknown", "rejected", "refused", "expired", "superseded"]>;
     attempts: Int;
     retryAt: NullOr<Number>;
     providerMessageId: optional<NonEmptyString>;
     providerRejection: optional<Struct<{
        code: NonEmptyString;
        class: Literals<...>;
     }>>;
  }>>;
  nextCursor: NullOr<String>;
}>]>;

Carrier’s bounded metadata page; unavailable storage is never reported as empty.

createDeliveryInspection()fnfunction

Signature

function createDeliveryInspection(sql): object;

Read existing storage without opening a sender, initializing tables, repairing jobs or arming a wake. The trusted host must admit an operator before calling.

Parameters

Parameter	Type
sql	Readonly<{ exec: (statement, …bindings) => WatchdogSqliteCursor; }>

Returns

Name	Type	Description
email()	(input) => | { status: "uninitialized"; } | { status: "available"; records: readonly object[]; nextCursor: string | null; }	Read aggregate dispatch evidence without email cargo or recipient addresses.
post()	(input) => | { status: "uninitialized"; } | { status: "available"; records: readonly ( | { key: string; state: "delivered"; } | { key: string; state: "pending"; kind: string; attempts: number; nextAttemptAt: number; } | { key: string; state: "dead"; kind: string; attempts: number; reason: "expired" | "refused" | "exhausted"; })[]; nextCursor: string | null; }	Read Post metadata; filtered pages retain their continuation through other states.