diff options
author | Trygve Laugstøl <trygvis@inamo.no> | 2015-10-18 18:10:20 +0200 |
---|---|---|
committer | Trygve Laugstøl <trygvis@inamo.no> | 2015-10-18 18:10:20 +0200 |
commit | 52eb8072664a61ea61dbdbef7485d6c81dbbcfe9 (patch) | |
tree | f4218bc276a0188da26da472d1233c264ff31dfe /apps/logger.js | |
parent | 9339e6269d6f5a5d0421c23c5e9ba3c8500fb535 (diff) | |
download | diller-server-52eb8072664a61ea61dbdbef7485d6c81dbbcfe9.tar.gz diller-server-52eb8072664a61ea61dbdbef7485d6c81dbbcfe9.tar.bz2 diller-server-52eb8072664a61ea61dbdbef7485d6c81dbbcfe9.tar.xz diller-server-52eb8072664a61ea61dbdbef7485d6c81dbbcfe9.zip |
o Dropping the app concept.
o Switching to pg-promise to not get overloaded by callbacks.
Diffstat (limited to 'apps/logger.js')
-rw-r--r-- | apps/logger.js | 39 |
1 files changed, 0 insertions, 39 deletions
diff --git a/apps/logger.js b/apps/logger.js deleted file mode 100644 index 32ceb27..0000000 --- a/apps/logger.js +++ /dev/null @@ -1,39 +0,0 @@ -var pg, log; - -function init(config) { - pg = config.pg; - log = config.log; - - log.info('loaded'); -} -exports.init = init; - -function onMessage(topic, message, payload) { - pg.connect(function (err, client, done) { - if (err) { - done(); - console.log(err); - return; - } - - var body = message.toString(); - - client.query("INSERT INTO message(timestamp, topic, message) values(current_timestamp, $1, $2)", [topic, body]); - - // pg.on('row', function(row) { - // results.push(row); - // }); - - client.on('end', function () { - log.info('message processed'); - done(); - }); - - client.on('error', function (err) { - log.info('error', err); - done(); - }); - }); -} - -exports.onMessage = onMessage; |