feat(pyth-lazer-protocol): add confidence to aggregated data (#2333)

keyvankhademi · web-flow · commit 707437af791b · 2025-02-05T14:56:00.000-08:00
* feat(pyth-lazer-protocol): add confidence to aggregated data

* update lock
diff --git a/lazer/Cargo.lock b/lazer/Cargo.lock
diff --git a/lazer/sdk/rust/protocol/Cargo.toml b/lazer/sdk/rust/protocol/Cargo.toml
@@ -1,6 +1,6 @@
 [package]
 name = "pyth-lazer-protocol"
-version = "0.4.2"
+version = "0.5.0"
 edition = "2021"
 description = "Pyth Lazer SDK - protocol types."
 license = "Apache-2.0"
diff --git a/lazer/sdk/rust/protocol/src/payload.rs b/lazer/sdk/rust/protocol/src/payload.rs
@@ -43,6 +43,7 @@ pub struct AggregatedPriceFeedData {
     pub best_bid_price: Option<Price>,
     pub best_ask_price: Option<Price>,
     pub publisher_count: Option<u16>,
+    pub confidence: Option<Price>,
 }
 
 pub const PAYLOAD_FORMAT_MAGIC: u32 = 2479346549;
diff --git a/lazer/sdk/rust/protocol/src/router.rs b/lazer/sdk/rust/protocol/src/router.rs
@@ -117,6 +117,14 @@ impl Add<Price> for Price {
     }
 }
 
+impl Sub<Price> for Price {
+    type Output = Option<Price>;
+    fn sub(self, rhs: Price) -> Self::Output {
+        let value = self.0.get().saturating_sub(rhs.0.get());
+        NonZeroI64::new(value).map(Self)
+    }
+}
+
 impl Div<i64> for Price {
     type Output = Option<Price>;
     fn div(self, rhs: i64) -> Self::Output {

Original file line number	Diff line number	Diff line change
`@@ -43,6 +43,7 @@ pub struct AggregatedPriceFeedData {`
`43`	`43`	`pub best_bid_price: Option<Price>,`
`44`	`44`	`pub best_ask_price: Option<Price>,`
`45`	`45`	`pub publisher_count: Option<u16>,`
	`46`	`+ pub confidence: Option<Price>,`
`46`	`47`	`}`
`47`	`48`
`48`	`49`	`pub const PAYLOAD_FORMAT_MAGIC: u32 = 2479346549;`
Original file line number	Diff line number	Diff line change
`@@ -117,6 +117,14 @@ impl Add<Price> for Price {`
`117`	`117`	`}`
`118`	`118`	`}`
`119`	`119`
	`120`	`+impl Sub<Price> for Price {`
	`121`	`+ type Output = Option<Price>;`
	`122`	`+ fn sub(self, rhs: Price) -> Self::Output {`
	`123`	`+ let value = self.0.get().saturating_sub(rhs.0.get());`
	`124`	`+ NonZeroI64::new(value).map(Self)`
	`125`	`+ }`
	`126`	`+}`
	`127`	`+`
`120`	`128`	`impl Div<i64> for Price {`
`121`	`129`	`type Output = Option<Price>;`
`122`	`130`	`fn div(self, rhs: i64) -> Self::Output {`