Struct AnalyticsService 

pub struct AnalyticsService { /* private fields */ }

Analytics service for dashboard metrics

Implementations

impl AnalyticsService

pub fn new(pool: PgPool) -> Self

Create a new analytics service

pub async fn create_materialized_views(&self) -> Result<()>

Create all materialized views

pub async fn refresh_all_views(&self) -> Result<()>

Refresh all materialized views

pub async fn get_dashboard_metrics(&self) -> Result<DashboardMetrics>

Get dashboard metrics (from materialized view if available, otherwise compute)

pub async fn compute_dashboard_metrics(&self) -> Result<DashboardMetrics>

Compute dashboard metrics directly (without materialized view)

pub async fn get_top_tokens( &self, limit: i64, ) -> Result<Vec<TokenMetricsSummary>>

Get token metrics (top tokens by volume)

pub async fn get_daily_stats( &self, start_date: NaiveDate, end_date: NaiveDate, ) -> Result<Vec<DailyStats>>

Get daily statistics for a date range

pub async fn get_top_users( &self, limit: i64, ) -> Result<Vec<UserActivitySummary>>

Get top users by trading volume

pub async fn drop_materialized_views(&self) -> Result<()>

Drop all materialized views

pub async fn record_price_history( &self, token_id: Uuid, price_satoshis: i64, supply: i64, ) -> Result<()>

Record price history data point

Inserts a price history record into the TimescaleDB hypertable. Safe to call even if TimescaleDB is not installed (uses regular table).

pub async fn record_volume_history( &self, token_id: Uuid, buy_volume_satoshis: i64, sell_volume_satoshis: i64, trade_count: i32, unique_traders: i32, ) -> Result<()>

Record volume history data point

Inserts or updates a volume history record for a specific time bucket. Typically called on trade execution to update the current hour’s volume.

pub async fn record_platform_volume( &self, total_volume_satoshis: i64, trade_count: i32, active_tokens: i32, active_traders: i32, fees_collected_satoshis: i64, ) -> Result<()>

Record platform-wide volume history

pub async fn get_price_history( &self, token_id: Uuid, start_time: DateTime<Utc>, end_time: DateTime<Utc>, ) -> Result<Vec<PriceHistory>>

Get price history for a token within a time range

pub async fn get_volume_history( &self, token_id: Uuid, start_time: DateTime<Utc>, end_time: DateTime<Utc>, ) -> Result<Vec<VolumeHistory>>

Get volume history for a token within a time range

pub async fn get_ohlc_data( &self, token_id: Uuid, start_time: DateTime<Utc>, end_time: DateTime<Utc>, bucket_interval: &str, ) -> Result<Vec<OhlcData>>

Get OHLC (candlestick) data for a token

Returns OHLC data with configurable time buckets (e.g., ‘1 hour’, ‘1 day’, ‘1 week’). Uses TimescaleDB’s continuous aggregate if available, otherwise computes from raw data.

pub async fn get_aggregated_volume( &self, token_id: Option<Uuid>, start_time: DateTime<Utc>, end_time: DateTime<Utc>, bucket_interval: &str, ) -> Result<Vec<VolumeHistory>>

Get aggregated volume data by time bucket

pub async fn get_platform_volume_history( &self, start_time: DateTime<Utc>, end_time: DateTime<Utc>, ) -> Result<Vec<PlatformVolumeHistory>>

Get platform-wide volume history

pub async fn is_timescaledb_available(&self) -> bool

Check if TimescaleDB extension is available

pub async fn get_hypertable_info( &self, table_name: &str, ) -> Result<Option<String>>

Get hypertable information (only works with TimescaleDB)