X-Git-Url: https://git.lizzy.rs/?a=blobdiff_plain;f=src%2Fmain.cpp;h=af6d307dcccde61f27b2e5652df12d285b4e09d5;hb=be8d1d2d99ad835b5de7277b7b518c334113e795;hp=8a9d14d0aff6296953223bc3a481dbe5c37594f6;hpb=37b7f094e3ea502339794f64e8bad22444c6fb54;p=dragonfireclient.git diff --git a/src/main.cpp b/src/main.cpp index 8a9d14d0a..af6d307dc 100644 --- a/src/main.cpp +++ b/src/main.cpp @@ -17,957 +17,515 @@ with this program; if not, write to the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. */ -#ifdef NDEBUG - /*#ifdef _WIN32 - #pragma message ("Disabling unit tests") - #else - #warning "Disabling unit tests" - #endif*/ - // Disable unit tests - #define ENABLE_TESTS 0 -#else - // Enable unit tests - #define ENABLE_TESTS 1 -#endif - -#ifdef _MSC_VER -#ifndef SERVER // Dedicated server isn't linked with Irrlicht - #pragma comment(lib, "Irrlicht.lib") - // This would get rid of the console window - //#pragma comment(linker, "/subsystem:windows /ENTRY:mainCRTStartup") -#endif - #pragma comment(lib, "zlibwapi.lib") - #pragma comment(lib, "Shell32.lib") -#endif - +#include "irrlichttypes.h" // must be included before anything irrlicht, see comment in the file #include "irrlicht.h" // createDevice - -#include "main.h" -#include "mainmenumanager.h" -#include -#include -#include #include "irrlichttypes_extrabloated.h" +#include "chat_interface.h" #include "debug.h" -#include "test.h" -#include "clouds.h" +#include "unittest/test.h" #include "server.h" -#include "constants.h" -#include "porting.h" -#include "gettime.h" #include "filesys.h" -#include "config.h" #include "version.h" -#include "guiMainMenu.h" -#include "game.h" -#include "keycode.h" -#include "tile.h" -#include "chat.h" +#include "client/game.h" #include "defaultsettings.h" #include "gettext.h" -#include "settings.h" -#include "profiler.h" #include "log.h" -#include "mods.h" -#if USE_FREETYPE -#include "xCGUITTFont.h" -#endif -#include "util/string.h" -#include "subgame.h" -#include "quicktune.h" -#include "serverlist.h" +#include "util/quicktune.h" #include "httpfetch.h" -#include "guiEngine.h" -#include "mapsector.h" - -#include "database-sqlite3.h" -#ifdef USE_LEVELDB -#include "database-leveldb.h" +#include "gameparams.h" +#include "database/database.h" +#include "config.h" +#include "player.h" +#include "porting.h" +#include "network/socket.h" +#if USE_CURSES + #include "terminal_chat_console.h" #endif - -#if USE_REDIS -#include "database-redis.h" +#ifndef SERVER +#include "gui/guiMainMenu.h" +#include "client/clientlauncher.h" +#include "gui/guiEngine.h" +#include "gui/mainmenumanager.h" #endif #ifdef HAVE_TOUCHSCREENGUI -#include "touchscreengui.h" + #include "gui/touchscreengui.h" #endif -/* - Settings. - These are loaded from the config file. -*/ -Settings main_settings; -Settings *g_settings = &main_settings; -std::string g_settings_path; - -// Global profiler -Profiler main_profiler; -Profiler *g_profiler = &main_profiler; - -// Menu clouds are created later -Clouds *g_menuclouds = 0; -irr::scene::ISceneManager *g_menucloudsmgr = 0; - -/* - Debug streams -*/ -// Connection -std::ostream *dout_con_ptr = &dummyout; -std::ostream *derr_con_ptr = &verbosestream; - -// Server -std::ostream *dout_server_ptr = &infostream; -std::ostream *derr_server_ptr = &errorstream; +#if !defined(SERVER) && \ + (IRRLICHT_VERSION_MAJOR == 1) && \ + (IRRLICHT_VERSION_MINOR == 8) && \ + (IRRLICHT_VERSION_REVISION == 2) + #error "Irrlicht 1.8.2 is known to be broken - please update Irrlicht to version >= 1.8.3" +#endif -// Client -std::ostream *dout_client_ptr = &infostream; -std::ostream *derr_client_ptr = &errorstream; +#define DEBUGFILE "debug.txt" +#define DEFAULT_SERVER_PORT 30000 -#ifndef SERVER -/* - Random stuff -*/ +typedef std::map OptionList; -/* mainmenumanager.h */ +/********************************************************************** + * Private functions + **********************************************************************/ -gui::IGUIEnvironment* guienv = NULL; -gui::IGUIStaticText *guiroot = NULL; -MainMenuManager g_menumgr; +static bool get_cmdline_opts(int argc, char *argv[], Settings *cmd_args); +static void set_allowed_options(OptionList *allowed_options); -bool noMenuActive() -{ - return (g_menumgr.menuCount() == 0); -} +static void print_help(const OptionList &allowed_options); +static void print_allowed_options(const OptionList &allowed_options); +static void print_version(); +static void print_worldspecs(const std::vector &worldspecs, + std::ostream &os, bool print_name = true, bool print_path = true); +static void print_modified_quicktune_values(); -// Passed to menus to allow disconnecting and exiting -MainGameCallback *g_gamecallback = NULL; -#endif +static void list_game_ids(); +static void list_worlds(bool print_name, bool print_path); +static bool setup_log_params(const Settings &cmd_args); +static bool create_userdata_path(); +static bool init_common(const Settings &cmd_args, int argc, char *argv[]); +static void startup_message(); +static bool read_config_file(const Settings &cmd_args); +static void init_log_streams(const Settings &cmd_args); -/* - gettime.h implementation -*/ +static bool game_configure(GameParams *game_params, const Settings &cmd_args); +static void game_configure_port(GameParams *game_params, const Settings &cmd_args); -#ifdef SERVER +static bool game_configure_world(GameParams *game_params, const Settings &cmd_args); +static bool get_world_from_cmdline(GameParams *game_params, const Settings &cmd_args); +static bool get_world_from_config(GameParams *game_params, const Settings &cmd_args); +static bool auto_select_world(GameParams *game_params); +static std::string get_clean_world_path(const std::string &path); -u32 getTimeMs() -{ - /* Use imprecise system calls directly (from porting.h) */ - return porting::getTime(PRECISION_MILLI); -} +static bool game_configure_subgame(GameParams *game_params, const Settings &cmd_args); +static bool get_game_from_cmdline(GameParams *game_params, const Settings &cmd_args); +static bool determine_subgame(GameParams *game_params); -u32 getTime(TimePrecision prec) -{ - return porting::getTime(prec); -} +static bool run_dedicated_server(const GameParams &game_params, const Settings &cmd_args); +static bool migrate_map_database(const GameParams &game_params, const Settings &cmd_args); -#else +/**********************************************************************/ -// A small helper class -class TimeGetter -{ -public: - virtual u32 getTime(TimePrecision prec) = 0; -}; -// A precise irrlicht one -class IrrlichtTimeGetter: public TimeGetter -{ -public: - IrrlichtTimeGetter(IrrlichtDevice *device): - m_device(device) - {} - u32 getTime(TimePrecision prec) - { - if (prec == PRECISION_MILLI) { - if (m_device == NULL) - return 0; - return m_device->getTimer()->getRealTime(); - } else { - return porting::getTime(prec); - } - } -private: - IrrlichtDevice *m_device; -}; -// Not so precise one which works without irrlicht -class SimpleTimeGetter: public TimeGetter -{ -public: - u32 getTime(TimePrecision prec) - { - return porting::getTime(prec); - } -}; +FileLogOutput file_log_output; -// A pointer to a global instance of the time getter -// TODO: why? -TimeGetter *g_timegetter = NULL; +static OptionList allowed_options; -u32 getTimeMs() +int main(int argc, char *argv[]) { - if (g_timegetter == NULL) - return 0; - return g_timegetter->getTime(PRECISION_MILLI); -} + int retval; + debug_set_exception_handler(); -u32 getTime(TimePrecision prec) { - if (g_timegetter == NULL) - return 0; - return g_timegetter->getTime(prec); -} -#endif + g_logger.registerThread("Main"); + g_logger.addOutputMaxLevel(&stderr_output, LL_ACTION); -class StderrLogOutput: public ILogOutput -{ -public: - /* line: Full line with timestamp, level and thread */ - void printLog(const std::string &line) - { - std::cerr << line << std::endl; + Settings cmd_args; + bool cmd_args_ok = get_cmdline_opts(argc, argv, &cmd_args); + if (!cmd_args_ok + || cmd_args.getFlag("help") + || cmd_args.exists("nonopt1")) { + porting::attachOrCreateConsole(); + print_help(allowed_options); + return cmd_args_ok ? 0 : 1; } -} main_stderr_log_out; + if (cmd_args.getFlag("console")) + porting::attachOrCreateConsole(); -class DstreamNoStderrLogOutput: public ILogOutput -{ -public: - /* line: Full line with timestamp, level and thread */ - void printLog(const std::string &line) - { - dstream_no_stderr << line << std::endl; + if (cmd_args.getFlag("version")) { + porting::attachOrCreateConsole(); + print_version(); + return 0; } -} main_dstream_no_stderr_log_out; - -#ifndef SERVER -/* - Event handler for Irrlicht + if (!setup_log_params(cmd_args)) + return 1; - NOTE: Everything possible should be moved out from here, - probably to InputHandler and the_game -*/ + porting::signal_handler_init(); -class MyEventReceiver : public IEventReceiver -{ -public: - // This is the one method that we have to implement - virtual bool OnEvent(const SEvent& event) - { - /* - React to nothing here if a menu is active - */ - if (noMenuActive() == false) { -#ifdef HAVE_TOUCHSCREENGUI - if (m_touchscreengui != 0) { - m_touchscreengui->Toggle(false); - } +#ifdef __ANDROID__ + porting::initAndroid(); + porting::initializePathsAndroid(); +#else + porting::initializePaths(); #endif - return g_menumgr.preprocessEvent(event); - } - - // Remember whether each key is down or up - if (event.EventType == irr::EET_KEY_INPUT_EVENT) { - if (event.KeyInput.PressedDown) { - keyIsDown.set(event.KeyInput); - keyWasDown.set(event.KeyInput); - } else { - keyIsDown.unset(event.KeyInput); - } - } -#ifdef HAVE_TOUCHSCREENGUI - // case of touchscreengui we have to handle different events - if ((m_touchscreengui != 0) && - (event.EventType == irr::EET_TOUCH_INPUT_EVENT)) { - m_touchscreengui->translateEvent(event); - return true; - } -#endif - // handle mouse events - if(event.EventType == irr::EET_MOUSE_INPUT_EVENT) { - if (noMenuActive() == false) { - left_active = false; - middle_active = false; - right_active = false; - } else { - left_active = event.MouseInput.isLeftPressed(); - middle_active = event.MouseInput.isMiddlePressed(); - right_active = event.MouseInput.isRightPressed(); - - if (event.MouseInput.Event == EMIE_LMOUSE_PRESSED_DOWN) { - leftclicked = true; - } - if (event.MouseInput.Event == EMIE_RMOUSE_PRESSED_DOWN) { - rightclicked = true; - } - if (event.MouseInput.Event == EMIE_LMOUSE_LEFT_UP) { - leftreleased = true; - } - if (event.MouseInput.Event == EMIE_RMOUSE_LEFT_UP) { - rightreleased = true; - } - if (event.MouseInput.Event == EMIE_MOUSE_WHEEL) { - mouse_wheel += event.MouseInput.Wheel; - } - } - } - if(event.EventType == irr::EET_LOG_TEXT_EVENT) { - dstream<< std::string("Irrlicht log: ") + std::string(event.LogEvent.Text)<getBool("enable_console")) + porting::attachOrCreateConsole(); - left_active = false; - middle_active = false; - right_active = false; - - mouse_wheel = 0; - } - - MyEventReceiver() - { - clearInput(); -#ifdef HAVE_TOUCHSCREENGUI - m_touchscreengui = NULL; +#ifndef __ANDROID__ + // Run unit tests + if (cmd_args.getFlag("run-unittests")) { +#if BUILD_UNITTESTS + return run_tests(); +#else + errorstream << "Unittest support is not enabled in this binary. " + << "If you want to enable it, compile project with BUILD_UNITTESTS=1 flag." + << std::endl; #endif } +#endif - bool leftclicked; - bool rightclicked; - bool leftreleased; - bool rightreleased; - - bool left_active; - bool middle_active; - bool right_active; - - s32 mouse_wheel; - -#ifdef HAVE_TOUCHSCREENGUI - TouchScreenGUI* m_touchscreengui; + GameStartData game_params; +#ifdef SERVER + porting::attachOrCreateConsole(); + game_params.is_dedicated_server = true; +#else + const bool isServer = cmd_args.getFlag("server"); + if (isServer) + porting::attachOrCreateConsole(); + game_params.is_dedicated_server = isServer; #endif -private: - // The current state of keys - KeyList keyIsDown; - // Whether a key has been pressed or not - KeyList keyWasDown; -}; + if (!game_configure(&game_params, cmd_args)) + return 1; -/* - Separated input handler -*/ + sanity_check(!game_params.world_path.empty()); -class RealInputHandler : public InputHandler -{ -public: - RealInputHandler(IrrlichtDevice *device, MyEventReceiver *receiver): - m_device(device), - m_receiver(receiver), - m_mousepos(0,0) - { - } - virtual bool isKeyDown(const KeyPress &keyCode) - { - return m_receiver->IsKeyDown(keyCode); - } - virtual bool wasKeyDown(const KeyPress &keyCode) - { - return m_receiver->WasKeyDown(keyCode); - } - virtual v2s32 getMousePos() - { - if (m_device->getCursorControl()) { - return m_device->getCursorControl()->getPosition(); - } - else { - return m_mousepos; - } - } - virtual void setMousePos(s32 x, s32 y) - { - if (m_device->getCursorControl()) { - m_device->getCursorControl()->setPosition(x, y); - } - else { - m_mousepos = v2s32(x,y); - } - } - - virtual bool getLeftState() - { - return m_receiver->left_active; - } - virtual bool getRightState() - { - return m_receiver->right_active; - } + if (game_params.is_dedicated_server) + return run_dedicated_server(game_params, cmd_args) ? 0 : 1; - virtual bool getLeftClicked() - { - return m_receiver->leftclicked; - } - virtual bool getRightClicked() - { - return m_receiver->rightclicked; - } - virtual void resetLeftClicked() - { - m_receiver->leftclicked = false; - } - virtual void resetRightClicked() - { - m_receiver->rightclicked = false; - } - - virtual bool getLeftReleased() - { - return m_receiver->leftreleased; - } - virtual bool getRightReleased() - { - return m_receiver->rightreleased; - } - virtual void resetLeftReleased() - { - m_receiver->leftreleased = false; - } - virtual void resetRightReleased() - { - m_receiver->rightreleased = false; - } +#ifndef SERVER + ClientLauncher launcher; + retval = launcher.run(game_params, cmd_args) ? 0 : 1; +#else + retval = 0; +#endif - virtual s32 getMouseWheel() - { - return m_receiver->getMouseWheel(); - } + // Update configuration file + if (!g_settings_path.empty()) + g_settings->updateConfigFile(g_settings_path.c_str()); - void clear() - { - m_receiver->clearInput(); - } -private: - IrrlichtDevice *m_device; - MyEventReceiver *m_receiver; - v2s32 m_mousepos; -}; + print_modified_quicktune_values(); -class RandomInputHandler : public InputHandler -{ -public: - RandomInputHandler() - { - leftdown = false; - rightdown = false; - leftclicked = false; - rightclicked = false; - leftreleased = false; - rightreleased = false; - keydown.clear(); - } - virtual bool isKeyDown(const KeyPress &keyCode) - { - return keydown[keyCode]; - } - virtual bool wasKeyDown(const KeyPress &keyCode) - { - return false; - } - virtual v2s32 getMousePos() - { - return mousepos; - } - virtual void setMousePos(s32 x, s32 y) - { - mousepos = v2s32(x, y); - } + // Stop httpfetch thread (if started) + httpfetch_cleanup(); - virtual bool getLeftState() - { - return leftdown; - } - virtual bool getRightState() - { - return rightdown; - } + END_DEBUG_EXCEPTION_HANDLER - virtual bool getLeftClicked() - { - return leftclicked; - } - virtual bool getRightClicked() - { - return rightclicked; - } - virtual void resetLeftClicked() - { - leftclicked = false; - } - virtual void resetRightClicked() - { - rightclicked = false; - } + return retval; +} - virtual bool getLeftReleased() - { - return leftreleased; - } - virtual bool getRightReleased() - { - return rightreleased; - } - virtual void resetLeftReleased() - { - leftreleased = false; - } - virtual void resetRightReleased() - { - rightreleased = false; - } - virtual s32 getMouseWheel() - { - return 0; - } +/***************************************************************************** + * Startup / Init + *****************************************************************************/ - virtual void step(float dtime) - { - { - static float counter1 = 0; - counter1 -= dtime; - if (counter1 < 0.0) { - counter1 = 0.1 * Rand(1, 40); - keydown.toggle(getKeySetting("keymap_jump")); - } - } - { - static float counter1 = 0; - counter1 -= dtime; - if (counter1 < 0.0) { - counter1 = 0.1 * Rand(1, 40); - keydown.toggle(getKeySetting("keymap_special1")); - } - } - { - static float counter1 = 0; - counter1 -= dtime; - if (counter1 < 0.0) { - counter1 = 0.1 * Rand(1, 40); - keydown.toggle(getKeySetting("keymap_forward")); - } - } - { - static float counter1 = 0; - counter1 -= dtime; - if (counter1 < 0.0) { - counter1 = 0.1 * Rand(1, 40); - keydown.toggle(getKeySetting("keymap_left")); - } - } - { - static float counter1 = 0; - counter1 -= dtime; - if (counter1 < 0.0) { - counter1 = 0.1 * Rand(1, 20); - mousespeed = v2s32(Rand(-20, 20), Rand(-15, 20)); - } - } - { - static float counter1 = 0; - counter1 -= dtime; - if (counter1 < 0.0) { - counter1 = 0.1 * Rand(1, 30); - leftdown = !leftdown; - if (leftdown) - leftclicked = true; - if (!leftdown) - leftreleased = true; - } - } - { - static float counter1 = 0; - counter1 -= dtime; - if (counter1 < 0.0) { - counter1 = 0.1 * Rand(1, 15); - rightdown = !rightdown; - if (rightdown) - rightclicked = true; - if (!rightdown) - rightreleased = true; - } - } - mousepos += mousespeed; - } - s32 Rand(s32 min, s32 max) - { - return (myrand()%(max-min+1))+min; - } -private: - KeyList keydown; - v2s32 mousepos; - v2s32 mousespeed; - bool leftdown; - bool rightdown; - bool leftclicked; - bool rightclicked; - bool leftreleased; - bool rightreleased; -}; - -#endif // !SERVER - -// These are defined global so that they're not optimized too much. -// Can't change them to volatile. -s16 temp16; -f32 tempf; -v3f tempv3f1; -v3f tempv3f2; -std::string tempstring; -std::string tempstring2; - -void SpeedTests() +static bool get_cmdline_opts(int argc, char *argv[], Settings *cmd_args) { - { - infostream << "The following test should take around 20ms." << std::endl; - TimeTaker timer("Testing std::string speed"); - const u32 jj = 10000; - for(u32 j = 0; j < jj; j++) { - tempstring = ""; - tempstring2 = ""; - const u32 ii = 10; - for(u32 i = 0; i < ii; i++) { - tempstring2 += "asd"; - } - for(u32 i = 0; i < ii+1; i++) { - tempstring += "asd"; - if (tempstring == tempstring2) - break; - } - } - } - - infostream << "All of the following tests should take around 100ms each." - << std::endl; - - { - TimeTaker timer("Testing floating-point conversion speed"); - tempf = 0.001; - for(u32 i = 0; i < 4000000; i++) { - temp16 += tempf; - tempf += 0.001; - } - } + set_allowed_options(&allowed_options); - { - TimeTaker timer("Testing floating-point vector speed"); - - tempv3f1 = v3f(1, 2, 3); - tempv3f2 = v3f(4, 5, 6); - for(u32 i = 0; i < 10000000; i++) { - tempf += tempv3f1.dotProduct(tempv3f2); - tempv3f2 += v3f(7, 8, 9); - } - } - - { - TimeTaker timer("Testing std::map speed"); - - std::map map1; - tempf = -324; - const s16 ii = 300; - for(s16 y = 0; y < ii; y++) { - for(s16 x = 0; x < ii; x++) { - map1[v2s16(x, y)] = tempf; - tempf += 1; - } - } - for(s16 y = ii - 1; y >= 0; y--) { - for(s16 x = 0; x < ii; x++) { - tempf = map1[v2s16(x, y)]; - } - } - } - - { - infostream << "Around 5000/ms should do well here." << std::endl; - TimeTaker timer("Testing mutex speed"); - - JMutex m; - u32 n = 0; - u32 i = 0; - do { - n += 10000; - for(; i < n; i++) { - m.Lock(); - m.Unlock(); - } - } - // Do at least 10ms - while(timer.getTimerTime() < 10); - - u32 dtime = timer.stop(); - u32 per_ms = n / dtime; - infostream << "Done. " << dtime << "ms, " << per_ms << "/ms" << std::endl; - } -} - -static void print_worldspecs(const std::vector &worldspecs, std::ostream &os) -{ - for(u32 i = 0; i < worldspecs.size(); i++) { - std::string name = worldspecs[i].name; - std::string path = worldspecs[i].path; - if (name.find(" ") != std::string::npos) - name = std::string("'") + name + "'"; - path = std::string("'") + path + "'"; - name = padStringRight(name, 14); - os << " " << name << " " << path << std::endl; - } + return cmd_args->parseCommandLine(argc, argv, allowed_options); } -int main(int argc, char *argv[]) +static void set_allowed_options(OptionList *allowed_options) { - int retval = 0; + allowed_options->clear(); - /* - Initialization - */ - - log_add_output_maxlev(&main_stderr_log_out, LMT_ACTION); - log_add_output_all_levs(&main_dstream_no_stderr_log_out); - - log_register_thread("main"); - /* - Parse command line - */ - - // List all allowed options - std::map allowed_options; - allowed_options.insert(std::make_pair("help", ValueSpec(VALUETYPE_FLAG, + allowed_options->insert(std::make_pair("help", ValueSpec(VALUETYPE_FLAG, _("Show allowed options")))); - allowed_options.insert(std::make_pair("version", ValueSpec(VALUETYPE_FLAG, + allowed_options->insert(std::make_pair("version", ValueSpec(VALUETYPE_FLAG, _("Show version information")))); - allowed_options.insert(std::make_pair("config", ValueSpec(VALUETYPE_STRING, + allowed_options->insert(std::make_pair("config", ValueSpec(VALUETYPE_STRING, _("Load configuration from specified file")))); - allowed_options.insert(std::make_pair("port", ValueSpec(VALUETYPE_STRING, + allowed_options->insert(std::make_pair("port", ValueSpec(VALUETYPE_STRING, _("Set network port (UDP)")))); - allowed_options.insert(std::make_pair("disable-unittests", ValueSpec(VALUETYPE_FLAG, - _("Disable unit tests")))); - allowed_options.insert(std::make_pair("enable-unittests", ValueSpec(VALUETYPE_FLAG, - _("Enable unit tests")))); - allowed_options.insert(std::make_pair("map-dir", ValueSpec(VALUETYPE_STRING, + allowed_options->insert(std::make_pair("run-unittests", ValueSpec(VALUETYPE_FLAG, + _("Run the unit tests and exit")))); + allowed_options->insert(std::make_pair("map-dir", ValueSpec(VALUETYPE_STRING, _("Same as --world (deprecated)")))); - allowed_options.insert(std::make_pair("world", ValueSpec(VALUETYPE_STRING, - _("Set world path (implies local game) ('list' lists all)")))); - allowed_options.insert(std::make_pair("worldname", ValueSpec(VALUETYPE_STRING, - _("Set world by name (implies local game)")))); - allowed_options.insert(std::make_pair("quiet", ValueSpec(VALUETYPE_FLAG, + allowed_options->insert(std::make_pair("world", ValueSpec(VALUETYPE_STRING, + _("Set world path (implies local game if used with option --go)")))); + allowed_options->insert(std::make_pair("worldname", ValueSpec(VALUETYPE_STRING, + _("Set world by name (implies local game if used with option --go)")))); + allowed_options->insert(std::make_pair("worldlist", ValueSpec(VALUETYPE_STRING, + _("Get list of worlds ('path' lists paths, " + "'name' lists names, 'both' lists both)")))); + allowed_options->insert(std::make_pair("quiet", ValueSpec(VALUETYPE_FLAG, _("Print to console errors only")))); - allowed_options.insert(std::make_pair("info", ValueSpec(VALUETYPE_FLAG, + allowed_options->insert(std::make_pair("color", ValueSpec(VALUETYPE_STRING, + _("Coloured logs ('always', 'never' or 'auto'), defaults to 'auto'" + )))); + allowed_options->insert(std::make_pair("info", ValueSpec(VALUETYPE_FLAG, _("Print more information to console")))); - allowed_options.insert(std::make_pair("verbose", ValueSpec(VALUETYPE_FLAG, + allowed_options->insert(std::make_pair("verbose", ValueSpec(VALUETYPE_FLAG, _("Print even more information to console")))); - allowed_options.insert(std::make_pair("trace", ValueSpec(VALUETYPE_FLAG, + allowed_options->insert(std::make_pair("trace", ValueSpec(VALUETYPE_FLAG, _("Print enormous amounts of information to log and console")))); - allowed_options.insert(std::make_pair("logfile", ValueSpec(VALUETYPE_STRING, + allowed_options->insert(std::make_pair("logfile", ValueSpec(VALUETYPE_STRING, _("Set logfile path ('' = no logging)")))); - allowed_options.insert(std::make_pair("gameid", ValueSpec(VALUETYPE_STRING, + allowed_options->insert(std::make_pair("gameid", ValueSpec(VALUETYPE_STRING, _("Set gameid (\"--gameid list\" prints available ones)")))); - allowed_options.insert(std::make_pair("migrate", ValueSpec(VALUETYPE_STRING, + allowed_options->insert(std::make_pair("migrate", ValueSpec(VALUETYPE_STRING, _("Migrate from current map backend to another (Only works when using minetestserver or with --server)")))); + allowed_options->insert(std::make_pair("migrate-players", ValueSpec(VALUETYPE_STRING, + _("Migrate from current players backend to another (Only works when using minetestserver or with --server)")))); + allowed_options->insert(std::make_pair("migrate-auth", ValueSpec(VALUETYPE_STRING, + _("Migrate from current auth backend to another (Only works when using minetestserver or with --server)")))); + allowed_options->insert(std::make_pair("terminal", ValueSpec(VALUETYPE_FLAG, + _("Feature an interactive terminal (Only works when using minetestserver or with --server)")))); #ifndef SERVER - allowed_options.insert(std::make_pair("videomodes", ValueSpec(VALUETYPE_FLAG, + allowed_options->insert(std::make_pair("videomodes", ValueSpec(VALUETYPE_FLAG, _("Show available video modes")))); - allowed_options.insert(std::make_pair("speedtests", ValueSpec(VALUETYPE_FLAG, + allowed_options->insert(std::make_pair("speedtests", ValueSpec(VALUETYPE_FLAG, _("Run speed tests")))); - allowed_options.insert(std::make_pair("address", ValueSpec(VALUETYPE_STRING, + allowed_options->insert(std::make_pair("address", ValueSpec(VALUETYPE_STRING, _("Address to connect to. ('' = local game)")))); - allowed_options.insert(std::make_pair("random-input", ValueSpec(VALUETYPE_FLAG, + allowed_options->insert(std::make_pair("random-input", ValueSpec(VALUETYPE_FLAG, _("Enable random user input, for testing")))); - allowed_options.insert(std::make_pair("server", ValueSpec(VALUETYPE_FLAG, + allowed_options->insert(std::make_pair("server", ValueSpec(VALUETYPE_FLAG, _("Run dedicated server")))); - allowed_options.insert(std::make_pair("name", ValueSpec(VALUETYPE_STRING, + allowed_options->insert(std::make_pair("name", ValueSpec(VALUETYPE_STRING, _("Set player name")))); - allowed_options.insert(std::make_pair("password", ValueSpec(VALUETYPE_STRING, + allowed_options->insert(std::make_pair("password", ValueSpec(VALUETYPE_STRING, _("Set password")))); - allowed_options.insert(std::make_pair("go", ValueSpec(VALUETYPE_FLAG, + allowed_options->insert(std::make_pair("password-file", ValueSpec(VALUETYPE_STRING, + _("Set password from contents of file")))); + allowed_options->insert(std::make_pair("go", ValueSpec(VALUETYPE_FLAG, _("Disable main menu")))); + allowed_options->insert(std::make_pair("console", ValueSpec(VALUETYPE_FLAG, + _("Starts with the console (Windows only)")))); #endif - Settings cmd_args; +} - bool ret = cmd_args.parseCommandLine(argc, argv, allowed_options); - - if (ret == false || cmd_args.getFlag("help") || cmd_args.exists("nonopt1")) { - dstream << _("Allowed options:") << std::endl; - for(std::map::iterator - i = allowed_options.begin(); - i != allowed_options.end(); ++i) { - std::ostringstream os1(std::ios::binary); - os1 << " --"<first; - if (i->second.type == VALUETYPE_FLAG) { - } else - os1 << _(" "); - dstream << padStringRight(os1.str(), 24); - - if (i->second.help != NULL) - dstream << i->second.help; - dstream << std::endl; - } +static void print_help(const OptionList &allowed_options) +{ + std::cout << _("Allowed options:") << std::endl; + print_allowed_options(allowed_options); +} + +static void print_allowed_options(const OptionList &allowed_options) +{ + for (const auto &allowed_option : allowed_options) { + std::ostringstream os1(std::ios::binary); + os1 << " --" << allowed_option.first; + if (allowed_option.second.type != VALUETYPE_FLAG) + os1 << _(" "); + + std::cout << padStringRight(os1.str(), 30); + + if (allowed_option.second.help) + std::cout << allowed_option.second.help; - return cmd_args.getFlag("help") ? 0 : 1; + std::cout << std::endl; } +} - if (cmd_args.getFlag("version")) { -#ifdef SERVER - dstream << "minetestserver " << minetest_version_hash << std::endl; -#else - dstream << "Minetest " << minetest_version_hash << std::endl; - dstream << "Using Irrlicht " << IRRLICHT_SDK_VERSION << std::endl; +static void print_version() +{ + std::cout << PROJECT_NAME_C " " << g_version_hash + << " (" << porting::getPlatformName() << ")" << std::endl; +#ifndef SERVER + std::cout << "Using Irrlicht " IRRLICHT_SDK_VERSION << std::endl; #endif - dstream << "Build info: " << minetest_build_info << std::endl; - return 0; + std::cout << g_build_info << std::endl; +} + +static void list_game_ids() +{ + std::set gameids = getAvailableGameIds(); + for (const std::string &gameid : gameids) + std::cout << gameid < worldspecs = getAvailableWorlds(); + print_worldspecs(worldspecs, std::cout, print_name, print_path); +} + +static void print_worldspecs(const std::vector &worldspecs, + std::ostream &os, bool print_name, bool print_path) +{ + for (const WorldSpec &worldspec : worldspecs) { + std::string name = worldspec.name; + std::string path = worldspec.path; + if (print_name && print_path) { + os << "\t" << name << "\t\t" << path << std::endl; + } else if (print_name) { + os << "\t" << name << std::endl; + } else if (print_path) { + os << "\t" << path << std::endl; + } } +} + +static void print_modified_quicktune_values() +{ + bool header_printed = false; + std::vector names = getQuicktuneNames(); - /* - Low-level initialization - */ + for (const std::string &name : names) { + QuicktuneValue val = getQuicktuneValue(name); + if (!val.modified) + continue; + if (!header_printed) { + dstream << "Modified quicktune values:" << std::endl; + header_printed = true; + } + dstream << name << " = " << val.getString() << std::endl; + } +} +static bool setup_log_params(const Settings &cmd_args) +{ // Quiet mode, print errors only if (cmd_args.getFlag("quiet")) { - log_remove_output(&main_stderr_log_out); - log_add_output_maxlev(&main_stderr_log_out, LMT_ERROR); + g_logger.removeOutput(&stderr_output); + g_logger.addOutputMaxLevel(&stderr_output, LL_ERROR); } + + // Coloured log messages (see log.h) + std::string color_mode; + if (cmd_args.exists("color")) { + color_mode = cmd_args.get("color"); +#if !defined(_WIN32) + } else { + char *color_mode_env = getenv("MT_LOGCOLOR"); + if (color_mode_env) + color_mode = color_mode_env; +#endif + } + if (color_mode != "") { + if (color_mode == "auto") { + Logger::color_mode = LOG_COLOR_AUTO; + } else if (color_mode == "always") { + Logger::color_mode = LOG_COLOR_ALWAYS; + } else if (color_mode == "never") { + Logger::color_mode = LOG_COLOR_NEVER; + } else { + errorstream << "Invalid color mode: " << color_mode << std::endl; + return false; + } + } + // If trace is enabled, enable logging of certain things if (cmd_args.getFlag("trace")) { dstream << _("Enabling trace level debug output") << std::endl; - log_trace_level_enabled = true; - dout_con_ptr = &verbosestream; // this is somewhat old crap - socket_enable_debug_output = true; // socket doesn't use log.h + g_logger.setTraceEnabled(true); + dout_con_ptr = &verbosestream; // This is somewhat old + socket_enable_debug_output = true; // Sockets doesn't use log.h } + // In certain cases, output info level on stderr if (cmd_args.getFlag("info") || cmd_args.getFlag("verbose") || cmd_args.getFlag("trace") || cmd_args.getFlag("speedtests")) - log_add_output(&main_stderr_log_out, LMT_INFO); + g_logger.addOutput(&stderr_output, LL_INFO); + // In certain cases, output verbose level on stderr if (cmd_args.getFlag("verbose") || cmd_args.getFlag("trace")) - log_add_output(&main_stderr_log_out, LMT_VERBOSE); + g_logger.addOutput(&stderr_output, LL_VERBOSE); - porting::signal_handler_init(); - bool &kill = *porting::signal_handler_killstatus(); + return true; +} - porting::initializePaths(); +static bool create_userdata_path() +{ + bool success; #ifdef __ANDROID__ - porting::initAndroid(); - - porting::setExternalStorageDir(porting::jnienv); if (!fs::PathExists(porting::path_user)) { - fs::CreateDir(porting::path_user); + success = fs::CreateDir(porting::path_user); + } else { + success = true; } - porting::copyAssets(); #else // Create user data directory - fs::CreateDir(porting::path_user); + success = fs::CreateDir(porting::path_user); #endif - infostream << "path_share = " << porting::path_share << std::endl; - infostream << "path_user = " << porting::path_user << std::endl; + return success; +} - // Initialize debug stacks - debug_stacks_init(); - DSTACK(__FUNCTION_NAME); +static bool init_common(const Settings &cmd_args, int argc, char *argv[]) +{ + startup_message(); + set_default_settings(g_settings); - // Debug handler - BEGIN_DEBUG_EXCEPTION_HANDLER + // Initialize sockets + sockets_init(); + atexit(sockets_cleanup); - // List gameids if requested - if (cmd_args.exists("gameid") && cmd_args.get("gameid") == "list") { - std::set gameids = getAvailableGameIds(); - for(std::set::const_iterator i = gameids.begin(); - i != gameids.end(); i++) - dstream<<(*i)< worldspecs = getAvailableWorlds(); - print_worldspecs(worldspecs, dstream); - return 0; - } + init_log_streams(cmd_args); - // Print startup message - infostream<getS32("curl_parallel_limit")); - // Initialize default settings - set_default_settings(g_settings); + init_gettext(porting::path_locale.c_str(), + g_settings->get("language"), argc, argv); - // Initialize sockets - sockets_init(); - atexit(sockets_cleanup); + return true; +} - /* - Read config file - */ +static void startup_message() +{ + infostream << PROJECT_NAME << " " << _("with") + << " SER_FMT_VER_HIGHEST_READ=" + << (int)SER_FMT_VER_HIGHEST_READ << ", " + << g_build_info << std::endl; +} +static bool read_config_file(const Settings &cmd_args) +{ // Path of configuration file in use - g_settings_path = ""; + sanity_check(g_settings_path == ""); // Sanity check if (cmd_args.exists("config")) { bool r = g_settings->readConfigFile(cmd_args.get("config").c_str()); - if (r == false) { + if (!r) { errorstream << "Could not read configuration from \"" - << cmd_args.get("config") << "\"" << std::endl; - return 1; + << cmd_args.get("config") << "\"" << std::endl; + return false; } g_settings_path = cmd_args.get("config"); } else { std::vector filenames; - filenames.push_back(porting::path_user + - DIR_DELIM + "minetest.conf"); + filenames.push_back(porting::path_user + DIR_DELIM + "minetest.conf"); // Legacy configuration file location filenames.push_back(porting::path_user + DIR_DELIM + ".." + DIR_DELIM + "minetest.conf"); + #if RUN_IN_PLACE // Try also from a lower level (to aid having the same configuration // for many RUN_IN_PLACE installs) @@ -975,976 +533,480 @@ int main(int argc, char *argv[]) DIR_DELIM + ".." + DIR_DELIM + ".." + DIR_DELIM + "minetest.conf"); #endif - for(u32 i = 0; i < filenames.size(); i++) { - bool r = g_settings->readConfigFile(filenames[i].c_str()); + for (const std::string &filename : filenames) { + bool r = g_settings->readConfigFile(filename.c_str()); if (r) { - g_settings_path = filenames[i]; + g_settings_path = filename; break; } } // If no path found, use the first one (menu creates the file) - if (g_settings_path == "") + if (g_settings_path.empty()) g_settings_path = filenames[0]; } - // Initialize debug streams -#define DEBUGFILE "debug.txt" -#if RUN_IN_PLACE - std::string logfile = DEBUGFILE; -#else - std::string logfile = porting::path_user+DIR_DELIM+DEBUGFILE; -#endif + return true; +} + +static void init_log_streams(const Settings &cmd_args) +{ + std::string log_filename = porting::path_user + DIR_DELIM + DEBUGFILE; + if (cmd_args.exists("logfile")) - logfile = cmd_args.get("logfile"); + log_filename = cmd_args.get("logfile"); - log_remove_output(&main_dstream_no_stderr_log_out); - int loglevel = g_settings->getS32("debug_log_level"); + g_logger.removeOutput(&file_log_output); + std::string conf_loglev = g_settings->get("debug_log_level"); - if (loglevel == 0) //no logging - logfile = ""; - else if (loglevel > 0 && loglevel <= LMT_NUM_VALUES) - log_add_output_maxlev(&main_dstream_no_stderr_log_out, - (LogMessageLevel)(loglevel - 1)); + // Old integer format + if (std::isdigit(conf_loglev[0])) { + warningstream << "Deprecated use of debug_log_level with an " + "integer value; please update your configuration." << std::endl; + static const char *lev_name[] = + {"", "error", "action", "info", "verbose"}; + int lev_i = atoi(conf_loglev.c_str()); + if (lev_i < 0 || lev_i >= (int)ARRLEN(lev_name)) { + warningstream << "Supplied invalid debug_log_level!" + " Assuming action level." << std::endl; + lev_i = 2; + } + conf_loglev = lev_name[lev_i]; + } - if (logfile != "") - debugstreams_init(false, logfile.c_str()); - else - debugstreams_init(false, NULL); + if (log_filename.empty() || conf_loglev.empty()) // No logging + return; - infostream << "logfile = " << logfile << std::endl; + LogLevel log_level = Logger::stringToLevel(conf_loglev); + if (log_level == LL_MAX) { + warningstream << "Supplied unrecognized debug_log_level; " + "using maximum." << std::endl; + } - // Initialize random seed - srand(time(0)); - mysrand(time(0)); + file_log_output.setFile(log_filename, + g_settings->getU64("debug_log_size_max") * 1000000); + g_logger.addOutputMaxLevel(&file_log_output, log_level); +} - // Initialize HTTP fetcher - httpfetch_init(g_settings->getS32("curl_parallel_limit")); +static bool game_configure(GameParams *game_params, const Settings &cmd_args) +{ + game_configure_port(game_params, cmd_args); -#ifndef __ANDROID__ - /* - Run unit tests - */ - if ((ENABLE_TESTS && cmd_args.getFlag("disable-unittests") == false) - || cmd_args.getFlag("enable-unittests") == true) { - run_tests(); + if (!game_configure_world(game_params, cmd_args)) { + errorstream << "No world path specified or found." << std::endl; + return false; } -#endif -#ifdef _MSC_VER - init_gettext((porting::path_share + DIR_DELIM + "locale").c_str(), - g_settings->get("language"), argc, argv); -#else - init_gettext((porting::path_share + DIR_DELIM + "locale").c_str(), - g_settings->get("language")); -#endif - /* - Game parameters - */ + game_configure_subgame(game_params, cmd_args); - // Port - u16 port = 30000; - if (cmd_args.exists("port")) - port = cmd_args.getU16("port"); - else if (g_settings->exists("port")) - port = g_settings->getU16("port"); - if (port == 0) - port = 30000; + return true; +} - // World directory - std::string commanded_world = ""; - if (cmd_args.exists("world")) - commanded_world = cmd_args.get("world"); - else if (cmd_args.exists("map-dir")) - commanded_world = cmd_args.get("map-dir"); - else if (cmd_args.exists("nonopt0")) // First nameless argument - commanded_world = cmd_args.get("nonopt0"); - else if (g_settings->exists("map-dir")) - commanded_world = g_settings->get("map-dir"); +static void game_configure_port(GameParams *game_params, const Settings &cmd_args) +{ + if (cmd_args.exists("port")) { + game_params->socket_port = cmd_args.getU16("port"); + } else { + if (game_params->is_dedicated_server) + game_params->socket_port = g_settings->getU16("port"); + else + game_params->socket_port = g_settings->getU16("remote_port"); + } + + if (game_params->socket_port == 0) + game_params->socket_port = DEFAULT_SERVER_PORT; +} + +static bool game_configure_world(GameParams *game_params, const Settings &cmd_args) +{ + if (get_world_from_cmdline(game_params, cmd_args)) + return true; + + if (get_world_from_config(game_params, cmd_args)) + return true; + + return auto_select_world(game_params); +} + +static bool get_world_from_cmdline(GameParams *game_params, const Settings &cmd_args) +{ + std::string commanded_world; // World name - std::string commanded_worldname = ""; + std::string commanded_worldname; if (cmd_args.exists("worldname")) commanded_worldname = cmd_args.get("worldname"); - // Strip world.mt from commanded_world - { - std::string worldmt = "world.mt"; - if (commanded_world.size() > worldmt.size() && - commanded_world.substr(commanded_world.size() - worldmt.size()) - == worldmt) { - dstream << _("Supplied world.mt file - stripping it off.") << std::endl; - commanded_world = commanded_world.substr(0, - commanded_world.size() - worldmt.size()); - } - } - // If a world name was specified, convert it to a path - if (commanded_worldname != "") { + if (!commanded_worldname.empty()) { // Get information about available worlds std::vector worldspecs = getAvailableWorlds(); bool found = false; - for(u32 i = 0; i < worldspecs.size(); i++) { - std::string name = worldspecs[i].name; + for (const WorldSpec &worldspec : worldspecs) { + std::string name = worldspec.name; if (name == commanded_worldname) { - if (commanded_world != "") { - dstream << _("--worldname takes precedence over previously " - "selected world.") << std::endl; - } - commanded_world = worldspecs[i].path; + dstream << _("Using world specified by --worldname on the " + "command line") << std::endl; + commanded_world = worldspec.path; found = true; break; } } if (!found) { - dstream << _("World") << " '"<world_path = get_clean_world_path(commanded_world); + return !commanded_world.empty(); } + if (cmd_args.exists("world")) + commanded_world = cmd_args.get("world"); + else if (cmd_args.exists("map-dir")) + commanded_world = cmd_args.get("map-dir"); + else if (cmd_args.exists("nonopt0")) // First nameless argument + commanded_world = cmd_args.get("nonopt0"); - /* - Run dedicated server if asked to or no other option - */ -#ifdef SERVER - bool run_dedicated_server = true; -#else - bool run_dedicated_server = cmd_args.getFlag("server"); -#endif - g_settings->set("server_dedicated", run_dedicated_server ? "true" : "false"); - if (run_dedicated_server) - { - DSTACK("Dedicated server branch"); - // Create time getter if built with Irrlicht -#ifndef SERVER - g_timegetter = new SimpleTimeGetter(); -#endif - - // World directory - std::string world_path; - verbosestream << _("Determining world path") << std::endl; - bool is_legacy_world = false; - // If a world was commanded, use it - if (commanded_world != "") { - world_path = commanded_world; - infostream << "Using commanded world path [" << world_path << "]" - << std::endl; - } else { // No world was specified; try to select it automatically - // Get information about available worlds - std::vector worldspecs = getAvailableWorlds(); - // If a world name was specified, select it - if (commanded_worldname != "") { - world_path = ""; - for(u32 i = 0; i < worldspecs.size(); i++) { - std::string name = worldspecs[i].name; - if (name == commanded_worldname) { - world_path = worldspecs[i].path; - break; - } - } - if (world_path == "") { - dstream << _("World") << " '" << commanded_worldname << "' " << _("not " - "available. Available worlds:") << std::endl; - print_worldspecs(worldspecs, dstream); - return 1; - } - } - // If there is only a single world, use it - if (worldspecs.size() == 1) { - world_path = worldspecs[0].path; - dstream <<_("Automatically selecting world at") << " [" - << world_path << "]" << std::endl; - // If there are multiple worlds, list them - } else if (worldspecs.size() > 1) { - dstream << _("Multiple worlds are available.") << std::endl; - dstream << _("Please select one using --worldname " - " or --world ") << std::endl; - print_worldspecs(worldspecs, dstream); - return 1; - // If there are no worlds, automatically create a new one - } else { - // This is the ultimate default world path - world_path = porting::path_user + DIR_DELIM + "worlds" + - DIR_DELIM + "world"; - infostream << "Creating default world at [" - << world_path << "]" << std::endl; - } - } - - if (world_path == "") { - errorstream << "No world path specified or found." << std::endl; - return 1; - } - verbosestream << _("Using world path") << " [" << world_path << "]" << std::endl; - - // We need a gamespec. - SubgameSpec gamespec; - verbosestream << _("Determining gameid/gamespec") << std::endl; - // If world doesn't exist - if (!getWorldExists(world_path)) { - // Try to take gamespec from command line - if (commanded_gamespec.isValid()) { - gamespec = commanded_gamespec; - infostream << "Using commanded gameid [" << gamespec.id << "]" << std::endl; - } else { // Otherwise we will be using "minetest" - gamespec = findSubgame(g_settings->get("default_game")); - infostream << "Using default gameid [" << gamespec.id << "]" << std::endl; - } - } else { // World exists - std::string world_gameid = getWorldGameId(world_path, is_legacy_world); - // If commanded to use a gameid, do so - if (commanded_gamespec.isValid()) { - gamespec = commanded_gamespec; - if (commanded_gamespec.id != world_gameid) { - errorstream << "WARNING: Using commanded gameid [" - << gamespec.id << "]" << " instead of world gameid [" - << world_gameid << "]" << std::endl; - } - } else { - // If world contains an embedded game, use it; - // Otherwise find world from local system. - gamespec = findWorldSubgame(world_path); - infostream << "Using world gameid [" << gamespec.id << "]" << std::endl; - } - } - if (!gamespec.isValid()) { - errorstream << "Subgame [" << gamespec.id << "] could not be found." - << std::endl; - return 1; - } - verbosestream << _("Using gameid") << " [" << gamespec.id<<"]" << std::endl; - - // Bind address - std::string bind_str = g_settings->get("bind_address"); - Address bind_addr(0, 0, 0, 0, port); - - if (g_settings->getBool("ipv6_server")) { - bind_addr.setAddress((IPv6AddressBytes*) NULL); - } - try { - bind_addr.Resolve(bind_str.c_str()); - } catch (ResolveError &e) { - infostream << "Resolving bind address \"" << bind_str - << "\" failed: " << e.what() - << " -- Listening on all addresses." << std::endl; - } - if (bind_addr.isIPv6() && !g_settings->getBool("enable_ipv6")) { - errorstream << "Unable to listen on " - << bind_addr.serializeString() - << L" because IPv6 is disabled" << std::endl; - return 1; - } - - // Create server - Server server(world_path, gamespec, false, bind_addr.isIPv6()); - - // Database migration - if (cmd_args.exists("migrate")) { - std::string migrate_to = cmd_args.get("migrate"); - Settings world_mt; - bool success = world_mt.readConfigFile((world_path + DIR_DELIM - + "world.mt").c_str()); - if (!success) { - errorstream << "Cannot read world.mt" << std::endl; - return 1; - } - if (!world_mt.exists("backend")) { - errorstream << "Please specify your current backend in world.mt file:" - << std::endl << " backend = {sqlite3|leveldb|redis|dummy}" << std::endl; - return 1; - } - std::string backend = world_mt.get("backend"); - Database *new_db; - if (backend == migrate_to) { - errorstream << "Cannot migrate: new backend is same" - <<" as the old one" << std::endl; - return 1; - } - if (migrate_to == "sqlite3") - new_db = new Database_SQLite3(&(ServerMap&)server.getMap(), world_path); - #if USE_LEVELDB - else if (migrate_to == "leveldb") - new_db = new Database_LevelDB(&(ServerMap&)server.getMap(), world_path); - #endif - #if USE_REDIS - else if (migrate_to == "redis") - new_db = new Database_Redis(&(ServerMap&)server.getMap(), world_path); - #endif - else { - errorstream << "Migration to " << migrate_to - << " is not supported" << std::endl; - return 1; - } - - std::list blocks; - ServerMap &old_map = ((ServerMap&)server.getMap()); - old_map.listAllLoadableBlocks(blocks); - int count = 0; - new_db->beginSave(); - for (std::list::iterator i = blocks.begin(); i != blocks.end(); i++) { - MapBlock *block = old_map.loadBlock(*i); - new_db->saveBlock(block); - MapSector *sector = old_map.getSectorNoGenerate(v2s16(i->X, i->Z)); - sector->deleteBlock(block); - ++count; - if (count % 500 == 0) - actionstream << "Migrated " << count << " blocks " - << (100.0 * count / blocks.size()) << "% completed" << std::endl; - } - new_db->endSave(); - delete new_db; + game_params->world_path = get_clean_world_path(commanded_world); + return !commanded_world.empty(); +} - actionstream << "Successfully migrated " << count << " blocks" << std::endl; - world_mt.set("backend", migrate_to); - if (!world_mt.updateConfigFile((world_path + DIR_DELIM + "world.mt").c_str())) - errorstream << "Failed to update world.mt!" << std::endl; - else - actionstream << "world.mt updated" << std::endl; +static bool get_world_from_config(GameParams *game_params, const Settings &cmd_args) +{ + // World directory + std::string commanded_world; - return 0; - } + if (g_settings->exists("map-dir")) + commanded_world = g_settings->get("map-dir"); - server.start(bind_addr); + game_params->world_path = get_clean_world_path(commanded_world); - // Run server - dedicated_server_loop(server, kill); + return !commanded_world.empty(); +} - return 0; +static bool auto_select_world(GameParams *game_params) +{ + // No world was specified; try to select it automatically + // Get information about available worlds + + std::vector worldspecs = getAvailableWorlds(); + std::string world_path; + + // If there is only a single world, use it + if (worldspecs.size() == 1) { + world_path = worldspecs[0].path; + dstream <<_("Automatically selecting world at") << " [" + << world_path << "]" << std::endl; + // If there are multiple worlds, list them + } else if (worldspecs.size() > 1 && game_params->is_dedicated_server) { + std::cerr << _("Multiple worlds are available.") << std::endl; + std::cerr << _("Please select one using --worldname " + " or --world ") << std::endl; + print_worldspecs(worldspecs, std::cerr); + return false; + // If there are no worlds, automatically create a new one + } else { + // This is the ultimate default world path + world_path = porting::path_user + DIR_DELIM + "worlds" + + DIR_DELIM + "world"; + infostream << "Using default world at [" + << world_path << "]" << std::endl; } -#ifndef SERVER // Exclude from dedicated server build - - /* - More parameters - */ - - std::string address = g_settings->get("address"); - if (commanded_world != "") - address = ""; - else if (cmd_args.exists("address")) - address = cmd_args.get("address"); - - std::string playername = g_settings->get("name"); - if (cmd_args.exists("name")) - playername = cmd_args.get("name"); - - bool skip_main_menu = cmd_args.getFlag("go"); - - /* - Device initialization - */ - - // Resolution selection - - bool fullscreen = g_settings->getBool("fullscreen"); - u16 screenW = g_settings->getU16("screenW"); - u16 screenH = g_settings->getU16("screenH"); - - // bpp, fsaa, vsync - - bool vsync = g_settings->getBool("vsync"); - u16 bits = g_settings->getU16("fullscreen_bpp"); - u16 fsaa = g_settings->getU16("fsaa"); - - // Determine driver - - video::E_DRIVER_TYPE driverType; + assert(world_path != ""); // Post-condition + game_params->world_path = world_path; + return true; +} - std::string driverstring = g_settings->get("video_driver"); +static std::string get_clean_world_path(const std::string &path) +{ + const std::string worldmt = "world.mt"; + std::string clean_path; - if (driverstring == "null") - driverType = video::EDT_NULL; - else if (driverstring == "software") - driverType = video::EDT_SOFTWARE; - else if (driverstring == "burningsvideo") - driverType = video::EDT_BURNINGSVIDEO; - else if (driverstring == "direct3d8") - driverType = video::EDT_DIRECT3D8; - else if (driverstring == "direct3d9") - driverType = video::EDT_DIRECT3D9; - else if (driverstring == "opengl") - driverType = video::EDT_OPENGL; -#ifdef _IRR_COMPILE_WITH_OGLES1_ - else if (driverstring == "ogles1") - driverType = video::EDT_OGLES1; -#endif -#ifdef _IRR_COMPILE_WITH_OGLES2_ - else if (driverstring == "ogles2") - driverType = video::EDT_OGLES2; -#endif - else { - errorstream << "WARNING: Invalid video_driver specified; defaulting " - << "to opengl" << std::endl; - driverType = video::EDT_OPENGL; + if (path.size() > worldmt.size() + && path.substr(path.size() - worldmt.size()) == worldmt) { + dstream << _("Supplied world.mt file - stripping it off.") << std::endl; + clean_path = path.substr(0, path.size() - worldmt.size()); + } else { + clean_path = path; } + return path; +} - /* - List video modes if requested - */ - - MyEventReceiver* receiver = new MyEventReceiver(); - if (cmd_args.getFlag("videomodes")) { - IrrlichtDevice *nulldevice; +static bool game_configure_subgame(GameParams *game_params, const Settings &cmd_args) +{ + bool success; - SIrrlichtCreationParameters params = SIrrlichtCreationParameters(); - params.DriverType = video::EDT_NULL; - params.WindowSize = core::dimension2d(640, 480); - params.Bits = 24; - params.AntiAlias = fsaa; - params.Fullscreen = false; - params.Stencilbuffer = false; - params.Vsync = vsync; - params.EventReceiver = receiver; - params.HighPrecisionFPU = g_settings->getBool("high_precision_fpu"); + success = get_game_from_cmdline(game_params, cmd_args); + if (!success) + success = determine_subgame(game_params); - nulldevice = createDeviceEx(params); + return success; +} - if (nulldevice == 0) - return 1; +static bool get_game_from_cmdline(GameParams *game_params, const Settings &cmd_args) +{ + SubgameSpec commanded_gamespec; - dstream << _("Available video modes (WxHxD):") << std::endl; + if (cmd_args.exists("gameid")) { + std::string gameid = cmd_args.get("gameid"); + commanded_gamespec = findSubgame(gameid); + if (!commanded_gamespec.isValid()) { + errorstream << "Game \"" << gameid << "\" not found" << std::endl; + return false; + } + dstream << _("Using game specified by --gameid on the command line") + << std::endl; + game_params->game_spec = commanded_gamespec; + return true; + } - video::IVideoModeList *videomode_list = - nulldevice->getVideoModeList(); + return false; +} - if (videomode_list == 0) { - nulldevice->drop(); - return 1; +static bool determine_subgame(GameParams *game_params) +{ + SubgameSpec gamespec; + + assert(game_params->world_path != ""); // Pre-condition + + // If world doesn't exist + if (!game_params->world_path.empty() + && !getWorldExists(game_params->world_path)) { + // Try to take gamespec from command line + if (game_params->game_spec.isValid()) { + gamespec = game_params->game_spec; + infostream << "Using commanded gameid [" << gamespec.id << "]" << std::endl; + } else { // Otherwise we will be using "minetest" + gamespec = findSubgame(g_settings->get("default_game")); + infostream << "Using default gameid [" << gamespec.id << "]" << std::endl; + if (!gamespec.isValid()) { + errorstream << "Game specified in default_game [" + << g_settings->get("default_game") + << "] is invalid." << std::endl; + return false; + } } - - s32 videomode_count = videomode_list->getVideoModeCount(); - core::dimension2d videomode_res; - s32 videomode_depth; - for (s32 i = 0; i < videomode_count; ++i) { - videomode_res = videomode_list->getVideoModeResolution(i); - videomode_depth = videomode_list->getVideoModeDepth(i); - dstream<world_path, false); + // If commanded to use a gameid, do so + if (game_params->game_spec.isValid()) { + gamespec = game_params->game_spec; + if (game_params->game_spec.id != world_gameid) { + warningstream << "Using commanded gameid [" + << gamespec.id << "]" << " instead of world gameid [" + << world_gameid << "]" << std::endl; + } + } else { + // If world contains an embedded game, use it; + // Otherwise find world from local system. + gamespec = findWorldSubgame(game_params->world_path); + infostream << "Using world gameid [" << gamespec.id << "]" << std::endl; } + } - dstream << _("Active video mode (WxHxD):") << std::endl; - videomode_res = videomode_list->getDesktopResolution(); - videomode_depth = videomode_list->getDesktopDepth(); - dstream << videomode_res.Width << "x" << videomode_res.Height - << "x" << videomode_depth << std::endl; - - nulldevice->drop(); - - delete receiver; - return 0; + if (!gamespec.isValid()) { + errorstream << "Game [" << gamespec.id << "] could not be found." + << std::endl; + return false; } - /* - Create device and exit if creation failed - */ - SIrrlichtCreationParameters params = SIrrlichtCreationParameters(); - params.DriverType = driverType; - params.WindowSize = core::dimension2d(screenW, screenH); - params.Bits = bits; - params.AntiAlias = fsaa; - params.Fullscreen = fullscreen; - params.Stencilbuffer = false; - params.Vsync = vsync; - params.EventReceiver = receiver; - params.HighPrecisionFPU = g_settings->getBool("high_precision_fpu"); -#ifdef __ANDROID__ - params.PrivateData = porting::app_global; - params.OGLES2ShaderPath = std::string(porting::path_user + DIR_DELIM + - "media" + DIR_DELIM + "Shaders" + DIR_DELIM).c_str(); -#endif + game_params->game_spec = gamespec; + return true; +} - IrrlichtDevice * device = createDeviceEx(params); - if (device == 0) { - delete receiver; - return 1; // could not create selected driver. +/***************************************************************************** + * Dedicated server + *****************************************************************************/ +static bool run_dedicated_server(const GameParams &game_params, const Settings &cmd_args) +{ + verbosestream << _("Using world path") << " [" + << game_params.world_path << "]" << std::endl; + verbosestream << _("Using gameid") << " [" + << game_params.game_spec.id << "]" << std::endl; + + // Bind address + std::string bind_str = g_settings->get("bind_address"); + Address bind_addr(0, 0, 0, 0, game_params.socket_port); + + if (g_settings->getBool("ipv6_server")) { + bind_addr.setAddress((IPv6AddressBytes*) NULL); + } + try { + bind_addr.Resolve(bind_str.c_str()); + } catch (ResolveError &e) { + infostream << "Resolving bind address \"" << bind_str + << "\" failed: " << e.what() + << " -- Listening on all addresses." << std::endl; + } + if (bind_addr.isIPv6() && !g_settings->getBool("enable_ipv6")) { + errorstream << "Unable to listen on " + << bind_addr.serializeString() + << L" because IPv6 is disabled" << std::endl; + return false; } - // Map our log level to irrlicht engine one. - static const irr::ELOG_LEVEL irr_log_level[5] = { - ELL_NONE, - ELL_ERROR, - ELL_WARNING, - ELL_INFORMATION, -#if (IRRLICHT_VERSION_MAJOR == 1 && IRRLICHT_VERSION_MINOR < 8) - ELL_INFORMATION -#else - ELL_DEBUG -#endif - }; - - ILogger* irr_logger = device->getLogger(); - irr_logger->setLogLevel(irr_log_level[loglevel]); + // Database migration + if (cmd_args.exists("migrate")) + return migrate_map_database(game_params, cmd_args); - porting::initIrrlicht(device); - late_init_default_settings(g_settings); + if (cmd_args.exists("migrate-players")) + return ServerEnvironment::migratePlayersDatabase(game_params, cmd_args); - /* - Continue initialization - */ + if (cmd_args.exists("migrate-auth")) + return ServerEnvironment::migrateAuthDatabase(game_params, cmd_args); - video::IVideoDriver* driver = device->getVideoDriver(); + if (cmd_args.exists("terminal")) { +#if USE_CURSES + bool name_ok = true; + std::string admin_nick = g_settings->get("name"); - /* - This changes the minimum allowed number of vertices in a VBO. - Default is 500. - */ - //driver->setMinHardwareBufferVertexCount(50); + name_ok = name_ok && !admin_nick.empty(); + name_ok = name_ok && string_allowed(admin_nick, PLAYERNAME_ALLOWED_CHARS); - // Create time getter - g_timegetter = new IrrlichtTimeGetter(device); + if (!name_ok) { + if (admin_nick.empty()) { + errorstream << "No name given for admin. " + << "Please check your minetest.conf that it " + << "contains a 'name = ' to your main admin account." + << std::endl; + } else { + errorstream << "Name for admin '" + << admin_nick << "' is not valid. " + << "Please check that it only contains allowed characters. " + << "Valid characters are: " << PLAYERNAME_ALLOWED_CHARS_USER_EXPL + << std::endl; + } + return false; + } + ChatInterface iface; + bool &kill = *porting::signal_handler_killstatus(); - // Create game callback for menus - g_gamecallback = new MainGameCallback(device); + try { + // Create server + Server server(game_params.world_path, game_params.game_spec, + false, bind_addr, true, &iface); - /* - Speed tests (done after irrlicht is loaded to get timer) - */ - if (cmd_args.getFlag("speedtests")) - { - dstream << "Running speed tests" << std::endl; - SpeedTests(); - device->drop(); - return 0; - } + g_term_console.setup(&iface, &kill, admin_nick); - device->setResizable(true); + g_term_console.start(); - bool random_input = g_settings->getBool("random_input") - || cmd_args.getFlag("random-input"); - InputHandler *input = NULL; + server.start(); + // Run server + dedicated_server_loop(server, kill); + } catch (const ModError &e) { + g_term_console.stopAndWaitforThread(); + errorstream << "ModError: " << e.what() << std::endl; + return false; + } catch (const ServerError &e) { + g_term_console.stopAndWaitforThread(); + errorstream << "ServerError: " << e.what() << std::endl; + return false; + } - if (random_input) { - input = new RandomInputHandler(); - } else { - input = new RealInputHandler(device,receiver); - } + // Tell the console to stop, and wait for it to finish, + // only then leave context and free iface + g_term_console.stop(); + g_term_console.wait(); - scene::ISceneManager* smgr = device->getSceneManager(); - - guienv = device->getGUIEnvironment(); - gui::IGUISkin* skin = guienv->getSkin(); - std::string font_path = g_settings->get("font_path"); - gui::IGUIFont *font; - #if USE_FREETYPE - bool use_freetype = g_settings->getBool("freetype"); - if (use_freetype) { - std::string fallback; - if (is_yes(gettext("needs_fallback_font"))) - fallback = "fallback_"; - u16 font_size = g_settings->getU16(fallback + "font_size"); - font_path = g_settings->get(fallback + "font_path"); - u32 font_shadow = g_settings->getU16(fallback + "font_shadow"); - u32 font_shadow_alpha = g_settings->getU16(fallback + "font_shadow_alpha"); - font = gui::CGUITTFont::createTTFont(guienv, font_path.c_str(), font_size, - true, true, font_shadow, font_shadow_alpha); + g_term_console.clearKillStatus(); } else { - font = guienv->getFont(font_path.c_str()); - } - #else - font = guienv->getFont(font_path.c_str()); - #endif - if (font) - skin->setFont(font); - else - errorstream << "WARNING: Font file was not found." - << " Using default font." << std::endl; - // If font was not found, this will get us one - font = skin->getFont(); - assert(font); - - u32 text_height = font->getDimension(L"Hello, world!").Height; - infostream << "text_height=" << text_height << std::endl; - - skin->setColor(gui::EGDC_BUTTON_TEXT, video::SColor(255, 255, 255, 255)); - skin->setColor(gui::EGDC_3D_HIGH_LIGHT, video::SColor(255, 0, 0, 0)); - skin->setColor(gui::EGDC_3D_SHADOW, video::SColor(255, 0, 0, 0)); - skin->setColor(gui::EGDC_HIGH_LIGHT, video::SColor(255, 70, 100, 50)); - skin->setColor(gui::EGDC_HIGH_LIGHT_TEXT, video::SColor(255, 255, 255, 255)); - -#if (IRRLICHT_VERSION_MAJOR >= 1 && IRRLICHT_VERSION_MINOR >= 8) || IRRLICHT_VERSION_MAJOR >= 2 - // Irrlicht 1.8 input colours - skin->setColor(gui::EGDC_EDITABLE, video::SColor(255, 128, 128, 128)); - skin->setColor(gui::EGDC_FOCUSED_EDITABLE, video::SColor(255, 96, 134, 49)); +#else + errorstream << "Cmd arg --terminal passed, but " + << "compiled without ncurses. Ignoring." << std::endl; + } { #endif + try { + // Create server + Server server(game_params.world_path, game_params.game_spec, false, + bind_addr, true); + server.start(); + // Run server + bool &kill = *porting::signal_handler_killstatus(); + dedicated_server_loop(server, kill); - // Create the menu clouds - if (!g_menucloudsmgr) - g_menucloudsmgr = smgr->createNewSceneManager(); - if (!g_menuclouds) - g_menuclouds = new Clouds(g_menucloudsmgr->getRootSceneNode(), - g_menucloudsmgr, -1, rand(), 100); - g_menuclouds->update(v2f(0, 0), video::SColor(255, 200, 200, 255)); - scene::ICameraSceneNode* camera; - camera = g_menucloudsmgr->addCameraSceneNode(0, - v3f(0, 0, 0), v3f(0, 60, 100)); - camera->setFarValue(10000); - - /* - GUI stuff - */ - - ChatBackend chat_backend; - - /* - If an error occurs, this is set to something and the - menu-game loop is restarted. It is then displayed before - the menu. - */ - std::wstring error_message = L""; - - // The password entered during the menu screen, - std::string password; - - bool first_loop = true; - - /* - Menu-game loop - */ - while (device->run() && (kill == false) && - (g_gamecallback->shutdown_requested == false)) - { - // Set the window caption - wchar_t* text = wgettext("Main Menu"); - device->setWindowCaption((std::wstring(L"Minetest [") + text + L"]").c_str()); - delete[] text; - - // This is used for catching disconnects - try - { - - /* - Clear everything from the GUIEnvironment - */ - guienv->clear(); - - /* - We need some kind of a root node to be able to add - custom gui elements directly on the screen. - Otherwise they won't be automatically drawn. - */ - guiroot = guienv->addStaticText(L"", - core::rect(0, 0, 10000, 10000)); - - SubgameSpec gamespec; - WorldSpec worldspec; - bool simple_singleplayer_mode = false; - - // These are set up based on the menu and other things - std::string current_playername = "inv£lid"; - std::string current_password = ""; - std::string current_address = "does-not-exist"; - int current_port = 0; - - /* - Out-of-game menu loop. - - Loop quits when menu returns proper parameters. - */ - while (kill == false) { - // If skip_main_menu, only go through here once - if (skip_main_menu && !first_loop) { - kill = true; - break; - } - first_loop = false; - - // Cursor can be non-visible when coming from the game - #ifndef ANDROID - device->getCursorControl()->setVisible(true); - #endif - // Some stuff are left to scene manager when coming from the game - // (map at least?) - smgr->clear(); - - // Initialize menu data - MainMenuData menudata; - menudata.address = address; - menudata.name = playername; - menudata.port = itos(port); - menudata.errormessage = wide_to_narrow(error_message); - error_message = L""; - if (cmd_args.exists("password")) - menudata.password = cmd_args.get("password"); - - driver->setTextureCreationFlag(video::ETCF_CREATE_MIP_MAPS, g_settings->getBool("mip_map")); - - menudata.enable_public = g_settings->getBool("server_announce"); - - std::vector worldspecs = getAvailableWorlds(); - - // If a world was commanded, append and select it - if(commanded_world != "") { - worldspec.gameid = getWorldGameId(commanded_world, true); - worldspec.name = _("[--world parameter]"); - if(worldspec.gameid == "") { - worldspec.gameid = g_settings->get("default_game"); - worldspec.name += " [new]"; - } - worldspec.path = commanded_world; - } - - if (skip_main_menu == false) { - video::IVideoDriver* driver = device->getVideoDriver(); - - infostream << "Waiting for other menus" << std::endl; - while (device->run() && kill == false) { - if (noMenuActive()) - break; - driver->beginScene(true, true, - video::SColor(255, 128, 128, 128)); - guienv->drawAll(); - driver->endScene(); - // On some computers framerate doesn't seem to be - // automatically limited - sleep_ms(25); - } - infostream << "Waited for other menus" << std::endl; - - /* show main menu */ - GUIEngine mymenu(device, guiroot, &g_menumgr,smgr,&menudata,kill); - - //once finished you'll never end up here - smgr->clear(); - } - - if (menudata.errormessage != "") { - error_message = narrow_to_wide(menudata.errormessage); - continue; - } - - //update worldspecs (necessary as new world may have been created) - worldspecs = getAvailableWorlds(); - - if (menudata.name == "") - menudata.name = std::string("Guest") + itos(myrand_range(1000,9999)); - else - playername = menudata.name; - - password = translatePassword(playername, narrow_to_wide(menudata.password)); - //infostream<<"Main: password hash: '"<set("name", playername); - - // Break out of menu-game loop to shut down cleanly - if (device->run() == false || kill == true) - break; - - current_playername = playername; - current_password = password; - current_address = address; - current_port = port; - - // If using simple singleplayer mode, override - if (simple_singleplayer_mode) { - current_playername = "singleplayer"; - current_password = ""; - current_address = ""; - current_port = myrand_range(49152, 65535); - } else if (address != "") { - ServerListSpec server; - server["name"] = menudata.servername; - server["address"] = menudata.address; - server["port"] = menudata.port; - server["description"] = menudata.serverdescription; - ServerList::insert(server); - } - - if ((!skip_main_menu) && - (menudata.selected_world >= 0) && - (menudata.selected_world < (int)worldspecs.size())) { - g_settings->set("selected_world_path", - worldspecs[menudata.selected_world].path); - worldspec = worldspecs[menudata.selected_world]; - - } - - infostream <<"Selected world: " << worldspec.name - << " ["<run() == false || kill == true) { - if (g_settings_path != "") { - g_settings->updateConfigFile(g_settings_path.c_str()); - } - break; - } - - /* - Run game - */ -#ifdef HAVE_TOUCHSCREENGUI - receiver->m_touchscreengui = new TouchScreenGUI(device, receiver); - g_touchscreengui = receiver->m_touchscreengui; -#endif - the_game( - kill, - random_input, - input, - device, - font, - worldspec.path, - current_playername, - current_password, - current_address, - current_port, - error_message, - chat_backend, - gamespec, - simple_singleplayer_mode - ); - smgr->clear(); -#ifdef HAVE_TOUCHSCREENGUI - delete g_touchscreengui; - g_touchscreengui = NULL; - receiver->m_touchscreengui = NULL; -#endif - - } //try - catch(con::PeerNotFoundException &e) - { - error_message = wgettext("Connection error (timed out?)"); - errorstream << wide_to_narrow(error_message) << std::endl; + } catch (const ModError &e) { + errorstream << "ModError: " << e.what() << std::endl; + return false; + } catch (const ServerError &e) { + errorstream << "ServerError: " << e.what() << std::endl; + return false; } -#ifdef NDEBUG - catch(std::exception &e) - { - std::string narrow_message = "Some exception: \""; - narrow_message += e.what(); - narrow_message += "\""; - errorstream << narrow_message << std::endl; - error_message = narrow_to_wide(narrow_message); - } -#endif + } - // If no main menu, show error and exit - if (skip_main_menu) { - if (error_message != L"") { - verbosestream << "error_message = " - << wide_to_narrow(error_message) << std::endl; - retval = 1; - } - break; - } - } // Menu-game loop + return true; +} +static bool migrate_map_database(const GameParams &game_params, const Settings &cmd_args) +{ + std::string migrate_to = cmd_args.get("migrate"); + Settings world_mt; + std::string world_mt_path = game_params.world_path + DIR_DELIM + "world.mt"; + if (!world_mt.readConfigFile(world_mt_path.c_str())) { + errorstream << "Cannot read world.mt!" << std::endl; + return false; + } - g_menuclouds->drop(); - g_menucloudsmgr->drop(); + if (!world_mt.exists("backend")) { + errorstream << "Please specify your current backend in world.mt:" + << std::endl + << " backend = {sqlite3|leveldb|redis|dummy|postgresql}" + << std::endl; + return false; + } - delete input; + std::string backend = world_mt.get("backend"); + if (backend == migrate_to) { + errorstream << "Cannot migrate: new backend is same" + << " as the old one" << std::endl; + return false; + } - /* - In the end, delete the Irrlicht device. - */ - device->drop(); + MapDatabase *old_db = ServerMap::createDatabase(backend, game_params.world_path, world_mt), + *new_db = ServerMap::createDatabase(migrate_to, game_params.world_path, world_mt); -#if USE_FREETYPE - if (use_freetype) - font->drop(); -#endif - delete receiver; -#endif // !SERVER + u32 count = 0; + time_t last_update_time = 0; + bool &kill = *porting::signal_handler_killstatus(); - // Update configuration file - if (g_settings_path != "") - g_settings->updateConfigFile(g_settings_path.c_str()); + std::vector blocks; + old_db->listAllLoadableBlocks(blocks); + new_db->beginSave(); + for (std::vector::const_iterator it = blocks.begin(); it != blocks.end(); ++it) { + if (kill) return false; - // Print modified quicktune values - { - bool header_printed = false; - std::vector names = getQuicktuneNames(); - for(u32 i = 0; i < names.size(); i++) { - QuicktuneValue val = getQuicktuneValue(names[i]); - if (!val.modified) - continue; - if (!header_printed) { - dstream << "Modified quicktune values:" << std::endl; - header_printed = true; - } - dstream<= 1) { + std::cerr << " Migrated " << count << " blocks, " + << (100.0 * count / blocks.size()) << "% completed.\r"; + new_db->endSave(); + new_db->beginSave(); + last_update_time = time(NULL); } } + std::cerr << std::endl; + new_db->endSave(); + delete old_db; + delete new_db; - // Stop httpfetch thread (if started) - httpfetch_cleanup(); - - END_DEBUG_EXCEPTION_HANDLER(errorstream) - - debugstreams_deinit(); - + actionstream << "Successfully migrated " << count << " blocks" << std::endl; + world_mt.set("backend", migrate_to); + if (!world_mt.updateConfigFile(world_mt_path.c_str())) + errorstream << "Failed to update world.mt!" << std::endl; + else + actionstream << "world.mt updated" << std::endl; - return retval; + return true; } - -//END -