merch-tracker-v2/merch-api
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

addr forming refactor
All checks were successful
/ Make image (push) Successful in 58s
Details

Browse source
This commit is contained in:
nquidox 2026-04-02 17:58:49 +03:00
parent ab473f02be
commit b2222e956a
2 changed files with 6 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

3
internal/app/handler.go
View file

@ -85,7 +85,8 @@ func New(ctx context.Context, cfg config.Config) *App {
newApp.modules = append(newApp.modules, m) newApp.modules = append(newApp.modules, m)
newApp.tasker = task.New(task.Deps{ newApp.tasker = task.New(task.Deps{
Addr: "", Host: cfg.TasksSource.Host,
Port: cfg.TasksSource.Port,
MerchProvider: m, MerchProvider: m,
}) })

6
internal/task/handler.go
View file

@ -17,7 +17,8 @@ type Handler struct {
} }
type Deps struct { type Deps struct {
Addr string Host string
Port string
MerchProvider common.MerchProvider MerchProvider common.MerchProvider
} }
@ -25,7 +26,7 @@ func New(deps Deps) *Handler {
srv := grpc.NewServer() srv := grpc.NewServer()
handler := &Handler{ handler := &Handler{
addr: deps.Addr, addr: net.JoinHostPort(deps.Host, deps.Port),
service: newService(deps.MerchProvider), service: newService(deps.MerchProvider),
} }
@ -36,6 +37,7 @@ func New(deps Deps) *Handler {
} }
func (h *Handler) Serve() error { func (h *Handler) Serve() error {
log.WithField("addr", h.addr).Debugf("%v Serving tasks", pkgLogHeader)
listener, err := net.Listen("tcp", h.addr) listener, err := net.Listen("tcp", h.addr)
if err != nil { if err != nil {
log.WithError(err).Errorf("%v Listner failure", pkgLogHeader) log.WithError(err).Errorf("%v Listner failure", pkgLogHeader)