arangodb/arangod/Transaction/Helpers.h

////////////////////////////////////////////////////////////////////////////////
/// DISCLAIMER
///
/// Copyright 2014-2016 ArangoDB GmbH, Cologne, Germany
/// Copyright 2004-2014 triAGENS GmbH, Cologne, Germany
///
/// Licensed under the Apache License, Version 2.0 (the "License");
/// you may not use this file except in compliance with the License.
/// You may obtain a copy of the License at
///
///     http://www.apache.org/licenses/LICENSE-2.0
///
/// Unless required by applicable law or agreed to in writing, software
/// distributed under the License is distributed on an "AS IS" BASIS,
/// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
/// See the License for the specific language governing permissions and
/// limitations under the License.
///
/// Copyright holder is ArangoDB GmbH, Cologne, Germany
///
/// @author Jan Steemann
////////////////////////////////////////////////////////////////////////////////

#ifndef ARANGOD_TRANSACTION_HELPERS_H
#define ARANGOD_TRANSACTION_HELPERS_H 1

#include "Basics/Common.h"
#include "Transaction/CountCache.h"
#include "Utils/OperationResult.h"
#include "VocBase/voc-types.h"

#include <velocypack/Slice.h>
#include <velocypack/StringRef.h>
#include <velocypack/velocypack-aliases.h>

namespace arangodb {
class CollectionNameResolver;

namespace basics {
class StringBuffer;
}

namespace velocypack {
class Builder;
}

namespace transaction {
class Context;
class Methods;
  
namespace helpers {
/// @brief extract the _key attribute from a slice
arangodb::velocypack::StringRef extractKeyPart(VPackSlice);

std::string extractIdString(CollectionNameResolver const*, VPackSlice, VPackSlice const&);

/// @brief quick access to the _key attribute in a database document
/// the document must have at least two attributes, and _key is supposed to
/// be the first one
VPackSlice extractKeyFromDocument(VPackSlice);

/// @brief quick access to the _id attribute in a database document
/// the document must have at least two attributes, and _id is supposed to
/// be the second one
/// note that this may return a Slice of type Custom!
/// do NOT call this method when
/// - the input slice is not a database document
/// - you are not willing to deal with slices of type Custom
VPackSlice extractIdFromDocument(VPackSlice);

/// @brief quick access to the _from attribute in a database document
/// the document must have at least five attributes: _key, _id, _from, _to
/// and _rev (in this order)
VPackSlice extractFromFromDocument(VPackSlice);

/// @brief quick access to the _to attribute in a database document
/// the document must have at least five attributes: _key, _id, _from, _to
/// and _rev (in this order)
VPackSlice extractToFromDocument(VPackSlice);

/// @brief extract _key and _rev from a document, in one go
/// this is an optimized version used when loading collections, WAL
/// collection and compaction
void extractKeyAndRevFromDocument(VPackSlice slice, VPackSlice& keySlice,
                                  TRI_voc_rid_t& revisionId);

/// @brief extract _rev from a database document
TRI_voc_rid_t extractRevFromDocument(VPackSlice slice);
VPackSlice extractRevSliceFromDocument(VPackSlice slice);

OperationResult buildCountResult(std::vector<std::pair<std::string, uint64_t>> const& count,
                                 transaction::CountType type, int64_t& total);

/// @brief creates an id string from a custom _id value and the _key string
std::string makeIdFromCustom(CollectionNameResolver const* resolver,
                             VPackSlice const& idPart, VPackSlice const& keyPart);
};  // namespace helpers

/// @brief basics::StringBuffer leaser
/// @deprecated rather use StringLeaser for a shared std::string
class StringBufferLeaser {
 public:
  explicit StringBufferLeaser(Methods*);
  explicit StringBufferLeaser(transaction::Context*);
  ~StringBufferLeaser();
  arangodb::basics::StringBuffer* stringBuffer() const { return _stringBuffer; }
  arangodb::basics::StringBuffer* operator->() const { return _stringBuffer; }
  arangodb::basics::StringBuffer* get() const { return _stringBuffer; }

 private:
  transaction::Context* _transactionContext;
  arangodb::basics::StringBuffer* _stringBuffer;
};

/// @brief std::string leaser
class StringLeaser {
 public:
  explicit StringLeaser(Methods*);
  explicit StringLeaser(transaction::Context*);
  ~StringLeaser();
  std::string* string() const { return _string; }
  std::string* operator->() const { return _string; }
  std::string* get() const { return _string; }

 private:
  transaction::Context* _transactionContext;
  std::string* _string;
};

class BuilderLeaser {
 public:
  explicit BuilderLeaser(transaction::Methods*);
  explicit BuilderLeaser(transaction::Context*);
  ~BuilderLeaser();
  inline arangodb::velocypack::Builder* builder() const { return _builder; }
  inline arangodb::velocypack::Builder* operator->() const { return _builder; }
  inline arangodb::velocypack::Builder* get() const { return _builder; }
  inline arangodb::velocypack::Builder* steal() {
    arangodb::velocypack::Builder* res = _builder;
    _builder = nullptr;
    return res;
  }

 private:
  transaction::Context* _transactionContext;
  arangodb::velocypack::Builder* _builder;
};

inline bool isCoordinatorTransactionId(TRI_voc_tid_t tid) {
  return (tid % 4) == 0;
}

inline bool isFollowerTransactionId(TRI_voc_tid_t tid) {
  return (tid % 4) == 2;
}

inline bool isLeaderTransactionId(TRI_voc_tid_t tid) {
  return (tid % 4) == 1;
}
  
inline bool isChildTransactionId(TRI_voc_tid_t tid) {
  return isLeaderTransactionId(tid) || isFollowerTransactionId(tid);
}

inline bool isLegacyTransactionId(TRI_voc_tid_t tid) {
  return (tid % 4) == 3;
}
  
}  // namespace transaction
}  // namespace arangodb

#endif