agent

type Action string

type Agent struct {
	ID           string         `yaml:"id"`
	Name         string         `yaml:"name"`
	Type         string         `yaml:"type"`
	Process      string         `yaml:"process"` // The process this agent handles
	Description  string         `yaml:"description,omitempty"`
	Version      string         `yaml:"version,omitempty"`
	Instructions string         `yaml:"instructions,omitempty"`
	Scaling      *ScalingConfig `yaml:"scaling,omitempty"`
	Status       Status         `yaml:"status"`
	TaskID       string         `yaml:"task_id,omitempty"`
	ProcessName  string         `yaml:"process_name,omitempty"` // Currently executing process
	WorktreePath string         `yaml:"worktree_path,omitempty"`
	CreatedAt    time.Time      `yaml:"created_at"`
	UpdatedAt    time.Time      `yaml:"updated_at"`
	// contains filtered or unexported fields
}

type AgentConfig struct {
	Name         string         `yaml:"name"`
	Type         string         `yaml:"type"`
	Process      string         `yaml:"process"` // The process this agent handles (e.g., "implement", "review", "qa")
	Instructions string         `yaml:"instructions,omitempty"`
	Scaling      *ScalingConfig `yaml:"scaling,omitempty"`
}

type AgentRegistry interface {
	GetAgentsByName(name string) []*Agent
	CreateAgent(config *AgentConfig) (*Agent, error)
	RemoveAgent(agentID string) error
	ListAgents() []*Agent
}

type ApprovalRequest struct {
	AgentID   string
	Action    Action
	Target    string
	Details   map[string]interface{}
	Response  chan bool
	Timestamp time.Time
}

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

type BaseExecutor struct {
	Config ExecutorConfig
	// contains filtered or unexported fields
}

type ClaudeCodeExecutor struct {
	BaseExecutor
	// contains filtered or unexported fields
}

type Config struct {
	Agents []*AgentConfig `yaml:"agents"`
}

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

type ExecutionResult struct {
	Success    bool
	NextStatus string
	Message    string
	Artifacts  []string
	Error      error
}

type Executor interface {
	// Initialize the executor with configuration
	Initialize(ctx context.Context, config ExecutorConfig) error

	// Connect establishes a persistent connection (for streaming executors)
	Connect(ctx context.Context) error

	// Disconnect closes the persistent connection
	Disconnect() error

	// IsConnected returns true if the executor has an active connection
	IsConnected() bool

	// Execute a work item (task or event)
	Execute(ctx context.Context, work *WorkItem) (*ExecutionResult, error)

	// Check if the executor can handle this work item
	CanExecute(work *WorkItem) bool

	// Cleanup resources
	Cleanup() error
}

type ExecutorConfig struct {
	AgentID      string
	Name         string
	Process      string // The process type this executor handles
	Instructions string
	WorktreePath string

	// Permission handling
	PermissionRequestChan  chan<- PermissionRequest  // Channel to send permission requests
	PermissionResponseChan <-chan PermissionResponse // Channel to receive permission responses

	// Dependency injection
	TaskService     task.Service
	EventBus        *event.EventBus
	WorktreeManager *worktree.Manager
}

type ExecutorFactory interface {
	CreateExecutor(executorType string) (Executor, error)
}

type IndividualAgentConfig struct {
	Name         string         `yaml:"name"`
	Type         string         `yaml:"type"`
	Process      string         `yaml:"process"` // The process this agent handles
	Scaling      *ScalingConfig `yaml:"scaling,omitempty"`
	Description  string         `yaml:"description,omitempty"`
	Version      string         `yaml:"version,omitempty"`
	Instructions string         `yaml:"instructions,omitempty"`
}

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

type PermissionRequest struct {
	ID        string                 // Unique request ID
	ToolName  string                 // Tool being requested (e.g., "Bash", "Write", "Edit")
	Input     map[string]interface{} // Tool input parameters
	TaskID    string                 // Associated task ID
	AgentID   string                 // Agent making the request
	Timestamp int64                  // Request timestamp
}

type PermissionResponse struct {
	RequestID    string                 // Matching request ID
	Allowed      bool                   // Whether the action is allowed
	Message      string                 // Optional message (e.g., reason for denial)
	UpdatedInput map[string]interface{} // Optional: modified input parameters
}

type ScalingConfig struct {
	Min  int  `yaml:"min"`
	Max  int  `yaml:"max"`
	Auto bool `yaml:"auto"`
}

type Status string

type WorkItem struct {
	ID          string
	Task        *task.Task
	ProcessName string // The process being executed (e.g., "implement", "review", "qa")
	Context     map[string]interface{}
}