hondacrx
c46c7ba2dc
Port From (https://github.com/TrinityCore/TrinityCore/commit/cab4c87d2d7f6d734ef067d6bf50f4b1d338a7bc)
103 lines
4.2 KiB
C#
103 lines
4.2 KiB
C#
/*
|
|
* Copyright (C) 2012-2020 CypherCore <http://github.com/CypherCore>
|
|
*
|
|
* This program is free software: you can redistribute it and/or modify
|
|
* it under the terms of the GNU General Public License as published by
|
|
* the Free Software Foundation, either version 3 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 General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License
|
|
* along with this program. If not, see <http://www.gnu.org/licenses/>.
|
|
*/
|
|
|
|
using Framework.Constants;
|
|
using Game.DataStorage;
|
|
using Game.Networking;
|
|
using Game.Networking.Packets;
|
|
using System.Collections.Generic;
|
|
|
|
namespace Game
|
|
{
|
|
public partial class WorldSession
|
|
{
|
|
[WorldPacketHandler(ClientOpcodes.DbQueryBulk, Processing = PacketProcessing.Inplace, Status = SessionStatus.Authed)]
|
|
void HandleDBQueryBulk(DBQueryBulk dbQuery)
|
|
{
|
|
IDB2Storage store = Global.DB2Mgr.GetStorage(dbQuery.TableHash);
|
|
if (store == null)
|
|
{
|
|
Log.outError(LogFilter.Network, "CMSG_DB_QUERY_BULK: {0} requested unsupported unknown hotfix type: {1}", GetPlayerInfo(), dbQuery.TableHash);
|
|
return;
|
|
}
|
|
|
|
foreach (DBQueryBulk.DBQueryRecord record in dbQuery.Queries)
|
|
{
|
|
DBReply dbReply = new DBReply();
|
|
dbReply.TableHash = dbQuery.TableHash;
|
|
dbReply.RecordID = record.RecordID;
|
|
|
|
if (store.HasRecord(record.RecordID))
|
|
{
|
|
dbReply.Status = 1;
|
|
dbReply.Timestamp = (uint)GameTime.GetGameTime();
|
|
store.WriteRecord(record.RecordID, GetSessionDbcLocale(), dbReply.Data);
|
|
}
|
|
else
|
|
{
|
|
Log.outTrace(LogFilter.Network, "CMSG_DB_QUERY_BULK: {0} requested non-existing entry {1} in datastore: {2}", GetPlayerInfo(), record.RecordID, dbQuery.TableHash);
|
|
dbReply.Timestamp = (uint)Time.UnixTime;
|
|
}
|
|
|
|
SendPacket(dbReply);
|
|
}
|
|
}
|
|
|
|
void SendAvailableHotfixes()
|
|
{
|
|
SendPacket(new AvailableHotfixes(Global.WorldMgr.GetRealmId().GetAddress(), Global.DB2Mgr.GetHotfixCount(), Global.DB2Mgr.GetHotfixData()));
|
|
}
|
|
|
|
[WorldPacketHandler(ClientOpcodes.HotfixRequest, Status = SessionStatus.Authed)]
|
|
void HandleHotfixRequest(HotfixRequest hotfixQuery)
|
|
{
|
|
var hotfixes = Global.DB2Mgr.GetHotfixData();
|
|
|
|
HotfixConnect hotfixQueryResponse = new HotfixConnect();
|
|
foreach (HotfixRecord hotfixRecord in hotfixQuery.Hotfixes)
|
|
{
|
|
if (hotfixes.Contains(hotfixRecord))
|
|
{
|
|
var storage = Global.DB2Mgr.GetStorage(hotfixRecord.TableHash);
|
|
|
|
HotfixConnect.HotfixData hotfixData = new HotfixConnect.HotfixData();
|
|
hotfixData.Record = hotfixRecord;
|
|
if (storage != null && storage.HasRecord((uint)hotfixRecord.RecordID))
|
|
{
|
|
uint pos = hotfixQueryResponse.HotfixContent.GetSize();
|
|
storage.WriteRecord((uint)hotfixRecord.RecordID, GetSessionDbcLocale(), hotfixQueryResponse.HotfixContent);
|
|
hotfixData.Size.Set(hotfixQueryResponse.HotfixContent.GetSize() - pos);
|
|
}
|
|
else
|
|
{
|
|
byte[] blobData = Global.DB2Mgr.GetHotfixBlobData(hotfixRecord.TableHash, hotfixRecord.RecordID, GetSessionDbcLocale());
|
|
if (blobData != null)
|
|
{
|
|
hotfixData.Size.Set((uint)blobData.Length);
|
|
hotfixQueryResponse.HotfixContent.WriteBytes(blobData);
|
|
}
|
|
}
|
|
|
|
hotfixQueryResponse.Hotfixes.Add(hotfixData);
|
|
}
|
|
}
|
|
|
|
SendPacket(hotfixQueryResponse);
|
|
}
|
|
}
|
|
}
|