event aggregator

tiffany.js

const VALID_EVENTS = ["searchChanged", "jobViewed", "applicationSubmitted"];

async function process(api) {
  try {
    const events = await api("GET", "/events");
    const { invalid, counts } = categorizeEvents(events);

    await Promise.all([
      api("POST", "/counts", counts),
      api("POST", "/invalid", invalid)
    ]);
    return true;
  } catch (_e) {
    return false;
  }
}

function categorizeEvents(events) {
  const invalid = new Set();
  const counts = {};

  categorize(events);

  function categorize(evts) {
    evts.forEach(event => {
      if (Array.isArray(event)) {
        return categorize(event);
      }

      if (VALID_EVENTS.includes(event.name)) {
        counts[event.name] = (counts[event.name] || 0) + 1;
      } else {
        invalid.add(event.name);
      }
    });
  }

  return { invalid: Array.from(invalid), counts };
}