1
0
Fork 0
mirror of https://github.com/KingDuckZ/incredis synced 2024-12-01 00:45:42 +00:00
incredis/test/integration/redis_connection_fixture.cpp

45 lines
1.2 KiB
C++
Raw Normal View History

#include "redis_connection_fixture.hpp"
#include "catch.hpp"
#include "incredis/incredis.hpp"
#include <ciso646>
namespace incredis {
namespace test {
extern std::string g_hostname;
extern uint16_t g_port;
extern std::string g_socket;
extern uint32_t g_db;
RedisConnectionFixture::RedisConnectionFixture() :
m_hostname(g_hostname),
m_socket(g_socket),
m_db(g_db),
m_port(g_port)
{
if (use_socket_connection())
m_incredis.reset(new redis::IncRedis(std::string(m_socket)));
else
m_incredis.reset(new redis::IncRedis(std::string(m_hostname), m_port));
m_incredis->connect();
m_incredis->wait_for_connect();
REQUIRE_FALSE(not m_incredis->is_connected());
auto batch = m_incredis->make_batch();
batch.select(m_db);
batch.client_setname("IncredisIntegrationTest");
batch.script_flush();
REQUIRE_NOTHROW(batch.throw_if_failed());
}
RedisConnectionFixture::~RedisConnectionFixture() noexcept = default;
bool RedisConnectionFixture::use_socket_connection() const {
return not m_socket.empty();
}
redis::IncRedis& RedisConnectionFixture::incredis() {
return *m_incredis;
}
} //namespace test
} //namespace incredis