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

feat(opensearch): add profile_id and organization_id to /search APIs (#5705)

Browse Source 
Co-authored-by: hyperswitch-bot[bot] <148525504+hyperswitch-bot[bot]@users.noreply.github.com>
This commit is contained in:
Sandeep Kumar
2024-09-11 21:07:44 +05:30
committed by GitHub
parent b72c77075e
commit 7eb5354efe
3 changed files with 123 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
crates/router/src/analytics.rs
View File

@ -21,6 +21,7 @@ pub mod routes {
GetSdkEventMetricRequest, ReportRequest,
};
use common_enums::EntityType;
use common_utils::id_type::{MerchantId, OrganizationId};
use error_stack::{report, ResultExt};
use crate::{
@ -1840,10 +1841,17 @@ pub mod routes {
.map(|(i, _)| *i)
.collect();
let merchant_id: MerchantId = auth.merchant_id;
let org_id: OrganizationId = auth.org_id;
let search_params: Vec<AuthInfo> = vec![AuthInfo::MerchantLevel {
org_id: org_id.clone(),
merchant_ids: vec![merchant_id.clone()],
}];
analytics::search::msearch_results(
&state.opensearch_client,
req,
&auth.merchant_id,
search_params,
accessible_indexes,
)
.await
@ -1888,7 +1896,15 @@ pub mod routes {
.filter(|(ind, _)| *ind == index)
.find(|i| i.1.iter().any(|p| permissions.contains(p)))
.ok_or(OpenSearchError::IndexAccessNotPermittedError(index))?;
analytics::search::search_results(&state.opensearch_client, req, &auth.merchant_id)
let merchant_id: MerchantId = auth.merchant_id;
let org_id: OrganizationId = auth.org_id;
let search_params: Vec<AuthInfo> = vec![AuthInfo::MerchantLevel {
org_id: org_id.clone(),
merchant_ids: vec![merchant_id.clone()],
}];
analytics::search::search_results(&state.opensearch_client, req, search_params)
.await
.map(ApplicationResponse::Json)
},