chore: run formatter

crates/analytics/src/opensearch.rs

@@ -10,7 +10,6 @@ use common_utils::{
     types::TimeRange,
 };
 use error_stack::ResultExt;
-use storage_impl::errors::{StorageError, StorageResult};
 use opensearch::{
     auth::Credentials,
     cert::CertificateValidation,
@@ -24,7 +23,7 @@ use opensearch::{
     MsearchParts, OpenSearch, SearchParts,
 };
 use serde_json::{json, Map, Value};
-use storage_impl::errors::ApplicationError;
+use storage_impl::errors::{ApplicationError, StorageError, StorageResult};
 use time::PrimitiveDateTime;
 
 use super::{health_check::HealthCheck, query::QueryResult, types::QueryExecutionError};

crates/hyperswitch_domain_models/src/errors.rs

@@ -1 +1 @@
-pub mod api_error_response;
+pub mod api_error_response;

crates/payment_methods/src/state.rs

@@ -18,7 +18,11 @@ use storage_impl::{kv_router_store::KVRouterStore, DatabaseStore, MockDb, Router
 
 #[async_trait::async_trait]
 pub trait PaymentMethodsStorageInterface:
-    Send + Sync + dyn_clone::DynClone + PaymentMethodInterface<Error = storage_impl::errors::StorageError> + 'static
+    Send
+    + Sync
+    + dyn_clone::DynClone
+    + PaymentMethodInterface<Error = storage_impl::errors::StorageError>
+    + 'static
 {
 }
 dyn_clone::clone_trait_object!(PaymentMethodsStorageInterface);

crates/router/src/core/errors.rs

@@ -10,7 +10,9 @@ use std::fmt::Display;
 use actix_web::{body::BoxBody, ResponseError};
 pub use common_utils::errors::{CustomResult, ParsingError, ValidationError};
 use diesel_models::errors as storage_errors;
-pub use hyperswitch_domain_models::errors::api_error_response::{ApiErrorResponse, ErrorType, NotImplementedMessage};
+pub use hyperswitch_domain_models::errors::api_error_response::{
+    ApiErrorResponse, ErrorType, NotImplementedMessage,
+};
 pub use hyperswitch_interfaces::errors::ConnectorError;
 pub use redis_interface::errors::RedisError;
 use scheduler::errors as sch_errors;

crates/router/src/core/payments.rs

@@ -5571,7 +5571,10 @@ pub async fn list_payments(
             {
                 Ok(pa) => Some(Ok((pi, pa))),
                 Err(error) => {
-                    if matches!(error.current_context(), errors::StorageError::ValueNotFound(_)) {
+                    if matches!(
+                        error.current_context(),
+                        errors::StorageError::ValueNotFound(_)
+                    ) {
                         logger::warn!(
                             ?error,
                             "payment_attempts missing for payment_id : {:?}",

crates/router/src/core/payouts/validator.rs

@@ -18,12 +18,12 @@ use super::helpers;
 ))]
 use crate::core::payment_methods::cards::get_pm_list_context;
 use crate::{
-    errors::StorageError,
     core::{
         errors::{self, RouterResult},
         utils as core_utils,
     },
     db::StorageInterface,
+    errors::StorageError,
     routes::SessionState,
     types::{api::payouts, domain, storage},
     utils,

crates/router/src/db/kafka_store.rs

@@ -2010,10 +2010,8 @@ impl PaymentIntentInterface for KafkaStore {
         profile_id: &id_type::ProfileId,
         merchant_key_store: &domain::MerchantKeyStore,
         storage_scheme: &MerchantStorageScheme,
-    ) -> error_stack::Result<
-        hyperswitch_domain_models::payments::PaymentIntent,
-        errors::StorageError,
-    > {
+    ) -> error_stack::Result<hyperswitch_domain_models::payments::PaymentIntent, errors::StorageError>
+    {
         self.diesel_store
             .find_payment_intent_by_merchant_reference_id_profile_id(
                 state,
@@ -3510,8 +3508,7 @@ impl BatchSampleDataInterface for KafkaStore {
     async fn insert_refunds_batch_for_sample_data(
         &self,
         batch: Vec<diesel_models::RefundNew>,
-    ) -> CustomResult<Vec<diesel_models::Refund>, storage_impl::errors::StorageError>
-    {
+    ) -> CustomResult<Vec<diesel_models::Refund>, storage_impl::errors::StorageError> {
         let refunds_list = self
             .diesel_store
             .insert_refunds_batch_for_sample_data(batch)
@@ -3530,8 +3527,7 @@ impl BatchSampleDataInterface for KafkaStore {
     async fn insert_disputes_batch_for_sample_data(
         &self,
         batch: Vec<diesel_models::DisputeNew>,
-    ) -> CustomResult<Vec<diesel_models::Dispute>, storage_impl::errors::StorageError>
-    {
+    ) -> CustomResult<Vec<diesel_models::Dispute>, storage_impl::errors::StorageError> {
         let disputes_list = self
             .diesel_store
             .insert_disputes_batch_for_sample_data(batch)
@@ -3597,8 +3593,7 @@ impl BatchSampleDataInterface for KafkaStore {
     async fn delete_refunds_for_sample_data(
         &self,
         merchant_id: &id_type::MerchantId,
-    ) -> CustomResult<Vec<diesel_models::Refund>, storage_impl::errors::StorageError>
-    {
+    ) -> CustomResult<Vec<diesel_models::Refund>, storage_impl::errors::StorageError> {
         let refunds_list = self
             .diesel_store
             .delete_refunds_for_sample_data(merchant_id)
@@ -3618,8 +3613,7 @@ impl BatchSampleDataInterface for KafkaStore {
     async fn delete_disputes_for_sample_data(
         &self,
         merchant_id: &id_type::MerchantId,
-    ) -> CustomResult<Vec<diesel_models::Dispute>, storage_impl::errors::StorageError>
-    {
+    ) -> CustomResult<Vec<diesel_models::Dispute>, storage_impl::errors::StorageError> {
         let disputes_list = self
             .diesel_store
             .delete_disputes_for_sample_data(merchant_id)

crates/router/src/events.rs

@@ -2,11 +2,13 @@ use std::collections::HashMap;
 
 use error_stack::ResultExt;
 use events::{EventsError, Message, MessagingInterface};
-use storage_impl::errors::{StorageError, StorageResult};
 use masking::ErasedMaskSerialize;
 use router_env::logger;
 use serde::{Deserialize, Serialize};
-use storage_impl::{config::TenantConfig, errors::ApplicationError};
+use storage_impl::{
+    config::TenantConfig,
+    errors::{ApplicationError, StorageError, StorageResult},
+};
 use time::PrimitiveDateTime;
 
 use crate::{

crates/storage_impl/src/database/store.rs

@@ -3,6 +3,7 @@ use bb8::CustomizeConnection;
 use common_utils::DbConnectionParams;
 use diesel::PgConnection;
 use error_stack::ResultExt;
+
 use crate::{
     config::{Database, TenantConfig},
     errors::{StorageError, StorageResult},

crates/storage_impl/src/mock_db/payment_intent.rs

@@ -9,9 +9,9 @@ use hyperswitch_domain_models::{
         PaymentIntent,
     },
 };
-use crate::errors::StorageError;
 
 use super::MockDb;
+use crate::errors::StorageError;
 
 #[async_trait::async_trait]
 impl PaymentIntentInterface for MockDb {

crates/storage_impl/src/payment_method.rs

@@ -20,13 +20,12 @@ use router_env::{instrument, tracing};
 
 use super::MockDb;
 use crate::{
-    diesel_error_to_data_error,
-    errors,
+    diesel_error_to_data_error, errors,
     kv_router_store::{
         FilterResourceParams, FindResourceBy, InsertResourceParams, KVRouterStore,
         UpdateResourceParams,
     },
-    redis::kv_store::{ Op, PartitionKey},
+    redis::kv_store::{Op, PartitionKey},
     utils::{pg_connection_read, pg_connection_write},
     DatabaseStore, RouterStore,
 };
@@ -72,7 +71,10 @@ impl<T: DatabaseStore> PaymentMethodInterface for KVRouterStore<T> {
             key_store,
             storage_scheme,
             PaymentMethod::find_by_id(&conn, payment_method_id),
-            FindResourceBy::LookupId(format!("payment_method_{}", payment_method_id.get_string_repr())),
+            FindResourceBy::LookupId(format!(
+                "payment_method_{}",
+                payment_method_id.get_string_repr()
+            )),
         )
         .await
     }

crates/storage_impl/src/payments/payment_intent.rs

@@ -47,8 +47,7 @@ use router_env::{instrument, tracing};
 use crate::connection;
 use crate::{
     diesel_error_to_data_error,
-    errors::StorageError,
-    errors::RedisErrorExt,
+    errors::{RedisErrorExt, StorageError},
     kv_router_store::KVRouterStore,
     redis::kv_store::{decide_storage_scheme, kv_wrapper, KvOperation, Op, PartitionKey},
     utils::{self, pg_connection_read, pg_connection_write},

crates/storage_impl/src/payouts/payouts.rs

@@ -62,8 +62,8 @@ use crate::store::schema::{
     payout_attempt::all_columns as poa_all_columns, payouts::all_columns as po_all_columns,
 };
 use crate::{
-    diesel_error_to_data_error, errors::StorageError,
-    errors::RedisErrorExt,
+    diesel_error_to_data_error,
+    errors::{RedisErrorExt, StorageError},
     kv_router_store::KVRouterStore,
     redis::kv_store::{decide_storage_scheme, kv_wrapper, KvOperation, Op, PartitionKey},
     utils::{self, pg_connection_read, pg_connection_write},
@@ -603,7 +603,6 @@ impl<T: DatabaseStore> PayoutsInterface for crate::RouterStore<T> {
         )>,
         StorageError,
     > {
-
         let conn = connection::pg_connection_read(self).await?;
         let conn = async_bb8_diesel::Connection::as_async_conn(&conn);
         let mut query = DieselPayouts::table()