filter_dividend_pathways_by_dividendRate()

filter_dividend_pathways_by_dividendRate.js

 // This first function in swarm_redistribution.js filters out the dividend pathway that is 
 // closest to the dividendRate of the dividend that is being issued. 
 // Since nodes can change their dividendRates at any time, you might have multiple
 // dividend pathways in different dividendRates. 
 
 // filter_dividend_pathways_by_dividendRate() filters out if an account has multiple dividendRates, 
 // and sorts by the rate closest to the dividendRate of the dividend pathway of the account 
 // that was passed into the function.


  filter_dividend_pathways_by_dividendRate(account, currency, dividendRate_X, function(doc_filtered){console.log(doc_filtered)})  
  function filter_dividend_pathways_by_dividendRate(account, currency, dividendRate_X, callback){
       db.collection(account).find({ type:"dividend_pathway", currency: currency, dividendRate: { $lte: dividendRate_X} },function (err, doc){
           var filtered_docs = []    
           async.each(doc, function(obj, callback){
            
           if(JSON.stringify(filtered_docs).indexOf(obj.account) === -1){
               filtered_docs.push(obj)
               }
               else{
 
               // If the account already has a doc, check if dividendRate is lower than the previous, 
               // and filter out the highest one.
               
               Array.prototype.filterObjects = function(key, value) {
                   return this.filter(function(x) { return x[key] === value; })
               }
               
               var a = filtered_docs.filterObjects("account", obj.account);
                
               if(a[0].dividendRate > obj.dividendRate){  
               filtered_docs = filtered_docs.filter(function (el) {
                        return el.account !== obj.account;
                       });
            
               filtered_docs.push(obj)                   
               }
                   
               }

    callback();

}, function(err) {
callback(filtered_docs)
});  


  
       })
       
  }