UdpSource.hpp

// SPDX-FileCopyrightText: 2026 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
 
// Project includes
#include "../../details/Framer.hpp"
#include "SourceTransport.hpp"
#include <dfx-fdwatch/PollerFd.hpp>
#include <dfx-fdwatch/Timer.hpp>
 
namespace dfx::Core
{
class UdpSource : public SourceTransport
{
public:
    using SourceTransport::SourceTransport;
 
public:
    void start(FdWatch::Poller & poller) override;
    void stop() noexcept override;
 
private:
    void _onSocketReadyRead(FdWatch::EventTriggers events);
    void _onCleanupTimerTimeout();
 
private:
    FdWatch::PollerFd _socket;
    details::Framer _framer;
    FdWatch::Timer _cleanupTimer;
 
private:
    std::vector<uint8_t> _memory;
};
} // !namespace dfx::Core