import { useCallback, useEffect, useRef, useState } from "react"; import { useTranslation } from "react-i18next"; import { useInfiniteQuery, useQuery, useQueryClient } from "@tanstack/react-query"; import { ArrowDown, ArrowUp, RefreshCw } from "lucide-react"; import { api, type FeedFilters, type Video } from "../lib/api"; import i18n from "../i18n"; import { notify } from "../lib/notifications"; import VideoCard from "./VideoCard"; import PlayerModal from "./PlayerModal"; const PAGE = 60; // The "Show" view filter, content-type filter and ordering live in the feed toolbar // (above the cards), not the filter sidebar. const SHOW_IDS = ["unwatched", "in_progress", "all", "watched", "hidden"]; const CONTENT = [ { key: "includeNormal", label: "sidebar.content.normal" }, { key: "includeShorts", label: "sidebar.content.shorts" }, { key: "includeLive", label: "sidebar.content.live" }, ] as const; const rollSeed = () => Math.floor(Math.random() * 1_000_000_000); // Ordering = a key + direction (like the Playlists page), mapped to the backend sort strings // (which encode both). One entry per concept; a single arrow flips the direction. type SortKey = "date" | "popular" | "duration" | "title" | "subscribers" | "priority" | "shuffle"; const SORT_KEYS: SortKey[] = ["date", "popular", "duration", "title", "subscribers", "priority", "shuffle"]; const SORT_MAP: Record, { asc: string; desc: string }> = { date: { desc: "newest", asc: "oldest" }, popular: { desc: "views", asc: "views_asc" }, duration: { desc: "duration_desc", asc: "duration_asc" }, title: { asc: "title", desc: "title_desc" }, subscribers: { desc: "subscribers", asc: "subscribers_asc" }, priority: { desc: "priority", asc: "priority_asc" }, }; const SORT_DEFAULT_DIR: Record, "asc" | "desc"> = { date: "desc", popular: "desc", duration: "desc", title: "asc", subscribers: "desc", priority: "desc", }; function parseSort(s: string): { key: SortKey; dir: "asc" | "desc" } { if (s === "shuffle") return { key: "shuffle", dir: "desc" }; for (const k of Object.keys(SORT_MAP) as (keyof typeof SORT_MAP)[]) { if (SORT_MAP[k].asc === s) return { key: k, dir: "asc" }; if (SORT_MAP[k].desc === s) return { key: k, dir: "desc" }; } return { key: "date", dir: "desc" }; } function buildSort(key: SortKey, dir: "asc" | "desc"): string { return key === "shuffle" ? "shuffle" : SORT_MAP[key][dir]; } function matchesView(status: string, show: string): boolean { switch (show) { case "hidden": return status === "hidden"; case "watched": return status === "watched"; case "unwatched": case "in_progress": // (in_progress is further narrowed server-side by resume position; here we only // need to drop a card once it's optimistically marked watched/hidden.) return status !== "watched" && status !== "hidden"; default: return status !== "hidden"; // all } } export default function Feed({ filters, setFilters, view, canRead, isDemo = false, onOpenWizard, }: { filters: FeedFilters; setFilters: (f: FeedFilters) => void; view: "grid" | "list"; canRead: boolean; isDemo?: boolean; onOpenWizard: () => void; }) { const { t } = useTranslation(); const [overrides, setOverrides] = useState>({}); const [savedOverrides, setSavedOverrides] = useState>({}); // The open player: which video and where to start (null = resume from saved position). const [activeVideo, setActiveVideo] = useState<{ video: Video; startAt: number | null } | null>( null ); const qc = useQueryClient(); const openVideo = useCallback( (video: Video, startAt: number | null = null) => setActiveVideo({ video, startAt }), [] ); const query = useInfiniteQuery({ queryKey: ["feed", filters], queryFn: ({ pageParam }) => api.feed(filters, pageParam as number, PAGE), initialPageParam: 0, getNextPageParam: (last) => (last.has_more ? last.offset + last.limit : undefined), }); // Drop optimistic status overrides when filters change OR fresh server data // arrives — after a refetch the server is authoritative, so a stale override // (e.g. a video reverted to "new" from the notification center) won't keep it // filtered out of the current view. useEffect(() => { setOverrides({}); setSavedOverrides({}); }, [filters]); useEffect(() => { setOverrides({}); setSavedOverrides({}); }, [query.dataUpdatedAt]); const countQuery = useQuery({ queryKey: ["feed-count", filters], queryFn: () => api.feedCount(filters), staleTime: 30_000, }); const sentinel = useRef(null); const { hasNextPage, isFetchingNextPage, fetchNextPage } = query; useEffect(() => { const el = sentinel.current; if (!el) return; const io = new IntersectionObserver( (entries) => { if (entries[0].isIntersecting && hasNextPage && !isFetchingNextPage) { fetchNextPage(); } }, { rootMargin: "1500px" } // prefetch the next page well before the bottom is in view ); io.observe(el); return () => io.disconnect(); }, [hasNextPage, isFetchingNextPage, fetchNextPage]); // Keep the loaded videos in a ref so onState can stay referentially stable // (it needs the list only to look up a title for the notification). A stable // onState lets memo(VideoCard) skip re-rendering existing cards on page append. const loadedRef = useRef([]); const onState = useCallback( (id: string, status: string) => { setOverrides((o) => ({ ...o, [id]: status })); // Refetch once the server has the change so other views (e.g. Hidden) are in sync. api .setState(id, status) .then(() => qc.invalidateQueries({ queryKey: ["feed"] })) .catch(() => // Server rejected the change — drop the optimistic override so the card // reverts to the real (unchanged) state instead of staying phantom-hidden. setOverrides((o) => { const next = { ...o }; delete next[id]; return next; }) ); if (status === "hidden") { const v = loadedRef.current.find((x) => x.id === id); notify({ message: v?.title ? i18n.t("feed.hiddenNamed", { title: v.title }) : i18n.t("feed.hidden"), action: { label: i18n.t("feed.undo"), onClick: () => onState(id, "new") }, meta: { kind: "video-hidden", videoId: id, title: v?.title ?? "this video", channelId: v?.channel_id ?? "", channelName: v?.channel_title ?? "", }, }); } else if (status === "watched") { const v = loadedRef.current.find((x) => x.id === id); notify({ message: v?.title ? i18n.t("feed.markedWatchedNamed", { title: v.title }) : i18n.t("feed.markedWatched"), action: { label: i18n.t("feed.unwatch"), onClick: () => onState(id, "new") }, meta: { kind: "video-watched", videoId: id, title: v?.title ?? "this video" }, }); } }, [qc] ); const onChannelFilter = useCallback( (channelId: string, channelName: string) => { setFilters({ ...filters, channelId, channelName }); }, [filters, setFilters] ); const onToggleSave = useCallback( (id: string, saved: boolean) => { setSavedOverrides((o) => ({ ...o, [id]: saved })); (saved ? api.watchLaterAdd(id) : api.watchLaterRemove(id)) .then(() => { qc.invalidateQueries({ queryKey: ["playlists"] }); qc.invalidateQueries({ queryKey: ["playlist"] }); }) .catch(() => setSavedOverrides((o) => ({ ...o, [id]: !saved }))); }, [qc] ); const loaded: Video[] = (query.data?.pages ?? []).flatMap((p) => p.items); loadedRef.current = loaded; const items: Video[] = loaded .map((v) => (overrides[v.id] ? { ...v, status: overrides[v.id] } : v)) .map((v) => (savedOverrides[v.id] !== undefined ? { ...v, saved: savedOverrides[v.id] } : v)) .filter((v) => matchesView(v.status, filters.show)); if (query.isLoading) return
{t("feed.loading")}
; if (query.isError) return
{t("feed.loadError")}
; // Empty "my" feed with no YouTube access. The shared demo account can never connect // YouTube, so it gets a gentle nudge into the shared library instead of the connect // wizard; real users get the onboarding prompt. No toolbar (sort/type are meaningless). if (items.length === 0 && !canRead && filters.scope === "my") return (

{isDemo ? t("feed.demoEmptyTitle") : t("feed.emptyTitle")}

{isDemo ? t("feed.demoEmptyBody") : t("feed.emptyBody")}

{isDemo ? ( ) : ( <> )}
); const { key: sortKey, dir: sortDir } = parseSort(filters.sort); const toolbar = (
{SHOW_IDS.map((id) => ( ))}
{countQuery.data ? t("feed.videoCount", { count: countQuery.data.count, formattedCount: countQuery.data.count.toLocaleString(), }) : " "}
{t("feed.sortLabel")} {sortKey !== "shuffle" && ( )} {sortKey === "shuffle" && ( )}
); return (
{toolbar} {items.length === 0 ? (
{t("feed.noMatches")}
) : view === "grid" ? (
{items.map((v) => ( ))}
) : (
{items.map((v) => ( ))}
)} {activeVideo && ( setActiveVideo(null)} onState={onState} /> )}
{isFetchingNextPage && (
{t("feed.loadingMore")}
)}
); }