ATN — Agentic Trading Network

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_279":280,"_281":282},"routes/_app.x.$handle.$name",{"_110":109,"_38":56,"_119":100,"_33":120,"_13":14,"_121":-5,"_11":122,"_123":124,"_125":126,"_127":128,"_129":130,"_27":-5,"_131":-5,"_132":-5,"_133":31,"_134":135,"_136":69,"_137":-5,"_138":-5,"_139":140},"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":37,"_68":69,"_70":-5,"_71":-5,"_72":73,"_74":75,"_76":77,"_78":79,"_80":81,"_82":-5,"_83":84,"_85":84,"_86":87,"_88":87,"_89":87,"_90":84,"_91":84,"_92":93,"_94":95,"_96":97,"_98":31},"version",10,"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","api/main.ts","latestPath","fileId","686ae364-8b1b-11f1-be27-1607ee4eb77e","name","main.ts","fileType","http","content","// ─── ATN/CNOS Main HTTP Handler ──────────────────────────────────────\n// Serves the dashboard and all API routes.\n\nimport { Hono } from \"npm:hono\";\nimport { httpEndpoint } from \"https://esm.town/v/std/utils/index.ts\";\n\nimport { initDB, getStats, getRecentCases, getRecentPipelineRuns, getCasesByResolution, searchMemory } from \"../lib/db.ts\";\nimport { getSettings, saveSettings, resetSettings, type ATNSettings } from \"../lib/settings.ts\";\nimport { sendTelegramMessage } from \"../lib/telegram.ts\";\nimport { runPipeline } from \"../lib/cnos.ts\";\nimport { dashboardHTML } from \"../lib/dashboard.ts\";\n\n// Market data tools\nimport {\n searchSymbols,\n getQuote,\n getQuotesBatch,\n getOHLCV,\n getTechnicals,\n getTechnicalsRating,\n analyzeMultiTimeframe,\n computeLevels,\n getNews,\n runScreener,\n compareSymbols,\n calculateCorrelation,\n} from \"../lib/market-data.ts\";\n\nconst app = new Hono();\napp.onError((err) => Promise.reject(err));\n\n// ─── Dashboard ───────────────────────────────────────────────────────\napp.get(\"/\", async (c) => {\n await initDB();\n const endpoint = httpEndpoint(import.meta.url);\n const html = dashboardHTML(endpoint);\n return c.html(html);\n});\n\n// ─── API: Stats ──────────────────────────────────────────────────────\napp.get(\"/api/stats\", async (c) => {\n await initDB();\n const stats = await getStats();\n return c.json(stats);\n});\n\n// ─── API: Cases ──────────────────────────────────────────────────────\napp.get(\"/api/cases\", async (c) => {\n await initDB();\n const resolution = c.req.query(\"resolution\");\n const limit = parseInt(c.req.query(\"limit\") || \"10\");\n if (resolution) {\n const cases = await getCasesByResolution(resolution);\n return c.json(cases);\n }\n const cases = await getRecentCases(limit);\n return c.json(cases);\n});\n\n// ─── API: Pipeline Runs ──────────────────────────────────────────────\napp.get(\"/api/pipeline\", async (c) => {\n await initDB();\n const runs = await getRecentPipelineRuns(50);\n return c.json(runs);\n});\n\n// ─── API: Run Pipeline Manually ──────────────────────────────────────\napp.post(\"/api/pipeline/run\", async (c) => {\n await initDB();\n const result = await runPipeline();\n return c.json(result);\n});\n\n// ─── API: Settings ───────────────────────────────────────────────────\napp.get(\"/api/settings\", async (c) => {\n const settings = await getSettings();\n // Don't return the bot token in full\n return c.json({\n ...settings,\n telegramBotToken: settings.telegramBotToken ? settings.telegramBotToken.substring(0, 8) + \"...\" : \"\",\n });\n});\n\napp.post(\"/api/settings\", async (c) => {\n const body = await c.req.json();\n // If telegram token is masked (contains \"...\"), keep the existing one\n if (body.telegramBotToken && body.telegramBotToken.includes(\"...\")) {\n const current = await getSettings();\n body.telegramBotToken = current.telegramBotToken;\n }\n await saveSettings(body);\n return c.json({ ok: true });\n});\n\napp.post(\"/api/settings/reset\", async (c) => {\n await resetSettings();\n return c.json({ ok: true });\n});\n\n// ─── API: Telegram Test ──────────────────────────────────────────────\napp.post(\"/api/telegram/test\", async (c) => {\n const ok = await sendTelegramMessage(\n \"🤖 *ATN Test Message*\\n\\nTelegram integration is working! Your Agentic Trading Network bot is online.\",\n );\n if (ok) return c.json({ ok: true });\n return c.json({ ok: false, error: \"Failed to send. Check your bot token and chat ID in settings.\" });\n});\n\n// ─── API: Memory Search ──────────────────────────────────────────────\napp.get(\"/api/memory/search\", async (c) => {\n await initDB();\n const q = c.req.query(\"q\") || \"\";\n const results = await searchMemory(q, 10);\n return c.json(results);\n});\n\n// ─── API: Market Data Tools ──────────────────────────────────────────\napp.post(\"/api/tools/search_symbols\", async (c) => {\n const { query } = await c.req.json();\n const result = await searchSymbols(query);\n return c.json(result);\n});\n\napp.post(\"/api/tools/get_quote\", async (c) => {\n const { symbol } = await c.req.json();\n const result = await getQuote(symbol);\n return c.json(result);\n});\n\napp.post(\"/api/tools/get_quotes_batch\", async (c) => {\n const { symbols } = await c.req.json();\n const result = await getQuotesBatch(symbols);\n return c.json(result);\n});\n\napp.post(\"/api/tools/get_ohlcv\", async (c) => {\n const { symbol, timeframe } = await c.req.json();\n const result = await getOHLCV(symbol, timeframe || \"1D\");\n return c.json(result);\n});\n\napp.post(\"/api/tools/get_technicals\", async (c) => {\n const { symbol, timeframe } = await c.req.json();\n const result = await getTechnicals(symbol, timeframe || \"1D\");\n return c.json(result);\n});\n\napp.post(\"/api/tools/get_technicals_rating\", async (c) => {\n const { symbol, timeframe } = await c.req.json();\n const result = await getTechnicalsRating(symbol, timeframe || \"1D\");\n return c.json(result);\n});\n\napp.post(\"/api/tools/analyze_multi_timeframe\", async (c) => {\n const { symbol } = await c.req.json();\n const result = await analyzeMultiTimeframe(symbol);\n return c.json(result);\n});\n\napp.post(\"/api/tools/compute_levels\", async (c) => {\n const { symbol, timeframe } = await c.req.json();\n const result = await computeLevels(symbol, timeframe || \"1D\");\n return c.json(result);\n});\n\napp.post(\"/api/tools/get_news\", async (c) => {\n const { symbol } = await c.req.json();\n const result = await getNews(symbol);\n return c.json(result);\n});\n\napp.post(\"/api/tools/run_screener\", async (c) => {\n const { symbols, condition } = await c.req.json();\n const result = await runScreener(symbols, condition || \"\");\n return c.json(result);\n});\n\napp.post(\"/api/tools/compare_symbols\", async (c) => {\n const { symbols } = await c.req.json();\n const result = await compareSymbols(symbols);\n return c.json(result);\n});\n\napp.post(\"/api/tools/calculate_correlation\", async (c) => {\n const { symbols, timeframe } = await c.req.json();\n const result = await calculateCorrelation(symbols, timeframe || \"1D\");\n return c.json(result);\n});\n\n// ─── API: Full CNOS Cycle for a Single Symbol ────────────────────────\napp.post(\"/api/cycle/:symbol\", async (c) => {\n await initDB();\n const symbol = c.req.param(\"symbol\");\n const { timeframe } = await c.req.json().catch(() => ({ timeframe: \"4H\" }));\n const { runCNOSCycle } = await import(\"../lib/cnos.ts\");\n const settings = await getSettings();\n const result = await runCNOSCycle(settings.deskId, symbol, timeframe || \"4H\");\n return c.json(result);\n});\n\n// ─── Health Check ────────────────────────────────────────────────────\napp.get(\"/api/health\", (c) => {\n return c.json({ status: \"online\", service: \"ATN/CNOS Bot\", version: \"1.0.0\" });\n});\n\nexport default app.fetch;\n","createdAt",["D",1785308525726],"branchVersion","branchId","7f4fd07b-175a-4243-9d9e-b81c40f32513",{"_36":51,"_38":50,"_40":52,"_42":-5,"_44":53,"_46":14,"_47":48,"_30":31},"api","46ee31fd-c5df-427a-9ec6-96a53a130045","directory",["D",1785308525726],"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","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",{"_110":109,"_118":114},"org",{"_110":109,"_111":112,"_113":114,"_19":66,"_115":116,"_117":31},"branch",{"_13":99,"_38":100,"_54":48,"_101":55,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":-5,"_107":56,"_108":109},"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":274,"_58":-5,"_59":31,"_60":61,"_62":61,"_63":64,"_65":-5,"_19":66,"_67":37,"_68":69,"_70":-5,"_71":-5,"_72":73,"_74":75,"_76":77,"_78":79,"_80":275,"_82":-5,"_83":84,"_85":84,"_86":87,"_88":87,"_89":87,"_90":84,"_91":84,"_92":276,"_94":277,"_96":278,"_98":31},"tree",[180,182,184,192],"files",[180,181,182,183,184,185,186,187,188,189,190,191,192],"counts",{"_170":73,"_171":158,"_172":73,"_173":174,"_175":176},"contents",[141,142,143,144],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_54":167,"_38":50,"_36":51,"_148":-5,"_47":48,"_46":14,"_150":69,"_44":168,"_13":73,"_40":52,"_42":-5,"_30":31,"_153":-5,"_33":169},{"_54":161,"_38":162,"_36":163,"_148":-5,"_47":48,"_46":164,"_150":69,"_44":165,"_13":73,"_40":52,"_42":-5,"_30":31,"_153":-5,"_33":166},{"_54":155,"_38":156,"_36":157,"_148":-5,"_47":48,"_46":158,"_150":69,"_44":159,"_13":73,"_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":73,"_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","cron","14a2dc12-cf92-4d0e-8c2d-8e10cb4dec84",8,["D",1785308315894],[162],"86306ec0-c15c-4900-8a2d-0cdb2fed84d3",["D",1785308525726],[50],"pulls","branches","forks","envVars",{"_177":73,"_179":73},"connections",{"_177":73,"_178":73},"count","unfilledCount","emptyCount",{"_54":167,"_38":50,"_36":51,"_148":-5,"_47":48,"_46":14,"_150":69,"_44":271,"_13":73,"_40":52,"_42":-5,"_30":31,"_153":-5,"_194":272,"_33":273},{"_54":267,"_38":39,"_36":37,"_148":51,"_47":48,"_46":14,"_150":31,"_44":268,"_13":73,"_40":41,"_42":43,"_30":31,"_153":-5,"_194":269,"_33":270},{"_54":161,"_38":162,"_36":163,"_148":-5,"_47":48,"_46":164,"_150":69,"_44":264,"_13":73,"_40":52,"_42":-5,"_30":31,"_153":-5,"_194":265,"_33":266},{"_54":256,"_38":257,"_36":258,"_148":163,"_47":48,"_46":164,"_150":69,"_44":259,"_13":73,"_40":260,"_42":261,"_30":31,"_153":-5,"_194":262,"_33":263},{"_54":155,"_38":156,"_36":157,"_148":-5,"_47":48,"_46":158,"_150":69,"_44":253,"_13":73,"_40":52,"_42":-5,"_30":31,"_153":-5,"_194":254,"_33":255},{"_54":245,"_38":246,"_36":247,"_148":157,"_47":48,"_46":248,"_150":69,"_44":249,"_13":73,"_40":202,"_42":250,"_30":31,"_153":-5,"_194":251,"_33":252},{"_54":237,"_38":238,"_36":239,"_148":157,"_47":48,"_46":240,"_150":69,"_44":241,"_13":73,"_40":202,"_42":242,"_30":31,"_153":-5,"_194":243,"_33":244},{"_54":229,"_38":230,"_36":231,"_148":157,"_47":48,"_46":232,"_150":31,"_44":233,"_13":73,"_40":202,"_42":234,"_30":31,"_153":-5,"_194":235,"_33":236},{"_54":222,"_38":223,"_36":224,"_148":157,"_47":48,"_46":158,"_150":69,"_44":225,"_13":73,"_40":202,"_42":226,"_30":31,"_153":-5,"_194":227,"_33":228},{"_54":214,"_38":215,"_36":216,"_148":157,"_47":48,"_46":217,"_150":31,"_44":218,"_13":73,"_40":202,"_42":219,"_30":31,"_153":-5,"_194":220,"_33":221},{"_54":206,"_38":207,"_36":208,"_148":157,"_47":48,"_46":209,"_150":31,"_44":210,"_13":73,"_40":202,"_42":211,"_30":31,"_153":-5,"_194":212,"_33":213},{"_54":197,"_38":198,"_36":199,"_148":157,"_47":48,"_46":200,"_150":69,"_44":201,"_13":73,"_40":202,"_42":203,"_30":31,"_153":-5,"_194":204,"_33":205},{"_54":145,"_38":146,"_36":147,"_148":-5,"_47":48,"_46":149,"_150":31,"_44":193,"_13":73,"_40":27,"_42":152,"_30":31,"_153":-5,"_194":195,"_33":196},["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,198],"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,207],"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,215],"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,223],"40f616ee-233c-4b03-bda2-cd0d4679058c","dashboard.ts","55376cea-8b1b-11f1-ae8a-1607ee4eb77e",9,["D",1785308493510],"// ─── Dashboard HTML Generator ────────────────────────────────────────\n// Generates the dashboard page. Client-side JS fetches from the API.\n\nexport function dashboardHTML(endpoint: string): string {\n return `\n\n\n \n \n ATN — Agentic Trading Network\n \n\n\n \n\n

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

\n\n \n

Cognitive Resolution Cycle

\n 1. Observe→\n 2. Hypothesis→\n 3. Proof→\n 4. Contradiction→\n 5. Invalidation→\n 6. Resolution→\n 7. Memory→\n 8. Reuse\n

Recent MarketCases

Recent Pipeline Runs

\n\n \n

All MarketCases

\n \n \n \n \n

\n\n \n

Pipeline Control

Manually trigger the CNOS 8-stage cycle for all configured symbols.

\n \n

Pipeline Run History

\n\n \n

Telegram Notifications

\n \n Enable Telegram notifications\n

\n Bot Token\n \n

\n Chat ID\n \n

\n \n \n

\n\n

Pipeline Configuration

\n \n Enable automated pipeline\n

\n Symbols (comma-separated)\n \n

\n Timeframe\n \n

\n Interval (minutes)\n \n

\n\n

Desk Configuration

\n Desk ID\n \n

\n Min Confidence for Case\n \n

\n \n Auto-generate MarketCases from observations\n

\n \n Auto-resolve cases (CONFIRMED/REJECTED)\n

\n Contradictions required for refinement\n \n

\n\n

Notification Preferences

Notify on new MarketCase

Notify on case resolution

Notify on contradiction detected

Notify on errors

\n\n

\n \n \n

\n\n \n

Market Data Tools (MCP-style)

search_symbols

Search and resolve symbols across exchanges

\n \n \n

get_quote

Real-time quote snapshot

\n \n \n

get_technicals

Technical indicators (RSI, MACD, EMAs, Bollinger, ATR, etc.)

\n \n \n \n

get_technicals_rating

Aggregated buy/sell/neutral rating with breakdown

\n \n \n \n

analyze_multi_timeframe

Trend alignment across 15m, 1H, 4H, 1D

\n \n \n

compute_levels

Support/resistance, swing levels, FVGs, premium/discount

\n \n \n \n

get_news

get_ohlcv

Historical OHLCV bars

\n \n \n \n

\n\n \n

Resolved Memory Search

Search verified, attributable, reusable knowledge in the network memory.

\n \n \n

\n\n \n\n \n\n`;\n}\n",[],[156,230],"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,238],"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,246],["D",1785307426186],[185,186,187,188,189,190,191],[156],"e6ecdc51-6b7e-4b1f-b8fa-bf39bd9bc5e7","pipeline.ts","eb58ae1a-8b1a-11f1-9fc9-1607ee4eb77e",["D",1785308315894],"interval","// ─── 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",[],[162,257],["D",1785308315894],[183],[162],"f6329601-4402-4dad-a9ae-b1d6c46af39b",["D",1785308525726],[],[50,39],["D",1785308525726],[181],[50],["D",1785307366530],["D",1789476648181],{"_110":109,"_118":114},{"_110":109,"_111":112,"_113":114,"_19":66,"_115":116,"_117":31},{"_13":99,"_38":100,"_54":48,"_101":55,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":-5,"_107":56,"_108":109},"ctx",{"_92":-5,"_138":312,"_313":314,"_315":316,"_317":31,"_318":31,"_319":31,"_320":69,"_321":-5,"_322":-7,"_323":-7,"_324":73,"_325":31,"_326":31,"_327":-5,"_328":31,"_329":31,"_330":31,"_331":-5},"ENV",{"_283":284,"_285":286,"_287":100,"_288":289,"_290":291,"_292":293,"_294":295,"_296":297,"_298":299,"_300":301,"_302":303,"_304":305,"_306":307,"_308":309,"_310":311},"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"]

ATN — AGENTIC TRADING NETWORK

CNOS Cognitive Resolution Layer · Layer 6

Cognitive Resolution Cycle

Recent MarketCases

Recent Pipeline Runs

All MarketCases

Pipeline Control

Pipeline Run History

Telegram Notifications

Pipeline Configuration

Desk Configuration

Notification Preferences

Market Data Tools (MCP-style)

search_symbols

get_quote

get_technicals

get_technicals_rating

analyze_multi_timeframe

compute_levels

get_news

get_ohlcv

Resolved Memory Search

Diff · v10