serve

type EventJournalPage ¶

type EventJournalPage struct {
	Events         []StatusEvent `json:"events"`
	NextJournalSeq uint64        `json:"next_journal_seq"`
	Done           bool          `json:"done"`
}

EventJournalPage is the GET /v1/sessions/{sid}/journal response: a page of a session's Enduring events in journal-sequence order plus the resume cursor. NextJournalSeq is the sequence to pass as from_journal_seq to fetch the next page (set only when more may remain); Done reports the journal was exhausted (fewer than Limit events remained). GatePrepared never appears — the event replayer filters it.

type InvalidAddrError ¶

type InvalidAddrError struct {
	Addr  string
	Cause error
}

InvalidAddrError reports that the bind address handed to Server is malformed (e.g. missing port) and could not be parsed by net.SplitHostPort. The bind fails secure and returns nothing. Cause is the underlying parse error, exposed via Unwrap; the message carries ONLY the offending Addr — never a secret.

func (e InvalidAddrError) Error() string

func (e InvalidAddrError) Unwrap() error

type InvalidParamError ¶

type InvalidParamError struct {
	Param  string
	Reason string
}

InvalidParamError reports that an HTTP path- or query-supplied parameter failed validation at the request boundary. It carries the parameter name and a client-safe Reason; handlers map it to HTTP 400 with a generic message. Typed (per CLAUDE.md) so callers errors.As it to distinguish bad input from other failures. Reason is a fixed, non-sensitive string (never echoes the raw value).

func (e InvalidParamError) Error() string

type JournalPage ¶

type JournalPage struct {
	From  uint64
	Limit int
}

JournalPage is the cursor/limit window a journal read requests. From is the inclusive journal sequence to begin at (0 = from the beginning); Limit is the maximum number of Enduring events to return. Both are validated at the HTTP boundary before a JournalPage is built.

type LiveSession ¶

type LiveSession interface {
	SessionID() uuid.UUID
	Submit(ctx context.Context, blocks []content.Block) (uuid.UUID, error)
	SubscribeEvents(filter event.EventFilter) (event.Subscription, error)
	RespondGate(ctx context.Context, response gate.GateResponse) error
	Interrupt(ctx context.Context) (bool, error)
}

LiveSession is the narrow, HTTP-facing view of a running session: the exact method set an HTTP handler needs to drive one session and nothing more (Interface Segregation). session.SessionController satisfies it structurally at the composition root; serve never imports or names that contract in production.

• Submit queues human-authored input to the session's primary loop and returns the minted input id (fire-and-forget; the outcome is observed on the event stream, correlated by that id).
• SubscribeEvents attaches a filtered consumer to the session fan-in; the caller Closes the returned Subscription when done.
• RespondGate delivers a human's answer to an open approval gate.
• Interrupt cancels every in-flight turn in the session, reporting whether any running turn was actually cancelled.

type LoopNotFoundError ¶

type LoopNotFoundError struct {
	LoopID uuid.UUID
}

LoopNotFoundError reports that no loop exists for the requested loop id within a session. It maps to HTTP 404. The LoopID is for the audit log only.

func (e LoopNotFoundError) Error() string

type NonPublicEventError ¶

type NonPublicEventError struct {
	Visibility event.EventVisibility
}

NonPublicEventError reports that an event reached an outward serialization boundary without public visibility. Visibility is retained for errors.As-based audit handling; Error deliberately omits event type and payload details.

func (e *NonPublicEventError) Error() string

type Option ¶

type Option func(*config)

Option mutates a config during construction (the functional-options pattern). Every Option is fail-safe: an invalid argument leaves the corresponding secure default in place rather than weakening the configuration.

func WithAuth(authn func(*http.Request) error) Option

func WithMaxBodyBytes(n int64) Option

type Page ¶

type Page struct {
	Skip  int
	Limit int
}

Page is the offset/limit window a session-list read requests. Skip is the number of entries to drop from the front of the stable-sorted list; Limit is the maximum number to return. Both are validated (non-negative, Limit hard-capped) at the HTTP boundary before a Page is built, so a Reader implementation may trust them.

type PublicBindWithoutAuthError ¶

type PublicBindWithoutAuthError struct {
	Addr string
}

PublicBindWithoutAuthError reports a fail-secure refusal to bind a non-loopback address without authentication configured (used by P1-10's bind path; defined here so the typed error exists). Its message carries ONLY the offending Addr — never any credential or secret.

func (e PublicBindWithoutAuthError) Error() string

type Reader ¶

type Reader interface {
	ListSessions(ctx context.Context, page Page) (SessionList, error)
	ReadStatus(ctx context.Context, id uuid.UUID) (SessionStatus, error)
	ReadJournal(ctx context.Context, id uuid.UUID, page JournalPage) (EventJournalPage, error)
}

Reader is the narrow, stateless read plane over persisted session history. It is the seam serve's read handlers depend on (Dependency Inversion): serve declares the interface and the DTOs, and a concrete adapter (pkg/serve/catalogreader) wires it over the session store WITHOUT serve importing any store package. Every method is a pure read — it consults durable projection/history only, never a live in-process session — so any pod can serve a read and no live session need exist.

• ListSessions returns a stable-sorted, offset-paged slice of session summaries.
• ReadStatus returns one session's public projected status (no replay). It returns a SessionNotFoundError when the session has no catalog entry.
• ReadJournal returns a cursor-paged slice of the session's public Enduring events. Serve validates both event-bearing results again before writing.

type Rig ¶

type Rig[S LiveSession, O any] interface {
	NewSession(ctx context.Context, opts ...O) (S, error)
	RestoreSession(ctx context.Context, id uuid.UUID) (S, error)
}

Rig is the narrow session-factory view serve depends on. It is generic over the concrete live-session type S (constrained to LiveSession) so a caller keeps the real type through NewSession/RestoreSession without serve importing it: the composition root instantiates Rig[session.SessionController, rig.SessionOption], while serve remains independent of both concrete packages.

• NewSession brings up a brand-new live session that exposes its minted ID.
• RestoreSession rebuilds a prior session from its durable history by id.

type ServerOption ¶

type ServerOption func(*serverConfig)

ServerOption mutates a serverConfig during Server construction (the functional- options pattern). Every option is fail-safe: it can only relax the bind guard via an explicit opt-in, never silently.

func WithInsecurePublicBind() ServerOption

type SessionDone ¶ added in v0.30.0

type SessionDone interface {
	// Done returns a channel closed once the session has begun shutting down. It never
	// reopens, and a receive means "admits no new work", not "cleanup finished".
	Done() <-chan struct{}
}

SessionDone is the OPTIONAL liveness extension of LiveSession: a session that can report its own death exposes a channel closed once its shutdown has begun.

It is deliberately separate from LiveSession rather than folded into it. A session is drivable whether or not it can report death, so requiring the method would force every implementor (tui, acp, consumer fakes) to grow one for a capability most of them do not have — an Interface Segregation violation, and a compile break across three repositories for one optional bit. Being structural, it also means session.SessionController need not widen: serve type-asserts the DYNAMIC type, and *sessionruntime.Session satisfies it today.

Absence is not death. A session that does not satisfy SessionDone is treated as live forever, which is exactly today's behaviour; only a session that opts in can be evicted. A wrapper around a live session MUST forward Done, or it silently opts its wrapped session out and reintroduces the corpse-pinning leak this exists to fix.

type SessionList ¶

type SessionList struct {
	Sessions []SessionSummary `json:"sessions"`
	Skip     int              `json:"skip"`
	Limit    int              `json:"limit"`
	NextSkip int              `json:"next_skip"`
	Done     bool             `json:"done"`
}

SessionList is the GET /v1/sessions response: a page of summaries plus the paging cursor a client resumes from. Skip/Limit echo the request window; NextSkip is the Skip to pass for the next page (set only when more may remain); Done reports the end of the list was reached (the page returned fewer than Limit entries).

type SessionNotFoundError ¶

type SessionNotFoundError struct {
	SessionID uuid.UUID
}

SessionNotFoundError reports that no session exists for the requested id. It maps to HTTP 404. The SessionID is carried for the audit log; the client sees only the generic envelope message.

func (e SessionNotFoundError) Error() string

type SessionStatus ¶

type SessionStatus struct {
	SessionID      uuid.UUID    `json:"session_id"`
	State          string       `json:"state,omitempty"`
	LastJournalSeq uint64       `json:"last_journal_seq"`
	ActiveTurnID   uuid.UUID    `json:"active_turn_id,omitzero"`
	WaitingGateID  uuid.UUID    `json:"waiting_gate_id,omitzero"`
	LastTurn       *StatusEvent `json:"last_turn,omitempty"`
	LastStep       *StatusEvent `json:"last_step,omitempty"`
	UpdatedAt      time.Time    `json:"updated_at,omitzero"`
}

SessionStatus is the GET /v1/sessions/{sid}/status response: one session's projected lifecycle status, read from the catalog projection with NO journal replay. State is the lifecycle fold (running/waiting_on_gate/idle/failed/ interrupted/stopped); ActiveTurnID and WaitingGateID are zero (omitted) unless a turn is running or a gate is open; LastTurn/LastStep are the codec-safe summaries of the most recent terminal turn and completed step; UpdatedAt is the projection's most-recent-activity instant.

type SessionSummary ¶

type SessionSummary struct {
	SessionID    uuid.UUID `json:"session_id"`
	State        string    `json:"state,omitempty"`
	Title        string    `json:"title,omitempty"`
	CreatedAt    time.Time `json:"created_at,omitzero"`
	LastActiveAt time.Time `json:"last_active_at,omitzero"`
}

SessionSummary is one row of a session list: the small, picker-facing projection of a session's catalog entry. It is deliberately narrow (Interface Segregation) — a list caller needs an identity, a lifecycle state, and recency, not the full status projection (LastTurn/LastStep replay-safe summaries live on SessionStatus).

type StatusEvent ¶

type StatusEvent struct {
	JournalSeq uint64
	Event      event.Event
}

StatusEvent pairs a durable journal sequence with the concrete event recorded at that sequence. Event is the event.Event INTERFACE, which encoding/json cannot serialize directly (an interface has no stable wire shape), so StatusEvent defines a custom MarshalJSON that emits the codec-safe {journal_seq, event} shape with the event serialized by event.MarshalEvent (the single durable-envelope authority). It is a write-only DTO — the read plane serializes it outward and never decodes it.

func (s StatusEvent) MarshalJSON() ([]byte, error)

type StoreReadError ¶

type StoreReadError struct {
	Op    string
	Cause error
}

StoreReadError reports that a read-plane backend operation failed. It maps to HTTP 500. Op names the failed operation (e.g. "list", "get") for the log; the Cause is wrapped for errors.As/Is and is NEVER written to the response body.

func (e StoreReadError) Error() string

func (e StoreReadError) Unwrap() error