in index.js [98:150]
function init(callback) {
if (!online) {
if (!setRegion || setRegion === null || setRegion === "") {
setRegion = "us-east-1";
console.log("Warning: Setting default region " + setRegion);
}
if (debug) {
console.log("AWS Streams to Firehose Forwarder v" + pjson.version + " in " + setRegion);
}
transform.setupTransformer(function (err, transformer) {
if (err) {
callback(err);
} else {
useTransformer = transformer;
aws.config.update({
region: setRegion
});
// configure a new connection to firehose, if one has not been
// provided
if (!exports.firehose) {
if (debug) {
console.log("Connecting to Amazon Kinesis Firehose in " + setRegion);
}
exports.firehose = new aws.Firehose({
apiVersion: '2015-08-04',
region: setRegion
});
}
// configure a new connection to kinesis streams, if one has not
// been provided
if (!exports.kinesis) {
if (debug) {
console.log("Connecting to Amazon Kinesis Streams in " + setRegion);
}
exports.kinesis = new aws.Kinesis({
apiVersion: '2013-12-02',
region: setRegion
});
}
online = true;
callback(null);
}
});
} else {
callback(null);
}
}