supervisor_wx.h

#pragma once
 
//
// Copyright (c) 2019-2022 Ivan Baidakou (basiliscos) (the dot dmol at gmail dot com)
//
// Distributed under the MIT Software License
//
 
#include "rotor/wx/export.h"
#include "rotor/supervisor.h"
#include "rotor/wx/supervisor_config_wx.h"
#include "rotor/wx/system_context_wx.h"
#include <wx/event.h>
#include <wx/timer.h>
#include <memory>
#include <unordered_map>
 
namespace rotor {
namespace wx {

struct ROTOR_WX_API supervisor_wx_t : public supervisor_t {

    using config_t = supervisor_config_wx_t;

    template <typename Supervisor> using config_builder_t = supervisor_config_wx_builder_t<Supervisor>;

    supervisor_wx_t(supervisor_config_wx_t &config);
 
    void start() noexcept override;
    void shutdown() noexcept override;
    void enqueue(message_ptr_t message) noexcept override;
    // void on_timer_trigger(request_id_t timer_id) noexcept override;

    inline system_context_wx_t *get_context() noexcept { return static_cast<system_context_wx_t *>(context); }
 
  protected:
    struct ROTOR_WX_API timer_t : public wxTimer {
        using supervisor_ptr_t = intrusive_ptr_t<supervisor_wx_t>;

        timer_handler_base_t *handler;

        supervisor_ptr_t sup;

        timer_t(timer_handler_base_t *handler, supervisor_ptr_t &&sup_);

        virtual void Notify() noexcept override;
    };
 
    friend struct timer_t;
 
    void do_start_timer(const pt::time_duration &interval, timer_handler_base_t &handler) noexcept override;
    void do_cancel_timer(request_id_t timer_id) noexcept override;

    using timer_ptr_t = std::unique_ptr<timer_t>;

    using timers_map_t = std::unordered_map<request_id_t, timer_ptr_t>;

    wxEvtHandler *handler;

    timers_map_t timers_map;
};
 
} // namespace wx
} // namespace rotor