Add a new integration test for events

Author: Junha Yang

Cargo.lock

@@ -20,6 +20,7 @@ hex = "0.4.2"
 ckey = {package = "codechain-key", path = "../key" }
 ccrypto = { package = "codechain-crypto", git = "https://github.com/CodeChain-io/rust-codechain-crypto.git", version = "0.3", tag = "v0.3.0" }
 rand = "0.7"
+primitives = { git = "https://github.com/CodeChain-io/rust-codechain-primitives.git", version = "0.5", tag = "v0.5.1" }
 
 [features]
 integration-test = []

integration-test/Cargo.toml

@@ -151,6 +151,19 @@ pub async fn get_latest_block(port: u16) -> u64 {
     value["data"]["block"]["header"]["number"].as_u64().unwrap()
 }
 
+pub async fn get_event(port: u16, tx_hash: primitives::H256) -> Vec<Vec<u8>> {
+    let query = "query Test($txHash: String!) {
+        event(txHash: $txHash)
+    }";
+    let mut variables = Value::Object(Default::default());
+    variables["txHash"] = Value::String(hex::encode(tx_hash.as_ref()));
+
+    let query_result = request_query(port, "engine", query, &variables.to_string()).await;
+    let value: Value = serde_json::from_str(&query_result).unwrap();
+    let list = value["data"]["event"].as_array().unwrap();
+    list.iter().map(|event| event.as_array().unwrap().iter().map(|x| x.as_i64().unwrap() as u8).collect()).collect()
+}
+
 /// This is a copy from `foundry-timestamp`.
 #[derive(serde::Serialize, serde::Deserialize, Debug)]
 pub struct SignedTransaction {

integration-test/src/lib.rs

@@ -152,3 +152,28 @@ async fn sequence_management2() {
         assert_eq!(value["data"]["account"]["seq"], tx_num_per_step * (i + 1));
     }
 }
+
+#[actix_rt::test]
+async fn events() {
+    let _node = run_node_override(simple_solo_node());
+    delay_for(Duration::from_secs(3)).await;
+
+    let user: Ed25519KeyPair = Random.generate().unwrap();
+
+    let tx1 = create_tx_hello(GRAPHQL_PORT, user.public(), user.private(), 0).await;
+    send_tx(GRAPHQL_PORT, tx1.tx_type(), tx1.body()).await.unwrap();
+
+    // invalid
+    let tx2 = create_tx_hello(GRAPHQL_PORT, user.public(), user.private(), 100).await;
+    send_tx(GRAPHQL_PORT, tx2.tx_type(), tx2.body()).await.unwrap();
+
+    delay_for(Duration::from_secs(4)).await;
+
+    let result = get_event(GRAPHQL_PORT, *tx1.hash()).await;
+
+    assert_eq!(1, result.len());
+    assert_eq!(*tx1.body(), result[0]);
+
+    let result = get_event(GRAPHQL_PORT, *tx2.hash()).await;
+    assert!(result.is_empty());
+}

integration-test/tests/integration_test.rs

@@ -80,7 +80,13 @@ impl TxOwner for ServiceHandler {
                 ExecuteError::NotAllowedHello => Err(()),
             }
         } else {
-            Ok(Default::default())
+            // For test/debug purpose, it returns an event which is just same as the content of transaction
+            Ok(TransactionOutcome {
+                events: vec![coordinator::types::Event {
+                    key: "".to_owned(),
+                    value: transaction.body().clone(),
+                }],
+            })
         }
     }