[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_267":268,"_269":270},"routes/_app.x.$handle.$name",{"_100":99,"_37":48,"_108":90,"_32":102,"_13":14,"_109":-5,"_11":110,"_111":112,"_113":114,"_115":116,"_117":118,"_26":-5,"_119":-5,"_120":-5,"_121":30,"_122":123,"_124":30,"_125":-5,"_126":-5,"_127":128},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":-5},"project",{"_46":47,"_37":48,"_41":49,"_50":-5,"_51":30,"_52":53,"_54":53,"_55":56,"_57":-5,"_19":58,"_59":-5,"_60":30,"_61":-5,"_62":-5,"_63":64,"_65":66,"_67":68,"_69":70,"_71":72,"_73":-5,"_74":75,"_76":75,"_77":78,"_79":78,"_80":78,"_81":75,"_82":75,"_83":84,"_85":86,"_87":88,"_89":30},"version",10,"changes",[25],"aiChatInfo",{"_20":21,"_22":-5,"_23":-5,"_24":-5},"userId","aiChatMessageId","813ef524-7cc5-452d-9fa6-dd1c1de8b523","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle",{"_26":27,"_28":-7,"_29":30,"_31":30,"_32":33,"_34":33},"file",{"_35":36,"_37":33,"_38":26,"_39":40,"_41":42,"_43":14,"_44":45,"_29":30},"previous","deleted",false,"deletedHere","path","README.md","latestPath","fileId","61ff2a54-5aa5-11f1-8431-ee650bb23af1","name","fileType","content","# Binance Futures Scalping Bot\n\n1-minute scalping bot for Binance USDM Futures with DCA logic, technical indicators, and Telegram reporting.\n\n## Strategy\n\n- **Timeframe:** 1m candles\n- **Trend Filter:** EMA 200 — only Long above, only Short below\n- **Entry Zone:** Bollinger Bands (20, 2) — Long at lower band, Short at upper band\n- **Momentum:** Stochastic (5, 3, 3) — oversold/overbought crossover confirmation\n- **Liquidity:** Order book bid/ask ratio validation\n- **Leverage:** Fixed 20x\n- **R:R:** Fixed 1:1.5 (SL 1.5%, TP 2.25%)\n- **DCA:** Second entry at 0.7% adverse move, recalculates avg price + SL/TP\n- **Max Positions:** 4 concurrent\n\n## Pairs\n`1000PEPE/USDT`, `DOGE/USDT`, `1000FLOKI/USDT`, `1000SHIB/USDT`, `1000BONK/USDT`\n\n## Architecture\n\n```mermaid\ngraph TD\n A[bot-loop.ts — every 15min] --> B[Sync positions with exchange]\n B --> C[Manage DCA entries]\n C --> D[Scan all symbols]\n D --> E{Signal found?}\n E -->|Yes| F[Execute market order]\n F --> G[Place SL/TP orders]\n G --> H[Save to SQLite]\n E -->|No| I[Wait for next cycle]\n J[telegram-report.ts — every 30min] --> K[Send status to Telegram]\n```\n\n## Setup\n\nAdd these 4 environment variables to activate the bot (see links below).\n\n## ⚠️ Risk Warning\n\nThis bot trades with **real money** and **20x leverage**. A 5% adverse move = 100% loss. Only use funds you can afford to lose.\n","createdAt",["D",1779980178527],"branchVersion","branchId","faabd302-5aa4-11f1-82e9-ee650bb23af1","id","faaace58-5aa4-11f1-82e9-ee650bb23af1","binance-scalping-bot",["D",1779980005182],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","1m Binance Futures scalping bot with DCA, EMA/BB/Stoch","imageUrl","f4c69c23-c3db-41dc-88a8-169912f3e393","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","019e5621-4dde-7419-8fb0-8d072ba2bcea","tursoName","faaace585aa411f182e9ee650bb23af1","tursoHostname","faaace585aa411f182e9ee650bb23af1-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789495880338],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_100":99,"_107":102},"org",{"_100":99,"_101":102,"_103":102,"_19":58,"_104":105,"_106":30},"branch",{"_13":14,"_37":90,"_46":45,"_91":47,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":48,"_98":99},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","mobaslah","handle","displayName","","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","adoptOrgId",{"_46":47,"_37":48,"_41":262,"_50":-5,"_51":30,"_52":53,"_54":53,"_55":56,"_57":-5,"_19":58,"_59":-5,"_60":30,"_61":-5,"_62":-5,"_63":64,"_65":66,"_67":68,"_69":70,"_71":263,"_73":-5,"_74":75,"_76":75,"_77":78,"_79":78,"_80":78,"_81":75,"_82":75,"_83":264,"_85":265,"_87":266,"_89":30},"tree",[221,222,223,224,225,226,227,228,229,230],"files",[221,222,223,224,225,226,227,228,229,230],"counts",{"_211":64,"_212":197,"_213":64,"_214":215,"_216":217},"contents",[129,130,131,132,133,134,135,136,137,138],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_46":208,"_37":33,"_35":36,"_142":-5,"_44":45,"_43":14,"_144":145,"_41":209,"_13":64,"_38":26,"_39":40,"_29":30,"_149":-5,"_32":210},{"_46":201,"_37":202,"_35":203,"_142":-5,"_44":45,"_43":204,"_144":145,"_41":205,"_13":64,"_38":156,"_39":206,"_29":30,"_149":-5,"_32":207},{"_46":194,"_37":195,"_35":196,"_142":-5,"_44":45,"_43":197,"_144":145,"_41":198,"_13":64,"_38":147,"_39":199,"_29":30,"_149":-5,"_32":200},{"_46":187,"_37":188,"_35":189,"_142":-5,"_44":45,"_43":190,"_144":145,"_41":191,"_13":64,"_38":147,"_39":192,"_29":30,"_149":-5,"_32":193},{"_46":180,"_37":181,"_35":182,"_142":-5,"_44":45,"_43":183,"_144":145,"_41":184,"_13":64,"_38":147,"_39":185,"_29":30,"_149":-5,"_32":186},{"_46":173,"_37":174,"_35":175,"_142":-5,"_44":45,"_43":176,"_144":145,"_41":177,"_13":64,"_38":147,"_39":178,"_29":30,"_149":-5,"_32":179},{"_46":166,"_37":167,"_35":168,"_142":-5,"_44":45,"_43":169,"_144":145,"_41":170,"_13":64,"_38":147,"_39":171,"_29":30,"_149":-5,"_32":172},{"_46":159,"_37":160,"_35":161,"_142":-5,"_44":45,"_43":162,"_144":145,"_41":163,"_13":64,"_38":147,"_39":164,"_29":30,"_149":-5,"_32":165},{"_46":151,"_37":152,"_35":153,"_142":-5,"_44":45,"_43":154,"_144":145,"_41":155,"_13":64,"_38":156,"_39":157,"_29":30,"_149":-5,"_32":158},{"_46":139,"_37":140,"_35":141,"_142":-5,"_44":45,"_43":143,"_144":145,"_41":146,"_13":64,"_38":147,"_39":148,"_29":30,"_149":-5,"_32":150},"4e036808-5aa5-11f1-8431-ee650bb23af1","telegram.ts","4e0368b2-5aa5-11f1-8431-ee650bb23af1","parentId",7,"latest",true,["D",1779980145001],"script","// ============================================\n// TELEGRAM — Notifications & status reports\n// ============================================\nimport { getAvailableBalance } from \"./exchange.ts\";\nimport { getOpenPositions, getRecentTrades } from \"./database.ts\";\nimport { getExchange } from \"./exchange.ts\";\n\nconst TELEGRAM_API = \"https://api.telegram.org/bot\";\n\nfunction getTelegramConfig() {\n const token = Deno.env.get(\"TELEGRAM_TOKEN\");\n const chatId = Deno.env.get(\"TELEGRAM_CHAT_ID\");\n if (!token || !chatId) throw new Error(\"Missing TELEGRAM_TOKEN or TELEGRAM_CHAT_ID\");\n return { token, chatId };\n}\n\n/**\n * Send a message to Telegram\n */\nexport async function sendTelegram(text: string) {\n try {\n const { token, chatId } = getTelegramConfig();\n await fetch(`${TELEGRAM_API}${token}/sendMessage`, {\n method: \"POST\",\n headers: { \"Content-Type\": \"application/json\" },\n body: JSON.stringify({\n chat_id: chatId,\n text,\n parse_mode: \"Markdown\",\n }),\n });\n } catch (err: any) {\n console.error(`Telegram error: ${err.message}`);\n }\n}\n\n/**\n * Send trade entry notification\n */\nexport async function notifyEntry(message: string) {\n await sendTelegram(`🟢 *NEW TRADE*\\n${message}`);\n}\n\n/**\n * Send DCA notification\n */\nexport async function notifyDCA(message: string) {\n await sendTelegram(`🔄 *DCA TRIGGERED*\\n${message}`);\n}\n\n/**\n * Send comprehensive 5-minute status report\n */\nexport async function sendStatusReport() {\n const ex = getExchange();\n\n // 1. Balance\n const balance = await getAvailableBalance();\n\n // 2. Open positions with live PnL\n const positions = await getOpenPositions();\n let positionsText = \"\";\n if (positions.length === 0) {\n positionsText = \" No open positions\";\n } else {\n for (const pos of positions) {\n const p = pos as any;\n try {\n const ticker = await ex.fetchTicker(p.symbol);\n const livePrice = ticker.last!;\n let unrealizedPnl: number;\n if (p.side === \"LONG\") {\n unrealizedPnl = (livePrice - p.avg_price) * p.quantity;\n } else {\n unrealizedPnl = (p.avg_price - livePrice) * p.quantity;\n }\n const pnlEmoji = unrealizedPnl >= 0 ? \"🟢\" : \"🔴\";\n const dcaStatus = p.dca_count > 0 ? \"✅ DCA done\" : \"⏳ No DCA\";\n positionsText += ` ${pnlEmoji} ${p.side} ${p.symbol}\\n`;\n positionsText += ` Entry: ${p.avg_price} | Now: ${livePrice}\\n`;\n positionsText += ` PnL: $${unrealizedPnl.toFixed(4)} | ${dcaStatus}\\n`;\n positionsText += ` SL: ${p.sl_price} | TP: ${p.tp_price}\\n\\n`;\n } catch {\n positionsText += ` ${p.side} ${p.symbol} (price unavailable)\\n`;\n }\n }\n }\n\n // 3. Recent closed trades\n const trades = await getRecentTrades(5);\n let tradesText = \"\";\n if (trades.length === 0) {\n tradesText = \" No recent trades\";\n } else {\n for (const t of trades) {\n const tr = t as any;\n const emoji = tr.result === \"WIN\" ? \"✅\" : \"❌\";\n tradesText += ` ${emoji} ${tr.side} ${tr.symbol} PnL: $${tr.pnl?.toFixed(4) || \"?\"} (${tr.result})\\n`;\n }\n }\n\n const report = `📊 *BOT STATUS REPORT*\n━━━━━━━━━━━━━━━━━\n💰 *Balance:* $${balance.toFixed(4)} USDT\n\n📈 *Open Positions (${positions.length}/4):*\n${positionsText}\n📋 *Recent Trades:*\n${tradesText}\n━━━━━━━━━━━━━━━━━\n⏰ ${new Date().toISOString()}`;\n\n await sendTelegram(report);\n}\n","label",[140],"572babe8-5aa5-11f1-bf22-ee650bb23af1","telegram-report.ts","572bad00-5aa5-11f1-bf22-ee650bb23af1",9,["D",1779980160367],"interval","// ============================================\n// TELEGRAM REPORT — 5-minute status updates\n// ============================================\nimport { initDB } from \"./database.ts\";\nimport { sendStatusReport } from \"./telegram.ts\";\n\nexport default async function (interval: Interval) {\n try {\n await initDB();\n await sendStatusReport();\n console.log(\"📊 Status report sent to Telegram\");\n } catch (err: any) {\n console.error(`Report error: ${err.message}`);\n }\n}\n",[152],"21d6b244-5aa5-11f1-82e9-ee650bb23af1","strategy.ts","21d6b30c-5aa5-11f1-82e9-ee650bb23af1",4,["D",1779980070863],"// ============================================\n// STRATEGY — Signal generation from indicators\n// ============================================\nimport { getExchange } from \"./exchange.ts\";\nimport { calcEMA, calcBollingerBands, calcStochastic } from \"./indicators.ts\";\nimport {\n SYMBOLS, TIMEFRAME, CANDLE_LIMIT,\n EMA_PERIOD, BB_PERIOD, BB_STD_DEV,\n STOCH_K_PERIOD, STOCH_SMOOTH_K, STOCH_D_PERIOD,\n STOCH_OVERSOLD, STOCH_OVERBOUGHT,\n ORDERBOOK_DEPTH, ORDERBOOK_RATIO_THRESHOLD,\n} from \"./config.ts\";\n\nexport type Signal = \"LONG\" | \"SHORT\" | null;\n\nexport interface AnalysisResult {\n symbol: string;\n signal: Signal;\n price: number;\n ema200: number;\n bbUpper: number;\n bbLower: number;\n stochK: number;\n stochD: number;\n obRatio: number; // bid/ask volume ratio\n reason: string;\n}\n\n/**\n * Analyze a single symbol and return a trading signal\n */\nexport async function analyzeSymbol(symbol: string): Promise {\n const ex = getExchange();\n\n // Fetch 1m candles\n const ohlcv = await ex.fetchOHLCV(symbol, TIMEFRAME, undefined, CANDLE_LIMIT);\n\n const opens = ohlcv.map((c) => c[1] as number);\n const highs = ohlcv.map((c) => c[2] as number);\n const lows = ohlcv.map((c) => c[3] as number);\n const closes = ohlcv.map((c) => c[4] as number);\n\n const lastIdx = closes.length - 1;\n const price = closes[lastIdx];\n\n // --- EMA 200 ---\n const ema = calcEMA(closes, EMA_PERIOD);\n const ema200 = ema[lastIdx];\n\n // --- Bollinger Bands ---\n const bb = calcBollingerBands(closes, BB_PERIOD, BB_STD_DEV);\n const bbUpper = bb.upper[lastIdx];\n const bbLower = bb.lower[lastIdx];\n\n // --- Stochastic ---\n const stoch = calcStochastic(highs, lows, closes, STOCH_K_PERIOD, STOCH_SMOOTH_K, STOCH_D_PERIOD);\n const stochK = stoch.k[lastIdx];\n const stochD = stoch.d[lastIdx];\n const prevStochK = stoch.k[lastIdx - 1];\n const prevStochD = stoch.d[lastIdx - 1];\n\n // --- Order Book Liquidity ---\n const ob = await ex.fetchOrderBook(symbol, ORDERBOOK_DEPTH);\n const bidVol = ob.bids.reduce((sum, [_, vol]) => sum + vol, 0);\n const askVol = ob.asks.reduce((sum, [_, vol]) => sum + vol, 0);\n const obRatio = askVol > 0 ? bidVol / askVol : 1;\n\n // Default result\n const result: AnalysisResult = {\n symbol, signal: null, price, ema200,\n bbUpper, bbLower, stochK, stochD, obRatio,\n reason: \"\",\n };\n\n // ============================================\n // LONG CONDITIONS:\n // 1. Price > EMA 200 (uptrend)\n // 2. Price touches/near Lower Bollinger Band\n // 3. Stochastic %K < 20 (oversold) with bullish crossover (%K crosses above %D)\n // 4. Order book bid/ask ratio > threshold (buying pressure)\n // ============================================\n const nearLowerBB = price <= bbLower * 1.002; // within 0.2% of lower band\n const stochBullishCross = stochK < STOCH_OVERSOLD && prevStochK <= prevStochD && stochK > stochD;\n const longOB = obRatio > ORDERBOOK_RATIO_THRESHOLD;\n\n if (price > ema200 && nearLowerBB && stochBullishCross && longOB) {\n result.signal = \"LONG\";\n result.reason = `Price>${ema200.toFixed(6)} EMA200, near LowerBB=${bbLower.toFixed(6)}, StochK=${stochK.toFixed(1)}<${STOCH_OVERSOLD} cross, OB=${obRatio.toFixed(2)}`;\n return result;\n }\n\n // ============================================\n // SHORT CONDITIONS:\n // 1. Price < EMA 200 (downtrend)\n // 2. Price touches/near Upper Bollinger Band\n // 3. Stochastic %K > 80 (overbought) with bearish crossover (%K crosses below %D)\n // 4. Order book bid/ask ratio < inverse threshold (selling pressure)\n // ============================================\n const nearUpperBB = price >= bbUpper * 0.998; // within 0.2% of upper band\n const stochBearishCross = stochK > STOCH_OVERBOUGHT && prevStochK >= prevStochD && stochK < stochD;\n const shortOB = obRatio < (1 / ORDERBOOK_RATIO_THRESHOLD);\n\n if (price < ema200 && nearUpperBB && stochBearishCross && shortOB) {\n result.signal = \"SHORT\";\n result.reason = `Price<${ema200.toFixed(6)} EMA200, near UpperBB=${bbUpper.toFixed(6)}, StochK=${stochK.toFixed(1)}>${STOCH_OVERBOUGHT} cross, OB=${obRatio.toFixed(2)}`;\n return result;\n }\n\n result.reason = \"No signal\";\n return result;\n}\n\n/**\n * Scan all configured symbols for signals\n */\nexport async function scanAllSymbols(): Promise {\n const results: AnalysisResult[] = [];\n\n for (const symbol of SYMBOLS) {\n try {\n const r = await analyzeSymbol(symbol);\n results.push(r);\n } catch (err: any) {\n console.error(`Error analyzing ${symbol}: ${err.message}`);\n }\n }\n\n return results;\n}\n",[160],"14a5e7de-5aa5-11f1-818e-ee650bb23af1","indicators.ts","14a5e888-5aa5-11f1-818e-ee650bb23af1",3,["D",1779980048760],"// ============================================\n// INDICATORS — EMA, Bollinger Bands, Stochastic\n// ============================================\n\n/**\n * Calculate EMA (Exponential Moving Average)\n * @param closes - array of closing prices\n * @param period - EMA period\n * @returns array of EMA values (same length as input, early values are SMA-seeded)\n */\nexport function calcEMA(closes: number[], period: number): number[] {\n if (closes.length < period) return [];\n\n const ema: number[] = [];\n const multiplier = 2 / (period + 1);\n\n // Seed with SMA of first `period` values\n let sum = 0;\n for (let i = 0; i < period; i++) {\n sum += closes[i];\n ema.push(0); // placeholder\n }\n ema[period - 1] = sum / period;\n\n // Calculate EMA from period onwards\n for (let i = period; i < closes.length; i++) {\n const val = (closes[i] - ema[i - 1]) * multiplier + ema[i - 1];\n ema.push(val);\n }\n\n return ema;\n}\n\n/**\n * Calculate Bollinger Bands (SMA-based)\n * @returns { upper, middle, lower } arrays\n */\nexport function calcBollingerBands(\n closes: number[],\n period: number,\n stdDev: number\n): { upper: number[]; middle: number[]; lower: number[] } {\n const upper: number[] = [];\n const middle: number[] = [];\n const lower: number[] = [];\n\n for (let i = 0; i < closes.length; i++) {\n if (i < period - 1) {\n upper.push(0);\n middle.push(0);\n lower.push(0);\n continue;\n }\n\n // SMA\n let sum = 0;\n for (let j = i - period + 1; j <= i; j++) {\n sum += closes[j];\n }\n const sma = sum / period;\n\n // Standard Deviation\n let sqSum = 0;\n for (let j = i - period + 1; j <= i; j++) {\n sqSum += (closes[j] - sma) ** 2;\n }\n const sd = Math.sqrt(sqSum / period);\n\n middle.push(sma);\n upper.push(sma + stdDev * sd);\n lower.push(sma - stdDev * sd);\n }\n\n return { upper, middle, lower };\n}\n\n/**\n * Calculate Stochastic Oscillator\n * @returns { k, d } arrays — smoothed %K and %D\n */\nexport function calcStochastic(\n highs: number[],\n lows: number[],\n closes: number[],\n kPeriod: number,\n smoothK: number,\n dPeriod: number\n): { k: number[]; d: number[] } {\n const rawK: number[] = [];\n\n // Step 1: Raw %K\n for (let i = 0; i < closes.length; i++) {\n if (i < kPeriod - 1) {\n rawK.push(50); // neutral placeholder\n continue;\n }\n let highest = -Infinity;\n let lowest = Infinity;\n for (let j = i - kPeriod + 1; j <= i; j++) {\n if (highs[j] > highest) highest = highs[j];\n if (lows[j] < lowest) lowest = lows[j];\n }\n const range = highest - lowest;\n rawK.push(range === 0 ? 50 : ((closes[i] - lowest) / range) * 100);\n }\n\n // Step 2: Smooth %K (SMA of raw %K)\n const k = smaSmooth(rawK, smoothK);\n\n // Step 3: %D (SMA of smoothed %K)\n const d = smaSmooth(k, dPeriod);\n\n return { k, d };\n}\n\n/**\n * Simple SMA smoothing helper\n */\nfunction smaSmooth(data: number[], period: number): number[] {\n const result: number[] = [];\n for (let i = 0; i < data.length; i++) {\n if (i < period - 1) {\n result.push(data[i]);\n continue;\n }\n let sum = 0;\n for (let j = i - period + 1; j <= i; j++) {\n sum += data[j];\n }\n result.push(sum / period);\n }\n return result;\n}\n",[167],"434460d4-5aa5-11f1-82e9-ee650bb23af1","execution.ts","434461ba-5aa5-11f1-82e9-ee650bb23af1",6,["D",1779980126964],"// ============================================\n// EXECUTION — Order placement, DCA, SL/TP\n// ============================================\nimport { getExchange, getAvailableBalance, setLeverage, setMarginMode } from \"./exchange.ts\";\nimport {\n LEVERAGE, BALANCE_PER_ENTRY_PCT, SL_PCT, RISK_REWARD_RATIO,\n DCA_TRIGGER_PCT, MAX_DCA_ENTRIES, MAX_CONCURRENT_POSITIONS,\n} from \"./config.ts\";\nimport {\n getOpenPositions, countOpenPositions, hasOpenPosition,\n insertPosition, updatePositionDCA, closePosition,\n} from \"./database.ts\";\nimport { Signal } from \"./strategy.ts\";\n\n/**\n * Calculate SL and TP prices based on entry and side.\n * SL = SL_PCT from entry (1.5%)\n * TP = SL_PCT * RISK_REWARD_RATIO from entry (1.5% * 1.5 = 2.25%)\n */\nfunction calcSLTP(entryPrice: number, side: \"LONG\" | \"SHORT\") {\n const slDist = entryPrice * SL_PCT;\n const tpDist = slDist * RISK_REWARD_RATIO;\n\n if (side === \"LONG\") {\n return {\n sl: entryPrice - slDist,\n tp: entryPrice + tpDist,\n };\n } else {\n return {\n sl: entryPrice + slDist,\n tp: entryPrice - tpDist,\n };\n }\n}\n\n/**\n * Place SL and TP orders on the exchange\n * Returns { slOrderId, tpOrderId }\n */\nasync function placeSLTP(\n symbol: string,\n side: \"LONG\" | \"SHORT\",\n quantity: number,\n sl: number,\n tp: number\n) {\n const ex = getExchange();\n const closeSide = side === \"LONG\" ? \"sell\" : \"buy\";\n\n // Stop Loss — stop market order\n const slOrder = await ex.createOrder(symbol, \"STOP_MARKET\", closeSide, quantity, undefined, {\n stopPrice: ex.priceToPrecision(symbol, sl),\n reduceOnly: true,\n });\n\n // Take Profit — take profit market order\n const tpOrder = await ex.createOrder(symbol, \"TAKE_PROFIT_MARKET\", closeSide, quantity, undefined, {\n stopPrice: ex.priceToPrecision(symbol, tp),\n reduceOnly: true,\n });\n\n return {\n slOrderId: slOrder.id,\n tpOrderId: tpOrder.id,\n };\n}\n\n/**\n * Cancel existing SL/TP orders for a symbol\n */\nasync function cancelOrders(symbol: string, orderIds: string[]) {\n const ex = getExchange();\n for (const id of orderIds) {\n if (!id) continue;\n try {\n await ex.cancelOrder(id, symbol);\n } catch (e: any) {\n // Order might already be filled/cancelled\n console.warn(`Cancel order ${id} warning: ${e.message}`);\n }\n }\n}\n\n/**\n * Execute a new trade entry\n */\nexport async function executeEntry(\n symbol: string,\n signal: Signal,\n reason: string\n): Promise {\n if (!signal) return null;\n\n // Check max positions\n const openCount = await countOpenPositions();\n if (openCount >= MAX_CONCURRENT_POSITIONS) {\n console.log(`Max ${MAX_CONCURRENT_POSITIONS} positions reached, skipping ${symbol}`);\n return null;\n }\n\n // Check if already in this symbol\n if (await hasOpenPosition(symbol)) {\n console.log(`Already have position in ${symbol}, skipping`);\n return null;\n }\n\n const ex = getExchange();\n\n // Set leverage and margin mode\n await setLeverage(symbol, LEVERAGE);\n await setMarginMode(symbol);\n\n // Calculate position size: 25% of available balance * leverage\n const balance = await getAvailableBalance();\n const notional = balance * BALANCE_PER_ENTRY_PCT * LEVERAGE;\n\n // Get current price for qty calculation\n const ticker = await ex.fetchTicker(symbol);\n const price = ticker.last!;\n const quantity = parseFloat(ex.amountToPrecision(symbol, notional / price));\n\n if (quantity <= 0) {\n console.log(`Quantity too small for ${symbol}, balance=$${balance.toFixed(2)}`);\n return null;\n }\n\n // Place market order\n const side = signal === \"LONG\" ? \"buy\" : \"sell\";\n const order = await ex.createOrder(symbol, \"market\", side, quantity);\n const entryPrice = order.average || price;\n\n console.log(`✅ ${signal} ${symbol} @ ${entryPrice} qty=${quantity} | ${reason}`);\n\n // Calculate and place SL/TP\n const { sl, tp } = calcSLTP(entryPrice, signal);\n const { slOrderId, tpOrderId } = await placeSLTP(symbol, signal, quantity, sl, tp);\n\n // Save to database\n await insertPosition({\n symbol,\n side: signal,\n entry_price: entryPrice,\n quantity,\n sl_price: sl,\n tp_price: tp,\n sl_order_id: slOrderId,\n tp_order_id: tpOrderId,\n });\n\n return `${signal} ${symbol} @ ${entryPrice} | SL=${sl.toFixed(6)} TP=${tp.toFixed(6)}`;\n}\n\n/**\n * Check and execute DCA for all open positions.\n * If price has moved 0.7% against entry, add a second entry.\n */\nexport async function manageDCA() {\n const ex = getExchange();\n const positions = await getOpenPositions();\n\n for (const pos of positions) {\n const p = pos as any;\n if (p.dca_count >= MAX_DCA_ENTRIES) continue;\n\n // Get current price\n const ticker = await ex.fetchTicker(p.symbol);\n const currentPrice = ticker.last!;\n\n // Check if price moved 0.7% against us\n let shouldDCA = false;\n if (p.side === \"LONG\") {\n shouldDCA = currentPrice <= p.entry_price * (1 - DCA_TRIGGER_PCT);\n } else {\n shouldDCA = currentPrice >= p.entry_price * (1 + DCA_TRIGGER_PCT);\n }\n\n if (!shouldDCA) continue;\n\n console.log(`🔄 DCA triggered for ${p.symbol} (${p.side}) — price moved ${(DCA_TRIGGER_PCT * 100).toFixed(1)}% against entry`);\n\n try {\n // Calculate DCA size (another 25% of current balance)\n const balance = await getAvailableBalance();\n const notional = balance * BALANCE_PER_ENTRY_PCT * LEVERAGE;\n const dcaQty = parseFloat(ex.amountToPrecision(p.symbol, notional / currentPrice));\n\n if (dcaQty <= 0) {\n console.log(`DCA quantity too small for ${p.symbol}`);\n continue;\n }\n\n // Place DCA market order\n const side = p.side === \"LONG\" ? \"buy\" : \"sell\";\n const dcaOrder = await ex.createOrder(p.symbol, \"market\", side, dcaQty);\n const dcaPrice = dcaOrder.average || currentPrice;\n\n // Recalculate average price\n // avgPrice = (oldQty * oldAvg + dcaQty * dcaPrice) / totalQty\n const totalQty = p.quantity + dcaQty;\n const newAvgPrice = (p.quantity * p.avg_price + dcaQty * dcaPrice) / totalQty;\n\n // Recalculate SL/TP from new average price\n const { sl, tp } = calcSLTP(newAvgPrice, p.side);\n\n // Cancel old SL/TP orders\n await cancelOrders(p.symbol, [p.sl_order_id, p.tp_order_id]);\n\n // Place new SL/TP with updated levels and total quantity\n const { slOrderId, tpOrderId } = await placeSLTP(p.symbol, p.side, totalQty, sl, tp);\n\n // Update database\n await updatePositionDCA(p.symbol, newAvgPrice, totalQty, sl, tp, slOrderId, tpOrderId);\n\n console.log(`✅ DCA ${p.side} ${p.symbol} @ ${dcaPrice} | New Avg=${newAvgPrice.toFixed(6)} SL=${sl.toFixed(6)} TP=${tp.toFixed(6)}`);\n } catch (err: any) {\n console.error(`DCA error for ${p.symbol}: ${err.message}`);\n }\n }\n}\n\n/**\n * Sync positions with exchange — detect closed trades (SL/TP hit)\n */\nexport async function syncPositions() {\n const ex = getExchange();\n const dbPositions = await getOpenPositions();\n\n // Fetch actual exchange positions\n const exchangePositions = await ex.fetchPositions();\n const activeSymbols = new Set(\n exchangePositions\n .filter((p) => p.contracts && p.contracts > 0)\n .map((p) => p.symbol)\n );\n\n for (const pos of dbPositions) {\n const p = pos as any;\n if (!activeSymbols.has(p.symbol)) {\n // Position was closed on exchange (SL or TP hit)\n // Estimate PnL based on which side was closer\n const ticker = await ex.fetchTicker(p.symbol);\n const lastPrice = ticker.last!;\n\n // Simple PnL estimate\n let pnl: number;\n if (p.side === \"LONG\") {\n pnl = (lastPrice - p.avg_price) * p.quantity;\n } else {\n pnl = (p.avg_price - lastPrice) * p.quantity;\n }\n\n await closePosition(p.symbol, lastPrice, pnl);\n console.log(`📊 Position closed: ${p.symbol} PnL=$${pnl.toFixed(4)}`);\n }\n }\n}\n",[174],"0ab4a602-5aa5-11f1-82e9-ee650bb23af1","exchange.ts","0ab4a6de-5aa5-11f1-82e9-ee650bb23af1",2,["D",1779980031732],"// ============================================\n// EXCHANGE — Initialize CCXT Binance connection\n// ============================================\nimport ccxt from \"npm:ccxt@4\";\n\nlet _exchange: ccxt.binanceusdm | null = null;\n\n/**\n * Get or create the Binance USDM Futures exchange instance.\n * Uses env vars for credentials. Mainnet mode.\n */\nexport function getExchange(): ccxt.binanceusdm {\n if (_exchange) return _exchange;\n\n const apiKey = Deno.env.get(\"BINANCE_API_KEY\");\n const secret = Deno.env.get(\"BINANCE_SECRET_KEY\");\n\n if (!apiKey || !secret) {\n throw new Error(\"Missing BINANCE_API_KEY or BINANCE_SECRET_KEY env vars\");\n }\n\n _exchange = new ccxt.binanceusdm({\n apiKey,\n secret,\n enableRateLimit: true,\n options: {\n defaultType: \"future\",\n adjustForTimeDifference: true,\n },\n });\n\n // MAINNET — real trading\n _exchange.setSandboxMode(false);\n\n return _exchange;\n}\n\n/**\n * Fetch USDT futures balance\n */\nexport async function getAvailableBalance(): Promise {\n const ex = getExchange();\n const balance = await ex.fetchBalance({ type: \"future\" });\n return parseFloat(balance.free?.USDT?.toString() || \"0\");\n}\n\n/**\n * Fetch all open positions\n */\nexport async function getOpenPositions() {\n const ex = getExchange();\n const positions = await ex.fetchPositions();\n return positions.filter(\n (p) => p.contracts && p.contracts > 0\n );\n}\n\n/**\n * Set leverage for a symbol\n */\nexport async function setLeverage(symbol: string, leverage: number) {\n const ex = getExchange();\n try {\n await ex.setLeverage(leverage, symbol);\n } catch (e: any) {\n // Some pairs may already have the leverage set\n if (!e.message?.includes(\"No need to change leverage\")) {\n console.warn(`Leverage warning for ${symbol}: ${e.message}`);\n }\n }\n}\n\n/**\n * Set margin mode to cross\n */\nexport async function setMarginMode(symbol: string) {\n const ex = getExchange();\n try {\n await ex.setMarginMode(\"cross\", symbol);\n } catch (e: any) {\n if (!e.message?.includes(\"No need to change margin type\")) {\n console.warn(`Margin mode warning for ${symbol}: ${e.message}`);\n }\n }\n}\n",[181],"2d48ec82-5aa5-11f1-bae2-ee650bb23af1","database.ts","2d48ed22-5aa5-11f1-bae2-ee650bb23af1",5,["D",1779980090091],"// ============================================\n// DATABASE — SQLite state for positions & trades\n// ============================================\nimport { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\n/**\n * Initialize database tables (idempotent)\n */\nexport async function initDB() {\n await sqlite.batch([\n {\n sql: `CREATE TABLE IF NOT EXISTS positions (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n symbol TEXT NOT NULL,\n side TEXT NOT NULL, -- 'LONG' or 'SHORT'\n entry_price REAL NOT NULL,\n avg_price REAL NOT NULL, -- updated after DCA\n quantity REAL NOT NULL, -- total quantity\n sl_price REAL NOT NULL,\n tp_price REAL NOT NULL,\n dca_count INTEGER DEFAULT 0, -- 0=first entry, 1=DCA triggered\n dca_order_id TEXT,\n sl_order_id TEXT,\n tp_order_id TEXT,\n status TEXT DEFAULT 'OPEN', -- 'OPEN', 'CLOSED'\n pnl REAL,\n opened_at TEXT DEFAULT (datetime('now')),\n closed_at TEXT\n )`,\n },\n {\n sql: `CREATE TABLE IF NOT EXISTS trade_log (\n id INTEGER PRIMARY KEY AUTOINCREMENT,\n symbol TEXT NOT NULL,\n side TEXT NOT NULL,\n entry_price REAL,\n exit_price REAL,\n quantity REAL,\n pnl REAL,\n result TEXT, -- 'WIN' or 'LOSS'\n closed_at TEXT DEFAULT (datetime('now'))\n )`,\n },\n ]);\n}\n\n/**\n * Get all open positions\n */\nexport async function getOpenPositions() {\n const result = await sqlite.execute(\n \"SELECT * FROM positions WHERE status = 'OPEN'\"\n );\n return result.rows;\n}\n\n/**\n * Count open positions\n */\nexport async function countOpenPositions(): Promise {\n const result = await sqlite.execute(\n \"SELECT COUNT(*) as cnt FROM positions WHERE status = 'OPEN'\"\n );\n return (result.rows[0] as any).cnt;\n}\n\n/**\n * Check if we already have an open position for a symbol\n */\nexport async function hasOpenPosition(symbol: string): Promise {\n const result = await sqlite.execute({\n sql: \"SELECT COUNT(*) as cnt FROM positions WHERE symbol = ? AND status = 'OPEN'\",\n args: [symbol],\n });\n return (result.rows[0] as any).cnt > 0;\n}\n\n/**\n * Insert a new position\n */\nexport async function insertPosition(pos: {\n symbol: string;\n side: string;\n entry_price: number;\n quantity: number;\n sl_price: number;\n tp_price: number;\n sl_order_id?: string;\n tp_order_id?: string;\n}) {\n await sqlite.execute({\n sql: `INSERT INTO positions (symbol, side, entry_price, avg_price, quantity, sl_price, tp_price, sl_order_id, tp_order_id)\n VALUES (?, ?, ?, ?, ?, ?, ?, ?, ?)`,\n args: [\n pos.symbol, pos.side, pos.entry_price, pos.entry_price,\n pos.quantity, pos.sl_price, pos.tp_price,\n pos.sl_order_id || null, pos.tp_order_id || null,\n ],\n });\n}\n\n/**\n * Update position after DCA (recalculated avg price, new SL/TP, updated qty)\n */\nexport async function updatePositionDCA(\n symbol: string,\n newAvgPrice: number,\n newQty: number,\n newSL: number,\n newTP: number,\n slOrderId: string,\n tpOrderId: string\n) {\n await sqlite.execute({\n sql: `UPDATE positions \n SET avg_price = ?, quantity = ?, sl_price = ?, tp_price = ?,\n sl_order_id = ?, tp_order_id = ?, dca_count = 1\n WHERE symbol = ? AND status = 'OPEN'`,\n args: [newAvgPrice, newQty, newSL, newTP, slOrderId, tpOrderId, symbol],\n });\n}\n\n/**\n * Close a position and log the trade\n */\nexport async function closePosition(symbol: string, exitPrice: number, pnl: number) {\n // Get the position details first\n const res = await sqlite.execute({\n sql: \"SELECT * FROM positions WHERE symbol = ? AND status = 'OPEN'\",\n args: [symbol],\n });\n\n if (res.rows.length === 0) return;\n const pos = res.rows[0] as any;\n\n // Mark as closed\n await sqlite.execute({\n sql: \"UPDATE positions SET status = 'CLOSED', pnl = ?, closed_at = datetime('now') WHERE id = ?\",\n args: [pnl, pos.id],\n });\n\n // Log to trade history\n await sqlite.execute({\n sql: `INSERT INTO trade_log (symbol, side, entry_price, exit_price, quantity, pnl, result)\n VALUES (?, ?, ?, ?, ?, ?, ?)`,\n args: [\n pos.symbol, pos.side, pos.avg_price, exitPrice,\n pos.quantity, pnl, pnl >= 0 ? \"WIN\" : \"LOSS\",\n ],\n });\n}\n\n/**\n * Get recent closed trades\n */\nexport async function getRecentTrades(limit = 10) {\n const result = await sqlite.execute({\n sql: \"SELECT * FROM trade_log ORDER BY closed_at DESC LIMIT ?\",\n args: [limit],\n });\n return result.rows;\n}\n",[188],"0375ee6e-5aa5-11f1-82e9-ee650bb23af1","config.ts","0375ef40-5aa5-11f1-82e9-ee650bb23af1",1,["D",1779980019904],"// ============================================\n// CONFIGURATION — All bot settings in one place\n// ============================================\n\n// --- Trading Pairs (low-price, high-volume futures) ---\nexport const SYMBOLS = [\n \"1000PEPE/USDT:USDT\",\n \"DOGE/USDT:USDT\",\n \"1000FLOKI/USDT:USDT\",\n \"1000SHIB/USDT:USDT\",\n \"1000BONK/USDT:USDT\",\n];\n\n// --- Leverage & Position Sizing ---\nexport const LEVERAGE = 20;\nexport const BALANCE_PER_ENTRY_PCT = 0.25; // 25% of available balance per entry\nexport const MAX_CONCURRENT_POSITIONS = 4;\n\n// --- DCA Settings ---\nexport const DCA_TRIGGER_PCT = 0.007; // 0.7% adverse move triggers DCA\nexport const MAX_DCA_ENTRIES = 1; // Only 1 DCA (second entry)\n\n// --- Risk-to-Reward ---\nexport const RISK_REWARD_RATIO = 1.5; // 1:1.5 R:R\nexport const SL_PCT = 0.015; // 1.5% stop loss from entry (before leverage)\n\n// --- Indicator Settings ---\nexport const EMA_PERIOD = 200;\nexport const BB_PERIOD = 20;\nexport const BB_STD_DEV = 2;\nexport const STOCH_K_PERIOD = 5;\nexport const STOCH_SMOOTH_K = 3;\nexport const STOCH_D_PERIOD = 3;\nexport const STOCH_OVERSOLD = 20;\nexport const STOCH_OVERBOUGHT = 80;\n\n// --- Order Book ---\nexport const ORDERBOOK_DEPTH = 20;\nexport const ORDERBOOK_RATIO_THRESHOLD = 1.3; // bid/ask ratio > 1.3 for long, < 0.77 for short\n\n// --- Timeframe ---\nexport const TIMEFRAME = \"1m\";\nexport const CANDLE_LIMIT = 250; // enough for EMA 200\n\n// --- Telegram ---\nexport const TELEGRAM_REPORT_INTERVAL_MS = 5 * 60 * 1000; // 5 minutes\n",[195],"54c5647a-5aa5-11f1-bb46-ee650bb23af1","bot-loop.ts","54c5652e-5aa5-11f1-bb46-ee650bb23af1",8,["D",1779980156323],"// ============================================\n// BOT LOOP — Main execution cycle (every 60s)\n// Scans markets, enters trades, manages DCA,\n// syncs closed positions\n// ============================================\nimport { initDB } from \"./database.ts\";\nimport { scanAllSymbols } from \"./strategy.ts\";\nimport { executeEntry, manageDCA, syncPositions } from \"./execution.ts\";\nimport { notifyEntry, sendTelegram } from \"./telegram.ts\";\n\nexport default async function (interval: Interval) {\n try {\n // Initialize database tables on first run\n await initDB();\n\n console.log(`🔄 Bot cycle started at ${new Date().toISOString()}`);\n\n // Step 1: Sync positions with exchange (detect SL/TP hits)\n await syncPositions();\n\n // Step 2: Manage DCA for existing positions\n await manageDCA();\n\n // Step 3: Scan all symbols for new entry signals\n const signals = await scanAllSymbols();\n\n for (const analysis of signals) {\n if (analysis.signal) {\n console.log(`📡 Signal: ${analysis.signal} ${analysis.symbol} | ${analysis.reason}`);\n\n try {\n const result = await executeEntry(analysis.symbol, analysis.signal, analysis.reason);\n if (result) {\n await notifyEntry(result);\n }\n } catch (err: any) {\n console.error(`❌ Entry error for ${analysis.symbol}: ${err.message}`);\n await sendTelegram(`❌ Entry failed: ${analysis.symbol}\\n${err.message}`);\n }\n }\n }\n\n console.log(`✅ Bot cycle complete. Scanned ${signals.length} pairs.`);\n } catch (err: any) {\n console.error(`🔥 Bot loop error: ${err.message}`);\n try {\n await sendTelegram(`🔥 *BOT ERROR*\\n${err.message}`);\n } catch {\n // Telegram might also be down\n }\n }\n}\n",[202],"61ff2950-5aa5-11f1-8431-ee650bb23af1",["D",1779980178527],[33],"pulls","branches","forks","envVars",{"_218":64,"_220":64},"connections",{"_218":64,"_219":64},"count","unfilledCount","emptyCount",{"_46":208,"_37":33,"_35":36,"_142":-5,"_44":45,"_43":14,"_144":145,"_41":259,"_13":64,"_38":26,"_39":40,"_29":30,"_149":-5,"_232":260,"_32":261},{"_46":201,"_37":202,"_35":203,"_142":-5,"_44":45,"_43":204,"_144":145,"_41":256,"_13":64,"_38":156,"_39":206,"_29":30,"_149":-5,"_232":257,"_32":258},{"_46":194,"_37":195,"_35":196,"_142":-5,"_44":45,"_43":197,"_144":145,"_41":253,"_13":64,"_38":147,"_39":199,"_29":30,"_149":-5,"_232":254,"_32":255},{"_46":187,"_37":188,"_35":189,"_142":-5,"_44":45,"_43":190,"_144":145,"_41":250,"_13":64,"_38":147,"_39":192,"_29":30,"_149":-5,"_232":251,"_32":252},{"_46":180,"_37":181,"_35":182,"_142":-5,"_44":45,"_43":183,"_144":145,"_41":247,"_13":64,"_38":147,"_39":185,"_29":30,"_149":-5,"_232":248,"_32":249},{"_46":173,"_37":174,"_35":175,"_142":-5,"_44":45,"_43":176,"_144":145,"_41":244,"_13":64,"_38":147,"_39":178,"_29":30,"_149":-5,"_232":245,"_32":246},{"_46":166,"_37":167,"_35":168,"_142":-5,"_44":45,"_43":169,"_144":145,"_41":241,"_13":64,"_38":147,"_39":171,"_29":30,"_149":-5,"_232":242,"_32":243},{"_46":159,"_37":160,"_35":161,"_142":-5,"_44":45,"_43":162,"_144":145,"_41":238,"_13":64,"_38":147,"_39":164,"_29":30,"_149":-5,"_232":239,"_32":240},{"_46":151,"_37":152,"_35":153,"_142":-5,"_44":45,"_43":154,"_144":145,"_41":235,"_13":64,"_38":156,"_39":157,"_29":30,"_149":-5,"_232":236,"_32":237},{"_46":139,"_37":140,"_35":141,"_142":-5,"_44":45,"_43":143,"_144":145,"_41":231,"_13":64,"_38":147,"_39":148,"_29":30,"_149":-5,"_232":233,"_32":234},["D",1779980145001],"children",[],[140],["D",1779980160367],[],[152],["D",1779980070863],[],[160],["D",1779980048760],[],[167],["D",1779980126964],[],[174],["D",1779980031732],[],[181],["D",1779980090091],[],[188],["D",1779980019904],[],[195],["D",1779980156323],[],[202],["D",1779980178527],[],[33],["D",1779980005182],["D",1789495880338],{"_100":99,"_107":102},{"_100":99,"_101":102,"_103":102,"_19":58,"_104":105,"_106":30},{"_13":14,"_37":90,"_46":45,"_91":47,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":48,"_98":99},"ctx",{"_83":-5,"_126":300,"_301":302,"_303":304,"_305":30,"_306":30,"_307":30,"_308":145,"_309":-5,"_310":-7,"_311":-7,"_312":64,"_313":30,"_314":30,"_315":-5,"_316":30,"_317":30,"_318":30,"_319":-5},"ENV",{"_271":272,"_273":274,"_275":90,"_276":277,"_278":279,"_280":281,"_282":283,"_284":285,"_286":287,"_288":289,"_290":291,"_292":293,"_294":295,"_296":297,"_298":299},"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"]

Diff · v10