working message factory

This commit is contained in:
2025-02-06 22:16:07 +01:00
parent f5430f3d0f
commit bbafae2588
5 changed files with 105 additions and 4 deletions

View File

@@ -0,0 +1,13 @@
#pragma once
#include <sp/default/DefaultPacket.h>
#include <sp/protocol/Field.h>
#include <sp/protocol/MessageBase.h>
enum DisconnectPacketFields {
Reason = 0
};
using DisconnectFields = std::tuple<std::string /*Reason*/>;
DeclarePacket(Disconnect);

View File

@@ -1,11 +1,15 @@
#pragma once
enum PacketId {
KeepAlive
KeepAlive = 0,
Disconnect,
};
#include <examples/KeepAlivePacket.h>
#include <examples/DisconnectPacket.h>
using AllPackets = std::tuple<KeepAlivePacket>;
// they must be in the same order !
using AllPackets = std::tuple<KeepAlivePacket, DisconnectPacket>;
#include <sp/default/DefaultPacketHandler.h>
#include <sp/default/DefaultPacketFactory.h>

View File

@@ -0,0 +1,7 @@
#pragma once
#include <sp/protocol/MessageFactory.h>
namespace sp {
using PacketFactory = sp::MessageFactory<sp::PacketMessage, AllPackets>;
} // namespace sp

View File

@@ -0,0 +1,65 @@
#pragma once
#include <array>
#include <functional>
#include <iostream>
#include <memory>
namespace sp {
namespace details {
template <typename TBase>
using ArrayType = std::vector<std::function<std::unique_ptr<TBase>(void)>>;
template <typename TBase, typename... TMessages>
struct ArrayFiller {};
template <typename TBase, typename... TMessages>
struct ArrayFiller<TBase, std::tuple<TMessages...>> {
static void ArrayAppend(details::ArrayType<TBase>& array) {
ArrayFiller<TBase, TMessages...>::ArrayAppend(array);
}
};
template <typename TBase, typename TMessage, typename... TMessages>
struct ArrayFiller<TBase, TMessage, TMessages...> {
static void ArrayAppend(details::ArrayType<TBase>& array) {
ArrayFiller<TBase, TMessage>::ArrayAppend(array);
ArrayFiller<TBase, TMessages...>::ArrayAppend(array);
}
};
template <typename TBase, typename TMessage>
struct ArrayFiller<TBase, TMessage> {
static void ArrayAppend(details::ArrayType<TBase>& array) {
array.push_back([]() -> std::unique_ptr<TBase> { return std::make_unique<TMessage>(); });
}
};
} // namespace details
template <typename TBase, typename TTMessages>
class MessageFactory {
public:
using IdType = typename TBase::MsgIdType;
MessageFactory() {
details::ArrayFiller<TBase, TTMessages>::ArrayAppend(m_Factory);
}
std::unique_ptr<TBase> CreateMessage(IdType id) {
if (id >= m_Factory.size())
return nullptr;
return m_Factory.at(id)();
}
private:
details::ArrayType<TBase> m_Factory;
};
} // namespace sp

View File

@@ -7,6 +7,10 @@ class KeepAliveHandler : public sp::PacketHandler {
void Handle(KeepAlivePacket& packet) {
std::cout << "KeepAlive handled !\n";
}
void Handle(DisconnectPacket& packet) {
std::cout << "Disconnect handled !\n";
}
};
int main() {
@@ -24,7 +28,15 @@ int main() {
std::cout << "KeepAlive2 : " << keepAlive2->GetField<KeepAliveId>() << "\n";
//TODO: write ID and factory
//TODO: write ID
sp::PacketFactory factory;
auto packet = factory.CreateMessage(Disconnect);
if (packet == nullptr) {
std::cout << "Mauvais ID !\n";
return 1;
}
std::cout << (unsigned) packet->GetId() << std::endl;
packet->Dispatch(handler);
return 0;
}