controller

type ConfigWriterDeleter interface {
	DeleteConfig(ctx context.Context, namespaceName types.NamespacedName) error
	EnsureConfigExists(ctx context.Context, namespaceName types.NamespacedName) error
	WriteEmptyConfig(ctx context.Context, namespaceName types.NamespacedName) error
}

type HTTPRouteWrapper struct {
	*gatewayv1.HTTPRoute
}

type MCPGatewayExtensionFinderValidator interface {
	HasValidReferenceGrant(ctx context.Context, mcpExt *mcpv1alpha1.MCPGatewayExtension) (bool, error)
	FindValidMCPGatewayExtsForGateway(ctx context.Context, g *gatewayv1.Gateway) ([]*mcpv1alpha1.MCPGatewayExtension, error)
}

type MCPGatewayExtensionReconciler struct {
	client.Client
	DirectAPIReader client.Reader
	Scheme          *runtime.Scheme

	ConfigWriterDeleter   ConfigWriterDeleter
	MCPExtFinderValidator MCPGatewayExtensionFinderValidator
	BrokerRouterImage     string
	// contains filtered or unexported fields
}

type MCPGatewayExtensionValidator struct {
	client.Client
	DirectAPIReader client.Reader // uncached reader
	Logger          *slog.Logger
}

type MCPReconciler struct {
	client.Client
	Scheme                *runtime.Scheme
	DirectAPIReader       client.Reader // uncached reader for fetching secrets
	ConfigReaderWriter    MCPServerConfigReaderWriter
	MCPExtFinderValidator MCPGatewayExtensionFinderValidator
}

type MCPServerConfigReaderWriter interface {
	UpsertMCPServer(ctx context.Context, server config.MCPServer, namespaceName types.NamespacedName) error
	// RemoveMCPServer removes a server from all config secrets cluster-wide
	RemoveMCPServer(ctx context.Context, serverName string) error
}

type MCPVirtualServerReconciler struct {
	client.Client
	DirectAPIReader client.Reader
	Scheme          *runtime.Scheme

	ConfigReaderWriter VirtualServerConfigReaderWriter
	// contains filtered or unexported fields
}

type ServerInfo struct {
	ID                 string
	Endpoint           string
	Hostname           string
	ToolPrefix         string
	HTTPRouteName      string
	HTTPRouteNamespace string
	Credential         string
}

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

type VirtualServerConfigReaderWriter interface {
	WriteVirtualServerConfig(ctx context.Context, virtualServers []config.VirtualServerConfig, namespaceName types.NamespacedName) error
}