feat: implement HexDecodeWorkflowName

Author: agparadiso

pkg/workflows/utils.go

@@ -4,6 +4,8 @@ import (
 	"crypto/sha256"
 	"encoding/hex"
 	"strings"
+
+	"github.com/smartcontractkit/chainlink-common/pkg/logger"
 )
 
 func EncodeExecutionID(workflowID, eventID string) (string, error) {
@@ -84,3 +86,14 @@ func HashTruncateName(name string) [10]byte {
 
 	return result
 }
+
+// HexDecodeWorkflowName makes the best effort to decode the hex workflow name.
+// In case of failure it will log the error and return the input name.
+func HexDecodeWorkflowName(encoded string, logger logger.Logger) string {
+	decoded, err := hex.DecodeString(encoded)
+	if err != nil {
+		logger.Errorf("failed to decode WorkflowName %q: %v", encoded, err)
+		return encoded
+	}
+	return string(decoded)
+}

pkg/workflows/utils_test.go

@@ -5,6 +5,7 @@ import (
 	"encoding/hex"
 	"testing"
 
+	"github.com/smartcontractkit/chainlink-common/pkg/logger"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 )
@@ -99,3 +100,29 @@ func TestNormalizeWorkflowName(t *testing.T) {
 		})
 	}
 }
+
+func TestHexDecodeWorkflowName(t *testing.T) {
+	tt := []struct {
+		name     string
+		input    string
+		expected string
+	}{
+		{
+			name:     "OK-correct_workflow_name",
+			input:    "776f726b666c6f772d6e616d65",
+			expected: "workflow-name",
+		},
+		{
+			name:     "NOK-incorrect_workflow_name",
+			input:    "776f726b666c6f772d6e616d65!",
+			expected: "776f726b666c6f772d6e616d65!",
+		},
+	}
+
+	for _, tc := range tt {
+		t.Run(tc.name, func(t *testing.T) {
+			result := HexDecodeWorkflowName(tc.input, logger.TestSugared(t))
+			require.Equal(t, tc.expected, result)
+		})
+	}
+}