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

Refactor proposal approvement

Browse source
This commit is contained in:
Srdjan Obucina 2020-04-14 05:27:14 +02:00
parent 88c98db1f4
commit 4507601992
1 changed files with 70 additions and 45 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

115
libraries/plugins/peerplays_sidechain/sidechain_net_handler_bitcoin.cpp
View file

@ -917,46 +917,79 @@ bool sidechain_net_handler_bitcoin::process_proposal(const proposal_object &po)
op_obj_idx_0 = po.proposed_transaction.operations[0]; op_obj_idx_0 = po.proposed_transaction.operations[0];
} }
int32_t op_idx_1 = -1;
chain::operation op_obj_idx_1;
if (po.proposed_transaction.operations.size() >= 2) {
op_idx_1 = po.proposed_transaction.operations[1].which();
op_obj_idx_1 = po.proposed_transaction.operations[1];
}
switch (op_idx_0) { switch (op_idx_0) {
case chain::operation::tag<chain::son_wallet_update_operation>::value: { case chain::operation::tag<chain::son_wallet_update_operation>::value: {
//son_wallet_id_type swo_id = op_obj_idx_0.get<son_wallet_update_operation>().son_wallet_id;
//const auto &idx = database.get_index_type<son_wallet_index>().indices().get<by_id>(); bool address_ok = false;
//const auto swo = idx.find(swo_id); son_wallet_id_type swo_id = op_obj_idx_0.get<son_wallet_update_operation>().son_wallet_id;
//if (swo != idx.end()) { const auto &idx = database.get_index_type<son_wallet_index>().indices().get<by_id>();
// auto active_sons = gpo.active_sons; const auto swo = idx.find(swo_id);
// vector<son_info> wallet_sons = swo->sons; if (swo != idx.end()) {
// auto active_sons = gpo.active_sons;
// bool son_sets_equal = (active_sons.size() == wallet_sons.size()); vector<son_info> wallet_sons = swo->sons;
//
// if (son_sets_equal) { bool son_sets_equal = (active_sons.size() == wallet_sons.size());
// for (size_t i = 0; i < active_sons.size(); i++) {
// son_sets_equal = son_sets_equal && active_sons.at(i) == wallet_sons.at(i); if (son_sets_equal) {
// } for (size_t i = 0; i < active_sons.size(); i++) {
// } son_sets_equal = son_sets_equal && active_sons.at(i) == wallet_sons.at(i);
// }
// if (son_sets_equal) { }
// auto active_sons = gpo.active_sons;
// vector<string> son_pubkeys_bitcoin; if (son_sets_equal) {
// for (const son_info &si : active_sons) { auto active_sons = gpo.active_sons;
// son_pubkeys_bitcoin.push_back(si.sidechain_public_keys.at(sidechain_type::bitcoin)); vector<string> son_pubkeys_bitcoin;
// } for (const son_info &si : active_sons) {
// son_pubkeys_bitcoin.push_back(si.sidechain_public_keys.at(sidechain_type::bitcoin));
// uint32_t nrequired = son_pubkeys_bitcoin.size() * 2 / 3 + 1; }
// string reply_str = bitcoin_client->createmultisig(nrequired, son_pubkeys_bitcoin);
// uint32_t nrequired = son_pubkeys_bitcoin.size() * 2 / 3 + 1;
// std::stringstream active_pw_ss(reply_str); string reply_str = bitcoin_client->createmultisig(nrequired, son_pubkeys_bitcoin);
// boost::property_tree::ptree active_pw_pt;
// boost::property_tree::read_json(active_pw_ss, active_pw_pt); std::stringstream active_pw_ss(reply_str);
// if (active_pw_pt.count("error") && active_pw_pt.get_child("error").empty()) { boost::property_tree::ptree active_pw_pt;
// std::stringstream res; boost::property_tree::read_json(active_pw_ss, active_pw_pt);
// boost::property_tree::json_parser::write_json(res, active_pw_pt.get_child("result")); if (active_pw_pt.count("error") && active_pw_pt.get_child("error").empty()) {
// std::stringstream res;
// should_approve = (op_obj_idx_0.get<son_wallet_update_operation>().address == res.str()); boost::property_tree::json_parser::write_json(res, active_pw_pt.get_child("result"));
// }
// } address_ok = (op_obj_idx_0.get<son_wallet_update_operation>().address == res.str());
//} }
should_approve = true; }
}
bool transaction_ok = false;
object_id_type object_id = op_obj_idx_1.get<sidechain_transaction_create_operation>().object_id;
std::string op_tx_str = op_obj_idx_1.get<sidechain_transaction_create_operation>().transaction;
const auto &st_idx = database.get_index_type<sidechain_transaction_index>().indices().get<by_object_id>();
const auto st = st_idx.find(object_id);
if (st == st_idx.end()) {
std::string tx_str = "";
if (object_id.is<son_wallet_id_type>()) {
const auto &idx = database.get_index_type<son_wallet_index>().indices().get<by_id>();
const auto swo = idx.find(object_id);
if (swo != idx.end()) {
tx_str = op_tx_str; //create_primary_wallet_transaction();
}
}
transaction_ok = (op_tx_str == tx_str);
}
should_approve = address_ok &&
transaction_ok;
break; break;
} }
@ -1019,14 +1052,6 @@ bool sidechain_net_handler_bitcoin::process_proposal(const proposal_object &po)
std::string tx_str = ""; std::string tx_str = "";
if (object_id.is<son_wallet_id_type>()) {
const auto &idx = database.get_index_type<son_wallet_index>().indices().get<by_id>();
const auto swo = idx.find(object_id);
if (swo != idx.end()) {
tx_str = op_tx_str; //create_primary_wallet_transaction();
}
}
if (object_id.is<son_wallet_deposit_id_type>()) { if (object_id.is<son_wallet_deposit_id_type>()) {
const auto &idx = database.get_index_type<son_wallet_deposit_index>().indices().get<by_id>(); const auto &idx = database.get_index_type<son_wallet_deposit_index>().indices().get<by_id>();
const auto swdo = idx.find(object_id); const auto swdo = idx.find(object_id);