Files

AI Assistant 0978e485dc feat: Add claim plan confirmation flow via Redis SSE

Problem:
- After wizard form submission, need to wait for claim data from n8n
- Claim data comes via Redis channel claim:plan:{session_token}
- Need to display confirmation form with claim data

Solution:
1. Backend: Added SSE endpoint /api/v1/claim-plan/{session_token}
   - Subscribes to Redis channel claim:plan:{session_token}
   - Streams claim data from n8n to frontend
   - Handles timeouts and errors gracefully

2. Frontend: Added subscription to claim:plan channel
   - StepWizardPlan: After form submission, subscribes to SSE
   - Waits for claim_plan_ready event
   - Shows loading message while waiting
   - On success: saves claimPlanData and shows confirmation step

3. New component: StepClaimConfirmation
   - Displays claim confirmation form in iframe
   - Receives claimPlanData from parent
   - Generates HTML form (placeholder - should call n8n for real HTML)
   - Handles confirmation/cancellation via postMessage

4. ClaimForm: Added conditional step for confirmation
   - Shows StepClaimConfirmation when showClaimConfirmation=true
   - Step appears after StepWizardPlan
   - Only visible when claimPlanData is available

Flow:
1. User fills wizard form → submits
2. Form data sent to n8n via /api/v1/claims/wizard
3. Frontend subscribes to SSE /api/v1/claim-plan/{session_token}
4. n8n processes data → publishes to Redis claim:plan:{session_token}
5. Backend receives → streams to frontend via SSE
6. Frontend receives → shows StepClaimConfirmation
7. User confirms → proceeds to next step

Files:
- backend/app/api/events.py: Added stream_claim_plan endpoint
- frontend/src/components/form/StepWizardPlan.tsx: Added subscribeToClaimPlan
- frontend/src/components/form/StepClaimConfirmation.tsx: New component
- frontend/src/pages/ClaimForm.tsx: Added confirmation step to steps array

2025-11-24 13:36:14 +03:00

3.1 KiB

Raw Blame History

Исправление ошибки в Code1: mapDialogHistory

Проблема

Ошибка:

Cannot read properties of null (reading 'map') [line 69]

Причина: Функция mapDialogHistory получает null вместо массива, когда src.dialog_history равен null.

Исправление

Текущий код (строка 69):

function mapDialogHistory(h = []) {
  return h.map(m => ({
    id: toNullish(m.id),
    role: toNullish(m.role),
    message: toNullish(m.message),
    message_type: toNullish(m.message_type),
    tg_message_id: toNullish(m.tg_message_id),
    created_at: toNullish(m.created_at),
  }));
}

Исправленный код:

function mapDialogHistory(h = []) {
  // Проверяем, что h не null и является массивом
  if (!h || !Array.isArray(h)) return [];
  return h.map(m => ({
    id: toNullish(m.id),
    role: toNullish(m.role),
    message: toNullish(m.message),
    message_type: toNullish(m.message_type),
    tg_message_id: toNullish(m.tg_message_id),
    created_at: toNullish(m.created_at),
  }));
}

Альтернативное решение

Можно также исправить в месте вызова:

// В функции normalizeOne, строка ~172
dialog_history: mapDialogHistory(src.dialog_history || []),

Но лучше исправить саму функцию, чтобы она была более устойчивой.

Полный исправленный код функции mapDialogHistory

function mapDialogHistory(h = []) {
  // Проверяем, что h не null и является массивом
  if (!h || !Array.isArray(h)) return [];
  return h.map(m => ({
    id: toNullish(m.id),
    role: toNullish(m.role),
    message: toNullish(m.message),
    message_type: toNullish(m.message_type),
    tg_message_id: toNullish(m.tg_message_id),
    created_at: toNullish(m.created_at),
  }));
}

Почему это происходит

Когда SQL запрос в ноде give_data1 возвращает null для dialog_history (если нет записей в clpr_dialog_history_tg), функция mapDialogHistory получает null вместо массива.

PostgreSQL jsonb_agg возвращает null, если нет строк для агрегации, а не пустой массив [].

Дополнительные проверки

Можно также добавить проверки для других функций, которые работают с массивами:

function mapDocuments(docs = []) {
  if (!docs || !Array.isArray(docs)) return [];
  return docs.map(d => ({...}));
}

function mapVisionDocs(vds = []) {
  if (!vds || !Array.isArray(vds)) return [];
  return vds.map(v => ({...}));
}

function mapCombinedDocs(cds = []) {
  if (!cds || !Array.isArray(cds)) return [];
  return cds.map(c => ({...}));
}

Но для mapDialogHistory это критично, т.к. она вызывается первой и падает.

3.1 KiB Raw Blame History Unescape Escape