From 8e41381f30888d7de28982568be0a3de1e13c2c7 Mon Sep 17 00:00:00 2001
From: Waleed Ashraf <waleedashraf@outlook.com>
Date: Sat, 22 Aug 2015 13:08:51 +0500
Subject: [PATCH] Blockchain

---
 config/blockchain.js   |  3 +++
 worker.js              |  2 ++
 worker/transactions.js | 12 ++++++++++++
 3 files changed, 17 insertions(+)
 create mode 100644 config/blockchain.js
 create mode 100644 worker/transactions.js

diff --git a/config/blockchain.js b/config/blockchain.js
new file mode 100644
index 0000000..0b4d065
--- /dev/null
+++ b/config/blockchain.js
@@ -0,0 +1,3 @@
+var WebSocket = require('ws');
+var ws = new WebSocket('wss://ws.chain.com/v2/notifications');
+module.exports.blockchain = ws;
diff --git a/worker.js b/worker.js
index 9c7a7e2..a3bce87 100644
--- a/worker.js
+++ b/worker.js
@@ -3,4 +3,6 @@ Sails.load(function(err, sails) {
   var market = require('./worker/market.js');
   // push continuous rate updates to redis
   market.contRate();
+  var trans = require('./worker/transactions.js');
+  trans.trans();
 });
diff --git a/worker/transactions.js b/worker/transactions.js
new file mode 100644
index 0000000..559ffcd
--- /dev/null
+++ b/worker/transactions.js
@@ -0,0 +1,12 @@
+var ws = sails.config.blockchain;
+module.exports.trans = function(){
+  var log = sails.log;
+  ws.on('open', function() {
+      ws.send(JSON.stringify({type: 'new-transaction', block_chain: 'bitcoin'}));
+  });
+  ws.on('message', function(ev) {
+    var x = JSON.parse(ev);
+    log.silly('New Transaction',x);
+  });
+
+};