dynamodb payload, config changes

 Committer: nkumar

Author: nkumar

config/default.js

@@ -48,6 +48,10 @@ module.exports = {
     RECONSILER_END: process.env.RECONSILER_END || 5,
     RECONSILER_DURATION_TYPE: process.env.RECONSILER_DURATION_TYPE || 'm'
   },
+  DYNAMODB:
+	{
+	DYNAMODB_TABLE: process.env.DYNAMODB_TABLE || 'test_pg_ifx_payload_sync'
+	},
 
 	AUTH0_URL: process.env.AUTH0_URL ,
 	AUTH0_AUDIENCE: process.env.AUTH0_AUDIENCE ,

src/services/pushToDynamoDb.js

@@ -4,13 +4,11 @@ const _ = require('lodash')
 var AWS = require("aws-sdk");
 async function pushToDynamoDb(payload) {
   try { console.log('----Push To DynomoDB  -------');
-        //  console.log(payload)
-	   p_dd_payloadseqid = payload.payload.payloadseqid;
 	    var params = {
-	    TableName: 'test_pg_ifx_payload_sync',
+	    TableName: config.DYNAMODB.DYNAMODB_TABLE,
     	    Item: {
        		payloadseqid: payload.payload.payloadseqid,
-       		pl_document: payload.payload,
+       		pl_document: payload,
 		pl_table: payload.payload.table,
 		pl_uniquecolumn: payload.payload.Uniquecolumn,
 		pl_operation: payload.payload.operation,
@@ -25,9 +23,8 @@ async function pushToDynamoDb(payload) {
   	});
 
   } catch (e) {
-          logger.error(`Error at PushToDynamoDB "${e}"`)
+          logger.error(`error-sync: Error at PushToDynamoDB "${e}"`)
   }
 }
 
-console.log("--from DyanomoDb--")
 module.exports = pushToDynamoDb