mcp

type ClaimInfo struct {
	WorkerID  string `json:"worker_id"`
	ClaimedAt string `json:"claimed_at"` // RFC3339
	Duration  string `json:"duration"`
}

type ClaimResult struct {
	IssueNumber int    `json:"issue_number"`
	Owner       string `json:"owner"`
	Repo        string `json:"repo"`
	WorkerID    string `json:"worker_id"`
	ClaimedAt   string `json:"claimed_at"` // RFC3339
	Phase       string `json:"phase,omitempty"`
}

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

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

type HeartbeatResult struct {
	ClaimDuration string `json:"claim_duration"`
	Status        string `json:"status"`
}

type PendingAction struct {
	ID        string
	ToolName  string
	Execute   func() (*gosdk.CallToolResult, error) // closure captures handler + input
	CreatedAt time.Time
}

type Project struct {
	Name      string                   `json:"name" yaml:"name"`
	Owner     string                   `json:"owner" yaml:"owner"`
	Repo      string                   `json:"repo" yaml:"repo"`
	Phase     string                   `json:"phase" yaml:"phase"`
	Tags      []string                 `json:"tags,omitempty" yaml:"tags"`
	Tracker   forge.IssueTracker       `json:"-" yaml:"-"`
	Reader    forge.RepoReader         `json:"-" yaml:"-"`
	Writer    forge.RepoWriter         `json:"-" yaml:"-"`
	PRManager forge.PullRequestManager `json:"-" yaml:"-"`
}

type ProjectConfig struct {
	Name       string   `yaml:"name"`
	Owner      string   `yaml:"owner"`
	Repo       string   `yaml:"repo"`
	Forge      string   `yaml:"forge"`       // "github" (default) or "gitea"
	GiteaURL   string   `yaml:"gitea_url"`   // required when forge = "gitea"
	GiteaToken string   `yaml:"gitea_token"` // optional; falls back to GITEA_TOKEN env var
	Phase      string   `yaml:"phase"`       // lifecycle phase; defaults to "development"
	Tags       []string `yaml:"tags"`        // optional classification tags
}

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

type WorkCoordinator interface {
	// ClaimIssue claims a specific issue for an interactive worker.
	ClaimIssue(ctx context.Context, owner, repo string, number int, workerID string) (*ClaimResult, error)

	// RequestWork finds the next best queued issue matching filters and claims it.
	RequestWork(ctx context.Context, workerID string, opts *WorkRequestOptions) (*ClaimResult, *forge.Issue, error)

	// CompleteIssue marks a claimed issue as done (status:claimed -> status:needs-qc).
	CompleteIssue(ctx context.Context, owner, repo string, number int, workerID string, prNumber int, summary string) error

	// ReleaseIssue returns a claimed issue to the queue without completing it.
	ReleaseIssue(ctx context.Context, owner, repo string, number int, workerID string, reason string) error

	// HeartbeatIssue resets the heartbeat timer for a claimed issue.
	HeartbeatIssue(ctx context.Context, owner, repo string, number int, workerID string) (*HeartbeatResult, error)

	// GetClaimInfo returns claim info for an issue, or nil if not claimed.
	GetClaimInfo(owner, repo string, number int) *ClaimInfo
}

type WorkRequestOptions struct {
	Project    string
	Labels     []string
	Priority   string
	Complexity string
}

type WorkerInfo struct {
	AgentID         string
	Hostname        string
	Status          string
	CurrentTask     *int
	ActiveWorktrees int
	CPUPercent      float64
	MemoryPercent   float64
}