12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997 |
- /*
- Minetest
- Copyright (C) 2013 celeron55, Perttu Ahola <celeron55@gmail.com>
- This program is free software; you can redistribute it and/or modify
- it under the terms of the GNU Lesser General Public License as published by
- the Free Software Foundation; either version 2.1 of the License, or
- (at your option) 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 Lesser General Public License for more details.
- You should have received a copy of the GNU Lesser General Public License along
- with this program; if not, write to the Free Software Foundation, Inc.,
- 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
- */
- #include <iostream>
- #include <algorithm>
- #include <sstream>
- #include <cmath>
- #include <IFileSystem.h>
- #include "client.h"
- #include "network/clientopcodes.h"
- #include "network/connection.h"
- #include "network/networkpacket.h"
- #include "threading/mutex_auto_lock.h"
- #include "client/clientevent.h"
- #include "client/renderingengine.h"
- #include "util/auth.h"
- #include "util/directiontables.h"
- #include "util/pointedthing.h"
- #include "util/serialize.h"
- #include "util/string.h"
- #include "util/srp.h"
- #include "filesys.h"
- #include "mapblock_mesh.h"
- #include "mapblock.h"
- #include "minimap.h"
- #include "mods.h"
- #include "profiler.h"
- #include "shader.h"
- #include "gettext.h"
- #include "clientmap.h"
- #include "clientmedia.h"
- #include "version.h"
- #include "database-sqlite3.h"
- #include "serialization.h"
- #include "guiscalingfilter.h"
- #include "script/scripting_client.h"
- #include "game.h"
- #include "chatmessage.h"
- #include "translation.h"
- extern gui::IGUIEnvironment* guienv;
- /*
- Client
- */
- Client::Client(
- const char *playername,
- const std::string &password,
- const std::string &address_name,
- MapDrawControl &control,
- IWritableTextureSource *tsrc,
- IWritableShaderSource *shsrc,
- IWritableItemDefManager *itemdef,
- IWritableNodeDefManager *nodedef,
- ISoundManager *sound,
- MtEventManager *event,
- bool ipv6,
- GameUIFlags *game_ui_flags
- ):
- m_tsrc(tsrc),
- m_shsrc(shsrc),
- m_itemdef(itemdef),
- m_nodedef(nodedef),
- m_sound(sound),
- m_event(event),
- m_mesh_update_thread(this),
- m_env(
- new ClientMap(this, control, 666),
- tsrc, this
- ),
- m_particle_manager(&m_env),
- m_con(new con::Connection(PROTOCOL_ID, 512, CONNECTION_TIMEOUT, ipv6, this)),
- m_address_name(address_name),
- m_server_ser_ver(SER_FMT_VER_INVALID),
- m_last_chat_message_sent(time(NULL)),
- m_password(password),
- m_chosen_auth_mech(AUTH_MECHANISM_NONE),
- m_media_downloader(new ClientMediaDownloader()),
- m_state(LC_Created),
- m_game_ui_flags(game_ui_flags)
- {
- // Add local player
- m_env.setLocalPlayer(new LocalPlayer(this, playername));
- if (g_settings->getBool("enable_minimap")) {
- m_minimap = new Minimap(this);
- }
- m_cache_save_interval = g_settings->getU16("server_map_save_interval");
- m_modding_enabled = g_settings->getBool("enable_client_modding");
- m_script = new ClientScripting(this);
- m_env.setScript(m_script);
- m_script->setEnv(&m_env);
- }
- void Client::loadMods()
- {
- // Load builtin
- scanModIntoMemory(BUILTIN_MOD_NAME, getBuiltinLuaPath());
- // If modding is not enabled, don't load mods, just builtin
- if (!m_modding_enabled) {
- return;
- }
- ClientModConfiguration modconf(getClientModsLuaPath());
- m_mods = modconf.getMods();
- std::vector<ModSpec> unsatisfied_mods = modconf.getUnsatisfiedMods();
- // complain about mods with unsatisfied dependencies
- if (!modconf.isConsistent()) {
- modconf.printUnsatisfiedModsError();
- }
- // Print mods
- infostream << "Client Loading mods: ";
- for (const ModSpec &mod : m_mods)
- infostream << mod.name << " ";
- infostream << std::endl;
- // Load and run "mod" scripts
- for (const ModSpec &mod : m_mods) {
- if (!string_allowed(mod.name, MODNAME_ALLOWED_CHARS)) {
- throw ModError("Error loading mod \"" + mod.name +
- "\": Mod name does not follow naming conventions: "
- "Only characters [a-z0-9_] are allowed.");
- }
- scanModIntoMemory(mod.name, mod.path);
- }
- }
- void Client::scanModSubfolder(const std::string &mod_name, const std::string &mod_path,
- std::string mod_subpath)
- {
- std::string full_path = mod_path + DIR_DELIM + mod_subpath;
- std::vector<fs::DirListNode> mod = fs::GetDirListing(full_path);
- for (const fs::DirListNode &j : mod) {
- std::string filename = j.name;
- if (j.dir) {
- scanModSubfolder(mod_name, mod_path, mod_subpath
- + filename + DIR_DELIM);
- continue;
- }
- std::replace( mod_subpath.begin(), mod_subpath.end(), DIR_DELIM_CHAR, '/');
- m_mod_files[mod_name + ":" + mod_subpath + filename] = full_path + filename;
- }
- }
- void Client::initMods()
- {
- m_script->loadModFromMemory(BUILTIN_MOD_NAME);
- // If modding is not enabled, don't load mods, just builtin
- if (!m_modding_enabled) {
- return;
- }
- // Load and run "mod" scripts
- for (const ModSpec &mod : m_mods)
- m_script->loadModFromMemory(mod.name);
- }
- const std::string &Client::getBuiltinLuaPath()
- {
- static const std::string builtin_dir = porting::path_share + DIR_DELIM + "builtin";
- return builtin_dir;
- }
- const std::string &Client::getClientModsLuaPath()
- {
- static const std::string clientmods_dir = porting::path_share + DIR_DELIM + "clientmods";
- return clientmods_dir;
- }
- const std::vector<ModSpec>& Client::getMods() const
- {
- static std::vector<ModSpec> client_modspec_temp;
- return client_modspec_temp;
- }
- const ModSpec* Client::getModSpec(const std::string &modname) const
- {
- return NULL;
- }
- void Client::Stop()
- {
- m_shutdown = true;
- // Don't disable this part when modding is disabled, it's used in builtin
- m_script->on_shutdown();
- //request all client managed threads to stop
- m_mesh_update_thread.stop();
- // Save local server map
- if (m_localdb) {
- infostream << "Local map saving ended." << std::endl;
- m_localdb->endSave();
- }
- delete m_script;
- }
- bool Client::isShutdown()
- {
- return m_shutdown || !m_mesh_update_thread.isRunning();
- }
- Client::~Client()
- {
- m_shutdown = true;
- m_con->Disconnect();
- m_mesh_update_thread.stop();
- m_mesh_update_thread.wait();
- while (!m_mesh_update_thread.m_queue_out.empty()) {
- MeshUpdateResult r = m_mesh_update_thread.m_queue_out.pop_frontNoEx();
- delete r.mesh;
- }
- delete m_inventory_from_server;
- // Delete detached inventories
- for (auto &m_detached_inventorie : m_detached_inventories) {
- delete m_detached_inventorie.second;
- }
- // cleanup 3d model meshes on client shutdown
- while (RenderingEngine::get_mesh_cache()->getMeshCount() != 0) {
- scene::IAnimatedMesh *mesh = RenderingEngine::get_mesh_cache()->getMeshByIndex(0);
- if (mesh)
- RenderingEngine::get_mesh_cache()->removeMesh(mesh);
- }
- delete m_minimap;
- }
- void Client::connect(Address address, bool is_local_server)
- {
- initLocalMapSaving(address, m_address_name, is_local_server);
- m_con->SetTimeoutMs(0);
- m_con->Connect(address);
- }
- void Client::step(float dtime)
- {
- // Limit a bit
- if(dtime > 2.0)
- dtime = 2.0;
- if(m_ignore_damage_timer > dtime)
- m_ignore_damage_timer -= dtime;
- else
- m_ignore_damage_timer = 0.0;
- m_animation_time += dtime;
- if(m_animation_time > 60.0)
- m_animation_time -= 60.0;
- m_time_of_day_update_timer += dtime;
- ReceiveAll();
- /*
- Packet counter
- */
- {
- float &counter = m_packetcounter_timer;
- counter -= dtime;
- if(counter <= 0.0)
- {
- counter = 20.0;
- infostream << "Client packetcounter (" << m_packetcounter_timer
- << "):"<<std::endl;
- m_packetcounter.print(infostream);
- m_packetcounter.clear();
- }
- }
- // UGLY hack to fix 2 second startup delay caused by non existent
- // server client startup synchronization in local server or singleplayer mode
- static bool initial_step = true;
- if (initial_step) {
- initial_step = false;
- }
- else if(m_state == LC_Created) {
- float &counter = m_connection_reinit_timer;
- counter -= dtime;
- if(counter <= 0.0) {
- counter = 2.0;
- LocalPlayer *myplayer = m_env.getLocalPlayer();
- FATAL_ERROR_IF(myplayer == NULL, "Local player not found in environment.");
- u16 proto_version_min = g_settings->getFlag("send_pre_v25_init") ?
- CLIENT_PROTOCOL_VERSION_MIN_LEGACY : CLIENT_PROTOCOL_VERSION_MIN;
- if (proto_version_min < 25) {
- // Send TOSERVER_INIT_LEGACY
- // [0] u16 TOSERVER_INIT_LEGACY
- // [2] u8 SER_FMT_VER_HIGHEST_READ
- // [3] u8[20] player_name
- // [23] u8[28] password (new in some version)
- // [51] u16 minimum supported network protocol version (added sometime)
- // [53] u16 maximum supported network protocol version (added later than the previous one)
- char pName[PLAYERNAME_SIZE];
- char pPassword[PASSWORD_SIZE];
- memset(pName, 0, PLAYERNAME_SIZE * sizeof(char));
- memset(pPassword, 0, PASSWORD_SIZE * sizeof(char));
- std::string hashed_password = translate_password(myplayer->getName(), m_password);
- snprintf(pName, PLAYERNAME_SIZE, "%s", myplayer->getName());
- snprintf(pPassword, PASSWORD_SIZE, "%s", hashed_password.c_str());
- sendLegacyInit(pName, pPassword);
- }
- if (CLIENT_PROTOCOL_VERSION_MAX >= 25)
- sendInit(myplayer->getName());
- }
- // Not connected, return
- return;
- }
- /*
- Do stuff if connected
- */
- /*
- Run Map's timers and unload unused data
- */
- const float map_timer_and_unload_dtime = 5.25;
- if(m_map_timer_and_unload_interval.step(dtime, map_timer_and_unload_dtime)) {
- ScopeProfiler sp(g_profiler, "Client: map timer and unload");
- std::vector<v3s16> deleted_blocks;
- m_env.getMap().timerUpdate(map_timer_and_unload_dtime,
- g_settings->getFloat("client_unload_unused_data_timeout"),
- g_settings->getS32("client_mapblock_limit"),
- &deleted_blocks);
- /*
- Send info to server
- NOTE: This loop is intentionally iterated the way it is.
- */
- std::vector<v3s16>::iterator i = deleted_blocks.begin();
- std::vector<v3s16> sendlist;
- for(;;) {
- if(sendlist.size() == 255 || i == deleted_blocks.end()) {
- if(sendlist.empty())
- break;
- /*
- [0] u16 command
- [2] u8 count
- [3] v3s16 pos_0
- [3+6] v3s16 pos_1
- ...
- */
- sendDeletedBlocks(sendlist);
- if(i == deleted_blocks.end())
- break;
- sendlist.clear();
- }
- sendlist.push_back(*i);
- ++i;
- }
- }
- /*
- Send pending messages on out chat queue
- */
- if (!m_out_chat_queue.empty() && canSendChatMessage()) {
- sendChatMessage(m_out_chat_queue.front());
- m_out_chat_queue.pop();
- }
- /*
- Handle environment
- */
- // Control local player (0ms)
- LocalPlayer *player = m_env.getLocalPlayer();
- assert(player);
- player->applyControl(dtime, &m_env);
- // Step environment
- m_env.step(dtime);
- m_sound->step(dtime);
- /*
- Get events
- */
- while (m_env.hasClientEnvEvents()) {
- ClientEnvEvent envEvent = m_env.getClientEnvEvent();
- if (envEvent.type == CEE_PLAYER_DAMAGE) {
- if (m_ignore_damage_timer <= 0) {
- u8 damage = envEvent.player_damage.amount;
- if (envEvent.player_damage.send_to_server)
- sendDamage(damage);
- // Add to ClientEvent queue
- ClientEvent *event = new ClientEvent();
- event->type = CE_PLAYER_DAMAGE;
- event->player_damage.amount = damage;
- m_client_event_queue.push(event);
- }
- }
- // Protocol v29 or greater obsoleted this event
- else if (envEvent.type == CEE_PLAYER_BREATH && m_proto_ver < 29) {
- u16 breath = envEvent.player_breath.amount;
- sendBreath(breath);
- }
- }
- /*
- Print some info
- */
- float &counter = m_avg_rtt_timer;
- counter += dtime;
- if(counter >= 10) {
- counter = 0.0;
- // connectedAndInitialized() is true, peer exists.
- float avg_rtt = getRTT();
- infostream << "Client: avg_rtt=" << avg_rtt << std::endl;
- }
- /*
- Send player position to server
- */
- {
- float &counter = m_playerpos_send_timer;
- counter += dtime;
- if((m_state == LC_Ready) && (counter >= m_recommended_send_interval))
- {
- counter = 0.0;
- sendPlayerPos();
- }
- }
- /*
- Replace updated meshes
- */
- {
- int num_processed_meshes = 0;
- while (!m_mesh_update_thread.m_queue_out.empty())
- {
- num_processed_meshes++;
- MinimapMapblock *minimap_mapblock = NULL;
- bool do_mapper_update = true;
- MeshUpdateResult r = m_mesh_update_thread.m_queue_out.pop_frontNoEx();
- MapBlock *block = m_env.getMap().getBlockNoCreateNoEx(r.p);
- if (block) {
- // Delete the old mesh
- delete block->mesh;
- block->mesh = nullptr;
- if (r.mesh) {
- minimap_mapblock = r.mesh->moveMinimapMapblock();
- if (minimap_mapblock == NULL)
- do_mapper_update = false;
- bool is_empty = true;
- for (int l = 0; l < MAX_TILE_LAYERS; l++)
- if (r.mesh->getMesh(l)->getMeshBufferCount() != 0)
- is_empty = false;
- if (is_empty)
- delete r.mesh;
- else
- // Replace with the new mesh
- block->mesh = r.mesh;
- }
- } else {
- delete r.mesh;
- }
- if (m_minimap && do_mapper_update)
- m_minimap->addBlock(r.p, minimap_mapblock);
- if (r.ack_block_to_server) {
- /*
- Acknowledge block
- [0] u8 count
- [1] v3s16 pos_0
- */
- sendGotBlocks(r.p);
- }
- }
- if (num_processed_meshes > 0)
- g_profiler->graphAdd("num_processed_meshes", num_processed_meshes);
- }
- /*
- Load fetched media
- */
- if (m_media_downloader && m_media_downloader->isStarted()) {
- m_media_downloader->step(this);
- if (m_media_downloader->isDone()) {
- delete m_media_downloader;
- m_media_downloader = NULL;
- }
- }
- /*
- If the server didn't update the inventory in a while, revert
- the local inventory (so the player notices the lag problem
- and knows something is wrong).
- */
- if(m_inventory_from_server)
- {
- float interval = 10.0;
- float count_before = floor(m_inventory_from_server_age / interval);
- m_inventory_from_server_age += dtime;
- float count_after = floor(m_inventory_from_server_age / interval);
- if(count_after != count_before)
- {
- // Do this every <interval> seconds after TOCLIENT_INVENTORY
- // Reset the locally changed inventory to the authoritative inventory
- LocalPlayer *player = m_env.getLocalPlayer();
- player->inventory = *m_inventory_from_server;
- m_inventory_updated = true;
- }
- }
- /*
- Update positions of sounds attached to objects
- */
- {
- for (auto &m_sounds_to_object : m_sounds_to_objects) {
- int client_id = m_sounds_to_object.first;
- u16 object_id = m_sounds_to_object.second;
- ClientActiveObject *cao = m_env.getActiveObject(object_id);
- if (!cao)
- continue;
- m_sound->updateSoundPosition(client_id, cao->getPosition());
- }
- }
- /*
- Handle removed remotely initiated sounds
- */
- m_removed_sounds_check_timer += dtime;
- if(m_removed_sounds_check_timer >= 2.32) {
- m_removed_sounds_check_timer = 0;
- // Find removed sounds and clear references to them
- std::vector<s32> removed_server_ids;
- for (std::unordered_map<s32, int>::iterator i = m_sounds_server_to_client.begin();
- i != m_sounds_server_to_client.end();) {
- s32 server_id = i->first;
- int client_id = i->second;
- ++i;
- if(!m_sound->soundExists(client_id)) {
- m_sounds_server_to_client.erase(server_id);
- m_sounds_client_to_server.erase(client_id);
- m_sounds_to_objects.erase(client_id);
- removed_server_ids.push_back(server_id);
- }
- }
- // Sync to server
- if(!removed_server_ids.empty()) {
- sendRemovedSounds(removed_server_ids);
- }
- }
- m_mod_storage_save_timer -= dtime;
- if (m_mod_storage_save_timer <= 0.0f) {
- verbosestream << "Saving registered mod storages." << std::endl;
- m_mod_storage_save_timer = g_settings->getFloat("server_map_save_interval");
- for (std::unordered_map<std::string, ModMetadata *>::const_iterator
- it = m_mod_storages.begin(); it != m_mod_storages.end(); ++it) {
- if (it->second->isModified()) {
- it->second->save(getModStoragePath());
- }
- }
- }
- // Write server map
- if (m_localdb && m_localdb_save_interval.step(dtime,
- m_cache_save_interval)) {
- m_localdb->endSave();
- m_localdb->beginSave();
- }
- }
- bool Client::loadMedia(const std::string &data, const std::string &filename)
- {
- // Silly irrlicht's const-incorrectness
- Buffer<char> data_rw(data.c_str(), data.size());
- std::string name;
- const char *image_ext[] = {
- ".png", ".jpg", ".bmp", ".tga",
- ".pcx", ".ppm", ".psd", ".wal", ".rgb",
- NULL
- };
- name = removeStringEnd(filename, image_ext);
- if (!name.empty()) {
- verbosestream<<"Client: Attempting to load image "
- <<"file \""<<filename<<"\""<<std::endl;
- io::IFileSystem *irrfs = RenderingEngine::get_filesystem();
- video::IVideoDriver *vdrv = RenderingEngine::get_video_driver();
- // Create an irrlicht memory file
- io::IReadFile *rfile = irrfs->createMemoryReadFile(
- *data_rw, data_rw.getSize(), "_tempreadfile");
- FATAL_ERROR_IF(!rfile, "Could not create irrlicht memory file.");
- // Read image
- video::IImage *img = vdrv->createImageFromFile(rfile);
- if (!img) {
- errorstream<<"Client: Cannot create image from data of "
- <<"file \""<<filename<<"\""<<std::endl;
- rfile->drop();
- return false;
- }
- m_tsrc->insertSourceImage(filename, img);
- img->drop();
- rfile->drop();
- return true;
- }
- const char *sound_ext[] = {
- ".0.ogg", ".1.ogg", ".2.ogg", ".3.ogg", ".4.ogg",
- ".5.ogg", ".6.ogg", ".7.ogg", ".8.ogg", ".9.ogg",
- ".ogg", NULL
- };
- name = removeStringEnd(filename, sound_ext);
- if (!name.empty()) {
- verbosestream<<"Client: Attempting to load sound "
- <<"file \""<<filename<<"\""<<std::endl;
- m_sound->loadSoundData(name, data);
- return true;
- }
- const char *model_ext[] = {
- ".x", ".b3d", ".md2", ".obj",
- NULL
- };
- name = removeStringEnd(filename, model_ext);
- if (!name.empty()) {
- verbosestream<<"Client: Storing model into memory: "
- <<"\""<<filename<<"\""<<std::endl;
- if(m_mesh_data.count(filename))
- errorstream<<"Multiple models with name \""<<filename.c_str()
- <<"\" found; replacing previous model"<<std::endl;
- m_mesh_data[filename] = data;
- return true;
- }
- const char *translate_ext[] = {
- ".tr", NULL
- };
- name = removeStringEnd(filename, translate_ext);
- if (!name.empty()) {
- verbosestream << "Client: Loading translation: "
- << "\"" << filename << "\"" << std::endl;
- g_translations->loadTranslation(data);
- return true;
- }
- errorstream << "Client: Don't know how to load file \""
- << filename << "\"" << std::endl;
- return false;
- }
- // Virtual methods from con::PeerHandler
- void Client::peerAdded(con::Peer *peer)
- {
- infostream << "Client::peerAdded(): peer->id="
- << peer->id << std::endl;
- }
- void Client::deletingPeer(con::Peer *peer, bool timeout)
- {
- infostream << "Client::deletingPeer(): "
- "Server Peer is getting deleted "
- << "(timeout=" << timeout << ")" << std::endl;
- if (timeout) {
- m_access_denied = true;
- m_access_denied_reason = gettext("Connection timed out.");
- }
- }
- /*
- u16 command
- u16 number of files requested
- for each file {
- u16 length of name
- string name
- }
- */
- void Client::request_media(const std::vector<std::string> &file_requests)
- {
- std::ostringstream os(std::ios_base::binary);
- writeU16(os, TOSERVER_REQUEST_MEDIA);
- size_t file_requests_size = file_requests.size();
- FATAL_ERROR_IF(file_requests_size > 0xFFFF, "Unsupported number of file requests");
- // Packet dynamicly resized
- NetworkPacket pkt(TOSERVER_REQUEST_MEDIA, 2 + 0);
- pkt << (u16) (file_requests_size & 0xFFFF);
- for (const std::string &file_request : file_requests) {
- pkt << file_request;
- }
- Send(&pkt);
- infostream << "Client: Sending media request list to server ("
- << file_requests.size() << " files. packet size)" << std::endl;
- }
- void Client::initLocalMapSaving(const Address &address,
- const std::string &hostname,
- bool is_local_server)
- {
- if (!g_settings->getBool("enable_local_map_saving") || is_local_server) {
- return;
- }
- const std::string world_path = porting::path_user
- + DIR_DELIM + "worlds"
- + DIR_DELIM + "server_"
- + hostname + "_" + std::to_string(address.getPort());
- fs::CreateAllDirs(world_path);
- m_localdb = new MapDatabaseSQLite3(world_path);
- m_localdb->beginSave();
- actionstream << "Local map saving started, map will be saved at '" << world_path << "'" << std::endl;
- }
- void Client::ReceiveAll()
- {
- u64 start_ms = porting::getTimeMs();
- for(;;)
- {
- // Limit time even if there would be huge amounts of data to
- // process
- if(porting::getTimeMs() > start_ms + 100)
- break;
- try {
- Receive();
- g_profiler->graphAdd("client_received_packets", 1);
- }
- catch(con::NoIncomingDataException &e) {
- break;
- }
- catch(con::InvalidIncomingDataException &e) {
- infostream<<"Client::ReceiveAll(): "
- "InvalidIncomingDataException: what()="
- <<e.what()<<std::endl;
- }
- }
- }
- void Client::Receive()
- {
- NetworkPacket pkt;
- m_con->Receive(&pkt);
- ProcessData(&pkt);
- }
- inline void Client::handleCommand(NetworkPacket* pkt)
- {
- const ToClientCommandHandler& opHandle = toClientCommandTable[pkt->getCommand()];
- (this->*opHandle.handler)(pkt);
- }
- /*
- sender_peer_id given to this shall be quaranteed to be a valid peer
- */
- void Client::ProcessData(NetworkPacket *pkt)
- {
- ToClientCommand command = (ToClientCommand) pkt->getCommand();
- u32 sender_peer_id = pkt->getPeerId();
- //infostream<<"Client: received command="<<command<<std::endl;
- m_packetcounter.add((u16)command);
- /*
- If this check is removed, be sure to change the queue
- system to know the ids
- */
- if(sender_peer_id != PEER_ID_SERVER) {
- infostream << "Client::ProcessData(): Discarding data not "
- "coming from server: peer_id=" << sender_peer_id
- << std::endl;
- return;
- }
- // Command must be handled into ToClientCommandHandler
- if (command >= TOCLIENT_NUM_MSG_TYPES) {
- infostream << "Client: Ignoring unknown command "
- << command << std::endl;
- return;
- }
- /*
- * Those packets are handled before m_server_ser_ver is set, it's normal
- * But we must use the new ToClientConnectionState in the future,
- * as a byte mask
- */
- if(toClientCommandTable[command].state == TOCLIENT_STATE_NOT_CONNECTED) {
- handleCommand(pkt);
- return;
- }
- if(m_server_ser_ver == SER_FMT_VER_INVALID) {
- infostream << "Client: Server serialization"
- " format invalid or not initialized."
- " Skipping incoming command=" << command << std::endl;
- return;
- }
- /*
- Handle runtime commands
- */
- handleCommand(pkt);
- }
- void Client::Send(NetworkPacket* pkt)
- {
- m_con->Send(PEER_ID_SERVER,
- serverCommandFactoryTable[pkt->getCommand()].channel,
- pkt,
- serverCommandFactoryTable[pkt->getCommand()].reliable);
- }
- // Will fill up 12 + 12 + 4 + 4 + 4 bytes
- void writePlayerPos(LocalPlayer *myplayer, ClientMap *clientMap, NetworkPacket *pkt)
- {
- v3f pf = myplayer->getPosition() * 100;
- v3f sf = myplayer->getSpeed() * 100;
- s32 pitch = myplayer->getPitch() * 100;
- s32 yaw = myplayer->getYaw() * 100;
- u32 keyPressed = myplayer->keyPressed;
- // scaled by 80, so that pi can fit into a u8
- u8 fov = clientMap->getCameraFov() * 80;
- u8 wanted_range = MYMIN(255,
- std::ceil(clientMap->getControl().wanted_range / MAP_BLOCKSIZE));
- v3s32 position(pf.X, pf.Y, pf.Z);
- v3s32 speed(sf.X, sf.Y, sf.Z);
- /*
- Format:
- [0] v3s32 position*100
- [12] v3s32 speed*100
- [12+12] s32 pitch*100
- [12+12+4] s32 yaw*100
- [12+12+4+4] u32 keyPressed
- [12+12+4+4+4] u8 fov*80
- [12+12+4+4+4+1] u8 ceil(wanted_range / MAP_BLOCKSIZE)
- */
- *pkt << position << speed << pitch << yaw << keyPressed;
- *pkt << fov << wanted_range;
- }
- void Client::interact(u8 action, const PointedThing& pointed)
- {
- if(m_state != LC_Ready) {
- errorstream << "Client::interact() "
- "Canceled (not connected)"
- << std::endl;
- return;
- }
- LocalPlayer *myplayer = m_env.getLocalPlayer();
- if (myplayer == NULL)
- return;
- /*
- [0] u16 command
- [2] u8 action
- [3] u16 item
- [5] u32 length of the next item (plen)
- [9] serialized PointedThing
- [9 + plen] player position information
- actions:
- 0: start digging (from undersurface) or use
- 1: stop digging (all parameters ignored)
- 2: digging completed
- 3: place block or item (to abovesurface)
- 4: use item
- 5: perform secondary action of item
- */
- NetworkPacket pkt(TOSERVER_INTERACT, 1 + 2 + 0);
- pkt << action;
- pkt << (u16)getPlayerItem();
- std::ostringstream tmp_os(std::ios::binary);
- pointed.serialize(tmp_os);
- pkt.putLongString(tmp_os.str());
- writePlayerPos(myplayer, &m_env.getClientMap(), &pkt);
- Send(&pkt);
- }
- void Client::deleteAuthData()
- {
- if (!m_auth_data)
- return;
- switch (m_chosen_auth_mech) {
- case AUTH_MECHANISM_FIRST_SRP:
- break;
- case AUTH_MECHANISM_SRP:
- case AUTH_MECHANISM_LEGACY_PASSWORD:
- srp_user_delete((SRPUser *) m_auth_data);
- m_auth_data = NULL;
- break;
- case AUTH_MECHANISM_NONE:
- break;
- }
- m_chosen_auth_mech = AUTH_MECHANISM_NONE;
- }
- AuthMechanism Client::choseAuthMech(const u32 mechs)
- {
- if (mechs & AUTH_MECHANISM_SRP)
- return AUTH_MECHANISM_SRP;
- if (mechs & AUTH_MECHANISM_FIRST_SRP)
- return AUTH_MECHANISM_FIRST_SRP;
- if (mechs & AUTH_MECHANISM_LEGACY_PASSWORD)
- return AUTH_MECHANISM_LEGACY_PASSWORD;
- return AUTH_MECHANISM_NONE;
- }
- void Client::sendLegacyInit(const char* playerName, const char* playerPassword)
- {
- NetworkPacket pkt(TOSERVER_INIT_LEGACY,
- 1 + PLAYERNAME_SIZE + PASSWORD_SIZE + 2 + 2);
- u16 proto_version_min = g_settings->getFlag("send_pre_v25_init") ?
- CLIENT_PROTOCOL_VERSION_MIN_LEGACY : CLIENT_PROTOCOL_VERSION_MIN;
- pkt << (u8) SER_FMT_VER_HIGHEST_READ;
- pkt.putRawString(playerName,PLAYERNAME_SIZE);
- pkt.putRawString(playerPassword, PASSWORD_SIZE);
- pkt << (u16) proto_version_min << (u16) CLIENT_PROTOCOL_VERSION_MAX;
- Send(&pkt);
- }
- void Client::sendInit(const std::string &playerName)
- {
- NetworkPacket pkt(TOSERVER_INIT, 1 + 2 + 2 + (1 + playerName.size()));
- // we don't support network compression yet
- u16 supp_comp_modes = NETPROTO_COMPRESSION_NONE;
- u16 proto_version_min = g_settings->getFlag("send_pre_v25_init") ?
- CLIENT_PROTOCOL_VERSION_MIN_LEGACY : CLIENT_PROTOCOL_VERSION_MIN;
- pkt << (u8) SER_FMT_VER_HIGHEST_READ << (u16) supp_comp_modes;
- pkt << (u16) proto_version_min << (u16) CLIENT_PROTOCOL_VERSION_MAX;
- pkt << playerName;
- Send(&pkt);
- }
- void Client::startAuth(AuthMechanism chosen_auth_mechanism)
- {
- m_chosen_auth_mech = chosen_auth_mechanism;
- switch (chosen_auth_mechanism) {
- case AUTH_MECHANISM_FIRST_SRP: {
- // send srp verifier to server
- std::string verifier;
- std::string salt;
- generate_srp_verifier_and_salt(getPlayerName(), m_password,
- &verifier, &salt);
- NetworkPacket resp_pkt(TOSERVER_FIRST_SRP, 0);
- resp_pkt << salt << verifier << (u8)((m_password.empty()) ? 1 : 0);
- Send(&resp_pkt);
- break;
- }
- case AUTH_MECHANISM_SRP:
- case AUTH_MECHANISM_LEGACY_PASSWORD: {
- u8 based_on = 1;
- if (chosen_auth_mechanism == AUTH_MECHANISM_LEGACY_PASSWORD) {
- m_password = translate_password(getPlayerName(), m_password);
- based_on = 0;
- }
- std::string playername_u = lowercase(getPlayerName());
- m_auth_data = srp_user_new(SRP_SHA256, SRP_NG_2048,
- getPlayerName().c_str(), playername_u.c_str(),
- (const unsigned char *) m_password.c_str(),
- m_password.length(), NULL, NULL);
- char *bytes_A = 0;
- size_t len_A = 0;
- SRP_Result res = srp_user_start_authentication(
- (struct SRPUser *) m_auth_data, NULL, NULL, 0,
- (unsigned char **) &bytes_A, &len_A);
- FATAL_ERROR_IF(res != SRP_OK, "Creating local SRP user failed.");
- NetworkPacket resp_pkt(TOSERVER_SRP_BYTES_A, 0);
- resp_pkt << std::string(bytes_A, len_A) << based_on;
- Send(&resp_pkt);
- break;
- }
- case AUTH_MECHANISM_NONE:
- break; // not handled in this method
- }
- }
- void Client::sendDeletedBlocks(std::vector<v3s16> &blocks)
- {
- NetworkPacket pkt(TOSERVER_DELETEDBLOCKS, 1 + sizeof(v3s16) * blocks.size());
- pkt << (u8) blocks.size();
- for (const v3s16 &block : blocks) {
- pkt << block;
- }
- Send(&pkt);
- }
- void Client::sendGotBlocks(v3s16 block)
- {
- NetworkPacket pkt(TOSERVER_GOTBLOCKS, 1 + 6);
- pkt << (u8) 1 << block;
- Send(&pkt);
- }
- void Client::sendRemovedSounds(std::vector<s32> &soundList)
- {
- size_t server_ids = soundList.size();
- assert(server_ids <= 0xFFFF);
- NetworkPacket pkt(TOSERVER_REMOVED_SOUNDS, 2 + server_ids * 4);
- pkt << (u16) (server_ids & 0xFFFF);
- for (int sound_id : soundList)
- pkt << sound_id;
- Send(&pkt);
- }
- void Client::sendNodemetaFields(v3s16 p, const std::string &formname,
- const StringMap &fields)
- {
- size_t fields_size = fields.size();
- FATAL_ERROR_IF(fields_size > 0xFFFF, "Unsupported number of nodemeta fields");
- NetworkPacket pkt(TOSERVER_NODEMETA_FIELDS, 0);
- pkt << p << formname << (u16) (fields_size & 0xFFFF);
- StringMap::const_iterator it;
- for (it = fields.begin(); it != fields.end(); ++it) {
- const std::string &name = it->first;
- const std::string &value = it->second;
- pkt << name;
- pkt.putLongString(value);
- }
- Send(&pkt);
- }
- void Client::sendInventoryFields(const std::string &formname,
- const StringMap &fields)
- {
- size_t fields_size = fields.size();
- FATAL_ERROR_IF(fields_size > 0xFFFF, "Unsupported number of inventory fields");
- NetworkPacket pkt(TOSERVER_INVENTORY_FIELDS, 0);
- pkt << formname << (u16) (fields_size & 0xFFFF);
- StringMap::const_iterator it;
- for (it = fields.begin(); it != fields.end(); ++it) {
- const std::string &name = it->first;
- const std::string &value = it->second;
- pkt << name;
- pkt.putLongString(value);
- }
- Send(&pkt);
- }
- void Client::sendInventoryAction(InventoryAction *a)
- {
- std::ostringstream os(std::ios_base::binary);
- a->serialize(os);
- // Make data buffer
- std::string s = os.str();
- NetworkPacket pkt(TOSERVER_INVENTORY_ACTION, s.size());
- pkt.putRawString(s.c_str(),s.size());
- Send(&pkt);
- }
- bool Client::canSendChatMessage() const
- {
- u32 now = time(NULL);
- float time_passed = now - m_last_chat_message_sent;
- float virt_chat_message_allowance = m_chat_message_allowance + time_passed *
- (CLIENT_CHAT_MESSAGE_LIMIT_PER_10S / 8.0f);
- if (virt_chat_message_allowance < 1.0f)
- return false;
- return true;
- }
- void Client::sendChatMessage(const std::wstring &message)
- {
- const s16 max_queue_size = g_settings->getS16("max_out_chat_queue_size");
- if (canSendChatMessage()) {
- u32 now = time(NULL);
- float time_passed = now - m_last_chat_message_sent;
- m_last_chat_message_sent = time(NULL);
- m_chat_message_allowance += time_passed * (CLIENT_CHAT_MESSAGE_LIMIT_PER_10S / 8.0f);
- if (m_chat_message_allowance > CLIENT_CHAT_MESSAGE_LIMIT_PER_10S)
- m_chat_message_allowance = CLIENT_CHAT_MESSAGE_LIMIT_PER_10S;
- m_chat_message_allowance -= 1.0f;
- NetworkPacket pkt(TOSERVER_CHAT_MESSAGE, 2 + message.size() * sizeof(u16));
- pkt << message;
- Send(&pkt);
- } else if (m_out_chat_queue.size() < (u16) max_queue_size || max_queue_size == -1) {
- m_out_chat_queue.push(message);
- } else {
- infostream << "Could not queue chat message because maximum out chat queue size ("
- << max_queue_size << ") is reached." << std::endl;
- }
- }
- void Client::clearOutChatQueue()
- {
- m_out_chat_queue = std::queue<std::wstring>();
- }
- void Client::sendChangePassword(const std::string &oldpassword,
- const std::string &newpassword)
- {
- LocalPlayer *player = m_env.getLocalPlayer();
- if (player == NULL)
- return;
- std::string playername = player->getName();
- if (m_proto_ver >= 25) {
- // get into sudo mode and then send new password to server
- m_password = oldpassword;
- m_new_password = newpassword;
- startAuth(choseAuthMech(m_sudo_auth_methods));
- } else {
- std::string oldpwd = translate_password(playername, oldpassword);
- std::string newpwd = translate_password(playername, newpassword);
- NetworkPacket pkt(TOSERVER_PASSWORD_LEGACY, 2 * PASSWORD_SIZE);
- for (u8 i = 0; i < PASSWORD_SIZE; i++) {
- pkt << (u8) (i < oldpwd.length() ? oldpwd[i] : 0);
- }
- for (u8 i = 0; i < PASSWORD_SIZE; i++) {
- pkt << (u8) (i < newpwd.length() ? newpwd[i] : 0);
- }
- Send(&pkt);
- }
- }
- void Client::sendDamage(u8 damage)
- {
- NetworkPacket pkt(TOSERVER_DAMAGE, sizeof(u8));
- pkt << damage;
- Send(&pkt);
- }
- void Client::sendBreath(u16 breath)
- {
- // Protocol v29 make this obsolete
- if (m_proto_ver >= 29)
- return;
- NetworkPacket pkt(TOSERVER_BREATH, sizeof(u16));
- pkt << breath;
- Send(&pkt);
- }
- void Client::sendRespawn()
- {
- NetworkPacket pkt(TOSERVER_RESPAWN, 0);
- Send(&pkt);
- }
- void Client::sendReady()
- {
- NetworkPacket pkt(TOSERVER_CLIENT_READY,
- 1 + 1 + 1 + 1 + 2 + sizeof(char) * strlen(g_version_hash));
- pkt << (u8) VERSION_MAJOR << (u8) VERSION_MINOR << (u8) VERSION_PATCH
- << (u8) 0 << (u16) strlen(g_version_hash);
- pkt.putRawString(g_version_hash, (u16) strlen(g_version_hash));
- Send(&pkt);
- }
- void Client::sendPlayerPos()
- {
- LocalPlayer *myplayer = m_env.getLocalPlayer();
- if(myplayer == NULL)
- return;
- ClientMap &map = m_env.getClientMap();
- u8 camera_fov = map.getCameraFov();
- u8 wanted_range = map.getControl().wanted_range;
- // Save bandwidth by only updating position when something changed
- if(myplayer->last_position == myplayer->getPosition() &&
- myplayer->last_speed == myplayer->getSpeed() &&
- myplayer->last_pitch == myplayer->getPitch() &&
- myplayer->last_yaw == myplayer->getYaw() &&
- myplayer->last_keyPressed == myplayer->keyPressed &&
- myplayer->last_camera_fov == camera_fov &&
- myplayer->last_wanted_range == wanted_range)
- return;
- myplayer->last_position = myplayer->getPosition();
- myplayer->last_speed = myplayer->getSpeed();
- myplayer->last_pitch = myplayer->getPitch();
- myplayer->last_yaw = myplayer->getYaw();
- myplayer->last_keyPressed = myplayer->keyPressed;
- myplayer->last_camera_fov = camera_fov;
- myplayer->last_wanted_range = wanted_range;
- //infostream << "Sending Player Position information" << std::endl;
- u16 our_peer_id;
- {
- //MutexAutoLock lock(m_con_mutex); //bulk comment-out
- our_peer_id = m_con->GetPeerID();
- }
- // Set peer id if not set already
- if(myplayer->peer_id == PEER_ID_INEXISTENT)
- myplayer->peer_id = our_peer_id;
- assert(myplayer->peer_id == our_peer_id);
- NetworkPacket pkt(TOSERVER_PLAYERPOS, 12 + 12 + 4 + 4 + 4 + 1 + 1);
- writePlayerPos(myplayer, &map, &pkt);
- Send(&pkt);
- }
- void Client::sendPlayerItem(u16 item)
- {
- LocalPlayer *myplayer = m_env.getLocalPlayer();
- if(myplayer == NULL)
- return;
- u16 our_peer_id = m_con->GetPeerID();
- // Set peer id if not set already
- if(myplayer->peer_id == PEER_ID_INEXISTENT)
- myplayer->peer_id = our_peer_id;
- assert(myplayer->peer_id == our_peer_id);
- NetworkPacket pkt(TOSERVER_PLAYERITEM, 2);
- pkt << item;
- Send(&pkt);
- }
- void Client::removeNode(v3s16 p)
- {
- std::map<v3s16, MapBlock*> modified_blocks;
- try {
- m_env.getMap().removeNodeAndUpdate(p, modified_blocks);
- }
- catch(InvalidPositionException &e) {
- }
- for (const auto &modified_block : modified_blocks) {
- addUpdateMeshTaskWithEdge(modified_block.first, false, true);
- }
- }
- /**
- * Helper function for Client Side Modding
- * Flavour is applied there, this should not be used for core engine
- * @param p
- * @param is_valid_position
- * @return
- */
- MapNode Client::getNode(v3s16 p, bool *is_valid_position)
- {
- if (checkCSMFlavourLimit(CSMFlavourLimit::CSM_FL_LOOKUP_NODES)) {
- v3s16 ppos = floatToInt(m_env.getLocalPlayer()->getPosition(), BS);
- if ((u32) ppos.getDistanceFrom(p) > m_csm_noderange_limit) {
- *is_valid_position = false;
- return {};
- }
- }
- return m_env.getMap().getNodeNoEx(p, is_valid_position);
- }
- void Client::addNode(v3s16 p, MapNode n, bool remove_metadata)
- {
- //TimeTaker timer1("Client::addNode()");
- std::map<v3s16, MapBlock*> modified_blocks;
- try {
- //TimeTaker timer3("Client::addNode(): addNodeAndUpdate");
- m_env.getMap().addNodeAndUpdate(p, n, modified_blocks, remove_metadata);
- }
- catch(InvalidPositionException &e) {
- }
- for (const auto &modified_block : modified_blocks) {
- addUpdateMeshTaskWithEdge(modified_block.first, false, true);
- }
- }
- void Client::setPlayerControl(PlayerControl &control)
- {
- LocalPlayer *player = m_env.getLocalPlayer();
- assert(player);
- player->control = control;
- }
- void Client::selectPlayerItem(u16 item)
- {
- m_playeritem = item;
- m_inventory_updated = true;
- sendPlayerItem(item);
- }
- // Returns true if the inventory of the local player has been
- // updated from the server. If it is true, it is set to false.
- bool Client::getLocalInventoryUpdated()
- {
- bool updated = m_inventory_updated;
- m_inventory_updated = false;
- return updated;
- }
- // Copies the inventory of the local player to parameter
- void Client::getLocalInventory(Inventory &dst)
- {
- LocalPlayer *player = m_env.getLocalPlayer();
- assert(player);
- dst = player->inventory;
- }
- Inventory* Client::getInventory(const InventoryLocation &loc)
- {
- switch(loc.type){
- case InventoryLocation::UNDEFINED:
- {}
- break;
- case InventoryLocation::CURRENT_PLAYER:
- {
- LocalPlayer *player = m_env.getLocalPlayer();
- assert(player);
- return &player->inventory;
- }
- break;
- case InventoryLocation::PLAYER:
- {
- // Check if we are working with local player inventory
- LocalPlayer *player = m_env.getLocalPlayer();
- if (!player || strcmp(player->getName(), loc.name.c_str()) != 0)
- return NULL;
- return &player->inventory;
- }
- break;
- case InventoryLocation::NODEMETA:
- {
- NodeMetadata *meta = m_env.getMap().getNodeMetadata(loc.p);
- if(!meta)
- return NULL;
- return meta->getInventory();
- }
- break;
- case InventoryLocation::DETACHED:
- {
- if (m_detached_inventories.count(loc.name) == 0)
- return NULL;
- return m_detached_inventories[loc.name];
- }
- break;
- default:
- FATAL_ERROR("Invalid inventory location type.");
- break;
- }
- return NULL;
- }
- void Client::inventoryAction(InventoryAction *a)
- {
- /*
- Send it to the server
- */
- sendInventoryAction(a);
- /*
- Predict some local inventory changes
- */
- a->clientApply(this, this);
- // Remove it
- delete a;
- }
- float Client::getAnimationTime()
- {
- return m_animation_time;
- }
- int Client::getCrackLevel()
- {
- return m_crack_level;
- }
- v3s16 Client::getCrackPos()
- {
- return m_crack_pos;
- }
- void Client::setCrack(int level, v3s16 pos)
- {
- int old_crack_level = m_crack_level;
- v3s16 old_crack_pos = m_crack_pos;
- m_crack_level = level;
- m_crack_pos = pos;
- if(old_crack_level >= 0 && (level < 0 || pos != old_crack_pos))
- {
- // remove old crack
- addUpdateMeshTaskForNode(old_crack_pos, false, true);
- }
- if(level >= 0 && (old_crack_level < 0 || pos != old_crack_pos))
- {
- // add new crack
- addUpdateMeshTaskForNode(pos, false, true);
- }
- }
- u16 Client::getHP()
- {
- LocalPlayer *player = m_env.getLocalPlayer();
- assert(player);
- return player->hp;
- }
- bool Client::getChatMessage(std::wstring &res)
- {
- if (m_chat_queue.empty())
- return false;
- ChatMessage *chatMessage = m_chat_queue.front();
- m_chat_queue.pop();
- res = L"";
- switch (chatMessage->type) {
- case CHATMESSAGE_TYPE_RAW:
- case CHATMESSAGE_TYPE_ANNOUNCE:
- case CHATMESSAGE_TYPE_SYSTEM:
- res = chatMessage->message;
- break;
- case CHATMESSAGE_TYPE_NORMAL: {
- if (!chatMessage->sender.empty())
- res = L"<" + chatMessage->sender + L"> " + chatMessage->message;
- else
- res = chatMessage->message;
- break;
- }
- default:
- break;
- }
- delete chatMessage;
- return true;
- }
- void Client::typeChatMessage(const std::wstring &message)
- {
- // Discard empty line
- if (message.empty())
- return;
- // If message was ate by script API, don't send it to server
- if (m_script->on_sending_message(wide_to_utf8(message))) {
- return;
- }
- // Send to others
- sendChatMessage(message);
- // Show locally
- if (message[0] != L'/') {
- // compatibility code
- if (m_proto_ver < 29) {
- LocalPlayer *player = m_env.getLocalPlayer();
- assert(player);
- std::wstring name = narrow_to_wide(player->getName());
- pushToChatQueue(new ChatMessage(CHATMESSAGE_TYPE_NORMAL, message, name));
- }
- }
- }
- void Client::addUpdateMeshTask(v3s16 p, bool ack_to_server, bool urgent)
- {
- // Check if the block exists to begin with. In the case when a non-existing
- // neighbor is automatically added, it may not. In that case we don't want
- // to tell the mesh update thread about it.
- MapBlock *b = m_env.getMap().getBlockNoCreateNoEx(p);
- if (b == NULL)
- return;
- m_mesh_update_thread.updateBlock(&m_env.getMap(), p, ack_to_server, urgent);
- }
- void Client::addUpdateMeshTaskWithEdge(v3s16 blockpos, bool ack_to_server, bool urgent)
- {
- try{
- addUpdateMeshTask(blockpos, ack_to_server, urgent);
- }
- catch(InvalidPositionException &e){}
- // Leading edge
- for (int i=0;i<6;i++)
- {
- try{
- v3s16 p = blockpos + g_6dirs[i];
- addUpdateMeshTask(p, false, urgent);
- }
- catch(InvalidPositionException &e){}
- }
- }
- void Client::addUpdateMeshTaskForNode(v3s16 nodepos, bool ack_to_server, bool urgent)
- {
- {
- v3s16 p = nodepos;
- infostream<<"Client::addUpdateMeshTaskForNode(): "
- <<"("<<p.X<<","<<p.Y<<","<<p.Z<<")"
- <<std::endl;
- }
- v3s16 blockpos = getNodeBlockPos(nodepos);
- v3s16 blockpos_relative = blockpos * MAP_BLOCKSIZE;
- try{
- addUpdateMeshTask(blockpos, ack_to_server, urgent);
- }
- catch(InvalidPositionException &e) {}
- // Leading edge
- if(nodepos.X == blockpos_relative.X){
- try{
- v3s16 p = blockpos + v3s16(-1,0,0);
- addUpdateMeshTask(p, false, urgent);
- }
- catch(InvalidPositionException &e){}
- }
- if(nodepos.Y == blockpos_relative.Y){
- try{
- v3s16 p = blockpos + v3s16(0,-1,0);
- addUpdateMeshTask(p, false, urgent);
- }
- catch(InvalidPositionException &e){}
- }
- if(nodepos.Z == blockpos_relative.Z){
- try{
- v3s16 p = blockpos + v3s16(0,0,-1);
- addUpdateMeshTask(p, false, urgent);
- }
- catch(InvalidPositionException &e){}
- }
- }
- ClientEvent *Client::getClientEvent()
- {
- FATAL_ERROR_IF(m_client_event_queue.empty(),
- "Cannot getClientEvent, queue is empty.");
- ClientEvent *event = m_client_event_queue.front();
- m_client_event_queue.pop();
- return event;
- }
- bool Client::connectedToServer()
- {
- return m_con->Connected();
- }
- const Address Client::getServerAddress()
- {
- return m_con->GetPeerAddress(PEER_ID_SERVER);
- }
- float Client::mediaReceiveProgress()
- {
- if (m_media_downloader)
- return m_media_downloader->getProgress();
- return 1.0; // downloader only exists when not yet done
- }
- typedef struct TextureUpdateArgs {
- gui::IGUIEnvironment *guienv;
- u64 last_time_ms;
- u16 last_percent;
- const wchar_t* text_base;
- ITextureSource *tsrc;
- } TextureUpdateArgs;
- void texture_update_progress(void *args, u32 progress, u32 max_progress)
- {
- TextureUpdateArgs* targs = (TextureUpdateArgs*) args;
- u16 cur_percent = ceil(progress / (double) max_progress * 100.);
- // update the loading menu -- if neccessary
- bool do_draw = false;
- u64 time_ms = targs->last_time_ms;
- if (cur_percent != targs->last_percent) {
- targs->last_percent = cur_percent;
- time_ms = porting::getTimeMs();
- // only draw when the user will notice something:
- do_draw = (time_ms - targs->last_time_ms > 100);
- }
- if (do_draw) {
- targs->last_time_ms = time_ms;
- std::basic_stringstream<wchar_t> strm;
- strm << targs->text_base << " " << targs->last_percent << "%...";
- RenderingEngine::draw_load_screen(strm.str(), targs->guienv, targs->tsrc, 0,
- 72 + (u16) ((18. / 100.) * (double) targs->last_percent), true);
- }
- }
- void Client::afterContentReceived()
- {
- infostream<<"Client::afterContentReceived() started"<<std::endl;
- assert(m_itemdef_received); // pre-condition
- assert(m_nodedef_received); // pre-condition
- assert(mediaReceived()); // pre-condition
- const wchar_t* text = wgettext("Loading textures...");
- // Clear cached pre-scaled 2D GUI images, as this cache
- // might have images with the same name but different
- // content from previous sessions.
- guiScalingCacheClear();
- // Rebuild inherited images and recreate textures
- infostream<<"- Rebuilding images and textures"<<std::endl;
- RenderingEngine::draw_load_screen(text, guienv, m_tsrc, 0, 70);
- m_tsrc->rebuildImagesAndTextures();
- delete[] text;
- // Rebuild shaders
- infostream<<"- Rebuilding shaders"<<std::endl;
- text = wgettext("Rebuilding shaders...");
- RenderingEngine::draw_load_screen(text, guienv, m_tsrc, 0, 71);
- m_shsrc->rebuildShaders();
- delete[] text;
- // Update node aliases
- infostream<<"- Updating node aliases"<<std::endl;
- text = wgettext("Initializing nodes...");
- RenderingEngine::draw_load_screen(text, guienv, m_tsrc, 0, 72);
- m_nodedef->updateAliases(m_itemdef);
- std::string texture_path = g_settings->get("texture_path");
- if (!texture_path.empty() && fs::IsDir(texture_path))
- m_nodedef->applyTextureOverrides(texture_path + DIR_DELIM + "override.txt");
- m_nodedef->setNodeRegistrationStatus(true);
- m_nodedef->runNodeResolveCallbacks();
- delete[] text;
- // Update node textures and assign shaders to each tile
- infostream<<"- Updating node textures"<<std::endl;
- TextureUpdateArgs tu_args;
- tu_args.guienv = guienv;
- tu_args.last_time_ms = porting::getTimeMs();
- tu_args.last_percent = 0;
- tu_args.text_base = wgettext("Initializing nodes");
- tu_args.tsrc = m_tsrc;
- m_nodedef->updateTextures(this, texture_update_progress, &tu_args);
- delete[] tu_args.text_base;
- // Start mesh update thread after setting up content definitions
- infostream<<"- Starting mesh update thread"<<std::endl;
- m_mesh_update_thread.start();
- m_state = LC_Ready;
- sendReady();
- if (g_settings->getBool("enable_client_modding")) {
- m_script->on_client_ready(m_env.getLocalPlayer());
- m_script->on_connect();
- }
- text = wgettext("Done!");
- RenderingEngine::draw_load_screen(text, guienv, m_tsrc, 0, 100);
- infostream<<"Client::afterContentReceived() done"<<std::endl;
- delete[] text;
- }
- float Client::getRTT()
- {
- return m_con->getPeerStat(PEER_ID_SERVER,con::AVG_RTT);
- }
- float Client::getCurRate()
- {
- return (m_con->getLocalStat(con::CUR_INC_RATE) +
- m_con->getLocalStat(con::CUR_DL_RATE));
- }
- void Client::makeScreenshot()
- {
- irr::video::IVideoDriver *driver = RenderingEngine::get_video_driver();
- irr::video::IImage* const raw_image = driver->createScreenShot();
- if (!raw_image)
- return;
- time_t t = time(NULL);
- struct tm *tm = localtime(&t);
- char timetstamp_c[64];
- strftime(timetstamp_c, sizeof(timetstamp_c), "%Y%m%d_%H%M%S", tm);
- std::string filename_base = g_settings->get("screenshot_path")
- + DIR_DELIM
- + std::string("screenshot_")
- + std::string(timetstamp_c);
- std::string filename_ext = "." + g_settings->get("screenshot_format");
- std::string filename;
- u32 quality = (u32)g_settings->getS32("screenshot_quality");
- quality = MYMIN(MYMAX(quality, 0), 100) / 100.0 * 255;
- // Try to find a unique filename
- unsigned serial = 0;
- while (serial < SCREENSHOT_MAX_SERIAL_TRIES) {
- filename = filename_base + (serial > 0 ? ("_" + itos(serial)) : "") + filename_ext;
- std::ifstream tmp(filename.c_str());
- if (!tmp.good())
- break; // File did not apparently exist, we'll go with it
- serial++;
- }
- if (serial == SCREENSHOT_MAX_SERIAL_TRIES) {
- infostream << "Could not find suitable filename for screenshot" << std::endl;
- } else {
- irr::video::IImage* const image =
- driver->createImage(video::ECF_R8G8B8, raw_image->getDimension());
- if (image) {
- raw_image->copyTo(image);
- std::ostringstream sstr;
- if (driver->writeImageToFile(image, filename.c_str(), quality)) {
- sstr << "Saved screenshot to '" << filename << "'";
- } else {
- sstr << "Failed to save screenshot '" << filename << "'";
- }
- pushToChatQueue(new ChatMessage(CHATMESSAGE_TYPE_SYSTEM,
- narrow_to_wide(sstr.str())));
- infostream << sstr.str() << std::endl;
- image->drop();
- }
- }
- raw_image->drop();
- }
- bool Client::shouldShowMinimap() const
- {
- return !m_minimap_disabled_by_server;
- }
- void Client::pushToEventQueue(ClientEvent *event)
- {
- m_client_event_queue.push(event);
- }
- void Client::showGameChat(const bool show)
- {
- m_game_ui_flags->show_chat = show;
- }
- void Client::showGameHud(const bool show)
- {
- m_game_ui_flags->show_hud = show;
- }
- void Client::showMinimap(const bool show)
- {
- m_game_ui_flags->show_minimap = show;
- }
- void Client::showProfiler(const bool show)
- {
- m_game_ui_flags->show_profiler_graph = show;
- }
- void Client::showGameFog(const bool show)
- {
- m_game_ui_flags->force_fog_off = !show;
- }
- void Client::showGameDebug(const bool show)
- {
- m_game_ui_flags->show_debug = show;
- }
- // IGameDef interface
- // Under envlock
- IItemDefManager* Client::getItemDefManager()
- {
- return m_itemdef;
- }
- INodeDefManager* Client::getNodeDefManager()
- {
- return m_nodedef;
- }
- ICraftDefManager* Client::getCraftDefManager()
- {
- return NULL;
- //return m_craftdef;
- }
- ITextureSource* Client::getTextureSource()
- {
- return m_tsrc;
- }
- IShaderSource* Client::getShaderSource()
- {
- return m_shsrc;
- }
- u16 Client::allocateUnknownNodeId(const std::string &name)
- {
- errorstream << "Client::allocateUnknownNodeId(): "
- << "Client cannot allocate node IDs" << std::endl;
- FATAL_ERROR("Client allocated unknown node");
- return CONTENT_IGNORE;
- }
- ISoundManager* Client::getSoundManager()
- {
- return m_sound;
- }
- MtEventManager* Client::getEventManager()
- {
- return m_event;
- }
- ParticleManager* Client::getParticleManager()
- {
- return &m_particle_manager;
- }
- scene::IAnimatedMesh* Client::getMesh(const std::string &filename)
- {
- StringMap::const_iterator it = m_mesh_data.find(filename);
- if (it == m_mesh_data.end()) {
- errorstream << "Client::getMesh(): Mesh not found: \"" << filename
- << "\"" << std::endl;
- return NULL;
- }
- const std::string &data = it->second;
- // Create the mesh, remove it from cache and return it
- // This allows unique vertex colors and other properties for each instance
- Buffer<char> data_rw(data.c_str(), data.size()); // Const-incorrect Irrlicht
- io::IReadFile *rfile = RenderingEngine::get_filesystem()->createMemoryReadFile(
- *data_rw, data_rw.getSize(), filename.c_str());
- FATAL_ERROR_IF(!rfile, "Could not create/open RAM file");
- scene::IAnimatedMesh *mesh = RenderingEngine::get_scene_manager()->getMesh(rfile);
- rfile->drop();
- // NOTE: By playing with Irrlicht refcounts, maybe we could cache a bunch
- // of uniquely named instances and re-use them
- mesh->grab();
- RenderingEngine::get_mesh_cache()->removeMesh(mesh);
- return mesh;
- }
- const std::string* Client::getModFile(const std::string &filename)
- {
- StringMap::const_iterator it = m_mod_files.find(filename);
- if (it == m_mod_files.end()) {
- errorstream << "Client::getModFile(): File not found: \"" << filename
- << "\"" << std::endl;
- return NULL;
- }
- return &it->second;
- }
- bool Client::registerModStorage(ModMetadata *storage)
- {
- if (m_mod_storages.find(storage->getModName()) != m_mod_storages.end()) {
- errorstream << "Unable to register same mod storage twice. Storage name: "
- << storage->getModName() << std::endl;
- return false;
- }
- m_mod_storages[storage->getModName()] = storage;
- return true;
- }
- void Client::unregisterModStorage(const std::string &name)
- {
- std::unordered_map<std::string, ModMetadata *>::const_iterator it =
- m_mod_storages.find(name);
- if (it != m_mod_storages.end()) {
- // Save unconditionaly on unregistration
- it->second->save(getModStoragePath());
- m_mod_storages.erase(name);
- }
- }
- std::string Client::getModStoragePath() const
- {
- return porting::path_user + DIR_DELIM + "client" + DIR_DELIM + "mod_storage";
- }
|