tsarevvv/rust-ipfs
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat: timeout on block/stat

Browse Source 
this wasn't actually needed to pass the test, unsure why.
This commit is contained in:
Joonas Koivunen 2020-07-09 14:17:41 +03:00
parent fbe90ab8ec
commit 62e0986c41
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
http/src/v0/block.rs
View File

@ -211,6 +211,7 @@ async fn rm_query<T: IpfsTypes>(
#[derive(Debug, Deserialize)] #[derive(Debug, Deserialize)]
pub struct StatQuery { pub struct StatQuery {
arg: String, arg: String,
timeout: Option<StringSerialized<humantime::Duration>>,
} }
#[derive(Debug, Serialize)] #[derive(Debug, Serialize)]
@ -225,7 +226,13 @@ async fn stat_query<T: IpfsTypes>(
query: StatQuery, query: StatQuery,
) -> Result<impl Reply, Rejection> { ) -> Result<impl Reply, Rejection> {
let cid: Cid = query.arg.parse().map_err(StringError::from)?; let cid: Cid = query.arg.parse().map_err(StringError::from)?;
let block = ipfs.get_block(&cid).await.map_err(StringError::from)?; let block = ipfs
.get_block(&cid)
.maybe_timeout(query.timeout.map(StringSerialized::into_inner))
.await
.map_err(StringError::from)?
.map_err(StringError::from)?;
let response = StatResponse { let response = StatResponse {
key: query.arg, key: query.arg,
size: block.data().len(), size: block.data().len(),