processLogParse.js

const insignificantDeaths = [
  'npc_dota_creep',
  'npc_dota_neutral',
];

function translate(s) {
  return s === 'dota_unknown' ? null : s;
}
/**
 * A processor to reduce the event stream to only logs we want to persist
 * */
function processReduce(entries, meta) {
  const result = entries.filter((e) => {
    if (e.type === 'DOTA_COMBATLOG_PURCHASE'
      || (e.type === 'DOTA_COMBATLOG_DEATH' && insignificantDeaths.every(prefix => e.targetname.indexOf(prefix) !== 0))
    ) {
      return Boolean(e.time);
    }
    return false;
  }).map((e) => {
    const e2 = Object.assign({}, e, {
      match_id: meta.match_id,
      attackername_slot: meta.slot_to_playerslot[meta.hero_to_slot[e.attackername]],
      targetname_slot: meta.slot_to_playerslot[meta.hero_to_slot[e.targetname]],
      sourcename_slot: meta.slot_to_playerslot[meta.hero_to_slot[e.sourcename]],
      targetsourcename_slot: meta.slot_to_playerslot[meta.hero_to_slot[e.targetname]],
      player1_slot: meta.slot_to_playerslot[e.player1],
      player_slot: e.player_slot || meta.slot_to_playerslot[e.slot],
      inflictor: translate(e.inflictor),
    });
    return e2;
  });
  /*
  var count = {};
  result.forEach(function(r)
  {
      count[r.type] = (count[r.type] || 0) + 1;
  });
  console.log(count);
  */
  return result;
}
module.exports = processReduce;