#include "storage_builder.hpp"

#include "../env/writer.hpp"
#include "../env/assert.hpp"
#include "../env/logging.hpp"
#include "../env/latlon.hpp"

#include "../std/fstream.hpp"
#include "../std/iterator.hpp"


namespace
{

template <class ToDo>
void ProcessEntriesFile(string const & path, ToDo & toDo)
{
  ifstream fs(path.c_str());

  string str;
  vector<string> entries;

  while (!fs.eof())
  {
    getline(fs, str);
    if (str.empty())
      continue;

    entries.clear();
    str::Tokenize(str, "\t ", MakeBackInserter(entries));

    toDo(entries);
  }
}

bool EncodeTitle(string & s)
{
  CHECK(!s.empty(), ());

  // strip prefix before / or \.
  size_t const i = s.find_last_of("\\/");
  if (i != string::npos)
  {
    s = s.substr(i+1);

    if (s.empty())
      return false;
  }

  replace(s.begin(), s.end(), '_', ' ');
  return true;
}

class DoAddEntries
{
  StorageBuilder & m_storage;
public:
  DoAddEntries(StorageBuilder & storage) : m_storage(storage) {}

  void operator() (vector<string> const & entries)
  {
    CHECK(entries.size() == 8, (entries));

    string title = entries[1];
    if (!EncodeTitle(title))
      return;

    ArticleInfoBuilder builder(title);
    builder.SetParams(entries);
    m_storage.Add(builder);
  }
};

class DoAddRedirects
{
  StorageBuilder & m_storage;
public:
  DoAddRedirects(StorageBuilder & storage) : m_storage(storage) {}

  void operator() (vector<string> const & entries)
  {
    CHECK(entries.size() == 4, (entries));

    ArticleInfoBuilder const * p = m_storage.GetArticle(entries[2]);
    if (p)
    {
      string title = entries[1];
      if (!EncodeTitle(title))
        return;

      m_storage.Add(ArticleInfoBuilder(title, *p, true));
    }
    else
      LOG(WARNING, ("No article for url:", entries[2]));
  }
};

class DoAddGeocodes
{
  StorageBuilder & m_storage;

  static double ToDouble(string const & s)
  {
    char * stop;
    double const d = strtod(s.c_str(), &stop);
    CHECK(stop && *stop == 0, (s));
    return d;
  }

public:
  DoAddGeocodes(StorageBuilder & storage) : m_storage(storage) {}

  void operator() (vector<string> const & entries)
  {
    CHECK(entries.size() == 3, (entries));

    ArticleInfoBuilder * p = m_storage.GetArticle(entries[0]);
    if (p)
    {
      double const lat = ToDouble(entries[1]);
      double const lon = ToDouble(entries[2]);

      if (ll::ValidLat(lat) && ll::ValidLon(lon))
        p->SetLatLon(lat, lon);
      else
        LOG(WARNING, ("Bad Lat, Lon:", entries[1], entries[2]));
    }
  }
};

}

void ArticleInfoBuilder::SetParams(vector<string> const & entries)
{
  m_url = entries[0];
  m_length = atoi(entries[2].c_str());
  CHECK(m_length != 0, (entries[2]));
  m_parentUrl = entries[4];
}

void StorageBuilder::ParseEntries(string const & path)
{
  DoAddEntries doAdd(*this);
  ProcessEntriesFile(path, doAdd);
}

void StorageBuilder::ParseRedirects(string const & path)
{
  DoAddRedirects doAdd(*this);
  ProcessEntriesFile(path, doAdd);
}

void StorageBuilder::ParseGeocodes(string const & path)
{
  DoAddGeocodes doAdd(*this);
  ProcessEntriesFile(path, doAdd);

  for (size_t i = 0; i < m_info.size(); ++i)
  {
    if (m_info[i].m_redirect)
    {
      ArticleInfoBuilder const * p = GetArticle(m_info[i].m_url);
      CHECK(p, ());
      m_info[i].SetLatLon(p->m_lat, p->m_lon);
    }
  }
}

void StorageBuilder::Add(ArticleInfoBuilder const & info)
{
  m_info.push_back(info);
  if (!info.m_redirect)
    CHECK(m_url2info.insert(make_pair(info.m_url, m_info.size()-1)).second, (info.m_url));
}

void StorageBuilder::ProcessArticles()
{
  sort(m_info.begin(), m_info.end(), ArticleInfo::LessStorage());

  size_t const count = m_info.size();
  for (size_t i = 0; i < count; ++i)
  {
    for (size_t j = 0; j < count; ++j)
    {
      if (i != j && !m_info[j].m_redirect && m_info[i].m_parentUrl == m_info[j].m_url)
      {
        m_info[i].m_parentIndex = j;
        break;
      }
    }
  }
}

void StorageBuilder::Save(string const & path)
{
  ProcessArticles();

  try
  {
    wr::FileWriter w(path);
    size_t const count = m_info.size();
    w.Write(static_cast<uint32_t>(count));

    for (size_t i = 0; i < count; ++i)
      m_info[i].Write(w);
  }
  catch (file::FileException const & ex)
  {
    LOG(ERROR, (ex));
  }
}

void StorageBuilder::Load(string const & path)
{
  Storage s;
  s.Load(path);

  m_info.assign(s.m_info.begin(), s.m_info.end());
}

void StorageBuilder::Assign(Storage & storage)
{
  ProcessArticles();

  storage.m_info.assign(m_info.begin(), m_info.end());
}

bool StorageBuilder::operator == (Storage const & s) const
{
  if (m_info.size() != s.m_info.size())
    return false;

  for (size_t i = 0; i < m_info.size();++i)
    if (!(m_info[i] == s.m_info[i]))
      return false;

  return true;
}


void StorageBuilder::InitMock()
{
  ArticleInfoBuilder i1("London");
  i1.m_url = "London";
  i1.m_parentUrl = "Great_Britain";
  i1.m_lat = 51.50726;
  i1.m_lon = -0.12765;
  Add(i1);

  ArticleInfoBuilder i2("Lancaster");
  i2.m_url = "Lancaster";
  i2.m_parentUrl = "Great_Britain";
  i2.m_lat = 54.04839;
  i2.m_lon = -2.79904;
  Add(i2);

  ArticleInfoBuilder i3("Great Britain");
  i3.m_url = "Great_Britain";
  i3.m_lat = 54.70235;
  i3.m_lon = -3.27656;
  Add(i3);
}

StorageMock::StorageMock()
{
  StorageBuilder builder;
  builder.InitMock();
  builder.Assign(*this);
}