feat(pyth-lazer) Create schema for lazer agent JRPC endpoint (#2836)

Author: bplatak

Cargo.lock

@@ -19,7 +19,7 @@ no-log-ix-name = []
 idl-build = ["anchor-lang/idl-build"]
 
 [dependencies]
-pyth-lazer-protocol = { path = "../../../../sdk/rust/protocol", version = "0.7.2" }
+pyth-lazer-protocol = { path = "../../../../sdk/rust/protocol", version = "0.8.0" }
 
 anchor-lang = "0.30.1"
 bytemuck = "1.20.0"

lazer/contracts/solana/Cargo.lock

@@ -7,7 +7,7 @@ license = "Apache-2.0"
 repository = "https://github.com/pyth-network/pyth-crosschain"
 
 [dependencies]
-pyth-lazer-protocol = { version = "0.7.2", path = "../../sdk/rust/protocol" }
+pyth-lazer-protocol = { version = "0.8.0", path = "../../sdk/rust/protocol" }
 anyhow = "1.0.98"
 protobuf = "3.7.2"
 serde-value = "0.7.0"

lazer/contracts/solana/programs/pyth-lazer-solana-contract/Cargo.toml

@@ -1,9 +1,12 @@
 use std::{collections::BTreeMap, time::Duration};
 
+use crate::publisher_update::feed_update::Update;
+use crate::publisher_update::{FeedUpdate, FundingRateUpdate, PriceUpdate};
 use ::protobuf::MessageField;
 use anyhow::{bail, ensure, Context};
 use humantime::format_duration;
 use protobuf::dynamic_value::{dynamic_value, DynamicValue};
+use pyth_lazer_protocol::jrpc::{FeedUpdateParams, UpdateParams};
 use pyth_lazer_protocol::router::TimestampUs;
 
 pub mod transaction_envelope {
@@ -164,3 +167,38 @@ impl TryFrom<DynamicValue> for serde_value::Value {
         }
     }
 }
+
+impl From<FeedUpdateParams> for FeedUpdate {
+    fn from(value: FeedUpdateParams) -> Self {
+        FeedUpdate {
+            feed_id: Some(value.feed_id.0),
+            source_timestamp: value.source_timestamp.into(),
+            update: Some(value.update.into()),
+            special_fields: Default::default(),
+        }
+    }
+}
+
+impl From<UpdateParams> for Update {
+    fn from(value: UpdateParams) -> Self {
+        match value {
+            UpdateParams::PriceUpdate {
+                price,
+                best_bid_price,
+                best_ask_price,
+            } => Update::PriceUpdate(PriceUpdate {
+                price: Some(price.0.into()),
+                best_bid_price: best_bid_price.map(|p| p.0.into()),
+                best_ask_price: best_ask_price.map(|p| p.0.into()),
+                special_fields: Default::default(),
+            }),
+            UpdateParams::FundingRateUpdate { price, rate } => {
+                Update::FundingRateUpdate(FundingRateUpdate {
+                    price: price.map(|p| p.0.into()),
+                    rate: Some(rate.0),
+                    special_fields: Default::default(),
+                })
+            }
+        }
+    }
+}

lazer/publisher_sdk/rust/Cargo.toml

@@ -6,7 +6,7 @@ description = "A Rust client for Pyth Lazer"
 license = "Apache-2.0"
 
 [dependencies]
-pyth-lazer-protocol = { path = "../protocol", version = "0.7.2" }
+pyth-lazer-protocol = { path = "../protocol", version = "0.8.0" }
 tokio = { version = "1", features = ["full"] }
 tokio-tungstenite = { version = "0.20", features = ["native-tls"] }
 futures-util = "0.3"

lazer/publisher_sdk/rust/src/lib.rs

@@ -1,6 +1,6 @@
 [package]
 name = "pyth-lazer-protocol"
-version = "0.7.3"
+version = "0.8.0"
 edition = "2021"
 description = "Pyth Lazer SDK - protocol types."
 license = "Apache-2.0"
@@ -14,8 +14,8 @@ serde_json = "1.0"
 derive_more = { version = "1.0.0", features = ["from"] }
 itertools = "0.13.0"
 rust_decimal = "1.36.0"
-base64 = "0.22.1"
 protobuf = "3.7.2"
+humantime-serde = "1.1.1"
 
 [dev-dependencies]
 bincode = "1.3.3"