Flow Support

Cargo.toml

@@ -14,6 +14,7 @@ members = [
     'our-std',
     'gateway-crypto',
     'ethereum-client',
+    'flow-client',
     'test-utils/open-oracle-mock-reporter',
     'trx-request',
     'types-derive',

flow-client/Cargo.toml

@@ -0,0 +1,38 @@
+[package]
+name = 'flow-client'
+version = '0.1.0'
+authors = ['Compound <https://compound.finance>']
+edition = '2018'
+
+# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html
+
+[dependencies]
+codec = { package = 'parity-scale-codec', version = '2.0.0', default-features = false, features = ['derive'] }
+hex = { version = '0.4.2', default-features = false }
+hex-buffer-serde = { version = "0.3.0", default-features = false, features = ['alloc', 'const_len'] }
+serde = { version = '1.0.125', features = ['derive'], default-features = false }
+serde_json = { version = '1.0.64', features = ['alloc'], default-features = false }
+sp-io = { default-features = false, features = ['disable_oom', 'disable_panic_handler'], git = 'https://github.com/compound-finance/substrate', branch = 'jflatow/compound'}
+sp-core = { default-features = false, git = 'https://github.com/compound-finance/substrate', branch = 'jflatow/compound' }
+sp-runtime = { default-features = false, git = 'https://github.com/compound-finance/substrate', branch = 'jflatow/compound' }
+sp-runtime-interface = { default-features = false, git = 'https://github.com/compound-finance/substrate', branch = 'jflatow/compound' }
+sp-std = { default-features = false, git = 'https://github.com/compound-finance/substrate', branch = 'jflatow/compound' }
+our-std = { path = '../our-std', default-features = false }
+types-derive = { path = '../types-derive' }
+gateway-crypto = { path = '../gateway-crypto', default-features = false }
+
+[features]
+default = ['std']
+std = [
+    'codec/std',
+    'serde/std',
+    'serde_json/std',
+    'sp-core/std',
+    'sp-io/std',
+    'sp-runtime/std',
+    'sp-runtime-interface/std',
+    'sp-std/std',
+    'our-std/std',
+    'gateway-crypto/std',
+]
+runtime-debug = ['our-std/runtime-debug']

flow-client/src/events.rs

@@ -0,0 +1,74 @@
+use codec::{Decode, Encode};
+use our_std::convert::TryInto;
+use our_std::{Deserialize, RuntimeDebug, Serialize};
+
+use types_derive::Types;
+
+#[derive(Clone, Eq, PartialEq, Encode, Decode, RuntimeDebug, Types, Serialize, Deserialize)]
+struct Lock {
+    asset: String,
+    // sender: String,
+    recipient: String,
+    amount: u128,
+}
+
+#[derive(Clone, Eq, PartialEq, Encode, Decode, RuntimeDebug, Types, Serialize, Deserialize)]
+pub enum FlowEvent {
+    Lock {
+        asset: [u8; 8],
+        // sender: String,
+        recipient: [u8; 8],
+        amount: u128,
+    }, // NoticeInvoked {
+       //     era_id: u32,
+       //     era_index: u32,
+       //     notice_hash: [u8; 32],
+       //     result: Vec<u8>,
+       // }
+}
+
+#[derive(Clone, Eq, PartialEq, Encode, Decode, RuntimeDebug)]
+pub enum EventError {
+    UnknownEventTopic(String),
+    ErrorParsingData,
+}
+
+pub fn decode_event(topic: &str, data: &str) -> Result<FlowEvent, EventError> {
+    match topic {
+        "Lock" => {
+            let event_res: serde_json::error::Result<Lock> = serde_json::from_str(&data);
+            let event = event_res.map_err(|_| EventError::ErrorParsingData)?;
+            let asset_res = gateway_crypto::flow_asset_str_to_address(&event.asset);
+
+            Ok(FlowEvent::Lock {
+                asset: asset_res.ok_or(EventError::ErrorParsingData)?,
+                // sender: event.sender,
+                recipient: hex::decode(event.recipient)
+                    .map_err(|_| EventError::ErrorParsingData)?
+                    .try_into()
+                    .map_err(|_| EventError::ErrorParsingData)?,
+                amount: event.amount,
+            })
+        }
+        _ => Err(EventError::UnknownEventTopic(topic.to_string())),
+    }
+}
+
+#[cfg(test)]
+mod tests {
+    use super::*;
+
+    #[test]
+    fn test_flow_decode_lock_event() {
+        let topic = "Lock";
+        let data = "{\"asset\":\"FLOW\",\"recipient\":\"fc6346ab93540e97\",\"amount\":1000000000}";
+        assert_eq!(
+            decode_event(topic, data),
+            Ok(FlowEvent::Lock {
+                asset: [70, 76, 79, 87, 0, 0, 0, 0], // "FLOW" asset
+                recipient: hex::decode("fc6346ab93540e97").unwrap().try_into().unwrap(),
+                amount: 1000000000
+            })
+        )
+    }
+}