feat(lazer/sdk/rust): add rust client for Lazer

lazer/Cargo.toml

@@ -2,6 +2,7 @@
 resolver = "2"
 members = [
   "sdk/rust/protocol",
+  "sdk/rust/client",
   "contracts/solana/programs/pyth-lazer-solana-contract",
 ]
 

lazer/sdk/rust/client/Cargo.toml

@@ -0,0 +1,18 @@
+[package]
+name = "pyth-lazer-client"
+version = "0.1.0"
+edition = "2021"
+description = "A Rust client for Pyth Lazer"
+license = "Apache-2.0"
+
+[dependencies]
+pyth-lazer-protocol = { path = "../protocol" }
+tokio = { version = "1", features = ["full"] }
+tokio-tungstenite = { version = "0.20", features = ["native-tls"] }
+futures-util = "0.3"
+serde = { version = "1.0", features = ["derive"] }
+serde_json = "1.0"
+base64 = "0.21"
+anyhow = "1.0"
+tracing = "0.1"
+url = "2.4"

lazer/sdk/rust/client/examples/subscribe_price_feeds.rs

@@ -0,0 +1,60 @@
+use futures_util::StreamExt;
+use pyth_lazer_client::LazerClient;
+use pyth_lazer_protocol::router::{
+    Chain, Channel, DeliveryFormat, FixedRate, JsonBinaryEncoding, PriceFeedId, PriceFeedProperty,
+    SubscriptionParams, SubscriptionParamsRepr,
+};
+use pyth_lazer_protocol::subscription::{Request, SubscribeRequest, SubscriptionId};
+
+#[tokio::main]
+async fn main() -> anyhow::Result<()> {
+    // Create and start the client
+    let mut client = LazerClient::new(
+        "wss://pyth-lazer.dourolabs.app/v1/stream",
+        "YOUR_ACCESS_TOKEN",
+    )?;
+    let mut stream = client.start().await?;
+
+    // Create subscription request
+    let subscription_request = SubscribeRequest {
+        subscription_id: SubscriptionId(1),
+        params: SubscriptionParams::new(SubscriptionParamsRepr {
+            price_feed_ids: vec![PriceFeedId(1), PriceFeedId(2), PriceFeedId(3)],
+            properties: vec![PriceFeedProperty::Price],
+            chains: vec![Chain::Solana],
+            delivery_format: DeliveryFormat::Binary,
+            json_binary_encoding: JsonBinaryEncoding::default(),
+            parsed: false,
+            channel: Channel::FixedRate(FixedRate::from_ms(200).expect("unsupported update rate")),
+        })
+        .expect("invalid subscription params"),
+    };
+
+    client
+        .subscribe(Request::Subscribe(subscription_request))
+        .await?;
+
+    println!("Subscribed to BTC/USD price feed. Waiting for updates...");
+
+    // Process the first 100 updates
+    let mut count = 0;
+    while let Some(msg) = stream.next().await {
+        println!("Received update: {:?}", msg?);
+        count += 1;
+        if count >= 100 {
+            break;
+        }
+    }
+
+    // Unsubscribe from all feeds before exiting
+    for feed_id in 1..=3 {
+        client.unsubscribe(SubscriptionId(feed_id)).await?;
+        println!("Unsubscribed from feed {}", feed_id);
+        // Add a small delay between unsubscribe requests
+        tokio::time::sleep(tokio::time::Duration::from_millis(100)).await;
+    }
+
+    // Wait a moment to ensure unsubscribe messages are sent
+    tokio::time::sleep(tokio::time::Duration::from_millis(500)).await;
+    Ok(())
+}