pending_txs_storage.hpp

Go to the documentation of this file.

#ifndef IROHA_PENDING_TXS_STORAGE_HPP
#define IROHA_PENDING_TXS_STORAGE_HPP

#include <optional>

#include "ametsuchi/tx_presence_cache.hpp"
#include "common/result.hpp"
#include "interfaces/common_objects/transaction_sequence_common.hpp"
#include "interfaces/common_objects/types.hpp"
#include "interfaces/query_responses/pending_transactions_page_response.hpp"

namespace iroha {
  class MstState;

  class PendingTransactionStorage {
   public:
    enum ErrorCode {
      kNotFound,  // there is no batch which first tx has specified hash
    };

    struct Response {
      shared_model::interface::types::SharedTxsCollectionType transactions;
      shared_model::interface::types::TransactionsNumberType
          all_transactions_size;
      std::optional<
          shared_model::interface::PendingTransactionsPageResponse::BatchInfo>
          next_batch_info;

      Response() : all_transactions_size(0) {}
    };

    // TODO igor-egorov 2019-06-06 IR-516 remove deprecated interface
    [[deprecated]] virtual shared_model::interface::types::
        SharedTxsCollectionType
        getPendingTransactions(
            const shared_model::interface::types::AccountIdType &account_id)
            const = 0;

    virtual void insertPresenceCache(
        std::shared_ptr<ametsuchi::TxPresenceCache> &cache) = 0;

    virtual expected::Result<Response, ErrorCode> getPendingTransactions(
        const shared_model::interface::types::AccountIdType &account_id,
        const shared_model::interface::types::TransactionsNumberType page_size,
        const std::optional<shared_model::interface::types::HashType>
            &first_tx_hash) const = 0;

    virtual void removeTransaction(
        shared_model::interface::types::HashType const &hash) = 0;

    virtual void updatedBatchesHandler(
        std::shared_ptr<MstState> const &updated_batches) = 0;

    virtual void removeBatch(
        std::shared_ptr<shared_model::interface::TransactionBatch> const
            &batch) = 0;

    virtual ~PendingTransactionStorage() = default;
  };

}  // namespace iroha

#endif  // IROHA_PENDING_TXS_STORAGE_HPP