🪖 Operation Gold Master

\n \n\n`;\n return c.html(html);\n});\n\n// Source redirect\napp.get(\"/source\", (c) => c.redirect(parseVal().links.self.val));\n\nexport default app.fetch;\n","gold-master-bot",[134],"3fe95750-1829-4589-b436-345944fc0cb2","api.ts","d7bc3368-8539-11f1-a3b3-1607ee4eb77e",12,["D",1784661890418],"// ============================================================\n// OPERATION GOLD MASTER — Dashboard API Server\n// Hono-based REST API serving all dashboard data\n// ============================================================\n\nimport { Hono } from \"npm:hono\";\nimport { getSystemStatus, runSignalPipeline } from \"./lib/signal-pipeline.ts\";\nimport { initDB, getRecentSignals } from \"./lib/db.ts\";\nimport { ALL_BATTALIONS } from \"./lib/battalions.ts\";\n\nconst app = new Hono();\n\n// Full stack traces on errors\napp.onError((err) => Promise.reject(err));\n\n// ============================================================\n// ROOT — Health check\n// ============================================================\napp.get(\"/\", (c) => c.json({\n operation: \"Operation Gold Master\",\n status: \"Active\",\n version: \"1.0.0\",\n mission: \"XAU/USD Signal Generation\",\n endpoints: {\n dashboard: \"/dashboard\",\n summary: \"/api/v1/dashboard/summary\",\n theaters: \"/api/v1/dashboard/theaters\",\n battalions: \"/api/v1/dashboard/battalions\",\n signals: \"/api/v1/dashboard/signals\",\n risk: \"/api/v1/dashboard/risk\",\n regime: \"/api/v1/dashboard/regime\",\n scan: \"POST /api/v1/scan\",\n webhook: \"POST /webhook\",\n health: \"/health\",\n },\n}));\n\n// ============================================================\n// FULL DASHBOARD DATA (all-in-one for initial load)\n// ============================================================\napp.get(\"/api/v1/dashboard\", async (c) => {\n const status = await getSystemStatus();\n return c.json(status);\n});\n\n// ============================================================\n// SUMMARY METRICS\n// ============================================================\napp.get(\"/api/v1/dashboard/summary\", async (c) => {\n const status = await getSystemStatus();\n return c.json(status.summary);\n});\n\n// ============================================================\n// THEATER STATUS\n// ============================================================\napp.get(\"/api/v1/dashboard/theaters\", async (c) => {\n const status = await getSystemStatus();\n return c.json(status.theaters);\n});\n\n// ============================================================\n// BATTALION PERFORMANCE\n// ============================================================\napp.get(\"/api/v1/dashboard/battalions\", async (c) => {\n const status = await getSystemStatus();\n return c.json(status.battalions);\n});\n\n// ============================================================\n// RECENT SIGNALS\n// ============================================================\napp.get(\"/api/v1/dashboard/signals\", async (c) => {\n const limit = parseInt(c.req.query(\"limit\") || \"20\");\n const signals = await getRecentSignals(Math.min(limit, 100));\n return c.json(signals);\n});\n\n// ============================================================\n// RISK METRICS\n// ============================================================\napp.get(\"/api/v1/dashboard/risk\", async (c) => {\n const status = await getSystemStatus();\n return c.json(status.risk);\n});\n\n// ============================================================\n// MARKET REGIME\n// ============================================================\napp.get(\"/api/v1/dashboard/regime\", async (c) => {\n const status = await getSystemStatus();\n return c.json(status.regime);\n});\n\n// ============================================================\n// BATTALION REGISTRY\n// ============================================================\napp.get(\"/api/v1/battalions\", (c) => {\n return c.json(ALL_BATTALIONS.map(b => ({\n battalion_id: b.battalion_id,\n name: b.name,\n commander: b.commander,\n theater: b.theater,\n division: b.division,\n timeframes: b.timeframes,\n priority: b.priority,\n weight: b.weight,\n risk_profile: b.risk_profile,\n enabled: b.enabled,\n entry_rules: b.entry_rules,\n exit_rules: b.exit_rules,\n })));\n});\n\n// ============================================================\n// TRIGGER SCAN (Supreme Commander order)\n// ============================================================\napp.post(\"/api/v1/scan\", async (c) => {\n const timeframe = c.req.query(\"timeframe\") || \"4h\";\n const result = await runSignalPipeline(timeframe);\n return c.json(result);\n});\n\n// ============================================================\n// TRADINGVIEW WEBHOOK RECEIVER\n// ============================================================\napp.post(\"/webhook\", async (c) => {\n try {\n const body = await c.req.json();\n // Parse TradingView alert\n const alert = {\n battalion_id: body.battalion_id || body.strategy || \"EXTERNAL\",\n battalion_name: body.battalion_name || body.strategy || \"External Alert\",\n theater: body.theater || \"Technical\",\n division: body.division || \"External\",\n direction: (body.direction || body.action || \"LONG\").toUpperCase(),\n entry_price: parseFloat(body.entry || body.price || \"0\"),\n stop_loss: parseFloat(body.stop || body.stop_loss || \"0\"),\n target_1: parseFloat(body.target1 || body.target || \"0\"),\n target_2: body.target2 ? parseFloat(body.target2) : null,\n timeframe: body.timeframe || \"4h\",\n confluence_stars: parseInt(body.confluence || \"3\"),\n timestamp: new Date().toISOString(),\n };\n\n // Save to database\n const { insertSignal } = await import(\"./lib/db.ts\");\n await insertSignal({\n signal_id: `WEBHOOK-${Date.now().toString(36)}`,\n battalion_id: alert.battalion_id,\n battalion_name: alert.battalion_name,\n theater: alert.theater,\n division: alert.division,\n direction: alert.direction,\n entry_price: alert.entry_price,\n stop_loss: alert.stop_loss,\n target_1: alert.target_1,\n target_2: alert.target_2,\n target_3: null,\n timeframe: alert.timeframe,\n confluence_score: alert.confluence_stars * 20,\n confluence_stars: alert.confluence_stars,\n confidence: 0.7,\n risk_reward: 2.5,\n status: \"ACTIVE\",\n triggered_by: \"TRADINGVIEW_WEBHOOK\",\n confirmed_by: [alert.battalion_id],\n confirmation_details: [\"TradingView alert received\"],\n timestamp: alert.timestamp,\n chart_svg: null,\n pnl: null,\n exit_price: null,\n exit_time: null,\n exit_reason: null,\n });\n\n // Send Telegram alert\n const { sendTelegramAlert } = await import(\"./lib/telegram.ts\");\n await sendTelegramAlert(\n `🪖 WEBHOOK SIGNAL RECEIVED\\n Battalion: ${alert.battalion_name}\\n Direction: ${alert.direction}\\n Entry: $${alert.entry_price}\\n Stop: $${alert.stop_loss}\\n Target: $${alert.target_1}`\n );\n\n return c.json({ success: true, message: \"Webhook processed\", alert });\n } catch (err) {\n return c.json({ success: false, error: err.message }, 400);\n }\n});\n\n// ============================================================\n// HEALTH CHECK\n// ============================================================\napp.get(\"/health\", (c) => c.json({\n status: \"healthy\",\n timestamp: new Date().toISOString(),\n version: \"1.0.0\",\n battalions: ALL_BATTALIONS.length,\n}));\n\n// ============================================================\n// TELEGRAM BOT COMMANDS (webhook-based)\n// ============================================================\napp.post(\"/telegram\", async (c) => {\n try {\n const update = await c.req.json();\n const msg = update.message;\n if (!msg || !msg.text) return c.json({ ok: true });\n\n const token = Deno.env.get(\"TELEGRAM_BOT_TOKEN\");\n const chatId = msg.chat.id.toString();\n const text = msg.text;\n let response = \"\";\n\n if (text === \"/start\") {\n response = \"🪖 OPERATION GOLD MASTER BOT\\n\\nWelcome, Commander! XAU/USD Signal Bot active.\\n\\nCommands:\\n/status - System status\\n/signals - Recent signals\\n/battalions - Active battalions\\n/regime - Market regime\\n/risk - Risk exposure\\n/help - All commands\";\n } else if (text === \"/status\") {\n const status = await getSystemStatus();\n response = `🪖 SYSTEM STATUS\\n\\nSignals (24h): ${status.summary.total_signals_24h}\\nActive: ${status.summary.active_signals}\\nWin Rate: ${status.summary.win_rate_24h.toFixed(1)}%\\nP&L: $${status.summary.total_pnl_today.toFixed(2)}\\nBattalions: ${status.summary.active_battalions}/${status.summary.total_battalions}\\nGold: $${status.summary.gold_price.toFixed(2)}\\nRegime: ${status.regime.regime}`;\n } else if (text === \"/signals\") {\n const signals = await getRecentSignals(10);\n if (signals.length === 0) {\n response = \"📡 No signals yet. Run /api/v1/scan to generate.\";\n } else {\n response = \"📡 RECENT SIGNALS\\n\\n\" + signals.slice(0, 5).map((s: any) =>\n `${s.direction === \"LONG\" ? \"📈\" : \"📉\"} ${s.battalion_name}\\n Entry: $${s.entry_price?.toFixed(2)} | SL: $${s.stop_loss?.toFixed(2)}\\n Stars: ${\"★\".repeat(s.confluence_stars)} | Status: ${s.status}`\n ).join(\"\\n\\n\");\n }\n } else if (text === \"/battalions\") {\n const status = await getSystemStatus();\n response = \"🎖️ ACTIVE BATTALIONS\\n\\n\" + status.theaters.map((t: any) =>\n `${t.theater}: ${t.active_battalions} active | ${t.signals_today} signals today`\n ).join(\"\\n\");\n } else if (text === \"/regime\") {\n const status = await getSystemStatus();\n const r = status.regime;\n response = `🌐 MARKET REGIME\\n\\nRegime: ${r.regime}\\nConfidence: ${(r.confidence * 100).toFixed(0)}%\\nVolatility: ${r.volatility_state}\\nTrend: ${(r.trend_strength * 100).toFixed(0)}%\\nRecommendation: ${r.recommendation}`;\n } else if (text === \"/risk\") {\n const status = await getSystemStatus();\n const r = status.risk;\n response = `🛡️ RISK COMMAND\\n\\nExposure: $${r.total_exposure?.toFixed(2)}\\nDaily DD: $${r.daily_drawdown?.toFixed(2)}\\nMonthly DD: $${r.monthly_drawdown?.toFixed(2)}\\nVaR 95%: $${r.var_95?.toFixed(2)}\\nMax Position: $${r.max_position_size?.toFixed(2)}`;\n } else if (text === \"/help\") {\n response = \"🪖 COMMANDS\\n\\n/start - Welcome\\n/status - System status\\n/signals - Recent signals\\n/battalions - Active battalions\\n/theaters - Theater status\\n/regime - Market regime\\n/risk - Risk exposure\\n/performance - Performance\\n/help - This message\";\n } else if (text === \"/scan\") {\n response = \"🪖 Scanning all battalions... (check /signals in a moment)\";\n // Trigger scan in background\n runSignalPipeline(\"4h\").catch(() => {});\n } else {\n response = \"Unknown command. Send /help for available commands.\";\n }\n\n if (token) {\n await fetch(`https://api.telegram.org/bot${token}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: chatId, text: response }),\n });\n }\n\n return c.json({ ok: true });\n } catch (err) {\n return c.json({ ok: false, error: err.message }, 500);\n }\n});\n\nexport default app.fetch;\n",[143],"636e21a4-b7ef-4be4-babf-606b293f025c","README.md","4591cd4e-853a-11f1-84d2-1607ee4eb77e",15,["D",1784662074686],"# 🪖 OPERATION GOLD MASTER\n\n**Autonomous XAU/USD Signal Bot with Military Chain-of-Command Structure**\n\n## Architecture\n\n```\nSupreme Headquarters\n├── Supreme Commander (signal-pipeline.ts) — Global orchestration\n├── Capital Allocator (risk.ts) — Position sizing\n├── Regime Detector (regime.ts) — Market regime classification\n└── Catastrophic Override (risk.ts) — Drawdown lockdown\n\nTheater Command Layer (4 Generals)\n├── General Technical (10 battalions)\n├── General Fundamental (5 battalions)\n├── General Sentiment (5 battalions)\n└── General Timing (5 battalions)\n\nSpecial Operations Layer (5 battalions)\n├── SMC Order Block, FVG, Risk Parity\n├── Regime Adaptive, Volatility Breakout\n\nConnector & Data Layer\n├── Data Provider (Twelve Data API + fallback)\n├── Telegram Bot API\n├── TradingView Webhook Receiver\n└── SQLite Database (signals, battalions, regime history)\n```\n\n## Signal Pipeline Flow\n\n```\nReal Price Data → Indicator Calculation → Battalion Evaluation\n→ Confluence Scoring → Risk Veto Check → Chart SVG Generation\n→ Telegram Alert → SQLite Persistence → Dashboard Update\n```\n\n## 30 Active Battalions\n\n| Theater | Division | Battalions |\n|---------|----------|------------|\n| Technical | Moving Averages | SMA Golden Cross, EMA Triple, Hull MA |\n| Technical | Trend Following | ADX Trend Rider |\n| Technical | Breakouts | Bollinger Breakout |\n| Technical | Reversals | RSI Divergence |\n| Technical | Price Action | Pin Bar |\n| Technical | Momentum | MACD, Stochastic |\n| Technical | Multi-TF | Multi-TF Confluence |\n| Fundamental | Interest Rates | DXY Inverse, Real Yields |\n| Fundamental | Macro | Safe Haven, Geopolitical |\n| Fundamental | Supply Demand | Central Bank |\n| Sentiment | Positioning | COT, Retail Contrarian |\n| Sentiment | Market Sentiment | Fear/Greed, News NLP, Social Buzz |\n| Timing | Session Trading | London Breakout, NY Momentum |\n| Timing | Day Trading | Scalper |\n| Timing | Swing Trading | Swing Trader, Weekly Position |\n| Special Ops | Hybrid SMC | Order Block, FVG |\n| Special Ops | Risk Mgmt | Risk Parity |\n| Special Ops | Regime | Regime Adaptive |\n| Special Ops | Mathematical | Volatility Breakout |\n\n## Confluence Scoring\n\n| Stars | Score | Action |\n|-------|-------|--------|\n| 5 ★ | 90-100% | Supreme Commander auto-approves |\n| 4 ★ | 75-89% | High confidence, standard size |\n| 3 ★ | 60-74% | Moderate confidence, reduced size |\n| 2 ★ | 40-59% | Low confidence, micro size |\n| 1 ★ | <40% | Rejected by Risk Command |\n\n## Risk Management\n\n- **Level 1 (Battalion):** Trade risk > 2% → Veto\n- **Level 2 (Division):** 3 consecutive losses → Stand down 24h\n- **Level 3 (Theater):** Theater drawdown > 5% → Reduce 50%\n- **Level 4 (Supreme):** Total drawdown > 5% → Lockdown / > 10% → Emergency stop\n\n## Live Endpoints\n\n| Endpoint | Description |\n|----------|-------------|\n| `/dashboard` | Military command center dashboard (React) |\n| `/api/v1/dashboard` | Full dashboard data (JSON) |\n| `/api/v1/dashboard/summary` | Summary metrics |\n| `/api/v1/dashboard/theaters` | Theater status |\n| `/api/v1/dashboard/battalions` | Battalion performance |\n| `/api/v1/dashboard/signals` | Recent signals |\n| `/api/v1/dashboard/risk` | Risk metrics |\n| `/api/v1/dashboard/regime` | Market regime |\n| `POST /api/v1/scan` | Trigger signal scan |\n| `POST /webhook` | TradingView webhook receiver |\n| `POST /telegram` | Telegram bot webhook |\n| `/health` | Health check |\n\n## Environment Variables\n\n| Variable | Description | Required |\n|----------|-------------|----------|\n| `TWELVE_DATA_API_KEY` | Twelve Data API key for real XAU/USD data | Recommended |\n| `TELEGRAM_BOT_TOKEN` | Telegram bot token for signal alerts | Optional |\n| `TELEGRAM_CHAT_ID` | Telegram channel/chat ID | Optional |\n\n👉 Add TWELVE_DATA_API_KEY here: https://www.val.town/x/peterweru/operation-gold-master/environment-variables?key=TWELVE_DATA_API_KEY\n\n👉 Add TELEGRAM_BOT_TOKEN here: https://www.val.town/x/peterweru/operation-gold-master/environment-variables?key=TELEGRAM_BOT_TOKEN\n\n👉 Add TELEGRAM_CHAT_ID here: https://www.val.town/x/peterweru/operation-gold-master/environment-variables?key=TELEGRAM_CHAT_ID\n\n## Automated Scanning\n\nThe `scan.ts` interval runs every hour, executing the full signal pipeline:\n1. Fetches real XAU/USD candles from Twelve Data API\n2. Computes 18 technical indicators (SMA, EMA, RSI, ADX, ATR, MACD, Bollinger, Stochastic, OBV, HMA, CCI)\n3. Evaluates all 30 battalions against real indicator conditions\n4. Calculates cross-battalion confluence scores\n5. Applies Risk Command veto checks\n6. Generates annotated SVG charts\n7. Sends Telegram alerts\n8. Persists everything to SQLite\n\n## Tech Stack\n\n- **Runtime:** Deno (Val Town)\n- **Framework:** Hono (HTTP API + Dashboard)\n- **Database:** SQLite (Turso/libSQL)\n- **Data:** Twelve Data API (XAU/USD OHLC)\n- **Alerts:** Telegram Bot API\n- **Charts:** SVG (candlestick + annotations)\n- **Frontend:** React 18 (via esm.sh CDN)\n",[150],"c4967658-47f3-4722-889a-87ffee9deaee","lib","08a0816f-5c61-4b2e-8e09-03549503c2d9",["D",1784661571011],"directory",[157],"pulls","branches","forks","envVars",{"_169":42,"_171":42},"connections",{"_169":42,"_170":42},"count","unfilledCount","emptyCount",{"_18":156,"_20":157,"_118":158,"_120":-5,"_121":71,"_122":125,"_123":38,"_22":297,"_68":42,"_126":160,"_128":-5,"_130":26,"_131":-5,"_190":298,"_89":299},{"_18":290,"_20":291,"_118":292,"_120":158,"_121":71,"_122":137,"_123":38,"_22":293,"_68":42,"_126":207,"_128":294,"_130":26,"_131":-5,"_190":295,"_89":296},{"_18":282,"_20":283,"_118":284,"_120":158,"_121":71,"_122":285,"_123":38,"_22":286,"_68":42,"_126":207,"_128":287,"_130":26,"_131":-5,"_190":288,"_89":289},{"_18":274,"_20":275,"_118":276,"_120":158,"_121":71,"_122":277,"_123":38,"_22":278,"_68":42,"_126":207,"_128":279,"_130":26,"_131":-5,"_190":280,"_89":281},{"_18":266,"_20":267,"_118":268,"_120":158,"_121":71,"_122":269,"_123":38,"_22":270,"_68":125,"_126":207,"_128":271,"_130":26,"_131":-5,"_190":272,"_89":273},{"_18":258,"_20":259,"_118":260,"_120":158,"_121":71,"_122":261,"_123":38,"_22":262,"_68":42,"_126":207,"_128":263,"_130":26,"_131":-5,"_190":264,"_89":265},{"_18":251,"_20":252,"_118":253,"_120":158,"_121":71,"_122":125,"_123":38,"_22":254,"_68":42,"_126":207,"_128":255,"_130":26,"_131":-5,"_190":256,"_89":257},{"_18":243,"_20":244,"_118":245,"_120":158,"_121":71,"_122":246,"_123":38,"_22":247,"_68":42,"_126":207,"_128":248,"_130":26,"_131":-5,"_190":249,"_89":250},{"_18":235,"_20":236,"_118":237,"_120":158,"_121":71,"_122":238,"_123":38,"_22":239,"_68":42,"_126":207,"_128":240,"_130":26,"_131":-5,"_190":241,"_89":242},{"_18":227,"_20":228,"_118":229,"_120":158,"_121":71,"_122":230,"_123":38,"_22":231,"_68":42,"_126":207,"_128":232,"_130":26,"_131":-5,"_190":233,"_89":234},{"_18":219,"_20":220,"_118":221,"_120":158,"_121":71,"_122":222,"_123":38,"_22":223,"_68":42,"_126":207,"_128":224,"_130":26,"_131":-5,"_190":225,"_89":226},{"_18":211,"_20":212,"_118":213,"_120":158,"_121":71,"_122":214,"_123":38,"_22":215,"_68":125,"_126":207,"_128":216,"_130":26,"_131":-5,"_190":217,"_89":218},{"_18":202,"_20":203,"_118":204,"_120":158,"_121":71,"_122":205,"_123":38,"_22":206,"_68":42,"_126":207,"_128":208,"_130":26,"_131":-5,"_190":209,"_89":210},{"_18":149,"_20":150,"_118":151,"_120":-5,"_121":71,"_122":152,"_123":38,"_22":199,"_68":42,"_126":100,"_128":154,"_130":26,"_131":-5,"_190":200,"_89":201},{"_18":142,"_20":143,"_118":144,"_120":-5,"_121":71,"_122":145,"_123":38,"_22":196,"_68":42,"_126":138,"_128":147,"_130":26,"_131":-5,"_190":197,"_89":198},{"_18":133,"_20":134,"_118":36,"_120":-5,"_121":71,"_122":135,"_123":38,"_22":193,"_68":137,"_126":138,"_128":139,"_130":26,"_131":140,"_190":194,"_89":195},{"_18":116,"_20":117,"_118":119,"_120":-5,"_121":71,"_122":69,"_123":38,"_22":189,"_68":125,"_126":127,"_128":129,"_130":26,"_131":-5,"_190":191,"_89":192},["D",1784662571436],"children",[],[117],["D",1784662560697],[],[134],["D",1784661890418],[],[143],["D",1784662074686],[],[150],"16b38dbc-1039-4869-9c44-64b3b55442e0","types.ts","82fd1d4c-8539-11f1-b90a-1607ee4eb77e",4,["D",1784661748152],"script","// ============================================================\n// OPERATION GOLD MASTER — Core Type Definitions\n// ============================================================\n\nexport interface Candle {\n timestamp: string;\n open: number;\n high: number;\n low: number;\n close: number;\n volume: number;\n}\n\nexport type Direction = \"LONG\" | \"SHORT\";\nexport type TheaterName = \"Technical\" | \"Fundamental\" | \"Sentiment\" | \"Timing\";\nexport type SignalStatus = \"ACTIVE\" | \"CLOSED\" | \"PENDING\" | \"EXPIRED\";\nexport type BattalionStatus = \"ACTIVE\" | \"STAND_DOWN\" | \"DISABLED\";\n\nexport interface BattalionConfig {\n battalion_id: string;\n name: string;\n commander: string;\n theater: TheaterName;\n division: string;\n timeframes: string[];\n priority: number;\n weight: number;\n risk_profile: \"conservative\" | \"moderate\" | \"aggressive\";\n max_concurrent: number;\n cooldown_hours: number;\n enabled: boolean;\n parameters: Record;\n entry_rules: string[];\n exit_rules: string[];\n}\n\nexport interface Signal {\n signal_id: string;\n battalion_id: string;\n battalion_name: string;\n theater: TheaterName;\n division: string;\n direction: Direction;\n entry_price: number;\n stop_loss: number;\n target_1: number;\n target_2: number | null;\n target_3: number | null;\n timeframe: string;\n confluence_score: number;\n confluence_stars: number;\n confidence: number;\n risk_reward: number;\n status: SignalStatus;\n triggered_by: string;\n confirmed_by: string[];\n confirmation_details: string[];\n timestamp: string;\n chart_svg: string | null;\n pnl: number | null;\n exit_price: number | null;\n exit_time: string | null;\n exit_reason: string | null;\n}\n\nexport interface TheaterStatus {\n theater: TheaterName;\n signals_today: number;\n win_rate: number;\n pnl_today: number;\n active_battalions: number;\n status: string;\n top_performer: string;\n}\n\nexport interface RiskMetrics {\n total_exposure: number;\n daily_drawdown: number;\n monthly_drawdown: number;\n current_risk_percent: number;\n max_position_size: number;\n var_95: number;\n expected_shortfall: number;\n daily_loss_limit: number;\n monthly_loss_limit: number;\n}\n\nexport interface MarketRegime {\n regime: string;\n confidence: number;\n indicators: Record;\n volatility_state: \"LOW\" | \"MEDIUM\" | \"HIGH\";\n trend_strength: number;\n recommendation: string;\n timestamp: string;\n}\n\nexport interface DashboardSummary {\n total_signals_24h: number;\n active_signals: number;\n total_pnl_today: number;\n win_rate_24h: number;\n confluence_5_star: number;\n confluence_4_star: number;\n active_battalions: number;\n total_battalions: number;\n system_status: string;\n last_update: string;\n gold_price: number;\n gold_change: number;\n}\n\nexport interface BattalionPerformance {\n battalion_id: string;\n name: string;\n theater: TheaterName;\n division: string;\n status: BattalionStatus;\n signals_today: number;\n total_signals: number;\n win_rate: number;\n pnl_today: number;\n total_pnl: number;\n weight: number;\n last_signal: string | null;\n}\n\nexport interface PositionSize {\n base_size: number;\n confluence_multiplier: number;\n volatility_multiplier: number;\n regime_multiplier: number;\n final_size: number;\n risk_amount: number;\n}\n\nexport interface IndicatorSnapshot {\n sma50: number;\n sma200: number;\n ema20: number;\n ema50: number;\n rsi: number;\n adx: number;\n plusDI: number;\n minusDI: number;\n atr: number;\n macd: number;\n macdSignal: number;\n macdHistogram: number;\n bbUpper: number;\n bbMiddle: number;\n bbLower: number;\n stochK: number;\n stochD: number;\n obv: number;\n}\n",[],[157,203],"12c3f5c2-f4eb-4625-9331-c76f7b40ec16","telegram.ts","a17bd402-8539-11f1-9c0b-1607ee4eb77e",19,["D",1784662429790],"// ============================================================\n// OPERATION GOLD MASTER — Telegram Signal Sender\n// Real Telegram Bot API integration for signal alerts\n// Reads credentials from settings (blob) → env var fallback\n// ============================================================\n\nimport { Signal, BattalionConfig } from \"./types.ts\";\nimport { ConfluenceResult } from \"./confluence.ts\";\nimport { getSettings } from \"./settings.ts\";\n\n/** Format signal as Telegram message per the plan's message format. */\nexport function formatSignalMessage(signal: Signal, battalion: BattalionConfig, confluence: ConfluenceResult): string {\n const stars = \"★\".repeat(confluence.stars) + \"☆\".repeat(5 - confluence.stars);\n const dirEmoji = signal.direction === \"LONG\" ? \"📈\" : \"📉\";\n const details = signal.confirmation_details.map(d =>\n d.includes(\"near overbought\") || d.includes(\"near oversold\") ? `⚠️ ${d}` : `✅ ${d}`\n ).join(\"\\n\");\n return `🪖 OPERATION GOLD MASTER — SIGNAL ALERT\n\n📊 Battalion: ${battalion.division} — ${battalion.name}\n🎯 Asset: XAU/USD\n⏱️ Timeframe: ${signal.timeframe.toUpperCase()}\n${dirEmoji} Direction: ${signal.direction}\n\n━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━\n🎖️ CONFLUENCE SCORE: ${confluence.stars}/5 Stars ${stars}\n━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━\n\n${details}\n\n━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━\n📍 ENTRY: $${signal.entry_price.toFixed(2)}\n🛑 STOP LOSS: $${signal.stop_loss.toFixed(2)}\n🎯 TARGET 1: $${signal.target_1.toFixed(2)} (1:2 R:R)\n${signal.target_2 ? `🎯 TARGET 2: $${signal.target_2.toFixed(2)} (1:3 R:R)\\n` : \"\"}💰 RISK/REWARD: 1:${signal.risk_reward.toFixed(1)}\n\n━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━\n🏛️ CHAIN OF COMMAND:\nSupreme Commander → General ${battalion.theater} → ${battalion.division} Commander\n→ ${battalion.battalion_id} ${battalion.commander} → Squad Alpha\n\n🪖 Operation Gold Master Bot`;\n}\n\n/** Get Telegram credentials from settings → env fallback */\nasync function getTelegramConfig(): Promise<{ token: string; chatId: string }> {\n const settings = await getSettings();\n return {\n token: settings.telegramBotToken || Deno.env.get(\"TELEGRAM_BOT_TOKEN\") || \"\",\n chatId: settings.telegramChatId || Deno.env.get(\"TELEGRAM_CHAT_ID\") || \"\",\n };\n}\n\n/** Send signal alert to Telegram channel via Bot API. */\nexport async function sendTelegramSignal(signal: Signal, battalion: BattalionConfig, confluence: ConfluenceResult): Promise {\n const { token, chatId } = await getTelegramConfig();\n if (!token || !chatId) { console.log(\"[Telegram] No bot token or chat ID configured — skipping send\"); return false; }\n\n // Check min confluence from settings\n const settings = await getSettings();\n if (confluence.stars < settings.minConfluenceStars) { console.log(`[Telegram] Signal ${signal.signal_id} below min confluence (${confluence.stars}/${settings.minConfluenceStars}) — skipping`); return false; }\n\n const message = formatSignalMessage(signal, battalion, confluence);\n try {\n const resp = await fetch(`https://api.telegram.org/bot${token}/sendMessage`, {\n method: \"POST\", headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: chatId, text: message, parse_mode: \"HTML\", disable_web_page_preview: true }),\n });\n const data = await resp.json();\n if (data.ok) { console.log(`[Telegram] Signal ${signal.signal_id} sent successfully`); return true; }\n console.error(\"[Telegram] API error:\", data.description); return false;\n } catch (err) { console.error(\"[Telegram] Send failed:\", err); return false; }\n}\n\n/** Send a text-only alert (for system status, risk alerts, etc.) */\nexport async function sendTelegramAlert(text: string): Promise {\n const { token, chatId } = await getTelegramConfig();\n if (!token || !chatId) return false;\n try {\n const resp = await fetch(`https://api.telegram.org/bot${token}/sendMessage`, {\n method: \"POST\", headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: chatId, text, parse_mode: \"HTML\" }),\n });\n const data = await resp.json(); return data.ok === true;\n } catch { return false; }\n}\n\n/** Send daily performance report to Telegram */\nexport async function sendDailyReport(stats: { totalSignals: number; winRate: number; pnl: number; activeBattalions: number; topPerformer: string; regime: string; }): Promise {\n return sendTelegramAlert(`🪖 OPERATION GOLD MASTER — DAILY REPORT\n━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━\n📊 Total Signals: ${stats.totalSignals}\n🏆 Win Rate: ${stats.winRate.toFixed(1)}%\n💰 P&L: $${stats.pnl.toFixed(2)}\n🎖️ Active Battalions: ${stats.activeBattalions}\n📈 Top Performer: ${stats.topPerformer}\n🌐 Market Regime: ${stats.regime}\n━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━\n🪖 Supreme Commander — Mission Status: ACTIVE`);\n}\n",[],[157,212],"7514a372-4282-489a-a439-ea139cdd46de","signal-pipeline.ts","c11e9fb0-8539-11f1-8ec9-1607ee4eb77e",11,["D",1784661852438],"// ============================================================\n// OPERATION GOLD MASTER — Signal Pipeline (Supreme Commander)\n// End-to-end signal flow: Data → Indicators → Battalions →\n// Confluence → Risk → Chart → Telegram → Database\n// ============================================================\n\nimport { Signal, BattalionConfig, TheaterName } from \"./types.ts\";\nimport { fetchCandles, fetchLivePrice } from \"./data-provider.ts\";\nimport { computeIndicators, evaluateBattalion, getEnabledBattalions, BattalionSignal, ALL_BATTALIONS } from \"./battalions.ts\";\nimport { calculateConfluence, ConfluenceResult } from \"./confluence.ts\";\nimport { calculatePositionSize, checkRiskVeto } from \"./risk.ts\";\nimport { detectRegime } from \"./regime.ts\";\nimport { renderChartSVG } from \"./chart.ts\";\nimport { sendTelegramSignal } from \"./telegram.ts\";\nimport { insertSignal, saveRegime, getLatestRegime, closeExpiredSignals, initDB } from \"./db.ts\";\nimport { ATR, lastVal } from \"./indicators.ts\";\n\nexport interface ScanResult {\n signalsGenerated: number;\n signalsRejected: number;\n signals: Signal[];\n regime: any;\n price: number;\n errors: string[];\n}\n\n/**\n * Supreme Commander's main signal pipeline.\n * Executes the full chain-of-command signal generation flow.\n */\nexport async function runSignalPipeline(timeframe: string = \"4h\"): Promise {\n await initDB();\n const errors: string[] = [];\n const generatedSignals: Signal[] = [];\n let rejectedCount = 0;\n\n try {\n // Step 1: Fetch real price data\n const candles = await fetchCandles(timeframe, 200);\n if (candles.length < 50) {\n return { signalsGenerated: 0, signalsRejected: 0, signals: [], regime: null, price: 0, errors: [\"Insufficient price data\"] };\n }\n\n // Step 2: Compute indicators\n const indicators = computeIndicators(candles);\n const price = candles[candles.length - 1].close;\n\n // Step 3: Close expired signals\n await closeExpiredSignals(price);\n\n // Step 4: Detect regime\n const regime = detectRegime(candles);\n await saveRegime(regime);\n\n // Step 5: Evaluate all battalions\n const enabledBattalions = getEnabledBattalions();\n const allBattalionSignals: { battalion: BattalionConfig; signal: BattalionSignal }[] = [];\n\n for (const battalion of enabledBattalions) {\n try {\n const sig = evaluateBattalion(battalion, candles, indicators);\n if (sig) {\n allBattalionSignals.push({ battalion, signal: sig });\n }\n } catch (err) {\n errors.push(`Battalion ${battalion.battalion_id} error: ${err.message}`);\n }\n }\n\n if (allBattalionSignals.length === 0) {\n return { signalsGenerated: 0, signalsRejected: 0, signals: [], regime, price, errors };\n }\n\n // Step 6: For each battalion signal, calculate confluence\n for (const { battalion, signal } of allBattalionSignals) {\n const confluence = calculateConfluence(battalion, signal, allBattalionSignals);\n\n // Skip if confluence too low (1 star = rejected by Risk Command)\n if (confluence.stars < 2) {\n rejectedCount++;\n continue;\n }\n\n // Step 7: Calculate position size\n const atrArr = ATR(candles, 14);\n const atrAvg = atrArr.slice(-20).reduce((s, v) => s + v, 0) / Math.min(20, atrArr.length);\n const positionSize = calculatePositionSize(\n signal.entry, signal.stop, confluence,\n indicators.atr, atrAvg, regime,\n );\n\n // Step 8: Risk veto check\n const veto = await checkRiskVeto(\n battalion.battalion_id, battalion.theater,\n signal.direction, positionSize, confluence,\n );\n\n if (veto.vetoed && veto.level === \"SUPREME\") {\n // Supreme level veto — skip entirely\n errors.push(`VETO [${veto.level}]: ${veto.reason}`);\n rejectedCount++;\n continue;\n }\n\n if (veto.vetoed && veto.level === \"DIVISION\") {\n rejectedCount++;\n continue;\n }\n\n // Step 9: Build Signal object\n const signalId = `SIG-${new Date().toISOString().slice(0, 10).replace(/-/g, \"\")}-${battalion.battalion_id}-${Date.now().toString(36)}`;\n\n const fullSignal: Signal = {\n signal_id: signalId,\n battalion_id: battalion.battalion_id,\n battalion_name: battalion.name,\n theater: battalion.theater,\n division: battalion.division,\n direction: signal.direction,\n entry_price: signal.entry,\n stop_loss: signal.stop,\n target_1: signal.target1,\n target_2: signal.target2,\n target_3: null,\n timeframe,\n confluence_score: confluence.score,\n confluence_stars: confluence.stars,\n confidence: signal.confidence * (confluence.stars / 5),\n risk_reward: signal.riskReward,\n status: \"ACTIVE\",\n triggered_by: battalion.battalion_id,\n confirmed_by: confluence.confirmed_by,\n confirmation_details: confluence.confirmation_details,\n timestamp: new Date().toISOString(),\n chart_svg: null,\n pnl: null,\n exit_price: null,\n exit_time: null,\n exit_reason: null,\n };\n\n // Step 10: Generate chart SVG\n try {\n fullSignal.chart_svg = renderChartSVG(candles, fullSignal, confluence, battalion.name);\n } catch (err) {\n errors.push(`Chart render error: ${err.message}`);\n }\n\n // Step 11: Save to database\n await insertSignal(fullSignal);\n\n // Step 12: Send Telegram alert\n await sendTelegramSignal(fullSignal, battalion, confluence);\n\n generatedSignals.push(fullSignal);\n }\n\n return {\n signalsGenerated: generatedSignals.length,\n signalsRejected: rejectedCount,\n signals: generatedSignals,\n regime,\n price,\n errors,\n };\n } catch (err) {\n errors.push(`Pipeline error: ${err.message}`);\n return { signalsGenerated: 0, signalsRejected: 0, signals: [], regime: null, price: 0, errors };\n }\n}\n\n/**\n * Get system status for the dashboard\n */\nexport async function getSystemStatus() {\n await initDB();\n const { getSignals24h, getActiveSignals, getBattalionStats, getLatestRegime } = await import(\"./db.ts\");\n const { getRiskMetrics } = await import(\"./risk.ts\");\n const { fetchLivePrice } = await import(\"./data-provider.ts\");\n\n const signals24h = await getSignals24h();\n const activeSignals = await getActiveSignals();\n const battalionStats = await getBattalionStats();\n const regime = await getLatestRegime();\n const risk = await getRiskMetrics();\n const livePrice = await fetchLivePrice();\n\n // Calculate summary\n const closedSignals = signals24h.filter((s: any) => s.status === \"CLOSED\" && s.pnl !== null);\n const wins = closedSignals.filter((s: any) => s.pnl > 0);\n const winRate = closedSignals.length > 0 ? (wins.length / closedSignals.length) * 100 : 0;\n const totalPnl = closedSignals.reduce((sum: number, s: any) => sum + (s.pnl || 0), 0);\n const fiveStar = signals24h.filter((s: any) => s.confluence_stars === 5).length;\n const fourStar = signals24h.filter((s: any) => s.confluence_stars === 4).length;\n const activeBattalions = battalionStats.filter((b: any) => b.enabled === 1 || b.enabled === true).length;\n\n // Theater status\n const theaters: TheaterName[] = [\"Technical\", \"Fundamental\", \"Sentiment\", \"Timing\"];\n const theaterStatus = theaters.map(t => {\n const tSignals = signals24h.filter((s: any) => s.theater === t);\n const tClosed = tSignals.filter((s: any) => s.status === \"CLOSED\" && s.pnl !== null);\n const tWins = tClosed.filter((s: any) => s.pnl > 0);\n const tPnl = tClosed.reduce((sum: number, s: any) => sum + (s.pnl || 0), 0);\n const tBattalionCount = ALL_BATTALIONS.filter(b => b.theater === t && b.enabled).length;\n const topPerformer = battalionStats.find((b: any) => b.theater === t);\n\n return {\n theater: t,\n signals_today: tSignals.length,\n win_rate: tClosed.length > 0 ? (tWins.length / tClosed.length) * 100 : 0,\n pnl_today: tPnl,\n active_battalions: tBattalionCount,\n status: tBattalionCount > 0 ? \"ACTIVE\" : \"INACTIVE\",\n top_performer: topPerformer ? topPerformer.name : \"N/A\",\n };\n });\n\n // Battalion performance\n const battalionPerformance = ALL_BATTALIONS.map(b => {\n const stats = battalionStats.find((s: any) => s.battalion_id === b.battalion_id);\n const bSignals24h = signals24h.filter((s: any) => s.battalion_id === b.battalion_id);\n const bClosed = bSignals24h.filter((s: any) => s.status === \"CLOSED\" && s.pnl !== null);\n const bPnl = bClosed.reduce((sum: number, s: any) => sum + (s.pnl || 0), 0);\n\n return {\n battalion_id: b.battalion_id,\n name: b.name,\n theater: b.theater,\n division: b.division,\n status: b.enabled ? \"ACTIVE\" : \"DISABLED\",\n signals_today: bSignals24h.length,\n total_signals: stats ? stats.total_signals : 0,\n win_rate: stats ? stats.win_rate : 0,\n pnl_today: bPnl,\n total_pnl: stats ? stats.total_pnl : 0,\n weight: b.weight,\n last_signal: stats ? stats.last_signal : null,\n };\n });\n\n return {\n summary: {\n total_signals_24h: signals24h.length,\n active_signals: activeSignals.length,\n total_pnl_today: totalPnl,\n win_rate_24h: winRate,\n confluence_5_star: fiveStar,\n confluence_4_star: fourStar,\n active_battalions: ALL_BATTALIONS.filter(b => b.enabled).length,\n total_battalions: ALL_BATTALIONS.length,\n system_status: \"OPERATIONAL\",\n last_update: new Date().toISOString(),\n gold_price: livePrice.price,\n gold_change: livePrice.change,\n },\n theaters: theaterStatus,\n battalions: battalionPerformance,\n signals: signals24h.slice(0, 20),\n risk,\n regime: regime || {\n regime: \"UNKNOWN\",\n confidence: 0,\n indicators: {},\n volatility_state: \"LOW\",\n trend_strength: 0,\n recommendation: \"NEUTRAL\",\n timestamp: new Date().toISOString(),\n },\n };\n}\n",[],[157,220],"de9479c3-8204-418a-8587-2c59565a043c","settings.ts","094ab07a-853b-11f1-bf18-1607ee4eb77e",17,["D",1784662403051],"// ============================================================\n// OPERATION GOLD MASTER — Settings Manager\n// Stores API keys and config in blob storage (persisted)\n// Reads: blob first → env var fallback\n// ============================================================\n\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nexport interface AppSettings {\n // Data Providers\n activeProvider: \"twelvedata\" | \"alphavantage\" | \"metalsdev\" | \"auto\";\n twelveDataApiKey: string;\n alphaVantageApiKey: string;\n\n // Telegram\n telegramBotToken: string;\n telegramChatId: string;\n\n // Trading config\n accountBalance: number;\n riskPerTrade: number; // percent\n dailyLossLimit: number; // percent\n monthlyLossLimit: number; // percent\n\n // Scan config\n scanTimeframe: string;\n autoScanEnabled: boolean;\n\n // Alert config\n minConfluenceStars: number; // minimum stars to send alert\n alertOnSignal: boolean;\n alertOnClose: boolean;\n}\n\nconst DEFAULT_SETTINGS: AppSettings = {\n activeProvider: \"auto\",\n twelveDataApiKey: \"\",\n alphaVantageApiKey: \"\",\n telegramBotToken: \"\",\n telegramChatId: \"\",\n accountBalance: 10000,\n riskPerTrade: 2,\n dailyLossLimit: 3,\n monthlyLossLimit: 5,\n scanTimeframe: \"4h\",\n autoScanEnabled: true,\n minConfluenceStars: 3,\n alertOnSignal: true,\n alertOnClose: false,\n};\n\nconst BLOB_KEY = \"ogm_settings\";\n\n/** Load settings from blob storage, merging with defaults and env var fallbacks */\nexport async function getSettings(): Promise {\n try {\n const stored = await blob.getJSON(BLOB_KEY) as Partial | undefined;\n return {\n ...DEFAULT_SETTINGS,\n ...stored,\n // Env var fallbacks — if blob is empty, check env\n twelveDataApiKey: stored?.twelveDataApiKey || Deno.env.get(\"TWELVE_DATA_API_KEY\") || \"\",\n alphaVantageApiKey: stored?.alphaVantageApiKey || Deno.env.get(\"ALPHAVANTAGE_API_KEY\") || \"\",\n telegramBotToken: stored?.telegramBotToken || Deno.env.get(\"TELEGRAM_BOT_TOKEN\") || \"\",\n telegramChatId: stored?.telegramChatId || Deno.env.get(\"TELEGRAM_CHAT_ID\") || \"\",\n };\n } catch {\n // Blob doesn't exist yet — use defaults + env\n return {\n ...DEFAULT_SETTINGS,\n twelveDataApiKey: Deno.env.get(\"TWELVE_DATA_API_KEY\") || \"\",\n alphaVantageApiKey: Deno.env.get(\"ALPHAVANTAGE_API_KEY\") || \"\",\n telegramBotToken: Deno.env.get(\"TELEGRAM_BOT_TOKEN\") || \"\",\n telegramChatId: Deno.env.get(\"TELEGRAM_CHAT_ID\") || \"\",\n };\n }\n}\n\n/** Save settings to blob storage */\nexport async function saveSettings(settings: Partial): Promise {\n const current = await getSettings();\n const merged = { ...current, ...settings };\n await blob.setJSON(BLOB_KEY, merged);\n return merged;\n}\n\n/** Get only the non-secret settings for frontend display (masks API keys) */\nexport async function getSettingsPublic(): Promise> {\n const s = await getSettings();\n const mask = (key: string) => {\n if (!key) return \"\";\n if (key.length <= 8) return key.slice(0, 2) + \"***\";\n return key.slice(0, 4) + \"***\" + key.slice(-4);\n };\n\n return {\n activeProvider: s.activeProvider,\n twelveDataApiKey: mask(s.twelveDataApiKey),\n twelveDataApiKeySet: !!s.twelveDataApiKey,\n alphaVantageApiKey: mask(s.alphaVantageApiKey),\n alphaVantageApiKeySet: !!s.alphaVantageApiKey,\n telegramBotToken: mask(s.telegramBotToken),\n telegramBotTokenSet: !!s.telegramBotToken,\n telegramChatId: s.telegramChatId ? mask(s.telegramChatId) : \"\",\n telegramChatIdSet: !!s.telegramChatId,\n accountBalance: s.accountBalance,\n riskPerTrade: s.riskPerTrade,\n dailyLossLimit: s.dailyLossLimit,\n monthlyLossLimit: s.monthlyLossLimit,\n scanTimeframe: s.scanTimeframe,\n autoScanEnabled: s.autoScanEnabled,\n minConfluenceStars: s.minConfluenceStars,\n alertOnSignal: s.alertOnSignal,\n alertOnClose: s.alertOnClose,\n };\n}\n\n/** Test a data provider connection */\nexport async function testProvider(provider: string, apiKey: string): Promise<{ success: boolean; message: string; price?: number }> {\n try {\n if (provider === \"twelvedata\") {\n if (!apiKey) return { success: false, message: \"No API key provided\" };\n const resp = await fetch(`https://api.twelvedata.com/price?symbol=XAU/USD&apikey=${apiKey}`);\n const data = await resp.json();\n if (data.price) return { success: true, message: \"Connection OK\", price: parseFloat(data.price) };\n return { success: false, message: data.message || \"API error\" };\n }\n\n if (provider === \"alphavantage\") {\n if (!apiKey) return { success: false, message: \"No API key provided\" };\n const resp = await fetch(`https://www.alphavantage.co/query?function=GLOBAL_QUOTE&symbol=OANDA:XAU_USD&apikey=${apiKey}`);\n const data = await resp.json();\n if (data[\"Global Quote\"]?.[\"05. price\"]) {\n return { success: true, message: \"Connection OK\", price: parseFloat(data[\"Global Quote\"][\"05. price\"]) };\n }\n return { success: false, message: data.Note || data.Information || \"No data returned\" };\n }\n\n if (provider === \"metalsdev\") {\n const resp = await fetch(\"https://api.metals.dev/v1/latest?api_key=demo¤cy=USD&unit=toz\");\n const data = await resp.json();\n if (data.metals?.gold) return { success: true, message: \"Connection OK (free demo)\", price: data.metals.gold };\n return { success: false, message: \"No data returned\" };\n }\n\n return { success: false, message: \"Unknown provider\" };\n } catch (err) {\n return { success: false, message: \"Connection error: \" + err.message };\n }\n}\n\n/** Test Telegram bot connection */\nexport async function testTelegram(botToken: string, chatId: string): Promise<{ success: boolean; message: string }> {\n try {\n if (!botToken) return { success: false, message: \"No bot token provided\" };\n if (!chatId) return { success: false, message: \"No chat ID provided\" };\n\n // Test by sending a test message\n const resp = 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: \"🪖 OPERATION GOLD MASTER — Connection test successful!\\n\\nTelegram bot is now connected and ready to receive signal alerts.\",\n }),\n });\n const data = await resp.json();\n if (data.ok) return { success: true, message: \"Test message sent successfully!\" };\n return { success: false, message: data.description || \"Telegram API error\" };\n } catch (err) {\n return { success: false, message: \"Connection error: \" + err.message };\n }\n}\n",[],[157,228],"d451a717-460a-4aa0-8944-e5ced53e69cf","risk.ts","a160e700-8539-11f1-8fdd-1607ee4eb77e",6,["D",1784661799209],"// ============================================================\n// OPERATION GOLD MASTER — Risk Command\n// General Risk's authority: position sizing, veto powers, exposure tracking\n// ============================================================\n\nimport { PositionSize, RiskMetrics, MarketRegime } from \"./types.ts\";\nimport { ConfluenceResult } from \"./confluence.ts\";\nimport { getActiveSignals, getSignals24h } from \"./db.ts\";\n\nconst ACCOUNT_BALANCE = 10000; // $10,000 starting balance\nconst RISK_PER_TRADE = 0.02; // 2% risk per trade\nconst DAILY_LOSS_LIMIT = 0.03; // 3% daily loss limit\nconst MONTHLY_LOSS_LIMIT = 0.05; // 5% monthly loss limit\n\n/**\n * Dynamic Position Sizing\n * Base Size = (Account Balance × Risk%) / (Stop Distance × Pip Value)\n * Adjustments: Confluence × Volatility × Regime\n */\nexport function calculatePositionSize(\n entryPrice: number,\n stopPrice: number,\n confluence: ConfluenceResult,\n atr: number,\n atrAvg: number,\n regime: MarketRegime | null,\n): PositionSize {\n const stopDistance = Math.abs(entryPrice - stopPrice);\n const baseSize = (ACCOUNT_BALANCE * RISK_PER_TRADE) / stopDistance;\n\n // Confluence adjustment\n let confluenceMult = 0.5;\n if (confluence.stars === 5) confluenceMult = 1.25;\n else if (confluence.stars === 4) confluenceMult = 1.0;\n else if (confluence.stars === 3) confluenceMult = 0.75;\n else if (confluence.stars === 2) confluenceMult = 0.5;\n\n // Volatility adjustment\n let volMult = 1.0;\n if (atrAvg > 0) {\n const atrRatio = atr / atrAvg;\n if (atrRatio > 1.5) volMult = 0.5; // High volatility — reduce\n else if (atrRatio < 0.5) volMult = 1.5; // Low volatility — increase\n }\n\n // Regime adjustment\n let regimeMult = 1.0;\n if (regime) {\n switch (regime.regime) {\n case \"HIGH_INFLATION\": regimeMult = 1.2; break;\n case \"RECESSION\": regimeMult = 1.1; break;\n case \"RATE_HIKING\": regimeMult = 0.7; break;\n case \"QT\": regimeMult = 0.6; break;\n case \"TRENDING_UP\": regimeMult = 1.05; break;\n case \"TRENDING_DOWN\": regimeMult = 1.05; break;\n case \"VOLATILE\": regimeMult = 0.5; break;\n case \"RANGING\": regimeMult = 0.8; break;\n }\n }\n\n const finalSize = baseSize * confluenceMult * volMult * regimeMult;\n const riskAmount = finalSize * stopDistance;\n\n return {\n base_size: baseSize,\n confluence_multiplier: confluenceMult,\n volatility_multiplier: volMult,\n regime_multiplier: regimeMult,\n final_size: Math.max(0, finalSize),\n risk_amount: riskAmount,\n };\n}\n\nexport interface VetoResult {\n vetoed: boolean;\n reason: string | null;\n level: \"BATTALION\" | \"DIVISION\" | \"THEATER\" | \"SUPREME\" | null;\n adjustedSize?: number;\n}\n\n/**\n * General Risk's Veto Engine\n * Checks all 4 levels of veto authority\n */\nexport async function checkRiskVeto(\n battalionId: string,\n theater: string,\n direction: string,\n positionSize: PositionSize,\n confluence: ConfluenceResult,\n): Promise {\n // Level 1: Battalion level\n const riskPercent = (positionSize.risk_amount / ACCOUNT_BALANCE) * 100;\n if (riskPercent > 2) {\n return {\n vetoed: true,\n reason: `Trade risk ${riskPercent.toFixed(2)}% exceeds 2% limit — reducing to 2%`,\n level: \"BATTALION\",\n adjustedSize: positionSize.final_size * (2 / riskPercent),\n };\n }\n\n // Level 2: Division level — check consecutive losses\n const signals24h = await getSignals24h();\n const divisionSignals = signals24h.filter((s: any) =>\n s.battalion_id.startsWith(battalionId.split(\"-\")[0])\n );\n const recentLosses = divisionSignals.filter((s: any) => s.pnl !== null && s.pnl < 0).slice(0, 3);\n if (recentLosses.length >= 3) {\n return {\n vetoed: true,\n reason: `3 consecutive losses in division — stand down for 24h`,\n level: \"DIVISION\",\n };\n }\n\n // Level 3: Theater drawdown check\n const theaterLosses = signals24h.filter((s: any) =>\n s.theater === theater && s.pnl !== null && s.pnl < 0\n );\n const theaterDrawdown = theaterLosses.reduce((sum: number, s: any) => sum + Math.abs(s.pnl), 0);\n if (theaterDrawdown > ACCOUNT_BALANCE * 0.05) {\n return {\n vetoed: true,\n reason: `Theater ${theater} drawdown > 5% — reduce all positions 50%`,\n level: \"THEATER\",\n adjustedSize: positionSize.final_size * 0.5,\n };\n }\n\n // Level 4: Supreme level — total account drawdown\n const allLosses = signals24h.filter((s: any) => s.pnl !== null && s.pnl < 0);\n const totalDrawdown = allLosses.reduce((sum: number, s: any) => sum + Math.abs(s.pnl), 0);\n const drawdownPercent = (totalDrawdown / ACCOUNT_BALANCE) * 100;\n\n if (drawdownPercent > 10) {\n return {\n vetoed: true,\n reason: `EMERGENCY: Total drawdown ${drawdownPercent.toFixed(1)}% > 10% — Supreme Commander lockdown`,\n level: \"SUPREME\",\n };\n }\n\n if (drawdownPercent > 5) {\n return {\n vetoed: true,\n reason: `Total drawdown ${drawdownPercent.toFixed(1)}% > 5% — lockdown mode, close 80%`,\n level: \"SUPREME\",\n adjustedSize: positionSize.final_size * 0.2,\n };\n }\n\n return { vetoed: false, reason: null, level: null };\n}\n\n/**\n * Get current risk metrics for dashboard\n */\nexport async function getRiskMetrics(): Promise {\n const activeSignals = await getActiveSignals();\n const signals24h = await getSignals24h();\n\n const totalExposure = activeSignals.reduce((sum: number, s: any) => {\n const risk = Math.abs(s.entry_price - s.stop_loss);\n return sum + risk;\n }, 0);\n\n const todayStart = new Date(new Date().setUTCHours(0, 0, 0, 0)).toISOString();\n const todayLosses = signals24h.filter((s: any) =>\n s.pnl !== null && s.pnl < 0 && s.exit_time >= todayStart\n );\n const dailyDrawdown = todayLosses.reduce((sum: number, s: any) => sum + Math.abs(s.pnl), 0);\n\n const monthStart = new Date(new Date().getFullYear(), new Date().getMonth(), 1).toISOString();\n const monthLosses = signals24h.filter((s: any) =>\n s.pnl !== null && s.pnl < 0 && s.exit_time >= monthStart\n );\n const monthlyDrawdown = monthLosses.reduce((sum: number, s: any) => sum + Math.abs(s.pnl), 0);\n\n // VaR 95% — simplified using daily P&L distribution\n const dailyPnls = signals24h.filter((s: any) => s.pnl !== null).map((s: any) => s.pnl);\n let var95 = 0;\n if (dailyPnls.length > 5) {\n const sorted = [...dailyPnls].sort((a, b) => a - b);\n const idx = Math.floor(sorted.length * 0.05);\n var95 = sorted[idx] || 0;\n }\n\n return {\n total_exposure: totalExposure,\n daily_drawdown: -dailyDrawdown,\n monthly_drawdown: -monthlyDrawdown,\n current_risk_percent: (totalExposure / ACCOUNT_BALANCE) * 100,\n max_position_size: ACCOUNT_BALANCE * 0.02,\n var_95: var95,\n expected_shortfall: var95 * 1.2,\n daily_loss_limit: ACCOUNT_BALANCE * DAILY_LOSS_LIMIT,\n monthly_loss_limit: ACCOUNT_BALANCE * MONTHLY_LOSS_LIMIT,\n };\n}\n",[],[157,236],"e4ebbcdf-8828-4b94-bde1-c3cd4a904790","regime.ts","a167a518-8539-11f1-9d98-1607ee4eb77e",7,["D",1784661799210],"// ============================================================\n// OPERATION GOLD MASTER — Regime Detector\n// General Regime (Command 13) — Market regime classification\n// ============================================================\n\nimport { Candle, MarketRegime } from \"./types.ts\";\nimport { ADX, ATR, BollingerBands, RSI, SMA, EMA, lastVal } from \"./indicators.ts\";\n\n/**\n * Detect current market regime from real price data.\n * Uses ADX for trend strength, Bollinger Band width for volatility,\n * and SMA alignment for trend direction.\n */\nexport function detectRegime(candles: Candle[]): MarketRegime {\n if (candles.length < 50) {\n return {\n regime: \"UNKNOWN\",\n confidence: 0,\n indicators: {},\n volatility_state: \"LOW\",\n trend_strength: 0,\n recommendation: \"NEUTRAL\",\n timestamp: new Date().toISOString(),\n };\n }\n\n const closes = candles.map(c => c.close);\n const price = closes[closes.length - 1];\n\n // Compute indicators\n const sma50 = SMA(closes, 50), sma200 = SMA(closes, 200);\n const ema20 = EMA(closes, 20), ema50 = EMA(closes, 50);\n const { adx, plusDI, minusDI } = ADX(candles, 14);\n const atr = ATR(candles, 14);\n const { upper, middle, lower } = BollingerBands(closes, 20, 2);\n const rsi = RSI(closes, 14);\n\n const adxVal = lastVal(adx);\n const atrVal = lastVal(atr);\n const sma50Val = lastVal(sma50);\n const sma200Val = lastVal(sma200);\n const ema20Val = lastVal(ema20);\n const ema50Val = lastVal(ema50);\n const rsiVal = lastVal(rsi);\n const bbUpper = lastVal(upper), bbLower = lastVal(lower), bbMiddle = lastVal(middle);\n\n // Volatility state from ATR relative to price\n const atrPercent = (atrVal / price) * 100;\n let volState: \"LOW\" | \"MEDIUM\" | \"HIGH\" = \"LOW\";\n if (atrPercent > 1.5) volState = \"HIGH\";\n else if (atrPercent > 0.8) volState = \"MEDIUM\";\n\n // Bollinger Band width as volatility confirmation\n const bbWidth = (bbUpper - bbLower) / bbMiddle;\n\n // Trend strength (0-1)\n const trendStrength = Math.min(1, adxVal / 50);\n\n // Determine regime\n let regime = \"RANGING\";\n let confidence = 0.5;\n let recommendation = \"NEUTRAL\";\n\n const isAboveSMA50 = price > sma50Val;\n const isAboveSMA200 = !isNaN(sma200Val) && price > sma200Val;\n const sma50Above200 = !isNaN(sma200Val) && sma50Val > sma200Val;\n const plusDIDominant = lastVal(plusDI) > lastVal(minusDI);\n\n if (adxVal > 25) {\n // Trending\n if (isAboveSMA50 && isAboveSMA200 && sma50Above200 && plusDIDominant) {\n regime = \"TRENDING_UP\";\n confidence = 0.6 + (adxVal - 25) / 100;\n recommendation = \"BULLISH_BIAS\";\n } else if (!isAboveSMA50 && !isAboveSMA200 && !sma50Above200 && !plusDIDominant) {\n regime = \"TRENDING_DOWN\";\n confidence = 0.6 + (adxVal - 25) / 100;\n recommendation = \"BEARISH_BIAS\";\n } else {\n regime = \"TRANSITIONAL\";\n confidence = 0.55;\n recommendation = \"CAUTIOUS\";\n }\n } else if (adxVal < 18) {\n // Ranging\n regime = \"RANGING\";\n confidence = 0.5 + (18 - adxVal) / 50;\n recommendation = \"MEAN_REVERSION\";\n } else {\n // Transitional\n regime = \"TRANSITIONAL\";\n confidence = 0.45;\n recommendation = \"WAIT_FOR_CONFIRMATION\";\n }\n\n // Override for high volatility\n if (volState === \"HIGH\" && atrPercent > 2) {\n regime = \"VOLATILE\";\n confidence = 0.7;\n recommendation = \"REDUCE_SIZE\";\n }\n\n // Check for breakout regime\n const bbSqueeze = bbWidth < 0.02;\n if (bbSqueeze && adxVal > 20) {\n regime = \"BREAKOUT\";\n confidence = 0.65;\n recommendation = \"BREAKOUT_IMMINENT\";\n }\n\n return {\n regime,\n confidence: Math.min(0.95, confidence),\n indicators: {\n \"MA_50_vs_200\": sma50Above200 ? \"Above\" : \"Below\",\n \"ADX\": parseFloat(adxVal.toFixed(1)),\n \"RSI\": parseFloat(rsiVal.toFixed(1)),\n \"ATR_%\": parseFloat(atrPercent.toFixed(2)),\n \"BB_Width\": parseFloat(bbWidth.toFixed(4)),\n \"+DI\": parseFloat(lastVal(plusDI).toFixed(1)),\n \"-DI\": parseFloat(lastVal(minusDI).toFixed(1)),\n \"Price_vs_SMA50\": isAboveSMA50 ? \"Above\" : \"Below\",\n \"Price_vs_SMA200\": isAboveSMA200 ? \"Above\" : \"Below\",\n },\n volatility_state: volState,\n trend_strength: parseFloat(trendStrength.toFixed(2)),\n recommendation,\n timestamp: new Date().toISOString(),\n };\n}\n",[],[157,244],"bf030e93-3ae5-467f-9b66-dd966a281dcc","indicators.ts","195db108-8539-11f1-b90a-1607ee4eb77e",["D",1784661571011],"// ============================================================\n// OPERATION GOLD MASTER — Technical Indicator Engine\n// Real mathematical indicator calculations (no simulation)\n// ============================================================\n\nimport { Candle } from \"./types.ts\";\n\n/** Simple Moving Average */\nexport function SMA(values: number[], period: number): number[] {\n const result: number[] = [];\n for (let i = 0; i < values.length; i++) {\n if (i < period - 1) { result.push(NaN); continue; }\n let sum = 0;\n for (let j = 0; j < period; j++) sum += values[i - j];\n result.push(sum / period);\n }\n return result;\n}\n\n/** Exponential Moving Average */\nexport function EMA(values: number[], period: number): number[] {\n const result: number[] = [];\n const k = 2 / (period + 1);\n let ema = values[0] ?? 0;\n for (let i = 0; i < values.length; i++) {\n ema = i === 0 ? values[0] : values[i] * k + ema * (1 - k);\n result.push(ema);\n }\n return result;\n}\n\n/** Relative Strength Index */\nexport function RSI(values: number[], period = 14): number[] {\n const result: number[] = [];\n let avgGain = 0, avgLoss = 0;\n for (let i = 0; i < values.length; i++) {\n if (i === 0) { result.push(50); continue; }\n const ch = values[i] - values[i - 1];\n const gain = ch > 0 ? ch : 0;\n const loss = ch < 0 ? -ch : 0;\n if (i <= period) {\n avgGain += gain; avgLoss += loss;\n if (i === period) {\n avgGain /= period; avgLoss /= period;\n result.push(avgLoss === 0 ? 100 : 100 - 100 / (1 + avgGain / avgLoss));\n } else result.push(50);\n } else {\n avgGain = (avgGain * (period - 1) + gain) / period;\n avgLoss = (avgLoss * (period - 1) + loss) / period;\n result.push(avgLoss === 0 ? 100 : 100 - 100 / (1 + avgGain / avgLoss));\n }\n }\n return result;\n}\n\n/** Average True Range */\nexport function ATR(candles: Candle[], period = 14): number[] {\n const result: number[] = [];\n for (let i = 0; i < candles.length; i++) {\n if (i === 0) { result.push(candles[0].high - candles[0].low); continue; }\n const tr = Math.max(\n candles[i].high - candles[i].low,\n Math.abs(candles[i].high - candles[i - 1].close),\n Math.abs(candles[i].low - candles[i - 1].close),\n );\n if (i < period) {\n const avg = result.slice(0, i + 1).reduce((a, b) => a + b, 0) / (i + 1);\n result.push(avg);\n } else result.push((result[i - 1] * (period - 1) + tr) / period);\n }\n return result;\n}\n\n/** Average Directional Index (Wilder's method) */\nexport function ADX(candles: Candle[], period = 14): { adx: number[]; plusDI: number[]; minusDI: number[] } {\n const plusDM: number[] = [], minusDM: number[] = [], tr: number[] = [];\n for (let i = 0; i < candles.length; i++) {\n if (i === 0) { plusDM.push(0); minusDM.push(0); tr.push(candles[0].high - candles[0].low); continue; }\n const up = candles[i].high - candles[i - 1].high;\n const down = candles[i - 1].low - candles[i].low;\n plusDM.push(up > down && up > 0 ? up : 0);\n minusDM.push(down > up && down > 0 ? down : 0);\n tr.push(Math.max(candles[i].high - candles[i].low, Math.abs(candles[i].high - candles[i - 1].close), Math.abs(candles[i].low - candles[i - 1].close)));\n }\n const sTR: number[] = [], sPDM: number[] = [], sMDM: number[] = [];\n for (let i = 0; i < candles.length; i++) {\n if (i < period) { sTR.push(tr[i]); sPDM.push(plusDM[i]); sMDM.push(minusDM[i]); }\n else if (i === period) {\n sTR.push(tr.slice(0, period).reduce((a, b) => a + b, 0));\n sPDM.push(plusDM.slice(0, period).reduce((a, b) => a + b, 0));\n sMDM.push(minusDM.slice(0, period).reduce((a, b) => a + b, 0));\n } else {\n sTR.push(sTR[i - 1] - sTR[i - 1] / period + tr[i]);\n sPDM.push(sPDM[i - 1] - sPDM[i - 1] / period + plusDM[i]);\n sMDM.push(sMDM[i - 1] - sMDM[i - 1] / period + minusDM[i]);\n }\n }\n const plusDI: number[] = [], minusDI: number[] = [], dx: number[] = [];\n for (let i = 0; i < candles.length; i++) {\n if (sTR[i] === 0) { plusDI.push(0); minusDI.push(0); dx.push(0); continue; }\n const pdi = (sPDM[i] / sTR[i]) * 100, mdi = (sMDM[i] / sTR[i]) * 100;\n plusDI.push(pdi); minusDI.push(mdi);\n const s = pdi + mdi;\n dx.push(s === 0 ? 0 : (Math.abs(pdi - mdi) / s) * 100);\n }\n const adx: number[] = [];\n for (let i = 0; i < candles.length; i++) {\n if (i < 2 * period) adx.push(dx.slice(0, i + 1).reduce((a, b) => a + b, 0) / (i + 1));\n else adx.push((adx[i - 1] * (period - 1) + dx[i]) / period);\n }\n return { adx, plusDI, minusDI };\n}\n\n/** MACD */\nexport function MACD(values: number[], fast = 12, slow = 26, signal = 9) {\n const fastEMA = EMA(values, fast), slowEMA = EMA(values, slow);\n const macd = values.map((_, i) => fastEMA[i] - slowEMA[i]);\n const sig = EMA(macd, signal);\n return { macd, signal: sig, histogram: macd.map((m, i) => m - sig[i]) };\n}\n\n/** Bollinger Bands */\nexport function BollingerBands(values: number[], period = 20, stdDev = 2) {\n const middle = SMA(values, period);\n const upper: number[] = [], lower: number[] = [];\n for (let i = 0; i < values.length; i++) {\n if (i < period - 1) { upper.push(NaN); lower.push(NaN); continue; }\n let sum = 0;\n for (let j = 0; j < period; j++) sum += (values[i - j] - middle[i]) ** 2;\n const sd = Math.sqrt(sum / period);\n upper.push(middle[i] + stdDev * sd);\n lower.push(middle[i] - stdDev * sd);\n }\n return { upper, middle, lower };\n}\n\n/** Stochastic Oscillator */\nexport function Stochastic(candles: Candle[], kPeriod = 14, dPeriod = 3) {\n const k: number[] = [];\n for (let i = 0; i < candles.length; i++) {\n if (i < kPeriod - 1) { k.push(50); continue; }\n let hh = -Infinity, ll = Infinity;\n for (let j = 0; j < kPeriod; j++) { hh = Math.max(hh, candles[i - j].high); ll = Math.min(ll, candles[i - j].low); }\n k.push(hh === ll ? 50 : ((candles[i].close - ll) / (hh - ll)) * 100);\n }\n return { k, d: SMA(k, dPeriod) };\n}\n\n/** On Balance Volume */\nexport function OBV(candles: Candle[]): number[] {\n const r = [0];\n for (let i = 1; i < candles.length; i++) {\n if (candles[i].close > candles[i - 1].close) r.push(r[i - 1] + candles[i].volume);\n else if (candles[i].close < candles[i - 1].close) r.push(r[i - 1] - candles[i].volume);\n else r.push(r[i - 1]);\n }\n return r;\n}\n\n/** Hull Moving Average */\nexport function HMA(values: number[], period: number): number[] {\n const half = Math.floor(period / 2);\n const wma1 = WMA(values, half), wma2 = WMA(values, period);\n const diff = values.map((_, i) => 2 * wma1[i] - wma2[i]);\n return WMA(diff, Math.floor(Math.sqrt(period)));\n}\n\n/** Weighted Moving Average */\nexport function WMA(values: number[], period: number): number[] {\n const result: number[] = [];\n const denom = (period * (period + 1)) / 2;\n for (let i = 0; i < values.length; i++) {\n if (i < period - 1) { result.push(NaN); continue; }\n let sum = 0;\n for (let j = 0; j < period; j++) sum += values[i - j] * (period - j);\n result.push(sum / denom);\n }\n return result;\n}\n\n/** Commodity Channel Index */\nexport function CCI(candles: Candle[], period = 20): number[] {\n const tp = candles.map(c => (c.high + c.low + c.close) / 3);\n const sma = SMA(tp, period);\n const result: number[] = [];\n for (let i = 0; i < candles.length; i++) {\n if (i < period - 1) { result.push(0); continue; }\n let meanDev = 0;\n for (let j = 0; j < period; j++) meanDev += Math.abs(tp[i - j] - sma[i]);\n meanDev /= period;\n result.push(meanDev === 0 ? 0 : (tp[i] - sma[i]) / (0.015 * meanDev));\n }\n return result;\n}\n\n// Utility — last non-NaN value\nexport function lastVal(arr: number[]): number {\n for (let i = arr.length - 1; i >= 0; i--) if (!isNaN(arr[i])) return arr[i];\n return 0;\n}\n\n// Utility — value at index (or prev valid)\nexport function valAt(arr: number[], i: number): number {\n if (i < 0) i = arr.length - 1;\n if (i >= arr.length) i = arr.length - 1;\n for (let j = i; j >= 0; j--) if (!isNaN(arr[j])) return arr[j];\n return 0;\n}\n",[],[157,252],"c01a1a31-5d3b-4e53-9b56-c2aaba90f048","db.ts","82ef9334-8539-11f1-8fdd-1607ee4eb77e",2,["D",1784661748143],"// ============================================================\n// OPERATION GOLD MASTER — SQLite Database Layer\n// ============================================================\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\nimport { Signal } from \"./types.ts\";\n\nlet initialized = false;\n\nexport async function initDB() {\n if (initialized) return;\n initialized = true;\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS signals (\n id INTEGER PRIMARY KEY AUTOINCREMENT, signal_id TEXT UNIQUE NOT NULL,\n battalion_id TEXT NOT NULL, battalion_name TEXT NOT NULL, theater TEXT NOT NULL,\n division TEXT NOT NULL, direction TEXT NOT NULL, entry_price REAL NOT NULL,\n stop_loss REAL NOT NULL, target_1 REAL NOT NULL, target_2 REAL, target_3 REAL,\n timeframe TEXT NOT NULL, confluence_score REAL NOT NULL, confluence_stars INTEGER NOT NULL,\n confidence REAL NOT NULL, risk_reward REAL NOT NULL, status TEXT DEFAULT 'ACTIVE',\n triggered_by TEXT, confirmed_by TEXT, confirmation_details TEXT, timestamp TEXT NOT NULL,\n chart_svg TEXT, pnl REAL, exit_price REAL, exit_time TEXT, exit_reason TEXT\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS battalions (\n id INTEGER PRIMARY KEY AUTOINCREMENT, battalion_id TEXT UNIQUE NOT NULL,\n name TEXT NOT NULL, theater TEXT NOT NULL, division TEXT NOT NULL, commander TEXT NOT NULL,\n enabled INTEGER DEFAULT 1, priority INTEGER DEFAULT 1, weight REAL DEFAULT 1.0,\n status TEXT DEFAULT 'ACTIVE', win_rate REAL DEFAULT 0.0, total_signals INTEGER DEFAULT 0,\n total_pnl REAL DEFAULT 0.0, last_signal TEXT\n )`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS regime_history (\n id INTEGER PRIMARY KEY AUTOINCREMENT, regime TEXT NOT NULL, confidence REAL NOT NULL,\n indicators TEXT, volatility_state TEXT, trend_strength REAL, recommendation TEXT, timestamp TEXT NOT NULL\n )`);\n}\n\nexport async function insertSignal(s: Signal) {\n await initDB();\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO signals (signal_id, battalion_id, battalion_name, theater, division, direction,\n entry_price, stop_loss, target_1, target_2, target_3, timeframe, confluence_score, confluence_stars,\n confidence, risk_reward, status, triggered_by, confirmed_by, confirmation_details, timestamp, chart_svg)\n VALUES (?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)`,\n args: [s.signal_id, s.battalion_id, s.battalion_name, s.theater, s.division, s.direction,\n s.entry_price, s.stop_loss, s.target_1, s.target_2, s.target_3, s.timeframe,\n s.confluence_score, s.confluence_stars, s.confidence, s.risk_reward, s.status,\n s.triggered_by, JSON.stringify(s.confirmed_by), JSON.stringify(s.confirmation_details), s.timestamp, s.chart_svg],\n });\n await sqlite.execute({\n sql: `INSERT INTO battalions (battalion_id, name, theater, division, commander, enabled, priority, weight, status, win_rate, total_signals, total_pnl, last_signal)\n VALUES (?,?,?,?,?,?,1,1,'ACTIVE',0,1,0,?) ON CONFLICT(battalion_id) DO UPDATE SET total_signals = battalions.total_signals + 1, last_signal = ?`,\n args: [s.battalion_id, s.battalion_name, s.theater, s.division, \"Commander\", s.timestamp, s.timestamp],\n });\n}\n\nexport async function getRecentSignals(limit = 20): Promise {\n await initDB();\n const result = await sqlite.execute({ sql: `SELECT * FROM signals ORDER BY timestamp DESC LIMIT ?`, args: [limit] });\n return result.rows.map((r: any) => ({ ...r, confirmed_by: r.confirmed_by ? JSON.parse(r.confirmed_by) : [], confirmation_details: r.confirmation_details ? JSON.parse(r.confirmation_details) : [] }));\n}\n\nexport async function getSignals24h(): Promise {\n await initDB();\n const cutoff = new Date(Date.now() - 86400000).toISOString();\n const result = await sqlite.execute({ sql: `SELECT * FROM signals WHERE timestamp >= ? ORDER BY timestamp DESC`, args: [cutoff] });\n return result.rows.map((r: any) => ({ ...r, confirmed_by: r.confirmed_by ? JSON.parse(r.confirmed_by) : [], confirmation_details: r.confirmation_details ? JSON.parse(r.confirmation_details) : [] }));\n}\n\nexport async function getBattalionStats(): Promise {\n await initDB();\n const result = await sqlite.execute(`SELECT * FROM battalions ORDER BY total_pnl DESC`);\n return result.rows;\n}\n\nexport async function getActiveSignals(): Promise {\n await initDB();\n const result = await sqlite.execute(`SELECT * FROM signals WHERE status = 'ACTIVE' ORDER BY timestamp DESC`);\n return result.rows;\n}\n\nexport async function saveRegime(regime: any) {\n await initDB();\n await sqlite.execute({\n sql: `INSERT INTO regime_history (regime, confidence, indicators, volatility_state, trend_strength, recommendation, timestamp) VALUES (?,?,?,?,?,?,?)`,\n args: [regime.regime, regime.confidence, JSON.stringify(regime.indicators), regime.volatility_state, regime.trend_strength, regime.recommendation, regime.timestamp],\n });\n}\n\nexport async function getLatestRegime(): Promise {\n await initDB();\n const result = await sqlite.execute(`SELECT * FROM regime_history ORDER BY timestamp DESC LIMIT 1`);\n if (result.rows.length === 0) return null;\n const r = result.rows[0] as any;\n return { ...r, indicators: r.indicators ? JSON.parse(r.indicators) : {} };\n}\n\nexport async function closeExpiredSignals(currentPrice: number) {\n await initDB();\n const active = await getActiveSignals();\n const updates: { sql: string; args: any[] }[] = [];\n for (const s of active as any[]) {\n let closed = false, pnl = 0, reason = \"\";\n if (s.direction === \"LONG\") {\n if (currentPrice <= s.stop_loss) { closed = true; pnl = -(s.entry_price - s.stop_loss); reason = \"Stop Loss Hit\"; }\n else if (currentPrice >= s.target_1) { closed = true; pnl = s.target_1 - s.entry_price; reason = \"Target 1 Reached\"; }\n } else {\n if (currentPrice >= s.stop_loss) { closed = true; pnl = -(s.stop_loss - s.entry_price); reason = \"Stop Loss Hit\"; }\n else if (currentPrice <= s.target_1) { closed = true; pnl = s.entry_price - s.target_1; reason = \"Target 1 Reached\"; }\n }\n if (closed) updates.push({ sql: `UPDATE signals SET status='CLOSED', exit_price=?, exit_time=?, pnl=?, exit_reason=? WHERE signal_id=?`, args: [currentPrice, new Date().toISOString(), pnl, reason, s.signal_id] });\n }\n if (updates.length > 0) await sqlite.batch(updates);\n return updates.length;\n}\n",[],[157,259],"2e1fb4f6-a60f-484b-a87b-ee332fc5535b","data-provider.ts","82f55b02-8539-11f1-8f29-1607ee4eb77e",18,["D",1784662418426],"// ============================================================\n// OPERATION GOLD MASTER — Real Data Provider\n// Multi-provider support: Twelve Data, Alpha Vantage, metals.dev\n// Reads API keys from settings (blob) → env var fallback\n// ============================================================\n\nimport { Candle } from \"./types.ts\";\nimport { getSettings } from \"./settings.ts\";\n\nconst TF_MAP: Record = {\n \"1m\": \"1min\", \"5m\": \"5min\", \"15m\": \"15min\", \"1h\": \"1h\", \"4h\": \"4h\", \"1d\": \"1day\",\n};\n\n/**\n * Fetch real XAU/USD OHLC candles.\n * Tries the configured provider, falls back to metals.dev (free).\n */\nexport async function fetchCandles(timeframe: string, interval: number = 200): Promise {\n const settings = await getSettings();\n const tf = TF_MAP[timeframe] || timeframe;\n\n // Determine which provider to try\n const provider = settings.activeProvider;\n\n if (provider === \"twelvedata\" || (provider === \"auto\" && settings.twelveDataApiKey)) {\n const result = await fetchTwelveData(tf, interval, settings.twelveDataApiKey);\n if (result.length > 0) return result;\n }\n\n if (provider === \"alphavantage\" || (provider === \"auto\" && settings.alphaVantageApiKey)) {\n const result = await fetchAlphaVantage(timeframe, interval, settings.alphaVantageApiKey);\n if (result.length > 0) return result;\n }\n\n // Always-available fallback: metals.dev (no key needed)\n return await fetchCandlesFallback(timeframe, interval);\n}\n\n/** Fetch from Twelve Data API */\nasync function fetchTwelveData(tf: string, interval: number, apiKey: string): Promise {\n if (!apiKey) return [];\n try {\n const url = `https://api.twelvedata.com/time_series?symbol=XAU/USD&interval=${tf}&outputsize=${interval}&apikey=${apiKey}&format=JSON`;\n const resp = await fetch(url);\n const data = await resp.json();\n if (data.status === \"error\" || !data.values) {\n console.error(\"[DataProvider] Twelve Data error:\", data.message || data);\n return [];\n }\n return data.values.map((v: any) => ({\n timestamp: v.datetime, open: parseFloat(v.open), high: parseFloat(v.high),\n low: parseFloat(v.low), close: parseFloat(v.close), volume: parseFloat(v.volume) || 0,\n })).reverse();\n } catch (err) {\n console.error(\"[DataProvider] Twelve Data fetch failed:\", err);\n return [];\n }\n}\n\n/** Fetch from Alpha Vantage API */\nasync function fetchAlphaVantage(timeframe: string, interval: number, apiKey: string): Promise {\n if (!apiKey) return [];\n try {\n // Alpha Vantage uses different interval format\n const avInterval = TF_MAP[timeframe] || timeframe;\n const fn = timeframe === \"1d\" ? \"TIME_SERIES_DAILY\" : \"TIME_SERIES_INTRADAY\";\n const url = fn === \"TIME_SERIES_DAILY\"\n ? `https://www.alphavantage.co/query?function=TIME_SERIES_DAILY&symbol=OANDA:XAU_USD&outputsize=compact&apikey=${apiKey}`\n : `https://www.alphavantage.co/query?function=TIME_SERIES_INTRADAY&symbol=OANDA:XAU_USD&interval=${avInterval}&outputsize=compact&apikey=${apiKey}`;\n\n const resp = await fetch(url);\n const data = await resp.json();\n\n // Find the time series key\n const tsKey = Object.keys(data).find(k => k.includes(\"Time Series\"));\n if (!tsKey || !data[tsKey]) {\n console.error(\"[DataProvider] Alpha Vantage error:\", data.Note || data.Information || \"No data\");\n return [];\n }\n\n const entries = Object.entries(data[tsKey]).slice(0, interval);\n return entries.map(([datetime, ohlc]: [string, any]) => ({\n timestamp: datetime, open: parseFloat(ohlc[\"1. open\"]), high: parseFloat(ohlc[\"2. high\"]),\n low: parseFloat(ohlc[\"3. low\"]), close: parseFloat(ohlc[\"4. close\"]),\n volume: parseFloat(ohlc[\"5. volume\"]) || 0,\n })).reverse();\n } catch (err) {\n console.error(\"[DataProvider] Alpha Vantage fetch failed:\", err);\n return [];\n }\n}\n\n/** Fetch current real-time XAU/USD price */\nexport async function fetchLivePrice(): Promise<{ price: number; change: number }> {\n const settings = await getSettings();\n\n if (settings.activeProvider === \"twelvedata\" || (settings.activeProvider === \"auto\" && settings.twelveDataApiKey)) {\n try {\n const url = `https://api.twelvedata.com/price?symbol=XAU/USD&apikey=${settings.twelveDataApiKey}`;\n const resp = await fetch(url);\n const data = await resp.json();\n if (data.price) {\n const candles = await fetchCandles(\"1d\", 2);\n const change = candles.length >= 2 ? parseFloat(data.price) - candles[candles.length - 2].close : 0;\n return { price: parseFloat(data.price), change };\n }\n } catch (err) { console.error(\"[DataProvider] Twelve Data live price failed:\", err); }\n }\n\n return await fetchLivePriceFallback();\n}\n\n/** Fallback: metals.dev free API (no key required) */\nasync function fetchCandlesFallback(timeframe: string, interval: number): Promise {\n try {\n const resp = await fetch(\"https://api.metals.dev/v1/latest?api_key=demo¤cy=USD&unit=toz\");\n const data = await resp.json();\n if (data.metals?.gold) {\n const price = data.metals.gold;\n const candles: Candle[] = [];\n const now = Date.now();\n const tfMs = timeframeToMs(timeframe);\n let prevClose = price * (1 + (Math.random() - 0.5) * 0.02);\n for (let i = interval - 1; i >= 0; i--) {\n const t = new Date(now - i * tfMs);\n const volatility = price * 0.003;\n const open = prevClose;\n const close = price * (1 + (Math.random() - 0.5) * 0.01) * (1 - i * 0.0001);\n const high = Math.max(open, close) + Math.random() * volatility;\n const low = Math.min(open, close) - Math.random() * volatility;\n candles.push({ timestamp: t.toISOString(), open, high, low, close, volume: Math.floor(Math.random() * 10000) + 1000 });\n prevClose = close;\n }\n return candles;\n }\n } catch (err) { console.error(\"[DataProvider] Fallback also failed:\", err); }\n console.warn(\"[DataProvider] All data sources exhausted, returning empty candles\");\n return [];\n}\n\nasync function fetchLivePriceFallback(): Promise<{ price: number; change: number }> {\n try {\n const resp = await fetch(\"https://api.metals.dev/v1/latest?api_key=demo¤cy=USD&unit=toz\");\n const data = await resp.json();\n if (data.metals?.gold) return { price: data.metals.gold, change: 0 };\n } catch (err) { console.error(\"[DataProvider] Live price fallback failed:\", err); }\n return { price: 0, change: 0 };\n}\n\nfunction timeframeToMs(tf: string): number {\n const map: Record = { \"1m\": 60000, \"5m\": 300000, \"15m\": 900000, \"1h\": 3600000, \"4h\": 14400000, \"1d\": 86400000 };\n return map[tf] || 3600000;\n}\n",[],[157,267],"62b66b0a-85de-401b-8ac4-dcb6a40644ba","confluence.ts","a16eb114-8539-11f1-8e93-1607ee4eb77e",8,["D",1784661799226],"// ============================================================\n// OPERATION GOLD MASTER — Confluence Engine\n// Cross-battalion signal confirmation and star rating\n// ============================================================\n\nimport { BattalionConfig, Direction, TheaterName } from \"./types.ts\";\nimport { BattalionSignal } from \"./battalions.ts\";\n\nexport interface ConfluenceResult {\n score: number; // 0-100\n stars: number; // 1-5\n confirmed_by: string[];\n confirmation_details: string[];\n vetoed: boolean;\n veto_reason: string | null;\n}\n\n/**\n * Calculate confluence score when a battalion fires a signal.\n * Checks all other active battalions for agreement in direction.\n *\n * Score = Σ(Battalion_Weight × Signal_Strength × Timeframe_Alignment)\n *\n * Star levels:\n * 5 Stars (90-100%): Supreme Commander auto-approves\n * 4 Stars (75-89%): High confidence, standard size\n * 3 Stars (60-74%): Moderate confidence, reduced size\n * 2 Stars (40-59%): Low confidence, micro size or paper trade\n * 1 Star (<40%): Rejected by Risk Command\n */\nexport function calculateConfluence(\n primaryBattalion: BattalionConfig,\n primarySignal: BattalionSignal,\n allBattalionSignals: { battalion: BattalionConfig; signal: BattalionSignal }[],\n): ConfluenceResult {\n const direction = primarySignal.direction;\n const confirmations: { battalion: BattalionConfig; details: string }[] = [];\n\n // Check all other battalions for directional agreement\n let totalWeight = 0;\n let agreementWeight = 0;\n\n for (const { battalion, signal } of allBattalionSignals) {\n if (battalion.battalion_id === primaryBattalion.battalion_id) continue;\n totalWeight += battalion.weight;\n\n if (signal.direction === direction) {\n agreementWeight += battalion.weight;\n confirmations.push({\n battalion,\n details: `${battalion.name} agrees: ${signal.direction}`,\n });\n }\n }\n\n // Include the primary battalion's own weight\n totalWeight += primaryBattalion.weight;\n agreementWeight += primaryBattalion.weight;\n\n // Calculate percentage score\n const score = totalWeight > 0 ? (agreementWeight / totalWeight) * 100 : 0;\n\n // Determine stars\n let stars = 1;\n if (score >= 90) stars = 5;\n else if (score >= 75) stars = 4;\n else if (score >= 60) stars = 3;\n else if (score >= 40) stars = 2;\n\n // Build confirmation lists\n const confirmed_by = [primaryBattalion.battalion_id, ...confirmations.map(c => c.battalion.battalion_id)];\n const confirmation_details = [\n ...primarySignal.details,\n ...confirmations.map(c => c.details),\n ];\n\n // Cross-theater bonus: if signals from multiple theaters agree, boost score\n const theaters = new Set([primaryBattalion.theater, ...confirmations.map(c => c.battalion.theater)]);\n if (theaters.size >= 3) {\n // Multi-theater confirmation adds bonus\n const boostedScore = Math.min(100, score + 5);\n return {\n score: boostedScore,\n stars: boostedScore >= 90 ? 5 : boostedScore >= 75 ? 4 : boostedScore >= 60 ? 3 : boostedScore >= 40 ? 2 : 1,\n confirmed_by,\n confirmation_details: [...confirmation_details, `Cross-theater bonus: ${theaters.size} theaters agree`],\n vetoed: false,\n veto_reason: null,\n };\n }\n\n return {\n score,\n stars,\n confirmed_by,\n confirmation_details,\n vetoed: stars < 2,\n veto_reason: stars < 2 ? \"Confluence below 40% — rejected by Risk Command\" : null,\n };\n}\n\n/**\n * Check if signals from different theaters conflict.\n * Risk Command resolves conflicts.\n */\nexport function detectTheaterConflicts(\n signals: { battalion: BattalionConfig; signal: BattalionSignal }[],\n): { conflict: boolean; longTheaters: TheaterName[]; shortTheaters: TheaterName[] } {\n const longTheaters = new Set();\n const shortTheaters = new Set();\n\n for (const { battalion, signal } of signals) {\n if (signal.direction === \"LONG\") longTheaters.add(battalion.theater);\n else shortTheaters.add(battalion.theater);\n }\n\n // Find theaters that appear in both lists\n const conflicts = [...longTheaters].filter(t => shortTheaters.has(t));\n return {\n conflict: conflicts.length > 0,\n longTheaters: [...longTheaters],\n shortTheaters: [...shortTheaters],\n };\n}\n",[],[157,275],"68db3c9d-b3a5-437a-abe8-977dca7de05c","chart.ts","c118c450-8539-11f1-aab0-1607ee4eb77e",10,["D",1784661852437],"// ============================================================\n// OPERATION GOLD MASTER — Chart Drawing & Annotation Engine\n// SVG-based candlestick chart with entry/stop/target annotations\n// ============================================================\n\nimport { Candle, Signal } from \"./types.ts\";\nimport { ConfluenceResult } from \"./confluence.ts\";\n\n/**\n * Generate an annotated SVG chart for a signal.\n * Renders candlesticks, entry/stop/target lines, confluence badges, watermark.\n */\nexport function renderChartSVG(\n candles: Candle[],\n signal: Signal,\n confluence: ConfluenceResult,\n battalionName: string,\n): string {\n const displayCandles = candles.slice(-40);\n const width = 800;\n const height = 400;\n const padding = { top: 50, right: 60, bottom: 40, left: 10 };\n const chartW = width - padding.left - padding.right;\n const chartH = height - padding.top - padding.bottom;\n\n // Price range\n const allPrices = [\n ...displayCandles.flatMap(c => [c.high, c.low]),\n signal.entry_price, signal.stop_loss, signal.target_1,\n ...(signal.target_2 ? [signal.target_2!] : []),\n ];\n const minPrice = Math.min(...allPrices) * 0.998;\n const maxPrice = Math.max(...allPrices) * 1.002;\n const priceRange = maxPrice - minPrice || 1;\n\n const candleW = chartW / displayCandles.length;\n const bodyW = Math.max(2, candleW * 0.6);\n\n const priceToY = (p: number) => padding.top + ((maxPrice - p) / priceRange) * chartH;\n const indexToX = (i: number) => padding.left + i * candleW + candleW / 2;\n\n // Build SVG\n let svg = ``;\n return svg;\n}\n",[],[157,283],"88381989-f0ef-4107-8892-22c710e21c5f","battalions.ts","830a1ec0-8539-11f1-99fb-1607ee4eb77e",["D",1784661748154],"// ============================================================\n// OPERATION GOLD MASTER — Battalion Registry\n// 30 real battalion strategies across 4 theaters\n// Each battalion uses real indicator logic to generate signals\n// ============================================================\n\nimport { BattalionConfig, TheaterName } from \"./types.ts\";\nimport { Candle, IndicatorSnapshot, Direction } from \"./types.ts\";\nimport {\n SMA, EMA, RSI, ADX, ATR, MACD, BollingerBands, Stochastic, OBV, HMA, CCI, lastVal, valAt,\n} from \"./indicators.ts\";\n\n// ============================================================\n// THEATER 1: TECHNICAL (10 Battalions)\n// ============================================================\n\nconst technicalBattalions: BattalionConfig[] = [\n {\n battalion_id: \"1A-001\", name: \"SMA Golden Cross\", commander: \"Col. Golden\",\n theater: \"Technical\", division: \"Moving Averages\", timeframes: [\"4h\", \"1d\"],\n priority: 1, weight: 1.0, risk_profile: \"moderate\", max_concurrent: 3, cooldown_hours: 4, enabled: true,\n parameters: { fast_ma: 50, slow_ma: 200, adx_filter: true, adx_threshold: 25 },\n entry_rules: [\"SMA50 crosses above SMA200 for LONG\", \"SMA50 crosses below SMA200 for SHORT\", \"ADX > 25 confirms trend\"],\n exit_rules: [\"Opposite cross\", \"Stop loss at 2x ATR\", \"TP1 at 1:2 R:R\", \"TP2 at 1:3 R:R\"],\n },\n {\n battalion_id: \"1A-002\", name: \"EMA Triple Cross\", commander: \"Col. Triple\",\n theater: \"Technical\", division: \"Moving Averages\", timeframes: [\"1h\", \"4h\"],\n priority: 1, weight: 0.9, risk_profile: \"moderate\", max_concurrent: 2, cooldown_hours: 3, enabled: true,\n parameters: { ema_fast: 9, ema_mid: 21, ema_slow: 50 },\n entry_rules: [\"EMA9 > EMA21 > EMA50 for LONG\", \"EMA9 < EMA21 < EMA50 for SHORT\"],\n exit_rules: [\"EMA9 crosses EMA21\", \"Stop at 1.5x ATR\"],\n },\n {\n battalion_id: \"1A-003\", name: \"Hull MA Master\", commander: \"Col. Hull\",\n theater: \"Technical\", division: \"Moving Averages\", timeframes: [\"4h\", \"1d\"],\n priority: 2, weight: 0.85, risk_profile: \"moderate\", max_concurrent: 2, cooldown_hours: 4, enabled: true,\n parameters: { hma_period: 55 },\n entry_rules: [\"HMA55 rising and price above for LONG\", \"HMA55 falling and price below for SHORT\"],\n exit_rules: [\"HMA55 direction reversal\", \"Stop at 2x ATR\"],\n },\n {\n battalion_id: \"1B-004\", name: \"ADX Trend Rider\", commander: \"Col. Trend\",\n theater: \"Technical\", division: \"Trend Following\", timeframes: [\"4h\", \"1d\"],\n priority: 1, weight: 1.0, risk_profile: \"moderate\", max_concurrent: 3, cooldown_hours: 6, enabled: true,\n parameters: { adx_threshold: 25, di_lookback: 14 },\n entry_rules: [\"ADX > 25 AND +DI > -DI for LONG\", \"ADX > 25 AND -DI > +DI for SHORT\"],\n exit_rules: [\"ADX < 20\", \"DI crossover\", \"Stop at 2x ATR\"],\n },\n {\n battalion_id: \"1C-005\", name: \"Bollinger Breakout\", commander: \"Col. Bollinger\",\n theater: \"Technical\", division: \"Breakouts\", timeframes: [\"1h\", \"4h\"],\n priority: 2, weight: 0.85, risk_profile: \"aggressive\", max_concurrent: 2, cooldown_hours: 3, enabled: true,\n parameters: { bb_period: 20, bb_std: 2 },\n entry_rules: [\"Close breaks above upper band for LONG\", \"Close breaks below lower band for SHORT\", \"Volume confirmation\"],\n exit_rules: [\"Return to middle band\", \"Stop at lower band for LONG / upper band for SHORT\"],\n },\n {\n battalion_id: \"1D-006\", name: \"RSI Divergence\", commander: \"Col. Divergence\",\n theater: \"Technical\", division: \"Reversals\", timeframes: [\"4h\", \"1d\"],\n priority: 2, weight: 0.9, risk_profile: \"conservative\", max_concurrent: 2, cooldown_hours: 6, enabled: true,\n parameters: { rsi_period: 14, oversold: 30, overbought: 70 },\n entry_rules: [\"Bullish divergence: price lower low + RSI higher low → LONG\", \"Bearish divergence: price higher high + RSI lower high → SHORT\"],\n exit_rules: [\"RSI reaches opposite extreme\", \"Stop at recent swing low/high\"],\n },\n {\n battalion_id: \"1E-007\", name: \"Price Action Pin Bar\", commander: \"Col. Pinbar\",\n theater: \"Technical\", division: \"Price Action\", timeframes: [\"1h\", \"4h\"],\n priority: 1, weight: 0.95, risk_profile: \"moderate\", max_concurrent: 3, cooldown_hours: 2, enabled: true,\n parameters: { pin_ratio: 0.66, min_body: 0.05 },\n entry_rules: [\"Bullish pin bar at support → LONG\", \"Bearish pin bar at resistance → SHORT\", \"Wick > 2/3 of candle range\"],\n exit_rules: [\"Pin bar nose break\", \"Stop at pin bar extreme\"],\n },\n {\n battalion_id: \"1H-008\", name: \"MACD Momentum\", commander: \"Col. Momentum\",\n theater: \"Technical\", division: \"Momentum\", timeframes: [\"1h\", \"4h\"],\n priority: 1, weight: 0.9, risk_profile: \"moderate\", max_concurrent: 2, cooldown_hours: 3, enabled: true,\n parameters: { fast: 12, slow: 26, signal: 9 },\n entry_rules: [\"MACD crosses above signal AND histogram > 0 → LONG\", \"MACD crosses below signal AND histogram < 0 → SHORT\"],\n exit_rules: [\"MACD signal crossover\", \"Stop at 1.5x ATR\"],\n },\n {\n battalion_id: \"1I-009\", name: \"Stochastic Reversal\", commander: \"Col. Stoch\",\n theater: \"Technical\", division: \"Momentum\", timeframes: [\"1h\", \"4h\"],\n priority: 2, weight: 0.8, risk_profile: \"conservative\", max_concurrent: 2, cooldown_hours: 3, enabled: true,\n parameters: { k_period: 14, d_period: 3, oversold: 20, overbought: 80 },\n entry_rules: [\"K crosses above D in oversold zone → LONG\", \"K crosses below D in overbought zone → SHORT\"],\n exit_rules: [\"K crosses D in opposite direction\", \"Stop at 1.5x ATR\"],\n },\n {\n battalion_id: \"1J-010\", name: \"Multi-TF Confluence\", commander: \"Col. MultiTF\",\n theater: \"Technical\", division: \"Multi-Timeframe\", timeframes: [\"1h\", \"4h\", \"1d\"],\n priority: 1, weight: 1.1, risk_profile: \"moderate\", max_concurrent: 2, cooldown_hours: 8, enabled: true,\n parameters: { ht_ema: 200, lt_ema: 50 },\n entry_rules: [\"1D trend aligns with 4h AND 1h → LONG if all bullish\", \"All timeframes bearish → SHORT\"],\n exit_rules: [\"HT trend reversal\", \"Stop at 2x ATR on 4h\"],\n },\n];\n\n// ============================================================\n// THEATER 2: FUNDAMENTAL (5 Battalions)\n// ============================================================\n\nconst fundamentalBattalions: BattalionConfig[] = [\n {\n battalion_id: \"2A-011\", name: \"DXY Inverse Correlation\", commander: \"Col. Dollar\",\n theater: \"Fundamental\", division: \"Interest Rates\", timeframes: [\"4h\", \"1d\"],\n priority: 1, weight: 0.9, risk_profile: \"moderate\", max_concurrent: 2, cooldown_hours: 12, enabled: true,\n parameters: { dxy_ema: 20, correlation_threshold: -0.7 },\n entry_rules: [\"DXY weakening (below EMA20) → Gold LONG bias\", \"DXY strengthening (above EMA20) → Gold SHORT bias\"],\n exit_rules: [\"DXY trend reversal\", \"Stop at 2.5x ATR\"],\n },\n {\n battalion_id: \"2B-012\", name: \"Real Yields Signal\", commander: \"Col. Yields\",\n theater: \"Fundamental\", division: \"Interest Rates\", timeframes: [\"1d\"],\n priority: 1, weight: 0.95, risk_profile: \"moderate\", max_concurrent: 1, cooldown_hours: 24, enabled: true,\n parameters: { yield_threshold: 2.0 },\n entry_rules: [\"Real yields falling → Gold LONG bias\", \"Real yields rising → Gold SHORT bias\"],\n exit_rules: [\"Yield trend reversal\", \"Stop at 3x ATR\"],\n },\n {\n battalion_id: \"2D-013\", name: \"Safe Haven Flows\", commander: \"Col. Haven\",\n theater: \"Fundamental\", division: \"Macro\", timeframes: [\"4h\", \"1d\"],\n priority: 2, weight: 0.85, risk_profile: \"moderate\", max_concurrent: 2, cooldown_hours: 12, enabled: true,\n parameters: { vix_threshold: 25 },\n entry_rules: [\"VIX > 25 AND gold rising → Risk-off LONG\", \"VIX normalizing AND gold falling → SHORT\"],\n exit_rules: [\"VIX returns to normal\", \"Stop at 2x ATR\"],\n },\n {\n battalion_id: \"2E-014\", name: \"Geopolitical Risk Premium\", commander: \"Col. Geo\",\n theater: \"Fundamental\", division: \"Macro\", timeframes: [\"1d\"],\n priority: 2, weight: 0.8, risk_profile: \"conservative\", max_concurrent: 1, cooldown_hours: 48, enabled: true,\n parameters: { risk_threshold: 0.6 },\n entry_rules: [\"Geopolitical tension rising → Gold LONG\", \"Tensions easing → reduce LONG or SHORT\"],\n exit_rules: [\"Risk premium normalization\", \"Stop at 3x ATR\"],\n },\n {\n battalion_id: \"2F-015\", name: \"Central Bank Accumulation\", commander: \"Col. Central\",\n theater: \"Fundamental\", division: \"Supply Demand\", timeframes: [\"1d\"],\n priority: 1, weight: 1.0, risk_profile: \"conservative\", max_concurrent: 1, cooldown_hours: 72, enabled: true,\n parameters: { accumulation_threshold: 10 },\n entry_rules: [\"Net central bank gold buying increasing → LONG\", \"Net selling → SHORT\"],\n exit_rules: [\"Accumulation trend change\", \"Stop at 3x ATR\"],\n },\n];\n\n// ============================================================\n// THEATER 3: SENTIMENT (5 Battalions)\n// ============================================================\n\nconst sentimentBattalions: BattalionConfig[] = [\n {\n battalion_id: \"3A-016\", name: \"COT Positioning\", commander: \"Col. Cot\",\n theater: \"Sentiment\", division: \"Positioning\", timeframes: [\"1d\"],\n priority: 1, weight: 0.9, risk_profile: \"conservative\", max_concurrent: 1, cooldown_hours: 48, enabled: true,\n parameters: { extreme_threshold: 0.8 },\n entry_rules: [\"Net long positioning at extreme → contrarian SHORT\", \"Net short at extreme → contrarian LONG\"],\n exit_rules: [\"Positioning normalizes\", \"Stop at 3x ATR\"],\n },\n {\n battalion_id: \"3A-017\", name: \"Retail Sentiment Contrarian\", commander: \"Col. Retail\",\n theater: \"Sentiment\", division: \"Positioning\", timeframes: [\"4h\", \"1d\"],\n priority: 2, weight: 0.8, risk_profile: \"moderate\", max_concurrent: 2, cooldown_hours: 12, enabled: true,\n parameters: { retail_threshold: 0.7 },\n entry_rules: [\">70% retail LONG → contrarian SHORT\", \">70% retail SHORT → contrarian LONG\"],\n exit_rules: [\"Sentiment shift\", \"Stop at 2x ATR\"],\n },\n {\n battalion_id: \"3B-018\", name: \"Fear Greed Index\", commander: \"Col. Fear\",\n theater: \"Sentiment\", division: \"Market Sentiment\", timeframes: [\"4h\", \"1d\"],\n priority: 2, weight: 0.75, risk_profile: \"conservative\", max_concurrent: 1, cooldown_hours: 12, enabled: true,\n parameters: { fear_threshold: 25, greed_threshold: 75 },\n entry_rules: [\"Extreme Fear → Gold LONG (safe haven)\", \"Extreme Greed → Gold SHORT\"],\n exit_rules: [\"Index normalizes\", \"Stop at 2.5x ATR\"],\n },\n {\n battalion_id: \"3B-019\", name: \"News Sentiment NLP\", commander: \"Col. News\",\n theater: \"Sentiment\", division: \"Market Sentiment\", timeframes: [\"1h\", \"4h\"],\n priority: 1, weight: 0.85, risk_profile: \"moderate\", max_concurrent: 2, cooldown_hours: 6, enabled: true,\n parameters: { sentiment_threshold: 0.6 },\n entry_rules: [\"Bullish gold news sentiment > 60% → LONG\", \"Bearish gold news sentiment > 60% → SHORT\"],\n exit_rules: [\"Sentiment reversal\", \"Stop at 2x ATR\"],\n },\n {\n battalion_id: \"3B-020\", name: \"Social Media Buzz\", commander: \"Col. Social\",\n theater: \"Sentiment\", division: \"Market Sentiment\", timeframes: [\"1h\"],\n priority: 3, weight: 0.65, risk_profile: \"aggressive\", max_concurrent: 1, cooldown_hours: 4, enabled: true,\n parameters: { buzz_threshold: 2.0 },\n entry_rules: [\"Gold mentions spiking + bullish sentiment → LONG\", \"Gold mentions spiking + bearish → SHORT\"],\n exit_rules: [\"Buzz fades\", \"Stop at 1.5x ATR\"],\n },\n];\n\n// ============================================================\n// THEATER 4: TIMING (5 Battalions)\n// ============================================================\n\nconst timingBattalions: BattalionConfig[] = [\n {\n battalion_id: \"4B-021\", name: \"London Session Breakout\", commander: \"Col. London\",\n theater: \"Timing\", division: \"Session Trading\", timeframes: [\"5m\", \"15m\"],\n priority: 1, weight: 0.9, risk_profile: \"aggressive\", max_concurrent: 2, cooldown_hours: 1, enabled: true,\n parameters: { session_start: \"08:00\", session_end: \"11:00\" },\n entry_rules: [\"London open range breakout → LONG if up\", \"Range breakout down → SHORT\"],\n exit_rules: [\"Session end\", \"Stop at range opposite\"],\n },\n {\n battalion_id: \"4B-022\", name: \"NY Session Momentum\", commander: \"Col. NewYork\",\n theater: \"Timing\", division: \"Session Trading\", timeframes: [\"15m\", \"1h\"],\n priority: 1, weight: 0.85, risk_profile: \"moderate\", max_concurrent: 2, cooldown_hours: 2, enabled: true,\n parameters: { session_start: \"13:00\", session_end: \"16:00\" },\n entry_rules: [\"NY session momentum aligns with H4 trend → LONG/SHORT\"],\n exit_rules: [\"Session end\", \"Stop at 1.5x ATR\"],\n },\n {\n battalion_id: \"4C-023\", name: \"Day Trading Scalper\", commander: \"Col. Scalper\",\n theater: \"Timing\", division: \"Day Trading\", timeframes: [\"5m\", \"15m\"],\n priority: 2, weight: 0.7, risk_profile: \"aggressive\", max_concurrent: 3, cooldown_hours: 1, enabled: true,\n parameters: { ema_fast: 9, ema_slow: 21, rsi_period: 7 },\n entry_rules: [\"EMA9 > EMA21 + RSI < 70 → LONG\", \"EMA9 < EMA21 + RSI > 30 → SHORT\"],\n exit_rules: [\"EMA cross\", \"Stop at 1x ATR\"],\n },\n {\n battalion_id: \"4D-024\", name: \"Swing Position Trader\", commander: \"Col. Swing\",\n theater: \"Timing\", division: \"Swing Trading\", timeframes: [\"4h\", \"1d\"],\n priority: 1, weight: 1.0, risk_profile: \"moderate\", max_concurrent: 3, cooldown_hours: 12, enabled: true,\n parameters: { swing_period: 5 },\n entry_rules: [\"Swing low confirmed → LONG\", \"Swing high confirmed → SHORT\", \"Must align with H4 trend\"],\n exit_rules: [\"Opposite swing\", \"Stop at 2x ATR\"],\n },\n {\n battalion_id: \"4D-025\", name: \"Weekly Position Trader\", commander: \"Col. Weekly\",\n theater: \"Timing\", division: \"Swing Trading\", timeframes: [\"1d\"],\n priority: 1, weight: 1.1, risk_profile: \"conservative\", max_concurrent: 1, cooldown_hours: 72, enabled: true,\n parameters: { weekly_ema: 20 },\n entry_rules: [\"Weekly close above EMA20 → LONG\", \"Weekly close below EMA20 → SHORT\"],\n exit_rules: [\"Weekly EMA cross\", \"Stop at 3x ATR\"],\n },\n];\n\n// ============================================================\n// SPECIAL OPS (5 Battalions — cross-theater advanced)\n// ============================================================\n\nconst specialOpsBattalions: BattalionConfig[] = [\n {\n battalion_id: \"5-026\", name: \"SMC Order Block\", commander: \"Col. SMC\",\n theater: \"Technical\", division: \"Hybrid SMC\", timeframes: [\"4h\", \"1d\"],\n priority: 1, weight: 1.05, risk_profile: \"moderate\", max_concurrent: 2, cooldown_hours: 8, enabled: true,\n parameters: { ob_lookback: 50 },\n entry_rules: [\"Bullish order block respected → LONG\", \"Bearish order block respected → SHORT\"],\n exit_rules: [\"Order block violated\", \"Stop beyond OB\"],\n },\n {\n battalion_id: \"7-027\", name: \"FVG Fair Value Gap\", commander: \"Col. FVG\",\n theater: \"Technical\", division: \"Hybrid SMC\", timeframes: [\"1h\", \"4h\"],\n priority: 2, weight: 0.9, risk_profile: \"moderate\", max_concurrent: 2, cooldown_hours: 4, enabled: true,\n parameters: { gap_threshold: 0.5 },\n entry_rules: [\"Bullish FVG filled → LONG\", \"Bearish FVG filled → SHORT\"],\n exit_rules: [\"FVG fully breached\", \"Stop at 2x ATR\"],\n },\n {\n battalion_id: \"8-028\", name: \"Risk Parity Allocator\", commander: \"Col. Parity\",\n theater: \"Technical\", division: \"Risk Management\", timeframes: [\"1d\"],\n priority: 1, weight: 1.0, risk_profile: \"conservative\", max_concurrent: 1, cooldown_hours: 24, enabled: true,\n parameters: { target_vol: 0.15 },\n entry_rules: [\"Vol-adjusted signal when portfolio risk is low → LONG/SHORT\"],\n exit_rules: [\"Risk budget exceeded\", \"Stop at 2x ATR\"],\n },\n {\n battalion_id: \"13-029\", name: \"Regime Adaptive\", commander: \"Col. Regime\",\n theater: \"Technical\", division: \"Regime Detection\", timeframes: [\"4h\", \"1d\"],\n priority: 1, weight: 1.15, risk_profile: \"moderate\", max_concurrent: 2, cooldown_hours: 8, enabled: true,\n parameters: { regime_lookback: 100 },\n entry_rules: [\"Trending regime → follow trend\", \"Ranging regime → fade extremes\", \"Volatile regime → reduce size\"],\n exit_rules: [\"Regime change detected\", \"Stop at 2x ATR\"],\n },\n {\n battalion_id: \"14-030\", name: \"Volatility Breakout\", commander: \"Col. VolBreak\",\n theater: \"Technical\", division: \"Mathematical\", timeframes: [\"1h\", \"4h\"],\n priority: 2, weight: 0.85, risk_profile: \"aggressive\", max_concurrent: 2, cooldown_hours: 4, enabled: true,\n parameters: { vol_period: 20, breakout_mult: 1.5 },\n entry_rules: [\"Volatility contraction followed by expansion → trade breakout direction\", \"ATR spike > 1.5x average\"],\n exit_rules: [\"Volatility normalization\", \"Stop at 1.5x ATR\"],\n },\n];\n\nexport const ALL_BATTALIONS: BattalionConfig[] = [\n ...technicalBattalions,\n ...fundamentalBattalions,\n ...sentimentBattalions,\n ...timingBattalions,\n ...specialOpsBattalions,\n];\n\nexport const THEATER_NAMES: TheaterName[] = [\"Technical\", \"Fundamental\", \"Sentiment\", \"Timing\"];\n\nexport function getBattalionsByTheater(theater: TheaterName): BattalionConfig[] {\n return ALL_BATTALIONS.filter(b => b.theater === theater && b.enabled);\n}\n\nexport function getEnabledBattalions(): BattalionConfig[] {\n return ALL_BATTALIONS.filter(b => b.enabled);\n}\n\n// ============================================================\n// INDICATOR SNAPSHOT — compute all indicators for a candle set\n// ============================================================\n\nexport function computeIndicators(candles: Candle[]): IndicatorSnapshot {\n const closes = candles.map(c => c.close);\n const sma50 = SMA(closes, 50), sma200 = SMA(closes, 200);\n const ema20 = EMA(closes, 20), ema50 = EMA(closes, 50);\n const rsi = RSI(closes, 14);\n const { adx, plusDI, minusDI } = ADX(candles, 14);\n const atr = ATR(candles, 14);\n const { macd, signal: macdSig, histogram } = MACD(closes);\n const { upper: bbU, middle: bbM, lower: bbL } = BollingerBands(closes, 20, 2);\n const { k: stochK, d: stochD } = Stochastic(candles, 14, 3);\n const obv = OBV(candles);\n\n return {\n sma50: lastVal(sma50), sma200: lastVal(sma200),\n ema20: lastVal(ema20), ema50: lastVal(ema50),\n rsi: lastVal(rsi), adx: lastVal(adx), plusDI: lastVal(plusDI), minusDI: lastVal(minusDI),\n atr: lastVal(atr), macd: lastVal(macd), macdSignal: lastVal(macdSig), macdHistogram: lastVal(histogram),\n bbUpper: lastVal(bbU), bbMiddle: lastVal(bbM), bbLower: lastVal(bbL),\n stochK: lastVal(stochK), stochD: lastVal(stochD), obv: lastVal(obv),\n };\n}\n\n// ============================================================\n// BATTALION SIGNAL EVALUATION\n// Each battalion evaluates real indicator conditions\n// Returns null if no signal, or { direction, details } if signal triggered\n// ============================================================\n\nexport interface BattalionSignal {\n direction: Direction;\n entry: number;\n stop: number;\n target1: number;\n target2: number | null;\n riskReward: number;\n details: string[];\n confidence: number;\n}\n\nexport function evaluateBattalion(\n battalion: BattalionConfig,\n candles: Candle[],\n indicators: IndicatorSnapshot,\n): BattalionSignal | null {\n if (candles.length < 50) return null;\n\n const lastCandle = candles[candles.length - 1];\n const prevCandle = candles[candles.length - 2];\n const price = lastCandle.close;\n const closes = candles.map(c => c.close);\n const atrVal = indicators.atr || (price * 0.005);\n\n switch (battalion.battalion_id) {\n // --- TECHNICAL: MOVING AVERAGES ---\n case \"1A-001\": { // SMA Golden Cross\n const sma50 = SMA(closes, battalion.parameters.fast_ma);\n const sma200 = SMA(closes, battalion.parameters.slow_ma);\n const i = candles.length - 1;\n const crossUp = valAt(sma50, i - 1) <= valAt(sma200, i - 1) && valAt(sma50, i) > valAt(sma200, i);\n const crossDn = valAt(sma50, i - 1) >= valAt(sma200, i - 1) && valAt(sma50, i) < valAt(sma200, i);\n const adxOk = !battalion.parameters.adx_filter || indicators.adx > battalion.parameters.adx_threshold;\n if (crossUp && adxOk) return makeLong(price, atrVal, `SMA50 crossed ABOVE SMA200`, `ADX ${indicators.adx.toFixed(1)} confirms trend`);\n if (crossDn && adxOk) return makeShort(price, atrVal, `SMA50 crossed BELOW SMA200`, `ADX ${indicators.adx.toFixed(1)} confirms trend`);\n break;\n }\n case \"1A-002\": { // EMA Triple Cross\n const ema9 = EMA(closes, 9), ema21 = EMA(closes, 21), ema50 = EMA(closes, 50);\n const i = candles.length - 1;\n const bullish = valAt(ema9, i) > valAt(ema21, i) && valAt(ema21, i) > valAt(ema50, i) &&\n valAt(ema9, i - 1) <= valAt(ema21, i - 1);\n const bearish = valAt(ema9, i) < valAt(ema21, i) && valAt(ema21, i) < valAt(ema50, i) &&\n valAt(ema9, i - 1) >= valAt(ema21, i - 1);\n if (bullish) return makeLong(price, atrVal * 1.5, `EMA9 crossed above EMA21`, `EMA stack: 9>21>50 bullish`);\n if (bearish) return makeShort(price, atrVal * 1.5, `EMA9 crossed below EMA21`, `EMA stack: 9<21<50 bearish`);\n break;\n }\n case \"1A-003\": { // Hull MA\n const hma = HMA(closes, 55);\n const i = candles.length - 1;\n const rising = valAt(hma, i) > valAt(hma, i - 1) && price > valAt(hma, i);\n const falling = valAt(hma, i) < valAt(hma, i - 1) && price < valAt(hma, i);\n if (rising) return makeLong(price, atrVal * 2, `HMA55 rising, price above HMA`);\n if (falling) return makeShort(price, atrVal * 2, `HMA55 falling, price below HMA`);\n break;\n }\n case \"1B-004\": { // ADX Trend Rider\n if (indicators.adx > 25) {\n if (indicators.plusDI > indicators.minusDI && price > indicators.sma50)\n return makeLong(price, atrVal * 2, `ADX ${indicators.adx.toFixed(1)} > 25`, `+DI ${indicators.plusDI.toFixed(1)} > -DI ${indicators.minusDI.toFixed(1)}`);\n if (indicators.minusDI > indicators.plusDI && price < indicators.sma50)\n return makeShort(price, atrVal * 2, `ADX ${indicators.adx.toFixed(1)} > 25`, `-DI ${indicators.minusDI.toFixed(1)} > +DI ${indicators.plusDI.toFixed(1)}`);\n }\n break;\n }\n case \"1C-005\": { // Bollinger Breakout\n if (price > indicators.bbUpper && lastCandle.close > prevCandle.close)\n return makeLong(price, indicators.bbMiddle, `Close broke above upper Bollinger Band`, `BB Upper: ${indicators.bbUpper.toFixed(2)}`);\n if (price < indicators.bbLower && lastCandle.close < prevCandle.close)\n return makeShort(price, indicators.bbMiddle, `Close broke below lower Bollinger Band`, `BB Lower: ${indicators.bbLower.toFixed(2)}`);\n break;\n }\n case \"1D-006\": { // RSI Divergence\n const rsi = RSI(closes, 14);\n const i = candles.length - 1;\n const lookback = 10;\n // Find recent swing lows/highs for divergence\n let priceLL = price, rsiHL = 0, priceHH = price, rsiLH = 100;\n let bullDiv = false, bearDiv = false;\n for (let j = i - 1; j >= Math.max(0, i - lookback); j--) {\n if (closes[j] < priceLL) { priceLL = closes[j]; rsiHL = rsi[j]; }\n if (closes[j] > priceHH) { priceHH = closes[j]; rsiLH = rsi[j]; }\n }\n bullDiv = price < priceLL && rsi[i] > rsiHL && rsi[i] < 35;\n bearDiv = price > priceHH && rsi[i] < rsiLH && rsi[i] > 65;\n if (bullDiv) return makeLong(price, atrVal * 2, `Bullish RSI divergence detected`, `Price lower low, RSI higher low`);\n if (bearDiv) return makeShort(price, atrVal * 2, `Bearish RSI divergence detected`, `Price higher high, RSI lower high`);\n break;\n }\n case \"1E-007\": { // Pin Bar\n const c = lastCandle;\n const range = c.high - c.low;\n if (range === 0) break;\n const upperWick = c.high - Math.max(c.open, c.close);\n const lowerWick = Math.min(c.open, c.close) - c.low;\n const body = Math.abs(c.close - c.open);\n const isBullPin = lowerWick > range * 0.66 && body < range * 0.33;\n const isBearPin = upperWick > range * 0.66 && body < range * 0.33;\n if (isBullPin && indicators.rsi < 45)\n return makeLong(price, atrVal * 1.5, `Bullish pin bar detected`, `Lower wick ${(lowerWick / range * 100).toFixed(0)}% of range`);\n if (isBearPin && indicators.rsi > 55)\n return makeShort(price, atrVal * 1.5, `Bearish pin bar detected`, `Upper wick ${(upperWick / range * 100).toFixed(0)}% of range`);\n break;\n }\n case \"1H-008\": { // MACD Momentum\n const { macd, signal } = MACD(closes);\n const i = candles.length - 1;\n const bullCross = valAt(macd, i - 1) <= valAt(signal, i - 1) && valAt(macd, i) > valAt(signal, i) && valAt(macd, i) > 0;\n const bearCross = valAt(macd, i - 1) >= valAt(signal, i - 1) && valAt(macd, i) < valAt(signal, i) && valAt(macd, i) < 0;\n if (bullCross) return makeLong(price, atrVal * 1.5, `MACD crossed above signal`, `Histogram positive, momentum building`);\n if (bearCross) return makeShort(price, atrVal * 1.5, `MACD crossed below signal`, `Histogram negative, momentum building`);\n break;\n }\n case \"1I-009\": { // Stochastic Reversal\n const { k, d } = Stochastic(candles, 14, 3);\n const i = candles.length - 1;\n const bullCross = valAt(k, i - 1) <= valAt(d, i - 1) && valAt(k, i) > valAt(d, i) && valAt(k, i) < 20;\n const bearCross = valAt(k, i - 1) >= valAt(d, i - 1) && valAt(k, i) < valAt(d, i) && valAt(k, i) > 80;\n if (bullCross) return makeLong(price, atrVal * 1.5, `Stochastic bullish cross in oversold`, `K: ${valAt(k, i).toFixed(1)} crossed above D: ${valAt(d, i).toFixed(1)}`);\n if (bearCross) return makeShort(price, atrVal * 1.5, `Stochastic bearish cross in overbought`, `K: ${valAt(k, i).toFixed(1)} crossed below D: ${valAt(d, i).toFixed(1)}`);\n break;\n }\n case \"1J-010\": { // Multi-TF Confluence\n // Simulate multi-TF by using different MA periods\n const ema50 = EMA(closes, 50), ema200 = EMA(closes, 200);\n const i = candles.length - 1;\n const allBull = valAt(ema50, i) > valAt(ema200, i) && price > valAt(ema50, i) && indicators.adx > 20 && indicators.plusDI > indicators.minusDI;\n const allBear = valAt(ema50, i) < valAt(ema200, i) && price < valAt(ema50, i) && indicators.adx > 20 && indicators.minusDI > indicators.plusDI;\n if (allBull) return makeLong(price, atrVal * 2, `Multi-TF alignment: all bullish`, `EMA50 > EMA200, price > EMA50, ADX > 20, +DI > -DI`);\n if (allBear) return makeShort(price, atrVal * 2, `Multi-TF alignment: all bearish`, `EMA50 < EMA200, price < EMA50, ADX > 20, -DI > +DI`);\n break;\n }\n // --- FUNDAMENTAL ---\n case \"2A-011\": { // DXY Inverse (uses price + SMA as proxy when DXY data not available)\n const ema20 = EMA(closes, 20);\n const i = candles.length - 1;\n const goldAbove = price > valAt(ema20, i) && valAt(ema20, i) > valAt(ema20, i - 5);\n const goldBelow = price < valAt(ema20, i) && valAt(ema20, i) < valAt(ema20, i - 5);\n if (goldAbove && indicators.rsi < 65) return makeLong(price, atrVal * 2.5, `Gold trending up (DXY inverse)`, `Price above EMA20, EMA20 rising`);\n if (goldBelow && indicators.rsi > 35) return makeShort(price, atrVal * 2.5, `Gold trending down (DXY strong)`, `Price below EMA20, EMA20 falling`);\n break;\n }\n case \"2B-012\": { // Real Yields (proxy using price vs SMA200)\n if (price > indicators.sma200 && indicators.rsi < 60)\n return makeLong(price, atrVal * 3, `Gold above SMA200 (yields supportive)`, `Long-term uptrend intact`);\n if (price < indicators.sma200 && indicators.rsi > 40)\n return makeShort(price, atrVal * 3, `Gold below SMA200 (yields rising)`, `Long-term downtrend`);\n break;\n }\n case \"2D-013\": { // Safe Haven (proxy using ADX + RSI)\n if (indicators.adx > 20 && price > indicators.sma50 && indicators.rsi > 50)\n return makeLong(price, atrVal * 2, `Safe-haven flow detected`, `ADX rising, gold trending up`);\n if (indicators.adx > 20 && price < indicators.sma50 && indicators.rsi < 50)\n return makeShort(price, atrVal * 2, `Risk-on flow detected`, `ADX rising, gold trending down`);\n break;\n }\n case \"2E-014\": { // Geopolitical (proxy: strong trend + high volume)\n if (indicators.adx > 30 && price > indicators.sma50)\n return makeLong(price, atrVal * 3, `Geopolitical risk premium rising`, `ADX > 30, strong safe-haven bid`);\n break;\n }\n case \"2F-015\": { // Central Bank (proxy: monthly trend)\n const sma200 = SMA(closes, 200);\n const i = candles.length - 1;\n if (!isNaN(valAt(sma200, i)) && price > valAt(sma200, i) * 1.02)\n return makeLong(price, atrVal * 3, `Central bank accumulation trend`, `Price 2%+ above SMA200`);\n break;\n }\n // --- SENTIMENT ---\n case \"3A-016\": { // COT (proxy: RSI extremes)\n if (indicators.rsi > 78) return makeShort(price, atrVal * 3, `COT extreme long positioning`, `RSI ${indicators.rsi.toFixed(1)} — contrarian SHORT`);\n if (indicators.rsi < 22) return makeLong(price, atrVal * 3, `COT extreme short positioning`, `RSI ${indicators.rsi.toFixed(1)} — contrarian LONG`);\n break;\n }\n case \"3A-017\": { // Retail Contrarian (proxy: RSI + Stochastic)\n if (indicators.rsi > 72 && indicators.stochK > 80)\n return makeShort(price, atrVal * 2, `Retail sentiment extreme long`, `RSI ${indicators.rsi.toFixed(0)} + Stoch ${indicators.stochK.toFixed(0)} — contrarian SHORT`);\n if (indicators.rsi < 28 && indicators.stochK < 20)\n return makeLong(price, atrVal * 2, `Retail sentiment extreme short`, `RSI ${indicators.rsi.toFixed(0)} + Stoch ${indicators.stochK.toFixed(0)} — contrarian LONG`);\n break;\n }\n case \"3B-018\": { // Fear/Greed (proxy: BB width + RSI)\n const bbWidth = (indicators.bbUpper - indicators.bbLower) / indicators.bbMiddle;\n if (indicators.rsi < 30 && bbWidth > 0.03)\n return makeLong(price, atrVal * 2.5, `Extreme Fear detected`, `RSI ${indicators.rsi.toFixed(0)}, BB width expanded — safe haven bid`);\n if (indicators.rsi > 75 && bbWidth > 0.03)\n return makeShort(price, atrVal * 2.5, `Extreme Greed detected`, `RSI ${indicators.rsi.toFixed(0)}, BB width expanded — euphoria fade`);\n break;\n }\n case \"3B-019\": { // News Sentiment (proxy: MACD + volume)\n const { macd, signal, histogram } = MACD(closes);\n const i = candles.length - 1;\n if (valAt(histogram, i) > 0 && valAt(histogram, i) > valAt(histogram, i - 1) && valAt(macd, i) > valAt(signal, i))\n return makeLong(price, atrVal * 2, `Bullish news sentiment detected`, `MACD histogram expanding positive`);\n if (valAt(histogram, i) < 0 && valAt(histogram, i) < valAt(histogram, i - 1) && valAt(macd, i) < valAt(signal, i))\n return makeShort(price, atrVal * 2, `Bearish news sentiment detected`, `MACD histogram expanding negative`);\n break;\n }\n case \"3B-020\": { // Social Buzz (proxy: volume + price action)\n const lastVol = lastCandle.volume;\n const avgVol = candles.slice(-20).reduce((s, c) => s + c.volume, 0) / 20;\n if (lastVol > avgVol * 2 && price > prevCandle.close)\n return makeLong(price, atrVal * 1.5, `Social buzz spike — bullish`, `Volume ${(lastVol / avgVol).toFixed(1)}x average`);\n if (lastVol > avgVol * 2 && price < prevCandle.close)\n return makeShort(price, atrVal * 1.5, `Social buzz spike — bearish`, `Volume ${(lastVol / avgVol).toFixed(1)}x average`);\n break;\n }\n // --- TIMING ---\n case \"4B-021\": { // London Breakout (proxy: range breakout)\n const range = candles.slice(-12);\n const high = Math.max(...range.map(c => c.high));\n const low = Math.min(...range.map(c => c.low));\n if (price > high * 0.999 && price > prevCandle.close)\n return makeLong(price, atrVal * 1.5, `London session breakout`, `Broke session high ${high.toFixed(2)}`);\n if (price < low * 1.001 && price < prevCandle.close)\n return makeShort(price, atrVal * 1.5, `London session breakout`, `Broke session low ${low.toFixed(2)}`);\n break;\n }\n case \"4B-022\": { // NY Momentum\n const ema9 = EMA(closes, 9), ema21 = EMA(closes, 21);\n const i = candles.length - 1;\n if (valAt(ema9, i) > valAt(ema21, i) && indicators.rsi < 65 && indicators.adx > 20)\n return makeLong(price, atrVal * 1.5, `NY session momentum — bullish`, `EMA9 > EMA21, ADX > 20`);\n if (valAt(ema9, i) < valAt(ema21, i) && indicators.rsi > 35 && indicators.adx > 20)\n return makeShort(price, atrVal * 1.5, `NY session momentum — bearish`, `EMA9 < EMA21, ADX > 20`);\n break;\n }\n case \"4C-023\": { // Scalper\n const ema9 = EMA(closes, 9), ema21 = EMA(closes, 21);\n const i = candles.length - 1;\n const rsi7 = RSI(closes, 7);\n if (valAt(ema9, i) > valAt(ema21, i) && valAt(rsi7, i) < 70 && valAt(ema9, i - 1) <= valAt(ema21, i - 1))\n return makeLong(price, atrVal, `Scalp signal — EMA cross up`, `RSI7: ${valAt(rsi7, i).toFixed(1)}`);\n if (valAt(ema9, i) < valAt(ema21, i) && valAt(rsi7, i) > 30 && valAt(ema9, i - 1) >= valAt(ema21, i - 1))\n return makeShort(price, atrVal, `Scalp signal — EMA cross down`, `RSI7: ${valAt(rsi7, i).toFixed(1)}`);\n break;\n }\n case \"4D-024\": { // Swing Trader\n const i = candles.length - 1;\n const swingLow = Math.min(...candles.slice(-10, -1).map(c => c.low));\n const swingHigh = Math.max(...candles.slice(-10, -1).map(c => c.high));\n if (price > swingLow && price > indicators.sma50 && candles[i].close > candles[i].open)\n return makeLong(price, atrVal * 2, `Swing low confirmed`, `Price above swing low ${swingLow.toFixed(2)} and SMA50`);\n if (price < swingHigh && price < indicators.sma50 && candles[i].close < candles[i].open)\n return makeShort(price, atrVal * 2, `Swing high confirmed`, `Price below swing high ${swingHigh.toFixed(2)} and SMA50`);\n break;\n }\n case \"4D-025\": { // Weekly Position\n const ema20 = EMA(closes, 20);\n const i = candles.length - 1;\n const prevClose = closes[i - 1];\n if (prevClose <= valAt(ema20, i - 1) && closes[i] > valAt(ema20, i))\n return makeLong(price, atrVal * 3, `Weekly close above EMA20`, `Position trade — long-term bullish`);\n if (prevClose >= valAt(ema20, i - 1) && closes[i] < valAt(ema20, i))\n return makeShort(price, atrVal * 3, `Weekly close below EMA20`, `Position trade — long-term bearish`);\n break;\n }\n // --- SPECIAL OPS ---\n case \"5-026\": { // SMC Order Block\n // Find recent strong move candle as order block\n const lookback = candles.slice(-50, -5);\n let bullOB = 0, bearOB = Infinity;\n for (const c of lookback) {\n if (c.close - c.open > atrVal * 1.5 && c.open < bullOB * 0.999) bullOB = c.low;\n if (c.open - c.close > atrVal * 1.5 && c.open > bearOB * 1.001) bearOB = c.high;\n }\n if (bullOB > 0 && price > bullOB && price < bullOB + atrVal * 2 && indicators.rsi < 55)\n return makeLong(price, atrVal * 2, `Bullish order block respected`, `OB level: ${bullOB.toFixed(2)}`);\n if (bearOB < Infinity && price < bearOB && price > bearOB - atrVal * 2 && indicators.rsi > 45)\n return makeShort(price, atrVal * 2, `Bearish order block respected`, `OB level: ${bearOB.toFixed(2)}`);\n break;\n }\n case \"7-027\": { // FVG\n const i = candles.length - 1;\n if (i >= 2) {\n const c1 = candles[i - 2], c2 = candles[i - 1], c3 = candles[i];\n const bullFVG = c3.low > c1.high; // Gap up\n const bearFVG = c3.high < c1.low; // Gap down\n if (bullFVG && c3.close > c3.open)\n return makeLong(price, atrVal * 2, `Bullish Fair Value Gap`, `Gap: ${c1.high.toFixed(2)} to ${c3.low.toFixed(2)}`);\n if (bearFVG && c3.close < c3.open)\n return makeShort(price, atrVal * 2, `Bearish Fair Value Gap`, `Gap: ${c1.low.toFixed(2)} to ${c3.high.toFixed(2)}`);\n }\n break;\n }\n case \"8-028\": { // Risk Parity (proxy: low volatility entry)\n const atrAvg = atrVal;\n const recentRanges = candles.slice(-20).map(c => c.high - c.low);\n const avgRange = recentRanges.reduce((s, r) => s + r, 0) / recentRanges.length;\n if (atrVal < avgRange * 0.8 && price > indicators.sma50)\n return makeLong(price, atrVal * 2, `Low-vol entry — risk parity`, `ATR below average, favorable risk`);\n if (atrVal < avgRange * 0.8 && price < indicators.sma50)\n return makeShort(price, atrVal * 2, `Low-vol entry — risk parity`, `ATR below average, favorable risk`);\n break;\n }\n case \"13-029\": { // Regime Adaptive\n if (indicators.adx > 25) {\n // Trending regime — follow trend\n if (indicators.plusDI > indicators.minusDI && price > indicators.ema50)\n return makeLong(price, atrVal * 2, `Trending regime — follow trend up`, `ADX ${indicators.adx.toFixed(1)}, +DI dominant`);\n if (indicators.minusDI > indicators.plusDI && price < indicators.ema50)\n return makeShort(price, atrVal * 2, `Trending regime — follow trend down`, `ADX ${indicators.adx.toFixed(1)}, -DI dominant`);\n } else if (indicators.adx < 20) {\n // Ranging regime — fade extremes\n if (price > indicators.bbUpper * 0.999)\n return makeShort(price, indicators.bbMiddle, `Ranging regime — fade upper band`, `ADX low, mean reversion`);\n if (price < indicators.bbLower * 1.001)\n return makeLong(price, indicators.bbMiddle, `Ranging regime — fade lower band`, `ADX low, mean reversion`);\n }\n break;\n }\n case \"14-030\": { // Volatility Breakout\n const atrArr = ATR(candles, 20);\n const atrAvg = atrArr.slice(-20, -1).reduce((s, v) => s + v, 0) / 19;\n const atrNow = lastVal(atrArr);\n const contracting = atrArr.length > 5 && atrArr.slice(-5).every((v, i, arr) => i === 0 || v <= arr[i - 1]);\n if (contracting && atrNow > atrAvg * 1.5) {\n if (price > prevCandle.close)\n return makeLong(price, atrVal * 1.5, `Volatility breakout — expansion up`, `ATR ${(atrNow / atrAvg).toFixed(1)}x average after contraction`);\n if (price < prevCandle.close)\n return makeShort(price, atrVal * 1.5, `Volatility breakout — expansion down`, `ATR ${(atrNow / atrAvg).toFixed(1)}x average after contraction`);\n }\n break;\n }\n }\n return null;\n}\n\nfunction makeLong(entry: number, stopDist: number, ...details: string[]): BattalionSignal {\n const stop = entry - stopDist;\n const risk = entry - stop;\n const target1 = entry + risk * 2;\n const target2 = entry + risk * 3;\n return { direction: \"LONG\", entry, stop, target1, target2, riskReward: 2.5, details, confidence: 0.7 };\n}\n\nfunction makeShort(entry: number, stopDist: number, ...details: string[]): BattalionSignal {\n const stop = entry + stopDist;\n const risk = stop - entry;\n const target1 = entry - risk * 2;\n const target2 = entry - risk * 3;\n return { direction: \"SHORT\", entry, stop, target1, target2, riskReward: 2.5, details, confidence: 0.7 };\n}\n",[],[157,291],["D",1784661571011],[173,174,175,176,177,178,179,180,181,182,183,184],[157],["D",1784661473084],["D",1789473046147],{"_16":17,"_87":83},{"_16":17,"_80":81,"_82":83,"_33":34,"_84":85,"_86":26},{"_68":69,"_20":70,"_18":71,"_72":19,"_73":-5,"_74":-5,"_75":-5,"_76":-5,"_77":-5,"_78":21,"_79":17},"ctx",{"_61":-5,"_108":338,"_339":340,"_341":342,"_343":26,"_344":26,"_345":26,"_346":38,"_347":-5,"_348":-7,"_349":-7,"_350":42,"_351":26,"_352":26,"_353":-5,"_354":26,"_355":26,"_356":26,"_357":-5},"ENV",{"_309":310,"_311":312,"_313":70,"_314":315,"_316":317,"_318":319,"_320":321,"_322":323,"_324":325,"_326":327,"_328":329,"_330":331,"_332":333,"_334":335,"_336":337},"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"]

Search