net_aeroftp.h

// Copyright 2024-2025 The Aerospace Corporation.
// This file is a part of SatCat5, licensed under CERN-OHL-W v2 or later.
// AeroCube File Transfer Protocol (AeroFTP) transmitter
 
#pragma once
 
#include <satcat5/eth_header.h>
#include <satcat5/net_address.h>
#include <satcat5/net_protocol.h>
#include <satcat5/polling.h>
#include <satcat5/udp_core.h>
 
namespace satcat5 {
    namespace net {
        class AeroFtpClient : satcat5::poll::Timer {
        public:
            inline bool busy() const {return m_file_pos < m_file_len;}
            inline bool done() const {return m_file_pos >= m_file_len;}
 
            bool send(u32 file_id,
                satcat5::io::Readable* src,
                satcat5::io::Readable* aux = 0);
 
            void close();
 
            void throttle(unsigned msec_per_pkt);
 
        protected:
            explicit AeroFtpClient(satcat5::net::Address* dst);
 
            void end_of_file();             
            void skip_ahead();              
            void timer_event() override;    
 
            // Internal state.
            satcat5::net::Address* const m_dst;
            satcat5::io::Readable* m_src;   
            satcat5::io::Readable* m_aux;   
            u32 m_file_id;                  
            u32 m_file_len;                 
            u32 m_file_pos;                 
            u32 m_bytes_sent;               
            unsigned m_throttle;            
        };
    }
 
    namespace eth {
        constexpr satcat5::eth::MacType ETYPE_AEROFTP = {0x4346};
 
        class AeroFtpClient final
            : public satcat5::eth::AddressContainer
            , public satcat5::net::AeroFtpClient
        {
        public:
            explicit AeroFtpClient(satcat5::eth::Dispatch* eth);
 
            inline void connect(
                const satcat5::eth::MacAddr& addr,
                const satcat5::eth::MacType& type = satcat5::eth::ETYPE_AEROFTP)
                { m_addr.connect(addr, type); }
 
            inline bool ready() const
                { return m_addr.ready(); }
        };
    }
 
    namespace udp {
        constexpr satcat5::udp::Port PORT_AEROFTP = {0x4346};
 
        class AeroFtpClient final
            : public satcat5::udp::AddressContainer
            , public satcat5::net::AeroFtpClient
        {
        public:
            explicit AeroFtpClient(satcat5::udp::Dispatch* udp);
 
            inline void connect(
                const satcat5::udp::Addr& addr,
                const satcat5::udp::Port& port = satcat5::udp::PORT_AEROFTP)
                { m_addr.connect(addr, port, 0); }
 
            inline bool ready() const
                { return m_addr.ready(); }
        };
    }
}