feat(ethereum): <- add PTokensRouterMetadataEvent with EthLog parser

common/ethereum/src/eth_contracts/mod.rs

@@ -2,6 +2,7 @@ mod erc20_token;
 mod erc20_vault;
 mod erc777_proxy;
 mod erc777_token;
+mod ptokens_router;
 mod weth;
 
 pub use self::{

common/ethereum/src/eth_contracts/ptokens_router.rs

@@ -0,0 +1,63 @@
+use std::convert::TryFrom;
+
+use common::{types::Bytes, AppError};
+use common_metadata::{MetadataChainId, METADATA_CHAIN_ID_NUMBER_OF_BYTES};
+use derive_more::Constructor;
+use ethabi::{decode as eth_abi_decode, ParamType as EthAbiParamType, Token as EthAbiToken};
+
+use crate::{EthLog, EthLogExt};
+
+#[derive(Debug, Clone, Constructor, Eq, PartialEq, Default)]
+pub struct PTokensRouterMetadataEvent {
+    pub user_data: Bytes,
+    pub origin_chain_id: MetadataChainId,
+    pub origin_address: String,
+    pub destination_chain_id: MetadataChainId,
+    pub destination_address: String,
+}
+
+impl TryFrom<&EthLog> for PTokensRouterMetadataEvent {
+    type Error = AppError;
+
+    fn try_from(log: &EthLog) -> std::result::Result<Self, Self::Error> {
+        info!("decoding `PTokensRouterMetadataEvent` from log...");
+
+        fn get_err_msg(field: &str) -> String {
+            format!("Error getting `{}` from `PTokensRouterMetadataEvent`!", field)
+        }
+
+        let tokens = eth_abi_decode(
+            &[
+                EthAbiParamType::Bytes,
+                EthAbiParamType::FixedBytes(METADATA_CHAIN_ID_NUMBER_OF_BYTES),
+                EthAbiParamType::String,
+                EthAbiParamType::FixedBytes(METADATA_CHAIN_ID_NUMBER_OF_BYTES),
+                EthAbiParamType::String,
+            ],
+            &log.get_data(),
+        )?;
+
+        Ok(Self {
+            user_data: match tokens[0] {
+                EthAbiToken::Bytes(ref bytes) => Ok(bytes.to_vec()),
+                _ => Err(get_err_msg("user_data")),
+            }?,
+            origin_chain_id: match tokens[1] {
+                EthAbiToken::FixedBytes(ref bytes) => Ok(MetadataChainId::from_bytes(bytes)?),
+                _ => Err(get_err_msg("origin_chain_id")),
+            }?,
+            origin_address: match tokens[2] {
+                EthAbiToken::String(ref string) => Ok(string.to_string()),
+                _ => Err(get_err_msg("origin_address")),
+            }?,
+            destination_chain_id: match tokens[1] {
+                EthAbiToken::FixedBytes(ref bytes) => Ok(MetadataChainId::from_bytes(bytes)?),
+                _ => Err(get_err_msg("destination_chain_id")),
+            }?,
+            destination_address: match tokens[2] {
+                EthAbiToken::String(ref string) => Ok(string.to_string()),
+                _ => Err(get_err_msg("destination_address")),
+            }?,
+        })
+    }
+}