\n \n \n\n",[18,85],"d38b44e1-73c8-4ecd-aff3-d510d24742af",["D",1783414555839],"\n",[18,90],"5bf49824-27df-4281-9d45-1569bd328d97",["D",1783414555839],[18,95],"pulls","branches","forks","envVars",{"_91":26,"_219":26},"connections",{"_91":26,"_218":26},"unfilledCount","emptyCount",{"_35":325,"_13":300,"_72":294,"_45":-5,"_37":38,"_187":304,"_195":24,"_39":326,"_41":26,"_75":96,"_185":-5,"_77":30,"_188":-5,"_242":327,"_17":328},{"_35":317,"_13":318,"_72":319,"_45":294,"_37":38,"_187":320,"_195":24,"_39":321,"_41":26,"_75":76,"_185":322,"_77":30,"_188":-5,"_242":323,"_17":324},{"_35":309,"_13":310,"_72":311,"_45":294,"_37":38,"_187":312,"_195":24,"_39":313,"_41":26,"_75":76,"_185":314,"_77":30,"_188":-5,"_242":315,"_17":316},{"_35":301,"_13":302,"_72":303,"_45":294,"_37":38,"_187":304,"_195":24,"_39":305,"_41":26,"_75":76,"_185":306,"_77":30,"_188":-5,"_242":307,"_17":308},{"_35":291,"_13":292,"_72":293,"_45":294,"_37":38,"_187":295,"_195":24,"_39":296,"_41":26,"_75":76,"_185":297,"_77":30,"_188":-5,"_242":298,"_17":299},{"_35":184,"_13":18,"_72":113,"_45":-5,"_37":38,"_187":42,"_195":24,"_39":288,"_41":26,"_75":96,"_185":-5,"_77":30,"_188":-5,"_242":289,"_17":290},{"_35":208,"_13":95,"_72":94,"_45":113,"_37":38,"_187":42,"_195":24,"_39":285,"_41":26,"_75":96,"_185":-5,"_77":30,"_188":-5,"_242":286,"_17":287},{"_35":277,"_13":278,"_72":279,"_45":94,"_37":38,"_187":280,"_195":24,"_39":281,"_41":26,"_75":76,"_185":282,"_77":30,"_188":-5,"_242":283,"_17":284},{"_35":269,"_13":270,"_72":271,"_45":94,"_37":38,"_187":272,"_195":24,"_39":273,"_41":197,"_75":76,"_185":274,"_77":30,"_188":-5,"_242":275,"_17":276},{"_35":261,"_13":262,"_72":263,"_45":94,"_37":38,"_187":264,"_195":24,"_39":265,"_41":26,"_75":76,"_185":266,"_77":30,"_188":-5,"_242":267,"_17":268},{"_35":204,"_13":90,"_72":89,"_45":113,"_37":38,"_187":42,"_195":24,"_39":258,"_41":26,"_75":21,"_185":206,"_77":30,"_188":-5,"_242":259,"_17":260},{"_35":200,"_13":85,"_72":84,"_45":113,"_37":38,"_187":99,"_195":24,"_39":255,"_41":197,"_75":21,"_185":202,"_77":30,"_188":-5,"_242":256,"_17":257},{"_35":194,"_13":74,"_72":73,"_45":113,"_37":38,"_187":107,"_195":24,"_39":252,"_41":197,"_75":76,"_185":198,"_77":30,"_188":-5,"_242":253,"_17":254},{"_35":245,"_13":246,"_72":247,"_45":-5,"_37":38,"_187":149,"_195":24,"_39":248,"_41":26,"_75":21,"_185":249,"_77":30,"_188":-5,"_242":250,"_17":251},{"_35":235,"_13":236,"_72":237,"_45":-5,"_37":38,"_187":238,"_195":24,"_39":239,"_41":197,"_75":240,"_185":241,"_77":30,"_188":-5,"_242":243,"_17":244},"0a22038d-e95a-41d6-8404-c659ba15d2f0","index.ts","019f3bca-84bb-7554-be09-5331baf60b85",9,["D",1783414706283],"http","import { Hono } from \"npm:hono\";\nimport { parseVal, readFile, serveFile } from \"https://esm.town/v/std/utils/index.ts\";\nimport { fetchCandles, fetchTicker, SUPPORTED_BARS } from \"./backend/okx.ts\";\nimport { chartSeries, indicatorSummary } from \"./backend/indicators.ts\";\nimport { smcSummary } from \"./backend/smc.ts\";\nimport { analyzeCached } from \"./backend/ai.ts\";\n\nconst app = new Hono();\n\napp.onError((err, c) => {\n console.error(\"Error:\", err);\n return c.json({ error: (err as Error).message }, 500);\n});\n\napp.get(\"/source\", (c) => c.redirect(parseVal().links.self.val));\n\n// Свечи + EMA для графика\napp.get(\"/api/candles\", async (c) => {\n const instId = c.req.query(\"instId\") ?? \"BTC-USDT\";\n const bar = c.req.query(\"bar\") ?? \"15m\";\n if (!SUPPORTED_BARS.includes(bar as any)) return c.json({ error: \"unsupported bar\" }, 400);\n const [candles, ticker] = await Promise.all([fetchCandles(instId, bar, 300), fetchTicker(instId)]);\n return c.json({ instId, bar, candles, series: chartSeries(candles), ticker });\n});\n\n// Полный анализ: индикаторы + SMC + ИИ\napp.get(\"/api/analyze\", async (c) => {\n const instId = c.req.query(\"instId\") ?? \"BTC-USDT\";\n const bar = c.req.query(\"bar\") ?? \"15m\";\n if (!SUPPORTED_BARS.includes(bar as any)) return c.json({ error: \"unsupported bar\" }, 400);\n\n const candles = await fetchCandles(instId, bar, 300);\n if (candles.length < 60) return c.json({ error: \"недостаточно данных\" }, 400);\n\n const indicators = indicatorSummary(candles);\n const smc = smcSummary(candles, indicators.atr14);\n const payload = { indicators, smc };\n\n const lastClosed = candles[candles.length - 2]; // последняя закрытая свеча\n const { analysis, cached, analyzedAt } = await analyzeCached(instId, bar, lastClosed.ts, payload);\n\n return c.json({ instId, bar, price: indicators.price, indicators, smc, analysis, cached, analyzedAt });\n});\n\n// Статика\napp.get(\"/frontend/*\", (c) => serveFile(c.req.path, import.meta.url));\napp.get(\"/\", async (c) => {\n let html = await readFile(\"/frontend/index.html\", import.meta.url);\n return c.html(html);\n});\n\nexport default app.fetch;\n","children",[],[236],"ed4de594-904f-4bb7-934b-e107082b9828","README.md","6586885a-79e2-11f1-ad26-1607ee4eb77e",["D",1783414869798],"# 🤖 Crypto Monitor\n\nИИ-анализ крипто-графиков с биржи OKX в реальном времени: классические индикаторы + Smart Money Concepts → осмысленный вердикт («BTC/USDT зашёл в боковик», «ETH/USDT растёт» и т.д.).\n\n## Возможности\n\n- 📊 Живой свечной график (lightweight-charts) с EMA 20/50/200, автообновление каждые 30 сек\n- 🪙 Выбор пары (BTC, ETH, SOL, XRP и др.) и таймфрейма (5м — 1д)\n- 📈 Индикаторы: EMA, RSI, MACD, ATR, Bollinger Bands (в т.ч. сжатие), объёмы\n- 🧠 Smart Money Concepts: структура рынка (HH/HL/LH/LL), BOS/CHoCH, незакрытые FVG, активные ордер-блоки, пулы ликвидности (equal highs/lows), premium/discount зона\n- 🤖 ИИ (Val Town `std/openai`, ключи не нужны) синтезирует все сигналы в связный анализ: вердикт, bias, уверенность, наблюдения, ключевые уровни, бычий/медвежий сценарии\n- ⚡ Кэш анализа: ИИ вызывается один раз на закрытую свечу для каждой пары/ТФ\n\n## Архитектура\n\n```mermaid\nflowchart LR\n UI[React-дашборд
frontend/] -->|/api/candles, /api/analyze| S[Hono-сервер
index.ts]\n S -->|свечи, тикер| OKX[(OKX Public API)]\n S --> IND[indicators.ts
EMA·RSI·MACD·ATR·BB]\n S --> SMC[smc.ts
структура·FVG·OB·ликвидность]\n IND & SMC -->|компактная сводка JSON| AI[ai.ts
std/openai · gpt-4o-mini]\n AI -->|вердикт + уровни + сценарии| UI\n```\n\n## Файлы\n\n- `index.ts` — HTTP-роуты: `/`, `/api/candles`, `/api/analyze`\n- `backend/okx.ts` — свечи и тикер с OKX\n- `backend/indicators.ts` — расчёт индикаторов + сводка для ИИ\n- `backend/smc.ts` — Smart Money Concepts\n- `backend/ai.ts` — промпт, вызов ИИ, кэш по последней закрытой свече\n- `frontend/` — React-дашборд (Chart, AnalysisPanel)\n\n⚠️ Не является финансовым советом — это анализ графика, сгенерированный ИИ.\n",[],[246],["D",1783414820427],[],[18,74],["D",1783414736184],[],[18,85],["D",1783414555839],[],[18,90],"ef55046e-156f-45dc-83c2-ac3005286d7a","Chart.tsx","1cce6e8e-79e2-11f1-ad26-1607ee4eb77e",11,["D",1783414747799],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useEffect, useRef } from \"https://esm.sh/react@18.2.0\";\nimport { createChart, type IChartApi } from \"https://esm.sh/lightweight-charts@4.2.3\";\n\ninterface Candle { ts: number; o: number; h: number; l: number; c: number; vol: number }\n\nexport default function Chart(\n { candles, series }: {\n candles: Candle[];\n series: { ema20: (number | null)[]; ema50: (number | null)[]; ema200: (number | null)[] };\n },\n) {\n const ref = useRef(null);\n const chartRef = useRef(null);\n\n useEffect(() => {\n if (!ref.current) return;\n const chart = createChart(ref.current, {\n height: 420,\n layout: { background: { color: \"#0f1420\" }, textColor: \"#8b95a7\" },\n grid: {\n vertLines: { color: \"#1a2130\" },\n horzLines: { color: \"#1a2130\" },\n },\n timeScale: { timeVisible: true, secondsVisible: false, borderColor: \"#1a2130\" },\n rightPriceScale: { borderColor: \"#1a2130\" },\n crosshair: { mode: 0 },\n });\n chartRef.current = chart;\n\n const candleSeries = chart.addCandlestickSeries({\n upColor: \"#22c55e\",\n downColor: \"#ef4444\",\n borderVisible: false,\n wickUpColor: \"#22c55e\",\n wickDownColor: \"#ef4444\",\n });\n candleSeries.setData(\n candles.map((c) => ({\n time: (c.ts / 1000) as any,\n open: c.o,\n high: c.h,\n low: c.l,\n close: c.c,\n })),\n );\n\n const addEma = (values: (number | null)[], color: string, title: string) => {\n const line = chart.addLineSeries({ color, lineWidth: 1, title, priceLineVisible: false, lastValueVisible: false });\n line.setData(\n values\n .map((v, i) => (v !== null ? { time: (candles[i].ts / 1000) as any, value: v } : null))\n .filter(Boolean) as any,\n );\n };\n addEma(series.ema20, \"#38bdf8\", \"EMA20\");\n addEma(series.ema50, \"#f59e0b\", \"EMA50\");\n addEma(series.ema200, \"#a78bfa\", \"EMA200\");\n\n chart.timeScale().fitContent();\n\n const onResize = () => {\n if (ref.current) chart.applyOptions({ width: ref.current.clientWidth });\n };\n onResize();\n window.addEventListener(\"resize\", onResize);\n return () => {\n window.removeEventListener(\"resize\", onResize);\n chart.remove();\n chartRef.current = null;\n };\n }, [candles, series]);\n\n return

;\n}\n",[],[18,95,262],"6ada164a-622f-4bf1-ac9d-3ed348ddf195","App.tsx","019f3bca-84bb-7554-be09-5c4f368635be",13,["D",1783414808522],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React, { useCallback, useEffect, useRef, useState } from \"https://esm.sh/react@18.2.0\";\nimport Chart from \"./Chart.tsx\";\nimport AnalysisPanel from \"./AnalysisPanel.tsx\";\n\nconst PAIRS = [\n \"BTC-USDT\",\n \"ETH-USDT\",\n \"SOL-USDT\",\n \"XRP-USDT\",\n \"BNB-USDT\",\n \"DOGE-USDT\",\n \"TON-USDT\",\n \"ADA-USDT\",\n \"LINK-USDT\",\n \"AVAX-USDT\",\n \"SUI-USDT\",\n \"PEPE-USDT\",\n];\n\nconst BARS = [\n { v: \"5m\", label: \"5м\" },\n { v: \"15m\", label: \"15м\" },\n { v: \"30m\", label: \"30м\" },\n { v: \"1H\", label: \"1ч\" },\n { v: \"4H\", label: \"4ч\" },\n { v: \"1D\", label: \"1д\" },\n];\n\nexport default function App() {\n const [instId, setInstId] = useState(\"BTC-USDT\");\n const [bar, setBar] = useState(\"15m\");\n const [chartData, setChartData] = useState(null);\n const [analysis, setAnalysis] = useState(null);\n const [loadingAnalysis, setLoadingAnalysis] = useState(false);\n const [analysisError, setAnalysisError] = useState(null);\n const reqId = useRef(0);\n\n const loadCandles = useCallback(async (id: string, b: string) => {\n try {\n const res = await fetch(`/api/candles?instId=${id}&bar=${b}`);\n const json = await res.json();\n if (json.error) throw new Error(json.error);\n setChartData(json);\n } catch (e) {\n console.error(\"candles error\", e);\n }\n }, []);\n\n const loadAnalysis = useCallback(async (id: string, b: string) => {\n const my = ++reqId.current;\n setLoadingAnalysis(true);\n setAnalysisError(null);\n try {\n const res = await fetch(`/api/analyze?instId=${id}&bar=${b}`);\n const json = await res.json();\n if (my !== reqId.current) return; // устаревший запрос\n if (json.error) throw new Error(json.error);\n setAnalysis(json);\n } catch (e) {\n if (my === reqId.current) setAnalysisError((e as Error).message);\n } finally {\n if (my === reqId.current) setLoadingAnalysis(false);\n }\n }, []);\n\n // при смене пары/ТФ — грузим всё; свечи автообновляются каждые 30 сек\n useEffect(() => {\n setAnalysis(null);\n loadCandles(instId, bar);\n loadAnalysis(instId, bar);\n const t = setInterval(() => loadCandles(instId, bar), 30_000);\n return () => clearInterval(t);\n }, [instId, bar, loadCandles, loadAnalysis]);\n\n const ticker = chartData?.ticker;\n const chgCls = ticker && ticker.change24hPct >= 0 ? \"text-green-400\" : \"text-red-400\";\n\n return (\n

\n {/* Шапка */}\n

🤖 Crypto Monitor

ИИ-анализ графиков OKX: индикаторы + Smart Money Concepts

\n {ticker && (\n

{ticker.last.toLocaleString()}

\n {ticker.change24hPct >= 0 ? \"+\" : \"\"}\n {ticker.change24hPct.toFixed(2)}% за 24ч\n

\n )}\n

\n\n {/* Панель управления */}\n

\n setInstId(e.target.value)}\n className=\"bg-slate-900 border border-slate-700 rounded-lg px-3 py-2 text-sm font-mono focus:outline-none focus:border-sky-500\"\n >\n {PAIRS.map((p) => )}\n \n\n

\n {BARS.map((b) => (\n setBar(b.v)}\n className={`px-3 py-2 text-sm font-medium transition-colors ${\n bar === b.v ? \"bg-sky-600 text-white\" : \"bg-slate-900 text-slate-400 hover:bg-slate-800\"\n }`}\n >\n {b.label}\n \n ))}\n

\n\n loadAnalysis(instId, bar)}\n disabled={loadingAnalysis}\n className=\"ml-auto px-4 py-2 rounded-lg bg-sky-600 hover:bg-sky-500 disabled:opacity-50 text-sm font-semibold transition-colors\"\n >\n {loadingAnalysis ? \"Анализ…\" : \"🔄 Обновить анализ\"}\n \n

\n\n {/* График */}\n

\n {chartData\n ? \n : (\n

\n Загрузка графика…\n

\n )}\n

\n ━ EMA20\n ━ EMA50\n ━ EMA200\n автообновление свечей каждые 30 сек\n

\n\n {/* Анализ */}\n \n\n \n

\n );\n}\n",[],[18,95,270],"ff297743-22b9-4ecf-ae12-fb87ec63028f","AnalysisPanel.tsx","3224fc12-79e2-11f1-93fb-1607ee4eb77e",12,["D",1783414783585],"/** @jsxImportSource https://esm.sh/react@18.2.0 */\nimport React from \"https://esm.sh/react@18.2.0\";\n\nconst VERDICT_META: Record = {\n uptrend: { label: \"Растёт\", icon: \"📈\", cls: \"bg-green-500/15 text-green-400 border-green-500/40\" },\n downtrend: { label: \"Падает\", icon: \"📉\", cls: \"bg-red-500/15 text-red-400 border-red-500/40\" },\n range: { label: \"Боковик\", icon: \"↔️\", cls: \"bg-yellow-500/15 text-yellow-400 border-yellow-500/40\" },\n reversal_risk: { label: \"Риск разворота\", icon: \"⚠️\", cls: \"bg-orange-500/15 text-orange-400 border-orange-500/40\" },\n};\n\nconst BIAS_META: Record = {\n long: { label: \"LONG\", cls: \"text-green-400\" },\n short: { label: \"SHORT\", cls: \"text-red-400\" },\n neutral: { label: \"НЕЙТРАЛЬНО\", cls: \"text-slate-400\" },\n};\n\nexport default function AnalysisPanel({ data, loading, error }: { data: any; loading: boolean; error: string | null }) {\n if (loading) {\n return (\n

\n \n ИИ анализирует график (индикаторы + Smart Money)…\n

\n );\n }\n if (error) {\n return

Ошибка анализа: {error}

;\n }\n if (!data) return null;\n\n const a = data.analysis;\n const v = VERDICT_META[a.verdict] ?? VERDICT_META.range;\n const b = BIAS_META[a.bias] ?? BIAS_META.neutral;\n const smc = data.smc;\n const ind = data.indicators;\n\n return (\n

\n {/* Вердикт */}\n

Вердикт ИИ · {v.icon} {v.label}

{a.headline}

{b.label}

уверенность {a.confidence}%

{a.summary}

\n\n {/* Наблюдения */}\n

🔍 Наблюдения

\n ▸\n {o}\n

\n\n {/* Уровни и сценарии */}\n

🎯 Ключевые уровни

\n Сопротивления: {a.keyLevels.resistance.map((x: number) => x.toLocaleString()).join(\" · \") || \"—\"}\n

\n Поддержки: {a.keyLevels.support.map((x: number) => x.toLocaleString()).join(\" · \") || \"—\"}\n

🔮 Сценарии

Бычий: {a.scenarios.bullish}

Медвежий: {a.scenarios.bearish}

\n\n {/* Сырые данные: индикаторы + SMC */}\n

📊 Индикаторы

\n \n \n \n \n \n 0 ? \"+\" : \"\"}${ind.ema.priceVsEma200Pct}%`} />\n \n \n \n \n

🧠 Smart Money

\n \n \n \n \n \n `${f.type === \"bullish\" ? \"буч.\" : \"медв.\"} ${f.bottom.toLocaleString()}–${f.top.toLocaleString()}`).join(\"; \") : \"нет\"} />\n `${o.type === \"bullish\" ? \"буч.\" : \"медв.\"} ${o.bottom.toLocaleString()}–${o.top.toLocaleString()}`).join(\"; \") : \"нет\"} />\n `${p.type === \"buy_side\" ? \"сверху\" : \"снизу\"} @${p.price.toLocaleString()}`).join(\"; \") : \"нет\"} />\n \n

\n\n

\n Анализ от {new Date(data.analyzedAt).toLocaleTimeString()} {data.cached ? \"(кэш — обновится с закрытием новой свечи)\" : \"(свежий)\"} · Не является финансовым советом\n

\n );\n}\n\nfunction Row({ k, v }: { k: string; v: any }) {\n return (\n \n {k}\n {String(v ?? \"—\")}\n \n );\n}\n",[],[18,95,278],["D",1783414555839],[227,228,229],[18,95],["D",1783414555839],[226,230,231,232],[18],"3a2af989-4a50-4892-bb88-bd0070348e4b","smc.ts","ea35cc56-79e1-11f1-b313-1607ee4eb77e","404bbf5d-3bf6-4963-ae70-e1c66a2caf36",7,["D",1783414662913],"// Smart Money Concepts: структура рынка, BOS/CHoCH, FVG, ордер-блоки, ликвидность\nimport type { Candle } from \"./okx.ts\";\n\nexport interface Swing {\n index: number;\n ts: number;\n price: number;\n type: \"high\" | \"low\";\n}\n\n/** Свинг-точки (фракталы с плечом lookback) */\nexport function findSwings(candles: Candle[], lookback = 3): Swing[] {\n const swings: Swing[] = [];\n for (let i = lookback; i < candles.length - lookback; i++) {\n const c = candles[i];\n let isHigh = true, isLow = true;\n for (let j = i - lookback; j <= i + lookback; j++) {\n if (j === i) continue;\n if (candles[j].h >= c.h) isHigh = false;\n if (candles[j].l <= c.l) isLow = false;\n }\n if (isHigh) swings.push({ index: i, ts: c.ts, price: c.h, type: \"high\" });\n if (isLow) swings.push({ index: i, ts: c.ts, price: c.l, type: \"low\" });\n }\n return swings;\n}\n\n/** Структура рынка: HH/HL vs LH/LL + последний BOS/CHoCH */\nexport function marketStructure(candles: Candle[], swings: Swing[]) {\n const highs = swings.filter((s) => s.type === \"high\").slice(-4);\n const lows = swings.filter((s) => s.type === \"low\").slice(-4);\n\n const labels: string[] = [];\n for (let i = 1; i < highs.length; i++) {\n labels.push(highs[i].price > highs[i - 1].price ? \"HH\" : \"LH\");\n }\n for (let i = 1; i < lows.length; i++) {\n labels.push(lows[i].price > lows[i - 1].price ? \"HL\" : \"LL\");\n }\n\n const hh = labels.filter((l) => l === \"HH\").length;\n const hl = labels.filter((l) => l === \"HL\").length;\n const lh = labels.filter((l) => l === \"LH\").length;\n const ll = labels.filter((l) => l === \"LL\").length;\n\n let trend: \"uptrend\" | \"downtrend\" | \"range\" = \"range\";\n if (hh + hl >= 3 && hh >= 1 && hl >= 1) trend = \"uptrend\";\n else if (lh + ll >= 3 && lh >= 1 && ll >= 1) trend = \"downtrend\";\n\n // BOS / CHoCH: пробила ли цена закрытием последний свинг\n const price = candles[candles.length - 1].c;\n const lastHigh = highs[highs.length - 1];\n const lastLow = lows[lows.length - 1];\n let structureEvent: string | null = null;\n if (lastHigh && price > lastHigh.price) {\n structureEvent = trend === \"downtrend\"\n ? \"CHoCH_bullish (слом нисходящей структуры вверх)\"\n : \"BOS_bullish (пробой последнего свинг-хая)\";\n } else if (lastLow && price < lastLow.price) {\n structureEvent = trend === \"uptrend\"\n ? \"CHoCH_bearish (слом восходящей структуры вниз)\"\n : \"BOS_bearish (пробой последнего свинг-лоу)\";\n }\n\n return {\n trend,\n recentLabels: labels,\n lastSwingHigh: lastHigh ? { price: lastHigh.price, barsAgo: candles.length - 1 - lastHigh.index } : null,\n lastSwingLow: lastLow ? { price: lastLow.price, barsAgo: candles.length - 1 - lastLow.index } : null,\n structureEvent,\n };\n}\n\n/** Незакрытые имбалансы (Fair Value Gaps) за последние N баров */\nexport function findFVG(candles: Candle[], maxAge = 60) {\n const fvgs: { type: \"bullish\" | \"bearish\"; top: number; bottom: number; barsAgo: number }[] = [];\n const n = candles.length;\n const price = candles[n - 1].c;\n for (let i = Math.max(2, n - maxAge); i < n - 1; i++) {\n // бычий FVG: low[i+1] > high[i-1]\n if (candles[i + 1].l > candles[i - 1].h) {\n const top = candles[i + 1].l, bottom = candles[i - 1].h;\n // не заполнен, если цена не вернулась ниже bottom\n const filled = candles.slice(i + 2).some((c) => c.l <= bottom);\n if (!filled && price > bottom) {\n fvgs.push({ type: \"bullish\", top, bottom, barsAgo: n - 1 - i });\n }\n }\n // медвежий FVG: high[i+1] < low[i-1]\n if (candles[i + 1].h < candles[i - 1].l) {\n const top = candles[i - 1].l, bottom = candles[i + 1].h;\n const filled = candles.slice(i + 2).some((c) => c.h >= top);\n if (!filled && price < top) {\n fvgs.push({ type: \"bearish\", top, bottom, barsAgo: n - 1 - i });\n }\n }\n }\n return fvgs.slice(-5);\n}\n\n/** Ордер-блоки: последняя противоположная свеча перед импульсом, пробившим структуру */\nexport function findOrderBlocks(candles: Candle[], atrValue: number | null, maxAge = 80) {\n const obs: { type: \"bullish\" | \"bearish\"; top: number; bottom: number; barsAgo: number }[] = [];\n const n = candles.length;\n const price = candles[n - 1].c;\n const impulse = (atrValue ?? avgRange(candles)) * 1.5;\n\n for (let i = Math.max(1, n - maxAge); i < n - 2; i++) {\n const c = candles[i];\n const next3 = candles.slice(i + 1, i + 4);\n const up = next3.length && Math.max(...next3.map((x) => x.c)) - c.c > impulse;\n const down = next3.length && c.c - Math.min(...next3.map((x) => x.c)) > impulse;\n // бычий OB: медвежья свеча перед импульсом вверх\n if (c.c < c.o && up) {\n const mitigated = candles.slice(i + 4).some((x) => x.l <= c.l);\n if (!mitigated && price > c.h) {\n obs.push({ type: \"bullish\", top: c.h, bottom: c.l, barsAgo: n - 1 - i });\n }\n }\n // медвежий OB: бычья свеча перед импульсом вниз\n if (c.c > c.o && down) {\n const mitigated = candles.slice(i + 4).some((x) => x.h >= c.h);\n if (!mitigated && price < c.l) {\n obs.push({ type: \"bearish\", top: c.h, bottom: c.l, barsAgo: n - 1 - i });\n }\n }\n }\n return obs.slice(-4);\n}\n\nfunction avgRange(candles: Candle[]) {\n const slice = candles.slice(-20);\n return slice.reduce((a, c) => a + (c.h - c.l), 0) / slice.length;\n}\n\n/** Скопления ликвидности: равные хаи/лои (в пределах допуска) */\nexport function findLiquidity(swings: Swing[], tolerancePct = 0.15) {\n const pools: { type: \"buy_side\" | \"sell_side\"; price: number; touches: number }[] = [];\n const check = (group: Swing[], type: \"buy_side\" | \"sell_side\") => {\n for (let i = 0; i < group.length; i++) {\n const cluster = group.filter(\n (s) => Math.abs(s.price - group[i].price) / group[i].price * 100 < tolerancePct,\n );\n if (cluster.length >= 2) {\n const price = cluster.reduce((a, s) => a + s.price, 0) / cluster.length;\n if (!pools.some((p) => p.type === type && Math.abs(p.price - price) / price * 100 < tolerancePct)) {\n pools.push({ type, price, touches: cluster.length });\n }\n }\n }\n };\n check(swings.filter((s) => s.type === \"high\").slice(-10), \"buy_side\"); // equal highs → ликвидность сверху\n check(swings.filter((s) => s.type === \"low\").slice(-10), \"sell_side\"); // equal lows → ликвидность снизу\n return pools.slice(-4);\n}\n\n/** Premium / Discount относительно последнего значимого диапазона */\nexport function premiumDiscount(candles: Candle[], swings: Swing[]) {\n const highs = swings.filter((s) => s.type === \"high\");\n const lows = swings.filter((s) => s.type === \"low\");\n if (!highs.length || !lows.length) return null;\n const rangeHigh = Math.max(...highs.slice(-3).map((s) => s.price));\n const rangeLow = Math.min(...lows.slice(-3).map((s) => s.price));\n const price = candles[candles.length - 1].c;\n const posPct = ((price - rangeLow) / (rangeHigh - rangeLow)) * 100;\n return {\n rangeHigh,\n rangeLow,\n equilibrium: (rangeHigh + rangeLow) / 2,\n pricePositionPct: +posPct.toFixed(1),\n zone: posPct > 60 ? \"premium\" : posPct < 40 ? \"discount\" : \"equilibrium\",\n };\n}\n\n/** Полная SMC-сводка для ИИ */\nexport function smcSummary(candles: Candle[], atrValue: number | null) {\n const swings = findSwings(candles);\n return {\n structure: marketStructure(candles, swings),\n unfilledFVG: findFVG(candles),\n activeOrderBlocks: findOrderBlocks(candles, atrValue),\n liquidityPools: findLiquidity(swings),\n premiumDiscount: premiumDiscount(candles, swings),\n };\n}\n",[],[300,292],"backend","71c996d8-56c8-44e4-a4fe-815835620009","okx.ts","be9f6af2-79e1-11f1-933e-1607ee4eb77e",5,["D",1783414589784],"// Работа с публичным API биржи OKX (без ключей)\n\nexport interface Candle {\n ts: number; // ms\n o: number;\n h: number;\n l: number;\n c: number;\n vol: number;\n}\n\nexport const SUPPORTED_BARS = [\"1m\", \"5m\", \"15m\", \"30m\", \"1H\", \"4H\", \"1D\", \"1W\"] as const;\nexport type Bar = typeof SUPPORTED_BARS[number];\n\n/**\n * Загружает свечи с OKX. Возвращает от старых к новым.\n * https://www.okx.com/docs-v5/en/#order-book-trading-market-data-get-candlesticks\n */\nexport async function fetchCandles(instId: string, bar: string, limit = 300): Promise {\n const url = `https://www.okx.com/api/v5/market/candles?instId=${encodeURIComponent(instId)}&bar=${\n encodeURIComponent(bar)\n }&limit=${limit}`;\n const res = await fetch(url, { headers: { \"User-Agent\": \"val.town crypto-monitor\" } });\n if (!res.ok) throw new Error(`OKX HTTP ${res.status}`);\n const json = await res.json();\n if (json.code !== \"0\") throw new Error(`OKX error: ${json.msg || json.code}`);\n const rows: string[][] = json.data;\n // OKX отдаёт от новых к старым — разворачиваем\n return rows\n .map((r) => ({\n ts: Number(r[0]),\n o: Number(r[1]),\n h: Number(r[2]),\n l: Number(r[3]),\n c: Number(r[4]),\n vol: Number(r[5]),\n }))\n .reverse();\n}\n\n/** Текущий тикер (последняя цена, изменение за 24ч) */\nexport async function fetchTicker(instId: string) {\n const res = await fetch(\n `https://www.okx.com/api/v5/market/ticker?instId=${encodeURIComponent(instId)}`,\n );\n const json = await res.json();\n if (json.code !== \"0\") throw new Error(`OKX error: ${json.msg || json.code}`);\n const t = json.data[0];\n const last = Number(t.last);\n const open24h = Number(t.open24h);\n return {\n last,\n open24h,\n high24h: Number(t.high24h),\n low24h: Number(t.low24h),\n change24hPct: open24h ? ((last - open24h) / open24h) * 100 : 0,\n };\n}\n",[],[300,302],"6bdf0b5b-4caf-4495-b001-92a9b5936804","indicators.ts","d3cadb00-79e1-11f1-9a47-1607ee4eb77e",6,["D",1783414625301],"// Классические технические индикаторы\nimport type { Candle } from \"./okx.ts\";\n\nexport function sma(values: number[], period: number): (number | null)[] {\n const out: (number | null)[] = new Array(values.length).fill(null);\n let sum = 0;\n for (let i = 0; i < values.length; i++) {\n sum += values[i];\n if (i >= period) sum -= values[i - period];\n if (i >= period - 1) out[i] = sum / period;\n }\n return out;\n}\n\nexport function ema(values: number[], period: number): (number | null)[] {\n const out: (number | null)[] = new Array(values.length).fill(null);\n const k = 2 / (period + 1);\n let prev: number | null = null;\n for (let i = 0; i < values.length; i++) {\n if (i === period - 1) {\n prev = values.slice(0, period).reduce((a, b) => a + b, 0) / period;\n out[i] = prev;\n } else if (prev !== null) {\n prev = values[i] * k + prev * (1 - k);\n out[i] = prev;\n }\n }\n return out;\n}\n\nexport function rsi(closes: number[], period = 14): (number | null)[] {\n const out: (number | null)[] = new Array(closes.length).fill(null);\n let avgGain = 0, avgLoss = 0;\n for (let i = 1; i < closes.length; i++) {\n const diff = closes[i] - closes[i - 1];\n const gain = Math.max(diff, 0), loss = Math.max(-diff, 0);\n if (i <= period) {\n avgGain += gain / period;\n avgLoss += loss / period;\n if (i === period) out[i] = avgLoss === 0 ? 100 : 100 - 100 / (1 + avgGain / avgLoss);\n } else {\n avgGain = (avgGain * (period - 1) + gain) / period;\n avgLoss = (avgLoss * (period - 1) + loss) / period;\n out[i] = avgLoss === 0 ? 100 : 100 - 100 / (1 + avgGain / avgLoss);\n }\n }\n return out;\n}\n\nexport function macd(closes: number[], fast = 12, slow = 26, signalP = 9) {\n const emaFast = ema(closes, fast);\n const emaSlow = ema(closes, slow);\n const macdLine = closes.map((_, i) =>\n emaFast[i] !== null && emaSlow[i] !== null ? (emaFast[i]! - emaSlow[i]!) : null\n );\n // сигнальная линия = EMA от MACD (по ненулевой части)\n const start = macdLine.findIndex((v) => v !== null);\n const clean = macdLine.slice(start) as number[];\n const sig = ema(clean, signalP);\n const signal: (number | null)[] = new Array(closes.length).fill(null);\n for (let i = 0; i < sig.length; i++) signal[start + i] = sig[i];\n const hist = macdLine.map((v, i) => (v !== null && signal[i] !== null ? v - signal[i]! : null));\n return { macdLine, signal, hist };\n}\n\nexport function atr(candles: Candle[], period = 14): (number | null)[] {\n const out: (number | null)[] = new Array(candles.length).fill(null);\n let prev: number | null = null;\n const trs: number[] = [];\n for (let i = 0; i < candles.length; i++) {\n const c = candles[i];\n const prevClose = i > 0 ? candles[i - 1].c : c.o;\n const tr = Math.max(c.h - c.l, Math.abs(c.h - prevClose), Math.abs(c.l - prevClose));\n trs.push(tr);\n if (i === period - 1) {\n prev = trs.reduce((a, b) => a + b, 0) / period;\n out[i] = prev;\n } else if (prev !== null) {\n prev = (prev * (period - 1) + tr) / period;\n out[i] = prev;\n }\n }\n return out;\n}\n\nexport function bollinger(closes: number[], period = 20, mult = 2) {\n const mid = sma(closes, period);\n const upper: (number | null)[] = new Array(closes.length).fill(null);\n const lower: (number | null)[] = new Array(closes.length).fill(null);\n for (let i = period - 1; i < closes.length; i++) {\n const slice = closes.slice(i - period + 1, i + 1);\n const m = mid[i]!;\n const sd = Math.sqrt(slice.reduce((a, b) => a + (b - m) ** 2, 0) / period);\n upper[i] = m + mult * sd;\n lower[i] = m - mult * sd;\n }\n return { mid, upper, lower };\n}\n\nconst last = (arr: (T | null)[]): T | null => {\n for (let i = arr.length - 1; i >= 0; i--) if (arr[i] !== null) return arr[i];\n return null;\n};\n\n/** Компактная сводка индикаторов для ИИ */\nexport function indicatorSummary(candles: Candle[]) {\n const closes = candles.map((c) => c.c);\n const vols = candles.map((c) => c.vol);\n const price = closes[closes.length - 1];\n\n const ema20 = ema(closes, 20), ema50 = ema(closes, 50), ema200 = ema(closes, 200);\n const rsiArr = rsi(closes);\n const { macdLine, signal, hist } = macd(closes);\n const atrArr = atr(candles);\n const bb = bollinger(closes);\n\n const e20 = last(ema20), e50 = last(ema50), e200 = last(ema200);\n const r = last(rsiArr);\n const rPrev = rsiArr[rsiArr.length - 6] ?? null;\n const m = last(macdLine), s = last(signal), h = last(hist);\n const hPrev = hist[hist.length - 4] ?? null;\n const a = last(atrArr);\n const bbU = last(bb.upper), bbL = last(bb.lower), bbM = last(bb.mid);\n\n // сжатие полос Боллинджера (сравниваем ширину с медианой за 60 баров)\n const widths: number[] = [];\n for (let i = Math.max(0, closes.length - 60); i < closes.length; i++) {\n if (bb.upper[i] !== null && bb.lower[i] !== null && bb.mid[i]) {\n widths.push((bb.upper[i]! - bb.lower[i]!) / bb.mid[i]!);\n }\n }\n const curWidth = bbU !== null && bbL !== null && bbM ? (bbU - bbL) / bbM : null;\n const medWidth = widths.length ? widths.slice().sort((x, y) => x - y)[Math.floor(widths.length / 2)] : null;\n\n const volAvg = vols.slice(-20).reduce((x, y) => x + y, 0) / Math.min(20, vols.length);\n const volLast = vols[vols.length - 1];\n\n const pct = (v: number | null) => (v === null ? null : +((price - v) / v * 100).toFixed(2));\n\n return {\n price,\n ema: {\n ema20: e20, ema50: e50, ema200: e200,\n priceVsEma20Pct: pct(e20), priceVsEma50Pct: pct(e50), priceVsEma200Pct: pct(e200),\n alignment: e20 !== null && e50 !== null && e200 !== null\n ? (e20 > e50 && e50 > e200 ? \"bullish\" : e20 < e50 && e50 < e200 ? \"bearish\" : \"mixed\")\n : \"insufficient_data\",\n },\n rsi14: r !== null ? +r.toFixed(1) : null,\n rsi14_5barsAgo: rPrev !== null ? +rPrev.toFixed(1) : null,\n macd: {\n macd: m, signal: s, histogram: h,\n histogram3barsAgo: hPrev,\n state: m !== null && s !== null ? (m > s ? \"macd_above_signal\" : \"macd_below_signal\") : null,\n histogramDirection: h !== null && hPrev !== null ? (h > hPrev ? \"expanding_up\" : \"contracting/down\") : null,\n },\n atr14: a,\n atrPctOfPrice: a !== null ? +(a / price * 100).toFixed(2) : null,\n bollinger: {\n upper: bbU, mid: bbM, lower: bbL,\n pricePosition: bbU !== null && bbL !== null\n ? +(((price - bbL) / (bbU - bbL)) * 100).toFixed(1) // 0 = нижняя, 100 = верхняя\n : null,\n squeeze: curWidth !== null && medWidth !== null ? curWidth < medWidth * 0.7 : null,\n },\n volume: {\n lastVsAvg20: volAvg ? +(volLast / volAvg).toFixed(2) : null,\n },\n change: {\n last10barsPct: +((price - closes[closes.length - 11]) / closes[closes.length - 11] * 100).toFixed(2),\n last50barsPct: closes.length > 51\n ? +((price - closes[closes.length - 51]) / closes[closes.length - 51] * 100).toFixed(2)\n : null,\n },\n };\n}\n\n/** Серии для отрисовки на графике */\nexport function chartSeries(candles: Candle[]) {\n const closes = candles.map((c) => c.c);\n return {\n ema20: ema(closes, 20),\n ema50: ema(closes, 50),\n ema200: ema(closes, 200),\n };\n}\n",[],[300,310],"c02d9396-dc68-4b9a-878e-2a775910404b","ai.ts","fb002a7c-79e1-11f1-bfda-1607ee4eb77e",8,["D",1783414691082],"// ИИ-анализ: индикаторы + SMC → осмысленный вердикт (std/openai, бесплатно на Val Town)\nimport { OpenAI } from \"https://esm.town/v/std/openai\";\n\nexport interface AiAnalysis {\n headline: string;\n verdict: \"uptrend\" | \"downtrend\" | \"range\" | \"reversal_risk\";\n bias: \"long\" | \"short\" | \"neutral\";\n confidence: number;\n summary: string;\n observations: string[];\n keyLevels: { support: number[]; resistance: number[] };\n scenarios: { bullish: string; bearish: string };\n}\n\nconst SYSTEM_PROMPT = `Ты — опытный крипто-аналитик. Тебе дают рассчитанные по свечам OKX данные:\nклассические индикаторы (EMA 20/50/200, RSI, MACD, ATR, Bollinger, объёмы) и Smart Money Concepts\n(структура рынка HH/HL/LH/LL, BOS/CHoCH, незакрытые FVG, активные ордер-блоки, пулы ликвидности\nequal highs/lows, premium/discount зона).\n\nТвоя задача — дать ОСМЫСЛЕННЫЙ анализ на русском языке, синтезируя ВСЕ данные, а не пересказывая их.\nИщи конфлюэнс (совпадение сигналов) и противоречия. Примеры хорошего мышления:\n- \"цена в premium-зоне + медвежий ордер-блок сверху + RSI дивергенция → риск снятия ликвидности и разворота\"\n- \"BOS вверх + откат в бычий FVG в discount-зоне + EMA веером вверх → тренд, покупатели контролируют\"\n- \"сжатие Боллинджера + структура range + равные хаи/лои с двух сторон → боковик, накопление, ждать пробоя\"\n\nНе выдумывай цифры — используй только предоставленные уровни. Не давай финансовых советов, только анализ графика.\n\nОтвет строго JSON:\n{\n \"headline\": \"краткий вердикт одной фразой, напр. 'BTC/USDT зашёл в боковик — накопление под ликвидностью'\",\n \"verdict\": \"uptrend\" | \"downtrend\" | \"range\" | \"reversal_risk\",\n \"bias\": \"long\" | \"short\" | \"neutral\",\n \"confidence\": число 0-100,\n \"summary\": \"2-4 предложения связного анализа с конфлюэнсом сигналов\",\n \"observations\": [\"3-6 конкретных наблюдений, каждое со ссылкой на индикатор или SMC-концепт и уровни\"],\n \"keyLevels\": { \"support\": [числа], \"resistance\": [числа] },\n \"scenarios\": { \"bullish\": \"что подтвердит рост и куда цель\", \"bearish\": \"что подтвердит падение и куда цель\" }\n}`;\n\nexport async function analyzeWithAI(\n instId: string,\n bar: string,\n payload: unknown,\n): Promise {\n const openai = new OpenAI();\n const completion = await openai.chat.completions.create({\n model: \"gpt-4o-mini\",\n response_format: { type: \"json_object\" },\n temperature: 0.3,\n messages: [\n { role: \"system\", content: SYSTEM_PROMPT },\n {\n role: \"user\",\n content: `Инструмент: ${instId}, таймфрейм: ${bar}.\\nДанные:\\n${JSON.stringify(payload)}`,\n },\n ],\n });\n const text = completion.choices[0]?.message?.content ?? \"{}\";\n const parsed = JSON.parse(text);\n return {\n headline: parsed.headline ?? \"Нет данных\",\n verdict: parsed.verdict ?? \"range\",\n bias: parsed.bias ?? \"neutral\",\n confidence: Number(parsed.confidence) || 50,\n summary: parsed.summary ?? \"\",\n observations: Array.isArray(parsed.observations) ? parsed.observations : [],\n keyLevels: {\n support: Array.isArray(parsed.keyLevels?.support) ? parsed.keyLevels.support : [],\n resistance: Array.isArray(parsed.keyLevels?.resistance) ? parsed.keyLevels.resistance : [],\n },\n scenarios: {\n bullish: parsed.scenarios?.bullish ?? \"\",\n bearish: parsed.scenarios?.bearish ?? \"\",\n },\n };\n}\n\n// Кэш в памяти: не дёргаем ИИ, пока не закрылась новая свеча\nconst cache = new Map();\n\nexport async function analyzeCached(\n instId: string,\n bar: string,\n lastCandleTs: number,\n payload: unknown,\n): Promise<{ analysis: AiAnalysis; cached: boolean; analyzedAt: number }> {\n const mapKey = `${instId}:${bar}`;\n const freshKey = `${lastCandleTs}`;\n const hit = cache.get(mapKey);\n if (hit && hit.key === freshKey) {\n return { analysis: hit.result, cached: true, analyzedAt: hit.at };\n }\n const result = await analyzeWithAI(instId, bar, payload);\n const at = Date.now();\n cache.set(mapKey, { key: freshKey, result, at });\n return { analysis: result, cached: false, analyzedAt: at };\n}\n",[],[300,318],"13d3dee9-1b04-4dfb-b89a-f00c2dd0ecc5",["D",1783414589784],[221,222,223,224],[300],["D",1783414239783],{"_11":12,"_162":80},{"_11":12,"_158":80,"_79":80,"_31":78,"_159":160,"_161":30},{"_41":149,"_13":16,"_35":38,"_150":115,"_151":-5,"_152":-5,"_153":-5,"_154":-5,"_155":-5,"_156":14,"_157":12},"ctx",{"_55":-5,"_181":366,"_367":368,"_369":370,"_371":30,"_372":30,"_373":30,"_374":24,"_375":-5,"_376":-7,"_377":-7,"_378":26,"_379":30,"_380":30,"_381":-5,"_382":30,"_383":30,"_384":30,"_385":-5},"ENV",{"_337":338,"_339":340,"_341":16,"_342":343,"_344":345,"_346":347,"_348":349,"_350":351,"_352":353,"_354":355,"_356":357,"_358":359,"_360":361,"_362":363,"_364":365},"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"]

History · frontend