#include "event_manager.hh"
#include "client_manager.hh"

#include <poll.h>

namespace Kakoune
{

FDWatcher::FDWatcher(int fd, Callback callback)
    : m_fd{fd}, m_callback{std::move(callback)}
{
    EventManager::instance().m_fd_watchers.insert(this);
}

FDWatcher::~FDWatcher()
{
    EventManager::instance().m_fd_watchers.erase(this);
}

Timer::Timer(TimePoint date, Callback callback)
    : m_date{date}, m_callback{std::move(callback)}
{
    EventManager::instance().m_timers.insert(this);
}

Timer::~Timer()
{
    EventManager::instance().m_timers.erase(this);
}

void Timer::run()
{
    m_date = TimePoint::max();
    m_callback(*this);
}

EventManager::EventManager()
{
    m_forced_fd.reserve(4);
}

EventManager::~EventManager()
{
    kak_assert(m_fd_watchers.empty());
    kak_assert(m_timers.empty());
}

void EventManager::handle_next_events()
{
    std::vector<pollfd> events;
    events.reserve(m_fd_watchers.size());
    for (auto& watcher : m_fd_watchers)
        events.emplace_back(pollfd{ watcher->fd(), POLLIN | POLLPRI, 0 });
    std::vector<int> forced;
    std::swap(forced, m_forced_fd);

    TimePoint next_timer = TimePoint::max();
    for (auto& timer : m_timers)
    {
        if (timer->next_date() <= next_timer)
            next_timer = timer->next_date();
    }
    using namespace std::chrono;
    auto timeout = duration_cast<milliseconds>(next_timer - Clock::now()).count();
    poll(events.data(), events.size(), timeout < INT_MAX ? (int)timeout : INT_MAX);
    for (size_t i = 0; i < events.size(); ++i)
    {
        auto& event = events[i];
        const int fd = event.fd;
        if (event.revents or contains(forced, fd))
        {
            auto it = find_if(m_fd_watchers,
                              [fd](FDWatcher* w) { return w->fd() == fd; });
            if (it != m_fd_watchers.end())
                (*it)->run();
        }
    }

    TimePoint now = Clock::now();
    for (auto& timer : m_timers)
    {
        if (timer->next_date() <= now)
            timer->run();
    }

    if (ClientManager::has_instance())
        ClientManager::instance().redraw_clients();
}

void EventManager::force_signal(int fd)
{
    m_forced_fd.push_back(fd);
}

}