Fix a weird bug and optimize code

AnyFetch · Jul 8, 2014 · b757f3d · b757f3d
1 parent 3bd4fc2
commit b757f3d
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 14 deletions.
diff --git a/lib/handlers/update.js b/lib/handlers/update.js
@@ -64,6 +64,7 @@ module.exports = function(updateAccount, queue, workers) {
         function updateToken(queues, newCursor, providerData, cb) {
           if(providerData) {
             token.data = providerData;
+            token.markModified('data');
           }
           token.cursor = newCursor;
           token.isUpdating = false;
@@ -73,7 +74,8 @@ module.exports = function(updateAccount, queue, workers) {
         function executeQueue(queues, cb) {
           Object.keys(workers).forEach(function(name) {
             queues[name].forEach(function(task) {
-              task.anyfetchToken = token.anyfetchToken;
+              task._anyfetchToken = token.anyfetchToken;
+              task._data = token.data;
 
               queue.create(name, task).save();
             });

diff --git a/lib/index.js b/lib/index.js
@@ -60,21 +60,14 @@ module.exports.createServer = function createServer(connectFunctions, updateAcco
   Object.keys(workers).forEach(function createQueue(name) {
     server.queue.process(name, (workers[name].concurrency) ? workers[name].concurrency : 1, function(job, done) {
       job.task = job.data;
+      job.anyfetchClient = new Anyfetch(job.task._anyfetchToken);
+      job.serviceData = job.task._data;
 
-      job.anyfetchClient = new Anyfetch(job.task.anyfetchToken);
+      delete job.data;
+      delete job.task._data;
+      delete job.task._anyfetchToken;
 
-      Token.findOne({anyfetchToken: job.task.anyfetchToken}, function(err, token) {
-        if(err) {
-          done(err);
-        }
-
-        job.serviceData = token.data;
-
-        delete job.data;
-        delete job.task.anyfetchToken;
-
-        workers[name](job, done);
-      });
+      workers[name](job, done);
     });
   });