[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_177":178,"_179":180},"routes/_app.x.$handle.$name",{"_108":107,"_38":51,"_116":94,"_33":110,"_13":14,"_117":-5,"_11":118,"_119":120,"_121":122,"_123":124,"_125":126,"_26":-5,"_127":128,"_129":130,"_131":31,"_132":133,"_134":31,"_135":-5,"_136":-5,"_137":138},"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",2,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","f03d0804-311f-4613-b7c8-653829a49e3d","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","01a06150-7456-72b2-b01c-991ea257bad9","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 quoteVolume: 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","createdAt",["D",1788339075985],"branchVersion","branchId","e08d80c0-e13d-45af-a5ef-d581ac01580a","id","e3457866-fc14-426a-b766-6febc5ad1c69","crypto-analysis",["D",1788339057685],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Scans mid-liquidity USDT pairs and posts analysis","imageUrl","ce1d74cb-7bc9-40a2-bbdd-2eb0b3916b37","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a059f6-d6ad-7343-b9ef-2e04007a610e","tursoName","e3457866fc14426ab7666febc5ad1c69","tursoHostname","e3457866fc14426ab7666febc5ad1c69-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789469441210],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_108":107,"_115":110},"org",{"_108":107,"_109":110,"_111":110,"_19":61,"_112":113,"_114":31},"branch",{"_13":93,"_38":94,"_49":48,"_95":50,"_96":97,"_98":99,"_100":56,"_101":102,"_103":104,"_105":51,"_106":107},"isOwned",4,"main","projectId","forkedBranchId","048ca32d-0128-477a-864d-75c287c2728c","forkedBranchVersion",36,"forkedProjectPrivacy","forkedProjectId","39352c72-d9f2-4d8c-9fcd-3dcc8075e63e","forkedProjectOrgId","01a0593c-e182-77cd-ae7c-935af95131b8","projectName","userHandle","moju","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_49":50,"_38":51,"_44":172,"_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":173,"_76":-5,"_77":78,"_79":78,"_80":81,"_82":81,"_83":81,"_84":78,"_85":78,"_86":174,"_88":175,"_90":176,"_92":31},"tree",[167],"files",[167],"counts",{"_156":67,"_157":153,"_158":67,"_159":160,"_161":162},"contents",[148],"upstreamProject",{"_49":102,"_38":51,"_58":146,"_60":-5,"_55":56,"_86":147},"upstreamBranch",{"_49":97,"_44":139,"_140":141,"_38":94,"_95":102,"_13":142,"_96":-5,"_98":-5,"_143":144,"_53":-5,"_92":31,"_55":56,"_106":145,"_68":104,"_105":51},"emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1788203711379],"updatedAt",["D",1788712665343],62,"lockfileKey","1788712665413-esm.town_v_BinanceType_crypto-analysis@62-main","BinanceType","Top gainer chart, Binance Square post, Telegram alert",{"_108":145,"_115":110},{"_49":149,"_38":34,"_36":37,"_150":-5,"_47":48,"_46":14,"_151":31,"_44":152,"_13":153,"_39":40,"_41":43,"_30":31,"_154":-5,"_33":155},"fefd60ea-ccae-47f3-bc17-8d3801768fd6","parentId","latest",["D",1788339075985],1,"label",[34],"pulls","branches","forks","envVars",{"_163":165,"_166":165},"connections",{"_163":67,"_164":67},"count","unfilledCount",3,"emptyCount",{"_49":149,"_38":34,"_36":37,"_150":-5,"_47":48,"_46":14,"_151":31,"_44":168,"_13":153,"_39":40,"_41":43,"_30":31,"_154":-5,"_169":170,"_33":171},["D",1788339075985],"children",[],[34],["D",1788339057685],["D",1789469441210],{"_108":107,"_115":110},{"_108":107,"_109":110,"_111":110,"_19":61,"_112":113,"_114":31},{"_13":93,"_38":94,"_49":48,"_95":50,"_96":97,"_98":99,"_100":56,"_101":102,"_103":104,"_105":51,"_106":107},"ctx",{"_86":-5,"_136":210,"_211":212,"_213":214,"_215":31,"_216":31,"_217":31,"_218":219,"_220":-5,"_221":-7,"_222":-7,"_223":67,"_224":31,"_225":31,"_226":-5,"_227":31,"_228":31,"_229":31,"_230":-5},"ENV",{"_181":182,"_183":184,"_185":94,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195,"_196":197,"_198":199,"_200":201,"_202":203,"_204":205,"_206":207,"_208":209},"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 · v2