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 with the specified command
	// The startCmd parameter allows sessions to use different commands than the adapter default
	// The transportURL parameter is for ACP adapter (e.g., "stdio://", "tcp://host:port", "unix:///path")
	// Other adapters should ignore this parameter
	// The env parameter sets session-level environment variables (merged with adapter-level env)
	CreateSession(sessionName, workDir, startCmd, transportURL string, env map[string]string) error
}

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 TranscriptMessage struct {
	Type      string         `json:"type"` // "user", "assistant", "progress", etc.
	SessionID string         `json:"sessionId"`
	IsMeta    bool           `json:"isMeta"`
	Message   MessageContent `json:"message"`
}