fix(web): allow returning home from questionnaires

Keep the shared dialog and submitted answers while leaving the focus screen. Remove the history trap and wire the text-step home action. Refs #85
feat(ui): extend minimal doctor design across all screens
2026-10-04 16:14:37 +03:00 · 2026-10-04 16:09:57 +03:00
26 changed files with 542 additions and 1195 deletions
@@ -1,15 +1,15 @@
 # Dashboard-only Streamlit settings (doctor dashboard + demo console).
 [theme]
 base = "light"
-primaryColor = "#2A78D6"
+primaryColor = "#285E4E"
-backgroundColor = "#F6F7F9"
+backgroundColor = "#F6F7F3"
 secondaryBackgroundColor = "#FFFFFF"
-textColor = "#1B1F24"
+textColor = "#213B38"
-borderColor = "#E3E6EA"
+borderColor = "#E1E7E3"
 baseRadius = "medium"
 # Falls back to the system sans-serif when offline (ADR-004).
-font = "Inter:https://fonts.googleapis.com/css2?family=Inter:wght@400;500;600;700&display=swap, sans-serif"
+font = "sans-serif"
-headingFontWeights = 700
+headingFontWeights = 600
 [client]
 toolbarMode = "minimal"
@@ -1,150 +0,0 @@
 # Подключение будущего бота MAX
 Серверная часть готова к подключению. Сам бот ещё не создан, секреты не заполнены,
 реальная отправка не включена. Изменений интерфейса сайта в этой поставке нет.
 Интеграция уведомляет **самого пациента**; врачебные оповещения остаются в существующем канале проекта.
 ## Что реализовано
 - Одноразовая ссылка для привязки аккаунта MAX к текущему пациенту сайта, срок по умолчанию 10 минут.
 - Подтверждение подключения, `/help`, `/stop`, отключение при остановке или удалении бота в MAX.
 - Нейтральные напоминания из существующего планировщика сайта: тесты, дневник, приём лекарств и другие события outbox.
 - Уведомление о завершении теста: сервер каждые примерно 30 секунд находит новые завершённые
  `QuestionnaireRecord` и `ScaleResult`, начиная с момента подключения MAX. Незавершённые и старые тесты не отправляются.
 - Постоянная очередь, восстановление после перезапуска, ограниченные повторы при сетевых ошибках и ответах 429/5xx.
 - В сообщении только короткий текст и кнопка на сайт. Ответы, оценки, диагнозы, назначения и ключ входа на сайт
  в MAX не передаются. Переписка с ботом не сохраняется и не отправляется в LLM.
 ## 1. Создать бота — будущему владельцу
 1. Открыть [MAX для партнёров](https://business.max.ru/) и пройти регистрацию/проверку профиля.
   Условия допуска зависят от типа владельца; актуальный порядок — в
   [официальной инструкции подключения](https://dev.max.ru/help/platform_connection).
 2. Создать чат-бота, оформить описание и пройти требуемую MAX модерацию.
 3. В настройках бота получить токен и скопировать имя из его публичной ссылки `https://max.ru/ИМЯ`.
 4. Передать администратору сервера имя бота, а токен — через защищённое хранилище секретов.
   Токен не нужен в переписке, MR или репозитории.
 ## 2. Заполнить настройки сервера
 Нужны доступная identity/clinical БД проекта, публичный HTTPS-адрес сайта и HTTPS-адрес API на порту 443.
 Входящие POST от MAX должны доходить до API без браузерной CAPTCHA или страницы авторизации.
 Прокси должен передавать заголовок `X-Max-Bot-Api-Secret` и не журналировать тело webhook/Authorization.
 Дополнительные таблицы identity создаются существующим `init_db()` при запуске приложения.
 В `.env` сервера (вне Git) заполнить:
 ```dotenv
 MAX_ENABLED=false
 MAX_BOT_TOKEN=
 MAX_BOT_USERNAME=
 MAX_WEBHOOK_SECRET=
 MAX_WEBHOOK_URL=https://api.example.org/api/v1/webhooks/max
 MAX_SITE_URL=https://patient.example.org/
 MAX_LINK_TTL_SECONDS=600
 # При необходимости — PEM-файл доверенного CA, доступный внутри контейнера:
 MAX_CA_BUNDLE=
 DEMO_CLOCK=false
 ```
 - `MAX_BOT_USERNAME` — только имя, без `@`, домена или параметров ссылки.
 - `MAX_WEBHOOK_SECRET` — отдельная случайная строка, не токен бота: 32–256 символов из `A–Z a–z 0–9 _ -`.
  Сгенерировать локально, например `python -c 'import secrets; print(secrets.token_urlsafe(32))'`, сохранить в секреты.
 - `MAX_SITE_URL` ведёт в обычный личный кабинет; не добавлять в адрес ключи доступа или данные пациента.
 - Исходящие запросы идут на `https://platform-api2.max.ru`, токен передаётся заголовком `Authorization`.
  Верификация TLS всегда включена. Если системе нужен корневой сертификат Минцифры, установить его по
  официальной инструкции MAX и указать PEM-путь в `MAX_CA_BUNDLE`; не отключать проверку TLS.
 - Переменные должны попасть именно в окружение API-контейнера/процесса, а не только панели сайта.
  В текущем Compose сервис `app` уже получает `.env` через `env_file`.
  После изменения окружения пересоздать процесс/контейнер API. Новые зависимости не требуются.
 ## 3. Проверить и включить
 В каталоге проекта, в том же окружении, где работает API:
 ```sh
 uv run python -m app.channels.max_setup check
 ```
 Команда проверит токен и совпадение имени бота. Сообщений пользователям она не отправляет.
 Затем установить `MAX_ENABLED=true`, перезапустить API и выполнить:
 ```sh
 uv run python -m app.channels.max_setup subscribe
 uv run python -m app.channels.max_setup status
 ```
 `subscribe` регистрирует только заданный webhook с секретом и событиями
 `bot_started`, `message_created`, `bot_stopped`, `dialog_removed`. Старые чужие подписки автоматически
 не удаляются: при переносе сервера владелец должен проверить их отдельно через MAX API.
 `status` проверяет регистрацию адреса; это ещё не проверка доступности сервера из MAX.
 Команды не печатают токены, секрет webhook или сырые ответы платформы.
 При запуске через Compose вместо `uv run python ...` использовать
 `docker compose exec app python -m app.channels.max_setup check` (также `subscribe` и `status`).
 После изменения `.env` пересоздать API: `docker compose up -d --build --force-recreate app`.
 Запускать один процесс API с MAX на один токен бота: его worker отправляет до одного сообщения в секунду.
 БД защищает очередь от параллельного захвата, но общий лимит скорости нескольких процессов не координируется.
 Планировщик и MAX worker запускаются вместе с FastAPI, отдельный процесс бота не нужен.
 При `MAX_ENABLED=false` сетевых вызовов MAX и фонового worker нет; сайт продолжает обычную работу.
 ## API для разработчика сайта
 В проекте используется ключ текущего пациента, полученный при входе. Для этих ручек передавать его
 как `Authorization: Bearer <patient_token>`; это существующая авторизация прототипа, не новая система SSO.
 Не брать token другого пациента и не публиковать демонстрационные учётные записи для реального использования.
 | Метод и путь | Запрос | Ответ |
 |---|---|---|
 | `GET /api/v1/me/notifications/max` | Authorization | `available`, `connected`, `last_delivery` |
 | `POST /api/v1/me/notifications/max/link` | Authorization; JSON `{"consent": true}` | `url`, `expires_at` |
 | `DELETE /api/v1/me/notifications/max` | Authorization | состояние с `connected: false` |
 | `POST /api/v1/webhooks/max` | MAX JSON + `X-Max-Bot-Api-Secret` | `{"success": true}` после записи события |
 Поток подключения: пациент явно соглашается на уведомления → сайт получает `url` → открывает ссылку MAX →
 пользователь запускает бота → webhook подтверждает привязку → повторный GET показывает `connected: true`.
 Ссылка одноразовая; новая ссылка отменяет предыдущую. Изначальный ключ пациента не входит в URL MAX.
 Для привязки и доставки дополнительно нужны действующее согласие и подтверждение совершеннолетия в состоянии пациента.
 Активную привязку нельзя молча переназначить другому аккаунту: сначала отключить её.
 Коды ошибок: 401 — неизвестный/отсутствующий ключ пациента; 403 — нет согласия или неверный секрет webhook;
 422 — неверный запрос; 413 — webhook больше 64 КиБ; 503 — MAX выключен или хранилище события недоступно.
 Повтор webhook с тем же идентификатором события не создаёт новых отправок. Групповые чаты игнорируются.
 `last_delivery`: `queued`, `sending`, `sent`, `failed`, `cancelled` или `null`.
 `sent` означает принятие сообщения API MAX, а не прочтение человеком.
 ## Пробное подключение после создания бота
 1. Войти на сайте синтетическим пациентом и дать необходимые согласия.
 2. Получить ссылку через POST выше (Swagger `/docs` или будущий интерфейс сайта), перейти в MAX и запустить бота.
 3. Убедиться, что GET показывает `connected: true` и приходит подтверждение.
 4. Завершить тест на сайте; примерно через 30 секунд плюс очередь должно прийти сообщение без результатов.
 5. Дождаться события планировщика и проверить нейтральное напоминание с кнопкой на сайт.
 6. Отправить `/stop`: GET должен показать `connected: false`, ожидающие уведомления отменяются.
 7. Повторить подключение новой ссылкой, проверить DELETE через API и остановку бота через интерфейс MAX.
 При недоставке проверить настройки и подписку, доступность HTTPS, состояние очереди и коды ошибок в логах.
 `http_401`/`http_403` требуют проверки токена/прав; `http_429` — ожидания; `transport` — сети/TLS;
 `failed` после шести попыток требует вмешательства администратора. Детали ответов и идентификаторы в логи не выводятся.
 Отключение отменяет очередь; уже принятый MAX запрос отозвать невозможно.
 ## Гарантии и ограничения
 Очередь и подтверждения событий сохраняются в identity БД. Клинические записи остаются в clinical БД.
 Для событий завершения тестов БД повторно просматривается после перезапуска; ключи уведомлений предотвращают
 повторную постановку. Напоминания используют существующий механизм outbox/повторов планировщика.
 При временных ошибках — до 6 попыток с увеличением задержки и учётом `Retry-After`; зависшая отправка получает
 новую аренду через 60 секунд. Потеря процесса между принятием сообщения MAX и записью успеха в БД может
 привести к повторному сообщению: MAX не предоставляет ключ идемпотентности отправки.
 Не удалять строки дедупликации/очереди без согласованной политики хранения. При большом количестве пациентов
 нужны пакетное сканирование завершённых тестов и общий ограничитель скорости; текущая реализация рассчитана на MVP.
 Проверки разработчика: `make lint test`; тесты MAX работают с синтетикой и подменённым HTTP-транспортом.
 Реальную доставку подтвердит только пробное подключение после выдачи токена и настройки публичного сервера.
 Официальные контракты: [отправка сообщений](https://dev.max.ru/docs-api/methods/POST/messages),
 [подписка webhook](https://dev.max.ru/docs-api/methods/POST/subscriptions),
 [события](https://dev.max.ru/docs-api/objects/Update),
 [ссылки запуска бота](https://dev.max.ru/docs/chatbots/bots-coding/prepare).
@@ -1,224 +0,0 @@
 """Notifications-only MAX adapter; no patient text enters the dialog engine or an LLM.
 Webhook transactions persist receipts and replies together, then return immediately.
 The worker delivers from identity DB with leases and bounded retries. MAX has no send
 idempotency key: a crash after API acceptance and before commit can duplicate a message.
 """
 import asyncio
 import contextlib
 import json
 import logging
 from functools import lru_cache
 import yaml
 from pydantic import BaseModel, Field
 from sqlalchemy import select
 from sqlalchemy.exc import IntegrityError
 from app.channels.max_client import MaxApiError, MaxClient
 from app.config import get_settings
 from app.core import clock
 from app.db.max_notifications import MaxBinding, MaxReceipt
 from app.db.session import get_identity_session
 from app.dialog.contracts import Reply
 from app.integrations import max_store as store
 from app.integrations.base import Outbox, integrations
 log = logging.getLogger(__name__)
 class Texts(BaseModel):
    connected: str = Field(max_length=4000)
    not_connected: str = Field(max_length=4000)
    invalid: str = Field(max_length=4000)
    stopped: str = Field(max_length=4000)
    help: str = Field(max_length=4000)
    notification: str = Field(max_length=4000)
    completed: str = Field(max_length=4000)
    open_site: str = Field(max_length=128)
@lru_cache
 def texts() -> Texts:
    path = get_settings().config_dir / "texts" / "max.yaml"
    return Texts.model_validate(yaml.safe_load(path.read_text(encoding="utf-8")))
 def _event(event: dict) -> tuple[str, int, str, str] | None:
    """Normalize only documented private-user events; unknown/malformed events are ignored."""
    kind = event.get("update_type")
    stamp = event.get("timestamp")
    if type(stamp) is not int or stamp < 0:
        return None
    message_id = ""
    if kind == "message_created":
        message = event.get("message")
        if not isinstance(message, dict):
            return None
        recipient, body = message.get("recipient"), message.get("body")
        if not isinstance(recipient, dict) or recipient.get("chat_type") != "dialog" or not isinstance(body, dict):
            return None
        user, text, message_id = message.get("sender"), body.get("text"), body.get("mid")
        if not isinstance(message_id, str) or not message_id or not isinstance(text, str):
            return None
    elif kind in ("bot_started", "bot_stopped", "dialog_removed"):
        user, text = event.get("user"), event.get("payload") or ""
    else:
        return None
    if not isinstance(user, dict) or user.get("is_bot") is not False:
        return None
    uid = user.get("user_id")
    if type(uid) is not int or not 0 < uid < 2**63 or not isinstance(text, str) or len(text) > 4000:
        return None
    # Names, profile details and raw text are neither persisted nor logged.
    receipt = store.digest(f"{kind}:{uid}:{message_id or stamp}")
    return kind, uid, text.strip(), receipt
 async def handle_update(event: dict) -> None:
    if not get_settings().max_enabled or (parsed := _event(event)) is None:
        return
    kind, user_id, text, receipt = parsed
    now = clock.now()
    try:
        async with get_identity_session() as session:
            if await session.get(MaxReceipt, receipt):
                return
            session.add(MaxReceipt(digest=receipt, received_at=now))
            await session.flush()
            binding = await session.scalar(select(MaxBinding).where(MaxBinding.user_id == user_id))
            reply_token = None
            command, _, payload = text.partition(" ")
            if kind in ("bot_stopped", "dialog_removed") or command.lower() == "/stop":
                if binding:
                    await store.disconnect(session, binding.token)
                # When MAX itself stops/deletes the bot, do not attempt a reply.
                if kind != "message_created":
                    return
                reply = "stopped"
            elif kind == "bot_started" or command.lower() == "/start":
                code = text if kind == "bot_started" else payload.strip()
                if code:
                    token = await store.code_token(session, code, now) if len(code) <= 128 else None
                    linked = (
                        token and await store.active_patient(token) and await store.bind(session, code, user_id, now)
                    )
                    reply = "connected" if linked else "invalid"
                    reply_token = token if linked else None
                else:
                    reply = "connected" if binding and binding.enabled else "not_connected"
                    reply_token = binding.token if binding and binding.enabled else None
            else:
                reply = "help"
            await store.enqueue(session, key=receipt, user_id=user_id, token=reply_token, kind=reply, now=now)
    except IntegrityError:
        # A concurrent delivery of the same webhook can race on its receipt primary key.
        async with get_identity_session() as session:
            if await session.get(MaxReceipt, receipt) is None:
                raise
 class MaxOutbox:
    def __init__(self, fallback: Outbox):
        self.fallback = fallback
    async def push(self, token: str, replies: list[Reply]) -> None:
        if replies and get_settings().max_enabled and await store.active_patient(token):
            async with get_identity_session() as session:
                binding = await session.get(MaxBinding, token)
                if binding and binding.enabled:
                    # Hash the event for retry deduplication; never store/transmit its clinical text.
                    event = json.dumps([r.model_dump() for r in replies], sort_keys=True, ensure_ascii=False)
                    key = store.digest(f"{token}:{binding.connected_at.isoformat()}:{clock.today()}:{event}")
                    await store.enqueue(
                        session, key=key, user_id=binding.user_id, token=token, kind="notification", now=clock.now()
                    )
        await self.fallback.push(token, replies)
 async def deliver_one(client: MaxClient) -> bool:
    async with get_identity_session() as session:
        row = await store.claim(session, clock.now())
    if row is None:
        return False
    if row.token is not None:
        async with get_identity_session() as session:
            binding = await session.get(MaxBinding, row.token)
            valid = (
                binding
                and binding.enabled
                and binding.user_id == row.user_id
                and binding.connected_at <= row.created_at
            )
        if not valid or not await store.active_patient(row.token):
            async with get_identity_session() as session:
                await store.finish(session, row, state="cancelled", now=clock.now())
            return True
    settings, messages = get_settings(), texts()
    try:
        await client.send(
            row.user_id, getattr(messages, row.kind), site_url=settings.max_site_url, button=messages.open_site
        )
    except MaxApiError as exc:
        retry = exc.retryable and row.attempts < store.MAX_ATTEMPTS
        delay = max(exc.retry_after, min(300, 5 * 2 ** (row.attempts - 1)))
        async with get_identity_session() as session:
            await store.finish(
                session,
                row,
                state="queued" if retry else "failed",
                now=clock.now(),
                error=exc.code,
                retry_seconds=delay if retry else 0,
            )
        log.warning("MAX delivery deferred=%s code=%s", retry, exc.code)
    else:
        async with get_identity_session() as session:
            await store.finish(session, row, state="sent", now=clock.now())
    return True
 async def _run(client: MaxClient) -> None:
    tick = 0
    while True:
        try:
            if tick % 30 == 0:
                async with get_identity_session() as session:
                    await store.collect_completed(session, clock.now())
            await deliver_one(client)
        except Exception as exc:
            # No exception text: SQL/HTTP errors may contain identifiers or parameters.
            log.error("MAX worker failed type=%s", type(exc).__name__)
        tick += 1
        # One send per second per process, below MAX's two-per-second per-dialog limit.
        await asyncio.sleep(1)
 _client: MaxClient | None = None
 _task: asyncio.Task | None = None
 _wrapper: MaxOutbox | None = None
 async def start() -> None:
    global _client, _task, _wrapper
    if not get_settings().max_enabled or _task is not None:
        return
    texts()  # Validate templates before replacing a working outbox.
    _client = MaxClient(get_settings())
    _wrapper = MaxOutbox(integrations.outbox)
    integrations.outbox = _wrapper
    _task = asyncio.create_task(_run(_client), name="max-notifications")
 async def stop() -> None:
    global _client, _task, _wrapper
    if _task:
        _task.cancel()
        with contextlib.suppress(asyncio.CancelledError):
            await _task
    if _wrapper and integrations.outbox is _wrapper:
        integrations.outbox = _wrapper.fallback
    if _client:
        await _client.close()
    _client = _task = _wrapper = None
@@ -1,101 +0,0 @@
 """Small MAX Bot API client. Secrets stay in headers; failures never expose response bodies."""
 import logging
 import ssl
 import httpx
 from app.config import Settings
 API_URL = "https://platform-api2.max.ru"
 UPDATE_TYPES = ["bot_started", "message_created", "bot_stopped", "dialog_removed"]
 class _HideRecipient(logging.Filter):
    def filter(self, record: logging.LogRecord) -> bool:
        # httpx INFO normally logs query strings, which include a MAX user_id.
        return "platform-api2.max.ru" not in record.getMessage()
 logging.getLogger("httpx").addFilter(_HideRecipient())
 class MaxApiError(Exception):
    def __init__(self, code: str, *, retryable: bool = False, retry_after: float = 0):
        self.code, self.retryable, self.retry_after = code, retryable, retry_after
        super().__init__(code)
 class MaxClient:
    def __init__(self, settings: Settings, *, transport: httpx.AsyncBaseTransport | None = None):
        context = ssl.create_default_context()
        if settings.max_ca_bundle:
            context.load_verify_locations(cafile=str(settings.max_ca_bundle))
        self.http = httpx.AsyncClient(
            base_url=API_URL,
            headers={"Authorization": settings.max_bot_token.get_secret_value()},
            timeout=httpx.Timeout(5),
            verify=context,
            follow_redirects=False,
            transport=transport,
        )
    async def close(self) -> None:
        await self.http.aclose()
    async def request(self, method: str, path: str, **kwargs) -> dict:
        try:
            response = await self.http.request(method, path, **kwargs)
        except httpx.RequestError:
            raise MaxApiError("transport", retryable=True) from None
        if not response.is_success:
            try:
                delay = min(3600, max(0, float(response.headers.get("Retry-After", "0"))))
            except ValueError:
                delay = 0
            raise MaxApiError(
                f"http_{response.status_code}",
                retryable=response.status_code in (408, 429) or response.status_code >= 500,
                retry_after=delay,
            )
        try:
            data = response.json()
        except ValueError:
            raise MaxApiError("invalid_response", retryable=True) from None
        if not isinstance(data, dict):
            raise MaxApiError("invalid_response", retryable=True)
        if data.get("success") is False:
            raise MaxApiError("rejected")
        return data
    async def send(self, user_id: int, text: str, *, site_url: str, button: str) -> None:
        data = await self.request(
            "POST",
            "/messages",
            params={"user_id": user_id, "disable_link_preview": "true"},
            json={
                "text": text,
                "notify": True,
                "attachments": [
                    {
                        "type": "inline_keyboard",
                        "payload": {"buttons": [[{"type": "link", "text": button, "url": site_url}]]},
                    }
                ],
            },
        )
        if not isinstance(data.get("message"), dict):
            raise MaxApiError("missing_message", retryable=True)
    async def subscribe(self, settings: Settings) -> None:
        data = await self.request(
            "POST",
            "/subscriptions",
            json={
                "url": settings.max_webhook_url,
                "update_types": UPDATE_TYPES,
                "secret": settings.max_webhook_secret.get_secret_value(),
            },
        )
        if data.get("success") is not True:
            raise MaxApiError("subscription_not_confirmed")
@@ -1,56 +0,0 @@
 """Operator commands for a future bot owner. Never runs as part of application startup."""
 import argparse
 import asyncio
 import sys
 from pydantic import ValidationError
 from app.channels.max_client import MaxApiError, MaxClient
 from app.config import Settings
 async def run(command: str) -> None:
    # Validate the same configuration even while the deployed app is still disabled.
    settings = Settings(max_enabled=True)
    client = MaxClient(settings)
    try:
        bot = await client.request("GET", "/me")
        if bot.get("is_bot") is not True:
            raise MaxApiError("not_a_bot")
        if bot.get("username") != settings.max_bot_username:
            raise MaxApiError("bot_username_mismatch")
        if command == "subscribe":
            await client.subscribe(settings)
            print("Webhook MAX зарегистрирован. Проверьте командой status, затем выполните пробное подключение.")
        elif command == "status":
            result = await client.request("GET", "/subscriptions")
            subscriptions = result.get("subscriptions", [])
            configured = any(isinstance(s, dict) and s.get("url") == settings.max_webhook_url for s in subscriptions)
            print("Нужный webhook зарегистрирован." if configured else "Нужный webhook не найден.")
            if not configured:
                raise MaxApiError("webhook_missing")
        else:
            print("Токен принят MAX, имя бота совпадает с настройкой. Подписка не изменялась.")
    finally:
        await client.close()
 def main() -> int:
    parser = argparse.ArgumentParser(description="Подготовка MAX: параметры берутся только из .env/окружения.")
    parser.add_argument("command", choices=("check", "subscribe", "status"))
    args = parser.parse_args()
    try:
        asyncio.run(run(args.command))
    except ValidationError:
        print("Проверьте параметры MAX в .env по app/channels/MAX_SETUP.md.", file=sys.stderr)
        return 1
    except (MaxApiError, OSError) as exc:
        code = exc.code if isinstance(exc, MaxApiError) else "tls_or_file_error"
        print(f"Не удалось выполнить настройку MAX: {code}. Секреты и ответ сервера скрыты.", file=sys.stderr)
        return 1
    return 0
 if __name__ == "__main__":
    raise SystemExit(main())
@@ -14,7 +14,7 @@ ROOT_DIR = Path(__file__).resolve().parent.parent
 class Settings(BaseSettings):
    # Empty values in .env (e.g. `TG_BOT_TOKEN=`) fall back to defaults instead of failing validation.
-    model_config = SettingsConfigDict(env_file=".env", extra="ignore", env_ignore_empty=True, hide_input_in_errors=True)
+    model_config = SettingsConfigDict(env_file=".env", extra="ignore", env_ignore_empty=True)
    # Two separate databases (ADR-003): identity holds direct identifiers, clinical holds pseudonymised data.
    identity_db_url: str = "postgresql+asyncpg://identity_app:identity_app@localhost:5432/identity"
@@ -1,8 +0,0 @@
 connected: "Уведомления подключены. Здесь будут появляться напоминания с сайта. Отключить их можно командой /stop."
 not_connected: "Чтобы получать уведомления, откройте сайт и подключите MAX в настройках уведомлений."
 invalid: "Не удалось подключить уведомления. Создайте новую ссылку на сайте. Если MAX уже подключён к другому аккаунту, сначала отключите прежнюю привязку."
 stopped: "Уведомления отключены. Подключить их снова можно по новой ссылке с сайта."
 help: "Этот бот присылает уведомления. Пройти тесты, посмотреть результаты и продолжить общение можно на сайте. Команда /stop отключает уведомления."
 notification: "На сайте есть напоминание для вас. Откройте личный кабинет, чтобы продолжить."
 completed: "Прохождение теста завершено. Подробности доступны в личном кабинете на сайте."
 open_site: "Открыть сайт"
@@ -42,7 +42,10 @@ def dose_strip_html(grid: h.DoseGrid, start: date | None) -> str:
        f'<span><i style="border:1.5px dashed var(--grey)"></i>ожидается · {c["pending"]}</span>'
        "</div>"
    )
-    return f'<div class="mt-doses" style="grid-template-columns:{cols}">{"".join(cells)}</div>{legend}'
+    return (
        f'<div class="mt-dose-scroll"><div class="mt-doses" style="grid-template-columns:{cols}">'
        f"{''.join(cells)}</div></div>{legend}"
    )
 def _tile(label: str, value: str, hint: str = "", tone: str = "blue") -> str:
@@ -181,7 +184,7 @@ def render(card: PatientCard, today: date | None) -> None:
    main, side = st.columns([1.75, 1], gap="large")
    with main:
-        with st.container(border=True):
+        with st.container(border=True, key="panel-scales"):
            c1, c2 = st.columns(2)
            for col, scale_id, title in ((c1, "phq9", "PHQ-9"), (c2, "pcl5", "PCL-5")):
                fig = charts.scale_figure(card.series, scale_id, title, start)
@@ -191,22 +194,22 @@ def render(card: PatientCard, today: date | None) -> None:
                    else:
                        st.plotly_chart(fig, config=theme.PLOTLY_CONFIG, key=f"chart-{scale_id}")
            st.caption("◇ — внеплановое заполнение (по триггеру правил). Полосы — градации тяжести из config/scales.")
-        with st.container(border=True):
+        with st.container(border=True, key="panel-wellbeing"):
            fig = charts.wellbeing_figure(card.series, start)
            if fig is None:
                st.caption("Ежедневных чек-инов пока нет")
            else:
                st.plotly_chart(fig, config=theme.PLOTLY_CONFIG, key="chart-wellbeing")
                st.caption("Красная зона настроения ≤ 3 (3 дня → внеплановый PHQ-9); пунктир — сон 4 ч.")
-        with st.container(border=True):
+        with st.container(border=True, key="panel-doses"):
            st.html('<div class="mt-panel-title">Календарь приёма</div>')
            st.html(dose_strip_html(grid, start))
    with side:
-        with st.container(border=True):
+        with st.container(border=True, key="panel-alerts"):
            _alerts_feed(card.alerts, today)
-        with st.container(border=True):
+        with st.container(border=True, key="panel-summary"):
            _summary(card.summary)
-        with st.container(border=True):
+        with st.container(border=True, key="panel-safety"):
            _safety_plan(card.safety_plan)
-        with st.container(border=True):
+        with st.container(border=True, key="panel-prescriptions"):
            _prescriptions(card)
@@ -51,7 +51,7 @@ def render_playback_panel(persona: dict[str, Any]) -> None:
    token = persona["token"]
    scenario, source = w.scenario_for(persona)
    state = w.playback_state(token)
-    st.subheader("🎬 Сценарий демо")
+    st.subheader("Сценарий демо")
    _scenario_source_controls(persona, source)
    if scenario.errors:
        with st.expander(f"⚠️ Замечания к сценарию: {len(scenario.errors)}", expanded=not scenario.days):
@@ -368,10 +368,9 @@ def render_doctor_panel(highlight_token: str | None, *, key: str = "doc") -> Non
    ]
    for a in fresh_acute[:1]:
        st.markdown(
-            "<div style='background:#c62828;color:#fff;padding:18px 20px;border-radius:12px;"
+            "<div class='mt-banner t-red mt-console-alert'><div>"
            "font-size:1.35rem;font-weight:700;margin-bottom:8px'>"
            f"🚨 ОСТРЫЙ АЛЕРТ · {_escape(a.get('patient_name', ''))} · {_fmt_ts(a.get('ts'))}<br>"
-            f"<span style='font-size:1.05rem;font-weight:500'>{_escape(a.get('reason', ''))}</span></div>",
+            f"<div class='mt-sub'>{_escape(a.get('reason', ''))}</div></div></div>",
            unsafe_allow_html=True,
        )
        c1, c2 = st.columns(2)
@@ -68,7 +68,7 @@ def _reset() -> None:
 def _result(res: ConnectPatientOut, name: str) -> None:
    link = h.absolute_link(res.deep_link, os.environ.get("DASHBOARD_PUBLIC_URL", "http://localhost:8501"))
-    with st.container(border=True):
+    with st.container(border=True, key="panel-connect-result"):
        st.html(
            f'<div class="mt-kicker">Пациент подключён · {escape(name)}</div>'
            '<div class="mt-sub" style="margin:4px 0 10px">Покажите QR пациенту или продиктуйте код — бот спросит '
@@ -108,7 +108,7 @@ def main() -> None:
    st.button("Заполнить демо-данными (Андрей)", icon=":material/auto_fix_high:", on_click=_fill_demo, args=(today,))
    left, right = st.columns(2, gap="large")
-    with left, st.container(border=True):
+    with left, st.container(border=True, key="panel-connect-person"):
        st.html('<div class="mt-panel-title">Пациент</div>')
        st.text_input("Имя и инициал фамилии", key="cp_name", placeholder="Андрей С.", help="Без полного ФИО")
        a, b = st.columns(2)
@@ -128,7 +128,7 @@ def main() -> None:
            key="cp_modules",
            format_func=lambda m: h.MODULE_LABELS[m],
        )
-    with right, st.container(border=True):
+    with right, st.container(border=True, key="panel-connect-prescription"):
        st.html('<div class="mt-panel-title">Назначение</div>')
        d1, d2 = st.columns([1.4, 1])
        with d1:
@@ -14,21 +14,31 @@ sys.path.insert(0, str(Path(__file__).resolve().parents[1]))
 from console import widgets as w  # noqa: E402
 from console.playback_ui import render_playback_panel  # noqa: E402
 from dashboard import theme  # noqa: E402
 from dashboard.components import ui  # noqa: E402
 st.set_page_config(page_title="Демо-консоль", page_icon="🎬", layout="wide")
 st.html(theme.CSS)
 st.html(
    ui.page_header(
        "Демо-консоль",
        "Чат пациента и сценарий сопровождения. Прототип на синтетических данных.",
        kicker="Демонстрация",
    )
 )
 persona = w.select_persona()
 w.render_connect_hero()
 w.show_flash()
 st.sidebar.caption(f"API: {w.get_api().base_url}")
-st.title("Демо-консоль")
+with st.container(border=True, key="panel-console-clock"):
 st.caption("Прототип на синтетических данных. Время — виртуальные демо-часы (ADR-005).")
    w.render_clock_bar(persona, key="console-clock")
 st.divider()
 chat_col, play_col = st.columns([1.05, 1], gap="large")
-with chat_col:
+with chat_col, st.container(border=True, key="panel-console-chat"):
-    st.subheader(f"💬 Чат пациента — {persona.get('display_name') or persona['token']}")
+    st.subheader(f"Чат пациента — {persona.get('display_name') or persona['token']}")
    w.render_chat(persona["token"], height=560, key="console-chat")
-with play_col:
+with play_col, st.container(border=True, key="panel-console-scenario"):
    render_playback_panel(persona)
@@ -15,12 +15,12 @@ sys.path.insert(0, str(Path(__file__).resolve().parents[1]))
 from console import widgets as w  # noqa: E402
 from dashboard import theme  # noqa: E402
 from dashboard.components import ui  # noqa: E402
 st.set_page_config(page_title="Сплит-экран", page_icon="🖥️", layout="wide", initial_sidebar_state="collapsed")
-st.markdown(
+st.html(theme.CSS)
-    "<style>.block-container{padding-top:1.2rem;max-width:100%} "
+st.html(ui.page_header("Сплит-экран", "Пациент и врач: сопровождение в реальном времени.", kicker="Демонстрация"))
    "[data-testid='stMarkdownContainer'] p, [data-testid='stMarkdownContainer'] li{font-size:1.08rem}</style>",
    unsafe_allow_html=True,
 )
 persona = w.select_persona()
 w.show_flash()
@@ -44,15 +44,15 @@ if clicked and nxt is not None:
    st.rerun()
 left, right = st.columns([1.1, 1], gap="large")
-with left:
+with left, st.container(border=True, key="panel-split-patient"):
    url = w.patient_web_url()
    if url:
-        st.markdown(f"#### 📱 Пациент — {persona.get('display_name') or token}")
+        st.markdown(f"#### Пациент — {persona.get('display_name') or token}")
        st.iframe(url, height=760)
        st.caption(f"Веб-приложение пациента: {url}")
    else:
-        st.markdown(f"#### 💬 Пациент — {persona.get('display_name') or token}")
+        st.markdown(f"#### Пациент — {persona.get('display_name') or token}")
        w.render_chat(token, height=600, key="split-chat")
-with right:
+with right, st.container(border=True, key="panel-split-doctor"):
-    st.markdown("#### 🩺 Кабинет врача — д-р Смирнова Е. А.")
+    st.markdown("#### Кабинет врача — д-р Смирнова Е. А.")
    w.polled_doctor_panel(token, key="split-doc")
@@ -138,8 +138,8 @@ div[class*="st-key-prow-"] {{ border-top:1px solid var(--line); padding:18px 0 4
 .mt-empty p {{ font-size:.85rem; margin:8px 0 0; }}
 /* ---------- chips, badges, bars ---------- */
-.mt-chip {{ display:inline-block; font-size:.72rem; padding: 1px 8px; border-radius: 999px; margin-right: 4px;
+.mt-chip {{ display:inline-block; font-size:.72rem; padding: 1px 8px; border-radius: 5px; margin-right: 4px;
-  background: var(--blue-tint); color: var(--blue-ink); font-weight: 500; }}
+  background: #edf3ee; color: #38634b; font-weight: 500; }}
 .mt-badge {{ display:inline-flex; align-items:center; gap:6px; font-size:.7rem; font-weight:550; padding: 5px 8px;
  border-radius: 5px; white-space: normal; }}
 .mt-badge.t-red {{ background: var(--red-tint); color: var(--red-ink); }}
@@ -166,7 +166,7 @@ div[class*="st-key-prow-"] {{ border-top:1px solid var(--line); padding:18px 0 4
 .mt-banner b {{ color: inherit; }}
 .mt-pulse {{ width: 12px; height: 12px; border-radius: 50%; background: var(--red); margin-top: 5px; flex: none;
  box-shadow: 0 0 0 4px #faeeee; }}
-.mt-panel-title {{ font-size: .8rem; text-transform: uppercase; letter-spacing: .07em; font-weight: 650;
+.mt-panel-title {{ font-size: .82rem; text-transform: uppercase; letter-spacing: .03em; font-weight: 550;
  color: var(--ink-3); margin: 2px 0 8px; }}
 .mt-alert {{ border-left: 4px solid var(--grey); padding: 4px 0 4px 12px; }}
 .mt-alert.t-red {{ border-left-color: var(--red); }}
@@ -175,9 +175,9 @@ div[class*="st-key-prow-"] {{ border-top:1px solid var(--line); padding:18px 0 4
 .mt-alert .when {{ color: var(--ink-3); font-size: .78rem; }}
 .mt-alert .why {{ color: var(--ink); font-weight: 600; font-size: .92rem; margin: 2px 0; }}
 .mt-alert.acked .why {{ color: var(--ink-3); font-weight: 500; }}
-.mt-summary {{ background: var(--blue-tint); border-radius: 12px; padding: 14px 16px; color: var(--ink);
+.mt-summary {{ background: #f4f6f2; border:1px solid var(--line); border-radius: 12px; padding: 14px 16px;
-  line-height: 1.5; font-size: .93rem; }}
+  color: var(--ink); line-height: 1.5; font-size: .93rem; }}
-.mt-summary .disc {{ color: var(--blue-ink); font-size: .76rem; margin-top: 8px; }}
+.mt-summary .disc {{ color: var(--ink-2); font-size: .76rem; margin-top: 8px; }}
 .mt-plan ol {{ margin: 0; padding-left: 1.2rem; }}
 .mt-plan li {{ margin: 3px 0; color: var(--ink); font-size: .9rem; }}
@@ -195,6 +195,21 @@ div[class*="st-key-prow-"] {{ border-top:1px solid var(--line); padding:18px 0 4
 .mt-legend i {{ display:inline-block; width: 12px; height: 12px; border-radius: 3px; margin-right: 5px;
  vertical-align: -1px; }}
 /* ---------- internal pages ---------- */
 div[class*="st-key-panel-"] {{ background:var(--surface); border:1px solid var(--line); border-radius:12px;
  padding:20px; }}
 [data-testid="stExpander"] {{ background:var(--surface); border-color:var(--line); border-radius:12px; }}
 [data-testid="stChatMessage"] {{ background:#f4f6f2; border:1px solid var(--line); border-radius:12px; }}
 [data-testid="stChatInput"] {{ background:var(--surface); border:1px solid var(--line); border-radius:8px; }}
 [data-testid="stNumberInputContainer"], [data-testid="stDateInput"] input {{
  background:var(--surface); color:var(--ink); border-color:var(--line); border-radius:8px; }}
 [data-testid="stApp"] [data-variant="pills"][data-selected] {{ background:#edf3ee; color:#285e4e;
  border-color:#b4c6ba; }}
 .mt-console-alert {{ font-size:1.1rem; font-weight:600; }}
 .mt-console-alert .mt-sub {{ color:var(--red-ink); font-weight:400; }}
 .mt-dose-scroll {{ overflow-x:auto; padding-bottom:4px; }}
 .mt-doses {{ min-width:max-content; }}
 /* ---------- connect result ---------- */
 .mt-code {{ font-size: 2.4rem; font-weight: 700; letter-spacing: .12em; color: var(--ink);
  font-variant-numeric: tabular-nums; }}
@@ -222,6 +237,8 @@ div[class*="st-key-prow-"] {{ border-top:1px solid var(--line); padding:18px 0 4
  .mt-mobile-label {{ display:block; color:var(--ink-3); font-size:.68rem; margin-bottom:5px; }}
  .mt-row-details {{ grid-template-columns:1fr; gap:12px; }}
  .mt-list-footer {{ flex-wrap:wrap; }}
  .mt-head .mt-side {{ text-align:left; }}
  div[class*="st-key-panel-"] {{ padding:16px; }}
  .mt-tip:hover::after, .mt-tip:focus-visible::after {{ display:none; }}
 }}
@media (prefers-reduced-motion: reduce) {{
@@ -1,21 +0,0 @@
 """Startup validation errors must not print configuration credentials."""
 import pytest
 from pydantic import ValidationError
 from app.config import Settings
 def test_incomplete_max_configuration_does_not_expose_token():
    with pytest.raises(ValidationError) as error:
        Settings(_env_file=None, max_enabled=True, max_bot_token="SYNTHETIC_SECRET")
    message = str(error.value)
    assert "MAX_BOT_USERNAME" in message
    assert "SYNTHETIC_SECRET" not in message and "input_value" not in message
 def test_invalid_field_does_not_expose_accidentally_pasted_secret():
    with pytest.raises(ValidationError) as error:
        Settings(_env_file=None, max_enabled="SYNTHETIC_SECRET")
    assert "max_enabled" in str(error.value)
    assert "SYNTHETIC_SECRET" not in str(error.value)
@@ -1,281 +0,0 @@
 """End-to-end server-only MAX flow, real SQLite transactions and mocked network."""
 from datetime import timedelta
 from unittest.mock import AsyncMock
 from urllib.parse import parse_qs, urlsplit
 import pytest
 from httpx import ASGITransport, AsyncClient
 from sqlalchemy import select
 from app.channels import max_bot
 from app.channels.max_client import MaxApiError
 from app.config import get_settings
 from app.core import clock
 from app.db import repo, session
 from app.db.bootstrap import init_db
 from app.db.clinical import ScaleResult
 from app.db.intake import QuestionnaireRecord
 from app.db.max_notifications import MaxBinding, MaxDelivery, MaxReceipt
 from app.dialog.contracts import Reply
 from app.integrations import max_store as store
 from app.integrations.base import MemoryOutbox, integrations
 from app.main import app
 TOKEN = "synthetic-patient"
 SECRET = "synthetic-webhook-secret-" * 2
@pytest.fixture(autouse=True)
 async def database(monkeypatch):
    for key, value in {
        "MAX_ENABLED": "true",
        "MAX_BOT_TOKEN": "fake-token",
        "MAX_BOT_USERNAME": "test_bot",
        "MAX_WEBHOOK_SECRET": SECRET,
        "MAX_WEBHOOK_URL": "https://api.example.org/api/v1/webhooks/max",
        "MAX_SITE_URL": "https://example.org",
    }.items():
        monkeypatch.setenv(key, value)
    get_settings.cache_clear()
    max_bot.texts.cache_clear()
    await session.configure(identity_url="sqlite+aiosqlite:///:memory:", clinical_url="sqlite+aiosqlite:///:memory:")
    await init_db()
    async with session.get_clinical_session() as s:
        await repo.upsert_profile(s, token=TOKEN, doctor_id="")
        await repo.set_dialog_state(
            s, token=TOKEN, state="idle", data={"consent": True, "adult": True}, now=clock.now()
        )
    yield
    await max_bot.stop()
    await session.configure()
    get_settings.cache_clear()
 def event(kind="bot_started", text="", uid=100, *, stamp=1000):
    user = {"user_id": uid, "is_bot": False, "first_name": "Synthetic"}
    if kind == "message_created":
        return {
            "update_type": kind,
            "timestamp": stamp,
            "message": {
                "sender": user,
                "recipient": {"chat_type": "dialog", "chat_id": 123},
                "body": {"mid": f"mid-{stamp}", "text": text},
            },
        }
    return {"update_type": kind, "timestamp": stamp, "user": user, "chat_id": 123, "payload": text}
 async def connect():
    async with session.get_identity_session() as s:
        code, _ = await store.issue_code(s, TOKEN, clock.now(), 600)
    await max_bot.handle_update(event(text=code))
    return code
 async def test_http_connect_webhook_duplicate_notification_and_stop():
    async with AsyncClient(transport=ASGITransport(app=app), base_url="http://test") as client:
        auth = {"Authorization": f"Bearer {TOKEN}"}
        linked = await client.post("/api/v1/me/notifications/max/link", headers=auth, json={"consent": True})
        code = parse_qs(urlsplit(linked.json()["url"]).query)["start"][0]
        headers = {"X-Max-Bot-Api-Secret": SECRET}
        for _ in range(2):
            assert (
                await client.post("/api/v1/webhooks/max", headers=headers, json=event(text=code))
            ).status_code == 200
        assert (await client.get("/api/v1/me/notifications/max", headers=auth)).json()["connected"]
        async with session.get_identity_session() as s:
            assert len((await s.scalars(select(MaxReceipt))).all()) == 1
            assert len((await s.scalars(select(MaxDelivery))).all()) == 1
        sender = AsyncMock()
        assert await max_bot.deliver_one(sender)
        assert sender.send.call_args.args == (100, max_bot.texts().connected)
        await client.post("/api/v1/webhooks/max", headers=headers, json=event("message_created", "/stop", stamp=2000))
        assert not (await client.get("/api/v1/me/notifications/max", headers=auth)).json()["connected"]
 async def test_unbound_start_help_and_invalid_code_are_generic():
    for e in (event(), event("message_created", "private patient text", stamp=2000), event(text="expired", stamp=3000)):
        await max_bot.handle_update(e)
    async with session.get_identity_session() as s:
        rows = (await s.scalars(select(MaxDelivery))).all()
        assert {r.kind for r in rows} == {"not_connected", "help", "invalid"}
        assert all(r.token is None for r in rows)
        assert not (await s.scalars(select(MaxBinding))).all()
@pytest.mark.parametrize("kind", ["bot_stopped", "dialog_removed", "message_created"])
 async def test_stopping_cancels_pending_confirmation_and_reminders(kind):
    await connect()
    await max_bot.MaxOutbox(MemoryOutbox()).push(TOKEN, [Reply(text="private scheduled question")])
    await max_bot.handle_update(event(kind, "/stop", stamp=2000))
    async with session.get_identity_session() as s:
        assert not (await s.get(MaxBinding, TOKEN)).enabled
        rows = (await s.scalars(select(MaxDelivery).where(MaxDelivery.token == TOKEN))).all()
        assert rows and all(r.state == "cancelled" for r in rows)
    sender = AsyncMock()
    await max_bot.deliver_one(sender)
    assert sender.send.call_count == (1 if kind == "message_created" else 0)
 async def test_private_patient_content_stays_in_fallback_only():
    await connect()
    fallback = MemoryOutbox()
    wrapper = max_bot.MaxOutbox(fallback)
    replies = [Reply(text="SYNTHETIC confidential result 42", kind="question")]
    await wrapper.push(TOKEN, replies)
    await wrapper.push(TOKEN, replies)
    assert fallback.drain(TOKEN) == replies * 2
    async with session.get_identity_session() as s:
        rows = (await s.scalars(select(MaxDelivery).where(MaxDelivery.kind == "notification"))).all()
        assert len(rows) == 1
        assert "confidential" not in repr(rows[0].__dict__)
    sender = AsyncMock()
    while await max_bot.deliver_one(sender):
        pass
    assert any(c.args[1] == max_bot.texts().notification for c in sender.send.call_args_list)
    assert all("confidential" not in c.args[1] and TOKEN not in str(c.kwargs) for c in sender.send.call_args_list)
 async def test_revoked_consent_prevents_binding_and_delivery():
    await connect()
    async with session.get_clinical_session() as s:
        await repo.set_dialog_state(
            s, token=TOKEN, state="idle", data={"consent": False, "adult": True}, now=clock.now()
        )
    sender = AsyncMock()
    await max_bot.deliver_one(sender)
    sender.send.assert_not_called()
    async with session.get_identity_session() as s:
        await store.disconnect(s, TOKEN)
        code, _ = await store.issue_code(s, TOKEN, clock.now(), 600)
    await max_bot.handle_update(event(text=code, stamp=2000))
    async with session.get_identity_session() as s:
        assert not (await s.get(MaxBinding, TOKEN)).enabled
@pytest.mark.parametrize(
    "bad",
    [
        {},
        {"update_type": "other", "timestamp": 1},
        event() | {"timestamp": True},
        event() | {"user": {"user_id": True, "is_bot": False}},
        event() | {"user": {"user_id": 100, "is_bot": True}},
        event() | {"payload": {"wrong": "type"}},
        {"update_type": "message_created", "timestamp": 1, "message": {}},
    ],
 )
 async def test_malformed_or_bot_events_are_ignored(bad):
    await max_bot.handle_update(bad)
    async with session.get_identity_session() as s:
        assert not (await s.scalars(select(MaxReceipt))).all()
 async def test_group_cannot_claim_a_patient_link():
    async with session.get_identity_session() as s:
        code, _ = await store.issue_code(s, TOKEN, clock.now(), 600)
    update = event("message_created", "/start " + code)
    update["message"]["recipient"]["chat_type"] = "chat"
    await max_bot.handle_update(update)
    async with session.get_identity_session() as s:
        assert await s.get(MaxBinding, TOKEN) is None
        assert await store.code_token(s, code, clock.now()) == TOKEN
 async def test_429_respects_retry_deadline_and_then_succeeds(monkeypatch):
    await max_bot.handle_update(event())
    now = clock.now()
    monkeypatch.setattr(clock, "now", lambda: now)
    sender = AsyncMock()
    sender.send.side_effect = MaxApiError("http_429", retryable=True, retry_after=120)
    assert await max_bot.deliver_one(sender)
    async with session.get_identity_session() as s:
        row = (await s.scalars(select(MaxDelivery))).one()
        assert row.state == "queued" and row.next_attempt_at == now + timedelta(seconds=120)
    assert not await max_bot.deliver_one(sender)
    now += timedelta(seconds=121)
    sender.send.side_effect = None
    assert await max_bot.deliver_one(sender)
    async with session.get_identity_session() as s:
        row = (await s.scalars(select(MaxDelivery))).one()
        assert row.state == "sent" and row.attempts == 2
 async def test_permanent_error_does_not_retry():
    await max_bot.handle_update(event())
    sender = AsyncMock()
    sender.send.side_effect = MaxApiError("http_403")
    await max_bot.deliver_one(sender)
    assert not await max_bot.deliver_one(sender)
    async with session.get_identity_session() as s:
        assert (await s.scalars(select(MaxDelivery))).one().state == "failed"
@pytest.mark.parametrize("source", ["scale", "questionnaire"])
 async def test_completed_test_produces_one_neutral_notification(source):
    await connect()
    sender = AsyncMock()
    await max_bot.deliver_one(sender)
    sender.reset_mock()
    async with session.get_clinical_session() as s:
        now = clock.now()
        if source == "scale":
            s.add(ScaleResult(token=TOKEN, ts=now, scale="phq9", total=1, severity="synthetic", complete=True))
        else:
            s.add(
                QuestionnaireRecord(
                    id="synthetic-form",
                    token=TOKEN,
                    kind="intake",
                    version="test",
                    policy_version="test",
                    started_at=now,
                    completed_at=now,
                    day=now.date(),
                    status="complete",
                    answers={},
                    details={},
                )
            )
    for _ in range(2):
        async with session.get_identity_session() as s:
            await store.collect_completed(s, clock.now())
    assert await max_bot.deliver_one(sender)
    assert not await max_bot.deliver_one(sender)
    sender.send.assert_awaited_once_with(
        100, max_bot.texts().completed, site_url="https://example.org", button=max_bot.texts().open_site
    )
 async def test_private_start_command_accepts_issued_code():
    async with session.get_identity_session() as s:
        code, _ = await store.issue_code(s, TOKEN, clock.now(), 600)
    await max_bot.handle_update(event("message_created", "/start " + code))
    async with session.get_identity_session() as s:
        assert (await s.get(MaxBinding, TOKEN)).user_id == 100
 async def test_disabled_lifecycle_never_constructs_client(monkeypatch):
    monkeypatch.setenv("MAX_ENABLED", "false")
    get_settings.cache_clear()
    monkeypatch.setattr(max_bot, "MaxClient", lambda _: pytest.fail("disabled MAX must not create a network client"))
    before = integrations.outbox
    await max_bot.start()
    await max_bot.handle_update(event())
    await max_bot.stop()
    assert integrations.outbox is before
 async def test_lifecycle_wraps_once_restores_and_closes(monkeypatch):
    sender = AsyncMock()
    monkeypatch.setattr(max_bot, "MaxClient", lambda _: sender)
    before = integrations.outbox
    await max_bot.start()
    first = integrations.outbox
    await max_bot.start()
    assert integrations.outbox is first and first.fallback is before
    await max_bot.stop()
    assert integrations.outbox is before
    sender.close.assert_awaited_once()
@@ -1,95 +0,0 @@
 """Wire contract with MAX, using an in-process HTTP fake (no real bot/token)."""
 import json
 import logging
 import httpx
 import pytest
 from app.channels.max_client import API_URL, UPDATE_TYPES, MaxApiError, MaxClient
 from app.config import Settings
 def settings():
    return Settings(
        _env_file=None,
        max_enabled=True,
        max_bot_token="synthetic-secret-token",
        max_bot_username="synthetic_bot",
        max_webhook_secret="synthetic-webhook-secret-" * 2,
        max_webhook_url="https://api.example.org/api/v1/webhooks/max",
        max_site_url="https://example.org",
    )
 async def test_message_wire_contract_and_no_identifiers_in_logs(caplog):
    def handler(request):
        assert str(request.url).startswith(API_URL + "/messages?")
        assert request.url.params["user_id"] == "1234567890123"
        assert "access_token" not in request.url.params
        assert request.headers["Authorization"] == "synthetic-secret-token"
        body = json.loads(request.content)
        assert body["text"] == "neutral reminder" and "format" not in body
        button = body["attachments"][0]["payload"]["buttons"][0][0]
        assert button == {"type": "link", "text": "Open", "url": "https://example.org"}
        return httpx.Response(200, json={"message": {"body": {"mid": "synthetic-id"}}})
    client = MaxClient(settings(), transport=httpx.MockTransport(handler))
    with caplog.at_level(logging.INFO):
        await client.send(1234567890123, "neutral reminder", site_url="https://example.org", button="Open")
    await client.close()
    assert "1234567890123" not in caplog.text and "synthetic-secret-token" not in caplog.text
@pytest.mark.parametrize(
    "status,retry", [(429, True), (500, True), (503, True), (408, True), (401, False), (403, False)]
 )
 async def test_error_codes_are_redacted_and_classified(status, retry):
    client = MaxClient(
        settings(),
        transport=httpx.MockTransport(
            lambda r: httpx.Response(
                status, json={"message": "sensitive provider text"}, headers={"Retry-After": "120"}
            )
        ),
    )
    with pytest.raises(MaxApiError) as error:
        await client.send(100, "neutral", site_url="https://example.org", button="Open")
    assert error.value.retryable is retry and error.value.retry_after == 120
    assert "sensitive" not in str(error.value)
    await client.close()
@pytest.mark.parametrize("body", [{"success": False, "message": "private"}, {}, {"success": True}, []])
 async def test_http_200_is_not_enough_to_mark_delivered(body):
    client = MaxClient(settings(), transport=httpx.MockTransport(lambda r: httpx.Response(200, json=body)))
    with pytest.raises(MaxApiError):
        await client.send(100, "neutral", site_url="https://example.org", button="Open")
    await client.close()
 async def test_timeout_is_retryable_without_request_details():
    def handler(request):
        raise httpx.ReadTimeout("private URL", request=request)
    client = MaxClient(settings(), transport=httpx.MockTransport(handler))
    with pytest.raises(MaxApiError, match="^transport$") as error:
        await client.request("GET", "/me")
    assert error.value.retryable
    await client.close()
 async def test_subscription_includes_secret_and_exact_event_types():
    def handler(request):
        assert request.url.path == "/subscriptions"
        body = json.loads(request.content)
        assert body == {
            "url": settings().max_webhook_url,
            "update_types": UPDATE_TYPES,
            "secret": settings().max_webhook_secret.get_secret_value(),
        }
        return httpx.Response(200, json={"success": True})
    client = MaxClient(settings(), transport=httpx.MockTransport(handler))
    await client.subscribe(settings())
    await client.close()
@@ -1,51 +0,0 @@
 """Operator tools do not send messages or expose credentials."""
 from unittest.mock import AsyncMock
 import pytest
 from app.channels import max_setup
 from app.channels.max_client import MaxApiError
 from app.config import Settings
@pytest.fixture
 def client(monkeypatch):
    settings = Settings(_env_file=None, max_bot_username="test_bot", max_webhook_url="https://api.example.org/hook")
    sender = AsyncMock()
    sender.request.return_value = {"is_bot": True, "username": "test_bot"}
    monkeypatch.setattr(max_setup, "Settings", lambda **kwargs: settings)
    monkeypatch.setattr(max_setup, "MaxClient", lambda cfg: sender)
    return sender
 async def test_check_only_reads_bot_identity(client):
    await max_setup.run("check")
    client.request.assert_awaited_once_with("GET", "/me")
    client.subscribe.assert_not_called()
    client.send.assert_not_called()
    client.close.assert_awaited_once()
 async def test_subscribe_is_explicit_and_checks_bot_first(client):
    await max_setup.run("subscribe")
    client.subscribe.assert_awaited_once()
    client.send.assert_not_called()
 async def test_mismatched_bot_does_not_change_webhooks(client):
    client.request.return_value = {"is_bot": True, "username": "another_bot"}
    with pytest.raises(MaxApiError, match="bot_username_mismatch"):
        await max_setup.run("subscribe")
    client.subscribe.assert_not_called()
    client.close.assert_awaited_once()
 async def test_status_checks_exact_configured_webhook(client):
    client.request.side_effect = [
        {"is_bot": True, "username": "test_bot"},
        {"subscriptions": [{"url": "https://elsewhere.example.org"}]},
    ]
    with pytest.raises(MaxApiError, match="webhook_missing"):
        await max_setup.run("status")
    client.subscribe.assert_not_called()
@@ -1 +1 @@
-<svg xmlns="http://www.w3.org/2000/svg" viewBox="0 0 32 32"><rect width="32" height="32" rx="6" fill="#0a4da2"/><path d="M13 7h6v6h6v6h-6v6h-6v-6H7v-6h6z" fill="#fff"/></svg>
+<svg xmlns="http://www.w3.org/2000/svg" viewBox="0 0 32 32"><rect width="32" height="32" rx="9" fill="#285e4e"/><path d="M16 8v16M8 16h16" stroke="#fff" stroke-width="2" stroke-linecap="round"/></svg>
@@ -3,13 +3,14 @@ import { Link, NavLink } from "react-router-dom";
 import { ru } from "../content/ru";
 import { useDialog } from "../dialog/DialogContext";
 import { useSession } from "../session/SessionContext";
 import { HotlineCard, useHelp } from "./HelpSheet";
 import { Icon, LogoMark, type IconName } from "./Icon";
 /*
- * Layout from docs/mock (series 2).
+ * Shared patient workspace, following the approved doctor dashboard.
 *  phone:   content → «Экстренная помощь» block → bottom tab bar (signed in)
- *  desktop: navy sidebar | content | right rail (optional `aside` + emergency panel)
+ *  desktop: white sidebar | workspace header | content + emergency panel
 *  bare:    one centred column on every width (questionnaires)
 */
@@ -87,6 +88,10 @@ function Sidebar({ signedIn }: { signedIn: boolean }) {
          </li>
        </ul>
      )}
      <div className="sidebar__note">
        <strong>{ru.product.supportTitle}</strong>
        <span>{ru.product.supportText}</span>
      </div>
    </nav>
  );
 }
@@ -122,6 +127,24 @@ function Rail({ aside }: { aside?: ReactNode }) {
  );
 }
 function WorkspaceHeader({ signedIn, bare = false }: { signedIn: boolean; bare?: boolean }) {
  const { session } = useSession();
  return (
    <header className={`workspace${bare ? " workspace--bare" : ""}`}>
      <div className="workspace__brand">
        <LogoMark size={30} />
        <span>{bare ? ru.product.name : signedIn ? ru.product.workspace : ru.nav.signIn}</span>
      </div>
      {signedIn && !bare ? (
        <Link className="workspace__profile" to="/profile">
          <span className="avatar"><Icon name="user" size={18} /></span>
          <span>{session?.displayName || ru.nav.profile}</span>
        </Link>
      ) : <span className="workspace__tag">{ru.product.tagline}</span>}
    </header>
  );
 }
 export function AppShell({
  children,
  signedIn = true,
@@ -144,6 +167,7 @@ export function AppShell({
    return (
      <div className="app app--bare">
        <div className="app__main">
          <WorkspaceHeader signedIn={signedIn} bare />
          <main className="screen" id="main">
            {children}
            {sos && <EmergencyBlock />}
@@ -155,6 +179,7 @@ export function AppShell({
    <div className={`app${signedIn && !focus ? " app--tabs" : ""}`}>
      <Sidebar signedIn={signedIn} />
      <div className="app__main">
        <WorkspaceHeader signedIn={signedIn} />
        <main className="screen" id="main">
          {children}
          {sos && <EmergencyBlock />}
@@ -163,8 +163,8 @@ export function Icon({ name, size = 22, label }: { name: IconName; size?: number
 export function LogoMark({ size = 32 }: { size?: number }) {
  return (
    <svg width={size} height={size} viewBox="0 0 32 32" aria-hidden="true" focusable="false">
-      <rect width="32" height="32" rx="9" fill="var(--c-teal)" />
+      <rect width="32" height="32" rx="9" fill="var(--c-primary)" />
-      <path d="M13 7h6v6h6v6h-6v6h-6v-6H7v-6h6z" fill="#fff" />
+      <path d="M16 8v16M8 16h16" stroke="#fff" strokeWidth="2" strokeLinecap="round" />
    </svg>
  );
 }
@@ -6,6 +6,9 @@ export const ru = {
  product: {
    name: "Сопровождение пациента",
    tagline: "между визитами к врачу",
    workspace: "Личный кабинет",
    supportTitle: "Рядом между визитами",
    supportText: "Наблюдение за самочувствием и поддержка назначенного лечения.",
  },
  nav: {
    today: "Сегодня",
@@ -201,6 +204,7 @@ export const ru = {
    toIntake: "Пройти первичный опрос",
  },
  flow: {
    home: "На главный экран",
    question: (n: number, total: number) => `Вопрос ${n} из ${total}`,
    period: "За последний месяц",
    textPlaceholder: "Напишите несколько слов",
@@ -1,7 +1,3 @@
 import "@fontsource/golos-text/400.css";
 import "@fontsource/golos-text/500.css";
 import "@fontsource/golos-text/600.css";
 import "@fontsource/golos-text/700.css";
 import "./theme/tokens.css";
 import "./theme/global.css";
@@ -265,7 +265,7 @@ function FreeText({
            {skip.label}
          </button>
        ) : (
-          <button type="button" className="btn btn--ghost" onClick={onExit}>
+          <button type="button" className="btn btn--ghost" disabled={busy} onClick={onExit}>
            {ru.flow.exit}
          </button>
        )}
@@ -362,6 +362,7 @@ function SurveyAct({
  press,
  say,
  onPause,
  onHome,
 }: {
  step: Survey;
  stepKey: string;
@@ -369,6 +370,7 @@ function SurveyAct({
  press: (b: DialogButton) => void;
  say: (text: string) => void;
  onPause: (b: DialogButton) => void;
  onHome: () => void;
 }) {
  let answer: ReactNode;
  switch (step.input) {
@@ -381,7 +383,7 @@ function SurveyAct({
      break;
    case "text":
      answer = (
-        <FreeText key={stepKey} skip={step.skip} busy={busy} onSend={say} onSkip={press} onExit={() => undefined} />
+        <FreeText key={stepKey} skip={step.skip} busy={busy} onSend={say} onSkip={press} onExit={onHome} />
      );
      break;
    default:
@@ -522,17 +524,6 @@ export function Flow() {
    navigate("/today", { replace: true });
  }, [step, stepKey, navigate, toast]);
  // Questionnaire: answers are saved on the server per question, and there is no going back to change one.
  // The browser «back» is absorbed by a duplicate history entry of this same screen.
  const testing = step?.kind === "survey" || step?.kind === "choice" || step?.kind === "consent";
  useEffect(() => {
    if (!testing) return;
    window.history.pushState(null, "", window.location.href);
    const stay = () => window.history.pushState(null, "", window.location.href);
    window.addEventListener("popstate", stay);
    return () => window.removeEventListener("popstate", stay);
  }, [testing]);
  const press = (b: DialogButton) => void dialog.send({ type: "button", button: b.data }, b.label);
  // «Продолжить позже»: answers are already saved on the server — pause and go straight home, no confirmation.
  const pause = (b: DialogButton) =>
@@ -588,7 +579,7 @@ export function Flow() {
      ) : item ? (
        <Progress n={item.index} total={item.total} adaptive={item.adaptive} />
      ) : null;
-    const top = <TopBar onBack={testing ? undefined : home}>{progress}</TopBar>;
+    const top = progress ? <TopBar>{progress}</TopBar> : null;
    // Phone: one column. Desktop: question and context on the left, answers and actions on the right.
    let lead: ReactNode;
    let act: ReactNode;
@@ -702,7 +693,7 @@ export function Flow() {
        break;
      case "survey":
        lead = <SurveyLead step={step} catalog={catalog} />;
-        act = <SurveyAct step={step} stepKey={stepKey} busy={dialog.busy} press={press} say={say} onPause={pause} />;
+        act = <SurveyAct step={step} stepKey={stepKey} busy={dialog.busy} press={press} say={say} onPause={pause} onHome={home} />;
        break;
      case "choice":
        lead = <Head title={step.title} lead={step.lead} />;
@@ -725,6 +716,14 @@ export function Flow() {
  return (
    <AppShell focus bare sos={step?.kind !== "crisis"}>
      <nav className="flow-nav" aria-label={ru.flow.home}>
        {/* Leaving does not send an answer or clear pending: Today can reopen this same question.
            Wait for an in-flight answer before leaving so its result has reached the shared dialog. */}
        <button type="button" className="btn btn--ghost btn--auto" disabled={dialog.busy} onClick={home}>
          <Icon name="home" size={20} />
          {ru.flow.home}
        </button>
      </nav>
      {content}
    </AppShell>
  );
@@ -1,45 +1,45 @@
 /*
- * Design tokens — single source of colours, type and spacing (docs/mock, series 2).
+ * Shared visual language with dashboard/theme.py and the approved doctor workspace.
 * Capacitor wraps this same bundle; a React Native port maps these 1:1 to a theme object.
 */
 :root {
  /* Ink & surfaces */
-  --c-navy: #0f2747; /* primary buttons, headings, desktop sidebar */
+  --c-primary: #285e4e; /* primary buttons and active navigation */
-  --c-navy-hover: #0a1d37;
+  --c-primary-hover: #204b3e;
-  --c-navy-soft: #e8eef6;
+  --c-primary-soft: #edf3ee;
-  --c-text: #13294b;
+  --c-text: #213b38;
-  --c-text-2: #4d5d73;
+  --c-text-2: #526660;
-  --c-text-3: #7a889b;
+  --c-text-3: #63736f;
-  --c-page: #ffffff;
+  --c-page: #f6f7f3;
-  --c-page-desk: #f4f7fb; /* desktop canvas behind white panels */
+  --c-page-desk: #f6f7f3; /* desktop canvas behind white panels */
  --c-surface: #ffffff;
-  --c-tile: #f3f7fb; /* soft card fill */
+  --c-tile: #f4f6f2; /* soft card fill */
-  --c-border: #e2e9f1;
+  --c-border: #e1e7e3;
-  --c-border-strong: #c9d4e1;
+  --c-border-strong: #b4c6ba;
-  /* Selection & positive: teal */
+  /* Selection & positive */
-  --c-teal: #17a08f;
+  --c-teal: #527f61;
-  --c-teal-strong: #0e7e71;
+  --c-teal-strong: #38634b;
-  --c-teal-soft: #e3f5f2;
+  --c-teal-soft: #eef4ee;
-  /* Info: blue */
+  /* Informational surfaces */
-  --c-blue: #2f7fdb;
+  --c-blue: #38634b;
-  --c-blue-soft: #eaf3fd;
+  --c-blue-soft: #edf3ee;
  /* Help & crisis: red */
-  --c-red: #e2383b;
+  --c-red: #a83236;
-  --c-red-strong: #c62b2e;
+  --c-red-strong: #a83236;
-  --c-red-soft: #fdeded;
+  --c-red-soft: #faeeee;
-  --c-red-line: #f7d3d3;
+  --c-red-line: #e7cbcb;
  /* Warning */
-  --c-amber: #e69a12;
+  --c-amber: #805714;
-  --c-amber-soft: #fff4dd;
+  --c-amber-soft: #fbf3e4;
-  --c-focus: #2f7fdb;
+  --c-focus: #598d7a;
-  /* Type: Golos Text (OFL), bundled locally — works offline. */
+  /* Same offline system stack as the doctor workspace. */
-  --font: "Golos Text", system-ui, -apple-system, "Segoe UI", sans-serif;
+  --font: -apple-system, BlinkMacSystemFont, "Segoe UI", Arial, sans-serif;
  --fs-12: 0.75rem;
  --fs-13: 0.8125rem;
  --fs-14: 0.875rem;
@@ -63,14 +63,14 @@
  --s-12: 48px;
  /* Radii: tiles > buttons > chips */
-  --r-tile: 16px;
+  --r-tile: 12px;
-  --r-btn: 12px;
+  --r-btn: 8px;
-  --r-chip: 999px;
+  --r-chip: 5px;
  --tap: 52px;
  --nav-h: 64px;
-  --sidebar-w: 232px;
+  --sidebar-w: 228px;
-  --rail-w: 300px;
+  --rail-w: 264px;
  --safe-top: env(safe-area-inset-top, 0px);
  --safe-bottom: env(safe-area-inset-bottom, 0px);
Author	SHA1	Message	Date
Pavel Eliseev	a4ee3d25f0	fix(web): allow returning home from questionnaires CI / ruff · pytest (pull_request) Successful in 2m28s Details Keep the shared dialog and submitted answers while leaving the focus screen. Remove the history trap and wire the text-step home action. Refs #85	2026-10-04 16:14:37 +03:00
Pavel Eliseev	2a2fdb171e	feat(ui): extend minimal doctor design across all screens CI / ruff · pytest (pull_request) Successful in 2m16s Details Refs #85	2026-10-04 16:09:57 +03:00
`@@ -1 +1 @@`
	`<svg xmlns="http://www.w3.org/2000/svg" viewBox="0 0 32 32"><rect width="32" height="32" rx="6" fill="#0a4da2"/><path d="M13 7h6v6h6v6h-6v6h-6v-6H7v-6h6z" fill="#fff"/></svg>`	`<svg xmlns="http://www.w3.org/2000/svg" viewBox="0 0 32 32"><rect width="32" height="32" rx="9" fill="#285e4e"/><path d="M16 8v16M8 16h16" stroke="#fff" stroke-width="2" stroke-linecap="round"/></svg>`