grpc

type ConnectionManager interface {
	// Connect establishes a connection to the gRPC server
	Connect(ctx context.Context) error

	// GetConnection returns the current connection
	GetConnection() *grpcLib.ClientConn

	// IsConnected checks if the connection is healthy
	IsConnected() bool

	// Reconnect attempts to reconnect to the server
	Reconnect(ctx context.Context) error

	// HealthCheck performs a health check on the connection
	HealthCheck(ctx context.Context) error

	// Close closes the connection
	Close() error
}

type ConnectionManagerConfig struct {
	Host           string          `json:"host"`
	Port           int             `json:"port"`
	ConnectTimeout time.Duration   `json:"connect_timeout"`
	KeepAlive      KeepAliveConfig `json:"keep_alive"`
	MaxMessageSize int             `json:"max_message_size"`
}

type KeepAliveConfig struct {
	Time                time.Duration `json:"time"`
	Timeout             time.Duration `json:"timeout"`
	PermitWithoutStream bool          `json:"permit_without_stream"`
}

type MethodInfo = types.MethodInfo

type ReflectionClient interface {
	// DiscoverMethods discovers all methods using reflection
	DiscoverMethods(ctx context.Context) ([]types.MethodInfo, error)

	// InvokeMethod invokes a method using dynamic protobuf messages with optional headers
	InvokeMethod(ctx context.Context, headers map[string]string, method types.MethodInfo, inputJSON string) (string, error)

	// HealthCheck performs a health check
	HealthCheck(ctx context.Context) error

	// Close closes the reflection client
	Close() error
}

type ServiceDiscoverer interface {
	// Connect establishes connection to the gRPC server
	Connect(ctx context.Context) error

	// DiscoverServices discovers all available services
	DiscoverServices(ctx context.Context) error

	// GetMethods returns all discovered methods in a flat list
	GetMethods() []types.MethodInfo

	// InvokeMethodByTool invokes a gRPC method by tool name with optional headers
	InvokeMethodByTool(ctx context.Context, headers map[string]string, toolName string, inputJSON string) (string, error)

	// HealthCheck performs a health check
	HealthCheck(ctx context.Context) error

	// Close closes the service discoverer
	Close() error

	// GetMethodCount returns the total number of discovered methods
	GetMethodCount() int

	// GetServiceStats returns statistics about discovered services
	GetServiceStats() map[string]interface{}
}

type SourceLocation = types.SourceLocation