cliconfig

type AuditConfig struct {
	Enabled  bool                 `yaml:"enabled"`
	Level    string               `yaml:"level"` // minimal, standard, full
	File     string               `yaml:"file,omitempty"`
	MaxSize  int                  `yaml:"max_size_mb,omitempty"` // Max file size in MB
	Console  bool                 `yaml:"console,omitempty"`     // Log to console
	Database *AuditDatabaseConfig `yaml:"database,omitempty"`    // Log to a SQL database, in addition to file/console
}

type AuditDatabaseConfig struct {
	Type            string `yaml:"type"`                        // sqlite, mysql, mssql, postgres
	DSN             string `yaml:"dsn"`                         // Raw connection string
	Table           string `yaml:"table,omitempty"`             // Table name (default: audit_log)
	BatchSize       int    `yaml:"batch_size,omitempty"`        // 0 = no batching (insert one row per entry)
	AutoCreateTable bool   `yaml:"auto_create_table,omitempty"` // Create the table (and indexes) if missing
}

type BrokerConfig struct {
	Type           string `yaml:"type"`                      // rabbitmq, msmq, kafka
	Host           string `yaml:"host,omitempty"`            // Broker host
	Port           int    `yaml:"port,omitempty"`            // Broker port
	User           string `yaml:"user,omitempty"`            // Username
	Password       string `yaml:"password,omitempty"`        // Password
	Queue          string `yaml:"queue,omitempty"`           // Queue/topic name
	VHost          string `yaml:"vhost,omitempty"`           // RabbitMQ vhost
	UseTLS         bool   `yaml:"use_tls,omitempty"`         // Use TLS/SSL (amqps) for RabbitMQ
	TLSSkipVerify  bool   `yaml:"tls_skip_verify,omitempty"` // Skip TLS certificate verification (self-signed certs)
	Exchange       string `yaml:"exchange,omitempty"`        // RabbitMQ exchange (default = "")
	RoutingKey     string `yaml:"routing_key,omitempty"`     // RabbitMQ routing key (default = queue name)
	Durable        bool   `yaml:"durable,omitempty"`         // Queue survives broker restart
	AutoDelete     bool   `yaml:"auto_delete,omitempty"`     // Queue deleted when no consumers
	Exclusive      bool   `yaml:"exclusive,omitempty"`       // Queue accessible by one connection only
	PassiveDeclare bool   `yaml:"passive_declare,omitempty"` // Don't create queue, just check it exists (avoids 406 PRECONDITION_FAILED)
	QueuePath      string `yaml:"queue_path,omitempty"`      // MSMQ: полный путь к очереди (например: ".\private$\tdtp_in")
	// Kafka-specific
	Brokers       []string `yaml:"brokers,omitempty"`        // Kafka: список брокеров (["localhost:9092"])
	ConsumerGroup string   `yaml:"consumer_group,omitempty"` // Kafka: consumer group ID
}

type CircuitBreakerConfig struct {
	Enabled          bool   `yaml:"enabled"`
	Threshold        uint32 `yaml:"threshold"`         // Failure threshold
	Timeout          int    `yaml:"timeout"`           // Timeout in seconds
	MaxConcurrent    int    `yaml:"max_concurrent"`    // Max concurrent calls
	SuccessThreshold uint32 `yaml:"success_threshold"` // Success threshold for recovery
}

type Config struct {
	Database   DatabaseConfig   `yaml:"database"`
	Storage    storage.Config   `yaml:"storage,omitempty"`
	Export     ExportConfig     `yaml:"export,omitempty"`
	Tables     []string         `yaml:"tables,omitempty"`
	Broker     BrokerConfig     `yaml:"broker,omitempty"`
	Resilience ResilienceConfig `yaml:"resilience,omitempty"`
	Audit      AuditConfig      `yaml:"audit,omitempty"`
	Processors ProcessorsConfig `yaml:"processors,omitempty"`
	Security   SecurityConfig   `yaml:"security,omitempty"`
}

type DatabaseConfig struct {
	Type        string `yaml:"type"`                   // sqlite, postgres, mssql, access
	Host        string `yaml:"host,omitempty"`         // For network databases
	Port        int    `yaml:"port,omitempty"`         // Database port
	Database    string `yaml:"database,omitempty"`     // Database name or file path
	User        string `yaml:"user,omitempty"`         // Username
	Password    string `yaml:"password,omitempty"`     // Password
	Schema      string `yaml:"schema,omitempty"`       // PostgreSQL schema (default: public)
	WindowsAuth bool   `yaml:"windows_auth,omitempty"` // MS SQL Windows authentication
	SSLMode     string `yaml:"sslmode,omitempty"`      // PostgreSQL SSL mode
	DSN         string `yaml:"dsn,omitempty"`          // Raw connection string (overrides other fields; required for access)
	Charset     string `yaml:"charset,omitempty"`      // Charset for string decoding, e.g. "windows-1251" (ODBC/legacy drivers)

	// StrictSchema restores VARCHAR(n)/CHAR(n) instead of TEXT when a
	// table is created during import (PostgreSQL adapter only). Off by
	// default: an oversized value then fails the insert instead of being
	// silently widened to TEXT. See adapters.Config.StrictSchema.
	StrictSchema bool `yaml:"strict_schema,omitempty"`
}

type ExportConfig struct {
	Compress      bool   `yaml:"compress"`       // Enable compression by default
	CompressLevel int    `yaml:"compress_level"` // Compression level: 1-19 (zstd) or 6-7 (kanzi)
	CompressAlgo  string `yaml:"compress_algo"`  // Algorithm: "zstd" (default) or "kanzi"
}

type MaskRule struct {
	Field    string `yaml:"field"`
	Strategy string `yaml:"strategy"` // email, phone, card, partial
}

type NormalizeRule struct {
	Field    string `yaml:"field"`
	Strategy string `yaml:"strategy"` // email, phone, date, trim, uppercase, lowercase
}

type ProcessorsConfig struct {
	Mask      []MaskRule      `yaml:"mask,omitempty"`
	Validate  []ValidateRule  `yaml:"validate,omitempty"`
	Normalize []NormalizeRule `yaml:"normalize,omitempty"`
}

type ResilienceConfig struct {
	CircuitBreaker CircuitBreakerConfig `yaml:"circuit_breaker,omitempty"`
	Retry          RetryConfig          `yaml:"retry,omitempty"`
}

type RetryConfig struct {
	Enabled     bool   `yaml:"enabled"`
	MaxAttempts int    `yaml:"max_attempts"`
	Strategy    string `yaml:"strategy"` // constant, linear, exponential
	InitialWait int    `yaml:"initial_wait_ms"`
	MaxWait     int    `yaml:"max_wait_ms"`
	Jitter      bool   `yaml:"jitter"`
}

type SecurityConfig struct {
	// MercuryURL is the xZMercury base URL used to bind and resolve encryption
	// keys. --mercury-url overrides it, so a one-off run can point elsewhere
	// without editing the file.
	MercuryURL string `yaml:"mercury_url,omitempty"`
}

type ValidateRule struct {
	Field   string `yaml:"field"`
	Type    string `yaml:"type"` // regex, range, format
	Pattern string `yaml:"pattern,omitempty"`
	Min     string `yaml:"min,omitempty"`
	Max     string `yaml:"max,omitempty"`
}