Struct Handler

server/handler.go:36–75

Handler implements the ChatCLIService gRPC server.

// Handler implements the ChatCLIService gRPC server.
type Handler struct {
	pb.UnimplementedChatCLIServiceServer

	llmManager     manager.LLMManager
	sessionManager SessionStore
	logger         *zap.Logger

	// default provider/model from server config
	defaultProvider string
	defaultModel    string

	// K8s watcher context injection (optional, set when watcher is active)
	watcherContextFunc func() string
	watcherStatusFunc  func() string // compact status summary
	watcherStatsFunc   func() (alertCount, snapshotCount, podCount int)
	watcherAlertsFunc  func() []AlertInfo // raw alerts for AIOps operator
	watcherDeployment  string
	watcherNamespace   string

	// Prometheus metrics (optional, nil when metrics are disabled)
	llmMetrics     *metrics.LLMMetrics
	sessionMetrics *metrics.SessionMetrics

	// Remote resource discovery (optional, nil when not configured)
	pluginManager *plugins.Manager
	personaLoader *persona.Loader

	// Provider fallback chain (optional, nil when not configured)
	fallbackChain *fallback.Chain

	// MCP manager (optional, nil when not configured)
	mcpManager *mcp.Manager

	// Security: SSRF validator for provider URL checking (H1)
	ssrfValidator *SSRFValidator

	// Conversation hub broker for cross-channel continuity (optional, nil when
	// the hub is disabled). Set via SetHub.
	hub hub.Broker
}

// SessionStore abstracts session persistence for testability.
type SessionStore interface {