forgot to add db insert for instagram stream

will-horning · Jul 29, 2014 · fa639a3 · fa639a3
1 parent 8008118
commit fa639a3
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/instagram_stream.js b/instagram_stream.js
@@ -15,11 +15,11 @@ var addToQueue = function(db, new_instagram){
         queue.find({}, function(err, instagrams){
             if(instagrams.length > config.mongo.QUEUE_SIZE){
                 var sorted_instagrams = _.sortBy(instagrams, function(ig){
-                    return ig.created_time
+                    return ig.created_time;
                 });
                 queue.remove(sorted_tweets[0]);
             }
-        })
+        });
     });
 };
 
@@ -91,6 +91,9 @@ module.exports = function(app, io, db){
                     return true;
                 }
             });
+            _.forEach(results, function(result){
+                addToQueue(result);
+            });
             if(results.length > 0){
                 io.emit('instagram', results);
             }