minetest.git - modified minetest for gpcfs purposes

about summary refs log tree commit diff

path: root/src/connection.cpp

	Commit message (Collapse)	Author	Age
*	Make Connection::Receive return the data via a SharedBuffer reference, so ↵	Kahrl	2011-11-07
\| \| \| \| \| \| \| \|	the caller doesn't have to choose the right buffer size in advance. Conflicts: src/test.cpp
*	Attempt a workaround to the network layer segfault	Perttu Ahola	2011-10-30
\|
*	Make it to compile on MSVC2010	Perttu Ahola	2011-10-21
\|
*	Some tuning in m_max_packets_per_second algorithm	Perttu Ahola	2011-10-21
\|
*	Improve Connection with threading and some kind of congestion control	Perttu Ahola	2011-10-20
\|
*	Better handling of SendFailedException in Connection	Perttu Ahola	2011-10-18
\|
*	Catch SendFailedException when replying back in Connection::Receive()	Perttu Ahola	2011-10-17
\|
*	Make Connection::Send cancel silently if peer doesn't exist.	Perttu Ahola	2011-09-06
\|
*	Cleaned networking code a bit (had this one on the to-do list for like 4 ↵	Perttu Ahola	2011-05-21
\| \| \| \|	months already)
*	OMG! Main Menu!	Perttu Ahola	2011-01-23
\|
*	Players are left on server while server is running. No passwords yet.	Perttu Ahola	2011-01-15
\|
*	tinkering around	Perttu Ahola	2010-12-25
\|
*	disconnect method to connection to be used instead of just timing out	Perttu Ahola	2010-12-24
\|
*	day/night working client side	Perttu Ahola	2010-12-19
\|
*	license stuff	Perttu Ahola	2010-11-29
\| \| \| \| \|	--HG-- rename : src/licensecomment.txt => licensecomment.txt
*	Initial files	Perttu Ahola	2010-11-27

include "settings.h" #include "debug.h" #include "log.h" #include <algorithm> #include <iomanip> #include <cctype> #define HTTP_API(name) \ lua_pushstring(L, #name); \ lua_pushcfunction(L, l_http_##name); \ lua_settable(L, -3); #if USE_CURL void ModApiHttp::read_http_fetch_request(lua_State *L, HTTPFetchRequest &req) { luaL_checktype(L, 1, LUA_TTABLE); req.caller = httpfetch_caller_alloc_secure(); getstringfield(L, 1, "url", req.url); lua_getfield(L, 1, "user_agent"); if (lua_isstring(L, -1)) req.useragent = getstringfield_default(L, 1, "user_agent", ""); lua_pop(L, 1); req.multipart = getboolfield_default(L, 1, "multipart", false); req.timeout = getintfield_default(L, 1, "timeout", 3) * 1000; // post_data: if table, post form data, otherwise raw data lua_getfield(L, 1, "post_data"); if (lua_istable(L, 2)) { lua_pushnil(L); while (lua_next(L, 2) != 0) { req.post_fields[luaL_checkstring(L, -2)] = luaL_checkstring(L, -1); lua_pop(L, 1); } } else if (lua_isstring(L, 2)) { req.post_data = readParam<std::string>(L, 2); } lua_pop(L, 1); lua_getfield(L, 1, "extra_headers"); if (lua_istable(L, 2)) { lua_pushnil(L); while (lua_next(L, 2) != 0) { const char *header = luaL_checkstring(L, -1); req.extra_headers.emplace_back(header); lua_pop(L, 1); } } lua_pop(L, 1); } void ModApiHttp::push_http_fetch_result(lua_State *L, HTTPFetchResult &res, bool completed) { lua_newtable(L); setboolfield(L, -1, "succeeded", res.succeeded); setboolfield(L, -1, "timeout", res.timeout); setboolfield(L, -1, "completed", completed); setintfield(L, -1, "code", res.response_code); setstringfield(L, -1, "data", res.data.c_str()); } // http_api.fetch_async(HTTPRequest definition) int ModApiHttp::l_http_fetch_async(lua_State *L) { NO_MAP_LOCK_REQUIRED; HTTPFetchRequest req; read_http_fetch_request(L, req); actionstream << "Mod performs HTTP request with URL " << req.url << std::endl; httpfetch_async(req); // Convert handle to hex string since lua can't handle 64-bit integers std::stringstream handle_conversion_stream; handle_conversion_stream << std::hex << req.caller; std::string caller_handle(handle_conversion_stream.str()); lua_pushstring(L, caller_handle.c_str()); return 1; } // http_api.fetch_async_get(handle) int ModApiHttp::l_http_fetch_async_get(lua_State *L) { NO_MAP_LOCK_REQUIRED; std::string handle_str = luaL_checkstring(L, 1); // Convert hex string back to 64-bit handle u64 handle; std::stringstream handle_conversion_stream; handle_conversion_stream << std::hex << handle_str; handle_conversion_stream >> handle; HTTPFetchResult res; bool completed = httpfetch_async_get(handle, res); push_http_fetch_result(L, res, completed); return 1; } int ModApiHttp::l_request_http_api(lua_State *L) { NO_MAP_LOCK_REQUIRED; // We have to make sure that this function is being called directly by // a mod, otherwise a malicious mod could override this function and // steal its return value. lua_Debug info; // Make sure there's only one item below this function on the stack... if (lua_getstack(L, 2, &info)) { return 0; } FATAL_ERROR_IF(!lua_getstack(L, 1, &info), "lua_getstack() failed"); FATAL_ERROR_IF(!lua_getinfo(L, "S", &info), "lua_getinfo() failed"); // ...and that that item is the main file scope. if (strcmp(info.what, "main") != 0) { return 0; } // Mod must be listed in secure.http_mods or secure.trusted_mods lua_rawgeti(L, LUA_REGISTRYINDEX, CUSTOM_RIDX_CURRENT_MOD_NAME); if (!lua_isstring(L, -1)) { return 0; } std::string mod_name = readParam<std::string>(L, -1); std::string http_mods = g_settings->get("secure.http_mods"); http_mods.erase(std::remove(http_mods.begin(), http_mods.end(), ' '), http_mods.end()); std::vector<std::string> mod_list_http = str_split(http_mods, ','); std::string trusted_mods = g_settings->get("secure.trusted_mods"); trusted_mods.erase(std::remove(trusted_mods.begin(), trusted_mods.end(), ' '), trusted_mods.end()); std::vector<std::string> mod_list_trusted = str_split(trusted_mods, ','); mod_list_http.insert(mod_list_http.end(), mod_list_trusted.begin(), mod_list_trusted.end()); if (std::find(mod_list_http.begin(), mod_list_http.end(), mod_name) == mod_list_http.end()) { lua_pushnil(L); return 1; } lua_getglobal(L, "core"); lua_getfield(L, -1, "http_add_fetch"); lua_newtable(L); HTTP_API(fetch_async); HTTP_API(fetch_async_get); // Stack now looks like this: // <core.http_add_fetch> <table with fetch_async, fetch_async_get> // Now call core.http_add_fetch to append .fetch(request, callback) to table lua_call(L, 1, 1); return 1; } #endif void ModApiHttp::Initialize(lua_State *L, int top) { #if USE_CURL API_FCT(request_http_api); #endif }