Update TransportGetFindingsSearchAction.kt

annie3431 · Mar 29, 2022 · 18d5e1d · 18d5e1d
1 parent e73e4db
commit 18d5e1d
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...ing/src/main/kotlin/org/opensearch/alerting/transport/TransportGetFindingsSearchAction.kt b/...ing/src/main/kotlin/org/opensearch/alerting/transport/TransportGetFindingsSearchAction.kt
@@ -163,12 +163,12 @@ class TransportGetFindingsSearchAction @Inject constructor(
                         findings.add(finding)
                         for (doc_id in doc_ids) {
                             val document = searchDocument(doc_id, sourceIndex, actionListener)
-                            if (document)
+                            if (document != null)
                                 docs.add(document)
                         }
                         findingsWithDocs.add(FindingWithDocs(finding, docs))
                         // TODO: remove debug log
-                        log.info("findingsWithDoc: $findingsWithDoc")
+                        log.info("findingsWithDocs: $findingsWithDocs")
                     }
                     actionListener.onResponse(GetFindingsSearchResponse(RestStatus.OK, totalFindingCount, findings))
                 }
@@ -183,8 +183,8 @@ class TransportGetFindingsSearchAction @Inject constructor(
     fun searchDocument(
         documentId: String,
         sourceIndex: String,
-        actionListener: ActionListener<GetFindingsSearchResponse>
-    ): FindingDocument {
+        actionListener: ActionListener<FindingDocument>
+    ) {
         val getRequest = GetRequest(sourceIndex, documentId)
         client.threadPool().threadContext.stashContext().use {
             client.get(