add commitTransaction code for staking

node/node_newblock.go

@@ -90,6 +90,10 @@ func (node *Node) proposeNewBlock() (*types.Block, error) {
 		return nil, err
 	}
 
+	if len(selectedStakingTxs) > 0 {
+		utils.Logger().Debug().Int("selectedStakingtxs", len(selectedStakingTxs)).Msg("hehe, staking txs proposed")
+	}
+
 	// Prepare cross shard transaction receipts
 	receiptsList := node.proposeReceiptsProof()
 	if len(receiptsList) != 0 {

node/worker/worker.go

@@ -161,6 +161,7 @@ func (w *Worker) SelectStakingTransactionsForNewBlock(
 	}
 
 	selected := staking.StakingTransactions{}
+	// TODO: chao add total gas fee checking when needed
 	unselected := staking.StakingTransactions{}
 	invalid := staking.StakingTransactions{}
 	for _, tx := range txs {
@@ -181,7 +182,6 @@ func (w *Worker) SelectStakingTransactionsForNewBlock(
 		w.current.header.GasUsed()).Msg("[SelectStakingTransaction] Block gas limit and usage info")
 
 	return selected, unselected, invalid
-
 }
 
 func (w *Worker) commitStakingTransaction(tx *staking.StakingTransaction, coinbase common.Address) ([]*types.Log, error) {
@@ -256,9 +256,14 @@ func (w *Worker) CommitTransactions(txs types.Transactions, stakingTxns staking.
 
 		}
 	}
-	for _, stakingTx := range stakingTxns {
+	for _, tx := range stakingTxns {
-		_ = stakingTx
+		snap := w.current.state.Snapshot()
-		// TODO: add logic to commit staking txns
+		_, err := w.commitStakingTransaction(tx, coinbase)
+		if err != nil {
+			w.current.state.RevertToSnapshot(snap)
+			return err
+
+		}
 	}
 	return nil
 }