AI Assistant
647abf6578
feat: Интеграция n8n + Redis Pub/Sub + SSE для real-time обработки заявок
🎯 Основные изменения:
Backend:
- ✅ Добавлен SSE endpoint для real-time событий (/api/v1/events/{task_id})
- ✅ Redis Pub/Sub для публикации/подписки на события OCR/Vision
- ✅ Удален aioboto3 из requirements.txt (конфликт зависимостей)
- ✅ Добавлен OCR worker (deprecated, логика перенесена в n8n)
Frontend (React):
- ✅ Автогенерация claim_id и session_id
- ✅ Клиентская конвертация файлов в PDF (JPG/PNG/HEIC/WEBP)
- ✅ Сжатие изображений до 2MB перед конвертацией
- ✅ SSE подписка на события OCR/Vision в Step1Policy
- ✅ Валидация документов (полис vs неподходящий контент)
- ✅ Real-time прогресс загрузки и обработки файлов
- ✅ Интеграция с n8n webhooks для проверки полиса и загрузки файлов
n8n Workflows:
- ✅ Проверка полиса в MySQL + запись в PostgreSQL
- ✅ Загрузка файлов в S3 + OCR + Vision AI
- ✅ Публикация событий в Redis через backend API
- ✅ Валидация документов (распознавание полисов ERV)
Документация:
- 📝 N8N_INTEGRATION.md - интеграция с n8n
- 📝 N8N_SQL_QUERIES.md - SQL запросы для workflows
- 📝 N8N_PDF_COMPRESS.md - сжатие PDF
- 📝 N8N_STIRLING_COMPRESS.md - интеграция Stirling-PDF
Утилиты:
- 🔧 monitor_redis.py/sh - мониторинг Redis Pub/Sub
- 🔧 test_redis_events.sh - тестирование событий
- 🔧 pdfConverter.ts - клиентская конвертация в PDF
Архитектура:
React → n8n webhooks (sync) → MySQL/PostgreSQL/S3
→ n8n workflows (async) → OCR/Vision → Redis Pub/Sub → SSE → React