[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_258":259,"_260":261},"routes/_app.x.$handle.$name",{"_109":108,"_38":56,"_117":99,"_33":112,"_13":14,"_118":-5,"_11":119,"_120":121,"_122":123,"_124":125,"_126":127,"_27":-5,"_128":-5,"_129":-5,"_130":31,"_131":132,"_133":134,"_135":-5,"_136":-5,"_137":138},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_54":55,"_38":56,"_42":57,"_58":-5,"_59":31,"_60":61,"_62":61,"_63":64,"_65":-5,"_19":66,"_67":-5,"_68":31,"_69":-5,"_70":-5,"_71":72,"_73":74,"_75":76,"_77":78,"_79":80,"_81":-5,"_82":83,"_84":83,"_85":86,"_87":86,"_88":86,"_89":83,"_90":83,"_91":92,"_93":94,"_95":96,"_97":31},"version",8,"changes",[25,26],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","a420d503-0830-4003-a179-fea354ccde46","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_27":47,"_29":-7,"_30":31,"_32":31,"_33":48,"_35":48},{"_27":28,"_29":-7,"_30":31,"_32":31,"_33":34,"_35":34},"file",{"_36":37,"_38":34,"_39":40,"_41":-5,"_42":43,"_44":14,"_45":46,"_30":31},"previous","deleted",false,"deletedHere","path","handlers","latestPath","fileId","fe278bd7-3119-4141-b248-21626269f21c","name","fileType","directory","content","createdAt",["D",1776956452693],"branchVersion","branchId","f2aa5b74-3f24-11f1-bf01-42b51c65c3df",{"_36":49,"_38":50,"_39":51,"_41":52,"_42":53,"_44":14,"_45":46,"_30":31},"handlers/access.ts","38f4abca-3f25-11f1-8f86-42b51c65c3df","access.ts","script","// Channel-join + referral gate\nimport * as db from \"../database/queries.ts\";\nimport * as tg from \"../lib/telegram.ts\";\nimport { BOT_TOKEN, CHANNEL, ADMIN_ID, REFERRALS_REQUIRED, HOST_DURATION_SECONDS, MAX_PROJECTS_PER_USER } from \"../lib/config.ts\";\n\nexport function isAdmin(tgId: number): boolean { return tgId === ADMIN_ID; }\n\nexport async function ensureChannelJoined(chatId: number, userId: number): Promise {\n if (isAdmin(userId)) { await db.markJoined(userId, true); return true; }\n const r = await tg.checkChannelMember(BOT_TOKEN, CHANNEL, userId);\n if (r.ok && r.isMember) { await db.markJoined(userId, true); return true; }\n await db.markJoined(userId, false);\n await tg.sendMessage(\n BOT_TOKEN, chatId,\n `🔒 Join Required\\n\\nTo use ScottHub please join our channel:\\n👉 https://t.me/ScottHubs\\n\\nThen press /start again.`,\n { reply_markup: tg.REMOVE_KEYBOARD },\n );\n return false;\n}\n\nexport type HostCheck =\n | { allowed: true; reason: \"admin\" | \"referrals\" | \"renew\" }\n | { allowed: false; need: number; have: number; reason: string };\n\nexport async function canCreateNewProject(userId: number): Promise {\n if (isAdmin(userId)) return { allowed: true, reason: \"admin\" };\n const count = await db.countProjects(userId);\n if (count >= MAX_PROJECTS_PER_USER) {\n return { allowed: false, need: 0, have: count, reason: `Max ${MAX_PROJECTS_PER_USER} bot slots reached. Stop/delete one first.` };\n }\n const user = await db.getUser(userId);\n if (!user) return { allowed: false, need: REFERRALS_REQUIRED, have: 0, reason: \"User not registered\" };\n if (user.referral_count >= REFERRALS_REQUIRED) return { allowed: true, reason: \"referrals\" };\n return { allowed: false, need: REFERRALS_REQUIRED, have: user.referral_count, reason: \"Not enough referrals\" };\n}\n\n/** Claim (consume) referrals for a NEW host slot. Admin is free. */\nexport async function claimHostSlot(userId: number): Promise<{ ok: true; expiresAt: number } | { ok: false; reason: string }> {\n const expiresAt = Math.floor(Date.now() / 1000) + HOST_DURATION_SECONDS;\n if (isAdmin(userId)) return { ok: true, expiresAt };\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 };\n}\n",["D",1776956452693],"id","f2a9c592-3f24-11f1-bf01-42b51c65c3df","scotthub",["D",1776956334773],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","ScottHub - Telegram Bot Hosting Platform with webhooks","imageUrl","3060ef0e-1f2c-4c3f-b663-3c9f482009b6","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019dbad4-a3c2-70f4-af59-375ca41cca1b","tursoName","f2a9c5923f2411f1bf0142b51c65c3df","tursoHostname","f2a9c5923f2411f1bf0142b51c65c3df-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789508444194],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_109":108,"_116":112},"org",{"_109":108,"_110":-5,"_111":112,"_19":66,"_113":114,"_115":31},"branch",{"_13":98,"_38":99,"_54":46,"_100":55,"_101":-5,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":56,"_107":108},"isOwned",19,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","reymonddilig13","handle","displayName","avatar","","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_54":55,"_38":56,"_42":253,"_58":-5,"_59":31,"_60":61,"_62":61,"_63":64,"_65":-5,"_19":66,"_67":-5,"_68":31,"_69":-5,"_70":-5,"_71":72,"_73":74,"_75":76,"_77":78,"_79":254,"_81":-5,"_82":83,"_84":83,"_85":86,"_87":86,"_88":86,"_89":83,"_90":83,"_91":255,"_93":256,"_95":257,"_97":31},"tree",[179,182,184,189],"files",[179,180,181,182,183,184,185,186,187,188,189],"counts",{"_169":72,"_170":147,"_171":72,"_172":173,"_174":175},"contents",[139,140,141,142],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_54":163,"_38":164,"_36":165,"_146":-5,"_45":46,"_44":166,"_148":134,"_42":167,"_13":72,"_39":40,"_41":-5,"_30":31,"_152":-5,"_33":168},{"_54":160,"_38":34,"_36":37,"_146":-5,"_45":46,"_44":14,"_148":134,"_42":161,"_13":72,"_39":40,"_41":-5,"_30":31,"_152":-5,"_33":162},{"_54":154,"_38":155,"_36":156,"_146":-5,"_45":46,"_44":157,"_148":134,"_42":158,"_13":72,"_39":40,"_41":-5,"_30":31,"_152":-5,"_33":159},{"_54":143,"_38":144,"_36":145,"_146":-5,"_45":46,"_44":147,"_148":31,"_42":149,"_13":72,"_39":150,"_41":151,"_30":31,"_152":-5,"_33":153},"f2afc41a-3f24-11f1-bf01-42b51c65c3df","main.ts","f2afc4ce-3f24-11f1-bf01-42b51c65c3df","parentId",1,"latest",["D",1776956334802],"http","// ScottHub bootstrap - real handler in handlers/\nimport app from \"./handlers/app.ts\";\nexport default app.fetch;\n","label",[144],"f7529f4c-3f24-11f1-bf01-42b51c65c3df","lib","a091f1d7-eade-4864-9db3-0c01aa453aef",2,["D",1776956342577],[155],"38f4c89e-3f25-11f1-8f86-42b51c65c3df",["D",1776956452693],[34],"19d6e280-3f25-11f1-8c3e-42b51c65c3df","database","39b957e7-b36b-4e60-938e-3cb9062a4f18",6,["D",1776956400462],[164],"pulls","branches","forks","envVars",{"_176":72,"_178":72},"connections",{"_176":72,"_177":72},"count","unfilledCount","emptyCount",{"_54":163,"_38":164,"_36":165,"_146":-5,"_45":46,"_44":166,"_148":134,"_42":250,"_13":72,"_39":40,"_41":-5,"_30":31,"_152":-5,"_191":251,"_33":252},{"_54":242,"_38":243,"_36":244,"_146":165,"_45":46,"_44":245,"_148":134,"_42":246,"_13":72,"_39":51,"_41":247,"_30":31,"_152":-5,"_191":248,"_33":249},{"_54":235,"_38":236,"_36":237,"_146":165,"_45":46,"_44":166,"_148":134,"_42":238,"_13":72,"_39":51,"_41":239,"_30":31,"_152":-5,"_191":240,"_33":241},{"_54":160,"_38":34,"_36":37,"_146":-5,"_45":46,"_44":14,"_148":134,"_42":232,"_13":72,"_39":40,"_41":-5,"_30":31,"_152":-5,"_191":233,"_33":234},{"_54":228,"_38":50,"_36":49,"_146":37,"_45":46,"_44":14,"_148":134,"_42":229,"_13":72,"_39":51,"_41":52,"_30":31,"_152":-5,"_191":230,"_33":231},{"_54":154,"_38":155,"_36":156,"_146":-5,"_45":46,"_44":157,"_148":134,"_42":225,"_13":72,"_39":40,"_41":-5,"_30":31,"_152":-5,"_191":226,"_33":227},{"_54":218,"_38":219,"_36":220,"_146":156,"_45":46,"_44":157,"_148":134,"_42":221,"_13":72,"_39":51,"_41":222,"_30":31,"_152":-5,"_191":223,"_33":224},{"_54":210,"_38":211,"_36":212,"_146":156,"_45":46,"_44":213,"_148":134,"_42":214,"_13":72,"_39":51,"_41":215,"_30":31,"_152":-5,"_191":216,"_33":217},{"_54":202,"_38":203,"_36":204,"_146":156,"_45":46,"_44":205,"_148":134,"_42":206,"_13":72,"_39":51,"_41":207,"_30":31,"_152":-5,"_191":208,"_33":209},{"_54":194,"_38":195,"_36":196,"_146":156,"_45":46,"_44":197,"_148":134,"_42":198,"_13":72,"_39":51,"_41":199,"_30":31,"_152":-5,"_191":200,"_33":201},{"_54":143,"_38":144,"_36":145,"_146":-5,"_45":46,"_44":147,"_148":31,"_42":190,"_13":72,"_39":150,"_41":151,"_30":31,"_152":-5,"_191":192,"_33":193},["D",1776956334802],"children",[],[144],"06b0524a-3f25-11f1-8c3e-42b51c65c3df","utils.ts","06b05308-3f25-11f1-8c3e-42b51c65c3df",4,["D",1776956368356],"// 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).replaceAll(\"&\", \"&\").replaceAll(\"<\", \"<\").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 | undefined): string {\n if (!ts) return \"—\";\n return new Date(ts * 1000).toISOString().replace(\"T\", \" \").slice(0, 16) + \" UTC\";\n}\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)).map((b) => b.toString(16).padStart(2, \"0\")).join(\"\").slice(0, 16);\n}\n\nlet _cachedBaseUrl: string | null = null;\nexport async function getBaseUrl(): Promise {\n if (_cachedBaseUrl) return _cachedBaseUrl;\n try {\n _cachedBaseUrl = await httpEndpoint(\"/main.ts\");\n return _cachedBaseUrl!;\n } catch {\n const v = parseVal();\n return `https://${v.author}--${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\nexport function safePath(p: string): string {\n return p.trim().replace(/^\\/+/, \"\").replace(/\\.\\./g, \"\").replace(/[^\\w.\\-\\/]/g, \"_\");\n}\n",[],[155,195],"01672a16-3f25-11f1-8f86-42b51c65c3df","telegram.ts","01672b1a-3f25-11f1-8f86-42b51c65c3df",3,["D",1776956359495],"// Telegram Bot API wrapper + keyboards\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 return res.json().catch(() => ({ ok: false, description: \"non-json response\" }));\n}\n\nexport async function sendMessage(token: string, chatId: number | string, text: string, extra: Record = {}) {\n return tg(token, \"sendMessage\", {\n chat_id: chatId, text, parse_mode: \"HTML\", disable_web_page_preview: true, ...extra,\n });\n}\n\nexport async function sendDocument(token: string, chatId: number | string, fileBytes: Uint8Array, filename: string, caption = \"\") {\n const form = new FormData();\n form.append(\"chat_id\", String(chatId));\n form.append(\"document\", new Blob([fileBytes]), filename);\n if (caption) { form.append(\"caption\", caption); form.append(\"parse_mode\", \"HTML\"); }\n const res = await fetch(`${BASE}/bot${token}/sendDocument`, { method: \"POST\", body: form });\n return res.json().catch(() => ({ ok: false }));\n}\n\nexport async function answerCallback(token: string, id: string, text = \"\") {\n return tg(token, \"answerCallbackQuery\", { callback_query_id: id, 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 return r.ok ? r.result : null;\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(\"download failed: \" + 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(\"download failed: \" + res.status);\n return new Uint8Array(await res.arrayBuffer());\n}\n\nexport async function checkChannelMember(token: string, channel: string, userId: number) {\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 return { ok: true, isMember: [\"creator\", \"administrator\", \"member\", \"restricted\"].includes(status) };\n}\n\nexport async function getMe(token: string) { return tg(token, \"getMe\"); }\nexport async function setWebhook(token: string, url: string, secret?: string) {\n return tg(token, \"setWebhook\", {\n url, secret_token: secret,\n allowed_updates: [\"message\", \"edited_message\", \"callback_query\", \"chat_member\", \"my_chat_member\"],\n drop_pending_updates: false,\n });\n}\nexport async function deleteWebhook(token: string) { return tg(token, \"deleteWebhook\", { drop_pending_updates: false }); }\nexport async function getWebhookInfo(token: string) { return tg(token, \"getWebhookInfo\"); }\n\n// ==== Main Reply Keyboards (NOT inline) ====\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: \"📜 Logs\" }, { text: \"🗂 Switch Project\" }],\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",[],[155,203],"12ed740c-3f25-11f1-9142-42b51c65c3df","parser.ts","12ed74b6-3f25-11f1-9142-42b51c65c3df",5,["D",1776956388892],"// Smart Python parser - detects imports, bot token, admin id, api id/hash\nconst STDLIB = new Set([\n \"os\",\"sys\",\"re\",\"json\",\"time\",\"datetime\",\"random\",\"math\",\"asyncio\",\"logging\",\n \"threading\",\"subprocess\",\"pathlib\",\"typing\",\"collections\",\"functools\",\"itertools\",\n \"traceback\",\"urllib\",\"http\",\"socket\",\"ssl\",\"hashlib\",\"hmac\",\"base64\",\"io\",\"struct\",\n \"copy\",\"pickle\",\"csv\",\"sqlite3\",\"zipfile\",\"tarfile\",\"gzip\",\"bz2\",\"string\",\"textwrap\",\n \"argparse\",\"configparser\",\"shutil\",\"tempfile\",\"glob\",\"uuid\",\"secrets\",\"dataclasses\",\n \"enum\",\"abc\",\"contextlib\",\"warnings\",\"weakref\",\"inspect\",\"importlib\",\"operator\",\n \"queue\",\"multiprocessing\",\"concurrent\",\"signal\",\"platform\",\"getpass\",\"calendar\",\n \"decimal\",\"fractions\",\"statistics\",\"unittest\",\"email\",\"html\",\"xml\",\"zoneinfo\",\n \"locale\",\"gettext\",\"codecs\",\"mimetypes\",\"encodings\",\"builtins\",\"__future__\",\n]);\n\nconst IMPORT_TO_PIP: Record = {\n telegram: \"python-telegram-bot\", telethon: \"Telethon\", pyrogram: \"Pyrogram\",\n aiogram: \"aiogram\", cv2: \"opencv-python\", PIL: \"Pillow\", Image: \"Pillow\",\n bs4: \"beautifulsoup4\", yaml: \"PyYAML\", dotenv: \"python-dotenv\", jwt: \"PyJWT\",\n MySQLdb: \"mysqlclient\", dns: \"dnspython\", sklearn: \"scikit-learn\",\n discord: \"discord.py\", requests: \"requests\", aiohttp: \"aiohttp\", httpx: \"httpx\",\n flask: \"Flask\", fastapi: \"fastapi\", uvicorn: \"uvicorn\", django: \"Django\",\n motor: \"motor\", pymongo: \"pymongo\", redis: \"redis\", psycopg2: \"psycopg2-binary\",\n sqlalchemy: \"SQLAlchemy\", numpy: \"numpy\", pandas: \"pandas\",\n apscheduler: \"APScheduler\", pydantic: \"pydantic\", tgcrypto: \"TgCrypto\",\n telebot: \"pyTelegramBotAPI\", pytelegrambotapi: \"pyTelegramBotAPI\",\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 for (const raw of cleaned.split(/\\r?\\n/)) {\n const line = raw.trim();\n let m = line.match(/^from\\s+([a-zA-Z_][\\w\\.]*)\\s+import\\s+/);\n if (m) { found.add(m[1].split(\".\")[0]); continue; }\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.toLowerCase()] ?? IMPORT_TO_PIP[i] ?? i))];\n return { imports: [...found], pip };\n}\n\nexport function detectBotToken(code: string): string | null {\n const m = code.match(/(\\d{6,12}:[A-Za-z0-9_\\-]{30,})/);\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",[],[155,211],"f7528d5e-3f24-11f1-bf01-42b51c65c3df","config.ts","f7528e4e-3f24-11f1-bf01-42b51c65c3df",["D",1776956342577],"// Central configuration for ScottHub\nexport const BOT_TOKEN = \"8779579899:AAEN9iro-5zo8Hr5XDKJ18iLSnr3FPkvefo\";\nexport const CHANNEL = \"@ScottHubs\";\nexport const CHANNEL_URL = \"https://t.me/ScottHubs\";\nexport const ARCHIVE_CHANNEL = \"@ProjectScottCode\";\nexport const ADMIN_ID = 6511143869;\n\n// Telegram API credentials for hosted Telethon/Pyrogram bots\nexport const TG_API_ID = \"31802482\";\nexport const TG_API_HASH = \"184c16c584a0e350a252271029cf7eb7\";\n\n// Hosting rules\nexport const REFERRALS_REQUIRED = 2;\nexport const HOST_DURATION_SECONDS = 2 * 24 * 60 * 60; // 2 days\nexport const MAX_PROJECTS_PER_USER = 2; // 2 bot slots per user (free tier)\nexport const MAX_FILE_BYTES = 2_000_000;\n\n// Web panel login\nexport const PANEL_USER = \"Scott\";\nexport const PANEL_PASS = \"ReyBalor21\";\n",[],[155,219],["D",1776956342577],[185,186,187,188],[155],"38f4ab02-3f25-11f1-8f86-42b51c65c3df",["D",1776956452693],[],[34,50],["D",1776956452693],[183],[34],"19d6c426-3f25-11f1-8c3e-42b51c65c3df","schema.ts","19d6c4f8-3f25-11f1-8c3e-42b51c65c3df",["D",1776956400462],"// DB schema + migrations\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport async function runMigrations() {\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS users (\n tg_id INTEGER PRIMARY KEY, username TEXT, first_name TEXT,\n referral_code TEXT UNIQUE, referred_by INTEGER,\n referral_count INTEGER DEFAULT 0,\n state TEXT DEFAULT 'idle', state_data TEXT,\n joined_channel INTEGER DEFAULT 0,\n active_project_id INTEGER,\n created_at INTEGER DEFAULT (strftime('%s','now')),\n updated_at INTEGER DEFAULT (strftime('%s','now'))\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS projects (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n owner_id INTEGER NOT NULL, name TEXT NOT NULL,\n main_file TEXT, bot_token TEXT, bot_username TEXT,\n admin_id TEXT, detected_imports TEXT,\n status TEXT DEFAULT 'stopped',\n webhook_secret TEXT, webhook_url TEXT,\n created_at INTEGER DEFAULT (strftime('%s','now')),\n started_at INTEGER, expires_at INTEGER, stopped_at INTEGER,\n last_update_at INTEGER, message_count INTEGER DEFAULT 0\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS files (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n project_id INTEGER NOT NULL, path TEXT NOT NULL, content TEXT NOT NULL,\n size INTEGER DEFAULT 0, is_main INTEGER DEFAULT 0,\n uploaded_at INTEGER DEFAULT (strftime('%s','now')),\n UNIQUE(project_id, path)\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS referrals (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n referrer_id INTEGER NOT NULL, invited_id INTEGER NOT NULL UNIQUE,\n created_at INTEGER DEFAULT (strftime('%s','now'))\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS webhook_events (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n project_id INTEGER, bot_token_hash TEXT, direction TEXT,\n payload TEXT, status_code INTEGER,\n created_at INTEGER DEFAULT (strftime('%s','now'))\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS panel_sessions (\n token TEXT PRIMARY KEY, username TEXT NOT NULL,\n created_at INTEGER DEFAULT (strftime('%s','now')),\n expires_at INTEGER NOT NULL\n )`);\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 // Safe migrations\n try { await sqlite.execute(`ALTER TABLE users ADD COLUMN active_project_id INTEGER`); } catch {}\n try { await sqlite.execute(`ALTER TABLE projects ADD COLUMN webhook_url TEXT`); } catch {}\n}\n",[],[164,236],"3183b638-3f25-11f1-bf01-42b51c65c3df","queries.ts","3183b6d8-3f25-11f1-bf01-42b51c65c3df",7,["D",1776956440212],"// All DB queries\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport type UserRow = {\n tg_id: number; username: string | null; first_name: string | null;\n referral_code: string; referred_by: number | null; referral_count: number;\n state: string; state_data: string | null; joined_channel: number;\n active_project_id: number | null;\n};\nexport type ProjectRow = {\n id: number; owner_id: number; name: string;\n main_file: string | null; bot_token: string | null; bot_username: string | null;\n admin_id: string | null; detected_imports: string | null; status: string;\n webhook_secret: string | null; webhook_url: string | null;\n created_at: number; started_at: number | null; expires_at: number | null;\n stopped_at: number | null; last_update_at: number | null; message_count: number;\n};\nexport type FileRow = {\n id: number; project_id: number; path: string; content: string;\n size: number; is_main: number; uploaded_at: number;\n};\n\nfunction genCode(prefix: string, len = 8): string {\n const chars = \"ABCDEFGHJKLMNPQRSTUVWXYZ23456789\";\n let s = \"\"; 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(tgId: number, username: string | null, firstName: string | null, referredBy: number | null = null) {\n const existing = await sqlite.execute({ sql: \"SELECT * FROM users WHERE tg_id=?\", args: [tgId] });\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 i = 0; i < 5; i++) {\n const c = await sqlite.execute({ sql: \"SELECT 1 FROM users WHERE referral_code=?\", args: [code] });\n if (c.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}\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}\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}\nexport async function setActiveProject(tgId: number, projectId: number | null) {\n await sqlite.execute({ sql: \"UPDATE users SET active_project_id=? WHERE tg_id=?\", args: [projectId, tgId] });\n}\nexport async function markJoined(tgId: number, joined: boolean) {\n await sqlite.execute({ sql: \"UPDATE users SET joined_channel=? WHERE tg_id=?\", args: [joined ? 1 : 0, tgId] });\n}\nexport async function addReferral(referrerId: number, invitedId: number): Promise {\n try {\n await sqlite.execute({ sql: \"INSERT INTO referrals (referrer_id, invited_id) VALUES (?, ?)\", args: [referrerId, invitedId] });\n await sqlite.execute({ sql: \"UPDATE users SET referral_count=referral_count+1 WHERE tg_id=?\", args: [referrerId] });\n return true;\n } catch { return false; }\n}\nexport async function consumeReferrals(userId: number, amount: number) {\n await sqlite.execute({ sql: \"UPDATE users SET referral_count=referral_count-? WHERE tg_id=?\", args: [amount, userId] });\n}\n\n// ===== PROJECTS =====\nexport async function listProjectsByOwner(ownerId: number): Promise {\n const r = await sqlite.execute({ sql: \"SELECT * FROM projects WHERE owner_id=? ORDER BY id ASC\", args: [ownerId] });\n return r.rows as unknown as ProjectRow[];\n}\nexport async function getActiveProject(ownerId: number): Promise {\n const user = await getUser(ownerId);\n if (user?.active_project_id) {\n const r = await sqlite.execute({ sql: \"SELECT * FROM projects WHERE id=? AND owner_id=?\", args: [user.active_project_id, ownerId] });\n if (r.rows.length) return r.rows[0] as unknown as ProjectRow;\n }\n const projs = await listProjectsByOwner(ownerId);\n return projs[0] ?? null;\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}\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}\nexport async function countProjects(ownerId: number): Promise {\n const r = await sqlite.execute({ sql: \"SELECT COUNT(*) as c FROM projects WHERE owner_id=?\", args: [ownerId] });\n return Number((r.rows[0] as any)?.c ?? 0);\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}\nexport async function updateProject(id: number, patch: Partial) {\n const keys = Object.keys(patch); if (!keys.length) return;\n const sets = keys.map((k) => `${k}=?`).join(\", \");\n const args = keys.map((k) => (patch as any)[k]); args.push(id);\n await sqlite.execute({ sql: `UPDATE projects SET ${sets} WHERE id=?`, args });\n}\nexport async function deleteProject(id: number) {\n await sqlite.execute({ sql: \"DELETE FROM files WHERE project_id=?\", args: [id] });\n await sqlite.execute({ sql: \"DELETE FROM webhook_events WHERE project_id=?\", args: [id] });\n await sqlite.execute({ sql: \"DELETE FROM projects WHERE id=?\", args: [id] });\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\n// ===== FILES =====\nexport async function addFile(projectId: number, path: string, content: string, isMain = false): 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({ sql: \"SELECT * FROM files WHERE project_id=? AND path=?\", args: [projectId, path] });\n return r.rows[0] as unknown as FileRow;\n}\nexport async function listFiles(projectId: number): Promise {\n const r = await sqlite.execute({ sql: \"SELECT * FROM files WHERE project_id=? ORDER BY is_main DESC, path ASC\", args: [projectId] });\n return r.rows as unknown as FileRow[];\n}\nexport async function getFile(projectId: number, path: string): Promise {\n const r = await sqlite.execute({ sql: \"SELECT * FROM files WHERE project_id=? AND path=?\", args: [projectId, path] });\n return r.rows.length ? (r.rows[0] as unknown as FileRow) : null;\n}\nexport async function deleteFileDb(projectId: number, path: string) {\n await sqlite.execute({ sql: \"DELETE FROM files WHERE project_id=? AND path=?\", args: [projectId, path] });\n}\nexport async function setMainFile(projectId: number, path: string) {\n await sqlite.execute({ sql: \"UPDATE files SET is_main=0 WHERE project_id=?\", args: [projectId] });\n await sqlite.execute({ sql: \"UPDATE files SET is_main=1 WHERE project_id=? AND path=?\", args: [projectId, path] });\n await sqlite.execute({ sql: \"UPDATE projects SET main_file=? WHERE id=?\", args: [path, projectId] });\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}\nexport async function recentEventsForProject(projectId: number, limit = 20) {\n const r = await sqlite.execute({\n sql: \"SELECT * FROM webhook_events WHERE project_id=? ORDER BY id DESC LIMIT ?\",\n args: [projectId, limit],\n });\n return r.rows as any[];\n}\nexport async function recentWebhookEvents(limit = 50) {\n const r = await sqlite.execute({ sql: \"SELECT * FROM webhook_events ORDER BY id DESC LIMIT ?\", args: [limit] });\n return r.rows as any[];\n}\n\n// ===== STATS / SESSIONS =====\nexport async function globalStats() {\n const num = (x: any) => Number(x.rows[0]?.c ?? 0);\n return {\n users: num(await sqlite.execute(\"SELECT COUNT(*) as c FROM users\")),\n projects: num(await sqlite.execute(\"SELECT COUNT(*) as c FROM projects\")),\n running: num(await sqlite.execute(\"SELECT COUNT(*) as c FROM projects WHERE status='running'\")),\n files: num(await sqlite.execute(\"SELECT COUNT(*) as c FROM files\")),\n messages: num(await sqlite.execute(\"SELECT COUNT(*) as c FROM webhook_events\")),\n };\n}\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({ sql: \"INSERT INTO panel_sessions (token, username, expires_at) VALUES (?, ?, ?)\", args: [token, username, expires] });\n return token;\n}\nexport async function validateSession(token: string): Promise {\n const now = Math.floor(Date.now() / 1000);\n const r = await sqlite.execute({ sql: \"SELECT 1 FROM panel_sessions WHERE token=? AND expires_at>?\", args: [token, now] });\n return r.rows.length > 0;\n}\nexport async function deleteSession(token: string) {\n await sqlite.execute({ sql: \"DELETE FROM panel_sessions WHERE token=?\", args: [token] });\n}\n",[],[164,243],["D",1776956400462],[180,181],[164],["D",1776956334773],["D",1789508444194],{"_109":108,"_116":112},{"_109":108,"_110":-5,"_111":112,"_19":66,"_113":114,"_115":31},{"_13":98,"_38":99,"_54":46,"_100":55,"_101":-5,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":56,"_107":108},"ctx",{"_91":-5,"_136":291,"_292":293,"_294":295,"_296":31,"_297":31,"_298":31,"_299":134,"_300":-5,"_301":-7,"_302":-7,"_303":72,"_304":31,"_305":31,"_306":-5,"_307":31,"_308":31,"_309":31,"_310":-5},"ENV",{"_262":263,"_264":265,"_266":99,"_267":268,"_269":270,"_271":272,"_273":274,"_275":276,"_277":278,"_279":280,"_281":282,"_283":284,"_285":286,"_287":288,"_289":290},"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 · v8