Add option to view only notifications

src/invidious.cr

@@ -1769,20 +1769,25 @@ post "/preferences" do |env|
     unseen_only ||= "off"
     unseen_only = unseen_only == "on"
 
+    notifications_only = env.params.body["notifications_only"]?.try &.as(String)
+    notifications_only ||= "off"
+    notifications_only = notifications_only == "on"
+
     preferences = {
-      "video_loop"    => video_loop,
-      "autoplay"      => autoplay,
-      "speed"         => speed,
-      "quality"       => quality,
-      "volume"        => volume,
-      "comments"      => comments,
-      "redirect_feed" => redirect_feed,
-      "dark_mode"     => dark_mode,
-      "thin_mode"     => thin_mode,
-      "max_results"   => max_results,
-      "sort"          => sort,
-      "latest_only"   => latest_only,
-      "unseen_only"   => unseen_only,
+      "video_loop"         => video_loop,
+      "autoplay"           => autoplay,
+      "speed"              => speed,
+      "quality"            => quality,
+      "volume"             => volume,
+      "comments"           => comments,
+      "redirect_feed"      => redirect_feed,
+      "dark_mode"          => dark_mode,
+      "thin_mode"          => thin_mode,
+      "max_results"        => max_results,
+      "sort"               => sort,
+      "latest_only"        => latest_only,
+      "unseen_only"        => unseen_only,
+      "notifications_only" => notifications_only,
     }.to_json
 
     PG_DB.exec("UPDATE users SET preferences = $1 WHERE email = $2", preferences, user.email)
@@ -1823,61 +1828,84 @@ get "/feed/subscriptions" do |env|
       offset = (page - 1) * max_results
     end
 
-    if preferences.latest_only
-      if preferences.unseen_only
-        ucids = arg_array(user.subscriptions)
-        if user.watched.empty?
-          watched = "'{}'"
-        else
-          watched = arg_array(user.watched, user.subscriptions.size + 1)
-        end
+    notifications = PG_DB.query_one("SELECT notifications FROM users WHERE email = $1", user.email,
+      as: Array(String))
+    if preferences.notifications_only && !notifications.empty?
+      args = arg_array(notifications)
 
-        videos = PG_DB.query_all("SELECT DISTINCT ON (ucid) * FROM channel_videos WHERE \
-      ucid IN (#{ucids}) AND id NOT IN (#{watched}) ORDER BY ucid, published DESC",
-          user.subscriptions + user.watched, as: ChannelVideo)
-      else
-        args = arg_array(user.subscriptions)
-        videos = PG_DB.query_all("SELECT DISTINCT ON (ucid) * FROM channel_videos WHERE \
-        ucid IN (#{args}) ORDER BY ucid, published DESC", user.subscriptions, as: ChannelVideo)
-      end
+      videos = PG_DB.query_all("SELECT * FROM channel_videos WHERE id IN (#{args})
+      ORDER BY published DESC", notifications, as: ChannelVideo)
+      notifications = [] of ChannelVideo
 
       videos.sort_by! { |video| video.published }.reverse!
+
+      case preferences.sort
+      when "alphabetically"
+        videos.sort_by! { |video| video.title }
+      when "alphabetically - reverse"
+        videos.sort_by! { |video| video.title }.reverse!
+      when "channel name"
+        videos.sort_by! { |video| video.author }
+      when "channel name - reverse"
+        videos.sort_by! { |video| video.author }.reverse!
+      end
     else
-      if preferences.unseen_only
-        ucids = arg_array(user.subscriptions, 3)
-        if user.watched.empty?
-          watched = "'{}'"
+      if preferences.latest_only
+        if preferences.unseen_only
+          ucids = arg_array(user.subscriptions)
+          if user.watched.empty?
+            watched = "'{}'"
+          else
+            watched = arg_array(user.watched, user.subscriptions.size + 1)
+          end
+
+          videos = PG_DB.query_all("SELECT DISTINCT ON (ucid) * FROM channel_videos WHERE \
+      ucid IN (#{ucids}) AND id NOT IN (#{watched}) ORDER BY ucid, published DESC",
+            user.subscriptions + user.watched, as: ChannelVideo)
         else
-          watched = arg_array(user.watched, user.subscriptions.size + 3)
+          args = arg_array(user.subscriptions)
+          videos = PG_DB.query_all("SELECT DISTINCT ON (ucid) * FROM channel_videos WHERE \
+        ucid IN (#{args}) ORDER BY ucid, published DESC", user.subscriptions, as: ChannelVideo)
         end
 
-        videos = PG_DB.query_all("SELECT * FROM channel_videos WHERE ucid IN (#{ucids}) \
-          AND id NOT IN (#{watched}) ORDER BY published DESC LIMIT $1 OFFSET $2",
-          [limit, offset] + user.subscriptions + user.watched, as: ChannelVideo)
+        videos.sort_by! { |video| video.published }.reverse!
       else
-        args = arg_array(user.subscriptions, 3)
-        videos = PG_DB.query_all("SELECT * FROM channel_videos WHERE ucid IN (#{args}) \
+        if preferences.unseen_only
+          ucids = arg_array(user.subscriptions, 3)
+          if user.watched.empty?
+            watched = "'{}'"
+          else
+            watched = arg_array(user.watched, user.subscriptions.size + 3)
+          end
+
+          videos = PG_DB.query_all("SELECT * FROM channel_videos WHERE ucid IN (#{ucids}) \
+          AND id NOT IN (#{watched}) ORDER BY published DESC LIMIT $1 OFFSET $2",
+            [limit, offset] + user.subscriptions + user.watched, as: ChannelVideo)
+        else
+          args = arg_array(user.subscriptions, 3)
+          videos = PG_DB.query_all("SELECT * FROM channel_videos WHERE ucid IN (#{args}) \
           ORDER BY published DESC LIMIT $1 OFFSET $2", [limit, offset] + user.subscriptions, as: ChannelVideo)
+        end
       end
-    end
 
-    case preferences.sort
-    when "alphabetically"
-      videos.sort_by! { |video| video.title }
-    when "alphabetically - reverse"
-      videos.sort_by! { |video| video.title }.reverse!
-    when "channel name"
-      videos.sort_by! { |video| video.author }
-    when "channel name - reverse"
-      videos.sort_by! { |video| video.author }.reverse!
-    end
+      case preferences.sort
+      when "alphabetically"
+        videos.sort_by! { |video| video.title }
+      when "alphabetically - reverse"
+        videos.sort_by! { |video| video.title }.reverse!
+      when "channel name"
+        videos.sort_by! { |video| video.author }
+      when "channel name - reverse"
+        videos.sort_by! { |video| video.author }.reverse!
+      end
 
-    # TODO: Add option to disable picking out notifications from regular feed
-    notifications = PG_DB.query_one("SELECT notifications FROM users WHERE email = $1", user.email,
-      as: Array(String))
+      # TODO: Add option to disable picking out notifications from regular feed
+      notifications = PG_DB.query_one("SELECT notifications FROM users WHERE email = $1", user.email,
+        as: Array(String))
 
-    notifications = videos.select { |v| notifications.includes? v.id }
-    videos = videos - notifications
+      notifications = videos.select { |v| notifications.includes? v.id }
+      videos = videos - notifications
+    end
 
     if !limit
       videos = videos[0..max_results]

src/invidious/helpers.cr

@@ -176,10 +176,15 @@ class Preferences
       nilable: true,
       default: false,
     },
-    max_results: Int32,
-    sort:        String,
-    latest_only: Bool,
-    unseen_only: Bool,
+    max_results:        Int32,
+    sort:               String,
+    latest_only:        Bool,
+    unseen_only:        Bool,
+    notifications_only: {
+      type:    Bool,
+      nilable: true,
+      default: false,
+    },
   })
 end
 

src/invidious/views/preferences.ecr

@@ -97,6 +97,11 @@ function update_value(element) {
                 <input name="unseen_only" id="unseen_only" type="checkbox" <% if user.preferences.unseen_only %>checked<% end %>>
             </div>
 
+            <div class="pure-control-group">
+                <label for="notifications_only">Only show notifications: </label>
+                <input name="notifications_only" id="notifications_only" type="checkbox" <% if user.preferences.notifications_only %>checked<% end %>>
+            </div>
+
             <legend>Data preferences</legend>
             <div class="pure-control-group">
                 <label>