Paragon MM

[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_163":164,"_165":166},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":-7,"_61":133,"_16":-7,"_134":-5,"_17":135,"_136":137,"_28":138,"_21":139,"_23":140,"_141":-5,"_142":-5,"_143":-5,"_144":36,"_145":146,"_147":34,"_148":-5,"_149":-5,"_150":151},"routes/_app.x.$handle.$name._index",{"_11":12,"_13":14,"_15":-7,"_16":-7,"_17":18,"_19":20,"_21":22,"_23":24,"_25":-7,"_26":-5,"_27":-5,"_28":29,"_30":-5,"_31":-5,"_32":-5,"_33":34,"_35":36,"_37":34},"handle","ziggyware","name","gemini-exchange-bot","branchName","version","project",{"_39":78,"_13":14,"_50":79,"_80":-5,"_81":36,"_82":83,"_84":83,"_85":86,"_87":-5,"_88":89,"_90":-5,"_91":36,"_92":-5,"_93":-5,"_94":67,"_95":96,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":102,"_103":102,"_104":105,"_106":105,"_107":105,"_108":102,"_109":102,"_110":111,"_112":113,"_114":115,"_116":36},"tags",[],"counts",{"_66":67,"_68":69,"_70":67,"_71":72,"_73":74},"contents",[63],"readme","upstream","pull","files",[38],"preview","ahead","behind","showHomeCustomizationHint",true,"showHTTPPreviewSettingsHint",false,"hasHTTPFiles",{"_39":40,"_13":41,"_42":43,"_44":-5,"_45":46,"_47":48,"_49":34,"_50":51,"_16":52,"_53":54,"_55":56,"_57":36,"_58":-5,"_59":60,"_61":62},"id","4d5b4864-256f-11f1-962d-42dde27851f2","main.ts","fileId","3d904b6e-256f-11f1-ba65-42dde27851f2","parentId","branchId","3d8d8866-256f-11f1-ba65-42dde27851f2","branchVersion",7,"latest","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","label","children",[],"path",[41],{"_39":40,"_13":41,"_42":43,"_44":-5,"_45":46,"_47":48,"_49":34,"_50":64,"_16":52,"_53":54,"_55":56,"_57":36,"_58":-5,"_61":65},["D",1774129539448],[41],"pulls",0,"branches",1,"forks","envVars",{"_75":67,"_77":67},"connections",{"_75":67,"_76":67},"count","unfilledCount","emptyCount","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","orgId","850db142-aa5e-4914-bceb-1e2e085ae4c5","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_11":12,"_132":128},"org",{"_11":12,"_126":-5,"_127":128,"_88":89,"_129":130,"_131":36},"branch",{"_16":48,"_13":117,"_39":46,"_118":78,"_119":-5,"_120":-5,"_121":-5,"_122":-5,"_123":-5,"_124":14,"_125":12},"isOwned","main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","avatar","https://img.clerk.com/eyJ0eXBlIjoicHJveHkiLCJzcmMiOiJodHRwczovL2ltYWdlcy5jbGVyay5kZXYvb2F1dGhfZ2l0aHViL2ltZ18yekJHRDE5SGVoUHUzUENQaXY2MTRkT3h0cncifQ","tier","free","canRestrictVals","profileImageUrl","","adoptOrgId",{"_39":78,"_13":14,"_50":159,"_80":-5,"_81":36,"_82":83,"_84":83,"_85":86,"_87":-5,"_88":89,"_90":-5,"_91":36,"_92":-5,"_93":-5,"_94":67,"_95":96,"_97":-5,"_98":-5,"_99":-5,"_100":-5,"_101":102,"_103":102,"_104":105,"_106":105,"_107":105,"_108":102,"_109":102,"_110":160,"_112":161,"_114":162,"_116":36},"tree",[156],[156],{"_66":67,"_68":69,"_70":67,"_71":154,"_73":155},[152],"file","upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_39":40,"_13":41,"_42":43,"_44":-5,"_45":46,"_47":48,"_49":34,"_50":64,"_16":52,"_53":54,"_55":56,"_57":36,"_58":-5,"_61":153},[41],{"_75":67,"_77":67},{"_75":67,"_76":67},{"_39":40,"_13":41,"_42":43,"_44":-5,"_45":46,"_47":48,"_49":34,"_50":51,"_16":52,"_53":54,"_55":56,"_57":36,"_58":-5,"_59":157,"_61":158},[],[41],["D",1774129512941],{"_11":12,"_132":128},{"_11":12,"_126":-5,"_127":128,"_88":89,"_129":130,"_131":36},{"_16":48,"_13":117,"_39":46,"_118":78,"_119":-5,"_120":-5,"_121":-5,"_122":-5,"_123":-5,"_124":14,"_125":12},"ctx",{"_110":-5,"_149":196,"_197":198,"_199":200,"_201":36,"_202":36,"_203":36,"_204":34,"_205":-5,"_206":-7,"_207":-7,"_208":67,"_209":36,"_210":36,"_211":-5,"_212":36,"_213":36,"_214":36,"_215":-5},"ENV",{"_167":168,"_169":170,"_171":117,"_172":173,"_174":175,"_176":177,"_178":179,"_180":181,"_182":183,"_184":185,"_186":187,"_188":189,"_190":191,"_192":193,"_194":195},"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"]