[{"_1":2,"_182":-5,"_183":-5},"loaderData",{"_3":4,"_95":96},"root",{"_5":6,"_36":37,"_68":69},"ctx",{"_7":8,"_23":-5,"_24":25,"_26":27,"_28":20,"_29":20,"_30":20,"_31":-5,"_32":33,"_34":20,"_35":20},"auth",{"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20,"_21":22},"sessionClaims","sessionId","sessionStatus","userId","actor","orgId","orgRole","orgSlug","orgPermissions","factorVerificationAge","isAuthenticated",false,"tokenType","session_token","user","preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesChatPanelState","notificationCount",0,"flagDenols","isBusinessOrgMember","ENV",{"_38":39,"_40":41,"_42":43,"_44":45,"_46":47,"_48":49,"_50":51,"_52":53,"_54":55,"_56":57,"_58":59,"_60":61,"_62":63,"_64":65,"_66":67},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","VAL_RUNTIME_NAME","prod","RENDER_GIT_COMMIT","0cc4e234bbf6f8e65a0eea123bbd1ea70d97ca74","RENDER_GIT_BRANCH","main","CLERK_PUBLISHABLE_KEY","pk_live_Y2xlcmsudmFsLnRvd24k","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","API_URL","https://api.val.town","clerkState",{"_70":71},"__internal_clerk_state",{"_72":73,"_74":47,"_75":76,"_77":76,"_78":20,"_79":76,"_80":76,"_81":76,"_82":76,"_83":84,"_93":20,"_94":20},"__clerk_ssr_state",{"_21":22,"_9":-5,"_10":-5,"_11":-5,"_12":-5,"_13":-5,"_14":-5,"_15":-5,"_16":-5,"_17":-5,"_18":-5,"_19":20},"__publishableKey","__proxyUrl","","__domain","__isSatellite","__signInUrl","__signUpUrl","__afterSignInUrl","__afterSignUpUrl","__clerk_debug",{"_85":20,"_19":20,"_86":76,"_87":88,"_89":76,"_90":47,"_91":20,"_92":76},"isSignedIn","proxyUrl","reason","session-token-and-uat-missing","message","publishableKey","isSatellite","domain","__telemetryDisabled","__telemetryDebug","routes/embed.x.$handle.$name.$",{"_97":98,"_99":100,"_101":102,"_103":104,"_157":158,"_179":180,"_181":-5},"handle","minhnguyen00","name","bb_agent","path","storage/db.ts","project",{"_105":106,"_99":100,"_107":108,"_109":-5,"_110":20,"_111":112,"_113":76,"_114":76,"_12":115,"_116":-5,"_117":20,"_118":-5,"_119":-5,"_120":33,"_14":121,"_122":123,"_124":125,"_126":-5,"_127":128,"_129":128,"_130":131,"_132":131,"_133":131,"_134":128,"_135":128,"_23":136,"_138":139,"_143":144,"_156":20},"id","083c206c-2b7f-11f1-8d7a-42dde27851f2","createdAt",["D",1774796002418],"deletedAt","legacyEnvVars","privacy","public","description","imageUrl","019d37cd-8417-71f5-bf2f-af87e0391787","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","019d37ce-8610-7097-8dec-2ecab63c9d61","tursoName","083c206c2b7f11f18d7a42dde27851f2","tursoHostname","083c206c2b7f11f18d7a42dde27851f2-val-town.aws-us-east-2.turso.io","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_97":98,"_137":76},"profileImageUrl","org",{"_97":98,"_140":76,"_12":-5,"_141":142},"avatar","tier","free","branch",{"_145":146,"_99":45,"_105":147,"_148":106,"_149":-5,"_150":-5,"_151":-5,"_152":-5,"_153":-5,"_154":100,"_155":98},"version",24,"083dcce6-2b7f-11f1-8d7a-42dde27851f2","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","isOwned","file",{"_105":159,"_99":160,"_161":162,"_163":164,"_165":147,"_166":167,"_168":169,"_107":170,"_145":33,"_171":172,"_173":174,"_175":20,"_176":-5,"_101":177},"2326da14-2b81-11f1-b45d-42dde27851f2","db.ts","fileId","2326dba4-2b81-11f1-b45d-42dde27851f2","parentId","0e92d60c-2b81-11f1-b025-42dde27851f2","branchId","branchVersion",5,"latest",true,["D",1774796906527],"fileType","script","content","/**\n * storage/db.ts\n * SQLite schema & queries cho toàn bộ hệ thống bb_agent\n * Dùng project-scoped SQLite (std/sqlite/main.ts)\n */\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n// ─── KHỞI TẠO BẢNG ────────────────────────────────────────────────────────────\n\nexport async function initDB(): Promise {\n await sqlite.batch([\n // Lưu danh sách tài khoản đã tạo / đang nuôi\n {\n sql: `CREATE TABLE IF NOT EXISTS accounts (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n platform TEXT NOT NULL, -- tên nền tảng: \"shopee\", \"tiki\", ...\n username TEXT,\n email TEXT,\n password TEXT,\n phone TEXT,\n cookies TEXT, -- JSON string cookies sau khi login\n status TEXT DEFAULT 'pending', -- pending | active | banned | error\n profile TEXT, -- JSON string thông tin bổ sung\n created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now'))\n )`,\n },\n // Lịch sử từng task automation chạy\n {\n sql: `CREATE TABLE IF NOT EXISTS task_logs (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n task_type TEXT NOT NULL, -- register | warmup | listing | custom\n account_id INTEGER,\n platform TEXT,\n status TEXT DEFAULT 'running', -- running | success | failed\n result TEXT, -- JSON kết quả hoặc lỗi\n bb_session TEXT, -- Browserbase session ID để debug/replay\n started_at TEXT DEFAULT (datetime('now')),\n finished_at TEXT\n )`,\n },\n // CSV data được import vào (thay thế filesystem)\n {\n sql: `CREATE TABLE IF NOT EXISTS csv_data (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL UNIQUE, -- tên \"file\" CSV\n headers TEXT NOT NULL, -- JSON array tên cột\n rows TEXT NOT NULL, -- JSON array of arrays\n row_count INTEGER DEFAULT 0,\n created_at TEXT DEFAULT (datetime('now')),\n updated_at TEXT DEFAULT (datetime('now'))\n )`,\n },\n // Hàng đợi tác vụ (job queue đơn giản)\n {\n sql: `CREATE TABLE IF NOT EXISTS task_queue (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n task_type TEXT NOT NULL,\n payload TEXT NOT NULL, -- JSON payload\n status TEXT DEFAULT 'queued', -- queued | running | done | failed\n priority INTEGER DEFAULT 0,\n created_at TEXT DEFAULT (datetime('now')),\n run_at TEXT DEFAULT (datetime('now'))\n )`,\n },\n ]);\n}\n\n// ─── ACCOUNTS ─────────────────────────────────────────────────────────────────\n\nexport interface Account {\n id?: number;\n platform: string;\n username?: string;\n email?: string;\n password?: string;\n phone?: string;\n cookies?: string;\n status?: string;\n profile?: string;\n}\n\nexport async function insertAccount(acc: Account): Promise {\n const result = await sqlite.execute({\n sql: `INSERT INTO accounts (platform, username, email, password, phone, cookies, status, profile)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n acc.platform,\n acc.username ?? null,\n acc.email ?? null,\n acc.password ?? null,\n acc.phone ?? null,\n acc.cookies ?? null,\n acc.status ?? \"pending\",\n acc.profile ? JSON.stringify(acc.profile) : null,\n ],\n });\n return Number(result.lastInsertRowid);\n}\n\nexport async function updateAccountStatus(\n id: number,\n status: string,\n extra?: Partial,\n): Promise {\n await sqlite.execute({\n sql: `UPDATE accounts SET status = ?, cookies = COALESCE(?, cookies),\n phone = COALESCE(?, phone), updated_at = datetime('now')\n WHERE id = ?`,\n args: [status, extra?.cookies ?? null, extra?.phone ?? null, id],\n });\n}\n\nexport async function getAccounts(platform?: string, status?: string): Promise {\n let sql = \"SELECT * FROM accounts WHERE 1=1\";\n const args: string[] = [];\n if (platform) { sql += \" AND platform = ?\"; args.push(platform); }\n if (status) { sql += \" AND status = ?\"; args.push(status); }\n sql += \" ORDER BY created_at DESC\";\n const res = await sqlite.execute({ sql, args });\n return res.rows as unknown as Account[];\n}\n\n// ─── TASK LOGS ────────────────────────────────────────────────────────────────\n\nexport async function logTaskStart(\n taskType: string,\n accountId?: number,\n platform?: string,\n bbSession?: string,\n): Promise {\n const res = await sqlite.execute({\n sql: `INSERT INTO task_logs (task_type, account_id, platform, status, bb_session)\n VALUES (?, ?, ?, 'running', ?)`,\n args: [taskType, accountId ?? null, platform ?? null, bbSession ?? null],\n });\n return Number(res.lastInsertRowid);\n}\n\nexport async function logTaskFinish(\n logId: number,\n status: \"success\" | \"failed\",\n result: unknown,\n): Promise {\n await sqlite.execute({\n sql: `UPDATE task_logs SET status = ?, result = ?, finished_at = datetime('now')\n WHERE id = ?`,\n args: [status, JSON.stringify(result), logId],\n });\n}\n\nexport async function getRecentLogs(limit = 20): Promise {\n const res = await sqlite.execute({\n sql: `SELECT * FROM task_logs ORDER BY started_at DESC LIMIT ?`,\n args: [limit],\n });\n return res.rows;\n}\n\n// ─── CSV STORAGE ──────────────────────────────────────────────────────────────\n\nexport interface CsvFile {\n name: string;\n headers: string[];\n rows: string[][];\n}\n\nexport async function saveCsv(file: CsvFile): Promise {\n await sqlite.execute({\n sql: `INSERT INTO csv_data (name, headers, rows, row_count)\n VALUES (?, ?, ?, ?)\n ON CONFLICT(name) DO UPDATE SET\n headers = excluded.headers,\n rows = excluded.rows,\n row_count = excluded.row_count,\n updated_at = datetime('now')`,\n args: [\n file.name,\n JSON.stringify(file.headers),\n JSON.stringify(file.rows),\n file.rows.length,\n ],\n });\n}\n\nexport async function loadCsv(name: string): Promise {\n const res = await sqlite.execute({\n sql: \"SELECT * FROM csv_data WHERE name = ?\",\n args: [name],\n });\n if (res.rows.length === 0) return null;\n const row = res.rows[0] as Record;\n return {\n name: row.name as string,\n headers: JSON.parse(row.headers as string),\n rows: JSON.parse(row.rows as string),\n };\n}\n\nexport async function listCsvFiles(): Promise<{ name: string; rowCount: number; updatedAt: string }[]> {\n const res = await sqlite.execute(\n \"SELECT name, row_count, updated_at FROM csv_data ORDER BY updated_at DESC\",\n );\n return res.rows as unknown as { name: string; rowCount: number; updatedAt: string }[];\n}\n\n// ─── TASK QUEUE ───────────────────────────────────────────────────────────────\n\nexport async function enqueueTask(\n taskType: string,\n payload: unknown,\n priority = 0,\n): Promise {\n const res = await sqlite.execute({\n sql: `INSERT INTO task_queue (task_type, payload, priority) VALUES (?, ?, ?)`,\n args: [taskType, JSON.stringify(payload), priority],\n });\n return Number(res.lastInsertRowid);\n}\n\nexport async function dequeueTask(): Promise<{ id: number; taskType: string; payload: unknown } | null> {\n const res = await sqlite.execute(\n `SELECT * FROM task_queue WHERE status = 'queued' AND run_at <= datetime('now')\n ORDER BY priority DESC, id ASC LIMIT 1`,\n );\n if (res.rows.length === 0) return null;\n const row = res.rows[0] as Record;\n await sqlite.execute({\n sql: \"UPDATE task_queue SET status = 'running' WHERE id = ?\",\n args: [row.id as number],\n });\n return {\n id: row.id as number,\n taskType: row.task_type as string,\n payload: JSON.parse(row.payload as string),\n };\n}\n\nexport async function finishQueuedTask(id: number, status: \"done\" | \"failed\"): Promise {\n await sqlite.execute({\n sql: \"UPDATE task_queue SET status = ? WHERE id = ?\",\n args: [status, id],\n });\n}\n","deleted","label",[178,160],"storage","permalink","https://www.val.town/x/minhnguyen00/bb_agent/code/storage/db.ts","extension","actionData","errors"]