VFS_mongo.h

Go to the documentation of this file.

#ifndef VFS_MONGOHD_H
#define VFS_MONGOHD_H
 
#include "VFS_datastore/VFS_datastore.h"
 
#include <stdexcept>
 
#ifndef Q_MOC_RUN
#include <mongocxx/instance.hpp>
#include <mongocxx/database.hpp>
#include <mongocxx/client.hpp>
#include <mongocxx/uri.hpp>
#endif
 
using namespace mongocxx;
 
class VFS_mongo;
 
class VFS_mongo_cache_entry : public VFS_datastore_cache_entry
{
        Q_OBJECT
 
        friend class VFS_mongo;
 
        public:
                explicit VFS_mongo_cache_entry(VFS_mongo *mongo, QString path, bool debug, int flushInterval, int expireInterval, bool create=false, bool container=false, QJsonObject createData=QJsonObject());
                virtual ~VFS_mongo_cache_entry();
 
                virtual bool valid(QString &reason);
                virtual bool isContainer();
 
        protected:
                VFS_mongo *_mongo;                      
                QString _path;                          
                bool _container;                        
 
                virtual void flush();
 
        public slots:
};
 
class VFS_mongo : public VFS_datastore
{
        Q_OBJECT
 
        friend class VFS_mongo_cache_entry;     //for update_one and find_one
 
        public:
                Q_INVOKABLE explicit VFS_mongo( QString uri, QString db, QString collection, quint64 size=VFS_datastore_cache::DEFAULT_DATACACHE_SIZE, bool debug=false, int flushInterval=5000, int expireInterval=60000, bool createCollection=false );
                virtual ~VFS_mongo();
 
                virtual QString reportDetails();
 
        protected:
                int _flushInterval;                     
                int _expireInterval;                    
 
                virtual QByteArray icon();
 
                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);
                virtual void subscribe(VFS_request *r);
 
                bool createDocument( QString path, QJsonObject o, quint64 &size, bool container=false );
                bool removeDocument( QString path );
                quint64 writeDocument( QString path, QJsonObject o, bool container=false );
                QJsonObject readDocument( QString path, quint64 &size, bool &container );
                bool createCollection( QString name );
 
        public slots:
        //      virtual void applyDiff(VFS_request *r);
 
        private:
                QString _url;                           
                QString _databaseName;                  
                QString _collection;                    
 
                static instance _instance;              
 
                client _client;                         
                database _database;                     
 
                bool _createCollection;                 
};
 
 
//https://stackoverflow.com/questions/8152720/correct-way-to-inherit-from-stdexception
class VFS_mongo_exception : public std::exception
{
        public:
                explicit VFS_mongo_exception(QString m);
                virtual ~VFS_mongo_exception() throw();
 
                virtual const char *what() const throw();
 
        protected:
                QString _message;                       
};
 
class VFS_mongo_entryException : public VFS_mongo_exception
{
        public:
                explicit VFS_mongo_entryException(QString m);
                virtual ~VFS_mongo_entryException() throw();
};
 
class VFS_mongo_directoryException : public VFS_mongo_exception
{
        public:
                explicit VFS_mongo_directoryException(QString m);
                virtual ~VFS_mongo_directoryException() throw();
};
 
class VFS_mongo_collectionException : public VFS_mongo_exception
{
        public:
                explicit VFS_mongo_collectionException(QString m);
                virtual ~VFS_mongo_collectionException() throw();
};
 
#endif // VFS_MONGO_PLUGIN_H