From 06cfb1841ff6d44e2436a51fa143f88bf5fc6e67 Mon Sep 17 00:00:00 2001 From: Tino Rusch Date: Fri, 13 Dec 2024 13:50:54 +0100 Subject: [PATCH 1/2] fix pin ack model by including success and error fields --- src/models.rs | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/models.rs b/src/models.rs index ffa47d3..0b8b68c 100644 --- a/src/models.rs +++ b/src/models.rs @@ -195,6 +195,8 @@ impl From for PinStatus { .map(|a| PinAck { worker: a.worker, block_height: a.block_height as i64, + success: a.success, + error: if a.error.is_empty() { None } else { Some(a.error) }, }) .collect(), cid: Some(proto.cid), @@ -550,6 +552,8 @@ pub struct PinAck { pub worker: String, #[serde(rename = "blockHeight")] pub block_height: i64, + pub success: bool, + pub error: Option, } #[derive(Serialize, Deserialize, Debug)] From 460a16d862f770a8cf103811b43a10e319503862 Mon Sep 17 00:00:00 2001 From: Tino Rusch Date: Fri, 13 Dec 2024 14:02:26 +0100 Subject: [PATCH 2/2] cargo fmt --- src/models.rs | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/src/models.rs b/src/models.rs index 0b8b68c..2d7913e 100644 --- a/src/models.rs +++ b/src/models.rs @@ -196,7 +196,11 @@ impl From for PinStatus { worker: a.worker, block_height: a.block_height as i64, success: a.success, - error: if a.error.is_empty() { None } else { Some(a.error) }, + error: if a.error.is_empty() { + None + } else { + Some(a.error) + }, }) .collect(), cid: Some(proto.cid),