diff --git a/internal/app/handler.go b/internal/app/handler.go index b7e8649..c5f4b13 100644 --- a/internal/app/handler.go +++ b/internal/app/handler.go @@ -85,7 +85,8 @@ func New(ctx context.Context, cfg config.Config) *App { newApp.modules = append(newApp.modules, m) newApp.tasker = task.New(task.Deps{ - Addr: "", + Host: cfg.TasksSource.Host, + Port: cfg.TasksSource.Port, MerchProvider: m, }) diff --git a/internal/task/handler.go b/internal/task/handler.go index 1d01394..2e75d04 100644 --- a/internal/task/handler.go +++ b/internal/task/handler.go @@ -17,7 +17,8 @@ type Handler struct { } type Deps struct { - Addr string + Host string + Port string MerchProvider common.MerchProvider } @@ -25,7 +26,7 @@ func New(deps Deps) *Handler { srv := grpc.NewServer() handler := &Handler{ - addr: deps.Addr, + addr: net.JoinHostPort(deps.Host, deps.Port), service: newService(deps.MerchProvider), } @@ -36,6 +37,7 @@ func New(deps Deps) *Handler { } func (h *Handler) Serve() error { + log.WithField("addr", h.addr).Debugf("%v Serving tasks", pkgLogHeader) listener, err := net.Listen("tcp", h.addr) if err != nil { log.WithError(err).Errorf("%v Listner failure", pkgLogHeader)