Reddit Sentinel

\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 account_admin_sessions (session_id) VALUES (?)\",\n [newSessionId],\n );\n setCookie(c, COOKIE_NAME, newSessionId, {\n path: \"/\",\n secure: true,\n httpOnly: true,\n maxAge: 604800,\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 account_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 account_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. REDDIT ACCOUNT CHECKER LOGIC (OLD.REDDIT.COM SCRAPING)\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 // 1. Tách Username từ URL\n let targetUrl = row.check_url.trim().split(\"?\")[0].replace(/\\/$/, \"\");\n let username = \"\";\n const match = targetUrl.match(/user\\/([^/?]+)/i);\n if (match) username = match[1];\n\n // 2. Ép dùng giao diện CŨ (old.reddit.com) vì giao diện này chứa HTML thuần tĩnh (không cần JS)\n const checkUrl = username\n ? `https://old.reddit.com/user/${username}`\n : targetUrl;\n\n let headers = {\n \"User-Agent\":\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/124.0.0.0 Safari/537.36\",\n \"Accept\":\n \"text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,*/*;q=0.8\",\n \"Accept-Language\": \"en-US,en;q=0.5\",\n };\n\n try {\n const response = await fetch(checkUrl, {\n headers,\n cache: \"no-store\",\n redirect: \"follow\",\n });\n\n const status = response.status;\n const textData = await response.text();\n const textLower = textData.toLowerCase();\n\n // KIỂM TRA LỖI TỪ REDDIT\n if (status === 429) {\n return {\n id: row.id,\n status: \"ERROR\",\n details: \"Lỗi 429: Bị Reddit chặn tạm thời do quét quá nhanh\",\n };\n }\n\n // A. Dấu hiệu tài khoản Bị Ban (Suspended)\n if (\n textLower.includes(\"has been suspended\") ||\n textLower.includes(\"account suspended\") ||\n textLower.includes(\"suspended-user\")\n ) {\n return {\n id: row.id,\n status: \"ERROR\",\n details: \"Tài khoản ĐÃ BỊ BAN (Suspended)\",\n };\n }\n\n // B. Dấu hiệu tài khoản bị xóa / Không có thật (Trang web cũ sẽ báo rõ ràng mã 404 hoặc page not found)\n if (\n status === 404 ||\n textLower.includes(\"page not found\") ||\n textLower.includes(\"nobody on reddit goes by that name\") ||\n textLower.includes(\"this account has been deleted\")\n ) {\n return {\n id: row.id,\n status: \"ERROR\",\n details: \"Tài khoản KHÔNG TỒN TẠI, BỊ XÓA hoặc SHADOWBAN\",\n };\n }\n\n // C. Trạng thái bình thường\n if (status === 200) {\n return {\n id: row.id,\n status: \"OK\",\n details: \"Tài khoản hoạt động bình thường\",\n };\n } else {\n return {\n id: row.id,\n status: \"ERROR\",\n details: `HTTP ${status}: Lỗi không xác định`,\n };\n }\n } catch (e) {\n return {\n id: row.id,\n status: \"ERROR\",\n details: `Lỗi kết nối mạng: ${e.message}`,\n };\n }\n}\n\n// Helpers chuẩn hoá URL\nfunction formatRedditUrl(input) {\n let url = input.trim();\n if (url.startsWith(\"u/\")) {\n return `https://www.reddit.com/user/${url.substring(2)}`;\n }\n if (!url.startsWith(\"http\")) return `https://www.reddit.com/user/${url}`;\n return url;\n}\n\n// ====================================================================\n// 6. API ROUTES\n// ====================================================================\napp.get(\"/api/list\", async (c) => {\n const result = await sqlite.execute(\n \"SELECT * FROM account_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 finalUrl = formatRedditUrl(body.check_url);\n const maxOrderRes = await sqlite.execute(\n \"SELECT MAX(sort_order) as max FROM account_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 account_monitor_final (name, platform, check_url, token_env_key, status, is_paused, sort_order, created_at) VALUES (?, 'Reddit', ?, NULL, 'PENDING', 0, ?, datetime('now'))`,\n [body.name, finalUrl, 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 finalUrl = formatRedditUrl(body.check_url);\n await sqlite.execute(\n `UPDATE account_monitor_final SET name = ?, check_url = ? WHERE id = ?`,\n [body.name, finalUrl, 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 account_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 account_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 account_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 account_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 account_monitor_final\");\n const checkPromises = result.rows.map((row) => checkSingleAccount(row));\n const results = await Promise.all(checkPromises);\n const currentErrors = [];\n const updates = [];\n\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 account_monitor_final SET status = ?, details = ?, last_check = datetime('now') WHERE id = ?`,\n [res.status, res.details, res.id],\n );\n });\n\n await Promise.all(updatePromises);\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 Reddit Sentinel Monitor\n \n \n \n \n \n \n \n \n

\n Reddit Sentinel Monitor\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 function (req: Request): Response | Promise {\n return app.fetch(req);\n}","deleted","label",[129],"3b47741e-634a-4664-b074-6b79347078b1","cron.ts","019ef587-5e22-7713-a5f7-a00be4fb7a41",["D",1782237728044],3,"interval","import sqlite from \"https://esm.town/v/std/db/main.ts\";\n\n// --- CẤU HÌNH ---\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 Cron Check...\");\n\n const ADMIN_PASS = Deno.env.get(\"ADMIN_PASS\");\n\n // 1. Gọi API Check-All từ Ứng dụng Chính\n const response = await fetch(VAL_MAIN_API_URL, {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${ADMIN_PASS}`,\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).\",\n );\n } else {\n console.error(\"❌ Failed to trigger check:\", response.statusText);\n }\n return;\n }\n\n const data = await response.json();\n const currentErrors = data.current_errors || [];\n\n // Lấy chi tiết text báo lỗi để gửi Ntfy\n const fullUpdates = data.updates || [];\n const errorDetails = fullUpdates.filter((u) => currentErrors.includes(u.id));\n\n // 2. Lấy danh sách lỗi cũ từ DB để so sánh (tránh báo trùng)\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS cron_error_tracking_account (\n id INTEGER PRIMARY KEY,\n error_ids TEXT\n )\n `);\n\n const prevRes = await sqlite.execute(\n \"SELECT error_ids FROM cron_error_tracking_account 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_account (id, error_ids) VALUES (1, '[]')\",\n );\n }\n\n // 3. Tìm các lỗi MỚI xuất hiện\n const newErrors = currentErrors.filter((id) => !previousErrors.includes(id));\n\n // 4. Gửi thông báo ntfy nếu có lỗi mới\n if (newErrors.length > 0) {\n console.log(\n `⚠️ Found ${newErrors.length} new errors. Sending notification...`,\n );\n\n // Gộp tên lỗi (Bị Xóa hay Bị Ban) để bắn thông báo\n const newErrorItems = errorDetails.filter((u) => newErrors.includes(u.id));\n const msgBody = newErrorItems.map((item) => `- Sự cố: ${item.details}`)\n .join(\"\\n\");\n\n await fetch(`https://ntfy.sh/${NTFY_TOPIC}`, {\n method: \"POST\",\n body: `Có ${newErrors.length} tài khoản Reddit gặp vấn đề:\\n${msgBody}`,\n headers: {\n \"Title\": \"Reddit Sentinel Alert\",\n \"Priority\": \"high\",\n \"Tags\": \"warning\",\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_account SET error_ids = ? WHERE id = 1\",\n [JSON.stringify(currentErrors)],\n );\n}",[147],"pulls",1,"forks","envVars",{"_161":138,"_163":53},"connections",{"_161":53,"_162":53},"count","unfilledCount","emptyCount",{"_20":146,"_13":147,"_130":148,"_132":-5,"_133":21,"_134":30,"_136":115,"_22":170,"_29":150,"_139":151,"_141":152,"_143":40,"_144":-5,"_167":171,"_94":172},{"_20":128,"_13":129,"_130":131,"_132":-5,"_133":21,"_134":135,"_136":115,"_22":166,"_29":138,"_139":140,"_141":142,"_143":40,"_144":-5,"_167":168,"_94":169},["D",1782236883997],"children",[],[129],["D",1782237728044],[],[147],["D",1782235749838],["D",1789494036282],{"_11":12,"_92":88},{"_11":12,"_85":86,"_87":88,"_46":47,"_89":90,"_91":40},{"_29":30,"_13":26,"_20":21,"_27":28,"_31":32,"_33":34,"_79":42,"_80":81,"_82":55,"_83":14,"_84":12},"ctx",{"_72":-5,"_117":211,"_212":213,"_214":215,"_216":40,"_217":40,"_218":40,"_219":115,"_220":-5,"_221":-7,"_222":-7,"_223":53,"_224":40,"_225":40,"_226":-5,"_227":40,"_228":40,"_229":40,"_230":-5},"ENV",{"_182":183,"_184":185,"_186":26,"_187":188,"_189":190,"_191":192,"_193":194,"_195":196,"_197":198,"_199":200,"_201":202,"_203":204,"_205":206,"_207":208,"_209":210},"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"]

Reddit Sentinel

\n Reddit Sentinel Monitor\n

Thêm tài khoản Reddit

Account Name

Branches1

Branches
1