Skip to content

Commit

Permalink
refactor: [torrust#39] upload torrent handler
Browse files Browse the repository at this point in the history
The upload torrent handler now uses the extractor to get the user id.
  • Loading branch information
mario-nt committed Nov 30, 2023
1 parent da8e2ea commit 684a922
Showing 1 changed file with 7 additions and 7 deletions.
14 changes: 7 additions & 7 deletions src/web/api/v1/contexts/torrent/handlers.rs
Original file line number Diff line number Diff line change
Expand Up @@ -23,6 +23,7 @@ use crate::services::torrent_file::generate_random_torrent;
use crate::utils::parse_torrent;
use crate::web::api::v1::auth::get_optional_logged_in_user;
use crate::web::api::v1::extractors::bearer_token::Extract;
use crate::web::api::v1::extractors::user_id::ExtractLoggedInUser;
use crate::web::api::v1::responses::OkResponseData;
use crate::web::api::v1::routes::API_VERSION_URL_PREFIX;

Expand All @@ -37,20 +38,19 @@ use crate::web::api::v1::routes::API_VERSION_URL_PREFIX;
#[allow(clippy::unused_async)]
pub async fn upload_torrent_handler(
State(app_data): State<Arc<AppData>>,
Extract(maybe_bearer_token): Extract,
ExtractLoggedInUser(user_id): ExtractLoggedInUser,
multipart: Multipart,
) -> Response {
let user_id = match app_data.auth.get_user_id_from_bearer_token(&maybe_bearer_token).await {
Ok(user_id) => user_id,
Err(error) => return error.into_response(),
};

let add_torrent_form = match build_add_torrent_request_from_payload(multipart).await {
Ok(torrent_request) => torrent_request,
Err(error) => return error.into_response(),
};

match app_data.torrent_service.add_torrent(add_torrent_form, user_id).await {
match app_data
.torrent_service
.add_torrent(add_torrent_form, user_id.unwrap().value())
.await
{
Ok(response) => new_torrent_response(&response).into_response(),
Err(error) => error.into_response(),
}
Expand Down

0 comments on commit 684a922

Please sign in to comment.