diff --git a/processors/createParsedDataBlob.mjs b/processors/createParsedDataBlob.ts similarity index 71% rename from processors/createParsedDataBlob.mjs rename to processors/createParsedDataBlob.ts index 9b36b6ebe..6d9667a56 100644 --- a/processors/createParsedDataBlob.mjs +++ b/processors/createParsedDataBlob.ts @@ -1,14 +1,14 @@ import { Console } from 'console'; import readline from 'readline'; -import processAllPlayers from './processAllPlayers.mjs'; -import processTeamfights from './processTeamfights.mjs'; -import processParsedData from './processParsedData.mjs'; -import processMetadata from './processMetadata.mjs'; -import processExpand from './processExpand.mjs'; -import processDraftTimings from './processDraftTimings.mjs'; -import parseSchema from './parseSchema.mjs'; +import processAllPlayers from './processAllPlayers.js'; +import processTeamfights from './processTeamfights.js'; +import processParsedData from './processParsedData.js'; +import processMetadata from './processMetadata.js'; +import processExpand from './processExpand.js'; +import processDraftTimings from './processDraftTimings.js'; +import parseSchema from './parseSchema.js'; -function createParsedDataBlob(entries, matchId) { +function createParsedDataBlob(entries: any[], matchId: string) { const logConsole = new Console(process.stderr); logConsole.time('metadata'); const meta = processMetadata(entries); @@ -33,13 +33,13 @@ function createParsedDataBlob(entries, matchId) { parsedData.radiant_xp_adv = ap.radiant_xp_adv; return parsedData; } -const entries = []; +const entries: any[] = []; let complete = false; const matchId = process.argv[2]; const parseStream = readline.createInterface({ input: process.stdin, }); -parseStream.on('line', (e) => { +parseStream.on('line', (e: any) => { e = JSON.parse(e); entries.push(e); if (e.type === 'epilogue') { @@ -49,7 +49,7 @@ parseStream.on('line', (e) => { parseStream.on('close', () => { if (complete) { const parsedData = createParsedDataBlob(entries, matchId); - process.stdout.write(JSON.stringify(parsedData), null, (err) => { + process.stdout.write(JSON.stringify(parsedData), undefined, (err) => { process.exit(Number(err)); }); } else { diff --git a/processors/parseSchema.mjs b/processors/parseSchema.ts similarity index 100% rename from processors/parseSchema.mjs rename to processors/parseSchema.ts diff --git a/processors/performanceOthers.mjs b/processors/performanceOthers.ts similarity index 100% rename from processors/performanceOthers.mjs rename to processors/performanceOthers.ts diff --git a/processors/populate.mjs b/processors/populate.ts similarity index 98% rename from processors/populate.mjs rename to processors/populate.ts index 19c66c35a..993920bb3 100644 --- a/processors/populate.mjs +++ b/processors/populate.ts @@ -1,4 +1,4 @@ -import performanceOthers from './performanceOthers.mjs'; +import performanceOthers from './performanceOthers.js'; function populate(e, container, meta) { let t; switch (e.type) { diff --git a/processors/processAllPlayers.mjs b/processors/processAllPlayers.ts similarity index 100% rename from processors/processAllPlayers.mjs rename to processors/processAllPlayers.ts diff --git a/processors/processDraftTimings.mjs b/processors/processDraftTimings.ts similarity index 100% rename from processors/processDraftTimings.mjs rename to processors/processDraftTimings.ts diff --git a/processors/processExpand.mjs b/processors/processExpand.ts similarity index 100% rename from processors/processExpand.mjs rename to processors/processExpand.ts diff --git a/processors/processMetadata.mjs b/processors/processMetadata.ts similarity index 96% rename from processors/processMetadata.mjs rename to processors/processMetadata.ts index ba0774a5a..15750611d 100644 --- a/processors/processMetadata.mjs +++ b/processors/processMetadata.ts @@ -1,7 +1,7 @@ /** * Given an event stream, extracts metadata such as game zero time and hero to slot/ID mappings. * */ -function processMetadata(entries) { +function processMetadata(entries: any[]) { const heroToSlot = {}; const slotToPlayerslot = {}; const heroIdToSlot = {}; @@ -47,6 +47,7 @@ function processMetadata(entries) { slot_to_playerslot: slotToPlayerslot, hero_id_to_slot: heroIdToSlot, ability_levels: abilityLevels, + match_id: '', }; } export default processMetadata; diff --git a/processors/processMultiKillStreaks.mjs b/processors/processMultiKillStreaks.ts similarity index 100% rename from processors/processMultiKillStreaks.mjs rename to processors/processMultiKillStreaks.ts diff --git a/processors/processParsedData.mjs b/processors/processParsedData.ts similarity index 85% rename from processors/processParsedData.mjs rename to processors/processParsedData.ts index 1c6138e96..5eeee0cf9 100644 --- a/processors/processParsedData.mjs +++ b/processors/processParsedData.ts @@ -1,4 +1,4 @@ -import populate from './populate.mjs'; +import populate from './populate.js'; function processParsedData(entries, container, meta) { for (let i = 0; i < entries.length; i += 1) { const e = entries[i]; diff --git a/processors/processTeamfights.mjs b/processors/processTeamfights.ts similarity index 99% rename from processors/processTeamfights.mjs rename to processors/processTeamfights.ts index db7e00262..813500ccc 100644 --- a/processors/processTeamfights.mjs +++ b/processors/processTeamfights.ts @@ -1,4 +1,4 @@ -import populate from './populate.mjs'; +import populate from './populate.js'; /** * A processor to compute teamfights that occurred given an event stream * */ diff --git a/processors/processUploadProps.mjs b/processors/processUploadProps.ts similarity index 100% rename from processors/processUploadProps.mjs rename to processors/processUploadProps.ts