[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_172":173,"_174":175},"routes/_app.x.$handle.$name",{"_99":98,"_32":45,"_108":89,"_27":55,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_20":-5,"_119":-5,"_120":-5,"_121":25,"_122":123,"_124":125,"_126":-5,"_127":-5,"_128":129},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":55,"_18":56,"_57":-5,"_58":25,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":70,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":82,"_83":84,"_85":86,"_87":25},"version",5,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":34,"_35":37,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","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;","/** @jsxImportSource npm:hono/jsx */\nimport { Hono } from \"npm:hono\";\nimport { deleteCookie, getCookie, setCookie } from \"npm:hono/cookie\";\nimport sqlite from \"https://esm.town/v/std/db/main.ts\";\n\nconst app = new Hono();\n\n// ====================================================================\n// 1. CẤU HÌNH & HẰNG SỐ\n// ====================================================================\nconst ADMIN_USER = Deno.env.get(\"ADMIN_USER\") || \"admin\";\nconst ADMIN_PASS = Deno.env.get(\"ADMIN_PASS\") || \"123456\";\nconst COOKIE_NAME = \"drive_sentinel_session\";\n\nconst FOLDER_SVG_PATH =\n ``;\nconst FAVICON_URL = `data:image/svg+xml,${\n encodeURIComponent(\n ``,\n )\n}`;\n\n// ====================================================================\n// 2. DATABASE OPERATIONS (Tối ưu Cache)\n// ====================================================================\nlet dbInitialized = false;\n\nasync function ensureDB() {\n if (dbInitialized) return;\n\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 await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS drive_admin_sessions (\n session_id TEXT PRIMARY KEY,\n created_at DATETIME DEFAULT CURRENT_TIMESTAMP\n )\n `);\n\n await sqlite.execute(\n `DELETE FROM drive_admin_sessions WHERE created_at < datetime('now', '-7 days')`,\n );\n dbInitialized = true;\n}\n\n// ====================================================================\n// 3. MIDDLEWARE XÁC THỰC BẢO MẬT\n// ====================================================================\napp.use(\"*\", async (c, next) => {\n const path = new URL(c.req.url).pathname;\n if (path === \"/login\" || path === \"/logout\") return await next();\n\n // 1. Xác thực cho Val Cron Job (Qua Header)\n const authHeader = c.req.header(\"Authorization\");\n if (authHeader && authHeader === `Bearer ${ADMIN_PASS}`) {\n await ensureDB();\n return await next();\n }\n\n // 2. Xác thực cho Trình duyệt Web (Qua Cookie)\n const sessionId = getCookie(c, COOKIE_NAME);\n if (sessionId) {\n try {\n await ensureDB();\n const check = await sqlite.execute(\n \"SELECT session_id FROM drive_admin_sessions WHERE session_id = ?\",\n [sessionId],\n );\n if (check.rows.length > 0) {\n c.set(\"sessionId\", sessionId);\n return await next();\n }\n } catch (e) {\n console.error(\"DB Error:\", e);\n }\n }\n\n if (path.startsWith(\"/api/\")) {\n return c.json({ success: false, error: \"Unauthorized.\" }, 401);\n }\n return c.redirect(\"/login\");\n});\n\n// ====================================================================\n// 4. AUTHENTICATION CONTROLLERS\n// ====================================================================\napp.get(\"/login\", (c) => {\n const error = c.req.query(\"error\");\n return c.html(`\n \n \n \n \n \n Đăng nhập - Google Drive Sentinel\n \n \n \n \n \n \n

\n \n

Google Drive Sentinel

Vui lòng đăng nhập hệ thống

\n ${\n error\n ? `

Sai tài khoản hoặc mật khẩu

`\n : \"\"\n }\n \n

\n \n \n \n `);\n});\n\napp.post(\"/login\", async (c) => {\n const body = await c.req.parseBody();\n if (body.username === ADMIN_USER && body.password === ADMIN_PASS) {\n await ensureDB();\n const newSessionId = crypto.randomUUID();\n await sqlite.execute(\n \"INSERT INTO drive_admin_sessions (session_id) VALUES (?)\",\n [newSessionId],\n );\n setCookie(c, COOKIE_NAME, newSessionId, {\n path: \"/\",\n secure: true,\n httpOnly: true,\n maxAge: 60 * 60 * 24 * 7,\n sameSite: \"Lax\",\n });\n return c.redirect(\"/\");\n }\n return c.redirect(\"/login?error=1\");\n});\n\napp.get(\"/logout\", async (c) => {\n const currentSessionId = getCookie(c, COOKIE_NAME);\n if (currentSessionId) {\n await ensureDB();\n await sqlite.execute(\n \"DELETE FROM drive_admin_sessions WHERE session_id = ?\",\n [currentSessionId],\n );\n }\n deleteCookie(c, COOKIE_NAME, { path: \"/\" });\n return c.redirect(\"/login\");\n});\n\napp.post(\"/api/auth/logout-others\", async (c) => {\n const currentSessionId = c.get(\"sessionId\");\n if (currentSessionId) {\n await sqlite.execute(\n \"DELETE FROM drive_admin_sessions WHERE session_id != ?\",\n [currentSessionId],\n );\n return c.json({ success: true });\n }\n return c.json({ success: false, error: \"Không tìm thấy phiên\" });\n});\n\n// ====================================================================\n// 5. LOGIC HELPERS: GOOGLE DRIVE\n// ====================================================================\nfunction parseDriveLink(link) {\n let id = \"\";\n let kind = \"file\";\n if (!link) return { id: \"\", kind: \"file\" };\n if (!link.startsWith(\"http\")) return { id: link, kind: \"file\" };\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 id = link;\n } catch (e) {\n id = link;\n }\n return { id, kind };\n}\n\nasync function checkSingleResource(row, fallbackGasUrl) {\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 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 try {\n const response = await fetch(`${workerUrl}?id=${row.resource_id}`);\n const data = await response.json();\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 if (data.status === \"OK\") {\n if (row.gas_url) type = data.type;\n else {\n if (type === \"Unknown\") type = \"Public\";\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}\nasync function checkResource(row, fallbackGasUrl) {\n return await checkSingleResource(row, fallbackGasUrl);\n}\n\n// ====================================================================\n// 6. API ROUTES\n// ====================================================================\napp.get(\"/api/list\", async (c) => {\n const result = await sqlite.execute(\n \"SELECT * FROM drive_monitor_final ORDER BY sort_order ASC, created_at DESC\",\n );\n return c.json(result.rows);\n});\n\napp.post(\"/api/add\", async (c) => {\n const body = await c.req.json();\n const gasUrl = body.gas_url && body.gas_url.trim() !== \"\"\n ? body.gas_url\n : null;\n const { id, kind } = parseDriveLink(body.resource_link);\n const maxOrderRes = await sqlite.execute(\n \"SELECT MAX(sort_order) as max FROM drive_monitor_final\",\n );\n const nextOrder = (maxOrderRes.rows[0].max !== null)\n ? maxOrderRes.rows[0].max + 1\n : 0;\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 [\n body.name,\n id,\n body.resource_link,\n gasUrl,\n kind,\n \"PENDING\",\n \"Unknown\",\n nextOrder,\n ],\n );\n return c.json({ success: true });\n});\n\napp.post(\"/api/update\", async (c) => {\n const body = await c.req.json();\n const gasUrl = body.gas_url && body.gas_url.trim() !== \"\"\n ? body.gas_url\n : 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\napp.post(\"/api/save-order\", async (c) => {\n const body = await c.req.json();\n for (let i = 0; i < body.order.length; i++) {\n await sqlite.execute(\n \"UPDATE drive_monitor_final SET sort_order = ? WHERE id = ?\",\n [i, body.order[i]],\n );\n }\n return c.json({ success: true });\n});\n\napp.post(\"/api/toggle-pause\", async (c) => {\n const body = await c.req.json();\n const cur = await sqlite.execute(\n \"SELECT is_paused FROM drive_monitor_final WHERE id = ?\",\n [body.id],\n );\n const newState = cur.rows[0].is_paused ? 0 : 1;\n const newStatus = newState ? \"PAUSED\" : \"PENDING\";\n await sqlite.execute(\n `UPDATE drive_monitor_final SET is_paused = ?, status = ? WHERE id = ?`,\n [newState, newStatus, body.id],\n );\n return c.json({ success: true });\n});\n\napp.post(\"/api/delete\", async (c) => {\n const body = await c.req.json();\n await sqlite.execute(`DELETE FROM drive_monitor_final WHERE id = ?`, [\n body.id,\n ]);\n return c.json({ success: true });\n});\n\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 const checkPromises = rows.map((row) => checkResource(row, fallbackGasUrl));\n const results = await Promise.all(checkPromises);\n const currentErrors = [];\n const updates = [];\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 [\n res.status,\n res.type,\n res.details,\n res.owner_email,\n res.me_email,\n res.id,\n ],\n );\n updates.push(res);\n if (res.status === \"ERROR\") currentErrors.push(res.id);\n }\n return c.json({ success: true, updates, current_errors: currentErrors });\n});\n\n// ====================================================================\n// 7. UI TEMPLATE & ROUTE\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 Google Drive Sentinel\n

\n \n \n \n

\n\n \n\n \n\n \n \n \n `);\n});\n\nexport default function (req: Request): Response | Promise {\n return app.fetch(req);\n}","createdAt",["D",1772188131488],"branchVersion","branchId","31cb9426-0d66-11f1-bcf0-42dde27851f2","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",{"_99":98,"_107":103},"org",{"_99":98,"_100":101,"_102":103,"_18":56,"_104":105,"_106":25},"branch",{"_13":88,"_32":89,"_43":42,"_90":44,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":45,"_97":98},"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",{"_43":44,"_32":45,"_38":167,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":55,"_18":56,"_57":-5,"_58":25,"_59":-5,"_60":-5,"_61":62,"_63":64,"_65":66,"_67":68,"_69":168,"_71":-5,"_72":73,"_74":73,"_75":76,"_77":76,"_78":76,"_79":73,"_80":73,"_81":169,"_83":170,"_85":171,"_87":25},"tree",[158,159],"files",[158,159],"counts",{"_148":62,"_149":136,"_150":62,"_151":152,"_153":154},"contents",[130,131],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":139,"_32":140,"_30":141,"_133":-5,"_41":42,"_40":142,"_134":25,"_38":143,"_13":144,"_33":145,"_35":146,"_24":25,"_137":-5,"_27":147},{"_43":132,"_32":28,"_30":31,"_133":-5,"_41":42,"_40":14,"_134":125,"_38":135,"_13":136,"_33":34,"_35":37,"_24":25,"_137":-5,"_27":138},"1c09ffe4-13c7-11f1-a46c-42dde27851f2","parentId","latest",["D",1772188131488],1,"label",[28],"064a936a-0d75-11f1-b264-42dde27851f2","cron.ts","019c74d7-67e7-76b5-85ca-7404dd99f186",4,["D",1771493169295],3,"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 =\n \"https://varina_lab--019c74d767e8766fa36b5b4536f58069.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(\n \"SELECT error_ids FROM cron_error_tracking WHERE id = 1\",\n );\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(\n \"INSERT INTO cron_error_tracking (id, error_ids) VALUES (1, '[]')\",\n );\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(\n `⚠️ Found ${newErrors.length} new errors. Sending notification...`,\n );\n\n await fetch(`https://ntfy.sh/${NTFY_TOPIC}`, {\n method: \"POST\",\n body:\n \"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(\n \"UPDATE cron_error_tracking SET error_ids = ? WHERE id = 1\",\n [JSON.stringify(currentErrors)],\n );\n}",[140],"pulls","branches","forks","envVars",{"_155":142,"_157":62},"connections",{"_155":62,"_156":62},"count","unfilledCount","emptyCount",{"_43":139,"_32":140,"_30":141,"_133":-5,"_41":42,"_40":142,"_134":25,"_38":164,"_13":144,"_33":145,"_35":146,"_24":25,"_137":-5,"_161":165,"_27":166},{"_43":132,"_32":28,"_30":31,"_133":-5,"_41":42,"_40":14,"_134":125,"_38":160,"_13":136,"_33":34,"_35":37,"_24":25,"_137":-5,"_161":162,"_27":163},["D",1772188131488],"children",[],[28],["D",1771493169295],[],[140],["D",1771486799815],["D",1789527643940],{"_99":98,"_107":103},{"_99":98,"_100":101,"_102":103,"_18":56,"_104":105,"_106":25},{"_13":88,"_32":89,"_43":42,"_90":44,"_91":-5,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":45,"_97":98},"ctx",{"_81":-5,"_127":205,"_206":207,"_208":209,"_210":25,"_211":25,"_212":25,"_213":125,"_214":-5,"_215":-7,"_216":-7,"_217":62,"_218":25,"_219":25,"_220":-5,"_221":25,"_222":25,"_223":25,"_224":-5},"ENV",{"_176":177,"_178":179,"_180":89,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200,"_201":202,"_203":204},"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

Google Drive Sentinel

\n Google Drive Sentinel\n

Thêm tài nguyên

Resource Name

Diff · v5