diff --git a/chronicle-receiver/exp_relic_plugin.cpp b/chronicle-receiver/exp_relic_plugin.cpp index 8a8651c..43586e9 100644 --- a/chronicle-receiver/exp_relic_plugin.cpp +++ b/chronicle-receiver/exp_relic_plugin.cpp @@ -1,5 +1,3 @@ - - // copyright defined in LICENSE.txt #include "exp_relic_plugin.hpp" @@ -2031,7 +2029,97 @@ class exp_relic_plugin_impl : std::enable_shared_from_this(fktransactionid)+","+ + bnums+",'"+ + payer_account+"','"+ + payee_account+"',"+ + amount_suf+",'"+ + trnstype+"',"+ + memo+",'"+ + blocktimestamp+"');"; + + PGresult *res = PQexec(conn, insertQuery.c_str()); + if (PQresultStatus(res) != PGRES_TUPLES_OK) { + terminalerror("fipxlviii_transfer",insertQuery,conn,res); + return; + } + PQclear(res); + + // Insert account activity for sender (payer) + insertQuery = "SELECT insaccountactivities("+ + boost::lexical_cast(fktransactionid)+","+ + bnums+",'"+ + payer_account+"','"+ + +"sender');"; + + res = PQexec(conn, insertQuery.c_str()); + if (PQresultStatus(res) != PGRES_TUPLES_OK) { + terminalerror("fipxlviii_sender_activity",insertQuery,conn,res); + return; + } + PQclear(res); + + // Insert account activity for receiver (payee) + insertQuery = "SELECT insaccountactivities("+ + boost::lexical_cast(fktransactionid)+","+ + bnums+",'"+ + payee_account+"','"+ + +"receiver');"; + + res = PQexec(conn, insertQuery.c_str()); + if (PQresultStatus(res) != PGRES_TUPLES_OK) { + terminalerror("fipxlviii_receiver_activity",insertQuery,conn,res); + return; + } + PQclear(res); + } + + ilog("FIP-48: Successfully processed ${n} token transfers", ("n", num_transfers)); + } //end if action is fipxlviii (FIP-48) } //end creator_action ordinal is 0 else if ((iactordinal > 1)&&(fktransactionid > -1)) { //action ordinal >1, and a valid tx