[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_441":442,"_443":444},"routes/_app.x.$handle.$name",{"_111":110,"_38":52,"_120":97,"_33":121,"_13":14,"_122":-5,"_11":123,"_124":125,"_126":127,"_128":129,"_130":131,"_26":-5,"_132":133,"_134":135,"_136":31,"_137":138,"_139":66,"_140":-5,"_141":-5,"_142":143},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_50":51,"_38":52,"_45":53,"_54":-5,"_55":31,"_56":57,"_58":57,"_59":60,"_61":-5,"_19":62,"_63":64,"_65":66,"_67":-5,"_68":-5,"_69":70,"_71":72,"_73":74,"_75":76,"_77":78,"_79":-5,"_80":81,"_82":81,"_83":84,"_85":84,"_86":84,"_87":81,"_88":81,"_89":90,"_91":92,"_93":94,"_95":31},"version",29,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","159dda93-caf4-4132-86d3-8e34826bb686","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":29,"_30":31,"_32":31,"_33":34,"_35":34},"file",{"_36":37,"_38":39,"_40":41,"_42":44,"_45":46,"_47":14,"_48":49,"_30":31},"previous",{"_36":37,"_38":39,"_40":41,"_42":43},"deleted",false,"deletedHere","path","src/lib/db.ts","latestPath","fileId","019f68b9-9fa0-755f-881f-70ec1b1a27ed","name","db.ts","fileType","script","content","// Data layer: SQLite schema + typed helpers for the gold bot.\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport type { AnalysisResult, CustomStrategy } from \"./types.ts\";\n\nconst PREFIX = \"gold_bot\";\nexport const T = {\n strategies: `${PREFIX}_strategies`,\n signals: `${PREFIX}_signals`,\n snapshots: `${PREFIX}_price_snapshots`,\n telegram: `${PREFIX}_telegram_config`,\n settings: `${PREFIX}_bot_settings`,\n execution: `${PREFIX}_execution_queue`,\n pocketOption: `${PREFIX}_pocket_option_config`,\n};\n\nlet initialized = false;\nexport async function initDb() {\n if (initialized) return;\n await sqlite.batch([\n {\n sql: `CREATE TABLE IF NOT EXISTS ${T.strategies} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL,\n description TEXT DEFAULT '',\n side TEXT NOT NULL,\n weight REAL NOT NULL DEFAULT 1,\n active INTEGER NOT NULL DEFAULT 1,\n indicator TEXT NOT NULL,\n operator TEXT NOT NULL,\n value REAL NOT NULL,\n created_at INTEGER NOT NULL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS ${T.signals} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n direction TEXT NOT NULL,\n confidence INTEGER NOT NULL,\n entry REAL NOT NULL,\n stop_loss REAL NOT NULL,\n tp1 REAL NOT NULL, tp2 REAL NOT NULL, tp3 REAL NOT NULL,\n atr REAL NOT NULL,\n bullish_score REAL NOT NULL,\n bearish_score REAL NOT NULL,\n session TEXT NOT NULL,\n reasoning TEXT NOT NULL,\n factors TEXT NOT NULL,\n status TEXT NOT NULL DEFAULT 'open',\n telegram_sent INTEGER NOT NULL DEFAULT 0,\n created_at INTEGER NOT NULL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS ${T.snapshots} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n price REAL NOT NULL,\n created_at INTEGER NOT NULL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS ${T.telegram} (\n id INTEGER PRIMARY KEY CHECK (id = 1),\n bot_token TEXT DEFAULT '',\n chat_id TEXT DEFAULT '',\n notify_buy INTEGER NOT NULL DEFAULT 1,\n notify_sell INTEGER NOT NULL DEFAULT 1,\n notify_neutral INTEGER NOT NULL DEFAULT 0,\n min_confidence INTEGER NOT NULL DEFAULT 60\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS ${T.settings} (\n id INTEGER PRIMARY KEY CHECK (id = 1),\n api_key TEXT DEFAULT '',\n risk_per_trade REAL NOT NULL DEFAULT 1,\n rr1 REAL NOT NULL DEFAULT 1.5,\n rr2 REAL NOT NULL DEFAULT 2.5,\n rr3 REAL NOT NULL DEFAULT 4.0,\n scan_interval_min INTEGER NOT NULL DEFAULT 15,\n bot_running INTEGER NOT NULL DEFAULT 0\n )`,\n },\n { sql: `INSERT OR IGNORE INTO ${T.telegram} (id) VALUES (1)` },\n { sql: `INSERT OR IGNORE INTO ${T.settings} (id) VALUES (1)` },\n {\n sql: `CREATE TABLE IF NOT EXISTS ${T.pocketOption} (\n id INTEGER PRIMARY KEY CHECK (id = 1),\n enabled INTEGER NOT NULL DEFAULT 0,\n is_demo INTEGER NOT NULL DEFAULT 1,\n asset TEXT NOT NULL DEFAULT 'XAUUSD_otc',\n trade_amount REAL NOT NULL DEFAULT 10,\n expiry_seconds INTEGER NOT NULL DEFAULT 60,\n min_confidence INTEGER NOT NULL DEFAULT 65,\n po_session TEXT DEFAULT '',\n po_uid TEXT DEFAULT '',\n po_email TEXT DEFAULT '',\n po_password TEXT DEFAULT '',\n created_at INTEGER NOT NULL\n )`,\n },\n { sql: `INSERT OR IGNORE INTO ${T.pocketOption} (id) VALUES (1)` },\n {\n sql: `CREATE TABLE IF NOT EXISTS ${T.execution} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n signal_id INTEGER NOT NULL,\n direction TEXT NOT NULL,\n asset TEXT NOT NULL,\n amount REAL NOT NULL,\n expiry_seconds INTEGER NOT NULL,\n confidence INTEGER NOT NULL,\n entry_price REAL,\n status TEXT NOT NULL DEFAULT 'pending',\n deal_id TEXT,\n result TEXT,\n payout REAL,\n profit_loss REAL,\n worker_id TEXT,\n created_at INTEGER NOT NULL,\n claimed_at INTEGER,\n executed_at INTEGER,\n completed_at INTEGER\n )`,\n },\n ]);\n initialized = true;\n}\n\n// ---------- Settings ----------\nexport interface BotSettings {\n apiKey: string;\n hasApiKey: boolean;\n riskPerTrade: number;\n riskReward: [number, number, number];\n scanIntervalMin: number;\n botRunning: boolean;\n}\n\nexport async function getSettings(): Promise {\n await initDb();\n const r = await sqlite.execute(`SELECT * FROM ${T.settings} WHERE id = 1`);\n const row = r.rows[0] as Record;\n return {\n apiKey: String(row.api_key ?? \"\"),\n hasApiKey: !!row.api_key,\n riskPerTrade: Number(row.risk_per_trade),\n riskReward: [Number(row.rr1), Number(row.rr2), Number(row.rr3)],\n scanIntervalMin: Number(row.scan_interval_min),\n botRunning: !!row.bot_running,\n };\n}\n\nexport async function updateSettings(p: Partial<{\n apiKey: string;\n riskPerTrade: number;\n riskReward: [number, number, number];\n scanIntervalMin: number;\n botRunning: boolean;\n}>) {\n await initDb();\n const sets: string[] = [];\n const args: any[] = [];\n if (p.apiKey !== undefined && p.apiKey !== \"\") { sets.push(\"api_key = ?\"); args.push(p.apiKey); }\n if (p.riskPerTrade !== undefined) { sets.push(\"risk_per_trade = ?\"); args.push(p.riskPerTrade); }\n if (p.riskReward) { sets.push(\"rr1 = ?\", \"rr2 = ?\", \"rr3 = ?\"); args.push(...p.riskReward); }\n if (p.scanIntervalMin !== undefined) { sets.push(\"scan_interval_min = ?\"); args.push(p.scanIntervalMin); }\n if (p.botRunning !== undefined) { sets.push(\"bot_running = ?\"); args.push(p.botRunning ? 1 : 0); }\n if (!sets.length) return;\n await sqlite.execute({ sql: `UPDATE ${T.settings} SET ${sets.join(\", \")} WHERE id = 1`, args });\n}\n\n// ---------- Telegram config ----------\nexport interface TelegramConfig {\n botToken: string;\n hasToken: boolean;\n chatId: string;\n notifyBuy: boolean;\n notifySell: boolean;\n notifyNeutral: boolean;\n minConfidence: number;\n}\n\nexport async function getTelegram(): Promise {\n await initDb();\n const r = await sqlite.execute(`SELECT * FROM ${T.telegram} WHERE id = 1`);\n const row = r.rows[0] as Record;\n return {\n botToken: String(row.bot_token ?? \"\"),\n hasToken: !!row.bot_token,\n chatId: String(row.chat_id ?? \"\"),\n notifyBuy: !!row.notify_buy,\n notifySell: !!row.notify_sell,\n notifyNeutral: !!row.notify_neutral,\n minConfidence: Number(row.min_confidence),\n };\n}\n\nexport async function updateTelegram(p: Partial<{\n botToken: string; chatId: string;\n notifyBuy: boolean; notifySell: boolean; notifyNeutral: boolean; minConfidence: number;\n}>) {\n await initDb();\n const sets: string[] = [];\n const args: any[] = [];\n if (p.botToken !== undefined && p.botToken !== \"\") { sets.push(\"bot_token = ?\"); args.push(p.botToken); }\n if (p.chatId !== undefined) { sets.push(\"chat_id = ?\"); args.push(p.chatId); }\n if (p.notifyBuy !== undefined) { sets.push(\"notify_buy = ?\"); args.push(p.notifyBuy ? 1 : 0); }\n if (p.notifySell !== undefined) { sets.push(\"notify_sell = ?\"); args.push(p.notifySell ? 1 : 0); }\n if (p.notifyNeutral !== undefined) { sets.push(\"notify_neutral = ?\"); args.push(p.notifyNeutral ? 1 : 0); }\n if (p.minConfidence !== undefined) { sets.push(\"min_confidence = ?\"); args.push(p.minConfidence); }\n if (!sets.length) return;\n await sqlite.execute({ sql: `UPDATE ${T.telegram} SET ${sets.join(\", \")} WHERE id = 1`, args });\n}\n\n// ---------- Strategies ----------\nexport async function listStrategies(): Promise {\n await initDb();\n const r = await sqlite.execute(`SELECT * FROM ${T.strategies} ORDER BY id DESC`);\n return r.rows.map((row: any) => ({\n id: Number(row.id),\n name: String(row.name),\n description: String(row.description ?? \"\"),\n side: row.side,\n weight: Number(row.weight),\n active: !!row.active,\n condition: { indicator: row.indicator, operator: row.operator, value: Number(row.value) },\n }));\n}\n\nexport async function createStrategy(s: Omit): Promise {\n await initDb();\n const r = await sqlite.execute({\n sql: `INSERT INTO ${T.strategies} (name, description, side, weight, active, indicator, operator, value, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [s.name, s.description, s.side, s.weight, s.active ? 1 : 0,\n s.condition.indicator, s.condition.operator, s.condition.value, Date.now()],\n });\n return Number(r.lastInsertRowid);\n}\n\nexport async function updateStrategy(id: number, s: Partial>) {\n await initDb();\n const sets: string[] = [];\n const args: any[] = [];\n if (s.name !== undefined) { sets.push(\"name = ?\"); args.push(s.name); }\n if (s.description !== undefined) { sets.push(\"description = ?\"); args.push(s.description); }\n if (s.side !== undefined) { sets.push(\"side = ?\"); args.push(s.side); }\n if (s.weight !== undefined) { sets.push(\"weight = ?\"); args.push(s.weight); }\n if (s.active !== undefined) { sets.push(\"active = ?\"); args.push(s.active ? 1 : 0); }\n if (s.condition) {\n sets.push(\"indicator = ?\", \"operator = ?\", \"value = ?\");\n args.push(s.condition.indicator, s.condition.operator, s.condition.value);\n }\n if (!sets.length) return;\n args.push(id);\n await sqlite.execute({ sql: `UPDATE ${T.strategies} SET ${sets.join(\", \")} WHERE id = ?`, args });\n}\n\nexport async function deleteStrategy(id: number) {\n await initDb();\n await sqlite.execute({ sql: `DELETE FROM ${T.strategies} WHERE id = ?`, args: [id] });\n}\n\n// ---------- Signals ----------\nexport interface SignalRow extends AnalysisResult {\n id: number;\n status: \"open\" | \"tp_hit\" | \"sl_hit\" | \"cancelled\";\n telegramSent: boolean;\n createdAt: number;\n}\n\nexport async function saveSignal(a: AnalysisResult, telegramSent: boolean): Promise {\n await initDb();\n const r = await sqlite.execute({\n sql: `INSERT INTO ${T.signals}\n (direction, confidence, entry, stop_loss, tp1, tp2, tp3, atr, bullish_score, bearish_score, session, reasoning, factors, status, telegram_sent, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, 'open', ?, ?)`,\n args: [a.direction, a.confidence, a.entry, a.stopLoss, a.takeProfits[0], a.takeProfits[1], a.takeProfits[2],\n a.atr, a.bullishScore, a.bearishScore, a.session, JSON.stringify(a.reasoning), JSON.stringify(a.factors),\n telegramSent ? 1 : 0, Date.now()],\n });\n return Number(r.lastInsertRowid);\n}\n\nexport async function listSignals(limit = 50): Promise {\n await initDb();\n const r = await sqlite.execute({ sql: `SELECT * FROM ${T.signals} ORDER BY id DESC LIMIT ?`, args: [limit] });\n return r.rows.map(rowToSignal);\n}\n\nexport async function updateSignalStatus(id: number, status: SignalRow[\"status\"]) {\n await initDb();\n await sqlite.execute({ sql: `UPDATE ${T.signals} SET status = ? WHERE id = ?`, args: [status, id] });\n}\n\nfunction rowToSignal(row: any): SignalRow {\n return {\n id: Number(row.id),\n direction: row.direction,\n confidence: Number(row.confidence),\n entry: Number(row.entry),\n stopLoss: Number(row.stop_loss),\n takeProfits: [Number(row.tp1), Number(row.tp2), Number(row.tp3)],\n riskRewardRatios: [1.5, 2.5, 4.0],\n atr: Number(row.atr),\n bullishScore: Number(row.bullish_score),\n bearishScore: Number(row.bearish_score),\n session: row.session,\n reasoning: JSON.parse(row.reasoning || \"[]\"),\n factors: JSON.parse(row.factors || \"[]\"),\n timestamp: Math.floor(Number(row.created_at) / 1000),\n status: row.status,\n telegramSent: !!row.telegram_sent,\n createdAt: Number(row.created_at),\n } as SignalRow;\n}\n\n// ---------- Price snapshots ----------\nexport async function saveSnapshot(price: number) {\n await initDb();\n await sqlite.execute({ sql: `INSERT INTO ${T.snapshots} (price, created_at) VALUES (?, ?)`, args: [price, Date.now()] });\n}\n\n// ---------- Pocket Option config ----------\nexport interface PocketOptionConfig {\n enabled: boolean;\n isDemo: boolean;\n asset: string;\n tradeAmount: number;\n expirySeconds: number;\n minConfidence: number;\n}\n\nexport async function getPocketOption(): Promise {\n await initDb();\n try { await sqlite.execute(`INSERT OR IGNORE INTO ${T.pocketOption} (id) VALUES (1)`); } catch {}\n const r = await sqlite.execute(`SELECT * FROM ${T.pocketOption} WHERE id = 1`);\n const row = (r.rows[0] ?? {}) as Record;\n return {\n enabled: !!row.enabled,\n isDemo: row.is_demo === undefined ? true : !!row.is_demo,\n asset: String(row.asset ?? \"XAUUSD_otc\"),\n tradeAmount: Number(row.trade_amount ?? 10),\n expirySeconds: Number(row.expiry_seconds ?? 60),\n minConfidence: Number(row.min_confidence ?? 65),\n };\n}\n\nexport async function updatePocketOption(p: Partial) {\n await initDb();\n const sets: string[] = [];\n const args: any[] = [];\n if (p.enabled !== undefined) { sets.push(\"enabled = ?\"); args.push(p.enabled ? 1 : 0); }\n if (p.isDemo !== undefined) { sets.push(\"is_demo = ?\"); args.push(p.isDemo ? 1 : 0); }\n if (p.asset !== undefined) { sets.push(\"asset = ?\"); args.push(p.asset); }\n if (p.tradeAmount !== undefined) { sets.push(\"trade_amount = ?\"); args.push(p.tradeAmount); }\n if (p.expirySeconds !== undefined) { sets.push(\"expiry_seconds = ?\"); args.push(p.expirySeconds); }\n if (p.minConfidence !== undefined) { sets.push(\"min_confidence = ?\"); args.push(p.minConfidence); }\n if (!sets.length) return;\n await sqlite.execute({ sql: `UPDATE ${T.pocketOption} SET ${sets.join(\", \")} WHERE id = 1`, args });\n}\n\n// ---------- Execution queue ----------\nexport interface ExecutionRow {\n id: number;\n signalId: number;\n direction: string;\n asset: string;\n amount: number;\n expirySeconds: number;\n confidence: number;\n entryPrice: number | null;\n status: \"pending\" | \"claimed\" | \"executing\" | \"win\" | \"loss\" | \"draw\" | \"error\" | \"skipped\";\n dealId: string | null;\n result: string | null;\n payout: number | null;\n profitLoss: number | null;\n workerId: string | null;\n createdAt: number;\n claimedAt: number | null;\n executedAt: number | null;\n completedAt: number | null;\n}\n\nexport async function enqueueExecution(\n signalId: number,\n direction: string,\n config: PocketOptionConfig,\n entryPrice: number,\n): Promise {\n await initDb();\n const r = await sqlite.execute({\n sql: `INSERT INTO ${T.execution}\n (signal_id, direction, asset, amount, expiry_seconds, confidence, entry_price, status, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, 'pending', ?)`,\n args: [signalId, direction, config.asset, config.tradeAmount, config.expirySeconds,\n config.minConfidence, entryPrice, Date.now()],\n });\n return Number(r.lastInsertRowid);\n}\n\nexport async function getPendingExecutions(limit = 10): Promise {\n await initDb();\n const r = await sqlite.execute({\n sql: `SELECT * FROM ${T.execution} WHERE status = 'pending' ORDER BY id ASC LIMIT ?`,\n args: [limit],\n });\n return r.rows.map(rowToExecution);\n}\n\nexport async function claimExecutions(ids: number[], workerId: string): Promise {\n await initDb();\n if (!ids.length) return [];\n const placeholders = ids.map(() => \"?\").join(\",\");\n await sqlite.execute({\n sql: `UPDATE ${T.execution} SET status = 'claimed', claimed_at = ?, worker_id = ? WHERE id IN (${placeholders}) AND status = 'pending'`,\n args: [Date.now(), workerId, ...ids],\n });\n const r = await sqlite.execute({\n sql: `SELECT * FROM ${T.execution} WHERE id IN (${placeholders}) AND worker_id = ? AND status = 'claimed'`,\n args: [...ids, workerId],\n });\n return r.rows.map(rowToExecution);\n}\n\nexport async function updateExecutionResult(\n id: number,\n result: Partial>,\n) {\n await initDb();\n const sets: string[] = [];\n const args: any[] = [];\n if (result.status) { sets.push(\"status = ?\"); args.push(result.status); }\n if (result.dealId !== undefined) { sets.push(\"deal_id = ?\"); args.push(result.dealId); }\n if (result.result !== undefined) { sets.push(\"result = ?\"); args.push(result.result); }\n if (result.payout !== undefined) { sets.push(\"payout = ?\"); args.push(result.payout); }\n if (result.profitLoss !== undefined) { sets.push(\"profit_loss = ?\"); args.push(result.profitLoss); }\n if (result.entryPrice !== undefined) { sets.push(\"entry_price = ?\"); args.push(result.entryPrice); }\n if (result.status === \"win\" || result.status === \"loss\" || result.status === \"draw\" || result.status === \"error\") {\n sets.push(\"completed_at = ?\"); args.push(Date.now());\n } else if (result.status === \"executing\") {\n sets.push(\"executed_at = ?\"); args.push(Date.now());\n }\n if (!sets.length) return;\n args.push(id);\n await sqlite.execute({ sql: `UPDATE ${T.execution} SET ${sets.join(\", \")} WHERE id = ?`, args });\n}\n\nexport async function listExecutions(limit = 50): Promise {\n await initDb();\n const r = await sqlite.execute({\n sql: `SELECT * FROM ${T.execution} ORDER BY id DESC LIMIT ?`,\n args: [limit],\n });\n return r.rows.map(rowToExecution);\n}\n\nexport async function getExecutionStats(): Promise<{ total: number; wins: number; losses: number; draws: number; errors: number; pending: number; profitLoss: number }> {\n await initDb();\n const r = await sqlite.execute({\n sql: `SELECT\n COUNT(*) as total,\n SUM(CASE WHEN status = 'win' THEN 1 ELSE 0 END) as wins,\n SUM(CASE WHEN status = 'loss' THEN 1 ELSE 0 END) as losses,\n SUM(CASE WHEN status = 'draw' THEN 1 ELSE 0 END) as draws,\n SUM(CASE WHEN status = 'error' THEN 1 ELSE 0 END) as errors,\n SUM(CASE WHEN status IN ('pending','claimed','executing') THEN 1 ELSE 0 END) as pending,\n SUM(COALESCE(profit_loss, 0)) as profit_loss\n FROM ${T.execution}`,\n });\n const row = r.rows[0] as Record;\n return {\n total: Number(row.total ?? 0),\n wins: Number(row.wins ?? 0),\n losses: Number(row.losses ?? 0),\n draws: Number(row.draws ?? 0),\n errors: Number(row.errors ?? 0),\n pending: Number(row.pending ?? 0),\n profitLoss: Number(row.profit_loss ?? 0),\n };\n}\n\nfunction rowToExecution(row: any): ExecutionRow {\n return {\n id: Number(row.id),\n signalId: Number(row.signal_id),\n direction: String(row.direction),\n asset: String(row.asset),\n amount: Number(row.amount),\n expirySeconds: Number(row.expiry_seconds),\n confidence: Number(row.confidence),\n entryPrice: row.entry_price !== null ? Number(row.entry_price) : null,\n status: String(row.status) as ExecutionRow[\"status\"],\n dealId: row.deal_id !== null ? String(row.deal_id) : null,\n result: row.result !== null ? String(row.result) : null,\n payout: row.payout !== null ? Number(row.payout) : null,\n profitLoss: row.profit_loss !== null ? Number(row.profit_loss) : null,\n workerId: row.worker_id !== null ? String(row.worker_id) : null,\n createdAt: Number(row.created_at),\n claimedAt: row.claimed_at !== null ? Number(row.claimed_at) : null,\n executedAt: row.executed_at !== null ? Number(row.executed_at) : null,\n completedAt: row.completed_at !== null ? Number(row.completed_at) : null,\n };\n}\n\n// ---------- Pocket Option credentials (server-side only, never returned to browser) ----------\nexport interface PocketOptionCredentials {\n hasSession: boolean;\n hasUid: boolean;\n hasEmail: boolean;\n hasPassword: boolean;\n}\n\nexport async function getPOCredentialsSafe(): Promise {\n await initDb();\n try { await sqlite.execute(`INSERT OR IGNORE INTO ${T.pocketOption} (id) VALUES (1)`); } catch {}\n const r = await sqlite.execute(`SELECT po_session, po_uid, po_email, po_password FROM ${T.pocketOption} WHERE id = 1`);\n const row = (r.rows[0] ?? {}) as Record;\n return {\n hasSession: !!(row.po_session && String(row.po_session).trim()),\n hasUid: !!(row.po_uid && String(row.po_uid).trim()),\n hasEmail: !!(row.po_email && String(row.po_email).trim()),\n hasPassword: !!(row.po_password && String(row.po_password).trim()),\n };\n}\n\nexport interface PocketOptionFullCredentials {\n session: string;\n uid: string;\n email: string;\n password: string;\n}\n\nexport async function getPOCredentials(): Promise {\n await initDb();\n const r = await sqlite.execute(`SELECT po_session, po_uid, po_email, po_password FROM ${T.pocketOption} WHERE id = 1`);\n const row = (r.rows[0] ?? {}) as Record;\n return {\n session: String(row.po_session ?? \"\"),\n uid: String(row.po_uid ?? \"\"),\n email: String(row.po_email ?? \"\"),\n password: String(row.po_password ?? \"\"),\n };\n}\n\nexport async function updatePOCredentials(p: Partial) {\n await initDb();\n const sets: string[] = [];\n const args: any[] = [];\n if (p.session !== undefined && p.session !== \"\") { sets.push(\"po_session = ?\"); args.push(p.session); }\n if (p.uid !== undefined && p.uid !== \"\") { sets.push(\"po_uid = ?\"); args.push(p.uid); }\n if (p.email !== undefined && p.email !== \"\") { sets.push(\"po_email = ?\"); args.push(p.email); }\n if (p.password !== undefined && p.password !== \"\") { sets.push(\"po_password = ?\"); args.push(p.password); }\n if (!sets.length) return;\n await sqlite.execute({ sql: `UPDATE ${T.pocketOption} SET ${sets.join(\", \")} WHERE id = 1`, args });\n}\n\n// Worker config — returns everything the worker needs in one call\nexport interface WorkerConfig {\n enabled: boolean;\n isDemo: boolean;\n asset: string;\n tradeAmount: number;\n expirySeconds: number;\n minConfidence: number;\n session: string;\n uid: string;\n email: string;\n password: string;\n}\n\nexport async function getWorkerConfig(): Promise {\n await initDb();\n try { await sqlite.execute(`INSERT OR IGNORE INTO ${T.pocketOption} (id) VALUES (1)`); } catch {}\n const r = await sqlite.execute(`SELECT * FROM ${T.pocketOption} WHERE id = 1`);\n const row = (r.rows[0] ?? {}) as Record;\n return {\n enabled: !!row.enabled,\n isDemo: row.is_demo === undefined ? true : !!row.is_demo,\n asset: String(row.asset ?? \"XAUUSD_otc\"),\n tradeAmount: Number(row.trade_amount ?? 10),\n expirySeconds: Number(row.expiry_seconds ?? 60),\n minConfidence: Number(row.min_confidence ?? 65),\n session: String(row.po_session ?? \"\"),\n uid: String(row.po_uid ?? \"\"),\n email: String(row.po_email ?? \"\"),\n password: String(row.po_password ?? \"\"),\n };\n}\n","// Data layer: SQLite schema + typed helpers for the gold bot.\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport type { AnalysisResult, CustomStrategy } from \"./types.ts\";\n\nconst PREFIX = \"gold_bot\";\nexport const T = {\n strategies: `${PREFIX}_strategies`,\n signals: `${PREFIX}_signals`,\n snapshots: `${PREFIX}_price_snapshots`,\n telegram: `${PREFIX}_telegram_config`,\n settings: `${PREFIX}_bot_settings`,\n execution: `${PREFIX}_execution_queue`,\n pocketOption: `${PREFIX}_pocket_option_config`,\n};\n\nlet initialized = false;\nexport async function initDb() {\n if (initialized) return;\n await sqlite.batch([\n {\n sql: `CREATE TABLE IF NOT EXISTS ${T.strategies} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n name TEXT NOT NULL,\n description TEXT DEFAULT '',\n side TEXT NOT NULL,\n weight REAL NOT NULL DEFAULT 1,\n active INTEGER NOT NULL DEFAULT 1,\n indicator TEXT NOT NULL,\n operator TEXT NOT NULL,\n value REAL NOT NULL,\n created_at INTEGER NOT NULL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS ${T.signals} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n direction TEXT NOT NULL,\n confidence INTEGER NOT NULL,\n entry REAL NOT NULL,\n stop_loss REAL NOT NULL,\n tp1 REAL NOT NULL, tp2 REAL NOT NULL, tp3 REAL NOT NULL,\n atr REAL NOT NULL,\n bullish_score REAL NOT NULL,\n bearish_score REAL NOT NULL,\n session TEXT NOT NULL,\n reasoning TEXT NOT NULL,\n factors TEXT NOT NULL,\n status TEXT NOT NULL DEFAULT 'open',\n telegram_sent INTEGER NOT NULL DEFAULT 0,\n created_at INTEGER NOT NULL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS ${T.snapshots} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n price REAL NOT NULL,\n created_at INTEGER NOT NULL\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS ${T.telegram} (\n id INTEGER PRIMARY KEY CHECK (id = 1),\n bot_token TEXT DEFAULT '',\n chat_id TEXT DEFAULT '',\n notify_buy INTEGER NOT NULL DEFAULT 1,\n notify_sell INTEGER NOT NULL DEFAULT 1,\n notify_neutral INTEGER NOT NULL DEFAULT 0,\n min_confidence INTEGER NOT NULL DEFAULT 60\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS ${T.settings} (\n id INTEGER PRIMARY KEY CHECK (id = 1),\n api_key TEXT DEFAULT '',\n risk_per_trade REAL NOT NULL DEFAULT 1,\n rr1 REAL NOT NULL DEFAULT 1.5,\n rr2 REAL NOT NULL DEFAULT 2.5,\n rr3 REAL NOT NULL DEFAULT 4.0,\n scan_interval_min INTEGER NOT NULL DEFAULT 15,\n bot_running INTEGER NOT NULL DEFAULT 0\n )`,\n },\n { sql: `INSERT OR IGNORE INTO ${T.telegram} (id) VALUES (1)` },\n { sql: `INSERT OR IGNORE INTO ${T.settings} (id) VALUES (1)` },\n {\n sql: `CREATE TABLE IF NOT EXISTS ${T.pocketOption} (\n id INTEGER PRIMARY KEY CHECK (id = 1),\n enabled INTEGER NOT NULL DEFAULT 0,\n is_demo INTEGER NOT NULL DEFAULT 1,\n asset TEXT NOT NULL DEFAULT 'XAUUSD_otc',\n trade_amount REAL NOT NULL DEFAULT 10,\n expiry_seconds INTEGER NOT NULL DEFAULT 60,\n min_confidence INTEGER NOT NULL DEFAULT 65,\n po_session TEXT DEFAULT '',\n po_uid TEXT DEFAULT '',\n po_email TEXT DEFAULT '',\n po_password TEXT DEFAULT '',\n created_at INTEGER NOT NULL\n )`,\n },\n { sql: `INSERT OR IGNORE INTO ${T.pocketOption} (id) VALUES (1)` },\n {\n sql: `CREATE TABLE IF NOT EXISTS ${T.execution} (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n signal_id INTEGER NOT NULL,\n direction TEXT NOT NULL,\n asset TEXT NOT NULL,\n amount REAL NOT NULL,\n expiry_seconds INTEGER NOT NULL,\n confidence INTEGER NOT NULL,\n entry_price REAL,\n status TEXT NOT NULL DEFAULT 'pending',\n deal_id TEXT,\n result TEXT,\n payout REAL,\n profit_loss REAL,\n worker_id TEXT,\n created_at INTEGER NOT NULL,\n claimed_at INTEGER,\n executed_at INTEGER,\n completed_at INTEGER\n )`,\n },\n ]);\n initialized = true;\n}\n\n// ---------- Settings ----------\nexport interface BotSettings {\n apiKey: string;\n hasApiKey: boolean;\n riskPerTrade: number;\n riskReward: [number, number, number];\n scanIntervalMin: number;\n botRunning: boolean;\n}\n\nexport async function getSettings(): Promise {\n await initDb();\n const r = await sqlite.execute(`SELECT * FROM ${T.settings} WHERE id = 1`);\n const row = r.rows[0] as Record;\n return {\n apiKey: String(row.api_key ?? \"\"),\n hasApiKey: !!row.api_key,\n riskPerTrade: Number(row.risk_per_trade),\n riskReward: [Number(row.rr1), Number(row.rr2), Number(row.rr3)],\n scanIntervalMin: Number(row.scan_interval_min),\n botRunning: !!row.bot_running,\n };\n}\n\nexport async function updateSettings(p: Partial<{\n apiKey: string;\n riskPerTrade: number;\n riskReward: [number, number, number];\n scanIntervalMin: number;\n botRunning: boolean;\n}>) {\n await initDb();\n const sets: string[] = [];\n const args: any[] = [];\n if (p.apiKey !== undefined && p.apiKey !== \"\") { sets.push(\"api_key = ?\"); args.push(p.apiKey); }\n if (p.riskPerTrade !== undefined) { sets.push(\"risk_per_trade = ?\"); args.push(p.riskPerTrade); }\n if (p.riskReward) { sets.push(\"rr1 = ?\", \"rr2 = ?\", \"rr3 = ?\"); args.push(...p.riskReward); }\n if (p.scanIntervalMin !== undefined) { sets.push(\"scan_interval_min = ?\"); args.push(p.scanIntervalMin); }\n if (p.botRunning !== undefined) { sets.push(\"bot_running = ?\"); args.push(p.botRunning ? 1 : 0); }\n if (!sets.length) return;\n await sqlite.execute({ sql: `UPDATE ${T.settings} SET ${sets.join(\", \")} WHERE id = 1`, args });\n}\n\n// ---------- Telegram config ----------\nexport interface TelegramConfig {\n botToken: string;\n hasToken: boolean;\n chatId: string;\n notifyBuy: boolean;\n notifySell: boolean;\n notifyNeutral: boolean;\n minConfidence: number;\n}\n\nexport async function getTelegram(): Promise {\n await initDb();\n const r = await sqlite.execute(`SELECT * FROM ${T.telegram} WHERE id = 1`);\n const row = r.rows[0] as Record;\n return {\n botToken: String(row.bot_token ?? \"\"),\n hasToken: !!row.bot_token,\n chatId: String(row.chat_id ?? \"\"),\n notifyBuy: !!row.notify_buy,\n notifySell: !!row.notify_sell,\n notifyNeutral: !!row.notify_neutral,\n minConfidence: Number(row.min_confidence),\n };\n}\n\nexport async function updateTelegram(p: Partial<{\n botToken: string; chatId: string;\n notifyBuy: boolean; notifySell: boolean; notifyNeutral: boolean; minConfidence: number;\n}>) {\n await initDb();\n const sets: string[] = [];\n const args: any[] = [];\n if (p.botToken !== undefined && p.botToken !== \"\") { sets.push(\"bot_token = ?\"); args.push(p.botToken); }\n if (p.chatId !== undefined) { sets.push(\"chat_id = ?\"); args.push(p.chatId); }\n if (p.notifyBuy !== undefined) { sets.push(\"notify_buy = ?\"); args.push(p.notifyBuy ? 1 : 0); }\n if (p.notifySell !== undefined) { sets.push(\"notify_sell = ?\"); args.push(p.notifySell ? 1 : 0); }\n if (p.notifyNeutral !== undefined) { sets.push(\"notify_neutral = ?\"); args.push(p.notifyNeutral ? 1 : 0); }\n if (p.minConfidence !== undefined) { sets.push(\"min_confidence = ?\"); args.push(p.minConfidence); }\n if (!sets.length) return;\n await sqlite.execute({ sql: `UPDATE ${T.telegram} SET ${sets.join(\", \")} WHERE id = 1`, args });\n}\n\n// ---------- Strategies ----------\nexport async function listStrategies(): Promise {\n await initDb();\n const r = await sqlite.execute(`SELECT * FROM ${T.strategies} ORDER BY id DESC`);\n return r.rows.map((row: any) => ({\n id: Number(row.id),\n name: String(row.name),\n description: String(row.description ?? \"\"),\n side: row.side,\n weight: Number(row.weight),\n active: !!row.active,\n condition: { indicator: row.indicator, operator: row.operator, value: Number(row.value) },\n }));\n}\n\nexport async function createStrategy(s: Omit): Promise {\n await initDb();\n const r = await sqlite.execute({\n sql: `INSERT INTO ${T.strategies} (name, description, side, weight, active, indicator, operator, value, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [s.name, s.description, s.side, s.weight, s.active ? 1 : 0,\n s.condition.indicator, s.condition.operator, s.condition.value, Date.now()],\n });\n return Number(r.lastInsertRowid);\n}\n\nexport async function updateStrategy(id: number, s: Partial>) {\n await initDb();\n const sets: string[] = [];\n const args: any[] = [];\n if (s.name !== undefined) { sets.push(\"name = ?\"); args.push(s.name); }\n if (s.description !== undefined) { sets.push(\"description = ?\"); args.push(s.description); }\n if (s.side !== undefined) { sets.push(\"side = ?\"); args.push(s.side); }\n if (s.weight !== undefined) { sets.push(\"weight = ?\"); args.push(s.weight); }\n if (s.active !== undefined) { sets.push(\"active = ?\"); args.push(s.active ? 1 : 0); }\n if (s.condition) {\n sets.push(\"indicator = ?\", \"operator = ?\", \"value = ?\");\n args.push(s.condition.indicator, s.condition.operator, s.condition.value);\n }\n if (!sets.length) return;\n args.push(id);\n await sqlite.execute({ sql: `UPDATE ${T.strategies} SET ${sets.join(\", \")} WHERE id = ?`, args });\n}\n\nexport async function deleteStrategy(id: number) {\n await initDb();\n await sqlite.execute({ sql: `DELETE FROM ${T.strategies} WHERE id = ?`, args: [id] });\n}\n\n// ---------- Signals ----------\nexport interface SignalRow extends AnalysisResult {\n id: number;\n status: \"open\" | \"tp_hit\" | \"sl_hit\" | \"cancelled\";\n telegramSent: boolean;\n createdAt: number;\n}\n\nexport async function saveSignal(a: AnalysisResult, telegramSent: boolean): Promise {\n await initDb();\n const r = await sqlite.execute({\n sql: `INSERT INTO ${T.signals}\n (direction, confidence, entry, stop_loss, tp1, tp2, tp3, atr, bullish_score, bearish_score, session, reasoning, factors, status, telegram_sent, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, 'open', ?, ?)`,\n args: [a.direction, a.confidence, a.entry, a.stopLoss, a.takeProfits[0], a.takeProfits[1], a.takeProfits[2],\n a.atr, a.bullishScore, a.bearishScore, a.session, JSON.stringify(a.reasoning), JSON.stringify(a.factors),\n telegramSent ? 1 : 0, Date.now()],\n });\n return Number(r.lastInsertRowid);\n}\n\nexport async function listSignals(limit = 50): Promise {\n await initDb();\n const r = await sqlite.execute({ sql: `SELECT * FROM ${T.signals} ORDER BY id DESC LIMIT ?`, args: [limit] });\n return r.rows.map(rowToSignal);\n}\n\nexport async function updateSignalStatus(id: number, status: SignalRow[\"status\"]) {\n await initDb();\n await sqlite.execute({ sql: `UPDATE ${T.signals} SET status = ? WHERE id = ?`, args: [status, id] });\n}\n\nfunction rowToSignal(row: any): SignalRow {\n return {\n id: Number(row.id),\n direction: row.direction,\n confidence: Number(row.confidence),\n entry: Number(row.entry),\n stopLoss: Number(row.stop_loss),\n takeProfits: [Number(row.tp1), Number(row.tp2), Number(row.tp3)],\n riskRewardRatios: [1.5, 2.5, 4.0],\n atr: Number(row.atr),\n bullishScore: Number(row.bullish_score),\n bearishScore: Number(row.bearish_score),\n session: row.session,\n reasoning: JSON.parse(row.reasoning || \"[]\"),\n factors: JSON.parse(row.factors || \"[]\"),\n timestamp: Math.floor(Number(row.created_at) / 1000),\n status: row.status,\n telegramSent: !!row.telegram_sent,\n createdAt: Number(row.created_at),\n } as SignalRow;\n}\n\n// ---------- Price snapshots ----------\nexport async function saveSnapshot(price: number) {\n await initDb();\n await sqlite.execute({ sql: `INSERT INTO ${T.snapshots} (price, created_at) VALUES (?, ?)`, args: [price, Date.now()] });\n}\n\n// ---------- Pocket Option config ----------\nexport interface PocketOptionConfig {\n enabled: boolean;\n isDemo: boolean;\n asset: string;\n tradeAmount: number;\n expirySeconds: number;\n minConfidence: number;\n}\n\nexport async function getPocketOption(): Promise {\n await initDb();\n try { await sqlite.execute(`INSERT OR IGNORE INTO ${T.pocketOption} (id) VALUES (1)`); } catch {}\n const r = await sqlite.execute(`SELECT * FROM ${T.pocketOption} WHERE id = 1`);\n const row = (r.rows[0] ?? {}) as Record;\n return {\n enabled: !!row.enabled,\n isDemo: row.is_demo === undefined ? true : !!row.is_demo,\n asset: String(row.asset ?? \"XAUUSD_otc\"),\n tradeAmount: Number(row.trade_amount ?? 10),\n expirySeconds: Number(row.expiry_seconds ?? 60),\n minConfidence: Number(row.min_confidence ?? 65),\n };\n}\n\nexport async function updatePocketOption(p: Partial) {\n await initDb();\n const sets: string[] = [];\n const args: any[] = [];\n if (p.enabled !== undefined) { sets.push(\"enabled = ?\"); args.push(p.enabled ? 1 : 0); }\n if (p.isDemo !== undefined) { sets.push(\"is_demo = ?\"); args.push(p.isDemo ? 1 : 0); }\n if (p.asset !== undefined) { sets.push(\"asset = ?\"); args.push(p.asset); }\n if (p.tradeAmount !== undefined) { sets.push(\"trade_amount = ?\"); args.push(p.tradeAmount); }\n if (p.expirySeconds !== undefined) { sets.push(\"expiry_seconds = ?\"); args.push(p.expirySeconds); }\n if (p.minConfidence !== undefined) { sets.push(\"min_confidence = ?\"); args.push(p.minConfidence); }\n if (!sets.length) return;\n await sqlite.execute({ sql: `UPDATE ${T.pocketOption} SET ${sets.join(\", \")} WHERE id = 1`, args });\n}\n\n// ---------- Execution queue ----------\nexport interface ExecutionRow {\n id: number;\n signalId: number;\n direction: string;\n asset: string;\n amount: number;\n expirySeconds: number;\n confidence: number;\n entryPrice: number | null;\n status: \"pending\" | \"claimed\" | \"executing\" | \"win\" | \"loss\" | \"draw\" | \"error\" | \"skipped\";\n dealId: string | null;\n result: string | null;\n payout: number | null;\n profitLoss: number | null;\n workerId: string | null;\n createdAt: number;\n claimedAt: number | null;\n executedAt: number | null;\n completedAt: number | null;\n}\n\nexport async function enqueueExecution(\n signalId: number,\n direction: string,\n config: PocketOptionConfig,\n entryPrice: number,\n): Promise {\n await initDb();\n const r = await sqlite.execute({\n sql: `INSERT INTO ${T.execution}\n (signal_id, direction, asset, amount, expiry_seconds, confidence, entry_price, status, created_at)\n VALUES (?, ?, ?, ?, ?, ?, ?, 'pending', ?)`,\n args: [signalId, direction, config.asset, config.tradeAmount, config.expirySeconds,\n config.minConfidence, entryPrice, Date.now()],\n });\n return Number(r.lastInsertRowid);\n}\n\nexport async function getPendingExecutions(limit = 10): Promise {\n await initDb();\n const r = await sqlite.execute({\n sql: `SELECT * FROM ${T.execution} WHERE status = 'pending' ORDER BY id ASC LIMIT ?`,\n args: [limit],\n });\n return r.rows.map(rowToExecution);\n}\n\nexport async function claimExecutions(ids: number[], workerId: string): Promise {\n await initDb();\n if (!ids.length) return [];\n const placeholders = ids.map(() => \"?\").join(\",\");\n await sqlite.execute({\n sql: `UPDATE ${T.execution} SET status = 'claimed', claimed_at = ?, worker_id = ? WHERE id IN (${placeholders}) AND status = 'pending'`,\n args: [Date.now(), workerId, ...ids],\n });\n const r = await sqlite.execute({\n sql: `SELECT * FROM ${T.execution} WHERE id IN (${placeholders}) AND worker_id = ? AND status = 'claimed'`,\n args: [...ids, workerId],\n });\n return r.rows.map(rowToExecution);\n}\n\nexport async function updateExecutionResult(\n id: number,\n result: Partial>,\n) {\n await initDb();\n const sets: string[] = [];\n const args: any[] = [];\n if (result.status) { sets.push(\"status = ?\"); args.push(result.status); }\n if (result.dealId !== undefined) { sets.push(\"deal_id = ?\"); args.push(result.dealId); }\n if (result.result !== undefined) { sets.push(\"result = ?\"); args.push(result.result); }\n if (result.payout !== undefined) { sets.push(\"payout = ?\"); args.push(result.payout); }\n if (result.profitLoss !== undefined) { sets.push(\"profit_loss = ?\"); args.push(result.profitLoss); }\n if (result.entryPrice !== undefined) { sets.push(\"entry_price = ?\"); args.push(result.entryPrice); }\n if (result.status === \"win\" || result.status === \"loss\" || result.status === \"draw\" || result.status === \"error\") {\n sets.push(\"completed_at = ?\"); args.push(Date.now());\n } else if (result.status === \"executing\") {\n sets.push(\"executed_at = ?\"); args.push(Date.now());\n }\n if (!sets.length) return;\n args.push(id);\n await sqlite.execute({ sql: `UPDATE ${T.execution} SET ${sets.join(\", \")} WHERE id = ?`, args });\n}\n\nexport async function listExecutions(limit = 50): Promise {\n await initDb();\n const r = await sqlite.execute({\n sql: `SELECT * FROM ${T.execution} ORDER BY id DESC LIMIT ?`,\n args: [limit],\n });\n return r.rows.map(rowToExecution);\n}\n\nexport async function getExecutionStats(): Promise<{ total: number; wins: number; losses: number; draws: number; errors: number; pending: number; profitLoss: number }> {\n await initDb();\n const r = await sqlite.execute({\n sql: `SELECT\n COUNT(*) as total,\n SUM(CASE WHEN status = 'win' THEN 1 ELSE 0 END) as wins,\n SUM(CASE WHEN status = 'loss' THEN 1 ELSE 0 END) as losses,\n SUM(CASE WHEN status = 'draw' THEN 1 ELSE 0 END) as draws,\n SUM(CASE WHEN status = 'error' THEN 1 ELSE 0 END) as errors,\n SUM(CASE WHEN status IN ('pending','claimed','executing') THEN 1 ELSE 0 END) as pending,\n SUM(COALESCE(profit_loss, 0)) as profit_loss\n FROM ${T.execution}`,\n });\n const row = r.rows[0] as Record;\n return {\n total: Number(row.total ?? 0),\n wins: Number(row.wins ?? 0),\n losses: Number(row.losses ?? 0),\n draws: Number(row.draws ?? 0),\n errors: Number(row.errors ?? 0),\n pending: Number(row.pending ?? 0),\n profitLoss: Number(row.profit_loss ?? 0),\n };\n}\n\nfunction rowToExecution(row: any): ExecutionRow {\n return {\n id: Number(row.id),\n signalId: Number(row.signal_id),\n direction: String(row.direction),\n asset: String(row.asset),\n amount: Number(row.amount),\n expirySeconds: Number(row.expiry_seconds),\n confidence: Number(row.confidence),\n entryPrice: row.entry_price !== null ? Number(row.entry_price) : null,\n status: String(row.status) as ExecutionRow[\"status\"],\n dealId: row.deal_id !== null ? String(row.deal_id) : null,\n result: row.result !== null ? String(row.result) : null,\n payout: row.payout !== null ? Number(row.payout) : null,\n profitLoss: row.profit_loss !== null ? Number(row.profit_loss) : null,\n workerId: row.worker_id !== null ? String(row.worker_id) : null,\n createdAt: Number(row.created_at),\n claimedAt: row.claimed_at !== null ? Number(row.claimed_at) : null,\n executedAt: row.executed_at !== null ? Number(row.executed_at) : null,\n completedAt: row.completed_at !== null ? Number(row.completed_at) : null,\n };\n}\n\n// ---------- Pocket Option credentials (server-side only, never returned to browser) ----------\nexport interface PocketOptionCredentials {\n hasSession: boolean;\n hasUid: boolean;\n hasEmail: boolean;\n hasPassword: boolean;\n}\n\nexport async function getPOCredentialsSafe(): Promise {\n await initDb();\n await migratePOColumns();\n try { await sqlite.execute(`INSERT OR IGNORE INTO ${T.pocketOption} (id) VALUES (1)`); } catch {}\n const r = await sqlite.execute(`SELECT po_session, po_uid, po_email, po_password FROM ${T.pocketOption} WHERE id = 1`);\n const row = (r.rows[0] ?? {}) as Record;\n return {\n hasSession: !!(row.po_session && String(row.po_session).trim()),\n hasUid: !!(row.po_uid && String(row.po_uid).trim()),\n hasEmail: !!(row.po_email && String(row.po_email).trim()),\n hasPassword: !!(row.po_password && String(row.po_password).trim()),\n };\n}\n\nexport interface PocketOptionFullCredentials {\n session: string;\n uid: string;\n email: string;\n password: string;\n}\n\nexport async function getPOCredentials(): Promise {\n await initDb();\n const r = await sqlite.execute(`SELECT po_session, po_uid, po_email, po_password FROM ${T.pocketOption} WHERE id = 1`);\n const row = (r.rows[0] ?? {}) as Record;\n return {\n session: String(row.po_session ?? \"\"),\n uid: String(row.po_uid ?? \"\"),\n email: String(row.po_email ?? \"\"),\n password: String(row.po_password ?? \"\"),\n };\n}\n\nexport async function updatePOCredentials(p: Partial) {\n await initDb();\n const sets: string[] = [];\n const args: any[] = [];\n if (p.session !== undefined && p.session !== \"\") { sets.push(\"po_session = ?\"); args.push(p.session); }\n if (p.uid !== undefined && p.uid !== \"\") { sets.push(\"po_uid = ?\"); args.push(p.uid); }\n if (p.email !== undefined && p.email !== \"\") { sets.push(\"po_email = ?\"); args.push(p.email); }\n if (p.password !== undefined && p.password !== \"\") { sets.push(\"po_password = ?\"); args.push(p.password); }\n if (!sets.length) return;\n await sqlite.execute({ sql: `UPDATE ${T.pocketOption} SET ${sets.join(\", \")} WHERE id = 1`, args });\n}\n\n// Worker config — returns everything the worker needs in one call\nexport interface WorkerConfig {\n enabled: boolean;\n isDemo: boolean;\n asset: string;\n tradeAmount: number;\n expirySeconds: number;\n minConfidence: number;\n session: string;\n uid: string;\n email: string;\n password: string;\n}\n\nexport async function getWorkerConfig(): Promise {\n await initDb();\n try { await sqlite.execute(`INSERT OR IGNORE INTO ${T.pocketOption} (id) VALUES (1)`); } catch {}\n const r = await sqlite.execute(`SELECT * FROM ${T.pocketOption} WHERE id = 1`);\n const row = (r.rows[0] ?? {}) as Record;\n return {\n enabled: !!row.enabled,\n isDemo: row.is_demo === undefined ? true : !!row.is_demo,\n asset: String(row.asset ?? \"XAUUSD_otc\"),\n tradeAmount: Number(row.trade_amount ?? 10),\n expirySeconds: Number(row.expiry_seconds ?? 60),\n minConfidence: Number(row.min_confidence ?? 65),\n session: String(row.po_session ?? \"\"),\n uid: String(row.po_uid ?? \"\"),\n email: String(row.po_email ?? \"\"),\n password: String(row.po_password ?? \"\"),\n };\n}\n","createdAt",["D",1784176232961],"branchVersion","branchId","3fb300e2-6b7e-45ca-96c4-600fa1223d69","id","f6ee4bdf-7b32-40b0-8a18-64837024be7e","gold-pocket-option",["D",1784168423025],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","XAU/USD gold bot with Pocket Option trade execution","imageUrl","4459125c-8003-4433-acd3-58baf3bbb84a","pinnedFileId","019f68b9-9fa0-755f-881f-9931b705fb3b","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019f5364-9c00-7099-b436-37f40dd67401","tursoName","f6ee4bdf7b3240b08a1864837024be7e","tursoHostname","f6ee4bdf7b3240b08a1864837024be7e-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789525843977],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_111":110,"_119":115},"org",{"_111":110,"_112":113,"_114":115,"_19":62,"_116":117,"_118":31},"branch",{"_13":96,"_38":97,"_50":49,"_98":51,"_99":100,"_101":102,"_103":57,"_104":105,"_106":107,"_108":52,"_109":110},"isOwned",32,"main","projectId","forkedBranchId","5a0b467a-991a-4c16-802a-cdbd508660f1","forkedBranchVersion",30,"forkedProjectPrivacy","forkedProjectId","d6d0507d-e6f5-49da-b696-433d20202b1d","forkedProjectOrgId","019f0766-2070-77aa-9d40-6c13a831e714","projectName","userHandle","john3","handle","displayName","John","avatar","https://lh3.googleusercontent.com/a/ACg8ocLmB5zwj3H7UDrJtdAlWaVsMtkLVeeyDnlgXDPSPVwyWzrKTQ=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_50":51,"_38":52,"_45":436,"_54":-5,"_55":31,"_56":57,"_58":57,"_59":60,"_61":-5,"_19":62,"_63":64,"_65":66,"_67":-5,"_68":-5,"_69":70,"_71":72,"_73":74,"_75":76,"_77":437,"_79":-5,"_80":81,"_82":81,"_83":84,"_85":84,"_86":84,"_87":81,"_88":81,"_89":438,"_91":439,"_93":440,"_95":31},"tree",[204,206,231,233,234],"files",[204,205,206,207,208,209,210,211,212,213,214,215,216,217,218,219,220,221,222,223,224,225,226,227,228,229,230,231,232,233,234],"counts",{"_194":70,"_195":173,"_196":70,"_197":198,"_199":200},"contents",[154,155,156,157,158],"upstreamProject",{"_50":105,"_38":150,"_59":151,"_61":-5,"_56":57,"_89":152},"upstreamBranch",{"_50":100,"_45":144,"_145":146,"_38":97,"_98":105,"_13":102,"_99":-5,"_101":-5,"_147":148,"_54":-5,"_95":31,"_56":57,"_109":149,"_71":107,"_108":150},"emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1782535694487],"updatedAt",["D",1782536318333],"lockfileKey","1782536318495-esm.town_v_weruweruu_Weru@30-main","weruweruu","Weru","www.auragold.com",{"_111":149,"_119":153},"https://lh3.googleusercontent.com/a/ACg8ocKmJe9zq9vNjMgRM94QacY4kEn_fQHg4P8R765ZV3w7WevdUw=s96-c",{"_50":189,"_38":190,"_36":191,"_161":-5,"_48":49,"_47":173,"_163":66,"_45":192,"_13":70,"_40":182,"_42":-5,"_30":31,"_168":-5,"_33":193},{"_50":184,"_38":185,"_36":186,"_161":-5,"_48":49,"_47":173,"_163":66,"_45":187,"_13":70,"_40":182,"_42":-5,"_30":31,"_168":-5,"_33":188},{"_50":177,"_38":178,"_36":179,"_161":-5,"_48":49,"_47":180,"_163":66,"_45":181,"_13":70,"_40":182,"_42":-5,"_30":31,"_168":-5,"_33":183},{"_50":170,"_38":171,"_36":172,"_161":-5,"_48":49,"_47":173,"_163":66,"_45":174,"_13":70,"_40":26,"_42":175,"_30":31,"_168":-5,"_33":176},{"_50":159,"_38":160,"_36":64,"_161":-5,"_48":49,"_47":162,"_163":66,"_45":164,"_13":165,"_40":166,"_42":167,"_30":31,"_168":-5,"_33":169},"f33e1979-2219-470f-9ec8-b4ef5e3ede29","main.ts","parentId",28,"latest",["D",1784176219286],4,"http","// XAU/USD Gold Trading Bot — HTTP API + dashboard server.\nimport { Hono } from \"npm:hono@4\";\nimport { parseVal, serveFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { fetchCandles, fetchQuote, INTERVALS, type Interval } from \"./src/lib/market.ts\";\nimport { runAnalysisPipeline } from \"./src/lib/pipeline.ts\";\nimport { sendTelegramMessage } from \"./src/lib/telegram.ts\";\nimport {\n claimExecutions,\n createStrategy,\n deleteStrategy,\n getExecutionStats,\n getPocketOption,\n getSettings,\n getTelegram,\n listExecutions,\n listSignals,\n listStrategies,\n updateExecutionResult,\n updateSettings,\n updateSignalStatus,\n updateStrategy,\n updateTelegram,\n updatePocketOption,\n} from \"./src/lib/db.ts\";\n\nconst app = new Hono();\napp.onError((err) => Promise.reject(err));\n\nconst json = (data: unknown, status = 200) =>\n new Response(JSON.stringify(data), { status, headers: { \"Content-Type\": \"application/json\" } });\n\n// ---------- Market data ----------\napp.get(\"/api/market-data\", async (c) => {\n const settings = await getSettings();\n if (!settings.hasApiKey) return json({ error: \"No API key configured\" }, 400);\n const interval = (c.req.query(\"interval\") ?? \"5min\") as Interval;\n const what = c.req.query(\"type\") ?? \"candles\";\n try {\n if (what === \"quote\") return json(await fetchQuote(settings.apiKey));\n const outputsize = Number(c.req.query(\"outputsize\") ?? \"200\");\n const candles = await fetchCandles(settings.apiKey, interval, outputsize);\n return json({ interval, candles });\n } catch (e) {\n return json({ error: String(e) }, 502);\n }\n});\n\napp.get(\"/api/intervals\", (c) => json([...INTERVALS]));\n\n// ---------- Analyze ----------\napp.post(\"/api/analyze\", async (c) => {\n const r = await runAnalysisPipeline();\n return json(r, r.ok ? 200 : 400);\n});\n\n// ---------- Bot CRUD ----------\napp.get(\"/api/bot/signals\", async (c) => {\n const limit = Number(c.req.query(\"limit\") ?? \"50\");\n return json(await listSignals(limit));\n});\n\napp.patch(\"/api/bot/signals/:id\", async (c) => {\n const id = Number(c.req.param(\"id\"));\n const body = await c.req.json();\n if (body.status) await updateSignalStatus(id, body.status);\n return json({ ok: true });\n});\n\napp.get(\"/api/bot/strategies\", async (c) => json(await listStrategies()));\n\napp.post(\"/api/bot/strategies\", async (c) => {\n const b = await c.req.json();\n const id = await createStrategy({\n name: b.name,\n description: b.description ?? \"\",\n side: b.side,\n weight: Number(b.weight ?? 1),\n active: b.active ?? true,\n condition: b.condition,\n });\n return json({ id });\n});\n\napp.patch(\"/api/bot/strategies/:id\", async (c) => {\n await updateStrategy(Number(c.req.param(\"id\")), await c.req.json());\n return json({ ok: true });\n});\n\napp.delete(\"/api/bot/strategies/:id\", async (c) => {\n await deleteStrategy(Number(c.req.param(\"id\")));\n return json({ ok: true });\n});\n\napp.get(\"/api/bot/settings\", async (c) => {\n const s = await getSettings();\n const { apiKey: _omit, ...safe } = s; // never leak the key\n return json(safe);\n});\n\napp.patch(\"/api/bot/settings\", async (c) => {\n await updateSettings(await c.req.json());\n return json({ ok: true });\n});\n\napp.get(\"/api/bot/telegram\", async (c) => {\n const t = await getTelegram();\n const { botToken: _omit, ...safe } = t; // never leak the token\n return json(safe);\n});\n\napp.patch(\"/api/bot/telegram\", async (c) => {\n await updateTelegram(await c.req.json());\n return json({ ok: true });\n});\n\napp.post(\"/api/bot/telegram/test\", async (c) => {\n const t = await getTelegram();\n if (!t.hasToken || !t.chatId) return json({ ok: false, error: \"Configure bot token and chat ID first\" }, 400);\n const r = await sendTelegramMessage(\n t.botToken,\n t.chatId,\n \"✅ Gold Bot connected!\\nYou'll receive XAU/USD trade signals here.\",\n );\n return json(r, r.ok ? 200 : 400);\n});\n\n// ---------- Pocket Option config ----------\napp.get(\"/api/bot/pocket-option\", async (c) => json(await getPocketOption()));\n\napp.patch(\"/api/bot/pocket-option\", async (c) => {\n await updatePocketOption(await c.req.json());\n return json({ ok: true });\n});\n\n// ---------- Pocket Option credentials (sanitized — never returns secrets) ----------\napp.get(\"/api/bot/pocket-option/creds\", async (c) => {\n const { getPOCredentialsSafe } = await import(\"./src/lib/db.ts\");\n return json(await getPOCredentialsSafe());\n});\n\napp.patch(\"/api/bot/pocket-option/creds\", async (c) => {\n const { updatePOCredentials } = await import(\"./src/lib/db.ts\");\n await updatePOCredentials(await c.req.json());\n return json({ ok: true });\n});\n\n// ---------- Worker config endpoint (returns full config incl. secrets for the worker) ----------\napp.get(\"/api/worker/config\", async (c) => {\n const { getWorkerConfig } = await import(\"./src/lib/db.ts\");\n const config = await getWorkerConfig();\n if (!config.session && !config.email) {\n return json({ error: \"No Pocket Option credentials configured. Set them in the dashboard first.\" }, 400);\n }\n return json(config);\n});\n\n// ---------- Execution queue (worker polls these) ----------\napp.get(\"/api/execution/list\", async (c) => {\n const limit = Number(c.req.query(\"limit\") ?? \"50\");\n return json(await listExecutions(limit));\n});\n\napp.get(\"/api/execution/stats\", async (c) => json(await getExecutionStats()));\n\napp.post(\"/api/execution/claim\", async (c) => {\n const b = await c.req.json();\n const workerId = String(b.workerId ?? `worker-${Date.now()}`);\n const limit = Number(b.limit ?? 5);\n const { getPendingExecutions } = await import(\"./src/lib/db.ts\");\n const pending = await getPendingExecutions(limit);\n if (!pending.length) return json({ claimed: [], workerId });\n const claimed = await claimExecutions(pending.map((p) => p.id), workerId);\n return json({ claimed, workerId });\n});\n\napp.post(\"/api/execution/result\", async (c) => {\n const b = await c.req.json();\n const id = Number(b.id);\n if (!id) return json({ error: \"Missing id\" }, 400);\n await updateExecutionResult(id, {\n status: b.status,\n dealId: b.dealId,\n result: b.result,\n payout: b.payout,\n profitLoss: b.profitLoss,\n entryPrice: b.entryPrice,\n });\n return json({ ok: true });\n});\n\n// ---------- Worker download ----------\napp.get(\"/api/worker/download\", async (c) => {\n const workerCode = `#!/usr/bin/env python3\n\"\"\"Pocket Option Worker — auto-configured from Val Town dashboard.\"\"\"\nimport os, sys, asyncio, uuid, aiohttp\nfrom datetime import datetime\n\nVAL_TOWN_URL = os.environ.get(\"VAL_TOWN_URL\", \"\").rstrip(\"/\")\nWORKER_ID = os.environ.get(\"WORKER_ID\", f\"worker-{uuid.uuid4().hex[:8]}\")\nPOLL_INTERVAL = int(os.environ.get(\"POLL_INTERVAL\", \"10\"))\nMAX_CONCURRENT = int(os.environ.get(\"MAX_CONCURRENT\", \"3\"))\n\nif not VAL_TOWN_URL:\n print(\"ERROR: Set VAL_TOWN_URL env var to your dashboard URL.\"); sys.exit(1)\n\nasync def fetch_config(session):\n async with session.get(f\"{VAL_TOWN_URL}/api/worker/config\") as resp:\n data = await resp.json()\n if \"error\" in data:\n print(f\"ERROR: {data['error']}\"); return None\n return data\n\nasync def claim_signals(session, limit=5):\n async with session.post(f\"{VAL_TOWN_URL}/api/execution/claim\", json={\"workerId\": WORKER_ID, \"limit\": limit}) as resp:\n data = await resp.json()\n return data.get(\"claimed\", [])\n\nasync def report_result(session, exec_id, status, **kwargs):\n payload = {\"id\": exec_id, \"status\": status, **kwargs}\n async with session.post(f\"{VAL_TOWN_URL}/api/execution/result\", json=payload) as resp:\n return await resp.json()\n\nasync def execute_trade(session, config, signal):\n from pocket_option_async import PocketOptionClient, Asset, DealAction, Regions, AuthorizationData, ChangeAssetRequest\n from pocket_option_async.deals import Deals\n\n exec_id = signal[\"id\"]\n direction = signal[\"direction\"]\n asset_str = signal[\"asset\"]\n amount = float(signal[\"amount\"])\n expiry = int(signal[\"expirySeconds\"])\n\n print(f\"[{datetime.now().strftime('%H:%M:%S')}] Executing #{exec_id}: {direction} {asset_str} ${amount} {expiry}s\")\n\n action = DealAction.CALL if direction == \"BUY\" else DealAction.PUT\n try:\n asset = getattr(Asset, asset_str, None)\n if asset is None:\n await report_result(session, exec_id, \"error\", result=f\"Unknown asset: {asset_str}\"); return\n except Exception as e:\n await report_result(session, exec_id, \"error\", result=str(e)); return\n\n try:\n await report_result(session, exec_id, \"executing\")\n client = PocketOptionClient()\n deals = Deals(client)\n\n @client.on.connect\n async def on_connect(data):\n await client.emit.auth(AuthorizationData.model_validate({\n \"session\": config[\"session\"], \"isDemo\": 1, \"uid\": int(config[\"uid\"]), \"platform\": 2,\n }))\n\n @client.on.success_auth\n async def on_auth(data):\n await client.emit.change_asset(ChangeAssetRequest(asset=asset, period=expiry))\n\n await client.connect(Regions.DEMO)\n await asyncio.sleep(2)\n\n deal = await deals.open_deal(asset=asset, amount=amount, action=action, is_demo=1, option_type=100, time=expiry)\n deal_id = str(deal.id if hasattr(deal, \"id\") else \"unknown\")\n print(f\" -> Deal opened: {deal_id}\")\n\n result = await deals.check_deal_result(wait_time=expiry + 30, deal=deal)\n status_str = str(result.status if hasattr(result, \"status\") else result).lower()\n\n if \"win\" in status_str:\n await report_result(session, exec_id, \"win\", deal_id=deal_id, payout=amount*0.8, profit_loss=amount*0.8)\n elif \"loss\" in status_str:\n await report_result(session, exec_id, \"loss\", deal_id=deal_id, profit_loss=-amount)\n elif \"draw\" in status_str:\n await report_result(session, exec_id, \"draw\", deal_id=deal_id, profit_loss=0)\n else:\n await report_result(session, exec_id, \"error\", deal_id=deal_id, result=f\"Unexpected: {status_str}\")\n\n await client.disconnect()\n except Exception as e:\n print(f\" -> ERROR: {e}\")\n await report_result(session, exec_id, \"error\", result=str(e), profit_loss=0)\n\nasync def main():\n print(\"=\" * 60)\n print(f\" Pocket Option Worker — {WORKER_ID}\")\n print(f\" Dashboard: {VAL_TOWN_URL}\")\n print(\"=\" * 60)\n\n async with aiohttp.ClientSession() as http_session:\n config = await fetch_config(http_session)\n if not config:\n print(\"ERROR: Could not fetch config. Make sure credentials are saved in the dashboard.\"); return\n if not config.get(\"enabled\"):\n print(\"WARNING: Auto-execution is disabled in the dashboard. Worker will poll but not execute.\")\n if not config.get(\"session\") and not config.get(\"email\"):\n print(\"ERROR: No credentials found. Save them in the dashboard Pocket Option tab.\"); return\n\n print(f\" Asset: {config['asset']} | Amount: ${config['tradeAmount']} | Expiry: {config['expirySeconds']}s\")\n print(f\" Demo: {'Yes' if config['isDemo'] else 'No'} | Min confidence: {config['minConfidence']}%\")\n print(\"=\" * 60)\n\n active_tasks = set()\n while True:\n try:\n done = {t for t in active_tasks if t.done()}\n active_tasks -= done\n available = MAX_CONCURRENT - len(active_tasks)\n if available > 0:\n signals = await claim_signals(http_session, available)\n if signals:\n print(f\"\\\\n[{datetime.now().strftime('%H:%M:%S')}] Claimed {len(signals)} signal(s)\")\n for sig in signals:\n task = asyncio.create_task(execute_trade(http_session, config, sig))\n active_tasks.add(task)\n await asyncio.sleep(POLL_INTERVAL)\n except KeyboardInterrupt:\n print(\"\\\\nShutting down...\"); break\n except Exception as e:\n print(f\" Poll error: {e}\")\n await asyncio.sleep(POLL_INTERVAL)\n\nif __name__ == \"__main__\":\n asyncio.run(main())\n`;\n return new Response(workerCode, { headers: { \"Content-Type\": \"text/plain; charset=utf-8\" } });\n});\n\n// ---------- View source ----------\napp.get(\"/source\", (c) => c.redirect(parseVal().links.self.val));\n\n// ---------- Static dashboard ----------\napp.get(\"/\", async () => serveFile(\"./src/frontend/index.html\", import.meta.url));\n\nexport default app.fetch;\n","label",[160],"d5d00f4f-ae7c-49fd-aa10-44720e9fcbee","README.md","019f68b9-9fa0-755f-881f-9646af481980",1,["D",1784168423025],"# 🥇 XAU/USD Gold Trading Bot\n\nA gold scalping bot and trading dashboard built on Val Town, implementing the\n**Ultimate Hybrid Gold Trading Strategy**. It fetches live XAU/USD data from\nTwelve Data, runs a multi-layer technical analysis engine, generates trade\nsignals with risk-managed levels, and (optionally) delivers alerts via Telegram.\n\n> ⚠️ **For educational and research purposes only. Gold trading carries\n> significant financial risk.**\n\n## Getting started\n\n1. **Settings tab** → paste your [Twelve Data API key](https://twelvedata.com)\n (free tier: 800 calls/day). It's stored server-side and never returned to the browser.\n2. **Dashboard** → click **Scan Now** to run the first analysis and populate the chart.\n3. **Telegram tab** (optional) → add a bot token + chat ID, then send a test message.\n4. **Strategy Intelligence tab** → add custom rules that score alongside the built-in engine.\n5. **Dashboard** → **Start Auto-Scan** to enable scheduled scanning (every 15 min on free tier).\n\n## Architecture\n\n```mermaid\nflowchart TD\n UI[\"React dashboard
(5 tabs)\"] -->|fetch| API[\"main.ts
Hono HTTP API\"]\n CRON[\"cron/autoscan.ts
every 15 min\"] --> PIPE\n API -->|/api/analyze| PIPE[\"pipeline.ts\"]\n API -->|/api/market-data| MKT[\"market.ts
Twelve Data\"]\n PIPE --> MKT\n PIPE --> ENG[\"analysis.ts
hybrid engine\"]\n ENG --> IND[\"indicators.ts\"]\n ENG --> PAT[\"patterns.ts\"]\n PIPE --> DB[(\"SQLite
db.ts\")]\n PIPE --> TG[\"telegram.ts
sendMessage\"]\n API --> DB\n```\n\n## The analysis engine (`src/lib/analysis.ts`)\n\nA pure-TypeScript library combining many methodologies, each contributing a\nweighted bullish/bearish score:\n\n- **EMA trend** (20/50/200) + **higher-timeframe (1H) bias**\n- **Market structure**: HH/HL vs LH/LL (trend detection)\n- **RSI (14)** and **MACD (12/26/9)** histogram momentum\n- **ICT Order Blocks** (bullish/bearish) and **Fair Value Gaps**\n- **Liquidity Sweep** detection — highest weight (3 points)\n- **SMT Divergence** (price vs RSI)\n- **Candlestick patterns** (Hammer, Shooting Star, Engulfing, Pin Bar, Marubozu, Morning/Evening Star, Doji)\n- **Dynamic Support & Resistance** via swing points\n- **Trading session filter** (scores reduced 30% in low-liquidity hours)\n\nDirection requires a **2-point lead** over the opposite side (avoids weak NEUTRAL\nsignals). Confidence = winning side ÷ total score. Stop-loss = ATR × 1.5 anchored\nto nearest S/R; take-profits at the configured 1.5R / 2.5R / 4.0R.\n\n## File map\n\n| Path | Purpose |\n| --- | --- |\n| `main.ts` | Hono HTTP API + serves the dashboard |\n| `cron/autoscan.ts` | Scheduled auto-scan (interval) |\n| `src/lib/analysis.ts` | Hybrid analysis engine |\n| `src/lib/indicators.ts` | EMA/RSI/MACD/ATR/swing math |\n| `src/lib/patterns.ts` | Candlestick patterns |\n| `src/lib/market.ts` | Twelve Data fetcher |\n| `src/lib/telegram.ts` | Outbound Telegram notifier |\n| `src/lib/pipeline.ts` | fetch → analyze → persist → notify |\n| `src/lib/db.ts` | SQLite schema + helpers (5 tables) |\n| `src/frontend/*` | React dashboard (Twind styling) |\n\n## Notes for Val Town\n\n- Twelve Data API key and Telegram credentials are stored in **SQLite**\n (configured via the dashboard) — not env vars — so no setup outside the app is needed.\n- The free tier enforces a **15-minute minimum** cron interval. Upgrade for tighter scheduling.\n- This was adapted from a Netlify/Postgres design to Val Town's Deno runtime\n (HTTP vals, project SQLite, interval cron).\n",[171],"06e08f4b-230d-4871-b0f4-246282449d42","worker","42e34538-bcb7-470e-833b-10bb393cc024",16,["D",1784168577992],"directory",[178],"1b3d80a6-465c-4f8f-a9c9-285d6cbe3cf9","src","019f68b9-9fa0-755f-881f-912684cc88bc",["D",1784168423025],[185],"d632a9c8-6b2a-455c-aadd-d5d9f96cebdd","cron","019f68b9-9fa0-755f-881f-316767c51e8a",["D",1784168423025],[190],"pulls","branches","forks","envVars",{"_201":70,"_203":70},"connections",{"_201":173,"_202":173},"count","unfilledCount","emptyCount",{"_50":189,"_38":190,"_36":191,"_161":-5,"_48":49,"_47":173,"_163":66,"_45":433,"_13":70,"_40":182,"_42":-5,"_30":31,"_168":-5,"_236":434,"_33":435},{"_50":425,"_38":426,"_36":427,"_161":191,"_48":49,"_47":173,"_163":66,"_45":428,"_13":70,"_40":429,"_42":430,"_30":31,"_168":-5,"_236":431,"_33":432},{"_50":184,"_38":185,"_36":186,"_161":-5,"_48":49,"_47":173,"_163":66,"_45":422,"_13":70,"_40":182,"_42":-5,"_30":31,"_168":-5,"_236":423,"_33":424},{"_50":418,"_38":322,"_36":317,"_161":186,"_48":49,"_47":173,"_163":66,"_45":419,"_13":70,"_40":182,"_42":-5,"_30":31,"_168":-5,"_236":420,"_33":421},{"_50":414,"_38":406,"_36":401,"_161":317,"_48":49,"_47":173,"_163":66,"_45":415,"_13":70,"_40":182,"_42":-5,"_30":31,"_168":-5,"_236":416,"_33":417},{"_50":407,"_38":408,"_36":409,"_161":401,"_48":49,"_47":173,"_163":66,"_45":410,"_13":70,"_40":41,"_42":411,"_30":31,"_168":-5,"_236":412,"_33":413},{"_50":398,"_38":399,"_36":400,"_161":401,"_48":49,"_47":173,"_163":66,"_45":402,"_13":70,"_40":41,"_42":403,"_30":31,"_168":-5,"_236":404,"_33":405},{"_50":394,"_38":357,"_36":352,"_161":317,"_48":49,"_47":173,"_163":66,"_45":395,"_13":70,"_40":182,"_42":-5,"_30":31,"_168":-5,"_236":396,"_33":397},{"_50":387,"_38":388,"_36":389,"_161":352,"_48":49,"_47":173,"_163":66,"_45":390,"_13":70,"_40":41,"_42":391,"_30":31,"_168":-5,"_236":392,"_33":393},{"_50":379,"_38":380,"_36":381,"_161":352,"_48":49,"_47":382,"_163":66,"_45":383,"_13":345,"_40":41,"_42":384,"_30":31,"_168":-5,"_236":385,"_33":386},{"_50":372,"_38":373,"_36":374,"_161":352,"_48":49,"_47":173,"_163":66,"_45":375,"_13":70,"_40":41,"_42":376,"_30":31,"_168":-5,"_236":377,"_33":378},{"_50":365,"_38":366,"_36":367,"_161":352,"_48":49,"_47":173,"_163":66,"_45":368,"_13":70,"_40":41,"_42":369,"_30":31,"_168":-5,"_236":370,"_33":371},{"_50":358,"_38":359,"_36":360,"_161":352,"_48":49,"_47":173,"_163":66,"_45":361,"_13":70,"_40":41,"_42":362,"_30":31,"_168":-5,"_236":363,"_33":364},{"_50":349,"_38":350,"_36":351,"_161":352,"_48":49,"_47":173,"_163":66,"_45":353,"_13":70,"_40":41,"_42":354,"_30":31,"_168":-5,"_236":355,"_33":356},{"_50":340,"_38":341,"_36":342,"_161":317,"_48":49,"_47":343,"_163":66,"_45":344,"_13":345,"_40":41,"_42":346,"_30":31,"_168":-5,"_236":347,"_33":348},{"_50":331,"_38":332,"_36":333,"_161":317,"_48":49,"_47":334,"_163":66,"_45":335,"_13":336,"_40":41,"_42":337,"_30":31,"_168":-5,"_236":338,"_33":339},{"_50":323,"_38":324,"_36":325,"_161":317,"_48":49,"_47":326,"_163":66,"_45":327,"_13":173,"_40":26,"_42":328,"_30":31,"_168":-5,"_236":329,"_33":330},{"_50":314,"_38":315,"_36":316,"_161":317,"_48":49,"_47":173,"_163":66,"_45":318,"_13":70,"_40":41,"_42":319,"_30":31,"_168":-5,"_236":320,"_33":321},{"_50":310,"_38":260,"_36":255,"_161":186,"_48":49,"_47":173,"_163":66,"_45":311,"_13":70,"_40":182,"_42":-5,"_30":31,"_168":-5,"_236":312,"_33":313},{"_50":303,"_38":304,"_36":305,"_161":255,"_48":49,"_47":173,"_163":66,"_45":306,"_13":70,"_40":41,"_42":307,"_30":31,"_168":-5,"_236":308,"_33":309},{"_50":298,"_38":39,"_36":37,"_161":255,"_48":49,"_47":14,"_163":31,"_45":299,"_13":300,"_40":41,"_42":44,"_30":31,"_168":-5,"_236":301,"_33":302},{"_50":291,"_38":292,"_36":293,"_161":255,"_48":49,"_47":173,"_163":66,"_45":294,"_13":70,"_40":41,"_42":295,"_30":31,"_168":-5,"_236":296,"_33":297},{"_50":284,"_38":285,"_36":286,"_161":255,"_48":49,"_47":173,"_163":66,"_45":287,"_13":70,"_40":41,"_42":288,"_30":31,"_168":-5,"_236":289,"_33":290},{"_50":277,"_38":278,"_36":279,"_161":255,"_48":49,"_47":173,"_163":66,"_45":280,"_13":70,"_40":41,"_42":281,"_30":31,"_168":-5,"_236":282,"_33":283},{"_50":268,"_38":269,"_36":270,"_161":255,"_48":49,"_47":271,"_163":66,"_45":272,"_13":273,"_40":41,"_42":274,"_30":31,"_168":-5,"_236":275,"_33":276},{"_50":261,"_38":262,"_36":263,"_161":255,"_48":49,"_47":173,"_163":66,"_45":264,"_13":70,"_40":41,"_42":265,"_30":31,"_168":-5,"_236":266,"_33":267},{"_50":252,"_38":253,"_36":254,"_161":255,"_48":49,"_47":173,"_163":66,"_45":256,"_13":70,"_40":41,"_42":257,"_30":31,"_168":-5,"_236":258,"_33":259},{"_50":177,"_38":178,"_36":179,"_161":-5,"_48":49,"_47":180,"_163":66,"_45":249,"_13":70,"_40":182,"_42":-5,"_30":31,"_168":-5,"_236":250,"_33":251},{"_50":242,"_38":243,"_36":244,"_161":179,"_48":49,"_47":180,"_163":66,"_45":245,"_13":70,"_40":26,"_42":246,"_30":31,"_168":-5,"_236":247,"_33":248},{"_50":170,"_38":171,"_36":172,"_161":-5,"_48":49,"_47":173,"_163":66,"_45":239,"_13":70,"_40":26,"_42":175,"_30":31,"_168":-5,"_236":240,"_33":241},{"_50":159,"_38":160,"_36":64,"_161":-5,"_48":49,"_47":162,"_163":66,"_45":235,"_13":165,"_40":166,"_42":167,"_30":31,"_168":-5,"_236":237,"_33":238},["D",1784176219286],"children",[],[160],["D",1784168423025],[],[171],"881ed3c8-3b60-4009-aef8-b5f7f0fde553","pocket_option_worker.py","42a46adc-80bd-11f1-84c3-1607ee4eb77e",["D",1784168577992],"#!/usr/bin/env python3\n\"\"\"\nPocket Option Worker — bridges Val Town signals to Pocket Option trade execution.\n\nPolls the Val Town API for pending signals, opens binary option trades via the\nPocket Option SDK, waits for expiry, and reports results back.\n\nENV VARS (set on your VPS):\n VAL_TOWN_URL — Your val's HTTP endpoint URL\n PO_SESSION — Pocket Option session token (from browser cookies)\n PO_UID — Pocket Option user ID (integer)\n\nOptional:\n WORKER_ID — Unique worker identifier (default: auto-generated)\n POLL_INTERVAL — Seconds between polls (default: 10)\n MAX_CONCURRENT — Max simultaneous trades (default: 3)\n\nUsage:\n pip install pocket-option-async\n python pocket_option_worker.py\n\"\"\"\n\nimport os\nimport sys\nimport asyncio\nimport json\nimport time\nimport uuid\nfrom datetime import datetime\n\nimport aiohttp\n\n# Pocket Option SDK imports\nfrom pocket_option_async import (\n PocketOptionClient,\n Asset,\n DealAction,\n Regions,\n AuthorizationData,\n ChangeAssetRequest,\n)\nfrom pocket_option_async.deals import Deals\nfrom pocket_option_async.deals.models import Deal\nfrom pocket_option_async.deals.enums import DealStatusEnum\n\n# ─── Configuration ───────────────────────────────────────────────\nVAL_TOWN_URL = os.environ.get(\"VAL_TOWN_URL\", \"\").rstrip(\"/\")\nPO_SESSION = os.environ.get(\"PO_SESSION\", \"\")\nPO_UID = int(os.environ.get(\"PO_UID\", \"0\"))\nWORKER_ID = os.environ.get(\"WORKER_ID\", f\"worker-{uuid.uuid4().hex[:8]}\")\nPOLL_INTERVAL = int(os.environ.get(\"POLL_INTERVAL\", \"10\"))\nMAX_CONCURRENT = int(os.environ.get(\"MAX_CONCURRENT\", \"3\"))\n\nif not VAL_TOWN_URL or not PO_SESSION or not PO_UID:\n print(\"ERROR: Set VAL_TOWN_URL, PO_SESSION, and PO_UID env vars.\")\n sys.exit(1)\n\n# ─── Val Town API helpers ────────────────────────────────────────\nasync def vt_claim_signals(session: aiohttp.ClientSession, limit: int = 5) -> list:\n \"\"\"Claim pending signals from the Val Town execution queue.\"\"\"\n async with session.post(\n f\"{VAL_TOWN_URL}/api/execution/claim\",\n json={\"workerId\": WORKER_ID, \"limit\": limit},\n ) as resp:\n data = await resp.json()\n return data.get(\"claimed\", [])\n\nasync def vt_report_result(\n session: aiohttp.ClientSession,\n exec_id: int,\n status: str,\n deal_id: str | None = None,\n result: str | None = None,\n payout: float | None = None,\n profit_loss: float | None = None,\n entry_price: float | None = None,\n):\n \"\"\"Report trade result back to Val Town.\"\"\"\n payload = {\n \"id\": exec_id,\n \"status\": status,\n \"dealId\": deal_id,\n \"result\": result,\n \"payout\": payout,\n \"profitLoss\": profit_loss,\n \"entryPrice\": entry_price,\n }\n async with session.post(\n f\"{VAL_TOWN_URL}/api/execution/result\",\n json=payload,\n ) as resp:\n return await resp.json()\n\n# ─── Asset mapping ───────────────────────────────────────────────\n# Map string asset names from Val Town to Pocket Option SDK Asset enum.\n# Extend this as needed — check the SDK's Asset enum for available symbols.\nASSET_MAP = {\n \"XAUUSD_otc\": Asset.XAUUSD_otc if hasattr(Asset, \"XAUUSD_otc\") else None,\n \"EURUSD_otc\": Asset.EURUSD_otc if hasattr(Asset, \"EURUSD_otc\") else None,\n \"GBPUSD_otc\": Asset.GBPUSD_otc if hasattr(Asset, \"GBPUSD_otc\") else None,\n \"AUDCAD_otc\": Asset.AUDCAD_otc if hasattr(Asset, \"AUDCAD_otc\") else None,\n \"USDJPY_otc\": Asset.USDJPY_otc if hasattr(Asset, \"USDJPY_otc\") else None,\n \"EURJPY_otc\": Asset.EURJPY_otc if hasattr(Asset, \"EURJPY_otc\") else None,\n \"BTCUSD_otc\": Asset.BTCUSD_otc if hasattr(Asset, \"BTCUSD_otc\") else None,\n \"ETHUSD_otc\": Asset.ETHUSD_otc if hasattr(Asset, \"ETHUSD_otc\") else None,\n}\n\ndef resolve_asset(asset_str: str):\n \"\"\"Resolve asset string to Pocket Option Asset enum value.\"\"\"\n asset = ASSET_MAP.get(asset_str)\n if asset is None:\n # Try direct attribute lookup as fallback\n try:\n asset = getattr(Asset, asset_str)\n except AttributeError:\n print(f\"WARNING: Unknown asset '{asset_str}', skipping.\")\n return None\n return asset\n\n# ─── Trade execution ─────────────────────────────────────────────\nasync def execute_trade(\n client: PocketOptionClient,\n deals: Deals,\n session: aiohttp.ClientSession,\n signal: dict,\n):\n \"\"\"Execute a single trade from a claimed signal.\"\"\"\n exec_id = signal[\"id\"]\n direction = signal[\"direction\"] # \"BUY\" or \"SELL\"\n asset_str = signal[\"asset\"]\n amount = float(signal[\"amount\"])\n expiry = int(signal[\"expirySeconds\"])\n is_demo = 1 # Always demo mode for safety\n\n print(f\"[{datetime.now().strftime('%H:%M:%S')}] Executing #{exec_id}: \"\n f\"{direction} {asset_str} ${amount} {expiry}s\")\n\n # Map direction to DealAction\n action = DealAction.CALL if direction == \"BUY\" else DealAction.PUT\n\n # Resolve asset\n asset = resolve_asset(asset_str)\n if asset is None:\n await vt_report_result(session, exec_id, \"error\", result=f\"Unknown asset: {asset_str}\")\n return\n\n try:\n # Mark as executing\n await vt_report_result(session, exec_id, \"executing\")\n\n # Change to the target asset\n await client.emit.change_asset(\n ChangeAssetRequest(asset=asset, period=expiry)\n )\n await asyncio.sleep(1)\n\n # Open the deal\n deal = await deals.open_deal(\n asset=asset,\n amount=amount,\n action=action,\n is_demo=is_demo,\n option_type=100,\n time=expiry,\n )\n\n deal_id = str(deal.id if hasattr(deal, \"id\") else deal.get(\"id\", \"unknown\"))\n print(f\" → Deal opened: {deal_id}\")\n\n # Wait for result\n result = await deals.check_deal_result(\n wait_time=expiry + 30, # extra buffer\n deal=deal,\n )\n\n # Determine outcome\n status = \"error\"\n payout_val = None\n pl = None\n result_str = str(result)\n\n if hasattr(result, \"status\"):\n deal_status = result.status\n elif isinstance(result, dict):\n deal_status = result.get(\"status\", \"unknown\")\n else:\n deal_status = str(result)\n\n # Check for win/loss/draw\n status_lower = str(deal_status).lower()\n if \"win\" in status_lower or deal_status == DealStatusEnum.WIN:\n status = \"win\"\n payout_val = amount * 0.8 # typical 80% payout; adjust\n pl = payout_val\n elif \"loss\" in status_lower or deal_status == DealStatusEnum.LOSS:\n status = \"loss\"\n pl = -amount\n elif \"draw\" in status_lower or deal_status == DealStatusEnum.DRAW:\n status = \"draw\"\n pl = 0\n else:\n status = \"error\"\n result_str = f\"Unexpected status: {deal_status}\"\n\n print(f\" → Result: {status} (P/L: ${pl})\")\n\n await vt_report_result(\n session, exec_id, status,\n deal_id=deal_id,\n result=result_str,\n payout=payout_val,\n profit_loss=pl,\n )\n\n except Exception as e:\n print(f\" → ERROR: {e}\")\n await vt_report_result(\n session, exec_id, \"error\",\n result=str(e),\n profit_loss=0,\n )\n\n# ─── Main loop ───────────────────────────────────────────────────\nasync def main():\n print(\"=\" * 60)\n print(f\" Pocket Option Worker — {WORKER_ID}\")\n print(f\" Val Town: {VAL_TOWN_URL}\")\n print(f\" Poll interval: {POLL_INTERVAL}s | Max concurrent: {MAX_CONCURRENT}\")\n print(\"=\" * 60)\n\n # Connect to Pocket Option\n client = PocketOptionClient()\n deals = Deals(client)\n\n @client.on.connect\n async def on_connect(data):\n await client.emit.auth(\n AuthorizationData.model_validate({\n \"session\": PO_SESSION,\n \"isDemo\": 1,\n \"uid\": PO_UID,\n \"platform\": 2,\n })\n )\n print(\" Connected to Pocket Option, authenticating…\")\n\n @client.on.success_auth\n async def on_success_auth(data):\n print(\" ✅ Authenticated successfully!\")\n # Subscribe to default asset\n try:\n await client.emit.subscribe_to_asset(Asset.XAUUSD_otc)\n except Exception:\n pass # non-critical\n\n print(\" Connecting to Pocket Option WebSocket…\")\n await client.connect(Regions.DEMO)\n print(\" WebSocket connected.\\n\")\n\n # Main polling loop\n active_tasks: set[asyncio.Task] = set()\n async with aiohttp.ClientSession() as http_session:\n while True:\n try:\n # Clean up completed tasks\n done = {t for t in active_tasks if t.done()}\n active_tasks -= done\n for t in done:\n # Surface any exceptions\n exc = t.exception()\n if exc:\n print(f\" Task error: {exc}\")\n\n # Only claim if we have capacity\n available = MAX_CONCURRENT - len(active_tasks)\n if available <= 0:\n await asyncio.sleep(1)\n continue\n\n # Poll for pending signals\n signals = await vt_claim_signals(http_session, limit=available)\n\n if signals:\n print(f\"\\n[{datetime.now().strftime('%H:%M:%S')}] \"\n f\"Claimed {len(signals)} signal(s)\")\n for sig in signals:\n task = asyncio.create_task(\n execute_trade(client, deals, http_session, sig)\n )\n active_tasks.add(task)\n\n await asyncio.sleep(POLL_INTERVAL)\n\n except KeyboardInterrupt:\n print(\"\\n Shutting down…\")\n break\n except Exception as e:\n print(f\" Poll error: {e}\")\n await asyncio.sleep(POLL_INTERVAL)\n\n # Cleanup\n for t in active_tasks:\n t.cancel()\n await client.disconnect()\n print(\" Worker stopped.\")\n\n\nif __name__ == \"__main__\":\n try:\n asyncio.run(main())\n except KeyboardInterrupt:\n print(\"\\n Bye!\")\n",[],[178,243],["D",1784168577992],[232],[178],"09719703-d808-46f4-8eea-749886ca9860","types.ts","019f68b9-9fa0-755f-881f-8bfef8d07565","019f68b9-9fa0-755f-881f-8dd49a9197f0",["D",1784168423025],"// Shared types for the XAU/USD gold trading bot.\n\nexport interface Candle {\n time: number; // unix seconds\n open: number;\n high: number;\n low: number;\n close: number;\n volume: number;\n}\n\nexport type Direction = \"BUY\" | \"SELL\" | \"NEUTRAL\";\n\nexport interface AnalysisFactor {\n name: string;\n side: \"bullish\" | \"bearish\" | \"neutral\";\n weight: number;\n detail: string;\n}\n\nexport interface AnalysisResult {\n direction: Direction;\n confidence: number; // 0-100\n entry: number;\n stopLoss: number;\n takeProfits: [number, number, number]; // 1.5R, 2.5R, 4.0R\n riskRewardRatios: [number, number, number];\n atr: number;\n bullishScore: number;\n bearishScore: number;\n factors: AnalysisFactor[];\n session: TradingSession;\n reasoning: string[];\n timestamp: number;\n}\n\nexport type TradingSession =\n | \"London\"\n | \"NY-London Overlap\"\n | \"New York\"\n | \"Asian/Low Liquidity\";\n\nexport interface CustomStrategy {\n id: number;\n name: string;\n description: string;\n side: \"bullish\" | \"bearish\";\n weight: number;\n active: boolean;\n // A simple, safe expression-free rule set (evaluated in analysis.ts):\n condition: StrategyCondition;\n}\n\nexport interface StrategyCondition {\n indicator: \"rsi\" | \"ema_trend\" | \"macd_hist\" | \"price_vs_ema200\";\n operator: \"<\" | \">\" | \"==\";\n value: number;\n}\n",[],[185,260,253],"lib","77cb734e-40a1-442e-95d9-a0fbc6a111c6","telegram.ts","019f68b9-9fa0-755f-881f-87fdc4da47c8",["D",1784168423025],"// Outbound-only Telegram notifier (sendMessage). Token/chatId come from the DB.\nimport type { AnalysisResult } from \"./types.ts\";\n\nexport async function sendTelegramMessage(\n botToken: string,\n chatId: string,\n text: string,\n): Promise<{ ok: boolean; error?: string }> {\n if (!botToken || !chatId) return { ok: false, error: \"Missing bot token or chat ID\" };\n try {\n const res = await fetch(`https://api.telegram.org/bot${botToken}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n chat_id: chatId,\n text,\n parse_mode: \"HTML\",\n disable_web_page_preview: true,\n }),\n });\n const json = await res.json();\n if (!json.ok) return { ok: false, error: json.description ?? \"Telegram API error\" };\n return { ok: true };\n } catch (e) {\n return { ok: false, error: String(e) };\n }\n}\n\nexport function formatSignalMessage(a: AnalysisResult): string {\n const emoji = a.direction === \"BUY\" ? \"🟢\" : a.direction === \"SELL\" ? \"🔴\" : \"⚪\";\n const arrow = a.direction === \"BUY\" ? \"▲\" : a.direction === \"SELL\" ? \"▼\" : \"■\";\n const lines = [\n `${emoji} XAU/USD ${a.direction} ${arrow}`,\n `Confidence: ${a.confidence}%`,\n `Session: ${a.session}`,\n ``,\n `Entry: ${a.entry}`,\n `Stop Loss: ${a.stopLoss}`,\n `TP1 (${a.riskRewardRatios[0]}R): ${a.takeProfits[0]}`,\n `TP2 (${a.riskRewardRatios[1]}R): ${a.takeProfits[1]}`,\n `TP3 (${a.riskRewardRatios[2]}R): ${a.takeProfits[2]}`,\n `ATR: ${a.atr}`,\n ``,\n `Score: 🟢 ${a.bullishScore} / 🔴 ${a.bearishScore}`,\n ``,\n `Why:`,\n ...a.reasoning.slice(0, 6).map((r) => `• ${r}`),\n ``,\n `Educational only. Trade at your own risk.`,\n ];\n return lines.join(\"\\n\");\n}\n",[],[185,260,262],"b2b3371f-7619-47c8-9263-1d4eabd6ebdb","pipeline.ts","019f68b9-9fa0-755f-881f-81fbd9eea53b",7,["D",1784168474164],3,"// Full analysis pipeline: fetch data -> analyze -> persist -> notify.\nimport { analyze } from \"./analysis.ts\";\nimport { fetchCandles } from \"./market.ts\";\nimport { formatSignalMessage, sendTelegramMessage } from \"./telegram.ts\";\nimport {\n enqueueExecution,\n getSettings,\n getTelegram,\n getPocketOption,\n listStrategies,\n saveSignal,\n saveSnapshot,\n} from \"./db.ts\";\nimport type { AnalysisResult } from \"./types.ts\";\n\nexport interface PipelineResult {\n ok: boolean;\n error?: string;\n analysis?: AnalysisResult;\n signalId?: number;\n telegramSent: boolean;\n telegramError?: string;\n executionEnqueued?: boolean;\n}\n\nexport async function runAnalysisPipeline(): Promise {\n const settings = await getSettings();\n if (!settings.hasApiKey) {\n return { ok: false, error: \"No Twelve Data API key configured\", telegramSent: false };\n }\n\n let c5, c1h;\n try {\n [c5, c1h] = await Promise.all([\n fetchCandles(settings.apiKey, \"5min\", 250),\n fetchCandles(settings.apiKey, \"1h\", 150),\n ]);\n } catch (e) {\n return { ok: false, error: String(e), telegramSent: false };\n }\n if (c5.length < 60) {\n return { ok: false, error: \"Not enough 5min candles returned\", telegramSent: false };\n }\n\n const strategies = await listStrategies();\n const analysis = analyze(c5, c1h, {\n strategies,\n riskReward: settings.riskReward,\n });\n\n await saveSnapshot(analysis.entry);\n\n // Decide whether to notify\n const tg = await getTelegram();\n let telegramSent = false;\n let telegramError: string | undefined;\n const typeAllowed =\n (analysis.direction === \"BUY\" && tg.notifyBuy) ||\n (analysis.direction === \"SELL\" && tg.notifySell) ||\n (analysis.direction === \"NEUTRAL\" && tg.notifyNeutral);\n const meetsConfidence = analysis.confidence >= tg.minConfidence;\n\n if (tg.hasToken && tg.chatId && typeAllowed && meetsConfidence) {\n const r = await sendTelegramMessage(tg.botToken, tg.chatId, formatSignalMessage(analysis));\n telegramSent = r.ok;\n telegramError = r.error;\n }\n\n const signalId = await saveSignal(analysis, telegramSent);\n\n // Enqueue for Pocket Option execution if enabled and signal is actionable\n let executionEnqueued = false;\n if (analysis.direction !== \"NEUTRAL\") {\n const po = await getPocketOption();\n if (po.enabled && analysis.confidence >= po.minConfidence) {\n await enqueueExecution(signalId, analysis.direction, po, analysis.entry);\n executionEnqueued = true;\n }\n }\n\n return { ok: true, analysis, signalId, telegramSent, telegramError, executionEnqueued };\n}\n",[],[185,260,269],"5522d747-4bcc-45f6-88ac-16bae419dc7c","patterns.ts","019f68b9-9fa0-755f-881f-7c75350684c8",["D",1784168423025],"// Candlestick pattern detection (11 patterns) on the most recent candles.\nimport type { Candle } from \"./types.ts\";\n\nexport interface PatternHit {\n name: string;\n side: \"bullish\" | \"bearish\";\n}\n\nconst body = (c: Candle) => Math.abs(c.close - c.open);\nconst range = (c: Candle) => c.high - c.low || 1e-9;\nconst upperWick = (c: Candle) => c.high - Math.max(c.open, c.close);\nconst lowerWick = (c: Candle) => Math.min(c.open, c.close) - c.low;\nconst isBull = (c: Candle) => c.close > c.open;\nconst isBear = (c: Candle) => c.close < c.open;\n\n// Evaluate patterns ending at the last candle.\nexport function detectPatterns(candles: Candle[]): PatternHit[] {\n const hits: PatternHit[] = [];\n const n = candles.length;\n if (n < 3) return hits;\n const c = candles[n - 1];\n const p = candles[n - 2];\n const p2 = candles[n - 3];\n const b = body(c);\n const r = range(c);\n\n // Doji\n if (b <= r * 0.1) hits.push({ name: \"Doji\", side: isBull(c) ? \"bullish\" : \"bearish\" });\n\n // Hammer (bullish): small body up top, long lower wick\n if (lowerWick(c) >= b * 2 && upperWick(c) <= b * 0.6 && b > 0) {\n hits.push({ name: \"Hammer\", side: \"bullish\" });\n }\n\n // Shooting Star (bearish): small body down low, long upper wick\n if (upperWick(c) >= b * 2 && lowerWick(c) <= b * 0.6 && b > 0) {\n hits.push({ name: \"Shooting Star\", side: \"bearish\" });\n }\n\n // Pin Bar (either side) — wick >= 66% of range\n if (lowerWick(c) >= r * 0.66) hits.push({ name: \"Bullish Pin Bar\", side: \"bullish\" });\n if (upperWick(c) >= r * 0.66) hits.push({ name: \"Bearish Pin Bar\", side: \"bearish\" });\n\n // Marubozu — body is nearly the whole range\n if (b >= r * 0.9) {\n hits.push({ name: \"Marubozu\", side: isBull(c) ? \"bullish\" : \"bearish\" });\n }\n\n // Bullish Engulfing\n if (isBear(p) && isBull(c) && c.close >= p.open && c.open <= p.close) {\n hits.push({ name: \"Bullish Engulfing\", side: \"bullish\" });\n }\n // Bearish Engulfing\n if (isBull(p) && isBear(c) && c.open >= p.close && c.close <= p.open) {\n hits.push({ name: \"Bearish Engulfing\", side: \"bearish\" });\n }\n\n // Morning Star (bullish reversal): big bear, small body, big bull\n if (\n isBear(p2) && body(p2) > range(p2) * 0.5 &&\n body(p) < range(p) * 0.4 &&\n isBull(c) && body(c) > range(c) * 0.5 &&\n c.close > (p2.open + p2.close) / 2\n ) {\n hits.push({ name: \"Morning Star\", side: \"bullish\" });\n }\n // Evening Star (bearish reversal)\n if (\n isBull(p2) && body(p2) > range(p2) * 0.5 &&\n body(p) < range(p) * 0.4 &&\n isBear(c) && body(c) > range(c) * 0.5 &&\n c.close < (p2.open + p2.close) / 2\n ) {\n hits.push({ name: \"Evening Star\", side: \"bearish\" });\n }\n\n return hits;\n}\n",[],[185,260,278],"210af79f-db2c-469b-a4d3-7b61a0f10188","market.ts","019f68b9-9fa0-755f-881f-7a1dd6710b16",["D",1784168423025],"// Twelve Data market-data fetcher for XAU/USD.\nimport type { Candle } from \"./types.ts\";\n\nconst BASE = \"https://api.twelvedata.com\";\nexport const SYMBOL = \"XAU/USD\";\n\nexport const INTERVALS = [\"1min\", \"5min\", \"15min\", \"30min\", \"1h\", \"1day\"] as const;\nexport type Interval = (typeof INTERVALS)[number];\n\nexport interface Quote {\n symbol: string;\n price: number;\n change: number;\n percentChange: number;\n timestamp: number;\n}\n\ninterface TDError {\n status?: string;\n code?: number;\n message?: string;\n}\n\nfunction assertOk(json: any) {\n if (json && (json.status === \"error\" || json.code >= 400)) {\n const e = json as TDError;\n throw new Error(`Twelve Data error${e.code ? ` (${e.code})` : \"\"}: ${e.message ?? \"unknown\"}`);\n }\n}\n\nexport async function fetchCandles(\n apiKey: string,\n interval: Interval = \"5min\",\n outputsize = 250,\n): Promise {\n const url = `${BASE}/time_series?symbol=${encodeURIComponent(SYMBOL)}&interval=${interval}` +\n `&outputsize=${outputsize}&order=ASC&apikey=${encodeURIComponent(apiKey)}`;\n const res = await fetch(url);\n const json = await res.json();\n assertOk(json);\n if (!json.values) return [];\n return (json.values as any[]).map((v) => ({\n time: Math.floor(new Date(v.datetime.replace(\" \", \"T\") + \"Z\").getTime() / 1000),\n open: parseFloat(v.open),\n high: parseFloat(v.high),\n low: parseFloat(v.low),\n close: parseFloat(v.close),\n volume: v.volume ? parseFloat(v.volume) : 0,\n }));\n}\n\nexport async function fetchQuote(apiKey: string): Promise {\n const url = `${BASE}/quote?symbol=${encodeURIComponent(SYMBOL)}&apikey=${encodeURIComponent(apiKey)}`;\n const res = await fetch(url);\n const json = await res.json();\n assertOk(json);\n return {\n symbol: SYMBOL,\n price: parseFloat(json.close ?? json.price ?? \"0\"),\n change: parseFloat(json.change ?? \"0\"),\n percentChange: parseFloat(json.percent_change ?? \"0\"),\n timestamp: json.timestamp ? Number(json.timestamp) : Math.floor(Date.now() / 1000),\n };\n}\n",[],[185,260,285],"6554e122-96d4-47dd-955e-81f99f937121","indicators.ts","019f68b9-9fa0-755f-881f-75e53634e9c8",["D",1784168423025],"// Pure technical-indicator math. No I/O, fully unit-testable.\nimport type { Candle } from \"./types.ts\";\n\nexport function sma(values: number[], period: number): number[] {\n const out: number[] = [];\n for (let i = 0; i < values.length; i++) {\n if (i < period - 1) {\n out.push(NaN);\n continue;\n }\n let sum = 0;\n for (let j = i - period + 1; j <= i; j++) sum += values[j];\n out.push(sum / period);\n }\n return out;\n}\n\nexport function ema(values: number[], period: number): number[] {\n const out: number[] = [];\n const k = 2 / (period + 1);\n let prev = NaN;\n for (let i = 0; i < values.length; i++) {\n if (i < period - 1) {\n out.push(NaN);\n continue;\n }\n if (Number.isNaN(prev)) {\n // seed with SMA of first `period` values\n let sum = 0;\n for (let j = i - period + 1; j <= i; j++) sum += values[j];\n prev = sum / period;\n } else {\n prev = values[i] * k + prev * (1 - k);\n }\n out.push(prev);\n }\n return out;\n}\n\nexport function rsi(values: number[], period = 14): number[] {\n const out: number[] = new Array(values.length).fill(NaN);\n if (values.length <= period) return out;\n let gain = 0;\n let loss = 0;\n for (let i = 1; i <= period; i++) {\n const diff = values[i] - values[i - 1];\n if (diff >= 0) gain += diff;\n else loss -= diff;\n }\n let avgGain = gain / period;\n let avgLoss = loss / period;\n out[period] = avgLoss === 0 ? 100 : 100 - 100 / (1 + avgGain / avgLoss);\n for (let i = period + 1; i < values.length; i++) {\n const diff = values[i] - values[i - 1];\n const up = diff >= 0 ? diff : 0;\n const down = diff < 0 ? -diff : 0;\n avgGain = (avgGain * (period - 1) + up) / period;\n avgLoss = (avgLoss * (period - 1) + down) / period;\n out[i] = avgLoss === 0 ? 100 : 100 - 100 / (1 + avgGain / avgLoss);\n }\n return out;\n}\n\nexport interface MacdPoint {\n macd: number;\n signal: number;\n histogram: number;\n}\n\nexport function macd(\n values: number[],\n fast = 12,\n slow = 26,\n signalPeriod = 9,\n): MacdPoint[] {\n const emaFast = ema(values, fast);\n const emaSlow = ema(values, slow);\n const macdLine = values.map((_, i) => emaFast[i] - emaSlow[i]);\n // signal = EMA of macdLine (ignoring leading NaNs)\n const cleanIdx = macdLine.findIndex((v) => !Number.isNaN(v));\n const signalRaw = ema(\n macdLine.map((v) => (Number.isNaN(v) ? 0 : v)),\n signalPeriod,\n );\n return values.map((_, i) => {\n const m = macdLine[i];\n const s = i >= cleanIdx ? signalRaw[i] : NaN;\n return { macd: m, signal: s, histogram: m - s };\n });\n}\n\nexport function atr(candles: Candle[], period = 14): number[] {\n const out: number[] = new Array(candles.length).fill(NaN);\n if (candles.length < 2) return out;\n const trs: number[] = [0];\n for (let i = 1; i < candles.length; i++) {\n const h = candles[i].high;\n const l = candles[i].low;\n const pc = candles[i - 1].close;\n trs.push(Math.max(h - l, Math.abs(h - pc), Math.abs(l - pc)));\n }\n let sum = 0;\n for (let i = 1; i <= period && i < trs.length; i++) sum += trs[i];\n let prev = sum / period;\n out[period] = prev;\n for (let i = period + 1; i < candles.length; i++) {\n prev = (prev * (period - 1) + trs[i]) / period;\n out[i] = prev;\n }\n return out;\n}\n\nexport interface SwingPoint {\n index: number;\n price: number;\n type: \"high\" | \"low\";\n}\n\n// Find swing highs/lows using a left/right window (fractal-style).\nexport function swingPoints(candles: Candle[], window = 2): SwingPoint[] {\n const out: SwingPoint[] = [];\n for (let i = window; i < candles.length - window; i++) {\n let isHigh = true;\n let isLow = true;\n for (let j = i - window; j <= i + window; j++) {\n if (j === i) continue;\n if (candles[j].high >= candles[i].high) isHigh = false;\n if (candles[j].low <= candles[i].low) isLow = false;\n }\n if (isHigh) out.push({ index: i, price: candles[i].high, type: \"high\" });\n if (isLow) out.push({ index: i, price: candles[i].low, type: \"low\" });\n }\n return out;\n}\n\nexport const last = (arr: T[]): T => arr[arr.length - 1];\n",[],[185,260,292],"f68b3372-2cdf-4e81-89fd-06b2a3ef1a8b",["D",1784176232961],9,[],[185,260,39],"abf205e0-e2d6-43fb-9794-deec6a0093f7","analysis.ts","019f68b9-9fa0-755f-881f-6cd8b5ea9f93",["D",1784168423025],"// Ultimate Hybrid Gold Trading Strategy — pure analysis engine.\n// Input: 5min candles (primary) + 1h candles (higher-TF bias). Output: AnalysisResult.\nimport type {\n AnalysisFactor,\n AnalysisResult,\n Candle,\n CustomStrategy,\n Direction,\n TradingSession,\n} from \"./types.ts\";\nimport { atr, ema, last, macd, rsi, swingPoints } from \"./indicators.ts\";\nimport { detectPatterns } from \"./patterns.ts\";\n\ninterface Scored {\n bullish: number;\n bearish: number;\n factors: AnalysisFactor[];\n reasoning: string[];\n}\n\nfunction add(\n s: Scored,\n name: string,\n side: \"bullish\" | \"bearish\" | \"neutral\",\n weight: number,\n detail: string,\n) {\n s.factors.push({ name, side, weight, detail });\n if (side === \"bullish\") s.bullish += weight;\n else if (side === \"bearish\") s.bearish += weight;\n if (side !== \"neutral\") s.reasoning.push(`${detail} (${side} +${weight})`);\n}\n\n// --- Trading session (UTC hours) ---\nexport function getSession(date = new Date()): TradingSession {\n const h = date.getUTCHours();\n if (h >= 13 && h < 16) return \"NY-London Overlap\"; // highest liquidity\n if (h >= 7 && h < 13) return \"London\";\n if (h >= 16 && h < 21) return \"New York\";\n return \"Asian/Low Liquidity\";\n}\n\n// --- ICT: detect last bullish/bearish order block ---\nfunction orderBlocks(c: Candle[]) {\n let bullish: number | null = null;\n let bearish: number | null = null;\n for (let i = c.length - 3; i >= Math.max(1, c.length - 30); i--) {\n // bullish OB: down candle followed by strong up move\n if (c[i].close < c[i].open && c[i + 1].close > c[i + 1].open &&\n c[i + 1].close > c[i].high && bullish === null) {\n bullish = (c[i].open + c[i].close) / 2;\n }\n if (c[i].close > c[i].open && c[i + 1].close < c[i + 1].open &&\n c[i + 1].close < c[i].low && bearish === null) {\n bearish = (c[i].open + c[i].close) / 2;\n }\n }\n return { bullish, bearish };\n}\n\n// --- ICT: Fair Value Gaps (3-candle imbalance) on recent candles ---\nfunction fairValueGaps(c: Candle[]) {\n let bullish = false;\n let bearish = false;\n for (let i = c.length - 2; i >= Math.max(2, c.length - 20); i--) {\n if (c[i - 1].high < c[i + 1].low) bullish = true; // gap up\n if (c[i - 1].low > c[i + 1].high) bearish = true; // gap down\n }\n return { bullish, bearish };\n}\n\n// --- Liquidity sweep: wick takes out a recent swing then closes back ---\nfunction liquiditySweep(c: Candle[], swings: ReturnType) {\n const cur = last(c);\n const recentHighs = swings.filter((s) => s.type === \"high\").slice(-4);\n const recentLows = swings.filter((s) => s.type === \"low\").slice(-4);\n let bullishSweep = false; // swept lows then closed up = bullish\n let bearishSweep = false; // swept highs then closed down = bearish\n for (const lo of recentLows) {\n if (cur.low < lo.price && cur.close > lo.price && cur.close > cur.open) bullishSweep = true;\n }\n for (const hi of recentHighs) {\n if (cur.high > hi.price && cur.close < hi.price && cur.close < cur.open) bearishSweep = true;\n }\n return { bullishSweep, bearishSweep };\n}\n\n// --- Market structure: HH/HL vs LH/LL + BOS/CHoCH ---\nfunction marketStructure(swings: ReturnType) {\n const highs = swings.filter((s) => s.type === \"high\").slice(-3);\n const lows = swings.filter((s) => s.type === \"low\").slice(-3);\n let trend: \"up\" | \"down\" | \"range\" = \"range\";\n if (highs.length >= 2 && lows.length >= 2) {\n const hh = highs[highs.length - 1].price > highs[highs.length - 2].price;\n const hl = lows[lows.length - 1].price > lows[lows.length - 2].price;\n const lh = highs[highs.length - 1].price < highs[highs.length - 2].price;\n const ll = lows[lows.length - 1].price < lows[lows.length - 2].price;\n if (hh && hl) trend = \"up\";\n else if (lh && ll) trend = \"down\";\n }\n return { trend };\n}\n\n// --- Dynamic S/R from swing points nearest to price ---\nfunction nearestSR(price: number, swings: ReturnType) {\n let support = -Infinity;\n let resistance = Infinity;\n for (const s of swings) {\n if (s.price <= price && s.price > support) support = s.price;\n if (s.price >= price && s.price < resistance) resistance = s.price;\n }\n return {\n support: Number.isFinite(support) ? support : price * 0.995,\n resistance: Number.isFinite(resistance) ? resistance : price * 1.005,\n };\n}\n\nexport interface AnalyzeOptions {\n strategies?: CustomStrategy[];\n now?: Date;\n riskReward?: [number, number, number]; // defaults 1.5, 2.5, 4.0\n}\n\nexport function analyze(\n c5: Candle[],\n c1h: Candle[],\n opts: AnalyzeOptions = {},\n): AnalysisResult {\n const s: Scored = { bullish: 0, bearish: 0, factors: [], reasoning: [] };\n const closes = c5.map((x) => x.close);\n const price = last(closes);\n\n // EMAs on 5m\n const ema20 = last(ema(closes, 20));\n const ema50 = last(ema(closes, 50));\n const ema200 = last(ema(closes, 200));\n if (!Number.isNaN(ema20) && !Number.isNaN(ema50)) {\n if (ema20 > ema50 && price > ema20) add(s, \"EMA Trend (20/50)\", \"bullish\", 2, \"Price above rising 20/50 EMA\");\n else if (ema20 < ema50 && price < ema20) add(s, \"EMA Trend (20/50)\", \"bearish\", 2, \"Price below falling 20/50 EMA\");\n }\n if (!Number.isNaN(ema200)) {\n if (price > ema200) add(s, \"EMA 200 Bias\", \"bullish\", 1, \"Price above 200 EMA\");\n else add(s, \"EMA 200 Bias\", \"bearish\", 1, \"Price below 200 EMA\");\n }\n\n // Higher-TF (1h) bias\n if (c1h.length >= 50) {\n const h = c1h.map((x) => x.close);\n const e20 = last(ema(h, 20));\n const e50 = last(ema(h, 50));\n if (e20 > e50) add(s, \"1H Trend Bias\", \"bullish\", 2, \"1H EMA trend up\");\n else if (e20 < e50) add(s, \"1H Trend Bias\", \"bearish\", 2, \"1H EMA trend down\");\n }\n\n // RSI\n const rsiv = last(rsi(closes, 14));\n if (!Number.isNaN(rsiv)) {\n if (rsiv < 30) add(s, \"RSI\", \"bullish\", 2, `RSI oversold (${rsiv.toFixed(0)})`);\n else if (rsiv > 70) add(s, \"RSI\", \"bearish\", 2, `RSI overbought (${rsiv.toFixed(0)})`);\n else if (rsiv > 50) add(s, \"RSI\", \"bullish\", 1, `RSI bullish (${rsiv.toFixed(0)})`);\n else if (rsiv < 50) add(s, \"RSI\", \"bearish\", 1, `RSI bearish (${rsiv.toFixed(0)})`);\n }\n\n // MACD histogram momentum\n const macdArr = macd(closes);\n const mp = last(macdArr);\n const mpPrev = macdArr[macdArr.length - 2];\n if (mp && !Number.isNaN(mp.histogram)) {\n const rising = mpPrev && mp.histogram > mpPrev.histogram;\n if (mp.histogram > 0 && rising) add(s, \"MACD\", \"bullish\", 2, \"MACD histogram positive & rising\");\n else if (mp.histogram < 0 && !rising) add(s, \"MACD\", \"bearish\", 2, \"MACD histogram negative & falling\");\n else if (mp.histogram > 0) add(s, \"MACD\", \"bullish\", 1, \"MACD histogram positive\");\n else if (mp.histogram < 0) add(s, \"MACD\", \"bearish\", 1, \"MACD histogram negative\");\n }\n\n // Market structure\n const swings = swingPoints(c5, 2);\n const ms = marketStructure(swings);\n if (ms.trend === \"up\") add(s, \"Market Structure\", \"bullish\", 2, \"HH/HL structure (uptrend)\");\n else if (ms.trend === \"down\") add(s, \"Market Structure\", \"bearish\", 2, \"LH/LL structure (downtrend)\");\n\n // ICT order blocks\n const ob = orderBlocks(c5);\n if (ob.bullish !== null && price >= ob.bullish * 0.999 && price <= ob.bullish * 1.002) {\n add(s, \"Order Block\", \"bullish\", 2, \"Price at bullish order block\");\n }\n if (ob.bearish !== null && price <= ob.bearish * 1.001 && price >= ob.bearish * 0.998) {\n add(s, \"Order Block\", \"bearish\", 2, \"Price at bearish order block\");\n }\n\n // Fair Value Gaps\n const fvg = fairValueGaps(c5);\n if (fvg.bullish) add(s, \"Fair Value Gap\", \"bullish\", 1, \"Bullish FVG present\");\n if (fvg.bearish) add(s, \"Fair Value Gap\", \"bearish\", 1, \"Bearish FVG present\");\n\n // Liquidity sweep — highest weighted\n const sweep = liquiditySweep(c5, swings);\n if (sweep.bullishSweep) add(s, \"Liquidity Sweep\", \"bullish\", 3, \"Swept sell-side liquidity & reversed up\");\n if (sweep.bearishSweep) add(s, \"Liquidity Sweep\", \"bearish\", 3, \"Swept buy-side liquidity & reversed down\");\n\n // SMT divergence: price vs RSI\n const rsiArr = rsi(closes, 14);\n if (swings.length >= 4) {\n const lows = swings.filter((x) => x.type === \"low\").slice(-2);\n const highs = swings.filter((x) => x.type === \"high\").slice(-2);\n if (lows.length === 2) {\n const priceLower = lows[1].price < lows[0].price;\n const rsiHigher = rsiArr[lows[1].index] > rsiArr[lows[0].index];\n if (priceLower && rsiHigher) add(s, \"SMT Divergence\", \"bullish\", 2, \"Bullish RSI divergence\");\n }\n if (highs.length === 2) {\n const priceHigher = highs[1].price > highs[0].price;\n const rsiLower = rsiArr[highs[1].index] < rsiArr[highs[0].index];\n if (priceHigher && rsiLower) add(s, \"SMT Divergence\", \"bearish\", 2, \"Bearish RSI divergence\");\n }\n }\n\n // Candlestick patterns\n for (const pat of detectPatterns(c5)) {\n add(s, `Pattern: ${pat.name}`, pat.side, 1, `${pat.name} candlestick`);\n }\n\n // Custom user strategies\n for (const strat of opts.strategies ?? []) {\n if (!strat.active) continue;\n const v = strategyValue(strat.condition.indicator, { rsiv, ema20, ema50, ema200, price, macdHist: mp?.histogram ?? 0 });\n if (v === null) continue;\n const { operator, value } = strat.condition;\n const ok = operator === \"<\" ? v < value : operator === \">\" ? v > value : Math.abs(v - value) < 0.0001;\n if (ok) add(s, `Custom: ${strat.name}`, strat.side, strat.weight, strat.description || strat.name);\n }\n\n // Session filter — reduce conviction in low liquidity\n const session = getSession(opts.now ?? new Date());\n if (session === \"Asian/Low Liquidity\") {\n s.bullish *= 0.7;\n s.bearish *= 0.7;\n s.reasoning.push(\"Low-liquidity session: scores reduced 30%\");\n }\n\n // Direction needs a 2-point lead to avoid weak NEUTRAL signals\n const lead = Math.abs(s.bullish - s.bearish);\n let direction: Direction = \"NEUTRAL\";\n if (lead >= 2 && s.bullish > s.bearish) direction = \"BUY\";\n else if (lead >= 2 && s.bearish > s.bullish) direction = \"SELL\";\n\n const total = s.bullish + s.bearish || 1;\n const winner = Math.max(s.bullish, s.bearish);\n const confidence = direction === \"NEUTRAL\" ? 0 : Math.round((winner / total) * 100);\n\n // Risk levels\n const atrv = last(atr(c5, 14)) || price * 0.002;\n const sr = nearestSR(price, swings);\n const rr = opts.riskReward ?? [1.5, 2.5, 4.0];\n let stopLoss: number;\n let takeProfits: [number, number, number];\n if (direction === \"SELL\") {\n stopLoss = Math.max(sr.resistance, price + atrv * 1.5);\n const risk = stopLoss - price;\n takeProfits = [price - risk * rr[0], price - risk * rr[1], price - risk * rr[2]];\n } else {\n // BUY or NEUTRAL (still compute illustrative long levels)\n stopLoss = Math.min(sr.support, price - atrv * 1.5);\n const risk = price - stopLoss;\n takeProfits = [price + risk * rr[0], price + risk * rr[1], price + risk * rr[2]];\n }\n\n return {\n direction,\n confidence,\n entry: round(price),\n stopLoss: round(stopLoss),\n takeProfits: takeProfits.map(round) as [number, number, number],\n riskRewardRatios: rr,\n atr: round(atrv),\n bullishScore: round1(s.bullish),\n bearishScore: round1(s.bearish),\n factors: s.factors,\n session,\n reasoning: s.reasoning,\n timestamp: Math.floor((opts.now ?? new Date()).getTime() / 1000),\n };\n}\n\nfunction strategyValue(\n indicator: string,\n v: { rsiv: number; ema20: number; ema50: number; ema200: number; price: number; macdHist: number },\n): number | null {\n switch (indicator) {\n case \"rsi\": return Number.isNaN(v.rsiv) ? null : v.rsiv;\n case \"macd_hist\": return v.macdHist;\n case \"ema_trend\": return v.ema20 - v.ema50;\n case \"price_vs_ema200\": return v.price - v.ema200;\n default: return null;\n }\n}\n\nconst round = (n: number) => Math.round(n * 100) / 100;\nconst round1 = (n: number) => Math.round(n * 10) / 10;\n",[],[185,260,304],"78d0b133-b741-4edc-91d1-583d99813e02",["D",1784168423025],[223,224,225,226,227,228,229,230],[185,260],"95dc71bb-b9c6-4825-8355-ce651c670956","main.tsx","019f68b9-9fa0-755f-881f-66941f5ac857","019f68b9-9fa0-755f-881f-6b058105945e",["D",1784168423025],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React from \"https://esm.sh/react@18.2.0\";\nimport { createRoot } from \"https://esm.sh/react-dom@18.2.0/client\";\nimport { App } from \"./App.tsx\";\n\ncreateRoot(document.getElementById(\"root\")!).render();\n",[],[185,322,315],"frontend","ceea06e7-c3ad-4c3a-bf92-f1fe97a23008","index.html","019f68b9-9fa0-755f-881f-618744bb8399",10,["D",1784168489933],"\n\n\n \n \n XAU/USD Gold Trading Bot\n 🥇\" />\n \n \n\n\n

\n \n\n\n",[],[185,322,324],"7dc38db9-1dbb-4f9d-b91d-867f0cfa306e","api.ts","019f68b9-9fa0-755f-881f-5d726b4b6574",26,["D",1784176156285],5,"// Tiny typed fetch client for the dashboard.\nasync function req(url: string, opts?: RequestInit): Promise {\n const res = await fetch(url, {\n ...opts,\n headers: { \"Content-Type\": \"application/json\", ...(opts?.headers ?? {}) },\n });\n const text = await res.text();\n const data = text ? JSON.parse(text) : {};\n if (!res.ok) throw new Error(data.error || `HTTP ${res.status}`);\n return data as T;\n}\n\nexport interface Candle {\n time: number; open: number; high: number; low: number; close: number; volume: number;\n}\nexport interface Quote {\n symbol: string; price: number; change: number; percentChange: number; timestamp: number;\n}\nexport interface Factor { name: string; side: string; weight: number; detail: string; }\nexport interface Signal {\n id: number; direction: string; confidence: number; entry: number; stopLoss: number;\n takeProfits: number[]; riskRewardRatios: number[]; atr: number;\n bullishScore: number; bearishScore: number; session: string;\n reasoning: string[]; factors: Factor[]; status: string; telegramSent: boolean; createdAt: number;\n}\nexport interface Strategy {\n id: number; name: string; description: string; side: string; weight: number; active: boolean;\n condition: { indicator: string; operator: string; value: number };\n}\nexport interface Settings {\n hasApiKey: boolean; riskPerTrade: number; riskReward: number[];\n scanIntervalMin: number; botRunning: boolean;\n}\nexport interface Telegram {\n hasToken: boolean; chatId: string; notifyBuy: boolean; notifySell: boolean;\n notifyNeutral: boolean; minConfidence: number;\n}\nexport interface PocketOption {\n enabled: boolean; isDemo: boolean; asset: string; tradeAmount: number;\n expirySeconds: number; minConfidence: number;\n}\nexport interface POCredentials {\n hasSession: boolean; hasUid: boolean; hasEmail: boolean; hasPassword: boolean;\n}\nexport interface Execution {\n id: number; signalId: number; direction: string; asset: string; amount: number;\n expirySeconds: number; confidence: number; entryPrice: number | null;\n status: string; dealId: string | null; result: string | null;\n payout: number | null; profitLoss: number | null; workerId: string | null;\n createdAt: number; claimedAt: number | null; executedAt: number | null; completedAt: number | null;\n}\nexport interface ExecutionStats {\n total: number; wins: number; losses: number; draws: number; errors: number;\n pending: number; profitLoss: number;\n}\n\nexport const api = {\n candles: (interval: string, outputsize = 200) =>\n req<{ interval: string; candles: Candle[] }>(`/api/market-data?type=candles&interval=${interval}&outputsize=${outputsize}`),\n quote: () => req(`/api/market-data?type=quote`),\n analyze: () => req<{ ok: boolean; analysis?: any; telegramSent: boolean; telegramError?: string; error?: string }>(`/api/analyze`, { method: \"POST\" }),\n\n signals: (limit = 50) => req(`/api/bot/signals?limit=${limit}`),\n setSignalStatus: (id: number, status: string) =>\n req(`/api/bot/signals/${id}`, { method: \"PATCH\", body: JSON.stringify({ status }) }),\n\n strategies: () => req(`/api/bot/strategies`),\n createStrategy: (s: Partial) => req<{ id: number }>(`/api/bot/strategies`, { method: \"POST\", body: JSON.stringify(s) }),\n updateStrategy: (id: number, s: Partial) => req(`/api/bot/strategies/${id}`, { method: \"PATCH\", body: JSON.stringify(s) }),\n deleteStrategy: (id: number) => req(`/api/bot/strategies/${id}`, { method: \"DELETE\" }),\n\n settings: () => req(`/api/bot/settings`),\n updateSettings: (s: Partial) => req(`/api/bot/settings`, { method: \"PATCH\", body: JSON.stringify(s) }),\n\n telegram: () => req(`/api/bot/telegram`),\n updateTelegram: (t: Partial) => req(`/api/bot/telegram`, { method: \"PATCH\", body: JSON.stringify(t) }),\n testTelegram: () => req<{ ok: boolean; error?: string }>(`/api/bot/telegram/test`, { method: \"POST\" }),\n\n pocketOption: () => req(`/api/bot/pocket-option`),\n updatePocketOption: (p: Partial) => req(`/api/bot/pocket-option`, { method: \"PATCH\", body: JSON.stringify(p) }),\n\n poCredentials: () => req(`/api/bot/pocket-option/creds`),\n updatePOCredentials: (c: Partial<{ session: string; uid: string; email: string; password: string }>) =>\n req(`/api/bot/pocket-option/creds`, { method: \"PATCH\", body: JSON.stringify(c) }),\n\n executions: (limit = 50) => req(`/api/execution/list?limit=${limit}`),\n executionStats: () => req(`/api/execution/stats`),\n};\n",[],[185,322,332],"07cf1bbe-d96f-4965-8c37-6eb30a91dbc7","App.tsx","019f68b9-9fa0-755f-881f-5bd4ab37b7bf",14,["D",1784168494723],2,"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useState } from \"https://esm.sh/react@18.2.0\";\nimport { Dashboard } from \"./tabs/Dashboard.tsx\";\nimport { Signals } from \"./tabs/Signals.tsx\";\nimport { Strategies } from \"./tabs/Strategies.tsx\";\nimport { SettingsTab } from \"./tabs/SettingsTab.tsx\";\nimport { TelegramTab } from \"./tabs/TelegramTab.tsx\";\n\nconst TABS = [\n { id: \"dashboard\", label: \"Dashboard\", icon: \"📊\" },\n { id: \"signals\", label: \"Signals\", icon: \"📡\" },\n { id: \"strategies\", label: \"Strategy Intelligence\", icon: \"🧠\" },\n { id: \"settings\", label: \"Settings\", icon: \"⚙️\" },\n { id: \"telegram\", label: \"Telegram\", icon: \"✈️\" },\n];\n\nexport function App() {\n const [tab, setTab] = useState(\"dashboard\");\n return (\n

\n 🥇\n

XAU/USD Gold Bot

Ultimate Hybrid Strategy

\n view source\n

\n \n

\n\n

\n {tab === \"dashboard\" && }\n {tab === \"signals\" && }\n {tab === \"strategies\" && }\n {tab === \"settings\" && }\n {tab === \"pocketoption\" && }\n {tab === \"telegram\" && }\n

\n\n \n

\n );\n}\n",[],[185,322,341],"4111bd5d-c253-40d5-b8d4-3a597c29639d","TelegramTab.tsx","019f68b9-9fa0-755f-881f-5376150275dd","019f68b9-9fa0-755f-881f-5647a720ad18",["D",1784168423025],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useEffect, useState } from \"https://esm.sh/react@18.2.0\";\nimport { api, type Telegram } from \"../api.ts\";\nimport { Card, Btn, Input } from \"../components/ui.tsx\";\n\nfunction Toggle({ label, checked, onChange }: { label: string; checked: boolean; onChange: (v: boolean) => void }) {\n return (\n \n {label}\n \n \n );\n}\n\nexport function TelegramTab() {\n const [t, setT] = useState(null);\n const [botToken, setBotToken] = useState(\"\");\n const [msg, setMsg] = useState<{ ok: boolean; text: string } | null>(null);\n\n useEffect(() => { api.telegram().then(setT).catch(() => {}); }, []);\n\n async function save() {\n if (!t) return;\n await api.updateTelegram({\n botToken: botToken || undefined as any,\n chatId: t.chatId,\n notifyBuy: t.notifyBuy, notifySell: t.notifySell, notifyNeutral: t.notifyNeutral,\n minConfidence: t.minConfidence,\n });\n setBotToken(\"\");\n setT(await api.telegram());\n setMsg({ ok: true, text: \"Saved\" });\n setTimeout(() => setMsg(null), 2500);\n }\n\n async function test() {\n setMsg(null);\n const r = await api.testTelegram().catch((e) => ({ ok: false, error: String(e.message) }));\n setMsg(r.ok ? { ok: true, text: \"Test message sent! Check Telegram.\" } : { ok: false, text: r.error || \"Failed\" });\n }\n\n if (!t) return

Loading…

;\n\n return (\n

\n \n

Open Telegram and message @BotFather
Send /newbot and follow the prompts to get a bot token
Message @userinfobot to get your numeric chat ID
Start a chat with your new bot (send it any message) so it can reply to you
Paste both below, save, then hit Send Test Message

\n \n\n \n Bot Token {t.hasToken && ✓ saved}\n setBotToken(e.target.value)} className=\"mt-1 mb-3\" />\n Chat ID\n setT({ ...t, chatId: e.target.value })} className=\"mt-1\" />\n

\n Save\n Send Test Message\n

\n {msg &&

{msg.ok ? \"✓ \" : \"✕ \"}{msg.text}

}\n \n\n \n setT({ ...t, notifyBuy: v })} />\n setT({ ...t, notifySell: v })} />\n setT({ ...t, notifyNeutral: v })} />\n

\n Minimum confidence\n {t.minConfidence}%\n

\n setT({ ...t, minConfidence: Number(e.target.value) })}\n className=\"w-full mt-2 accent-amber-500\" />\n

\n Save Filters\n \n

\n );\n}\n",[],[185,322,357,350],"tabs","10eab569-1662-4fbf-88d9-998284af52a3","Strategies.tsx","019f68b9-9fa0-755f-881f-4cf890050a14",["D",1784168423025],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useEffect, useState } from \"https://esm.sh/react@18.2.0\";\nimport { api, type Strategy } from \"../api.ts\";\nimport { Card, Btn, Input } from \"../components/ui.tsx\";\n\nconst INDICATORS = [\n { v: \"rsi\", label: \"RSI (14)\" },\n { v: \"macd_hist\", label: \"MACD Histogram\" },\n { v: \"ema_trend\", label: \"EMA20 − EMA50\" },\n { v: \"price_vs_ema200\", label: \"Price − EMA200\" },\n];\n\nconst blank = {\n name: \"\", description: \"\", side: \"bullish\", weight: 1,\n indicator: \"rsi\", operator: \"<\", value: 30,\n};\n\nexport function Strategies() {\n const [list, setList] = useState([]);\n const [form, setForm] = useState({ ...blank });\n const [editId, setEditId] = useState(null);\n const [loading, setLoading] = useState(true);\n\n async function load() {\n setLoading(true);\n setList(await api.strategies().catch(() => []));\n setLoading(false);\n }\n useEffect(() => { load(); }, []);\n\n function reset() { setForm({ ...blank }); setEditId(null); }\n\n async function save() {\n if (!form.name.trim()) return;\n const payload = {\n name: form.name, description: form.description, side: form.side, weight: Number(form.weight),\n active: true,\n condition: { indicator: form.indicator, operator: form.operator, value: Number(form.value) },\n };\n if (editId) await api.updateStrategy(editId, payload as any);\n else await api.createStrategy(payload as any);\n reset();\n await load();\n }\n\n function edit(s: Strategy) {\n setEditId(s.id);\n setForm({\n name: s.name, description: s.description, side: s.side, weight: s.weight,\n indicator: s.condition.indicator, operator: s.condition.operator, value: s.condition.value,\n });\n }\n\n async function toggle(s: Strategy) {\n await api.updateStrategy(s.id, { active: !s.active } as any);\n setList((p) => p.map((x) => x.id === s.id ? { ...x, active: !x.active } : x));\n }\n\n async function remove(id: number) {\n await api.deleteStrategy(id);\n setList((p) => p.filter((x) => x.id !== id));\n }\n\n const sel = \"bg-slate-950 border border-slate-700 rounded-lg px-3 py-2 text-sm w-full\";\n\n return (\n

\n \n

\n setForm({ ...form, name: e.target.value })} />\n setForm({ ...form, description: e.target.value })} />\n

\n \n setForm({ ...form, weight: Number(e.target.value) })} />\n

Rule: when

\n \n \n setForm({ ...form, value: Number(e.target.value) })} />\n

\n {editId ? \"Update\" : \"Add Strategy\"}\n {editId && Cancel}\n

\n \n\n \n {loading ?

Loading…

:\n list.length === 0 ?

No custom strategies yet. Active strategies are evaluated on every scan alongside the built-in engine.

: (\n

\n {list.map((s) => (\n

\n \n {s.name}\n +{s.weight} {s.side}\n

\n {s.condition.indicator} {s.condition.operator} {s.condition.value}\n

\n toggle(s)}>{s.active ? \"Pause\" : \"Activate\"}\n edit(s)}>Edit\n remove(s.id)}>✕\n

\n ))}\n

\n )}\n \n

\n );\n}\n",[],[185,322,357,359],"b08a5c06-c15a-47e9-99a8-58e6d71cc1c7","Signals.tsx","019f68b9-9fa0-755f-881f-48ed1dd17798",["D",1784168423025],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useEffect, useState } from \"https://esm.sh/react@18.2.0\";\nimport { api, type Signal } from \"../api.ts\";\nimport { Card, SignalCard } from \"../components/ui.tsx\";\n\nconst FILTERS = [\"all\", \"BUY\", \"SELL\", \"open\", \"tp_hit\", \"sl_hit\"] as const;\nconst LABELS: Record = {\n all: \"All\", BUY: \"Buy\", SELL: \"Sell\", open: \"Open\", tp_hit: \"Hit TP\", sl_hit: \"Hit SL\",\n};\n\nexport function Signals() {\n const [signals, setSignals] = useState([]);\n const [filter, setFilter] = useState(\"all\");\n const [loading, setLoading] = useState(true);\n\n async function load() {\n setLoading(true);\n setSignals(await api.signals(100).catch(() => []));\n setLoading(false);\n }\n useEffect(() => { load(); }, []);\n\n async function setStatus(id: number, status: string) {\n await api.setSignalStatus(id, status);\n setSignals((prev) => prev.map((s) => s.id === id ? { ...s, status } : s));\n }\n\n const filtered = signals.filter((s) => {\n if (filter === \"all\") return true;\n if (filter === \"BUY\" || filter === \"SELL\") return s.direction === filter;\n return s.status === filter;\n });\n\n return (\n \n

\n {FILTERS.map((f) => (\n \n ))}\n {filtered.length} signals\n

\n {loading ? (\n

Loading…

\n ) : filtered.length === 0 ? (\n

No signals match this filter.

\n ) : (\n

\n {filtered.map((s) => setStatus(s.id, st)} />)}\n

\n )}\n \n );\n}\n",[],[185,322,357,366],"74d7fdbb-07ce-4949-809a-8bd534b2e3b6","SettingsTab.tsx","019f68b9-9fa0-755f-881f-47d37b642eb2",["D",1784168423025],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useEffect, useState } from \"https://esm.sh/react@18.2.0\";\nimport { api, type Settings } from \"../api.ts\";\nimport { Card, Btn, Input } from \"../components/ui.tsx\";\n\nexport function SettingsTab() {\n const [s, setS] = useState(null);\n const [apiKey, setApiKey] = useState(\"\");\n const [saved, setSaved] = useState(false);\n\n useEffect(() => { api.settings().then(setS).catch(() => {}); }, []);\n\n async function save() {\n if (!s) return;\n await api.updateSettings({\n apiKey: apiKey || undefined as any,\n riskPerTrade: s.riskPerTrade,\n riskReward: s.riskReward,\n scanIntervalMin: s.scanIntervalMin,\n });\n setApiKey(\"\");\n setSaved(true);\n setS(await api.settings());\n setTimeout(() => setSaved(false), 2500);\n }\n\n if (!s) return

Loading…

;\n\n return (\n

\n \n API Key {s.hasApiKey && ✓ saved}\n setApiKey(e.target.value)} className=\"mt-1\" />\n

\n Get a free key (800 calls/day) at{\" \"}\n twelvedata.com.\n Stored securely server-side and never returned to the browser.\n

\n \n\n \n Risk per trade (%)\n setS({ ...s, riskPerTrade: Number(e.target.value) })} className=\"mt-1 mb-3\" />\n Risk : Reward ratios (TP1 / TP2 / TP3)\n

\n {s.riskReward.map((r, i) => (\n {\n const rr = [...s.riskReward]; rr[i] = Number(e.target.value); setS({ ...s, riskReward: rr });\n }} />\n ))}\n

\n Auto-scan interval (minutes)\n setS({ ...s, scanIntervalMin: Number(e.target.value) })} className=\"mt-1\" />\n

Free Val Town tier enforces a 15-minute minimum on the cron schedule.

\n \n\n

\n Save Settings\n {saved && ✓ Saved}\n

\n );\n}\n",[],[185,322,357,373],"fb8d5a2d-76a5-473d-9ade-56f112eb0627","PocketOptionTab.tsx","429dbac0-80bd-11f1-9b05-1607ee4eb77e",27,["D",1784176203795],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useEffect, useState, useCallback } from \"https://esm.sh/react@18.2.0\";\nimport { api, type PocketOption, type POCredentials, type Execution, type ExecutionStats } from \"../api.ts\";\nimport { Card, Btn, Input } from \"../components/ui.tsx\";\n\nconst ASSETS = [\n \"XAUUSD_otc\", \"EURUSD_otc\", \"GBPUSD_otc\", \"AUDCAD_otc\",\n \"USDJPY_otc\", \"EURJPY_otc\", \"BTCUSD_otc\", \"ETHUSD_otc\",\n];\n\nconst STATUS_STYLES: Record = {\n pending: \"bg-blue-500/15 text-blue-400\",\n claimed: \"bg-amber-500/15 text-amber-400\",\n executing: \"bg-purple-500/15 text-purple-400\",\n win: \"bg-emerald-500/15 text-emerald-400\",\n loss: \"bg-red-500/15 text-red-400\",\n draw: \"bg-slate-500/15 text-slate-400\",\n error: \"bg-red-700/15 text-red-500\",\n skipped: \"bg-slate-600/20 text-slate-500\",\n};\n\nfunction Toggle({ label, checked, onChange }: { label: string; checked: boolean; onChange: (v: boolean) => void }) {\n return (\n \n {label}\n \n \n );\n}\n\nconst WORKER_URL = \"https://john3--019f68b99fa0755f881f9931b705fb3b.web.val.run\";\n\nexport function PocketOptionTab() {\n const [config, setConfig] = useState(null);\n const [creds, setCreds] = useState(null);\n const [executions, setExecutions] = useState([]);\n const [stats, setStats] = useState(null);\n const [saved, setSaved] = useState(false);\n const [credsSaved, setCredsSaved] = useState(false);\n\n // credential form fields\n const [session, setSession] = useState(\"\");\n const [uid, setUid] = useState(\"\");\n const [email, setEmail] = useState(\"\");\n const [password, setPassword] = useState(\"\");\n\n const load = useCallback(async () => {\n try {\n const [c, cr, e, s] = await Promise.all([\n api.pocketOption(),\n api.poCredentials(),\n api.executions(50),\n api.executionStats(),\n ]);\n setConfig(c);\n setCreds(cr);\n setExecutions(e);\n setStats(s);\n } catch {}\n }, []);\n\n useEffect(() => {\n load();\n const interval = setInterval(load, 5000);\n return () => clearInterval(interval);\n }, [load]);\n\n async function saveConfig() {\n if (!config) return;\n await api.updatePocketOption(config);\n setSaved(true);\n setTimeout(() => setSaved(false), 2500);\n }\n\n async function saveCreds() {\n const payload: Record = {};\n if (session.trim()) payload.session = session.trim();\n if (uid.trim()) payload.uid = uid.trim();\n if (email.trim()) payload.email = email.trim();\n if (password.trim()) payload.password = password.trim();\n if (Object.keys(payload).length === 0) return;\n await api.updatePOCredentials(payload);\n setSession(\"\"); setUid(\"\"); setEmail(\"\"); setPassword(\"\");\n setCredsSaved(true);\n setTimeout(() => setCredsSaved(false), 2500);\n await load();\n }\n\n if (!config || !creds) return

Loading…

;\n\n const winRate = stats && stats.total > 0\n ? ((stats.wins / (stats.wins + stats.losses + stats.draws)) * 100).toFixed(1)\n : \"—\";\n\n const credsReady = creds.hasSession && creds.hasUid;\n\n return (\n

\n {/* Stats Bar */}\n {stats && (\n

\n \n \n \n \n \n \n = 0 ? `+$${stats.profitLoss.toFixed(2)}` : `-$${Math.abs(stats.profitLoss).toFixed(2)}`} cls={stats.profitLoss >= 0 ? \"text-emerald-400\" : \"text-red-400\"} />\n

\n )}\n\n {/* Credentials + Config */}\n

\n {/* Credentials Card */}\n \n

\n \n \n {credsReady ? \"Credentials configured ✓\" : \"Credentials needed — enter below\"}\n \n

\n \n \n \n \n

\n\n

\n Session Token {creds.hasSession && ✓ saved}\n setSession(e.target.value)} className=\"mt-1\" />\n

From browser: DevTools → Application → Cookies → pocketoption.com → \"session\"

\n\n

\n User ID (UID) {creds.hasUid && ✓ saved}\n setUid(e.target.value)} className=\"mt-1\" />\n

Found in your Pocket Option profile or account settings

\n\n

Or use email/password (worker will auto-login to get session):

\n Email {creds.hasEmail && ✓ saved}\n setEmail(e.target.value)} className=\"mt-1\" />\n

\n Password {creds.hasPassword && ✓ saved}\n setPassword(e.target.value)} className=\"mt-1\" />\n

\n\n

\n Save Credentials\n {credsSaved && ✓ Saved}\n

\n\n

\n 🔒 Credentials stored server-side in encrypted SQLite. Never returned to the browser.\n Only the worker can access them via the /api/worker/config endpoint.\n

\n \n\n {/* Config Card */}\n \n

\n setConfig({ ...config, enabled: v })} />\n setConfig({ ...config, isDemo: v })} />\n\n

\n Trading asset\n \n

\n\n

\n Trade amount ($)\n setConfig({ ...config, tradeAmount: Number(e.target.value) })} className=\"mt-1\" />\n

\n Expiry (seconds)\n setConfig({ ...config, expirySeconds: Number(e.target.value) })} className=\"mt-1\" />\n

\n\n

\n Min confidence to execute\n {config.minConfidence}%\n

\n setConfig({ ...config, minConfidence: Number(e.target.value) })}\n className=\"w-full mt-2 accent-amber-500\" />\n

\n\n

\n Save Config\n {saved && ✓ Saved}\n

\n \n

\n\n {/* Complete Setup Guide */}\n \n

\n \n Go to Settings tab → paste your Twelve Data API key (free at twelvedata.com)\n \n \n Enter your Pocket Option session + UID above (or email/password)\n \n \n Toggle \"Enable auto-execution\" above and save config\n \n \n Install Python worker on your computer/VPS (see below)\n \n

\n\n

🖥️ Run the Worker (one command)

\n The worker fetches all config (credentials, asset, amount) from this dashboard automatically.\n No env vars needed — just set the URL.\n

# Install dependencies

pip install pocket-option-async aiohttp

\n
\n

# Set your dashboard URL

export VAL_TOWN_URL=\"{WORKER_URL}\"

\n
\n

# Download & run the worker

curl -o worker.py \"{WORKER_URL}/api/worker/download\"

python worker.py

\n\n

🍪 How to get your Session Token & UID

Open pocketoption.com and log in
Press F12 to open Developer Tools
Go to Application → Cookies → pocketoption.com
Find the cookie named session — copy its value
For UID: go to your profile page — the number in the URL or settings is your UID
Paste both in the credentials form above and click Save Credentials

\n Alternatively, just enter your email + password above. The worker will auto-login to get a fresh session.\n

\n\n

\n 0 ? \"bg-amber-400 animate-pulse\" : \"bg-slate-600\"}`}>\n \n {stats && stats.pending > 0\n ? `${stats.pending} signal(s) waiting for worker to come online`\n : \"No pending signals — worker will pick up new signals when they arrive\"}\n \n

\n \n\n {/* Execution History */}\n \n {executions.length === 0 ? (\n

\n No executions yet. Once the worker is running, trades will appear here in real-time.\n

\n ) : (\n

\n \n \n \n \n \n \n \n \n \n \n \n \n \n \n \n {executions.map((e) => (\n \n \n \n \n \n \n \n \n \n \n \n ))}\n \n

ID	Dir	Asset	Amount	Expiry	Entry	Status	P/L	Time
#{e.id}	\n \n {e.direction === \"BUY\" ? \"CALL ▲\" : \"PUT ▼\"}\n \n	{e.asset}	${e.amount}	{e.expirySeconds}s	{e.entryPrice ?? \"—\"}	\n \n {e.status}\n \n	= 0 ? \"text-emerald-400\" : \"text-red-400\"}`}>\n {e.profitLoss === null ? \"—\" : e.profitLoss >= 0 ? `+$${e.profitLoss.toFixed(2)}` : `-$${Math.abs(e.profitLoss).toFixed(2)}`}\n	{new Date(e.createdAt).toLocaleTimeString()}

\n )}\n \n

\n );\n}\n\nfunction StatBox({ label, value, cls = \"\" }: { label: string; value: string | number; cls?: string }) {\n return (\n

{label}

{value}

\n );\n}\n\nfunction CredChip({ label, ok }: { label: string; ok: boolean }) {\n return (\n \n {ok ? \"✓\" : \"○\"} {label}\n \n );\n}\n\nfunction SetupStep({ num, title, done, children }: { num: string; title: string; done: boolean; children: React.ReactNode }) {\n return (\n

\n \n {done ? \"✓\" : num}\n \n {title}\n

{children}

\n );\n}\n",[],[185,322,357,380],"201d7aea-09b9-496e-aaca-e20786868325","Dashboard.tsx","019f68b9-9fa0-755f-881f-4380d119367d",["D",1784168423025],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useEffect, useState } from \"https://esm.sh/react@18.2.0\";\nimport { api, type Candle, type Quote, type Settings, type Signal } from \"../api.ts\";\nimport { Card, Btn, SignalCard } from \"../components/ui.tsx\";\nimport { CandleChart } from \"../components/Chart.tsx\";\n\nconst TIMEFRAMES = [\"1min\", \"5min\", \"15min\", \"30min\", \"1h\", \"1day\"];\n\nexport function Dashboard() {\n const [tf, setTf] = useState(\"5min\");\n const [candles, setCandles] = useState([]);\n const [quote, setQuote] = useState(null);\n const [signals, setSignals] = useState([]);\n const [settings, setSettings] = useState(null);\n const [loading, setLoading] = useState(false);\n const [scanning, setScanning] = useState(false);\n const [msg, setMsg] = useState(null);\n\n async function loadChart(interval = tf) {\n setLoading(true);\n setMsg(null);\n try {\n const [c, q] = await Promise.all([api.candles(interval), api.quote().catch(() => null)]);\n setCandles(c.candles);\n if (q) setQuote(q);\n } catch (e) {\n setMsg(String((e as Error).message));\n } finally {\n setLoading(false);\n }\n }\n\n async function loadMeta() {\n setSignals(await api.signals(10).catch(() => []));\n setSettings(await api.settings().catch(() => null));\n }\n\n useEffect(() => { loadMeta(); }, []);\n useEffect(() => { loadChart(tf); }, [tf]);\n\n async function scanNow() {\n setScanning(true);\n setMsg(null);\n try {\n const r = await api.analyze();\n if (!r.ok) setMsg(\"Scan failed: \" + r.error);\n else setMsg(`New ${r.analysis.direction} signal @ ${r.analysis.confidence}%${r.telegramSent ? \" · sent to Telegram\" : \"\"}`);\n await loadMeta();\n await loadChart();\n } catch (e) {\n setMsg(String((e as Error).message));\n } finally {\n setScanning(false);\n }\n }\n\n async function toggleBot() {\n if (!settings) return;\n await api.updateSettings({ botRunning: !settings.botRunning });\n setSettings({ ...settings, botRunning: !settings.botRunning });\n }\n\n const up = (quote?.change ?? 0) >= 0;\n\n return (\n

\n {!settings?.hasApiKey && (\n

\n ⚠️ No Twelve Data API key set. Go to Settings and add your key to load live data.\n

\n )}\n\n

\n \n

XAU/USD

\n {quote ? quote.price.toFixed(2) : \"—\"}\n

\n {quote && (\n

\n {up ? \"▲\" : \"▼\"} {quote.change.toFixed(2)} ({quote.percentChange.toFixed(2)}%)\n

\n )}\n

\n \n {scanning ? \"Scanning…\" : \"🔍 Scan Now\"}\n \n \n {settings?.botRunning ? \"⏹ Stop Auto-Scan\" : \"▶ Start Auto-Scan\"}\n \n {settings && (\n

\n Auto-scan every {settings.scanIntervalMin} min · {settings.botRunning ? \"🟢 running\" : \"⚪ stopped\"}\n

\n )}\n

\n \n\n \n

\n {TIMEFRAMES.map((t) => (\n \n ))}\n

\n {loading ? (\n

Loading chart…

\n ) : candles.length ? (\n \n ) : (\n

No data yet

\n )}\n \n

\n\n {msg &&

{msg}

}\n\n \n {signals.length === 0 ? (\n

No signals yet. Click Scan Now to generate one.

\n ) : (\n

\n {signals.map((s) => )}\n

\n )}\n \n

\n );\n}\n",[],[185,322,357,388],"d487fc63-50a6-4c78-8674-002606ec1888",["D",1784168423025],[212,213,214,215,216,217],[185,322,357],"7098918f-ab65-4817-b92b-5c0a2cdb025f","ui.tsx","019f68b9-9fa0-755f-881f-3ae40100fbb2","019f68b9-9fa0-755f-881f-3f68d8c0fa8a",["D",1784168423025],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useState } from \"https://esm.sh/react@18.2.0\";\nimport type { Signal } from \"../api.ts\";\n\nexport function Card({ title, children, className = \"\" }: { title?: string; children: React.ReactNode; className?: string }) {\n return (\n

\n {title &&

{title}

}\n {children}\n

\n );\n}\n\nexport function Btn({ children, onClick, variant = \"primary\", disabled, className = \"\" }: {\n children: React.ReactNode; onClick?: () => void; variant?: \"primary\" | \"ghost\" | \"danger\" | \"success\"; disabled?: boolean; className?: string;\n}) {\n const styles: Record = {\n primary: \"bg-amber-500 hover:bg-amber-400 text-slate-950\",\n success: \"bg-emerald-600 hover:bg-emerald-500 text-white\",\n danger: \"bg-red-600 hover:bg-red-500 text-white\",\n ghost: \"bg-slate-800 hover:bg-slate-700 text-slate-200\",\n };\n return (\n \n );\n}\n\nexport function Input(props: React.InputHTMLAttributes) {\n return ;\n}\n\nexport function DirBadge({ dir }: { dir: string }) {\n const map: Record = {\n BUY: \"bg-emerald-500/15 text-emerald-400 border-emerald-500/30\",\n SELL: \"bg-red-500/15 text-red-400 border-red-500/30\",\n NEUTRAL: \"bg-slate-500/15 text-slate-400 border-slate-500/30\",\n };\n return {dir};\n}\n\nexport function StatusBadge({ status }: { status: string }) {\n const map: Record = {\n open: [\"Open\", \"bg-blue-500/15 text-blue-400\"],\n tp_hit: [\"Hit TP\", \"bg-emerald-500/15 text-emerald-400\"],\n sl_hit: [\"Hit SL\", \"bg-red-500/15 text-red-400\"],\n cancelled: [\"Cancelled\", \"bg-slate-600/20 text-slate-400\"],\n };\n const [label, cls] = map[status] ?? map.open;\n return {label};\n}\n\nexport function SignalCard({ s, onStatus }: { s: Signal; onStatus?: (status: string) => void }) {\n const [open, setOpen] = useState(false);\n const time = new Date(s.createdAt).toLocaleString();\n return (\n

\n \n {s.confidence}%\n \n

\n {s.telegramSent ? 📨 : null}\n {time}\n

\n \n \n \n \n \n

\n 🟢 {s.bullishScore} / 🔴 {s.bearishScore} · {s.session} · ATR {s.atr}\n

\n \n

\n {open && (\n

• {r}

\n {onStatus && s.status === \"open\" && (\n

\n onStatus(\"tp_hit\")}>Hit TP\n onStatus(\"sl_hit\")}>Hit SL\n onStatus(\"cancelled\")}>Cancel\n

\n )}\n

\n );\n}\n\nfunction Stat({ label, value, cls = \"\" }: { label: string; value: number; cls?: string }) {\n return (\n

{label}

{value}

\n );\n}\n",[],[185,322,406,399],"components","064918ec-d3f2-41d1-905b-1640b0b09e93","Chart.tsx","019f68b9-9fa0-755f-881f-34b1e00626ce",["D",1784168423025],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useEffect, useRef } from \"https://esm.sh/react@18.2.0\";\nimport type { Candle } from \"../api.ts\";\n\nexport function CandleChart({ candles }: { candles: Candle[] }) {\n const ref = useRef(null);\n\n useEffect(() => {\n const canvas = ref.current;\n if (!canvas || candles.length === 0) return;\n const dpr = window.devicePixelRatio || 1;\n const W = canvas.clientWidth;\n const H = canvas.clientHeight;\n canvas.width = W * dpr;\n canvas.height = H * dpr;\n const ctx = canvas.getContext(\"2d\")!;\n ctx.scale(dpr, dpr);\n ctx.clearRect(0, 0, W, H);\n\n const priceH = H * 0.78;\n const volH = H * 0.22;\n const padR = 56;\n const plotW = W - padR;\n\n const data = candles.slice(-120);\n const highs = data.map((c) => c.high);\n const lows = data.map((c) => c.low);\n const maxP = Math.max(...highs);\n const minP = Math.min(...lows);\n const range = maxP - minP || 1;\n const maxV = Math.max(...data.map((c) => c.volume), 1);\n\n const cw = plotW / data.length;\n const bodyW = Math.max(1, cw * 0.6);\n const yP = (p: number) => 6 + (priceH - 12) * (1 - (p - minP) / range);\n\n // grid + price axis\n ctx.font = \"10px ui-monospace, monospace\";\n ctx.textBaseline = \"middle\";\n for (let i = 0; i <= 4; i++) {\n const p = minP + (range * i) / 4;\n const y = yP(p);\n ctx.strokeStyle = \"rgba(148,163,184,0.12)\";\n ctx.beginPath();\n ctx.moveTo(0, y);\n ctx.lineTo(plotW, y);\n ctx.stroke();\n ctx.fillStyle = \"rgba(148,163,184,0.8)\";\n ctx.fillText(p.toFixed(2), plotW + 6, y);\n }\n\n // candles\n data.forEach((c, i) => {\n const x = i * cw + cw / 2;\n const up = c.close >= c.open;\n const color = up ? \"#22c55e\" : \"#ef4444\";\n ctx.strokeStyle = color;\n ctx.fillStyle = color;\n // wick\n ctx.beginPath();\n ctx.moveTo(x, yP(c.high));\n ctx.lineTo(x, yP(c.low));\n ctx.stroke();\n // body\n const yo = yP(c.open);\n const yc = yP(c.close);\n const top = Math.min(yo, yc);\n const h = Math.max(1, Math.abs(yc - yo));\n ctx.fillRect(x - bodyW / 2, top, bodyW, h);\n // volume\n const vh = (c.volume / maxV) * (volH - 6);\n ctx.globalAlpha = 0.5;\n ctx.fillRect(x - bodyW / 2, H - vh, bodyW, vh);\n ctx.globalAlpha = 1;\n });\n }, [candles]);\n\n return (\n \n );\n}\n",[],[185,322,406,408],"f5791cab-707b-4cb8-960e-6775420e7063",["D",1784168423025],[209,210],[185,322,406],"9ae374c3-cdb4-4e17-a291-749a029e1187",["D",1784168423025],[208,211,218,219,220,221],[185,322],["D",1784168423025],[207,222],[185],"d272d429-a0b7-4d5b-ade9-10b1958e5156","autoscan.ts","019f68b9-9fa0-755f-881f-2d656f36a944",["D",1784168423025],"interval","// Scheduled auto-scan. Runs every 15 min (free-tier minimum).\n// Only triggers analysis when the bot is marked \"running\" in settings.\nimport { getSettings } from \"../src/lib/db.ts\";\nimport { runAnalysisPipeline } from \"../src/lib/pipeline.ts\";\n\nexport default async function () {\n const settings = await getSettings();\n if (!settings.botRunning) {\n console.log(\"Auto-scan skipped: bot is stopped.\");\n return;\n }\n if (!settings.hasApiKey) {\n console.log(\"Auto-scan skipped: no API key.\");\n return;\n }\n const r = await runAnalysisPipeline();\n if (!r.ok) {\n console.error(\"Auto-scan failed:\", r.error);\n return;\n }\n console.log(\n `Auto-scan: ${r.analysis!.direction} @ ${r.analysis!.confidence}%` +\n (r.telegramSent ? \" (sent to Telegram)\" : r.telegramError ? ` (telegram: ${r.telegramError})` : \"\"),\n );\n}\n",[],[190,426],["D",1784168423025],[205],[190],["D",1784168423025],["D",1789525843977],{"_111":110,"_119":115},{"_111":110,"_112":113,"_114":115,"_19":62,"_116":117,"_118":31},{"_13":96,"_38":97,"_50":49,"_98":51,"_99":100,"_101":102,"_103":57,"_104":105,"_106":107,"_108":52,"_109":110},"ctx",{"_89":-5,"_141":474,"_475":476,"_477":478,"_479":31,"_480":31,"_481":31,"_482":66,"_483":-5,"_484":-7,"_485":-7,"_486":70,"_487":31,"_488":31,"_489":-5,"_490":31,"_491":31,"_492":31,"_493":-5},"ENV",{"_445":446,"_447":448,"_449":97,"_450":451,"_452":453,"_454":455,"_456":457,"_458":459,"_460":461,"_462":463,"_464":465,"_466":467,"_468":469,"_470":471,"_472":473},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v29