Utils_p.h

#include <QUuid>
 
 
#include <Cyqlops/Crypto/Hash.h>
#include <Cyqlops/Crypto/RSAAlgorithm.h>
 
#include <knowCore/Timestamp.h>
#include <knowCore/TypeDefinitions.h>
 
#include <kDB/Repository/TriplesStore_p.h>
#include <kDB/Repository/DatabaseInterface/PostgreSQL/SQLInterface_p.h>
 
namespace kDB::Repository::VersionControl::Utils
{
  inline QByteArray computeDeltaHash(const QByteArray& _diff)
  {
    return Cyqlops::Crypto::Hash::md5(_diff);
  } 
  inline QByteArray computeRevisionHash(const QByteArray& _content_hash, int _historicity)
  {
    return Cyqlops::Crypto::Hash::md5(_content_hash, _historicity);
  }
 
  inline QByteArray computeSignature(const Cyqlops::Crypto::RSAAlgorithm& _signature_algortihm, const QUuid& _author, const knowCore::Timestamp& _time, const QByteArray& _hash)
  {
    QByteArray hash = Cyqlops::Crypto::Hash::md5(_author.toByteArray(), _time.toEpoch<knowCore::NanoSeconds>().count(), _hash);
    return _signature_algortihm.sign(hash, Cyqlops::Crypto::Hash::Algorithm::RAW);
  }
 
  struct MetaVersion
  {
    static inline void setHead(const kDB::Repository::Transaction& _transaction, QSharedPointer<TriplesStore::Definition> _definition, int _revisionId, const QByteArray& _hash)
    {
      knowCore::ValueHash new_head_map;
      new_head_map.add("id", _revisionId);
      new_head_map.add("hash", QString::fromLatin1(_hash.toHex()));
      _definition->setMeta(QStringList() << "versioning" << "head", knowCore::Value::fromValue(new_head_map), _transaction);
    }
    static inline knowCore::ReturnValue<QByteArray> getHead(const QueryConnectionInfo& _connection_info, QSharedPointer<TriplesStore::Definition> _definition)
    {
      KNOWCORE_RETURN_VALUE_TRY(hash_var, DatabaseInterface::PostgreSQL::SQLInterface::getMeta(_connection_info, _definition->name, QStringList() << "versioning" << "head" << "hash"));
      KNOWCORE_RETURN_VALUE_TRY(hash_str, hash_var.value<QString>());
      return kCrvSuccess(QByteArray::fromHex(hash_str.toLatin1()));
    }
  };
}