appmgr

type App interface {
	// Init initializes application by config
	// Any error will cause process exit with error status
	Init()

	// Run runs application
	Run() error

	// RunOrExit runs application and exits with error status if got any error
	RunOrExit()

	// RegisterMiddleware registers a middleware with name in application
	// The middlewares need to be registered before calling App.Init
	RegisterMiddleware(string, Middleware)

	// AddJob adds job func with name into application
	AddJob(string, func(ctx context.Context) error)

	// GetContext gets context of application
	GetContext() context.Context

	// GetService gets service object by name
	GetService(string) Service

	// GetGrpcClientConn gets grpc client conn interface by name
	GetGrpcClientConn(string) grpc.ClientConnInterface

	// GetGrpcClientConns gets grpc client conn interfaces by name for different endpoints
	GetGrpcClientConns(string) []grpc.ClientConnInterface

	// GetDatabaseClient gets database gorm client by name
	GetDatabaseClient(string) *gorm.DB

	// GetDatabaseSqlxClient gets database mssqlx client by name
	GetDatabaseSqlxClient(string) *mssqlx.DBs

	// GetCacheClient gets cache client by name
	GetCacheClient(string) cache.Client

	// GetPulsarClient gets Pulsar client by name
	GetPulsarClient(string) pulsar.Client

	// GetIDGenerator gets uniqueid Generator
	GetIDGenerator() uniqueid.Generator
}

type AppConfig struct {
	Name        string            `json:"name" mapstructure:"name"`
	Observable  ObservableConfig  `json:"observable" mapstructure:"observable"`
	Services    []ServiceConfig   `json:"services" mapstructure:"services"`
	Jobs        []string          `json:"jobs" mapstructure:"jobs"`
	Clients     ClientsConfig     `json:"clients" mapstructure:"clients"`
	Databases   []database.Config `json:"databases" mapstructure:"databases"`
	Caches      []cache.Config    `json:"caches" mapstructure:"caches"`
	Pulsars     []pulsar.Config   `json:"pulsar" mapstructure:"pulsars"`
	IDGenerator IDGeneratorConfig `json:"id_generator" mapstructure:"id_generator"`
}

type AppInfo struct {
	Name        string
	Version     string
	Description string
}

type ClientManager interface {
	GetGrpcClientConn(string) grpc.ClientConnInterface
	GetGrpcClientConns(string) []grpc.ClientConnInterface
}

type ClientsConfig struct {
	Grpc GrpcConfig `json:"grpc" mapstructure:"grpc"`
}

type DatabaseManager interface {
	GetDatabaseClient(string) *gorm.DB
	GetDatabaseSqlxClient(string) *mssqlx.DBs
}

type EndpointsConfig struct {
	Grpc string `json:"grpc" mapstructure:"grpc"`
	Http string `json:"http" mapstructure:"http"`
}

type GrpcConfig struct {
	Middlewares []interface{}      `json:"middlewares" mapstructure:"middlewares"`
	Servers     []GrpcServerConfig `json:"servers" mapstructure:"servers"`
}

type GrpcSecurityConfig struct {
	Cert string `json:"cert" mapstructure:"cert"`
	Key  string `json:"key" mapstructure:"key"`
	Ca   string `json:"ca" mapstructure:"ca"`
}

type GrpcServerConfig struct {
	Name     string             `json:"name" mapstructure:"name" validate:"required"`
	Endpoint string             `json:"endpoint" mapstructure:"endpoint" validate:"required"`
	Security GrpcSecurityConfig `json:"security" mapstructure:"security"`
}

type IContextGetter interface {
	Value(key interface{}) interface{}
}

type IDGeneratorConfig struct {
	ServiceID int    `json:"service_id" mapstructure:"service_id"`
	Key       string `json:"key" mapstructure:"key"`
}

type Middleware interface {
	GinHandler(map[string]interface{}) gin.HandlerFunc
	GrpcServerInterceptor(map[string]interface{}) (grpc.UnaryServerInterceptor, grpc.StreamServerInterceptor)
	GrpcClientInterceptor(map[string]interface{}) (grpc.UnaryClientInterceptor, grpc.StreamClientInterceptor)
}

type ObservableConfig struct {
	Endpoints EndpointsConfig `json:"endpoints" mapstructure:"endpoints" validate:"required"`
	Modules   []string        `json:"modules" mapstructure:"modules"`
}

type ObservableService interface {
	GetContext() context.Context
	Run() error
	Wait()
}

type Service interface {
	GetContext() context.Context
	GetName() string
	GetApp() App
	GetGrpcEndpoint() string
	GetHttpEndpoint() string
	GetGrpcServiceRegistrar() grpc.ServiceRegistrar
	GetGrpcChannelClient() grpc.ClientConnInterface
	GetServeMux() *runtime.ServeMux
	GetGinRouter() gin.IRoutes
	AddHealthCheck(name string, check health.CheckFunc)
	Run() error
	Wait()
}

type ServiceConfig struct {
	Name        string                `json:"name" mapstructure:"name" validate:"required"`
	Endpoints   EndpointsConfig       `json:"endpoints" mapstructure:"endpoints" validate:"required"`
	Security    ServiceSecurityConfig `json:"security" mapstructure:"security"`
	Middlewares []interface{}         `json:"middlewares" mapstructure:"middlewares"`
}

type ServiceSecurityConfig struct {
	Grpc GrpcSecurityConfig `json:"grpc" mapstructure:"grpc"`
}