Struct MarketDatabaseService 

pub struct MarketDatabaseService { /* private fields */ }

Service for managing market data persistence in PostgreSQL

Implementations

impl MarketDatabaseService

pub fn new(pool: PgPool, exchange_name: String) -> Self

Creates a new MarketDatabaseService

pub async fn initialize_database(&self) -> Result<(), Error>

Initializes the database tables and triggers

pub async fn store_market_hierarchy( &self, hierarchy: &[MarketNode], ) -> Result<(), Error>

Stores the complete market hierarchy in the database

pub async fn store_filtered_market_nodes( &self, hierarchy: &[MarketNode], symbol_map: &HashMap<&str, &str>, table_name: &str, ) -> Result<(), Error>

Stores filtered market nodes with specific epic format in a custom table Only processes MarketNode.children where epic has format “XX.X.XXXXXXX.XX.XX” (4 dots) Adds a symbol field based on the provided HashMap mapping

pub fn is_valid_epic_format(&self, epic: &str) -> bool

Checks if epic has the required format: “XX.X.XXXXXXX.XX.XX” (exactly 4 dots)

pub fn find_symbol_for_market( &self, instrument_name: &str, symbol_map: &HashMap<&str, &str>, ) -> String

Finds the appropriate symbol for a market based on its name

pub fn convert_update_time( &self, update_time: &Option<String>, ) -> Option<DateTime<Utc>>

Converts updateTime from milliseconds to formatted timestamp

pub fn convert_market_data_to_instrument( &self, market: &MarketData, node_id: &str, ) -> MarketInstrument

Converts MarketData to MarketInstrument

pub async fn get_market_hierarchy( &self, ) -> Result<Vec<MarketHierarchyNode>, Error>

Retrieves market hierarchy from the database

pub async fn get_instruments_by_node( &self, node_id: &str, ) -> Result<Vec<MarketInstrument>, Error>

Retrieves market instruments for a specific node

pub async fn search_instruments( &self, search_term: &str, ) -> Result<Vec<MarketInstrument>, Error>

Searches for instruments by name or epic

pub async fn get_statistics(&self) -> Result<DatabaseStatistics, Error>

Gets statistics about the stored data