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

refactor(router): make api services public (#277)

Browse Source
This commit is contained in:
ItsMeShashank
2023-01-04 15:26:23 +05:30
committed by GitHub
parent 0559f48096
commit c7dd51df55
1 changed files with 13 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
crates/router/src/services/api.rs
View File

@ -183,7 +183,7 @@ where
} }
#[instrument(skip_all)] #[instrument(skip_all)]
pub(crate) async fn call_connector_api( pub async fn call_connector_api(
state: &AppState, state: &AppState,
request: Request, request: Request,
) -> CustomResult<Result<types::Response, types::Response>, errors::ApiClientError> { ) -> CustomResult<Result<types::Response, types::Response>, errors::ApiClientError> {
@ -409,14 +409,14 @@ pub enum AuthFlow {
Merchant, Merchant,
} }
pub(crate) fn get_auth_flow(auth_type: &MerchantAuthentication<'_>) -> AuthFlow { pub fn get_auth_flow(auth_type: &MerchantAuthentication<'_>) -> AuthFlow {
match auth_type { match auth_type {
MerchantAuthentication::ApiKey => AuthFlow::Merchant, MerchantAuthentication::ApiKey => AuthFlow::Merchant,
_ => AuthFlow::Client, _ => AuthFlow::Client,
} }
} }
pub(crate) fn get_auth_type(request: &HttpRequest) -> RouterResult<MerchantAuthentication<'_>> { pub fn get_auth_type(request: &HttpRequest) -> RouterResult<MerchantAuthentication<'_>> {
let api_key = get_api_key(request).change_context(errors::ApiErrorResponse::Unauthorized)?; let api_key = get_api_key(request).change_context(errors::ApiErrorResponse::Unauthorized)?;
if api_key.starts_with("pk_") { if api_key.starts_with("pk_") {
Ok(MerchantAuthentication::PublishableKey) Ok(MerchantAuthentication::PublishableKey)
@ -426,7 +426,7 @@ pub(crate) fn get_auth_type(request: &HttpRequest) -> RouterResult<MerchantAuthe
} }
#[instrument(skip(request, payload, state, func))] #[instrument(skip(request, payload, state, func))]
pub(crate) async fn server_wrap_util<'a, 'b, T, Q, F, Fut>( pub async fn server_wrap_util<'a, 'b, T, Q, F, Fut>(
state: &'b AppState, state: &'b AppState,
request: &'a HttpRequest, request: &'a HttpRequest,
payload: T, payload: T,
@ -455,7 +455,7 @@ where
skip(request, payload, state, func), skip(request, payload, state, func),
fields(request_method, request_url_path) fields(request_method, request_url_path)
)] )]
pub(crate) async fn server_wrap<'a, 'b, A, T, Q, F, Fut>( pub async fn server_wrap<'a, 'b, A, T, Q, F, Fut>(
state: &'b AppState, state: &'b AppState,
request: &'a HttpRequest, request: &'a HttpRequest,
payload: T, payload: T,
@ -520,7 +520,7 @@ where
res res
} }
pub(crate) fn log_and_return_error_response<T>(error: Report<T>) -> HttpResponse pub fn log_and_return_error_response<T>(error: Report<T>) -> HttpResponse
where where
T: actix_web::ResponseError + error_stack::Context, T: actix_web::ResponseError + error_stack::Context,
{ {
@ -594,7 +594,7 @@ pub async fn authenticate_connector<'a>(
} }
} }
pub(crate) fn get_auth_type_and_check_client_secret<P>( pub fn get_auth_type_and_check_client_secret<P>(
req: &HttpRequest, req: &HttpRequest,
payload: P, payload: P,
) -> RouterResult<(P, MerchantAuthentication<'_>)> ) -> RouterResult<(P, MerchantAuthentication<'_>)>
@ -608,7 +608,7 @@ where
)) ))
} }
pub(crate) async fn authenticate_eph_key<'a>( pub async fn authenticate_eph_key<'a>(
req: &'a HttpRequest, req: &'a HttpRequest,
store: &dyn StorageInterface, store: &dyn StorageInterface,
customer_id: String, customer_id: String,
@ -662,25 +662,25 @@ async fn authenticate_by_publishable_key(
.attach_printable("Merchant not authenticated") .attach_printable("Merchant not authenticated")
} }
pub(crate) fn http_response_json<T: body::MessageBody + 'static>(response: T) -> HttpResponse { pub fn http_response_json<T: body::MessageBody + 'static>(response: T) -> HttpResponse {
HttpResponse::Ok() HttpResponse::Ok()
.content_type("application/json") .content_type("application/json")
.append_header(("Via", "Juspay_router")) .append_header(("Via", "Juspay_router"))
.body(response) .body(response)
} }
pub(crate) fn http_response_plaintext<T: body::MessageBody + 'static>(res: T) -> HttpResponse { pub fn http_response_plaintext<T: body::MessageBody + 'static>(res: T) -> HttpResponse {
HttpResponse::Ok() HttpResponse::Ok()
.content_type("text/plain") .content_type("text/plain")
.append_header(("Via", "Juspay_router")) .append_header(("Via", "Juspay_router"))
.body(res) .body(res)
} }
pub(crate) fn http_response_ok() -> HttpResponse { pub fn http_response_ok() -> HttpResponse {
HttpResponse::Ok().finish() HttpResponse::Ok().finish()
} }
pub(crate) fn http_redirect_response<T: body::MessageBody + 'static>( pub fn http_redirect_response<T: body::MessageBody + 'static>(
response: T, response: T,
redirection_response: api::RedirectionResponse, redirection_response: api::RedirectionResponse,
) -> HttpResponse { ) -> HttpResponse {
@ -695,7 +695,7 @@ pub(crate) fn http_redirect_response<T: body::MessageBody + 'static>(
.body(response) .body(response)
} }
pub(crate) fn http_response_err<T: body::MessageBody + 'static>(response: T) -> HttpResponse { pub fn http_response_err<T: body::MessageBody + 'static>(response: T) -> HttpResponse {
HttpResponse::BadRequest() HttpResponse::BadRequest()
.content_type("application/json") .content_type("application/json")
.append_header(("Via", "Juspay_router")) .append_header(("Via", "Juspay_router"))