Paragon MM

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_157":158,"_159":160},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_18":19,"_17":-7,"_118":-5,"_20":119,"_22":120,"_121":122,"_123":124,"_25":125,"_24":-5,"_126":-5,"_127":-5,"_128":53,"_129":130,"_131":44,"_132":-5,"_133":-5,"_134":135},"routes/_app.x.$handle.$name.branch.$branch.code.$",{"_11":12,"_13":14,"_15":16,"_17":-7,"_18":19,"_20":21,"_22":23,"_24":-7,"_25":26,"_27":-5,"_28":-5,"_29":-5,"_30":-5,"_31":-5},"handle","ziggyware","name","gemini-exchange-working-bot","branchName","main","version","path","","project",{"_33":61,"_13":14,"_45":62,"_63":-5,"_64":53,"_65":66,"_67":66,"_68":-5,"_69":-5,"_70":71,"_72":-5,"_73":53,"_74":-5,"_75":-5,"_76":77,"_78":79,"_80":81,"_82":83,"_84":85,"_86":-5,"_87":88,"_89":88,"_90":91,"_92":91,"_93":91,"_94":88,"_95":88,"_96":97,"_98":99,"_100":101,"_102":53},"tree",[56],"file","contents",[32],"upstream","pull","ahead","behind","envVars",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_18":55},"id","0b6ae0ca-55eb-11f1-8b42-ee650bb23af1","main.ts","fileId","031b4c6e-2582-11f1-bf1f-42dde27851f2","parentId","branchId","031836aa-2582-11f1-bf1f-42dde27851f2","branchVersion",67,"latest",true,"createdAt",["D",1779460342231],66,"fileType","http","content","/*\n * PARAGON MM — Gemini Market Maker\n * Single-file Val Town deployment\n *\n * SETUP:\n * 1. Create a new val on val.town\n * 2. Set type to HTTP\n * 3. Paste this entire file\n * 4. Open the val URL in your browser\n * 5. Enter Gemini API key/secret in the Config tab\n * 6. Click Start or Single Cycle\n *\n * Strategy: Avellaneda-Stoikov passive market making\n * - maker-or-cancel limits on both sides of mid (0.1% maker fee)\n * - inventory skew to mean-revert position\n * - volatility-adaptive spread widening\n * - fee floor: never tighter than 2x maker fee\n * - kill switch on 5 consecutive errors\n */\n\n// ============================================================\n// GEMINI CLIENT (factory, no class)\n// ============================================================\n\nconst GEMINI_PROD = \"https://api.gemini.com\";\nconst GEMINI_SANDBOX = \"https://api.sandbox.gemini.com\";\nlet lastNonce = 0;\nlet nonce = 0;\n\nfunction sleep(ms: number): Promise {\n return new Promise(resolve => setTimeout(resolve, ms));\n}\nasync function nonced(){\n if(nonce === 0 || nonce == lastNonce){\n nonce = parseFloat(Date.now().toString());\n }\n \n while(nonce === lastNonce)\n {\n await sleep(10);\n nonce = parseFloat(Date.now().toString());\n }\n \n lastNonce = nonce;\n \n return nonce;\n}\nasync function createGeminiClient(apiKey: string, apiSecret: string, sandbox: boolean) {\n const base = sandbox ? GEMINI_SANDBOX : GEMINI_PROD;\n\n async function signed(endpoint: string, extra: Record = {}) {\n \n const payload = JSON.stringify({ request: endpoint, nonce: await nonced(), ...extra });\n const b64 = btoa(payload);\n const enc = new TextEncoder();\n const key = await crypto.subtle.importKey(\"raw\", enc.encode(apiSecret), { name: \"HMAC\", hash: \"SHA-384\" }, false, [\"sign\"]);\n const sig = await crypto.subtle.sign(\"HMAC\", key, enc.encode(b64));\n const hex = Array.from(new Uint8Array(sig)).map(b => b.toString(16).padStart(2, \"0\")).join(\"\");\n\n const r = await fetch(`${base}${endpoint}`, {\n method: \"POST\",\n headers: {\n \"Content-Type\": \"text/plain\",\n \"X-GEMINI-APIKEY\": apiKey,\n \"X-GEMINI-PAYLOAD\": b64,\n \"X-GEMINI-SIGNATURE\": hex,\n \"Cache-Control\": \"no-cache\",\n },\n });\n if (!r.ok) throw new Error(`Gemini ${endpoint} [${r.status}]: ${await r.text()}`);\n return await r.json();\n }\n return {\n ticker: async (sym: string) => { const r = await fetch(`${base}/v1/pubticker/${sym}`); if (!r.ok) throw new Error(`${r.status}`); return await r.json(); },\n book: async (sym: string, n = 5) => { const r = await fetch(`${base}/v1/book/${sym}?limit_bids=${n}&limit_asks=${n}`); if (!r.ok) throw new Error(`${r.status}`); return await r.json(); },\n balances: async () => await signed(\"/v1/balances\"),\n orders: async () => await signed(\"/v1/orders\"),\n newOrder: async (sym: string, amt: string, price: string, side: \"buy\" | \"sell\", opts = [\"maker-or-cancel\"]) =>\n await signed(\"/v1/order/new\", { symbol: sym, amount: amt, price, side, type: \"exchange limit\", options: opts }),\n cancelAll: async() => await signed(\"/v1/order/cancel/all\"),\n };\n}\n\n// ============================================================\n// STATE (module-level singleton)\n// ============================================================\n\ninterface Cfg { apiKey: string; apiSecret: string; sandbox: boolean; symbol: string; orderSize: string; spreadBps: number; maxInv: number; skewFactor: number; intervalSec: number; }\ninterface LogE { ts: number; msg: string; }\ninterface Cycle { ts: number; mid: number; spread: number; bp: number; ap: number; inv: number; vol: number; bs: string; as: string; }\n\nconst cfg: Cfg = { apiKey: Deno.env.get(\"GEMINI_API_KEY\"), apiSecret: Deno.env.get(\"GEMINI_API_SECRET\"), sandbox: Deno.env.get(\"GEMINI_TEST\").toString()===\"true\", symbol: \"btcusd\", orderSize: \"0.0001\", spreadBps: 20, maxInv: 0.005, skewFactor: 0.5, intervalSec: 15 };\nconst logs: LogE[] = [];\nconst cycles: Cycle[] = [];\nconst mids: number[] = [];\nlet running = false;\nlet timer: any = null;\nlet errCount = 0;\nasync function log(msg: string)\n{\n await Promise.resolve();\n logs.push({ ts: Date.now(), msg }); if (logs.length > 200) logs.shift();\n}\n\n// ============================================================\n// MARKET MAKER\n// ============================================================\n\nfunction qd(sym: string) { return ({ btcusd: 2, ethusd: 2, solusd: 2, dogeusd: 5, ltcusd: 2 } as any)[sym] ?? 2; }\nfunction bd(sym: string) { return ({ btcusd: 6, ethusd: 6, solusd: 4, dogeusd: 0, ltcusd: 5 } as any)[sym] ?? 6; }\n\nfunction volMult(): number {\n if (mids.length < 5) return 1;\n const ret: number[] = [];\n for (let i = 1; i < mids.length; i++) ret.push(Math.log(mids[i] / mids[i - 1]));\n const m = ret.reduce((a, b) => a + b, 0) / ret.length;\n const v = ret.reduce((a, r) => a + (r - m) ** 2, 0) / ret.length;\n return Math.max(0.8, Math.min(3, Math.sqrt(v) / 0.001));\n}\n\nasync function cycle() {\n const c = await createGeminiClient(cfg.apiKey, cfg.apiSecret, cfg.sandbox);\n const [bk, tk] = await Promise.all([c.book(cfg.symbol, 3), c.ticker(cfg.symbol)]);\n const bb = parseFloat(bk.bids?.[0]?.price || \"0\");\n const ba = parseFloat(bk.asks?.[0]?.price || \"0\");\n const mid = (bb + ba) / 2;\n if (mid <= 0) { await log(\"Invalid mid, skip.\"); return; }\n\n mids.push(mid); if (mids.length > 30) mids.shift();\n const vm = volMult();\n\n let inv = 0;\n try {\n const bals = await c.balances();\n const base = cfg.symbol.replace(/usd$/i, \"\").toUpperCase();\n const f = bals.find((b: any) => b.currency.toUpperCase() === base);\n inv = parseFloat(f?.available || \"0\");\n } catch { await log(\"Balance fetch failed.\"); }\n\n const ir = cfg.maxInv > 0 ? inv / cfg.maxInv : 0;\n const skew = ir * cfg.skewFactor * (cfg.spreadBps / 10000) * mid;\n const hs = (cfg.spreadBps / 10000 / 2) * mid * vm;\n\n let bp = mid - hs - skew;\n let ap = mid + hs - skew;\n const floor = mid * 0.002;\n if ((ap - bp) < floor) { const w = (floor - (ap - bp)) / 2; bp -= w; ap += w; await log(\"Widened to fee floor.\"); }\n\n try { await c.cancelAll(); } catch (e: any) { await log(`Cancel: ${e.message}`); }\n\n const amt = parseFloat(cfg.orderSize).toFixed(bd(cfg.symbol));\n const bps = bp.toFixed(qd(cfg.symbol));\n const aps = ap.toFixed(qd(cfg.symbol));\n\n let bs = \"—\", as_ = \"—\";\n\n if (inv < cfg.maxInv) {\n try {\n const o = await c.newOrder(cfg.symbol, amt, bps, \"buy\");\n bs = o.is_live ? \"live\" : o.is_cancelled ? \"moc-rej\" : \"filled\";\n await log(`BID ${amt} @ ${bps} → ${bs}`);\n } catch (e: any) { bs = \"err\"; await log(`BID err: ${e.message}`); }\n }\n\n if (inv > 0) {\n const sa = Math.min(parseFloat(cfg.orderSize), inv).toFixed(bd(cfg.symbol));\n try {\n const o = await c.newOrder(cfg.symbol, sa, aps, \"sell\");\n as_ = o.is_live ? \"live\" : o.is_cancelled ? \"moc-rej\" : \"filled\";\n await log(`ASK ${sa} @ ${aps} → ${as_}`);\n } catch (e: any) { as_ = \"err\"; await log(`ASK err: ${e.message}`); }\n } else { await log(\"No base to sell.\"); }\n\n cycles.push({ ts: Date.now(), mid, spread: ap - bp, bp, ap, inv, vol: vm, bs, as: as_ });\n if (cycles.length > 100) cycles.shift();\n}\n\nasync function safeCycle() {\n try { await cycle(); errCount = 0; }\n catch (e: any) {\n errCount++;\n await log(`Cycle err #${errCount}: ${e.message}`);\n if (errCount >= 5) { await log(\"KILL SWITCH.\"); await stopEngine(); try { const c = await createGeminiClient(cfg.apiKey, cfg.apiSecret, cfg.sandbox); await c.cancelAll(); } catch {} }\n }\n}\n\nasync function startEngine() { running = true; errCount = 0; await log(`Engine ON — ${cfg.intervalSec}s`); await safeCycle(); timer = setInterval(safeCycle, cfg.intervalSec * 1000); }\nasync function stopEngine() { if (timer) { clearInterval(timer); timer = null; } running = false; await log(\"Engine OFF.\"); }\n\n// ============================================================\n// HTTP HANDLER\n// ============================================================\n\nexport default async function(req: Request): Promise {\n const url = new URL(req.url);\n const p = url.pathname;\n\n // API routes\n if (p === \"/api/state\") return Response.json({ cfg: { ...cfg, apiKey: cfg.apiKey ? \"***\" : \"\", apiSecret: cfg.apiSecret ? \"***\" : \"\" }, running, logs, cycles });\n if (p === \"/api/config\" && req.method === \"POST\") { const b = await req.json(); Object.assign(cfg, b); return Response.json({ ok: true }); }\n if (p === \"/api/start\" && req.method === \"POST\") {\n if (!cfg.apiKey || !cfg.apiSecret) return Response.json({ error: \"API credentials required\" }, { status: 400 });\n await startEngine(); return Response.json({ ok: true });\n }\n if (p === \"/api/stop\" && req.method === \"POST\") { await stopEngine(); return Response.json({ ok: true }); }\n if (p === \"/api/cycle\" && req.method === \"POST\") {\n if (!cfg.apiKey || !cfg.apiSecret) return Response.json({ error: \"API credentials required\" }, { status: 400 });\n try { await cycle(); return Response.json({ ok: true, last: cycles[cycles.length - 1] }); }\n catch (e: any) { return Response.json({ error: e.message }, { status: 500 }); }\n }\n if (p === \"/api/cancel\" && req.method === \"POST\") {\n if (!cfg.apiKey || !cfg.apiSecret) return Response.json({ error: \"Creds required\" }, { status: 400 });\n try { const c = await createGeminiClient(cfg.apiKey, cfg.apiSecret, cfg.sandbox); return Response.json(await c.cancelAll()); }\n catch (e: any) { return Response.json({ error: e.message }, { status: 500 }); }\n }\n if (p === \"/api/balances\") {\n if (!cfg.apiKey || !cfg.apiSecret) return Response.json({ error: \"Creds required\" }, { status: 400 });\n try { const c = await createGeminiClient(cfg.apiKey, cfg.apiSecret, cfg.sandbox); return Response.json(await c.balances()); }\n catch (e: any) { return Response.json({ error: e.message }, { status: 500 }); }\n }\n if (p.startsWith(\"/api/ticker/\")) {\n const sym = p.split(\"/\").pop()!;\n try { const c = await createGeminiClient(cfg.apiKey,cfg.apiSecret, cfg.sandbox); return Response.json(await c.ticker(sym)); }\n catch (e: any) { return Response.json({ error: e.message }, { status: 500 }); }\n }\n if (p.startsWith(\"/api/book/\")) {\n const sym = p.split(\"/\").pop()!;\n try { const c = await createGeminiClient(cfg.apiKey,cfg.apiSecret, cfg.sandbox); return Response.json(await c.book(sym)); }\n catch (e: any) { return Response.json({ error: e.message }, { status: 500 }); }\n }\n\n // Serve the SPA\n return new Response(HTML, { headers: { \"Content-Type\": \"text/html; charset=utf-8\" } });\n}\n\n// ============================================================\n// INLINE HTML + VANILLA JS DASHBOARD\n// ============================================================\n\nconst HTML = `\n\n\n\nParagon MM\n\n\n\n\n

◆PARAGON MMGemini Market Maker

\n IDLE\n \n

\n \n

Market

Book (Top 3)

—

Controls

\n \n \n \n \n \n

\n \n

Last Cycle

No cycles yet

History

—

Log

—

\n \n \n \n \n

\n\n\n`;","deleted",false,"label",[35],{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":57,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_58":59,"_18":60},["D",1779460342231],"children",[],[35],"0317599c-2582-11f1-bf1f-42dde27851f2",["D",1774137575302],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","imageUrl","userId","2c6d46b0-54dd-11f0-a86c-6fbc2b29331a","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","850db142-aa5e-4914-bceb-1e2e085ae4c5","tursoName","0317599c258211f1bf1f42dde27851f2","tursoHostname","0317599c258211f1bf1f42dde27851f2-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789495880338],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_117":113},"org",{"_11":12,"_111":-5,"_112":113,"_70":71,"_114":115,"_116":53},"branch",{"_17":42,"_13":16,"_33":40,"_103":61,"_104":-5,"_105":-5,"_106":-5,"_107":-5,"_108":-5,"_109":14,"_110":12},"isOwned","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yekJHRDE5SGVoUHUzUENQaXY2MTRkT3h0cncifQ","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_33":61,"_13":14,"_45":152,"_63":-5,"_64":53,"_65":66,"_67":66,"_68":-5,"_69":-5,"_70":71,"_72":-5,"_73":53,"_74":-5,"_75":-5,"_76":77,"_78":79,"_80":81,"_82":83,"_84":153,"_86":-5,"_87":88,"_89":88,"_90":91,"_92":91,"_93":91,"_94":88,"_95":88,"_96":154,"_98":155,"_100":156,"_102":53},[149],"files",[149],"counts",{"_138":77,"_139":140,"_141":77,"_31":142,"_143":144},[136],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":46,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_18":137},[35],"pulls","branches",1,"forks",{"_145":147,"_148":77},"connections",{"_145":77,"_146":77},"count","unfilledCount",3,"emptyCount",{"_33":34,"_13":35,"_36":37,"_38":-5,"_39":40,"_41":42,"_43":44,"_45":57,"_17":47,"_48":49,"_50":51,"_52":53,"_54":-5,"_58":150,"_18":151},[],[35],["D",1774137575302],["D",1789495880338],{"_11":12,"_117":113},{"_11":12,"_111":-5,"_112":113,"_70":71,"_114":115,"_116":53},{"_17":42,"_13":16,"_33":40,"_103":61,"_104":-5,"_105":-5,"_106":-5,"_107":-5,"_108":-5,"_109":14,"_110":12},"ctx",{"_96":-5,"_133":190,"_191":192,"_193":194,"_195":53,"_196":53,"_197":53,"_198":44,"_199":-5,"_200":-7,"_201":-7,"_202":77,"_203":53,"_204":53,"_205":-5,"_206":53,"_207":53,"_208":53,"_209":-5},"ENV",{"_161":162,"_163":164,"_165":16,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189},"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"]

Code