Merge pull request #31 from maraoz/feature/add-socketio

add socket.io and try it with a simple socket message

.jshintrc

@@ -32,7 +32,9 @@
         "afterEach",
         "it",
         "inject",
-        "expect"
+        "expect",
+        "$"
+
     ],
     "indent": false, // Specify indentation spacing
     "devel": true, // Allow development statements e.g. `console.log();`.

HeaderDB.js

@@ -1,213 +0,0 @@
-require('classtool');
-
-function ClassSpec(b) {
-  var assert = require('assert');
-  var fs = require('fs');
-  var Block = require('bitcore/Block').class();
-  var Deserialize = require('bitcore/Deserialize');
-  var Parser = require('bitcore/util/BinaryParser').class();
-  var coinUtil = require('bitcore/util/util');
-
-  function HeaderDB(b) {
-    this.network = b.network;
-    this.fd = null;
-    this.blocks = {};
-    this.byHeight = [];
-    this.bestBlock = null;
-    this.cached_size = 0;
-  }
-
-  HeaderDB.prototype.size = function() {
-    this.cached_size = Object.keys(this.blocks).length;
-    return this.cached_size;
-  };
-
-  HeaderDB.prototype.locator = function(block) {
-    if (!block)
-      block = this.bestBlock;
-
-    var step = 1;
-    var start = 0;
-    var loc = [];
-    // see https://en.bitcoin.it/wiki/Protocol_specification#getblocks
-    for (var i = block.height; i > 0; i -= step, ++start) {
-      if (start >= 10)
-        step *= 2;
-      loc.push(this.byHeight[i]);
-    }
-    assert.equal(this.byHeight[0].toString(),
-          this.network.genesisBlock.hash.toString());
-    loc.push(this.byHeight[0]);
-    //console.log('Requesting more headers. Current height: ' + block.height );
-    return loc;
-  };
-
-  HeaderDB.prototype.add = function(block) {
-    var hash = block.calcHash();
-    block.hash = hash;
-    var curWork = Deserialize.intFromCompact(block.bits);
-
-    if (hash in this.blocks) {
-            var old  =  this.blocks[hash];
-      throw new Error('duplicate block (was at height ' + old.height  + ')');
-       }
-
-    var bestChain = false;
-
-    var reorg = {
-      oldBest: null,
-      conn: 0,
-      disconn: 0,
-    };
-
-    if (this.cached_size == 0) {
-      if (this.network.genesisBlock.hash.toString() !=
-          hash.toString())
-        throw new Error('Invalid genesis block');
-
-      block.height = 0;
-      block.work = curWork;
-      bestChain = true;
-            this.cached_size++;
-    } else {
-      var prevBlock = this.blocks[block.prev_hash];
-      if (!prevBlock)
-        throw new Error('orphan block; prev not found');
-
-      block.height = prevBlock.height + 1;
-      block.work = prevBlock.work + curWork;
-            this.cached_size++;
-
-      if (block.work > this.bestBlock.work)
-        bestChain = true;
-    }
-
-
-    // add to by-hash index
-    this.blocks[hash] = block;
-
-    if (bestChain) {
-      var oldBest = this.bestBlock;
-      var newBest = block;
-
-      reorg.oldBest = oldBest;
-
-      // likely case: new best chain has greater height
-      if (!oldBest) {
-        while (newBest) {
-          newBest = this.blocks[newBest.prev_hash];
-          reorg.conn++;
-        }
-      } else {
-        while (newBest &&
-               (newBest.height > oldBest.height)) {
-          newBest = this.blocks[newBest.prev_hash];
-          reorg.conn++;
-        }
-      }
-
-      // unlikely: old best chain has greater height
-      while (oldBest && newBest &&
-             (oldBest.height > newBest.height)) {
-        oldBest = this.blocks[oldBest.prev_hash];
-        reorg.disconn++;
-      }
-
-      // height matches, but still walking parallel
-      while (oldBest && newBest && (oldBest != newBest)) {
-        newBest = this.blocks[newBest.prev_hash];
-        reorg.conn++;
-
-        oldBest = this.blocks[oldBest.prev_hash];
-        reorg.disconn++;
-      }
-
-      var shuf = (reorg.conn > reorg.disconn) ?
-           reorg.conn : reorg.disconn;
-
-      // reorg analyzed, updated best-chain pointer
-      this.bestBlock = block;
-
-      // update by-height index
-      var ptr = block;
-      var updated = [];
-      for (var idx = block.height; 
-           idx > (block.height - shuf); idx--) {
-        if (idx < 0)
-          break;
-        var update = [ idx, ptr ];
-        updated.push(update);
-        ptr = this.blocks[ptr.prev_hash];
-      }
-
-      updated.reverse();
-
-      for (var i = 0; i < updated.length; i++) {
-        var update = updated[i];
-        var idx = update[0];
-        var ptr = update[1];
-
-        if (idx < this.byHeight.length)
-          this.byHeight[idx] = ptr.hash;
-        else
-          this.byHeight.push(ptr.hash);
-      }
-    }
-    return reorg;
-  };
-
-  HeaderDB.prototype.addBuf = function(buf) {
-    var block = new Block();
-    var parser = new Parser(buf);
-    block.parse(parser, true);
-    this.add(block);
-
-  };
-
-
-  HeaderDB.prototype.readFile = function(filename) {
-    var fd = fs.openSync(filename, 'r');
-    var stats = fs.fstatSync(fd);
-    if (stats.size % 80 != 0)
-      throw new Error('Corrupted header db');
-
-    while (1) {
-      var buf = new Buffer(80);
-      var bread = fs.readSync(fd, buf, 0, 80, null);
-      if (bread < 80)
-        break;
-
-      this.addBuf(buf);
-
-            if ( ! ( this.cached_size % 1000 )) {
-                console.log('\tblock...' +  this.cached_size ) ;
-            }
-    }
-
-    fs.closeSync(fd);
-  };
-
-  HeaderDB.prototype.writeFile = function(filename) {
-    var block = this.bestBlock;
-    var data = [];
-    while (block) {
-      var s = block.getHeader();
-      data.push(s);
-      block = this.blocks[block.prev_hash];
-    }
-
-    data.reverse();
-
-    var fd = fs.openSync(filename, 'w');
-
-    data.forEach(function(datum) {
-      fs.writeSync(fd, datum, 0, 80, null);
-    });
-
-    fs.closeSync(fd);
-  };
-
-  return HeaderDB;
-};
-module.defineClass(ClassSpec);
-

app/views/includes/head.jade

@@ -13,3 +13,6 @@ head
   link(rel='stylesheet', href='/lib/bootstrap/dist/css/bootstrap.min.css')
   link(rel='stylesheet', href='/css/common.css')
 
+  script(src='/socket.io/socket.io.js')
+  script(src='/lib/jquery/jquery.js')
+

app/views/index.jade

@@ -2,3 +2,4 @@ extends layouts/default
 
 block content
   section.container(data-ng-view)
+

app/views/sockets/main.js

@@ -0,0 +1,13 @@
+'use strict';
+
+var Transaction = require('../../models/Transaction');
+
+module.exports = function(app, io) {
+  io.set('log level', 1); // reduce logging
+  io.sockets.on('connection', function(socket) {
+    Transaction.findOne(function(err, tx) {
+      socket.emit('tx', tx);
+    });
+  });
+};
+

package.json

@@ -60,7 +60,9 @@
     "grunt-nodemon": "~0.1.2",
     "grunt-mocha-test": "~0.8.1",
     "should": "~2.1.1",
-    "view-helpers": "latest" 
+    "view-helpers": "latest",
+    "socket.io": "~0.9.16"
+
   },
   "devDependencies": {
     "grunt-contrib-watch": "latest",

public/js/controllers/index.js

@@ -1,6 +1,16 @@
 'use strict';
 
-angular.module('mystery.system').controller('IndexController', ['$scope', 'Global', 'Index', function ($scope, Global, Index) {
+angular.module('mystery.system').controller('IndexController', ['$scope', 'Global', 'Index', function($scope, Global, Index) {
   $scope.global = Global;
   $scope.index = Index;
 }]);
+
+$(document).ready(function() {
+  var socket = io.connect('http://localhost');
+  socket.on('tx', function(data) {
+    var tx = data;
+    console.log('Transaction received! '+tx.txid);
+  });
+
+});
+

server.js

@@ -56,9 +56,14 @@ require('./config/express')(app, db);
 //Bootstrap routes
 require('./config/routes')(app);
 
+// socket.io
+var server = require('http').createServer(app);
+var io = require('socket.io').listen(server);
+require('./app/views/sockets/main.js')(app,io);
+
 //Start the app by listening on <port>
 var port = process.env.PORT || config.port;
-app.listen(port);
+server.listen(port);
 console.log('Express app started on port ' + port);
 
 //expose app