VFS_remotoserver.h

Go to the documentation of this file.

#ifndef VFS_REMOTOSERVER_H
#define VFS_REMOTOSERVER_H
 
#include <QJsonDocument>
#include <QJsonObject>
//#include <QDomDocument>
 
#include "VFS/VFS_websocket/VFS_websocket/VFS_websocket_server.h"
 
class VFS_remotoserver : public VFS_websocket_server
{
        Q_OBJECT
 
        public:
                Q_INVOKABLE explicit VFS_remotoserver(quint16 port, QString auth, QString sessions, QHostAddress addr=QHostAddress::Any, QWebSocketServer::SslMode ssl=QWebSocketServer::NonSecureMode, QString sslCertPath="", QString sslKeyPath="");
                virtual ~VFS_remotoserver();
 
                virtual QString reportDetails();
 
        signals:
 
        public slots:
                virtual void clientBinaryMessage(QByteArray message);
                virtual void clientTextMessage(QString message);
 
        protected:
                virtual VFS_websocket_client *createWebsocketClient(QWebSocket *s);
 
        private:
                static int count;                                       
};
 
class VFS_remotoserver_client : public VFS_websocket_client
{
        Q_OBJECT
 
        friend class VFS_remotoserver_request;
 
        public:
                explicit VFS_remotoserver_client(QWebSocket *socket, VFS_websocket_server *server );
                virtual ~VFS_remotoserver_client();
 
                virtual QJsonDocument receive(QByteArray data);
                virtual VFS_node *find(VFS_request *r);
 
                virtual QString reportDetails();
 
                bool writeUIDiff(QString path, QJsonDocument diff, QString user, bool binary=false);
                bool writeUIRead(QString path, QJsonDocument data, QJsonObject metadata, bool binary=false);
                bool writeUIWrite(QString path, QJsonDocument data, QJsonObject metadata, bool binary=false);
                bool writeUIRM(QString path, bool binary=false);
                bool writeUISubscribe(QString path, QJsonDocument data, QJsonObject metadata, bool binary=false);
                bool writeUILS(QString id, QString path, QJsonDocument data, QJsonObject metadata, bool binary=false);
                bool writeUIMetadata(QString path, QJsonObject metadata, bool binary=false);
                bool writeUIRequestLock(QString path, QJsonDocument data, bool binary=false);
                bool writeUIReleaseLock(QString path, QJsonDocument data, bool binary=false);
                bool writeUICode(QString libname, QString code, QString error, bool binary=false);
                bool writeUICodeDirectory(QJsonObject o, QString error, bool binary=false);
                bool writeError(QString message, bool binary=false);
                bool writeRequestSuccess(QString command, QString path, QJsonDocument data=QJsonDocument(), QJsonObject metadata=QJsonObject(), bool binary=false);
                bool writeRequestError(QString command, QString path, QString reason, bool binary=false);
 
                virtual VFS_request *createRequest(VFS_request::requestType type, QString path, QString user="unknown", QJsonDocument data=QJsonDocument(), QJsonObject metadata=QJsonObject(), bool dontDelete=false);
 
                QJsonObject parameters() const;
 
        protected:
                virtual void authenticate(QJsonDocument d);
 
                //virtual void ls(VFS_request *r);
                //virtual void read(VFS_request *r);
                virtual void write(VFS_request *r);
                //virtual void metadata(VFS_request *r);
                //virtual void report(VFS_request *r);
                //virtual void submit(VFS_request *r);
                virtual void rm(VFS_request *r);
 
                VFS_session                     *_session;              
 
                void addSourcePathMap(VFS_node *source, QString path);
 
                QString                         _user;                  
                QString                         _type;                  
                QJsonObject                     _parameters;            
                QMap<VFS_node *, QString>       _sourcePathMap;         
 
        private:
 
        public slots:
                virtual void receiveResponse(VFS_request *t);
                virtual void applyDiff(VFS_request *t);
                virtual void removeSourcePathMap(VFS_node *n);
};
 
class VFS_remotoserver_request : public VFS_request
{
        public:
                VFS_remotoserver_request(VFS_request::requestType type, VFS_remotoserver_client *origin, QString path="", QString user="unknown", QJsonDocument data=QJsonDocument(), QJsonObject metadata=QJsonObject(), bool binary=false);
                virtual ~VFS_remotoserver_request();
 
                virtual void execute();
 
                bool    _binary;                                        
};
 
#endif // VFS_REMOTOSERVER_H