services

Jan 26, 2026

Changes in this version

type A2APollingMonitor

+ func (m *A2APollingMonitor) SetAgentEventChannel(eventChan chan<- domain.AgentEvent)

Jan 26, 2026

Changes in this version

+ func NewClaudeCodeModelService() domain.ModelService

+ type ClaudeCodeModelService struct

+ func (s *ClaudeCodeModelService) GetCurrentModel() string

+ func (s *ClaudeCodeModelService) IsModelAvailable(modelID string) bool

+ func (s *ClaudeCodeModelService) IsVisionModel(model string) bool

+ func (s *ClaudeCodeModelService) ListModels(ctx context.Context) ([]string, error)

+ func (s *ClaudeCodeModelService) SelectModel(modelID string) error

+ func (s *ClaudeCodeModelService) ValidateModel(modelID string) error

Jan 25, 2026

Changes in this version

type InMemoryConversationRepository

+ func (r *InMemoryConversationRepository) GetCurrentConversationID() string

Jan 24, 2026

Changes in this version

+ func TestEventPublisher_PublishToolExecutionCompleted(t *testing.T)

Jan 19, 2026

Changes in this version

type InMemoryConversationRepository

+ func (r *InMemoryConversationRepository) SetSessionStats(tokenStats domain.SessionTokenStats, costStats domain.SessionCostStats)

+ type PermissiveApprovalPolicy struct

+ func NewPermissiveApprovalPolicy() *PermissiveApprovalPolicy

+ func (p *PermissiveApprovalPolicy) ShouldRequireApproval(ctx context.Context, toolCall *sdk.ChatCompletionMessageToolCall, ...) bool

+ type StandardApprovalPolicy struct

+ func NewStandardApprovalPolicy(cfg *config.Config, stateManager domain.StateManager) *StandardApprovalPolicy

+ func (p *StandardApprovalPolicy) ShouldRequireApproval(ctx context.Context, toolCall *sdk.ChatCompletionMessageToolCall, ...) bool

+ type StrictApprovalPolicy struct

+ func NewStrictApprovalPolicy() *StrictApprovalPolicy

+ func (p *StrictApprovalPolicy) ShouldRequireApproval(ctx context.Context, toolCall *sdk.ChatCompletionMessageToolCall, ...) bool

Jan 11, 2026

Changes in this version

+ type CircularScreenshotBuffer struct

+ func NewCircularScreenshotBuffer(maxSize int, tempDir string, sessionID string) (*CircularScreenshotBuffer, error)

+ func (b *CircularScreenshotBuffer) Add(screenshot *domain.Screenshot) error

+ func (b *CircularScreenshotBuffer) Cleanup() error

+ func (b *CircularScreenshotBuffer) Clear() error

+ func (b *CircularScreenshotBuffer) Count() int

+ func (b *CircularScreenshotBuffer) GetByID(id string) (*domain.Screenshot, error)

+ func (b *CircularScreenshotBuffer) GetLatest() (*domain.Screenshot, error)

+ func (b *CircularScreenshotBuffer) GetRecent(limit int) []*domain.Screenshot

type ConfigService

+ func (cs *ConfigService) GetAPIKey() string

+ func (cs *ConfigService) GetAgentConfig() *config.AgentConfig

+ func (cs *ConfigService) GetGatewayURL() string

+ func (cs *ConfigService) GetOutputDirectory() string

+ func (cs *ConfigService) GetProtectedPaths() []string

+ func (cs *ConfigService) GetSandboxDirectories() []string

+ func (cs *ConfigService) GetTimeout() int

+ func (cs *ConfigService) IsApprovalRequired(toolName string) bool

+ func (cs *ConfigService) IsBashCommandWhitelisted(command string) bool

+ type ScreenshotServer struct

+ func NewScreenshotServer(cfg *config.Config, imageService domain.ImageService, sessionID string) *ScreenshotServer

+ func (s *ScreenshotServer) GetLatestScreenshot() (*domain.Screenshot, error)

+ func (s *ScreenshotServer) Port() int

+ func (s *ScreenshotServer) Start() error

+ func (s *ScreenshotServer) Stop() error

type StateManager

+ func (sm *StateManager) BroadcastEvent(event domain.ChatEvent)

+ func (sm *StateManager) ClearComputerUsePauseState()

+ func (sm *StateManager) ClearLastClickCoordinates()

+ func (sm *StateManager) ClearLastFocusedApp()

+ func (sm *StateManager) GetEventBridge() domain.EventBridge

+ func (sm *StateManager) GetLastClickCoordinates() (x, y int)

+ func (sm *StateManager) GetLastFocusedApp() string

+ func (sm *StateManager) GetPausedRequestID() string

+ func (sm *StateManager) IsComputerUsePaused() bool

+ func (sm *StateManager) SetComputerUsePaused(paused bool, requestID string)

+ func (sm *StateManager) SetEventBridge(bridge domain.EventBridge)

+ func (sm *StateManager) SetLastClickCoordinates(x, y int)

+ func (sm *StateManager) SetLastFocusedApp(appID string)

Jan 1, 2026

Changes in this version

type ConversationOptimizer

+ func (co *ConversationOptimizer) GenerateLLMSummary(messages []sdk.Message, model string) (string, error)

type InMemoryConversationRepository

+ func (r *InMemoryConversationRepository) GetCurrentConversationTitle() string

type PersistentConversationRepository

+ func (r *PersistentConversationRepository) GetCurrentConversationTitle() string

Dec 18, 2025

Changes in this version

type StateManager

+ func (sm *StateManager) ClearMessageEditState()

+ func (sm *StateManager) GetMessageEditState() *domain.MessageEditState

+ func (sm *StateManager) IsEditingMessage() bool

+ func (sm *StateManager) SetMessageEditState(state *domain.MessageEditState)

Dec 18, 2025

Changes in this version

type InMemoryConversationRepository

+ func (r *InMemoryConversationRepository) DeleteMessagesAfterIndex(index int) error

type PersistentConversationRepository

+ func (r *PersistentConversationRepository) DeleteMessagesAfterIndex(index int) error

Dec 14, 2025

Changes in this version

type AgentManager

+ func (am *AgentManager) GetAllAgentNames() []string

+ func (am *AgentManager) GetExternalAgentURL(agentName string) string

+ func (am *AgentManager) GetTotalAgentCount() int

+ func (am *AgentManager) IsExternalAgent(agentName string) bool

Dec 12, 2025

Changes in this version

+ type ImageOptimizer struct

+ func NewImageOptimizer(cfg config.ClipboardImageOptimizeConfig) *ImageOptimizer

+ func (o *ImageOptimizer) OptimizeImage(imagePath string) (*OptimizeResult, error)

+ type OptimizeResult struct

+ Data []byte

+ Extension string

type OptimizerConfig

+ KeepFirstMessages int

type PricingServiceImpl

+ func (p *PricingServiceImpl) FormatModelPricing(model string) string

Dec 11, 2025

Changes in this version

type InMemoryConversationRepository

+ func (r *InMemoryConversationRepository) StartNewConversation(title string) error

Dec 10, 2025

Changes in this version

type GatewayManager

+ func (gm *GatewayManager) EnsureStarted() error

Dec 10, 2025

Changes in this version

type PricingServiceImpl

+ func (p *PricingServiceImpl) IsEnabled() bool

Dec 9, 2025

Changes in this version

+ func NewPricingService(cfg *config.PricingConfig) domain.PricingService

type InMemoryConversationRepository

+ func (r *InMemoryConversationRepository) GetSessionCostStats() domain.SessionCostStats

+ type PricingServiceImpl struct

+ func (p *PricingServiceImpl) CalculateCost(model string, inputTokens, outputTokens int) (inputCost, outputCost, totalCost float64)

+ func (p *PricingServiceImpl) GetInputPrice(model string) float64

+ func (p *PricingServiceImpl) GetOutputPrice(model string) float64

type StateManager

+ func (sm *StateManager) GetPreviousView() domain.ViewState

Dec 8, 2025

Changes in this version

+ const InferNetworkPrefix

+ func NewContainerRuntime(sessionID domain.SessionID, runtimeType RuntimeType) (domain.ContainerRuntime, error)

+ func NewDockerRuntime(sessionID domain.SessionID) domain.ContainerRuntime

+ func NewPodmanRuntime(sessionID domain.SessionID) domain.ContainerRuntime

+ type DockerRuntime struct

+ func (dr *DockerRuntime) CleanupNetwork(ctx context.Context) error

+ func (dr *DockerRuntime) ContainerExists(containerIDOrName string) bool

+ func (dr *DockerRuntime) EnsureNetwork(ctx context.Context) error

+ func (dr *DockerRuntime) GetContainerHealth(ctx context.Context, containerIDOrName string) (domain.HealthStatus, error)

+ func (dr *DockerRuntime) GetNetworkName() string

+ func (dr *DockerRuntime) ListRunningContainers(ctx context.Context, nameFilter string) ([]domain.ContainerInfo, error)

+ func (dr *DockerRuntime) PullImage(ctx context.Context, image string) error

+ func (dr *DockerRuntime) RunContainer(ctx context.Context, opts domain.RunContainerOptions) (string, error)

+ func (dr *DockerRuntime) StopContainer(ctx context.Context, containerIDOrName string) error

type GatewayManager

+ func (gm *GatewayManager) GetGatewayURL() string

+ type PodmanRuntime struct

+ func (pr *PodmanRuntime) CleanupNetwork(ctx context.Context) error

+ func (pr *PodmanRuntime) ContainerExists(containerIDOrName string) bool

+ func (pr *PodmanRuntime) EnsureNetwork(ctx context.Context) error

+ func (pr *PodmanRuntime) GetContainerHealth(ctx context.Context, containerIDOrName string) (domain.HealthStatus, error)

+ func (pr *PodmanRuntime) GetNetworkName() string

+ func (pr *PodmanRuntime) ListRunningContainers(ctx context.Context, nameFilter string) ([]domain.ContainerInfo, error)

+ func (pr *PodmanRuntime) PullImage(ctx context.Context, image string) error

+ func (pr *PodmanRuntime) RunContainer(ctx context.Context, opts domain.RunContainerOptions) (string, error)

+ func (pr *PodmanRuntime) StopContainer(ctx context.Context, containerIDOrName string) error

+ type RuntimeType string

+ const RuntimeTypeDocker

+ const RuntimeTypePodman

Dec 7, 2025

Changes in this version

+ type BackgroundShellService struct

+ func NewBackgroundShellService(tracker domain.ShellTracker, cfg *config.Config, ...) *BackgroundShellService

+ func (s *BackgroundShellService) CancelShell(shellID string) error

+ func (s *BackgroundShellService) DetachToBackground(ctx context.Context, cmd *exec.Cmd, command string, ...) (string, error)

+ func (s *BackgroundShellService) GetAllShells() []*domain.BackgroundShell

+ func (s *BackgroundShellService) GetShell(shellID string) *domain.BackgroundShell

+ func (s *BackgroundShellService) GetShellOutput(shellID string, fromOffset int64) (string, int64, domain.ShellState, error)

+ func (s *BackgroundShellService) GetShellOutputWithFilter(shellID string, fromOffset int64, filterPattern string) (string, int64, domain.ShellState, error)

+ func (s *BackgroundShellService) GetStats() map[string]int

+ func (s *BackgroundShellService) RemoveShell(shellID string) error

+ func (s *BackgroundShellService) Stop()

type LLMToolService

+ func (s *LLMToolService) GetTool(name string) (domain.Tool, error)

type NoOpToolService

+ func (s *NoOpToolService) GetTool(name string) (domain.Tool, error)

type TokenizerService

+ func (t *TokenizerService) GetToolStats(toolService domain.ToolService, agentMode domain.AgentMode) (tokens int, count int)

Dec 6, 2025

Changes in this version

type MCPManager

+ func (m *MCPManager) StartServer(ctx context.Context, server config.MCPServerEntry) error

+ func (m *MCPManager) StartServers(ctx context.Context) error

+ func (m *MCPManager) StopServers(ctx context.Context) error

+ type SSEHTTPClientTransport struct

+ func NewSSEHTTPClientTransport(endpoint string) *SSEHTTPClientTransport

+ func (t *SSEHTTPClientTransport) Close() error

+ func (t *SSEHTTPClientTransport) Send(ctx context.Context, message *transport.BaseJsonRpcMessage) error

+ func (t *SSEHTTPClientTransport) SetCloseHandler(handler func())

+ func (t *SSEHTTPClientTransport) SetErrorHandler(handler func(error))

+ func (t *SSEHTTPClientTransport) SetMessageHandler(handler func(ctx context.Context, message *transport.BaseJsonRpcMessage))

+ func (t *SSEHTTPClientTransport) Start(ctx context.Context) error

+ func (t *SSEHTTPClientTransport) WithHeader(key, value string) *SSEHTTPClientTransport

Dec 6, 2025

Changes in this version

+ func Merge(base *config.MCPConfig, optional *config.MCPConfig) *config.MCPConfig

+ type MCPConfigService struct

+ func NewMCPConfigService(configPath string) *MCPConfigService

+ func (s *MCPConfigService) AddServer(server config.MCPServerEntry) error

+ func (s *MCPConfigService) GetServer(name string) (*config.MCPServerEntry, error)

+ func (s *MCPConfigService) ListServers() ([]config.MCPServerEntry, error)

+ func (s *MCPConfigService) Load() (*config.MCPConfig, error)

+ func (s *MCPConfigService) RemoveServer(name string) error

+ func (s *MCPConfigService) Save(cfg *config.MCPConfig) error

+ func (s *MCPConfigService) UpdateServer(server config.MCPServerEntry) error

+ type MCPManager struct

+ func NewMCPManager(cfg *config.MCPConfig) *MCPManager

+ func (m *MCPManager) ClearToolCount(serverName string)

+ func (m *MCPManager) Close() error

+ func (m *MCPManager) GetClients() []domain.MCPClient

+ func (m *MCPManager) GetTotalServers() int

+ func (m *MCPManager) StartMonitoring(ctx context.Context) <-chan domain.MCPServerStatusUpdateEvent

+ func (m *MCPManager) UpdateToolCount(serverName string, count int)

Dec 2, 2025

Changes in this version

type InMemoryConversationRepository

+ func (r *InMemoryConversationRepository) MarkMessageAsPlanByIndex(index int)

Nov 29, 2025

Changes in this version

type ImageService

+ func (s *ImageService) IsImageURL(urlStr string) bool

+ func (s *ImageService) ReadImageFromURL(imageURL string) (*domain.ImageAttachment, error)

Nov 26, 2025

Changes in this version

type OptimizerConfig

+ AutoAt int

+ Tokenizer *TokenizerService

Nov 25, 2025

Changes in this version

type InMemoryConversationRepository

+ func (r *InMemoryConversationRepository) AddPendingToolCall(toolCall sdk.ChatCompletionMessageToolCall, ...) error

+ func (r *InMemoryConversationRepository) MarkLastMessageAsPlan()

+ func (r *InMemoryConversationRepository) RemovePendingToolCallByID(toolCallID string)

+ func (r *InMemoryConversationRepository) UpdatePlanStatus(action domain.PlanApprovalAction)

+ func (r *InMemoryConversationRepository) UpdateToolApprovalStatus(action domain.ApprovalAction)

type LLMToolService

+ func (s *LLMToolService) ExecuteToolDirect(ctx context.Context, toolCall sdk.ChatCompletionMessageToolCallFunction) (*domain.ToolExecutionResult, error)

type NoOpToolService

+ func (s *NoOpToolService) ExecuteToolDirect(ctx context.Context, toolCall sdk.ChatCompletionMessageToolCallFunction) (*domain.ToolExecutionResult, error)

type StateManager

+ func (sm *StateManager) ClearPlanApprovalUIState()

+ func (sm *StateManager) GetPlanApprovalUIState() *domain.PlanApprovalUIState

+ func (sm *StateManager) SetPlanApprovalSelectedIndex(index int)

+ func (sm *StateManager) SetupPlanApprovalUIState(planContent string, responseChan chan domain.PlanApprovalAction)

Nov 25, 2025

Changes in this version

+ const InferNetworkName

type AgentManager

+ func (am *AgentManager) SetStatusCallback(...)

type StateManager

+ func (sm *StateManager) AreAllAgentsReady() bool

+ func (sm *StateManager) ClearAgentReadiness()

+ func (sm *StateManager) GetAgentReadiness() *domain.AgentReadinessState

+ func (sm *StateManager) InitializeAgentReadiness(totalAgents int)

+ func (sm *StateManager) RemoveAgent(name string)

+ func (sm *StateManager) SetAgentError(name string, err error)

+ func (sm *StateManager) UpdateAgentStatus(name string, state domain.AgentState, message string, url string, image string)

Nov 24, 2025

Changes in this version

+ type TokenizerConfig struct

+ CharsPerToken float64

+ MessageOverhead int

+ ToolCallOverhead int

+ func DefaultTokenizerConfig() TokenizerConfig

+ type TokenizerService struct

+ func NewTokenizerService(config TokenizerConfig) *TokenizerService

+ func (t *TokenizerService) AdjustedEstimate(text string) int

+ func (t *TokenizerService) CalculateUsagePolyfill(inputMessages []sdk.Message, outputContent string, ...) *sdk.CompletionUsage

+ func (t *TokenizerService) EstimateMessageTokens(msg sdk.Message) int

+ func (t *TokenizerService) EstimateMessagesTokens(messages []sdk.Message) int

+ func (t *TokenizerService) EstimateResponseTokens(response string) int

+ func (t *TokenizerService) EstimateTokenCount(text string) int

+ func (t *TokenizerService) EstimateToolDefinitionsTokens(tools []sdk.ChatCompletionTool) int

+ func (t *TokenizerService) IsLikelyCodeContent(text string) bool

+ func (t *TokenizerService) ShouldUsePolyfill(usage *sdk.CompletionUsage) bool

Nov 23, 2025

Changes in this version

type StateManager

+ func (sm *StateManager) GetTodos() []domain.TodoItem

+ func (sm *StateManager) SetChatPending()

+ func (sm *StateManager) SetTodos(todos []domain.TodoItem)

Nov 22, 2025

Changes in this version

type HTTPModelService

+ func (s *HTTPModelService) IsVisionModel(modelID string) bool

Nov 21, 2025

Changes in this version

+ type ImageService struct

+ func NewImageService() *ImageService

+ func (s *ImageService) CreateDataURL(attachment *domain.ImageAttachment) string

+ func (s *ImageService) IsImageFile(filePath string) bool

+ func (s *ImageService) ReadImageFromBinary(imageData []byte, filename string) (*domain.ImageAttachment, error)

+ func (s *ImageService) ReadImageFromFile(filePath string) (*domain.ImageAttachment, error)

Nov 19, 2025

Changes in this version

+ const AgentContainerPrefix

type LLMToolService

+ func (s *LLMToolService) ListToolsForMode(mode domain.AgentMode) []sdk.ChatCompletionTool

type NoOpToolService

+ func (s *NoOpToolService) ListToolsForMode(mode domain.AgentMode) []sdk.ChatCompletionTool

type StateManager

+ func (sm *StateManager) CycleAgentMode() domain.AgentMode

+ func (sm *StateManager) GetAgentMode() domain.AgentMode

+ func (sm *StateManager) SetAgentMode(mode domain.AgentMode)

+ func (sm *StateManager) SetupApprovalUIState(toolCall *sdk.ChatCompletionMessageToolCall, ...)

Nov 18, 2025

Changes in this version

type AgentsConfigService

+ func (s *AgentsConfigService) UpdateAgent(agent config.AgentEntry) error

Nov 18, 2025

Changes in this version

+ type AgentManager struct

+ func NewAgentManager(cfg *config.Config, agentsConfig *config.AgentsConfig) *AgentManager

+ func (am *AgentManager) IsRunning() bool

+ func (am *AgentManager) StartAgent(ctx context.Context, agent config.AgentEntry) error

+ func (am *AgentManager) StartAgents(ctx context.Context) error

+ func (am *AgentManager) StopAgent(ctx context.Context, agentName string) error

+ func (am *AgentManager) StopAgents(ctx context.Context) error

+ type AgentsConfigService struct

+ func NewAgentsConfigService(configPath string) *AgentsConfigService

+ func (s *AgentsConfigService) AddAgent(agent config.AgentEntry) error

+ func (s *AgentsConfigService) GetAgent(name string) (*config.AgentEntry, error)

+ func (s *AgentsConfigService) GetAgentURLs() ([]string, error)

+ func (s *AgentsConfigService) ListAgents() ([]config.AgentEntry, error)

+ func (s *AgentsConfigService) Load() (*config.AgentsConfig, error)

+ func (s *AgentsConfigService) RemoveAgent(name string) error

+ func (s *AgentsConfigService) Save(cfg *config.AgentsConfig) error

+ type GatewayManager struct

+ func NewGatewayManager(cfg *config.Config) *GatewayManager

+ func (gm *GatewayManager) IsRunning() bool

+ func (gm *GatewayManager) Start(ctx context.Context) error

+ func (gm *GatewayManager) Stop(ctx context.Context) error

Oct 20, 2025

Changes in this version

+ type BackgroundTaskService struct

+ func NewBackgroundTaskService(taskTracker domain.TaskTracker) *BackgroundTaskService

+ func (s *BackgroundTaskService) CancelBackgroundTask(taskID string) error

+ func (s *BackgroundTaskService) GetBackgroundTasks() []domain.TaskPollingState

+ type TaskRetentionService struct

+ func NewTaskRetentionService(maxRetention int) *TaskRetentionService

+ func (t *TaskRetentionService) AddTask(task domain.TaskInfo)

+ func (t *TaskRetentionService) Clear()

+ func (t *TaskRetentionService) GetMaxRetention() int

+ func (t *TaskRetentionService) GetTasks() []domain.TaskInfo

+ func (t *TaskRetentionService) SetMaxRetention(maxRetention int)

Oct 18, 2025

Changes in this version

+ type A2APollingMonitor struct

+ func NewA2APollingMonitor(taskTracker domain.TaskTracker, eventChan chan<- domain.ChatEvent, ...) *A2APollingMonitor

+ func (m *A2APollingMonitor) MonitorPollingState(ctx context.Context, taskID string, state *domain.TaskPollingState)

+ func (m *A2APollingMonitor) Start(ctx context.Context)

+ func (m *A2APollingMonitor) Stop()

+ type ADKClientFactory func(agentURL string) client.A2AClient

type LLMToolService

+ func (s *LLMToolService) GetTaskTracker() domain.TaskTracker

+ type MessageQueueService struct

+ func NewMessageQueueService() *MessageQueueService

+ func (mq *MessageQueueService) Clear()

+ func (mq *MessageQueueService) Dequeue() *domain.QueuedMessage

+ func (mq *MessageQueueService) Enqueue(message sdk.Message, requestID string)

+ func (mq *MessageQueueService) GetAll() []domain.QueuedMessage

+ func (mq *MessageQueueService) IsEmpty() bool

+ func (mq *MessageQueueService) Peek() *domain.QueuedMessage

+ func (mq *MessageQueueService) Size() int

type NoOpToolService

+ func (s *NoOpToolService) GetTaskTracker() domain.TaskTracker

type StateManager

+ func (sm *StateManager) AddQueuedMessage(message sdk.Message, requestID string)

+ func (sm *StateManager) CancelBackgroundTask(taskID string, toolService domain.ToolService) error

+ func (sm *StateManager) ClearQueuedMessages()

+ func (sm *StateManager) GetBackgroundTasks(toolService domain.ToolService) []domain.TaskPollingState

+ func (sm *StateManager) GetQueuedMessages() []domain.QueuedMessage

+ func (sm *StateManager) IsAgentBusy() bool

+ func (sm *StateManager) PopQueuedMessage() *domain.QueuedMessage

Sep 17, 2025

Changes in this version

type PersistentConversationRepository

+ func (r *PersistentConversationRepository) SetTaskTracker(taskTracker domain.TaskTracker)

Sep 15, 2025

Changes in this version

+ type A2AAgentService struct

+ func NewA2AAgentService(cfg *config.Config) *A2AAgentService

+ func (s *A2AAgentService) GetAgentCard(ctx context.Context, agentURL string) (*adk.AgentCard, error)

+ func (s *A2AAgentService) GetAgentCards(ctx context.Context) ([]*domain.CachedAgentCard, error)

+ func (s *A2AAgentService) GetConfiguredAgents() []string

type InMemoryConversationRepository

+ func (r *InMemoryConversationRepository) ClearExceptFirstUserMessage() error

+ type IndexedToolResult struct

+ Index int

+ Result domain.ConversationEntry

Sep 1, 2025

Changes in this version

type ConversationOptimizer

+ func (co *ConversationOptimizer) OptimizeMessagesWithModel(messages []sdk.Message, currentModel string) []sdk.Message

type InMemoryConversationRepository

+ func (r *InMemoryConversationRepository) FormatToolResultExpanded(result *domain.ToolExecutionResult, terminalWidth int) string

+ func (r *InMemoryConversationRepository) FormatToolResultForLLM(result *domain.ToolExecutionResult) string

+ func (r *InMemoryConversationRepository) FormatToolResultForUI(result *domain.ToolExecutionResult, terminalWidth int) string

type OptimizerConfig

+ BufferSize int

+ MinMessages int

+ Model string

type PersistentConversationRepository

+ func (r *PersistentConversationRepository) GetOptimizedMessages() []sdk.Message

+ func (r *PersistentConversationRepository) SetOptimizedMessages(ctx context.Context, optimizedMessages []sdk.Message) error

Aug 27, 2025

Changes in this version

+ type BackgroundJobManager struct

+ func NewBackgroundJobManager(titleGenerator TitleGenerator, config *config.Config) *BackgroundJobManager

+ func (m *BackgroundJobManager) IsRunning() bool

+ func (m *BackgroundJobManager) Start(ctx context.Context)

+ func (m *BackgroundJobManager) Stop()

+ func (m *BackgroundJobManager) TriggerTitleGeneration(ctx context.Context) error

+ type ConversationTitleGenerator struct

+ func NewConversationTitleGenerator(client sdk.Client, storage storage.ConversationStorage, config *config.Config) *ConversationTitleGenerator

+ func NewConversationTitleGeneratorWithSDKClient(client domain.SDKClient, storage storage.ConversationStorage, ...) *ConversationTitleGenerator

+ func (g *ConversationTitleGenerator) GenerateTitleForConversation(ctx context.Context, conversationID string) error

+ func (g *ConversationTitleGenerator) InvalidateTitle(ctx context.Context, conversationID string) error

+ func (g *ConversationTitleGenerator) ProcessPendingTitles(ctx context.Context) error

type PersistentConversationRepository

+ func (r *PersistentConversationRepository) SetTitleGenerator(titleGenerator *ConversationTitleGenerator)

+ type TitleGenerator interface

+ ProcessPendingTitles func(ctx context.Context) error

Aug 26, 2025

Changes in this version

+ type PersistentConversationRepository struct

+ func NewPersistentConversationRepository(formatterService *ToolFormatterService, ...) *PersistentConversationRepository

+ func (r *PersistentConversationRepository) AddMessage(msg domain.ConversationEntry) error

+ func (r *PersistentConversationRepository) AddTokenUsage(inputTokens, outputTokens, totalTokens int) error

+ func (r *PersistentConversationRepository) Clear() error

+ func (r *PersistentConversationRepository) Close() error

+ func (r *PersistentConversationRepository) DeleteSavedConversation(ctx context.Context, conversationID string) error

+ func (r *PersistentConversationRepository) GetCurrentConversationID() string

+ func (r *PersistentConversationRepository) GetCurrentConversationMetadata() storage.ConversationMetadata

+ func (r *PersistentConversationRepository) ListSavedConversations(ctx context.Context, limit, offset int) ([]storage.ConversationSummary, error)

+ func (r *PersistentConversationRepository) LoadConversation(ctx context.Context, conversationID string) error

+ func (r *PersistentConversationRepository) SaveConversation(ctx context.Context) error

+ func (r *PersistentConversationRepository) SetAutoSave(enabled bool)

+ func (r *PersistentConversationRepository) SetConversationTags(tags []string)

+ func (r *PersistentConversationRepository) SetConversationTitle(title string)

+ func (r *PersistentConversationRepository) StartNewConversation(title string) error

Aug 25, 2025

Changes in this version

+ type ConfigService struct

+ func NewConfigService(v *viper.Viper, cfg *config.Config) *ConfigService

+ func (cs *ConfigService) GetConfig() *config.Config

+ func (cs *ConfigService) Reload() (*config.Config, error)

+ func (cs *ConfigService) SetValue(key, value string) error

Aug 22, 2025

Changes in this version

+ type AgentServiceImpl struct

+ func NewAgentService(client sdk.Client, toolService domain.ToolService, systemPrompt string, ...) *AgentServiceImpl

+ func (s *AgentServiceImpl) CancelRequest(requestID string) error

+ func (s *AgentServiceImpl) GetMetrics(requestID string) *domain.ChatMetrics

+ func (s *AgentServiceImpl) Run(ctx context.Context, req *domain.AgentRequest) (*domain.ChatSyncResponse, error)

+ func (s *AgentServiceImpl) RunWithStream(ctx context.Context, req *domain.AgentRequest) (<-chan domain.ChatEvent, error)

type OptimizerConfig

+ Client sdk.Client

+ Config *config.Config

+ ModelService domain.ModelService

type ToolFormatterService

+ func (s *ToolFormatterService) ShouldAlwaysExpandTool(toolName string) bool

Aug 21, 2025

Changes in this version

+ type ApprovalArgumentFormatter interface

+ FormatArgumentsForApproval func(args map[string]any) string

type ToolFormatterService

+ func (s *ToolFormatterService) FormatToolArgumentsForApproval(toolName string, args map[string]any) string

Aug 21, 2025

Changes in this version

+ type ToolFormatterService struct

+ func NewToolFormatterService(registry ToolRegistry) *ToolFormatterService

+ func (s *ToolFormatterService) FormatToolCall(toolName string, args map[string]any) string

+ func (s *ToolFormatterService) FormatToolResultExpanded(result *domain.ToolExecutionResult, terminalWidth int) string

+ func (s *ToolFormatterService) FormatToolResultForLLM(result *domain.ToolExecutionResult) string

+ func (s *ToolFormatterService) FormatToolResultForUI(result *domain.ToolExecutionResult, terminalWidth int) string

+ type ToolRegistry interface

+ GetTool func(name string) (domain.Tool, error)

+ ListAvailableTools func() []string

Aug 20, 2025

Changes in this version

type LLMToolService

+ func (s *LLMToolService) ListAvailableTools() []string

type NoOpToolService

+ func (s *NoOpToolService) ListAvailableTools() []string

Aug 20, 2025

Changes in this version

+ type ConversationOptimizer struct

+ func NewConversationOptimizer(config OptimizerConfig) *ConversationOptimizer

+ func (co *ConversationOptimizer) CompactToolCalls(message sdk.Message) sdk.Message

+ func (co *ConversationOptimizer) EstimateTokens(content string) int

+ func (co *ConversationOptimizer) GetOptimizationStats(messages []sdk.Message) map[string]int

+ func (co *ConversationOptimizer) OptimizeForExport(entries []domain.ConversationEntry) []domain.ConversationEntry

+ func (co *ConversationOptimizer) OptimizeMessages(messages []sdk.Message) []sdk.Message

+ func (co *ConversationOptimizer) SummarizeOldMessages(messages []domain.ConversationEntry) string

+ type OptimizerConfig struct

+ CompactThreshold int

+ Enabled bool

+ MaxHistory int

+ SkipRedundantConfirmations bool

+ TruncateLargeOutputs bool

Aug 19, 2025

Changes in this version

type InMemoryConversationRepository

+ func (r *InMemoryConversationRepository) AddTokenUsage(inputTokens, outputTokens, totalTokens int) error

+ func (r *InMemoryConversationRepository) GetSessionTokens() domain.SessionTokenStats

Aug 19, 2025

Changes in this version

+ type DebugEvent struct

+ Data map[string]interface{}

+ Duration *time.Duration

+ ID string

+ Message string

+ Source string

+ StateAfter *domain.StateSnapshot

+ Timestamp time.Time

+ Type DebugEventType

+ type DebugEventType int

+ const DebugEventTypeCommand

+ const DebugEventTypeError

+ const DebugEventTypeKeyPress

+ const DebugEventTypeMessage

+ const DebugEventTypePerformance

+ const DebugEventTypeSDKEvent

+ const DebugEventTypeStateChange

+ const DebugEventTypeToolExecution

+ const DebugEventTypeUIUpdate

+ func (d DebugEventType) String() string

+ type DebugService struct

+ func NewDebugService(enabled bool, stateManager *StateManager, outputDir string) *DebugService

+ func (ds *DebugService) Cleanup()

+ func (ds *DebugService) Disable()

+ func (ds *DebugService) Enable()

+ func (ds *DebugService) ExportEvents(filename string) error

+ func (ds *DebugService) ExportMetrics(filename string) error

+ func (ds *DebugService) GetEventsByType(eventType DebugEventType) []DebugEvent

+ func (ds *DebugService) GetEventsSince(since time.Time) []DebugEvent

+ func (ds *DebugService) GetPerformanceSummary() map[string]interface{}

+ func (ds *DebugService) IsEnabled() bool

+ func (ds *DebugService) LogCommand(command string, args []string, result interface{}, duration time.Duration)

+ func (ds *DebugService) LogError(err error, source string, context map[string]interface{})

+ func (ds *DebugService) LogEvent(eventType DebugEventType, source, message string, data map[string]interface{})

+ func (ds *DebugService) LogKeyPress(key string, handler string, view string)

+ func (ds *DebugService) LogMessage(msg tea.Msg, source string)

+ func (ds *DebugService) LogSDKEvent(eventType string, requestID string, data interface{})

+ func (ds *DebugService) LogToolExecution(toolName string, phase string, data map[string]interface{})

+ func (ds *DebugService) OnStateChanged(oldState, newState domain.StateSnapshot)

+ func (ds *DebugService) TrackMessageProcessing(msgType string, duration time.Duration)

+ func (ds *DebugService) TrackSDKCall(operation string, duration time.Duration)

+ func (ds *DebugService) TrackStateTransition(duration time.Duration)

+ func (ds *DebugService) TrackUIRender(duration time.Duration)

+ type HealthStatus struct

+ Healthy bool

+ LastStateChange time.Time

+ MemoryUsageKB int

+ StateHistorySize int

+ ValidationErrors []error

+ type PerformanceMetrics struct

+ MessageProcessingTimes map[string][]time.Duration

+ SDKCallTimes map[string][]time.Duration

+ StateTransitionTimes []time.Duration

+ UIRenderTimes []time.Duration

+ func NewPerformanceMetrics() *PerformanceMetrics

+ type StateChangeEvent struct

+ NewState domain.StateSnapshot

+ OldState domain.StateSnapshot

+ Timestamp time.Time

+ Type StateChangeType

+ type StateChangeListener interface

+ OnStateChanged func(oldState, newState domain.StateSnapshot)

+ type StateChangeType int

+ const StateChangeTypeChatStatus

+ const StateChangeTypeDimensions

+ const StateChangeTypeToolExecution

+ const StateChangeTypeViewTransition

+ func (s StateChangeType) String() string

+ type StateManager struct

+ func NewStateManager(debugMode bool) *StateManager

+ func (sm *StateManager) AddListener(listener StateChangeListener)

+ func (sm *StateManager) ApproveCurrentTool() error

+ func (sm *StateManager) ClearApprovalUIState()

+ func (sm *StateManager) ClearFileSelectionState()

+ func (sm *StateManager) CompleteCurrentTool(result *domain.ToolExecutionResult) error

+ func (sm *StateManager) DenyCurrentTool() error

+ func (sm *StateManager) EndChatSession()

+ func (sm *StateManager) EndToolExecution()

+ func (sm *StateManager) ExportStateHistory() ([]byte, error)

+ func (sm *StateManager) FailCurrentTool(result *domain.ToolExecutionResult) error

+ func (sm *StateManager) GetApprovalUIState() *domain.ApprovalUIState

+ func (sm *StateManager) GetChatSession() *domain.ChatSession

+ func (sm *StateManager) GetCurrentView() domain.ViewState

+ func (sm *StateManager) GetDimensions() (int, int)

+ func (sm *StateManager) GetFileSelectionState() *domain.FileSelectionState

+ func (sm *StateManager) GetHealthStatus() HealthStatus

+ func (sm *StateManager) GetStateHistory() []domain.StateSnapshot

+ func (sm *StateManager) GetStateSnapshot() domain.StateSnapshot

+ func (sm *StateManager) GetToolExecution() *domain.ToolExecutionSession

+ func (sm *StateManager) IsDebugMode() bool

+ func (sm *StateManager) RecoverFromInconsistentState() error

+ func (sm *StateManager) RemoveListener(listener StateChangeListener)

+ func (sm *StateManager) SetApprovalSelectedIndex(index int)

+ func (sm *StateManager) SetDebugMode(enabled bool)

+ func (sm *StateManager) SetDimensions(width, height int)

+ func (sm *StateManager) SetFileSelectedIndex(index int)

+ func (sm *StateManager) SetToolApprovalRequired(required bool) error

+ func (sm *StateManager) SetupApprovalUI()

+ func (sm *StateManager) SetupFileSelection(files []string)

+ func (sm *StateManager) StartChatSession(requestID, model string, eventChan <-chan domain.ChatEvent) error

+ func (sm *StateManager) StartToolExecution(toolCalls []sdk.ChatCompletionMessageToolCall) error

+ func (sm *StateManager) TransitionToView(newView domain.ViewState) error

+ func (sm *StateManager) UpdateChatStatus(status domain.ChatStatus) error

+ func (sm *StateManager) UpdateFileSearchQuery(query string)

+ func (sm *StateManager) ValidateState() []error

+ type ToolApprovalRequestMsg struct

+ SessionID string

+ ToolCall sdk.ChatCompletionMessageToolCall

+ ToolIndex int

+ TotalTools int

+ type ToolApprovalResponseMsg struct

+ Approved bool

+ SessionID string

+ ToolIndex int

+ type ToolExecutionCompletedMsg struct

+ FailureCount int

+ Results []*domain.ToolExecutionResult

+ SessionID string

+ SuccessCount int

+ TotalExecuted int

+ type ToolExecutionContext struct

+ CurrentIndex int

+ EventChannel chan tea.Msg

+ RequestID string

+ Results []*domain.ToolExecutionResult

+ SessionID string

+ StartTime time.Time

+ Status ToolExecutionStatus

+ ToolCalls []sdk.ChatCompletionMessageToolCall

+ type ToolExecutionOrchestrator struct

+ func NewToolExecutionOrchestrator(stateManager *StateManager, debugService *DebugService, ...) *ToolExecutionOrchestrator

+ func (teo *ToolExecutionOrchestrator) CancelExecution(reason string) tea.Cmd

+ func (teo *ToolExecutionOrchestrator) GetExecutionStatus() (bool, *ToolExecutionContext)

+ func (teo *ToolExecutionOrchestrator) GetHealthStatus() map[string]interface{}

+ func (teo *ToolExecutionOrchestrator) HandleApprovalResponse(approved bool, toolIndex int) tea.Cmd

+ func (teo *ToolExecutionOrchestrator) RecoverFromStuckState() tea.Cmd

+ func (teo *ToolExecutionOrchestrator) StartToolExecution(requestID string, toolCalls []sdk.ChatCompletionMessageToolCall) (string, tea.Cmd)

+ type ToolExecutionProgressMsg struct

+ CurrentTool int

+ RequiresApproval bool

+ SessionID string

+ Status string

+ ToolName string

+ TotalTools int

+ type ToolExecutionStartedMsg struct

+ SessionID string

+ TotalTools int

+ type ToolExecutionStatus int

+ const ToolExecutionStatusCancelled

+ const ToolExecutionStatusCompleted

+ const ToolExecutionStatusCompleting

+ const ToolExecutionStatusExecuting

+ const ToolExecutionStatusFailed

+ const ToolExecutionStatusProcessing

+ const ToolExecutionStatusReady

+ const ToolExecutionStatusWaitingApproval

+ func (t ToolExecutionStatus) String() string

Aug 15, 2025

Changes in this version

+ func NewFileService() domain.FileService

+ type FileServiceImpl struct

+ func (s *FileServiceImpl) GetFileInfo(path string) (domain.FileInfo, error)

+ func (s *FileServiceImpl) ListProjectFiles() ([]string, error)

+ func (s *FileServiceImpl) ReadFile(path string) (string, error)

+ func (s *FileServiceImpl) ReadFileLines(path string, startLine, endLine int) (string, error)

+ func (s *FileServiceImpl) ValidateFile(path string) error

Aug 14, 2025

Changes in this version

type LLMToolService

+ func NewLLMToolServiceWithRegistry(cfg *config.Config, registry *tools.Registry) *LLMToolService

Aug 14, 2025

Changes in this version

+ type FileSearchMatch struct

+ IsDir bool

+ Path string

+ RelPath string

+ Size int64

+ type FileSearchResult struct

+ Duration string

+ Error string

+ Matches []FileSearchMatch

+ Pattern string

+ Total int

Aug 14, 2025

Changes in this version

+ type GoogleSearchItem struct

+ Link string

+ Snippet string

+ Title string

+ type GoogleSearchResponse struct

+ Items []GoogleSearchItem

+ type WebSearchEngine string

+ const DuckDuckGoSearch

+ const GoogleSearch

+ type WebSearchService struct

+ func NewWebSearchService() *WebSearchService

+ func (s *WebSearchService) IsEnabled() bool

+ func (s *WebSearchService) SearchDuckDuckGo(ctx context.Context, query string, maxResults int) (*domain.WebSearchResponse, error)

+ func (s *WebSearchService) SearchGoogle(ctx context.Context, query string, maxResults int) (*domain.WebSearchResponse, error)

+ func (s *WebSearchService) SetEnabled(enabled bool)

Aug 13, 2025

Changes in this version

+ type CacheEntry struct

+ Content string

+ Timestamp time.Time

+ URL string

+ type FetchService struct

+ func NewFetchService(cfg *config.Config) *FetchService

+ func (f *FetchService) ClearCache()

+ func (f *FetchService) FetchContent(ctx context.Context, target string) (*domain.FetchResult, error)

+ func (f *FetchService) GetCacheStats() map[string]interface{}

+ func (f *FetchService) ValidateURL(targetURL string) error

+ type GitHubReference struct

+ Number int

+ Owner string

+ Repo string

+ Type string

Aug 12, 2025

Changes in this version

+ type FileReadResult struct

+ Content string

+ EndLine int

+ Error string

+ FilePath string

+ Size int64

+ StartLine int

type LocalFileService

+ func (s *LocalFileService) ReadFileLines(path string, startLine, endLine int) (string, error)

Aug 12, 2025

Changes in this version

+ type HTTPModelService struct

+ func NewHTTPModelService(baseURL, apiKey string) *HTTPModelService

+ func (s *HTTPModelService) GetCurrentModel() string

+ func (s *HTTPModelService) IsModelAvailable(modelID string) bool

+ func (s *HTTPModelService) ListModels(ctx context.Context) ([]string, error)

+ func (s *HTTPModelService) SelectModel(modelID string) error

+ func (s *HTTPModelService) ValidateModel(modelID string) error

+ type InMemoryConversationRepository struct

+ func NewInMemoryConversationRepository() *InMemoryConversationRepository

+ func (r *InMemoryConversationRepository) AddMessage(msg domain.ConversationEntry) error

+ func (r *InMemoryConversationRepository) Clear() error

+ func (r *InMemoryConversationRepository) Export(format domain.ExportFormat) ([]byte, error)

+ func (r *InMemoryConversationRepository) GetMessageCount() int

+ func (r *InMemoryConversationRepository) GetMessages() []domain.ConversationEntry

+ func (r *InMemoryConversationRepository) UpdateLastMessage(content string) error

+ func (r *InMemoryConversationRepository) UpdateLastMessageToolCalls(toolCalls *[]sdk.ChatCompletionMessageToolCall) error

+ type LLMToolService struct

+ func NewLLMToolService(cfg *config.Config) *LLMToolService

+ func (s *LLMToolService) ExecuteTool(ctx context.Context, name string, args map[string]interface{}) (string, error)

+ func (s *LLMToolService) IsToolEnabled(name string) bool

+ func (s *LLMToolService) ListTools() []domain.ToolDefinition

+ func (s *LLMToolService) ValidateTool(name string, args map[string]interface{}) error

+ type LocalFileService struct

+ func NewLocalFileService() *LocalFileService

+ func (s *LocalFileService) GetFileInfo(path string) (domain.FileInfo, error)

+ func (s *LocalFileService) ListProjectFiles() ([]string, error)

+ func (s *LocalFileService) ReadFile(path string) (string, error)

+ func (s *LocalFileService) ValidateFile(path string) error

+ type ModelsResponse struct

+ Data []struct{ ... }

+ type NoOpToolService struct

+ func NewNoOpToolService() *NoOpToolService

+ func (s *NoOpToolService) ExecuteTool(ctx context.Context, name string, args map[string]interface{}) (string, error)

+ func (s *NoOpToolService) IsToolEnabled(name string) bool

+ func (s *NoOpToolService) ListTools() []domain.ToolDefinition

+ func (s *NoOpToolService) ValidateTool(name string, args map[string]interface{}) error

+ type StreamingChatService struct

+ func NewStreamingChatService(baseURL, apiKey string, timeoutSeconds int, toolService domain.ToolService) *StreamingChatService

+ func (s *StreamingChatService) CancelRequest(requestID string) error

+ func (s *StreamingChatService) GetMetrics(requestID string) *domain.ChatMetrics

+ func (s *StreamingChatService) SendMessage(ctx context.Context, model string, messages []sdk.Message) (<-chan domain.ChatEvent, error)

+ type ToolResult struct

+ Command string

+ Duration string

+ Error string

+ ExitCode int

+ Output string