[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_180":181,"_182":183},"routes/_app.x.$handle.$name",{"_94":93,"_32":45,"_103":84,"_27":104,"_13":14,"_105":-5,"_11":106,"_107":108,"_109":110,"_111":112,"_113":114,"_20":-5,"_115":-5,"_116":-5,"_117":25,"_118":119,"_120":121,"_122":-5,"_123":-5,"_124":125},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":77,"_78":79,"_80":81,"_82":25},"version",19,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","bot.ts","latestPath","fileId","dc1ca102-77bc-11f1-a480-1607ee4eb77e","name","fileType","http","content","// ============================================================\n// Qashqadaryo — Xitoy platformasi: Telegram bot (BULUT versiyasi)\n// Val Town uchun HTTP val. Bu kod val.town saytiga joylanadi.\n//\n// Kerakli muhit o'zgaruvchilari (Environment variables):\n// TELEGRAM_TOKEN - @BotFather bergan token\n// ANTHROPIC_API_KEY - Claude kaliti (sk-ant-...)\n// APP_SECRET - dastur bilan bulut o'rtasidagi maxfiy kalit\n// ALLOWED_IDS - ruxsat etilgan Telegram ID lar (vergul bilan)\n// OPENAI_API_KEY - (ixtiyoriy) ovozli xabarlar uchun Whisper\n// ============================================================\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport Anthropic from \"npm:@anthropic-ai/sdk\";\n\nconst TG = Deno.env.get(\"TELEGRAM_TOKEN\") || \"\";\nconst CLAUDE_KEY = Deno.env.get(\"ANTHROPIC_API_KEY\") || \"\";\nconst APP_SECRET = Deno.env.get(\"APP_SECRET\") || \"\";\nconst OPENAI_KEY = Deno.env.get(\"OPENAI_API_KEY\") || \"\";\nconst ALLOWED = (Deno.env.get(\"ALLOWED_IDS\") || \"\").split(\",\").map((s) => s.trim()).filter(Boolean);\n\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS qx_inbox (id INTEGER PRIMARY KEY AUTOINCREMENT, payload TEXT, created TEXT)`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS qx_kv (k TEXT PRIMARY KEY, v TEXT)`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS qx_log (id INTEGER PRIMARY KEY AUTOINCREMENT, t TEXT, msg TEXT)`);\n\nasync function vlog(msg: string) {\n try {\n await sqlite.execute({ sql: `INSERT INTO qx_log (t, msg) VALUES (?, ?)`, args: [new Date().toISOString(), msg.slice(0, 500)] });\n } catch (_) {}\n}\n\nconst uid = () => Date.now().toString(36) + Math.random().toString(36).slice(2, 6);\nconst today = () => new Date().toISOString().slice(0, 10);\n\n/* ---------- SQLite yordamchilar ---------- */\nfunction rowVal(row: any, i: number, name: string) {\n return Array.isArray(row) ? row[i] : row[name];\n}\nasync function getSnapshot(): Promise {\n const r = await sqlite.execute({ sql: `SELECT v FROM qx_kv WHERE k='snapshot'`, args: [] });\n const empty = { tasks: [], projects: [], trades: [], partners: [], documents: [], problems: [] };\n if (!r.rows.length) return empty;\n try { return { ...empty, ...JSON.parse(rowVal(r.rows[0], 0, \"v\")) }; } catch { return empty; }\n}\nasync function saveSnapshot(snap: any) {\n await sqlite.execute({ sql: `INSERT INTO qx_kv (k, v) VALUES ('snapshot', ?) ON CONFLICT(k) DO UPDATE SET v = excluded.v`, args: [JSON.stringify(snap)] });\n}\n/* Yozuvni bulut bazasiga BEVOSITA qo'llaymiz (onlayn platforma darhol ko'radi) */\nasync function applyToSnapshot(ev: any) {\n const snap = await getSnapshot();\n if (ev.type === \"record\") {\n (snap[ev.key] = snap[ev.key] || []).push(ev.obj);\n } else if (ev.type === \"update\") {\n const list = snap[ev.key] || [];\n const i = list.findIndex((x: any) => x.id === ev.id);\n if (i >= 0) Object.assign(list[i], ev.patch);\n }\n await saveSnapshot(snap);\n}\nasync function pushInbox(payload: any) {\n await sqlite.execute({ sql: `INSERT INTO qx_inbox (payload, created) VALUES (?, ?)`, args: [JSON.stringify(payload), new Date().toISOString()] });\n await applyToSnapshot(payload); // bulut bazasiga ham darhol yoziladi\n}\n\n/* ---------- Telegram ---------- */\nconst tgApi = (method: string, body: any) =>\n fetch(`https://api.telegram.org/bot${TG}/${method}`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(body || {}),\n }).then((r) => r.json());\n\nasync function tgDownload(fileId: string) {\n const info = await tgApi(\"getFile\", { file_id: fileId });\n if (!info.ok) throw new Error(\"Faylni olib bo'lmadi: \" + (info.description || \"\"));\n const r = await fetch(`https://api.telegram.org/file/bot${TG}/${info.result.file_path}`);\n return new Uint8Array(await r.arrayBuffer());\n}\nfunction toB64(buf: Uint8Array) {\n let s = \"\";\n for (let i = 0; i < buf.length; i += 8192) s += String.fromCharCode(...buf.subarray(i, i + 8192));\n return btoa(s);\n}\n\n/* ---------- SAYT INTEGRATSIYASI (investinkashkadarya.uz) ---------- */\nconst SITE = Deno.env.get(\"SITE_API\") || \"https://api.investinkashkadarya.uz\";\nconst SITE_EMAIL = Deno.env.get(\"SITE_EMAIL\") || \"\";\nconst SITE_PASSWORD = Deno.env.get(\"SITE_PASSWORD\") || \"\";\nlet siteCookie = \"\";\nlet siteCookieAt = 0;\n\nasync function siteLogin(): Promise {\n if (!SITE_EMAIL || !SITE_PASSWORD) return false;\n const r = await fetch(SITE + \"/api/auth/login\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ email: SITE_EMAIL, password: SITE_PASSWORD }),\n });\n if (!r.ok) { await vlog(\"Sayt login xatosi: \" + r.status); return false; }\n const setc = r.headers.get(\"set-cookie\") || \"\";\n // barcha cookie'larni yig'amiz\n siteCookie = setc.split(/,(?=[^;]+=[^;]+)/).map((c) => c.split(\";\")[0].trim()).filter(Boolean).join(\"; \");\n siteCookieAt = Date.now();\n return !!siteCookie;\n}\nasync function siteFetch(path: string, init: any = {}): Promise {\n if (!siteCookie || Date.now() - siteCookieAt > 4 * 60 * 1000) await siteLogin();\n init.headers = { ...(init.headers || {}), Cookie: siteCookie };\n let r = await fetch(SITE + path, init);\n if (r.status === 401) { // sessiya tugagan — qayta kiramiz\n await siteLogin();\n init.headers.Cookie = siteCookie;\n r = await fetch(SITE + path, init);\n }\n return r;\n}\nasync function siteCreateCard(f: any) {\n const r = await siteFetch(\"/api/business-cards\", {\n method: \"POST\", headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n companyName: f.companyName || null, personName: f.personName || null,\n position: f.position || null, email: f.email || null, phone: f.phone || null,\n website: f.website || null, address: f.address || null, country: f.country || null,\n notes: [f.notes, f.sector ? \"Soha: \" + f.sector : \"\"].filter(Boolean).join(\" | \") || null,\n }),\n });\n if (!r.ok) throw new Error(\"Sayt kontakt xatosi: \" + r.status + \" \" + (await r.text()).slice(0, 200));\n return r.json();\n}\nasync function siteCreateInvestor(f: any) {\n const r = await siteFetch(\"/api/investors\", {\n method: \"POST\", headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n email: f.email, password: f.password,\n firstName: f.firstName || \"-\", lastName: f.lastName || \"-\",\n companyName: f.companyName, country: f.country || \"China\",\n sector: f.sector || \"other\",\n }),\n });\n if (!r.ok) throw new Error(\"Sayt investor xatosi: \" + r.status + \" \" + (await r.text()).slice(0, 250));\n return r.json();\n}\n\nconst MY_DISTRICT = Deno.env.get(\"MY_DISTRICT\") || \"\";\n\n/* Asosiy saytdan JONLI kontekst (menga biriktirilgan vazifalar + tuman loyihalari) */\nlet ctxCache = \"\", ctxAt = 0;\nasync function siteContext(force = false) {\n if (!force && ctxCache && Date.now() - ctxAt < 60000) return ctxCache;\n const lines: string[] = [\"=== investinkashkadarya.uz — JONLI MA'LUMOT ===\"];\n try {\n const me = await (await siteFetch(\"/api/dashboard/me\")).json();\n lines.push(\"\\n## MENGA BIRIKTIRILGAN VAZIFALAR (\" + (me.pendingTasks || []).length + \")\");\n for (const t of (me.pendingTasks || [])) lines.push(`- [${t.code}] ${t.title} | holat:${t.status} | muddat:${(t.dueDate || \"\").slice(0, 10) || \"-\"}${t.priority ? \" | ustuvorlik:\" + t.priority : \"\"}${t.description ? \" — \" + t.description : \"\"}`);\n lines.push(\"\\n## YAQIN UCHRASHUVLAR (\" + (me.upcomingMeetings || []).length + \")\");\n for (const m of (me.upcomingMeetings || [])) lines.push(`- ${m.title || m.subject || m.code || \"Uchrashuv\"} | ${(m.scheduledAt || m.startAt || m.date || \"\").slice(0, 16)}`);\n if (me.myKpi) lines.push(\"\\n## KPI: \" + JSON.stringify(me.myKpi).slice(0, 300));\n } catch (e: any) { lines.push(\"(vazifalarni olishda xato: \" + e.message + \")\"); }\n try {\n if (MY_DISTRICT) {\n const pr = await (await siteFetch(\"/api/projects?districtId=\" + MY_DISTRICT + \"&limit=100\")).json();\n const items = pr.items || [];\n const cn = items.filter((p: any) => /xitoy|china|китай/i.test(p.country || \"\"));\n lines.push(`\\n## TUMANIM LOYIHALARI (jami ${pr.total}, shundan Xitoy: ${cn.length})`);\n for (const p of items) {\n const nm = (p.name && (p.name.uz || p.name._origText)) || p.code;\n lines.push(`- [${p.code}] ${nm} | ${p.country || \"-\"} | ${p.sectorName || \"-\"} | ${p.totalCost || 0} mln | holat:${p.stage}`);\n }\n }\n } catch (e: any) { lines.push(\"(loyihalarni olishda xato: \" + e.message + \")\"); }\n ctxCache = lines.join(\"\\n\").slice(0, 190000);\n ctxAt = Date.now();\n return ctxCache;\n}\n\n/* ---------- Claude tahlili ---------- */\nconst client = new Anthropic({ apiKey: CLAUDE_KEY });\n\nconst PARSE_SCHEMA = {\n type: \"object\",\n additionalProperties: false,\n required: [\"action\", \"kind\", \"targetId\", \"title\", \"status\", \"progress\", \"district\", \"partnerName\", \"budget\", \"currency\", \"direction\", \"notes\", \"phone\", \"wechat\", \"email\"],\n properties: {\n action: { type: \"string\", enum: [\"add\", \"update\"] },\n kind: { type: \"string\", enum: [\"task\", \"project\", \"trade\", \"partner\", \"document\", \"problem\", \"question\"] },\n targetId: { type: \"string\" },\n title: { type: \"string\" },\n status: { type: \"string\", enum: [\"todo\", \"done\", \"new\", \"nego\", \"appr\", \"prog\", \"stop\", \"none\"] },\n progress: { type: \"number\" },\n district: { type: \"string\" },\n partnerName: { type: \"string\" },\n budget: { type: \"number\" },\n currency: { type: \"string\", enum: [\"USD\", \"CNY\", \"UZS\", \"EUR\", \"NONE\"] },\n direction: { type: \"string\", enum: [\"import\", \"export\", \"none\"] },\n notes: { type: \"string\" },\n phone: { type: \"string\" },\n wechat: { type: \"string\" },\n email: { type: \"string\" },\n },\n};\n\nconst PARSE_SYSTEM = `Sen Qashqadaryo viloyati - Xitoy yo'nalishi bo'yicha loyihalarni boshqarish platformasining yordamchisisan.\nFoydalanuvchi Telegram orqali o'zbek (ba'zan rus yoki xitoy) tilida xabar yuboradi. Senga platformadagi mavjud yozuvlar ro'yxati (ID bilan) ham beriladi.\n\nVazifang: xabar (1) SAVOL/so'rovmi, (2) YANGI yozuv qo'shishmi yoki (3) MAVJUD yozuvni yangilashmi - aniqlash.\n\nSAVOL (juda muhim, birinchi tekshir): agar foydalanuvchi biror narsa SO'RAYOTGAN, tahlil, hisobot, maslahat, tushuntirish yoki umumiy javob kutayotgan bo'lsa (masalan \"qancha loyiha bor?\", \"eng katta investor kim?\", \"menga bugun nima qilishim kerak?\", \"bu haqda nima deb o'ylaysan?\", \"tarjima qil\", \"hisobla\", savol belgisi bilan tugagan yoki so'roq so'zlar bilan boshlangan) -> kind=question. Bu holatda boshqa maydonlar bo'sh bo'lsin. Faqat aniq ma'lumot QO'SHISH/YANGILASH bo'lmagan hamma narsa question.\n\nUPDATE belgilari: \"...foizga yetdi\" -> progress; \"tasdiqlandi, imzolandi\" -> status=appr/done; \"boshlandi\" -> prog; \"to'xtadi\" -> stop; \"tugadi\" -> done. Ro'yxatdan nomi o'xshash yozuvni top, ID sini targetId ga yoz. Topilmasa action=add.\n\nADD qoidalari: \"qildim/bajardim\" -> task done; \"qilish kerak/reja\" -> task todo; zavod/investitsiya -> project; import/eksport/konteyner -> trade; yangi kompaniya/kontakt -> partner; shartnoma/hujjat -> document; aniqmas -> task todo.\n\nSHERIK kontaktlari: telefon -> phone, WeChat/veychat -> wechat, email -> email maydonlariga yoz. Mavjud sherik haqida telefon/wechat/email kelsa -> action=update, kind=partner, targetId=SHERIKLAR ro'yxatidagi IDsi.\n\nRASM kelsa (vizitka, shartnoma surati, eslatma): barcha matnni o'qi (xitoy/rus/ingliz bo'lishi mumkin). Vizitka -> partner, title=kompaniya nomi, notes ga ism/telefon/email/shahar. Shartnoma -> document. Eslatma -> task.\n\nMUAMMO (juda muhim): \"muammo, to'siq, kechikish, mushkulot, ishlamayapti, rad etildi, yetishmayapti, kelishmovchilik\" kabi salbiy holat -> kind=problem, action=add.\n- title ga muammoning qisqa bayoni.\n- targetId ga bu muammo QAYSI loyiha/bitimga tegishli bo'lsa, o'sha LOYIHA IDsini yoz (ro'yxatdan top). Topilmasa bo'sh qoldir.\n- \"muammo hal bo'ldi/yechildi\" -> action=update, kind=problem, targetId=MUAMMOLAR ro'yxatidagi muammo IDsi, status=done.\n\nBOG'LASH: hujjat (kind=document) aniq bir loyihaga tegishli bo'lsa, targetId ga o'sha loyiha IDsini yoz.\n\nHUJJAT MAZMUNI: kind=document bo'lsa, notes maydoniga hujjatning MAZMUNINI 2-4 jumlada yoz: tomonlar kimlar, summa qancha, muddatlar, asosiy shartlar. Bu juda muhim - foydalanuvchi hujjat nimaligini shu yerdan biladi.\n\ntitle doim qisqa o'zbekcha. Tegishli bo'lmagan maydonlarga bo'sh satr, 0, -1 yoki none/NONE yoz.`;\n\nfunction catalogText(snap: any) {\n const lines: string[] = [];\n const add = (label: string, arr: any[], f: (x: any) => string) => {\n lines.push(\"## \" + label);\n (arr || []).slice(-40).forEach((x) => lines.push(f(x)));\n };\n add(\"LOYIHALAR\", snap.projects, (x) => `${x.id} | ${x.name} | holat:${x.status} | ${x.progress || 0}%`);\n add(\"SAVDO BITIMLARI\", snap.trades, (x) => `${x.id} | ${x.name} | ${x.type} | holat:${x.status}`);\n add(\"SHERIKLAR\", snap.partners, (x) => `${x.id} | ${x.nameUz} | tel:${x.phone || \"-\"} | wechat:${x.wechat || \"-\"}`);\n add(\"HUJJATLAR\", snap.documents, (x) => `${x.id} | ${x.title} | ${x.status}`);\n add(\"KUNLIK ISHLAR (rejadagi)\", (snap.tasks || []).filter((t: any) => t.status === \"todo\"), (x) => `${x.id} | ${x.text}`);\n add(\"MUAMMOLAR (ochiq)\", (snap.problems || []).filter((p: any) => p.status === \"open\"), (x) => `${x.id} | ${x.text} | loyiha_id:${x.linkedId || \"-\"}`);\n return lines.join(\"\\n\");\n}\n\nasync function parseContent(blocks: any[]) {\n const snap = await getSnapshot();\n const resp = await client.messages.create({\n model: \"claude-sonnet-5\", // tezlik uchun\n max_tokens: 1200,\n thinking: { type: \"disabled\" },\n system: PARSE_SYSTEM,\n output_config: { format: { type: \"json_schema\", schema: PARSE_SCHEMA } },\n messages: [{\n role: \"user\",\n content: [...blocks, { type: \"text\", text: `MAVJUD YOZUVLAR:\\n${catalogText(snap)}\\n\\nYuqoridagi xabarni (yoki rasmni) tahlil qilib, JSON qaytir.` }],\n }],\n } as any);\n const tb: any = (resp.content as any[]).find((b) => b.type === \"text\");\n return JSON.parse(tb.text);\n}\n\n/* Saytga yozish uchun kontakt maydonlarini ajratish (matn yoki rasmdan) */\nconst CARD_SCHEMA = {\n type: \"object\", additionalProperties: false,\n required: [\"companyName\", \"personName\", \"position\", \"email\", \"phone\", \"website\", \"address\", \"country\", \"sector\", \"notes\"],\n properties: {\n companyName: { type: \"string\" }, personName: { type: \"string\" }, position: { type: \"string\" },\n email: { type: \"string\" }, phone: { type: \"string\" }, website: { type: \"string\" },\n address: { type: \"string\" }, country: { type: \"string\", description: \"Davlat, aniqlanmasa 'China'\" },\n sector: { type: \"string\", enum: [\"agriculture\", \"manufacturing\", \"mining\", \"energy\", \"construction\", \"it_tech\", \"finance\", \"retail\", \"transport\", \"tourism\", \"healthcare\", \"education\", \"pharma\", \"textile\", \"food_processing\", \"other\"] },\n notes: { type: \"string\" },\n },\n};\nasync function extractCard(blocks: any[]) {\n const resp = await client.messages.create({\n model: \"claude-sonnet-5\", max_tokens: 800, thinking: { type: \"disabled\" },\n system: \"Berilgan matn yoki vizitka rasmidan kompaniya kontakt ma'lumotlarini ajrat. Barcha matnni o'qi (xitoy/rus/ingliz). Topilmagan maydonga bo'sh satr. country aniqlanmasa 'China'. sector ni ro'yxatdan tanla.\",\n output_config: { format: { type: \"json_schema\", schema: CARD_SCHEMA } },\n messages: [{ role: \"user\", content: blocks }],\n } as any);\n return JSON.parse((resp.content as any[]).find((b) => b.type === \"text\").text);\n}\nfunction randPass() { return \"Inv\" + Math.random().toString(36).slice(2, 10) + \"9!\"; }\n\n/* Har qanday savolga Claude Fable 5 (eng kuchli model) orqali javob berish */\nconst ANSWER_SYSTEM = `ROLI: Sen — Qashqadaryo viloyati investitsiyalar, sanoat va savdo yo'nalishidagi professional AI yordamchisan (investitsiya kotibiyati mudiri uchun shaxsiy yordamchi).\nAsosiy vazifalaring: xorijiy investitsiyalarni jalb qilish; investorlar bilan muzokara materiallari; rasmiy xatlar, memorandumlar, investitsiya bitimlari, taqdimotlar; texnik-iqtisodiy asos (TIA), biznes-reja va loyiha konsepsiyalari; forum va B2B uchrashuvlar; Xitoy, Rossiya, Yaqin Sharq bilan hamkorlik hujjatlari.\n\nASOSIY MA'LUMOT MANBAI — investinkashkadarya.uz sayti (quyida jonli beriladi). Loyiha/vazifa/investor haqidagi savollarga SHU sayt ma'lumotlari asosida, aniq raqam va kodlar bilan javob ber. Ma'lumotni o'ylab topma.\n\nISH USLUBI:\n— Rasmiy va diplomatik uslubda yoz; aniq, professional, investorga tushunarli.\n— Hujjatlarni sarlavha, bo'lim va punktlarga ajrat; kerak bo'lsa jadval ishlat.\n— Amaliy va real yechimlar taklif qil; xalqaro biznes standartlariga mos yoz.\n— Qisqa, lekin mazmunli va ishonchli. Ortiqcha muqaddima yozma.\n— Hokim, vazirlik va investorlar uchun uslubni moslashtir.\n\nTIL: Foydalanuvchi savoli o'zbek/rus/xitoy/ingliz tilida bo'lishi mumkin. Javobni odatda O'ZBEK tilida ber; agar foydalanuvchi boshqa tilda hujjat/tarjima so'rasa, o'sha tilda (rus/xitoy/ingliz) professional biznes-hukumat uslubida yoz. Xitoycha matnda rasmiy biznes terminologiyasidan foydalan. Sun'iy tarjimadan qoch, ma'noni to'liq saqla.\n\nEKSPERT SOHALARING: sanoat zonalari, energetika, chiqindidan elektr energiyasi, qishloq xo'jaligi, chorvachilik, oziq-ovqat sanoati, logistika, eksport, infratuzilma, mashinasozlik, qurilish materiallari, PPP/BOT loyihalari, Xitoy–O'zbekiston hamkorligi.\n\nINVESTITSIYA LOYIHASI so'ralganda ko'rsat: ROI va investor foydasi; davlat imtiyozlari va preferensiyalar; logistika va eksport; erkin iqtisodiy zona afzalliklari; soliq va bojxona imtiyozlari; elektr/gaz/suv/infratuzilma; amalga oshirish bosqichlari; xavflar va yechimlari.\n\nRASMIY HUJJATLAR (so'ralganda to'liq tayyorla): memorandum, investitsiya bitimi, xizmat shartnomasi, hukumatga murojaat, rasmiy xat, forum taklifi, prezentatsiya matni, commercial offer, feasibility study (TIA), loyiha konsepsiyasi, tender/EPC hujjatlari.\n\nXITOY INVESTORLARI bilan: \"win-win cooperation\" uslubi; \"Belt and Road Initiative\" bilan bog'liqlik; O'zbekistonning strategik joylashuvi; Rossiya/MDH/Markaziy Osiyo bozorlariga chiqish; uzoq muddatli hamkorlik ruhi.\n\nMAQSAD: Qashqadaryo viloyatiga yirik xorijiy investitsiyalarni jalb qilish, xalqaro hamkorlikni kengaytirish va professional davlat-investitsiya hujjatlarini tez, sifatli tayyorlash.\n\nEslatma: bu Telegram — matnni ixcham, sarlavha va punktlar bilan formatla. Umumiy bilim, tarjima yoki hisob-kitob so'ralsa, oddiy professional yordamchi sifatida javob ber.`;\n\nconst REPORT_SYSTEM = `Sen Qashqadaryo viloyati hokimligining Xitoy yo'nalishi bo'yicha rasmiy hisobot tayyorlovchi yordamchisan.\nBerilgan JONLI sayt ma'lumotlari (investinkashkadarya.uz) asosida QUYIDAGI RASMIY SHAKLDA hisobot tuz. Aynan shu tuzilishni saqla, o'zbek tilida:\n\n📋 RASMIY HISOBOT\nQashqadaryo viloyati — Xitoy yo'nalishi\nSana: {bugungi sana}\n\n1️⃣ UMUMIY HOLAT\n— (loyihalar, vazifalar soni va qisqa umumiy baho)\n\n2️⃣ MENGA BIRIKTIRILGAN VAZIFALAR\n— (har birini raqamlab, holati va muddati bilan)\n\n3️⃣ TUMAN LOYIHALARI (XITOY YO'NALISHI)\n— (asosiy loyihalar, holati bilan; ko'p bo'lsa eng muhimlarini)\n\n4️⃣ E'TIBOR TALAB QILADIGAN MASALALAR\n— (muddati yaqin yoki kechikayotgan ishlar, muammolar)\n\n5️⃣ TAVSIYALAR\n— (bugun nimaga e'tibor berish kerak — 2-4 aniq band)\n\nHisobotni tayyorladi: Platforma yordamchisi (Claude)\n\nFaktik bo'l, faqat berilgan ma'lumotdan foydalisan. Emoji va sarlavhalarni saqla.`;\n\nasync function answerWithFable(blocks: any[], report = false) {\n const ctx = await siteContext();\n const sys = (report ? REPORT_SYSTEM : ANSWER_SYSTEM) + \"\\n\\n\" + ctx;\n // 1-urinish: Claude Fable 5 (thinking doim yoniq — parametr berilmaydi)\n try {\n const resp = await client.beta.messages.create({\n model: \"claude-fable-5\",\n max_tokens: 3000,\n output_config: { effort: \"medium\" },\n betas: [\"server-side-fallback-2026-06-01\"],\n fallbacks: [{ model: \"claude-opus-4-8\" }],\n system: sys,\n messages: [{ role: \"user\", content: blocks }],\n } as any);\n return (resp.content as any[]).filter((b) => b.type === \"text\").map((b) => b.text).join(\"\\n\").trim() || \"…\";\n } catch (e: any) {\n await vlog(\"Fable xatosi, Opus'ga o'tildi: \" + e.message);\n // Zaxira: Opus 4.8\n const resp = await client.messages.create({\n model: \"claude-opus-4-8\", max_tokens: 3000, thinking: { type: \"adaptive\" },\n system: sys, messages: [{ role: \"user\", content: blocks }],\n } as any);\n return (resp.content as any[]).filter((b) => b.type === \"text\").map((b) => b.text).join(\"\\n\").trim() || \"…\";\n }\n}\n\n/* ---------- Yozuv yaratish / yangilash ---------- */\nconst KIND_UZ: any = { task: \"Kunlik ish\", project: \"Investitsiya loyihasi\", trade: \"Savdo bitimi\", partner: \"Sherik\", document: \"Hujjat\", problem: \"Muammo ⚠️\" };\nconst SECTION_UZ: any = { task: \"✅ Kunlik ishlar\", project: \"🏭 Loyihalar\", trade: \"🚢 Import/Eksport\", partner: \"🤝 Sheriklar\", document: \"📄 Hujjatlar\", problem: \"⚠️ loyihaning Muammolar ro'yxati\" };\nconst STATUS_UZ: any = { new: \"Yangi\", nego: \"Muzokara\", appr: \"Tasdiqlangan\", prog: \"Jarayonda\", done: \"Yakunlangan\", stop: \"To'xtatilgan\" };\nconst KEY_MAP: any = { task: \"tasks\", project: \"projects\", trade: \"trades\", partner: \"partners\", document: \"documents\", problem: \"problems\" };\n\nfunction recordFromParse(p: any, extraNotes: string) {\n const notes = [p.notes, extraNotes].filter(Boolean).join(\" | \");\n if (p.kind === \"task\") return { key: \"tasks\", obj: { id: uid(), text: p.title, status: p.status === \"done\" ? \"done\" : \"todo\", date: today(), source: \"telegram\", notes } };\n if (p.kind === \"partner\") return { key: \"partners\", obj: { id: uid(), nameUz: p.title, nameZh: \"\", contact: \"\", phone: p.phone || \"\", wechat: p.wechat || \"\", email: p.email || \"\", city: \"\", industry: \"\", notes } };\n if (p.kind === \"problem\") return { key: \"problems\", obj: { id: uid(), linkedId: p.targetId || \"\", text: p.title, status: \"open\", date: today(), source: \"telegram\", notes } };\n if (p.kind === \"document\") return { key: \"documents\", obj: { id: uid(), title: p.title, type: \"other\", projectId: p.targetId || \"\", date: today(), status: \"pending\", notes } };\n const base = { id: uid(), name: p.title, partnerId: \"\", district: p.district || \"\", budget: p.budget || 0, currency: p.currency === \"NONE\" ? \"USD\" : p.currency, status: \"new\", progress: 0, startDate: today(), responsible: \"\", notes };\n if (p.kind === \"trade\") return { key: \"trades\", obj: { ...base, type: p.direction === \"export\" ? \"export\" : \"import\" } };\n return { key: \"projects\", obj: { ...base, type: \"invest\" } };\n}\n\nasync function buildUpdate(p: any) {\n const snap = await getSnapshot();\n const key = KEY_MAP[p.kind];\n const rec = (snap[key] || []).find((x: any) => x.id === p.targetId);\n if (!rec) return null;\n const patch: any = {};\n const changes: string[] = [];\n if (key === \"tasks\") {\n if (p.status === \"done\" || p.status === \"todo\") { patch.status = p.status; changes.push(p.status === \"done\" ? \"bajarildi ✔️\" : \"rejaga qaytarildi\"); }\n } else if (key === \"problems\") {\n if (p.status === \"done\") { patch.status = \"resolved\"; changes.push(\"hal qilindi ✅\"); }\n } else if (key === \"partners\") {\n if (p.phone) { patch.phone = p.phone; changes.push(\"telefon: \" + p.phone); }\n if (p.wechat) { patch.wechat = p.wechat; changes.push(\"WeChat: \" + p.wechat); }\n if (p.email) { patch.email = p.email; changes.push(\"email: \" + p.email); }\n } else if (key === \"documents\") {\n if (p.status === \"done\" || p.status === \"appr\") { patch.status = \"signed\"; changes.push(\"imzolangan\"); }\n else if (p.status === \"prog\" || p.status === \"nego\") { patch.status = \"pending\"; changes.push(\"kutilmoqda\"); }\n } else if (key === \"projects\" || key === \"trades\") {\n if ([\"new\", \"nego\", \"appr\", \"prog\", \"done\", \"stop\"].includes(p.status)) { patch.status = p.status; changes.push(\"holat: \" + STATUS_UZ[p.status]); }\n if (p.progress >= 0 && p.progress <= 100) { patch.progress = p.progress; changes.push(\"bajarilish: \" + p.progress + \"%\"); }\n if (p.budget > 0) { patch.budget = p.budget; if (p.currency && p.currency !== \"NONE\") patch.currency = p.currency; changes.push(\"summa yangilandi\"); }\n }\n if (p.notes) { patch.notes = [rec.notes, p.notes].filter(Boolean).join(\" | \"); if (!changes.length) changes.push(\"izoh qo'shildi\"); }\n if (!Object.keys(patch).length) return null;\n return { key, id: rec.id, patch, name: rec.name || rec.text || rec.title || rec.nameUz, changes };\n}\n\nasync function processParsed(p: any, extraNotes: string, reply: (t: string) => Promise) {\n if (p.action === \"update\" && p.targetId) {\n const upd = await buildUpdate(p);\n if (upd) {\n await pushInbox({ type: \"update\", key: upd.key, id: upd.id, patch: upd.patch });\n return reply(`🔄 Yangilandi: ${KIND_UZ[p.kind]}\\n\"${upd.name}\"\\n${upd.changes.map((c) => \"• \" + c).join(\"\\n\")}`);\n }\n }\n const rec = recordFromParse(p, extraNotes);\n await pushInbox({ type: \"record\", ...rec });\n let msg = `✅ \"${p.title}\"${p.kind === \"task\" ? (p.status === \"done\" ? \" — bajarilgan ✔️\" : \" — rejaga yozildi 📌\") : \"\"}\\n📥 ${SECTION_UZ[p.kind]} bo'limiga joylandi.`;\n if ((p.kind === \"document\" || p.kind === \"problem\") && p.notes) msg += `\\n\\n📄 Claude o'qigan mazmuni:\\n${p.notes}`;\n if (p.kind === \"partner\") {\n const missing = [];\n if (!p.phone) missing.push(\"telefon\");\n if (!p.wechat) missing.push(\"WeChat\");\n if (!p.email) missing.push(\"email\");\n if (missing.length) msg += `\\n\\n❓ ${missing.join(\", \")} ma'lum bo'lsa, yozib yuboring — o'zim qo'shib qo'yaman.\\nMasalan: \"${p.title} wechati: abc_123\"`;\n }\n return reply(msg);\n}\n\n/* ---------- Ovoz -> matn ---------- */\nasync function transcribeVoice(buf: Uint8Array) {\n if (!OPENAI_KEY) return null;\n const fd = new FormData();\n fd.append(\"file\", new Blob([buf], { type: \"audio/ogg\" }), \"voice.ogg\");\n fd.append(\"model\", \"whisper-1\");\n // Til ko'rsatilmaydi — Whisper o'zi aniqlaydi (o'zbek, rus, xitoy...)\n fd.append(\"prompt\", \"Qashqadaryo, Xitoy, loyiha, shartnoma, logistika, 物流, проект, 项目\");\n const r = await fetch(\"https://api.openai.com/v1/audio/transcriptions\", {\n method: \"POST\",\n headers: { Authorization: \"Bearer \" + OPENAI_KEY },\n body: fd,\n });\n if (!r.ok) throw new Error(\"Whisper xatosi: \" + (await r.text()).slice(0, 200));\n return (await r.json()).text;\n}\n\n/* ---------- Fayl matnini ajratib olish (Word, Excel, matn) ---------- */\nasync function extractText(buf: Uint8Array, mime: string, fileName: string): Promise {\n // Oddiy matn fayllari\n if (/^text\\//.test(mime) || /json|xml|csv/.test(mime) || /\\.(txt|md|csv|json|xml|html?)$/i.test(fileName)) {\n return new TextDecoder(\"utf-8\", { fatal: false }).decode(buf).slice(0, 50000);\n }\n // Word (.docx)\n if (/\\.docx$/i.test(fileName)) {\n try {\n const JSZip = (await import(\"npm:jszip\")).default;\n const zip = await JSZip.loadAsync(buf);\n const xml = await zip.file(\"word/document.xml\")?.async(\"string\");\n if (xml) {\n return xml\n .replace(/]/g, \"\\n<\")\n .replace(/<[^>]+>/g, \"\")\n .replace(/[ \\t]+/g, \" \")\n .trim()\n .slice(0, 50000);\n }\n } catch (_) {}\n }\n // Excel (.xlsx)\n if (/\\.xlsx$/i.test(fileName)) {\n try {\n const XLSX = await import(\"npm:xlsx\");\n const wb = XLSX.read(buf, { type: \"array\" });\n let out = \"\";\n for (const name of wb.SheetNames.slice(0, 3)) {\n out += `\\n== Varaq: ${name} ==\\n` + XLSX.utils.sheet_to_csv(wb.Sheets[name]);\n }\n return out.trim().slice(0, 50000);\n } catch (_) {}\n }\n return null;\n}\n\n/* ---------- Tugmali menyu ---------- */\nconst MENU = {\n keyboard: [\n [{ text: \"🪪 Kontakt/Vizitka\" }, { text: \"💼 Investor qo'shish\" }],\n [{ text: \"❓ Savol berish\" }, { text: \"📊 Bugungi hisobot\" }],\n ],\n resize_keyboard: true,\n};\n\n/* Saytga kontakt/investor qo'shish (buyruq va tugmadan chaqiriladi) */\nasync function siteAdd(cmd: string, blocks: any[], reply: (t: string, kb?: any) => Promise) {\n await reply(blocks.some((b) => b.type === \"image\") ? \"🖼 Vizitkani o'qib, saytga qo'shyapman...\" : \"🌐 Saytga qo'shyapman...\");\n const f = await extractCard(blocks);\n if (cmd === \"investor\") {\n if (!f.companyName) return reply(\"⚠️ Kompaniya nomi aniqlanmadi. Qaytadan urinib ko'ring.\", MENU);\n const email = f.email || `investor_${Date.now()}@kashkadarya.local`;\n const pass = randPass();\n await siteCreateInvestor({ email, password: pass, firstName: (f.personName || \"Investor\").split(\" \")[0], lastName: (f.personName || \"\").split(\" \").slice(1).join(\" \") || \"-\", companyName: f.companyName, country: f.country || \"China\", sector: f.sector || \"other\" });\n await vlog(\"Saytga investor: \" + f.companyName);\n await pushInbox({ type: \"record\", key: \"partners\", obj: { id: uid(), nameUz: f.companyName, nameZh: \"\", contact: f.personName || \"\", phone: f.phone || \"\", wechat: \"\", email, city: f.country || \"China\", industry: f.sector || \"\", notes: \"Saytga investor sifatida qo'shildi | \" + (f.notes || \"\") } });\n return reply(`✅ Investor saytga qo'shildi!\\n🏢 ${f.companyName}\\n📧 ${email}\\n🔑 Parol: ${pass}\\n🌐 https://admin.investinkashkadarya.uz\\n\\n(parolni investorga yetkazing)`, MENU);\n }\n if (!f.companyName && !f.personName) return reply(\"⚠️ Kontakt ma'lumoti aniqlanmadi. Qaytadan urinib ko'ring.\", MENU);\n await siteCreateCard(f);\n await vlog(\"Saytga kontakt: \" + (f.companyName || f.personName));\n await pushInbox({ type: \"record\", key: \"partners\", obj: { id: uid(), nameUz: f.companyName || f.personName, nameZh: \"\", contact: f.personName || \"\", phone: f.phone || \"\", wechat: \"\", email: f.email || \"\", city: f.country || \"\", industry: f.sector || \"\", notes: \"Saytga kontakt sifatida qo'shildi | \" + (f.notes || \"\") } });\n return reply(`✅ Kontakt saytga qo'shildi!\\n🏢 ${f.companyName || \"-\"}\\n👤 ${f.personName || \"-\"}\\n📞 ${f.phone || \"-\"}\\n📧 ${f.email || \"-\"}\\n🌐 https://admin.investinkashkadarya.uz/business-cards\\n\\n(platforma Sheriklariga ham qo'shildi)`, MENU);\n}\n\n/* Xabardan rasm/matn bloklarini yig'ish */\nasync function msgToBlocks(msg: any, extraText?: string) {\n const blocks: any[] = [];\n if (msg.photo) {\n const sizes = msg.photo.filter((p: any) => p.width <= 1600);\n const ph = sizes.length ? sizes[sizes.length - 1] : msg.photo[0];\n const buf = await tgDownload(ph.file_id);\n blocks.push({ type: \"image\", source: { type: \"base64\", media_type: \"image/jpeg\", data: toB64(buf) } });\n }\n const txt = (extraText || msg.text || msg.caption || \"\").trim();\n if (txt) blocks.push({ type: \"text\", text: txt });\n return blocks;\n}\n\n/* ---------- Xabarlarni qayta ishlash ---------- */\nasync function handleMessage(msg: any) {\n const chatId = msg.chat.id;\n const reply = (text: string, kb?: any) => tgApi(\"sendMessage\", { chat_id: chatId, text, ...(kb ? { reply_markup: kb } : {}) });\n\n if (ALLOWED.length && !ALLOWED.includes(String(msg.from.id))) {\n return reply(`⛔ Sizga ruxsat berilmagan.\\nSizning ID: ${msg.from.id}`);\n }\n\n try {\n const cmdText = (msg.text || msg.caption || \"\").trim();\n const modeKey = \"mode_\" + chatId;\n\n // ===== /start va yordam =====\n if (msg.text && (msg.text.startsWith(\"/start\") || msg.text.startsWith(\"/yordam\") || msg.text.startsWith(\"/help\"))) {\n await kvSet(modeKey, \"\");\n return reply(\n `Salom! 🇺🇿🇨🇳 Qashqadaryo — Xitoy platformasi botiman (24/7 bulutda).\\n\\n` +\n `Pastdagi tugmalardan foydalaning:\\n` +\n `🪪 Kontakt/Vizitka — saytga kontakt qo'shish\\n` +\n `💼 Investor qo'shish — saytga investor qo'shish\\n` +\n `❓ Savol berish — har qanday savolga javob (Claude Fable 5)\\n` +\n `📊 Bugungi hisobot — kunlik holat\\n\\n` +\n `Shunchaki matn/ovoz/fayl yuborsangiz ham — o'zim tushunib joylayman.`,\n MENU\n );\n }\n\n // ===== TUGMALAR va BUYRUQLAR =====\n const norm = cmdText.toLowerCase();\n // Vizitka rejimi\n if (/🪪|^\\/vizitka\\b|^\\/kontakt\\b|kontakt\\/vizitka/i.test(cmdText)) {\n const rest = cmdText.replace(/^\\/(vizitka|kontakt)\\b/i, \"\").trim();\n const blocks = await msgToBlocks(msg, rest || undefined);\n if (blocks.length) { await kvSet(modeKey, \"\"); return siteAdd(\"vizitka\", blocks, reply); }\n await kvSet(modeKey, \"vizitka\");\n return reply(\"🪪 Vizitka rasmini yuboring yoki kontakt ma'lumotini yozing:\\n(kompaniya, ism, lavozim, telefon, email, davlat)\", MENU);\n }\n // Investor rejimi\n if (/💼|^\\/investor\\b|investor qo/i.test(cmdText)) {\n const rest = cmdText.replace(/^\\/investor\\b/i, \"\").trim();\n const blocks = await msgToBlocks(msg, rest || undefined);\n if (blocks.length) { await kvSet(modeKey, \"\"); return siteAdd(\"investor\", blocks, reply); }\n await kvSet(modeKey, \"investor\");\n return reply(\"💼 Investor ma'lumotini yozing yoki vizitkasini yuboring:\\n(kompaniya nomi, ism, email, davlat, soha)\", MENU);\n }\n // Savol rejimi tugmasi\n if (/❓|^\\/savol\\b|savol berish/i.test(cmdText) && !msg.photo) {\n const rest = cmdText.replace(/^\\/savol\\b/i, \"\").replace(/❓\\s*savol berish/i, \"\").trim();\n if (!rest) { await kvSet(modeKey, \"\"); return reply(\"❓ Savolingizni yozing yoki ovozli xabar yuboring:\", MENU); }\n }\n // Hisobot tugmasi\n if (/📊|^\\/hisobot\\b|bugungi hisobot/i.test(cmdText)) {\n await kvSet(modeKey, \"\");\n await tgApi(\"sendChatAction\", { chat_id: chatId, action: \"typing\" });\n const bugun = new Date().toLocaleDateString(\"uz-UZ\", { day: \"2-digit\", month: \"2-digit\", year: \"numeric\" });\n const ans = await answerWithFable([{ type: \"text\", text: `Bugungi sana: ${bugun}. Rasmiy hisobot tuz.` }], true);\n return reply(ans, MENU);\n }\n\n // ===== FAOL REJIM (tugma bosilgach kelgan navbatdagi xabar) =====\n const mode = await kvGet(modeKey);\n if ((mode === \"vizitka\" || mode === \"investor\") && !norm.startsWith(\"/\")) {\n await kvSet(modeKey, \"\");\n const blocks = await msgToBlocks(msg);\n if (!blocks.length) return reply(\"Ma'lumot yoki rasm topilmadi. Qaytadan urinib ko'ring.\", MENU);\n return siteAdd(mode, blocks, reply);\n }\n\n if (msg.text) {\n const p = await parseContent([{ type: \"text\", text: \"XABAR:\\n\" + msg.text }]);\n if (p.kind === \"question\") {\n await tgApi(\"sendChatAction\", { chat_id: chatId, action: \"typing\" });\n return reply(await answerWithFable([{ type: \"text\", text: msg.text }]));\n }\n return processParsed(p, \"\", reply);\n }\n if (msg.voice) {\n if (!OPENAI_KEY) return reply(\"🎤 Ovoz uchun OPENAI_API_KEY sozlanmagan. Matn yozing.\");\n const buf = await tgDownload(msg.voice.file_id);\n const text = await transcribeVoice(buf);\n if (!text?.trim()) return reply(\"Ovozni tushuna olmadim.\");\n await reply(`🎤 Eshitdim: \"${text}\"`);\n const p = await parseContent([{ type: \"text\", text: \"XABAR:\\n\" + text }]);\n if (p.kind === \"question\") {\n await tgApi(\"sendChatAction\", { chat_id: chatId, action: \"typing\" });\n return reply(await answerWithFable([{ type: \"text\", text }]));\n }\n return processParsed(p, \"Ovozli xabardan\", reply);\n }\n if (msg.photo || msg.document) {\n let fileId: string, fileName: string, mime: string;\n if (msg.document) {\n fileId = msg.document.file_id; fileName = msg.document.file_name || \"fayl\"; mime = msg.document.mime_type || \"\";\n } else {\n // Tezlik uchun: eng kattasini emas, ~1300px atrofidagi o'lchamni olamiz (tahlilga yetarli, 2-3x tez)\n const sizes = msg.photo.filter((p: any) => p.width <= 1600);\n const ph = sizes.length ? sizes[sizes.length - 1] : msg.photo[0];\n fileId = ph.file_id; fileName = \"rasm.jpg\"; mime = \"image/jpeg\";\n }\n const isImage = /^image\\/(jpeg|png|gif|webp)$/.test(mime);\n const isPdf = mime === \"application/pdf\";\n const isAudio = /^audio\\//.test(mime) || /\\.(mp3|m4a|ogg|wav|opus)$/i.test(fileName);\n const isTextLike = /^text\\//.test(mime) || /json|xml|csv/.test(mime) || /\\.(txt|md|csv|json|xml|html?|docx|xlsx)$/i.test(fileName);\n await vlog(`Fayl keldi: ${fileName} | mime:${mime || \"-\"} | rasm:${isImage} pdf:${isPdf} audio:${isAudio} matn:${isTextLike}`);\n\n if (!isImage && !isPdf && !isAudio && !isTextLike) {\n // Qo'llanmaydigan tur (video, arxiv...) — hujjat sifatida qayd etamiz\n await pushInbox({ type: \"record\", key: \"documents\", obj: { id: uid(), title: (msg.caption || fileName).slice(0, 120), type: \"other\", projectId: \"\", date: today(), status: \"pending\", notes: \"Telegram orqali kelgan fayl: \" + fileName } });\n return reply(\"✅ Fayl hujjat sifatida qayd etildi: \" + fileName + \"\\n(bu turdagi fayl mazmunini o'qiy olmayman — matn, rasm, PDF, Word, Excel yoki audio yuboring)\");\n }\n\n // Javob va yuklab olish parallel — vaqt yutamiz\n const emoji = isImage ? \"🖼 Rasmni ko'ryapman...\" : isAudio ? \"🎧 Eshityapman...\" : \"📎 Faylni o'qiyapman...\";\n const [, buf] = await Promise.all([reply(emoji), tgDownload(fileId)]);\n if ((isImage || isPdf) && buf.length > 4_800_000) return reply(\"Fayl juda katta (5MB dan kichik yuboring).\");\n\n let blocks: any[] = [];\n let manba = \"Fayldan (Telegram)\";\n if (isImage) {\n blocks = [{ type: \"image\", source: { type: \"base64\", media_type: mime, data: toB64(buf) } }];\n manba = \"Rasmdan (Telegram)\";\n } else if (isPdf) {\n blocks = [{ type: \"document\", source: { type: \"base64\", media_type: \"application/pdf\", data: toB64(buf) } }];\n manba = \"PDF fayldan (Telegram)\";\n } else if (isAudio) {\n if (!OPENAI_KEY) return reply(\"🎧 Audio fayl uchun OPENAI_API_KEY sozlanmagan. Matn yoki rasm yuboring.\");\n const text = await transcribeVoice(buf);\n if (!text?.trim()) return reply(\"Audioni tushuna olmadim.\");\n await reply(`🎧 Eshitdim: \"${text.slice(0, 300)}\"`);\n blocks = [{ type: \"text\", text: \"AUDIO FAYL MAZMUNI:\\n\" + text }];\n manba = \"Audio fayldan (\" + fileName + \")\";\n } else {\n const extracted = await extractText(buf, mime, fileName);\n await vlog(`Matn ajratildi: ${fileName} -> ${extracted ? extracted.length + \" belgi\" : \"BO'LMADI\"}`);\n if (!extracted) {\n await pushInbox({ type: \"record\", key: \"documents\", obj: { id: uid(), title: (msg.caption || fileName).slice(0, 120), type: \"other\", projectId: \"\", date: today(), status: \"pending\", notes: \"Telegram orqali kelgan fayl (o'qib bo'lmadi): \" + fileName } });\n return reply(\"✅ Fayl hujjat sifatida qayd etildi: \" + fileName);\n }\n blocks = [{ type: \"text\", text: `FAYL (${fileName}) MAZMUNI:\\n` + extracted }];\n manba = \"Fayldan (\" + fileName + \")\";\n }\n if (msg.caption) blocks.push({ type: \"text\", text: \"Foydalanuvchi izohi: \" + msg.caption });\n const p = await parseContent(blocks);\n await vlog(`Claude tahlili: ${fileName} -> ${p.action}/${p.kind} \"${p.title}\"`);\n if (p.kind === \"question\") { // fayl/rasm haqida savol -> Fable javob beradi\n await tgApi(\"sendChatAction\", { chat_id: chatId, action: \"typing\" });\n return reply(await answerWithFable(blocks));\n }\n return processParsed(p, manba, reply);\n }\n return reply(\"Bu turdagi xabarni qabul qilmayman. Matn, ovoz, rasm yoki PDF yuboring.\");\n } catch (e: any) {\n await vlog(\"XATO: \" + e.message);\n return reply(\"⚠️ Xatolik: \" + e.message);\n }\n}\n\n/* ---------- SAYT SINXRONI: bildirishnoma + menga biriktirilgan vazifalar ---------- */\nasync function kvGet(k: string): Promise {\n const r = await sqlite.execute({ sql: `SELECT v FROM qx_kv WHERE k=?`, args: [k] });\n return r.rows.length ? rowVal(r.rows[0], 0, \"v\") : \"\";\n}\nasync function kvSet(k: string, v: string) {\n await sqlite.execute({ sql: `INSERT INTO qx_kv (k, v) VALUES (?, ?) ON CONFLICT(k) DO UPDATE SET v = excluded.v`, args: [k, v] });\n}\nconst MY_CHAT = Deno.env.get(\"MY_CHAT_ID\") || \"\";\n\nasync function runSync() {\n if (!SITE_EMAIL) return { ok: false, reason: \"sayt sozlanmagan\" };\n let sentNotif = 0, tasks = 0;\n\n // 1) BILDIRISHNOMALAR -> Telegram\n try {\n const r = await siteFetch(\"/api/dashboard/notifications\");\n if (r.ok) {\n const list = await r.json();\n const seen = await kvGet(\"notif_seen\");\n const seenTime = seen ? new Date(seen).getTime() : Date.now() - 86400000; // birinchi safar: oxirgi 1 kun\n let maxTime = seenTime;\n // eskidan yangiga\n const fresh = (list as any[]).filter((n) => new Date(n.timestamp).getTime() > seenTime).reverse();\n for (const n of fresh) {\n maxTime = Math.max(maxTime, new Date(n.timestamp).getTime());\n if (MY_CHAT) {\n await tgApi(\"sendMessage\", { chat_id: MY_CHAT, text: `🔔 Sayt bildirishnomasi:\\n${n.title}${n.description ? \"\\n\" + n.description : \"\"}${n.actorName ? \"\\n👤 \" + n.actorName : \"\"}\\n\\nhttps://admin.investinkashkadarya.uz${n.href || \"\"}` });\n sentNotif++;\n }\n }\n await kvSet(\"notif_seen\", new Date(maxTime).toISOString());\n }\n } catch (e: any) { await vlog(\"Bildirishnoma sync xatosi: \" + e.message); }\n\n // 2) MENGA BIRIKTIRILGAN VAZIFALAR -> platforma (tasks)\n try {\n const r = await siteFetch(\"/api/dashboard/me\");\n if (r.ok) {\n const d = await r.json();\n const snap = await getSnapshot();\n // eski sayt vazifalarini olib tashlaymiz (site_ prefiksli)\n snap.tasks = (snap.tasks || []).filter((t: any) => !String(t.id).startsWith(\"site_\"));\n for (const tsk of (d.pendingTasks || [])) {\n snap.tasks.push({\n id: \"site_\" + tsk.id, text: (tsk.title || tsk.code) + (tsk.description ? \" — \" + tsk.description : \"\"),\n status: tsk.status === \"completed\" ? \"done\" : \"todo\",\n date: (tsk.dueDate || tsk.createdAt || \"\").slice(0, 10) || today(),\n source: \"sayt\", notes: \"Saytdagi vazifa \" + tsk.code + (tsk.priority ? \" | ustuvorlik: \" + tsk.priority : \"\"),\n });\n tasks++;\n }\n for (const m of (d.upcomingMeetings || [])) {\n snap.tasks.push({\n id: \"site_\" + m.id, text: \"📅 Uchrashuv: \" + (m.title || m.subject || m.code || \"\"),\n status: \"todo\", date: (m.scheduledAt || m.startAt || m.date || \"\").slice(0, 10) || today(),\n source: \"sayt\", notes: \"Saytdagi uchrashuv\" + (m.location ? \" | \" + m.location : \"\"),\n });\n tasks++;\n }\n await saveSnapshot(snap);\n }\n } catch (e: any) { await vlog(\"Vazifa sync xatosi: \" + e.message); }\n\n await vlog(`Sync: ${sentNotif} bildirishnoma, ${tasks} vazifa`);\n return { ok: true, notifications: sentNotif, tasks };\n}\n\n/* ---------- HTTP kirish nuqtasi ---------- */\nconst CORS = { \"Access-Control-Allow-Origin\": \"*\", \"Access-Control-Allow-Methods\": \"GET,POST,OPTIONS\", \"Access-Control-Allow-Headers\": \"content-type\" };\nconst jsonCors = (data: any) => new Response(JSON.stringify(data), { headers: { \"content-type\": \"application/json\", ...CORS } });\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const okSecret = (url.searchParams.get(\"secret\") || \"\") === APP_SECRET && APP_SECRET;\n if (req.method === \"OPTIONS\") return new Response(null, { headers: CORS });\n // Himoyalangan yo'llarga noto'g'ri kalit bilan kirilса — 401\n if (/^\\/(snapshot|chat|inbox|import|log)$/.test(url.pathname) && !okSecret) {\n return new Response(JSON.stringify({ error: \"unauthorized\" }), { status: 401, headers: { \"content-type\": \"application/json\", ...CORS } });\n }\n\n // Telegram webhook\n if (req.method === \"POST\" && url.pathname === \"/webhook\") {\n if (req.headers.get(\"x-telegram-bot-api-secret-token\") !== APP_SECRET) return new Response(\"no\", { status: 401 });\n const upd = await req.json();\n if (upd.message) await handleMessage(upd.message);\n return Response.json({ ok: true });\n }\n // Webhookni ro'yxatdan o'tkazish (bir marta ochiladi)\n if (url.pathname === \"/setup\" && okSecret) {\n const r = await tgApi(\"setWebhook\", { url: url.origin + \"/webhook\", secret_token: APP_SECRET });\n return Response.json(r);\n }\n // Bulutdan uzish (webhookni o'chirish)\n if (url.pathname === \"/uzish\" && okSecret) {\n return Response.json(await tgApi(\"deleteWebhook\", {}));\n }\n // Sayt sinxroni (interval chaqiradi): bildirishnoma + vazifalar\n if (url.pathname === \"/sync\" && okSecret) {\n return jsonCors(await runSync());\n }\n // Kuzatuv jurnali (diagnostika uchun)\n if (url.pathname === \"/log\" && okSecret) {\n const res = await sqlite.execute({ sql: `SELECT t, msg FROM qx_log ORDER BY id DESC LIMIT 60`, args: [] });\n const lines = res.rows.map((r: any) => `${rowVal(r, 0, \"t\")} ${rowVal(r, 1, \"msg\")}`);\n return new Response(lines.join(\"\\n\") || \"jurnal bo'sh\", { headers: { \"content-type\": \"text/plain; charset=utf-8\" } });\n }\n // Dastur yangi yozuvlarni oladi\n if (url.pathname === \"/inbox\" && okSecret) {\n const res = await sqlite.execute({ sql: `SELECT id, payload FROM qx_inbox ORDER BY id`, args: [] });\n const items = res.rows.map((r: any) => ({ id: rowVal(r, 0, \"id\"), payload: rowVal(r, 1, \"payload\") }));\n if (items.length) await sqlite.execute({ sql: `DELETE FROM qx_inbox WHERE id <= ?`, args: [items[items.length - 1].id] });\n return Response.json(items.map((i) => JSON.parse(i.payload)));\n }\n // Tashqi tizimdan ommaviy import (masalan investinkashkadarya.uz dan)\n if (url.pathname === \"/import\" && req.method === \"POST\" && okSecret) {\n const events = await req.json();\n if (!Array.isArray(events)) return new Response(\"array kutilgan\", { status: 400 });\n for (const ev of events.slice(0, 100)) await pushInbox(ev);\n await vlog(`Import: ${events.length} ta yozuv qabul qilindi`);\n return Response.json({ ok: true, count: events.length });\n }\n // Dastur ma'lumotlar nusxasini yuboradi (POST) yoki oladi (GET) — onlayn platforma uchun\n if (url.pathname === \"/snapshot\" && okSecret) {\n if (req.method === \"POST\") {\n const body = await req.text();\n await sqlite.execute({ sql: `INSERT INTO qx_kv (k, v) VALUES ('snapshot', ?) ON CONFLICT(k) DO UPDATE SET v = excluded.v`, args: [body] });\n return jsonCors({ ok: true });\n }\n return jsonCors(await getSnapshot());\n }\n // Onlayn platforma Claude yordamchisi (Fable 5, refusalda Opus 4.8)\n if (url.pathname === \"/chat\" && req.method === \"POST\" && okSecret) {\n try {\n const { messages } = await req.json();\n const ctx = await siteContext();\n const sys = ANSWER_SYSTEM + \"\\n\\n\" + ctx;\n let resp;\n try {\n resp = await client.beta.messages.create({\n model: \"claude-fable-5\", max_tokens: 3000, output_config: { effort: \"medium\" },\n betas: [\"server-side-fallback-2026-06-01\"], fallbacks: [{ model: \"claude-opus-4-8\" }],\n system: sys, messages,\n } as any);\n } catch (_) {\n resp = await client.messages.create({ model: \"claude-opus-4-8\", max_tokens: 3000, thinking: { type: \"adaptive\" }, system: sys, messages } as any);\n }\n return jsonCors({ text: (resp.content as any[]).filter((b) => b.type === \"text\").map((b) => b.text).join(\"\\n\") });\n } catch (e: any) { return jsonCors({ error: e.message }); }\n }\n return new Response(\"Qashqadaryo — Xitoy platformasi boti ishlayapti ✅\", { headers: { \"content-type\": \"text/plain; charset=utf-8\" } });\n}\n","// ============================================================\n// Qashqadaryo — Xitoy platformasi: Telegram bot (BULUT versiyasi)\n// Val Town uchun HTTP val. Bu kod val.town saytiga joylanadi.\n//\n// Kerakli muhit o'zgaruvchilari (Environment variables):\n// TELEGRAM_TOKEN - @BotFather bergan token\n// ANTHROPIC_API_KEY - Claude kaliti (sk-ant-...)\n// APP_SECRET - dastur bilan bulut o'rtasidagi maxfiy kalit\n// ALLOWED_IDS - ruxsat etilgan Telegram ID lar (vergul bilan)\n// OPENAI_API_KEY - (ixtiyoriy) ovozli xabarlar uchun Whisper\n// ============================================================\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport Anthropic from \"npm:@anthropic-ai/sdk\";\n\nconst TG = Deno.env.get(\"TELEGRAM_TOKEN\") || \"\";\nconst CLAUDE_KEY = Deno.env.get(\"ANTHROPIC_API_KEY\") || \"\";\nconst APP_SECRET = Deno.env.get(\"APP_SECRET\") || \"\";\nconst OPENAI_KEY = Deno.env.get(\"OPENAI_API_KEY\") || \"\";\nconst ALLOWED = (Deno.env.get(\"ALLOWED_IDS\") || \"\").split(\",\").map((s) => s.trim()).filter(Boolean);\n\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS qx_inbox (id INTEGER PRIMARY KEY AUTOINCREMENT, payload TEXT, created TEXT)`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS qx_kv (k TEXT PRIMARY KEY, v TEXT)`);\nawait sqlite.execute(`CREATE TABLE IF NOT EXISTS qx_log (id INTEGER PRIMARY KEY AUTOINCREMENT, t TEXT, msg TEXT)`);\n\nasync function vlog(msg: string) {\n try {\n await sqlite.execute({ sql: `INSERT INTO qx_log (t, msg) VALUES (?, ?)`, args: [new Date().toISOString(), msg.slice(0, 500)] });\n } catch (_) {}\n}\n\nconst uid = () => Date.now().toString(36) + Math.random().toString(36).slice(2, 6);\nconst today = () => new Date().toISOString().slice(0, 10);\n\n/* ---------- SQLite yordamchilar ---------- */\nfunction rowVal(row: any, i: number, name: string) {\n return Array.isArray(row) ? row[i] : row[name];\n}\nasync function getSnapshot(): Promise {\n const r = await sqlite.execute({ sql: `SELECT v FROM qx_kv WHERE k='snapshot'`, args: [] });\n const empty = { tasks: [], projects: [], trades: [], partners: [], documents: [], problems: [] };\n if (!r.rows.length) return empty;\n try { return { ...empty, ...JSON.parse(rowVal(r.rows[0], 0, \"v\")) }; } catch { return empty; }\n}\nasync function saveSnapshot(snap: any) {\n await sqlite.execute({ sql: `INSERT INTO qx_kv (k, v) VALUES ('snapshot', ?) ON CONFLICT(k) DO UPDATE SET v = excluded.v`, args: [JSON.stringify(snap)] });\n}\n/* Yozuvni bulut bazasiga BEVOSITA qo'llaymiz (onlayn platforma darhol ko'radi) */\nasync function applyToSnapshot(ev: any) {\n const snap = await getSnapshot();\n if (ev.type === \"record\") {\n (snap[ev.key] = snap[ev.key] || []).push(ev.obj);\n } else if (ev.type === \"update\") {\n const list = snap[ev.key] || [];\n const i = list.findIndex((x: any) => x.id === ev.id);\n if (i >= 0) Object.assign(list[i], ev.patch);\n }\n await saveSnapshot(snap);\n}\nasync function pushInbox(payload: any) {\n await sqlite.execute({ sql: `INSERT INTO qx_inbox (payload, created) VALUES (?, ?)`, args: [JSON.stringify(payload), new Date().toISOString()] });\n await applyToSnapshot(payload); // bulut bazasiga ham darhol yoziladi\n}\n\n/* ---------- Telegram ---------- */\nconst tgApi = (method: string, body: any) =>\n fetch(`https://api.telegram.org/bot${TG}/${method}`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify(body || {}),\n }).then((r) => r.json());\n\nasync function tgDownload(fileId: string) {\n const info = await tgApi(\"getFile\", { file_id: fileId });\n if (!info.ok) throw new Error(\"Faylni olib bo'lmadi: \" + (info.description || \"\"));\n const r = await fetch(`https://api.telegram.org/file/bot${TG}/${info.result.file_path}`);\n return new Uint8Array(await r.arrayBuffer());\n}\nfunction toB64(buf: Uint8Array) {\n let s = \"\";\n for (let i = 0; i < buf.length; i += 8192) s += String.fromCharCode(...buf.subarray(i, i + 8192));\n return btoa(s);\n}\n/* Telegramga tayyor faylni yuborish */\nasync function tgSendDocument(chatId: any, filename: string, bytes: Uint8Array, caption?: string) {\n const fd = new FormData();\n fd.append(\"chat_id\", String(chatId));\n if (caption) fd.append(\"caption\", caption.slice(0, 1000));\n fd.append(\"document\", new Blob([bytes]), filename);\n return fetch(`https://api.telegram.org/bot${TG}/sendDocument`, { method: \"POST\", body: fd }).then((r) => r.json());\n}\n/* Matndan Word (.docx) hujjat yaratish */\nasync function buildDocx(title: string, text: string): Promise {\n const { Document, Packer, Paragraph, HeadingLevel } = await import(\"npm:docx@8\");\n const paras: any[] = [new Paragraph({ text: title, heading: HeadingLevel.TITLE })];\n for (const raw of text.split(\"\\n\")) {\n const line = raw.replace(/\\*\\*/g, \"\").replace(/`/g, \"\").trimEnd();\n if (!line.trim()) { paras.push(new Paragraph(\"\")); continue; }\n if (/^#{1,6}\\s/.test(line)) paras.push(new Paragraph({ text: line.replace(/^#+\\s/, \"\"), heading: HeadingLevel.HEADING_1 }));\n else if (/^\\s*[-*•]\\s/.test(line)) paras.push(new Paragraph({ text: line.replace(/^\\s*[-*•]\\s/, \"\"), bullet: { level: 0 } }));\n else paras.push(new Paragraph(line));\n }\n const doc = new Document({ sections: [{ children: paras }] });\n const buf = await Packer.toBuffer(doc);\n return new Uint8Array(buf);\n}\n\n/* ---------- SAYT INTEGRATSIYASI (investinkashkadarya.uz) ---------- */\nconst SITE = Deno.env.get(\"SITE_API\") || \"https://api.investinkashkadarya.uz\";\nconst SITE_EMAIL = Deno.env.get(\"SITE_EMAIL\") || \"\";\nconst SITE_PASSWORD = Deno.env.get(\"SITE_PASSWORD\") || \"\";\nlet siteCookie = \"\";\nlet siteCookieAt = 0;\n\nasync function siteLogin(): Promise {\n if (!SITE_EMAIL || !SITE_PASSWORD) return false;\n const r = await fetch(SITE + \"/api/auth/login\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ email: SITE_EMAIL, password: SITE_PASSWORD }),\n });\n if (!r.ok) { await vlog(\"Sayt login xatosi: \" + r.status); return false; }\n const setc = r.headers.get(\"set-cookie\") || \"\";\n // barcha cookie'larni yig'amiz\n siteCookie = setc.split(/,(?=[^;]+=[^;]+)/).map((c) => c.split(\";\")[0].trim()).filter(Boolean).join(\"; \");\n siteCookieAt = Date.now();\n return !!siteCookie;\n}\nasync function siteFetch(path: string, init: any = {}): Promise {\n if (!siteCookie || Date.now() - siteCookieAt > 4 * 60 * 1000) await siteLogin();\n init.headers = { ...(init.headers || {}), Cookie: siteCookie };\n let r = await fetch(SITE + path, init);\n if (r.status === 401) { // sessiya tugagan — qayta kiramiz\n await siteLogin();\n init.headers.Cookie = siteCookie;\n r = await fetch(SITE + path, init);\n }\n return r;\n}\nasync function siteCreateCard(f: any) {\n const r = await siteFetch(\"/api/business-cards\", {\n method: \"POST\", headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n companyName: f.companyName || null, personName: f.personName || null,\n position: f.position || null, email: f.email || null, phone: f.phone || null,\n website: f.website || null, address: f.address || null, country: f.country || null,\n notes: [f.notes, f.sector ? \"Soha: \" + f.sector : \"\"].filter(Boolean).join(\" | \") || null,\n }),\n });\n if (!r.ok) throw new Error(\"Sayt kontakt xatosi: \" + r.status + \" \" + (await r.text()).slice(0, 200));\n return r.json();\n}\nasync function siteCreateInvestor(f: any) {\n const r = await siteFetch(\"/api/investors\", {\n method: \"POST\", headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n email: f.email, password: f.password,\n firstName: f.firstName || \"-\", lastName: f.lastName || \"-\",\n companyName: f.companyName, country: f.country || \"China\",\n sector: f.sector || \"other\",\n }),\n });\n if (!r.ok) throw new Error(\"Sayt investor xatosi: \" + r.status + \" \" + (await r.text()).slice(0, 250));\n return r.json();\n}\n/* Vizitka rasmini saytga yuklab, karta yaratish (OCR + rasm saqlanadi) */\nasync function siteCardScan(buf: Uint8Array, filename = \"card.jpg\", mime = \"image/jpeg\") {\n const fd = new FormData();\n fd.append(\"file\", new Blob([buf], { type: mime }), filename);\n const r = await siteFetch(\"/api/business-cards/scan\", { method: \"POST\", body: fd });\n if (!r.ok) throw new Error(\"Sayt scan xatosi: \" + r.status + \" \" + (await r.text()).slice(0, 200));\n return r.json();\n}\n/* Saytga muammo (ticket) qo'shish */\nasync function siteCreateTicket(f: any) {\n const r = await siteFetch(\"/api/tickets\", {\n method: \"POST\", headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n title: f.title, description: f.description,\n category: f.category || \"project_related\",\n priority: f.priority || \"medium\",\n ...(f.relatedProjectId ? { relatedProjectId: f.relatedProjectId } : {}),\n isDistrictProblem: true,\n }),\n });\n if (!r.ok) throw new Error(\"Sayt muammo xatosi: \" + r.status + \" \" + (await r.text()).slice(0, 200));\n return r.json();\n}\n/* Saytga fayl yuklash (ticket/loyihaga biriktirish mumkin) */\nasync function siteUploadDoc(buf: Uint8Array, filename: string, mime: string, meta: any = {}) {\n const fd = new FormData();\n fd.append(\"file\", new Blob([buf], { type: mime || \"application/octet-stream\" }), filename);\n for (const [k, v] of Object.entries(meta)) if (v !== undefined && v !== null) fd.append(k, String(v));\n const r = await siteFetch(\"/api/documents/upload\", { method: \"POST\", body: fd });\n if (!r.ok) throw new Error(\"Sayt fayl yuklash xatosi: \" + r.status + \" \" + (await r.text()).slice(0, 150));\n return r.json();\n}\n\nconst MY_DISTRICT = Deno.env.get(\"MY_DISTRICT\") || \"\";\n/* Tuman loyihalari: kod -> id xaritasi (muammoni loyihaga bog'lash uchun) */\nasync function districtProjectMap(): Promise> {\n const map: Record = {};\n try {\n if (!MY_DISTRICT) return map;\n const pr = await (await siteFetch(\"/api/projects?districtId=\" + MY_DISTRICT + \"&limit=100\")).json();\n for (const p of (pr.items || [])) if (p.code) map[p.code.toUpperCase()] = p.id;\n } catch (_) {}\n return map;\n}\n\n/* Asosiy saytdan JONLI kontekst (menga biriktirilgan vazifalar + tuman loyihalari) */\nlet ctxCache = \"\", ctxAt = 0;\nasync function siteContext(force = false) {\n if (!force && ctxCache && Date.now() - ctxAt < 60000) return ctxCache;\n const lines: string[] = [\"=== investinkashkadarya.uz — JONLI MA'LUMOT ===\"];\n try {\n const me = await (await siteFetch(\"/api/dashboard/me\")).json();\n lines.push(\"\\n## MENGA BIRIKTIRILGAN VAZIFALAR (\" + (me.pendingTasks || []).length + \")\");\n for (const t of (me.pendingTasks || [])) lines.push(`- [${t.code}] ${t.title} | holat:${t.status} | muddat:${(t.dueDate || \"\").slice(0, 10) || \"-\"}${t.priority ? \" | ustuvorlik:\" + t.priority : \"\"}${t.description ? \" — \" + t.description : \"\"}`);\n lines.push(\"\\n## YAQIN UCHRASHUVLAR (\" + (me.upcomingMeetings || []).length + \")\");\n for (const m of (me.upcomingMeetings || [])) lines.push(`- ${m.title || m.subject || m.code || \"Uchrashuv\"} | ${(m.scheduledAt || m.startAt || m.date || \"\").slice(0, 16)}`);\n if (me.myKpi) lines.push(\"\\n## KPI: \" + JSON.stringify(me.myKpi).slice(0, 300));\n } catch (e: any) { lines.push(\"(vazifalarni olishda xato: \" + e.message + \")\"); }\n try {\n if (MY_DISTRICT) {\n const pr = await (await siteFetch(\"/api/projects?districtId=\" + MY_DISTRICT + \"&limit=100\")).json();\n const items = pr.items || [];\n const cn = items.filter((p: any) => /xitoy|china|китай/i.test(p.country || \"\"));\n lines.push(`\\n## TUMANIM LOYIHALARI (jami ${pr.total}, shundan Xitoy: ${cn.length})`);\n for (const p of items) {\n const nm = (p.name && (p.name.uz || p.name._origText)) || p.code;\n lines.push(`- [${p.code}] ${nm} | ${p.country || \"-\"} | ${p.sectorName || \"-\"} | ${p.totalCost || 0} mln | holat:${p.stage}`);\n }\n }\n } catch (e: any) { lines.push(\"(loyihalarni olishda xato: \" + e.message + \")\"); }\n ctxCache = lines.join(\"\\n\").slice(0, 190000);\n ctxAt = Date.now();\n return ctxCache;\n}\n\n/* ---------- Claude tahlili ---------- */\nconst client = new Anthropic({ apiKey: CLAUDE_KEY });\n\nconst PARSE_SCHEMA = {\n type: \"object\",\n additionalProperties: false,\n required: [\"action\", \"kind\", \"targetId\", \"title\", \"status\", \"progress\", \"district\", \"partnerName\", \"budget\", \"currency\", \"direction\", \"notes\", \"phone\", \"wechat\", \"email\"],\n properties: {\n action: { type: \"string\", enum: [\"add\", \"update\"] },\n kind: { type: \"string\", enum: [\"task\", \"project\", \"trade\", \"partner\", \"document\", \"problem\", \"question\"] },\n targetId: { type: \"string\" },\n title: { type: \"string\" },\n status: { type: \"string\", enum: [\"todo\", \"done\", \"new\", \"nego\", \"appr\", \"prog\", \"stop\", \"none\"] },\n progress: { type: \"number\" },\n district: { type: \"string\" },\n partnerName: { type: \"string\" },\n budget: { type: \"number\" },\n currency: { type: \"string\", enum: [\"USD\", \"CNY\", \"UZS\", \"EUR\", \"NONE\"] },\n direction: { type: \"string\", enum: [\"import\", \"export\", \"none\"] },\n notes: { type: \"string\" },\n phone: { type: \"string\" },\n wechat: { type: \"string\" },\n email: { type: \"string\" },\n },\n};\n\nconst PARSE_SYSTEM = `Sen Qashqadaryo viloyati - Xitoy yo'nalishi bo'yicha loyihalarni boshqarish platformasining yordamchisisan.\nFoydalanuvchi Telegram orqali o'zbek (ba'zan rus yoki xitoy) tilida xabar yuboradi. Senga platformadagi mavjud yozuvlar ro'yxati (ID bilan) ham beriladi.\n\nVazifang: xabar (1) SAVOL/so'rovmi, (2) YANGI yozuv qo'shishmi yoki (3) MAVJUD yozuvni yangilashmi - aniqlash.\n\nSAVOL (juda muhim, birinchi tekshir): agar foydalanuvchi biror narsa SO'RAYOTGAN, tahlil, hisobot, maslahat, tushuntirish yoki umumiy javob kutayotgan bo'lsa (masalan \"qancha loyiha bor?\", \"eng katta investor kim?\", \"menga bugun nima qilishim kerak?\", \"bu haqda nima deb o'ylaysan?\", \"tarjima qil\", \"hisobla\", savol belgisi bilan tugagan yoki so'roq so'zlar bilan boshlangan) -> kind=question. Bu holatda boshqa maydonlar bo'sh bo'lsin. Faqat aniq ma'lumot QO'SHISH/YANGILASH bo'lmagan hamma narsa question.\n\nUPDATE belgilari: \"...foizga yetdi\" -> progress; \"tasdiqlandi, imzolandi\" -> status=appr/done; \"boshlandi\" -> prog; \"to'xtadi\" -> stop; \"tugadi\" -> done. Ro'yxatdan nomi o'xshash yozuvni top, ID sini targetId ga yoz. Topilmasa action=add.\n\nADD qoidalari: \"qildim/bajardim\" -> task done; \"qilish kerak/reja\" -> task todo; zavod/investitsiya -> project; import/eksport/konteyner -> trade; yangi kompaniya/kontakt -> partner; shartnoma/hujjat -> document; aniqmas -> task todo.\n\nSHERIK kontaktlari: telefon -> phone, WeChat/veychat -> wechat, email -> email maydonlariga yoz. Mavjud sherik haqida telefon/wechat/email kelsa -> action=update, kind=partner, targetId=SHERIKLAR ro'yxatidagi IDsi.\n\nRASM kelsa (vizitka, shartnoma surati, eslatma): barcha matnni o'qi (xitoy/rus/ingliz bo'lishi mumkin). Vizitka -> partner, title=kompaniya nomi, notes ga ism/telefon/email/shahar. Shartnoma -> document. Eslatma -> task.\n\nMUAMMO (juda muhim): \"muammo, to'siq, kechikish, mushkulot, ishlamayapti, rad etildi, yetishmayapti, kelishmovchilik\" kabi salbiy holat -> kind=problem, action=add.\n- title ga muammoning qisqa bayoni.\n- targetId ga bu muammo QAYSI loyiha/bitimga tegishli bo'lsa, o'sha LOYIHA IDsini yoz (ro'yxatdan top). Topilmasa bo'sh qoldir.\n- \"muammo hal bo'ldi/yechildi\" -> action=update, kind=problem, targetId=MUAMMOLAR ro'yxatidagi muammo IDsi, status=done.\n\nBOG'LASH: hujjat (kind=document) aniq bir loyihaga tegishli bo'lsa, targetId ga o'sha loyiha IDsini yoz.\n\nHUJJAT MAZMUNI: kind=document bo'lsa, notes maydoniga hujjatning MAZMUNINI 2-4 jumlada yoz: tomonlar kimlar, summa qancha, muddatlar, asosiy shartlar. Bu juda muhim - foydalanuvchi hujjat nimaligini shu yerdan biladi.\n\ntitle doim qisqa o'zbekcha. Tegishli bo'lmagan maydonlarga bo'sh satr, 0, -1 yoki none/NONE yoz.`;\n\nfunction catalogText(snap: any) {\n const lines: string[] = [];\n const add = (label: string, arr: any[], f: (x: any) => string) => {\n lines.push(\"## \" + label);\n (arr || []).slice(-40).forEach((x) => lines.push(f(x)));\n };\n add(\"LOYIHALAR\", snap.projects, (x) => `${x.id} | ${x.name} | holat:${x.status} | ${x.progress || 0}%`);\n add(\"SAVDO BITIMLARI\", snap.trades, (x) => `${x.id} | ${x.name} | ${x.type} | holat:${x.status}`);\n add(\"SHERIKLAR\", snap.partners, (x) => `${x.id} | ${x.nameUz} | tel:${x.phone || \"-\"} | wechat:${x.wechat || \"-\"}`);\n add(\"HUJJATLAR\", snap.documents, (x) => `${x.id} | ${x.title} | ${x.status}`);\n add(\"KUNLIK ISHLAR (rejadagi)\", (snap.tasks || []).filter((t: any) => t.status === \"todo\"), (x) => `${x.id} | ${x.text}`);\n add(\"MUAMMOLAR (ochiq)\", (snap.problems || []).filter((p: any) => p.status === \"open\"), (x) => `${x.id} | ${x.text} | loyiha_id:${x.linkedId || \"-\"}`);\n return lines.join(\"\\n\");\n}\n\nasync function parseContent(blocks: any[]) {\n const snap = await getSnapshot();\n const resp = await client.messages.create({\n model: \"claude-sonnet-5\", // tezlik uchun\n max_tokens: 1200,\n thinking: { type: \"disabled\" },\n system: PARSE_SYSTEM,\n output_config: { format: { type: \"json_schema\", schema: PARSE_SCHEMA } },\n messages: [{\n role: \"user\",\n content: [...blocks, { type: \"text\", text: `MAVJUD YOZUVLAR:\\n${catalogText(snap)}\\n\\nYuqoridagi xabarni (yoki rasmni) tahlil qilib, JSON qaytir.` }],\n }],\n } as any);\n const tb: any = (resp.content as any[]).find((b) => b.type === \"text\");\n return JSON.parse(tb.text);\n}\n\n/* Saytga yozish uchun kontakt maydonlarini ajratish (matn yoki rasmdan) */\nconst CARD_SCHEMA = {\n type: \"object\", additionalProperties: false,\n required: [\"companyName\", \"personName\", \"position\", \"email\", \"phone\", \"website\", \"address\", \"country\", \"sector\", \"notes\"],\n properties: {\n companyName: { type: \"string\" }, personName: { type: \"string\" }, position: { type: \"string\" },\n email: { type: \"string\" }, phone: { type: \"string\" }, website: { type: \"string\" },\n address: { type: \"string\" }, country: { type: \"string\", description: \"Davlat, aniqlanmasa 'China'\" },\n sector: { type: \"string\", enum: [\"agriculture\", \"manufacturing\", \"mining\", \"energy\", \"construction\", \"it_tech\", \"finance\", \"retail\", \"transport\", \"tourism\", \"healthcare\", \"education\", \"pharma\", \"textile\", \"food_processing\", \"other\"] },\n notes: { type: \"string\" },\n },\n};\nasync function extractCard(blocks: any[]) {\n const resp = await client.messages.create({\n model: \"claude-sonnet-5\", max_tokens: 800, thinking: { type: \"disabled\" },\n system: \"Berilgan matn yoki vizitka rasmidan kompaniya kontakt ma'lumotlarini ajrat. Barcha matnni o'qi (xitoy/rus/ingliz). Topilmagan maydonga bo'sh satr. country aniqlanmasa 'China'. sector ni ro'yxatdan tanla.\",\n output_config: { format: { type: \"json_schema\", schema: CARD_SCHEMA } },\n messages: [{ role: \"user\", content: blocks }],\n } as any);\n return JSON.parse((resp.content as any[]).find((b) => b.type === \"text\").text);\n}\nfunction randPass() { return \"Inv\" + Math.random().toString(36).slice(2, 10) + \"9!\"; }\n\n/* Muammoni (ticket) tuzilmali ajratish */\nconst TICKET_SCHEMA = {\n type: \"object\", additionalProperties: false,\n required: [\"title\", \"description\", \"category\", \"projectCode\"],\n properties: {\n title: { type: \"string\", description: \"Muammoning qisqa sarlavhasi (kamida 3 belgi)\" },\n description: { type: \"string\", description: \"Muammoning to'liq bayoni (kamida 5 belgi)\" },\n category: { type: \"string\", enum: [\"technical\", \"information\", \"document\", \"complaint\", \"investment_request\", \"project_related\", \"external_org\", \"other\"], description: \"Muammo turi\" },\n projectCode: { type: \"string\", description: \"Agar muammo ma'lum loyihaga tegishli bo'lsa, loyiha kodi (PRJ-...), aks holda bo'sh\" },\n },\n};\nasync function extractTicket(blocks: any[]) {\n const resp = await client.messages.create({\n model: \"claude-sonnet-5\", max_tokens: 700, thinking: { type: \"disabled\" },\n system: \"Berilgan matn/rasmdan muammo (ariza) ma'lumotini ajrat. title qisqa, description to'liq. category ni ro'yxatdan tanla (ko'pincha project_related). Loyiha kodi aytilgan bo'lsa projectCode ga yoz.\",\n output_config: { format: { type: \"json_schema\", schema: TICKET_SCHEMA } },\n messages: [{ role: \"user\", content: blocks }],\n } as any);\n return JSON.parse((resp.content as any[]).find((b) => b.type === \"text\").text);\n}\n\n/* Har qanday savolga Claude Fable 5 (eng kuchli model) orqali javob berish */\nconst ANSWER_SYSTEM = `ROLI: Sen — Qashqadaryo viloyati investitsiyalar, sanoat va savdo yo'nalishidagi professional AI yordamchisan (investitsiya kotibiyati mudiri uchun shaxsiy yordamchi).\nAsosiy vazifalaring: xorijiy investitsiyalarni jalb qilish; investorlar bilan muzokara materiallari; rasmiy xatlar, memorandumlar, investitsiya bitimlari, taqdimotlar; texnik-iqtisodiy asos (TIA), biznes-reja va loyiha konsepsiyalari; forum va B2B uchrashuvlar; Xitoy, Rossiya, Yaqin Sharq bilan hamkorlik hujjatlari.\n\nASOSIY MA'LUMOT MANBAI — investinkashkadarya.uz sayti (quyida jonli beriladi). Loyiha/vazifa/investor haqidagi savollarga SHU sayt ma'lumotlari asosida, aniq raqam va kodlar bilan javob ber. Ma'lumotni o'ylab topma.\n\nISH USLUBI:\n— Rasmiy va diplomatik uslubda yoz; aniq, professional, investorga tushunarli.\n— Hujjatlarni sarlavha, bo'lim va punktlarga ajrat; kerak bo'lsa jadval ishlat.\n— Amaliy va real yechimlar taklif qil; xalqaro biznes standartlariga mos yoz.\n— Qisqa, lekin mazmunli va ishonchli. Ortiqcha muqaddima yozma.\n— Hokim, vazirlik va investorlar uchun uslubni moslashtir.\n\nTIL: Foydalanuvchi savoli o'zbek/rus/xitoy/ingliz tilida bo'lishi mumkin. Javobni odatda O'ZBEK tilida ber; agar foydalanuvchi boshqa tilda hujjat/tarjima so'rasa, o'sha tilda (rus/xitoy/ingliz) professional biznes-hukumat uslubida yoz. Xitoycha matnda rasmiy biznes terminologiyasidan foydalan. Sun'iy tarjimadan qoch, ma'noni to'liq saqla.\n\nEKSPERT SOHALARING: sanoat zonalari, energetika, chiqindidan elektr energiyasi, qishloq xo'jaligi, chorvachilik, oziq-ovqat sanoati, logistika, eksport, infratuzilma, mashinasozlik, qurilish materiallari, PPP/BOT loyihalari, Xitoy–O'zbekiston hamkorligi.\n\nINVESTITSIYA LOYIHASI so'ralganda ko'rsat: ROI va investor foydasi; davlat imtiyozlari va preferensiyalar; logistika va eksport; erkin iqtisodiy zona afzalliklari; soliq va bojxona imtiyozlari; elektr/gaz/suv/infratuzilma; amalga oshirish bosqichlari; xavflar va yechimlari.\n\nRASMIY HUJJATLAR (so'ralganda to'liq tayyorla): memorandum, investitsiya bitimi, xizmat shartnomasi, hukumatga murojaat, rasmiy xat, forum taklifi, prezentatsiya matni, commercial offer, feasibility study (TIA), loyiha konsepsiyasi, tender/EPC hujjatlari.\n\nXITOY INVESTORLARI bilan: \"win-win cooperation\" uslubi; \"Belt and Road Initiative\" bilan bog'liqlik; O'zbekistonning strategik joylashuvi; Rossiya/MDH/Markaziy Osiyo bozorlariga chiqish; uzoq muddatli hamkorlik ruhi.\n\nMAQSAD: Qashqadaryo viloyatiga yirik xorijiy investitsiyalarni jalb qilish, xalqaro hamkorlikni kengaytirish va professional davlat-investitsiya hujjatlarini tez, sifatli tayyorlash.\n\nEslatma: bu Telegram — matnni ixcham, sarlavha va punktlar bilan formatla. Umumiy bilim, tarjima yoki hisob-kitob so'ralsa, oddiy professional yordamchi sifatida javob ber.`;\n\nconst REPORT_SYSTEM = `Sen Qashqadaryo viloyati hokimligining Xitoy yo'nalishi bo'yicha rasmiy hisobot tayyorlovchi yordamchisan.\nBerilgan JONLI sayt ma'lumotlari (investinkashkadarya.uz) asosida QUYIDAGI RASMIY SHAKLDA hisobot tuz. Aynan shu tuzilishni saqla, o'zbek tilida:\n\n📋 RASMIY HISOBOT\nQashqadaryo viloyati — Xitoy yo'nalishi\nSana: {bugungi sana}\n\n1️⃣ UMUMIY HOLAT\n— (loyihalar, vazifalar soni va qisqa umumiy baho)\n\n2️⃣ MENGA BIRIKTIRILGAN VAZIFALAR\n— (har birini raqamlab, holati va muddati bilan)\n\n3️⃣ TUMAN LOYIHALARI (XITOY YO'NALISHI)\n— (asosiy loyihalar, holati bilan; ko'p bo'lsa eng muhimlarini)\n\n4️⃣ E'TIBOR TALAB QILADIGAN MASALALAR\n— (muddati yaqin yoki kechikayotgan ishlar, muammolar)\n\n5️⃣ TAVSIYALAR\n— (bugun nimaga e'tibor berish kerak — 2-4 aniq band)\n\nHisobotni tayyorladi: Platforma yordamchisi (Claude)\n\nFaktik bo'l, faqat berilgan ma'lumotdan foydalisan. Emoji va sarlavhalarni saqla.`;\n\nasync function answerWithFable(blocks: any[], report = false) {\n const ctx = await siteContext();\n const sys = (report ? REPORT_SYSTEM : ANSWER_SYSTEM) + \"\\n\\n\" + ctx;\n // HISOBOT: tezlik uchun sonnet-5 (thinking o'chirilgan) — Fable emas\n if (report) {\n const resp = await client.messages.create({\n model: \"claude-sonnet-5\", max_tokens: 2500, thinking: { type: \"disabled\" },\n system: sys, messages: [{ role: \"user\", content: blocks }],\n } as any);\n return (resp.content as any[]).filter((b) => b.type === \"text\").map((b) => b.text).join(\"\\n\").trim() || \"…\";\n }\n // 1-urinish: Claude Fable 5 (thinking doim yoniq — parametr berilmaydi)\n try {\n const resp = await client.beta.messages.create({\n model: \"claude-fable-5\",\n max_tokens: 3000,\n output_config: { effort: \"medium\" },\n betas: [\"server-side-fallback-2026-06-01\"],\n fallbacks: [{ model: \"claude-opus-4-8\" }],\n system: sys,\n messages: [{ role: \"user\", content: blocks }],\n } as any);\n return (resp.content as any[]).filter((b) => b.type === \"text\").map((b) => b.text).join(\"\\n\").trim() || \"…\";\n } catch (e: any) {\n await vlog(\"Fable xatosi, Opus'ga o'tildi: \" + e.message);\n // Zaxira: Opus 4.8\n const resp = await client.messages.create({\n model: \"claude-opus-4-8\", max_tokens: 3000, thinking: { type: \"adaptive\" },\n system: sys, messages: [{ role: \"user\", content: blocks }],\n } as any);\n return (resp.content as any[]).filter((b) => b.type === \"text\").map((b) => b.text).join(\"\\n\").trim() || \"…\";\n }\n}\n\n/* ---------- Yozuv yaratish / yangilash ---------- */\nconst KIND_UZ: any = { task: \"Kunlik ish\", project: \"Investitsiya loyihasi\", trade: \"Savdo bitimi\", partner: \"Sherik\", document: \"Hujjat\", problem: \"Muammo ⚠️\" };\nconst SECTION_UZ: any = { task: \"✅ Kunlik ishlar\", project: \"🏭 Loyihalar\", trade: \"🚢 Import/Eksport\", partner: \"🤝 Sheriklar\", document: \"📄 Hujjatlar\", problem: \"⚠️ loyihaning Muammolar ro'yxati\" };\nconst STATUS_UZ: any = { new: \"Yangi\", nego: \"Muzokara\", appr: \"Tasdiqlangan\", prog: \"Jarayonda\", done: \"Yakunlangan\", stop: \"To'xtatilgan\" };\nconst KEY_MAP: any = { task: \"tasks\", project: \"projects\", trade: \"trades\", partner: \"partners\", document: \"documents\", problem: \"problems\" };\n\nfunction recordFromParse(p: any, extraNotes: string) {\n const notes = [p.notes, extraNotes].filter(Boolean).join(\" | \");\n if (p.kind === \"task\") return { key: \"tasks\", obj: { id: uid(), text: p.title, status: p.status === \"done\" ? \"done\" : \"todo\", date: today(), source: \"telegram\", notes } };\n if (p.kind === \"partner\") return { key: \"partners\", obj: { id: uid(), nameUz: p.title, nameZh: \"\", contact: \"\", phone: p.phone || \"\", wechat: p.wechat || \"\", email: p.email || \"\", city: \"\", industry: \"\", notes } };\n if (p.kind === \"problem\") return { key: \"problems\", obj: { id: uid(), linkedId: p.targetId || \"\", text: p.title, status: \"open\", date: today(), source: \"telegram\", notes } };\n if (p.kind === \"document\") return { key: \"documents\", obj: { id: uid(), title: p.title, type: \"other\", projectId: p.targetId || \"\", date: today(), status: \"pending\", notes } };\n const base = { id: uid(), name: p.title, partnerId: \"\", district: p.district || \"\", budget: p.budget || 0, currency: p.currency === \"NONE\" ? \"USD\" : p.currency, status: \"new\", progress: 0, startDate: today(), responsible: \"\", notes };\n if (p.kind === \"trade\") return { key: \"trades\", obj: { ...base, type: p.direction === \"export\" ? \"export\" : \"import\" } };\n return { key: \"projects\", obj: { ...base, type: \"invest\" } };\n}\n\nasync function buildUpdate(p: any) {\n const snap = await getSnapshot();\n const key = KEY_MAP[p.kind];\n const rec = (snap[key] || []).find((x: any) => x.id === p.targetId);\n if (!rec) return null;\n const patch: any = {};\n const changes: string[] = [];\n if (key === \"tasks\") {\n if (p.status === \"done\" || p.status === \"todo\") { patch.status = p.status; changes.push(p.status === \"done\" ? \"bajarildi ✔️\" : \"rejaga qaytarildi\"); }\n } else if (key === \"problems\") {\n if (p.status === \"done\") { patch.status = \"resolved\"; changes.push(\"hal qilindi ✅\"); }\n } else if (key === \"partners\") {\n if (p.phone) { patch.phone = p.phone; changes.push(\"telefon: \" + p.phone); }\n if (p.wechat) { patch.wechat = p.wechat; changes.push(\"WeChat: \" + p.wechat); }\n if (p.email) { patch.email = p.email; changes.push(\"email: \" + p.email); }\n } else if (key === \"documents\") {\n if (p.status === \"done\" || p.status === \"appr\") { patch.status = \"signed\"; changes.push(\"imzolangan\"); }\n else if (p.status === \"prog\" || p.status === \"nego\") { patch.status = \"pending\"; changes.push(\"kutilmoqda\"); }\n } else if (key === \"projects\" || key === \"trades\") {\n if ([\"new\", \"nego\", \"appr\", \"prog\", \"done\", \"stop\"].includes(p.status)) { patch.status = p.status; changes.push(\"holat: \" + STATUS_UZ[p.status]); }\n if (p.progress >= 0 && p.progress <= 100) { patch.progress = p.progress; changes.push(\"bajarilish: \" + p.progress + \"%\"); }\n if (p.budget > 0) { patch.budget = p.budget; if (p.currency && p.currency !== \"NONE\") patch.currency = p.currency; changes.push(\"summa yangilandi\"); }\n }\n if (p.notes) { patch.notes = [rec.notes, p.notes].filter(Boolean).join(\" | \"); if (!changes.length) changes.push(\"izoh qo'shildi\"); }\n if (!Object.keys(patch).length) return null;\n return { key, id: rec.id, patch, name: rec.name || rec.text || rec.title || rec.nameUz, changes };\n}\n\nasync function processParsed(p: any, extraNotes: string, reply: (t: string) => Promise) {\n if (p.action === \"update\" && p.targetId) {\n const upd = await buildUpdate(p);\n if (upd) {\n await pushInbox({ type: \"update\", key: upd.key, id: upd.id, patch: upd.patch });\n return reply(`🔄 Yangilandi: ${KIND_UZ[p.kind]}\\n\"${upd.name}\"\\n${upd.changes.map((c) => \"• \" + c).join(\"\\n\")}`);\n }\n }\n const rec = recordFromParse(p, extraNotes);\n await pushInbox({ type: \"record\", ...rec });\n let msg = `✅ \"${p.title}\"${p.kind === \"task\" ? (p.status === \"done\" ? \" — bajarilgan ✔️\" : \" — rejaga yozildi 📌\") : \"\"}\\n📥 ${SECTION_UZ[p.kind]} bo'limiga joylandi.`;\n if ((p.kind === \"document\" || p.kind === \"problem\") && p.notes) msg += `\\n\\n📄 Claude o'qigan mazmuni:\\n${p.notes}`;\n if (p.kind === \"partner\") {\n const missing = [];\n if (!p.phone) missing.push(\"telefon\");\n if (!p.wechat) missing.push(\"WeChat\");\n if (!p.email) missing.push(\"email\");\n if (missing.length) msg += `\\n\\n❓ ${missing.join(\", \")} ma'lum bo'lsa, yozib yuboring — o'zim qo'shib qo'yaman.\\nMasalan: \"${p.title} wechati: abc_123\"`;\n }\n return reply(msg);\n}\n\n/* ---------- Ovoz -> matn ---------- */\nasync function transcribeVoice(buf: Uint8Array) {\n if (!OPENAI_KEY) return null;\n const fd = new FormData();\n fd.append(\"file\", new Blob([buf], { type: \"audio/ogg\" }), \"voice.ogg\");\n fd.append(\"model\", \"whisper-1\");\n // Til ko'rsatilmaydi — Whisper o'zi aniqlaydi (o'zbek, rus, xitoy...)\n fd.append(\"prompt\", \"Qashqadaryo, Xitoy, loyiha, shartnoma, logistika, 物流, проект, 项目\");\n const r = await fetch(\"https://api.openai.com/v1/audio/transcriptions\", {\n method: \"POST\",\n headers: { Authorization: \"Bearer \" + OPENAI_KEY },\n body: fd,\n });\n if (!r.ok) throw new Error(\"Whisper xatosi: \" + (await r.text()).slice(0, 200));\n return (await r.json()).text;\n}\n\n/* ---------- Fayl matnini ajratib olish (Word, Excel, matn) ---------- */\nasync function extractText(buf: Uint8Array, mime: string, fileName: string): Promise {\n // Oddiy matn fayllari\n if (/^text\\//.test(mime) || /json|xml|csv/.test(mime) || /\\.(txt|md|csv|json|xml|html?)$/i.test(fileName)) {\n return new TextDecoder(\"utf-8\", { fatal: false }).decode(buf).slice(0, 50000);\n }\n // Word (.docx)\n if (/\\.docx$/i.test(fileName)) {\n try {\n const JSZip = (await import(\"npm:jszip\")).default;\n const zip = await JSZip.loadAsync(buf);\n const xml = await zip.file(\"word/document.xml\")?.async(\"string\");\n if (xml) {\n return xml\n .replace(/]/g, \"\\n<\")\n .replace(/<[^>]+>/g, \"\")\n .replace(/[ \\t]+/g, \" \")\n .trim()\n .slice(0, 50000);\n }\n } catch (_) {}\n }\n // Excel (.xlsx)\n if (/\\.xlsx$/i.test(fileName)) {\n try {\n const XLSX = await import(\"npm:xlsx\");\n const wb = XLSX.read(buf, { type: \"array\" });\n let out = \"\";\n for (const name of wb.SheetNames.slice(0, 3)) {\n out += `\\n== Varaq: ${name} ==\\n` + XLSX.utils.sheet_to_csv(wb.Sheets[name]);\n }\n return out.trim().slice(0, 50000);\n } catch (_) {}\n }\n return null;\n}\n\n/* ---------- Tugmali menyu ---------- */\nconst MENU = {\n keyboard: [\n [{ text: \"🪪 Kontakt/Vizitka\" }, { text: \"💼 Investor qo'shish\" }],\n [{ text: \"⚠️ Muammo (saytga)\" }, { text: \"📄 Hujjat (Word)\" }],\n [{ text: \"❓ Savol berish\" }, { text: \"📊 Bugungi hisobot\" }],\n ],\n resize_keyboard: true,\n};\n\n/* Saytga muammo (ticket) qo'shish + fayl biriktirish */\nasync function problemAdd(blocks: any[], fileInfo: any, reply: (t: string, kb?: any) => Promise) {\n await reply(\"⚠️ Muammoni saytga qo'shyapman...\");\n const t = await extractTicket(blocks);\n if (!t.title || t.title.length < 3 || !t.description || t.description.length < 5) {\n return reply(\"⚠️ Muammo bayoni yetarli emas. Kamida bir-ikki jumla yozing.\", MENU);\n }\n let relatedProjectId: string | undefined;\n if (t.projectCode) { const m = await districtProjectMap(); relatedProjectId = m[t.projectCode.toUpperCase()]; }\n const tk: any = await siteCreateTicket({ title: t.title, description: t.description, category: t.category, relatedProjectId });\n await vlog(\"Saytga muammo: \" + t.title + (relatedProjectId ? \" (loyihaga bog'landi)\" : \"\"));\n let fileMsg = \"\";\n if (fileInfo && fileInfo.buf) {\n try {\n await siteUploadDoc(fileInfo.buf, fileInfo.name, fileInfo.mime, { relatedTicketId: tk.id, category: \"document\", ...(relatedProjectId ? { relatedProjectId } : {}) });\n fileMsg = \"\\n📎 Fayl biriktirildi: \" + fileInfo.name;\n } catch (e: any) { fileMsg = \"\\n⚠️ Fayl biriktirilmadi: \" + e.message; }\n }\n // platformaga ham (mahalliy ko'rinish uchun)\n await pushInbox({ type: \"record\", key: \"problems\", obj: { id: uid(), linkedId: \"\", text: t.title, status: \"open\", date: today(), source: \"sayt\", notes: t.description + \" | Sayt ticket: \" + (tk.code || tk.id) } });\n return reply(`✅ Muammo saytga qo'shildi!\\n⚠️ ${t.title}\\n📋 ${tk.code || tk.id}${relatedProjectId ? \"\\n🔗 Loyihaga bog'landi\" : \"\"}${fileMsg}\\n🌐 https://admin.investinkashkadarya.uz/tickets`, MENU);\n}\n\n/* Word hujjat yaratib, Telegramga fayl sifatida yuborish */\nasync function hujjatAdd(soro: string, chatId: any, reply: (t: string, kb?: any) => Promise) {\n await reply(\"📄 Hujjat tayyorlanmoqda... (biroz kuting)\");\n const text = await answerWithFable([{ type: \"text\", text: \"Quyidagi so'rov bo'yicha to'liq rasmiy hujjat matnini tayyorla (sarlavha, bo'limlar, punktlar bilan):\\n\\n\" + soro }]);\n const title = (text.split(\"\\n\").find((l) => l.trim()) || \"Hujjat\").replace(/[#*`]/g, \"\").trim().slice(0, 80);\n try {\n const bytes = await buildDocx(title, text);\n await tgSendDocument(chatId, (title.replace(/[^\\wа-яёa-zʻ' -]/gi, \"_\").slice(0, 50) || \"hujjat\") + \".docx\", bytes, \"📄 \" + title);\n return reply(\"✅ Hujjat tayyor — yuqorida fayl sifatida yuborildi.\", MENU);\n } catch (e: any) {\n await vlog(\"Docx xatosi: \" + e.message);\n return reply(text + \"\\n\\n(⚠️ Word fayl yaratilmadi: \" + e.message + \")\", MENU);\n }\n}\n\n/* Saytga kontakt/investor qo'shish (buyruq va tugmadan chaqiriladi) */\nasync function siteAdd(cmd: string, blocks: any[], reply: (t: string, kb?: any) => Promise) {\n const imgBlock = blocks.find((b) => b.type === \"image\");\n // VIZITKA + RASM: saytga scan orqali (rasm ham saqlanadi, OCR bilan)\n if (cmd !== \"investor\" && imgBlock) {\n await reply(\"🖼 Vizitka rasmini saytga yuklab, o'qiyapman...\");\n const bytes = Uint8Array.from(atob(imgBlock.source.data), (c) => c.charCodeAt(0));\n const card: any = await siteCardScan(bytes, \"card.jpg\", imgBlock.source.media_type);\n await vlog(\"Saytga vizitka (rasm bilan): \" + (card.companyName || card.personName || card.id));\n await pushInbox({ type: \"record\", key: \"partners\", obj: { id: uid(), nameUz: card.companyName || card.personName || \"Vizitka\", nameZh: \"\", contact: card.personName || \"\", phone: card.phone || \"\", wechat: \"\", email: card.email || \"\", city: card.country || \"\", industry: \"\", notes: \"Saytga rasm bilan yuklandi (vizitka) | \" + (card.rawOcrText || \"\").slice(0, 200) } });\n return reply(\n `✅ Vizitka RASM BILAN saytga yuklandi!\\n🏢 ${card.companyName || \"-\"}\\n👤 ${card.personName || \"-\"}\\n📞 ${card.phone || \"-\"}\\n📧 ${card.email || \"-\"}\\n🖼 Rasm saytda saqlandi\\n🌐 https://admin.investinkashkadarya.uz/business-cards`,\n MENU\n );\n }\n await reply(\"🌐 Saytga qo'shyapman...\");\n const f = await extractCard(blocks);\n if (cmd === \"investor\") {\n if (!f.companyName) return reply(\"⚠️ Kompaniya nomi aniqlanmadi. Qaytadan urinib ko'ring.\", MENU);\n const email = f.email || `investor_${Date.now()}@kashkadarya.local`;\n const pass = randPass();\n await siteCreateInvestor({ email, password: pass, firstName: (f.personName || \"Investor\").split(\" \")[0], lastName: (f.personName || \"\").split(\" \").slice(1).join(\" \") || \"-\", companyName: f.companyName, country: f.country || \"China\", sector: f.sector || \"other\" });\n await vlog(\"Saytga investor: \" + f.companyName);\n await pushInbox({ type: \"record\", key: \"partners\", obj: { id: uid(), nameUz: f.companyName, nameZh: \"\", contact: f.personName || \"\", phone: f.phone || \"\", wechat: \"\", email, city: f.country || \"China\", industry: f.sector || \"\", notes: \"Saytga investor sifatida qo'shildi | \" + (f.notes || \"\") } });\n return reply(`✅ Investor saytga qo'shildi!\\n🏢 ${f.companyName}\\n📧 ${email}\\n🔑 Parol: ${pass}\\n🌐 https://admin.investinkashkadarya.uz\\n\\n(parolni investorga yetkazing)`, MENU);\n }\n if (!f.companyName && !f.personName) return reply(\"⚠️ Kontakt ma'lumoti aniqlanmadi. Qaytadan urinib ko'ring.\", MENU);\n await siteCreateCard(f);\n await vlog(\"Saytga kontakt: \" + (f.companyName || f.personName));\n await pushInbox({ type: \"record\", key: \"partners\", obj: { id: uid(), nameUz: f.companyName || f.personName, nameZh: \"\", contact: f.personName || \"\", phone: f.phone || \"\", wechat: \"\", email: f.email || \"\", city: f.country || \"\", industry: f.sector || \"\", notes: \"Saytga kontakt sifatida qo'shildi | \" + (f.notes || \"\") } });\n return reply(`✅ Kontakt saytga qo'shildi!\\n🏢 ${f.companyName || \"-\"}\\n👤 ${f.personName || \"-\"}\\n📞 ${f.phone || \"-\"}\\n📧 ${f.email || \"-\"}\\n🌐 https://admin.investinkashkadarya.uz/business-cards\\n\\n(platforma Sheriklariga ham qo'shildi)`, MENU);\n}\n\n/* Xabardan rasm/matn bloklarini yig'ish */\nasync function msgToBlocks(msg: any, extraText?: string) {\n const blocks: any[] = [];\n if (msg.photo) {\n const sizes = msg.photo.filter((p: any) => p.width <= 1600);\n const ph = sizes.length ? sizes[sizes.length - 1] : msg.photo[0];\n const buf = await tgDownload(ph.file_id);\n blocks.push({ type: \"image\", source: { type: \"base64\", media_type: \"image/jpeg\", data: toB64(buf) } });\n }\n const txt = (extraText || msg.text || msg.caption || \"\").trim();\n if (txt) blocks.push({ type: \"text\", text: txt });\n return blocks;\n}\n\n/* Xabardagi faylni (rasm yoki hujjat) yuklab olish — muammoga biriktirish uchun */\nasync function msgFile(msg: any) {\n if (msg.document) {\n return { buf: await tgDownload(msg.document.file_id), name: msg.document.file_name || \"fayl\", mime: msg.document.mime_type || \"application/octet-stream\" };\n }\n if (msg.photo) {\n const ph = msg.photo[msg.photo.length - 1];\n return { buf: await tgDownload(ph.file_id), name: \"rasm.jpg\", mime: \"image/jpeg\" };\n }\n return null;\n}\n\n/* ---------- Xabarlarni qayta ishlash ---------- */\nasync function handleMessage(msg: any) {\n const chatId = msg.chat.id;\n const reply = (text: string, kb?: any) => tgApi(\"sendMessage\", { chat_id: chatId, text, ...(kb ? { reply_markup: kb } : {}) });\n\n if (ALLOWED.length && !ALLOWED.includes(String(msg.from.id))) {\n return reply(`⛔ Sizga ruxsat berilmagan.\\nSizning ID: ${msg.from.id}`);\n }\n\n try {\n const cmdText = (msg.text || msg.caption || \"\").trim();\n const modeKey = \"mode_\" + chatId;\n\n // ===== /start va yordam =====\n if (msg.text && (msg.text.startsWith(\"/start\") || msg.text.startsWith(\"/yordam\") || msg.text.startsWith(\"/help\"))) {\n await kvSet(modeKey, \"\");\n return reply(\n `Salom! 🇺🇿🇨🇳 Qashqadaryo — Xitoy platformasi botiman (24/7 bulutda).\\n\\n` +\n `Pastdagi tugmalardan foydalaning:\\n` +\n `🪪 Kontakt/Vizitka — saytga kontakt (rasm ham yuklanadi)\\n` +\n `💼 Investor qo'shish — saytga investor\\n` +\n `⚠️ Muammo (saytga) — muammoni saytga, fayl bilan\\n` +\n `📄 Hujjat (Word) — rasmiy hujjatni fayl qilib olish\\n` +\n `❓ Savol berish — har qanday savolga javob (Claude Fable 5)\\n` +\n `📊 Bugungi hisobot — kunlik holat\\n\\n` +\n `Shunchaki matn/ovoz/fayl yuborsangiz ham — o'zim tushunib joylayman.`,\n MENU\n );\n }\n\n // ===== TUGMALAR va BUYRUQLAR =====\n const norm = cmdText.toLowerCase();\n // Vizitka rejimi\n if (/🪪|^\\/vizitka\\b|^\\/kontakt\\b|kontakt\\/vizitka/i.test(cmdText)) {\n const rest = cmdText.replace(/^\\/(vizitka|kontakt)\\b/i, \"\").trim();\n const blocks = await msgToBlocks(msg, rest || undefined);\n if (blocks.length) { await kvSet(modeKey, \"\"); return siteAdd(\"vizitka\", blocks, reply); }\n await kvSet(modeKey, \"vizitka\");\n return reply(\"🪪 Vizitka rasmini yuboring yoki kontakt ma'lumotini yozing:\\n(kompaniya, ism, lavozim, telefon, email, davlat)\", MENU);\n }\n // Investor rejimi\n if (/💼|^\\/investor\\b|investor qo/i.test(cmdText)) {\n const rest = cmdText.replace(/^\\/investor\\b/i, \"\").trim();\n const blocks = await msgToBlocks(msg, rest || undefined);\n if (blocks.length) { await kvSet(modeKey, \"\"); return siteAdd(\"investor\", blocks, reply); }\n await kvSet(modeKey, \"investor\");\n return reply(\"💼 Investor ma'lumotini yozing yoki vizitkasini yuboring:\\n(kompaniya nomi, ism, email, davlat, soha)\", MENU);\n }\n // Muammo (saytga ticket) rejimi\n if (/⚠️|^\\/muammo\\b|muammo \$saytga\$/i.test(cmdText)) {\n const rest = cmdText.replace(/^\\/muammo\\b/i, \"\").replace(/⚠️\\s*muammo \$saytga\$/i, \"\").trim();\n const blocks = await msgToBlocks(msg, rest || undefined);\n if (blocks.length) { await kvSet(modeKey, \"\"); return problemAdd(blocks, await msgFile(msg), reply); }\n await kvSet(modeKey, \"muammo\");\n return reply(\"⚠️ Muammoni yozing (loyiha kodini ko'rsatsangiz — o'shanga bog'lanadi).\\nKerak bo'lsa fayl/rasm ham biriktiring:\", MENU);\n }\n // Hujjat (Word) rejimi\n if (/📄|^\\/hujjat\\b|hujjat \$word\$/i.test(cmdText)) {\n const rest = cmdText.replace(/^\\/hujjat\\b/i, \"\").replace(/📄\\s*hujjat \$word\$/i, \"\").trim();\n if (rest) { await kvSet(modeKey, \"\"); return hujjatAdd(rest, chatId, reply); }\n await kvSet(modeKey, \"hujjat\");\n return reply(\"📄 Qanday hujjat kerak? Yozing:\\n(masalan: \\\"Xitoy investoriga logistika markazi bo'yicha memorandum\\\", \\\"gazobeton loyihasi commercial offer\\\")\", MENU);\n }\n // Savol rejimi tugmasi\n if (/❓|^\\/savol\\b|savol berish/i.test(cmdText) && !msg.photo) {\n const rest = cmdText.replace(/^\\/savol\\b/i, \"\").replace(/❓\\s*savol berish/i, \"\").trim();\n if (!rest) { await kvSet(modeKey, \"\"); return reply(\"❓ Savolingizni yozing yoki ovozli xabar yuboring:\", MENU); }\n }\n // Hisobot tugmasi\n if (/📊|^\\/hisobot\\b|bugungi hisobot/i.test(cmdText)) {\n await kvSet(modeKey, \"\");\n await reply(\"📊 Hisobot tayyorlanmoqda...\");\n const bugun = new Date().toLocaleDateString(\"uz-UZ\", { day: \"2-digit\", month: \"2-digit\", year: \"numeric\" });\n const ans = await answerWithFable([{ type: \"text\", text: `Bugungi sana: ${bugun}. Rasmiy hisobot tuz.` }], true);\n return reply(ans, MENU);\n }\n\n // ===== FAOL REJIM (tugma bosilgach kelgan navbatdagi xabar) =====\n const mode = await kvGet(modeKey);\n if (mode && !norm.startsWith(\"/\")) {\n await kvSet(modeKey, \"\");\n if (mode === \"vizitka\" || mode === \"investor\") {\n const blocks = await msgToBlocks(msg);\n if (!blocks.length) return reply(\"Ma'lumot yoki rasm topilmadi. Qaytadan urinib ko'ring.\", MENU);\n return siteAdd(mode, blocks, reply);\n }\n if (mode === \"muammo\") {\n const blocks = await msgToBlocks(msg);\n if (!blocks.length) return reply(\"Muammo bayonini yozing.\", MENU);\n return problemAdd(blocks, await msgFile(msg), reply);\n }\n if (mode === \"hujjat\") {\n const soro = (msg.text || msg.caption || \"\").trim();\n if (!soro) return reply(\"Qanday hujjat kerakligini matn bilan yozing.\", MENU);\n return hujjatAdd(soro, chatId, reply);\n }\n }\n\n if (msg.text) {\n const p = await parseContent([{ type: \"text\", text: \"XABAR:\\n\" + msg.text }]);\n if (p.kind === \"question\") {\n await tgApi(\"sendChatAction\", { chat_id: chatId, action: \"typing\" });\n return reply(await answerWithFable([{ type: \"text\", text: msg.text }]));\n }\n return processParsed(p, \"\", reply);\n }\n if (msg.voice) {\n if (!OPENAI_KEY) return reply(\"🎤 Ovoz uchun OPENAI_API_KEY sozlanmagan. Matn yozing.\");\n const buf = await tgDownload(msg.voice.file_id);\n const text = await transcribeVoice(buf);\n if (!text?.trim()) return reply(\"Ovozni tushuna olmadim.\");\n await reply(`🎤 Eshitdim: \"${text}\"`);\n const p = await parseContent([{ type: \"text\", text: \"XABAR:\\n\" + text }]);\n if (p.kind === \"question\") {\n await tgApi(\"sendChatAction\", { chat_id: chatId, action: \"typing\" });\n return reply(await answerWithFable([{ type: \"text\", text }]));\n }\n return processParsed(p, \"Ovozli xabardan\", reply);\n }\n if (msg.photo || msg.document) {\n let fileId: string, fileName: string, mime: string;\n if (msg.document) {\n fileId = msg.document.file_id; fileName = msg.document.file_name || \"fayl\"; mime = msg.document.mime_type || \"\";\n } else {\n // Tezlik uchun: eng kattasini emas, ~1300px atrofidagi o'lchamni olamiz (tahlilga yetarli, 2-3x tez)\n const sizes = msg.photo.filter((p: any) => p.width <= 1600);\n const ph = sizes.length ? sizes[sizes.length - 1] : msg.photo[0];\n fileId = ph.file_id; fileName = \"rasm.jpg\"; mime = \"image/jpeg\";\n }\n const isImage = /^image\\/(jpeg|png|gif|webp)$/.test(mime);\n const isPdf = mime === \"application/pdf\";\n const isAudio = /^audio\\//.test(mime) || /\\.(mp3|m4a|ogg|wav|opus)$/i.test(fileName);\n const isTextLike = /^text\\//.test(mime) || /json|xml|csv/.test(mime) || /\\.(txt|md|csv|json|xml|html?|docx|xlsx)$/i.test(fileName);\n await vlog(`Fayl keldi: ${fileName} | mime:${mime || \"-\"} | rasm:${isImage} pdf:${isPdf} audio:${isAudio} matn:${isTextLike}`);\n\n if (!isImage && !isPdf && !isAudio && !isTextLike) {\n // Qo'llanmaydigan tur (video, arxiv...) — hujjat sifatida qayd etamiz\n await pushInbox({ type: \"record\", key: \"documents\", obj: { id: uid(), title: (msg.caption || fileName).slice(0, 120), type: \"other\", projectId: \"\", date: today(), status: \"pending\", notes: \"Telegram orqali kelgan fayl: \" + fileName } });\n return reply(\"✅ Fayl hujjat sifatida qayd etildi: \" + fileName + \"\\n(bu turdagi fayl mazmunini o'qiy olmayman — matn, rasm, PDF, Word, Excel yoki audio yuboring)\");\n }\n\n // Javob va yuklab olish parallel — vaqt yutamiz\n const emoji = isImage ? \"🖼 Rasmni ko'ryapman...\" : isAudio ? \"🎧 Eshityapman...\" : \"📎 Faylni o'qiyapman...\";\n const [, buf] = await Promise.all([reply(emoji), tgDownload(fileId)]);\n if ((isImage || isPdf) && buf.length > 4_800_000) return reply(\"Fayl juda katta (5MB dan kichik yuboring).\");\n\n let blocks: any[] = [];\n let manba = \"Fayldan (Telegram)\";\n if (isImage) {\n blocks = [{ type: \"image\", source: { type: \"base64\", media_type: mime, data: toB64(buf) } }];\n manba = \"Rasmdan (Telegram)\";\n } else if (isPdf) {\n blocks = [{ type: \"document\", source: { type: \"base64\", media_type: \"application/pdf\", data: toB64(buf) } }];\n manba = \"PDF fayldan (Telegram)\";\n } else if (isAudio) {\n if (!OPENAI_KEY) return reply(\"🎧 Audio fayl uchun OPENAI_API_KEY sozlanmagan. Matn yoki rasm yuboring.\");\n const text = await transcribeVoice(buf);\n if (!text?.trim()) return reply(\"Audioni tushuna olmadim.\");\n await reply(`🎧 Eshitdim: \"${text.slice(0, 300)}\"`);\n blocks = [{ type: \"text\", text: \"AUDIO FAYL MAZMUNI:\\n\" + text }];\n manba = \"Audio fayldan (\" + fileName + \")\";\n } else {\n const extracted = await extractText(buf, mime, fileName);\n await vlog(`Matn ajratildi: ${fileName} -> ${extracted ? extracted.length + \" belgi\" : \"BO'LMADI\"}`);\n if (!extracted) {\n await pushInbox({ type: \"record\", key: \"documents\", obj: { id: uid(), title: (msg.caption || fileName).slice(0, 120), type: \"other\", projectId: \"\", date: today(), status: \"pending\", notes: \"Telegram orqali kelgan fayl (o'qib bo'lmadi): \" + fileName } });\n return reply(\"✅ Fayl hujjat sifatida qayd etildi: \" + fileName);\n }\n blocks = [{ type: \"text\", text: `FAYL (${fileName}) MAZMUNI:\\n` + extracted }];\n manba = \"Fayldan (\" + fileName + \")\";\n }\n if (msg.caption) blocks.push({ type: \"text\", text: \"Foydalanuvchi izohi: \" + msg.caption });\n const p = await parseContent(blocks);\n await vlog(`Claude tahlili: ${fileName} -> ${p.action}/${p.kind} \"${p.title}\"`);\n if (p.kind === \"question\") { // fayl/rasm haqida savol -> Fable javob beradi\n await tgApi(\"sendChatAction\", { chat_id: chatId, action: \"typing\" });\n return reply(await answerWithFable(blocks));\n }\n return processParsed(p, manba, reply);\n }\n return reply(\"Bu turdagi xabarni qabul qilmayman. Matn, ovoz, rasm yoki PDF yuboring.\");\n } catch (e: any) {\n await vlog(\"XATO: \" + e.message);\n return reply(\"⚠️ Xatolik: \" + e.message);\n }\n}\n\n/* ---------- SAYT SINXRONI: bildirishnoma + menga biriktirilgan vazifalar ---------- */\nasync function kvGet(k: string): Promise {\n const r = await sqlite.execute({ sql: `SELECT v FROM qx_kv WHERE k=?`, args: [k] });\n return r.rows.length ? rowVal(r.rows[0], 0, \"v\") : \"\";\n}\nasync function kvSet(k: string, v: string) {\n await sqlite.execute({ sql: `INSERT INTO qx_kv (k, v) VALUES (?, ?) ON CONFLICT(k) DO UPDATE SET v = excluded.v`, args: [k, v] });\n}\nconst MY_CHAT = Deno.env.get(\"MY_CHAT_ID\") || \"\";\n\nasync function runSync() {\n if (!SITE_EMAIL) return { ok: false, reason: \"sayt sozlanmagan\" };\n let sentNotif = 0, tasks = 0;\n\n // 1) BILDIRISHNOMALAR -> Telegram\n try {\n const r = await siteFetch(\"/api/dashboard/notifications\");\n if (r.ok) {\n const list = await r.json();\n const seen = await kvGet(\"notif_seen\");\n const seenTime = seen ? new Date(seen).getTime() : Date.now() - 86400000; // birinchi safar: oxirgi 1 kun\n let maxTime = seenTime;\n // eskidan yangiga\n const fresh = (list as any[]).filter((n) => new Date(n.timestamp).getTime() > seenTime).reverse();\n for (const n of fresh) {\n maxTime = Math.max(maxTime, new Date(n.timestamp).getTime());\n if (MY_CHAT) {\n await tgApi(\"sendMessage\", { chat_id: MY_CHAT, text: `🔔 Sayt bildirishnomasi:\\n${n.title}${n.description ? \"\\n\" + n.description : \"\"}${n.actorName ? \"\\n👤 \" + n.actorName : \"\"}\\n\\nhttps://admin.investinkashkadarya.uz${n.href || \"\"}` });\n sentNotif++;\n }\n }\n await kvSet(\"notif_seen\", new Date(maxTime).toISOString());\n }\n } catch (e: any) { await vlog(\"Bildirishnoma sync xatosi: \" + e.message); }\n\n // 2) MENGA BIRIKTIRILGAN VAZIFALAR -> platforma (tasks)\n try {\n const r = await siteFetch(\"/api/dashboard/me\");\n if (r.ok) {\n const d = await r.json();\n const snap = await getSnapshot();\n // eski sayt vazifalarini olib tashlaymiz (site_ prefiksli)\n snap.tasks = (snap.tasks || []).filter((t: any) => !String(t.id).startsWith(\"site_\"));\n for (const tsk of (d.pendingTasks || [])) {\n snap.tasks.push({\n id: \"site_\" + tsk.id, text: (tsk.title || tsk.code) + (tsk.description ? \" — \" + tsk.description : \"\"),\n status: tsk.status === \"completed\" ? \"done\" : \"todo\",\n date: (tsk.dueDate || tsk.createdAt || \"\").slice(0, 10) || today(),\n source: \"sayt\", notes: \"Saytdagi vazifa \" + tsk.code + (tsk.priority ? \" | ustuvorlik: \" + tsk.priority : \"\"),\n });\n tasks++;\n }\n for (const m of (d.upcomingMeetings || [])) {\n snap.tasks.push({\n id: \"site_\" + m.id, text: \"📅 Uchrashuv: \" + (m.title || m.subject || m.code || \"\"),\n status: \"todo\", date: (m.scheduledAt || m.startAt || m.date || \"\").slice(0, 10) || today(),\n source: \"sayt\", notes: \"Saytdagi uchrashuv\" + (m.location ? \" | \" + m.location : \"\"),\n });\n tasks++;\n }\n await saveSnapshot(snap);\n }\n } catch (e: any) { await vlog(\"Vazifa sync xatosi: \" + e.message); }\n\n await vlog(`Sync: ${sentNotif} bildirishnoma, ${tasks} vazifa`);\n return { ok: true, notifications: sentNotif, tasks };\n}\n\n/* ---------- HTTP kirish nuqtasi ---------- */\nconst CORS = { \"Access-Control-Allow-Origin\": \"*\", \"Access-Control-Allow-Methods\": \"GET,POST,OPTIONS\", \"Access-Control-Allow-Headers\": \"content-type\" };\nconst jsonCors = (data: any) => new Response(JSON.stringify(data), { headers: { \"content-type\": \"application/json\", ...CORS } });\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const okSecret = (url.searchParams.get(\"secret\") || \"\") === APP_SECRET && APP_SECRET;\n if (req.method === \"OPTIONS\") return new Response(null, { headers: CORS });\n // Himoyalangan yo'llarga noto'g'ri kalit bilan kirilса — 401\n if (/^\\/(snapshot|chat|inbox|import|log)$/.test(url.pathname) && !okSecret) {\n return new Response(JSON.stringify({ error: \"unauthorized\" }), { status: 401, headers: { \"content-type\": \"application/json\", ...CORS } });\n }\n\n // Telegram webhook\n if (req.method === \"POST\" && url.pathname === \"/webhook\") {\n if (req.headers.get(\"x-telegram-bot-api-secret-token\") !== APP_SECRET) return new Response(\"no\", { status: 401 });\n const upd = await req.json();\n if (upd.message) await handleMessage(upd.message);\n return Response.json({ ok: true });\n }\n // Webhookni ro'yxatdan o'tkazish (bir marta ochiladi)\n if (url.pathname === \"/setup\" && okSecret) {\n const r = await tgApi(\"setWebhook\", { url: url.origin + \"/webhook\", secret_token: APP_SECRET });\n return Response.json(r);\n }\n // Bulutdan uzish (webhookni o'chirish)\n if (url.pathname === \"/uzish\" && okSecret) {\n return Response.json(await tgApi(\"deleteWebhook\", {}));\n }\n // Sayt sinxroni (interval chaqiradi): bildirishnoma + vazifalar\n if (url.pathname === \"/sync\" && okSecret) {\n return jsonCors(await runSync());\n }\n // Kuzatuv jurnali (diagnostika uchun)\n if (url.pathname === \"/log\" && okSecret) {\n const res = await sqlite.execute({ sql: `SELECT t, msg FROM qx_log ORDER BY id DESC LIMIT 60`, args: [] });\n const lines = res.rows.map((r: any) => `${rowVal(r, 0, \"t\")} ${rowVal(r, 1, \"msg\")}`);\n return new Response(lines.join(\"\\n\") || \"jurnal bo'sh\", { headers: { \"content-type\": \"text/plain; charset=utf-8\" } });\n }\n // Dastur yangi yozuvlarni oladi\n if (url.pathname === \"/inbox\" && okSecret) {\n const res = await sqlite.execute({ sql: `SELECT id, payload FROM qx_inbox ORDER BY id`, args: [] });\n const items = res.rows.map((r: any) => ({ id: rowVal(r, 0, \"id\"), payload: rowVal(r, 1, \"payload\") }));\n if (items.length) await sqlite.execute({ sql: `DELETE FROM qx_inbox WHERE id <= ?`, args: [items[items.length - 1].id] });\n return Response.json(items.map((i) => JSON.parse(i.payload)));\n }\n // Tashqi tizimdan ommaviy import (masalan investinkashkadarya.uz dan)\n if (url.pathname === \"/import\" && req.method === \"POST\" && okSecret) {\n const events = await req.json();\n if (!Array.isArray(events)) return new Response(\"array kutilgan\", { status: 400 });\n for (const ev of events.slice(0, 100)) await pushInbox(ev);\n await vlog(`Import: ${events.length} ta yozuv qabul qilindi`);\n return Response.json({ ok: true, count: events.length });\n }\n // Dastur ma'lumotlar nusxasini yuboradi (POST) yoki oladi (GET) — onlayn platforma uchun\n if (url.pathname === \"/snapshot\" && okSecret) {\n if (req.method === \"POST\") {\n const body = await req.text();\n await sqlite.execute({ sql: `INSERT INTO qx_kv (k, v) VALUES ('snapshot', ?) ON CONFLICT(k) DO UPDATE SET v = excluded.v`, args: [body] });\n return jsonCors({ ok: true });\n }\n return jsonCors(await getSnapshot());\n }\n // Onlayn platforma Claude yordamchisi (Fable 5, refusalda Opus 4.8)\n if (url.pathname === \"/chat\" && req.method === \"POST\" && okSecret) {\n try {\n const { messages } = await req.json();\n const ctx = await siteContext();\n const sys = ANSWER_SYSTEM + \"\\n\\n\" + ctx;\n let resp;\n try {\n resp = await client.beta.messages.create({\n model: \"claude-fable-5\", max_tokens: 3000, output_config: { effort: \"medium\" },\n betas: [\"server-side-fallback-2026-06-01\"], fallbacks: [{ model: \"claude-opus-4-8\" }],\n system: sys, messages,\n } as any);\n } catch (_) {\n resp = await client.messages.create({ model: \"claude-opus-4-8\", max_tokens: 3000, thinking: { type: \"adaptive\" }, system: sys, messages } as any);\n }\n return jsonCors({ text: (resp.content as any[]).filter((b) => b.type === \"text\").map((b) => b.text).join(\"\\n\") });\n } catch (e: any) { return jsonCors({ error: e.message }); }\n }\n return new Response(\"Qashqadaryo — Xitoy platformasi boti ishlayapti ✅\", { headers: { \"content-type\": \"text/plain; charset=utf-8\" } });\n}\n","createdAt",["D",1783207824667],"branchVersion","branchId","f4c3811e-72d2-4a20-bcb5-6059864e675d","id","32c0d8ee-556b-4aaa-8a2c-ad0e8131788e","qx-bot",["D",1783178791890],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","3520a3e2-ee4d-43e8-8ee0-ad96cb331ca1","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019f2db3-afef-725b-b34f-1367a986844e","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_94":93,"_102":98},"org",{"_94":93,"_95":96,"_97":98,"_18":54,"_99":100,"_101":25},"branch",{"_13":83,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"isOwned",23,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","sherzodeshonkulov","handle","displayName","Sherzod Eshonkulov","avatar","https://lh3.googleusercontent.com/a/ACg8ocIIA9i1wHpBTlMuNOOZOUx1dtwqz_pVTbuceC_h5zKRQHf8nrA=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":176,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":-5,"_64":-5,"_65":-5,"_66":-5,"_67":68,"_69":68,"_70":71,"_72":71,"_73":71,"_74":68,"_75":68,"_76":177,"_78":178,"_80":179,"_82":25},"tree",[163,164,165],"files",[163,164,165],"counts",{"_152":60,"_153":145,"_154":60,"_155":156,"_157":158},"contents",[126,127,128],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":148,"_32":28,"_30":31,"_132":-5,"_41":42,"_40":14,"_134":25,"_38":149,"_13":150,"_33":34,"_35":37,"_24":25,"_138":-5,"_27":151},{"_43":140,"_32":141,"_30":142,"_132":-5,"_41":42,"_40":143,"_134":121,"_38":144,"_13":145,"_33":136,"_35":146,"_24":25,"_138":-5,"_27":147},{"_43":129,"_32":130,"_30":131,"_132":-5,"_41":42,"_40":133,"_134":121,"_38":135,"_13":60,"_33":136,"_35":137,"_24":25,"_138":-5,"_27":139},"47be76a3-933f-4a35-a714-f951ed745491","sync.ts","c3da409a-77f3-11f1-bdde-1607ee4eb77e","parentId",13,"latest",["D",1783202427142],"interval","// Qashqadaryo — Xitoy platformasi: SAYT SINXRONI (interval)\n// Val Town interval val. Har ~2 daqiqada bot'ning /sync yo'lini chaqiradi:\n// - saytdagi bildirishnomalarni Telegramga yuboradi\n// - menga biriktirilgan vazifalarni platformaga tortadi\n// Jadval (schedule): */2 * * * * (har 2 daqiqada)\nconst BOT = \"https://sherzodeshonkulov--dc1ca10277bc11f1a4801607ee4eb77e.web.val.run\";\nconst SECRET = Deno.env.get(\"APP_SECRET\") || \"\";\n\nexport default async function () {\n if (!SECRET) return;\n try {\n const r = await fetch(BOT + \"/sync?secret=\" + encodeURIComponent(SECRET));\n console.log(\"sync:\", await r.text());\n } catch (e) {\n console.log(\"sync xatosi:\", (e as Error).message);\n }\n}\n","label",[130],"a9b4be9d-e986-4836-8dfa-7ebeeff551e1","kunlik.ts","edbb693e-77bc-11f1-8eba-1607ee4eb77e",11,["D",1783186062849],1,"// ============================================================\n// Qashqadaryo — Xitoy platformasi: KUNLIK AVTOMATIK REJA (bulut)\n// Val Town uchun CRON val. Bot bilan bir xil loyihaga qo'shiladi.\n//\n// Jadval (schedule): 0 3 * * * (UTC 03:00 = Toshkent 08:00)\n// Kerakli muhit o'zgaruvchilari bot bilan bir xil:\n// TELEGRAM_TOKEN, ANTHROPIC_API_KEY, ALLOWED_IDS\n// ============================================================\nimport { sqlite } from \"https://esm.town/v/std/sqlite\";\nimport Anthropic from \"npm:@anthropic-ai/sdk\";\n\nconst TG = Deno.env.get(\"TELEGRAM_TOKEN\") || \"\";\nconst CLAUDE_KEY = Deno.env.get(\"ANTHROPIC_API_KEY\") || \"\";\nconst ALLOWED = (Deno.env.get(\"ALLOWED_IDS\") || \"\").split(\",\").map((s) => s.trim()).filter(Boolean);\n\nconst uid = () => Date.now().toString(36) + Math.random().toString(36).slice(2, 6);\nconst today = () => new Date().toISOString().slice(0, 10);\nconst rowVal = (row: any, i: number, name: string) => (Array.isArray(row) ? row[i] : row[name]);\n\nasync function getSnapshot(): Promise {\n const empty = { tasks: [], projects: [], trades: [], partners: [], documents: [], problems: [] };\n try {\n const r = await sqlite.execute({ sql: `SELECT v FROM qx_kv WHERE k='snapshot'`, args: [] });\n if (!r.rows.length) return empty;\n return { ...empty, ...JSON.parse(rowVal(r.rows[0], 0, \"v\")) };\n } catch { return empty; }\n}\n\nfunction catalogText(snap: any) {\n const lines: string[] = [];\n const add = (label: string, arr: any[], f: (x: any) => string) => {\n lines.push(\"## \" + label);\n (arr || []).slice(-40).forEach((x) => lines.push(f(x)));\n };\n add(\"LOYIHALAR\", snap.projects, (x) => `${x.name} | holat:${x.status} | ${x.progress || 0}% | tuman:${x.district || \"-\"}`);\n add(\"SAVDO BITIMLARI\", snap.trades, (x) => `${x.name} | ${x.type} | holat:${x.status}`);\n add(\"MUAMMOLAR (ochiq)\", (snap.problems || []).filter((p: any) => p.status === \"open\"), (x) => `${x.text}`);\n add(\"REJADAGI ISHLAR\", (snap.tasks || []).filter((t: any) => t.status === \"todo\"), (x) => `${x.text} (${x.date})`);\n return lines.join(\"\\n\");\n}\n\nconst DAILY_SCHEMA = {\n type: \"object\",\n additionalProperties: false,\n required: [\"digest\", \"tasks\"],\n properties: {\n digest: { type: \"string\" },\n tasks: { type: \"array\", items: { type: \"object\", additionalProperties: false, required: [\"text\"], properties: { text: { type: \"string\" } } } },\n },\n};\nconst DAILY_SYSTEM = `Sen Qashqadaryo-Xitoy loyihalar boshqaruvchisining rejalashtiruvchi yordamchisisan.\nBerilgan yozuvlar asosida BUGUN qilinishi kerak bo'lgan ishlar rejasini tuz:\n- Ochiq muammolar (⚠️) - eng ustuvor, hal qilish bo'yicha aniq qadam\n- Muzokara/tasdiqlash bosqichidagi loyihalar - keyingi qadam\n- Jarayondagi loyihalar - nazorat qadamlari\n- Eski rejadagi ishlar - eslat\nQoidalar: tasks ga ENG KO'PI 5 ta ish. Mavjud rejadagilarni TAKRORLAMA. digest - qisqa kunlik xulosa (Telegram uchun, emoji bilan). Hammasi o'zbekcha.`;\n\nexport default async function () {\n if (!CLAUDE_KEY || !TG) return;\n const snap = await getSnapshot();\n if (!(snap.projects.length || snap.trades.length || snap.tasks.length)) return;\n\n const client = new Anthropic({ apiKey: CLAUDE_KEY });\n const resp = await client.messages.create({\n model: \"claude-sonnet-5\",\n max_tokens: 3000,\n thinking: { type: \"disabled\" },\n system: DAILY_SYSTEM,\n output_config: { format: { type: \"json_schema\", schema: DAILY_SCHEMA } },\n messages: [{ role: \"user\", content: \"MAVJUD YOZUVLAR:\\n\" + catalogText(snap) + \"\\n\\nBugungi sana: \" + today() }],\n } as any);\n const plan = JSON.parse(((resp.content as any[]).find((b) => b.type === \"text\")).text);\n\n // Ishlarni platformaga qo'shamiz (bulut bazasi + dastur navbati)\n const snapNow = await getSnapshot();\n for (const task of (plan.tasks || []).slice(0, 5)) {\n const ev = { type: \"record\", key: \"tasks\", obj: { id: uid(), text: task.text, status: \"todo\", date: today(), source: \"avto\", notes: \"Kunlik avtomatik reja\" } };\n await sqlite.execute({\n sql: `INSERT INTO qx_inbox (payload, created) VALUES (?, ?)`,\n args: [JSON.stringify(ev), new Date().toISOString()],\n });\n (snapNow.tasks = snapNow.tasks || []).push(ev.obj);\n }\n await sqlite.execute({ sql: `INSERT INTO qx_kv (k, v) VALUES ('snapshot', ?) ON CONFLICT(k) DO UPDATE SET v = excluded.v`, args: [JSON.stringify(snapNow)] });\n\n // Telegramga kunlik xulosani yuboramiz\n const text = \"🌅 Bugungi reja:\\n\\n\" + plan.digest + \"\\n\\n\" + (plan.tasks || []).map((x: any, i: number) => `${i + 1}. ${x.text}`).join(\"\\n\");\n for (const id of ALLOWED) {\n await fetch(`https://api.telegram.org/bot${TG}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: id, text }),\n });\n }\n}\n",[141],"cf25035b-af12-4f7c-91d3-5c914d34cb79",["D",1783207824667],15,[28],"pulls","branches","forks","envVars",{"_159":161,"_162":60},"connections",{"_159":60,"_160":60},"count","unfilledCount",10,"emptyCount",{"_43":148,"_32":28,"_30":31,"_132":-5,"_41":42,"_40":14,"_134":25,"_38":173,"_13":150,"_33":34,"_35":37,"_24":25,"_138":-5,"_167":174,"_27":175},{"_43":140,"_32":141,"_30":142,"_132":-5,"_41":42,"_40":143,"_134":121,"_38":170,"_13":145,"_33":136,"_35":146,"_24":25,"_138":-5,"_167":171,"_27":172},{"_43":129,"_32":130,"_30":131,"_132":-5,"_41":42,"_40":133,"_134":121,"_38":166,"_13":60,"_33":136,"_35":137,"_24":25,"_138":-5,"_167":168,"_27":169},["D",1783202427142],"children",[],[130],["D",1783186062849],[],[141],["D",1783207824667],[],[28],["D",1783178791890],{"_94":93,"_102":98},{"_94":93,"_95":96,"_97":98,"_18":54,"_99":100,"_101":25},{"_13":83,"_32":84,"_43":42,"_85":44,"_86":-5,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":45,"_92":93},"ctx",{"_76":-5,"_123":213,"_214":215,"_216":217,"_218":25,"_219":25,"_220":25,"_221":121,"_222":-5,"_223":-7,"_224":-7,"_225":60,"_226":25,"_227":25,"_228":-5,"_229":25,"_230":25,"_231":25,"_232":-5},"ENV",{"_184":185,"_186":187,"_188":84,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200,"_201":202,"_203":204,"_205":206,"_207":208,"_209":210,"_211":212},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","fdb67791413f4386b4dbf18f354029a617f6160f","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v19