Compare commits

...

9 Commits

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

Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
2026-07-12 22:13:32 +05:00
jze9
3161470a7d feat: мультивыбор колледжей в фильтре публичной ленты
Параметр category в /news принимает несколько slug'ов через запятую
(category_id IN ...), обратно совместим с одиночным slug. FilterBar:
чипы колледжей стали переключателями (можно отметить несколько),
filters.category теперь массив.

Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
2026-06-17 18:47:19 +05:00
jze9
45368c64bf fix: VK-импорт без фильтра добирает всю историю в фоне
run_import останавливал группу по batch_new==0, из-за чего для групп
без строгого фильтра (strict_filter=False) фоновый импорт обрывался на
первом батче без новых записей и не доходил до более старых
нетегированных постов.

_process_post теперь возвращает статус imported|exists|skipped, а
условие остановки ветвится: строгий фильтр — прежнее поведение,
без фильтра — стоп только когда весь батч уже в БД.
Заодно run_history_import передаёт screen_name для корректных source_url.

Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
2026-06-17 18:47:13 +05:00
jze9
955f46c9ca feat: редирект неизвестных маршрутов на корень /
nginx: любой путь кроме /admin, /editor/, /api/ редиректит на /.
Использован named location @spa чтобы избежать повторной маршрутизации
при внутреннем редиректе try_files → /index.html.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
2026-05-20 19:42:47 +05:00
jze9
615c819e97 fix: корректные source_url для VK постов (screen_name формат)
- VkSource: добавлено поле screen_name, заполняется из VK API при добавлении источника
- vk_parser: source_url теперь в формате vk.com/{screen_name}?w=wall{owner}_{post}
  вместо устаревшего vk.com/wall{owner}_{post}
- _vk_post_exists: проверка через LIKE чтобы находить оба формата URL
- admin_vk: автоматически получает screen_name при создании/обновлении источника
- admin_system: исправлен regex в repair-media-urls — только /news-media/ URL
- Alembic миграция: b2c3d4e5f6a7 добавляет колонку screen_name в vk_sources

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
2026-05-20 19:32:28 +05:00
jze9
9e277de65d fix: исправить URL медиа — nginx /media/ проксирует без имени бакета
- vk_parser: убрать bucket из MINIO_PUBLIC_URL (nginx добавляет /news-media/ сам)
- admin_system: добавить endpoint POST /repair-media-urls для обновления старых URL в БД
- SystemStatus: кнопка «Починить URL медиа» запускает repair endpoint
- .env.example: заменить реальные адреса/пароли на плейсхолдеры

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
2026-05-20 16:44:36 +05:00
jze9
00acc59cc4 Revert "nginx: добавлен конфиг для news.cloud-copp74.ru, порт web→8080"
This reverts commit 764c446efd.
2026-05-19 19:08:13 +05:00
jze9
764c446efd nginx: добавлен конфиг для news.cloud-copp74.ru, порт web→8080
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
2026-05-19 18:39:18 +05:00
jze9
6de9464401 fix: healthcheck web container uses 127.0.0.1 instead of localhost
Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
2026-05-19 17:53:55 +05:00
13 changed files with 271 additions and 48 deletions

View File

@@ -1,12 +1,14 @@
# ============= БАЗА ДАННЫХ =============
DATABASE_URL=postgresql+asyncpg://news_admin:news_secure_2026@192.168.1.11:5432/news
DATABASE_URL=postgresql+asyncpg://db_user:db_password@db-host:5432/news
# ============= MINIO / ХРАНИЛИЩЕ =============
MINIO_ENDPOINT=minio:9000
MINIO_ACCESS_KEY=minioadmin
MINIO_SECRET_KEY=minioadmin
MINIO_ENDPOINT=minio-host:9000
MINIO_ACCESS_KEY=your-access-key
MINIO_SECRET_KEY=your-secret-key
MINIO_BUCKET=news-media
MINIO_PUBLIC_URL=http://localhost:9000
# MINIO_PUBLIC_URL — публичный URL через который браузер загружает медиа.
# nginx проксирует /media/ → MinIO bucket, поэтому ставим домен сайта + /media (без имени бакета)
MINIO_PUBLIC_URL=https://your-domain.ru/media
# ============= JWT / БЕЗОПАСНОСТЬ =============
JWT_SECRET=your-super-secret-key-change-in-production

View File

@@ -82,6 +82,7 @@ class VkSource(Base):
id: Mapped[uuid.UUID] = mapped_column(UUID(as_uuid=True), primary_key=True, default=uuid.uuid4)
group_id: Mapped[str] = mapped_column(String(50), unique=True) # числовой ID без минуса
group_name: Mapped[str] = mapped_column(String(200)) # станет названием категории
screen_name: Mapped[str | None] = mapped_column(String(200), nullable=True) # screen_name для корректных URL
enabled: Mapped[bool] = mapped_column(Boolean, default=True)
strict_filter: Mapped[bool] = mapped_column(Boolean, default=True) # True = только посты с тегами
last_run: Mapped[datetime | None] = mapped_column(DateTime, nullable=True)

View File

@@ -0,0 +1,26 @@
"""add screen_name to vk_sources
Revision ID: b2c3d4e5f6a7
Revises: a1b2c3d4e5f6
Create Date: 2026-05-20 18:00:00.000000
"""
from typing import Sequence, Union
from alembic import op
import sqlalchemy as sa
revision: str = 'b2c3d4e5f6a7'
down_revision: Union[str, None] = 'a1b2c3d4e5f6'
branch_labels: Union[str, Sequence[str], None] = None
depends_on: Union[str, Sequence[str], None] = None
def upgrade() -> None:
op.add_column('vk_sources',
sa.Column('screen_name', sa.String(200), nullable=True)
)
def downgrade() -> None:
op.drop_column('vk_sources', 'screen_name')

View File

@@ -113,3 +113,61 @@ async def system_status(db: AsyncSession = Depends(get_db), _: str = Depends(req
"redis": redis,
"minio": minio,
}
@router.post("/repair-media-urls")
async def repair_media_urls(db: AsyncSession = Depends(get_db), _: str = Depends(require_admin)):
"""Заменяет старые MinIO URL на актуальный MINIO_PUBLIC_URL во всех статьях и медиафайлах.
Системный nginx проксирует /media/ → MinIO bucket /news-media/, поэтому bucket исключается из URL.
Старый формат: http://host:port/news-media/object_path
Новый формат: MINIO_PUBLIC_URL/object_path (без bucket)
Запускать один раз после изменения MINIO_PUBLIC_URL в .env.
"""
new_base = MINIO_PUBLIC_URL.rstrip("/")
# cover_url: http://host/news-media/path → new_base/path
r_cover = await db.execute(text(r"""
UPDATE articles
SET cover_url = :new_base || '/' ||
regexp_replace(cover_url, '^https?://[^/]+(:[0-9]+)?/[^/]+/', '')
WHERE cover_url IS NOT NULL
AND cover_url LIKE '%/news-media/%'
AND cover_url NOT LIKE :prefix
RETURNING id
"""), {"new_base": new_base, "prefix": new_base + "%"})
# HTML-контент: только MinIO URL вида src="http://host/news-media/path"
# Точный паттерн: URL содержит /news-media/ — не трогаем другие ссылки
r_content = await db.execute(text(r"""
UPDATE articles
SET content = regexp_replace(
content,
'https?://[^/''"]+(:[0-9]+)?/news-media/([^''">]+)',
:new_base || '/\2',
'g'
)
WHERE content LIKE '%/news-media/%'
AND content NOT LIKE :prefix
RETURNING id
"""), {"new_base": new_base, "prefix": "%" + new_base + "%"})
# media.url
r_media = await db.execute(text(r"""
UPDATE media
SET url = :new_base || '/' ||
regexp_replace(url, '^https?://[^/]+(:[0-9]+)?/[^/]+/', '')
WHERE url LIKE '%/news-media/%'
AND url NOT LIKE :prefix
RETURNING id
"""), {"new_base": new_base, "prefix": new_base + "%"})
await db.commit()
return {
"new_base": new_base,
"cover_url_fixed": r_cover.rowcount,
"content_fixed": r_content.rowcount,
"media_fixed": r_media.rowcount,
}

View File

@@ -1,3 +1,4 @@
import httpx
from fastapi import APIRouter, BackgroundTasks, Depends, HTTPException # BackgroundTasks используется в history endpoints
from pydantic import BaseModel
from sqlalchemy import select
@@ -18,11 +19,30 @@ class SourceIn(BaseModel):
strict_filter: bool = True
async def _fetch_screen_name(group_id: str) -> str | None:
if not VK_TOKEN:
return None
try:
async with httpx.AsyncClient(timeout=5) as client:
r = await client.get(
"https://api.vk.com/method/groups.getById",
params={"group_ids": group_id, "access_token": VK_TOKEN, "v": "5.131"},
)
data = r.json()
groups = data.get("response", [])
if groups:
return groups[0].get("screen_name")
except Exception:
pass
return None
def _source_dict(s: VkSource) -> dict:
return {
"id": str(s.id),
"group_id": s.group_id,
"group_name": s.group_name,
"screen_name": s.screen_name,
"enabled": s.enabled,
"strict_filter": s.strict_filter,
"last_run": s.last_run.isoformat() if s.last_run else None,
@@ -58,7 +78,8 @@ async def add_source(data: SourceIn, db: AsyncSession = Depends(get_db), _: str
exists = (await db.execute(select(VkSource).where(VkSource.group_id == group_id))).scalar_one_or_none()
if exists:
raise HTTPException(status_code=409, detail="Источник с таким group_id уже есть")
source = VkSource(group_id=group_id, group_name=data.group_name, enabled=data.enabled, strict_filter=data.strict_filter)
screen_name = await _fetch_screen_name(group_id)
source = VkSource(group_id=group_id, group_name=data.group_name, screen_name=screen_name, enabled=data.enabled, strict_filter=data.strict_filter)
db.add(source)
await db.commit()
await db.refresh(source)
@@ -74,6 +95,8 @@ async def update_source(source_id: str, data: SourceIn, db: AsyncSession = Depen
source.group_name = data.group_name
source.enabled = data.enabled
source.strict_filter = data.strict_filter
if not source.screen_name:
source.screen_name = await _fetch_screen_name(source.group_id)
await db.commit()
await db.refresh(source)
return _source_dict(source)

View File

@@ -62,9 +62,13 @@ async def list_news(
)
if category:
cat = (await db.execute(select(Category).where(Category.slug == category))).scalar_one_or_none()
if cat:
base = base.where(Article.category_id == cat.id)
# Поддержка нескольких колледжей: category="slug1,slug2,..."
slugs = [s for s in (part.strip() for part in category.split(",")) if s]
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": []}

View File

@@ -162,7 +162,8 @@ async def _upload_from_url(url: str, db: AsyncSession | None = None,
mc = _minio_client()
_ensure_bucket(mc)
mc.put_object(MINIO_BUCKET, object_name, io.BytesIO(data), len(data), content_type=ct)
public_url = f"{MINIO_PUBLIC_URL}/{MINIO_BUCKET}/{object_name}"
# Системный nginx проксирует /media/ → MinIO bucket, поэтому bucket не дублируем в URL
public_url = f"{MINIO_PUBLIC_URL}/{object_name}"
if db is not None:
from bd.models import Media
db.add(Media(
@@ -302,7 +303,7 @@ async def _download_vk_video(owner_id: int, video_id: int,
mc = _minio_client()
_ensure_bucket(mc)
mc.put_object(MINIO_BUCKET, object_name, io.BytesIO(data), len(data), content_type="video/mp4")
public_url = f"{MINIO_PUBLIC_URL}/{MINIO_BUCKET}/{object_name}"
public_url = f"{MINIO_PUBLIC_URL}/{object_name}"
print(f"[VK] Видео загружено в MinIO: {object_name} ({total/1024/1024:.1f}MB)")
if db is not None:
from bd.models import Media
@@ -360,8 +361,8 @@ async def _slug_exists(slug: str, db: AsyncSession) -> bool:
async def _vk_post_exists(owner_id: int, post_id: int, db: AsyncSession) -> bool:
source_url = f"https://vk.com/wall{owner_id}_{post_id}"
r = await db.execute(select(Article.id).where(Article.source_url == source_url))
pattern = f"%wall{owner_id}_{post_id}%"
r = await db.execute(select(Article.id).where(Article.source_url.like(pattern)))
return r.scalar_one_or_none() is not None
@@ -387,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) -> 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", [])
@@ -409,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", [])
@@ -420,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()
@@ -544,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
@@ -561,7 +566,10 @@ async def _process_post(post: dict, category_name: str, db: AsyncSession, strict
created_at = datetime.utcfromtimestamp(ts)
published_at = created_at if status == ArticleStatus.published else None
source_url = f"https://vk.com/wall{owner_id}_{post_id}"
if screen_name:
source_url = f"https://vk.com/{screen_name}?w=wall{owner_id}_{post_id}"
else:
source_url = f"https://vk.com/wall{owner_id}_{post_id}"
article = Article(
id=article_id,
@@ -590,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 ──────────────────────────────────────────────────────────────
@@ -670,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)
if ok:
st = await _process_post(post, source.group_name, db, source.strict_filter, screen_name=source.screen_name)
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
@@ -687,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
@@ -745,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)
if ok:
st = await _process_post(post, source.group_name, db, source.strict_filter, screen_name=source.screen_name)
if st == "imported":
imported += 1; grp_new += 1; batch_new += 1
else:
skipped += 1; grp_skip += 1

View File

@@ -47,7 +47,7 @@ services:
api:
condition: service_healthy
healthcheck:
test: ["CMD-SHELL", "wget -qO- http://localhost/ || exit 1"]
test: ["CMD-SHELL", "wget -qO- http://127.0.0.1/ || exit 1"]
interval: 10s
timeout: 5s
retries: 5

View File

@@ -1,20 +1,41 @@
server {
listen 80;
# Главное React-приложение
location / {
root /usr/share/nginx/html/app;
try_files $uri /index.html;
root /usr/share/nginx/html/app;
# Named location — отдаёт React SPA без повторной маршрутизации
location @spa {
try_files /index.html =404;
}
# Корневая страница
location = / {
try_files /index.html =404;
}
# Статические ассеты приложения (JS, CSS, шрифты, картинки)
location ~* \.(js|css|png|jpg|jpeg|gif|ico|svg|woff|woff2|ttf|eot|json|map)$ {
try_files $uri =404;
}
# Админ-панель — React SPA, все вложенные пути разрешены
location ^~ /admin {
try_files $uri @spa;
}
# Редактор статей (отдельный React-билд)
location /editor/ {
location ^~ /editor/ {
root /usr/share/nginx/html;
try_files $uri /editor/index.html;
try_files $uri @editor_spa;
}
location @editor_spa {
root /usr/share/nginx/html;
try_files /editor/index.html =404;
}
# Статические ассеты редактора (Vite base: '/editor-assets/')
location /editor-assets/ {
location ^~ /editor-assets/ {
alias /usr/share/nginx/html/editor/;
}
@@ -23,10 +44,14 @@ server {
proxy_pass http://api:8000/;
proxy_set_header Host $host;
proxy_set_header X-Real-IP $remote_addr;
# Отключаем буферизацию для быстрого ответа
proxy_buffering off;
}
# Всё остальное — редирект на корень
location / {
return 302 /;
}
gzip on;
gzip_types text/plain text/css application/json application/javascript text/xml application/xml;
}

View File

@@ -114,3 +114,6 @@ export const adminVkImportHistory = (token, sourceId, sinceDays = 365) =>
export const adminSystemStatus = token =>
req('GET', 'admin/system/status', token)
export const adminRepairMediaUrls = token =>
req('POST', 'admin/system/repair-media-urls', token)

View File

@@ -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'}`}
onClick={() => set('category')(null)}
className={`chip ${selected.length === 0 ? 'chip--active' : 'chip--ghost'}`}
onClick={() => set('category')([])}
>Все</button>
{categories.map(c => (
<button
key={c.id}
className={`chip ${filters.category === c.slug ? 'chip--active' : 'chip--ghost'}`}
onClick={() => set('category')(c.slug)}
className={`chip ${selected.includes(c.slug) ? 'chip--active' : 'chip--ghost'}`}
onClick={() => toggleCategory(c.slug)}
>{c.name}</button>
))}
</div>

View File

@@ -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
const [searchInput, setSearchInput] = useState('')
const [searchQuery, setSearchQuery] = useState('')
// Поиск с debounce (тоже инициализируется из URL)
const [searchInput, setSearchInput] = useState(() => searchParams.get('q') || '')
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

View File

@@ -1,6 +1,6 @@
import React, { useState, useEffect, useCallback } from 'react'
import { useAuth } from '../../hooks/useAuth'
import { adminSystemStatus } from '../../api/index'
import { adminSystemStatus, adminRepairMediaUrls } from '../../api/index'
import AdminLayout from '../../components/AdminLayout'
import Loader from '../../components/Loader'
@@ -90,6 +90,7 @@ export default function SystemStatus() {
const [data, setData] = useState(null)
const [loading, setLoading] = useState(true)
const [lastUpdated, setLastUpdated] = useState(null)
const [repairState, setRepairState] = useState(null) // null | 'running' | result-object
const load = useCallback(async () => {
setLoading(true)
@@ -106,6 +107,17 @@ export default function SystemStatus() {
useEffect(() => { load() }, [load])
const runRepair = async () => {
if (!window.confirm('Обновить все MinIO URL в базе данных?\nЭто перезапишет cover_url и img-теги в контенте статей.')) return
setRepairState('running')
try {
const result = await adminRepairMediaUrls(token)
setRepairState(result)
} catch (e) {
setRepairState({ error: String(e) })
}
}
const allOk = data && Object.values(data).every(s => s.ok)
return (
@@ -127,11 +139,34 @@ export default function SystemStatus() {
</span>
)}
</div>
<button className="btn btn-ghost btn-sm" onClick={load} disabled={loading}>
{loading ? 'Проверяю...' : '🔄 Обновить'}
</button>
<div style={{ display: 'flex', gap: '0.5rem', flexWrap: 'wrap' }}>
<button className="btn btn-ghost btn-sm" onClick={load} disabled={loading}>
{loading ? 'Проверяю...' : '🔄 Обновить'}
</button>
<button
className="btn btn-sm"
style={{ background: 'var(--c-warning, #f59e0b)', color: '#fff', border: 'none' }}
onClick={runRepair}
disabled={repairState === 'running'}
>
{repairState === 'running' ? 'Исправляю...' : '🔧 Починить URL медиа'}
</button>
</div>
</div>
{repairState && repairState !== 'running' && (
<div style={{
background: repairState.error ? 'var(--c-danger-bg, #fee2e2)' : 'var(--c-success-bg, #d1fae5)',
color: repairState.error ? 'var(--c-danger, #991b1b)' : 'var(--c-success, #065f46)',
borderRadius: 8, padding: '0.75rem 1rem', marginBottom: '1rem', fontSize: '0.875rem',
}}>
{repairState.error
? `Ошибка: ${repairState.error}`
: `✅ Готово. Новый base: ${repairState.new_base} | cover_url: ${repairState.cover_url_fixed} | контент: ${repairState.content_fixed} | media: ${repairState.media_fixed}`
}
</div>
)}
{loading && !data ? <Loader /> : (
<div style={{ display: 'grid', gap: '1rem', gridTemplateColumns: 'repeat(auto-fill, minmax(340px, 1fr))' }}>
<ServiceCard title="PostgreSQL" icon="🐘" data={data?.postgres} />