Add MetadataObfuscator

HadesAPI/go.mod

@@ -6,6 +6,7 @@ require (
 	github.com/Mtze/HadesCI/shared v0.0.0
 	github.com/gin-gonic/gin v1.9.1
 	github.com/hibiken/asynq v0.24.1
+	github.com/hibiken/asynqmon v0.7.2
 	github.com/sirupsen/logrus v1.9.3
 )
 
@@ -27,7 +28,6 @@ require (
 	github.com/google/go-cmp v0.6.0 // indirect
 	github.com/google/uuid v1.6.0 // indirect
 	github.com/gorilla/mux v1.8.1 // indirect
-	github.com/hibiken/asynqmon v0.7.2 // indirect
 	github.com/joho/godotenv v1.5.1 // indirect
 	github.com/json-iterator/go v1.1.12 // indirect
 	github.com/klauspost/cpuid/v2 v2.2.4 // indirect

HadesAPI/main.go

@@ -49,6 +49,7 @@ func main() {
 		RootPath:          "/monitoring", // RootPath specifies the root for asynqmon app
 		RedisConnOpt:      asynq_client_opts,
 		PrometheusAddress: cfg.PrometheusAddress,
+		PayloadFormatter:  MetadataObfuscator,
 	})
 	r.Any("/monitoring/*a", gin.WrapH(h))
 

HadesAPI/monitoring.go

@@ -0,0 +1,23 @@
+package main
+
+import (
+	"encoding/json"
+
+	"github.com/Mtze/HadesCI/shared/payload"
+	"github.com/hibiken/asynqmon"
+	log "github.com/sirupsen/logrus"
+)
+
+var MetadataObfuscator = asynqmon.PayloadFormatterFunc(func(_ string, bytes []byte) string {
+	var job payload.QueuePayload
+	if err := json.Unmarshal(bytes, &job); err != nil {
+		log.WithError(err).Error("Failed to unmarshal task payload")
+		return ""
+	}
+	for i := range job.Steps {
+		job.Steps[i].Metadata = make(map[string]string)
+	}
+
+	json_tmp, _ := json.Marshal(job)
+	return string(json_tmp)
+})