Merge pull request #187 from aodn/bug/6324-sse-not-send-on-progress

Bug/6324 sse not send on progress
aodn · Feb 6, 2025 · a1f01a8 · a1f01a8
2 parents c454bb2 + ecffaec
commit a1f01a8
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/indexer/src/main/java/au/org/aodn/esindexer/service/IndexCloudOptimizedServiceImpl.java b/indexer/src/main/java/au/org/aodn/esindexer/service/IndexCloudOptimizedServiceImpl.java
@@ -120,19 +120,20 @@ public List<BulkResponse> indexCloudOptimizedData(MetadataEntity entity,
             for (List<StacItemModel> entries : dataset) {
                 if (entries != null) {
                     for(StacItemModel entry: entries) {
-                        log.debug("add dataset into b with UUID: {} and props: {}", entry.getUuid(), entry.getProperties());
+                        log.debug("add cloud data with UUID: {} and props: {}", entry.getUuid(), entry.getProperties());
                         count++;
                         bulkRequestProcessor.processItem(entry.getUuid(), entry)
                                 .ifPresent(responses::add);
                     }
+                    callback.onProgress(String.format("Added... %d", count));
                 }
             }
             bulkRequestProcessor
                     .flush()
                     .ifPresent(responses::add);
 
             log.info("Finished execute bulk indexing records {} to index: {}", count, indexName);
-            callback.onComplete(responses);
+            callback.onProgress(responses);
         }
         catch (Exception e) {
             log.error("Exception thrown or not found while indexing cloud optimized data : {}", entity.getUuid(), e);