/* * Copyright (C) 2016+ AzerothCore , released under GNU GPL v2 license, you may redistribute it and/or modify it under version 2 of the License, or (at your option), any later version. * Copyright (C) 2008-2016 TrinityCore * Copyright (C) 2005-2009 MaNGOS */ /** \file \ingroup u2w */ #include "WorldSocket.h" // must be first to make ACE happy with ACE includes in it #include "AccountMgr.h" #include "BattlegroundMgr.h" #include "Common.h" #include "DatabaseEnv.h" #include "Group.h" #include "Guild.h" #include "GuildMgr.h" #include "Log.h" #include "MapManager.h" #include "ObjectAccessor.h" #include "ObjectMgr.h" #include "Opcodes.h" #include "OutdoorPvPMgr.h" #include "PacketUtilities.h" #include "Pet.h" #include "Player.h" #include "SavingSystem.h" #include "ScriptMgr.h" #include "SocialMgr.h" #include "Transport.h" #include "Vehicle.h" #include "WardenMac.h" #include "WardenWin.h" #include "World.h" #include "WorldPacket.h" #include "WorldSession.h" #include "zlib.h" #ifdef ELUNA #include "LuaEngine.h" #endif namespace { std::string const DefaultPlayerName = ""; } bool MapSessionFilter::Process(WorldPacket* packet) { ClientOpcodeHandler const* opHandle = opcodeTable[static_cast(packet->GetOpcode())]; //let's check if our opcode can be really processed in Map::Update() if (opHandle->ProcessingPlace == PROCESS_INPLACE) return true; //we do not process thread-unsafe packets if (opHandle->ProcessingPlace == PROCESS_THREADUNSAFE) return false; Player* player = m_pSession->GetPlayer(); if (!player) return false; //in Map::Update() we do not process packets where player is not in world! return player->IsInWorld(); } //we should process ALL packets when player is not in world/logged in //OR packet handler is not thread-safe! bool WorldSessionFilter::Process(WorldPacket* packet) { ClientOpcodeHandler const* opHandle = opcodeTable[static_cast(packet->GetOpcode())]; //check if packet handler is supposed to be safe if (opHandle->ProcessingPlace == PROCESS_INPLACE) return true; //thread-unsafe packets should be processed in World::UpdateSessions() if (opHandle->ProcessingPlace == PROCESS_THREADUNSAFE) return true; //no player attached? -> our client! ^^ Player* player = m_pSession->GetPlayer(); if (!player) return true; //lets process all packets for non-in-the-world player return (player->IsInWorld() == false); } /// WorldSession constructor WorldSession::WorldSession(uint32 id, WorldSocket* sock, AccountTypes sec, uint8 expansion, time_t mute_time, LocaleConstant locale, uint32 recruiter, bool isARecruiter, bool skipQueue, uint32 TotalTime) : m_muteTime(mute_time), m_timeOutTime(0), _lastAuctionListItemsMSTime(0), _lastAuctionListOwnerItemsMSTime(0), AntiDOS(this), m_GUIDLow(0), _player(nullptr), m_Socket(sock), _security(sec), _skipQueue(skipQueue), _accountId(id), m_expansion(expansion), m_total_time(TotalTime), _logoutTime(0), m_inQueue(false), m_playerLoading(false), m_playerLogout(false), m_playerSave(false), m_sessionDbcLocale(sWorld->GetDefaultDbcLocale()), m_sessionDbLocaleIndex(locale), m_latency(0), m_TutorialsChanged(false), recruiterId(recruiter), isRecruiter(isARecruiter), m_currentVendorEntry(0), timeWhoCommandAllowed(0), _calendarEventCreationCooldown(0), _timeSyncClockDeltaQueue(6), _timeSyncClockDelta(0), _pendingTimeSyncRequests() { memset(m_Tutorials, 0, sizeof(m_Tutorials)); _warden = nullptr; _offlineTime = 0; _kicked = false; _shouldSetOfflineInDB = true; _timeSyncNextCounter = 0; _timeSyncTimer = 0; if (sock) { m_Address = sock->GetRemoteAddress(); sock->AddReference(); ResetTimeOutTime(false); LoginDatabase.PExecute("UPDATE account SET online = 1 WHERE id = %u;", GetAccountId()); } InitializeQueryCallbackParameters(); } /// WorldSession destructor WorldSession::~WorldSession() { LoginDatabase.PExecute("UPDATE account SET totaltime = %u WHERE id = %u", GetTotalTime(), GetAccountId()); ///- unload player if not unloaded if (_player) LogoutPlayer(true); /// - If have unclosed socket, close it if (m_Socket) { m_Socket->CloseSocket("WorldSession destructor"); m_Socket->RemoveReference(); m_Socket = nullptr; } if (_warden) { delete _warden; _warden = nullptr; } ///- empty incoming packet queue WorldPacket* packet = nullptr; while (_recvQueue.next(packet)) delete packet; if (GetShouldSetOfflineInDB()) LoginDatabase.PExecute("UPDATE account SET online = 0 WHERE id = %u;", GetAccountId()); // One-time query } std::string const& WorldSession::GetPlayerName() const { return _player != nullptr ? _player->GetName() : DefaultPlayerName; } std::string WorldSession::GetPlayerInfo() const { std::ostringstream ss; ss << "[Player: "; if (!m_playerLoading && _player) { ss << _player->GetName() << ' ' << _player->GetGUID().ToString() << ", "; } ss << "Account: " << GetAccountId() << "]"; return ss.str(); } /// Get player guid if available. Use for logging purposes only ObjectGuid::LowType WorldSession::GetGuidLow() const { return GetPlayer() ? GetPlayer()->GetGUID().GetCounter() : 0; } /// Send a packet to the client void WorldSession::SendPacket(WorldPacket const* packet) { if (packet->GetOpcode() == NULL_OPCODE) { LOG_ERROR("network.opcode", "%s send NULL_OPCODE", GetPlayerInfo().c_str()); return; } if (!m_Socket) return; #if defined(ENABLE_EXTRAS) && defined(ENABLE_EXTRA_LOGS) && defined(ACORE_DEBUG) // Code for network use statistic static uint64 sendPacketCount = 0; static uint64 sendPacketBytes = 0; static time_t firstTime = time(nullptr); static time_t lastTime = firstTime; // next 60 secs start time static uint64 sendLastPacketCount = 0; static uint64 sendLastPacketBytes = 0; time_t cur_time = time(nullptr); if ((cur_time - lastTime) < 60) { sendPacketCount += 1; sendPacketBytes += packet->size(); sendLastPacketCount += 1; sendLastPacketBytes += packet->size(); } else { uint64 minTime = uint64(cur_time - lastTime); uint64 fullTime = uint64(lastTime - firstTime); LOG_DEBUG("server", "Send all time packets count: " UI64FMTD " bytes: " UI64FMTD " avr.count/sec: %f avr.bytes/sec: %f time: %u", sendPacketCount, sendPacketBytes, float(sendPacketCount) / fullTime, float(sendPacketBytes) / fullTime, uint32(fullTime)); LOG_DEBUG("server", "Send last min packets count: " UI64FMTD " bytes: " UI64FMTD " avr.count/sec: %f avr.bytes/sec: %f", sendLastPacketCount, sendLastPacketBytes, float(sendLastPacketCount) / minTime, float(sendLastPacketBytes) / minTime); lastTime = cur_time; sendLastPacketCount = 1; sendLastPacketBytes = packet->wpos(); // wpos is real written size } #endif // !ACORE_DEBUG sScriptMgr->OnPacketSend(this, *packet); #ifdef ELUNA if (!sEluna->OnPacketSend(this, *packet)) return; #endif LOG_TRACE("network.opcode", "S->C: %s %s", GetPlayerInfo().c_str(), GetOpcodeNameForLogging(static_cast(packet->GetOpcode())).c_str()); if (m_Socket->SendPacket(*packet) == -1) m_Socket->CloseSocket("m_Socket->SendPacket(*packet) == -1"); } /// Add an incoming packet to the queue void WorldSession::QueuePacket(WorldPacket* new_packet) { _recvQueue.add(new_packet); } /// Logging helper for unexpected opcodes void WorldSession::LogUnexpectedOpcode(WorldPacket* packet, char const* status, const char* reason) { LOG_ERROR("network.opcode", "Received unexpected opcode %s Status: %s Reason: %s from %s", GetOpcodeNameForLogging(static_cast(packet->GetOpcode())).c_str(), status, reason, GetPlayerInfo().c_str()); } /// Logging helper for unexpected opcodes void WorldSession::LogUnprocessedTail(WorldPacket* packet) { if (!sLog->ShouldLog("network.opcode", LogLevel::LOG_LEVEL_TRACE) || packet->rpos() >= packet->wpos()) return; LOG_TRACE("network.opcode", "Unprocessed tail data (read stop at %u from %u) Opcode %s from %s", uint32(packet->rpos()), uint32(packet->wpos()), GetOpcodeNameForLogging(static_cast(packet->GetOpcode())).c_str(), GetPlayerInfo().c_str()); packet->print_storage(); } /// Update the WorldSession (triggered by World update) bool WorldSession::Update(uint32 diff, PacketFilter& updater) { if (updater.ProcessUnsafe()) { UpdateTimeOutTime(diff); /// If necessary, kick the player because the client didn't send anything for too long /// (or they've been idling in character select) if (sWorld->getBoolConfig(CONFIG_CLOSE_IDLE_CONNECTIONS) && IsConnectionIdle() && m_Socket) m_Socket->CloseSocket("Client didn't send anything for too long"); } HandleTeleportTimeout(updater.ProcessUnsafe()); uint32 _startMSTime = getMSTime(); WorldPacket* packet = nullptr; bool deletePacket = true; WorldPacket* firstDelayedPacket = nullptr; uint32 processedPackets = 0; time_t currentTime = time(nullptr); while (m_Socket && !m_Socket->IsClosed() && !_recvQueue.empty() && _recvQueue.peek(true) != firstDelayedPacket && _recvQueue.next(packet, updater)) { OpcodeClient opcode = static_cast(packet->GetOpcode()); ClientOpcodeHandler const* opHandle = opcodeTable[opcode]; try { switch (opHandle->Status) { case STATUS_LOGGEDIN: if (!_player) { // pussywizard: such packets were sent to do something for a character that has already logged out, skip them } else if (!_player->IsInWorld()) { // pussywizard: such packets may do something important and the player is just being teleported, move to the end of the queue // pussywizard: previously such were skipped, so leave it as it is xD proper code below if we wish to change that // pussywizard: requeue only important packets not related to maps (PROCESS_THREADUNSAFE) /*if (opHandle.packetProcessing == PROCESS_THREADUNSAFE) { if (!firstDelayedPacket) firstDelayedPacket = packet; deletePacket = false; QueuePacket(packet); }*/ } else if (_player->IsInWorld() && AntiDOS.EvaluateOpcode(*packet, currentTime)) { sScriptMgr->OnPacketReceive(this, *packet); #ifdef ELUNA if (!sEluna->OnPacketReceive(this, *packet)) break; #endif opHandle->Call(this, *packet); LogUnprocessedTail(packet); } break; case STATUS_TRANSFER: if (_player && !_player->IsInWorld() && AntiDOS.EvaluateOpcode(*packet, currentTime)) { sScriptMgr->OnPacketReceive(this, *packet); #ifdef ELUNA if (!sEluna->OnPacketReceive(this, *packet)) break; #endif opHandle->Call(this, *packet); LogUnprocessedTail(packet); } break; case STATUS_AUTHED: if (m_inQueue) // prevent cheating break; if (AntiDOS.EvaluateOpcode(*packet, currentTime)) { sScriptMgr->OnPacketReceive(this, *packet); #ifdef ELUNA if (!sEluna->OnPacketReceive(this, *packet)) break; #endif opHandle->Call(this, *packet); LogUnprocessedTail(packet); } break; case STATUS_NEVER: LOG_ERROR("network.opcode", "Received not allowed opcode %s from %s", GetOpcodeNameForLogging(static_cast(packet->GetOpcode())).c_str(), GetPlayerInfo().c_str()); break; case STATUS_UNHANDLED: LOG_DEBUG("network.opcode", "Received not handled opcode %s from %s", GetOpcodeNameForLogging(static_cast(packet->GetOpcode())).c_str(), GetPlayerInfo().c_str()); break; } } catch (WorldPackets::PacketArrayMaxCapacityException const& pamce) { LOG_ERROR("network", "PacketArrayMaxCapacityException: %s while parsing %s from %s.", pamce.what(), GetOpcodeNameForLogging(static_cast(packet->GetOpcode())).c_str(), GetPlayerInfo().c_str()); } catch (ByteBufferException const&) { LOG_ERROR("server", "WorldSession::Update ByteBufferException occured while parsing a packet (opcode: %u) from client %s, accountid=%i. Skipped packet.", packet->GetOpcode(), GetRemoteAddress().c_str(), GetAccountId()); if (sLog->ShouldLog("network", LogLevel::LOG_LEVEL_DEBUG)) { LOG_DEBUG("network", "Dumping error causing packet:"); packet->hexlike(); } } if (deletePacket) delete packet; deletePacket = true; #define MAX_PROCESSED_PACKETS_IN_SAME_WORLDSESSION_UPDATE 150 processedPackets++; //process only a max amout of packets in 1 Update() call. //Any leftover will be processed in next update if (processedPackets > MAX_PROCESSED_PACKETS_IN_SAME_WORLDSESSION_UPDATE) break; if (getMSTimeDiff(_startMSTime, getMSTime()) >= 3) // limit (by time) packets processed in one update, prevent DDoS break; } if (m_Socket && !m_Socket->IsClosed()) ProcessQueryCallbacks(); if (updater.ProcessUnsafe()) { if (m_Socket && !m_Socket->IsClosed() && _warden) { _warden->Update(diff); } time_t currTime = time(nullptr); if (ShouldLogOut(currTime) && !m_playerLoading) { LogoutPlayer(true); } if (m_Socket && m_Socket->IsClosed()) { m_Socket->RemoveReference(); m_Socket = nullptr; } if (!m_Socket) { return false; } } if (!updater.ProcessUnsafe()) // <=> updater is of type MapSessionFilter { // Send time sync packet every 10s. if (_timeSyncTimer > 0) { if (diff >= _timeSyncTimer) { SendTimeSync(); } else { _timeSyncTimer -= diff; } } } return true; } bool WorldSession::HandleSocketClosed() { if (m_Socket && m_Socket->IsClosed() && !IsKicked() && GetPlayer() && !PlayerLogout() && GetPlayer()->m_taxi.empty() && GetPlayer()->IsInWorld() && !World::IsStopped()) { m_Socket->RemoveReference(); m_Socket = nullptr; GetPlayer()->TradeCancel(false); return true; } return false; } bool WorldSession::IsSocketClosed() const { return !m_Socket || m_Socket->IsClosed(); } void WorldSession::HandleTeleportTimeout(bool updateInSessions) { // pussywizard: handle teleport ack timeout if (m_Socket && !m_Socket->IsClosed() && GetPlayer() && GetPlayer()->IsBeingTeleported()) { time_t currTime = time(nullptr); if (updateInSessions) // session update from World::UpdateSessions { if (GetPlayer()->IsBeingTeleportedFar() && GetPlayer()->GetSemaphoreTeleportFar() + sWorld->getIntConfig(CONFIG_TELEPORT_TIMEOUT_FAR) < currTime) while (GetPlayer() && GetPlayer()->IsBeingTeleportedFar()) HandleMoveWorldportAck(); } else // session update from Map::Update { if (GetPlayer()->IsBeingTeleportedNear() && GetPlayer()->GetSemaphoreTeleportNear() + sWorld->getIntConfig(CONFIG_TELEPORT_TIMEOUT_NEAR) < currTime) while (GetPlayer() && GetPlayer()->IsInWorld() && GetPlayer()->IsBeingTeleportedNear()) { Player* plMover = GetPlayer()->m_mover->ToPlayer(); if (!plMover) break; WorldPacket pkt(MSG_MOVE_TELEPORT_ACK, 20); pkt << plMover->GetPackGUID(); pkt << uint32(0); // flags pkt << uint32(0); // time HandleMoveTeleportAck(pkt); } } } } /// %Log the player out void WorldSession::LogoutPlayer(bool save) { // finish pending transfers before starting the logout while (_player && _player->IsBeingTeleportedFar()) HandleMoveWorldportAck(); m_playerLogout = true; m_playerSave = save; if (_player) { if (ObjectGuid lguid = _player->GetLootGUID()) DoLootRelease(lguid); ///- If the player just died before logging out, make him appear as a ghost //FIXME: logout must be delayed in case lost connection with client in time of combat if (_player->GetDeathTimer()) { _player->getHostileRefManager().deleteReferences(); _player->BuildPlayerRepop(); _player->RepopAtGraveyard(); } else if (_player->HasAuraType(SPELL_AURA_SPIRIT_OF_REDEMPTION)) { // this will kill character by SPELL_AURA_SPIRIT_OF_REDEMPTION _player->RemoveAurasByType(SPELL_AURA_MOD_SHAPESHIFT); _player->KillPlayer(); _player->BuildPlayerRepop(); _player->RepopAtGraveyard(); } else if (_player->HasPendingBind()) { _player->RepopAtGraveyard(); _player->SetPendingBind(0, 0); } // pussywizard: leave whole bg on logout (character stays ingame when necessary) // pussywizard: GetBattleground() checked inside _player->LeaveBattleground(); // pussywizard: checked first time if (!_player->IsBeingTeleportedFar() && !_player->m_InstanceValid && !_player->IsGameMaster()) _player->RepopAtGraveyard(); sOutdoorPvPMgr->HandlePlayerLeaveZone(_player, _player->GetZoneId()); // pussywizard: remove from battleground queues on logout for (int i = 0; i < PLAYER_MAX_BATTLEGROUND_QUEUES; ++i) if (BattlegroundQueueTypeId bgQueueTypeId = _player->GetBattlegroundQueueTypeId(i)) { _player->RemoveBattlegroundQueueId(bgQueueTypeId); sBattlegroundMgr->GetBattlegroundQueue(bgQueueTypeId).RemovePlayer(_player->GetGUID(), false, i); // track if player logs out after invited to join BG if (_player->IsInvitedForBattlegroundInstance()) { if (sWorld->getBoolConfig(CONFIG_BATTLEGROUND_TRACK_DESERTERS)) { PreparedStatement* stmt = CharacterDatabase.GetPreparedStatement(CHAR_INS_DESERTER_TRACK); stmt->setUInt32(0, _player->GetGUID().GetCounter()); stmt->setUInt8(1, BG_DESERTION_TYPE_INVITE_LOGOUT); CharacterDatabase.Execute(stmt); } sScriptMgr->OnBattlegroundDesertion(_player, BG_DESERTION_TYPE_INVITE_LOGOUT); } } ///- If the player is in a guild, update the guild roster and broadcast a logout message to other guild members if (Guild* guild = sGuildMgr->GetGuildById(_player->GetGuildId())) guild->HandleMemberLogout(this); ///- Remove pet _player->RemovePet(nullptr, PET_SAVE_AS_CURRENT); // pussywizard: on logout remove auras that are removed at map change (before saving to db) // there are some positive auras from boss encounters that can be kept by logging out and logging in after boss is dead, and may be used on next bosses _player->RemoveAurasWithInterruptFlags(AURA_INTERRUPT_FLAG_CHANGE_MAP); ///- If the player is in a group (or invited), remove him. If the group if then only 1 person, disband the group. _player->UninviteFromGroup(); // remove player from the group if he is: // a) in group; b) not in raid group; c) logging out normally (not being kicked or disconnected) if (_player->GetGroup() && !_player->GetGroup()->isRaidGroup() && !_player->GetGroup()->isLFGGroup() && m_Socket) _player->RemoveFromGroup(); // pussywizard: checked second time after being removed from a group if (!_player->IsBeingTeleportedFar() && !_player->m_InstanceValid && !_player->IsGameMaster()) _player->RepopAtGraveyard(); // Repop at GraveYard or other player far teleport will prevent saving player because of not present map // Teleport player immediately for correct player save while (_player && _player->IsBeingTeleportedFar()) HandleMoveWorldportAck(); ///- empty buyback items and save the player in the database // some save parts only correctly work in case player present in map/player_lists (pets, etc) SavingSystemMgr::InsertToSavingSkipListIfNeeded(_player->GetNextSave()); // pussywizard if (save) { uint32 eslot; for (int j = BUYBACK_SLOT_START; j < BUYBACK_SLOT_END; ++j) { eslot = j - BUYBACK_SLOT_START; _player->SetGuidValue(PLAYER_FIELD_VENDORBUYBACK_SLOT_1 + (eslot * 2), ObjectGuid::Empty); _player->SetUInt32Value(PLAYER_FIELD_BUYBACK_PRICE_1 + eslot, 0); _player->SetUInt32Value(PLAYER_FIELD_BUYBACK_TIMESTAMP_1 + eslot, 0); } _player->SaveToDB(false, true); } ///- Leave all channels before player delete... _player->CleanupChannels(); //! Send update to group and reset stored max enchanting level if (_player->GetGroup()) { _player->GetGroup()->SendUpdate(); _player->GetGroup()->ResetMaxEnchantingLevel(); Map::PlayerList const& playerList = _player->GetMap()->GetPlayers(); if (_player->GetMap()->IsDungeon() || _player->GetMap()->IsRaidOrHeroicDungeon()) if (playerList.isEmpty()) _player->TeleportToEntryPoint(); } //! Broadcast a logout message to the player's friends sSocialMgr->SendFriendStatus(_player, FRIEND_OFFLINE, _player->GetGUID(), true); sSocialMgr->RemovePlayerSocial(_player->GetGUID()); //! Call script hook before deletion sScriptMgr->OnPlayerLogout(_player); LOG_INFO("entities.player", "Account: %d (IP: %s) Logout Character:[%s] (%s) Level: %d", GetAccountId(), GetRemoteAddress().c_str(), _player->GetName().c_str(), _player->GetGUID().ToString().c_str(), _player->getLevel()); //! Remove the player from the world // the player may not be in the world when logging out // e.g if he got disconnected during a transfer to another map // calls to GetMap in this case may cause crashes _player->CleanupsBeforeDelete(); if (Map* _map = _player->FindMap()) { _map->RemovePlayerFromMap(_player, true); _map->AfterPlayerUnlinkFromMap(); } SetPlayer(nullptr); // pointer already deleted //! Send the 'logout complete' packet to the client //! Client will respond by sending 3x CMSG_CANCEL_TRADE, which we currently dont handle WorldPacket data(SMSG_LOGOUT_COMPLETE, 0); SendPacket(&data); #if defined(ENABLE_EXTRAS) && defined(ENABLE_EXTRA_LOGS) LOG_DEBUG("network", "SESSION: Sent SMSG_LOGOUT_COMPLETE Message"); #endif //! Since each account can only have one online character at any given time, ensure all characters for active account are marked as offline PreparedStatement* stmt = CharacterDatabase.GetPreparedStatement(CHAR_UPD_ACCOUNT_ONLINE); stmt->setUInt32(0, GetAccountId()); CharacterDatabase.Execute(stmt); } m_playerLogout = false; m_playerSave = false; LogoutRequest(0); } /// Kick a player out of the World void WorldSession::KickPlayer(std::string const& reason, bool setKicked) { if (m_Socket) m_Socket->CloseSocket(reason); if (setKicked) SetKicked(true); // pussywizard: the session won't be left ingame for 60 seconds and to also kick offline session } void WorldSession::SendNotification(const char* format, ...) { if (format) { va_list ap; char szStr[1024]; szStr[0] = '\0'; va_start(ap, format); vsnprintf(szStr, 1024, format, ap); va_end(ap); WorldPacket data(SMSG_NOTIFICATION, (strlen(szStr) + 1)); data << szStr; SendPacket(&data); } } void WorldSession::SendNotification(uint32 string_id, ...) { char const* format = GetAcoreString(string_id); if (format) { va_list ap; char szStr[1024]; szStr[0] = '\0'; va_start(ap, string_id); vsnprintf(szStr, 1024, format, ap); va_end(ap); WorldPacket data(SMSG_NOTIFICATION, (strlen(szStr) + 1)); data << szStr; SendPacket(&data); } } char const* WorldSession::GetAcoreString(uint32 entry) const { return sObjectMgr->GetAcoreString(entry, GetSessionDbLocaleIndex()); } void WorldSession::Handle_NULL(WorldPacket& null) { LOG_ERROR("network.opcode", "Received unhandled opcode %s from %s", GetOpcodeNameForLogging(static_cast(null.GetOpcode())).c_str(), GetPlayerInfo().c_str()); } void WorldSession::Handle_EarlyProccess(WorldPacket& recvPacket) { LOG_ERROR("network.opcode", "Received opcode %s that must be processed in WorldSocket::ReadDataHandler from %s", GetOpcodeNameForLogging(static_cast(recvPacket.GetOpcode())).c_str(), GetPlayerInfo().c_str()); } void WorldSession::Handle_ServerSide(WorldPacket& recvPacket) { LOG_ERROR("network.opcode", "Received server-side opcode %s from %s", GetOpcodeNameForLogging(static_cast(recvPacket.GetOpcode())).c_str(), GetPlayerInfo().c_str()); } void WorldSession::Handle_Deprecated(WorldPacket& recvPacket) { LOG_ERROR("network.opcode", "Received deprecated opcode %s from %s", GetOpcodeNameForLogging(static_cast(recvPacket.GetOpcode())).c_str(), GetPlayerInfo().c_str()); } void WorldSession::SendAuthWaitQue(uint32 position) { if (position == 0) { WorldPacket packet(SMSG_AUTH_RESPONSE, 1); packet << uint8(AUTH_OK); SendPacket(&packet); } else { WorldPacket packet(SMSG_AUTH_RESPONSE, 6); packet << uint8(AUTH_WAIT_QUEUE); packet << uint32(position); packet << uint8(0); // unk SendPacket(&packet); } } void WorldSession::LoadGlobalAccountData() { PreparedStatement* stmt = CharacterDatabase.GetPreparedStatement(CHAR_SEL_ACCOUNT_DATA); stmt->setUInt32(0, GetAccountId()); LoadAccountData(CharacterDatabase.Query(stmt), GLOBAL_CACHE_MASK); } void WorldSession::LoadAccountData(PreparedQueryResult result, uint32 mask) { for (uint32 i = 0; i < NUM_ACCOUNT_DATA_TYPES; ++i) if (mask & (1 << i)) m_accountData[i] = AccountData(); if (!result) return; do { Field* fields = result->Fetch(); uint32 type = fields[0].GetUInt8(); if (type >= NUM_ACCOUNT_DATA_TYPES) { LOG_ERROR("server", "Table `%s` have invalid account data type (%u), ignore.", mask == GLOBAL_CACHE_MASK ? "account_data" : "character_account_data", type); continue; } if ((mask & (1 << type)) == 0) { LOG_ERROR("server", "Table `%s` have non appropriate for table account data type (%u), ignore.", mask == GLOBAL_CACHE_MASK ? "account_data" : "character_account_data", type); continue; } m_accountData[type].Time = time_t(fields[1].GetUInt32()); m_accountData[type].Data = fields[2].GetString(); } while (result->NextRow()); } void WorldSession::SetAccountData(AccountDataType type, time_t tm, std::string const& data) { uint32 id = 0; uint32 index = 0; if ((1 << type) & GLOBAL_CACHE_MASK) { id = GetAccountId(); index = CHAR_REP_ACCOUNT_DATA; } else { // _player can be nullptr and packet received after logout but m_GUID still store correct guid if (!m_GUIDLow) return; id = m_GUIDLow; index = CHAR_REP_PLAYER_ACCOUNT_DATA; } PreparedStatement* stmt = CharacterDatabase.GetPreparedStatement(index); stmt->setUInt32(0, id); stmt->setUInt8(1, type); stmt->setUInt32(2, uint32(tm)); stmt->setString(3, data); CharacterDatabase.Execute(stmt); m_accountData[type].Time = tm; m_accountData[type].Data = data; } void WorldSession::SendAccountDataTimes(uint32 mask) { WorldPacket data(SMSG_ACCOUNT_DATA_TIMES, 4 + 1 + 4 + 8 * 4); // changed in WotLK data << uint32(time(nullptr)); // unix time of something data << uint8(1); data << uint32(mask); // type mask for (uint32 i = 0; i < NUM_ACCOUNT_DATA_TYPES; ++i) if (mask & (1 << i)) data << uint32(GetAccountData(AccountDataType(i))->Time);// also unix time SendPacket(&data); } void WorldSession::LoadTutorialsData() { memset(m_Tutorials, 0, sizeof(uint32) * MAX_ACCOUNT_TUTORIAL_VALUES); PreparedStatement* stmt = CharacterDatabase.GetPreparedStatement(CHAR_SEL_TUTORIALS); stmt->setUInt32(0, GetAccountId()); if (PreparedQueryResult result = CharacterDatabase.Query(stmt)) for (uint8 i = 0; i < MAX_ACCOUNT_TUTORIAL_VALUES; ++i) m_Tutorials[i] = (*result)[i].GetUInt32(); m_TutorialsChanged = false; } void WorldSession::SendTutorialsData() { WorldPacket data(SMSG_TUTORIAL_FLAGS, 4 * MAX_ACCOUNT_TUTORIAL_VALUES); for (uint8 i = 0; i < MAX_ACCOUNT_TUTORIAL_VALUES; ++i) data << m_Tutorials[i]; SendPacket(&data); } void WorldSession::SaveTutorialsData(SQLTransaction& trans) { if (!m_TutorialsChanged) return; PreparedStatement* stmt = CharacterDatabase.GetPreparedStatement(CHAR_SEL_HAS_TUTORIALS); stmt->setUInt32(0, GetAccountId()); bool hasTutorials = bool(CharacterDatabase.Query(stmt)); stmt = CharacterDatabase.GetPreparedStatement(hasTutorials ? CHAR_UPD_TUTORIALS : CHAR_INS_TUTORIALS); for (uint8 i = 0; i < MAX_ACCOUNT_TUTORIAL_VALUES; ++i) stmt->setUInt32(i, m_Tutorials[i]); stmt->setUInt32(MAX_ACCOUNT_TUTORIAL_VALUES, GetAccountId()); trans->Append(stmt); m_TutorialsChanged = false; } void WorldSession::ReadMovementInfo(WorldPacket& data, MovementInfo* mi) { data >> mi->flags; data >> mi->flags2; data >> mi->time; data >> mi->pos.PositionXYZOStream(); if (mi->HasMovementFlag(MOVEMENTFLAG_ONTRANSPORT)) { data >> mi->transport.guid.ReadAsPacked(); data >> mi->transport.pos.PositionXYZOStream(); data >> mi->transport.time; data >> mi->transport.seat; if (mi->HasExtraMovementFlag(MOVEMENTFLAG2_INTERPOLATED_MOVEMENT)) data >> mi->transport.time2; } if (mi->HasMovementFlag(MovementFlags(MOVEMENTFLAG_SWIMMING | MOVEMENTFLAG_FLYING)) || (mi->HasExtraMovementFlag(MOVEMENTFLAG2_ALWAYS_ALLOW_PITCHING))) data >> mi->pitch; data >> mi->fallTime; if (mi->HasMovementFlag(MOVEMENTFLAG_FALLING)) { data >> mi->jump.zspeed; data >> mi->jump.sinAngle; data >> mi->jump.cosAngle; data >> mi->jump.xyspeed; } if (mi->HasMovementFlag(MOVEMENTFLAG_SPLINE_ELEVATION)) data >> mi->splineElevation; //! Anti-cheat checks. Please keep them in seperate if() blocks to maintain a clear overview. //! Might be subject to latency, so just remove improper flags. #ifdef ACORE_DEBUG #define REMOVE_VIOLATING_FLAGS(check, maskToRemove) \ { \ if (check) \ { \ LOG_DEBUG("entities.unit", "WorldSession::ReadMovementInfo: Violation of MovementFlags found (%s). " \ "MovementFlags: %u, MovementFlags2: %u for player %s. Mask %u will be removed.", \ STRINGIZE(check), mi->GetMovementFlags(), mi->GetExtraMovementFlags(), GetPlayer()->GetGUID().ToString().c_str(), maskToRemove); \ mi->RemoveMovementFlag((maskToRemove)); \ } \ } #else #define REMOVE_VIOLATING_FLAGS(check, maskToRemove) \ if (check) \ mi->RemoveMovementFlag((maskToRemove)); #endif /*! This must be a packet spoofing attempt. MOVEMENTFLAG_ROOT sent from the client is not valid in conjunction with any of the moving movement flags such as MOVEMENTFLAG_FORWARD. It will freeze clients that receive this player's movement info. */ REMOVE_VIOLATING_FLAGS(mi->HasMovementFlag(MOVEMENTFLAG_ROOT), MOVEMENTFLAG_ROOT); //! Cannot hover without SPELL_AURA_HOVER REMOVE_VIOLATING_FLAGS(mi->HasMovementFlag(MOVEMENTFLAG_HOVER) && !GetPlayer()->HasAuraType(SPELL_AURA_HOVER), MOVEMENTFLAG_HOVER); //! Cannot ascend and descend at the same time REMOVE_VIOLATING_FLAGS(mi->HasMovementFlag(MOVEMENTFLAG_ASCENDING) && mi->HasMovementFlag(MOVEMENTFLAG_DESCENDING), MOVEMENTFLAG_ASCENDING | MOVEMENTFLAG_DESCENDING); //! Cannot move left and right at the same time REMOVE_VIOLATING_FLAGS(mi->HasMovementFlag(MOVEMENTFLAG_LEFT) && mi->HasMovementFlag(MOVEMENTFLAG_RIGHT), MOVEMENTFLAG_LEFT | MOVEMENTFLAG_RIGHT); //! Cannot strafe left and right at the same time REMOVE_VIOLATING_FLAGS(mi->HasMovementFlag(MOVEMENTFLAG_STRAFE_LEFT) && mi->HasMovementFlag(MOVEMENTFLAG_STRAFE_RIGHT), MOVEMENTFLAG_STRAFE_LEFT | MOVEMENTFLAG_STRAFE_RIGHT); //! Cannot pitch up and down at the same time REMOVE_VIOLATING_FLAGS(mi->HasMovementFlag(MOVEMENTFLAG_PITCH_UP) && mi->HasMovementFlag(MOVEMENTFLAG_PITCH_DOWN), MOVEMENTFLAG_PITCH_UP | MOVEMENTFLAG_PITCH_DOWN); //! Cannot move forwards and backwards at the same time REMOVE_VIOLATING_FLAGS(mi->HasMovementFlag(MOVEMENTFLAG_FORWARD) && mi->HasMovementFlag(MOVEMENTFLAG_BACKWARD), MOVEMENTFLAG_FORWARD | MOVEMENTFLAG_BACKWARD); //! Cannot walk on water without SPELL_AURA_WATER_WALK REMOVE_VIOLATING_FLAGS(mi->HasMovementFlag(MOVEMENTFLAG_WATERWALKING) && !GetPlayer()->HasAuraType(SPELL_AURA_WATER_WALK) && !GetPlayer()->HasAuraType(SPELL_AURA_GHOST), MOVEMENTFLAG_WATERWALKING); //! Cannot feather fall without SPELL_AURA_FEATHER_FALL REMOVE_VIOLATING_FLAGS(mi->HasMovementFlag(MOVEMENTFLAG_FALLING_SLOW) && !GetPlayer()->HasAuraType(SPELL_AURA_FEATHER_FALL), MOVEMENTFLAG_FALLING_SLOW); /*! Cannot fly if no fly auras present. Exception is being a GM. Note that we check for account level instead of Player::IsGameMaster() because in some situations it may be feasable to use .gm fly on as a GM without having .gm on, e.g. aerial combat. */ REMOVE_VIOLATING_FLAGS(mi->HasMovementFlag(MOVEMENTFLAG_FLYING | MOVEMENTFLAG_CAN_FLY) && GetSecurity() == SEC_PLAYER && !GetPlayer()->m_mover->HasAuraType(SPELL_AURA_FLY) && !GetPlayer()->m_mover->HasAuraType(SPELL_AURA_MOD_INCREASE_MOUNTED_FLIGHT_SPEED), MOVEMENTFLAG_FLYING | MOVEMENTFLAG_CAN_FLY); //! Cannot fly and fall at the same time REMOVE_VIOLATING_FLAGS(mi->HasMovementFlag(MOVEMENTFLAG_CAN_FLY | MOVEMENTFLAG_DISABLE_GRAVITY) && mi->HasMovementFlag(MOVEMENTFLAG_FALLING), MOVEMENTFLAG_FALLING); REMOVE_VIOLATING_FLAGS(mi->HasMovementFlag(MOVEMENTFLAG_SPLINE_ENABLED) && (!GetPlayer()->movespline->Initialized() || GetPlayer()->movespline->Finalized()), MOVEMENTFLAG_SPLINE_ENABLED); #undef REMOVE_VIOLATING_FLAGS } void WorldSession::WriteMovementInfo(WorldPacket* data, MovementInfo* mi) { *data << mi->guid.WriteAsPacked(); *data << mi->flags; *data << mi->flags2; *data << mi->time; *data << mi->pos.PositionXYZOStream(); if (mi->HasMovementFlag(MOVEMENTFLAG_ONTRANSPORT)) { *data << mi->transport.guid.WriteAsPacked(); *data << mi->transport.pos.PositionXYZOStream(); *data << mi->transport.time; *data << mi->transport.seat; if (mi->HasExtraMovementFlag(MOVEMENTFLAG2_INTERPOLATED_MOVEMENT)) *data << mi->transport.time2; } if (mi->HasMovementFlag(MovementFlags(MOVEMENTFLAG_SWIMMING | MOVEMENTFLAG_FLYING)) || mi->HasExtraMovementFlag(MOVEMENTFLAG2_ALWAYS_ALLOW_PITCHING)) *data << mi->pitch; *data << mi->fallTime; if (mi->HasMovementFlag(MOVEMENTFLAG_FALLING)) { *data << mi->jump.zspeed; *data << mi->jump.sinAngle; *data << mi->jump.cosAngle; *data << mi->jump.xyspeed; } if (mi->HasMovementFlag(MOVEMENTFLAG_SPLINE_ELEVATION)) *data << mi->splineElevation; } void WorldSession::ReadAddonsInfo(WorldPacket& data) { if (data.rpos() + 4 > data.size()) return; uint32 size; data >> size; if (!size) return; if (size > 0xFFFFF) { LOG_ERROR("server", "WorldSession::ReadAddonsInfo addon info too big, size %u", size); return; } uLongf uSize = size; uint32 pos = data.rpos(); ByteBuffer addonInfo; addonInfo.resize(size); if (uncompress(addonInfo.contents(), &uSize, data.contents() + pos, data.size() - pos) == Z_OK) { uint32 addonsCount; addonInfo >> addonsCount; // addons count for (uint32 i = 0; i < addonsCount; ++i) { std::string addonName; uint8 enabled; uint32 crc, unk1; // check next addon data format correctness if (addonInfo.rpos() + 1 > addonInfo.size()) return; addonInfo >> addonName; addonInfo >> enabled >> crc >> unk1; #if defined(ENABLE_EXTRAS) && defined(ENABLE_EXTRA_LOGS) LOG_DEBUG("server", "ADDON: Name: %s, Enabled: 0x%x, CRC: 0x%x, Unknown2: 0x%x", addonName.c_str(), enabled, crc, unk1); #endif AddonInfo addon(addonName, enabled, crc, 2, true); SavedAddon const* savedAddon = AddonMgr::GetAddonInfo(addonName); if (savedAddon) { #if defined(ENABLE_EXTRAS) && defined(ENABLE_EXTRA_LOGS) bool match = true; if (addon.CRC != savedAddon->CRC) match = false; if (!match) LOG_DEBUG("server", "ADDON: %s was known, but didn't match known CRC (0x%x)!", addon.Name.c_str(), savedAddon->CRC); else LOG_DEBUG("server", "ADDON: %s was known, CRC is correct (0x%x)", addon.Name.c_str(), savedAddon->CRC); #endif } else { AddonMgr::SaveAddon(addon); #if defined(ENABLE_EXTRAS) && defined(ENABLE_EXTRA_LOGS) LOG_DEBUG("server", "ADDON: %s (0x%x) was not known, saving...", addon.Name.c_str(), addon.CRC); #endif } // TODO: Find out when to not use CRC/pubkey, and other possible states. m_addonsList.push_back(addon); } uint32 currentTime; addonInfo >> currentTime; #if defined(ENABLE_EXTRAS) && defined(ENABLE_EXTRA_LOGS) LOG_DEBUG("network", "ADDON: CurrentTime: %u", currentTime); #endif #if defined(ENABLE_EXTRAS) && defined(ENABLE_EXTRA_LOGS) if (addonInfo.rpos() != addonInfo.size()) LOG_DEBUG("network", "packet under-read!"); #endif } else LOG_ERROR("server", "Addon packet uncompress error!"); } void WorldSession::SendAddonsInfo() { uint8 addonPublicKey[256] = { 0xC3, 0x5B, 0x50, 0x84, 0xB9, 0x3E, 0x32, 0x42, 0x8C, 0xD0, 0xC7, 0x48, 0xFA, 0x0E, 0x5D, 0x54, 0x5A, 0xA3, 0x0E, 0x14, 0xBA, 0x9E, 0x0D, 0xB9, 0x5D, 0x8B, 0xEE, 0xB6, 0x84, 0x93, 0x45, 0x75, 0xFF, 0x31, 0xFE, 0x2F, 0x64, 0x3F, 0x3D, 0x6D, 0x07, 0xD9, 0x44, 0x9B, 0x40, 0x85, 0x59, 0x34, 0x4E, 0x10, 0xE1, 0xE7, 0x43, 0x69, 0xEF, 0x7C, 0x16, 0xFC, 0xB4, 0xED, 0x1B, 0x95, 0x28, 0xA8, 0x23, 0x76, 0x51, 0x31, 0x57, 0x30, 0x2B, 0x79, 0x08, 0x50, 0x10, 0x1C, 0x4A, 0x1A, 0x2C, 0xC8, 0x8B, 0x8F, 0x05, 0x2D, 0x22, 0x3D, 0xDB, 0x5A, 0x24, 0x7A, 0x0F, 0x13, 0x50, 0x37, 0x8F, 0x5A, 0xCC, 0x9E, 0x04, 0x44, 0x0E, 0x87, 0x01, 0xD4, 0xA3, 0x15, 0x94, 0x16, 0x34, 0xC6, 0xC2, 0xC3, 0xFB, 0x49, 0xFE, 0xE1, 0xF9, 0xDA, 0x8C, 0x50, 0x3C, 0xBE, 0x2C, 0xBB, 0x57, 0xED, 0x46, 0xB9, 0xAD, 0x8B, 0xC6, 0xDF, 0x0E, 0xD6, 0x0F, 0xBE, 0x80, 0xB3, 0x8B, 0x1E, 0x77, 0xCF, 0xAD, 0x22, 0xCF, 0xB7, 0x4B, 0xCF, 0xFB, 0xF0, 0x6B, 0x11, 0x45, 0x2D, 0x7A, 0x81, 0x18, 0xF2, 0x92, 0x7E, 0x98, 0x56, 0x5D, 0x5E, 0x69, 0x72, 0x0A, 0x0D, 0x03, 0x0A, 0x85, 0xA2, 0x85, 0x9C, 0xCB, 0xFB, 0x56, 0x6E, 0x8F, 0x44, 0xBB, 0x8F, 0x02, 0x22, 0x68, 0x63, 0x97, 0xBC, 0x85, 0xBA, 0xA8, 0xF7, 0xB5, 0x40, 0x68, 0x3C, 0x77, 0x86, 0x6F, 0x4B, 0xD7, 0x88, 0xCA, 0x8A, 0xD7, 0xCE, 0x36, 0xF0, 0x45, 0x6E, 0xD5, 0x64, 0x79, 0x0F, 0x17, 0xFC, 0x64, 0xDD, 0x10, 0x6F, 0xF3, 0xF5, 0xE0, 0xA6, 0xC3, 0xFB, 0x1B, 0x8C, 0x29, 0xEF, 0x8E, 0xE5, 0x34, 0xCB, 0xD1, 0x2A, 0xCE, 0x79, 0xC3, 0x9A, 0x0D, 0x36, 0xEA, 0x01, 0xE0, 0xAA, 0x91, 0x20, 0x54, 0xF0, 0x72, 0xD8, 0x1E, 0xC7, 0x89, 0xD2 }; WorldPacket data(SMSG_ADDON_INFO, 4); for (AddonsList::iterator itr = m_addonsList.begin(); itr != m_addonsList.end(); ++itr) { data << uint8(itr->State); uint8 crcpub = itr->UsePublicKeyOrCRC; data << uint8(crcpub); if (crcpub) { uint8 usepk = (itr->CRC != STANDARD_ADDON_CRC); // If addon is Standard addon CRC data << uint8(usepk); if (usepk) // if CRC is wrong, add public key (client need it) { #if defined(ENABLE_EXTRAS) && defined(ENABLE_EXTRA_LOGS) LOG_DEBUG("server", "ADDON: CRC (0x%x) for addon %s is wrong (does not match expected 0x%x), sending pubkey", itr->CRC, itr->Name.c_str(), STANDARD_ADDON_CRC); #endif data.append(addonPublicKey, sizeof(addonPublicKey)); } data << uint32(0); // TODO: Find out the meaning of this. } uint8 unk3 = 0; // 0 is sent here data << uint8(unk3); if (unk3) { // String, length 256 (null terminated) data << uint8(0); } } m_addonsList.clear(); AddonMgr::BannedAddonList const* bannedAddons = AddonMgr::GetBannedAddons(); data << uint32(bannedAddons->size()); for (AddonMgr::BannedAddonList::const_iterator itr = bannedAddons->begin(); itr != bannedAddons->end(); ++itr) { data << uint32(itr->Id); data.append(itr->NameMD5, sizeof(itr->NameMD5)); data.append(itr->VersionMD5, sizeof(itr->VersionMD5)); data << uint32(itr->Timestamp); data << uint32(1); // IsBanned } SendPacket(&data); } void WorldSession::SetPlayer(Player* player) { _player = player; if (_player) m_GUIDLow = _player->GetGUID().GetCounter(); } void WorldSession::InitializeQueryCallbackParameters() { // Callback parameters that have pointers in them should be properly // initialized to nullptr here. _charCreateCallback.SetParam(nullptr); _loadPetFromDBFirstCallback.SetFirstParam(0); _loadPetFromDBFirstCallback.SetSecondParam(nullptr); } void WorldSession::ProcessQueryCallbacks() { ProcessQueryCallbackPlayer(); ProcessQueryCallbackPet(); ProcessQueryCallbackLogin(); } void WorldSession::ProcessQueryCallbackPlayer() { PreparedQueryResult result; //- HandleCharRenameOpcode if (_charRenameCallback.IsReady()) { std::string param = _charRenameCallback.GetParam(); _charRenameCallback.GetResult(result); HandleChangePlayerNameOpcodeCallBack(result, param); _charRenameCallback.FreeResult(); } //- HandleOpenItemOpcode if (_openWrappedItemCallback.IsReady()) { uint8 bagIndex = _openWrappedItemCallback.GetFirstParam(); uint8 slot = _openWrappedItemCallback.GetSecondParam(); ObjectGuid::LowType itemLowGUID = _openWrappedItemCallback.GetThirdParam(); _openWrappedItemCallback.GetResult(result); HandleOpenWrappedItemCallback(result, bagIndex, slot, itemLowGUID); _openWrappedItemCallback.FreeResult(); } //- Player - ActivateSpec if (_loadActionsSwitchSpecCallback.ready()) { _loadActionsSwitchSpecCallback.get(result); HandleLoadActionsSwitchSpec(result); _loadActionsSwitchSpecCallback.cancel(); } } void WorldSession::ProcessQueryCallbackPet() { PreparedQueryResult result; //- SendStabledPet if (_sendStabledPetCallback.IsReady()) { ObjectGuid param = _sendStabledPetCallback.GetParam(); _sendStabledPetCallback.GetResult(result); SendStablePetCallback(result, param); _sendStabledPetCallback.FreeResult(); return; } //- HandleStablePet if (_stablePetCallback.ready()) { _stablePetCallback.get(result); HandleStablePetCallback(result); _stablePetCallback.cancel(); return; } //- HandleUnstablePet if (_unstablePetCallback.IsReady()) { uint32 param = _unstablePetCallback.GetParam(); _unstablePetCallback.GetResult(result); HandleUnstablePetCallback(result, param); _unstablePetCallback.FreeResult(); return; } //- HandleStableSwapPet if (_stableSwapCallback.IsReady()) { uint32 param = _stableSwapCallback.GetParam(); _stableSwapCallback.GetResult(result); HandleStableSwapPetCallback(result, param); _stableSwapCallback.FreeResult(); return; } //- LoadPetFromDB first part if (_loadPetFromDBFirstCallback.IsReady()) { Player* player = GetPlayer(); if (!player) { if (AsynchPetSummon* info = _loadPetFromDBFirstCallback.GetSecondParam()) delete info; _loadPetFromDBFirstCallback.Reset(); return; } // process only if player is in world (teleport crashes?) // otherwise wait with result till he logs in if (player->IsInWorld()) { uint8 asynchLoadType = _loadPetFromDBFirstCallback.GetFirstParam(); _loadPetFromDBFirstCallback.GetResult(result); uint8 loadResult = HandleLoadPetFromDBFirstCallback(result, asynchLoadType); if (loadResult != PET_LOAD_OK) Pet::HandleAsynchLoadFailed(_loadPetFromDBFirstCallback.GetSecondParam(), player, asynchLoadType, loadResult); if (AsynchPetSummon* info = _loadPetFromDBFirstCallback.GetSecondParam()) delete info; _loadPetFromDBFirstCallback.Reset(); } return; } //- LoadPetFromDB second part if (_loadPetFromDBSecondCallback.ready()) { Player* player = GetPlayer(); if (!player) { SQLQueryHolder* param; _loadPetFromDBSecondCallback.get(param); delete param; _loadPetFromDBSecondCallback.cancel(); } else if (!player->IsInWorld()) { // wait } else { SQLQueryHolder* param; _loadPetFromDBSecondCallback.get(param); HandleLoadPetFromDBSecondCallback((LoadPetFromDBQueryHolder*)param); delete param; _loadPetFromDBSecondCallback.cancel(); } return; } } void WorldSession::ProcessQueryCallbackLogin() { PreparedQueryResult result; //! HandleCharEnumOpcode if (_charEnumCallback.ready()) { _charEnumCallback.get(result); HandleCharEnum(result); _charEnumCallback.cancel(); } if (_charCreateCallback.IsReady()) { _charCreateCallback.GetResult(result); HandleCharCreateCallback(result, _charCreateCallback.GetParam()); // Don't call FreeResult() here, the callback handler will do that depending on the events in the callback chain } //! HandlePlayerLoginOpcode if (_charLoginCallback.ready()) { SQLQueryHolder* param; _charLoginCallback.get(param); HandlePlayerLoginFromDB((LoginQueryHolder*)param); _charLoginCallback.cancel(); } } void WorldSession::InitWarden(SessionKey const& k, std::string const& os) { if (os == "Win") { _warden = new WardenWin(); _warden->Init(this, k); } else if (os == "OSX") { // Disabled as it is causing the client to crash // _warden = new WardenMac(); // _warden->Init(this, k); } } bool WorldSession::DosProtection::EvaluateOpcode(WorldPacket& p, time_t time) const { uint32 maxPacketCounterAllowed = GetMaxPacketCounterAllowed(p.GetOpcode()); // Return true if there no limit for the opcode if (!maxPacketCounterAllowed) return true; PacketCounter& packetCounter = _PacketThrottlingMap[p.GetOpcode()]; if (packetCounter.lastReceiveTime != time) { packetCounter.lastReceiveTime = time; packetCounter.amountCounter = 0; } // Check if player is flooding some packets if (++packetCounter.amountCounter <= maxPacketCounterAllowed) return true; LOG_WARN("network", "AntiDOS: Account %u, IP: %s, Ping: %u, Character: %s, flooding packet (opc: %s (0x%X), count: %u)", Session->GetAccountId(), Session->GetRemoteAddress().c_str(), Session->GetLatency(), Session->GetPlayerName().c_str(), opcodeTable[static_cast(p.GetOpcode())]->Name, p.GetOpcode(), packetCounter.amountCounter); switch (_policy) { case POLICY_LOG: return true; case POLICY_KICK: { LOG_INFO("network", "AntiDOS: Player %s kicked!", Session->GetPlayerName().c_str()); Session->KickPlayer(); return false; } case POLICY_BAN: { uint32 bm = sWorld->getIntConfig(CONFIG_PACKET_SPOOF_BANMODE); uint32 duration = sWorld->getIntConfig(CONFIG_PACKET_SPOOF_BANDURATION); // in seconds std::string nameOrIp = ""; switch (bm) { case 0: // Ban account (void)AccountMgr::GetName(Session->GetAccountId(), nameOrIp); sBan->BanAccount(nameOrIp, std::to_string(duration), "DOS (Packet Flooding/Spoofing", "Server: AutoDOS"); break; case 1: // Ban ip nameOrIp = Session->GetRemoteAddress(); sBan->BanIP(nameOrIp, std::to_string(duration), "DOS (Packet Flooding/Spoofing", "Server: AutoDOS"); break; } LOG_INFO("network", "AntiDOS: Player automatically banned for %u seconds.", duration); return false; } default: // invalid policy return true; } } uint32 WorldSession::DosProtection::GetMaxPacketCounterAllowed(uint16 opcode) const { uint32 maxPacketCounterAllowed; switch (opcode) { // CPU usage sending 2000 packets/second on a 3.70 GHz 4 cores on Win x64 // [% CPU mysqld] [%CPU worldserver RelWithDebInfo] case CMSG_PLAYER_LOGIN: // 0 0.5 case CMSG_NAME_QUERY: // 0 1 case CMSG_PET_NAME_QUERY: // 0 1 case CMSG_NPC_TEXT_QUERY: // 0 1 case CMSG_ATTACKSTOP: // 0 1 case CMSG_QUERY_QUESTS_COMPLETED: // 0 1 case CMSG_QUERY_TIME: // 0 1 case CMSG_CORPSE_MAP_POSITION_QUERY: // 0 1 case CMSG_MOVE_TIME_SKIPPED: // 0 1 case MSG_QUERY_NEXT_MAIL_TIME: // 0 1 case CMSG_SETSHEATHED: // 0 1 case MSG_RAID_TARGET_UPDATE: // 0 1 case CMSG_PLAYER_LOGOUT: // 0 1 case CMSG_LOGOUT_REQUEST: // 0 1 case CMSG_PET_RENAME: // 0 1 case CMSG_QUESTGIVER_CANCEL: // 0 1 case CMSG_QUESTGIVER_REQUEST_REWARD: // 0 1 case CMSG_COMPLETE_CINEMATIC: // 0 1 case CMSG_BANKER_ACTIVATE: // 0 1 case CMSG_BUY_BANK_SLOT: // 0 1 case CMSG_OPT_OUT_OF_LOOT: // 0 1 case CMSG_DUEL_ACCEPTED: // 0 1 case CMSG_DUEL_CANCELLED: // 0 1 case CMSG_CALENDAR_COMPLAIN: // 0 1 case CMSG_QUEST_QUERY: // 0 1.5 case CMSG_ITEM_QUERY_SINGLE: // 0 1.5 case CMSG_ITEM_NAME_QUERY: // 0 1.5 case CMSG_GAMEOBJECT_QUERY: // 0 1.5 case CMSG_CREATURE_QUERY: // 0 1.5 case CMSG_QUESTGIVER_STATUS_QUERY: // 0 1.5 case CMSG_GUILD_QUERY: // 0 1.5 case CMSG_ARENA_TEAM_QUERY: // 0 1.5 case CMSG_TAXINODE_STATUS_QUERY: // 0 1.5 case CMSG_TAXIQUERYAVAILABLENODES: // 0 1.5 case CMSG_QUESTGIVER_QUERY_QUEST: // 0 1.5 case CMSG_PAGE_TEXT_QUERY: // 0 1.5 case MSG_QUERY_GUILD_BANK_TEXT: // 0 1.5 case MSG_CORPSE_QUERY: // 0 1.5 case MSG_MOVE_SET_FACING: // 0 1.5 case CMSG_REQUEST_PARTY_MEMBER_STATS: // 0 1.5 case CMSG_QUESTGIVER_COMPLETE_QUEST: // 0 1.5 case CMSG_SET_ACTION_BUTTON: // 0 1.5 case CMSG_RESET_INSTANCES: // 0 1.5 case CMSG_HEARTH_AND_RESURRECT: // 0 1.5 case CMSG_TOGGLE_PVP: // 0 1.5 case CMSG_PET_ABANDON: // 0 1.5 case CMSG_ACTIVATETAXIEXPRESS: // 0 1.5 case CMSG_ACTIVATETAXI: // 0 1.5 case CMSG_SELF_RES: // 0 1.5 case CMSG_UNLEARN_SKILL: // 0 1.5 case CMSG_EQUIPMENT_SET_SAVE: // 0 1.5 case CMSG_DELETEEQUIPMENT_SET: // 0 1.5 case CMSG_DISMISS_CRITTER: // 0 1.5 case CMSG_REPOP_REQUEST: // 0 1.5 case CMSG_GROUP_INVITE: // 0 1.5 case CMSG_GROUP_DECLINE: // 0 1.5 case CMSG_GROUP_ACCEPT: // 0 1.5 case CMSG_GROUP_UNINVITE_GUID: // 0 1.5 case CMSG_GROUP_UNINVITE: // 0 1.5 case CMSG_GROUP_DISBAND: // 0 1.5 case CMSG_BATTLEMASTER_JOIN_ARENA: // 0 1.5 case CMSG_LEAVE_BATTLEFIELD: // 0 1.5 case MSG_GUILD_BANK_LOG_QUERY: // 0 2 case CMSG_LOGOUT_CANCEL: // 0 2 case CMSG_REALM_SPLIT: // 0 2 case CMSG_ALTER_APPEARANCE: // 0 2 case CMSG_QUEST_CONFIRM_ACCEPT: // 0 2 case MSG_GUILD_EVENT_LOG_QUERY: // 0 2.5 case CMSG_READY_FOR_ACCOUNT_DATA_TIMES: // 0 2.5 case CMSG_QUESTGIVER_STATUS_MULTIPLE_QUERY: // 0 2.5 case CMSG_BEGIN_TRADE: // 0 2.5 case CMSG_INITIATE_TRADE: // 0 3 case CMSG_MESSAGECHAT: // 0 3.5 case CMSG_INSPECT: // 0 3.5 case CMSG_AREA_SPIRIT_HEALER_QUERY: // not profiled case CMSG_STANDSTATECHANGE: // not profiled case MSG_RANDOM_ROLL: // not profiled case CMSG_TIME_SYNC_RESP: // not profiled case CMSG_TRAINER_BUY_SPELL: // not profiled case CMSG_FORCE_SWIM_SPEED_CHANGE_ACK: // not profiled case CMSG_FORCE_SWIM_BACK_SPEED_CHANGE_ACK: // not profiled case CMSG_FORCE_RUN_SPEED_CHANGE_ACK: // not profiled case CMSG_FORCE_RUN_BACK_SPEED_CHANGE_ACK: // not profiled case CMSG_FORCE_FLIGHT_SPEED_CHANGE_ACK: // not profiled case CMSG_FORCE_FLIGHT_BACK_SPEED_CHANGE_ACK: // not profiled case CMSG_FORCE_WALK_SPEED_CHANGE_ACK: // not profiled case CMSG_FORCE_TURN_RATE_CHANGE_ACK: // not profiled case CMSG_FORCE_PITCH_RATE_CHANGE_ACK: // not profiled { // "0" is a magic number meaning there's no limit for the opcode. // All the opcodes above must cause little CPU usage and no sync/async database queries at all maxPacketCounterAllowed = 0; break; } case CMSG_QUESTGIVER_ACCEPT_QUEST: // 0 4 case CMSG_QUESTLOG_REMOVE_QUEST: // 0 4 case CMSG_QUESTGIVER_CHOOSE_REWARD: // 0 4 case CMSG_CONTACT_LIST: // 0 5 case CMSG_LEARN_PREVIEW_TALENTS: // 0 6 case CMSG_AUTOBANK_ITEM: // 0 6 case CMSG_AUTOSTORE_BANK_ITEM: // 0 6 case CMSG_WHO: // 0 7 case CMSG_PLAYER_VEHICLE_ENTER: // 0 8 case CMSG_LEARN_PREVIEW_TALENTS_PET: // not profiled case MSG_MOVE_HEARTBEAT: { maxPacketCounterAllowed = 200; break; } case CMSG_GUILD_SET_PUBLIC_NOTE: // 1 2 1 async db query case CMSG_GUILD_SET_OFFICER_NOTE: // 1 2 1 async db query case CMSG_SET_CONTACT_NOTES: // 1 2.5 1 async db query case CMSG_CALENDAR_GET_CALENDAR: // 0 1.5 medium upload bandwidth usage case CMSG_GUILD_BANK_QUERY_TAB: // 0 3.5 medium upload bandwidth usage case CMSG_QUERY_INSPECT_ACHIEVEMENTS: // 0 13 high upload bandwidth usage case CMSG_GAMEOBJ_REPORT_USE: // not profiled case CMSG_GAMEOBJ_USE: // not profiled case MSG_PETITION_DECLINE: // not profiled { maxPacketCounterAllowed = 50; break; } case CMSG_QUEST_POI_QUERY: // 0 25 very high upload bandwidth usage { maxPacketCounterAllowed = MAX_QUEST_LOG_SIZE; break; } case CMSG_GM_REPORT_LAG: // 1 3 1 async db query case CMSG_SPELLCLICK: // not profiled case CMSG_REMOVE_GLYPH: // not profiled case CMSG_DISMISS_CONTROLLED_VEHICLE: // not profiled { maxPacketCounterAllowed = 20; break; } case CMSG_PETITION_SIGN: // 9 4 2 sync 1 async db queries case CMSG_TURN_IN_PETITION: // 8 5.5 2 sync db query case CMSG_GROUP_CHANGE_SUB_GROUP: // 6 5 1 sync 1 async db queries case CMSG_PETITION_QUERY: // 4 3.5 1 sync db query case CMSG_CHAR_RACE_CHANGE: // 5 4 1 sync db query case CMSG_CHAR_CUSTOMIZE: // 5 5 1 sync db query case CMSG_CHAR_FACTION_CHANGE: // 5 5 1 sync db query case CMSG_CHAR_DELETE: // 4 4 1 sync db query case CMSG_DEL_FRIEND: // 7 5 1 async db query case CMSG_ADD_FRIEND: // 6 4 1 async db query case CMSG_CHAR_RENAME: // 5 3 1 async db query case CMSG_GMSURVEY_SUBMIT: // 2 3 1 async db query case CMSG_BUG: // 1 1 1 async db query case CMSG_GROUP_SET_LEADER: // 1 2 1 async db query case CMSG_GROUP_RAID_CONVERT: // 1 5 1 async db query case CMSG_GROUP_ASSISTANT_LEADER: // 1 2 1 async db query case CMSG_PETITION_BUY: // not profiled 1 sync 1 async db queries case CMSG_CHANGE_SEATS_ON_CONTROLLED_VEHICLE: // not profiled case CMSG_REQUEST_VEHICLE_PREV_SEAT: // not profiled case CMSG_REQUEST_VEHICLE_NEXT_SEAT: // not profiled case CMSG_REQUEST_VEHICLE_SWITCH_SEAT: // not profiled case CMSG_REQUEST_VEHICLE_EXIT: // not profiled case CMSG_CONTROLLER_EJECT_PASSENGER: // not profiled case CMSG_ITEM_REFUND: // not profiled case CMSG_SOCKET_GEMS: // not profiled case CMSG_WRAP_ITEM: // not profiled case CMSG_REPORT_PVP_AFK: // not profiled { maxPacketCounterAllowed = 10; break; } case CMSG_CHAR_CREATE: // 7 5 3 async db queries case CMSG_CHAR_ENUM: // 22 3 2 async db queries case CMSG_GMTICKET_CREATE: // 1 25 1 async db query case CMSG_GMTICKET_UPDATETEXT: // 0 15 1 async db query case CMSG_GMTICKET_DELETETICKET: // 1 25 1 async db query case CMSG_GMRESPONSE_RESOLVE: // 1 25 1 async db query case CMSG_CALENDAR_ADD_EVENT: // 21 10 2 async db query case CMSG_CALENDAR_UPDATE_EVENT: // not profiled case CMSG_CALENDAR_REMOVE_EVENT: // not profiled case CMSG_CALENDAR_COPY_EVENT: // not profiled case CMSG_CALENDAR_EVENT_INVITE: // not profiled case CMSG_CALENDAR_EVENT_SIGNUP: // not profiled case CMSG_CALENDAR_EVENT_RSVP: // not profiled case CMSG_CALENDAR_EVENT_REMOVE_INVITE: // not profiled case CMSG_CALENDAR_EVENT_MODERATOR_STATUS: // not profiled case CMSG_ARENA_TEAM_INVITE: // not profiled case CMSG_ARENA_TEAM_ACCEPT: // not profiled case CMSG_ARENA_TEAM_DECLINE: // not profiled case CMSG_ARENA_TEAM_LEAVE: // not profiled case CMSG_ARENA_TEAM_DISBAND: // not profiled case CMSG_ARENA_TEAM_REMOVE: // not profiled case CMSG_ARENA_TEAM_LEADER: // not profiled case CMSG_LOOT_METHOD: // not profiled case CMSG_GUILD_INVITE: // not profiled case CMSG_GUILD_ACCEPT: // not profiled case CMSG_GUILD_DECLINE: // not profiled case CMSG_GUILD_LEAVE: // not profiled case CMSG_GUILD_DISBAND: // not profiled case CMSG_GUILD_LEADER: // not profiled case CMSG_GUILD_MOTD: // not profiled case CMSG_GUILD_RANK: // not profiled case CMSG_GUILD_ADD_RANK: // not profiled case CMSG_GUILD_DEL_RANK: // not profiled case CMSG_GUILD_INFO_TEXT: // not profiled case CMSG_GUILD_BANK_DEPOSIT_MONEY: // not profiled case CMSG_GUILD_BANK_WITHDRAW_MONEY: // not profiled case CMSG_GUILD_BANK_BUY_TAB: // not profiled case CMSG_GUILD_BANK_UPDATE_TAB: // not profiled case CMSG_SET_GUILD_BANK_TEXT: // not profiled case MSG_SAVE_GUILD_EMBLEM: // not profiled case MSG_PETITION_RENAME: // not profiled case MSG_TALENT_WIPE_CONFIRM: // not profiled case MSG_SET_DUNGEON_DIFFICULTY: // not profiled case MSG_SET_RAID_DIFFICULTY: // not profiled case MSG_PARTY_ASSIGNMENT: // not profiled case MSG_RAID_READY_CHECK: // not profiled { maxPacketCounterAllowed = 3; break; } case CMSG_ITEM_REFUND_INFO: // not profiled { maxPacketCounterAllowed = PLAYER_SLOTS_COUNT; break; } default: { maxPacketCounterAllowed = 100; break; } } return maxPacketCounterAllowed; } void WorldSession::ResetTimeSync() { _timeSyncNextCounter = 0; _pendingTimeSyncRequests.clear(); } void WorldSession::SendTimeSync() { WorldPacket data(SMSG_TIME_SYNC_REQ, 4); data << uint32(_timeSyncNextCounter); SendPacket(&data); _pendingTimeSyncRequests[_timeSyncNextCounter] = getMSTime(); // Schedule next sync in 10 sec (except for the 2 first packets, which are spaced by only 5s) _timeSyncTimer = _timeSyncNextCounter == 0 ? 5000 : 10000; _timeSyncNextCounter++; }