Method ProcessMessage

ucs/worldserver.cpp:62–174

}

void WorldServer::ProcessMessage(uint16 opcode, EQ::Net::Packet &p)
{
	ServerPacket tpack(opcode, p);
	ServerPacket *pack = &tpack;

	LogNetcode("Received Opcode: {:#04x}", opcode);

	switch (opcode)
	{
	case 0: {
		break;
	}
	case ServerOP_KeepAlive:
	{
		break;
	}
	case ServerOP_ServerReloadRequest: {
		auto o = (ServerReload::Request*) pack->pBuffer;
		if (o->type == ServerReload::Type::Logs) {
			EQEmuLogSys::Instance()->LoadLogDatabaseSettings();
			PlayerEventLogs::Instance()->ReloadSettings();
		}

		break;
	}
	case ServerOP_PlayerEvent: {
		auto n = PlayerEvent::PlayerEventContainer{};
		auto s = (ServerSendPlayerEvent_Struct*) pack->pBuffer;
		EQ::Util::MemoryStreamReader ss(s->cereal_data, s->cereal_size);
		cereal::BinaryInputArchive archive(ss);
		archive(n);

		DiscordManager::Instance()->QueuePlayerEventMessage(n);

		break;
	}
	case ServerOP_DiscordWebhookMessage: {
		auto *q = (DiscordWebhookMessage_Struct *) p.Data();

		DiscordManager::Instance()->QueueWebhookMessage(
			q->webhook_id,
			q->message
		);

		break;
	}
	case ServerOP_UCSMessage:
	{
		char *Buffer = (char *)pack->pBuffer;

		auto From = new char[strlen(Buffer) + 1];

		VARSTRUCT_DECODE_STRING(From, Buffer);

		std::string Message = Buffer;

		LogInfo("Player: [{}], Sent Message: [{}]", From, Message.c_str());