modality

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

type BusEvent struct {
	Type      string         `json:"type"`
	Modality  string         `json:"modality"`
	Channel   string         `json:"channel"`
	Timestamp time.Time      `json:"timestamp"`
	Data      map[string]any `json:"data,omitempty"`
}

type ChannelAdapter interface {
	// Connect joins a session, declaring supported modalities.
	Connect(sessionID string, descriptor *ChannelDescriptor) error

	// Disconnect leaves a session.
	Disconnect(sessionID string) error

	// HandleIncoming sends raw input from the channel to the kernel.
	HandleIncoming(channelID string, modality ModalityType, raw []byte) error

	// Deliver sends output from the kernel to the channel.
	Deliver(channelID string, output *EncodedOutput) error
}

type ChannelConnection struct {
	ID         string         `json:"id"`
	Modalities []ModalityType `json:"modalities"`
}

type ChannelDescriptor struct {
	ID         string         `json:"id"`                 // "discord-text", "claude-code", etc.
	Transport  string         `json:"transport"`          // "openclaw-gateway", "mcp", "http", "stdio"
	Input      []ModalityType `json:"input"`              // modalities this channel can receive
	Output     []ModalityType `json:"output"`             // modalities this channel can deliver
	SessionKey string         `json:"session_key"`        // pattern for session binding, e.g. "discord:{guild}:{channel}:{user}"
	Metadata   map[string]any `json:"metadata,omitempty"` // transport-specific data (guild ID, thread ID, etc.)
}

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

type CognitiveEvent struct {
	Modality   ModalityType   `json:"modality"`
	Channel    string         `json:"channel"`
	Content    string         `json:"content"`
	Confidence float64        `json:"confidence,omitempty"`
	Metadata   map[string]any `json:"metadata,omitempty"`
	Timestamp  time.Time      `json:"timestamp"`
}

type CognitiveIntent struct {
	Modality ModalityType   `json:"modality"`
	Channel  string         `json:"channel"`
	Content  string         `json:"content"`
	Params   map[string]any `json:"params,omitempty"`
}

type Decoder interface {
	Decode(raw []byte, modality ModalityType, channel string) (*CognitiveEvent, error)
}

type EncodedOutput struct {
	Modality ModalityType   `json:"modality"`
	Data     []byte         `json:"data,omitempty"`
	MimeType string         `json:"mime_type,omitempty"`
	Duration time.Duration  `json:"duration,omitempty"`
	Metadata map[string]any `json:"metadata,omitempty"`
}

type Encoder interface {
	Encode(intent *CognitiveIntent) (*EncodedOutput, error)
}

type ErrorData struct {
	Modality    string `json:"modality"`
	Module      string `json:"module"`
	Error       string `json:"error"`
	ErrorType   string `json:"error_type,omitempty"`
	Recoverable bool   `json:"recoverable,omitempty"`
}

type EventListener func(eventType string, data map[string]any)

type FieldRequiredError struct {
	EventType string
	Field     string
}

type Gate interface {
	Check(raw []byte, modality ModalityType) (*GateResult, error)
}

type GateData struct {
	Modality    string  `json:"modality"`
	Channel     string  `json:"channel"`
	Decision    string  `json:"decision"`
	Confidence  float64 `json:"confidence"`
	SpeechRatio float64 `json:"speech_ratio,omitempty"`
	DurationMs  int     `json:"duration_ms,omitempty"`
	Gate        string  `json:"gate,omitempty"`
}

type GateResult struct {
	Allowed    bool    `json:"allowed"`
	Confidence float64 `json:"confidence"`
	Reason     string  `json:"reason,omitempty"`
}

type InputData struct {
	Modality       string  `json:"modality"`
	Channel        string  `json:"channel"`
	Transcript     string  `json:"transcript"`
	GateConfidence float64 `json:"gate_confidence,omitempty"`
	SpeechRatio    float64 `json:"speech_ratio,omitempty"`
	LatencyMs      int     `json:"latency_ms,omitempty"`
	Engine         string  `json:"engine,omitempty"`
}

type ManagedModule struct {
	Name, Command string
	Args          []string
	Conn          *SubprocessConn
	Status        ModuleStatus
	PID           int
	StartedAt     time.Time
	Restarts      int
	MaxRestarts   int
	LastError     string
	// contains filtered or unexported fields
}

type ModalityType string

type Module interface {
	// Type returns the modality this module handles.
	Type() ModalityType

	// Gate returns the input gate, or nil for passthrough modalities
	// that accept all input (e.g., text).
	Gate() Gate

	// Decoder returns the signal-to-event decoder.
	Decoder() Decoder

	// Encoder returns the intent-to-signal encoder.
	Encoder() Encoder

	// State returns current operational state for health monitoring
	// and the agent's HUD.
	State() *ModuleState

	// Start initializes the module. For subprocess-backed modules,
	// this spawns the Python child process and waits for readiness.
	Start(ctx context.Context) error

	// Stop gracefully shuts down the module, sending shutdown commands
	// to any child processes and waiting for clean exit.
	Stop(ctx context.Context) error

	// Health returns the current operational status of the module.
	Health() ModuleStatus
}

type ModuleState struct {
	Status    ModuleStatus   `json:"status"`
	Modality  ModalityType   `json:"modality"`
	PID       int            `json:"pid,omitempty"`
	Uptime    time.Duration  `json:"uptime,omitempty"`
	LastError string         `json:"last_error,omitempty"`
	Metrics   map[string]any `json:"metrics,omitempty"`
}

type ModuleStatus string

type OutputData struct {
	Modality    string  `json:"modality"`
	Channel     string  `json:"channel"`
	Text        string  `json:"text"`
	Engine      string  `json:"engine,omitempty"`
	Voice       string  `json:"voice,omitempty"`
	RTF         float64 `json:"rtf,omitempty"`
	DurationSec float64 `json:"duration_sec,omitempty"`
	LatencyMs   int     `json:"latency_ms,omitempty"`
}

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

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

type SalienceEntry struct {
	Key       string    `json:"key"`
	Score     float64   `json:"score"`
	LastEvent time.Time `json:"last_event"`
	EventType string    `json:"event_type"`
	Count     int       `json:"count"`
}

type StateChangeData struct {
	Modality  string `json:"modality"`
	Module    string `json:"module"`
	FromState string `json:"from_state"`
	ToState   string `json:"to_state"`
	PID       int    `json:"pid,omitempty"`
}

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

type SupervisorConfig struct {
	Name           string
	Command        string
	Args           []string
	MaxRestarts    int           // default 5
	HealthInterval time.Duration // default 10s
	StderrLogDir   string        // default ".cog/run/modality/{name}"
}

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

type TransformData struct {
	FromModality string `json:"from_modality"`
	ToModality   string `json:"to_modality"`
	Step         string `json:"step"`
	Engine       string `json:"engine,omitempty"`
	LatencyMs    int    `json:"latency_ms,omitempty"`
	InputBytes   int    `json:"input_bytes,omitempty"`
	OutputChars  int    `json:"output_chars,omitempty"`
}

type WireMessage struct {
	ID   string `json:"id"`
	Type string `json:"type"` // "request", "response", "error", "command", "event"
	Ts   string `json:"ts"`
	// Request
	Module    string         `json:"module,omitempty"`
	Operation string         `json:"op,omitempty"`
	Data      map[string]any `json:"data,omitempty"`
	// Response
	Result map[string]any `json:"result,omitempty"`
	// Streaming (reserved)
	Chunk int  `json:"chunk,omitempty"`
	Done  bool `json:"done,omitempty"`
	// Command
	Command string `json:"command,omitempty"`
	// Event
	Event  string `json:"event,omitempty"`
	Status string `json:"status,omitempty"`
	// Error
	Error       string `json:"error,omitempty"`
	ErrorType   string `json:"error_type,omitempty"`
	Recoverable bool   `json:"recoverable,omitempty"`
}