reverse ENS lookup (#403)

* add ens support

* make regex case insensitive

* fix dbissue

* update files

* do not pull etherscan or show currencies if on testnet

* fix block watch

* parenthesis

app/client/lib/ethereum/observeBlocks.js

@@ -19,49 +19,64 @@ Update wallet balances
 @method updateBalances
 */
 updateBalances = function() {
+    // UPDATE TOKEN BALANCES
+    var allWatchedAccounts = EthAccounts.find().fetch().concat(Wallets.find().fetch().concat(CustomContracts.find().fetch()));
 
-    var walletsAndContracts = Wallets.find().fetch().concat(CustomContracts.find().fetch());
+    // go through all existing accounts, for each token
+    _.each(allWatchedAccounts, function(account){
 
-    // UPDATE WALLETS ACCOUNTS balance
-    _.each(walletsAndContracts, function(wallet){
-        if(wallet.address) {
-            web3.eth.getBalance(wallet.address, function(err, res){
+        if(account.address) {
+            web3.eth.getBalance(account.address, function(err, res){
                 if(!err) {
                     // is of type wallet
-                    if(wallet.creationBlock) {
-                        Wallets.update(wallet._id, {$set: {
+                    if(account.creationBlock) {
+                        Wallets.update(account._id, {$set: {
                             balance: res.toString(10)
                         }});
                     } else {
-                        CustomContracts.update(wallet._id, {$set: {
+                        EthAccounts.update(account._id, {$set: {
+                            balance: res.toString(10)
+                        }});
+                        CustomContracts.update(account._id, {$set: {
                             balance: res.toString(10)
                         }});
                     }
                 }
             });
 
             // update dailylimit spent, etc, if wallet type
-            if(wallet.creationBlock) {
+            if(account.creationBlock) {
                 Meteor.setTimeout(function() {
-                    updateContractData(wallet);
+                    updateContractData(account);
                 }, 1000);
             }
         }
-    });
 
 
-
-    // UPDATE TOKEN BALANCES
-    var walletsContractsAndAccounts = EthAccounts.find().fetch().concat(walletsAndContracts);
+        // Only check ENS names every N minutes
+        if (!account.ensCheck || (account.ensCheck && Date.now() - account.ensCheck > 10*60*1000)) {
+            Helpers.getENSName(account.address, function(err, name, returnedAddr) {
+                if (!err && account.address.toLowerCase() == returnedAddr){
+                    EthAccounts.update({address: account.address}, {$set:{ name: name, ens: true, ensCheck: Date.now()}});
+                    CustomContracts.update({address: account.address}, {$set:{ name: name, ens: true, ensCheck: Date.now()}});
+                    Wallets.update({address: account.address}, {$set:{ name: name, ens: true, ensCheck: Date.now()}});
+                } else {
+                    EthAccounts.update({address: account.address}, {$set:{ens: false, ensCheck: Date.now()}});
+                    CustomContracts.update({address: account.address}, {$set:{ens: false, ensCheck: Date.now()}});
+                    Wallets.update({address: account.address}, {$set:{ens: false, ensCheck: Date.now()}});
+
+                }
+            });
+        }
+
 
-    _.each(Tokens.find().fetch(), function(token){
-        if(!token.address)
-            return;
 
-        var tokenInstance = TokenContract.at(token.address);
+        _.each(Tokens.find().fetch(), function(token){
+            if(!token.address)
+                return;
+
+            var tokenInstance = TokenContract.at(token.address);
 
-        // go through all existing accounts, for each token
-        _.each(walletsContractsAndAccounts, function(account){
             tokenInstance.balanceOf(account.address, function(e, balance){
                 var currentBalance = (token && token.balances) ? token.balances[account._id] : 0;
 
@@ -74,7 +89,7 @@ updateBalances = function() {
                         set['balances.'+ account._id] = '';
                         Tokens.update(token._id, {$unset: set});
                     }
-                    
+
                 }
             });
         });
@@ -88,11 +103,20 @@ Observe the latest blocks
 @method observeLatestBlocks
 */
 observeLatestBlocks = function(){
-    // update balances on start 
+    console.log('observeLatestBlocks');
+
+    // update balances on start
     updateBalances();
 
+    // If watching blocks is not working..
+    var interval = setInterval(updateBalances, 15000);
+
     // GET the latest blockchain information
     web3.eth.filter('latest').watch(function(e, res){
+        console.log('NEW BLOCK', e, res);
+
+        clearInterval(interval);
+
         if(!e) {
             // console.log('Block arrived ', res);
             updateBalances();

app/client/lib/ethereum/observeTransactions.js

@@ -272,8 +272,10 @@ observeTransactions = function(){
 
         // check for confirmations
         if(!tx.confirmed && tx.transactionHash) {
-            var filter = web3.eth.filter('latest');
-            filter.watch(function(e, blockHash){
+
+            var updateTransactions = function(e, blockHash){
+                console.log('updateTransactions', e, blockHash);
+
                 if(!e) {
                     var confirmations = (tx.blockNumber && EthBlocks.latest.number) ? (EthBlocks.latest.number + 1) - tx.blockNumber : 0;
                     confCount++;
@@ -370,6 +372,16 @@ observeTransactions = function(){
                         });
                     }
                 }
+            };
+
+            // remove this if the filter works again
+            var interval = setInterval(function(e, blockHash) { 
+                updateTransactions(e, blockHash) 
+            }, 15000);
+
+            var filter = web3.eth.filter('latest').watch(function(e, blockHash) {
+                updateTransactions(e, blockHash);
+                clearInterval(interval);
             });
         }
     };
@@ -408,8 +420,9 @@ observeTransactions = function(){
                 checkTransactionConfirmations(newDocument);
             }
 
-            // add price data
-            if(newDocument.timestamp &&
+            // If on main net, add price data
+            if( Session.get('network') == 'main' && 
+                newDocument.timestamp &&
                (!newDocument.exchangeRates ||
                !newDocument.exchangeRates.btc ||
                !newDocument.exchangeRates.usd ||
@@ -426,7 +439,7 @@ observeTransactions = function(){
                     if(!e && res && res.statusCode === 200) {
                         var content = JSON.parse(res.content);
 
-                        if(content){
+                        if(content && content.Response !== "Error"){
                             _.each(content, function(price, key){
                                 if(price && _.isFinite(price)) {
                                     var name = key.toLowerCase();

app/client/lib/helpers/helperFunctions.js

@@ -18,14 +18,14 @@ Get the default contract example
 @method getDefaultContractExample
 **/
 Helpers.getDefaultContractExample = function(withoutPragma) {
-    const source = 'contract MyContract {\n    /* Constructor */\n    function MyContract() {\n\n    }\n}';
+    var source = 'contract MyContract {\n    /* Constructor */\n    function MyContract() {\n\n    }\n}';
 
     if (withoutPragma) {
         return source;
     } else {
         var solcVersion;
 
-        // Keep this for now as the Mist-API object will only be availabe from Mist version >= 0.8.9 
+        // Keep this for now as the Mist-API object will only be availabe from Mist version >= 0.8.9
         // so that older versions that will query code from wallet.ethereum.org won't use broken example code.
         if (typeof mist !== 'undefined' && mist.solidity && mist.solidity.version) {
             solcVersion = mist.solidity.version;
@@ -182,7 +182,7 @@ Helpers.showNotification = function(i18nText, values, callback) {
             // icon: 'http://cdn.sstatic.net/stackexchange/img/logos/so/so-icon.png',
             body: TAPi18n.__(i18nText +'.text', values),
         });
-        
+
         if(_.isFunction(callback))
             notification.onclick = callback;
     }
@@ -227,8 +227,8 @@ Gets the docuement matching the given addess from the EthAccounts or Wallets col
 Helpers.getAccountNameByAddress = function(address) {
     if (typeof address != 'undefined')
         var doc =  Helpers.getAccountByAddress(address.toLowerCase());
-    
-    return doc ? doc.name : address; 
+
+    return doc ? doc.name : address;
 };
 
 /**
@@ -262,7 +262,7 @@ Formats a timestamp to any format given.
 @return {String} The formated time
 **/
 Helpers.formatTime = function(time, format) { //parameters
-    
+
     // make sure not existing values are not Spacebars.kw
     if(format instanceof Spacebars.kw)
         format = null;
@@ -312,9 +312,9 @@ Helpers.formatTransactionBalance = function(value, exchangeRates, unit) {
 
         if(unit === 'btc')
             format += '[000000]';
-        else 
+        else
             format += '[0]';
-        
+
         var price = new BigNumber(String(web3.fromWei(value, 'ether')), 10).times(exchangeRates[unit].price);
         return EthTools.formatNumber(price, format) + ' '+ unit.toUpperCase();
     } else {
@@ -324,8 +324,8 @@ Helpers.formatTransactionBalance = function(value, exchangeRates, unit) {
 
 
 /**
-Formats an input and prepares it to be a template 
-    
+Formats an input and prepares it to be a template
+
     Helpers.createTemplateDataFromInput(abiFunctionInput);
 
 @method createTemplateDataFromInput
@@ -342,7 +342,7 @@ Helpers.createTemplateDataFromInput = function (input, key){
     input.displayName = input.name
         .replace(/([A-Z])/g, ' $1')
         .replace(/([\-\_])/g, '&thinsp;<span class="punctuation">$1</span>&thinsp;');
-        
+
     if(input.type.indexOf('[') === -1 &&
        (input.typeShort === 'string' ||
         input.typeShort === 'uint' ||
@@ -356,12 +356,12 @@ Helpers.createTemplateDataFromInput = function (input, key){
         input.template =  'elements_input_json';
     }
 
-    return input;    
+    return input;
 };
 
 /**
 Adds the input value from a form field to the inputs array
-    
+
 @method addInputValue
 @param {object} inputs          The current inputs
 @param {object} currentInput   The current input
@@ -373,7 +373,7 @@ Helpers.addInputValue = function (inputs, currentInput, formField){
             var value = _.isUndefined(input.value) ? '' : input.value;
 
             if(currentInput.name === input.name &&
-               currentInput.type === input.type && 
+               currentInput.type === input.type &&
                currentInput.index === input.index ) {
 
                 if(input.type.indexOf('[') !== -1) {
@@ -412,13 +412,13 @@ Takes a camelcase and shows it with spaces
 @return {string} sentence    The same name, sanitized, with spaces
 **/
 Helpers.toSentence = function (inputString, noHTML) {
-    if (typeof inputString == 'undefined') 
+    if (typeof inputString == 'undefined')
       return false;
     else {
-    	inputString = inputString.replace(/[^a-zA-Z0-9_]/g, '');
+        inputString = inputString.replace(/[^a-zA-Z0-9_]/g, '');
       if (noHTML === true) // only consider explicit true
         return inputString.replace(/([A-Z]+|[0-9]+)/g, ' $1').trim();
-      else 
+      else
         return inputString.replace(/([A-Z]+|[0-9]+)/g, ' $1').trim().replace(/([\_])/g, '<span class="dapp-punctuation">$1</span>');
     }
 }
@@ -428,9 +428,85 @@ Helpers.toSentence = function (inputString, noHTML) {
 Returns true if Main is the current network.
 
 @method isOnMainNetwork
-@return {Bool} 
+@return {Bool}
 **/
 Helpers.isOnMainNetwork = function () {
     return Session.get('network') == 'main';
 };
 
+/**
+ENS Functions
+**/
+var sha3 = function(str, opt) {
+  return '0x' + web3.sha3(str, opt).replace('0x','');
+};
+
+function namehash(name) {
+    var node = '0x0000000000000000000000000000000000000000000000000000000000000000';
+    if (name != '') {
+        var labels = name.split(".");
+        for(var i = labels.length - 1; i >= 0; i--) {
+            node = sha3(node + sha3(labels[i]).slice(2), {encoding: 'hex'});
+        }
+    }
+    return node.toString();
+}
+
+
+var ensContractAbi = [{"constant":true,"inputs":[{"name":"node","type":"bytes32"}],"name":"resolver","outputs":[{"name":"","type":"address"}],"payable":false,"type":"function"},{"constant":true,"inputs":[{"name":"node","type":"bytes32"}],"name":"owner","outputs":[{"name":"","type":"address"}],"payable":false,"type":"function"},{"constant":false,"inputs":[{"name":"node","type":"bytes32"},{"name":"label","type":"bytes32"},{"name":"owner","type":"address"}],"name":"setSubnodeOwner","outputs":[],"payable":false,"type":"function"},{"constant":false,"inputs":[{"name":"node","type":"bytes32"},{"name":"ttl","type":"uint64"}],"name":"setTTL","outputs":[],"payable":false,"type":"function"},{"constant":true,"inputs":[{"name":"node","type":"bytes32"}],"name":"ttl","outputs":[{"name":"","type":"uint64"}],"payable":false,"type":"function"},{"constant":false,"inputs":[{"name":"node","type":"bytes32"},{"name":"resolver","type":"address"}],"name":"setResolver","outputs":[],"payable":false,"type":"function"},{"constant":false,"inputs":[{"name":"node","type":"bytes32"},{"name":"owner","type":"address"}],"name":"setOwner","outputs":[],"payable":false,"type":"function"},{"anonymous":false,"inputs":[{"indexed":true,"name":"node","type":"bytes32"},{"indexed":false,"name":"owner","type":"address"}],"name":"Transfer","type":"event"},{"anonymous":false,"inputs":[{"indexed":true,"name":"node","type":"bytes32"},{"indexed":true,"name":"label","type":"bytes32"},{"indexed":false,"name":"owner","type":"address"}],"name":"NewOwner","type":"event"},{"anonymous":false,"inputs":[{"indexed":true,"name":"node","type":"bytes32"},{"indexed":false,"name":"resolver","type":"address"}],"name":"NewResolver","type":"event"},{"anonymous":false,"inputs":[{"indexed":true,"name":"node","type":"bytes32"},{"indexed":false,"name":"ttl","type":"uint64"}],"name":"NewTTL","type":"event"}];
+
+var resolverContractAbi = [{"constant":true,"inputs":[{"name":"interfaceID","type":"bytes4"}],"name":"supportsInterface","outputs":[{"name":"","type":"bool"}],"payable":false,"type":"function"},{"constant":true,"inputs":[{"name":"node","type":"bytes32"},{"name":"contentTypes","type":"uint256"}],"name":"ABI","outputs":[{"name":"contentType","type":"uint256"},{"name":"data","type":"bytes"}],"payable":false,"type":"function"},{"constant":false,"inputs":[{"name":"node","type":"bytes32"},{"name":"x","type":"bytes32"},{"name":"y","type":"bytes32"}],"name":"setPubkey","outputs":[],"payable":false,"type":"function"},{"constant":true,"inputs":[{"name":"node","type":"bytes32"}],"name":"content","outputs":[{"name":"ret","type":"bytes32"}],"payable":false,"type":"function"},{"constant":true,"inputs":[{"name":"node","type":"bytes32"}],"name":"addr","outputs":[{"name":"ret","type":"address"}],"payable":false,"type":"function"},{"constant":false,"inputs":[{"name":"node","type":"bytes32"},{"name":"contentType","type":"uint256"},{"name":"data","type":"bytes"}],"name":"setABI","outputs":[],"payable":false,"type":"function"},{"constant":true,"inputs":[{"name":"node","type":"bytes32"}],"name":"name","outputs":[{"name":"ret","type":"string"}],"payable":false,"type":"function"},{"constant":false,"inputs":[{"name":"node","type":"bytes32"},{"name":"name","type":"string"}],"name":"setName","outputs":[],"payable":false,"type":"function"},{"constant":false,"inputs":[{"name":"node","type":"bytes32"},{"name":"hash","type":"bytes32"}],"name":"setContent","outputs":[],"payable":false,"type":"function"},{"constant":true,"inputs":[{"name":"node","type":"bytes32"}],"name":"pubkey","outputs":[{"name":"x","type":"bytes32"},{"name":"y","type":"bytes32"}],"payable":false,"type":"function"},{"constant":false,"inputs":[{"name":"node","type":"bytes32"},{"name":"addr","type":"address"}],"name":"setAddr","outputs":[],"payable":false,"type":"function"},{"inputs":[{"name":"ensAddr","type":"address"}],"payable":false,"type":"constructor"},{"anonymous":false,"inputs":[{"indexed":true,"name":"node","type":"bytes32"},{"indexed":false,"name":"a","type":"address"}],"name":"AddrChanged","type":"event"},{"anonymous":false,"inputs":[{"indexed":true,"name":"node","type":"bytes32"},{"indexed":false,"name":"hash","type":"bytes32"}],"name":"ContentChanged","type":"event"},{"anonymous":false,"inputs":[{"indexed":true,"name":"node","type":"bytes32"},{"indexed":false,"name":"name","type":"string"}],"name":"NameChanged","type":"event"},{"anonymous":false,"inputs":[{"indexed":true,"name":"node","type":"bytes32"},{"indexed":true,"name":"contentType","type":"uint256"}],"name":"ABIChanged","type":"event"},{"anonymous":false,"inputs":[{"indexed":true,"name":"node","type":"bytes32"},{"indexed":false,"name":"x","type":"bytes32"},{"indexed":false,"name":"y","type":"bytes32"}],"name":"PubkeyChanged","type":"event"}];
+
+var ensAddress = '0x314159265dd8dbb310642f98f50c066173c1259b';
+
+
+/**
+Returns a string, given an address
+
+@method getENSName
+**/
+Helpers.getENSName = function(address, callback) {
+
+    if (Session.get('network') !== 'main' ) {
+        callback('Cannot retrieve ENS addresses unless fully synced on main chain', null, null);
+        return;
+    }
+    var node = namehash(address.toLowerCase().replace('0x','')+'.addr.reverse');
+    var ensContract = web3.eth.contract(ensContractAbi);
+    var resolverContract = web3.eth.contract(resolverContractAbi);
+
+    // instantiate ens
+    ensContract.at(ensAddress, function(err, ens) {
+        // get a resolver address for that name
+        ens.resolver(node, function(err, resolverAddress) {
+            if (err) callback(err, null, null);
+            else if (resolverAddress == 0) callback('no resolver address', null, null);
+            else {
+                // if you find one, find the name on that resolver
+                resolverContract.at(resolverAddress).name(node, function(error, name) {
+                    if (err) callback(err, null, null);
+                    else if (name == 0) callback('Found resolver but no name', null, null);
+                    else {
+                        // any address can claim any name, we need to check the name now
+                        var node = namehash(name);
+                        // get a resolver address for that name
+                        ens.resolver(node, function (err, resolverAddress) {
+                            if (err) callback(err, null, null);
+                            else if (resolverAddress == 0) callback('Name has no resolver', null, null);
+                            else {
+                                // if you find one, find the addr of that resolver
+                                resolverContract.at(resolverAddress).addr(node, function(error, returnAddr) {
+                                    if (err) callback(err, null, null);
+                                    else if (returnAddr == 0) callback('No address returned', null, null);
+                                    else {
+                                        callback(error, name, returnAddr);
+                                    }
+                                })
+                            }
+                        })
+                    }
+                })
+            }
+        })
+    });
+}