chore(integrations): added logging to see how many results we processed

Signed-off-by: Uroš Marolt <uros@marolt.me>

Author: themarolt

services/apps/data_sink_worker/src/service/dataSink.service.ts

@@ -341,6 +341,9 @@ export default class DataSinkService extends LoggerBase {
     }
 
     // handle results
+    let errors = 0
+    let successes = 0
+    let deletions = 0
     const resultsToDelete: string[] = []
     for (const [resultId, result] of resultMap) {
       const batchEntry = single(batch, (b) => b.resultId === resultId)
@@ -356,15 +359,25 @@ export default class DataSinkService extends LoggerBase {
           undefined,
           result.err,
         )
-      } else if (batchEntry.created) {
-        resultsToDelete.push(resultId)
+
+        errors++
+      } else {
+        successes++
+        if (batchEntry.created) {
+          deletions++
+          resultsToDelete.push(resultId)
+        }
       }
     }
 
     if (resultsToDelete.length > 0) {
       await this.repo.deleteResults(resultsToDelete)
     }
 
+    this.log.info(
+      `Processed ${successes} results successfully, ${errors} with error, ${deletions} were deleted from db!`,
+    )
+
     const end = performance.now()
     const totalTime = end - start