chat

package
v0.8.4-beta Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 11, 2026 License: MIT Imports: 44 Imported by: 0

Documentation

Overview

Package chat implements shared persisted chat orchestration for Kodelet UIs.

Index

Constants

View Source 
const (

	// ConversationStreamActiveHeader reports whether a conversation was active when a live stream attached.
	ConversationStreamActiveHeader = "X-Kodelet-Conversation-Active"
	// ClientIDHeader identifies one attached UI client, independently of its user login.
	ClientIDHeader = "X-Kodelet-Client-ID"
	// UICapabilitiesHeader declares UI features supported by a watching client.
	UICapabilitiesHeader = "X-Kodelet-UI-Capabilities"
)
View Source 
const (
	// RunnerIDMetadataKey identifies the remote runner that owns a conversation environment.
	RunnerIDMetadataKey = convtypes.RunnerIDMetadataKey
	// EnvironmentProfileMetadataKey stores the runner-owned profile independently from model policy.
	EnvironmentProfileMetadataKey = convtypes.RunnerEnvironmentProfileMetadataKey
)

Variables

This section is empty.

Functions

func AddEnvironmentCommandDisplay 

func AddEnvironmentCommandDisplay(thread llmtypes.Thread, result agentenv.CommandResult)

AddEnvironmentCommandDisplay stores the compact display for an environment-routed command.

func AddExtensionCommandDisplay 

func AddExtensionCommandDisplay(thread llmtypes.Thread, result *extensions.RoutedCommandResult)

func AddSlashCommandDisplay 

func AddSlashCommandDisplay(thread llmtypes.Thread, expansion *slashcommands.Expansion)

func ApplyCommandRestrictions 

func ApplyCommandRestrictions(ctx context.Context, llmConfig *llmtypes.Config, result agentenv.CommandResult)

ApplyCommandRestrictions applies model/tool restrictions returned by an environment command.

func ApplyFragmentRestrictions 

func ApplyFragmentRestrictions(ctx context.Context, llmConfig *llmtypes.Config, fragmentMetadata *fragments.Metadata)

func BuildState 

func BuildState(
	ctx context.Context,
	llmConfig llmtypes.Config,
	sessionID string,
	workingDir string,
	extensionRuntime *extensions.Runtime,
) (*tools.BasicState, error)

func ContextWithProfileResolver 

func ContextWithProfileResolver(ctx context.Context, resolve func(string, string) (llmtypes.Config, error)) context.Context

ContextWithProfileResolver installs the daemon's caller/runner-bound profile lookup.

func ExpandCWDInput 

func ExpandCWDInput(query, defaultCWD string) (string, error)

ExpandCWDInput expands user-entered working-directory text relative to a default cwd.

func ExpandSlashCommand 

func ExpandSlashCommand(ctx context.Context, message string, cwd string) (string, *slashcommands.Expansion, error)

func IsNaturalDirectoryQuery 

func IsNaturalDirectoryQuery(query string) bool

IsNaturalDirectoryQuery reports whether query is a bare directory name.

func NormalizeEnvironmentProfile 

func NormalizeEnvironmentProfile(profile string) string

NormalizeEnvironmentProfile maps blank and the reserved default name to runner base configuration.

func NormalizeRequest 

func NormalizeRequest(req ChatRequest) (string, []string, error)

func NormalizeRequestedProfile 

func NormalizeRequestedProfile(profile string) string

func ResolveConfig 

func ResolveConfig(ctx context.Context, conversationID, requestedProfile, requestedCWD, defaultCWDInput string) (llmtypes.Config, string, error)

func ResolveConfigForExistingConversation 

func ResolveConfigForExistingConversation(record *conversationservice.GetConversationResponse, requestedReasoningEfforts ...string) (llmtypes.Config, error)

func ResolveConfigForNewConversation 

func ResolveConfigForNewConversation(requestedProfile string, requestedReasoningEfforts ...string) (llmtypes.Config, error)

func ResolveConfigWithReasoning 

func ResolveConfigWithReasoning(ctx context.Context, conversationID, requestedProfile, requestedReasoningEffort, requestedCWD, defaultCWDInput string) (llmtypes.Config, string, error)

func ResolveConfiguredDefaultCWD 

func ResolveConfiguredDefaultCWD(configuredCWD string) (string, error)

ResolveConfiguredDefaultCWD resolves a configured default working directory.

func ResolveExtensionCallContext 

func ResolveExtensionCallContext(ctx context.Context, conversationID, cwd string, config llmtypes.Config) (extensions.ExtensionCallContext, error)

ResolveExtensionCallContext builds the extension context for an interactive operation, including the persisted origin of a resumed conversation.

func ResolveExtensionProfile 

func ResolveExtensionProfile(profile extensions.Profile, reasoningEffort string) (llmtypes.Config, error)

ResolveExtensionProfile decodes a self-contained profile, not a session override. Provider credentials are resolved at execution time, not during registration.

func ResolveRemoteConfigWithReasoning 

func ResolveRemoteConfigWithReasoning(ctx context.Context, conversationID, requestedProfile, requestedReasoningEffort string) (llmtypes.Config, error)

ResolveRemoteConfigWithReasoning resolves only control-plane provider settings. The runner manifest supplies the authoritative workspace path and environment configuration.

func ResolveRemoteConfigWithReasoningAndEnvironmentProfile 

func ResolveRemoteConfigWithReasoningAndEnvironmentProfile(ctx context.Context, conversationID, requestedProfile, requestedReasoningEffort, requestedEnvironmentProfile string) (llmtypes.Config, string, error)

ResolveRemoteConfigWithReasoningAndEnvironmentProfile resolves central model policy and the independently locked runner profile.

func RunDefaultChat 

func RunDefaultChat(ctx context.Context, req ChatRequest, sink ChatEventSink, defaultCWD string, extensionRuntimes ExtensionRuntimeProvider) (string, error)

RunDefaultChat executes a single persisted chat turn and streams events to the sink.

func TryExtensionCommand 

func TryExtensionCommand(
	ctx context.Context,
	message string,
	extensionRuntime *extensions.Runtime,
	llmConfig llmtypes.Config,
	conversationID string,
	workingDir string,
) (*extensions.RoutedCommandResult, bool, error)

Types

type AnthropicAccountMutation 

type AnthropicAccountMutation struct {
	Action   string `json:"action"`
	Alias    string `json:"alias,omitempty"`
	NewAlias string `json:"newAlias,omitempty"`
}

func (AnthropicAccountMutation) Validate 

func (m AnthropicAccountMutation) Validate() error

type AnthropicAccountSummary 

type AnthropicAccountSummary struct {
	Alias     string `json:"alias"`
	Email     string `json:"email"`
	ExpiresAt int64  `json:"expiresAt"`
	IsDefault bool   `json:"isDefault"`
}

AnthropicAccountSummary never contains provider tokens or credentials.

type AnthropicAccountUsage 

type AnthropicAccountUsage struct {
	Account  string               `json:"account"`
	Email    string               `json:"email"`
	Window5h AnthropicUsageWindow `json:"window_5h"`
	Window7d AnthropicUsageWindow `json:"window_7d"`
}

type AnthropicAccounts 

type AnthropicAccounts struct {
	Accounts []AnthropicAccountSummary `json:"accounts"`
}

type AnthropicLogin 

type AnthropicLogin struct {
	ID               string `json:"id"`
	Status           string `json:"status"`
	AuthorizationURL string `json:"authorizationUrl,omitempty"`
	Message          string `json:"message,omitempty"`
}

type AnthropicUsageWindow 

type AnthropicUsageWindow struct {
	Status      string  `json:"status"`
	Utilization float64 `json:"utilization"`
	ResetTime   string  `json:"reset_time"`
	ResetUnix   int64   `json:"reset_unix"`
}

type ChatClientCapabilities 

type ChatClientCapabilities struct {
	InteractiveUI      bool `json:"interactiveUI"`
	PersistentWidgets  bool `json:"persistentWidgets"`
	PersistentSurfaces bool `json:"persistentSurfaces"`
}

ChatClientCapabilities describes UI behavior supported by the client attached to a chat run.

type ChatContentBlock 

type ChatContentBlock struct {
	Type     string              `json:"type"`
	Text     string              `json:"text,omitempty"`
	Command  string              `json:"command,omitempty"`
	Source   *ChatImageSource    `json:"source,omitempty"`
	ImageURL *ChatImageURLSource `json:"image_url,omitempty"`
}

ChatContentBlock represents a typed chat content block.

func ContentBlocksForUserInput 

func ContentBlocksForUserInput(text string, imageInputs []string) []ChatContentBlock

type ChatEvent 

type ChatEvent struct {
	Kind              string                          `json:"kind"`
	ConversationID    string                          `json:"conversation_id,omitempty"`
	ConversationName  string                          `json:"conversation_name,omitempty"`
	CWD               string                          `json:"cwd,omitempty"`
	Role              string                          `json:"role,omitempty"`
	Delta             string                          `json:"delta,omitempty"`
	Content           any                             `json:"content,omitempty"`
	TextData          any                             `json:"text_data,omitempty"`
	Usage             *llmtypes.Usage                 `json:"usage,omitempty"`
	Compaction        *llmtypes.CompactionMarker      `json:"compaction,omitempty"`
	BeforeCurrentUser bool                            `json:"before_current_user,omitempty"`
	ToolName          string                          `json:"tool_name,omitempty"`
	ToolCallID        string                          `json:"tool_call_id,omitempty"`
	Input             string                          `json:"input,omitempty"`
	ToolOutput        string                          `json:"tool_output,omitempty"`
	ToolResult        *tooltypes.StructuredToolResult `json:"tool_result,omitempty"`
	UIInput           *UIInputEvent                   `json:"ui_input,omitempty"`
	UIConfirm         *UIConfirmEvent                 `json:"ui_confirm,omitempty"`
	UISelect          *UISelectEvent                  `json:"ui_select,omitempty"`
	UINotify          *UINotifyEvent                  `json:"ui_notify,omitempty"`
	UIRequestID       string                          `json:"ui_request_id,omitempty"`
	UIWidget          *UIWidgetEvent                  `json:"ui_widget,omitempty"`
	UIWidgets         []UIWidgetEvent                 `json:"ui_widgets,omitempty"`
	UIWidgetRevision  string                          `json:"ui_widget_revision,omitempty"`
	UIPersistent      *UIPersistentEvent              `json:"ui_persistent,omitempty"`
	Cancelled         bool                            `json:"cancelled,omitempty"`
	Error             string                          `json:"error,omitempty"`
	Result            *string                         `json:"result,omitempty"`
}

ChatEvent is a single streaming chat event.

type ChatEventSink 

type ChatEventSink interface {
	Send(ChatEvent) error
}

ChatEventSink receives streamed chat events.

type ChatImageSource 

type ChatImageSource struct {
	Data      string `json:"data"`
	MediaType string `json:"media_type"`
}

ChatImageSource represents embedded image data.

func ParseDataURL 

func ParseDataURL(dataURL string) (*ChatImageSource, bool)

ParseDataURL parses a base64 data URL into a chat image source.

type ChatImageURLSource 

type ChatImageURLSource struct {
	URL string `json:"url"`
}

ChatImageURLSource represents URL-based image input.

type ChatRequest 

type ChatRequest struct {
	Message              string                     `json:"message"`
	Content              []ChatContentBlock         `json:"content,omitempty"`
	ConversationID       string                     `json:"conversationId,omitempty"`
	ParentConversationID string                     `json:"parentConversationId,omitempty"`
	TurnID               string                     `json:"turnId,omitempty"`
	RunnerID             string                     `json:"runnerId,omitempty"`
	SessionExtensionsID  string                     `json:"sessionExtensionsId,omitempty"`
	Profile              string                     `json:"profile,omitempty"`
	EnvironmentProfile   string                     `json:"environmentProfile,omitempty"`
	ReasoningEffort      string                     `json:"reasoningEffort,omitempty"`
	CWD                  string                     `json:"cwd,omitempty"`
	Options              *llmtypes.ExecutionOptions `json:"options,omitempty"`
	ClientCapabilities   *ChatClientCapabilities    `json:"clientCapabilities,omitempty"`
}

ChatRequest is the payload for a streamed chat turn.

func (*ChatRequest) UnmarshalJSON 

func (r *ChatRequest) UnmarshalJSON(data []byte) error

UnmarshalJSON validates the request and its execution-options envelope. Invalid requests leave the receiver untouched.

type ChatRunner 

type ChatRunner interface {
	Run(ctx context.Context, req ChatRequest, sink ChatEventSink) (string, error)
}

ChatRunner executes a single persisted chat turn.

type Client 

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

Client is a daemon HTTP client for chat turns, conversation history, and workspace operations.

func NewClient 

func NewClient(server, authToken, runnerID string, options ...ClientOption) (*Client, error)

NewClient creates a daemon HTTP client with an optional runner selection.

func (*Client) AnthropicAccountUsage 

func (r *Client) AnthropicAccountUsage(ctx context.Context, alias string) (AnthropicAccountUsage, error)

func (*Client) AnthropicAccounts 

func (r *Client) AnthropicAccounts(ctx context.Context) (AnthropicAccounts, error)

func (*Client) AppendMessageHistory 

func (r *Client) AppendMessageHistory(ctx context.Context, target WorkspaceTarget, entry messagehistory.Entry) error

AppendMessageHistory saves a raw composer message without starting a conversation or model turn.

func (*Client) AttachSessionExtensions 

func (r *Client) AttachSessionExtensions(ctx context.Context, conversationID, runnerID string, extensionIDs []string, handler func(context.Context, protocol.ExtensionFrame) error) (SessionExtensionRelay, error)

AttachSessionExtensions opens a callback relay using this client's daemon credential and client identity. The handler receives accepted frames independently of their RPC acknowledgements, so a callback may make nested host requests without deadlocking.

func (*Client) CancelAnthropicLogin 

func (r *Client) CancelAnthropicLogin(ctx context.Context, id string) error

func (*Client) CancelProviderDeviceLogin 

func (r *Client) CancelProviderDeviceLogin(ctx context.Context, provider, id string) error

func (*Client) ChatSettings 

func (r *Client) ChatSettings(ctx context.Context, profile string) (ControlPlaneChatSettings, error)

ChatSettings fetches control-plane model profiles and reasoning policy.

func (*Client) CodexStatus 

func (r *Client) CodexStatus(ctx context.Context) (CodexStatus, error)

func (*Client) CompleteAnthropicLogin 

func (r *Client) CompleteAnthropicLogin(ctx context.Context, id, code, alias string) (AnthropicLogin, error)

CompleteAnthropicLogin explicitly selects an alias (empty means derive from the returned email) rather than overwriting the browser's default account.

func (*Client) CreateCommit 

func (r *Client) CreateCommit(ctx context.Context, target WorkspaceTarget, approval protocol.WorkspaceGitCommitParams) (protocol.WorkspaceGitCommitResult, error)

CreateCommit submits one explicit approval without retrying an uncertain mutation.

func (*Client) DeleteConversation 

func (r *Client) DeleteConversation(ctx context.Context, conversationID string) error

DeleteConversation deletes persisted history on the daemon. Active executions are rejected by the server; transport failures are never retried implicitly.

func (*Client) DiscoverWorkspace 

func (r *Client) DiscoverWorkspace(ctx context.Context, target WorkspaceTarget) (protocol.WorkspaceDiscoverResult, error)

DiscoverWorkspace validates the target and discovers its slash commands on the runner without starting a model turn or a workspace run lease.

func (*Client) ExecuteWorkspaceShortcut 

func (r *Client) ExecuteWorkspaceShortcut(ctx context.Context, request WorkspaceShortcutRequest) (runnerpayload.ShortcutExecuteResult, error)

ExecuteWorkspaceShortcut performs one bounded runner-side invocation. Stream loss cancels this invocation; it never cancels an active conversation turn.

func (*Client) ForkConversation 

func (r *Client) ForkConversation(ctx context.Context, conversationID string) (string, error)

ForkConversation creates a centrally persisted copy with normal lineage and affinity.

func (*Client) GetTurnReceipt 

func (r *Client) GetTurnReceipt(ctx context.Context, conversationID, turnID string) (TurnReceipt, error)

GetTurnReceipt queries durable status without submitting or restarting work.

func (*Client) InspectWorkspace 

func (r *Client) InspectWorkspace(ctx context.Context, target WorkspaceTarget, params protocol.WorkspaceInspectParams) (protocol.WorkspaceInspectResult, error)

func (*Client) ListConversations 

func (r *Client) ListConversations(ctx context.Context, limit int) ([]convtypes.ConversationSummary, error)

ListConversations returns control-plane conversations visible to this client.

func (*Client) ListConversationsInCWD 

func (r *Client) ListConversationsInCWD(ctx context.Context, limit int, cwd string) ([]convtypes.ConversationSummary, error)

ListConversationsInCWD lists history using runner-host CWD semantics. The daemon applies the workspace filter before pagination, so follow never picks a turn from another workspace merely because it was updated more recently.

func (*Client) LoadConversation 

func (r *Client) LoadConversation(ctx context.Context, conversationID string) (ConversationHistory, error)

LoadConversation returns normalized history from the control plane.

func (*Client) LoadConversationRecord 

func (r *Client) LoadConversationRecord(ctx context.Context, conversationID string) (convtypes.ConversationRecord, error)

LoadConversationRecord returns the lossless export shape, not rendered UI history.

func (*Client) LoadMessageHistory 

func (r *Client) LoadMessageHistory(ctx context.Context, target WorkspaceTarget) (protocol.WorkspaceMessageHistoryResult, error)

LoadMessageHistory recalls raw composer messages from the selected runner's workspace.

func (*Client) MoveConversation 

func (r *Client) MoveConversation(ctx context.Context, id string, params ConversationMoveRequest) (ConversationMoveResult, error)

MoveConversation plans or confirms a daemon-owned conversation move. It never retries a mutation after an uncertain transport outcome.

func (*Client) MutateAnthropicAccount 

func (r *Client) MutateAnthropicAccount(ctx context.Context, mutation AnthropicAccountMutation) error

func (*Client) PrepareCommit 

func (r *Client) PrepareCommit(ctx context.Context, target WorkspaceTarget) (protocol.WorkspaceGitCommitSnapshot, error)

PrepareCommit reads a bounded, immutable staged diff on the selected runner.

func (*Client) ProviderConnection 

func (r *Client) ProviderConnection(ctx context.Context, provider string) (ProviderConnection, error)

func (*Client) ProviderDeviceLogin 

func (r *Client) ProviderDeviceLogin(ctx context.Context, provider, id string) (ProviderDeviceLogin, error)

func (*Client) QueryConversations 

func (r *Client) QueryConversations(ctx context.Context, options conversations.ListConversationsRequest) (conversations.ListConversationsResponse, error)

QueryConversations applies history filters centrally, without requiring an online runner. CWD filters match canonical persisted runner-host paths.

func (*Client) Run 

func (r *Client) Run(ctx context.Context, request ChatRequest, sink ChatEventSink) (conversationID string, err error)

Run posts one chat request and forwards NDJSON events to the event sink.

func (*Client) RunnerStatus 

func (r *Client) RunnerStatus(ctx context.Context, target WorkspaceTarget) (RunnerStatus, error)

RunnerStatus inspects the selected runner without requiring workspace readiness. Saved conversation affinity takes precedence over all other runner selections. An authorization failure returns the runner with permissions disabled and an error.

func (*Client) SearchConversations 

func (r *Client) SearchConversations(ctx context.Context, query string, limit int) (ConversationSearchResults, error)

func (*Client) ServerStatus 

func (r *Client) ServerStatus(ctx context.Context) (ServerStatus, error)

ServerStatus reports the connected server's version and build metadata.

func (*Client) StartAnthropicLogin 

func (r *Client) StartAnthropicLogin(ctx context.Context) (AnthropicLogin, error)

func (*Client) StartProviderDeviceLogin 

func (r *Client) StartProviderDeviceLogin(ctx context.Context, provider string) (ProviderDeviceLogin, error)

func (*Client) SteerConversation 

func (r *Client) SteerConversation(ctx context.Context, conversationID, message string, images []string) (bool, error)

SteerConversation queues steering content in the control plane that owns the active provider loop.

func (*Client) StopConversation 

func (r *Client) StopConversation(ctx context.Context, conversationID string) error

StopConversation requests cancellation of central and runner work before the client stream closes.

func (*Client) StopConversationTurn 

func (r *Client) StopConversationTurn(ctx context.Context, conversationID, turnID string) error

StopConversationTurn requests cancellation of one specific control-plane turn.

func (*Client) StreamConversation 

func (r *Client) StreamConversation(ctx context.Context, conversationID string, sink ChatEventSink) error

StreamConversation follows live events for one control-plane conversation across turns.

func (*Client) WorkspaceCWDSuggestions 

func (r *Client) WorkspaceCWDSuggestions(ctx context.Context, target WorkspaceTarget, query string) (protocol.WorkspaceCWDHintsResult, error)

WorkspaceCWDSuggestions resolves directory hints using runner-host paths.

func (*Client) WorkspaceRunners 

func (r *Client) WorkspaceRunners(ctx context.Context) ([]runnerregistry.Runner, error)

WorkspaceRunners lists the available targets using this client's server and credential.

type ClientOption 

type ClientOption func(*Client)

ClientOption configures the daemon HTTP client without discovering local state.

func WithHTTPClient 

func WithHTTPClient(client *http.Client) ClientOption

WithHTTPClient supplies the transport used for daemon requests. A nil client leaves the default streaming client in place.

type CodexStatus 

type CodexStatus struct {
	Connected      bool                  `json:"connected"`
	Authentication string                `json:"authentication,omitempty"`
	AccountID      string                `json:"accountId,omitempty"`
	ExpiresAt      int64                 `json:"expiresAt,omitempty"`
	CanRefresh     bool                  `json:"canRefresh,omitempty"`
	Usage          *auth.CodexUsageStats `json:"usage,omitempty"`
	UsageMessage   string                `json:"usageMessage,omitempty"`
}

CodexStatus is the server's account and live-usage view. It never contains tokens.

type ControlPlaneChatSettings 

type ControlPlaneChatSettings struct {
	ConversationHierarchyVersion int                         `json:"conversationHierarchyVersion,omitempty"`
	CurrentProfile               string                      `json:"currentProfile,omitempty"`
	Profiles                     []ControlPlaneProfileOption `json:"profiles"`
	Model                        string                      `json:"model"`
	ModelOptions                 []string                    `json:"modelOptions"`
	ReasoningEffort              string                      `json:"reasoningEffort"`
	ReasoningEffortOptions       []string                    `json:"reasoningEffortOptions"`
	DefaultCWD                   string                      `json:"defaultCWD,omitempty"`
	DefaultRunnerID              string                      `json:"defaultRunnerId,omitempty"`
	DefaultRunnerHostID          string                      `json:"defaultRunnerHostId,omitempty"`
	DefaultRunnerReady           bool                        `json:"defaultRunnerReady"`
}

ControlPlaneChatSettings contains server-owned settings for a new conversation.

type ControlPlaneHTTPError 

type ControlPlaneHTTPError struct {
	StatusCode int
	Message    string
}

ControlPlaneHTTPError reports a non-successful control-plane response.

func (*ControlPlaneHTTPError) Error 

func (e *ControlPlaneHTTPError) Error() string

func (*ControlPlaneHTTPError) Retryable 

func (e *ControlPlaneHTTPError) Retryable() bool

Retryable reports whether retrying the request may succeed without user action.

type ControlPlaneProfileOption 

type ControlPlaneProfileOption struct {
	Name   string `json:"name"`
	Scope  string `json:"scope"`
	Active bool   `json:"active,omitempty"`
	Hidden bool   `json:"hidden,omitempty"`
}

ControlPlaneProfileOption describes one model-policy profile advertised by the server.

type ControlPlaneStreamProtocolError 

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

ControlPlaneStreamProtocolError reports invalid data from a control-plane event stream.

func (*ControlPlaneStreamProtocolError) Error 

func (e *ControlPlaneStreamProtocolError) Error() string

func (*ControlPlaneStreamProtocolError) Retryable 

func (e *ControlPlaneStreamProtocolError) Retryable() bool

Retryable reports that reconnecting cannot repair deterministic stream data errors.

func (*ControlPlaneStreamProtocolError) Unwrap 

func (e *ControlPlaneStreamProtocolError) Unwrap() error

type ConversationHistory 

type ConversationHistory struct {
	ID                   string
	ParentConversationID string
	CWD                  string
	Title                string
	Provider             string
	Model                string
	Profile              string
	ReasoningEffort      string
	RunnerID             string
	EnvironmentProfile   string
	UpdatedAt            time.Time
	Usage                llmtypes.Usage
	Messages             []conversationservice.StreamableMessage
}

ConversationHistory is the client-facing persisted state needed to resume a conversation.

type ConversationMoveRequest 

type ConversationMoveRequest struct {
	RunnerID     string `json:"runnerId"`
	CWD          string `json:"cwd,omitempty"`
	Confirmation string `json:"confirmation,omitempty"`
}

ConversationMoveRequest selects a saved destination without contacting a runner. An omitted CWD preserves the saved directory. Confirmation is the digest of a previously returned move plan, not permission to replace conversation history.

type ConversationMoveResult 

type ConversationMoveResult struct {
	ConversationID     string `json:"conversationId"`
	SourceRunnerID     string `json:"sourceRunnerId,omitempty"`
	SourceCWD          string `json:"sourceCwd"`
	RunnerID           string `json:"runnerId"`
	RunnerName         string `json:"runnerName,omitempty"`
	CWD                string `json:"cwd"`
	EnvironmentProfile string `json:"environmentProfile,omitempty"`
	Confirmation       string `json:"confirmation"`
	Moved              bool   `json:"moved"`
}

ConversationMoveResult describes the source and destination, not execution readiness.

type ConversationSearchResults 

type ConversationSearchResults struct {
	Conversations []convtypes.ConversationSummary
	// Pending counts conversations not yet indexed for search; results may
	// be incomplete while it is nonzero.
	Pending int
}

type ConversationSearcher 

type ConversationSearcher interface {
	SearchConversations(ctx context.Context, query string, limit int) (ConversationSearchResults, error)
}

ConversationSearcher optionally searches persisted conversations by full text.

type ConversationSource 

type ConversationSource interface {
	ListConversations(ctx context.Context, limit int) ([]convtypes.ConversationSummary, error)
	LoadConversation(ctx context.Context, conversationID string) (ConversationHistory, error)
}

ConversationSource supplies persisted conversation summaries and normalized history to a chat client.

type ConversationStreamLifecycleSink 

type ConversationStreamLifecycleSink interface {
	ConversationStreamConnected(active bool) error
}

ConversationStreamLifecycleSink receives connection state for a persistent conversation stream.

type ConversationStreamer 

type ConversationStreamer interface {
	StreamConversation(ctx context.Context, conversationID string, sink ChatEventSink) error
}

ConversationStreamer follows live events for a persisted conversation across turns.

type EnvironmentResolver 

type EnvironmentResolver interface {
	ResolveEnvironment(ctx context.Context, req ChatRequest, conversationID string, config llmtypes.Config, resolvedCWD string) (agentenv.Environment, error)
}

EnvironmentResolver optionally selects a non-local environment for a chat request.

type Executor 

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

Executor orchestrates persisted chat turns, LLM threads, and execution environments.

func NewExecutor 

func NewExecutor(defaultCWD string, extensionRuntimes ...ExtensionRuntimeProvider) *Executor

NewExecutor creates a chat executor with cached conversation threads.

func (*Executor) Close 

func (r *Executor) Close() error

Close releases cached conversation threads and their persistent transports.

func (*Executor) CloseConversation 

func (r *Executor) CloseConversation(conversationID string) error

CloseConversation releases a cached thread when its conversation is removed.

func (*Executor) DefaultCWD 

func (r *Executor) DefaultCWD() string

DefaultCWD returns the executor's configured default working directory.

func (*Executor) ExtensionRuntimeProvider 

func (r *Executor) ExtensionRuntimeProvider() ExtensionRuntimeProvider

ExtensionRuntimeProvider returns the executor's configured extension runtime provider.

func (*Executor) Run 

func (r *Executor) Run(ctx context.Context, req ChatRequest, sink ChatEventSink) (string, error)

Run executes a single persisted chat turn and streams events to the sink.

func (*Executor) SetEnvironmentResolver 

func (r *Executor) SetEnvironmentResolver(resolver EnvironmentResolver)

SetEnvironmentResolver configures remote environment selection for subsequent requests.

type ExtensionRuntimeProvider 

type ExtensionRuntimeProvider interface {
	Runtime(ctx context.Context, cwd string) (*extensions.Runtime, error)
}

ExtensionRuntimeProvider supplies extension runtimes for chat turns.

type ProviderConnection 

type ProviderConnection struct {
	Provider  string `json:"provider"`
	Connected bool   `json:"connected"`
}

ProviderConnection contains only daemon connection status, never credentials.

type ProviderDeviceLogin 

type ProviderDeviceLogin struct {
	ID              string `json:"id"`
	Status          string `json:"status"`
	VerificationURL string `json:"verificationUrl,omitempty"`
	UserCode        string `json:"userCode,omitempty"`
	Message         string `json:"message,omitempty"`
}

ProviderDeviceLogin is the public part of a daemon-owned device login.

type RunnerStatus 

type RunnerStatus struct {
	Runner             *runnerregistry.Runner
	TerminalAuthorized bool
}

RunnerStatus describes the selected runner and the current user's terminal permission.

type ServerStatus 

type ServerStatus struct {
	Version   string `json:"version"`
	GitCommit string `json:"gitCommit,omitempty"`
	BuildTime string `json:"buildTime,omitempty"`
	APIReady  bool   `json:"apiReady"`
}

ServerStatus is the connected server's version, build metadata, and readiness.

type ServiceStoreAdapter 

type ServiceStoreAdapter struct {
	Service conversationservice.ConversationServiceInterface
}

func (ServiceStoreAdapter) Close 

func (s ServiceStoreAdapter) Close() error

func (ServiceStoreAdapter) Delete 

func (s ServiceStoreAdapter) Delete(context.Context, string) error

func (ServiceStoreAdapter) Load 

func (s ServiceStoreAdapter) Load(ctx context.Context, id string) (convtypes.ConversationRecord, error)

func (ServiceStoreAdapter) Query 

func (s ServiceStoreAdapter) Query(context.Context, convtypes.QueryOptions) (convtypes.QueryResult, error)

func (ServiceStoreAdapter) Save 

func (s ServiceStoreAdapter) Save(context.Context, convtypes.ConversationRecord) error

type SessionExtensionRelay 

type SessionExtensionRelay interface {
	Attachment() protocol.SessionExtensions
	SendFrame(context.Context, protocol.ExtensionFrame) error
	Close() error
	Done() <-chan struct{}
	Err() error
}

SessionExtensionRelay is a single authenticated, session-scoped callback connection. A closed relay cannot reconnect or replay callbacks; resuming requires a new attachment.

type TurnPendingError 

type TurnPendingError struct{ Receipt TurnReceipt }

TurnPendingError means the daemon already owns this exact submission.

func (*TurnPendingError) Error 

func (e *TurnPendingError) Error() string

func (*TurnPendingError) Retryable 

func (e *TurnPendingError) Retryable() bool

Retryable is false because the daemon already owns this submission.

type TurnReceipt 

type TurnReceipt struct {
	ConversationID  string    `json:"conversationId" db:"conversation_id"`
	TurnID          string    `json:"turnId" db:"turn_id"`
	RunID           string    `json:"runId,omitempty" db:"run_id"`
	Status          string    `json:"status" db:"status"`
	CancelRequested bool      `json:"cancelRequested,omitempty" db:"cancel_requested"`
	Result          *string   `json:"result,omitempty" db:"result"`
	Error           string    `json:"error,omitempty" db:"error"`
	CreatedAt       time.Time `json:"createdAt" db:"created_at"`
	UpdatedAt       time.Time `json:"updatedAt" db:"updated_at"`
}

TurnReceipt reconciles an ordinary persisted conversation submission. It is not an instruction to retry execution or replay transient tool/UI events.

func (TurnReceipt) Terminal 

func (r TurnReceipt) Terminal() bool

Terminal reports an authoritative outcome, including interrupted execution.

type UIConfirmEvent 

type UIConfirmEvent struct {
	ID                string `json:"id"`
	Title             string `json:"title"`
	Message           string `json:"message,omitempty"`
	ConfirmButtonText string `json:"confirmButtonText,omitempty"`
	CancelButtonText  string `json:"cancelButtonText,omitempty"`
}

UIConfirmEvent describes an extension-requested confirmation prompt.

type UIInputEvent 

type UIInputEvent struct {
	ID               string `json:"id"`
	Title            string `json:"title"`
	HelpText         string `json:"helpText,omitempty"`
	Message          string `json:"message,omitempty"`
	Placeholder      string `json:"placeholder,omitempty"`
	DefaultValue     string `json:"defaultValue,omitempty"`
	SubmitButtonText string `json:"submitButtonText,omitempty"`
	CancelButtonText string `json:"cancelButtonText,omitempty"`
	Required         bool   `json:"required,omitempty"`
	Secret           bool   `json:"secret,omitempty"`
}

UIInputEvent describes an extension-requested input prompt.

type UINotifyEvent 

type UINotifyEvent struct {
	Title   string `json:"title,omitempty"`
	Message string `json:"message"`
}

UINotifyEvent describes an extension-requested notification.

type UIPersistentAck 

type UIPersistentAck struct {
	RequestID string                     `json:"requestId"`
	Response  extensions.UIFrameResponse `json:"response"`
}

type UIPersistentEvent 

type UIPersistentEvent struct {
	RequestID        string                       `json:"requestId,omitempty"`
	RouteID          string                       `json:"routeId,omitempty"`
	Epoch            string                       `json:"epoch,omitempty"`
	Method           string                       `json:"method"`
	RunnerID         string                       `json:"runnerId,omitempty"`
	RunnerGeneration int64                        `json:"runnerGeneration,omitempty"`
	Owner            runnerpayload.ExtensionOwner `json:"owner"`
	Request          json.RawMessage              `json:"request,omitempty"`
}

UIPersistentEvent is an owner-targeted, acknowledged native UI operation. RouteID is opaque input authority; clients never select a runner or run ID.

type UIPersistentInput 

type UIPersistentInput struct {
	RouteID string          `json:"routeId"`
	Method  string          `json:"method"`
	Request json.RawMessage `json:"request"`
}

type UISelectEvent 

type UISelectEvent struct {
	ID               string   `json:"id"`
	Title            string   `json:"title"`
	Message          string   `json:"message,omitempty"`
	Options          []string `json:"options"`
	SubmitButtonText string   `json:"submitButtonText,omitempty"`
	CancelButtonText string   `json:"cancelButtonText,omitempty"`
}

UISelectEvent describes an extension-requested single-choice prompt.

type UIWidgetEvent 

type UIWidgetEvent struct {
	Key         string             `json:"key"`
	ExtensionID string             `json:"extension_id"`
	Generation  string             `json:"generation"`
	ID          string             `json:"id"`
	Placement   string             `json:"placement,omitempty"`
	Frame       extensions.UIFrame `json:"frame"`
	Removed     bool               `json:"removed,omitempty"`
}

UIWidgetEvent carries one persistent extension widget snapshot or removal.

type UncertainSubmissionError 

type UncertainSubmissionError struct {
	ConversationID, TurnID string
	Err                    error
}

UncertainSubmissionError retains the identities needed for safe reconciliation. Unwrap preserves transport/cancellation errors for existing callers.

func (*UncertainSubmissionError) Error 

func (e *UncertainSubmissionError) Error() string

func (*UncertainSubmissionError) Retryable 

func (e *UncertainSubmissionError) Retryable() bool

Retryable forbids execution retry; callers can make a read-only status query.

func (*UncertainSubmissionError) Unwrap 

func (e *UncertainSubmissionError) Unwrap() error

type WorkspaceShortcutRequest 

type WorkspaceShortcutRequest struct {
	Target   WorkspaceTarget             `json:"target"`
	RunID    string                      `json:"runId,omitempty"`
	Digest   string                      `json:"digest"`
	Shortcut protocol.ShortcutDescriptor `json:"shortcut"`
}

WorkspaceShortcutRequest binds an advertised shortcut to its discovery scope. RunID is present only for discovery of an active, pinned environment.

func (*WorkspaceShortcutRequest) UnmarshalJSON 

func (r *WorkspaceShortcutRequest) UnmarshalJSON(data []byte) error

func (WorkspaceShortcutRequest) Validate 

func (r WorkspaceShortcutRequest) Validate() error

type WorkspaceTarget 

type WorkspaceTarget struct {
	Profile            string                     `json:"profile,omitempty"`
	RunnerID           string                     `json:"runnerId,omitempty"`
	CWD                string                     `json:"cwd,omitempty"`
	EnvironmentProfile string                     `json:"environmentProfile,omitempty"`
	ConversationID     string                     `json:"conversationId,omitempty"`
	Options            *llmtypes.ExecutionOptions `json:"options,omitempty"`
}

WorkspaceTarget selects runner-owned discovery without interpreting paths on the client. Profile selects the daemon model profile independently of the runner's EnvironmentProfile; blank inherits the daemon's configured profile. ConversationID pins discovery to persisted runner/CWD affinity and the stored model profile; clients should omit Profile when discovering a saved conversation.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.