feat: фильтры ленты синхронизируются с URL (расшариваемые ссылки)

NewsFeed читает category/tag/period/q из query-параметров при загрузке
и пишет их обратно в URL при изменении фильтров. Теперь адрес в строке
браузера — готовая ссылка: ?category=slug1,slug2 открывает ленту сразу
с выбранными колледжами (для кнопок на внешнем сайте).

Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>

api/route/public.py

@@ -62,9 +62,13 @@ async def list_news(
     )
 
     if category:
-        cat = (await db.execute(select(Category).where(Category.slug == category))).scalar_one_or_none()
+        # Поддержка нескольких колледжей: category="slug1,slug2,..."
-        if cat:
+        slugs = [s for s in (part.strip() for part in category.split(",")) if s]
-            base = base.where(Article.category_id == cat.id)
+        cat_ids = (
+            await db.execute(select(Category.id).where(Category.slug.in_(slugs)))
+        ).scalars().all()
+        if cat_ids:
+            base = base.where(Article.category_id.in_(cat_ids))
         else:
             return {"total": 0, "offset": offset, "limit": limit, "has_more": False, "items": []}
 

api/vk_parser.py

@@ -388,13 +388,17 @@ async def _get_or_create_tag(name: str, db: AsyncSession) -> Tag:
 
 # ── Post processing ───────────────────────────────────────────────────────────
 
-async def _process_post(post: dict, category_name: str, db: AsyncSession, strict_filter: bool = True, screen_name: str | None = None) -> bool:
+async def _process_post(post: dict, category_name: str, db: AsyncSession, strict_filter: bool = True, screen_name: str | None = None) -> str:
+    """Обрабатывает один VK-пост. Возвращает статус:
+    "imported" — пост сохранён; "exists" — уже есть в БД (догнали историю);
+    "skipped"  — пропущен по другой причине (репост известной группы / фильтр / пустой).
+    """
     owner_id = post["owner_id"]
     post_id  = post["id"]
     vk_slug  = _vk_slug(owner_id, post_id)
 
     if await _vk_post_exists(owner_id, post_id, db):
-        return False
+        return "exists"
 
     text        = post.get("text", "")
     attachments = post.get("attachments", [])
@@ -410,7 +414,7 @@ async def _process_post(post: dict, category_name: str, db: AsyncSession, strict
         )).scalar_one_or_none()
         if in_db:
             # Оригинал придёт сам из своей группы — пропускаем
-            return False
+            return "skipped"
         # Берём содержимое оригинала; комментарий репостера добавляем в начало
         orig_text  = original.get("text", "")
         orig_atts  = original.get("attachments", [])
@@ -421,7 +425,7 @@ async def _process_post(post: dict, category_name: str, db: AsyncSession, strict
     # strict_filter=True: пропускаем пост если нет тегов
     # strict_filter=False: импортируем всё, теги назначаем если найдены
     if strict_filter and not tag_names:
-        return False
+        return "skipped"
 
     # Заранее генерируем UUID и slug — используются в путях MinIO
     article_id = uuid.uuid4()
@@ -545,7 +549,7 @@ async def _process_post(post: dict, category_name: str, db: AsyncSession, strict
 
     content = _sanitize("\n".join(content_parts))
     if not content.strip():
-        return False
+        return "skipped"
 
     title      = _early_title
     title_slug = _early_slug
@@ -594,7 +598,7 @@ async def _process_post(post: dict, category_name: str, db: AsyncSession, strict
         .values(article_id=article_id)
     )
     await db.commit()
-    return True
+    return "imported"
 
 
 # ── VK API fetch ──────────────────────────────────────────────────────────────
@@ -674,13 +678,16 @@ async def run_import() -> dict:
                     break
 
                 batch_new = 0
+                batch_existing = 0
                 for post in posts:
                     try:
-                        ok = await _process_post(post, source.group_name, db, source.strict_filter, screen_name=source.screen_name)
+                        st = await _process_post(post, source.group_name, db, source.strict_filter, screen_name=source.screen_name)
-                        if ok:
+                        if st == "imported":
                             imported += 1; grp_new += 1; batch_new += 1
                         else:
                             skipped += 1; grp_skip += 1
+                            if st == "exists":
+                                batch_existing += 1
                     except Exception as exc:
                         print(f"[VK]   ✗ Пост {post.get('id')}: {exc}")
                         errors += 1; grp_err += 1
@@ -691,7 +698,16 @@ async def run_import() -> dict:
 
                 await asyncio.sleep(1.5)
 
-                if batch_new == 0 or len(posts) < batch or not VK_TOKEN:
+                # Условие остановки:
+                # — строгий фильтр: новых тегированных постов в батче нет → догнали.
+                # — без фильтра: останавливаемся только когда ВЕСЬ батч уже в БД,
+                #   иначе пропустили бы более старые нетегированные посты (ранняя остановка).
+                if source.strict_filter:
+                    caught_up = batch_new == 0
+                else:
+                    caught_up = batch_existing == len(posts)
+
+                if caught_up or len(posts) < batch or not VK_TOKEN:
                     print(f"[VK]   Догнали до уже импортированных, останавливаем группу")
                     break
 
@@ -749,8 +765,8 @@ async def run_history_import(group_id: str | None = None, since_days: int = 365)
                         hit_cutoff = True
                         continue
                     try:
-                        ok = await _process_post(post, source.group_name, db, source.strict_filter)
+                        st = await _process_post(post, source.group_name, db, source.strict_filter, screen_name=source.screen_name)
-                        if ok:
+                        if st == "imported":
                             imported += 1; grp_new += 1; batch_new += 1
                         else:
                             skipped += 1; grp_skip += 1

web-react/src/components/FilterBar.jsx

@@ -11,19 +11,28 @@ const DATE_PRESETS = [
 export default function FilterBar({ categories, tags, filters, onChange }) {
   const set = key => val => onChange({ ...filters, [key]: val })
 
+  // Мультивыбор колледжей: filters.category — массив slug'ов
+  const selected = filters.category ?? []
+  const toggleCategory = slug => {
+    const next = selected.includes(slug)
+      ? selected.filter(s => s !== slug)
+      : [...selected, slug]
+    set('category')(next)
+  }
+
   return (
     <div className="filter-bar">
-      {/* Категории */}
+      {/* Категории (можно выбрать несколько) */}
       <div className="filter-row">
         <button
-          className={`chip ${!filters.category ? 'chip--active' : 'chip--ghost'}`}
+          className={`chip ${selected.length === 0 ? 'chip--active' : 'chip--ghost'}`}
-          onClick={() => set('category')(null)}
+          onClick={() => set('category')([])}
         >Все</button>
         {categories.map(c => (
           <button
             key={c.id}
-            className={`chip ${filters.category === c.slug ? 'chip--active' : 'chip--ghost'}`}
+            className={`chip ${selected.includes(c.slug) ? 'chip--active' : 'chip--ghost'}`}
-            onClick={() => set('category')(c.slug)}
+            onClick={() => toggleCategory(c.slug)}
           >{c.name}</button>
         ))}
       </div>

web-react/src/pages/NewsFeed.jsx

@@ -1,4 +1,5 @@
 import React, { useState, useEffect, useCallback, useRef } from 'react'
+import { useSearchParams } from 'react-router-dom'
 import { useTheme } from '../hooks/useTheme'
 import { getNews, getCategories, getTags, getArticle } from '../api/index'
 import NewsCard     from '../components/NewsCard'
@@ -19,6 +20,7 @@ function presetToDateFrom(preset) {
 
 export default function NewsFeed() {
   const { dark, toggle } = useTheme()
+  const [searchParams, setSearchParams] = useSearchParams()
   const [articles, setArticles]     = useState([])
   const [total, setTotal]           = useState(0)
   const [categories, setCategories] = useState([])
@@ -26,15 +28,20 @@ export default function NewsFeed() {
   const [loading, setLoading]       = useState(true)
   const [loadingMore, setLoadingMore] = useState(false)
   const [hasMore, setHasMore]       = useState(false)
-  const [filters, setFilters]       = useState({ category: null, tag: null, datePreset: '' })
+  // Начальное состояние фильтров читаем из URL — ссылка открывает ленту с этими колледжами
+  const [filters, setFilters]       = useState(() => ({
+    category:   (searchParams.get('category') || '').split(',').filter(Boolean),
+    tag:        searchParams.get('tag') || null,
+    datePreset: searchParams.get('period') || '',
+  }))
 
   const offsetRef    = useRef(0)
   const busyRef      = useRef(false)
   const sentinelRef  = useRef(null)
 
-  // Поиск с debounce
+  // Поиск с debounce (тоже инициализируется из URL)
-  const [searchInput, setSearchInput] = useState('')
+  const [searchInput, setSearchInput] = useState(() => searchParams.get('q') || '')
-  const [searchQuery, setSearchQuery] = useState('')
+  const [searchQuery, setSearchQuery] = useState(() => searchParams.get('q') || '')
   const debounceRef = useRef(null)
 
   const handleSearch = e => {
@@ -60,7 +67,7 @@ export default function NewsFeed() {
 
   const buildParams = useCallback((offset) => {
     const params = { limit: PAGE_SIZE, offset }
-    if (filters.category) params.category = filters.category
+    if (filters.category?.length) params.category = filters.category.join(',')
     if (filters.tag)      params.tag = filters.tag
     const df = presetToDateFrom(filters.datePreset)
     if (df) params.date_from = df
@@ -68,6 +75,16 @@ export default function NewsFeed() {
     return params
   }, [filters, searchQuery])
 
+  // Синхронизируем фильтры/поиск в URL, чтобы адрес можно было скопировать и расшарить
+  useEffect(() => {
+    const p = {}
+    if (filters.category.length) p.category = filters.category.join(',')
+    if (filters.tag)             p.tag = filters.tag
+    if (filters.datePreset)      p.period = filters.datePreset
+    if (searchQuery)             p.q = searchQuery
+    setSearchParams(p, { replace: true })
+  }, [filters, searchQuery, setSearchParams])
+
   // Сброс и первая загрузка при смене фильтров/поиска
   useEffect(() => {
     let cancelled = false