[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_163":164,"_165":166},"routes/_app.x.$handle.$name",{"_104":103,"_38":51,"_112":94,"_33":106,"_13":14,"_113":-5,"_11":114,"_115":116,"_117":118,"_119":120,"_121":122,"_26":-5,"_123":-5,"_124":-5,"_125":31,"_126":127,"_128":31,"_129":-5,"_130":-5,"_131":132},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_49":50,"_38":51,"_44":52,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":-5,"_63":31,"_64":-5,"_65":-5,"_66":67,"_68":69,"_70":71,"_72":73,"_74":75,"_76":-5,"_77":78,"_79":78,"_80":81,"_82":81,"_83":81,"_84":78,"_85":78,"_86":87,"_88":89,"_90":91,"_92":31},"version",37,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","652bc5f1-8025-44f2-abd4-06dd4555dcb1","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":29,"_30":31,"_32":31,"_33":34,"_35":34},"file",{"_36":37,"_38":34,"_39":40,"_41":43,"_44":45,"_46":14,"_47":48,"_30":31},"previous",{"_36":37,"_38":34,"_39":40,"_41":42},"deleted",false,"deletedHere","path","main.ts","latestPath","fileId","b0fe12f6-a572-11f1-b4fb-1607ee4eb77e","name","fileType","interval","content","/**\n * Crypto Market Analysis → Binance Square + Telegram\n *\n * Every run:\n * 1. Finds the top USDT gainer on Binance (24h ticker stats).\n * 2. Pulls its last 24h of 1h candles and renders a dark-themed line chart via QuickChart.\n * 3. Publishes a formatted English technical-analysis post (S/R, Fibonacci, RSI) + chart to Binance Square.\n * 4. Notifies a Telegram chat with the result (success or failure).\n *\n * Required env vars:\n * SQUARE_API_KEY — Binance Square content-creator OpenAPI key\n * TELEGRAM_BOT_TOKEN — Telegram bot token (from @BotFather)\n * TELEGRAM_CHAT_ID — Telegram chat/channel id to notify\n */\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\ninterface BinanceTicker24hr {\n symbol: string;\n priceChange: string;\n priceChangePercent: string;\n lastPrice: string;\n highPrice: string;\n lowPrice: string;\n volume: string;\n}\n\ninterface Candle {\n open: number;\n high: number;\n low: number;\n close: number;\n closeTime: number;\n}\n\ninterface Analysis {\n closes: number[];\n rsi: number | null;\n rsiSignal: string;\n supportLevels: number[];\n resistanceLevels: number[];\n fibLevels: { ratio: string; price: number }[];\n trend: \"bullish\" | \"bearish\";\n periodHigh: number;\n periodLow: number;\n}\n\n// Binance kline row: [openTime, open, high, low, close, volume, closeTime, ...]\ntype BinanceKline = [number, string, string, string, string, string, number, ...unknown[]];\n\nconst BINANCE_API = \"https://www.binance.com/fapi/v1\";\nconst SQUARE_POST_URL =\n \"https://www.binance.com/bapi/composite/v1/public/pgc/openApi/content/add\";\n\n// ---------------------------------------------------------------------------\n// Binance market data\n// ---------------------------------------------------------------------------\n\nasync function getTopUsdtGainers(count = 3): Promise {\n const res = await fetch(`${BINANCE_API}/ticker/24hr`);\n if (!res.ok) {\n throw new Error(`Binance 24hr ticker request failed: ${res.status} ${res.statusText}`);\n }\n const tickers: BinanceTicker24hr[] = await res.json();\n\n const usdtPairs = tickers.filter((t) => t.symbol.endsWith(\"USDT\"));\n if (usdtPairs.length === 0) {\n throw new Error(\"No USDT trading pairs returned by Binance\");\n }\n\n return usdtPairs\n .sort((a, b) => parseFloat(b.priceChangePercent) - parseFloat(a.priceChangePercent))\n .slice(0, count);\n}\n\nasync function getKlines(symbol: string, limit = 168): Promise {\n const url = `${BINANCE_API}/klines?symbol=${symbol}&interval=1h&limit=${limit}`;\n const res = await fetch(url);\n if (!res.ok) {\n throw new Error(`Binance klines request failed for ${symbol}: ${res.status} ${res.statusText}`);\n }\n const klines: BinanceKline[] = await res.json();\n return klines.map((k) => ({\n open: parseFloat(k[1]),\n high: parseFloat(k[2]),\n low: parseFloat(k[3]),\n close: parseFloat(k[4]),\n closeTime: k[6],\n }));\n}\n\n// ---------------------------------------------------------------------------\n// Technical analysis: RSI, S/R levels, Fibonacci retracement\n// ---------------------------------------------------------------------------\n\n/** Wilder's RSI(14) */\nfunction computeRsi(closes: number[], period = 14): number | null {\n if (closes.length < period + 1) return null;\n let gain = 0;\n let loss = 0;\n for (let i = 1; i <= period; i++) {\n const diff = closes[i] - closes[i - 1];\n if (diff >= 0) gain += diff;\n else loss -= diff;\n }\n let avgGain = gain / period;\n let avgLoss = loss / period;\n for (let i = period + 1; i < closes.length; i++) {\n const diff = closes[i] - closes[i - 1];\n avgGain = (avgGain * (period - 1) + Math.max(diff, 0)) / period;\n avgLoss = (avgLoss * (period - 1) + Math.max(-diff, 0)) / period;\n }\n if (avgLoss === 0) return 100;\n const rs = avgGain / avgLoss;\n return 100 - 100 / (1 + rs);\n}\n\nfunction analyzeCandles(candles: Candle[]): Analysis {\n const closes = candles.map((c) => c.close);\n const currentPrice = closes[closes.length - 1];\n const periodHigh = Math.max(...candles.map((c) => c.high));\n const periodLow = Math.min(...candles.map((c) => c.low));\n\n // --- Support & resistance from swing highs/lows (fractal, ±3 candles) ---\n const supports: number[] = [];\n const resistances: number[] = [];\n const w = 3;\n for (let i = w; i < candles.length - w; i++) {\n const c = candles[i];\n const isSwingHigh = c.high >= Math.max(...candles.slice(i - w, i + w + 1).map((x) => x.high));\n const isSwingLow = c.low <= Math.min(...candles.slice(i - w, i + w + 1).map((x) => x.low));\n if (isSwingHigh && c.high > currentPrice) resistances.push(c.high);\n if (isSwingLow && c.low < currentPrice) supports.push(c.low);\n }\n // Classic pivot points (from the most recent completed daily-like window = last 24 candles)\n const window = candles.slice(-25, -1);\n const wh = Math.max(...window.map((c) => c.high));\n const wl = Math.min(...window.map((c) => c.low));\n const wc = window[window.length - 1].close;\n const pp = (wh + wl + wc) / 3;\n const pivots = [pp, 2 * pp - wl, pp + (wh - wl), 2 * pp - 2 * wl + wh, 2 * pp - 2 * wh + wl];\n for (const p of pivots) {\n if (p < currentPrice) supports.push(p);\n else resistances.push(p);\n }\n // Deduplicate and keep the nearest levels\n const dedupe = (arr: number[], ref: number, dir: 1 | -1) => {\n const sorted = [...new Set(arr.map((x) => +x.toFixed(6)))]\n .filter((x) => (dir === 1 ? x < ref : x > ref))\n .sort((a, b) => (dir === 1 ? b - a : a - b));\n const out: number[] = [];\n for (const x of sorted) {\n if (!out.length || Math.abs(x - out[out.length - 1]) / ref > 0.002) out.push(x);\n if (out.length === 3) break;\n }\n return out;\n };\n const supportLevels = dedupe(supports, currentPrice, 1);\n const resistanceLevels = dedupe(resistances, currentPrice, -1);\n\n // --- Fibonacci retracement between period low and high ---\n const diff = periodHigh - periodLow;\n const ratios = [\n [\"0.0\", 0], [\"0.236\", 0.236], [\"0.382\", 0.382], [\"0.5\", 0.5],\n [\"0.618\", 0.618], [\"0.786\", 0.786], [\"1.0\", 1],\n ] as const;\n const fibLevels = ratios.map(([ratio, r]) => ({\n ratio,\n price: +(periodLow + diff * r).toFixed(6),\n }));\n\n // --- RSI ---\n const rsi = computeRsi(closes);\n const rsiSignal = rsi == null\n ? \"insufficient data\"\n : rsi >= 70\n ? \"overbought ⚠️\"\n : rsi <= 30\n ? \"oversold ✅\"\n : rsi >= 50\n ? \"bullish momentum\"\n : \"bearish momentum\";\n\n const trend: \"bullish\" | \"bearish\" = currentPrice >= (pp) ? \"bullish\" : \"bearish\";\n\n return {\n closes,\n rsi,\n rsiSignal,\n supportLevels,\n resistanceLevels,\n fibLevels,\n trend,\n periodHigh,\n periodLow,\n };\n}\n\n// ---------------------------------------------------------------------------\n// Chart generation (QuickChart)\n// ---------------------------------------------------------------------------\n\nfunction buildChartUrl(symbolBase: string, a: Analysis): string {\n const closes = a.closes;\n const labels = closes.map((_, i) => `${closes.length - i}h`);\n\n const priceDataset = {\n label: `${symbolBase}`,\n data: closes,\n borderColor: \"#02c076\",\n backgroundColor: \"rgba(2, 192, 118, 0.15)\",\n borderWidth: 2,\n pointRadius: 0,\n fill: true,\n tension: 0.3,\n };\n\n // Horizontal level lines (constant datasets)\n const levelDatasets: Record[] = [];\n for (const s of a.supportLevels) {\n levelDatasets.push({\n label: `S ${s}`,\n data: closes.map(() => s),\n borderColor: \"rgba(2, 192, 118, 0.6)\",\n borderDash: [6, 6],\n borderWidth: 1,\n pointRadius: 0,\n fill: false,\n });\n }\n for (const r of a.resistanceLevels) {\n levelDatasets.push({\n label: `R ${r}`,\n data: closes.map(() => r),\n borderColor: \"rgba(240, 70, 90, 0.6)\",\n borderDash: [6, 6],\n borderWidth: 1,\n pointRadius: 0,\n fill: false,\n });\n }\n // Only draw the key fib ratios to keep the chart readable\n const keyFib = a.fibLevels.filter((f) => [\"0.382\", \"0.5\", \"0.618\"].includes(f.ratio));\n for (const f of keyFib) {\n levelDatasets.push({\n label: `Fib ${f.ratio} ${f.price}`,\n data: closes.map(() => f.price),\n borderColor: \"rgba(240, 185, 11, 0.7)\",\n borderDash: [2, 3],\n borderWidth: 1,\n pointRadius: 0,\n fill: false,\n });\n }\n\n const chartConfig = {\n type: \"line\",\n data: {\n labels,\n datasets: [priceDataset, ...levelDatasets],\n },\n options: {\n title: {\n display: true,\n text: `${symbolBase}/USDT — Price, S/R, Fibonacci Levels (RSI ${a.rsi?.toFixed(1) ?? \"n/a\"})`,\n fontColor: \"#ffffff\",\n fontSize: 16,\n },\n legend: {\n position: \"bottom\",\n labels: { fontColor: \"#ffffff\", fontSize: 10, boxWidth: 12 },\n },\n scales: {\n xAxes: [\n {\n ticks: { fontColor: \"#ffffff\", maxTicksLimit: 8, display: false },\n gridLines: { color: \"rgba(255,255,255,0.08)\" },\n },\n ],\n yAxes: [\n {\n ticks: { fontColor: \"#ffffff\" },\n gridLines: { color: \"rgba(255,255,255,0.08)\" },\n },\n ],\n },\n },\n };\n\n const params = new URLSearchParams({\n c: JSON.stringify(chartConfig),\n backgroundColor: \"#181a20\",\n width: \"900\",\n height: \"600\",\n devicePixelRatio: \"2\",\n });\n\n return `https://quickchart.io/chart?${params.toString()}`;\n}\n\n// ---------------------------------------------------------------------------\n// Content formatting (English)\n// ---------------------------------------------------------------------------\n\nfunction formatEnglishPost(ticker: BinanceTicker24hr, symbolBase: string, a: Analysis): string {\n const tag = \"$\" + symbolBase; // cashtag → renders the coin card automatically on Square\n const fmt = (n: number) => n.toPrecision(6).replace(/\\.?0+$/, \"\");\n const trendText = a.trend === \"bullish\" ? \"Bullish 📈\" : \"Bearish 📉\";\n const rsiLine = a.rsi == null\n ? \"RSI(14): n/a\"\n : `RSI(14): ${a.rsi.toFixed(1)} — ${a.rsiSignal}`;\n\n return [\n tag,\n \"\",\n `🟢 Futures Technical Analysis | ${tag}`,\n \"\",\n `💰 Current Price: ${ticker.lastPrice} USDT`,\n `📈 24h Change: ${ticker.priceChangePercent}%`,\n `⬆️ 24h High: ${ticker.highPrice} USDT`,\n `⬇️ 24h Low: ${ticker.lowPrice} USDT`,\n \"\",\n `🎯 Trend: ${trendText}`,\n \"\",\n \"🛡️ Support Levels:\",\n ...(a.supportLevels.length\n ? a.supportLevels.map((s, i) => ` S${i + 1}: ${fmt(s)} USDT`)\n : [\" — none detected —\"]),\n \"\",\n \"🚧 Resistance Levels:\",\n ...(a.resistanceLevels.length\n ? a.resistanceLevels.map((r, i) => ` R${i + 1}: ${fmt(r)} USDT`)\n : [\" — none detected —\"]),\n \"\",\n \"📐 Fibonacci Retracement (7d high-low):\",\n ...a.fibLevels.map((f) => ` ${f.ratio}: ${fmt(f.price)} USDT`),\n \"\",\n `⚡ Momentum: ${rsiLine}`,\n \"\",\n \"📝 Technical Note: This coin topped the futures gainers list over the last 24 hours. \" +\n \"Watch the nearest support/resistance levels and the 0.382–0.618 Fibonacci zone for \" +\n \"reaction. RSI indicates \" + a.rsiSignal.replace(/[^\\w\\s]/g, \"\").trim() +\n \". Always manage risk before taking any trade.\",\n \"\",\n `#CryptoAnalysis #BinanceSquare #TechnicalAnalysis #RSI #Fibonacci`,\n ].join(\"\\n\");\n}\n\n// ---------------------------------------------------------------------------\n// Binance Square publishing (text + image via official OpenAPI)\n// ---------------------------------------------------------------------------\n\nconst SQUARE_OPENAPI_V2 =\n \"https://www.binance.com/bapi/composite/v2/public/pgc/openApi\";\n\nasync function squareApi(\n endpoint: string,\n apiKey: string,\n body: Record,\n baseUrl = SQUARE_POST_URL.replace(\"/content/add\", \"\"),\n): Promise> {\n const res = await fetch(`${baseUrl}${endpoint}`, {\n method: \"POST\",\n headers: {\n \"X-Square-OpenAPI-Key\": apiKey,\n \"Content-Type\": \"application/json\",\n \"clienttype\": \"binanceSkill\",\n },\n body: JSON.stringify(body),\n });\n const raw = await res.text();\n let json: { code?: string; message?: string | null; data?: Record };\n try {\n json = JSON.parse(raw);\n } catch {\n throw new Error(`Square API returned non-JSON response: ${res.status} ${raw.slice(0, 200)}`);\n }\n if (json.code !== \"000000\") {\n throw new Error(`Square API error [${json.code}]: ${json.message}`);\n }\n return json.data ?? {};\n}\n\nasync function pollImageStatus(\n apiKey: string,\n fileTicket: string,\n): Promise<{ status: number; imageUrl?: string; failedReason?: string }> {\n for (let i = 0; i < 10; i++) {\n const data = await squareApi(\"/image/imageStatus\", apiKey, { fileTicket }, SQUARE_OPENAPI_V2);\n if (data.status === 1) return data as { status: number; imageUrl?: string };\n if (data.status === 2) {\n throw new Error(`Image processing failed: ${data.failedReason}`);\n }\n await new Promise((r) => setTimeout(r, 3000));\n }\n throw new Error(\"Image processing poll timed out\");\n}\n\n/** Upload an image to Binance Square via the official OpenAPI flow. */\nasync function uploadSquareImage(apiKey: string, imageUrl: string): Promise {\n // 1. Download the QuickChart PNG\n const imgRes = await fetch(imageUrl);\n if (!imgRes.ok) throw new Error(`Failed to download chart image: ${imgRes.status}`);\n const bytes = new Uint8Array(await imgRes.arrayBuffer());\n\n // 2. Request a presigned upload URL from the Square publishing board\n const { presignedUrl, fileTicket } = (await squareApi(\n \"/image/presignedUrl\",\n apiKey,\n { imageName: `chart-${Date.now()}.png` },\n SQUARE_OPENAPI_V2,\n )) as { presignedUrl: string; fileTicket: string };\n\n // 3. PUT the bytes to the presigned URL\n const putRes = await fetch(presignedUrl, {\n method: \"PUT\",\n headers: { \"Content-Type\": \"image/png\" },\n body: bytes,\n });\n if (!putRes.ok) throw new Error(`Image upload failed: ${putRes.status} ${putRes.statusText}`);\n\n // 4. Poll until processed, then return the hosted image URL\n const status = await pollImageStatus(apiKey, fileTicket);\n if (!status.imageUrl) throw new Error(\"Image processed but no imageUrl returned\");\n return status.imageUrl;\n}\n\nasync function postToBinanceSquare(\n apiKey: string,\n content: string,\n chartUrl: string,\n): Promise<{ ok: boolean; body: unknown }> {\n // Upload the chart image first, then publish contentType=1 (image post)\n const squareImageUrl = await uploadSquareImage(apiKey, chartUrl);\n\n const res = await fetch(SQUARE_POST_URL, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"X-Square-OpenAPI-Key\": apiKey,\n \"clienttype\": \"binanceSkill\",\n },\n body: JSON.stringify({\n contentType: 1,\n bodyTextOnly: content,\n imageList: [squareImageUrl],\n }),\n });\n\n const raw = await res.text();\n let body: unknown;\n try {\n body = JSON.parse(raw);\n } catch {\n body = { status: res.status, raw: raw.slice(0, 200) };\n }\n return { ok: res.ok, body };\n}\n\n// ---------------------------------------------------------------------------\n// Telegram notifications\n// ---------------------------------------------------------------------------\n\nasync function sendTelegramAlert(message: string, imageUrl?: string): Promise {\n const token = Deno.env.get(\"TELEGRAM_BOT_TOKEN\");\n const chatId = Deno.env.get(\"TELEGRAM_CHAT_ID\");\n\n if (!token || !chatId) {\n console.error(\"sendTelegramAlert: missing TELEGRAM_BOT_TOKEN or TELEGRAM_CHAT_ID\");\n return;\n }\n\n const base = `https://api.telegram.org/bot${token}`;\n\n try {\n const res = imageUrl\n ? await fetch(`${base}/sendPhoto`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: chatId, photo: imageUrl, caption: message }),\n })\n : await fetch(`${base}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: chatId, text: message }),\n });\n\n if (!res.ok) {\n console.error(`Telegram API error: ${res.status} ${await res.text()}`);\n }\n } catch (err) {\n console.error(\"Failed to send Telegram alert:\", err);\n }\n}\n\n// ---------------------------------------------------------------------------\n// Main scheduled entrypoint\n// ---------------------------------------------------------------------------\n\nexport default async function (interval: Interval) {\n const SQUARE_API_KEY = Deno.env.get(\"SQUARE_API_KEY\");\n const TELEGRAM_BOT_TOKEN = Deno.env.get(\"TELEGRAM_BOT_TOKEN\");\n const TELEGRAM_CHAT_ID = Deno.env.get(\"TELEGRAM_CHAT_ID\");\n\n try {\n if (!SQUARE_API_KEY) throw new Error(\"Missing SQUARE_API_KEY environment variable\");\n if (!TELEGRAM_BOT_TOKEN) throw new Error(\"Missing TELEGRAM_BOT_TOKEN environment variable\");\n if (!TELEGRAM_CHAT_ID) throw new Error(\"Missing TELEGRAM_CHAT_ID environment variable\");\n\n // 1. Get top USDT futures gainers (fetch more so cooldown filtering has candidates)\n const topGainers = await getTopUsdtGainers(10);\n\n // Cooldown: don't repost the same coin within 10 hours\n const COOLDOWN_MS = 10 * 60 * 60 * 1000;\n // Daily quota: max 100 posts in any rolling 24h window (Square limit)\n const WINDOW_MS = 24 * 60 * 60 * 1000;\n const MAX_POSTS_PER_WINDOW = 100;\n const POSTS_PER_RUN = 2;\n\n // Prune log entries older than 24h (outside the counting window)\n await sqlite.execute(\"DELETE FROM post_log WHERE postedAt < ?\", [\n Date.now() - WINDOW_MS,\n ]);\n\n // Count posts already published within the last 24h (including the ones\n // published hours ago — they all count toward the 100/day quota)\n const used = await sqlite.execute(\"SELECT COUNT(*) AS c FROM post_log\");\n const postsInWindow = Number(used.rows[0]?.c ?? 0);\n console.log(`Posts in last 24h window: ${postsInWindow}/${MAX_POSTS_PER_WINDOW}`);\n\n if (postsInWindow >= MAX_POSTS_PER_WINDOW) {\n const oldest = await sqlite.execute(\n \"SELECT MIN(postedAt) AS t FROM post_log\",\n );\n const resetAt = Number(oldest.rows[0]?.t ?? 0) + WINDOW_MS;\n console.log(\n `Daily limit reached (${postsInWindow}/${MAX_POSTS_PER_WINDOW}). ` +\n `Resumes after ${new Date(resetAt).toISOString()}`,\n );\n return;\n }\n\n let successCount = 0;\n const links: string[] = [];\n\n for (const gainer of topGainers) {\n if (successCount >= POSTS_PER_RUN) break; // 2 posts per run\n if (postsInWindow + successCount >= MAX_POSTS_PER_WINDOW) break; // quota\n\n const symbolBase = gainer.symbol.replace(/USDT$/, \"\");\n try {\n // Cooldown check\n const last = await sqlite.execute(\n \"SELECT postedAt FROM last_posted WHERE symbol = ?\",\n [symbolBase],\n );\n const lastAt = Number(last.rows[0]?.postedAt ?? 0);\n if (Date.now() - lastAt < COOLDOWN_MS) {\n console.log(\n `Skipped ${symbolBase}: posted ${\n Math.round((Date.now() - lastAt) / 60000)\n } min ago (cooldown 10h)`,\n );\n continue;\n }\n\n // Fetch klines, run analysis, build chart with levels\n const candles = await getKlines(gainer.symbol, 168);\n const analysis = analyzeCandles(candles);\n const chartUrl = buildChartUrl(symbolBase, analysis);\n\n // 3. Content (English)\n const postText = formatEnglishPost(gainer, symbolBase, analysis);\n\n // 4. Publish to Binance Square (with chart image)\n const squareResult = await postToBinanceSquare(SQUARE_API_KEY, postText, chartUrl);\n const squareBody = squareResult.body as { code?: string; data?: { id?: string } } | null;\n const postId = squareBody?.data?.id;\n const success =\n squareResult.ok && (squareBody?.code === \"000000\" || squareBody?.code == null);\n\n if (success) {\n successCount++;\n const now = Date.now();\n // Record posting time for the 10h cooldown\n await sqlite.execute(\n \"INSERT INTO last_posted (symbol, postedAt) VALUES (?, ?) \" +\n \"ON CONFLICT(symbol) DO UPDATE SET postedAt = excluded.postedAt\",\n [symbolBase, now],\n );\n // Record for the rolling 24h / 100-post quota\n await sqlite.execute(\n \"INSERT INTO post_log (symbol, postedAt) VALUES (?, ?)\",\n [symbolBase, now],\n );\n if (postId) links.push(`https://www.binance.com/square/post/${postId}`);\n await sendTelegramAlert(\n `✅ تم نشر تحليل ${symbolBase} بنجاح على Binance Square!` +\n (postId ? `\\n🔗 https://www.binance.com/square/post/${postId}` : \"\") +\n `\\n\\n${postText}`,\n chartUrl,\n );\n // Warn once when the daily quota is now full\n if (postsInWindow + successCount >= MAX_POSTS_PER_WINDOW) {\n await sendTelegramAlert(\n `⛔ تم الوصول إلى حد 100 منشور خلال 24 ساعة. ` +\n `سيستأنف النشر تلقائيًا بعد انقضاء نافذة 24 ساعة.`,\n );\n }\n } else {\n await sendTelegramAlert(\n `❌ فشل نشر تحليل ${symbolBase} على Binance Square.\\n` +\n `التفاصيل: ${JSON.stringify(squareResult.body)}\\n\\n${postText}`,\n chartUrl,\n );\n }\n\n console.log(\n `Processed ${gainer.symbol} (${gainer.priceChangePercent}%): ${\n success ? \"published\" : \"failed\"\n }`,\n );\n\n // Be polite between posts (avoid rate limits / 100 posts daily cap)\n await new Promise((r) => setTimeout(r, 5000));\n } catch (coinErr) {\n const msg = coinErr instanceof Error ? coinErr.message : String(coinErr);\n console.error(`Failed processing ${gainer.symbol}: ${msg}`);\n await sendTelegramAlert(`⚠️ فشل معالجة ${symbolBase}:\\n${msg}`);\n }\n }\n\n console.log(\n `Done: ${successCount}/${topGainers.length} posts published. ` +\n (links.length ? `Links: ${links.join(\" | \")}` : \"\"),\n );\n } catch (err) {\n const message = err instanceof Error ? err.message : String(err);\n console.error(\"crypto-analysis run failed:\", message);\n await sendTelegramAlert(`🚨 خطأ غير متوقع أثناء تحليل السوق:\\n${message}`);\n }\n}\n","/**\n * Crypto Market Analysis → Binance Square + Telegram\n *\n * Every run:\n * 1. Finds the top USDT gainer on Binance (24h ticker stats).\n * 2. Pulls its last 24h of 1h candles and renders a dark-themed line chart via QuickChart.\n * 3. Publishes a formatted English technical-analysis post (S/R, Fibonacci, RSI) + chart to Binance Square.\n * 4. Notifies a Telegram chat with the result (success or failure).\n *\n * Required env vars:\n * SQUARE_API_KEY — Binance Square content-creator OpenAPI key\n * TELEGRAM_BOT_TOKEN — Telegram bot token (from @BotFather)\n * TELEGRAM_CHAT_ID — Telegram chat/channel id to notify\n */\n\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\ninterface BinanceTicker24hr {\n symbol: string;\n priceChange: string;\n priceChangePercent: string;\n lastPrice: string;\n highPrice: string;\n lowPrice: string;\n volume: string;\n}\n\ninterface Candle {\n open: number;\n high: number;\n low: number;\n close: number;\n closeTime: number;\n}\n\ninterface Analysis {\n closes: number[];\n rsi: number | null;\n rsiSignal: string;\n supportLevels: number[];\n resistanceLevels: number[];\n fibLevels: { ratio: string; price: number }[];\n trend: \"bullish\" | \"bearish\";\n periodHigh: number;\n periodLow: number;\n}\n\n// Binance kline row: [openTime, open, high, low, close, volume, closeTime, ...]\ntype BinanceKline = [number, string, string, string, string, string, number, ...unknown[]];\n\nconst BINANCE_API = \"https://www.binance.com/fapi/v1\";\nconst SQUARE_POST_URL =\n \"https://www.binance.com/bapi/composite/v1/public/pgc/openApi/content/add\";\n\n// ---------------------------------------------------------------------------\n// Binance market data\n// ---------------------------------------------------------------------------\n\nasync function getTopUsdtGainers(count = 3): Promise {\n const res = await fetch(`${BINANCE_API}/ticker/24hr`);\n if (!res.ok) {\n throw new Error(`Binance 24hr ticker request failed: ${res.status} ${res.statusText}`);\n }\n const tickers: BinanceTicker24hr[] = await res.json();\n\n const usdtPairs = tickers.filter((t) => t.symbol.endsWith(\"USDT\"));\n if (usdtPairs.length === 0) {\n throw new Error(\"No USDT trading pairs returned by Binance\");\n }\n\n return usdtPairs\n .sort((a, b) => parseFloat(b.priceChangePercent) - parseFloat(a.priceChangePercent))\n .slice(0, count);\n}\n\nasync function getKlines(symbol: string, limit = 168): Promise {\n const url = `${BINANCE_API}/klines?symbol=${symbol}&interval=1h&limit=${limit}`;\n const res = await fetch(url);\n if (!res.ok) {\n throw new Error(`Binance klines request failed for ${symbol}: ${res.status} ${res.statusText}`);\n }\n const klines: BinanceKline[] = await res.json();\n return klines.map((k) => ({\n open: parseFloat(k[1]),\n high: parseFloat(k[2]),\n low: parseFloat(k[3]),\n close: parseFloat(k[4]),\n closeTime: k[6],\n }));\n}\n\n// ---------------------------------------------------------------------------\n// Technical analysis: RSI, S/R levels, Fibonacci retracement\n// ---------------------------------------------------------------------------\n\n/** Wilder's RSI(14) */\nfunction computeRsi(closes: number[], period = 14): number | null {\n if (closes.length < period + 1) return null;\n let gain = 0;\n let loss = 0;\n for (let i = 1; i <= period; i++) {\n const diff = closes[i] - closes[i - 1];\n if (diff >= 0) gain += diff;\n else loss -= diff;\n }\n let avgGain = gain / period;\n let avgLoss = loss / period;\n for (let i = period + 1; i < closes.length; i++) {\n const diff = closes[i] - closes[i - 1];\n avgGain = (avgGain * (period - 1) + Math.max(diff, 0)) / period;\n avgLoss = (avgLoss * (period - 1) + Math.max(-diff, 0)) / period;\n }\n if (avgLoss === 0) return 100;\n const rs = avgGain / avgLoss;\n return 100 - 100 / (1 + rs);\n}\n\nfunction analyzeCandles(candles: Candle[]): Analysis {\n const closes = candles.map((c) => c.close);\n const currentPrice = closes[closes.length - 1];\n const periodHigh = Math.max(...candles.map((c) => c.high));\n const periodLow = Math.min(...candles.map((c) => c.low));\n\n // --- Support & resistance from swing highs/lows (fractal, ±3 candles) ---\n const supports: number[] = [];\n const resistances: number[] = [];\n const w = 3;\n for (let i = w; i < candles.length - w; i++) {\n const c = candles[i];\n const isSwingHigh = c.high >= Math.max(...candles.slice(i - w, i + w + 1).map((x) => x.high));\n const isSwingLow = c.low <= Math.min(...candles.slice(i - w, i + w + 1).map((x) => x.low));\n if (isSwingHigh && c.high > currentPrice) resistances.push(c.high);\n if (isSwingLow && c.low < currentPrice) supports.push(c.low);\n }\n // Classic pivot points (from the most recent completed daily-like window = last 24 candles)\n const window = candles.slice(-25, -1);\n const wh = Math.max(...window.map((c) => c.high));\n const wl = Math.min(...window.map((c) => c.low));\n const wc = window[window.length - 1].close;\n const pp = (wh + wl + wc) / 3;\n const pivots = [pp, 2 * pp - wl, pp + (wh - wl), 2 * pp - 2 * wl + wh, 2 * pp - 2 * wh + wl];\n for (const p of pivots) {\n if (p < currentPrice) supports.push(p);\n else resistances.push(p);\n }\n // Deduplicate and keep the nearest levels\n const dedupe = (arr: number[], ref: number, dir: 1 | -1) => {\n const sorted = [...new Set(arr.map((x) => +x.toFixed(6)))]\n .filter((x) => (dir === 1 ? x < ref : x > ref))\n .sort((a, b) => (dir === 1 ? b - a : a - b));\n const out: number[] = [];\n for (const x of sorted) {\n if (!out.length || Math.abs(x - out[out.length - 1]) / ref > 0.002) out.push(x);\n if (out.length === 3) break;\n }\n return out;\n };\n const supportLevels = dedupe(supports, currentPrice, 1);\n const resistanceLevels = dedupe(resistances, currentPrice, -1);\n\n // --- Fibonacci retracement between period low and high ---\n const diff = periodHigh - periodLow;\n const ratios = [\n [\"0.0\", 0], [\"0.236\", 0.236], [\"0.382\", 0.382], [\"0.5\", 0.5],\n [\"0.618\", 0.618], [\"0.786\", 0.786], [\"1.0\", 1],\n ] as const;\n const fibLevels = ratios.map(([ratio, r]) => ({\n ratio,\n price: +(periodLow + diff * r).toFixed(6),\n }));\n\n // --- RSI ---\n const rsi = computeRsi(closes);\n const rsiSignal = rsi == null\n ? \"insufficient data\"\n : rsi >= 70\n ? \"overbought ⚠️\"\n : rsi <= 30\n ? \"oversold ✅\"\n : rsi >= 50\n ? \"bullish momentum\"\n : \"bearish momentum\";\n\n const trend: \"bullish\" | \"bearish\" = currentPrice >= (pp) ? \"bullish\" : \"bearish\";\n\n return {\n closes,\n rsi,\n rsiSignal,\n supportLevels,\n resistanceLevels,\n fibLevels,\n trend,\n periodHigh,\n periodLow,\n };\n}\n\n// ---------------------------------------------------------------------------\n// Chart generation (QuickChart)\n// ---------------------------------------------------------------------------\n\nfunction buildChartUrl(symbolBase: string, a: Analysis): string {\n const closes = a.closes;\n const labels = closes.map((_, i) => `${closes.length - i}h`);\n\n const priceDataset = {\n label: `${symbolBase}`,\n data: closes,\n borderColor: \"#02c076\",\n backgroundColor: \"rgba(2, 192, 118, 0.15)\",\n borderWidth: 2,\n pointRadius: 0,\n fill: true,\n tension: 0.3,\n };\n\n // Horizontal level lines (constant datasets)\n const levelDatasets: Record[] = [];\n for (const s of a.supportLevels) {\n levelDatasets.push({\n label: `S ${s}`,\n data: closes.map(() => s),\n borderColor: \"rgba(2, 192, 118, 0.6)\",\n borderDash: [6, 6],\n borderWidth: 1,\n pointRadius: 0,\n fill: false,\n });\n }\n for (const r of a.resistanceLevels) {\n levelDatasets.push({\n label: `R ${r}`,\n data: closes.map(() => r),\n borderColor: \"rgba(240, 70, 90, 0.6)\",\n borderDash: [6, 6],\n borderWidth: 1,\n pointRadius: 0,\n fill: false,\n });\n }\n // Only draw the key fib ratios to keep the chart readable\n const keyFib = a.fibLevels.filter((f) => [\"0.382\", \"0.5\", \"0.618\"].includes(f.ratio));\n for (const f of keyFib) {\n levelDatasets.push({\n label: `Fib ${f.ratio} ${f.price}`,\n data: closes.map(() => f.price),\n borderColor: \"rgba(240, 185, 11, 0.7)\",\n borderDash: [2, 3],\n borderWidth: 1,\n pointRadius: 0,\n fill: false,\n });\n }\n\n const chartConfig = {\n type: \"line\",\n data: {\n labels,\n datasets: [priceDataset, ...levelDatasets],\n },\n options: {\n title: {\n display: true,\n text: `${symbolBase}/USDT — Price, S/R, Fibonacci Levels (RSI ${a.rsi?.toFixed(1) ?? \"n/a\"})`,\n fontColor: \"#ffffff\",\n fontSize: 16,\n },\n legend: {\n position: \"bottom\",\n labels: { fontColor: \"#ffffff\", fontSize: 10, boxWidth: 12 },\n },\n scales: {\n xAxes: [\n {\n ticks: { fontColor: \"#ffffff\", maxTicksLimit: 8, display: false },\n gridLines: { color: \"rgba(255,255,255,0.08)\" },\n },\n ],\n yAxes: [\n {\n ticks: { fontColor: \"#ffffff\" },\n gridLines: { color: \"rgba(255,255,255,0.08)\" },\n },\n ],\n },\n },\n };\n\n const params = new URLSearchParams({\n c: JSON.stringify(chartConfig),\n backgroundColor: \"#181a20\",\n width: \"900\",\n height: \"600\",\n devicePixelRatio: \"2\",\n });\n\n return `https://quickchart.io/chart?${params.toString()}`;\n}\n\n// ---------------------------------------------------------------------------\n// Content formatting (English)\n// ---------------------------------------------------------------------------\n\nfunction formatEnglishPost(ticker: BinanceTicker24hr, symbolBase: string, a: Analysis): string {\n const tag = \"$\" + symbolBase; // cashtag → renders the coin card automatically on Square\n const fmt = (n: number) => n.toPrecision(6).replace(/\\.?0+$/, \"\");\n const trendText = a.trend === \"bullish\" ? \"Bullish 📈\" : \"Bearish 📉\";\n\n // --- Trade setup derived from S/R levels ---\n const entry = currentPrice;\n const nearSupport = a.supportLevels[0];\n const nearResistance = a.resistanceLevels[0];\n let side: string;\n let stopLoss: number | null = null;\n let targets: { label: string; price: number }[] = [];\n\n if (a.trend === \"bullish\") {\n side = \"LONG 🔼\";\n stopLoss = nearSupport != null\n ? nearSupport * 0.995 // just below nearest support\n : entry * 0.96; // fallback: -4%\n const t1 = nearResistance ?? entry * 1.05;\n const t2 = a.resistanceLevels[1] ?? entry * 1.10;\n targets = [\n { label: \"TP1\", price: t1 },\n { label: \"TP2\", price: t2 },\n { label: \"TP3\", price: a.periodHigh > t2 ? a.periodHigh : t2 * 1.05 },\n ];\n } else {\n side = \"SHORT 🔽\";\n stopLoss = nearResistance != null\n ? nearResistance * 1.005 // just above nearest resistance\n : entry * 1.04; // fallback: +4%\n const t1 = nearSupport ?? entry * 0.95;\n const t2 = a.supportLevels[1] ?? entry * 0.90;\n targets = [\n { label: \"TP1\", price: t1 },\n { label: \"TP2\", price: t2 },\n { label: \"TP3\", price: a.periodLow < t2 ? a.periodLow : t2 * 0.95 },\n ];\n }\n const risk = Math.abs(entry - stopLoss);\n const rr = targets.length && risk > 0\n ? (Math.abs(targets[targets.length - 1].price - entry) / risk).toFixed(1)\n : \"n/a\";\n const trendArrow = a.trend === \"bullish\" ? \"🟢 LONG\" : \"🔴 SHORT\";\n const rsiLine = a.rsi == null\n ? \"RSI(14): n/a\"\n : `RSI(14): ${a.rsi.toFixed(1)} — ${a.rsiSignal}`;\n\n return [\n tag,\n \"\",\n `🟢 Futures Technical Analysis | ${tag}`,\n \"\",\n `💰 Current Price: ${ticker.lastPrice} USDT`,\n `📈 24h Change: ${ticker.priceChangePercent}%`,\n `⬆️ 24h High: ${ticker.highPrice} USDT`,\n `⬇️ 24h Low: ${ticker.lowPrice} USDT`,\n \"\",\n `🎯 Trend: ${trendText}`,\n \"\",\n \"🛡️ Support Levels:\",\n ...(a.supportLevels.length\n ? a.supportLevels.map((s, i) => ` S${i + 1}: ${fmt(s)} USDT`)\n : [\" — none detected —\"]),\n \"\",\n \"🚧 Resistance Levels:\",\n ...(a.resistanceLevels.length\n ? a.resistanceLevels.map((r, i) => ` R${i + 1}: ${fmt(r)} USDT`)\n : [\" — none detected —\"]),\n \"\",\n \"📐 Fibonacci Retracement (7d high-low):\",\n ...a.fibLevels.map((f) => ` ${f.ratio}: ${fmt(f.price)} USDT`),\n \"\",\n `⚡ Momentum: ${rsiLine}`,\n \"\",\n \"📝 Technical Note: This coin topped the futures gainers list over the last 24 hours. \" +\n \"Watch the nearest support/resistance levels and the 0.382–0.618 Fibonacci zone for \" +\n \"reaction. RSI indicates \" + a.rsiSignal.replace(/[^\\w\\s]/g, \"\").trim() +\n \". Always manage risk before taking any trade.\",\n \"\",\n `#CryptoAnalysis #BinanceSquare #TechnicalAnalysis #RSI #Fibonacci`,\n ].join(\"\\n\");\n}\n\n// ---------------------------------------------------------------------------\n// Binance Square publishing (text + image via official OpenAPI)\n// ---------------------------------------------------------------------------\n\nconst SQUARE_OPENAPI_V2 =\n \"https://www.binance.com/bapi/composite/v2/public/pgc/openApi\";\n\nasync function squareApi(\n endpoint: string,\n apiKey: string,\n body: Record,\n baseUrl = SQUARE_POST_URL.replace(\"/content/add\", \"\"),\n): Promise> {\n const res = await fetch(`${baseUrl}${endpoint}`, {\n method: \"POST\",\n headers: {\n \"X-Square-OpenAPI-Key\": apiKey,\n \"Content-Type\": \"application/json\",\n \"clienttype\": \"binanceSkill\",\n },\n body: JSON.stringify(body),\n });\n const raw = await res.text();\n let json: { code?: string; message?: string | null; data?: Record };\n try {\n json = JSON.parse(raw);\n } catch {\n throw new Error(`Square API returned non-JSON response: ${res.status} ${raw.slice(0, 200)}`);\n }\n if (json.code !== \"000000\") {\n throw new Error(`Square API error [${json.code}]: ${json.message}`);\n }\n return json.data ?? {};\n}\n\nasync function pollImageStatus(\n apiKey: string,\n fileTicket: string,\n): Promise<{ status: number; imageUrl?: string; failedReason?: string }> {\n for (let i = 0; i < 10; i++) {\n const data = await squareApi(\"/image/imageStatus\", apiKey, { fileTicket }, SQUARE_OPENAPI_V2);\n if (data.status === 1) return data as { status: number; imageUrl?: string };\n if (data.status === 2) {\n throw new Error(`Image processing failed: ${data.failedReason}`);\n }\n await new Promise((r) => setTimeout(r, 3000));\n }\n throw new Error(\"Image processing poll timed out\");\n}\n\n/** Upload an image to Binance Square via the official OpenAPI flow. */\nasync function uploadSquareImage(apiKey: string, imageUrl: string): Promise {\n // 1. Download the QuickChart PNG\n const imgRes = await fetch(imageUrl);\n if (!imgRes.ok) throw new Error(`Failed to download chart image: ${imgRes.status}`);\n const bytes = new Uint8Array(await imgRes.arrayBuffer());\n\n // 2. Request a presigned upload URL from the Square publishing board\n const { presignedUrl, fileTicket } = (await squareApi(\n \"/image/presignedUrl\",\n apiKey,\n { imageName: `chart-${Date.now()}.png` },\n SQUARE_OPENAPI_V2,\n )) as { presignedUrl: string; fileTicket: string };\n\n // 3. PUT the bytes to the presigned URL\n const putRes = await fetch(presignedUrl, {\n method: \"PUT\",\n headers: { \"Content-Type\": \"image/png\" },\n body: bytes,\n });\n if (!putRes.ok) throw new Error(`Image upload failed: ${putRes.status} ${putRes.statusText}`);\n\n // 4. Poll until processed, then return the hosted image URL\n const status = await pollImageStatus(apiKey, fileTicket);\n if (!status.imageUrl) throw new Error(\"Image processed but no imageUrl returned\");\n return status.imageUrl;\n}\n\nasync function postToBinanceSquare(\n apiKey: string,\n content: string,\n chartUrl: string,\n): Promise<{ ok: boolean; body: unknown }> {\n // Upload the chart image first, then publish contentType=1 (image post)\n const squareImageUrl = await uploadSquareImage(apiKey, chartUrl);\n\n const res = await fetch(SQUARE_POST_URL, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"application/json\",\n \"X-Square-OpenAPI-Key\": apiKey,\n \"clienttype\": \"binanceSkill\",\n },\n body: JSON.stringify({\n contentType: 1,\n bodyTextOnly: content,\n imageList: [squareImageUrl],\n }),\n });\n\n const raw = await res.text();\n let body: unknown;\n try {\n body = JSON.parse(raw);\n } catch {\n body = { status: res.status, raw: raw.slice(0, 200) };\n }\n return { ok: res.ok, body };\n}\n\n// ---------------------------------------------------------------------------\n// Telegram notifications\n// ---------------------------------------------------------------------------\n\nasync function sendTelegramAlert(message: string, imageUrl?: string): Promise {\n const token = Deno.env.get(\"TELEGRAM_BOT_TOKEN\");\n const chatId = Deno.env.get(\"TELEGRAM_CHAT_ID\");\n\n if (!token || !chatId) {\n console.error(\"sendTelegramAlert: missing TELEGRAM_BOT_TOKEN or TELEGRAM_CHAT_ID\");\n return;\n }\n\n const base = `https://api.telegram.org/bot${token}`;\n\n try {\n const res = imageUrl\n ? await fetch(`${base}/sendPhoto`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: chatId, photo: imageUrl, caption: message }),\n })\n : await fetch(`${base}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({ chat_id: chatId, text: message }),\n });\n\n if (!res.ok) {\n console.error(`Telegram API error: ${res.status} ${await res.text()}`);\n }\n } catch (err) {\n console.error(\"Failed to send Telegram alert:\", err);\n }\n}\n\n// ---------------------------------------------------------------------------\n// Main scheduled entrypoint\n// ---------------------------------------------------------------------------\n\nexport default async function (interval: Interval) {\n const SQUARE_API_KEY = Deno.env.get(\"SQUARE_API_KEY\");\n const TELEGRAM_BOT_TOKEN = Deno.env.get(\"TELEGRAM_BOT_TOKEN\");\n const TELEGRAM_CHAT_ID = Deno.env.get(\"TELEGRAM_CHAT_ID\");\n\n try {\n if (!SQUARE_API_KEY) throw new Error(\"Missing SQUARE_API_KEY environment variable\");\n if (!TELEGRAM_BOT_TOKEN) throw new Error(\"Missing TELEGRAM_BOT_TOKEN environment variable\");\n if (!TELEGRAM_CHAT_ID) throw new Error(\"Missing TELEGRAM_CHAT_ID environment variable\");\n\n // 1. Get top USDT futures gainers (fetch more so cooldown filtering has candidates)\n const topGainers = await getTopUsdtGainers(10);\n\n // Cooldown: don't repost the same coin within 10 hours\n const COOLDOWN_MS = 10 * 60 * 60 * 1000;\n // Daily quota: max 100 posts in any rolling 24h window (Square limit)\n const WINDOW_MS = 24 * 60 * 60 * 1000;\n const MAX_POSTS_PER_WINDOW = 100;\n const POSTS_PER_RUN = 2;\n\n // Prune log entries older than 24h (outside the counting window)\n await sqlite.execute(\"DELETE FROM post_log WHERE postedAt < ?\", [\n Date.now() - WINDOW_MS,\n ]);\n\n // Count posts already published within the last 24h (including the ones\n // published hours ago — they all count toward the 100/day quota)\n const used = await sqlite.execute(\"SELECT COUNT(*) AS c FROM post_log\");\n const postsInWindow = Number(used.rows[0]?.c ?? 0);\n console.log(`Posts in last 24h window: ${postsInWindow}/${MAX_POSTS_PER_WINDOW}`);\n\n if (postsInWindow >= MAX_POSTS_PER_WINDOW) {\n const oldest = await sqlite.execute(\n \"SELECT MIN(postedAt) AS t FROM post_log\",\n );\n const resetAt = Number(oldest.rows[0]?.t ?? 0) + WINDOW_MS;\n console.log(\n `Daily limit reached (${postsInWindow}/${MAX_POSTS_PER_WINDOW}). ` +\n `Resumes after ${new Date(resetAt).toISOString()}`,\n );\n return;\n }\n\n let successCount = 0;\n const links: string[] = [];\n\n for (const gainer of topGainers) {\n if (successCount >= POSTS_PER_RUN) break; // 2 posts per run\n if (postsInWindow + successCount >= MAX_POSTS_PER_WINDOW) break; // quota\n\n const symbolBase = gainer.symbol.replace(/USDT$/, \"\");\n try {\n // Cooldown check\n const last = await sqlite.execute(\n \"SELECT postedAt FROM last_posted WHERE symbol = ?\",\n [symbolBase],\n );\n const lastAt = Number(last.rows[0]?.postedAt ?? 0);\n if (Date.now() - lastAt < COOLDOWN_MS) {\n console.log(\n `Skipped ${symbolBase}: posted ${\n Math.round((Date.now() - lastAt) / 60000)\n } min ago (cooldown 10h)`,\n );\n continue;\n }\n\n // Fetch klines, run analysis, build chart with levels\n const candles = await getKlines(gainer.symbol, 168);\n const analysis = analyzeCandles(candles);\n const chartUrl = buildChartUrl(symbolBase, analysis);\n\n // 3. Content (English)\n const postText = formatEnglishPost(gainer, symbolBase, analysis);\n\n // 4. Publish to Binance Square (with chart image)\n const squareResult = await postToBinanceSquare(SQUARE_API_KEY, postText, chartUrl);\n const squareBody = squareResult.body as { code?: string; data?: { id?: string } } | null;\n const postId = squareBody?.data?.id;\n const success =\n squareResult.ok && (squareBody?.code === \"000000\" || squareBody?.code == null);\n\n if (success) {\n successCount++;\n const now = Date.now();\n // Record posting time for the 10h cooldown\n await sqlite.execute(\n \"INSERT INTO last_posted (symbol, postedAt) VALUES (?, ?) \" +\n \"ON CONFLICT(symbol) DO UPDATE SET postedAt = excluded.postedAt\",\n [symbolBase, now],\n );\n // Record for the rolling 24h / 100-post quota\n await sqlite.execute(\n \"INSERT INTO post_log (symbol, postedAt) VALUES (?, ?)\",\n [symbolBase, now],\n );\n if (postId) links.push(`https://www.binance.com/square/post/${postId}`);\n await sendTelegramAlert(\n `✅ تم نشر تحليل ${symbolBase} بنجاح على Binance Square!` +\n (postId ? `\\n🔗 https://www.binance.com/square/post/${postId}` : \"\") +\n `\\n\\n${postText}`,\n chartUrl,\n );\n // Warn once when the daily quota is now full\n if (postsInWindow + successCount >= MAX_POSTS_PER_WINDOW) {\n await sendTelegramAlert(\n `⛔ تم الوصول إلى حد 100 منشور خلال 24 ساعة. ` +\n `سيستأنف النشر تلقائيًا بعد انقضاء نافذة 24 ساعة.`,\n );\n }\n } else {\n await sendTelegramAlert(\n `❌ فشل نشر تحليل ${symbolBase} على Binance Square.\\n` +\n `التفاصيل: ${JSON.stringify(squareResult.body)}\\n\\n${postText}`,\n chartUrl,\n );\n }\n\n console.log(\n `Processed ${gainer.symbol} (${gainer.priceChangePercent}%): ${\n success ? \"published\" : \"failed\"\n }`,\n );\n\n // Be polite between posts (avoid rate limits / 100 posts daily cap)\n await new Promise((r) => setTimeout(r, 5000));\n } catch (coinErr) {\n const msg = coinErr instanceof Error ? coinErr.message : String(coinErr);\n console.error(`Failed processing ${gainer.symbol}: ${msg}`);\n await sendTelegramAlert(`⚠️ فشل معالجة ${symbolBase}:\\n${msg}`);\n }\n }\n\n console.log(\n `Done: ${successCount}/${topGainers.length} posts published. ` +\n (links.length ? `Links: ${links.join(\" | \")}` : \"\"),\n );\n } catch (err) {\n const message = err instanceof Error ? err.message : String(err);\n console.error(\"crypto-analysis run failed:\", message);\n await sendTelegramAlert(`🚨 خطأ غير متوقع أثناء تحليل السوق:\\n${message}`);\n }\n}\n","createdAt",["D",1788583251407],"branchVersion","branchId","048ca32d-0128-477a-864d-75c287c2728c","id","39352c72-d9f2-4d8c-9fcd-3dcc8075e63e","crypto-analysis",["D",1788203711379],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Top gainer chart, Binance Square post, Telegram alert","imageUrl","84d098b9-db57-4898-9030-8348bcd8e25b","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0593c-e182-77cd-ae7c-935af95131b8","tursoName","39352c72d9f24d8c9fcd3dcc8075e63e","tursoHostname","39352c72d9f24d8c9fcd3dcc8075e63e-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789518676100],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_104":103,"_111":106},"org",{"_104":103,"_105":106,"_107":106,"_19":61,"_108":109,"_110":31},"branch",{"_13":93,"_38":94,"_49":48,"_95":50,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":51,"_102":103},"isOwned",62,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","BinanceType","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_49":50,"_38":51,"_44":158,"_53":-5,"_54":31,"_55":56,"_57":56,"_58":59,"_60":-5,"_19":61,"_62":-5,"_63":31,"_64":-5,"_65":-5,"_66":67,"_68":69,"_70":71,"_72":73,"_74":159,"_76":-5,"_77":78,"_79":78,"_80":81,"_82":81,"_83":81,"_84":78,"_85":78,"_86":160,"_88":161,"_90":162,"_92":31},"tree",[153],"files",[153],"counts",{"_141":67,"_142":143,"_144":143,"_145":146,"_147":148},"contents",[133],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_49":134,"_38":34,"_36":37,"_135":-5,"_47":48,"_46":14,"_136":31,"_44":137,"_13":138,"_39":40,"_41":43,"_30":31,"_139":-5,"_33":140},"5f789473-ffbc-4210-9ee3-e3f109f5753d","parentId","latest",["D",1788583251407],27,"label",[34],"pulls","branches",1,"forks","envVars",{"_149":151,"_152":67},"connections",{"_149":67,"_150":67},"count","unfilledCount",3,"emptyCount",{"_49":134,"_38":34,"_36":37,"_135":-5,"_47":48,"_46":14,"_136":31,"_44":154,"_13":138,"_39":40,"_41":43,"_30":31,"_139":-5,"_155":156,"_33":157},["D",1788583251407],"children",[],[34],["D",1788203711379],["D",1789518676100],{"_104":103,"_111":106},{"_104":103,"_105":106,"_107":106,"_19":61,"_108":109,"_110":31},{"_13":93,"_38":94,"_49":48,"_95":50,"_96":-5,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":51,"_102":103},"ctx",{"_86":-5,"_130":196,"_197":198,"_199":200,"_201":31,"_202":31,"_203":31,"_204":205,"_206":-5,"_207":-7,"_208":-7,"_209":67,"_210":31,"_211":31,"_212":-5,"_213":31,"_214":31,"_215":31,"_216":-5},"ENV",{"_167":168,"_169":170,"_171":94,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195},"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",true,"preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Diff · v37