librelay

type AskPublished struct {
	AskID       string    `json:"ask_id"`
	SessionID   string    `json:"session_id,omitempty"`
	MissionID   string    `json:"mission_id,omitempty"`
	AgentName   string    `json:"agent_name,omitempty"`
	ToolsName   string    `json:"tools_name,omitempty"`
	ToolName    string    `json:"tool_name,omitempty"`
	PolicyName  string    `json:"policy_name,omitempty"`
	MatchedRule *int      `json:"matched_rule,omitempty"`
	ArgsSummary string    `json:"args_summary,omitempty"`
	ExpiresAt   time.Time `json:"expires_at,omitzero"`
}

type AskResolved struct {
	AskID  string `json:"ask_id"`
	Reason string `json:"reason"`
}

type AskVerdict struct {
	AskID     string    `json:"ask_id"`
	Decision  string    `json:"decision"`
	Answer    string    `json:"answer,omitempty"`
	Guidance  string    `json:"guidance,omitempty"`
	DecidedBy string    `json:"decided_by,omitempty"`
	DecidedAt time.Time `json:"decided_at,omitzero"`
}

type ChainTrigger struct {
	// RequestID correlates the [ChainTriggerResult] with this trigger.
	RequestID string `json:"request_id"`
	// Chain names the chain file on the machine's own configuration path.
	Chain     string `json:"chain"`
	AgentName string `json:"agent_name,omitempty"`
	// SessionMode is [ChainSessionNew] or [ChainSessionReused].
	SessionMode string `json:"session_mode"`
	SessionName string `json:"session_name,omitempty"`
	// Input is the event envelope the chain receives, raw.
	Input json.RawMessage `json:"input"`
	// Policy optionally names the HITL policy envelope for the run; empty applies the machine's own default.
	Policy string `json:"policy,omitempty"`
}

type ChainTriggerResult struct {
	// RequestID is [ChainTrigger.RequestID], echoed verbatim.
	RequestID string `json:"request_id"`
	// Status is one of the ChainTriggerStatus constants.
	Status string `json:"status"`
	// Error says why, for [ChainTriggerStatusError] and [ChainTriggerStatusRefused]; empty on ok.
	Error string `json:"error,omitempty"`
}

type Error struct {
	// Code is machine-readable; see the Code* constants.
	Code string `json:"code"`
	// Message is for humans and may change freely between versions.
	Message string `json:"message,omitempty"`
}

type Frame struct {
	// Type discriminates the frame; control types carry ControlPrefix, everything else is routed opaquely.
	Type string `json:"type"`
	// Instance is the runtime instance this frame concerns; empty only on frames that precede identification.
	Instance string `json:"instance,omitempty"`
	// Session names the stream within Instance that this frame concerns; empty on control traffic and anything instance-scoped.
	Session string `json:"session,omitempty"`
	// ID marks this frame as a request and correlates the reply; its presence obliges exactly one answer.
	ID string `json:"id,omitempty"`
	// ReplyTo carries the ID of the request being answered and marks this frame as a response.
	ReplyTo string `json:"re,omitempty"`
	// Seq is the producer's per-(Instance, Session) cursor for this frame, monotonically increasing and gap-free within a session; zero means unsequenced.
	Seq uint64 `json:"seq,omitempty"`
	// Trace is the correlation key for the one human action this frame belongs to; peer-supplied text that must never be authorized on. Empty means untraced.
	Trace string `json:"trace,omitempty"`
	// Payload is the message body, left as raw JSON; empty is legal.
	Payload json.RawMessage `json:"payload,omitempty"`
}

type Hello struct {
	// ProtocolVersion is the highest envelope version the connector speaks.
	ProtocolVersion int `json:"protocol_version"`
	// Instance identifies the runtime; also set on the frame.
	Instance string `json:"instance"`
	// Agent names the implementation and version, for operator diagnosis only.
	Agent string `json:"agent,omitempty"`
	// Nonce is a fresh random challenge the relay signs into [Welcome.Signature].
	Nonce []byte `json:"nonce,omitempty"`
}

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

type Resume struct {
	// AfterSeq is the last [Frame.Seq] the requester saw; zero asks for the whole retained stream.
	AfterSeq uint64 `json:"after_seq"`
}

type Resumed struct {
	// FromSeq is the first [Frame.Seq] that follows; greater than Resume.AfterSeq+1 only when Evicted is set.
	FromSeq uint64 `json:"from_seq"`
	// Evicted reports the requested cursor is older than what the producer retains.
	Evicted bool `json:"evicted,omitempty"`
}

type Welcome struct {
	// ProtocolVersion is the version the relay selected, min(peer, self); the connector must close if it's lower than it can speak.
	ProtocolVersion int `json:"protocol_version"`
	// Relay names the relay implementation and version, diagnostics only.
	Relay string `json:"relay,omitempty"`
	// Signature is Ed25519 over [SigningInput] of Hello.Nonce, ProtocolVersion and instance.
	Signature []byte `json:"sig,omitempty"`
	// RetryAfterSeconds hints how long to wait before redialling. Zero means the connector's own backoff applies.
	RetryAfterSeconds int `json:"retry_after,omitempty"`
}

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