[Home]	[About]
[Screenshots]	[Download]
[News]	[Community]
[Documentation]	[Manual]
[Bugs & Requests]	[Wiki]

/home/tetron/hack/vos/libs/vos/extensions/revcontrol/revcontrol.hh

Go to the documentation of this file.

#ifndef _REVCONTROL_HH_
#define _REVCONTROL_HH_

#include <vos/vos/vos.hh>
#include <vos/extensions/fspersist/fspersist.hh>
#include <vos/extensions/revcontrol/revdefs.hh>
#include <vos/extensions/revcontrol/changelog.hh>

namespace VOS {
    class VERSIONED_API RevisionControlError : public std::runtime_error
    {
    public:
        RevisionControlError(const std::string& s) : std::runtime_error(s) { };
    };

    class VERSIONED_API RevisionControlPersistance : public FileSystemPersistance
    {
    private:
        Site* site;
        ChangeLog* log;

        void checkin(const char* path);
        void checkout(const char* path, const char* version = "");
        std::string readHeadRCSVersion(const std::string& path);

    public:
        RevisionControlPersistance(const std::string& dbpath);

        virtual void siteExtensionAttachedTo(Site* site);

        virtual void post_createVobject(VobjectState& state, Vobject* requester, VobjectBase* newvobject);
        virtual void post_renameVobject(VobjectState& state, Vobject* requester,
                                        const std::string& oldname, const std::string& newname);
        virtual void post_addType(VobjectState& state, boost::recursive_mutex::scoped_lock& state_lock,
                                  Vobject* requester, const std::string& s);
        virtual void post_removeType(VobjectState& state, boost::recursive_mutex::scoped_lock& state_lock,
                                     Vobject* requester, const std::string& s);
        virtual void post_insertChild(VobjectState& state, boost::recursive_mutex::scoped_lock& state_lock,
                                      Vobject* requester,
                                      int position, const std::string& contextual_name, Vobject* child);
        virtual void post_setChild(VobjectState& state, boost::recursive_mutex::scoped_lock& state_lock,
                                   Vobject* requester,
                                   int position, const std::string& contextual_name, Vobject* child,
                                   const std::string& oldcontextual_name, Vobject* oldchild);
        virtual void post_removeChild(VobjectState& state, boost::recursive_mutex::scoped_lock& state_lock,
                                      Vobject* requester,
                                      ParentChildRelation* pcr,
                                      bool strict);
        virtual void post_addToACL(AccessControlState* acs, Vobject* requester, const std::string& ACLname, Vobject* id,
                                   const std::string& oldACLname);
        virtual void post_removeFromACL(AccessControlState* acs, Vobject* requester,
                                        const std::string& ACLname, Vobject* id);
        virtual void post_deleteACL(AccessControlState* acs, Vobject* requester,
                                    const std::string& policies, AccessControlList* oldacl);
        virtual void post_setDefaultPolicy(AccessControlState* acs, Vobject* requester,
                                           const std::string& policy,
                                           const std::string& oldpolicy);

        virtual void wipeDatabase();

        virtual bool storeBlock(Vobject* from, const std::string& key, const std::string& data);
        virtual bool getBlock(Vobject* from, const std::string& key, std::string& data);
        virtual bool getBlockAtVersion(Vobject* from, const std::string& key,
                                       int version, std::string& data);

        std::string readHeadVersion(Vobject* from, const std::string& file);

        std::string getDefaultPolicyAtVersion(Vobject* vobj, unsigned int ver);
        std::string getACLsAtVersion(Vobject* vobj, unsigned int ver);
        std::string getChildrenAtVersion(Vobject* vobj, unsigned int ver);
        std::string getTypesAtVersion(Vobject* vobj, unsigned int ver);

        void findChangedVobjects(int startVer, int updateVer,
                                 std::map< std::string, std::set<std::string> >& dirty,
                                 Message* reply);

        void handleFetchVersionRequest(Message* m);
        void handleCommitRequest(Message* m);
        void handleSetTagRequest(Message* m);

        typedef enum { AddTag, Commit, FetchVersion} RevControlAccessType;

        bool validateRepositoryAccess(Vobject* requester, RevControlAccessType at, std::string& message);
    };

    class  RevControlAccess
    {
    public:
        virtual ~RevControlAccess()
{ }
        /** Get a short string describing this policy. */
        virtual const std::string getPolicyName() = 0;

        virtual bool checkAddTagPermission(Vobject* requester, std::string& message) = 0;
        virtual bool checkCommitPermission(Vobject* requester, std::string& message) = 0;
        virtual bool checkFetchVersionPermission(Vobject* requester, std::string& message) = 0;
    };

    class ReadOnlyRevControlAccess : public RevControlAccess
    {
    public:
        static ReadOnlyRevControlAccess static_;

        virtual ~ReadOnlyRevControlAccess() { }

        virtual const std::string getPolicyName()
            { return "revcontrol:read-only"; }

        virtual bool checkAddTagPermission(Vobject* requester, std::string& message)
            { return false; }
        virtual bool checkCommitPermission(Vobject* requester, std::string& message)
            { return false; }
        virtual bool checkFetchVersionPermission(Vobject* requester, std::string& message)
            { return true; }
    };

    class AcceptAllRevControlAccess : public RevControlAccess
    {
    public:
        static AcceptAllRevControlAccess static_;

        virtual ~AcceptAllRevControlAccess() { }

        virtual const std::string getPolicyName()
            { return "revcontrol:accept-all"; }

        virtual bool checkAddTagPermission(Vobject* requester, std::string& message)
            { return true; }
        virtual bool checkCommitPermission(Vobject* requester, std::string& message)
            { return true; }
        virtual bool checkFetchVersionPermission(Vobject* requester, std::string& message)
            { return true; }
    };

    class DenyAllRevControlAccess : public RevControlAccess
    {
    public:
        static DenyAllRevControlAccess static_;

        virtual ~DenyAllRevControlAccess() { }

        virtual const std::string getPolicyName()
            { return "revcontrol:deny-all"; }

        virtual bool checkAddTagPermission(Vobject* requester, std::string& message)
            { return false; }
        virtual bool checkCommitPermission(Vobject* requester, std::string& message)
            { return false; }
        virtual bool checkFetchVersionPermission(Vobject* requester, std::string& message)
            { return false; }
    };
}

#endif