| LEFT | RIGHT |
| 1 /* | 1 /* |
| 2 * This file is part of Adblock Plus <https://adblockplus.org/>, | 2 * This file is part of Adblock Plus <https://adblockplus.org/>, |
| 3 * Copyright (C) 2006-2015 Eyeo GmbH | 3 * Copyright (C) 2006-2015 Eyeo GmbH |
| 4 * | 4 * |
| 5 * Adblock Plus is free software: you can redistribute it and/or modify | 5 * Adblock Plus is free software: you can redistribute it and/or modify |
| 6 * it under the terms of the GNU General Public License version 3 as | 6 * it under the terms of the GNU General Public License version 3 as |
| 7 * published by the Free Software Foundation. | 7 * published by the Free Software Foundation. |
| 8 * | 8 * |
| 9 * Adblock Plus is distributed in the hope that it will be useful, | 9 * Adblock Plus is distributed in the hope that it will be useful, |
| 10 * but WITHOUT ANY WARRANTY; without even the implied warranty of | 10 * but WITHOUT ANY WARRANTY; without even the implied warranty of |
| 11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | 11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
| 12 * GNU General Public License for more details. | 12 * GNU General Public License for more details. |
| 13 * | 13 * |
| 14 * You should have received a copy of the GNU General Public License | 14 * You should have received a copy of the GNU General Public License |
| 15 * along with Adblock Plus. If not, see <http://www.gnu.org/licenses/>. | 15 * along with Adblock Plus. If not, see <http://www.gnu.org/licenses/>. |
| 16 */ | 16 */ |
| 17 | 17 |
| 18 package org.adblockplus.browser; | 18 package org.adblockplus.browser; |
| 19 | 19 |
| 20 import java.io.IOException; | |
| 21 import java.io.StringReader; | |
| 22 import java.util.ArrayList; | |
| 23 import java.util.HashMap; | |
| 24 import java.util.List; | 20 import java.util.List; |
| 25 import java.util.concurrent.ConcurrentHashMap; | |
| 26 import java.util.concurrent.Semaphore; | |
| 27 | 21 |
| 28 import org.mozilla.gecko.R; | 22 import org.mozilla.gecko.R; |
| 29 import org.mozilla.gecko.util.NativeJSObject; | |
| 30 import org.mozilla.gecko.util.ThreadUtils; | 23 import org.mozilla.gecko.util.ThreadUtils; |
| 31 import org.xmlpull.v1.XmlPullParser; | |
| 32 import org.xmlpull.v1.XmlPullParserException; | |
| 33 | 24 |
| 34 import android.app.ProgressDialog; | 25 import android.app.ProgressDialog; |
| 35 import android.content.Context; | 26 import android.content.Context; |
| 36 import android.preference.CheckBoxPreference; | 27 import android.preference.CheckBoxPreference; |
| 37 import android.preference.Preference; | 28 import android.preference.Preference; |
| 38 import android.preference.PreferenceCategory; | 29 import android.preference.PreferenceCategory; |
| 39 import android.util.AttributeSet; | 30 import android.util.AttributeSet; |
| 40 import android.util.Log; | |
| 41 import android.util.Xml; | |
| 42 | 31 |
| 43 public class SubscriptionPreferenceCategory extends PreferenceCategory | 32 public class SubscriptionPreferenceCategory extends PreferenceCategory |
| 44 { | 33 { |
| 45 private volatile static SubscriptionContainer subscriptionContainer = null; | 34 volatile static SubscriptionContainer subscriptionContainer = null; |
| 46 private final CheckBoxChangeListener checkBoxChangeListener = new CheckBoxChan
geListener(); | 35 private final CheckBoxChangeListener checkBoxChangeListener = new CheckBoxChan
geListener(); |
| 47 private boolean isEnabledList = false; | 36 private boolean isEnabledList = false; |
| 48 private ProgressDialog progressDialog; | 37 private ProgressDialog progressDialog; |
| 49 | 38 |
| 50 public SubscriptionPreferenceCategory(Context context) | 39 public SubscriptionPreferenceCategory(Context context) |
| 51 { | 40 { |
| 52 super(context); | 41 super(context); |
| 53 } | 42 } |
| 54 | 43 |
| 55 public SubscriptionPreferenceCategory(Context context, AttributeSet attrs) | 44 public SubscriptionPreferenceCategory(Context context, AttributeSet attrs) |
| (...skipping 27 matching lines...) Expand all Loading... |
| 83 | 72 |
| 84 this.setEnabled(false); | 73 this.setEnabled(false); |
| 85 this.setShouldDisableView(true); | 74 this.setShouldDisableView(true); |
| 86 | 75 |
| 87 super.onAttachedToActivity(); | 76 super.onAttachedToActivity(); |
| 88 | 77 |
| 89 this.progressDialog.setProgressStyle(ProgressDialog.STYLE_SPINNER); | 78 this.progressDialog.setProgressStyle(ProgressDialog.STYLE_SPINNER); |
| 90 this.progressDialog.setMessage(this.getContext().getString(R.string.abb_adbl
ocking_waiting)); | 79 this.progressDialog.setMessage(this.getContext().getString(R.string.abb_adbl
ocking_waiting)); |
| 91 this.progressDialog.show(); | 80 this.progressDialog.show(); |
| 92 | 81 |
| 93 AddOnBridge.handlerPost(new Runnable() | 82 AddOnBridge.postToHandler(new Runnable() |
| 94 { | 83 { |
| 95 @Override | 84 @Override |
| 96 public void run() | 85 public void run() |
| 97 { | 86 { |
| 98 initSubscriptions(); | 87 initSubscriptions(); |
| 99 ThreadUtils.postToUiThread(new Runnable() | 88 ThreadUtils.postToUiThread(new Runnable() |
| 100 { | 89 { |
| 101 @Override | 90 @Override |
| 102 public void run() | 91 public void run() |
| 103 { | 92 { |
| (...skipping 76 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 180 { | 169 { |
| 181 final CheckBoxPreference cbp = (CheckBoxPreference) preference; | 170 final CheckBoxPreference cbp = (CheckBoxPreference) preference; |
| 182 final boolean enable = ((Boolean) newValue).booleanValue(); | 171 final boolean enable = ((Boolean) newValue).booleanValue(); |
| 183 SubscriptionPreferenceCategory.subscriptionContainer.changeSubscriptionS
tate( | 172 SubscriptionPreferenceCategory.subscriptionContainer.changeSubscriptionS
tate( |
| 184 cbp.getKey(), | 173 cbp.getKey(), |
| 185 enable); | 174 enable); |
| 186 } | 175 } |
| 187 return true; | 176 return true; |
| 188 } | 177 } |
| 189 } | 178 } |
| 190 | |
| 191 final static class SubscriptionContainer implements AdblockPlusApiCallback | |
| 192 { | |
| 193 private static final String TAG = SubscriptionContainer.class.getName(); | |
| 194 private final ConcurrentHashMap<String, Boolean> enableState = new Concurren
tHashMap<String, Boolean>(); | |
| 195 private final Semaphore entriesReady = new Semaphore(0); | |
| 196 private final List<Subscription> entries = new ArrayList<Subscription>(); | |
| 197 private final HashMap<String, Subscription> urlMap = new HashMap<String, Sub
scription>(); | |
| 198 | |
| 199 private SubscriptionContainer() | |
| 200 { | |
| 201 // prevent external instantiation | |
| 202 } | |
| 203 | |
| 204 public final static SubscriptionContainer create() | |
| 205 { | |
| 206 return create(true); | |
| 207 } | |
| 208 | |
| 209 public final static SubscriptionContainer create(final boolean refresh) | |
| 210 { | |
| 211 final SubscriptionContainer sc = new SubscriptionContainer(); | |
| 212 AddOnBridge.queryValue(sc, "subscriptionsXml"); | |
| 213 sc.entriesReady.acquireUninterruptibly(); | |
| 214 | |
| 215 for (final Subscription e : sc.entries) | |
| 216 { | |
| 217 sc.urlMap.put(e.url, e); | |
| 218 sc.enableState.put(e.url, Boolean.FALSE); | |
| 219 } | |
| 220 | |
| 221 if (refresh) | |
| 222 { | |
| 223 sc.refresh(); | |
| 224 } | |
| 225 | |
| 226 return sc; | |
| 227 } | |
| 228 | |
| 229 public void refresh() | |
| 230 { | |
| 231 if (!this.entries.isEmpty()) | |
| 232 { | |
| 233 for (int i = 0; i < this.entries.size(); i++) | |
| 234 { | |
| 235 SubscriptionChangeAction.post(this.entries.get(i), | |
| 236 this, | |
| 237 SubscriptionChangeAction.Mode.QUERY_SUBSCRIPTION_ENABLED); | |
| 238 } | |
| 239 | |
| 240 this.entriesReady.acquireUninterruptibly(this.entries.size()); | |
| 241 } | |
| 242 } | |
| 243 | |
| 244 public List<Subscription> getSubscriptions(boolean enabled) | |
| 245 { | |
| 246 final List<Subscription> ret = new ArrayList<Subscription>(); | |
| 247 for (final Subscription e : this.entries) | |
| 248 { | |
| 249 if (this.isSubscriptionListed(e.url) == enabled) | |
| 250 { | |
| 251 ret.add(e); | |
| 252 } | |
| 253 } | |
| 254 return ret; | |
| 255 } | |
| 256 | |
| 257 public boolean isSubscriptionListed(final String url) | |
| 258 { | |
| 259 return this.enableState.containsKey(url) && this.enableState.get(url).bool
eanValue(); | |
| 260 } | |
| 261 | |
| 262 public void changeSubscriptionState(final String url, final boolean enable) | |
| 263 { | |
| 264 final Subscription e = this.urlMap.get(url); | |
| 265 if (e != null) | |
| 266 { | |
| 267 if (enable) | |
| 268 { | |
| 269 SubscriptionChangeAction.post(e, subscriptionContainer, | |
| 270 SubscriptionChangeAction.Mode.ENABLE_SUBSCRIPTION); | |
| 271 } | |
| 272 else | |
| 273 { | |
| 274 SubscriptionChangeAction.post(e, subscriptionContainer, | |
| 275 SubscriptionChangeAction.Mode.DISABLE_SUBSCRIPTION); | |
| 276 } | |
| 277 } | |
| 278 } | |
| 279 | |
| 280 @Override | |
| 281 public void onApiRequestSucceeded(NativeJSObject jsObject) | |
| 282 { | |
| 283 final XmlPullParser parser = Xml.newPullParser(); | |
| 284 try | |
| 285 { | |
| 286 parser.setFeature(XmlPullParser.FEATURE_PROCESS_NAMESPACES, false); | |
| 287 parser.setInput(new StringReader(AddOnBridge.getStringFromJsObject(jsObj
ect, "value", ""))); | |
| 288 parser.nextTag(); | |
| 289 parser.require(XmlPullParser.START_TAG, null, "subscriptions"); | |
| 290 while (parser.next() != XmlPullParser.END_TAG) | |
| 291 { | |
| 292 if (parser.getEventType() != XmlPullParser.START_TAG) | |
| 293 { | |
| 294 continue; | |
| 295 } | |
| 296 if ("subscription".equals(parser.getName())) | |
| 297 { | |
| 298 final String title = parser.getAttributeValue(null, "title"); | |
| 299 final String specialization = parser.getAttributeValue(null, "specia
lization"); | |
| 300 final String url = parser.getAttributeValue(null, "url"); | |
| 301 this.entries.add(new Subscription(title, specialization, url)); | |
| 302 } | |
| 303 parser.next(); | |
| 304 } | |
| 305 } | |
| 306 catch (XmlPullParserException e) | |
| 307 { | |
| 308 Log.e(TAG, "Failed to parse subscriptions.xml: " + e.getMessage(), e); | |
| 309 } | |
| 310 catch (IOException e) | |
| 311 { | |
| 312 Log.e(TAG, "Failed to parse subscriptions.xml: " + e.getMessage(), e); | |
| 313 } | |
| 314 finally | |
| 315 { | |
| 316 this.entriesReady.release(); | |
| 317 } | |
| 318 } | |
| 319 | |
| 320 @Override | |
| 321 public void onApiRequestFailed(String errorMessage) | |
| 322 { | |
| 323 Log.e(TAG, "Error: " + errorMessage); | |
| 324 this.entriesReady.release(); | |
| 325 } | |
| 326 | |
| 327 private static class SubscriptionChangeAction implements AdblockPlusApiCallb
ack | |
| 328 { | |
| 329 private static final String TAG = SubscriptionChangeAction.class.getName()
; | |
| 330 | |
| 331 private final Subscription subscription; | |
| 332 private final SubscriptionContainer parent; | |
| 333 private final Mode mode; | |
| 334 | |
| 335 public enum Mode | |
| 336 { | |
| 337 QUERY_SUBSCRIPTION_ENABLED, | |
| 338 ENABLE_SUBSCRIPTION, | |
| 339 DISABLE_SUBSCRIPTION, | |
| 340 } | |
| 341 | |
| 342 public SubscriptionChangeAction(final Subscription subscription, | |
| 343 final SubscriptionContainer parent, | |
| 344 final Mode mode) | |
| 345 { | |
| 346 this.subscription = subscription; | |
| 347 this.parent = parent; | |
| 348 this.mode = mode; | |
| 349 } | |
| 350 | |
| 351 public static SubscriptionChangeAction post(final Subscription subscriptio
n, | |
| 352 final SubscriptionContainer parent, | |
| 353 final Mode mode) | |
| 354 { | |
| 355 return new SubscriptionChangeAction(subscription, parent, mode).post(); | |
| 356 } | |
| 357 | |
| 358 public SubscriptionChangeAction post() | |
| 359 { | |
| 360 switch (this.mode) | |
| 361 { | |
| 362 case QUERY_SUBSCRIPTION_ENABLED: | |
| 363 AddOnBridge.querySubscriptionListStatus(this, this.subscription.url)
; | |
| 364 break; | |
| 365 case ENABLE_SUBSCRIPTION: | |
| 366 AddOnBridge.addSubscription(this, this.subscription.url, this.subscr
iption.title); | |
| 367 break; | |
| 368 case DISABLE_SUBSCRIPTION: | |
| 369 AddOnBridge.removeSubscription(this, this.subscription.url); | |
| 370 break; | |
| 371 default: | |
| 372 break; | |
| 373 } | |
| 374 return this; | |
| 375 } | |
| 376 | |
| 377 @Override | |
| 378 public void onApiRequestSucceeded(NativeJSObject jsObject) | |
| 379 { | |
| 380 switch (this.mode) | |
| 381 { | |
| 382 case QUERY_SUBSCRIPTION_ENABLED: | |
| 383 try | |
| 384 { | |
| 385 this.parent.enableState.put(this.subscription.url, | |
| 386 Boolean.valueOf(AddOnBridge.getBooleanFromJsObject(jsObject, "
value", false))); | |
| 387 } | |
| 388 finally | |
| 389 { | |
| 390 this.parent.entriesReady.release(); | |
| 391 } | |
| 392 break; | |
| 393 default: | |
| 394 break; | |
| 395 } | |
| 396 } | |
| 397 | |
| 398 @Override | |
| 399 public void onApiRequestFailed(String errorMessage) | |
| 400 { | |
| 401 switch (this.mode) | |
| 402 { | |
| 403 case QUERY_SUBSCRIPTION_ENABLED: | |
| 404 this.parent.enableState.put(this.subscription.url, Boolean.FALSE); | |
| 405 this.parent.entriesReady.release(); | |
| 406 break; | |
| 407 default: | |
| 408 break; | |
| 409 } | |
| 410 | |
| 411 Log.e(TAG, "Error for '" + this.subscription.url | |
| 412 + "', mode: " + this.mode + ": " | |
| 413 + errorMessage); | |
| 414 } | |
| 415 } | |
| 416 | |
| 417 public static class Subscription | |
| 418 { | |
| 419 public final String title; | |
| 420 public final String specialization; | |
| 421 public final String url; | |
| 422 | |
| 423 public Subscription(final String title, final String specialization, final
String url) | |
| 424 { | |
| 425 this.title = title; | |
| 426 this.specialization = specialization; | |
| 427 this.url = url; | |
| 428 } | |
| 429 | |
| 430 @Override | |
| 431 public String toString() | |
| 432 { | |
| 433 return this.specialization + " (" + this.title + ") @ " + this.url; | |
| 434 } | |
| 435 } | |
| 436 } | |
| 437 } | 179 } |
| 438 | 180 |
| LEFT | RIGHT |