[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_234":235,"_236":237},"routes/_app.x.$handle.$name",{"_11":12,"_13":14,"_15":16,"_17":18,"_38":-7,"_121":-5,"_19":122,"_123":124,"_125":126,"_127":128,"_129":130,"_21":131,"_132":-5,"_133":-5,"_134":24,"_135":136,"_137":24,"_138":-5,"_139":-5,"_140":141},"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","lorencetang","name","poly-log-fetch-test","branchName","main","path","scan_bsps.ts","project",{"_32":72,"_13":14,"_36":73,"_74":-5,"_75":24,"_76":77,"_78":77,"_79":80,"_81":-5,"_30":68,"_82":-5,"_83":24,"_84":-5,"_85":-5,"_86":26,"_40":41,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":92,"_93":92,"_94":95,"_96":95,"_97":95,"_98":92,"_99":92,"_53":100,"_101":102,"_103":104,"_105":24},"file",{"_63":64,"_13":18,"_65":66,"_67":24,"_71":-5},"isDirectory",false,"page",0,"history",[31],"hasNext","userId",{"_32":33,"_34":35,"_36":37,"_38":39,"_40":41,"_42":43,"_44":-5,"_45":-5,"_46":-5,"_47":-5,"_48":-5,"_49":50,"_51":52,"_53":54,"_21":55,"_56":-5,"_57":-5,"_58":-5,"_59":-5,"_60":61},"id","7ba19fbd-02e8-4a17-a9fd-d59c268c58f8","branchId","2605b7b0-175e-4775-ac85-f322767f4602","createdAt",["D",1787134991245],"version",12,"orgId","01a0186b-55d3-76bb-8f28-5e239a5e05cf","parentId","d249270b-7ed3-4f67-8537-ced753ad9e33","incomingCommitId","aiChatMessageId","aiChatThreadId","aiChatThreadUserId","aiChatThreadTitle","source","mcp","clientLabel","ChatGPT","user",{"_32":68,"_40":41,"_11":12,"_69":70},{"_63":64,"_13":18,"_65":66,"_67":24},"pull","merge","revert","multiple","commits",[62],{"_32":33,"_34":35,"_36":37,"_38":39,"_40":41,"_42":43,"_44":-5,"_45":-5,"_46":-5,"_47":-5,"_48":-5,"_49":50,"_51":52,"_53":54,"_21":55,"_56":-5,"_57":-5,"_58":-5},"fileId","fab292e2-9bb7-11f1-a323-1607ee4eb77e","fileType","script","deleted","b13d5b98-32fd-4204-bf50-fce395eb52e3","avatar","https://lh3.googleusercontent.com/a/ACg8ocKXYNWn4Fg7SDJtPMUkccTZpjUdPW31lGVY1hyWwUNH-uR15Q=s96-c","deletedAtVersion","a2f1e0d0-91b6-40cc-9d83-16ab57c2d902",["D",1787126705138],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Test remote access to Polymarket spike logs","imageUrl","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount","tursoName","tursoHostname","tursoMeasuredAt","pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm",{"_11":12,"_120":70},"org",{"_11":12,"_115":116,"_69":70,"_30":68,"_117":118,"_119":24},"branch",{"_38":106,"_13":16,"_32":35,"_107":72,"_108":-5,"_109":-5,"_110":-5,"_111":-5,"_112":-5,"_113":14,"_114":12},"isOwned",17,"projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","displayName","Lorence Tang","tier","free","canRestrictVals","profileImageUrl","adoptOrgId",{"_32":72,"_13":14,"_36":230,"_74":-5,"_75":24,"_76":77,"_78":77,"_79":80,"_81":-5,"_30":68,"_82":-5,"_83":24,"_84":-5,"_85":-5,"_86":26,"_40":41,"_87":-5,"_88":-5,"_89":-5,"_90":-5,"_91":92,"_93":92,"_94":95,"_96":95,"_97":95,"_98":92,"_99":92,"_53":231,"_101":232,"_103":233,"_105":24},"tree",[162,163,164,165,166,167,168,169],"files",[162,163,164,165,166,167,168,169],"counts",{"_151":26,"_152":153,"_154":26,"_155":156,"_157":158},"contents",[],{"_32":142,"_13":18,"_63":64,"_42":-5,"_34":35,"_143":39,"_144":145,"_36":146,"_38":26,"_65":66,"_147":148,"_67":24,"_149":-5,"_17":150},"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},"a9b5b6d5-a1c3-4bea-8bf2-71692b8f01eb","branchVersion","latest",true,["D",1787134991245],"content","const urls=[['BTC','https://site6666.easycryptofiat.com/jjo3-fetch.log?cb=202608191822'],['ETH','https://site7777.easycryptofiat.com/jjo4-fetch.log?cb=202608191822'],['SOL','https://site8888.easycryptofiat.com/jjo5-fetch.log?cb=202608191822']];\nfor(const [asset,url] of urls){\n const r=await fetch(url,{headers:{'Cache-Control':'no-cache'}}); if(!r.body){console.log(JSON.stringify({asset,error:'no body'}));continue}\n const rd=r.body.getReader(),dec=new TextDecoder(); let buf='',lines=0,bsps=0,entry=0,pnl=0,first='',last=''; const samples:string[]=[];\n while(true){const {value,done}=await rd.read(); if(done)break; buf+=dec.decode(value,{stream:true}); let i; while((i=buf.indexOf('\\n'))>=0){const line=buf.slice(0,i);buf=buf.slice(i+1);lines++; if(!first)first=line.slice(0,40); last=line.slice(0,40); if(line.includes('[BSPS')){bsps++; if(samples.length<20)samples.push(line.slice(0,1200));} if(line.includes('[BSPS_BUY]')&&line.includes('purpose=bsps_entry'))entry++; if(line.includes('[Event PnL]')||line.includes('[BSPS_RESOLVE]')||line.includes('[BSPS] resolved'))pnl++; }}\n console.log(JSON.stringify({asset,status:r.status,cl:r.headers.get('content-length'),lines,bsps,entry,pnl,first,last,samples}));\n}","label",[18],"pulls","branches",1,"forks","envVars",{"_159":26,"_161":26},"connections",{"_159":26,"_160":26},"count","unfilledCount","emptyCount",{"_32":222,"_13":223,"_63":224,"_42":-5,"_34":35,"_143":225,"_144":145,"_36":226,"_38":26,"_65":66,"_147":227,"_67":24,"_149":-5,"_176":228,"_17":229},{"_32":214,"_13":215,"_63":216,"_42":-5,"_34":35,"_143":217,"_144":145,"_36":218,"_38":26,"_65":66,"_147":219,"_67":24,"_149":-5,"_176":220,"_17":221},{"_32":206,"_13":207,"_63":208,"_42":-5,"_34":35,"_143":209,"_144":145,"_36":210,"_38":174,"_65":66,"_147":211,"_67":24,"_149":-5,"_176":212,"_17":213},{"_32":198,"_13":199,"_63":200,"_42":-5,"_34":35,"_143":174,"_144":145,"_36":201,"_38":202,"_65":66,"_147":203,"_67":24,"_149":-5,"_176":204,"_17":205},{"_32":190,"_13":191,"_63":192,"_42":-5,"_34":35,"_143":193,"_144":145,"_36":194,"_38":26,"_65":66,"_147":195,"_67":24,"_149":-5,"_176":196,"_17":197},{"_32":182,"_13":183,"_63":184,"_42":-5,"_34":35,"_143":185,"_144":145,"_36":186,"_38":153,"_65":66,"_147":187,"_67":24,"_149":-5,"_176":188,"_17":189},{"_32":142,"_13":18,"_63":64,"_42":-5,"_34":35,"_143":39,"_144":145,"_36":179,"_38":26,"_65":66,"_147":148,"_67":24,"_149":-5,"_176":180,"_17":181},{"_32":170,"_13":171,"_63":172,"_42":-5,"_34":35,"_143":106,"_144":145,"_36":173,"_38":174,"_65":66,"_147":175,"_67":24,"_149":-5,"_176":177,"_17":178},"63a0a154-7b23-49a1-adb6-a5b077d7dc14","sim_compare.ts","434731de-9bb8-11f1-baad-1607ee4eb77e",["D",1787135935924],3,"type R=Record;\nconst jobs=[\n ['BTC','site6666.easycryptofiat.com','btcusdt'],\n] as const;\nconst dates=['2026-08-03','2026-08-04'];\nconst FEE=0.07, LOT=20, GRID=0.05, ASKLO=.50, ASKH=.90, ALIGN=.005;\nfunction fee(sh:number,p:number){return sh*FEE*p*(1-p)}\nfunction trig(kind:string,r:R){\n if(kind==='BSPS'){\n const a=r.top10w_imb,b=r.imb_delta;if(typeof a!=='number'||typeof b!=='number')return 0;\n if(a>=.30&&b>=.08)return 1;if(a<=-.30&&b<=-.08)return -1;return 0;\n }\n const a=r.top1_imb,b=r.afi_500,c=r.fut_afi_500;if([a,b,c].some(x=>typeof x!=='number'))return 0;\n if(a>=.70&&b>=.60&&c>=.60)return 1;if(a<=-.70&&b<=-.60&&c<=-.60)return -1;return 0;\n}\nfunction init(){return{entries:0,tp:0,resolveWins:0,resolveLosses:0,realized:0,invested:0,fees:0,entryAskSum:0,open:false,side:0,entryAsk:0,cost:0,event:'',lastD2s:null as number|null,events:0,eventsTraded:new Set()}}\nfunction closeTP(s:any,bid:number){const proceeds=LOT*bid, f=fee(LOT,bid);s.realized+=proceeds-f-s.cost;s.fees+=f;s.tp++;s.open=false;s.side=0;s.entryAsk=0;s.cost=0}\nfunction resolve(s:any){if(!s.event)return;if(s.open){const win=(s.lastD2s!==null)&&Math.sign(s.lastD2s)===s.side;const payout=win?LOT:0;s.realized+=payout-s.cost;if(win)s.resolveWins++;else s.resolveLosses++;s.open=false;s.side=0;s.entryAsk=0;s.cost=0;}s.events++}\nasync function runFile(asset:string,url:string){const S:any={BSPS:init(),PSC:init()};const resp=await fetch(url,{headers:{'Cache-Control':'no-cache'}});if(!resp.ok)throw new Error(`${resp.status}`);const rd=resp.body!.getReader(),dec=new TextDecoder();let buf='',cur='';while(1){const {value,done}=await rd.read();if(done)break;buf+=dec.decode(value,{stream:true});let i;while((i=buf.indexOf('\\n'))>=0){const line=buf.slice(0,i);buf=buf.slice(i+1);if(!line)continue;let r:R;try{r=JSON.parse(line)}catch{continue};if(!r.event)continue;if(cur&&r.event!==cur){for(const k of ['BSPS','PSC'])resolve(S[k]);}if(r.event!==cur){cur=r.event;for(const k of ['BSPS','PSC'])S[k].event=cur;}const d=typeof r.d2s==='number'?r.d2s:null;for(const k of ['BSPS','PSC'])S[k].lastD2s=d??S[k].lastD2s;\n for(const k of ['BSPS','PSC']){const s=S[k];if(s.open){const bid=s.side>0?r.poly_up_bid:r.poly_down_bid;if(typeof bid==='number'&&bid>=s.entryAsk+GRID)closeTP(s,bid);}if(!s.open&&typeof d==='number'&&Math.abs(d)>=ALIGN){const dir=trig(k,r);if(dir&&Math.sign(d)===dir){const ask=dir>0?r.poly_up_ask:r.poly_down_ask;if(typeof ask==='number'&&ask>=ASKLO&&ask<=ASKH){const f=fee(LOT,ask);s.entries++;s.invested+=LOT*ask+f;s.fees+=f;s.entryAskSum+=ask;s.cost=LOT*ask+f;s.open=true;s.side=dir;s.entryAsk=ask;s.eventsTraded.add(cur);}}}}\n }}for(const k of ['BSPS','PSC'])resolve(S[k]);for(const k of ['BSPS','PSC']){const s=S[k];s.eventsTraded=s.eventsTraded.size;s.avgEntryAsk=s.entries?s.entryAskSum/s.entries:0;s.roi=s.invested?s.realized/s.invested:0;delete s.entryAskSum;delete s.open;delete s.side;delete s.entryAsk;delete s.cost;delete s.event;delete s.lastD2s;}return{asset,url,...S}}\nfunction aggInit(){return{entries:0,tp:0,resolveWins:0,resolveLosses:0,realized:0,invested:0,fees:0,events:0,eventsTraded:0,avgEntryAskNum:0}}\nfunction merge(a:any,s:any){for(const k of ['entries','tp','resolveWins','resolveLosses','realized','invested','fees','events','eventsTraded'])a[k]+=s[k];a.avgEntryAskNum+=s.avgEntryAsk*s.entries}\nfor(const [asset,h,sym] of jobs){const A:any={BSPS:aggInit(),PSC:aggInit()};for(const d of dates){const url=`https://${h}/${sym}-${d}.jsonl`;const r=await runFile(asset,url);merge(A.BSPS,r.BSPS);merge(A.PSC,r.PSC);console.log(JSON.stringify({type:'day',date:d,asset,BSPS:r.BSPS,PSC:r.PSC}));}for(const k of ['BSPS','PSC']){const a=A[k];a.avgEntryAsk=a.entries?a.avgEntryAskNum/a.entries:0;a.roi=a.invested?a.realized/a.invested:0;a.resolveWinRate=(a.resolveWins+a.resolveLosses)?a.resolveWins/(a.resolveWins+a.resolveLosses):0;delete a.avgEntryAskNum;}console.log(JSON.stringify({type:'asset_total',asset,...A}));}\n","children",[],[171],["D",1787134991245],[],[18],"9c5cde3e-6c9f-4d08-8634-53fcef3718b4","rules.ts","57279200-9ba6-11f1-9fbc-1607ee4eb77e",7,["D",1787127725201],"type R=Record; const urls=[['BTC','https://site6666.easycryptofiat.com/btcusdt-2026-08-07.jsonl'],['ETH','https://site7777.easycryptofiat.com/ethusdt-2026-08-06.jsonl'],['SOL','https://site8888.easycryptofiat.com/solusdt-2026-08-07.jsonl'],['XRP','https://site9999.easycryptofiat.com/xrpusdt-2026-08-07.jsonl']] as const;\nconst th=.01; const cooldown=900;\nconst rules:{[k:string]:(r:R)=>number}={\n top1_60:r=>Math.abs(r.top1_imb||0)>=.60?Math.sign(r.top1_imb):0,\n top1_70:r=>Math.abs(r.top1_imb||0)>=.70?Math.sign(r.top1_imb):0,\n top1_80:r=>Math.abs(r.top1_imb||0)>=.80?Math.sign(r.top1_imb):0,\n top1_60_fut:r=>Math.abs(r.top1_imb||0)>=.60&&Math.abs(r.fut_top1_imb||0)>=.45&&Math.sign(r.top1_imb)===Math.sign(r.fut_top1_imb)?Math.sign(r.top1_imb):0,\n top1_60_afi:r=>Math.abs(r.top1_imb||0)>=.60&&Math.abs(r.afi_500||0)>=.60&&Math.sign(r.top1_imb)===Math.sign(r.afi_500)?Math.sign(r.top1_imb):0,\n top1_60_futafi:r=>Math.abs(r.top1_imb||0)>=.60&&Math.abs(r.fut_afi_500||0)>=.60&&Math.sign(r.top1_imb)===Math.sign(r.fut_afi_500)?Math.sign(r.top1_imb):0,\n top1_60_dualafi:r=>Math.abs(r.top1_imb||0)>=.60&&Math.abs(r.afi_500||0)>=.55&&Math.abs(r.fut_afi_500||0)>=.55&&Math.sign(r.top1_imb)===Math.sign(r.afi_500)&&Math.sign(r.top1_imb)===Math.sign(r.fut_afi_500)?Math.sign(r.top1_imb):0,\n top1_70_dualafi:r=>Math.abs(r.top1_imb||0)>=.70&&Math.abs(r.afi_500||0)>=.60&&Math.abs(r.fut_afi_500||0)>=.60&&Math.sign(r.top1_imb)===Math.sign(r.afi_500)&&Math.sign(r.top1_imb)===Math.sign(r.fut_afi_500)?Math.sign(r.top1_imb):0,\n current_bsps:r=>Math.abs(r.top10w_imb||0)>=.30&&Math.abs(r.imb_delta||0)>=.08&&Math.sign(r.top10w_imb)===Math.sign(r.imb_delta)?Math.sign(r.top10w_imb):0,\n};\nasync function one(asset:string,url:string){const a:any={};for(const k in rules)a[k]={n:0,pos:0,hit:0,wrong:0,small:0,sum:0,last:-1e9}; const res=await fetch(url); const rd=res.body!.getReader(),dec=new TextDecoder();let buf='',q:any[]=[],ev='';while(1){const {value,done}=await rd.read();if(done)break;buf+=dec.decode(value,{stream:true});let i;while((i=buf.indexOf('\\n'))>=0){const s=buf.slice(0,i);buf=buf.slice(i+1);if(!s)continue;let r:R;try{r=JSON.parse(s)}catch{continue};const t=Date.parse(r.ts),px=r.spot_mid;if(!Number.isFinite(t)||typeof px!=='number')continue;if(r.event!==ev){q=[];ev=r.event}const ds:any={};for(const [k,f] of Object.entries(rules))ds[k]=f(r);q.push({t,px,ds,ev:r.event});while(q.length&&t-q[0].t>=950){const c=q.shift(),dt=t-c.t;if(dt>1150||c.ev!==r.event)continue;const ret=(px/c.px-1)*100;for(const [k,d] of Object.entries(c.ds)){if(!d)continue;const x=a[k];if(c.t-x.last0)x.pos++;if(dr>=th)x.hit++;else if(dr<=-th)x.wrong++;else x.small++;}}}}for(const k in a){const x=a[k];a[k]={n:x.n,posRate:x.n?x.pos/x.n:0,hitRate:x.n?x.hit/x.n:0,wrongRate:x.n?x.wrong/x.n:0,meanDirRetPct:x.n?x.sum/x.n:0,hit:x.hit,wrong:x.wrong};}return{asset,a}}\nfor(const [asset,url] of urls) console.log(JSON.stringify(await one(asset,url)));",[],[183],"deb32253-5552-4a56-bf74-89a49aa80624","probe_overlap.ts","0e283066-9bb8-11f1-bb0c-1607ee4eb77e",13,["D",1787135023893],"const sets=[['BTC','site6666.easycryptofiat.com','btcusdt'],['ETH','site7777.easycryptofiat.com','ethusdt'],['SOL','site8888.easycryptofiat.com','solusdt']]; const dates=['2026-08-15','2026-08-16','2026-08-17','2026-08-18','2026-08-19'];\nasync function p(url:string){try{const r=await fetch(url,{headers:{'Cache-Control':'no-cache'}}); if(!r.body)return {status:r.status}; const rd=r.body.getReader();let txt='';const dec=new TextDecoder();while(txt.length<20000&&!txt.includes('\\n')){const {value,done}=await rd.read();if(done||!value)break;txt+=dec.decode(value,{stream:true})}await rd.cancel();const line=txt.split('\\n')[0];let j:any=null;try{j=JSON.parse(line)}catch{}return{status:r.status,cl:r.headers.get('content-length'),ok:!!j,event:j?.event,ts:j?.ts}}catch(e){return{error:String(e)}}}\nfor(const [asset,h,s] of sets)for(const d of dates){const url=`https://${h}/${s}-${d}.jsonl`;console.log(JSON.stringify({asset,d,url,...await p(url)}))}",[],[191],"f102632c-b961-4c0d-9a84-f564ae262ecb","main.ts","afd4fb74-9ba4-11f1-8a66-1607ee4eb77e",["D",1787126986902],2,"const sets = [\n {host:'site6666.easycryptofiat.com', sym:'btcusdt', dates:['2026-07-30','2026-07-31','2026-08-01','2026-08-02','2026-08-03','2026-08-04','2026-08-05','2026-08-06','2026-08-07']},\n {host:'site7777.easycryptofiat.com', sym:'ethusdt', dates:['2026-07-30','2026-07-31','2026-08-01','2026-08-02','2026-08-03','2026-08-04','2026-08-05','2026-08-06']},\n {host:'site8888.easycryptofiat.com', sym:'solusdt', dates:['2026-07-30','2026-07-31','2026-08-01','2026-08-02','2026-08-03','2026-08-04','2026-08-05','2026-08-06','2026-08-07']},\n {host:'site9999.easycryptofiat.com', sym:'xrpusdt', dates:['2026-07-30','2026-07-31','2026-08-01','2026-08-02','2026-08-03','2026-08-04','2026-08-05','2026-08-06','2026-08-07']},\n];\nasync function probe(url:string){\n const r = await fetch(url,{headers:{'Cache-Control':'no-cache'}});\n const reader = r.body?.getReader();\n const dec = new TextDecoder();\n let txt='';\n if(reader){\n while(txt.length<65536 && !txt.includes('\\n')){\n const {value,done}=await reader.read(); if(done||!value) break;\n txt += dec.decode(value,{stream:true});\n }\n await reader.cancel();\n }\n const line=(txt.split('\\n')[0]||'').trim();\n let parsed:any=null; let err='';\n try{ parsed=JSON.parse(line); }catch(e){err=String(e);}\n return {status:r.status,cl:r.headers.get('content-length'),ct:r.headers.get('content-type'),ok_json:!!parsed,event:parsed?.event,ts:parsed?.ts,keys:parsed?Object.keys(parsed).length:0,err};\n}\nfor(const s of sets){\n for(const d of s.dates){\n for(const mid of [false,true]){\n const url=`https://${s.host}/${s.sym}-${d}${mid?'.mid':''}.jsonl`;\n try { console.log(JSON.stringify({url,...await probe(url)})); }\n catch(e){ console.log(JSON.stringify({url,error:String(e)})); }\n }\n }\n}\n",[],[199],"e58c66fe-6835-4baa-89ac-7145a9111c37","latestcheck.ts","86bcddd4-9ba8-11f1-ba83-1607ee4eb77e",11,["D",1787128680106],"type R=Record;\nconst url='https://site9999.easycryptofiat.com/xrpusdt-2026-08-07.jsonl';\nconst names=['top1_80','top1_70_dualafi','current_bsps'];\nfunction rule(n:string,r:R){if(n==='top1_80')return Math.abs(r.top1_imb||0)>=.80?Math.sign(r.top1_imb):0;if(n==='top1_70_dualafi')return Math.abs(r.top1_imb||0)>=.70&&Math.abs(r.afi_500||0)>=.60&&Math.abs(r.fut_afi_500||0)>=.60&&Math.sign(r.top1_imb)===Math.sign(r.afi_500)&&Math.sign(r.top1_imb)===Math.sign(r.fut_afi_500)?Math.sign(r.top1_imb):0;return Math.abs(r.top10w_imb||0)>=.30&&Math.abs(r.imb_delta||0)>=.08&&Math.sign(r.top10w_imb)===Math.sign(r.imb_delta)?Math.sign(r.top10w_imb):0}\nconst a:any={};for(const n of names)a[n]={n:0,hit:0,wrong:0,pos:0,sum:0,last:-1e15};const f:any={top1_imb:[0,0],top10w_imb:[0,0],imb_delta:[0,0],afi_500:[0,0],fut_afi_500:[0,0]};const res=await fetch(url),rd=res.body!.getReader(),dec=new TextDecoder();let buf='',q:any[]=[],ev='',rows=0,sp=0;while(1){const {value,done}=await rd.read();if(done)break;buf+=dec.decode(value,{stream:true});let i;while((i=buf.indexOf('\\n'))>=0){const s=buf.slice(0,i);buf=buf.slice(i+1);if(!s)continue;let r:R;try{r=JSON.parse(s)}catch{continue};rows++;const t=Date.parse(r.ts),px=r.spot_mid;if(!Number.isFinite(t)||typeof px!=='number')continue;if(r.event!==ev){q=[];ev=r.event}const ds:any={};for(const n of names)ds[n]=rule(n,r);const fv:any={};for(const k in f)fv[k]=r[k];q.push({t,px,ev:r.event,ds,fv});while(q.length&&t-q[0].t>=950){const c=q.shift(),dt=t-c.t;if(dt>1150||c.ev!==r.event)continue;const ret=(px/c.px-1)*100,d=ret>0?1:-1;if(Math.abs(ret)>=.01){sp++;for(const k in f){const v=c.fv[k];if(typeof v==='number'&&v!==0){f[k][0]++;if(Math.sign(v)===d)f[k][1]++;}}}for(const n of names){const dir=c.ds[n],x=a[n];if(!dir||c.t-x.last<900)continue;x.last=c.t;x.n++;const dr=ret*dir;x.sum+=dr;if(dr>0)x.pos++;if(dr>=.01)x.hit++;else if(dr<=-.01)x.wrong++;}}}}\nfor(const n of names){const x=a[n];a[n]={n:x.n,posRate:x.pos/x.n,hitRate:x.hit/x.n,wrongRate:x.wrong/x.n,condLargeAcc:x.hit/(x.hit+x.wrong),mean:x.sum/x.n,hit:x.hit,wrong:x.wrong}};const ff:any={};for(const k in f)ff[k]=f[k][1]/f[k][0];console.log(JSON.stringify({url,rows,spikes01:sp,rules:a,dirAcc:ff}));",[],[207],"807bdd94-dfb9-4698-86d1-ecc104aa0f3b","analyze.ts","19d2bfec-9ba6-11f1-be03-1607ee4eb77e",4,["D",1787127312518],"type Row = Record;\nconst TEST_URLS = [\n 'https://site6666.easycryptofiat.com/btcusdt-2026-07-30.jsonl',\n 'https://site7777.easycryptofiat.com/ethusdt-2026-07-30.jsonl',\n 'https://site8888.easycryptofiat.com/solusdt-2026-07-30.jsonl',\n 'https://site9999.easycryptofiat.com/xrpusdt-2026-07-30.jsonl',\n];\nconst THRS = [0.005,0.01,0.02,0.05]; // pct points, matching NC-style 1s returns\nconst feats = ['top1_imb','top5w_imb','top10w_imb','ofi','ofi_delta','ofi_slope','imb_delta','imb_slope','micro_disp','micro_vel','micro_accel','afi_100','afi_250','afi_500','afi_1s','afi_2s','flow_accel','tcount_accel','fut_top1_imb','fut_top5w_imb','fut_ofi','fut_micro_disp','fut_micro_vel','fut_micro_accel','fut_afi_500','fut_afi_1s','spot_fut_lead','basis_vel','basis_accel'];\nfunction num(x:any){return typeof x==='number' && Number.isFinite(x)?x:null}\nfunction sig(x:any){const v=num(x); return v===null||v===0?0:(v>0?1:-1)}\nfunction derived(r:Row){\n const biddep=num(r.bid_depl_spd)||0, askdep=num(r.ask_depl_spd)||0;\n const badd=num(r.bid_added)||0, brm=num(r.bid_removed)||0, aadd=num(r.ask_added)||0, arm=num(r.ask_removed)||0;\n return {\n book_depl_pressure: askdep-biddep,\n book_flow_pressure: badd+arm-brm-aadd,\n large_trade_dir:(num(r.large_buy)||0)-(num(r.large_sell)||0),\n consec_trade_dir:(num(r.consec_buy)||0)-(num(r.consec_sell)||0),\n };\n}\nconst allFeats=[...feats,'book_depl_pressure','book_flow_pressure','large_trade_dir','consec_trade_dir'];\nconst rules:{[k:string]:(r:Row)=>number}={\n current_bsps:(r)=>{const a=num(r.top10w_imb),b=num(r.imb_delta); if(a===null||b===null) return 0; return Math.abs(a)>=.3&&Math.abs(b)>=.08&&Math.sign(a)===Math.sign(b)?Math.sign(a):0},\n book_flow:(r)=>{const a=num(r.top5w_imb),b=num(r.afi_500); if(a===null||b===null) return 0; return Math.abs(a)>=.5&&Math.abs(b)>=.6&&Math.sign(a)===Math.sign(b)?Math.sign(a):0},\n dual_flow:(r)=>{const a=num(r.afi_500),b=num(r.fut_afi_500); if(a===null||b===null) return 0; return Math.abs(a)>=.6&&Math.abs(b)>=.6&&Math.sign(a)===Math.sign(b)?Math.sign(a):0},\n fut_flow_micro:(r)=>{const a=num(r.fut_afi_500),b=num(r.fut_micro_vel); if(a===null||b===null) return 0; return Math.abs(a)>=.7&&b!==0&&Math.sign(a)===Math.sign(b)?Math.sign(a):0},\n book_fut:(r)=>{const a=num(r.top5w_imb),b=num(r.fut_afi_500); if(a===null||b===null) return 0; return Math.abs(a)>=.5&&Math.abs(b)>=.6&&Math.sign(a)===Math.sign(b)?Math.sign(a):0},\n triple:(r)=>{const a=num(r.top5w_imb),b=num(r.afi_500),c=num(r.fut_afi_500); if([a,b,c].some(x=>x===null)) return 0; return Math.abs(a!)>=.45&&Math.abs(b!)>=.55&&Math.abs(c!)>=.55&&Math.sign(a!)===Math.sign(b!)&&Math.sign(a!)===Math.sign(c!)?Math.sign(a!):0},\n flow_accel_fut:(r)=>{const a=num(r.flow_accel),b=num(r.fut_afi_500); if(a===null||b===null) return 0; return Math.abs(a)>=.7&&Math.abs(b)>=.6&&Math.sign(a)===Math.sign(b)?Math.sign(a):0},\n ofi_book:(r)=>{const a=num(r.top5w_imb),b=num(r.ofi_slope); if(a===null||b===null) return 0; return Math.abs(a)>=.45&&Math.sign(a)===Math.sign(b)&&b!==0?Math.sign(a):0},\n};\nfunction initAgg(){\n const f:any={}; for(const k of allFeats) f[k]={n:0,sum:0,sumsq:0,sp:{}};\n const rr:any={}; for(const k of Object.keys(rules)) rr[k]={last:-1e99,n:0,retSum:0,pos:0,th:{}};\n return {rows:0,pairs:0,spikes:Object.fromEntries(THRS.map(t=>[t,0])),f,rules:rr};\n}\nfunction updFeature(agg:any,k:string,v:number,retPct:number){\n const a=agg.f[k]; a.n++; a.sum+=v; a.sumsq+=v*v;\n for(const th of THRS){ if(Math.abs(retPct)>=th){const d=retPct>0?1:-1; const s=a.sp[th]||(a.sp[th]={n:0,align:0,sumAlign:0,sumAbs:0}); s.n++; if(Math.sign(v)===d) s.align++; s.sumAlign+=v*d; s.sumAbs+=Math.abs(v);} }\n}\nfunction updRule(agg:any,name:string,dir:number,retPct:number,tms:number){\n if(!dir) return; const a=agg.rules[name]; if(tms-a.last<900) return; a.last=tms; a.n++; const dr=retPct*dir; a.retSum+=dr; if(dr>0)a.pos++;\n for(const th of THRS){const s=a.th[th]||(a.th[th]={hit:0,wrong:0,small:0}); if(dr>=th)s.hit++; else if(dr<=-th)s.wrong++; else s.small++;}\n}\nasync function analyze(url:string){\n const agg=initAgg(); const r=await fetch(url,{headers:{'Cache-Control':'no-cache'}}); if(!r.body) throw new Error('no body');\n const reader=r.body.getReader(); const dec=new TextDecoder(); let buf=''; const q:any[]=[]; let currentEvent='';\n while(true){const {value,done}=await reader.read(); if(done)break; buf+=dec.decode(value,{stream:true}); let p; while((p=buf.indexOf('\\n'))>=0){const line=buf.slice(0,p); buf=buf.slice(p+1); if(!line)continue; let row:Row; try{row=JSON.parse(line)}catch{continue}; agg.rows++;\n const t=Date.parse(row.ts); const px=num(row.spot_mid); if(!Number.isFinite(t)||px===null)continue;\n if(row.event!==currentEvent){q.length=0; currentEvent=row.event}\n const d=derived(row); const vals:any={}; for(const k of feats) vals[k]=row[k]; Object.assign(vals,d);\n const ruleDirs:any={}; for(const [name,fn] of Object.entries(rules)) ruleDirs[name]=fn({...row,...d});\n q.push({t,px,event:row.event,vals,ruleDirs});\n while(q.length && t-q[0].t>=950){const c=q.shift(); const dt=t-c.t; if(dt>1150||c.event!==row.event)continue; const ret=(px/c.px-1)*100; agg.pairs++; for(const th of THRS) if(Math.abs(ret)>=th) agg.spikes[th]++;\n for(const k of allFeats){const v=num(c.vals[k]); if(v!==null)updFeature(agg,k,v,ret)}\n for(const [name,dir] of Object.entries(c.ruleDirs)) updRule(agg,name,dir as number,ret,c.t);\n }\n }}\n const out:any={url,rows:agg.rows,pairs:agg.pairs,spikes:agg.spikes,features:{},rules:{}};\n for(const k of allFeats){const a=agg.f[k]; const mean=a.n?a.sum/a.n:0; const sd=a.n?Math.sqrt(Math.max(0,a.sumsq/a.n-mean*mean)):0; const o:any={}; for(const th of THRS){const s=a.sp[th]; if(s)o[th]={n:s.n,dirAcc:s.n?s.align/s.n:null,alignedZ:sd?s.sumAlign/s.n/sd:null,meanAbs:s.sumAbs/s.n};} out.features[k]=o;}\n for(const [k,a] of Object.entries(agg.rules)){const o:any={n:a.n,meanDirRetPct:a.n?a.retSum/a.n:null,posRate:a.n?a.pos/a.n:null,th:{}}; for(const th of THRS){const s=a.th[th]||{hit:0,wrong:0,small:0}; o.th[th]={hitRate:a.n?s.hit/a.n:null,wrongRate:a.n?s.wrong/a.n:null,smallRate:a.n?s.small/a.n:null,hit:s.hit,wrong:s.wrong};} out.rules[k]=o;}\n return out;\n}\nfor(const url of TEST_URLS){const t0=Date.now(); try{const out=await analyze(url); console.log(JSON.stringify({sec:(Date.now()-t0)/1000,...out}));}catch(e){console.log(JSON.stringify({url,error:String(e)}));}}\n",[],[215],"5fa30dab-421b-45a9-b57f-77f70acbbdfa","allrules.ts","8671e150-9ba6-11f1-aaa4-1607ee4eb77e",6,["D",1787127494759],"type R=Record;\nconst sets:any={BTC:{h:'site6666.easycryptofiat.com',s:'btcusdt',d:['2026-07-30','2026-07-31','2026-08-01','2026-08-02','2026-08-03','2026-08-04','2026-08-05','2026-08-06','2026-08-07']},ETH:{h:'site7777.easycryptofiat.com',s:'ethusdt',d:['2026-07-30','2026-07-31','2026-08-01','2026-08-02','2026-08-03','2026-08-04','2026-08-05','2026-08-06']},SOL:{h:'site8888.easycryptofiat.com',s:'solusdt',d:['2026-07-30','2026-07-31','2026-08-01','2026-08-02','2026-08-03','2026-08-04','2026-08-05','2026-08-06','2026-08-07']},XRP:{h:'site9999.easycryptofiat.com',s:'xrpusdt',d:['2026-07-30','2026-07-31','2026-08-01','2026-08-02','2026-08-03','2026-08-04','2026-08-05','2026-08-06','2026-08-07']}};\nconst rules:{[k:string]:(r:R)=>number}={\n top1_80:r=>Math.abs(r.top1_imb||0)>=.80?Math.sign(r.top1_imb):0,\n top1_70_dualafi:r=>Math.abs(r.top1_imb||0)>=.70&&Math.abs(r.afi_500||0)>=.60&&Math.abs(r.fut_afi_500||0)>=.60&&Math.sign(r.top1_imb)===Math.sign(r.afi_500)&&Math.sign(r.top1_imb)===Math.sign(r.fut_afi_500)?Math.sign(r.top1_imb):0,\n top1_60_dualafi:r=>Math.abs(r.top1_imb||0)>=.60&&Math.abs(r.afi_500||0)>=.55&&Math.abs(r.fut_afi_500||0)>=.55&&Math.sign(r.top1_imb)===Math.sign(r.afi_500)&&Math.sign(r.top1_imb)===Math.sign(r.fut_afi_500)?Math.sign(r.top1_imb):0,\n current_bsps:r=>Math.abs(r.top10w_imb||0)>=.30&&Math.abs(r.imb_delta||0)>=.08&&Math.sign(r.top10w_imb)===Math.sign(r.imb_delta)?Math.sign(r.top10w_imb):0,\n};\nconst featNames=['top1_imb','top5w_imb','top10w_imb','imb_delta','ofi_slope','afi_100','afi_500','afi_1s','fut_top1_imb','fut_top5w_imb','fut_afi_500','fut_afi_1s','fut_micro_vel'];\nfunction init(){const a:any={rows:0,pairs:0,sp:0,rules:{},feat:{}};for(const k in rules)a.rules[k]={n:0,hit:0,wrong:0,pos:0,sum:0,last:-1e15};for(const k of featNames)a.feat[k]={n:0,align:0};return a}\nasync function file(asset:string,url:string){const a=init(),resp=await fetch(url,{headers:{'Accept-Encoding':'gzip','Cache-Control':'no-cache'}}),rd=resp.body!.getReader(),dec=new TextDecoder();let buf='',q:any[]=[],ev='';while(1){const {value,done}=await rd.read();if(done)break;buf+=dec.decode(value,{stream:true});let i;while((i=buf.indexOf('\\n'))>=0){const s=buf.slice(0,i);buf=buf.slice(i+1);if(!s)continue;let r:R;try{r=JSON.parse(s)}catch{continue};a.rows++;const t=Date.parse(r.ts),px=r.spot_mid;if(!Number.isFinite(t)||typeof px!=='number')continue;if(r.event!==ev){q=[];ev=r.event}const ds:any={};for(const [k,f] of Object.entries(rules))ds[k]=f(r);const fv:any={};for(const k of featNames)fv[k]=r[k];q.push({t,px,ev:r.event,ds,fv});while(q.length&&t-q[0].t>=950){const c=q.shift(),dt=t-c.t;if(dt>1150||c.ev!==r.event)continue;a.pairs++;const ret=(px/c.px-1)*100,d=ret>0?1:-1;if(Math.abs(ret)>=.01){a.sp++;for(const k of featNames){const v=c.fv[k];if(typeof v==='number'&&v!==0){a.feat[k].n++;if(Math.sign(v)===d)a.feat[k].align++;}}}for(const [k,dir] of Object.entries(c.ds)){if(!dir)continue;const x=a.rules[k];if(c.t-x.last<900)continue;x.last=c.t;x.n++;const dr=ret*dir;x.sum+=dr;if(dr>0)x.pos++;if(dr>=.01)x.hit++;else if(dr<=-.01)x.wrong++;}}}}return{asset,url,a}}\nfunction merge(dst:any,src:any){dst.rows+=src.rows;dst.pairs+=src.pairs;dst.sp+=src.sp;for(const k in dst.rules){const d=dst.rules[k],s=src.rules[k];d.n+=s.n;d.hit+=s.hit;d.wrong+=s.wrong;d.pos+=s.pos;d.sum+=s.sum;}for(const k of featNames){dst.feat[k].n+=src.feat[k].n;dst.feat[k].align+=src.feat[k].align}}\nasync function pool(tasks:any[],n=6){const out:any[]=[];let ix=0;async function w(){while(1){const i=ix++;if(i>=tasks.length)return;const t=tasks[i];try{out.push(await file(t.asset,t.url));}catch(e){out.push({asset:t.asset,url:t.url,error:String(e)})}}}await Promise.all(Array.from({length:n},w));return out}\nconst tasks:any[]=[];for(const [asset,x] of Object.entries(sets))for(const d of x.d)tasks.push({asset,url:`https://${x.h}/${x.s}-${d}.jsonl`});const t0=Date.now(),res=await pool(tasks,8);for(const asset of Object.keys(sets)){const z=init();let ok=0,err=0;for(const r of res.filter(x=>x.asset===asset)){if(r.error)err++;else{ok++;merge(z,r.a)}}const rr:any={};for(const k in z.rules){const x=z.rules[k];rr[k]={n:x.n,posRate:x.n?x.pos/x.n:0,hitRate:x.n?x.hit/x.n:0,wrongRate:x.n?x.wrong/x.n:0,meanDirRetPct:x.n?x.sum/x.n:0,hit:x.hit,wrong:x.wrong}}const ff:any={};for(const k of featNames){const x=z.feat[k];ff[k]=x.n?x.align/x.n:null}console.log(JSON.stringify({asset,ok,err,rows:z.rows,pairs:z.pairs,spikes01:z.sp,rules:rr,dirAccSpike01:ff}));}console.log(JSON.stringify({sec:(Date.now()-t0)/1000,errors:res.filter(x=>x.error).map(x=>({url:x.url,error:x.error}))}));",[],[223],["D",1787126705138],{"_11":12,"_120":70},{"_11":12,"_115":116,"_69":70,"_30":68,"_117":118,"_119":24},{"_38":106,"_13":16,"_32":35,"_107":72,"_108":-5,"_109":-5,"_110":-5,"_111":-5,"_112":-5,"_113":14,"_114":12},"ctx",{"_53":-5,"_139":267,"_268":269,"_270":271,"_272":24,"_273":24,"_274":24,"_275":145,"_276":-5,"_277":-7,"_278":-7,"_279":26,"_280":24,"_281":24,"_282":-5,"_283":24,"_284":24,"_285":24,"_286":-5},"ENV",{"_238":239,"_240":241,"_242":16,"_243":244,"_245":246,"_247":248,"_249":250,"_251":252,"_253":254,"_255":256,"_257":258,"_259":260,"_261":262,"_263":264,"_265":266},"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"]

History · scan_bsps.ts