fix: if topic not exist in kafka - error
All checks were successful
Deploy / CreateImage (push) Successful in 3m4s
Deploy / ValidateConfig (push) Successful in 27s
Deploy / MigrateDatabase (push) Successful in 48s
Deploy / DeployService (push) Successful in 27s

This commit is contained in:
pasha1coil 2025-06-09 13:05:05 +03:00 committed by skeris
parent 22db0b9030
commit 88f7f29259
3 changed files with 17 additions and 2 deletions

@ -23,7 +23,12 @@ func main() {
err = validate.ValidateKafka([]string{cfg.KafkaBrokers}, cfg.KafkaTopicTariff) err = validate.ValidateKafka([]string{cfg.KafkaBrokers}, cfg.KafkaTopicTariff)
if err != nil { if err != nil {
log.Fatalf("error validating kafka: %v", err) log.Fatalf("error validating kafka Tariff: %v", err)
}
err = validate.ValidateKafka([]string{cfg.KafkaBrokers}, cfg.KafkaTopicGigaChat)
if err != nil {
log.Fatalf("error validating kafka GigaChat: %v", err)
} }
err = validate.ValidateRedis(cfg.RedisHost, cfg.RedisPassword, int(cfg.RedisDB)) err = validate.ValidateRedis(cfg.RedisHost, cfg.RedisPassword, int(cfg.RedisDB))
@ -78,5 +83,13 @@ func validateNotEmpty(cfg initialize.Config) error {
return errors.New("api url is not be empty") return errors.New("api url is not be empty")
} }
if cfg.GigaChatApiBaseURL == "" {
return errors.New("giga chat api base url is not be empty")
}
if cfg.GigaChatApiAuthKey == "" {
return errors.New("giga chat api key is not be empty")
}
return nil return nil
} }

2
go.mod

@ -5,7 +5,7 @@ go 1.23.2
toolchain go1.23.4 toolchain go1.23.4
require ( require (
gitea.pena/PenaSide/common v0.0.0-20250421103113-7e4b3ae9e1e0 gitea.pena/PenaSide/common v0.0.0-20250609100303-3b7c00cc97bc
gitea.pena/PenaSide/customer v0.0.0-20250518194954-882ec684be86 gitea.pena/PenaSide/customer v0.0.0-20250518194954-882ec684be86
gitea.pena/PenaSide/hlog v0.0.0-20241125221102-a54c29c002a9 gitea.pena/PenaSide/hlog v0.0.0-20241125221102-a54c29c002a9
gitea.pena/SQuiz/common v0.0.0-20250610100937-ce7096a3dd37 gitea.pena/SQuiz/common v0.0.0-20250610100937-ce7096a3dd37

2
go.sum

@ -1,5 +1,7 @@
gitea.pena/PenaSide/common v0.0.0-20250421103113-7e4b3ae9e1e0 h1:+gvpAPo1+1WtCpA+QaCWNy4R9/cIERBBzrVSYrx7hNo= gitea.pena/PenaSide/common v0.0.0-20250421103113-7e4b3ae9e1e0 h1:+gvpAPo1+1WtCpA+QaCWNy4R9/cIERBBzrVSYrx7hNo=
gitea.pena/PenaSide/common v0.0.0-20250421103113-7e4b3ae9e1e0/go.mod h1:91EuBCgcqgJ6mG36n2pds8sPwwfaJytLWOzY3h2YFKU= gitea.pena/PenaSide/common v0.0.0-20250421103113-7e4b3ae9e1e0/go.mod h1:91EuBCgcqgJ6mG36n2pds8sPwwfaJytLWOzY3h2YFKU=
gitea.pena/PenaSide/common v0.0.0-20250609100303-3b7c00cc97bc h1:xwojlRrEl2hjZxgoMqSz8pkWmQRYq7LsDdeAExtgyQE=
gitea.pena/PenaSide/common v0.0.0-20250609100303-3b7c00cc97bc/go.mod h1:91EuBCgcqgJ6mG36n2pds8sPwwfaJytLWOzY3h2YFKU=
gitea.pena/PenaSide/customer v0.0.0-20250407185330-82e95e8da043 h1:a/89TC0bRdWRjS875EIE1c1ZPgmRcDaKMcQoUv+sg+I= gitea.pena/PenaSide/customer v0.0.0-20250407185330-82e95e8da043 h1:a/89TC0bRdWRjS875EIE1c1ZPgmRcDaKMcQoUv+sg+I=
gitea.pena/PenaSide/customer v0.0.0-20250407185330-82e95e8da043/go.mod h1:DDg6CQDhU+aSSTv8R/LbkNGegdCx+Q++DcgPfE2LbZU= gitea.pena/PenaSide/customer v0.0.0-20250407185330-82e95e8da043/go.mod h1:DDg6CQDhU+aSSTv8R/LbkNGegdCx+Q++DcgPfE2LbZU=
gitea.pena/PenaSide/customer v0.0.0-20250518194954-882ec684be86 h1:NjY7t0aerJqCcHez74sI3mQLjP3Yhc3jYG/n1/k279Y= gitea.pena/PenaSide/customer v0.0.0-20250518194954-882ec684be86 h1:NjY7t0aerJqCcHez74sI3mQLjP3Yhc3jYG/n1/k279Y=