rust/hyperswitch
1
0
Fork 0
mirror of https://github.com/juspay/hyperswitch.git synced 2025-11-02 21:07:58 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor(accounts): move dashboard_metadata table to accounts_schema and point v2 to v1 dashboard_metadata (#7793)

Browse Source
This commit is contained in:
Sandeep Kumar
2025-04-17 15:49:38 +05:30
committed by GitHub
parent 2067bc3520
commit 4f4e31db24
2 changed files with 7 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
crates/router/src/db.rs
View File

@ -169,6 +169,7 @@ pub trait AccountsStorageInterface:
+ business_profile::ProfileInterface
+ merchant_connector_account::MerchantConnectorAccountInterface
+ merchant_key_store::MerchantKeyStoreInterface
+ dashboard_metadata::DashboardMetadataInterface
+ 'static
{
}

12
crates/router/src/db/dashboard_metadata.rs
View File

@ -62,7 +62,7 @@ impl DashboardMetadataInterface for Store {
&self,
metadata: storage::DashboardMetadataNew,
) -> CustomResult<storage::DashboardMetadata, errors::StorageError> {
let conn = connection::pg_connection_write(self).await?;
let conn = connection::pg_accounts_connection_write(self).await?;
metadata
.insert(&conn)
.await
@ -78,7 +78,7 @@ impl DashboardMetadataInterface for Store {
data_key: enums::DashboardMetadata,
dashboard_metadata_update: storage::DashboardMetadataUpdate,
) -> CustomResult<storage::DashboardMetadata, errors::StorageError> {
let conn = connection::pg_connection_write(self).await?;
let conn = connection::pg_accounts_connection_write(self).await?;
storage::DashboardMetadata::update(
&conn,
user_id,
@ -99,7 +99,7 @@ impl DashboardMetadataInterface for Store {
org_id: &id_type::OrganizationId,
data_keys: Vec<enums::DashboardMetadata>,
) -> CustomResult<Vec<storage::DashboardMetadata>, errors::StorageError> {
let conn = connection::pg_connection_read(self).await?;
let conn = connection::pg_accounts_connection_read(self).await?;
storage::DashboardMetadata::find_user_scoped_dashboard_metadata(
&conn,
user_id.to_owned(),
@ -118,7 +118,7 @@ impl DashboardMetadataInterface for Store {
org_id: &id_type::OrganizationId,
data_keys: Vec<enums::DashboardMetadata>,
) -> CustomResult<Vec<storage::DashboardMetadata>, errors::StorageError> {
let conn = connection::pg_connection_read(self).await?;
let conn = connection::pg_accounts_connection_read(self).await?;
storage::DashboardMetadata::find_merchant_scoped_dashboard_metadata(
&conn,
merchant_id.to_owned(),
@ -135,7 +135,7 @@ impl DashboardMetadataInterface for Store {
user_id: &str,
merchant_id: &id_type::MerchantId,
) -> CustomResult<bool, errors::StorageError> {
let conn = connection::pg_connection_write(self).await?;
let conn = connection::pg_accounts_connection_write(self).await?;
storage::DashboardMetadata::delete_all_user_scoped_dashboard_metadata_by_merchant_id(
&conn,
user_id.to_owned(),
@ -152,7 +152,7 @@ impl DashboardMetadataInterface for Store {
merchant_id: &id_type::MerchantId,
data_key: enums::DashboardMetadata,
) -> CustomResult<storage::DashboardMetadata, errors::StorageError> {
let conn = connection::pg_connection_write(self).await?;
let conn = connection::pg_accounts_connection_write(self).await?;
storage::DashboardMetadata::delete_user_scoped_dashboard_metadata_by_merchant_id_data_key(
&conn,
user_id.to_owned(),