contracts

type CORSHandler interface {
	Handler(opts CORSOptions) func(http.Handler) http.Handler
}

type CORSOptions struct {
	AllowedOrigins   []string
	AllowedMethods   []string
	AllowedHeaders   []string
	AllowCredentials bool
	MaxAge           int
}

type DatabaseConnection interface {
	Query(ctx context.Context, sql string, args ...any) (DatabaseRows, error)
	QueryRow(ctx context.Context, sql string, args ...any) DatabaseRow
	Exec(ctx context.Context, sql string, args ...any) (DatabaseResult, error)
	Begin(ctx context.Context) (DatabaseTransaction, error)
	Release()
}

type DatabasePool interface {
	Ping(ctx context.Context) error
	Close()
	Acquire(ctx context.Context) (DatabaseConnection, error)
}

type DatabasePoolSnapshot struct {
	AcquireCount         int64
	AcquireDuration      time.Duration
	AcquiredConns        int32
	CanceledAcquireCount int64
	ConstructingConns    int32
	EmptyAcquireCount    int64
	IdleConns            int32
	MaxConns             int32
	NewConnsCount        int64
	TotalConns           int32
}

type DatabasePoolSnapshotProvider interface {
	StatSnapshot() DatabasePoolSnapshot
}

type DatabaseResult interface {
	RowsAffected() int64
}

type DatabaseRow interface {
	Scan(dest ...any) error
}

type DatabaseRows interface {
	Next() bool
	Scan(dest ...any) error
	Close()
	Err() error
}

type DatabaseTransaction interface {
	Query(ctx context.Context, sql string, args ...any) (DatabaseRows, error)
	QueryRow(ctx context.Context, sql string, args ...any) DatabaseRow
	Exec(ctx context.Context, sql string, args ...any) (DatabaseResult, error)
	Commit(ctx context.Context) error
	Rollback(ctx context.Context) error
}

type EnvVar interface {
	LoadEnvFiles(paths []string) error
	Get(key string) (string, bool)
	GetOr(key, def string) string
	MustGet(key string) string
	GetBoolOr(key string, def bool) bool
	MustGetBool(key string) bool
	GetIntOr(key string, def int) int
	MustGetInt(key string) int
	GetInt64Or(key string, def int64) int64
	MustGetInt64(key string) int64
	GetUintOr(key string, def uint) uint
	MustGetUint(key string) uint
	GetUint64Or(key string, def uint64) uint64
	MustGetUint64(key string) uint64
	GetFloat64Or(key string, def float64) float64
	MustGetFloat64(key string) float64
	MustGetDuration(key string) time.Duration
	GetDurationOr(key string, def time.Duration) time.Duration
	Bind(dst any) error
	MustBind(dst any)
	BindWithPrefix(dst any, prefix string) error
	MustBindWithPrefix(dst any, prefix string)
	DumpRedacted() map[string]string
}

type HTTPClient interface {
	Do(req *http.Request) (*http.Response, error)
}

type HTTPMiddleware interface {
	RequestID() func(http.Handler) http.Handler
	RealIP() func(http.Handler) http.Handler
	Recoverer() func(http.Handler) http.Handler
}

type HTTPRouter interface {
	http.Handler
	Get(pattern string, h http.HandlerFunc)
	Post(pattern string, h http.HandlerFunc)
	Put(pattern string, h http.HandlerFunc)
	Delete(pattern string, h http.HandlerFunc)
	Mount(pattern string, h http.Handler)
	Use(middlewares ...func(http.Handler) http.Handler)
}

type MethodRouteRegistrar interface {
	Get(pattern string, h http.HandlerFunc)
}

type Middleware interface {
	Middleware() func(http.Handler) http.Handler
}

type MiddlewareChain interface {
	Use(middlewares ...func(http.Handler) http.Handler)
}

type Migrator interface {
	Up(ctx context.Context, dir string) error
	Down(ctx context.Context, dir string) error
	Status(ctx context.Context, dir string) (string, error)
	Close() error
}

type TxManager interface {
	WithinTx(ctx context.Context, fn func(ctx context.Context) error) error
}

type URLParamExtractor interface {
	URLParam(r *http.Request, key string) string
}

type Validator interface {
	Validate(ctx context.Context, value interface{}) error
	ValidateStruct(ctx context.Context, obj interface{}) error
	ValidateField(ctx context.Context, obj interface{}, field string) error
}