crewrun

type APIError struct {
	Status int
	Code   string
}

type AgentBudget struct {
	MonthlyUSD float64 `json:"monthly_usd"`
	AskOverUSD float64 `json:"ask_over_usd,omitempty"`
}

type CaptureClaim struct {
	Subject string `json:"subject"`
	Text    string `json:"text"`
	Kind    string `json:"kind"`
	Basis   string `json:"basis"`
	Reason  string `json:"reason"`
}

type Client struct {
	BaseURL   string
	TokenFile string
	Scope     Scope
	HTTP      *http.Client
}

type Config struct {
	Listen   string
	LockPath string
	Engine   *Engine
}

type Crew struct {
	Research     *CrewResearch `json:"research,omitempty"`
	Type         string        `json:"type"`
	Name         string        `json:"name"`
	Handle       string        `json:"handle,omitempty"`
	Model        string        `json:"model,omitempty"`
	Instructions string        `json:"instructions,omitempty"`
	Skills       []string      `json:"skills,omitempty"`
	Trigger      *Trigger      `json:"trigger,omitempty"`
	Enabled      bool          `json:"enabled,omitempty"`
	Limits       *Limits       `json:"limits,omitempty"`
	Graph        *Graph        `json:"graph,omitempty"`
	Notify       *CrewNotify   `json:"notify,omitempty"` // 진행 알림 (progress.go)
	// work agents (type agent, or template saved before agents) and teams, for meetings
	Role            string            `json:"role,omitempty"`
	Effort          string            `json:"effort,omitempty"`
	ModelMode       string            `json:"model_mode,omitempty"`
	FallbackModel   string            `json:"fallback_model,omitempty"`
	MaxOutputTokens int               `json:"max_output_tokens,omitempty"`
	OutputFormat    string            `json:"output_format,omitempty"`
	Backend         string            `json:"backend,omitempty"` // the host runner's agent-runner connection (expert)
	Budget          *AgentBudget      `json:"budget,omitempty"`
	Members         []TeamMember      `json:"members,omitempty"`
	Mode            string            `json:"mode,omitempty"`
	Ending          *TeamEnding       `json:"ending,omitempty"`
	Context         []TeamContext     `json:"context,omitempty"`
	Templates       []MeetingTemplate `json:"templates,omitempty"`
}

type CrewItem struct {
	ID       string `json:"id"`
	Revision int64  `json:"revision"`
	Crew     Crew   `json:"crew"`
}

type CrewNotify struct {
	Channels []NotifyChannel `json:"channels,omitempty"`
	Moments  []string        `json:"moments,omitempty"` // start | step | approval | fail | end; empty = all but step
}

type CrewResearch struct {
	QuickNode        string `json:"quick_node"`
	DeepNode         string `json:"deep_node"`
	DeepAlias        string `json:"deep_alias"`
	EvidenceStrategy string `json:"evidence_strategy"`
	HelperOrigin     string `json:"helper_origin"`
}

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

type Decision struct {
	Approve   bool      `json:"approve"`
	Note      string    `json:"note,omitempty"`
	DecidedBy string    `json:"decided_by"`
	DecidedAt time.Time `json:"decided_at"`
}

type Edge struct {
	From string `json:"from"`
	Port string `json:"port,omitempty"`
	To   string `json:"to"`
	Max  int    `json:"max,omitempty"`
}

type Engine struct {
	Store Store
	Now   func() time.Time
	Loc   *time.Location
	Log   *slog.Logger
	// DefaultModel runs AI nodes when neither the node nor the workflow names a model.
	DefaultModel string
	// Runner is the AI node command prefix; the engine appends
	// "run-node --json" and writes the node spec as JSON on stdin.
	Runner      []string
	Sandbox     []string
	GH          string
	KeysFile    string
	NotifyFile  string
	NotifyScope string // "<workspace>/<project>": the runner's own destinations in NotifyFile
	HooksFile   string
	PublicURL   string
	TelegramAPI string
	HTTP        *http.Client
	CodeTimeout time.Duration

	// Traces records each finished run as an execution trace with its own producer credential and
	// hands the receipt to Sinks (see receipts.go); either unset leaves runs untraced.
	Traces *Client
	Sinks  []ReceiptSink

	// Meetings drives team meetings when set (FromEnv sets the Arkism client).
	Meetings MeetingStore
	// MeetingAI replaces the run-node call of a meeting turn (tests).
	MeetingAI func(context.Context, aiSpec) (aiAnswer, error)
	// contains filtered or unexported fields
}

type FlowAttemptRequest struct {
	NodeID          string `json:"node_id"`
	Attempt         int    `json:"attempt"`
	CallKey         string `json:"call_key"`
	Model           string `json:"model"`
	MaxInputTokens  int64  `json:"max_input_tokens"`
	MaxOutputTokens int64  `json:"max_output_tokens"`
}

type FlowAttemptReservation struct {
	ID              string  `json:"id"`
	Status          string  `json:"status"`
	DispatchAllowed bool    `json:"dispatch_allowed"`
	ReservedTokens  int64   `json:"reserved_tokens"`
	ReservedCostUSD float64 `json:"reserved_cost_usd"`
	CostKnown       bool    `json:"cost_known"`
}

type FlowAttemptSettlement struct {
	Status       string   `json:"status"`
	InputTokens  int64    `json:"input_tokens"`
	OutputTokens int64    `json:"output_tokens"`
	UsageKnown   bool     `json:"usage_known"`
	Estimated    bool     `json:"estimated"`
	CostUSD      *float64 `json:"cost_usd,omitempty"`
}

type FlowAttemptStore interface {
	ReserveFlowAttempt(context.Context, Run, FlowAttemptRequest) (FlowAttemptReservation, error)
	SettleFlowAttempt(context.Context, Run, string, FlowAttemptSettlement) error
}

type FlowChild struct {
	Kind     string `json:"kind"`
	ID       string `json:"id"`
	CrewID   string `json:"crew_id"`
	NodeID   string `json:"node_id"`
	Attempt  int    `json:"attempt"`
	Required bool   `json:"required"`
}

type FlowChildCreated struct {
	Parent Run       `json:"parent"`
	Child  FlowChild `json:"child"`
}

type FlowChildRequest struct {
	NodeID  string `json:"node_id"`
	Attempt int    `json:"attempt"`
	Kind    string `json:"kind"`
	CrewID  string `json:"crew_id"`
	Input   string `json:"input"`
}

type FlowChildStore interface {
	CreateFlowChild(context.Context, Run, FlowChildRequest) (FlowChildCreated, error)
	CancelFlowChildren(context.Context, Run) error
}

type FlowEffectReceipt struct {
	Status       string `json:"status"`
	HTTPStatus   int    `json:"http_status"`
	ResponseHash string `json:"response_hash,omitempty"`
}

type FlowEffectRequest struct {
	NodeID     string `json:"node_id"`
	Attempt    int    `json:"attempt"`
	Adapter    string `json:"adapter"`
	TargetHash string `json:"target_hash"`
	ArgsHash   string `json:"args_hash"`
	Preview    string `json:"preview"`
}

type FlowEffectStore interface {
	PrepareFlowEffect(context.Context, Run, FlowEffectRequest) (FlowEffectView, error)
	ClaimFlowEffect(context.Context, Run, FlowEffectView, string) (FlowEffectView, error)
	SettleFlowEffect(context.Context, Run, FlowEffectView, FlowEffectReceipt) error
}

type FlowEffectView struct {
	ID              string `json:"id"`
	EffectHash      string `json:"effect_hash"`
	Status          string `json:"status"`
	DispatchAllowed bool   `json:"dispatch_allowed"`
}

type FlowLease struct {
	LeaseUntil      time.Time `json:"lease_until"`
	CancelRequested bool      `json:"cancel_requested"`
}

type FlowLeaseStore interface {
	LeaseRun(context.Context, string, string, string) (FlowLease, error)
}

type FlowPolicy struct {
	MaxDepth      int     `json:"max_depth"`
	MaxChildren   int     `json:"max_children"`
	MaxConcurrent int     `json:"max_concurrent"`
	MaxTokens     int64   `json:"max_tokens,omitempty"`
	MaxCostUSD    float64 `json:"max_cost_usd,omitempty"`
}

type Graph struct {
	Nodes []Node `json:"nodes"`
	Edges []Edge `json:"edges"`
}

type Limits struct {
	MaxSteps   int `json:"max_steps,omitempty"`
	MaxMinutes int `json:"max_minutes,omitempty"`
}

type Meeting struct {
	RootID          string             `json:"root_id,omitempty"`
	ParentID        string             `json:"parent_id,omitempty"`
	ParentNodeID    string             `json:"parent_node_id,omitempty"`
	Status          string             `json:"status"`
	TeamID          string             `json:"team_id"`
	TeamRevision    int64              `json:"team_revision"`
	TeamSnapshot    *MeetingSnapshot   `json:"team_snapshot,omitempty"`
	Title           string             `json:"title"`
	Topic           string             `json:"topic"`
	TemplateKey     string             `json:"template_key,omitempty"`
	Trigger         string             `json:"trigger"`
	Round           int                `json:"round"`
	MaxRounds       int                `json:"max_rounds"`
	Speaking        string             `json:"speaking,omitempty"`
	Turns           []MeetingTurn      `json:"turns"`
	NotesPending    []MeetingNote      `json:"notes_pending"`
	TokensUsed      int64              `json:"tokens_used"`
	TokenCap        int64              `json:"token_cap,omitempty"`
	CostUSD         float64            `json:"cost_usd"`
	CostEstimateUSD float64            `json:"cost_estimate_usd,omitempty"`
	Conclusion      *MeetingConclusion `json:"conclusion,omitempty"`
	EndedReason     string             `json:"ended_reason,omitempty"`
	Waiting         *MeetingWaiting    `json:"waiting,omitempty"`
	Saved           *MeetingSaved      `json:"saved,omitempty"`
	Discord         json.RawMessage    `json:"discord,omitempty"`
	BudgetApproved  json.RawMessage    `json:"budget_approved,omitempty"`
	LeaseUntil      *time.Time         `json:"lease_until,omitempty"`
}

type MeetingConclusion struct {
	Summary       string   `json:"summary"`
	Decisions     []string `json:"decisions"`
	Todos         []string `json:"todos"`
	OpenQuestions []string `json:"open_questions"`
}

type MeetingCreator interface {
	CreateMeeting(ctx context.Context, teamID, title, topic string) (MeetingRecord, error)
}

type MeetingNote struct {
	By   string    `json:"by"`
	Text string    `json:"text"`
	At   time.Time `json:"at"`
}

type MeetingRecord struct {
	ID       string  `json:"id"`
	Revision int64   `json:"revision"`
	Meeting  Meeting `json:"crew_meeting"`
}

type MeetingSaved struct {
	CaptureEventID string   `json:"capture_event_id,omitempty"`
	CandidateIDs   []string `json:"candidate_ids,omitempty"`
}

type MeetingSnapshot struct {
	Team   Crew            `json:"team"`
	Agents map[string]Crew `json:"agents"`
}

type MeetingStore interface {
	ListMeetings(ctx context.Context, status string) ([]MeetingRecord, error)
	GetMeeting(ctx context.Context, id string) (MeetingRecord, error)
	UpdateMeeting(ctx context.Context, r MeetingRecord, lease string) (MeetingRecord, error)
	// Capture sends claims for one event and returns the candidate ids made.
	Capture(ctx context.Context, eventID string, claims []CaptureClaim, model string) ([]string, error)
	// AgentSpend is each agent's estimated spend over the last 30 days.
	AgentSpend(ctx context.Context) (map[string]float64, error)
	// ContextText is the text of one record a team reads before it meets.
	ContextText(ctx context.Context, collection, id string) (string, error)
}

type MeetingTemplate struct {
	Key       string `json:"key"`
	Name      string `json:"name"`
	Prompt    string `json:"prompt,omitempty"`
	Overrides *struct {
		Mode   string      `json:"mode,omitempty"`
		Ending *TeamEnding `json:"ending,omitempty"`
	} `json:"overrides,omitempty"`
}

type MeetingTurn struct {
	Seq          int        `json:"seq"`
	Round        int        `json:"round"`
	AgentID      string     `json:"agent_id,omitempty"`
	Speaker      string     `json:"speaker"`
	Model        string     `json:"model,omitempty"`
	Kind         string     `json:"kind"`
	Stance       string     `json:"stance,omitempty"`
	Text         string     `json:"text"`
	InputTokens  int64      `json:"input_tokens,omitempty"`
	OutputTokens int64      `json:"output_tokens,omitempty"`
	CostUSD      float64    `json:"cost_usd,omitempty"`
	Estimated    bool       `json:"estimated,omitempty"`
	StartedAt    *time.Time `json:"started_at,omitempty"`
	FinishedAt   *time.Time `json:"finished_at,omitempty"`
	OK           bool       `json:"ok"`
	Error        string     `json:"error,omitempty"`
}

type MeetingWaiting struct {
	Kind   string    `json:"kind"`
	Reason string    `json:"reason,omitempty"`
	At     time.Time `json:"at"`
}

type Node struct {
	ID     string            `json:"id"`
	Type   string            `json:"type"`
	Title  string            `json:"title,omitempty"`
	Config map[string]string `json:"config,omitempty"`
}

type NodeState struct {
	Status     string     `json:"status"`
	Port       string     `json:"port,omitempty"`
	StartedAt  *time.Time `json:"started_at,omitempty"`
	FinishedAt *time.Time `json:"finished_at,omitempty"`
	Output     string     `json:"output,omitempty"`
	Error      string     `json:"error,omitempty"`
	Runs       int        `json:"runs,omitempty"`   // starts of this node in the run
	Tokens     int64      `json:"tokens,omitempty"` // AI tokens (input + output) of its last finish
	// Backend is the agent-runner trace of a step sent to a connection (names and ids only, never text).
	Backend map[string]any `json:"backend,omitempty"`
}

type NotifyChannel struct {
	Kind    string `json:"kind"`    // discord | telegram | slack
	Channel string `json:"channel"` // notify.json destination name ("#ops" → "ops"); unknown → "default"
	When    string `json:"when"`    // events | approval | report
}

type NotifyConfig struct {
	Telegram map[string]struct {
		BotToken string `json:"bot_token"`
		ChatID   string `json:"chat_id"`
	} `json:"telegram"`
	Slack map[string]struct {
		WebhookURL string `json:"webhook_url"`
	} `json:"slack"`
	Email map[string]struct {
		Host string   `json:"host"`
		Port string   `json:"port"`
		User string   `json:"user"`
		Pass string   `json:"pass"`
		From string   `json:"from"`
		To   []string `json:"to"`
	} `json:"email"`
}

type ReceiptSink func(TraceReceipt) error

type Ref struct {
	Collection string `json:"collection"`
	ID         string `json:"id"`
	Revision   int64  `json:"revision"`
}

type Run struct {
	LeaseToken string   `json:"-"`
	ID         string   `json:"id"`
	Revision   int64    `json:"revision"`
	State      RunState `json:"crew_run"`
	// CreatedByType tells a run a person started from the desktop (시험 실행·지금 실행) apart from the engine's own.
	CreatedByType string `json:"created_by_type,omitempty"`
}

type RunState struct {
	Effects         map[string]string     `json:"effects,omitempty"`
	SourceType      string                `json:"source_type,omitempty"`
	RootID          string                `json:"root_id,omitempty"`
	ParentID        string                `json:"parent_id,omitempty"`
	ParentNodeID    string                `json:"parent_node_id,omitempty"`
	Depth           int                   `json:"depth,omitempty"`
	Children        map[string]FlowChild  `json:"children,omitempty"`
	Definitions     map[string]CrewItem   `json:"definitions,omitempty"`
	Policy          *FlowPolicy           `json:"policy,omitempty"`
	ResearchMode    string                `json:"research_mode,omitempty"`
	InvocationMode  string                `json:"invocation_mode,omitempty"`
	Definition      *Crew                 `json:"definition,omitempty"`
	Origin          map[string]string     `json:"origin,omitempty"`
	CancelRequested bool                  `json:"cancel_requested,omitempty"`
	CrewID          string                `json:"crew_id"`
	CrewRevision    int64                 `json:"crew_revision"`
	Trigger         string                `json:"trigger"`
	Status          string                `json:"status"`
	Input           string                `json:"input,omitempty"`
	Nodes           map[string]*NodeState `json:"nodes"`
	Waiting         *Waiting              `json:"waiting,omitempty"`
	Decisions       map[string]Decision   `json:"decisions,omitempty"`
	Summary         string                `json:"summary,omitempty"`
	Only            string                `json:"only,omitempty"`  // run this one node, skip the rest
	Loops           map[string]int        `json:"loops,omitempty"` // back edge uses, keyed "from>to:port"
	Deadline        *time.Time            `json:"deadline,omitempty"`
}

type Scope struct {
	WorkspaceID string `json:"workspace_id"`
	ProjectID   string `json:"project_id"`
	UserID      string `json:"user_id,omitempty"`
	AgentID     string `json:"agent_id,omitempty"`
}

type Store interface {
	ListCrew(ctx context.Context) ([]CrewItem, error)
	ListRuns(ctx context.Context, status string, limit int) ([]Run, error)
	GetRun(ctx context.Context, id string) (Run, error)
	CreateRun(ctx context.Context, st RunState) (Run, error)
	UpdateRun(ctx context.Context, r Run) (Run, error)
}

type TeamContext struct {
	Collection string `json:"collection"`
	ID         string `json:"id"`
	Title      string `json:"title,omitempty"`
	Share      string `json:"share"`
}

type TeamEnding struct {
	MaxRounds        int   `json:"max_rounds"`
	TokenCap         int64 `json:"token_cap,omitempty"`
	EndOnAllApproved bool  `json:"end_on_all_approved,omitempty"`
	EndOnModerator   bool  `json:"end_on_moderator,omitempty"`
}

type TeamMember struct {
	AgentID       string `json:"agent_id"`
	Order         int    `json:"order"`
	Role          string `json:"role"`
	Focus         string `json:"focus,omitempty"`
	ModelOverride string `json:"model_override,omitempty"`
}

type TraceReceipt struct {
	Scope        map[string]string `json:"scope"`
	SessionID    string            `json:"session_id"`
	Trace        Ref               `json:"trace"`
	Run          Ref               `json:"run"`
	SourceEvents []Ref             `json:"source_events"`
	OccurredAt   string            `json:"occurred_at"`
}

type Trigger struct {
	Kind string `json:"kind"`
	Cron string `json:"cron,omitempty"`
}

type Waiting struct {
	EffectID      string     `json:"effect_id,omitempty"`
	EffectHash    string     `json:"effect_hash,omitempty"`
	ChildRunID    string     `json:"child_run_id,omitempty"`
	ChildKind     string     `json:"child_kind,omitempty"`
	ChildRevision int64      `json:"child_revision,omitempty"`
	DecisionKind  string     `json:"decision_kind,omitempty"`
	NodeID        string     `json:"node_id"`
	Kind          string     `json:"kind"`
	ResumeAt      *time.Time `json:"resume_at,omitempty"`
	Question      string     `json:"question,omitempty"`
	CallbackHash  string     `json:"callback_hash,omitempty"`
}