Change mining script to mine periodically and use filters instead of polling.

js/mine.js

@@ -1,16 +1,49 @@
-var miner_var;
+// Adapted from Iuri Matias' Embark framework
+// https://github.com/iurimatias/embark-framework
+// Modified by ryepdx to mine at regular intervals.
+(function() {
+  var main = function () {
+    /* TODO: Find a way to load mining config from YML.
      
-if (admin.miner === undefined) {
+    if (!loadScript("config.js")) {
-  miner_var = miner;
+      console.log("== config.js not found");
-}
+    }
-else {
-  miner_var = admin.miner;
-}
 
-miner_var.setEtherbase(web3.eth.accounts[0]);
+    if (typeof(config) === "undefined") {
+      config = {};
+      console.log("== config is undefined, proceeding with defaults");
+    }
+
+    In the meantime, just set an empty config object.
+    */
+    config = {}
+
+    defaults = {
+      interval_ms: 15000,
+      mine_pending_txns: true,
+      mine_periodically: true,
+      mine_normally: false,
+      threads: 1
+    }
+
+    for (key in defaults) {
+      if (config[key] === undefined) {
+        config[key] = defaults[key];
+      }
+    }
+
+    var miner_obj = (admin.miner === undefined) ? miner : admin.miner;
+
+    if (config.mine_normally) {
+        miner_obj.start(config.threads);
+        return;
+    }
+    miner_obj.stop();
+
+    if (config.mine_periodically) start_periodic_mining(config, miner_obj);
+    if (config.mine_pending_txns) start_transaction_mining(config, miner_obj);
+  };
 
-setInterval(function() {
-  var minimalAmount = (web3.eth.getBalance(web3.eth.coinbase) >= 15000000000000000000);
   var pendingTransactions = function() {
     if (web3.eth.pendingTransactions === undefined || web3.eth.pendingTransactions === null) {
       return txpool.status.pending || txpool.status.queued;
@@ -21,19 +54,61 @@ setInterval(function() {
     else {
       return web3.eth.pendingTransactions.length > 0 || web3.eth.getBlock('pending').transactions.length > 0;
     }
+  };
+
+  var start_periodic_mining = function (config, miner_obj) {
+    var last_mined_ms = Date.now();
+    var timeout_set = false;
+
+    miner_obj.start(config.threads);
+    web3.eth.filter("latest").watch(function () {
+      if ((config.mine_pending_txns && pendingTransactions()) || timeout_set) {
+        return;
       }
 
-  if(!web3.eth.mining && (!minimalAmount || pendingTransactions())) {
+      timeout_set = true;
-    if (!minimalAmount) { console.log("=== minimal ether amount not reached yet") }
+
-    if (pendingTransactions()) { console.log("=== there are pending transactions") }
+      var now = Date.now();
-    console.log("=== start mining");
+      var ms_since_block = now - last_mined_ms;
-    miner_var.start();
+      last_mined_ms = now;
-  }
+
-  else if (web3.eth.mining && minimalAmount && !pendingTransactions()) {
+      var next_block_in_ms;
-    if (minimalAmount) { console.log("=== minimal ether amount reached") }
+
-    if (!pendingTransactions()) { console.log("=== no pending transactions") }
+      if (ms_since_block > config.interval_ms) {
-    console.log("=== stop mining");
+        next_block_in_ms = 0;
-    miner_var.stop();
+      } else {
-  }
+        next_block_in_ms = (config.interval_ms - ms_since_block);
-}, 1000)
+      }
+
+      miner_obj.stop();
+      console.log("== Looking for next block in " + next_block_in_ms + "ms");
+
+      setTimeout(function () {
+        console.log("== Looking for next block");
+        timeout_set = false;
+        miner_obj.start(config.threads);
+      }, next_block_in_ms);
+    });
+  };
+
+  var start_transaction_mining = function (config, miner_obj) {
+    web3.eth.filter("pending").watch(function () {
+      if (miner_obj.hashrate > 0) return;
+
+      console.log("== Pending transactions! Looking for next block...");
+      miner_obj.start(config.threads);
+    });
+    
+    if (config.mine_periodically) return;
+
+    web3.eth.filter("latest").watch(function () {
+      if (!pendingTransactions()) {
+        console.log("== No transactions left. Stopping miner...");
+        miner_obj.stop();
+      }
+    });
+  };
+
+  main();
+})();