#ifdef _WIN32

//! Windows netword DLL init

WORD version = MAKEWORD(2, 2);

WSADATA data;

if (WSAStartup(version, &data) != 0) {

std::cerr << "WSAStartup() failure" << std::endl;

return -1;

}

#endif /* _WIN32 */

//! Enable logging

cpp_redis::active_logger = std::unique_ptr<cpp_redis::logger>(new cpp_redis::logger);

cpp_redis::subscriber sub;

sub.connect("127.0.0.1", 6379, [](const std::string& host, std::size_t port, cpp_redis::subscriber::connect_state status) {

if (status == cpp_redis::subscriber::connect_state::dropped) {

std::cout << "client disconnected from " << host << ":" << port << std::endl;

should_exit.notify_all();

}

});

//! authentication if server-server requires it

// sub.auth("some_password", [](const cpp_redis::reply& reply) {

// if (reply.is_error()) { std::cerr << "Authentication failed: " << reply.as_string() << std::endl; }

// else {

// std::cout << "successful authentication" << std::endl;

// }

// });

sub.subscribe("some_chan", [](const std::string& chan, const std::string& msg) {

std::cout << "MESSAGE " << chan << ": " << msg << std::endl;

});

sub.psubscribe("*", [](const std::string& chan, const std::string& msg) {

std::cout << "PMESSAGE " << chan << ": " << msg << std::endl;

});

sub.commit();

signal(SIGINT, &sigint_handler);

std::mutex mtx;

std::unique_lock<std::mutex> l(mtx);

should_exit.wait(l);

#ifdef _WIN32

WSACleanup();

#endif /* _WIN32 */

return 0;