/*
* The ManaPlus Client
* Copyright (C) 2004-2009 The Mana World Development Team
* Copyright (C) 2009-2010 The Mana Developers
* Copyright (C) 2011-2014 The ManaPlus Developers
*
* This file is part of The ManaPlus Client.
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 2 of the License, or
* any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with this program. If not, see .
*/
#include "main.h"
#include "client.h"
#include "auctionmanager.h"
#include "chatlogger.h"
#include "configuration.h"
#include "dropshortcut.h"
#include "emoteshortcut.h"
#include "eventsmanager.h"
#include "game.h"
#include "guild.h"
#include "guildmanager.h"
#include "graphicsmanager.h"
#include "itemshortcut.h"
#include "party.h"
#include "soundconsts.h"
#include "soundmanager.h"
#include "statuseffect.h"
#include "units.h"
#include "touchmanager.h"
#include "being/beingspeech.h"
#include "being/playerinfo.h"
#include "being/playerrelations.h"
#include "input/inputmanager.h"
#include "input/joystick.h"
#include "input/keyboardconfig.h"
#include "gui/gui.h"
#include "gui/skin.h"
#include "gui/theme.h"
#include "gui/windows/buyselldialog.h"
#include "gui/windows/buydialog.h"
#include "gui/windows/changeemaildialog.h"
#include "gui/windows/changepassworddialog.h"
#include "gui/windows/charselectdialog.h"
#include "gui/windows/confirmdialog.h"
#include "gui/windows/connectiondialog.h"
#include "gui/windows/didyouknowwindow.h"
#include "gui/windows/helpwindow.h"
#include "gui/windows/logindialog.h"
#include "gui/windows/npcdialog.h"
#include "gui/windows/okdialog.h"
#include "gui/windows/registerdialog.h"
#include "gui/windows/selldialog.h"
#include "gui/windows/serverdialog.h"
#include "gui/windows/setupwindow.h"
#include "gui/windows/unregisterdialog.h"
#include "gui/windows/updaterwindow.h"
#include "gui/windows/quitdialog.h"
#include "gui/windows/worldselectdialog.h"
#include "gui/widgets/button.h"
#include "gui/widgets/desktop.h"
#include "net/chathandler.h"
#include "net/download.h"
#include "net/gamehandler.h"
#include "net/generalhandler.h"
#include "net/guildhandler.h"
#include "net/inventoryhandler.h"
#include "net/loginhandler.h"
#include "net/net.h"
#include "net/netconsts.h"
#include "net/partyhandler.h"
#include "particle/particle.h"
#include "resources/imagehelper.h"
#include "resources/openglimagehelper.h"
#include "resources/resourcemanager.h"
#include "resources/surfaceimagehelper.h"
#include "resources/spritereference.h"
#include "resources/db/avatardb.h"
#include "resources/db/chardb.h"
#include "resources/db/colordb.h"
#include "resources/db/deaddb.h"
#include "resources/db/emotedb.h"
#include "resources/db/sounddb.h"
#include "resources/db/itemdb.h"
#include "resources/db/mapdb.h"
#include "resources/db/moddb.h"
#include "resources/db/monsterdb.h"
#include "resources/db/npcdb.h"
#include "resources/db/palettedb.h"
#include "resources/db/petdb.h"
#include "resources/db/weaponsdb.h"
#include "utils/base64.h"
#include "utils/cpu.h"
#include "utils/delete2.h"
#include "utils/files.h"
#include "utils/fuzzer.h"
#include "utils/gettext.h"
#include "utils/mkdir.h"
#include "utils/paths.h"
#include "utils/physfstools.h"
#include "utils/sdlcheckutils.h"
#include "utils/sdlhelper.h"
#include "utils/timer.h"
#include "utils/translation/translationmanager.h"
#include "test/testlauncher.h"
#include "test/testmain.h"
#ifdef __APPLE__
#include
#endif
#include
#ifdef WIN32
#include
#include "utils/specialfolder.h"
#endif
#ifdef ANDROID
#ifndef USE_SDL2
#include
#endif
#endif
#include
#include
#include
#include "mumblemanager.h"
#include "debug.h"
#if defined __native_client__
#define _nacl_dir std::string("/persistent/manaplus")
#endif
#ifdef ANDROID
#ifdef USE_SDL2
int loadingProgressCounter = 1;
#endif
#endif
std::string errorMessage;
LoginData loginData;
Client *client = nullptr;
ChatLogger *chatLogger = nullptr; // Chat log object
KeyboardConfig keyboard;
UserPalette *userPalette = nullptr;
SoundManager soundManager;
volatile bool runCounters;
bool isSafeMode = false;
int serverVersion = 0;
unsigned int tmwServerVersion = 0;
int start_time;
unsigned int mLastHost = 0;
unsigned long mSearchHash = 0;
int textures_count = 0;
#ifdef WIN32
extern "C" char const *_nl_locale_name_default(void);
#endif
namespace
{
class AccountListener final : public ActionListener
{
public:
void action(const ActionEvent &)
{
client->setState(STATE_CHAR_SELECT);
}
} accountListener;
class LoginListener final : public ActionListener
{
public:
void action(const ActionEvent &)
{
client->setState(STATE_PRE_LOGIN);
}
} loginListener;
} // namespace
Client::Client(const Options &options) :
ActionListener(),
mOptions(options),
mConfigDir(),
mServerConfigDir(),
mLocalDataDir(),
mTempDir(),
mUpdateHost(),
mUpdatesDir(),
mScreenshotDir(),
mUsersDir(),
mNpcsDir(),
mRootDir(),
mServerName(),
mOnlineListUrl(),
mLogFileName(),
mCurrentServer(),
mGame(nullptr),
mCurrentDialog(nullptr),
mQuitDialog(nullptr),
mDesktop(nullptr),
mSetupButton(nullptr),
mVideoButton(nullptr),
mHelpButton(nullptr),
mAboutButton(nullptr),
mThemesButton(nullptr),
mPerfomanceButton(nullptr),
#ifdef ANDROID
mCloseButton(nullptr),
#endif
mState(STATE_CHOOSE_SERVER),
mOldState(STATE_START),
mIcon(nullptr),
mCaption(),
mOldUpdates(),
mFpsManager(),
mSkin(nullptr),
mGuiAlpha(1.0F),
mButtonPadding(1),
mButtonSpacing(3),
mKeyboardHeight(0),
mLimitFps(false),
mConfigAutoSaved(false),
mIsMinimized(false),
mInputFocused(true),
mMouseFocused(true),
mNewMessageFlag(false)
{
// Initialize frame limiting
mFpsManager.framecount = 0;
mFpsManager.rateticks = 0;
mFpsManager.lastticks = 0;
mFpsManager.rate = 0;
}
void Client::testsInit()
{
if (!mOptions.test.empty() && mOptions.test != "99")
{
gameInit();
}
else
{
logger = new Logger;
initLocalDataDir();
initTempDir();
initConfigDir();
}
}
void Client::gameInit()
{
logger = new Logger;
// Load branding information
if (!mOptions.brandingPath.empty())
branding.init(mOptions.brandingPath);
branding.setDefaultValues(getBrandingDefaults());
initRootDir();
initHomeDir();
// Configure logger
if (!mOptions.logFileName.empty())
mLogFileName = mOptions.logFileName;
else
mLogFileName = mLocalDataDir + "/manaplus.log";
logger->setLogFile(mLogFileName);
#ifdef USE_FUZZER
Fuzzer::init();
#endif
backupConfig();
initConfiguration();
paths.setDefaultValues(getPathsDefaults());
initFeatures();
logger->log("init 4");
logger->setDebugLog(config.getBoolValue("debugLog"));
config.incValue("runcount");
#ifndef ANDROID
storeSafeParameters();
#endif
const ResourceManager *const resman = ResourceManager::getInstance();
if (!resman->setWriteDir(mLocalDataDir))
{
logger->error(strprintf("%s couldn't be set as home directory! "
"Exiting.", mLocalDataDir.c_str()));
}
initLang();
chatLogger = new ChatLogger;
if (mOptions.chatLogDir.empty())
chatLogger->setBaseLogDir(mLocalDataDir + std::string("/logs/"));
else
chatLogger->setBaseLogDir(mOptions.chatLogDir);
logger->setLogToStandardOut(config.getBoolValue("logToStandardOut"));
// Log the client version
logger->log1(FULL_VERSION);
logger->log("Start configPath: " + config.getConfigPath());
initScreenshotDir();
// Initialize SDL
logger->log1("Initializing SDL...");
if (SDL_Init(SDL_INIT_VIDEO | SDL_INIT_TIMER) < 0)
{
logger->safeError(strprintf("Could not initialize SDL: %s",
SDL_GetError()));
}
atexit(SDL_Quit);
initPacketLimiter();
#ifndef USE_SDL2
SDL_EnableUNICODE(1);
#endif
applyKeyRepeat();
// disable unused SDL events
#ifndef USE_SDL2
SDL_EventState(SDL_VIDEOEXPOSE, SDL_IGNORE);
#endif
SDL_EventState(SDL_SYSWMEVENT, SDL_IGNORE);
SDL_EventState(SDL_USEREVENT, SDL_IGNORE);
#ifdef WIN32
extractDataDir();
mountDataDir();
#endif
setIcon();
checkConfigVersion();
logVars();
Cpu::detect();
#if defined(USE_OPENGL)
#if !defined(ANDROID) && !defined(__APPLE__) && !defined(__native_client__)
if (!mOptions.safeMode && mOptions.test.empty()
&& !config.getBoolValue("videodetected"))
{
graphicsManager.detectVideoSettings();
}
#endif
#endif
updateEnv();
initGraphics();
#ifndef WIN32
extractDataDir();
mountDataDir();
#endif
updateDataPath();
// Add the main data directories to our PhysicsFS search path
if (!mOptions.dataPath.empty())
resman->addToSearchPath(mOptions.dataPath, false);
// Add the local data directory to PhysicsFS search path
resman->addToSearchPath(mLocalDataDir, false);
TranslationManager::loadCurrentLang();
initTitle();
theme = new Theme;
Theme::selectSkin();
touchManager.init();
// Initialize the item and emote shortcuts.
for (unsigned f = 0; f < SHORTCUT_TABS; f ++)
itemShortcut[f] = new ItemShortcut(f);
emoteShortcut = new EmoteShortcut;
dropShortcut = new DropShortcut;
gui = new Gui();
gui->postInit(mainGraphics);
initSoundManager();
eventsManager.init();
// Initialize keyboard
keyboard.init();
inputManager.init();
// Initialise player relations
player_relations.init();
Joystick::init();
createWindows();
keyboard.update();
if (joystick)
joystick->update();
// Initialize default server
mCurrentServer.hostname = mOptions.serverName;
mCurrentServer.port = mOptions.serverPort;
loginData.username = mOptions.username;
loginData.password = mOptions.password;
loginData.remember = serverConfig.getValue("remember", 1);
loginData.registerLogin = false;
if (mCurrentServer.hostname.empty())
{
mCurrentServer.hostname = branding.getValue("defaultServer", "");
mOptions.serverName = mCurrentServer.hostname;
}
if (mCurrentServer.port == 0)
{
mCurrentServer.port = static_cast(branding.getValue(
"defaultPort", static_cast(DEFAULT_PORT)));
mCurrentServer.type = ServerInfo::parseType(
branding.getValue("defaultServerType", "tmwathena"));
}
if (chatLogger)
chatLogger->setServerName(mCurrentServer.hostname);
if (loginData.username.empty() && loginData.remember)
loginData.username = serverConfig.getValue("username", "");
if (mState != STATE_ERROR)
mState = STATE_CHOOSE_SERVER;
startTimers();
const int fpsLimit = config.getIntValue("fpslimit");
mLimitFps = fpsLimit > 0;
SDL_initFramerate(&mFpsManager);
setFramerate(fpsLimit);
initConfigListeners();
setGuiAlpha(config.getFloatValue("guialpha"));
optionChanged("fpslimit");
start_time = static_cast(time(nullptr));
PlayerInfo::init();
#ifdef ANDROID
#ifndef USE_SDL2
updateScreenKeyboard(SDL_GetScreenKeyboardHeight(nullptr));
#endif
#endif
}
Client::~Client()
{
if (!mOptions.testMode)
gameClear();
else
testsClear();
CHECKLISTENERS
}
void Client::initConfigListeners()
{
config.addListener("fpslimit", this);
config.addListener("guialpha", this);
config.addListener("gamma", this);
config.addListener("enableGamma", this);
config.addListener("particleEmitterSkip", this);
config.addListener("vsync", this);
config.addListener("repeateDelay", this);
config.addListener("repeateInterval", this);
config.addListener("logInput", this);
}
void Client::initSoundManager()
{
// Initialize sound engine
try
{
if (config.getBoolValue("sound"))
soundManager.init();
soundManager.setSfxVolume(config.getIntValue("sfxVolume"));
soundManager.setMusicVolume(config.getIntValue("musicVolume"));
}
catch (const char *const err)
{
mState = STATE_ERROR;
errorMessage = err;
logger->log("Warning: %s", err);
}
soundManager.playMusic(branding.getValue(
"loginMusic", "Magick - Real.ogg"));
}
void Client::createWindows()
{
userPalette = new UserPalette;
setupWindow = new SetupWindow;
setupWindow->postInit();
helpWindow = new HelpWindow;
didYouKnowWindow = new DidYouKnowWindow;
didYouKnowWindow->postInit();
}
void Client::updateEnv()
{
#if defined(WIN32) || defined(__APPLE__)
if (config.getBoolValue("centerwindow"))
setEnv("SDL_VIDEO_CENTERED", "1");
else
setEnv("SDL_VIDEO_CENTERED", "0");
#endif
if (config.getBoolValue("allowscreensaver"))
setEnv("SDL_VIDEO_ALLOW_SCREENSAVER", "1");
else
setEnv("SDL_VIDEO_ALLOW_SCREENSAVER", "0");
}
void Client::updateDataPath()
{
if (mOptions.dataPath.empty()
&& !branding.getStringValue("dataPath").empty())
{
if (isRealPath(branding.getStringValue("dataPath")))
{
mOptions.dataPath = branding.getStringValue("dataPath");
}
else
{
mOptions.dataPath = branding.getDirectory().append(dirSeparator)
+ branding.getStringValue("dataPath");
}
mOptions.skipUpdate = true;
}
}
void Client::initGraphics()
{
graphicsManager.initGraphics(mOptions.noOpenGL);
runCounters = config.getBoolValue("packetcounters");
applyVSync();
graphicsManager.setVideoMode();
getConfigDefaults2(config.getDefaultValues());
applyGrabMode();
applyGamma();
mainGraphics->beginDraw();
}
void Client::initTitle()
{
if (mOptions.test.empty())
{
mCaption = strprintf("%s %s",
branding.getStringValue("appName").c_str(),
SMALL_VERSION);
}
else
{
mCaption = strprintf(
"Please wait - VIDEO MODE TEST - %s %s - Please wait",
branding.getStringValue("appName").c_str(),
SMALL_VERSION);
}
SDL::SetWindowTitle(mainGraphics->getWindow(), mCaption.c_str());
#ifndef WIN32
setIcon();
#endif
}
#ifdef ANDROID
#ifdef USE_SDL2
static void updateProgress(int cnt)
{
const int progress = cnt + loadingProgressCounter;
const int h = mainGraphics->mHeight;
mainGraphics->setColor(Color(255, 255, 255));
const int maxSize = mainGraphics->mWidth - 100;
const int width = maxSize * progress / 450;
mainGraphics->fillRectangle(Rect(50, h - 100, width, 50));
mainGraphics->updateScreen();
}
static void setProgress(const int val)
{
loadingProgressCounter = val;
updateProgress(loadingProgressCounter);
}
#endif
#endif
void Client::extractDataDir()
{
#ifdef ANDROID
#ifdef USE_SDL2
Files::setCopyCallBack(&updateProgress);
setProgress(0);
extractAssets();
const std::string zipName = std::string(getenv(
"APPDIR")).append("/data.zip");
const std::string dirName = std::string(getenv(
"APPDIR")).append("/data");
Files::extractZip(zipName, "data", dirName);
Files::extractLocale();
#endif
#endif
#if defined __native_client__
const std::string dirName = _nacl_dir.append("/data");
Files::extractZip("/http/data.zip", "data", dirName);
#endif
}
void Client::mountDataDir()
{
const ResourceManager *const resman = ResourceManager::getInstance();
resman->addToSearchPath(PKG_DATADIR "data/perserver/default", false);
resman->addToSearchPath("data/perserver/default", false);
#if defined __APPLE__
CFBundleRef mainBundle = CFBundleGetMainBundle();
CFURLRef resourcesURL = CFBundleCopyResourcesDirectoryURL(mainBundle);
char path[PATH_MAX];
if (!CFURLGetFileSystemRepresentation(resourcesURL, TRUE, (uint8_t*)path,
PATH_MAX))
{
fprintf(stderr, "Can't find Resources directory\n");
}
CFRelease(resourcesURL);
// possible crash
strncat(path, "/data", PATH_MAX - 1);
resman->addToSearchPath(path, false);
// possible this need for support run client from dmg images.
// mPackageDir = path;
#endif
resman->addToSearchPath(PKG_DATADIR "data", false);
setPackageDir(PKG_DATADIR "data");
resman->addToSearchPath("data", false);
#ifdef ANDROID
#ifdef USE_SDL2
if (getenv("APPDIR"))
{
const std::string appDir = getenv("APPDIR");
resman->addToSearchPath(appDir + "/data", false);
resman->addToSearchPath(appDir + "/data/perserver/default", false);
}
#endif
#endif
#if defined __native_client__
resman->addToSearchPath(_nacl_dir.append("/data"), false);
#endif
// Add branding/data to PhysFS search path
if (!mOptions.brandingPath.empty())
{
std::string path = mOptions.brandingPath;
// Strip blah.manaplus from the path
#ifdef WIN32
const int loc1 = path.find_last_of('/');
const int loc2 = path.find_last_of('\\');
const int loc = static_cast(std::max(loc1, loc2));
#else
const int loc = static_cast(path.find_last_of('/'));
#endif
if (loc > 0)
{
resman->addToSearchPath(path.substr(
0, loc + 1).append("data"), false);
}
}
}
void Client::initLang()
{
#ifdef ENABLE_NLS
std::string lang = config.getStringValue("lang");
#ifdef WIN32
if (lang.empty())
lang = std::string(_nl_locale_name_default());
putenv(const_cast(("LANG=" + lang).c_str()));
putenv(const_cast(("LANGUAGE=" + lang).c_str()));
// mingw doesn't like LOCALEDIR to be defined for some reason
if (lang != "C")
bindTextDomain("translations/");
#else // WIN32
if (!lang.empty())
{
setEnv("LANG", lang.c_str());
setEnv("LANGUAGE", lang.c_str());
}
#ifdef ANDROID
#ifdef USE_SDL2
bindTextDomain((std::string(getenv("APPDIR")).append("/locale")).c_str());
#else // USE_SDL2
bindTextDomain((std::string(PhysFs::getBaseDir()).append(
"/locale")).c_str());
#endif // USE_SDL2
#else // ANDROID
#ifdef ENABLE_PORTABLE
bindTextDomain((std::string(PhysFs::getBaseDir()).append(
"../locale/")).c_str());
#else // ENABLE_PORTABLE
#ifdef __APPLE__
bindTextDomain((std::string(PhysFs::getBaseDir())
.append("ManaPlus.app/Contents/Resources/locale/")).c_str());
#else // __APPLE__
bindTextDomain(LOCALEDIR);
#endif // __APPLE__
#endif // ENABLE_PORTABLE
#endif // ANDROID
#endif // WIN32
char *locale = setlocale(LC_MESSAGES, lang.c_str());
if (locale)
{
logger->log("locale: %s", locale);
}
else
{
locale = setlocale(LC_MESSAGES, (lang + ".utf8").c_str());
if (locale)
logger->log("locale: %s", locale);
else
logger->log("locale empty");
}
bind_textdomain_codeset("manaplus", "UTF-8");
textdomain("manaplus");
#endif // ENABLE_NLS
}
void Client::bindTextDomain(const char *const path)
{
#ifdef ENABLE_NLS
const char *const dir = bindtextdomain("manaplus", path);
if (dir)
logger->log("bindtextdomain: %s", dir);
else
logger->log("bindtextdomain failed");
#endif
}
void Client::setEnv(const char *const name, const char *const value)
{
if (!name || !value)
return;
#ifdef WIN32
if (putenv(const_cast((std::string(name)
+ "=" + value).c_str())))
#else
if (setenv(name, value, 1))
#endif
{
logger->log("setenv failed: %s=%s", name, value);
}
}
void Client::testsClear()
{
if (!mOptions.test.empty())
gameClear();
else
BeingInfo::clear();
}
void Client::gameClear()
{
if (logger)
logger->log1("Quitting1");
config.removeListeners(this);
eventsManager.shutdown();
delete2(setupWindow);
delete2(helpWindow);
delete2(didYouKnowWindow);
stopTimers();
// Unload XML databases
CharDB::unload();
DeadDB::unload();
ColorDB::unload();
SoundDB::unload();
EmoteDB::unload();
ItemDB::unload();
MonsterDB::unload();
NPCDB::unload();
AvatarDB::unload();
WeaponsDB::unload();
PaletteDB::unload();
PETDB::unload();
StatusEffect::unload();
ModDB::unload();
if (Net::getLoginHandler())
Net::getLoginHandler()->clearWorlds();
if (Net::getChatHandler())
Net::getChatHandler()->clear();
#ifdef USE_MUMBLE
delete2(mumbleManager);
#endif
PlayerInfo::deinit();
// Before config.write() since it writes the shortcuts to the config
for (unsigned f = 0; f < SHORTCUT_TABS; f ++)
delete2(itemShortcut[f])
delete2(emoteShortcut);
delete2(dropShortcut);
player_relations.store();
if (logger)
logger->log1("Quitting2");
delete2(mCurrentDialog);
delete2(gui);
if (Net::getInventoryHandler())
Net::getInventoryHandler()->clear();
if (logger)
logger->log1("Quitting3");
delete2(mainGraphics);
if (imageHelper != surfaceImageHelper)
delete surfaceImageHelper;
surfaceImageHelper = nullptr;
delete2(imageHelper);
if (logger)
logger->log1("Quitting4");
XML::cleanupXML();
if (logger)
logger->log1("Quitting5");
BeingInfo::clear();
// Shutdown sound
soundManager.close();
if (logger)
logger->log1("Quitting6");
ActorSprite::unload();
touchManager.clear();
ResourceManager::deleteInstance();
if (logger)
logger->log1("Quitting8");
MSDL_FreeSurface(mIcon);
if (logger)
logger->log1("Quitting9");
delete2(userPalette);
delete2(joystick);
keyboard.deinit();
if (logger)
logger->log1("Quitting10");
soundManager.shutdown();
touchManager.shutdown();
#ifdef DEBUG_CONFIG
config.enableKeyLogging();
#endif
config.removeOldKeys();
config.write();
serverConfig.write();
config.clear();
serverConfig.clear();
if (logger)
logger->log1("Quitting11");
#ifdef USE_PROFILER
Perfomance::clear();
#endif
#ifdef DEBUG_OPENGL_LEAKS
if (logger)
logger->log("textures left: %d", textures_count);
#endif
delete2(chatLogger);
TranslationManager::close();
}
int Client::testsExec() const
{
#ifdef USE_OPENGL
if (mOptions.test.empty())
{
TestMain test;
return test.exec();
}
else
{
TestLauncher launcher(mOptions.test);
return launcher.exec();
}
#else
return 0;
#endif
}
#define ADDBUTTON(var, object) var = object; \
x -= var->getWidth() + mButtonSpacing; \
var->setPosition(x, mButtonPadding); \
top->add(var);
int Client::gameExec()
{
int lastTickTime = tick_time;
#ifdef USE_MUMBLE
if (!mumbleManager)
mumbleManager = new MumbleManager();
#endif
mSkin = theme->load("windowmenu.xml", "");
if (mSkin)
{
mButtonPadding = mSkin->getPadding();
mButtonSpacing = mSkin->getOption("spacing", 3);
}
while (mState != STATE_EXIT)
{
PROFILER_START();
if (eventsManager.handleEvents())
continue;
BLOCK_START("Client::gameExec 3")
if (Net::getGeneralHandler())
Net::getGeneralHandler()->flushNetwork();
BLOCK_END("Client::gameExec 3")
BLOCK_START("Client::gameExec 4")
if (gui)
gui->logic();
cur_time = static_cast(time(nullptr));
int k = 0;
while (lastTickTime != tick_time && k < 40)
{
if (mGame)
mGame->logic();
else if (gui)
gui->handleInput();
++lastTickTime;
k ++;
}
soundManager.logic();
logic_count += k;
if (gui)
gui->slowLogic();
if (mGame)
mGame->slowLogic();
BLOCK_END("Client::gameExec 4")
// This is done because at some point tick_time will wrap.
lastTickTime = tick_time;
// Update the screen when application is visible, delay otherwise.
if (!mIsMinimized)
{
frame_count++;
if (gui)
gui->draw();
mainGraphics->updateScreen();
}
else
{
SDL_Delay(100);
}
BLOCK_START("~Client::SDL_framerateDelay")
if (mLimitFps)
SDL_framerateDelay(&mFpsManager);
BLOCK_END("~Client::SDL_framerateDelay")
BLOCK_START("Client::gameExec 6")
if (mState == STATE_CONNECT_GAME &&
Net::getGameHandler()->isConnected())
{
Net::getLoginHandler()->disconnect();
}
else if (mState == STATE_CONNECT_SERVER &&
mOldState == STATE_CHOOSE_SERVER)
{
mServerName = mCurrentServer.hostname;
initServerConfig(mCurrentServer.hostname);
initFeatures();
PlayerInfo::loadData();
loginData.registerUrl = mCurrentServer.registerUrl;
if (!mCurrentServer.onlineListUrl.empty())
mOnlineListUrl = mCurrentServer.onlineListUrl;
else
mOnlineListUrl = mServerName;
if (mOptions.username.empty())
{
if (loginData.remember)
loginData.username = serverConfig.getValue("username", "");
else
loginData.username.clear();
}
else
{
loginData.username = mOptions.username;
}
loginData.remember = serverConfig.getValue("remember", 1);
Net::connectToServer(mCurrentServer);
#ifdef USE_MUMBLE
if (mumbleManager)
mumbleManager->setServer(mCurrentServer.hostname);
#endif
GuildManager::init();
AuctionManager::init();
if (!mConfigAutoSaved)
{
mConfigAutoSaved = true;
config.write();
}
}
else if (mState == STATE_CONNECT_SERVER &&
mOldState != STATE_CHOOSE_SERVER &&
Net::getLoginHandler()->isConnected())
{
mState = STATE_PRE_LOGIN;
}
else if (mState == STATE_WORLD_SELECT && mOldState == STATE_UPDATE)
{
if (Net::getLoginHandler()->getWorlds().size() < 2)
mState = STATE_PRE_LOGIN;
}
else if (mOldState == STATE_START ||
(mOldState == STATE_GAME && mState != STATE_GAME))
{
if (!gui)
break;
BasicContainer2 *const top = static_cast(
gui->getTop());
if (!top)
break;
mDesktop = new Desktop(nullptr);
mDesktop->postInit();
top->add(mDesktop);
int x = top->getWidth() - mButtonPadding;
ADDBUTTON(mSetupButton, new Button(mDesktop,
// TRANSLATORS: setup tab quick button
_("Setup"), "Setup", this))
ADDBUTTON(mPerfomanceButton, new Button(mDesktop,
// TRANSLATORS: perfoamance tab quick button
_("Performance"), "Perfomance", this))
ADDBUTTON(mVideoButton, new Button(mDesktop,
// TRANSLATORS: video tab quick button
_("Video"), "Video", this))
ADDBUTTON(mThemesButton, new Button(mDesktop,
// TRANSLATORS: theme tab quick button
_("Theme"), "Themes", this))
ADDBUTTON(mAboutButton, new Button(mDesktop,
// TRANSLATORS: theme tab quick button
_("About"), "about", this))
ADDBUTTON(mHelpButton, new Button(mDesktop,
// TRANSLATORS: theme tab quick button
_("Help"), "help", this))
#ifdef ANDROID
ADDBUTTON(mCloseButton, new Button(mDesktop,
// TRANSLATORS: close quick button
_("Close"), "close", this))
#endif
mDesktop->setSize(mainGraphics->getWidth(),
mainGraphics->getHeight());
}
BLOCK_END("Client::gameExec 6")
if (mState == STATE_SWITCH_LOGIN && mOldState == STATE_GAME)
Net::getGameHandler()->disconnect();
if (mState != mOldState)
{
BLOCK_START("Client::gameExec 7")
PlayerInfo::stateChange(mState);
if (mOldState == STATE_GAME)
{
delete2(mGame);
Game::clearInstance();
ResourceManager *const resman = ResourceManager::getInstance();
if (resman)
resman->cleanOrphans();
Party::clearParties();
Guild::clearGuilds();
NpcDialog::clearDialogs();
Net::getGuildHandler()->clear();
Net::getPartyHandler()->clear();
if (chatLogger)
chatLogger->clear();
if (!mOptions.dataPath.empty())
UpdaterWindow::unloadMods(mOptions.dataPath);
else
UpdaterWindow::unloadMods(mOldUpdates);
if (!mOptions.skipUpdate)
UpdaterWindow::unloadMods(mOldUpdates + "/fix/");
}
mOldState = mState;
// Get rid of the dialog of the previous state
delete2(mCurrentDialog);
// State has changed, while the quitDialog was active, it might
// not be correct anymore
if (mQuitDialog)
{
mQuitDialog->scheduleDelete();
mQuitDialog = nullptr;
}
BLOCK_END("Client::gameExec 7")
BLOCK_START("Client::gameExec 8")
switch (mState)
{
case STATE_CHOOSE_SERVER:
{
BLOCK_START("Client::gameExec STATE_CHOOSE_SERVER")
logger->log1("State: CHOOSE SERVER");
mCurrentServer.supportUrl.clear();
ResourceManager *const resman
= ResourceManager::getInstance();
if (mOptions.dataPath.empty())
{
// Add customdata directory
resman->searchAndRemoveArchives(
"customdata/",
"zip");
}
if (!mOldUpdates.empty())
{
UpdaterWindow::unloadUpdates(mOldUpdates);
mOldUpdates.clear();
}
if (!mOptions.skipUpdate)
{
resman->searchAndRemoveArchives(
mUpdatesDir + "/local/",
"zip");
resman->removeFromSearchPath(mLocalDataDir
+ dirSeparator + mUpdatesDir + "/local/");
}
resman->clearCache();
loginData.clearUpdateHost();
serverVersion = 0;
// Allow changing this using a server choice dialog
// We show the dialog box only if the command-line
// options weren't set.
if (mOptions.serverName.empty() && mOptions.serverPort == 0
&& !branding.getValue("onlineServerList", "a").empty())
{
// Don't allow an alpha opacity
// lower than the default value
theme->setMinimumOpacity(0.8F);
mCurrentDialog = new ServerDialog(&mCurrentServer,
mConfigDir);
mCurrentDialog->postInit();
}
else
{
mState = STATE_CONNECT_SERVER;
// Reset options so that cancelling or connect
// timeout will show the server dialog.
mOptions.serverName.clear();
mOptions.serverPort = 0;
}
BLOCK_END("Client::gameExec STATE_CHOOSE_SERVER")
break;
}
case STATE_CONNECT_SERVER:
BLOCK_START("Client::gameExec STATE_CONNECT_SERVER")
logger->log1("State: CONNECT SERVER");
loginData.updateHosts.clear();
mCurrentDialog = new ConnectionDialog(
// TRANSLATORS: connection dialog header
_("Connecting to server"), STATE_SWITCH_SERVER);
mCurrentDialog->postInit();
TranslationManager::loadCurrentLang();
BLOCK_END("Client::gameExec STATE_CONNECT_SERVER")
break;
case STATE_PRE_LOGIN:
logger->log1("State: PRE_LOGIN");
// if (serverVersion < 5)
// setState(STATE_LOGIN);
break;
case STATE_LOGIN:
BLOCK_START("Client::gameExec STATE_LOGIN")
logger->log1("State: LOGIN");
// Don't allow an alpha opacity
// lower than the default value
theme->setMinimumOpacity(0.8F);
loginData.updateType
= serverConfig.getValue("updateType", 0);
mSearchHash = Net::Download::adlerBuffer(
const_cast(mCurrentServer.hostname.c_str()),
static_cast(mCurrentServer.hostname.size()));
if (mOptions.username.empty()
|| mOptions.password.empty())
{
mCurrentDialog = new LoginDialog(&loginData,
mCurrentServer.hostname, &mOptions.updateHost);
mCurrentDialog->postInit();
}
else
{
mState = STATE_LOGIN_ATTEMPT;
// Clear the password so that when login fails, the
// dialog will show up next time.
mOptions.password.clear();
}
BLOCK_END("Client::gameExec STATE_LOGIN")
break;
case STATE_LOGIN_ATTEMPT:
BLOCK_START("Client::gameExec STATE_LOGIN_ATTEMPT")
logger->log1("State: LOGIN ATTEMPT");
mCurrentDialog = new ConnectionDialog(
// TRANSLATORS: connection dialog header
_("Logging in"), STATE_SWITCH_SERVER);
mCurrentDialog->postInit();
Net::getLoginHandler()->loginOrRegister(&loginData);
BLOCK_END("Client::gameExec STATE_LOGIN_ATTEMPT")
break;
case STATE_WORLD_SELECT:
BLOCK_START("Client::gameExec STATE_WORLD_SELECT")
logger->log1("State: WORLD SELECT");
{
TranslationManager::loadCurrentLang();
Worlds worlds = Net::getLoginHandler()->getWorlds();
if (worlds.empty())
{
// Trust that the netcode knows what it's doing
mState = STATE_UPDATE;
}
else if (worlds.size() == 1)
{
Net::getLoginHandler()->chooseServer(
0, mCurrentServer.persistentIp);
mState = STATE_UPDATE;
}
else
{
mCurrentDialog = new WorldSelectDialog(worlds);
mCurrentDialog->postInit();
if (mOptions.chooseDefault)
{
static_cast(mCurrentDialog)
->action(ActionEvent(nullptr, "ok"));
}
}
}
BLOCK_END("Client::gameExec STATE_WORLD_SELECT")
break;
case STATE_WORLD_SELECT_ATTEMPT:
BLOCK_START("Client::gameExec STATE_WORLD_SELECT_ATTEMPT")
logger->log1("State: WORLD SELECT ATTEMPT");
mCurrentDialog = new ConnectionDialog(
// TRANSLATORS: connection dialog header
_("Entering game world"), STATE_WORLD_SELECT);
mCurrentDialog->postInit();
BLOCK_END("Client::gameExec STATE_WORLD_SELECT_ATTEMPT")
break;
case STATE_UPDATE:
BLOCK_START("Client::gameExec STATE_UPDATE")
logger->log1("State: UPDATE");
// Determine which source to use for the update host
if (!mOptions.updateHost.empty())
mUpdateHost = mOptions.updateHost;
else
mUpdateHost = loginData.updateHost;
initUpdatesDir();
if (!mOldUpdates.empty())
UpdaterWindow::unloadUpdates(mOldUpdates);
if (mOptions.skipUpdate)
{
mState = STATE_LOAD_DATA;
mOldUpdates = "";
UpdaterWindow::loadDirMods(mOptions.dataPath);
}
else if (loginData.updateType & UpdateType::Skip)
{
mOldUpdates = mLocalDataDir
+ dirSeparator + mUpdatesDir;
UpdaterWindow::loadLocalUpdates(mOldUpdates);
mState = STATE_LOAD_DATA;
}
else
{
mOldUpdates = mLocalDataDir
+ dirSeparator + mUpdatesDir;
mCurrentDialog = new UpdaterWindow(mUpdateHost,
mOldUpdates,
mOptions.dataPath.empty(),
loginData.updateType);
mCurrentDialog->postInit();
}
BLOCK_END("Client::gameExec STATE_UPDATE")
break;
case STATE_LOAD_DATA:
{
BLOCK_START("Client::gameExec STATE_LOAD_DATA")
logger->log1("State: LOAD DATA");
const ResourceManager *const resman
= ResourceManager::getInstance();
// If another data path has been set,
// we don't load any other files...
if (mOptions.dataPath.empty())
{
// Add customdata directory
resman->searchAndAddArchives(
"customdata/",
"zip",
false);
}
if (!mOptions.skipUpdate)
{
resman->searchAndAddArchives(
mUpdatesDir + "/local/",
"zip",
false);
resman->addToSearchPath(mLocalDataDir + dirSeparator
+ mUpdatesDir + "/local/", false);
}
logger->log("Init paths");
paths.init("paths.xml", true);
paths.setDefaultValues(getPathsDefaults());
if (!SpriteReference::Empty)
{
SpriteReference::Empty = new SpriteReference(
paths.getStringValue("spriteErrorFile"), 0);
}
if (!BeingInfo::unknown)
BeingInfo::unknown = new BeingInfo;
initFeatures();
TranslationManager::loadCurrentLang();
PlayerInfo::stateChange(mState);
// Load XML databases
CharDB::load();
DeadDB::load();
PaletteDB::load();
ColorDB::load();
SoundDB::load();
MapDB::load();
ItemDB::load();
Being::load();
MonsterDB::load();
AvatarDB::load();
WeaponsDB::load();
NPCDB::load();
PETDB::load();
EmoteDB::load();
// ModDB::load();
StatusEffect::load();
Units::loadUnits();
ActorSprite::load();
if (mDesktop)
mDesktop->reloadWallpaper();
mState = STATE_GET_CHARACTERS;
BLOCK_END("Client::gameExec STATE_LOAD_DATA")
break;
}
case STATE_GET_CHARACTERS:
BLOCK_START("Client::gameExec STATE_GET_CHARACTERS")
logger->log1("State: GET CHARACTERS");
mCurrentDialog = new ConnectionDialog(
// TRANSLATORS: connection dialog header
_("Requesting characters"),
STATE_SWITCH_SERVER);
mCurrentDialog->postInit();
Net::getCharServerHandler()->requestCharacters();
BLOCK_END("Client::gameExec STATE_GET_CHARACTERS")
break;
case STATE_CHAR_SELECT:
BLOCK_START("Client::gameExec STATE_CHAR_SELECT")
logger->log1("State: CHAR SELECT");
// Don't allow an alpha opacity
// lower than the default value
theme->setMinimumOpacity(0.8F);
mCurrentDialog = new CharSelectDialog(&loginData);
mCurrentDialog->postInit();
if (!(static_cast(mCurrentDialog))
->selectByName(mOptions.character,
CharSelectDialog::Choose))
{
(static_cast(mCurrentDialog))
->selectByName(
serverConfig.getValue("lastCharacter", ""),
mOptions.chooseDefault ?
CharSelectDialog::Choose :
CharSelectDialog::Focus);
}
// Choosing character on the command line should work only
// once, clear it so that 'switch character' works.
mOptions.character.clear();
BLOCK_END("Client::gameExec STATE_CHAR_SELECT")
break;
case STATE_CONNECT_GAME:
BLOCK_START("Client::gameExec STATE_CONNECT_GAME")
logger->log1("State: CONNECT GAME");
mCurrentDialog = new ConnectionDialog(
// TRANSLATORS: connection dialog header
_("Connecting to the game server"),
STATE_CHOOSE_SERVER);
mCurrentDialog->postInit();
Net::getGameHandler()->connect();
BLOCK_END("Client::gameExec STATE_CONNECT_GAME")
break;
case STATE_CHANGE_MAP:
BLOCK_START("Client::gameExec STATE_CHANGE_MAP")
logger->log1("State: CHANGE_MAP");
mCurrentDialog = new ConnectionDialog(
// TRANSLATORS: connection dialog header
_("Changing game servers"),
STATE_SWITCH_CHARACTER);
mCurrentDialog->postInit();
Net::getGameHandler()->connect();
BLOCK_END("Client::gameExec STATE_CHANGE_MAP")
break;
case STATE_GAME:
BLOCK_START("Client::gameExec STATE_GAME")
if (player_node)
{
logger->log("Memorizing selected character %s",
player_node->getName().c_str());
serverConfig.setValue("lastCharacter",
player_node->getName());
#ifdef USE_MUMBLE
if (mumbleManager)
mumbleManager->setPlayer(player_node->getName());
#endif
}
// Fade out logon-music here too to give the desired effect
// of "flowing" into the game.
soundManager.fadeOutMusic(1000);
// Allow any alpha opacity
theme->setMinimumOpacity(-1.0F);
if (chatLogger)
chatLogger->setServerName(mServerName);
#ifdef ANDROID
delete2(mCloseButton);
#endif
delete2(mSetupButton);
delete2(mVideoButton);
delete2(mThemesButton);
delete2(mAboutButton);
delete2(mHelpButton);
delete2(mPerfomanceButton);
delete2(mDesktop);
mCurrentDialog = nullptr;
logger->log1("State: GAME");
if (Net::getGeneralHandler())
Net::getGeneralHandler()->reloadPartially();
mGame = new Game;
BLOCK_END("Client::gameExec STATE_GAME")
break;
case STATE_LOGIN_ERROR:
BLOCK_START("Client::gameExec STATE_LOGIN_ERROR")
logger->log1("State: LOGIN ERROR");
// TRANSLATORS: error dialog header
mCurrentDialog = new OkDialog(_("Error"),
errorMessage, DialogType::ERROR);
mCurrentDialog->addActionListener(&loginListener);
mCurrentDialog = nullptr; // OkDialog deletes itself
BLOCK_END("Client::gameExec STATE_LOGIN_ERROR")
break;
case STATE_ACCOUNTCHANGE_ERROR:
BLOCK_START("Client::gameExec STATE_ACCOUNTCHANGE_ERROR")
logger->log1("State: ACCOUNT CHANGE ERROR");
// TRANSLATORS: error dialog header
mCurrentDialog = new OkDialog(_("Error"),
errorMessage, DialogType::ERROR);
mCurrentDialog->addActionListener(&accountListener);
mCurrentDialog = nullptr; // OkDialog deletes itself
BLOCK_END("Client::gameExec STATE_ACCOUNTCHANGE_ERROR")
break;
case STATE_REGISTER_PREP:
BLOCK_START("Client::gameExec STATE_REGISTER_PREP")
logger->log1("State: REGISTER_PREP");
mCurrentDialog = new ConnectionDialog(
// TRANSLATORS: connection dialog header
_("Requesting registration details"), STATE_LOGIN);
mCurrentDialog->postInit();
Net::getLoginHandler()->getRegistrationDetails();
BLOCK_END("Client::gameExec STATE_REGISTER_PREP")
break;
case STATE_REGISTER:
logger->log1("State: REGISTER");
mCurrentDialog = new RegisterDialog(&loginData);
mCurrentDialog->postInit();
break;
case STATE_REGISTER_ATTEMPT:
BLOCK_START("Client::gameExec STATE_REGISTER_ATTEMPT")
logger->log("Username is %s", loginData.username.c_str());
Net::getLoginHandler()->registerAccount(&loginData);
BLOCK_END("Client::gameExec STATE_REGISTER_ATTEMPT")
break;
case STATE_CHANGEPASSWORD:
BLOCK_START("Client::gameExec STATE_CHANGEPASSWORD")
logger->log1("State: CHANGE PASSWORD");
mCurrentDialog = new ChangePasswordDialog(&loginData);
mCurrentDialog->setVisible(true);
BLOCK_END("Client::gameExec STATE_CHANGEPASSWORD")
break;
case STATE_CHANGEPASSWORD_ATTEMPT:
BLOCK_START("Client::gameExec "
"STATE_CHANGEPASSWORD_ATTEMPT")
logger->log1("State: CHANGE PASSWORD ATTEMPT");
Net::getLoginHandler()->changePassword(loginData.username,
loginData.password, loginData.newPassword);
BLOCK_END("Client::gameExec STATE_CHANGEPASSWORD_ATTEMPT")
break;
case STATE_CHANGEPASSWORD_SUCCESS:
BLOCK_START("Client::gameExec "
"STATE_CHANGEPASSWORD_SUCCESS")
logger->log1("State: CHANGE PASSWORD SUCCESS");
// TRANSLATORS: password change message header
mCurrentDialog = new OkDialog(_("Password Change"),
// TRANSLATORS: password change message text
_("Password changed successfully!"),
DialogType::ERROR);
mCurrentDialog->addActionListener(&accountListener);
mCurrentDialog = nullptr; // OkDialog deletes itself
loginData.password = loginData.newPassword;
loginData.newPassword.clear();
BLOCK_END("Client::gameExec STATE_CHANGEPASSWORD_SUCCESS")
break;
case STATE_CHANGEEMAIL:
logger->log1("State: CHANGE EMAIL");
mCurrentDialog = new ChangeEmailDialog(&loginData);
mCurrentDialog->setVisible(true);
break;
case STATE_CHANGEEMAIL_ATTEMPT:
logger->log1("State: CHANGE EMAIL ATTEMPT");
Net::getLoginHandler()->changeEmail(loginData.email);
break;
case STATE_CHANGEEMAIL_SUCCESS:
logger->log1("State: CHANGE EMAIL SUCCESS");
// TRANSLATORS: email change message header
mCurrentDialog = new OkDialog(_("Email Change"),
// TRANSLATORS: email change message text
_("Email changed successfully!"), DialogType::ERROR);
mCurrentDialog->addActionListener(&accountListener);
mCurrentDialog = nullptr; // OkDialog deletes itself
break;
case STATE_UNREGISTER:
logger->log1("State: UNREGISTER");
mCurrentDialog = new UnRegisterDialog(&loginData);
mCurrentDialog->postInit();
break;
case STATE_UNREGISTER_ATTEMPT:
logger->log1("State: UNREGISTER ATTEMPT");
Net::getLoginHandler()->unregisterAccount(
loginData.username, loginData.password);
break;
case STATE_UNREGISTER_SUCCESS:
logger->log1("State: UNREGISTER SUCCESS");
Net::getLoginHandler()->disconnect();
mCurrentDialog = openErrorDialog(
// TRANSLATORS: unregister message header
_("Unregister Successful"),
// TRANSLATORS: unregister message text
_("Farewell, come back any time..."), true);
loginData.clear();
// The errorlistener sets the state to STATE_CHOOSE_SERVER
mCurrentDialog->addActionListener(&errorListener);
mCurrentDialog = nullptr; // OkDialog deletes itself
break;
case STATE_SWITCH_SERVER:
BLOCK_START("Client::gameExec STATE_SWITCH_SERVER")
logger->log1("State: SWITCH SERVER");
Net::getLoginHandler()->disconnect();
Net::getGameHandler()->disconnect();
Net::getGameHandler()->clear();
mServerName.clear();
serverConfig.write();
serverConfig.unload();
if (setupWindow)
setupWindow->externalUnload();
mState = STATE_CHOOSE_SERVER;
BLOCK_END("Client::gameExec STATE_SWITCH_SERVER")
break;
case STATE_SWITCH_LOGIN:
BLOCK_START("Client::gameExec STATE_SWITCH_LOGIN")
logger->log1("State: SWITCH LOGIN");
Net::getLoginHandler()->logout();
Net::getLoginHandler()->disconnect();
Net::getGameHandler()->disconnect();
Net::getLoginHandler()->connect();
mState = STATE_LOGIN;
BLOCK_END("Client::gameExec STATE_SWITCH_LOGIN")
break;
case STATE_SWITCH_CHARACTER:
BLOCK_START("Client::gameExec STATE_SWITCH_CHARACTER")
logger->log1("State: SWITCH CHARACTER");
// Done with game
Net::getGameHandler()->disconnect();
mState = STATE_GET_CHARACTERS;
BLOCK_END("Client::gameExec STATE_SWITCH_CHARACTER")
break;
case STATE_LOGOUT_ATTEMPT:
logger->log1("State: LOGOUT ATTEMPT");
break;
case STATE_WAIT:
logger->log1("State: WAIT");
break;
case STATE_EXIT:
BLOCK_START("Client::gameExec STATE_EXIT")
logger->log1("State: EXIT");
Net::unload();
BLOCK_END("Client::gameExec STATE_EXIT")
break;
case STATE_FORCE_QUIT:
BLOCK_START("Client::gameExec STATE_FORCE_QUIT")
logger->log1("State: FORCE QUIT");
if (Net::getGeneralHandler())
Net::getGeneralHandler()->unload();
mState = STATE_EXIT;
BLOCK_END("Client::gameExec STATE_FORCE_QUIT")
break;
case STATE_ERROR:
BLOCK_START("Client::gameExec STATE_ERROR")
config.write();
if (mOldState == STATE_GAME)
serverConfig.write();
logger->log1("State: ERROR");
logger->log("Error: %s\n", errorMessage.c_str());
// TRANSLATORS: error message header
mCurrentDialog = openErrorDialog(_("Error"),
errorMessage, true);
mCurrentDialog->addActionListener(&errorListener);
mCurrentDialog = nullptr; // OkDialog deletes itself
Net::getGameHandler()->disconnect();
BLOCK_END("Client::gameExec STATE_ERROR")
break;
case STATE_AUTORECONNECT_SERVER:
// ++++++
break;
case STATE_START:
default:
mState = STATE_FORCE_QUIT;
break;
}
BLOCK_END("Client::gameExec 8")
}
}
return 0;
}
void Client::optionChanged(const std::string &name)
{
if (name == "fpslimit")
{
const int fpsLimit = config.getIntValue("fpslimit");
mLimitFps = fpsLimit > 0;
setFramerate(fpsLimit);
}
else if (name == "guialpha")
{
const float alpha = config.getFloatValue("guialpha");
setGuiAlpha(alpha);
ImageHelper::setEnableAlpha(alpha != 1.0F);
}
else if (name == "gamma" || name == "enableGamma")
{
applyGamma();
}
else if (name == "particleEmitterSkip")
{
Particle::emitterSkip = config.getIntValue("particleEmitterSkip") + 1;
}
else if (name == "vsync")
{
applyVSync();
}
else if (name == "repeateInterval" || name == "repeateDelay")
{
applyKeyRepeat();
}
}
void Client::action(const ActionEvent &event)
{
std::string tab;
const std::string &eventId = event.getId();
if (eventId == "close")
{
setState(STATE_FORCE_QUIT);
return;
}
if (eventId == "Setup")
{
tab.clear();
}
else if (eventId == "help")
{
inputManager.executeAction(InputAction::WINDOW_HELP);
return;
}
else if (eventId == "about")
{
inputManager.executeAction(InputAction::WINDOW_ABOUT);
return;
}
else if (eventId == "Video")
{
tab = "Video";
}
else if (eventId == "Themes")
{
tab = "Theme";
}
else if (eventId == "Perfomance")
{
tab = "Perfomance";
}
else
{
return;
}
if (setupWindow)
{
setupWindow->setVisible(!setupWindow->isWindowVisible());
if (setupWindow->isWindowVisible())
{
if (!tab.empty())
setupWindow->activateTab(tab);
setupWindow->requestMoveToTop();
}
}
}
void Client::initRootDir()
{
mRootDir = PhysFs::getBaseDir();
const std::string portableName = mRootDir + "portable.xml";
struct stat statbuf;
if (!stat(portableName.c_str(), &statbuf) && S_ISREG(statbuf.st_mode))
{
std::string dir;
Configuration portable;
portable.init(portableName);
if (mOptions.brandingPath.empty())
{
branding.init(portableName);
branding.setDefaultValues(getBrandingDefaults());
}
logger->log("Portable file: %s", portableName.c_str());
if (mOptions.localDataDir.empty())
{
dir = portable.getValue("dataDir", "");
if (!dir.empty())
{
mOptions.localDataDir = mRootDir + dir;
logger->log("Portable data dir: %s",
mOptions.localDataDir.c_str());
}
}
if (mOptions.configDir.empty())
{
dir = portable.getValue("configDir", "");
if (!dir.empty())
{
mOptions.configDir = mRootDir + dir;
logger->log("Portable config dir: %s",
mOptions.configDir.c_str());
}
}
if (mOptions.screenshotDir.empty())
{
dir = portable.getValue("screenshotDir", "");
if (!dir.empty())
{
mOptions.screenshotDir = mRootDir + dir;
logger->log("Portable screenshot dir: %s",
mOptions.screenshotDir.c_str());
}
}
}
}
/**
* Initializes the home directory. On UNIX and FreeBSD, ~/.mana is used. On
* Windows and other systems we use the current working directory.
*/
void Client::initHomeDir()
{
initLocalDataDir();
initTempDir();
initConfigDir();
}
void Client::initLocalDataDir()
{
mLocalDataDir = mOptions.localDataDir;
if (mLocalDataDir.empty())
{
#ifdef __APPLE__
// Use Application Directory instead of .mana
mLocalDataDir = std::string(PhysFs::getUserDir()) +
"/Library/Application Support/" +
branding.getValue("appName", "ManaPlus");
#elif defined __HAIKU__
mLocalDataDir = std::string(PhysFs::getUserDir()) +
"/config/data/Mana";
#elif defined WIN32
mLocalDataDir = getSpecialFolderLocation(CSIDL_LOCAL_APPDATA);
if (mLocalDataDir.empty())
mLocalDataDir = std::string(PhysFs::getUserDir());
mLocalDataDir.append("/Mana");
#elif defined __ANDROID__
mLocalDataDir = getSdStoragePath() + branding.getValue(
"appShort", "ManaPlus") + "/local";
#elif defined __native_client__
mLocalDataDir = _nacl_dir.append("/local");
#else
mLocalDataDir = std::string(PhysFs::getUserDir()) +
".local/share/mana";
#endif
}
if (mkdir_r(mLocalDataDir.c_str()))
{
// TRANSLATORS: directory creation error
logger->error(strprintf(_("%s doesn't exist and can't be created! "
"Exiting."), mLocalDataDir.c_str()));
}
#ifdef USE_PROFILER
Perfomance::init(mLocalDataDir + "/profiler.log");
#endif
}
void Client::initTempDir()
{
mTempDir = mLocalDataDir + dirSeparator + "temp";
if (mkdir_r(mTempDir.c_str()))
{
// TRANSLATORS: directory creation error
logger->error(strprintf(_("%s doesn't exist and can't be created! "
"Exiting."), mTempDir.c_str()));
}
// ResourceManager::deleteFilesInDirectory(mTempDir);
}
void Client::initConfigDir()
{
mConfigDir = mOptions.configDir;
if (mConfigDir.empty())
{
#ifdef __APPLE__
mConfigDir = mLocalDataDir + dirSeparator
+ branding.getValue("appShort", "mana");
#elif defined __HAIKU__
mConfigDir = std::string(PhysFs::getUserDir()) +
"/config/settings/Mana" +
branding.getValue("appName", "ManaPlus");
#elif defined WIN32
mConfigDir = getSpecialFolderLocation(CSIDL_APPDATA);
if (mConfigDir.empty())
{
mConfigDir = mLocalDataDir;
}
else
{
mConfigDir.append("/mana/").append(branding.getValue(
"appShort", "mana"));
}
#elif defined __ANDROID__
mConfigDir = getSdStoragePath() + branding.getValue(
"appShort", "ManaPlus").append("/config");
#elif defined __native_client__
mConfigDir = _nacl_dir.append("/config");
#else
mConfigDir = std::string(PhysFs::getUserDir()).append(
"/.config/mana/").append(branding.getValue("appShort", "mana"));
#endif
logger->log("Generating config dir: " + mConfigDir);
}
if (mkdir_r(mConfigDir.c_str()))
{
// TRANSLATORS: directory creation error
logger->error(strprintf(_("%s doesn't exist and can't be created! "
"Exiting."), mConfigDir.c_str()));
}
}
/**
* Initializes the home directory. On UNIX and FreeBSD, ~/.mana is used. On
* Windows and other systems we use the current working directory.
*/
void Client::initServerConfig(const std::string &serverName)
{
mServerConfigDir = mConfigDir + dirSeparator + serverName;
if (mkdir_r(mServerConfigDir.c_str()))
{
// TRANSLATORS: directory creation error
logger->error(strprintf(_("%s doesn't exist and can't be created! "
"Exiting."), mServerConfigDir.c_str()));
}
const std::string configPath = mServerConfigDir + "/config.xml";
FILE *configFile = fopen(configPath.c_str(), "r");
if (!configFile)
{
configFile = fopen(configPath.c_str(), "wt");
logger->log("Creating new server config: " + configPath);
}
if (configFile)
{
fclose(configFile);
serverConfig.init(configPath);
serverConfig.setDefaultValues(getConfigDefaults());
logger->log("serverConfigPath: " + configPath);
}
initPacketLimiter();
initTradeFilter();
initUsersDir();
player_relations.init();
// Initialize the item and emote shortcuts.
for (unsigned f = 0; f < SHORTCUT_TABS; f ++)
{
delete itemShortcut[f];
itemShortcut[f] = new ItemShortcut(f);
}
delete emoteShortcut;
emoteShortcut = new EmoteShortcut;
// Initialize the drop shortcuts.
delete dropShortcut;
dropShortcut = new DropShortcut;
}
void Client::initFeatures()
{
features.init(paths.getStringValue("featuresFile"), true);
features.setDefaultValues(getFeaturesDefaults());
}
void Client::initConfiguration() const
{
#ifdef DEBUG_CONFIG
config.setIsMain(true);
#endif
// Fill configuration with defaults
config.setValue("hwaccel", false);
#ifdef USE_OPENGL
#if (defined __APPLE__)
config.setValue("opengl", static_cast(RENDER_NORMAL_OPENGL));
#elif (defined ANDROID)
config.setValue("opengl", static_cast(RENDER_GLES_OPENGL));
#elif (defined WIN32)
config.setValue("opengl", static_cast(RENDER_SAFE_OPENGL));
#else
config.setValue("opengl", static_cast(RENDER_SOFTWARE));
#endif
#else
config.setValue("opengl", static_cast(RENDER_SOFTWARE));
#endif
config.setValue("screen", false);
config.setValue("sound", true);
config.setValue("guialpha", 0.8F);
// config.setValue("remember", true);
config.setValue("sfxVolume", 100);
config.setValue("musicVolume", 60);
config.setValue("fpslimit", 60);
std::string defaultUpdateHost = branding.getValue("defaultUpdateHost", "");
if (!checkPath(defaultUpdateHost))
defaultUpdateHost.clear();
config.setValue("updatehost", defaultUpdateHost);
config.setValue("useScreenshotDirectorySuffix", true);
config.setValue("ChatLogLength", 128);
std::string configPath;
if (mOptions.test.empty())
configPath = mConfigDir + "/config.xml";
else
configPath = mConfigDir + "/test.xml";
FILE *configFile = fopen(configPath.c_str(), "r");
if (!configFile)
{
configFile = fopen(configPath.c_str(), "wt");
logger->log1("Creating new config");
}
if (!configFile)
{
logger->log("Can't create %s. Using defaults.", configPath.c_str());
}
else
{
fclose(configFile);
config.init(configPath);
logger->log1("init 3");
config.setDefaultValues(getConfigDefaults());
logger->log("configPath: " + configPath);
}
}
void Client::backupConfig() const
{
const std::string confName = mConfigDir + "/config.xml.bak";
const int maxFileIndex = 5;
::remove((confName + toString(maxFileIndex)).c_str());
for (int f = maxFileIndex; f > 1; f --)
{
const std::string fileName1 = confName + toString(f - 1);
const std::string fileName2 = confName + toString(f);
Files::renameFile(fileName1, fileName2);
}
const std::string fileName3 = mConfigDir + "/config.xml";
const std::string fileName4 = confName + toString(1);
Files::copyFile(fileName3, fileName4);
}
/**
* Parse the update host and determine the updates directory
* Then verify that the directory exists (creating if needed).
*/
void Client::initUpdatesDir()
{
std::stringstream updates;
// If updatesHost is currently empty, fill it from config file
if (mUpdateHost.empty())
mUpdateHost = config.getStringValue("updatehost");
if (!checkPath(mUpdateHost))
return;
// Don't go out of range int he next check
if (mUpdateHost.length() < 2)
return;
const size_t sz = mUpdateHost.size();
// Remove any trailing slash at the end of the update host
if (mUpdateHost.at(sz - 1) == '/')
mUpdateHost.resize(sz - 1);
// Parse out any "http://" or "https://", and set the updates directory
const size_t pos = mUpdateHost.find("://");
if (pos != mUpdateHost.npos)
{
if (pos + 3 < mUpdateHost.length() && !mUpdateHost.empty())
{
updates << "updates/" << mUpdateHost.substr(pos + 3);
mUpdatesDir = updates.str();
}
else
{
logger->log("Error: Invalid update host: %s", mUpdateHost.c_str());
// TRANSLATORS: update server initialisation error
errorMessage = strprintf(_("Invalid update host: %s."),
mUpdateHost.c_str());
mState = STATE_ERROR;
}
}
else
{
logger->log1("Warning: no protocol was specified for the update host");
updates << "updates/" << mUpdateHost;
mUpdatesDir = updates.str();
}
#ifdef WIN32
if (mUpdatesDir.find(":") != std::string::npos)
replaceAll(mUpdatesDir, ":", "_");
#endif
const ResourceManager *const resman = ResourceManager::getInstance();
const std::string updateDir("/" + mUpdatesDir);
// Verify that the updates directory exists. Create if necessary.
if (!resman->isDirectory(updateDir))
{
if (!resman->mkdir(updateDir))
{
#if defined WIN32
std::string newDir = mLocalDataDir + "\\" + mUpdatesDir;
size_t loc = newDir.find("/", 0);
while (loc != std::string::npos)
{
newDir.replace(loc, 1, "\\");
loc = newDir.find("/", loc);
}
if (!CreateDirectory(newDir.c_str(), nullptr) &&
GetLastError() != ERROR_ALREADY_EXISTS)
{
logger->log("Error: %s can't be made, but doesn't exist!",
newDir.c_str());
// TRANSLATORS: update server initialisation error
errorMessage = _("Error creating updates directory!");
mState = STATE_ERROR;
}
#else
logger->log("Error: %s/%s can't be made, but doesn't exist!",
mLocalDataDir.c_str(), mUpdatesDir.c_str());
// TRANSLATORS: update server initialisation error
errorMessage = _("Error creating updates directory!");
mState = STATE_ERROR;
#endif
}
}
const std::string updateLocal = updateDir + "/local";
const std::string updateFix = updateDir + "/fix";
if (!resman->isDirectory(updateLocal))
resman->mkdir(updateLocal);
if (!resman->isDirectory(updateFix))
resman->mkdir(updateFix);
}
void Client::initScreenshotDir()
{
if (!mOptions.screenshotDir.empty())
{
mScreenshotDir = mOptions.screenshotDir;
if (mkdir_r(mScreenshotDir.c_str()))
{
// TRANSLATORS: directory creation error
logger->log(strprintf(
_("Error: %s doesn't exist and can't be created! "
"Exiting."), mScreenshotDir.c_str()));
}
}
else if (mScreenshotDir.empty())
{
mScreenshotDir = decodeBase64String(
config.getStringValue("screenshotDirectory3"));
if (mScreenshotDir.empty())
{
#ifdef __ANDROID__
mScreenshotDir = getSdStoragePath() + std::string("/images");
if (mkdir_r(mScreenshotDir.c_str()))
{
// TRANSLATORS: directory creation error
logger->log(strprintf(
_("Error: %s doesn't exist and can't be created! "
"Exiting."), mScreenshotDir.c_str()));
}
#else
mScreenshotDir = getPicturesDir();
#endif
if (config.getBoolValue("useScreenshotDirectorySuffix"))
{
const std::string configScreenshotSuffix =
branding.getValue("screenshots", "ManaPlus");
if (!configScreenshotSuffix.empty())
{
mScreenshotDir.append(dirSeparator).append(
configScreenshotSuffix);
}
}
config.setValue("screenshotDirectory3",
encodeBase64String(mScreenshotDir));
}
}
logger->log("screenshotDirectory: " + mScreenshotDir);
}
#ifndef ANDROID
void Client::storeSafeParameters() const
{
bool tmpHwaccel;
RenderType tmpOpengl;
int tmpFpslimit;
int tmpAltFpslimit;
bool tmpSound;
int width;
int height;
std::string font;
std::string bFont;
std::string particleFont;
std::string helpFont;
std::string secureFont;
std::string npcFont;
std::string japanFont;
std::string chinaFont;
bool showBackground;
bool enableMumble;
bool enableMapReduce;
isSafeMode = config.getBoolValue("safemode");
if (isSafeMode)
logger->log1("Run in safe mode");
tmpOpengl = intToRenderType(config.getIntValue("opengl"));
width = config.getIntValue("screenwidth");
height = config.getIntValue("screenheight");
tmpHwaccel = config.getBoolValue("hwaccel");
tmpFpslimit = config.getIntValue("fpslimit");
tmpAltFpslimit = config.getIntValue("altfpslimit");
tmpSound = config.getBoolValue("sound");
font = config.getStringValue("font");
bFont = config.getStringValue("boldFont");
particleFont = config.getStringValue("particleFont");
helpFont = config.getStringValue("helpFont");
secureFont = config.getStringValue("secureFont");
npcFont = config.getStringValue("npcFont");
japanFont = config.getStringValue("japanFont");
chinaFont = config.getStringValue("chinaFont");
showBackground = config.getBoolValue("showBackground");
enableMumble = config.getBoolValue("enableMumble");
enableMapReduce = config.getBoolValue("enableMapReduce");
if (!mOptions.safeMode && !tmpOpengl)
{
// if video mode configured reset most settings to safe
config.setValue("hwaccel", false);
config.setValue("altfpslimit", 3);
config.setValue("sound", false);
config.setValue("safemode", true);
config.setValue("screenwidth", 640);
config.setValue("screenheight", 480);
config.setValue("font", "fonts/dejavusans.ttf");
config.setValue("boldFont", "fonts/dejavusans-bold.ttf");
config.setValue("particleFont", "fonts/dejavusans.ttf");
config.setValue("helpFont", "fonts/dejavusansmono.ttf");
config.setValue("secureFont", "fonts/dejavusansmono.ttf");
config.setValue("npcFont", "fonts/dejavusans.ttf");
config.setValue("japanFont", "fonts/mplus-1p-regular.ttf");
config.setValue("chinaFont", "fonts/wqy-microhei.ttf");
config.setValue("showBackground", false);
config.setValue("enableMumble", false);
config.setValue("enableMapReduce", false);
}
else
{
// if video mode not configured reset only video mode to safe
config.setValue("screenwidth", 640);
config.setValue("screenheight", 480);
}
#if defined(__APPLE__)
config.setValue("opengl", static_cast(RENDER_NORMAL_OPENGL));
#else
config.setValue("opengl", static_cast(RENDER_SOFTWARE));
#endif
config.write();
if (mOptions.safeMode)
{
isSafeMode = true;
return;
}
config.setValue("safemode", false);
if (!tmpOpengl)
{
config.setValue("hwaccel", tmpHwaccel);
config.setValue("opengl", static_cast(tmpOpengl));
config.setValue("fpslimit", tmpFpslimit);
config.setValue("altfpslimit", tmpAltFpslimit);
config.setValue("sound", tmpSound);
config.setValue("screenwidth", width);
config.setValue("screenheight", height);
config.setValue("font", font);
config.setValue("boldFont", bFont);
config.setValue("particleFont", particleFont);
config.setValue("helpFont", helpFont);
config.setValue("secureFont", secureFont);
config.setValue("npcFont", npcFont);
config.setValue("japanFont", japanFont);
config.setValue("chinaFont", chinaFont);
config.setValue("showBackground", showBackground);
config.setValue("enableMumble", enableMumble);
config.setValue("enableMapReduce", enableMapReduce);
}
else
{
config.setValue("opengl", static_cast(tmpOpengl));
config.setValue("screenwidth", width);
config.setValue("screenheight", height);
}
}
#endif
void Client::initTradeFilter() const
{
const std::string tradeListName =
getServerConfigDirectory() + "/tradefilter.txt";
std::ofstream tradeFile;
struct stat statbuf;
if (stat(tradeListName.c_str(), &statbuf) || !S_ISREG(statbuf.st_mode))
{
tradeFile.open(tradeListName.c_str(), std::ios::out);
if (tradeFile.is_open())
{
tradeFile << ": sell" << std::endl;
tradeFile << ": buy" << std::endl;
tradeFile << ": trade" << std::endl;
tradeFile << "i sell" << std::endl;
tradeFile << "i buy" << std::endl;
tradeFile << "i trade" << std::endl;
tradeFile << "i trading" << std::endl;
tradeFile << "i am buy" << std::endl;
tradeFile << "i am sell" << std::endl;
tradeFile << "i am trade" << std::endl;
tradeFile << "i am trading" << std::endl;
tradeFile << "i'm buy" << std::endl;
tradeFile << "i'm sell" << std::endl;
tradeFile << "i'm trade" << std::endl;
tradeFile << "i'm trading" << std::endl;
}
tradeFile.close();
}
}
void Client::initUsersDir()
{
mUsersDir = getServerConfigDirectory() + "/users/";
if (mkdir_r(mUsersDir.c_str()))
{
// TRANSLATORS: directory creation error
logger->error(strprintf(_("%s doesn't exist and can't be created! "
"Exiting."), mUsersDir.c_str()));
}
mNpcsDir = getServerConfigDirectory() + "/npcs/";
if (mkdir_r(mNpcsDir.c_str()))
{
// TRANSLATORS: directory creation error
logger->error(strprintf(_("%s doesn't exist and can't be created! "
"Exiting."), mNpcsDir.c_str()));
}
}
void Client::initPacketLimiter()
{
// here i setting packet limits. but current server is broken,
// and this limits may not help.
mPacketLimits[PACKET_CHAT].timeLimit = 10 + 5;
mPacketLimits[PACKET_CHAT].lastTime = 0;
mPacketLimits[PACKET_CHAT].cntLimit = 1;
mPacketLimits[PACKET_CHAT].cnt = 0;
// 10
mPacketLimits[PACKET_PICKUP].timeLimit = 10 + 5;
mPacketLimits[PACKET_PICKUP].lastTime = 0;
mPacketLimits[PACKET_PICKUP].cntLimit = 1;
mPacketLimits[PACKET_PICKUP].cnt = 0;
// 10 5
mPacketLimits[PACKET_DROP].timeLimit = 5;
mPacketLimits[PACKET_DROP].lastTime = 0;
mPacketLimits[PACKET_DROP].cntLimit = 1;
mPacketLimits[PACKET_DROP].cnt = 0;
// 100
mPacketLimits[PACKET_NPC_NEXT].timeLimit = 0;
mPacketLimits[PACKET_NPC_NEXT].lastTime = 0;
mPacketLimits[PACKET_NPC_NEXT].cntLimit = 1;
mPacketLimits[PACKET_NPC_NEXT].cnt = 0;
mPacketLimits[PACKET_NPC_INPUT].timeLimit = 100;
mPacketLimits[PACKET_NPC_INPUT].lastTime = 0;
mPacketLimits[PACKET_NPC_INPUT].cntLimit = 1;
mPacketLimits[PACKET_NPC_INPUT].cnt = 0;
// 50
mPacketLimits[PACKET_NPC_TALK].timeLimit = 60;
mPacketLimits[PACKET_NPC_TALK].lastTime = 0;
mPacketLimits[PACKET_NPC_TALK].cntLimit = 1;
mPacketLimits[PACKET_NPC_TALK].cnt = 0;
// 10
mPacketLimits[PACKET_EMOTE].timeLimit = 10 + 5;
mPacketLimits[PACKET_EMOTE].lastTime = 0;
mPacketLimits[PACKET_EMOTE].cntLimit = 1;
mPacketLimits[PACKET_EMOTE].cnt = 0;
// 100
mPacketLimits[PACKET_SIT].timeLimit = 100;
mPacketLimits[PACKET_SIT].lastTime = 0;
mPacketLimits[PACKET_SIT].cntLimit = 1;
mPacketLimits[PACKET_SIT].cnt = 0;
mPacketLimits[PACKET_DIRECTION].timeLimit = 50;
mPacketLimits[PACKET_DIRECTION].lastTime = 0;
mPacketLimits[PACKET_DIRECTION].cntLimit = 1;
mPacketLimits[PACKET_DIRECTION].cnt = 0;
// 2+
mPacketLimits[PACKET_ATTACK].timeLimit = 2 + 10;
mPacketLimits[PACKET_ATTACK].lastTime = 0;
mPacketLimits[PACKET_ATTACK].cntLimit = 1;
mPacketLimits[PACKET_ATTACK].cnt = 0;
mPacketLimits[PACKET_STOPATTACK].timeLimit = 2 + 10;
mPacketLimits[PACKET_STOPATTACK].lastTime = 0;
mPacketLimits[PACKET_STOPATTACK].cntLimit = 1;
mPacketLimits[PACKET_STOPATTACK].cnt = 0;
mPacketLimits[PACKET_ONLINELIST].timeLimit = 1800;
mPacketLimits[PACKET_ONLINELIST].lastTime = 0;
mPacketLimits[PACKET_ONLINELIST].cntLimit = 1;
mPacketLimits[PACKET_ONLINELIST].cnt = 0;
// 300ms + 50 fix
mPacketLimits[PACKET_WHISPER].timeLimit = 30 + 5;
mPacketLimits[PACKET_WHISPER].lastTime = 0;
mPacketLimits[PACKET_WHISPER].cntLimit = 1;
mPacketLimits[PACKET_WHISPER].cnt = 0;
if (!mServerConfigDir.empty())
{
const std::string packetLimitsName = getServerConfigDirectory()
+ "/packetlimiter.txt";
std::ifstream inPacketFile;
struct stat statbuf;
if (stat(packetLimitsName.c_str(), &statbuf)
|| !S_ISREG(statbuf.st_mode))
{
// wtiting new file
writePacketLimits(packetLimitsName);
}
else
{ // reading existent file
inPacketFile.open(packetLimitsName.c_str(), std::ios::in);
char line[101];
if (!inPacketFile.is_open() || !inPacketFile.getline(line, 100))
{
inPacketFile.close();
return;
}
const int ver = atoi(line);
for (int f = 0; f < PACKET_SIZE; f ++)
{
if (!inPacketFile.getline(line, 100))
break;
if (!(ver == 1 && (f == PACKET_DROP || f == PACKET_NPC_NEXT)))
mPacketLimits[f].timeLimit = atoi(line);
}
inPacketFile.close();
if (ver < 5)
writePacketLimits(packetLimitsName);
}
}
}
void Client::writePacketLimits(const std::string &packetLimitsName) const
{
std::ofstream outPacketFile;
outPacketFile.open(packetLimitsName.c_str(), std::ios::out);
if (!outPacketFile.is_open())
{
outPacketFile.close();
return;
}
outPacketFile << "4" << std::endl;
for (int f = 0; f < PACKET_SIZE; f ++)
{
outPacketFile << toString(mPacketLimits[f].timeLimit)
<< std::endl;
}
outPacketFile.close();
}
bool Client::checkPackets(const int type) const
{
if (type > PACKET_SIZE)
return false;
if (!serverConfig.getValueBool("enableBuggyServers", true))
return true;
const PacketLimit &limit = mPacketLimits[type];
const int timeLimit = limit.timeLimit;
if (!timeLimit)
return true;
const int time = tick_time;
const int lastTime = limit.lastTime;
const int cnt = limit.cnt;
const int cntLimit = limit.cntLimit;
if (lastTime > tick_time)
{
// instance()->mPacketLimits[type].lastTime = time;
// instance()->mPacketLimits[type].cnt = 0;
return true;
}
else if (lastTime + timeLimit > time)
{
if (cnt >= cntLimit)
{
return false;
}
else
{
// instance()->mPacketLimits[type].cnt ++;
return true;
}
}
// instance()->mPacketLimits[type].lastTime = time;
// instance()->mPacketLimits[type].cnt = 1;
return true;
}
bool Client::limitPackets(const int type)
{
if (type < 0 || type > PACKET_SIZE)
return false;
if (!serverConfig.getValueBool("enableBuggyServers", true))
return true;
PacketLimit &pack = mPacketLimits[type];
const int timeLimit = pack.timeLimit;
if (!timeLimit)
return true;
const int time = tick_time;
const int lastTime = pack.lastTime;
const int cnt = pack.cnt;
const int cntLimit = pack.cntLimit;
if (lastTime > tick_time)
{
pack.lastTime = time;
pack.cnt = 0;
return true;
}
else if (lastTime + timeLimit > time)
{
if (cnt >= cntLimit)
{
return false;
}
else
{
pack.cnt ++;
return true;
}
}
pack.lastTime = time;
pack.cnt = 1;
return true;
}
void Client::setFramerate(const int fpsLimit) const
{
if (!fpsLimit)
return;
if (!mLimitFps)
return;
SDL_setFramerate(&client->mFpsManager, fpsLimit);
}
int Client::getFramerate() const
{
if (!mLimitFps)
return 0;
return SDL_getFramerate(&client->mFpsManager);
}
void Client::closeDialogs()
{
NpcDialog::clearDialogs();
BuyDialog::closeAll();
BuySellDialog::closeAll();
NpcDialog::closeAll();
SellDialog::closeAll();
if (Net::getInventoryHandler())
Net::getInventoryHandler()->closeStorage();
}
bool Client::isTmw() const
{
const std::string &name = getServerName();
if (name == "server.themanaworld.org"
|| name == "themanaworld.org"
|| name == "192.31.187.185")
{
return true;
}
return false;
}
void Client::resizeVideo(int actualWidth,
int actualHeight,
const bool always)
{
// Keep a minimum size. This isn't adhered to by the actual window, but
// it keeps some window positions from getting messed up.
actualWidth = std::max(470, actualWidth);
actualHeight = std::max(320, actualHeight);
if (!mainGraphics)
return;
if (!always
&& mainGraphics->mActualWidth == actualWidth
&& mainGraphics->mActualHeight == actualHeight)
{
return;
}
if (mainGraphics->resizeScreen(actualWidth, actualHeight))
{
const int width = mainGraphics->mWidth;
const int height = mainGraphics->mHeight;
touchManager.resize(width, height);
if (gui)
gui->videoResized();
if (mDesktop)
mDesktop->setSize(width, height);
if (mSetupButton)
{
int x = width - mSetupButton->getWidth() - mButtonPadding;
mSetupButton->setPosition(x, mButtonPadding);
#ifndef WIN32
x -= mPerfomanceButton->getWidth() + mButtonSpacing;
mPerfomanceButton->setPosition(x, mButtonPadding);
x -= mVideoButton->getWidth() + mButtonSpacing;
mVideoButton->setPosition(x, mButtonPadding);
x -= mThemesButton->getWidth() + mButtonSpacing;
mThemesButton->setPosition(x, mButtonPadding);
x -= mAboutButton->getWidth() + mButtonSpacing;
mAboutButton->setPosition(x, mButtonPadding);
x -= mHelpButton->getWidth() + mButtonSpacing;
mHelpButton->setPosition(x, mButtonPadding);
#ifdef ANDROID
x -= mCloseButton->getWidth() + mButtonSpacing;
mCloseButton->setPosition(x, mButtonPadding);
#endif
#endif
}
if (mGame)
mGame->videoResized(width, height);
if (gui)
gui->draw();
config.setValue("screenwidth", actualWidth);
config.setValue("screenheight", actualHeight);
}
}
void Client::applyGrabMode()
{
SDL::grabInput(mainGraphics->getWindow(),
config.getBoolValue("grabinput"));
}
void Client::applyGamma()
{
if (config.getFloatValue("enableGamma"))
{
SDL::setGamma(mainGraphics->getWindow(),
config.getFloatValue("gamma"));
}
}
void Client::applyVSync()
{
const int val = config.getIntValue("vsync");
if (val > 0 && val < 2)
SDL::setVsync(val);
}
void Client::applyKeyRepeat()
{
#ifndef USE_SDL2
SDL_EnableKeyRepeat(config.getIntValue("repeateDelay"),
config.getIntValue("repeateInterval"));
#endif
}
void Client::applyScale()
{
const int scale = config.getIntValue("scale");
if (mainGraphics->getScale() == scale)
return;
mainGraphics->setScale(scale);
resizeVideo(mainGraphics->mActualWidth,
mainGraphics->mActualHeight,
true);
}
void Client::setIsMinimized(const bool n)
{
mIsMinimized = n;
if (!n && mNewMessageFlag)
{
mNewMessageFlag = false;
SDL::SetWindowTitle(mainGraphics->getWindow(), mCaption.c_str());
}
}
void Client::newChatMessage()
{
if (!mNewMessageFlag && mIsMinimized)
{
// show * on window caption
SDL::SetWindowTitle(mainGraphics->getWindow(),
("*" + client->mCaption).c_str());
mNewMessageFlag = true;
}
}
void Client::logVars()
{
#ifdef ANDROID
logger->log("APPDIR: %s", getenv("APPDIR"));
logger->log("DATADIR2: %s", getSdStoragePath().c_str());
#endif
}
void Client::windowRemoved(const Window *const window)
{
if (mCurrentDialog == window)
mCurrentDialog = nullptr;
}
void Client::checkConfigVersion()
{
const int version = config.getIntValue("cfgver");
if (version < 1)
{
if (config.getIntValue("fontSize") == 11)
config.deleteKey("fontSize");
if (config.getIntValue("npcfontSize") == 13)
config.deleteKey("npcfontSize");
}
if (version < 2)
{
if (config.getIntValue("screenButtonsSize") == 1)
config.deleteKey("screenButtonsSize");
if (config.getIntValue("screenJoystickSize") == 1)
config.deleteKey("screenJoystickSize");
}
if (version < 3)
{
config.setValue("audioFrequency", 44100);
#ifdef ANDROID
config.setValue("customcursor", false);
#endif
}
if (version < 4)
{
#ifdef ANDROID
config.setValue("showDidYouKnow", false);
#endif
}
if (version < 5)
{
if (config.getIntValue("speech") == BeingSpeech::TEXT_OVERHEAD)
{
config.setValue("speech", static_cast(
BeingSpeech::NO_NAME_IN_BUBBLE));
}
}
if (version < 6)
config.setValue("blur", false);
if (version < 7)
config.setValue("download-music", true);
if (version < 8)
config.deleteKey("videodetected");
config.setValue("cfgver", 8);
}
Window *Client::openErrorDialog(const std::string &header,
const std::string &message,
const bool modal)
{
if (getSupportUrl().empty() || config.getBoolValue("hidesupport"))
{
return new OkDialog(header, message, DialogType::ERROR, modal);
}
else
{
ConfirmDialog *const dialog = new ConfirmDialog(
header, strprintf("%s %s", message.c_str(),
// TRANSLATORS: error message question
_("Do you want to open support page?")),
SOUND_ERROR, false, modal);
dialog->postInit();
return dialog;
}
}
void Client::setIcon()
{
std::string iconFile = branding.getValue("appIcon", "icons/manaplus");
#ifdef WIN32
iconFile.append(".ico");
#else
iconFile.append(".png");
#endif
iconFile = ResourceManager::getPath(iconFile);
logger->log("Loading icon from file: %s", iconFile.c_str());
#ifdef WIN32
static SDL_SysWMinfo pInfo;
if (mainGraphics)
SDL::getWindowWMInfo(mainGraphics->getWindow(), &pInfo);
else
SDL::getWindowWMInfo(nullptr, &pInfo);
// Attempt to load icon from .ico file
HICON icon = (HICON) LoadImage(nullptr, iconFile.c_str(),
IMAGE_ICON, 64, 64, LR_LOADFROMFILE);
// If it's failing, we load the default resource file.
if (!icon)
{
logger->log("icon load error");
icon = LoadIcon(GetModuleHandle(nullptr), "A");
}
if (icon)
SetClassLong(pInfo.window, GCL_HICON, reinterpret_cast(icon));
#else
mIcon = MIMG_Load(iconFile.c_str());
if (mIcon)
{
#ifdef USE_SDL2
SDL_SetSurfaceAlphaMod(mIcon, SDL_ALPHA_OPAQUE);
#else
SDL_SetAlpha(mIcon, SDL_SRCALPHA, SDL_ALPHA_OPAQUE);
#endif
SDL::SetWindowIcon(mainGraphics->getWindow(), mIcon);
}
#endif
}
bool Client::isKeyboardVisible() const
{
#ifdef USE_SDL2
return SDL_IsTextInputActive();
#else
return mKeyboardHeight > 1;
#endif
}
void Client::reloadWallpaper()
{
if (mDesktop)
mDesktop->reloadWallpaper();
}
#ifdef ANDROID
#ifdef USE_SDL2
void Client::extractAssets()
{
if (!getenv("APPDIR"))
{
logger->log("error: APPDIR is not set!");
return;
}
const std::string fileName = std::string(getenv(
"APPDIR")).append("/data.zip");
logger->log("Extracting asset into: " + fileName);
uint8_t *buf = new uint8_t[1000000];
FILE *const file = fopen(fileName.c_str(), "w");
for (int f = 0; f < 100; f ++)
{
std::string part = strprintf("manaplus-data.zip%u%u",
static_cast(f / 10),
static_cast(f % 10));
logger->log("testing asset: " + part);
SDL_RWops *const rw = SDL_RWFromFile(part.c_str(), "r");
if (rw)
{
const int size = SDL_RWsize(rw);
int size2 = SDL_RWread(rw, buf, 1, size);
logger->log("asset size: %d", size2);
fwrite(buf, 1, size2, file);
SDL_RWclose(rw);
setProgress(loadingProgressCounter + 1);
}
else
{
break;
}
}
fclose(file);
const std::string fileName2 = std::string(getenv(
"APPDIR")).append("/locale.zip");
FILE *const file2 = fopen(fileName2.c_str(), "w");
SDL_RWops *const rw = SDL_RWFromFile("manaplus-locale.zip", "r");
if (rw)
{
const int size = SDL_RWsize(rw);
int size2 = SDL_RWread(rw, buf, 1, size);
fwrite(buf, 1, size2, file2);
SDL_RWclose(rw);
setProgress(loadingProgressCounter + 1);
}
fclose(file2);
delete [] buf;
}
#endif
#endif