2015-09-25 00:45:13 +02:00
|
|
|
#include <exception>
|
|
|
|
#include <iostream>
|
|
|
|
#include <string>
|
2015-09-25 13:11:36 +02:00
|
|
|
#include <thread>
|
2015-09-25 00:45:13 +02:00
|
|
|
|
|
|
|
#include <boost/asio.hpp>
|
|
|
|
#include <boost/program_options.hpp>
|
|
|
|
|
|
|
|
#include "config.h"
|
2015-09-29 14:33:53 +02:00
|
|
|
|
|
|
|
#include "../lib/clientmessage.h"
|
|
|
|
#include "../lib/logger.h"
|
|
|
|
#include "../lib/response.h"
|
2015-09-25 00:45:13 +02:00
|
|
|
|
2015-09-28 17:05:05 +02:00
|
|
|
#include "mainwindow.h"
|
2015-09-25 13:11:36 +02:00
|
|
|
|
2015-09-25 00:45:13 +02:00
|
|
|
// Info about doorlock-client version
|
|
|
|
const static std::string version =
|
|
|
|
"doorlock-client-" DOORLOCK_VERSION;
|
|
|
|
const static std::string gitversion =
|
|
|
|
DOORLOCK_GIT_BRANCH "-" DOORLOCK_GIT_COMMIT_HASH;
|
|
|
|
|
|
|
|
const static Logger &l = Logger::get();
|
|
|
|
|
|
|
|
namespace po = boost::program_options;
|
|
|
|
using boost::asio::ip::tcp;
|
|
|
|
|
|
|
|
boost::asio::io_service io_service;
|
|
|
|
|
|
|
|
const static std::string subscriptionCommand =
|
|
|
|
"{ \"command\": \"subscribe\"}";
|
|
|
|
|
|
|
|
// The receive buffer length of the TCP socket
|
|
|
|
const int constexpr SOCKET_BUFFERLENGTH = 2048;
|
|
|
|
|
2015-09-25 13:11:36 +02:00
|
|
|
static volatile bool run = true;
|
|
|
|
|
2015-09-28 17:05:05 +02:00
|
|
|
std::unique_ptr<MainWindow> mainWindow = nullptr;
|
2015-09-25 13:11:36 +02:00
|
|
|
|
2015-09-29 02:13:48 +02:00
|
|
|
static void onDoorlockUpdate(const Clientmessage &msg)
|
2015-09-24 21:22:51 +02:00
|
|
|
{
|
2015-09-29 14:55:20 +02:00
|
|
|
const auto& doormessage = msg.doormessage();
|
|
|
|
l("Received message", LogLevel::info);
|
|
|
|
l((std::string)" token" + msg.token(),
|
|
|
|
LogLevel::info);
|
|
|
|
l((std::string)" open: " + std::to_string(doormessage.isOpen),
|
|
|
|
LogLevel::info);
|
|
|
|
l((std::string)" button lock: " + std::to_string(doormessage.isLockButton),
|
|
|
|
LogLevel::info);
|
|
|
|
l((std::string)" button unlock: " + std::to_string(doormessage.isUnlockButton),
|
|
|
|
LogLevel::info);
|
|
|
|
l((std::string)" emergency open: " + std::to_string(doormessage.isEmergencyUnlock),
|
|
|
|
LogLevel::info);
|
2015-09-28 17:05:05 +02:00
|
|
|
if (mainWindow) {
|
2015-09-29 02:13:48 +02:00
|
|
|
mainWindow->setQRCode(msg.token());
|
2015-09-25 13:11:36 +02:00
|
|
|
}
|
|
|
|
}
|
|
|
|
|
2015-09-25 00:45:13 +02:00
|
|
|
static int doorlock_client(const std::string &hostname,
|
|
|
|
const unsigned short port)
|
|
|
|
{
|
|
|
|
int retval = 0;
|
|
|
|
|
|
|
|
try {
|
|
|
|
tcp::resolver resolver(io_service);
|
|
|
|
tcp::socket socket(io_service);
|
|
|
|
tcp::resolver::query query(hostname, std::to_string(port));
|
|
|
|
tcp::resolver::iterator endpoint_iterator = resolver.resolve(query);
|
|
|
|
tcp::resolver::iterator end;
|
|
|
|
boost::system::error_code error = boost::asio::error::host_not_found;
|
|
|
|
size_t length;
|
|
|
|
std::vector<char> data;
|
|
|
|
|
|
|
|
while (error && endpoint_iterator != end) {
|
|
|
|
socket.close();
|
|
|
|
socket.connect(*endpoint_iterator++, error);
|
|
|
|
}
|
|
|
|
if (error)
|
|
|
|
throw boost::system::system_error(error);
|
|
|
|
|
|
|
|
// After connection is established, send the subscription command
|
|
|
|
socket.write_some(boost::asio::buffer(subscriptionCommand), error);
|
|
|
|
if (error)
|
|
|
|
throw boost::system::system_error(error);
|
|
|
|
|
|
|
|
data.resize(SOCKET_BUFFERLENGTH);
|
2015-09-25 13:11:36 +02:00
|
|
|
for (;run;) {
|
2015-09-25 00:45:13 +02:00
|
|
|
length = socket.read_some(boost::asio::buffer(data), error);
|
|
|
|
if (error)
|
|
|
|
throw boost::system::system_error(error);
|
|
|
|
|
|
|
|
const auto message = Clientmessage::fromJson(std::string(data.begin(), data.begin()+length));
|
2015-09-29 02:13:48 +02:00
|
|
|
onDoorlockUpdate(message);
|
2015-09-25 00:45:13 +02:00
|
|
|
}
|
|
|
|
}
|
|
|
|
catch(const std::exception &e)
|
|
|
|
{
|
|
|
|
l(LogLevel::error, e.what());
|
|
|
|
goto out;
|
|
|
|
}
|
|
|
|
|
|
|
|
out:
|
|
|
|
return retval;
|
|
|
|
}
|
|
|
|
|
|
|
|
int main(int argc, char** argv)
|
|
|
|
{
|
|
|
|
std::string hostname;
|
|
|
|
unsigned short port;
|
|
|
|
|
|
|
|
l((std::string)"Hello, this is " + version + " built on " + gitversion,
|
|
|
|
LogLevel::info);
|
|
|
|
|
|
|
|
try {
|
|
|
|
po::options_description desc("doorlockd (" + version + " built on " + gitversion + ")");
|
|
|
|
desc.add_options()
|
|
|
|
("help,h",
|
|
|
|
"print help")
|
|
|
|
("port,p",
|
|
|
|
po::value<unsigned short>(&port)->default_value(DEFAULT_PORT),
|
|
|
|
"Port")
|
|
|
|
("host,c",
|
|
|
|
po::value<std::string>(&hostname)->default_value("localhost"),
|
|
|
|
"IP or name of host running doorlockd");
|
|
|
|
|
|
|
|
po::variables_map vm;
|
|
|
|
po::store(po::command_line_parser(argc, argv).options(desc).run(), vm);
|
|
|
|
|
|
|
|
if (vm.count("help"))
|
|
|
|
{
|
|
|
|
std::cout << desc << std::endl;
|
2015-09-29 02:13:48 +02:00
|
|
|
exit(-1);
|
2015-09-25 00:45:13 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
po::notify(vm);
|
|
|
|
}
|
|
|
|
catch(const std::exception &e)
|
|
|
|
{
|
|
|
|
l(LogLevel::error, e.what());
|
2015-09-29 02:13:48 +02:00
|
|
|
exit(-1);
|
2015-09-25 00:45:13 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
l(LogLevel::notice, "Starting doorlock-client");
|
2015-09-25 13:11:36 +02:00
|
|
|
|
2015-09-29 02:13:48 +02:00
|
|
|
QApplication app(argc, argv);
|
|
|
|
app.setOrganizationName("Binary Kitchen");
|
|
|
|
app.setApplicationName("doorlock-client");
|
|
|
|
|
|
|
|
mainWindow = std::unique_ptr<MainWindow>(new MainWindow);
|
|
|
|
mainWindow->showFullScreen();
|
|
|
|
|
|
|
|
// Start the TCP client as thread
|
|
|
|
std::thread clientThread = std::thread([&] () {
|
|
|
|
// If the TCP client returns, an error has occured
|
|
|
|
// In normal operation, it never returns
|
|
|
|
doorlock_client(hostname, port);
|
|
|
|
|
|
|
|
// Stop the QT application
|
|
|
|
app.quit();
|
|
|
|
});
|
|
|
|
|
|
|
|
// This routine will never return in normal operation
|
|
|
|
app.exec();
|
|
|
|
|
|
|
|
clientThread.join();
|
2015-09-25 00:45:13 +02:00
|
|
|
|
|
|
|
l(LogLevel::notice, "Stopping doorlock-client");
|
2015-09-29 02:13:48 +02:00
|
|
|
return 0;
|
2015-09-24 21:22:51 +02:00
|
|
|
}
|