|
| 1 | +use std::collections::HashSet; |
| 2 | + |
| 3 | +use api_models::analytics::{ |
| 4 | + disputes::{DisputeDimensions, DisputeFilters, DisputeMetricsBucketIdentifier}, |
| 5 | + Granularity, TimeRange, |
| 6 | +}; |
| 7 | +use common_utils::errors::ReportSwitchExt; |
| 8 | +use error_stack::ResultExt; |
| 9 | +use time::PrimitiveDateTime; |
| 10 | + |
| 11 | +use super::DisputeMetricRow; |
| 12 | +use crate::{ |
| 13 | + enums::AuthInfo, |
| 14 | + query::{Aggregate, GroupByClause, QueryBuilder, QueryFilter, SeriesBucket, ToSql, Window}, |
| 15 | + types::{AnalyticsCollection, AnalyticsDataSource, MetricsError, MetricsResult}, |
| 16 | +}; |
| 17 | +#[derive(Default)] |
| 18 | +pub(crate) struct DisputeStatusMetric {} |
| 19 | + |
| 20 | +#[async_trait::async_trait] |
| 21 | +impl<T> super::DisputeMetric<T> for DisputeStatusMetric |
| 22 | +where |
| 23 | + T: AnalyticsDataSource + super::DisputeMetricAnalytics, |
| 24 | + PrimitiveDateTime: ToSql<T>, |
| 25 | + AnalyticsCollection: ToSql<T>, |
| 26 | + Granularity: GroupByClause<T>, |
| 27 | + Aggregate<&'static str>: ToSql<T>, |
| 28 | + Window<&'static str>: ToSql<T>, |
| 29 | +{ |
| 30 | + async fn load_metrics( |
| 31 | + &self, |
| 32 | + dimensions: &[DisputeDimensions], |
| 33 | + auth: &AuthInfo, |
| 34 | + filters: &DisputeFilters, |
| 35 | + granularity: &Option<Granularity>, |
| 36 | + time_range: &TimeRange, |
| 37 | + pool: &T, |
| 38 | + ) -> MetricsResult<HashSet<(DisputeMetricsBucketIdentifier, DisputeMetricRow)>> |
| 39 | + where |
| 40 | + T: AnalyticsDataSource + super::DisputeMetricAnalytics, |
| 41 | + { |
| 42 | + let mut query_builder = QueryBuilder::new(AnalyticsCollection::DisputeSessionized); |
| 43 | + |
| 44 | + for dim in dimensions { |
| 45 | + query_builder.add_select_column(dim).switch()?; |
| 46 | + } |
| 47 | + |
| 48 | + query_builder.add_select_column("dispute_status").switch()?; |
| 49 | + |
| 50 | + query_builder |
| 51 | + .add_select_column(Aggregate::Count { |
| 52 | + field: None, |
| 53 | + alias: Some("count"), |
| 54 | + }) |
| 55 | + .switch()?; |
| 56 | + query_builder |
| 57 | + .add_select_column(Aggregate::Min { |
| 58 | + field: "created_at", |
| 59 | + alias: Some("start_bucket"), |
| 60 | + }) |
| 61 | + .switch()?; |
| 62 | + query_builder |
| 63 | + .add_select_column(Aggregate::Max { |
| 64 | + field: "created_at", |
| 65 | + alias: Some("end_bucket"), |
| 66 | + }) |
| 67 | + .switch()?; |
| 68 | + |
| 69 | + filters.set_filter_clause(&mut query_builder).switch()?; |
| 70 | + |
| 71 | + auth.set_filter_clause(&mut query_builder).switch()?; |
| 72 | + |
| 73 | + time_range.set_filter_clause(&mut query_builder).switch()?; |
| 74 | + |
| 75 | + for dim in dimensions { |
| 76 | + query_builder.add_group_by_clause(dim).switch()?; |
| 77 | + } |
| 78 | + |
| 79 | + query_builder |
| 80 | + .add_group_by_clause("dispute_status") |
| 81 | + .switch()?; |
| 82 | + |
| 83 | + if let Some(granularity) = granularity.as_ref() { |
| 84 | + granularity |
| 85 | + .set_group_by_clause(&mut query_builder) |
| 86 | + .switch()?; |
| 87 | + } |
| 88 | + |
| 89 | + query_builder |
| 90 | + .execute_query::<DisputeMetricRow, _>(pool) |
| 91 | + .await |
| 92 | + .change_context(MetricsError::QueryBuildingError)? |
| 93 | + .change_context(MetricsError::QueryExecutionFailure)? |
| 94 | + .into_iter() |
| 95 | + .map(|i| { |
| 96 | + Ok(( |
| 97 | + DisputeMetricsBucketIdentifier::new( |
| 98 | + i.dispute_stage.as_ref().map(|i| i.0), |
| 99 | + i.connector.clone(), |
| 100 | + TimeRange { |
| 101 | + start_time: match (granularity, i.start_bucket) { |
| 102 | + (Some(g), Some(st)) => g.clip_to_start(st)?, |
| 103 | + _ => time_range.start_time, |
| 104 | + }, |
| 105 | + end_time: granularity.as_ref().map_or_else( |
| 106 | + || Ok(time_range.end_time), |
| 107 | + |g| i.end_bucket.map(|et| g.clip_to_end(et)).transpose(), |
| 108 | + )?, |
| 109 | + }, |
| 110 | + ), |
| 111 | + i, |
| 112 | + )) |
| 113 | + }) |
| 114 | + .collect::<error_stack::Result< |
| 115 | + HashSet<(DisputeMetricsBucketIdentifier, DisputeMetricRow)>, |
| 116 | + crate::query::PostProcessingError, |
| 117 | + >>() |
| 118 | + .change_context(MetricsError::PostProcessingFailure) |
| 119 | + } |
| 120 | +} |
0 commit comments