core.hpp

/*
 * This file is part of libtcspc
 * Copyright 2019-2026 Board of Regents of the University of Wisconsin System
 * SPDX-License-Identifier: MIT
 */
 
#pragma once
 
#include "introspect.hpp"
 
#include <ostream>
#include <stdexcept>
#include <string>
#include <utility>
 
namespace tcspc {

struct warning_event {
    std::string message;

    friend auto operator==(warning_event const &lhs,
                           warning_event const &rhs) noexcept
        -> bool = default;

    friend auto operator<<(std::ostream &stream, warning_event const &event)
        -> std::ostream & {
        return stream << event.message;
    }
};

struct never_event {
    never_event() = delete;
};
 
namespace internal {
 
class sink_all {
  public:
    [[nodiscard]] auto introspect_node() const -> processor_info {
        return processor_info(this, "sink_all");
    }
 
    [[nodiscard]] auto introspect_graph() const -> processor_graph {
        return processor_graph().push_entry_point(this);
    }
 
    template <typename Event> void handle(Event const & /* event */) {}
 
    void flush() {}
};
 
template <typename Downstream> class source_nothing {
    bool flushed = false;
    Downstream downstream;
 
  public:
    explicit source_nothing(Downstream downstream)
        : downstream(std::move(downstream)) {}
 
    [[nodiscard]] auto introspect_node() const -> processor_info {
        return processor_info(this, "source_nothing");
    }
 
    [[nodiscard]] auto introspect_graph() const -> processor_graph {
        return downstream.introspect_graph().push_entry_point(this);
    }
 
    void flush() {
        if (flushed) {
            throw std::logic_error(
                "source_nothing may not be flushed a second time");
        }
        flushed = true;
        downstream.flush();
    }
};
 
} // namespace internal

inline auto sink_all() { return internal::sink_all(); }

template <typename Downstream> auto source_nothing(Downstream downstream) {
    return internal::source_nothing<Downstream>(std::move(downstream));
}
 
} // namespace tcspc