collaboration

type Binding struct {
	ParentOwner string
	// Closing only authorizes transcript finalization, never model/tool execution.
	Closing    bool
	Recovered  bool
	Runtime    *Runtime
	Scope      Scope
	Child      *Work
	Seen       int64
	WaitCursor int64
	WaitUntil  time.Time
	// HasInput probes durable steer without consuming it; the engine owns delivery.
	HasInput func(context.Context) (bool, error)
}

type Event struct {
	Sequence int64  `json:"sequence"`
	From     string `json:"from"`
	RunID    string `json:"run_id,omitempty"`
	Kind     string `json:"kind"`
	Content  string `json:"content"`
}

type Group struct {
	// Revision is the database CAS version, never a caller-provided JSON field.
	Revision        int64 `json:"-"`
	InputBytes      int
	SuccessorID     string // durable admission for a subsequent human turn
	ParentMessageID string
	ParentOwner     string
	ParentLease     time.Time
	ParentWait      *ParentWait
	// ParentClosePending keeps interrupted/expired parents recoverable until their transcript and stream are closed.
	ParentClosePending bool
	RootQuery          string
	Scope              Scope
	Status             string
	Members            []*Member
	Events             []Event
	Requests           map[string]string
	NextSequence       int64
	Deadline           time.Time
}

type Member struct {
	// Inherited instances remain addressable across parent turns but are not
	// current-turn UI tasks until explicitly continued.
	Inherited bool   `json:"inherited,omitempty"`
	ID        string `json:"member_id"`
	Name      string `json:"task_name"`
	AgentID   string `json:"agent_id"`
	SessionID string `json:"session_id"`
	// ConfigJSON is stored separately from the model-visible projection.
	ConfigJSON string  `json:"config_snapshot"`
	Runs       []*Run  `json:"runs"`
	Mail       []Event `json:"mail,omitempty"`
}

type MemberView struct {
	PreviousTurn    bool      `json:"previous_turn,omitempty"`
	Progress        *Progress `json:"progress,omitempty"`
	PromptID        string    `json:"prompt_id,omitempty"`
	ID              string    `json:"member_id"`
	Name            string    `json:"task_name"`
	AgentID         string    `json:"agent_id"`
	SessionID       string    `json:"session_id"`
	RunID           string    `json:"run_id"`
	Status          string    `json:"status"`
	CancelRequested bool      `json:"cancel_requested"`
}

type ParentWait struct {
	Snapshot []byte
	After    int64
	Until    time.Time
}

type Progress struct {
	Phase      string    `json:"phase"`
	ToolName   string    `json:"tool_name,omitempty"`
	ToolCallID string    `json:"tool_call_id,omitempty"`
	Iteration  int       `json:"iteration,omitempty"`
	UpdatedAt  time.Time `json:"updated_at"`
}

type PromptState struct {
	ID         string `json:"id"`
	Kind       string `json:"kind,omitempty"`
	Status     string `json:"status,omitempty"`
	ToolCallID string `json:"tool_call_id,omitempty"`
	Service    string `json:"service,omitempty"`
	Tool       string `json:"tool,omitempty"`
	Decision   string `json:"decision,omitempty"`
}

type Record struct {
	ID        string `gorm:"primaryKey;type:varchar(36)"`
	TenantID  uint64 `gorm:"not null"`
	UserID    string `gorm:"type:varchar(64);not null"`
	SessionID string `gorm:"type:varchar(36);not null"`
	Status    string `gorm:"type:varchar(32);not null;index"`
	Version   int64  `gorm:"not null"`
	Data      string `gorm:"type:text;not null"`
	UpdatedAt time.Time
}

type Result struct {
	// Artifacts are runtime-produced metadata, never parsed from model prose.
	Artifacts        types.MessageArtifacts `json:"artifacts,omitempty"`
	Truncated        bool                   `json:"truncated,omitempty"`
	Evidence         string                 `json:"evidence,omitempty"`
	Answer           string                 `json:"answer,omitempty"`
	Error            string                 `json:"error,omitempty"`
	MessageID        string                 `json:"message_id,omitempty"`
	ConsumedSequence int64                  `json:"consumed_sequence,omitempty"`
	Suspended        bool                   `json:"suspended,omitempty"`
}

type Run struct {
	// Inherited identifies a baseline run copied from an earlier parent turn.
	Inherited       bool         `json:"inherited,omitempty"`
	Prompt          *PromptState `json:"prompt,omitempty"`
	Progress        *Progress    `json:"progress,omitempty"`
	ID              string       `json:"run_id"`
	State           string       `json:"status"`
	Query           string       `json:"query"`
	Owner           string       `json:"-"`
	Lease           time.Time    `json:"lease_until"`
	Attempt         int          `json:"attempt"`
	CancelRequested bool         `json:"cancel_requested"`
	Result          Result       `json:"result"`
	// DeliveredSequence fences automatic followups even when the executor cannot return a result.
	DeliveredSequence int64  `json:"delivered_sequence,omitempty"`
	PromptID          string `json:"prompt_id,omitempty"`
	MessageID         string `json:"message_id,omitempty"`
	UserMessageID     string `json:"user_message_id,omitempty"`
}

type Runner func(context.Context, Work) (Result, error)

type Runtime struct {
	Store       *Store
	Run         Runner
	WakeParent  func(context.Context, *Binding, []byte) error
	Reconcile   func(context.Context, Scope) error
	ParentInput func(context.Context, Scope, string) (bool, error)
	// Prune bounds durable storage; it runs every PruneInterval.
	Prune         func(context.Context) error
	PruneInterval time.Duration
	Poll          time.Duration
	Lease         time.Duration
	// Concurrency bounds running children per group; MaxRunning bounds the
	// child executions this process runs across all groups.
	Concurrency int
	MaxRunning  int
	// contains filtered or unexported fields
}

type RuntimeNotice struct {
	Type           string `json:"type"`
	Source         string `json:"source"`
	Task           string `json:"task,omitempty"`
	RunID          string `json:"run_id,omitempty"`
	Sequence       int64  `json:"sequence"`
	PromptID       string `json:"prompt_id,omitempty"`
	PromptKind     string `json:"prompt_kind,omitempty"`
	ToolCallID     string `json:"tool_call_id,omitempty"`
	Service        string `json:"service,omitempty"`
	Tool           string `json:"tool,omitempty"`
	Decision       string `json:"decision,omitempty"`
	ExecutionState string `json:"execution_state,omitempty"`
	Message        string `json:"message,omitempty"`
}

type Scope struct {
	TenantID              uint64
	UserID, SessionID, ID string
}

type StatusSnapshot struct {
	GroupID  string       `json:"group_id"`
	Revision int64        `json:"revision"`
	Tasks    []TaskStatus `json:"tasks"`
}

type Store struct {

	// OnStatus runs after a successful commit, never inside a retried mutation.
	// Consumers must tolerate duplicate and out-of-order snapshots by revision.
	OnStatus func(context.Context, *Group)
	// contains filtered or unexported fields
}

type TaskStatus struct {
	ID            string    `json:"id"`
	Name          string    `json:"name"`
	DisplayName   string    `json:"display_name,omitempty"`
	AgentID       string    `json:"agent_id"`
	SessionID     string    `json:"session_id"`
	RunID         string    `json:"run_id"`
	Status        string    `json:"status"`
	Progress      *Progress `json:"progress,omitempty"`
	PromptID      string    `json:"prompt_id,omitempty"`
	LatestMessage string    `json:"latest_message,omitempty"`
}

type Work struct {
	Scope  Scope
	Member Member
	Run    Run
}