services

type Database interface {
	Generic
	WithServiceManager(c ServiceManager) Database
	WithProductDatabase() Database
	WithMasterClient(*sql.DB) Database
	WithReplicaClient(*sql.DB) Database
	OpenTransactionMaster(ctx context.Context) (context.Context, error)
	TransactionMaster(ctx context.Context, f func(tx DatabaseTransaction) error) error
	OpenTransactionReplica(ctx context.Context) (context.Context, error)
	TransactionReplica(ctx context.Context, f func(tx DatabaseTransaction) error) error
	CloseTransaction(ctx context.Context, err error) error
}

type DatabaseTransaction interface {
	Insert(query string, args ...interface{}) (sql.Result, error)
	Update(query string, args ...interface{}) (sql.Result, error)
	Get(query string, args ...interface{}) (*sql.Rows, error)
	Migrate(script string) (sql.Result, error)
}

type Discounts interface {
	Generic
	WithServiceManager(c ServiceManager) Discounts
	Get(ctx context.Context, req domains.DiscountRequest) (*domains.DiscountResponse, error)
}

type Environment interface {
	Generic
	WithServiceManager(c ServiceManager) Environment
	Env() string
	Service() string
	Version() string
	DebugPprof() bool
	AwsRegion() string
	AwsEndpoint() string
	AwsAccessKey() string
	AwsSecretKey() string
	DiscountsAddress() string
	SpanUrl() string
	ProductDatabaseDsn() string
	ProductReplicaDatabaseDsn() string
	ProductTopicAddress() string
	Configs() map[string]interface{}
}

type Events interface {
	Generic
	WithServiceManager(c ServiceManager) Events
	Send(ctx context.Context, req domains.EventRequest) error
	SendBulk(ctx context.Context, req []domains.EventRequest) error
}

type Generic interface {
	ServiceManager() ServiceManager
	Init(ctx context.Context) error
	Close() error
	Readiness(ctx context.Context) error
	Liveness(ctx context.Context) error
}

type HttpServer interface {
	Generic
	WithServiceManager(c ServiceManager) HttpServer
	Run() error
}

type Logger interface {
	Generic
	WithServiceManager(c ServiceManager) Logger
	WithCallerCount(c int) Logger
	Info(ctx context.Context, message string, fields ...map[string]interface{})
	Warn(ctx context.Context, message string, fields ...map[string]interface{})
	Error(ctx context.Context, message string, fields ...map[string]interface{})
	Fatal(ctx context.Context, message string, fields ...map[string]interface{})
}

type NoopDatabase struct {
	NoopHealth
	NoopServiceManager
}

type NoopDiscounts struct {
	NoopHealth
	NoopServiceManager
}

type NoopEnvironment struct {
	NoopHealth
	NoopServiceManager
}

type NoopEvents struct {
	NoopHealth
	NoopServiceManager
}

type NoopHealth struct{}

type NoopHttpServer struct {
	NoopHealth
	NoopServiceManager
}

type NoopLogger struct {
	NoopHealth
	NoopServiceManager
}

type NoopProductsHandler struct {
	NoopHealth
	NoopServiceManager
}

type NoopProductsRepository struct {
	NoopHealth
	NoopServiceManager
}

type NoopServiceManager struct{}

type NoopSpans struct {
	NoopHealth
	NoopServiceManager
}

type NoopValidator struct {
	NoopHealth
	NoopServiceManager
}

type ProductsHandler interface {
	Generic
	WithServiceManager(c ServiceManager) ProductsHandler
	Create(ctx context.Context, c domains.ProductCreate) (*domains.Product, error)
	Update(ctx context.Context, c domains.ProductUpdate) (*domains.Product, error)
	Get(ctx context.Context, productId string) (*domains.Product, error)
	List(ctx context.Context) ([]domains.Product, error)
	Delete(ctx context.Context, productId string) (*domains.Product, error)
}

type ProductsRepository interface {
	Generic
	WithServiceManager(ServiceManager) ProductsRepository
	Search(ctx context.Context, search domains.ProductSearch) ([]domains.Product, error)
	Create(ctx context.Context, product *domains.Product) error
	Update(ctx context.Context, product *domains.Product) error
	Delete(ctx context.Context, product *domains.Product) error
	Migrate(ctx context.Context) error
}

type ServiceManager interface {
	Init() error
	Close() error
	Readiness(ctx context.Context) error
	Liveness(ctx context.Context) error
	Context() context.Context
	WithLogger(d Logger) ServiceManager
	Logger() Logger
	WithHttpServer(d HttpServer) ServiceManager
	HttpServer() HttpServer
	WithEnvironment(d Environment) ServiceManager
	Environment() Environment
	WithDiscounts(d Discounts) ServiceManager
	Discounts() Discounts
	WithValidator(d Validator) ServiceManager
	Validator() Validator
	WithSpans(d Spans) ServiceManager
	Spans() Spans
	WithProductDatabase(d Database) ServiceManager
	ProductDatabase() Database
	WithProductsRepository(d ProductsRepository) ServiceManager
	ProductsRepository() ProductsRepository
	WithProductsHandler(d ProductsHandler) ServiceManager
	ProductsHandler() ProductsHandler
	WithProductsEvents(d Events) ServiceManager
	ProductsEvents() Events
}

type Spans interface {
	Generic
	WithServiceManager(c ServiceManager) Spans
	New(ctx context.Context, spanConfigs ...domains.SpanConfig) (context.Context, *domains.Span)
	Tracer() *zipkin.Tracer
}

type Validator interface {
	Generic
	WithServiceManager(c ServiceManager) Validator
	Validate(ctx context.Context, obj interface{}) error
	ValidateSlice(ctx context.Context, objs interface{}) error
}