lightapp-platform-common
Advanced tools
Comparing version 2.0.5 to 2.0.6
{ | ||
"name": "lightapp-platform-common", | ||
"version": "2.0.5", | ||
"version": "2.0.6", | ||
"description": "common utilities for lightapp platform", | ||
@@ -11,2 +11,2 @@ "main": "index.js", | ||
"license": "ISC" | ||
} | ||
} |
@@ -9,6 +9,6 @@ "use strict"; | ||
const aws_sdk_1 = __importDefault(require("aws-sdk")); | ||
const config = require('../config/firehose.json'); | ||
let fireHose = new aws_sdk_1.default.Firehose(); | ||
class Firehose { | ||
constructor() { | ||
constructor(streamName) { | ||
this.streamName = streamName; | ||
} | ||
@@ -18,9 +18,8 @@ putRecord(meterReading, callback) { | ||
let _result; | ||
const streamName = config.StreamName; | ||
const data = new Buffer(JSON.stringify(meterReading) + '\n'); | ||
const recordParams = { | ||
DeliveryStreamName: streamName, | ||
DeliveryStreamName: this.streamName, | ||
Record: { Data: data } | ||
}; | ||
console.log(`start writing to firehose with streamName: ${streamName}`); | ||
console.log(`start writing to firehose with streamName: ${this.streamName}`); | ||
console.log(`fireHose instance ${fireHose && 'exists'}`); | ||
@@ -27,0 +26,0 @@ fireHose.putRecord(recordParams, (err, data) => { |
17660
35
502