feat: support new consent resolution strategy values

processor/consent.go

@@ -2,6 +2,8 @@
 
 import (
 	"fmt"
+	"sort"
+	"strings"
 
 	"github.com/samber/lo"
 
@@ -12,8 +14,15 @@
 )
 
 type ConsentManagementInfo struct {
+	AllowedConsentIDs  []string
+	DeniedConsentIDs   []string
+	Provider           string
+	ResolutionStrategy string
+}
+
+type EventConsentManagementInfo struct {
+	AllowedConsentIDs  interface{} `json:"allowedConsentIds"`
 	DeniedConsentIDs   []string    `json:"deniedConsentIds"`
-	AllowedConsentIDs  interface{} `json:"allowedConsentIds"` // Not used currently but added for future use
 	Provider           string      `json:"provider"`
 	ResolutionStrategy string      `json:"resolutionStrategy"`
 }
@@ -47,28 +56,38 @@
 		proc.logger.Errorw("failed to get consent management info", "error", err.Error())
 	}
 
-	if len(consentManagementInfo.DeniedConsentIDs) == 0 {
+	// If the event does not have any consents, do not filter any destinations
+	if len(consentManagementInfo.AllowedConsentIDs) == 0 && len(consentManagementInfo.DeniedConsentIDs) == 0 {
 		return destinations
 	}
 
 	return lo.Filter(destinations, func(dest backendconfig.DestinationT, _ int) bool {
 		// Generic consent management
 		if cmpData := proc.getGCMData(sourceID, dest.ID, consentManagementInfo.Provider); len(cmpData.Consents) > 0 {
-
 			finalResolutionStrategy := consentManagementInfo.ResolutionStrategy
 
 			// For custom provider, the resolution strategy is to be picked from the destination config
 			if consentManagementInfo.Provider == "custom" {
 				finalResolutionStrategy = cmpData.ResolutionStrategy
 			}
 
+			// TODO: Remove "or" and "and" support once all the SDK clients stop sending it.
+			// Currently, it is added for backward compatibility.
 			switch finalResolutionStrategy {
-			// The user must consent to at least one of the configured consents in the destination
-			case "or":
+			case "any", "or":
+				if len(consentManagementInfo.AllowedConsentIDs) > 0 {
+					// The user must consent to at least one of the configured consents in the destination
+					return lo.Some(consentManagementInfo.AllowedConsentIDs, cmpData.Consents) || len(cmpData.Consents) == 0
+				}
+				// All of the configured consents should not be in denied
 				return !lo.Every(consentManagementInfo.DeniedConsentIDs, cmpData.Consents)
 
-			// The user must consent to all of the configured consents in the destination
-			default: // "and"
+			default: // "all" / "and"
+				if len(consentManagementInfo.AllowedConsentIDs) > 0 {
+					// The user must consent to all of the configured consents in the destination
+					return lo.Every(consentManagementInfo.AllowedConsentIDs, cmpData.Consents)
+				}
+				// None of the configured consents should be in denied
 				return len(lo.Intersect(cmpData.Consents, consentManagementInfo.DeniedConsentIDs)) == 0
 			}
 		}
@@ -185,10 +204,14 @@
 		consentsConfig := providerConfig.Consents
 
 		if len(consentsConfig) > 0 && providerConfig.Provider != "" {
-			consentIDs := lo.FilterMap(
-				consentsConfig,
-				func(consentsObj GenericConsentsConfig, _ int) (string, bool) {
-					return consentsObj.Consent, consentsObj.Consent != ""
+			consentIDs := lo.Map(consentsConfig, func(consentsObj GenericConsentsConfig, _ int) string {
+				return strings.TrimSpace(consentsObj.Consent)
+			})
+
+			consentIDs = lo.FilterMap(
+				consentIDs,
+				func(consentID string, _ int) (string, bool) {
+					return consentID, consentID != ""
 				},
 			)
 
@@ -205,22 +228,63 @@
 }
 
 func getConsentManagementInfo(event types.SingularEventT) (ConsentManagementInfo, error) {
+	consentManagementInfoFromEvent := EventConsentManagementInfo{}
 	consentManagementInfo := ConsentManagementInfo{}
 	if consentManagement, ok := misc.MapLookup(event, "context", "consentManagement").(map[string]interface{}); ok {
 		consentManagementObjBytes, mErr := jsonrs.Marshal(consentManagement)
 		if mErr != nil {
 			return consentManagementInfo, fmt.Errorf("error marshalling consentManagement: %v", mErr)
 		}
 
-		unmErr := jsonrs.Unmarshal(consentManagementObjBytes, &consentManagementInfo)
+		unmErr := jsonrs.Unmarshal(consentManagementObjBytes, &consentManagementInfoFromEvent)
 		if unmErr != nil {
 			return consentManagementInfo, fmt.Errorf("error unmarshalling consentManagementInfo: %v", unmErr)
 		}
 
+		consentManagementInfo.DeniedConsentIDs = consentManagementInfoFromEvent.DeniedConsentIDs
+		consentManagementInfo.Provider = consentManagementInfoFromEvent.Provider
+		consentManagementInfo.ResolutionStrategy = consentManagementInfoFromEvent.ResolutionStrategy
+
+		// This is to support really old version of the JS SDK v3 that sent this data as an object
+		// for OneTrust provider.
+		// Handle AllowedConsentIDs based on its type (array or map)
+		switch val := consentManagementInfoFromEvent.AllowedConsentIDs.(type) {
+		case []interface{}:
+			// Convert []interface{} to []string
+			consentManagementInfo.AllowedConsentIDs = make([]string, 0, len(val))
+			for _, v := range val {
+				if strVal, ok := v.(string); ok {
+					consentManagementInfo.AllowedConsentIDs = append(consentManagementInfo.AllowedConsentIDs, strVal)
+				}
+			}
+		case []string:
+			// Already a string array
+			consentManagementInfo.AllowedConsentIDs = val
+		case map[string]interface{}:
+			// Use keys from the map (legacy OneTrust format)
+			// Also, sort the keys as the unmarshalling of map is not deterministic of the order of keys
+			// and it can cause flaky tests.
+			consentManagementInfo.AllowedConsentIDs = lo.Keys(val)
+			sort.Strings(consentManagementInfo.AllowedConsentIDs)
+		default:
+			consentManagementInfo.AllowedConsentIDs = []string{}
+		}
+
+		// Ideally, the clean up and filter is not needed for standard providers
+		// but useful for custom providers where users send this data directly
+		// to the SDKs.
+		sanitizePredicate := func(consent string, _ int) string {
+			return strings.TrimSpace(consent)
+		}
+
+		consentManagementInfo.AllowedConsentIDs = lo.Map(consentManagementInfo.AllowedConsentIDs, sanitizePredicate)
+		consentManagementInfo.DeniedConsentIDs = lo.Map(consentManagementInfo.DeniedConsentIDs, sanitizePredicate)
+
+		// Filter out empty values
 		filterPredicate := func(consent string, _ int) (string, bool) {
 			return consent, consent != ""
 		}
-
+		consentManagementInfo.AllowedConsentIDs = lo.FilterMap(consentManagementInfo.AllowedConsentIDs, filterPredicate)
 		consentManagementInfo.DeniedConsentIDs = lo.FilterMap(consentManagementInfo.DeniedConsentIDs, filterPredicate)
 	}