[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_251":252,"_253":254},"routes/_app.x.$handle.$name",{"_111":110,"_38":56,"_120":101,"_33":121,"_13":14,"_122":-5,"_11":123,"_124":125,"_126":127,"_128":129,"_130":131,"_27":-5,"_132":-5,"_133":-5,"_134":31,"_135":136,"_137":31,"_138":-5,"_139":-5,"_140":141},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_54":55,"_38":56,"_44":57,"_58":-5,"_59":31,"_60":61,"_62":61,"_63":64,"_65":-5,"_19":66,"_67":68,"_69":70,"_71":-5,"_72":-5,"_73":74,"_75":76,"_77":78,"_79":80,"_81":82,"_83":-5,"_84":85,"_86":85,"_87":88,"_89":88,"_90":88,"_91":85,"_92":85,"_93":94,"_95":96,"_97":98,"_99":31},"version",8,"changes",[25,26],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","b1ec66d4-c465-4aca-8eef-a72040f859bd","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_27":49,"_29":-7,"_30":31,"_32":31,"_33":50,"_35":50},{"_27":28,"_29":-7,"_30":31,"_32":31,"_33":34,"_35":34},"file",{"_36":37,"_38":39,"_40":41,"_42":43,"_44":45,"_46":14,"_47":48,"_30":31},"previous","deleted",false,"deletedHere","path","cron/pipeline.ts","latestPath","fileId","eb58ae1a-8b1a-11f1-9fc9-1607ee4eb77e","name","pipeline.ts","fileType","interval","content","// ─── Automated Pipeline Cron Job ──────────────────────────────────────\n// Runs the full CNOS 8-stage cycle for all configured symbols on a schedule.\n// Schedule and symbols are controlled from the dashboard settings.\n\nimport { runPipeline } from \"../lib/cnos.ts\";\nimport { getSettings, saveSettings } from \"../lib/settings.ts\";\nimport { initDB } from \"../lib/db.ts\";\n\nexport default async function (interval: Interval) {\n await initDB();\n const settings = await getSettings();\n\n if (!settings.pipelineEnabled) {\n console.log(\"Pipeline is disabled — skipping run\");\n return;\n }\n\n console.log(`Pipeline run started at ${new Date().toISOString()}`);\n console.log(`Symbols: ${settings.pipelineSymbols.join(\", \")}`);\n console.log(`Timeframe: ${settings.pipelineTimeframe}`);\n console.log(`Desk: ${settings.deskId}`);\n\n const result = await runPipeline();\n\n console.log(`Pipeline complete: ${result.processed} symbols processed`);\n if (result.errors.length > 0) {\n console.log(`Errors: ${result.errors.join(\"; \")}`);\n }\n for (const r of result.results) {\n console.log(` ${r.symbol} → ${r.resolution} (proof: ${r.proofPassed}, contradictions: ${r.contradictions})`);\n }\n}\n","createdAt",["D",1785308315894],"branchVersion","branchId","7f4fd07b-175a-4243-9d9e-b81c40f32513",{"_36":51,"_38":50,"_40":52,"_42":-5,"_44":53,"_46":14,"_47":48,"_30":31},"cron","14a2dc12-cf92-4d0e-8c2d-8e10cb4dec84","directory",["D",1785308315894],"id","a9d8b9e9-d031-4c55-a731-b847098d7926","atn-cnos-bot",["D",1785307366530],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Agentic Trading Network bot with CNOS cognitive resolution layer","imageUrl","fb553982-e0f4-426a-964b-f9954390755a","pinnedFileId","686ae364-8b1b-11f1-be27-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","019fab8b-9f9e-774c-8b18-dc32359ac260","tursoName","a9d8b9e9d0314c55a731b847098d7926","tursoHostname","a9d8b9e9d0314c55a731b847098d7926-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789476648181],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_111":110,"_119":115},"org",{"_111":110,"_112":113,"_114":115,"_19":66,"_116":117,"_118":31},"branch",{"_13":100,"_38":101,"_54":48,"_102":55,"_103":-5,"_104":-5,"_105":-5,"_106":-5,"_107":-5,"_108":56,"_109":110},"isOwned",30,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","hitter2","handle","displayName","Hitter","avatar","https://lh3.googleusercontent.com/a/ACg8ocJ8jWQdlaCgat_lteLBEdqQMeHm85EOjYF-UtAmj4WyqMLMkQ=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_54":55,"_38":56,"_44":246,"_58":-5,"_59":31,"_60":61,"_62":61,"_63":64,"_65":-5,"_19":66,"_67":68,"_69":70,"_71":-5,"_72":-5,"_73":74,"_75":76,"_77":78,"_79":80,"_81":247,"_83":-5,"_84":85,"_86":85,"_87":88,"_89":88,"_90":88,"_91":85,"_92":85,"_93":248,"_95":249,"_97":250,"_99":31},"tree",[174,176,183],"files",[174,175,176,177,178,179,180,181,182,183],"counts",{"_164":74,"_165":158,"_166":74,"_167":168,"_169":170},"contents",[142,143,144],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_54":161,"_38":50,"_36":51,"_148":-5,"_47":48,"_46":14,"_150":70,"_44":162,"_13":74,"_40":52,"_42":-5,"_30":31,"_153":-5,"_33":163},{"_54":155,"_38":156,"_36":157,"_148":-5,"_47":48,"_46":158,"_150":70,"_44":159,"_13":74,"_40":52,"_42":-5,"_30":31,"_153":-5,"_33":160},{"_54":145,"_38":146,"_36":147,"_148":-5,"_47":48,"_46":149,"_150":31,"_44":151,"_13":74,"_40":27,"_42":152,"_30":31,"_153":-5,"_33":154},"3310d570-516b-4ecd-96c2-3faafa44fb51","README.md","cb48cec6-8b19-11f1-9711-1607ee4eb77e","parentId",3,"latest",["D",1785307832603],"# atn-cnos-bot","label",[146],"fa6ed36c-77e7-408a-b21f-b7e68e58f55f","lib","28a98165-a9c7-443c-a3db-b41db2dce7b9",1,["D",1785307426186],[156],"28ed7aac-99c7-4431-9761-2ef1d84e3c27",["D",1785308315894],[50],"pulls","branches","forks","envVars",{"_171":74,"_173":74},"connections",{"_171":74,"_172":74},"count","unfilledCount","emptyCount",{"_54":161,"_38":50,"_36":51,"_148":-5,"_47":48,"_46":14,"_150":70,"_44":243,"_13":74,"_40":52,"_42":-5,"_30":31,"_153":-5,"_185":244,"_33":245},{"_54":239,"_38":39,"_36":37,"_148":51,"_47":48,"_46":14,"_150":70,"_44":240,"_13":74,"_40":41,"_42":43,"_30":31,"_153":-5,"_185":241,"_33":242},{"_54":155,"_38":156,"_36":157,"_148":-5,"_47":48,"_46":158,"_150":70,"_44":236,"_13":74,"_40":52,"_42":-5,"_30":31,"_153":-5,"_185":237,"_33":238},{"_54":228,"_38":229,"_36":230,"_148":157,"_47":48,"_46":231,"_150":70,"_44":232,"_13":74,"_40":193,"_42":233,"_30":31,"_153":-5,"_185":234,"_33":235},{"_54":220,"_38":221,"_36":222,"_148":157,"_47":48,"_46":223,"_150":70,"_44":224,"_13":74,"_40":193,"_42":225,"_30":31,"_153":-5,"_185":226,"_33":227},{"_54":213,"_38":214,"_36":215,"_148":157,"_47":48,"_46":158,"_150":70,"_44":216,"_13":74,"_40":193,"_42":217,"_30":31,"_153":-5,"_185":218,"_33":219},{"_54":205,"_38":206,"_36":207,"_148":157,"_47":48,"_46":208,"_150":31,"_44":209,"_13":74,"_40":193,"_42":210,"_30":31,"_153":-5,"_185":211,"_33":212},{"_54":197,"_38":198,"_36":199,"_148":157,"_47":48,"_46":200,"_150":31,"_44":201,"_13":74,"_40":193,"_42":202,"_30":31,"_153":-5,"_185":203,"_33":204},{"_54":188,"_38":189,"_36":190,"_148":157,"_47":48,"_46":191,"_150":70,"_44":192,"_13":74,"_40":193,"_42":194,"_30":31,"_153":-5,"_185":195,"_33":196},{"_54":145,"_38":146,"_36":147,"_148":-5,"_47":48,"_46":149,"_150":31,"_44":184,"_13":74,"_40":27,"_42":152,"_30":31,"_153":-5,"_185":186,"_33":187},["D",1785307832603],"children",[],[146],"76b93934-2b92-40d7-bf36-82518acdbf3a","telegram.ts","61da3258-8b1a-11f1-8268-1607ee4eb77e",6,["D",1785308085170],"script","// ─── Telegram Notification Service ───────────────────────────────────\nimport { getSettings } from \"./settings.ts\";\n\nexport async function sendTelegramMessage(text: string): Promise {\n const settings = await getSettings();\n if (!settings.telegramEnabled || !settings.telegramBotToken || !settings.telegramChatId) {\n return false;\n }\n\n try {\n const res = await fetch(\n `https://api.telegram.org/bot${settings.telegramBotToken}/sendMessage`,\n {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n chat_id: settings.telegramChatId,\n text,\n parse_mode: \"Markdown\",\n disable_web_page_preview: true,\n }),\n },\n );\n const data = await res.json();\n return data.ok === true;\n } catch (e) {\n console.error(\"Telegram send failed:\", e);\n return false;\n }\n}\n\nexport function formatCaseMessage(c: {\n symbol: string;\n timeframe: string;\n hypothesis: string;\n conviction: number;\n resolution: string;\n meta_tags?: string[];\n}): string {\n const tags = c.meta_tags?.length ? c.meta_tags.join(\", \") : \"none\";\n const emoji = c.resolution === \"CONFIRMED\" ? \"✅\" :\n c.resolution === \"REJECTED\" ? \"❌\" :\n c.resolution === \"REFINED\" ? \"🔄\" : \"⏳\";\n return [\n `*ATN New MarketCase* ${emoji}`,\n ``,\n `*Symbol:* ${c.symbol}`,\n `*Timeframe:* ${c.timeframe}`,\n `*Conviction:* ${c.conviction}/100`,\n `*Resolution:* ${c.resolution}`,\n `*Tags:* ${tags}`,\n ``,\n `*Hypothesis:*`,\n `${c.hypothesis}`,\n ].join(\"\\n\");\n}\n\nexport function formatResolutionMessage(c: {\n symbol: string;\n resolution: string;\n resolution_reason: string;\n contradictions_resolved: number;\n}): string {\n const emoji = c.resolution === \"CONFIRMED\" ? \"✅\" :\n c.resolution === \"REJECTED\" ? \"❌\" : \"🔄\";\n return [\n `*ATN Case Resolved* ${emoji}`,\n ``,\n `*Symbol:* ${c.symbol}`,\n `*Resolution:* ${c.resolution}`,\n `*Reason:* ${c.resolution_reason}`,\n `*Contradictions resolved:* ${c.contradictions_resolved}`,\n ].join(\"\\n\");\n}\n\nexport function formatContradictionMessage(c: {\n caseSymbol: string;\n contradictionText: string;\n challengingDesk: string;\n}): string {\n return [\n `*ATN Contradiction Detected* ⚡`,\n ``,\n `*Symbol:* ${c.caseSymbol}`,\n `*Challenge from:* ${c.challengingDesk}`,\n `*Issue:* ${c.contradictionText}`,\n ].join(\"\\n\");\n}\n\nexport function formatPipelineMessage(stage: string, casesProcessed: number, details: string): string {\n return [\n `*ATN Pipeline Run* 🔄`,\n ``,\n `*Stage:* ${stage}`,\n `*Cases processed:* ${casesProcessed}`,\n `*Details:* ${details}`,\n ].join(\"\\n\");\n}\n\nexport function formatErrorMessage(error: string): string {\n return [\n `*ATN Error* 🚨`,\n ``,\n `${error}`,\n ].join(\"\\n\");\n}\n\nexport async function notifyNewCase(c: any): Promise {\n const settings = await getSettings();\n if (settings.notifyOnNewCase) {\n await sendTelegramMessage(formatCaseMessage(c));\n }\n}\n\nexport async function notifyResolution(c: any): Promise {\n const settings = await getSettings();\n if (settings.notifyOnResolution) {\n await sendTelegramMessage(formatResolutionMessage(c));\n }\n}\n\nexport async function notifyContradiction(c: any): Promise {\n const settings = await getSettings();\n if (settings.notifyOnContradiction) {\n await sendTelegramMessage(formatContradictionMessage(c));\n }\n}\n\nexport async function notifyPipelineRun(stage: string, casesProcessed: number, details: string): Promise {\n await sendTelegramMessage(formatPipelineMessage(stage, casesProcessed, details));\n}\n\nexport async function notifyError(error: string): Promise {\n const settings = await getSettings();\n if (settings.notifyOnError) {\n await sendTelegramMessage(formatErrorMessage(error));\n }\n}\n",[],[156,189],"5b6c62ba-c256-4ff2-9f7a-3b0a1f78d478","settings.ts","61d274be-8b1a-11f1-a22c-1607ee4eb77e",5,["D",1785308085169],"// ─── Settings System ─────────────────────────────────────────────────\n// Settings stored in blob storage, editable from the dashboard.\n\nimport { blob } from \"https://esm.town/v/std/blob/main.ts\";\n\nexport interface ATNSettings {\n // Telegram\n telegramBotToken: string;\n telegramChatId: string;\n telegramEnabled: boolean;\n\n // Pipeline\n pipelineEnabled: boolean;\n pipelineSymbols: string[];\n pipelineTimeframe: string;\n pipelineIntervalMinutes: number;\n\n // Desk\n deskId: string;\n autoGenerateCases: boolean;\n autoResolve: boolean;\n minConfidenceForCase: number;\n contradictionsRequired: number;\n\n // Notifications\n notifyOnNewCase: boolean;\n notifyOnResolution: boolean;\n notifyOnContradiction: boolean;\n notifyOnError: boolean;\n\n // Network\n networkName: string;\n vertical: string;\n}\n\nconst DEFAULT_SETTINGS: ATNSettings = {\n telegramBotToken: \"\",\n telegramChatId: \"\",\n telegramEnabled: false,\n\n pipelineEnabled: false,\n pipelineSymbols: [\"BTC\", \"ETH\", \"SPY\", \"EURUSD\", \"GOLD\"],\n pipelineTimeframe: \"4H\",\n pipelineIntervalMinutes: 60,\n\n deskId: \"desk_alpha_01\",\n autoGenerateCases: true,\n autoResolve: true,\n minConfidenceForCase: 50,\n contradictionsRequired: 2,\n\n notifyOnNewCase: true,\n notifyOnResolution: true,\n notifyOnContradiction: true,\n notifyOnError: true,\n\n networkName: \"ATN\",\n vertical: \"trading\",\n};\n\nconst SETTINGS_KEY = \"atn_settings\";\n\nexport async function getSettings(): Promise {\n const data = await blob.getJSON(SETTINGS_KEY);\n if (!data) return DEFAULT_SETTINGS;\n return { ...DEFAULT_SETTINGS, ...data };\n}\n\nexport async function saveSettings(settings: Partial): Promise {\n const current = await getSettings();\n const updated = { ...current, ...settings };\n await blob.setJSON(SETTINGS_KEY, updated);\n return updated;\n}\n\nexport async function resetSettings(): Promise {\n await blob.setJSON(SETTINGS_KEY, DEFAULT_SETTINGS);\n return DEFAULT_SETTINGS;\n}\n",[],[156,198],"5f3754be-e7d6-4771-bd82-eca67f95ea0d","market-data.ts","0fdafa6a-8b19-11f1-9c9d-1607ee4eb77e",2,["D",1785307518151],"// ─── Market Data Fetcher ─────────────────────────────────────────────\n// Uses free public APIs (Yahoo Finance, Stooq) for market data.\n// No API key required.\n\nconst YF_BASE = \"https://query1.finance.yahoo.com/v8/finance\";\nconst YF_CHART = \"https://query1.finance.yahoo.com/v8/finance/chart\";\n\n// Symbol normalization map\nconst SYMBOL_MAP: Record = {\n \"BTC\": \"BTC-USD\",\n \"BTCUSDT\": \"BTC-USD\",\n \"XBT\": \"BTC-USD\",\n \"ETH\": \"ETH-USD\",\n \"ETHUSDT\": \"ETH-USD\",\n \"SOL\": \"SOL-USD\",\n \"SOLUSDT\": \"SOL-USD\",\n \"EURUSD\": \"EURUSD=X\",\n \"GBPUSD\": \"GBPUSD=X\",\n \"USDJPY\": \"USDJPY=X\",\n \"XAUUSD\": \"GC=F\",\n \"GOLD\": \"GC=F\",\n \"SPX\": \"^GSPC\",\n \"SP500\": \"^GSPC\",\n \"NASDAQ\": \"^IXIC\",\n \"DOW\": \"^DJI\",\n \"DXY\": \"DX-Y.NYB\",\n \"VIX\": \"^VIX\",\n \"WTI\": \"CL=F\",\n \"OIL\": \"CL=F\",\n \"TENYEAR\": \"^TNX\",\n \"2YR\": \"^FVX\",\n};\n\nexport function normalizeSymbol(symbol: string): string {\n const upper = symbol.toUpperCase().trim();\n return SYMBOL_MAP[upper] ?? upper;\n}\n\nexport function timeframeToInterval(tf: string): { interval: string; range: string } {\n const map: Record = {\n \"1m\": { interval: \"1m\", range: \"1d\" },\n \"5m\": { interval: \"5m\", range: \"5d\" },\n \"15m\": { interval: \"15m\", range: \"1mo\" },\n \"1H\": { interval: \"60m\", range: \"3mo\" },\n \"4H\": { interval: \"1h\", range: \"6mo\" },\n \"1D\": { interval: \"1d\", range: \"1y\" },\n \"1W\": { interval: \"1wk\", range: \"2y\" },\n \"1M\": { interval: \"1mo\", range: \"5y\" },\n };\n return map[tf] ?? { interval: \"1d\", range: \"6mo\" };\n}\n\n// ─── Tool: search_symbols ────────────────────────────────────────────\nexport async function searchSymbols(query: string): Promise {\n try {\n const res = await fetch(\n `${YF_BASE}/search?q=${encodeURIComponent(query)}"esCount=10&newsCount=0`,\n { headers: { \"User-Agent\": \"Mozilla/5.0\" } },\n );\n const data = await res.json();\n return (data.quotes || []).map((q: any) => ({\n symbol: q.symbol,\n name: q.shortname || q.longname || q.symbol,\n exchange: q.exchange,\n type: q.quoteType,\n region: q.region ?? \"US\",\n }));\n } catch (e) {\n return [{ error: `Search failed: ${e.message}` }];\n }\n}\n\n// ─── Tool: get_quote ─────────────────────────────────────────────────\nexport async function getQuote(symbol: string): Promise {\n try {\n const sym = normalizeSymbol(symbol);\n const res = await fetch(\n `https://query1.finance.yahoo.com/v7/finance/quote?symbols=${encodeURIComponent(sym)}`,\n { headers: { \"User-Agent\": \"Mozilla/5.0\" } },\n );\n const data = await res.json();\n const q = data.quoteResponse?.result?.[0];\n if (!q) return { error: `No quote found for ${symbol}` };\n return {\n symbol: q.symbol,\n name: q.shortName ?? q.longName ?? q.symbol,\n price: q.regularMarketPrice,\n change: q.regularMarketChange,\n changePercent: q.regularMarketChangePercent,\n previousClose: q.regularMarketPreviousClose,\n open: q.regularMarketOpen,\n high: q.regularMarketDayHigh,\n low: q.regularMarketDayLow,\n volume: q.regularMarketVolume,\n marketCap: q.marketCap,\n currency: q.currency,\n };\n } catch (e) {\n return { error: `Quote failed: ${e.message}` };\n }\n}\n\n// ─── Tool: get_quotes_batch ──────────────────────────────────────────\nexport async function getQuotesBatch(symbols: string[]): Promise {\n const results = await Promise.all(symbols.map((s) => getQuote(s)));\n return results;\n}\n\n// ─── Tool: get_ohlcv ─────────────────────────────────────────────────\nexport async function getOHLCV(\n symbol: string,\n timeframe: string = \"1D\",\n limit: number = 100,\n): Promise {\n try {\n const sym = normalizeSymbol(symbol);\n const { interval, range } = timeframeToInterval(timeframe);\n const url = `${YF_CHART}/${encodeURIComponent(sym)}?interval=${interval}&range=${range}&includePrePost=false`;\n const res = await fetch(url, { headers: { \"User-Agent\": \"Mozilla/5.0\" } });\n const data = await res.json();\n const result = data.chart?.result?.[0];\n if (!result) return { error: `No OHLCV data for ${symbol}` };\n\n const timestamps = result.timestamp || [];\n const quotes = result.indicators?.quote?.[0] || {};\n const bars = [];\n const startIdx = Math.max(0, timestamps.length - limit);\n for (let i = startIdx; i < timestamps.length; i++) {\n if (quotes.open?.[i] != null) {\n bars.push({\n timestamp: new Date(timestamps[i] * 1000).toISOString(),\n open: quotes.open[i],\n high: quotes.high[i],\n low: quotes.low[i],\n close: quotes.close[i],\n volume: quotes.volume?.[i] ?? 0,\n });\n }\n }\n return { symbol: sym, timeframe, bars, count: bars.length };\n } catch (e) {\n return { error: `OHLCV failed: ${e.message}` };\n }\n}\n\n// ─── Tool: get_technicals ────────────────────────────────────────────\nexport async function getTechnicals(symbol: string, timeframe: string = \"1D\"): Promise {\n try {\n const ohlcv = await getOHLCV(symbol, timeframe, 200);\n if (ohlcv.error) return ohlcv;\n const bars = ohlcv.bars;\n const closes = bars.map((b: any) => b.close);\n const highs = bars.map((b: any) => b.high);\n const lows = bars.map((b: any) => b.low);\n const volumes = bars.map((b: any) => b.volume);\n\n const last = closes[closes.length - 1];\n\n // Simple Moving Averages\n const sma = (period: number) => {\n if (closes.length < period) return null;\n const slice = closes.slice(-period);\n return slice.reduce((a: number, b: number) => a + b, 0) / period;\n };\n // Exponential Moving Averages\n const ema = (period: number) => {\n if (closes.length < period) return null;\n const k = 2 / (period + 1);\n let emaVal = closes.slice(0, period).reduce((a: number, b: number) => a + b, 0) / period;\n for (let i = period; i < closes.length; i++) {\n emaVal = closes[i] * k + emaVal * (1 - k);\n }\n return emaVal;\n };\n // RSI\n const rsi = (period: number = 14) => {\n if (closes.length < period + 1) return null;\n let gains = 0, losses = 0;\n for (let i = closes.length - period; i < closes.length; i++) {\n const diff = closes[i] - closes[i - 1];\n if (diff > 0) gains += diff; else losses -= diff;\n }\n const avgGain = gains / period;\n const avgLoss = losses / period;\n if (avgLoss === 0) return 100;\n const rs = avgGain / avgLoss;\n return 100 - (100 / (1 + rs));\n };\n // MACD\n const macd = () => {\n const ema12 = ema(12);\n const ema26 = ema(26);\n if (!ema12 || !ema26) return null;\n const macdLine = ema12 - ema26;\n const signalLine = macdLine * 0.9; // simplified\n return { macd: macdLine, signal: signalLine, histogram: macdLine - signalLine };\n };\n // Bollinger Bands\n const bollinger = (period: number = 20) => {\n if (closes.length < period) return null;\n const slice = closes.slice(-period);\n const smaVal = slice.reduce((a: number, b: number) => a + b, 0) / period;\n const variance = slice.reduce((a: number, b: number) => a + (b - smaVal) ** 2, 0) / period;\n const std = Math.sqrt(variance);\n return {\n middle: smaVal,\n upper: smaVal + 2 * std,\n lower: smaVal - 2 * std,\n };\n };\n // ATR\n const atr = (period: number = 14) => {\n if (bars.length < period + 1) return null;\n let trSum = 0;\n for (let i = bars.length - period; i < bars.length; i++) {\n const tr = Math.max(\n highs[i] - lows[i],\n Math.abs(highs[i] - closes[i - 1]),\n Math.abs(lows[i] - closes[i - 1]),\n );\n trSum += tr;\n }\n return trSum / period;\n };\n // Stochastic\n const stoch = (period: number = 14) => {\n if (bars.length < period) return null;\n const slice = bars.slice(-period);\n const highestHigh = Math.max(...slice.map((b: any) => b.high));\n const lowestLow = Math.min(...slice.map((b: any) => b.low));\n const currentClose = closes[closes.length - 1];\n if (highestHigh === lowestLow) return { k: 50, d: 50 };\n const k = ((currentClose - lowestLow) / (highestHigh - lowestLow)) * 100;\n return { k, d: k * 0.9 };\n };\n // ADX (simplified)\n const adx = (period: number = 14) => {\n if (bars.length < period * 2) return null;\n let plusDM = 0, minusDM = 0, tr = 0;\n for (let i = bars.length - period; i < bars.length; i++) {\n const upMove = highs[i] - highs[i - 1];\n const downMove = lows[i - 1] - lows[i];\n if (upMove > downMove && upMove > 0) plusDM += upMove;\n if (downMove > upMove && downMove > 0) minusDM += downMove;\n tr += Math.max(highs[i] - lows[i], Math.abs(highs[i] - closes[i - 1]));\n }\n const di_plus = (plusDM / tr) * 100;\n const di_minus = (minusDM / tr) * 100;\n const dx = Math.abs(di_plus - di_minus) / (di_plus + di_minus) * 100;\n return dx;\n };\n\n return {\n symbol: ohlcv.symbol,\n timeframe,\n lastPrice: last,\n indicators: {\n sma: { sma20: sma(20), sma50: sma(50), sma200: sma(200) },\n ema: { ema12: ema(12), ema20: ema(20), ema50: ema(50), ema200: ema(200) },\n rsi: rsi(14),\n macd: macd(),\n bollinger: bollinger(20),\n atr: atr(14),\n stochastic: stoch(14),\n adx: adx(14),\n volume: volumes[volumes.length - 1],\n avgVolume20: volumes.slice(-20).reduce((a: number, b: number) => a + b, 0) / Math.min(20, volumes.length),\n },\n };\n } catch (e) {\n return { error: `Technicals failed: ${e.message}` };\n }\n}\n\n// ─── Tool: get_technicals_rating ─────────────────────────────────────\nexport async function getTechnicalsRating(symbol: string, timeframe: string = \"1D\"): Promise {\n const tech = await getTechnicals(symbol, timeframe);\n if (tech.error) return tech;\n\n const i = tech.indicators;\n let buySignals = 0;\n let sellSignals = 0;\n const breakdown: any[] = [];\n\n // RSI\n if (i.rsi != null) {\n if (i.rsi < 30) { buySignals++; breakdown.push({ indicator: \"RSI\", signal: \"BUY\", value: i.rsi }); }\n else if (i.rsi > 70) { sellSignals++; breakdown.push({ indicator: \"RSI\", signal: \"SELL\", value: i.rsi }); }\n else breakdown.push({ indicator: \"RSI\", signal: \"NEUTRAL\", value: i.rsi });\n }\n // MACD\n if (i.macd) {\n if (i.macd.histogram > 0) { buySignals++; breakdown.push({ indicator: \"MACD\", signal: \"BUY\", value: i.macd.histogram }); }\n else { sellSignals++; breakdown.push({ indicator: \"MACD\", signal: \"SELL\", value: i.macd.histogram }); }\n }\n // EMA\n if (i.ema.ema20 && i.ema.ema50) {\n if (i.ema.ema20 > i.ema.ema50) { buySignals++; breakdown.push({ indicator: \"EMA20/50\", signal: \"BUY\", value: i.ema.ema20 }); }\n else { sellSignals++; breakdown.push({ indicator: \"EMA20/50\", signal: \"SELL\", value: i.ema.ema20 }); }\n }\n // Price vs SMA200\n if (i.sma.sma200) {\n if (tech.lastPrice > i.sma.sma200) { buySignals++; breakdown.push({ indicator: \"Price vs SMA200\", signal: \"BUY\", value: i.sma.sma200 }); }\n else { sellSignals++; breakdown.push({ indicator: \"Price vs SMA200\", signal: \"SELL\", value: i.sma.sma200 }); }\n }\n // Stochastic\n if (i.stochastic) {\n if (i.stochastic.k < 20) { buySignals++; breakdown.push({ indicator: \"Stochastic\", signal: \"BUY\", value: i.stochastic.k }); }\n else if (i.stochastic.k > 80) { sellSignals++; breakdown.push({ indicator: \"Stochastic\", signal: \"SELL\", value: i.stochastic.k }); }\n else breakdown.push({ indicator: \"Stochastic\", signal: \"NEUTRAL\", value: i.stochastic.k });\n }\n\n const total = buySignals + sellSignals;\n const rating = buySignals > sellSignals ? \"BUY\" : sellSignals > buySignals ? \"SELL\" : \"NEUTRAL\";\n const score = total > 0 ? Math.round((buySignals / total) * 100) : 50;\n\n return {\n symbol: tech.symbol,\n timeframe,\n rating,\n score,\n buySignals,\n sellSignals,\n breakdown,\n };\n}\n\n// ─── Tool: analyze_multi_timeframe ───────────────────────────────────\nexport async function analyzeMultiTimeframe(symbol: string): Promise {\n const timeframes = [\"15m\", \"1H\", \"4H\", \"1D\"];\n const results = await Promise.all(\n timeframes.map(async (tf) => {\n const rating = await getTechnicalsRating(symbol, tf);\n return { timeframe: tf, ...rating };\n }),\n );\n\n const validResults = results.filter((r) => !r.error);\n const buyCount = validResults.filter((r) => r.rating === \"BUY\").length;\n const sellCount = validResults.filter((r) => r.rating === \"SELL\").length;\n\n const alignmentScore = validResults.length > 0\n ? Math.round((Math.max(buyCount, sellCount) / validResults.length) * 100)\n : 0;\n\n const bias = buyCount > sellCount ? \"BULLISH\" : sellCount > buyCount ? \"BEARISH\" : \"MIXED\";\n\n return {\n symbol,\n bias,\n alignmentScore,\n buyCount,\n sellCount,\n timeframeDetails: validResults.map((r) => ({\n timeframe: r.timeframe,\n rating: r.rating,\n score: r.score,\n })),\n };\n}\n\n// ─── Tool: compute_levels ────────────────────────────────────────────\nexport async function computeLevels(symbol: string, timeframe: string = \"1D\"): Promise {\n const ohlcv = await getOHLCV(symbol, timeframe, 100);\n if (ohlcv.error) return ohlcv;\n const bars = ohlcv.bars;\n if (bars.length < 10) return { error: \"Not enough data for levels\" };\n\n // Swing highs and lows (lookback of 5 bars)\n const swingHighs: any[] = [];\n const swingLows: any[] = [];\n const lookback = 5;\n for (let i = lookback; i < bars.length - lookback; i++) {\n const isSwingHigh = bars.slice(i - lookback, i + lookback + 1).every(\n (b: any, idx: number) => idx === lookback || b.high <= bars[i].high,\n );\n const isSwingLow = bars.slice(i - lookback, i + lookback + 1).every(\n (b: any, idx: number) => idx === lookback || b.low >= bars[i].low,\n );\n if (isSwingHigh) swingHighs.push({ index: i, price: bars[i].high, timestamp: bars[i].timestamp });\n if (isSwingLow) swingLows.push({ index: i, price: bars[i].low, timestamp: bars[i].timestamp });\n }\n\n const lastPrice = bars[bars.length - 1].close;\n const resistanceLevels = swingHighs.slice(-5).map((s) => s.price);\n const supportLevels = swingLows.slice(-5).map((s) => s.price);\n\n // Recent range for premium/discount\n const recentBars = bars.slice(-50);\n const rangeHigh = Math.max(...recentBars.map((b: any) => b.high));\n const rangeLow = Math.min(...recentBars.map((b: any) => b.low));\n const range = rangeHigh - rangeLow;\n const fib50 = rangeLow + range * 0.5;\n const equilibrium = lastPrice > fib50 ? \"PREMIUM\" : \"DISCOUNT\";\n\n // FVG detection (simplified)\n const fvgs: any[] = [];\n for (let i = 2; i < bars.length; i++) {\n const gap = bars[i].low - bars[i - 2].high;\n if (gap > 0) {\n fvgs.push({ index: i, top: bars[i].low, bottom: bars[i - 2].high });\n }\n }\n\n return {\n symbol: ohlcv.symbol,\n timeframe,\n lastPrice,\n supportLevels,\n resistanceLevels,\n swingHighs: swingHighs.slice(-5).map((s) => ({ price: s.price, timestamp: s.timestamp })),\n swingLows: swingLows.slice(-5).map((s) => ({ price: s.price, timestamp: s.timestamp })),\n range: { high: rangeHigh, low: rangeLow, fib50, equilibrium },\n fairValueGaps: fvgs.slice(-3),\n };\n}\n\n// ─── Tool: get_news ──────────────────────────────────────────────────\nexport async function getNews(symbol: string): Promise {\n try {\n const res = await fetch(\n `${YF_BASE}/search?q=${encodeURIComponent(normalizeSymbol(symbol))}"esCount=0&newsCount=5`,\n { headers: { \"User-Agent\": \"Mozilla/5.0\" } },\n );\n const data = await res.json();\n return (data.news || []).map((n: any) => ({\n title: n.title,\n publisher: n.publisher,\n url: n.link,\n publishedAt: new Date(n.providerPublishTime * 1000).toISOString(),\n type: n.type,\n }));\n } catch (e) {\n return { error: `News failed: ${e.message}` };\n }\n}\n\n// ─── Tool: run_screener (simplified) ─────────────────────────────────\nexport async function runScreener(symbols: string[], condition: string): Promise {\n const results = await Promise.all(\n symbols.map(async (sym) => {\n const tech = await getTechnicals(sym, \"1D\");\n if (tech.error) return { symbol: sym, error: tech.error };\n return {\n symbol: sym,\n lastPrice: tech.lastPrice,\n rsi: tech.indicators.rsi,\n ema20: tech.indicators.ema.ema20,\n ema50: tech.indicators.ema.ema50,\n sma200: tech.indicators.sma.sma200,\n macdHistogram: tech.indicators.macd?.histogram,\n adx: tech.indicators.adx,\n };\n }),\n );\n\n // Simple condition matching\n return results.filter((r) => {\n if (r.error) return false;\n const lower = condition.toLowerCase();\n if (lower.includes(\"rsi > 50\")) return r.rsi != null && r.rsi > 50;\n if (lower.includes(\"rsi < 30\")) return r.rsi != null && r.rsi < 30;\n if (lower.includes(\"rsi > 70\")) return r.rsi != null && r.rsi > 70;\n if (lower.includes(\"close above ema200\") || lower.includes(\"close > ema200\")) {\n return r.sma200 != null && r.lastPrice > r.sma200;\n }\n if (lower.includes(\"ema20 > ema50\")) return r.ema20 != null && r.ema50 != null && r.ema20 > r.ema50;\n if (lower.includes(\"adx > 20\")) return r.adx != null && r.adx > 20;\n return true; // no filter → return all\n });\n}\n\n// ─── Tool: compare_symbols ───────────────────────────────────────────\nexport async function compareSymbols(symbols: string[]): Promise {\n const quotes = await getQuotesBatch(symbols);\n const technicals = await Promise.all(\n symbols.map((s) => getTechnicalsRating(s, \"1D\")),\n );\n return symbols.map((sym, i) => ({\n symbol: sym,\n quote: quotes[i],\n rating: technicals[i].rating,\n score: technicals[i].score,\n }));\n}\n\n// ─── Tool: calculate_correlation ─────────────────────────────────────\nexport async function calculateCorrelation(symbols: string[], timeframe: string = \"1D\"): Promise {\n const ohlcvData = await Promise.all(\n symbols.map((s) => getOHLCV(s, timeframe, 60)),\n );\n\n const logReturns: Record = {};\n symbols.forEach((sym, i) => {\n const data = ohlcvData[i];\n if (data.error) return;\n const closes = data.bars.map((b: any) => b.close);\n const returns: number[] = [];\n for (let j = 1; j < closes.length; j++) {\n returns.push(Math.log(closes[j] / closes[j - 1]));\n }\n logReturns[sym] = returns;\n });\n\n const matrix: Record> = {};\n for (const s1 of symbols) {\n matrix[s1] = {};\n for (const s2 of symbols) {\n const r1 = logReturns[s1];\n const r2 = logReturns[s2];\n if (!r1 || !r2) { matrix[s1][s2] = null; continue; }\n const minLen = Math.min(r1.length, r2.length);\n const mean1 = r1.slice(0, minLen).reduce((a: number, b: number) => a + b, 0) / minLen;\n const mean2 = r2.slice(0, minLen).reduce((a: number, b: number) => a + b, 0) / minLen;\n let cov = 0, var1 = 0, var2 = 0;\n for (let j = 0; j < minLen; j++) {\n const d1 = r1[j] - mean1;\n const d2 = r2[j] - mean2;\n cov += d1 * d2;\n var1 += d1 * d1;\n var2 += d2 * d2;\n }\n matrix[s1][s2] = (var1 > 0 && var2 > 0) ? cov / Math.sqrt(var1 * var2) : 0;\n }\n }\n return { symbols, timeframe, correlationMatrix: matrix };\n}\n",[],[156,206],"7869c454-5e13-4aa0-9a35-f18da687caaf","db.ts","d90a4dec-8b18-11f1-a7df-1607ee4eb77e",["D",1785307426186],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n// ─── Schema Initialization ───────────────────────────────────────────\nexport async function initDB() {\n await sqlite.batch([\n {\n sql: `CREATE TABLE IF NOT EXISTS observations (\n id TEXT PRIMARY KEY,\n desk_id TEXT NOT NULL,\n agent_type TEXT NOT NULL,\n symbol TEXT NOT NULL,\n timeframe TEXT NOT NULL,\n observation_type TEXT NOT NULL,\n data_payload TEXT NOT NULL,\n confidence INTEGER DEFAULT 50,\n privacy_class TEXT DEFAULT 'shared',\n provenance TEXT,\n created_at TEXT DEFAULT (datetime('now'))\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS market_cases (\n id TEXT PRIMARY KEY,\n vertical TEXT DEFAULT 'ATN',\n domain TEXT DEFAULT 'trading',\n symbol TEXT NOT NULL,\n timeframe TEXT NOT NULL,\n hypothesis TEXT NOT NULL,\n expected_outcome TEXT,\n reasoning TEXT,\n invalidation_level TEXT,\n conviction INTEGER DEFAULT 50,\n time_horizon TEXT,\n meta_tags TEXT,\n evidence TEXT,\n resolution TEXT DEFAULT 'PENDING',\n resolution_reason TEXT,\n contradictions_resolved INTEGER DEFAULT 0,\n reuse_count INTEGER DEFAULT 0,\n contributors TEXT,\n confidence_history TEXT,\n outcome_hit_target INTEGER,\n outcome_rr_ratio REAL,\n follow_up_case TEXT,\n proof_artifact TEXT,\n created_at TEXT DEFAULT (datetime('now')),\n resolved_at TEXT\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS contradictions (\n id TEXT PRIMARY KEY,\n case_id TEXT NOT NULL,\n challenging_case_id TEXT,\n challenging_desk_id TEXT,\n contradiction_text TEXT NOT NULL,\n status TEXT DEFAULT 'OPEN',\n created_at TEXT DEFAULT (datetime('now')),\n resolved_at TEXT\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS resolved_memory (\n id TEXT PRIMARY KEY,\n case_id TEXT NOT NULL UNIQUE,\n embedding_key TEXT,\n reuse_count INTEGER DEFAULT 0,\n created_at TEXT DEFAULT (datetime('now'))\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS desks (\n id TEXT PRIMARY KEY,\n handle TEXT,\n agents_config TEXT,\n reputation INTEGER DEFAULT 100,\n contributions INTEGER DEFAULT 0,\n resolutions_correct INTEGER DEFAULT 0,\n resolutions_wrong INTEGER DEFAULT 0,\n created_at TEXT DEFAULT (datetime('now')),\n last_active TEXT\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS pipeline_runs (\n id TEXT PRIMARY KEY,\n stage TEXT NOT NULL,\n status TEXT NOT NULL,\n details TEXT,\n cases_processed INTEGER DEFAULT 0,\n created_at TEXT DEFAULT (datetime('now'))\n )`,\n },\n {\n sql: `CREATE INDEX IF NOT EXISTS idx_observations_symbol ON observations(symbol)`,\n },\n {\n sql: `CREATE INDEX IF NOT EXISTS idx_cases_symbol ON market_cases(symbol)`,\n },\n {\n sql: `CREATE INDEX IF NOT EXISTS idx_cases_resolution ON market_cases(resolution)`,\n },\n {\n sql: `CREATE INDEX IF NOT EXISTS idx_contradictions_case ON contradictions(case_id)`,\n },\n ]);\n}\n\n// ─── Helpers ─────────────────────────────────────────────────────────\nexport function uuid(): string {\n return crypto.randomUUID();\n}\n\nexport async function createObservation(obs: {\n desk_id: string;\n agent_type: string;\n symbol: string;\n timeframe: string;\n observation_type: string;\n data_payload: any;\n confidence?: number;\n privacy_class?: string;\n provenance?: string;\n}) {\n const id = uuid();\n await sqlite.execute({\n sql: `INSERT INTO observations (id, desk_id, agent_type, symbol, timeframe, observation_type, data_payload, confidence, privacy_class, provenance)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n id,\n obs.desk_id,\n obs.agent_type,\n obs.symbol,\n obs.timeframe,\n obs.observation_type,\n JSON.stringify(obs.data_payload),\n obs.confidence ?? 50,\n obs.privacy_class ?? \"shared\",\n obs.provenance ?? null,\n ],\n });\n return id;\n}\n\nexport async function createMarketCase(c: {\n desk_id: string;\n symbol: string;\n timeframe: string;\n hypothesis: string;\n expected_outcome?: string;\n reasoning?: string;\n invalidation_level?: string;\n conviction?: number;\n time_horizon?: string;\n meta_tags?: string[];\n evidence?: string[];\n proof_artifact?: string;\n}) {\n const id = uuid();\n const contributors = JSON.stringify([c.desk_id]);\n const confidence_history = JSON.stringify([\n { timestamp: new Date().toISOString(), score: c.conviction ?? 50, source: \"initial\" },\n ]);\n await sqlite.execute({\n sql: `INSERT INTO market_cases (id, symbol, timeframe, hypothesis, expected_outcome, reasoning,\n invalidation_level, conviction, time_horizon, meta_tags, evidence, contributors,\n confidence_history, proof_artifact)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n id,\n c.symbol,\n c.timeframe,\n c.hypothesis,\n c.expected_outcome ?? null,\n c.reasoning ?? null,\n c.invalidation_level ?? null,\n c.conviction ?? 50,\n c.time_horizon ?? null,\n c.meta_tags ? JSON.stringify(c.meta_tags) : null,\n c.evidence ? JSON.stringify(c.evidence) : null,\n contributors,\n confidence_history,\n c.proof_artifact ?? null,\n ],\n });\n return id;\n}\n\nexport async function updateCaseResolution(\n caseId: string,\n resolution: string,\n reason: string,\n) {\n await sqlite.execute({\n sql: `UPDATE market_cases SET resolution = ?, resolution_reason = ?, resolved_at = datetime('now')\n WHERE id = ?`,\n args: [resolution, reason, caseId],\n });\n if (resolution === \"CONFIRMED\" || resolution === \"REJECTED\") {\n await sqlite.execute({\n sql: `INSERT OR REPLACE INTO resolved_memory (id, case_id, embedding_key)\n VALUES (?, ?, ?)`,\n args: [uuid(), caseId, `embed_${caseId}`],\n });\n }\n}\n\nexport async function addContradiction(\n caseId: string,\n challengingDeskId: string,\n text: string,\n challengingCaseId?: string,\n) {\n const id = uuid();\n await sqlite.execute({\n sql: `INSERT INTO contradictions (id, case_id, challenging_case_id, challenging_desk_id, contradiction_text)\n VALUES (?, ?, ?, ?, ?)`,\n args: [id, caseId, challengingCaseId ?? null, challengingDeskId, text],\n });\n await sqlite.execute({\n sql: `UPDATE market_cases SET contradictions_resolved = contradictions_resolved + 1 WHERE id = ?`,\n args: [caseId],\n });\n return id;\n}\n\nexport async function incrementReuse(caseId: string) {\n await sqlite.execute({\n sql: `UPDATE market_cases SET reuse_count = reuse_count + 1 WHERE id = ?`,\n args: [caseId],\n });\n await sqlite.execute({\n sql: `UPDATE resolved_memory SET reuse_count = reuse_count + 1 WHERE case_id = ?`,\n args: [caseId],\n });\n}\n\nexport async function getStats() {\n const [members, agents, cases, memoryObjects, observations, confirmed, rejected, pending] =\n await Promise.all([\n sqlite.execute(\"SELECT COUNT(*) as c FROM desks\"),\n sqlite.execute(\"SELECT COUNT(DISTINCT agent_type) as c FROM observations\"),\n sqlite.execute(\"SELECT COUNT(*) as c FROM market_cases\"),\n sqlite.execute(\"SELECT COUNT(*) as c FROM resolved_memory\"),\n sqlite.execute(\"SELECT COUNT(*) as c FROM observations\"),\n sqlite.execute(\"SELECT COUNT(*) as c FROM market_cases WHERE resolution = 'CONFIRMED'\"),\n sqlite.execute(\"SELECT COUNT(*) as c FROM market_cases WHERE resolution = 'REJECTED'\"),\n sqlite.execute(\"SELECT COUNT(*) as c FROM market_cases WHERE resolution = 'PENDING'\"),\n ]);\n return {\n members: (members.rows[0] as any)?.c ?? 0,\n agents: Math.max((agents.rows[0] as any)?.c ?? 0, 6),\n cases: (cases.rows[0] as any)?.c ?? 0,\n memoryObjects: (memoryObjects.rows[0] as any)?.c ?? 0,\n observations: (observations.rows[0] as any)?.c ?? 0,\n confirmed: (confirmed.rows[0] as any)?.c ?? 0,\n rejected: (rejected.rows[0] as any)?.c ?? 0,\n pending: (pending.rows[0] as any)?.c ?? 0,\n };\n}\n\nexport async function logPipelineRun(stage: string, status: string, details: string, casesProcessed: number) {\n await sqlite.execute({\n sql: `INSERT INTO pipeline_runs (id, stage, status, details, cases_processed)\n VALUES (?, ?, ?, ?, ?)`,\n args: [uuid(), stage, status, details, casesProcessed],\n });\n}\n\nexport async function getRecentCases(limit: number = 10) {\n const result = await sqlite.execute({\n sql: `SELECT * FROM market_cases ORDER BY created_at DESC LIMIT ?`,\n args: [limit],\n });\n return result.rows.map((r) => ({\n ...r,\n meta_tags: r.meta_tags ? JSON.parse(r.meta_tags as string) : [],\n contributors: r.contributors ? JSON.parse(r.contributors as string) : [],\n })) as any[];\n}\n\nexport async function getRecentPipelineRuns(limit: number = 20) {\n const result = await sqlite.execute({\n sql: `SELECT * FROM pipeline_runs ORDER BY created_at DESC LIMIT ?`,\n args: [limit],\n });\n return result.rows as any[];\n}\n\nexport async function getCasesByResolution(resolution: string) {\n const result = await sqlite.execute({\n sql: `SELECT * FROM market_cases WHERE resolution = ? ORDER BY created_at DESC`,\n args: [resolution],\n });\n return result.rows.map((r) => ({\n ...r,\n meta_tags: r.meta_tags ? JSON.parse(r.meta_tags as string) : [],\n contributors: r.contributors ? JSON.parse(r.contributors as string) : [],\n })) as any[];\n}\n\nexport async function searchMemory(query: string, limit: number = 5) {\n const result = await sqlite.execute({\n sql: `SELECT mc.*, rm.reuse_count as memory_reuse\n FROM market_cases mc\n JOIN resolved_memory rm ON rm.case_id = mc.id\n WHERE mc.resolution IN ('CONFIRMED', 'REJECTED')\n AND (mc.hypothesis LIKE ? OR mc.symbol LIKE ? OR mc.meta_tags LIKE ?)\n ORDER BY rm.reuse_count DESC, mc.created_at DESC\n LIMIT ?`,\n args: [`%${query}%`, `%${query}%`, `%${query}%`, limit],\n });\n return result.rows.map((r) => ({\n ...r,\n meta_tags: r.meta_tags ? JSON.parse(r.meta_tags as string) : [],\n })) as any[];\n}\n",[],[156,214],"eea8db28-62d6-4b17-b332-5bb98ead0d95","cnos.ts","e58f2dba-8b1a-11f1-aa6c-1607ee4eb77e",7,["D",1785308306186],"// ─── CNOS CORE: 8-Stage Cognitive Resolution Cycle ───────────────────\n// The missing cognitive layer (Layer 6) that completes the stack.\n// Observation → Hypothesis → Proof → Contradiction → Invalidation\n// → Resolution → Memory → Reuse\n\nimport {\n createObservation,\n createMarketCase,\n updateCaseResolution,\n addContradiction,\n incrementReuse,\n getStats,\n logPipelineRun,\n getRecentCases,\n getCasesByResolution,\n searchMemory,\n initDB,\n uuid,\n} from \"./db.ts\";\n\nimport { getOHLCV, getTechnicals, computeLevels } from \"./market-data.ts\";\n\nimport { runDesk, type ObservationResult } from \"./agents.ts\";\n\nimport {\n getSettings,\n type ATNSettings,\n} from \"./settings.ts\";\n\nimport {\n notifyNewCase,\n notifyResolution,\n notifyContradiction,\n notifyPipelineRun,\n notifyError,\n} from \"./telegram.ts\";\n\n// ─── Stage 1: Observation ────────────────────────────────────────────\n// Ingest raw agent outputs from a private desk. Strip private data.\nexport async function stage1_observation(\n deskId: string,\n symbol: string,\n timeframe: string,\n): Promise {\n const { observations } = await runDesk(deskId, symbol, timeframe);\n // Privacy firewall: execution agent output is NEVER included\n // observations only contains shared agents (macro, structure, liquidity, risk, memory)\n await logPipelineRun(\"OBSERVATION\", \"COMPLETE\", `Desk ${deskId} observed ${symbol} on ${timeframe}`, observations.length);\n return observations;\n}\n\n// ─── Stage 2: Structured Observation / Hypothesis ───────────────────\n// Convert the strongest observation into a testable MarketCase\nexport async function stage2_hypothesis(\n observations: ObservationResult[],\n deskId: string,\n symbol: string,\n timeframe: string,\n settings: ATNSettings,\n): Promise {\n const valid = observations\n .filter((o) => o.hypothesis && o.confidence >= settings.minConfidenceForCase)\n .sort((a, b) => b.confidence - a.confidence);\n\n if (valid.length === 0) {\n await logPipelineRun(\"HYPOTHESIS\", \"SKIP\", `No observations met minimum confidence ${settings.minConfidenceForCase}`, 0);\n return null;\n }\n\n const best = valid[0];\n const caseId = await createMarketCase({\n desk_id: deskId,\n symbol,\n timeframe,\n hypothesis: best.hypothesis!,\n expected_outcome: best.expected_outcome,\n reasoning: best.summary,\n invalidation_level: best.invalidation_level,\n conviction: best.confidence,\n time_horizon: timeframe,\n meta_tags: best.meta_tags,\n evidence: observations.filter((o) => o.observation_id).map((o) => o.observation_id),\n });\n\n await logPipelineRun(\"HYPOTHESIS\", \"COMPLETE\", `Created MarketCase for ${symbol} conviction ${best.confidence}`, 1);\n\n // Telegram notification\n await notifyNewCase({\n symbol,\n timeframe,\n hypothesis: best.hypothesis,\n conviction: best.confidence,\n resolution: \"PENDING\",\n meta_tags: best.meta_tags,\n });\n\n return caseId;\n}\n\n// ─── Stage 3: Proof ──────────────────────────────────────────────────\n// Automated backtesting — verify the hypothesis against historical data\nexport async function stage3_proof(\n caseId: string,\n symbol: string,\n timeframe: string,\n): Promise<{ passed: boolean; details: any }> {\n const ohlcv = await getOHLCV(symbol, timeframe, 50);\n if (ohlcv.error) {\n await logPipelineRun(\"PROOF\", \"FAIL\", `Could not fetch data for ${symbol}`, 0);\n return { passed: false, details: { error: ohlcv.error } };\n }\n\n const bars = ohlcv.bars;\n const last20 = bars.slice(-20);\n const closes = last20.map((b: any) => b.close);\n\n // Simulated proof: check if recent price action supports the hypothesis\n const recentChange = ((closes[closes.length - 1] - closes[0]) / closes[0]) * 100;\n const avgVolume = last20.reduce((a: number, b: any) => a + b.volume, 0) / last20.length;\n const lastVolume = bars[bars.length - 1].volume;\n const volumeSurge = lastVolume > avgVolume * 1.5;\n\n // Win rate proxy: how many of the last 10 bars closed green\n const last10 = bars.slice(-10);\n const greenBars = last10.filter((b: any) => b.close > b.open).length;\n const winRate = (greenBars / last10.length) * 100;\n\n // Profit factor proxy\n const gains = last10.filter((b: any) => b.close > b.open).reduce((a: number, b: any) => a + (b.close - b.open), 0);\n const losses = last10.filter((b: any) => b.close <= b.open).reduce((a: number, b: any) => a + Math.abs(b.close - b.open), 0);\n const profitFactor = losses > 0 ? gains / losses : gains > 0 ? 3 : 1;\n\n // Max drawdown in last 20 bars\n let peak = closes[0];\n let maxDD = 0;\n for (const c of closes) {\n if (c > peak) peak = c;\n const dd = ((peak - c) / peak) * 100;\n if (dd > maxDD) maxDD = dd;\n }\n\n const proofArtifact = {\n recentChange: recentChange.toFixed(2) + \"%\",\n winRate: winRate.toFixed(1) + \"%\",\n profitFactor: profitFactor.toFixed(2),\n maxDrawdown: maxDD.toFixed(2) + \"%\",\n volumeSurge,\n barsAnalyzed: last20.length,\n };\n\n const passed = winRate >= 50 && profitFactor >= 1.0 && maxDD < 15;\n\n await logPipelineRun(\"PROOF\", passed ? \"PASS\" : \"FAIL\",\n `${symbol}: WR ${winRate.toFixed(0)}% PF ${profitFactor.toFixed(2)} DD ${maxDD.toFixed(1)}%`, 1);\n\n // Store proof artifact on the case\n const { sqlite } = await import(\"https://esm.town/v/std/sqlite/main.ts\");\n await sqlite.execute({\n sql: \"UPDATE market_cases SET proof_artifact = ? WHERE id = ?\",\n args: [JSON.stringify(proofArtifact), caseId],\n });\n\n return { passed, details: proofArtifact };\n}\n\n// ─── Stage 4: Contradiction ──────────────────────────────────────────\n// Compare hypothesis against other cases in the network\nexport async function stage4_contradiction(\n caseId: string,\n symbol: string,\n hypothesis: string,\n settings: ATNSettings,\n): Promise<{ contradictionsFound: number; contradictions: any[] }> {\n // Find other pending or resolved cases for the same symbol\n const { sqlite } = await import(\"https://esm.town/v/std/sqlite/main.ts\");\n const result = await sqlite.execute({\n sql: `SELECT * FROM market_cases WHERE symbol = ? AND id != ? ORDER BY created_at DESC LIMIT 10`,\n args: [symbol, caseId],\n });\n\n const otherCases = result.rows as any[];\n const contradictions: any[] = [];\n\n for (const other of otherCases) {\n const otherHypo = (other.hypothesis as string) ?? \"\";\n const otherResolution = (other.resolution as string) ?? \"PENDING\";\n\n // Check for directional contradiction\n const thisBullish = hypothesis.toLowerCase().includes(\"upside\") ||\n hypothesis.toLowerCase().includes(\"bullish\") ||\n hypothesis.toLowerCase().includes(\"continuation toward resistance\") ||\n hypothesis.toLowerCase().includes(\"risk-on\");\n const otherBearish = otherHypo.toLowerCase().includes(\"downside\") ||\n otherHypo.toLowerCase().includes(\"bearish\") ||\n otherHypo.toLowerCase().includes(\"continuation toward support\") ||\n otherHypo.toLowerCase().includes(\"risk-off\");\n\n const thisBearish = hypothesis.toLowerCase().includes(\"downside\") ||\n hypothesis.toLowerCase().includes(\"bearish\") ||\n hypothesis.toLowerCase().includes(\"continuation toward support\") ||\n hypothesis.toLowerCase().includes(\"risk-off\");\n const otherBullish = otherHypo.toLowerCase().includes(\"upside\") ||\n otherHypo.toLowerCase().includes(\"bullish\") ||\n otherHypo.toLowerCase().includes(\"continuation toward resistance\") ||\n otherHypo.toLowerCase().includes(\"risk-on\");\n\n if ((thisBullish && otherBearish) || (thisBearish && otherBullish)) {\n const contradictionText = `New ${thisBullish ? \"bullish\" : \"bearish\"} hypothesis on ${symbol} contradicts ${otherBullish ? \"bullish\" : \"bearish\"} case ${other.id.substring(0, 8)} (${otherResolution})`;\n const cId = await addContradiction(caseId, \"desk_beta_02\", contradictionText, other.id);\n contradictions.push({ id: cId, text: contradictionText, againstCase: other.id });\n }\n\n // Check if contradicts a CONFIRMED case\n if (otherResolution === \"CONFIRMED\" && (thisBullish !== otherBullish)) {\n const contradictionText = `New hypothesis on ${symbol} contradicts a CONFIRMED case ${other.id.substring(0, 8)}`;\n const cId = await addContradiction(caseId, \"desk_gamma_03\", contradictionText, other.id);\n contradictions.push({ id: cId, text: contradictionText, againstCase: other.id });\n }\n }\n\n await logPipelineRun(\"CONTRADICTION\", contradictions.length > 0 ? \"FLAGGED\" : \"CLEAR\",\n `${symbol}: ${contradictions.length} contradictions found`, contradictions.length);\n\n // Notify contradictions\n for (const c of contradictions) {\n await notifyContradiction({\n caseSymbol: symbol,\n contradictionText: c.text,\n challengingDesk: \"network\",\n });\n }\n\n return { contradictionsFound: contradictions.length, contradictions };\n}\n\n// ─── Stage 5: Invalidation ───────────────────────────────────────────\n// Check if the hypothesis has been invalidated by current market data\nexport async function stage5_invalidation(\n caseId: string,\n symbol: string,\n timeframe: string,\n invalidationLevel: string | null,\n): Promise<{ invalidated: boolean; reason: string }> {\n if (!invalidationLevel) {\n return { invalidated: false, reason: \"No invalidation level set\" };\n }\n\n const ohlcv = await getOHLCV(symbol, timeframe, 5);\n if (ohlcv.error) {\n return { invalidated: false, reason: \"Could not fetch data for invalidation check\" };\n }\n\n const lastBar = ohlcv.bars[ohlcv.bars.length - 1];\n const lastPrice = lastBar.close;\n\n // Parse invalidation level from text (extract number)\n const numMatch = invalidationLevel.match(/[\\d,.]+/);\n if (!numMatch) {\n // Non-numeric invalidation (e.g., \"VIX spikes above 30\") — can't auto-check\n return { invalidated: false, reason: `Manual check needed: ${invalidationLevel}` };\n }\n\n const level = parseFloat(numMatch[0].replace(/,/g, \"\"));\n const lower = invalidationLevel.toLowerCase();\n\n let invalidated = false;\n let reason = \"\";\n\n if (lower.includes(\"below\")) {\n if (lastPrice < level) {\n invalidated = true;\n reason = `Price ${lastPrice.toFixed(2)} dropped below invalidation level ${level}`;\n }\n } else if (lower.includes(\"above\")) {\n if (lastPrice > level) {\n invalidated = true;\n reason = `Price ${lastPrice.toFixed(2)} exceeded invalidation level ${level}`;\n }\n } else {\n // Generic: check if price is near the level\n const distance = Math.abs(lastPrice - level) / level * 100;\n if (distance < 1) {\n invalidated = true;\n reason = `Price ${lastPrice.toFixed(2)} within 1% of invalidation level ${level}`;\n }\n }\n\n await logPipelineRun(\"INVALIDATION\", invalidated ? \"INVALIDATED\" : \"VALID\",\n `${symbol}: ${invalidated ? \"INVALIDATED — \" + reason : \"Still valid\"}`, 1);\n\n return { invalidated, reason };\n}\n\n// ─── Stage 6: Resolution ─────────────────────────────────────────────\n// Combine proof + contradiction + invalidation into a final resolution\nexport async function stage6_resolution(\n caseId: string,\n symbol: string,\n proofPassed: boolean,\n contradictionsFound: number,\n invalidated: boolean,\n invalidationReason: string,\n settings: ATNSettings,\n): Promise<{ resolution: string; reason: string }> {\n let resolution = \"PENDING\";\n let reason = \"\";\n\n if (invalidated) {\n resolution = \"REJECTED\";\n reason = `Invalidated: ${invalidationReason}`;\n } else if (!proofPassed) {\n resolution = \"REJECTED\";\n reason = \"Proof stage failed — insufficient statistical evidence (win rate, profit factor, or drawdown)\";\n } else if (contradictionsFound >= settings.contradictionsRequired) {\n // Has enough contradictions to require refinement\n resolution = \"REFINED\";\n reason = `${contradictionsFound} contradictions found — hypothesis needs refinement before confirmation`;\n } else if (proofPassed && contradictionsFound < settings.contradictionsRequired) {\n resolution = \"CONFIRMED\";\n reason = `Passed proof stage with ${contradictionsFound} contradictions (threshold: ${settings.contradictionsRequired})`;\n }\n\n if (!settings.autoResolve && resolution !== \"REJECTED\") {\n resolution = \"PENDING\";\n reason = \"Auto-resolve disabled — awaiting manual review\";\n }\n\n await updateCaseResolution(caseId, resolution, reason);\n await logPipelineRun(\"RESOLUTION\", resolution, `${symbol}: ${resolution} — ${reason}`, 1);\n\n // Notify\n await notifyResolution({\n symbol,\n resolution,\n resolution_reason: reason,\n contradictions_resolved: contradictionsFound,\n });\n\n return { resolution, reason };\n}\n\n// ─── Stage 7: Resolved Memory ────────────────────────────────────────\n// Verified cases enter the shared memory store\nexport async function stage7_memory(caseId: string, resolution: string): Promise {\n if (resolution === \"CONFIRMED\" || resolution === \"REJECTED\") {\n // Memory entry is already created in updateCaseResolution\n await logPipelineRun(\"MEMORY\", \"STORED\", `Case ${caseId.substring(0, 8)} entered resolved memory as ${resolution}`, 1);\n } else {\n await logPipelineRun(\"MEMORY\", \"SKIP\", `Case ${caseId.substring(0, 8)} not resolved — stays pending`, 0);\n }\n}\n\n// ─── Stage 8: Reuse ──────────────────────────────────────────────────\n// Check if any new observations match existing resolved memory\nexport async function stage8_reuse(symbol: string): Promise<{ matches: number }> {\n const matches = await searchMemory(symbol, 5);\n for (const m of matches) {\n await incrementReuse(m.id);\n }\n await logPipelineRun(\"REUSE\", \"COMPLETE\", `${symbol}: ${matches.length} memory matches found and reuse count incremented`, matches.length);\n return { matches: matches.length };\n}\n\n// ─── Full CNOS Cycle ─────────────────────────────────────────────────\n// Runs all 8 stages for a single symbol\nexport async function runCNOSCycle(\n deskId: string,\n symbol: string,\n timeframe: string,\n): Promise<{\n symbol: string;\n caseId: string | null;\n resolution: string;\n proofPassed: boolean;\n contradictions: number;\n stages: string[];\n}> {\n const settings = await getSettings();\n const stages: string[] = [];\n\n // Stage 1: Observation\n stages.push(\"OBSERVATION\");\n const observations = await stage1_observation(deskId, symbol, timeframe);\n\n // Stage 2: Hypothesis\n stages.push(\"HYPOTHESIS\");\n const caseId = await stage2_hypothesis(observations, deskId, symbol, timeframe, settings);\n if (!caseId) {\n return { symbol, caseId: null, resolution: \"SKIPPED\", proofPassed: false, contradictions: 0, stages };\n }\n\n // Stage 3: Proof\n stages.push(\"PROOF\");\n const proof = await stage3_proof(caseId, symbol, timeframe);\n\n // Stage 4: Contradiction\n stages.push(\"CONTRADICTION\");\n const { sqlite } = await import(\"https://esm.town/v/std/sqlite/main.ts\");\n const caseRow = await sqlite.execute({ sql: \"SELECT * FROM market_cases WHERE id = ?\", args: [caseId] });\n const hypothesis = (caseRow.rows[0] as any)?.hypothesis ?? \"\";\n const invalidationLevel = (caseRow.rows[0] as any)?.invalidation_level ?? null;\n const contradictionResult = await stage4_contradiction(caseId, symbol, hypothesis, settings);\n\n // Stage 5: Invalidation\n stages.push(\"INVALIDATION\");\n const invalidationResult = await stage5_invalidation(caseId, symbol, timeframe, invalidationLevel);\n\n // Stage 6: Resolution\n stages.push(\"RESOLUTION\");\n const resolutionResult = await stage6_resolution(\n caseId, symbol,\n proof.passed,\n contradictionResult.contradictionsFound,\n invalidationResult.invalidated,\n invalidationResult.reason,\n settings,\n );\n\n // Stage 7: Memory\n stages.push(\"MEMORY\");\n await stage7_memory(caseId, resolutionResult.resolution);\n\n // Stage 8: Reuse\n stages.push(\"REUSE\");\n await stage8_reuse(symbol);\n\n await notifyPipelineRun(\"FULL_CYCLE\", 1, `${symbol} completed all 8 stages → ${resolutionResult.resolution}`);\n\n return {\n symbol,\n caseId,\n resolution: resolutionResult.resolution,\n proofPassed: proof.passed,\n contradictions: contradictionResult.contradictionsFound,\n stages,\n };\n}\n\n// ─── Run Pipeline for All Configured Symbols ─────────────────────────\nexport async function runPipeline(): Promise<{\n processed: number;\n results: any[];\n errors: string[];\n}> {\n await initDB();\n const settings = await getSettings();\n const results: any[] = [];\n const errors: string[] = [];\n\n if (!settings.pipelineEnabled) {\n return { processed: 0, results: [], errors: [\"Pipeline is disabled in settings\"] };\n }\n\n for (const symbol of settings.pipelineSymbols) {\n try {\n const result = await runCNOSCycle(settings.deskId, symbol, settings.pipelineTimeframe);\n results.push(result);\n } catch (e: any) {\n errors.push(`${symbol}: ${e.message}`);\n await notifyError(`${symbol} pipeline error: ${e.message}`);\n }\n }\n\n await notifyPipelineRun(\"PIPELINE_BATCH\", results.length, `Processed ${results.length} symbols, ${errors.length} errors`);\n\n return { processed: results.length, results, errors };\n}\n",[],[156,221],"d39cd854-4396-41b7-a9ed-7a9385e451c6","agents.ts","104b7258-8b1a-11f1-bd5c-1607ee4eb77e",4,["D",1785307948387],"// ─── Private Agentic Desk Agents ─────────────────────────────────────\n// Each desk runs 6 specialized agents. Agents produce structured\n// observations that are shared with the network. Execution stays private.\n\nimport {\n getQuote,\n getTechnicals,\n getTechnicalsRating,\n analyzeMultiTimeframe,\n computeLevels,\n getOHLCV,\n getNews,\n} from \"./market-data.ts\";\n\nimport { createObservation, createMarketCase, searchMemory } from \"./db.ts\";\n\nexport type AgentType =\n | \"macro\"\n | \"structure\"\n | \"liquidity\"\n | \"risk\"\n | \"memory\"\n | \"execution\";\n\nexport interface ObservationResult {\n observation_id: string;\n agent_type: AgentType;\n symbol: string;\n timeframe: string;\n observation_type: string;\n summary: string;\n data: any;\n confidence: number;\n hypothesis?: string;\n expected_outcome?: string;\n invalidation_level?: string;\n meta_tags?: string[];\n}\n\n// ─── Macro Agent ─────────────────────────────────────────────────────\n// Economic regime, cross-asset flows, macro context\nexport async function runMacroAgent(\n deskId: string,\n symbol: string,\n): Promise {\n const mtf = await analyzeMultiTimeframe(symbol);\n const news = await getNews(symbol);\n\n // Macro context from cross-asset\n const spyQuote = await getQuote(\"SPY\");\n const vixQuote = await getQuote(\"VIX\");\n const dxyQuote = await getQuote(\"DXY\");\n\n const riskRegime = vixQuote?.price > 25 ? \"RISK-OFF\" : vixQuote?.price > 18 ? \"NEUTRAL\" : \"RISK-ON\";\n const dxyTrend = dxyQuote?.changePercent > 0 ? \"DXY_RISING\" : \"DXY_FALLING\";\n\n const observation = {\n riskRegime,\n dxyTrend,\n vix: vixQuote?.price,\n spyChange: spyQuote?.changePercent,\n multiTimeframeBias: mtf.bias,\n alignmentScore: mtf.alignmentScore,\n newsCount: Array.isArray(news) ? news.length : 0,\n topNews: Array.isArray(news) ? news.slice(0, 3).map((n: any) => n.title) : [],\n };\n\n const obsId = await createObservation({\n desk_id: deskId,\n agent_type: \"macro\",\n symbol,\n timeframe: \"1D\",\n observation_type: \"macro_context\",\n data_payload: observation,\n confidence: 65,\n provenance: \"macro_agent\",\n });\n\n const hypothesis = `IF ${riskRegime} regime persists with VIX at ${vixQuote?.price?.toFixed(1)} THEN ${symbol} likely ${mtf.bias === \"BULLISH\" ? \"continues upside\" : \"faces headwind\"} BECAUSE cross-asset flows favor ${riskRegime === \"RISK-ON\" ? \"risk assets\" : \"safe haven\"}`;\n const invalidation = riskRegime === \"RISK-OFF\" ? \"VIX drops below 18\" : \"VIX spikes above 30\";\n\n return {\n observation_id: obsId,\n agent_type: \"macro\",\n symbol,\n timeframe: \"1D\",\n observation_type: \"macro_context\",\n summary: `${riskRegime} regime. ${mtf.bias} bias on ${symbol}. VIX: ${vixQuote?.price?.toFixed(1)}`,\n data: observation,\n confidence: 65,\n hypothesis,\n expected_outcome: mtf.bias === \"BULLISH\" ? \"Price appreciation\" : \"Price decline or consolidation\",\n invalidation_level: invalidation,\n meta_tags: [symbol, \"macro\", riskRegime, dxyTrend, mtf.bias],\n };\n}\n\n// ─── Structure Agent ─────────────────────────────────────────────────\n// Price action, SMC, swing analysis, multi-timeframe alignment\nexport async function runStructureAgent(\n deskId: string,\n symbol: string,\n timeframe: string = \"4H\",\n): Promise {\n const tech = await getTechnicals(symbol, timeframe);\n const levels = await computeLevels(symbol, timeframe);\n const rating = await getTechnicalsRating(symbol, timeframe);\n\n if (tech.error) {\n return {\n observation_id: \"\",\n agent_type: \"structure\",\n symbol,\n timeframe,\n observation_type: \"structure_analysis\",\n summary: `Error: ${tech.error}`,\n data: {},\n confidence: 0,\n };\n }\n\n const i = tech.indicators;\n const trend = i.ema.ema20 > i.ema.ema50 ? \"UPTREND\" : i.ema.ema20 < i.ema.ema50 ? \"DOWNTREND\" : \"RANGE\";\n const rsiSignal = i.rsi < 30 ? \"OVERSOLD\" : i.rsi > 70 ? \"OVERBOUGHT\" : \"NEUTRAL\";\n const macdSignal = i.macd?.histogram > 0 ? \"BULLISH\" : \"BEARISH\";\n const bbPosition = tech.lastPrice > i.bollinger?.upper ? \"UPPER_BAND\" :\n tech.lastPrice < i.bollinger?.lower ? \"LOWER_BAND\" : \"MID_RANGE\";\n\n const structure = {\n trend,\n rsi: i.rsi,\n rsiSignal,\n macdSignal,\n macdHistogram: i.macd?.histogram,\n bollingerPosition: bbPosition,\n ema20: i.ema.ema20,\n ema50: i.ema.ema50,\n ema200: i.ema.ema200,\n sma200: i.sma.sma200,\n adx: i.adx,\n rating: rating.rating,\n ratingScore: rating.score,\n support: levels.supportLevels,\n resistance: levels.resistanceLevels,\n swingHighs: levels.swingHighs,\n swingLows: levels.swingLows,\n equilibrium: levels.range?.equilibrium,\n fairValueGaps: levels.fairValueGaps,\n };\n\n const obsId = await createObservation({\n desk_id: deskId,\n agent_type: \"structure\",\n symbol,\n timeframe,\n observation_type: \"structure_analysis\",\n data_payload: structure,\n confidence: Math.min(90, rating.score + 10),\n provenance: \"structure_agent\",\n });\n\n const hypothesis = `IF ${symbol} ${trend} with RSI ${rsiSignal} (${i.rsi?.toFixed(1)}) and MACD ${macdSignal} THEN expect ${trend === \"UPTREND\" ? \"continuation toward resistance\" : trend === \"DOWNTREND\" ? \"continuation toward support\" : \"range-bound movement\"} BECAUSE structure confirms ${trend} with ADX ${i.adx?.toFixed(1)}`;\n const invalidation = trend === \"UPTREND\"\n ? `Close below ${levels.supportLevels?.[0]?.toFixed(2)} on ${timeframe}`\n : `Close above ${levels.resistanceLevels?.[0]?.toFixed(2)} on ${timeframe}`;\n\n return {\n observation_id: obsId,\n agent_type: \"structure\",\n symbol,\n timeframe,\n observation_type: \"structure_analysis\",\n summary: `${trend} | RSI ${i.rsi?.toFixed(1)} ${rsiSignal} | MACD ${macdSignal} | Rating ${rating.rating} (${rating.score})`,\n data: structure,\n confidence: Math.min(90, rating.score + 10),\n hypothesis,\n expected_outcome: trend === \"UPTREND\" ? \"Move to resistance\" : trend === \"DOWNTREND\" ? \"Move to support\" : \"Range continuation\",\n invalidation_level: invalidation,\n meta_tags: [symbol, timeframe, trend, rsiSignal, macdSignal, `rating_${rating.rating}`],\n };\n}\n\n// ─── Liquidity Agent ─────────────────────────────────────────────────\n// Volume profiling, order flow, FVG identification, premium/discount\nexport async function runLiquidityAgent(\n deskId: string,\n symbol: string,\n timeframe: string = \"4H\",\n): Promise {\n const ohlcv = await getOHLCV(symbol, timeframe, 50);\n const levels = await computeLevels(symbol, timeframe);\n\n if (ohlcv.error) {\n return {\n observation_id: \"\",\n agent_type: \"liquidity\",\n symbol,\n timeframe,\n observation_type: \"liquidity_analysis\",\n summary: `Error: ${ohlcv.error}`,\n data: {},\n confidence: 0,\n };\n }\n\n const bars = ohlcv.bars;\n const volumes = bars.map((b: any) => b.volume);\n const avgVolume = volumes.reduce((a: number, b: number) => a + b, 0) / volumes.length;\n const lastVolume = volumes[volumes.length - 1];\n const volumeRatio = lastVolume / avgVolume;\n\n // Volume-weighted price level (VWAP approximation)\n let pvSum = 0, volSum = 0;\n for (const b of bars) {\n pvSum += b.close * b.volume;\n volSum += b.volume;\n }\n const vwap = pvSum / volSum;\n const lastPrice = bars[bars.length - 1].close;\n const vwapDeviation = ((lastPrice - vwap) / vwap) * 100;\n\n // Liquidity zones from FVGs\n const liquidityZones = levels.fairValueGaps?.map((fvg: any) => ({\n top: fvg.top,\n bottom: fvg.bottom,\n type: \"FVG\",\n })) ?? [];\n\n // Volume profile buckets (simplified)\n const profileBuckets: Record = {};\n for (const b of bars) {\n const key = b.close.toFixed(2);\n profileBuckets[key] = (profileBuckets[key] || 0) + b.volume;\n }\n const pocLevel = Object.entries(profileBuckets).sort((a, b) => b[1] - a[1])[0]?.[0] ?? \"N/A\";\n\n const liquidity = {\n vwap,\n vwapDeviation: vwapDeviation.toFixed(2) + \"%\",\n volumeRatio: volumeRatio.toFixed(2),\n avgVolume,\n lastVolume,\n pointOfControl: pocLevel,\n equilibrium: levels.range?.equilibrium,\n premiumDiscount: levels.range?.equilibrium,\n liquidityZones,\n supportLevels: levels.supportLevels,\n resistanceLevels: levels.resistanceLevels,\n };\n\n const obsId = await createObservation({\n desk_id: deskId,\n agent_type: \"liquidity\",\n symbol,\n timeframe,\n observation_type: \"liquidity_analysis\",\n data_payload: liquidity,\n confidence: 60,\n provenance: \"liquidity_agent\",\n });\n\n const deviation = parseFloat(vwapDeviation.toFixed(2));\n const hypothesis = `IF ${symbol} is ${levels.range?.equilibrium} (${deviation > 0 ? \"+\" : \"\"}${deviation}% from VWAP) with volume ratio ${volumeRatio.toFixed(2)}x THEN expect ${levels.range?.equilibrium === \"PREMIUM\" ? \"mean reversion toward VWAP\" : \"bounce from discount zone\"} BECAUSE price is ${levels.range?.equilibrium === \"PREMIUM\" ? \"above\" : \"below\"} value area`;\n const invalidation = levels.range?.equilibrium === \"PREMIUM\"\n ? `Sustained close above ${levels.resistanceLevels?.[0]?.toFixed(2)}`\n : `Sustained close below ${levels.supportLevels?.[0]?.toFixed(2)}`;\n\n return {\n observation_id: obsId,\n agent_type: \"liquidity\",\n symbol,\n timeframe,\n observation_type: \"liquidity_analysis\",\n summary: `${levels.range?.equilibrium} | VWAP dev: ${deviation > 0 ? \"+\" : \"\"}${deviation}% | Vol ratio: ${volumeRatio.toFixed(2)}x | POC: ${pocLevel}`,\n data: liquidity,\n confidence: 60,\n hypothesis,\n expected_outcome: levels.range?.equilibrium === \"PREMIUM\" ? \"Reversion to VWAP\" : \"Bounce from discount\",\n invalidation_level: invalidation,\n meta_tags: [symbol, timeframe, levels.range?.equilibrium, `vol_${volumeRatio > 1.5 ? \"high\" : \"normal\"}`],\n };\n}\n\n// ─── Risk Agent (PRIVATE — observations only, no execution shared) ───\nexport async function runRiskAgent(\n deskId: string,\n symbol: string,\n timeframe: string = \"4H\",\n): Promise {\n const tech = await getTechnicals(symbol, timeframe);\n if (tech.error) {\n return {\n observation_id: \"\",\n agent_type: \"risk\",\n symbol,\n timeframe,\n observation_type: \"risk_assessment\",\n summary: `Error: ${tech.error}`,\n data: {},\n confidence: 0,\n };\n }\n\n const atr = tech.indicators.atr ?? 0;\n const lastPrice = tech.lastPrice;\n const atrPercent = (atr / lastPrice) * 100;\n\n // Risk levels based on ATR\n const suggestedStop = atr * 1.5;\n const suggestedTarget = atr * 3;\n const riskReward = suggestedTarget / suggestedStop;\n\n // Correlation risk flag\n const adx = tech.indicators.adx ?? 0;\n const trendStrength = adx > 25 ? \"STRONG\" : adx > 20 ? \"MODERATE\" : \"WEAK\";\n\n // Risk score (higher = riskier)\n let riskScore = 0;\n if (atrPercent > 3) riskScore += 30;\n else if (atrPercent > 2) riskScore += 20;\n else riskScore += 10;\n if (adx < 20) riskScore += 20;\n if (tech.indicators.rsi > 70 || tech.indicators.rsi < 30) riskScore += 15;\n\n const riskLevel = riskScore > 50 ? \"HIGH\" : riskScore > 30 ? \"MODERATE\" : \"LOW\";\n\n const riskData = {\n atr,\n atrPercent: atrPercent.toFixed(2) + \"%\",\n suggestedStopDistance: suggestedStop.toFixed(2),\n suggestedTargetDistance: suggestedTarget.toFixed(2),\n riskRewardRatio: riskReward.toFixed(2),\n trendStrength,\n adx,\n rsi: tech.indicators.rsi,\n riskScore,\n riskLevel,\n };\n\n const obsId = await createObservation({\n desk_id: deskId,\n agent_type: \"risk\",\n symbol,\n timeframe,\n observation_type: \"risk_assessment\",\n data_payload: riskData,\n confidence: 55,\n privacy_class: \"shared\", // only risk metrics shared, not position sizing\n });\n\n return {\n observation_id: obsId,\n agent_type: \"risk\",\n symbol,\n timeframe,\n observation_type: \"risk_assessment\",\n summary: `Risk: ${riskLevel} | ATR: ${atrPercent.toFixed(2)}% | RR: ${riskReward.toFixed(2)} | Trend: ${trendStrength}`,\n data: riskData,\n confidence: 55,\n hypothesis: `IF ${symbol} has ${riskLevel} risk (ATR ${atrPercent.toFixed(2)}%) THEN position sizing should be ${riskLevel === \"HIGH\" ? \"reduced\" : \"standard\"} BECAUSE volatility and trend strength dictate exposure`,\n expected_outcome: riskLevel === \"HIGH\" ? \"Wider stops needed, smaller position\" : \"Standard risk parameters applicable\",\n invalidation_level: `ATR exceeds ${(atrPercent * 1.5).toFixed(2)}%`,\n meta_tags: [symbol, timeframe, `risk_${riskLevel}`, `atr_${atrPercent.toFixed(1)}%`],\n };\n}\n\n// ─── Memory Agent ────────────────────────────────────────────────────\n// RAG over desk's local memory + network resolved memory\nexport async function runMemoryAgent(\n deskId: string,\n symbol: string,\n): Promise {\n // Search resolved memory for similar cases\n const similar = await searchMemory(symbol, 5);\n\n const memoryData = {\n similarCasesFound: similar.length,\n cases: similar.map((c) => ({\n case_id: c.id,\n symbol: c.symbol,\n hypothesis: c.hypothesis,\n resolution: c.resolution,\n conviction: c.conviction,\n reuse_count: c.reuse_count,\n tags: c.meta_tags,\n })),\n topResolution: similar[0]?.resolution ?? \"NONE\",\n avgConviction: similar.length > 0\n ? Math.round(similar.reduce((a, c) => a + (c.conviction ?? 0), 0) / similar.length)\n : 0,\n };\n\n const obsId = await createObservation({\n desk_id: deskId,\n agent_type: \"memory\",\n symbol,\n timeframe: \"1D\",\n observation_type: \"memory_retrieval\",\n data_payload: memoryData,\n confidence: similar.length > 0 ? 70 : 40,\n provenance: \"memory_agent\",\n });\n\n const hasHistory = similar.length > 0;\n const hypothesis = hasHistory\n ? `IF ${symbol} has ${similar.length} resolved cases with avg conviction ${memoryData.avgConviction} THEN current analysis benefits from historical context BECAUSE resolved memory contains verified patterns`\n : `IF ${symbol} has no resolved memory THEN this observation establishes a new memory baseline BECAUSE first cases seed the network`;\n\n return {\n observation_id: obsId,\n agent_type: \"memory\",\n symbol,\n timeframe: \"1D\",\n observation_type: \"memory_retrieval\",\n summary: hasHistory\n ? `${similar.length} similar cases found | Avg conviction: ${memoryData.avgConviction} | Top resolution: ${memoryData.topResolution}`\n : \"No prior memory — establishing baseline\",\n data: memoryData,\n confidence: similar.length > 0 ? 70 : 40,\n hypothesis,\n expected_outcome: hasHistory ? \"Pattern-informed analysis\" : \"New memory entry created\",\n invalidation_level: \"N/A\",\n meta_tags: [symbol, \"memory\", hasHistory ? \"has_history\" : \"new_baseline\"],\n };\n}\n\n// ─── Execution Agent (PRIVATE — never shared) ────────────────────────\n// Produces only a private signal, no network egress\nexport async function runExecutionAgent(\n deskId: string,\n symbol: string,\n observations: ObservationResult[],\n): Promise<{ action: string; reasoning: string; private: boolean }> {\n const macro = observations.find((o) => o.agent_type === \"macro\");\n const structure = observations.find((o) => o.agent_type === \"structure\");\n const liquidity = observations.find((o) => o.agent_type === \"liquidity\");\n const risk = observations.find((o) => o.agent_type === \"risk\");\n\n const bullishCount = [macro, structure, liquidity].filter((o) =>\n o?.hypothesis?.toLowerCase().includes(\"upside\") ||\n o?.hypothesis?.toLowerCase().includes(\"bullish\") ||\n o?.hypothesis?.toLowerCase().includes(\"continuation toward resistance\") ||\n o?.hypothesis?.toLowerCase().includes(\"risk-on\")\n ).length;\n\n const riskLevel = risk?.data?.riskLevel ?? \"MODERATE\";\n\n let action = \"HOLD\";\n if (bullishCount >= 2 && riskLevel !== \"HIGH\") action = \"LONG_SIGNAL\";\n else if (bullishCount === 0 && riskLevel !== \"HIGH\") action = \"SHORT_SIGNAL\";\n else if (riskLevel === \"HIGH\") action = \"REDUCE_EXPOSURE\";\n\n return {\n action,\n reasoning: `${bullishCount}/3 agents bullish. Risk: ${riskLevel}. Action: ${action}`,\n private: true, // NEVER shared with network\n };\n}\n\n// ─── Run Full Desk ───────────────────────────────────────────────────\nexport async function runDesk(\n deskId: string,\n symbol: string,\n timeframe: string = \"4H\",\n): Promise<{\n observations: ObservationResult[];\n execution: { action: string; reasoning: string; private: boolean };\n caseId?: string;\n}> {\n // Run all shared agents in parallel\n const [macro, structure, liquidity, risk, memory] = await Promise.all([\n runMacroAgent(deskId, symbol),\n runStructureAgent(deskId, symbol, timeframe),\n runLiquidityAgent(deskId, symbol, timeframe),\n runRiskAgent(deskId, symbol, timeframe),\n runMemoryAgent(deskId, symbol),\n ]);\n\n const observations = [macro, structure, liquidity, risk, memory];\n\n // Run execution agent PRIVATELY (never shared)\n const execution = await runExecutionAgent(deskId, symbol, observations);\n\n // Create a MarketCase from the strongest observation\n const sorted = observations\n .filter((o) => o.hypothesis && o.confidence > 0)\n .sort((a, b) => b.confidence - a.confidence);\n\n let caseId: string | undefined;\n if (sorted.length > 0 && sorted[0].hypothesis) {\n const best = sorted[0];\n caseId = await createMarketCase({\n desk_id: deskId,\n symbol,\n timeframe,\n hypothesis: best.hypothesis,\n expected_outcome: best.expected_outcome,\n reasoning: best.summary,\n invalidation_level: best.invalidation_level,\n conviction: best.confidence,\n time_horizon: timeframe,\n meta_tags: best.meta_tags,\n evidence: observations.filter((o) => o.observation_id).map((o) => o.observation_id),\n });\n }\n\n return { observations, execution, caseId };\n}\n",[],[156,229],["D",1785307426186],[177,178,179,180,181,182],[156],"e6ecdc51-6b7e-4b1f-b8fa-bf39bd9bc5e7",["D",1785308315894],[],[50,39],["D",1785308315894],[175],[50],["D",1785307366530],["D",1789476648181],{"_111":110,"_119":115},{"_111":110,"_112":113,"_114":115,"_19":66,"_116":117,"_118":31},{"_13":100,"_38":101,"_54":48,"_102":55,"_103":-5,"_104":-5,"_105":-5,"_106":-5,"_107":-5,"_108":56,"_109":110},"ctx",{"_93":-5,"_139":284,"_285":286,"_287":288,"_289":31,"_290":31,"_291":31,"_292":70,"_293":-5,"_294":-7,"_295":-7,"_296":74,"_297":31,"_298":31,"_299":-5,"_300":31,"_301":31,"_302":31,"_303":-5},"ENV",{"_255":256,"_257":258,"_259":101,"_260":261,"_262":263,"_264":265,"_266":267,"_268":269,"_270":271,"_272":273,"_274":275,"_276":277,"_278":279,"_280":281,"_282":283},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v8