mike-m-5.js

processFeed = function(item, feedID, lastFeedInserted) {
  console.log("last inserted: " + lastFeedInserted + " New feed: " + item.title);
  Feeds.insert({
    feedID: feedID,
    title: item.title
  });
};
  Meteor.methods({
    addFeeds: function() {
    try {

      var allowedUrls = AllowedUrls.find();
      var Future  = Npm.require('fibers/future');

      allowedUrls.forEach(function(url) {
        var lastFeedInserted = Feeds.findOne({ feedID: url._id });
        
        request(url.feedUrl)
        .pipe(new FeedParser())
        .on('error', function(error) {
        })// always handle errors
        .on('meta', function (meta) {   
        })// do something
        .on('readable', function () {

          console.log("onreadable called");
          //===============================================================
          //  Get the last inserted feed
          // iterate through new fetched feeds
          //  check if the feed mathces last inserted feed
          //      if it does NOT, save it
          //===============================================================
          var future = new Future();
          var stream = this;
          future.return(stream.read());

          var item;
          var bool = true;


          while (item = future.wait() && bool) {
            console.log("bool:      ", bool);
            if (lastFeedInserted) {
              if (lastFeedInserted.title !== item.title) {
                console.log("processFeed");
                var processFeedOptions = {
                  item: item,
                  feedID: url._id,
                  lastFeedInserted: lastFeedInserted
                }
                console.log("sucess!!!, feed iserted");
              } else {
                console.log("bool is being set to false");
                bool = false;
                break;
              }
            } else {
              var processFeedOptions = {
                item: item,
                feedID: url._id,
                lastFeedInserted: lastFeedInserted
              }
              console.log("brand new feed inserted");
            }
            // Calling a common processFeed so as to not duplicate code.
            Meteor.bindEnvironment(function(processFeedOptions){
              processFeed(processFeedOptions);
            }, function(e){
              throw e;
            });
          }
        });
      });
    } catch(e) {
      console.log("I should go home.", e);
    }
  }
});