-
Notifications
You must be signed in to change notification settings - Fork 1.2k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat(analytics): three_ds and authentication events in sdkevents (#4251)
Co-authored-by: Akash Kamble <127744130+akash-c-k@users.noreply.github.com>
- Loading branch information
1 parent
a071463
commit 88b53b0
Showing
13 changed files
with
914 additions
and
29 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
122 changes: 122 additions & 0 deletions
122
crates/analytics/src/sdk_events/metrics/authentication_unsuccessful_count.rs
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,122 @@ | ||
| use api_models::analytics::{ | ||
| sdk_events::{ | ||
| SdkEventDimensions, SdkEventFilters, SdkEventMetricsBucketIdentifier, SdkEventNames, | ||
| }, | ||
| Granularity, TimeRange, | ||
| }; | ||
| use common_utils::errors::ReportSwitchExt; | ||
| use error_stack::ResultExt; | ||
| use time::PrimitiveDateTime; | ||
|
|
||
| use super::SdkEventMetricRow; | ||
| use crate::{ | ||
| query::{Aggregate, GroupByClause, QueryBuilder, QueryFilter, ToSql, Window}, | ||
| types::{AnalyticsCollection, AnalyticsDataSource, MetricsError, MetricsResult}, | ||
| }; | ||
|
|
||
| #[derive(Default)] | ||
| pub(super) struct AuthenticationUnsuccessfulCount; | ||
|
|
||
| #[async_trait::async_trait] | ||
| impl<T> super::SdkEventMetric<T> for AuthenticationUnsuccessfulCount | ||
| where | ||
| T: AnalyticsDataSource + super::SdkEventMetricAnalytics, | ||
| PrimitiveDateTime: ToSql<T>, | ||
| AnalyticsCollection: ToSql<T>, | ||
| Granularity: GroupByClause<T>, | ||
| Aggregate<&'static str>: ToSql<T>, | ||
| Window<&'static str>: ToSql<T>, | ||
| { | ||
| async fn load_metrics( | ||
| &self, | ||
| dimensions: &[SdkEventDimensions], | ||
| publishable_key: &str, | ||
| filters: &SdkEventFilters, | ||
| granularity: &Option<Granularity>, | ||
| time_range: &TimeRange, | ||
| pool: &T, | ||
| ) -> MetricsResult<Vec<(SdkEventMetricsBucketIdentifier, SdkEventMetricRow)>> { | ||
| let mut query_builder: QueryBuilder<T> = QueryBuilder::new(AnalyticsCollection::SdkEvents); | ||
| let dimensions = dimensions.to_vec(); | ||
|
|
||
| for dim in dimensions.iter() { | ||
| query_builder.add_select_column(dim).switch()?; | ||
| } | ||
|
|
||
| query_builder | ||
| .add_select_column(Aggregate::Count { | ||
| field: None, | ||
| alias: Some("count"), | ||
| }) | ||
| .switch()?; | ||
|
|
||
| if let Some(granularity) = granularity.as_ref() { | ||
| query_builder | ||
| .add_granularity_in_mins(granularity) | ||
| .switch()?; | ||
| } | ||
|
|
||
| filters.set_filter_clause(&mut query_builder).switch()?; | ||
|
|
||
| query_builder | ||
| .add_filter_clause("merchant_id", publishable_key) | ||
| .switch()?; | ||
|
|
||
| query_builder | ||
| .add_filter_clause("event_name", SdkEventNames::AuthenticationCall) | ||
| .switch()?; | ||
|
|
||
| query_builder | ||
| .add_filter_clause("log_type", "ERROR") | ||
| .switch()?; | ||
|
|
||
| query_builder | ||
| .add_filter_clause("category", "USER_EVENT") | ||
| .switch()?; | ||
|
|
||
| time_range | ||
| .set_filter_clause(&mut query_builder) | ||
| .attach_printable("Error filtering time range") | ||
| .switch()?; | ||
|
|
||
| for dim in dimensions.iter() { | ||
| query_builder | ||
| .add_group_by_clause(dim) | ||
| .attach_printable("Error grouping by dimensions") | ||
| .switch()?; | ||
| } | ||
|
|
||
| if let Some(_granularity) = granularity.as_ref() { | ||
| query_builder | ||
| .add_group_by_clause("time_bucket") | ||
| .attach_printable("Error adding granularity") | ||
| .switch()?; | ||
| } | ||
|
|
||
| query_builder | ||
| .execute_query::<SdkEventMetricRow, _>(pool) | ||
| .await | ||
| .change_context(MetricsError::QueryBuildingError)? | ||
| .change_context(MetricsError::QueryExecutionFailure)? | ||
| .into_iter() | ||
| .map(|i| { | ||
| Ok(( | ||
| SdkEventMetricsBucketIdentifier::new( | ||
| i.payment_method.clone(), | ||
| i.platform.clone(), | ||
| i.browser_name.clone(), | ||
| i.source.clone(), | ||
| i.component.clone(), | ||
| i.payment_experience.clone(), | ||
| i.time_bucket.clone(), | ||
| ), | ||
| i, | ||
| )) | ||
| }) | ||
| .collect::<error_stack::Result< | ||
| Vec<(SdkEventMetricsBucketIdentifier, SdkEventMetricRow)>, | ||
| crate::query::PostProcessingError, | ||
| >>() | ||
| .change_context(MetricsError::PostProcessingFailure) | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.