Docserver: Run tasks in testing

chrome/common/extensions/docs/server2/appengine_wrappers.py

 # Copyright (c) 2012 The Chromium Authors. All rights reserved.
 # Use of this source code is governed by a BSD-style license that can be
 # found in the LICENSE file.
 
 def IsDeadlineExceededError(error):
   '''A general way of determining whether |error| is a DeadlineExceededError,
   since there are 3 different types thrown by AppEngine and we might as well
   handle them all the same way. For more info see:
   https://developers.google.com/appengine/articles/deadlineexceedederrors
   '''
@@ skipping 259 matching lines @@
       return _RPC()
 
     @staticmethod
     def put_async(value):
       db._store[value.key] = value
       return _RPC()
 
   class BlobReferenceProperty(object):
     pass
 
-  class FakeTaskQueue(object):
+  # Executes any queued tasks synchronously as they are queued.
+  _task_runner = None
+
+  def SetTaskRunnerForTest(task_runner):
+    global _task_runner
+    _task_runner = task_runner
+
+  class SynchronousTaskQueue(object):
     class Task(object):
       def __init__(self, url=None, params={}):
-        pass
+        self.url_ = url
+        self.params_ = params
+
+      def GetUrl(self):
+        return self.url_
+
+      def GetCommit(self):
+        return self.params_.get('commit')
 
     class Queue(object):
       def __init__(self, name='default'):
         pass
 
       def add(self, task):
+        global _task_runner
+        if _task_runner:
+          _task_runner(task.GetUrl(), task.GetCommit())
         return _RPC()
 
       def purge(self):
         return _RPC()
 
-  taskqueue = FakeTaskQueue()
+  taskqueue = SynchronousTaskQueue()