keep track of watched content for subsequent shuffle sessions

app/src/main/java/io/lbry/browser/data/DatabaseHelper.java

@@ -21,7 +21,7 @@ import io.lbry.browser.utils.Helper;
 import io.lbry.browser.utils.LbryUri;
 
 public class DatabaseHelper extends SQLiteOpenHelper {
-    public static final int DATABASE_VERSION = 6;
+    public static final int DATABASE_VERSION = 7;
     public static final String DATABASE_NAME = "LbryApp.db";
     private static DatabaseHelper instance;
 
@@ -60,6 +60,7 @@ public class DatabaseHelper extends SQLiteOpenHelper {
                     ", is_read INTEGER DEFAULT 0 NOT NULL" +
                     ", is_seen INTEGER DEFAULT 0 NOT NULL " +
                     ", timestamp TEXT NOT NULL)",
+            "CREATE TABLE shuffle_watched (id INTEGER PRIMARY KEY NOT NULL, claim_id TEXT NOT NULL)"
     };
     private static final String[] SQL_CREATE_INDEXES = {
             "CREATE UNIQUE INDEX idx_subscription_url ON subscriptions (url)",
@@ -69,7 +70,8 @@ public class DatabaseHelper extends SQLiteOpenHelper {
             "CREATE UNIQUE INDEX idx_view_history_url_device ON view_history (url, device)",
             "CREATE INDEX idx_view_history_device ON view_history (device)",
             "CREATE UNIQUE INDEX idx_notification_remote_id ON notifications (remote_id)",
-            "CREATE INDEX idx_notification_timestamp ON notifications (timestamp)"
+            "CREATE INDEX idx_notification_timestamp ON notifications (timestamp)",
+            "CREATE UNIQUE INDEX idx_shuffle_watched_claim ON shuffle_watched (claim_id)",
     };
 
     private static final String[] SQL_V1_V2_UPGRADE = {
@@ -99,6 +101,10 @@ public class DatabaseHelper extends SQLiteOpenHelper {
     private static final String[] SQL_V5_V6_UPGRADE = {
             "ALTER TABLE notifications ADD COLUMN author_url TEXT"
     };
+    private static final String[] SQL_V6_V7_UPGRADE = {
+            "CREATE TABLE shuffle_watched (id INTEGER PRIMARY KEY NOT NULL, claim_id TEXT NOT NULL)",
+            "CREATE UNIQUE INDEX idx_shuffle_watched_claim ON shuffle_watched (claim_id)"
+    };
 
     private static final String SQL_INSERT_SUBSCRIPTION = "REPLACE INTO subscriptions (channel_name, url) VALUES (?, ?)";
     private static final String SQL_CLEAR_SUBSCRIPTIONS = "DELETE FROM subscriptions";
@@ -116,6 +122,9 @@ public class DatabaseHelper extends SQLiteOpenHelper {
     private static final String SQL_MARK_NOTIFICATIONS_READ = "UPDATE notifications SET is_read = 1 WHERE is_read = 0";
     private static final String SQL_MARK_NOTIFICATION_READ_AND_SEEN = "UPDATE notifications SET is_read = 1, is_seen = 1 WHERE id = ?";
 
+    private static final String SQL_INSERT_SHUFFLE_WATCHED = "REPLACE INTO shuffle_watched (claim_id) VALUES (?)";
+    private static final String SQL_GET_SHUFFLE_WATCHED_CLAIMS = "SELECT claim_id FROM shuffle_watched";
+
     private static final String SQL_INSERT_VIEW_HISTORY =
             "REPLACE INTO view_history (url, claim_id, claim_name, cost, currency, title, publisher_claim_id, publisher_name, publisher_title, thumbnail_url, device, release_time, timestamp) VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)";
     private static final String SQL_GET_VIEW_HISTORY =
@@ -174,6 +183,11 @@ public class DatabaseHelper extends SQLiteOpenHelper {
                 db.execSQL(sql);
             }
         }
+        if (oldVersion < 7) {
+            for (String sql : SQL_V6_V7_UPGRADE) {
+                db.execSQL(sql);
+            }
+        }
     }
     public void onDowngrade(SQLiteDatabase db, int oldVersion, int newVersion) {
 
@@ -190,6 +204,7 @@ public class DatabaseHelper extends SQLiteOpenHelper {
     public static void clearUrlHistoryBefore(Date date, SQLiteDatabase db) {
         db.execSQL(SQL_CLEAR_URL_HISTORY_BEFORE_TIME, new Object[] { new SimpleDateFormat(Helper.ISO_DATE_FORMAT_PATTERN).format(new Date()) });
     }
+
     // History items are essentially url suggestions
     public static List<UrlSuggestion> getRecentHistory(SQLiteDatabase db) {
         List<UrlSuggestion> suggestions = new ArrayList<>();
@@ -376,4 +391,20 @@ public class DatabaseHelper extends SQLiteOpenHelper {
     public static void markNotificationReadAndSeen(long notificationId, SQLiteDatabase db) {
         db.execSQL(SQL_MARK_NOTIFICATION_READ_AND_SEEN, new Object[] { notificationId });
     }
+    public static void createOrUpdateShuffleWatched(String claimId, SQLiteDatabase db) {
+        db.execSQL(SQL_INSERT_SHUFFLE_WATCHED, new Object[] { claimId });
+    }
+    public static List<String> getShuffleWatchedClaims(SQLiteDatabase db) {
+        List<String> claimIds = new ArrayList<>();
+        Cursor cursor = null;
+        try {
+            cursor = db.rawQuery(SQL_GET_SHUFFLE_WATCHED_CLAIMS, null);
+            while (cursor.moveToNext()) {
+                claimIds.add(cursor.getString(0));
+            }
+        } finally {
+            Helper.closeCursor(cursor);
+        }
+        return claimIds;
+    }
 }

app/src/main/java/io/lbry/browser/ui/findcontent/ShuffleFragment.java

@@ -3,6 +3,7 @@ package io.lbry.browser.ui.findcontent;
 import android.content.Context;
 import android.content.Intent;
 import android.content.SharedPreferences;
+import android.database.sqlite.SQLiteDatabase;
 import android.graphics.Color;
 import android.net.Uri;
 import android.os.AsyncTask;
@@ -45,6 +46,7 @@ import java.util.concurrent.TimeUnit;
 
 import io.lbry.browser.MainActivity;
 import io.lbry.browser.R;
+import io.lbry.browser.data.DatabaseHelper;
 import io.lbry.browser.exceptions.LbryUriException;
 import io.lbry.browser.model.Claim;
 import io.lbry.browser.model.lbryinc.Reward;
@@ -70,6 +72,7 @@ public class ShuffleFragment extends BaseFragment {
     private int playlistIndex;
     private Claim current;
     private List<Claim> playlist;
+    private List<String> watchedContentClaimIds;
 
     private long sessionStart;
     private ProgressBar surfModeLoading;
@@ -104,6 +107,10 @@ public class ShuffleFragment extends BaseFragment {
                         logPlay(currentUrl, startTimeMillis);
                         playbackStarted = true;
                         isPlaying = true;
+
+                        if (current != null) {
+                            saveWatchedContent(current.getClaimId());
+                        }
                     }
 
                     renderTotalDuration();
@@ -227,13 +234,14 @@ public class ShuffleFragment extends BaseFragment {
         }
 
         if (playlist == null) {
-            loadContent();
+            loadWatchedContentList();
         } else {
             if (current != null) {
                 playbackCurrentClaim();
             } else {
                 startPlaylist();
             }
+            loadAndScheduleDurations();
         }
     }
 
@@ -264,6 +272,46 @@ public class ShuffleFragment extends BaseFragment {
 
     }
 
+    private void loadWatchedContentList() {
+        (new AsyncTask<Void, Void, List<String>>() {
+            protected List<String> doInBackground(Void... params) {
+                MainActivity activity = (MainActivity) getContext();
+                if (activity != null) {
+                    try {
+                        SQLiteDatabase db = activity.getDbHelper().getReadableDatabase();
+                        return DatabaseHelper.getShuffleWatchedClaims(db);
+                    } catch (Exception ex) {
+                        // pass
+                    }
+                }
+                return null;
+            }
+            protected void onPostExecute(List<String> claimIds) {
+                watchedContentClaimIds = new ArrayList<>(claimIds);
+                if (playlist == null) {
+                    loadContent();
+                }
+            }
+        }).executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR);
+    }
+
+    private void saveWatchedContent(final String claimId) {
+        (new AsyncTask<Void, Void, Void>() {
+            protected Void doInBackground(Void... params) {
+                MainActivity activity = (MainActivity) getContext();
+                if (activity != null) {
+                    try {
+                        SQLiteDatabase db = activity.getDbHelper().getWritableDatabase();
+                        DatabaseHelper.createOrUpdateShuffleWatched(claimId, db);
+                    } catch (Exception ex) {
+                        // pass
+                    }
+                }
+                return  null;
+            }
+        }).executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR);
+    }
+
     private void loadContent() {
         if (playlist == null || playlist.size() == 0) {
             Helper.setViewVisibility(surfModeLoading, View.VISIBLE);
@@ -301,6 +349,7 @@ public class ShuffleFragment extends BaseFragment {
         playlistIndex = 0;
         current = playlist.get(playlistIndex);
         checkCurrentClaimIsVideo(false);
+        checkCurrentClaimWatched(false);
         playbackCurrentClaim();
     }
 
@@ -311,11 +360,26 @@ public class ShuffleFragment extends BaseFragment {
                 playlistIndex--;
             } else {
                 playlistIndex++;
+                checkPlaylistSize();
             }
             current = playlist.get(playlistIndex);
         }
     }
 
+    private void checkCurrentClaimWatched(boolean previous) {
+        if (current != null && watchedContentClaimIds != null) {
+            while (watchedContentClaimIds.contains(current.getClaimId())) {
+                if (previous) {
+                    playlistIndex--;
+                } else {
+                    playlistIndex++;
+                    checkPlaylistSize();
+                }
+                current = playlist.get(playlistIndex);
+            }
+        }
+    }
+
     private void playPreviousClaim() {
         if (playlist == null || playlist.size() == 0) {
             return;
@@ -325,6 +389,7 @@ public class ShuffleFragment extends BaseFragment {
         }
         current = playlist.get(playlistIndex);
         checkCurrentClaimIsVideo(true);
+        checkCurrentClaimWatched(true);
         playbackCurrentClaim();
     }
     private void playNextClaim() {
@@ -334,13 +399,18 @@ public class ShuffleFragment extends BaseFragment {
         if (playlistIndex < playlist.size() - 1) {
             playlistIndex++;
         }
+        checkPlaylistSize();
+        current = playlist.get(playlistIndex);
+        checkCurrentClaimIsVideo(false);
+        checkCurrentClaimWatched(false);
+        playbackCurrentClaim();
+    }
+
+    private void checkPlaylistSize() {
         if (playlist.size() - playlistIndex < 10) {
             currentClaimSearchPage++;
             loadContent();
         }
-        current = playlist.get(playlistIndex);
-        checkCurrentClaimIsVideo(false);
-        playbackCurrentClaim();
     }
 
     private void playbackCurrentClaim() {