DBService.cpp

Go to the documentation of this file.

/*
    Copyright (C) 2014-2016 Leosac
 
    This file is part of Leosac.
 
    Leosac is free software: you can redistribute it and/or modify
    it under the terms of the GNU Affero General Public License as published by
    the Free Software Foundation, either version 3 of the License, or
    (at your option) any later version.
 
    Leosac is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
    GNU Affero General Public License for more details.
 
    You should have received a copy of the GNU Affero General Public License
    along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
 
#include "DBService.hpp"
#include "DatabaseTracer.hpp"
#include "OptionalTransaction.hpp"
#include "core/audit/AuditEntry.hpp"
#include "core/audit/AuditEntry_odb.h"
#include "core/auth/AccessPoint_odb.h"
#include "core/auth/Door_odb.h"
#include "core/auth/Group_odb.h"
#include "core/auth/User_odb.h"
#include "core/auth/Zone_odb.h"
#include "core/credentials/Credential_odb.h"
#include "exception/EntityNotFound.hpp"
#include "tools/AssertCast.hpp"
#include "tools/Schedule_odb.h"
#include "tools/log.hpp"
#include <odb/database.hxx>
 
using namespace Leosac;
 
 
DBService::DBService(DBPtr db)
    : database_(db)
{
    ASSERT_LOG(database_, "Not valid database pointer for DBService.");
}
 
DBPtr DBService::db() const
{
    return database_;
}
 
size_t DBService::operation_count() const
{
    if (database_->tracer())
    {
        auto tracer = assert_cast<db::DatabaseTracer *>(database_->tracer());
        return tracer->count();
    }
    return 0;
}
 
Auth::GroupPtr DBService::find_group_by_id(const Auth::GroupId &id, Flag flags)
{
    db::OptionalTransaction t(database_->begin());
    auto grp = database_->find<Auth::Group>(id);
    t.commit();
    if (!grp && flags & Flag::THROW_IF_NOT_FOUND)
        throw EntityNotFound(id, "group");
    return grp;
}
 
Auth::UserPtr DBService::find_user_by_id(const Auth::UserId &id, Flag flags)
{
    db::OptionalTransaction t(database_->begin());
    auto user = database_->find<Auth::User>(id);
    t.commit();
    if (!user && flags & Flag::THROW_IF_NOT_FOUND)
        throw EntityNotFound(id, "user");
    return user;
}
 
Auth::UserGroupMembershipPtr
DBService::find_membership_by_id(const Auth::UserGroupMembershipId &id, Flag flags)
{
    db::OptionalTransaction t(database_->begin());
    auto ugm = database_->find<Auth::UserGroupMembership>(id);
    t.commit();
    if (!ugm && flags & Flag::THROW_IF_NOT_FOUND)
        throw EntityNotFound(id, "user-group-membership");
    return ugm;
}
 
Cred::ICredentialPtr DBService::find_credential_by_id(const Cred::CredentialId &id,
                                                      DBService::Flag flags)
{
    db::OptionalTransaction t(database_->begin());
    auto cred = database_->find<Cred::Credential>(id);
    t.commit();
    if (!cred && flags & Flag::THROW_IF_NOT_FOUND)
        throw EntityNotFound(id, "credential");
    return cred;
}
 
Tools::ISchedulePtr DBService::find_schedule_by_id(const Tools::ScheduleId &id,
                                                   DBService::Flag flags)
{
    db::OptionalTransaction t(database_->begin());
    auto sched = database_->find<Tools::Schedule>(id);
    t.commit();
    if (!sched && flags & Flag::THROW_IF_NOT_FOUND)
        throw EntityNotFound(id, "schedule");
    return sched;
}
 
Auth::IDoorPtr DBService::find_door_by_id(const Auth::DoorId &id,
                                          DBService::Flag flags)
{
    db::OptionalTransaction t(database_->begin());
    auto door = database_->find<Auth::Door>(id);
    t.commit();
    if (!door && flags & Flag::THROW_IF_NOT_FOUND)
        throw EntityNotFound(id, "door");
    return door;
}
 
Auth::IZonePtr DBService::find_zone_by_id(const Auth::ZoneId &id,
                                          DBService::Flag flags)
{
    db::OptionalTransaction t(database_->begin());
    auto zone = database_->find<Auth::Zone>(id);
    t.commit();
    if (!zone && flags & Flag::THROW_IF_NOT_FOUND)
        throw EntityNotFound(id, "zone");
    return zone;
}
 
 
Audit::IAuditEntryPtr DBService::find_audit_by_id(const Audit::AuditEntryId &id,
                                                  Flag flags)
{
    db::OptionalTransaction t(database_->begin());
    auto audit = database_->find<Audit::AuditEntry>(id);
    t.commit();
    if (!audit && flags & Flag::THROW_IF_NOT_FOUND)
        throw EntityNotFound(id, "audit-entry");
    audit->database(database_);
    return audit;
}
 
 
Auth::IAccessPointPtr
DBService::find_access_point_by_id(const Auth::AccessPointId &id,
                                   DBService::Flag flags)
{
    db::OptionalTransaction t(database_->begin());
    auto ap = database_->find<Auth::AccessPoint>(id);
    t.commit();
    if (!ap && flags & Flag::THROW_IF_NOT_FOUND)
        throw EntityNotFound(id, "door");
    return ap;
}
 
update::IUpdatePtr DBService::find_update_by_id(const update::UpdateId &id,
                                                DBService::Flag flags)
{
    db::OptionalTransaction t(database_->begin());
    auto ap = database_->find<update::Update>(id);
    t.commit();
    if (!ap && flags & Flag::THROW_IF_NOT_FOUND)
        throw EntityNotFound(id, "update");
    return ap;
}
 
template <typename T>
static void persist_impl(const DBPtr db, T &&obj)
{
    db::OptionalTransaction t(db->begin());
    ASSERT_LOG(obj.id() == 0, "Object is probably already persisted.");
    db->persist(std::forward<T>(obj));
    t.commit();
}
 
template <typename T>
static void update_impl(const DBPtr db, T &&obj)
{
    db::OptionalTransaction t(db->begin());
    db->update(std::forward<T>(obj));
    t.commit();
}
 
void DBService::persist(Audit::IAuditEntry &ientry)
{
    persist_impl(database_, assert_cast<Audit::AuditEntry &>(ientry));
}
 
void DBService::update(Audit::IAuditEntry &ientry)
{
    update_impl(database_, assert_cast<Audit::AuditEntry &>(ientry));
}