[{"_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",56,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","022ac67d-61bc-484d-80d9-070e7a12a6f4","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 stopLoss: number | null;\n targets: (number | null)[];\n recentCandles: Candle[];\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 // --- Single trade setup (entry / SL / targets) ---\n const nearSupport = supportLevels[0];\n const nearResistance = resistanceLevels[0];\n const entry = currentPrice;\n let stopLoss: number | null = null;\n let targets: (number | null)[] = [];\n\n if (trend === \"bullish\") {\n stopLoss = nearSupport != null ? nearSupport * 0.995 : entry * 0.96;\n const t1 = nearResistance ?? entry * 1.05;\n const t2 = resistanceLevels[1] ?? entry * 1.10;\n targets = [\n t1,\n t2,\n periodHigh > t2 ? periodHigh : t2 * 1.05,\n ];\n } else {\n stopLoss = nearResistance != null ? nearResistance * 1.005 : entry * 1.04;\n const t1 = nearSupport ?? entry * 0.95;\n const t2 = supportLevels[1] ?? entry * 0.90;\n targets = [\n t1,\n t2,\n periodLow < t2 ? periodLow : t2 * 0.95,\n ];\n }\n\n return {\n closes,\n rsi,\n rsiSignal,\n supportLevels,\n resistanceLevels,\n fibLevels,\n trend,\n periodHigh,\n periodLow,\n stopLoss,\n targets,\n recentCandles: candles.slice(-48),\n };\n}\n\n// ---------------------------------------------------------------------------\n// Chart generation (QuickChart)\n// ---------------------------------------------------------------------------\n\nfunction buildChartUrl(symbolBase: string, a: Analysis): string {\n const recent = a.recentCandles;\n const labels = recent.map((_, i) => `${recent.length - i}h`);\n const bull = a.trend === \"bullish\";\n const side = bull ? \"LONG\" : \"SHORT\";\n const fmt = (n: number) => n.toPrecision(6).replace(/\\.?0+$/, \"\");\n\n // --- Candle emulation via floating bars (wick + body) ---\n const GREEN = \"#02c076\";\n const RED = \"#f0465a\";\n const wickData = recent.map((c) => [+c.low.toFixed(6), +c.high.toFixed(6)]);\n const bodyData = recent.map((c) =>\n +c.open.toFixed(6) <= +c.close.toFixed(6)\n ? [+c.open.toFixed(6), +c.close.toFixed(6)]\n : [+c.close.toFixed(6), +c.open.toFixed(6)]\n );\n const colors = recent.map((c) => (c.close >= c.open ? GREEN : RED));\n\n // --- Trade level lines (line datasets over bar chart) ---\n const levelDatasets: Record[] = [];\n const addLevel = (\n label: string,\n price: number | null | undefined,\n color: string,\n dash: number[],\n ) => {\n if (price == null) return;\n levelDatasets.push({\n type: \"line\",\n label: `${label} ${fmt(price)}`,\n data: recent.map(() => price),\n borderColor: color,\n borderDash: dash,\n borderWidth: 2,\n pointRadius: 0,\n fill: false,\n });\n };\n\n addLevel(`🛑 SL`, a.stopLoss, RED, [8, 4]);\n addLevel(`🎯 TP1`, a.targets?.[0], GREEN, [8, 4]);\n addLevel(`🎯 TP2`, a.targets?.[1], GREEN, [8, 4]);\n addLevel(`🎯 TP3`, a.targets?.[2], GREEN, [8, 4]);\n addLevel(`⭐ Entry`, a.closes[a.closes.length - 1], \"#f0b90b\", [0]);\n\n const chartConfig = {\n type: \"bar\",\n data: {\n labels,\n datasets: [\n {\n label: \"wick\",\n data: wickData,\n backgroundColor: colors,\n barPercentage: 0.12,\n categoryPercentage: 1,\n },\n {\n label: symbolBase,\n data: bodyData,\n backgroundColor: colors,\n barPercentage: 0.7,\n categoryPercentage: 1,\n },\n ...levelDatasets,\n ],\n },\n options: {\n title: {\n display: true,\n text: `${symbolBase}/USDT ${side} — ${bull ? \"▲\" : \"▼\"} Trade Setup (RSI ${\n a.rsi?.toFixed(1) ?? \"n/a\"\n })`,\n fontColor: \"#ffffff\",\n fontSize: 18,\n },\n legend: {\n position: \"bottom\",\n labels: { fontColor: \"#ffffff\", fontSize: 11, boxWidth: 14 },\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 chartQuery = new URLSearchParams({\n backgroundColor: \"#181a20\",\n width: \"1080\",\n height: \"1080\",\n devicePixelRatio: \"2\",\n });\n\n // Return an object instead of a URL: the config is POSTed to QuickChart\n // (GET URLs are size-limited and fail for large configs).\n return { ...chartConfig, ...Object.fromEntries(chartQuery) } as never;\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 entry = a.closes[a.closes.length - 1];\n const stopLoss = a.stopLoss;\n const targets = a.targets;\n const side = a.trend === \"bullish\" ? \"LONG 🔼\" : \"SHORT 🔽\";\n\n const risk = stopLoss != null ? Math.abs(entry - stopLoss) : 0;\n const lastTp = targets[targets.length - 1];\n const rr = risk > 0 && lastTp != null\n ? (Math.abs(lastTp - entry) / risk).toFixed(1)\n : \"n/a\";\n\n // --- Catchy hook lines (rotating curiosity hooks) ---\n const hooks = a.trend === \"bullish\"\n ? [\n `🚨 ${tag} just flashed a buy signal — smart money is loading up...`,\n `🔥 While everyone is watching, ${tag} is quietly setting up this move...`,\n `👀 This ${tag} setup is what traders dream about — don't scroll past it.`,\n `💎 ${tag} bulls are back. This entry could be the one.`,\n ]\n : [\n `🚨 ${tag} just flashed a sell signal — the drop may just be starting...`,\n `⚠️ ${tag} is breaking down — here's the short everyone will talk about.`,\n `🧨 Sellers took control of ${tag}. This setup prints...`,\n `👀 ${tag} is bleeding — smart money is already positioned.`,\n ];\n const hook = hooks[Math.floor(Math.random() * hooks.length)];\n\n const tpLines = targets.map((t, i) => `🎯 TP${i + 1}: ${t != null ? fmt(t) : \"—\"}`).join(\"\\n\");\n\n return [\n tag,\n \"\",\n hook,\n \"\",\n \"📌 TRADE SETUP:\",\n ` ${side}`,\n ` 🟢 Entry: ${fmt(entry)}`,\n ` 🛑 Stop Loss: ${stopLoss != null ? fmt(stopLoss) : \"—\"}`,\n tpLines,\n ` ⚖️ Risk/Reward: 1 : ${rr}`,\n \"\",\n `⚡ 24h move: ${ticker.priceChangePercent}% | RSI: ${a.rsi?.toFixed(1) ?? \"n/a\"}`,\n \"\",\n \"💡 Not financial advice — always manage your risk.\",\n \"\",\n \"#Crypto #Bitcoin #CryptoTrading #Altcoins #CryptoNews #TradingSignals #BinanceSquare #ForexTrading #DayTrading #AltcoinSeason\",\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\nasync function fetchChartPng(chartConfig: unknown): Promise {\n // POST the config to QuickChart (GET URLs are size-limited and fail\n // for large candlestick configs).\n const res = await fetch(\"https://quickchart.io/chart\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n chart: chartConfig,\n width: 1080,\n height: 1080,\n backgroundColor: \"#181a20\",\n devicePixelRatio: 2,\n }),\n });\n if (!res.ok) {\n throw new Error(`QuickChart render failed: ${res.status} ${await res.text()}`);\n }\n return new Uint8Array(await res.arrayBuffer());\n}\n\n/** Upload an image to Binance Square via the official OpenAPI flow. */\nasync function uploadSquareImage(apiKey: string, chartPng: Uint8Array): Promise {\n // 1. 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 // 2. PUT the bytes to the presigned URL\n const putRes = await fetch(presignedUrl, {\n method: \"PUT\",\n headers: { \"Content-Type\": \"image/png\" },\n body: chartPng,\n });\n if (!putRes.ok) throw new Error(`Image upload failed: ${putRes.status} ${putRes.statusText}`);\n\n // 3. 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 chartConfig: unknown,\n): Promise<{ ok: boolean; body: unknown; imageUrl?: string }> {\n // Render the chart PNG, upload it, then publish contentType=1 (image post)\n const chartPng = await fetchChartPng(chartConfig);\n const squareImageUrl = await uploadSquareImage(apiKey, chartPng);\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, imageUrl: squareImageUrl };\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 // Telegram photo captions are limited to 1024 chars\n const maxLen = imageUrl ? 1024 : 4096;\n if (message.length > maxLen) {\n message = message.slice(0, maxLen - 1) + \"…\";\n }\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(20);\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 = 1;\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 stopLoss: number | null;\n targets: (number | null)[];\n recentCandles: Candle[];\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 // --- Single trade setup (entry / SL / targets) ---\n const nearSupport = supportLevels[0];\n const nearResistance = resistanceLevels[0];\n const entry = currentPrice;\n let stopLoss: number | null = null;\n let targets: (number | null)[] = [];\n\n if (trend === \"bullish\") {\n stopLoss = nearSupport != null ? nearSupport * 0.995 : entry * 0.96;\n const t1 = nearResistance ?? entry * 1.05;\n const t2 = resistanceLevels[1] ?? entry * 1.10;\n targets = [\n t1,\n t2,\n periodHigh > t2 ? periodHigh : t2 * 1.05,\n ];\n } else {\n stopLoss = nearResistance != null ? nearResistance * 1.005 : entry * 1.04;\n const t1 = nearSupport ?? entry * 0.95;\n const t2 = supportLevels[1] ?? entry * 0.90;\n targets = [\n t1,\n t2,\n periodLow < t2 ? periodLow : t2 * 0.95,\n ];\n }\n\n return {\n closes,\n rsi,\n rsiSignal,\n supportLevels,\n resistanceLevels,\n fibLevels,\n trend,\n periodHigh,\n periodLow,\n stopLoss,\n targets,\n recentCandles: candles.slice(-48),\n };\n}\n\n// ---------------------------------------------------------------------------\n// Chart generation (QuickChart)\n// ---------------------------------------------------------------------------\n\nfunction buildChartUrl(symbolBase: string, a: Analysis): string {\n const recent = a.recentCandles;\n const labels = recent.map((_, i) => `${recent.length - i}h`);\n const bull = a.trend === \"bullish\";\n const side = bull ? \"LONG\" : \"SHORT\";\n const fmt = (n: number) => n.toPrecision(6).replace(/\\.?0+$/, \"\");\n\n // --- Candle emulation via floating bars (wick + body) ---\n const GREEN = \"#02c076\";\n const RED = \"#f0465a\";\n const wickData = recent.map((c) => [+c.low.toFixed(6), +c.high.toFixed(6)]);\n const bodyData = recent.map((c) =>\n +c.open.toFixed(6) <= +c.close.toFixed(6)\n ? [+c.open.toFixed(6), +c.close.toFixed(6)]\n : [+c.close.toFixed(6), +c.open.toFixed(6)]\n );\n const colors = recent.map((c) => (c.close >= c.open ? GREEN : RED));\n\n // --- Trade level lines (line datasets over bar chart) ---\n const levelDatasets: Record[] = [];\n const addLevel = (\n label: string,\n price: number | null | undefined,\n color: string,\n dash: number[],\n ) => {\n if (price == null) return;\n levelDatasets.push({\n type: \"line\",\n label: `${label} ${fmt(price)}`,\n data: recent.map(() => price),\n borderColor: color,\n borderDash: dash,\n borderWidth: 2,\n pointRadius: 0,\n fill: false,\n });\n };\n\n addLevel(`🛑 SL`, a.stopLoss, RED, [8, 4]);\n addLevel(`🎯 TP1`, a.targets?.[0], GREEN, [8, 4]);\n addLevel(`🎯 TP2`, a.targets?.[1], GREEN, [8, 4]);\n addLevel(`🎯 TP3`, a.targets?.[2], GREEN, [8, 4]);\n addLevel(`⭐ Entry`, a.closes[a.closes.length - 1], \"#f0b90b\", [0]);\n\n const chartConfig = {\n type: \"bar\",\n data: {\n labels,\n datasets: [\n {\n label: \"wick\",\n data: wickData,\n backgroundColor: colors,\n barPercentage: 0.12,\n categoryPercentage: 1,\n },\n {\n label: symbolBase,\n data: bodyData,\n backgroundColor: colors,\n barPercentage: 0.7,\n categoryPercentage: 1,\n },\n ...levelDatasets,\n ],\n },\n options: {\n title: {\n display: true,\n text: `${symbolBase}/USDT ${side} — ${bull ? \"▲\" : \"▼\"} Trade Setup (RSI ${\n a.rsi?.toFixed(1) ?? \"n/a\"\n })`,\n fontColor: \"#ffffff\",\n fontSize: 18,\n },\n legend: {\n position: \"bottom\",\n labels: { fontColor: \"#ffffff\", fontSize: 11, boxWidth: 14 },\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 chartQuery = new URLSearchParams({\n backgroundColor: \"#181a20\",\n width: \"1080\",\n height: \"1080\",\n devicePixelRatio: \"2\",\n });\n\n // Return an object instead of a URL: the config is POSTed to QuickChart\n // (GET URLs are size-limited and fail for large configs).\n return { ...chartConfig, ...Object.fromEntries(chartQuery) } as never;\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 entry = a.closes[a.closes.length - 1];\n const stopLoss = a.stopLoss;\n const targets = a.targets;\n const side = a.trend === \"bullish\" ? \"LONG 🔼\" : \"SHORT 🔽\";\n\n const risk = stopLoss != null ? Math.abs(entry - stopLoss) : 0;\n const lastTp = targets[targets.length - 1];\n const rr = risk > 0 && lastTp != null\n ? (Math.abs(lastTp - entry) / risk).toFixed(1)\n : \"n/a\";\n\n // --- Catchy hook lines (rotating curiosity hooks) ---\n const hooks = a.trend === \"bullish\"\n ? [\n `🚨 ${tag} just flashed a buy signal — smart money is loading up...`,\n `🔥 While everyone is watching, ${tag} is quietly setting up this move...`,\n `👀 This ${tag} setup is what traders dream about — don't scroll past it.`,\n `💎 ${tag} bulls are back. This entry could be the one.`,\n ]\n : [\n `🚨 ${tag} just flashed a sell signal — the drop may just be starting...`,\n `⚠️ ${tag} is breaking down — here's the short everyone will talk about.`,\n `🧨 Sellers took control of ${tag}. This setup prints...`,\n `👀 ${tag} is bleeding — smart money is already positioned.`,\n ];\n const hook = hooks[Math.floor(Math.random() * hooks.length)];\n\n const tpLines = targets.map((t, i) => `🎯 TP${i + 1}: ${t != null ? fmt(t) : \"—\"}`).join(\"\\n\");\n\n return [\n tag,\n \"\",\n hook,\n \"\",\n \"📌 TRADE SETUP:\",\n ` ${side}`,\n ` 🟢 Entry: ${fmt(entry)}`,\n ` 🛑 Stop Loss: ${stopLoss != null ? fmt(stopLoss) : \"—\"}`,\n tpLines,\n ` ⚖️ Risk/Reward: 1 : ${rr}`,\n \"\",\n `⚡ 24h move: ${ticker.priceChangePercent}% | RSI: ${a.rsi?.toFixed(1) ?? \"n/a\"}`,\n \"\",\n \"💡 Not financial advice — always manage your risk.\",\n \"\",\n \"#Crypto #Bitcoin #CryptoTrading #Altcoins #CryptoNews #TradingSignals #BinanceSquare #ForexTrading #DayTrading #AltcoinSeason\",\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\nasync function fetchChartPng(chartConfig: unknown): Promise {\n // POST the config to QuickChart (GET URLs are size-limited and fail\n // for large candlestick configs).\n const res = await fetch(\"https://quickchart.io/chart\", {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n chart: chartConfig,\n width: 1080,\n height: 1080,\n backgroundColor: \"#181a20\",\n devicePixelRatio: 2,\n }),\n });\n if (!res.ok) {\n throw new Error(`QuickChart render failed: ${res.status} ${await res.text()}`);\n }\n return new Uint8Array(await res.arrayBuffer());\n}\n\n/** Upload an image to Binance Square via the official OpenAPI flow. */\nasync function uploadSquareImage(apiKey: string, chartPng: Uint8Array): Promise {\n // 1. 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 // 2. PUT the bytes to the presigned URL\n const putRes = await fetch(presignedUrl, {\n method: \"PUT\",\n headers: { \"Content-Type\": \"image/png\" },\n body: chartPng,\n });\n if (!putRes.ok) throw new Error(`Image upload failed: ${putRes.status} ${putRes.statusText}`);\n\n // 3. 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 chartConfig: unknown,\n): Promise<{ ok: boolean; body: unknown; imageUrl?: string }> {\n // Render the chart PNG, upload it, then publish contentType=1 (image post)\n const chartPng = await fetchChartPng(chartConfig);\n const squareImageUrl = await uploadSquareImage(apiKey, chartPng);\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, imageUrl: squareImageUrl };\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 // Telegram photo captions are limited to 1024 chars\n const maxLen = imageUrl ? 1024 : 4096;\n if (message.length > maxLen) {\n message = message.slice(0, maxLen - 1) + \"…\";\n }\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(20);\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 = 1;\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 config\n const candles = await getKlines(gainer.symbol, 168);\n const analysis = analyzeCandles(candles);\n const chartConfig = buildChartUrl(symbolBase, analysis);\n\n // 3. Content (English)\n const postText = formatEnglishPost(gainer, symbolBase, analysis);\n\n // 4. Publish to Binance Square (renders chart, uploads, posts)\n const squareResult = await postToBinanceSquare(SQUARE_API_KEY, postText, chartConfig);\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",1788712296259],"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},"8823dd87-2c37-42cf-9605-749872989448","parentId","latest",["D",1788712296259],46,"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",1788712296259],"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 · v56