From fcb5bf4dd4a75cf9cdeeee82463cf044ef1ed41d Mon Sep 17 00:00:00 2001 From: inorichi Date: Sun, 10 Jan 2016 17:47:43 +0100 Subject: [PATCH] Add an option to update the library automatically after a specified time and an option to update only non completed mangas. Other minor changes. --- app/build.gradle | 4 +- app/src/main/AndroidManifest.xml | 9 ++ .../mangafeed/data/network/NetworkHelper.java | 4 +- .../data/preference/PreferencesHelper.java | 9 ++ .../data/sync/LibraryUpdateAlarm.java | 62 ++++++++++++ .../data/sync/LibraryUpdateService.java | 95 ++++++++++++------ .../mangafeed/ui/library/LibraryFragment.java | 5 +- .../ui/setting/SettingsGeneralFragment.java | 14 ++- .../res/drawable-xhdpi/card_background.9.png | Bin 934 -> 755 bytes app/src/main/res/values/arrays.xml | 22 ++++ app/src/main/res/values/keys.xml | 2 + app/src/main/res/values/strings.xml | 16 ++- app/src/main/res/xml/pref_general.xml | 13 +++ 13 files changed, 209 insertions(+), 46 deletions(-) create mode 100644 app/src/main/java/eu/kanade/mangafeed/data/sync/LibraryUpdateAlarm.java diff --git a/app/build.gradle b/app/build.gradle index ab932e1a4..2cc0bab75 100644 --- a/app/build.gradle +++ b/app/build.gradle @@ -89,8 +89,8 @@ dependencies { compile "com.android.support:design:$SUPPORT_LIBRARY_VERSION" compile "com.android.support:recyclerview-v7:$SUPPORT_LIBRARY_VERSION" compile "com.android.support:support-annotations:$SUPPORT_LIBRARY_VERSION" - compile 'com.squareup.okhttp:okhttp-urlconnection:2.7.0' - compile 'com.squareup.okhttp:okhttp:2.7.0' + compile 'com.squareup.okhttp:okhttp-urlconnection:2.7.2' + compile 'com.squareup.okhttp:okhttp:2.7.2' compile 'com.squareup.okio:okio:1.6.0' compile 'com.google.code.gson:gson:2.5' compile 'com.jakewharton:disklrucache:2.0.2' diff --git a/app/src/main/AndroidManifest.xml b/app/src/main/AndroidManifest.xml index 9dfb27f33..2a062750c 100644 --- a/app/src/main/AndroidManifest.xml +++ b/app/src/main/AndroidManifest.xml @@ -6,6 +6,7 @@ + + + + + + + + diff --git a/app/src/main/java/eu/kanade/mangafeed/data/network/NetworkHelper.java b/app/src/main/java/eu/kanade/mangafeed/data/network/NetworkHelper.java index 90a7d6b3e..2ea70d691 100644 --- a/app/src/main/java/eu/kanade/mangafeed/data/network/NetworkHelper.java +++ b/app/src/main/java/eu/kanade/mangafeed/data/network/NetworkHelper.java @@ -44,7 +44,7 @@ public final class NetworkHelper { } catch (Throwable e) { return Observable.error(e); } - }).retry(2); + }).retry(1); } public Observable mapResponseToString(final Response response) { @@ -74,7 +74,7 @@ public final class NetworkHelper { } catch (Throwable e) { return Observable.error(e); } - }).retry(2); + }).retry(1); } public Observable getProgressResponse(final String url, final Headers headers, final ProgressListener listener) { diff --git a/app/src/main/java/eu/kanade/mangafeed/data/preference/PreferencesHelper.java b/app/src/main/java/eu/kanade/mangafeed/data/preference/PreferencesHelper.java index 3a067429d..b48bf0c7b 100644 --- a/app/src/main/java/eu/kanade/mangafeed/data/preference/PreferencesHelper.java +++ b/app/src/main/java/eu/kanade/mangafeed/data/preference/PreferencesHelper.java @@ -97,6 +97,10 @@ public class PreferencesHelper { return rxPrefs.getInteger(getKey(R.string.pref_library_columns_landscape_key), 0); } + public boolean updateOnlyNonCompleted() { + return prefs.getBoolean(getKey(R.string.pref_update_only_non_completed_key), false); + } + public Preference imageDecoder() { return rxPrefs.getInteger(getKey(R.string.pref_image_decoder_key), 0); } @@ -148,4 +152,9 @@ public class PreferencesHelper { return rxPrefs.getInteger(getKey(R.string.pref_download_slots_key), 1); } + public static int getLibraryUpdateInterval(Context context) { + return PreferenceManager.getDefaultSharedPreferences(context).getInt( + context.getString(R.string.pref_library_update_interval_key), 0); + } + } diff --git a/app/src/main/java/eu/kanade/mangafeed/data/sync/LibraryUpdateAlarm.java b/app/src/main/java/eu/kanade/mangafeed/data/sync/LibraryUpdateAlarm.java new file mode 100644 index 000000000..49ac67bbd --- /dev/null +++ b/app/src/main/java/eu/kanade/mangafeed/data/sync/LibraryUpdateAlarm.java @@ -0,0 +1,62 @@ +package eu.kanade.mangafeed.data.sync; + +import android.app.AlarmManager; +import android.app.PendingIntent; +import android.content.BroadcastReceiver; +import android.content.Context; +import android.content.Intent; +import android.os.SystemClock; + +import eu.kanade.mangafeed.data.preference.PreferencesHelper; +import timber.log.Timber; + +public class LibraryUpdateAlarm extends BroadcastReceiver { + + public static final String LIBRARY_UPDATE_ACTION = "eu.kanade.UPDATE_LIBRARY"; + + public static void startAlarm(Context context) { + startAlarm(context, PreferencesHelper.getLibraryUpdateInterval(context)); + } + + public static void startAlarm(Context context, int intervalInHours) { + stopAlarm(context); + if (intervalInHours == 0) + return; + + int intervalInMillis = intervalInHours * 60 * 60 * 1000; + long nextRun = SystemClock.elapsedRealtime() + intervalInMillis; + + AlarmManager alarmManager = (AlarmManager) context.getSystemService(Context.ALARM_SERVICE); + PendingIntent pendingIntent = getPendingIntent(context); + alarmManager.setInexactRepeating(AlarmManager.ELAPSED_REALTIME_WAKEUP, + nextRun, intervalInMillis, pendingIntent); + + Timber.i("Alarm set. Library will update on " + nextRun); + } + + public static void stopAlarm(Context context) { + AlarmManager alarmManager = (AlarmManager) context.getSystemService(Context.ALARM_SERVICE); + PendingIntent pendingIntent = getPendingIntent(context); + alarmManager.cancel(pendingIntent); + } + + private static PendingIntent getPendingIntent(Context context) { + Intent intent = new Intent(context, LibraryUpdateAlarm.class); + intent.setAction(LIBRARY_UPDATE_ACTION); + return PendingIntent.getBroadcast(context, 0, intent, 0); + } + + @Override + public void onReceive(Context context, Intent intent) { + if (intent.getAction() == null) + return; + + if (intent.getAction().equals(Intent.ACTION_BOOT_COMPLETED)) { + startAlarm(context); + } else if (intent.getAction().equals(LIBRARY_UPDATE_ACTION)) { + LibraryUpdateService.start(context); + } + + } + +} diff --git a/app/src/main/java/eu/kanade/mangafeed/data/sync/LibraryUpdateService.java b/app/src/main/java/eu/kanade/mangafeed/data/sync/LibraryUpdateService.java index 7bfd893da..114b136c0 100644 --- a/app/src/main/java/eu/kanade/mangafeed/data/sync/LibraryUpdateService.java +++ b/app/src/main/java/eu/kanade/mangafeed/data/sync/LibraryUpdateService.java @@ -17,6 +17,7 @@ import eu.kanade.mangafeed.BuildConfig; import eu.kanade.mangafeed.R; import eu.kanade.mangafeed.data.database.DatabaseHelper; import eu.kanade.mangafeed.data.database.models.Manga; +import eu.kanade.mangafeed.data.preference.PreferencesHelper; import eu.kanade.mangafeed.data.source.SourceManager; import eu.kanade.mangafeed.util.AndroidComponentUtil; import eu.kanade.mangafeed.util.NetworkUtil; @@ -31,16 +32,23 @@ public class LibraryUpdateService extends Service { @Inject DatabaseHelper db; @Inject SourceManager sourceManager; + @Inject PreferencesHelper preferences; - private Subscription updateSubscription; + private Subscription subscription; public static final int UPDATE_NOTIFICATION_ID = 1; - public static Intent getStartIntent(Context context) { + public static void start(Context context) { + if (!isRunning(context)) { + context.startService(getStartIntent(context)); + } + } + + private static Intent getStartIntent(Context context) { return new Intent(context, LibraryUpdateService.class); } - public static boolean isRunning(Context context) { + private static boolean isRunning(Context context) { return AndroidComponentUtil.isServiceRunning(context, LibraryUpdateService.class); } @@ -52,8 +60,10 @@ public class LibraryUpdateService extends Service { @Override public void onDestroy() { - if (updateSubscription != null) - updateSubscription.unsubscribe(); + if (subscription != null) + subscription.unsubscribe(); + // Reset the alarm + LibraryUpdateAlarm.startAlarm(this); super.onDestroy(); } @@ -68,44 +78,56 @@ public class LibraryUpdateService extends Service { return START_NOT_STICKY; } - Observable.fromCallable(() -> db.getFavoriteMangas().executeAsBlocking()) + subscription = Observable.fromCallable(() -> db.getFavoriteMangas().executeAsBlocking()) .subscribeOn(Schedulers.io()) - .subscribe(mangas -> { - startUpdating(mangas, startId); - }); + .flatMap(this::updateLibrary) + .subscribe(next -> {}, + error -> { + NotificationUtil.create(this, UPDATE_NOTIFICATION_ID, + getString(R.string.notification_update_error), ""); + stopSelf(startId); + }, () -> { + Timber.i("Library updated"); + stopSelf(startId); + }); return START_STICKY; } - private void startUpdating(final List mangas, final int startId) { + private Observable updateLibrary(List allLibraryMangas) { final AtomicInteger count = new AtomicInteger(0); + final List updates = new ArrayList<>(); + final List failedUpdates = new ArrayList<>(); - List updates = new ArrayList<>(); + final List mangas = !preferences.updateOnlyNonCompleted() ? allLibraryMangas : + Observable.from(allLibraryMangas) + .filter(manga -> manga.status != Manga.COMPLETED) + .toList().toBlocking().single(); - updateSubscription = Observable.from(mangas) - .doOnNext(manga -> { - NotificationUtil.create(this, UPDATE_NOTIFICATION_ID, - getString(R.string.notification_progress, - count.incrementAndGet(), mangas.size()), manga.title); - }) - .concatMap(manga -> sourceManager.get(manga.source) - .pullChaptersFromNetwork(manga.url) - .flatMap(chapters -> db.insertOrRemoveChapters(manga, chapters)) - .filter(result -> result.getNumberOfRowsInserted() > 0) - .flatMap(result -> Observable.just(new MangaUpdate(manga, result)))) - .subscribe(update -> { - updates.add(update); - }, error -> { - Timber.e("Error syncing"); - stopSelf(startId); - }, () -> { - NotificationUtil.createBigText(this, UPDATE_NOTIFICATION_ID, - getString(R.string.notification_completed), getUpdatedMangas(updates)); - stopSelf(startId); - }); + return Observable.from(mangas) + .doOnNext(manga -> NotificationUtil.create(this, UPDATE_NOTIFICATION_ID, + getString(R.string.notification_update_progress, + count.incrementAndGet(), mangas.size()), manga.title)) + .concatMap(manga -> updateManga(manga) + .onErrorReturn(error -> { + failedUpdates.add(manga); + return new PostResult(0, 0, 0); + }) + .filter(result -> result.getNumberOfRowsInserted() > 0) + .map(result -> new MangaUpdate(manga, result))) + .doOnNext(updates::add) + .doOnCompleted(() -> NotificationUtil.createBigText(this, UPDATE_NOTIFICATION_ID, + getString(R.string.notification_update_completed), + getUpdatedMangas(updates, failedUpdates))); } - private String getUpdatedMangas(List updates) { + private Observable updateManga(Manga manga) { + return sourceManager.get(manga.source) + .pullChaptersFromNetwork(manga.url) + .flatMap(chapters -> db.insertOrRemoveChapters(manga, chapters)); + } + + private String getUpdatedMangas(List updates, List failedUpdates) { final StringBuilder result = new StringBuilder(); if (updates.isEmpty()) { result.append(getString(R.string.notification_no_new_chapters)).append("\n"); @@ -116,6 +138,13 @@ public class LibraryUpdateService extends Service { result.append("\n").append(update.getManga().title); } } + if (!failedUpdates.isEmpty()) { + result.append("\n"); + result.append(getString(R.string.notification_manga_update_failed)); + for (Manga manga : failedUpdates) { + result.append("\n").append(manga.title); + } + } return result.toString(); } diff --git a/app/src/main/java/eu/kanade/mangafeed/ui/library/LibraryFragment.java b/app/src/main/java/eu/kanade/mangafeed/ui/library/LibraryFragment.java index 2f8c7dbbf..196b02abb 100644 --- a/app/src/main/java/eu/kanade/mangafeed/ui/library/LibraryFragment.java +++ b/app/src/main/java/eu/kanade/mangafeed/ui/library/LibraryFragment.java @@ -105,10 +105,7 @@ public class LibraryFragment extends BaseRxFragment public boolean onOptionsItemSelected(MenuItem item) { switch (item.getItemId()) { case R.id.action_refresh: - if (!LibraryUpdateService.isRunning(getActivity())) { - Intent intent = LibraryUpdateService.getStartIntent(getActivity()); - getActivity().startService(intent); - } + LibraryUpdateService.start(getActivity()); return true; case R.id.action_edit_categories: onEditCategories(); diff --git a/app/src/main/java/eu/kanade/mangafeed/ui/setting/SettingsGeneralFragment.java b/app/src/main/java/eu/kanade/mangafeed/ui/setting/SettingsGeneralFragment.java index f4443983a..a411ddd10 100644 --- a/app/src/main/java/eu/kanade/mangafeed/ui/setting/SettingsGeneralFragment.java +++ b/app/src/main/java/eu/kanade/mangafeed/ui/setting/SettingsGeneralFragment.java @@ -7,12 +7,12 @@ import android.view.ViewGroup; import eu.kanade.mangafeed.R; import eu.kanade.mangafeed.data.preference.PreferencesHelper; +import eu.kanade.mangafeed.data.sync.LibraryUpdateAlarm; +import eu.kanade.mangafeed.ui.setting.preference.IntListPreference; import eu.kanade.mangafeed.ui.setting.preference.LibraryColumnsDialog; public class SettingsGeneralFragment extends SettingsNestedFragment { - private LibraryColumnsDialog columnsDialog; - public static SettingsNestedFragment newInstance(int resourcePreference, int resourceTitle) { SettingsNestedFragment fragment = new SettingsGeneralFragment(); fragment.setArgs(resourcePreference, resourceTitle); @@ -25,11 +25,19 @@ public class SettingsGeneralFragment extends SettingsNestedFragment { PreferencesHelper preferences = getSettingsActivity().preferences; - columnsDialog = (LibraryColumnsDialog) findPreference( + LibraryColumnsDialog columnsDialog = (LibraryColumnsDialog) findPreference( getString(R.string.pref_library_columns_dialog_key)); columnsDialog.setPreferencesHelper(preferences); + IntListPreference updateInterval = (IntListPreference) findPreference( + getString(R.string.pref_library_update_interval_key)); + + updateInterval.setOnPreferenceChangeListener((preference, newValue) -> { + LibraryUpdateAlarm.startAlarm(getActivity(), Integer.parseInt((String) newValue)); + return true; + }); + return view; } diff --git a/app/src/main/res/drawable-xhdpi/card_background.9.png b/app/src/main/res/drawable-xhdpi/card_background.9.png index 52f1612dd43ffe2a322fa1b1e7c66be837efbdb0..8190c3b276cb2cd7a45c53966e28773fd091b854 100755 GIT binary patch literal 755 zcmeAS@N?(olHy`uVBq!ia0vp^F(Ayr1|%Q9zZAj1z_iQL#WAGf*4w*@-iHkY8WOkX zZC(4KjpwDqF^3EP|8uAJTJAi$#dmYbt#`IN&g=OfRuwGTxx2gna<96h0E?qQaR1RG zMUy&C&wMh!ZjNQsvOfxoozs2S&51d0a)YyxBE*C+{BFlq(Z$9rjaT z>DCjXRaX}6%9wfAXmhF?_owc&yH5V~*&Oy*q-N$vqsyD8&F%fZzb-b_C3*Tc?tIHQ ziDq}x%hyk>Ub|ezAbUWr`-E=Lcw0;i<^IYPMsLduc_~UPUrjEn5F|? z*SVA_8}0sHA89$;+gtxIeSf>%cuLll z-dTRQ((s>Yy)F9!8?ikMH3k)hniZ+xi3fHcG{2^$x#P`2#{Xs(s}7%E@jxEv@B@tO zG6iH2f9#u!pFZ&l_uCOt%4c_Ksn$B)wnp`xW+#r`c=+I=c=FC)vTXC7yfQz_d+5Mq z6Y~YN?hz`P_Z^#OS$ufGX1XPTi~nY`dgeiw$s7N9+)C*&tNL3QC~eCr<=S@KwO6V3 z!4{{teM{B`WPZCX?>YPLrE|ON7u}BB?RfaxMConq3qGqH?C=-*aQ{oT*nL=lAQd`05I&H>cij`uO9nJ@>qF6^QV9V*A+A6g6Zm8nVhWNcqFWXJ z1*lWLB*-tAkwZvp5T~jQq zYqglWqHIh1in`TzV=vY9d)Uvt7`4*O;kZGiMq8=$k|@s4>x=#Pj{SV2qAaMtF!_>z zw#l>d<%Wr!6W4SfYg@6QuP}LQxI=QHy9wK=>}-qIS~`NB8P=ICY_INIk;y9RYZ7yN zByn=ZzRUYtn!bLRDp}F(_G|sV`<%ym+a`FkTxi>@D`+mvcQJUnx5cf;5TRLIjiDK@ zVix5!Rq6hir4Y6A<2>&>?#oSX3KVMcd@SH&oHwJ=P-x;kYn637kBD|YeH$(OaV>-S z6XE9OA89$9eJpd&DX4X^{CAmP%=u}iz$+c6&iS3o&Z)n8#^2$sSE%Wt$Q9V(B(g}L zRRhXQa&Of*a=(DB=$hxb``%wltRDX;T=e%m%MQc;bIM9SC@0#s82im;uK4Y@WHzhc z7A}ipUki8J&fov$-OoLD<-%o@G<+*|#e1~4ELy%$^7ZeppB&Qi`;R}ZT7O*af*j{g z)m<|`IK&$Bef?Xv{~e$Fs`ibAB7b~JvKP4?;#jM&z>x27zT0G#U ztlgG7Z;mQP>{fjw(aq?<&$@x*v_NOaQQM;xCR^T%8vPDl_1%hVPU-sBt6Yv4E-}2O zXTIj|yJ^v3*}W4BJ9q_o)pjag<66kC+OqXX!O2A*IwN@UcpRU3v`8ElPxM`)I$tnk zhoy*}M!JG-snVoI4lVB*_m}tfMRRgb?CDS_-jKJ>*GXxTq4Gt`FzMBkCUm5@s4mZX w`Mlr6Pm{6JBK+rVyBR0f3;g`cI{)xruI!oi6RKn;d1 + + @string/update_never + @string/update_1hour + @string/update_2hour + @string/update_3hour + @string/update_6hour + @string/update_12hour + @string/update_24hour + @string/update_48hour + + + + 0 + 1 + 2 + 3 + 6 + 12 + 24 + 48 + + \ No newline at end of file diff --git a/app/src/main/res/values/keys.xml b/app/src/main/res/values/keys.xml index 66fbbf4a5..71612af6b 100644 --- a/app/src/main/res/values/keys.xml +++ b/app/src/main/res/values/keys.xml @@ -10,6 +10,8 @@ pref_library_columns_dialog_key pref_library_columns_portrait_key pref_library_columns_landscape_key + pref_library_update_interval_key + pref_update_only_non_completed_key pref_default_viewer_key pref_hide_status_bar_key diff --git a/app/src/main/res/values/strings.xml b/app/src/main/res/values/strings.xml index 4fc74f371..c36a19479 100644 --- a/app/src/main/res/values/strings.xml +++ b/app/src/main/res/values/strings.xml @@ -63,6 +63,16 @@ Portrait Landscape Default + Library update period + Update only non completed mangas + Manual + Hourly + Every 2 hours + Every 3 hours + Every 6 hours + Every 12 hours + Daily + Every 2 days Hide status bar @@ -168,9 +178,11 @@ The image could not be loaded.\nTry to change the image decoder - Update progress: %1$d/%2$d - Update completed + Update progress: %1$d/%2$d + Update completed + An unexpected error occurred updating the library No new chapters found Found new chapters for: + Failed updating mangas: diff --git a/app/src/main/res/xml/pref_general.xml b/app/src/main/res/xml/pref_general.xml index c0ad44871..4d4747cc2 100644 --- a/app/src/main/res/xml/pref_general.xml +++ b/app/src/main/res/xml/pref_general.xml @@ -6,4 +6,17 @@ android:persistent="false" android:title="@string/pref_library_columns"/> + + + + \ No newline at end of file