phala-node: add rpc pha_getStorageChangesAt

Author: kvinwang

Cargo.lock

@@ -18,6 +18,7 @@ impl-serde = "0.3"
 log = { version = "0.4.14", default-features = false }
 hex = { version = "0.4.3", default-features = false }
 codec = { package = "parity-scale-codec", version = "2.2" }
+scale-info = { version = "1.0.0", default-features = false }
 
 # primitives
 sp-runtime = { path = "../../substrate/primitives/runtime" }

crates/phala-node-rpc-ext/Cargo.toml

@@ -1,6 +1,7 @@
 use std::marker::PhantomData;
 use std::sync::Arc;
 
+use codec::Encode;
 use jsonrpc_derive::rpc;
 use mq_seq::Error as MqSeqError;
 use pallet_mq_runtime_api::MqApi;
@@ -34,6 +35,11 @@ pub trait NodeRpcExtApi<BlockHash> {
         to: BlockHash,
     ) -> Result<GetStorageChangesResponse, StorageChangesError>;
 
+    /// Get storage changes made by given block.
+    /// Returns `hex_encode(scale_encode(StorageChanges))`
+    #[rpc(name = "pha_getStorageChangesAt")]
+    fn get_storage_changes_at(&self, block: BlockHash) -> Result<String, StorageChangesError>;
+
     /// Return the next mq sequence number for given sender which take the ready transactions in count.
     #[rpc(name = "pha_getMqNextSequence")]
     fn get_mq_seq(&self, sender_hex: String) -> Result<u64, MqSeqError>;
@@ -95,6 +101,12 @@ where
         }
     }
 
+    fn get_storage_changes_at(&self, block: Block::Hash) -> Result<String, StorageChangesError> {
+        let changes = self.get_storage_changes(block, block)?;
+        let encoded = changes[0].encode();
+        Ok(impl_serde::serialize::to_hex(&encoded, false))
+    }
+
     fn get_mq_seq(&self, sender_hex: String) -> Result<u64, MqSeqError> {
         mq_seq::get_mq_seq(&*self.client, &self.pool, sender_hex)
     }

crates/phala-node-rpc-ext/src/lib.rs

@@ -1,3 +1,6 @@
+use codec::{Decode, Encode};
+use scale_info::TypeInfo;
+
 use super::*;
 
 /// State RPC errors.
@@ -42,7 +45,7 @@ impl From<Error> for jsonrpc_core::Error {
 }
 
 /// Storage key.
-#[derive(Serialize, Deserialize, Clone, Debug)]
+#[derive(Serialize, Deserialize, Clone, Debug, Encode, Decode, TypeInfo)]
 pub struct StorageKey(#[serde(with = "impl_serde::serialize")] Vec<u8>);
 
 /// Storage value.
@@ -54,7 +57,7 @@ pub type StorageCollection<K, V> = Vec<(K, Option<V>)>;
 /// In memory arrays of storage values for multiple child tries.
 pub type ChildStorageCollection<K, V> = Vec<(K, StorageCollection<K, V>)>;
 
-#[derive(Serialize, Deserialize, Clone, Debug)]
+#[derive(Serialize, Deserialize, Clone, Debug, Encode, Decode, TypeInfo)]
 #[serde(rename_all = "camelCase")]
 pub struct StorageChanges {
     /// A value of `None` means that it was deleted.