shared

type AnalysisResult struct {
	Status          *Status
	RateLimitHit    bool
	ErrorSignature  string
	OutputSize      int
	CompletionCount int

	// Stream metadata (populated by AnalyzeStreamResult, zero when using AnalyzeOutput).
	NumTurns     int
	TotalCostUSD float64
	DurationMS   int
}

type AssistantEvent struct {
	Type            EventType        `json:"type"`
	UUID            string           `json:"uuid,omitempty"`
	SessionID       string           `json:"session_id"`
	ParentToolUseID *string          `json:"parent_tool_use_id"`
	Message         AssistantMessage `json:"message"`
}

type AssistantMessage struct {
	ID         string         `json:"id"`
	Role       string         `json:"role"`
	Model      string         `json:"model"`
	StopReason string         `json:"stop_reason"`
	Content    []ContentBlock `json:"content"`
	Usage      *TokenUsage    `json:"usage,omitempty"`
}

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

type CircuitBreakerConfig struct {
	StagnationThreshold       int
	SameErrorThreshold        int
	OutputDeclineThreshold    int
	MaxConsecutiveTestLoops   int
	CompletionThreshold       int
	SafetyCompletionThreshold int
}

type CircuitBreakerState struct {
	NoProgressCount            int    `json:"no_progress_count"`
	Tripped                    bool   `json:"tripped"`
	TripReason                 string `json:"trip_reason,omitempty"`
	SameErrorCount             int    `json:"same_error_count"`
	LastErrorSignature         string `json:"last_error_signature,omitempty"`
	DeclineCount               int    `json:"decline_count"`
	LastOutputSize             int    `json:"last_output_size"`
	ConsecutiveTestLoops       int    `json:"consecutive_test_loops"`
	ConsecutiveCompletionCount int    `json:"consecutive_completion_count"`
}

type CircuitHistory struct {
	Project string                `json:"project"`
	Agent   string                `json:"agent"`
	Entries []CircuitHistoryEntry `json:"entries"`
}

type CircuitHistoryEntry struct {
	Timestamp       time.Time `json:"timestamp"`
	FromState       string    `json:"from_state"` // closed, tripped
	ToState         string    `json:"to_state"`
	Reason          string    `json:"reason,omitempty"`
	NoProgressCount int       `json:"no_progress_count"`
	SameErrorCount  int       `json:"same_error_count,omitempty"`
	TestLoopCount   int       `json:"test_loop_count,omitempty"`
	CompletionCount int       `json:"completion_count,omitempty"`
}

type CircuitState struct {
	Project         string     `json:"project"`
	Agent           string     `json:"agent"`
	NoProgressCount int        `json:"no_progress_count"`
	Tripped         bool       `json:"tripped"`
	TripReason      string     `json:"trip_reason,omitempty"`
	TrippedAt       *time.Time `json:"tripped_at,omitempty"`
	UpdatedAt       time.Time  `json:"updated_at"`
}

type CompactMetadata struct {
	Trigger   string `json:"trigger"`
	PreTokens int    `json:"pre_tokens"`
}

type ConcurrencyAction int

type ConcurrencyCheckConfig struct {
	// Client is the Docker client for listing containers.
	Client *docker.Client

	// Project is the project name to check.
	Project string

	// WorkDir is the current absolute host working directory.
	WorkDir string

	// IOStreams is used for warning output.
	IOStreams *iostreams.IOStreams

	// Prompter returns the interactive prompter. Nil means non-interactive.
	Prompter func() *prompter.Prompter
}

type Config struct {
	MaxLoops                  int  `yaml:"max_loops" mapstructure:"max_loops"`
	StagnationThreshold       int  `yaml:"stagnation_threshold" mapstructure:"stagnation_threshold"`
	TimeoutMinutes            int  `yaml:"timeout_minutes" mapstructure:"timeout_minutes"`
	AutoConfirm               bool `yaml:"auto_confirm" mapstructure:"auto_confirm"`
	CallsPerHour              int  `yaml:"calls_per_hour" mapstructure:"calls_per_hour"`
	CompletionThreshold       int  `yaml:"completion_threshold" mapstructure:"completion_threshold"`
	SessionExpirationHours    int  `yaml:"session_expiration_hours" mapstructure:"session_expiration_hours"`
	SameErrorThreshold        int  `yaml:"same_error_threshold" mapstructure:"same_error_threshold"`
	OutputDeclineThreshold    int  `yaml:"output_decline_threshold" mapstructure:"output_decline_threshold"`
	MaxConsecutiveTestLoops   int  `yaml:"max_consecutive_test_loops" mapstructure:"max_consecutive_test_loops"`
	LoopDelaySeconds          int  `yaml:"loop_delay_seconds" mapstructure:"loop_delay_seconds"`
	SafetyCompletionThreshold int  `yaml:"safety_completion_threshold" mapstructure:"safety_completion_threshold"`
}

type ContainerStartConfig struct {
	ContainerID string
	Cleanup     func()
}

type ContentBlock struct {
	Type string `json:"type"`

	// Text block: populated when Type == "text".
	Text string `json:"text,omitempty"`

	// Tool use block: populated when Type == "tool_use".
	ID    string          `json:"id,omitempty"`
	Name  string          `json:"name,omitempty"`
	Input json.RawMessage `json:"input,omitempty"`

	// Tool result block: populated when Type == "tool_result".
	// Content is json.RawMessage because the API sends either a string or an array.
	ToolUseID string          `json:"tool_use_id,omitempty"`
	Content   json.RawMessage `json:"content,omitempty"`
	IsError   bool            `json:"is_error,omitempty"`

	// Thinking block: populated when Type == "thinking".
	Thinking string `json:"thinking,omitempty"`
}

type EventType string

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

type HookConfig map[string][]HookMatcherGroup

type HookHandler struct {
	Type    string `json:"type"`
	Command string `json:"command,omitempty"`
	Prompt  string `json:"prompt,omitempty"`
	Timeout int    `json:"timeout,omitempty"`
}

type HookMatcherGroup struct {
	Matcher string        `json:"matcher,omitempty"`
	Hooks   []HookHandler `json:"hooks"`
}

type LoopContainerConfig struct {
	// Client is the Docker client.
	Client *docker.Client

	Command []string

	// Config is the config.Config interface providing Project(), Settings(), etc.
	Config config.Config

	// ProjectName is the resolved project name (from project.ProjectManager).
	// Empty string when no project is registered.
	ProjectName string

	// LoopOpts holds the shared loop flags (agent, image, worktree, etc.).
	LoopOpts *LoopOptions

	// Flags is the command's pflag.FlagSet for Changed() detection.
	Flags *pflag.FlagSet

	// Version is the clawker build version.
	Version string

	// ProjectManager returns the project manager for worktree registration.
	ProjectManager func() (project.ProjectManager, error)

	// HostProxy returns the host proxy service.
	HostProxy func() hostproxy.HostProxyService

	// Firewall returns the firewall manager.
	Firewall func(context.Context) (firewall.FirewallManager, error)

	// SocketBridge returns the socket bridge manager.
	SocketBridge func() socketbridge.SocketBridgeManager

	// IOStreams is the I/O streams for spinner output during creation.
	IOStreams *iostreams.IOStreams

	// Log is the file logger for diagnostic output.
	Log *logger.Logger
}

type LoopContainerResult struct {
	// ContainerID is the Docker container ID.
	ContainerID string

	// ContainerName is the full container name (clawker.project.agent).
	ContainerName string

	// AgentName is the resolved agent name.
	AgentName string

	// ProjectName is the resolved project name (from project.ProjectManager).
	ProjectName string

	// ProjectCfg is the project configuration.
	ProjectCfg *config.Project

	// WorkDir is the host working directory for this session.
	WorkDir string
}

type LoopDashEvent struct {
	Kind          LoopDashEventKind
	Iteration     int
	MaxIterations int
	AgentName     string
	Project       string

	// Status (populated on IterEnd)
	StatusText     string
	TasksCompleted int
	FilesModified  int
	TestsStatus    string
	ExitSignal     bool

	// Circuit breaker
	CircuitProgress  int
	CircuitThreshold int
	CircuitTripped   bool

	// Rate limiter
	RateRemaining int
	RateLimit     int

	// Timing
	IterDuration time.Duration

	// Completion
	ExitReason string
	Error      error

	// Session totals
	TotalTasks int
	TotalFiles int

	// Cost/token data (populated on IterEnd from ResultEvent)
	IterCostUSD float64
	IterTokens  int
	IterTurns   int

	// Output
	OutputChunk string
	OutputKind  OutputKind
}

type LoopDashEventKind int

type LoopDashboardConfig struct {
	AgentName string
	Project   string
	MaxLoops  int
}

type LoopDashboardResult struct {
	Err         error // display error only
	Detached    bool  // user pressed q/Esc — loop continues, switch to minimal output
	Interrupted bool  // user pressed Ctrl+C — stop the loop
}

type LoopOptions struct {
	// Loop control
	MaxLoops            int
	StagnationThreshold int
	TimeoutMinutes      int
	LoopDelay           int

	// Circuit breaker tuning
	SameErrorThreshold        int
	OutputDeclineThreshold    int
	MaxConsecutiveTestLoops   int
	SafetyCompletionThreshold int
	CompletionThreshold       int
	StrictCompletion          bool

	// Execution
	SkipPermissions bool
	CallsPerHour    int
	ResetCircuit    bool

	// Hooks
	HooksFile string

	// System prompt
	AppendSystemPrompt string

	// Container — Agent is set programmatically by iterate/tasks run functions
	// (auto-generated via loop.GenerateAgentName), not exposed as a CLI flag.
	// Status and reset commands register their own --agent flag independently.
	Agent    string
	Worktree string
	Image    string

	// Output
	Verbose bool
}

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

type MonitorOptions struct {
	// Writer is where monitor output goes (typically os.Stderr).
	Writer io.Writer

	// MaxLoops is the total max loops for progress calculation.
	MaxLoops int

	// ShowRateLimit shows rate limiter status if enabled.
	ShowRateLimit bool

	// RateLimiter to query for status.
	RateLimiter *RateLimiter

	// Verbose enables detailed output.
	Verbose bool
}

type Options struct {
	// CreateContainer creates a new container for each iteration.
	// Returns a ContainerStartConfig with the container ID and cleanup function.
	CreateContainer func(ctx context.Context) (*ContainerStartConfig, error)

	// ProjectCfg is the project configuration.
	ProjectCfg *config.Project

	// ProjectName is the project identity string used for session/circuit
	// storage keys and container naming. Resolved from project.ProjectManager
	// at command level; empty string when no project is registered.
	ProjectName string

	// Agent is the agent name.
	Agent string

	// Prompt is the prompt used for each iteration (-p flag).
	Prompt string

	// MaxLoops is the maximum number of loops to run.
	MaxLoops int

	// StagnationThreshold is how many loops without progress before tripping.
	StagnationThreshold int

	// Timeout is the per-loop timeout.
	Timeout time.Duration

	// ResetCircuit resets the circuit breaker before starting.
	ResetCircuit bool

	// CallsPerHour is the rate limit (0 to disable).
	CallsPerHour int

	// CompletionThreshold is the number of completion indicators required.
	CompletionThreshold int

	// SessionExpirationHours is the session TTL (0 for default).
	SessionExpirationHours int

	// SameErrorThreshold is how many same-error loops before tripping.
	SameErrorThreshold int

	// OutputDeclineThreshold is the percentage decline that triggers trip.
	OutputDeclineThreshold int

	// MaxConsecutiveTestLoops is how many test-only loops before tripping.
	MaxConsecutiveTestLoops int

	// LoopDelaySeconds is the delay between loop iterations.
	LoopDelaySeconds int

	// SafetyCompletionThreshold is loops with completion indicators but no exit signal before trip.
	SafetyCompletionThreshold int

	// UseStrictCompletion requires both EXIT_SIGNAL and completion indicators.
	UseStrictCompletion bool

	// SkipPermissions passes --dangerously-skip-permissions to claude.
	SkipPermissions bool

	// SystemPrompt is the full system prompt appended via --append-system-prompt.
	// Built by BuildSystemPrompt() which combines the default LOOP_STATUS
	// instructions with any user-provided additional instructions.
	SystemPrompt string

	// Monitor is the optional monitor for live output.
	Monitor *Monitor

	// WorkDir is the host working directory for this session.
	WorkDir string

	// Logger is the diagnostic file logger (from Factory).
	Logger *logger.Logger

	// Verbose enables verbose logging.
	Verbose bool

	// OnLoopStart is called before each loop iteration.
	OnLoopStart func(loopNum int)

	// OnLoopEnd is called after each loop iteration with optional cost data.
	OnLoopEnd func(loopNum int, status *Status, resultEvent *ResultEvent, err error)

	// OnOutput is called with text output chunks during execution.
	OnOutput func(chunk []byte)

	// OnStreamEvent is called for each raw streaming event (content_block_start,
	// content_block_delta, etc.). Enables rich TUI updates like tool activity
	// indicators. When set alongside OnOutput, both fire independently.
	OnStreamEvent func(*StreamDeltaEvent)

	// OnRateLimitHit is called when Claude's API limit is detected.
	// Return true to wait and retry, false to exit.
	OnRateLimitHit func() bool
}

type OutputKind int

type RateLimitState struct {
	Calls       int       `json:"calls"`
	WindowStart time.Time `json:"window_start"`
}

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

type Result struct {
	// LoopsCompleted is the number of loops that ran.
	LoopsCompleted int

	// FinalStatus is the last parsed status.
	FinalStatus *Status

	// ExitReason describes why the loop exited.
	ExitReason string

	// Session is the final session state.
	Session *Session

	// Error is set if the loop exited due to an error.
	Error error

	// RateLimitHit is true if the loop hit Claude's API rate limit.
	RateLimitHit bool
}

type ResultEvent struct {
	Type          EventType   `json:"type"`
	Subtype       string      `json:"subtype"`
	SessionID     string      `json:"session_id"`
	IsError       bool        `json:"is_error"`
	DurationMS    int         `json:"duration_ms"`
	DurationAPIMS int         `json:"duration_api_ms"`
	NumTurns      int         `json:"num_turns"`
	TotalCostUSD  float64     `json:"total_cost_usd"`
	Usage         *TokenUsage `json:"usage,omitempty"`

	// Success-only fields.
	Result string `json:"result,omitempty"`

	// Error-only fields.
	Errors []string `json:"errors,omitempty"`
}

type ResultOutput struct {
	LoopsCompleted      int    `json:"loops_completed"`
	ExitReason          string `json:"exit_reason"`
	Success             bool   `json:"success"`
	Error               string `json:"error,omitempty"`
	TotalTasksCompleted int    `json:"total_tasks_completed,omitempty"`
	TotalFilesModified  int    `json:"total_files_modified,omitempty"`
	FinalStatus         string `json:"final_status,omitempty"`
	RateLimitHit        bool   `json:"rate_limit_hit,omitempty"`
}

type RunLoopConfig struct {
	Runner      *Runner
	RunnerOpts  Options
	TUI         interface{} // unused after refactor, kept for API compat (TODO: remove)
	IOStreams   *iostreams.IOStreams
	Setup       *LoopContainerResult
	Format      *cmdutil.FormatFlags
	Verbose     bool
	CommandName string // "iterate" or "tasks"
}

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

type Session struct {
	// Project is the clawker project name.
	Project string `json:"project"`

	// Agent is the agent name.
	Agent string `json:"agent"`

	// WorkDir is the host working directory for this session.
	WorkDir string `json:"work_dir,omitempty"`

	// StartedAt is when the session started.
	StartedAt time.Time `json:"started_at"`

	// UpdatedAt is when the session was last updated.
	UpdatedAt time.Time `json:"updated_at"`

	// LoopsCompleted is the number of loops completed.
	LoopsCompleted int `json:"loops_completed"`

	// Status is the last known status.
	Status string `json:"status"`

	// NoProgressCount is the current count without progress.
	NoProgressCount int `json:"no_progress_count"`

	// TotalTasksCompleted is the cumulative tasks completed.
	TotalTasksCompleted int `json:"total_tasks_completed"`

	// TotalFilesModified is the cumulative files modified.
	TotalFilesModified int `json:"total_files_modified"`

	// LastError is the last error message, if any.
	LastError string `json:"last_error,omitempty"`

	// InitialPrompt is the prompt that started the session.
	InitialPrompt string `json:"initial_prompt,omitempty"`

	// RateLimitState tracks the rate limiter state for persistence.
	RateLimitState *RateLimitState `json:"rate_limit_state,omitempty"`
}

type SessionHistory struct {
	Project string                `json:"project"`
	Agent   string                `json:"agent"`
	Entries []SessionHistoryEntry `json:"entries"`
}

type SessionHistoryEntry struct {
	Timestamp time.Time `json:"timestamp"`
	Event     string    `json:"event"` // created, updated, expired, deleted, repeated_error
	LoopCount int       `json:"loop_count"`
	Status    string    `json:"status,omitempty"`
	Error     string    `json:"error,omitempty"`
}

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

type Status struct {
	// Status is one of: IN_PROGRESS, COMPLETE, BLOCKED
	Status string

	// TasksCompleted is the number of tasks completed in this loop.
	TasksCompleted int

	// FilesModified is the number of files modified in this loop.
	FilesModified int

	// TestsStatus is one of: PASSING, FAILING, NOT_RUN
	TestsStatus string

	// WorkType describes the type of work done (IMPLEMENTATION, TESTING, etc.)
	WorkType string

	// ExitSignal indicates whether Claude requested to exit the loop.
	ExitSignal bool

	// Recommendation is a one-line recommendation for next steps.
	Recommendation string

	// CompletionIndicators is the count of completion phrases found in output.
	CompletionIndicators int
}

type StreamAPIEvent struct {
	Type         string              `json:"type"` // message_start, content_block_start, content_block_delta, content_block_stop, message_delta, message_stop
	Index        int                 `json:"index,omitempty"`
	ContentBlock *StreamContentBlock `json:"content_block,omitempty"`
	Delta        *StreamDelta        `json:"delta,omitempty"`
	Message      *StreamMessageDelta `json:"message,omitempty"`
	Usage        *TokenUsage         `json:"usage,omitempty"`
}

type StreamContentBlock struct {
	Type string `json:"type"`           // "text", "tool_use"
	ID   string `json:"id,omitempty"`   // block ID
	Name string `json:"name,omitempty"` // tool name when Type == "tool_use"
}

type StreamDelta struct {
	Type        string `json:"type"`                   // "text_delta", "input_json_delta"
	Text        string `json:"text,omitempty"`         // text content when Type == "text_delta"
	PartialJSON string `json:"partial_json,omitempty"` // partial JSON when Type == "input_json_delta"
}

type StreamDeltaEvent struct {
	Type            EventType      `json:"type"`
	UUID            string         `json:"uuid,omitempty"`
	SessionID       string         `json:"session_id"`
	ParentToolUseID *string        `json:"parent_tool_use_id"`
	Event           StreamAPIEvent `json:"event"`
}

type StreamHandler struct {
	// OnSystem is called for system events (init, compact_boundary).
	OnSystem func(*SystemEvent)

	// OnAssistant is called for each complete assistant message.
	OnAssistant func(*AssistantEvent)

	// OnUser is called for each tool result message.
	OnUser func(*UserEvent)

	// OnResult is called when the final result event arrives.
	OnResult func(*ResultEvent)

	// OnStreamEvent is called for real-time streaming events (token deltas).
	// Requires --include-partial-messages flag.
	OnStreamEvent func(*StreamDeltaEvent)
}

type StreamMessageDelta struct {
	StopReason string `json:"stop_reason,omitempty"`
}

type SystemEvent struct {
	Type           EventType `json:"type"`
	UUID           string    `json:"uuid,omitempty"`
	Subtype        string    `json:"subtype"`
	SessionID      string    `json:"session_id"`
	Model          string    `json:"model,omitempty"`
	Tools          []string  `json:"tools,omitempty"`
	CWD            string    `json:"cwd,omitempty"`
	PermissionMode string    `json:"permissionMode,omitempty"`

	// CompactBoundary-only fields.
	CompactMetadata *CompactMetadata `json:"compact_metadata,omitempty"`
}

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

type TokenUsage struct {
	InputTokens              int `json:"input_tokens"`
	OutputTokens             int `json:"output_tokens"`
	CacheCreationInputTokens int `json:"cache_creation_input_tokens,omitempty"`
	CacheReadInputTokens     int `json:"cache_read_input_tokens,omitempty"`
}

type UpdateResult struct {
	Tripped       bool
	Reason        string
	IsComplete    bool // True if strict completion criteria met
	CompletionMsg string
}

type UserEvent struct {
	Type            EventType        `json:"type"`
	UUID            string           `json:"uuid,omitempty"`
	SessionID       string           `json:"session_id"`
	ParentToolUseID *string          `json:"parent_tool_use_id"`
	Message         UserEventMessage `json:"message"`
}

type UserEventMessage struct {
	Role    string         `json:"role"`
	Content []ContentBlock `json:"content"`
}