agentmsg

type Kind string

type LifecyclePayload struct {
	MessageID string `json:"message_id"`
	Kind      Kind   `json:"kind"`
	Synopsis  string `json:"synopsis"`
	// ContentRef is the durable body reference when the body was stored.
	// Empty when body was empty.
	ContentRef string `json:"content_ref,omitempty"`
}

type Message struct {
	ID        string    `json:"id"`
	RunID     string    `json:"run_id"`
	Kind      Kind      `json:"kind"`
	From      Party     `json:"from"`
	To        Party     `json:"to"`
	InReplyTo string    `json:"in_reply_to,omitempty"`
	Body      string    `json:"body"`
	Refs      []string  `json:"refs,omitempty"`
	CreatedAt time.Time `json:"created_at"`
	// Interrupt marks a mid-step steer: the receiving task should stop its
	// current step and act on this steer immediately. Only KindSteer may
	// carry it (enforced by Validate).
	Interrupt bool `json:"interrupt,omitempty"`
}

type Options struct {
	// MaxBodyBytes bounds Body. Zero means DefaultMaxBodyBytes.
	MaxBodyBytes int
	// Now overrides the clock (tests). Nil uses time.Now.
	Now func() time.Time
	// ID overrides minted ID (tests). Empty mints a new durable ID.
	ID string
	// InReplyTo links an answer (or ask reply) to a prior message ID.
	InReplyTo string
	// Interrupt marks the message as a mid-step interrupt steer.
	Interrupt bool
}

type Party struct {
	TaskID string `json:"task_id,omitempty"`
	Agent  string `json:"agent,omitempty"`
	Role   string `json:"role,omitempty"`
}

type RouteAction string

type RouteDecision struct {
	Action RouteAction
	Reason string // set when Action == RouteDecline
}

type RouteInput struct {
	FromRole string
	ToRole   string
	// Blocking is true when the asker waits (wait_seconds > 0).
	Blocking bool
	// TargetRunning is true when a same-run task with ToRole is live.
	TargetRunning bool
	// AsksUsedByTask is asks already posted by the asker task this attempt.
	AsksUsedByTask int
	// ReferralSpawnsUsed is referral-as-spawn count for the run so far.
	ReferralSpawnsUsed int
	// ChainDepth is ancestor hop count for this ask (0 = first hop).
	ChainDepth int
	// Cycle is true when ToRole already appears in the ancestor chain.
	Cycle bool
}

type RoutingPolicy struct {
	Mode                    string   // "policy" | "parent"
	MaxAsksPerTask          int      // default 4
	MaxReferralDepth        int      // default 2
	Allow                   []string // "from->to"; empty = any live pair; non-empty all-malformed list declines, never any-live
	MaxReferralSpawnsPerRun int      // default 4
}