diff --git a/e2core/server/handlers.go b/e2core/server/handlers.go index 461eb60e..28771087 100644 --- a/e2core/server/handlers.go +++ b/e2core/server/handlers.go @@ -17,8 +17,15 @@ func (s *Server) executePluginByNameHandler() echo.HandlerFunc { namespace := ReadParam(c, "namespace") name := ReadParam(c, "name") + ll := s.logger.With(). + Str("ident", ident). + Str("namespace", namespace). + Str("fn", name). + Logger() + mod := s.syncer.GetModuleByName(ident, namespace, name) if mod == nil { + ll.Error().Msg("syncer did not find module by these details") return echo.NewHTTPError(http.StatusNotFound, "module not found") } @@ -32,6 +39,10 @@ func (s *Server) executePluginByNameHandler() echo.HandlerFunc { return echo.NewHTTPError(http.StatusInternalServerError, "failed to handle request").SetInternal(err) } + ll.Info(). + Str("fqmn", mod.FQMN). + Msg("found module with fqmn") + steps := []tenant.WorkflowStep{{FQMN: mod.FQMN}} // a sequence executes the handler's steps and manages its state. diff --git a/e2core/server/server.go b/e2core/server/server.go index 0c879aa4..2cf9a08e 100644 --- a/e2core/server/server.go +++ b/e2core/server/server.go @@ -30,6 +30,7 @@ type Server struct { dispatcher *dispatcher options *options.Options + logger zerolog.Logger } // New creates a new Server instance. @@ -67,6 +68,7 @@ func New(l zerolog.Logger, sync *syncer.Syncer, opts *options.Options) (*Server, options: opts, bus: b, dispatcher: d, + logger: ll, } if opts.AdminEnabled() {