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
|
// Copyright 2016 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 "modules/serviceworkers/ForeignFetchRespondWithObserver.h"
#include "core/fetch/CrossOriginAccessControl.h"
#include "modules/fetch/Response.h"
#include "modules/serviceworkers/ForeignFetchResponse.h"
namespace blink {
ForeignFetchRespondWithObserver* ForeignFetchRespondWithObserver::create(
ExecutionContext* context,
int eventID,
const KURL& requestURL,
WebURLRequest::FetchRequestMode requestMode,
WebURLRequest::FetchRedirectMode redirectMode,
WebURLRequest::FrameType frameType,
WebURLRequest::RequestContext requestContext,
PassRefPtr<SecurityOrigin> requestOrigin,
WaitUntilObserver* observer) {
return new ForeignFetchRespondWithObserver(
context, eventID, requestURL, requestMode, redirectMode, frameType,
requestContext, std::move(requestOrigin), observer);
}
void ForeignFetchRespondWithObserver::responseWasFulfilled(
const ScriptValue& value) {
ASSERT(getExecutionContext());
ExceptionState exceptionState(value.isolate(), ExceptionState::UnknownContext,
"ForeignFetchEvent", "respondWith");
ForeignFetchResponse foreignFetchResponse =
ScriptValue::to<ForeignFetchResponse>(toIsolate(getExecutionContext()),
value, exceptionState);
if (exceptionState.hadException()) {
exceptionState.clearException();
responseWasRejected(WebServiceWorkerResponseErrorNoForeignFetchResponse);
return;
}
Response* response = foreignFetchResponse.response();
const FetchResponseData* internalResponse = response->response();
const bool isOpaque =
internalResponse->getType() == FetchResponseData::OpaqueType ||
internalResponse->getType() == FetchResponseData::OpaqueRedirectType;
if (internalResponse->getType() != FetchResponseData::DefaultType)
internalResponse = internalResponse->internalResponse();
if (!foreignFetchResponse.hasOrigin()) {
if (foreignFetchResponse.hasHeaders() &&
!foreignFetchResponse.headers().isEmpty()) {
responseWasRejected(
WebServiceWorkerResponseErrorForeignFetchHeadersWithoutOrigin);
return;
}
// If response isn't already opaque, make it opaque.
if (!isOpaque) {
FetchResponseData* opaqueData =
internalResponse->createOpaqueFilteredResponse();
response = Response::create(getExecutionContext(), opaqueData);
}
} else if (m_requestOrigin->toString() != foreignFetchResponse.origin()) {
responseWasRejected(
WebServiceWorkerResponseErrorForeignFetchMismatchedOrigin);
return;
} else if (!isOpaque) {
HTTPHeaderSet headers;
if (foreignFetchResponse.hasHeaders()) {
for (const String& header : foreignFetchResponse.headers())
headers.add(header);
if (response->response()->getType() == FetchResponseData::CORSType) {
const HTTPHeaderSet& existingHeaders =
response->response()->corsExposedHeaderNames();
HTTPHeaderSet headersToRemove;
for (HTTPHeaderSet::iterator it = headers.begin(); it != headers.end();
++it) {
if (!existingHeaders.contains(*it))
headersToRemove.add(*it);
}
headers.removeAll(headersToRemove);
}
}
FetchResponseData* responseData =
internalResponse->createCORSFilteredResponse(headers);
response = Response::create(getExecutionContext(), responseData);
}
RespondWithObserver::responseWasFulfilled(
ScriptValue::from(value.getScriptState(), response));
}
ForeignFetchRespondWithObserver::ForeignFetchRespondWithObserver(
ExecutionContext* context,
int eventID,
const KURL& requestURL,
WebURLRequest::FetchRequestMode requestMode,
WebURLRequest::FetchRedirectMode redirectMode,
WebURLRequest::FrameType frameType,
WebURLRequest::RequestContext requestContext,
PassRefPtr<SecurityOrigin> requestOrigin,
WaitUntilObserver* observer)
: RespondWithObserver(context,
eventID,
requestURL,
requestMode,
redirectMode,
frameType,
requestContext,
observer),
m_requestOrigin(requestOrigin) {}
} // namespace blink
|
