[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_167":168,"_169":170},"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",3,"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)`);\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 pushInbox(payload: any) {\n await sqlite.execute({ sql: `INSERT INTO qx_inbox (payload, created) VALUES (?, ?)`, args: [JSON.stringify(payload), new Date().toISOString()] });\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/* ---------- 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\"],\n properties: {\n action: { type: \"string\", enum: [\"add\", \"update\"] },\n kind: { type: \"string\", enum: [\"task\", \"project\", \"trade\", \"partner\", \"document\", \"problem\"] },\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 },\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 YANGI yozuv qo'shishmi yoki MAVJUD yozuvni yangilashmi - aniqlash.\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\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\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}`);\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: 2000,\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/* ---------- Yozuv yaratish / yangilash ---------- */\nconst KIND_UZ: any = { task: \"Kunlik ish\", project: \"Investitsiya loyihasi\", trade: \"Savdo bitimi\", partner: \"Sherik\", document: \"Hujjat\", problem: \"Muammo ⚠️\" };\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: \"\", 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 === \"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(dastur ochilganda ko'rinadi)`);\n }\n }\n const rec = recordFromParse(p, extraNotes);\n await pushInbox({ type: \"record\", ...rec });\n return reply(`✅ Qo'shildi: ${KIND_UZ[p.kind]}\\n\"${p.title}\"${p.kind === \"task\" ? (p.status === \"done\" ? \" — bajarilgan ✔️\" : \" — rejaga yozildi 📌\") : \"\"}\\n\\n(dastur ochilganda ko'rinadi)`);\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 fd.append(\"language\", \"uz\");\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/* ---------- Xabarlarni qayta ishlash ---------- */\nasync function handleMessage(msg: any) {\n const chatId = msg.chat.id;\n const reply = (text: string) => tgApi(\"sendMessage\", { chat_id: chatId, text });\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 if (msg.text && msg.text.startsWith(\"/start\")) {\n return reply(`Salom! 🇺🇿🇨🇳 Qashqadaryo — Xitoy platformasi botiman (bulut rejimi — 24/7 ishlayman).\\n\\n📝 Matn, 🎤 ovoz, 📎 fayl yuboring.\\nSizning ID: ${msg.from.id}`);\n }\n if (msg.text) {\n const p = await parseContent([{ type: \"text\", text: \"XABAR:\\n\" + msg.text }]);\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 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 const ph = msg.photo[msg.photo.length - 1];\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 if (!isImage && !isPdf) {\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 }\n await reply(isImage ? \"🖼 Rasmni ko'ryapman...\" : \"📎 Faylni o'qiyapman...\");\n const buf = await tgDownload(fileId);\n if (buf.length > 4_800_000) return reply(\"Fayl juda katta (5MB dan kichik yuboring).\");\n const blocks: any[] = [\n isImage\n ? { type: \"image\", source: { type: \"base64\", media_type: mime, data: toB64(buf) } }\n : { type: \"document\", source: { type: \"base64\", media_type: \"application/pdf\", data: toB64(buf) } },\n ];\n if (msg.caption) blocks.push({ type: \"text\", text: \"Foydalanuvchi izohi: \" + msg.caption });\n const p = await parseContent(blocks);\n return processParsed(p, isImage ? \"Rasmdan (Telegram)\" : \"PDF fayldan (Telegram)\", reply);\n }\n return reply(\"Bu turdagi xabarni qabul qilmayman. Matn, ovoz, rasm yoki PDF yuboring.\");\n } catch (e: any) {\n return reply(\"⚠️ Xatolik: \" + e.message);\n }\n}\n\n/* ---------- HTTP kirish nuqtasi ---------- */\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\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 // 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 // Dastur ma'lumotlar nusxasini yuboradi\n if (url.pathname === \"/snapshot\" && req.method === \"POST\" && okSecret) {\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 Response.json({ ok: true });\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)`);\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 pushInbox(payload: any) {\n await sqlite.execute({ sql: `INSERT INTO qx_inbox (payload, created) VALUES (?, ?)`, args: [JSON.stringify(payload), new Date().toISOString()] });\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/* ---------- 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\"] },\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 YANGI yozuv qo'shishmi yoki MAVJUD yozuvni yangilashmi - aniqlash.\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\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: 2000,\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/* ---------- Yozuv yaratish / yangilash ---------- */\nconst KIND_UZ: any = { task: \"Kunlik ish\", project: \"Investitsiya loyihasi\", trade: \"Savdo bitimi\", partner: \"Sherik\", document: \"Hujjat\", problem: \"Muammo ⚠️\" };\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(dastur ochilganda ko'rinadi)`);\n }\n }\n const rec = recordFromParse(p, extraNotes);\n await pushInbox({ type: \"record\", ...rec });\n let msg = `✅ Qo'shildi: ${KIND_UZ[p.kind]}\\n\"${p.title}\"${p.kind === \"task\" ? (p.status === \"done\" ? \" — bajarilgan ✔️\" : \" — rejaga yozildi 📌\") : \"\"}`;\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(dastur ochilganda ko'rinadi)\");\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 fd.append(\"language\", \"uz\");\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/* ---------- Xabarlarni qayta ishlash ---------- */\nasync function handleMessage(msg: any) {\n const chatId = msg.chat.id;\n const reply = (text: string) => tgApi(\"sendMessage\", { chat_id: chatId, text });\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 if (msg.text && msg.text.startsWith(\"/start\")) {\n return reply(`Salom! 🇺🇿🇨🇳 Qashqadaryo — Xitoy platformasi botiman (bulut rejimi — 24/7 ishlayman).\\n\\n📝 Matn, 🎤 ovoz, 📎 fayl yuboring.\\nSizning ID: ${msg.from.id}`);\n }\n if (msg.text) {\n const p = await parseContent([{ type: \"text\", text: \"XABAR:\\n\" + msg.text }]);\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 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 const ph = msg.photo[msg.photo.length - 1];\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 if (!isImage && !isPdf) {\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 }\n await reply(isImage ? \"🖼 Rasmni ko'ryapman...\" : \"📎 Faylni o'qiyapman...\");\n const buf = await tgDownload(fileId);\n if (buf.length > 4_800_000) return reply(\"Fayl juda katta (5MB dan kichik yuboring).\");\n const blocks: any[] = [\n isImage\n ? { type: \"image\", source: { type: \"base64\", media_type: mime, data: toB64(buf) } }\n : { type: \"document\", source: { type: \"base64\", media_type: \"application/pdf\", data: toB64(buf) } },\n ];\n if (msg.caption) blocks.push({ type: \"text\", text: \"Foydalanuvchi izohi: \" + msg.caption });\n const p = await parseContent(blocks);\n return processParsed(p, isImage ? \"Rasmdan (Telegram)\" : \"PDF fayldan (Telegram)\", reply);\n }\n return reply(\"Bu turdagi xabarni qabul qilmayman. Matn, ovoz, rasm yoki PDF yuboring.\");\n } catch (e: any) {\n return reply(\"⚠️ Xatolik: \" + e.message);\n }\n}\n\n/* ---------- HTTP kirish nuqtasi ---------- */\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\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 // 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 // Dastur ma'lumotlar nusxasini yuboradi\n if (url.pathname === \"/snapshot\" && req.method === \"POST\" && okSecret) {\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 Response.json({ ok: true });\n }\n return new Response(\"Qashqadaryo — Xitoy platformasi boti ishlayapti ✅\", { headers: { \"content-type\": \"text/plain; charset=utf-8\" } });\n}\n","createdAt",["D",1783179333591],"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":163,"_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":164,"_78":165,"_80":166,"_82":25},"tree",[154,155],"files",[154,155],"counts",{"_143":60,"_144":141,"_145":60,"_146":147,"_148":149},"contents",[126,127],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":139,"_32":28,"_30":31,"_131":-5,"_41":42,"_40":14,"_133":25,"_38":140,"_13":141,"_33":34,"_35":37,"_24":25,"_137":-5,"_27":142},{"_43":128,"_32":129,"_30":130,"_131":-5,"_41":42,"_40":132,"_133":25,"_38":134,"_13":60,"_33":135,"_35":136,"_24":25,"_137":-5,"_27":138},"ace79d95-e30c-45f0-a2e1-8abb29431a0c","kunlik.ts","edbb693e-77bc-11f1-8eba-1607ee4eb77e","parentId",2,"latest",["D",1783178875070],"interval","// ============================================================\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 platforma navbatiga qo'shamiz (dastur ochilganda tushadi)\n for (const task of (plan.tasks || []).slice(0, 5)) {\n await sqlite.execute({\n sql: `INSERT INTO qx_inbox (payload, created) VALUES (?, ?)`,\n args: [JSON.stringify({ type: \"record\", key: \"tasks\", obj: { id: uid(), text: task.text, status: \"todo\", date: today(), source: \"avto\", notes: \"Kunlik avtomatik reja\" } }), new Date().toISOString()],\n });\n }\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","label",[129],"c266ae37-4a97-4ac3-bb91-f5eb16edf72f",["D",1783179333591],1,[28],"pulls","branches","forks","envVars",{"_150":152,"_153":60},"connections",{"_150":60,"_151":60},"count","unfilledCount",10,"emptyCount",{"_43":139,"_32":28,"_30":31,"_131":-5,"_41":42,"_40":14,"_133":25,"_38":160,"_13":141,"_33":34,"_35":37,"_24":25,"_137":-5,"_157":161,"_27":162},{"_43":128,"_32":129,"_30":130,"_131":-5,"_41":42,"_40":132,"_133":25,"_38":156,"_13":60,"_33":135,"_35":136,"_24":25,"_137":-5,"_157":158,"_27":159},["D",1783178875070],"children",[],[129],["D",1783179333591],[],[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":200,"_201":202,"_203":204,"_205":25,"_206":25,"_207":25,"_208":121,"_209":-5,"_210":-7,"_211":-7,"_212":60,"_213":25,"_214":25,"_215":-5,"_216":25,"_217":25,"_218":25,"_219":-5},"ENV",{"_171":172,"_173":174,"_175":84,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","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 · v3