fix(dlq): dlq listing api not using the right prefix

internal/server/v1/dlq/handler.go

@@ -41,7 +41,7 @@ func (h *Handler) ListFirehoseDLQ(w http.ResponseWriter, r *http.Request) {
 	}
 	// check the variables for dlq related config.
 	bucketName := conf.EnvVariables[firehose.ConfigDLQBucket]
-	directoryPrefix := conf.EnvVariables[firehose.ConfigDLQDirectoryPrefix]
+	directoryPrefix := buildDlqPrefixDirectory(conf.EnvVariables[firehose.ConfigDLQDirectoryPrefix], resp.GetResource().GetName())
 	topicDates, err := h.service.gcsClient.ListDlqMetadata(gcs.BucketInfo{
 		BucketName: bucketName,
 		Prefix:     directoryPrefix,

internal/server/v1/dlq/helpers.go

@@ -0,0 +1,7 @@
+package dlq
+
+import "strings"
+
+func buildDlqPrefixDirectory(template string, firehoseName string) string {
+	return strings.Replace(template, "{{ .name }}", firehoseName, 1)
+}

internal/server/v1/dlq/mapper.go

@@ -4,7 +4,6 @@ import (
 	"errors"
 	"fmt"
 	"strconv"
-	"strings"
 
 	entropyv1beta1 "buf.build/gen/go/gotocompany/proton/protocolbuffers/go/gotocompany/entropy/v1beta1"
 	"github.com/go-openapi/strfmt"
@@ -68,7 +67,7 @@ func enrichDlqJob(job *models.DlqJob, res *entropyv1beta1.Resource) error {
 	dataType := envs["INPUT_SCHEMA_PROTO_CLASS"]
 	groupID := firehoseLabels["group"]
 	groupSlug := firehoseLabels["team"]
-	dlqPrefixDirectory := strings.Replace(envs["DLQ_GCS_DIRECTORY_PREFIX"], "{{ .name }}", res.Name, 1)
+	dlqPrefixDirectory := buildDlqPrefixDirectory(envs["DLQ_GCS_DIRECTORY_PREFIX"], res.Name)
 	metricStatsDTag := fmt.Sprintf(
 		"namespace=%s,app=%s,sink=%s,team=%s,proto=%s,firehose=%s",
 		namespace,