feat(application): implement transaction validation for the query runner

core/application/src/query_runner.rs

@@ -3,13 +3,17 @@ use draco_interfaces::{
     application::SyncQueryRunnerInterface,
     types::{
         AccountInfo, CommodityServed, CommodityTypes, Epoch, EpochInfo, Metadata, NodeInfo,
-        ProtocolParams, ReportedReputationMeasurements, Service, ServiceId, TotalServed, Value,
+        ProtocolParams, ReportedReputationMeasurements, Service, ServiceId, TotalServed,
+        TransactionResponse, UpdateRequest, Value,
     },
 };
 use fleek_crypto::{AccountOwnerPublicKey, ClientPublicKey, NodePublicKey};
 use hp_float::unsigned::HpUfloat;
 
-use crate::state::Committee;
+use crate::{
+    state::{Committee, State},
+    table::StateTables,
+};
 
 #[derive(Clone)]
 pub struct QueryRunner {
@@ -283,4 +287,15 @@ impl SyncQueryRunnerInterface for QueryRunner {
             self.param_table.get(ctx).get(param).unwrap_or(0)
         })
     }
+
+    fn validate_txn(&self, txn: UpdateRequest) -> TransactionResponse {
+        self.inner.run(|ctx| {
+            // Create the app/execution enviroment
+            let backend = StateTables {
+                table_selector: ctx,
+            };
+            let app = State::new(backend);
+            app.execute_txn(txn.clone())
+        })
+    }
 }

core/application/src/tests.rs

@@ -5,8 +5,8 @@ use anyhow::{anyhow, Result};
 use draco_interfaces::{
     application::ExecutionEngineSocket,
     types::{
-        Block, Epoch, ExecutionError, NodeInfo, ProofOfConsensus, Tokens, TotalServed,
-        TransactionResponse, UpdateMethod, UpdatePayload, UpdateRequest,
+        Block, Epoch, ExecutionData, ExecutionError, NodeInfo, ProofOfConsensus, Tokens,
+        TotalServed, TransactionResponse, UpdateMethod, UpdatePayload, UpdateRequest,
     },
     ApplicationInterface, BlockExecutionResponse, DeliveryAcknowledgment, SyncQueryRunnerInterface,
 };
@@ -807,3 +807,36 @@ async fn test_supply_across_epoch() {
         }
     }
 }
+
+#[test]
+async fn test_validate_txn() {
+    let (update_socket, query_runner) = init_app(None).await;
+    let (_, genesis_committee) = get_genesis();
+
+    // Submit a ChangeEpoch transaction that will revert (EpochHasNotStarted) and ensure that the
+    // `validate_txn` method of the query runner returns the same response as the update runner.
+    let req = get_update_request_node(
+        UpdateMethod::ChangeEpoch { epoch: 1 },
+        genesis_committee[0].public_key,
+    );
+    let res = run_transaction(vec![req.clone()], &update_socket)
+        .await
+        .unwrap();
+    assert_eq!(
+        res.txn_receipts[0],
+        //TransactionResponse::Revert(ExecutionError::EpochHasNotStarted)
+        query_runner.validate_txn(req)
+    );
+
+    // Submit a ChangeEpoch transaction that will succeed and ensure that the
+    // `validate_txn` method of the query runner returns the same response as the update runner.
+    let req = get_update_request_node(
+        UpdateMethod::ChangeEpoch { epoch: 0 },
+        genesis_committee[0].public_key,
+    );
+    let res = run_transaction(vec![req], &update_socket).await.unwrap();
+    assert_eq!(
+        res.txn_receipts[0],
+        TransactionResponse::Success(ExecutionData::None)
+    );
+}

core/interfaces/src/application.rs

@@ -8,7 +8,7 @@ use crate::{
     config::ConfigConsumer,
     types::{
         Block, CommodityServed, Epoch, EpochInfo, NodeInfo, ProtocolParams,
-        ReportedReputationMeasurements, TotalServed, TransactionResponse,
+        ReportedReputationMeasurements, TotalServed, TransactionResponse, UpdateRequest,
     },
 };
 
@@ -150,6 +150,9 @@ pub trait SyncQueryRunnerInterface: Clone + Send + Sync + 'static {
 
     /// Returns the passed in protocol parameter
     fn get_protocol_params(&self, param: ProtocolParams) -> u128;
+
+    /// Validates the passed in transaction
+    fn validate_txn(&self, txn: UpdateRequest) -> TransactionResponse;
 }
 
 #[derive(Clone, Debug)]