### Task: Respond to the user query using the provided context, incorporating inline citations in the format [id] only when the tag includes an explicit id attribute (e.g., ). ### Guidelines: - If you don't know the answer, clearly state that. - If uncertain, ask the user for clarification. - Respond in the same language as the user's query. - If the context is unreadable or of poor quality, inform the user and provide the best possible answer. - If the answer isn't present in the context but you possess the knowledge, explain this to the user and provide the answer using your own understanding. - Only include inline citations using [id] (e.g., [1], [2]) when the tag includes an id attribute. - Do not cite if the tag does not contain an id attribute. - Do not use XML tags in your response. - Ensure citations are concise and directly related to the information provided. ### Example of Citation: If the user asks about a specific topic and the information is found in a source with a provided id attribute, the response should include the citation like in the following example: "According to the study, the proposed method increases efficiency by 20% [1]." ### Output: Provide a clear and direct response to the user's query, including inline citations in the format [id] only when the tag with id attribute is present in the context. or {}).get(\n \"chat_id\", body.get(\"chat_id\", \"web-user\")\n ),\n \"user_email\": (__user__ or {}).get(\"email\", \"anonymous\"),\n }\n\n # -------- 2) Streaming generator --------\n def _gen():\n # Первая строка — статус\n yield \"⏳\"\n\n result_holder = {\"ok\": False, \"text\": \"\", \"err\": \"\"}\n\n def _do_request():\n try:\n if files and files.get(\"data\"):\n r = requests.post(url, data=payload, files=files, timeout=300)\n else:\n # ИСПРАВЛЕНО: Прямая отправка payload без обертки \"body\"\n r = requests.post(url, json=payload, timeout=300)\n\n r.raise_for_status()\n\n try:\n data = r.json()\n\n out_obj = data.get(\"output\")\n result_text = [{"id":"raumai4pro","user_id":"58aa593f-3b9f-4895-b3f1-aeaf7097b14f","name":"RaumAI4Pro","type":"pipe","content":"import requests\nimport base64\nimport io\nimport json\nimport threading\nimport time\nfrom typing import Union, Generator, Iterator\n\n\nclass Pipe:\n def __init__(self):\n self.type = \"manifold\"\n self.id = \"raumai_v4_pro\" # ИСПРАВЛЕНО: Уникальный ID\n self.name = \"RaumAI 4 Pro\" # ИСПРАВЛЕНО: Понятное имя в интерфейсе\n\n def pipe(\n self, body: dict, __user__: dict = None, __metadata__: dict = None\n ) -> Union[str, Generator, Iterator]:\n\n # ИСПРАВЛЕНО: Ваш локальный IP и точный путь вебхука\n url = \"http://10.0.0.20:5678/webhook/raumai04pro\"\n\n messages = body.get(\"messages\", [])\n user_message = \"\"\n files = {}\n\n # -------- 1) Сбор текста и изображений --------\n if messages:\n last_content = messages[-1].get(\"content\", [])\n text_part = last_shown_sec:\n yield f\" -{elapsed}s-\"\n last_shown_sec = elapsed\n\n time.sleep(0.2)\n\n # -------- Ответ с нового абзаца --------\n if result_holder[\"ok\"]:\n yield \"\\n\\n\" + (result_holder[\"text\"] or \"…\")\n else:\n yield \"\\n\\n\" + (result_holder[\"err\"] or \"…\")\n\n return _gen()\n","meta":{"description":"raumai4pro","manifest":{}},"is_active":true,"is_global":false,"updated_at":1775806109,"created_at":1775573732}] на пустой ответ (защита от \"line 1 column 1\")\n if not r.text.strip():\n result_holder[\"err\"] = \"❌ n8n вернул пустой ответ.\"\n return\n\n r.raise_for_status()\n\n try:\n data = r.json()\n output = (\n data.get(\"output\")\n or data.get(\"result\")\n or data.get(\"text\")\n or r.text\n )\n result_holder[\"text\"] = (\n str(output).replace(\"\\\\n\", \"\\n\").lstrip()\n )\n result_holder[\"ok\"] = True\n except Exception:\n # Если n8n вернул текст, а не JSON\n result_holder[\"text\"] = r.text\n result_holder[\"ok\"] = self, body: dict, __user__: dict = None, __metadata__: dict = None\n ) -> Union[str, Generator, Iterator]:\n\n messages = body.get(\"messages\", [])\n if not messages:\n return \"Ошибка: Сообщения не найдены.\"\n\n user_token = (__user__ or {}).get(\"token\")\n user_email = (__user__ or {}).get(\"email\", \"anonymous\")\n last_msg = messages[-1]\n\n user_message = \"\"\n send_files = {} # Для requests.post(files=...)\n attached_files_meta = []\n\n # --- 1) СБОР ТЕКСТА И ИЗОБРАЖЕНИЙ (Base64) ---\n last_content = last_msg.get(\"content\", [])\n if isinstance(last_content, list):\n for item in last_content:\n if not isinstance(item, dict):\n continue\n if item.get(\"type\") == \"text\":\n user_message += item.get(\"text\") or item.get(\"content\") or \"\"\n\n if item.get(\"type\") == \"image_url\":\n str(last_content)\n\n # --- 2) ЗАГРУЗКА СОДЕРЖИМОГО ФАЙЛОВ (.txt, .log, .json) ---\n files_list = last_msg.get(\"files\", [])\n valid_extensions = (\".txt\", \".log\", \".json\")\n\n for file in files_list:\n file_id = file.get(\"id\") or file.get(\"file_id\")\n file_name = file.get(\"name\", \"file.txt\")\n\n attached_files_meta.append({\"id\": file_id, \"name\": file_name})\n\n if file_name.lower().endswith(valid_extensions) and user_token:\n try:\n content_url = f\"{self.valves.OPENWEBUI_API_URL}/api/v1/files/{file_id}/content\"\n response = requests.get(\n content_url,\n headers={\"Authorization\": f\"Bearer {user_token}\"},\n timeout=15,\n )\n if response.status_code == 200:\n mime = (\n так а количество вложений скажите пожалуйста