#![allow(unused_mut, unused_imports)]
use crate::models::shares::v1::*;
use axum::{RequestExt, RequestPartsExt};
impl<S: Send + Sync> axum::extract::FromRequestParts<S> for ListSharesRequest {
type Rejection = axum::response::Response;
async fn from_request_parts(
parts: &mut axum::http::request::Parts,
_state: &S,
) -> Result<Self, Self::Rejection> {
#[derive(serde::Deserialize)]
struct QueryParams {
#[serde(default)]
max_results: Option<i32>,
#[serde(default)]
page_token: Option<String>,
}
let axum_extra::extract::Query(QueryParams {
max_results,
page_token,
}) = parts
.extract::<axum_extra::extract::Query<QueryParams>>()
.await
.map_err(axum::response::IntoResponse::into_response)?;
Ok(ListSharesRequest {
max_results,
page_token,
..Default::default()
})
}
}
impl<S: Send + Sync> axum::extract::FromRequest<S> for CreateShareRequest {
type Rejection = axum::response::Response;
async fn from_request(
req: axum::extract::Request<axum::body::Body>,
_state: &S,
) -> Result<Self, Self::Rejection> {
let axum::extract::Json(request) = req
.extract()
.await
.map_err(axum::response::IntoResponse::into_response)?;
Ok(request)
}
}
impl<S: Send + Sync> axum::extract::FromRequestParts<S> for GetShareRequest {
type Rejection = axum::response::Response;
async fn from_request_parts(
parts: &mut axum::http::request::Parts,
_state: &S,
) -> Result<Self, Self::Rejection> {
let axum::extract::Path(name) = parts
.extract::<axum::extract::Path<String>>()
.await
.map_err(axum::response::IntoResponse::into_response)?;
#[derive(serde::Deserialize)]
struct QueryParams {
#[serde(default)]
include_shared_data: Option<bool>,
}
let axum_extra::extract::Query(QueryParams {
include_shared_data,
}) = parts
.extract::<axum_extra::extract::Query<QueryParams>>()
.await
.map_err(axum::response::IntoResponse::into_response)?;
Ok(GetShareRequest {
name,
include_shared_data,
..Default::default()
})
}
}
impl<S: Send + Sync> axum::extract::FromRequest<S> for UpdateShareRequest {
type Rejection = axum::response::Response;
async fn from_request(
mut req: axum::extract::Request<axum::body::Body>,
_state: &S,
) -> Result<Self, Self::Rejection> {
let (mut parts, body) = req.into_parts();
let axum::extract::Path(name) = parts
.extract::<axum::extract::Path<String>>()
.await
.map_err(axum::response::IntoResponse::into_response)?;
let body_req = axum::extract::Request::from_parts(parts, body);
let axum::extract::Json::<UpdateShareRequest>(body) = body_req
.extract()
.await
.map_err(axum::response::IntoResponse::into_response)?;
let (updates, new_name, owner, comment) =
(body.updates, body.new_name, body.owner, body.comment);
Ok(UpdateShareRequest {
name,
updates,
new_name,
owner,
comment,
..Default::default()
})
}
}
impl<S: Send + Sync> axum::extract::FromRequestParts<S> for DeleteShareRequest {
type Rejection = axum::response::Response;
async fn from_request_parts(
parts: &mut axum::http::request::Parts,
_state: &S,
) -> Result<Self, Self::Rejection> {
let axum::extract::Path(name) = parts
.extract::<axum::extract::Path<String>>()
.await
.map_err(axum::response::IntoResponse::into_response)?;
Ok(DeleteShareRequest {
name,
..Default::default()
})
}
}
impl<S: Send + Sync> axum::extract::FromRequestParts<S> for GetPermissionsRequest {
type Rejection = axum::response::Response;
async fn from_request_parts(
parts: &mut axum::http::request::Parts,
_state: &S,
) -> Result<Self, Self::Rejection> {
let axum::extract::Path(name) = parts
.extract::<axum::extract::Path<String>>()
.await
.map_err(axum::response::IntoResponse::into_response)?;
#[derive(serde::Deserialize)]
struct QueryParams {
#[serde(default)]
max_results: Option<i32>,
#[serde(default)]
page_token: Option<String>,
}
let axum_extra::extract::Query(QueryParams {
max_results,
page_token,
}) = parts
.extract::<axum_extra::extract::Query<QueryParams>>()
.await
.map_err(axum::response::IntoResponse::into_response)?;
Ok(GetPermissionsRequest {
name,
max_results,
page_token,
..Default::default()
})
}
}
impl<S: Send + Sync> axum::extract::FromRequest<S> for UpdatePermissionsRequest {
type Rejection = axum::response::Response;
async fn from_request(
mut req: axum::extract::Request<axum::body::Body>,
_state: &S,
) -> Result<Self, Self::Rejection> {
let (mut parts, body) = req.into_parts();
let axum::extract::Path(name) = parts
.extract::<axum::extract::Path<String>>()
.await
.map_err(axum::response::IntoResponse::into_response)?;
let body_req = axum::extract::Request::from_parts(parts, body);
let axum::extract::Json::<UpdatePermissionsRequest>(body) = body_req
.extract()
.await
.map_err(axum::response::IntoResponse::into_response)?;
let (changes, omit_permissions_list) = (body.changes, body.omit_permissions_list);
Ok(UpdatePermissionsRequest {
name,
changes,
omit_permissions_list,
..Default::default()
})
}
}