ralph

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

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 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 HistoryStore struct {
	// contains filtered or unexported fields
}

type LoopOptions struct {
	// ContainerName is the full container name (clawker.project.agent).
	ContainerName string

	// Project is the project name.
	Project string

	// Agent is the agent name.
	Agent string

	// Prompt is the initial prompt (used only on first loop if provided).
	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

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

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

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

	// Verbose enables verbose logging.
	Verbose bool

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

	// OnLoopEnd is called after each loop iteration.
	OnLoopEnd func(loopNum int, status *Status, err error)

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

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

type LoopResult 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 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 RateLimitState struct {
	Calls       int       `json:"calls"`
	WindowStart time.Time `json:"window_start"`
}

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

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"`

	// 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
	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 UpdateResult struct {
	Tripped       bool
	Reason        string
	IsComplete    bool // True if strict completion criteria met
	CompletionMsg string
}