-
Notifications
You must be signed in to change notification settings - Fork 649
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #1860 from nathanhourt/bsip40
BSIP40 Implementation
- Loading branch information
Showing
49 changed files
with
4,321 additions
and
84 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,192 @@ | ||
| /* | ||
| * Copyright (c) 2019 Contributors. | ||
| * | ||
| * The MIT License | ||
| * | ||
| * Permission is hereby granted, free of charge, to any person obtaining a copy | ||
| * of this software and associated documentation files (the "Software"), to deal | ||
| * in the Software without restriction, including without limitation the rights | ||
| * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell | ||
| * copies of the Software, and to permit persons to whom the Software is | ||
| * furnished to do so, subject to the following conditions: | ||
| * | ||
| * The above copyright notice and this permission notice shall be included in | ||
| * all copies or substantial portions of the Software. | ||
| * | ||
| * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR | ||
| * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, | ||
| * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE | ||
| * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER | ||
| * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, | ||
| * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN | ||
| * THE SOFTWARE. | ||
| */ | ||
|
|
||
| #include <graphene/chain/custom_authority_evaluator.hpp> | ||
| #include <graphene/chain/custom_authority_object.hpp> | ||
| #include <graphene/chain/account_object.hpp> | ||
| #include <graphene/chain/database.hpp> | ||
| #include <graphene/chain/exceptions.hpp> | ||
| #include <graphene/chain/hardfork_visitor.hpp> | ||
|
|
||
| namespace graphene { namespace chain { | ||
|
|
||
| void_result custom_authority_create_evaluator::do_evaluate(const custom_authority_create_operation& op) | ||
| { try { | ||
| const database& d = db(); | ||
| auto now = d.head_block_time(); | ||
| FC_ASSERT(HARDFORK_BSIP_40_PASSED(now), "Custom active authorities are not yet enabled"); | ||
|
|
||
| op.account(d); | ||
|
|
||
| const auto& config = d.get_global_properties().parameters.extensions.value.custom_authority_options; | ||
| FC_ASSERT(config.valid(), "Cannot use custom authorities yet: global configuration not set"); | ||
| FC_ASSERT(op.valid_to > now, "Custom authority expiration must be in the future"); | ||
| FC_ASSERT((op.valid_to - now).to_seconds() <= config->max_custom_authority_lifetime_seconds, | ||
| "Custom authority lifetime exceeds maximum limit"); | ||
|
|
||
| bool operation_forked_in = hardfork_visitor(now).visit((operation::tag_type)op.operation_type.value); | ||
| FC_ASSERT(operation_forked_in, "Cannot create custom authority for operation which is not valid yet"); | ||
|
|
||
| auto restriction_count = restriction::restriction_count(op.restrictions); | ||
| FC_ASSERT(restriction_count <= config->max_custom_authority_restrictions, | ||
| "Custom authority has more than the maximum number of restrictions"); | ||
|
|
||
| for (const auto& account_weight_pair : op.auth.account_auths) | ||
| account_weight_pair.first(d); | ||
|
|
||
| const auto& index = d.get_index_type<custom_authority_index>().indices().get<by_account_custom>(); | ||
| auto range = index.equal_range(op.account); | ||
| FC_ASSERT(std::distance(range.first, range.second) < config->max_custom_authorities_per_account, | ||
| "Cannot create custom authority: account already has maximum number"); | ||
| range = index.equal_range(boost::make_tuple(op.account, op.operation_type)); | ||
| FC_ASSERT(std::distance(range.first, range.second) < config->max_custom_authorities_per_account_op, | ||
| "Cannot create custom authority: account already has maximum number for this operation type"); | ||
|
|
||
| return void_result(); | ||
| } FC_CAPTURE_AND_RETHROW((op)) } | ||
|
|
||
| object_id_type custom_authority_create_evaluator::do_apply(const custom_authority_create_operation& op) | ||
| { try { | ||
| database& d = db(); | ||
|
|
||
| return d.create<custom_authority_object>([&op] (custom_authority_object& obj) mutable { | ||
| obj.account = op.account; | ||
| obj.enabled = op.enabled; | ||
| obj.valid_from = op.valid_from; | ||
| obj.valid_to = op.valid_to; | ||
| obj.operation_type = op.operation_type; | ||
| obj.auth = op.auth; | ||
| std::for_each(op.restrictions.begin(), op.restrictions.end(), [&obj](const restriction& r) mutable { | ||
| obj.restrictions.insert(std::make_pair(obj.restriction_counter++, r)); | ||
| }); | ||
| }).id; | ||
| } FC_CAPTURE_AND_RETHROW((op)) } | ||
|
|
||
| void_result custom_authority_update_evaluator::do_evaluate(const custom_authority_update_operation& op) | ||
| { try { | ||
| const database& d = db(); | ||
| auto now = d.head_block_time(); | ||
| old_object = &op.authority_to_update(d); | ||
| FC_ASSERT(old_object->account == op.account, "Cannot update a different account's custom authority"); | ||
|
|
||
| if (op.new_enabled) | ||
| FC_ASSERT(*op.new_enabled != old_object->enabled, | ||
| "Custom authority update specifies an enabled flag, but flag is not changed"); | ||
|
|
||
| const auto& config = d.get_global_properties().parameters.extensions.value.custom_authority_options; | ||
| auto valid_from = old_object->valid_from; | ||
| auto valid_to = old_object->valid_to; | ||
| if (op.new_valid_from) { | ||
| FC_ASSERT(*op.new_valid_from != old_object->valid_from, | ||
| "Custom authority update specifies a new valid from date, but date is not changed"); | ||
| valid_from = *op.new_valid_from; | ||
| } | ||
| if (op.new_valid_to) { | ||
| FC_ASSERT(*op.new_valid_to != old_object->valid_to, | ||
| "Custom authority update specifies a new valid to date, but date is not changed"); | ||
| FC_ASSERT(*op.new_valid_to > now, "Custom authority expiration must be in the future"); | ||
| FC_ASSERT((*op.new_valid_to - now).to_seconds() <= config->max_custom_authority_lifetime_seconds, | ||
| "Custom authority lifetime exceeds maximum limit"); | ||
| valid_to = *op.new_valid_to; | ||
| } | ||
| FC_ASSERT(valid_from < valid_to, "Custom authority validity begin date must be before expiration date"); | ||
|
|
||
| if (op.new_auth) { | ||
| FC_ASSERT(*op.new_auth != old_object->auth, | ||
| "Custom authority update specifies a new authentication authority, but authority is not changed"); | ||
| for (const auto& account_weight_pair : op.new_auth->account_auths) | ||
| account_weight_pair.first(d); | ||
| } | ||
|
|
||
| std::for_each(op.restrictions_to_remove.begin(), op.restrictions_to_remove.end(), [this](uint16_t id) { | ||
| FC_ASSERT(old_object->restrictions.count(id) == 1, "Cannot remove restriction ID ${I}: ID not found", | ||
| ("I", id)); | ||
| }); | ||
| if (!op.restrictions_to_add.empty()) { | ||
| // Sanity check | ||
| if (!old_object->restrictions.empty()) | ||
| FC_ASSERT((--old_object->restrictions.end())->first < old_object->restriction_counter, | ||
| "LOGIC ERROR: Restriction counter overlaps restrictions. Please report this error."); | ||
| FC_ASSERT(old_object->restriction_counter + op.restrictions_to_add.size() > old_object->restriction_counter, | ||
| "Unable to add restrictions: causes wraparound of restriction IDs"); | ||
| } | ||
|
|
||
| // Add up the restriction counts for all old restrictions not being removed, and all new ones | ||
| size_t restriction_count = 0; | ||
| for (const auto& restriction_pair : old_object->restrictions) | ||
| if (op.restrictions_to_remove.count(restriction_pair.first) == 0) | ||
| restriction_count += restriction_pair.second.restriction_count(); | ||
| restriction_count += restriction::restriction_count(op.restrictions_to_add); | ||
| // Check restriction count against limit | ||
| FC_ASSERT(restriction_count <= config->max_custom_authority_restrictions, | ||
| "Cannot update custom authority: updated authority would exceed the maximum number of restrictions"); | ||
|
|
||
| get_restriction_predicate(op.restrictions_to_add, old_object->operation_type); | ||
| return void_result(); | ||
| } FC_CAPTURE_AND_RETHROW((op)) } | ||
|
|
||
| void_result custom_authority_update_evaluator::do_apply(const custom_authority_update_operation& op) | ||
| { try { | ||
| database& d = db(); | ||
|
|
||
| d.modify(*old_object, [&op](custom_authority_object& obj) { | ||
| if (op.new_enabled) obj.enabled = *op.new_enabled; | ||
| if (op.new_valid_from) obj.valid_from = *op.new_valid_from; | ||
| if (op.new_valid_to) obj.valid_to = *op.new_valid_to; | ||
| if (op.new_auth) obj.auth = *op.new_auth; | ||
|
|
||
| std::for_each(op.restrictions_to_remove.begin(), op.restrictions_to_remove.end(), [&obj](auto id) mutable { | ||
| obj.restrictions.erase(id); | ||
| }); | ||
| std::for_each(op.restrictions_to_add.begin(), op.restrictions_to_add.end(), [&obj](const auto& r) mutable { | ||
| obj.restrictions.insert(std::make_pair(obj.restriction_counter++, r)); | ||
| }); | ||
|
|
||
| // Clear the predicate cache | ||
| obj.clear_predicate_cache(); | ||
| }); | ||
|
|
||
| return void_result(); | ||
| } FC_CAPTURE_AND_RETHROW((op)) } | ||
|
|
||
| void_result custom_authority_delete_evaluator::do_evaluate(const custom_authority_delete_operation& op) | ||
| { try { | ||
| const database& d = db(); | ||
|
|
||
| old_object = &op.authority_to_delete(d); | ||
| FC_ASSERT(old_object->account == op.account, "Cannot delete a different account's custom authority"); | ||
|
|
||
| return void_result(); | ||
| } FC_CAPTURE_AND_RETHROW((op)) } | ||
|
|
||
| void_result custom_authority_delete_evaluator::do_apply(const custom_authority_delete_operation& op) | ||
| { try { | ||
| database& d = db(); | ||
|
|
||
| d.remove(*old_object); | ||
|
|
||
| return void_result(); | ||
| } FC_CAPTURE_AND_RETHROW((op)) } | ||
|
|
||
| } } // graphene::chain |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.