use jsonrpsee::types::error::{ErrorObject, ErrorObjectOwned};
use sp_runtime::transaction_validity::InvalidTransaction;
pub type Result<T> = std::result::Result<T, Error>;
#[derive(Debug, thiserror::Error)]
pub enum Error {
#[error("Client error: {}", .0)]
Client(Box<dyn std::error::Error + Send + Sync>),
#[error("Transaction pool error: {}", .0)]
Pool(#[from] sc_transaction_pool_api::error::Error),
#[error("Extrinsic verification error: {}", .0)]
Verification(Box<dyn std::error::Error + Send + Sync>),
#[error("Invalid extrinsic format: {}", .0)]
BadFormat(#[from] codec::Error),
#[error("Invalid key type ID format (should be of length four)")]
BadKeyType,
#[error("The key store is unavailable")]
KeystoreUnavailable,
#[error("Session keys are not encoded correctly")]
InvalidSessionKeys,
#[error(transparent)]
UnsafeRpcCalled(#[from] crate::policy::UnsafeRpcError),
}
const BASE_ERROR: i32 = crate::error::base::AUTHOR;
const BAD_FORMAT: i32 = BASE_ERROR + 1;
const VERIFICATION_ERROR: i32 = BASE_ERROR + 2;
const POOL_INVALID_TX: i32 = BASE_ERROR + 10;
const POOL_UNKNOWN_VALIDITY: i32 = POOL_INVALID_TX + 1;
const POOL_TEMPORARILY_BANNED: i32 = POOL_INVALID_TX + 2;
const POOL_ALREADY_IMPORTED: i32 = POOL_INVALID_TX + 3;
const POOL_TOO_LOW_PRIORITY: i32 = POOL_INVALID_TX + 4;
const POOL_CYCLE_DETECTED: i32 = POOL_INVALID_TX + 5;
const POOL_IMMEDIATELY_DROPPED: i32 = POOL_INVALID_TX + 6;
const POOL_UNACTIONABLE: i32 = POOL_INVALID_TX + 8;
const POOL_NO_TAGS: i32 = POOL_INVALID_TX + 9;
const POOL_INVALID_BLOCK_ID: i32 = POOL_INVALID_TX + 10;
const POOL_FUTURE_TX: i32 = POOL_INVALID_TX + 11;
const OTHER_ERR: i32 = BASE_ERROR + 40;
impl From<Error> for ErrorObjectOwned {
fn from(e: Error) -> ErrorObjectOwned {
use sc_transaction_pool_api::error::Error as PoolError;
match e {
Error::BadFormat(e) => ErrorObject::owned(
BAD_FORMAT,
format!("Extrinsic has invalid format: {}", e),
None::<()>,
),
Error::Verification(e) => ErrorObject::owned(
VERIFICATION_ERROR,
format!("Verification Error: {}", e),
Some(format!("{:?}", e)),
),
Error::Pool(PoolError::InvalidTransaction(InvalidTransaction::Custom(e))) => {
ErrorObject::owned(
POOL_INVALID_TX,
"Invalid Transaction",
Some(format!("Custom error: {}", e)),
)
},
Error::Pool(PoolError::InvalidTransaction(e)) => {
let msg: &str = e.into();
ErrorObject::owned(
POOL_INVALID_TX,
"Invalid Transaction",
Some(msg),
)
},
Error::Pool(PoolError::UnknownTransaction(e)) => {
ErrorObject::owned(
POOL_UNKNOWN_VALIDITY,
"Unknown Transaction Validity",
Some(format!("{:?}", e)),
)
},
Error::Pool(PoolError::TemporarilyBanned) =>
ErrorObject::owned(
POOL_TEMPORARILY_BANNED,
"Transaction is temporarily banned",
None::<()>,
),
Error::Pool(PoolError::AlreadyImported(hash)) =>
ErrorObject::owned(
POOL_ALREADY_IMPORTED,
"Transaction Already Imported",
Some(format!("{:?}", hash)),
),
Error::Pool(PoolError::TooLowPriority { old, new }) => ErrorObject::owned(
POOL_TOO_LOW_PRIORITY,
format!("Priority is too low: ({} vs {})", old, new),
Some("The transaction has too low priority to replace another transaction already in the pool.")
),
Error::Pool(PoolError::CycleDetected) =>
ErrorObject::owned(
POOL_CYCLE_DETECTED,
"Cycle Detected",
None::<()>
),
Error::Pool(PoolError::ImmediatelyDropped) => ErrorObject::owned(
POOL_IMMEDIATELY_DROPPED,
"Immediately Dropped",
Some("The transaction couldn't enter the pool because of the limit"),
),
Error::Pool(PoolError::Unactionable) => ErrorObject::owned(
POOL_UNACTIONABLE,
"Unactionable",
Some("The transaction is unactionable since it is not propagable and \
the local node does not author blocks")
),
Error::Pool(PoolError::NoTagsProvided) => ErrorObject::owned(
POOL_NO_TAGS,
"No tags provided",
Some("Transaction does not provide any tags, so the pool can't identify it")
),
Error::Pool(PoolError::InvalidBlockId(_)) =>
ErrorObject::owned(
POOL_INVALID_BLOCK_ID,
"The provided block ID is not valid",
None::<()>
),
Error::Pool(PoolError::RejectedFutureTransaction) => {
ErrorObject::owned(
POOL_FUTURE_TX,
"The pool is not accepting future transactions",
None::<()>,
)
},
Error::UnsafeRpcCalled(e) => e.into(),
other => ErrorObject::owned(
OTHER_ERR,
other.to_string(),
None::<()>,
)
}
}
}