use slot instead of publish_time for unique id

Author: ayazabbas

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "pyth-stream"
-version = "0.1.5"
+version = "0.1.6"
 edition = "2021"
 
 [lib]

Cargo.toml

@@ -43,6 +43,7 @@ struct PriceInfo {
     conf: String,
     expo: i32,
     publish_time: i64,
+    slot: u64, // Add this field
 }
 
 // Add this struct to deserialize the configuration
@@ -149,12 +150,14 @@ async fn fetch_price_updates(jetstream: jetstream::Context, config: &AppConfig)
                         conf: price_account.agg.conf.to_string(),
                         expo: price_account.expo,
                         publish_time: price_account.timestamp,
+                        slot: update.context.slot, // Add this field
                     },
                     ema_price: PriceInfo {
                         price: price_account.ema_price.val.to_string(),
                         conf: price_account.ema_conf.val.to_string(),
                         expo: price_account.expo,
                         publish_time: price_account.timestamp,
+                        slot: update.context.slot, // Add this field
                     },
                 },
             };
@@ -164,7 +167,7 @@ async fn fetch_price_updates(jetstream: jetstream::Context, config: &AppConfig)
             // Create a unique message ID
             let message_id = format!(
                 "{}:{}",
-                price_update.price_feed.id, price_update.price_feed.price.publish_time
+                price_update.price_feed.id, price_update.price_feed.price.slot
             );
 
             // Create headers with the Nats-Msg-Id

src/bin/pyth_reader.rs

@@ -263,6 +263,7 @@ struct PriceInfo {
     conf: String,
     expo: i32,
     publish_time: i64,
+    slot: u64, // Add this field
 }
 
 async fn handle_nats_messages(jetstream: jetstream::Context, clients: Clients) -> Result<()> {
@@ -309,7 +310,10 @@ async fn handle_nats_messages(jetstream: jetstream::Context, clients: Clients) -
                     };
                     price_update.price_feed.id = hex_id.clone();
 
-                    debug!("Parsed price update for feed ID: {}", hex_id);
+                    debug!(
+                        "Parsed price update for feed ID: {} at slot: {}",
+                        hex_id, price_update.price_feed.price.slot
+                    );
 
                     let clients = clients.lock().await;
                     debug!("Number of connected clients: {}", clients.len());
@@ -320,7 +324,10 @@ async fn handle_nats_messages(jetstream: jetstream::Context, clients: Clients) -
                             if let Err(e) = sender.send(Message::Text(update_json)) {
                                 warn!(client_addr = %client_addr, error = %e, "Failed to send price update to client");
                             } else {
-                                debug!("Successfully sent update to client: {}", client_addr);
+                                debug!(
+                                    "Successfully sent update to client: {} for slot: {}",
+                                    client_addr, price_update.price_feed.price.slot
+                                );
                             }
                         } else {
                             debug!(