/*
 * Copyright (C) 2009 Tommi Maekitalo
 *
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public License as
 * published by the Free Software Foundation; either version 2 of the
 * License, or (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful, but
 * is provided AS IS, WITHOUT ANY WARRANTY; without even the implied
 * warranty of MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE, and
 * NON-INFRINGEMENT.  See the GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301 USA
 *
 */

#include <zim/writer/dbsource.h>
#include <zim/blob.h>
#include <tntdb/connect.h>
#include <tntdb/error.h>
#include <cxxtools/arg.h>
#include <cxxtools/log.h>
#include <stdexcept>
#include <sstream>
#include <limits>

log_define("zim.writer.dbsource")

namespace zim
{
  namespace writer
  {
    std::string DbArticle::getAid() const
    {
      log_debug("getAid");
      return row[0].getString();
    }

    char DbArticle::getNamespace() const
    {
      log_debug("getNamespace");
      return row[1].getChar();
    }

    std::string DbArticle::getUrl() const
    {
      log_debug("getTitle");
      return row[2].getString();
    }

    std::string DbArticle::getTitle() const
    {
      log_debug("getTitle");
      return row[3].getString();
    }

    bool DbArticle::isRedirect() const
    {
      log_debug("isRedirect");
      return !row[5].isNull();
    }

    std::string DbArticle::getMimeType() const
    {
      log_debug("getMimeType");
      if (row[4].isNull())
      {
        std::ostringstream msg;
        msg << "article " << getNamespace() << '/' << getTitle() << " has no mime type";
        throw std::runtime_error(msg.str());
      }

      return row[4].getString();
    }

    bool DbArticle::shouldCompress() const
    {
      log_debug("shouldCompress");
      return row[6].getBool();
    }

    std::string DbArticle::getRedirectAid() const
    {
      log_debug("getRedirectAid");
      return row[5].getString();
    }

    DbSource::DbSource(int& argc, char* argv[])
      : initialized(false),
        dburl(cxxtools::Arg<std::string>(argc, argv, "--db", "postgresql:dbname=zim"))
    {
    }

    void DbSource::setFilename(const std::string& fname)
    {
      conn = tntdb::connect(dburl);
      selData = conn.prepare("select data from article where aid = :aid");

      tntdb::Statement s = conn.prepare("select zid from zimfile where filename = :filename");
      try
      {
        tntdb::Value v = s.set("filename", fname).selectValue();
        zid = v.getUnsigned();
      }
      catch (const tntdb::NotFound&)
      {
        std::ostringstream msg;
        msg << "file \"" << fname << "\" not defined in database table zimfile";
        throw std::runtime_error(msg.str());
      }

      stmt = conn.prepare(
        "select a.aid, a.namespace, a.url, a.title, m.mimetype, r.aid, m.compress"
        "  from article a"
        "  left outer join mimetype m"
        "    on m.id = a.mimetype"
        "  join zimarticle z"
        "    on a.aid = z.aid"
        "  left outer join article r"
        "    on a.redirect = r.url"
        " where z.zid = :zid"
        "   and (a.redirect is null"
        "          or r.aid is not null)");
      stmt.set("zid", zid);

      current = stmt.end();
    }

    const Article* DbSource::getNextArticle()
    {
      log_debug("getNextArticle");

      if (initialized)
      {
        log_debug("fetch next");
        ++current;
      }
      else
      {
        log_debug("initialize cursor");
        current = stmt.begin();
        initialized = true;
      }

      if (current == stmt.end())
      {
        log_debug("the end");
        return 0;
      }

      article = DbArticle(*current);

      return &article;
    }

    Blob DbSource::getData(const std::string& aid)
    {
      dataValue = selData.set("aid", aid)
                         .selectValue();
      dataValue.getBlob(dataBlob);
      return Blob(dataBlob.data(), dataBlob.size());
    }

    std::string DbSource::getMainPage()
    {
      tntdb::Statement stmt = conn.prepare("select mainpage from zimfile where zid = :zid");
      stmt.set("zid", zid);
      tntdb::Value v = stmt.selectValue();
      return v.isNull() ? std::string() : v.getString();
    }

    std::string DbSource::getLayoutPage()
    {
      tntdb::Statement stmt = conn.prepare("select layoutpage from zimfile where zid = :zid");
      stmt.set("zid", zid);
      tntdb::Value v = stmt.selectValue();
      return v.isNull() ? std::string() : v.getString();
    }

  }

}