Merge pull request #224 from overture-stack/develop

Release Candidate 3.11.0

Author: Buwujiu

.mvn/maven.config

@@ -1,3 +1,3 @@
--Drevision=3.10.0
+-Drevision=3.11.0
 -Dsha1=
 -Dchangelist=-SNAPSHOT

maestro-app/src/main/java/bio/overture/maestro/app/infra/adapter/outbound/indexing/elasticsearch/AnalysisCentricElasticSearchAdapter.java

@@ -146,17 +146,24 @@ private List<AnalysisCentricDocument> getAnalysisCentricDocuments(
   private UpdateRequest mapAnalysisToUpsertRepositoryQuery(
       AnalysisCentricDocument analysisCentricDocument) {
     val mapper = new ObjectMapper().setPropertyNamingStrategy(PropertyNamingStrategy.SNAKE_CASE);
+
     val paramsBuilder = new HashMap<String, Object>();
     paramsBuilder.put(
         "repository",
         mapper.convertValue(analysisCentricDocument.getRepositories().get(0), Map.class));
     paramsBuilder.put("analysis_state", analysisCentricDocument.getAnalysisState());
     paramsBuilder.put("updated_at", getDateIso(analysisCentricDocument.getUpdatedAt()));
-    if (analysisCentricDocument.getPublishedAt()
-        != null) { // Nullable as may not have been published
+
+    if (analysisCentricDocument.getPublishedAt() != null) {
+      // Nullable as may not have been published
       paramsBuilder.put("published_at", getDateIso(analysisCentricDocument.getPublishedAt()));
     }
 
+    if (analysisCentricDocument.getFirstPublishedAt() != null) {
+      paramsBuilder.put(
+          "first_published_at", getDateIso(analysisCentricDocument.getFirstPublishedAt()));
+    }
+
     val parameters = unmodifiableMap(paramsBuilder);
     val inline = getInline(parameters);
 

maestro-app/src/main/java/bio/overture/maestro/app/infra/adapter/outbound/indexing/elasticsearch/FileCentricElasticSearchAdapter.java

@@ -277,12 +277,19 @@ private UpdateRequest mapFileToUpsertRepositoryQuery(FileCentricDocument fileCen
         "repository", mapper.convertValue(fileCentricDocument.getRepositories().get(0), Map.class));
     paramsBuilder.put("analysis_state", fileCentricDocument.getAnalysis().getAnalysisState());
     paramsBuilder.put("updated_at", getDateIso(fileCentricDocument.getAnalysis().getUpdatedAt()));
-    if (fileCentricDocument.getAnalysis().getPublishedAt()
-        != null) { // Nullable as may not have been published
+
+    if (fileCentricDocument.getAnalysis().getPublishedAt() != null) {
+      // Nullable as may not have been published
       paramsBuilder.put(
           "published_at", getDateIso(fileCentricDocument.getAnalysis().getPublishedAt()));
     }
 
+    if (fileCentricDocument.getAnalysis().getFirstPublishedAt() != null) {
+      paramsBuilder.put(
+          "first_published_at",
+          getDateIso(fileCentricDocument.getAnalysis().getFirstPublishedAt()));
+    }
+
     val parameters = unmodifiableMap(paramsBuilder);
     val inline = getInlineForFile(parameters);
 

maestro-app/src/main/java/bio/overture/maestro/app/infra/adapter/outbound/indexing/elasticsearch/SearchAdapterHelper.java

@@ -211,7 +211,8 @@ public static Script getInline(Map<String, Object> parameters) {
             "if (!ctx._source.repositories.contains(params.repository)) { ctx._source.repositories.add(params.repository) } \n"
                 + "ctx._source.analysis_state = params.analysis_state;\n"
                 + "ctx._source.updated_at = ZonedDateTime.parse(params.updated_at).toInstant().toEpochMilli();\n"
-                + "if (params.published_at != null) { ctx._source.published_at = ZonedDateTime.parse(params.published_at).toInstant().toEpochMilli(); }\n",
+                + "if (params.published_at != null) { ctx._source.published_at = ZonedDateTime.parse(params.published_at).toInstant().toEpochMilli(); }\n"
+                + "if (params.first_published_at != null) { ctx._source.first_published_at = ZonedDateTime.parse(params.first_published_at).toInstant().toEpochMilli(); }\n",
             parameters);
     return inline;
   }
@@ -224,7 +225,8 @@ public static Script getInlineForFile(Map<String, Object> parameters) {
             "if (!ctx._source.repositories.contains(params.repository)) { ctx._source.repositories.add(params.repository) }\n"
                 + "ctx._source.analysis.analysis_state = params.analysis_state;\n"
                 + "ctx._source.analysis.updated_at = ZonedDateTime.parse(params.updated_at).toInstant().toEpochMilli();\n"
-                + "if (params.published_at != null) { ctx._source.analysis.published_at = ZonedDateTime.parse(params.published_at).toInstant().toEpochMilli(); }\n",
+                + "if (params.published_at != null) { ctx._source.analysis.published_at = ZonedDateTime.parse(params.published_at).toInstant().toEpochMilli(); }\n"
+                + "if (params.first_published_at != null) { ctx._source.analysis.first_published_at = ZonedDateTime.parse(params.first_published_at).toInstant().toEpochMilli(); }\n",
             parameters);
     return inline;
   }