-
Notifications
You must be signed in to change notification settings - Fork 7
refactor: backport gear 1.10 #787
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
base: main
Are you sure you want to change the base?
Conversation
gshep
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Good job! 🎸
Please remove commented code so we can test relayers on the testnet
| transports::{ws::WsConnect, RpcError, TransportErrorKind}, | ||
| }; | ||
| use anyhow::{Context, Result as AnyResult}; | ||
| //use subxt::utils::{H160, H256}; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Not necessary anymore if I understand correctly? So the dependency in Cargo.toml
| queue_id, | ||
| root, | ||
| }, | ||
| ) => Some((*queue_id, *root)),*/ |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
remove?
| /*gear_rpc_client::metadata::Event::GearEthBridge( | ||
| gear_rpc_client::metadata::gear_eth_bridge::Event::MessageQueued { message, .. }, | ||
| ) => Some(U256(message.nonce.0)), | ||
| ) => Some(U256(message.nonce.0)),*/ |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
remove?
| destination: message.destination.0, | ||
| payload: message.payload.clone(), | ||
| }) | ||
| }*/ |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
remove?
| if destination != ActorId(to_user.0) { | ||
| return None; | ||
| }*/ |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
remove
| /// Fetch queue merkle root for the given block. | ||
| pub async fn fetch_queue_merkle_root(&self, block: H256) -> AnyResult<(u64, H256)> { | ||
| let block = (*self.api).blocks().at(block).await?; | ||
| /*let block = (*self.api).blocks().at(block).await?; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
remove
|
|
||
| pub async fn fetch_timestamp(&self, block: H256) -> AnyResult<u64> { | ||
| let block = (*self.api).blocks().at(block).await?; | ||
| /*let block = (*self.api).blocks().at(block).await?; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
remove
| let address = | ||
| gsdk::Api::storage_root(gsdk::metadata::storage::GearEthBridgeStorage::QueueMerkleRoot); | ||
| let address = gsdk::gear::storage().gear_eth_bridge().queue_merkle_root(); | ||
| //gsdk::Api::storage_root(gsdk::metadata::storage::GearEthBridgeStorage::QueueMerkleRoot); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
remove
|
|
||
| pub mod dto; | ||
| pub mod metadata; | ||
| //pub mod metadata; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
remove?
Resolves #786
@gshep