#22857 refreshing block editor contentlet reference

dotCMS/src/integration-test/java/com/dotcms/MainSuite.java

@@ -14,6 +14,7 @@
 import com.dotcms.content.model.hydration.MetadataDelegateTest;
 import com.dotcms.contenttype.business.ContentTypeInitializerTest;
 import com.dotcms.contenttype.business.DotAssetBaseTypeToContentTypeStrategyImplTest;
+import com.dotcms.contenttype.business.StoryBlockAPITest;
 import com.dotcms.contenttype.test.DotAssetAPITest;
 import com.dotcms.csspreproc.CSSCacheTest;
 import com.dotcms.dotpubsub.PostgresPubSubImplTest;
@@ -570,7 +571,8 @@
         PaginatedContentletsIntegrationTest.class,
         Task220822CreateVariantTableTest.class,
         Task220829CreateExperimentsTableTest.class,
-        StoryBlockTest.class
+        StoryBlockTest.class,
+        StoryBlockAPITest.class
 })
 public class MainSuite {
 

dotCMS/src/integration-test/java/com/dotcms/contenttype/business/StoryBlockAPITest.java

@@ -0,0 +1,185 @@
+package com.dotcms.contenttype.business;
+
+import com.dotcms.IntegrationTestBase;
+import com.dotcms.content.business.json.ContentletJsonHelper;
+import com.dotcms.contenttype.model.type.ContentType;
+import com.dotcms.datagen.ContentletDataGen;
+import com.dotcms.util.IntegrationTestInitService;
+import com.dotmarketing.business.APILocator;
+import com.dotmarketing.exception.DotDataException;
+import com.dotmarketing.exception.DotSecurityException;
+import com.dotmarketing.portlets.contentlet.model.Contentlet;
+import com.fasterxml.jackson.core.JsonProcessingException;
+import com.liferay.util.StringPool;
+import io.vavr.Tuple2;
+import io.vavr.control.Try;
+import org.junit.Assert;
+import org.junit.BeforeClass;
+import org.junit.Test;
+
+import java.util.LinkedHashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Optional;
+
+/**
+ * Test for {@link StoryBlockAPI}
+ * @author jsanca
+ */
+public class StoryBlockAPITest extends IntegrationTestBase {
+
+    private static final String JSON =
+                    "{\n" +
+                    "            \"type\":\"doc\",\n" +
+                    "            \"content\":[\n" +
+                    "               {\n" +
+                    "                  \"type\":\"horizontalRule\"\n" +
+                    "               },\n" +
+                    "               {\n" +
+                    "                  \"type\":\"heading\",\n" +
+                    "                  \"content\":[\n" +
+                    "                     {\n" +
+                    "                        \"text\":\"Heading\",\n" +
+                    "                        \"type\":\"text\"\n" +
+                    "                     },\n" +
+                    "                     {\n" +
+                    "                        \"marks\":[\n" +
+                    "                           {\n" +
+                    "                              \"type\":\"italic\"\n" +
+                    "                           }\n" +
+                    "                        ],\n" +
+                    "                        \"text\":\" 1\",\n" +
+                    "                        \"type\":\"text\"\n" +
+                    "                     }\n" +
+                    "                  ],\n" +
+                    "                  \"attrs\":{\n" +
+                    "                     \"textAlign\":\"left\",\n" +
+                    "                     \"level\":1\n" +
+                    "                  }\n" +
+                    "               },\n" +
+                    "               {\n" +
+                    "                  \"type\":\"paragraph\",\n" +
+                    "                  \"content\":[\n" +
+                    "                     {\n" +
+                    "                        \"text\":\"Paragraph\",\n" +
+                    "                        \"type\":\"text\"\n" +
+                    "                     },\n" +
+                    "                     {\n" +
+                    "                        \"marks\":[\n" +
+                    "                           {\n" +
+                    "                              \"type\":\"bold\"\n" +
+                    "                           }\n" +
+                    "                        ],\n" +
+                    "                        \"text\":\" yeah\",\n" +
+                    "                        \"type\":\"text\"\n" +
+                    "                     }\n" +
+                    "                  ],\n" +
+                    "                  \"attrs\":{\n" +
+                    "                     \"textAlign\":\"left\"\n" +
+                    "                  }\n" +
+                    "               }\n" +
+                    "            ]\n" +
+                    "         }";
+
+
+
+    @BeforeClass
+    public static void prepare() throws Exception {
+        //Setting web app environment
+        IntegrationTestInitService.getInstance().init();
+    }
+
+    /**
+     * Method to test: {@link StoryBlockAPI#refreshStoryBlockValueReferences(Object)}
+     * Given Scenario: This will create a story block contentlet, adds a rich content and retrieve the json.
+     * Then, will update the rich content previously added, the story block contentlet should reflect the new rich text changed.
+     * ExpectedResult: The new json will reflect the rich text changes
+     *
+     */
+    @Test
+    public void test_refresh_references() throws DotDataException, DotSecurityException, JsonProcessingException {
+
+        //1) create a rich text contentlet with some initial values
+        final ContentType contentTypeRichText = APILocator.getContentTypeAPI(APILocator.systemUser()).find("webPageContent");
+        final Contentlet richTextContentlet   = new ContentletDataGen(contentTypeRichText).setProperty("title","Title1").setProperty("body","Body1").nextPersisted();
+
+        // 2) add the contentlet to the static story block created previously
+        final Object newStoryBlockJson        = APILocator.getStoryBlockAPI().addContentlet(JSON, richTextContentlet);
+
+        // 3) convert the json to map, to start the test
+        final Map    newStoryBlockMap         = ContentletJsonHelper.INSTANCE.get().objectMapper()
+                                                    .readValue(Try.of(() -> newStoryBlockJson.toString())
+                                                    .getOrElse(StringPool.BLANK), LinkedHashMap.class);
+
+        Assert.assertNotNull(newStoryBlockMap);
+        final List contentList = (List) newStoryBlockMap.get("content");
+        final Optional<Object> firstContentletMap = contentList.stream()
+                .filter(content -> "dotContent".equals(Map.class.cast(content).get("type"))).findFirst();
+
+        Assert.assertTrue(firstContentletMap.isPresent());
+        final Map contentletMap = (Map) Map.class.cast(Map.class.cast(firstContentletMap.get()).get(StoryBlockAPI.ATTRS_KEY)).get(StoryBlockAPI.DATA_KEY);
+        Assert.assertEquals(contentletMap.get("identifier"), richTextContentlet.getIdentifier());
+        Assert.assertEquals(contentletMap.get("title"), richTextContentlet.getStringProperty("title"));
+        Assert.assertEquals(contentletMap.get("body"),  richTextContentlet.getStringProperty("body"));
+
+        // 4) checkout/publish the contentlet in order to do new changes
+        final Contentlet newRichTextContentlet = APILocator.getContentletAPI().checkout(richTextContentlet.getInode(), APILocator.systemUser(), false);
+        newRichTextContentlet.setProperty("title","Title2");
+        newRichTextContentlet.setProperty("body","Body2");
+        APILocator.getContentletAPI().publish(
+                APILocator.getContentletAPI().checkin(newRichTextContentlet, APILocator.systemUser(), false), APILocator.systemUser(), false);
+
+        // 5) ask for refreshing references, the new changes of the rich text contentlet should be reflected on the json
+        final Tuple2<Boolean, Object> refreshResult = APILocator.getStoryBlockAPI().refreshStoryBlockValueReferences(newStoryBlockJson);
+
+        // 6) check if the results are ok.
+        Assert.assertTrue(refreshResult._1());
+        Assert.assertNotNull(refreshResult._2());
+        final Map    refreshedStoryBlockMap         = ContentletJsonHelper.INSTANCE.get().objectMapper()
+                .readValue(Try.of(() -> refreshResult._2().toString())
+                        .getOrElse(StringPool.BLANK), LinkedHashMap.class);
+        final List refreshedContentList = (List) refreshedStoryBlockMap.get("content");
+        final Optional<Object> refreshedfirstContentletMap = refreshedContentList.stream()
+                .filter(content -> "dotContent".equals(Map.class.cast(content).get("type"))).findFirst();
+
+        Assert.assertTrue(refreshedfirstContentletMap.isPresent());
+        final Map refreshedContentletMap = (Map) Map.class.cast(Map.class.cast(refreshedfirstContentletMap.get()).get(StoryBlockAPI.ATTRS_KEY)).get(StoryBlockAPI.DATA_KEY);
+        Assert.assertEquals(refreshedContentletMap.get("identifier"), newRichTextContentlet.getIdentifier());
+        Assert.assertEquals("Title2", newRichTextContentlet.getStringProperty("title"));
+        Assert.assertEquals("Body2",  newRichTextContentlet.getStringProperty("body"));
+    }
+
+    /**
+     * Method to test: {@link StoryBlockAPI#getDependencies(Object)}
+     * Given Scenario: Creates a story block and adds 3 contentlets
+     * ExpectedResult: The contentlets added should be retrieved
+     *
+     */
+    @Test
+    public void test_get_dependencies() throws DotDataException, DotSecurityException, JsonProcessingException {
+
+        //1) create a rich text contentlets with some initial values
+        final ContentType contentTypeRichText = APILocator.getContentTypeAPI(APILocator.systemUser()).find("webPageContent");
+        final Contentlet richTextContentlet1   = new ContentletDataGen(contentTypeRichText).setProperty("title","Title1").setProperty("body","Body1").nextPersisted();
+        final Contentlet richTextContentlet2   = new ContentletDataGen(contentTypeRichText).setProperty("title","Title1").setProperty("body","Body1").nextPersisted();
+        final Contentlet richTextContentlet3   = new ContentletDataGen(contentTypeRichText).setProperty("title","Title1").setProperty("body","Body1").nextPersisted();
+
+        // 2) adds the contentlets to the static story block created previously
+        final Object newStoryBlockJson1        = APILocator.getStoryBlockAPI().addContentlet(JSON, richTextContentlet1);
+        final Object newStoryBlockJson2        = APILocator.getStoryBlockAPI().addContentlet(newStoryBlockJson1, richTextContentlet2);
+        final Object newStoryBlockJson3        = APILocator.getStoryBlockAPI().addContentlet(newStoryBlockJson2, richTextContentlet3);
+
+        // 3) convert the json to map, to start the test
+        final Map    newStoryBlockMap         = ContentletJsonHelper.INSTANCE.get().objectMapper()
+                .readValue(Try.of(() -> newStoryBlockJson3.toString())
+                        .getOrElse(StringPool.BLANK), LinkedHashMap.class);
+
+        Assert.assertNotNull(newStoryBlockMap);
+        final List<String> contentletIdList = APILocator.getStoryBlockAPI().getDependencies(newStoryBlockJson3);
+        Assert.assertNotNull(contentletIdList);
+        Assert.assertEquals(3, contentletIdList.size());
+        Assert.assertTrue(contentletIdList.contains(richTextContentlet1.getIdentifier()));
+        Assert.assertTrue(contentletIdList.contains(richTextContentlet2.getIdentifier()));
+        Assert.assertTrue(contentletIdList.contains(richTextContentlet3.getIdentifier()));
+    }
+}

dotCMS/src/main/java/com/dotcms/content/elasticsearch/business/ESContentFactoryImpl.java

@@ -86,6 +86,7 @@
 import com.google.common.collect.Lists;
 import com.google.common.primitives.Ints;
 import com.liferay.portal.model.User;
+import io.vavr.Tuple2;
 import io.vavr.control.Try;
 import java.io.Serializable;
 import java.sql.Connection;
@@ -855,7 +856,7 @@ protected Contentlet find(final String inode) throws ElasticsearchException, Dot
             if (CACHE_404_CONTENTLET.equals(contentlet.getInode())) {
                 return null;
             }
-            return contentlet;
+            return processContentletCache(contentlet);
         }
 
         final Optional<Contentlet> dbContentlet = this.findInDb(inode);
@@ -870,6 +871,26 @@ protected Contentlet find(final String inode) throws ElasticsearchException, Dot
 
     }
 
+    /*
+     * When a contentlet is being cached, may need some process since the value may be invalid.
+     * One of the things to check would be the contentlet references on the story block, if the contentlet
+     * has a story block field and contentlets referred in it, the code checks if the contentlets have been
+     * changed, if so updates the content and stores the json updated again to the contentlet
+     */
+    private Contentlet processContentletCache (final Contentlet contentletCached) {
+
+        final Tuple2<Boolean, Contentlet> storyBlockRefreshedResult =
+                APILocator.getStoryBlockAPI().refreshReferences(contentletCached);
+
+        if (storyBlockRefreshedResult._1()) {
+
+            contentletCache.add(storyBlockRefreshedResult._2().getInode(), storyBlockRefreshedResult._2());
+            return storyBlockRefreshedResult._2();
+        }
+
+        return contentletCached;
+    }
+
 	@Override
 	protected List<Contentlet> findAllCurrent() throws DotDataException {
 		throw new DotDataException("findAllCurrent() will blow your stack off, use findAllCurrent(offset, limit)");

dotCMS/src/main/java/com/dotcms/contenttype/business/StoryBlockAPI.java

@@ -0,0 +1,67 @@
+package com.dotcms.contenttype.business;
+
+import com.dotmarketing.portlets.contentlet.model.Contentlet;
+import com.google.common.collect.ImmutableSet;
+import io.vavr.Tuple2;
+
+import java.util.List;
+import java.util.Set;
+
+/**
+ * Api to handle dependencies, references and so for the StoryBlock (content editor)
+ * @author jsanca
+ */
+public interface StoryBlockAPI {
+
+    String CONTENT_KEY = "content";
+    String TYPE_KEY = "type";
+    String ATTRS_KEY = "attrs";
+    String DATA_KEY = "data";
+    String IDENTIFIER_KEY = "identifier";
+    String INODE_KEY = "inode";
+    String LANGUAGE_ID_KEY = "languageId";
+
+    /**
+     * Encapsulates the allowed types for contentlets on the story block
+     */
+    Set<String> allowedTypes = new ImmutableSet.Builder<String>().add("dotContent","dotImage").build();
+
+    /**
+     * Analyzed all {@link com.dotcms.contenttype.model.field.StoryBlockField} fields, refreshing all contentlet which
+     * inode is different to the live inode on the system.
+     * @param contentlet {@link Contentlet} to refresh
+     * @return Contentlet content refreshed
+     */
+    Tuple2<Boolean, Contentlet> refreshReferences(final Contentlet contentlet);
+
+    /**
+     * Refresh the story block references for a story block json (The argument storyBlockValue will be converted to string and parse as json)
+     * @param storyBlockValue Object
+     * @return Tuple2 boolean if there was something to refresh, the object is the new object refreshed; if not anything to refresh return the same object sent as an argument
+     */
+    Tuple2<Boolean, Object> refreshStoryBlockValueReferences(final Object storyBlockValue);
+
+    /**
+     * For each {@link com.dotcms.contenttype.model.field.StoryBlockField} field, retrieve contentlet ids referrer on the
+     * story block json.
+     * @param contentlet {@link Contentlet}
+     * @return List of identifier (empty list if not any contentlet)
+     */
+    List<String> getDependencies (final Contentlet contentlet);
+
+    /**
+     * Get the dependencies for a story block json /Users/jsanca/gitsources/new-core2/core/dotCMS/src/main/java/com/dotcms/contenttype/business/StoryBlockAPI.java
+     * @param storyBlockValue Object
+     * @return List of contentlets on the story block referrer
+     */
+    List<String> getDependencies (final Object storyBlockValue);
+
+    /**
+     * Adds a contentlet to the story block value
+     * @param storyBlockValue {@link Object}
+     * @param contentlet {@link Contentlet}
+     * @return Object
+     */
+    Object addContentlet(final Object storyBlockValue, final Contentlet contentlet);
+
+}