t2-mapper/docs/assets/demoTimelineScanner-CRMdvfeq.js

import{t as e}from"./logger-zy3b0zcG.js";import{A as t,_ as n}from"./streamHelpers-Be29sBCp.js";var r=e(`demoTimelineScanner`),i=500,a=new Set([`msglegitkill`,`msgheadshotkill`,`msgteamkill`,`msgselfkill`,`msgexplosionkill`,`msgvehiclekill`,`msgvehiclecrash`,`msgvehiclespawnkill`,`msgturretkill`,`msgcturretkill`,`msgturretselfkill`,`msgoobkill`,`msgcampkill`,`msgrogueminekill`,`msglavakill`,`msglightningkill`]),o=new Set([`msgselfkill`,`msgturretselfkill`,`msgoobkill`,`msglavakill`,`msglightningkill`,`msgcampkill`]);function s(e,t){if(e.length>=2&&e.charCodeAt(0)===1){let n=parseInt(e.slice(1),10);if(Number.isFinite(n))return t.get(n)??e}return e}function c(e,t,r){let i=s(e,r);for(let e=0;e<t.length;e++){let a=`%${e+1}`;i.includes(a)&&(i=i.replaceAll(a,n(s(t[e],r))))}return i=i.replace(/%\d+/g,``),n(i)}async function l(e,l,u,d){let f=new t(new Uint8Array(e)),{initialBlock:p}=await f.load(),m=new Map;for(let[e,t]of p.taggedStrings)m.set(e,t);let h=f.getRegistry(),g=l?n(l).trim().toLowerCase():null,_=null,v=null;for(let e=0;e<p.demoValues.length;e++){if(p.demoValues[e]!==`readplayerinfo`)continue;let t=p.demoValues[e+1];if(t?.startsWith(`1	`)){let e=t.split(`	`),n=parseInt(e[1],10);Number.isFinite(n)&&(_=n);break}}if(_!=null){let e=p.demoValues,t=parseInt(e[1]===`<BLANK>`?`0`:e[1]??`0`,10)||0;for(let n=0;n<t;n++){let t=(e[2+n]??``).split(`	`);if(parseInt(t[2],10)===_){let e=parseInt(t[4],10);isNaN(e)||(v=e);break}}}let y=[],b=0,x=!1,S=0,C=f.blockCount;for(;!d?.aborted;){let e;try{e=f.nextBlock()}catch(e){r.warn(`Stopping scan at block %d due to read error: %o`,S,e);break}if(!e)break;if(S++,e.type===2){b++;continue}if(e.type!==0||!e.parsed)continue;let t=e.parsed;if(!t.events)continue;let l=32/1e3*b;for(let e of t.events)try{if(!e.parsedData)continue;let t=e.parsedData.type;if(t===`NetStringEvent`){let t=e.parsedData.id,n=e.parsedData.value;n!=null&&m.set(t,n);continue}let r=h.getEventParser(e.classId)?.name;if(t!==`RemoteCommandEvent`&&r!==`RemoteCommandEvent`||s(e.parsedData.funcName,m)!==`ServerMessage`)continue;let i=e.parsedData.args;if(!i||i.length<2)continue;let u=s(i[0],m).toLowerCase();if(u===`msgclientjointeam`&&_!=null&&i.length>=6&&parseInt(s(i[4],m),10)===_){let e=parseInt(s(i[5],m),10);isNaN(e)||(v=e)}if(u===`msgmissionstart`&&!x){x=!0,y.push({timeSec:l,type:`match-start`,description:`Match started`});continue}if(u===`msggameover`){y.push({timeSec:l,type:`match-end`,description:`Match ended`});continue}if(u===`msgctfflagcapped`&&i.length>=2){let e=c(i[1],i.slice(2),m),t=i.length>=3?n(s(i[2],m)).trim():void 0,r=i.length>=4?n(s(i[3],m)).trim():void 0,a=`neutral`;if(v!=null&&v>0&&i.length>=6){let e=parseInt(s(i[5],m),10);e===v?a=`friendly`:isNaN(e)||(a=`enemy`)}y.push({timeSec:l,type:`flag-cap`,description:e||`Flag captured`,teamAffinity:a,capturer:t,flagTeamName:r||void 0});continue}if(a.has(u)&&i.length>=6){if(o.has(u))continue;let e=n(s(i[5],m)).trim(),t=n(s(i[2],m)).trim(),r=i.length>=10?n(s(i[9],m)).trim():void 0;if(g&&e.toLowerCase()===g){let n=c(i[1],i.slice(2),m);y.push({timeSec:l,type:`kill`,description:n||`${e} got a kill`,killer:e,victim:t,weapon:r||void 0})}}}catch(e){r.warn(`Skipping malformed event in block %d: %o`,S,e)}S%i===0&&(C&&u&&u(Math.min(S/C,1)),await new Promise(e=>setTimeout(e,0)))}return r.info(`Scanned %d blocks, found %d events`,S,y.length),y}export{l as scanDemoTimeline};