chrissewell/beelzebub
1
0
Fork 0
mirror of https://github.com/mariocandela/beelzebub.git synced 2025-07-01 18:47:26 -04:00
Code Issues Packages Projects Releases Wiki Activity

tiny refactoring

Browse Source
This commit is contained in:
Mario
2023-06-16 23:32:49 +02:00
parent 5fbe6c0211
commit b05a44a3c5
2 changed files with 12 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
builder/director.go
View File

@ -53,7 +53,6 @@ func (d *Director) rabbitMQTraceStrategy(event tracer.Event) {
"event": event, "event": event,
}).Info("New Event") }).Info("New Event")
log.Debug("Push Event on queue")
eventJSON, err := json.Marshal(event) eventJSON, err := json.Marshal(event)
if err != nil { if err != nil {
log.Error(err.Error()) 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 { if err = d.builder.rabbitMQChannel.PublishWithContext(context.TODO(), "", RabbitmqQueueName, false, false, publishing); err != nil {
log.Error(err.Error()) log.Error(err.Error())
} else {
log.WithFields(log.Fields{
"status": event.Status,
"event": event,
}).Debug("Event published")
} }
} }

6
parser/configurations_parser.go
View File

@ -5,6 +5,7 @@ import (
"io/ioutil" "io/ioutil"
"os" "os"
"path/filepath" "path/filepath"
"strings"
log "github.com/sirupsen/logrus" log "github.com/sirupsen/logrus"
"gopkg.in/yaml.v3" "gopkg.in/yaml.v3"
@ -124,13 +125,18 @@ func (bp configurationsParser) ReadConfigurationsServices() ([]BeelzebubServiceC
func gelAllFilesNameByDirName(dirName string) ([]string, error) { func gelAllFilesNameByDirName(dirName string) ([]string, error) {
var filesName []string var filesName []string
const extension = ".yaml"
files, err := ioutil.ReadDir(dirName) files, err := ioutil.ReadDir(dirName)
if err != nil { if err != nil {
return nil, err return nil, err
} }
for _, file := range files { for _, file := range files {
if !file.IsDir() && strings.Contains(file.Name(), extension) {
filesName = append(filesName, file.Name()) filesName = append(filesName, file.Name())
} else {
log.Debugf("Ignore ")
}
} }
return filesName, nil return filesName, nil
} }