Implement chrome.experimental.downloads.onChanged

net/tools/testserver/testserver.py

 #!/usr/bin/env python
 # 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.
 
 """This is a simple HTTP/FTP/SYNC/TCP/UDP/ server used for testing Chrome.
 
 It supports several test URLs, as specified by the handlers in TestPageHandler.
 By default, it listens on an ephemeral port and sends the port number back to
 the originating process over a pipe. The originating process can specify an
@@ skipping 891 matching lines @@
 
     return True
 
   def FileHandler(self):
     """This handler sends the contents of the requested file.  Wow, it's like
     a real webserver!"""
     prefix = self.server.file_root_url
     if not self.path.startswith(prefix):
       return False
     # Consume a request body if present.
-    if self.command == 'POST' or self.command == 'PUT' :
+    if self.command == 'POST' or self.command == 'PUT':
       self.ReadRequestBody()
+    _, _, _, _, query_str, _ = urlparse.urlparse(self.path)

[cbentzel, 2012/02/13 19:23:38]

Feels like expected_headers and expected_body should move into 
_FileHandlerHelper. May need to change how the body gets consumed here and
PostOnlyFileHandler to make that work. 

Another thought for these tests - could you just use the EchoAllHandler instead?
Might need to modify it to report the method used. 

[benjhayden, 2012/02/13 21:05:31]

Done.
The downloads extension api does not provide any way to access the contents of
downloaded files.
I'd rather not depend on an unrelated API such as the HTML5 File api unless
absolutely necessary in case that API changes, and so that I don't have to
figure out how.

+    query_dict = cgi.parse_qs(query_str)
+    expected_headers = query_dict.get('expected_headers', [])
+    for expected_header in expected_headers:
+      header_name, expected_value = expected_header.split(':')
+      if self.headers.getheader(header_name) != expected_value:
+        self.send_response(404)
+        self.end_headers()
+        self.wfile.write('')
+        return True
     return self._FileHandlerHelper(prefix)
 
   def PostOnlyFileHandler(self):
     """This handler sends the contents of the requested file on a POST."""
     prefix = urlparse.urljoin(self.server.file_root_url, 'post/')
     if not self.path.startswith(prefix):
       return False
-    self.ReadRequestBody()
+    body = self.ReadRequestBody()
+    _, _, _, _, query_str, _ = urlparse.urlparse(self.path)
+    query_dict = cgi.parse_qs(query_str)
+    expected_body = query_dict.get('expected_body', [])
+    if expected_body and body not in expected_body:
+      self.send_response(404)
+      self.end_headers()
+      self.wfile.write('')
+      return True
     return self._FileHandlerHelper(prefix)
 
   def _FileHandlerHelper(self, prefix):
     _, _, url_path, _, query, _ = urlparse.urlparse(self.path)
     sub_path = url_path[len(prefix):]
     entries = sub_path.split('/')
     file_path = os.path.join(self.server.data_dir, *entries)
     if os.path.isdir(file_path):
       file_path = os.path.join(file_path, 'index.html')
 
@@ skipping 1073 matching lines @@
                            'random key if none is specified on the command '
                            'line.')
   option_parser.add_option('', '--policy-user', default='user@example.com',
                            dest='policy_user',
                            help='Specify the user name the server should '
                            'report back to the client as the user owning the '
                            'token used for making the policy request.')
   options, args = option_parser.parse_args()
 
   sys.exit(main(options, args))