[{"_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",{"_97":96,"_32":45,"_106":87,"_27":107,"_13":14,"_108":-5,"_11":109,"_110":111,"_112":113,"_114":115,"_116":117,"_20":-5,"_118":-5,"_119":-5,"_120":25,"_121":122,"_123":124,"_125":-5,"_126":-5,"_127":128},"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":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":68,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":80,"_81":82,"_83":84,"_85":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.ts","latestPath","fileId","019c78a6-8114-76d5-a8a9-8aa410c39f0f","name","fileType","http","content","/** @jsxImportSource npm:hono/jsx */\nimport { Hono } from \"npm:hono\";\nimport sqlite from \"https://esm.town/v/std/db/main.ts\";\n\nconst app = new Hono();\n\n// ====================================================================\n// 1. CONFIGURATION (CẤU HÌNH HỆ THỐNG)\n// ====================================================================\nconst CONFIG = {\n TABLE_NAME: \"dropbox_monitor_final\",\n ICON_SVG: ``\n};\nconst FAVICON_URL = `data:image/svg+xml,${encodeURIComponent(CONFIG.ICON_SVG)}`;\n\n// ====================================================================\n// 2. DATABASE LAYER\n// ====================================================================\nconst DB = {\n async init() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${CONFIG.TABLE_NAME} ( \n id INTEGER PRIMARY KEY AUTOINCREMENT, name TEXT NOT NULL, resource_id TEXT NOT NULL, \n resource_link TEXT, access_token TEXT, status TEXT DEFAULT 'PENDING', \n resource_type TEXT DEFAULT 'Unknown', kind TEXT DEFAULT 'file', last_check DATETIME, \n details TEXT, owner_email TEXT, me_email TEXT, created_at DATETIME DEFAULT CURRENT_TIMESTAMP, \n is_paused BOOLEAN DEFAULT 0, sort_order INTEGER DEFAULT 0 \n )\n `);\n },\n async getAll() {\n const result = await sqlite.execute(`SELECT * FROM ${CONFIG.TABLE_NAME} ORDER BY sort_order ASC, created_at DESC`);\n return result.rows;\n },\n async add(data) {\n const maxRes = await sqlite.execute(`SELECT MAX(sort_order) as max FROM ${CONFIG.TABLE_NAME}`);\n const nextOrder = maxRes.rows[0].max !== null ? maxRes.rows[0].max + 1 : 0;\n await sqlite.execute(\n `INSERT INTO ${CONFIG.TABLE_NAME} (name, resource_id, resource_link, access_token, kind, status, resource_type, is_paused, sort_order, created_at) VALUES (?, ?, ?, ?, ?, 'PENDING', 'Unknown', 0, ?, datetime('now'))`, \n [data.name, data.id, data.link, data.token, data.kind, nextOrder]\n );\n },\n async update(data) {\n await sqlite.execute( \n `UPDATE ${CONFIG.TABLE_NAME} SET name = ?, resource_id = ?, resource_link = ?, access_token = ?, kind = ? WHERE id = ?`, \n [data.name, data.id, data.link, data.token, data.kind, data.db_id] \n );\n },\n async updateOrder(id, orderIndex) {\n await sqlite.execute(`UPDATE ${CONFIG.TABLE_NAME} SET sort_order = ? WHERE id = ?`, [orderIndex, id]);\n },\n async togglePause(id) {\n const cur = await sqlite.execute(`SELECT is_paused FROM ${CONFIG.TABLE_NAME} WHERE id = ?`, [id]); \n const newState = cur.rows[0].is_paused ? 0 : 1; \n await sqlite.execute(`UPDATE ${CONFIG.TABLE_NAME} SET is_paused = ?, status = ? WHERE id = ?`, [newState, newState ? \"PAUSED\" : \"PENDING\", id]);\n },\n async delete(id) {\n await sqlite.execute(`DELETE FROM ${CONFIG.TABLE_NAME} WHERE id = ?`, [id]);\n },\n async saveCheckResult(res) {\n await sqlite.execute( \n `UPDATE ${CONFIG.TABLE_NAME} 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 }\n};\n\n// ====================================================================\n// 3. SERVICE LAYER & TOKEN MANAGER (BỘ NHỚ ĐỆM TỐI ƯU HIỆU SUẤT)\n// ====================================================================\nconst TokenManager = {\n promises: {}, // Lưu trạng thái request đang chạy để tránh gọi trùng lặp\n \n async getAccessToken(refreshToken) {\n if (!refreshToken) return null;\n \n // TỐI ƯU: Nếu token này đang được request, chờ kết quả thay vì gọi thêm request mới\n if (this.promises[refreshToken]) return this.promises[refreshToken];\n \n this.promises[refreshToken] = (async () => {\n const appKey = Deno.env.get(\"DROPBOX_APP_KEY\");\n const appSecret = Deno.env.get(\"DROPBOX_APP_SECRET\");\n if (!appKey || !appSecret) throw new Error(\"Chưa cài đặt DROPBOX_APP_KEY / APP_SECRET\");\n \n const basicAuth = btoa(`${appKey}:${appSecret}`);\n const res = await fetch(\"https://api.dropboxapi.com/oauth2/token\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n \"Authorization\": `Basic ${basicAuth}`\n },\n body: new URLSearchParams({ grant_type: \"refresh_token\", refresh_token: refreshToken })\n });\n \n const data = await res.json();\n if (!res.ok) throw new Error(data.error_description || \"Lỗi tạo Token mới\");\n return data.access_token;\n })();\n \n return this.promises[refreshToken];\n }\n};\n\nconst DropboxAPI = {\n parseLink(link) {\n if (!link) return { id: \"\", kind: \"file\" };\n return { id: link, kind: (link.includes(\"/scl/fo/\") || link.includes(\"/sh/\")) ? \"folder\" : \"file\" };\n },\n\n async checkResource(row) {\n if (row.is_paused) return { ...row, status: \"PAUSED\", details: \"Đang ngừng theo dõi\" };\n\n const systemRefreshToken = Deno.env.get(\"DROPBOX_REFRESH_TOKEN\");\n const activeRefreshToken = row.access_token || systemRefreshToken; // Cột access_token cũ giờ lưu Refresh Token\n const isSystemToken = !row.access_token && !!systemRefreshToken;\n\n if (!activeRefreshToken) return { ...row, status: \"WARNING\", type: \"Unknown\", details: \"Thiếu Refresh Token hợp lệ\" };\n\n let token;\n try {\n // Gọi qua TokenManager để lấy Access Token sống 4 tiếng, siêu tối ưu\n token = await TokenManager.getAccessToken(activeRefreshToken);\n } catch (err) {\n return { ...row, status: \"ERROR\", details: \"Auth Error: \" + err.message };\n }\n\n try {\n let meEmail = \"Unknown\";\n const accountRes = await fetch(\"https://api.dropboxapi.com/2/users/get_current_account\", {\n method: \"POST\", headers: { \"Authorization\": `Bearer ${token}` }\n });\n if (accountRes.ok) meEmail = (await accountRes.json()).email;\n\n const checkRes = await fetch(\"https://api.dropboxapi.com/2/sharing/get_shared_link_metadata\", {\n method: \"POST\", headers: { \"Authorization\": `Bearer ${token}`, \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ url: row.resource_link })\n });\n const data = await checkRes.json();\n\n if (checkRes.ok && data) {\n let type = \"Owner\"; \n if (isSystemToken) type = \"Public\"; \n else if (data.team_member_info || (data.link_permissions && data.link_permissions.can_revoke === false)) type = \"Shared\";\n\n return { id: row.id, status: \"OK\", type: type, details: data.name, owner_email: \"Hidden by API\", me_email: isSystemToken ? \"System Checker\" : meEmail };\n } else {\n return { id: row.id, status: \"ERROR\", type: isSystemToken ? \"Public\" : row.resource_type, details: data.error_summary || \"Mất quyền truy cập\", owner_email: row.owner_email, me_email: meEmail };\n }\n } catch (e) {\n return { ...row, status: \"ERROR\", details: e.message };\n }\n }\n};\n\n// ====================================================================\n// 4. CONTROLLERS (API ROUTES)\n// ====================================================================\napp.get(\"/api/list\", async (c) => { await DB.init(); return c.json(await DB.getAll()); });\n\napp.post(\"/api/add\", async (c) => {\n await DB.init();\n const body = await c.req.json();\n const { id, kind } = DropboxAPI.parseLink(body.resource_link);\n await DB.add({ name: body.name, id, link: body.resource_link, token: body.access_token?.trim() || null, kind });\n return c.json({ success: true });\n});\n\napp.post(\"/api/update\", async (c) => {\n const body = await c.req.json(); \n const { id, kind } = DropboxAPI.parseLink(body.resource_link); \n await DB.update({ db_id: body.id, name: body.name, id, link: body.resource_link, token: body.access_token?.trim() || null, kind });\n return c.json({ success: true });\n});\n\napp.post(\"/api/save-order\", async (c) => {\n const { order } = await c.req.json(); \n for (let i = 0; i < order.length; i++) await DB.updateOrder(order[i], i);\n return c.json({ success: true });\n});\n\napp.post(\"/api/toggle-pause\", async (c) => {\n const { id } = await c.req.json(); \n await DB.togglePause(id);\n return c.json({ success: true });\n});\n\napp.post(\"/api/delete\", async (c) => {\n const { id } = await c.req.json();\n await DB.delete(id);\n return c.json({ success: true });\n});\n\napp.post(\"/api/check-all\", async (c) => {\n const rows = await DB.getAll();\n const checkPromises = rows.map(row => DropboxAPI.checkResource(row));\n const results = await Promise.all(checkPromises);\n \n const currentErrors = [];\n const updates = [];\n\n for (const res of results) {\n await DB.saveCheckResult(res);\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// 5. VIEW (GIAO DIỆN HTML)\n// ====================================================================\napp.get(\"/\", (c) => {\n return c.html(`\n\n\n\n \n \n Dropbox Sentinel\n \n \n \n \n \n \n\n\n

Dropbox Sentinel

\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 sqlite from \"https://esm.town/v/std/db/main.ts\";\n\nconst app = new Hono();\n\n// ====================================================================\n// 1. CONFIGURATION (CẤU HÌNH HỆ THỐNG)\n// ====================================================================\nconst CONFIG = {\n TABLE_NAME: \"dropbox_monitor_final\",\n ICON_SVG:\n ``,\n};\nconst FAVICON_URL = `data:image/svg+xml,${encodeURIComponent(CONFIG.ICON_SVG)}`;\n\n// ====================================================================\n// 2. DATABASE LAYER (MÔ HÌNH DỮ LIỆU) - BỌC THÉP CHỐNG LỖI\n// ====================================================================\nconst DB = {\n async init() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ${CONFIG.TABLE_NAME} ( \n id INTEGER PRIMARY KEY AUTOINCREMENT, name TEXT NOT NULL, resource_id TEXT NOT NULL, \n resource_link TEXT, access_token TEXT, status TEXT DEFAULT 'PENDING', \n resource_type TEXT DEFAULT 'Unknown', kind TEXT DEFAULT 'file', last_check DATETIME, \n details TEXT, owner_email TEXT, me_email TEXT, created_at DATETIME DEFAULT CURRENT_TIMESTAMP, \n is_paused BOOLEAN DEFAULT 0, sort_order INTEGER DEFAULT 0 \n )\n `);\n // Tự động nâng cấp bảng cũ nếu thiếu cột access_token\n try {\n await sqlite.execute(\n `ALTER TABLE ${CONFIG.TABLE_NAME} ADD COLUMN access_token TEXT`,\n );\n } catch (e) {}\n },\n async getAll() {\n const result = await sqlite.execute(\n `SELECT * FROM ${CONFIG.TABLE_NAME} ORDER BY sort_order ASC, created_at DESC`,\n );\n return result.rows;\n },\n async add(data) {\n const maxRes = await sqlite.execute(\n `SELECT MAX(sort_order) as max FROM ${CONFIG.TABLE_NAME}`,\n );\n const nextOrder = maxRes.rows[0].max !== null ? maxRes.rows[0].max + 1 : 0;\n await sqlite.execute(\n `INSERT INTO ${CONFIG.TABLE_NAME} (name, resource_id, resource_link, access_token, kind, status, resource_type, is_paused, sort_order, created_at) VALUES (?, ?, ?, ?, ?, 'PENDING', 'Unknown', 0, ?, datetime('now'))`,\n [data.name, data.id, data.link, data.token || null, data.kind, nextOrder],\n );\n },\n async update(data) {\n await sqlite.execute(\n `UPDATE ${CONFIG.TABLE_NAME} SET name = ?, resource_id = ?, resource_link = ?, access_token = ?, kind = ? WHERE id = ?`,\n [\n data.name,\n data.id,\n data.link,\n data.token || null,\n data.kind,\n data.db_id,\n ],\n );\n },\n async updateOrder(id, orderIndex) {\n await sqlite.execute(\n `UPDATE ${CONFIG.TABLE_NAME} SET sort_order = ? WHERE id = ?`,\n [orderIndex, id],\n );\n },\n async togglePause(id) {\n const cur = await sqlite.execute(\n `SELECT is_paused FROM ${CONFIG.TABLE_NAME} WHERE id = ?`,\n [id],\n );\n const newState = cur.rows[0].is_paused ? 0 : 1;\n await sqlite.execute(\n `UPDATE ${CONFIG.TABLE_NAME} SET is_paused = ?, status = ? WHERE id = ?`,\n [newState, newState ? \"PAUSED\" : \"PENDING\", id],\n );\n },\n async delete(id) {\n await sqlite.execute(`DELETE FROM ${CONFIG.TABLE_NAME} WHERE id = ?`, [id]);\n },\n async saveCheckResult(res) {\n // Ép kiểu triệt để, loại bỏ toàn bộ undefined có thể gây sập SQLite\n const rStatus = res.status || \"ERROR\";\n const rType = res.type || res.resource_type || \"Unknown\";\n const rDetails = res.details || null;\n const rOwner = res.owner_email || null;\n const rMe = res.me_email || null;\n\n await sqlite.execute(\n `UPDATE ${CONFIG.TABLE_NAME} SET status = ?, resource_type = ?, details = ?, owner_email = ?, me_email = ?, last_check = datetime('now') WHERE id = ?`,\n [rStatus, rType, rDetails, rOwner, rMe, res.id],\n );\n },\n};\n\n// ====================================================================\n// 3. SERVICE LAYER & TOKEN MANAGER\n// ====================================================================\nconst TokenManager = {\n promises: {},\n async getAccessToken(refreshToken) {\n if (!refreshToken) return null;\n if (this.promises[refreshToken]) return this.promises[refreshToken];\n\n this.promises[refreshToken] = (async () => {\n const appKey = Deno.env.get(\"DROPBOX_APP_KEY\");\n const appSecret = Deno.env.get(\"DROPBOX_APP_SECRET\");\n if (!appKey || !appSecret) {\n throw new Error(\"Chưa cấu hình DROPBOX_APP_KEY hoặc SECRET\");\n }\n\n const basicAuth = btoa(`${appKey}:${appSecret}`);\n const res = await fetch(\"https://api.dropboxapi.com/oauth2/token\", {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/x-www-form-urlencoded\",\n \"Authorization\": `Basic ${basicAuth}`,\n },\n body: new URLSearchParams({\n grant_type: \"refresh_token\",\n refresh_token: refreshToken,\n }),\n });\n\n const data = await res.json();\n if (!res.ok) {\n throw new Error(data.error_description || \"Không thể cấp Token mới\");\n }\n return data.access_token;\n })();\n return this.promises[refreshToken];\n },\n};\n\nconst DropboxAPI = {\n parseLink(link) {\n if (!link) return { id: \"\", kind: \"file\" };\n return {\n id: link,\n kind: (link.includes(\"/scl/fo/\") || link.includes(\"/sh/\"))\n ? \"folder\"\n : \"file\",\n };\n },\n\n async checkResource(row) {\n if (row.is_paused) {\n return { ...row, status: \"PAUSED\", details: \"Đang ngừng theo dõi\" };\n }\n\n const systemRefreshToken = Deno.env.get(\"DROPBOX_REFRESH_TOKEN\");\n const activeRefreshToken = row.access_token || systemRefreshToken;\n const isSystemToken = !row.access_token && !!systemRefreshToken;\n\n if (!activeRefreshToken) {\n return {\n ...row,\n status: \"WARNING\",\n type: row.resource_type || \"Unknown\",\n details: \"Thiếu Refresh Token hợp lệ\",\n };\n }\n\n let token;\n try {\n token = await TokenManager.getAccessToken(activeRefreshToken);\n } catch (err) {\n // Đảm bảo luôn trả về type để không làm sập SQLite\n return {\n ...row,\n status: \"ERROR\",\n type: row.resource_type || \"Unknown\",\n details: \"Auth Error: \" + err.message,\n };\n }\n\n try {\n let meEmail = \"Unknown\";\n const accountRes = await fetch(\n \"https://api.dropboxapi.com/2/users/get_current_account\",\n {\n method: \"POST\",\n headers: { \"Authorization\": `Bearer ${token}` },\n },\n );\n if (accountRes.ok) meEmail = (await accountRes.json()).email;\n\n const checkRes = await fetch(\n \"https://api.dropboxapi.com/2/sharing/get_shared_link_metadata\",\n {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${token}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({ url: row.resource_link }),\n },\n );\n const data = await checkRes.json();\n\n if (checkRes.ok && data) {\n let type = \"Owner\";\n if (isSystemToken) type = \"Public\";\n else if (\n data.team_member_info ||\n (data.link_permissions && data.link_permissions.can_revoke === false)\n ) type = \"Shared\";\n\n return {\n id: row.id,\n status: \"OK\",\n type: type,\n details: data.name,\n owner_email: \"Hidden by API\",\n me_email: isSystemToken ? \"System Checker\" : meEmail,\n };\n } else {\n return {\n id: row.id,\n status: \"ERROR\",\n type: isSystemToken ? \"Public\" : (row.resource_type || \"Unknown\"),\n details: data.error_summary || \"Mất quyền truy cập\",\n owner_email: row.owner_email,\n me_email: meEmail,\n };\n }\n } catch (e) {\n return {\n ...row,\n status: \"ERROR\",\n type: row.resource_type || \"Unknown\",\n details: \"Lỗi mạng: \" + e.message,\n };\n }\n },\n};\n\n// ====================================================================\n// 4. CONTROLLERS (API ROUTES)\n// ====================================================================\napp.get(\"/api/list\", async (c) => {\n await DB.init();\n return c.json(await DB.getAll());\n});\n\napp.post(\"/api/add\", async (c) => {\n await DB.init();\n const body = await c.req.json();\n const { id, kind } = DropboxAPI.parseLink(body.resource_link);\n await DB.add({\n name: body.name,\n id,\n link: body.resource_link,\n token: body.access_token?.trim() || null,\n kind,\n });\n return c.json({ success: true });\n});\n\napp.post(\"/api/update\", async (c) => {\n const body = await c.req.json();\n const { id, kind } = DropboxAPI.parseLink(body.resource_link);\n await DB.update({\n db_id: body.id,\n name: body.name,\n id,\n link: body.resource_link,\n token: body.access_token?.trim() || null,\n kind,\n });\n return c.json({ success: true });\n});\n\napp.post(\"/api/save-order\", async (c) => {\n const { order } = await c.req.json();\n for (let i = 0; i < order.length; i++) await DB.updateOrder(order[i], i);\n return c.json({ success: true });\n});\n\napp.post(\"/api/toggle-pause\", async (c) => {\n const { id } = await c.req.json();\n await DB.togglePause(id);\n return c.json({ success: true });\n});\n\napp.post(\"/api/delete\", async (c) => {\n const { id } = await c.req.json();\n await DB.delete(id);\n return c.json({ success: true });\n});\n\napp.post(\"/api/check-all\", async (c) => {\n try {\n const rows = await DB.getAll();\n const checkPromises = rows.map((row) => DropboxAPI.checkResource(row));\n const results = await Promise.all(checkPromises);\n\n const currentErrors = [];\n const updates = [];\n\n for (const res of results) {\n await DB.saveCheckResult(res);\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 } catch (err) {\n // Trả về lỗi 500 kèm chi tiết để báo động lên giao diện\n return c.json({ success: false, error: err.message }, 500);\n }\n});\n\n// ====================================================================\n// 5. VIEW (GIAO DIỆN HTML)\n// ====================================================================\napp.get(\"/\", (c) => {\n return c.html(`\n\n\n\n \n \n Dropbox Sentinel\n \n \n \n \n \n \n\n\n

Dropbox Sentinel

\n \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",1771557268986],"branchVersion","branchId","fb8bfc30-0dfa-11f1-938e-42dde27851f2","id","fb871a62-0dfa-11f1-938e-42dde27851f2","Dropbox_Sentinel",["D",1771550703765],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","019c7021-27a1-77a3-91ff-0bee8f142cc4","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019c7021-27a1-77a3-91ff-0ea08d94c033","tursoName","fb871a620dfa11f1938e42dde27851f2","tursoHostname","fb871a620dfa11f1938e42dde27851f2-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789529498250],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_97":96,"_105":101},"org",{"_97":96,"_98":99,"_100":101,"_18":54,"_102":103,"_104":25},"branch",{"_13":86,"_32":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"isOwned",11,"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":-5,"_53":-5,"_18":54,"_55":-5,"_56":25,"_57":-5,"_58":-5,"_59":60,"_61":62,"_63":64,"_65":66,"_67":168,"_69":-5,"_70":71,"_72":71,"_73":74,"_75":74,"_76":74,"_77":71,"_78":71,"_79":169,"_81":170,"_83":171,"_85":25},"tree",[158,159],"files",[158,159],"counts",{"_146":60,"_147":148,"_149":60,"_150":151,"_152":153},"contents",[129,130],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles",true,"grants","orgs","customDomains",{},{"_43":138,"_32":139,"_30":140,"_132":-5,"_41":42,"_40":141,"_133":25,"_38":142,"_13":135,"_33":143,"_35":144,"_24":25,"_136":-5,"_27":145},{"_43":131,"_32":28,"_30":31,"_132":-5,"_41":42,"_40":14,"_133":25,"_38":134,"_13":135,"_33":34,"_35":37,"_24":25,"_136":-5,"_27":137},"44afc3f6-0e0a-11f1-b58d-42dde27851f2","parentId","latest",["D",1771557268986],2,"label",[28],"03c7792c-0dfd-11f1-a982-42dde27851f2","cron.ts","019c78a6-8114-76d5-a8a9-8712489fefc3",3,["D",1771551576634],"interval","import sqlite from \"https://esm.town/v/std/db/main.ts\";\n\n// ====================================================================\n// CẤU HÌNH CRON JOB\n// ====================================================================\n// 1. Thay URL này bằng địa chỉ Val Chính của bạn + \"/api/check-all\"\nconst VAL_MAIN_API_URL =\n \"https://varina_lab--019c78a6811476d5a8a98aa410c39f0f.web.val.run/api/check-all\";\n\n// 2. Tên Topic của ứng dụng ntfy để nhận thông báo về điện thoại\nconst NTFY_TOPIC = \"varina_thong-bao\";\n\nexport default async function (interval: Interval) {\n console.log(\"🕒 Starting Dropbox Sentinel Cron Check...\");\n\n // 1. Gọi API quét toàn bộ tài nguyên trên Val Chính\n const response = await fetch(VAL_MAIN_API_URL, { method: \"POST\" });\n\n if (!response.ok) {\n console.error(\"❌ Failed to trigger check API:\", response.statusText);\n return;\n }\n\n const data = await response.json();\n const currentErrors = data.current_errors || [];\n\n // 2. Khởi tạo Bảng lịch sử lỗi (Bảng này độc lập với bản Google Drive)\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS cron_error_tracking_dropbox ( \n id INTEGER PRIMARY KEY, \n error_ids TEXT \n )\n `);\n\n // 3. Lấy danh sách ID đã bị lỗi từ lần kiểm tra trước\n const prevRes = await sqlite.execute(\n \"SELECT error_ids FROM cron_error_tracking_dropbox WHERE id = 1\",\n );\n let previousErrors = [];\n\n if (prevRes.rows.length > 0) {\n previousErrors = JSON.parse(prevRes.rows[0].error_ids || \"[]\");\n } else {\n await sqlite.execute(\n \"INSERT INTO cron_error_tracking_dropbox (id, error_ids) VALUES (1, '[]')\",\n );\n }\n\n // 4. Lọc ra các LỖI MỚI (Có trong hiện tại nhưng chưa có trong lịch sử)\n const newErrors = currentErrors.filter((id) => !previousErrors.includes(id));\n\n // 5. Bắn thông báo nếu có LỖI MỚI\n if (newErrors.length > 0) {\n console.log(\n `⚠️ Found ${newErrors.length} new error(s). Sending ntfy notification...`,\n );\n\n await fetch(`https://ntfy.sh/${NTFY_TOPIC}`, {\n method: \"POST\",\n body:\n `Cảnh báo: Có ${newErrors.length} tài nguyên Dropbox bị lỗi. Kiểm tra ngay.`,\n headers: {\n \"Title\": \"Dropbox Sentinel Alert\",\n \"Priority\": \"high\",\n \"Tags\": \"warning,dropbox\",\n },\n });\n } else {\n console.log(\"✅ Check completed. No new errors found.\");\n }\n\n // 6. Cập nhật lại danh sách lỗi hiện hành vào DB để dành cho lần chạy Cron sau\n await sqlite.execute(\n \"UPDATE cron_error_tracking_dropbox SET error_ids = ? WHERE id = 1\",\n [JSON.stringify(currentErrors)],\n );\n}",[139],"pulls","branches",1,"forks","envVars",{"_154":156,"_157":60},"connections",{"_154":60,"_155":60},"count","unfilledCount",7,"emptyCount",{"_43":138,"_32":139,"_30":140,"_132":-5,"_41":42,"_40":141,"_133":25,"_38":164,"_13":135,"_33":143,"_35":144,"_24":25,"_136":-5,"_161":165,"_27":166},{"_43":131,"_32":28,"_30":31,"_132":-5,"_41":42,"_40":14,"_133":25,"_38":160,"_13":135,"_33":34,"_35":37,"_24":25,"_136":-5,"_161":162,"_27":163},["D",1771557268986],"children",[],[28],["D",1771551576634],[],[139],["D",1771550703765],["D",1789529498250],{"_97":96,"_105":101},{"_97":96,"_98":99,"_100":101,"_18":54,"_102":103,"_104":25},{"_13":86,"_32":87,"_43":42,"_88":44,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":-5,"_94":45,"_95":96},"ctx",{"_79":-5,"_126":205,"_206":207,"_208":209,"_210":25,"_211":25,"_212":25,"_213":124,"_214":-5,"_215":-7,"_216":-7,"_217":60,"_218":25,"_219":25,"_220":-5,"_221":25,"_222":25,"_223":25,"_224":-5},"ENV",{"_176":177,"_178":179,"_180":87,"_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","5015b8df46402d8bba4f485ecc37aec202b0e06b","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"]

Dropbox Sentinel

Thêm tài nguyên

Name

Dropbox Sentinel

Thêm tài nguyên

Name

Diff · v5