TcpServer.h

#include "DLLInfo.h"
#include <NDEVR/Buffer.h>
#include <NDEVR/String.h>
#include <QObject>
 
class QTcpSocket;
class QTcpServer;
namespace NDEVR
{
    class String;
    class File;
    class Exception;
    class NDEVR_NETWORK_PROTOCOLS_API TcpServer : public QObject
    {
    public:
        Q_OBJECT
    public:
        explicit TcpServer(const String& server_name, uint04 port, QObject* parent = 0);
        explicit TcpServer(const String& server_name, QObject* parent = 0);
        void connectToRemoteServer(const String& remote_address);
        void connectToRemoteServer(QTcpSocket* remote_socket);
    protected:
        virtual bool dataReceived(const String& data_type, const String& args, const String& data, QTcpSocket* socket);
        virtual bool fileReceived(const String& data_type, const String& args, const File& data, QTcpSocket* socket);
    public:
        static QByteArray CreateMessagePacket(const StringView& type, const StringView& data, const StringView& args = StringView());
        static QByteArray CreateFilePacket(const File& file, bool send_file_contents);
        static QByteArray CreateOpenAppPacket(const File& application, const String& args = String(), bool wait_for_completion = true, bool windowless = false);
        static QByteArray CreateOpenFilePacket(const File& file_to_open);
        static QByteArray CreateRequestSendFilePacket(const File& file_to_request, const String& args = String());
        static QByteArray CreateSendErrorPacket(const Exception& e);
    public:
        virtual bool sendData(const StringView& data, QTcpSocket* socket = nullptr);
        virtual bool sendFile(const File& file, QTcpSocket* socket = nullptr);
        virtual bool sendFile(const File& file, bool send_file_contents, QTcpSocket* socket = nullptr);
        virtual bool sendShowFileBrowser(QTcpSocket* socket = nullptr);
        virtual bool sendSetScreenResolution(const Vector<2, uint04>& size, QTcpSocket* socket = nullptr);
        virtual bool sendOpenApp(const File& application, const String& args, bool wait_for_completion, bool windowless, QTcpSocket* socket = nullptr);
        virtual bool sendData(const StringView& data_type, const StringView& data, QTcpSocket* socket = nullptr);
        virtual bool sendError(const Exception& e, QTcpSocket* socket = nullptr);
        virtual bool sendPacket(const QByteArray& packet, QTcpSocket* socket = nullptr);
    protected:
        virtual void socketDisconnected(QTcpSocket* socket);
        virtual void showError(const Exception& e);
 
    public slots:
        void newConnectionSlot();
        void readSocketSlot();
        void discardSocketSlot();
        void displayErrorSlot(int socketError);
    public:
        static constexpr StringView generic_data_message_type = "data"; 
        static constexpr StringView error_data_message = "send_error_message"; 
        static constexpr StringView open_os_settings = "open_os_settings"; 
        static constexpr StringView set_screen_resolution = "set_screen_resolution"; 
        static constexpr StringView generic_file_message_type = "file"; 
        static constexpr StringView start_application_file_message_type = "start_application"; 
        static constexpr StringView open_file_message_type = "open_file"; 
        static constexpr StringView request_send_file = "request_send_file"; 
    private:
        QTcpServer* server; 
        String m_server_name; 
        Buffer<QTcpSocket*> m_sockets; 
    };
}