Skip to content
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

Refactor send_tx methods into plain functions #2044

Merged
merged 39 commits into from
Apr 13, 2022
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
39 commits
Select commit Hold shift + click to select a range
162fea4
Refactoring send_tx
soareschen Mar 11, 2022
d73a8b8
WIP refactoring
soareschen Mar 14, 2022
586dadc
Merge branch 'master' into soares/refactor-send-tx
soareschen Mar 18, 2022
517432f
More code reorganization
soareschen Mar 18, 2022
8d4d371
Split out functions from main cosmos.rs
soareschen Mar 18, 2022
b7ff345
Use refactored code to send_tx
soareschen Mar 18, 2022
9333179
Merge branch 'master' into soares/refactor-send-tx
soareschen Mar 31, 2022
f24fd1a
Walk through send_tx_with_account_sequence
soareschen Apr 1, 2022
bb989f8
Refactor code
soareschen Apr 1, 2022
a9eec75
Reorder function arguments
soareschen Apr 1, 2022
0b3f89c
Refactor send_tx_with_account_sequence_retry into plain function
soareschen Apr 1, 2022
4aac7c8
Refactor account query functions
soareschen Apr 4, 2022
4d791fa
Refactor query_tx
soareschen Apr 4, 2022
65f9de6
Refactor wait_for_block_commits
soareschen Apr 4, 2022
80ab989
Turn wait_for_block_commits into simple loop
soareschen Apr 4, 2022
732b050
Merge remote-tracking branch 'origin/master' into soares/refactor-sen…
soareschen Apr 4, 2022
a84057e
Refactor send_messages_and_wait_commit
soareschen Apr 5, 2022
6f1596a
Refactor send_messages_and_wait_check_tx
soareschen Apr 5, 2022
7bdf017
Merge remote-tracking branch 'origin/master' into soares/refactor-sen…
soareschen Apr 5, 2022
a0ef196
Refactor sign_message
soareschen Apr 5, 2022
9262f00
Refactor gas config
soareschen Apr 5, 2022
5dad18c
Move out query account module
soareschen Apr 5, 2022
8d1040c
Reorganize types
soareschen Apr 5, 2022
646da40
Remove pub const
soareschen Apr 5, 2022
2dae995
Simplify arguments
soareschen Apr 5, 2022
7fe9488
Remove redundant account query function
soareschen Apr 5, 2022
206dfc2
Refactor query status
soareschen Apr 6, 2022
7f25765
Introduce TransferTimeout abstraction
soareschen Apr 6, 2022
d245cdb
Use prost::Message::encoded_len() to compute encoded message length
soareschen Apr 7, 2022
ad4deca
Merge remote-tracking branch 'origin/master' into soares/refactor-sen…
soareschen Apr 7, 2022
52992f6
Address review feedback
soareschen Apr 7, 2022
2d101f3
Re-add missing comments
soareschen Apr 7, 2022
e621b07
Merge remote-tracking branch 'origin/master' into soares/refactor-sen…
soareschen Apr 8, 2022
17ade0d
Fix clippy error
soareschen Apr 8, 2022
c5a88b1
Merge remote-tracking branch 'origin/master' into soares/refactor-sen…
soareschen Apr 11, 2022
073b057
Remove check for both timeout height offset and duration being zero
soareschen Apr 11, 2022
225f241
Do not set timeout height or time when input is zero
soareschen Apr 12, 2022
2f64495
Merge remote-tracking branch 'origin/master' into soares/refactor-sen…
soareschen Apr 12, 2022
0580999
Merge branch 'master' into soares/refactor-send-tx
soareschen Apr 12, 2022
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 3 additions & 2 deletions relayer-cli/src/commands/tx/transfer.rs
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
use abscissa_core::clap::Parser;
use abscissa_core::{config::Override, Command, FrameworkErrorKind, Runnable};

use core::time::Duration;
use ibc::{
core::{
ics02_client::client_state::ClientState,
Expand Down Expand Up @@ -141,7 +142,7 @@ impl TxIcs20MsgTransferCmd {
denom,
receiver: self.receiver.clone(),
timeout_height_offset: self.timeout_height_offset,
timeout_seconds: core::time::Duration::from_secs(self.timeout_seconds),
timeout_duration: Duration::from_secs(self.timeout_seconds),
number_msgs,
};

Expand Down Expand Up @@ -226,7 +227,7 @@ impl Runnable for TxIcs20MsgTransferCmd {
// Checks pass, build and send the tx
let res: Result<Vec<IbcEvent>, Error> =
build_and_send_transfer_messages(&chains.src, &chains.dst, &opts)
.map_err(Error::packet);
.map_err(Error::transfer);

match res {
Ok(ev) => Output::success(ev).exit(),
Expand Down
8 changes: 4 additions & 4 deletions relayer-cli/src/error.rs
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ use ibc_relayer::error::Error as RelayerError;
use ibc_relayer::foreign_client::ForeignClientError;
use ibc_relayer::link::error::LinkError;
use ibc_relayer::supervisor::Error as SupervisorError;
use ibc_relayer::transfer::PacketError;
use ibc_relayer::transfer::TransferError;
use ibc_relayer::upgrade_chain::UpgradeChainError;
use tendermint::Error as TendermintError;

Expand Down Expand Up @@ -69,9 +69,9 @@ define_error! {
[ ConnectionError ]
|_| { "connection error" },

Packet
[ PacketError ]
|_| { "packet error" },
Transfer
[ TransferError ]
|_| { "transfer error" },

Channel
[ ChannelError ]
Expand Down
4 changes: 2 additions & 2 deletions relayer/src/chain.rs
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ pub enum HealthCheck {

/// The result of a chain status query.
#[derive(Clone, Debug)]
pub struct StatusResponse {
pub struct ChainStatus {
pub height: ICSHeight,
pub timestamp: Timestamp,
}
Expand Down Expand Up @@ -160,7 +160,7 @@ pub trait ChainEndpoint: Sized {
}

/// Query the latest height and timestamp the chain is at
fn query_status(&self) -> Result<StatusResponse, Error>;
fn query_status(&self) -> Result<ChainStatus, Error>;

/// Performs a query to retrieve the state of all clients that a chain hosts.
fn query_clients(
Expand Down
Loading