mirror of
https://github.com/Relintai/pandemonium_engine.git
synced 2024-12-18 18:06:56 +01:00
170 lines
3.8 KiB
C++
170 lines
3.8 KiB
C++
#include "web_server.h"
|
|
|
|
#include "core/class_db.h"
|
|
#include "web_node.h"
|
|
#include "web_server_request.h"
|
|
|
|
#include "http_session_manager.h"
|
|
|
|
bool WebServer::get_is_running() {
|
|
return _is_running;
|
|
}
|
|
|
|
WebNode *WebServer::get_web_root() {
|
|
return _web_root;
|
|
}
|
|
|
|
Node *WebServer::get_web_root_bind() {
|
|
return _web_root;
|
|
}
|
|
|
|
HTTPSessionManager *WebServer::get_session_manager() {
|
|
return _session_manager;
|
|
}
|
|
|
|
Node *WebServer::get_session_manager_bind() {
|
|
return _session_manager;
|
|
}
|
|
|
|
void WebServer::server_handle_request(Ref<WebServerRequest> request) {
|
|
ERR_FAIL_COND(!_web_root);
|
|
|
|
request->server = this;
|
|
request->web_root = _web_root;
|
|
|
|
_rw_lock.read_lock();
|
|
_web_root->handle_request_main(request);
|
|
_rw_lock.read_unlock();
|
|
}
|
|
|
|
void WebServer::request_write_lock() {
|
|
_write_lock_requested = true;
|
|
}
|
|
|
|
void WebServer::refresh_root() {
|
|
_web_root = nullptr;
|
|
_session_manager = nullptr;
|
|
|
|
for (int i = 0; i < get_child_count(); ++i) {
|
|
if (!_web_root) {
|
|
_web_root = Object::cast_to<WebNode>(get_child(i));
|
|
}
|
|
|
|
if (!_session_manager) {
|
|
_session_manager = Object::cast_to<HTTPSessionManager>(get_child(i));
|
|
}
|
|
}
|
|
}
|
|
|
|
void WebServer::start() {
|
|
call("_start");
|
|
}
|
|
void WebServer::stop() {
|
|
call("_stop");
|
|
}
|
|
|
|
void WebServer::_start() {
|
|
if (_is_running) {
|
|
return;
|
|
}
|
|
|
|
_is_running = true;
|
|
|
|
refresh_root();
|
|
}
|
|
void WebServer::_stop() {
|
|
if (!_is_running) {
|
|
return;
|
|
}
|
|
|
|
_is_running = false;
|
|
}
|
|
|
|
String WebServer::get_configuration_warning() const {
|
|
int webnode_count = 0;
|
|
int session_manager_count = 0;
|
|
|
|
for (int i = 0; i < get_child_count(); ++i) {
|
|
if (!_web_root) {
|
|
WebNode *wn = Object::cast_to<WebNode>(get_child(i));
|
|
|
|
if (wn) {
|
|
++webnode_count;
|
|
}
|
|
}
|
|
|
|
if (!_session_manager) {
|
|
HTTPSessionManager *sm = Object::cast_to<HTTPSessionManager>(get_child(i));
|
|
|
|
if (sm) {
|
|
++session_manager_count;
|
|
}
|
|
}
|
|
}
|
|
|
|
String err;
|
|
|
|
if (webnode_count == 0) {
|
|
err += "You need one (and only one) WebNode as the child for the webserver to work. (A WebRoot Node is recommended by default.)";
|
|
} else if (webnode_count > 1) {
|
|
err += "You have more than one root WebNode as the child of the server. Please move them under a new common WebNode, else the server will only use the first one!";
|
|
}
|
|
|
|
if (session_manager_count > 1) {
|
|
if (err != "") {
|
|
err += "\n";
|
|
}
|
|
|
|
err += "You have more than one HTTPSessionManager nodes as child, the server will only be able use the first one. Please remove the other.";
|
|
}
|
|
|
|
return err;
|
|
}
|
|
|
|
WebServer::WebServer() {
|
|
_is_running = false;
|
|
|
|
_web_root = nullptr;
|
|
_session_manager = nullptr;
|
|
|
|
_write_lock_requested = false;
|
|
|
|
set_process_internal(true);
|
|
}
|
|
|
|
WebServer::~WebServer() {
|
|
}
|
|
|
|
void WebServer::_notification(int p_what) {
|
|
if (p_what == NOTIFICATION_INTERNAL_PROCESS) {
|
|
if (_write_lock_requested) {
|
|
_rw_lock.write_lock();
|
|
notification(NOTIFICATION_WEB_SERVER_WRITE_LOCK_ACQUIRED);
|
|
//the root could have changed.
|
|
refresh_root();
|
|
_rw_lock.write_unlock();
|
|
|
|
_write_lock_requested = false;
|
|
}
|
|
}
|
|
}
|
|
|
|
void WebServer::_bind_methods() {
|
|
ClassDB::bind_method(D_METHOD("get_web_root"), &WebServer::get_web_root_bind);
|
|
ClassDB::bind_method(D_METHOD("get_session_manager"), &WebServer::get_session_manager_bind);
|
|
|
|
ClassDB::bind_method(D_METHOD("server_handle_request", "request"), &WebServer::server_handle_request);
|
|
ClassDB::bind_method(D_METHOD("request_write_lock"), &WebServer::request_write_lock);
|
|
|
|
BIND_VMETHOD(MethodInfo("_start"));
|
|
BIND_VMETHOD(MethodInfo("_stop"));
|
|
ClassDB::bind_method(D_METHOD("start"), &WebServer::start);
|
|
ClassDB::bind_method(D_METHOD("stop"), &WebServer::stop);
|
|
ClassDB::bind_method(D_METHOD("_start"), &WebServer::_start);
|
|
ClassDB::bind_method(D_METHOD("_stop"), &WebServer::_stop);
|
|
|
|
BIND_CONSTANT(NOTIFICATION_WEB_SERVER_STARTED);
|
|
BIND_CONSTANT(NOTIFICATION_WEB_SERVER_STOPPED);
|
|
BIND_CONSTANT(NOTIFICATION_WEB_SERVER_WRITE_LOCK_ACQUIRED);
|
|
}
|