feat(analytics): Add currency as dimension and filter for disputes (#7006)

Author: tsdk02

crates/analytics/src/disputes/core.rs

@@ -204,6 +204,7 @@ pub async fn get_filters(
         .filter_map(|fil: DisputeFilterRow| match dim {
             DisputeDimensions::DisputeStage => fil.dispute_stage,
             DisputeDimensions::Connector => fil.connector,
+            DisputeDimensions::Currency => fil.currency.map(|i| i.as_ref().to_string()),
         })
         .collect::<Vec<String>>();
         res.query_data.push(DisputeFilterValue {

crates/analytics/src/disputes/filters.rs

@@ -1,12 +1,16 @@
 use api_models::analytics::{disputes::DisputeDimensions, Granularity, TimeRange};
 use common_utils::errors::ReportSwitchExt;
+use diesel_models::enums::Currency;
 use error_stack::ResultExt;
 use time::PrimitiveDateTime;
 
 use crate::{
     enums::AuthInfo,
     query::{Aggregate, GroupByClause, QueryBuilder, QueryFilter, ToSql, Window},
-    types::{AnalyticsCollection, AnalyticsDataSource, FiltersError, FiltersResult, LoadRow},
+    types::{
+        AnalyticsCollection, AnalyticsDataSource, DBEnumWrapper, FiltersError, FiltersResult,
+        LoadRow,
+    },
 };
 pub trait DisputeFilterAnalytics: LoadRow<DisputeFilterRow> {}
 
@@ -48,4 +52,5 @@ pub struct DisputeFilterRow {
     pub dispute_status: Option<String>,
     pub connector_status: Option<String>,
     pub dispute_stage: Option<String>,
+    pub currency: Option<DBEnumWrapper<Currency>>,
 }

crates/analytics/src/disputes/metrics.rs

@@ -27,6 +27,7 @@ pub struct DisputeMetricRow {
     pub dispute_stage: Option<DBEnumWrapper<storage_enums::DisputeStage>>,
     pub dispute_status: Option<DBEnumWrapper<storage_enums::DisputeStatus>>,
     pub connector: Option<String>,
+    pub currency: Option<DBEnumWrapper<storage_enums::Currency>>,
     pub total: Option<bigdecimal::BigDecimal>,
     pub count: Option<i64>,
     #[serde(with = "common_utils::custom_serde::iso8601::option")]

crates/analytics/src/disputes/metrics/dispute_status_metric.rs

@@ -97,6 +97,7 @@ where
                     DisputeMetricsBucketIdentifier::new(
                         i.dispute_stage.as_ref().map(|i| i.0),
                         i.connector.clone(),
+                        i.currency.as_ref().map(|i| i.0),
                         TimeRange {
                             start_time: match (granularity, i.start_bucket) {
                                 (Some(g), Some(st)) => g.clip_to_start(st)?,

crates/analytics/src/disputes/metrics/sessionized_metrics/dispute_status_metric.rs

@@ -97,6 +97,7 @@ where
                     DisputeMetricsBucketIdentifier::new(
                         i.dispute_stage.as_ref().map(|i| i.0),
                         i.connector.clone(),
+                        i.currency.as_ref().map(|i| i.0),
                         TimeRange {
                             start_time: match (granularity, i.start_bucket) {
                                 (Some(g), Some(st)) => g.clip_to_start(st)?,

crates/analytics/src/disputes/metrics/sessionized_metrics/total_amount_disputed.rs

@@ -98,6 +98,7 @@ where
                     DisputeMetricsBucketIdentifier::new(
                         i.dispute_stage.as_ref().map(|i| i.0),
                         i.connector.clone(),
+                        i.currency.as_ref().map(|i| i.0),
                         TimeRange {
                             start_time: match (granularity, i.start_bucket) {
                                 (Some(g), Some(st)) => g.clip_to_start(st)?,

crates/analytics/src/disputes/metrics/sessionized_metrics/total_dispute_lost_amount.rs

@@ -99,6 +99,7 @@ where
                     DisputeMetricsBucketIdentifier::new(
                         i.dispute_stage.as_ref().map(|i| i.0),
                         i.connector.clone(),
+                        i.currency.as_ref().map(|i| i.0),
                         TimeRange {
                             start_time: match (granularity, i.start_bucket) {
                                 (Some(g), Some(st)) => g.clip_to_start(st)?,

crates/analytics/src/disputes/metrics/total_amount_disputed.rs

@@ -97,6 +97,7 @@ where
                     DisputeMetricsBucketIdentifier::new(
                         i.dispute_stage.as_ref().map(|i| i.0),
                         i.connector.clone(),
+                        i.currency.as_ref().map(|i| i.0),
                         TimeRange {
                             start_time: match (granularity, i.start_bucket) {
                                 (Some(g), Some(st)) => g.clip_to_start(st)?,

crates/analytics/src/disputes/metrics/total_dispute_lost_amount.rs

@@ -98,6 +98,7 @@ where
                     DisputeMetricsBucketIdentifier::new(
                         i.dispute_stage.as_ref().map(|i| i.0),
                         i.connector.clone(),
+                        i.currency.as_ref().map(|i| i.0),
                         TimeRange {
                             start_time: match (granularity, i.start_bucket) {
                                 (Some(g), Some(st)) => g.clip_to_start(st)?,

crates/analytics/src/disputes/types.rs

@@ -24,6 +24,12 @@ where
                 .attach_printable("Error adding dispute stage filter")?;
         }
 
+        if !self.currency.is_empty() {
+            builder
+                .add_filter_in_range_clause(DisputeDimensions::Currency, &self.currency)
+                .attach_printable("Error adding currency filter")?;
+        }
+
         Ok(())
     }
 }