source: SMSSender/src/persistence/storage/DAAccountListManager.cpp @ 43:10dd65d71f7f

/*
 * DAAccountListManager.cpp
 *
 *  Created on: Aug 30, 2009
 *      Author: saemy
 */

#include "DAAccountListManager.h"

#include <QSqlQuery>

#include <igateway.h>
#include <StorageExceptions.h>
#include <typeconvert.h>

#include "../../business/BCGatewayManager.h"

#include "DAStorage.h"

DAAccountListManager* DAAccountListManager::instance_=0;
DAAccountListManager* DAAccountListManager::instance(){
    return instance_ ? instance_ : (instance_ = new DAAccountListManager);
}


IAccount* DAAccountListManager::getAccount(int accountId, bool skeletonOnly /* = false */) {
    QSqlQuery query = storage()->createQuery();
    query.exec("SELECT type "
                 "FROM t_accounts "
                 "WHERE (accountId = '" + QString::number(accountId) + "'); ");
    if (!query.next()) {
        throw Storage::EReadException(tr("No such account in the database! [accountId: %1]").arg(accountId));
    }

    IGateway* gateway = BCGatewayManager::instance()->getGateway(query.value(0).toString());

    // TODO: What if this gateway is NULL (is not loaded)?
    gateway->setDefaultStorage(storage());

    IAccount* account = gateway->createAccountInstance();
    account->setId(accountId);

    if (!skeletonOnly) {
        account->getStorageOfficer()->readFromStorage();
    }

    return account;
}

QSet<IAccount*> DAAccountListManager::getAccountList(bool skeletonsOnly /* = false */) {
    QSet<IAccount*> accountList;

    QSqlQuery query = storage()->createQuery();
    query.exec("SELECT accountId "
                 "FROM t_accounts;");
    while (query.next()) {
        try{
            IAccount* account = getAccount(query.value(0).toInt(), skeletonsOnly);
            accountList.insert(account);
        }catch (const Storage::EReadException& e){
            // TODO: What shall be done here?
        }
    }

    return accountList;
}


IStorage* DAAccountListManager::storage() {
    return DAStorage::instance();
}