001/* 002 * Copyright 2019 Anyware Services 003 * 004 * Licensed under the Apache License, Version 2.0 (the "License"); 005 * you may not use this file except in compliance with the License. 006 * You may obtain a copy of the License at 007 * 008 * http://www.apache.org/licenses/LICENSE-2.0 009 * 010 * Unless required by applicable law or agreed to in writing, software 011 * distributed under the License is distributed on an "AS IS" BASIS, 012 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 013 * See the License for the specific language governing permissions and 014 * limitations under the License. 015 */ 016package org.ametys.cms.data; 017 018import java.util.ArrayList; 019import java.util.Arrays; 020import java.util.Collection; 021import java.util.Collections; 022import java.util.HashMap; 023import java.util.HashSet; 024import java.util.List; 025import java.util.Map; 026import java.util.Optional; 027import java.util.Set; 028import java.util.function.Function; 029import java.util.stream.Collectors; 030import java.util.stream.IntStream; 031import java.util.stream.Stream; 032 033import org.apache.avalon.framework.component.Component; 034import org.apache.avalon.framework.service.ServiceException; 035import org.apache.avalon.framework.service.ServiceManager; 036import org.apache.avalon.framework.service.Serviceable; 037import org.apache.commons.collections4.SetUtils; 038import org.apache.commons.lang3.StringUtils; 039import org.apache.commons.lang3.tuple.ImmutablePair; 040import org.apache.commons.lang3.tuple.Pair; 041 042import org.ametys.cms.contenttype.ContentAttributeDefinition; 043import org.ametys.cms.contenttype.ContentType; 044import org.ametys.cms.contenttype.ContentTypeExtensionPoint; 045import org.ametys.cms.data.type.ModelItemTypeConstants; 046import org.ametys.cms.repository.Content; 047import org.ametys.cms.repository.ModifiableContent; 048import org.ametys.plugins.repository.AmetysObjectResolver; 049import org.ametys.plugins.repository.data.external.ExternalizableDataProvider.ExternalizableDataStatus; 050import org.ametys.plugins.repository.data.holder.DataHolder; 051import org.ametys.plugins.repository.data.holder.ModelAwareDataHolder; 052import org.ametys.plugins.repository.data.holder.ModifiableModelAwareDataHolder; 053import org.ametys.plugins.repository.data.holder.group.impl.ModelAwareRepeater; 054import org.ametys.plugins.repository.data.holder.group.impl.ModelAwareRepeaterEntry; 055import org.ametys.plugins.repository.data.holder.group.impl.ModifiableModelAwareComposite; 056import org.ametys.plugins.repository.data.holder.group.impl.ModifiableModelAwareRepeater; 057import org.ametys.plugins.repository.data.holder.group.impl.ModifiableModelAwareRepeaterEntry; 058import org.ametys.plugins.repository.data.holder.impl.DataHolderHelper; 059import org.ametys.plugins.repository.data.holder.values.SynchronizableRepeater; 060import org.ametys.plugins.repository.data.holder.values.SynchronizableValue; 061import org.ametys.plugins.repository.data.holder.values.SynchronizationContext; 062import org.ametys.plugins.repository.data.holder.values.UntouchedValue; 063import org.ametys.plugins.repository.data.holder.values.ValueContext; 064import org.ametys.plugins.repository.model.RepeaterDefinition; 065import org.ametys.plugins.repository.model.ViewHelper; 066import org.ametys.runtime.model.ModelItem; 067import org.ametys.runtime.model.ModelViewItemGroup; 068import org.ametys.runtime.model.View; 069import org.ametys.runtime.model.ViewItemContainer; 070import org.ametys.runtime.model.exception.BadItemTypeException; 071 072/** 073 * Helper for data of type 'content' 074 */ 075public class ContentDataHelper implements Serviceable, Component 076{ 077 /** Avalon role */ 078 public static final String ROLE = ContentDataHelper.class.getName(); 079 080 private AmetysObjectResolver _resolver; 081 private ContentTypeExtensionPoint _cTypeExtensionPoint; 082 083 public void service(ServiceManager manager) throws ServiceException 084 { 085 _resolver = (AmetysObjectResolver) manager.lookup(AmetysObjectResolver.ROLE); 086 _cTypeExtensionPoint = (ContentTypeExtensionPoint) manager.lookup(ContentTypeExtensionPoint.ROLE); 087 } 088 089 /** 090 * Retrieves the content identifier of a content data 091 * @param dataHolder data holder that contains the content data 092 * @param dataPath path to the content data 093 * @param defaultValue The default value to return 094 * @return the content identifier 095 * @throws BadItemTypeException if the data at the given path is not a content data 096 */ 097 public static String getContentIdFromContentData(ModelAwareDataHolder dataHolder, String dataPath, String defaultValue) throws BadItemTypeException 098 { 099 ContentValue value = dataHolder.getValue(dataPath); 100 return Optional.ofNullable(value) 101 .map(ContentValue::getContentId) 102 .orElse(defaultValue); 103 } 104 105 /** 106 * Retrieves the content identifier of a content data 107 * @param dataHolder data holder that contains the content data 108 * @param dataPath path to the content data 109 * @return the content identifier, empty string if it is invalid 110 * @throws BadItemTypeException if the data at the given path is not a content data 111 */ 112 public static String getContentIdFromContentData(ModelAwareDataHolder dataHolder, String dataPath) throws BadItemTypeException 113 { 114 return getContentIdFromContentData(dataHolder, dataPath, StringUtils.EMPTY); 115 } 116 117 /** 118 * Retrieves the content identifiers in an array from a multiple content data 119 * @param dataHolder data holder that contains the multiple content data 120 * @param dataPath path to the multiple content data 121 * @return an array containing the content identifiers 122 * @throws BadItemTypeException if the data at the given path is not a content data 123 */ 124 public static boolean isMultipleContentDataEmpty(ModelAwareDataHolder dataHolder, String dataPath) throws BadItemTypeException 125 { 126 return isMultipleContentDataEmpty(dataHolder, dataPath, ValueContext.newInstance()); 127 } 128 129 /** 130 * Retrieves the content identifiers in an array from a multiple content data 131 * @param dataHolder data holder that contains the multiple content data 132 * @param dataPath path to the multiple content data 133 * @param context the context of the value to retrieve 134 * @return an array containing the content identifiers 135 * @throws BadItemTypeException if the data at the given path is not a content data 136 */ 137 public static boolean isMultipleContentDataEmpty(ModelAwareDataHolder dataHolder, String dataPath, ValueContext context) throws BadItemTypeException 138 { 139 return getContentIdsStreamFromMultipleContentData(dataHolder, dataPath, context).count() <= 0; 140 } 141 142 /** 143 * Retrieves the content identifiers in a {@link List} from a multiple content data 144 * @param dataHolder data holder that contains the multiple content data 145 * @param dataPath path to the multiple content data 146 * @return a {@link List} containing the content identifiers 147 * @throws BadItemTypeException if the data at the given path is not a content data 148 */ 149 public static List<String> getContentIdsListFromMultipleContentData(ModelAwareDataHolder dataHolder, String dataPath) throws BadItemTypeException 150 { 151 return getContentIdsListFromMultipleContentData(dataHolder, dataPath, ValueContext.newInstance()); 152 } 153 154 /** 155 * Retrieves the content identifiers in a {@link List} from a multiple content data 156 * @param dataHolder data holder that contains the multiple content data 157 * @param dataPath path to the multiple content data 158 * @param context the context of the value to retrieve 159 * @return a {@link List} containing the content identifiers 160 * @throws BadItemTypeException if the data at the given path is not a content data 161 */ 162 public static List<String> getContentIdsListFromMultipleContentData(ModelAwareDataHolder dataHolder, String dataPath, ValueContext context) throws BadItemTypeException 163 { 164 return getContentIdsStreamFromMultipleContentData(dataHolder, dataPath, context).collect(Collectors.toList()); 165 } 166 167 /** 168 * Retrieves the content identifiers in an array from a multiple content data 169 * @param dataHolder data holder that contains the multiple content data 170 * @param dataPath path to the multiple content data 171 * @return an array containing the content identifiers 172 * @throws BadItemTypeException if the data at the given path is not a content data 173 */ 174 public static String[] getContentIdsArrayFromMultipleContentData(ModelAwareDataHolder dataHolder, String dataPath) throws BadItemTypeException 175 { 176 return getContentIdsArrayFromMultipleContentData(dataHolder, dataPath, ValueContext.newInstance()); 177 } 178 179 /** 180 * Retrieves the content identifiers in an array from a multiple content data 181 * @param dataHolder data holder that contains the multiple content data 182 * @param dataPath path to the multiple content data 183 * @param context the context of the value to retrieve 184 * @return an array containing the content identifiers 185 * @throws BadItemTypeException if the data at the given path is not a content data 186 */ 187 public static String[] getContentIdsArrayFromMultipleContentData(ModelAwareDataHolder dataHolder, String dataPath, ValueContext context) throws BadItemTypeException 188 { 189 return getContentIdsStreamFromMultipleContentData(dataHolder, dataPath, context).toArray(String[]::new); 190 } 191 192 /** 193 * Retrieves a {@link Stream} of the content identifiers from a multiple content data 194 * @param dataHolder data holder that contains the multiple content data 195 * @param dataPath path to the multiple content data 196 * @return a {@link Stream} of the content identifiers 197 * @throws BadItemTypeException if the data at the given path is not a content data 198 */ 199 public static Stream<String> getContentIdsStreamFromMultipleContentData(ModelAwareDataHolder dataHolder, String dataPath) throws BadItemTypeException 200 { 201 return getContentIdsStreamFromMultipleContentData(dataHolder, dataPath, ValueContext.newInstance()); 202 } 203 204 /** 205 * Retrieves a {@link Stream} of the content identifiers from a multiple content data 206 * @param dataHolder data holder that contains the multiple content data 207 * @param dataPath path to the multiple content data 208 * @param context the context of the value to retrieve 209 * @return a {@link Stream} of the content identifiers 210 * @throws BadItemTypeException if the data at the given path is not a content data 211 */ 212 public static Stream<String> getContentIdsStreamFromMultipleContentData(ModelAwareDataHolder dataHolder, String dataPath, ValueContext context) throws BadItemTypeException 213 { 214 ContentValue[] value = DataHolderHelper.getValue(dataHolder, dataPath, context); 215 return Optional.ofNullable(value) 216 .map(v -> Arrays.stream(v)) 217 .orElse(Stream.empty()) 218 .map(ContentValue::getContentId); 219 } 220 221 /** 222 * Prepares a write operation in the given {@link ModelAwareDataHolder} by traversing a {@link View} with the values to be written.<br> 223 * The goal is to find content attributes and to extract added and removed values. 224 * @param viewItemContainer the view to walk through 225 * @param content the source {@link ModifiableContent} 226 * @param values the new values 227 * @param context the synchronization context 228 * @return the contents to-be-added and to-be-removed 229 */ 230 public Collection<ReferencedContents> collectReferencedContents(ViewItemContainer viewItemContainer, ModifiableContent content, Map<String, Object> values, SynchronizationContext context) 231 { 232 // content ids, grouped by invert attribute paths, instead of definition paths, so that if several attributes share the same invert attribute, they are handled together 233 // data structure is <definition> mapped <previous contents mapped with their data paths, new contents mapped with their data paths> 234 Map<ContentAttributeDefinition, Pair<Map<ContentValue, List<String>>, Map<ContentValue, List<String>>>> references = new HashMap<>(); 235 236 _collectReferencedContents(content, viewItemContainer, Optional.of(content), StringUtils.EMPTY, Optional.of(StringUtils.EMPTY), Optional.of(values), false, context, references); 237 238 Collection<ReferencedContents> contents = new ArrayList<>(); 239 for (ContentAttributeDefinition definition : references.keySet()) 240 { 241 Pair<Map<ContentValue, List<String>>, Map<ContentValue, List<String>>> allValues = references.get(definition); 242 Map<ContentValue, List<String>> previousValues = allValues.getLeft(); 243 Map<ContentValue, List<String>> newValues = allValues.getRight(); 244 245 Map<ContentValue, List<String>> addedValues = new HashMap<>(); 246 Map<ContentValue, List<String>> removedValues = new HashMap<>(); 247 248 newValues.forEach((value, list) -> { 249 if (!previousValues.containsKey(value)) 250 { 251 addedValues.put(value, list); 252 } 253 }); 254 255 previousValues.forEach((value, list) -> { 256 if (!newValues.containsKey(value)) 257 { 258 removedValues.put(value, list); 259 } 260 }); 261 262 String invert = definition.getInvertRelationPath(); 263 ContentType invertType = _cTypeExtensionPoint.getExtension(definition.getContentTypeId()); 264 ContentAttributeDefinition invertDefinition = (ContentAttributeDefinition) invertType.getModelItem(invert); 265 266 Map<ContentValue, ContentValue> thirdPartyContents = new HashMap<>(); 267 if (!DataHolderHelper.isMultiple(invertDefinition)) 268 { 269 List<ModifiableContent> refContents = addedValues.keySet().stream().map(v -> v.getContentIfExists()).flatMap(Optional::stream).collect(Collectors.toList()); 270 271 for (ModifiableContent refContent : refContents) 272 { 273 ContentValue previousValue = refContent.getValue(invert); 274 if (previousValue != null) 275 { 276 String previousContentId = previousValue.getContentId(); 277 if (!content.getId().equals(previousContentId)) 278 { 279 // the single-valued content attribute is about to change, we should store the 3rd party content involved in the invert relation 280 thirdPartyContents.put(new ContentValue(refContent), previousValue); 281 } 282 } 283 } 284 } 285 286 contents.add(new ReferencedContents(definition, addedValues, removedValues, thirdPartyContents)); 287 } 288 289 return contents; 290 } 291 292 @SuppressWarnings("unchecked") 293 private void _collectReferencedContents(Content content, 294 ViewItemContainer viewItemContainer, 295 Optional<ModelAwareDataHolder> currentDataHolder, 296 String dataPathPrefix, 297 Optional<String> oldDataPathPrefix, 298 Optional<Map<String, Object>> values, 299 boolean insideKeptDataHolder, 300 SynchronizationContext context, 301 Map<ContentAttributeDefinition, Pair<Map<ContentValue, List<String>>, Map<ContentValue, List<String>>>> references) 302 { 303 ViewHelper.visitView(viewItemContainer, 304 (element, definition) -> { 305 // simple element 306 String name = definition.getName(); 307 308 if (definition instanceof ContentAttributeDefinition) 309 { 310 ContentAttributeDefinition contentDefinition = (ContentAttributeDefinition) definition; 311 String invert = contentDefinition.getInvertRelationPath(); 312 if (invert != null) 313 { 314 _collectInvertRelation(content, currentDataHolder, dataPathPrefix, oldDataPathPrefix, values, insideKeptDataHolder, name, contentDefinition, context, references); 315 } 316 } 317 }, 318 (group, definition) -> { 319 // composite 320 String name = definition.getName(); 321 String updatedPrefix = dataPathPrefix + name + ModelItem.ITEM_PATH_SEPARATOR; 322 Optional<String> updatedOldPrefix = oldDataPathPrefix.map(p -> p + name + ModelItem.ITEM_PATH_SEPARATOR); 323 _collectReferencedContents(content, group, currentDataHolder.map(v -> v.getComposite(name)), updatedPrefix, updatedOldPrefix, values.map(v -> (Map<String, Object>) v.get(name)), insideKeptDataHolder, context, references); 324 }, 325 (group, definition) -> { 326 // repeater 327 String name = definition.getName(); 328 _collectRepeater(content, group, currentDataHolder, dataPathPrefix, oldDataPathPrefix, values, insideKeptDataHolder, context, name, references); 329 }, 330 group -> _collectReferencedContents(content, group, currentDataHolder, dataPathPrefix, oldDataPathPrefix, values, insideKeptDataHolder, context, references)); 331 } 332 333 private void _collectInvertRelation(Content content, 334 Optional<ModelAwareDataHolder> currentDataHolder, 335 String dataPathPrefix, 336 Optional<String> oldDataPathPrefix, 337 Optional<Map<String, Object>> values, 338 boolean insideKeptDataHolder, 339 String name, 340 ContentAttributeDefinition definition, 341 SynchronizationContext context, 342 Map<ContentAttributeDefinition, Pair<Map<ContentValue, List<String>>, Map<ContentValue, List<String>>>> references) 343 { 344 String dataPath = dataPathPrefix + name; 345 346 Set<ContentValue> previousContents = currentDataHolder 347 .map(dh -> dh.getValue(name)) 348 .map(this::_getContentRefs) 349 .orElseGet(Collections::emptySet); 350 Set<ContentValue> newContents; 351 352 if (insideKeptDataHolder) 353 { 354 newContents = previousContents; 355 } 356 else 357 { 358 Optional<Object> rawValue = values.map(v -> v.get(name)); 359 360 Optional<String> oldDataPath = oldDataPathPrefix.map(p -> p + name); 361 rawValue = rawValue.map(v -> DataHolderHelper.getValueFromSynchronizableValue(v, content, definition, oldDataPath, context)); 362 363 // If the current value is an untouched value, don't edit the invert relation 364 if (rawValue.filter(UntouchedValue.class::isInstance).isPresent()) 365 { 366 return; 367 } 368 369 newContents = rawValue.map(this::_getContentRefs) 370 .orElseGet(Collections::emptySet); 371 372 SynchronizableValue.Mode mode = values.map(v -> v.get(name)) 373 .filter(SynchronizableValue.class::isInstance) 374 .map(SynchronizableValue.class::cast) 375 .map(v -> v.getMode()) 376 .orElse(SynchronizableValue.Mode.REPLACE); 377 378 if (mode == SynchronizableValue.Mode.REMOVE) 379 { 380 newContents = SetUtils.difference(previousContents, newContents); 381 } 382 else if (mode == SynchronizableValue.Mode.APPEND) 383 { 384 newContents = SetUtils.union(previousContents, newContents); 385 } 386 } 387 388 _addReferences(references, definition, dataPath, previousContents, newContents); 389 } 390 391 private Set<ContentValue> _getContentRefs(Object value) 392 { 393 if (value instanceof ContentValue) 394 { 395 return Set.of((ContentValue) value); 396 } 397 else if (value instanceof ContentValue[]) 398 { 399 return Set.copyOf(Arrays.asList((ContentValue[]) value)); 400 } 401 else if (value instanceof String) 402 { 403 return Set.of(new ContentValue(_resolver, (String) value)); 404 } 405 else if (value instanceof String[]) 406 { 407 return Arrays.stream((String[]) value).map(id -> new ContentValue(_resolver, id)).collect(Collectors.toSet()); 408 } 409 else if (value instanceof ModifiableContent) 410 { 411 return Set.of(new ContentValue((ModifiableContent) value)); 412 } 413 else if (value instanceof ModifiableContent[]) 414 { 415 return Arrays.stream((ModifiableContent[]) value).map(ContentValue::new).collect(Collectors.toSet()); 416 } 417 418 return Collections.emptySet(); 419 } 420 421 private void _addReferences(Map<ContentAttributeDefinition, Pair<Map<ContentValue, List<String>>, Map<ContentValue, List<String>>>> references, ContentAttributeDefinition definition, String dataPath, Set<ContentValue> previousContents, Set<ContentValue> newContents) 422 { 423 Pair<Map<ContentValue, List<String>>, Map<ContentValue, List<String>>> values = references.get(definition); 424 Map<ContentValue, List<String>> previousValues = values == null ? new HashMap<>() : values.getLeft(); 425 Map<ContentValue, List<String>> newValues = values == null ? new HashMap<>() : values.getRight(); 426 427 previousContents.forEach(c -> previousValues.computeIfAbsent(c, __ -> new ArrayList<>()).add(dataPath)); 428 newContents.forEach(c -> newValues.computeIfAbsent(c, __ -> new ArrayList<>()).add(dataPath)); 429 430 references.put(definition, Pair.of(previousValues, newValues)); 431 } 432 433 @SuppressWarnings("unchecked") 434 private void _collectRepeater(Content content, 435 ModelViewItemGroup group, 436 Optional<ModelAwareDataHolder> currentDataHolder, 437 String dataPathPrefix, 438 Optional<String> oldDataPathPrefix, 439 Optional<Map<String, Object>> values, 440 boolean insideKeptDataHolder, 441 SynchronizationContext context, 442 String name, 443 Map<ContentAttributeDefinition, Pair<Map<ContentValue, List<String>>, Map<ContentValue, List<String>>>> references) 444 { 445 Object value = values.map(v -> v.get(name)).orElse(null); 446 List<Map<String, Object>> newEntries = null; 447 Map<Integer, Integer> mapping = null; 448 SynchronizableRepeater.Mode mode = SynchronizableRepeater.Mode.REPLACE_ALL; 449 if (value instanceof List) 450 { 451 newEntries = (List<Map<String, Object>>) value; 452 mapping = IntStream.rangeClosed(1, newEntries.size()).boxed().collect(Collectors.toMap(Function.identity(), Function.identity())); 453 } 454 else if (value instanceof SynchronizableRepeater) 455 { 456 newEntries = ((SynchronizableRepeater) value).getEntries(); 457 mapping = ((SynchronizableRepeater) value).getPositionsMapping(); 458 mode = ((SynchronizableRepeater) value).getMode(); 459 } 460 461 // first collect data for actually existing entries 462 Set<Integer> alreadyHandledValues = new HashSet<>(); 463 ModelAwareRepeater repeater = currentDataHolder.map(v -> v.getRepeater(name)).orElse(null); 464 if (repeater != null) 465 { 466 for (ModelAwareRepeaterEntry entry : repeater.getEntries()) 467 { 468 int position = entry.getPosition(); 469 470 Optional<Map<String, Object>> newValues = Optional.empty(); 471 String newPositionSuffix = ""; 472 boolean newKeptValue = insideKeptDataHolder; 473 474 if (!insideKeptDataHolder) 475 { 476 if (mode == SynchronizableRepeater.Mode.REPLACE_ALL) 477 { 478 Integer newPosition = mapping != null ? mapping.get(position) : null; 479 480 if (newPosition != null) 481 { 482 // not removed entry 483 newValues = newEntries != null ? Optional.ofNullable(newEntries.get(newPosition - 1)) : Optional.empty(); 484 newPositionSuffix = "[" + newPosition + "]"; 485 alreadyHandledValues.add(newPosition); 486 } 487 } 488 else if (mode == SynchronizableRepeater.Mode.REPLACE) 489 { 490 List<Integer> replacePositions = ((SynchronizableRepeater) value).getReplacePositions(); 491 int index = replacePositions.indexOf(position); 492 493 if (index >= 0) 494 { 495 assert newEntries != null; 496 newValues = Optional.ofNullable(newEntries.get(index)); 497 newPositionSuffix = "[" + position + "]"; 498 alreadyHandledValues.add(position); 499 } 500 else 501 { 502 // entry kept as is 503 newKeptValue = true; 504 } 505 } 506 else 507 { 508 Set<Integer> removedEntries = ((SynchronizableRepeater) value).getRemovedEntries(); 509 newKeptValue = !removedEntries.contains(position); 510 } 511 } 512 513 String updatePrefix = dataPathPrefix + name + newPositionSuffix + ModelItem.ITEM_PATH_SEPARATOR; 514 Optional<String> updatedOldPrefix = oldDataPathPrefix.map(p -> dataPathPrefix + name + "[" + position + "]" + ModelItem.ITEM_PATH_SEPARATOR); 515 _collectReferencedContents(content, group, Optional.of(entry), updatePrefix, updatedOldPrefix, newValues, newKeptValue, context, references); 516 } 517 } 518 519 // then collect data for newly created entries 520 if (newEntries != null) 521 { 522 for (int i = 1; i <= newEntries.size(); i++) 523 { 524 if (!alreadyHandledValues.contains(i)) 525 { 526 String updatedPrefix = dataPathPrefix + name + "[" + i + "]" + ModelItem.ITEM_PATH_SEPARATOR; 527 _collectReferencedContents(content, group, Optional.empty(), updatedPrefix, Optional.empty(), Optional.of(newEntries.get(i - 1)), insideKeptDataHolder, context, references); 528 } 529 } 530 } 531 } 532 533 /** 534 * Find any broken reference in data holder's content attributes. 535 * A reference is considered as broken if the referenced content does not exist 536 * @param dataHolder the {@link ModelAwareDataHolder} to inspect. 537 * @param fix if <code>true</code>, and the dataHolder is modifiable, broken references will be removed 538 * Warning: if modifications are made on the given data holder, the modifications won't be saved and the workflow won't change 539 * @return all broken references, by attribute path 540 */ 541 public static Map<String, List<String>> checkBrokenReferences(ModelAwareDataHolder dataHolder, boolean fix) 542 { 543 Map<String, List<String>> result = new HashMap<>(); 544 Map<String, Object> contentAttributes = DataHolderHelper.findItemsByType(dataHolder, ModelItemTypeConstants.CONTENT_ELEMENT_TYPE_ID); 545 for (Map.Entry<String, Object> entry : contentAttributes.entrySet()) 546 { 547 String dataPath = entry.getKey(); 548 Object value = entry.getValue(); 549 if (value instanceof ContentValue) 550 { 551 ContentValue contentValue = (ContentValue) value; 552 if (contentValue.getContentIfExists().isEmpty()) 553 { 554 result.computeIfAbsent(dataPath, __ -> new ArrayList<>()).add(contentValue.getContentId()); 555 if (fix && dataHolder instanceof ModifiableModelAwareDataHolder) 556 { 557 ((ModifiableModelAwareDataHolder) dataHolder).setValue(dataPath, null); 558 } 559 } 560 } 561 else if (value instanceof ContentValue[]) 562 { 563 List<ContentValue> newValues = new ArrayList<>(); 564 for (ContentValue contentValue : (ContentValue[]) value) 565 { 566 if (contentValue.getContentIfExists().isEmpty()) 567 { 568 result.computeIfAbsent(dataPath, __ -> new ArrayList<>()).add(contentValue.getContentId()); 569 } 570 else if (fix) 571 { 572 newValues.add(contentValue); 573 } 574 } 575 if (fix && dataHolder instanceof ModifiableModelAwareDataHolder) 576 { 577 ((ModifiableModelAwareDataHolder) dataHolder).setValue(dataPath, newValues.toArray(ContentValue[]::new)); 578 } 579 } 580 } 581 return result; 582 } 583 584 /** 585 * Find any broken invert relation in a content attributes. 586 * The invert relation is considered as broken if the referenced content does not reference the first one by the attribute with the invert relation path 587 * This check does not take nonexistent referenced contents into account. First call the {@link ContentDataHelper#checkBrokenReferences(ModelAwareDataHolder, boolean)} method 588 * @param content the content to inspect. 589 * @param fix if <code>true</code>, and the referenced contents are modifiable, broken invert relations will be fixed by adding the relation on the referenced content 590 * if the referenced content is referencing another content and the attribute is single (and not in a repeater), the third content will be modified too, to remove the relation to the second content. 591 * Warning: if modifications are made on some contents, the modifications won't be saved and the workflows won't change 592 * @return All broken invert relations in a collection of {@link ReferencedContents}. 593 * Call {@link ReferencedContents#getAddedContents()} to get all contents referenced by the given content that does not reference it in return 594 * Call {@link ReferencedContents#getThirdPartyContents()} to get contents referenced by content in added contents that reference it in return 595 */ 596 public static Collection<ReferencedContents> checkBrokenInvertRelations(Content content, boolean fix) 597 { 598 // Search for all content attribute's values 599 Map<String, Object> contentAttributes = DataHolderHelper.findItemsByType(content, ModelItemTypeConstants.CONTENT_ELEMENT_TYPE_ID); 600 601 // Collect broken invert relations 602 Collection<ReferencedContents> brokenInvertRelations = new ArrayList<>(); 603 for (Map.Entry<String, Object> entry : contentAttributes.entrySet()) 604 { 605 String dataPath = entry.getKey(); 606 Object value = entry.getValue(); 607 ContentAttributeDefinition definition = (ContentAttributeDefinition) content.getDefinition(dataPath); 608 609 // Continue check only on content attributes with an invert relation path 610 if (StringUtils.isNotBlank(definition.getInvertRelationPath())) 611 { 612 Map<ContentValue, List<String>> contentsToAdd = new HashMap<>(); 613 Map<ContentValue, ContentValue> thirdPartyContents = new HashMap<>(); 614 615 if (value instanceof ContentValue) 616 { 617 Pair<Boolean, Optional<ContentValue>> isBroken = _isInvertRelationBroken(content, (ContentValue) value, definition); 618 if (isBroken.getLeft()) 619 { 620 contentsToAdd.put((ContentValue) value, List.of(dataPath)); 621 isBroken.getRight() 622 .ifPresent(v -> thirdPartyContents.put((ContentValue) value, v)); 623 } 624 } 625 else if (value instanceof ContentValue[]) 626 { 627 for (ContentValue contentValue : (ContentValue[]) value) 628 { 629 Pair<Boolean, Optional<ContentValue>> isBroken = _isInvertRelationBroken(content, contentValue, definition); 630 if (isBroken.getLeft()) 631 { 632 contentsToAdd.computeIfAbsent(contentValue, __ -> new ArrayList<>()).add(dataPath); 633 isBroken.getRight() 634 .ifPresent(v -> thirdPartyContents.put(contentValue, v)); 635 } 636 } 637 } 638 639 // Add a ReferencedContents object if there is at least one broken relation 640 // No need to check the third part content, this map can't have entries if the first one is empty 641 if (!contentsToAdd.isEmpty()) 642 { 643 ReferencedContents brokenInvertRelation = new ReferencedContents(definition, contentsToAdd, Map.of(), thirdPartyContents); 644 brokenInvertRelations.add(brokenInvertRelation); 645 } 646 } 647 } 648 649 if (fix) 650 { 651 Map<String, ModifiableContent> modifiedContents = new HashMap<>(); 652 653 for (ReferencedContents brokenInvertRelation : brokenInvertRelations) 654 { 655 // Add relation on contents referenced by the given one 656 String invertRelationPath = brokenInvertRelation.getDefinition().getInvertRelationPath(); 657 modifiedContents.putAll(manageInvertRelations(invertRelationPath, brokenInvertRelation.getAddedContents(), content.getId(), ContentDataHelper::addInvertRelation, modifiedContents, Map.of())); 658 659 // Remove relations on third party contents 660 Map<ContentValue, Collection<String>> thirdPartyContents = new HashMap<>(); 661 for (Map.Entry<ContentValue, ContentValue> thirdPartyContent : brokenInvertRelation.getThirdPartyContents().entrySet()) 662 { 663 thirdPartyContents.computeIfAbsent(thirdPartyContent.getValue(), __ -> new ArrayList<>()).add(thirdPartyContent.getKey().getContentId()); 664 } 665 modifiedContents.putAll(manageInvertRelations(brokenInvertRelation.getDefinition().getPath(), thirdPartyContents, ContentDataHelper::removeInvertRelation, modifiedContents, Map.of())); 666 } 667 } 668 669 return brokenInvertRelations; 670 } 671 672 /** 673 * Check if the invert relation between the given contents is broken 674 * @param source the source content of the invert relation 675 * @param destinationValue the destination content of the invert relation 676 * @param definition the definition concerned by the checked invert relation 677 * @return a {@link Pair} containing the result of the check ({@link Boolean} part left) and an optional third part content, if the relation is broken and the destination content references another content in a single attribute that should be modified 678 */ 679 private static Pair<Boolean, Optional<ContentValue>> _isInvertRelationBroken(Content source, ContentValue destinationValue, ContentAttributeDefinition definition) 680 { 681 Boolean isBroken = Boolean.FALSE; 682 Optional<ContentValue> thirdPartContent = Optional.empty(); 683 684 // Get the target content - ignore nonexistent contents, the checkBrokenReferences dealt with it 685 Optional<? extends Content> optDestination = destinationValue.getContentIfExists(); 686 if (optDestination.isPresent()) 687 { 688 // Get the value of the target content's attribute 689 Content destination = optDestination.get(); 690 Object value = destination.getValue(definition.getInvertRelationPath(), true); 691 if (value == null) 692 { 693 isBroken = true; 694 } 695 else if (value instanceof ContentValue) 696 { 697 // If the value does not correspond to the current data holder 698 if (!((ContentValue) value).getContentId().equals(source.getId())) 699 { 700 isBroken = true; 701 702 // If the value of the destination is in relation to the destination too, this third part content will have to be modified 703 Object thirdPartValue = ((ContentValue) value).getValue(definition.getPath(), true); 704 if (thirdPartValue instanceof ContentValue) 705 { 706 if (((ContentValue) thirdPartValue).getContentId().equals(destination.getId())) 707 { 708 thirdPartContent = Optional.of((ContentValue) value); 709 } 710 } 711 else if (thirdPartValue instanceof ContentValue[]) 712 { 713 for (ContentValue thridPartSingleValue : (ContentValue[]) thirdPartValue) 714 { 715 if (thridPartSingleValue.getContentId().equals(destination.getId())) 716 { 717 thirdPartContent = Optional.of((ContentValue) value); 718 break; 719 } 720 } 721 } 722 } 723 } 724 else if (value instanceof ContentValue[]) 725 { 726 // Search for the source content in the values of the destination 727 boolean foundSource = false; 728 for (ContentValue contentValue : (ContentValue[]) value) 729 { 730 if (contentValue.getContentId().equals(source.getId())) 731 { 732 foundSource = true; 733 break; 734 } 735 } 736 737 isBroken = Boolean.valueOf(!foundSource); 738 } 739 } 740 741 return new ImmutablePair<>(isBroken, thirdPartContent); 742 } 743 744 /** 745 * Manages the invert relations concerned by the given path, through the given {@link InvertRelationManager} 746 * @param invertRelationPath the concerned invert relation path 747 * @param referencedContents a {@link Set} containing the referenced contents to manage (add or remove the relation) 748 * @param referencingContentId the id of the content referencing the given contents 749 * @param invertRelationManager the {@link InvertRelationManager} to use (to add or remove the invert relations) 750 * @param alreadyModifiedContents a {@link Map} of contents (indexed by their identifiers) that have already been modified. 751 * This map will be used to initialize the returned map and to search for contents that have already been resolved (to resolve each content only once, even if there are several modifications on a same content) 752 * @param externalizableDataContext the context {@link Map} that is used to determine if a data is externalizable 753 * @return a {@link Map} containing the contents (indexed by their identifiers) that have been modified by this call and the ones that have already been modified 754 */ 755 public static Map<String, ModifiableContent> manageInvertRelations(String invertRelationPath, Set<ContentValue> referencedContents, String referencingContentId, InvertRelationManager invertRelationManager, Map<String, ModifiableContent> alreadyModifiedContents, Map<String, Object> externalizableDataContext) 756 { 757 Map<ContentValue, Collection<String>> referencedContentsWithReferencing = referencedContents.stream() 758 .collect(Collectors.toMap(value -> value, value -> Set.of(referencingContentId))); 759 760 return manageInvertRelations(invertRelationPath, referencedContentsWithReferencing, invertRelationManager, alreadyModifiedContents, externalizableDataContext); 761 } 762 763 /** 764 * Manages the invert relations concerned by the given path, through the given {@link InvertRelationManager} 765 * @param invertRelationPath the concerned invert relation path 766 * @param referencedContents a {@link Map} containing the referenced contents to manage (add or remove the relation) and the id of the content referencing this content 767 * @param invertRelationManager the {@link InvertRelationManager} to use (to add or remove the invert relations) 768 * @param alreadyModifiedContents a {@link Map} of contents (indexed by their identifiers) that have already been modified. 769 * This map will be used to initialize the returned map and to search for contents that have already been resolved (to resolve each content only once, even if there are several modifications on a same content) 770 * @param externalizableDataContext the context {@link Map} that is used to determine if a data is externalizable 771 * @return a {@link Map} containing the contents (indexed by their identifiers) that have been modified by this call and the ones that have already been modified 772 */ 773 public static Map<String, ModifiableContent> manageInvertRelations(String invertRelationPath, Map<ContentValue, Collection<String>> referencedContents, InvertRelationManager invertRelationManager, Map<String, ModifiableContent> alreadyModifiedContents, Map<String, Object> externalizableDataContext) 774 { 775 Map<String, ModifiableContent> allModifiedContents = new HashMap<>(alreadyModifiedContents); 776 777 for (ContentValue referencedContent : referencedContents.keySet()) 778 { 779 String contentId = referencedContent.getContentId(); 780 Optional<ModifiableContent> optContent = allModifiedContents.containsKey(contentId) 781 ? Optional.of(allModifiedContents.get(contentId)) 782 : referencedContent.getContentIfExists(); 783 784 if (optContent.isPresent()) 785 { 786 ModifiableContent content = optContent.get(); 787 788 ModelItem modelItem = content.getDefinition(invertRelationPath); 789 ValueContext valueContext = ValueContext.newInstance(); 790 if (DataHolderHelper.getExternalizableDataProviderExtensionPoint().isDataExternalizable(content, modelItem)) 791 { 792 if (ExternalizableDataStatus.EXTERNAL.equals(content.getStatus(invertRelationPath))) 793 { 794 throw new IllegalStateException("Unable to manage the invert relation on distant content '" + content + "', the data at path '" + invertRelationPath + "' is external."); 795 } 796 else 797 { 798 valueContext.withStatus(ExternalizableDataStatus.LOCAL); 799 } 800 } 801 802 if (invertRelationManager.manageInvertRelation(content, invertRelationPath, referencedContents.get(referencedContent), valueContext)) 803 { 804 allModifiedContents.put(contentId, content); 805 } 806 } 807 } 808 809 return allModifiedContents; 810 } 811 812 /** 813 * Adds the invert relation to the given {@link DataHolder} 814 * @param dataHolder the data holder where to add the invert relation 815 * @param invertRelationPath the path of the invert relation 816 * @param referencingContentIds the id of the contents that reference the data holder 817 * @param context the value's context 818 * @return <code>true</code> if the given data holder has been modified, <code>false</code> otherwise 819 */ 820 public static boolean addInvertRelation(ModifiableModelAwareDataHolder dataHolder, String invertRelationPath, Collection<String> referencingContentIds, ValueContext context) 821 { 822 String[] pathSegments = StringUtils.split(invertRelationPath, ModelItem.ITEM_PATH_SEPARATOR); 823 String dataName = pathSegments[0]; 824 825 if (pathSegments.length == 1) 826 { 827 ContentAttributeDefinition invertRelationDefinition = (ContentAttributeDefinition) dataHolder.getDefinition(invertRelationPath); 828 if (invertRelationDefinition.isMultiple()) 829 { 830 List<String> newValues = new ArrayList<>(); 831 832 if (DataHolderHelper.hasValue(dataHolder, invertRelationPath, context)) 833 { 834 ContentValue[] oldValues = DataHolderHelper.getValue(dataHolder, invertRelationPath, context); 835 836 newValues = Arrays.stream(oldValues) 837 .map(ContentValue::getContentId) 838 .collect(Collectors.toList()); 839 } 840 841 newValues.addAll(referencingContentIds); 842 DataHolderHelper.setValue(dataHolder, invertRelationPath, newValues.toArray(new String[newValues.size()]), context); 843 return true; 844 } 845 else 846 { 847 assert referencingContentIds.size() == 1; 848 DataHolderHelper.setValue(dataHolder, invertRelationPath, referencingContentIds.iterator().next(), context); 849 return true; 850 } 851 } 852 else 853 { 854 ModelItem modelItem = dataHolder.getDefinition(dataName); 855 String subInvertRelationPath = StringUtils.join(pathSegments, ModelItem.ITEM_PATH_SEPARATOR, 1, pathSegments.length); 856 if (modelItem instanceof RepeaterDefinition) 857 { 858 ModifiableModelAwareRepeaterEntry repeaterEntry = dataHolder.getRepeater(dataName, true).addEntry(); 859 return addInvertRelation(repeaterEntry, subInvertRelationPath, referencingContentIds, context); 860 } 861 else 862 { 863 ModifiableModelAwareComposite composite = dataHolder.getComposite(dataName, true); 864 return addInvertRelation(composite, subInvertRelationPath, referencingContentIds, context); 865 } 866 } 867 } 868 869 /** 870 * Removes the invert relation to the given {@link DataHolder} 871 * @param referencedContent the content where to remove the invert relation 872 * @param invertRelationPath the path of the invert relation 873 * @param referencingContentIds the id of the contents that do not reference the given content anymore 874 * @param context the value's context 875 * @return <code>true</code> if the referenced content has been modified, <code>false</code> otherwise 876 */ 877 public static boolean removeInvertRelation(ModifiableContent referencedContent, String invertRelationPath, Collection<String> referencingContentIds, ValueContext context) 878 { 879 ContentAttributeDefinition invertRelationDefinition = (ContentAttributeDefinition) referencedContent.getDefinition(invertRelationPath); 880 if (invertRelationDefinition.isMultiple()) 881 { 882 if (DataHolderHelper.hasValue(referencedContent, invertRelationPath, context)) 883 { 884 ContentValue[] oldValues = DataHolderHelper.getValue(referencedContent, invertRelationPath, context); 885 886 String[] newValues = Arrays.stream(oldValues) 887 .map(ContentValue::getContentId) 888 .filter(id -> !referencingContentIds.contains(id)) 889 .toArray(size -> new String[size]); 890 891 DataHolderHelper.setValue(referencedContent, invertRelationPath, newValues, context); 892 return oldValues.length > newValues.length; 893 } 894 else 895 { 896 return false; 897 } 898 } 899 else 900 { 901 return _removeSingleInvertRelation(referencedContent, invertRelationPath, referencingContentIds, context); 902 } 903 } 904 905 private static boolean _removeSingleInvertRelation(ModifiableModelAwareDataHolder dataHolder, String invertRelationPath, Collection<String> referencingContentIds, ValueContext context) 906 { 907 String[] pathSegments = StringUtils.split(invertRelationPath, ModelItem.ITEM_PATH_SEPARATOR); 908 String dataName = pathSegments[0]; 909 910 if (pathSegments.length == 1) 911 { 912 ContentValue value = DataHolderHelper.getValue(dataHolder, dataName, context); 913 if (value != null && referencingContentIds.contains(value.getContentId())) 914 { 915 DataHolderHelper.removeValue(dataHolder, dataName, context); 916 return true; 917 } 918 else 919 { 920 return false; 921 } 922 } 923 else 924 { 925 ModelItem modelItem = dataHolder.getDefinition(dataName); 926 String subInvertRelationPath = StringUtils.join(pathSegments, ModelItem.ITEM_PATH_SEPARATOR, 1, pathSegments.length); 927 if (modelItem instanceof RepeaterDefinition) 928 { 929 boolean modified = false; 930 931 ModifiableModelAwareRepeater repeater = dataHolder.getRepeater(dataName); 932 if (repeater != null) 933 { 934 for (ModifiableModelAwareRepeaterEntry repeaterEntry : repeater.getEntries()) 935 { 936 modified = _removeSingleInvertRelation(repeaterEntry, subInvertRelationPath, referencingContentIds, context) || modified; 937 } 938 } 939 940 return modified; 941 } 942 else 943 { 944 ModifiableModelAwareComposite composite = dataHolder.getComposite(dataName); 945 return _removeSingleInvertRelation(composite, subInvertRelationPath, referencingContentIds, context); 946 } 947 } 948 } 949 950 /** 951 * Invert relation manager (to add or remove a relation on a content 952 */ 953 @FunctionalInterface 954 public interface InvertRelationManager 955 { 956 /** 957 * Manages the invert relation to the given {@link DataHolder} 958 * @param referencedContent the content where to manage the invert relation 959 * @param invertRelationPath the path of the invert relation 960 * @param referencingContentIds the id of the contents that reference.d the given content 961 * @param context the value's context 962 * @return <code>true</code> if the referenced content has been modified, <code>false</code> otherwise 963 */ 964 public boolean manageInvertRelation(ModifiableContent referencedContent, String invertRelationPath, Collection<String> referencingContentIds, ValueContext context); 965 } 966}