[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_171":172,"_173":174},"routes/_app.x.$handle.$name",{"_104":103,"_32":50,"_113":94,"_27":60,"_13":14,"_114":-5,"_11":115,"_116":117,"_118":119,"_120":121,"_122":123,"_21":-5,"_124":-5,"_125":-5,"_126":25,"_127":128,"_129":130,"_131":-5,"_132":-5,"_133":134},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_48":49,"_32":50,"_37":51,"_52":-5,"_53":25,"_54":55,"_56":55,"_57":58,"_59":60,"_18":61,"_62":-5,"_63":25,"_64":-5,"_65":-5,"_66":67,"_68":69,"_70":71,"_72":73,"_74":75,"_76":-5,"_77":78,"_79":78,"_80":81,"_82":81,"_83":81,"_84":78,"_85":78,"_86":87,"_88":89,"_90":91,"_92":25},"version",1,"changes",[19,20],"aiChatInfo","userId",{"_21":42,"_23":-7,"_24":25,"_26":25,"_27":43,"_29":43},{"_21":22,"_23":-7,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":36,"_37":38,"_39":14,"_40":41,"_24":25},"previous","deleted",false,"deletedHere","path","main.tsx","latestPath","fileId","019c74d7-67e8-766f-a36b-5b4536f58069","name","fileType","http","content","/** @jsxImportSource npm:hono/jsx */\nimport { Hono } from \"npm:hono\";\nimport { html } from \"npm:hono/html\";\nimport sqlite from \"https://esm.town/v/std/db/main.ts\";\n\nconst app = new Hono();\n\n// ====================================================================\n// CONFIGURATION & CONSTANTS\n// ====================================================================\n\n// Favicon: Folder Icon (Indigo) - Safe Base64 SVG\nconst FOLDER_SVG_PATH = ``;\nconst FAVICON_URL = `data:image/svg+xml,${encodeURIComponent(``)}`;\n\n// ====================================================================\n// DATABASE OPERATIONS\n// ====================================================================\n\nasync function initDB() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS drive_monitor_final (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL,\n resource_id TEXT NOT NULL,\n resource_link TEXT,\n gas_url TEXT,\n status TEXT DEFAULT 'PENDING',\n resource_type TEXT DEFAULT 'Unknown',\n kind TEXT DEFAULT 'file',\n last_check DATETIME,\n details TEXT,\n owner_email TEXT,\n me_email TEXT,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP,\n is_paused BOOLEAN DEFAULT 0,\n sort_order INTEGER DEFAULT 0\n )\n `);\n}\n\n// ====================================================================\n// LOGIC HELPERS\n// ====================================================================\n\n/**\n * Xử lý link Google Drive để tách ID và loại (File/Folder)\n */\nfunction parseDriveLink(link) {\n let id = \"\"; let kind = \"file\";\n if (!link) return { id: \"\", kind: \"file\" };\n if (!link.startsWith(\"http\")) return { id: link, kind: \"file\" };\n \n try {\n const url = new URL(link);\n if (url.pathname.includes(\"/folders/\")) { \n id = url.pathname.split(\"/folders/\")[1].split(/[\\/?]/)[0]; \n kind = \"folder\"; \n } else if (url.pathname.includes(\"/d/\")) { \n id = url.pathname.split(\"/d/\")[1].split(/[\\/?]/)[0]; \n kind = \"file\"; \n } else { \n id = link; \n }\n } catch (e) { id = link; }\n return { id, kind };\n}\n\n/**\n * Thực hiện kiểm tra tài nguyên thông qua GAS Worker\n */\nasync function checkSingleResource(row, fallbackGasUrl) {\n // 1. Nếu Paused -> Bỏ qua\n if (row.is_paused) {\n return { \n id: row.id,\n status: \"PAUSED\", \n type: row.resource_type, \n details: \"Đang ngừng theo dõi\", \n owner_email: row.owner_email, \n me_email: row.me_email \n };\n }\n\n // 2. Xác định Worker URL\n const workerUrl = row.gas_url || fallbackGasUrl;\n if (!workerUrl) {\n return { \n id: row.id,\n status: \"WARNING\", \n type: row.resource_type, \n details: \"Cần 1 GAS URL\", \n owner_email: row.owner_email, \n me_email: row.me_email \n };\n }\n\n // 3. Gọi Worker (Fetch)\n try {\n const response = await fetch(`${workerUrl}?id=${row.resource_id}`);\n const data = await response.json();\n \n let type = row.resource_type;\n let ownerEmail = data.debug_owner || row.owner_email;\n let meEmail = data.debug_me || row.me_email;\n\n if (data.status === \"OK\") {\n if (row.gas_url) {\n type = data.type; // Worker riêng -> Tin tưởng type trả về\n } else {\n if (type === 'Unknown') type = \"Public\"; // Mượn Worker -> Mặc định Public nếu chưa biết\n meEmail = \"Public Check\";\n }\n }\n return { \n id: row.id,\n status: data.status, \n type: type, \n details: data.name, \n owner_email: ownerEmail, \n me_email: meEmail \n };\n } catch (e) {\n return { \n id: row.id,\n status: \"ERROR\", \n type: row.resource_type, \n details: e.message, \n owner_email: row.owner_email, \n me_email: row.me_email \n };\n }\n}\n\n// ====================================================================\n// API ROUTES\n// ====================================================================\n\n// --- LIST ---\napp.get(\"/api/list\", async (c) => {\n await initDB();\n const result = await sqlite.execute(\"SELECT * FROM drive_monitor_final ORDER BY sort_order ASC, created_at DESC\");\n return c.json(result.rows);\n});\n\n// --- ADD ---\napp.post(\"/api/add\", async (c) => {\n await initDB();\n const body = await c.req.json();\n const gasUrl = body.gas_url && body.gas_url.trim() !== \"\" ? body.gas_url : null;\n const { id, kind } = parseDriveLink(body.resource_link);\n \n // Logic lấy sort_order lớn nhất để thêm vào cuối\n const maxOrderRes = await sqlite.execute(\"SELECT MAX(sort_order) as max FROM drive_monitor_final\");\n const nextOrder = (maxOrderRes.rows[0].max !== null) ? maxOrderRes.rows[0].max + 1 : 0;\n \n await sqlite.execute(\n `INSERT INTO drive_monitor_final (name, resource_id, resource_link, gas_url, kind, status, resource_type, is_paused, sort_order, created_at) VALUES (?, ?, ?, ?, ?, ?, ?, 0, ?, datetime('now'))`,\n [body.name, id, body.resource_link, gasUrl, kind, 'PENDING', 'Unknown', nextOrder]\n );\n return c.json({ success: true });\n});\n\n// --- UPDATE ---\napp.post(\"/api/update\", async (c) => {\n const body = await c.req.json();\n const gasUrl = body.gas_url && body.gas_url.trim() !== \"\" ? body.gas_url : null;\n const { id, kind } = parseDriveLink(body.resource_link);\n await sqlite.execute(\n `UPDATE drive_monitor_final SET name = ?, resource_id = ?, resource_link = ?, gas_url = ?, kind = ? WHERE id = ?`, \n [body.name, id, body.resource_link, gasUrl, kind, body.id]\n );\n return c.json({ success: true });\n});\n\n// --- SAVE ORDER ---\napp.post(\"/api/save-order\", async (c) => {\n const body = await c.req.json();\n const ids = body.order;\n // SQLite trên Val Town chạy HTTP, update loop vẫn ổn với số lượng nhỏ\n for (let i = 0; i < ids.length; i++) { \n await sqlite.execute(\"UPDATE drive_monitor_final SET sort_order = ? WHERE id = ?\", [i, ids[i]]); \n }\n return c.json({ success: true });\n});\n\n// --- TOGGLE PAUSE ---\napp.post(\"/api/toggle-pause\", async (c) => {\n const body = await c.req.json();\n const cur = await sqlite.execute(\"SELECT is_paused FROM drive_monitor_final WHERE id = ?\", [body.id]);\n const newState = cur.rows[0].is_paused ? 0 : 1;\n const newStatus = newState ? \"PAUSED\" : \"PENDING\"; \n await sqlite.execute(`UPDATE drive_monitor_final SET is_paused = ?, status = ? WHERE id = ?`, [newState, newStatus, body.id]);\n return c.json({ success: true });\n});\n\n// --- DELETE ---\napp.post(\"/api/delete\", async (c) => {\n const body = await c.req.json();\n await sqlite.execute(`DELETE FROM drive_monitor_final WHERE id = ?`, [body.id]);\n return c.json({ success: true });\n});\n\n// --- CHECK ALL (CONCURRENT OPTIMIZED) ---\napp.post(\"/api/check-all\", async (c) => {\n const result = await sqlite.execute(\"SELECT * FROM drive_monitor_final\");\n const rows = result.rows;\n const validRow = rows.find(r => r.gas_url && r.gas_url.startsWith(\"http\"));\n const fallbackGasUrl = validRow ? validRow.gas_url : null;\n \n // 1. Chạy tất cả các request song song (Promise.all)\n const checkPromises = rows.map(row => checkResource(row, fallbackGasUrl));\n const results = await Promise.all(checkPromises);\n\n const currentErrors = [];\n const updates = [];\n\n // 2. Cập nhật DB (Tuần tự để tránh lock DB)\n for (const res of results) {\n await sqlite.execute(\n `UPDATE drive_monitor_final SET status = ?, resource_type = ?, details = ?, owner_email = ?, me_email = ?, last_check = datetime('now') WHERE id = ?`,\n [res.status, res.type, res.details, res.owner_email, res.me_email, res.id]\n );\n updates.push(res);\n if (res.status === 'ERROR') {\n currentErrors.push(res.id);\n }\n }\n\n return c.json({ success: true, updates, current_errors: currentErrors });\n});\n\n// --- HELPER WRAPPER FOR CHECK RESOURCE ---\n// Wrapper này giúp map() dễ dàng hơn trong Promise.all\nasync function checkResource(row, fallbackGasUrl) {\n return await checkSingleResource(row, fallbackGasUrl);\n}\n\n\n// ====================================================================\n// UI TEMPLATE & ROUTE\n// ====================================================================\n\napp.get(\"/\", (c) => {\n return c.html(`\n \n \n \n \n \n Google Drive Sentinel\n \n \n \n \n \n \n \n \n

\n \n \n

\n Google Drive Sentinel\n

\n \n \n

\n \n

\n\n \n

\n\n \n \n\n \n \n\n \n \n \n \n `);\n});\n\nexport default app.fetch;","createdAt",["D",1771486799815],"branchVersion","branchId","31cb9426-0d66-11f1-bcf0-42dde27851f2",{"_30":44,"_32":43,"_33":45,"_35":46,"_37":47,"_39":14,"_40":41,"_24":25},"cron.ts","019c74d7-67e7-76b5-85ca-7404dd99f186","interval","import sqlite from \"https://esm.town/v/std/db/main.ts\";\n\n// --- CẤU HÌNH ---\n// 1. URL của Val chính (Nhớ thêm /api/check-all)\nconst VAL_MAIN_API_URL = \"https://nemofb--019c689f9300707f928d50c684e072e6.web.val.run/api/check-all\"; \n\n// 2. Kênh thông báo ntfy\nconst NTFY_TOPIC = \"varina_thong-bao\";\n\nexport default async function(interval: Interval) {\n console.log(\"🕒 Starting Cron Check...\");\n\n // 1. Gọi API Check-All từ Val Chính\n const response = await fetch(VAL_MAIN_API_URL, { method: \"POST\" });\n if (!response.ok) {\n console.error(\"❌ Failed to trigger check:\", response.statusText);\n return;\n }\n\n const data = await response.json();\n const currentErrors = data.current_errors || [];\n\n // 2. Lấy danh sách lỗi cũ từ DB (Lưu tạm trong 1 bảng riêng cho Cron này)\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS cron_error_tracking (\n id INTEGER PRIMARY KEY,\n error_ids TEXT -- Lưu JSON array các ID bị lỗi\n )\n `);\n\n const prevRes = await sqlite.execute(\"SELECT error_ids FROM cron_error_tracking WHERE id = 1\");\n let previousErrors = [];\n if (prevRes.rows.length > 0) {\n previousErrors = JSON.parse(prevRes.rows[0].error_ids || \"[]\");\n } else {\n // Lần đầu chạy -> Insert\n await sqlite.execute(\"INSERT INTO cron_error_tracking (id, error_ids) VALUES (1, '[]')\");\n }\n\n // 3. So sánh: Tìm các lỗi MỚI xuất hiện (Có trong Current nhưng không có trong Previous)\n const newErrors = currentErrors.filter(id => !previousErrors.includes(id));\n\n // 4. Nếu có lỗi mới -> Gửi thông báo\n if (newErrors.length > 0) {\n console.log(`⚠️ Found ${newErrors.length} new errors. Sending notification...`);\n \n await fetch(`https://ntfy.sh/${NTFY_TOPIC}`, {\n method: \"POST\",\n body: \"Cảnh báo: Phát hiện tài nguyên Google Drive bị lỗi. Kiểm tra ngay.\",\n headers: {\n \"Title\": \"Drive Sentinel Alert\",\n \"Priority\": \"high\",\n \"Tags\": \"warning,drive\"\n }\n });\n } else {\n console.log(\"✅ No new errors found.\");\n }\n\n // 5. Cập nhật lại danh sách lỗi hiện tại vào DB\n await sqlite.execute(\"UPDATE cron_error_tracking SET error_ids = ? WHERE id = 1\", [JSON.stringify(currentErrors)]);\n}",["D",1771486799815],"id","31c88722-0d66-11f1-bcf0-42dde27851f2","GDrive_Sentinel",["D",1771486799815],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Guestbook","imageUrl","","019c7021-27a1-77a3-91ff-0bee8f142cc4","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019c7021-27a1-77a3-91ff-0ea08d94c033","tursoName","31c887220d6611f1bcf042dde27851f2","tursoHostname","31c887220d6611f1bcf042dde27851f2-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789527643940],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_104":103,"_112":108},"org",{"_104":103,"_105":106,"_107":108,"_18":61,"_109":110,"_111":25},"branch",{"_13":93,"_32":94,"_48":41,"_95":49,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":50,"_102":103},"isOwned",7,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","varina_lab","handle","displayName","Varina Lab","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18zOXB6RWdqcFJZRGlHSkcxS2NYTXRjUUc3eTYifQ","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_48":49,"_32":50,"_37":166,"_52":-5,"_53":25,"_54":55,"_56":55,"_57":58,"_59":60,"_18":61,"_62":-5,"_63":25,"_64":-5,"_65":-5,"_66":67,"_68":69,"_70":71,"_72":73,"_74":167,"_76":-5,"_77":78,"_79":78,"_80":81,"_82":81,"_83":81,"_84":78,"_85":78,"_86":168,"_88":169,"_90":170,"_92":25},"tree",[157,158],"files",[157,158],"counts",{"_146":67,"_147":14,"_148":67,"_149":150,"_151":152},"contents",[135,136],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_48":143,"_32":43,"_30":44,"_138":-5,"_40":41,"_39":14,"_139":25,"_37":144,"_13":67,"_33":45,"_35":46,"_24":25,"_141":-5,"_27":145},{"_48":137,"_32":28,"_30":31,"_138":-5,"_40":41,"_39":14,"_139":25,"_37":140,"_13":67,"_33":34,"_35":36,"_24":25,"_141":-5,"_27":142},"31cead3c-0d66-11f1-bcf0-42dde27851f2","parentId","latest",["D",1771486799815],"label",[28],"31ce7c86-0d66-11f1-bcf0-42dde27851f2",["D",1771486799815],[43],"pulls","branches","forks","envVars",{"_153":155,"_156":67},"connections",{"_153":67,"_154":67},"count","unfilledCount",4,"emptyCount",{"_48":143,"_32":43,"_30":44,"_138":-5,"_40":41,"_39":14,"_139":25,"_37":163,"_13":67,"_33":45,"_35":46,"_24":25,"_141":-5,"_160":164,"_27":165},{"_48":137,"_32":28,"_30":31,"_138":-5,"_40":41,"_39":14,"_139":25,"_37":159,"_13":67,"_33":34,"_35":36,"_24":25,"_141":-5,"_160":161,"_27":162},["D",1771486799815],"children",[],[28],["D",1771486799815],[],[43],["D",1771486799815],["D",1789527643940],{"_104":103,"_112":108},{"_104":103,"_105":106,"_107":108,"_18":61,"_109":110,"_111":25},{"_13":93,"_32":94,"_48":41,"_95":49,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":50,"_102":103},"ctx",{"_86":-5,"_132":204,"_205":206,"_207":208,"_209":25,"_210":25,"_211":25,"_212":130,"_213":-5,"_214":-7,"_215":-7,"_216":67,"_217":25,"_218":25,"_219":-5,"_220":25,"_221":25,"_222":25,"_223":-5},"ENV",{"_175":176,"_177":178,"_179":94,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199,"_200":201,"_202":203},"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"]

\n Google Drive Sentinel\n

Thêm tài nguyên

Resource Name

Diff · v1