From cc0dcb25054e9dff3fdc4b58eaf861d35d0b06de Mon Sep 17 00:00:00 2001
From: Trygve Laugstøl <trygvis@inamo.no>
Date: Sun, 18 Oct 2015 10:36:01 +0200
Subject: wip

---
 apps/logger.js | 39 +++++++++++++++++++++++++++++++++++++++
 1 file changed, 39 insertions(+)
 create mode 100644 apps/logger.js

(limited to 'apps/logger.js')

diff --git a/apps/logger.js b/apps/logger.js
new file mode 100644
index 0000000..32ceb27
--- /dev/null
+++ b/apps/logger.js
@@ -0,0 +1,39 @@
+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;
-- 
cgit v1.2.3