types

type AuthInfo struct {
	UserID   string   `json:"user_id,omitempty"`
	Username string   `json:"username,omitempty"`
	Email    string   `json:"email,omitempty"`
	Roles    []string `json:"roles,omitempty"`
	Extra    H        `json:"extra,omitempty"`
}

type CacheStorage interface {
	Set(key string, value interface{}, duration ...time.Duration)
	Get(key string) (interface{}, bool)
	Delete(key string)
	Has(key string) bool
	Keys() []string
	Clear()
}

type ContextKey string

type ErrorHandler interface {
	HandleError(ctx RequestContext, err error)
}

type FileStreamer interface {
	Process(filePath string, processor func(chunk []byte, offset int64) error) error
	ProcessReader(reader http.Request, processor func(chunk []byte, offset int64) error) error
}

type H map[string]interface{}

type HandlerFunc interface{}

type JWTManager interface {
	GenerateToken(payload map[string]interface{}) (string, error)
	ValidateToken(token string) (map[string]interface{}, error)
	ParsePayload(token string) (map[string]interface{}, error)
	RevokeToken(jti string, expirationTime time.Time) error
	IsTokenRevoked(jti string) bool
}

type ListResponse struct {
	Data       interface{} `json:"data"`
	Pagination Pagination  `json:"pagination"`
}

type Pagination struct {
	CurrentPage int   `json:"current_page"`
	PageSize    int   `json:"page_size"`
	TotalCount  int64 `json:"total_count"`
	TotalPages  int   `json:"total_pages,omitempty"`
}

type RequestContext interface {
	context.Context

	// 基础方法
	Method() string
	Host() string
	URL() string
	GetHeader(key string) string
	GetIP() string

	// 参数获取
	Param(key string, defaultValue ...string) string
	ParamInt(key string, defaultValue ...int) int
	Query(key string) string
	PostForm(key string) string

	// 响应方法
	Success(data interface{}, url ...string)
	Fail(msg string, url ...string)
	Error(msg string, url ...string)
	JSON(code int, obj interface{})

	// 缓存方法
	CacheSet(key string, value interface{}, duration ...time.Duration)
	CacheGet(key string) (interface{}, bool)
	CacheDelete(key string)

	// JWT方法
	SetJWT(token string, maxAge int)
	GetJWT() string

	// 文件上传
	FormFile(name string) (*multipart.FileHeader, error)
}

type ResourcePool[T any] interface {
	Get() (T, error)
	Put(resource T)
	Close()
	Len() int
	Stats() (active, idle int)
}

type Response struct {
	Code int         `json:"code"`
	Msg  string      `json:"msg"`
	Data interface{} `json:"data,omitempty"`
	URL  string      `json:"url,omitempty"`
}

type ResponseWriter interface {
	http.ResponseWriter
	JSON(code int, obj interface{})
	Abort()
}

type SSEClient interface {
	GetID() string
	Send(event *SSEEvent) error
	Close()
}

type SSEEvent struct {
	Event string      `json:"event"`
	Data  interface{} `json:"data"`
	ID    string      `json:"id"`
	Retry int         `json:"retry"`
}

type SSEHub interface {
	RegisterClient(client SSEClient)
	UnregisterClient(client SSEClient)
	Broadcast(event *SSEEvent)
	GetClients() []string
	Close()
}

type UploadConfig struct {
	AllowedExts []string // 允许的文件扩展名
	MaxSize     int64    // 最大文件大小（字节）
	SavePath    string   // 保存路径
}

type Validator interface {
	Validate() (bool, string)
}