55 lines
1.3 KiB
C++
55 lines
1.3 KiB
C++
|
#pragma once
|
||
|
|
|
||
|
|
namespace scripting::lua
|
||
|
|
{
|
||
|
|
using event_arguments = std::vector<sol::lua_value>;
|
||
|
|
using event_callback = sol::protected_function;
|
||
|
|
|
||
|
|
class event_listener_handle
|
||
|
|
{
|
||
|
|
public:
|
||
|
|
uint64_t id = 0;
|
||
|
|
};
|
||
|
|
|
||
|
|
class event_listener final : public event_listener_handle
|
||
|
|
{
|
||
|
|
public:
|
||
|
|
std::string event = {};
|
||
|
|
entity entity{};
|
||
|
|
event_callback callback = {};
|
||
|
|
bool is_volatile = false;
|
||
|
|
bool is_deleted = false;
|
||
|
|
};
|
||
|
|
|
||
|
|
class event_handler final
|
||
|
|
{
|
||
|
|
public:
|
||
|
|
event_handler(sol::state& state);
|
||
|
|
|
||
|
|
event_handler(event_handler&&) noexcept = delete;
|
||
|
|
event_handler& operator=(event_handler&&) noexcept = delete;
|
||
|
|
|
||
|
|
event_handler(const scheduler&) = delete;
|
||
|
|
event_handler& operator=(const event_handler&) = delete;
|
||
|
|
|
||
|
|
void dispatch(const event& event);
|
||
|
|
|
||
|
|
event_listener_handle add_event_listener(event_listener&& listener);
|
||
|
|
|
||
|
|
void clear();
|
||
|
|
|
||
|
|
private:
|
||
|
|
sol::state& state_;
|
||
|
|
std::atomic_int64_t current_listener_id_ = 0;
|
||
|
|
|
||
|
|
using task_list = std::vector<event_listener>;
|
||
|
|
utils::concurrency::container<task_list> new_callbacks_;
|
||
|
|
utils::concurrency::container<task_list, std::recursive_mutex> callbacks_;
|
||
|
|
|
||
|
|
void dispatch_to_specific_listeners(const event& event, const event_arguments& arguments);
|
||
|
|
|
||
|
|
void remove(const event_listener_handle& handle);
|
||
|
|
void merge_callbacks();
|
||
|
|
};
|
||
|
|
}
|