PersistenceService.hpp

#ifndef HAVE_PERSISTENCE_SERVICE_H
#define HAVE_PERSISTENCE_SERVICE_H 1

#include <string>
#include <iterator>

#include <boost/iterator/iterator_facade.hpp>


#include "Metadata.hpp"
#include "ContentItem.hpp"

#include "rdf_model.hpp"
#include "rdf_query.hpp"

namespace mico {
    namespace persistence {

        using namespace mico::rdf::query;

        class content_item_iterator;

        class PersistenceMetadata : public Metadata {
            friend class PersistenceService;

        protected:
            PersistenceMetadata(std::string baseUrl) : Metadata(baseUrl)  {};

        };


        class PersistenceService {

        private:

            std::string marmottaServerUrl;
            std::string contentDirectory;
            PersistenceMetadata metadata;

        public:

            PersistenceService(std::string serverAddress)
                    : marmottaServerUrl("http://" + serverAddress + ":8080/marmotta")
                    , contentDirectory("ftp://mico:mico@" + serverAddress)
                    , metadata("http://" + serverAddress + ":8080/marmotta") {};


            PersistenceService(std::string serverAddress, int marmottaPort, std::string user, std::string password)
                    : marmottaServerUrl("http://" + serverAddress + ":" + std::to_string(marmottaPort) + "/marmotta")
                    , contentDirectory("ftp://" + user + ":" + password + "@" + serverAddress)
                    , metadata("http://" + serverAddress + ":" + std::to_string(marmottaPort) + "/marmotta") {};


            PersistenceService(std::string marmottaServerUrl, std::string contentDirectory)
                    : marmottaServerUrl(marmottaServerUrl), contentDirectory(contentDirectory), metadata(marmottaServerUrl) {};


            PersistenceMetadata& getMetadata() { return metadata; };

            ContentItem* createContentItem();

            ContentItem* createContentItem(const mico::rdf::model::URI& id);


            ContentItem* getContentItem(const mico::rdf::model::URI& id);

            void deleteContentItem(const mico::rdf::model::URI& id);

            content_item_iterator begin();


            content_item_iterator end();



        };


#ifndef DOXYGEN_SHOULD_SKIP_THIS

        class content_item_iterator  : public boost::iterator_facade<content_item_iterator, ContentItem*, boost::forward_traversal_tag, ContentItem*> {
        private:
            int pos;
            const std::string& baseUrl;
            const std::string& contentDirectory;
            const mico::rdf::query::TupleResult* result;

        public:
            content_item_iterator(const std::string& baseUrl, const std::string& contentDirectory)
                    : pos(-1), baseUrl(baseUrl), contentDirectory(contentDirectory), result(NULL) {};

            content_item_iterator(const std::string& baseUrl, const std::string& contentDirectory, const mico::rdf::query::TupleResult* r)
                    : pos(0), baseUrl(baseUrl), contentDirectory(contentDirectory), result(r) {};

            ~content_item_iterator() { if(result) { delete result; } };


        private:

            friend class boost::iterator_core_access;

            void increment();
            bool equal(content_item_iterator const& other) const;
            ContentItem* dereference() const;

        };
#endif
    }
}

#endif