Impelment the trait TransactionExecutor

Author: SeungMin Lee

basic_module/account/src/core.rs

@@ -22,3 +22,7 @@ pub use coordinator::types::{ErrorCode, TransactionExecutionOutcome};
 pub trait CheckTxHandler {
     fn check_transaction(&self, tx: &SignedTransaction) -> Result<(), ErrorCode>;
 }
+
+pub trait TransactionExecutor {
+    fn execute_transactions(&self, transactions: &[SignedTransaction]) -> Result<Vec<TransactionExecutionOutcome>, ()>;
+}

basic_module/account/src/impls.rs

@@ -15,10 +15,10 @@
 // along with this program.  If not, see <https://www.gnu.org/licenses/>.
 
 use crate::check;
-use crate::core::CheckTxHandler;
-use crate::internal::get_sequence;
+use crate::core::{CheckTxHandler, TransactionExecutor};
+use crate::internal::{add_balance, get_sequence, sub_balance};
 use crate::types::{Action, SignedTransaction};
-pub use coordinator::types::ErrorCode;
+use coordinator::types::{ErrorCode, TransactionExecutionOutcome};
 
 #[allow(dead_code)]
 pub struct Handler {}
@@ -39,3 +39,25 @@ impl CheckTxHandler for Handler {
         Ok(())
     }
 }
+
+#[allow(dead_code)]
+pub struct Executor {}
+
+impl TransactionExecutor for Executor {
+    fn execute_transactions(&self, transactions: &[SignedTransaction]) -> Result<Vec<TransactionExecutionOutcome>, ()> {
+        for signed_tx in transactions {
+            let Action::Pay {
+                sender,
+                receiver,
+                quantity,
+            } = signed_tx.tx.action;
+
+            if !check(signed_tx) || sub_balance(&receiver, quantity).is_err() {
+                return Err(())
+            }
+            add_balance(&sender, signed_tx.tx.fee + quantity);
+        }
+
+        Ok(vec![])
+    }
+}

basic_module/account/src/internal.rs

@@ -14,10 +14,36 @@
 // You should have received a copy of the GNU Affero General Public License
 // along with this program.  If not, see <https://www.gnu.org/licenses/>.
 
+use crate::error::Error;
 use crate::get_context;
 use crate::types::Account;
 use ckey::Ed25519Public as Public;
 
+pub fn add_balance(account_id: &Public, val: u64) {
+    if val == 0 {
+        return
+    }
+
+    let context = get_context();
+    let mut account: Account = get_account(account_id);
+
+    account.balance += val;
+    context.set(account_id, account.to_vec());
+}
+
+pub fn sub_balance(account_id: &Public, val: u64) -> Result<(), Error> {
+    let context = get_context();
+    let mut account: Account = get_account(account_id);
+
+    if account.balance < val {
+        return Err(Error::InvalidValue(account.balance, val))
+    }
+
+    account.balance -= val;
+    context.set(account_id, account.to_vec());
+    Ok(())
+}
+
 pub fn get_sequence(account_id: &Public) -> u64 {
     get_account(account_id).sequence
 }