${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",[],[225],{"_105":235,"_97":236,"_167":237,"_169":-5,"_170":148,"_171":238,"_173":174,"_107":239,"_102":240,"_176":191,"_178":241,"_180":22,"_181":-5,"_182":242,"_100":243},"e9a3d752-1ecd-11f1-a978-42dde27851f2","ddgEmail.ts","b5de6c78-1ca9-11f1-baf0-42dde27851f2",105,["D",1773400516199],4,"/**\n * DDG Email Service v3\n * DDG chỉ có 1 alias cố định → tự generate email random @duck.com style\n * Dùng adjective-noun-random pattern giống DDG\n */\n\nconst DDG_API_TOKEN = Deno.env.get(\"DDG_API_TOKEN\") || \"\";\nconst BASE_URL = \"https://quack.duckduckgo.com/api/email\";\n\nexport interface DDGAlias {\n address: string;\n fullEmail: string;\n}\n\n// Thử lấy alias thật từ DDG trước, nếu trùng thì tự tạo\nconst _usedEmails = new Set();\n\nconst ADJECTIVES = [\n \"amber\",\"breezy\",\"calm\",\"daring\",\"eager\",\"fancy\",\"gentle\",\"happy\",\n \"icy\",\"jolly\",\"kind\",\"lively\",\"merry\",\"nimble\",\"orange\",\"peppy\",\n \"quiet\",\"rapid\",\"sunny\",\"tidy\",\"unique\",\"vivid\",\"warm\",\"xenial\",\"young\",\"zippy\",\n \"brave\",\"crisp\",\"dusty\",\"early\",\"fuzzy\",\"grand\",\"hasty\",\"idle\",\"jazzy\",\n \"kooky\",\"lumpy\",\"misty\",\"nifty\",\"oval\",\"prime\",\"quirky\",\"rusty\",\"sleek\",\n \"tangy\",\"ultra\",\"vague\",\"windy\",\"exact\",\"yummy\",\"zesty\",\n];\n\nconst NOUNS = [\n \"apple\",\"badger\",\"candle\",\"daisy\",\"eagle\",\"falcon\",\"garden\",\"harbor\",\n \"island\",\"jungle\",\"kite\",\"lemon\",\"maple\",\"nebula\",\"ocean\",\"panda\",\n \"quartz\",\"river\",\"stone\",\"tiger\",\"umbrella\",\"violet\",\"walnut\",\"xenon\",\n \"yacht\",\"zebra\",\"anchor\",\"bridge\",\"castle\",\"delta\",\"ember\",\"frost\",\n \"glacier\",\"hollow\",\"iris\",\"jasper\",\"kelp\",\"lagoon\",\"meteor\",\"nova\",\n \"orbit\",\"peak\",\"quest\",\"ridge\",\"sierra\",\"tundra\",\"unity\",\"vortex\",\n \"willow\",\"pixel\",\"yield\",\"zephyr\",\n];\n\nfunction randomInt(min: number, max: number): number {\n return Math.floor(Math.random() * (max - min + 1)) + min;\n}\n\nfunction generateRandomAlias(): string {\n const adj = ADJECTIVES[randomInt(0, ADJECTIVES.length - 1)];\n const noun = NOUNS[randomInt(0, NOUNS.length - 1)];\n const num = randomInt(100, 9999);\n return `${adj}-${noun}-${num}`;\n}\n\nexport async function generateDDGAlias(): Promise {\n // Thử gọi DDG API thật trước\n if (DDG_API_TOKEN) {\n try {\n const response = await fetch(`${BASE_URL}/addresses`, {\n method: \"POST\",\n headers: {\n \"Authorization\": `Bearer ${DDG_API_TOKEN}`,\n \"Content-Type\": \"application/json\",\n },\n body: JSON.stringify({}),\n });\n\n if (response.ok) {\n const data = await response.json();\n const address = data?.address || \"\";\n if (address && !_usedEmails.has(address)) {\n _usedEmails.add(address);\n const fullEmail = `${address}@duck.com`;\n console.log(`[ddg] ✅ DDG API: ${fullEmail}`);\n return { address, fullEmail };\n }\n console.log(`[ddg] ⚠️ DDG trả về alias trùng \"${address}\" → tự generate`);\n } else {\n console.log(`[ddg] ⚠️ DDG API lỗi ${response.status} → tự generate`);\n }\n } catch (e) {\n console.log(`[ddg] ⚠️ DDG API exception: ${(e as Error).message} → tự generate`);\n }\n }\n\n // Tự generate alias random, đảm bảo không trùng\n let alias = \"\";\n let attempts = 0;\n do {\n alias = generateRandomAlias();\n attempts++;\n } while (_usedEmails.has(alias) && attempts < 100);\n\n _usedEmails.add(alias);\n const fullEmail = `${alias}@duck.com`;\n console.log(`[ddg] ✅ Generated: ${fullEmail}`);\n return { address: alias, fullEmail };\n}\n\nif (import.meta.main) {\n console.log(\"🧪 Test tạo 5 emails...\");\n const emails: string[] = [];\n for (let i = 0; i < 5; i++) {\n const alias = await generateDDGAlias();\n emails.push(alias.fullEmail);\n console.log(` ${i + 1}. ${alias.fullEmail}`);\n }\n const unique = new Set(emails).size;\n console.log(`\\n${unique === 5 ? \"✅\" : \"❌\"} Unique: ${unique}/5`);\n}\n",[],[236],{"_105":245,"_97":246,"_167":247,"_169":-5,"_170":148,"_171":248,"_173":174,"_107":249,"_102":250,"_176":191,"_178":251,"_180":22,"_181":-5,"_182":252,"_100":253},"e68ffa08-1ecf-11f1-8d39-42dde27851f2","ebayRegister.ts","d6075f86-1caf-11f1-ad51-42dde27851f2",111,["D",1773401369754],21,"/**\n * eBay Business Registration Bot v4.0\n * B1: Kernel browser (profile + proxy US cố định, lưu cache/cookie)\n * B2: Validate dữ liệu + lưu SQLite\n * B3: Tạo DDG email + lưu chung 1 dòng SQLite\n * B4+: Captcha → Register → Fill → Submit → Verify\n */\n\nimport \"https://esm.town/v/wolf/StubFS/stubFs.ts\";\nimport { chromium } from \"npm:playwright-core\";\nimport Kernel from \"npm:@onkernel/sdk\";\nimport OpenAI from \"npm:openai\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nimport { fetchAccountsFromSheets, updateEmailInSheet, type AccountData } from \"./sheets.ts\";\nimport { generateDDGAlias } from \"./ddgEmail.ts\";\nimport { initResultsDB, saveResult, printSummary } from \"./results.ts\";\nimport { solveHCaptchaWithGemini } from \"./captcha.ts\";\nimport { Logger, createRunId } from \"./logger.ts\";\n\n// ── Cấu hình ──────────────────────────────────────────\nconst AI_API_KEY = Deno.env.get(\"AI_API_KEY\") || \"\";\nconst AI_BASE_URL = Deno.env.get(\"AI_BASE_URL\") || \"\";\nconst AI_MODEL = Deno.env.get(\"AI_MODEL\") || \"qwen2.5-72b-instruct\";\nconst NOPECHA_EXTENSION_ID = Deno.env.get(\"NOPECHA_EXTENSION_ID\") || \"k17g3z4olapuyz9oaf2z0i0d\";\nconst DELAY_BETWEEN = 15_000;\nconst RUN_LIMIT = 1;\n\nconst URL_CAPTCHA = \"https://www.ebay.com/splashui/captcha?\";\nconst URL_REGISTER = \"https://signup.ebay.com/pa/crte?\";\n\n// ══════════════════════════════════════════════════════\n// DB: Khởi tạo bảng accounts (1 dòng = 1 tài khoản đầy đủ)\n// ══════════════════════════════════════════════════════\nasync function initAccountsTable() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS accounts (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n\n -- B1: Browser / Session\n sessionId TEXT,\n liveViewUrl TEXT,\n cdpWsUrl TEXT,\n profileId TEXT,\n\n -- B2: Dữ liệu từ Sheets\n rowIndex INTEGER,\n business_name TEXT,\n ein TEXT,\n busines_street TEXT,\n business_city TEXT,\n business_state TEXT,\n business_zip TEXT,\n first_name TEXT,\n last_name TEXT,\n ssn TEXT,\n dob TEXT,\n city TEXT,\n state TEXT,\n zip TEXT,\n routing_number TEXT,\n account_number TEXT,\n password TEXT,\n\n -- B3: Email DDG\n email TEXT,\n ddgAddress TEXT,\n\n -- Kết quả cuối\n status TEXT DEFAULT 'pending',\n ebayUsername TEXT,\n errorMessage TEXT,\n\n createdAt TEXT DEFAULT (datetime('now')),\n updatedAt TEXT DEFAULT (datetime('now'))\n )\n `);\n}\n\n// Cập nhật 1 cột bất kỳ trong bảng accounts\nasync function updateAccount(id: number, fields: Record) {\n const keys = Object.keys(fields);\n const setClauses = keys.map(k => `${k} = ?`).join(\", \");\n const values = keys.map(k => fields[k]);\n await sqlite.execute({\n sql: `UPDATE accounts SET ${setClauses}, updatedAt=datetime('now') WHERE id=?`,\n args: [...values, id],\n });\n}\n\n// ══════════════════════════════════════════════════════\n// VALIDATE dữ liệu — trả về danh sách lỗi\n// ══════════════════════════════════════════════════════\ninterface ValidationResult {\n valid: boolean;\n errors: string[];\n}\n\nfunction validateAccount(a: AccountData): ValidationResult {\n const errors: string[] = [];\n const required: Array<[string, string]> = [\n [a.businessName, \"business_name\"],\n [a.ein, \"ein\"],\n [a.businessStreet, \"busines_street\"],\n [a.businessCity, \"business_city\"],\n [a.businessState, \"business_state\"],\n [a.businessZip, \"business_zip\"],\n [a.firstName, \"first_name\"],\n [a.lastName, \"last_name\"],\n [a.ssn, \"ssn\"],\n [a.dob, \"dob\"],\n [a.city, \"city\"],\n [a.state, \"state\"],\n [a.zip, \"zip\"],\n [a.routingNumber, \"routing_number\"],\n // account_number không bắt buộc khi đăng ký eBay\n // [a.accountNumber, \"account_number\"],\n ];\n\n for (const [val, name] of required) {\n if (!val?.trim()) errors.push(`${name} trống`);\n }\n\n // firstName không được là mã số\n if (a.firstName && /^\\d{3,}-\\d{3,}$/.test(a.firstName.trim())) {\n errors.push(`first_name trông như mã số: \"${a.firstName}\"`);\n }\n\n return { valid: errors.length === 0, errors };\n}\n\n// ══════════════════════════════════════════════════════\n// FILL FIELD helper\n// ══════════════════════════════════════════════════════\nasync function fillField(\n page: any,\n selectors: string[],\n value: string,\n label: string,\n log: Logger\n): Promise {\n for (const sel of selectors) {\n try {\n const el = page.locator(sel).first();\n if (await el.isVisible({ timeout: 2000 }).catch(() => false)) {\n await el.click();\n await el.clear();\n await el.fill(value);\n const display = label.includes(\"pass\") || label.includes(\"ssn\") ? \"***\" : value;\n await log.success(` ✅ [${label}] = \"${display}\" ← ${sel}`);\n await page.waitForTimeout(300);\n return true;\n }\n } catch (e) {\n await log.debug(` [${sel}] fail: ${(e as Error).message}`);\n }\n }\n await log.warn(` ❌ Không tìm thấy field: ${label}`);\n return false;\n}\n\n// ══════════════════════════════════════════════════════\n// ĐĂNG KÝ 1 TÀI KHOẢN\n// ══════════════════════════════════════════════════════\nasync function registerAccount(\n kernel: InstanceType,\n ai: OpenAI,\n account: AccountData,\n idx: number,\n log: Logger\n): Promise<{ status: \"success\" | \"failed\"; ebayUsername?: string; errorMessage?: string }> {\n\n // ════════════════════════════════════════════════════\n // B1 — Tạo Kernel Browser\n // • Loại: profile cố định (persistent) + proxy US\n // • Lưu lịch sử cache và cookie (dùng profile_id)\n // • Ghi session_id, live_view_url, cdp_ws_url → SQLite\n // ════════════════════════════════════════════════════\n await log.step(\"B1:BROWSER\", \"Tạo Kernel browser (profile + proxy US)\");\n\n // Tạo profile_id cố định cho account này — cùng profile → giữ cookie/cache\n const profileId = `ebay-us-acc-${account.rowIndex}`;\n\n const createOptions: Record = {\n profile_id: profileId, // profile cố định → lưu cookie & cache\n country: \"US\", // proxy US cố định\n };\n if (NOPECHA_EXTENSION_ID) {\n createOptions.extension_ids = [NOPECHA_EXTENSION_ID];\n }\n\n await log.debug(\"Kernel create options\", createOptions);\n const kb = await kernel.browsers.create(createOptions);\n\n await log.success(\"Browser tạo thành công\", {\n session_id: kb.session_id,\n live_view: kb.browser_live_view_url,\n profile_id: profileId,\n proxy: \"US cố định\",\n });\n await log.info(`🔴 LIVE VIEW: ${kb.browser_live_view_url}`);\n\n // Lưu session vào bảng accounts (tạo dòng mới)\n await sqlite.execute({\n sql: `INSERT INTO accounts (sessionId, liveViewUrl, cdpWsUrl, profileId, rowIndex, status)\n VALUES (?, ?, ?, ?, ?, 'pending')`,\n args: [kb.session_id, kb.browser_live_view_url, kb.cdp_ws_url, profileId, account.rowIndex],\n });\n\n // Lấy id dòng vừa tạo\n const idRow = await sqlite.execute(\n \"SELECT id FROM accounts WHERE sessionId = ? LIMIT 1\",\n );\n // fallback: query lại chính xác\n const idResult = await sqlite.execute({\n sql: \"SELECT id FROM accounts WHERE sessionId = ? LIMIT 1\",\n args: [kb.session_id],\n });\n const dbId = (idResult.rows[0] as any)?.id as number;\n await log.debug(`SQLite accounts.id = ${dbId}`);\n\n const browser = await chromium.connectOverCDP(kb.cdp_ws_url);\n await log.success(\"Playwright kết nối CDP thành công\");\n\n try {\n const context = browser.contexts()[0] || await browser.newContext({\n locale: \"en-US\",\n timezoneId: \"America/New_York\",\n userAgent: \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/122.0.0.0 Safari/537.36\",\n });\n const page = context.pages()[0] || await context.newPage();\n await page.setViewportSize({ width: 1280, height: 900 });\n\n // ════════════════════════════════════════════════════\n // B2 — Validate dữ liệu từ Sheets + lưu vào SQLite\n // Các trường bắt buộc:\n // business_name, ein, busines_street, business_city,\n // business_state, business_zip, first_name, last_name,\n // ssn, dob, city, state, zip, routing_number, account_number\n // ════════════════════════════════════════════════════\n await log.step(\"B2:VALIDATE\", \"Validate dữ liệu + lưu SQLite\");\n\n const vResult = validateAccount(account);\n await log.info(\"Dữ liệu từ Sheets\", {\n business_name: account.businessName,\n ein: account.ein,\n busines_street: account.businessStreet,\n business_city: account.businessCity,\n business_state: account.businessState,\n business_zip: account.businessZip,\n first_name: account.firstName,\n last_name: account.lastName,\n ssn: account.ssn ? \"***\" + account.ssn.slice(-4) : \"\",\n dob: account.dob,\n city: account.city,\n state: account.state,\n zip: account.zip,\n routing_number: account.routingNumber,\n account_number: account.accountNumber ? \"***\" + account.accountNumber.slice(-4) : \"\",\n });\n\n if (!vResult.valid) {\n await log.error(\"Dữ liệu không hợp lệ\", { errors: vResult.errors });\n await updateAccount(dbId, { status: \"failed\", errorMessage: vResult.errors.join(\", \") });\n return { status: \"failed\", errorMessage: `Dữ liệu không hợp lệ: ${vResult.errors.join(\", \")}` };\n }\n\n // Lưu toàn bộ dữ liệu vào SQLite (cùng dòng với B1)\n await updateAccount(dbId, {\n business_name: account.businessName,\n ein: account.ein,\n busines_street: account.businessStreet,\n business_city: account.businessCity,\n business_state: account.businessState,\n business_zip: account.businessZip,\n first_name: account.firstName,\n last_name: account.lastName,\n ssn: account.ssn,\n dob: account.dob,\n city: account.city,\n state: account.state,\n zip: account.zip,\n routing_number: account.routingNumber,\n account_number: account.accountNumber,\n password: account.password,\n });\n await log.success(\"✅ Dữ liệu hợp lệ, đã lưu vào SQLite (accounts.id=\" + dbId + \")\");\n\n // ════════════════════════════════════════════════════\n // B3 — Tạo email DDG @duck.com + lưu chung 1 dòng SQLite\n // ════════════════════════════════════════════════════\n await log.step(\"B3:EMAIL\", \"Tạo email @duck.com qua DuckDuckGo API\");\n\n let fullEmail = \"\";\n let ddgAddress = \"\";\n try {\n const ddg = await generateDDGAlias();\n fullEmail = ddg.fullEmail;\n ddgAddress = ddg.address;\n await log.success(`Email tạo thành công: ${fullEmail}`);\n } catch (e) {\n await log.error(`Lỗi tạo DDG email: ${(e as Error).message}`);\n await updateAccount(dbId, { status: \"failed\", errorMessage: `DDG email lỗi: ${(e as Error).message}` });\n throw e;\n }\n\n // Lưu email vào cùng dòng SQLite (B1 + B2 + B3 = 1 dòng)\n await updateAccount(dbId, { email: fullEmail, ddgAddress });\n await log.success(`Email lưu vào SQLite chung dòng id=${dbId}: ${fullEmail}`);\n\n // Ghi email lên Google Sheets ngay (cột A) để không mất nếu crash\n try {\n await updateEmailInSheet(account.rowIndex, fullEmail);\n await log.success(\"Đã ghi email vào Sheets (cột A) ✓\");\n } catch (e) {\n await log.warn(`Ghi Sheets lỗi (không critical): ${(e as Error).message}`);\n }\n\n // ════════════════════════════════════════════════════\n // B4 — Mở trang Captcha\n // ════════════════════════════════════════════════════\n await log.step(\"B4:CAPTCHA_PAGE\", `Mở trang Captcha`);\n await page.goto(URL_CAPTCHA, { waitUntil: \"domcontentloaded\", timeout: 30_000 });\n await page.waitForTimeout(3000);\n await log.success(\"Trang captcha tải xong\", { url: page.url(), title: await page.title() });\n\n // ════════════════════════════════════════════════════\n // B5 — Giải hCaptcha (tối đa 3 lần, có reload)\n // ════════════════════════════════════════════════════\n await log.step(\"B5:CAPTCHA_SOLVE\", \"Giải hCaptcha bằng Gemini Vision\");\n let captchaSolved = false;\n for (let attempt = 1; attempt <= 3; attempt++) {\n await log.info(`Lần thử ${attempt}/3`);\n captchaSolved = await solveHCaptchaWithGemini(page, undefined, 5, log);\n if (captchaSolved) {\n await log.success(`hCaptcha giải xong ở lần ${attempt}!`);\n break;\n }\n if (attempt < 3) {\n await log.warn(`Lần ${attempt} thất bại → reload`);\n await page.reload({ waitUntil: \"domcontentloaded\", timeout: 20_000 });\n await page.waitForTimeout(2000);\n }\n }\n if (!captchaSolved) {\n await log.error(\"❌ Không giải được captcha sau 3 lần\");\n await updateAccount(dbId, { status: \"failed\", errorMessage: \"hCaptcha không giải được\" });\n return { status: \"failed\", errorMessage: \"hCaptcha không giải được sau 3 lần\" };\n }\n await page.waitForTimeout(1500);\n\n // ════════════════════════════════════════════════════\n // B6 — Mở trang Register\n // ════════════════════════════════════════════════════\n await log.step(\"B6:REGISTER_PAGE\", `Mở trang Register`);\n await page.goto(URL_REGISTER, { waitUntil: \"domcontentloaded\", timeout: 30_000 });\n await page.waitForTimeout(3000);\n\n const regUrl = page.url();\n await log.success(\"Trang Register tải xong\", { url: regUrl, title: await page.title() });\n\n if (regUrl.includes(\"captcha\") || regUrl.includes(\"security\")) {\n await log.error(\"❌ Bị redirect về captcha — eBay block IP\");\n await updateAccount(dbId, { status: \"failed\", errorMessage: \"Redirect về captcha\" });\n return { status: \"failed\", errorMessage: \"Bị redirect về captcha\" };\n }\n\n // ════════════════════════════════════════════════════\n // B7 — Chọn Business account tab\n // ════════════════════════════════════════════════════\n await log.step(\"B7:BUSINESS_TAB\", \"Chọn Business account\");\n for (const sel of [\n \"#businessaccount-radio\",\n 'input[value=\"business\"]',\n 'input[id*=\"business\"][type=\"radio\"]',\n 'label:has-text(\"Business account\")',\n 'a:has-text(\"Business account\")',\n '[data-testid*=\"business\"]',\n ]) {\n try {\n const el = page.locator(sel).first();\n if (await el.isVisible({ timeout: 2000 }).catch(() => false)) {\n await el.click();\n await page.waitForTimeout(1500);\n await log.success(`Business tab clicked ← ${sel}`);\n break;\n }\n } catch { /* thử tiếp */ }\n }\n\n // ════════════════════════════════════════════════════\n // B8 — Điền form\n // ════════════════════════════════════════════════════\n await log.step(\"B8:FILL_FORM\", \"Điền tất cả fields vào form\");\n\n await fillField(page, [\n \"#businessName\", 'input[name=\"businessName\"]',\n 'input[name=\"legalBusinessName\"]', 'input[placeholder*=\"business name\" i]',\n ], account.businessName, \"business_name\", log);\n\n await fillField(page, [\n \"#Email\", \"#businessEmail\",\n 'input[name=\"Email\"]', 'input[name=\"email\"]',\n 'input[name=\"businessEmail\"]', 'input[type=\"email\"]',\n ], fullEmail, \"email\", log);\n\n await fillField(page, [\n \"#pwd\", \"#bizPassword\",\n 'input[name=\"pwd\"]', 'input[name=\"bizPassword\"]', 'input[type=\"password\"]',\n ], account.password, \"password\", log);\n\n await fillField(page, [\n \"#firstName\", 'input[name=\"firstName\"]',\n 'input[name=\"fname\"]', 'input[placeholder*=\"first name\" i]',\n ], account.firstName, \"first_name\", log);\n\n await fillField(page, [\n \"#lastName\", 'input[name=\"lastName\"]',\n 'input[name=\"lname\"]', 'input[placeholder*=\"last name\" i]',\n ], account.lastName, \"last_name\", log);\n\n // Country dropdown\n for (const sel of [\"#businessCountry\", 'select[name=\"businessCountry\"]', 'select[name=\"country\"]', \"#country\"]) {\n try {\n const el = page.locator(sel).first();\n if (await el.isVisible({ timeout: 2000 }).catch(() => false)) {\n await el.selectOption([{ label: \"United States\" }, { value: \"US\" }]).catch(() => null);\n await log.success(`Country = United States ← ${sel}`);\n await page.waitForTimeout(400);\n break;\n }\n } catch { /* thử tiếp */ }\n }\n\n await page.waitForTimeout(800);\n\n // ════════════════════════════════════════════════════\n // B9 — Submit form\n // ════════════════════════════════════════════════════\n await log.step(\"B9:SUBMIT\", \"Click Submit\");\n let submitted = false;\n for (const sel of [\n \"#BUSINESS_REG_FORM_SUBMIT\",\n 'button[id=\"BUSINESS_REG_FORM_SUBMIT\"]',\n 'button[data-testid*=\"submit\" i]',\n 'button[type=\"submit\"]',\n 'input[type=\"submit\"]',\n 'button:has-text(\"Create account\")',\n 'button:has-text(\"Register\")',\n 'button:has-text(\"Continue\")',\n ]) {\n try {\n const el = page.locator(sel).first();\n if (await el.isVisible({ timeout: 3000 }).catch(() => false)) {\n await el.click();\n await log.success(`Submit clicked ← ${sel}`);\n submitted = true;\n break;\n }\n } catch { /* thử tiếp */ }\n }\n if (!submitted) {\n await log.warn(\"Không tìm thấy nút submit → nhấn Enter\");\n await page.keyboard.press(\"Enter\");\n }\n\n await log.info(\"Chờ 7s sau submit...\");\n await page.waitForTimeout(7000);\n\n // ════════════════════════════════════════════════════\n // B10 — Kiểm tra kết quả\n // ════════════════════════════════════════════════════\n await log.step(\"B10:RESULT\", \"Kiểm tra kết quả đăng ký\");\n\n const finalUrl = page.url();\n const pageTitle = await page.title();\n const bodyText = await page.locator(\"body\").innerText().catch(() => \"\");\n\n await log.info(\"Trạng thái sau submit\", {\n url: finalUrl,\n title: pageTitle,\n bodyPreview: bodyText.slice(0, 300),\n });\n\n const errText = await page.locator(\n \"#gh-notification, .errRt, .error-message, [role='alert'], .field-error, .notification--error, .inline-error\"\n ).first().textContent().catch(() => null);\n if (errText?.trim()) await log.warn(\"Error element\", { text: errText.trim() });\n\n // LLM phân tích\n let analysis = { success: false, reason: \"\" };\n try {\n const res = await ai.chat.completions.create({\n model: AI_MODEL,\n messages: [\n { role: \"system\", content: `Phân tích kết quả đăng ký eBay. Trả về JSON: {\"success\":true/false,\"reason\":\"...\"}` },\n { role: \"user\", content: `URL: ${finalUrl}\\nTitle: ${pageTitle}\\nBody: ${bodyText.slice(0, 400)}` },\n ],\n temperature: 0.1, max_tokens: 100,\n });\n const t = res.choices[0].message.content || \"{}\";\n analysis = JSON.parse(t.match(/\\{[\\s\\S]*\\}/)?.[0] || \"{}\");\n await log.info(\"LLM phân tích\", analysis);\n } catch (e) {\n await log.warn(`LLM lỗi: ${(e as Error).message}`);\n }\n\n const isSuccess = analysis.success\n || finalUrl.includes(\"/mye/\")\n || finalUrl.includes(\"MyeBay\")\n || bodyText.toLowerCase().includes(\"welcome\");\n\n if (isSuccess) {\n await updateAccount(dbId, { status: \"success\", ebayUsername: fullEmail });\n await log.summary(\"success\");\n return { status: \"success\", ebayUsername: fullEmail };\n } else {\n const errMsg = errText?.trim() || analysis.reason || \"Không xác định\";\n await updateAccount(dbId, { status: \"failed\", errorMessage: errMsg });\n await log.summary(\"failed\", errMsg);\n return { status: \"failed\", errorMessage: errMsg };\n }\n\n } finally {\n // ════════════════════════════════════════════════════\n // CLEANUP — Đóng browser nhưng GIỮ PROFILE vĩnh viễn\n // Profile được lưu trên Kernel theo profile_id\n // Lần sau chạy lại account này sẽ dùng đúng profile cũ\n // ════════════════════════════════════════════════════\n await log.step(\"CLEANUP\", \"Đóng browser — giữ profile vĩnh viễn\");\n try {\n await browser.close();\n // KHÔNG gọi deleteByID → profile được giữ lại trên Kernel\n await sqlite.execute({\n sql: `UPDATE accounts SET updatedAt=datetime('now') WHERE sessionId=?`,\n args: [kb.session_id],\n });\n await log.success(`Browser đóng — profile \"${profileId}\" vẫn còn vĩnh viễn trên Kernel`);\n } catch (e) {\n await log.error(`Cleanup lỗi: ${(e as Error).message}`);\n }\n }\n}\n\n// ══════════════════════════════════════════════════════\n// MAIN\n// ══════════════════════════════════════════════════════\nconst RUN_ID = createRunId();\nconst mainLog = new Logger(RUN_ID, 0, \"MAIN\");\n\nawait mainLog.step(\"INIT\", \"eBay Bot v4.0 khởi động\");\nawait mainLog.info(\"Cấu hình\", {\n RUN_ID, RUN_LIMIT, AI_MODEL,\n NOPECHA: NOPECHA_EXTENSION_ID || \"⚠️ chưa set\",\n});\n\nconst ai = new OpenAI({ apiKey: AI_API_KEY, baseURL: AI_BASE_URL });\nconst kernel = new Kernel();\n\nawait initResultsDB();\nawait initAccountsTable();\n\nawait mainLog.step(\"READ_SHEETS\", \"Đọc Google Sheets CSV\");\nconst accounts = await fetchAccountsFromSheets();\n\nif (accounts.length === 0) {\n await mainLog.error(\"Không có tài khoản nào cần xử lý trong Sheets!\");\n Deno.exit(1);\n}\n\nconst toRun = RUN_LIMIT > 0 ? accounts.slice(0, RUN_LIMIT) : accounts;\nawait mainLog.success(\"Sẵn sàng\", { total: accounts.length, willRun: toRun.length });\n\nlet successCount = 0;\nlet failCount = 0;\n\nfor (let i = 0; i < toRun.length; i++) {\n const account = toRun[i];\n const accName = `${account.firstName} ${account.lastName}`.trim() || `row-${account.rowIndex}`;\n const accLog = new Logger(RUN_ID, i + 1, accName);\n\n await accLog.step(\"START\", `[${i + 1}/${toRun.length}] ${accName} | ${account.businessName}`);\n\n try {\n const result = await registerAccount(kernel, ai, account, i + 1, accLog);\n\n if (result.status === \"success\") {\n successCount++;\n await accLog.success(`✅ THÀNH CÔNG — ${result.ebayUsername}`);\n } else {\n failCount++;\n await accLog.error(`❌ THẤT BẠI — ${result.errorMessage}`);\n }\n\n await saveResult({\n email: result.ebayUsername || \"unknown\",\n firstName: account.firstName,\n lastName: account.lastName,\n businessName: account.businessName,\n ...result,\n });\n\n } catch (err) {\n failCount++;\n const msg = (err instanceof Error) ? err.message : String(err);\n await accLog.error(\"LỖI NGHIÊM TRỌNG\", { error: msg });\n await saveResult({\n email: \"error\", firstName: account.firstName,\n lastName: account.lastName, businessName: account.businessName,\n status: \"failed\", errorMessage: msg,\n });\n }\n\n await mainLog.info(\"Tiến độ\", {\n done: i + 1, total: toRun.length,\n success: successCount, failed: failCount,\n });\n\n if (i < toRun.length - 1) {\n await mainLog.info(`Nghỉ ${DELAY_BETWEEN / 1000}s trước tài khoản tiếp theo...`);\n await new Promise(r => setTimeout(r, DELAY_BETWEEN));\n }\n}\n\nawait mainLog.step(\"DONE\", \"Hoàn tất\");\nawait mainLog.info(\"TỔNG KẾT\", {\n total: toRun.length,\n success: successCount,\n failed: failCount,\n successRate: `${Math.round((successCount / toRun.length) * 100)}%`,\n});\nawait printSummary();\n",[],[246],{"_105":255,"_97":256,"_167":257,"_169":-5,"_170":148,"_171":219,"_173":174,"_107":258,"_102":33,"_176":191,"_178":259,"_180":22,"_181":-5,"_182":260,"_100":261},"0a76ff5a-1e23-11f1-8e8d-42dde27851f2","liveView.ts","0a770248-1e23-11f1-8e8d-42dde27851f2",["D",1773327127335],"/**\n * Live Browser Session Manager\n * Tạo browser session và trả về live_view_url để nhúng vào dashboard\n */\n\nimport \"https://esm.town/v/wolf/StubFS/stubFs.ts\";\nimport { chromium } from \"npm:playwright-core\";\nimport Kernel from \"npm:@onkernel/sdk\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n// ── Khởi tạo bảng lưu sessions ───────────────────────\nexport async function initSessionsDB() {\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\n// ── Tạo session mới và lưu vào DB ────────────────────\nexport async function createLiveSession(label = \"Manual Session\"): Promise<{\n sessionId: string;\n liveViewUrl: string;\n cdpWsUrl: string;\n}> {\n const kernel = new Kernel();\n const b = await kernel.browsers.create();\n\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\n return {\n sessionId: b.session_id,\n liveViewUrl: b.browser_live_view_url,\n cdpWsUrl: b.cdp_ws_url,\n };\n}\n\n// ── Đóng session ─────────────────────────────────────\nexport async function closeLiveSession(sessionId: string) {\n const kernel = new Kernel();\n try {\n await kernel.browsers.deleteByID(sessionId);\n } catch { /* bỏ qua nếu đã đóng */ }\n\n await sqlite.execute({\n sql: `UPDATE browser_sessions SET status='closed', closedAt=datetime('now') WHERE sessionId=?`,\n args: [sessionId],\n });\n}\n\n// ── Lấy danh sách sessions đang active ───────────────\nexport async function getActiveSessions() {\n return await sqlite.execute(\n \"SELECT * FROM browser_sessions WHERE status='active' ORDER BY createdAt DESC\"\n );\n}\n\n// ── Lấy tất cả sessions ──────────────────────────────\nexport async function getAllSessions(limit = 20) {\n return await sqlite.execute({\n sql: \"SELECT * FROM browser_sessions ORDER BY createdAt DESC LIMIT ?\",\n args: [limit],\n });\n}\n\n// ── Demo: Mở 1 session và điều hướng đến eBay ────────\nif (import.meta.main) {\n await initSessionsDB();\n\n console.log(\"🚀 Tạo live browser session...\");\n const { sessionId, liveViewUrl, cdpWsUrl } = await createLiveSession(\"Demo eBay\");\n\n console.log(`✅ Session: ${sessionId}`);\n console.log(`🔴 Live View URL: ${liveViewUrl}`);\n console.log(`\\n👆 Mở URL trên để xem browser trực tiếp!\\n`);\n\n // Kết nối và điều hướng đến eBay\n const browser = await chromium.connectOverCDP(cdpWsUrl);\n const context = browser.contexts()[0] || await browser.newContext();\n const page = context.pages()[0] || await context.newPage();\n\n await page.goto(\"https://reg.ebay.com/reg/RegistrationPage?bizflow=3\", {\n waitUntil: \"networkidle\",\n });\n console.log(\"✅ Đã mở trang eBay — xem live tại URL trên\");\n console.log(\"⏳ Giữ session trong 5 phút...\");\n\n await new Promise(r => setTimeout(r, 300_000)); // 5 phút\n await browser.close();\n await closeLiveSession(sessionId);\n console.log(\"🔒 Đã đóng session\");\n}\n",[],[256],{"_105":263,"_97":264,"_167":265,"_169":-5,"_170":148,"_171":266,"_173":174,"_107":267,"_102":33,"_176":191,"_178":268,"_180":22,"_181":-5,"_182":269,"_100":270},"c975e122-1e9c-11f1-8d2b-42dde27851f2","logger.ts","c975e1ea-1e9c-11f1-8d2b-42dde27851f2",69,["D",1773379416877],"/**\n * Logger — Ghi log chi tiết vào SQLite + console\n * Mỗi log có: timestamp, level, step, account index, message, data\n */\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n// ── Levels ────────────────────────────────────────────\nexport type LogLevel = \"info\" | \"success\" | \"warn\" | \"error\" | \"debug\" | \"step\";\n\n// ── Icons cho từng level ──────────────────────────────\nconst ICONS: Record = {\n step: \"🔷\",\n info: \"ℹ️ \",\n success: \"✅\",\n warn: \"⚠️ \",\n error: \"❌\",\n debug: \"🔍\",\n};\n\n// ── Đảm bảo bảng log tồn tại ─────────────────────────\nlet tableReady = false;\nasync function ensureTable() {\n if (tableReady) return;\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS run_logs (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n runId TEXT NOT NULL,\n accIndex INTEGER DEFAULT 0,\n accName TEXT DEFAULT '',\n level TEXT DEFAULT 'info',\n step TEXT DEFAULT '',\n message TEXT NOT NULL,\n data TEXT DEFAULT '',\n ms INTEGER DEFAULT 0,\n createdAt TEXT DEFAULT (datetime('now'))\n )\n `);\n tableReady = true;\n}\n\n// ── Logger class ──────────────────────────────────────\nexport class Logger {\n runId: string;\n accIndex: number;\n accName: string;\n private stepStart: number = Date.now();\n private runStart: number = Date.now();\n private currentStep: string = \"\";\n\n constructor(runId: string, accIndex = 0, accName = \"\") {\n this.runId = runId;\n this.accIndex = accIndex;\n this.accName = accName;\n }\n\n // ── Ghi 1 dòng log ──────────────────────────────────\n async log(\n level: LogLevel,\n message: string,\n data?: any,\n step?: string\n ) {\n await ensureTable();\n\n const ms = Date.now() - this.stepStart;\n const elapsed = Date.now() - this.runStart;\n const stepLabel = step || this.currentStep;\n const dataStr = data !== undefined ? JSON.stringify(data, null, 2) : \"\";\n const icon = ICONS[level];\n\n // Console output — đẹp và chi tiết\n const prefix = `[${this.accIndex.toString().padStart(2, \"0\")}][${this.accName.slice(0, 18).padEnd(18)}]`;\n const stepPfx = stepLabel ? `[${stepLabel}]` : \"\";\n const timePfx = `[+${(elapsed / 1000).toFixed(1)}s]`;\n const msInfo = level !== \"info\" ? ` (${ms}ms)` : \"\";\n\n console.log(`${icon} ${prefix}${stepPfx}${timePfx} ${message}${msInfo}`);\n if (dataStr && level !== \"debug\") {\n console.log(` └─ ${dataStr.replace(/\\n/g, \"\\n └─ \")}`);\n }\n\n // Ghi vào DB\n try {\n await sqlite.execute({\n sql: `INSERT INTO run_logs (runId, accIndex, accName, level, step, message, data, ms)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [this.runId, this.accIndex, this.accName, level, stepLabel, message, dataStr, ms],\n });\n } catch { /* không crash nếu DB lỗi */ }\n\n this.stepStart = Date.now();\n }\n\n // ── Shorthand methods ────────────────────────────────\n async step(stepName: string, message?: string) {\n this.currentStep = stepName;\n this.stepStart = Date.now();\n await this.log(\"step\", message || `━━ ${stepName} ━━`);\n }\n\n async info (msg: string, data?: any) { await this.log(\"info\", msg, data); }\n async success(msg: string, data?: any) { await this.log(\"success\", msg, data); }\n async warn (msg: string, data?: any) { await this.log(\"warn\", msg, data); }\n async error (msg: string, data?: any) { await this.log(\"error\", msg, data); }\n async debug (msg: string, data?: any) { await this.log(\"debug\", msg, data); }\n\n // ── Tóm tắt kết quả cuối ────────────────────────────\n async summary(status: \"success\" | \"failed\", detail?: string) {\n const total = ((Date.now() - this.runStart) / 1000).toFixed(1);\n const msg = status === \"success\"\n ? `HOÀN THÀNH THÀNH CÔNG sau ${total}s`\n : `THẤT BẠI sau ${total}s — ${detail || \"\"}`;\n await this.log(status === \"success\" ? \"success\" : \"error\", msg);\n }\n\n // ── Tạo child logger cho account khác ───────────────\n child(accIndex: number, accName: string): Logger {\n return new Logger(this.runId, accIndex, accName);\n }\n}\n\n// ── Factory: tạo runId theo thời gian ────────────────\nexport function createRunId(): string {\n return `run_${new Date().toISOString().replace(/[:.]/g, \"-\").slice(0, 19)}`;\n}\n\n// ── Đọc log từ DB (dùng cho dashboard) ───────────────\nexport async function getRunLogs(runId?: string, limit = 500) {\n await ensureTable();\n const sql = runId\n ? `SELECT * FROM run_logs WHERE runId = ? ORDER BY id DESC LIMIT ${limit}`\n : `SELECT * FROM run_logs ORDER BY id DESC LIMIT ${limit}`;\n const args = runId ? [runId] : [];\n const r = await sqlite.execute({ sql, args });\n return r.rows;\n}\n\nexport async function listRuns(limit = 20) {\n await ensureTable();\n const r = await sqlite.execute(`\n SELECT runId,\n MIN(createdAt) as startedAt,\n MAX(createdAt) as lastAt,\n COUNT(*) as totalLogs,\n SUM(CASE WHEN level='error' THEN 1 ELSE 0 END) as errors,\n SUM(CASE WHEN level='success' THEN 1 ELSE 0 END) as successes\n FROM run_logs\n GROUP BY runId\n ORDER BY startedAt DESC\n LIMIT ${limit}\n `);\n return r.rows;\n}\n\nexport async function clearRunLogs(runId?: string) {\n await ensureTable();\n if (runId) {\n await sqlite.execute({ sql: \"DELETE FROM run_logs WHERE runId = ?\", args: [runId] });\n } else {\n await sqlite.execute(\"DELETE FROM run_logs\");\n }\n}\n",[],[264],{"_105":272,"_97":273,"_167":274,"_169":-5,"_170":148,"_171":172,"_173":174,"_107":275,"_102":33,"_176":191,"_178":276,"_180":22,"_181":-5,"_182":277,"_100":278},"bd11d1ea-1ca6-11f1-9aa4-42dde27851f2","playwright.ts","019cd8cc-39b7-750b-a53a-a3fd6affd087",["D",1773163788597],"import \"https://esm.town/v/wolf/StubFS/stubFs.ts\";\nimport { chromium } from \"npm:playwright-core\";\nimport Kernel from \"npm:@onkernel/sdk\";\n\nconst kernel = new Kernel();\n\nconst kernelBrowser = await kernel.browsers.create();\nconst browser = await chromium.connectOverCDP(kernelBrowser.cdp_ws_url);\ntry {\n const context = browser.contexts()[0] || (await browser.newContext());\n const page = context.pages()[0] || (await context.newPage());\n await page.goto(\"https://www.wikipedia.org/\");\n const title = await page.title();\n console.log(title);\n} catch (error) {\n console.error(error);\n} finally {\n await browser.close();\n await kernel.browsers.deleteByID(kernelBrowser.session_id);\n}",[],[273],{"_105":280,"_97":281,"_167":282,"_169":-5,"_170":148,"_171":172,"_173":174,"_107":283,"_102":33,"_176":191,"_178":284,"_180":22,"_181":-5,"_182":285,"_100":286},"bd11d78a-1ca6-11f1-9aa4-42dde27851f2","puppeteer.ts","019cd8cc-39b7-750b-a53a-a701672d4cd8",["D",1773163788597],"import Kernel from \"npm:@onkernel/sdk\";\nimport { PuppeteerDeno } from \"https://deno.land/x/puppeteer@16.2.0/src/deno/Puppeteer.ts\";\n\nconst kernel = new Kernel();\n\nconst kernelBrowser = await kernel.browsers.create();\n\nconst puppeteer = new PuppeteerDeno({\n productName: \"chrome\",\n preferredRevision: null,\n});\nconst browser = await puppeteer.connect({\n browserWSEndpoint: kernelBrowser.cdp_ws_url,\n defaultViewport: null, // Optional: inherit viewport from the browser\n});\ntry {\n const page = await browser.newPage();\n await page.goto(\"https://en.wikipedia.org/wiki/OpenAI\");\n const intro = await page.evaluate(\n `document.querySelector('p:nth-of-type(2)').innerText`,\n );\n console.log(intro);\n} catch (error) {\n console.error(error);\n} finally {\n await browser.close();\n await kernel.browsers.deleteByID(kernelBrowser.session_id);\n}",[],[281],{"_105":288,"_97":289,"_167":290,"_169":-5,"_170":148,"_171":291,"_173":174,"_107":292,"_102":33,"_176":191,"_178":293,"_180":22,"_181":-5,"_182":294,"_100":295},"babdb842-1caf-11f1-ad51-42dde27851f2","results.ts","babdb93c-1caf-11f1-ad51-42dde27851f2",7,["D",1773167650292],"/**\n * Results Storage\n * Lưu kết quả đăng ký tài khoản eBay vào SQLite\n */\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport type RegistrationStatus = \"success\" | \"failed\" | \"pending\";\n\nexport interface RegistrationResult {\n email: string;\n firstName: string;\n lastName: string;\n businessName: string;\n status: RegistrationStatus;\n ebayUsername?: string;\n errorMessage?: string;\n}\n\nexport async function initResultsDB() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ebay_registrations (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n email TEXT NOT NULL,\n firstName TEXT,\n lastName TEXT,\n businessName TEXT,\n status TEXT DEFAULT 'pending',\n ebayUsername TEXT,\n errorMessage TEXT,\n createdAt TEXT DEFAULT (datetime('now'))\n )\n `);\n console.log(\"✅ Database sẵn sàng\");\n}\n\nexport async function saveResult(data: RegistrationResult) {\n await sqlite.execute({\n sql: `INSERT INTO ebay_registrations\n (email, firstName, lastName, businessName, status, ebayUsername, errorMessage)\n VALUES (?, ?, ?, ?, ?, ?, ?)`,\n args: [\n data.email,\n data.firstName,\n data.lastName,\n data.businessName,\n data.status,\n data.ebayUsername ?? null,\n data.errorMessage ?? null,\n ],\n });\n}\n\nexport async function getResults() {\n return await sqlite.execute(\n \"SELECT * FROM ebay_registrations ORDER BY createdAt DESC\"\n );\n}\n\nexport async function printSummary() {\n const res = await sqlite.execute(`\n SELECT status, COUNT(*) as count\n FROM ebay_registrations\n GROUP BY status\n `);\n console.log(\"\\n📊 TỔNG KẾT ĐĂNG KÝ:\");\n for (const row of res.rows) {\n const icon = row.status === \"success\" ? \"✅\" : row.status === \"failed\" ? \"❌\" : \"⏳\";\n console.log(` ${icon} ${row.status}: ${row.count}`);\n }\n}\n\nif (import.meta.main) {\n await initResultsDB();\n const all = await getResults();\n console.log(`Tổng số bản ghi: ${all.rows.length}`);\n}\n",[],[289],{"_105":297,"_97":298,"_167":299,"_169":-5,"_170":148,"_171":300,"_173":174,"_107":301,"_102":302,"_176":191,"_178":303,"_180":22,"_181":-5,"_182":304,"_100":305},"1426d2be-1ec3-11f1-9a8f-42dde27851f2","sheets.ts","9d788208-1caf-11f1-bb20-42dde27851f2",91,["D",1773395863048],14,"/**\n * Google Sheets Reader + Writer\n * CSV URL: gid=270738883\n *\n * Header thực tế (dòng 1):\n * mail, link view, business_name, ein, busines_street, business_city,\n * business_state, business_zip, First Name, Last Name, SSN, DOB,\n * DL Number, Address, City, State, Zip, Bank Name, Account Type,\n * Routing Number, Account Number\n *\n * Index:\n * 0 = mail\n * 1 = link view\n * 2 = business_name\n * 3 = ein\n * 4 = busines_street\n * 5 = business_city\n * 6 = business_state\n * 7 = business_zip\n * 8 = First Name\n * 9 = Last Name\n * 10 = SSN\n * 11 = DOB\n * 12 = DL Number\n * 13 = Address\n * 14 = City\n * 15 = State\n * 16 = Zip\n * 17 = Bank Name\n * 18 = Account Type\n * 19 = Routing Number\n * 20 = Account Number\n */\n\n// ── Cấu hình ──────────────────────────────────────────\nconst SHEETS_CSV_URL =\n \"https://docs.google.com/spreadsheets/d/e/2PACX-1vRnJi0p7fc3CEsGeV2axPwEo8mqZm3yYBIKQj2Ly70KV4WGScHXx7TjyE30-EaI2itFbuABgFgCZSog/pub?gid=270738883&single=true&output=csv\";\n\nconst SHEET_NAME = Deno.env.get(\"GOOGLE_SHEET_NAME\") || \"Sheet1\";\n\n// Cột mail = A (index 0)\nconst MAIL_COLUMN_LETTER = \"A\";\nconst MAIL_COLUMN_INDEX = 0;\n\n// ── Types ──────────────────────────────────────────────\nexport interface AccountData {\n rowIndex: number; // hàng thực trong sheet (bắt đầu từ 2)\n mail: string; // col 0 — mail (rỗng = chưa xử lý)\n linkView: string; // col 1 — link view\n businessName: string; // col 2 — business_name\n ein: string; // col 3 — ein\n businessStreet: string; // col 4 — busines_street\n businessCity: string; // col 5 — business_city\n businessState: string; // col 6 — business_state\n businessZip: string; // col 7 — business_zip\n firstName: string; // col 8 — First Name\n lastName: string; // col 9 — Last Name\n ssn: string; // col 10 — SSN\n dob: string; // col 11 — DOB\n dlNumber: string; // col 12 — DL Number\n address: string; // col 13 — Address\n city: string; // col 14 — City\n state: string; // col 15 — State\n zip: string; // col 16 — Zip\n bankName: string; // col 17 — Bank Name\n accountType: string; // col 18 — Account Type\n routingNumber: string; // col 19 — Routing Number\n accountNumber: string; // col 20 — Account Number\n // Derived\n password: string; // tạo từ SSN\n}\n\n// ─────────────────────────────────────────────────────\n// ĐỌC: Fetch dữ liệu từ Google Sheets CSV\n// ─────────────────────────────────────────────────────\nexport async function fetchAccountsFromSheets(): Promise {\n const res = await fetch(SHEETS_CSV_URL);\n if (!res.ok) throw new Error(`Sheets error: ${res.status} ${res.statusText}`);\n\n const csv = await res.text();\n // Bỏ \\r nếu có (Windows line ending)\n const lines = csv.trim().replace(/\\r/g, \"\").split(\"\\n\");\n if (lines.length < 2) throw new Error(\"Sheet trống hoặc không có dữ liệu\");\n\n // Dòng đầu làm header — tách bằng dấu phẩy\n const headers = lines[0].split(\",\").map(h => h.trim().replace(/\"/g, \"\"));\n console.log(`📋 Headers (${headers.length} cột): ${headers.join(\" | \")}`);\n\n const accounts: AccountData[] = [];\n\n for (let i = 1; i < lines.length; i++) {\n const line = lines[i].trim();\n if (!line) continue; // bỏ dòng trống\n\n const values = parseCSVLine(line);\n const v = (idx: number) => values[idx]?.trim().replace(/^\"|\"$/g, \"\") || \"\";\n\n // Bỏ qua dòng đã có mail (cột 0 không rỗng)\n if (v(MAIL_COLUMN_INDEX) !== \"\") {\n console.log(` ⏭️ Dòng ${i + 1}: đã có mail (${v(MAIL_COLUMN_INDEX)}), bỏ qua`);\n continue;\n }\n\n // Bỏ qua dòng không có dữ liệu tối thiểu\n if (!v(2) && !v(8)) {\n console.log(` ⏭️ Dòng ${i + 1}: trống hoàn toàn, bỏ qua`);\n continue;\n }\n\n const account: AccountData = {\n rowIndex: i + 1, // hàng thực (header = hàng 1, data từ hàng 2)\n mail: v(0),\n linkView: v(1),\n businessName: v(2),\n ein: v(3),\n businessStreet: v(4),\n businessCity: v(5),\n businessState: v(6),\n businessZip: v(7),\n firstName: v(8),\n lastName: v(9),\n ssn: v(10),\n dob: v(11),\n dlNumber: v(12),\n address: v(13),\n city: v(14),\n state: v(15),\n zip: v(16),\n bankName: v(17),\n accountType: v(18),\n routingNumber: v(19),\n accountNumber: v(20),\n // Password mặc định\n password: \"Aa11111@\",\n };\n\n console.log(` ✅ Dòng ${i + 1}: ${account.firstName} ${account.lastName} | ${account.businessName}`);\n accounts.push(account);\n }\n\n console.log(`\\n✅ Đọc được ${accounts.length} tài khoản chưa có mail\\n`);\n return accounts;\n}\n\n// ─────────────────────────────────────────────────────\n// GHI: Cập nhật mail vào cột A qua Apps Script Webhook\n// ─────────────────────────────────────────────────────\nconst APPS_SCRIPT_URL =\n Deno.env.get(\"GOOGLE_APPS_SCRIPT_URL\") ||\n \"https://script.google.com/macros/s/AKfycbyi5GoKGwII8OrSqxZ0zUQfUvA4dMbWTsp9-7p-PmPybl3s2ypdC52Fop71OWxNQNemsg/exec\";\n\nexport async function updateEmailInSheet(\n rowIndex: number,\n email: string,\n sheetName = SHEET_NAME\n): Promise {\n if (!APPS_SCRIPT_URL) {\n console.warn(\"⚠️ GOOGLE_APPS_SCRIPT_URL chưa cấu hình — bỏ qua ghi Sheets\");\n return false;\n }\n\n try {\n const resp = await fetch(APPS_SCRIPT_URL, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n rowIndex, // hàng cần ghi\n email, // email @duck.com\n sheetName, // tên tab\n mailColumn: MAIL_COLUMN_LETTER, // cột A\n }),\n redirect: \"follow\",\n });\n\n const text = await resp.text();\n let result: { ok?: boolean; error?: string; message?: string };\n try { result = JSON.parse(text); }\n catch { result = { error: text }; }\n\n if (result.ok) {\n console.log(` ✅ Sheets ghi OK: ${result.message || `hàng ${rowIndex}`}`);\n return true;\n } else {\n console.error(` ❌ Sheets webhook lỗi: ${result.error || text}`);\n return false;\n }\n } catch (e) {\n console.error(` ❌ Lỗi gọi Apps Script: ${(e as Error).message}`);\n return false;\n }\n}\n\n// ─────────────────────────────────────────────────────\n// Helper: parse 1 dòng CSV xử lý đúng dấu ngoặc kép\n// ─────────────────────────────────────────────────────\nfunction parseCSVLine(line: string): string[] {\n const result: string[] = [];\n let current = \"\";\n let inQuotes = false;\n\n for (let i = 0; i < line.length; i++) {\n const char = line[i];\n if (char === '\"') {\n // Escaped quote \"\"\n if (inQuotes && line[i + 1] === '\"') {\n current += '\"';\n i++;\n } else {\n inQuotes = !inQuotes;\n }\n } else if (char === \",\" && !inQuotes) {\n result.push(current.trim());\n current = \"\";\n } else {\n current += char;\n }\n }\n result.push(current.trim());\n return result;\n}\n\n// ─────────────────────────────────────────────────────\n// Test: chạy trực tiếp file này để kiểm tra\n// ─────────────────────────────────────────────────────\nif (import.meta.main) {\n console.log(\"🧪 Test đọc CSV...\\n\");\n const accounts = await fetchAccountsFromSheets();\n console.log(`\\nTổng: ${accounts.length} tài khoản`);\n if (accounts[0]) {\n console.log(\"\\n--- Tài khoản đầu tiên ---\");\n console.log(JSON.stringify(accounts[0], null, 2));\n }\n}\n",[],[298],{"_105":307,"_97":308,"_167":309,"_169":-5,"_170":148,"_171":310,"_173":174,"_107":311,"_102":240,"_176":191,"_178":312,"_180":22,"_181":-5,"_182":313,"_100":314},"359bc49e-1e65-11f1-912e-42dde27851f2","testSheets.ts","f4007f40-1e62-11f1-9450-42dde27851f2",62,["D",1773355546473],"// Test đọc dữ liệu từ Google Sheets CSV\nconst SHEETS_CSV_URL =\n \"https://docs.google.com/spreadsheets/d/e/2PACX-1vRnJi0p7fc3CEsGeV2axPwEo8mqZm3yYBIKQj2Ly70KV4WGScHXx7TjyE30-EaI2itFbuABgFgCZSog/pub?gid=169016620&single=true&output=csv\";\n\nconst MAIL_COLUMN_INDEX = 18; // cột S (0-indexed)\n\nfunction parseCSVLine(line: string): string[] {\n const result: string[] = [];\n let current = \"\";\n let inQuotes = false;\n for (const char of line) {\n if (char === '\"') inQuotes = !inQuotes;\n else if (char === \",\" && !inQuotes) { result.push(current.trim()); current = \"\"; }\n else current += char;\n }\n result.push(current.trim());\n return result;\n}\n\ntry {\n const res = await fetch(SHEETS_CSV_URL, {\n headers: {\n \"Accept\": \"text/csv,text/plain,*/*\",\n \"User-Agent\": \"Mozilla/5.0 (compatible; bot/1.0)\",\n },\n redirect: \"follow\",\n });\n\n console.log(`HTTP Status: ${res.status}`);\n console.log(`Content-Type: ${res.headers.get(\"content-type\")}`);\n\n const csv = await res.text();\n\n // Kiểm tra có phải HTML không\n if (csv.trim().startsWith(\" {\n console.log(` ${String.fromCharCode(65 + i)}(${i}) = \"${h}\"`);\n });\n\n console.log(`\\n📊 Dữ liệu:`);\n let pending = 0;\n 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\n const values = parseCSVLine(line);\n const v = (idx: number) => values[idx]?.trim() || \"\";\n\n const business = v(0);\n const firstName = v(7);\n const lastName = v(8);\n const ssn = v(9);\n const email = v(MAIL_COLUMN_INDEX);\n\n if (!business) continue;\n\n const passLast4 = ssn.replace(/[^0-9]/g, \"\").slice(-4) || \"????\";\n\n if (email !== \"\") {\n done++;\n console.log(`✅ Dòng ${i + 1}: [${business}] ${firstName} ${lastName} → ${email}`);\n } else {\n pending++;\n console.log(`⏳ Dòng ${i + 1}: [${business}] ${firstName} ${lastName} → chưa có email (pass ends: ...${passLast4})`);\n }\n }\n\n console.log(`\\n📈 Kết quả:`);\n console.log(` ✅ Đã có email (đã đăng ký): ${done}`);\n console.log(` ⏳ Chưa có email (cần đăng ký): ${pending}`);\n }\n} catch (e) {\n console.error(\"❌ Lỗi:\", (e as Error).message);\n}\n",[],[308],"files",[164,185,195,204,214,223,234,244,254,262,271,279,287,296,306],"counts",{"_319":33,"_320":172,"_321":33,"_322":323,"_327":328},"pulls","branches","forks","envVars",{"_324":325,"_326":33},"count",11,"emptyCount","connections",{"_324":33,"_329":33},"unfilledCount","contents",[],{"_105":196,"_97":101,"_167":197,"_169":-5,"_170":148,"_171":198,"_173":174,"_107":333,"_102":200,"_176":191,"_178":201,"_180":22,"_181":-5,"_100":334},["D",1773379880304],[101],"upstreamProject",{"_105":156,"_97":98,"_113":114,"_115":-5,"_111":112,"_23":337},{"_95":338,"_138":339},"onkernel","https://imagedelivery.net/iHX6Ovru0O7AjmyT5yZRoA/b0ca5b6d-1128-43ec-0542-59ec2f324200/square512","upstreamBranch",{"_105":151,"_107":342,"_343":344,"_97":45,"_149":156,"_102":153,"_150":-5,"_152":-5,"_345":346,"_109":-5,"_161":22,"_111":112,"_160":338,"_16":158,"_159":98},["D",1757615194853],"updatedAt",["D",1758305152093],"lockfileKey","1759418522490-esm.town_v_onkernel_kernel_starter@20-main","emptyEnvVars","isNew","flags",[],"routes/_app.x.$handle.$name.branch.$branch.history_.$",{"_95":96,"_97":98,"_99":45,"_100":101,"_103":353,"_177":358,"_361":362,"_379":380,"_386":33,"_387":33,"_388":22},{"_105":106,"_97":98,"_107":354,"_109":-5,"_110":22,"_111":112,"_113":114,"_115":-5,"_14":116,"_117":-5,"_118":22,"_119":-5,"_120":-5,"_121":33,"_16":122,"_123":124,"_125":126,"_127":-5,"_128":129,"_130":129,"_131":132,"_133":132,"_134":132,"_135":129,"_136":129,"_23":355,"_140":356,"_145":357,"_161":22},["D",1773163788597],{"_95":96,"_138":139},{"_95":96,"_142":139,"_14":116,"_143":144},{"_102":147,"_97":45,"_105":148,"_149":106,"_150":151,"_152":153,"_154":112,"_155":156,"_157":158,"_159":98,"_160":96},{"_105":196,"_97":101,"_167":197,"_169":-5,"_170":148,"_171":198,"_173":174,"_107":359,"_102":200,"_176":191,"_178":201,"_180":22,"_181":-5,"_100":360},["D",1773379880304],[101],"history",[363,365,370,374],{"_105":196,"_170":148,"_167":197,"_97":101,"_178":201,"_176":191,"_102":200,"_169":-5,"_107":364,"_171":198,"_181":-5},["D",1773379880304],{"_105":366,"_170":148,"_167":197,"_97":101,"_178":367,"_176":191,"_102":368,"_169":-5,"_107":369,"_171":250,"_181":-5},"50f3d3fe-1e23-11f1-94bf-42dde27851f2","/**\n * PHASE 1 — AI AGENT TỰ HỌC QUY TRÌNH ĐĂNG KÝ EBAY\n * ====================================================\n * AI Agent dùng ngôn ngữ tự nhiên điều khiển browser,\n * tự khám phá từng bước, ghi lại playbook vào SQLite.\n *\n * Chạy file này 1 LẦN DUY NHẤT để học quy trình.\n * Sau đó dùng agentReplay.ts để chạy hàng loạt.\n */\n\nimport \"https://esm.town/v/wolf/StubFS/stubFs.ts\";\nimport { chromium } from \"npm:playwright-core\";\nimport Kernel from \"npm:@onkernel/sdk\";\nimport OpenAI from \"npm:openai\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n// ── Cấu hình AI ──────────────────────────────────────\nconst AI_API_KEY = Deno.env.get(\"AI_API_KEY\") || \"\";\nconst AI_BASE_URL = Deno.env.get(\"AI_BASE_URL\") || \"\";\nconst AI_MODEL = Deno.env.get(\"AI_MODEL\") || \"qwen2.5-72b-instruct\";\n\n// ── Tài khoản TEST dùng để học (không cần thật) ──────\nconst TEST_ACCOUNT = {\n firstName: \"John\",\n lastName: \"Smith\",\n businessName: \"Smith Trading LLC\",\n email: \"test_learn@duck.com\",\n password: \"TestPass@2025!\",\n phone: \"2125551234\",\n};\n\n// ── URL đăng ký eBay Business US ─────────────────────\nconst EBAY_URL = \"https://reg.ebay.com/reg/RegistrationPage?ru=https://www.ebay.com/&bizflow=3\";\n\n// ─────────────────────────────────────────────────────\n// Khởi tạo bảng playbook trong SQLite\n// ─────────────────────────────────────────────────────\nasync function initPlaybookDB() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ebay_playbook (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n stepOrder INTEGER NOT NULL,\n action TEXT NOT NULL,\n description TEXT NOT NULL,\n selector TEXT,\n value TEXT,\n fieldKey TEXT,\n waitMs INTEGER DEFAULT 500,\n createdAt TEXT DEFAULT (datetime('now'))\n )\n `);\n // Xóa playbook cũ nếu có (học lại từ đầu)\n await sqlite.execute(\"DELETE FROM ebay_playbook\");\n console.log(\"🗄️ Bảng playbook đã sẵn sàng (đã xóa dữ liệu cũ)\");\n}\n\n// ─────────────────────────────────────────────────────\n// Lưu 1 step vào playbook\n// ─────────────────────────────────────────────────────\nasync function saveStep(step: {\n stepOrder: number;\n action: string;\n description: string;\n selector?: string;\n value?: string;\n fieldKey?: string;\n waitMs?: number;\n}) {\n await sqlite.execute({\n sql: `INSERT INTO ebay_playbook (stepOrder, action, description, selector, value, fieldKey, waitMs)\n VALUES (?, ?, ?, ?, ?, ?, ?)`,\n args: [\n step.stepOrder,\n step.action,\n step.description,\n step.selector ?? null,\n step.value ?? null,\n step.fieldKey ?? null,\n step.waitMs ?? 500,\n ],\n });\n}\n\n// ─────────────────────────────────────────────────────\n// Dùng AI để tìm selector phù hợp trên trang\n// ─────────────────────────────────────────────────────\nasync function findSelectorWithAI(\n ai: OpenAI,\n pageHTML: string,\n taskDescription: string\n): Promise<{ selector: string; confidence: string }> {\n const response = await ai.chat.completions.create({\n model: AI_MODEL,\n messages: [\n {\n role: \"system\",\n content: `Bạn là chuyên gia phân tích HTML và CSS selector.\nNhiệm vụ: Tìm CSS selector chính xác nhất cho phần tử được yêu cầu trong HTML.\nChỉ trả về JSON object, không giải thích thêm.\nFormat: {\"selector\": \"...\", \"confidence\": \"high|medium|low\"}`,\n },\n {\n role: \"user\",\n content: `Tìm selector cho: \"${taskDescription}\"\n\nHTML (rút gọn):\n${pageHTML.slice(0, 8000)}\n\nTrả về JSON:`,\n },\n ],\n temperature: 0.1,\n max_tokens: 200,\n });\n\n try {\n const text = response.choices[0].message.content || \"{}\";\n const json = text.match(/\\{.*\\}/s)?.[0] || \"{}\";\n return JSON.parse(json);\n } catch {\n return { selector: \"\", confidence: \"low\" };\n }\n}\n\n// ─────────────────────────────────────────────────────\n// AI phân tích kết quả đăng ký thành công hay chưa\n// ─────────────────────────────────────────────────────\nasync function analyzeResultWithAI(\n ai: OpenAI,\n url: string,\n pageTitle: string,\n pageText: string\n): Promise<{ success: boolean; reason: string }> {\n const response = await ai.chat.completions.create({\n model: AI_MODEL,\n messages: [\n {\n role: \"system\",\n content: `Bạn phân tích kết quả đăng ký tài khoản eBay.\nTrả về JSON: {\"success\": true/false, \"reason\": \"giải thích ngắn\"}`,\n },\n {\n role: \"user\",\n content: `URL hiện tại: ${url}\nTitle trang: ${pageTitle}\nNội dung trang (500 ký tự đầu): ${pageText.slice(0, 500)}\n\nĐăng ký thành công chưa?`,\n },\n ],\n temperature: 0.1,\n max_tokens: 150,\n });\n\n try {\n const text = response.choices[0].message.content || \"{}\";\n const json = text.match(/\\{.*\\}/s)?.[0] || \"{}\";\n return JSON.parse(json);\n } catch {\n return { success: false, reason: \"Không phân tích được\" };\n }\n}\n\n// ─────────────────────────────────────────────────────\n// MAIN — AI Agent học quy trình\n// ─────────────────────────────────────────────────────\nconsole.log(\"🤖 PHASE 1: AI Agent bắt đầu học quy trình đăng ký eBay Business...\\n\");\n\nconst ai = new OpenAI({ apiKey: AI_API_KEY, baseURL: AI_BASE_URL });\nconst kernel = new Kernel();\n\nawait initPlaybookDB();\n\nconst kernelBrowser = await kernel.browsers.create();\n\n// Lưu session vào DB để Live View theo dõi được\nawait 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`);\nawait sqlite.execute({\n sql: `INSERT OR REPLACE INTO browser_sessions (sessionId, liveViewUrl, cdpWsUrl, label, status)\n VALUES (?,?,?,?,'active')`,\n args: [kernelBrowser.session_id, kernelBrowser.browser_live_view_url, kernelBrowser.cdp_ws_url, \"🧠 AI Learn Session\"],\n});\nconsole.log(`\\n🔴 LIVE VIEW: ${kernelBrowser.browser_live_view_url}`);\nconsole.log(`→ Hoặc xem tại Dashboard: /live?session=${kernelBrowser.session_id}\\n`);\n\nconst browser = await chromium.connectOverCDP(kernelBrowser.cdp_ws_url);\nlet stepOrder = 1;\n\ntry {\n const context = browser.contexts()[0] || await browser.newContext({\n userAgent: \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/122.0.0.0 Safari/537.36\",\n locale: \"en-US\",\n timezoneId: \"America/New_York\",\n });\n const page = context.pages()[0] || await context.newPage();\n await page.setViewportSize({ width: 1280, height: 900 });\n\n // ── STEP 1: Mở trang đăng ký ────────────────────────\n console.log(`[Step ${stepOrder}] 🌐 Mở trang đăng ký eBay...`);\n await page.goto(EBAY_URL, { waitUntil: \"networkidle\", timeout: 30000 });\n await page.waitForTimeout(2000);\n await saveStep({\n stepOrder: stepOrder++,\n action: \"goto\",\n description: \"Mở trang đăng ký eBay Business US\",\n value: EBAY_URL,\n waitMs: 2000,\n });\n\n // ── STEP 2: AI tìm và click tab Business ────────────\n console.log(`[Step ${stepOrder}] 🤖 AI đang tìm tab Business account...`);\n let html = await page.content();\n const bizTabResult = await findSelectorWithAI(\n ai, html,\n \"tab hoặc link để chuyển sang đăng ký Business account (không phải Personal)\"\n );\n console.log(` → Selector tìm được: \"${bizTabResult.selector}\" (${bizTabResult.confidence})`);\n\n if (bizTabResult.selector && bizTabResult.confidence !== \"low\") {\n try {\n await page.click(bizTabResult.selector, { timeout: 5000 });\n await page.waitForTimeout(1500);\n console.log(` ✅ Đã click tab Business`);\n await saveStep({\n stepOrder: stepOrder++,\n action: \"click\",\n description: \"Click tab Business account\",\n selector: bizTabResult.selector,\n waitMs: 1500,\n });\n } catch {\n console.log(` ⚠️ Không click được, thử selector dự phòng...`);\n for (const sel of ['a:has-text(\"Business\")', '[data-testid=\"business-reg-tab\"]']) {\n try {\n await page.click(sel, { timeout: 3000 });\n await page.waitForTimeout(1500);\n await saveStep({ stepOrder: stepOrder++, action: \"click\", description: \"Click tab Business account (fallback)\", selector: sel, waitMs: 1500 });\n break;\n } catch { /* thử tiếp */ }\n }\n }\n }\n\n // ── STEP 3-8: AI tìm từng trường form ───────────────\n html = await page.content(); // lấy HTML mới sau khi đổi tab\n\n const fields = [\n { key: \"businessName\", desc: \"input field để nhập tên doanh nghiệp / Business name / Legal business name\", value: TEST_ACCOUNT.businessName },\n { key: \"firstName\", desc: \"input field để nhập First name / Tên\", value: TEST_ACCOUNT.firstName },\n { key: \"lastName\", desc: \"input field để nhập Last name / Họ\", value: TEST_ACCOUNT.lastName },\n { key: \"email\", desc: \"input field để nhập Email address\", value: TEST_ACCOUNT.email },\n { key: \"username\", desc: \"input field để nhập Username / User ID cho tài khoản eBay\", value: TEST_ACCOUNT.email.split(\"@\")[0] },\n { key: \"password\", desc: \"input field để nhập Password (type=password)\", value: TEST_ACCOUNT.password },\n { key: \"phone\", desc: \"input field để nhập số điện thoại / Phone number\", value: TEST_ACCOUNT.phone },\n ];\n\n for (const field of fields) {\n console.log(`[Step ${stepOrder}] 🤖 AI tìm field \"${field.key}\"...`);\n const result = await findSelectorWithAI(ai, html, field.desc);\n console.log(` → Selector: \"${result.selector}\" (${result.confidence})`);\n\n if (result.selector) {\n try {\n const el = page.locator(result.selector).first();\n const visible = await el.isVisible({ timeout: 3000 }).catch(() => false);\n if (visible) {\n await el.fill(field.value);\n console.log(` ✅ Đã điền \"${field.key}\": ${field.key === \"password\" ? \"***\" : field.value}`);\n await saveStep({\n stepOrder: stepOrder++,\n action: \"fill\",\n description: `Điền trường ${field.key}`,\n selector: result.selector,\n fieldKey: field.key,\n waitMs: 300,\n });\n } else {\n console.log(` ⚠️ Field \"${field.key}\" không visible, bỏ qua`);\n }\n } catch (e) {\n console.log(` ❌ Lỗi điền \"${field.key}\": ${e.message}`);\n }\n }\n await page.waitForTimeout(300);\n }\n\n // ── STEP: AI tìm nút Submit ──────────────────────────\n console.log(`[Step ${stepOrder}] 🤖 AI tìm nút Submit / Create account...`);\n html = await page.content();\n const submitResult = await findSelectorWithAI(\n ai, html,\n \"button để submit form đăng ký, có text như 'Create account', 'Register', 'Submit'\"\n );\n console.log(` → Selector: \"${submitResult.selector}\" (${submitResult.confidence})`);\n\n if (submitResult.selector) {\n await saveStep({\n stepOrder: stepOrder++,\n action: \"click\",\n description: \"Click nút Submit / Create account\",\n selector: submitResult.selector,\n waitMs: 5000,\n });\n console.log(` ✅ Đã lưu bước submit`);\n }\n\n // ── STEP: Lưu bước kiểm tra kết quả ────────────────\n await saveStep({\n stepOrder: stepOrder++,\n action: \"check_result\",\n description: \"Kiểm tra đăng ký thành công hay thất bại\",\n waitMs: 3000,\n });\n\n // ── Thực tế SUBMIT để kiểm tra (optional) ───────────\n console.log(`\\n🔍 Thực hiện submit thử để xác nhận quy trình...`);\n if (submitResult.selector) {\n try {\n await page.click(submitResult.selector, { timeout: 5000 });\n await page.waitForTimeout(5000);\n\n const currentUrl = page.url();\n const pageTitle = await page.title();\n const pageText = await page.locator(\"body\").innerText().catch(() => \"\");\n\n const analysis = await analyzeResultWithAI(ai, currentUrl, pageTitle, pageText);\n if (analysis.success) {\n console.log(` ✅ Đăng ký thử THÀNH CÔNG: ${analysis.reason}`);\n } else {\n console.log(` ℹ️ Kết quả: ${analysis.reason}`);\n console.log(` (Bình thường nếu email đã tồn tại hoặc cần xác minh)`);\n }\n } catch (e) {\n console.log(` ⚠️ Submit thử: ${e.message}`);\n }\n }\n\n // ── In playbook đã lưu ───────────────────────────────\n const playbook = await sqlite.execute(\n \"SELECT * FROM ebay_playbook ORDER BY stepOrder\"\n );\n console.log(`\\n📖 PLAYBOOK ĐÃ HỌC (${playbook.rows.length} bước):`);\n console.log(\"─\".repeat(60));\n for (const row of playbook.rows) {\n console.log(` [${row.stepOrder}] ${row.action.toUpperCase().padEnd(12)} | ${row.description}`);\n if (row.selector) console.log(` selector: \"${row.selector}\"`);\n }\n console.log(\"─\".repeat(60));\n console.log(`\\n✅ PHASE 1 HOÀN TẤT! Playbook đã lưu vào database.`);\n console.log(`→ Bây giờ chạy agentReplay.ts để đăng ký hàng loạt!\\n`);\n\n} finally {\n await browser.close();\n await kernel.browsers.deleteByID(kernelBrowser.session_id);\n // Đánh dấu session đã đóng\n await sqlite.execute({\n sql: `UPDATE browser_sessions SET status='closed', closedAt=datetime('now') WHERE sessionId=?`,\n args: [kernelBrowser.session_id],\n });\n}\n",2,["D",1773327245568],{"_105":371,"_170":148,"_167":197,"_97":101,"_178":372,"_176":191,"_102":172,"_169":-5,"_107":373,"_171":153,"_181":-5},"4d62e1b2-1e23-11f1-98a5-42dde27851f2","/**\n * PHASE 1 — AI AGENT TỰ HỌC QUY TRÌNH ĐĂNG KÝ EBAY\n * ====================================================\n * AI Agent dùng ngôn ngữ tự nhiên điều khiển browser,\n * tự khám phá từng bước, ghi lại playbook vào SQLite.\n *\n * Chạy file này 1 LẦN DUY NHẤT để học quy trình.\n * Sau đó dùng agentReplay.ts để chạy hàng loạt.\n */\n\nimport \"https://esm.town/v/wolf/StubFS/stubFs.ts\";\nimport { chromium } from \"npm:playwright-core\";\nimport Kernel from \"npm:@onkernel/sdk\";\nimport OpenAI from \"npm:openai\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n// ── Cấu hình AI ──────────────────────────────────────\nconst AI_API_KEY = Deno.env.get(\"AI_API_KEY\") || \"\";\nconst AI_BASE_URL = Deno.env.get(\"AI_BASE_URL\") || \"\";\nconst AI_MODEL = Deno.env.get(\"AI_MODEL\") || \"qwen2.5-72b-instruct\";\n\n// ── Tài khoản TEST dùng để học (không cần thật) ──────\nconst TEST_ACCOUNT = {\n firstName: \"John\",\n lastName: \"Smith\",\n businessName: \"Smith Trading LLC\",\n email: \"test_learn@duck.com\",\n password: \"TestPass@2025!\",\n phone: \"2125551234\",\n};\n\n// ── URL đăng ký eBay Business US ─────────────────────\nconst EBAY_URL = \"https://reg.ebay.com/reg/RegistrationPage?ru=https://www.ebay.com/&bizflow=3\";\n\n// ─────────────────────────────────────────────────────\n// Khởi tạo bảng playbook trong SQLite\n// ─────────────────────────────────────────────────────\nasync function initPlaybookDB() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ebay_playbook (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n stepOrder INTEGER NOT NULL,\n action TEXT NOT NULL,\n description TEXT NOT NULL,\n selector TEXT,\n value TEXT,\n fieldKey TEXT,\n waitMs INTEGER DEFAULT 500,\n createdAt TEXT DEFAULT (datetime('now'))\n )\n `);\n // Xóa playbook cũ nếu có (học lại từ đầu)\n await sqlite.execute(\"DELETE FROM ebay_playbook\");\n console.log(\"🗄️ Bảng playbook đã sẵn sàng (đã xóa dữ liệu cũ)\");\n}\n\n// ─────────────────────────────────────────────────────\n// Lưu 1 step vào playbook\n// ─────────────────────────────────────────────────────\nasync function saveStep(step: {\n stepOrder: number;\n action: string;\n description: string;\n selector?: string;\n value?: string;\n fieldKey?: string;\n waitMs?: number;\n}) {\n await sqlite.execute({\n sql: `INSERT INTO ebay_playbook (stepOrder, action, description, selector, value, fieldKey, waitMs)\n VALUES (?, ?, ?, ?, ?, ?, ?)`,\n args: [\n step.stepOrder,\n step.action,\n step.description,\n step.selector ?? null,\n step.value ?? null,\n step.fieldKey ?? null,\n step.waitMs ?? 500,\n ],\n });\n}\n\n// ─────────────────────────────────────────────────────\n// Dùng AI để tìm selector phù hợp trên trang\n// ─────────────────────────────────────────────────────\nasync function findSelectorWithAI(\n ai: OpenAI,\n pageHTML: string,\n taskDescription: string\n): Promise<{ selector: string; confidence: string }> {\n const response = await ai.chat.completions.create({\n model: AI_MODEL,\n messages: [\n {\n role: \"system\",\n content: `Bạn là chuyên gia phân tích HTML và CSS selector.\nNhiệm vụ: Tìm CSS selector chính xác nhất cho phần tử được yêu cầu trong HTML.\nChỉ trả về JSON object, không giải thích thêm.\nFormat: {\"selector\": \"...\", \"confidence\": \"high|medium|low\"}`,\n },\n {\n role: \"user\",\n content: `Tìm selector cho: \"${taskDescription}\"\n\nHTML (rút gọn):\n${pageHTML.slice(0, 8000)}\n\nTrả về JSON:`,\n },\n ],\n temperature: 0.1,\n max_tokens: 200,\n });\n\n try {\n const text = response.choices[0].message.content || \"{}\";\n const json = text.match(/\\{.*\\}/s)?.[0] || \"{}\";\n return JSON.parse(json);\n } catch {\n return { selector: \"\", confidence: \"low\" };\n }\n}\n\n// ─────────────────────────────────────────────────────\n// AI phân tích kết quả đăng ký thành công hay chưa\n// ─────────────────────────────────────────────────────\nasync function analyzeResultWithAI(\n ai: OpenAI,\n url: string,\n pageTitle: string,\n pageText: string\n): Promise<{ success: boolean; reason: string }> {\n const response = await ai.chat.completions.create({\n model: AI_MODEL,\n messages: [\n {\n role: \"system\",\n content: `Bạn phân tích kết quả đăng ký tài khoản eBay.\nTrả về JSON: {\"success\": true/false, \"reason\": \"giải thích ngắn\"}`,\n },\n {\n role: \"user\",\n content: `URL hiện tại: ${url}\nTitle trang: ${pageTitle}\nNội dung trang (500 ký tự đầu): ${pageText.slice(0, 500)}\n\nĐăng ký thành công chưa?`,\n },\n ],\n temperature: 0.1,\n max_tokens: 150,\n });\n\n try {\n const text = response.choices[0].message.content || \"{}\";\n const json = text.match(/\\{.*\\}/s)?.[0] || \"{}\";\n return JSON.parse(json);\n } catch {\n return { success: false, reason: \"Không phân tích được\" };\n }\n}\n\n// ─────────────────────────────────────────────────────\n// MAIN — AI Agent học quy trình\n// ─────────────────────────────────────────────────────\nconsole.log(\"🤖 PHASE 1: AI Agent bắt đầu học quy trình đăng ký eBay Business...\\n\");\n\nconst ai = new OpenAI({ apiKey: AI_API_KEY, baseURL: AI_BASE_URL });\nconst kernel = new Kernel();\n\nawait initPlaybookDB();\n\nconst kernelBrowser = await kernel.browsers.create();\n\n// Lưu session vào DB để Live View theo dõi được\nawait 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`);\nawait sqlite.execute({\n sql: `INSERT OR REPLACE INTO browser_sessions (sessionId, liveViewUrl, cdpWsUrl, label, status)\n VALUES (?,?,?,?,'active')`,\n args: [kernelBrowser.session_id, kernelBrowser.browser_live_view_url, kernelBrowser.cdp_ws_url, \"🧠 AI Learn Session\"],\n});\nconsole.log(`\\n🔴 LIVE VIEW: ${kernelBrowser.browser_live_view_url}`);\nconsole.log(`→ Hoặc xem tại Dashboard: /live?session=${kernelBrowser.session_id}\\n`);\n\nconst browser = await chromium.connectOverCDP(kernelBrowser.cdp_ws_url);\nlet stepOrder = 1;\n\ntry {\n const context = browser.contexts()[0] || await browser.newContext({\n userAgent: \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/122.0.0.0 Safari/537.36\",\n locale: \"en-US\",\n timezoneId: \"America/New_York\",\n });\n const page = context.pages()[0] || await context.newPage();\n await page.setViewportSize({ width: 1280, height: 900 });\n\n // ── STEP 1: Mở trang đăng ký ────────────────────────\n console.log(`[Step ${stepOrder}] 🌐 Mở trang đăng ký eBay...`);\n await page.goto(EBAY_URL, { waitUntil: \"networkidle\", timeout: 30000 });\n await page.waitForTimeout(2000);\n await saveStep({\n stepOrder: stepOrder++,\n action: \"goto\",\n description: \"Mở trang đăng ký eBay Business US\",\n value: EBAY_URL,\n waitMs: 2000,\n });\n\n // ── STEP 2: AI tìm và click tab Business ────────────\n console.log(`[Step ${stepOrder}] 🤖 AI đang tìm tab Business account...`);\n let html = await page.content();\n const bizTabResult = await findSelectorWithAI(\n ai, html,\n \"tab hoặc link để chuyển sang đăng ký Business account (không phải Personal)\"\n );\n console.log(` → Selector tìm được: \"${bizTabResult.selector}\" (${bizTabResult.confidence})`);\n\n if (bizTabResult.selector && bizTabResult.confidence !== \"low\") {\n try {\n await page.click(bizTabResult.selector, { timeout: 5000 });\n await page.waitForTimeout(1500);\n console.log(` ✅ Đã click tab Business`);\n await saveStep({\n stepOrder: stepOrder++,\n action: \"click\",\n description: \"Click tab Business account\",\n selector: bizTabResult.selector,\n waitMs: 1500,\n });\n } catch {\n console.log(` ⚠️ Không click được, thử selector dự phòng...`);\n for (const sel of ['a:has-text(\"Business\")', '[data-testid=\"business-reg-tab\"]']) {\n try {\n await page.click(sel, { timeout: 3000 });\n await page.waitForTimeout(1500);\n await saveStep({ stepOrder: stepOrder++, action: \"click\", description: \"Click tab Business account (fallback)\", selector: sel, waitMs: 1500 });\n break;\n } catch { /* thử tiếp */ }\n }\n }\n }\n\n // ── STEP 3-8: AI tìm từng trường form ───────────────\n html = await page.content(); // lấy HTML mới sau khi đổi tab\n\n const fields = [\n { key: \"businessName\", desc: \"input field để nhập tên doanh nghiệp / Business name / Legal business name\", value: TEST_ACCOUNT.businessName },\n { key: \"firstName\", desc: \"input field để nhập First name / Tên\", value: TEST_ACCOUNT.firstName },\n { key: \"lastName\", desc: \"input field để nhập Last name / Họ\", value: TEST_ACCOUNT.lastName },\n { key: \"email\", desc: \"input field để nhập Email address\", value: TEST_ACCOUNT.email },\n { key: \"username\", desc: \"input field để nhập Username / User ID cho tài khoản eBay\", value: TEST_ACCOUNT.email.split(\"@\")[0] },\n { key: \"password\", desc: \"input field để nhập Password (type=password)\", value: TEST_ACCOUNT.password },\n { key: \"phone\", desc: \"input field để nhập số điện thoại / Phone number\", value: TEST_ACCOUNT.phone },\n ];\n\n for (const field of fields) {\n console.log(`[Step ${stepOrder}] 🤖 AI tìm field \"${field.key}\"...`);\n const result = await findSelectorWithAI(ai, html, field.desc);\n console.log(` → Selector: \"${result.selector}\" (${result.confidence})`);\n\n if (result.selector) {\n try {\n const el = page.locator(result.selector).first();\n const visible = await el.isVisible({ timeout: 3000 }).catch(() => false);\n if (visible) {\n await el.fill(field.value);\n console.log(` ✅ Đã điền \"${field.key}\": ${field.key === \"password\" ? \"***\" : field.value}`);\n await saveStep({\n stepOrder: stepOrder++,\n action: \"fill\",\n description: `Điền trường ${field.key}`,\n selector: result.selector,\n fieldKey: field.key,\n waitMs: 300,\n });\n } else {\n console.log(` ⚠️ Field \"${field.key}\" không visible, bỏ qua`);\n }\n } catch (e) {\n console.log(` ❌ Lỗi điền \"${field.key}\": ${e.message}`);\n }\n }\n await page.waitForTimeout(300);\n }\n\n // ── STEP: AI tìm nút Submit ──────────────────────────\n console.log(`[Step ${stepOrder}] 🤖 AI tìm nút Submit / Create account...`);\n html = await page.content();\n const submitResult = await findSelectorWithAI(\n ai, html,\n \"button để submit form đăng ký, có text như 'Create account', 'Register', 'Submit'\"\n );\n console.log(` → Selector: \"${submitResult.selector}\" (${submitResult.confidence})`);\n\n if (submitResult.selector) {\n await saveStep({\n stepOrder: stepOrder++,\n action: \"click\",\n description: \"Click nút Submit / Create account\",\n selector: submitResult.selector,\n waitMs: 5000,\n });\n console.log(` ✅ Đã lưu bước submit`);\n }\n\n // ── STEP: Lưu bước kiểm tra kết quả ────────────────\n await saveStep({\n stepOrder: stepOrder++,\n action: \"check_result\",\n description: \"Kiểm tra đăng ký thành công hay thất bại\",\n waitMs: 3000,\n });\n\n // ── Thực tế SUBMIT để kiểm tra (optional) ───────────\n console.log(`\\n🔍 Thực hiện submit thử để xác nhận quy trình...`);\n if (submitResult.selector) {\n try {\n await page.click(submitResult.selector, { timeout: 5000 });\n await page.waitForTimeout(5000);\n\n const currentUrl = page.url();\n const pageTitle = await page.title();\n const pageText = await page.locator(\"body\").innerText().catch(() => \"\");\n\n const analysis = await analyzeResultWithAI(ai, currentUrl, pageTitle, pageText);\n if (analysis.success) {\n console.log(` ✅ Đăng ký thử THÀNH CÔNG: ${analysis.reason}`);\n } else {\n console.log(` ℹ️ Kết quả: ${analysis.reason}`);\n console.log(` (Bình thường nếu email đã tồn tại hoặc cần xác minh)`);\n }\n } catch (e) {\n console.log(` ⚠️ Submit thử: ${e.message}`);\n }\n }\n\n // ── In playbook đã lưu ───────────────────────────────\n const playbook = await sqlite.execute(\n \"SELECT * FROM ebay_playbook ORDER BY stepOrder\"\n );\n console.log(`\\n📖 PLAYBOOK ĐÃ HỌC (${playbook.rows.length} bước):`);\n console.log(\"─\".repeat(60));\n for (const row of playbook.rows) {\n console.log(` [${row.stepOrder}] ${row.action.toUpperCase().padEnd(12)} | ${row.description}`);\n if (row.selector) console.log(` selector: \"${row.selector}\"`);\n }\n console.log(\"─\".repeat(60));\n console.log(`\\n✅ PHASE 1 HOÀN TẤT! Playbook đã lưu vào database.`);\n console.log(`→ Bây giờ chạy agentReplay.ts để đăng ký hàng loạt!\\n`);\n\n} finally {\n await browser.close();\n await kernel.browsers.deleteByID(kernelBrowser.session_id);\n}\n",["D",1773327239599],{"_105":375,"_170":148,"_167":197,"_97":101,"_178":376,"_176":191,"_102":33,"_169":-5,"_107":377,"_171":378,"_181":-5},"f41dee38-1cb2-11f1-b242-42dde27851f2","/**\n * PHASE 1 — AI AGENT TỰ HỌC QUY TRÌNH ĐĂNG KÝ EBAY\n * ====================================================\n * AI Agent dùng ngôn ngữ tự nhiên điều khiển browser,\n * tự khám phá từng bước, ghi lại playbook vào SQLite.\n *\n * Chạy file này 1 LẦN DUY NHẤT để học quy trình.\n * Sau đó dùng agentReplay.ts để chạy hàng loạt.\n */\n\nimport \"https://esm.town/v/wolf/StubFS/stubFs.ts\";\nimport { chromium } from \"npm:playwright-core\";\nimport Kernel from \"npm:@onkernel/sdk\";\nimport OpenAI from \"npm:openai\";\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n// ── Cấu hình AI ──────────────────────────────────────\nconst AI_API_KEY = Deno.env.get(\"AI_API_KEY\") || \"\";\nconst AI_BASE_URL = Deno.env.get(\"AI_BASE_URL\") || \"\";\nconst AI_MODEL = Deno.env.get(\"AI_MODEL\") || \"qwen2.5-72b-instruct\";\n\n// ── Tài khoản TEST dùng để học (không cần thật) ──────\nconst TEST_ACCOUNT = {\n firstName: \"John\",\n lastName: \"Smith\",\n businessName: \"Smith Trading LLC\",\n email: \"test_learn@duck.com\",\n password: \"TestPass@2025!\",\n phone: \"2125551234\",\n};\n\n// ── URL đăng ký eBay Business US ─────────────────────\nconst EBAY_URL = \"https://reg.ebay.com/reg/RegistrationPage?ru=https://www.ebay.com/&bizflow=3\";\n\n// ─────────────────────────────────────────────────────\n// Khởi tạo bảng playbook trong SQLite\n// ─────────────────────────────────────────────────────\nasync function initPlaybookDB() {\n await sqlite.execute(`\n CREATE TABLE IF NOT EXISTS ebay_playbook (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n stepOrder INTEGER NOT NULL,\n action TEXT NOT NULL,\n description TEXT NOT NULL,\n selector TEXT,\n value TEXT,\n fieldKey TEXT,\n waitMs INTEGER DEFAULT 500,\n createdAt TEXT DEFAULT (datetime('now'))\n )\n `);\n // Xóa playbook cũ nếu có (học lại từ đầu)\n await sqlite.execute(\"DELETE FROM ebay_playbook\");\n console.log(\"🗄️ Bảng playbook đã sẵn sàng (đã xóa dữ liệu cũ)\");\n}\n\n// ─────────────────────────────────────────────────────\n// Lưu 1 step vào playbook\n// ─────────────────────────────────────────────────────\nasync function saveStep(step: {\n stepOrder: number;\n action: string;\n description: string;\n selector?: string;\n value?: string;\n fieldKey?: string;\n waitMs?: number;\n}) {\n await sqlite.execute({\n sql: `INSERT INTO ebay_playbook (stepOrder, action, description, selector, value, fieldKey, waitMs)\n VALUES (?, ?, ?, ?, ?, ?, ?)`,\n args: [\n step.stepOrder,\n step.action,\n step.description,\n step.selector ?? null,\n step.value ?? null,\n step.fieldKey ?? null,\n step.waitMs ?? 500,\n ],\n });\n}\n\n// ─────────────────────────────────────────────────────\n// Dùng AI để tìm selector phù hợp trên trang\n// ─────────────────────────────────────────────────────\nasync function findSelectorWithAI(\n ai: OpenAI,\n pageHTML: string,\n taskDescription: string\n): Promise<{ selector: string; confidence: string }> {\n const response = await ai.chat.completions.create({\n model: AI_MODEL,\n messages: [\n {\n role: \"system\",\n content: `Bạn là chuyên gia phân tích HTML và CSS selector.\nNhiệm vụ: Tìm CSS selector chính xác nhất cho phần tử được yêu cầu trong HTML.\nChỉ trả về JSON object, không giải thích thêm.\nFormat: {\"selector\": \"...\", \"confidence\": \"high|medium|low\"}`,\n },\n {\n role: \"user\",\n content: `Tìm selector cho: \"${taskDescription}\"\n\nHTML (rút gọn):\n${pageHTML.slice(0, 8000)}\n\nTrả về JSON:`,\n },\n ],\n temperature: 0.1,\n max_tokens: 200,\n });\n\n try {\n const text = response.choices[0].message.content || \"{}\";\n const json = text.match(/\\{.*\\}/s)?.[0] || \"{}\";\n return JSON.parse(json);\n } catch {\n return { selector: \"\", confidence: \"low\" };\n }\n}\n\n// ─────────────────────────────────────────────────────\n// AI phân tích kết quả đăng ký thành công hay chưa\n// ─────────────────────────────────────────────────────\nasync function analyzeResultWithAI(\n ai: OpenAI,\n url: string,\n pageTitle: string,\n pageText: string\n): Promise<{ success: boolean; reason: string }> {\n const response = await ai.chat.completions.create({\n model: AI_MODEL,\n messages: [\n {\n role: \"system\",\n content: `Bạn phân tích kết quả đăng ký tài khoản eBay.\nTrả về JSON: {\"success\": true/false, \"reason\": \"giải thích ngắn\"}`,\n },\n {\n role: \"user\",\n content: `URL hiện tại: ${url}\nTitle trang: ${pageTitle}\nNội dung trang (500 ký tự đầu): ${pageText.slice(0, 500)}\n\nĐăng ký thành công chưa?`,\n },\n ],\n temperature: 0.1,\n max_tokens: 150,\n });\n\n try {\n const text = response.choices[0].message.content || \"{}\";\n const json = text.match(/\\{.*\\}/s)?.[0] || \"{}\";\n return JSON.parse(json);\n } catch {\n return { success: false, reason: \"Không phân tích được\" };\n }\n}\n\n// ─────────────────────────────────────────────────────\n// MAIN — AI Agent học quy trình\n// ─────────────────────────────────────────────────────\nconsole.log(\"🤖 PHASE 1: AI Agent bắt đầu học quy trình đăng ký eBay Business...\\n\");\n\nconst ai = new OpenAI({ apiKey: AI_API_KEY, baseURL: AI_BASE_URL });\nconst kernel = new Kernel();\n\nawait initPlaybookDB();\n\nconst kernelBrowser = await kernel.browsers.create();\nconst browser = await chromium.connectOverCDP(kernelBrowser.cdp_ws_url);\nlet stepOrder = 1;\n\ntry {\n const context = browser.contexts()[0] || await browser.newContext({\n userAgent: \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/122.0.0.0 Safari/537.36\",\n locale: \"en-US\",\n timezoneId: \"America/New_York\",\n });\n const page = context.pages()[0] || await context.newPage();\n await page.setViewportSize({ width: 1280, height: 900 });\n\n // ── STEP 1: Mở trang đăng ký ────────────────────────\n console.log(`[Step ${stepOrder}] 🌐 Mở trang đăng ký eBay...`);\n await page.goto(EBAY_URL, { waitUntil: \"networkidle\", timeout: 30000 });\n await page.waitForTimeout(2000);\n await saveStep({\n stepOrder: stepOrder++,\n action: \"goto\",\n description: \"Mở trang đăng ký eBay Business US\",\n value: EBAY_URL,\n waitMs: 2000,\n });\n\n // ── STEP 2: AI tìm và click tab Business ────────────\n console.log(`[Step ${stepOrder}] 🤖 AI đang tìm tab Business account...`);\n let html = await page.content();\n const bizTabResult = await findSelectorWithAI(\n ai, html,\n \"tab hoặc link để chuyển sang đăng ký Business account (không phải Personal)\"\n );\n console.log(` → Selector tìm được: \"${bizTabResult.selector}\" (${bizTabResult.confidence})`);\n\n if (bizTabResult.selector && bizTabResult.confidence !== \"low\") {\n try {\n await page.click(bizTabResult.selector, { timeout: 5000 });\n await page.waitForTimeout(1500);\n console.log(` ✅ Đã click tab Business`);\n await saveStep({\n stepOrder: stepOrder++,\n action: \"click\",\n description: \"Click tab Business account\",\n selector: bizTabResult.selector,\n waitMs: 1500,\n });\n } catch {\n console.log(` ⚠️ Không click được, thử selector dự phòng...`);\n for (const sel of ['a:has-text(\"Business\")', '[data-testid=\"business-reg-tab\"]']) {\n try {\n await page.click(sel, { timeout: 3000 });\n await page.waitForTimeout(1500);\n await saveStep({ stepOrder: stepOrder++, action: \"click\", description: \"Click tab Business account (fallback)\", selector: sel, waitMs: 1500 });\n break;\n } catch { /* thử tiếp */ }\n }\n }\n }\n\n // ── STEP 3-8: AI tìm từng trường form ───────────────\n html = await page.content(); // lấy HTML mới sau khi đổi tab\n\n const fields = [\n { key: \"businessName\", desc: \"input field để nhập tên doanh nghiệp / Business name / Legal business name\", value: TEST_ACCOUNT.businessName },\n { key: \"firstName\", desc: \"input field để nhập First name / Tên\", value: TEST_ACCOUNT.firstName },\n { key: \"lastName\", desc: \"input field để nhập Last name / Họ\", value: TEST_ACCOUNT.lastName },\n { key: \"email\", desc: \"input field để nhập Email address\", value: TEST_ACCOUNT.email },\n { key: \"username\", desc: \"input field để nhập Username / User ID cho tài khoản eBay\", value: TEST_ACCOUNT.email.split(\"@\")[0] },\n { key: \"password\", desc: \"input field để nhập Password (type=password)\", value: TEST_ACCOUNT.password },\n { key: \"phone\", desc: \"input field để nhập số điện thoại / Phone number\", value: TEST_ACCOUNT.phone },\n ];\n\n for (const field of fields) {\n console.log(`[Step ${stepOrder}] 🤖 AI tìm field \"${field.key}\"...`);\n const result = await findSelectorWithAI(ai, html, field.desc);\n console.log(` → Selector: \"${result.selector}\" (${result.confidence})`);\n\n if (result.selector) {\n try {\n const el = page.locator(result.selector).first();\n const visible = await el.isVisible({ timeout: 3000 }).catch(() => false);\n if (visible) {\n await el.fill(field.value);\n console.log(` ✅ Đã điền \"${field.key}\": ${field.key === \"password\" ? \"***\" : field.value}`);\n await saveStep({\n stepOrder: stepOrder++,\n action: \"fill\",\n description: `Điền trường ${field.key}`,\n selector: result.selector,\n fieldKey: field.key,\n waitMs: 300,\n });\n } else {\n console.log(` ⚠️ Field \"${field.key}\" không visible, bỏ qua`);\n }\n } catch (e) {\n console.log(` ❌ Lỗi điền \"${field.key}\": ${e.message}`);\n }\n }\n await page.waitForTimeout(300);\n }\n\n // ── STEP: AI tìm nút Submit ──────────────────────────\n console.log(`[Step ${stepOrder}] 🤖 AI tìm nút Submit / Create account...`);\n html = await page.content();\n const submitResult = await findSelectorWithAI(\n ai, html,\n \"button để submit form đăng ký, có text như 'Create account', 'Register', 'Submit'\"\n );\n console.log(` → Selector: \"${submitResult.selector}\" (${submitResult.confidence})`);\n\n if (submitResult.selector) {\n await saveStep({\n stepOrder: stepOrder++,\n action: \"click\",\n description: \"Click nút Submit / Create account\",\n selector: submitResult.selector,\n waitMs: 5000,\n });\n console.log(` ✅ Đã lưu bước submit`);\n }\n\n // ── STEP: Lưu bước kiểm tra kết quả ────────────────\n await saveStep({\n stepOrder: stepOrder++,\n action: \"check_result\",\n description: \"Kiểm tra đăng ký thành công hay thất bại\",\n waitMs: 3000,\n });\n\n // ── Thực tế SUBMIT để kiểm tra (optional) ───────────\n console.log(`\\n🔍 Thực hiện submit thử để xác nhận quy trình...`);\n if (submitResult.selector) {\n try {\n await page.click(submitResult.selector, { timeout: 5000 });\n await page.waitForTimeout(5000);\n\n const currentUrl = page.url();\n const pageTitle = await page.title();\n const pageText = await page.locator(\"body\").innerText().catch(() => \"\");\n\n const analysis = await analyzeResultWithAI(ai, currentUrl, pageTitle, pageText);\n if (analysis.success) {\n console.log(` ✅ Đăng ký thử THÀNH CÔNG: ${analysis.reason}`);\n } else {\n console.log(` ℹ️ Kết quả: ${analysis.reason}`);\n console.log(` (Bình thường nếu email đã tồn tại hoặc cần xác minh)`);\n }\n } catch (e) {\n console.log(` ⚠️ Submit thử: ${e.message}`);\n }\n }\n\n // ── In playbook đã lưu ───────────────────────────────\n const playbook = await sqlite.execute(\n \"SELECT * FROM ebay_playbook ORDER BY stepOrder\"\n );\n console.log(`\\n📖 PLAYBOOK ĐÃ HỌC (${playbook.rows.length} bước):`);\n console.log(\"─\".repeat(60));\n for (const row of playbook.rows) {\n console.log(` [${row.stepOrder}] ${row.action.toUpperCase().padEnd(12)} | ${row.description}`);\n if (row.selector) console.log(` selector: \"${row.selector}\"`);\n }\n console.log(\"─\".repeat(60));\n console.log(`\\n✅ PHASE 1 HOÀN TẤT! Playbook đã lưu vào database.`);\n console.log(`→ Bây giờ chạy agentReplay.ts để đăng ký hàng loạt!\\n`);\n\n} finally {\n await browser.close();\n await kernel.browsers.deleteByID(kernelBrowser.session_id);\n}\n",["D",1773169035044],9,"versions",[381,383,384,385],{"_177":363,"_382":365},"previous",{"_177":365,"_382":370},{"_177":370,"_382":374},{"_177":374,"_382":-5},"versionNumber","page","hasNext","actionData","errors"]

minhheo

kernel_starter

History for agentLearn.ts