oneday-core - npm Package Compare versions

Comparing version 1.0.40 to 1.0.41

db.js

@@ -7,2 +7,3 @@ const aws = require('aws-sdk');
 const enums = require('./enum');
+const util = require('./util');
 
@@ -136,5 +137,4 @@ module.exports.getFromDb = getFromDb;
     }
+    params.ReturnValues = 'ALL_NEW';
 
-    params.ReturnValues = 'UPDATED_NEW';
-
     const result = await dynamoDb.update(params).promise();
@@ -145,3 +145,7 @@ console.log('Updated table: ' + params.TableName);
     if (isPublish === true) {
-        await resource.publishToTopic(topicName, enums.event_type.UPDATE, params, requestId, []);
+        let change = [];
+        if (params.ExpressionAttributeNames !== null && util.isObject(params.ExpressionAttributeNames)) {
+            change = Object.values(params.ExpressionAttributeNames);
+        }
+        await resource.publishToTopic(topicName, enums.event_type.UPDATE, result.Attributes, requestId, change);
     }
@@ -163,2 +167,3 @@ return result;
     }
+    params.ReturnValues = 'ALL_NEW';
 
@@ -170,5 +175,9 @@ const result = await dynamoDb.update(params).promise();
     if (isPublish === true) {
-        await resource.publishToTopic(topicName, enums.event_type.DELETE, params, requestId, []);
+        let change = [];
+        if (params.ExpressionAttributeNames !== null && util.isObject(params.ExpressionAttributeNames)) {
+            change = Object.values(params.ExpressionAttributeNames);
+        }
+        await resource.publishToTopic(topicName, enums.event_type.DELETE, result, requestId.Attributes, change);
     }
     return result;
 }

package.json

 {
   "name": "oneday-core",
-  "version": "1.0.40",
+  "version": "1.0.41",
   "description": "Basic AWS util functions to ease development.",
@@ -5,0 +5,0 @@ "main": "index.js",

resource.js

@@ -26,3 +26,3 @@ 'use strict';
 
-        const result = await sqs.sendMessage(params);
+        const result = await sqs.sendMessage(params).promise();
         console.log(result);
@@ -29,0 +29,0 @@

variable.js

 let instanceRequestId = null;
 
 function getInstanceRequestId() {
-    console.log('Get ReqId: ' + instanceRequestId);
     return instanceRequestId;
@@ -10,3 +9,2 @@ }
     instanceRequestId = id;
-    console.log('Set ReqId: ' + instanceRequestId);
 }
@@ -13,0 +11,0 @@

No alert changes

Improved metrics

Total package byte prevSize

25092

increased by1.7%

Lines of code

669

increased by1.21%

No dependency changes