\n \n

Workspace 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 workspace_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 workspace_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 workspace_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\n// ====================================================================\nasync function checkSingleAccount(row) {\n if (row.is_paused) {\n return { id: row.id, status: \"PAUSED\", details: \"Đang ngừng theo dõi\" };\n }\n\n let headers = {\n \"User-Agent\": \"ValTown-Sentinel-Monitor/2.0\",\n \"Content-Type\": \"application/json\",\n };\n\n if (row.token_env_key && Deno.env.get(row.token_env_key)) {\n headers[\"Authorization\"] = `Bearer ${Deno.env.get(row.token_env_key)}`;\n }\n\n if (row.platform === \"Notion\") {\n // Version ổn định gần nhất của Notion\n headers[\"Notion-Version\"] = \"2022-06-28\";\n }\n\n try {\n const response = await fetch(row.check_url, {\n headers,\n cache: \"no-store\",\n redirect: \"manual\",\n });\n\n if (!response.ok || response.status >= 300) {\n return {\n id: row.id,\n status: \"ERROR\",\n details:\n `HTTP ${response.status}: Lỗi xác thực hoặc không tìm thấy (${response.statusText})`,\n };\n }\n\n const textData = await response.text();\n\n try {\n const jsonData = JSON.parse(textData);\n\n if (\n jsonData.object === \"error\" || jsonData.error ||\n jsonData.message === \"Not Found\"\n ) {\n return {\n id: row.id,\n status: \"ERROR\",\n details: `Lỗi API: ${\n jsonData.message || jsonData.error || \"Không xác định\"\n }`,\n };\n }\n\n if (jsonData.statusCode && jsonData.statusCode >= 400) {\n return {\n id: row.id,\n status: \"ERROR\",\n details: `Coda API Lỗi: ${\n jsonData.statusMessage || \"Không xác định\"\n }`,\n };\n }\n\n return {\n id: row.id,\n status: \"OK\",\n details: \"Tài khoản/Workspace hoạt động bình thường\",\n };\n } catch (e) {\n return {\n id: row.id,\n status: \"OK\",\n details: \"Liên kết khả dụng (Non-JSON response)\",\n };\n }\n } catch (e) {\n return {\n id: row.id,\n status: \"ERROR\",\n details: `Không thể kết nối: ${e.message}`,\n };\n }\n}\n\n// ====================================================================\n// 6. API ROUTES\n// ====================================================================\napp.get(\"/api/list\", async (c) => {\n const result = await sqlite.execute(\n \"SELECT * FROM workspace_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 tokenEnv = body.token_env_key && body.token_env_key.trim() !== \"\"\n ? body.token_env_key\n : null;\n const maxOrderRes = await sqlite.execute(\n \"SELECT MAX(sort_order) as max FROM workspace_monitor_final\",\n );\n const nextOrder = (maxOrderRes.rows[0].max !== null)\n ? maxOrderRes.rows[0].max + 1\n : 0;\n\n await sqlite.execute(\n `INSERT INTO workspace_monitor_final (name, platform, check_url, token_env_key, status, is_paused, sort_order, created_at) VALUES (?, ?, ?, ?, ?, 0, ?, datetime('now'))`,\n [body.name, body.platform, body.check_url, tokenEnv, \"PENDING\", nextOrder],\n );\n return c.json({ success: true });\n});\n\napp.post(\"/api/update\", async (c) => {\n const body = await c.req.json();\n const tokenEnv = body.token_env_key && body.token_env_key.trim() !== \"\"\n ? body.token_env_key\n : null;\n await sqlite.execute(\n `UPDATE workspace_monitor_final SET name = ?, platform = ?, check_url = ?, token_env_key = ? WHERE id = ?`,\n [body.name, body.platform, body.check_url, tokenEnv, 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 const promises = body.order.map((id, i) =>\n sqlite.execute(\n \"UPDATE workspace_monitor_final SET sort_order = ? WHERE id = ?\",\n [i, id],\n )\n );\n await Promise.all(promises);\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 workspace_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 workspace_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 workspace_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 workspace_monitor_final\");\n const checkPromises = result.rows.map((row) => checkSingleAccount(row));\n const results = await Promise.all(checkPromises);\n\n const currentErrors = [];\n const updates = [];\n const updatePromises = results.map((res) => {\n updates.push(res);\n if (res.status === \"ERROR\") currentErrors.push(res.id);\n return sqlite.execute(\n `UPDATE workspace_monitor_final SET status = ?, details = ?, last_check = datetime('now') WHERE id = ?`,\n [res.status, res.details, res.id],\n );\n });\n await Promise.all(updatePromises);\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 Workspace Sentinel Monitor\n \n \n \n \n \n \n \n \n

\n Workspace Sentinel\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",[103],"permalink","https://www.val.town/x/varina_lab/Account_2_Sentinel/code/main.ts","extension","actionData","errors"]

Workspace Sentinel

\n Workspace Sentinel\n

Thêm Workspace

Account Name