PenaSide/codeword
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

replace // from app

Browse Source
This commit is contained in:
Pavel 2024-02-25 15:02:15 +03:00
parent a6f1bdfb68
commit d125d4f13e
1 changed files with 25 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

49
internal/app/app.go
View File

@ -12,6 +12,7 @@ import (
"codeword/pkg/closer"
"context"
"errors"
"github.com/twmb/franz-go/pkg/kgo"
"go.uber.org/zap"
"time"
)
@ -41,26 +42,26 @@ func Run(ctx context.Context, cfg initialize.Config, logger *zap.Logger) error {
return err
}
//kafkaTariffClient, err := kgo.NewClient(
// kgo.SeedBrokers(cfg.KafkaBrokers),
// kgo.ConsumeResetOffset(kgo.NewOffset().AtStart()),
// kgo.DefaultProduceTopic(cfg.KafkaTopic),
//)
//if err != nil {
// return err
//}
kafkaTariffClient, err := kgo.NewClient(
kgo.SeedBrokers(cfg.KafkaBrokers),
kgo.ConsumeResetOffset(kgo.NewOffset().AtStart()),
kgo.DefaultProduceTopic(cfg.KafkaTopic),
)
if err != nil {
return err
}
//discountRpcClient, err := initialize.DiscountGRPCClient(cfg.DiscountServiceAddress)
//if err != nil {
// logger.Error("failed to connect to discount service", zap.Error(err))
// return err
//}
//
//brokers := initialize.NewBrokers(initialize.BrokersDeps{
// Logger: logger,
// TariffClient: kafkaTariffClient,
// Topic: cfg.KafkaTopic,
//})
discountRpcClient, err := initialize.DiscountGRPCClient(cfg.DiscountServiceAddress)
if err != nil {
logger.Error("failed to connect to discount service", zap.Error(err))
return err
}
brokers := initialize.NewBrokers(initialize.BrokersDeps{
Logger: logger,
TariffClient: kafkaTariffClient,
Topic: cfg.KafkaTopic,
})
rdb, err := initialize.Redis(ctx, cfg)
encrypt := initialize.Encrypt(cfg)
@ -82,11 +83,11 @@ func Run(ctx context.Context, cfg initialize.Config, logger *zap.Logger) error {
})
promoService := services.NewPromoCodeService(services.PromoDeps{
Logger: logger,
PromoCodeRepo: promoCodeRepo,
StatsRepo: statsRepo,
//Kafka: brokers.TariffProducer,
//DiscountClient: discountRpcClient,
Logger: logger,
PromoCodeRepo: promoCodeRepo,
StatsRepo: statsRepo,
Kafka: brokers.TariffProducer,
DiscountClient: discountRpcClient,
})
recoveryController := recovery.NewRecoveryController(logger, recoveryService, cfg.DefaultRedirectionURL)