coap_proxy.h

Go to the documentation of this file.

// Copyright 2025 The Aerospace Corporation.
// This file is a part of SatCat5, licensed under CERN-OHL-W v2 or later.
 
#pragma once
 
#include <satcat5/coap_connection.h>
#include <satcat5/coap_resource.h>
#include <satcat5/utils.h>
 
namespace satcat5 {
    namespace coap {
        class ProxyResource final : public satcat5::coap::Resource {
        public:
            ProxyResource(
                satcat5::coap::ProxyServer* server,
                const char* local_uri,
                const satcat5::ip::Addr& fwd_addr,
                const satcat5::udp::Port& fwd_port,
                const char* fwd_uri = nullptr);
 
            bool request_get(Connection* obj, Reader* msg) override
                { return request_any(obj, msg); }
            bool request_post(Connection* obj, Reader* msg) override
                { return request_any(obj, msg); }
            bool request_put(Connection* obj, Reader* msg) override
                { return request_any(obj, msg); }
            bool request_delete(Connection* obj, Reader* msg) override
                { return request_any(obj, msg); }
 
        protected:
            bool request_any(Connection* obj, Reader* msg);
 
            satcat5::coap::ProxyServer* const m_pool;
            const satcat5::ip::Addr m_fwd_addr;
            const satcat5::udp::Port m_fwd_port;
            const char* const m_fwd_uri;
        };
 
        class ProxyServer : public satcat5::coap::ResourceServer {
        public:
            explicit ProxyServer(satcat5::udp::Dispatch* udp,
                satcat5::udp::Port port = satcat5::udp::PORT_COAP);
 
            Connection* find_client(u32 token) const;
 
            ConnectionUdp* find_server(u32 token) const;
 
            u16 next_msgid();
 
            u32 next_token();
 
        protected:
            virtual void local_response(Connection* obj, Reader* msg) {} // GCOVR_EXCL_LINE
 
            void proxy_response(Connection* client, Reader* msg);
 
            // Override all proxy-related coap::Endpoint callbacks.
            // (The coap_request callback is handled by the parent class.)
            void coap_response(Connection* obj, Reader* msg) override;
            void coap_reqwait(Connection* obj, Reader* msg) override;
            void coap_separate(Connection* obj, Reader* msg) override;
            void coap_error(Connection* obj) override;
 
            // Internal state
            u16 m_msgid;    
            u32 m_token;    
 
            satcat5::coap::ConnectionUdp m_extra_connection;
        };
    }
}