types

type Engine interface {
	Event(string, func(*Event))
	Call(string, *Event)
}

type Environment struct {
	Name  string
	Debug string
}

type Event struct {
	Name          string
	Exchange      string // Service exchange.
	RoutingKey    string // Service routing key.
	Data          interface{}
	ReplyTo       IReplyTo
	CorrelationId string
	Debug         bool
	Body          IRabbitBody
}

type GrpcClient struct {
	Name          string
	Host          string
	Port          string
	ClientOptions []grpc.DialOption
	Clients       []IGrpcServiceClient
}

type GrpcConfig struct {
	Server  IGrpcServer
	Clients []IGrpcClient
}

type GrpcServer struct {
	Port          string
	Router        func(*grpc.Server)
	ServerOptions []grpc.ServerOption
}

type HttpServer struct {
	Port       string
	Middleware func(*gin.Engine)
	Router     func(*gin.Engine)
	Gzip       bool
	Mode       string
}

type IEnvironment interface {
	GetName() string
	GetDebug() string
}

type IEvent interface {
	GetName() string
	GetData() interface{}
	GetReplyTo() IReplyTo
	GetCorrelationId() string
	GetExchange() string
	GetRoutingKey() string
	GetBody() []byte
	GetDebug() bool
}

type IFrameworkRabbitMQPublisher interface {
	Publish(IEvent) error
}

type IGrpcClient interface {
	GetName() string
	GetHost() string
	GetPort() string
	GetClientOptions() []grpc.DialOption
	GetClients() []IGrpcServiceClient
}

type IGrpcConfig interface {
	GetServer() IGrpcServer
	GetClients() []IGrpcClient
}

type IGrpcServer interface {
	GetPort() string
	GetRouter() func(*grpc.Server)
	GetServerOptions() []grpc.ServerOption
}

type IGrpcServiceClient interface {
	SetConnection(*grpc.ClientConn)
}

type IHttpServer interface {
	GetPort() string
	GetMode() string
	GetMiddleware() func(*gin.Engine)
	GetRouter() func(*gin.Engine)
	GetGzip() bool
}

type IMongoDB interface {
	GetDsn() string
	GetDatabase() string
	GetRepositories() []IMongoDBRepository
}

type IMongoDBRepository interface {
	SetDriver(*mongo.Database)
}

type IMySQL interface {
	GetHost() string
	GetPort() string
	GetUsername() string
	GetPassword() string
	GetDatabase() string
	GetCharset() string
	GetParseTime() string
	GetLoc() string
	DebugMode() bool
	GetRepositories() []IMySQLRepository
	GetDsn() string
	Migration() bool
	GetQueryFields() bool
	GetDisableNestedTransaction() bool
}

type IMySQLRepository interface {
	SetDriver(*gorm.DB, *sync.RWMutex)
}

type IRabbitBody interface {
	SetEvent(string)
	SetData(interface{})
	GetEvent() string
	GetData() interface{}
	Setup()
}

type IRabbitMQConfig interface {
	GetServers() []IRabbitMQServer
}

type IRabbitMQConsumer interface {
	GetName() string
	GetExchange() string
	GetExchangeType() string
	GetRoutingKey() string
	GetQueue() string
	GetDebug() bool
	GetListener() func(Engine)
	GenerateReplyTo() ReplyTo
	GetBody() IRabbitBody
}

type IRabbitMQDsn interface {
	GetHost() string
	GetPort() string
	GetUsername() string
	GetPassword() string
	GetVirtualHost() string
}

type IRabbitMQPublisher interface {
	GetName() string
	GetClients() []IRabbitMQServiceClient
}

type IRabbitMQServer interface {
	GetHost() string
	GetPort() string
	GetUsername() string
	GetPassword() string
	GetVHost() string
	GetConsumers() []IRabbitMQConsumer
	GetPublishers() []IRabbitMQPublisher
	GetAutoAck() bool
}

type IRabbitMQServiceClient interface {
	SetConnection(IFrameworkRabbitMQPublisher)
}

type IRedis interface {
	GetHost() string
	GetPort() string
	GetUsername() string
	GetPassword() string
	GetDatabase() int
	GetDsn() string
	// DebugMode() bool
	GetRepositories() []IRedisRepository
}

type IRedisRepository interface {
	SetDriver(*redis.Client)
}

type IReplyTo interface {
	SetRoutingKey(string)
	Get() string
}

type ITcpClient interface {
	GetName() string
	GetHost() string
	GetPort() string
	GetMode() string
	GetClients() []ITcpServiceClient
}

type ITcpConfig interface {
	GetServers() []ITcpServer
	GetClients() []ITcpClient
}

type ITcpServer interface {
	GetPort() string
	GetMode() string
	GetHandler() ITcpServiceHandler
}

type ITcpServiceClient interface {
	OnConnect()
	OnDisconnect()
}

type ITcpServiceHandler interface {
	OnConnect()
	OnDisconnect()
}

type IWebSocketBody interface {
	SetAction(string)
	SetData(interface{})
	GetAction() string
	GetData() interface{}
	Setup()
}

type IWebSocketEvent interface {
	GetConnection() *websocket.Conn
	GetName() string
	GetData() interface{}
	GetBody() []byte
	GetDebug() bool
}

type IWebSocketEventHandler interface {
	Event(string, func(IWebSocketEvent))
	Call(string, IWebSocketEvent)
}

type IWebSocketRoute interface {
	Initialize(*gin.Engine, bool)
}

type IWebSocketServer interface {
	GetPort() string
	GetMode() string
	GetRoutes() []IWebSocketRoute
}

type IdentityNetwork struct {
	Hostname     []string `desc:"Hostname"`
	IPV4         []net.IP `desc:"IPV4 Address"`
	IPV6         []net.IP `desc:"IPV6 Address"`
	NetInterface []string `desc:"Network Interface"`
}

type IdentityService struct {
	Name        string
	Description string
	ServiceDns  string `desc:"Service DNS"`
	Layer       string `desc:"Microservice Layer"`
	Author      string
}

type IdentitySource struct {
	Repository    string `desc:"Repository URL"`
	Documentation string `desc:"Documentation URL"`
}

type MongoDB struct {
	Dsn          string
	Database     string
	Repositories []IMongoDBRepository
}

type MySQL struct {
	Host                     string
	Port                     string
	Username                 string
	Password                 string
	Database                 string
	Charset                  string
	ParseTime                string
	Loc                      string
	Debug                    bool
	Gorm                     *gorm.DB
	DB                       *sql.DB
	Repositories             []IMySQLRepository
	EnableMigration          bool
	QueryFields              bool
	DisableNestedTransaction bool
}

type RabbitBody struct {
	Payload interface{}
	Event   string      `json:"event"`
	Data    interface{} `json:"data"`
}

type RabbitMQConfig struct {
	Servers []IRabbitMQServer
}

type RabbitMQConsumer struct {
	Name          string `json:"name"`
	Exchange      string `json:"exchange"`
	ExchangeType  string `json:"type"`
	RoutingKey    string `json:"routing_key"`
	Queue         string `json:"queue"`
	Debug         string `json:"debug"`
	Listener      func(Engine)
	CustomPayload IRabbitBody `json:"custom_payload"`
}

type RabbitMQDsn struct {
	Host, Port, Username, Password, VirtualHost string
}

type RabbitMQPublisher struct {
	Name    string `json:"name"`
	Clients []IRabbitMQServiceClient
}

type RabbitMQServer struct {
	Host        string
	Port        string
	Username    string
	Password    string
	VirtualHost string
	Consumers   []IRabbitMQConsumer
	Publishers  []IRabbitMQPublisher
	AutoAck     bool
}

type Redis struct {
	Host         string
	Port         string
	Username     string
	Password     string
	Database     int
	Debug        bool
	Repositories []IRedisRepository
}

type Replica struct {
	IPV4 []net.IP `desc:"Replica IPV4 Address"`
	IPV6 []net.IP `desc:"Replica IPV6 Address"`
}

type ReplyTo struct {
	Exchange   string `json:"exchange"`
	RoutingKey string `json:"routing_key"`
}

type Repository struct {
	DB  *gorm.DB
	Mu  *sync.RWMutex
	Con *sql.DB

	// sync
	DbName string
	Table  string
}

type Response struct {
	Code    int    `json:"code"`
	Status  string `json:"status"`
	Message string `json:"message,omitempty"`
}

type SqLite struct {
	Debug           bool
	DBPath          string
	Repositories    []IMySQLRepository
	EnableMigration bool

	QueryFields              bool
	DisableNestedTransaction bool
	// contains filtered or unexported fields
}

type TcpClient struct {
	Name    string
	Host    string
	Port    string
	Mode    string
	Clients []ITcpServiceClient
}

type TcpConfig struct {
	Servers []ITcpServer
	Clients []ITcpClient
}

type TcpServer struct {
	Port    string
	Mode    string
	Handler ITcpServiceHandler
}

type WebSocketBody struct {
	Action string      `json:"action"`
	Data   interface{} `json:"data"`
}

type WebSocketEvent struct {
	Connection *websocket.Conn
	Name       string
	Data       interface{}
	Debug      bool
	Body       IWebSocketBody
}

type WebSocketEventHandler struct {
	Debug bool
	// contains filtered or unexported fields
}

type WebSocketRoute struct {
	Path          string
	Handlers      func(IWebSocketEventHandler) // Service to inject
	CustomPayload IWebSocketBody
	// contains filtered or unexported fields
}

type WebSocketServer struct {
	Port   string
	Mode   string
	Routes []IWebSocketRoute
}