Merge: promote dev to prod

backend/app/routes/feed.py

@@ -66,33 +66,49 @@ def _filtered_query(
     include_shorts: bool,
     include_live: bool,
     show: str,
+    scope: str = "my",
 ) -> tuple[Select, object]:
     """Build the feed query (joins + all WHERE filters), shared by /feed and /feed/count.
-    Returns the column-bearing select plus the watch-status expression for sorting."""
+    Returns the column-bearing select plus the watch-status expression for sorting.
+
+    `scope="my"` (default) restricts the feed to the user's own non-hidden subscriptions.
+    `scope="all"` shows every video in the shared catalog (any user's ingested channels);
+    the subscription is then only LEFT-joined so per-channel priority still resolves for
+    channels the user happens to be subscribed to. Per-user watch state stays private in
+    either mode via the VideoState outer join."""
     state = aliased(VideoState)
     status_expr = func.coalesce(state.status, "new")
     position_expr = func.coalesce(state.position_seconds, 0)
 
-    query = (
-        select(
-            Video.id,
-            Video.title,
-            Video.channel_id,
-            Channel.title.label("channel_title"),
-            Channel.thumbnail_url.label("channel_thumbnail"),
-            Channel.handle.label("channel_handle"),
-            Video.published_at,
-            Video.thumbnail_url,
-            Video.duration_seconds,
-            Video.view_count,
-            Video.is_short,
-            Video.live_status,
-            status_expr.label("status"),
-            position_expr.label("position_seconds"),
+    query = select(
+        Video.id,
+        Video.title,
+        Video.channel_id,
+        Channel.title.label("channel_title"),
+        Channel.thumbnail_url.label("channel_thumbnail"),
+        Channel.handle.label("channel_handle"),
+        Video.published_at,
+        Video.thumbnail_url,
+        Video.duration_seconds,
+        Video.view_count,
+        Video.is_short,
+        Video.live_status,
+        status_expr.label("status"),
+        position_expr.label("position_seconds"),
+    ).join(Channel, Channel.id == Video.channel_id)
+
+    if scope == "all":
+        # Whole shared catalog; subscription is optional (only for priority sort).
+        query = query.outerjoin(
+            Subscription,
+            and_(
+                Subscription.channel_id == Video.channel_id,
+                Subscription.user_id == user.id,
+            ),
         )
-        .join(Channel, Channel.id == Video.channel_id)
+    else:
         # Only channels this user is subscribed to (and hasn't hidden).
-        .join(
+        query = query.join(
             Subscription,
             and_(
                 Subscription.channel_id == Video.channel_id,
@@ -100,7 +116,9 @@ def _filtered_query(
                 Subscription.hidden.is_(False),
             ),
         )
-        .outerjoin(state, and_(state.video_id == Video.id, state.user_id == user.id))
+
+    query = query.outerjoin(
+        state, and_(state.video_id == Video.id, state.user_id == user.id)
     )
 
     if channel_id:
@@ -199,6 +217,7 @@ def _feed_params(
     include_shorts: bool = False,
     include_live: bool = False,
     show: str = "unwatched",
+    scope: str = "my",
 ) -> dict:
     return {
         "tags": tags,
@@ -214,6 +233,7 @@ def _feed_params(
         "include_shorts": include_shorts,
         "include_live": include_live,
         "show": show,
+        "scope": scope,
     }
 
 
@@ -226,7 +246,8 @@ SORTS = {
     "title": func.lower(Video.title).asc().nulls_last(),
     "subscribers": Channel.subscriber_count.desc().nulls_last(),
     # Your per-channel priority (set in the channel manager), newest first within a tier.
-    "priority": Subscription.priority.desc(),
+    # coalesce keeps it null-safe in "all" scope where unsubscribed channels have no row.
+    "priority": func.coalesce(Subscription.priority, 0).desc(),
 }
 
 
@@ -243,7 +264,8 @@ def get_feed(
     query, _status = _filtered_query(db, user, **params)
     if sort == "priority":
         query = query.order_by(
-            Subscription.priority.desc(), Video.published_at.desc().nulls_last()
+            func.coalesce(Subscription.priority, 0).desc(),
+            Video.published_at.desc().nulls_last(),
         )
     else:
         order = SORTS.get(sort)

frontend/src/App.tsx

@@ -39,6 +39,7 @@ const DEFAULT_FILTERS: FeedFilters = {
   tagMode: "or",
   q: "",
   sort: "newest",
+  scope: "my",
   includeNormal: true,
   includeShorts: false,
   includeLive: false,

frontend/src/components/Channels.tsx

@@ -444,7 +444,7 @@ function ChannelRow({
             <Tooltip hint={t("channels.row.queuedByOtherHint")}>
               <span className="inline-flex items-center gap-1 text-[10px] px-1.5 py-0.5 rounded-full border border-accent/40 text-accent">
                 <History className="w-3 h-3" />
-                {t("channels.row.fullHistoryQueued")}
+                {t("channels.row.fullHistoryComing")}
               </span>
             </Tooltip>
           ) : (

frontend/src/components/Feed.tsx

@@ -148,7 +148,9 @@ export default function Feed({
   if (query.isLoading) return <div className="p-8 text-muted">{t("feed.loading")}</div>;
   if (query.isError) return <div className="p-8 text-muted">{t("feed.loadError")}</div>;
   if (items.length === 0) {
-    if (!canRead)
+    // No YouTube connection and looking at their own (empty) subscriptions: offer both
+    // connecting YouTube and just browsing the shared library (no read scope needed).
+    if (!canRead && filters.scope === "my")
       return (
         <div className="p-8 grid place-items-center text-center">
           <div className="max-w-sm">
@@ -160,6 +162,12 @@ export default function Feed({
             >
               {t("feed.setUp")}
             </button>
+            <button
+              onClick={() => setFilters({ ...filters, scope: "all" })}
+              className="block mx-auto mt-3 text-sm text-muted hover:text-accent transition"
+            >
+              {t("feed.browseShared")}
+            </button>
           </div>
         </div>
       );

frontend/src/components/Header.tsx

@@ -1,6 +1,6 @@
 import { useRef, useState } from "react";
 import { useTranslation } from "react-i18next";
-import { BarChart3, Home, Info, LogOut, Search, Settings, Shield, Tv } from "lucide-react";
+import { BarChart3, Home, Info, Library, LogOut, Search, Settings, Shield, Tv, User } from "lucide-react";
 import type { FeedFilters, Me } from "../lib/api";
 import type { Page } from "../lib/urlState";
 import { type LangCode } from "../i18n";
@@ -49,6 +49,35 @@ export default function Header({
 
       <SyncStatus isAdmin={me.role === "admin"} onGoToFullHistory={onGoToFullHistory} />
 
+      {page === "feed" && (
+        <div
+          className="flex items-center rounded-full border border-border bg-card p-0.5 text-xs shrink-0"
+          role="group"
+          aria-label={t("header.scope.label")}
+        >
+          {(["my", "all"] as const).map((s) => (
+            <button
+              key={s}
+              onClick={() => setFilters({ ...filters, scope: s })}
+              title={t("header.scope." + s + "Tip")}
+              aria-pressed={filters.scope === s}
+              className={`inline-flex items-center gap-1 px-2.5 py-1 rounded-full transition ${
+                filters.scope === s
+                  ? "bg-accent text-accent-fg"
+                  : "text-muted hover:text-fg"
+              }`}
+            >
+              {s === "my" ? (
+                <User className="w-3.5 h-3.5" />
+              ) : (
+                <Library className="w-3.5 h-3.5" />
+              )}
+              <span className="hidden sm:inline">{t("header.scope." + s)}</span>
+            </button>
+          ))}
+        </div>
+      )}
+
       {page === "feed" ? (
         <div className="flex-1 max-w-xl mx-auto relative">
           <Search className="w-4 h-4 absolute left-3 top-1/2 -translate-y-1/2 text-muted" />

frontend/src/components/Sidebar.tsx

@@ -8,6 +8,7 @@ import {
   EyeOff,
   GripVertical,
   Pencil,
+  RefreshCw,
   RotateCcw,
   X,
 } from "lucide-react";
@@ -48,6 +49,9 @@ const SORT_IDS = [
 
 const SHOW_IDS = ["unwatched", "in_progress", "all", "watched", "saved", "hidden"];
 
+// Fresh shuffle token for the "surprise me" sort.
+const rollSeed = () => Math.floor(Math.random() * 1_000_000_000);
+
 const DATE_PRESETS: { days: number; key: string }[] = [
   { days: 1, key: "24h" },
   { days: 7, key: "1week" },
@@ -56,8 +60,9 @@ const DATE_PRESETS: { days: number; key: string }[] = [
   { days: 365, key: "1year" },
 ];
 
-// Filter values owned by the sidebar (everything except the header search `q`).
-const DEFAULT_SIDEBAR_FILTERS: Omit<FeedFilters, "q"> = {
+// Filter values owned by the sidebar (everything except the header search `q` and the
+// `scope` mode, both preserved across a "Clear all").
+const DEFAULT_SIDEBAR_FILTERS: Omit<FeedFilters, "q" | "scope"> = {
   tags: [],
   tagMode: "or",
   sort: "newest",
@@ -81,13 +86,20 @@ function TagChip({
     <button
       onClick={onClick}
       title={t("sidebar.channelCount", { count: tag.channel_count })}
-      className={`text-xs px-2.5 py-1 rounded-full border shadow-sm hover:shadow active:translate-y-px transition ${
+      className={`inline-flex items-center gap-1.5 text-xs px-2.5 py-1 rounded-full border shadow-sm hover:shadow active:translate-y-px transition ${
         active
           ? "bg-accent text-accent-fg border-accent"
           : "bg-card border-border text-fg hover:border-accent"
       }`}
     >
-      {tag.name}
+      <span>{tag.name}</span>
+      <span
+        className={`tabular-nums text-[10px] leading-none px-1 py-0.5 rounded-full ${
+          active ? "bg-accent-fg/20 text-accent-fg" : "bg-muted/15 text-muted"
+        }`}
+      >
+        {tag.channel_count}
+      </span>
     </button>
   );
 }
@@ -159,7 +171,7 @@ export default function Sidebar({
 
   function clearAll() {
     setCustomDates(false);
-    setFilters({ ...DEFAULT_SIDEBAR_FILTERS, q: filters.q });
+    setFilters({ ...DEFAULT_SIDEBAR_FILTERS, q: filters.q, scope: filters.scope });
   }
 
   const available: Record<WidgetId, boolean> = {
@@ -208,17 +220,38 @@ export default function Sidebar({
         );
       case "sort":
         return (
-          <select
-            value={filters.sort}
-            onChange={(e) => setFilters({ ...filters, sort: e.target.value })}
-            className="w-full bg-card border border-border rounded-lg px-2 py-1.5 text-sm outline-none focus:border-accent"
-          >
-            {SORT_IDS.map((id) => (
-              <option key={id} value={id}>
-                {t("sidebar.sort." + id)}
-              </option>
-            ))}
-          </select>
+          <div className="flex items-center gap-1.5">
+            <select
+              value={filters.sort}
+              onChange={(e) => {
+                const sort = e.target.value;
+                // Seed shuffle on selection so it lands on a fresh order, not the
+                // deterministic seed-0 one every time.
+                setFilters({
+                  ...filters,
+                  sort,
+                  seed: sort === "shuffle" ? rollSeed() : undefined,
+                });
+              }}
+              className="w-full bg-card border border-border rounded-lg px-2 py-1.5 text-sm outline-none focus:border-accent"
+            >
+              {SORT_IDS.map((id) => (
+                <option key={id} value={id}>
+                  {t("sidebar.sort." + id)}
+                </option>
+              ))}
+            </select>
+            {filters.sort === "shuffle" && (
+              <button
+                onClick={() => setFilters({ ...filters, seed: rollSeed() })}
+                title={t("sidebar.reshuffle")}
+                aria-label={t("sidebar.reshuffle")}
+                className="shrink-0 p-1.5 rounded-lg border border-border bg-card text-fg shadow-sm hover:border-accent hover:text-accent active:translate-y-px transition"
+              >
+                <RefreshCw className="w-4 h-4" />
+              </button>
+            )}
+          </div>
         );
       case "date":
         return (

frontend/src/components/SyncStatus.tsx

@@ -57,6 +57,13 @@ export default function SyncStatus({
           <Loader2 className="w-3.5 h-3.5 animate-spin" />
           {t("header.sync.syncing", { count: syncing })}
         </span>
+      ) : notFull > 0 ? (
+        // Recent uploads are in, but the scheduler is still backfilling full history —
+        // so "all synced" would be misleading. Reflect the deep work as active.
+        <span className="flex items-center gap-1">
+          <Loader2 className="w-3.5 h-3.5 animate-spin" />
+          {t("header.sync.backfillingHistory")}
+        </span>
       ) : (
         <span>{t("header.sync.allSynced")}</span>
       )}
@@ -74,9 +81,10 @@ export default function SyncStatus({
           </Tooltip>
         </>
       )}
-      {/* Pause only makes sense when there's work to pause; Resume must always show
-          while paused so it can be lifted. Hidden entirely when idle and not paused. */}
-      {isAdmin && (data.paused || syncing > 0) && (
+      {/* Pause only makes sense when there's work to pause (recent OR deep backfill);
+          Resume must always show while paused so it can be lifted. Hidden entirely when
+          idle and not paused. */}
+      {isAdmin && (data.paused || syncing > 0 || notFull > 0) && (
         <button
           onClick={() => toggle.mutate()}
           disabled={toggle.isPending}

frontend/src/i18n/locales/de/channels.json

@@ -45,6 +45,7 @@
     "full": "vollständig",
     "fullHint": "Vollständiger Verlauf geladen.",
     "fullHistoryQueued": "vollständiger Verlauf in Warteschlange",
+    "fullHistoryComing": "vollständiger Verlauf unterwegs",
     "queuedRequestedHint": "Vollständiger Verlauf angefordert — der gesamte Katalog dieses Kanals wird nachgeladen, soweit das gemeinsame Kontingent es zulässt. Klicke, um deine Anforderung abzubrechen.",
     "queuedByOtherHint": "Ein anderer Abonnent hat den vollständigen Verlauf dieses Kanals bereits angefordert, sein gesamter Katalog ist also für alle unterwegs — hier gibt es nichts zu tun.",
     "getFullHistory": "vollständigen Verlauf laden",

frontend/src/i18n/locales/de/feed.json

@@ -4,6 +4,7 @@
   "emptyTitle": "Dein Feed ist leer",
   "emptyBody": "Verbinde dein YouTube-Konto, um deine Abos zu importieren und deinen Feed aufzubauen.",
   "setUp": "Meinen Feed einrichten",
+  "browseShared": "Oder einfach die gemeinsame Bibliothek durchsuchen",
   "noMatches": "Keine Videos entsprechen diesen Filtern.",
   "videoCount_one": "{{formattedCount}} Video",
   "videoCount_other": "{{formattedCount}} Videos",

frontend/src/i18n/locales/de/header.json

@@ -3,6 +3,13 @@
   "searchPlaceholder": "Deine Abos durchsuchen…",
   "channelManager": "Kanalverwaltung",
   "usageStats": "Nutzung & Statistik",
+  "scope": {
+    "label": "Feed-Quelle",
+    "my": "Meine",
+    "myTip": "Nur Videos aus deinen eigenen Abos",
+    "all": "Bibliothek",
+    "allTip": "Alle Videos im gemeinsamen Katalog"
+  },
   "account": {
     "admin": "Admin",
     "feed": "Feed",
@@ -18,6 +25,7 @@
     "countTooltip": "Videos aus deinen Abos im Vergleich zur Gesamtzahl im gemeinsamen Katalog, den die Abos aller Nutzer gefüllt haben.",
     "paused": "pausiert",
     "syncing": "{{count}} werden synchronisiert",
+    "backfillingHistory": "Verlauf wird geladen",
     "allSynced": "alles synchronisiert",
     "withoutFullHistory": "{{count}} ohne vollständigen Verlauf",
     "fullHistoryTooltip": "Einige deiner Kanäle haben nur ihre neuesten Uploads. Klicke, um die Kanalverwaltung (auf diese gefiltert) zu öffnen und ihren vollständigen Katalog anzufordern.",

frontend/src/i18n/locales/de/sidebar.json

@@ -23,6 +23,7 @@
   "from": "Von",
   "to": "Bis",
   "clearDates": "Daten löschen",
+  "reshuffle": "Neu mischen",
   "widget": {
     "show": "Anzeigen",
     "sort": "Sortierung",

frontend/src/i18n/locales/en/channels.json

@@ -45,6 +45,7 @@
     "full": "full",
     "fullHint": "Full history fetched.",
     "fullHistoryQueued": "full history queued",
+    "fullHistoryComing": "full history coming",
     "queuedRequestedHint": "Full history requested — this channel's whole back-catalog will backfill as the shared quota allows. Click to cancel your request.",
     "queuedByOtherHint": "Another subscriber already requested this channel's full history, so its whole back-catalog is on its way to everyone — nothing to do here.",
     "getFullHistory": "get full history",

frontend/src/i18n/locales/en/feed.json

@@ -4,6 +4,7 @@
   "emptyTitle": "Your feed is empty",
   "emptyBody": "Connect your YouTube account to import your subscriptions and build your feed.",
   "setUp": "Set up my feed",
+  "browseShared": "Or just browse the shared library",
   "noMatches": "No videos match these filters.",
   "videoCount_one": "{{formattedCount}} video",
   "videoCount_other": "{{formattedCount}} videos",

frontend/src/i18n/locales/en/header.json

@@ -3,6 +3,13 @@
   "searchPlaceholder": "Search your subscriptions…",
   "channelManager": "Channel manager",
   "usageStats": "Usage & stats",
+  "scope": {
+    "label": "Feed source",
+    "my": "Mine",
+    "myTip": "Only videos from your own subscriptions",
+    "all": "Library",
+    "allTip": "Every video in the shared catalog"
+  },
   "account": {
     "admin": "Admin",
     "feed": "Feed",
@@ -18,6 +25,7 @@
     "countTooltip": "Videos from your subscriptions, against the total in the shared catalog that every user's subscriptions have pulled in.",
     "paused": "paused",
     "syncing": "{{count}} syncing",
+    "backfillingHistory": "fetching history",
     "allSynced": "all synced",
     "withoutFullHistory": "{{count}} without full history",
     "fullHistoryTooltip": "Some of your channels only have their recent uploads. Click to open the channel manager (filtered to these) and request their full back-catalog.",

frontend/src/i18n/locales/en/sidebar.json

@@ -23,6 +23,7 @@
   "from": "From",
   "to": "To",
   "clearDates": "clear dates",
+  "reshuffle": "Reshuffle",
   "widget": {
     "show": "Show",
     "sort": "Sort",

frontend/src/i18n/locales/hu/channels.json

@@ -45,6 +45,7 @@
     "full": "teljes",
     "fullHint": "Teljes előzmény letöltve.",
     "fullHistoryQueued": "teljes előzmény sorban",
+    "fullHistoryComing": "teljes előzmény úton",
     "queuedRequestedHint": "Teljes előzmény kérve — a csatorna teljes archívuma letöltődik, ahogy a megosztott kvóta engedi. Kattints a kérés visszavonásához.",
     "queuedByOtherHint": "Egy másik feliratkozó már kérte ennek a csatornának a teljes előzményét, így a teljes archívuma már úton van mindenkihez — itt nincs teendőd.",
     "getFullHistory": "teljes előzmény lekérése",

frontend/src/i18n/locales/hu/feed.json

@@ -4,6 +4,7 @@
   "emptyTitle": "A hírfolyamod üres",
   "emptyBody": "Kösd össze a YouTube-fiókodat, hogy importáld a feliratkozásaidat, és felépítsd a hírfolyamodat.",
   "setUp": "Hírfolyam beállítása",
+  "browseShared": "Vagy csak böngészd a közös könyvtárat",
   "noMatches": "Egy videó sem felel meg ezeknek a szűrőknek.",
   "videoCount_one": "{{formattedCount}} videó",
   "videoCount_other": "{{formattedCount}} videó",

frontend/src/i18n/locales/hu/header.json

@@ -3,6 +3,13 @@
   "searchPlaceholder": "Keresés a feliratkozásaid között…",
   "channelManager": "Csatornakezelő",
   "usageStats": "Használat és statisztika",
+  "scope": {
+    "label": "Hírfolyam forrása",
+    "my": "Sajátom",
+    "myTip": "Csak a saját feliratkozásaid videói",
+    "all": "Könyvtár",
+    "allTip": "A közös könyvtár összes videója"
+  },
   "account": {
     "admin": "Adminisztrátor",
     "feed": "Hírfolyam",
@@ -18,6 +25,7 @@
     "countTooltip": "A feliratkozásaidból származó videók száma a megosztott katalógus teljes számához képest, amelyet az összes felhasználó feliratkozásai gyűjtöttek össze.",
     "paused": "szüneteltetve",
     "syncing": "{{count}} szinkronizálás alatt",
+    "backfillingHistory": "előzmény letöltése",
     "allSynced": "minden szinkronban",
     "withoutFullHistory": "{{count}} teljes előzmény nélkül",
     "fullHistoryTooltip": "Néhány csatornádnak csak a legutóbbi feltöltései vannak meg. Kattints a csatornakezelő megnyitásához (ezekre szűrve), és kérd le a teljes archívumukat.",

frontend/src/i18n/locales/hu/sidebar.json

@@ -23,6 +23,7 @@
   "from": "Ettől",
   "to": "Eddig",
   "clearDates": "dátumok törlése",
+  "reshuffle": "Újrakeverés",
   "widget": {
     "show": "Megjelenítés",
     "sort": "Rendezés",

frontend/src/lib/api.ts

@@ -73,6 +73,11 @@ export interface FeedFilters {
   tagMode: "or" | "and";
   q: string;
   sort: string;
+  // Re-roll token for the "shuffle" sort; bumped by the reshuffle button so the
+  // feed re-queries with a fresh order. Ignored by every other sort.
+  seed?: number;
+  // "my" = only your subscriptions (default); "all" = the whole shared catalog.
+  scope: "my" | "all";
   includeNormal: boolean;
   includeShorts: boolean;
   includeLive: boolean;
@@ -153,6 +158,8 @@ function feedQuery(f: FeedFilters, offset: number, limit: number): string {
   p.set("tag_mode", f.tagMode);
   if (f.q) p.set("q", f.q);
   p.set("sort", f.sort);
+  if (f.sort === "shuffle" && f.seed) p.set("seed", String(f.seed));
+  p.set("scope", f.scope);
   p.set("show_normal", String(f.includeNormal));
   p.set("include_shorts", String(f.includeShorts));
   p.set("include_live", String(f.includeLive));