Add Resource Handler for creating Streams to forward to extensions

content/browser/loader/stream_resource_handler.h

Index: content/browser/loader/stream_resource_handler.h
diff --git a/content/browser/loader/certificate_resource_handler.h b/content/browser/loader/stream_resource_handler.h
similarity index 53%
copy from content/browser/loader/certificate_resource_handler.h
copy to content/browser/loader/stream_resource_handler.h
index 428063aba47fa2b36213e724a812271a19f55b74..04d4d420382edc38e706d89905ce9e2a5a8fcddf 100644
--- a/content/browser/loader/certificate_resource_handler.h
+++ b/content/browser/loader/stream_resource_handler.h
@@ -1,40 +1,32 @@
-// Copyright (c) 2012 The Chromium Authors. All rights reserved.
+// Copyright (c) 2013 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.
 
-#ifndef CONTENT_BROWSER_LOADER_CERTIFICATE_RESOURCE_HANDLER_H_
-#define CONTENT_BROWSER_LOADER_CERTIFICATE_RESOURCE_HANDLER_H_
+#ifndef CONTENT_BROWSER_LOADER_STREAM_RESOURCE_HANDLER_H_
+#define CONTENT_BROWSER_LOADER_STREAM_RESOURCE_HANDLER_H_
 
-#include <string>
-#include <utility>
-#include <vector>
-
-#include "base/compiler_specific.h"
 #include "base/memory/ref_counted.h"
 #include "base/memory/scoped_ptr.h"
 #include "content/browser/loader/resource_handler.h"
+#include "content/browser/streams/stream_write_observer.h"
 #include "googleurl/src/gurl.h"
-#include "net/base/mime_util.h"
 
 namespace net {
-class IOBuffer;
 class URLRequest;
-class URLRequestStatus;
 }  // namespace net
 
 namespace content {
 
-// This class handles certificate mime types such as:
-// - "application/x-x509-user-cert"
-// - "application/x-x509-ca-cert"
-// - "application/x-pkcs12"
-//
-class CertificateResourceHandler : public ResourceHandler {
+class StreamRegistry;
+
+// Redirect this resource to a stream.
+class StreamResourceHandler : public StreamWriteObserver,
+                              public ResourceHandler {
  public:
-  CertificateResourceHandler(net::URLRequest* request,
-                             int render_process_host_id,
-                             int render_view_id);
-  virtual ~CertificateResourceHandler();
+  StreamResourceHandler(net::URLRequest* request,
+                        StreamRegistry* registry,
+                        const GURL& security_origin);
+  virtual ~StreamResourceHandler();
 
   virtual bool OnUploadProgress(int request_id,
                                 uint64 position,
@@ -46,12 +38,10 @@ class CertificateResourceHandler : public ResourceHandler {
                                    ResourceResponse* resp,
                                    bool* defer) OVERRIDE;
 
-  // Check if this indeed an X509 cert.
   virtual bool OnResponseStarted(int request_id,
                                  ResourceResponse* resp,
                                  bool* defer) OVERRIDE;
 
-  // Pass-through implementation.
   virtual bool OnWillStart(int request_id,
                            const GURL& url,
                            bool* defer) OVERRIDE;
@@ -62,39 +52,29 @@ class CertificateResourceHandler : public ResourceHandler {
                           int* buf_size,
                           int min_size) OVERRIDE;
 
-  // A read was completed, maybe allocate a new buffer for further data.
+  // A read was completed, forward the data to the Stream.
   virtual bool OnReadCompleted(int request_id,
                                int bytes_read,
                                bool* defer) OVERRIDE;
 
-  // Done downloading the certificate.
   virtual bool OnResponseCompleted(int request_id,
                                    const net::URLRequestStatus& urs,
                                    const std::string& sec_info) OVERRIDE;
 
-  // N/A to cert downloading.
   virtual void OnDataDownloaded(int request_id, int bytes_downloaded) OVERRIDE;
 
- private:
-  typedef std::vector<std::pair<scoped_refptr<net::IOBuffer>,
-                                size_t> > ContentVector;
+  scoped_refptr<Stream> stream() { return stream_; }
 
-  void AssembleResource();
+ private:
+  virtual void OnSpaceAvailable(Stream* stream) OVERRIDE;
 
-  GURL url_;
   net::URLRequest* request_;
-  size_t content_length_;
-  ContentVector buffer_;
+  scoped_refptr<Stream> stream_;
   scoped_refptr<net::IOBuffer> read_buffer_;
-  scoped_refptr<net::IOBuffer> resource_buffer_;  // Downloaded certificate.
-  // The id of the |RenderProcessHost| which started the download.
-  int render_process_host_id_;
-  // The id of the |RenderView| which started the download.
-  int render_view_id_;
-  net::CertificateMimeType cert_type_;
-  DISALLOW_COPY_AND_ASSIGN(CertificateResourceHandler);
+  DISALLOW_COPY_AND_ASSIGN(StreamResourceHandler);
 };
 
 }  // namespace content
 
-#endif  // CONTENT_BROWSER_LOADER_CERTIFICATE_RESOURCE_HANDLER_H_
+#endif  // CONTENT_BROWSER_LOADER_STREAM_RESOURCE_HANDLER_H_
+