storage/diff_scheme/diff_scheme_loader.cpp - master - githubmirror/omim

storage/diff_scheme/diff_scheme_loader.cpp
153 строки4 KB
Arsentiy Milchakov
[storage][diffs] use same diffs info into storage and queued counties for url logic incapsulation
13 янв 2020, 12:04
13 янв 2020, 12:042e49266
#include "storage/diff_scheme/diff_scheme_loader.hpp"

#include "platform/http_client.hpp"
#include "platform/platform.hpp"

#include "base/logging.hpp"

#include <memory>
#include <sstream>
#include <string>
#include <unordered_map>
#include <utility>

#include "3party/Alohalytics/src/alohalytics.h"
#include "3party/jansson/myjansson.hpp"

#include "private.h"

using namespace std;

namespace
{
using namespace storage::diffs;

char const kMaxVersionKey[] = "max_version";
char const kMwmsKey[] = "mwms";
char const kNameKey[] = "name";
char const kSizeKey[] = "size";
char const kVersionKey[] = "version";

auto const kTimeoutInSeconds = 5.0;

string SerializeCheckerData(LocalMapsInfo const & info)
{
  auto mwmsArrayNode = base::NewJSONArray();
  for (auto const & nameAndVersion : info.m_localMaps)
  {
    auto node = base::NewJSONObject();
    ToJSONObject(*node, kNameKey, nameAndVersion.first);
    ToJSONObject(*node, kVersionKey, nameAndVersion.second);
    json_array_append_new(mwmsArrayNode.get(), node.release());
  }

  auto const root = base::NewJSONObject();
  json_object_set_new(root.get(), kMwmsKey, mwmsArrayNode.release());
  ToJSONObject(*root, kMaxVersionKey, info.m_currentDataVersion);
  unique_ptr<char, JSONFreeDeleter> buffer(json_dumps(root.get(), JSON_COMPACT | JSON_ENSURE_ASCII));
  return buffer.get();
}

NameDiffInfoMap DeserializeResponse(string const & response, LocalMapsInfo::NameVersionMap const & nameVersionMap)
{
  if (response.empty())
  {
    LOG(LERROR, ("Diff response shouldn't be empty."));
    return {};
  }

  base::Json const json(response.c_str());
  if (json.get() == nullptr)
    return {};

  auto const root = json_object_get(json.get(), kMwmsKey);
  if (root == nullptr || !json_is_array(root))
    return {};

  auto const count = json_array_size(root);
  if (count == 0 || count != nameVersionMap.size())
  {
    LOG(LERROR, ("Diff list size in response must be equal to mwm list size in request."));
    return {};
  }

  NameDiffInfoMap diffs;

  for (size_t i = 0; i < count; ++i)
  {
    auto const node = json_array_get(root, i);

    if (!node)
    {
      LOG(LERROR, ("Incorrect server response."));
      return {};
    }

    string name;
    FromJSONObject(node, kNameKey, name);
    int64_t size;
    FromJSONObject(node, kSizeKey, size);
    // Invalid size. The diff is not available.
    if (size < 0)
      continue;

    if (nameVersionMap.find(name) == nameVersionMap.end())
    {
      LOG(LERROR, ("Incorrect country name in response:", name));
      return {};
    }

    DiffInfo info(size, nameVersionMap.at(name));
    diffs.emplace(move(name), move(info));
  }

  return diffs;
}

NameDiffInfoMap Load(LocalMapsInfo const & info)
{
  if (info.m_localMaps.empty())
    return {};

  platform::HttpClient request(DIFF_LIST_URL);
  string const body = SerializeCheckerData(info);
  ASSERT(!body.empty(), ());
  request.SetBodyData(body, "application/json");
  request.SetTimeout(kTimeoutInSeconds);
  request.SetRawHeader("User-Agent", GetPlatform().GetAppUserAgent());
  NameDiffInfoMap diffs;
  if (request.RunHttpRequest() && !request.WasRedirected() && request.ErrorCode() == 200)
  {
    diffs = DeserializeResponse(request.ServerResponse(), info.m_localMaps);
  }
  else
  {
    ostringstream ost;
    ost << "Request to diffs server failed. Code = " << request.ErrorCode()
        << ", redirection = " << request.WasRedirected();
    LOG(LINFO, (ost.str()));
    alohalytics::Stats::Instance().LogEvent("Downloader_DiffScheme_error",
                                            {{"type", "network"}, {"error", ost.str()}});
  }

  return diffs;
}
}  // namespace

namespace storage
{
namespace diffs
{
// static
void Loader::Load(LocalMapsInfo && info, DiffsReceivedCallback && callback)
{
  GetPlatform().RunTask(Platform::Thread::Network, [info = move(info), callback = move(callback)]() {
    auto result = ::Load(info);
    GetPlatform().RunTask(Platform::Thread::Gui,
                          [result = move(result), callback = move(callback)]() mutable {
                            callback(move(result));
                          });
  });
}
}  // namespace diffs
}  // namespace storage