feat: enable accumulator_v2 on price creation

Author: Riateche

program/rust/src/processor/add_price.rs

@@ -2,6 +2,7 @@ use {
     crate::{
         accounts::{
             PriceAccount,
+            PriceAccountFlags,
             ProductAccount,
             PythAccount,
         },
@@ -78,6 +79,10 @@ pub fn add_price(
     price_data.product_account = *product_account.key;
     price_data.next_price_account = product_data.first_price_account;
     price_data.min_pub_ = PRICE_ACCOUNT_DEFAULT_MIN_PUB;
+    price_data
+        .flags
+        .insert(PriceAccountFlags::ACCUMULATOR_V2 | PriceAccountFlags::MESSAGE_BUFFER_CLEARED);
+
     product_data.first_price_account = *price_account.key;
 
     Ok(())

program/rust/src/tests/test_full_publisher_set.rs

@@ -79,8 +79,8 @@ async fn test_full_publisher_set() -> Result<(), Box<dyn std::error::Error>> {
             .await
             .unwrap();
 
-        assert_eq!(price_data.agg_.price_, 110);
-        assert_eq!(price_data.agg_.conf_, 20);
+        assert_eq!(price_data.agg_.price_, 0);
+        assert_eq!(price_data.agg_.conf_, 0);
     }
 
     Ok(())

program/rust/src/tests/test_publish.rs

@@ -102,8 +102,8 @@ async fn test_publish() {
         assert_eq!(price_data.comp_[0].latest_.conf_, 0);
         assert_eq!(price_data.comp_[0].latest_.status_, PC_STATUS_UNKNOWN);
 
-        assert_eq!(price_data.comp_[0].agg_.price_, 150);
-        assert_eq!(price_data.comp_[0].agg_.conf_, 7);
-        assert_eq!(price_data.comp_[0].agg_.status_, PC_STATUS_TRADING);
+        assert_eq!(price_data.comp_[0].agg_.price_, 0);
+        assert_eq!(price_data.comp_[0].agg_.conf_, 0);
+        assert_eq!(price_data.comp_[0].agg_.status_, PC_STATUS_UNKNOWN);
     }
 }

program/rust/src/tests/test_publish_batch.rs

@@ -111,7 +111,7 @@ async fn test_publish_batch() {
             .get_account_data_as::<PriceAccount>(*price)
             .await
             .unwrap();
-        let quote = quotes.get(key).unwrap();
+        let _quote = quotes.get(key).unwrap();
         let new_quote = new_quotes.get(key).unwrap();
 
         assert_eq!(price_data.comp_[0].latest_.price_, new_quote.price);
@@ -125,11 +125,8 @@ async fn test_publish_batch() {
             )
             .unwrap()
         );
-        assert_eq!(price_data.comp_[0].agg_.price_, quote.price);
-        assert_eq!(price_data.comp_[0].agg_.conf_, quote.confidence);
-        assert_eq!(
-            price_data.comp_[0].agg_.status_,
-            get_status_for_conf_price_ratio(quote.price, quote.confidence, quote.status).unwrap()
-        );
+        assert_eq!(price_data.comp_[0].agg_.price_, 0);
+        assert_eq!(price_data.comp_[0].agg_.conf_, 0);
+        assert_eq!(price_data.comp_[0].agg_.status_, PC_STATUS_UNKNOWN);
     }
 }