config

type BaseConfig = Config

type CORSConfig struct {
	AllowOrigins     []string `mapstructure:"allow_origins"`
	AllowMethods     []string `mapstructure:"allow_methods"`
	AllowHeaders     []string `mapstructure:"allow_headers"`
	AllowCredentials bool     `mapstructure:"allow_credentials"`
}

type CasbinConfig struct {
	Model      string   `mapstructure:"model"`
	ModelFile  string   `mapstructure:"model_file"`
	Enabled    bool     `mapstructure:"enabled"`
	SkipPaths  []string `mapstructure:"skip_paths"`
	AdminUsers []string `mapstructure:"admin_users"`
}

type Config struct {
	System  SystemConfig `mapstructure:"system"`
	Mysql   MysqlConfig  `mapstructure:"mysql"`
	Redis   RedisConfig  `mapstructure:"redis"`
	Mongodb MongoConfig  `mapstructure:"mongodb"`
	Kafka   KafkaConfig  `mapstructure:"kafka"`
	Log     LogConfig    `mapstructure:"log"`
	JWT     JWTConfig    `mapstructure:"jwt"`
	CORS    CORSConfig   `mapstructure:"cors"`
	Casbin  CasbinConfig `mapstructure:"casbin"`
	Otel    OtelConfig   `mapstructure:"otel"`
}

type FileSource[T any] struct {
	Path string
}

type JWTConfig struct {
	Secret    string        `mapstructure:"secret"`
	Expire    time.Duration `mapstructure:"expire"`
	SkipPaths []string      `mapstructure:"skip_paths"`
	Enabled   bool          `mapstructure:"enabled"`
}

type KafkaConfig struct {
	Brokers  []string `mapstructure:"brokers"`
	ClientID string   `mapstructure:"client_id"`
	Topic    string   `mapstructure:"topic"`
}

type LogConfig struct {
	Level  string        `mapstructure:"level"`
	Format string        `mapstructure:"format"` // json, text, color
	Output string        `mapstructure:"output"` // stdout, stderr
	File   LogFileConfig `mapstructure:"file"`
}

type LogFileConfig struct {
	Filename   string `mapstructure:"filename"`
	MaxSize    int    `mapstructure:"max_size"`
	MaxBackups int    `mapstructure:"max_backups"`
	MaxAge     int    `mapstructure:"max_age"`
	Compress   bool   `mapstructure:"compress"`
	Format     string `mapstructure:"format"`
}

type MongoConfig struct {
	Host     string `mapstructure:"host"`
	Port     int    `mapstructure:"port"`
	User     string `mapstructure:"user"`
	Password string `mapstructure:"password"`
	Database string `mapstructure:"database"`
}

type MysqlConfig struct {
	Host         string `mapstructure:"host"`
	Port         int    `mapstructure:"port"`
	User         string `mapstructure:"user"`
	Password     string `mapstructure:"password"`
	Dbname       string `mapstructure:"database"`
	Database     string `mapstructure:"database"` // Alias for Dbname
	DockerHost   string `mapstructure:"docker_host"`
	MaxIdleConns int    `mapstructure:"max_idle_conns"`
	MaxOpenConns int    `mapstructure:"max_open_conns"`
	MaxLifetime  int    `mapstructure:"max_lifetime"`
}

type OtelConfig struct {
	Enabled       bool    `mapstructure:"enabled"`        // 是否启用 OpenTelemetry
	ServiceName   string  `mapstructure:"service_name"`   // 服务名称
	Environment   string  `mapstructure:"environment"`    // 环境标识: dev, test, prod
	OTLPEndpoint  string  `mapstructure:"otlp_endpoint"`  // OTLP gRPC 端点地址
	ExporterType  string  `mapstructure:"exporter_type"`  // 导出器类型: otlp, stdout
	SamplingRatio float64 `mapstructure:"sampling_ratio"` // 采样率: 0.0 - 1.0
}

type RedisConfig struct {
	Host     string `mapstructure:"host"`
	Port     int    `mapstructure:"port"`
	Password string `mapstructure:"password"`
	DB       int    `mapstructure:"database"`
	Database int    `mapstructure:"database"` // Alias for DB
	PoolSize int    `mapstructure:"pool_size"`
}

type Source[T any] interface {
	Load(ctx context.Context) (T, error)
}

type Store[T any] struct {
	// contains filtered or unexported fields
}

type SystemConfig struct {
	Port    string `mapstructure:"port"`
	Env     string `mapstructure:"env"` // dev, test, prod
	Name    string `mapstructure:"name"`
	Version string `mapstructure:"version"`
	Level   string `mapstructure:"level"`
}

type WatchableSource[T any] interface {
	Source[T]
	Watch(ctx context.Context, onChange func(T)) error
}