fix: ethereum adapter calls to async

Author: samparsky

Cargo.lock

@@ -24,6 +24,10 @@ ethkey = { version = "0.4.0", git = "https://github.com/paritytech/parity-ethere
 sha2 = "0.8.0"
 base64 = "0.10.1"
 lazy_static = "1.4.0"
+# Futures
+futures_legacy = { version = "0.3.1", package = "futures" }
+futures-preview = { version = "=0.3.0-alpha.19", features = ["compat"]}
 
 [dev-dependencies]
-byteorder = "1.3"
+byteorder = "1.3"
+tokio = { version = "0.2", features = ["macros", "rt-core"] }

adapter/Cargo.toml

@@ -3,6 +3,7 @@ use primitives::channel_validator::ChannelValidator;
 use primitives::config::Config;
 use primitives::{Channel, ValidatorId};
 use std::collections::HashMap;
+use futures::future::BoxFuture;
 
 #[derive(Debug, Clone)]
 pub struct DummyAdapter {
@@ -63,29 +64,38 @@ impl Adapter for DummyAdapter {
         Ok(is_same)
     }
 
-    fn validate_channel(&self, channel: &Channel) -> AdapterResult<bool> {
-        match DummyAdapter::is_channel_valid(&self.config, self.whoami(), channel) {
-            Ok(_) => Ok(true),
-            Err(e) => Err(AdapterError::InvalidChannel(e.to_string())),
-        }
+    fn validate_channel<'a>(&'a self, channel: &'a Channel) -> BoxFuture<'a, AdapterResult<bool>> {
+        Box::pin(
+            async move {
+                match DummyAdapter::is_channel_valid(&self.config, self.whoami(), channel) {
+                    Ok(_) => Ok(true),
+                    Err(e) => Err(AdapterError::InvalidChannel(e.to_string())),
+                }
+            }
+        )
+       
     }
 
-    fn session_from_token(&self, token: &str) -> AdapterResult<Session> {
-        let identity = self
-            .authorization_tokens
-            .iter()
-            .find(|(_, id)| *id == token);
-
-        match identity {
-            Some((id, _)) => Ok(Session {
-                uid: self.session_tokens[id].clone(),
-                era: 0,
-            }),
-            None => Err(AdapterError::Authentication(format!(
-                "no session token for this auth: {}",
-                token
-            ))),
-        }
+    fn session_from_token<'a>(&'a self, token: &'a str) -> BoxFuture<'a, AdapterResult<Session>> {
+        Box::pin(
+            async move {
+                let identity = self
+                .authorization_tokens
+                .iter()
+                .find(|(_, id)| *id == token);
+    
+                match identity {
+                    Some((id, _)) => Ok(Session {
+                        uid: self.session_tokens[id].clone(),
+                        era: 0,
+                    }),
+                    None => Err(AdapterError::Authentication(format!(
+                        "no session token for this auth: {}",
+                        token
+                    ))),
+                }
+            }
+        )
     }
 
     fn get_auth(&self, _validator: &ValidatorId) -> AdapterResult<String> {