${title}

\n ${content}\n

\n \n\n`, { headers: { \"Content-Type\": \"text/html;charset=utf-8\" } });\n}\n\n// ══════════════════════════════════════════════════════\n// PAGES\n// ══════════════════════════════════════════════════════\n\n// HOME\nasync function pageDashboard() {\n const s = await getStats();\n const rate = s.total > 0 ? Math.round((Number(s.success) / Number(s.total)) * 100) : 0;\n const recent = await sqlite.execute(\n \"SELECT * FROM ebay_registrations ORDER BY createdAt DESC LIMIT 5\"\n );\n const playbookStatus = Number(s.playbook) > 0\n ? `✓ Đã học (${s.playbook} bước)`\n : `✗ Chưa học`;\n\n const recentRows = recent.rows.length > 0\n ? recent.rows.map((r: any) => `\n \n ${r.firstName} ${r.lastName}\n ${r.businessName || \"—\"}\n ${r.email}\n ${r.status}\n ${r.createdAt?.slice(0,16) || \"\"}\n `).join(\"\")\n : `Chưa có dữ liệu`;\n\n return html(`\n

🏠 Tổng quan

Trạng thái hệ thống đăng ký tài khoản eBay Business

\n\n

Tổng tài khoản

${s.total}

Thành công

${s.success}

Thất bại

${s.failed}

Đang chờ

${s.pending}

Tỷ lệ thành công

${rate}%

\n\n

📊 Tỷ lệ thành công

\n ${s.success}/${s.total}\n

Progress

\n ✅ Thành công${s.success}\n

\n ❌ Thất bại${s.failed}\n

\n ⏳ Pending${s.pending}\n

\n\n

🤖 Trạng thái hệ thống

\n 📖 AI Playbook${playbookStatus}\n

\n 📋 Logs\n ${s.logs} entries\n

\n ${Number(s.playbook) === 0\n ? `⚠️ Cần học playbook trước`\n : `🚀 Chạy Bot ngay`}\n 📖 Xem Playbook\n

\n\n

🕐 Đăng ký gần đây

\n Xem tất cả →\n

\n \n \n \n \n ${recentRows}\n

Tên	Doanh nghiệp	Email	Trạng thái	Thời gian

`);\n}\n\n// ACCOUNTS\nasync function pageAccounts() {\n const rows = await sqlite.execute(\n \"SELECT * FROM ebay_registrations ORDER BY createdAt DESC LIMIT 100\"\n );\n const tableRows = rows.rows.length > 0\n ? rows.rows.map((r: any) => `\n \n ${r.firstName || \"\"} ${r.lastName || \"\"}\n ${r.businessName || \"—\"}\n ${r.email}\n ${r.ebayUsername || \"—\"}\n ${r.status}\n ${r.errorMessage ? r.errorMessage.slice(0,40)+\"...\" : \"—\"}\n ${r.createdAt?.slice(0,16) || \"\"}\n `).join(\"\")\n : `

📭

Chưa có tài khoản nào được đăng ký

`;\n\n return html(`\n

👥 Tài khoản đã đăng ký

\n \n

Danh sách ${rows.rows.length} tài khoản gần nhất

\n \n \n \n \n \n ${tableRows}\n

Họ tên	Doanh nghiệp	Email	Username eBay	Trạng thái	Lỗi	Thời gian

`);\n}\n\n// PLAYBOOK - trang xem + chỉnh sửa\nasync function pagePlaybook(editId?: string) {\n const steps = await sqlite.execute(\"SELECT * FROM ebay_playbook ORDER BY stepOrder\");\n\n const actionOptions = [\"goto\",\"click\",\"fill\",\"check_result\",\"wait\",\"select\",\"hover\",\"scroll\",\"keyboard\"]\n .map(a => ``).join(\"\");\n const fieldKeyOptions = [\"\",\"businessName\",\"firstName\",\"lastName\",\"email\",\"username\",\"password\",\"phone\",\"address\",\"city\",\"state\",\"zip\"]\n .map(k => ``).join(\"\");\n\n const stepsHtml = steps.rows.length > 0\n ? steps.rows.map((r: any) => {\n const isEditing = editId === String(r.id);\n if (isEditing) {\n // Form chỉnh sửa inline\n return `\n

${r.stepOrder}

\n ✏️ Đang chỉnh sửa bước ${r.stepOrder}\n ✕ Hủy\n

\n \n

\n Action *\n \n

\n Field Key (cho fill)\n \n

\n Mô tả *\n \n

\n CSS Selector\n \n

\n Value (cho goto/fill cố định)\n \n

\n Thứ tự (stepOrder)\n \n

\n Chờ sau bước (ms)\n \n

\n \n Hủy\n

`;\n }\n // Hiển thị bình thường với nút Edit/Xóa\n return `\n

⠿

${r.stepOrder}

\n ${r.action}\n

${r.description}

\n ${r.fieldKey ? `

🔑 field: ${r.fieldKey}

` : \"\"}\n ${r.value ? `

📌 value: ${r.value.slice(0,50)}

` : \"\"}\n

\n ${r.selector ? `

${r.selector}

` : '

'}\n

${r.waitMs||500}ms

\n ✏️\n \n

`;\n }).join(\"\")\n : `

📭

Chưa có playbook. Hãy chạy AI Learn hoặc thêm bước thủ công.

\n 🤖 Chạy AI Learn

`;\n\n return html(`\n

📖 Playbook Editor

\n ${steps.rows.length > 0 ? `\n ` : \"\"}\n 🤖 AI Learn lại\n

\n ${steps.rows.length > 0\n ? `${steps.rows.length} bước — Click ✏️ để sửa, kéo ⠿ để sắp xếp lại thứ tự`\n : \"Chưa có playbook\"}\n

\n\n

\n\n \n

\n ${steps.rows.length > 0 ? `\n

\n 💡 Click ✏️ để sửa từng bước · Kéo ⠿ để đổi thứ tự · Click 🗑️ để xóa\n

` : \"\"}\n

🔢 Các bước (${steps.rows.length})

\n Drag & drop để sắp xếp\n

${stepsHtml}

\n\n \n

➕ Thêm bước mới

\n Action *\n \n

\n Mô tả *\n \n

\n CSS Selector\n \n

\n Field Key (nếu là fill)\n \n

\n Value cố định (nếu goto/fill)\n \n

\n Thứ tự\n \n

\n Chờ (ms)\n \n

\n \n

\n\n \n

📚 Chú thích Field Key

businessName — Tên công ty

firstName — Tên

lastName — Họ

email — Email @duck.com

username — Tự tạo từ email

password — Mật khẩu

phone — Số điện thoại

\n\n \n\n `);\n}\n\n// RUN PAGE\nasync function pageRun() {\n const playbookCount = await sqlite.execute(\"SELECT COUNT(*) as n FROM ebay_playbook\");\n const hasPlaybook = Number(playbookCount.rows[0]?.n ?? 0) > 0;\n\n return html(`\n

🚀 Chạy Bot

Điều khiển AI Agent đăng ký tài khoản eBay Business

\n\n ${!hasPlaybook ? `\n

\n ⚠️ Chưa có playbook! Bạn cần chạy AI Learn trước để AI học quy trình đăng ký.\n

` : `\n

\n ✅ Playbook đã sẵn sàng! Bạn có thể chạy AI Replay ngay.\n

`}\n\n

\n\n \n

🧠 Phase 1 — AI Learn

\n ${hasPlaybook ? 'Đã học' : 'Chưa học'}\n

\n AI Agent sẽ tự mở trình duyệt, khám phá form đăng ký eBay, \n học từng bước và lưu playbook vào database.\n

\n Chạy 1 lần duy nhất hoặc khi eBay thay đổi giao diện.\n

\n            1. Mở trang eBay Business Registration
\n            2. AI phân tích HTML, tìm các trường form
\n            3. Điền dữ liệu test, ghi lại selector
\n            4. Lưu playbook vào SQLite\n          

\n \n

\n\n \n

🔁 Phase 2 — AI Replay

\n ${hasPlaybook ? 'Sẵn sàng' : 'Cần playbook'}\n

\n Đọc playbook đã học, tự động đăng ký tất cả tài khoản \n từ Google Sheets. Mỗi tài khoản được cấp 1 email @duck.com riêng.\n

\n            1. Đọc danh sách từ Google Sheets
\n            2. Tạo email @duck.com cho mỗi tài khoản
\n            3. Replay playbook với dữ liệu thực
\n            4. Lưu kết quả vào database\n          

\n \n

\n\n \n

📡 Hướng dẫn sử dụng

Bước 1

Nhấn AI Learn để bot tự học quy trình đăng ký từ eBay

Bước 2

Kiểm tra Playbook để xác nhận AI đã học đúng các bước

Bước 3

Nhấn AI Replay để tự động đăng ký hàng loạt

`);\n}\n\n// LOGS PAGE\nasync function pageLogs() {\n const logs = await sqlite.execute(\n \"SELECT * FROM job_logs ORDER BY createdAt DESC LIMIT 200\"\n );\n const logLines = logs.rows.length > 0\n ? logs.rows.map((r: any) => {\n const level = r.level || \"info\";\n const cls = level === \"error\" ? \"error\" : level === \"warn\" ? \"warn\" : level === \"success\" ? \"success\" : \"\";\n return `

\n ${r.createdAt?.slice(11,19) || \"\"}\n [${(r.jobType || \"sys\").toUpperCase()}]\n ${r.message}\n

`;\n }).join(\"\")\n : `

Chưa có logs

`;\n\n return html(`\n

📋 Logs hệ thống

Auto-refresh mỗi 5s\n

\n \n

${logs.rows.length} entries gần nhất

${logLines}

`);\n}\n\n// LIVE VIEW PAGE\nasync function pageLive(sessionId?: string) {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS browser_sessions (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n sessionId TEXT NOT NULL UNIQUE,\n liveViewUrl TEXT NOT NULL,\n cdpWsUrl TEXT NOT NULL,\n label TEXT DEFAULT 'Manual Session',\n status TEXT DEFAULT 'active',\n createdAt TEXT DEFAULT (datetime('now')),\n closedAt TEXT\n )\n `);\n\n const sessions = await sqlite.execute(\n \"SELECT * FROM browser_sessions ORDER BY createdAt DESC LIMIT 20\"\n );\n const active = sessions.rows.filter((r: any) => r.status === \"active\");\n const closed = sessions.rows.filter((r: any) => r.status === \"closed\");\n\n // Nếu có sessionId trong query → hiển thị live view\n let viewedSession: any = null;\n if (sessionId) {\n const found = sessions.rows.find((r: any) => r.sessionId === sessionId);\n if (found) viewedSession = found;\n } else if (active.length > 0) {\n viewedSession = active[0]; // auto chọn session active đầu tiên\n }\n\n const sessionRows = sessions.rows.length > 0\n ? sessions.rows.map((r: any) => {\n const isActive = r.status === \"active\";\n const isViewing = viewedSession?.sessionId === r.sessionId;\n return `\n \n

\n ${r.label || 'Session'}\n

\n \n ${r.sessionId?.slice(0,16)}...\n ${isActive ? 'active' : 'closed'}\n ${r.createdAt?.slice(11,19) || ''}\n \n

\n ${isActive ? `\n \n ${isViewing ? '👁️ Đang xem' : '👁️ Xem'}\n \n ↗️\n \n ` : `${r.closedAt?.slice(11,19) || 'closed'}`}\n

\n \n `;\n }).join(\"\")\n : `

📡

Chưa có session nào. Tạo session mới để bắt đầu.

`;\n\n const liveViewHtml = viewedSession\n ? `

\n ${viewedSession.label}\n ${viewedSession.sessionId?.slice(0,20)}...\n

\n \n — fps\n \n \n ↗️ Mở Live View\n \n

\n\n \n

\n \n \n

Live\n

\n\n

\n 🔗 ${viewedSession.sessionId?.slice(0,16)}...\n ⏰ ${viewedSession.createdAt?.slice(11,19)}\n \n Cập nhật mỗi\n \n \n

`\n : `

📡

Chưa có Live Session

Tạo session mới hoặc chạy agentLearn.ts / agentReplay.ts để xem browser trực tiếp

\n \n

`;\n\n return html(`\n

🔴 Live Browser View

\n \n

${active.length} session đang active\n \n \n ${active.length > 0 ? `\n ` : \"\"}\n

Theo dõi browser đang chạy theo thời gian thực

\n\n

\n\n \n

\n ${viewedSession\n ? `

Live: ${viewedSession.label}`\n : `📺 Chưa có session`}\n

\n ${viewedSession ? `⟳ Reload` : \"\"}\n

\n ${liveViewHtml}\n

\n\n \n

📋 Sessions (${sessions.rows.length})

\n ${active.length} active\n

\n \n \n \n \n ${sessionRows}\n

Tên	ID	Trạng thái	Giờ	Thao tác

\n\n \n

💡 Cách sử dụng

🤖 Theo dõi bot đang chạy

\n Khi chạy agentLearn.ts hoặc agentReplay.ts, \n session sẽ tự động xuất hiện ở đây.\n

🖱️ Session thủ công

\n Nhấn Tạo session để mở browser trống, \n sau đó điều khiển từ code.\n

↗️ Mở tab mới

\n Click ↗️ để xem live view trong tab riêng \n (không bị giới hạn bởi iframe).\n

\n ⚠️ Session tự động hết hạn sau 30 phút không hoạt động\n

\n\n \n\n `);\n}\n\n// ══════════════════════════════════════════════════════\n// INSPECTOR PAGE — Xem screenshot + HTML từng bước Learn\n// ══════════════════════════════════════════════════════\nasync function pageInspector(stepNum?: number) {\n // Đảm bảo bảng tồn tại\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS debug_steps (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n sessionId TEXT NOT NULL,\n stepNum INTEGER NOT NULL,\n stepName TEXT NOT NULL,\n screenshotB64 TEXT,\n pageUrl TEXT,\n pageTitle TEXT,\n htmlSnippet TEXT,\n notes TEXT,\n success INTEGER DEFAULT 0,\n createdAt TEXT DEFAULT (datetime('now'))\n )\n `);\n\n const steps = await sqlite.execute(\n \"SELECT id, sessionId, stepNum, stepName, pageUrl, pageTitle, notes, success, createdAt FROM debug_steps ORDER BY id\"\n );\n\n // Lấy chi tiết 1 step nếu có\n let detailStep: any = null;\n if (stepNum !== undefined) {\n const found = await sqlite.execute({\n sql: \"SELECT * FROM debug_steps WHERE id = ?\",\n args: [stepNum],\n });\n if (found.rows.length > 0) detailStep = found.rows[0];\n } else if (steps.rows.length > 0) {\n // Mặc định xem step cuối\n const lastId = (steps.rows[steps.rows.length - 1] as any).id;\n const found = await sqlite.execute({ sql: \"SELECT * FROM debug_steps WHERE id=?\", args: [lastId] });\n if (found.rows.length > 0) detailStep = found.rows[0];\n }\n\n const stepList = steps.rows.length > 0\n ? steps.rows.map((r: any) => {\n const isSelected = detailStep && detailStep.id === r.id;\n const icon = r.success ? \"✅\" : \"❌\";\n return `\n \n ${icon}\n

\n [${r.stepNum}] ${r.stepName}\n

\n ${r.notes || r.pageTitle || '—'}\n

\n \n ${r.createdAt?.slice(11,19)||''}\n \n `;\n }).join(\"\")\n : `

📭

Chưa có debug steps.
Chạy agentLearn.ts trước.

`;\n\n // Panel chi tiết\n const detailHtml = detailStep\n ? `\n

\n ${detailStep.success ? '✅' : '❌'}\n

[Step ${detailStep.stepNum}] ${detailStep.stepName}

${detailStep.createdAt?.slice(0,19)||''}

\n\n \n

URL

${detailStep.pageUrl||'—'}

Title

${detailStep.pageTitle||'—'}

\n ${detailStep.notes ? `\n

\n 📝 ${detailStep.notes}\n

` : ''}\n

\n\n \n ${detailStep.screenshotB64 ? `\n

📸 SCREENSHOT

\n $\"Click$ \n

\n Click ảnh để zoom · ${Math.round(detailStep.screenshotB64.length * 0.75 / 1024)}KB\n

` : `\n

\n Không có screenshot\n

`}\n\n \n ${detailStep.htmlSnippet ? `\n

🔍 HTML SNIPPET

\n \n

${detailStep.htmlSnippet.replace(//g,'>')}

\n ` : ''}\n `\n : `

🔬

Chọn 1 step để xem chi tiết

Screenshot và HTML thực tế từ browser

`;\n\n return html(`\n

🔬 Step Inspector

\n \n 🧠 Chạy AI Learn\n

\n ${steps.rows.length > 0\n ? `${steps.rows.length} steps được ghi lại — Click từng bước để xem screenshot và HTML thực tế`\n : 'Chạy agentLearn.ts để ghi lại từng bước với screenshot'}\n

\n\n ${steps.rows.length > 0 ? `\n

\n 💡 Mỗi bước có screenshot thực tế và HTML snippet để bạn biết chính xác trang đang hiển thị gì — dùng để tìm selector đúng\n

` : ''}\n\n

\n\n \n

📋 Các bước (${steps.rows.length})

\n ${stepList}\n

\n\n \n

\n ${detailStep ? `[Step ${detailStep.stepNum}] ${detailStep.stepName}` : '🔍 Chi tiết bước'}\n

\n ${detailStep ? `\n

\n ← Trước\n Sau →\n

` : ''}\n

\n ${detailHtml}\n

\n\n

`);\n}\n\n// ── Ghi log ───────────────────────────────────────────\nasync function addLog(jobType: string, message: string, level = \"info\") {\n await sqlite.execute({\n sql: \"INSERT INTO job_logs (jobType, message, level) VALUES (?,?,?)\",\n args: [jobType, message, level],\n });\n}\n\n// ══════════════════════════════════════════════════════\n// HTTP HANDLER\n// ══════════════════════════════════════════════════════\nexport default async function handler(req: Request): Promise {\n await ensureTables();\n\n const url = new URL(req.url);\n const path = url.pathname;\n\n // ── GET routes ──────────────────────────────────────\n if (req.method === \"GET\") {\n if (path === \"/\" || path === \"\") return pageDashboard();\n if (path === \"/accounts\") return pageAccounts();\n if (path === \"/playbook\") {\n const editId = url.searchParams.get(\"edit\") || undefined;\n return pagePlaybook(editId);\n }\n if (path === \"/run\") return pageRun();\n if (path === \"/live\") {\n const sessionParam = url.searchParams.get(\"session\") || undefined;\n return pageLive(sessionParam);\n }\n if (path === \"/logs\") return pageLogs();\n if (path === \"/inspector\") {\n const stepParam = url.searchParams.get(\"step\");\n return pageInspector(stepParam ? parseInt(stepParam) : undefined);\n }\n\n // JSON API\n // Test Apps Script webhook\n if (path === \"/api/test-sheets\") {\n const scriptUrl = \"https://script.google.com/macros/s/AKfycbyi5GoKGwII8OrSqxZ0zUQfUvA4dMbWTsp9-7p-PmPybl3s2ypdC52Fop71OWxNQNemsg/exec\";\n if (!scriptUrl) {\n return new Response(JSON.stringify({ ok: false, error: \"GOOGLE_APPS_SCRIPT_URL chưa cấu hình\" }), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n try {\n const resp = await fetch(scriptUrl, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ rowIndex: 2, email: \"test@duck.com\", sheetName: \"Sheet1\", mailColumn: \"S\" }),\n redirect: \"follow\",\n redirect: \"follow\",\n });\n const text = await resp.text();\n let result: any;\n try { result = JSON.parse(text); } catch { result = { raw: text }; }\n return new Response(JSON.stringify({ ok: true, response: result }), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n } catch (e) {\n return new Response(JSON.stringify({ ok: false, error: (e as Error).message }), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n }\n }\n\n\n // ── API đọc & debug dữ liệu Google Sheets ────────\n if (path === \"/api/sheets\") {\n const SHEETS_CSV_URL = \"https://docs.google.com/spreadsheets/d/e/2PACX-1vRnJi0p7fc3CEsGeV2axPwEo8mqZm3yYBIKQj2Ly70KV4WGScHXx7TjyE30-EaI2itFbuABgFgCZSog/pub?gid=169016620&single=true&output=csv\";\n const MAIL_COL = 18; // cột S (0-indexed)\n\n function parseCSVLine(line: string): string[] {\n const r: string[] = []; let cur = \"\"; let inQ = false;\n for (const c of line) {\n if (c === '\"') inQ = !inQ;\n else if (c === \",\" && !inQ) { r.push(cur.trim()); cur = \"\"; }\n else cur += c;\n }\n r.push(cur.trim());\n return r;\n }\n\n try {\n const res = await fetch(SHEETS_CSV_URL, { redirect: \"follow\" });\n const csv = await res.text();\n\n if (csv.trim().startsWith(\" Share > Publish to web > chọn CSV\",\n preview: csv.slice(0, 300),\n }, null, 2), { headers: { \"Content-Type\": \"application/json\" } });\n }\n\n const lines = csv.trim().split(\"\\n\");\n const headers = parseCSVLine(lines[0]);\n const rows: any[] = [];\n let pending = 0; let done = 0;\n\n for (let i = 1; i < lines.length; i++) {\n const line = lines[i].replace(/\\r$/, \"\");\n if (!line.trim()) continue;\n const v = parseCSVLine(line);\n const get = (idx: number) => v[idx]?.trim() || \"\";\n if (!get(0) && !get(7)) continue;\n\n const email = get(MAIL_COL);\n if (email) done++; else pending++;\n\n rows.push({\n row: i + 1,\n businessName: get(0),\n ein: get(1),\n street: get(2),\n city: get(12),\n state: get(13),\n zip: get(14),\n firstName: get(7),\n lastName: get(8),\n ssn_last4: \"****\" + get(9).replace(/\\D/g, \"\").slice(-4),\n dob: get(10),\n email: email || null,\n hasEmail: !!email,\n });\n }\n\n return new Response(JSON.stringify({\n ok: true,\n totalRows: rows.length,\n done,\n pending,\n columns: headers.map((h, i) => ({ col: String.fromCharCode(65 + i), idx: i, name: h })),\n rows,\n }, null, 2), { headers: { \"Content-Type\": \"application/json\" } });\n\n } catch (e: any) {\n return new Response(JSON.stringify({ ok: false, error: e.message }), {\n headers: { \"Content-Type\": \"application/json\" }\n });\n }\n }\n\n // ── Screenshot GET endpoint (fix: was in POST block) ──\n if (path === \"/live/screenshot\") {\n const screenshotSessionId = url.searchParams.get(\"session\") || \"\";\n if (!screenshotSessionId) return new Response(\"no session\", { status: 400 });\n try {\n const sRow = await sqlite.execute({\n sql: \"SELECT cdpWsUrl FROM browser_sessions WHERE sessionId=? AND status='active'\",\n args: [screenshotSessionId],\n });\n if (!sRow.rows[0]) return new Response(\"session not found\", { status: 404 });\n const cdpWsUrl = (sRow.rows[0] as any).cdpWsUrl as string;\n const wsUrl = new URL(cdpWsUrl.replace(\"wss://\", \"https://\").replace(\"/browser/cdp\", \"/browser/screenshot\"));\n const resp = await fetch(wsUrl.toString(), { headers: { \"Accept\": \"image/png\" } });\n if (resp.ok) {\n const buf = await resp.arrayBuffer();\n return new Response(buf, { headers: { \"Content-Type\": \"image/png\", \"Cache-Control\": \"no-store\" } });\n }\n const screenshotData = await captureScreenshotCDP(cdpWsUrl);\n if (screenshotData) {\n const bytes = Uint8Array.from(atob(screenshotData), c => c.charCodeAt(0));\n return new Response(bytes.buffer, { headers: { \"Content-Type\": \"image/png\", \"Cache-Control\": \"no-store\" } });\n }\n return new Response(\"screenshot failed\", { status: 502 });\n } catch (e: any) {\n return new Response(`error: ${e.message}`, { status: 500 });\n }\n }\n\n\n if (path === \"/api/stats\") {\n const s = await getStats();\n return new Response(JSON.stringify(s), { headers: { \"Content-Type\": \"application/json\" } });\n }\n if (path === \"/api/results\") {\n const r = await sqlite.execute(\"SELECT * FROM ebay_registrations ORDER BY createdAt DESC LIMIT 50\");\n return new Response(JSON.stringify(r.rows), { headers: { \"Content-Type\": \"application/json\" } });\n }\n if (path === \"/api/playbook\") {\n const r = await sqlite.execute(\"SELECT * FROM ebay_playbook ORDER BY stepOrder\");\n return new Response(JSON.stringify(r.rows), { headers: { \"Content-Type\": \"application/json\" } });\n }\n }\n\n // ── POST routes ─────────────────────────────────────\n if (req.method === \"POST\") {\n\n // Xóa results\n if (path === \"/clear-results\") {\n await sqlite.execute(\"DELETE FROM ebay_registrations\");\n await addLog(\"system\", \"Đã xóa toàn bộ kết quả đăng ký\", \"warn\");\n return new Response(null, { status: 302, headers: { Location: \"/accounts\" } });\n }\n\n // Xóa playbook\n if (path === \"/clear-playbook\") {\n await sqlite.execute(\"DELETE FROM ebay_playbook\");\n await addLog(\"system\", \"Đã xóa playbook — cần chạy AI Learn lại\", \"warn\");\n return new Response(null, { status: 302, headers: { Location: \"/playbook\" } });\n }\n\n // Xóa Inspector steps\n if (path === \"/inspector/clear\") {\n await sqlite.execute(\"DELETE FROM debug_steps\").catch(() => {});\n return new Response(null, { status: 302, headers: { Location: \"/inspector\" } });\n }\n\n // Xóa logs\n if (path === \"/clear-logs\") {\n await sqlite.execute(\"DELETE FROM job_logs\");\n return new Response(null, { status: 302, headers: { Location: \"/logs\" } });\n }\n\n // ── SCREENSHOT PROXY (CDP → base64 → PNG) ────────\n if (path === \"/live/screenshot\") {\n const sessionId = url.searchParams.get(\"session\") || \"\";\n if (!sessionId) {\n return new Response(\"no session\", { status: 400 });\n }\n try {\n const row = await sqlite.execute({\n sql: \"SELECT cdpWsUrl FROM browser_sessions WHERE sessionId=? AND status='active'\",\n args: [sessionId],\n });\n if (!row.rows[0]) {\n return new Response(\"session not found\", { status: 404 });\n }\n const cdpWsUrl = row.rows[0].cdpWsUrl as string;\n\n // Gọi CDP HTTP endpoint để lấy screenshot\n // cdpWsUrl = wss://proxy.xxx.onkernel.com:8443/browser/cdp?jwt=...\n // → HTTP base = https://proxy.xxx.onkernel.com:8443\n const wsUrl = new URL(cdpWsUrl.replace(\"wss://\", \"https://\").replace(\"/browser/cdp\", \"/browser/screenshot\"));\n\n const resp = await fetch(wsUrl.toString(), {\n headers: { \"Accept\": \"image/png\" },\n });\n\n if (resp.ok) {\n const buf = await resp.arrayBuffer();\n return new Response(buf, {\n headers: {\n \"Content-Type\": \"image/png\",\n \"Cache-Control\": \"no-store\",\n \"Access-Control-Allow-Origin\": \"*\",\n },\n });\n }\n\n // Fallback: dùng CDP JSON API\n const baseUrl = cdpWsUrl\n .replace(\"wss://\", \"https://\")\n .replace(/\\/browser\\/cdp.*/, \"\");\n const jsonResp = await fetch(`${baseUrl}/json`, {\n headers: { \"Accept\": \"application/json\" },\n }).catch(() => null);\n\n if (jsonResp?.ok) {\n const tabs = await jsonResp.json() as Array<{ id: string; webSocketDebuggerUrl: string }>;\n const tab = tabs.find(t => t.webSocketDebuggerUrl) || tabs[0];\n if (tab) {\n // Gửi CDP command Page.captureScreenshot qua WebSocket\n const screenshotData = await captureScreenshotCDP(cdpWsUrl);\n if (screenshotData) {\n const bytes = Uint8Array.from(atob(screenshotData), c => c.charCodeAt(0));\n return new Response(bytes.buffer, {\n headers: {\n \"Content-Type\": \"image/png\",\n \"Cache-Control\": \"no-store\",\n \"Access-Control-Allow-Origin\": \"*\",\n },\n });\n }\n }\n }\n\n return new Response(\"screenshot failed\", { status: 502 });\n } catch (e) {\n return new Response(`error: ${e.message}`, { status: 500 });\n }\n }\n\n // ── TẠO LIVE SESSION MỚI ─────────────────────────\n if (path === \"/live/create\") {\n const form = await req.formData();\n const label = String(form.get(\"label\") || \"Manual Session\");\n try {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS browser_sessions (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n sessionId TEXT NOT NULL UNIQUE,\n liveViewUrl TEXT NOT NULL,\n cdpWsUrl TEXT NOT NULL,\n label TEXT DEFAULT 'Manual Session',\n status TEXT DEFAULT 'active',\n createdAt TEXT DEFAULT (datetime('now')),\n closedAt TEXT\n )\n `);\n const Kernel = (await import(\"npm:@onkernel/sdk\")).default;\n const kernel = new Kernel();\n const b = await kernel.browsers.create();\n await sqlite.execute({\n sql: `INSERT INTO browser_sessions (sessionId, liveViewUrl, cdpWsUrl, label, status)\n VALUES (?,?,?,?,'active')`,\n args: [b.session_id, b.browser_live_view_url, b.cdp_ws_url, label],\n });\n await addLog(\"live\", `🔴 Tạo live session: ${label} (${b.session_id.slice(0,12)}...)`, \"success\");\n return new Response(null, {\n status: 302,\n headers: { Location: `/live?session=${b.session_id}` },\n });\n } catch (e) {\n await addLog(\"live\", `❌ Lỗi tạo session: ${e.message}`, \"error\");\n return new Response(null, { status: 302, headers: { Location: \"/live\" } });\n }\n }\n\n // ── ĐÓNG 1 LIVE SESSION ───────────────────────────\n if (path === \"/live/close\") {\n const form = await req.formData();\n const sessionId = String(form.get(\"sessionId\") || \"\");\n if (sessionId) {\n try {\n const Kernel = (await import(\"npm:@onkernel/sdk\")).default;\n const kernel = new Kernel();\n await kernel.browsers.deleteByID(sessionId).catch(() => {});\n } catch { /* bỏ qua */ }\n await sqlite.execute({\n sql: `UPDATE browser_sessions SET status='closed', closedAt=datetime('now') WHERE sessionId=?`,\n args: [sessionId],\n });\n await addLog(\"live\", `🔒 Đóng session ${sessionId.slice(0,12)}...`, \"warn\");\n }\n return new Response(null, { status: 302, headers: { Location: \"/live\" } });\n }\n\n // ── ĐÓNG TẤT CẢ SESSION ACTIVE ───────────────────\n if (path === \"/live/close-all\") {\n const active = await sqlite.execute(\"SELECT sessionId FROM browser_sessions WHERE status='active'\");\n let count = 0;\n for (const row of active.rows) {\n try {\n const Kernel = (await import(\"npm:@onkernel/sdk\")).default;\n const kernel = new Kernel();\n await kernel.browsers.deleteByID(row.sessionId as string).catch(() => {});\n count++;\n } catch { /* bỏ qua */ }\n }\n await sqlite.execute(\n `UPDATE browser_sessions SET status='closed', closedAt=datetime('now') WHERE status='active'`\n );\n await addLog(\"live\", `🔒 Đã đóng ${count} session`, \"warn\");\n return new Response(null, { status: 302, headers: { Location: \"/live\" } });\n }\n\n // ── THÊM BƯỚC MỚI vào playbook ──────────────────\n if (path === \"/playbook/add\") {\n const form = await req.formData();\n const action = String(form.get(\"action\") || \"click\");\n const description = String(form.get(\"description\") || \"\");\n const selector = String(form.get(\"selector\") || \"\") || null;\n const fieldKey = String(form.get(\"fieldKey\") || \"\") || null;\n const value = String(form.get(\"value\") || \"\") || null;\n const stepOrder = parseInt(String(form.get(\"stepOrder\") || \"99\"));\n const waitMs = parseInt(String(form.get(\"waitMs\") || \"500\"));\n\n if (!description) {\n return new Response(null, { status: 302, headers: { Location: \"/playbook\" } });\n }\n\n // Dịch chuyển các bước >= stepOrder lên 1\n await sqlite.execute({\n sql: \"UPDATE ebay_playbook SET stepOrder = stepOrder + 1 WHERE stepOrder >= ?\",\n args: [stepOrder],\n });\n await sqlite.execute({\n sql: `INSERT INTO ebay_playbook (stepOrder, action, description, selector, value, fieldKey, waitMs)\n VALUES (?,?,?,?,?,?,?)`,\n args: [stepOrder, action, description, selector, value, fieldKey, waitMs],\n });\n await addLog(\"playbook\", `➕ Thêm bước mới [${stepOrder}] ${action}: ${description}`, \"success\");\n return new Response(null, { status: 302, headers: { Location: \"/playbook\" } });\n }\n\n // ── CẬP NHẬT BƯỚC ────────────────────────────────\n if (path === \"/playbook/update\") {\n const form = await req.formData();\n const id = parseInt(String(form.get(\"id\") || \"0\"));\n const action = String(form.get(\"action\") || \"click\");\n const description = String(form.get(\"description\") || \"\");\n const selector = String(form.get(\"selector\") || \"\") || null;\n const fieldKey = String(form.get(\"fieldKey\") || \"\") || null;\n const value = String(form.get(\"value\") || \"\") || null;\n const stepOrder = parseInt(String(form.get(\"stepOrder\") || \"1\"));\n const waitMs = parseInt(String(form.get(\"waitMs\") || \"500\"));\n\n await sqlite.execute({\n sql: `UPDATE ebay_playbook\n SET action=?, description=?, selector=?, value=?, fieldKey=?, stepOrder=?, waitMs=?\n WHERE id=?`,\n args: [action, description, selector, value, fieldKey, stepOrder, waitMs, id],\n });\n await addLog(\"playbook\", `✏️ Cập nhật bước ID=${id}: ${action} — ${description}`, \"success\");\n return new Response(null, { status: 302, headers: { Location: \"/playbook\" } });\n }\n\n // ── XÓA BƯỚC ─────────────────────────────────────\n if (path === \"/playbook/delete\") {\n const form = await req.formData();\n const id = parseInt(String(form.get(\"id\") || \"0\"));\n const step = await sqlite.execute({ sql: \"SELECT * FROM ebay_playbook WHERE id=?\", args: [id] });\n if (step.rows.length > 0) {\n const s = step.rows[0] as any;\n await sqlite.execute({ sql: \"DELETE FROM ebay_playbook WHERE id=?\", args: [id] });\n // Chuẩn hoá lại stepOrder\n await sqlite.execute(\n \"UPDATE ebay_playbook SET stepOrder = stepOrder - 1 WHERE stepOrder > ?\",\n // @ts-ignore\n [s.stepOrder]\n );\n await addLog(\"playbook\", `🗑️ Xóa bước [${s.stepOrder}] ${s.action}: ${s.description}`, \"warn\");\n }\n return new Response(null, { status: 302, headers: { Location: \"/playbook\" } });\n }\n\n // ── SẮP XẾP LẠI THỨ TỰ (drag & drop) ──────────\n if (path === \"/playbook/reorder\") {\n try {\n const body = await req.json() as { ids: string[] };\n const ids = body.ids.map(Number).filter(Boolean);\n for (let i = 0; i < ids.length; i++) {\n await sqlite.execute({\n sql: \"UPDATE ebay_playbook SET stepOrder=? WHERE id=?\",\n args: [i + 1, ids[i]],\n });\n }\n await addLog(\"playbook\", `🔀 Đã sắp xếp lại ${ids.length} bước`, \"info\");\n return new Response(JSON.stringify({ ok: true }), {\n headers: { \"Content-Type\": \"application/json\" },\n });\n } catch {\n return new Response(JSON.stringify({ ok: false }), {\n status: 400, headers: { \"Content-Type\": \"application/json\" },\n });\n }\n }\n\n // Chạy AI Learn (trigger background)\n if (path === \"/run-learn\") {\n await addLog(\"learn\", \"🧠 AI Learn được kích hoạt từ Dashboard\", \"info\");\n await addLog(\"learn\", \"⚠️ Hãy mở file agentLearn.ts và bấm Run trong Val Town editor\", \"warn\");\n await addLog(\"learn\", \"💡 Sau khi chạy xong, reload trang Playbook để xem kết quả\", \"info\");\n\n return new Response(`\n\n\n\n

🧠

AI Learn đã được kích hoạt!

\n Vào Val Town editor → mở agentLearn.ts → bấm Run
\n Sau khi chạy xong, quay lại xem Playbook.\n

\n 📖 Xem Playbook\n ← Quay lại\n

\n`, { headers: { \"Content-Type\": \"text/html;charset=utf-8\" } });\n }\n\n // Chạy AI Replay (trigger background)\n if (path === \"/run-replay\") {\n const form = await req.formData();\n const delay = form.get(\"delay\") || \"15\";\n const limit = form.get(\"limit\") || \"0\";\n\n await addLog(\"replay\", `🚀 AI Replay được kích hoạt (delay=${delay}s, limit=${limit})`, \"info\");\n await addLog(\"replay\", \"⚠️ Hãy mở file agentReplay.ts và bấm Run trong Val Town editor\", \"warn\");\n await addLog(\"replay\", \"💡 Kết quả sẽ xuất hiện trong tab Tài khoản khi chạy xong\", \"info\");\n\n return new Response(`\n\n\n\n

🚀

AI Replay đã được kích hoạt!

\n Cấu hình: Delay = ${delay}s, Limit = ${Number(limit) === 0 ? \"Tất cả\" : limit}\n

\n Vào Val Town editor → mở agentReplay.ts → bấm Run
\n Kết quả sẽ hiển thị trong tab Tài khoản.\n

\n 👥 Xem Tài khoản\n 📋 Xem Logs\n ← Quay lại\n

\n`, { headers: { \"Content-Type\": \"text/html;charset=utf-8\" } });\n }\n }\n\n return new Response(\"404 Not Found\", { status: 404 });\n}\n","deleted","label",[100],"permalink","https://www.val.town/x/minhheo/kernel_starter/code/dashboard.ts","extension","actionData","errors"]