Channel.hpp

// SPDX-FileCopyrightText: 2025-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 <memory>
 
// Third-party includes
#include <nlohmann/json.hpp>
 
// Project includes
#include "messages/Message.hpp"
#include "transports/destinations/DestinationTransport.hpp"
#include "transports/sources/SourceTransport.hpp"
#include <dfx-hooks/Delivery.hpp>
#include <dfx-utilities/CopyMoveControl.hpp>
 
namespace dfx::Core
{
class Channel
{
    friend class SourceTransport;
 
public:
    using Id = uint32_t;
 
public:
    Channel(Id id, SourceTransportPtr source, DestinationTransportPtr destination);

    DFX_DISABLE_COPY_AND_MOVE(Channel);

    Id id() const noexcept { return _id; }

    int64_t pendingMessageCount() const;
 
public:
    SourceTransportPtr const & source() const noexcept           { return _source; }

    DestinationTransportPtr const & destination() const noexcept { return _destination; }
 
public:
    void setDeliveryHook(Hooks::Delivery * hook)
    { _deliveryHook = hook; }
 
protected:
    bool transmit(MessagePtr message);
 
private:
    Id const _id;
 
    SourceTransportPtr _source;
    DestinationTransportPtr _destination;
 
    Hooks::Delivery * _deliveryHook = nullptr;
};

using ChannelPtr = std::shared_ptr<Channel>;
} // !namespace dfx::Core