QtTCPConnection.hpp

Go to the documentation of this file.

//
// Created by cbihan on 05/10/2021.
//
 
#pragma once
 
#include <cstdint>
#include "Network/ITCPConnection.hpp"
#include "Network/RFCCodes.hpp"
#include <QTcpSocket>
#include <QtWidgets>
#include <functional>
#include <QString>
#include <QObject>
 
namespace Babel {
    class QtTCPConnection : public QObject, public ITCPConnection<RFCCodes> {
    Q_OBJECT
    public:
 
        void connect(const std::string &hostname, uint16_t port) override;
 
        void disconnect() override;
 
        bool isConnected() const override;
 
        void send(Message<RFCCodes> message) override;
 
        void readForMessages() override;
 
        void setCallbackOnMessage(std::function<void(Message<RFCCodes>)> callMessageReceived) override;
 
        uint64_t getId() const override;
 
        void setId(uint64_t id) override;
 
        std::string getPeerIp() const override;
 
        uint16_t getPeerPort() const override;
 
        explicit QtTCPConnection(QWidget *parent = nullptr, std::function<void(void)> onConnect = [](){});
 
    private:
 
        void readMessage();
 
        QTcpSocket *_socket;
 
        std::function<void(Message<RFCCodes>)> _callbackMessageReceived;
        TSQueue<Message<RFCCodes>> _messagesOut;
        Message<RFCCodes> _tmpMessage;
        uint64_t _bytesRead;
        uint64_t _connectionId;
    };
 
}