131 lines
4.0 KiB
Rust
131 lines
4.0 KiB
Rust
use std::collections::HashMap;
|
|
|
|
use serde::Deserialize;
|
|
|
|
use crate::{Client, EtherscanError, Response, Result};
|
|
|
|
#[derive(Deserialize, Clone, Debug)]
|
|
#[serde(rename_all = "camelCase")]
|
|
struct ContractExecutionStatus {
|
|
is_error: String,
|
|
err_description: String,
|
|
}
|
|
|
|
#[derive(Deserialize, Clone, Debug)]
|
|
struct TransactionReceiptStatus {
|
|
status: String,
|
|
}
|
|
|
|
impl Client {
|
|
/// Returns the status of a contract execution
|
|
pub async fn check_contract_execution_status(&self, tx_hash: impl AsRef<str>) -> Result<()> {
|
|
let query = self.create_query(
|
|
"transaction",
|
|
"getstatus",
|
|
HashMap::from([("txhash", tx_hash.as_ref())]),
|
|
);
|
|
let response: Response<ContractExecutionStatus> = self.get_json(&query).await?;
|
|
|
|
if response.result.is_error == "0" {
|
|
Ok(())
|
|
} else {
|
|
Err(EtherscanError::ExecutionFailed(response.result.err_description))
|
|
}
|
|
}
|
|
|
|
/// Returns the status of a transaction execution: `false` for failed and `true` for successful
|
|
pub async fn check_transaction_receipt_status(&self, tx_hash: impl AsRef<str>) -> Result<()> {
|
|
let query = self.create_query(
|
|
"transaction",
|
|
"gettxreceiptstatus",
|
|
HashMap::from([("txhash", tx_hash.as_ref())]),
|
|
);
|
|
let response: Response<TransactionReceiptStatus> = self.get_json(&query).await?;
|
|
|
|
match response.result.status.as_str() {
|
|
"0" => Err(EtherscanError::TransactionReceiptFailed),
|
|
"1" => Ok(()),
|
|
err => Err(EtherscanError::BadStatusCode(err.to_string())),
|
|
}
|
|
}
|
|
}
|
|
|
|
#[cfg(test)]
|
|
mod tests {
|
|
use super::*;
|
|
use crate::{tests::run_at_least_duration, Chain};
|
|
use serial_test::serial;
|
|
use std::time::Duration;
|
|
|
|
#[tokio::test]
|
|
#[serial]
|
|
async fn check_contract_execution_status_success() {
|
|
run_at_least_duration(Duration::from_millis(250), async {
|
|
let client = Client::new_from_env(Chain::Mainnet).unwrap();
|
|
|
|
let status = client
|
|
.check_contract_execution_status(
|
|
"0x16197e2a0eacc44c1ebdfddcfcfcafb3538de557c759a66e0ba95263b23d9007",
|
|
)
|
|
.await;
|
|
|
|
status.unwrap();
|
|
})
|
|
.await
|
|
}
|
|
|
|
#[tokio::test]
|
|
#[serial]
|
|
async fn check_contract_execution_status_error() {
|
|
run_at_least_duration(Duration::from_millis(250), async {
|
|
let client = Client::new_from_env(Chain::Mainnet).unwrap();
|
|
|
|
let err = client
|
|
.check_contract_execution_status(
|
|
"0x15f8e5ea1079d9a0bb04a4c58ae5fe7654b5b2b4463375ff7ffb490aa0032f3a",
|
|
)
|
|
.await
|
|
.unwrap_err();
|
|
|
|
assert!(matches!(err, EtherscanError::ExecutionFailed(_)));
|
|
assert_eq!(err.to_string(), "Contract execution call failed: Bad jump destination");
|
|
})
|
|
.await
|
|
}
|
|
|
|
#[tokio::test]
|
|
#[serial]
|
|
async fn check_transaction_receipt_status_success() {
|
|
run_at_least_duration(Duration::from_millis(250), async {
|
|
let client = Client::new_from_env(Chain::Mainnet).unwrap();
|
|
|
|
let success = client
|
|
.check_transaction_receipt_status(
|
|
"0x513c1ba0bebf66436b5fed86ab668452b7805593c05073eb2d51d3a52f480a76",
|
|
)
|
|
.await;
|
|
|
|
success.unwrap();
|
|
})
|
|
.await
|
|
}
|
|
|
|
#[tokio::test]
|
|
#[serial]
|
|
async fn check_transaction_receipt_status_failed() {
|
|
run_at_least_duration(Duration::from_millis(250), async {
|
|
let client = Client::new_from_env(Chain::Mainnet).unwrap();
|
|
|
|
let err = client
|
|
.check_transaction_receipt_status(
|
|
"0x21a29a497cb5d4bf514c0cca8d9235844bd0215c8fab8607217546a892fd0758",
|
|
)
|
|
.await
|
|
.unwrap_err();
|
|
|
|
assert!(matches!(err, EtherscanError::TransactionReceiptFailed));
|
|
})
|
|
.await
|
|
}
|
|
}
|