messaging_bridge.h

Go to the documentation of this file.

// BSD 3-Clause License
// Copyright (c) 2024, 🍀☀🌕🌥 🌊
// See the LICENSE file in the project root for full license information.
 
#pragma once
#ifndef KCENON_NETWORK_INTERNAL_INTEGRATION_MESSAGING_BRIDGE_H_
#define KCENON_NETWORK_INTERNAL_INTEGRATION_MESSAGING_BRIDGE_H_
 
#include <kcenon/network/detail/config/feature_flags.h>
#include "internal/integration/bridge_interface.h"
#include "internal/core/messaging_client.h"
#include "internal/core/messaging_server.h"
 
#if KCENON_WITH_CONTAINER_SYSTEM
#include "container.h"
#endif
 
#if KCENON_WITH_THREAD_SYSTEM
// Suppress deprecation warnings from thread_system headers
#  pragma clang diagnostic push
#  pragma clang diagnostic ignored "-Wdeprecated-declarations"
// Include format for thread_system headers that use std::format
#  include <format>
#include <kcenon/thread/core/thread_pool.h>
#  pragma clang diagnostic pop
#endif
 
#include "kcenon/network/integration/thread_integration.h"
 
#include <memory>
#include <string>
#include <functional>
#include <chrono>
 
namespace kcenon::network::integration {
 
class messaging_bridge : public INetworkBridge {
public:
    messaging_bridge();
 
    ~messaging_bridge() override;
 
    // INetworkBridge interface implementation
 
    VoidResult initialize(const BridgeConfig& config) override;
 
    VoidResult shutdown() override;
 
    bool is_initialized() const override;
 
    BridgeMetrics get_metrics() const override;
 
    // messaging_bridge-specific methods (maintained for backward compatibility)
 
    std::shared_ptr<kcenon::network::core::messaging_server> create_server(
        const std::string& server_id
    );
 
    std::shared_ptr<kcenon::network::core::messaging_client> create_client(
        const std::string& client_id
    );
 
#if KCENON_WITH_CONTAINER_SYSTEM
    void set_container(
        std::shared_ptr<container_module::value_container> container
    );
 
    void set_container_message_handler(
        std::function<void(const container_module::value_container&)> handler
    );
#endif
 
#if KCENON_WITH_THREAD_SYSTEM
    void set_thread_pool(
        std::shared_ptr<kcenon::thread::thread_pool> pool
    );
#endif
 
    void set_thread_pool_interface(
        std::shared_ptr<thread_pool_interface> pool
    );
 
    std::shared_ptr<thread_pool_interface> get_thread_pool_interface() const;
 
    void reset_metrics();
 
private:
    class impl;
    std::unique_ptr<impl> pimpl_;
};
 
// Namespace alias for backward compatibility
namespace bridge = kcenon::network::integration;
 
} // namespace kcenon::network::integration
 
// Additional backward compatibility aliases
namespace network_module {
    using messaging_bridge = kcenon::network::integration::messaging_bridge;
    using messaging_server = kcenon::network::core::messaging_server;
    using messaging_client = kcenon::network::core::messaging_client;
    using messaging_session = kcenon::network::session::messaging_session;
}
 
#endif // KCENON_NETWORK_INTERNAL_INTEGRATION_MESSAGING_BRIDGE_H_