aboutsummaryrefslogtreecommitdiff
path: root/apps/logger.js
diff options
context:
space:
mode:
authorTrygve Laugstøl <trygvis@inamo.no>2015-10-18 18:10:20 +0200
committerTrygve Laugstøl <trygvis@inamo.no>2015-10-18 18:10:20 +0200
commit52eb8072664a61ea61dbdbef7485d6c81dbbcfe9 (patch)
treef4218bc276a0188da26da472d1233c264ff31dfe /apps/logger.js
parent9339e6269d6f5a5d0421c23c5e9ba3c8500fb535 (diff)
downloaddiller-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.js39
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;