Helper function for backward compatible execution IDs (#1970)

Author: bolekk

pkg/workflows/utils.go

@@ -4,11 +4,14 @@ import (
 	"crypto/sha256"
 	"encoding/binary"
 	"encoding/hex"
+	"fmt"
+	"strconv"
 	"strings"
 
 	"golang.org/x/crypto/sha3"
 )
 
+// Deprecated: Use GenerateExecutionIDWithTriggerIndex instead.
 func EncodeExecutionID(workflowID, eventID string) (string, error) {
 	s := sha256.New()
 	_, err := s.Write([]byte(workflowID))
@@ -24,6 +27,34 @@ func EncodeExecutionID(workflowID, eventID string) (string, error) {
 	return hex.EncodeToString(s.Sum(nil)), nil
 }
 
+func GenerateExecutionIDWithTriggerIndex(workflowID, triggerEventID string, triggerIndex int) (string, error) {
+	s := sha256.New()
+	_, err := s.Write([]byte(workflowID))
+	if err != nil {
+		return "", err
+	}
+
+	_, err = s.Write([]byte(triggerEventID))
+	if err != nil {
+		return "", err
+	}
+
+	_, err = s.Write([]byte(strconv.Itoa(triggerIndex)))
+	if err != nil {
+		return "", err
+	}
+
+	return hex.EncodeToString(s.Sum(nil)), nil
+}
+
+func GetTriggerReferenceID(triggerIndex int) string {
+	return fmt.Sprintf("trigger_%d", triggerIndex)
+}
+
+func GetTriggerIndexFromReferenceID(referenceID string) (int, error) {
+	return strconv.Atoi(strings.TrimPrefix(referenceID, "trigger_"))
+}
+
 func GenerateWorkflowIDFromStrings(owner string, name string, workflow []byte, config []byte, secretsURL string) (string, error) {
 	ownerWithoutPrefix := owner
 	if strings.HasPrefix(owner, "0x") {

pkg/workflows/utils_test.go

@@ -42,6 +42,15 @@ func Test_EncodeExecutionID(t *testing.T) {
 	assert.NotEqual(t, reversed, actual)
 }
 
+func Test_GetTriggerReferenceID_RoundTrip(t *testing.T) {
+	for _, idx := range []int{0, 1, 5, 100} {
+		refID := GetTriggerReferenceID(idx)
+		got, err := GetTriggerIndexFromReferenceID(refID)
+		require.NoError(t, err)
+		assert.Equal(t, idx, got)
+	}
+}
+
 func Test_GenerateWorkflowIDFromStrings(t *testing.T) {
 	// With prefix
 	owner := "0x26729408f179371be6433b9585d8427f121bfe82"