termmux

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

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

type ConfigDirManager struct {
	BaseDir string
}

type EventSourceConfig struct {
	// OTEL callbacks — set by the driver's event handler
	OtelCallbacks otelserver.Callbacks

	// Session log path and callback — set by the driver
	SessionLogPath   string
	OnSessionLogLine func(line []byte)

	// Hook event handler — set by the driver
	OnHookEvent func(eventName string, payload []byte) []monitor.AgentEvent
}

type ManagerOption func(*SessionManager)

type Session struct {
	ID     string
	Config SessionConfig
	VT     *VirtualTerminal
	// contains filtered or unexported fields
}

type SessionConfig struct {
	DriverType  string
	Command     string
	Args        []string
	CWD         string
	Env         map[string]string
	InitialRows int
	InitialCols int
}

type SessionEventSources struct {
	OtelServer    *otelserver.Server
	SessionTailer *sessionlog.Tailer
	// contains filtered or unexported fields
}

type SessionInfo struct {
	ID          string
	DriverType  string
	Command     string
	State       monitor.State
	SubState    monitor.SubState
	CreatedAt   time.Time
	ClientCount int
}

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

type StreamTerminalRequest struct {
	SessionID string `json:"session_id"`
}

type TerminalAttached struct {
	Rows       int    `json:"rows"`
	Cols       int    `json:"cols"`
	Scrollback []byte `json:"scrollback,omitempty"`
}

type TerminalClientMessage struct {
	Attach *StreamTerminalRequest `json:"attach,omitempty"`
	Input  *TerminalInput         `json:"input,omitempty"`
	Resize *TerminalResize        `json:"resize,omitempty"`
}

type TerminalDetached struct {
	Reason string `json:"reason"` // "session_ended", "kicked", "error"
}

type TerminalInput struct {
	Data []byte `json:"data"`
}

type TerminalOutput struct {
	Data []byte `json:"data"`
}

type TerminalResize struct {
	Rows int `json:"rows"`
	Cols int `json:"cols"`
}

type TerminalServerMessage struct {
	Attached *TerminalAttached `json:"attached,omitempty"`
	Output   *TerminalOutput   `json:"output,omitempty"`
	Detached *TerminalDetached `json:"detached,omitempty"`
}

type TerminalSubscription struct {
	ID     string
	Chunks chan []byte   // Buffered channel acts as bounded queue
	Done   chan struct{} // Closed when subscription is cancelled

	// Scrollback snapshot delivered on subscribe
	Scrollback []byte
	Rows, Cols int
}

type VirtualTerminal struct {
	Ptm *os.File // PTY master
	Cmd *exec.Cmd
	Mu  sync.Mutex // Guards all terminal state and writes

	Rows, Cols int
	ChildRows  int

	// Child process state
	ChildExited bool
	ChildHung   bool
	ExitError   error
	// contains filtered or unexported fields
}