${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,205,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":206,"_170":148,"_167":207,"_97":101,"_178":211,"_176":191,"_102":210,"_169":-5,"_107":333,"_171":208,"_181":-5,"_100":334},["D",1773394907285],[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,"_418":419,"_432":33,"_433":33,"_434":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":206,"_97":101,"_167":207,"_169":-5,"_170":148,"_171":208,"_173":174,"_107":359,"_102":210,"_176":191,"_178":211,"_180":22,"_181":-5,"_100":360},["D",1773394907285],[101],"history",[363,365,371,377,382,388,394,399,404,410,414],{"_105":206,"_170":148,"_167":207,"_97":101,"_178":211,"_176":191,"_102":210,"_169":-5,"_107":364,"_171":208,"_181":-5},["D",1773394907285],{"_105":366,"_170":148,"_167":207,"_97":101,"_178":367,"_176":191,"_102":368,"_169":-5,"_107":369,"_171":370,"_181":-5},"d6a8ca3e-1ec0-11f1-8c3d-42dde27851f2","/**\n * PHASE 2 — REPLAY TỰ ĐỘNG THEO PLAYBOOK ĐÃ HỌC\n * =================================================\n * Đọc playbook từ SQLite (đã học bởi agentLearn.ts),\n * chạy lại đúng quy trình cho từng tài khoản trong Sheets.\n *\n * ⚠️ Phải chạy agentLearn.ts TRƯỚC để có playbook.\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, type AccountData } from \"./sheets.ts\";\nimport { generateDDGAlias } from \"./ddgEmail.ts\";\nimport { solveHCaptchaWithGemini } from \"./captcha.ts\";\nimport { initResultsDB, saveResult, printSummary } from \"./results.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\";\n\nconst EBAY_CAPTCHA_URL = \"https://www.ebay.com/splashui/captcha?\";\nconst EBAY_REGISTER_URL = \"https://signup.ebay.com/pa/crte?\";\nconst DELAY_BETWEEN = 15000; // ms giữa các tài khoản\nconst RUN_LIMIT = 5; // chạy 5 tài khoản\n\n// ── Kiểu dữ liệu playbook step ────────────────────────\ninterface PlaybookStep {\n stepOrder: number;\n action: string;\n description: string;\n selector: string | null;\n value: string | null;\n fieldKey: string | null;\n waitMs: number;\n}\n\n// ─────────────────────────────────────────────────────\n// Đọc playbook từ SQLite\n// ─────────────────────────────────────────────────────\nasync function loadPlaybook(): Promise {\n const res = await sqlite.execute(\n \"SELECT * FROM ebay_playbook ORDER BY stepOrder\"\n );\n if (res.rows.length === 0) {\n throw new Error(\"❌ Playbook trống! Hãy chạy agentLearn.ts trước.\");\n }\n return res.rows.map((r) => ({\n stepOrder: r.stepOrder as number,\n action: r.action as string,\n description: r.description as string,\n selector: r.selector as string | null,\n value: r.value as string | null,\n fieldKey: r.fieldKey as string | null,\n waitMs: (r.waitMs as number) || 500,\n }));\n}\n\n// ─────────────────────────────────────────────────────\n// Map fieldKey → giá trị thực tế của tài khoản\n// ─────────────────────────────────────────────────────\nfunction resolveValue(\n fieldKey: string | null,\n templateValue: string | null,\n account: AccountData,\n email: string\n): string {\n if (!fieldKey) return templateValue || \"\";\n const map: Record = {\n businessName: account.businessName,\n firstName: account.firstName,\n lastName: account.lastName,\n email: email,\n username: email.split(\"@\")[0].replace(/[^a-zA-Z0-9]/g, \"\").slice(0, 64),\n password: account.password,\n phone: account.phone,\n address: account.address,\n city: account.city,\n state: account.state,\n zip: account.zip,\n };\n return map[fieldKey] ?? templateValue ?? \"\";\n}\n\n// ─────────────────────────────────────────────────────\n// Dùng AI phân tích kết quả đăng ký\n// ─────────────────────────────────────────────────────\nasync function analyzeResult(\n ai: OpenAI,\n url: string,\n pageTitle: string,\n pageText: string\n): Promise<{ success: boolean; reason: string }> {\n const res = await ai.chat.completions.create({\n model: AI_MODEL,\n messages: [\n {\n role: \"system\",\n content: `Phân tích kết quả đăng ký tài khoản eBay.\nTrả về JSON: {\"success\": true/false, \"reason\": \"lý do ngắn gọn\"}`,\n },\n {\n role: \"user\",\n content: `URL: ${url}\nTitle: ${pageTitle}\nNội dung trang (500 ký tự đầu): ${pageText.slice(0, 500)}`,\n },\n ],\n temperature: 0.1,\n max_tokens: 150,\n });\n try {\n const text = res.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// Dùng AI sửa selector nếu bị lỗi\n// ─────────────────────────────────────────────────────\nasync function fixSelectorWithAI(\n ai: OpenAI,\n html: string,\n description: string,\n brokenSelector: string\n): Promise {\n const res = await ai.chat.completions.create({\n model: AI_MODEL,\n messages: [\n {\n role: \"system\",\n content: `Selector CSS bị lỗi, hãy tìm selector mới đúng hơn.\nTrả về JSON: {\"selector\": \"...\"}`,\n },\n {\n role: \"user\",\n content: `Cần tìm: \"${description}\"\nSelector cũ bị lỗi: \"${brokenSelector}\"\nHTML (rút gọn): ${html.slice(0, 6000)}`,\n },\n ],\n temperature: 0.1,\n max_tokens: 150,\n });\n try {\n const text = res.choices[0].message.content || \"{}\";\n const json = text.match(/\\{.*\\}/s)?.[0] || \"{}\";\n return JSON.parse(json).selector || \"\";\n } catch {\n return \"\";\n }\n}\n\n// ─────────────────────────────────────────────────────\n// Replay playbook cho 1 tài khoản\n// ─────────────────────────────────────────────────────\nasync function replayForAccount(\n kernel: InstanceType,\n ai: OpenAI,\n playbook: PlaybookStep[],\n account: AccountData,\n email: string\n): Promise<{ status: \"success\" | \"failed\"; ebayUsername?: string; errorMessage?: string }> {\n\n const NOPECHA_EXTENSION_ID = Deno.env.get(\"NOPECHA_EXTENSION_ID\") || \"k17g3z4olapuyz9oaf2z0i0d\";\n const createOpts: any = {};\n if (NOPECHA_EXTENSION_ID) createOpts.extension_ids = [NOPECHA_EXTENSION_ID];\n const kernelBrowser = await kernel.browsers.create(createOpts);\n\n // Lưu session vào DB để Live View theo dõi được\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 await sqlite.execute({\n sql: `INSERT OR REPLACE INTO browser_sessions (sessionId, liveViewUrl, cdpWsUrl, label, status)\n VALUES (?,?,?,?,'active')`,\n args: [\n kernelBrowser.session_id,\n kernelBrowser.browser_live_view_url,\n kernelBrowser.cdp_ws_url,\n `🔁 Replay: ${account.firstName} ${account.lastName}`,\n ],\n });\n console.log(` 🔴 Live: /live?session=${kernelBrowser.session_id}`);\n\n const browser = await chromium.connectOverCDP(kernelBrowser.cdp_ws_url);\n\n try {\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 const username = email.split(\"@\")[0].replace(/[^a-zA-Z0-9]/g, \"\").slice(0, 64);\n\n for (const step of playbook) {\n console.log(` [${step.stepOrder}] ${step.action.toUpperCase().padEnd(12)} ${step.description}`);\n\n try {\n // ── goto ────────────────────────────────────────\n if (step.action === \"goto\") {\n const gotoUrl = step.value || EBAY_REGISTER_URL;\n console.log(` → ${gotoUrl}`);\n await page.goto(gotoUrl, { waitUntil: \"domcontentloaded\", timeout: 30000 });\n await page.waitForTimeout(step.waitMs);\n }\n\n // ── solve_captcha ────────────────────────────────\n else if (step.action === \"solve_captcha\") {\n const solved = await solveHCaptchaWithGemini(page);\n console.log(` 🔐 hCaptcha: ${solved ? \"✅ giải xong\" : \"⚠️ không giải được\"}`);\n await page.waitForTimeout(step.waitMs);\n }\n\n // ── click ───────────────────────────────────────\n else if (step.action === \"click\" && step.selector) {\n const el = page.locator(step.selector).first();\n const visible = await el.isVisible({ timeout: 4000 }).catch(() => false);\n\n if (visible) {\n await el.click();\n await page.waitForTimeout(step.waitMs);\n } else {\n // AI tự sửa selector bị lỗi\n console.log(` ⚠️ Selector lỗi, AI đang tìm lại...`);\n const html = await page.content();\n const newSel = await fixSelectorWithAI(ai, html, step.description, step.selector);\n if (newSel) {\n await page.click(newSel, { timeout: 5000 });\n await page.waitForTimeout(step.waitMs);\n console.log(` 🔧 AI đã sửa selector: \"${newSel}\"`);\n }\n }\n }\n\n // ── fill ────────────────────────────────────────\n else if (step.action === \"fill\" && step.selector) {\n const value = resolveValue(step.fieldKey, step.value, account, email);\n const el = page.locator(step.selector).first();\n const visible = await el.isVisible({ timeout: 4000 }).catch(() => false);\n\n if (visible) {\n await el.fill(value);\n await page.waitForTimeout(step.waitMs);\n const display = step.fieldKey === \"password\" ? \"***\" : value;\n console.log(` → \"${step.fieldKey}\": ${display}`);\n } else {\n // AI tự sửa selector\n console.log(` ⚠️ Selector lỗi, AI đang tìm lại...`);\n const html = await page.content();\n const newSel = await fixSelectorWithAI(ai, html, step.description, step.selector);\n if (newSel) {\n await page.fill(newSel, value);\n await page.waitForTimeout(step.waitMs);\n console.log(` 🔧 AI sửa selector → điền \"${step.fieldKey}\"`);\n }\n }\n }\n\n // ── check_result ────────────────────────────────\n else if (step.action === \"check_result\") {\n await page.waitForTimeout(step.waitMs);\n\n // Xử lý hCaptcha nếu xuất hiện sau submit\n const hasHCaptcha = await page.locator('iframe[title*=\"hCaptcha\"], iframe[title*=\"Widget containing checkbox\"]').count().catch(() => 0) > 0;\n if (hasHCaptcha) {\n console.log(` 🔐 Phát hiện hCaptcha sau submit, đang giải...`);\n await solveHCaptchaWithGemini(page);\n await page.waitForTimeout(3000);\n }\n\n // AI phân tích kết quả\n const url = page.url();\n const title = await page.title();\n const bodyText = await page.locator(\"body\").innerText().catch(() => \"\");\n const analysis = await analyzeResult(ai, url, title, bodyText);\n\n if (analysis.success) {\n return { status: \"success\", ebayUsername: username };\n } else {\n // Tìm thêm thông báo lỗi trên trang\n const errText = await page.locator('.errRt, .error-message, [role=\"alert\"], .field-error')\n .first().textContent().catch(() => null);\n return {\n status: \"failed\",\n errorMessage: errText?.trim() || analysis.reason,\n };\n }\n }\n\n } catch (stepErr) {\n console.log(` ⚠️ Step lỗi: ${stepErr.message} — tiếp tục...`);\n }\n }\n\n return { status: \"failed\", errorMessage: \"Không hoàn tất playbook\" };\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}\n\n// ─────────────────────────────────────────────────────\n// MAIN\n// ─────────────────────────────────────────────────────\nconsole.log(\"🚀 PHASE 2: Replay tự động theo playbook đã học\\n\");\n\nconst ai = new OpenAI({ apiKey: AI_API_KEY, baseURL: AI_BASE_URL });\nconst kernel = new Kernel();\n\n// Khởi tạo DB kết quả\nawait initResultsDB();\n\n// Tải playbook\nconsole.log(\"📖 Đọc playbook từ database...\");\nconst playbook = await loadPlaybook();\nconsole.log(`✅ Playbook: ${playbook.length} bước\\n`);\nfor (const s of playbook) {\n console.log(` [${s.stepOrder}] ${s.action.toUpperCase().padEnd(12)} ${s.description}`);\n}\n\n// Tải danh sách tài khoản\nconsole.log(\"\\n📊 Đọc dữ liệu từ Google Sheets...\");\nconst accounts = await fetchAccountsFromSheets();\n\nif (accounts.length === 0) {\n console.error(\"❌ Không có tài khoản nào trong Sheets!\");\n Deno.exit(1);\n}\n\nconst toRun = RUN_LIMIT > 0 ? accounts.slice(0, RUN_LIMIT) : accounts;\nconsole.log(`\\n🎯 Bắt đầu đăng ký ${toRun.length}/${accounts.length} tài khoản...\\n`);\nconsole.log(\"=\".repeat(60));\n\nfor (let i = 0; i < toRun.length; i++) {\n const account = toRun[i];\n console.log(`\\n[${i + 1}/${toRun.length}] ${account.firstName} ${account.lastName} — ${account.businessName}`);\n console.log(\"─\".repeat(50));\n\n try {\n // Tạo email @duck.com mới\n const { fullEmail } = await generateDDGAlias();\n console.log(` 📧 Email: ${fullEmail}`);\n\n // Replay\n const result = await replayForAccount(kernel, ai, playbook, account, fullEmail);\n\n const icon = result.status === \"success\" ? \"✅\" : \"❌\";\n console.log(` ${icon} Kết quả: ${result.status}${result.errorMessage ? \" — \" + result.errorMessage : \"\"}`);\n\n await saveResult({\n email: fullEmail,\n firstName: account.firstName,\n lastName: account.lastName,\n businessName: account.businessName,\n ...result,\n });\n\n } catch (err) {\n const msg = err instanceof Error ? err.message : String(err);\n console.error(` ❌ Lỗi: ${msg}`);\n await saveResult({\n email: \"error\",\n firstName: account.firstName,\n lastName: account.lastName,\n businessName: account.businessName,\n status: \"failed\",\n errorMessage: msg,\n });\n }\n\n // Delay giữa các tài khoản\n if (i < accounts.length - 1) {\n console.log(`\\n ⏸️ Nghỉ ${DELAY_BETWEEN / 1000}s...`);\n await new Promise((r) => setTimeout(r, DELAY_BETWEEN));\n }\n}\n\nconsole.log(\"\\n\" + \"=\".repeat(60));\nawait printSummary();\nconsole.log(\"\\n✅ Hoàn tất tất cả tài khoản!\");\n",9,["D",1773394900905],82,{"_105":372,"_170":148,"_167":207,"_97":101,"_178":373,"_176":191,"_102":374,"_169":-5,"_107":375,"_171":376,"_181":-5},"d21f6af4-1ec0-11f1-ad90-42dde27851f2","/**\n * PHASE 2 — REPLAY TỰ ĐỘNG THEO PLAYBOOK ĐÃ HỌC\n * =================================================\n * Đọc playbook từ SQLite (đã học bởi agentLearn.ts),\n * chạy lại đúng quy trình cho từng tài khoản trong Sheets.\n *\n * ⚠️ Phải chạy agentLearn.ts TRƯỚC để có playbook.\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, type AccountData } from \"./sheets.ts\";\nimport { generateDDGAlias } from \"./ddgEmail.ts\";\nimport { solveHCaptchaWithGemini } from \"./captcha.ts\";\nimport { initResultsDB, saveResult, printSummary } from \"./results.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\";\n\nconst EBAY_CAPTCHA_URL = \"https://www.ebay.com/splashui/captcha?\";\nconst EBAY_REGISTER_URL = \"https://signup.ebay.com/pa/crte?\";\nconst DELAY_BETWEEN = 15000; // ms giữa các tài khoản\nconst RUN_LIMIT = 5; // chạy 5 tài khoản\n\n// ── Kiểu dữ liệu playbook step ────────────────────────\ninterface PlaybookStep {\n stepOrder: number;\n action: string;\n description: string;\n selector: string | null;\n value: string | null;\n fieldKey: string | null;\n waitMs: number;\n}\n\n// ─────────────────────────────────────────────────────\n// Đọc playbook từ SQLite\n// ─────────────────────────────────────────────────────\nasync function loadPlaybook(): Promise {\n const res = await sqlite.execute(\n \"SELECT * FROM ebay_playbook ORDER BY stepOrder\"\n );\n if (res.rows.length === 0) {\n throw new Error(\"❌ Playbook trống! Hãy chạy agentLearn.ts trước.\");\n }\n return res.rows.map((r) => ({\n stepOrder: r.stepOrder as number,\n action: r.action as string,\n description: r.description as string,\n selector: r.selector as string | null,\n value: r.value as string | null,\n fieldKey: r.fieldKey as string | null,\n waitMs: (r.waitMs as number) || 500,\n }));\n}\n\n// ─────────────────────────────────────────────────────\n// Map fieldKey → giá trị thực tế của tài khoản\n// ─────────────────────────────────────────────────────\nfunction resolveValue(\n fieldKey: string | null,\n templateValue: string | null,\n account: AccountData,\n email: string\n): string {\n if (!fieldKey) return templateValue || \"\";\n const map: Record = {\n businessName: account.businessName,\n firstName: account.firstName,\n lastName: account.lastName,\n email: email,\n username: email.split(\"@\")[0].replace(/[^a-zA-Z0-9]/g, \"\").slice(0, 64),\n password: account.password,\n phone: account.phone,\n address: account.address,\n city: account.city,\n state: account.state,\n zip: account.zip,\n };\n return map[fieldKey] ?? templateValue ?? \"\";\n}\n\n// ─────────────────────────────────────────────────────\n// Dùng AI phân tích kết quả đăng ký\n// ─────────────────────────────────────────────────────\nasync function analyzeResult(\n ai: OpenAI,\n url: string,\n pageTitle: string,\n pageText: string\n): Promise<{ success: boolean; reason: string }> {\n const res = await ai.chat.completions.create({\n model: AI_MODEL,\n messages: [\n {\n role: \"system\",\n content: `Phân tích kết quả đăng ký tài khoản eBay.\nTrả về JSON: {\"success\": true/false, \"reason\": \"lý do ngắn gọn\"}`,\n },\n {\n role: \"user\",\n content: `URL: ${url}\nTitle: ${pageTitle}\nNội dung trang (500 ký tự đầu): ${pageText.slice(0, 500)}`,\n },\n ],\n temperature: 0.1,\n max_tokens: 150,\n });\n try {\n const text = res.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// Dùng AI sửa selector nếu bị lỗi\n// ─────────────────────────────────────────────────────\nasync function fixSelectorWithAI(\n ai: OpenAI,\n html: string,\n description: string,\n brokenSelector: string\n): Promise {\n const res = await ai.chat.completions.create({\n model: AI_MODEL,\n messages: [\n {\n role: \"system\",\n content: `Selector CSS bị lỗi, hãy tìm selector mới đúng hơn.\nTrả về JSON: {\"selector\": \"...\"}`,\n },\n {\n role: \"user\",\n content: `Cần tìm: \"${description}\"\nSelector cũ bị lỗi: \"${brokenSelector}\"\nHTML (rút gọn): ${html.slice(0, 6000)}`,\n },\n ],\n temperature: 0.1,\n max_tokens: 150,\n });\n try {\n const text = res.choices[0].message.content || \"{}\";\n const json = text.match(/\\{.*\\}/s)?.[0] || \"{}\";\n return JSON.parse(json).selector || \"\";\n } catch {\n return \"\";\n }\n}\n\n// ─────────────────────────────────────────────────────\n// Replay playbook cho 1 tài khoản\n// ─────────────────────────────────────────────────────\nasync function replayForAccount(\n kernel: InstanceType,\n ai: OpenAI,\n playbook: PlaybookStep[],\n account: AccountData,\n email: string\n): Promise<{ status: \"success\" | \"failed\"; ebayUsername?: string; errorMessage?: string }> {\n\n const NOPECHA_EXTENSION_ID = Deno.env.get(\"NOPECHA_EXTENSION_ID\") || \"k17g3z4olapuyz9oaf2z0i0d\";\n const createOpts: any = {};\n if (NOPECHA_EXTENSION_ID) createOpts.extension_ids = [NOPECHA_EXTENSION_ID];\n const kernelBrowser = await kernel.browsers.create(createOpts);\n\n // Lưu session vào DB để Live View theo dõi được\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 await sqlite.execute({\n sql: `INSERT OR REPLACE INTO browser_sessions (sessionId, liveViewUrl, cdpWsUrl, label, status)\n VALUES (?,?,?,?,'active')`,\n args: [\n kernelBrowser.session_id,\n kernelBrowser.browser_live_view_url,\n kernelBrowser.cdp_ws_url,\n `🔁 Replay: ${account.firstName} ${account.lastName}`,\n ],\n });\n console.log(` 🔴 Live: /live?session=${kernelBrowser.session_id}`);\n\n const browser = await chromium.connectOverCDP(kernelBrowser.cdp_ws_url);\n\n try {\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 const username = email.split(\"@\")[0].replace(/[^a-zA-Z0-9]/g, \"\").slice(0, 64);\n\n for (const step of playbook) {\n console.log(` [${step.stepOrder}] ${step.action.toUpperCase().padEnd(12)} ${step.description}`);\n\n try {\n // ── goto ────────────────────────────────────────\n if (step.action === \"goto\") {\n const gotoUrl = step.value || EBAY_REGISTER_URL;\n console.log(` → ${gotoUrl}`);\n await page.goto(gotoUrl, { waitUntil: \"domcontentloaded\", timeout: 30000 });\n await page.waitForTimeout(step.waitMs);\n }\n\n // ── solve_captcha ────────────────────────────────\n else if (step.action === \"solve_captcha\") {\n const solved = await solveHCaptchaWithGemini(page);\n console.log(` 🔐 hCaptcha: ${solved ? \"✅ giải xong\" : \"⚠️ không giải được\"}`);\n await page.waitForTimeout(step.waitMs);\n }\n\n // ── click ───────────────────────────────────────\n else if (step.action === \"click\" && step.selector) {\n const el = page.locator(step.selector).first();\n const visible = await el.isVisible({ timeout: 4000 }).catch(() => false);\n\n if (visible) {\n await el.click();\n await page.waitForTimeout(step.waitMs);\n } else {\n // AI tự sửa selector bị lỗi\n console.log(` ⚠️ Selector lỗi, AI đang tìm lại...`);\n const html = await page.content();\n const newSel = await fixSelectorWithAI(ai, html, step.description, step.selector);\n if (newSel) {\n await page.click(newSel, { timeout: 5000 });\n await page.waitForTimeout(step.waitMs);\n console.log(` 🔧 AI đã sửa selector: \"${newSel}\"`);\n }\n }\n }\n\n // ── fill ────────────────────────────────────────\n else if (step.action === \"fill\" && step.selector) {\n const value = resolveValue(step.fieldKey, step.value, account, email);\n const el = page.locator(step.selector).first();\n const visible = await el.isVisible({ timeout: 4000 }).catch(() => false);\n\n if (visible) {\n await el.fill(value);\n await page.waitForTimeout(step.waitMs);\n const display = step.fieldKey === \"password\" ? \"***\" : value;\n console.log(` → \"${step.fieldKey}\": ${display}`);\n } else {\n // AI tự sửa selector\n console.log(` ⚠️ Selector lỗi, AI đang tìm lại...`);\n const html = await page.content();\n const newSel = await fixSelectorWithAI(ai, html, step.description, step.selector);\n if (newSel) {\n await page.fill(newSel, value);\n await page.waitForTimeout(step.waitMs);\n console.log(` 🔧 AI sửa selector → điền \"${step.fieldKey}\"`);\n }\n }\n }\n\n // ── check_result ────────────────────────────────\n else if (step.action === \"check_result\") {\n await page.waitForTimeout(step.waitMs);\n\n // Xử lý hCaptcha nếu xuất hiện sau submit\n const hasHCaptcha = await page.locator('iframe[title*=\"hCaptcha\"], iframe[title*=\"Widget containing checkbox\"]').count().catch(() => 0) > 0;\n if (hasHCaptcha) {\n console.log(` 🔐 Phát hiện hCaptcha sau submit, đang giải...`);\n await solveHCaptchaWithGemini(page);\n await page.waitForTimeout(3000);\n }\n\n // AI phân tích kết quả\n const url = page.url();\n const title = await page.title();\n const bodyText = await page.locator(\"body\").innerText().catch(() => \"\");\n const analysis = await analyzeResult(ai, url, title, bodyText);\n\n if (analysis.success) {\n return { status: \"success\", ebayUsername: username };\n } else {\n // Tìm thêm thông báo lỗi trên trang\n const errText = await page.locator('.errRt, .error-message, [role=\"alert\"], .field-error')\n .first().textContent().catch(() => null);\n return {\n status: \"failed\",\n errorMessage: errText?.trim() || analysis.reason,\n };\n }\n }\n\n } catch (stepErr) {\n console.log(` ⚠️ Step lỗi: ${stepErr.message} — tiếp tục...`);\n }\n }\n\n return { status: \"failed\", errorMessage: \"Không hoàn tất playbook\" };\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}\n\n// ─────────────────────────────────────────────────────\n// MAIN\n// ─────────────────────────────────────────────────────\nconsole.log(\"🚀 PHASE 2: Replay tự động theo playbook đã học\\n\");\n\nconst ai = new OpenAI({ apiKey: AI_API_KEY, baseURL: AI_BASE_URL });\nconst kernel = new Kernel();\n\n// Khởi tạo DB kết quả\nawait initResultsDB();\n\n// Tải playbook\nconsole.log(\"📖 Đọc playbook từ database...\");\nconst playbook = await loadPlaybook();\nconsole.log(`✅ Playbook: ${playbook.length} bước\\n`);\nfor (const s of playbook) {\n console.log(` [${s.stepOrder}] ${s.action.toUpperCase().padEnd(12)} ${s.description}`);\n}\n\n// Tải danh sách tài khoản\nconsole.log(\"\\n📊 Đọc dữ liệu từ Google Sheets...\");\nconst accounts = await fetchAccountsFromSheets();\n\nif (accounts.length === 0) {\n console.error(\"❌ Không có tài khoản nào trong Sheets!\");\n Deno.exit(1);\n}\n\nconst toRun = RUN_LIMIT > 0 ? accounts.slice(0, RUN_LIMIT) : accounts;\nconsole.log(`\\n🎯 Bắt đầu đăng ký ${toRun.length}/${accounts.length} tài khoản...\\n`);\nconsole.log(\"=\".repeat(60));\n\nfor (let i = 0; i < toRun.length; i++) {\n const account = toRun[i];\n console.log(`\\n[${i + 1}/${accounts.length}] ${account.firstName} ${account.lastName} — ${account.businessName}`);\n console.log(\"─\".repeat(50));\n\n try {\n // Tạo email @duck.com mới\n const { fullEmail } = await generateDDGAlias();\n console.log(` 📧 Email: ${fullEmail}`);\n\n // Replay\n const result = await replayForAccount(kernel, ai, playbook, account, fullEmail);\n\n const icon = result.status === \"success\" ? \"✅\" : \"❌\";\n console.log(` ${icon} Kết quả: ${result.status}${result.errorMessage ? \" — \" + result.errorMessage : \"\"}`);\n\n await saveResult({\n email: fullEmail,\n firstName: account.firstName,\n lastName: account.lastName,\n businessName: account.businessName,\n ...result,\n });\n\n } catch (err) {\n const msg = err instanceof Error ? err.message : String(err);\n console.error(` ❌ Lỗi: ${msg}`);\n await saveResult({\n email: \"error\",\n firstName: account.firstName,\n lastName: account.lastName,\n businessName: account.businessName,\n status: \"failed\",\n errorMessage: msg,\n });\n }\n\n // Delay giữa các tài khoản\n if (i < accounts.length - 1) {\n console.log(`\\n ⏸️ Nghỉ ${DELAY_BETWEEN / 1000}s...`);\n await new Promise((r) => setTimeout(r, DELAY_BETWEEN));\n }\n}\n\nconsole.log(\"\\n\" + \"=\".repeat(60));\nawait printSummary();\nconsole.log(\"\\n✅ Hoàn tất tất cả tài khoản!\");\n",8,["D",1773394893273],81,{"_105":378,"_170":148,"_167":207,"_97":101,"_178":379,"_176":191,"_102":291,"_169":-5,"_107":380,"_171":381,"_181":-5},"cc8884fe-1ec0-11f1-91a9-42dde27851f2","/**\n * PHASE 2 — REPLAY TỰ ĐỘNG THEO PLAYBOOK ĐÃ HỌC\n * =================================================\n * Đọc playbook từ SQLite (đã học bởi agentLearn.ts),\n * chạy lại đúng quy trình cho từng tài khoản trong Sheets.\n *\n * ⚠️ Phải chạy agentLearn.ts TRƯỚC để có playbook.\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, type AccountData } from \"./sheets.ts\";\nimport { generateDDGAlias } from \"./ddgEmail.ts\";\nimport { solveHCaptchaWithGemini } from \"./captcha.ts\";\nimport { initResultsDB, saveResult, printSummary } from \"./results.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\";\n\nconst EBAY_CAPTCHA_URL = \"https://www.ebay.com/splashui/captcha?\";\nconst EBAY_REGISTER_URL = \"https://signup.ebay.com/pa/crte?\";\nconst DELAY_BETWEEN = 15000; // ms giữa các tài khoản\nconst RUN_LIMIT = 5; // chạy 5 tài khoản\n\n// ── Kiểu dữ liệu playbook step ────────────────────────\ninterface PlaybookStep {\n stepOrder: number;\n action: string;\n description: string;\n selector: string | null;\n value: string | null;\n fieldKey: string | null;\n waitMs: number;\n}\n\n// ─────────────────────────────────────────────────────\n// Đọc playbook từ SQLite\n// ─────────────────────────────────────────────────────\nasync function loadPlaybook(): Promise {\n const res = await sqlite.execute(\n \"SELECT * FROM ebay_playbook ORDER BY stepOrder\"\n );\n if (res.rows.length === 0) {\n throw new Error(\"❌ Playbook trống! Hãy chạy agentLearn.ts trước.\");\n }\n return res.rows.map((r) => ({\n stepOrder: r.stepOrder as number,\n action: r.action as string,\n description: r.description as string,\n selector: r.selector as string | null,\n value: r.value as string | null,\n fieldKey: r.fieldKey as string | null,\n waitMs: (r.waitMs as number) || 500,\n }));\n}\n\n// ─────────────────────────────────────────────────────\n// Map fieldKey → giá trị thực tế của tài khoản\n// ─────────────────────────────────────────────────────\nfunction resolveValue(\n fieldKey: string | null,\n templateValue: string | null,\n account: AccountData,\n email: string\n): string {\n if (!fieldKey) return templateValue || \"\";\n const map: Record = {\n businessName: account.businessName,\n firstName: account.firstName,\n lastName: account.lastName,\n email: email,\n username: email.split(\"@\")[0].replace(/[^a-zA-Z0-9]/g, \"\").slice(0, 64),\n password: account.password,\n phone: account.phone,\n address: account.address,\n city: account.city,\n state: account.state,\n zip: account.zip,\n };\n return map[fieldKey] ?? templateValue ?? \"\";\n}\n\n// ─────────────────────────────────────────────────────\n// Dùng AI phân tích kết quả đăng ký\n// ─────────────────────────────────────────────────────\nasync function analyzeResult(\n ai: OpenAI,\n url: string,\n pageTitle: string,\n pageText: string\n): Promise<{ success: boolean; reason: string }> {\n const res = await ai.chat.completions.create({\n model: AI_MODEL,\n messages: [\n {\n role: \"system\",\n content: `Phân tích kết quả đăng ký tài khoản eBay.\nTrả về JSON: {\"success\": true/false, \"reason\": \"lý do ngắn gọn\"}`,\n },\n {\n role: \"user\",\n content: `URL: ${url}\nTitle: ${pageTitle}\nNội dung trang (500 ký tự đầu): ${pageText.slice(0, 500)}`,\n },\n ],\n temperature: 0.1,\n max_tokens: 150,\n });\n try {\n const text = res.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// Dùng AI sửa selector nếu bị lỗi\n// ─────────────────────────────────────────────────────\nasync function fixSelectorWithAI(\n ai: OpenAI,\n html: string,\n description: string,\n brokenSelector: string\n): Promise {\n const res = await ai.chat.completions.create({\n model: AI_MODEL,\n messages: [\n {\n role: \"system\",\n content: `Selector CSS bị lỗi, hãy tìm selector mới đúng hơn.\nTrả về JSON: {\"selector\": \"...\"}`,\n },\n {\n role: \"user\",\n content: `Cần tìm: \"${description}\"\nSelector cũ bị lỗi: \"${brokenSelector}\"\nHTML (rút gọn): ${html.slice(0, 6000)}`,\n },\n ],\n temperature: 0.1,\n max_tokens: 150,\n });\n try {\n const text = res.choices[0].message.content || \"{}\";\n const json = text.match(/\\{.*\\}/s)?.[0] || \"{}\";\n return JSON.parse(json).selector || \"\";\n } catch {\n return \"\";\n }\n}\n\n// ─────────────────────────────────────────────────────\n// Replay playbook cho 1 tài khoản\n// ─────────────────────────────────────────────────────\nasync function replayForAccount(\n kernel: InstanceType,\n ai: OpenAI,\n playbook: PlaybookStep[],\n account: AccountData,\n email: string\n): Promise<{ status: \"success\" | \"failed\"; ebayUsername?: string; errorMessage?: string }> {\n\n const NOPECHA_EXTENSION_ID = Deno.env.get(\"NOPECHA_EXTENSION_ID\") || \"k17g3z4olapuyz9oaf2z0i0d\";\n const createOpts: any = {};\n if (NOPECHA_EXTENSION_ID) createOpts.extension_ids = [NOPECHA_EXTENSION_ID];\n const kernelBrowser = await kernel.browsers.create(createOpts);\n\n // Lưu session vào DB để Live View theo dõi được\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 await sqlite.execute({\n sql: `INSERT OR REPLACE INTO browser_sessions (sessionId, liveViewUrl, cdpWsUrl, label, status)\n VALUES (?,?,?,?,'active')`,\n args: [\n kernelBrowser.session_id,\n kernelBrowser.browser_live_view_url,\n kernelBrowser.cdp_ws_url,\n `🔁 Replay: ${account.firstName} ${account.lastName}`,\n ],\n });\n console.log(` 🔴 Live: /live?session=${kernelBrowser.session_id}`);\n\n const browser = await chromium.connectOverCDP(kernelBrowser.cdp_ws_url);\n\n try {\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 const username = email.split(\"@\")[0].replace(/[^a-zA-Z0-9]/g, \"\").slice(0, 64);\n\n for (const step of playbook) {\n console.log(` [${step.stepOrder}] ${step.action.toUpperCase().padEnd(12)} ${step.description}`);\n\n try {\n // ── goto ────────────────────────────────────────\n if (step.action === \"goto\") {\n const gotoUrl = step.value || EBAY_REGISTER_URL;\n console.log(` → ${gotoUrl}`);\n await page.goto(gotoUrl, { waitUntil: \"domcontentloaded\", timeout: 30000 });\n await page.waitForTimeout(step.waitMs);\n }\n\n // ── solve_captcha ────────────────────────────────\n else if (step.action === \"solve_captcha\") {\n const solved = await solveHCaptchaWithGemini(page);\n console.log(` 🔐 hCaptcha: ${solved ? \"✅ giải xong\" : \"⚠️ không giải được\"}`);\n await page.waitForTimeout(step.waitMs);\n }\n\n // ── click ───────────────────────────────────────\n else if (step.action === \"click\" && step.selector) {\n const el = page.locator(step.selector).first();\n const visible = await el.isVisible({ timeout: 4000 }).catch(() => false);\n\n if (visible) {\n await el.click();\n await page.waitForTimeout(step.waitMs);\n } else {\n // AI tự sửa selector bị lỗi\n console.log(` ⚠️ Selector lỗi, AI đang tìm lại...`);\n const html = await page.content();\n const newSel = await fixSelectorWithAI(ai, html, step.description, step.selector);\n if (newSel) {\n await page.click(newSel, { timeout: 5000 });\n await page.waitForTimeout(step.waitMs);\n console.log(` 🔧 AI đã sửa selector: \"${newSel}\"`);\n }\n }\n }\n\n // ── fill ────────────────────────────────────────\n else if (step.action === \"fill\" && step.selector) {\n const value = resolveValue(step.fieldKey, step.value, account, email);\n const el = page.locator(step.selector).first();\n const visible = await el.isVisible({ timeout: 4000 }).catch(() => false);\n\n if (visible) {\n await el.fill(value);\n await page.waitForTimeout(step.waitMs);\n const display = step.fieldKey === \"password\" ? \"***\" : value;\n console.log(` → \"${step.fieldKey}\": ${display}`);\n } else {\n // AI tự sửa selector\n console.log(` ⚠️ Selector lỗi, AI đang tìm lại...`);\n const html = await page.content();\n const newSel = await fixSelectorWithAI(ai, html, step.description, step.selector);\n if (newSel) {\n await page.fill(newSel, value);\n await page.waitForTimeout(step.waitMs);\n console.log(` 🔧 AI sửa selector → điền \"${step.fieldKey}\"`);\n }\n }\n }\n\n // ── check_result ────────────────────────────────\n else if (step.action === \"check_result\") {\n await page.waitForTimeout(step.waitMs);\n\n // Xử lý hCaptcha nếu xuất hiện sau submit\n const hasHCaptcha = await page.locator('iframe[title*=\"hCaptcha\"], iframe[title*=\"Widget containing checkbox\"]').count().catch(() => 0) > 0;\n if (hasHCaptcha) {\n console.log(` 🔐 Phát hiện hCaptcha sau submit, đang giải...`);\n await solveHCaptchaWithGemini(page);\n await page.waitForTimeout(3000);\n }\n\n // AI phân tích kết quả\n const url = page.url();\n const title = await page.title();\n const bodyText = await page.locator(\"body\").innerText().catch(() => \"\");\n const analysis = await analyzeResult(ai, url, title, bodyText);\n\n if (analysis.success) {\n return { status: \"success\", ebayUsername: username };\n } else {\n // Tìm thêm thông báo lỗi trên trang\n const errText = await page.locator('.errRt, .error-message, [role=\"alert\"], .field-error')\n .first().textContent().catch(() => null);\n return {\n status: \"failed\",\n errorMessage: errText?.trim() || analysis.reason,\n };\n }\n }\n\n } catch (stepErr) {\n console.log(` ⚠️ Step lỗi: ${stepErr.message} — tiếp tục...`);\n }\n }\n\n return { status: \"failed\", errorMessage: \"Không hoàn tất playbook\" };\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}\n\n// ─────────────────────────────────────────────────────\n// MAIN\n// ─────────────────────────────────────────────────────\nconsole.log(\"🚀 PHASE 2: Replay tự động theo playbook đã học\\n\");\n\nconst ai = new OpenAI({ apiKey: AI_API_KEY, baseURL: AI_BASE_URL });\nconst kernel = new Kernel();\n\n// Khởi tạo DB kết quả\nawait initResultsDB();\n\n// Tải playbook\nconsole.log(\"📖 Đọc playbook từ database...\");\nconst playbook = await loadPlaybook();\nconsole.log(`✅ Playbook: ${playbook.length} bước\\n`);\nfor (const s of playbook) {\n console.log(` [${s.stepOrder}] ${s.action.toUpperCase().padEnd(12)} ${s.description}`);\n}\n\n// Tải danh sách tài khoản\nconsole.log(\"\\n📊 Đọc dữ liệu từ Google Sheets...\");\nconst accounts = await fetchAccountsFromSheets();\n\nif (accounts.length === 0) {\n console.error(\"❌ Không có tài khoản nào trong Sheets!\");\n Deno.exit(1);\n}\n\nconsole.log(`\\n🎯 Bắt đầu đăng ký ${accounts.length} tài khoản...\\n`);\nconsole.log(\"=\".repeat(60));\n\nfor (let i = 0; i < accounts.length; i++) {\n const account = accounts[i];\n console.log(`\\n[${i + 1}/${accounts.length}] ${account.firstName} ${account.lastName} — ${account.businessName}`);\n console.log(\"─\".repeat(50));\n\n try {\n // Tạo email @duck.com mới\n const { fullEmail } = await generateDDGAlias();\n console.log(` 📧 Email: ${fullEmail}`);\n\n // Replay\n const result = await replayForAccount(kernel, ai, playbook, account, fullEmail);\n\n const icon = result.status === \"success\" ? \"✅\" : \"❌\";\n console.log(` ${icon} Kết quả: ${result.status}${result.errorMessage ? \" — \" + result.errorMessage : \"\"}`);\n\n await saveResult({\n email: fullEmail,\n firstName: account.firstName,\n lastName: account.lastName,\n businessName: account.businessName,\n ...result,\n });\n\n } catch (err) {\n const msg = err instanceof Error ? err.message : String(err);\n console.error(` ❌ Lỗi: ${msg}`);\n await saveResult({\n email: \"error\",\n firstName: account.firstName,\n lastName: account.lastName,\n businessName: account.businessName,\n status: \"failed\",\n errorMessage: msg,\n });\n }\n\n // Delay giữa các tài khoản\n if (i < accounts.length - 1) {\n console.log(`\\n ⏸️ Nghỉ ${DELAY_BETWEEN / 1000}s...`);\n await new Promise((r) => setTimeout(r, DELAY_BETWEEN));\n }\n}\n\nconsole.log(\"\\n\" + \"=\".repeat(60));\nawait printSummary();\nconsole.log(\"\\n✅ Hoàn tất tất cả tài khoản!\");\n",["D",1773394883880],80,{"_105":383,"_170":148,"_167":207,"_97":101,"_178":384,"_176":191,"_102":385,"_169":-5,"_107":386,"_171":387,"_181":-5},"c330e82e-1ec0-11f1-ad90-42dde27851f2","/**\n * PHASE 2 — REPLAY TỰ ĐỘNG THEO PLAYBOOK ĐÃ HỌC\n * =================================================\n * Đọc playbook từ SQLite (đã học bởi agentLearn.ts),\n * chạy lại đúng quy trình cho từng tài khoản trong Sheets.\n *\n * ⚠️ Phải chạy agentLearn.ts TRƯỚC để có playbook.\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, type AccountData } from \"./sheets.ts\";\nimport { generateDDGAlias } from \"./ddgEmail.ts\";\nimport { solveHCaptchaWithGemini } from \"./captcha.ts\";\nimport { initResultsDB, saveResult, printSummary } from \"./results.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\";\n\nconst EBAY_CAPTCHA_URL = \"https://www.ebay.com/splashui/captcha?\";\nconst EBAY_REGISTER_URL = \"https://signup.ebay.com/pa/crte?\";\nconst DELAY_BETWEEN = 15000; // ms giữa các tài khoản\nconst RUN_LIMIT = 5; // chạy 5 tài khoản\n\n// ── Kiểu dữ liệu playbook step ────────────────────────\ninterface PlaybookStep {\n stepOrder: number;\n action: string;\n description: string;\n selector: string | null;\n value: string | null;\n fieldKey: string | null;\n waitMs: number;\n}\n\n// ─────────────────────────────────────────────────────\n// Đọc playbook từ SQLite\n// ─────────────────────────────────────────────────────\nasync function loadPlaybook(): Promise {\n const res = await sqlite.execute(\n \"SELECT * FROM ebay_playbook ORDER BY stepOrder\"\n );\n if (res.rows.length === 0) {\n throw new Error(\"❌ Playbook trống! Hãy chạy agentLearn.ts trước.\");\n }\n return res.rows.map((r) => ({\n stepOrder: r.stepOrder as number,\n action: r.action as string,\n description: r.description as string,\n selector: r.selector as string | null,\n value: r.value as string | null,\n fieldKey: r.fieldKey as string | null,\n waitMs: (r.waitMs as number) || 500,\n }));\n}\n\n// ─────────────────────────────────────────────────────\n// Map fieldKey → giá trị thực tế của tài khoản\n// ─────────────────────────────────────────────────────\nfunction resolveValue(\n fieldKey: string | null,\n templateValue: string | null,\n account: AccountData,\n email: string\n): string {\n if (!fieldKey) return templateValue || \"\";\n const map: Record = {\n businessName: account.businessName,\n firstName: account.firstName,\n lastName: account.lastName,\n email: email,\n username: email.split(\"@\")[0].replace(/[^a-zA-Z0-9]/g, \"\").slice(0, 64),\n password: account.password,\n phone: account.phone,\n address: account.address,\n city: account.city,\n state: account.state,\n zip: account.zip,\n };\n return map[fieldKey] ?? templateValue ?? \"\";\n}\n\n// ─────────────────────────────────────────────────────\n// Dùng AI phân tích kết quả đăng ký\n// ─────────────────────────────────────────────────────\nasync function analyzeResult(\n ai: OpenAI,\n url: string,\n pageTitle: string,\n pageText: string\n): Promise<{ success: boolean; reason: string }> {\n const res = await ai.chat.completions.create({\n model: AI_MODEL,\n messages: [\n {\n role: \"system\",\n content: `Phân tích kết quả đăng ký tài khoản eBay.\nTrả về JSON: {\"success\": true/false, \"reason\": \"lý do ngắn gọn\"}`,\n },\n {\n role: \"user\",\n content: `URL: ${url}\nTitle: ${pageTitle}\nNội dung trang (500 ký tự đầu): ${pageText.slice(0, 500)}`,\n },\n ],\n temperature: 0.1,\n max_tokens: 150,\n });\n try {\n const text = res.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// Dùng AI sửa selector nếu bị lỗi\n// ─────────────────────────────────────────────────────\nasync function fixSelectorWithAI(\n ai: OpenAI,\n html: string,\n description: string,\n brokenSelector: string\n): Promise {\n const res = await ai.chat.completions.create({\n model: AI_MODEL,\n messages: [\n {\n role: \"system\",\n content: `Selector CSS bị lỗi, hãy tìm selector mới đúng hơn.\nTrả về JSON: {\"selector\": \"...\"}`,\n },\n {\n role: \"user\",\n content: `Cần tìm: \"${description}\"\nSelector cũ bị lỗi: \"${brokenSelector}\"\nHTML (rút gọn): ${html.slice(0, 6000)}`,\n },\n ],\n temperature: 0.1,\n max_tokens: 150,\n });\n try {\n const text = res.choices[0].message.content || \"{}\";\n const json = text.match(/\\{.*\\}/s)?.[0] || \"{}\";\n return JSON.parse(json).selector || \"\";\n } catch {\n return \"\";\n }\n}\n\n// ─────────────────────────────────────────────────────\n// Replay playbook cho 1 tài khoản\n// ─────────────────────────────────────────────────────\nasync function replayForAccount(\n kernel: InstanceType,\n ai: OpenAI,\n playbook: PlaybookStep[],\n account: AccountData,\n email: string\n): Promise<{ status: \"success\" | \"failed\"; ebayUsername?: string; errorMessage?: string }> {\n\n const NOPECHA_EXTENSION_ID = Deno.env.get(\"NOPECHA_EXTENSION_ID\") || \"k17g3z4olapuyz9oaf2z0i0d\";\n const createOpts: any = {};\n if (NOPECHA_EXTENSION_ID) createOpts.extension_ids = [NOPECHA_EXTENSION_ID];\n const kernelBrowser = await kernel.browsers.create(createOpts);\n\n // Lưu session vào DB để Live View theo dõi được\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 await sqlite.execute({\n sql: `INSERT OR REPLACE INTO browser_sessions (sessionId, liveViewUrl, cdpWsUrl, label, status)\n VALUES (?,?,?,?,'active')`,\n args: [\n kernelBrowser.session_id,\n kernelBrowser.browser_live_view_url,\n kernelBrowser.cdp_ws_url,\n `🔁 Replay: ${account.firstName} ${account.lastName}`,\n ],\n });\n console.log(` 🔴 Live: /live?session=${kernelBrowser.session_id}`);\n\n const browser = await chromium.connectOverCDP(kernelBrowser.cdp_ws_url);\n\n try {\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 const username = email.split(\"@\")[0].replace(/[^a-zA-Z0-9]/g, \"\").slice(0, 64);\n\n for (const step of playbook) {\n console.log(` [${step.stepOrder}] ${step.action.toUpperCase().padEnd(12)} ${step.description}`);\n\n try {\n // ── goto ────────────────────────────────────────\n if (step.action === \"goto\") {\n const gotoUrl = step.value || EBAY_REGISTER_URL;\n console.log(` → ${gotoUrl}`);\n await page.goto(gotoUrl, { waitUntil: \"domcontentloaded\", timeout: 30000 });\n await page.waitForTimeout(step.waitMs);\n }\n\n // ── solve_captcha ────────────────────────────────\n else if (step.action === \"solve_captcha\") {\n const solved = await solveHCaptchaWithGemini(page);\n console.log(` 🔐 hCaptcha: ${solved ? \"✅ giải xong\" : \"⚠️ không giải được\"}`);\n await page.waitForTimeout(step.waitMs);\n }\n\n // ── click ───────────────────────────────────────\n else if (step.action === \"click\" && step.selector) {\n const el = page.locator(step.selector).first();\n const visible = await el.isVisible({ timeout: 4000 }).catch(() => false);\n\n if (visible) {\n await el.click();\n await page.waitForTimeout(step.waitMs);\n } else {\n // AI tự sửa selector bị lỗi\n console.log(` ⚠️ Selector lỗi, AI đang tìm lại...`);\n const html = await page.content();\n const newSel = await fixSelectorWithAI(ai, html, step.description, step.selector);\n if (newSel) {\n await page.click(newSel, { timeout: 5000 });\n await page.waitForTimeout(step.waitMs);\n console.log(` 🔧 AI đã sửa selector: \"${newSel}\"`);\n }\n }\n }\n\n // ── fill ────────────────────────────────────────\n else if (step.action === \"fill\" && step.selector) {\n const value = resolveValue(step.fieldKey, step.value, account, email);\n const el = page.locator(step.selector).first();\n const visible = await el.isVisible({ timeout: 4000 }).catch(() => false);\n\n if (visible) {\n await el.fill(value);\n await page.waitForTimeout(step.waitMs);\n const display = step.fieldKey === \"password\" ? \"***\" : value;\n console.log(` → \"${step.fieldKey}\": ${display}`);\n } else {\n // AI tự sửa selector\n console.log(` ⚠️ Selector lỗi, AI đang tìm lại...`);\n const html = await page.content();\n const newSel = await fixSelectorWithAI(ai, html, step.description, step.selector);\n if (newSel) {\n await page.fill(newSel, value);\n await page.waitForTimeout(step.waitMs);\n console.log(` 🔧 AI sửa selector → điền \"${step.fieldKey}\"`);\n }\n }\n }\n\n // ── check_result ────────────────────────────────\n else if (step.action === \"check_result\") {\n await page.waitForTimeout(step.waitMs);\n\n // Xử lý CAPTCHA nếu có\n const hasCaptcha = await page.locator('iframe[src*=\"recaptcha\"]').count() > 0;\n if (hasCaptcha) {\n console.log(` 🔐 Phát hiện CAPTCHA, đang giải...`);\n try {\n const token = await solveRecaptchaV2(RECAPTCHA_SITE_KEY, EBAY_URL);\n await page.evaluate((t) => {\n const ta = document.querySelector(\"#g-recaptcha-response\") as HTMLTextAreaElement;\n if (ta) { ta.style.display = \"block\"; ta.value = t; }\n if ((window as any).___grecaptcha_cfg) {\n const clients = (window as any).___grecaptcha_cfg.clients;\n for (const k in clients) {\n const c = clients[k];\n for (const j in c) {\n if (c[j] && typeof c[j].callback === \"function\") c[j].callback(t);\n }\n }\n }\n }, token);\n await page.waitForTimeout(2000);\n\n // Click submit lại sau khi giải captcha\n for (const sel of ['button[type=\"submit\"]', 'button:has-text(\"Create account\")', 'button:has-text(\"Register\")']) {\n const el = page.locator(sel).first();\n if (await el.isVisible().catch(() => false)) {\n await el.click();\n await page.waitForTimeout(4000);\n break;\n }\n }\n } catch (e) {\n console.log(` ⚠️ CAPTCHA: ${e.message}`);\n }\n }\n\n // AI phân tích kết quả\n const url = page.url();\n const title = await page.title();\n const bodyText = await page.locator(\"body\").innerText().catch(() => \"\");\n const analysis = await analyzeResult(ai, url, title, bodyText);\n\n if (analysis.success) {\n return { status: \"success\", ebayUsername: username };\n } else {\n // Tìm thêm thông báo lỗi trên trang\n const errText = await page.locator('.errRt, .error-message, [role=\"alert\"], .field-error')\n .first().textContent().catch(() => null);\n return {\n status: \"failed\",\n errorMessage: errText?.trim() || analysis.reason,\n };\n }\n }\n\n } catch (stepErr) {\n console.log(` ⚠️ Step lỗi: ${stepErr.message} — tiếp tục...`);\n }\n }\n\n return { status: \"failed\", errorMessage: \"Không hoàn tất playbook\" };\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}\n\n// ─────────────────────────────────────────────────────\n// MAIN\n// ─────────────────────────────────────────────────────\nconsole.log(\"🚀 PHASE 2: Replay tự động theo playbook đã học\\n\");\n\nconst ai = new OpenAI({ apiKey: AI_API_KEY, baseURL: AI_BASE_URL });\nconst kernel = new Kernel();\n\n// Khởi tạo DB kết quả\nawait initResultsDB();\n\n// Tải playbook\nconsole.log(\"📖 Đọc playbook từ database...\");\nconst playbook = await loadPlaybook();\nconsole.log(`✅ Playbook: ${playbook.length} bước\\n`);\nfor (const s of playbook) {\n console.log(` [${s.stepOrder}] ${s.action.toUpperCase().padEnd(12)} ${s.description}`);\n}\n\n// Tải danh sách tài khoản\nconsole.log(\"\\n📊 Đọc dữ liệu từ Google Sheets...\");\nconst accounts = await fetchAccountsFromSheets();\n\nif (accounts.length === 0) {\n console.error(\"❌ Không có tài khoản nào trong Sheets!\");\n Deno.exit(1);\n}\n\nconsole.log(`\\n🎯 Bắt đầu đăng ký ${accounts.length} tài khoản...\\n`);\nconsole.log(\"=\".repeat(60));\n\nfor (let i = 0; i < accounts.length; i++) {\n const account = accounts[i];\n console.log(`\\n[${i + 1}/${accounts.length}] ${account.firstName} ${account.lastName} — ${account.businessName}`);\n console.log(\"─\".repeat(50));\n\n try {\n // Tạo email @duck.com mới\n const { fullEmail } = await generateDDGAlias();\n console.log(` 📧 Email: ${fullEmail}`);\n\n // Replay\n const result = await replayForAccount(kernel, ai, playbook, account, fullEmail);\n\n const icon = result.status === \"success\" ? \"✅\" : \"❌\";\n console.log(` ${icon} Kết quả: ${result.status}${result.errorMessage ? \" — \" + result.errorMessage : \"\"}`);\n\n await saveResult({\n email: fullEmail,\n firstName: account.firstName,\n lastName: account.lastName,\n businessName: account.businessName,\n ...result,\n });\n\n } catch (err) {\n const msg = err instanceof Error ? err.message : String(err);\n console.error(` ❌ Lỗi: ${msg}`);\n await saveResult({\n email: \"error\",\n firstName: account.firstName,\n lastName: account.lastName,\n businessName: account.businessName,\n status: \"failed\",\n errorMessage: msg,\n });\n }\n\n // Delay giữa các tài khoản\n if (i < accounts.length - 1) {\n console.log(`\\n ⏸️ Nghỉ ${DELAY_BETWEEN / 1000}s...`);\n await new Promise((r) => setTimeout(r, DELAY_BETWEEN));\n }\n}\n\nconsole.log(\"\\n\" + \"=\".repeat(60));\nawait printSummary();\nconsole.log(\"\\n✅ Hoàn tất tất cả tài khoản!\");\n",6,["D",1773394868235],79,{"_105":389,"_170":148,"_167":207,"_97":101,"_178":390,"_176":191,"_102":391,"_169":-5,"_107":392,"_171":393,"_181":-5},"bcebae22-1ec0-11f1-91a9-42dde27851f2","/**\n * PHASE 2 — REPLAY TỰ ĐỘNG THEO PLAYBOOK ĐÃ HỌC\n * =================================================\n * Đọc playbook từ SQLite (đã học bởi agentLearn.ts),\n * chạy lại đúng quy trình cho từng tài khoản trong Sheets.\n *\n * ⚠️ Phải chạy agentLearn.ts TRƯỚC để có playbook.\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, type AccountData } from \"./sheets.ts\";\nimport { generateDDGAlias } from \"./ddgEmail.ts\";\nimport { solveHCaptchaWithGemini } from \"./captcha.ts\";\nimport { initResultsDB, saveResult, printSummary } from \"./results.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\";\n\nconst EBAY_CAPTCHA_URL = \"https://www.ebay.com/splashui/captcha?\";\nconst EBAY_REGISTER_URL = \"https://signup.ebay.com/pa/crte?\";\nconst DELAY_BETWEEN = 15000; // ms giữa các tài khoản\nconst RUN_LIMIT = 5; // chạy 5 tài khoản\n\n// ── Kiểu dữ liệu playbook step ────────────────────────\ninterface PlaybookStep {\n stepOrder: number;\n action: string;\n description: string;\n selector: string | null;\n value: string | null;\n fieldKey: string | null;\n waitMs: number;\n}\n\n// ─────────────────────────────────────────────────────\n// Đọc playbook từ SQLite\n// ─────────────────────────────────────────────────────\nasync function loadPlaybook(): Promise {\n const res = await sqlite.execute(\n \"SELECT * FROM ebay_playbook ORDER BY stepOrder\"\n );\n if (res.rows.length === 0) {\n throw new Error(\"❌ Playbook trống! Hãy chạy agentLearn.ts trước.\");\n }\n return res.rows.map((r) => ({\n stepOrder: r.stepOrder as number,\n action: r.action as string,\n description: r.description as string,\n selector: r.selector as string | null,\n value: r.value as string | null,\n fieldKey: r.fieldKey as string | null,\n waitMs: (r.waitMs as number) || 500,\n }));\n}\n\n// ─────────────────────────────────────────────────────\n// Map fieldKey → giá trị thực tế của tài khoản\n// ─────────────────────────────────────────────────────\nfunction resolveValue(\n fieldKey: string | null,\n templateValue: string | null,\n account: AccountData,\n email: string\n): string {\n if (!fieldKey) return templateValue || \"\";\n const map: Record = {\n businessName: account.businessName,\n firstName: account.firstName,\n lastName: account.lastName,\n email: email,\n username: email.split(\"@\")[0].replace(/[^a-zA-Z0-9]/g, \"\").slice(0, 64),\n password: account.password,\n phone: account.phone,\n address: account.address,\n city: account.city,\n state: account.state,\n zip: account.zip,\n };\n return map[fieldKey] ?? templateValue ?? \"\";\n}\n\n// ─────────────────────────────────────────────────────\n// Dùng AI phân tích kết quả đăng ký\n// ─────────────────────────────────────────────────────\nasync function analyzeResult(\n ai: OpenAI,\n url: string,\n pageTitle: string,\n pageText: string\n): Promise<{ success: boolean; reason: string }> {\n const res = await ai.chat.completions.create({\n model: AI_MODEL,\n messages: [\n {\n role: \"system\",\n content: `Phân tích kết quả đăng ký tài khoản eBay.\nTrả về JSON: {\"success\": true/false, \"reason\": \"lý do ngắn gọn\"}`,\n },\n {\n role: \"user\",\n content: `URL: ${url}\nTitle: ${pageTitle}\nNội dung trang (500 ký tự đầu): ${pageText.slice(0, 500)}`,\n },\n ],\n temperature: 0.1,\n max_tokens: 150,\n });\n try {\n const text = res.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// Dùng AI sửa selector nếu bị lỗi\n// ─────────────────────────────────────────────────────\nasync function fixSelectorWithAI(\n ai: OpenAI,\n html: string,\n description: string,\n brokenSelector: string\n): Promise {\n const res = await ai.chat.completions.create({\n model: AI_MODEL,\n messages: [\n {\n role: \"system\",\n content: `Selector CSS bị lỗi, hãy tìm selector mới đúng hơn.\nTrả về JSON: {\"selector\": \"...\"}`,\n },\n {\n role: \"user\",\n content: `Cần tìm: \"${description}\"\nSelector cũ bị lỗi: \"${brokenSelector}\"\nHTML (rút gọn): ${html.slice(0, 6000)}`,\n },\n ],\n temperature: 0.1,\n max_tokens: 150,\n });\n try {\n const text = res.choices[0].message.content || \"{}\";\n const json = text.match(/\\{.*\\}/s)?.[0] || \"{}\";\n return JSON.parse(json).selector || \"\";\n } catch {\n return \"\";\n }\n}\n\n// ─────────────────────────────────────────────────────\n// Replay playbook cho 1 tài khoản\n// ─────────────────────────────────────────────────────\nasync function replayForAccount(\n kernel: InstanceType,\n ai: OpenAI,\n playbook: PlaybookStep[],\n account: AccountData,\n email: string\n): Promise<{ status: \"success\" | \"failed\"; ebayUsername?: string; errorMessage?: string }> {\n\n const NOPECHA_EXTENSION_ID = Deno.env.get(\"NOPECHA_EXTENSION_ID\") || \"k17g3z4olapuyz9oaf2z0i0d\";\n const createOpts: any = {};\n if (NOPECHA_EXTENSION_ID) createOpts.extension_ids = [NOPECHA_EXTENSION_ID];\n const kernelBrowser = await kernel.browsers.create(createOpts);\n\n // Lưu session vào DB để Live View theo dõi được\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 await sqlite.execute({\n sql: `INSERT OR REPLACE INTO browser_sessions (sessionId, liveViewUrl, cdpWsUrl, label, status)\n VALUES (?,?,?,?,'active')`,\n args: [\n kernelBrowser.session_id,\n kernelBrowser.browser_live_view_url,\n kernelBrowser.cdp_ws_url,\n `🔁 Replay: ${account.firstName} ${account.lastName}`,\n ],\n });\n console.log(` 🔴 Live: /live?session=${kernelBrowser.session_id}`);\n\n const browser = await chromium.connectOverCDP(kernelBrowser.cdp_ws_url);\n\n try {\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 const username = email.split(\"@\")[0].replace(/[^a-zA-Z0-9]/g, \"\").slice(0, 64);\n\n for (const step of playbook) {\n console.log(` [${step.stepOrder}] ${step.action.toUpperCase().padEnd(12)} ${step.description}`);\n\n try {\n // ── goto ────────────────────────────────────────\n if (step.action === \"goto\") {\n await page.goto(step.value || EBAY_URL, { waitUntil: \"networkidle\", timeout: 30000 });\n await page.waitForTimeout(step.waitMs);\n }\n\n // ── click ───────────────────────────────────────\n else if (step.action === \"click\" && step.selector) {\n const el = page.locator(step.selector).first();\n const visible = await el.isVisible({ timeout: 4000 }).catch(() => false);\n\n if (visible) {\n await el.click();\n await page.waitForTimeout(step.waitMs);\n } else {\n // AI tự sửa selector bị lỗi\n console.log(` ⚠️ Selector lỗi, AI đang tìm lại...`);\n const html = await page.content();\n const newSel = await fixSelectorWithAI(ai, html, step.description, step.selector);\n if (newSel) {\n await page.click(newSel, { timeout: 5000 });\n await page.waitForTimeout(step.waitMs);\n console.log(` 🔧 AI đã sửa selector: \"${newSel}\"`);\n }\n }\n }\n\n // ── fill ────────────────────────────────────────\n else if (step.action === \"fill\" && step.selector) {\n const value = resolveValue(step.fieldKey, step.value, account, email);\n const el = page.locator(step.selector).first();\n const visible = await el.isVisible({ timeout: 4000 }).catch(() => false);\n\n if (visible) {\n await el.fill(value);\n await page.waitForTimeout(step.waitMs);\n const display = step.fieldKey === \"password\" ? \"***\" : value;\n console.log(` → \"${step.fieldKey}\": ${display}`);\n } else {\n // AI tự sửa selector\n console.log(` ⚠️ Selector lỗi, AI đang tìm lại...`);\n const html = await page.content();\n const newSel = await fixSelectorWithAI(ai, html, step.description, step.selector);\n if (newSel) {\n await page.fill(newSel, value);\n await page.waitForTimeout(step.waitMs);\n console.log(` 🔧 AI sửa selector → điền \"${step.fieldKey}\"`);\n }\n }\n }\n\n // ── check_result ────────────────────────────────\n else if (step.action === \"check_result\") {\n await page.waitForTimeout(step.waitMs);\n\n // Xử lý CAPTCHA nếu có\n const hasCaptcha = await page.locator('iframe[src*=\"recaptcha\"]').count() > 0;\n if (hasCaptcha) {\n console.log(` 🔐 Phát hiện CAPTCHA, đang giải...`);\n try {\n const token = await solveRecaptchaV2(RECAPTCHA_SITE_KEY, EBAY_URL);\n await page.evaluate((t) => {\n const ta = document.querySelector(\"#g-recaptcha-response\") as HTMLTextAreaElement;\n if (ta) { ta.style.display = \"block\"; ta.value = t; }\n if ((window as any).___grecaptcha_cfg) {\n const clients = (window as any).___grecaptcha_cfg.clients;\n for (const k in clients) {\n const c = clients[k];\n for (const j in c) {\n if (c[j] && typeof c[j].callback === \"function\") c[j].callback(t);\n }\n }\n }\n }, token);\n await page.waitForTimeout(2000);\n\n // Click submit lại sau khi giải captcha\n for (const sel of ['button[type=\"submit\"]', 'button:has-text(\"Create account\")', 'button:has-text(\"Register\")']) {\n const el = page.locator(sel).first();\n if (await el.isVisible().catch(() => false)) {\n await el.click();\n await page.waitForTimeout(4000);\n break;\n }\n }\n } catch (e) {\n console.log(` ⚠️ CAPTCHA: ${e.message}`);\n }\n }\n\n // AI phân tích kết quả\n const url = page.url();\n const title = await page.title();\n const bodyText = await page.locator(\"body\").innerText().catch(() => \"\");\n const analysis = await analyzeResult(ai, url, title, bodyText);\n\n if (analysis.success) {\n return { status: \"success\", ebayUsername: username };\n } else {\n // Tìm thêm thông báo lỗi trên trang\n const errText = await page.locator('.errRt, .error-message, [role=\"alert\"], .field-error')\n .first().textContent().catch(() => null);\n return {\n status: \"failed\",\n errorMessage: errText?.trim() || analysis.reason,\n };\n }\n }\n\n } catch (stepErr) {\n console.log(` ⚠️ Step lỗi: ${stepErr.message} — tiếp tục...`);\n }\n }\n\n return { status: \"failed\", errorMessage: \"Không hoàn tất playbook\" };\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}\n\n// ─────────────────────────────────────────────────────\n// MAIN\n// ─────────────────────────────────────────────────────\nconsole.log(\"🚀 PHASE 2: Replay tự động theo playbook đã học\\n\");\n\nconst ai = new OpenAI({ apiKey: AI_API_KEY, baseURL: AI_BASE_URL });\nconst kernel = new Kernel();\n\n// Khởi tạo DB kết quả\nawait initResultsDB();\n\n// Tải playbook\nconsole.log(\"📖 Đọc playbook từ database...\");\nconst playbook = await loadPlaybook();\nconsole.log(`✅ Playbook: ${playbook.length} bước\\n`);\nfor (const s of playbook) {\n console.log(` [${s.stepOrder}] ${s.action.toUpperCase().padEnd(12)} ${s.description}`);\n}\n\n// Tải danh sách tài khoản\nconsole.log(\"\\n📊 Đọc dữ liệu từ Google Sheets...\");\nconst accounts = await fetchAccountsFromSheets();\n\nif (accounts.length === 0) {\n console.error(\"❌ Không có tài khoản nào trong Sheets!\");\n Deno.exit(1);\n}\n\nconsole.log(`\\n🎯 Bắt đầu đăng ký ${accounts.length} tài khoản...\\n`);\nconsole.log(\"=\".repeat(60));\n\nfor (let i = 0; i < accounts.length; i++) {\n const account = accounts[i];\n console.log(`\\n[${i + 1}/${accounts.length}] ${account.firstName} ${account.lastName} — ${account.businessName}`);\n console.log(\"─\".repeat(50));\n\n try {\n // Tạo email @duck.com mới\n const { fullEmail } = await generateDDGAlias();\n console.log(` 📧 Email: ${fullEmail}`);\n\n // Replay\n const result = await replayForAccount(kernel, ai, playbook, account, fullEmail);\n\n const icon = result.status === \"success\" ? \"✅\" : \"❌\";\n console.log(` ${icon} Kết quả: ${result.status}${result.errorMessage ? \" — \" + result.errorMessage : \"\"}`);\n\n await saveResult({\n email: fullEmail,\n firstName: account.firstName,\n lastName: account.lastName,\n businessName: account.businessName,\n ...result,\n });\n\n } catch (err) {\n const msg = err instanceof Error ? err.message : String(err);\n console.error(` ❌ Lỗi: ${msg}`);\n await saveResult({\n email: \"error\",\n firstName: account.firstName,\n lastName: account.lastName,\n businessName: account.businessName,\n status: \"failed\",\n errorMessage: msg,\n });\n }\n\n // Delay giữa các tài khoản\n if (i < accounts.length - 1) {\n console.log(`\\n ⏸️ Nghỉ ${DELAY_BETWEEN / 1000}s...`);\n await new Promise((r) => setTimeout(r, DELAY_BETWEEN));\n }\n}\n\nconsole.log(\"\\n\" + \"=\".repeat(60));\nawait printSummary();\nconsole.log(\"\\n✅ Hoàn tất tất cả tài khoản!\");\n",5,["D",1773394857717],78,{"_105":395,"_170":148,"_167":207,"_97":101,"_178":396,"_176":191,"_102":240,"_169":-5,"_107":397,"_171":398,"_181":-5},"b6891a74-1ec0-11f1-ad90-42dde27851f2","/**\n * PHASE 2 — REPLAY TỰ ĐỘNG THEO PLAYBOOK ĐÃ HỌC\n * =================================================\n * Đọc playbook từ SQLite (đã học bởi agentLearn.ts),\n * chạy lại đúng quy trình cho từng tài khoản trong Sheets.\n *\n * ⚠️ Phải chạy agentLearn.ts TRƯỚC để có playbook.\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, type AccountData } from \"./sheets.ts\";\nimport { generateDDGAlias } from \"./ddgEmail.ts\";\nimport { solveHCaptchaWithGemini } from \"./captcha.ts\";\nimport { initResultsDB, saveResult, printSummary } from \"./results.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\";\n\nconst EBAY_CAPTCHA_URL = \"https://www.ebay.com/splashui/captcha?\";\nconst EBAY_REGISTER_URL = \"https://signup.ebay.com/pa/crte?\";\nconst DELAY_BETWEEN = 15000; // ms giữa các tài khoản\nconst RUN_LIMIT = 5; // chạy 5 tài khoản\n\n// ── Kiểu dữ liệu playbook step ────────────────────────\ninterface PlaybookStep {\n stepOrder: number;\n action: string;\n description: string;\n selector: string | null;\n value: string | null;\n fieldKey: string | null;\n waitMs: number;\n}\n\n// ─────────────────────────────────────────────────────\n// Đọc playbook từ SQLite\n// ─────────────────────────────────────────────────────\nasync function loadPlaybook(): Promise {\n const res = await sqlite.execute(\n \"SELECT * FROM ebay_playbook ORDER BY stepOrder\"\n );\n if (res.rows.length === 0) {\n throw new Error(\"❌ Playbook trống! Hãy chạy agentLearn.ts trước.\");\n }\n return res.rows.map((r) => ({\n stepOrder: r.stepOrder as number,\n action: r.action as string,\n description: r.description as string,\n selector: r.selector as string | null,\n value: r.value as string | null,\n fieldKey: r.fieldKey as string | null,\n waitMs: (r.waitMs as number) || 500,\n }));\n}\n\n// ─────────────────────────────────────────────────────\n// Map fieldKey → giá trị thực tế của tài khoản\n// ─────────────────────────────────────────────────────\nfunction resolveValue(\n fieldKey: string | null,\n templateValue: string | null,\n account: AccountData,\n email: string\n): string {\n if (!fieldKey) return templateValue || \"\";\n const map: Record = {\n businessName: account.businessName,\n firstName: account.firstName,\n lastName: account.lastName,\n email: email,\n username: email.split(\"@\")[0].replace(/[^a-zA-Z0-9]/g, \"\").slice(0, 64),\n password: account.password,\n phone: account.phone,\n address: account.address,\n city: account.city,\n state: account.state,\n zip: account.zip,\n };\n return map[fieldKey] ?? templateValue ?? \"\";\n}\n\n// ─────────────────────────────────────────────────────\n// Dùng AI phân tích kết quả đăng ký\n// ─────────────────────────────────────────────────────\nasync function analyzeResult(\n ai: OpenAI,\n url: string,\n pageTitle: string,\n pageText: string\n): Promise<{ success: boolean; reason: string }> {\n const res = await ai.chat.completions.create({\n model: AI_MODEL,\n messages: [\n {\n role: \"system\",\n content: `Phân tích kết quả đăng ký tài khoản eBay.\nTrả về JSON: {\"success\": true/false, \"reason\": \"lý do ngắn gọn\"}`,\n },\n {\n role: \"user\",\n content: `URL: ${url}\nTitle: ${pageTitle}\nNội dung trang (500 ký tự đầu): ${pageText.slice(0, 500)}`,\n },\n ],\n temperature: 0.1,\n max_tokens: 150,\n });\n try {\n const text = res.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// Dùng AI sửa selector nếu bị lỗi\n// ─────────────────────────────────────────────────────\nasync function fixSelectorWithAI(\n ai: OpenAI,\n html: string,\n description: string,\n brokenSelector: string\n): Promise {\n const res = await ai.chat.completions.create({\n model: AI_MODEL,\n messages: [\n {\n role: \"system\",\n content: `Selector CSS bị lỗi, hãy tìm selector mới đúng hơn.\nTrả về JSON: {\"selector\": \"...\"}`,\n },\n {\n role: \"user\",\n content: `Cần tìm: \"${description}\"\nSelector cũ bị lỗi: \"${brokenSelector}\"\nHTML (rút gọn): ${html.slice(0, 6000)}`,\n },\n ],\n temperature: 0.1,\n max_tokens: 150,\n });\n try {\n const text = res.choices[0].message.content || \"{}\";\n const json = text.match(/\\{.*\\}/s)?.[0] || \"{}\";\n return JSON.parse(json).selector || \"\";\n } catch {\n return \"\";\n }\n}\n\n// ─────────────────────────────────────────────────────\n// Replay playbook cho 1 tài khoản\n// ─────────────────────────────────────────────────────\nasync function replayForAccount(\n kernel: InstanceType,\n ai: OpenAI,\n playbook: PlaybookStep[],\n account: AccountData,\n email: string\n): Promise<{ status: \"success\" | \"failed\"; ebayUsername?: string; errorMessage?: string }> {\n\n const kernelBrowser = await kernel.browsers.create();\n\n // Lưu session vào DB để Live View theo dõi được\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 await sqlite.execute({\n sql: `INSERT OR REPLACE INTO browser_sessions (sessionId, liveViewUrl, cdpWsUrl, label, status)\n VALUES (?,?,?,?,'active')`,\n args: [\n kernelBrowser.session_id,\n kernelBrowser.browser_live_view_url,\n kernelBrowser.cdp_ws_url,\n `🔁 Replay: ${account.firstName} ${account.lastName}`,\n ],\n });\n console.log(` 🔴 Live: /live?session=${kernelBrowser.session_id}`);\n\n const browser = await chromium.connectOverCDP(kernelBrowser.cdp_ws_url);\n\n try {\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 const username = email.split(\"@\")[0].replace(/[^a-zA-Z0-9]/g, \"\").slice(0, 64);\n\n for (const step of playbook) {\n console.log(` [${step.stepOrder}] ${step.action.toUpperCase().padEnd(12)} ${step.description}`);\n\n try {\n // ── goto ────────────────────────────────────────\n if (step.action === \"goto\") {\n await page.goto(step.value || EBAY_URL, { waitUntil: \"networkidle\", timeout: 30000 });\n await page.waitForTimeout(step.waitMs);\n }\n\n // ── click ───────────────────────────────────────\n else if (step.action === \"click\" && step.selector) {\n const el = page.locator(step.selector).first();\n const visible = await el.isVisible({ timeout: 4000 }).catch(() => false);\n\n if (visible) {\n await el.click();\n await page.waitForTimeout(step.waitMs);\n } else {\n // AI tự sửa selector bị lỗi\n console.log(` ⚠️ Selector lỗi, AI đang tìm lại...`);\n const html = await page.content();\n const newSel = await fixSelectorWithAI(ai, html, step.description, step.selector);\n if (newSel) {\n await page.click(newSel, { timeout: 5000 });\n await page.waitForTimeout(step.waitMs);\n console.log(` 🔧 AI đã sửa selector: \"${newSel}\"`);\n }\n }\n }\n\n // ── fill ────────────────────────────────────────\n else if (step.action === \"fill\" && step.selector) {\n const value = resolveValue(step.fieldKey, step.value, account, email);\n const el = page.locator(step.selector).first();\n const visible = await el.isVisible({ timeout: 4000 }).catch(() => false);\n\n if (visible) {\n await el.fill(value);\n await page.waitForTimeout(step.waitMs);\n const display = step.fieldKey === \"password\" ? \"***\" : value;\n console.log(` → \"${step.fieldKey}\": ${display}`);\n } else {\n // AI tự sửa selector\n console.log(` ⚠️ Selector lỗi, AI đang tìm lại...`);\n const html = await page.content();\n const newSel = await fixSelectorWithAI(ai, html, step.description, step.selector);\n if (newSel) {\n await page.fill(newSel, value);\n await page.waitForTimeout(step.waitMs);\n console.log(` 🔧 AI sửa selector → điền \"${step.fieldKey}\"`);\n }\n }\n }\n\n // ── check_result ────────────────────────────────\n else if (step.action === \"check_result\") {\n await page.waitForTimeout(step.waitMs);\n\n // Xử lý CAPTCHA nếu có\n const hasCaptcha = await page.locator('iframe[src*=\"recaptcha\"]').count() > 0;\n if (hasCaptcha) {\n console.log(` 🔐 Phát hiện CAPTCHA, đang giải...`);\n try {\n const token = await solveRecaptchaV2(RECAPTCHA_SITE_KEY, EBAY_URL);\n await page.evaluate((t) => {\n const ta = document.querySelector(\"#g-recaptcha-response\") as HTMLTextAreaElement;\n if (ta) { ta.style.display = \"block\"; ta.value = t; }\n if ((window as any).___grecaptcha_cfg) {\n const clients = (window as any).___grecaptcha_cfg.clients;\n for (const k in clients) {\n const c = clients[k];\n for (const j in c) {\n if (c[j] && typeof c[j].callback === \"function\") c[j].callback(t);\n }\n }\n }\n }, token);\n await page.waitForTimeout(2000);\n\n // Click submit lại sau khi giải captcha\n for (const sel of ['button[type=\"submit\"]', 'button:has-text(\"Create account\")', 'button:has-text(\"Register\")']) {\n const el = page.locator(sel).first();\n if (await el.isVisible().catch(() => false)) {\n await el.click();\n await page.waitForTimeout(4000);\n break;\n }\n }\n } catch (e) {\n console.log(` ⚠️ CAPTCHA: ${e.message}`);\n }\n }\n\n // AI phân tích kết quả\n const url = page.url();\n const title = await page.title();\n const bodyText = await page.locator(\"body\").innerText().catch(() => \"\");\n const analysis = await analyzeResult(ai, url, title, bodyText);\n\n if (analysis.success) {\n return { status: \"success\", ebayUsername: username };\n } else {\n // Tìm thêm thông báo lỗi trên trang\n const errText = await page.locator('.errRt, .error-message, [role=\"alert\"], .field-error')\n .first().textContent().catch(() => null);\n return {\n status: \"failed\",\n errorMessage: errText?.trim() || analysis.reason,\n };\n }\n }\n\n } catch (stepErr) {\n console.log(` ⚠️ Step lỗi: ${stepErr.message} — tiếp tục...`);\n }\n }\n\n return { status: \"failed\", errorMessage: \"Không hoàn tất playbook\" };\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}\n\n// ─────────────────────────────────────────────────────\n// MAIN\n// ─────────────────────────────────────────────────────\nconsole.log(\"🚀 PHASE 2: Replay tự động theo playbook đã học\\n\");\n\nconst ai = new OpenAI({ apiKey: AI_API_KEY, baseURL: AI_BASE_URL });\nconst kernel = new Kernel();\n\n// Khởi tạo DB kết quả\nawait initResultsDB();\n\n// Tải playbook\nconsole.log(\"📖 Đọc playbook từ database...\");\nconst playbook = await loadPlaybook();\nconsole.log(`✅ Playbook: ${playbook.length} bước\\n`);\nfor (const s of playbook) {\n console.log(` [${s.stepOrder}] ${s.action.toUpperCase().padEnd(12)} ${s.description}`);\n}\n\n// Tải danh sách tài khoản\nconsole.log(\"\\n📊 Đọc dữ liệu từ Google Sheets...\");\nconst accounts = await fetchAccountsFromSheets();\n\nif (accounts.length === 0) {\n console.error(\"❌ Không có tài khoản nào trong Sheets!\");\n Deno.exit(1);\n}\n\nconsole.log(`\\n🎯 Bắt đầu đăng ký ${accounts.length} tài khoản...\\n`);\nconsole.log(\"=\".repeat(60));\n\nfor (let i = 0; i < accounts.length; i++) {\n const account = accounts[i];\n console.log(`\\n[${i + 1}/${accounts.length}] ${account.firstName} ${account.lastName} — ${account.businessName}`);\n console.log(\"─\".repeat(50));\n\n try {\n // Tạo email @duck.com mới\n const { fullEmail } = await generateDDGAlias();\n console.log(` 📧 Email: ${fullEmail}`);\n\n // Replay\n const result = await replayForAccount(kernel, ai, playbook, account, fullEmail);\n\n const icon = result.status === \"success\" ? \"✅\" : \"❌\";\n console.log(` ${icon} Kết quả: ${result.status}${result.errorMessage ? \" — \" + result.errorMessage : \"\"}`);\n\n await saveResult({\n email: fullEmail,\n firstName: account.firstName,\n lastName: account.lastName,\n businessName: account.businessName,\n ...result,\n });\n\n } catch (err) {\n const msg = err instanceof Error ? err.message : String(err);\n console.error(` ❌ Lỗi: ${msg}`);\n await saveResult({\n email: \"error\",\n firstName: account.firstName,\n lastName: account.lastName,\n businessName: account.businessName,\n status: \"failed\",\n errorMessage: msg,\n });\n }\n\n // Delay giữa các tài khoản\n if (i < accounts.length - 1) {\n console.log(`\\n ⏸️ Nghỉ ${DELAY_BETWEEN / 1000}s...`);\n await new Promise((r) => setTimeout(r, DELAY_BETWEEN));\n }\n}\n\nconsole.log(\"\\n\" + \"=\".repeat(60));\nawait printSummary();\nconsole.log(\"\\n✅ Hoàn tất tất cả tài khoản!\");\n",["D",1773394847002],77,{"_105":400,"_170":148,"_167":207,"_97":101,"_178":401,"_176":191,"_102":201,"_169":-5,"_107":402,"_171":403,"_181":-5},"b03a4a4e-1ec0-11f1-91a9-42dde27851f2","/**\n * PHASE 2 — REPLAY TỰ ĐỘNG THEO PLAYBOOK ĐÃ HỌC\n * =================================================\n * Đọc playbook từ SQLite (đã học bởi agentLearn.ts),\n * chạy lại đúng quy trình cho từng tài khoản trong Sheets.\n *\n * ⚠️ Phải chạy agentLearn.ts TRƯỚC để có playbook.\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, type AccountData } from \"./sheets.ts\";\nimport { generateDDGAlias } from \"./ddgEmail.ts\";\nimport { solveHCaptchaWithGemini } from \"./captcha.ts\";\nimport { initResultsDB, saveResult, printSummary } from \"./results.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\";\n\nconst EBAY_URL = \"https://reg.ebay.com/reg/RegistrationPage?ru=https://www.ebay.com/&bizflow=3\";\nconst RECAPTCHA_SITE_KEY = \"6Lc6yUoUAAAAAL9tFpEFmNGDsyNH0R11o4JR4Rmg\";\nconst DELAY_BETWEEN = 15000; // ms giữa các tài khoản\n\n// ── Kiểu dữ liệu playbook step ────────────────────────\ninterface PlaybookStep {\n stepOrder: number;\n action: string;\n description: string;\n selector: string | null;\n value: string | null;\n fieldKey: string | null;\n waitMs: number;\n}\n\n// ─────────────────────────────────────────────────────\n// Đọc playbook từ SQLite\n// ─────────────────────────────────────────────────────\nasync function loadPlaybook(): Promise {\n const res = await sqlite.execute(\n \"SELECT * FROM ebay_playbook ORDER BY stepOrder\"\n );\n if (res.rows.length === 0) {\n throw new Error(\"❌ Playbook trống! Hãy chạy agentLearn.ts trước.\");\n }\n return res.rows.map((r) => ({\n stepOrder: r.stepOrder as number,\n action: r.action as string,\n description: r.description as string,\n selector: r.selector as string | null,\n value: r.value as string | null,\n fieldKey: r.fieldKey as string | null,\n waitMs: (r.waitMs as number) || 500,\n }));\n}\n\n// ─────────────────────────────────────────────────────\n// Map fieldKey → giá trị thực tế của tài khoản\n// ─────────────────────────────────────────────────────\nfunction resolveValue(\n fieldKey: string | null,\n templateValue: string | null,\n account: AccountData,\n email: string\n): string {\n if (!fieldKey) return templateValue || \"\";\n const map: Record = {\n businessName: account.businessName,\n firstName: account.firstName,\n lastName: account.lastName,\n email: email,\n username: email.split(\"@\")[0].replace(/[^a-zA-Z0-9]/g, \"\").slice(0, 64),\n password: account.password,\n phone: account.phone,\n address: account.address,\n city: account.city,\n state: account.state,\n zip: account.zip,\n };\n return map[fieldKey] ?? templateValue ?? \"\";\n}\n\n// ─────────────────────────────────────────────────────\n// Dùng AI phân tích kết quả đăng ký\n// ─────────────────────────────────────────────────────\nasync function analyzeResult(\n ai: OpenAI,\n url: string,\n pageTitle: string,\n pageText: string\n): Promise<{ success: boolean; reason: string }> {\n const res = await ai.chat.completions.create({\n model: AI_MODEL,\n messages: [\n {\n role: \"system\",\n content: `Phân tích kết quả đăng ký tài khoản eBay.\nTrả về JSON: {\"success\": true/false, \"reason\": \"lý do ngắn gọn\"}`,\n },\n {\n role: \"user\",\n content: `URL: ${url}\nTitle: ${pageTitle}\nNội dung trang (500 ký tự đầu): ${pageText.slice(0, 500)}`,\n },\n ],\n temperature: 0.1,\n max_tokens: 150,\n });\n try {\n const text = res.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// Dùng AI sửa selector nếu bị lỗi\n// ─────────────────────────────────────────────────────\nasync function fixSelectorWithAI(\n ai: OpenAI,\n html: string,\n description: string,\n brokenSelector: string\n): Promise {\n const res = await ai.chat.completions.create({\n model: AI_MODEL,\n messages: [\n {\n role: \"system\",\n content: `Selector CSS bị lỗi, hãy tìm selector mới đúng hơn.\nTrả về JSON: {\"selector\": \"...\"}`,\n },\n {\n role: \"user\",\n content: `Cần tìm: \"${description}\"\nSelector cũ bị lỗi: \"${brokenSelector}\"\nHTML (rút gọn): ${html.slice(0, 6000)}`,\n },\n ],\n temperature: 0.1,\n max_tokens: 150,\n });\n try {\n const text = res.choices[0].message.content || \"{}\";\n const json = text.match(/\\{.*\\}/s)?.[0] || \"{}\";\n return JSON.parse(json).selector || \"\";\n } catch {\n return \"\";\n }\n}\n\n// ─────────────────────────────────────────────────────\n// Replay playbook cho 1 tài khoản\n// ─────────────────────────────────────────────────────\nasync function replayForAccount(\n kernel: InstanceType,\n ai: OpenAI,\n playbook: PlaybookStep[],\n account: AccountData,\n email: string\n): Promise<{ status: \"success\" | \"failed\"; ebayUsername?: string; errorMessage?: string }> {\n\n const kernelBrowser = await kernel.browsers.create();\n\n // Lưu session vào DB để Live View theo dõi được\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 await sqlite.execute({\n sql: `INSERT OR REPLACE INTO browser_sessions (sessionId, liveViewUrl, cdpWsUrl, label, status)\n VALUES (?,?,?,?,'active')`,\n args: [\n kernelBrowser.session_id,\n kernelBrowser.browser_live_view_url,\n kernelBrowser.cdp_ws_url,\n `🔁 Replay: ${account.firstName} ${account.lastName}`,\n ],\n });\n console.log(` 🔴 Live: /live?session=${kernelBrowser.session_id}`);\n\n const browser = await chromium.connectOverCDP(kernelBrowser.cdp_ws_url);\n\n try {\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 const username = email.split(\"@\")[0].replace(/[^a-zA-Z0-9]/g, \"\").slice(0, 64);\n\n for (const step of playbook) {\n console.log(` [${step.stepOrder}] ${step.action.toUpperCase().padEnd(12)} ${step.description}`);\n\n try {\n // ── goto ────────────────────────────────────────\n if (step.action === \"goto\") {\n await page.goto(step.value || EBAY_URL, { waitUntil: \"networkidle\", timeout: 30000 });\n await page.waitForTimeout(step.waitMs);\n }\n\n // ── click ───────────────────────────────────────\n else if (step.action === \"click\" && step.selector) {\n const el = page.locator(step.selector).first();\n const visible = await el.isVisible({ timeout: 4000 }).catch(() => false);\n\n if (visible) {\n await el.click();\n await page.waitForTimeout(step.waitMs);\n } else {\n // AI tự sửa selector bị lỗi\n console.log(` ⚠️ Selector lỗi, AI đang tìm lại...`);\n const html = await page.content();\n const newSel = await fixSelectorWithAI(ai, html, step.description, step.selector);\n if (newSel) {\n await page.click(newSel, { timeout: 5000 });\n await page.waitForTimeout(step.waitMs);\n console.log(` 🔧 AI đã sửa selector: \"${newSel}\"`);\n }\n }\n }\n\n // ── fill ────────────────────────────────────────\n else if (step.action === \"fill\" && step.selector) {\n const value = resolveValue(step.fieldKey, step.value, account, email);\n const el = page.locator(step.selector).first();\n const visible = await el.isVisible({ timeout: 4000 }).catch(() => false);\n\n if (visible) {\n await el.fill(value);\n await page.waitForTimeout(step.waitMs);\n const display = step.fieldKey === \"password\" ? \"***\" : value;\n console.log(` → \"${step.fieldKey}\": ${display}`);\n } else {\n // AI tự sửa selector\n console.log(` ⚠️ Selector lỗi, AI đang tìm lại...`);\n const html = await page.content();\n const newSel = await fixSelectorWithAI(ai, html, step.description, step.selector);\n if (newSel) {\n await page.fill(newSel, value);\n await page.waitForTimeout(step.waitMs);\n console.log(` 🔧 AI sửa selector → điền \"${step.fieldKey}\"`);\n }\n }\n }\n\n // ── check_result ────────────────────────────────\n else if (step.action === \"check_result\") {\n await page.waitForTimeout(step.waitMs);\n\n // Xử lý CAPTCHA nếu có\n const hasCaptcha = await page.locator('iframe[src*=\"recaptcha\"]').count() > 0;\n if (hasCaptcha) {\n console.log(` 🔐 Phát hiện CAPTCHA, đang giải...`);\n try {\n const token = await solveRecaptchaV2(RECAPTCHA_SITE_KEY, EBAY_URL);\n await page.evaluate((t) => {\n const ta = document.querySelector(\"#g-recaptcha-response\") as HTMLTextAreaElement;\n if (ta) { ta.style.display = \"block\"; ta.value = t; }\n if ((window as any).___grecaptcha_cfg) {\n const clients = (window as any).___grecaptcha_cfg.clients;\n for (const k in clients) {\n const c = clients[k];\n for (const j in c) {\n if (c[j] && typeof c[j].callback === \"function\") c[j].callback(t);\n }\n }\n }\n }, token);\n await page.waitForTimeout(2000);\n\n // Click submit lại sau khi giải captcha\n for (const sel of ['button[type=\"submit\"]', 'button:has-text(\"Create account\")', 'button:has-text(\"Register\")']) {\n const el = page.locator(sel).first();\n if (await el.isVisible().catch(() => false)) {\n await el.click();\n await page.waitForTimeout(4000);\n break;\n }\n }\n } catch (e) {\n console.log(` ⚠️ CAPTCHA: ${e.message}`);\n }\n }\n\n // AI phân tích kết quả\n const url = page.url();\n const title = await page.title();\n const bodyText = await page.locator(\"body\").innerText().catch(() => \"\");\n const analysis = await analyzeResult(ai, url, title, bodyText);\n\n if (analysis.success) {\n return { status: \"success\", ebayUsername: username };\n } else {\n // Tìm thêm thông báo lỗi trên trang\n const errText = await page.locator('.errRt, .error-message, [role=\"alert\"], .field-error')\n .first().textContent().catch(() => null);\n return {\n status: \"failed\",\n errorMessage: errText?.trim() || analysis.reason,\n };\n }\n }\n\n } catch (stepErr) {\n console.log(` ⚠️ Step lỗi: ${stepErr.message} — tiếp tục...`);\n }\n }\n\n return { status: \"failed\", errorMessage: \"Không hoàn tất playbook\" };\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}\n\n// ─────────────────────────────────────────────────────\n// MAIN\n// ─────────────────────────────────────────────────────\nconsole.log(\"🚀 PHASE 2: Replay tự động theo playbook đã học\\n\");\n\nconst ai = new OpenAI({ apiKey: AI_API_KEY, baseURL: AI_BASE_URL });\nconst kernel = new Kernel();\n\n// Khởi tạo DB kết quả\nawait initResultsDB();\n\n// Tải playbook\nconsole.log(\"📖 Đọc playbook từ database...\");\nconst playbook = await loadPlaybook();\nconsole.log(`✅ Playbook: ${playbook.length} bước\\n`);\nfor (const s of playbook) {\n console.log(` [${s.stepOrder}] ${s.action.toUpperCase().padEnd(12)} ${s.description}`);\n}\n\n// Tải danh sách tài khoản\nconsole.log(\"\\n📊 Đọc dữ liệu từ Google Sheets...\");\nconst accounts = await fetchAccountsFromSheets();\n\nif (accounts.length === 0) {\n console.error(\"❌ Không có tài khoản nào trong Sheets!\");\n Deno.exit(1);\n}\n\nconsole.log(`\\n🎯 Bắt đầu đăng ký ${accounts.length} tài khoản...\\n`);\nconsole.log(\"=\".repeat(60));\n\nfor (let i = 0; i < accounts.length; i++) {\n const account = accounts[i];\n console.log(`\\n[${i + 1}/${accounts.length}] ${account.firstName} ${account.lastName} — ${account.businessName}`);\n console.log(\"─\".repeat(50));\n\n try {\n // Tạo email @duck.com mới\n const { fullEmail } = await generateDDGAlias();\n console.log(` 📧 Email: ${fullEmail}`);\n\n // Replay\n const result = await replayForAccount(kernel, ai, playbook, account, fullEmail);\n\n const icon = result.status === \"success\" ? \"✅\" : \"❌\";\n console.log(` ${icon} Kết quả: ${result.status}${result.errorMessage ? \" — \" + result.errorMessage : \"\"}`);\n\n await saveResult({\n email: fullEmail,\n firstName: account.firstName,\n lastName: account.lastName,\n businessName: account.businessName,\n ...result,\n });\n\n } catch (err) {\n const msg = err instanceof Error ? err.message : String(err);\n console.error(` ❌ Lỗi: ${msg}`);\n await saveResult({\n email: \"error\",\n firstName: account.firstName,\n lastName: account.lastName,\n businessName: account.businessName,\n status: \"failed\",\n errorMessage: msg,\n });\n }\n\n // Delay giữa các tài khoản\n if (i < accounts.length - 1) {\n console.log(`\\n ⏸️ Nghỉ ${DELAY_BETWEEN / 1000}s...`);\n await new Promise((r) => setTimeout(r, DELAY_BETWEEN));\n }\n}\n\nconsole.log(\"\\n\" + \"=\".repeat(60));\nawait printSummary();\nconsole.log(\"\\n✅ Hoàn tất tất cả tài khoản!\");\n",["D",1773394836413],76,{"_105":405,"_170":148,"_167":207,"_97":101,"_178":406,"_176":191,"_102":407,"_169":-5,"_107":408,"_171":409,"_181":-5},"5b811c8c-1e23-11f1-98a5-42dde27851f2","/**\n * PHASE 2 — REPLAY TỰ ĐỘNG THEO PLAYBOOK ĐÃ HỌC\n * =================================================\n * Đọc playbook từ SQLite (đã học bởi agentLearn.ts),\n * chạy lại đúng quy trình cho từng tài khoản trong Sheets.\n *\n * ⚠️ Phải chạy agentLearn.ts TRƯỚC để có playbook.\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, type AccountData } from \"./sheets.ts\";\nimport { generateDDGAlias } from \"./ddgEmail.ts\";\nimport { solveRecaptchaV2 } from \"./captcha.ts\";\nimport { initResultsDB, saveResult, printSummary } from \"./results.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\";\n\nconst EBAY_URL = \"https://reg.ebay.com/reg/RegistrationPage?ru=https://www.ebay.com/&bizflow=3\";\nconst RECAPTCHA_SITE_KEY = \"6Lc6yUoUAAAAAL9tFpEFmNGDsyNH0R11o4JR4Rmg\";\nconst DELAY_BETWEEN = 15000; // ms giữa các tài khoản\n\n// ── Kiểu dữ liệu playbook step ────────────────────────\ninterface PlaybookStep {\n stepOrder: number;\n action: string;\n description: string;\n selector: string | null;\n value: string | null;\n fieldKey: string | null;\n waitMs: number;\n}\n\n// ─────────────────────────────────────────────────────\n// Đọc playbook từ SQLite\n// ─────────────────────────────────────────────────────\nasync function loadPlaybook(): Promise {\n const res = await sqlite.execute(\n \"SELECT * FROM ebay_playbook ORDER BY stepOrder\"\n );\n if (res.rows.length === 0) {\n throw new Error(\"❌ Playbook trống! Hãy chạy agentLearn.ts trước.\");\n }\n return res.rows.map((r) => ({\n stepOrder: r.stepOrder as number,\n action: r.action as string,\n description: r.description as string,\n selector: r.selector as string | null,\n value: r.value as string | null,\n fieldKey: r.fieldKey as string | null,\n waitMs: (r.waitMs as number) || 500,\n }));\n}\n\n// ─────────────────────────────────────────────────────\n// Map fieldKey → giá trị thực tế của tài khoản\n// ─────────────────────────────────────────────────────\nfunction resolveValue(\n fieldKey: string | null,\n templateValue: string | null,\n account: AccountData,\n email: string\n): string {\n if (!fieldKey) return templateValue || \"\";\n const map: Record = {\n businessName: account.businessName,\n firstName: account.firstName,\n lastName: account.lastName,\n email: email,\n username: email.split(\"@\")[0].replace(/[^a-zA-Z0-9]/g, \"\").slice(0, 64),\n password: account.password,\n phone: account.phone,\n address: account.address,\n city: account.city,\n state: account.state,\n zip: account.zip,\n };\n return map[fieldKey] ?? templateValue ?? \"\";\n}\n\n// ─────────────────────────────────────────────────────\n// Dùng AI phân tích kết quả đăng ký\n// ─────────────────────────────────────────────────────\nasync function analyzeResult(\n ai: OpenAI,\n url: string,\n pageTitle: string,\n pageText: string\n): Promise<{ success: boolean; reason: string }> {\n const res = await ai.chat.completions.create({\n model: AI_MODEL,\n messages: [\n {\n role: \"system\",\n content: `Phân tích kết quả đăng ký tài khoản eBay.\nTrả về JSON: {\"success\": true/false, \"reason\": \"lý do ngắn gọn\"}`,\n },\n {\n role: \"user\",\n content: `URL: ${url}\nTitle: ${pageTitle}\nNội dung trang (500 ký tự đầu): ${pageText.slice(0, 500)}`,\n },\n ],\n temperature: 0.1,\n max_tokens: 150,\n });\n try {\n const text = res.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// Dùng AI sửa selector nếu bị lỗi\n// ─────────────────────────────────────────────────────\nasync function fixSelectorWithAI(\n ai: OpenAI,\n html: string,\n description: string,\n brokenSelector: string\n): Promise {\n const res = await ai.chat.completions.create({\n model: AI_MODEL,\n messages: [\n {\n role: \"system\",\n content: `Selector CSS bị lỗi, hãy tìm selector mới đúng hơn.\nTrả về JSON: {\"selector\": \"...\"}`,\n },\n {\n role: \"user\",\n content: `Cần tìm: \"${description}\"\nSelector cũ bị lỗi: \"${brokenSelector}\"\nHTML (rút gọn): ${html.slice(0, 6000)}`,\n },\n ],\n temperature: 0.1,\n max_tokens: 150,\n });\n try {\n const text = res.choices[0].message.content || \"{}\";\n const json = text.match(/\\{.*\\}/s)?.[0] || \"{}\";\n return JSON.parse(json).selector || \"\";\n } catch {\n return \"\";\n }\n}\n\n// ─────────────────────────────────────────────────────\n// Replay playbook cho 1 tài khoản\n// ─────────────────────────────────────────────────────\nasync function replayForAccount(\n kernel: InstanceType,\n ai: OpenAI,\n playbook: PlaybookStep[],\n account: AccountData,\n email: string\n): Promise<{ status: \"success\" | \"failed\"; ebayUsername?: string; errorMessage?: string }> {\n\n const kernelBrowser = await kernel.browsers.create();\n\n // Lưu session vào DB để Live View theo dõi được\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 await sqlite.execute({\n sql: `INSERT OR REPLACE INTO browser_sessions (sessionId, liveViewUrl, cdpWsUrl, label, status)\n VALUES (?,?,?,?,'active')`,\n args: [\n kernelBrowser.session_id,\n kernelBrowser.browser_live_view_url,\n kernelBrowser.cdp_ws_url,\n `🔁 Replay: ${account.firstName} ${account.lastName}`,\n ],\n });\n console.log(` 🔴 Live: /live?session=${kernelBrowser.session_id}`);\n\n const browser = await chromium.connectOverCDP(kernelBrowser.cdp_ws_url);\n\n try {\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 const username = email.split(\"@\")[0].replace(/[^a-zA-Z0-9]/g, \"\").slice(0, 64);\n\n for (const step of playbook) {\n console.log(` [${step.stepOrder}] ${step.action.toUpperCase().padEnd(12)} ${step.description}`);\n\n try {\n // ── goto ────────────────────────────────────────\n if (step.action === \"goto\") {\n await page.goto(step.value || EBAY_URL, { waitUntil: \"networkidle\", timeout: 30000 });\n await page.waitForTimeout(step.waitMs);\n }\n\n // ── click ───────────────────────────────────────\n else if (step.action === \"click\" && step.selector) {\n const el = page.locator(step.selector).first();\n const visible = await el.isVisible({ timeout: 4000 }).catch(() => false);\n\n if (visible) {\n await el.click();\n await page.waitForTimeout(step.waitMs);\n } else {\n // AI tự sửa selector bị lỗi\n console.log(` ⚠️ Selector lỗi, AI đang tìm lại...`);\n const html = await page.content();\n const newSel = await fixSelectorWithAI(ai, html, step.description, step.selector);\n if (newSel) {\n await page.click(newSel, { timeout: 5000 });\n await page.waitForTimeout(step.waitMs);\n console.log(` 🔧 AI đã sửa selector: \"${newSel}\"`);\n }\n }\n }\n\n // ── fill ────────────────────────────────────────\n else if (step.action === \"fill\" && step.selector) {\n const value = resolveValue(step.fieldKey, step.value, account, email);\n const el = page.locator(step.selector).first();\n const visible = await el.isVisible({ timeout: 4000 }).catch(() => false);\n\n if (visible) {\n await el.fill(value);\n await page.waitForTimeout(step.waitMs);\n const display = step.fieldKey === \"password\" ? \"***\" : value;\n console.log(` → \"${step.fieldKey}\": ${display}`);\n } else {\n // AI tự sửa selector\n console.log(` ⚠️ Selector lỗi, AI đang tìm lại...`);\n const html = await page.content();\n const newSel = await fixSelectorWithAI(ai, html, step.description, step.selector);\n if (newSel) {\n await page.fill(newSel, value);\n await page.waitForTimeout(step.waitMs);\n console.log(` 🔧 AI sửa selector → điền \"${step.fieldKey}\"`);\n }\n }\n }\n\n // ── check_result ────────────────────────────────\n else if (step.action === \"check_result\") {\n await page.waitForTimeout(step.waitMs);\n\n // Xử lý CAPTCHA nếu có\n const hasCaptcha = await page.locator('iframe[src*=\"recaptcha\"]').count() > 0;\n if (hasCaptcha) {\n console.log(` 🔐 Phát hiện CAPTCHA, đang giải...`);\n try {\n const token = await solveRecaptchaV2(RECAPTCHA_SITE_KEY, EBAY_URL);\n await page.evaluate((t) => {\n const ta = document.querySelector(\"#g-recaptcha-response\") as HTMLTextAreaElement;\n if (ta) { ta.style.display = \"block\"; ta.value = t; }\n if ((window as any).___grecaptcha_cfg) {\n const clients = (window as any).___grecaptcha_cfg.clients;\n for (const k in clients) {\n const c = clients[k];\n for (const j in c) {\n if (c[j] && typeof c[j].callback === \"function\") c[j].callback(t);\n }\n }\n }\n }, token);\n await page.waitForTimeout(2000);\n\n // Click submit lại sau khi giải captcha\n for (const sel of ['button[type=\"submit\"]', 'button:has-text(\"Create account\")', 'button:has-text(\"Register\")']) {\n const el = page.locator(sel).first();\n if (await el.isVisible().catch(() => false)) {\n await el.click();\n await page.waitForTimeout(4000);\n break;\n }\n }\n } catch (e) {\n console.log(` ⚠️ CAPTCHA: ${e.message}`);\n }\n }\n\n // AI phân tích kết quả\n const url = page.url();\n const title = await page.title();\n const bodyText = await page.locator(\"body\").innerText().catch(() => \"\");\n const analysis = await analyzeResult(ai, url, title, bodyText);\n\n if (analysis.success) {\n return { status: \"success\", ebayUsername: username };\n } else {\n // Tìm thêm thông báo lỗi trên trang\n const errText = await page.locator('.errRt, .error-message, [role=\"alert\"], .field-error')\n .first().textContent().catch(() => null);\n return {\n status: \"failed\",\n errorMessage: errText?.trim() || analysis.reason,\n };\n }\n }\n\n } catch (stepErr) {\n console.log(` ⚠️ Step lỗi: ${stepErr.message} — tiếp tục...`);\n }\n }\n\n return { status: \"failed\", errorMessage: \"Không hoàn tất playbook\" };\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}\n\n// ─────────────────────────────────────────────────────\n// MAIN\n// ─────────────────────────────────────────────────────\nconsole.log(\"🚀 PHASE 2: Replay tự động theo playbook đã học\\n\");\n\nconst ai = new OpenAI({ apiKey: AI_API_KEY, baseURL: AI_BASE_URL });\nconst kernel = new Kernel();\n\n// Khởi tạo DB kết quả\nawait initResultsDB();\n\n// Tải playbook\nconsole.log(\"📖 Đọc playbook từ database...\");\nconst playbook = await loadPlaybook();\nconsole.log(`✅ Playbook: ${playbook.length} bước\\n`);\nfor (const s of playbook) {\n console.log(` [${s.stepOrder}] ${s.action.toUpperCase().padEnd(12)} ${s.description}`);\n}\n\n// Tải danh sách tài khoản\nconsole.log(\"\\n📊 Đọc dữ liệu từ Google Sheets...\");\nconst accounts = await fetchAccountsFromSheets();\n\nif (accounts.length === 0) {\n console.error(\"❌ Không có tài khoản nào trong Sheets!\");\n Deno.exit(1);\n}\n\nconsole.log(`\\n🎯 Bắt đầu đăng ký ${accounts.length} tài khoản...\\n`);\nconsole.log(\"=\".repeat(60));\n\nfor (let i = 0; i < accounts.length; i++) {\n const account = accounts[i];\n console.log(`\\n[${i + 1}/${accounts.length}] ${account.firstName} ${account.lastName} — ${account.businessName}`);\n console.log(\"─\".repeat(50));\n\n try {\n // Tạo email @duck.com mới\n const { fullEmail } = await generateDDGAlias();\n console.log(` 📧 Email: ${fullEmail}`);\n\n // Replay\n const result = await replayForAccount(kernel, ai, playbook, account, fullEmail);\n\n const icon = result.status === \"success\" ? \"✅\" : \"❌\";\n console.log(` ${icon} Kết quả: ${result.status}${result.errorMessage ? \" — \" + result.errorMessage : \"\"}`);\n\n await saveResult({\n email: fullEmail,\n firstName: account.firstName,\n lastName: account.lastName,\n businessName: account.businessName,\n ...result,\n });\n\n } catch (err) {\n const msg = err instanceof Error ? err.message : String(err);\n console.error(` ❌ Lỗi: ${msg}`);\n await saveResult({\n email: \"error\",\n firstName: account.firstName,\n lastName: account.lastName,\n businessName: account.businessName,\n status: \"failed\",\n errorMessage: msg,\n });\n }\n\n // Delay giữa các tài khoản\n if (i < accounts.length - 1) {\n console.log(`\\n ⏸️ Nghỉ ${DELAY_BETWEEN / 1000}s...`);\n await new Promise((r) => setTimeout(r, DELAY_BETWEEN));\n }\n}\n\nconsole.log(\"\\n\" + \"=\".repeat(60));\nawait printSummary();\nconsole.log(\"\\n✅ Hoàn tất tất cả tài khoản!\");\n",2,["D",1773327263294],23,{"_105":411,"_170":148,"_167":207,"_97":101,"_178":412,"_176":191,"_102":172,"_169":-5,"_107":413,"_171":229,"_181":-5},"574d3b3c-1e23-11f1-8e8d-42dde27851f2","/**\n * PHASE 2 — REPLAY TỰ ĐỘNG THEO PLAYBOOK ĐÃ HỌC\n * =================================================\n * Đọc playbook từ SQLite (đã học bởi agentLearn.ts),\n * chạy lại đúng quy trình cho từng tài khoản trong Sheets.\n *\n * ⚠️ Phải chạy agentLearn.ts TRƯỚC để có playbook.\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, type AccountData } from \"./sheets.ts\";\nimport { generateDDGAlias } from \"./ddgEmail.ts\";\nimport { solveRecaptchaV2 } from \"./captcha.ts\";\nimport { initResultsDB, saveResult, printSummary } from \"./results.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\";\n\nconst EBAY_URL = \"https://reg.ebay.com/reg/RegistrationPage?ru=https://www.ebay.com/&bizflow=3\";\nconst RECAPTCHA_SITE_KEY = \"6Lc6yUoUAAAAAL9tFpEFmNGDsyNH0R11o4JR4Rmg\";\nconst DELAY_BETWEEN = 15000; // ms giữa các tài khoản\n\n// ── Kiểu dữ liệu playbook step ────────────────────────\ninterface PlaybookStep {\n stepOrder: number;\n action: string;\n description: string;\n selector: string | null;\n value: string | null;\n fieldKey: string | null;\n waitMs: number;\n}\n\n// ─────────────────────────────────────────────────────\n// Đọc playbook từ SQLite\n// ─────────────────────────────────────────────────────\nasync function loadPlaybook(): Promise {\n const res = await sqlite.execute(\n \"SELECT * FROM ebay_playbook ORDER BY stepOrder\"\n );\n if (res.rows.length === 0) {\n throw new Error(\"❌ Playbook trống! Hãy chạy agentLearn.ts trước.\");\n }\n return res.rows.map((r) => ({\n stepOrder: r.stepOrder as number,\n action: r.action as string,\n description: r.description as string,\n selector: r.selector as string | null,\n value: r.value as string | null,\n fieldKey: r.fieldKey as string | null,\n waitMs: (r.waitMs as number) || 500,\n }));\n}\n\n// ─────────────────────────────────────────────────────\n// Map fieldKey → giá trị thực tế của tài khoản\n// ─────────────────────────────────────────────────────\nfunction resolveValue(\n fieldKey: string | null,\n templateValue: string | null,\n account: AccountData,\n email: string\n): string {\n if (!fieldKey) return templateValue || \"\";\n const map: Record = {\n businessName: account.businessName,\n firstName: account.firstName,\n lastName: account.lastName,\n email: email,\n username: email.split(\"@\")[0].replace(/[^a-zA-Z0-9]/g, \"\").slice(0, 64),\n password: account.password,\n phone: account.phone,\n address: account.address,\n city: account.city,\n state: account.state,\n zip: account.zip,\n };\n return map[fieldKey] ?? templateValue ?? \"\";\n}\n\n// ─────────────────────────────────────────────────────\n// Dùng AI phân tích kết quả đăng ký\n// ─────────────────────────────────────────────────────\nasync function analyzeResult(\n ai: OpenAI,\n url: string,\n pageTitle: string,\n pageText: string\n): Promise<{ success: boolean; reason: string }> {\n const res = await ai.chat.completions.create({\n model: AI_MODEL,\n messages: [\n {\n role: \"system\",\n content: `Phân tích kết quả đăng ký tài khoản eBay.\nTrả về JSON: {\"success\": true/false, \"reason\": \"lý do ngắn gọn\"}`,\n },\n {\n role: \"user\",\n content: `URL: ${url}\nTitle: ${pageTitle}\nNội dung trang (500 ký tự đầu): ${pageText.slice(0, 500)}`,\n },\n ],\n temperature: 0.1,\n max_tokens: 150,\n });\n try {\n const text = res.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// Dùng AI sửa selector nếu bị lỗi\n// ─────────────────────────────────────────────────────\nasync function fixSelectorWithAI(\n ai: OpenAI,\n html: string,\n description: string,\n brokenSelector: string\n): Promise {\n const res = await ai.chat.completions.create({\n model: AI_MODEL,\n messages: [\n {\n role: \"system\",\n content: `Selector CSS bị lỗi, hãy tìm selector mới đúng hơn.\nTrả về JSON: {\"selector\": \"...\"}`,\n },\n {\n role: \"user\",\n content: `Cần tìm: \"${description}\"\nSelector cũ bị lỗi: \"${brokenSelector}\"\nHTML (rút gọn): ${html.slice(0, 6000)}`,\n },\n ],\n temperature: 0.1,\n max_tokens: 150,\n });\n try {\n const text = res.choices[0].message.content || \"{}\";\n const json = text.match(/\\{.*\\}/s)?.[0] || \"{}\";\n return JSON.parse(json).selector || \"\";\n } catch {\n return \"\";\n }\n}\n\n// ─────────────────────────────────────────────────────\n// Replay playbook cho 1 tài khoản\n// ─────────────────────────────────────────────────────\nasync function replayForAccount(\n kernel: InstanceType,\n ai: OpenAI,\n playbook: PlaybookStep[],\n account: AccountData,\n email: string\n): Promise<{ status: \"success\" | \"failed\"; ebayUsername?: string; errorMessage?: string }> {\n\n const kernelBrowser = await kernel.browsers.create();\n\n // Lưu session vào DB để Live View theo dõi được\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 await sqlite.execute({\n sql: `INSERT OR REPLACE INTO browser_sessions (sessionId, liveViewUrl, cdpWsUrl, label, status)\n VALUES (?,?,?,?,'active')`,\n args: [\n kernelBrowser.session_id,\n kernelBrowser.browser_live_view_url,\n kernelBrowser.cdp_ws_url,\n `🔁 Replay: ${account.firstName} ${account.lastName}`,\n ],\n });\n console.log(` 🔴 Live: /live?session=${kernelBrowser.session_id}`);\n\n const browser = await chromium.connectOverCDP(kernelBrowser.cdp_ws_url);\n\n try {\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 const username = email.split(\"@\")[0].replace(/[^a-zA-Z0-9]/g, \"\").slice(0, 64);\n\n for (const step of playbook) {\n console.log(` [${step.stepOrder}] ${step.action.toUpperCase().padEnd(12)} ${step.description}`);\n\n try {\n // ── goto ────────────────────────────────────────\n if (step.action === \"goto\") {\n await page.goto(step.value || EBAY_URL, { waitUntil: \"networkidle\", timeout: 30000 });\n await page.waitForTimeout(step.waitMs);\n }\n\n // ── click ───────────────────────────────────────\n else if (step.action === \"click\" && step.selector) {\n const el = page.locator(step.selector).first();\n const visible = await el.isVisible({ timeout: 4000 }).catch(() => false);\n\n if (visible) {\n await el.click();\n await page.waitForTimeout(step.waitMs);\n } else {\n // AI tự sửa selector bị lỗi\n console.log(` ⚠️ Selector lỗi, AI đang tìm lại...`);\n const html = await page.content();\n const newSel = await fixSelectorWithAI(ai, html, step.description, step.selector);\n if (newSel) {\n await page.click(newSel, { timeout: 5000 });\n await page.waitForTimeout(step.waitMs);\n console.log(` 🔧 AI đã sửa selector: \"${newSel}\"`);\n }\n }\n }\n\n // ── fill ────────────────────────────────────────\n else if (step.action === \"fill\" && step.selector) {\n const value = resolveValue(step.fieldKey, step.value, account, email);\n const el = page.locator(step.selector).first();\n const visible = await el.isVisible({ timeout: 4000 }).catch(() => false);\n\n if (visible) {\n await el.fill(value);\n await page.waitForTimeout(step.waitMs);\n const display = step.fieldKey === \"password\" ? \"***\" : value;\n console.log(` → \"${step.fieldKey}\": ${display}`);\n } else {\n // AI tự sửa selector\n console.log(` ⚠️ Selector lỗi, AI đang tìm lại...`);\n const html = await page.content();\n const newSel = await fixSelectorWithAI(ai, html, step.description, step.selector);\n if (newSel) {\n await page.fill(newSel, value);\n await page.waitForTimeout(step.waitMs);\n console.log(` 🔧 AI sửa selector → điền \"${step.fieldKey}\"`);\n }\n }\n }\n\n // ── check_result ────────────────────────────────\n else if (step.action === \"check_result\") {\n await page.waitForTimeout(step.waitMs);\n\n // Xử lý CAPTCHA nếu có\n const hasCaptcha = await page.locator('iframe[src*=\"recaptcha\"]').count() > 0;\n if (hasCaptcha) {\n console.log(` 🔐 Phát hiện CAPTCHA, đang giải...`);\n try {\n const token = await solveRecaptchaV2(RECAPTCHA_SITE_KEY, EBAY_URL);\n await page.evaluate((t) => {\n const ta = document.querySelector(\"#g-recaptcha-response\") as HTMLTextAreaElement;\n if (ta) { ta.style.display = \"block\"; ta.value = t; }\n if ((window as any).___grecaptcha_cfg) {\n const clients = (window as any).___grecaptcha_cfg.clients;\n for (const k in clients) {\n const c = clients[k];\n for (const j in c) {\n if (c[j] && typeof c[j].callback === \"function\") c[j].callback(t);\n }\n }\n }\n }, token);\n await page.waitForTimeout(2000);\n\n // Click submit lại sau khi giải captcha\n for (const sel of ['button[type=\"submit\"]', 'button:has-text(\"Create account\")', 'button:has-text(\"Register\")']) {\n const el = page.locator(sel).first();\n if (await el.isVisible().catch(() => false)) {\n await el.click();\n await page.waitForTimeout(4000);\n break;\n }\n }\n } catch (e) {\n console.log(` ⚠️ CAPTCHA: ${e.message}`);\n }\n }\n\n // AI phân tích kết quả\n const url = page.url();\n const title = await page.title();\n const bodyText = await page.locator(\"body\").innerText().catch(() => \"\");\n const analysis = await analyzeResult(ai, url, title, bodyText);\n\n if (analysis.success) {\n return { status: \"success\", ebayUsername: username };\n } else {\n // Tìm thêm thông báo lỗi trên trang\n const errText = await page.locator('.errRt, .error-message, [role=\"alert\"], .field-error')\n .first().textContent().catch(() => null);\n return {\n status: \"failed\",\n errorMessage: errText?.trim() || analysis.reason,\n };\n }\n }\n\n } catch (stepErr) {\n console.log(` ⚠️ Step lỗi: ${stepErr.message} — tiếp tục...`);\n }\n }\n\n return { status: \"failed\", errorMessage: \"Không hoàn tất playbook\" };\n\n } finally {\n await browser.close();\n await kernel.browsers.deleteByID(kernelBrowser.session_id);\n }\n}\n\n// ─────────────────────────────────────────────────────\n// MAIN\n// ─────────────────────────────────────────────────────\nconsole.log(\"🚀 PHASE 2: Replay tự động theo playbook đã học\\n\");\n\nconst ai = new OpenAI({ apiKey: AI_API_KEY, baseURL: AI_BASE_URL });\nconst kernel = new Kernel();\n\n// Khởi tạo DB kết quả\nawait initResultsDB();\n\n// Tải playbook\nconsole.log(\"📖 Đọc playbook từ database...\");\nconst playbook = await loadPlaybook();\nconsole.log(`✅ Playbook: ${playbook.length} bước\\n`);\nfor (const s of playbook) {\n console.log(` [${s.stepOrder}] ${s.action.toUpperCase().padEnd(12)} ${s.description}`);\n}\n\n// Tải danh sách tài khoản\nconsole.log(\"\\n📊 Đọc dữ liệu từ Google Sheets...\");\nconst accounts = await fetchAccountsFromSheets();\n\nif (accounts.length === 0) {\n console.error(\"❌ Không có tài khoản nào trong Sheets!\");\n Deno.exit(1);\n}\n\nconsole.log(`\\n🎯 Bắt đầu đăng ký ${accounts.length} tài khoản...\\n`);\nconsole.log(\"=\".repeat(60));\n\nfor (let i = 0; i < accounts.length; i++) {\n const account = accounts[i];\n console.log(`\\n[${i + 1}/${accounts.length}] ${account.firstName} ${account.lastName} — ${account.businessName}`);\n console.log(\"─\".repeat(50));\n\n try {\n // Tạo email @duck.com mới\n const { fullEmail } = await generateDDGAlias();\n console.log(` 📧 Email: ${fullEmail}`);\n\n // Replay\n const result = await replayForAccount(kernel, ai, playbook, account, fullEmail);\n\n const icon = result.status === \"success\" ? \"✅\" : \"❌\";\n console.log(` ${icon} Kết quả: ${result.status}${result.errorMessage ? \" — \" + result.errorMessage : \"\"}`);\n\n await saveResult({\n email: fullEmail,\n firstName: account.firstName,\n lastName: account.lastName,\n businessName: account.businessName,\n ...result,\n });\n\n } catch (err) {\n const msg = err instanceof Error ? err.message : String(err);\n console.error(` ❌ Lỗi: ${msg}`);\n await saveResult({\n email: \"error\",\n firstName: account.firstName,\n lastName: account.lastName,\n businessName: account.businessName,\n status: \"failed\",\n errorMessage: msg,\n });\n }\n\n // Delay giữa các tài khoản\n if (i < accounts.length - 1) {\n console.log(`\\n ⏸️ Nghỉ ${DELAY_BETWEEN / 1000}s...`);\n await new Promise((r) => setTimeout(r, DELAY_BETWEEN));\n }\n}\n\nconsole.log(\"\\n\" + \"=\".repeat(60));\nawait printSummary();\nconsole.log(\"\\n✅ Hoàn tất tất cả tài khoản!\");\n",["D",1773327256240],{"_105":415,"_170":148,"_167":207,"_97":101,"_178":416,"_176":191,"_102":33,"_169":-5,"_107":417,"_171":210,"_181":-5},"18b806b6-1cb3-11f1-b242-42dde27851f2","/**\n * PHASE 2 — REPLAY TỰ ĐỘNG THEO PLAYBOOK ĐÃ HỌC\n * =================================================\n * Đọc playbook từ SQLite (đã học bởi agentLearn.ts),\n * chạy lại đúng quy trình cho từng tài khoản trong Sheets.\n *\n * ⚠️ Phải chạy agentLearn.ts TRƯỚC để có playbook.\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, type AccountData } from \"./sheets.ts\";\nimport { generateDDGAlias } from \"./ddgEmail.ts\";\nimport { solveRecaptchaV2 } from \"./captcha.ts\";\nimport { initResultsDB, saveResult, printSummary } from \"./results.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\";\n\nconst EBAY_URL = \"https://reg.ebay.com/reg/RegistrationPage?ru=https://www.ebay.com/&bizflow=3\";\nconst RECAPTCHA_SITE_KEY = \"6Lc6yUoUAAAAAL9tFpEFmNGDsyNH0R11o4JR4Rmg\";\nconst DELAY_BETWEEN = 15000; // ms giữa các tài khoản\n\n// ── Kiểu dữ liệu playbook step ────────────────────────\ninterface PlaybookStep {\n stepOrder: number;\n action: string;\n description: string;\n selector: string | null;\n value: string | null;\n fieldKey: string | null;\n waitMs: number;\n}\n\n// ─────────────────────────────────────────────────────\n// Đọc playbook từ SQLite\n// ─────────────────────────────────────────────────────\nasync function loadPlaybook(): Promise {\n const res = await sqlite.execute(\n \"SELECT * FROM ebay_playbook ORDER BY stepOrder\"\n );\n if (res.rows.length === 0) {\n throw new Error(\"❌ Playbook trống! Hãy chạy agentLearn.ts trước.\");\n }\n return res.rows.map((r) => ({\n stepOrder: r.stepOrder as number,\n action: r.action as string,\n description: r.description as string,\n selector: r.selector as string | null,\n value: r.value as string | null,\n fieldKey: r.fieldKey as string | null,\n waitMs: (r.waitMs as number) || 500,\n }));\n}\n\n// ─────────────────────────────────────────────────────\n// Map fieldKey → giá trị thực tế của tài khoản\n// ─────────────────────────────────────────────────────\nfunction resolveValue(\n fieldKey: string | null,\n templateValue: string | null,\n account: AccountData,\n email: string\n): string {\n if (!fieldKey) return templateValue || \"\";\n const map: Record = {\n businessName: account.businessName,\n firstName: account.firstName,\n lastName: account.lastName,\n email: email,\n username: email.split(\"@\")[0].replace(/[^a-zA-Z0-9]/g, \"\").slice(0, 64),\n password: account.password,\n phone: account.phone,\n address: account.address,\n city: account.city,\n state: account.state,\n zip: account.zip,\n };\n return map[fieldKey] ?? templateValue ?? \"\";\n}\n\n// ─────────────────────────────────────────────────────\n// Dùng AI phân tích kết quả đăng ký\n// ─────────────────────────────────────────────────────\nasync function analyzeResult(\n ai: OpenAI,\n url: string,\n pageTitle: string,\n pageText: string\n): Promise<{ success: boolean; reason: string }> {\n const res = await ai.chat.completions.create({\n model: AI_MODEL,\n messages: [\n {\n role: \"system\",\n content: `Phân tích kết quả đăng ký tài khoản eBay.\nTrả về JSON: {\"success\": true/false, \"reason\": \"lý do ngắn gọn\"}`,\n },\n {\n role: \"user\",\n content: `URL: ${url}\nTitle: ${pageTitle}\nNội dung trang (500 ký tự đầu): ${pageText.slice(0, 500)}`,\n },\n ],\n temperature: 0.1,\n max_tokens: 150,\n });\n try {\n const text = res.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// Dùng AI sửa selector nếu bị lỗi\n// ─────────────────────────────────────────────────────\nasync function fixSelectorWithAI(\n ai: OpenAI,\n html: string,\n description: string,\n brokenSelector: string\n): Promise {\n const res = await ai.chat.completions.create({\n model: AI_MODEL,\n messages: [\n {\n role: \"system\",\n content: `Selector CSS bị lỗi, hãy tìm selector mới đúng hơn.\nTrả về JSON: {\"selector\": \"...\"}`,\n },\n {\n role: \"user\",\n content: `Cần tìm: \"${description}\"\nSelector cũ bị lỗi: \"${brokenSelector}\"\nHTML (rút gọn): ${html.slice(0, 6000)}`,\n },\n ],\n temperature: 0.1,\n max_tokens: 150,\n });\n try {\n const text = res.choices[0].message.content || \"{}\";\n const json = text.match(/\\{.*\\}/s)?.[0] || \"{}\";\n return JSON.parse(json).selector || \"\";\n } catch {\n return \"\";\n }\n}\n\n// ─────────────────────────────────────────────────────\n// Replay playbook cho 1 tài khoản\n// ─────────────────────────────────────────────────────\nasync function replayForAccount(\n kernel: InstanceType,\n ai: OpenAI,\n playbook: PlaybookStep[],\n account: AccountData,\n email: string\n): Promise<{ status: \"success\" | \"failed\"; ebayUsername?: string; errorMessage?: string }> {\n\n const kernelBrowser = await kernel.browsers.create();\n const browser = await chromium.connectOverCDP(kernelBrowser.cdp_ws_url);\n\n try {\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 const username = email.split(\"@\")[0].replace(/[^a-zA-Z0-9]/g, \"\").slice(0, 64);\n\n for (const step of playbook) {\n console.log(` [${step.stepOrder}] ${step.action.toUpperCase().padEnd(12)} ${step.description}`);\n\n try {\n // ── goto ────────────────────────────────────────\n if (step.action === \"goto\") {\n await page.goto(step.value || EBAY_URL, { waitUntil: \"networkidle\", timeout: 30000 });\n await page.waitForTimeout(step.waitMs);\n }\n\n // ── click ───────────────────────────────────────\n else if (step.action === \"click\" && step.selector) {\n const el = page.locator(step.selector).first();\n const visible = await el.isVisible({ timeout: 4000 }).catch(() => false);\n\n if (visible) {\n await el.click();\n await page.waitForTimeout(step.waitMs);\n } else {\n // AI tự sửa selector bị lỗi\n console.log(` ⚠️ Selector lỗi, AI đang tìm lại...`);\n const html = await page.content();\n const newSel = await fixSelectorWithAI(ai, html, step.description, step.selector);\n if (newSel) {\n await page.click(newSel, { timeout: 5000 });\n await page.waitForTimeout(step.waitMs);\n console.log(` 🔧 AI đã sửa selector: \"${newSel}\"`);\n }\n }\n }\n\n // ── fill ────────────────────────────────────────\n else if (step.action === \"fill\" && step.selector) {\n const value = resolveValue(step.fieldKey, step.value, account, email);\n const el = page.locator(step.selector).first();\n const visible = await el.isVisible({ timeout: 4000 }).catch(() => false);\n\n if (visible) {\n await el.fill(value);\n await page.waitForTimeout(step.waitMs);\n const display = step.fieldKey === \"password\" ? \"***\" : value;\n console.log(` → \"${step.fieldKey}\": ${display}`);\n } else {\n // AI tự sửa selector\n console.log(` ⚠️ Selector lỗi, AI đang tìm lại...`);\n const html = await page.content();\n const newSel = await fixSelectorWithAI(ai, html, step.description, step.selector);\n if (newSel) {\n await page.fill(newSel, value);\n await page.waitForTimeout(step.waitMs);\n console.log(` 🔧 AI sửa selector → điền \"${step.fieldKey}\"`);\n }\n }\n }\n\n // ── check_result ────────────────────────────────\n else if (step.action === \"check_result\") {\n await page.waitForTimeout(step.waitMs);\n\n // Xử lý CAPTCHA nếu có\n const hasCaptcha = await page.locator('iframe[src*=\"recaptcha\"]').count() > 0;\n if (hasCaptcha) {\n console.log(` 🔐 Phát hiện CAPTCHA, đang giải...`);\n try {\n const token = await solveRecaptchaV2(RECAPTCHA_SITE_KEY, EBAY_URL);\n await page.evaluate((t) => {\n const ta = document.querySelector(\"#g-recaptcha-response\") as HTMLTextAreaElement;\n if (ta) { ta.style.display = \"block\"; ta.value = t; }\n if ((window as any).___grecaptcha_cfg) {\n const clients = (window as any).___grecaptcha_cfg.clients;\n for (const k in clients) {\n const c = clients[k];\n for (const j in c) {\n if (c[j] && typeof c[j].callback === \"function\") c[j].callback(t);\n }\n }\n }\n }, token);\n await page.waitForTimeout(2000);\n\n // Click submit lại sau khi giải captcha\n for (const sel of ['button[type=\"submit\"]', 'button:has-text(\"Create account\")', 'button:has-text(\"Register\")']) {\n const el = page.locator(sel).first();\n if (await el.isVisible().catch(() => false)) {\n await el.click();\n await page.waitForTimeout(4000);\n break;\n }\n }\n } catch (e) {\n console.log(` ⚠️ CAPTCHA: ${e.message}`);\n }\n }\n\n // AI phân tích kết quả\n const url = page.url();\n const title = await page.title();\n const bodyText = await page.locator(\"body\").innerText().catch(() => \"\");\n const analysis = await analyzeResult(ai, url, title, bodyText);\n\n if (analysis.success) {\n return { status: \"success\", ebayUsername: username };\n } else {\n // Tìm thêm thông báo lỗi trên trang\n const errText = await page.locator('.errRt, .error-message, [role=\"alert\"], .field-error')\n .first().textContent().catch(() => null);\n return {\n status: \"failed\",\n errorMessage: errText?.trim() || analysis.reason,\n };\n }\n }\n\n } catch (stepErr) {\n console.log(` ⚠️ Step lỗi: ${stepErr.message} — tiếp tục...`);\n }\n }\n\n return { status: \"failed\", errorMessage: \"Không hoàn tất playbook\" };\n\n } finally {\n await browser.close();\n await kernel.browsers.deleteByID(kernelBrowser.session_id);\n }\n}\n\n// ─────────────────────────────────────────────────────\n// MAIN\n// ─────────────────────────────────────────────────────\nconsole.log(\"🚀 PHASE 2: Replay tự động theo playbook đã học\\n\");\n\nconst ai = new OpenAI({ apiKey: AI_API_KEY, baseURL: AI_BASE_URL });\nconst kernel = new Kernel();\n\n// Khởi tạo DB kết quả\nawait initResultsDB();\n\n// Tải playbook\nconsole.log(\"📖 Đọc playbook từ database...\");\nconst playbook = await loadPlaybook();\nconsole.log(`✅ Playbook: ${playbook.length} bước\\n`);\nfor (const s of playbook) {\n console.log(` [${s.stepOrder}] ${s.action.toUpperCase().padEnd(12)} ${s.description}`);\n}\n\n// Tải danh sách tài khoản\nconsole.log(\"\\n📊 Đọc dữ liệu từ Google Sheets...\");\nconst accounts = await fetchAccountsFromSheets();\n\nif (accounts.length === 0) {\n console.error(\"❌ Không có tài khoản nào trong Sheets!\");\n Deno.exit(1);\n}\n\nconsole.log(`\\n🎯 Bắt đầu đăng ký ${accounts.length} tài khoản...\\n`);\nconsole.log(\"=\".repeat(60));\n\nfor (let i = 0; i < accounts.length; i++) {\n const account = accounts[i];\n console.log(`\\n[${i + 1}/${accounts.length}] ${account.firstName} ${account.lastName} — ${account.businessName}`);\n console.log(\"─\".repeat(50));\n\n try {\n // Tạo email @duck.com mới\n const { fullEmail } = await generateDDGAlias();\n console.log(` 📧 Email: ${fullEmail}`);\n\n // Replay\n const result = await replayForAccount(kernel, ai, playbook, account, fullEmail);\n\n const icon = result.status === \"success\" ? \"✅\" : \"❌\";\n console.log(` ${icon} Kết quả: ${result.status}${result.errorMessage ? \" — \" + result.errorMessage : \"\"}`);\n\n await saveResult({\n email: fullEmail,\n firstName: account.firstName,\n lastName: account.lastName,\n businessName: account.businessName,\n ...result,\n });\n\n } catch (err) {\n const msg = err instanceof Error ? err.message : String(err);\n console.error(` ❌ Lỗi: ${msg}`);\n await saveResult({\n email: \"error\",\n firstName: account.firstName,\n lastName: account.lastName,\n businessName: account.businessName,\n status: \"failed\",\n errorMessage: msg,\n });\n }\n\n // Delay giữa các tài khoản\n if (i < accounts.length - 1) {\n console.log(`\\n ⏸️ Nghỉ ${DELAY_BETWEEN / 1000}s...`);\n await new Promise((r) => setTimeout(r, DELAY_BETWEEN));\n }\n}\n\nconsole.log(\"\\n\" + \"=\".repeat(60));\nawait printSummary();\nconsole.log(\"\\n✅ Hoàn tất tất cả tài khoản!\");\n",["D",1773169096453],"versions",[420,422,423,424,425,426,427,428,429,430,431],{"_177":363,"_421":365},"previous",{"_177":365,"_421":371},{"_177":371,"_421":377},{"_177":377,"_421":382},{"_177":382,"_421":388},{"_177":388,"_421":394},{"_177":394,"_421":399},{"_177":399,"_421":404},{"_177":404,"_421":410},{"_177":410,"_421":414},{"_177":414,"_421":-5},"versionNumber","page","hasNext","actionData","errors"]

minhheo

kernel_starter

History for agentReplay.ts