cli

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

type ACPAdapterConfig struct {
	// Idle timeout - max time without any activity before cancelling request
	// Default: 5 minutes. If the agent is actively working (sending updates),
	// the request will continue. Only cancelled if there's no activity for this duration.
	IdleTimeout time.Duration `yaml:"idle_timeout"`

	// Max total timeout - absolute maximum time for a request regardless of activity
	// Default: 1 hour. This is a hard limit to prevent truly hung requests.
	MaxTotalTimeout time.Duration `yaml:"max_total_timeout"`

	// Environment variables for ACP server process
	Env map[string]string `yaml:"env"`

	// Deprecated: Use IdleTimeout instead
	// Kept for backward compatibility
	RequestTimeout time.Duration `yaml:"request_timeout"`
}

type ACPTransportType string

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

type CLIAdapter interface {
	// SendInput sends input to the CLI (via tmux send-keys)
	SendInput(sessionName, input string) error

	// HandleHookData handles raw hook data from the CLI
	// The adapter is responsible for:
	//   - Parsing the data (in any format: JSON, text, etc.)
	//   - Extracting the last user prompt for tmux filtering
	//   - Extracting the session name from the data
	//   - Processing the hook data and generating the response
	//
	// This interface is protocol-agnostic - it works with HTTP, gRPC, message queues, etc.
	// The engine is responsible for extracting the raw data from the transport layer.
	//
	// Parameter data: raw hook data (bytes)
	// Returns: (sessionName, lastUserPrompt, responseText, error)
	//   - sessionName: which session this hook is for (cwd)
	//   - lastUserPrompt: the last user's input (for filtering tmux output)
	//   - responseText: the CLI's response to send back to the user
	//   - error: any error that occurred
	HandleHookData(data []byte) (sessionName string, lastUserPrompt string, response string, err error)

	// IsSessionAlive checks if the session is still alive
	IsSessionAlive(sessionName string) bool

	// CreateSession creates a new session and starts the CLI.
	// Use WithWorkDir, WithStartCmd, WithTransportURL, WithEnv, WithYolo, WithResume options.
	CreateSession(sessionName string, opts ...SessionOption) error

	// StopSession stops and cleans up a running session.
	StopSession(sessionName string) error
}

type CLIEvent struct {
	Type     CLIEventType
	Content  string            // Text content or tool output
	ToolID   string            // For tool_use/tool_result: tool call ID
	ToolName string            // For tool_use/tool_result: tool name
	ToolMeta map[string]string // For tool_use: command, file_path, etc.
}

type CLIEventType string

type ClaudeAdapter struct {
	BaseAdapter
}

type ClaudeAdapterConfig struct {
	Env map[string]string // Environment variables to set for the CLI process
}

type ContentBlock struct {
	Type     string `json:"type"` // "text", "thinking", "image", etc.
	Text     string `json:"text,omitempty"`
	Thinking string `json:"thinking,omitempty"`
}

type Engine interface {
	SendToBot(platform, channel, message string)
	SendResponseToSession(sessionName, message string)
}

type GeminiAdapter struct {
	BaseAdapter
}

type GeminiAdapterConfig struct {
	Env map[string]string // Environment variables to set for the CLI process
}

type MessageContent struct {
	ID          string         `json:"id,omitempty"`
	Type        string         `json:"type,omitempty"`  // "message" for assistant
	Role        string         `json:"role,omitempty"`  // "user" or "assistant"
	Model       string         `json:"model,omitempty"` // Model name
	Content     []ContentBlock `json:"content,omitempty"`
	ContentText string         `json:"-"`                     // Extracted when content is a string
	StopReason  string         `json:"stop_reason,omitempty"` // null if incomplete, "end_turn"/"max_tokens" if complete
}

type OpenCodeAdapter struct {
	BaseAdapter
}

type OpenCodeAdapterConfig struct {
	Env map[string]string // Environment variables to set for the CLI process
}

type OpenCodeSessionInfo struct {
	ID        string `json:"id"`
	ProjectID string `json:"projectID"`
	Time      struct {
		Updated int64 `json:"updated"`
	} `json:"time"`
}

type SessionOption func(*SessionOptions)

type SessionOptions struct {
	WorkDir      string
	StartCmd     string
	TransportURL string
	Env          map[string]string
	Yolo         bool
	Resume       bool // Resume previous conversation on first turn
}

type StreamingCLI interface {
	// SendInputStreaming sends input and returns a channel of intermediate events.
	// The channel is closed when the turn completes (normally or on error).
	// Implementations must also satisfy CLIAdapter for session management.
	SendInputStreaming(sessionName, input string) (<-chan CLIEvent, error)
}

type TranscriptMessage struct {
	Type             string         `json:"type"` // "user", "assistant", "progress", etc.
	SessionID        string         `json:"sessionId"`
	IsMeta           bool           `json:"isMeta"`           // Legacy field, replaced by IsSidechain in newer versions
	IsSidechain      bool           `json:"isSidechain"`      // Replaces isMeta in Claude Code >= 2.1.x
	IsCompactSummary bool           `json:"isCompactSummary"` // Context compaction summary messages
	Message          MessageContent `json:"message"`
}