VFS_websocket_VFSclient.cpp

Go to the documentation of this file.

 
#include "VFS.h"
#include "VFS_websocket_VFSclient.h"
 
VFS_websocket_VFSclient::VFS_websocket_VFSclient(QString wsurl, QString username, QString password, quint16 interval)
: VFS_websocket_client(wsurl,interval)
, _username(username)
, _password(password)
{
}
 
VFS_websocket_VFSclient::~VFS_websocket_VFSclient()
{
}
 
void VFS_websocket_VFSclient::socket_connected()
{
        VFS_websocket_client::socket_connected();
 
        //printf("CONNECTED! SEND AUTH!\n");
        QJsonObject o;
        o["username"] = _username;
        o["password"] = _password;
        o["type"] = "vfsclient";
 
        sendText("identify",o);
}
 
void VFS_websocket_VFSclient::sendText(QString command, QJsonObject attributes)
{
        QJsonObject p;
 
        p["command"] = command;
        p["attributes"] = attributes;
 
        QString c = QJsonDocument(p).toJson();
 
        writeText( c );
}
 
void VFS_websocket_VFSclient::sendBinary(QString command, QJsonObject attributes)
{
        QJsonObject p;
 
        p["command"] = command;
        p["attributes"] = attributes;
 
        QByteArray c = QJsonDocument(p).toJson();
 
        writeBinary( c );
}
 
QJsonDocument VFS_websocket_VFSclient::receive(QByteArray message)
{
        QJsonDocument m = VFS_websocket_client::receive(message);
        if (m.isNull())
                return m;
 
        QJsonObject o = m.object();
        QString command = o["command"].toString();
        QJsonObject attrs = o["attributes"].toObject();
 
        if (command == "error")
        {
                VFS::ERROR( attrs["message"].toString() );
                m = QJsonDocument();                    //make a null document
        }
        else if (command == "authorization")
        {
                if (attrs["accepted"].toBool())
                {
                        _authenticated = true;
                        emit authorized();
                }
                else
                {
                        close();
                        killTimer(_connectID);          //auth has failed... don't attempt to reconnect with the same credentials
 
                        //printf("received:\n%s\n",qUtf8Printable(message));
 
                        VFS::ERROR( QString("%1 authorization was denied... use different credentials?").arg(className()) );
                        emit authDenied();
                }
        }
        else if (command == "ping" || command == "pong")
        {
                //do nothing
        }
        else if (command == "code")
        {
                VFS::WARN( QString("%1 should never receive code.").arg(className()) );
        }
        else
        {
                //VFS::WARN( QString("%1 unknown command: %2").arg(className()).arg(command) );
                emit commandReceived(command,attrs);
        }
 
        /*
                A subclass will probably want to implement:
                diff
                read
                subscribe
                metdata
                ls
                write
        */
 
        return m;
}