core

type BackupDriver interface {
	Create(ctx context.Context, req backupcontract.CreateRequest) (backupcontract.Manifest, error)
}

type BlobStorage interface {
	Put(ctx context.Context, in PutObjectInput) (StoredObject, error)
	Delete(ctx context.Context, bucket, key string) error
	PresignGet(ctx context.Context, bucket, key string, expiry time.Duration) (string, error)
}

type Cache interface {
	Get(ctx context.Context, key string) (value []byte, found bool, err error)
	Set(ctx context.Context, key string, value []byte, ttl time.Duration) error
	Delete(ctx context.Context, key string) error
	InvalidatePrefix(ctx context.Context, prefix string) error
	Close() error
}

type EnqueueOptions struct {
	Queue      string
	RunAt      time.Time
	MaxRetries int
	Timeout    time.Duration
	Retention  time.Duration
	Priority   int
}

type I18n interface {
	DefaultLanguage() string
	SupportedLanguages() []string
	NormalizeLanguage(raw string) string
	T(ctx context.Context, key string, templateData ...map[string]any) string
	TC(ctx context.Context, key string, count any, templateData ...map[string]any) string
	TS(ctx context.Context, key string, choice string, templateData ...map[string]any) string
}

type JobCapabilities struct {
	Delayed    bool
	Retries    bool
	Cron       bool
	Priority   bool
	DeadLetter bool
	Dashboard  bool
}

type JobHandler func(ctx context.Context, payload []byte) error

type JobListFilter struct {
	Queue    string
	Statuses []JobStatus
	Limit    int
	Offset   int
}

type JobRecord struct {
	ID         string
	Queue      string
	Name       string
	Payload    []byte
	Status     JobStatus
	Attempt    int
	MaxRetries int
	RunAt      time.Time
	CreatedAt  time.Time
	UpdatedAt  time.Time
	LastError  string
}

type JobStatus string

type Jobs interface {
	Register(name string, handler JobHandler) error
	Enqueue(ctx context.Context, name string, payload []byte, opts EnqueueOptions) (jobID string, err error)
	StartWorker(ctx context.Context) error
	StartScheduler(ctx context.Context) error
	Stop(ctx context.Context) error
	Capabilities() JobCapabilities
}

type JobsInspector interface {
	List(ctx context.Context, filter JobListFilter) ([]JobRecord, error)
	Get(ctx context.Context, id string) (JobRecord, bool, error)
}

type MailAddress struct {
	Email string
	Name  string
}

type MailAttachment struct {
	Filename    string
	ContentType string
	Content     []byte
}

type MailMessage struct {
	From        MailAddress
	To          []MailAddress
	CC          []MailAddress
	BCC         []MailAddress
	ReplyTo     *MailAddress
	Subject     string
	TextBody    string
	HTMLBody    string
	Headers     map[string]string
	Attachments []MailAttachment
}

type Mailer interface {
	Send(ctx context.Context, msg MailMessage) error
}

type MessageHandler func(ctx context.Context, topic string, payload []byte) error

type Module interface {
	ID() string
	Migrations() fs.FS
}

type PubSub interface {
	Publish(ctx context.Context, topic string, payload []byte) error
	Subscribe(ctx context.Context, topic string, handler MessageHandler) (Subscription, error)
	Close() error
}

type PutObjectInput struct {
	Bucket      string
	Key         string
	ContentType string
	Reader      io.Reader
	Size        int64
	Metadata    map[string]string
}

type RestoreDriver interface {
	Restore(ctx context.Context, req backupcontract.RestoreRequest) error
}

type RoutableModule interface {
	Module
	RegisterRoutes(r Router) error
}

type Router interface {
	Group(prefix string, middleware ...echo.MiddlewareFunc) *echo.Group
	GET(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	POST(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	PUT(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
	DELETE(path string, h echo.HandlerFunc, m ...echo.MiddlewareFunc) *echo.Route
}

type Store interface {
	Ping(ctx context.Context) error
	WithTx(ctx context.Context, fn TxFunc) error
}

type StoredObject struct {
	Bucket string
	Key    string
	ETag   string
	Size   int64
}

type Subscription interface {
	Close() error
}

type TxFunc func(ctx context.Context) error