1 #include "basetestcase.h"
2
getDummyConfig(QString name)3 RedisClient::ConnectionConfig BaseTestCase::getDummyConfig(QString name)
4 {
5 RedisClient::ConnectionConfig dummyConf("127.0.0.1", "", RedisClient::ConnectionConfig ::DEFAULT_REDIS_PORT, name);
6 dummyConf.setTimeouts(2000, 2000);
7 return dummyConf;
8 }
9
getRealConnectionWithDummyTransporter(const QStringList & expectedResponses)10 QSharedPointer<RedisClient::Connection> BaseTestCase::getRealConnectionWithDummyTransporter(const QStringList &expectedResponses)
11 {
12 RedisClient::ConnectionConfig dummyConf = getDummyConfig();
13
14 QSharedPointer<RedisClient::Connection> connection( new RedisClient::Connection(dummyConf));
15
16 QSharedPointer<DummyTransporter> transporter(new DummyTransporter(connection.data()));
17 transporter->setFakeResponses(expectedResponses);
18
19 connection->setTransporter(transporter.dynamicCast<RedisClient::AbstractTransporter>());
20 connection->connect();
21 return connection;
22 }
23
getFakeConnection(const QList<QVariant> & expectedScanResponses,const QStringList & expectedResponses,double version,bool raise_error)24 QSharedPointer<DummyConnection> BaseTestCase::getFakeConnection(const QList<QVariant> &expectedScanResponses, const QStringList &expectedResponses, double version, bool raise_error)
25 {
26 QSharedPointer<DummyConnection> connection(new DummyConnection(version, raise_error));
27 connection->fakeScanCollections.append(expectedScanResponses);
28 connection->setFakeResponses(expectedResponses);
29
30 return connection;
31 }
32
wait(int ms)33 void BaseTestCase::wait(int ms)
34 {
35 //wait for data
36 QEventLoop loop;
37 QTimer timeoutTimer;
38
39 timeoutTimer.setSingleShot(true);
40 QObject::connect(&timeoutTimer, SIGNAL(timeout()), &loop, SLOT(quit()));
41
42 timeoutTimer.start(ms);
43 loop.exec();
44 }
45
verifyExecutedCommandsCount(QSharedPointer<RedisClient::Connection> connection,uint valid_result)46 void BaseTestCase::verifyExecutedCommandsCount(QSharedPointer<RedisClient::Connection> connection, uint valid_result)
47 {
48 auto dummyTransporter = connection->getTransporter().dynamicCast<DummyTransporter>();
49 QCOMPARE((uint)dummyTransporter->addCommandCalls, valid_result);
50 }
51
getBulkStringReply(const QString & s)52 QString BaseTestCase::getBulkStringReply(const QString &s)
53 {
54 return QString("$%1\r\n%2\r\n").arg(s.size()).arg(s);
55 }
56