nativeturn

type Config struct {
	// TurnDeadline is the hard wall-clock ceiling on a single turn (belt 2).
	// A turn still running when it elapses is terminated with a context
	// deadline. Must be > 0.
	TurnDeadline time.Duration
	// GraceWindow is how long an in-flight turn survives with no viewer
	// attached before it is cancelled and torn down (belt 1); a reattach
	// inside the window keeps it alive. Must be > 0.
	GraceWindow time.Duration
	// JournalSize bounds the per-session replay journal (belt 3): the most
	// recent JournalSize events are retained, dropped oldest-first. Zero or
	// negative resolves to DefaultJournalSize in New.
	JournalSize int
}

type Event struct {
	// Seq is the 1-based monotonic id of this event within its session's
	// turn. Increases by one per emitted update, never repeats or reorders.
	Seq uint64
	// Update is the session/update notification as emitted by the turn,
	// before any per-viewer normalization.
	Update libacp.SessionNotification
}

type Registry struct {
	// contains filtered or unexported fields
}

type Result struct {
	// StopReason is the ACP stop reason the connected client's prompt resolves with.
	StopReason libacp.StopReason
	// Err is a genuine execution failure the client must see as a JSON-RPC
	// error. Nil for a clean end and for a cancellation, which resolves with
	// StopReasonCancelled and no error.
	Err error
	// Suspended marks a turn whose chain parked on a pending human approval:
	// not a failure (Err is nil), and status reads StateSuspended instead of
	// StateFinished until reaped.
	Suspended bool
}

type Turn struct {
	// contains filtered or unexported fields
}

type TurnFunc func(ctx context.Context, emit func(ctx context.Context, n libacp.SessionNotification)) Result

type TurnStatus struct {
	SessionID libacp.SessionID `json:"sessionId"`
	StartedAt time.Time        `json:"startedAt"`
	// Deadline is the hard wall-clock time this turn is terminated at (belt 2).
	Deadline time.Time `json:"deadline"`
	// Viewers is how many viewers are attached right now (0 in StateGrace).
	Viewers int `json:"viewers"`
	// State is one of StateRunning / StateGrace / StateFinished.
	State string `json:"state"`
}

type Viewer interface {
	// ID uniquely identifies this viewer within a session. Two viewers on
	// one session must not share an ID.
	ID() string

	// Deliver receives one turn event, in order: the replayed journal
	// backlog on attach, then every live event.
	//
	// It must not block — it runs on the turn's fan-out path under the
	// session lock, so a blocking call stalls the turn and every other
	// viewer. Enqueue and return. The returned error is advisory only.
	Deliver(ctx context.Context, ev Event) error
}