[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_248":249,"_250":251},"routes/_app.x.$handle.$name",{"_105":104,"_37":50,"_113":95,"_32":108,"_13":14,"_114":-5,"_11":115,"_116":117,"_118":119,"_120":121,"_122":123,"_26":-5,"_124":-5,"_125":-5,"_126":30,"_127":128,"_129":30,"_130":-5,"_131":-5,"_132":133},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_48":49,"_37":50,"_43":51,"_52":-5,"_53":30,"_54":55,"_56":55,"_57":58,"_59":-5,"_19":60,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":68,"_69":70,"_71":72,"_73":74,"_75":76,"_77":-5,"_78":79,"_80":79,"_81":82,"_83":82,"_84":82,"_85":79,"_86":79,"_87":88,"_89":90,"_91":92,"_93":30},"version",10,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","80fc1b47-68c7-4a2d-8a9d-65356b966e9a","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":-7,"_29":30,"_31":30,"_32":33,"_34":33},"file",{"_35":36,"_37":38,"_39":40,"_41":42,"_43":44,"_45":14,"_46":47,"_29":30},"previous","deleted",false,"deletedHere","path","handlers/access.ts","latestPath","fileId","15877cd2-3f23-11f1-96ce-42b51c65c3df","name","access.ts","fileType","script","content","// Access / gating: channel join + referral gate\nimport * as db from \"../database/queries.ts\";\nimport * as tg from \"../lib/telegram.ts\";\nimport { HOST_DURATION_SECONDS, REFERRALS_REQUIRED } from \"../lib/utils.ts\";\n\nconst BOT_TOKEN = \"8779579899:AAEN9iro-5zo8Hr5XDKJ18iLSnr3FPkvefo\";\nconst CHANNEL = \"@ScottHubs\";\nconst ADMIN_ID = 6511143869;\n\nexport function isAdmin(tgId: number): boolean {\n return tgId === ADMIN_ID;\n}\n\nexport async function ensureChannelJoined(chatId: number, userId: number): Promise {\n if (isAdmin(userId)) {\n await db.markJoined(userId, true);\n return true;\n }\n const r = await tg.checkChannelMember(BOT_TOKEN, CHANNEL, userId);\n if (r.ok && r.isMember) {\n await db.markJoined(userId, true);\n return true;\n }\n await db.markJoined(userId, false);\n await tg.sendMessage(\n BOT_TOKEN,\n chatId,\n `🔒 Join Required\\n\\nTo use ScottHub you must join our channel:\\n👉 https://t.me/ScottHubs\\n\\nAfter joining, press /start again.`,\n { reply_markup: tg.REMOVE_KEYBOARD },\n );\n return false;\n}\n\nexport async function canHost(userId: number): Promise<\n { allowed: true; reason: \"admin\" | \"referrals\" | \"active\" } | { allowed: false; need: number; have: number }\n> {\n if (isAdmin(userId)) return { allowed: true, reason: \"admin\" };\n const user = await db.getUser(userId);\n if (!user) return { allowed: false, need: REFERRALS_REQUIRED, have: 0 };\n\n const project = await db.getProjectByOwner(userId);\n const now = Math.floor(Date.now() / 1000);\n if (project && project.expires_at && project.expires_at > now) {\n return { allowed: true, reason: \"active\" };\n }\n\n if (user.referral_count >= REFERRALS_REQUIRED) {\n return { allowed: true, reason: \"referrals\" };\n }\n return { allowed: false, need: REFERRALS_REQUIRED, have: user.referral_count };\n}\n\nexport async function claimHostSlot(userId: number): Promise<\n { ok: true; expiresAt: number } | { ok: false; reason: string }\n> {\n if (isAdmin(userId)) {\n return { ok: true, expiresAt: Math.floor(Date.now() / 1000) + HOST_DURATION_SECONDS };\n }\n const user = await db.getUser(userId);\n if (!user) return { ok: false, reason: \"User not found\" };\n if (user.referral_count < REFERRALS_REQUIRED) {\n return { ok: false, reason: `Need ${REFERRALS_REQUIRED} referrals (you have ${user.referral_count})` };\n }\n await db.consumeReferrals(userId, REFERRALS_REQUIRED);\n return { ok: true, expiresAt: Math.floor(Date.now() / 1000) + HOST_DURATION_SECONDS };\n}\n","createdAt",["D",1776955534253],"branchVersion","branchId","cd2d8f62-3f22-11f1-b2aa-42b51c65c3df","id","cd2ce288-3f22-11f1-b2aa-42b51c65c3df","scotthub-host",["D",1776955412887],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","ScottHub - Telegram Bot Hosting Platform","imageUrl","676437db-cba0-454f-b925-a9cf4a24f1b1","pinnedFileId","b11eda64-3f23-11f1-81c4-42b51c65c3df","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019dbac9-2381-7248-9dc7-2d22f6f0f7af","tursoName","cd2ce2883f2211f1b2aa42b51c65c3df","tursoHostname","cd2ce2883f2211f1b2aa42b51c65c3df-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789506649022],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_105":104,"_112":108},"org",{"_105":104,"_106":-5,"_107":108,"_19":60,"_109":110,"_111":30},"branch",{"_13":94,"_37":95,"_48":47,"_96":49,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":50,"_103":104},"isOwned",18,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","diligronronbalor","handle","displayName","avatar","","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_48":49,"_37":50,"_43":243,"_52":-5,"_53":30,"_54":55,"_56":55,"_57":58,"_59":-5,"_19":60,"_61":62,"_63":64,"_65":-5,"_66":-5,"_67":68,"_69":70,"_71":72,"_73":74,"_75":244,"_77":-5,"_78":79,"_80":79,"_81":82,"_83":82,"_84":82,"_85":79,"_86":79,"_87":245,"_89":246,"_91":247,"_93":30},"tree",[176,179,181,182],"files",[176,177,178,179,180,181,182,183,184,185],"counts",{"_166":68,"_167":163,"_168":68,"_169":170,"_171":172},"contents",[134,135,136,137],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_48":160,"_37":161,"_35":162,"_141":-5,"_46":47,"_45":163,"_143":64,"_43":164,"_13":68,"_39":145,"_41":-5,"_29":30,"_146":-5,"_32":165},{"_48":154,"_37":155,"_35":156,"_141":-5,"_46":47,"_45":157,"_143":64,"_43":158,"_13":68,"_39":145,"_41":-5,"_29":30,"_146":-5,"_32":159},{"_48":148,"_37":149,"_35":150,"_141":-5,"_46":47,"_45":151,"_143":64,"_43":152,"_13":68,"_39":145,"_41":-5,"_29":30,"_146":-5,"_32":153},{"_48":138,"_37":139,"_35":140,"_141":-5,"_46":47,"_45":142,"_143":64,"_43":144,"_13":68,"_39":145,"_41":-5,"_29":30,"_146":-5,"_32":147},"d03236ae-3f22-11f1-9590-42b51c65c3df","lib","d0323780-3f22-11f1-9590-42b51c65c3df","parentId",2,"latest",["D",1776955417822],"directory","label",[139],"d0873884-3f22-11f1-afe3-42b51c65c3df","jobs","d0873942-3f22-11f1-afe3-42b51c65c3df",4,["D",1776955418495],[149],"d06951b6-3f22-11f1-afe3-42b51c65c3df","handlers","d0695288-3f22-11f1-afe3-42b51c65c3df",3,["D",1776955418310],[155],"cfd05ec0-3f22-11f1-9590-42b51c65c3df","database","cfd05f88-3f22-11f1-9590-42b51c65c3df",1,["D",1776955417306],[161],"pulls","branches","forks","envVars",{"_173":68,"_175":68},"connections",{"_173":68,"_174":68},"count","unfilledCount","emptyCount",{"_48":160,"_37":161,"_35":162,"_141":-5,"_46":47,"_45":163,"_143":64,"_43":240,"_13":68,"_39":145,"_41":-5,"_29":30,"_146":-5,"_192":241,"_32":242},{"_48":232,"_37":233,"_35":234,"_141":162,"_46":47,"_45":235,"_143":64,"_43":236,"_13":68,"_39":40,"_41":237,"_29":30,"_146":-5,"_192":238,"_32":239},{"_48":224,"_37":225,"_35":226,"_141":162,"_46":47,"_45":227,"_143":64,"_43":228,"_13":68,"_39":40,"_41":229,"_29":30,"_146":-5,"_192":230,"_32":231},{"_48":154,"_37":155,"_35":156,"_141":-5,"_46":47,"_45":157,"_143":64,"_43":221,"_13":68,"_39":145,"_41":-5,"_29":30,"_146":-5,"_192":222,"_32":223},{"_48":217,"_37":38,"_35":36,"_141":156,"_46":47,"_45":14,"_143":64,"_43":218,"_13":68,"_39":40,"_41":42,"_29":30,"_146":-5,"_192":219,"_32":220},{"_48":148,"_37":149,"_35":150,"_141":-5,"_46":47,"_45":151,"_143":64,"_43":214,"_13":68,"_39":145,"_41":-5,"_29":30,"_146":-5,"_192":215,"_32":216},{"_48":138,"_37":139,"_35":140,"_141":-5,"_46":47,"_45":142,"_143":64,"_43":211,"_13":68,"_39":145,"_41":-5,"_29":30,"_146":-5,"_192":212,"_32":213},{"_48":203,"_37":204,"_35":205,"_141":140,"_46":47,"_45":206,"_143":64,"_43":207,"_13":68,"_39":40,"_41":208,"_29":30,"_146":-5,"_192":209,"_32":210},{"_48":195,"_37":196,"_35":197,"_141":140,"_46":47,"_45":198,"_143":64,"_43":199,"_13":68,"_39":40,"_41":200,"_29":30,"_146":-5,"_192":201,"_32":202},{"_48":186,"_37":187,"_35":188,"_141":140,"_46":47,"_45":189,"_143":64,"_43":190,"_13":68,"_39":40,"_41":191,"_29":30,"_146":-5,"_192":193,"_32":194},"0ae9c00a-3f23-11f1-b0bb-42b51c65c3df","utils.ts","0ae9c0be-3f23-11f1-b0bb-42b51c65c3df",9,["D",1776955516460],"// Misc utilities\nimport { httpEndpoint, parseVal } from \"https://esm.town/v/std/utils/index.ts\";\n\nexport function esc(s: string | number | null | undefined): string {\n if (s === null || s === undefined) return \"\";\n return String(s)\n .replaceAll(\"&\", \"&\")\n .replaceAll(\"<\", \"<\")\n .replaceAll(\">\", \">\");\n}\n\nexport function fmtDuration(seconds: number): string {\n if (seconds <= 0) return \"expired\";\n const d = Math.floor(seconds / 86400);\n const h = Math.floor((seconds % 86400) / 3600);\n const m = Math.floor((seconds % 3600) / 60);\n if (d > 0) return `${d}d ${h}h ${m}m`;\n if (h > 0) return `${h}h ${m}m`;\n return `${m}m`;\n}\n\nexport function fmtDate(ts: number | null): string {\n if (!ts) return \"—\";\n return new Date(ts * 1000).toISOString().replace(\"T\", \" \").slice(0, 16) + \" UTC\";\n}\n\n// 2-day host window in seconds\nexport const HOST_DURATION_SECONDS = 2 * 24 * 60 * 60;\nexport const REFERRALS_REQUIRED = 2;\n\nexport async function hashToken(token: string): Promise {\n const buf = new TextEncoder().encode(token);\n const digest = await crypto.subtle.digest(\"SHA-256\", buf);\n return Array.from(new Uint8Array(digest))\n .map((b) => b.toString(16).padStart(2, \"0\"))\n .join(\"\")\n .slice(0, 16);\n}\n\n// Cache the resolved base URL\nlet _cachedBaseUrl: string | null = null;\n\nexport async function getBaseUrl(): Promise {\n if (_cachedBaseUrl) return _cachedBaseUrl;\n try {\n const endpoint = await httpEndpoint(\"/main.ts\");\n _cachedBaseUrl = endpoint;\n return endpoint;\n } catch {\n // fallback\n const v = parseVal();\n return `https://${v.username}--${v.name}.web.val.run`;\n }\n}\n\nexport function projectWebhookUrl(baseUrl: string, projectId: number, secret: string): string {\n return `${baseUrl}/tgwebhook/${projectId}/${secret}`;\n}\n","children",[],[139,187],"f925b77a-3f22-11f1-9476-42b51c65c3df","telegram.ts","f925b824-3f22-11f1-9476-42b51c65c3df",7,["D",1776955486622],"// Telegram Bot API wrapper\nconst BASE = \"https://api.telegram.org\";\n\nexport async function tg(token: string, method: string, body: Record = {}) {\n const res = await fetch(`${BASE}/bot${token}/${method}`, {\n method: \"POST\",\n headers: { \"content-type\": \"application/json\" },\n body: JSON.stringify(body),\n });\n const data = await res.json().catch(() => ({ ok: false, description: \"non-json response\" }));\n return data;\n}\n\nexport async function sendMessage(\n token: string,\n chatId: number | string,\n text: string,\n extra: Record = {},\n) {\n return tg(token, \"sendMessage\", {\n chat_id: chatId,\n text,\n parse_mode: \"HTML\",\n disable_web_page_preview: true,\n ...extra,\n });\n}\n\nexport async function editMessage(\n token: string,\n chatId: number | string,\n messageId: number,\n text: string,\n extra: Record = {},\n) {\n return tg(token, \"editMessageText\", {\n chat_id: chatId,\n message_id: messageId,\n text,\n parse_mode: \"HTML\",\n disable_web_page_preview: true,\n ...extra,\n });\n}\n\nexport async function answerCallback(token: string, callbackQueryId: string, text = \"\") {\n return tg(token, \"answerCallbackQuery\", { callback_query_id: callbackQueryId, text });\n}\n\nexport async function getFile(token: string, fileId: string): Promise<{ file_path?: string } | null> {\n const r = await tg(token, \"getFile\", { file_id: fileId });\n if (!r.ok) return null;\n return r.result;\n}\n\nexport async function downloadFile(token: string, filePath: string): Promise {\n const res = await fetch(`${BASE}/file/bot${token}/${filePath}`);\n if (!res.ok) throw new Error(\"Failed to download file: \" + res.status);\n return res.text();\n}\n\nexport async function downloadFileBytes(token: string, filePath: string): Promise {\n const res = await fetch(`${BASE}/file/bot${token}/${filePath}`);\n if (!res.ok) throw new Error(\"Failed to download file: \" + res.status);\n return new Uint8Array(await res.arrayBuffer());\n}\n\nexport async function checkChannelMember(\n token: string,\n channel: string,\n userId: number,\n): Promise<{ ok: boolean; isMember: boolean; error?: string }> {\n const r = await tg(token, \"getChatMember\", { chat_id: channel, user_id: userId });\n if (!r.ok) return { ok: false, isMember: false, error: r.description };\n const status = r.result?.status;\n const isMember = [\"creator\", \"administrator\", \"member\", \"restricted\"].includes(status);\n return { ok: true, isMember };\n}\n\nexport async function getMe(token: string) {\n return tg(token, \"getMe\");\n}\n\nexport async function setWebhook(token: string, url: string, secret?: string) {\n return tg(token, \"setWebhook\", {\n url,\n secret_token: secret,\n allowed_updates: [\"message\", \"edited_message\", \"callback_query\", \"chat_member\", \"my_chat_member\"],\n drop_pending_updates: false,\n });\n}\n\nexport async function deleteWebhook(token: string) {\n return tg(token, \"deleteWebhook\", { drop_pending_updates: false });\n}\n\nexport async function getWebhookInfo(token: string) {\n return tg(token, \"getWebhookInfo\");\n}\n\n// Main reply-keyboard (NOT inline) for usability\nexport const MAIN_KEYBOARD = {\n keyboard: [\n [{ text: \"🖥 Host\" }, { text: \"👥 Referral\" }],\n [{ text: \"📊 Status\" }, { text: \"ℹ️ Help\" }],\n ],\n resize_keyboard: true,\n is_persistent: true,\n};\n\nexport const HOST_KEYBOARD = {\n keyboard: [\n [{ text: \"🗄 Server\" }, { text: \"⬆️ Upload Files\" }],\n [{ text: \"📁 Manage Files\" }, { text: \"⏱ Host Time\" }],\n [{ text: \"⏹ Stop\" }, { text: \"🔄 Restart\" }],\n [{ text: \"⬅️ Back\" }],\n ],\n resize_keyboard: true,\n is_persistent: true,\n};\n\nexport const MANAGE_KEYBOARD = {\n keyboard: [\n [{ text: \"📄 List Files\" }, { text: \"⭐ Set Main File\" }],\n [{ text: \"➕ Add File\" }, { text: \"🗑 Delete File\" }],\n [{ text: \"⬅️ Back to Host\" }],\n ],\n resize_keyboard: true,\n is_persistent: true,\n};\n\nexport const BACK_KEYBOARD = {\n keyboard: [[{ text: \"⬅️ Back\" }]],\n resize_keyboard: true,\n is_persistent: true,\n};\n\nexport const REMOVE_KEYBOARD = { remove_keyboard: true };\n",[],[139,196],"04f89cf2-3f23-11f1-9a13-42b51c65c3df","parser.ts","04f89d92-3f23-11f1-9a13-42b51c65c3df",8,["D",1776955506490],"// Smart Python parser - detects bot token, admin id, imports, etc.\n\nconst STDLIB = new Set([\n \"os\", \"sys\", \"re\", \"json\", \"time\", \"datetime\", \"random\", \"math\", \"asyncio\",\n \"logging\", \"threading\", \"subprocess\", \"pathlib\", \"typing\", \"collections\",\n \"functools\", \"itertools\", \"traceback\", \"urllib\", \"http\", \"socket\", \"ssl\",\n \"hashlib\", \"hmac\", \"base64\", \"io\", \"struct\", \"copy\", \"pickle\", \"csv\",\n \"sqlite3\", \"zipfile\", \"tarfile\", \"gzip\", \"bz2\", \"string\", \"textwrap\",\n \"argparse\", \"configparser\", \"shutil\", \"tempfile\", \"glob\", \"uuid\", \"secrets\",\n \"dataclasses\", \"enum\", \"abc\", \"contextlib\", \"warnings\", \"weakref\", \"inspect\",\n \"importlib\", \"operator\", \"queue\", \"multiprocessing\", \"concurrent\", \"signal\",\n \"platform\", \"getpass\", \"calendar\", \"decimal\", \"fractions\", \"statistics\",\n \"unittest\", \"email\", \"html\", \"xml\", \"zoneinfo\", \"locale\", \"gettext\", \"codecs\",\n \"mimetypes\", \"encodings\", \"builtins\", \"__future__\",\n]);\n\nconst IMPORT_TO_PIP: Record = {\n \"telegram\": \"python-telegram-bot\",\n \"telethon\": \"Telethon\",\n \"pyrogram\": \"Pyrogram\",\n \"aiogram\": \"aiogram\",\n \"cv2\": \"opencv-python\",\n \"PIL\": \"Pillow\",\n \"Image\": \"Pillow\",\n \"bs4\": \"beautifulsoup4\",\n \"yaml\": \"PyYAML\",\n \"dotenv\": \"python-dotenv\",\n \"jwt\": \"PyJWT\",\n \"MySQLdb\": \"mysqlclient\",\n \"dns\": \"dnspython\",\n \"sklearn\": \"scikit-learn\",\n \"discord\": \"discord.py\",\n \"requests\": \"requests\",\n \"aiohttp\": \"aiohttp\",\n \"httpx\": \"httpx\",\n \"flask\": \"Flask\",\n \"fastapi\": \"fastapi\",\n \"uvicorn\": \"uvicorn\",\n \"django\": \"Django\",\n \"motor\": \"motor\",\n \"pymongo\": \"pymongo\",\n \"redis\": \"redis\",\n \"psycopg2\": \"psycopg2-binary\",\n \"sqlalchemy\": \"SQLAlchemy\",\n \"numpy\": \"numpy\",\n \"pandas\": \"pandas\",\n \"apscheduler\": \"APScheduler\",\n \"pydantic\": \"pydantic\",\n \"tgcrypto\": \"TgCrypto\",\n};\n\nexport function detectImports(code: string): { imports: string[]; pip: string[] } {\n const found = new Set();\n const cleaned = code\n .replace(/\"\"\"[\\s\\S]*?\"\"\"/g, \"\")\n .replace(/'''[\\s\\S]*?'''/g, \"\")\n .replace(/#[^\\n]*/g, \"\");\n\n const lines = cleaned.split(/\\r?\\n/);\n for (const raw of lines) {\n const line = raw.trim();\n let m = line.match(/^from\\s+([a-zA-Z_][\\w\\.]*)\\s+import\\s+/);\n if (m) {\n found.add(m[1].split(\".\")[0]);\n continue;\n }\n m = line.match(/^import\\s+(.+)$/);\n if (m) {\n for (const part of m[1].split(\",\")) {\n const name = part.trim().split(/\\s+as\\s+/)[0].trim().split(\".\")[0];\n if (name) found.add(name);\n }\n }\n }\n const imports = [...found].filter((x) => !STDLIB.has(x));\n const pip = [...new Set(imports.map((i) => IMPORT_TO_PIP[i] ?? i))];\n return { imports: [...found], pip };\n}\n\nexport function detectBotToken(code: string): string | null {\n const re = /(\\d{6,12}:[A-Za-z0-9_\\-]{30,})/;\n const m = code.match(re);\n return m ? m[1] : null;\n}\n\nexport function detectAdminId(code: string): string | null {\n const patterns = [\n /(?:ADMIN_ID|OWNER_ID|SUDO_USERS|OWNER|ADMINS?)\\s*=\\s*\\[?\\s*[\"']?(\\d{5,})[\"']?/i,\n /(?:admin|owner)[_\\s]?id\\s*=\\s*[\"']?(\\d{5,})[\"']?/i,\n ];\n for (const p of patterns) {\n const m = code.match(p);\n if (m) return m[1];\n }\n return null;\n}\n\nexport function detectApiIdHash(code: string): { apiId?: string; apiHash?: string } {\n const out: { apiId?: string; apiHash?: string } = {};\n const idM = code.match(/API[_\\s]?ID\\s*=\\s*[\"']?(\\d{5,})[\"']?/i);\n if (idM) out.apiId = idM[1];\n const hashM = code.match(/API[_\\s]?HASH\\s*=\\s*[\"']([a-f0-9]{32})[\"']/i);\n if (hashM) out.apiHash = hashM[1];\n return out;\n}\n\nexport function analyzePythonFile(code: string) {\n return {\n imports: detectImports(code),\n botToken: detectBotToken(code),\n adminId: detectAdminId(code),\n apiCreds: detectApiIdHash(code),\n lines: code.split(/\\r?\\n/).length,\n size: code.length,\n };\n}\n",[],[139,204],["D",1776955417822],[183,184,185],[139],["D",1776955418495],[],[149],"15877bec-3f23-11f1-96ce-42b51c65c3df",["D",1776955534253],[],[155,38],["D",1776955418310],[180],[155],"d8f094d4-3f22-11f1-9590-42b51c65c3df","schema.ts","d8f0957e-3f22-11f1-9590-42b51c65c3df",5,["D",1776955432607],"// Database schema + migrations for ScottHub\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport async function runMigrations() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS users (\n tg_id INTEGER PRIMARY KEY,\n username TEXT,\n first_name TEXT,\n referral_code TEXT UNIQUE,\n referred_by INTEGER,\n referral_count INTEGER DEFAULT 0,\n state TEXT DEFAULT 'idle',\n state_data TEXT,\n joined_channel INTEGER DEFAULT 0,\n created_at INTEGER DEFAULT (strftime('%s','now')),\n updated_at INTEGER DEFAULT (strftime('%s','now'))\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS projects (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n owner_id INTEGER NOT NULL,\n name TEXT NOT NULL,\n main_file TEXT,\n bot_token TEXT,\n bot_username TEXT,\n admin_id TEXT,\n detected_imports TEXT,\n status TEXT DEFAULT 'stopped',\n webhook_secret TEXT,\n webhook_url TEXT,\n created_at INTEGER DEFAULT (strftime('%s','now')),\n started_at INTEGER,\n expires_at INTEGER,\n stopped_at INTEGER,\n last_update_at INTEGER,\n message_count INTEGER DEFAULT 0\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS files (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n project_id INTEGER NOT NULL,\n path TEXT NOT NULL,\n content TEXT NOT NULL,\n size INTEGER DEFAULT 0,\n is_main INTEGER DEFAULT 0,\n uploaded_at INTEGER DEFAULT (strftime('%s','now')),\n UNIQUE(project_id, path)\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS referrals (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n referrer_id INTEGER NOT NULL,\n invited_id INTEGER NOT NULL UNIQUE,\n created_at INTEGER DEFAULT (strftime('%s','now'))\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS webhook_events (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n project_id INTEGER,\n bot_token_hash TEXT,\n direction TEXT,\n payload TEXT,\n status_code INTEGER,\n created_at INTEGER DEFAULT (strftime('%s','now'))\n )\n `);\n\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS panel_sessions (\n token TEXT PRIMARY KEY,\n username TEXT NOT NULL,\n created_at INTEGER DEFAULT (strftime('%s','now')),\n expires_at INTEGER NOT NULL\n )\n `);\n\n // Indexes\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_projects_owner ON projects(owner_id)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_files_project ON files(project_id)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_referrals_ref ON referrals(referrer_id)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_webhook_project ON webhook_events(project_id)`);\n await sqlite.execute(`CREATE INDEX IF NOT EXISTS idx_users_refcode ON users(referral_code)`);\n\n // Add webhook_url column if missing (migration)\n try {\n await sqlite.execute(`ALTER TABLE projects ADD COLUMN webhook_url TEXT`);\n } catch { /* already exists */ }\n}\n",[],[161,225],"ec081948-3f22-11f1-825c-42b51c65c3df","queries.ts","ec0819de-3f22-11f1-825c-42b51c65c3df",6,["D",1776955464643],"// All DB queries for ScottHub\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport type UserRow = {\n tg_id: number;\n username: string | null;\n first_name: string | null;\n referral_code: string;\n referred_by: number | null;\n referral_count: number;\n state: string;\n state_data: string | null;\n joined_channel: number;\n};\n\nexport type ProjectRow = {\n id: number;\n owner_id: number;\n name: string;\n main_file: string | null;\n bot_token: string | null;\n bot_username: string | null;\n admin_id: string | null;\n detected_imports: string | null;\n status: string;\n webhook_secret: string | null;\n webhook_url: string | null;\n created_at: number;\n started_at: number | null;\n expires_at: number | null;\n stopped_at: number | null;\n last_update_at: number | null;\n message_count: number;\n};\n\nexport type FileRow = {\n id: number;\n project_id: number;\n path: string;\n content: string;\n size: number;\n is_main: number;\n uploaded_at: number;\n};\n\nfunction genCode(prefix: string, len = 8): string {\n const chars = \"ABCDEFGHJKLMNPQRSTUVWXYZ23456789\";\n let s = \"\";\n for (let i = 0; i < len; i++) s += chars[Math.floor(Math.random() * chars.length)];\n return prefix + s;\n}\n\n// ---- USERS ----\nexport async function getOrCreateUser(\n tgId: number,\n username: string | null,\n firstName: string | null,\n referredBy: number | null = null,\n): Promise<{ user: UserRow; created: boolean }> {\n const existing = await sqlite.execute({\n sql: \"SELECT * FROM users WHERE tg_id = ?\",\n args: [tgId],\n });\n if (existing.rows.length > 0) {\n await sqlite.execute({\n sql: \"UPDATE users SET username=?, first_name=?, updated_at=strftime('%s','now') WHERE tg_id=?\",\n args: [username, firstName, tgId],\n });\n return { user: existing.rows[0] as unknown as UserRow, created: false };\n }\n let code = genCode(\"R\");\n for (let attempts = 0; attempts < 5; attempts++) {\n const check = await sqlite.execute({ sql: \"SELECT 1 FROM users WHERE referral_code=?\", args: [code] });\n if (check.rows.length === 0) break;\n code = genCode(\"R\");\n }\n await sqlite.execute({\n sql: \"INSERT INTO users (tg_id, username, first_name, referral_code, referred_by) VALUES (?, ?, ?, ?, ?)\",\n args: [tgId, username, firstName, code, referredBy],\n });\n const fresh = await sqlite.execute({ sql: \"SELECT * FROM users WHERE tg_id=?\", args: [tgId] });\n return { user: fresh.rows[0] as unknown as UserRow, created: true };\n}\n\nexport async function getUser(tgId: number): Promise {\n const r = await sqlite.execute({ sql: \"SELECT * FROM users WHERE tg_id=?\", args: [tgId] });\n return r.rows.length ? (r.rows[0] as unknown as UserRow) : null;\n}\n\nexport async function getUserByRefCode(code: string): Promise {\n const r = await sqlite.execute({ sql: \"SELECT * FROM users WHERE referral_code=?\", args: [code] });\n return r.rows.length ? (r.rows[0] as unknown as UserRow) : null;\n}\n\nexport async function setUserState(tgId: number, state: string, data: Record | null = null) {\n await sqlite.execute({\n sql: \"UPDATE users SET state=?, state_data=?, updated_at=strftime('%s','now') WHERE tg_id=?\",\n args: [state, data ? JSON.stringify(data) : null, tgId],\n });\n}\n\nexport async function markJoined(tgId: number, joined: boolean) {\n await sqlite.execute({\n sql: \"UPDATE users SET joined_channel=? WHERE tg_id=?\",\n args: [joined ? 1 : 0, tgId],\n });\n}\n\nexport async function addReferral(referrerId: number, invitedId: number): Promise {\n try {\n await sqlite.execute({\n sql: \"INSERT INTO referrals (referrer_id, invited_id) VALUES (?, ?)\",\n args: [referrerId, invitedId],\n });\n await sqlite.execute({\n sql: \"UPDATE users SET referral_count = referral_count + 1 WHERE tg_id=?\",\n args: [referrerId],\n });\n return true;\n } catch {\n return false;\n }\n}\n\n// ---- PROJECTS ----\nexport async function getProjectByOwner(ownerId: number): Promise {\n const r = await sqlite.execute({\n sql: \"SELECT * FROM projects WHERE owner_id=? ORDER BY id DESC LIMIT 1\",\n args: [ownerId],\n });\n return r.rows.length ? (r.rows[0] as unknown as ProjectRow) : null;\n}\n\nexport async function getProjectById(id: number): Promise {\n const r = await sqlite.execute({ sql: \"SELECT * FROM projects WHERE id=?\", args: [id] });\n return r.rows.length ? (r.rows[0] as unknown as ProjectRow) : null;\n}\n\nexport async function getProjectByToken(token: string): Promise {\n const r = await sqlite.execute({ sql: \"SELECT * FROM projects WHERE bot_token=?\", args: [token] });\n return r.rows.length ? (r.rows[0] as unknown as ProjectRow) : null;\n}\n\nexport async function createProject(ownerId: number, name: string): Promise {\n const secret = genCode(\"W\", 16);\n const r = await sqlite.execute({\n sql: \"INSERT INTO projects (owner_id, name, webhook_secret) VALUES (?, ?, ?) RETURNING *\",\n args: [ownerId, name, secret],\n });\n return r.rows[0] as unknown as ProjectRow;\n}\n\nexport async function updateProject(id: number, patch: Partial) {\n const keys = Object.keys(patch);\n if (keys.length === 0) return;\n const sets = keys.map((k) => `${k}=?`).join(\", \");\n const args = keys.map((k) => (patch as any)[k]);\n args.push(id);\n await sqlite.execute({ sql: `UPDATE projects SET ${sets} WHERE id=?`, args });\n}\n\nexport async function listAllProjects(): Promise {\n const r = await sqlite.execute(\"SELECT * FROM projects ORDER BY id DESC\");\n return r.rows as unknown as ProjectRow[];\n}\n\nexport async function listRunningProjects(): Promise {\n const now = Math.floor(Date.now() / 1000);\n const r = await sqlite.execute({\n sql: \"SELECT * FROM projects WHERE status='running' AND (expires_at IS NULL OR expires_at > ?)\",\n args: [now],\n });\n return r.rows as unknown as ProjectRow[];\n}\n\n// ---- FILES ----\nexport async function addFile(\n projectId: number,\n path: string,\n content: string,\n isMain = false,\n): Promise {\n await sqlite.execute({\n sql: `INSERT INTO files (project_id, path, content, size, is_main) VALUES (?, ?, ?, ?, ?)\n ON CONFLICT(project_id, path) DO UPDATE SET content=excluded.content, size=excluded.size, uploaded_at=strftime('%s','now')`,\n args: [projectId, path, content, content.length, isMain ? 1 : 0],\n });\n const r = await sqlite.execute({\n sql: \"SELECT * FROM files WHERE project_id=? AND path=?\",\n args: [projectId, path],\n });\n return r.rows[0] as unknown as FileRow;\n}\n\nexport async function listFiles(projectId: number): Promise {\n const r = await sqlite.execute({\n sql: \"SELECT * FROM files WHERE project_id=? ORDER BY is_main DESC, path ASC\",\n args: [projectId],\n });\n return r.rows as unknown as FileRow[];\n}\n\nexport async function getFile(projectId: number, path: string): Promise {\n const r = await sqlite.execute({\n sql: \"SELECT * FROM files WHERE project_id=? AND path=?\",\n args: [projectId, path],\n });\n return r.rows.length ? (r.rows[0] as unknown as FileRow) : null;\n}\n\nexport async function deleteFile(projectId: number, path: string) {\n await sqlite.execute({\n sql: \"DELETE FROM files WHERE project_id=? AND path=?\",\n args: [projectId, path],\n });\n}\n\nexport async function setMainFile(projectId: number, path: string) {\n await sqlite.execute({\n sql: \"UPDATE files SET is_main=0 WHERE project_id=?\",\n args: [projectId],\n });\n await sqlite.execute({\n sql: \"UPDATE files SET is_main=1 WHERE project_id=? AND path=?\",\n args: [projectId, path],\n });\n await sqlite.execute({\n sql: \"UPDATE projects SET main_file=? WHERE id=?\",\n args: [path, projectId],\n });\n}\n\n// ---- WEBHOOK LOG ----\nexport async function logWebhook(projectId: number | null, hash: string, direction: string, payload: string, status: number) {\n await sqlite.execute({\n sql: \"INSERT INTO webhook_events (project_id, bot_token_hash, direction, payload, status_code) VALUES (?, ?, ?, ?, ?)\",\n args: [projectId, hash, direction, payload.slice(0, 4000), status],\n });\n if (projectId) {\n await sqlite.execute({\n sql: \"UPDATE projects SET message_count = message_count + 1, last_update_at = strftime('%s','now') WHERE id=?\",\n args: [projectId],\n });\n }\n}\n\nexport async function recentWebhookEvents(limit = 50) {\n const r = await sqlite.execute({\n sql: \"SELECT * FROM webhook_events ORDER BY id DESC LIMIT ?\",\n args: [limit],\n });\n return r.rows;\n}\n\n// ---- STATS ----\nexport async function globalStats() {\n const u = await sqlite.execute(\"SELECT COUNT(*) as c FROM users\");\n const p = await sqlite.execute(\"SELECT COUNT(*) as c FROM projects\");\n const r = await sqlite.execute(\"SELECT COUNT(*) as c FROM projects WHERE status='running'\");\n const f = await sqlite.execute(\"SELECT COUNT(*) as c FROM files\");\n const m = await sqlite.execute(\"SELECT COUNT(*) as c FROM webhook_events\");\n const num = (x: any) => Number(x.rows[0]?.c ?? 0);\n return { users: num(u), projects: num(p), running: num(r), files: num(f), messages: num(m) };\n}\n\n// ---- PANEL SESSIONS ----\nexport async function createSession(username: string): Promise {\n const token = genCode(\"S\", 32) + Date.now().toString(36);\n const expires = Math.floor(Date.now() / 1000) + 60 * 60 * 24 * 7;\n await sqlite.execute({\n sql: \"INSERT INTO panel_sessions (token, username, expires_at) VALUES (?, ?, ?)\",\n args: [token, username, expires],\n });\n return token;\n}\n\nexport async function validateSession(token: string): Promise {\n const now = Math.floor(Date.now() / 1000);\n const r = await sqlite.execute({\n sql: \"SELECT 1 FROM panel_sessions WHERE token=? AND expires_at > ?\",\n args: [token, now],\n });\n return r.rows.length > 0;\n}\n\nexport async function deleteSession(token: string) {\n await sqlite.execute({ sql: \"DELETE FROM panel_sessions WHERE token=?\", args: [token] });\n}\n\nexport async function consumeReferrals(userId: number, amount: number) {\n await sqlite.execute({\n sql: \"UPDATE users SET referral_count = referral_count - ? WHERE tg_id=?\",\n args: [amount, userId],\n });\n}\n",[],[161,233],["D",1776955417306],[177,178],[161],["D",1776955412887],["D",1789506649022],{"_105":104,"_112":108},{"_105":104,"_106":-5,"_107":108,"_19":60,"_109":110,"_111":30},{"_13":94,"_37":95,"_48":47,"_96":49,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":-5,"_102":50,"_103":104},"ctx",{"_87":-5,"_131":281,"_282":283,"_284":285,"_286":30,"_287":30,"_288":30,"_289":64,"_290":-5,"_291":-7,"_292":-7,"_293":68,"_294":30,"_295":30,"_296":-5,"_297":30,"_298":30,"_299":30,"_300":-5},"ENV",{"_252":253,"_254":255,"_256":95,"_257":258,"_259":260,"_261":262,"_263":264,"_265":266,"_267":268,"_269":270,"_271":272,"_273":274,"_275":276,"_277":278,"_279":280},"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 · v10