[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_428":429,"_430":431},"routes/_app.x.$handle.$name",{"_100":99,"_32":45,"_109":90,"_27":110,"_13":14,"_111":-5,"_11":112,"_113":114,"_115":116,"_117":118,"_119":120,"_20":-5,"_121":-5,"_122":-5,"_123":25,"_124":125,"_126":59,"_127":-5,"_128":-5,"_129":130},"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":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":25},"version",83,"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","reviewCron.ts","latestPath","fileId","caadb194-7ec0-11f1-ac6b-1607ee4eb77e","name","fileType","interval","content","// ⏰ كرون مراجعة الخطة — يشغّل محرّك المراجعة (review.ts) دوريًا وينشر قرار المجلس + التصعيدات في Slack.\n// الإيقاع الحالي: كل ساعة (رتم عالٍ مبدئيًا — يُخفَّض لاحقًا من إعدادات الـinterval). يقرأ VT_TEAM_KEY.\nconst REVIEW = \"https://asnfq50--d6fdeb647ebe11f1985e1607ee4eb77e.web.val.run\";\n\nexport default async function () {\n const key = Deno.env.get(\"VT_TEAM_KEY\");\n const headers: Record = { \"content-type\": \"application/json\" };\n if (key) headers[\"authorization\"] = `Bearer ${key}`;\n try {\n const res = await fetch(REVIEW, { method: \"POST\", headers, body: JSON.stringify({ postSlack: true }) });\n const d = await res.json().catch(() => ({}));\n console.log(\"review cron:\", res.status, \"· updates:\", d?.updates_applied, \"· escalations:\", d?.escalations, \"· slack:\", d?.slackPosted);\n } catch (e) {\n console.log(\"review cron failed:\", String(e).slice(0, 160));\n }\n}\n","// ⏰ كرون مراجعة الخطة — يشغّل محرّك المراجعة (review.ts) دوريًا وينشر قرار المجلس + التصعيدات في Slack.\n// الإيقاع الحالي: كل ساعة (رتم عالٍ مبدئيًا — يُخفَّض لاحقًا من إعدادات الـinterval). يقرأ VT_TEAM_KEY.\nconst REVIEW = \"https://asnfq50--d6fdeb647ebe11f1985e1607ee4eb77e.web.val.run\";\n\nexport default async function () {\n // الإيقاع: يُطلَق كل ساعة لكن يشغّل المراجعة فعليًا كل ~8 ساعات (الساعات 0/8/16 UTC).\n // لا شيء يتغيّر من ساعة لأخرى، فالإطلاقات الفارغة كلفتها معدومة.\n if (new Date().getUTCHours() % 8 !== 0) return;\n const key = Deno.env.get(\"VT_TEAM_KEY\");\n const headers: Record = { \"content-type\": \"application/json\" };\n if (key) headers[\"authorization\"] = `Bearer ${key}`;\n try {\n const res = await fetch(REVIEW, { method: \"POST\", headers, body: JSON.stringify({ postSlack: true }) });\n const d = await res.json().catch(() => ({}));\n console.log(\"review cron:\", res.status, \"· updates:\", d?.updates_applied, \"· escalations:\", d?.escalations, \"· slack:\", d?.slackPosted);\n } catch (e) {\n console.log(\"review cron failed:\", String(e).slice(0, 160));\n }\n}\n","createdAt",["D",1784017220617],"branchVersion","branchId","1243f817-0d97-4744-95b6-602e019ed6e1","id","17ce3488-eab8-4846-a375-831957209321","virtual-team",["D",1783792190948],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Virtual AI team — shared memory + orchestration backbone","imageUrl","cca8102f-07bb-4295-b44a-38d66d1d3405","pinnedFileId","fb2957b8-7d50-11f1-b204-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019f1d6e-b169-7628-a2c5-3fdc2bb2972f","tursoName","17ce3488eab84846a375831957209321","tursoHostname","17ce3488eab84846a375831957209321-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789526460011],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_100":99,"_108":104},"org",{"_100":99,"_101":102,"_103":104,"_18":55,"_105":106,"_107":25},"branch",{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"isOwned",107,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","asnfq50","handle","displayName","mfcbr4krn8-hash","avatar","https://avatars.githubusercontent.com/u/294484094?v=4","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":423,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":424,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":425,"_84":426,"_86":427,"_88":25},"tree",[306,311,312,313,314,315,316,317,318,319,320,321,322,323,324,325,326,327,328,329],"files",[306,307,308,309,310,311,312,313,314,315,316,317,318,319,320,321,322,323,324,325,326,327,328,329],"counts",{"_295":63,"_296":167,"_297":63,"_298":299,"_300":301},"contents",[131,132,133,134,135,136,137,138,139,140,141,142,143,144,145,146,147,148,149,150],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":289,"_32":290,"_30":291,"_154":-5,"_41":42,"_40":196,"_156":59,"_38":292,"_13":63,"_33":293,"_35":-5,"_24":25,"_160":-5,"_27":294},{"_43":281,"_32":282,"_30":283,"_154":-5,"_41":42,"_40":284,"_156":25,"_38":285,"_13":286,"_33":158,"_35":287,"_24":25,"_160":-5,"_27":288},{"_43":274,"_32":275,"_30":276,"_154":-5,"_41":42,"_40":277,"_156":25,"_38":278,"_13":63,"_33":242,"_35":279,"_24":25,"_160":-5,"_27":280},{"_43":267,"_32":268,"_30":269,"_154":-5,"_41":42,"_40":270,"_156":59,"_38":271,"_13":257,"_33":158,"_35":272,"_24":25,"_160":-5,"_27":273},{"_43":260,"_32":261,"_30":262,"_154":-5,"_41":42,"_40":263,"_156":59,"_38":264,"_13":63,"_33":158,"_35":265,"_24":25,"_160":-5,"_27":266},{"_43":252,"_32":253,"_30":254,"_154":-5,"_41":42,"_40":255,"_156":59,"_38":256,"_13":257,"_33":242,"_35":258,"_24":25,"_160":-5,"_27":259},{"_43":245,"_32":246,"_30":247,"_154":-5,"_41":42,"_40":248,"_156":59,"_38":249,"_13":63,"_33":34,"_35":250,"_24":25,"_160":-5,"_27":251},{"_43":238,"_32":239,"_30":240,"_154":-5,"_41":42,"_40":167,"_156":59,"_38":241,"_13":63,"_33":242,"_35":243,"_24":25,"_160":-5,"_27":244},{"_43":233,"_32":234,"_30":57,"_154":-5,"_41":42,"_40":207,"_156":59,"_38":235,"_13":167,"_33":158,"_35":236,"_24":25,"_160":-5,"_27":237},{"_43":225,"_32":226,"_30":227,"_154":-5,"_41":42,"_40":228,"_156":59,"_38":229,"_13":230,"_33":158,"_35":231,"_24":25,"_160":-5,"_27":232},{"_43":217,"_32":218,"_30":219,"_154":-5,"_41":42,"_40":220,"_156":59,"_38":221,"_13":222,"_33":158,"_35":223,"_24":25,"_160":-5,"_27":224},{"_43":210,"_32":211,"_30":212,"_154":-5,"_41":42,"_40":213,"_156":59,"_38":214,"_13":167,"_33":158,"_35":215,"_24":25,"_160":-5,"_27":216},{"_43":202,"_32":203,"_30":204,"_154":-5,"_41":42,"_40":205,"_156":25,"_38":206,"_13":207,"_33":158,"_35":208,"_24":25,"_160":-5,"_27":209},{"_43":199,"_32":28,"_30":31,"_154":-5,"_41":42,"_40":14,"_156":59,"_38":200,"_13":167,"_33":34,"_35":37,"_24":25,"_160":-5,"_27":201},{"_43":191,"_32":192,"_30":193,"_154":-5,"_41":42,"_40":194,"_156":59,"_38":195,"_13":196,"_33":158,"_35":197,"_24":25,"_160":-5,"_27":198},{"_43":184,"_32":185,"_30":186,"_154":-5,"_41":42,"_40":187,"_156":25,"_38":188,"_13":63,"_33":158,"_35":189,"_24":25,"_160":-5,"_27":190},{"_43":177,"_32":178,"_30":179,"_154":-5,"_41":42,"_40":180,"_156":59,"_38":181,"_13":63,"_33":158,"_35":182,"_24":25,"_160":-5,"_27":183},{"_43":170,"_32":171,"_30":172,"_154":-5,"_41":42,"_40":173,"_156":25,"_38":174,"_13":63,"_33":158,"_35":175,"_24":25,"_160":-5,"_27":176},{"_43":162,"_32":163,"_30":164,"_154":-5,"_41":42,"_40":165,"_156":25,"_38":166,"_13":167,"_33":20,"_35":168,"_24":25,"_160":-5,"_27":169},{"_43":151,"_32":152,"_30":153,"_154":-5,"_41":42,"_40":155,"_156":59,"_38":157,"_13":63,"_33":158,"_35":159,"_24":25,"_160":-5,"_27":161},"91c70daa-28a9-4a57-89f3-fdab8ed2f0a6","track.ts","c5ecef54-7eba-11f1-b365-1607ee4eb77e","parentId",36,"latest",["D",1783947607457],"http","// 📈 روابط تتبّع النمو — مصدر بيانات «النمو» (Marketing). إسناد القناة/المؤثّر. بلا سرّ خارجي.\n// GET /r/:code → يسجّل النقرة ويحوّل 302 للوجهة (+utm_source) [عام — الناس يضغطونه]\n// POST /link { code, dest? } → إنشاء/تحديث رابط [VT_TEAM_KEY]\n// GET /stats → نقرات لكل code (إسناد) [VT_TEAM_KEY]\n// جداول: vt_links(code, dest, created_at) · vt_clicks(id, code, ts, referrer, ua)\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst DEST_DEFAULT = \"https://qahwaapp.com\";\n\nfunction rowsToObjects(rs: any): any[] {\n const cols: string[] = rs?.columns ?? [];\n return (rs?.rows ?? []).map((r: any) => Array.isArray(r) ? Object.fromEntries(cols.map((c, i) => [c, r[i]])) : r);\n}\nasync function init() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS vt_links (code TEXT PRIMARY KEY, dest TEXT NOT NULL, created_at TEXT)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS vt_clicks (id INTEGER PRIMARY KEY AUTOINCREMENT, code TEXT, ts TEXT, referrer TEXT, ua TEXT)`);\n}\n\nexport default async function (req: Request): Promise {\n await init();\n const url = new URL(req.url);\n const path = url.pathname.replace(/\\/+$/, \"\") || \"/\";\n const key = Deno.env.get(\"VT_TEAM_KEY\");\n const authed = !key || req.headers.get(\"authorization\") === `Bearer ${key}`;\n const json = (d: unknown, s = 200) => Response.json(d, { status: s });\n\n const rm = path.match(/^\\/r\\/([A-Za-z0-9_\\-]{1,40})$/);\n if (req.method === \"GET\" && rm) {\n const code = rm[1];\n const rs = await sqlite.execute(`SELECT dest FROM vt_links WHERE code=?`, [code]);\n const dest = rowsToObjects(rs)[0]?.dest || DEST_DEFAULT;\n await sqlite.execute(`INSERT INTO vt_clicks (code, ts, referrer, ua) VALUES (?,?,?,?)`,\n [code, new Date().toISOString(), req.headers.get(\"referer\") || \"\", (req.headers.get(\"user-agent\") || \"\").slice(0, 300)]);\n let loc = dest;\n try { const u = new URL(dest); u.searchParams.set(\"utm_source\", code); loc = u.toString(); } catch { /* keep */ }\n return new Response(null, { status: 302, headers: { location: loc } });\n }\n\n if (req.method === \"POST\" && path === \"/link\") {\n if (!authed) return json({ error: \"unauthorized\" }, 401);\n const b = await req.json().catch(() => null);\n if (!b?.code || !/^[A-Za-z0-9_\\-]{1,40}$/.test(b.code)) return json({ error: \"valid code required\" }, 400);\n await sqlite.execute(`INSERT INTO vt_links (code, dest, created_at) VALUES (?,?,?) ON CONFLICT(code) DO UPDATE SET dest=excluded.dest`,\n [b.code, b.dest || DEST_DEFAULT, new Date().toISOString()]);\n return json({ ok: true, code: b.code, hint: `شارك رابط .../r/${b.code}` });\n }\n\n if (req.method === \"GET\" && path === \"/stats\") {\n if (!authed) return json({ error: \"unauthorized\" }, 401);\n const rs = await sqlite.execute(`SELECT l.code, l.dest, COUNT(c.id) AS clicks, MAX(c.ts) AS last_click\n FROM vt_links l LEFT JOIN vt_clicks c ON c.code=l.code GROUP BY l.code, l.dest ORDER BY clicks DESC`);\n return json({ ok: true, links: rowsToObjects(rs) });\n }\n\n if (req.method === \"GET\" && path === \"/\") {\n return json({ ok: true, service: \"virtual-team · growth tracking\", usage: { redirect: \"GET /r/:code (public)\", create: \"POST /link {code,dest}\", stats: \"GET /stats\" } });\n }\n return json({ error: \"not found\" }, 404);\n}\n","label",[152],"b76be87c-bbf8-4efe-aab2-da2cc02bece2","team-context.md","1877bf5c-7d52-11f1-94c0-1607ee4eb77e",25,["D",1783848289713],1,"# سياق مجلس إدارة «رواد» (يقرأه كل عضو قبل أي مداولة)\n\n═══════════════════════════════════════\n## القسم أ — تفويض المجلس (مَن أنتم وماذا تفعلون)\n═══════════════════════════════════════\n\nأنتم **مجلس إدارة «رواد»** — العقل المفكّر وصانع القرار للشركة، **لستم مُراقبين يرفعون تقارير**.\nدوركم: **تفكّرون بمنطق حسب الرؤية أدناه، وتُصدرون قرارات قابلة للتنفيذ** (أولوية · تسلسل · مخاطر ·\nمعايير جاهزية) **لدفع المرحلة الأولى للاكتمال**. كل عضو يُصدر **قرارًا واضحًا في مجاله**، لا وصفًا للحالة.\nالمخرَج = **قرار** («أوصي/أقرر أن نفعل X لأن Y، بأولوية Z»)، لا تقرير. Slack = قاعة المجلس.\n\n═══════════════════════════════════════\n## القسم ب — رؤية «رواد» (أساس كل قرار)\n═══════════════════════════════════════\n\n**ما هو:** منصّة **اجتماعية متخصّصة في القهاوي فقط** (شبكة اجتماعية حول تجارب القهوة، لا خريطة عامة).\n**الوعد/التميّز:** قهوة **تناسب مزاجك** · مجتمع **حقيقي موثّق** (رواد + متابعون) · تخصّص · متابعة مقاهيك.\n**المحرّكات:**\n- التوصية: مزيج فلتر مزاج يدوي (عمل/لقاء/هدوء/درايف) + تعلّم تلقائي من سلوك المستخدم.\n- **التوثيق:** check-in **مقفول بالـGPS** (لا يفتح إلا عند القهوة فعليًا) → يمنع التزييف. لذلك **دقّة المواقع ركيزة ثقة**.\n- الاجتماعي: **ناس + قهوة** (تتابع قهاوي وأشخاصًا + فيد نشاط).\n**المستخدم:** أي شخص يشرب قهوة بالرياض (سوق شامل)، الرياض أولًا ثم توسّع.\n**الاستراتيجية (حلّ البدء البارد):** القهاوي لا تقتنع إلا بشبكة مستخدمين حقيقيين → ابنِ الطلب أولًا (رادار\nيُدرج كل القهاوي تلقائيًا) → اجذب مستخدمين متفاعلين → رافعة لتوقيع عقود مع القهاوي → افتح الطلب/الدفع.\n**الدخل (مستقبلي):** شبكة مدفوعات + طلب داخل التطبيق (سوق ثنائية: رواد ↔ قهاوي).\n**النمو:** متعدد القنوات (عضوي + فيروسي اجتماعي + مؤثرون + مدفوع + شراكات).\n\n═══════════════════════════════════════\n## القسم ج — المرحلة الأولى: الهدف والوضع الحالي (محور قرارات المجلس)\n═══════════════════════════════════════\n\n**هدف المرحلة الأولى:** بناء وإطلاق **الموقع الاجتماعي (ويب أولًا، بدومين رسمي)** =\nحصر اكتشاف دقيق + حسابات + GPS check-in + تقييمات موثّقة + فيد اجتماعي → **شبكة مستخدمين حقيقيين**.\n\n**الوضع الحالي (يُبنى على أساس qahwa-radar على Val Town):**\n- ✅ **الحسابات:** مبنية ومختبَرة (دخول برابط سحري بالإيميل، جلسات).\n- 🟡 **الاكتشاف/الحصر:** ~6,512 مقهى محصود، 99% مصنّف، لكن **فجوة إثراء (384/1,739 = 22%)**،\n التحقّق 6.7% فقط، وفجوة 574 بين المقبول والكتالوج. البحث يعمل لكن «الحصر» غير مكتمل الدقّة.\n- ⛔ **غير مبني بعد:** GPS check-in · التقييمات الموثّقة · الفيد الاجتماعي · الدومين الرسمي.\n- **معايير الإطلاق (يحدّدها المجلس):** متى نعتبر الحصر «كافيًا»؟ ما الحد الأدنى من الميزات للإطلاق؟\n\n═══════════════════════════════════════\n## القسم د — الحدود (تعلو على كل قرار)\n═══════════════════════════════════════\nممنوع مطلقًا (يُصعّد للمالك): صرف/تحويل أموال · حذف بيانات · تغيير صلاحيات · عقود ملزمة · إدخال بيانات اعتماد.\nيحتاج موافقة المالك: نشر عام · إرسال خارجي · إنفاق · إطلاق فعلي. مسموح: القراءة/التحليل/إصدار القرارات/المسودات.\n\n═══════════════════════════════════════\n## القسم هـ — أعضاء المجلس ومجالات قرارهم (المرحلة الأولى)\n═══════════════════════════════════════\n- 👔 **الرئيس (ceo):** يجمع مداولات الأعضاء ويُصدر **قرار المجلس الموحّد** (القرارات + الأولويات + التسلسل + معايير الجاهزية).\n- 🧑‍💻 **المنتج والهندسة (eng):** يقرّر **ماذا نبني/نصلّح تقنيًا وبأي تسلسل** (check-in, تقييمات, فيد, جودة الحصر, دقّة GPS). مصدره: خط أنابيب qahwa-radar الحيّ.\n- 📣 **النمو (marketing):** يقرّر **كيف نبني شبكة المستخدمين** (اكتساب، تفاعل، فيروسية، قنوات) — قلب استراتيجية البدء البارد.\n- 💰 **المالية (cfo):** يقرّر **انضباط الصرف وأولوياته** في بناء المرحلة (كلفة الأدوات/APIs، أين نصرف/نوفّر).\n\n**السياق التقني:** Val Town (Deno·SQLite·cron) · n8n · GitHub · Claude API. مصادر بيانات المقاهي: Google Places · OSM · Bright Data · Apify. العملة SAR.\n",[163],"b3d1c804-b284-418f-b1be-e75be66606fb","slacktest.ts","68037fc6-7dbf-11f1-ab81-1607ee4eb77e",21,["D",1783839646235],"// 🔧 اختبار نشر Slack — يتأكد أن SLACK_BOT_TOKEN صالح وأن البوت يقدر ينشر في القناة.\n// GET / → ينشر رسالة اختبار في #vt-admin ويرجّع رد Slack API (ok أو سبب الفشل).\nconst ADMIN = \"C0BGTSGP1KK\"; // #vt-admin\n\nexport default async function (_req: Request): Promise {\n const token = Deno.env.get(\"SLACK_BOT_TOKEN\");\n if (!token) return Response.json({ ok: false, error: \"SLACK_BOT_TOKEN غير مضبوط في env\" });\n const res = await fetch(\"https://slack.com/api/chat.postMessage\", {\n method: \"POST\",\n headers: { authorization: `Bearer ${token}`, \"content-type\": \"application/json; charset=utf-8\" },\n body: JSON.stringify({\n channel: ADMIN,\n text: \"🔧 *اختبار بوت الفريق الافتراضي* — النشر التلقائي جاهز ✅\",\n }),\n });\n const data = await res.json();\n return Response.json({ posted: data?.ok === true, slackApi: data });\n}\n",[171],"a9b566f3-cb40-4777-b844-5bc32d76d0ac","slackpost.ts","38a5668c-7dc3-11f1-8147-1607ee4eb77e",24,["D",1783841284754],"// 📮 نشر عام بالبوت — POST { channel, text } → ينشر عبر SLACK_BOT_TOKEN. يحمى بـ VT_TEAM_KEY إن ضُبط.\nexport default async function (req: Request): Promise {\n if (req.method !== \"POST\") return Response.json({ error: \"POST only\" }, { status: 405 });\n const teamKey = Deno.env.get(\"VT_TEAM_KEY\");\n if (teamKey && req.headers.get(\"authorization\") !== `Bearer ${teamKey}`) {\n return Response.json({ error: \"unauthorized\" }, { status: 401 });\n }\n const token = Deno.env.get(\"SLACK_BOT_TOKEN\");\n if (!token) return Response.json({ error: \"SLACK_BOT_TOKEN غير مضبوط\" }, { status: 400 });\n const b = await req.json().catch(() => null);\n if (!b?.channel || !b?.text) return Response.json({ error: \"channel and text required\" }, { status: 400 });\n const res = await fetch(\"https://slack.com/api/chat.postMessage\", {\n method: \"POST\",\n headers: { authorization: `Bearer ${token}`, \"content-type\": \"application/json; charset=utf-8\" },\n body: JSON.stringify({ channel: b.channel, text: b.text }),\n });\n const data = await res.json();\n return Response.json({ posted: data?.ok === true, slackApi: data });\n}\n",[178],"c81cf490-d52c-45a2-9df7-06f37366f006","slackEvents.ts","55a1a506-7ec8-11f1-94a3-1607ee4eb77e",67,["D",1783953432025],"// 💬 قناة المالك — يسمع رسائلك في قناة خاصة، الأعضاء يردّون (Haiku متوازي)، والرئيس يجمّع ويرد فيها.\n// يتطلب: SLACK_SIGNING_SECRET · SLACK_BOT_TOKEN · VT_TEAM_KEY · OWNER_CHANNEL (معرّف قناتك الخاصة).\n// اربطه في تطبيق Slack: Event Subscriptions → Request URL = هذا الرابط → Subscribe: message.channels + message.groups.\nimport { createHmac } from \"node:crypto\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst AGENT = \"https://asnfq50--4eee88c27d5211f18e4e1607ee4eb77e.web.val.run\";\nconst DOERS = [\"eng\", \"cfo\", \"marketing\"];\nconst LABELS: Record = { ceo: \"👔 المدير التنفيذي\", cfo: \"💰 المدير المالي\", marketing: \"📣 مدير التسويق\", eng: \"🧑‍💻 مدير المشاريع البرمجية\" };\n\nfunction verify(raw: string, ts: string, sig: string): boolean {\n const secret = Deno.env.get(\"SLACK_SIGNING_SECRET\");\n if (!secret || !ts || !sig) return false;\n if (Math.abs(Date.now() / 1000 - Number(ts)) > 300) return false;\n const expected = \"v0=\" + createHmac(\"sha256\", secret).update(`v0:${ts}:${raw}`).digest(\"hex\");\n return expected === sig;\n}\nfunction authHeaders(): Record {\n const k = Deno.env.get(\"VT_TEAM_KEY\");\n const h: Record = { \"content-type\": \"application/json\" };\n if (k) h[\"authorization\"] = `Bearer ${k}`;\n return h;\n}\nasync function runAgent(agent: string, task: string, timeoutMs = 24000): Promise {\n const res = await fetch(AGENT, {\n method: \"POST\", headers: authHeaders(),\n body: JSON.stringify({ agent, task, log: false, model: \"claude-haiku-4-5\" }),\n signal: AbortSignal.timeout(timeoutMs),\n });\n const d = await res.json();\n if (!res.ok) throw new Error(String(d?.error || res.status));\n return d.reply as string;\n}\nasync function slackPost(channel: string, text: string) {\n const token = Deno.env.get(\"SLACK_BOT_TOKEN\");\n if (!token) return;\n await fetch(\"https://slack.com/api/chat.postMessage\", {\n method: \"POST\", headers: { authorization: `Bearer ${token}`, \"content-type\": \"application/json; charset=utf-8\" },\n body: JSON.stringify({ channel, text }),\n }).catch(() => {});\n}\nasync function seenBefore(eventId: string): Promise {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS vt_events_seen (id TEXT PRIMARY KEY, ts TEXT)`);\n try { await sqlite.execute(`INSERT INTO vt_events_seen (id, ts) VALUES (?, ?)`, [eventId, new Date().toISOString()]); return false; }\n catch { return true; }\n}\n\nexport default async function (req: Request): Promise {\n if (req.method !== \"POST\") return Response.json({ ok: true, service: \"virtual-team · owner channel\" });\n const raw = await req.text();\n const ts = req.headers.get(\"x-slack-request-timestamp\") || \"\";\n const sig = req.headers.get(\"x-slack-signature\") || \"\";\n if (!verify(raw, ts, sig)) return new Response(\"bad signature\", { status: 401 });\n const body = JSON.parse(raw || \"{}\");\n\n if (body.type === \"url_verification\") return Response.json({ challenge: body.challenge });\n if (body.type !== \"event_callback\") return new Response(\"\", { status: 200 });\n\n const m = body.event || {};\n const OWNER_CHANNEL = Deno.env.get(\"OWNER_CHANNEL\") || \"\";\n // نتجاهل: غير الرسائل، رسائل البوت، التعديلات/الانضمام، وأي قناة غير قناة المالك\n if (m.type !== \"message\" || m.bot_id || m.subtype || !OWNER_CHANNEL || m.channel !== OWNER_CHANNEL) {\n return new Response(\"\", { status: 200 });\n }\n if (await seenBefore(body.event_id)) return new Response(\"\", { status: 200 });\n\n const text = (m.text || \"\").trim();\n const channel = m.channel;\n if (!text) return new Response(\"\", { status: 200 });\n\n await slackPost(channel, \"🤔 المجلس يتداول في طلبك…\");\n\n const reports = await Promise.all(DOERS.map((a) =>\n runAgent(a, `المالك يقول لمجلس «رواد»: «${text}»\\n\\nأجب من زاويتك بإيجاز شديد (قرار/رأي عملي واحد مبني على بياناتك الحيّة المحقونة). سطران كحد أقصى.`)\n .then((r) => ({ a, r })).catch((e) => ({ a, r: \"⚠️ \" + String(e).slice(0, 120) }))\n ));\n const digest = reports.map((x) => `### ${LABELS[x.a] || x.a}\\n${x.r}`).join(\"\\n\\n\");\n let answer = \"\";\n try {\n answer = await runAgent(\"ceo\",\n `المالك سأل المجلس: «${text}»\\n\\nإليك آراء الأعضاء. بصفتك رئيس مجلس «رواد»، اكتب **ردًّا موجزًا موحّدًا للمالك**: قرار/توصية واضحة + أهم خطوة تالية + أي شيء يحتاج اعتماده. لا تكرّر آراء الأعضاء حرفيًا.\\n\\n${digest}`,\n 22000);\n } catch (e) { answer = \"⚠️ تعذّر تجميع الرد: \" + String(e).slice(0, 120) + \"\\n\\n\" + digest; }\n\n await slackPost(channel, `👔 *رد المجلس:*\\n\\n${answer}`);\n return new Response(\"\", { status: 200 });\n}\n",[185],"a187fa69-5788-4458-9fff-826add9a5b9c","slackAction.ts","b3cfd9d6-7ec3-11f1-972c-1607ee4eb77e",66,["D",1783953197281],4,"// 💬 تفاعل Slack — يستقبل ضغطات أزرار الاعتماد + أوامر /plan و /approvals، ويتحقق من توقيع Slack.\n// يتطلب SLACK_SIGNING_SECRET (من إعدادات تطبيق Slack) + VT_TEAM_KEY. اربطه في تطبيق Slack:\n// Interactivity Request URL = هذا الرابط · Slash Commands (/plan,/approvals) Request URL = هذا الرابط\nimport { createHmac } from \"node:crypto\";\n\nconst APPROVALS = \"https://asnfq50--c17fb0a87ec111f1b4911607ee4eb77e.web.val.run\";\nconst PLAN = \"https://asnfq50--b9847cc07ebd11f1976c1607ee4eb77e.web.val.run\";\nconst OWN: Record = { ceo: \"👔\", cfo: \"💰\", marketing: \"📣\", eng: \"🧑‍💻\" };\n\nfunction authHeaders(): Record {\n const k = Deno.env.get(\"VT_TEAM_KEY\");\n const h: Record = { \"content-type\": \"application/json\" };\n if (k) h[\"authorization\"] = `Bearer ${k}`;\n return h;\n}\nfunction verify(raw: string, ts: string, sig: string): boolean {\n const secret = Deno.env.get(\"SLACK_SIGNING_SECRET\");\n if (!secret || !ts || !sig) { console.log(\"VERIFY missing:\", { hasSecret: !!secret, hasTs: !!ts, hasSig: !!sig }); return false; }\n if (Math.abs(Date.now() / 1000 - Number(ts)) > 300) { console.log(\"VERIFY old-ts:\", ts, \"now:\", Math.floor(Date.now() / 1000)); return false; }\n const expected = \"v0=\" + createHmac(\"sha256\", secret).update(`v0:${ts}:${raw}`).digest(\"hex\");\n const ok = expected === sig;\n if (!ok) console.log(\"VERIFY mismatch:\", { got: sig.slice(0, 15), exp: expected.slice(0, 15), rawLen: raw.length, secretLen: secret.length });\n return ok;\n}\n\nexport default async function (req: Request): Promise {\n if (req.method !== \"POST\") return Response.json({ ok: true, service: \"virtual-team · slack actions\" });\n const raw = await req.text();\n const ts = req.headers.get(\"x-slack-request-timestamp\") || \"\";\n const sig = req.headers.get(\"x-slack-signature\") || \"\";\n if (!verify(raw, ts, sig)) return new Response(\"bad signature\", { status: 401 });\n const params = new URLSearchParams(raw);\n\n // 1) ضغطة زر (Interactivity)\n if (params.has(\"payload\")) {\n const p = JSON.parse(params.get(\"payload\") || \"{}\");\n const val = p.actions?.[0]?.value || \"\";\n const [decision, id] = val.split(\":\");\n const user = p.user?.name || p.user?.username || \"المالك\";\n if ((decision === \"approve\" || decision === \"reject\") && id) {\n await fetch(APPROVALS + \"/decide\", {\n method: \"POST\", headers: authHeaders(),\n body: JSON.stringify({ id: Number(id), decision: decision === \"approve\" ? \"approved\" : \"rejected\" }),\n }).catch(() => {});\n const mark = decision === \"approve\" ? \"✅ *اعتُمد*\" : \"🚫 *رُفض*\";\n const text = `${mark} — بواسطة ${user}`;\n if (p.response_url) {\n await fetch(p.response_url, { method: \"POST\", headers: { \"content-type\": \"application/json\" }, body: JSON.stringify({ replace_original: true, text }) }).catch(() => {});\n }\n return new Response(\"\", { status: 200 });\n }\n return Response.json({ text: \"لم أفهم الإجراء\" });\n }\n\n // 2) أوامر (/plan , /approvals)\n const cmd = (params.get(\"command\") || \"\").trim();\n if (cmd === \"/plan\") {\n const d = await (await fetch(PLAN + \"/\", { headers: authHeaders() })).json();\n const s = d.summary || {};\n const lines = (d.plan || []).filter((i: any) => i.status !== \"done\").slice(0, 12)\n .map((i: any) => `• [${i.status}] ${OWN[i.owner] || \"\"} ${i.title}`).join(\"\\n\");\n return Response.json({ response_type: \"ephemeral\", text: `🗺️ *الخطة* — ★ ${d.north_star || \"\"}\\nمنجز ${s.done} · نشط ${s.active} · مقترح ${s.proposed} · معلّق ${s.blocked}\\n${lines}` });\n }\n if (cmd === \"/approvals\") {\n const d = await (await fetch(APPROVALS + \"/\", { headers: authHeaders() })).json();\n if (!d.count) return Response.json({ response_type: \"ephemeral\", text: \"لا بنود بانتظار اعتمادك ✅\" });\n const lines = (d.items || []).map((e: any) => `• [#${e.id}] ${OWN[e.owner] || \"\"} ${e.title} — ${e.reason || \"\"}`).join(\"\\n\");\n return Response.json({ response_type: \"ephemeral\", text: `⏳ *بانتظار اعتمادك (${d.count})*\\n${lines}\\n_اعتمد بأزرار رسائل المجلس._` });\n }\n return Response.json({ response_type: \"ephemeral\", text: \"الأوامر المتاحة: /plan · /approvals\" });\n}\n",[192],"24004955-63b4-49f1-9f7e-5e1116f93d80",["D",1784017220617],[28],"dea884b2-a28c-4ff4-8d13-6482d5ea9210","review.ts","d6fdeb64-7ebe-11f1-985e-1607ee4eb77e",62,["D",1783951489474],12,"// 🔄 محرّك مراجعة الخطة (3ب) — المجلس يحرّك الخطة الحيّة ويرفع قرارات تحتاج اعتماد المالك.\n// الأعضاء بالتوازي (Haiku، مهلة صارمة) يحدّثون بنودهم من بياناتهم الحيّة (JSON) → نطبّق على plan.ts →\n// الرئيس يصدر قرار موجز (أو ملخّص آلي احتياطي عند التأخّر) → (اختياريًا) ينشر Slack + التصعيدات.\n// POST / { postSlack?: boolean } [VT_TEAM_KEY]\n\nconst AGENT = \"https://asnfq50--4eee88c27d5211f18e4e1607ee4eb77e.web.val.run\";\nconst PLAN = \"https://asnfq50--b9847cc07ebd11f1976c1607ee4eb77e.web.val.run\";\nconst APPROVALS = \"https://asnfq50--c17fb0a87ec111f1b4911607ee4eb77e.web.val.run\";\nconst DOERS = [\"eng\", \"cfo\", \"marketing\"];\nconst CEO_CHANNEL = \"C0BGTSGP1KK\";\nconst LABELS: Record = { ceo: \"👔 المدير التنفيذي\", cfo: \"💰 المدير المالي\", marketing: \"📣 مدير التسويق\", eng: \"🧑‍💻 مدير المشاريع البرمجية\" };\n\nfunction authHeaders(): Record {\n const key = Deno.env.get(\"VT_TEAM_KEY\");\n const h: Record = { \"content-type\": \"application/json\" };\n if (key) h[\"authorization\"] = `Bearer ${key}`;\n return h;\n}\nasync function runAgent(agent: string, task: string, timeoutMs = 25000): Promise {\n const res = await fetch(AGENT, {\n method: \"POST\", headers: authHeaders(),\n body: JSON.stringify({ agent, task, log: true, model: \"claude-haiku-4-5\" }),\n signal: AbortSignal.timeout(timeoutMs),\n });\n const d = await res.json();\n if (!res.ok) throw new Error(`[${agent}] ${d?.error || res.status}`);\n return d.reply as string;\n}\nfunction extractJson(text: string): any | null {\n const m = text.match(/\\{[\\s\\S]*\\}/);\n if (!m) return null;\n try { return JSON.parse(m[0]); } catch { return null; }\n}\nasync function planGet(): Promise {\n return await (await fetch(PLAN + \"/\", { headers: authHeaders() })).json();\n}\nasync function planPost(path: string, body: any) {\n await fetch(PLAN + path, { method: \"POST\", headers: authHeaders(), body: JSON.stringify(body) }).catch(() => {});\n}\nasync function raiseApproval(owner: string, title: string, reason: string): Promise<{ id: any; isNew: boolean }> {\n try {\n const r = await fetch(APPROVALS + \"/raise\", { method: \"POST\", headers: authHeaders(), body: JSON.stringify({ owner, title, reason }) });\n const d = await r.json();\n return { id: d?.id ?? null, isNew: Boolean(d?.isNew) };\n } catch { return { id: null, isNew: false }; }\n}\nasync function awaitingApprovals(): Promise {\n try { const r = await fetch(APPROVALS + \"/\", { headers: authHeaders() }); const d = await r.json(); return d?.items ?? []; } catch { return []; }\n}\nasync function slack(channel: string, text: string) {\n const token = Deno.env.get(\"SLACK_BOT_TOKEN\");\n if (!token) return;\n await fetch(\"https://slack.com/api/chat.postMessage\", {\n method: \"POST\", headers: { authorization: `Bearer ${token}`, \"content-type\": \"application/json; charset=utf-8\" },\n body: JSON.stringify({ channel, text }),\n }).catch(() => {});\n}\nasync function slackBlocks(channel: string, text: string, id: number) {\n const token = Deno.env.get(\"SLACK_BOT_TOKEN\");\n if (!token) return;\n const blocks = [\n { type: \"section\", text: { type: \"mrkdwn\", text } },\n { type: \"actions\", elements: [\n { type: \"button\", text: { type: \"plain_text\", text: \"✔ اعتمد\", emoji: true }, style: \"primary\", action_id: \"approve\", value: `approve:${id}` },\n { type: \"button\", text: { type: \"plain_text\", text: \"✕ ارفض\", emoji: true }, style: \"danger\", action_id: \"reject\", value: `reject:${id}` },\n ] },\n ];\n await fetch(\"https://slack.com/api/chat.postMessage\", {\n method: \"POST\", headers: { authorization: `Bearer ${token}`, \"content-type\": \"application/json; charset=utf-8\" },\n body: JSON.stringify({ channel, text, blocks }),\n }).catch(() => {});\n}\nfunction fallbackSummary(after: any, memberOut: any[], escalations: any[]): string {\n const nexts = memberOut.filter((m) => m.next_action).map((m) => `• ${LABELS[m.agent] || m.agent}: ${m.next_action}`).join(\"\\n\") || \"—\";\n const esc = escalations.length ? escalations.map((e, i) => `${i + 1}. [${LABELS[e.owner] || e.owner}] ${e.title} — ${e.reason || \"\"}`).join(\"\\n\") : \"لا شيء\";\n return `⚙️ *ملخّص آلي* (الرئيس تأخّر)\\nالخطة: ${JSON.stringify(after.summary)}\\n*الخطوات التالية:*\\n${nexts}\\n*يحتاج اعتمادك:*\\n${esc}`;\n}\n\nexport default async function (req: Request): Promise {\n const key = Deno.env.get(\"VT_TEAM_KEY\");\n const CORS: Record = { \"access-control-allow-origin\": \"*\", \"access-control-allow-methods\": \"GET,POST,OPTIONS\", \"access-control-allow-headers\": \"authorization,content-type\" };\n const json = (d: unknown, s = 200) => new Response(JSON.stringify(d), { status: s, headers: { \"content-type\": \"application/json; charset=utf-8\", ...CORS } });\n if (req.method === \"OPTIONS\") return new Response(null, { status: 204, headers: CORS });\n if (key && req.headers.get(\"authorization\") !== `Bearer ${key}`) return json({ error: \"unauthorized\" }, 401);\n if (req.method !== \"POST\") return json({ ok: true, service: \"virtual-team · plan review\", usage: \"POST { postSlack? }\" });\n\n const body = await req.json().catch(() => ({}));\n const postSlack = Boolean(body?.postSlack);\n\n const before = await planGet();\n const items: any[] = before.plan ?? [];\n const config: any = before.config ?? {};\n\n const applied: any[] = [];\n const escalations: any[] = [];\n const memberOut: any[] = [];\n\n const buildTask = (m: string, mine: any[]) =>\n`هذه بنودك في الخطة الحيّة لـ«رواد» (owner=${m}). النجم-الشمالي: «${config.north_star || \"\"}». عتبة التصعيد: «${config.escalation || \"\"}».\nالبنود:\n${JSON.stringify(mine.map((i: any) => ({ id: i.id, title: i.title, status: i.status, priority: i.priority, done_criteria: i.done_criteria, progress: i.progress })), null, 2)}\n\nاستنادًا إلى بياناتك الحيّة (المحقونة في مهمتك) وميثاق المالك، حدّث بنودك بإيجاز. progress سطر واحد قصير.\nأعِد JSON فقط بهذا الشكل بالضبط، بدون أي نص خارج JSON:\n{\"items\":[{\"id\":<رقم بند لك>,\"status\":\"proposed|active|blocked|done\",\"progress\":\"سطر تقدّم قصير مبني على بياناتك\"}],\"escalate\":[{\"title\":\"قرار يحتاج اعتماد المالك\",\"reason\":\"لماذا\"}],\"next_action\":\"أهم خطوة تالية واحدة\"}\nحرّك بنودك أنت فقط وبناءً على الأدلة. اترك \"escalate\" فارغة إن لم يوجد ما يحتاج المالك.`;\n\n const runs = await Promise.all(DOERS.map(async (m) => {\n const mine = items.filter((i) => i.owner === m && i.status !== \"done\");\n if (!mine.length) return { m, mine, parsed: null as any, error: null as any };\n try { return { m, mine, parsed: extractJson(await runAgent(m, buildTask(m, mine), 26000)), error: null as any }; }\n catch (e) { return { m, mine, parsed: null as any, error: String(e).slice(0, 160) }; }\n }));\n\n for (const r of runs) {\n if (r.error) { memberOut.push({ agent: r.m, error: r.error }); continue; }\n if (!r.mine.length) continue;\n memberOut.push({ agent: r.m, parsed: Boolean(r.parsed), next_action: r.parsed?.next_action ?? null });\n if (!r.parsed) continue;\n for (const it of (r.parsed.items ?? [])) {\n const owns = r.mine.find((x: any) => Number(x.id) === Number(it?.id));\n if (!owns) continue;\n await planPost(\"/item\", { id: Number(it.id), title: owns.title, owner: r.m, status: it.status, progress: it.progress });\n applied.push({ id: Number(it.id), status: it.status, progress: it.progress });\n }\n for (const e of (r.parsed.escalate ?? [])) {\n if (!e?.title) continue;\n const raised = await raiseApproval(r.m, e.title, e.reason || \"\");\n escalations.push({ owner: r.m, title: e.title, reason: e.reason, id: raised.id, isNew: raised.isNew });\n }\n }\n\n const after = await planGet();\n const ceoTask =\n`بصفتك رئيس مجلس «رواد»، إليك الخطة الحيّة بعد تحديث الأعضاء + ما يحتاج اعتماد المالك.\nاكتب **قرار المجلس الموحّد موجزًا جدًا** (لا يتجاوز ~8 أسطر): الوضع في سطر · أهم 2-3 قرارات مرقّمة · يحتاج اعتمادك · أعلى خطر. لا تكرّر الخطة.\nملخّص الخطة: ${JSON.stringify(after.summary)}\nأهم البنود: ${JSON.stringify((after.plan ?? []).filter((i: any) => i.status !== \"done\").slice(0, 10).map((i: any) => ({ id: i.id, owner: i.owner, status: i.status, priority: i.priority, title: i.title })))}\nتنتظر اعتمادك: ${JSON.stringify(escalations)}`;\n let summary = \"\";\n try { summary = await runAgent(\"ceo\", ceoTask, 22000); }\n catch { summary = fallbackSummary(after, memberOut, escalations); }\n\n const anyNew = escalations.some((e) => e.isNew);\n const awaiting = await awaitingApprovals();\n if (postSlack) {\n await slack(CEO_CHANNEL, `⭐ *مراجعة الخطة — قرار المجلس*\\n\\n${summary}`);\n for (const e of escalations.filter((x) => x.isNew && x.id)) {\n await slackBlocks(CEO_CHANNEL, `⏳ *${LABELS[e.owner] || e.owner} — يحتاج اعتمادك:*\\n${e.title}${e.reason ? `\\n_${e.reason}_` : \"\"}`, Number(e.id));\n }\n }\n\n return json({ ok: true, updates_applied: applied.length, escalations_new: escalations.filter((e) => e.isNew).length, awaiting: awaiting.length, memberOut, summary, plan_summary: after.summary, awaiting_list: awaiting, slackPosted: postSlack });\n}\n",[203],"a21207e6-a7e6-4993-a759-0aab60275711","plan.ts","b9847cc0-7ebd-11f1-976c-1607ee4eb77e",57,["D",1783951013934],"// 🗺️ الخطة الحيّة — مصدر الحقيقة لمحرّك التخطيط. بنود المرحلة الأولى + ميثاق المالك + حلقة الاعتماد.\n// GET / → الخطة (مرتّبة) + النجم-الشمالي + الميثاق + ملخّص [VT_TEAM_KEY]\n// POST /item → upsert { id?, title, owner, status?, priority?, done_criteria?, progress?, approval? }\n// POST /item/status → { id, status } (proposed|active|blocked|done)\n// POST /item/approve → { id, decision } (approved|rejected) ← اعتماد المالك\n// GET/POST /config → ميثاق المالك (north_star, budget_cap_sar, risk_appetite, escalation)\n// جداول: vt_plan(...) · vt_config(key, value)\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst OWNERS = [\"ceo\", \"cfo\", \"marketing\", \"eng\"];\nconst STATUSES = [\"proposed\", \"active\", \"blocked\", \"done\"];\n\nconst SEED_PLAN = [\n { title: \"الحسابات (دخول سحري + جلسات)\", owner: \"eng\", status: \"done\", priority: 0, done_criteria: \"تسجيل/دخول يعمل ومختبَر\" },\n { title: \"الدومين الرسمي qahwaapp.com\", owner: \"eng\", status: \"done\", priority: 0, done_criteria: \"دومين نشط\" },\n { title: \"GPS check-in مقفول بالموقع\", owner: \"eng\", status: \"proposed\", priority: 1, done_criteria: \"لا يفتح check-in إلا عند القهوة فعليًا (منع تزييف)\" },\n { title: \"بناء أول موجة مستخدمين حقيقيين\", owner: \"marketing\", status: \"proposed\", priority: 1, done_criteria: \"أول موجة مستخدمين متفاعلين + check-ins\" },\n { title: \"التقييمات الموثّقة\", owner: \"eng\", status: \"proposed\", priority: 2, done_criteria: \"تقييم مرتبط بـcheck-in موثّق\" },\n { title: \"سدّ فجوة الإثراء (22%)\", owner: \"eng\", status: \"active\", priority: 2, done_criteria: \"نسبة الإثراء ≥ 90%\" },\n { title: \"انضباط الحرق ضمن السقف\", owner: \"cfo\", status: \"active\", priority: 2, done_criteria: \"الحرق الشهري ≤ السقف المعتمد\" },\n { title: \"الفيد الاجتماعي (ناس + قهوة)\", owner: \"eng\", status: \"proposed\", priority: 3, done_criteria: \"فيد نشاط للمتابَعين\" },\n { title: \"رفع التحقّق (6.7%)\", owner: \"eng\", status: \"active\", priority: 3, done_criteria: \"نسبة التحقّق ترتفع بوضوح\" },\n];\n\nconst SEED_CONFIG: Record = {\n north_star: \"شبكة مستخدمين حقيقيين متفاعلين (المرحلة الأولى)\",\n budget_cap_sar: \"\",\n risk_appetite: \"متوسّطة\",\n escalation: \"إنفاق · نشر عام · إطلاق فعلي · عقود → تُصعّد للمالك\",\n};\n\nfunction rowsToObjects(rs: any): any[] {\n const cols: string[] = rs?.columns ?? [];\n return (rs?.rows ?? []).map((r: any) => Array.isArray(r) ? Object.fromEntries(cols.map((c, i) => [c, r[i]])) : r);\n}\n\nasync function init() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS vt_plan (\n id INTEGER PRIMARY KEY AUTOINCREMENT, title TEXT NOT NULL, owner TEXT NOT NULL,\n status TEXT NOT NULL DEFAULT 'proposed', priority INTEGER DEFAULT 5,\n done_criteria TEXT, progress TEXT, approval TEXT NOT NULL DEFAULT 'none',\n created_at TEXT, updated_at TEXT)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS vt_config (key TEXT PRIMARY KEY, value TEXT)`);\n if (Number(rowsToObjects(await sqlite.execute(`SELECT COUNT(*) AS c FROM vt_plan`))[0]?.c ?? 0) === 0) {\n const now = new Date().toISOString();\n for (const p of SEED_PLAN) {\n await sqlite.execute(\n `INSERT INTO vt_plan (title,owner,status,priority,done_criteria,approval,created_at,updated_at) VALUES (?,?,?,?,?,?,?,?)`,\n [p.title, p.owner, p.status, p.priority, p.done_criteria, \"none\", now, now]);\n }\n }\n if (Number(rowsToObjects(await sqlite.execute(`SELECT COUNT(*) AS c FROM vt_config`))[0]?.c ?? 0) === 0) {\n for (const [k, v] of Object.entries(SEED_CONFIG)) {\n await sqlite.execute(`INSERT OR IGNORE INTO vt_config (key,value) VALUES (?,?)`, [k, v]);\n }\n }\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const path = url.pathname.replace(/\\/+$/, \"\") || \"/\";\n const key = Deno.env.get(\"VT_TEAM_KEY\");\n const authed = !key || req.headers.get(\"authorization\") === `Bearer ${key}`;\n const CORS: Record = { \"access-control-allow-origin\": \"*\", \"access-control-allow-methods\": \"GET,POST,OPTIONS\", \"access-control-allow-headers\": \"authorization,content-type\" };\n const json = (d: unknown, s = 200) => new Response(JSON.stringify(d), { status: s, headers: { \"content-type\": \"application/json; charset=utf-8\", ...CORS } });\n if (req.method === \"OPTIONS\") return new Response(null, { status: 204, headers: CORS });\n await init();\n if (!authed) return json({ error: \"unauthorized\" }, 401);\n const now = () => new Date().toISOString();\n\n if (req.method === \"POST\" && path === \"/item\") {\n const b = await req.json().catch(() => null);\n if (!b?.title || !OWNERS.includes(b.owner)) return json({ error: `title + owner(${OWNERS.join(\"/\")}) required` }, 400);\n if (b.id) {\n await sqlite.execute(\n `UPDATE vt_plan SET title=?, owner=?, status=COALESCE(?,status), priority=COALESCE(?,priority),\n done_criteria=COALESCE(?,done_criteria), progress=COALESCE(?,progress), updated_at=? WHERE id=?`,\n [b.title, b.owner, b.status ?? null, b.priority ?? null, b.done_criteria ?? null, b.progress ?? null, now(), b.id]);\n return json({ ok: true, id: b.id });\n }\n await sqlite.execute(\n `INSERT INTO vt_plan (title,owner,status,priority,done_criteria,progress,approval,created_at,updated_at) VALUES (?,?,?,?,?,?,?,?,?)`,\n [b.title, b.owner, b.status || \"proposed\", b.priority ?? 5, b.done_criteria || null, b.progress || null, b.approval || \"none\", now(), now()]);\n return json({ ok: true, id: Number(rowsToObjects(await sqlite.execute(\"SELECT last_insert_rowid() AS id\"))[0]?.id) });\n }\n\n if (req.method === \"POST\" && path === \"/item/status\") {\n const b = await req.json().catch(() => null);\n if (!b?.id || !STATUSES.includes(b.status)) return json({ error: `id + status(${STATUSES.join(\"/\")})` }, 400);\n await sqlite.execute(`UPDATE vt_plan SET status=?, updated_at=? WHERE id=?`, [b.status, now(), b.id]);\n return json({ ok: true });\n }\n\n if (req.method === \"POST\" && path === \"/item/approve\") {\n const b = await req.json().catch(() => null);\n if (!b?.id || ![\"approved\", \"rejected\"].includes(b.decision)) return json({ error: \"id + decision(approved|rejected)\" }, 400);\n await sqlite.execute(`UPDATE vt_plan SET approval=?, updated_at=? WHERE id=?`, [b.decision, now(), b.id]);\n return json({ ok: true });\n }\n\n if (req.method === \"POST\" && path === \"/config\") {\n const b = await req.json().catch(() => null);\n if (!b?.key) return json({ error: \"key required\" }, 400);\n await sqlite.execute(`INSERT INTO vt_config (key,value) VALUES (?,?) ON CONFLICT(key) DO UPDATE SET value=excluded.value`, [b.key, String(b.value ?? \"\")]);\n return json({ ok: true });\n }\n\n if (req.method === \"GET\" && path === \"/config\") {\n return json({ ok: true, config: Object.fromEntries(rowsToObjects(await sqlite.execute(\"SELECT key,value FROM vt_config\")).map((r) => [r.key, r.value])) });\n }\n\n const items = rowsToObjects(await sqlite.execute(`SELECT id,title,owner,status,priority,done_criteria,progress,approval,updated_at FROM vt_plan ORDER BY (status='done'), priority ASC, id ASC`));\n const config = Object.fromEntries(rowsToObjects(await sqlite.execute(\"SELECT key,value FROM vt_config\")).map((r) => [r.key, r.value]));\n const summary = {\n total: items.length,\n done: items.filter((i) => i.status === \"done\").length,\n active: items.filter((i) => i.status === \"active\").length,\n proposed: items.filter((i) => i.status === \"proposed\").length,\n blocked: items.filter((i) => i.status === \"blocked\").length,\n awaiting_approval: items.filter((i) => i.approval === \"awaiting\").length,\n };\n return json({ ok: true, north_star: config.north_star, summary, config, plan: items });\n}\n",[211],"cea7b9f7-1389-48bd-b678-7aebefa50bf7","panel.ts","7697c52c-7d71-11f1-819a-1607ee4eb77e",56,["D",1783950959645],2,"// 🖥️ لوحة المالك (مقفولة) — تعرض الخطة الحيّة + قائمة الاعتماد، وتعتمد بضغطة، وتشغّل مراجعة.\n// مقفولة بـVT_TEAM_KEY: المالك يُدخل المفتاح مرة (يُحفظ محليًا في المتصفح) ويُرسل في ترويسة Authorization.\nconst PLAN = \"https://asnfq50--b9847cc07ebd11f1976c1607ee4eb77e.web.val.run\";\nconst APPROVALS = \"https://asnfq50--c17fb0a87ec111f1b4911607ee4eb77e.web.val.run\";\nconst REVIEW = \"https://asnfq50--d6fdeb647ebe11f1985e1607ee4eb77e.web.val.run\";\n\nconst HTML = `\n\nلوحة مجلس رواد\n

لوحة مجلس رواد

OWNER · CONSOLE

\n\n

🔑 الدخول

\n \n

يُحفظ في متصفحك فقط.

\n\n\n\n

`;\n\nexport default function (req: Request): Response {\n return new Response(HTML, { headers: { \"content-type\": \"text/html; charset=utf-8\" } });\n}\n",[218],"ebd1f8f4-b389-4b33-8131-57ccb88f2a0c","orchestrate.ts","90f8ea50-7d52-11f1-8c34-1607ee4eb77e",33,["D",1783849123615],6,"// 🔀 المنسّق (Orchestrator) — حلقة المدير التنفيذي\n// POST / { goal, postSlack? } → 1) CEO يفكّك الهدف لمهام أقسام (JSON)\n// 2) تشغيل الأقسام بالتسلسل عبر agent.ts\n// 3) CEO يجمّع تقريرًا موحّدًا\n// 4) (اختياري) نشر التقارير في قنوات Slack إن postSlack=true وSLACK_BOT_TOKEN مضبوط\n// env: AGENT_URL · VT_TEAM_KEY · SLACK_BOT_TOKEN (للنشر)\n\nconst AGENT_FALLBACK = \"https://asnfq50--4eee88c27d5211f18e4e1607ee4eb77e.web.val.run\";\nconst DEPARTMENTS = [\"cfo\", \"marketing\", \"eng\"] as const;\n\n// خريطة القنوات في مساحة abdullah-rqu5371.slack.com\nconst SLACK_CHANNELS: Record = {\n ceo: \"C0BGTSGP1KK\", cfo: \"C0BGRV0QXAN\", marketing: \"C0BGTSHPG1F\", eng: \"C0BGRV10RJ6\",\n};\nconst LABELS: Record = {\n ceo: \"👔 المدير التنفيذي\", cfo: \"💰 المدير المالي\", marketing: \"📣 مدير التسويق\", eng: \"🧑‍💻 مدير المشاريع البرمجية\",\n};\n\nfunction agentUrl() {\n return (Deno.env.get(\"AGENT_URL\") || AGENT_FALLBACK).replace(/\\/+$/, \"\");\n}\n\nasync function runAgent(agent: string, task: string, log: boolean): Promise {\n const headers: Record = { \"content-type\": \"application/json\" };\n const key = Deno.env.get(\"VT_TEAM_KEY\");\n if (key) headers[\"authorization\"] = `Bearer ${key}`;\n const res = await fetch(agentUrl(), { method: \"POST\", headers, body: JSON.stringify({ agent, task, log }) });\n const data = await res.json();\n if (!res.ok) throw new Error(`[${agent}] ${data?.error || res.status}`);\n return data.reply as string;\n}\n\n// نشر رسالة في قناة Slack عبر chat.postMessage (يتطلب SLACK_BOT_TOKEN بصلاحية chat:write)\nasync function postToSlack(channel: string, text: string) {\n const token = Deno.env.get(\"SLACK_BOT_TOKEN\");\n if (!token || !channel) return;\n await fetch(\"https://slack.com/api/chat.postMessage\", {\n method: \"POST\",\n headers: { authorization: `Bearer ${token}`, \"content-type\": \"application/json; charset=utf-8\" },\n body: JSON.stringify({ channel, text }),\n }).catch(() => {});\n}\n\nfunction extractJsonArray(text: string): any[] | null {\n const m = text.match(/\\[[\\s\\S]*\\]/);\n if (!m) return null;\n try { return JSON.parse(m[0]); } catch { return null; }\n}\n\nexport default async function (req: Request): Promise {\n const json = (d: unknown, s = 200) =>\n new Response(JSON.stringify(d, null, 2), {\n status: s,\n headers: { \"content-type\": \"application/json; charset=utf-8\", \"access-control-allow-origin\": \"*\" },\n });\n\n if (req.method === \"OPTIONS\") {\n return new Response(null, { status: 204, headers: { \"access-control-allow-origin\": \"*\", \"access-control-allow-methods\": \"GET,POST,OPTIONS\", \"access-control-allow-headers\": \"authorization,content-type\" } });\n }\n\n if (req.method === \"GET\") {\n return json({ ok: true, service: \"virtual-team · orchestrator\", flow: [\"CEO decompose\", \"departments (sequential)\", \"CEO aggregate\", \"Slack (optional)\"], usage: \"POST { goal, postSlack? }\" });\n }\n\n if (req.method !== \"POST\") return json({ error: \"not found\" }, 404);\n\n const TEAM_KEY = Deno.env.get(\"VT_TEAM_KEY\");\n if (TEAM_KEY && req.headers.get(\"authorization\") !== `Bearer ${TEAM_KEY}`) {\n return json({ error: \"unauthorized\" }, 401);\n }\n\n try {\n const body = await req.json().catch(() => null);\n const goal = body?.goal;\n if (!goal || typeof goal !== \"string\") return json({ error: \"goal (string) required\" }, 400);\n\n // 1) التفكيك\n const decomposeTask =\n `بصفتك رئيس مجلس «رواد»، وزّع بند المجلس التالي على الأعضاء المعنيّين (${DEPARTMENTS.join(\", \")}) ليُصدر كل عضو قراره في مجاله. ` +\n `أعِد فقط مصفوفة JSON بدون أي شرح، بالشكل: [{\"agent\":\"eng\",\"task\":\"أصدر قرارك بشأن ...\"}]. ` +\n `اختر الأعضاء المعنيّين فقط، ومهمة كل عضو = «أصدر قرارك بشأن X».\\n\\nبند المجلس: ${goal}`;\n const planRaw = await runAgent(\"ceo\", decomposeTask, false);\n let plan = extractJsonArray(planRaw)?.filter((p) => p && DEPARTMENTS.includes(p.agent) && p.task);\n if (!plan || plan.length === 0) {\n plan = DEPARTMENTS.map((agent) => ({ agent, task: goal }));\n }\n\n const live = Boolean(body.postSlack) && Boolean(Deno.env.get(\"SLACK_BOT_TOKEN\"));\n\n // فتح الجلسة (حيّ) في قاعة المجلس\n if (live) {\n const members = plan.map((p: any) => LABELS[p.agent] ?? p.agent).join(\" · \");\n await postToSlack(SLACK_CHANNELS.ceo, `🏛️ *انعقدت جلسة المجلس*\\n*البند:* ${goal}\\n*الأعضاء:* ${members}\\n_تنزل قرارات الأعضاء في قنواتهم تباعًا…_`);\n }\n\n // 2) تشغيل الأعضاء بالتسلسل — كل عضو ينشر قراره في قناته فور انتهائه (حيّ)\n const reports: any[] = [];\n for (const p of plan) {\n let r: any;\n try { r = { agent: p.agent, task: p.task, report: await runAgent(p.agent, p.task, true) }; }\n catch (e) { r = { agent: p.agent, task: p.task, error: String(e) }; }\n reports.push(r);\n if (live) await postToSlack(SLACK_CHANNELS[r.agent], `*${LABELS[r.agent] ?? r.agent} — قراره:*\\n\\n${r.report ?? \"⚠️ \" + r.error}`);\n }\n\n // 3) التجميع\n const digest = reports\n .map((r: any) => `## ${r.agent}\\n${r.report ?? \"⚠️ \" + r.error}`)\n .join(\"\\n\\n\");\n const aggregateTask =\n `بند المجلس: «${goal}». إليك قرارات الأعضاء. بصفتك رئيس مجلس «رواد»، اكتب **قرار المجلس الموحّد** ` +\n `بصيغة مخرجاتك (الوضع · من كل عضو · قرارات المجلس المرقّمة بالأولوية · يحتاج اعتماد المالك · التالي تنفيذيًا · المخاطر).\\n\\n${digest}`;\n const summary = await runAgent(\"ceo\", aggregateTask, true);\n\n // 4) قرار المجلس الموحّد (حيّ) في قاعة المجلس\n if (live) await postToSlack(SLACK_CHANNELS.ceo, `⭐ *قرار المجلس الموحّد*\\n\\n${summary}`);\n\n return json({ ok: true, goal, plan, reports, summary, slackPosted: live });\n } catch (e) {\n return json({ error: String(e) }, 500);\n }\n}\n",[226],"f07f669c-34f3-442c-9f07-08f7e14798bc","memory.ts",["D",1783809542218],"// 🧠 الذاكرة المشتركة للفريق الافتراضي (Shared Memory)\n// جدول أحداث واحد ينتقل عبره السياق بين الوكلاء ويسجّل كل فعل مؤثّر (Audit).\n// المسارات:\n// GET / → صحّة + ملخّص\n// POST /event → إضافة حدث { agent, type, title?, body?, refs?, status?, impact? }\n// POST /status → تحديث حالة { id, status } (للموافقات: approved/rejected...)\n// GET /events → استعلام ?agent=&status=&type=&impact=&limit=\n// الأمان: إن ضُبط env VT_TEAM_KEY، تتطلب كل المسارات (عدا /) ترويسة Authorization: Bearer .\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst TABLE = \"vt_events_v1\";\nconst AGENTS = [\"ceo\", \"cfo\", \"marketing\", \"eng\"];\nconst TYPES = [\"task\", \"report\", \"decision\", \"escalation\", \"action\"];\nconst STATUSES = [\"open\", \"done\", \"blocked\", \"awaiting_approval\", \"approved\", \"rejected\"];\n\nasync function init() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ${TABLE} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n ts TEXT NOT NULL,\n agent TEXT NOT NULL,\n type TEXT NOT NULL,\n title TEXT,\n body TEXT,\n refs TEXT,\n status TEXT NOT NULL DEFAULT 'open',\n impact TEXT NOT NULL DEFAULT 'read'\n )`);\n}\n\n// std/sqlite قد يرجّع الصفوف كمصفوفات أو كائنات — نوحّدها لكائنات دائمًا.\nfunction rowsToObjects(rs: any): any[] {\n const cols: string[] = rs?.columns ?? [];\n return (rs?.rows ?? []).map((r: any) =>\n Array.isArray(r) ? Object.fromEntries(cols.map((c, i) => [c, r[i]])) : r\n );\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const path = url.pathname.replace(/\\/+$/, \"\") || \"/\";\n const cors = {\n \"access-control-allow-origin\": \"*\",\n \"access-control-allow-methods\": \"GET,POST,OPTIONS\",\n \"access-control-allow-headers\": \"authorization,content-type\",\n };\n const json = (d: unknown, status = 200) =>\n new Response(JSON.stringify(d, null, 2), {\n status,\n headers: { \"content-type\": \"application/json; charset=utf-8\", ...cors },\n });\n\n if (req.method === \"OPTIONS\") return new Response(null, { status: 204, headers: cors });\n\n const KEY = Deno.env.get(\"VT_TEAM_KEY\");\n const authed = !KEY || req.headers.get(\"authorization\") === `Bearer ${KEY}`;\n\n try {\n await init();\n\n if (req.method === \"GET\" && path === \"/\") {\n const rs = await sqlite.execute(`SELECT COUNT(*) AS c FROM ${TABLE}`);\n const count = rowsToObjects(rs)[0]?.c ?? 0;\n return json({\n ok: true,\n service: \"virtual-team · shared memory\",\n table: TABLE,\n events: count,\n secured: Boolean(KEY),\n note: KEY ? undefined : \"⚠️ وضع مفتوح — اضبط VT_TEAM_KEY لتأمين الذاكرة\",\n routes: [\"GET /\", \"POST /event\", \"POST /status\", \"GET /events?agent=&status=&type=&impact=&limit=\"],\n });\n }\n\n if (!authed) return json({ error: \"unauthorized\" }, 401);\n\n if (req.method === \"POST\" && path === \"/event\") {\n const b = await req.json().catch(() => null);\n if (!b || !b.agent || !b.type) return json({ error: \"agent and type are required\" }, 400);\n if (!AGENTS.includes(b.agent)) return json({ error: `agent must be one of ${AGENTS.join(\", \")}` }, 400);\n if (!TYPES.includes(b.type)) return json({ error: `type must be one of ${TYPES.join(\", \")}` }, 400);\n const ts = b.ts || new Date().toISOString();\n await sqlite.execute(\n `INSERT INTO ${TABLE} (ts,agent,type,title,body,refs,status,impact) VALUES (?,?,?,?,?,?,?,?)`,\n [ts, b.agent, b.type, b.title ?? null, b.body ?? null, b.refs ?? null, b.status ?? \"open\", b.impact ?? \"read\"],\n );\n const rs = await sqlite.execute(`SELECT last_insert_rowid() AS id`);\n return json({ ok: true, id: rowsToObjects(rs)[0]?.id });\n }\n\n if (req.method === \"POST\" && path === \"/status\") {\n const b = await req.json().catch(() => null);\n const id = Number(b?.id);\n const status = b?.status;\n if (!id || !status) return json({ error: \"id and status are required\" }, 400);\n if (!STATUSES.includes(status)) return json({ error: `status must be one of ${STATUSES.join(\", \")}` }, 400);\n await sqlite.execute(`UPDATE ${TABLE} SET status = ? WHERE id = ?`, [status, id]);\n const rs = await sqlite.execute(`SELECT * FROM ${TABLE} WHERE id = ?`, [id]);\n const row = rowsToObjects(rs)[0];\n if (!row) return json({ error: \"not found\", id }, 404);\n return json({ ok: true, event: row });\n }\n\n if (req.method === \"GET\" && path === \"/events\") {\n const where: string[] = [];\n const args: any[] = [];\n for (const f of [\"agent\", \"status\", \"type\", \"impact\"]) {\n const v = url.searchParams.get(f);\n if (v) { where.push(`${f} = ?`); args.push(v); }\n }\n const limit = Math.min(Math.max(Number(url.searchParams.get(\"limit\") ?? 50), 1), 200);\n const clause = where.length ? `WHERE ${where.join(\" AND \")}` : \"\";\n const rs = await sqlite.execute(\n `SELECT * FROM ${TABLE} ${clause} ORDER BY id DESC LIMIT ?`,\n [...args, limit],\n );\n const events = rowsToObjects(rs);\n return json({ ok: true, count: events.length, events });\n }\n\n return json({ error: \"not found\", routes: [\"GET /\", \"POST /event\", \"POST /status\", \"GET /events\"] }, 404);\n } catch (e) {\n return json({ error: String(e) }, 500);\n }\n}\n",[234],"c0f5000c-de71-4c57-b9db-11cc0657ebcb","main.ts","ea7bf146-7d50-11f1-b2df-1607ee4eb77e",["D",1783792190990],"script","// virtual-team — الفريق الافتراضي\n// العمود الفقري: الذاكرة المشتركة (memory.ts) + التنسيق لاحقًا.\nexport const about = \"virtual-team backbone\";\n",[239],"d738e08c-7a1f-4c21-968b-8dd69fe37cc1","heartbeat.ts","347fa8c0-7ebc-11f1-ba24-1607ee4eb77e",39,["D",1783948222479],"// 💓 heartbeat — يفحص صحّة نقاط الفريق كل تشغيل، وينذر Slack فقط عند **تغيّر** الحالة (توقّف/عودة) — بلا تكرار.\n// مجدول كـ interval. يقرأ VT_TEAM_KEY (للنقاط المقفولة) و SLACK_BOT_TOKEN (للإنذار). قناة الإنذار: HEARTBEAT_CHANNEL أو الهندسة افتراضيًا.\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst TARGETS = [\n { name: \"memory\", url: \"https://asnfq50--fb2957b87d5011f1b2041607ee4eb77e.web.val.run/\", auth: false },\n { name: \"agent\", url: \"https://asnfq50--4eee88c27d5211f18e4e1607ee4eb77e.web.val.run/\", auth: false },\n { name: \"orchestrate\", url: \"https://asnfq50--90f8ea507d5211f18c341607ee4eb77e.web.val.run/\", auth: false },\n { name: \"costs\", url: \"https://asnfq50--bcbccefe7eba11f1b41a1607ee4eb77e.web.val.run/\", auth: true },\n { name: \"track\", url: \"https://asnfq50--c5ecef547eba11f1b3651607ee4eb77e.web.val.run/\", auth: false },\n];\n\nfunction rowsToObjects(rs: any): any[] {\n const cols: string[] = rs?.columns ?? [];\n return (rs?.rows ?? []).map((r: any) => Array.isArray(r) ? Object.fromEntries(cols.map((c, i) => [c, r[i]])) : r);\n}\n\nasync function slack(text: string) {\n const token = Deno.env.get(\"SLACK_BOT_TOKEN\");\n const channel = Deno.env.get(\"HEARTBEAT_CHANNEL\") || \"C0BGRV10RJ6\";\n if (!token) return;\n await fetch(\"https://slack.com/api/chat.postMessage\", {\n method: \"POST\",\n headers: { authorization: `Bearer ${token}`, \"content-type\": \"application/json; charset=utf-8\" },\n body: JSON.stringify({ channel, text }),\n }).catch(() => {});\n}\n\nexport default async function () {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS vt_heartbeat (endpoint TEXT PRIMARY KEY, status TEXT, since TEXT)`);\n const key = Deno.env.get(\"VT_TEAM_KEY\");\n const changes: string[] = [];\n\n for (const t of TARGETS) {\n let ok = false;\n try {\n const res = await fetch(t.url, {\n headers: t.auth && key ? { authorization: `Bearer ${key}` } : {},\n signal: AbortSignal.timeout(12000),\n });\n ok = res.ok;\n } catch { ok = false; }\n const status = ok ? \"up\" : \"down\";\n\n const prev = rowsToObjects(await sqlite.execute(`SELECT status FROM vt_heartbeat WHERE endpoint=?`, [t.name]))[0]?.status ?? null;\n if (prev !== status) {\n await sqlite.execute(\n `INSERT INTO vt_heartbeat (endpoint,status,since) VALUES (?,?,?) ON CONFLICT(endpoint) DO UPDATE SET status=excluded.status, since=excluded.since`,\n [t.name, status, new Date().toISOString()]);\n if (prev !== null) changes.push(status === \"down\" ? `🔴 *${t.name}* توقّف` : `🟢 *${t.name}* رجع`);\n }\n }\n\n if (changes.length) await slack(\"💓 *heartbeat — تغيّر حالة نقاط الفريق*\\n\" + changes.join(\"\\n\"));\n console.log(\"heartbeat: checked\", TARGETS.length, \"endpoints; changes:\", changes.length);\n return { checked: TARGETS.length, changes };\n}\n",[246],"cd358288-916a-4269-a732-e7f305e5615a","daily.ts","ccc79f6c-7d71-11f1-a205-1607ee4eb77e",19,["D",1783838014438],3,"// ⏰ المراجعة التشغيلية اليومية (تلقائية)\n// يشغّل المنسّق بهدف يومي قياسي؛ التقارير + الخلاصة تُسجَّل في الذاكرة وتُنشر في Slack.\n// مجدول كـ interval (cron). يحتاج ANTHROPIC_API_KEY (للأدمغة) و SLACK_BOT_TOKEN (للنشر).\n\nconst ORCH = \"https://asnfq50--90f8ea507d5211f18c341607ee4eb77e.web.val.run\";\nconst DAILY_GOAL =\n \"المراجعة التشغيلية اليومية لـ qahwa-radar: حالة كل قسم بإيجاز + أهم القرارات المطلوبة اليوم.\";\n\nexport default async function () {\n const key = Deno.env.get(\"VT_TEAM_KEY\");\n const headers: Record = { \"content-type\": \"application/json\" };\n if (key) headers[\"authorization\"] = `Bearer ${key}`;\n\n const res = await fetch(ORCH, {\n method: \"POST\",\n headers,\n body: JSON.stringify({ goal: DAILY_GOAL, postSlack: true }),\n });\n const data = await res.json().catch(() => ({}));\n\n if (!res.ok) {\n console.log(`⚠️ daily review skipped (${res.status}):`, (data as any).error ?? \"unknown\");\n return;\n }\n console.log(\n \"✅ daily review done —\",\n ((data as any).reports?.length ?? 0),\n \"reports · slackPosted:\",\n (data as any).slackPosted,\n );\n}\n",[253],"5acb407b-4008-48d3-8d6b-a891d5afc62c","costs.ts","bcbccefe-7eba-11f1-b41a-1607ee4eb77e",35,["D",1783947592058],"// 💰 دفتر تكاليف الفريق — مصدر بيانات «المالية» (CFO). SQLite داخلي، بلا سرّ خارجي.\n// GET /?month=YYYY-MM → ملخّص: حرق الشهر بالريال + تفصيل لكل خدمة + السقف + المدرّج [VT_TEAM_KEY]\n// POST /set { service, amount_sar, month?, source? } → upsert [VT_TEAM_KEY]\n// جدول: vt_costs(service, month, amount_sar, source, updated_at)\n// السقف من env VT_BUDGET_SAR ، والرصيد من VT_CASH_SAR (اختياريان — يضبطهما المالك).\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nconst TABLE = \"vt_costs\";\nconst SEED = [\n { service: \"Val Town\", amount_sar: 0, source: \"estimate (free tier)\" },\n { service: \"n8n (self-hosted)\", amount_sar: 0, source: \"estimate (owner machine)\" },\n { service: \"Cloudflare\", amount_sar: 0, source: \"estimate (free plan)\" },\n { service: \"Claude API\", amount_sar: 40, source: \"estimate — يُستبدل بـAnthropicCostAPI\" },\n { service: \"Google Places\", amount_sar: 20, source: \"estimate — اضبط Cloud budget\" },\n { service: \"Bright Data\", amount_sar: 30, source: \"estimate — يُستبدل بـBrightDataAPI\" },\n { service: \"Apify\", amount_sar: 25, source: \"estimate — يُستبدل بـApifyUsageAPI\" },\n];\n\nfunction rowsToObjects(rs: any): any[] {\n const cols: string[] = rs?.columns ?? [];\n return (rs?.rows ?? []).map((r: any) => Array.isArray(r) ? Object.fromEntries(cols.map((c, i) => [c, r[i]])) : r);\n}\nfunction ym(): string { return new Date().toISOString().slice(0, 7); }\n\nasync function init() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS ${TABLE} (\n service TEXT NOT NULL, month TEXT NOT NULL, amount_sar REAL NOT NULL DEFAULT 0,\n source TEXT, updated_at TEXT, PRIMARY KEY (service, month))`);\n const rs = await sqlite.execute(`SELECT COUNT(*) AS c FROM ${TABLE}`);\n if (Number(rowsToObjects(rs)[0]?.c ?? 0) === 0) {\n const m = ym();\n for (const s of SEED) {\n await sqlite.execute(\n `INSERT OR IGNORE INTO ${TABLE} (service, month, amount_sar, source, updated_at) VALUES (?,?,?,?,?)`,\n [s.service, m, s.amount_sar, s.source, new Date().toISOString()]);\n }\n }\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const path = url.pathname.replace(/\\/+$/, \"\") || \"/\";\n const key = Deno.env.get(\"VT_TEAM_KEY\");\n const authed = !key || req.headers.get(\"authorization\") === `Bearer ${key}`;\n const json = (d: unknown, s = 200) => Response.json(d, { status: s });\n\n await init();\n if (!authed) return json({ error: \"unauthorized\" }, 401);\n\n if (req.method === \"POST\" && path === \"/set\") {\n const b = await req.json().catch(() => null);\n if (!b?.service || typeof b.amount_sar !== \"number\") return json({ error: \"service and amount_sar required\" }, 400);\n await sqlite.execute(\n `INSERT INTO ${TABLE} (service, month, amount_sar, source, updated_at) VALUES (?,?,?,?,?)\n ON CONFLICT(service, month) DO UPDATE SET amount_sar=excluded.amount_sar, source=excluded.source, updated_at=excluded.updated_at`,\n [b.service, b.month || ym(), b.amount_sar, b.source || \"manual\", new Date().toISOString()]);\n return json({ ok: true });\n }\n\n const m = url.searchParams.get(\"month\") || ym();\n const rs = await sqlite.execute(`SELECT service, amount_sar, source FROM ${TABLE} WHERE month=? ORDER BY amount_sar DESC`, [m]);\n const rows = rowsToObjects(rs);\n const total = rows.reduce((a, r) => a + Number(r.amount_sar || 0), 0);\n const cap = Number(Deno.env.get(\"VT_BUDGET_SAR\") || \"0\");\n const cash = Number(Deno.env.get(\"VT_CASH_SAR\") || \"0\");\n return json({\n ok: true, month: m, currency: \"SAR\",\n monthly_burn_sar: Math.round(total * 100) / 100,\n by_service: rows,\n budget_cap_sar: cap || null,\n over_budget: cap ? total > cap : null,\n runway_months: (cash && total) ? Math.round((cash / total) * 10) / 10 : null,\n note: \"أرقام أوّلية تقديرية — تُستبدل بأرقام حقيقية عند توصيل Cost APIs (Anthropic/Apify/BrightData).\",\n });\n}\n",[261],"552f95d3-af0f-4324-9e79-de1338ba23a0","approvals.ts","c17fb0a8-7ec1-11f1-b491-1607ee4eb77e",81,["D",1784017095307],"// ✅ قائمة الاعتماد الدائمة — التصعيدات التي تنتظر اعتماد المالك. دائمة، بلا تكرار.\n// GET / → البنود المنتظرة (awaiting) [?all=1 لعرض الكل] [VT_TEAM_KEY]\n// POST /raise → { owner, title, reason } رفع مُزال التكرار → { id, isNew }\n// POST /decide → { id, decision } (approved|rejected) ← اعتماد المالك\n// جدول: vt_approvals(id, owner, title, norm, reason, status, created_at, decided_at)\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nfunction norm(s: string): string {\n return (s || \"\").toLowerCase().replace(/[^\\p{L}\\p{N} ]/gu, \"\").replace(/\\s+/g, \" \").trim().slice(0, 80);\n}\n// Coarse theme so re-worded escalations about the same thing dedup together.\nfunction theme(s: string): string {\n const t = (s || \"\").toLowerCase();\n if (/سقف|حرق|ميزاني|budget|cap|cost|تكلف|صرف|إنفاق|runway/.test(t)) return \"budget\";\n if (/check|gps|ميدان|جيو|تشيك/.test(t)) return \"checkin\";\n if (/نمو|موجة|مؤثر|تسويق|launch|growth|دعوات|early|إطلاق/.test(t)) return \"growth\";\n if (/إثراء|enrich/.test(t)) return \"enrich\";\n if (/تحقّق|تحقق|verif/.test(t)) return \"verify\";\n return norm(s).slice(0, 40);\n}\nfunction rowsToObjects(rs: any): any[] {\n const cols: string[] = rs?.columns ?? [];\n return (rs?.rows ?? []).map((r: any) => Array.isArray(r) ? Object.fromEntries(cols.map((c, i) => [c, r[i]])) : r);\n}\nasync function init() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS vt_approvals (\n id INTEGER PRIMARY KEY AUTOINCREMENT, owner TEXT, title TEXT, norm TEXT, reason TEXT,\n status TEXT NOT NULL DEFAULT 'awaiting', created_at TEXT, decided_at TEXT)`);\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const path = url.pathname.replace(/\\/+$/, \"\") || \"/\";\n const key = Deno.env.get(\"VT_TEAM_KEY\");\n const authed = !key || req.headers.get(\"authorization\") === `Bearer ${key}`;\n const CORS: Record = { \"access-control-allow-origin\": \"*\", \"access-control-allow-methods\": \"GET,POST,OPTIONS\", \"access-control-allow-headers\": \"authorization,content-type\" };\n const json = (d: unknown, s = 200) => new Response(JSON.stringify(d), { status: s, headers: { \"content-type\": \"application/json; charset=utf-8\", ...CORS } });\n if (req.method === \"OPTIONS\") return new Response(null, { status: 204, headers: CORS });\n await init();\n if (!authed) return json({ error: \"unauthorized\" }, 401);\n\n if (req.method === \"POST\" && path === \"/raise\") {\n const b = await req.json().catch(() => null);\n if (!b?.title) return json({ error: \"title required\" }, 400);\n const n = theme(b.title);\n const cutoff = new Date(Date.now() - 14 * 864e5).toISOString();\n const ex = rowsToObjects(await sqlite.execute(`SELECT id FROM vt_approvals WHERE owner=? AND norm=? AND (status='awaiting' OR created_at >= ?) ORDER BY id DESC LIMIT 1`, [b.owner || \"\", n, cutoff]));\n if (ex.length) return json({ ok: true, id: ex[0].id, isNew: false });\n await sqlite.execute(`INSERT INTO vt_approvals (owner,title,norm,reason,status,created_at) VALUES (?,?,?,?,?,?)`,\n [b.owner || \"\", b.title, n, b.reason || \"\", \"awaiting\", new Date().toISOString()]);\n const id = Number(rowsToObjects(await sqlite.execute(\"SELECT last_insert_rowid() AS id\"))[0]?.id);\n return json({ ok: true, id, isNew: true });\n }\n\n if (req.method === \"POST\" && path === \"/decide\") {\n const b = await req.json().catch(() => null);\n if (!b?.id || ![\"approved\", \"rejected\"].includes(b.decision)) return json({ error: \"id + decision(approved|rejected)\" }, 400);\n await sqlite.execute(`UPDATE vt_approvals SET status=?, decided_at=? WHERE id=?`, [b.decision, new Date().toISOString(), b.id]);\n return json({ ok: true, id: b.id, decision: b.decision });\n }\n\n const all = url.searchParams.get(\"all\") === \"1\";\n const rs = await sqlite.execute(all\n ? `SELECT id,owner,title,reason,status,created_at,decided_at FROM vt_approvals ORDER BY id DESC LIMIT 100`\n : `SELECT id,owner,title,reason,status,created_at FROM vt_approvals WHERE status='awaiting' ORDER BY id DESC`);\n const items = rowsToObjects(rs);\n return json({ ok: true, count: items.length, items });\n}\n",[268],"fd81dcb1-bdbf-42ea-a19d-4d7d34436658","apply.ts","a053c00e-7f5c-11f1-9c8a-1607ee4eb77e",82,["D",1784017122863],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nfunction toObj(rs: any): any[] {\n const c: string[] = rs?.columns ?? [];\n return (rs?.rows ?? []).map((r: any) => Array.isArray(r) ? Object.fromEntries(c.map((k, i) => [k, r[i]])) : r);\n}\nasync function setCfg(k: string, v: string) {\n await sqlite.execute(\"UPDATE vt_config SET value=? WHERE key=?\", [v, k]);\n const ex = toObj(await sqlite.execute(\"SELECT 1 x FROM vt_config WHERE key=?\", [k]));\n if (!ex.length) await sqlite.execute(\"INSERT INTO vt_config (key,value) VALUES (?,?)\", [k, v]);\n}\nconst now = new Date().toISOString();\nconst out: any = {};\n\n// #1 — write the approved monthly burn cap (was empty → drove the CFO loop)\nawait setCfg(\"budget_cap_sar\", \"300\");\n\n// #5 — record the owner's real decisions so future reviews are grounded + honest\nconst directive = \"قرارات المالك (14 يوليو 2026): (1) سقف الحرق المعتمد = 300 ريال/شهر. (2) لا ميزانية مؤثّرين. (3) اعتمد الأمور الهندسية. (4) نوقف النمو وننتظر الهندسة. (5) GPS check-in يبنيه المالك/مطوّر فعلي — خارج قدرة وكلاء المجلس؛ يركّز المجلس على ما يؤثّر فيه فعلًا: الإثراء/التحقّق/التصنيف/انضباط التكلفة.\";\nawait setCfg(\"owner_directive\", directive);\n\n// #2 — resolve the 13 awaiting duplicates per the owner's actual Slack decisions,\n// and set norm=theme so the new dedup blocks re-raising them.\nawait sqlite.execute(\"UPDATE vt_approvals SET status='approved', decided_at=?, norm='budget' WHERE status='awaiting' AND owner='cfo'\", [now]);\nawait sqlite.execute(\"UPDATE vt_approvals SET status='approved', decided_at=?, norm='checkin' WHERE status='awaiting' AND owner='eng'\", [now]);\nawait sqlite.execute(\"UPDATE vt_approvals SET status='rejected', decided_at=?, norm='growth' WHERE status='awaiting' AND owner='marketing'\", [now]);\n\n// #5 — honest reframe of the critical blocker (item 3): it needs real-world action, not the board\nconst p3 = \"معطّل على إجراء واقعي: بناء واجهة check-in + اختبار ميداني فعلي عند قهوة — خارج قدرة وكلاء المجلس (لا يبنون/يختبرون كودًا). ينتظر المالك أو مطوّرًا. المجلس يركّز على ما يؤثّر فيه فعلًا: الإثراء/التحقّق/التصنيف/التكلفة.\";\nawait sqlite.execute(\"UPDATE vt_plan SET status='blocked', progress=?, updated_at=? WHERE id=3\", [p3, now]);\n\n// verify\nout.config = toObj(await sqlite.execute(\"SELECT key,value FROM vt_config ORDER BY key\"));\nout.approvals_summary = toObj(await sqlite.execute(\"SELECT status, COUNT(*) n FROM vt_approvals GROUP BY status\"));\nout.awaiting_left = toObj(await sqlite.execute(\"SELECT COUNT(*) n FROM vt_approvals WHERE status='awaiting'\"))[0];\nout.plan3 = toObj(await sqlite.execute(\"SELECT id,status,substr(progress,1,70) progress FROM vt_plan WHERE id=3\"))[0];\nconsole.log(JSON.stringify(out, null, 2));\n",[275],"f9e46931-16da-44a6-8b34-0935a0975016","agent.ts","4eee88c2-7d52-11f1-8e4e-1607ee4eb77e",46,["D",1783949824579],10,"// 🤖 دماغ الوكلاء (Agent Brain)\n// يقرأ السياق المشترك + ميثاق القسم + (بيانات حيّة إن توفّرت) → Claude (retry/backoff) → يكتب للذاكرة → يرجّع.\n//\n// المسارات:\n// GET / → قائمة الوكلاء\n// GET /?agent=eng&debug=1 → معاينة الـsystem prompt (بدون مفتاح)\n// POST / { agent, task, log? } → يشغّل الوكيل (يحتاج ANTHROPIC_API_KEY)\n//\n// env: ANTHROPIC_API_KEY · AGENT_MODEL · VT_TEAM_KEY · MEMORY_URL\n// البيانات الحيّة (اختيارية، كل مصدر بسرّه): QAHWA_OPS_SECRET (هندسة) · [لاحقًا: QuickBooks/Supermetrics]\n\nimport { readFile } from \"https://esm.town/v/std/utils/index.ts\";\n\ntype AgentDef = { name: string; charter: string; channel: string };\nconst AGENTS: Record = {\n ceo: { name: \"المدير التنفيذي\", charter: \"agents/ceo.md\", channel: \"#الإدارة\" },\n cfo: { name: \"المدير المالي\", charter: \"agents/cfo.md\", channel: \"#المالية\" },\n marketing: { name: \"مدير التسويق\", charter: \"agents/marketing.md\", channel: \"#التسويق\" },\n eng: { name: \"مدير المشاريع البرمجية\", charter: \"agents/engineering-pm.md\", channel: \"#الهندسة\" },\n};\n\nconst MEMORY_FALLBACK = \"https://asnfq50--fb2957b87d5011f1b2041607ee4eb77e.web.val.run\";\nconst QAHWA_OPS = \"https://asnfq50--8548c9527b8411f18de41607ee4eb77e.web.val.run\";\nconst COSTS_URL = \"https://asnfq50--bcbccefe7eba11f1b41a1607ee4eb77e.web.val.run\";\nconst TRACK_URL = \"https://asnfq50--c5ecef547eba11f1b3651607ee4eb77e.web.val.run\";\nconst PLAN_URL = \"https://asnfq50--b9847cc07ebd11f1976c1607ee4eb77e.web.val.run\";\n\nasync function load(path: string): Promise {\n return await readFile(\"/\" + path.replace(/^\\/+/, \"\"), import.meta.url);\n}\n\n// 🔌 البيانات الحيّة: لكل وكيل مصدر فعلي (مقيّد للقراءة). يرجّع نصًا يُحقَن في المهمة، أو null.\nasync function liveDataFor(agentKey: string): Promise {\n if (agentKey === \"eng\") {\n const secret = Deno.env.get(\"QAHWA_OPS_SECRET\");\n if (!secret) return null; // غير مفعّل — انسخ WEBHOOK_SECRET من qahwa-radar لـ env الفريق\n try {\n const res = await fetch(`${QAHWA_OPS}/?action=stats&secret=${encodeURIComponent(secret)}`);\n if (!res.ok) return null;\n const d = await res.json();\n if (!d?.ok) return null;\n const compact = JSON.stringify(\n {\n brain: d.brain,\n enrichment: d.enrichment,\n tags: d.tags,\n social: d.social, // تقدّم بناء الموقع الاجتماعي: مستخدمون/جلسات/check-ins/تقييمات/متابعات\n recentAlerts: d.recentAlerts,\n },\n null, 2,\n ).slice(0, 2200);\n return \"إحصاءات qahwa-radar الحيّة (من ops/stats — أرقام فعلية الآن؛ `social` = عدّاد بناء الموقع الاجتماعي):\\n\" + compact;\n } catch { return null; }\n }\n if (agentKey === \"ceo\") {\n const key = Deno.env.get(\"VT_TEAM_KEY\");\n try {\n const res = await fetch(PLAN_URL + \"/\", { headers: key ? { authorization: `Bearer ${key}` } : {} });\n if (!res.ok) return null;\n const d = await res.json();\n return \"الخطة الحيّة للمرحلة الأولى (النجم-الشمالي + الملخّص + البنود + ميثاق المالك) — قرارك يحرّك البنود ويصعّد ما يحتاج اعتماد المالك:\\n\" + JSON.stringify({ north_star: d.north_star, summary: d.summary, config: d.config, plan: d.plan }, null, 2).slice(0, 2600);\n } catch { return null; }\n }\n if (agentKey === \"cfo\") {\n const key = Deno.env.get(\"VT_TEAM_KEY\");\n try {\n const res = await fetch(COSTS_URL + \"/\", { headers: key ? { authorization: `Bearer ${key}` } : {} });\n if (!res.ok) return null;\n const d = await res.json();\n return \"دفتر التكاليف الحيّ (بالريال، الشهر الحالي — أرقام أوّلية تقديرية حتى توصيل Cost APIs):\\n\" + JSON.stringify(d, null, 2).slice(0, 2000);\n } catch { return null; }\n }\n if (agentKey === \"marketing\") {\n const key = Deno.env.get(\"VT_TEAM_KEY\");\n try {\n const res = await fetch(TRACK_URL + \"/stats\", { headers: key ? { authorization: `Bearer ${key}` } : {} });\n if (!res.ok) return null;\n const d = await res.json();\n const links = d.links ?? [];\n const body = links.length\n ? JSON.stringify(links, null, 2).slice(0, 1800)\n : \"لا روابط تتبّع بعد — أنشئ رابطًا /r/:code لكل قناة/مؤثّر عبر POST /link لتبدأ الإسناد الفعلي.\";\n return \"إسناد روابط النمو الحيّ (نقرات لكل قناة/مؤثّر):\\n\" + body;\n } catch { return null; }\n }\n // cfo → Anthropic/Apify/BrightData Cost APIs · marketing → Cloudflare Analytics: تُضاف عند توصيل أسرارها\n return null;\n}\n\nasync function buildSystemPrompt(key: string): Promise {\n const a = AGENTS[key];\n const [context, charter] = await Promise.all([load(\"team-context.md\"), load(a.charter)]);\n return [\n `أنت «${a.name}» ضمن فريق عمل افتراضي يعمل بالعربية داخل مساحة Slack.`,\n `التزم بالحدود والسياق أدناه، واتبع «صيغة المخرجات» في ميثاقك بدقة. كن موجزًا.`,\n `إن استلزمت المهمة فعلًا ممنوعًا أو يحتاج موافقة بشرية، لا تنفّذه — اقترحه وصعّده بوضوح.`,\n `# السياق المشترك\\n${context}`,\n `# ميثاقك\\n${charter}`,\n ].join(\"\\n\\n---\\n\\n\");\n}\n\nasync function callClaude(system: string, task: string, apiKey: string, model: string): Promise {\n const payload = JSON.stringify({ model, max_tokens: 4000, system, messages: [{ role: \"user\", content: task }] });\n let lastErr = \"unknown\";\n for (let attempt = 0; attempt < 4; attempt++) {\n if (attempt) await new Promise((r) => setTimeout(r, 700 * attempt * attempt));\n let res: Response;\n try {\n res = await fetch(\"https://api.anthropic.com/v1/messages\", {\n method: \"POST\",\n headers: { \"x-api-key\": apiKey, \"anthropic-version\": \"2023-06-01\", \"content-type\": \"application/json\" },\n body: payload,\n });\n } catch (e) { lastErr = \"network: \" + e; continue; }\n if (res.status === 429 || res.status === 529 || res.status >= 500) { lastErr = \"http \" + res.status; continue; }\n const data = await res.json().catch(() => null);\n if (!res.ok) throw new Error(data?.error?.message || `Anthropic ${res.status}`);\n const text = (data?.content ?? []).map((b: any) => b?.text ?? \"\").join(\"\").trim();\n if (text) return text;\n lastErr = \"empty reply\";\n }\n throw new Error(`Claude call failed after retries: ${lastErr}`);\n}\n\nasync function logToMemory(memUrl: string, teamKey: string | undefined, ev: Record) {\n const headers: Record = { \"content-type\": \"application/json\" };\n if (teamKey) headers[\"authorization\"] = `Bearer ${teamKey}`;\n await fetch(memUrl.replace(/\\/+$/, \"\") + \"/event\", { method: \"POST\", headers, body: JSON.stringify(ev) }).catch(() => {});\n}\n\nexport default async function (req: Request): Promise {\n const url = new URL(req.url);\n const json = (d: unknown, s = 200) =>\n new Response(JSON.stringify(d, null, 2), {\n status: s,\n headers: { \"content-type\": \"application/json; charset=utf-8\", \"access-control-allow-origin\": \"*\" },\n });\n\n if (req.method === \"OPTIONS\") {\n return new Response(null, { status: 204, headers: { \"access-control-allow-origin\": \"*\", \"access-control-allow-methods\": \"GET,POST,OPTIONS\", \"access-control-allow-headers\": \"authorization,content-type\" } });\n }\n\n const TEAM_KEY = Deno.env.get(\"VT_TEAM_KEY\");\n\n try {\n if (req.method === \"GET\" && url.searchParams.get(\"debug\")) {\n const key = url.searchParams.get(\"agent\") ?? \"\";\n if (!AGENTS[key]) return json({ error: `unknown agent: ${key}`, agents: Object.keys(AGENTS) }, 400);\n const sys = await buildSystemPrompt(key);\n const live = await liveDataFor(key);\n return json({ ok: true, agent: key, name: AGENTS[key].name, channel: AGENTS[key].channel, systemPromptChars: sys.length, liveData: live ? \"متوفّرة ✓\" : \"غير مفعّلة\", preview: sys.slice(0, 1200) });\n }\n\n if (req.method === \"GET\") {\n return json({\n ok: true, service: \"virtual-team · agent brain\",\n agents: Object.entries(AGENTS).map(([k, v]) => ({ key: k, name: v.name, channel: v.channel })),\n usage: { debug: \"GET /?agent=eng&debug=1\", run: \"POST { agent, task }\" },\n });\n }\n\n if (req.method === \"POST\") {\n if (TEAM_KEY && req.headers.get(\"authorization\") !== `Bearer ${TEAM_KEY}`) {\n return json({ error: \"unauthorized\" }, 401);\n }\n const b = await req.json().catch(() => null);\n const key = b?.agent;\n const task = b?.task;\n if (!key || !AGENTS[key]) return json({ error: `agent required — one of ${Object.keys(AGENTS).join(\", \")}` }, 400);\n if (!task || typeof task !== \"string\") return json({ error: \"task (string) required\" }, 400);\n\n const API_KEY = Deno.env.get(\"ANTHROPIC_API_KEY\");\n if (!API_KEY) return json({ error: \"أضِف ANTHROPIC_API_KEY في env الـval لتشغيل الأدمغة\", needsKey: true }, 503);\n\n const model = (typeof b.model === \"string\" && b.model) || Deno.env.get(\"AGENT_MODEL\") || \"claude-sonnet-5\";\n const system = await buildSystemPrompt(key);\n\n // حقن البيانات الحيّة في المهمة إن توفّرت\n const live = await liveDataFor(key);\n const fullTask = live\n ? `${task}\\n\\n---\\n## بيانات حيّة متاحة لك الآن (استخدمها بأرقامها الفعلية — لا تقل «لا أملك بيانات»):\\n${live}`\n : task;\n\n const reply = await callClaude(system, fullTask, API_KEY, model);\n\n if (b.log !== false) {\n await logToMemory(Deno.env.get(\"MEMORY_URL\") || MEMORY_FALLBACK, TEAM_KEY, {\n agent: key, type: \"report\", title: `رد ${AGENTS[key].name}`, body: reply.slice(0, 8000), impact: \"internal\",\n });\n }\n return json({ ok: true, agent: key, name: AGENTS[key].name, model, liveData: Boolean(live), reply });\n }\n\n return json({ error: \"not found\" }, 404);\n } catch (e) {\n return json({ error: String(e) }, 500);\n }\n}\n",[282],"5ff33df0-941c-499e-b18c-20c27fede4dc","agents","f33a438b-1c5a-4ba7-aac7-de41411e41cd",["D",1783792718124],"directory",[290],"pulls","branches","forks","envVars",{"_302":304,"_305":63},"connections",{"_302":63,"_303":63},"count","unfilledCount",7,"emptyCount",{"_43":289,"_32":290,"_30":291,"_154":-5,"_41":42,"_40":196,"_156":59,"_38":420,"_13":63,"_33":293,"_35":-5,"_24":25,"_160":-5,"_331":421,"_27":422},{"_43":412,"_32":413,"_30":414,"_154":291,"_41":42,"_40":415,"_156":59,"_38":416,"_13":167,"_33":20,"_35":417,"_24":25,"_160":-5,"_331":418,"_27":419},{"_43":404,"_32":405,"_30":406,"_154":291,"_41":42,"_40":407,"_156":59,"_38":408,"_13":167,"_33":20,"_35":409,"_24":25,"_160":-5,"_331":410,"_27":411},{"_43":396,"_32":397,"_30":398,"_154":291,"_41":42,"_40":399,"_156":59,"_38":400,"_13":167,"_33":20,"_35":401,"_24":25,"_160":-5,"_331":402,"_27":403},{"_43":388,"_32":389,"_30":390,"_154":291,"_41":42,"_40":391,"_156":59,"_38":392,"_13":167,"_33":20,"_35":393,"_24":25,"_160":-5,"_331":394,"_27":395},{"_43":281,"_32":282,"_30":283,"_154":-5,"_41":42,"_40":284,"_156":25,"_38":385,"_13":286,"_33":158,"_35":287,"_24":25,"_160":-5,"_331":386,"_27":387},{"_43":274,"_32":275,"_30":276,"_154":-5,"_41":42,"_40":277,"_156":25,"_38":382,"_13":63,"_33":242,"_35":279,"_24":25,"_160":-5,"_331":383,"_27":384},{"_43":267,"_32":268,"_30":269,"_154":-5,"_41":42,"_40":270,"_156":59,"_38":379,"_13":257,"_33":158,"_35":272,"_24":25,"_160":-5,"_331":380,"_27":381},{"_43":260,"_32":261,"_30":262,"_154":-5,"_41":42,"_40":263,"_156":59,"_38":376,"_13":63,"_33":158,"_35":265,"_24":25,"_160":-5,"_331":377,"_27":378},{"_43":252,"_32":253,"_30":254,"_154":-5,"_41":42,"_40":255,"_156":59,"_38":373,"_13":257,"_33":242,"_35":258,"_24":25,"_160":-5,"_331":374,"_27":375},{"_43":245,"_32":246,"_30":247,"_154":-5,"_41":42,"_40":248,"_156":59,"_38":370,"_13":63,"_33":34,"_35":250,"_24":25,"_160":-5,"_331":371,"_27":372},{"_43":238,"_32":239,"_30":240,"_154":-5,"_41":42,"_40":167,"_156":59,"_38":367,"_13":63,"_33":242,"_35":243,"_24":25,"_160":-5,"_331":368,"_27":369},{"_43":233,"_32":234,"_30":57,"_154":-5,"_41":42,"_40":207,"_156":59,"_38":364,"_13":167,"_33":158,"_35":236,"_24":25,"_160":-5,"_331":365,"_27":366},{"_43":225,"_32":226,"_30":227,"_154":-5,"_41":42,"_40":228,"_156":59,"_38":361,"_13":230,"_33":158,"_35":231,"_24":25,"_160":-5,"_331":362,"_27":363},{"_43":217,"_32":218,"_30":219,"_154":-5,"_41":42,"_40":220,"_156":59,"_38":358,"_13":222,"_33":158,"_35":223,"_24":25,"_160":-5,"_331":359,"_27":360},{"_43":210,"_32":211,"_30":212,"_154":-5,"_41":42,"_40":213,"_156":59,"_38":355,"_13":167,"_33":158,"_35":215,"_24":25,"_160":-5,"_331":356,"_27":357},{"_43":202,"_32":203,"_30":204,"_154":-5,"_41":42,"_40":205,"_156":25,"_38":352,"_13":207,"_33":158,"_35":208,"_24":25,"_160":-5,"_331":353,"_27":354},{"_43":199,"_32":28,"_30":31,"_154":-5,"_41":42,"_40":14,"_156":59,"_38":349,"_13":167,"_33":34,"_35":37,"_24":25,"_160":-5,"_331":350,"_27":351},{"_43":191,"_32":192,"_30":193,"_154":-5,"_41":42,"_40":194,"_156":59,"_38":346,"_13":196,"_33":158,"_35":197,"_24":25,"_160":-5,"_331":347,"_27":348},{"_43":184,"_32":185,"_30":186,"_154":-5,"_41":42,"_40":187,"_156":25,"_38":343,"_13":63,"_33":158,"_35":189,"_24":25,"_160":-5,"_331":344,"_27":345},{"_43":177,"_32":178,"_30":179,"_154":-5,"_41":42,"_40":180,"_156":59,"_38":340,"_13":63,"_33":158,"_35":182,"_24":25,"_160":-5,"_331":341,"_27":342},{"_43":170,"_32":171,"_30":172,"_154":-5,"_41":42,"_40":173,"_156":25,"_38":337,"_13":63,"_33":158,"_35":175,"_24":25,"_160":-5,"_331":338,"_27":339},{"_43":162,"_32":163,"_30":164,"_154":-5,"_41":42,"_40":165,"_156":25,"_38":334,"_13":167,"_33":20,"_35":168,"_24":25,"_160":-5,"_331":335,"_27":336},{"_43":151,"_32":152,"_30":153,"_154":-5,"_41":42,"_40":155,"_156":59,"_38":330,"_13":63,"_33":158,"_35":159,"_24":25,"_160":-5,"_331":332,"_27":333},["D",1783947607457],"children",[],[152],["D",1783848289713],[],[163],["D",1783839646235],[],[171],["D",1783841284754],[],[178],["D",1783953432025],[],[185],["D",1783953197281],[],[192],["D",1784017220617],[],[28],["D",1783951489474],[],[203],["D",1783951013934],[],[211],["D",1783950959645],[],[218],["D",1783849123615],[],[226],["D",1783809542218],[],[234],["D",1783792190990],[],[239],["D",1783948222479],[],[246],["D",1783838014438],[],[253],["D",1783947592058],[],[261],["D",1784017095307],[],[268],["D",1784017122863],[],[275],["D",1783949824579],[],[282],"f1bf02fc-8bad-4139-9d1d-d3bbd58dcb9f","marketing.md","31313226-7d52-11f1-b159-1607ee4eb77e",28,["D",1783848369424],"# 📣 عضو النمو — مجلس «رواد»\n\n**الدور:** تقرّر **كيف نبني شبكة المستخدمين الحقيقيين** — قلب استراتيجية البدء البارد وأساس اقتناع القهاوي لاحقًا. مجالك: الاكتساب · التفاعل · الفيروسية (check-in/فيد يجرّ الأصدقاء) · القنوات المحلية (إنستقرام/سناب/تيك توك/X) · مؤثرو القهوة.\n\n**مصدر قرارك:** الرؤية (السوق الشامل بالرياض · هوية «رواد» الدافئة) + الوضع الحالي. لا تلفّق أرقام أداء — إن غابت البيانات، قرّرك يكون تكتيكًا لبناء أول موجة.\n\n**تحسم بمنطق:** أي تكتيك يجيب أول مستخدمين حقيقيين متفاعلين بأقل كلفة؟ أيها يبني حلقة نمو ذاتية؟\n\n**صيغة المخرجات — قراري في النمو:**\n- ⭐ **القرار:** «نفعل X لبناء الشبكة، لأن Y» (تكتيك واحد قابل للتنفيذ الآن).\n- **القناة/الخطوة الأولى** المحدّدة.\n- **مقياس النجاح** (كيف نعرف إنه نجح).\n- **ما أحتاجه من المالك** (إن وُجد): اعتماد نشر/ميزانية.\n",[],[290,389],"5580ddbf-0821-4b93-85d3-878fe9b57062","engineering-pm.md","376d9de6-7d52-11f1-a2a4-1607ee4eb77e",27,["D",1783848346974],"# 🧑‍💻 عضو المنتج والهندسة — مجلس «رواد»\n\n**الدور:** تقرّر **ماذا نبني/نصلّح تقنيًا وبأي تسلسل** لإكمال المرحلة الأولى (الموقع الاجتماعي): GPS check-in · التقييمات الموثّقة · الفيد · جودة/اكتمال حصر المقاهي · دقّة تحديد المواقع (ركيزة التوثيق). تفكّر كمهندس منتج، لا كمُراقِب.\n\n**مصدر قرارك:** خط أنابيب qahwa-radar الحيّ (أرقام فعلية) + الرؤية + الوضع الحالي في السياق.\n\n**تحسم بمنطق:** ما الذي يقرّب الإطلاق أكثر؟ ما الذي يهدّد «الحقيقية» (الـcheck-in/الموقع)؟ ما الجاهز فعلًا؟\n\n**صيغة المخرجات — قراري الهندسي:**\n- ⭐ **القرار:** «نبني/نصلّح X التالي، لأن Y» (بند واحد حاسم قابل للتنفيذ الآن).\n- **التسلسل المقترح:** أهم ٢–٣ خطوات بعده.\n- **مخاطرة تقنية واحدة** تهدّد المرحلة + كيف نتجنّبها.\n- **ما أحتاجه من المالك** (إن وُجد): وصول/اعتماد.\n",[],[290,397],"4b2abb0d-63bb-4f21-b529-b1f6f45d2222","cfo.md","2b358318-7d52-11f1-8d5a-1607ee4eb77e",29,["D",1783848388192],"# 💰 عضو المالية — مجلس «رواد»\n\n**الدور:** تقرّر **انضباط الصرف وأولوياته** في بناء المرحلة الأولى — أين نصرف وأين نوفّر، وما القيمة مقابل الكلفة لكل خيار بناء. تحرس ألا نحرق المال قبل الوصول لشبكة المستخدمين. العملة: الريال.\n\n**مصدر قرارك:** الوضع الحالي + كلفة الأدوات المعروفة (Val Town · n8n · Claude API · Google Places · Bright Data · Apify) + الرؤية. لا يوجد إيراد بعد؛ التركيز على **كفاءة الحرق** حتى نبني الطلب. أي رقم غير مؤكّد يُصنّف «تقديري».\n\n**تحسم بمنطق:** هل هذا الصرف يقرّب الإطلاق/الشبكة؟ أين ازدواجية أو هدر نوقفه؟ ما أرخص طريق يوصل نفس القيمة؟\n\n**صيغة المخرجات — قراري المالي:**\n- ⭐ **القرار:** «نصرف على X / نوقف Y، لأن Z» (بند واحد قابل للتنفيذ الآن).\n- **أعلى بند كلفة أو هدر** يستحق الانتباه.\n- **تنبيه مالي واحد** يخصّ استدامة بناء المرحلة.\n- **ما أحتاجه من المالك** (إن وُجد): اعتماد إنفاق/توصيل مصدر مالي.\n",[],[290,405],"32763127-add7-4776-a47b-68c666fe47ff","ceo.md","24adc262-7d52-11f1-bd58-1607ee4eb77e",26,["D",1783848329718],"# 👔 رئيس مجلس إدارة «رواد»\n\n**الدور:** تقود جلسة المجلس، تجمع مداولات الأعضاء (المنتج/الهندسة · النمو · المالية)، وتُصدر **قرار المجلس الموحّد** لدفع المرحلة الأولى (بناء وإطلاق الموقع الاجتماعي). تفكّر بالرؤية، تحسم، وتحمي وقت المالك.\n\n**مبادئ:** تحسم بقرارات لا خيارات معلّقة · ترتّب حسب الأثر على «شبكة المستخدمين» والرؤية · لا تزعج المالك إلا بما يحتاج اعتماده فعلًا.\n\n**صيغة المخرجات — قرار المجلس:**\n- **الوضع:** سطران (أين نحن من المرحلة الأولى).\n- **من كل عضو:** سطر لقراره.\n- ⭐ **قرارات المجلس:** مرقّمة، مرتّبة بالأولوية، كل قرار «نفعل X لأن Y» — قابلة للتنفيذ فورًا.\n- **يحتاج اعتمادك (المالك):** فقط ما لا يقرّره المجلس وحده (إطلاق/إنفاق/عقود).\n- **التالي تنفيذيًا:** أول بند ينفّذه Claude الآن.\n- **المخاطر:** أعلى خطر على اكتمال المرحلة.\n",[],[290,413],["D",1783792718124],[307,308,309,310],[290],["D",1783792190948],["D",1789526460011],{"_100":99,"_108":104},{"_100":99,"_101":102,"_103":104,"_18":55,"_105":106,"_107":25},{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"ctx",{"_82":-5,"_128":461,"_462":463,"_464":465,"_466":25,"_467":25,"_468":25,"_469":59,"_470":-5,"_471":-7,"_472":-7,"_473":63,"_474":25,"_475":25,"_476":-5,"_477":25,"_478":25,"_479":25,"_480":-5},"ENV",{"_432":433,"_434":435,"_436":90,"_437":438,"_439":440,"_441":442,"_443":444,"_445":446,"_447":448,"_449":450,"_451":452,"_453":454,"_455":456,"_457":458,"_459":460},"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 · v83