hyperledger/iroha
Iroha - A simple, decentralized ledger http://iroha.tech
rocksdb_command_executor.hpp
Go to the documentation of this file.
1 
6 #ifndef IROHA_ROCKSDB_COMMAND_EXECUTOR_HPP
7 #define IROHA_ROCKSDB_COMMAND_EXECUTOR_HPP
8 
9 #include <optional>
10 
11 #include <fmt/format.h>
12 #include "ametsuchi/command_executor.hpp"
13 #include "ametsuchi/impl/rocksdb_common.hpp"
14 #include "ametsuchi/impl/rocksdb_db_transaction.hpp"
15 #include "interfaces/permissions.hpp"
16 
17 namespace rocksdb {
18  class Transaction;
19 }
20 
21 namespace shared_model::interface {
22  class AddAssetQuantity;
23  class AddPeer;
24  class AddSignatory;
25  class AppendRole;
26  class CompareAndSetAccountDetail;
27  class CallEngine;
28  class CreateAccount;
29  class CreateAsset;
30  class CreateDomain;
31  class CreateRole;
32  class DetachRole;
33  class GrantPermission;
34  class PermissionToString;
35  class RemovePeer;
36  class RemoveSignatory;
37  class RevokePermission;
38  class SetAccountDetail;
39  class SetQuorum;
40  class SubtractAssetQuantity;
41  class TransferAsset;
42  class SetSettingValue;
43 } // namespace shared_model::interface
44 
45 namespace iroha::ametsuchi {
46 
47  class VmCaller;
48 
49  class RocksDbCommandExecutor final : public CommandExecutor {
50  public:
51  using ExecutionResult = expected::Result<void, DbError>;
52 
53  enum ErrorCodes {
54  kNoPermissions = 2,
55  kNoAccount = 3,
56  kInvalidAmount = 3,
57  kRoleAlreadyExists = 3,
58  kSignatoryMustNotExist = 3,
59  kInvalidAssetAmount = 4,
60  kIncorrectOldValue = 4,
61  kPeersCountIsNotEnough = 4,
62  kNoSignatory = 4,
63  kCountNotEnough = 5,
64  kNotEnoughAssets = 6,
65  kIncorrectBalance = 7,
66  kException = 1002,
67  kNoImplementation = 1005,
68  kPermissionIsAlreadySet = 1007,
69  kPublicKeyIsEmpty = 1008,
70  kInvalidFieldSize = 1009,
71  };
72 
73  RocksDbCommandExecutor(
74  std::shared_ptr<RocksDBContext> db_context,
75  std::shared_ptr<shared_model::interface::PermissionToString>
76  perm_converter,
77  std::optional<std::reference_wrapper<const VmCaller>> vm_caller);
78 
79  ~RocksDbCommandExecutor();
80 
81  CommandResult execute(
82  const shared_model::interface::Command &cmd,
83  const shared_model::interface::types::AccountIdType &creator_account_id,
84  const std::string &tx_hash,
85  shared_model::interface::types::CommandIndexType cmd_index,
86  bool do_validation) override;
87 
88  void skipChanges() override;
89  DatabaseTransaction &dbSession() override;
90  std::shared_ptr<RocksDBContext> getSession();
91 
92  ExecutionResult operator()(
93  RocksDbCommon &common,
94  const shared_model::interface::AddAssetQuantity &command,
95  const shared_model::interface::types::AccountIdType &creator_account_id,
96  const std::string &tx_hash,
97  shared_model::interface::types::CommandIndexType cmd_index,
98  bool do_validation,
99  shared_model::interface::RolePermissionSet const &creator_permissions);
100 
101  ExecutionResult operator()(
102  RocksDbCommon &common,
103  const shared_model::interface::AddPeer &command,
104  const shared_model::interface::types::AccountIdType &creator_account_id,
105  const std::string &tx_hash,
106  shared_model::interface::types::CommandIndexType cmd_index,
107  bool do_validation,
108  shared_model::interface::RolePermissionSet const &creator_permissions);
109 
110  ExecutionResult operator()(
111  RocksDbCommon &common,
112  const shared_model::interface::AddSignatory &command,
113  const shared_model::interface::types::AccountIdType &creator_account_id,
114  const std::string &tx_hash,
115  shared_model::interface::types::CommandIndexType cmd_index,
116  bool do_validation,
117  shared_model::interface::RolePermissionSet const &creator_permissions);
118 
119  ExecutionResult operator()(
120  RocksDbCommon &common,
121  const shared_model::interface::CallEngine &command,
122  const shared_model::interface::types::AccountIdType &creator_account_id,
123  const std::string &tx_hash,
124  shared_model::interface::types::CommandIndexType cmd_index,
125  bool do_validation,
126  shared_model::interface::RolePermissionSet const &creator_permissions);
127 
128  ExecutionResult operator()(
129  RocksDbCommon &common,
130  const shared_model::interface::AppendRole &command,
131  const shared_model::interface::types::AccountIdType &creator_account_id,
132  const std::string &tx_hash,
133  shared_model::interface::types::CommandIndexType cmd_index,
134  bool do_validation,
135  shared_model::interface::RolePermissionSet const &creator_permissions);
136 
137  ExecutionResult operator()(
138  RocksDbCommon &common,
139  const shared_model::interface::CompareAndSetAccountDetail &command,
140  const shared_model::interface::types::AccountIdType &creator_account_id,
141  const std::string &tx_hash,
142  shared_model::interface::types::CommandIndexType cmd_index,
143  bool do_validation,
144  shared_model::interface::RolePermissionSet const &creator_permissions);
145 
146  ExecutionResult operator()(
147  RocksDbCommon &common,
148  const shared_model::interface::CreateAccount &command,
149  const shared_model::interface::types::AccountIdType &creator_account_id,
150  const std::string &tx_hash,
151  shared_model::interface::types::CommandIndexType cmd_index,
152  bool do_validation,
153  shared_model::interface::RolePermissionSet const &creator_permissions);
154 
155  ExecutionResult operator()(
156  RocksDbCommon &common,
157  const shared_model::interface::CreateAsset &command,
158  const shared_model::interface::types::AccountIdType &creator_account_id,
159  const std::string &tx_hash,
160  shared_model::interface::types::CommandIndexType cmd_index,
161  bool do_validation,
162  shared_model::interface::RolePermissionSet const &creator_permissions);
163 
164  ExecutionResult operator()(
165  RocksDbCommon &common,
166  const shared_model::interface::CreateDomain &command,
167  const shared_model::interface::types::AccountIdType &creator_account_id,
168  const std::string &tx_hash,
169  shared_model::interface::types::CommandIndexType cmd_index,
170  bool do_validation,
171  shared_model::interface::RolePermissionSet const &creator_permissions);
172 
173  ExecutionResult operator()(
174  RocksDbCommon &common,
175  const shared_model::interface::CreateRole &command,
176  const shared_model::interface::types::AccountIdType &creator_account_id,
177  const std::string &tx_hash,
178  shared_model::interface::types::CommandIndexType cmd_index,
179  bool do_validation,
180  shared_model::interface::RolePermissionSet const &creator_permissions);
181 
182  ExecutionResult operator()(
183  RocksDbCommon &common,
184  const shared_model::interface::DetachRole &command,
185  const shared_model::interface::types::AccountIdType &creator_account_id,
186  const std::string &tx_hash,
187  shared_model::interface::types::CommandIndexType cmd_index,
188  bool do_validation,
189  shared_model::interface::RolePermissionSet const &creator_permissions);
190 
191  ExecutionResult operator()(
192  RocksDbCommon &common,
193  const shared_model::interface::GrantPermission &command,
194  const shared_model::interface::types::AccountIdType &creator_account_id,
195  const std::string &tx_hash,
196  shared_model::interface::types::CommandIndexType cmd_index,
197  bool do_validation,
198  shared_model::interface::RolePermissionSet const &creator_permissions);
199 
200  ExecutionResult operator()(
201  RocksDbCommon &common,
202  const shared_model::interface::RemovePeer &command,
203  const shared_model::interface::types::AccountIdType &creator_account_id,
204  const std::string &tx_hash,
205  shared_model::interface::types::CommandIndexType cmd_index,
206  bool do_validation,
207  shared_model::interface::RolePermissionSet const &creator_permissions);
208 
209  ExecutionResult operator()(
210  RocksDbCommon &common,
211  const shared_model::interface::RemoveSignatory &command,
212  const shared_model::interface::types::AccountIdType &creator_account_id,
213  const std::string &tx_hash,
214  shared_model::interface::types::CommandIndexType cmd_index,
215  bool do_validation,
216  shared_model::interface::RolePermissionSet const &creator_permissions);
217 
218  ExecutionResult operator()(
219  RocksDbCommon &common,
220  const shared_model::interface::RevokePermission &command,
221  const shared_model::interface::types::AccountIdType &creator_account_id,
222  const std::string &tx_hash,
223  shared_model::interface::types::CommandIndexType cmd_index,
224  bool do_validation,
225  shared_model::interface::RolePermissionSet const &creator_permissions);
226 
227  ExecutionResult operator()(
228  RocksDbCommon &common,
229  const shared_model::interface::SetAccountDetail &command,
230  const shared_model::interface::types::AccountIdType &creator_account_id,
231  const std::string &tx_hash,
232  shared_model::interface::types::CommandIndexType cmd_index,
233  bool do_validation,
234  shared_model::interface::RolePermissionSet const &creator_permissions);
235 
236  ExecutionResult operator()(
237  RocksDbCommon &common,
238  const shared_model::interface::SetQuorum &command,
239  const shared_model::interface::types::AccountIdType &creator_account_id,
240  const std::string &tx_hash,
241  shared_model::interface::types::CommandIndexType cmd_index,
242  bool do_validation,
243  shared_model::interface::RolePermissionSet const &creator_permissions);
244 
245  ExecutionResult operator()(
246  RocksDbCommon &common,
247  const shared_model::interface::SubtractAssetQuantity &command,
248  const shared_model::interface::types::AccountIdType &creator_account_id,
249  const std::string &tx_hash,
250  shared_model::interface::types::CommandIndexType cmd_index,
251  bool do_validation,
252  shared_model::interface::RolePermissionSet const &creator_permissions);
253 
254  ExecutionResult operator()(
255  RocksDbCommon &common,
256  const shared_model::interface::TransferAsset &command,
257  const shared_model::interface::types::AccountIdType &creator_account_id,
258  const std::string &tx_hash,
259  shared_model::interface::types::CommandIndexType cmd_index,
260  bool do_validation,
261  shared_model::interface::RolePermissionSet const &creator_permissions);
262 
263  ExecutionResult operator()(
264  RocksDbCommon &common,
265  const shared_model::interface::SetSettingValue &command,
266  const shared_model::interface::types::AccountIdType &creator_account_id,
267  const std::string &,
268  shared_model::interface::types::CommandIndexType,
269  bool do_validation,
270  shared_model::interface::RolePermissionSet const &creator_permissions);
271 
272  private:
273  std::shared_ptr<RocksDBContext> db_context_;
274  std::shared_ptr<shared_model::interface::PermissionToString>
275  perm_converter_;
276  std::optional<std::reference_wrapper<const VmCaller>> vm_caller_;
277  RocksDbTransaction db_transaction_;
278  };
279 
280 } // namespace iroha::ametsuchi
281 
282 #endif // IROHA_ROCKSDB_COMMAND_EXECUTOR_HPP
shared_model::interface::CompareAndSetAccountDetail
Definition: compare_and_set_account_detail.hpp:21
permissions.hpp
shared_model::interface::AddSignatory
Definition: add_signatory.hpp:19
iroha::ametsuchi
Definition: block_query.hpp:17
iroha::ametsuchi::RocksDbTransaction
Definition: rocksdb_db_transaction.hpp:15
iroha::ametsuchi::RocksDbCommandExecutor
Definition: rocksdb_command_executor.hpp:49
shared_model::interface::SetQuorum
Definition: set_quorum.hpp:18
iroha::ametsuchi::RocksDbCommandExecutor::ErrorCodes
ErrorCodes
Definition: rocksdb_command_executor.hpp:53
shared_model::interface::PermissionSet
Definition: permissions.hpp:103
shared_model::interface::SubtractAssetQuantity
Definition: subtract_asset_quantity.hpp:20
shared_model::interface::SetSettingValue
Definition: set_setting_value.hpp:19
iroha::expected::Result
Definition: result_fwd.hpp:27
shared_model::interface::DetachRole
Definition: detach_role.hpp:19
shared_model::interface::RemoveSignatory
Definition: remove_signatory.hpp:18
shared_model::interface::CreateAsset
Definition: create_asset.hpp:18
shared_model::interface::CallEngine
Definition: call_engine.hpp:20
rocksdb
Definition: rocksdb_command_executor.hpp:17
shared_model::interface::RemovePeer
Definition: remove_peer.hpp:19
shared_model::interface::AppendRole
Definition: append_role.hpp:19
shared_model::interface::TransferAsset
Definition: transfer_asset.hpp:19
shared_model::interface::types::AccountIdType
std::string AccountIdType
Type of account id.
Definition: types.hpp:38
rocksdb_common.hpp
iroha::ametsuchi::CommandExecutor
Definition: command_executor.hpp:48
shared_model::interface
Definition: command_executor.hpp:14
shared_model::interface::CreateDomain
Definition: create_domain.hpp:18
shared_model::interface::CreateAccount
Definition: create_account.hpp:19
iroha::ametsuchi::execute
WsvCommandResult execute(soci::statement &st, Function &&error)
Definition: postgres_wsv_command.cpp:26
rocksdb_db_transaction.hpp
shared_model::interface::GrantPermission
Definition: grant_permission.hpp:19
shared_model::interface::SetAccountDetail
Definition: set_account_detail.hpp:19
iroha::ametsuchi::DatabaseTransaction
Definition: db_transaction.hpp:13
shared_model::interface::RevokePermission
Definition: revoke_permission.hpp:19
iroha::ametsuchi::RocksDbCommon
Definition: rocksdb_common.hpp:557
iroha::ametsuchi::kNoAccount
Definition: rocksdb_common.hpp:455
shared_model::interface::Command
Definition: command.hpp:41
shared_model::interface::types::CommandIndexType
int32_t CommandIndexType
Type of command index within a transaction.
Definition: types.hpp:100
shared_model::interface::AddAssetQuantity
Definition: add_asset_quantity.hpp:20
shared_model::interface::CreateRole
Definition: create_role.hpp:19
shared_model::interface::AddPeer
Definition: add_peer.hpp:20
command_executor.hpp