@dasmeta/event-manager-platform-helper - npm Package Compare versions

Comparing version 1.2.0 to 1.3.0

package.json

 {
   "name": "@dasmeta/event-manager-platform-helper",
-  "version": "1.2.0",
+  "version": "1.3.0",
   "description": "Event platform helper",
@@ -13,2 +13,3 @@ "main": "index.js",
   "dependencies": {
+    "@dasmeta/event-manager-node-api": "^2.2.3",
     "mongodb": "^3.3.2"
@@ -15,0 +16,0 @@ },

src/adapter/factory.js

 const availablePlatforms = [
     'fission',
-    'gcf'
+    'gcf',
+    'aws'
 ];
@@ -5,0 +6,0 @@ const getPlatformAdapters = (platform) => {

src/wrapper/index.js

@@ -1,2 +0,2 @@
-const { recordStart, recordSuccess, recordFailure, recordPreconditionFailure, hasReachedMaxAttempts } = require("../event-logger");
+const { EventSubscriptionApi } = require("@dasmeta/event-manager-node-api");
 const { getPlatformAdapters } = require("../adapter/factory");
@@ -29,4 +29,6 @@
 
-        await recordStart(eventInfo);
+        const api = new EventSubscriptionApi({ basePath: process.env.EVENT_MANAGER_BACKEND_HOST });
 
+        await api.eventSubscriptionsRecordStartPost(eventInfo);
+
         let response;
@@ -36,3 +38,3 @@ try {
 
-            await recordSuccess(eventInfo);
+            await api.eventSubscriptionsRecordSuccessPost(eventInfo);
         } catch (error) {
@@ -42,9 +44,9 @@ console.error("Error", error, { eventInfo, data, dataSource });
             if (error.message.includes("PreconditionFailedError")) {
-                if ((await hasReachedMaxAttempts({ ...eventInfo }))) {
-                    await recordFailure({ ...eventInfo, error });
+                if ((await api.eventSubscriptionsHasReachedMaxAttemptsGet(topic, subscription, eventId, eventInfo.maxAttempts))) {
+                    await api.eventSubscriptionsRecordFailurePost({ ...eventInfo, error });
                     throw error;
                 }
-                await recordPreconditionFailure({ ...eventInfo });
+                await api.eventSubscriptionsRecordPreconditionFailurePost({ ...eventInfo });
             } else {
-                await recordFailure({ ...eventInfo, error });
+                await api.eventSubscriptionsRecordFailurePost({ ...eventInfo, error });
                 throw error;
@@ -51,0 +53,0 @@ }

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

Environment variable access

Supply chain risk

Package accesses environment variables, which may be a sign of credential stuffing or data theft.

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

Dynamic require

Supply chain risk

Dynamic require can indicate the package is performing dangerous or unsafe dynamic code execution.

Found 1 instance in 1 package

Environment variable access

Supply chain risk

Package accesses environment variables, which may be a sign of credential stuffing or data theft.

Found 1 instance in 1 package

Improved metrics

Number of low supply chain risk alerts

5

decreased by-16.67%

Worsened metrics

Total package byte prevSize

19331

decreased by-19.64%

Dependency count

2

increased by100%

Number of package files

10

decreased by-9.09%

Lines of code

149

decreased by-50.17%

Dependency changes

• + Added@dasmeta/event-manager-node-api@^2.2.3

• + Added@dasmeta/event-manager-node-api@2.2.3(transitive)

• + Addedaxios@0.21.4(transitive)

• + Addedfollow-redirects@1.15.9(transitive)