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

	Query(ctx context.Context, query interface{}, model interface{}, args ...interface{}) error
	Exec(ctx context.Context, query interface{}, args ...interface{}) error
	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 INoSql interface {
	Init(app IService) error
	Stop() error
	String() string

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

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

type IServer interface {
	Init(app IService) error
	Start() error
	Stop() error
	String() string
	PushRoute(method string, path string, handler RouteFunc)
}

type IService interface {
	Init() error
	Stop() error
	GetLogger() ILogger
	GetConfig() IConfig
	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 RouteFunc func(ctx *srvCtx.Ctx)

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