config

type Config struct {
	Listener   ListenerCfg   `env:",prefix=LISTENER_"`
	Database   DatabaseCfg   `env:",prefix=DB_"`
	Nats       NatsCfg       `env:",prefix=NATS_"`
	PubSub     PubSubCfg     `env:",prefix=PUBSUB_"`
	Logger     LoggerCfg     `env:",prefix=LOG_"`
	Monitoring MonitoringCfg `env:",prefix=MONITOR_"`
}

type DatabaseCfg struct {
	DSN string `valid:"required" env:"DSN,overwrite"`
}

type FilterStruct struct {
	Tables map[string][]string
}

type ListenerCfg struct {
	SlotName          string        `valid:"required" env:"SLOT_NAME,overwrite"`
	AckTimeout        time.Duration `env:"ACK_TIMEOUT,overwrite"`
	RefreshConnection time.Duration `valid:"required" env:"REFRESH_TIMEOUT,overwrite"`
	HeartbeatInterval time.Duration `valid:"required" env:"HEARTBEAT_INTERVAL,overwrite"`
	Filter            FilterStruct  `env:"FILTER,overwrite"`
	TopicsMap         map[string]string
}

type LoggerCfg struct {
	Caller bool   `env:"CALLER,overwrite"`
	Level  string `env:"LEVEL,overwrite"`
	Format string `env:"FORMAT,overwrite"`
}

type MonitoringCfg struct {
	SentryDSN string `env:"SENTRY_DSN,overwrite"`
	PromAddr  string `env:"PROMETHEUS_ADDRESS,overwrite"`
}

type NatsCfg struct {
	Enabled     bool        `env:"ENABLED,overwrite"`
	Address     string      `env:"ADDRESS,overwrite"`
	StreamName  string      `env:"STREAM_NAME,overwrite"`
	TopicPrefix string      `env:"TOPIC_PREFIX,overwrite"`
	MTLS        NatsMtlsCfg `env:",prefix=MTLS_"`
}

type NatsMtlsCfg struct {
	CertPath           string `env:"CERT_PATH,overwrite,default=/etc/nats-certs/clients"`
	CertFile           string `env:"CERT_FILE,overwrite,default=tls.crt"`
	KeyFile            string `env:"KEY_FILE,overwrite,default=tls.key"`
	CAFile             string `env:"CA_FILE,overwrite,default=ca.crt"`
	InsecureSkipVerify bool   `env:"INSECURE_SKIP_VERIFY,overwrite,default=false"`
	Enabled            bool   `env:"ENABLED,overwrite,default=false"`
}

type PubSubCfg struct {
	Enabled   bool   `env:"ENABLED,overwrite"`
	Topic     string `env:"TOPIC,overwrite"`
	ProjectID string `env:"PROJECT_ID,overwrite"`
}