hyperion.ng/libsrc/webserver/WebServer.cpp

130 lines
3.0 KiB
C++
Raw Normal View History

2018-12-27 23:11:32 +01:00
#include "webserver/WebServer.h"
#include "StaticFileServing.h"
#include "QtHttpServer.h"
2018-12-30 22:07:53 +01:00
#include <QFileInfo>
#include <QJsonObject>
2018-12-27 23:11:32 +01:00
2018-12-30 22:07:53 +01:00
// bonjour
2018-12-27 23:11:32 +01:00
#include <bonjour/bonjourserviceregister.h>
2018-12-30 22:07:53 +01:00
// netUtil
#include <utils/NetUtils.h>
2018-12-27 23:11:32 +01:00
2018-12-30 22:07:53 +01:00
2018-12-27 23:11:32 +01:00
WebServer::WebServer(const QJsonDocument& config, QObject * parent)
: QObject(parent)
2018-12-30 22:07:53 +01:00
, _config(config)
2018-12-27 23:11:32 +01:00
, _log(Logger::getInstance("WEBSERVER"))
2018-12-30 22:07:53 +01:00
, _server()
{
2018-12-30 22:07:53 +01:00
}
WebServer::~WebServer()
{
stop();
}
void WebServer::initServer()
2018-12-27 23:11:32 +01:00
{
2018-12-30 22:07:53 +01:00
_server = new QtHttpServer (this);
2018-12-27 23:11:32 +01:00
_server->setServerName (QStringLiteral ("Hyperion Webserver"));
connect (_server, &QtHttpServer::started, this, &WebServer::onServerStarted);
connect (_server, &QtHttpServer::stopped, this, &WebServer::onServerStopped);
connect (_server, &QtHttpServer::error, this, &WebServer::onServerError);
// create StaticFileServing
_staticFileServing = new StaticFileServing (this);
2018-12-27 23:11:32 +01:00
connect(_server, &QtHttpServer::requestNeedsReply, _staticFileServing, &StaticFileServing::onRequestNeedsReply);
// init
2018-12-30 22:07:53 +01:00
handleSettingsUpdate(settings::WEBSERVER, _config);
2018-12-27 23:11:32 +01:00
}
void WebServer::onServerStarted (quint16 port)
{
2018-12-30 22:07:53 +01:00
_inited= true;
2018-12-27 23:11:32 +01:00
Info(_log, "Started on port %d name '%s'", port ,_server->getServerName().toStdString().c_str());
if(_serviceRegister == nullptr)
{
_serviceRegister = new BonjourServiceRegister(this);
_serviceRegister->registerService("_hyperiond-http._tcp", port);
}
else if( _serviceRegister->getPort() != port)
{
delete _serviceRegister;
_serviceRegister = new BonjourServiceRegister(this);
_serviceRegister->registerService("_hyperiond-http._tcp", port);
}
2018-12-30 22:07:53 +01:00
emit stateChange(true);
2018-12-27 23:11:32 +01:00
}
void WebServer::onServerStopped ()
{
2018-12-27 23:11:32 +01:00
Info(_log, "Stopped %s", _server->getServerName().toStdString().c_str());
2018-12-30 22:07:53 +01:00
emit stateChange(false);
2018-12-27 23:11:32 +01:00
}
void WebServer::onServerError (QString msg)
{
Error(_log, "%s", msg.toStdString().c_str());
}
void WebServer::handleSettingsUpdate(const settings::type& type, const QJsonDocument& config)
{
if(type == settings::WEBSERVER)
{
const QJsonObject& obj = config.object();
_baseUrl = obj["document_root"].toString(WEBSERVER_DEFAULT_PATH);
2018-12-30 22:07:53 +01:00
2018-12-27 23:11:32 +01:00
if ( (_baseUrl != ":/webconfig") && !_baseUrl.trimmed().isEmpty())
{
QFileInfo info(_baseUrl);
if (!info.exists() || !info.isDir())
{
Error(_log, "document_root '%s' is invalid", _baseUrl.toUtf8().constData());
_baseUrl = WEBSERVER_DEFAULT_PATH;
}
}
else
_baseUrl = WEBSERVER_DEFAULT_PATH;
Debug(_log, "Set document root to: %s", _baseUrl.toUtf8().constData());
_staticFileServing->setBaseUrl(_baseUrl);
if(_port != obj["port"].toInt(WEBSERVER_DEFAULT_PORT))
{
_port = obj["port"].toInt(WEBSERVER_DEFAULT_PORT);
stop();
}
// eval if the port is available, will be incremented if not
2018-12-30 22:07:53 +01:00
if(!_server->isListening())
NetUtils::portAvailable(_port, _log);
start();
2018-12-30 22:07:53 +01:00
emit portChanged(_port);
2018-12-27 23:11:32 +01:00
}
}
void WebServer::start()
{
_server->start(_port);
}
void WebServer::stop()
{
_server->stop();
}
2018-12-30 22:07:53 +01:00
void WebServer::setSSDPDescription(const QString & desc)
{
_staticFileServing->setSSDPDescription(desc);
}