data_buffer.h

Go to the documentation of this file.

#pragma once
#include "webcface/robot_link.h"
#include "webcface/view.h"
#include "webcface/components.h"
#include <sstream>
#include <memory>
 
WEBCFACE_NS_BEGIN
namespace internal {
template <typename Component>
class DataSetBuffer {
    Field target_;
    std::vector<Component> components_;
    bool modified_;
 
  public:
    DataSetBuffer() : target_(), components_(), modified_(false) {}
    explicit DataSetBuffer(const Field &base)
        : target_(base), components_(), modified_(false) {}
    DataSetBuffer(const DataSetBuffer &) = delete;
    DataSetBuffer(DataSetBuffer &&) = delete;
    DataSetBuffer &operator=(const DataSetBuffer &) = delete;
    DataSetBuffer &operator=(DataSetBuffer &&) = delete;
 
    virtual ~DataSetBuffer() noexcept {
        try {
            onDestroy();
        } catch (...) {
            // ignore exception
        }
    }
    void onDestroy() {
        if (!target_.data_w.expired() && target_.isSelf()) {
            sync();
        }
    }
 
    void sync() {
        if (modified_) {
            modified_ = false;
            onSync();
        }
    }
    void onSync();
 
    void init() {
        components_.clear();
        modified_ = true;
    }
 
    virtual void onAdd() {}
    void add(Component &&cp) {
        onAdd();
        components_.push_back(std::move(cp));
        modified_ = true;
    }
    void set(const std::vector<Component> &cv) {
        onAdd();
        components_ = cv;
        modified_ = true;
        sync();
    }
    void set(std::initializer_list<Component> cl) {
        onAdd();
        components_ = std::vector<Component>(cl.begin(), cl.end());
        modified_ = true;
        sync();
    }
    const std::vector<Component> &components() const { return components_; }
};
 
template <>
void DataSetBuffer<TemporalViewComponent>::onSync();
template <>
void DataSetBuffer<RobotLink>::onSync();
template <>
void DataSetBuffer<TemporalCanvas2DComponent>::onSync();
template <>
void DataSetBuffer<TemporalCanvas3DComponent>::onSync();
 
class ViewBuf final : public std::stringbuf,
                      public DataSetBuffer<TemporalViewComponent> {
    int sync() override;
 
  public:
    void addVC(TemporalViewComponent &&vc);
    void addText(std::string_view text, const TemporalViewComponent *vc = nullptr);
    void syncSetBuf() { this->DataSetBuffer<TemporalViewComponent>::sync(); }
 
    explicit ViewBuf();
    explicit ViewBuf(const Field &base);
    ~ViewBuf() override;
};
 
class Canvas2DDataBuf final : public DataSetBuffer<TemporalCanvas2DComponent> {
    double width_ = 0, height_ = 0;
 
  public:
    friend DataSetBuffer<TemporalCanvas2DComponent>;
    Canvas2DDataBuf() = default;
    Canvas2DDataBuf(const Field &base)
        : DataSetBuffer<TemporalCanvas2DComponent>(base) {}
    void onAdd() override { checkSize(); }
    void checkSize() const {
        if (width_ <= 0 && height_ <= 0) {
            throw std::invalid_argument("Canvas2D size is invalid (" +
                                        std::to_string(width_) + ", " +
                                        std::to_string(height_) + ")");
        }
    }
    void init(double width, double height) {
        width_ = width;
        height_ = height;
        this->DataSetBuffer<TemporalCanvas2DComponent>::init();
    }
    ~Canvas2DDataBuf() noexcept override {
        try {
            onDestroy();
        } catch (...) {
            // ignore exception
        }
    }
};
 
} // namespace internal
WEBCFACE_NS_END