Paragon MM

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_153":154,"_155":156},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_18":19,"_17":-7,"_116":-5,"_20":117,"_22":118,"_119":120,"_121":122,"_25":123,"_24":-5,"_124":-5,"_125":-5,"_126":53,"_127":128,"_129":44,"_130":-5,"_131":-5,"_132":133},"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-bot","branchName","main","version","path","","project",{"_33":61,"_13":14,"_45":62,"_63":-5,"_64":53,"_65":66,"_67":66,"_68":69,"_70":-5,"_71":72,"_73":-5,"_74":53,"_75":-5,"_76":-5,"_77":78,"_79":80,"_81":-5,"_82":-5,"_83":-5,"_84":-5,"_85":86,"_87":86,"_88":89,"_90":89,"_91":89,"_92":86,"_93":86,"_94":95,"_96":97,"_98":99,"_100":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","4d5b4864-256f-11f1-962d-42dde27851f2","main.ts","fileId","3d904b6e-256f-11f1-ba65-42dde27851f2","parentId","branchId","3d8d8866-256f-11f1-ba65-42dde27851f2","branchVersion",7,"latest",true,"createdAt",["D",1774129539448],6,"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\";\n\nfunction 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 const payload = JSON.stringify({ request: endpoint, nonce: Date.now().toString(), ...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 r.json();\n }\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 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 r.json(); },\n balances: () => signed(\"/v1/balances\"),\n orders: () => signed(\"/v1/orders\"),\n newOrder: (sym: string, amt: string, price: string, side: \"buy\" | \"sell\", opts = [\"maker-or-cancel\"]) =>\n signed(\"/v1/order/new\", { symbol: sym, amount: amt, price, side, type: \"exchange limit\", options: opts }),\n cancelAll: () => 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: \"\", apiSecret: \"\", sandbox: 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;\n\nfunction log(msg: string) { logs.push({ ts: Date.now(), msg }); if (logs.length > 200) logs.shift(); }\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 = 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) { 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 { 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; log(\"Widened to fee floor.\"); }\n\n try { await c.cancelAll(); } catch (e: any) { 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 log(`BID ${amt} @ ${bps} → ${bs}`);\n } catch (e: any) { bs = \"err\"; 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 log(`ASK ${sa} @ ${aps} → ${as_}`);\n } catch (e: any) { as_ = \"err\"; log(`ASK err: ${e.message}`); }\n } else { 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 log(`Cycle err #${errCount}: ${e.message}`);\n if (errCount >= 5) { log(\"KILL SWITCH.\"); stopEngine(); try { const c = createGeminiClient(cfg.apiKey, cfg.apiSecret, cfg.sandbox); await c.cancelAll(); } catch {} }\n }\n}\n\nfunction startEngine() { running = true; errCount = 0; log(`Engine ON — ${cfg.intervalSec}s`); safeCycle(); timer = setInterval(safeCycle, cfg.intervalSec * 1000); }\nfunction stopEngine() { if (timer) { clearInterval(timer); timer = null; } running = false; 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 startEngine(); return Response.json({ ok: true });\n }\n if (p === \"/api/stop\" && req.method === \"POST\") { 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 = 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 = 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 = createGeminiClient(\"\", \"\", 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 = createGeminiClient(\"\", \"\", 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",1774129539448],"children",[],[35],"3d8cb3aa-256f-11f1-ba65-42dde27851f2",["D",1774129512941],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","market maker for gemini exchange","imageUrl","userId","2c6d46b0-54dd-11f0-a86c-6fbc2b29331a","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","850db142-aa5e-4914-bceb-1e2e085ae4c5","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_115":111},"org",{"_11":12,"_109":-5,"_110":111,"_71":72,"_112":113,"_114":53},"branch",{"_17":42,"_13":16,"_33":40,"_101":61,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":-5,"_107":14,"_108":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":149,"_63":-5,"_64":53,"_65":66,"_67":66,"_68":69,"_70":-5,"_71":72,"_73":-5,"_74":53,"_75":-5,"_76":-5,"_77":78,"_79":80,"_81":-5,"_82":-5,"_83":-5,"_84":-5,"_85":86,"_87":86,"_88":89,"_90":89,"_91":89,"_92":86,"_93":86,"_94":150,"_96":151,"_98":152,"_100":53},[146],"files",[146],"counts",{"_136":78,"_137":138,"_139":78,"_31":140,"_141":142},[134],"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":135},[35],"pulls","branches",1,"forks",{"_143":78,"_145":78},"connections",{"_143":78,"_144":78},"count","unfilledCount","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":147,"_18":148},[],[35],["D",1774129512941],{"_11":12,"_115":111},{"_11":12,"_109":-5,"_110":111,"_71":72,"_112":113,"_114":53},{"_17":42,"_13":16,"_33":40,"_101":61,"_102":-5,"_103":-5,"_104":-5,"_105":-5,"_106":-5,"_107":14,"_108":12},"ctx",{"_94":-5,"_131":186,"_187":188,"_189":190,"_191":53,"_192":53,"_193":53,"_194":44,"_195":-5,"_196":-7,"_197":-7,"_198":78,"_199":53,"_200":53,"_201":-5,"_202":53,"_203":53,"_204":53,"_205":-5},"ENV",{"_157":158,"_159":160,"_161":16,"_162":163,"_164":165,"_166":167,"_168":169,"_170":171,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185},"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