1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
|
// Copyright 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.
#include "content/renderer/pepper/url_response_info_util.h"
#include <stdint.h>
#include "base/bind.h"
#include "base/files/file_path.h"
#include "base/location.h"
#include "base/single_thread_task_runner.h"
#include "base/threading/thread_task_runner_handle.h"
#include "content/public/renderer/renderer_ppapi_host.h"
#include "content/renderer/pepper/pepper_file_ref_renderer_host.h"
#include "content/renderer/pepper/renderer_ppapi_host_impl.h"
#include "ipc/ipc_message.h"
#include "ppapi/proxy/ppapi_messages.h"
#include "ppapi/shared_impl/url_response_info_data.h"
#include "third_party/WebKit/public/platform/FilePathConversion.h"
#include "third_party/WebKit/public/platform/WebHTTPHeaderVisitor.h"
#include "third_party/WebKit/public/platform/WebString.h"
#include "third_party/WebKit/public/platform/WebURL.h"
#include "third_party/WebKit/public/platform/WebURLResponse.h"
using blink::WebHTTPHeaderVisitor;
using blink::WebString;
using blink::WebURLResponse;
namespace content {
namespace {
class HeadersToString : public WebHTTPHeaderVisitor {
public:
HeadersToString() {}
~HeadersToString() override {}
const std::string& buffer() const { return buffer_; }
void VisitHeader(const WebString& name, const WebString& value) override {
if (!buffer_.empty())
buffer_.append("\n");
buffer_.append(name.Utf8());
buffer_.append(": ");
buffer_.append(value.Utf8());
}
private:
std::string buffer_;
};
bool IsRedirect(int32_t status) { return status >= 300 && status <= 399; }
void DidCreateResourceHosts(const ppapi::URLResponseInfoData& in_data,
const base::FilePath& external_path,
int renderer_pending_host_id,
const DataFromWebURLResponseCallback& callback,
const std::vector<int>& browser_pending_host_ids) {
DCHECK_EQ(1U, browser_pending_host_ids.size());
int browser_pending_host_id = 0;
if (browser_pending_host_ids.size() == 1)
browser_pending_host_id = browser_pending_host_ids[0];
ppapi::URLResponseInfoData data = in_data;
data.body_as_file_ref =
ppapi::MakeExternalFileRefCreateInfo(external_path,
std::string(),
browser_pending_host_id,
renderer_pending_host_id);
callback.Run(data);
}
} // namespace
void DataFromWebURLResponse(RendererPpapiHostImpl* host_impl,
PP_Instance pp_instance,
const WebURLResponse& response,
const DataFromWebURLResponseCallback& callback) {
ppapi::URLResponseInfoData data;
data.url = response.Url().GetString().Utf8();
data.status_code = response.HttpStatusCode();
data.status_text = response.HttpStatusText().Utf8();
if (IsRedirect(data.status_code)) {
data.redirect_url =
response.HttpHeaderField(WebString::FromUTF8("Location")).Utf8();
}
HeadersToString headers_to_string;
response.VisitHTTPHeaderFields(&headers_to_string);
data.headers = headers_to_string.buffer();
WebString file_path = response.DownloadFilePath();
if (!file_path.IsEmpty()) {
base::FilePath external_path = blink::WebStringToFilePath(file_path);
// TODO(teravest): Write a utility function to create resource hosts in the
// renderer and browser.
PepperFileRefRendererHost* renderer_host =
new PepperFileRefRendererHost(host_impl, pp_instance, 0, external_path);
int renderer_pending_host_id =
host_impl->GetPpapiHost()->AddPendingResourceHost(
std::unique_ptr<ppapi::host::ResourceHost>(renderer_host));
std::vector<IPC::Message> create_msgs;
create_msgs.push_back(PpapiHostMsg_FileRef_CreateForRawFS(external_path));
host_impl->CreateBrowserResourceHosts(pp_instance,
create_msgs,
base::Bind(&DidCreateResourceHosts,
data,
external_path,
renderer_pending_host_id,
callback));
} else {
base::ThreadTaskRunnerHandle::Get()->PostTask(
FROM_HERE, base::BindOnce(callback, data));
}
}
} // namespace content
|
