Analog-Labs
diff --git a/‎bridges/relays/ethereum/Cargo.lock‎
Lines changed: 6274 additions & 0 deletions b/‎bridges/relays/ethereum/Cargo.lock‎
Lines changed: 6274 additions & 0 deletions
diff --git a/‎bridges/relays/ethereum/Cargo.toml‎
Lines changed: 32 additions & 0 deletions b/‎bridges/relays/ethereum/Cargo.toml‎
Lines changed: 32 additions & 0 deletions
diff --git a/‎bridges/relays/ethereum/LICENSE‎
Lines changed: 675 additions & 0 deletions b/‎bridges/relays/ethereum/LICENSE‎
Lines changed: 675 additions & 0 deletions
diff --git a/‎bridges/relays/ethereum/README.md‎
Lines changed: 7 additions & 0 deletions b/‎bridges/relays/ethereum/README.md‎
Lines changed: 7 additions & 0 deletions
diff --git a/‎bridges/relays/ethereum/src/cli.yml‎
Lines changed: 33 additions & 0 deletions b/‎bridges/relays/ethereum/src/cli.yml‎
Lines changed: 33 additions & 0 deletions
diff --git a/‎bridges/relays/ethereum/src/ethereum_client.rs‎
Lines changed: 170 additions & 0 deletions b/‎bridges/relays/ethereum/src/ethereum_client.rs‎
Lines changed: 170 additions & 0 deletions
@@ -0,0 +1,32 @@
+[package]
+name = "async-bridge"
+version = "0.1.0"
+authors = ["Parity Technologies <[email protected]>"]
+edition = "2018"
+
+[dependencies]
+ansi_term = "0.9"
+async-std = "1.0.1"
+async-stream = "0.2.0"
+clap = { version = "2.33.0", features = ["yaml"] }
+codec = { package = "parity-scale-codec", version = "1.0.0" }
+env_logger = "0.7.0"
+frame-system = { git = "https://github.com/svyatonik/substrate.git", branch = "bridge_runtime" }
+futures = "0.3.1"
+jsonrpsee-core = { git = "https://github.com/paritytech/jsonrpsee.git" }
+jsonrpsee-http = { git = "https://github.com/paritytech/jsonrpsee.git" }
+linked-hash-map = "0.5.2"
+log = "0.4.8"
+node-primitives = { git = "https://github.com/svyatonik/substrate.git", branch = "bridge_runtime" }
+node-runtime = { git = "https://github.com/svyatonik/substrate.git", branch = "bridge_runtime" }
+pallet-transaction-payment = { git = "https://github.com/svyatonik/substrate.git", branch = "bridge_runtime" }
+parking_lot = "0.9.0"
+rustc-hex = "2.0.1"
+serde = { version = "1.0.40", features = ["derive"] }
+serde_json = "1.0.40"
+sp-bridge-eth-poa = { git = "https://github.com/svyatonik/substrate.git", branch = "bridge_runtime" }
+sp-core = { git = "https://github.com/svyatonik/substrate.git", branch = "bridge_runtime" }
+sp-keyring = { git = "https://github.com/svyatonik/substrate.git", branch = "bridge_runtime" }
+sp-runtime = { git = "https://github.com/svyatonik/substrate.git", branch = "bridge_runtime" }
+time = "0.1"
+web3 = { git = "https://github.com/svyatonik/rust-web3.git", branch = "fix_receipt" }
@@ -0,0 +1,7 @@
+# PoA <> Substrate Bridge
+
+**DISCLAIMER:** *we recommend not using the bridge in "production" (to bridge significant amounts) just yet.
+it's missing a code audit and should still be considered alpha. we can't rule out that there are bugs that might result in loss of the bridged amounts.
+we'll update this disclaimer once that changes*
+
+These docs are very incomplete yet. Describe high-level goals here in the (near) future.
@@ -0,0 +1,33 @@
+name: ethsub-bridge
+version: "0.1.0"
+author: Parity Technologies <[email protected]>
+about: Parity Ethereum (PoA) <-> Substrate bridge
+args:
+    - eth-host:
+        long: eth-host
+        value_name: ETH_HOST
+        help: Connect to Ethereum node at given host.
+        takes_value: true
+    - eth-port:
+        long: eth-port
+        value_name: ETH_PORT
+        help: Connect to Ethereum node at given port.
+        takes_value: true
+    - sub-host:
+        long: sub-host
+        value_name: SUB_HOST
+        help: Connect to Substrate node at given host.
+        takes_value: true
+    - sub-port:
+        long: sub-port
+        value_name: SUB_PORT
+        help: Connect to Substrate node at given port.
+        takes_value: true
+    - sub-signer:
+        long: sub-signer
+        value_name: SUB_SIGNER
+        help: The SURI of secret key to use when transactions are submitted to the Substrate node.
+    - sub-signer-password:
+        long: sub-signer-password
+        value_name: SUB_SIGNER_PASSWORD
+        help: The password for the SURI of secret key to use when transactions are submitted to the Substrate node.
@@ -0,0 +1,170 @@
+// Copyright 2019 Parity Technologies (UK) Ltd.
+// This file is part of Parity-Bridge.
+
+// Parity-Bridge is free software: you can redistribute it and/or modify
+// it under the terms of the GNU General Public License as published by
+// the Free Software Foundation, either version 3 of the License, or
+// (at your option) any later version.
+
+// Parity-Bridge is distributed in the hope that it will be useful,
+// but WITHOUT ANY WARRANTY; without even the implied warranty of
+// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+// GNU General Public License for more details.
+
+// You should have received a copy of the GNU General Public License
+// along with Parity-Bridge.  If not, see <http://www.gnu.org/licenses/>.
+
+use jsonrpsee_core::{client::ClientError, common::Params};
+use jsonrpsee_http::{HttpClient, RequestError, http_client};
+use serde::de::DeserializeOwned;
+use serde_json::{from_value, to_value};
+use crate::ethereum_sync_loop::MaybeConnectionError;
+use crate::ethereum_types::{H256, Header, HeaderId, Receipt, U64};
+
+/// Proof of hash serialization success.
+const HASH_SERIALIZATION_PROOF: &'static str = "hash serialization never fails; qed";
+/// Proof of integer serialization success.
+const INT_SERIALIZATION_PROOF: &'static str = "integer serialization never fails; qed";
+/// Proof of bool serialization success.
+const BOOL_SERIALIZATION_PROOF: &'static str = "bool serialization never fails; qed";
+
+/// Ethereum client type.
+pub type Client = HttpClient;
+
+/// All possible errors that can occur during interacting with Ethereum node.
+#[derive(Debug)]
+pub enum Error {
+	/// Request start failed.
+	StartRequestFailed(RequestError),
+	/// Request not found (should never occur?).
+	RequestNotFound,
+	/// Failed to receive response.
+	ResponseRetrievalFailed(ClientError<RequestError>),
+	/// Failed to parse response.
+	ResponseParseFailed(serde_json::Error),
+	/// We have received header with missing number and hash fields.
+	IncompleteHeader,
+	/// We have received receipt with missing gas_used field.
+	IncompleteReceipt,
+}
+
+impl MaybeConnectionError for Error {
+	fn is_connection_error(&self) -> bool {
+		match *self {
+			Error::StartRequestFailed(_) | Error::ResponseRetrievalFailed(_) => true,
+			_ => false,
+		}
+	}
+}
+
+/// Returns client that is able to call RPCs on Ethereum node.
+pub fn client(uri: &str) -> Client {
+	http_client(uri)
+}
+
+/// Retrieve best known block number from Ethereum node.
+pub async fn best_block_number(client: Client) -> (Client, Result<u64, Error>) {
+	let (client, result) = call_rpc::<U64>(
+		client,
+		"eth_blockNumber",
+		Params::None,
+	).await;
+	(client, result.map(|x| x.as_u64()))
+}
+
+/// Retrieve block header by its number from Ethereum node.
+pub async fn header_by_number(client: Client, number: u64) -> (Client, Result<Header, Error>) {
+	let (client, header) = call_rpc(
+		client,
+		"eth_getBlockByNumber",
+		Params::Array(vec![
+			to_value(U64::from(number)).expect(INT_SERIALIZATION_PROOF),
+			to_value(false).expect(BOOL_SERIALIZATION_PROOF),
+		]),
+	).await;
+	(client, header.and_then(|header: Header| match header.number.is_some() && header.hash.is_some() {
+		true => Ok(header),
+		false => Err(Error::IncompleteHeader),
+	}))
+}
+
+/// Retrieve block header by its hash from Ethereum node.
+pub async fn header_by_hash(client: Client, hash: H256) -> (Client, Result<Header, Error>) {
+	let (client, header) = call_rpc(
+		client,
+		"eth_getBlockByHash",
+		Params::Array(vec![
+			to_value(hash).expect(HASH_SERIALIZATION_PROOF),
+			to_value(false).expect(BOOL_SERIALIZATION_PROOF),
+		]),
+	).await;
+	(client, header.and_then(|header: Header| match header.number.is_none() && header.hash.is_none() {
+		true => Ok(header),
+		false => Err(Error::IncompleteHeader),
+	}))
+}
+
+/// Retrieve transactions receipts for given block.
+pub async fn transactions_receipts(
+	mut client: Client,
+	id: HeaderId,
+	transacactions: Vec<H256>,
+) -> (Client, Result<(HeaderId, Vec<Receipt>), Error>) {
+	let mut transactions_receipts = Vec::with_capacity(transacactions.len());
+	for transacaction in transacactions {
+		let (next_client, transaction_receipt) = transaction_receipt(client, transacaction).await;
+		let transaction_receipt = match transaction_receipt {
+			Ok(transaction_receipt) => transaction_receipt,
+			Err(error) => return (next_client, Err(error)),
+		};
+		transactions_receipts.push(transaction_receipt);
+		client = next_client;
+	}
+	(client, Ok((id, transactions_receipts)))
+}
+
+/// Retrieve transaction receipt by transaction hash.
+async fn transaction_receipt(client: Client, hash: H256) -> (Client, Result<Receipt, Error>) {
+	let (client, receipt) = call_rpc::<Receipt>(
+		client,
+		"eth_getTransactionReceipt",
+		Params::Array(vec![
+			to_value(hash).expect(HASH_SERIALIZATION_PROOF),
+		]),
+	).await;
+	(client, receipt.and_then(|receipt| {
+		match receipt.gas_used.is_some() {
+			true => Ok(receipt),
+			false => Err(Error::IncompleteReceipt),
+		}
+	}))
+}
+
+/// Calls RPC on Ethereum node.
+async fn call_rpc<T: DeserializeOwned>(
+	mut client: Client,
+	method: &'static str,
+	params: Params,
+) -> (Client, Result<T, Error>) {
+	async fn do_call_rpc<T: DeserializeOwned>(
+		client: &mut Client,
+		method: &'static str,
+		params: Params,
+	) -> Result<T, Error> {
+		let request_id = client
+			.start_request(method, params)
+			.await
+			.map_err(Error::StartRequestFailed)?;
+		// WARN: if there'll be need for executing >1 request at a time, we should avoid
+		// calling request_by_id
+		let response = client
+			.request_by_id(request_id)
+			.ok_or(Error::RequestNotFound)?
+			.await
+			.map_err(Error::ResponseRetrievalFailed)?;
+		from_value(response).map_err(Error::ResponseParseFailed)
+	}
+
+	let result = do_call_rpc(&mut client, method, params).await;
+	(client, result)
+}