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

Comparing version 0.0.10-dev.20 to 0.0.10-dev.21

lib/triggers/getNewAndUpdated.d.ts

 export declare abstract class PollingTrigger {
     protected logger: any;
-    protected emit: any;
-    constructor(logger: any, emit: any);
+    protected context: any;
+    constructor(logger: any, context: any);
     /**
@@ -6,0 +6,0 @@ *

lib/triggers/getNewAndUpdated.js

@@ -6,5 +6,5 @@ "use strict";
 class PollingTrigger {
-    constructor(logger, emit) {
+    constructor(logger, context) {
         this.logger = logger;
-        this.emit = emit;
+        this.context = context;
     }
@@ -86,7 +86,7 @@ /**
             this.logger.trace('Snapshot to be emitted: %j', snapshot);
-            this.emit('snapshot', snapshot);
+            this.context.emit('snapshot', snapshot);
             this.logger.debug('Finish emitting snapshot');
             this.logger.info('Finished processing call to Polling Trigger');
             this.logger.debug('Start emitting end');
-            await this.emit('end');
+            await this.context.emit('end');
             this.logger.debug('Finish emitting end');
@@ -227,3 +227,3 @@ }
                 this.logger.trace('Emitting new message with body: %j', r);
-                await this.emit('data', messages.newMessageWithBody(r));
+                await this.context.emit('data', messages.newMessageWithBody(r));
             }
@@ -244,3 +244,3 @@ }
         this.logger.trace('Emitting new message with body: %j', results);
-        await this.emit('data', messages.newMessageWithBody({ results }));
+        await this.context.emit('data', messages.newMessageWithBody({ results }));
         this.logger.debug('Finished emitting data');
@@ -247,0 +247,0 @@ }

lib/triggers/getNewAndUpdated.ts

@@ -10,7 +10,7 @@ import {
 
-  protected emit;
+  protected context;
 
-  public constructor(logger, emit) {
+  public constructor(logger, context) {
     this.logger = logger;
-    this.emit = emit;
+    this.context = context;
   }
@@ -93,7 +93,7 @@
       this.logger.trace('Snapshot to be emitted: %j', snapshot);
-      this.emit('snapshot', snapshot);
+      this.context.emit('snapshot', snapshot);
       this.logger.debug('Finish emitting snapshot');
       this.logger.info('Finished processing call to Polling Trigger');
       this.logger.debug('Start emitting end');
-      await this.emit('end');
+      await this.context.emit('end');
       this.logger.debug('Finish emitting end');
@@ -242,3 +242,3 @@ } catch (e) {
         this.logger.trace('Emitting new message with body: %j', r);
-        await this.emit('data', messages.newMessageWithBody(r));
+        await this.context.emit('data', messages.newMessageWithBody(r));
       }
@@ -260,3 +260,3 @@ }
     this.logger.trace('Emitting new message with body: %j', results);
-    await this.emit('data', messages.newMessageWithBody({ results }));
+    await this.context.emit('data', messages.newMessageWithBody({ results }));
     this.logger.debug('Finished emitting data');
@@ -263,0 +263,0 @@ }

package.json

 {
   "name": "@elastic.io/oih-standard-library",
-  "version": "0.0.10-dev.20",
+  "version": "0.0.10-dev.21",
   "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

169859

increased by0.08%

No dependency changes