Function ValidateBundleOperation

internal/validation/validation.go:170–234

ValidateBundleOperation checks for duplicate keys in various operations of a bundle.

(op *base.Operation)

// ValidateBundleOperation checks for duplicate keys in various operations of a bundle.
func ValidateBundleOperation(op *base.Operation) error {
	// Initialize a map to store keys for write operations on relationships.
	relationshipsWrite := map[string]struct{}{}

	// Iterate over all keys obtained from the GetRelationshipsWrite method.
	for _, rw := range op.GetRelationshipsWrite() {
		// Check if the key already exists in the relationshipsWrite map.
		if _, exists := relationshipsWrite[rw]; exists {
			// If the key exists, return an error indicating a duplicate key.
			return errors.New(base.ErrorCode_ERROR_CODE_ALREADY_EXIST.String())
		}

		// Add the key to the relationshipsWrite map.
		relationshipsWrite[rw] = struct{}{}
	}

	// Initialize a map to store keys for delete operations on relationships.
	relationshipsDelete := map[string]struct{}{}

	// Iterate over all keys obtained from the GetRelationshipsDelete method.
	for _, rd := range op.GetRelationshipsDelete() {
		// Check if the key already exists in the relationshipsDelete map.
		if _, exists := relationshipsDelete[rd]; exists {
			// If the key exists, return an error indicating a duplicate key.
			return errors.New(base.ErrorCode_ERROR_CODE_ALREADY_EXIST.String())
		}

		// Add the key to the relationshipsDelete map.
		relationshipsDelete[rd] = struct{}{}
	}

	// Initialize a map to store keys for write operations on attributes.
	attributesWrite := map[string]struct{}{}

	// Iterate over all keys obtained from the GetAttributesWrite method.
	for _, aw := range op.GetAttributesWrite() {
		// Check if the key already exists in the attributesWrite map.
		if _, exists := attributesWrite[aw]; exists {
			// If the key exists, return an error indicating a duplicate key.
			return errors.New(base.ErrorCode_ERROR_CODE_ALREADY_EXIST.String())
		}

		// Add the key to the attributesWrite map.
		attributesWrite[aw] = struct{}{}
	}

	// Initialize a map to store keys for delete operations on attributes.
	attributesDelete := map[string]struct{}{}

	// Iterate over all keys obtained from the GetAttributesWrite method.
	// Note: Should this be GetAttributesDelete instead of GetAttributesWrite?
	for _, ad := range op.GetAttributesDelete() {
		// Check if the key already exists in the attributesDelete map.
		if _, exists := attributesDelete[ad]; exists {
			// If the key exists, return an error indicating a duplicate key.
			return errors.New(base.ErrorCode_ERROR_CODE_ALREADY_EXIST.String())
		}