#pragma once

#include <systemd/sd-event.h>

#include <chrono>
#include <memory>
#include <sdbusplus/bus.hpp>

// TODO: openbmc/openbmc#1720 - add error handling for sd_event API failures

namespace sdevent
{
namespace event
{
namespace timer
{
class Timer;
} // namespace timer
} // namespace event
namespace event
{

using EventPtr = sd_event*;
class Event;

/** @brief Get an instance of the 'default' event. */
Event newDefault();

namespace details
{

/** @brief unique_ptr functor to release an event reference. */
struct EventDeleter
{
    void operator()(sd_event* ptr) const
    {
        deleter(ptr);
    }

    decltype(&sd_event_unref) deleter = sd_event_unref;
};

/* @brief Alias 'event' to a unique_ptr type for auto-release. */
using Event = std::unique_ptr<sd_event, EventDeleter>;

} // namespace details

/** @class Event
 *  @brief Provides C++ bindings to the sd_event_* class functions.
 */
class Event
{
  public:
    /* Define all of the basic class operations:
     *     Not allowed:
     *         - Default constructor to avoid nullptrs.
     *         - Copy operations due to internal unique_ptr.
     *     Allowed:
     *         - Move operations.
     *         - Destructor.
     */
    Event() = delete;
    Event(const Event&) = delete;
    Event& operator=(const Event&) = delete;
    Event(Event&&) = default;
    Event& operator=(Event&&) = default;
    ~Event() = default;

    /** @brief Conversion constructor from 'EventPtr'.
     *
     *  Increments ref-count of the event-pointer and releases it when
     *  done.
     */
    explicit Event(EventPtr e);

    /** @brief Constructor for 'Event'.
     *
     *  Takes ownership of the event-pointer and releases it when done.
     */
    Event(EventPtr e, std::false_type);

    /** @brief Release ownership of the stored event-pointer. */
    EventPtr release()
    {
        return evt.release();
    }

    /** @brief Wait indefinitely for new event sources. */
    void loop()
    {
        sd_event_loop(evt.get());
    }

    /** @brief Attach to a DBus loop. */
    void attach(sdbusplus::bus::bus& bus)
    {
        bus.attach_event(evt.get(), SD_EVENT_PRIORITY_NORMAL);
    }

    /** @brief C++ wrapper for sd_event_now. */
    auto now()
    {
        using namespace std::chrono;

        uint64_t usec;
        sd_event_now(evt.get(), CLOCK_MONOTONIC, &usec);
        microseconds d(usec);
        return steady_clock::time_point(d);
    }

    friend class timer::Timer;

  private:
    EventPtr get()
    {
        return evt.get();
    }

    details::Event evt;
};

inline Event::Event(EventPtr l) : evt(sd_event_ref(l))
{
}

inline Event::Event(EventPtr l, std::false_type) : evt(l)
{
}

inline Event newDefault()
{
    sd_event* e = nullptr;
    sd_event_default(&e);
    return Event(e, std::false_type());
}

} // namespace event
} // namespace sdevent