From ff7862c29796128f148d44da072e0cadd46a6dc2 Mon Sep 17 00:00:00 2001 From: Ubuntu Date: Thu, 28 Dec 2023 10:04:07 +0000 Subject: [PATCH] wip convert processors to ts --- ...edDataBlob.mjs => createParsedDataBlob.ts} | 22 +++++++++---------- .../{parseSchema.mjs => parseSchema.ts} | 0 ...ormanceOthers.mjs => performanceOthers.ts} | 0 processors/{populate.mjs => populate.ts} | 2 +- ...essAllPlayers.mjs => processAllPlayers.ts} | 0 ...raftTimings.mjs => processDraftTimings.ts} | 0 .../{processExpand.mjs => processExpand.ts} | 0 ...processMetadata.mjs => processMetadata.ts} | 3 ++- ...Streaks.mjs => processMultiKillStreaks.ts} | 0 ...essParsedData.mjs => processParsedData.ts} | 2 +- ...essTeamfights.mjs => processTeamfights.ts} | 2 +- ...sUploadProps.mjs => processUploadProps.ts} | 0 12 files changed, 16 insertions(+), 15 deletions(-) rename processors/{createParsedDataBlob.mjs => createParsedDataBlob.ts} (71%) rename processors/{parseSchema.mjs => parseSchema.ts} (100%) rename processors/{performanceOthers.mjs => performanceOthers.ts} (100%) rename processors/{populate.mjs => populate.ts} (98%) rename processors/{processAllPlayers.mjs => processAllPlayers.ts} (100%) rename processors/{processDraftTimings.mjs => processDraftTimings.ts} (100%) rename processors/{processExpand.mjs => processExpand.ts} (100%) rename processors/{processMetadata.mjs => processMetadata.ts} (96%) rename processors/{processMultiKillStreaks.mjs => processMultiKillStreaks.ts} (100%) rename processors/{processParsedData.mjs => processParsedData.ts} (85%) rename processors/{processTeamfights.mjs => processTeamfights.ts} (99%) rename processors/{processUploadProps.mjs => processUploadProps.ts} (100%) 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