oneday-core
Advanced tools
Comparing version 1.0.42 to 1.0.43
@@ -172,5 +172,5 @@ const aws = require('aws-sdk'); | ||
} | ||
await resource.publishToTopic(topicName, enums.event_type.DELETE, result, requestId.Attributes, change); | ||
await resource.publishToTopic(topicName, enums.event_type.DELETE, result.Attributes, change); | ||
} | ||
return result; | ||
} |
{ | ||
"name": "oneday-core", | ||
"version": "1.0.42", | ||
"version": "1.0.43", | ||
"description": "Basic AWS util functions to ease development.", | ||
@@ -5,0 +5,0 @@ "main": "index.js", |
@@ -36,3 +36,4 @@ 'use strict'; | ||
let params = null; | ||
let params = {}; | ||
const entityType = topicName.split('-')[0]; | ||
try { | ||
@@ -71,3 +72,3 @@ if (Object.keys(enums.event_type).indexOf(eventType.toUpperCase()) < 0) { | ||
DataType: 'String', | ||
StringValue: topicName.split('-')[0] | ||
StringValue: entityType | ||
} | ||
@@ -89,3 +90,3 @@ }, | ||
requestId: requestId, | ||
function: 'Publish_Topic_' + eventType, | ||
function: 'Publish_Topic_' + eventType + '_' + entityType, | ||
data: params, | ||
@@ -98,3 +99,3 @@ error: error, | ||
}; | ||
return await db.create(params, false, null); | ||
await db.create(params, false, null); | ||
} | ||
@@ -101,0 +102,0 @@ } |
25114
667