[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_418":419,"_420":421},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_17":18,"_51":-7,"_233":-5,"_19":234,"_235":236,"_237":238,"_239":240,"_241":242,"_21":243,"_244":-5,"_245":-5,"_246":24,"_247":248,"_249":191,"_250":-5,"_251":-5,"_252":253},"routes/_app.x.$handle.$name.branch.$branch.history_.$",{"_11":12,"_13":14,"_15":16,"_17":18,"_19":20,"_21":22,"_23":24,"_25":26,"_27":28,"_29":24,"_30":-5},"handle","auto","name","wsio","branchName","main","path","neoxa.ts","project",{"_45":178,"_13":14,"_49":179,"_180":-5,"_181":24,"_182":183,"_184":183,"_185":186,"_187":-5,"_30":80,"_188":189,"_190":191,"_192":-5,"_193":-5,"_194":26,"_53":195,"_196":197,"_198":199,"_200":201,"_202":-5,"_203":204,"_205":204,"_206":207,"_208":207,"_209":207,"_210":204,"_211":204,"_64":212,"_213":214,"_215":216,"_217":24},"file",{"_74":75,"_13":18,"_77":98,"_79":24,"_177":-5},"isDirectory",false,"page",0,"history",[31,32,33,34,35,36,37,38,39,40,41,42,43,44],"hasNext","userId",{"_45":170,"_47":48,"_49":171,"_51":172,"_53":54,"_55":163,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":173,"_21":174,"_67":-5,"_68":-5,"_69":-5,"_70":-5,"_71":175},{"_45":163,"_47":48,"_49":164,"_51":165,"_53":54,"_55":156,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":166,"_21":167,"_67":-5,"_68":-5,"_69":-5,"_70":-5,"_71":168},{"_45":156,"_47":48,"_49":157,"_51":158,"_53":54,"_55":149,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":159,"_21":160,"_67":-5,"_68":-5,"_69":-5,"_70":-5,"_71":161},{"_45":149,"_47":48,"_49":150,"_51":151,"_53":54,"_55":142,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":152,"_21":153,"_67":-5,"_68":-5,"_69":-5,"_70":-5,"_71":154},{"_45":142,"_47":48,"_49":143,"_51":144,"_53":54,"_55":135,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":145,"_21":146,"_67":-5,"_68":-5,"_69":-5,"_70":-5,"_71":147},{"_45":135,"_47":48,"_49":136,"_51":137,"_53":54,"_55":128,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":138,"_21":139,"_67":-5,"_68":-5,"_69":-5,"_70":-5,"_71":140},{"_45":128,"_47":48,"_49":129,"_51":130,"_53":54,"_55":121,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":131,"_21":132,"_67":-5,"_68":-5,"_69":-5,"_70":-5,"_71":133},{"_45":121,"_47":48,"_49":122,"_51":123,"_53":54,"_55":114,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":124,"_21":125,"_67":-5,"_68":-5,"_69":-5,"_70":-5,"_71":126},{"_45":114,"_47":48,"_49":115,"_51":116,"_53":54,"_55":107,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":117,"_21":118,"_67":-5,"_68":-5,"_69":-5,"_70":-5,"_71":119},{"_45":107,"_47":48,"_49":108,"_51":109,"_53":54,"_55":99,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":110,"_21":111,"_67":-5,"_68":-5,"_69":-5,"_70":-5,"_71":112},{"_45":99,"_47":48,"_49":100,"_51":101,"_53":54,"_55":102,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":103,"_21":104,"_67":-5,"_68":-5,"_69":-5,"_70":-5,"_71":105},{"_45":91,"_47":48,"_49":92,"_51":93,"_53":54,"_55":84,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":94,"_21":95,"_67":-5,"_68":-5,"_69":-5,"_70":-5,"_71":96},{"_45":84,"_47":48,"_49":85,"_51":86,"_53":54,"_55":46,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":87,"_21":88,"_67":-5,"_68":-5,"_69":-5,"_70":-5,"_71":89},{"_45":46,"_47":48,"_49":50,"_51":52,"_53":54,"_55":56,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":65,"_21":66,"_67":-5,"_68":-5,"_69":-5,"_70":-5,"_71":72},"id","c1ef2e8c-2f87-4842-a0f9-657c85d5e329","branchId","5460a70e-f84d-489f-927c-3f6edf925c52","createdAt",["D",1787867406451],"version",25,"orgId","01a044bf-3eda-702e-a4b3-e30744a846cf","parentId","0fbb42c6-1aa9-4435-8bdc-47aa4337134f","incomingCommitId","aiChatMessageId","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle","source","clientLabel","user",{"_45":80,"_53":54,"_11":81,"_82":83},{"_74":75,"_13":76,"_77":78,"_79":24},"pull","merge","revert","multiple","commits",[73],{"_45":46,"_47":48,"_49":50,"_51":52,"_53":54,"_55":56,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":65,"_21":66,"_67":-5,"_68":-5,"_69":-5},"fileId","442eae24-a261-11f1-8738-1607ee4eb77e","new-file-8743.ts","fileType","script","deleted","c981381e-b02a-44a8-b23a-de5419fdc4f6","antares","avatar","","2e529873-f644-4654-8857-421be22df0dd",["D",1787867409586],26,{"_45":80,"_53":54,"_11":81,"_82":83},{"_74":75,"_13":76,"_77":78,"_79":24},[90],{"_45":84,"_47":48,"_49":85,"_51":86,"_53":54,"_55":46,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":87,"_21":88,"_67":-5,"_68":-5,"_69":-5},"6fb57e1e-0ebd-41b1-bcac-e37127fc3c90",["D",1787867409589],27,{"_45":80,"_53":54,"_11":81,"_82":83},{"_74":75,"_13":76,"_77":98,"_79":24},[97],{"_45":91,"_47":48,"_49":92,"_51":93,"_53":54,"_55":84,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":94,"_21":95,"_67":-5,"_68":-5,"_69":-5},"http","86a28e4b-9ef1-4b31-bc59-21a7581370f6",["D",1787870395781],42,"27fa6288-97c1-45ed-9a72-a2988d4bb5b3",{"_45":80,"_53":54,"_11":81,"_82":83},{"_74":75,"_13":76,"_77":98,"_79":24},[106],{"_45":99,"_47":48,"_49":100,"_51":101,"_53":54,"_55":102,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":103,"_21":104,"_67":-5,"_68":-5,"_69":-5},"13a6673b-2156-4d81-94e9-39b142cd7f50",["D",1787871184500],43,{"_45":80,"_53":54,"_11":81,"_82":83},{"_74":75,"_13":76,"_77":98,"_79":24},[113],{"_45":107,"_47":48,"_49":108,"_51":109,"_53":54,"_55":99,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":110,"_21":111,"_67":-5,"_68":-5,"_69":-5},"6285a4d5-8f84-407c-a5ef-b046811514e6",["D",1787871614912],44,{"_45":80,"_53":54,"_11":81,"_82":83},{"_74":75,"_13":76,"_77":98,"_79":24},[120],{"_45":114,"_47":48,"_49":115,"_51":116,"_53":54,"_55":107,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":117,"_21":118,"_67":-5,"_68":-5,"_69":-5},"5ed051b4-ffbf-4cdc-a267-ca8f776bb951",["D",1787871776074],45,{"_45":80,"_53":54,"_11":81,"_82":83},{"_74":75,"_13":76,"_77":98,"_79":24},[127],{"_45":121,"_47":48,"_49":122,"_51":123,"_53":54,"_55":114,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":124,"_21":125,"_67":-5,"_68":-5,"_69":-5},"5c5e9407-c942-48ab-8d95-f558e3c27767",["D",1787872002221],46,{"_45":80,"_53":54,"_11":81,"_82":83},{"_74":75,"_13":76,"_77":98,"_79":24},[134],{"_45":128,"_47":48,"_49":129,"_51":130,"_53":54,"_55":121,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":131,"_21":132,"_67":-5,"_68":-5,"_69":-5},"18c9910b-9b32-4c23-93d6-c2888eb99748",["D",1787873641348],47,{"_45":80,"_53":54,"_11":81,"_82":83},{"_74":75,"_13":76,"_77":98,"_79":24},[141],{"_45":135,"_47":48,"_49":136,"_51":137,"_53":54,"_55":128,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":138,"_21":139,"_67":-5,"_68":-5,"_69":-5},"dc2b6983-3ba1-4472-98cc-b395a97f36e4",["D",1787873847877],48,{"_45":80,"_53":54,"_11":81,"_82":83},{"_74":75,"_13":76,"_77":98,"_79":24},[148],{"_45":142,"_47":48,"_49":143,"_51":144,"_53":54,"_55":135,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":145,"_21":146,"_67":-5,"_68":-5,"_69":-5},"d9272d47-1a4a-4e92-9b19-69d56a25a300",["D",1787874077001],49,{"_45":80,"_53":54,"_11":81,"_82":83},{"_74":75,"_13":76,"_77":98,"_79":24},[155],{"_45":149,"_47":48,"_49":150,"_51":151,"_53":54,"_55":142,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":152,"_21":153,"_67":-5,"_68":-5,"_69":-5},"3ad05b97-406e-44a5-9415-dba581185146",["D",1787874337942],50,{"_45":80,"_53":54,"_11":81,"_82":83},{"_74":75,"_13":76,"_77":98,"_79":24},[162],{"_45":156,"_47":48,"_49":157,"_51":158,"_53":54,"_55":149,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":159,"_21":160,"_67":-5,"_68":-5,"_69":-5},"39242926-a1a3-4eb5-a375-613952a1568e",["D",1787874477978],51,{"_45":80,"_53":54,"_11":81,"_82":83},{"_74":75,"_13":76,"_77":98,"_79":24},[169],{"_45":163,"_47":48,"_49":164,"_51":165,"_53":54,"_55":156,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":166,"_21":167,"_67":-5,"_68":-5,"_69":-5},"d831fa13-f336-40cd-bd92-bbfdb7a7937a",["D",1787874550480],52,{"_45":80,"_53":54,"_11":81,"_82":83},{"_74":75,"_13":18,"_77":98,"_79":24},[176],{"_45":170,"_47":48,"_49":171,"_51":172,"_53":54,"_55":163,"_57":-5,"_58":-5,"_59":-5,"_60":-5,"_61":-5,"_62":-5,"_63":-5,"_64":173,"_21":174,"_67":-5,"_68":-5,"_69":-5},"deletedAtVersion","c842cd0d-1ecb-4dfa-b1fa-57b54615f415",["D",1787860636222],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Websocket","imageUrl","pinnedFileId","80d68cee-a251-11f1-8a82-1607ee4eb77e","pinPreview",true,"pinMigrated","screenshotVersion","likeCount","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",{"_11":12,"_232":-5},"org",{"_11":12,"_227":228,"_82":-5,"_30":-5,"_229":230,"_231":24},"branch",{"_51":218,"_13":16,"_45":48,"_219":178,"_220":-5,"_221":-5,"_222":-5,"_223":-5,"_224":-5,"_225":14,"_226":12},"isOwned",294,"projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Automations","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_45":178,"_13":14,"_49":413,"_180":-5,"_181":24,"_182":183,"_184":183,"_185":186,"_187":-5,"_30":80,"_188":189,"_190":191,"_192":-5,"_193":-5,"_194":26,"_53":195,"_196":197,"_198":199,"_200":414,"_202":-5,"_203":204,"_205":204,"_206":207,"_208":207,"_209":207,"_210":204,"_211":204,"_64":415,"_213":416,"_215":417,"_217":24},"tree",[273,274,275,276,277,278,279,280,281,282,283,284,285,286,287],"files",[273,274,275,276,277,278,279,280,281,282,283,284,285,286,287],"counts",{"_262":26,"_263":264,"_265":26,"_266":267,"_268":269},"contents",[],{"_45":254,"_47":48,"_74":75,"_13":18,"_255":256,"_77":98,"_51":257,"_55":-5,"_49":258,"_259":172,"_260":-5,"_17":261},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},"c26d9b43-7e04-4733-be54-42d28d38f9b5","content","// 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}",13,["D",1787874550480],"branchVersion","label",[18],"pulls","branches",1,"forks","envVars",{"_270":26,"_272":26},"connections",{"_270":26,"_271":26},"count","unfilledCount","emptyCount",{"_45":405,"_13":406,"_74":407,"_55":-5,"_47":48,"_259":218,"_292":191,"_49":408,"_51":409,"_77":98,"_255":410,"_79":24,"_260":-5,"_296":411,"_17":412},{"_45":397,"_13":398,"_74":399,"_55":-5,"_47":48,"_259":400,"_292":191,"_49":401,"_51":93,"_77":98,"_255":402,"_79":24,"_260":-5,"_296":403,"_17":404},{"_45":388,"_13":389,"_74":390,"_55":-5,"_47":48,"_259":391,"_292":191,"_49":392,"_51":393,"_77":98,"_255":394,"_79":24,"_260":-5,"_296":395,"_17":396},{"_45":379,"_13":380,"_74":381,"_55":-5,"_47":48,"_259":382,"_292":191,"_49":383,"_51":384,"_77":98,"_255":385,"_79":24,"_260":-5,"_296":386,"_17":387},{"_45":373,"_13":374,"_74":189,"_55":-5,"_47":48,"_259":375,"_292":191,"_49":376,"_51":116,"_77":98,"_255":340,"_79":24,"_260":-5,"_296":377,"_17":378},{"_45":254,"_13":18,"_74":75,"_55":-5,"_47":48,"_259":172,"_292":191,"_49":370,"_51":257,"_77":98,"_255":256,"_79":24,"_260":-5,"_296":371,"_17":372},{"_45":361,"_13":362,"_74":363,"_55":-5,"_47":48,"_259":364,"_292":191,"_49":365,"_51":366,"_77":98,"_255":367,"_79":24,"_260":-5,"_296":368,"_17":369},{"_45":352,"_13":353,"_74":354,"_55":-5,"_47":48,"_259":355,"_292":191,"_49":356,"_51":357,"_77":98,"_255":358,"_79":24,"_260":-5,"_296":359,"_17":360},{"_45":343,"_13":344,"_74":345,"_55":-5,"_47":48,"_259":346,"_292":191,"_49":347,"_51":348,"_77":98,"_255":349,"_79":24,"_260":-5,"_296":350,"_17":351},{"_45":335,"_13":336,"_74":337,"_55":-5,"_47":48,"_259":338,"_292":191,"_49":339,"_51":264,"_77":98,"_255":340,"_79":24,"_260":-5,"_296":341,"_17":342},{"_45":326,"_13":327,"_74":328,"_55":-5,"_47":48,"_259":329,"_292":191,"_49":330,"_51":331,"_77":98,"_255":332,"_79":24,"_260":-5,"_296":333,"_17":334},{"_45":317,"_13":318,"_74":319,"_55":-5,"_47":48,"_259":320,"_292":191,"_49":321,"_51":322,"_77":98,"_255":323,"_79":24,"_260":-5,"_296":324,"_17":325},{"_45":308,"_13":309,"_74":310,"_55":-5,"_47":48,"_259":311,"_292":191,"_49":312,"_51":313,"_77":98,"_255":314,"_79":24,"_260":-5,"_296":315,"_17":316},{"_45":299,"_13":300,"_74":301,"_55":-5,"_47":48,"_259":302,"_292":191,"_49":303,"_51":304,"_77":98,"_255":305,"_79":24,"_260":-5,"_296":306,"_17":307},{"_45":288,"_13":289,"_74":290,"_55":-5,"_47":48,"_259":291,"_292":191,"_49":293,"_51":294,"_77":98,"_255":295,"_79":24,"_260":-5,"_296":297,"_17":298},"ab4c315b-9642-42cf-9c09-d6fe3322bc3c","xbts.ts","ed372390-a2f5-11f1-b032-1607ee4eb77e",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}","children",[],[289],"8877efce-f14c-4069-8a5e-e9ecbc94aaf0","test.ts","f1e41a42-a57a-11f1-abab-1607ee4eb77e",195,["D",1788209651018],7,"// Learn more: https://docs.val.town/vals/http/\nexport default async function (req: Request): Promise {\n const res = await fetch(\"https://gra.unaux.com/test.php\", {\n \"headers\": {\n \"User-Agent\":\n \"Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/126.0.0.0 Safari/537.36\",\n \"Accept\":\n \"text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8\",\n \"Accept-Language\": \"en-US,en;q=0.9\",\n },\n \"body\": '{m:\"sohtn\"}',\n \"method\": \"POST\",\n })\n .then((response) => response.text());\n return Response.json({ ok: res });\n}",[],[300],"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}",[],[309],"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}",[],[318],"55fc0475-08f5-4238-8cea-3d28e320125e","rabidrabbit.ts","f4ec545e-a488-11f1-b655-1607ee4eb77e",227,["D",1788230845457],5,"export 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}",[],[327],"279b079e-e13f-45a7-8c8f-0829fdbfd63a","proxy.ts","c6bc9a2e-a480-11f1-bd00-1607ee4eb77e",177,["D",1788100850318],"//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}",[],[336],"217739b2-609d-4304-a6ad-c286962a7e42","nonlogs.ts","eecfe158-a488-11f1-a6c1-1607ee4eb77e",185,["D",1788106266977],3,"//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}",[],[344],"40085def-50f1-4fbd-ad8f-a95ef7e6f4c5","nestexToDB.ts","ba09b360-a585-11f1-b61c-1607ee4eb77e",226,["D",1788227089986],20,"import sqlite from \"https://esm.town/v/std/sqlite/main.ts\";\n\nexport default async function (req: Request): Promise {\n //const orderbooks = { btc: [], usdt: [] };\n\n if (req.method !== \"POST\") {\n return Response.json({ message: \"This val responds to POST requests.\" }, {\n status: 400,\n });\n }\n try {\n const orderbooks = await req.json();\n var today = new Date();\n var dd = String(today.getDate()).padStart(2, \"0\");\n var mm = String(today.getMonth() + 1).padStart(2, \"0\");\n var yyyy = today.getFullYear();\n\n for(let i = 0; i < orderbooks.usdt.length;i++) {\n const usdt = orderbooks.usdt[i];\n var today = new Date();\n var dd = String(today.getDate()).padStart(2, \"0\");\n var mm = String(today.getMonth() + 1).padStart(2, \"0\"); //January is 0!\n var yyyy = today.getFullYear();\n\n const today_date = mm + \"/\" + dd + \"/\" + yyyy;\n\n await sqlite.execute(\n 'INSERT INTO \"nestex\" (\"coin\", \"set\", \"ask_price\", \"ask_volume\", \"bid_price\", \"bid_volume\", \"date\") VALUES (\\'' +\n usdt.ticker_id + '\\', \\'USDT\\', \\'' + usdt.ask_price + '\\',\\'' +\n usdt.ask_volume +\n '\\',\\'' + usdt.bid_price + '\\',\\'' + usdt.bid_volume + '\\',\\'' + today_date + '\\')'\n );\n }\n } catch (e) {\n return Response.json({ message: \"The body of this request was not JSON-encoded.\" }, {\n status: 400,\n });\n }\n \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 //break;\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 const btc = orderbooks.btc[orderbooks.btc.length - 1];\n var today = new Date();\n var dd = String(today.getDate()).padStart(2, \"0\");\n var mm = String(today.getMonth() + 1).padStart(2, \"0\"); //January is 0!\n var yyyy = today.getFullYear();\n\n const today_date = mm + \"/\" + dd + \"/\" + yyyy;\n await sqlite.execute(\n 'INSERT INTO \"nestex\" (\"coin\", \"set\", \"ask_price\", \"ask_volume\", \"bid_price\", \"bid_volume\", \"date\") VALUES (\\'' +\n btc.ticker_id + '\\', \\'BTC\\', \\'' + btc.ask_price + '\\',\\'' +\n btc.ask_volume +\n '\\',\\'' + btc.bid_price + '\\',\\'' + btc.bid_volume + '\\',\\'' + today_date + '\\')'\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 const usdt = orderbooks.usdt[orderbooks.usdt.length - 1];\n var today = new Date();\n var dd = String(today.getDate()).padStart(2, \"0\");\n var mm = String(today.getMonth() + 1).padStart(2, \"0\"); //January is 0!\n var yyyy = today.getFullYear();\n\n const today_date = mm + \"/\" + dd + \"/\" + yyyy;\n\n await sqlite.execute(\n 'INSERT INTO \"nestex\" (\"coin\", \"set\", \"ask_price\", \"ask_volume\", \"bid_price\", \"bid_volume\", \"date\") VALUES (\\'' +\n usdt.ticker_id + '\\', \\'USDT\\', \\'' + usdt.ask_price + '\\',\\'' +\n usdt.ask_volume +\n '\\',\\'' + usdt.bid_price + '\\',\\'' + usdt.bid_volume + '\\',\\'' + today_date + '\\')'\n );\n }\n }*/\n}",[],[353],"0cca265c-66e6-45bd-9ea3-e19fb8c2e9c0","nestex.ts","21fcfabe-a3eb-11f1-8127-1607ee4eb77e",225,["D",1788226867182],29,"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\n //const tickers = [{ticker_id: \"ARRR-USDT\", base_currency:\"ARRR\",target_currency:\"USDT\"}];\n for (let i = 0; i < tickers.length; i++) {\n const entry = tickers[i];\n await 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 \n const respp = await fetch(\"https://auto--ba09b360a58511f1b61c1607ee4eb77e.web.val.run\", {\n method: \"post\",\n headers: {\n 'Accept': 'application/json',\n 'Content-Type': 'application/json'\n },\n\n //make sure to serialize your JSON body\n body: JSON.stringify(orderbooks)\n})\n.then( (response) => { \n response.json();\n});\n return Response.json(respp);\n } \n \n \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}",[],[362],["D",1787874550480],[],[18],"d4d90fef-0324-421f-aa56-8cf3ced524c6","main.ts",175,["D",1788100299878],[],[374],"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}",[],[380],"10b79f9f-3212-4262-b0a1-90a070df55ad","coinw.ts","3bcb8466-a700-11f1-99d9-1607ee4eb77e",290,["D",1788404126479],2,"//Not working\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}",[],[389],"7f4e3414-0bbd-4fe3-95b9-092db909b651","coinw-copy.ts","f36ddd9a-a704-11f1-9c68-1607ee4eb77e",291,["D",1788404136231],"//Not working\nimport { WebSocket } from \"npm:ws\";\nexport default async function (req: Request): Promise {\n const ticker = {\n \"T_USDT\": {\n \"percentChange\": \"0.4266\",\n \"high24hr\": \"0.00613\",\n \"last\": \"0.00515\",\n \"highestBid\": \"0.00514\",\n \"id\": 768,\n \"isFrozen\": 0,\n \"baseVolume\": \"5509872.82642\",\n \"lowestAsk\": \"0.00517\",\n \"low24hr\": \"0.00359\",\n },\n \"MNT_USDT\": {\n \"percentChange\": \"0.0453\",\n \"high24hr\": \"0.562\",\n \"last\": \"0.5584\",\n \"highestBid\": \"0.558\",\n \"id\": 1573,\n \"isFrozen\": 0,\n \"baseVolume\": \"125168.8176\",\n \"lowestAsk\": \"0.5588\",\n \"low24hr\": \"0.532\",\n },\n \"PEPE_USDT\": {\n \"percentChange\": \"-0.0282\",\n \"high24hr\": \"0.0000035058\",\n \"last\": \"0.0000034037\",\n \"highestBid\": \"0.0000033999\",\n \"id\": 1321,\n \"isFrozen\": 0,\n \"baseVolume\": \"2535903.043613005\",\n \"lowestAsk\": \"0.0000034038\",\n \"low24hr\": \"0.0000033669\",\n },\n };\n\n const tickers = Object.keys(ticker);\n let coins = [];\n for (let i = 0; i < tickers.length; i++) {\n let [base, quote] = tickers[i].split(\"_\");\n let coin = {\n symbol: tickers[i],\n base: base,\n quote: quote,\n id: ticker[tickers[i]].id,\n };\n coins.push(coin);\n }\n\n SpotWebsocketPublic(\"wss://ws.futurescw.com\", coins);\n\n function SpotWebsocketPublic(url, coins) {\n const ws = new WebSocket(url);\n const orderbooks = { btc: [], usdt: [] };\n\n for (let i = 0; i < coins.length; i++) {\n ws.on(\"open\", () => {\n // Send subscription message\n //ws.send(JSON.stringify(subscriptionParams));\n\n ws.send(JSON.stringify({\n \"event\": \"sub\",\n \"params\": {\n \"biz\": \"exchange\",\n \"type\": \"depth_snapshot\",\n \"pairCode\": coins[i].id.toString(),\n },\n }));\n\n console.log(\"Subscription sent\");\n\n // Send ping every 10 seconds\n const pingInterval = setInterval(() => {\n ws.send(JSON.stringify({ event: \"ping\" }));\n console.log(\"Ping sent\");\n }, 10000);\n\n // Clean up on close\n ws.on(\"close\", () => clearInterval(pingInterval));\n });\n }\n\n ws.on(\"message\", (data) => {\n const obj = JSON.parse(data.toString());\n if (obj.channel == undefined) {\n console.log(obj);\n const data = JSON.parse(obj.data);\n orderbooks.usdt.push({\n ticker_id: obj.paircode,\n ask_price: data.asks[0][0],\n ask_volume: data.asks[0][1],\n bid_price: data.bids[0][0],\n bid_volume: data.bids[0][1],\n });\n //console.log(aa);\n ws.close();\n if (obj.pairCode == coins[coins.length - 1].id) {\n console.log(\"3nd\");\n }\n }\n });\n\n ws.on(\"error\", (error) => {\n console.log(\" Error:\", error.message);\n ws.close();\n });\n\n // Handle graceful shutdown (equivalent of KeyboardInterrupt)\n process.on(\"SIGINT\", () => {\n console.log(\"Disconnected by user.\");\n ws.close();\n process.exit(0);\n });\n }\n /*SpotWebsocketPublic(\"wss://ws.futurescw.com\", {\n \"event\": \"sub\",\n \"params\": {\n \"biz\": \"exchange\",\n \"type\": \"depth_snapshot\",\n \"pairCode\": \"557\",\n },\n });*/\n}",[],[398],"8784d4bb-ffc9-4eac-b4ec-80cd6bc00977","coinw-copy-copy.ts","4ab6f2e6-a717-11f1-b2a9-1607ee4eb77e",["D",1788495603197],35,"//Working but timeout\nimport { WebSocket } from \"npm:ws\";\n/*\ntype Orderbook = {\n ticker_id: string;\n ask_price: number;\n // more fields...\n};\n\ntype Orderbooks = {\n btc: Orderbook[];\n usdt: Orderbook[];\n};*/\n\nexport default async function handler(req: Request): Promise {\n const ticker_url = \"https://api.coinw.com/api/v1/public?command=returnTicker\";\n\n const ticker = await fetch(ticker_url)\n .then((response) => response.json())\n .catch((error) => console.error(error));\n //console.log(ticker);\n const tickers = Object.keys(ticker.data);\n let coins = [];\n for (let i = 0; i < tickers.length; i++) {\n let [base, quote] = tickers[i].split(\"_\");\n let coin = {\n symbol: tickers[i],\n base: base,\n quote: quote,\n id: ticker.data[tickers[i]].id,\n };\n coins.push(coin);\n }\n const idsToRemove = [\n 81,\n 2144,\n 1685,\n 1309,\n 1684,\n 1495,\n 1828,\n 1999,\n 1814,\n 2134,\n 2143,\n 1550,\n 1467,\n 619,\n 2141,\n 1836,\n 2078,\n 1687,\n 2145,\n 609,\n 2148,\n 2147,\n 2146,\n 673,\n 746,\n 242,\n ];\n coins = coins.filter(({ id }) => !idsToRemove.includes(id));\n coins = coins.filter(({ quote }) => (quote == \"USDT\" || quote == \"BTC\"));\n //console.log(coins);\n //return;\n const iterations = coins.length;\n\n try {\n const orderbooks = await collectOrderbooks(\n \"wss://ws.futurescw.com\",\n coins,\n iterations,\n );\n\n return new Response(JSON.stringify(orderbooks), {\n status: 200,\n headers: {\n \"Content-Type\": \"application/json\",\n },\n });\n } catch (error) {\n console.error(error);\n\n return new Response(\n JSON.stringify({\n error: \"Unable to collect orderbooks\",\n }),\n {\n status: 500,\n headers: {\n \"Content-Type\": \"application/json\",\n },\n },\n );\n }\n}\n\nfunction collectOrderbooks(\n url: string,\n coins: any[],\n iterations: number,\n): Promise

History · neoxa.ts