1253 lines
54 KiB
C++
1253 lines
54 KiB
C++
// ==============================================================
|
|
// This file is part of Glest (www.glest.org)
|
|
//
|
|
// Copyright (C) 2010- by Titus Tscharntke
|
|
//
|
|
// You can redistribute this code 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 (at your option) any later version
|
|
// ==============================================================
|
|
|
|
#include "menu_state_masterserver.h"
|
|
|
|
#include "server_line.h"
|
|
#include "renderer.h"
|
|
#include "sound_renderer.h"
|
|
#include "core_data.h"
|
|
#include "config.h"
|
|
#include "menu_state_connected_game.h"
|
|
#include "menu_state_custom_game.h"
|
|
#include "menu_state_new_game.h"
|
|
#include "metrics.h"
|
|
#include "network_manager.h"
|
|
#include "network_message.h"
|
|
#include "auto_test.h"
|
|
#include "socket.h"
|
|
#include "masterserver_info.h"
|
|
#include <curl/curl.h>
|
|
#include "cache_manager.h"
|
|
#include "leak_dumper.h"
|
|
|
|
namespace Glest{ namespace Game{
|
|
|
|
DisplayMessageFunction MenuStateMasterserver::pCB_DisplayMessage = NULL;
|
|
|
|
static string IRC_SERVER = "irc.libera.chat";
|
|
static string IRC_CHANNEL = "#megaglest-lobby";
|
|
|
|
// =====================================================
|
|
// class MenuStateMasterserver
|
|
// =====================================================
|
|
|
|
MenuStateMasterserver::MenuStateMasterserver(Program *program, MainMenu *mainMenu) :
|
|
MenuState(program, mainMenu, "masterserver"), mutexIRCClient(new Mutex(CODE_AT_LINE))
|
|
{
|
|
if(SystemFlags::VERBOSE_MODE_ENABLED) printf("\n\n\n\n******************** ENTERING MASTERSERVER MENU\n\n\n\n\n");
|
|
|
|
containerName = "MasterServer";
|
|
masterserverParseErrorShown = false;
|
|
updateFromMasterserverThread = NULL;
|
|
ircClient = NULL;
|
|
serverInfoString="empty";
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
|
|
Lang &lang= Lang::getInstance();
|
|
|
|
//Configure ConsolePosition
|
|
consoleIRC.setYPos(60);
|
|
consoleIRC.setFont(CoreData::getInstance().getMenuFontNormal());
|
|
consoleIRC.setFont3D(CoreData::getInstance().getMenuFontNormal3D());
|
|
consoleIRC.setLineHeight(18);
|
|
consoleIRC.setOnlyChatMessagesInStoredLines(false);
|
|
|
|
serverLinesToRender=8;
|
|
serverLinesLineHeight=25;
|
|
serverLinesYBase=680;
|
|
|
|
userButtonsHeight=20;
|
|
userButtonsWidth=150;
|
|
userButtonsLineHeight=userButtonsHeight+2;
|
|
userButtonsYBase=serverLinesYBase-(serverLinesToRender)*serverLinesLineHeight-90;
|
|
userButtonsToRender=userButtonsYBase/userButtonsLineHeight;
|
|
userButtonsXBase=1000-userButtonsWidth;
|
|
|
|
userScrollBar.init(1000-20,0,false,200,20);
|
|
userScrollBar.setLength(userButtonsYBase+userButtonsLineHeight);
|
|
userScrollBar.setElementCount(0);
|
|
userScrollBar.setVisibleSize(userButtonsToRender);
|
|
userScrollBar.setVisibleStart(0);
|
|
|
|
userButtonsXBase=1000-userButtonsWidth-userScrollBar.getW();
|
|
|
|
serverScrollBar.init(1000-20,serverLinesYBase-serverLinesLineHeight*(serverLinesToRender-1),false,200,20);
|
|
serverScrollBar.setLength(serverLinesLineHeight*serverLinesToRender);
|
|
serverScrollBar.setElementCount(0);
|
|
serverScrollBar.setVisibleSize(serverLinesToRender);
|
|
serverScrollBar.setVisibleStart(0);
|
|
|
|
lines[0].init(0, userButtonsYBase+userButtonsLineHeight+serverLinesLineHeight);
|
|
lines[1].init(userButtonsXBase-5,0,5,userButtonsYBase+2*userButtonsLineHeight);
|
|
lines[1].setHorizontal(false);
|
|
|
|
autoRefreshTime=0;
|
|
playServerFoundSound=false;
|
|
announcementLoaded=false;
|
|
|
|
mainMessageBox.registerGraphicComponent(containerName,"mainMessageBox");
|
|
mainMessageBox.init(lang.getString("Ok"));
|
|
mainMessageBox.setEnabled(false);
|
|
mainMessageBoxState=0;
|
|
|
|
lastRefreshTimer= time(NULL);
|
|
|
|
// announcement
|
|
announcementLabel.registerGraphicComponent(containerName,"announcementLabel");
|
|
announcementLabel.init(10, 730);
|
|
announcementLabel.setFont(CoreData::getInstance().getMenuFontBig());
|
|
announcementLabel.setFont3D(CoreData::getInstance().getMenuFontBig3D());
|
|
announcementLabel.setText("");
|
|
|
|
// versionInfo
|
|
versionInfoLabel.registerGraphicComponent(containerName,"versionInfoLabel");
|
|
versionInfoLabel.init(10, 680);
|
|
versionInfoLabel.setFont(CoreData::getInstance().getMenuFontBig());
|
|
versionInfoLabel.setFont3D(CoreData::getInstance().getMenuFontBig3D());
|
|
versionInfoLabel.setText("");
|
|
|
|
// header
|
|
labelTitle.registerGraphicComponent(containerName,"labelTitle");
|
|
labelTitle.init(410, serverLinesYBase+45);
|
|
labelTitle.setFont(CoreData::getInstance().getMenuFontBig());
|
|
labelTitle.setFont3D(CoreData::getInstance().getMenuFontBig3D());
|
|
labelTitle.setText(lang.getString("AvailableServers"));
|
|
|
|
if(Config::getInstance().getString("Masterserver","") == "") {
|
|
labelTitle.setText("*** " + lang.getString("AvailableServers"));
|
|
}
|
|
|
|
// bottom
|
|
int buttonPos=230;
|
|
|
|
// Titles for current games - START
|
|
int lineIndex = 0;
|
|
int lineOffset=25*lineIndex;
|
|
int i=5;
|
|
int startOffset=serverLinesYBase+23;
|
|
|
|
//general info:
|
|
//i+=10;
|
|
glestVersionLabel.registerGraphicComponent(containerName,"glestVersionLabel");
|
|
glestVersionLabel.init(i,startOffset-lineOffset);
|
|
glestVersionLabel.setText(lang.getString("MGVersion"));
|
|
|
|
i+=80;
|
|
platformLabel.registerGraphicComponent(containerName,"platformLabel");
|
|
platformLabel.init(i+15,startOffset-lineOffset);
|
|
platformLabel.setText(lang.getString("MGPlatform"));
|
|
|
|
// i+=50;
|
|
// binaryCompileDateLabel.registerGraphicComponent(containerName,"binaryCompileDateLabel");
|
|
// binaryCompileDateLabel.init(i,startOffset-lineOffset);
|
|
// binaryCompileDateLabel.setText(lang.getString("MGBuildDateTime"));
|
|
|
|
//game info:
|
|
i+=120;
|
|
serverTitleLabel.registerGraphicComponent(containerName,"serverTitleLabel");
|
|
serverTitleLabel.init(i,startOffset-lineOffset);
|
|
serverTitleLabel.setText(lang.getString("MGGameTitle"));
|
|
|
|
i+=170;
|
|
countryLabel.registerGraphicComponent(containerName,"countryLabel");
|
|
countryLabel.init(i-10,startOffset-lineOffset);
|
|
countryLabel.setText(lang.getString("MGGameCountry"));
|
|
|
|
i+=60;
|
|
|
|
// ipAddressLabel.registerGraphicComponent(containerName,"ipAddressLabel");
|
|
// ipAddressLabel.init(i,startOffset-lineOffset);
|
|
// ipAddressLabel.setText(lang.getString("MGGameIP"));
|
|
// i+=100;
|
|
|
|
//game setup info:
|
|
techLabel.registerGraphicComponent(containerName,"techLabel");
|
|
techLabel.init(i,startOffset-lineOffset);
|
|
techLabel.setText(lang.getString("TechTree"));
|
|
|
|
i+=165;
|
|
mapLabel.registerGraphicComponent(containerName,"mapLabel");
|
|
mapLabel.init(i,startOffset-lineOffset);
|
|
mapLabel.setText(lang.getString("Map"));
|
|
|
|
i+=95;
|
|
// tilesetLabel.registerGraphicComponent(containerName,"tilesetLabel");
|
|
// tilesetLabel.init(i,startOffset-lineOffset);
|
|
// tilesetLabel.setText(lang.getString("Tileset"));
|
|
// i+=100;
|
|
|
|
activeSlotsLabel.registerGraphicComponent(containerName,"activeSlotsLabel");
|
|
activeSlotsLabel.init(i,startOffset-lineOffset);
|
|
activeSlotsLabel.setText(lang.getString("MGGameSlots"));
|
|
|
|
i+=50;
|
|
//externalConnectPort.registerGraphicComponent(containerName,"externalConnectPort");
|
|
//externalConnectPort.init(i,startOffset-lineOffset);
|
|
//externalConnectPort.setText(lang.getString("Port"));
|
|
|
|
i+=30;
|
|
statusLabel.registerGraphicComponent(containerName,"statusLabel");
|
|
statusLabel.init(i+5,startOffset-lineOffset);
|
|
statusLabel.setText(lang.getString("MGGameStatus"));
|
|
|
|
i+=130;
|
|
selectButton.registerGraphicComponent(containerName,"selectButton");
|
|
selectButton.init(i-5, startOffset-lineOffset);
|
|
selectButton.setText(lang.getString("MGJoinGameSlots"));
|
|
|
|
// Titles for current games - END
|
|
|
|
buttonReturn.registerGraphicComponent(containerName,"buttonReturn");
|
|
buttonReturn.init(50, buttonPos, 150);
|
|
|
|
buttonCreateGame.registerGraphicComponent(containerName,"buttonCreateGame");
|
|
buttonCreateGame.init(275, buttonPos, 150);
|
|
|
|
buttonRefresh.registerGraphicComponent(containerName,"buttonRefresh");
|
|
buttonRefresh.init(500, buttonPos, 150);
|
|
|
|
buttonRefresh.setText(lang.getString("RefreshList"));
|
|
buttonReturn.setText(lang.getString("Return"));
|
|
buttonCreateGame.setText(lang.getString("HostGame"));
|
|
labelAutoRefresh.setText(lang.getString("AutoRefreshRate"));
|
|
|
|
labelAutoRefresh.registerGraphicComponent(containerName,"labelAutoRefresh");
|
|
labelAutoRefresh.init(750,buttonPos+30);
|
|
|
|
listBoxAutoRefresh.registerGraphicComponent(containerName,"listBoxAutoRefresh");
|
|
listBoxAutoRefresh.init(750,buttonPos);
|
|
listBoxAutoRefresh.pushBackItem(lang.getString("Off"));
|
|
listBoxAutoRefresh.pushBackItem("10 s");
|
|
listBoxAutoRefresh.pushBackItem("20 s");
|
|
listBoxAutoRefresh.pushBackItem("30 s");
|
|
listBoxAutoRefresh.setSelectedItemIndex(2);
|
|
autoRefreshTime=10*listBoxAutoRefresh.getSelectedItemIndex();
|
|
|
|
ircOnlinePeopleLabel.registerGraphicComponent(containerName,"ircOnlinePeopleLabel");
|
|
ircOnlinePeopleLabel.init(userButtonsXBase,userButtonsYBase+userButtonsLineHeight);
|
|
ircOnlinePeopleLabel.setText(lang.getString("IRCPeopleOnline"));
|
|
|
|
ircOnlinePeopleStatusLabel.registerGraphicComponent(containerName,"ircOnlinePeopleStatusLabel");
|
|
ircOnlinePeopleStatusLabel.init(userButtonsXBase,userButtonsYBase+userButtonsLineHeight-20);
|
|
ircOnlinePeopleStatusLabel.setText("");
|
|
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
|
|
NetworkManager::getInstance().end();
|
|
NetworkManager::getInstance().init(nrClient);
|
|
|
|
//console.addLine(lang.getString("ToSwitchOffMusicPress")+" - \""+configKeys.getCharKey("ToggleMusic")+"\"");
|
|
|
|
GraphicComponent::applyAllCustomProperties(containerName);
|
|
|
|
char szIRCNick[80]="";
|
|
Chrono seed(true);
|
|
srand((unsigned int)seed.getCurTicks());
|
|
|
|
int randomNickId = rand() % 999;
|
|
string netPlayerName=Config::getInstance().getString("NetPlayerName",Socket::getHostName().c_str());
|
|
string ircname=netPlayerName.substr(0,9);
|
|
snprintf(szIRCNick,80,"MG_%s_%d",ircname.c_str(),randomNickId);
|
|
normalizeNick(szIRCNick);
|
|
|
|
currentIrcNick=ircname;
|
|
consoleIRC.setStringToHighlight(currentIrcNick);
|
|
|
|
lines[2].init(0,consoleIRC.getYPos()-10,userButtonsXBase,5);
|
|
chatManager.init(&consoleIRC, -1, true, szIRCNick);
|
|
chatManager.setXPos(0);
|
|
chatManager.setYPos(consoleIRC.getYPos()-20);
|
|
chatManager.setFont(CoreData::getInstance().getMenuFontNormal());
|
|
chatManager.setFont3D(CoreData::getInstance().getMenuFontNormal3D());
|
|
|
|
needUpdateFromServer = true;
|
|
|
|
static string mutexOwnerId = string(extractFileFromDirectoryPath(__FILE__).c_str()) + string("_") + intToStr(__LINE__);
|
|
updateFromMasterserverThread = new SimpleTaskThread(this,0,100);
|
|
updateFromMasterserverThread->setUniqueID(mutexOwnerId);
|
|
updateFromMasterserverThread->start();
|
|
|
|
if(Config::getInstance().getString("IRCServer","") != "") {
|
|
IRC_SERVER = Config::getInstance().getString("IRCServer");
|
|
}
|
|
ircArgs.push_back(IRC_SERVER);
|
|
|
|
if(Config::getInstance().getString("IRCNick","") != "") {
|
|
ircArgs.push_back(Config::getInstance().getString("IRCNick"));
|
|
}
|
|
else {
|
|
ircArgs.push_back(szIRCNick);
|
|
}
|
|
|
|
if(Config::getInstance().getString("IRCChannel","") != "") {
|
|
IRC_CHANNEL = Config::getInstance().getString("IRCChannel");
|
|
}
|
|
ircArgs.push_back(IRC_CHANNEL);
|
|
|
|
if(Config::getInstance().getString("IRCUsername","") != "") {
|
|
ircArgs.push_back(Config::getInstance().getString("IRCUsername"));
|
|
}
|
|
else {
|
|
ircArgs.push_back(szIRCNick);
|
|
}
|
|
if(Config::getInstance().getString("IRCPassword","") != "") {
|
|
ircArgs.push_back("identify " + Config::getInstance().getString("IRCPassword"));
|
|
}
|
|
else {
|
|
ircArgs.push_back("");
|
|
}
|
|
|
|
MutexSafeWrapper safeMutexIRCPtr(mutexIRCClient,string(extractFileFromDirectoryPath(__FILE__).c_str()) + "_" + intToStr(__LINE__));
|
|
|
|
if(SystemFlags::VERBOSE_MODE_ENABLED) printf("#1 IRCCLient Cache check\n");
|
|
IRCThread * &ircThread = CacheManager::getCachedItem< IRCThread * >(GameConstants::ircClientCacheLookupKey);
|
|
|
|
// Playername changed so restart the IRC Thread
|
|
if(ircThread != NULL && netPlayerName != ircThread->getPlayerName()) {
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
ircThread->leaveChannel();
|
|
ircThread->setCallbackObj(NULL);
|
|
ircThread->signalQuit();
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
ircThread = NULL;
|
|
}
|
|
|
|
if(ircThread == NULL) {
|
|
if(SystemFlags::VERBOSE_MODE_ENABLED) printf("#2 IRCCLient Cache check\n");
|
|
|
|
static string mutexOwnerId = string(extractFileFromDirectoryPath(__FILE__).c_str()) + string("_") + intToStr(__LINE__);
|
|
ircThread = new IRCThread(ircArgs,this);
|
|
ircClient = ircThread;
|
|
ircClient->setUniqueID(mutexOwnerId);
|
|
ircClient->setPlayerName(netPlayerName);
|
|
ircClient->setGlestVersionString(glestVersionString);
|
|
ircClient->start();
|
|
}
|
|
else {
|
|
if(SystemFlags::VERBOSE_MODE_ENABLED) printf("#3 IRCCLient Cache check\n");
|
|
ircClient = ircThread;
|
|
ircClient->setCallbackObj(this);
|
|
ircClient->joinChannel();
|
|
}
|
|
|
|
if(netPlayerName=="newbie"){
|
|
showMessageBox(lang.getString("PlayerNameNotSetPrompt"),lang.getString("PlayerNameNotSetTitle"),false);
|
|
}
|
|
//showMessageBox("Go back and set your name in the game options!\n\nAt the moment you are just called >>newbie<< !","Player name not set!",false);
|
|
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
}
|
|
|
|
void MenuStateMasterserver::reloadUI() {
|
|
Lang &lang= Lang::getInstance();
|
|
|
|
console.resetFonts();
|
|
consoleIRC.setFont(CoreData::getInstance().getMenuFontNormal());
|
|
consoleIRC.setFont3D(CoreData::getInstance().getMenuFontNormal3D());
|
|
|
|
mainMessageBox.init(lang.getString("Ok"));
|
|
|
|
announcementLabel.setFont(CoreData::getInstance().getMenuFontBig());
|
|
announcementLabel.setFont3D(CoreData::getInstance().getMenuFontBig3D());
|
|
|
|
versionInfoLabel.setFont(CoreData::getInstance().getMenuFontBig());
|
|
versionInfoLabel.setFont3D(CoreData::getInstance().getMenuFontBig3D());
|
|
|
|
labelTitle.setFont(CoreData::getInstance().getMenuFontBig());
|
|
labelTitle.setFont3D(CoreData::getInstance().getMenuFontBig3D());
|
|
labelTitle.setText(lang.getString("AvailableServers"));
|
|
|
|
if(Config::getInstance().getString("Masterserver","") == "") {
|
|
labelTitle.setText("*** " + lang.getString("AvailableServers"));
|
|
}
|
|
|
|
glestVersionLabel.setText(lang.getString("MGVersion"));
|
|
|
|
platformLabel.setText(lang.getString("MGPlatform"));
|
|
|
|
serverTitleLabel.setText(lang.getString("MGGameTitle"));
|
|
|
|
countryLabel.setText(lang.getString("MGGameCountry"));
|
|
|
|
techLabel.setText(lang.getString("TechTree"));
|
|
|
|
mapLabel.setText(lang.getString("Map"));
|
|
|
|
activeSlotsLabel.setText(lang.getString("MGGameSlots"));
|
|
|
|
//externalConnectPort.setText(lang.getString("Port"));
|
|
|
|
statusLabel.setText(lang.getString("MGGameStatus"));
|
|
|
|
selectButton.setText(lang.getString("MGJoinGameSlots"));
|
|
|
|
// Titles for current games - END
|
|
|
|
buttonRefresh.setText(lang.getString("RefreshList"));
|
|
buttonReturn.setText(lang.getString("Return"));
|
|
buttonCreateGame.setText(lang.getString("HostGame"));
|
|
labelAutoRefresh.setText(lang.getString("AutoRefreshRate"));
|
|
|
|
ircOnlinePeopleLabel.setText(lang.getString("IRCPeopleOnline"));
|
|
|
|
chatManager.setFont(CoreData::getInstance().getMenuFontNormal());
|
|
chatManager.setFont3D(CoreData::getInstance().getMenuFontNormal3D());
|
|
|
|
GraphicComponent::reloadFontsForRegisterGraphicComponents(containerName);
|
|
}
|
|
|
|
//void MenuStateMasterserver::setConsolePos(int yPos){
|
|
// consoleIRC.setYPos(yPos);
|
|
// lines[2].setY(consoleIRC.getYPos()-10);
|
|
// chatManager.setYPos(consoleIRC.getYPos()-20);
|
|
//}
|
|
|
|
void MenuStateMasterserver::setButtonLinePosition(int pos){
|
|
buttonReturn.setY(pos);
|
|
buttonCreateGame.setY(pos);
|
|
buttonRefresh.setY(pos);
|
|
labelAutoRefresh.setY(pos+30);
|
|
listBoxAutoRefresh.setY(pos);
|
|
}
|
|
|
|
void MenuStateMasterserver::IRC_CallbackEvent(IRCEventType evt, const char* origin, const char **params, unsigned int count) {
|
|
MutexSafeWrapper safeMutexIRCPtr(mutexIRCClient,string(extractFileFromDirectoryPath(__FILE__).c_str()) + "_" + intToStr(__LINE__));
|
|
if(ircClient != NULL) {
|
|
if(evt == IRC_evt_exitThread) {
|
|
ircClient->leaveChannel();
|
|
ircClient->setCallbackObj(NULL);
|
|
|
|
ircClient = NULL;
|
|
}
|
|
else if(evt == IRC_evt_chatText) {
|
|
//printf ("===> IRC: '%s' said in channel %s: %s\n",origin ? origin : "someone",params[0], params[1] );
|
|
|
|
char szBuf[8096]="";
|
|
snprintf(szBuf,8096,"%s: %s",origin ? origin : "someone",params[1]);
|
|
string helpSTr=szBuf;
|
|
if(helpSTr.find(currentIrcNick)!=string::npos){
|
|
CoreData &coreData= CoreData::getInstance();
|
|
SoundRenderer &soundRenderer= SoundRenderer::getInstance();
|
|
|
|
soundRenderer.playFx(coreData.getHighlightSound());
|
|
}
|
|
consoleIRC.addLine(szBuf);
|
|
}
|
|
}
|
|
}
|
|
|
|
void MenuStateMasterserver::cleanup() {
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
|
|
MutexSafeWrapper safeMutex((updateFromMasterserverThread != NULL ? updateFromMasterserverThread->getMutexThreadObjectAccessor() : NULL),string(extractFileFromDirectoryPath(__FILE__).c_str()) + "_" + intToStr(__LINE__));
|
|
needUpdateFromServer = false;
|
|
safeMutex.ReleaseLock();
|
|
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
|
|
// if(updateFromMasterserverThread != NULL &&
|
|
// updateFromMasterserverThread->canShutdown(true) == true) {
|
|
// if(updateFromMasterserverThread->shutdownAndWait() == true) {
|
|
// delete updateFromMasterserverThread;
|
|
// }
|
|
// }
|
|
// updateFromMasterserverThread = NULL;
|
|
if(updateFromMasterserverThread != NULL) {
|
|
updateFromMasterserverThread->signalQuit();
|
|
}
|
|
if(updateFromMasterserverThread != NULL && updateFromMasterserverThread->canShutdown(false) == true &&
|
|
updateFromMasterserverThread->getRunningStatus() == false) {
|
|
//printf("#2 Ending client SLOT: %d\n",playerIndex);
|
|
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugNetwork).enabled) SystemFlags::OutputDebug(SystemFlags::debugNetwork,"In [%s::%s Line: %d]\n",__FILE__,__FUNCTION__,__LINE__);
|
|
delete updateFromMasterserverThread;
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugNetwork).enabled) SystemFlags::OutputDebug(SystemFlags::debugNetwork,"In [%s::%s Line: %d]\n",__FILE__,__FUNCTION__,__LINE__);
|
|
}
|
|
//else if(BaseThread::shutdownAndWait(slotThreadWorker) == true) {
|
|
else if(updateFromMasterserverThread != NULL && updateFromMasterserverThread->canShutdown(true) == true) {
|
|
if(updateFromMasterserverThread->getRunningStatus() == false) {
|
|
//printf("#3 Ending client SLOT: %d\n",playerIndex);
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugNetwork).enabled) SystemFlags::OutputDebug(SystemFlags::debugNetwork,"In [%s::%s Line: %d]\n",__FILE__,__FUNCTION__,__LINE__);
|
|
delete updateFromMasterserverThread;
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugNetwork).enabled) SystemFlags::OutputDebug(SystemFlags::debugNetwork,"In [%s::%s Line: %d]\n",__FILE__,__FUNCTION__,__LINE__);
|
|
}
|
|
else {
|
|
updateFromMasterserverThread->setDeleteSelfOnExecutionDone(true);
|
|
updateFromMasterserverThread->setDeleteAfterExecute(true);
|
|
}
|
|
}
|
|
//printf("#4 Ending client SLOT: %d\n",playerIndex);
|
|
updateFromMasterserverThread = NULL;
|
|
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
|
|
clearServerLines();
|
|
clearUserButtons();
|
|
|
|
MutexSafeWrapper safeMutexIRCPtr(mutexIRCClient,string(extractFileFromDirectoryPath(__FILE__).c_str()) + "_" + intToStr(__LINE__));
|
|
if(ircClient != NULL) {
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
|
|
ircClient->leaveChannel();
|
|
ircClient->setCallbackObj(NULL);
|
|
//ircClient->signalQuit();
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
ircClient = NULL;
|
|
}
|
|
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d] END\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
}
|
|
|
|
MenuStateMasterserver::~MenuStateMasterserver() {
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
|
|
cleanup();
|
|
|
|
delete mutexIRCClient;
|
|
mutexIRCClient = NULL;
|
|
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d] END\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
}
|
|
|
|
void MenuStateMasterserver::clearServerLines() {
|
|
while(!serverLines.empty()) {
|
|
delete serverLines.back();
|
|
serverLines.pop_back();
|
|
}
|
|
}
|
|
|
|
void MenuStateMasterserver::clearUserButtons() {
|
|
while(!userButtons.empty()){
|
|
delete userButtons.back();
|
|
userButtons.pop_back();
|
|
}
|
|
}
|
|
|
|
void MenuStateMasterserver::mouseClick(int x, int y, MouseButton mouseButton){
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
|
|
CoreData &coreData= CoreData::getInstance();
|
|
SoundRenderer &soundRenderer= SoundRenderer::getInstance();
|
|
|
|
if(mainMessageBox.getEnabled()){
|
|
int button= 0;
|
|
if(mainMessageBox.mouseClick(x, y, button)) {
|
|
soundRenderer.playFx(coreData.getClickSoundA());
|
|
if(button == 0) {
|
|
mainMessageBox.setEnabled(false);
|
|
}
|
|
}
|
|
}
|
|
else if(userScrollBar.mouseClick(x, y)){
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
soundRenderer.playFx(coreData.getClickSoundA());
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
}
|
|
else if(serverScrollBar.mouseClick(x, y)){
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
soundRenderer.playFx(coreData.getClickSoundA());
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
}
|
|
else if(buttonRefresh.mouseClick(x, y)){
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
|
|
MutexSafeWrapper safeMutex((updateFromMasterserverThread != NULL ? updateFromMasterserverThread->getMutexThreadObjectAccessor() : NULL),string(extractFileFromDirectoryPath(__FILE__).c_str()) + "_" + intToStr(__LINE__));
|
|
soundRenderer.playFx(coreData.getClickSoundB());
|
|
needUpdateFromServer = true;
|
|
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
}
|
|
else if(buttonReturn.mouseClick(x, y)){
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
|
|
soundRenderer.playFx(coreData.getClickSoundA());
|
|
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
if (ircClient != NULL && ircClient->isConnected() == true
|
|
&& ircClient->getHasJoinedChannel() == true) {
|
|
ircClient->SendIRCCmdMessage(IRC_CHANNEL, " << left the lobby");
|
|
sleep(30);
|
|
}
|
|
cleanup();
|
|
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
|
|
mainMenu->setState(new MenuStateNewGame(program, mainMenu));
|
|
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
}
|
|
else if(buttonCreateGame.mouseClick(x, y)){
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
|
|
MutexSafeWrapper safeMutex((updateFromMasterserverThread != NULL ? updateFromMasterserverThread->getMutexThreadObjectAccessor() : NULL),string(extractFileFromDirectoryPath(__FILE__).c_str()) + "_" + intToStr(__LINE__));
|
|
soundRenderer.playFx(coreData.getClickSoundB());
|
|
needUpdateFromServer = false;
|
|
safeMutex.ReleaseLock();
|
|
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
if (ircClient != NULL && ircClient->isConnected() == true
|
|
&& ircClient->getHasJoinedChannel() == true) {
|
|
ircClient->SendIRCCmdMessage(IRC_CHANNEL, " << tries to create a game");
|
|
sleep(30);
|
|
}
|
|
cleanup();
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
|
|
mainMenu->setState(new MenuStateCustomGame(program, mainMenu,true,pMasterServer));
|
|
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
}
|
|
else if(listBoxAutoRefresh.mouseClick(x, y)){
|
|
MutexSafeWrapper safeMutex((updateFromMasterserverThread != NULL ? updateFromMasterserverThread->getMutexThreadObjectAccessor() : NULL),string(extractFileFromDirectoryPath(__FILE__).c_str()) + "_" + intToStr(__LINE__));
|
|
soundRenderer.playFx(coreData.getClickSoundA());
|
|
autoRefreshTime=10*listBoxAutoRefresh.getSelectedItemIndex();
|
|
}
|
|
else {
|
|
MutexSafeWrapper safeMutex((updateFromMasterserverThread != NULL ? updateFromMasterserverThread->getMutexThreadObjectAccessor() : NULL),string(extractFileFromDirectoryPath(__FILE__).c_str()) + "_" + intToStr(__LINE__));
|
|
bool clicked=false;
|
|
if(serverScrollBar.getElementCount() != 0) {
|
|
for(int i = serverScrollBar.getVisibleStart(); i <= serverScrollBar.getVisibleEnd(); ++i) {
|
|
if(serverLines[i]->buttonMouseClick(x, y)) {
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
clicked=true;
|
|
soundRenderer.playFx(coreData.getClickSoundB());
|
|
string connectServerIP = serverLines[i]->getMasterServerInfo()->getIpAddress();
|
|
int connectServerPort = serverLines[i]->getMasterServerInfo()->getExternalConnectPort();
|
|
bool connected=connectToServer(connectServerIP,connectServerPort);
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
safeMutex.ReleaseLock();
|
|
if(connected){
|
|
soundRenderer.playFx(coreData.getClickSoundB());
|
|
|
|
if (ircClient != NULL && ircClient->isConnected() == true
|
|
&& ircClient->getHasJoinedChannel() == true) {
|
|
ircClient->SendIRCCmdMessage(IRC_CHANNEL, " << is connecting to '"+serverLines[i]->getMasterServerInfo()->getServerTitle()+"'");
|
|
sleep(30);
|
|
}
|
|
cleanup();
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
mainMenu->setState(new MenuStateConnectedGame(program, mainMenu,jmMasterserver));
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
if(!clicked && userScrollBar.getElementCount()!=0){
|
|
for(int i = userScrollBar.getVisibleStart(); i <= userScrollBar.getVisibleEnd(); ++i) {
|
|
if(userButtons[i]->getEnabled() == true && userButtons[i]->mouseClick(x, y)) {
|
|
//clicked=true;
|
|
if(!chatManager.getEditEnabled())
|
|
{
|
|
chatManager.switchOnEdit();
|
|
chatManager.addText(userButtons[i]->getText()+" ");
|
|
}
|
|
else
|
|
{
|
|
chatManager.addText(userButtons[i]->getText());
|
|
}
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
void MenuStateMasterserver::mouseUp(int x, int y, const MouseButton mouseButton){
|
|
if (mouseButton == mbLeft) {
|
|
userScrollBar.mouseUp(x, y);
|
|
serverScrollBar.mouseUp(x, y);
|
|
}
|
|
}
|
|
|
|
void MenuStateMasterserver::mouseMove(int x, int y, const MouseState *ms){
|
|
MutexSafeWrapper safeMutex((updateFromMasterserverThread != NULL ? updateFromMasterserverThread->getMutexThreadObjectAccessor() : NULL),string(extractFileFromDirectoryPath(__FILE__).c_str()) + "_" + intToStr(__LINE__));
|
|
|
|
if (mainMessageBox.getEnabled()) {
|
|
mainMessageBox.mouseMove(x, y);
|
|
}
|
|
buttonRefresh.mouseMove(x, y);
|
|
buttonReturn.mouseMove(x, y);
|
|
buttonCreateGame.mouseMove(x, y);
|
|
if (ms->get(mbLeft)) {
|
|
userScrollBar.mouseDown(x, y);
|
|
serverScrollBar.mouseDown(x, y);
|
|
} else {
|
|
userScrollBar.mouseMove(x, y);
|
|
serverScrollBar.mouseMove(x, y);
|
|
}
|
|
listBoxAutoRefresh.mouseMove(x, y);
|
|
|
|
if(serverScrollBar.getElementCount()!=0 ) {
|
|
for(int i = serverScrollBar.getVisibleStart(); i <= serverScrollBar.getVisibleEnd(); ++i) {
|
|
serverLines[i]->buttonMouseMove(x, y);
|
|
}
|
|
}
|
|
if(userScrollBar.getElementCount()!=0 ) {
|
|
for(int i = userScrollBar.getVisibleStart(); i <= userScrollBar.getVisibleEnd(); ++i) {
|
|
if(userButtons[i]->getEnabled() == true) {
|
|
userButtons[i]->mouseMove(x, y);
|
|
}
|
|
}
|
|
}
|
|
|
|
}
|
|
|
|
void MenuStateMasterserver::render(){
|
|
Renderer &renderer= Renderer::getInstance();
|
|
|
|
MutexSafeWrapper safeMutex((updateFromMasterserverThread != NULL ? updateFromMasterserverThread->getMutexThreadObjectAccessor() : NULL),string(extractFileFromDirectoryPath(__FILE__).c_str()) + "_" + intToStr(__LINE__));
|
|
if(mainMessageBox.getEnabled()) {
|
|
renderer.renderMessageBox(&mainMessageBox);
|
|
}
|
|
else
|
|
{
|
|
renderer.renderLabel(&labelTitle,&GREEN);
|
|
renderer.renderLabel(&announcementLabel,&YELLOW);
|
|
renderer.renderLabel(&versionInfoLabel);
|
|
|
|
// Render titles for server games listed
|
|
const Vec4f titleLabelColor = CYAN;
|
|
|
|
//general info:
|
|
renderer.renderLabel(&glestVersionLabel,&titleLabelColor);
|
|
renderer.renderLabel(&platformLabel,&titleLabelColor);
|
|
//renderer.renderLabel(&binaryCompileDateLabel,&titleLabelColor);
|
|
|
|
//game info:
|
|
renderer.renderLabel(&serverTitleLabel,&titleLabelColor);
|
|
renderer.renderLabel(&countryLabel,&titleLabelColor);
|
|
renderer.renderLabel(&statusLabel,&titleLabelColor);
|
|
//renderer.renderLabel(&ipAddressLabel,&titleLabelColor);
|
|
|
|
//game setup info:
|
|
renderer.renderLabel(&techLabel,&titleLabelColor);
|
|
renderer.renderLabel(&mapLabel,&titleLabelColor);
|
|
//renderer.renderLabel(&tilesetLabel,&titleLabelColor);
|
|
renderer.renderLabel(&activeSlotsLabel,&titleLabelColor);
|
|
//renderer.renderLabel(&externalConnectPort,&titleLabelColor);
|
|
renderer.renderLabel(&selectButton,&titleLabelColor);
|
|
|
|
Lang &lang= Lang::getInstance();
|
|
MutexSafeWrapper safeMutexIRCPtr(mutexIRCClient,string(extractFileFromDirectoryPath(__FILE__).c_str()) + "_" + intToStr(__LINE__));
|
|
if(ircClient != NULL &&
|
|
ircClient->isConnected() == true &&
|
|
ircClient->getHasJoinedChannel() == true) {
|
|
const Vec4f titleLabelColor = GREEN;
|
|
|
|
if(ircOnlinePeopleStatusLabel.getText() != "") {
|
|
ircOnlinePeopleStatusLabel.setText("");
|
|
}
|
|
|
|
renderer.renderLabel(&ircOnlinePeopleLabel,&titleLabelColor);
|
|
//renderer.renderLabel(&ircOnlinePeopleStatusLabel,&titleLabelColor);
|
|
}
|
|
else {
|
|
const Vec4f titleLabelColor = RED;
|
|
|
|
if(ircOnlinePeopleStatusLabel.getText() != lang.getString("Connecting")) {
|
|
ircOnlinePeopleStatusLabel.setText(lang.getString("Connecting"));
|
|
}
|
|
|
|
renderer.renderLabel(&ircOnlinePeopleLabel,&titleLabelColor);
|
|
renderer.renderLabel(&ircOnlinePeopleStatusLabel,&titleLabelColor);
|
|
}
|
|
safeMutexIRCPtr.ReleaseLock();
|
|
|
|
//const Vec4f titleLabelColorList = YELLOW;
|
|
|
|
if(serverScrollBar.getElementCount()!=0 ) {
|
|
for(int i = serverScrollBar.getVisibleStart(); i <= serverScrollBar.getVisibleEnd(); ++i) {
|
|
serverLines[i]->render();
|
|
}
|
|
}
|
|
renderer.renderScrollBar(&serverScrollBar);
|
|
|
|
for(int i = 0; i < (int)sizeof(lines) / (int)sizeof(lines[0]); ++i){
|
|
renderer.renderLine(&lines[i]);
|
|
}
|
|
renderer.renderButton(&buttonRefresh);
|
|
renderer.renderButton(&buttonReturn);
|
|
renderer.renderLabel(&labelAutoRefresh);
|
|
renderer.renderButton(&buttonCreateGame);
|
|
renderer.renderListBox(&listBoxAutoRefresh);
|
|
|
|
if(userScrollBar.getElementCount()!=0 ) {
|
|
for(int i = userScrollBar.getVisibleStart(); i <= userScrollBar.getVisibleEnd(); ++i) {
|
|
renderer.renderButton(userButtons[i]);
|
|
}
|
|
}
|
|
renderer.renderScrollBar(&userScrollBar);
|
|
if(ircClient != NULL &&
|
|
ircClient->isConnected() == true &&
|
|
ircClient->getHasJoinedChannel() == true) {
|
|
renderer.renderChatManager(&chatManager);
|
|
}
|
|
renderer.renderConsole(&consoleIRC,consoleStoredOnly,21);
|
|
|
|
}
|
|
if(program != NULL) program->renderProgramMsgBox();
|
|
}
|
|
|
|
void MenuStateMasterserver::update() {
|
|
MutexSafeWrapper safeMutex((updateFromMasterserverThread != NULL ? updateFromMasterserverThread->getMutexThreadObjectAccessor() : NULL),string(extractFileFromDirectoryPath(__FILE__).c_str()) + "_" + intToStr(__LINE__));
|
|
if(autoRefreshTime!=0 && difftime(time(NULL),lastRefreshTimer) >= autoRefreshTime ) {
|
|
needUpdateFromServer = true;
|
|
lastRefreshTimer= time(NULL);
|
|
}
|
|
|
|
// calculate button linepos:
|
|
setButtonLinePosition(serverLinesYBase-(serverLinesToRender)*serverLinesLineHeight-30);
|
|
|
|
if(playServerFoundSound)
|
|
{
|
|
SoundRenderer::getInstance().playFx(CoreData::getInstance().getAttentionSound());
|
|
//switch on music again!!
|
|
Config &config = Config::getInstance();
|
|
float configVolume = (config.getInt("SoundVolumeMusic") / 100.f);
|
|
CoreData::getInstance().getMenuMusic()->setVolume(configVolume);
|
|
|
|
playServerFoundSound=false;
|
|
}
|
|
|
|
//console.update();
|
|
|
|
//call the chat manager
|
|
chatManager.updateNetwork();
|
|
|
|
//console
|
|
consoleIRC.update();
|
|
|
|
MutexSafeWrapper safeMutexIRCPtr(mutexIRCClient,string(extractFileFromDirectoryPath(__FILE__).c_str()) + "_" + intToStr(__LINE__));
|
|
if(ircClient != NULL) {
|
|
std::vector<string> nickList = ircClient->getNickList();
|
|
|
|
if(currentIrcNick != ircClient->getNick()) {
|
|
currentIrcNick = ircClient->getNick();
|
|
consoleIRC.setStringToHighlight(currentIrcNick);
|
|
}
|
|
|
|
bool isNew=false;
|
|
//check if there is something new
|
|
if( oldNickList.size() != nickList.size()) {
|
|
isNew=true;
|
|
}
|
|
else {
|
|
for(unsigned int i = 0; i < nickList.size(); ++i) {
|
|
if(nickList[i] != oldNickList[i]) {
|
|
isNew=true;
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
if(isNew) {
|
|
clearUserButtons();
|
|
for(int i = 0; i < (int)nickList.size(); ++i) {
|
|
GraphicButton *button=new GraphicButton();
|
|
button->init(userButtonsXBase,userButtonsYBase,userButtonsWidth,userButtonsHeight);
|
|
//button->init(userButtonsXBase,userButtonsYBase-userButtonsLineHeight*i,userButtonsWidth,userButtonsHeight);
|
|
button->setFont(CoreData::getInstance().getDisplayFontSmall());
|
|
button->setFont3D(CoreData::getInstance().getDisplayFontSmall3D());
|
|
button->setText(nickList[i]);
|
|
if(strncmp(&nickList[i][0],"MG_",3) != 0 || &nickList[i][0] == currentIrcNick) {
|
|
button->setEnabled(false);
|
|
button->setEditable(false);
|
|
button->setCustomTexture(CoreData::getInstance().getCustomTexture());
|
|
button->setUseCustomTexture(true);
|
|
}
|
|
|
|
userButtons.push_back(button);
|
|
}
|
|
userScrollBar.setElementCount((int)userButtons.size());
|
|
oldNickList = nickList;
|
|
chatManager.setAutoCompleteTextList(oldNickList);
|
|
}
|
|
if(userScrollBar.getElementCount()!=0 ) {
|
|
for(int i = userScrollBar.getVisibleStart(); i <= userScrollBar.getVisibleEnd(); ++i) {
|
|
userButtons[i]->setY(userButtonsYBase-userButtonsLineHeight*(i-userScrollBar.getVisibleStart()));
|
|
}
|
|
}
|
|
}
|
|
safeMutexIRCPtr.ReleaseLock();
|
|
if(serverInfoString!="empty")
|
|
{
|
|
rebuildServerLines(serverInfoString);
|
|
serverInfoString="empty";
|
|
}
|
|
|
|
serverScrollBar.setElementCount((int)serverLines.size());
|
|
if(serverScrollBar.getElementCount()!=0 ) {
|
|
for(int i = serverScrollBar.getVisibleStart(); i <= serverScrollBar.getVisibleEnd(); ++i) {
|
|
serverLines[i]->setY(serverLinesYBase-serverLinesLineHeight*(i-serverScrollBar.getVisibleStart()));
|
|
}
|
|
}
|
|
|
|
if(threadedErrorMsg != "") {
|
|
std::string sError = threadedErrorMsg;
|
|
threadedErrorMsg = "";
|
|
|
|
if(pCB_DisplayMessage != NULL) {
|
|
pCB_DisplayMessage(sError.c_str(),false);
|
|
}
|
|
else {
|
|
throw megaglest_runtime_error(sError.c_str());
|
|
}
|
|
}
|
|
}
|
|
|
|
void MenuStateMasterserver::simpleTask(BaseThread *callingThread,void *userdata) {
|
|
if(callingThread->getQuitStatus() == true) {
|
|
return;
|
|
}
|
|
MutexSafeWrapper safeMutex(callingThread->getMutexThreadObjectAccessor(),string(extractFileFromDirectoryPath(__FILE__).c_str()) + "_" + intToStr(__LINE__));
|
|
bool needUpdate = needUpdateFromServer;
|
|
|
|
if(needUpdate == true) {
|
|
try {
|
|
|
|
if(callingThread->getQuitStatus() == true) {
|
|
return;
|
|
}
|
|
|
|
needUpdateFromServer = false;
|
|
|
|
if(announcementLoaded == false) {
|
|
string announcementURL = Config::getInstance().getString("AnnouncementURL","http://master.megaglest.org/files/announcement.txt");
|
|
if(announcementURL != "") {
|
|
|
|
safeMutex.ReleaseLock(true);
|
|
CURL *handle = SystemFlags::initHTTP();
|
|
std::string announcementTxt = SystemFlags::getHTTP(announcementURL,handle);
|
|
SystemFlags::cleanupHTTP(&handle);
|
|
if(callingThread->getQuitStatus() == true) {
|
|
return;
|
|
}
|
|
safeMutex.Lock();
|
|
|
|
if(StartsWith(announcementTxt,"Announcement from Masterserver:") == true) {
|
|
int newlineCount=0;
|
|
size_t lastIndex=0;
|
|
|
|
//announcementLabel.setText(announcementTxt);
|
|
consoleIRC.addLine(announcementTxt, true, Vec3f(1.0f,1.0f,0.0f));
|
|
|
|
while(true) {
|
|
lastIndex=announcementTxt.find("\n",lastIndex+1);
|
|
if(lastIndex==string::npos) {
|
|
break;
|
|
}
|
|
else {
|
|
newlineCount++;
|
|
}
|
|
}
|
|
newlineCount--;// remove my own line
|
|
for( int i=0; i< newlineCount;++i ) {
|
|
consoleIRC.addLine("");
|
|
}
|
|
}
|
|
}
|
|
consoleIRC.addLine("---------------------------------------------");
|
|
string versionURL = Config::getInstance().getString("VersionURL","http://master.megaglest.org/files/versions/")+glestVersionString+".txt";
|
|
//printf("\nversionURL=%s\n",versionURL.c_str());
|
|
if(versionURL != "") {
|
|
safeMutex.ReleaseLock(true);
|
|
CURL *handle = SystemFlags::initHTTP();
|
|
std::string versionTxt = SystemFlags::getHTTP(versionURL,handle);
|
|
SystemFlags::cleanupHTTP(&handle);
|
|
if(callingThread->getQuitStatus() == true) {
|
|
return;
|
|
}
|
|
safeMutex.Lock();
|
|
|
|
if(StartsWith(versionTxt,"Version info:") == true) {
|
|
int newlineCount=0;
|
|
size_t lastIndex=0;
|
|
|
|
//versionInfoLabel.setText(versionTxt);
|
|
consoleIRC.addLine(versionTxt, true, Vec3f(1.0f,0.0f,0.0f));
|
|
|
|
while(true) {
|
|
lastIndex=versionTxt.find("\n",lastIndex+1);
|
|
if(lastIndex==string::npos) {
|
|
break;
|
|
}
|
|
else {
|
|
newlineCount++;
|
|
}
|
|
}
|
|
newlineCount--;// remove my own line
|
|
for( int i=0; i< newlineCount;++i ) {
|
|
consoleIRC.addLine("");
|
|
}
|
|
}
|
|
}
|
|
consoleIRC.addLine("---------------------------------------------");
|
|
// write hint to console:
|
|
Config &configKeys = Config::getInstance(std::pair<ConfigType,ConfigType>(cfgMainKeys,cfgUserKeys));
|
|
consoleIRC.addLine(Lang::getInstance().getString("ToSwitchOffMusicPress")+" - \""+configKeys.getString("ToggleMusic")+"\"");
|
|
|
|
announcementLoaded=true;
|
|
}
|
|
|
|
//Lang &lang= Lang::getInstance();
|
|
try {
|
|
if(Config::getInstance().getString("Masterserver","") != "") {
|
|
|
|
safeMutex.ReleaseLock(true);
|
|
CURL *handle = SystemFlags::initHTTP();
|
|
|
|
string playerUUID = "?uuid=" + SystemFlags::escapeURL(Config::getInstance().getString("PlayerId",""));
|
|
|
|
string baseURL = Config::getInstance().getString("Masterserver");
|
|
if(baseURL != "") {
|
|
endPathWithSlash(baseURL,false);
|
|
}
|
|
|
|
std::string localServerInfoString = SystemFlags::getHTTP(baseURL + "showServersForGlest.php" + playerUUID,handle);
|
|
SystemFlags::cleanupHTTP(&handle);
|
|
if(callingThread->getQuitStatus() == true) {
|
|
return;
|
|
}
|
|
safeMutex.Lock();
|
|
|
|
serverInfoString=localServerInfoString;
|
|
}
|
|
}
|
|
catch(const exception &ex) {
|
|
serverInfoString=ex.what();
|
|
SystemFlags::OutputDebug(SystemFlags::debugError,"In [%s::%s Line %d] error during Internet game status update: [%s]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__,ex.what());
|
|
}
|
|
}
|
|
catch(const exception &e){
|
|
SystemFlags::OutputDebug(SystemFlags::debugError,"In [%s::%s Line: %d] Error [%s]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__,e.what());
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s] Line: %d, error [%s]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__,e.what());
|
|
threadedErrorMsg = e.what();
|
|
}
|
|
}
|
|
}
|
|
|
|
void MenuStateMasterserver::rebuildServerLines(const string &serverInfo) {
|
|
int numberOfOldServerLines = (int)serverLines.size();
|
|
clearServerLines();
|
|
Lang &lang= Lang::getInstance();
|
|
try {
|
|
if(serverInfo != "") {
|
|
if(SystemFlags::VERBOSE_MODE_ENABLED) printf("--------------> serverInfo [%s]\n",serverInfo.c_str());
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
|
|
std::vector<std::string> serverList;
|
|
Tokenize(serverInfo,serverList,"\n");
|
|
for(int i = 0; i < (int)serverList.size(); i++) {
|
|
string &server = serverList[i];
|
|
if(trim(server) == "") {
|
|
continue;
|
|
}
|
|
std::vector<std::string> serverEntities;
|
|
Tokenize(server,serverEntities,"|");
|
|
const int MIN_FIELDS_EXPECTED = 14;
|
|
|
|
if(SystemFlags::VERBOSE_MODE_ENABLED) printf("--------------> server [%s] serverEntities.size() = " MG_SIZE_T_SPECIFIER " MIN_FIELDS_EXPECTED = %d\n",server.c_str(),serverEntities.size(),MIN_FIELDS_EXPECTED);
|
|
|
|
if((int)serverEntities.size() >= MIN_FIELDS_EXPECTED) {
|
|
labelTitle.setText(lang.getString("AvailableServers"));
|
|
|
|
if(Config::getInstance().getString("Masterserver","") == "") {
|
|
labelTitle.setText("*** " + lang.getString("AvailableServers"));
|
|
}
|
|
|
|
MasterServerInfo *masterServerInfo=new MasterServerInfo();
|
|
|
|
//general info:
|
|
masterServerInfo->setGlestVersion(serverEntities[0]);
|
|
masterServerInfo->setPlatform(serverEntities[1]);
|
|
masterServerInfo->setBinaryCompileDate(serverEntities[2]);
|
|
|
|
//game info:
|
|
masterServerInfo->setServerTitle(serverEntities[3]);
|
|
masterServerInfo->setIpAddress(serverEntities[4]);
|
|
|
|
//game setup info:
|
|
masterServerInfo->setTech(serverEntities[5]);
|
|
masterServerInfo->setMap(serverEntities[6]);
|
|
masterServerInfo->setTileset(serverEntities[7]);
|
|
masterServerInfo->setActiveSlots(strToInt(serverEntities[8]));
|
|
masterServerInfo->setNetworkSlots(strToInt(serverEntities[9]));
|
|
masterServerInfo->setConnectedClients(strToInt(serverEntities[10]));
|
|
masterServerInfo->setExternalConnectPort(strToInt(serverEntities[11]));
|
|
masterServerInfo->setCountry(serverEntities[12]);
|
|
masterServerInfo->setStatus(strToInt(serverEntities[13]));
|
|
|
|
//printf("--------------> Country [%s] Status [%d]\n",masterServerInfo->getCountry().c_str(),masterServerInfo->getStatus());
|
|
|
|
//printf("Getting Ping time for host %s\n",masterServerInfo->getIpAddress().c_str());
|
|
//float pingTime = Socket::getAveragePingMS(masterServerInfo->getIpAddress().c_str(),1);
|
|
//printf("Ping time = %f\n",pingTime);
|
|
char szBuf[8096]="";
|
|
snprintf(szBuf,8096,"%s",masterServerInfo->getServerTitle().c_str());
|
|
masterServerInfo->setServerTitle(szBuf);
|
|
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
|
|
serverLines.push_back(new ServerLine( masterServerInfo, i, serverLinesYBase, serverLinesLineHeight, containerName));
|
|
delete masterServerInfo;
|
|
}
|
|
else {
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
|
|
Lang &lang= Lang::getInstance();
|
|
labelTitle.setText("*** " + lang.getString("AvailableServers") + "[" + intToStr(serverEntities.size()) + "][" + intToStr(MIN_FIELDS_EXPECTED) + "] [" + serverInfo + "]");
|
|
|
|
if(masterserverParseErrorShown == false) {
|
|
masterserverParseErrorShown = true;
|
|
SystemFlags::OutputDebug(SystemFlags::debugError,"In [%s::%s Line %d] error, no masterserver defined!\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
}
|
|
}
|
|
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
}
|
|
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s Line: %d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__);
|
|
}
|
|
|
|
}
|
|
catch(const exception &ex) {
|
|
labelTitle.setText("*** " + lang.getString("AvailableServers") + " [" + ex.what() + "]");
|
|
SystemFlags::OutputDebug(SystemFlags::debugError,"In [%s::%s Line %d] error during Internet game status update: [%s]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__,ex.what());
|
|
}
|
|
|
|
if((int)serverLines.size() > numberOfOldServerLines) {
|
|
playServerFoundSound = true;
|
|
}
|
|
}
|
|
|
|
|
|
bool MenuStateMasterserver::connectToServer(string ipString, int port) {
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s] START ipString='%s'\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,ipString.c_str());
|
|
|
|
ClientInterface* clientInterface= NetworkManager::getInstance().getClientInterface();
|
|
//Config& config= Config::getInstance();
|
|
Ip serverIp(ipString);
|
|
|
|
//int serverPort = Config::getInstance().getInt("PortServer",intToStr(GameConstants::serverPort).c_str());
|
|
int serverPort = port;
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s] try to connect to [%s] serverPort = %d\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,serverIp.getString().c_str(),serverPort);
|
|
clientInterface->connect(serverIp, serverPort);
|
|
if(clientInterface->isConnected() == false) {
|
|
NetworkManager::getInstance().end();
|
|
NetworkManager::getInstance().init(nrClient);
|
|
|
|
mainMessageBoxState=1;
|
|
Lang &lang= Lang::getInstance();
|
|
showMessageBox(lang.getString("CouldNotConnect"), lang.getString("ConnectionFailed"), false);
|
|
return false;
|
|
|
|
//if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s] connection failed\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__);
|
|
}
|
|
else {
|
|
if(SystemFlags::getSystemSettingType(SystemFlags::debugSystem).enabled) SystemFlags::OutputDebug(SystemFlags::debugSystem,"In [%s::%s] connected to [%s]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,serverIp.getString().c_str());
|
|
|
|
//save server ip
|
|
//config.setString("ServerIp", serverIp.getString());
|
|
//config.save();
|
|
|
|
for(time_t elapsedWait = time(NULL);
|
|
clientInterface->getIntroDone() == false &&
|
|
clientInterface->isConnected() &&
|
|
difftime(time(NULL),elapsedWait) <= 8;) {
|
|
if(clientInterface->isConnected()) {
|
|
//update lobby
|
|
clientInterface->updateLobby();
|
|
sleep(0);
|
|
//this->render();
|
|
}
|
|
}
|
|
if( clientInterface->isConnected() == true &&
|
|
clientInterface->getIntroDone() == true) {
|
|
return true;
|
|
}
|
|
|
|
return false;
|
|
}
|
|
}
|
|
|
|
void MenuStateMasterserver::showMessageBox(const string &text, const string &header, bool toggle){
|
|
if(!toggle){
|
|
mainMessageBox.setEnabled(false);
|
|
}
|
|
|
|
if(!mainMessageBox.getEnabled()){
|
|
mainMessageBox.setText(text);
|
|
mainMessageBox.setHeader(header);
|
|
mainMessageBox.setEnabled(true);
|
|
}
|
|
else{
|
|
mainMessageBox.setEnabled(false);
|
|
}
|
|
}
|
|
|
|
|
|
bool MenuStateMasterserver::textInput(std::string text) {
|
|
if (ircClient != NULL && ircClient->isConnected() == true
|
|
&& ircClient->getHasJoinedChannel() == true) {
|
|
return chatManager.textInput(text);
|
|
}
|
|
return false;
|
|
}
|
|
|
|
void MenuStateMasterserver::keyDown(SDL_KeyboardEvent key) {
|
|
//printf("In [%s::%s Line: %d] key [%d]\n",extractFileFromDirectoryPath(__FILE__).c_str(),__FUNCTION__,__LINE__,key.keysym.sym);
|
|
|
|
Config &configKeys = Config::getInstance(std::pair<ConfigType,ConfigType>(cfgMainKeys,cfgUserKeys));
|
|
|
|
if (ircClient != NULL && ircClient->isConnected() == true
|
|
&& ircClient->getHasJoinedChannel() == true) {
|
|
//chatmanger only if connected to irc!
|
|
if (chatManager.getEditEnabled() == true) {
|
|
//printf("keyDown key [%d] chatManager.getText() [%s]\n",key,chatManager.getText().c_str());
|
|
MutexSafeWrapper safeMutexIRCPtr(mutexIRCClient,string(extractFileFromDirectoryPath(__FILE__).c_str()) + "_" + intToStr(__LINE__));
|
|
//if (key == vkReturn && ircClient != NULL) {
|
|
if(isKeyPressed(SDLK_RETURN,key,false) == true && ircClient != NULL) {
|
|
ircClient->SendIRCCmdMessage(IRC_CHANNEL, chatManager.getText());
|
|
}
|
|
}
|
|
chatManager.keyDown(key);
|
|
}
|
|
if(chatManager.getEditEnabled() == false) {
|
|
//if(key == configKeys.getCharKey("ToggleMusic")) {
|
|
if(isKeyPressed(configKeys.getSDLKey("ToggleMusic"),key) == true) {
|
|
Config &config = Config::getInstance();
|
|
Lang &lang= Lang::getInstance();
|
|
|
|
float configVolume = (config.getInt("SoundVolumeMusic") / 100.f);
|
|
float currentVolume = CoreData::getInstance().getMenuMusic()->getVolume();
|
|
if(currentVolume > 0) {
|
|
CoreData::getInstance().getMenuMusic()->setVolume(0.f);
|
|
consoleIRC.addLine(lang.getString("GameMusic") + " " + lang.getString("Off"));
|
|
}
|
|
else {
|
|
CoreData::getInstance().getMenuMusic()->setVolume(configVolume);
|
|
//If the config says zero, use the default music volume
|
|
//gameMusic->setVolume(configVolume ? configVolume : 0.9);
|
|
consoleIRC.addLine(lang.getString("GameMusic"));
|
|
}
|
|
}
|
|
//else if(key == configKeys.getCharKey("SaveGUILayout")) {
|
|
else if(isKeyPressed(configKeys.getSDLKey("SaveGUILayout"),key) == true) {
|
|
bool saved = GraphicComponent::saveAllCustomProperties(containerName);
|
|
Lang &lang= Lang::getInstance();
|
|
consoleIRC.addLine(lang.getString("GUILayoutSaved") + " [" + (saved ? lang.getString("Yes") : lang.getString("No"))+ "]");
|
|
}
|
|
}
|
|
}
|
|
|
|
}}//end namespace
|