update respective index with the assets (#13843)

* update respective index with the assets

* checkstyle

* addressing comments

* add listorempty

openmetadata-service/src/main/java/org/openmetadata/service/jdbi3/DataProductRepository.java

@@ -19,11 +19,15 @@
 import static org.openmetadata.service.util.EntityUtil.entityReferenceMatch;
 
 import java.util.ArrayList;
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
 import lombok.extern.slf4j.Slf4j;
 import org.jdbi.v3.sqlobject.transaction.Transaction;
+import org.openmetadata.schema.EntityInterface;
 import org.openmetadata.schema.entity.domains.DataProduct;
 import org.openmetadata.schema.type.EntityReference;
+import org.openmetadata.schema.type.Include;
 import org.openmetadata.schema.type.Relationship;
 import org.openmetadata.service.Entity;
 import org.openmetadata.service.resources.domains.DataProductResource;
@@ -91,6 +95,18 @@ public void restorePatchAttributes(DataProduct original, DataProduct updated) {
     updated.withDomain(original.getDomain()); // Domain can't be changed
   }
 
+  @Override
+  protected void postUpdate(DataProduct original, DataProduct updated) {
+    super.postUpdate(original, updated);
+    Map<String, EntityReference> assetsMap = new HashMap<>();
+    listOrEmpty(original.getAssets()).forEach(asset -> assetsMap.put(asset.getId().toString(), asset));
+    listOrEmpty(updated.getAssets()).forEach(asset -> assetsMap.put(asset.getId().toString(), asset));
+    for (EntityReference assetRef : assetsMap.values()) {
+      EntityInterface asset = Entity.getEntity(assetRef, "*", Include.ALL);
+      searchRepository.updateEntity(asset);
+    }
+  }
+
   public class DataProductUpdater extends EntityUpdater {
     public DataProductUpdater(DataProduct original, DataProduct updated, Operation operation) {
       super(original, updated, operation);