\n \n

Dropbox 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 DB.init();\n const newSessionId = crypto.randomUUID();\n await sqlite.execute(\n \"INSERT INTO dropbox_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 DB.init();\n await sqlite.execute(\n \"DELETE FROM dropbox_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 dropbox_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. DROPBOX LOGIC HELPERS\n// ====================================================================\nconst TokenManager = {\n promises: {},\n async getAccessToken(refreshToken) {\n if (!refreshToken) return null;\n if (this.promises[refreshToken]) return this.promises[refreshToken];\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 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 ${btoa(`${appKey}:${appSecret}`)}`,\n },\n body: new URLSearchParams({\n grant_type: \"refresh_token\",\n refresh_token: refreshToken,\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 async checkResource(row) {\n if (row.is_paused) {\n 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;\n const isSystemToken = !row.access_token && !!systemRefreshToken;\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 let token;\n try {\n token = await TokenManager.getAccessToken(activeRefreshToken);\n } catch (err) {\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 { method: \"POST\", headers: { \"Authorization\": `Bearer ${token}` } },\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 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 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// 6. API ROUTES\n// ====================================================================\napp.get(\"/api/list\", async (c) => c.json(await DB.getAll()));\napp.post(\"/api/add\", async (c) => {\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});\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});\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});\napp.post(\"/api/toggle-pause\", async (c) => {\n await DB.togglePause((await c.req.json()).id);\n return c.json({ success: true });\n});\napp.post(\"/api/delete\", async (c) => {\n await DB.delete((await c.req.json()).id);\n return c.json({ success: true });\n});\napp.post(\"/api/check-all\", async (c) => {\n try {\n const rows = await DB.getAll();\n const results = await Promise.all(\n rows.map((row) => DropboxAPI.checkResource(row)),\n );\n const currentErrors = [];\n const updates = [];\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 return c.json({ success: false, error: err.message }, 500);\n }\n});\n\n// ====================================================================\n// 7. UI TEMPLATE & ROUTE\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

\n Dropbox Sentinel\n

\n \n \n \n

\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}","deleted","label",[118],"46856056-3960-11f1-9546-42b51c65c3df","cron.ts","019c78a6-8114-76d5-a8a9-8712489fefc3",["D",1776322108784],6,"interval","import sqlite from \"https://esm.town/v/std/db/main.ts\";\n\n// ====================================================================\n// CẤU HÌNH CRON JOB\nconst VAL_MAIN_API_URL = `${Deno.env.get(\"VAL_MAIN_API_URL\")}/api/check-all`;\nconst NTFY_TOPIC = Deno.env.get(\"NTFY_TOPIC\");\n\nexport default async function (interval: Interval) {\n console.log(\"🕒 Starting Dropbox Sentinel Cron Check...\");\n\n // LẤY MẬT KHẨU TỪ ENVIRONMENT ĐỂ MỞ CỬA API\n const ADMIN_PASS = Deno.env.get(\"ADMIN_PASS\");\n\n // 1. Gọi API quét toàn bộ tài nguyên trên Val Chính CÓ KÈM AUTHORIZATION HEADER\n const response = await fetch(VAL_MAIN_API_URL, {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${ADMIN_PASS}`, // <--- Điểm bảo mật\n },\n });\n\n if (!response.ok) {\n if (response.status === 401) {\n console.error(\n \"❌ Lỗi 401: Cron Job không được cấp quyền (Sai ADMIN_PASS). Hãy kiểm tra lại biến môi trường.\",\n );\n } else {\n console.error(\"❌ Failed to trigger check API:\", response.statusText);\n }\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\n let previousErrors = [];\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}",[136],"pulls",1,"forks","envVars",{"_150":152,"_153":51},"connections",{"_150":51,"_151":51},"count","unfilledCount",7,"emptyCount",{"_20":135,"_13":136,"_119":137,"_121":-5,"_122":21,"_123":30,"_125":110,"_22":160,"_29":139,"_128":140,"_130":141,"_132":38,"_133":-5,"_157":161,"_91":162},{"_20":117,"_13":118,"_119":120,"_121":-5,"_122":21,"_123":124,"_125":110,"_22":156,"_29":127,"_128":129,"_130":131,"_132":38,"_133":-5,"_157":158,"_91":159},["D",1772186979561],"children",[],[118],["D",1776322108784],[],[136],["D",1771550703765],["D",1789442454549],{"_11":12,"_89":85},{"_11":12,"_82":83,"_84":85,"_44":45,"_86":87,"_88":38},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":-5,"_32":-5,"_77":-5,"_78":-5,"_79":-5,"_80":14,"_81":12},"ctx",{"_70":-5,"_112":201,"_202":203,"_204":205,"_206":38,"_207":38,"_208":38,"_209":110,"_210":-5,"_211":-7,"_212":-7,"_213":51,"_214":38,"_215":38,"_216":-5,"_217":38,"_218":38,"_219":38,"_220":-5},"ENV",{"_172":173,"_174":175,"_176":26,"_177":178,"_179":180,"_181":182,"_183":184,"_185":186,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200},"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"]

Dropbox Sentinel

\n Dropbox Sentinel\n

Thêm tài nguyên

Name

Branches1

Branches
1