refs #478, test adjust to new classes

This commit is contained in:
Klaus Basan
2015-10-14 02:43:05 +02:00
committed by Mathew Sutcliffe
parent 166963af5b
commit 85b7801bb9
2 changed files with 18 additions and 27 deletions

View File

@@ -9,8 +9,8 @@
#include "testreaders.h" #include "testreaders.h"
#include "expect.h" #include "expect.h"
#include "blackcore/settings/global_reader_settings.h" #include "blackcore/data/globalsetup.h"
#include "blackmisc/networkutils.h" #include "blackmisc/network/networkutils.h"
#include "blackmisc/aviation/aircrafticaocode.h" #include "blackmisc/aviation/aircrafticaocode.h"
#include "blackmisc/aviation/airlineicaocode.h" #include "blackmisc/aviation/airlineicaocode.h"
@@ -23,32 +23,23 @@ using namespace BlackMisc::Network;
namespace BlackCoreTest namespace BlackCoreTest
{ {
CTestReaders::CTestReaders(QObject *parent) : CTestReaders::CTestReaders(QObject *parent) :
QObject(parent), QObject(parent),
m_icaoReader(this, m_icaoReader(this),
CGlobalReaderSettings::instance().protocolIcaoReader(), m_modelReader(this)
CGlobalReaderSettings::instance().serverIcaoReader(),
CGlobalReaderSettings::instance().baseUrlIcaoReader()
),
m_modelReader(this,
CGlobalReaderSettings::instance().protocolModelReader(),
CGlobalReaderSettings::instance().serverModelReader(),
CGlobalReaderSettings::instance().baseUrlModelReader()
)
{ } { }
void CTestReaders::readIcaoData() void CTestReaders::readIcaoData()
{ {
QString server(CGlobalReaderSettings::instance().serverIcaoReader()); CUrl url(m_setup.get().dbIcaoReader());
if (!pingServer(server)) { return; } if (!this->pingServer(url)) { return; }
m_icaoReader.start(); m_icaoReader.start();
Expect e(&this->m_icaoReader); Expect e(&this->m_icaoReader);
EXPECT_UNIT(e) EXPECT_UNIT(e)
.send(&CIcaoDataReader::readInBackgroundThread, CEntityFlags::AllIcaoEntities) .send(&CIcaoDataReader::readInBackgroundThread, CEntityFlags::AllIcaoEntities)
.expect(&CIcaoDataReader::dataRead, [server]() .expect(&CIcaoDataReader::dataRead, [url]()
{ {
qDebug() << "Read ICAO data from" << server; qDebug() << "Read ICAO data from" << url.getFullUrl();
}) })
.wait(10); .wait(10);
@@ -63,16 +54,15 @@ namespace BlackCoreTest
void CTestReaders::readModelData() void CTestReaders::readModelData()
{ {
QString server(CGlobalReaderSettings::instance().serverModelReader()); CUrl url(m_setup.get().dbModelReader());
if (!pingServer(server)) { return; } if (!this->pingServer(url)) { return; }
m_modelReader.start(); m_modelReader.start();
Expect e(&this->m_modelReader); Expect e(&this->m_modelReader);
EXPECT_UNIT(e) EXPECT_UNIT(e)
.send(&CModelDataReader::readInBackgroundThread, CEntityFlags::AllIcaoEntities) .send(&CModelDataReader::readInBackgroundThread, CEntityFlags::AllIcaoEntities)
.expect(&CModelDataReader::dataRead, [server]() .expect(&CModelDataReader::dataRead, [url]()
{ {
// CDbFlags::flagToString(entity) << CDbFlags::flagToString(state) << number qDebug() << "Read model data " << url;
qDebug() << "Read model data " << server;
}) })
.wait(10); .wait(10);
@@ -85,12 +75,12 @@ namespace BlackCoreTest
QVERIFY2(distributor.hasCompleteData(), "Missing data for distributor"); QVERIFY2(distributor.hasCompleteData(), "Missing data for distributor");
} }
bool CTestReaders::pingServer(const QString &server) bool CTestReaders::pingServer(const CUrl &url)
{ {
QString m; QString m;
if (!CNetworkUtils::canConnect(server, 80, m, 2500)) if (!CNetworkUtils::canConnect(url, m, 2500))
{ {
qWarning() << "Skipping unit test as" << server << "cannot be connected"; qWarning() << "Skipping unit test as" << url.getFullUrl() << "cannot be connected";
return false; return false;
} }
return true; return true;

View File

@@ -38,11 +38,12 @@ namespace BlackCoreTest
void readModelData(); void readModelData();
private: private:
BlackCore::CIcaoDataReader m_icaoReader; BlackCore::CIcaoDataReader m_icaoReader;
BlackCore::CModelDataReader m_modelReader; BlackCore::CModelDataReader m_modelReader;
BlackCore::CData<BlackCore::Data::GlobalSetup> m_setup {this}; //!< setup cache
//! Test if server is available //! Test if server is available
static bool pingServer(const QString &server); static bool pingServer(const BlackMisc::Network::CUrl &url);
}; };
} //namespace } //namespace