Delay.hpp

// SPDX-FileCopyrightText: 2025 Vincent Leroy
// SPDX-License-Identifier: MIT
//
// This file is part of dfx.
//
// Licensed under the MIT License. See the LICENSE file in the project root
// for full license information.
 
#pragma once
 
// Standard includes
#include <chrono>
#include <queue>
 
// Project includes
#include <dfx-core/Node.hpp>
#include <dfx-fdwatch/Timer.hpp>
 
namespace dfx::Node
{
class Delay : public Core::Node
{
    DFX_NODE("Delay")
 
    struct MessageData
    {
        Core::MessagePtr message;
        std::chrono::steady_clock::time_point deliveryTime;
    };
 
public:
    Delay(Id id, std::string name);
 
protected:
    void initializeImpl(nlohmann::json config) override;
    void handleMessage(Core::InputPort const & port, Core::MessagePtr message) override;
 
private:
    void _onTimerTimeout();
 
private:
    std::chrono::milliseconds _delay{0};
    std::queue<MessageData> _pendingMessages;
    FdWatch::Timer _timer;
};
} // !namespace dfx::Node