aiform_prod/docs/CODE4_FIXED.js

// n8n Code node (Run Once) — prepare object for Redis
const items = $input.all();

// 1) Найти первый подходящий элемент с parsed.obj
let main = null;
for (const it of items) {
  const j = it.json;
  if (!j) continue;
  // возможные места
  if (j.parsed && j.parsed.obj) { main = j.parsed.obj; break; }
  if (j.parsed && j.parsed.ok && j.parsed.obj) { main = j.parsed.obj; break; }
  if (j.output) {
    // если output — строка JSON
    try {
      const parsed = JSON.parse(j.output);
      if (parsed && parsed.wizard_plan) { main = parsed; break; }
    } catch (e) {}
  }
  if (j.json && j.json.wizard_plan) { main = j.json; break; }
}
if (!main) {
  // последний шанс: взять items[0].json
  main = items[0] ? (items[0].json || items[0]) : null;
}
if (!main) {
  throw new Error('Не удалось найти parsed.obj в входных данных');
}

// 2) Гарантии структуры
main.wizard_plan = main.wizard_plan || {};
main.coverage_report = main.coverage_report || {};
main.coverage_report.docs_received = main.coverage_report.docs_received || [];
main.wizard_plan.risks = main.wizard_plan.risks || ['DOCS_STATUS_UNKNOWN','EXPECTATION_UNSET'];
main.wizard_plan.deadlines = main.wizard_plan.deadlines || [
  { type: 'USER_UPLOAD_TTL', duration_hours: 48 },
  { type: 'USER_APPROVAL_TTL', duration_hours: 24 }
];

// 3) Добавить примерный документ (state/cities) — если ещё нет такого id
const exampleId = 'example_state_cities_json';
const already = main.coverage_report.docs_received.find(d => d.id === exampleId);
if (!already) {
  const exampleDoc = {
    id: exampleId,
    name: 'state_cities_example.json',
    type: 'application/json',
    uploaded_at: new Date().toISOString(),
    content: {
      state: 'California',
      cities: ['Los Angeles', 'San Francisco', 'San Diego']
    }
  };
  main.coverage_report.docs_received.push(exampleDoc);
}

// 4) session token / key
// Получаем session_token из разных источников (приоритет: Edit Fields11 > Redis Trigger)
const sessionToken = $('Edit Fields11').first().json.session_token 
  || $('Redis Trigger').first().json.message.session_id
  || null;

// Если session_token недоступен, генерируем временный ключ
if (!sessionToken) {
  console.warn('⚠️ session_token не найден, используем временный ключ');
}

// Используем session_token для Redis ключа (claim_id будет сгенерирован позже)
const redisKey = `ocr_events:${sessionToken || 'temp-' + Date.now()}`;

// 5) Возвращаем объект для следующего Redis node
return [{
  json: {
    redis_key: redisKey,
    redis_value: main
  }
}];