From e79e81fe4b4cb164959aa3f68728be4e5fc766d0 Mon Sep 17 00:00:00 2001
From: Matias Alejo Garcia <ematiu@gmail.com>
Date: Mon, 6 Jan 2014 23:50:29 -0300
Subject: [PATCH] block syncing working!

---
 app/models/Block.js | 68 +++++++++++++++++++++++++++++++++++++++++++++
 package.json        |  3 +-
 util/sync.js        | 64 ++++++++++++++++++++++++++++++++++++++++++
 3 files changed, 134 insertions(+), 1 deletion(-)
 create mode 100644 app/models/Block.js
 create mode 100755 util/sync.js

diff --git a/app/models/Block.js b/app/models/Block.js
new file mode 100644
index 00000000..94404267
--- /dev/null
+++ b/app/models/Block.js
@@ -0,0 +1,68 @@
+'use strict';
+
+/**
+ * Module dependencies.
+ */
+var mongoose = require('mongoose'),
+    Schema = mongoose.Schema;
+
+
+/**
+ * Block Schema
+ */
+var BlockSchema = new Schema({
+  hash: { 
+    type: String, 
+    index: true,
+    unique: true,
+  },
+  size: Number,
+  confirmations: Number,
+  version: Number,
+  merkleroot: String,
+  tx: [ String ],
+  time: Date,
+  nonce: Number,
+  bits: String,
+  difficulty: Number,
+  chainwork: String,
+  previousblockhash:  {
+    type: String, 
+    index: true,
+    unique: true,
+  },
+  nextblockhash: {
+    type: String, 
+    index: true,
+    unique: true,
+  },
+});
+
+/**
+ * Validations
+ */
+
+/*
+BlockSchema.path('title').validate(function(title) {
+    return title.length;
+},'Title cannot be blank');
+*/
+
+/**
+ * Statics
+ */
+
+BlockSchema.statics.load = function(id, cb) {
+    this.findOne({
+        _id: id
+    }).exec(cb);
+};
+
+
+BlockSchema.statics.fromHash = function(hash, cb) {
+    this.findOne({
+      hash: hash,
+    }).exec(cb);
+};
+
+module.exports = mongoose.model('Block', BlockSchema);
diff --git a/package.json b/package.json
index 0188d4d5..b235128d 100644
--- a/package.json
+++ b/package.json
@@ -38,6 +38,7 @@
     "mongoose": "~3.8.3",
     "lodash": "~2.4.1",
     "bower": "~1.2.8",
-    "bitcore": "*"
+    "bitcore": "*",
+    "buffertools": "*"
   }
 }
diff --git a/util/sync.js b/util/sync.js
new file mode 100755
index 00000000..9fe5a5b2
--- /dev/null
+++ b/util/sync.js
@@ -0,0 +1,64 @@
+#!/usr/bin/env node
+
+process.env.NODE_ENV = process.env.NODE_ENV || 'development';
+require('buffertools').extend();
+
+var RpcClient        = require('../node_modules/bitcore/RpcClient').class();
+var networks         = require('../node_modules/bitcore/networks');
+
+var Block            = require('../app/models/Block');
+var config           = require('../config/config');
+var mongoose         = require('mongoose');
+
+var networkName      = process.argv[2] || 'testnet';
+var genesisBlockHash = networks.testnet.genesisBlock.hash.reverse().toString('hex');
+
+
+function syncBlocks(blockHash) {
+
+  rpc.getBlock(blockHash, function(err, blockInfo) {
+    if (err) {
+      console.log(err);
+      throw(err); 
+    }
+
+    if ( ! ( blockInfo.result.height % 1000) ) 
+      console.log("Height:" + blockInfo.result.height);
+
+    Block.create( blockInfo.result, function(err, inBlock) {
+
+      if (err && err.toString().match(/E11000/)) {
+//        console.log("\twas there. Skipping");
+        return syncBlocks(blockInfo.result.nextblockhash);
+      }
+
+      if (err) throw(err);
+
+      if (inBlock.nextblockhash && ! inBlock.nextblockhash.match(/^0+$/)  ) {
+        syncBlocks(inBlock.nextblockhash)
+      }
+      else {
+        mongoose.connection.close();
+      }
+
+    });
+  });
+
+}
+
+
+mongoose.connect(config.db);
+
+var db    = mongoose.connection;
+var rpc   = new RpcClient(config.bitcoind);
+
+
+db.on('error', console.error.bind(console, 'connection error:'));
+db.once('open', function callback () {
+
+  syncBlocks(genesisBlockHash);
+
+});
+
+
+