Relintai/pandemonium_engine
1
0
Fork 0
mirror of https://github.com/Relintai/pandemonium_engine.git synced 2024-11-24 01:47:20 +01:00
Code Issues Packages Projects Releases Wiki Activity
7aa6798ab7
pandemonium_engine/modules/web/http/web_node.cpp

492 lines
14 KiB
C++
Raw Normal View History

Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
#include "web_node.h"
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
#include "core/error_macros.h"
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
#include "core/object.h"
#include "http_server_enums.h"
#include "web_server_request.h"
#if WEB_SETTINGS_ENABLED
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
#include "core/settings/settings.h"
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
#endif
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
#include "web_permission.h"
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
#include "web_server.h"
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
#ifdef DATABASES_ENABLED
#include "database/database.h"
#include "database/database_manager.h"
#include "database/query_builder.h"
#include "database/query_result.h"
#include "database/table_builder.h"
#endif
Cleaned up WebServer.
2022-06-26 21:34:29 +02:00
/*
void WebNode::update() {
}
*/
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
String WebNode::get_uri_segment() {
return _uri_segment;
}
void WebNode::set_uri_segment(const String &val) {
_uri_segment = val;
}
String WebNode::get_full_uri(const bool slash_at_the_end) {
if (slash_at_the_end) {
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
return get_full_uri_parent(true) + _uri_segment + "/";
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
} else {
return get_full_uri_parent(true) + _uri_segment;
}
}
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
String WebNode::get_full_uri_parent(const bool slash_at_the_end) {
String uri = "/";
WebNode *n = get_parent_webnode();
while (n) {
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
if (n->_uri_segment == "" || n->_uri_segment == "/") {
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
break;
}
uri = "/" + n->_uri_segment + uri;
n = n->get_parent_webnode();
}
if (!slash_at_the_end) {
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
uri.resize(uri.length() - 1);
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
}
return uri;
}
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
#if WEB_SETTINGS_ENABLED
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
Settings *WebNode::get_settings() {
if (_settings) {
return _settings;
}
return Settings::get_singleton();
}
void WebNode::set_settings(Settings *settings) {
_settings = settings;
// todo send event to children when it's implemented?
}
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
#endif
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
Ref<WebPermission> WebNode::get_web_permission() {
return _web_permission;
}
void WebNode::set_web_permission(const Ref<WebPermission> &wp) {
_web_permission = wp;
}
bool WebNode::get_routing_enabled() {
return _routing_enabled;
}
void WebNode::set_routing_enabled(const bool value) {
if (_routing_enabled == value) {
return;
}
_routing_enabled = value;
if (!_routing_enabled) {
clear_handlers();
} else {
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
if (is_inside_tree()) {
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
build_handler_map();
}
}
}
#ifdef DATABASES_ENABLED
Database *WebNode::get_database() {
if (_database) {
return _database;
}
return DatabaseManager::get_singleton()->ddb;
}
Ref<TableBuilder> WebNode::get_table_builder() {
Database *db = get_database();
ERR_FAIL_COND_V(!db, Ref<TableBuilder>());
return db->get_table_builder();
}
Ref<QueryBuilder> WebNode::get_query_builder() {
Database *db = get_database();
ERR_FAIL_COND_V(!db, Ref<QueryBuilder>());
return db->get_query_builder();
}
void WebNode::set_database(Database *db) {
_database = db;
// todo send event to children when it's implemented?
}
#endif
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
void WebNode::handle_request_main(Ref<WebServerRequest> request) {
_rw_lock.read_lock();
call("_handle_request_main", request);
_rw_lock.read_unlock();
}
void WebNode::_handle_request_main(Ref<WebServerRequest> request) {
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
if (_web_permission.is_valid()) {
if (_web_permission->activate(request)) {
return;
}
}
if (!_routing_enabled) {
_handle_request_main(request);
return;
}
if (!try_route_request_to_children(request)) {
_handle_request_main(request);
}
}
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
void WebNode::handle_request(Ref<WebServerRequest> request) {
call("_handle_request", request);
}
void WebNode::_handle_request(Ref<WebServerRequest> request) {
request->send_error(HTTPServerEnums::HTTP_STATUS_CODE_404_NOT_FOUND);
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
}
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
void WebNode::handle_error_send_request(Ref<WebServerRequest> request, const int error_code) {
call("_handle_error_send_request", request, error_code);
}
void WebNode::_handle_error_send_request(Ref<WebServerRequest> request, const int error_code) {
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
// this is a fallback error handler.
// Webroot implements a proper one
request->compiled_body = "<html><body>Internal server error!</body></html>";
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
request->set_status_code(HTTPServerEnums ::HTTP_STATUS_CODE_503_SERVICE_UNAVAILABLE);
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
request->send();
}
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
void WebNode::render_index(Ref<WebServerRequest> request) {
call("_render_index", request);
}
void WebNode::render_preview(Ref<WebServerRequest> request) {
call("_render_preview", request);
}
void WebNode::render_menu(Ref<WebServerRequest> request) {
call("_render_menu", request);
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
}
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
void WebNode::render_main_menu(Ref<WebServerRequest> request) {
call("_render_main_menu", request);
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
}
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
void WebNode::_render_index(Ref<WebServerRequest> request) {
}
void WebNode::_render_preview(Ref<WebServerRequest> request) {
}
void WebNode::_render_menu(Ref<WebServerRequest> request) {
WebNode *root = get_web_root();
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
if (root) {
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
root->render_main_menu(request);
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
}
}
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
void WebNode::_render_main_menu(Ref<WebServerRequest> request) {
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
}
void WebNode::create_table() {
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
call("_create_table");
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
}
void WebNode::drop_table() {
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
call("_drop_table");
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
}
void WebNode::udpate_table() {
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
call("_udpate_table");
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
}
void WebNode::create_default_entries() {
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
call("_create_default_entries");
}
void WebNode::_create_table() {
}
void WebNode::_drop_table() {
}
void WebNode::_udpate_table() {
}
void WebNode::_create_default_entries() {
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
}
void WebNode::migrate(const bool clear, const bool seed_db) {
_migrate(clear, seed_db);
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
for (int i = 0; i < get_child_count(); ++i) {
WebNode *c = Object::cast_to<WebNode>(get_child(i));
if (!c) {
continue;
}
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
c->migrate(clear, seed_db);
}
}
void WebNode::_migrate(const bool clear, const bool seed_db) {
if (clear) {
drop_table();
create_table();
} else {
udpate_table();
}
if (seed_db) {
create_default_entries();
}
}
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
bool WebNode::try_route_request_to_children(Ref<WebServerRequest> request) {
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
WebNode *handler = nullptr;
// if (path == "/") {
if (request->get_path_segment_count() == 0) {
// quick shortcut
handler = _index_node;
} else {
const String &main_route = request->get_current_path_segment();
handler = _node_route_map[main_route];
}
if (!handler) {
return false;
}
request->push_path();
handler->handle_request_main(request);
return true;
}
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
WebNode *WebNode::get_request_handler_child(Ref<WebServerRequest> request) {
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
WebNode *handler = nullptr;
// if (path == "/") {
if (request->get_path_segment_count() == 0) {
// quick shortcut
handler = _index_node;
} else {
const String &main_route = request->get_current_path_segment();
handler = _node_route_map[main_route];
}
return handler;
}
void WebNode::build_handler_map() {
_index_node = nullptr;
_node_route_map.clear();
for (int i = 0; i < get_child_count(); ++i) {
WebNode *c = Object::cast_to<WebNode>(get_child(i));
if (!c) {
continue;
}
String uri_segment = c->get_uri_segment();
if (uri_segment == "") {
// ignore
continue;
} else if (uri_segment == "/") {
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
ERR_CONTINUE_MSG(_index_node, "You have multiple root nodes!");
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
_index_node = c;
} else {
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
ERR_CONTINUE_MSG(_node_route_map[uri_segment], "You have multiple of the same uri! URI:" + uri_segment);
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
_node_route_map[uri_segment] = c;
}
}
}
void WebNode::clear_handlers() {
_index_node = nullptr;
_node_route_map.clear();
}
WebServer *WebNode::get_server() {
// todo this shoult probably be cached
return Object::cast_to<WebServer>(get_tree());
}
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
WebNode *WebNode::get_web_root() {
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
WebServer *s = get_server();
if (!s) {
return nullptr;
}
return s->get_web_root();
}
WebNode *WebNode::get_parent_webnode() {
return Object::cast_to<WebNode>(get_parent());
}
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
void WebNode::add_child_notify(Node *p_child) {
if (_routing_enabled && is_inside_tree()) {
build_handler_map();
}
}
void WebNode::remove_child_notify(Node *p_child) {
if (_routing_enabled && is_inside_tree()) {
build_handler_map();
}
}
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
void WebNode::_notification(const int what) {
switch (what) {
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
case NOTIFICATION_ENTER_TREE: {
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
if (_routing_enabled) {
build_handler_map();
}
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
} break;
case NOTIFICATION_INTERNAL_PROCESS: {
if (_write_lock_requested) {
_rw_lock.write_lock();
notification(NOTIFICATION_WEB_TREE_WRITE_LOCKED);
_rw_lock.write_unlock();
_write_lock_requested = false;
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
}
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
} break;
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
default:
break;
}
}
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
WebNode::WebNode() {
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
// should look this up in parents when parented (and node parenting is implemented)
// should have an event later when a parent gets one
#ifdef DATABASES_ENABLED
_database = nullptr;
#endif
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
#if WEB_SETTINGS_ENABLED
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
// same for this
_settings = nullptr;
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
#endif
Added the web module from rcpp_framework, and a test attempt at binding HTMLBuilder. The module is not in the build yet.
2022-06-25 01:55:54 +02:00
_routing_enabled = true;
_index_node = nullptr;
}
WebNode::~WebNode() {
Cleaned up WebServer.
2022-06-26 21:34:29 +02:00
}
Cleaned up WebNode.
2022-06-27 01:03:01 +02:00
void WebNode::_bind_methods() {
ClassDB::bind_method(D_METHOD("get_uri_segment"), &WebNode::get_uri_segment);
ClassDB::bind_method(D_METHOD("set_uri_segment", "val"), &WebNode::set_uri_segment);
ADD_PROPERTY(PropertyInfo(Variant::STRING, "uri_segment"), "set_uri_segment", "get_uri_segment");
ClassDB::bind_method(D_METHOD("get_uri_segment"), &WebNode::get_uri_segment);
ClassDB::bind_method(D_METHOD("get_uri_segment"), &WebNode::get_uri_segment);
String get_full_uri(const bool slash_at_the_end = true);
String get_full_uri_parent(const bool slash_at_the_end = true);
//#if WEB_SETTINGS_ENABLED
// Settings *get_settings();
// void set_settings(Settings * settings);
//#endif
ClassDB::bind_method(D_METHOD("get_web_permission"), &WebNode::get_web_permission);
ClassDB::bind_method(D_METHOD("set_web_permission", "val"), &WebNode::set_web_permission);
ADD_PROPERTY(PropertyInfo(Variant::OBJECT, "web_permission", PROPERTY_HINT_RESOURCE_TYPE, "WebPermission"), "set_web_permission", "get_web_permission");
ClassDB::bind_method(D_METHOD("get_routing_enabled"), &WebNode::get_routing_enabled);
ClassDB::bind_method(D_METHOD("set_routing_enabled", "val"), &WebNode::set_routing_enabled);
ADD_PROPERTY(PropertyInfo(Variant::BOOL, "routing_enabled"), "set_routing_enabled", "get_routing_enabled");
//#ifdef DATABASES_ENABLED
// Database *get_database();
// Ref<TableBuilder> get_table_builder();
// Ref<QueryBuilder> get_query_builder();
// void set_database(Database * db);
//#endif
BIND_VMETHOD(MethodInfo("_handle_request_main", PropertyInfo(Variant::OBJECT, "request", PROPERTY_HINT_RESOURCE_TYPE, "WebServerRequest")));
ClassDB::bind_method(D_METHOD("handle_request_main", "request"), &WebNode::handle_request_main);
ClassDB::bind_method(D_METHOD("_handle_request_main", "request"), &WebNode::_handle_request_main);
BIND_VMETHOD(MethodInfo("_handle_request", PropertyInfo(Variant::OBJECT, "request", PROPERTY_HINT_RESOURCE_TYPE, "WebServerRequest")));
ClassDB::bind_method(D_METHOD("handle_request", "request"), &WebNode::handle_request);
ClassDB::bind_method(D_METHOD("_handle_request", "request"), &WebNode::_handle_request);
BIND_VMETHOD(MethodInfo("_handle_error_send_request", PropertyInfo(Variant::OBJECT, "request", PROPERTY_HINT_RESOURCE_TYPE, "WebServerRequest"), PropertyInfo(Variant::INT, "error_code")));
ClassDB::bind_method(D_METHOD("handle_error_send_request", "request", "error_code"), &WebNode::handle_error_send_request);
ClassDB::bind_method(D_METHOD("_handle_error_send_request", "request", "error_code"), &WebNode::_handle_error_send_request);
BIND_VMETHOD(MethodInfo("_render_index", PropertyInfo(Variant::OBJECT, "request", PROPERTY_HINT_RESOURCE_TYPE, "WebServerRequest")));
BIND_VMETHOD(MethodInfo("_render_preview", PropertyInfo(Variant::OBJECT, "request", PROPERTY_HINT_RESOURCE_TYPE, "WebServerRequest")));
BIND_VMETHOD(MethodInfo("_render_menu", PropertyInfo(Variant::OBJECT, "request", PROPERTY_HINT_RESOURCE_TYPE, "WebServerRequest")));
BIND_VMETHOD(MethodInfo("_render_main_menu", PropertyInfo(Variant::OBJECT, "request", PROPERTY_HINT_RESOURCE_TYPE, "WebServerRequest")));
ClassDB::bind_method(D_METHOD("render_index", "request"), &WebNode::render_index);
ClassDB::bind_method(D_METHOD("render_preview", "request"), &WebNode::render_preview);
ClassDB::bind_method(D_METHOD("render_menu", "request"), &WebNode::render_menu);
ClassDB::bind_method(D_METHOD("render_main_menu", "request"), &WebNode::render_main_menu);
ClassDB::bind_method(D_METHOD("_render_index", "request"), &WebNode::_render_index);
ClassDB::bind_method(D_METHOD("_render_preview", "request"), &WebNode::_render_preview);
ClassDB::bind_method(D_METHOD("_render_menu", "request"), &WebNode::_render_menu);
ClassDB::bind_method(D_METHOD("_render_main_menu", "request"), &WebNode::_render_main_menu);
BIND_VMETHOD(MethodInfo("_create_table"));
BIND_VMETHOD(MethodInfo("_drop_table"));
BIND_VMETHOD(MethodInfo("_udpate_table"));
BIND_VMETHOD(MethodInfo("_create_default_entries"));
ClassDB::bind_method(D_METHOD("create_table"), &WebNode::create_table);
ClassDB::bind_method(D_METHOD("drop_table"), &WebNode::drop_table);
ClassDB::bind_method(D_METHOD("udpate_table"), &WebNode::udpate_table);
ClassDB::bind_method(D_METHOD("create_default_entries"), &WebNode::create_default_entries);
ClassDB::bind_method(D_METHOD("_create_table"), &WebNode::_create_table);
ClassDB::bind_method(D_METHOD("_drop_table"), &WebNode::_drop_table);
ClassDB::bind_method(D_METHOD("_udpate_table"), &WebNode::_udpate_table);
ClassDB::bind_method(D_METHOD("_create_default_entries"), &WebNode::_create_default_entries);
BIND_VMETHOD(MethodInfo("_migrate", PropertyInfo(Variant::BOOL, "clear"), PropertyInfo(Variant::BOOL, "pseed")));
ClassDB::bind_method(D_METHOD("migrate", "clear", "pseed"), &WebNode::migrate);
ClassDB::bind_method(D_METHOD("_migrate", "clear", "pseed"), &WebNode::_migrate);
ClassDB::bind_method(D_METHOD("try_route_request_to_children", "request"), &WebNode::try_route_request_to_children);
ClassDB::bind_method(D_METHOD("get_request_handler_child", "request"), &WebNode::get_request_handler_child);
ClassDB::bind_method(D_METHOD("build_handler_map"), &WebNode::build_handler_map);
ClassDB::bind_method(D_METHOD("clear_handlers"), &WebNode::clear_handlers);
ClassDB::bind_method(D_METHOD("request_write_lock"), &WebNode::request_write_lock);
ClassDB::bind_method(D_METHOD("get_server"), &WebNode::get_server);
ClassDB::bind_method(D_METHOD("get_web_root"), &WebNode::get_web_root);
ClassDB::bind_method(D_METHOD("get_parent_webnode"), &WebNode::get_parent_webnode);
BIND_CONSTANT(NOTIFICATION_WEB_TREE_WRITE_LOCKED);
}
Reference in New Issue Copy Permalink