doip_server.h

#ifndef DOIP_SERVER_H
#define DOIP_SERVER_H
 
#include <asyncbsdsocket/poller.h>
#include <asyncbsdsocket/tcp_listener.h>
#include <doiplib/doip_controller.h>
#include "../../ara/com/helper/concurrent_queue.h"
#include "./vehicle_id_request_handler.h"
#include "./diag_message_handler.h"
 
namespace application
{
    namespace doip
    {
        class DoipServer
        {
        public:
            static constexpr size_t cDoipPacketSize{64};
 
        private:
            AsyncBsdSocketLib::Poller *const mPoller;
            VehicleIdRequestHandler mVehicleIdRequestHandler;
            DiagMessageHandler mDiagMessageHandler;
            AsyncBsdSocketLib::TcpListener mListener;
            DoipLib::DoipController mController;
            ara::com::helper::ConcurrentQueue<std::vector<uint8_t>> mSendQueue;
 
            void onAccept();
            void onReceive();
            void onSend();
 
        public:
            DoipServer(
                AsyncBsdSocketLib::Poller *poller,
                helper::CurlWrapper *curl,
                std::string resourcesUrl,
                std::string ipAddress,
                uint16_t port,
                DoipLib::ControllerConfig &&config,
                std::string &&vin,
                uint16_t logicalAddress,
                uint64_t eid,
                uint64_t gid);
 
            ~DoipServer();
        };
    }
}
 
#endif