HTTP‑контроллер
  └─ PollAnswerQuery
       └─ PollAnswerHandler
            ├─ MessageStatusRepository.get_status()   [Redis]
            └─ MessageResultRepository.get_answer()   [Redis]

Стриминг ответа (GET /api/v1/queuing/stream)

HTTP‑контроллер → StreamingResponse(SSE)
  └─ StreamAnswerHandler
       └─ AnswerStreamer.stream()   [подписка на NATS → асинхронный генератор]

Требования

• Python 3.13
• Poetry — управление зависимостями
• Docker и Docker Compose — для Redis, NATS и опционально бэкенда

Переменные окружения

Скопируйте пример и при необходимости отредактируйте:

cp .env.example .env

Запуск

Вариант 1: Локальная разработка (бэкенд на хосте)

Инфраструктура в Docker, приложение через Poetry:

poetry install
cp .env.example .env
# В .env укажите REDIS_URL=redis://localhost:6379/0 и NATS_URL=nats://localhost:4222

# Поднять только Redis и NATS
docker compose up -d redis nats

# Запуск приложения
make run

API будет доступен на http://localhost:8000.

Вариант 2: Всё в Docker

cp .env.example .env
# В .env оставьте REDIS_URL=redis://redis:6379/0 и NATS_URL=nats://nats:4222 (имена сервисов)

docker compose up -d

Поднимаются Redis (порт 6379), NATS (4222, мониторинг 8222) и бэкенд (порт 8000). API: http://localhost:8000.

Полезные команды (Makefile)

Запуск тестов

make test

Проверка типов:

make typecheck

Добавление новой фичи (пример: лимитирование запросов по сессии)

1. Domain — добавить value object RateLimit или обогатить сущность Session, если нужно.
2. Application port — объявить RateLimiter(ABC) в application/common/ports/.
3. Infrastructure adapter — реализовать лимитер через Redis (скользящее окно) в infrastructure/adapters/.
4. IoC — зарегистрировать адаптер в setup/ioc/infrastructure.py.
5. Handler — внедрить и вызывать его в SubmitQuestionHandler.

Другие слои менять не требуется.