Method ParseUserTracksFromFile

tools/track_analyzing/track_archive_reader.cpp:285–325

}  // namespace details

void TrackArchiveReader::ParseUserTracksFromFile(string const & logFile, UserToTrack & userToTrack) const
{
  // Read file content
  FileReader reader(logFile);
  string archiveData;
  reader.ReadAsString(archiveData);

  // Unzip data
  using Inflate = coding::ZLib::Inflate;
  Inflate inflate(Inflate::Format::GZip);
  string logData;
  inflate(archiveData.data(), archiveData.size(), back_inserter(logData));

  // Parse log
  TemporaryFile tmpArchiveFile("" /* empty prefix */, kTmpArchiveFileNameTemplate);
  stringstream logParser;
  logParser << logData;

  size_t linesCount = 0;
  size_t errorsCount = 0;
  for (string line; getline(logParser, line); ++linesCount)
  {
    optional<details::UserTrackInfo> data = details::ParseLogRecord(line, tmpArchiveFile);

    if (data)
    {
      Track & track = userToTrack[data->m_userId];
      track.insert(track.end(), data->m_track.cbegin(), data->m_track.cend());
    }
    else
    {
      ++errorsCount;
    }
  }

  LOG(LINFO, ("Process", linesCount, "log records"));
  if (errorsCount == 0)
    LOG(LINFO, ("All records are parsed successfully"));
  else
    LOG(LERROR, ("Unable to parse", errorsCount, "records"));
}
}  // namespace track_analyzing