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

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",[208],"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",[215],"f07f669c-34f3-442c-9f07-08f7e14798bc","memory.ts",12,["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",[223],"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",[229],"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",[236],"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",[243],"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",[251],"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",[258],"b3e21278-d5c6-4d1c-8203-a8bc4ee0a73a","agent.ts","4eee88c2-7d52-11f1-8e4e-1607ee4eb77e",103,["D",1784761787262],15,"// 🤖 دماغ الوكلاء (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 refEnrichment: d.refEnrichment, // ⬅️ الفجوة المعتمدة، محسوبة خادميًا\n ref: d.ref, // المصدر الحقيقي للنشاط والكتالوج المُثرى\n brain: d.brain,\n fsqEnrichment: d.fsqEnrichment,\n instagramEnrichment: d.instagramEnrichment,\n tags: d.tags,\n discoveryDbLocalOnly: d.discoveryDbLocalOnly_NOT_PRODUCT_USERS,\n recentAlerts: d.recentAlerts,\n },\n null, 2,\n ).slice(0, 3200);\n return [\n \"إحصاءات حيّة الآن (من ops/stats). **اقرأ التسميات بدقّة — الخلط بينها سبق أن أنتج أربع توصيات صرف خاطئة رُفضت كلها:**\",\n \"🔢 **قاعدة الأرقام (إلزامية):** انسخ كل رقم **حرفيًا** من هذا JSON. **ممنوع الحساب الذهني** — لا طرح، لا نسب، لا جمع. إن لم يكن الرقم موجودًا هنا فقل **«غير متاح»** ولا تقدّره ولا تقتبسه من الخطة أو من رسالة سابقة.\",\n \"• `refEnrichment` = **فجوة إثراء الكتالوج الوحيدة المعتمدة** (`total`/`enriched`/`gap`/`pct`) — جاهزة محسوبة. أي رقم آخر تسمّيه «فجوة» فهو خطأ.\",\n \"• `ref` = **المصدر الحقيقي** للنشاط والكتالوج (الخادم المرجعي rawad-cafe): `ref.social` هو التشك-إنات/المستخدمين الفعليون، و`ref.fsq` هو إثراء الكتالوج الفعلي (ساعات/سعر/تقييم/صور/ذروة)، و`ref.product` يبيّن أن التشك-إن **مفعّل** ونصف قطره.\",\n \"• `fsqEnrichment` = تغطية قاعدة **الاكتشاف** المحلية فقط، وكل عدّاد فيه مع مقامه. `candidatesWithFsq` هو عدد مَن **لديه** بيانات — **وليس فجوة** (قراءته كفجوة هي بالضبط الخطأ الذي أنتج «فجوة 1,342 مقهى» وهي غير صحيحة).\",\n \"• `instagramEnrichment` = إثراء **حسابات إنستقرام فقط** (`enriched`/`verified` = توثيق إنستقرام الأزرق) — **ليست** بيانات المقهى ولا تحقّق الموقع الجغرافي، ولا تصلح مقياساً لجاهزية التشك-إن. (رقم «6.7% معدّل تحقّق» الشهير كان هذا بالذات: 26 حسابًا موثّقًا من 384.)\",\n \"• `discoveryDbLocalOnly` = عدّادات قاعدة الاكتشاف المحلية — **ليست مستخدمي المنتج**؛ مستخدمو المنتج في `ref.social.users` وحدها.\",\n \"⛔ لا تستنتج نقصاً في بيانات الكتالوج من أرقام إنستقرام، ولا تطلب صرفاً لسدّ فجوة مغطّاة في `refEnrichment`.\",\n compact,\n ].join(\"\\n\");\n } catch { return null; }\n }\n if (agentKey === \"ceo\") {\n const key = Deno.env.get(\"VT_TEAM_KEY\");\n const opsSecret = Deno.env.get(\"QAHWA_OPS_SECRET\");\n try {\n // الرئيس كان يرى الخطة فقط، فينقل أرقام الأعضاء دون قدرة على نقضها.\n // صار يرى الحقائق الحيّة أيضًا ليقارن ما كتبه الأعضاء بما تقوله البيانات فعلاً.\n const [planRes, opsRes] = await Promise.all([\n fetch(PLAN_URL + \"/\", { headers: key ? { authorization: `Bearer ${key}` } : {} }),\n opsSecret\n ? fetch(`${QAHWA_OPS}/?action=stats&secret=${encodeURIComponent(opsSecret)}`).catch(() => null)\n : Promise.resolve(null),\n ]);\n if (!planRes.ok) return null;\n const d = await planRes.json();\n let facts = \"\";\n if (opsRes && opsRes.ok) {\n const o = await opsRes.json().catch(() => null);\n if (o?.ok) {\n facts = \"\\n\\n## الحقائق الحيّة (مرجعك لنقض أي رقم كتبه عضو)\\n\"\n + \"🔢 انسخ الأرقام حرفيًا. ممنوع الحساب الذهني. الرقم غير الموجود هنا = «غير متاح».\\n\"\n + \"`refEnrichment` = فجوة إثراء الكتالوج الوحيدة المعتمدة. `ref.social.users` = مستخدمو المنتج الفعليون (وليس عدد التشك-إنات).\\n\"\n + JSON.stringify({ refEnrichment: o.refEnrichment, ref: o.ref }, null, 2).slice(0, 1500)\n + \"\\n**إن ذكر عضو رقمًا يخالف ما سبق، صحّحه صراحة في قرارك بدل ترحيله.**\";\n }\n }\n return \"الخطة الحيّة للمرحلة الأولى (النجم-الشمالي + الملخّص + البنود + ميثاق المالك) — قرارك يحرّك البنود ويصعّد ما يحتاج اعتماد المالك:\\n\"\n + JSON.stringify({ north_star: d.north_star, summary: d.summary, config: d.config, plan: d.plan }, null, 2).slice(0, 2600)\n + \"\\n⚠️ عناوين بنود الخطة قد تحوي أرقامًا قديمة مجمّدة وقت كتابتها — **لا تقتبس رقمًا من عنوان بند**.\"\n + facts;\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 // معاينة البيانات الحيّة (عدّادات فقط، بلا أسرار) — تجعل صحّة الاتصال قابلة للفحص بدل افتراضها.\n return json({ ok: true, agent: key, name: AGENTS[key].name, channel: AGENTS[key].channel, systemPromptChars: sys.length, liveData: live ? \"متوفّرة ✓\" : \"غير مفعّلة\", livePreview: live ? live.slice(0, 1800) : null, preview: sys.slice(0, 600) });\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",[265],"5ff33df0-941c-499e-b18c-20c27fede4dc","agents","f33a438b-1c5a-4ba7-aac7-de41411e41cd",["D",1783792718124],"directory",[273],"pulls","branches","forks","envVars",{"_285":287,"_288":42},"connections",{"_285":42,"_286":42},"count","unfilledCount",7,"emptyCount",{"_18":272,"_20":273,"_132":274,"_134":-5,"_135":71,"_136":182,"_138":38,"_22":399,"_68":42,"_140":276,"_142":-5,"_144":26,"_145":-5,"_313":400,"_89":401},{"_18":391,"_20":392,"_132":393,"_134":274,"_135":71,"_136":394,"_138":38,"_22":395,"_68":160,"_140":100,"_142":396,"_144":26,"_145":-5,"_313":397,"_89":398},{"_18":383,"_20":384,"_132":385,"_134":274,"_135":71,"_136":386,"_138":38,"_22":387,"_68":160,"_140":100,"_142":388,"_144":26,"_145":-5,"_313":389,"_89":390},{"_18":375,"_20":376,"_132":377,"_134":274,"_135":71,"_136":378,"_138":38,"_22":379,"_68":160,"_140":100,"_142":380,"_144":26,"_145":-5,"_313":381,"_89":382},{"_18":367,"_20":368,"_132":369,"_134":274,"_135":71,"_136":370,"_138":38,"_22":371,"_68":160,"_140":100,"_142":372,"_144":26,"_145":-5,"_313":373,"_89":374},{"_18":264,"_20":265,"_132":266,"_134":-5,"_135":71,"_136":267,"_138":38,"_22":364,"_68":269,"_140":141,"_142":270,"_144":26,"_145":-5,"_313":365,"_89":366},{"_18":257,"_20":258,"_132":259,"_134":-5,"_135":71,"_136":260,"_138":38,"_22":361,"_68":247,"_140":141,"_142":262,"_144":26,"_145":-5,"_313":362,"_89":363},{"_18":250,"_20":251,"_132":252,"_134":-5,"_135":71,"_136":253,"_138":38,"_22":358,"_68":42,"_140":141,"_142":255,"_144":26,"_145":-5,"_313":359,"_89":360},{"_18":242,"_20":243,"_132":244,"_134":-5,"_135":71,"_136":245,"_138":38,"_22":355,"_68":247,"_140":232,"_142":248,"_144":26,"_145":-5,"_313":356,"_89":357},{"_18":235,"_20":236,"_132":237,"_134":-5,"_135":71,"_136":238,"_138":38,"_22":352,"_68":42,"_140":190,"_142":240,"_144":26,"_145":-5,"_313":353,"_89":354},{"_18":228,"_20":229,"_132":230,"_134":-5,"_135":71,"_136":160,"_138":38,"_22":349,"_68":42,"_140":232,"_142":233,"_144":26,"_145":-5,"_313":350,"_89":351},{"_18":222,"_20":223,"_132":36,"_134":-5,"_135":71,"_136":224,"_138":38,"_22":346,"_68":160,"_140":141,"_142":226,"_144":26,"_145":-5,"_313":347,"_89":348},{"_18":214,"_20":215,"_132":216,"_134":-5,"_135":71,"_136":217,"_138":38,"_22":343,"_68":219,"_140":141,"_142":220,"_144":26,"_145":-5,"_313":344,"_89":345},{"_18":207,"_20":208,"_132":209,"_134":-5,"_135":71,"_136":210,"_138":38,"_22":340,"_68":152,"_140":141,"_142":212,"_144":26,"_145":-5,"_313":341,"_89":342},{"_18":200,"_20":201,"_132":202,"_134":-5,"_135":71,"_136":203,"_138":38,"_22":337,"_68":160,"_140":141,"_142":205,"_144":26,"_145":-5,"_313":338,"_89":339},{"_18":193,"_20":194,"_132":195,"_134":-5,"_135":71,"_136":69,"_138":38,"_22":334,"_68":197,"_140":141,"_142":198,"_144":26,"_145":-5,"_313":335,"_89":336},{"_18":185,"_20":186,"_132":187,"_134":-5,"_135":71,"_136":188,"_138":38,"_22":331,"_68":160,"_140":190,"_142":191,"_144":26,"_145":-5,"_313":332,"_89":333},{"_18":177,"_20":178,"_132":179,"_134":-5,"_135":71,"_136":180,"_138":38,"_22":328,"_68":182,"_140":141,"_142":183,"_144":26,"_145":-5,"_313":329,"_89":330},{"_18":170,"_20":171,"_132":172,"_134":-5,"_135":71,"_136":173,"_138":38,"_22":325,"_68":152,"_140":141,"_142":175,"_144":26,"_145":-5,"_313":326,"_89":327},{"_18":163,"_20":164,"_132":165,"_134":-5,"_135":71,"_136":166,"_138":38,"_22":322,"_68":42,"_140":141,"_142":168,"_144":26,"_145":-5,"_313":323,"_89":324},{"_18":155,"_20":156,"_132":157,"_134":-5,"_135":71,"_136":158,"_138":38,"_22":319,"_68":160,"_140":141,"_142":161,"_144":26,"_145":-5,"_313":320,"_89":321},{"_18":147,"_20":148,"_132":149,"_134":-5,"_135":71,"_136":150,"_138":38,"_22":316,"_68":152,"_140":100,"_142":153,"_144":26,"_145":-5,"_313":317,"_89":318},{"_18":130,"_20":131,"_132":133,"_134":-5,"_135":71,"_136":137,"_138":38,"_22":312,"_68":42,"_140":141,"_142":143,"_144":26,"_145":-5,"_313":314,"_89":315},["D",1783947607457],"children",[],[131],["D",1784761686481],[],[148],["D",1784761546630],[],[156],["D",1783841284754],[],[164],["D",1784761835818],[],[171],["D",1783953197281],[],[178],["D",1784017220617],[],[186],["D",1784761872825],[],[194],["D",1783951013934],[],[201],["D",1783950959645],[],[208],["D",1783849123615],[],[215],["D",1783809542218],[],[223],["D",1783792190990],[],[229],["D",1783948222479],[],[236],["D",1783838014438],[],[243],["D",1783947592058],[],[251],["D",1784017095307],[],[258],["D",1784761787262],[],[265],"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",[],[273,368],"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",[],[273,376],"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",[],[273,384],"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",[],[273,392],["D",1783792718124],[290,291,292,293],[273],["D",1783792190948],["D",1789439460012],{"_16":17,"_87":83},{"_16":17,"_80":81,"_82":83,"_33":34,"_84":85,"_86":26},{"_68":69,"_20":70,"_18":71,"_72":19,"_73":-5,"_74":-5,"_75":-5,"_76":-5,"_77":-5,"_78":21,"_79":17},"ctx",{"_61":-5,"_108":440,"_441":442,"_443":444,"_445":26,"_446":26,"_447":26,"_448":38,"_449":-5,"_450":-7,"_451":-7,"_452":42,"_453":26,"_454":26,"_455":-5,"_456":26,"_457":26,"_458":26,"_459":-5},"ENV",{"_411":412,"_413":414,"_415":70,"_416":417,"_418":419,"_420":421,"_422":423,"_424":425,"_426":427,"_428":429,"_430":431,"_432":433,"_434":435,"_436":437,"_438":439},"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"]

🔑 الدخول

🗺️ الخطة الحيّة

⏳ بانتظار اعتمادك

Search