Peerplays_Blockchain/peerplays_migrated
1
0
Fork 0
Code Issues 35 Pull requests 4 Projects Releases 20 Packages Wiki Activity Actions

SON212-SON213 - Add Sidechain Plugin Code to report SON Down, Approve proposal from sidechain plugin

Browse source
This commit is contained in:
satyakoneru 2020-01-09 14:20:41 +00:00
parent 818acfabfa
commit bb87b32792
1 changed files with 52 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

52
libraries/plugins/peerplays_sidechain/peerplays_sidechain_plugin.cpp
View file

@ -2,6 +2,7 @@
#include <fc/log/logger.hpp>
#include <graphene/chain/sidechain_address_object.hpp>
#include <graphene/chain/proposal_object.hpp>
#include <graphene/peerplays_sidechain/sidechain_net_manager.hpp>
#include <graphene/utilities/key_conversion.hpp>
@ -27,6 +28,7 @@ class peerplays_sidechain_plugin_impl
void heartbeat_loop();
chain::proposal_create_operation create_son_down_proposal(chain::son_id_type son_id, fc::time_point_sec last_active_ts);
void on_block_applied( const signed_block& b );
void on_objects_new(const vector<object_id_type>& new_object_ids);
private:
peerplays_sidechain_plugin& plugin;
@ -267,6 +269,55 @@ void peerplays_sidechain_plugin_impl::on_block_applied( const signed_block& b )
}
}
void peerplays_sidechain_plugin_impl::on_objects_new(const vector<object_id_type>& new_object_ids)
{
chain::database& d = plugin.database();
chain::son_id_type my_son_id = *(_sons.begin());
const chain::global_property_object& gpo = d.get_global_properties();
const auto& idx = d.get_index_type<chain::son_index>().indices().get<by_id>();
auto son_obj = idx.find( my_son_id );
auto it = std::find(gpo.active_sons.begin(), gpo.active_sons.end(), my_son_id);
if(it == gpo.active_sons.end()) {
return;
}
auto approve_proposal = [ & ]( const chain::proposal_id_type& id )
{
chain::proposal_update_operation puo;
puo.fee_paying_account = son_obj->son_account;
puo.proposal = id;
puo.active_approvals_to_add = { son_obj->son_account };
chain::signed_transaction trx = d.create_signed_transaction(_private_keys.begin()->second, puo);
fc::future<bool> fut = fc::async( [&](){
try {
d.push_transaction(trx);
plugin.app().p2p_node()->broadcast(net::trx_message(trx));
return true;
} catch(fc::exception e){
ilog("peerplays_sidechain_plugin_impl: sending approval failed with exception ${e}",("e", e.what()));
return false;
}
});
fut.wait(fc::seconds(10));
};
for(auto object_id: new_object_ids) {
if( object_id.is<chain::proposal_object>() ) {
const object* obj = d.find_object(object_id);
const chain::proposal_object* proposal = dynamic_cast<const chain::proposal_object*>(obj);
if(proposal == nullptr) {
return;
}
if(proposal->proposed_transaction.operations.size() == 1
&& proposal->proposed_transaction.operations[0].which() == chain::operation::tag<chain::son_report_down_operation>::value) {
approve_proposal( proposal->id );
}
}
}
}
} // end namespace detail
peerplays_sidechain_plugin::peerplays_sidechain_plugin() :
@ -297,6 +348,7 @@ void peerplays_sidechain_plugin::plugin_initialize(const boost::program_options:
ilog("peerplays sidechain plugin: plugin_initialize()");
my->plugin_initialize(options);
database().applied_block.connect( [&]( const signed_block& b){ my->on_block_applied(b); } );
database().new_objects.connect([this](const vector<object_id_type>& ids, const flat_set<account_id_type>& impacted_accounts) { my->on_objects_new(ids); });
}
void peerplays_sidechain_plugin::plugin_startup()