get with deduplicate (#5838)

Author: prkhrkat

pkg/resourceQualifiers/ResourceQualifiersMappingRepository.go

@@ -88,6 +88,7 @@ func (repo *QualifiersMappingRepositoryImpl) GetQualifierMappings(resourceType R
 	if err != nil {
 		return nil, err
 	}
+	qualifierMappings = DeduplicateQualifierMappings(qualifierMappings)
 	return qualifierMappings, nil
 }
 
@@ -143,6 +144,7 @@ func (repo *QualifiersMappingRepositoryImpl) GetMappingsByResourceTypeAndIdsAndQ
 	if err == pg.ErrNoRows {
 		err = nil
 	}
+	mappings = DeduplicateQualifierMappings(mappings)
 	return mappings, err
 }
 
@@ -165,6 +167,7 @@ func (repo *QualifiersMappingRepositoryImpl) GetQualifierMappingsForListOfQualif
 	if err != nil && err != pg.ErrNoRows {
 		return nil, err
 	}
+	qualifierMappings = DeduplicateQualifierMappings(qualifierMappings)
 	return qualifierMappings, nil
 }
 

pkg/resourceQualifiers/helper.go

@@ -67,3 +67,29 @@ func getIdentifierNamesForAppEnv(envName string, appName string) *SelectionIdent
 		AppName:         appName,
 	}
 }
+
+func DeduplicateQualifierMappings(mappings []*QualifierMapping) []*QualifierMapping {
+	uniqueMappings := make(map[string]*QualifierMapping)
+
+	for _, mapping := range mappings {
+		key := generateKey(mapping)
+		if existing, found := uniqueMappings[key]; found {
+			if mapping.UpdatedOn.After(existing.UpdatedOn) {
+				uniqueMappings[key] = mapping
+			}
+		} else {
+			uniqueMappings[key] = mapping
+		}
+	}
+
+	result := make([]*QualifierMapping, 0, len(uniqueMappings))
+	for _, mapping := range uniqueMappings {
+		result = append(result, mapping)
+	}
+
+	return result
+}
+
+func generateKey(mapping *QualifierMapping) string {
+	return fmt.Sprintf("%d-%d-%d-%d-%d-%s", mapping.ResourceId, mapping.ResourceType, mapping.QualifierId, mapping.IdentifierKey, mapping.IdentifierValueInt, mapping.IdentifierValueString)
+}