refinery

type CloseReason string

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

type FailureType string

type MRStatus string

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

type MergeConfig struct {
	// RunTests controls whether tests are run after merge.
	// Default: true
	RunTests bool `json:"run_tests"`

	// TestCommand is the command to run for testing.
	// Default: "go test ./..."
	TestCommand string `json:"test_command"`

	// DeleteMergedBranches controls whether merged branches are deleted.
	// Default: true
	DeleteMergedBranches bool `json:"delete_merged_branches"`

	// PushRetryCount is the number of times to retry a failed push.
	// Default: 3
	PushRetryCount int `json:"push_retry_count"`

	// PushRetryDelayMs is the base delay between push retries in milliseconds.
	// Each retry doubles the delay (exponential backoff).
	// Default: 1000
	PushRetryDelayMs int `json:"push_retry_delay_ms"`
}

type MergeQueueConfig struct {
	// Enabled controls whether the merge queue is active.
	Enabled bool `json:"enabled"`

	// TargetBranch is the default branch to merge to (e.g., "main").
	TargetBranch string `json:"target_branch"`

	// IntegrationBranches enables per-epic integration branches.
	IntegrationBranches bool `json:"integration_branches"`

	// OnConflict is the strategy for handling conflicts: "assign_back" or "auto_rebase".
	OnConflict string `json:"on_conflict"`

	// RunTests controls whether to run tests before merging.
	RunTests bool `json:"run_tests"`

	// TestCommand is the command to run for testing.
	TestCommand string `json:"test_command"`

	// DeleteMergedBranches controls whether to delete branches after merge.
	DeleteMergedBranches bool `json:"delete_merged_branches"`

	// RetryFlakyTests is the number of times to retry flaky tests.
	RetryFlakyTests int `json:"retry_flaky_tests"`

	// PollInterval is how often to check for new MRs.
	PollInterval time.Duration `json:"poll_interval"`

	// MaxConcurrent is the maximum number of MRs to process concurrently.
	MaxConcurrent int `json:"max_concurrent"`
}

type MergeRequest struct {
	// ID is a unique identifier for this merge request.
	ID string `json:"id"`

	// Branch is the source branch name (e.g., "polecat/Toast/gt-abc").
	Branch string `json:"branch"`

	// Worker is the polecat that created this branch.
	Worker string `json:"worker"`

	// IssueID is the beads issue being worked on.
	IssueID string `json:"issue_id"`

	// SwarmID is the swarm this work belongs to (if any).
	SwarmID string `json:"swarm_id,omitempty"`

	// TargetBranch is where this should merge (usually integration or main).
	TargetBranch string `json:"target_branch"`

	// CreatedAt is when the MR was queued.
	CreatedAt time.Time `json:"created_at"`

	// Status is the current status of the merge request.
	Status MRStatus `json:"status"`

	// CloseReason indicates why the MR was closed (only set when Status=closed).
	CloseReason CloseReason `json:"close_reason,omitempty"`

	// Error contains error details if the MR failed.
	Error string `json:"error,omitempty"`
}

type MergeResult struct {
	Success     bool
	MergeCommit string // SHA of merge commit on success
	Error       string
	Conflict    bool
	TestsFailed bool
}

type ProcessResult struct {
	Success     bool
	MergeCommit string
	Error       string
	Conflict    bool
	TestsFailed bool
}

type QueueItem struct {
	Position int           `json:"position"`
	MR       *MergeRequest `json:"mr"`
	Age      string        `json:"age"`
}

type Refinery struct {
	// RigName is the rig this refinery processes.
	RigName string `json:"rig_name"`

	// State is the current running state.
	State State `json:"state"`

	// PID is the process ID if running in background.
	PID int `json:"pid,omitempty"`

	// StartedAt is when the refinery was started.
	StartedAt *time.Time `json:"started_at,omitempty"`

	// CurrentMR is the merge request currently being processed.
	CurrentMR *MergeRequest `json:"current_mr,omitempty"`

	// PendingMRs tracks merge requests that have been submitted.
	// Key is the MR ID.
	PendingMRs map[string]*MergeRequest `json:"pending_mrs,omitempty"`

	// LastMergeAt is when the last successful merge happened.
	LastMergeAt *time.Time `json:"last_merge_at,omitempty"`
}

type State = agent.State