[{"_1":2,"_3":-5,"_4":-5},"loaderData",{"_5":6,"_7":8,"_9":10},"actionData","errors","root",{"_287":288,"_289":290},"routes/_app.x.$handle.$name",{"_96":95,"_31":43,"_105":86,"_26":106,"_13":14,"_107":-5,"_11":108,"_109":110,"_111":112,"_113":114,"_115":116,"_20":-5,"_117":-5,"_118":-5,"_119":24,"_120":121,"_122":24,"_123":-5,"_124":-5,"_125":126},"routes/_app.x.$handle.$name.branch.$branch.version.$version.diff",{"_11":12,"_13":14,"_15":16,"_17":-5,"_18":-5},"project",{"_41":42,"_31":43,"_36":44,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":-5,"_55":24,"_56":-5,"_57":-5,"_58":59,"_60":61,"_62":63,"_64":65,"_66":67,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":79,"_80":81,"_82":83,"_84":24},"version",12,"changes",[19],"aiChatInfo","userId",{"_20":21,"_22":-7,"_23":24,"_25":24,"_26":27,"_28":27},"file",{"_29":30,"_31":27,"_32":33,"_34":35,"_36":37,"_38":14,"_39":40,"_23":24},"previous","deleted",false,"deletedHere","path","replay_eth_old.ts","latestPath","fileId","c6ffc470-a08e-11f1-ad56-1607ee4eb77e","name","fileType","script","content","import { replaySource } from './replaylib.ts'; await replaySource('ETH','old','https://site7777.easycryptofiat.com/jjo4-fetch.log.old');","createdAt",["D",1787667050957],"branchVersion","branchId","da574ad5-1c4b-4e39-8d72-c25b03e25b98","id","de6795fa-952c-4199-b561-e9d7eb1cf742","bsps-replay-analysis",["D",1787666565619],"deletedAt","legacyEnvVars","privacy","public","httpPrivacy","description","Replay BSPS old/current logs and test systematic sizing","imageUrl","b13d5b98-32fd-4204-bf50-fce395eb52e3","pinnedFileId","pinPreview","pinMigrated","screenshotVersion","likeCount",0,"orgId","01a0186b-55d3-76bb-8f28-5e239a5e05cf","tursoName","de6795fa952c4199b561e9d7eb1cf742","tursoHostname","de6795fa952c4199b561e9d7eb1cf742-val-town.aws-us-east-2.turso.io","tursoMeasuredAt",["D",1789488693443],"pinned","userPerm","r","valPerm","blobPerm","rw","emailPerm","sqlitePerm","projectPerm","telemetryPerm","user",{"_96":95,"_104":100},"org",{"_96":95,"_97":98,"_99":100,"_18":53,"_101":102,"_103":24},"branch",{"_13":85,"_31":86,"_41":40,"_87":42,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":43,"_94":95},"isOwned",42,"main","projectId","forkedBranchId","forkedBranchVersion","forkedProjectPrivacy","forkedProjectId","forkedProjectOrgId","projectName","userHandle","lorencetang","handle","displayName","Lorence Tang","avatar","https://lh3.googleusercontent.com/a/ACg8ocKXYNWn4Fg7SDJtPMUkccTZpjUdPW31lGVY1hyWwUNH-uR15Q=s96-c","tier","free","canRestrictVals","profileImageUrl","branchName","","adoptOrgId",{"_41":42,"_31":43,"_36":282,"_45":-5,"_46":24,"_47":48,"_49":48,"_50":51,"_52":-5,"_18":53,"_54":-5,"_55":24,"_56":-5,"_57":-5,"_58":59,"_60":61,"_62":63,"_64":65,"_66":283,"_68":-5,"_69":70,"_71":70,"_72":73,"_74":73,"_75":73,"_76":70,"_77":70,"_78":284,"_80":285,"_82":286,"_84":24},"tree",[233,234,235,236,237,238,239,240,241,242,243,244],"files",[233,234,235,236,237,238,239,240,241,242,243,244],"counts",{"_223":59,"_224":184,"_225":59,"_226":227,"_228":229},"contents",[127,128,129,130,131,132,133,134,135,136,137,138],"upstreamProject","upstreamBranch","emptyEnvVars","flags",[],"hasHttpFiles","grants","orgs","customDomains",{},{"_41":216,"_31":217,"_29":218,"_142":-5,"_39":40,"_38":219,"_144":145,"_36":220,"_13":59,"_32":33,"_34":221,"_23":24,"_148":-5,"_26":222},{"_41":209,"_31":210,"_29":211,"_142":-5,"_39":40,"_38":212,"_144":145,"_36":213,"_13":59,"_32":33,"_34":214,"_23":24,"_148":-5,"_26":215},{"_41":202,"_31":203,"_29":204,"_142":-5,"_39":40,"_38":205,"_144":145,"_36":206,"_13":59,"_32":33,"_34":207,"_23":24,"_148":-5,"_26":208},{"_41":195,"_31":196,"_29":197,"_142":-5,"_39":40,"_38":198,"_144":145,"_36":199,"_13":59,"_32":33,"_34":200,"_23":24,"_148":-5,"_26":201},{"_41":188,"_31":189,"_29":190,"_142":-5,"_39":40,"_38":191,"_144":145,"_36":192,"_13":59,"_32":33,"_34":193,"_23":24,"_148":-5,"_26":194},{"_41":181,"_31":182,"_29":183,"_142":-5,"_39":40,"_38":184,"_144":145,"_36":185,"_13":59,"_32":33,"_34":186,"_23":24,"_148":-5,"_26":187},{"_41":174,"_31":175,"_29":176,"_142":-5,"_39":40,"_38":177,"_144":145,"_36":178,"_13":59,"_32":33,"_34":179,"_23":24,"_148":-5,"_26":180},{"_41":167,"_31":168,"_29":169,"_142":-5,"_39":40,"_38":170,"_144":145,"_36":171,"_13":59,"_32":33,"_34":172,"_23":24,"_148":-5,"_26":173},{"_41":164,"_31":27,"_29":30,"_142":-5,"_39":40,"_38":14,"_144":145,"_36":165,"_13":59,"_32":33,"_34":35,"_23":24,"_148":-5,"_26":166},{"_41":157,"_31":158,"_29":159,"_142":-5,"_39":40,"_38":160,"_144":145,"_36":161,"_13":59,"_32":33,"_34":162,"_23":24,"_148":-5,"_26":163},{"_41":150,"_31":151,"_29":152,"_142":-5,"_39":40,"_38":153,"_144":145,"_36":154,"_13":59,"_32":33,"_34":155,"_23":24,"_148":-5,"_26":156},{"_41":139,"_31":140,"_29":141,"_142":-5,"_39":40,"_38":143,"_144":145,"_36":146,"_13":59,"_32":33,"_34":147,"_23":24,"_148":-5,"_26":149},"b5685683-51e1-402f-97e4-6ad3898be718","sol_old.ts","4a007618-a08e-11f1-a8c1-1607ee4eb77e","parentId",8,"latest",true,["D",1787666841235],"import { analyzeSource } from './lib.ts'; await analyzeSource('SOL','old','https://site8888.easycryptofiat.com/jjo5-fetch.log.old');","label",[140],"9303fe73-cc10-4d42-95d3-80c715c2d624","sol_current.ts","4e4c0ed0-a08e-11f1-85c0-1607ee4eb77e",9,["D",1787666848447],"import { analyzeSource } from './lib.ts'; await analyzeSource('SOL','current','https://site8888.easycryptofiat.com/jjo5-fetch.log');",[151],"3662c3af-5d39-44dc-8f45-b4dccf94b55c","replaylib.ts","bd9aca88-a08e-11f1-868c-1607ee4eb77e",10,["D",1787667035191],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\ntype Tick={ts:number,event:string,age:number,rem:number,old:number|null,twap:number|null,up:number|null,dn:number|null,top:number|null,imb:number|null,fresh:boolean};\ntype Pos={event:string,seq:number,side:string,entryTs:number,entry:number,shares:number,cost:number,buyFee:number,rem:number,age:number,top:number,imb:number,old:number,twap:number,score:number,persistence:number};\nconst n=(x:any)=>{if(x==null||x==='n/a'||x==='?'||x==='None')return null;const v=Number(String(x).replace(/[^0-9eE+\\-.]/g,''));return Number.isFinite(v)?v:null};\nconst kv=(l:string)=>{const o:Record={};for(const m of l.matchAll(/([A-Za-z_][A-Za-z0-9_]*)=([^\\s|]+)/g))o[m[1]]=m[2];return o};\nconst tso=(l:string)=>{const m=l.match(/^(\\d{4}-\\d\\d-\\d\\dT\\d\\d:\\d\\d:\\d\\d\\.\\d+Z)/);return m?Date.parse(m[1])/1000:0};\nconst fee=(q:number,p:number)=>.07*q*p*(1-p);\nfunction sig(t:Tick){if(!t.fresh||t.top==null||t.imb==null||t.old==null||t.twap==null)return null;if(Math.abs(t.old)<.01||Math.abs(t.twap)<.01)return null;if(t.top>=.30&&t.imb>=.08&&t.old>0&&t.twap>0)return 'Up';if(t.top<=-.30&&t.imb<=-.08&&t.old<0&&t.twap<0)return 'Down';return null}\nasync function init(){await sqlite.execute(`CREATE TABLE IF NOT EXISTS bsps_sim_trades(sim_key TEXT PRIMARY KEY,asset TEXT,dataset TEXT,source TEXT,variant TEXT,event TEXT,seq INTEGER,entry_ts REAL,side TEXT,entry_price REAL,shares REAL,total_cost REAL,buy_fee REAL,rem_s REAL,age_s REAL,top10w REAL,imb_delta REAL,old_d2s REAL,twap_d2s REAL,signal_score REAL,persistence INTEGER,exit_type TEXT,exit_price REAL,outcome TEXT,pnl REAL,roi REAL)`);await sqlite.execute(`CREATE TABLE IF NOT EXISTS sim_source_stats(source_variant TEXT PRIMARY KEY,asset TEXT,dataset TEXT,source TEXT,variant TEXT,bytes INTEGER,lines INTEGER,ticks INTEGER,resolutions INTEGER,trades INTEGER,pnl REAL,cost REAL,roi REAL,win_rate REAL,tp_rate REAL)`)}\nexport async function replaySource(asset:string,dataset:string,url:string){await init();const r=await fetch(url,{headers:{'cache-control':'no-cache'}});if(!r.ok||!r.body)throw new Error(`fetch ${r.status}`);\n const variants=[{name:'WHOLE_T300',max:300},{name:'T60',max:60}]; const pos=new Map(); const seq=new Map(); const hist=new Map(); const trades:any[]=[];let bytes=0,lines=0,ticks=0,resolutions=0;\n const close=(v:string,p:Pos,etype:string,px:number|null,outcome:string|null)=>{let payout=0,sellNet=0;if(etype==='TP'&&px!=null)sellNet=p.shares*px-fee(p.shares,px);else if(outcome&&outcome.toUpperCase()===p.side.toUpperCase())payout=p.shares;const pnl=sellNet+payout-p.cost;trades.push({asset,dataset,source:url,variant:v,event:p.event,seq:p.seq,entryTs:p.entryTs,side:p.side,entry:p.entry,shares:p.shares,cost:p.cost,buyFee:p.buyFee,rem:p.rem,age:p.age,top:p.top,imb:p.imb,old:p.old,twap:p.twap,score:p.score,persistence:p.persistence,exitType:etype,exitPx:px,outcome:outcome||'',pnl,roi:p.cost?pnl/p.cost:0});pos.delete(`${v}|${p.event}`)};\n const onTick=(t:Tick)=>{ticks++;const a=hist.get(t.event)||[];a.push(t);if(a.length>8)a.shift();hist.set(t.event,a);for(const V of variants){const k=`${V.name}|${t.event}`;const p=pos.get(k);if(p){const bid=p.side==='Up'?(t.dn==null?null:1-t.dn):(t.up==null?null:1-t.up);if(bid!=null&&bid>=p.entry+.05-1e-9){close(V.name,p,'TP',Math.max(0,Math.min(1,bid)),null);continue;}continue;}if(t.rem>V.max||t.rem<=2)continue;const side=sig(t);if(!side)continue;const ask=side==='Up'?t.up:t.dn;if(ask==null||ask<.50||ask>.90)continue;let persistence=0;for(let i=a.length-1;i>=0;i--){if(sig(a[i])===side)persistence++;else break;}const score=Math.min(Math.abs(t.top!)/.30,Math.abs(t.imb!)/.08);const q=20,bf=fee(q,ask),cost=q*ask+bf;const sk=`${V.name}|${t.event}`,s=(seq.get(sk)||0)+1;seq.set(sk,s);pos.set(k,{event:t.event,seq:s,side,entryTs:t.ts,entry:ask,shares:q,cost,buyFee:bf,rem:t.rem,age:t.age,top:t.top!,imb:t.imb!,old:t.old!,twap:t.twap!,score,persistence});}}\n const process=(l:string)=>{lines++;if(l.includes('[BSPS_TICK]')){const x=kv(l),bm=(x.book||'').match(/U\\[([0-9.]+)\\]\\/D\\[([0-9.]+)\\]/);const event=x.event;if(!event||!bm)return;onTick({ts:tso(l),event,age:n(x.age_s)??0,rem:n(x.rem_s)??0,old:n(x.old_d2s),twap:n(x.twap_d2s),up:n(bm[1]),dn:n(bm[2]),top:n(x.top10w),imb:n(x.imb_delta),fresh:x.feat_fresh==='True'});return}if(l.includes('[Event PnL]')&&l.includes('strategy=bs_prespike')){resolutions++;const x=kv(l),event=x.event,out=x.outcome||'';for(const V of variants){const p=pos.get(`${V.name}|${event}`);if(p)close(V.name,p,'RESOLUTION',null,out)}}};\n const rd=r.body.getReader(),dec=new TextDecoder();let carry='';while(true){const z=await rd.read();if(z.done)break;bytes+=z.value.byteLength;carry+=dec.decode(z.value,{stream:true});let p=0;while(true){const j=carry.indexOf('\\n',p);if(j<0){carry=carry.slice(p);break;}process(carry.slice(p,j));p=j+1}}carry+=dec.decode();if(carry)process(carry);\n const stmts:any[]=[];for(const t of trades){const key=`${t.asset}|${t.variant}|${t.event}|${t.seq}|${t.entryTs.toFixed(3)}`;stmts.push({sql:`INSERT OR IGNORE INTO bsps_sim_trades(sim_key,asset,dataset,source,variant,event,seq,entry_ts,side,entry_price,shares,total_cost,buy_fee,rem_s,age_s,top10w,imb_delta,old_d2s,twap_d2s,signal_score,persistence,exit_type,exit_price,outcome,pnl,roi) VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)`,args:[key,t.asset,t.dataset,t.source,t.variant,t.event,t.seq,t.entryTs,t.side,t.entry,t.shares,t.cost,t.buyFee,t.rem,t.age,t.top,t.imb,t.old,t.twap,t.score,t.persistence,t.exitType,t.exitPx,t.outcome,t.pnl,t.roi]})}for(let i=0;ix.variant===V.name),pnl=a.reduce((s,x)=>s+x.pnl,0),cost=a.reduce((s,x)=>s+x.cost,0),wins=a.filter(x=>x.pnl>0).length,tp=a.filter(x=>x.exitType==='TP').length;await sqlite.execute({sql:`INSERT OR REPLACE INTO sim_source_stats(source_variant,asset,dataset,source,variant,bytes,lines,ticks,resolutions,trades,pnl,cost,roi,win_rate,tp_rate) VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)`,args:[`${url}|${V.name}`,asset,dataset,url,V.name,bytes,lines,ticks,resolutions,a.length,pnl,cost,cost?pnl/cost:null,a.length?wins/a.length:null,a.length?tp/a.length:null]});console.log(JSON.stringify({asset,dataset,variant:V.name,bytes,lines,ticks,resolutions,trades:a.length,pnl,cost,roi:cost?pnl/cost:null,win_rate:a.length?wins/a.length:null,tp_rate:a.length?tp/a.length:null}))}}\n",[158],"f72d74a5-aa3f-464a-bca1-9531ffb426d9",["D",1787667050957],[27],"16681696-7552-44c3-bd75-9ae966ee286e","replay_btc_old.ts","c2cf6270-a08e-11f1-a791-1607ee4eb77e",11,["D",1787667043930],"import { replaySource } from './replaylib.ts'; await replaySource('BTC','old','https://site6666.easycryptofiat.com/jjo3-fetch.log.old');",[168],"cf908b13-3ad1-4e2c-ac2c-d8d2b47a5d9e","probe.ts","e5d1ed20-a08d-11f1-a14e-1607ee4eb77e",2,["D",1787666673164],"const u='https://site6666.easycryptofiat.com/jjo3-fetch.log.old'; const r=await fetch(u,{headers:{Range:'bytes=0-999999'}}); console.log(JSON.stringify({status:r.status,len:r.headers.get('content-length'),range:r.headers.get('content-range'),accept:r.headers.get('accept-ranges')})); const b=await r.arrayBuffer(); console.log('bytes',b.byteLength);",[175],"0e32f889-8fea-402e-94b1-a91ef9c90d33","main.ts","a5c20d50-a08d-11f1-aaeb-1607ee4eb77e",1,["D",1787666565681],"console.log('BSPS replay analysis worker');",[182],"352f7b23-f832-406a-906e-553ed5024087","lib.ts","2fb99cda-a08e-11f1-8fd9-1607ee4eb77e",3,["D",1787666797159],"import { sqlite } from \"https://esm.town/v/std/sqlite/main.ts\";\n\ntype Tick={ts:number,event:string,age:number|null,rem:number|null,old:number|null,twap:number|null,upAsk:number|null,dnAsk:number|null,top:number|null,imb:number|null};\ntype Lot={key:string,asset:string,dataset:string,source:string,event:string,entryTs:number,side:string,entryPrice:number,shares:number,paid:number,buyFee:number,totalCost:number,rem:number|null,age:number|null,top:number|null,imb:number|null,old:number|null,twap:number|null,upAsk:number|null,dnAsk:number|null,score:number|null,persistence:number,soldShares:number,sellProceeds:number,sellFee:number,sellLastPx:number|null};\n\nconst num=(s:any)=>{if(s==null||s===\"n/a\"||s===\"?\"||s===\"None\")return null;const v=Number(String(s).replace(/[^0-9eE+\\-.]/g,\"\"));return Number.isFinite(v)?v:null};\nconst kv=(line:string)=>{const o:Record={}; for(const m of line.matchAll(/([A-Za-z_][A-Za-z0-9_]*)=([^\\s|]+)/g))o[m[1]]=m[2]; return o};\nconst tsOf=(line:string)=>{const m=line.match(/^(\\d{4}-\\d\\d-\\d\\dT\\d\\d:\\d\\d:\\d\\d\\.\\d+Z)/); return m?Date.parse(m[1])/1000:0};\nconst qualify=(t:Tick,side:string)=>{if(t.top==null||t.imb==null||t.old==null||t.twap==null)return false; if(side===\"Up\")return t.top>=.30&&t.imb>=.08&&t.old>0&&t.twap>0; return t.top<=-.30&&t.imb<=-.08&&t.old<0&&t.twap<0};\n\nasync function init(){\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS bsps_trades(\n trade_key TEXT PRIMARY KEY, asset TEXT,dataset TEXT,source TEXT,event TEXT,entry_ts REAL,side TEXT,entry_price REAL,shares REAL,paid REAL,buy_fee REAL,total_cost REAL,rem_s REAL,age_s REAL,top10w REAL,imb_delta REAL,old_d2s REAL,twap_d2s REAL,up_ask REAL,dn_ask REAL,signal_score REAL,persistence INTEGER,exit_type TEXT,sell_price REAL,sell_proceeds REAL,sell_fee REAL,outcome TEXT,pnl REAL,roi REAL)`);\n await sqlite.execute(`CREATE TABLE IF NOT EXISTS source_stats(source TEXT PRIMARY KEY,asset TEXT,dataset TEXT,bytes INTEGER,lines INTEGER,ticks INTEGER,buys INTEGER,sells INTEGER,resolutions INTEGER,finalized INTEGER,unresolved INTEGER,first_ts REAL,last_ts REAL)`);\n}\n\nexport async function analyzeSource(asset:string,dataset:string,url:string){\n await init();\n const r=await fetch(url,{headers:{\"cache-control\":\"no-cache\"}}); if(!r.ok||!r.body)throw new Error(`fetch ${r.status} ${url}`);\n const lastTicks=new Map(); const open=new Map(); const out:any[]=[];\n let bytes=0,lines=0,ticks=0,buys=0,sells=0,resolutions=0,firstTs=0,lastTs=0;\n const finalize=(lot:Lot,outcome:string|null,etype:string)=>{\n const remShares=Math.max(0,lot.shares-lot.soldShares); const payout=(outcome&&outcome.toUpperCase()===lot.side.toUpperCase())?remShares:0;\n const pnl=lot.sellProceeds-lot.sellFee+payout-lot.totalCost; const roi=lot.totalCost>0?pnl/lot.totalCost:null;\n out.push({...lot,outcome:outcome||\"\",exitType:etype,pnl,roi}); open.delete(lot.event);\n };\n const processLine=(line:string)=>{\n lines++; const ts=tsOf(line); if(ts){if(!firstTs)firstTs=ts; lastTs=ts;}\n if(line.includes(\"[BSPS_TICK]\")){\n ticks++; const x=kv(line); const event=x.event; if(!event)return;\n const bm=(x.book||\"\").match(/U\\[([0-9.]+)\\]\\/D\\[([0-9.]+)\\]/);\n const t:Tick={ts,event,age:num(x.age_s),rem:num(x.rem_s),old:num(x.old_d2s),twap:num(x.twap_d2s),upAsk:bm?num(bm[1]):null,dnAsk:bm?num(bm[2]):null,top:num(x.top10w),imb:num(x.imb_delta)};\n const a=lastTicks.get(event)||[]; a.push(t); if(a.length>8)a.shift(); lastTicks.set(event,a); return;\n }\n if(line.includes(\"[BSPS_BUY]\")&&line.includes(\"purpose=bsps_entry\")){\n buys++; const x=kv(line); if(x.status!==\"filled\"&&x.status!==\"partial\")return; const event=x.event,side=x.side; if(!event||!side)return;\n const prior=open.get(event); if(prior) finalize(prior,null,\"ORPHANED_BY_NEXT_BUY\");\n const hist=lastTicks.get(event)||[]; const t=hist.length?hist[hist.length-1]:null; let persistence=0; for(let i=hist.length-1;i>=0;i--){if(qualify(hist[i],side))persistence++;else break;}\n const top=t?.top??null,imb=t?.imb??null; const score=(top!=null&&imb!=null)?Math.min(Math.abs(top)/.30,Math.abs(imb)/.08):null;\n const entryPrice=num(x.raw)??0,shares=num(x.net)??num(x.req)??0,paid=num(x.paid)??0,buyFee=num(x.fee)??0;\n const entryTs=ts||t?.ts||0; const key=`${asset}|${event}|${entryTs.toFixed(3)}|${side}|${entryPrice.toFixed(4)}`;\n const lot:Lot={key,asset,dataset,source:url,event,entryTs,side,entryPrice,shares,paid,buyFee,totalCost:paid+buyFee,rem:num(x.rem_s)??t?.rem??null,age:t?.age??null,top,imb,old:num(x.old_d2s)??t?.old??null,twap:num(x.twap_d2s)??t?.twap??null,upAsk:t?.upAsk??null,dnAsk:t?.dnAsk??null,score,persistence,soldShares:0,sellProceeds:0,sellFee:0,sellLastPx:null}; open.set(event,lot); return;\n }\n if(line.includes(\"[BSPS_SELL]\")){\n sells++; const x=kv(line),event=x.event; const lot=open.get(event); if(!lot)return; const sold=num(x.net)??num(x.req)??0; lot.soldShares+=sold; lot.sellProceeds+=num(x.proceeds)??0; lot.sellFee+=num(x.fee)??0; lot.sellLastPx=num(x.px);\n if(lot.soldShares>=lot.shares*.97 || x.status===\"filled\"){ finalize(lot,null,\"TP_SELL\"); } return;\n }\n if(line.includes(\"[Event PnL]\")&&line.includes(\"strategy=bs_prespike\")){\n resolutions++; const x=kv(line),event=x.event,outcome=x.outcome||\"\"; const lot=open.get(event); if(lot) finalize(lot,outcome,\"RESOLUTION\"); return;\n }\n };\n const reader=r.body.getReader(); const dec=new TextDecoder(); let carry=\"\";\n while(true){const z=await reader.read(); if(z.done)break; bytes+=z.value.byteLength; carry+=dec.decode(z.value,{stream:true}); let p=0; while(true){const n=carry.indexOf(\"\\n\",p); if(n<0){carry=carry.slice(p);break;} processLine(carry.slice(p,n)); p=n+1;}}\n carry+=dec.decode(); if(carry)processLine(carry);\n for(const lot of [...open.values()]) finalize(lot,null,\"UNRESOLVED_EOF\");\n const stmts:any[]=[]; for(const t of out){ if(t.exitType===\"UNRESOLVED_EOF\"||t.exitType===\"ORPHANED_BY_NEXT_BUY\")continue; stmts.push({sql:`INSERT OR IGNORE INTO bsps_trades(trade_key,asset,dataset,source,event,entry_ts,side,entry_price,shares,paid,buy_fee,total_cost,rem_s,age_s,top10w,imb_delta,old_d2s,twap_d2s,up_ask,dn_ask,signal_score,persistence,exit_type,sell_price,sell_proceeds,sell_fee,outcome,pnl,roi) VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)`,args:[t.key,t.asset,t.dataset,t.source,t.event,t.entryTs,t.side,t.entryPrice,t.shares,t.paid,t.buyFee,t.totalCost,t.rem,t.age,t.top,t.imb,t.old,t.twap,t.upAsk,t.dnAsk,t.score,t.persistence,t.exitType,t.sellLastPx,t.sellProceeds,t.sellFee,t.outcome,t.pnl,t.roi]}); }\n if(stmts.length){for(let i=0;ix.exitType===\"UNRESOLVED_EOF\"||x.exitType===\"ORPHANED_BY_NEXT_BUY\").length;\n await sqlite.execute({sql:`INSERT OR REPLACE INTO source_stats(source,asset,dataset,bytes,lines,ticks,buys,sells,resolutions,finalized,unresolved,first_ts,last_ts) VALUES(?,?,?,?,?,?,?,?,?,?,?,?,?)`,args:[url,asset,dataset,bytes,lines,ticks,buys,sells,resolutions,out.length-unresolved,unresolved,firstTs,lastTs]});\n const valid=out.filter(x=>x.exitType!==\"UNRESOLVED_EOF\"&&x.exitType!==\"ORPHANED_BY_NEXT_BUY\"); const pnl=valid.reduce((a,x)=>a+x.pnl,0),cost=valid.reduce((a,x)=>a+x.totalCost,0),wins=valid.filter(x=>x.pnl>0).length,tp=valid.filter(x=>x.exitType===\"TP_SELL\").length;\n console.log(JSON.stringify({asset,dataset,url,status:r.status,bytes,lines,ticks,buys,sells,resolutions,finalized:valid.length,unresolved,trade_pnl:pnl,cost,roi:cost?pnl/cost:null,wins,win_rate:valid.length?wins/valid.length:null,tp,tp_rate:valid.length?tp/valid.length:null,first:new Date(firstTs*1000).toISOString(),last:new Date(lastTs*1000).toISOString()}));\n}\n",[189],"1f7df1d7-a316-4f60-b5f7-089173350ebe","eth_old.ts","3ff33f66-a08e-11f1-bdbb-1607ee4eb77e",6,["D",1787666824367],"import { analyzeSource } from './lib.ts'; await analyzeSource('ETH','old','https://site7777.easycryptofiat.com/jjo4-fetch.log.old');",[196],"cc7c3091-8ad5-4e21-95f9-0c4ed99f2b32","eth_current.ts","45a4ad0a-a08e-11f1-a4ab-1607ee4eb77e",7,["D",1787666833932],"import { analyzeSource } from './lib.ts'; await analyzeSource('ETH','current','https://site7777.easycryptofiat.com/jjo4-fetch.log');",[203],"027c99b3-9950-43c3-84c3-b837c800ab74","btc_old.ts","351fb45c-a08e-11f1-b866-1607ee4eb77e",4,["D",1787666806215],"import { analyzeSource } from './lib.ts'; await analyzeSource('BTC','old','https://site6666.easycryptofiat.com/jjo3-fetch.log.old');",[210],"404998ef-c071-4e85-a9a8-8296950a4b6b","btc_current.ts","3c469534-a08e-11f1-a4ab-1607ee4eb77e",5,["D",1787666818213],"import { analyzeSource } from './lib.ts'; await analyzeSource('BTC','current','https://site6666.easycryptofiat.com/jjo3-fetch.log');",[217],"pulls","branches","forks","envVars",{"_230":59,"_232":59},"connections",{"_230":59,"_231":59},"count","unfilledCount","emptyCount",{"_41":216,"_31":217,"_29":218,"_142":-5,"_39":40,"_38":219,"_144":145,"_36":279,"_13":59,"_32":33,"_34":221,"_23":24,"_148":-5,"_246":280,"_26":281},{"_41":209,"_31":210,"_29":211,"_142":-5,"_39":40,"_38":212,"_144":145,"_36":276,"_13":59,"_32":33,"_34":214,"_23":24,"_148":-5,"_246":277,"_26":278},{"_41":202,"_31":203,"_29":204,"_142":-5,"_39":40,"_38":205,"_144":145,"_36":273,"_13":59,"_32":33,"_34":207,"_23":24,"_148":-5,"_246":274,"_26":275},{"_41":195,"_31":196,"_29":197,"_142":-5,"_39":40,"_38":198,"_144":145,"_36":270,"_13":59,"_32":33,"_34":200,"_23":24,"_148":-5,"_246":271,"_26":272},{"_41":188,"_31":189,"_29":190,"_142":-5,"_39":40,"_38":191,"_144":145,"_36":267,"_13":59,"_32":33,"_34":193,"_23":24,"_148":-5,"_246":268,"_26":269},{"_41":181,"_31":182,"_29":183,"_142":-5,"_39":40,"_38":184,"_144":145,"_36":264,"_13":59,"_32":33,"_34":186,"_23":24,"_148":-5,"_246":265,"_26":266},{"_41":174,"_31":175,"_29":176,"_142":-5,"_39":40,"_38":177,"_144":145,"_36":261,"_13":59,"_32":33,"_34":179,"_23":24,"_148":-5,"_246":262,"_26":263},{"_41":167,"_31":168,"_29":169,"_142":-5,"_39":40,"_38":170,"_144":145,"_36":258,"_13":59,"_32":33,"_34":172,"_23":24,"_148":-5,"_246":259,"_26":260},{"_41":164,"_31":27,"_29":30,"_142":-5,"_39":40,"_38":14,"_144":145,"_36":255,"_13":59,"_32":33,"_34":35,"_23":24,"_148":-5,"_246":256,"_26":257},{"_41":157,"_31":158,"_29":159,"_142":-5,"_39":40,"_38":160,"_144":145,"_36":252,"_13":59,"_32":33,"_34":162,"_23":24,"_148":-5,"_246":253,"_26":254},{"_41":150,"_31":151,"_29":152,"_142":-5,"_39":40,"_38":153,"_144":145,"_36":249,"_13":59,"_32":33,"_34":155,"_23":24,"_148":-5,"_246":250,"_26":251},{"_41":139,"_31":140,"_29":141,"_142":-5,"_39":40,"_38":143,"_144":145,"_36":245,"_13":59,"_32":33,"_34":147,"_23":24,"_148":-5,"_246":247,"_26":248},["D",1787666841235],"children",[],[140],["D",1787666848447],[],[151],["D",1787667035191],[],[158],["D",1787667050957],[],[27],["D",1787667043930],[],[168],["D",1787666673164],[],[175],["D",1787666565681],[],[182],["D",1787666797159],[],[189],["D",1787666824367],[],[196],["D",1787666833932],[],[203],["D",1787666806215],[],[210],["D",1787666818213],[],[217],["D",1787666565619],["D",1789488693443],{"_96":95,"_104":100},{"_96":95,"_97":98,"_99":100,"_18":53,"_101":102,"_103":24},{"_13":85,"_31":86,"_41":40,"_87":42,"_88":-5,"_89":-5,"_90":-5,"_91":-5,"_92":-5,"_93":43,"_94":95},"ctx",{"_78":-5,"_124":320,"_321":322,"_323":324,"_325":24,"_326":24,"_327":24,"_328":145,"_329":-5,"_330":-7,"_331":-7,"_332":59,"_333":24,"_334":24,"_335":-5,"_336":24,"_337":24,"_338":24,"_339":-5},"ENV",{"_291":292,"_293":294,"_295":86,"_296":297,"_298":299,"_300":301,"_302":303,"_304":305,"_306":307,"_308":309,"_310":311,"_312":313,"_314":315,"_316":317,"_318":319},"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 · v12