Compare commits
5 Commits
v0.0.7
...
413789ba22
| Author | SHA1 | Date | |
|---|---|---|---|
| 413789ba22 | |||
| c4721fcf99 | |||
| 09215da22a | |||
| 25ffd9e678 | |||
| e55a6aebe7 |
@@ -98,7 +98,7 @@ SMTP_TIMEOUT_S=30
|
||||
# --- Версия инстанса (релиз v0.0.1) ---
|
||||
# install.sh копирует значение из корневого файла VERSION при каждой
|
||||
# установке/обновлении — руками менять не нужно.
|
||||
VIDCONF_VERSION=0.0.7
|
||||
VIDCONF_VERSION=0.0.8
|
||||
|
||||
# --- Профили compose. Дефолт ниже (`media,monitoring`) — только для ручного
|
||||
# `docker compose up` БЕЗ install.sh: медиа (LiveKit+coturn) + мониторинг,
|
||||
|
||||
24
CHANGELOG.md
24
CHANGELOG.md
@@ -3,6 +3,29 @@
|
||||
Формат основан на [Keep a Changelog](https://keepachangelog.com/ru/1.1.0/),
|
||||
проект придерживается [семантического версионирования](https://semver.org/lang/ru/).
|
||||
|
||||
## [0.0.8] — 2026-07-27
|
||||
|
||||
Админка: несколько mail-доменов для регистрации, фильтр и поиск по команде в
|
||||
списке пользователей, исправлен баг сохранения настроек.
|
||||
|
||||
### Исправлено
|
||||
- Сохранение любой настройки инстанса блокировалось ошибкой «уровень AI
|
||||
недоступен», даже если AI-модуль (транскрибация/суммаризация) выключен и
|
||||
пользователь уровень не трогал — фронт отправлял в `PUT /admin/settings`
|
||||
весь набор полей целиком, включая уже сохранённый `ai_level`. Теперь
|
||||
доступность уровня проверяется только при его фактической смене; фронт
|
||||
отправляет в запросе лишь реально изменённые поля.
|
||||
|
||||
### Добавлено
|
||||
- «Эталон mail-домена» в настройках инстанса поддерживает несколько
|
||||
доменов вместо одного — регистрация проходит с email с любого домена из
|
||||
списка. Старое значение из БД (один домен) читается без миграции и
|
||||
переписывается в новый формат при первом же сохранении.
|
||||
- В списке пользователей админки — вкладки «Активные»/«Заблокированные»/
|
||||
«Все» перед полем поиска.
|
||||
- Поиск по пользователям учитывает и название команды — пользователи без
|
||||
команды по-прежнему остаются в общей выдаче.
|
||||
|
||||
## [0.0.7] — 2026-07-27
|
||||
|
||||
Настройки устройств: выбор аудиовывода и компактная шторка на мобильном.
|
||||
@@ -183,6 +206,7 @@
|
||||
|
||||
Первоначальная версия VidConf.
|
||||
|
||||
[0.0.8]: https://github.com/MaxRonzhin/vidconf_rel/releases/tag/v0.0.8
|
||||
[0.0.7]: https://github.com/MaxRonzhin/vidconf_rel/releases/tag/v0.0.7
|
||||
[0.0.6]: https://github.com/MaxRonzhin/vidconf_rel/releases/tag/v0.0.6
|
||||
[0.0.5]: https://github.com/MaxRonzhin/vidconf_rel/releases/tag/v0.0.5
|
||||
|
||||
@@ -13,7 +13,7 @@
|
||||
|
||||
import uuid
|
||||
from pathlib import Path
|
||||
from typing import Annotated
|
||||
from typing import Annotated, Literal
|
||||
|
||||
import anyio
|
||||
from fastapi import APIRouter, Depends, File, HTTPException, Query, UploadFile, status
|
||||
@@ -174,12 +174,16 @@ async def send_conference_invitations(
|
||||
async def list_users(
|
||||
admin: Annotated[User, Depends(require_admin)],
|
||||
session: Annotated[AsyncSession, Depends(get_session)],
|
||||
status: Annotated[Literal["active", "blocked"] | None, Query()] = None,
|
||||
q: Annotated[str | None, Query()] = None,
|
||||
limit: Annotated[int, Query(gt=0, le=MAX_LIMIT)] = DEFAULT_LIMIT,
|
||||
offset: Annotated[int, Query(ge=0)] = 0,
|
||||
) -> AdminUserListOut:
|
||||
"""Список всех пользователей инстанса с текстовым поиском по email/имени."""
|
||||
rows, total = await AdminUserRepository(session).list_paginated(q=q, limit=limit, offset=offset)
|
||||
"""Список пользователей инстанса — фильтр по статусу (`active`/`blocked`, без
|
||||
параметра — все) и текстовый поиск по email/имени/названию команды."""
|
||||
rows, total = await AdminUserRepository(session).list_paginated(
|
||||
status=status, q=q, limit=limit, offset=offset
|
||||
)
|
||||
media_root = _media_root()
|
||||
items = [
|
||||
_to_admin_user_out(user, team_name=team_name, media_root=media_root)
|
||||
@@ -460,7 +464,7 @@ def _to_settings_out(cfg: InstanceConfig, *, transcription_queue_served: bool) -
|
||||
display_timezone=cfg.display_timezone,
|
||||
registration_team_choice=cfg.registration_team_choice,
|
||||
registration_email_domain_enabled=cfg.registration_email_domain_enabled,
|
||||
registration_email_domain=cfg.registration_email_domain,
|
||||
registration_email_domains=cfg.registration_email_domains,
|
||||
contact_email_enabled=cfg.contact_email_enabled,
|
||||
contact_email=cfg.contact_email,
|
||||
)
|
||||
|
||||
@@ -53,17 +53,17 @@ async def registration_options(
|
||||
|
||||
Список команд отдаётся только при включённой настройке инстанса
|
||||
`registration_team_choice` — иначе пустой массив (справочник команд не
|
||||
раскрывается, пока выбор выключен). `email_domain` — эталонный домен при
|
||||
включённой настройке `registration_email_domain`, иначе `None`.
|
||||
раскрывается, пока выбор выключен). `email_domains` — эталонные домены при
|
||||
включённой настройке `registration_email_domain`, иначе пустой список.
|
||||
"""
|
||||
cfg = await InstanceSettingsService(session).get()
|
||||
teams: list[RegistrationTeamOptionOut] = []
|
||||
if cfg.registration_team_choice:
|
||||
items, _ = await TeamRepository(session).list_all()
|
||||
teams = [RegistrationTeamOptionOut(id=team.id, name=team.name) for team in items]
|
||||
email_domain = cfg.registration_email_domain if cfg.registration_email_domain_enabled else None
|
||||
email_domains = cfg.registration_email_domains if cfg.registration_email_domain_enabled else []
|
||||
return RegistrationOptionsOut(
|
||||
team_choice_enabled=cfg.registration_team_choice, teams=teams, email_domain=email_domain
|
||||
team_choice_enabled=cfg.registration_team_choice, teams=teams, email_domains=email_domains
|
||||
)
|
||||
|
||||
|
||||
|
||||
@@ -77,11 +77,11 @@ class InstanceConfig(BaseModel):
|
||||
# — см. `services/instance_settings.py`.
|
||||
registration_team_choice: bool = False
|
||||
# Верификация регистрирующихся по домену email: при включении
|
||||
# `POST /auth/register` принимает только
|
||||
# email с доменом `registration_email_domain` — см.
|
||||
# `POST /auth/register` принимает только email с доменом из
|
||||
# `registration_email_domains` (любым из списка) — см.
|
||||
# `services/instance_settings.py`.
|
||||
registration_email_domain_enabled: bool = False
|
||||
registration_email_domain: str | None = None
|
||||
registration_email_domains: list[str] = Field(default_factory=list)
|
||||
# Контактный адрес инстанса — подставляется в `Reply-To` исходящих писем
|
||||
# (сами письма уходят от `no-reply@`, отвечать на них некуда без этого
|
||||
# адреса) — см. `services/instance_settings.py`, `services/email.py`.
|
||||
|
||||
@@ -2,7 +2,7 @@
|
||||
|
||||
import uuid
|
||||
|
||||
from sqlalchemy import func, or_, select
|
||||
from sqlalchemy import ColumnElement, func, or_, select
|
||||
from sqlalchemy.ext.asyncio import AsyncSession
|
||||
|
||||
from models.conference import Conference
|
||||
@@ -56,25 +56,37 @@ class AdminConferenceRepository:
|
||||
|
||||
|
||||
class AdminUserRepository:
|
||||
"""Постраничный список пользователей с текстовым поиском по email/имени."""
|
||||
"""Постраничный список пользователей с фильтром по статусу и текстовым поиском."""
|
||||
|
||||
def __init__(self, session: AsyncSession) -> None:
|
||||
self._session = session
|
||||
|
||||
async def list_paginated(
|
||||
self, *, q: str | None, limit: int, offset: int
|
||||
self, *, status: str | None, q: str | None, limit: int, offset: int
|
||||
) -> tuple[list[tuple[User, str | None]], int]:
|
||||
"""Вернуть страницу пользователей (+ имя команды) и общее число совпадений.
|
||||
|
||||
`LEFT JOIN` на `teams` — имя команды нужно карточке профиля/таблице
|
||||
админки, у пользователя без команды — `None`.
|
||||
`status` — `"active"`/`"blocked"` (фильтр по `is_blocked`), `None` —
|
||||
без фильтра (все пользователи). `q` ищет по email/имени пользователя
|
||||
И по названию команды (`LEFT JOIN` на `teams` — нужен и для этого
|
||||
поиска, и для колонки «Команда» в таблице админки; `LEFT`, а не
|
||||
`INNER`, — пользователи без команды не должны пропадать из общей
|
||||
выдачи, только не совпадать с поиском по названию команды).
|
||||
"""
|
||||
filters = []
|
||||
filters: list[ColumnElement[bool]] = []
|
||||
if status == "active":
|
||||
filters.append(User.is_blocked.is_(False))
|
||||
elif status == "blocked":
|
||||
filters.append(User.is_blocked.is_(True))
|
||||
if q:
|
||||
like = f"%{q}%"
|
||||
filters.append(or_(User.email.ilike(like), User.name_user.ilike(like)))
|
||||
filters.append(
|
||||
or_(User.email.ilike(like), User.name_user.ilike(like), Team.name.ilike(like))
|
||||
)
|
||||
|
||||
count_stmt = select(func.count()).select_from(User)
|
||||
count_stmt = (
|
||||
select(func.count()).select_from(User).outerjoin(Team, User.team_id == Team.id)
|
||||
)
|
||||
items_stmt = (
|
||||
select(User, Team.name)
|
||||
.outerjoin(Team, User.team_id == Team.id)
|
||||
|
||||
@@ -155,7 +155,7 @@ class SettingsOut(BaseModel):
|
||||
display_timezone: str
|
||||
registration_team_choice: bool
|
||||
registration_email_domain_enabled: bool
|
||||
registration_email_domain: str | None = None
|
||||
registration_email_domains: list[str] = Field(default_factory=list)
|
||||
contact_email_enabled: bool
|
||||
contact_email: str | None = None
|
||||
|
||||
|
||||
@@ -103,11 +103,11 @@ class RegistrationOptionsOut(BaseModel):
|
||||
|
||||
`teams` отдаётся только при `team_choice_enabled=True` — иначе пустой
|
||||
список (справочник команд не раскрывается, пока выбор выключен).
|
||||
`email_domain` — эталонный домен при включённой верификации регистрации
|
||||
`email_domains` — эталонные домены при включённой верификации регистрации
|
||||
по домену email (настройка инстанса `registration_email_domain`), иначе
|
||||
`None`.
|
||||
пустой список.
|
||||
"""
|
||||
|
||||
team_choice_enabled: bool
|
||||
teams: list[RegistrationTeamOptionOut]
|
||||
email_domain: str | None = None
|
||||
email_domains: list[str] = Field(default_factory=list)
|
||||
|
||||
@@ -106,9 +106,9 @@ class AuthService:
|
||||
существует — иначе `InvalidTeamSelectionError` (публичный
|
||||
эндпоинт, деталей не раскрываем). Если включена верификация домена
|
||||
email (`registration_email_domain_enabled`), домен `email` (часть
|
||||
после `@`, без учёта регистра) должен совпадать с эталонным —
|
||||
иначе `InvalidEmailDomainError`. Обе проверки — до создания
|
||||
пользователя.
|
||||
после `@`, без учёта регистра) должен совпадать с одним из
|
||||
эталонных доменов (`registration_email_domains`) — иначе
|
||||
`InvalidEmailDomainError`. Обе проверки — до создания пользователя.
|
||||
"""
|
||||
existing = await self._users.get_by_email(email)
|
||||
if existing is not None:
|
||||
@@ -118,7 +118,7 @@ class AuthService:
|
||||
|
||||
if cfg.registration_email_domain_enabled:
|
||||
email_domain = email.rsplit("@", 1)[-1].lower()
|
||||
if email_domain != cfg.registration_email_domain:
|
||||
if email_domain not in cfg.registration_email_domains:
|
||||
raise InvalidEmailDomainError(email)
|
||||
|
||||
if team_id is not None:
|
||||
|
||||
@@ -63,7 +63,12 @@ _DEFAULT_AI_LEVEL_VALUE = {"level": "min"}
|
||||
_DEFAULT_SUMMARY_RECIPIENTS_VALUE = {"mode": "all"}
|
||||
_DEFAULT_DISPLAY_TIMEZONE_VALUE = {"tz": "Europe/Moscow"}
|
||||
_DEFAULT_REGISTRATION_TEAM_CHOICE_VALUE = {"enabled": False}
|
||||
_DEFAULT_REGISTRATION_EMAIL_DOMAIN_VALUE: dict[str, Any] = {"enabled": False, "domain": None}
|
||||
_DEFAULT_REGISTRATION_EMAIL_DOMAIN_VALUE: dict[str, Any] = {"enabled": False, "domains": []}
|
||||
"""Формат значения ключа `registration_email_domain` в БД. До версии с
|
||||
несколькими доменами хранилась форма `{"enabled": bool, "domain": str|None}`
|
||||
(один домен) — читающий код (`_extract_email_domains`) понимает обе формы
|
||||
для обратной совместимости с уже развёрнутыми инстансами; при первом же
|
||||
`update()` значение переписывается в новую форму (см. `update`)."""
|
||||
_DEFAULT_CONTACT_EMAIL_VALUE: dict[str, Any] = {"enabled": False, "email": None}
|
||||
|
||||
# Простой паттерн доменного имени: минимум один символ, минимум одна точка,
|
||||
@@ -95,7 +100,7 @@ class SettingsUpdateIn(BaseModel):
|
||||
display_timezone: str | None = None
|
||||
registration_team_choice: bool | None = None
|
||||
registration_email_domain_enabled: bool | None = None
|
||||
registration_email_domain: str | None = None
|
||||
registration_email_domains: list[str] | None = None
|
||||
contact_email_enabled: bool | None = None
|
||||
contact_email: str | None = None
|
||||
|
||||
@@ -237,7 +242,20 @@ class InstanceSettingsService:
|
||||
rows = await self._load_rows()
|
||||
cfg = _build_config(rows)
|
||||
|
||||
if patch.ai_level is not None:
|
||||
if patch.ai_level is not None and patch.ai_level != cfg.ai_level:
|
||||
# Валидация только при фактической смене уровня (сравнение с уже
|
||||
# сохранённым cfg.ai_level) — иначе фронт, отправляющий текущий
|
||||
# ai_level вместе с любой другой правкой (см. `AdminSettingsTab`),
|
||||
# блокировал бы сохранение несвязанных настроек на слабом железе,
|
||||
# где текущий (давно и легитимно сохранённый) уровень недоступен
|
||||
# по факту заново переоценённых требований (RAM/модели).
|
||||
#
|
||||
# Не ослабляем проверку и при отключённых transcriber.enabled/
|
||||
# summarizer.enabled (когда уровень AI сейчас ни на что не
|
||||
# влияет): если проверять по факту переключения — это осознанное
|
||||
# намерение администратора сменить уровень, и молчаливое
|
||||
# сохранение недоступного значения подставит администратора при
|
||||
# последующем включении AI неработающей конфигурацией.
|
||||
statuses = {status.level: status for status in detect_ai_levels(cfg)}
|
||||
if not statuses[patch.ai_level].available:
|
||||
raise InvalidAiLevelError(
|
||||
@@ -267,26 +285,28 @@ class InstanceSettingsService:
|
||||
|
||||
if (
|
||||
patch.registration_email_domain_enabled is not None
|
||||
or patch.registration_email_domain is not None
|
||||
or patch.registration_email_domains is not None
|
||||
):
|
||||
enabled = (
|
||||
patch.registration_email_domain_enabled
|
||||
if patch.registration_email_domain_enabled is not None
|
||||
else cfg.registration_email_domain_enabled
|
||||
)
|
||||
raw_domain = (
|
||||
patch.registration_email_domain
|
||||
if patch.registration_email_domain is not None
|
||||
else cfg.registration_email_domain
|
||||
raw_domains = (
|
||||
patch.registration_email_domains
|
||||
if patch.registration_email_domains is not None
|
||||
else cfg.registration_email_domains
|
||||
)
|
||||
domain = _normalize_email_domain(raw_domain) if raw_domain else None
|
||||
if enabled and domain is None:
|
||||
domains = _normalize_email_domains(raw_domains)
|
||||
if enabled and not domains:
|
||||
raise InvalidEmailDomainError(
|
||||
"нельзя включить верификацию домена email без указания домена"
|
||||
"нельзя включить верификацию домена email без указания хотя бы одного домена"
|
||||
)
|
||||
cfg.registration_email_domain_enabled = enabled
|
||||
cfg.registration_email_domain = domain
|
||||
await self._set(_KEY_REGISTRATION_EMAIL_DOMAIN, {"enabled": enabled, "domain": domain})
|
||||
cfg.registration_email_domains = domains
|
||||
await self._set(
|
||||
_KEY_REGISTRATION_EMAIL_DOMAIN, {"enabled": enabled, "domains": domains}
|
||||
)
|
||||
|
||||
if patch.contact_email_enabled is not None or patch.contact_email is not None:
|
||||
contact_enabled = (
|
||||
@@ -402,6 +422,32 @@ def _normalize_email_domain(domain: str) -> str:
|
||||
return normalized
|
||||
|
||||
|
||||
def _normalize_email_domains(domains: list[str]) -> list[str]:
|
||||
"""Нормализовать список доменов: strip/lower/убрать «@» на каждом (см.
|
||||
`_normalize_email_domain`), отбросить пустые строки, убрать дубликаты
|
||||
(с сохранением порядка первого вхождения)."""
|
||||
normalized: list[str] = []
|
||||
for raw in domains:
|
||||
if not raw.strip():
|
||||
continue
|
||||
domain = _normalize_email_domain(raw)
|
||||
if domain not in normalized:
|
||||
normalized.append(domain)
|
||||
return normalized
|
||||
|
||||
|
||||
def _extract_email_domains(value: dict[str, Any]) -> list[str]:
|
||||
"""Достать список доменов из значения ключа `registration_email_domain`,
|
||||
понимая и текущую форму (`domains: [...]`), и форму до многодоменной
|
||||
поддержки (`domain: str | None`, один домен) — на проде уже записано
|
||||
именно старое значение, миграция БД для этого не нужна: следующий же
|
||||
`update()` перепишет строку в новую форму (см. docstring `update`)."""
|
||||
if "domains" in value:
|
||||
return list(value["domains"])
|
||||
legacy_domain = value.get("domain")
|
||||
return [legacy_domain] if legacy_domain else []
|
||||
|
||||
|
||||
def _normalize_contact_email(email: str) -> str:
|
||||
"""Нормализовать контактный email (strip, lower) и провалидировать формат."""
|
||||
normalized = email.strip().lower()
|
||||
@@ -436,9 +482,9 @@ def _build_config(rows: dict[str, Any]) -> InstanceConfig:
|
||||
registration_email_domain_enabled=rows.get(
|
||||
_KEY_REGISTRATION_EMAIL_DOMAIN, _DEFAULT_REGISTRATION_EMAIL_DOMAIN_VALUE
|
||||
).get("enabled", False),
|
||||
registration_email_domain=rows.get(
|
||||
_KEY_REGISTRATION_EMAIL_DOMAIN, _DEFAULT_REGISTRATION_EMAIL_DOMAIN_VALUE
|
||||
).get("domain"),
|
||||
registration_email_domains=_extract_email_domains(
|
||||
rows.get(_KEY_REGISTRATION_EMAIL_DOMAIN, _DEFAULT_REGISTRATION_EMAIL_DOMAIN_VALUE)
|
||||
),
|
||||
contact_email_enabled=rows.get(_KEY_CONTACT_EMAIL, _DEFAULT_CONTACT_EMAIL_VALUE).get(
|
||||
"enabled", False
|
||||
),
|
||||
|
||||
@@ -381,6 +381,67 @@ async def test_list_users_returns_all(client: httpx.AsyncClient, db_session: Asy
|
||||
assert all("email_verified" in item for item in items)
|
||||
|
||||
|
||||
async def test_list_users_filters_by_status(
|
||||
client: httpx.AsyncClient, db_session: AsyncSession
|
||||
) -> None:
|
||||
"""`status=active`/`blocked` фильтрует по `is_blocked`; без параметра — все."""
|
||||
admin = await _make_user(db_session, role="admin")
|
||||
active_user = await _make_user(db_session)
|
||||
blocked_user = await _make_user(db_session)
|
||||
blocked_user.is_blocked = True
|
||||
await db_session.commit()
|
||||
|
||||
active_response = await client.get(
|
||||
"/api/v1/admin/users", params={"status": "active"}, headers=_auth_headers(admin)
|
||||
)
|
||||
assert active_response.status_code == 200, active_response.text
|
||||
active_ids = [item["id"] for item in active_response.json()["items"]]
|
||||
assert str(active_user.id) in active_ids
|
||||
assert str(blocked_user.id) not in active_ids
|
||||
|
||||
blocked_response = await client.get(
|
||||
"/api/v1/admin/users", params={"status": "blocked"}, headers=_auth_headers(admin)
|
||||
)
|
||||
assert blocked_response.status_code == 200, blocked_response.text
|
||||
blocked_ids = [item["id"] for item in blocked_response.json()["items"]]
|
||||
assert str(blocked_user.id) in blocked_ids
|
||||
assert str(active_user.id) not in blocked_ids
|
||||
|
||||
all_response = await client.get("/api/v1/admin/users", headers=_auth_headers(admin))
|
||||
all_ids = [item["id"] for item in all_response.json()["items"]]
|
||||
assert str(active_user.id) in all_ids
|
||||
assert str(blocked_user.id) in all_ids
|
||||
|
||||
|
||||
async def test_list_users_search_matches_team_name(
|
||||
client: httpx.AsyncClient, db_session: AsyncSession
|
||||
) -> None:
|
||||
"""`q` находит пользователей по (части) названия их команды; пользователи
|
||||
без команды при этом не пропадают из общей (без поиска) выдачи."""
|
||||
admin = await _make_user(db_session, role="admin")
|
||||
suffix = uuid.uuid4().hex[:8]
|
||||
team = Team(name=f"Rocket-{suffix} Squad")
|
||||
db_session.add(team)
|
||||
await db_session.flush()
|
||||
teamed_user = await _make_user(db_session)
|
||||
teamed_user.team_id = team.id
|
||||
teamless_user = await _make_user(db_session)
|
||||
await db_session.commit()
|
||||
|
||||
response = await client.get(
|
||||
"/api/v1/admin/users", params={"q": f"Rocket-{suffix}"}, headers=_auth_headers(admin)
|
||||
)
|
||||
assert response.status_code == 200, response.text
|
||||
ids = [item["id"] for item in response.json()["items"]]
|
||||
assert str(teamed_user.id) in ids
|
||||
assert str(teamless_user.id) not in ids
|
||||
assert str(admin.id) not in ids
|
||||
|
||||
all_response = await client.get("/api/v1/admin/users", headers=_auth_headers(admin))
|
||||
all_ids = [item["id"] for item in all_response.json()["items"]]
|
||||
assert str(teamless_user.id) in all_ids
|
||||
|
||||
|
||||
async def test_patch_user_role_and_block(
|
||||
client: httpx.AsyncClient, db_session: AsyncSession
|
||||
) -> None:
|
||||
|
||||
@@ -238,7 +238,7 @@ async def test_registration_options_disabled_by_default(
|
||||
body = response.json()
|
||||
assert body["team_choice_enabled"] is False
|
||||
assert body["teams"] == []
|
||||
assert body["email_domain"] is None
|
||||
assert body["email_domains"] == []
|
||||
|
||||
|
||||
async def test_registration_options_enabled_returns_teams_sorted_by_name(
|
||||
@@ -343,29 +343,30 @@ async def test_register_with_unknown_team_id_returns_400(
|
||||
# --- Верификация регистрирующихся по домену email -------------------------------------
|
||||
|
||||
|
||||
async def test_registration_options_returns_email_domain_when_enabled(
|
||||
async def test_registration_options_returns_email_domains_when_enabled(
|
||||
client: httpx.AsyncClient, db_session: AsyncSession
|
||||
) -> None:
|
||||
"""При включённой верификации домена `registration-options` отдаёт эталонный домен."""
|
||||
"""При включённой верификации домена `registration-options` отдаёт все эталонные домены."""
|
||||
await InstanceSettingsService(db_session).update(
|
||||
SettingsUpdateIn(
|
||||
registration_email_domain_enabled=True, registration_email_domain="example.com"
|
||||
registration_email_domain_enabled=True,
|
||||
registration_email_domains=["example.com", "corp.example"],
|
||||
)
|
||||
)
|
||||
await db_session.commit()
|
||||
|
||||
response = await client.get("/api/v1/auth/registration-options")
|
||||
assert response.status_code == 200, response.text
|
||||
assert response.json()["email_domain"] == "example.com"
|
||||
assert response.json()["email_domains"] == ["example.com", "corp.example"]
|
||||
|
||||
|
||||
async def test_registration_options_email_domain_null_when_disabled(
|
||||
async def test_registration_options_email_domains_empty_when_disabled(
|
||||
client: httpx.AsyncClient, db_session: AsyncSession
|
||||
) -> None:
|
||||
"""Выключенная верификация домена — `email_domain` всегда `null`, даже если домен сохранён."""
|
||||
"""Выключенная верификация домена — `email_domains` всегда пуст, даже если домены сохранены."""
|
||||
await InstanceSettingsService(db_session).update(
|
||||
SettingsUpdateIn(
|
||||
registration_email_domain_enabled=True, registration_email_domain="example.com"
|
||||
registration_email_domain_enabled=True, registration_email_domains=["example.com"]
|
||||
)
|
||||
)
|
||||
await InstanceSettingsService(db_session).update(
|
||||
@@ -375,7 +376,7 @@ async def test_registration_options_email_domain_null_when_disabled(
|
||||
|
||||
response = await client.get("/api/v1/auth/registration-options")
|
||||
assert response.status_code == 200, response.text
|
||||
assert response.json()["email_domain"] is None
|
||||
assert response.json()["email_domains"] == []
|
||||
|
||||
|
||||
async def test_register_with_foreign_domain_when_verification_enabled_returns_400(
|
||||
@@ -383,7 +384,8 @@ async def test_register_with_foreign_domain_when_verification_enabled_returns_40
|
||||
) -> None:
|
||||
await InstanceSettingsService(db_session).update(
|
||||
SettingsUpdateIn(
|
||||
registration_email_domain_enabled=True, registration_email_domain="example.com"
|
||||
registration_email_domain_enabled=True,
|
||||
registration_email_domains=["example.com", "corp.example"],
|
||||
)
|
||||
)
|
||||
await db_session.commit()
|
||||
@@ -405,7 +407,7 @@ async def test_register_with_matching_domain_case_insensitive_succeeds(
|
||||
) -> None:
|
||||
await InstanceSettingsService(db_session).update(
|
||||
SettingsUpdateIn(
|
||||
registration_email_domain_enabled=True, registration_email_domain="example.com"
|
||||
registration_email_domain_enabled=True, registration_email_domains=["example.com"]
|
||||
)
|
||||
)
|
||||
await db_session.commit()
|
||||
@@ -421,6 +423,29 @@ async def test_register_with_matching_domain_case_insensitive_succeeds(
|
||||
assert response.status_code == 201, response.text
|
||||
|
||||
|
||||
async def test_register_with_second_domain_in_list_succeeds(
|
||||
client: httpx.AsyncClient, db_session: AsyncSession, email_backend: _CapturingEmailBackend
|
||||
) -> None:
|
||||
"""Email подходит, если совпадает с ЛЮБЫМ доменом из списка — не только с первым."""
|
||||
await InstanceSettingsService(db_session).update(
|
||||
SettingsUpdateIn(
|
||||
registration_email_domain_enabled=True,
|
||||
registration_email_domains=["example.com", "corp.example"],
|
||||
)
|
||||
)
|
||||
await db_session.commit()
|
||||
|
||||
response = await client.post(
|
||||
"/api/v1/auth/register",
|
||||
json={
|
||||
"email": "dave@corp.example",
|
||||
"name_user": "Dave",
|
||||
"password": "supersecret1",
|
||||
},
|
||||
)
|
||||
assert response.status_code == 201, response.text
|
||||
|
||||
|
||||
async def test_register_any_domain_allowed_when_verification_disabled(
|
||||
client: httpx.AsyncClient, email_backend: _CapturingEmailBackend
|
||||
) -> None:
|
||||
|
||||
@@ -134,7 +134,7 @@ async def test_ensure_bootstrapped_imports_yaml_defaults(
|
||||
assert cfg.display_timezone == "Europe/Moscow"
|
||||
assert cfg.registration_team_choice is False
|
||||
assert cfg.registration_email_domain_enabled is False
|
||||
assert cfg.registration_email_domain is None
|
||||
assert cfg.registration_email_domains == []
|
||||
assert cfg.contact_email_enabled is False
|
||||
assert cfg.contact_email is None
|
||||
|
||||
@@ -326,7 +326,7 @@ async def test_registration_team_choice_toggle(
|
||||
async def test_registration_email_domain_enable_without_domain_rejected(
|
||||
db_session: AsyncSession, clean_instance_settings: None
|
||||
) -> None:
|
||||
"""Включение верификации без домена (ни в патче, ни ранее сохранённого) → 400."""
|
||||
"""Включение верификации без доменов (ни в патче, ни ранее сохранённых) → 400."""
|
||||
service = InstanceSettingsService(db_session)
|
||||
await service.ensure_bootstrapped(PLUGINS_YAML)
|
||||
|
||||
@@ -335,7 +335,24 @@ async def test_registration_email_domain_enable_without_domain_rejected(
|
||||
|
||||
cfg = await service.get()
|
||||
assert cfg.registration_email_domain_enabled is False
|
||||
assert cfg.registration_email_domain is None
|
||||
assert cfg.registration_email_domains == []
|
||||
|
||||
|
||||
async def test_registration_email_domain_enable_with_empty_list_rejected(
|
||||
db_session: AsyncSession, clean_instance_settings: None
|
||||
) -> None:
|
||||
"""Пустой список доменов при включении верификации — та же ошибка, что и
|
||||
отсутствие поля (не молчаливое отключение проверки)."""
|
||||
service = InstanceSettingsService(db_session)
|
||||
await service.ensure_bootstrapped(PLUGINS_YAML)
|
||||
|
||||
with pytest.raises(InvalidEmailDomainError):
|
||||
await service.update(
|
||||
SettingsUpdateIn(registration_email_domain_enabled=True, registration_email_domains=[])
|
||||
)
|
||||
|
||||
cfg = await service.get()
|
||||
assert cfg.registration_email_domain_enabled is False
|
||||
|
||||
|
||||
async def test_registration_email_domain_rejects_invalid_pattern(
|
||||
@@ -345,48 +362,106 @@ async def test_registration_email_domain_rejects_invalid_pattern(
|
||||
await service.ensure_bootstrapped(PLUGINS_YAML)
|
||||
|
||||
with pytest.raises(InvalidEmailDomainError):
|
||||
await service.update(SettingsUpdateIn(registration_email_domain="not a domain"))
|
||||
await service.update(SettingsUpdateIn(registration_email_domains=["not a domain"]))
|
||||
|
||||
cfg = await service.get()
|
||||
assert cfg.registration_email_domain is None
|
||||
assert cfg.registration_email_domains == []
|
||||
|
||||
|
||||
async def test_registration_email_domain_normalizes_input(
|
||||
db_session: AsyncSession, clean_instance_settings: None
|
||||
) -> None:
|
||||
"""`@Corp.RU ` нормализуется в `corp.ru` (strip, убрать «@», lower)."""
|
||||
"""`@Corp.RU ` нормализуется в `corp.ru` (strip, убрать «@», lower); пустые строки
|
||||
отбрасываются, дубликаты схлопываются."""
|
||||
service = InstanceSettingsService(db_session)
|
||||
await service.ensure_bootstrapped(PLUGINS_YAML)
|
||||
|
||||
cfg = await service.update(
|
||||
SettingsUpdateIn(
|
||||
registration_email_domain_enabled=True, registration_email_domain="@Corp.RU "
|
||||
registration_email_domain_enabled=True,
|
||||
registration_email_domains=["@Corp.RU ", "", "corp.ru", "Acme.IO"],
|
||||
)
|
||||
)
|
||||
|
||||
assert cfg.registration_email_domain_enabled is True
|
||||
assert cfg.registration_email_domain == "corp.ru"
|
||||
assert cfg.registration_email_domains == ["corp.ru", "acme.io"]
|
||||
|
||||
reloaded = await service.get()
|
||||
assert reloaded.registration_email_domain == "corp.ru"
|
||||
assert reloaded.registration_email_domains == ["corp.ru", "acme.io"]
|
||||
|
||||
|
||||
async def test_registration_email_domain_can_be_disabled_keeping_stored_domain(
|
||||
async def test_registration_email_domain_can_be_disabled_keeping_stored_domains(
|
||||
db_session: AsyncSession, clean_instance_settings: None
|
||||
) -> None:
|
||||
"""Выключение верификации без передачи домена не требует домена и не роняет валидацию."""
|
||||
"""Выключение верификации без передачи доменов не требует их и не роняет валидацию."""
|
||||
service = InstanceSettingsService(db_session)
|
||||
await service.ensure_bootstrapped(PLUGINS_YAML)
|
||||
await service.update(
|
||||
SettingsUpdateIn(
|
||||
registration_email_domain_enabled=True, registration_email_domain="acme.io"
|
||||
registration_email_domain_enabled=True, registration_email_domains=["acme.io"]
|
||||
)
|
||||
)
|
||||
|
||||
cfg = await service.update(SettingsUpdateIn(registration_email_domain_enabled=False))
|
||||
|
||||
assert cfg.registration_email_domain_enabled is False
|
||||
assert cfg.registration_email_domain == "acme.io"
|
||||
assert cfg.registration_email_domains == ["acme.io"]
|
||||
|
||||
|
||||
async def test_registration_email_domain_reads_legacy_single_domain_shape(
|
||||
db_session: AsyncSession, clean_instance_settings: None
|
||||
) -> None:
|
||||
"""До многодоменной поддержки в БД хранилась форма `{"domain": str|None}` (один
|
||||
домен, без миграции на проде) — чтение должно разворачивать её в список из
|
||||
одного элемента (см. `_extract_email_domains`)."""
|
||||
service = InstanceSettingsService(db_session)
|
||||
await service.ensure_bootstrapped(PLUGINS_YAML)
|
||||
stmt = (
|
||||
pg_insert(InstanceSetting)
|
||||
.values(
|
||||
key="registration_email_domain",
|
||||
value={"enabled": True, "domain": "legacy.example"},
|
||||
)
|
||||
.on_conflict_do_update(
|
||||
index_elements=["key"],
|
||||
set_={"value": {"enabled": True, "domain": "legacy.example"}},
|
||||
)
|
||||
)
|
||||
await db_session.execute(stmt)
|
||||
await db_session.commit()
|
||||
|
||||
cfg = await service.get()
|
||||
|
||||
assert cfg.registration_email_domain_enabled is True
|
||||
assert cfg.registration_email_domains == ["legacy.example"]
|
||||
|
||||
|
||||
async def test_registration_email_domain_rewrites_legacy_shape_on_update(
|
||||
db_session: AsyncSession, clean_instance_settings: None
|
||||
) -> None:
|
||||
"""Первое же сохранение после чтения старой формы переписывает строку в
|
||||
новую (`domains: [...]`), а не оставляет legacy `domain` рядом."""
|
||||
service = InstanceSettingsService(db_session)
|
||||
await service.ensure_bootstrapped(PLUGINS_YAML)
|
||||
stmt = (
|
||||
pg_insert(InstanceSetting)
|
||||
.values(
|
||||
key="registration_email_domain",
|
||||
value={"enabled": True, "domain": "legacy.example"},
|
||||
)
|
||||
.on_conflict_do_update(
|
||||
index_elements=["key"],
|
||||
set_={"value": {"enabled": True, "domain": "legacy.example"}},
|
||||
)
|
||||
)
|
||||
await db_session.execute(stmt)
|
||||
await db_session.commit()
|
||||
|
||||
await service.update(SettingsUpdateIn(registration_email_domains=["new.example"]))
|
||||
|
||||
row = await db_session.get(InstanceSetting, "registration_email_domain")
|
||||
assert row is not None
|
||||
assert row.value == {"enabled": True, "domains": ["new.example"]}
|
||||
|
||||
|
||||
async def test_contact_email_enable_without_email_rejected(
|
||||
@@ -478,6 +553,52 @@ async def test_update_rejects_unavailable_ai_level(
|
||||
assert cfg.ai_level == "min"
|
||||
|
||||
|
||||
async def test_update_unrelated_setting_passes_when_current_ai_level_unavailable(
|
||||
db_session: AsyncSession, clean_instance_settings: None
|
||||
) -> None:
|
||||
"""Баг: фронт всегда отправляет текущий `ai_level` вместе с любой другой
|
||||
правкой (см. `AdminSettingsTab.handleSave`) — если уже сохранённый
|
||||
уровень стал недоступен (слабое железо/модель не докачана), это не
|
||||
должно блокировать сохранение несвязанной настройки. Валидация нужна
|
||||
только при фактической смене уровня (см. docstring `update`)."""
|
||||
service = InstanceSettingsService(db_session)
|
||||
await service.ensure_bootstrapped(PLUGINS_YAML)
|
||||
stmt = (
|
||||
pg_insert(InstanceSetting)
|
||||
.values(key="ai_level", value={"level": "medium"})
|
||||
.on_conflict_do_update(index_elements=["key"], set_={"value": {"level": "medium"}})
|
||||
)
|
||||
await db_session.execute(stmt)
|
||||
await db_session.commit()
|
||||
assert not detect_ai_levels(await service.get())[1].available # "medium" недоступен
|
||||
|
||||
# ai_level в патче совпадает с уже сохранённым — не должно проверяться.
|
||||
cfg = await service.update(
|
||||
SettingsUpdateIn(ai_level="medium", registration_team_choice=True)
|
||||
)
|
||||
|
||||
assert cfg.ai_level == "medium"
|
||||
assert cfg.registration_team_choice is True
|
||||
|
||||
|
||||
async def test_update_still_rejects_switching_to_unavailable_ai_level(
|
||||
db_session: AsyncSession, clean_instance_settings: None
|
||||
) -> None:
|
||||
"""Фактическая попытка ПЕРЕКЛЮЧИТЬ уровень на недоступный по-прежнему
|
||||
отклоняется — даже если AI (транскрибация/суммаризация) выключен: иначе
|
||||
администратор молча сохранит нерабочую конфигурацию, которая проявится
|
||||
только при последующем включении AI."""
|
||||
service = InstanceSettingsService(db_session)
|
||||
await service.ensure_bootstrapped(PLUGINS_YAML)
|
||||
await service.update(SettingsUpdateIn(transcription_enabled=False))
|
||||
|
||||
with pytest.raises(InvalidAiLevelError):
|
||||
await service.update(SettingsUpdateIn(ai_level="medium"))
|
||||
|
||||
cfg = await service.get()
|
||||
assert cfg.ai_level == "min"
|
||||
|
||||
|
||||
async def test_update_rejects_invalid_timezone(
|
||||
db_session: AsyncSession, clean_instance_settings: None
|
||||
) -> None:
|
||||
|
||||
@@ -82,7 +82,7 @@ services:
|
||||
MEDIA_ROOT: ${MEDIA_ROOT:-/app/media}
|
||||
# Версия инстанса (релиз v0.0.1) — install.sh копирует значение
|
||||
# из файла VERSION (корень репозитория) в .env; отдаётся в GET /api/health.
|
||||
VIDCONF_VERSION: ${VIDCONF_VERSION:-0.0.7}
|
||||
VIDCONF_VERSION: ${VIDCONF_VERSION:-0.0.8}
|
||||
# config/ лежит в корне репозитория и не попадает в образ (контекст сборки —
|
||||
# только backend/), поэтому plugins.yaml монтируется отдельно.
|
||||
volumes:
|
||||
|
||||
@@ -32,8 +32,9 @@ export interface SettingsOut {
|
||||
registration_team_choice: boolean
|
||||
/** Включена ли верификация регистрации по домену корпоративной почты. */
|
||||
registration_email_domain_enabled: boolean
|
||||
/** Эталонный домен для верификации (напр. `company.ru`) — `null`, если верификация выключена. */
|
||||
registration_email_domain: string | null
|
||||
/** Эталонные домены для верификации (напр. `['company.ru']`) — email подходит, если
|
||||
* совпадает с любым из списка; пуст, если верификация выключена. */
|
||||
registration_email_domains: string[]
|
||||
/** Включён ли контактный адрес инстанса (подставляется в `Reply-To` исходящих писем). */
|
||||
contact_email_enabled: boolean
|
||||
/** Контактный адрес — `null`, если не задан/выключен. */
|
||||
@@ -49,9 +50,9 @@ export interface SettingsUpdateIn {
|
||||
summary_recipients?: SummaryRecipientsMode
|
||||
display_timezone?: string
|
||||
registration_team_choice?: boolean
|
||||
/** Включение без домена или невалидный домен — backend отвечает 400. */
|
||||
/** Включение с пустым списком или невалидным доменом — backend отвечает 400. */
|
||||
registration_email_domain_enabled?: boolean
|
||||
registration_email_domain?: string | null
|
||||
registration_email_domains?: string[]
|
||||
/** Включение без email или невалидный email — backend отвечает 400. */
|
||||
contact_email_enabled?: boolean
|
||||
contact_email?: string | null
|
||||
@@ -136,6 +137,8 @@ export type AdminUserDetailOut = AdminUserOut
|
||||
|
||||
/** Параметры выборки списка пользователей. */
|
||||
export interface AdminUserQuery {
|
||||
/** Фильтр по блокировке — без параметра отдаются все пользователи. */
|
||||
status?: 'active' | 'blocked'
|
||||
q?: string
|
||||
limit?: number
|
||||
offset?: number
|
||||
@@ -220,7 +223,7 @@ export async function sendConferenceInvitations(id: string, emails?: string[]):
|
||||
|
||||
/** Список пользователей для админки — с поиском и пагинацией. */
|
||||
export async function listAdminUsers(query: AdminUserQuery = {}): Promise<PagedResult<AdminUserOut>> {
|
||||
const qs = toQueryString({ q: query.q, limit: query.limit, offset: query.offset })
|
||||
const qs = toQueryString({ status: query.status, q: query.q, limit: query.limit, offset: query.offset })
|
||||
return apiRequest<PagedResult<AdminUserOut>>(`/admin/users${qs}`)
|
||||
}
|
||||
|
||||
|
||||
@@ -21,8 +21,8 @@ export interface RegistrationTeamOption {
|
||||
export interface RegistrationOptions {
|
||||
team_choice_enabled: boolean
|
||||
teams: RegistrationTeamOption[]
|
||||
/** Эталонный домен почты при включённой верификации, иначе `null`. */
|
||||
email_domain: string | null
|
||||
/** Эталонные домены почты при включённой верификации (email подходит под любой), иначе пуст. */
|
||||
email_domains: string[]
|
||||
}
|
||||
|
||||
export interface CurrentUser {
|
||||
|
||||
@@ -1,6 +1,6 @@
|
||||
import { useState } from 'react'
|
||||
import { useMutation, useQuery, useQueryClient } from '@tanstack/react-query'
|
||||
import { AlertTriangle } from 'lucide-react'
|
||||
import { AlertTriangle, X } from 'lucide-react'
|
||||
import {
|
||||
getAdminSettings,
|
||||
sendTestEmail,
|
||||
@@ -60,7 +60,8 @@ function AdminSettingsForm({ data }: { data: SettingsOut }) {
|
||||
const [timezone, setTimezone] = useState(data.display_timezone)
|
||||
const [teamChoiceEnabled, setTeamChoiceEnabled] = useState(data.registration_team_choice)
|
||||
const [domainVerificationEnabled, setDomainVerificationEnabled] = useState(data.registration_email_domain_enabled)
|
||||
const [emailDomain, setEmailDomain] = useState(data.registration_email_domain ?? '')
|
||||
const [emailDomains, setEmailDomains] = useState(data.registration_email_domains)
|
||||
const [newDomainInput, setNewDomainInput] = useState('')
|
||||
const [contactEmailEnabled, setContactEmailEnabled] = useState(data.contact_email_enabled)
|
||||
const [contactEmail, setContactEmail] = useState(data.contact_email ?? '')
|
||||
const [testEmailTo, setTestEmailTo] = useState('')
|
||||
@@ -94,19 +95,48 @@ function AdminSettingsForm({ data }: { data: SettingsOut }) {
|
||||
},
|
||||
})
|
||||
|
||||
function addDomain() {
|
||||
const domain = newDomainInput.trim().toLowerCase().replace(/^@/, '')
|
||||
if (!domain || emailDomains.includes(domain)) {
|
||||
setNewDomainInput('')
|
||||
return
|
||||
}
|
||||
setEmailDomains([...emailDomains, domain])
|
||||
setNewDomainInput('')
|
||||
}
|
||||
|
||||
function removeDomain(domain: string) {
|
||||
setEmailDomains(emailDomains.filter((d) => d !== domain))
|
||||
}
|
||||
|
||||
function handleSave() {
|
||||
mutation.mutate({
|
||||
chat_enabled: chatEnabled,
|
||||
transcription_enabled: aiEnabled,
|
||||
ai_level: aiLevel,
|
||||
summary_recipients: recipients,
|
||||
display_timezone: timezone.trim(),
|
||||
registration_team_choice: teamChoiceEnabled,
|
||||
registration_email_domain_enabled: domainVerificationEnabled,
|
||||
registration_email_domain: emailDomain.trim() || null,
|
||||
contact_email_enabled: contactEmailEnabled,
|
||||
contact_email: contactEmail.trim() || null,
|
||||
})
|
||||
// Отправляем только реально изменённые поля (`SettingsUpdateIn` — набор
|
||||
// опциональных полей именно для этого): иначе, например, ai_level
|
||||
// уходил бы в PUT нетронутым при каждом сохранении и на слабом железе
|
||||
// валился бы в 400, блокируя правку вообще любой другой настройки.
|
||||
const payload: SettingsUpdateIn = {}
|
||||
if (chatEnabled !== data.chat_enabled) payload.chat_enabled = chatEnabled
|
||||
if (aiEnabled !== data.transcription_enabled) payload.transcription_enabled = aiEnabled
|
||||
if (aiLevel !== data.ai_level) payload.ai_level = aiLevel
|
||||
if (recipients !== data.summary_recipients) payload.summary_recipients = recipients
|
||||
if (timezone.trim() !== data.display_timezone) payload.display_timezone = timezone.trim()
|
||||
if (teamChoiceEnabled !== data.registration_team_choice) {
|
||||
payload.registration_team_choice = teamChoiceEnabled
|
||||
}
|
||||
if (domainVerificationEnabled !== data.registration_email_domain_enabled) {
|
||||
payload.registration_email_domain_enabled = domainVerificationEnabled
|
||||
}
|
||||
if (JSON.stringify(emailDomains) !== JSON.stringify(data.registration_email_domains)) {
|
||||
payload.registration_email_domains = emailDomains
|
||||
}
|
||||
if (contactEmailEnabled !== data.contact_email_enabled) {
|
||||
payload.contact_email_enabled = contactEmailEnabled
|
||||
}
|
||||
const trimmedContactEmail = contactEmail.trim() || null
|
||||
if (trimmedContactEmail !== (data.contact_email ?? null)) {
|
||||
payload.contact_email = trimmedContactEmail
|
||||
}
|
||||
mutation.mutate(payload)
|
||||
}
|
||||
|
||||
return (
|
||||
@@ -229,19 +259,53 @@ function AdminSettingsForm({ data }: { data: SettingsOut }) {
|
||||
|
||||
<section className="settings-card">
|
||||
<h2>Эталон mail-домена</h2>
|
||||
<p className="desc">Домен, с которым сверяется email при регистрации, если включена верификация в «Модулях».</p>
|
||||
<p className="desc">Домены, с любым из которых сверяется email при регистрации, если включена верификация в «Модулях».</p>
|
||||
|
||||
<div className="settings-card-body settings-card-body--center">
|
||||
<div className="settings-card-body">
|
||||
{emailDomains.length > 0 && (
|
||||
<div className="participants-chips">
|
||||
{emailDomains.map((domain) => (
|
||||
<span className="participant-chip" key={domain}>
|
||||
{domain}
|
||||
<button
|
||||
type="button"
|
||||
className="participant-chip-remove"
|
||||
aria-label={`Убрать домен: ${domain}`}
|
||||
onClick={() => removeDomain(domain)}
|
||||
disabled={!domainVerificationEnabled}
|
||||
>
|
||||
<X style={{ width: 12, height: 12 }} aria-hidden="true" />
|
||||
</button>
|
||||
</span>
|
||||
))}
|
||||
</div>
|
||||
)}
|
||||
<div className="field" style={{ marginBottom: 0 }}>
|
||||
<label htmlFor="settings-email-domain">Домен корпоративной почты</label>
|
||||
<input
|
||||
id="settings-email-domain"
|
||||
type="text"
|
||||
placeholder="company.ru"
|
||||
value={emailDomain}
|
||||
disabled={!domainVerificationEnabled}
|
||||
onChange={(e) => setEmailDomain(e.target.value)}
|
||||
/>
|
||||
<div style={{ display: 'flex', gap: 'var(--space-2)' }}>
|
||||
<input
|
||||
id="settings-email-domain"
|
||||
type="text"
|
||||
placeholder="company.ru"
|
||||
value={newDomainInput}
|
||||
disabled={!domainVerificationEnabled}
|
||||
onChange={(e) => setNewDomainInput(e.target.value)}
|
||||
onKeyDown={(e) => {
|
||||
if (e.key === 'Enter') {
|
||||
e.preventDefault()
|
||||
addDomain()
|
||||
}
|
||||
}}
|
||||
/>
|
||||
<button
|
||||
type="button"
|
||||
className="btn btn-secondary"
|
||||
disabled={!domainVerificationEnabled || !newDomainInput.trim()}
|
||||
onClick={addDomain}
|
||||
>
|
||||
Добавить
|
||||
</button>
|
||||
</div>
|
||||
</div>
|
||||
</div>
|
||||
</section>
|
||||
|
||||
@@ -13,6 +13,12 @@ const PAGE_SIZE = 10
|
||||
/** Верхний предел выборки команд для селекта — без отдельной пагинации в этом контексте. */
|
||||
const TEAMS_LIMIT = 200
|
||||
|
||||
const STATUS_FILTERS: { value: 'active' | 'blocked' | 'all'; label: string }[] = [
|
||||
{ value: 'active', label: 'Активные' },
|
||||
{ value: 'blocked', label: 'Заблокированные' },
|
||||
{ value: 'all', label: 'Все' },
|
||||
]
|
||||
|
||||
/**
|
||||
* Вкладка «Пользователи» админки — список с поиском, пагинацией, сменой
|
||||
* роли, блокировкой и командой (design/mockups/admin.html,
|
||||
@@ -28,6 +34,7 @@ const TEAMS_LIMIT = 200
|
||||
*/
|
||||
export function AdminUsersTab() {
|
||||
const { user: currentUser } = useAuth()
|
||||
const [statusFilter, setStatusFilter] = useState<'active' | 'blocked' | 'all'>('all')
|
||||
const [searchInput, setSearchInput] = useState('')
|
||||
const [search, setSearch] = useState('')
|
||||
const [offset, setOffset] = useState(0)
|
||||
@@ -45,8 +52,14 @@ export function AdminUsersTab() {
|
||||
}, [searchInput])
|
||||
|
||||
const { data, isLoading } = useQuery({
|
||||
queryKey: ['admin', 'users', search, offset],
|
||||
queryFn: () => listAdminUsers({ q: search || undefined, limit: PAGE_SIZE, offset }),
|
||||
queryKey: ['admin', 'users', statusFilter, search, offset],
|
||||
queryFn: () =>
|
||||
listAdminUsers({
|
||||
status: statusFilter === 'all' ? undefined : statusFilter,
|
||||
q: search || undefined,
|
||||
limit: PAGE_SIZE,
|
||||
offset,
|
||||
}),
|
||||
})
|
||||
|
||||
const { data: teamsData } = useQuery({
|
||||
@@ -89,13 +102,29 @@ export function AdminUsersTab() {
|
||||
|
||||
return (
|
||||
<>
|
||||
<div className="section-tabs-inline">
|
||||
{STATUS_FILTERS.map((f) => (
|
||||
<button
|
||||
key={f.value}
|
||||
type="button"
|
||||
className={`chip${statusFilter === f.value ? ' is-active' : ''}`}
|
||||
onClick={() => {
|
||||
setStatusFilter(f.value)
|
||||
setOffset(0)
|
||||
}}
|
||||
>
|
||||
{f.label}
|
||||
</button>
|
||||
))}
|
||||
</div>
|
||||
|
||||
<div className="toolbar-row">
|
||||
<div className="toolbar-left">
|
||||
<div className="search-wrap">
|
||||
<Search className="icon" style={{ width: 16, height: 16 }} aria-hidden="true" />
|
||||
<input
|
||||
type="text"
|
||||
placeholder="Поиск по имени или email…"
|
||||
placeholder="Поиск по имени, email или команде…"
|
||||
value={searchInput}
|
||||
onChange={(e) => setSearchInput(e.target.value)}
|
||||
/>
|
||||
|
||||
@@ -6,19 +6,21 @@ import { AuthLayout } from '@/components/auth/AuthLayout'
|
||||
import { getRegistrationOptions, register } from '@/api/auth'
|
||||
import { ApiError, errorDetail } from '@/api/client'
|
||||
|
||||
/** Текст предупреждения о несовпадении домена почты с эталонным. */
|
||||
function domainMismatchMessage(domain: string): string {
|
||||
return `Укажите рабочую почту — регистрация доступна только для домена @${domain}`
|
||||
/** Текст предупреждения о несовпадении домена почты с эталонными. */
|
||||
function domainMismatchMessage(domains: string[]): string {
|
||||
const list = domains.map((domain) => `@${domain}`).join(' или ')
|
||||
return `Укажите рабочую почту — регистрация доступна только для домена ${list}`
|
||||
}
|
||||
|
||||
/**
|
||||
* Экран регистрации (см. design/mockups/auth.html, блок «регистрация»).
|
||||
* Поле «Команда» показывается только если выбор команды включён в
|
||||
* настройках инстанса (`GET /auth/registration-options`, публичный эндпоинт).
|
||||
* Поле «Рабочая почта» дополнительно сверяется с эталонным доменом
|
||||
* (`registration-options.email_domain`), если в админке включена
|
||||
* верификация по домену — проверка идёт по blur и при сабмите, backend
|
||||
* при включённой верификации и чужом домене отвечает 400 `invalid_email_domain`.
|
||||
* Поле «Рабочая почта» дополнительно сверяется с эталонными доменами
|
||||
* (`registration-options.email_domains` — подходит совпадение с ЛЮБЫМ),
|
||||
* если в админке включена верификация по домену — проверка идёт по blur и
|
||||
* при сабмите, backend при включённой верификации и чужом домене отвечает
|
||||
* 400 `invalid_email_domain`.
|
||||
* После успешной регистрации показывает состояние «подтвердите почту»
|
||||
* (письмо со ссылкой backend в dev-режиме печатает в консоль).
|
||||
*/
|
||||
@@ -38,16 +40,16 @@ export function RegisterPage() {
|
||||
})
|
||||
const teamChoiceEnabled = registrationOptions?.team_choice_enabled ?? false
|
||||
const teams = registrationOptions?.teams ?? []
|
||||
const expectedEmailDomain = registrationOptions?.email_domain ?? null
|
||||
const expectedEmailDomains = registrationOptions?.email_domains ?? []
|
||||
|
||||
/** Домен после «@» не совпадает (без учёта регистра) с эталонным — `null`, если сверять не с чем. */
|
||||
/** Домен после «@» не совпадает (без учёта регистра) ни с одним эталонным — `null`, если сверять не с чем. */
|
||||
function checkEmailDomain(value: string): string | null {
|
||||
if (!expectedEmailDomain) return null
|
||||
if (expectedEmailDomains.length === 0) return null
|
||||
const atIndex = value.lastIndexOf('@')
|
||||
if (atIndex === -1) return null
|
||||
const domain = value.slice(atIndex + 1).trim().toLowerCase()
|
||||
if (domain !== expectedEmailDomain.toLowerCase()) {
|
||||
return domainMismatchMessage(expectedEmailDomain)
|
||||
if (!expectedEmailDomains.some((expected) => domain === expected.toLowerCase())) {
|
||||
return domainMismatchMessage(expectedEmailDomains)
|
||||
}
|
||||
return null
|
||||
}
|
||||
@@ -68,7 +70,7 @@ export function RegisterPage() {
|
||||
if (err instanceof ApiError && err.status === 409) {
|
||||
setError('Пользователь с таким email уже зарегистрирован')
|
||||
} else if (err instanceof ApiError && err.status === 400 && errorDetail(err) === 'invalid_email_domain') {
|
||||
setEmailDomainError(expectedEmailDomain ? domainMismatchMessage(expectedEmailDomain) : 'Регистрация с этим доменом почты недоступна')
|
||||
setEmailDomainError(expectedEmailDomains.length > 0 ? domainMismatchMessage(expectedEmailDomains) : 'Регистрация с этим доменом почты недоступна')
|
||||
} else {
|
||||
setError('Не удалось зарегистрироваться. Проверьте данные и попробуйте снова')
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user