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
106 lines
3.1 KiB
Markdown
106 lines
3.1 KiB
Markdown
# Исправление ошибки в Code1: mapDialogHistory
|
||
|
||
## Проблема
|
||
|
||
**Ошибка:**
|
||
```
|
||
Cannot read properties of null (reading 'map') [line 69]
|
||
```
|
||
|
||
**Причина:**
|
||
Функция `mapDialogHistory` получает `null` вместо массива, когда `src.dialog_history` равен `null`.
|
||
|
||
## Исправление
|
||
|
||
### Текущий код (строка 69):
|
||
|
||
```javascript
|
||
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),
|
||
}));
|
||
}
|
||
```
|
||
|
||
### Исправленный код:
|
||
|
||
```javascript
|
||
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),
|
||
}));
|
||
}
|
||
```
|
||
|
||
## Альтернативное решение
|
||
|
||
Можно также исправить в месте вызова:
|
||
|
||
```javascript
|
||
// В функции normalizeOne, строка ~172
|
||
dialog_history: mapDialogHistory(src.dialog_history || []),
|
||
```
|
||
|
||
Но лучше исправить саму функцию, чтобы она была более устойчивой.
|
||
|
||
## Полный исправленный код функции mapDialogHistory
|
||
|
||
```javascript
|
||
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`, если нет строк для агрегации, а не пустой массив `[]`.
|
||
|
||
## Дополнительные проверки
|
||
|
||
Можно также добавить проверки для других функций, которые работают с массивами:
|
||
|
||
```javascript
|
||
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` это критично, т.к. она вызывается первой и падает.
|
||
|
||
|
||
|