[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_285":286,"_287":288},"routes/_app.x.$handle.$name",{"_100":99,"_32":45,"_108":90,"_27":109,"_13":14,"_110":-5,"_11":111,"_112":113,"_114":115,"_116":117,"_118":119,"_20":-5,"_120":-5,"_121":-5,"_122":25,"_123":124,"_125":59,"_126":-5,"_127":-5,"_128":129},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_43":44,"_32":45,"_38":46,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":71,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":83,"_84":85,"_86":87,"_88":25},"version",191,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":23,"_24":25,"_26":25,"_27":28,"_29":28},"file",{"_30":31,"_32":28,"_33":37,"_35":36,"_38":39,"_40":14,"_41":42,"_24":25},"previous",{"_30":31,"_32":28,"_33":34,"_35":36},"deleted",false,"deletedHere","path","test.ts","latestPath","fileId","f1e41a42-a57a-11f1-abab-1607ee4eb77e","name","fileType","script","content","// Learn more: https://docs.val.town/vals/http/\nexport default async function (req: Request): Promise {\n return Response.json({ ok: true })\n}","http","createdAt",["D",1788208583335],"branchVersion","branchId","5460a70e-f84d-489f-927c-3f6edf925c52","id","c842cd0d-1ecb-4dfa-b1fa-57b54615f415","wsio",["D",1787860636222],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Websocket","imageUrl","c981381e-b02a-44a8-b23a-de5419fdc4f6","pinnedFileId","80d68cee-a251-11f1-8a82-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount",0,"orgId","01a044cb-0fcf-73cd-a71a-16423337bfe0","tursoName","c842cd0d1ecb4dfab1fa57b54615f415","tursoHostname","c842cd0d1ecb4dfab1fa57b54615f415-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789519842404],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_100":99,"_107":-5},"org",{"_100":99,"_101":102,"_103":-5,"_18":-5,"_104":105,"_106":25},"branch",{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"isOwned",294,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","auto","handle","displayName","Automations","avatar","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_43":44,"_32":45,"_38":280,"_47":-5,"_48":25,"_49":50,"_51":50,"_52":53,"_54":-5,"_18":55,"_56":57,"_58":59,"_60":-5,"_61":-5,"_62":63,"_64":65,"_66":67,"_68":69,"_70":281,"_72":-5,"_73":74,"_75":74,"_76":77,"_78":77,"_79":77,"_80":74,"_81":74,"_82":282,"_84":283,"_86":284,"_88":25},"tree",[235,236,237,238,239,240,241,242,243,244,245],"files",[235,236,237,238,239,240,241,242,243,244,245],"counts",{"_225":63,"_226":185,"_227":63,"_228":229,"_230":231},"contents",[130,131,132,133,134,135,136,137,138,139,140],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_43":217,"_32":218,"_30":219,"_144":-5,"_41":42,"_40":220,"_146":59,"_38":221,"_13":222,"_33":37,"_35":223,"_24":25,"_150":-5,"_27":224},{"_43":211,"_32":212,"_30":57,"_144":-5,"_41":42,"_40":213,"_146":59,"_38":214,"_13":215,"_33":37,"_35":186,"_24":25,"_150":-5,"_27":216},{"_43":203,"_32":204,"_30":205,"_144":-5,"_41":42,"_40":206,"_146":59,"_38":207,"_13":208,"_33":37,"_35":209,"_24":25,"_150":-5,"_27":210},{"_43":195,"_32":196,"_30":197,"_144":-5,"_41":42,"_40":198,"_146":25,"_38":199,"_13":200,"_33":37,"_35":201,"_24":25,"_150":-5,"_27":202},{"_43":188,"_32":189,"_30":190,"_144":-5,"_41":42,"_40":191,"_146":59,"_38":192,"_13":154,"_33":37,"_35":193,"_24":25,"_150":-5,"_27":194},{"_43":180,"_32":181,"_30":182,"_144":-5,"_41":42,"_40":183,"_146":59,"_38":184,"_13":185,"_33":37,"_35":186,"_24":25,"_150":-5,"_27":187},{"_43":172,"_32":173,"_30":174,"_144":-5,"_41":42,"_40":175,"_146":25,"_38":176,"_13":177,"_33":37,"_35":178,"_24":25,"_150":-5,"_27":179},{"_43":164,"_32":165,"_30":166,"_144":-5,"_41":42,"_40":167,"_146":59,"_38":168,"_13":169,"_33":37,"_35":170,"_24":25,"_150":-5,"_27":171},{"_43":156,"_32":157,"_30":158,"_144":-5,"_41":42,"_40":159,"_146":59,"_38":160,"_13":161,"_33":37,"_35":162,"_24":25,"_150":-5,"_27":163},{"_43":152,"_32":28,"_30":31,"_144":-5,"_41":42,"_40":14,"_146":25,"_38":153,"_13":154,"_33":37,"_35":36,"_24":25,"_150":-5,"_27":155},{"_43":141,"_32":142,"_30":143,"_144":-5,"_41":42,"_40":145,"_146":59,"_38":147,"_13":148,"_33":37,"_35":149,"_24":25,"_150":-5,"_27":151},"ab4c315b-9642-42cf-9c09-d6fe3322bc3c","xbts.ts","ed372390-a2f5-11f1-b032-1607ee4eb77e","parentId",125,"latest",["D",1787951365611],23,"export default async function (req: Request): Promise {\n const orderbooks = { btc: [], usdt: [] };\n\n const ticker_url = \"https://cmc.xbts.io/v2/tickers\";\n const book_url = \"https://cmc.xbts.io/v2/orderbook/\";\n\n const tickers_raw = await fetch(ticker_url)\n .then((response) => response.json())\n .catch((error) => console.error(error));\n\n const ticker_keys = Object.keys(tickers_raw.ticker);\n let tickers = [];\n for (const s of ticker_keys) {\n if (tickers_raw.ticker[s].base_symbol == \"BTC\") {\n tickers.push(tickers_raw.ticker[s]);\n }\n if (tickers_raw.ticker[s].base_symbol == \"USDT\") {\n tickers.push(tickers_raw.ticker[s]);\n }\n }\n\n const pairs = [];\n\n for (let i = 0; i < tickers.length; i++) {\n const entry = tickers[i];\n books(entry);\n //console.log(i, tickers.length - 1);\n await new Promise((r) => setTimeout(r, 300));\n if (i == (tickers.length - 1)) {\n return Response.json(orderbooks);\n }\n }\n\n async function books(entry) {\n //pairs.push({ pair: entry.pair, base: entry.base, quote: entry.quote });\n const book = await fetch(\n book_url + entry.base_symbol + \"_\" + entry.quote_symbol + \"?depth=2\",\n )\n .then((response) => response.json())\n /*.then((response) => {\n console.log(response);\n return response.json();\n })*/\n .catch((error) => console.error(error));\n //console.log(book);\n if (entry.base_symbol == \"BTC\") {\n orderbooks.btc.push({\n ticker_id: entry.quote_symbol,\n ask_price: (book.asks.length > 0) ? book.asks[0].price : null,\n ask_volume: (book.asks.length > 0) ? book.asks[0].quote : null,\n bid_price: (book.bids.length > 0) ? book.bids[0].price : null,\n bid_volume: (book.bids.length > 0) ? book.bids[0].quote : null,\n });\n }\n if (entry.base_symbol == \"USDT\") {\n orderbooks.usdt.push({\n ticker_id: entry.quote_symbol,\n ask_price: (book.asks.length > 0) ? book.asks[0].price : null,\n ask_volume: (book.asks.length > 0) ? book.asks[0].quote : null,\n bid_price: (book.bids.length > 0) ? book.bids[0].price : null,\n bid_volume: (book.bids.length > 0) ? book.bids[0].quote : null,\n });\n }\n }\n}","label",[142],"6d6edff7-b439-4a8d-b276-ee50586a7ee8",["D",1788208583335],3,[28],"6e5c7c7e-d599-4547-b9ca-c18dd60ad866","stakecube.ts","8d7c8496-a326-11f1-8311-1607ee4eb77e",178,["D",1788104343474],21,"//using another for longer exec time\nexport default async function (req: Request): Promise {\n const orderbooks = { btc: [], usdt: [] };\n\n const ticker_url = \"https://stakecube.io/api/v2/exchange/spot/markets\";\n const book_url =\n \"https://stakecube.io/api/v2/exchange/spot/orderbook?market=\";\n\n const tickers_raw = await fetch(ticker_url)\n .then((response) => response.json())\n .catch((error) => console.error(error));\n\n const ticker_keys = Object.keys(tickers_raw.result);\n let tickers = [];\n for (const s of ticker_keys) {\n if (tickers_raw.result[s].baseMarket == \"BTC\") {\n tickers.push(tickers_raw.result[s]);\n }\n if (tickers_raw.result[s].baseMarket == \"USDT\") {\n tickers.push(tickers_raw.result[s]);\n }\n }\n\n const pairs = [];\n\n for (let i = 0; i < tickers.length; i++) {\n const entry = tickers[i];\n books(entry);\n //console.log(i, tickers.length - 1);\n await new Promise((r) => setTimeout(r, 400));\n if (i == (tickers.length - 1)) {\n return Response.json(orderbooks);\n //console.log(orderbooks);\n }\n }\n //return Response.json(orderbooks);\n async function books(entry) {\n //pairs.push({ pair: entry.pair, base: entry.base, quote: entry.quote });\n console.log(book_url + entry.tradeMarket + \"_\" + entry.baseMarket);\n const book = await fetch(\n book_url + entry.tradeMarket + \"_\" + entry.baseMarket,\n )\n .then((response) => response.json())\n /*.then((response) => {\n console.log(response);\n return response.json();\n })*/\n .catch((error) => console.error(error));\n //console.log(book);\n if (entry.baseMarket == \"BTC\") {\n orderbooks.btc.push({\n ticker_id: entry.tradeMarket,\n ask_price:\n (book.result.asks != undefined && book.result.asks.length > 0)\n ? book.result.asks[book.result.asks.length - 1].price\n : null,\n ask_volume:\n (book.result.asks != undefined && book.result.asks.length > 0)\n ? book.result.asks[book.result.asks.length - 1].amount\n : null,\n bid_price:\n (book.result.bids != undefined && book.result.bids.length > 0)\n ? book.result.bids[0].price\n : null,\n bid_volume:\n (book.result.bids != undefined && book.result.bids.length > 0)\n ? book.result.bids[0].amount\n : null,\n });\n }\n if (entry.baseMarket == \"USDT\") {\n orderbooks.usdt.push({\n ticker_id: entry.tradeMarket,\n ask_price:\n (book.result.asks != undefined && book.result.asks.length > 0)\n ? book.result.asks[book.result.asks.length - 1].price\n : null,\n ask_volume:\n (book.result.asks != undefined && book.result.asks.length > 0)\n ? book.result.asks[book.result.asks.length - 1].amount\n : null,\n bid_price:\n (book.result.bids != undefined && book.result.bids.length > 0)\n ? book.result.bids[0].price\n : null,\n bid_volume:\n (book.result.bids != undefined && book.result.bids.length > 0)\n ? book.result.bids[0].amount\n : null,\n });\n }\n }\n}",[157],"b5068a8e-cc7e-4f76-938e-ba0d5cda3c25","safetrade.ts","eb0d4092-a271-11f1-a75f-1607ee4eb77e",119,["D",1787950305716],36,"//Not working\nexport default async function (req: Request): Promise {\n const orderbooks = { btc: [], usdt: [] };\n\n const ticker_url = \"https://safe.trade/api/v2/trade/public/markets\";\n const book_url = \"https://safe.trade/api/v2/trade/public/markets/\";\n\n /*const tickers = await fetch(ticker_url)\n .then((response) => response.json())\n .catch((error) => console.error(error));*/\n\n const tickers = await fetch(ticker_url, {\n \"credentials\": \"omit\",\n \"headers\": {\n \"authority\": \"safe.trade\",\n \"pragma\": \"no-cache\",\n \"cache-control\": \"no-cache\",\n \"User-Agent\":\n \"Mozilla/5.0 (Windows NT 10.0; rv:120.0) Gecko/20100101 Firefox/120.0\",\n \"Accept\":\n \"text/html,application/xhtml+xml,application/xml;q=0.9,image/avif,image/webp,*/*;q=0.8\",\n \"Accept-Language\": \"en-US,en;q=0.5\",\n \"Sec-GPC\": \"1\",\n \"Upgrade-Insecure-Requests\": \"1\",\n \"Sec-Fetch-Dest\": \"empty\",\n \"Sec-Fetch-Mode\": \"cors\",\n \"Sec-Fetch-Site\": \"cross-site\",\n },\n \"method\": \"GET\",\n \"mode\": \"cors\",\n })\n //.then((response) => response.json())\n .then((response) => response.text())\n .catch((error) => console.error(error));\n console.log(tickers);\n const pairs = [];\n\n for (let i = 0; i < tickers.length; i++) {\n const entry = tickers[i];\n books(entry);\n await new Promise((r) => setTimeout(r, 250));\n if (i == (tickers.length - 1)) {\n return Response.json(orderbooks);\n }\n }\n\n async function books(entry) {\n //pairs.push({ pair: entry.pair, base: entry.base, quote: entry.quote });\n const book = await fetch(book_url + entry.symbol + \"/depth\")\n .then((response) => response.json())\n .catch((error) => console.error(error));\n //console.log(book);\n if (entry.quote_unit == \"btc\") {\n let bid = null, bidVol = null, ask = null, askVol = null;\n if (book.bids.length > 0) {\n bid = book.bids[0][0];\n bidVol = book.bids[0][1];\n }\n if (book.asks.length > 0) {\n ask = book.asks[0][0];\n askVol = book.asks[0][1];\n }\n orderbooks.btc.push({\n ticker_id: entry.base_unit.toUpperCase(),\n ask_price: ask,\n ask_volume: askVol,\n bid_price: bid,\n bid_volume: bidVol,\n });\n }\n if (entry.quote_unit == \"usdt\") {\n let bid = null, bidVol = null, ask = null, askVol = null;\n if (book.bids.length > 0) {\n bid = book.bids[0][0];\n bidVol = book.bids[0][1];\n }\n if (book.asks.length > 0) {\n ask = book.asks[0][0];\n askVol = book.asks[0][1];\n }\n orderbooks.usdt.push({\n ticker_id: entry.base_unit.toUpperCase(),\n ask_price: ask,\n ask_volume: askVol,\n bid_price: bid,\n bid_volume: bidVol,\n });\n }\n }\n}",[165],"7724064a-1a86-4695-a04e-92ef5e41e399","rabidrabbit.ts","f4ec545e-a488-11f1-b655-1607ee4eb77e",187,["D",1788106453511],4,"//using another for longer exec time\nexport default async function (req: Request): Promise {\n const orderbooks = { btc: [], usdt: [] };\n\n const ticker_url = \"https://rabid-rabbit.org/api/public/v1/markets\";\n const book_url = \"https://rabid-rabbit.org/api/public/v1/orderbook/\";\n\n const tickers_raw = await fetch(ticker_url)\n .then((response) => response.json())\n .catch((error) => console.error(error));\n\n let tickers = [];\n for (const s of tickers_raw) {\n if (s.quote == \"BTC\" && s.type == \"spot\") {\n tickers.push(s);\n }\n if (s.quote == \"USDT\" && s.type == \"spot\") {\n tickers.push(s);\n }\n }\n\n for (let i = 0; i < tickers.length; i++) {\n const entry = tickers[i];\n books(entry);\n //console.log(i, tickers.length - 1);\n await new Promise((r) => setTimeout(r, 400));\n if (i == (tickers.length - 1)) {\n return Response.json(orderbooks);\n //console.log(orderbooks);\n }\n }\n //return Response.json(orderbooks);\n async function books(entry) {\n //pairs.push({ pair: entry.pair, base: entry.base, quote: entry.quote });\n //console.log(book_url + entry.tradeMarket + \"_\" + entry.baseMarket);\n const book = await fetch(\n book_url + entry.id + \"?depth=2\",\n )\n .then((response) => response.json())\n /*.then((response) => {\n console.log(response);\n return response.json();\n })*/\n .catch((error) => console.error(error));\n //console.log(book);\n let id = entry.id.split(\"-\")[0];\n if (entry.quote == \"BTC\") {\n orderbooks.btc.push({\n ticker_id: id,\n ask_price: (book.asks !== undefined && book.asks.length > 0)\n ? book.asks[0][0]\n : null,\n ask_volume: (book.asks !== undefined && book.asks.length > 0)\n ? book.asks[0][1]\n : null,\n bid_price: (book.bids !== undefined && book.bids.length > 0)\n ? book.bids[0][0]\n : null,\n bid_volume: (book.bids !== undefined && book.bids.length > 0)\n ? book.bids[0][1]\n : null,\n });\n }\n if (entry.quote == \"USDT\") {\n orderbooks.usdt.push({\n ticker_id: id,\n ask_price: (book.asks !== undefined && book.asks.length > 0)\n ? book.asks[0][0]\n : null,\n ask_volume: (book.asks !== undefined && book.asks.length > 0)\n ? book.asks[0][1]\n : null,\n bid_price: (book.bids !== undefined && book.bids.length > 0)\n ? book.bids[0][0]\n : null,\n bid_volume: (book.bids !== undefined && book.bids.length > 0)\n ? book.bids[0][1]\n : null,\n });\n }\n }\n}",[173],"279b079e-e13f-45a7-8c8f-0829fdbfd63a","proxy.ts","c6bc9a2e-a480-11f1-bd00-1607ee4eb77e",177,["D",1788100850318],1,"//import { io } from \"npm:socket.io-client\";\n//import { createServer } from \"node:http\";\n//import { URL } from \"node:url\";\n\nexport default async function (req: Request): Promise {\n const requestUrl = new URL(req.url);\n\n const targetUrl = requestUrl.searchParams.get(\"url\");\n\n if (!targetUrl) {\n return Response.json(\n {\n error: \"Missing url query parameter\",\n example: \"/?url=https://api.example.com/data\",\n },\n { status: 400 },\n );\n }\n\n let parsedUrl;\n\n try {\n parsedUrl = new URL(targetUrl);\n } catch {\n return Response.json(\n { error: \"Invalid URL\" },\n { status: 400 },\n );\n }\n\n // Basic protection against accidentally fetching local/private addresses.\n if (![\"http:\", \"https:\"].includes(parsedUrl.protocol)) {\n return Response.json(\n { error: \"Only HTTP and HTTPS URLs are allowed\" },\n { status: 400 },\n );\n }\n\n try {\n const upstreamResponse = await fetch(parsedUrl, {\n headers: {\n Accept: \"application/json\",\n },\n });\n\n const text = await upstreamResponse.text();\n\n let data;\n\n try {\n data = JSON.parse(text);\n } catch {\n return Response.json(\n {\n error: \"The upstream response was not valid JSON\",\n upstreamStatus: upstreamResponse.status,\n responsePreview: text.slice(0, 500),\n },\n { status: 502 },\n );\n }\n\n return Response.json(data);\n /*return Response.json(\n {\n success: upstreamResponse.ok,\n data,\n },\n {\n status: upstreamResponse.status,\n headers: {\n \"Cache-Control\": \"no-store\",\n },\n },\n );*/\n } catch (error) {\n return Response.json(\n {\n error: \"Unable to fetch the upstream endpoint\",\n message: error.message,\n },\n { status: 502 },\n );\n }\n}",[181],"217739b2-609d-4304-a6ad-c286962a7e42","nonlogs.ts","eecfe158-a488-11f1-a6c1-1607ee4eb77e",185,["D",1788106266977],"//using another for longer exec time\nexport default async function (req: Request): Promise {\n const orderbooks = { btc: [], usdt: [] };\n\n const ticker_url = \"https://nonlogs.io/api/markets\";\n const book_url = \"https://nonlogs.io/order/orderbook/\";\n\n const tickers_raw = await fetch(ticker_url)\n .then((response) => response.json())\n .catch((error) => console.error(error));\n\n const ticker_keys = Object.keys(tickers_raw.markets);\n let tickers = [];\n for (const s of ticker_keys) {\n if (s.endsWith(\"BTC\")) {\n tickers_raw.markets[s].ticker_id = s;\n tickers.push(tickers_raw.markets[s]);\n }\n if (s.endsWith(\"USDT\")) {\n tickers_raw.markets[s].ticker_id = s;\n tickers.push(tickers_raw.markets[s]);\n }\n }\n\n for (let i = 0; i < tickers.length; i++) {\n const entry = tickers[i];\n books(entry);\n //console.log(i, tickers.length - 1);\n await new Promise((r) => setTimeout(r, 400));\n if (i == (tickers.length - 1)) {\n return Response.json(orderbooks);\n //console.log(orderbooks);\n }\n }\n //return Response.json(orderbooks);\n async function books(entry) {\n //pairs.push({ pair: entry.pair, base: entry.base, quote: entry.quote });\n //console.log(book_url + entry.tradeMarket + \"_\" + entry.baseMarket);\n const book = await fetch(\n book_url + entry.ticker_id + \"?depth=2\",\n )\n .then((response) => response.json())\n /*.then((response) => {\n console.log(response);\n return response.json();\n })*/\n .catch((error) => console.error(error));\n //console.log(book);\n let id = entry.ticker_id.split(\"-\")[0];\n if (entry.ticker_id.endsWith(\"BTC\")) {\n orderbooks.btc.push({\n ticker_id: id,\n ask_price: (book.asks.length > 0) ? book.asks[0][0] : null,\n ask_volume: (book.asks.length > 0) ? book.asks[0][1] : null,\n bid_price: (book.bids.length > 0) ? book.bids[0][0] : null,\n bid_volume: (book.bids.length > 0) ? book.bids[0][1] : null,\n });\n }\n if (entry.ticker_id.endsWith(\"USDT\")) {\n orderbooks.usdt.push({\n ticker_id: id,\n ask_price: (book.asks.length > 0) ? book.asks[0][0] : null,\n ask_volume: (book.asks.length > 0) ? book.asks[0][1] : null,\n bid_price: (book.bids.length > 0) ? book.bids[0][0] : null,\n bid_volume: (book.bids.length > 0) ? book.bids[0][1] : null,\n });\n }\n }\n}",[189],"5e735850-0b38-42f8-9be4-5d0da9ea1738","nestex.ts","21fcfabe-a3eb-11f1-8127-1607ee4eb77e",171,["D",1788048495018],19,"export default async function (req: Request): Promise {\n const orderbooks = { btc: [], usdt: [] };\n\n const ticker_url = \"https://api.nestex.one/cg/tickers\";\n const book_url = \"https://api.nestex.one/cg/orderbook/\";\n const proxy1 = \"https://proxy.cors.sh/\";\n const proxy2 = \"https://api.codetabs.com/v1/proxy?quest=\";\n const proxy3 = \"https://cors.io/?url=\";\n\n const urls = [\n book_url,\n proxy1 + book_url,\n proxy2 + book_url,\n proxy3 + book_url,\n ];\n\n const tickers = await fetch(ticker_url)\n .then((response) => response.json())\n .catch((error) => console.error(error));\n\n for (let i = 0; i < tickers.length; i++) {\n const entry = tickers[i];\n books(entry, urls[i % 4] + entry.ticker_id);\n //console.log(i, tickers.length - 1);\n await new Promise((r) => setTimeout(r, 1700));\n if (entry.ticker_id == tickers[tickers.length - 1].ticker_id) {\n return Response.json(orderbooks);\n }\n }\n\n async function books(entry, url) {\n let book = await fetch(\n url,\n )\n //.then((response) => response.json())\n .then((response) => {\n console.log(response);\n return response.json();\n })\n .catch((error) => console.error(error));\n //console.log(book);\n return;\n\n if (url.startsWith(\"https://cors.io\")) {\n book = JSON.parse(book.body);\n }\n if (entry.target_currency == \"BTC\") {\n let ask_keys = Object.keys(book.asks);\n let ask_values = Object.values(book.asks);\n let bid_keys = Object.keys(book.bids);\n let bid_values = Object.values(book.bids);\n orderbooks.btc.push({\n ticker_id: entry.base_currency,\n ask_price: (ask_keys.length > 0) ? ask_keys[ask_keys.length - 1] : null,\n ask_volume: (ask_keys.length > 0)\n ? ask_values[ask_values.length - 1]\n : null,\n bid_price: (bid_keys.length > 0) ? bid_keys[0] : null,\n bid_volume: (bid_keys.length > 0) ? bid_values[0] : null,\n });\n }\n if (entry.target_currency == \"USDT\") {\n let ask_keys = Object.keys(book.asks);\n let ask_values = Object.values(book.asks);\n let bid_keys = Object.keys(book.bids);\n let bid_values = Object.values(book.bids);\n orderbooks.usdt.push({\n ticker_id: entry.base_currency,\n ask_price: (ask_keys.length > 0) ? ask_keys[ask_keys.length - 1] : null,\n ask_volume: (ask_keys.length > 0)\n ? ask_values[ask_values.length - 1]\n : null,\n bid_price: (bid_keys.length > 0) ? bid_keys[0] : null,\n bid_volume: (bid_keys.length > 0) ? bid_values[0] : null,\n });\n }\n }\n}",[196],"c26d9b43-7e04-4733-be54-42d28d38f9b5","neoxa.ts","442eae24-a261-11f1-8738-1607ee4eb77e",52,["D",1787874550480],13,"// Learn more: https://docs.val.town/vals/http/\n/*export default async function (req: Request): Promise {\n return Response.json({ ok: true })\n}*/\n\nimport { io } from \"npm:socket.io-client\";\n\n/*\ntype Orderbook = {\n bids: unknown[];\n asks: unknown[];\n};*/\n\nexport default async function (req: Request): Promise {\n /*const orderbooks: {\n btc: Orderbook | null;\n usdt: Orderbook | null;\n } = {\n btc: null,\n usdt: null,\n };*/\n const orderbooks = { btc: [], usdt: [] };\n\n const rest_url = \"https://neoxa.exchange/api/exchange/summary\";\n\n const data_rest = await fetch(rest_url)\n .then((response) => response.json())\n .catch((error) => console.error(error));\n\n const pairs = Object.keys(data_rest);\n\n const socket = io(\"https://neoxa.exchange/exchange\", {\n transports: [\"websocket\", \"polling\"],\n withCredentials: true,\n reconnection: false,\n });\n\n try {\n await new Promise((resolve, reject) => {\n /*const timeout = setTimeout(() => {\n reject(new Error(\"Timed out waiting for orderbook responses\"));\n }, 50_000);*/\n\n let counter = 0;\n // Register this before sending subscriptions.\n socket.on(\"exchange:orderbook\", (data: any) => {\n //console.log(\"Received orderbook:\", data);\n counter++;\n console.log(counter, pairs.length);\n if (data.pair.includes(\"_USDC\")) {\n orderbooks.usdt.push({\n ticker_id: data.pair.substring(0, data.pair.indexOf(\"_\")),\n ask_price: (data.asks.length > 0) ? data.asks[0].price : null,\n ask_volume: (data.asks.length > 0) ? data.asks[0].quantity : null,\n bid_price: (data.bids.length > 0) ? data.bids[0].price : null,\n bid_volume: (data.bids.length > 0) ? data.bids[0].quantity : null,\n });\n //socket.emit(\"unsubscribe\", { pair: data.pair });\n }\n\n if (data.pair.includes(\"_BTC\")) {\n orderbooks.btc.push({\n ticker_id: data.pair.substring(0, data.pair.indexOf(\"_\")),\n ask_price: (data.asks.length > 0) ? data.asks[0].price : null,\n ask_volume: (data.asks.length > 0) ? data.asks[0].quantity : null,\n bid_price: (data.bids.length > 0) ? data.bids[0].price : null,\n bid_volume: (data.bids.length > 0) ? data.bids[0].quantity : null,\n });\n socket.emit(\"unsubscribe\", { pair: data.pair });\n }\n\n // Resolve after all expected responses have arrived.\n //const receivedAll = orderbooks.btc !== null && orderbooks.usdt !== null;\n const receivedAll = data.pair == pairs[pairs.length - 1];\n\n if (receivedAll) {\n //clearTimeout(timeout);\n resolve();\n }\n });\n\n socket.on(\"connect\", () => {\n for (const pair of pairs) {\n if (pair.includes(\"_USDC\")) {\n socket.emit(\"subscribe\", { pair: pair });\n }\n if (pair.includes(\"_BTC\")) {\n socket.emit(\"subscribe\", { pair: pair });\n }\n }\n });\n\n socket.on(\"connect_error\", (error) => {\n //clearTimeout(timeout);\n reject(error);\n });\n });\n\n return Response.json(orderbooks);\n } catch (error) {\n return Response.json(\n {\n error: error instanceof Error\n ? error.message\n : \"Unable to retrieve orderbooks\",\n orderbooks,\n },\n { status: 500 },\n );\n } finally {\n socket.close();\n }\n}",[204],"d4d90fef-0324-421f-aa56-8cf3ced524c6","main.ts",175,["D",1788100299878],44,[212],"597a5183-cd60-4deb-ad09-9ed82dc0d269","dextrade.ts","614aa528-a287-11f1-b37e-1607ee4eb77e",92,["D",1787928113990],11,"import { io } from \"npm:socket.io-client\";\n\nexport default async function (req: Request): Promise {\n const orderbooks = { btc: [], usdt: [] };\n\n const ticker_url = \"https://api.dex-trade.com/v1/public/symbols\";\n const book_url = \"https://api.dex-trade.com/v1/public/book?pair=\";\n //let current_book = \"\";\n\n const tickers_raw = await fetch(ticker_url)\n .then((response) => response.json())\n .catch((error) => console.error(error));\n\n let tickers = [];\n for (const s of tickers_raw.data) {\n if (s.quote == \"BTC\") {\n tickers.push(s);\n }\n if (s.quote == \"USDT\") {\n tickers.push(s);\n }\n }\n\n const pairs = [];\n\n for (let i = 0; i < tickers.length; i++) {\n const entry = tickers[i];\n books(entry);\n console.log(i, tickers.length - 1);\n await new Promise((r) => setTimeout(r, 250));\n if (i == (tickers.length - 1)) {\n return Response.json(orderbooks);\n }\n }\n\n async function books(entry) {\n //pairs.push({ pair: entry.pair, base: entry.base, quote: entry.quote });\n const book = await fetch(book_url + entry.pair)\n .then((response) => response.json())\n /*.then((response) => {\n console.log(response);\n return response.json();\n })*/\n .catch((error) => console.error(error));\n //console.log(book);\n if (entry.quote == \"BTC\") {\n let bids = [], asks = [];\n if (book.data.buy.length > 0) {\n bids = [{\n rate: book.data.buy[0].rate,\n volume: book.data.buy[0].volume,\n }];\n }\n if (book.data.sell.length > 0) {\n asks = [{\n rate: book.data.sell[0].rate,\n volume: book.data.sell[0].volume,\n }];\n }\n orderbooks.btc.push({\n ticker_id: entry.pair,\n data: { buy: bids, sell: asks },\n });\n }\n if (entry.quote == \"USDT\") {\n let bids = [], asks = [];\n if (book.data.buy.length > 0) {\n bids = [{\n rate: book.data.buy[0].rate,\n volume: book.data.buy[0].volume,\n }];\n }\n if (book.data.sell.length > 0) {\n asks = [{\n rate: book.data.sell[0].rate,\n volume: book.data.sell[0].volume,\n }];\n }\n orderbooks.usdt.push({\n ticker_id: entry.pair,\n data: { buy: bids, sell: asks },\n });\n }\n }\n}",[218],"pulls","branches","forks","envVars",{"_232":63,"_234":63},"connections",{"_232":63,"_233":63},"count","unfilledCount","emptyCount",{"_43":217,"_32":218,"_30":219,"_144":-5,"_41":42,"_40":220,"_146":59,"_38":277,"_13":222,"_33":37,"_35":223,"_24":25,"_150":-5,"_247":278,"_27":279},{"_43":211,"_32":212,"_30":57,"_144":-5,"_41":42,"_40":213,"_146":59,"_38":274,"_13":215,"_33":37,"_35":186,"_24":25,"_150":-5,"_247":275,"_27":276},{"_43":203,"_32":204,"_30":205,"_144":-5,"_41":42,"_40":206,"_146":59,"_38":271,"_13":208,"_33":37,"_35":209,"_24":25,"_150":-5,"_247":272,"_27":273},{"_43":195,"_32":196,"_30":197,"_144":-5,"_41":42,"_40":198,"_146":25,"_38":268,"_13":200,"_33":37,"_35":201,"_24":25,"_150":-5,"_247":269,"_27":270},{"_43":188,"_32":189,"_30":190,"_144":-5,"_41":42,"_40":191,"_146":59,"_38":265,"_13":154,"_33":37,"_35":193,"_24":25,"_150":-5,"_247":266,"_27":267},{"_43":180,"_32":181,"_30":182,"_144":-5,"_41":42,"_40":183,"_146":59,"_38":262,"_13":185,"_33":37,"_35":186,"_24":25,"_150":-5,"_247":263,"_27":264},{"_43":172,"_32":173,"_30":174,"_144":-5,"_41":42,"_40":175,"_146":25,"_38":259,"_13":177,"_33":37,"_35":178,"_24":25,"_150":-5,"_247":260,"_27":261},{"_43":164,"_32":165,"_30":166,"_144":-5,"_41":42,"_40":167,"_146":59,"_38":256,"_13":169,"_33":37,"_35":170,"_24":25,"_150":-5,"_247":257,"_27":258},{"_43":156,"_32":157,"_30":158,"_144":-5,"_41":42,"_40":159,"_146":59,"_38":253,"_13":161,"_33":37,"_35":162,"_24":25,"_150":-5,"_247":254,"_27":255},{"_43":152,"_32":28,"_30":31,"_144":-5,"_41":42,"_40":14,"_146":25,"_38":250,"_13":154,"_33":37,"_35":36,"_24":25,"_150":-5,"_247":251,"_27":252},{"_43":141,"_32":142,"_30":143,"_144":-5,"_41":42,"_40":145,"_146":59,"_38":246,"_13":148,"_33":37,"_35":149,"_24":25,"_150":-5,"_247":248,"_27":249},["D",1787951365611],"children",[],[142],["D",1788208583335],[],[28],["D",1788104343474],[],[157],["D",1787950305716],[],[165],["D",1788106453511],[],[173],["D",1788100850318],[],[181],["D",1788106266977],[],[189],["D",1788048495018],[],[196],["D",1787874550480],[],[204],["D",1788100299878],[],[212],["D",1787928113990],[],[218],["D",1787860636222],["D",1789519842404],{"_100":99,"_107":-5},{"_100":99,"_101":102,"_103":-5,"_18":-5,"_104":105,"_106":25},{"_13":89,"_32":90,"_43":42,"_91":44,"_92":-5,"_93":-5,"_94":-5,"_95":-5,"_96":-5,"_97":45,"_98":99},"ctx",{"_82":-5,"_127":318,"_319":320,"_321":322,"_323":25,"_324":25,"_325":25,"_326":59,"_327":-5,"_328":-7,"_329":-7,"_330":63,"_331":25,"_332":25,"_333":-5,"_334":25,"_335":25,"_336":25,"_337":-5},"ENV",{"_289":290,"_291":292,"_293":90,"_294":295,"_296":297,"_298":299,"_300":301,"_302":303,"_304":305,"_306":307,"_308":309,"_310":311,"_312":313,"_314":315,"_316":317},"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 · v191