LEFT | RIGHT |
1 #include <AdblockPlus.h> | 1 #include <AdblockPlus.h> |
2 #include <functional> | 2 #include <functional> |
3 #include <vector> | 3 #include <vector> |
4 #include <Windows.h> | 4 #include <Windows.h> |
5 | 5 |
6 #include "../shared/AutoHandle.h" | 6 #include "../shared/AutoHandle.h" |
7 #include "../shared/Communication.h" | 7 #include "../shared/Communication.h" |
8 #include "../shared/Dictionary.h" | 8 #include "../shared/Dictionary.h" |
9 #include "../shared/Utils.h" | 9 #include "../shared/Utils.h" |
10 #include "../shared/Version.h" | 10 #include "../shared/Version.h" |
| 11 #include "../shared/CriticalSection.h" |
11 #include "Debug.h" | 12 #include "Debug.h" |
12 #include "Updater.h" | 13 #include "Updater.h" |
13 | 14 |
14 namespace | 15 namespace |
15 { | 16 { |
16 std::auto_ptr<AdblockPlus::FilterEngine> filterEngine; | 17 std::auto_ptr<AdblockPlus::FilterEngine> filterEngine; |
17 | 18 |
18 void WriteStrings(Communication::OutputBuffer& response, | 19 void WriteStrings(Communication::OutputBuffer& response, |
19 const std::vector<std::string>& strings) | 20 const std::vector<std::string>& strings) |
20 { | 21 { |
(...skipping 10 matching lines...) Expand all Loading... |
31 response << count; | 32 response << count; |
32 for (int32_t i = 0; i < count; i++) | 33 for (int32_t i = 0; i < count; i++) |
33 { | 34 { |
34 AdblockPlus::SubscriptionPtr subscription = subscriptions[i]; | 35 AdblockPlus::SubscriptionPtr subscription = subscriptions[i]; |
35 response << subscription->GetProperty("url")->AsString() | 36 response << subscription->GetProperty("url")->AsString() |
36 << subscription->GetProperty("title")->AsString() | 37 << subscription->GetProperty("title")->AsString() |
37 << subscription->GetProperty("specialization")->AsString() | 38 << subscription->GetProperty("specialization")->AsString() |
38 << subscription->IsListed(); | 39 << subscription->IsListed(); |
39 } | 40 } |
40 } | 41 } |
| 42 |
| 43 CriticalSection firstRunLock; |
| 44 bool firstRunActionExecuted = false; |
41 | 45 |
42 Communication::OutputBuffer HandleRequest(Communication::InputBuffer& request) | 46 Communication::OutputBuffer HandleRequest(Communication::InputBuffer& request) |
43 { | 47 { |
44 Communication::OutputBuffer response; | 48 Communication::OutputBuffer response; |
45 | 49 |
46 Communication::ProcType procedure; | 50 Communication::ProcType procedure; |
47 request >> procedure; | 51 request >> procedure; |
48 switch (procedure) | 52 switch (procedure) |
49 { | 53 { |
50 case Communication::PROC_MATCHES: | 54 case Communication::PROC_MATCHES: |
(...skipping 87 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
138 } | 142 } |
139 case Communication::PROC_REMOVE_FILTER: | 143 case Communication::PROC_REMOVE_FILTER: |
140 { | 144 { |
141 std::string text; | 145 std::string text; |
142 request >> text; | 146 request >> text; |
143 filterEngine->GetFilter(text)->RemoveFromList(); | 147 filterEngine->GetFilter(text)->RemoveFromList(); |
144 break; | 148 break; |
145 } | 149 } |
146 case Communication::PROC_SET_PREF: | 150 case Communication::PROC_SET_PREF: |
147 { | 151 { |
148 std::string prefName = ""; | 152 std::string prefName; |
149 std::string prefValue = ""; | |
150 request >> prefName; | 153 request >> prefName; |
151 request >> prefValue; | 154 |
152 filterEngine->SetPref(prefName, filterEngine->GetJsEngine()->NewValue(pr
efValue)); | 155 Communication::ValueType valueType = request.GetType(); |
| 156 switch (valueType) |
| 157 { |
| 158 case Communication::TYPE_STRING: |
| 159 { |
| 160 std::string prefValue; |
| 161 request >> prefValue; |
| 162 filterEngine->SetPref(prefName, filterEngine->GetJsEngine()->NewValu
e(prefValue)); |
| 163 break; |
| 164 } |
| 165 case Communication::TYPE_INT64: |
| 166 { |
| 167 int64_t prefValue; |
| 168 request >> prefValue; |
| 169 filterEngine->SetPref(prefName, filterEngine->GetJsEngine()->NewValu
e(prefValue)); |
| 170 break; |
| 171 } |
| 172 case Communication::TYPE_INT32: |
| 173 { |
| 174 int prefValue; |
| 175 request >> prefValue; |
| 176 filterEngine->SetPref(prefName, filterEngine->GetJsEngine()->NewValu
e(prefValue)); |
| 177 break; |
| 178 } |
| 179 case Communication::TYPE_BOOL: |
| 180 { |
| 181 bool prefValue; |
| 182 request >> prefValue; |
| 183 filterEngine->SetPref(prefName, filterEngine->GetJsEngine()->NewValu
e(prefValue)); |
| 184 break; |
| 185 } |
| 186 default: |
| 187 break; |
| 188 } |
153 break; | 189 break; |
154 } | 190 } |
155 case Communication::PROC_GET_PREF: | 191 case Communication::PROC_GET_PREF: |
156 { | 192 { |
157 std::string name; | 193 std::string name; |
158 request >> name; | 194 request >> name; |
159 | 195 |
160 AdblockPlus::JsValuePtr valuePtr = filterEngine->GetPref(name); | 196 AdblockPlus::JsValuePtr valuePtr = filterEngine->GetPref(name); |
161 if ((valuePtr->IsNull()) || (!valuePtr->IsString())) | 197 if (valuePtr->IsNull() || valuePtr->IsUndefined()) |
162 response << 0; | 198 { |
| 199 // Report no success |
| 200 response << false; |
| 201 break; |
| 202 } |
| 203 |
| 204 // Report success |
| 205 response << true; |
| 206 |
| 207 if (valuePtr->IsBool()) |
| 208 { |
| 209 response << valuePtr->AsBool(); |
| 210 } |
| 211 else if (valuePtr->IsNumber()) |
| 212 { |
| 213 response << valuePtr->AsInt(); |
| 214 } |
| 215 else if (valuePtr->IsString()) |
| 216 { |
| 217 response << valuePtr->AsString(); |
| 218 } |
| 219 break; |
| 220 } |
| 221 case Communication::PROC_IS_FIRST_RUN_ACTION_NEEDED: |
| 222 { |
| 223 CriticalSection::Lock lock(firstRunLock); |
| 224 if (!firstRunActionExecuted && filterEngine->IsFirstRun()) |
| 225 { |
| 226 response << true; |
| 227 firstRunActionExecuted = true; |
| 228 } |
163 else | 229 else |
164 { | 230 { |
165 response << 1; | 231 response << false; |
166 response << valuePtr->AsString(); | 232 } |
167 } | 233 break; |
168 break; | 234 } |
169 } | |
170 case Communication::PROC_GET_IS_FIRST_RUN: | |
171 { | |
172 response << filterEngine->IsFirstRun(); | |
173 break; | |
174 } | |
175 | 235 |
176 } | 236 } |
177 return response; | 237 return response; |
178 } | 238 } |
179 | 239 |
180 DWORD WINAPI ClientThread(LPVOID param) | 240 DWORD WINAPI ClientThread(LPVOID param) |
181 { | 241 { |
182 std::auto_ptr<Communication::Pipe> pipe(static_cast<Communication::Pipe*>(pa
ram)); | 242 std::auto_ptr<Communication::Pipe> pipe(static_cast<Communication::Pipe*>(pa
ram)); |
183 | 243 |
184 try | 244 try |
(...skipping 92 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
277 } | 337 } |
278 catch (std::runtime_error e) | 338 catch (std::runtime_error e) |
279 { | 339 { |
280 DebugException(e); | 340 DebugException(e); |
281 return 1; | 341 return 1; |
282 } | 342 } |
283 } | 343 } |
284 | 344 |
285 return 0; | 345 return 0; |
286 } | 346 } |
LEFT | RIGHT |