refactor: remove unused code

Author: alexcambose

src/bin/pyth_reader.rs

@@ -188,11 +188,6 @@ async fn fetch_price_updates(jetstream: jetstream::Context, config: &AppConfig)
             }
         };
 
-        // info!(
-        //     "Price Account: {:#?}, account: {:#?} \n\n",
-        //     price_account, account
-        // );
-
         // We want to send price updates whenever the aggregate changes but sometimes the accounts can change without the aggregate changing
         if price_account.agg.status == PriceStatus::Trading
             && (update.context.slot - price_account.agg.pub_slot)
@@ -253,18 +248,13 @@ async fn fetch_price_updates(jetstream: jetstream::Context, config: &AppConfig)
                     Err(e) => warn!("Failed to publish price update to JetStream: {}", e),
                 }
             });
-
+            info!(
+                "update: {}, comp: {}",
+                update.context.slot,
+                price_account.comp.len()
+            );
             for component in price_account.comp {
                 let publisher = component.publisher.to_string();
-                let publisher_price_update_message_id = format!(
-                    "{}:{}:{}",
-                    price_update.price_feed.id, price_update.price_feed.price.slot, publisher
-                );
-
-                let mut publisher_price_updates = HeaderMap::new();
-                publisher_price_updates
-                    .insert("Nats-Msg-Id", publisher_price_update_message_id.as_str());
-
                 let publisher_price_update = PublisherPriceUpdate {
                     feed_id: update.value.pubkey.to_string(),
                     publisher: publisher.clone(),