lineage2/L2Bot2.0
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: change message api to one interface

Browse Source
This commit is contained in:
k0t9i 2023-01-26 14:58:19 +04:00
parent 2a3e39019e
commit 112c20b7d3
5 changed files with 81 additions and 80 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
L2BotCore/Domain/DTO/Message.h Normal file
View File

@ -0,0 +1,52 @@
#pragma once
#pragma once
#include <cstdint>
#include <memory>
#include "../Entities/EntityInterface.h"
#include "../Enums/EntityStateEnum.h"
namespace L2Bot::Domain::DTO
{
class Message : public Serializers::Serializable
{
public:
const std::vector<Serializers::Node> BuildSerializationNodes() const override
{
std::wstring operation = L"none";
switch (m_Operation)
{
case Enums::EntityStateEnum::created:
operation = L"create";
break;
case Enums::EntityStateEnum::updated:
operation = L"update";
break;
case Enums::EntityStateEnum::deleted:
operation = L"delete";
}
return
{
Serializers::Node{ L"type", m_Type },
Serializers::Node{ L"operation", operation },
Serializers::Node{L"content", m_Content.BuildSerializationNodes()}
};
}
Message(const std::wstring& type, const Enums::EntityStateEnum operation, const Serializers::Serializable& content) :
m_Type(type),
m_Operation(operation),
m_Content(content)
{
}
Message() = default;
virtual ~Message() = default;
private:
const std::wstring m_Type;
const Enums::EntityStateEnum m_Operation;
const Serializers::Serializable& m_Content;
};
}

56
L2BotCore/Domain/Serializers/SerializableStateContainer.h
View File

@ -1,56 +0,0 @@
#pragma once
#include <vector>
#include "../DTO/EntityState.h"
#include "Serializable.h"
namespace L2Bot::Domain::Serializers
{
class SerializableStateContainer : public Serializers::Serializable
{
public:
const std::vector<Serializers::Node> BuildSerializationNodes() const override
{
std::vector<Serializers::Node> result;
for (const auto& kvp : m_Objects)
{
std::wstring operationName = L"";
switch (kvp->GetState())
{
case Enums::EntityStateEnum::created:
operationName = L"created";
break;
case Enums::EntityStateEnum::updated:
operationName = L"updated";
break;
case Enums::EntityStateEnum::deleted:
operationName = L"deleted";
break;
}
if (operationName != L"")
{
result.push_back(
{
m_ContainerName,
std::vector<Serializers::Node>{ { operationName, kvp->GetEntity()->BuildSerializationNodes() } }
}
);
}
}
return result;
}
SerializableStateContainer(const std::vector<std::shared_ptr<DTO::EntityState>> objects, const std::wstring& containerName) :
m_Objects(objects), m_ContainerName(containerName)
{
}
SerializableStateContainer() = delete;
virtual ~SerializableStateContainer() = default;
private:
const std::vector<std::shared_ptr<DTO::EntityState>> m_Objects;
const std::wstring m_ContainerName;
};
}

2
L2BotCore/L2BotCore.vcxproj
View File

@ -160,6 +160,7 @@
</ItemDefinitionGroup>
<ItemGroup>
<ClInclude Include="Domain\DTO\EntityState.h" />
<ClInclude Include="Domain\DTO\Message.h" />
<ClInclude Include="Domain\Entities\AbnormalEffect.h" />
<ClInclude Include="Domain\Entities\ArmorItem.h" />
<ClInclude Include="Domain\Entities\EntityInterface.h" />
@ -195,7 +196,6 @@
<ClInclude Include="Domain\ValueObjects\ExperienceInfo.h" />
<ClInclude Include="Domain\ValueObjects\FullName.h" />
<ClInclude Include="Domain\ValueObjects\InventoryInfo.h" />
<ClInclude Include="Domain\Serializers\SerializableStateContainer.h" />
<ClInclude Include="Domain\ValueObjects\PermanentStats.h" />
<ClInclude Include="Domain\ValueObjects\Phenotype.h" />
<ClInclude Include="Domain\ValueObjects\Reputation.h" />

6
L2BotCore/L2BotCore.vcxproj.filters
View File

@ -90,9 +90,6 @@
<ClInclude Include="Domain\Serializers\Node.h">
<Filter>Header Files</Filter>
</ClInclude>
<ClInclude Include="Domain\Serializers\SerializableStateContainer.h">
<Filter>Header Files</Filter>
</ClInclude>
<ClInclude Include="Domain\Transports\TransportInterface.h">
<Filter>Header Files</Filter>
</ClInclude>
@ -150,6 +147,9 @@
<ClInclude Include="Domain\Repositories\ChatMessageRepositoryInterface.h">
<Filter>Header Files</Filter>
</ClInclude>
<ClInclude Include="Domain\DTO\Message.h">
<Filter>Header Files</Filter>
</ClInclude>
</ItemGroup>
<ItemGroup>
<ClCompile Include="pch.cpp">

45
L2BotDll/Services/WorldHandler.h
View File

@ -6,10 +6,10 @@
#include <Windows.h>
#include "Domain/Services/EntityService.h"
#include "Domain/Services/ChatMessageService.h"
#include "Domain/Serializers/SerializableStateContainer.h"
#include "Domain/Serializers/SerializerInterface.h"
#include "Domain/Repositories/EntityRepositoryInterface.h"
#include "Domain/Transports/TransportInterface.h"
#include "Domain/DTO/Message.h"
using namespace L2Bot::Domain;
@ -83,7 +83,7 @@ private:
for (const auto& item : data)
{
m_Transport.Send(
m_Serializer.Serialize({ item })
m_Serializer.Serialize(item)
);
}
}
@ -120,33 +120,38 @@ private:
}
}
const std::vector<Serializers::Node> GetData()
const std::vector<std::vector<Serializers::Node>> GetData()
{
std::vector<Serializers::SerializableStateContainer> items
std::map<std::wstring, Services::EntityService> services
{
Serializers::SerializableStateContainer{m_HeroService.GetEntities(), L"hero"},
Serializers::SerializableStateContainer{m_DropService.GetEntities(), L"drop"},
Serializers::SerializableStateContainer{m_NPCService.GetEntities(), L"npc"},
Serializers::SerializableStateContainer{m_PlayerService.GetEntities(), L"player"},
Serializers::SerializableStateContainer{m_SkillService.GetEntities(), L"skill"},
Serializers::SerializableStateContainer{m_ItemService.GetEntities(), L"item"},
Serializers::SerializableStateContainer{m_AbnormalEffectService.GetEntities(), L"abnormalEffect"},
{L"hero", m_HeroService},
{L"drop", m_DropService},
{L"npc", m_NPCService},
{L"player", m_PlayerService},
{L"skill", m_SkillService},
{L"item", m_ItemService},
{L"abnormalEffect", m_AbnormalEffectService}
};
std::vector<Serializers::Node> result;
for (const auto& item : items)
std::vector<std::vector<Serializers::Node>> result;
for (auto& kvp : services)
{
for (const auto node : item.BuildSerializationNodes())
for (const auto& entity : kvp.second.GetEntities())
{
result.push_back(node);
}
if (entity->GetState() != Enums::EntityStateEnum::none)
{
const auto message = DTO::Message{ kvp.first, entity->GetState(), *entity->GetEntity().get() };
result.push_back(message.BuildSerializationNodes());
}
};
}
for (const auto& message : m_ChatMessageService.GetMessages())
for (const auto& chatMessage : m_ChatMessageService.GetMessages())
{
result.push_back(Serializers::Node{ L"chat", message.BuildSerializationNodes() });
const auto message = DTO::Message{ L"chat", Enums::EntityStateEnum::created, chatMessage };
result.push_back(message.BuildSerializationNodes());
}
return result;
}