/*
 * account.cpp -- account management
 *
 * Copyright (c) 2013-2016 David Demelier <markand@malikania.fr>
 *
 * Permission to use, copy, modify, and/or distribute this software for any
 * purpose with or without fee is hereby granted, provided that the above
 * copyright notice and this permission notice appear in all copies.
 *
 * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
 * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
 * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
 * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
 * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
 * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
 * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
 */

#include <cassert>
#include <sstream>
#include <stdexcept>
#include <vector>

#include <malikania/dynlib.hpp>
#include <malikania/account.hpp>

#include "driver.hpp"

using namespace malikania;

extern "C" {

namespace {

Account toAccount(PGresult *result, int i)
{
    assert(i < PQntuples(result));

    Account account;

    account.setId(static_cast<std::uint64_t>(std::stoll(PQgetvalue(result, i, 0))));
    account.setName(PQgetvalue(result, i, 1));
    account.setEmail(PQgetvalue(result, i, 2));
    account.setFirstName(PQgetvalue(result, i, 3));
    account.setLastName(PQgetvalue(result, i, 4));
    account.setPassword(PQgetvalue(result, i, 6));

    return account;
}

} // !namespace

DYNLIB_EXPORT void malikania_account_create(Account &account)
{
    std::ostringstream oss;

    oss << "insert into mk_account(ac_name, ac_email, ac_firstname, ac_lastname, ac_password) values (";
    oss << pgsql::escape(account.name()) << ", ";
    oss << pgsql::escape(account.email()) << ", ";
    oss << pgsql::escape(account.firstName()) << ", ";
    oss << pgsql::escape(account.lastName()) << ", ";
    oss << pgsql::escape(account.password()) << ") returning ac_id";

    std::shared_ptr<PGresult> result = pgsql::exec(oss.str());

    account.setId(static_cast<std::uint64_t>(std::stoll(PQgetvalue(result.get(), 0, 0))));
}

DYNLIB_EXPORT void malikania_account_update(Account &account)
{
    std::ostringstream oss;

    oss << "update mk_account set ";
    oss << "ac_name = " << pgsql::escape(account.name()) << ", ";
    oss << "ac_email = " << pgsql::escape(account.email()) << ", ";
    oss << "ac_firstname = " << pgsql::escape(account.firstName()) << ", ";
    oss << "ac_lastname = " << pgsql::escape(account.lastName()) << ", ";
    oss << "ac_password = " << pgsql::escape(account.password()) << " ";
    oss << "where ac_id = " << account.id();

    pgsql::exec(oss.str());
}

DYNLIB_EXPORT void malikania_account_remove(const Account &account)
{
    std::ostringstream oss;

    oss << "delete from mk_account where ac_id = " << account.id();

    pgsql::exec(oss.str());
}

DYNLIB_EXPORT Account malikania_account_get(std::uint64_t id)
{
    std::ostringstream oss;

    oss << "select * from mk_account where ac_id = " << id;

    std::shared_ptr<PGresult> result = pgsql::exec(oss.str());

    if (PQntuples(result.get()) != 1)
        throw std::out_of_range("account not found");

    return toAccount(result.get(), 0);
}

DYNLIB_EXPORT std::vector<malikania::Account> malikania_account_list()
{
    std::vector<Account> accounts;
    std::shared_ptr<PGresult> result = pgsql::exec("select * from mk_account");

    for (int i = 0; i < PQntuples(result.get()); ++i)
        accounts.push_back(toAccount(result.get(), i));

    return accounts;
}

DYNLIB_EXPORT std::uint64_t malikania_account_count()
{
    std::shared_ptr<PGresult> result = pgsql::exec("select count(*) from mk_account");

    return static_cast<std::uint64_t>(std::stoll(PQgetvalue(result.get(), 0, 0)));
}

DYNLIB_EXPORT void malikania_account_clear()
{
    pgsql::exec("delete from mk_account");
}

}