diff --git a/builder/director.go b/builder/director.go index bf09f0c..42187e8 100644 --- a/builder/director.go +++ b/builder/director.go @@ -53,7 +53,6 @@ func (d *Director) rabbitMQTraceStrategy(event tracer.Event) { "event": event, }).Info("New Event") - log.Debug("Push Event on queue") eventJSON, err := json.Marshal(event) if err != nil { log.Error(err.Error()) @@ -64,5 +63,10 @@ func (d *Director) rabbitMQTraceStrategy(event tracer.Event) { if err = d.builder.rabbitMQChannel.PublishWithContext(context.TODO(), "", RabbitmqQueueName, false, false, publishing); err != nil { log.Error(err.Error()) + } else { + log.WithFields(log.Fields{ + "status": event.Status, + "event": event, + }).Debug("Event published") } } diff --git a/parser/configurations_parser.go b/parser/configurations_parser.go index 5176814..4106920 100644 --- a/parser/configurations_parser.go +++ b/parser/configurations_parser.go @@ -5,6 +5,7 @@ import ( "io/ioutil" "os" "path/filepath" + "strings" log "github.com/sirupsen/logrus" "gopkg.in/yaml.v3" @@ -124,13 +125,18 @@ func (bp configurationsParser) ReadConfigurationsServices() ([]BeelzebubServiceC func gelAllFilesNameByDirName(dirName string) ([]string, error) { var filesName []string + const extension = ".yaml" files, err := ioutil.ReadDir(dirName) if err != nil { return nil, err } for _, file := range files { - filesName = append(filesName, file.Name()) + if !file.IsDir() && strings.Contains(file.Name(), extension) { + filesName = append(filesName, file.Name()) + } else { + log.Debugf("Ignore ") + } } return filesName, nil }