claude

type CLIRunner ¶

type CLIRunner struct{}

CLIRunner implements Runner using the claude CLI.

func (r *CLIRunner) Run(ctx context.Context, database *db.DB, taskID string, prompt string, workDir string, cfg *project.Config) error

type ClaudeRunnerMock ¶

type ClaudeRunnerMock struct {
	// RunFunc mocks the Run method.
	RunFunc func(ctx context.Context, database *db.DB, taskID string, prompt string, workDir string, cfg *project.Config) error
	// contains filtered or unexported fields
}

ClaudeRunnerMock is a mock implementation of Runner.

func TestSomethingThatUsesRunner(t *testing.T) {

	// make and configure a mocked Runner
	mockedRunner := &ClaudeRunnerMock{
		RunFunc: func(ctx context.Context, database *db.DB, taskID string, prompt string, workDir string, cfg *project.Config) error {
			panic("mock out the Run method")
		},
	}

	// use mockedRunner in code that requires Runner
	// and then make assertions.

}

func (mock *ClaudeRunnerMock) Run(ctx context.Context, database *db.DB, taskID string, prompt string, workDir string, cfg *project.Config) error

func (mock *ClaudeRunnerMock) RunCalls() []struct {
	Ctx      context.Context
	Database *db.DB
	TaskID   string
	Prompt   string
	WorkDir  string
	Cfg      *project.Config
}

len(mockedRunner.RunCalls())

type DefaultOrchestratorManager ¶

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

DefaultOrchestratorManager is the default implementation of OrchestratorManager. It wraps the package-level functions and holds the database reference needed for orchestrator heartbeat checking.

func (m *DefaultOrchestratorManager) EnsureWorkOrchestrator(ctx context.Context, workID, projName, workDir, friendlyName string, w io.Writer) (bool, error)

func (m *DefaultOrchestratorManager) SpawnWorkOrchestrator(ctx context.Context, workID, projName, workDir, friendlyName string, w io.Writer) error

func (m *DefaultOrchestratorManager) TerminateWorkTabs(ctx context.Context, workID, projName string, w io.Writer) error

type LogAnalysisParams ¶

type LogAnalysisParams struct {
	TaskID       string
	WorkID       string
	BranchName   string
	RootIssueID  string
	WorkflowName string
	JobName      string
	LogContent   string
}

LogAnalysisParams contains parameters for building a log analysis prompt.

type OrchestratorManager ¶

type OrchestratorManager interface {
	// EnsureWorkOrchestrator checks if a work orchestrator tab exists and spawns one if not.
	// Returns true if the orchestrator was spawned, false if it was already running.
	EnsureWorkOrchestrator(ctx context.Context, workID, projName, workDir, friendlyName string, w io.Writer) (bool, error)

	// SpawnWorkOrchestrator creates a zellij tab and runs the orchestrate command for a work unit.
	SpawnWorkOrchestrator(ctx context.Context, workID, projName, workDir, friendlyName string, w io.Writer) error

	// TerminateWorkTabs terminates all zellij tabs associated with a work unit.
	TerminateWorkTabs(ctx context.Context, workID, projName string, w io.Writer) error
}

OrchestratorManager provides operations for managing work orchestrators. This interface enables dependency injection and testing of orchestrator management.

func NewOrchestratorManager(database *db.DB) OrchestratorManager

type OrchestratorManagerMock ¶

type OrchestratorManagerMock struct {
	// EnsureWorkOrchestratorFunc mocks the EnsureWorkOrchestrator method.
	EnsureWorkOrchestratorFunc func(ctx context.Context, workID string, projName string, workDir string, friendlyName string, w io.Writer) (bool, error)

	// SpawnWorkOrchestratorFunc mocks the SpawnWorkOrchestrator method.
	SpawnWorkOrchestratorFunc func(ctx context.Context, workID string, projName string, workDir string, friendlyName string, w io.Writer) error

	// TerminateWorkTabsFunc mocks the TerminateWorkTabs method.
	TerminateWorkTabsFunc func(ctx context.Context, workID string, projName string, w io.Writer) error
	// contains filtered or unexported fields
}

OrchestratorManagerMock is a mock implementation of OrchestratorManager.

func TestSomethingThatUsesOrchestratorManager(t *testing.T) {

	// make and configure a mocked OrchestratorManager
	mockedOrchestratorManager := &OrchestratorManagerMock{
		EnsureWorkOrchestratorFunc: func(ctx context.Context, workID string, projName string, workDir string, friendlyName string, w io.Writer) (bool, error) {
			panic("mock out the EnsureWorkOrchestrator method")
		},
		SpawnWorkOrchestratorFunc: func(ctx context.Context, workID string, projName string, workDir string, friendlyName string, w io.Writer) error {
			panic("mock out the SpawnWorkOrchestrator method")
		},
		TerminateWorkTabsFunc: func(ctx context.Context, workID string, projName string, w io.Writer) error {
			panic("mock out the TerminateWorkTabs method")
		},
	}

	// use mockedOrchestratorManager in code that requires OrchestratorManager
	// and then make assertions.

}

func (mock *OrchestratorManagerMock) EnsureWorkOrchestrator(ctx context.Context, workID string, projName string, workDir string, friendlyName string, w io.Writer) (bool, error)

func (mock *OrchestratorManagerMock) EnsureWorkOrchestratorCalls() []struct {
	Ctx          context.Context
	WorkID       string
	ProjName     string
	WorkDir      string
	FriendlyName string
	W            io.Writer
}

len(mockedOrchestratorManager.EnsureWorkOrchestratorCalls())

func (mock *OrchestratorManagerMock) SpawnWorkOrchestrator(ctx context.Context, workID string, projName string, workDir string, friendlyName string, w io.Writer) error

func (mock *OrchestratorManagerMock) SpawnWorkOrchestratorCalls() []struct {
	Ctx          context.Context
	WorkID       string
	ProjName     string
	WorkDir      string
	FriendlyName string
	W            io.Writer
}

len(mockedOrchestratorManager.SpawnWorkOrchestratorCalls())

func (mock *OrchestratorManagerMock) TerminateWorkTabs(ctx context.Context, workID string, projName string, w io.Writer) error

func (mock *OrchestratorManagerMock) TerminateWorkTabsCalls() []struct {
	Ctx      context.Context
	WorkID   string
	ProjName string
	W        io.Writer
}

len(mockedOrchestratorManager.TerminateWorkTabsCalls())

type Runner ¶

type Runner interface {
	// Run executes Claude directly in the current terminal (fork/exec).
	Run(ctx context.Context, database *db.DB, taskID string, prompt string, workDir string, cfg *project.Config) error
}

Runner defines the interface for running Claude. This abstraction enables testing without spawning the actual claude CLI.

func NewRunner() Runner