Move bridge contact addresses to primary configuration file.

README.md

@@ -30,7 +30,7 @@ and they can convert them back as well.
 
 ![withdraw](./res/withdraw.png)
 
-### How to build 
+### How to build
 
 Requires `rust` and `cargo`: [installation instructions.](https://www.rust-lang.org/en-US/install.html)
 
@@ -83,6 +83,7 @@ keystore = "/path/to/keystore"
 
 [home]
 account = "0x006e27b6a72e1f34c626762f3c4761547aff1421"
+contract_address = "0x49edf201c1e139282643d5e7c6fb0c7219ad1db7"
 rpc_host = "http://localhost"
 rpc_port = 8545
 required_confirmations = 0
@@ -91,6 +92,7 @@ default_gas_price = 1_000_000_000 # 1 GWEI
 
 [foreign]
 account = "0x006e27b6a72e1f34c626762f3c4761547aff1421"
+contract_address = "0x49edf201c1e139282643d5e7c6fb0c7219ad1db8"
 rpc_host = "http://localhost"
 rpc_port = 9545
 required_confirmations = 0
@@ -110,11 +112,12 @@ withdraw_confirm = { gas = 3000000 }
 
 #### Options
 
-- `keystore` - path to a keystore directory with JSON keys  
+- `keystore` - path to a keystore directory with JSON keys
 
 #### home/foreign options
 
 - `home/foreign.account` - authority address on the home (**required**)
+- `home/foreign.contract_address` - The address of the bridge contract on home/foreign chain. (**required**).
 - `home/foreign.rpc_host` - RPC host (**required**)
 - `home/foreign.rpc_port` - RPC port (**defaults to 8545**)
 - `home/foreign.required_confirmations` - number of confirmation required to consider transaction final on home (default: **12**)
@@ -141,17 +144,13 @@ withdraw_confirm = { gas = 3000000 }
 ### Database file format
 
 ```toml
-home_contract_address = "0x49edf201c1e139282643d5e7c6fb0c7219ad1db7"
-foreign_contract_address = "0x49edf201c1e139282643d5e7c6fb0c7219ad1db8"
 checked_deposit_relay = 120
 checked_withdraw_relay = 121
 checked_withdraw_confirm = 121
 ```
 
 **all fields are required**
 
-- `home_contract_address` - address of the bridge contract on home chain
-- `foreign_contract_address` - address of the bridge contract on foreign chain
 - `checked_deposit_relay` - number of the last block for which an authority has relayed deposits to the foreign
 - `checked_withdraw_relay` - number of the last block for which an authority has relayed withdraws to the home
 - `checked_withdraw_confirm` - number of the last block for which an authority has confirmed withdraw

bridge/src/bridge/deploy.rs

@@ -64,64 +64,73 @@ impl<T: Transport + Clone> Future for Deploy<T> {
 	fn poll(&mut self) -> Poll<Self::Item, Self::Error> {
 		loop {
 			let _next_state = match self.state {
-				DeployState::CheckIfNeeded => match Database::load(&self.app.database_path).map_err(ErrorKind::from) {
-					Ok(database) => return Ok(Deployed::Existing(database).into()),
-					Err(ErrorKind::MissingFile(_e)) => {
-						#[cfg(feature = "deploy")] {
-							println!("deploy");
-							let main_data = self.app.home_bridge.constructor(
-								self.app.config.home.contract.bin.clone().0,
-								self.app.config.authorities.required_signatures,
-								self.app.config.authorities.accounts.clone(),
-								self.app.config.estimated_gas_cost_of_withdraw
-							);
-							let test_data = self.app.foreign_bridge.constructor(
-								self.app.config.foreign.contract.bin.clone().0,
-								self.app.config.authorities.required_signatures,
-								self.app.config.authorities.accounts.clone(),
-								self.app.config.estimated_gas_cost_of_withdraw
-							);
+				DeployState::CheckIfNeeded => {
+					match Database::load(&self.app.database_path).map_err(ErrorKind::from) {
+						Ok(database) => return Ok(Deployed::Existing(database).into()),
+						Err(ErrorKind::MissingFile(_e)) => {
+							#[cfg(feature = "deploy")] {
+								println!("deploy");
+								let main_data = self.app.home_bridge.constructor(
+									self.app.config.home.contract.bin.clone().0,
+									self.app.config.authorities.required_signatures,
+									self.app.config.authorities.accounts.clone(),
+									self.app.config.estimated_gas_cost_of_withdraw
+								);
+								let test_data = self.app.foreign_bridge.constructor(
+									self.app.config.foreign.contract.bin.clone().0,
+									self.app.config.authorities.required_signatures,
+									self.app.config.authorities.accounts.clone(),
+									self.app.config.estimated_gas_cost_of_withdraw
+								);
 
-							let main_tx = Transaction {
-								nonce: U256::zero(),
-								gas_price: self.app.config.txs.home_deploy.gas_price.into(),
-								gas: self.app.config.txs.home_deploy.gas.into(),
-								action: Action::Create,
-								value: U256::zero(),
-								data: main_data.into(),
-							};
+								let main_tx = Transaction {
+									nonce: U256::zero(),
+									gas_price: self.app.config.txs.home_deploy.gas_price.into(),
+									gas: self.app.config.txs.home_deploy.gas.into(),
+									action: Action::Create,
+									value: U256::zero(),
+									data: main_data.into(),
+								};
 
-							let test_tx = Transaction {
-								nonce: U256::zero(),
-								gas_price: self.app.config.txs.foreign_deploy.gas_price.into(),
-								gas: self.app.config.txs.foreign_deploy.gas.into(),
-								action: Action::Create,
-								value: U256::zero(),
-								data: test_data.into(),
-							};
+								let test_tx = Transaction {
+									nonce: U256::zero(),
+									gas_price: self.app.config.txs.foreign_deploy.gas_price.into(),
+									gas: self.app.config.txs.foreign_deploy.gas.into(),
+									action: Action::Create,
+									value: U256::zero(),
+									data: test_data.into(),
+								};
 
-							let main_future = api::send_transaction_with_nonce(self.app.connections.home.clone(), self.app.clone(),
-																			   self.app.config.home.clone(), main_tx, self.home_chain_id,
-																			   TransactionWithConfirmation(self.app.connections.home.clone(), self.app.config.home.poll_interval, self.app.config.home.required_confirmations));
+								let main_future = api::send_transaction_with_nonce(self.app.connections.home.clone(), self.app.clone(),
+																				   self.app.config.home.clone(), main_tx, self.home_chain_id,
+																				   TransactionWithConfirmation(self.app.connections.home.clone(), self.app.config.home.poll_interval, self.app.config.home.required_confirmations));
 
-							let test_future = api::send_transaction_with_nonce(self.app.connections.foreign.clone(), self.app.clone(),
-																			   self.app.config.foreign.clone(), test_tx, self.foreign_chain_id,
-																			   TransactionWithConfirmation(self.app.connections.foreign.clone(), self.app.config.foreign.poll_interval, self.app.config.foreign.required_confirmations));
+								let test_future = api::send_transaction_with_nonce(self.app.connections.foreign.clone(), self.app.clone(),
+																				   self.app.config.foreign.clone(), test_tx, self.foreign_chain_id,
+																				   TransactionWithConfirmation(self.app.connections.foreign.clone(), self.app.config.foreign.poll_interval, self.app.config.foreign.required_confirmations));
 
-							DeployState::Deploying(main_future.join(test_future))
-						}
-						#[cfg(not(feature = "deploy"))] {
-							return Err(ErrorKind::MissingFile(_e).into())
-						}
-					},
-					Err(err) => return Err(err.into()),
+								DeployState::Deploying(main_future.join(test_future))
+							}
+							#[cfg(not(feature = "deploy"))] {
+								return Err(ErrorKind::MissingFile(_e).into())
+							}
+						},
+						Err(err) => return Err(err.into()),
+					}
 				},
 				#[cfg(feature = "deploy")]
 				DeployState::Deploying(ref mut future) => {
 					let (main_receipt, test_receipt) = try_ready!(future.poll());
+
+					// The `deploy` feature is being removed so this shouldn't
+					// matter but the following lines have been left here as a
+					// reminder that contract addresses are no longer stored
+					// within `Database`.
+					//
+					// let _ = main_receipt.contract_address.expect("contract creation receipt must have an address; qed")
+					// let _ = test_receipt.contract_address.expect("contract creation receipt must have an address; qed")
+
 					let database = Database {
-						home_contract_address: main_receipt.contract_address.expect("contract creation receipt must have an address; qed"),
-						foreign_contract_address: test_receipt.contract_address.expect("contract creation receipt must have an address; qed"),
 						home_deploy: Some(main_receipt.block_number.low_u64()),
 						foreign_deploy: Some(test_receipt.block_number.low_u64()),
 						checked_deposit_relay: main_receipt.block_number.low_u64(),

bridge/src/bridge/deposit_relay.rs

@@ -49,11 +49,11 @@ pub fn create_deposit_relay<T: Transport + Clone>(app: Arc<App<T>>, init: &Datab
 		request_timeout: app.config.home.request_timeout,
 		poll_interval: app.config.home.poll_interval,
 		confirmations: app.config.home.required_confirmations,
-		filter: deposits_filter(&app.home_bridge, init.home_contract_address),
+		filter: deposits_filter(&app.home_bridge, app.config.home.contract_address),
 	};
 	DepositRelay {
 		logs: api::log_stream(app.connections.home.clone(), app.timer.clone(), logs_init),
-		foreign_contract: init.foreign_contract_address,
+		foreign_contract: app.config.foreign.contract_address,
 		state: DepositRelayState::Wait,
 		app,
 		foreign_balance,
@@ -92,7 +92,7 @@ impl<T: Transport> Stream for DepositRelay<T> {
 					let gas = U256::from(self.app.config.txs.deposit_relay.gas);
 					let gas_price = U256::from(*self.foreign_gas_price.read().unwrap());
 					let balance_required = gas * gas_price * U256::from(item.logs.len());
-					
+
 					if balance_required > *foreign_balance.as_ref().unwrap() {
 						return Err(ErrorKind::InsufficientFunds.into())
 					}

bridge/src/bridge/gas_price.rs

@@ -165,6 +165,7 @@ mod tests {
 	fn errored_request() {
 		let node = Node {
 			account: Address::new(),
+			contract_address: "49edf201c1e139282643d5e7c6fb0c7219ad1db7".into(),
 			request_timeout: Duration::from_secs(5),
 			poll_interval: Duration::from_secs(1),
 			required_confirmations: 0,
@@ -208,6 +209,7 @@ mod tests {
 	fn bad_json() {
 		let node = Node {
 			account: Address::new(),
+			contract_address: "49edf201c1e139282643d5e7c6fb0c7219ad1db7".into(),
 			request_timeout: Duration::from_secs(5),
 			poll_interval: Duration::from_secs(1),
 			required_confirmations: 0,
@@ -251,6 +253,7 @@ mod tests {
 	fn unexpected_json() {
 		let node = Node {
 			account: Address::new(),
+			contract_address: "49edf201c1e139282643d5e7c6fb0c7219ad1db7".into(),
 			request_timeout: Duration::from_secs(5),
 			poll_interval: Duration::from_secs(1),
 			required_confirmations: 0,
@@ -293,6 +296,7 @@ mod tests {
 	fn non_object_json() {
 		let node = Node {
 			account: Address::new(),
+			contract_address: "49edf201c1e139282643d5e7c6fb0c7219ad1db7".into(),
 			request_timeout: Duration::from_secs(5),
 			poll_interval: Duration::from_secs(1),
 			required_confirmations: 0,
@@ -335,6 +339,7 @@ mod tests {
 	fn correct_json() {
 		let node = Node {
 			account: Address::new(),
+			contract_address: "49edf201c1e139282643d5e7c6fb0c7219ad1db7".into(),
 			request_timeout: Duration::from_secs(5),
 			poll_interval: Duration::from_secs(1),
 			required_confirmations: 0,

bridge/src/bridge/mod.rs

@@ -221,6 +221,7 @@ impl<'a, T: Transport + 'a> Stream for BridgeEventStream<'a, T> {
 #[cfg(test)]
 mod tests {
 	extern crate tempdir;
+
 	use self::tempdir::TempDir;
 	use database::Database;
 	use super::{Bridge, BridgeChecked};
@@ -244,20 +245,23 @@ mod tests {
 		let _ = event_loop.run(bridge.collect());
 
 		let db = Database::load(&path).unwrap();
+
 		assert_eq!(1, db.checked_deposit_relay);
 		assert_eq!(0, db.checked_withdraw_confirm);
 		assert_eq!(0, db.checked_withdraw_relay);
 
 		let bridge = Bridge {
 			path: path.clone(),
 			database: Database::default(),
-			event_stream: stream::iter_ok::<_, Error>(vec![BridgeChecked::DepositRelay(2), BridgeChecked::WithdrawConfirm(3), BridgeChecked::WithdrawRelay(2)]),
+			event_stream: stream::iter_ok::<_, Error>(vec![BridgeChecked::DepositRelay(2),
+				BridgeChecked::WithdrawConfirm(3), BridgeChecked::WithdrawRelay(2)]),
 		};
 
 		let mut event_loop = Core::new().unwrap();
 		let _ = event_loop.run(bridge.collect());
 
 		let db = Database::load(&path).unwrap();
+
 		assert_eq!(2, db.checked_deposit_relay);
 		assert_eq!(3, db.checked_withdraw_confirm);
 		assert_eq!(2, db.checked_withdraw_relay);

bridge/src/bridge/withdraw_confirm.rs

@@ -44,12 +44,12 @@ pub fn create_withdraw_confirm<T: Transport + Clone>(app: Arc<App<T>>, init: &Da
 		request_timeout: app.config.foreign.request_timeout,
 		poll_interval: app.config.foreign.poll_interval,
 		confirmations: app.config.foreign.required_confirmations,
-		filter: withdraws_filter(&app.foreign_bridge, init.foreign_contract_address.clone()),
+		filter: withdraws_filter(&app.foreign_bridge, app.config.foreign.contract_address.clone()),
 	};
 
 	WithdrawConfirm {
 		logs: api::log_stream(app.connections.foreign.clone(), app.timer.clone(), logs_init),
-		foreign_contract: init.foreign_contract_address,
+		foreign_contract: app.config.foreign.contract_address,
 		state: WithdrawConfirmState::Wait,
 		app,
 		foreign_balance,

bridge/src/bridge/withdraw_relay.rs

@@ -83,13 +83,13 @@ pub fn create_withdraw_relay<T: Transport + Clone>(app: Arc<App<T>>, init: &Data
 		request_timeout: app.config.foreign.request_timeout,
 		poll_interval: app.config.foreign.poll_interval,
 		confirmations: app.config.foreign.required_confirmations,
-		filter: collected_signatures_filter(&app.foreign_bridge, init.foreign_contract_address),
+		filter: collected_signatures_filter(&app.foreign_bridge, app.config.foreign.contract_address),
 	};
 
 	WithdrawRelay {
 		logs: api::log_stream(app.connections.foreign.clone(), app.timer.clone(), logs_init),
-		home_contract: init.home_contract_address,
-		foreign_contract: init.foreign_contract_address,
+		home_contract: app.config.home.contract_address,
+		foreign_contract: app.config.foreign.contract_address,
 		state: WithdrawRelayState::Wait,
 		app,
 		home_balance,