@elastic.io/oih-standard-library - npm Package Compare versions

Comparing version 0.0.10-dev.14 to 0.0.10-dev.15

lib/triggers/getNewAndUpdated.js

@@ -30,2 +30,5 @@ "use strict";
                     this.logger.trace('Polled objects: %j', result);
+                    if (result.length === 0) {
+                        break;
+                    }
                     await this.emitIndividually(result);
@@ -38,2 +41,5 @@ break;
                     this.logger.trace('Polled objects: %j', result);
+                    if (result.length === 0) {
+                        break;
+                    }
                     await this.emitAll(result);
@@ -185,4 +191,6 @@ break;
         const result = await this.getObjectsFromPage(objectType, startTime, endTime, page, cfg);
-        this.logger.trace('Polled objects: %j', result);
-        await this.emitAll(result.objects);
+        this.logger.trace('Polled next page and objects: %j', result);
+        if (result.objects.length > 0) {
+            await this.emitAll(result.objects);
+        }
         return result.nextPage;
@@ -189,0 +197,0 @@ }

lib/triggers/getNewAndUpdated.ts

@@ -37,2 +37,5 @@ import {
           this.logger.trace('Polled objects: %j', result);
+          if (result.length === 0) {
+            break;
+          }
           await this.emitIndividually(result);
@@ -45,2 +48,5 @@ break;
           this.logger.trace('Polled objects: %j', result);
+          if (result.length === 0) {
+            break;
+          }
           await this.emitAll(result);
@@ -200,4 +206,6 @@ break;
     const result = await this.getObjectsFromPage(objectType, startTime, endTime, page, cfg);
-    this.logger.trace('Polled objects: %j', result);
-    await this.emitAll(result.objects);
+    this.logger.trace('Polled next page and objects: %j', result);
+    if (result.objects.length > 0) {
+      await this.emitAll(result.objects);
+    }
     return result.nextPage;
@@ -204,0 +212,0 @@ }

package.json

 {
   "name": "@elastic.io/oih-standard-library",
-  "version": "0.0.10-dev.14",
+  "version": "0.0.10-dev.15",
   "description": "Library for OIH standards implementation",
@@ -5,0 +5,0 @@ "author": {

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

164711

increased by0.39%

Lines of code

2430

increased by0.66%

No dependency changes