types

type CallOptions struct {
	Strategy CallStrategy
	Timeout  time.Duration
}

type CallResult struct {
	Response any
	Error    error
	IsLocal  bool
	IsRemote bool
	Duration time.Duration
}

type CallStrategy int

type DependencyEntry struct {
	Name string
	Type DependencyType
}

type DependencyType string

type EventBusInterface interface {
	Subscribe(eventName string, handler func(any))
	Publish(eventName string, data any)
	PublishWithRetry(eventName string, data any, maxRetries int)
	GetMetrics() map[string]any
}

type EventData struct {
	Time      time.Time `json:"time"`
	Source    string    `json:"source"`
	EventType string    `json:"event_type"`
	Data      any       `json:"data"`
}

type EventTarget int

type Handler any

type Interface interface {
	Name() string
	Version() string
	Init(conf *config.Config, m ManagerInterface) error
	GetMetadata() Metadata

	GetHandlers() Handler
	GetServices() Service

	Dependencies() []string

	OptionalMethods
}

type ManagerInterface interface {
	GetConfig() *config.Config

	InitExtensions() error
	RegisterExtension(ext Interface) error
	GetExtensionByName(name string) (Interface, error)
	ListExtensions() map[string]*Wrapper

	GetHandlerByName(name string) (Handler, error)
	ListHandlers() map[string]Handler
	GetServiceByName(name string) (Service, error)
	ListServices() map[string]Service

	GetCrossService(extensionName, servicePath string) (any, error)
	RegisterCrossService(key string, service any)

	CallService(ctx context.Context, serviceName, methodName string, req any) (*CallResult, error)
	CallServiceWithOptions(ctx context.Context, serviceName, methodName string, req any, opts *CallOptions) (*CallResult, error)

	LoadPlugins() error
	LoadPlugin(path string) error
	ReloadPlugin(name string) error
	UnloadPlugin(name string) error

	GetExtensionPublisher(name string, publisherType reflect.Type) (any, error)
	GetExtensionSubscriber(name string, subscriberType reflect.Type) (any, error)
	PublishEvent(eventName string, data any, target ...EventTarget)
	PublishEventWithRetry(eventName string, data any, maxRetries int, target ...EventTarget)
	SubscribeEvent(eventName string, handler func(any), source ...EventTarget)

	RegisterConsulService(name string, info *ServiceInfo) error
	DeregisterConsulService(name string) error
	GetConsulService(name string) (*api.AgentService, error)
	CheckServiceHealth(name string) string
	GetHealthyServices(name string) ([]*api.ServiceEntry, error)
	GetServiceCacheStats() map[string]any

	RegisterRoutes(router *gin.Engine)
	ManageRoutes(router *gin.RouterGroup)

	ExecuteWithCircuitBreaker(extensionName string, fn func() (any, error)) (any, error)

	PublishMessage(exchange, routingKey string, body []byte) error
	SubscribeToMessages(queue string, handler func([]byte) error) error

	GetMetadata() map[string]Metadata
	GetStatus() map[string]string
	GetEventsMetrics() map[string]any

	Cleanup()

	Register(ext Interface) error                     // deprecated: use RegisterExtension
	GetExtension(name string) (Interface, error)      // deprecated: use GetExtensionByName
	GetExtensions() map[string]*Wrapper               // deprecated: use ListExtensions
	GetHandler(name string) (Handler, error)          // deprecated: use GetHandlerByName
	GetHandlers() map[string]Handler                  // deprecated: use ListHandlers
	GetService(extensionName string) (Service, error) // deprecated: use GetServiceByName
	GetServices() map[string]Service                  // deprecated: use ListServices
	RefreshCrossServices()                            // deprecated: automatic refresh
}

type Metadata struct {
	// Name is the name of the extension
	Name string `json:"name,omitempty"`
	// Version is the version of the extension
	Version string `json:"version,omitempty"`
	// Dependencies are the dependencies of the extension
	Dependencies []string `json:"dependencies,omitempty"`
	// Description is the description of the extension
	Description string `json:"description,omitempty"`
	// Type is the type of the extension, e.g. core, business, plugin, module, etc
	Type string `json:"type,omitempty"`
	// Group is the belong group of the extension, e.g. iam, res, flow, sys, org, rt, plug, etc
	Group string `json:"group,omitempty"`
}

type OptionalImpl struct{}

type OptionalMethods interface {
	PreInit() error
	PostInit() error
	PreCleanup() error
	Cleanup() error

	Status() string

	GetAllDependencies() []DependencyEntry

	NeedServiceDiscovery() bool
	GetServiceInfo() *ServiceInfo

	GetPublisher() any
	GetSubscriber() any

	RegisterRoutes(router *gin.RouterGroup)
}

type PluginLoaderInterface interface {
	LoadPlugin(path string, manager ManagerInterface) error
	UnloadPlugin(name string) error
	GetPlugin(name string) *Wrapper
	GetPlugins() map[string]*Wrapper
	RegisterPlugin(ext Interface, metadata Metadata)
	GetRegisteredPlugins() []*Wrapper
}

type Service any

type ServiceDiscoveryInterface interface {
	RegisterService(name string, info *ServiceInfo) error
	DeregisterService(name string) error
	GetService(name string) (*api.AgentService, error)
	CheckServiceHealth(name string) string
	GetHealthyServices(name string) ([]*api.ServiceEntry, error)
	SetCacheTTL(ttl time.Duration)
	ClearCache()
	GetCacheStats() map[string]any
}

type ServiceInfo struct {
	Address string            `json:"address"`
	Tags    []string          `json:"tags"`
	Meta    map[string]string `json:"meta"`
}

type Wrapper struct {
	Metadata Metadata  `json:"metadata"`
	Instance Interface `json:"instance,omitempty"`
}