109 lines
2.7 KiB
C
109 lines
2.7 KiB
C
|
#ifndef SOCKET_H
|
||
|
|
#define SOCKET_H
|
||
|
|
|
||
|
|
#include <QtCore/QObject>
|
||
|
|
#include <QtWebSockets/QWebSocket>
|
||
|
|
#include <QtCore/QByteArray>
|
||
|
|
|
||
|
|
#include <wType/string.h>
|
||
|
|
#include <wType/uint64.h>
|
||
|
|
#include <wType/bytearray.h>
|
||
|
|
#include <wType/event.h>
|
||
|
|
#include <wType/vocabulary.h>
|
||
|
|
|
||
|
|
#include <utils/exception.h>
|
||
|
|
|
||
|
|
namespace W
|
||
|
|
{
|
||
|
|
class Socket:
|
||
|
|
public QObject
|
||
|
|
{
|
||
|
|
Q_OBJECT
|
||
|
|
friend class Server;
|
||
|
|
|
||
|
|
enum State
|
||
|
|
{
|
||
|
|
disconnected_s,
|
||
|
|
disconnecting_s,
|
||
|
|
connecting_s,
|
||
|
|
connected_s
|
||
|
|
};
|
||
|
|
|
||
|
|
enum DeserializationState {
|
||
|
|
dSize,
|
||
|
|
dBody
|
||
|
|
};
|
||
|
|
|
||
|
|
public:
|
||
|
|
explicit Socket(const String& p_name, QObject* parent = 0);
|
||
|
|
~Socket();
|
||
|
|
|
||
|
|
void send(const Event& ev) const;
|
||
|
|
void open(const String& addr, const Uint64& port);
|
||
|
|
void close();
|
||
|
|
|
||
|
|
Uint64 getId() const;
|
||
|
|
String getRemoteName() const;
|
||
|
|
String getName() const;
|
||
|
|
typedef QAbstractSocket::SocketError SocketError;
|
||
|
|
|
||
|
|
private:
|
||
|
|
explicit Socket(const String& p_name, QWebSocket *p_socket, uint64_t p_id, QObject *parent = 0);
|
||
|
|
|
||
|
|
void setHandlers();
|
||
|
|
void setId(const Uint64& p_id);
|
||
|
|
void setRemoteId();
|
||
|
|
void setRemoteName();
|
||
|
|
void setName(const String& p_name);
|
||
|
|
|
||
|
|
bool serverCreated;
|
||
|
|
State state;
|
||
|
|
DeserializationState dState;
|
||
|
|
QWebSocket *socket;
|
||
|
|
Uint64 id;
|
||
|
|
String name;
|
||
|
|
String remoteName;
|
||
|
|
ByteArray* helperBuffer;
|
||
|
|
|
||
|
|
signals:
|
||
|
|
void connected();
|
||
|
|
void disconnected();
|
||
|
|
void negotiationId(uint64_t p_id);
|
||
|
|
void error(W::Socket::SocketError err, const QString& msg);
|
||
|
|
void message(const W::Event&);
|
||
|
|
void proxy(const W::Event&);
|
||
|
|
|
||
|
|
public slots:
|
||
|
|
void cantDeliver(const Event& event) const;
|
||
|
|
|
||
|
|
private slots:
|
||
|
|
void onSocketConnected();
|
||
|
|
void onSocketDisconnected();
|
||
|
|
void onSocketError(QAbstractSocket::SocketError err);
|
||
|
|
void onBinaryMessageReceived(const QByteArray& ba);
|
||
|
|
void onEvent(W::Event* ev);
|
||
|
|
|
||
|
|
private:
|
||
|
|
class ErrorIdSetting:
|
||
|
|
public Utils::Exception
|
||
|
|
{
|
||
|
|
public:
|
||
|
|
ErrorIdSetting():Exception(){}
|
||
|
|
|
||
|
|
std::string getMessage() const{return "An attempt to set id to the socket not in connecting state";}
|
||
|
|
};
|
||
|
|
|
||
|
|
class ErrorNameSetting:
|
||
|
|
public Utils::Exception
|
||
|
|
{
|
||
|
|
public:
|
||
|
|
ErrorNameSetting():Exception(){}
|
||
|
|
|
||
|
|
std::string getMessage() const{return "An attempt to set name to the socket not in connecting state";}
|
||
|
|
};
|
||
|
|
|
||
|
|
};
|
||
|
|
}
|
||
|
|
|
||
|
|
#endif // SOCKET_H
|