LocalDestination.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
 
// Standard includes
#include <optional>
 
// Project includes
#include "DestinationTransport.hpp"
#include <dfx-utilities/sync-queues/SpscFixedQueue.hpp>
 
namespace dfx::Core
{
class LocalDestination : public DestinationTransport
{
public:
    using DestinationTransport::DestinationTransport;
 
public:
    void start(FdWatch::Poller &) override {}
    void stop() noexcept override {}

    bool deliver(MessagePtr message) override
    { return _pendingMessages.tryPush(std::move(message)); }

    int64_t pendingMessageCount() const noexcept override
    { return static_cast<int64_t>(_pendingMessages.size()); }
 
public:
    std::optional<MessagePtr> pop()
    { return _pendingMessages.tryPop(); }
 
private:
    Utils::SpscFixedQueue<MessagePtr, 64> _pendingMessages;
};
} // !namespace dfx::Core