interfaces

type Event interface {
	Topic() string
	Message() *Message
	Ack() error
	Error() error
}

type IBroker interface {
	Init(app IService) error
	Stop() error
	String() string

	Publish(topic string, m *Message) error
	Subscribe(topic string, s *Subscriber) error
}

type ICache interface {
	Init(app IService) error
	Stop() error
	String() string

	Has(key string) bool
	Set(key string, args any, timeout time.Duration) error
	Get(key string) (any, error)
	Delete(key string) error
}

type IConfig interface {
	Init(app IService) error
	Stop() error
	Has(key string) bool
	GetString(key string, def string) string
	GetBool(key string, def bool) bool
	GetInt(key string, def int) int
	GetFloat(key string, def float32) float32
}

type IController interface {
	Init(app IService) error
	Stop() error
	String() string
}

type IDatabase interface {
	Init(app IService) error
	Stop() error
	String() string

	Exists(ctx context.Context, query interface{}, args ...interface{}) bool
	Count(ctx context.Context, query interface{}, args ...interface{}) int64
	FindOne(ctx context.Context, query interface{}, model interface{}, args ...interface{}) error
	Find(ctx context.Context, query interface{}, model interface{}, args ...interface{}) error
	Exec(ctx context.Context, query interface{}, model interface{}, args ...interface{}) error
	Update(ctx context.Context, query interface{}, args ...interface{}) error
	Delete(ctx context.Context, query interface{}, args ...interface{}) int64
	GetDb() interface{}
}

type ILogger interface {
	Init(app IService) error
	Stop() error
	SetLevel(level LogLevel)
	Push(level LogLevel, msg string, toParent bool)
	Debug(args ...interface{})
	Info(args ...interface{})
	Warn(args ...interface{})
	Message(args ...interface{})
	Error(err error)
	Fatal(err error)
	Panic(err error)
}

type IModules interface {
	Init(app IService) error
	Stop() error
	String() string
}

type IRepository interface {
	Init(app IService) error
	Stop() error
	String() string
}

type IServer interface {
	Init(app IService) error
	Stop() error
	String() string
}

type IService interface {
	Init() error
	Stop() error
	GetLogger() ILogger
	PushCache(c ICache) IService
	GetCache(key string) ICache
	PushBroker(c IBroker) IService
	GetBroker(key string) IBroker
	PushDatabase(c IDatabase) IService
	GetDatabase(key string) IDatabase
	PushController(c IController) IService
	GetController(key string) IController
	PushModule(c IModules) IService
	GetModule(key string) IModules
	PushRepository(c IRepository) IService
	GetRepository(key string) IRepository
	PushServer(c IServer) IService
	GetServer(key string) IServer
	PushStorage(c IStorage) IService
	GetStorage(key string) IStorage
}

type IStorage interface {
	Init(app IService) error
	Stop() error
	String() string

	Has(name string) bool
	Put(name string, data []byte) error
	Read(name string) ([]byte, error)
	Delete(name string) error
	List() []string
}

type LogLevel int

type Message struct {
	Header map[string]string
	Body   []byte
}

type Subscriber interface {
	Handler(event *Event) error
	Unsubscribe() error
}