[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_191":192,"_193":194},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_70":136,"_40":-7,"_142":-5,"_17":143,"_144":145,"_146":147,"_148":149,"_150":151,"_152":-5,"_153":154,"_155":156,"_157":48,"_158":159,"_160":48,"_161":-5,"_162":-5,"_163":164},"routes/_app.x.$handle.$name.compare.$branch",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":22,"_23":24,"_25":26,"_27":28,"_29":30,"_31":-5},"handle","moju","name","crypto-analysis","branchName","main","project",{"_32":58,"_13":14,"_34":99,"_46":-5,"_100":48,"_49":50,"_101":50,"_102":103,"_104":-5,"_105":106,"_107":-5,"_108":48,"_109":-5,"_110":-5,"_111":112,"_53":113,"_114":115,"_116":117,"_118":119,"_120":-5,"_121":122,"_123":122,"_124":125,"_126":125,"_127":125,"_128":122,"_129":122,"_130":131,"_132":133,"_134":28,"_47":48},"ahead",3,"behind",26,"diff",{"_63":64,"_65":66,"_67":68},"hasChanges",true,"sourceBranch",{"_40":56,"_13":16,"_32":57,"_38":58,"_42":33,"_43":59,"_60":50,"_61":39,"_62":54,"_55":14,"_51":12},"targetBranch",{"_32":33,"_34":35,"_36":37,"_13":16,"_38":39,"_40":41,"_42":-5,"_43":-5,"_44":45,"_46":-5,"_47":48,"_49":50,"_51":52,"_53":54,"_55":14},"pull","id","048ca32d-0128-477a-864d-75c287c2728c","createdAt",["D",1788203711379],"updatedAt",["D",1788712665343],"projectId","39352c72-d9f2-4d8c-9fcd-3dcc8075e63e","version",62,"forkedBranchId","forkedBranchVersion","lockfileKey","1788712665413-esm.town_v_BinanceType_crypto-analysis@62-main","deletedAt","isOwned",false,"privacy","public","userHandle","BinanceType","orgId","01a0593c-e182-77cd-ae7c-935af95131b8","projectName",4,"e08d80c0-e13d-45af-a5ef-d581ac01580a","e3457866-fc14-426a-b766-6febc5ad1c69",36,"forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","added",[],"deleted",[],"modified",[69],{"_70":71,"_72":73,"_74":75},"path","main.ts","targetFile",{"_32":93,"_13":71,"_77":94,"_79":-5,"_80":33,"_81":59,"_82":48,"_34":95,"_40":22,"_84":85,"_86":96,"_65":48,"_88":-5,"_89":-7,"_70":97,"_91":98},"sourceFile",{"_32":76,"_13":71,"_77":78,"_79":-5,"_80":57,"_81":56,"_82":26,"_34":83,"_40":20,"_84":85,"_86":87,"_65":48,"_88":-5,"_89":-7,"_70":90,"_91":92},"52314641-ffcd-4aa7-9474-32ebceff0614","fileId","01a06150-7456-72b2-b01c-991ea257bad9","parentId","branchId","branchVersion","latest",["D",1788339076128],"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 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\n/**\n * Mid-liquidity opportunity scanner.\n * No fixed watchlist — it scans ALL Binance USDT futures pairs and picks\n * coins in a middle liquidity band (24h quote volume between MIN and MAX),\n * then ranks those by strongest 24h price move.\n */\nconst MIN_QUOTE_VOLUME = 5_000_000; // ≥ $5M traded in 24h (not illiquid)\nconst MAX_QUOTE_VOLUME = 500_000_000; // ≤ $500M traded in 24h (not mega-cap)\nconst MAX_CANDIDATES = 10;\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 // Skip leveraged tokens and stablecoin pairs\n const skip = /(UPUSDT|DOWNUSDT|BULLUSDT|BEARUSDT|USDCUSDT|FDUSDUSDT|TUSDUSDT|BUSDT)$/;\n const candidates = tickers.filter((t) => {\n if (!t.symbol.endsWith(\"USDT\") || skip.test(t.symbol)) return false;\n const qv = parseFloat(t.quoteVolume ?? \"0\");\n return qv >= MIN_QUOTE_VOLUME && qv <= MAX_QUOTE_VOLUME;\n });\n\n console.log(\n `Mid-liquidity candidates (${MIN_QUOTE_VOLUME / 1e6}M–${MAX_QUOTE_VOLUME / 1e6}M USDT): ${candidates.length}`,\n );\n\n return candidates\n .sort((a, b) => Math.abs(parseFloat(b.priceChangePercent)) - Math.abs(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 is currently showing strong movement within the \" +\n \"mid-liquidity segment (24h volume between $5M and $500M). \" +\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","label","children",[71],"contentHash","85188da118da443e05bd2aba6624f6723c8f45bbc2d4000043c4f92ae11b496f","3cec6958-b4d2-42b1-ac57-1863c8847047","b0fe12f6-a572-11f1-b4fb-1607ee4eb77e",["D",1788271835885],"/**\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",[71],"6162d13097ad09c85dfaa0df3be51565f8512393a23cb3bf4dd595a4dfbea99a",["D",1788339057685],"legacyEnvVars","httpPrivacy","description","Scans mid-liquidity USDT pairs and posts analysis","imageUrl","userId","ce1d74cb-7bc9-40a2-bbdd-2eb0b3916b37","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"01a059f6-d6ad-7343-b9ef-2e04007a610e","tursoName","e3457866fc14426ab7666febc5ad1c69","tursoHostname","e3457866fc14426ab7666febc5ad1c69-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789555877593],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_141":136},"org",{"_11":12,"_135":136,"_137":136,"_105":106,"_138":139,"_140":48},"branch","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_32":58,"_13":14,"_34":186,"_46":-5,"_100":48,"_49":50,"_101":50,"_102":103,"_104":-5,"_105":106,"_107":-5,"_108":48,"_109":-5,"_110":-5,"_111":112,"_53":113,"_114":115,"_116":117,"_118":187,"_120":-5,"_121":122,"_123":122,"_124":125,"_126":125,"_127":125,"_128":122,"_129":122,"_130":188,"_132":189,"_134":190,"_47":48},"tree",[183],"files",[183],"counts",{"_172":112,"_173":174,"_175":112,"_176":177,"_178":179},"contents",[169],"file","upstreamProject",{"_32":39,"_13":14,"_102":167,"_104":-5,"_49":50,"_130":168},"upstreamBranch",{"_32":33,"_34":165,"_36":166,"_13":16,"_38":39,"_40":41,"_42":-5,"_43":-5,"_44":45,"_46":-5,"_47":48,"_49":50,"_51":52,"_53":54,"_55":14},"emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},["D",1788203711379],["D",1788712665343],"Top gainer chart, Binance Square post, Telegram alert",{"_11":52,"_141":136},{"_32":76,"_13":71,"_77":78,"_79":-5,"_80":57,"_81":56,"_82":26,"_34":170,"_40":20,"_84":85,"_86":87,"_65":48,"_88":-5,"_70":171},["D",1788339076128],[71],"pulls","branches",1,"forks","envVars",{"_180":20,"_182":20},"connections",{"_180":112,"_181":112},"count","unfilledCount","emptyCount",{"_32":76,"_13":71,"_77":78,"_79":-5,"_80":57,"_81":56,"_82":26,"_34":83,"_40":20,"_84":85,"_86":87,"_65":48,"_88":-5,"_89":184,"_70":185},[],[71],["D",1788339057685],["D",1789555877593],{"_11":12,"_141":136},{"_11":12,"_135":136,"_137":136,"_105":106,"_138":139,"_140":48},{"_40":56,"_13":16,"_32":57,"_38":58,"_42":33,"_43":59,"_60":50,"_61":39,"_62":54,"_55":14,"_51":12},"ctx",{"_130":-5,"_162":224,"_225":226,"_227":228,"_229":48,"_230":48,"_231":48,"_232":26,"_233":-5,"_234":-7,"_235":-7,"_236":112,"_237":48,"_238":48,"_239":-5,"_240":48,"_241":48,"_242":48,"_243":-5},"ENV",{"_195":196,"_197":198,"_199":16,"_200":201,"_202":203,"_204":205,"_206":207,"_208":209,"_210":211,"_212":213,"_214":215,"_216":217,"_218":219,"_220":221,"_222":223},"REACT_APP_SENTRY_DSN","https://586020d86f05489db63a554690acf1e9@o1398359.ingest.sentry.io/6724499","RENDER_GIT_COMMIT","e87eb04e707cf64e7e532c8e8ec395f209e17f15","RENDER_GIT_BRANCH","POSTHOG_API_TOKEN","phc_nmoyuAkStEZuUp69rYlg1DZgrIt19Gx0Y4Hwf8tGgJP","POSTHOG_API_HOST","https://wart.val.town","WEB_API_TEMPLATE","https://{val}.web.val.run","APP_URL","https://www.val.town","MODULE_URL","https://esm.town","VANITY_WEB_API_TEMPLATE","https://{label}.val.run/","DENOLS_URL","https://lsp.val.town","NODE_ENV","production","CLOUDFLARE_TURNSTILE_SITE_KEY","0x4AAAAAACtaIZJH7s9rBMZ6","GOOGLE_CLIENT_ID","875989696899-jtsqkhlbdv5jrlsk8631p7ipjg3c6o62.apps.googleusercontent.com","STRIPE_PUBLISHABLE_KEY","pk_live_51N2zvWEpZTTLipIkVEwXrUG9AT0yeOOEYxszarZT1jpsZV58Ly6wlg3SltZpHN26CUalOBmUSY7adQRQiSkCZz2500qSXNkf8Y","API_URL","https://api.val.town",[],"preferencesKeybindings","default","preferencesTheme","light","preferencesFixers","preferencesCopilot","preferencesSelectionAi","preferencesCloseBrackets","preferencesChatPanelState","preferencesDprint","preferencesDenofmt","notificationCount","flagDenols","isBusinessOrgMember","businessOrgHandle","isBusinessOrgAdmin","isHigherTownieTier","navCollapsed","currentOrgId"]

Compare

Mergemoju/mainintoBinanceType/main

Cmain.ts+26-7