Left: | ||
Right: |
LEFT | RIGHT |
---|---|
1 #include "PluginStdAfx.h" | 1 #include "PluginStdAfx.h" |
2 | 2 |
3 #include "PluginWbPassThrough.h" | 3 #include "PluginWbPassThrough.h" |
4 #include "PluginClient.h" | 4 #include "PluginClient.h" |
5 #include "PluginClientFactory.h" | 5 #include "PluginClientFactory.h" |
6 #ifdef SUPPORT_FILTER | |
7 #include "PluginFilter.h" | 6 #include "PluginFilter.h" |
8 #endif | |
9 #include "PluginSettings.h" | 7 #include "PluginSettings.h" |
10 #include "PluginClass.h" | 8 #include "PluginClass.h" |
11 #include "PluginSystem.h" | 9 #include "PluginSystem.h" |
10 #include <WinInet.h> | |
11 #include "wtypes.h" | |
12 #include "../shared/Utils.h" | |
12 #include "../shared/IE_version.h" | 13 #include "../shared/IE_version.h" |
13 #include "wtypes.h" | 14 |
14 | 15 namespace |
15 EXTERN_C IMAGE_DOS_HEADER __ImageBase; | 16 { |
16 | 17 const std::string g_blockedByABPPage = "<!DOCTYPE html>" |
17 | 18 "<html>" |
18 | 19 "<body>" |
19 int WBPassthruSink::GetContentTypeFromMimeType(CString mimeType) | 20 "<!-- blocked by AdblockPlus -->" |
21 "</body>" | |
22 "</html>"; | |
23 | |
24 template <class T> | |
25 T ExtractHttpHeader(const T& allHeaders, const T& targetHeaderNameWithColon, c onst T& delimiter) | |
26 { | |
27 auto targetHeaderBeginsAt = allHeaders.find(targetHeaderNameWithColon); | |
28 if (targetHeaderBeginsAt == T::npos) | |
29 { | |
30 return T(); | |
31 } | |
32 targetHeaderBeginsAt += targetHeaderNameWithColon.length(); | |
33 auto targetHeaderEndsAt = allHeaders.find(delimiter, targetHeaderBeginsAt); | |
34 if (targetHeaderEndsAt == T::npos) | |
35 { | |
36 return T(); | |
37 } | |
38 return allHeaders.substr(targetHeaderBeginsAt, targetHeaderEndsAt - targetHe aderBeginsAt); | |
39 } | |
40 | |
41 std::string ExtractHttpAcceptHeader(IInternetProtocol* internetProtocol) | |
42 { | |
43 // Despite there being HTTP_QUERY_ACCEPT and other query info flags, they do n't work here, | |
44 // only HTTP_QUERY_RAW_HEADERS_CRLF | HTTP_QUERY_FLAG_REQUEST_HEADERS does w ork. | |
45 ATL::CComPtr<IWinInetHttpInfo> winInetHttpInfo; | |
46 HRESULT hr = internetProtocol->QueryInterface(&winInetHttpInfo); | |
47 if (FAILED(hr) || !winInetHttpInfo) | |
48 { | |
49 return ""; | |
50 } | |
51 DWORD size = 0; | |
52 DWORD flags = 0; | |
53 DWORD queryOption = HTTP_QUERY_RAW_HEADERS_CRLF | HTTP_QUERY_FLAG_REQUEST_HE ADERS; | |
54 hr = winInetHttpInfo->QueryInfo(queryOption, /*buffer*/ nullptr, /*get size* / &size, &flags, /*reserved*/ 0); | |
55 if (FAILED(hr)) | |
56 { | |
57 return ""; | |
58 } | |
59 std::string buf(size, '\0'); | |
60 hr = winInetHttpInfo->QueryInfo(queryOption, &buf[0], &size, &flags, 0); | |
61 if (FAILED(hr)) | |
62 { | |
63 return ""; | |
64 } | |
65 return ExtractHttpHeader<std::string>(buf, "Accept:", "\r\n"); | |
66 } | |
67 | |
68 bool IsXmlHttpRequest(const std::wstring& additionalHeaders) | |
69 { | |
70 auto requestedWithHeader = ExtractHttpHeader<std::wstring>(additionalHeaders , L"X-Requested-With:", L"\n"); | |
71 return TrimString(requestedWithHeader) == L"XMLHttpRequest"; | |
72 } | |
73 } | |
74 | |
75 WBPassthruSink::WBPassthruSink() | |
76 : m_currentPositionOfSentPage(0) | |
77 , m_contentType(CFilter::EContentType::contentTypeAny) | |
78 , m_isCustomResponse(false) | |
79 { | |
80 } | |
81 | |
82 int WBPassthruSink::GetContentTypeFromMimeType(const CString& mimeType) | |
20 { | 83 { |
21 if (mimeType.Find(L"image/") >= 0) | 84 if (mimeType.Find(L"image/") >= 0) |
22 { | 85 { |
23 return CFilter::contentTypeImage; | 86 return CFilter::contentTypeImage; |
24 } | 87 } |
25 if (mimeType.Find(L"text/css") >= 0) | 88 if (mimeType.Find(L"text/css") >= 0) |
26 { | 89 { |
27 return CFilter::contentTypeStyleSheet; | 90 return CFilter::contentTypeStyleSheet; |
28 } | 91 } |
29 if ((mimeType.Find(L"application/javascript") >= 0) || (mimeType.Find(L"applic ation/json") >= 0)) | 92 if ((mimeType.Find(L"application/javascript") >= 0) || (mimeType.Find(L"applic ation/json") >= 0)) |
(...skipping 10 matching lines...) Expand all Loading... | |
40 } | 103 } |
41 // It is important to have this check last, since it is rather generic, and mi ght overlay text/html, for example | 104 // It is important to have this check last, since it is rather generic, and mi ght overlay text/html, for example |
42 if (mimeType.Find(L"xml") >= 0) | 105 if (mimeType.Find(L"xml") >= 0) |
43 { | 106 { |
44 return CFilter::contentTypeXmlHttpRequest; | 107 return CFilter::contentTypeXmlHttpRequest; |
45 } | 108 } |
46 | 109 |
47 return CFilter::contentTypeAny; | 110 return CFilter::contentTypeAny; |
48 } | 111 } |
49 | 112 |
50 int WBPassthruSink::GetContentTypeFromURL(CString src) | 113 int WBPassthruSink::GetContentTypeFromURL(const CString& src) |
51 { | 114 { |
52 CString srcExt = src; | 115 CString srcExt = src; |
53 | 116 |
54 int pos = 0; | 117 int pos = 0; |
55 if ((pos = src.Find('?')) > 0) | 118 if ((pos = src.Find('?')) > 0) |
56 { | 119 { |
57 srcExt = src.Left(pos); | 120 srcExt = src.Left(pos); |
58 } | 121 } |
59 | 122 |
60 int lastDotIndex = srcExt.ReverseFind('.'); | 123 int lastDotIndex = srcExt.ReverseFind('.'); |
(...skipping 17 matching lines...) Expand all Loading... | |
78 return CFilter::contentTypeXmlHttpRequest; | 141 return CFilter::contentTypeXmlHttpRequest; |
79 } | 142 } |
80 else if (ext == L".swf") | 143 else if (ext == L".swf") |
81 { | 144 { |
82 return CFilter::contentTypeObject; | 145 return CFilter::contentTypeObject; |
83 } | 146 } |
84 else if (ext == L".jsp" || ext == L".php" || ext == L".html") | 147 else if (ext == L".jsp" || ext == L".php" || ext == L".html") |
85 { | 148 { |
86 return CFilter::contentTypeSubdocument; | 149 return CFilter::contentTypeSubdocument; |
87 } | 150 } |
88 else | 151 return CFilter::contentTypeAny; |
89 { | 152 } |
90 return CFilter::contentTypeAny & ~CFilter::contentTypeSubdocument; | 153 |
91 } | 154 int WBPassthruSink::GetContentType(const CString& mimeType, const std::wstring& domain, const CString& src) |
92 | |
93 } | |
94 | |
95 int WBPassthruSink::GetContentType(CString mimeType, CString domain, CString src ) | |
96 { | 155 { |
97 // No referer or mime type | 156 // No referer or mime type |
98 // BINDSTRING_XDR_ORIGIN works only for IE v8+ | 157 // BINDSTRING_XDR_ORIGIN works only for IE v8+ |
99 if (mimeType.IsEmpty() && domain.IsEmpty() && AdblockPlus::IE::InstalledMajorV ersion() >= 8) | 158 if (mimeType.IsEmpty() && domain.empty() && AdblockPlus::IE::InstalledMajorVer sion() >= 8) |
sergei
2015/01/06 13:39:11
Actually we are supporting only versions starting
Eric
2015/01/06 17:10:34
You and Oleksandr and I had a discussion about thi
| |
100 { | 159 { |
101 return CFilter::contentTypeXmlHttpRequest; | 160 return CFilter::contentTypeXmlHttpRequest; |
102 } | 161 } |
103 int contentType = GetContentTypeFromMimeType(mimeType); | 162 int contentType = GetContentTypeFromMimeType(mimeType); |
104 if (contentType == CFilter::contentTypeAny) | 163 if (contentType == CFilter::contentTypeAny) |
105 { | 164 { |
106 contentType = GetContentTypeFromURL(src); | 165 contentType = GetContentTypeFromURL(src); |
107 } | 166 } |
108 return contentType; | 167 return contentType; |
109 } | 168 } |
110 | 169 |
111 //////////////////////////////////////////////////////////////////////////////// //////// | 170 //////////////////////////////////////////////////////////////////////////////// //////// |
112 //WBPassthruSink | 171 //WBPassthruSink |
113 //Monitor and/or cancel every request and responde | 172 //Monitor and/or cancel every request and responde |
114 //WB makes, including images, sounds, scripts, etc | 173 //WB makes, including images, sounds, scripts, etc |
115 //////////////////////////////////////////////////////////////////////////////// //////// | 174 //////////////////////////////////////////////////////////////////////////////// //////// |
116 HRESULT WBPassthruSink::OnStart(LPCWSTR szUrl, IInternetProtocolSink *pOIProtSin k, | 175 HRESULT WBPassthruSink::OnStart(LPCWSTR szUrl, IInternetProtocolSink *pOIProtSin k, |
117 IInternetBindInfo *pOIBindInfo, DWORD grfPI, HAN DLE_PTR dwReserved, | 176 IInternetBindInfo *pOIBindInfo, DWORD grfPI, HAN DLE_PTR dwReserved, |
118 IInternetProtocol* pTargetProtocol) | 177 IInternetProtocol* pTargetProtocol, bool& handle d) |
119 { | 178 { |
120 | |
121 m_pTargetProtocol = pTargetProtocol; | 179 m_pTargetProtocol = pTargetProtocol; |
122 bool isBlocked = false; | 180 return BaseClass::OnStart(szUrl, pOIProtSink, pOIBindInfo, grfPI, dwReserved, pTargetProtocol); |
123 m_shouldBlock = false; | 181 } |
124 m_lastDataReported = false; | 182 |
125 CString src; | 183 HRESULT WBPassthruSink::OnRead(void* pv, ULONG cb, ULONG* pcbRead) |
126 src.Append(szUrl); | 184 { |
127 DEBUG_GENERAL(src); | 185 if (!pv || !pcbRead) |
128 CPluginClient::UnescapeUrl(src); | 186 { |
129 | 187 return E_POINTER; |
130 CString boundDomain; | 188 } |
131 CString mimeType; | 189 *pcbRead = 0; |
132 LPOLESTR mime[10]; | 190 |
133 if (pOIBindInfo) | 191 if (PassthroughAPP::CustomSinkStartPolicy<WBPassthru, WBPassthruSink>::GetProt ocol(this)->m_shouldSupplyCustomContent) |
134 { | 192 { |
135 ULONG resLen = 0; | 193 ULONG blockedByABPPageSize = static_cast<ULONG>(g_blockedByABPPage.size()); |
136 | 194 auto positionGrow = std::min<ULONG>(cb, static_cast<ULONG>(blockedByABPPageS ize - m_currentPositionOfSentPage)); |
137 // Apparently IE will report random mime type if there's more then 1 in the list. | 195 if (positionGrow == 0) { |
138 // So we get the whole list and just use the first one (top priority one) | 196 return S_FALSE; |
139 pOIBindInfo->GetBindString(BINDSTRING_ACCEPT_MIMES, mime, 10, &resLen); | 197 } |
140 if (mime && resLen > 0) | 198 std::copy(g_blockedByABPPage.begin(), g_blockedByABPPage.begin() + positionG row, |
141 { | 199 stdext::make_checked_array_iterator(static_cast<char*>(pv), cb)); |
142 mimeType.SetString(mime[0]); | 200 *pcbRead = positionGrow; |
143 } | 201 m_currentPositionOfSentPage += positionGrow; |
144 LPOLESTR bindToObject = 0; | 202 |
145 pOIBindInfo->GetBindString(BINDSTRING_FLAG_BIND_TO_OBJECT, &bindToObject, 1, &resLen); | 203 if (m_spInternetProtocolSink) |
146 LPOLESTR domainRetrieved = 0; | 204 { |
147 if (resLen == 0 || wcscmp(bindToObject, L"FALSE") == 0) | 205 m_spInternetProtocolSink->ReportData(BSCF_INTERMEDIATEDATANOTIFICATION, |
148 { | 206 static_cast<ULONG>(m_currentPositionOfSentPage), blockedByABPPageSize); |
149 HRESULT hr = pOIBindInfo->GetBindString(BINDSTRING_XDR_ORIGIN, &domainRetr ieved, 1, &resLen); | 207 } |
150 | 208 if (blockedByABPPageSize == m_currentPositionOfSentPage && m_spInternetProto colSink) |
151 if ((hr == S_OK) && domainRetrieved && (resLen > 0)) | 209 { |
152 { | 210 m_spInternetProtocolSink->ReportData(BSCF_DATAFULLYAVAILABLE, blockedByABP PageSize, blockedByABPPageSize); |
153 boundDomain.SetString(domainRetrieved); | 211 m_spInternetProtocolSink->ReportResult(S_OK, 0, nullptr); |
154 } | |
155 } | |
156 } | |
157 | |
158 CString cookie; | |
159 ULONG len1 = 2048; | |
160 ULONG len2 = 2048; | |
161 | |
162 #ifdef SUPPORT_FILTER | |
163 int contentType = CFilter::contentTypeAny; | |
164 | |
165 CPluginTab* tab = CPluginClass::GetTab(::GetCurrentThreadId()); | |
166 CPluginClient* client = CPluginClient::GetInstance(); | |
167 | |
168 | |
169 if (tab && client) | |
170 { | |
171 CString documentUrl = tab->GetDocumentUrl(); | |
172 // Page is identical to document => don't block | |
173 if (documentUrl == src) | |
174 { | |
175 // fall through | |
176 } | |
177 else if (CPluginSettings::GetInstance()->IsPluginEnabled() && !client->IsWhi telistedUrl(std::wstring(documentUrl))) | |
178 { | |
179 boundDomain = tab->GetDocumentUrl(); | |
180 | |
181 contentType = CFilter::contentTypeAny; | |
182 | |
183 #ifdef SUPPORT_FRAME_CACHING | |
184 if ((tab != 0) && (tab->IsFrameCached(src))) | |
185 { | |
186 contentType = CFilter::contentTypeSubdocument; | |
187 } | |
188 else | |
189 #endif // SUPPORT_FRAME_CACHING | |
190 contentType = GetContentType(mimeType, boundDomain, src); | |
191 if (client->ShouldBlock(src, contentType, boundDomain, true)) | |
192 { | |
193 isBlocked = true; | |
194 | |
195 DEBUG_BLOCKER("Blocker::Blocking Http-request:" + src); | |
196 } | |
197 } | |
198 if (!isBlocked) | |
199 { | |
200 DEBUG_BLOCKER("Blocker::Ignoring Http-request:" + src) | |
201 } | |
202 } | |
203 | |
204 | |
205 if (tab == NULL) | |
206 { | |
207 contentType = GetContentType(mimeType, boundDomain, src); | |
208 if (client->ShouldBlock(src, contentType, boundDomain, true)) | |
209 { | |
210 isBlocked = true; | |
211 } | |
212 } | |
213 | |
214 #ifdef _DEBUG | |
215 CString type; | |
216 | |
217 if (contentType == CFilter::contentTypeDocument) type = "DOCUMENT"; | |
218 else if (contentType == CFilter::contentTypeObject) type = "OBJECT"; | |
219 else if (contentType == CFilter::contentTypeImage) type = "IMAGE"; | |
220 else if (contentType == CFilter::contentTypeScript) type = "SCRIPT"; | |
221 else if (contentType == CFilter::contentTypeOther) type = "OTHER"; | |
222 else if (contentType == CFilter::contentTypeUnknown) type = "OTHER"; | |
223 else if (contentType == CFilter::contentTypeSubdocument) type = "SUBDOCUMENT"; | |
224 else if (contentType == CFilter::contentTypeStyleSheet) type = "STYLESHEET"; | |
225 else type = "OTHER"; | |
226 | |
227 if (isBlocked) | |
228 { | |
229 CPluginDebug::DebugResultBlocking(type, src, boundDomain); | |
230 } | |
231 else | |
232 { | |
233 CPluginDebug::DebugResultIgnoring(type, src, boundDomain); | |
234 } | |
235 #endif | |
236 | |
237 //Fixes the iframe back button issue | |
238 if (AdblockPlus::IE::InstalledMajorVersion() > 6) | |
239 { | |
240 if ((contentType == CFilter::contentTypeImage) && (isBlocked)) | |
241 { | |
242 m_shouldBlock = true; | |
243 BaseClass::OnStart(szUrl, pOIProtSink, pOIBindInfo, grfPI, dwReserved, pTa rgetProtocol); | |
244 | |
245 return INET_E_REDIRECT_FAILED; | |
246 | |
247 } | |
248 if (((contentType == CFilter::contentTypeSubdocument))&& (isBlocked)) | |
249 { | |
250 m_shouldBlock = true; | |
251 BaseClass::OnStart(szUrl, pOIProtSink, pOIBindInfo, grfPI, dwReserved, pTa rgetProtocol); | |
252 | |
253 m_spInternetProtocolSink->ReportProgress(BINDSTATUS_MIMETYPEAVAILABLE, L"t ext/html"); | |
254 | |
255 //Here we check if we are running on Windows 8 Consumer Preview. | |
256 //For some reason on that environment the next line causes IE to crash | |
257 if (CPluginSettings::GetInstance()->GetWindowsBuildNumber() != 8250) | |
258 { | |
259 m_spInternetProtocolSink->ReportResult(INET_E_REDIRECTING, 301, L"res:// mshtml.dll/blank.htm"); | |
260 } | |
261 | |
262 return INET_E_REDIRECT_FAILED; | |
263 } | |
264 if (((contentType == CFilter::contentTypeScript)) && (isBlocked)) | |
265 { | |
266 m_shouldBlock = true; | |
267 BaseClass::OnStart(szUrl, pOIProtSink, pOIBindInfo, grfPI, dwReserved, pTa rgetProtocol); | |
268 m_spInternetProtocolSink->ReportProgress(BINDSTATUS_MIMETYPEAVAILABLE, L"t ext/javascript"); | |
269 m_spInternetProtocolSink->ReportResult(INET_E_REDIRECTING, 301, L"data:"); | |
270 return INET_E_REDIRECT_FAILED; | |
271 } | |
272 if ((contentType == CFilter::contentTypeXmlHttpRequest) && (isBlocked)) | |
273 { | |
274 m_shouldBlock = true; | |
275 BaseClass::OnStart(szUrl, pOIProtSink, pOIBindInfo, grfPI, dwReserved, pTa rgetProtocol); | |
276 m_spInternetProtocolSink->ReportResult(INET_E_REDIRECTING, 301, L"data:"); | |
277 return INET_E_REDIRECT_FAILED; | |
278 } | |
279 if ((isBlocked)) | |
280 { | |
281 m_shouldBlock = true; | |
282 BaseClass::OnStart(szUrl, pOIProtSink, pOIBindInfo, grfPI, dwReserved, pTa rgetProtocol); | |
283 m_spInternetProtocolSink->ReportResult(S_FALSE, 0, L""); | |
284 | |
285 return INET_E_REDIRECT_FAILED; | |
286 } | |
287 } | |
288 #endif // SUPPORT_FILTER | |
289 | |
290 return isBlocked ? S_FALSE : BaseClass::OnStart(szUrl, pOIProtSink, pOIBindInf o, grfPI, dwReserved, pTargetProtocol); | |
291 } | |
292 | |
293 | |
294 HRESULT WBPassthruSink::Read(void *pv, ULONG cb, ULONG* pcbRead) | |
295 { | |
296 if (m_shouldBlock) | |
297 { | |
298 *pcbRead = 0; | |
299 if (!m_lastDataReported) | |
300 { | |
301 if (cb <= 1) | |
302 { | |
303 //IE must've gone nuts if this happened, but let's be cool about it and report we have no more data | |
304 m_spInternetProtocolSink->ReportResult(S_FALSE, 0, NULL); | |
305 return S_FALSE; | |
306 } | |
307 *pcbRead = 1; | |
308 memcpy(pv, " ", 1); | |
309 | |
310 if (m_spInternetProtocolSink != NULL) | |
311 { | |
312 m_spInternetProtocolSink->ReportResult(S_OK, 0, NULL); | |
313 } | |
314 m_lastDataReported = true; | |
315 m_shouldBlock = false; | |
316 return S_OK; | |
317 } | 212 } |
318 return S_OK; | 213 return S_OK; |
319 } | 214 } |
320 else | 215 return m_pTargetProtocol->Read(pv, cb, pcbRead); |
321 { | |
322 | |
323 return m_pTargetProtocol->Read(pv, cb, pcbRead); | |
324 } | |
325 return S_OK; | |
326 } | 216 } |
327 STDMETHODIMP WBPassthruSink::Switch( | 217 STDMETHODIMP WBPassthruSink::Switch( |
328 /* [in] */ PROTOCOLDATA *pProtocolData) | 218 /* [in] */ PROTOCOLDATA *pProtocolData) |
329 { | 219 { |
330 ATLASSERT(m_spInternetProtocolSink != 0); | 220 ATLASSERT(m_spInternetProtocolSink != 0); |
331 | 221 |
332 /* | 222 /* |
333 From Igor Tandetnik "itandetnik@mvps.org" | 223 From Igor Tandetnik "itandetnik@mvps.org" |
334 " | 224 " |
335 Beware multithreading. URLMon has this nasty habit of spinning worker | 225 Beware multithreading. URLMon has this nasty habit of spinning worker |
336 threads, not even bothering to initialize COM on them, and calling APP | 226 threads, not even bothering to initialize COM on them, and calling APP |
337 methods on those threads. If you try to raise COM events directly from | 227 methods on those threads. If you try to raise COM events directly from |
338 such a thread, bad things happen (random crashes, events being lost). | 228 such a thread, bad things happen (random crashes, events being lost). |
339 You are only guaranteed to be on the main STA thread in two cases. | 229 You are only guaranteed to be on the main STA thread in two cases. |
340 First, in methods of interfaces that were obtained with | 230 First, in methods of interfaces that were obtained with |
341 IServiceProvider, such as IHttpNegotiage::BeginningTransaction or | 231 IServiceProvider, such as IHttpNegotiage::BeginningTransaction or |
342 IAuthenticate::Authenticate. Second, you can call | 232 IAuthenticate::Authenticate. Second, you can call |
343 IInternetProtocolSink::Switch with PD_FORCE_SWITCH flag in | 233 IInternetProtocolSink::Switch with PD_FORCE_SWITCH flag in |
344 PROTOCOLDATA::grfFlags, eventually URLMon will turn around and call | 234 PROTOCOLDATA::grfFlags, eventually URLMon will turn around and call |
345 IInternetProtocol::Continue on the main thread. | 235 IInternetProtocol::Continue on the main thread. |
346 | 236 |
347 Or, if you happen to have a window handy that was created on the main | 237 Or, if you happen to have a window handy that was created on the main |
348 thread, you can post yourself a message. | 238 thread, you can post yourself a message. |
349 " | 239 " |
350 */ | 240 */ |
351 return m_spInternetProtocolSink ? m_spInternetProtocolSink->Switch(pProtocolDa ta) : E_UNEXPECTED; | 241 return m_spInternetProtocolSink ? m_spInternetProtocolSink->Switch(pProtocolDa ta) : E_UNEXPECTED; |
352 } | 242 } |
353 | 243 |
354 | 244 // This is the heuristic which detects the requests issued by Flash.ocx. |
355 STDMETHODIMP WBPassthruSink::BeginningTransaction(LPCWSTR szURL, LPCWSTR szHeade rs, DWORD dwReserved, LPWSTR *pszAdditionalHeaders) | 245 // It turned out that the implementation from ''Flash.ocx'' (tested version is 1 5.0.0.152) |
356 { | 246 // returns quite minimal configuration in comparison with the implementation fro m Microsofts' |
247 // libraries (see grfBINDF and bindInfo.dwOptions). The impl from MS often inclu des something | |
248 // else. | |
249 bool WBPassthruSink::IsFlashRequest(const wchar_t* const* additionalHeaders) | |
250 { | |
251 if (additionalHeaders && *additionalHeaders) | |
252 { | |
253 auto flashVersionHeader = ExtractHttpHeader<std::wstring>(*additionalHeaders , L"x-flash-version:", L"\n"); | |
254 if (!TrimString(flashVersionHeader).empty()) | |
255 { | |
256 return true; | |
257 } | |
258 } | |
259 ATL::CComPtr<IBindStatusCallback> bscb; | |
260 if (SUCCEEDED(QueryServiceFromClient(&bscb)) && !!bscb) | |
261 { | |
262 DWORD grfBINDF = 0; | |
263 BINDINFO bindInfo = {}; | |
264 bindInfo.cbSize = sizeof(bindInfo); | |
265 if (SUCCEEDED(bscb->GetBindInfo(&grfBINDF, &bindInfo)) && | |
266 (BINDF_ASYNCHRONOUS | BINDF_ASYNCSTORAGE| BINDF_PULLDATA) == grfBINDF && | |
267 (BINDINFO_OPTIONS_ENABLE_UTF8 | BINDINFO_OPTIONS_USE_IE_ENCODING) == bindI nfo.dwOptions | |
268 ) | |
269 { | |
270 return true; | |
271 } | |
272 } | |
273 return false; | |
274 } | |
275 | |
276 STDMETHODIMP WBPassthruSink::BeginningTransaction(LPCWSTR szURL, LPCWSTR szHeade rs, DWORD dwReserved, LPWSTR* pszAdditionalHeaders) | |
277 { | |
278 if (!szURL) | |
279 { | |
280 return E_POINTER; | |
281 } | |
282 std::wstring src = szURL; | |
283 DEBUG_GENERAL(ToCString(src)); | |
284 | |
285 std::string acceptHeader = ExtractHttpAcceptHeader(m_spTargetProtocol); | |
286 m_contentType = GetContentTypeFromMimeType(ATL::CString(acceptHeader.c_str())) ; | |
287 | |
357 if (pszAdditionalHeaders) | 288 if (pszAdditionalHeaders) |
358 { | 289 { |
359 *pszAdditionalHeaders = 0; | 290 *pszAdditionalHeaders = nullptr; |
291 } | |
292 | |
293 CComPtr<IHttpNegotiate> httpNegotiate; | |
294 QueryServiceFromClient(&httpNegotiate); | |
295 // This fills the pszAdditionalHeaders with more headers. One of which is the Referer header, which we need. | |
296 // There doesn't seem to be any other way to get this header before the reques t has been made. | |
297 HRESULT nativeHr = httpNegotiate ? httpNegotiate->BeginningTransaction(szURL, szHeaders, dwReserved, pszAdditionalHeaders) : S_OK; | |
298 | |
299 if (pszAdditionalHeaders && *pszAdditionalHeaders) | |
300 { | |
301 m_boundDomain = ExtractHttpHeader<std::wstring>(*pszAdditionalHeaders, L"Ref erer:", L"\n"); | |
302 } | |
303 m_boundDomain = TrimString(m_boundDomain); | |
304 CPluginTab* tab = CPluginClass::GetTab(::GetCurrentThreadId()); | |
305 CPluginClient* client = CPluginClient::GetInstance(); | |
306 | |
307 if (tab && client) | |
308 { | |
309 CString documentUrl = tab->GetDocumentUrl(); | |
310 // Page is identical to document => don't block | |
311 if (documentUrl == ToCString(src)) | |
312 { | |
313 return nativeHr; | |
314 } | |
315 else if (CPluginSettings::GetInstance()->IsPluginEnabled() && !client->IsWhi telistedUrl(std::wstring(documentUrl))) | |
316 { | |
317 if (tab->IsFrameCached(ToCString(src))) | |
318 { | |
319 m_contentType = CFilter::contentTypeSubdocument; | |
320 } | |
321 } | |
322 } | |
323 | |
324 if (IsFlashRequest(pszAdditionalHeaders)) | |
325 { | |
326 m_contentType = CFilter::EContentType::contentTypeObjectSubrequest; | |
327 } | |
328 | |
329 if (pszAdditionalHeaders && *pszAdditionalHeaders && IsXmlHttpRequest(*pszAddi tionalHeaders)) | |
330 { | |
331 m_contentType = CFilter::EContentType::contentTypeXmlHttpRequest; | |
332 } | |
333 | |
334 if (client->ShouldBlock(szURL, m_contentType, m_boundDomain, /*debug flag but must be set*/true)) | |
335 { | |
336 // NOTE: Feeding custom HTML to Flash, instead of original object subrequest | |
337 // doesn't have much sense. It also can manifest in unwanted result» | |
338 // like video being blocked (See https://issues.adblockplus.org/ticket/1669) » | |
339 // So we report blocked object subrequests as failed, not just empty HTML. | |
340 m_isCustomResponse = m_contentType != CFilter::contentTypeObjectSubrequest; | |
341 return E_ABORT; | |
342 } | |
343 return nativeHr; | |
344 } | |
345 | |
346 STDMETHODIMP WBPassthruSink::OnResponse(DWORD dwResponseCode, LPCWSTR szResponse Headers, LPCWSTR szRequestHeaders, LPWSTR *pszAdditionalRequestHeaders) | |
347 { | |
348 if (pszAdditionalRequestHeaders) | |
349 { | |
350 *pszAdditionalRequestHeaders = 0; | |
360 } | 351 } |
361 | 352 |
362 CComPtr<IHttpNegotiate> spHttpNegotiate; | 353 CComPtr<IHttpNegotiate> spHttpNegotiate; |
363 QueryServiceFromClient(&spHttpNegotiate); | 354 QueryServiceFromClient(&spHttpNegotiate); |
364 return spHttpNegotiate ? spHttpNegotiate->BeginningTransaction(szURL, szHeader s,dwReserved, pszAdditionalHeaders) : S_OK; | |
365 } | |
366 | |
367 STDMETHODIMP WBPassthruSink::OnResponse(DWORD dwResponseCode, LPCWSTR szResponse Headers, LPCWSTR szRequestHeaders, LPWSTR *pszAdditionalRequestHeaders) | |
368 { | |
369 if (pszAdditionalRequestHeaders) | |
370 { | |
371 *pszAdditionalRequestHeaders = 0; | |
372 } | |
373 | |
374 CComPtr<IHttpNegotiate> spHttpNegotiate; | |
375 QueryServiceFromClient(&spHttpNegotiate); | |
376 | 355 |
377 return spHttpNegotiate ? spHttpNegotiate->OnResponse(dwResponseCode, szRespons eHeaders, szRequestHeaders, pszAdditionalRequestHeaders) : S_OK; | 356 return spHttpNegotiate ? spHttpNegotiate->OnResponse(dwResponseCode, szRespons eHeaders, szRequestHeaders, pszAdditionalRequestHeaders) : S_OK; |
378 } | 357 } |
379 | 358 |
380 STDMETHODIMP WBPassthruSink::ReportProgress(ULONG ulStatusCode, LPCWSTR szStatus Text) | 359 STDMETHODIMP WBPassthruSink::ReportProgress(ULONG ulStatusCode, LPCWSTR szStatus Text) |
381 { | 360 { |
382 return m_spInternetProtocolSink ? m_spInternetProtocolSink->ReportProgress(ulS tatusCode, szStatusText) : S_OK; | 361 return m_spInternetProtocolSink ? m_spInternetProtocolSink->ReportProgress(ulS tatusCode, szStatusText) : S_OK; |
383 } | 362 } |
384 | 363 |
364 STDMETHODIMP WBPassthruSink::ReportResult(/* [in] */ HRESULT hrResult, /* [in] * / DWORD dwError, /* [in] */ LPCWSTR szResult) | |
365 { | |
366 if (m_isCustomResponse) | |
367 { | |
368 // Don't notify the client about aborting of the operation, thus don't call BaseClass::ReportResult. | |
369 // Current method is called by the original protocol implementation and we a re intercepting the | |
370 // call here and eating it, we will call the proper ReportResult later by ou rself. | |
371 return S_OK; | |
372 } | |
373 return BaseClass::ReportResult(hrResult, dwError, szResult); | |
374 } | |
375 | |
376 | |
377 WBPassthru::WBPassthru() | |
378 : m_shouldSupplyCustomContent(false) | |
379 { | |
380 } | |
385 | 381 |
386 STDMETHODIMP WBPassthru::Start(LPCWSTR szUrl, IInternetProtocolSink *pOIProtSink , | 382 STDMETHODIMP WBPassthru::Start(LPCWSTR szUrl, IInternetProtocolSink *pOIProtSink , |
387 IInternetBindInfo *pOIBindInfo, DWORD grfPI, HANDLE_PTR dwReserved) | 383 IInternetBindInfo *pOIBindInfo, DWORD grfPI, HANDLE_PTR dwReserved) |
388 { | 384 { |
389 ATLASSERT(m_spInternetProtocol != 0); | 385 ATLASSERT(m_spInternetProtocol != 0); |
390 if (!m_spInternetProtocol) | 386 if (!m_spInternetProtocol) |
391 { | 387 { |
392 return E_UNEXPECTED; | 388 return E_UNEXPECTED; |
393 } | 389 } |
394 | 390 |
395 return OnStart(szUrl, pOIProtSink, pOIBindInfo, grfPI, | 391 return OnStart(szUrl, pOIProtSink, pOIBindInfo, grfPI, dwReserved, m_spInterne tProtocol); |
396 dwReserved, m_spInternetProtocol); | 392 } |
397 } | 393 |
398 | 394 STDMETHODIMP WBPassthru::Read(/* [in, out] */ void *pv,/* [in] */ ULONG cb,/* [o ut] */ ULONG *pcbRead) |
399 STDMETHODIMP WBPassthru::Read(»/* [in, out] */ void *pv,/* [in] */ ULONG cb,/* [out] */ ULONG *pcbRead) | 395 { |
400 { | 396 WBPassthruSink* pSink = GetSink(); |
401 | 397 return pSink->OnRead(pv, cb, pcbRead); |
402 WBPassthruSink* pSink = GetSink(); | 398 } |
403 return pSink->Read(pv, cb, pcbRead); | |
404 } | |
LEFT | RIGHT |