Method ParseUserTracks

tools/track_analyzing/log_parser.cpp:111–155

}

void LogParser::ParseUserTracks(string const & logFile, UserToTrack & userToTrack) const
{
  base::Timer timer;

  std::ifstream stream(logFile);
  if (!stream)
    MYTHROW(MessageException, ("Can't open file", logFile, "to parse tracks"));

  std::regex const base_regex(R"(.*(DataV0|CurrentData)\s+aloha_id\s*:\s*(\S+)\s+.*\|(\w+)\|)");
  ankerl::unordered_dense::set<string> usersWithOldVersion;
  uint64_t linesCount = 0;
  size_t pointsCount = 0;

  for (string line; getline(stream, line); ++linesCount)
  {
    std::smatch base_match;
    if (!std::regex_match(line, base_match, base_regex))
      continue;

    CHECK_EQUAL(base_match.size(), 4, ());

    string const version = base_match[1].str();
    string const userId = base_match[2].str();
    string const data = base_match[3].str();
    if (version != "CurrentData")
    {
      CHECK_EQUAL(version, "DataV0", ());
      usersWithOldVersion.insert(userId);
      continue;
    }

    auto const packet = ReadDataPoints(data);
    if (!packet.empty())
    {
      Track & track = userToTrack[userId];
      track.insert(track.end(), packet.cbegin(), packet.cend());
    }

    pointsCount += packet.size();
  };

  LOG(LINFO, ("Tracks parsing finished, elapsed:", timer.ElapsedSeconds(), "seconds, lines:", linesCount, ", points",
              pointsCount));
  LOG(LINFO, ("Users with current version:", userToTrack.size(), ", old version:", usersWithOldVersion.size()));
}

void LogParser::SplitIntoMwms(UserToTrack const & userToTrack, MwmToTracks & mwmToTracks) const
{