Left: | ||
Right: |
OLD | NEW |
---|---|
1 #include "PluginStdAfx.h" | 1 #include "PluginStdAfx.h" |
2 #include "PluginSettings.h" | 2 #include "PluginSettings.h" |
3 #include "PluginSystem.h" | 3 #include "PluginSystem.h" |
4 #include "PluginFilter.h" | 4 #include "PluginFilter.h" |
5 #include "PluginClientFactory.h" | 5 #include "PluginClientFactory.h" |
6 #include "PluginMutex.h" | 6 #include "PluginMutex.h" |
7 #include "PluginClass.h" | 7 #include "PluginClass.h" |
8 | 8 |
9 #include "AdblockPlusClient.h" | 9 #include "AdblockPlusClient.h" |
10 | 10 |
(...skipping 90 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
101 return new Communication::Pipe(Communication::pipeName, Communication: :Pipe::MODE_CONNECT); | 101 return new Communication::Pipe(Communication::pipeName, Communication: :Pipe::MODE_CONNECT); |
102 } | 102 } |
103 catch (Communication::PipeConnectionError e) | 103 catch (Communication::PipeConnectionError e) |
104 { | 104 { |
105 } | 105 } |
106 } | 106 } |
107 throw std::runtime_error("Unable to open Adblock Plus Engine pipe"); | 107 throw std::runtime_error("Unable to open Adblock Plus Engine pipe"); |
108 } | 108 } |
109 } | 109 } |
110 | 110 |
111 std::vector<std::wstring> ReadStrings(Communication::InputBuffer& message) | |
112 { | |
113 int32_t count; | |
114 message >> count; | |
115 | |
116 std::vector<std::wstring> result; | |
117 for (int32_t i = 0; i < count; i++) | |
118 { | |
119 std::string str; | |
120 message >> str; | |
121 result.push_back(ToUtf16String(str)); | |
122 } | |
123 return result; | |
124 } | |
125 | |
126 std::vector<SubscriptionDescription> ReadSubscriptions(Communication::InputBuf fer& message) | 111 std::vector<SubscriptionDescription> ReadSubscriptions(Communication::InputBuf fer& message) |
127 { | 112 { |
128 int32_t count; | 113 int32_t count; |
129 message >> count; | 114 message >> count; |
130 | 115 |
131 std::vector<SubscriptionDescription> result; | 116 std::vector<SubscriptionDescription> result; |
132 for (int32_t i = 0; i < count; i++) | 117 for (int32_t i = 0; i < count; i++) |
133 { | 118 { |
134 SubscriptionDescription description; | 119 SubscriptionDescription description; |
135 std::string url; | 120 std::string url; |
(...skipping 166 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
302 } | 287 } |
303 | 288 |
304 std::vector<std::wstring> CAdblockPlusClient::GetElementHidingSelectors(const st d::wstring& domain) | 289 std::vector<std::wstring> CAdblockPlusClient::GetElementHidingSelectors(const st d::wstring& domain) |
305 { | 290 { |
306 Communication::OutputBuffer request; | 291 Communication::OutputBuffer request; |
307 request << Communication::PROC_GET_ELEMHIDE_SELECTORS << ToUtf8String(domain); | 292 request << Communication::PROC_GET_ELEMHIDE_SELECTORS << ToUtf8String(domain); |
308 | 293 |
309 Communication::InputBuffer response; | 294 Communication::InputBuffer response; |
310 if (!CallEngine(request, response)) | 295 if (!CallEngine(request, response)) |
311 return std::vector<std::wstring>(); | 296 return std::vector<std::wstring>(); |
312 return ReadStrings(response); | 297 |
298 std::vector<std::string> selectors; | |
299 response >> selectors; | |
300 return ToUtf16Strings(selectors); | |
Eric
2015/02/09 16:18:57
Here and below, you're following a call to operato
| |
313 } | 301 } |
314 | 302 |
315 std::vector<SubscriptionDescription> CAdblockPlusClient::FetchAvailableSubscript ions() | 303 std::vector<SubscriptionDescription> CAdblockPlusClient::FetchAvailableSubscript ions() |
316 { | 304 { |
317 Communication::InputBuffer response; | 305 Communication::InputBuffer response; |
318 if (!CallEngine(Communication::PROC_AVAILABLE_SUBSCRIPTIONS, response)) | 306 if (!CallEngine(Communication::PROC_AVAILABLE_SUBSCRIPTIONS, response)) |
319 return std::vector<SubscriptionDescription>(); | 307 return std::vector<SubscriptionDescription>(); |
320 return ReadSubscriptions(response); | 308 return ReadSubscriptions(response); |
321 } | 309 } |
322 | 310 |
(...skipping 45 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
368 void CAdblockPlusClient::UpdateAllSubscriptions() | 356 void CAdblockPlusClient::UpdateAllSubscriptions() |
369 { | 357 { |
370 CallEngine(Communication::PROC_UPDATE_ALL_SUBSCRIPTIONS); | 358 CallEngine(Communication::PROC_UPDATE_ALL_SUBSCRIPTIONS); |
371 } | 359 } |
372 | 360 |
373 std::vector<std::wstring> CAdblockPlusClient::GetExceptionDomains() | 361 std::vector<std::wstring> CAdblockPlusClient::GetExceptionDomains() |
374 { | 362 { |
375 Communication::InputBuffer response; | 363 Communication::InputBuffer response; |
376 if (!CallEngine(Communication::PROC_GET_EXCEPTION_DOMAINS, response)) | 364 if (!CallEngine(Communication::PROC_GET_EXCEPTION_DOMAINS, response)) |
377 return std::vector<std::wstring>(); | 365 return std::vector<std::wstring>(); |
378 return ReadStrings(response); | 366 |
367 std::vector<std::string> domains; | |
368 response >> domains; | |
369 return ToUtf16Strings(domains); | |
Eric
2015/02/09 16:18:57
Second pair of calls: operator>>, ToUtf16Strings
| |
379 } | 370 } |
380 | 371 |
381 bool CAdblockPlusClient::IsFirstRun() | 372 bool CAdblockPlusClient::IsFirstRun() |
382 { | 373 { |
383 DEBUG_GENERAL("IsFirstRun"); | 374 DEBUG_GENERAL("IsFirstRun"); |
384 Communication::InputBuffer response; | 375 Communication::InputBuffer response; |
385 if (!CallEngine(Communication::PROC_IS_FIRST_RUN_ACTION_NEEDED, response)) ret urn false; | 376 if (!CallEngine(Communication::PROC_IS_FIRST_RUN_ACTION_NEEDED, response)) ret urn false; |
386 bool res; | 377 bool res; |
387 response >> res; | 378 response >> res; |
388 return res; | 379 return res; |
(...skipping 160 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
549 DEBUG_GENERAL("CompareVersions"); | 540 DEBUG_GENERAL("CompareVersions"); |
550 Communication::OutputBuffer request; | 541 Communication::OutputBuffer request; |
551 request << Communication::PROC_COMPARE_VERSIONS << ToUtf8String(v1) << ToUtf8S tring(v2); | 542 request << Communication::PROC_COMPARE_VERSIONS << ToUtf8String(v1) << ToUtf8S tring(v2); |
552 Communication::InputBuffer response; | 543 Communication::InputBuffer response; |
553 if (!CallEngine(request, response)) | 544 if (!CallEngine(request, response)) |
554 return 0; | 545 return 0; |
555 int result; | 546 int result; |
556 response >> result; | 547 response >> result; |
557 return result; | 548 return result; |
558 } | 549 } |
OLD | NEW |