core/cursor.h

#ifndef DBALLE_CORE_CURSOR_H
#define DBALLE_CORE_CURSOR_H

#include <dballe/core/enq.h>
#include <dballe/cursor.h>
#include <memory>

namespace dballe {
namespace impl {

struct CursorStation : public dballe::CursorStation
{
    virtual void enq(Enq& enq) const = 0;

    inline static std::shared_ptr<CursorStation>
    downcast(std::shared_ptr<dballe::CursorStation> c)
    {
        auto res = std::dynamic_pointer_cast<CursorStation>(c);
        if (!res)
            throw std::runtime_error(
                "Attempted to downcast the wrong kind of cursor");
        return res;
    }

    static std::shared_ptr<CursorStation> make_empty();
};

struct CursorStationData : public dballe::CursorStationData
{
    virtual void enq(Enq& enq) const = 0;

    inline static std::shared_ptr<CursorStationData>
    downcast(std::shared_ptr<dballe::CursorStationData> c)
    {
        auto res = std::dynamic_pointer_cast<CursorStationData>(c);
        if (!res)
            throw std::runtime_error(
                "Attempted to downcast the wrong kind of cursor");
        return res;
    }

    static std::shared_ptr<CursorStationData> make_empty();
};

struct CursorData : public dballe::CursorData
{
    virtual void enq(Enq& enq) const = 0;

    inline static std::shared_ptr<CursorData>
    downcast(std::shared_ptr<dballe::CursorData> c)
    {
        auto res = std::dynamic_pointer_cast<CursorData>(c);
        if (!res)
            throw std::runtime_error(
                "Attempted to downcast the wrong kind of cursor");
        return res;
    }

    static std::shared_ptr<CursorData> make_empty();
};

struct CursorSummary : public dballe::CursorSummary
{
    virtual void enq(Enq& enq) const = 0;

    inline static std::shared_ptr<CursorSummary>
    downcast(std::shared_ptr<dballe::CursorSummary> c)
    {
        auto res = std::dynamic_pointer_cast<CursorSummary>(c);
        if (!res)
            throw std::runtime_error(
                "Attempted to downcast the wrong kind of cursor");
        return res;
    }

    static std::shared_ptr<CursorSummary> make_empty();
};

struct CursorMessage : public dballe::CursorMessage
{
    virtual void enq(Enq& enq) const {}

    inline static std::shared_ptr<CursorMessage>
    downcast(std::shared_ptr<dballe::CursorMessage> c)
    {
        auto res = std::dynamic_pointer_cast<CursorMessage>(c);
        if (!res)
            throw std::runtime_error(
                "Attempted to downcast the wrong kind of cursor");
        return res;
    }

    static std::shared_ptr<CursorMessage> make_empty();
};

} // namespace impl
} // namespace dballe
#endif