fix: fix example

Author: tejasbadadare

lazer/Cargo.lock

@@ -1,25 +1,35 @@
-use pyth_lazer_sdk::LazerClient;
-use pyth_lazer_protocol::subscription::{Request, SubscribeRequest, SubscriptionId, SubscriptionParams};
 use futures_util::StreamExt;
+use pyth_lazer_protocol::router::{
+    Chain, Channel, DeliveryFormat, FixedRate, JsonBinaryEncoding, PriceFeedId, PriceFeedProperty,
+    SubscriptionParams, SubscriptionParamsRepr,
+};
+use pyth_lazer_protocol::subscription::{Request, SubscribeRequest, SubscriptionId};
+use pyth_lazer_sdk::LazerClient;
 
 #[tokio::main]
 async fn main() -> anyhow::Result<()> {
-    // Connect to the Pyth Lazer WebSocket endpoint
-    let (mut client, mut stream) = LazerClient::start("wss://hermes.pyth.network").await?;
-    
-    // Subscribe to BTC/USD price feed
-    let btc_feed_id = "ff61491a931112ddf1bd8147cd1b641375f79f5825126d665480874634fd0ace";
-    
-    client.subscribe(Request::Subscribe(SubscribeRequest {
+    let (mut client, mut stream) = LazerClient::start("lazer_endpoint").await?;
+
+    let subscription_request = SubscribeRequest {
         subscription_id: SubscriptionId(1),
-        params: SubscriptionParams {
-            ids: vec![btc_feed_id.to_string()],
-            binary_message_format: true,
-        },
-    })).await?;
+        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 5 updates
     let mut count = 0;
     while let Some(msg) = stream.next().await {

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

@@ -109,8 +109,7 @@ impl LazerClient {
 
                         match magic {
                             EVM_FORMAT_MAGIC => {
-                                evm =
-                                    Some(EvmMessage::deserialize_slice(&data[pos..pos + len])?);
+                                evm = Some(EvmMessage::deserialize_slice(&data[pos..pos + len])?);
                             }
                             SOLANA_FORMAT_MAGIC_BE => {
                                 solana =