bkinnightskytw
/
event_transformer
1
0
Fork 1
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: combine map implement function and virtual override method.

This commit is contained in:
insleker 2024-04-24 11:34:01 +08:00
parent da420c625f
commit 0ce9e7a903
2 changed files with 113 additions and 77 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

97
include/event_transformer.h
View File

@ -1,21 +1,99 @@
#pragma once #pragma once
using namespace std; #include <any>
#include <functional>
template<class... EventTypes> #include <map>
class EventList; #include <typeindex>
#include <typeinfo>
template<>
class EventList<>
{};
/** /**
* @details
* variadic template + template specialization
*/
template<class... EventTypes>
class EventList
{
// no function here will be expose to outer.
// void hello()
// {
// printf("hello");
// }
};
/**
* base of EventList
*/
template<>
class EventList<>
{
public:
// template<typename EVT>
// void dispatch(EVT evt)
// {
// using namespace std;
// // static_cast<EventList<>*>(evt_li_ptr)->dispatch(evt);
// // for (auto const& [key, val] : fmap) {
// // }
// auto any_func = this->fmap.at(std::type_index(typeid(EVT)));
// if (any_func.has_value()) {
// auto func = std::any_cast<std::function<void(EVT&)>>(any_func);
// func(evt); // dispatch
// return;
// }
// // else, call its own private dispatch function.
// // dynamic_cast<EventList<EVT>*>(this)->dispatch(evt); // error: 'EventList<>' is not polymorphic, so I need to
// // create seperate func.
// };
template<typename EvntLists, typename EVT>
friend void dispatch(EvntLists* evnt_list_ptr, EVT evt);
/**
* @todo create templated setting functor meta function.
*/
template<typename EvntLists, typename EVT>
friend void set_meta(EvntLists* evnt_list_ptr, EVT evt);
protected:
// std::optional
std::map<std::type_index, std::any> fmap;
};
// class Dispatcher
// {
// Dispatcher(Event)
// };
template<typename EvntLists, typename EVT>
void
dispatch(EvntLists* evnt_list_ptr, EVT evt)
{
auto base = static_cast<EventList<>*>(evnt_list_ptr); //->dispatch(evt);
auto any_func = base->fmap.at(std::type_index(typeid(EVT)));
if (any_func.has_value()) {
auto func = std::any_cast<std::function<void(EVT&)>>(any_func);
func(evt); // dispatch
return;
}
// else, call its own private dispatch function.
dynamic_cast<EventList<EVT>*>(evnt_list_ptr)->dispatch(evt); // error: 'EventList<>' is not polymorphic, so I need to
// create seperate func.
}
/**
* The second event list, connect between event and base
* @todo addition type but without trigger ambiguous error. * @todo addition type but without trigger ambiguous error.
*/ */
template<class Event> template<class Event>
class EventList<Event> : public virtual EventList<> class EventList<Event> : public virtual EventList<>
{ {
public: public:
EventList<Event>()
{
// printf("constructor called\n");
fmap.insert(std::pair<std::type_index, std::any>(std::type_index(typeid(Event)), std::any()));
// auto any_func = fmap.at(std::type_index(typeid(Event)));
// printf("any val:%d\n", any_func.has_value());
}
virtual void dispatch(const Event&){}; //=0 virtual void dispatch(const Event&){}; //=0
// virtual void dispatch(Event&) // virtual void dispatch(Event&)
// { // {
@ -27,6 +105,9 @@ public:
// }; // };
}; };
/**
* intermediate, and hierachy
*/
template<class Event, class... Others> template<class Event, class... Others>
class EventList<Event, Others...> class EventList<Event, Others...>
: public EventList<Event> : public EventList<Event>

91
tests/test_event_basic.cpp
View File

@ -57,6 +57,9 @@ class Foo_pp : public Foo
public: public:
// for c++ 17 // for c++ 17
/**
* if cast back to Foo, template function will disapear.
*/
template<typename EVT> template<typename EVT>
void dispatch(EVT evt) void dispatch(EVT evt)
{ {
@ -101,61 +104,8 @@ TEST_F(Evt_trans_test, create_test)
* I want this be interface only. * I want this be interface only.
* @todo require a dynamic map to map from rtti typeinfo to coresponding function。 * @todo require a dynamic map to map from rtti typeinfo to coresponding function。
*/ */
class Fake_module_process_ev : public EventList<AEvent, BEvent> class Fake_module_process_ev : virtual public EventList<AEvent, BEvent>
{ {}; // Fake_module_process_ev
// struct Concept
// { // (5)
// virtual ~Concept()
// {
// }
// virtual void dispatch() = 0;
// };
// std::unique_ptr<Concept> pimpl_;
// template<typename T> // (6)
// struct Model : Concept
// {
// Model(const T& t)
// : object(t)
// {
// }
// void dispatch() override
// {
// return object.dispatch();
// }
// private:
// T object;
// };
public:
// /**
// * @todo type erase
// * @see https://www.hmoonotes.org/2023/06/cpp-type-erasure.html
// * @see https://www.modernescpp.com/index.php/type-erasure/
// */
// // template<typename EVT>
// // void dispatch(EVT evt)
// // {
// // // I want to override this. (type erase)
// // std::cout << "base interface\n";
// // };
template<typename EVT>
void dispatch(EVT evt)
{
using namespace std;
// for (auto const& [key, val] : fmap) {
// }
auto func = std::any_cast<std::function<void(EVT&)>>(fmap.at(type_index(typeid(EVT))));
func(evt); // dispatch
};
protected:
// void (*)(std::any &);
std::map<std::type_index, std::any> fmap;
}; // Fake_module_process_ev
/** /**
* 用friend 會變成 `dispatch(foo, a_event);` 而非 `foo.dispatch(a_event);` * 用friend 會變成 `dispatch(foo, a_event);` 而非 `foo.dispatch(a_event);`
@ -168,6 +118,8 @@ protected:
// template<typename Functor> // template<typename Functor>
class So5_fake_module_process_ev : virtual public Fake_module_process_ev class So5_fake_module_process_ev : virtual public Fake_module_process_ev
{ {
using EventList<AEvent>::dispatch; // to disable warning
so_5::mbox_t target; so_5::mbox_t target;
public: public:
@ -177,23 +129,21 @@ public:
using namespace std; using namespace std;
// iterate over all the inherit class and generate function from functor. // iterate over all the inherit class and generate function from functor.
// //
std::function<void(AEvent&)> func = [this](AEvent& evt) -> void { so_5::send<AEvent>(target); }; std::function<void(AEvent&)> func = [this](AEvent& evt) -> void {
// so_5::send<AEvent>(target, evt.speed); //both work, but this isn't
so_5::send<AEvent>(target, evt);
};
fmap[type_index(typeid(AEvent))] = std::any(func); fmap[type_index(typeid(AEvent))] = std::any(func);
// Functor<>; // Functor<>;
} }
// template<typename EVT> void dispatch(const BEvent& evt) override
// void dispatch(EVT evt) {
// { std::cout << "So5_fake is handling BEvent" << endl;
// // cout << "this is additional wrapper from event name: " << evt.name << "\n"; }
// cout << "this is additional wrapper from event name: "
// << "\n";
// // static_cast<EventList<decltype(evt)>&>(*this).dispatch(evt);
// so_5::send<EVT>(target);
// }
}; };
/** /**
* simulate module process which require event interface * simulate module process which require event interface but hide implement.
*/ */
void void
fake_module_process(Fake_module_process_ev* evt_li_ptr) fake_module_process(Fake_module_process_ev* evt_li_ptr)
@ -202,8 +152,13 @@ fake_module_process(Fake_module_process_ev* evt_li_ptr)
std::cout << "fake module called\n"; std::cout << "fake module called\n";
std::this_thread::sleep_for(std::chrono::milliseconds(100)); std::this_thread::sleep_for(std::chrono::milliseconds(100));
const AEvent a_ev = AEvent{ .speed = 5.0 }; const AEvent a_ev = AEvent{ .speed = 5.0 };
evt_li_ptr->dispatch(a_ev); // static_cast<EventList<>*>(evt_li_ptr)->dispatch(a_ev);
// static_cast<EventList<>*>(evt_li_ptr)->dispatch(a_ev);
// evt_li_ptr->ev_dispatch(a_ev);
// static_cast<EventList<decltype(a_ev)>&>(*evt_li_ptr).dispatch(a_ev); // static_cast<EventList<decltype(a_ev)>&>(*evt_li_ptr).dispatch(a_ev);
dispatch(evt_li_ptr, a_ev);
const BEvent b_ev = BEvent();
dispatch(evt_li_ptr, b_ev);
std::cout << "fake module exist\n"; std::cout << "fake module exist\n";
// //
} }
@ -213,7 +168,7 @@ class pinger final : public so_5::agent_t
void on_pong(mhood_t<AEvent> cmd) void on_pong(mhood_t<AEvent> cmd)
{ {
std::cout << "actor pinger: received a A event\n"; std::cout << "actor pinger: received a A event, speed: " << cmd->speed << ".\n";
} }
public: public: