reflog.h

Go to the documentation of this file.

#ifndef CVMFS_REFLOG_H_
#define CVMFS_REFLOG_H_

#include <string>
#include <vector>

#include "reflog_sql.h"

namespace manifest {


class Reflog {
 public:
  static Reflog *Open(const std::string &database_path);
  static Reflog *Create(const std::string &database_path,
                        const std::string &repo_name);
  static void HashDatabase(const std::string &database_path,
                           shash::Any *hash_reflog);

  static bool ReadChecksum(const std::string &path, shash::Any* checksum);
  static bool WriteChecksum(const std::string &path, const shash::Any &value);

  bool AddCertificate(const shash::Any &certificate);
  bool AddCatalog(const shash::Any &catalog);
  bool AddHistory(const shash::Any &history);
  bool AddMetainfo(const shash::Any &metainfo);

  uint64_t CountEntries();
  bool List(SqlReflog::ReferenceType type,
            std::vector<shash::Any> *hashes) const;
  bool ListOlderThan(SqlReflog::ReferenceType type,
                     uint64_t timestamp,
                     std::vector<shash::Any> *hashes) const;

  bool Remove(const shash::Any &hash);

  bool ContainsCertificate(const shash::Any &certificate) const;
  bool ContainsCatalog(const shash::Any &catalog) const;
  bool ContainsHistory(const shash::Any &history) const;
  bool ContainsMetainfo(const shash::Any &metainfo) const;

  bool GetCatalogTimestamp(const shash::Any &catalog,
                           uint64_t *timestamp) const;

  void BeginTransaction();
  void CommitTransaction();

  void TakeDatabaseFileOwnership();
  void DropDatabaseFileOwnership();
  bool OwnsDatabaseFile() const {
    return database_.IsValid() && database_->OwnsFile();
  }
  bool Vacuum() { return database_->Vacuum(); }

  std::string fqrn() const;
  std::string database_file() const;

 protected:
  bool AddReference(const shash::Any               &hash,
                    const SqlReflog::ReferenceType  type);
  bool ContainsReference(const shash::Any               &hash,
                         const SqlReflog::ReferenceType  type) const;
  bool GetReferenceTimestamp(const shash::Any               &hash,
                             const SqlReflog::ReferenceType  type,
                             uint64_t *timestamp) const;

 private:
  bool CreateDatabase(const std::string &database_path,
                      const std::string &repo_name);
  bool OpenDatabase(const std::string &database_path);

  void PrepareQueries();

 private:
  UniquePtr<ReflogDatabase>       database_;

  UniquePtr<SqlInsertReference>   insert_reference_;
  UniquePtr<SqlCountReferences>   count_references_;
  UniquePtr<SqlListReferences>    list_references_;
  UniquePtr<SqlRemoveReference>   remove_reference_;
  UniquePtr<SqlContainsReference> contains_reference_;
  UniquePtr<SqlGetTimestamp>      get_timestamp_;
};

}  // namespace manifest

#endif  // CVMFS_REFLOG_H_