xerbalind/planetwars.dev
1
0
Fork 0
Code Issues Pull requests Projects Releases 1 Packages 1 Wiki Activity

rename route handler methods

Browse source
This commit is contained in:
Ilion Beyst 2022-06-20 20:27:51 +02:00
parent 478094abcf
commit a2a8a41689
1 changed files with 15 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

27
planetwars-server/src/modules/registry.rs
View file

@ -25,17 +25,20 @@ pub fn registry_service() -> Router {
fn registry_api_v2() -> Router { fn registry_api_v2() -> Router {
Router::new() Router::new()
.route("/", get(root_handler)) .route("/", get(get_root))
.route("/:name/blobs/:digest", head(blob_check).get(get_blob))
.route("/:name/blobs/uploads/", post(blob_upload))
.route(
"/:name/blobs/uploads/:uuid",
put(put_handler).patch(handle_upload),
)
.route( .route(
"/:name/manifests/:reference", "/:name/manifests/:reference",
get(get_manifest).put(put_manifest), get(get_manifest).put(put_manifest),
) )
.route(
"/:name/blobs/:digest",
head(check_blob_exists).get(get_blob),
)
.route("/:name/blobs/uploads/", post(create_upload))
.route(
"/:name/blobs/uploads/:uuid",
put(put_upload).patch(patch_upload),
)
} }
async fn fallback(request: axum::http::Request<Body>) -> impl IntoResponse { async fn fallback(request: axum::http::Request<Body>) -> impl IntoResponse {
@ -77,7 +80,7 @@ where
} }
} }
async fn root_handler(_auth: RegistryAuth) -> impl IntoResponse { async fn get_root(_auth: RegistryAuth) -> impl IntoResponse {
// root should return 200 OK to confirm api compliance // root should return 200 OK to confirm api compliance
Response::builder() Response::builder()
.status(StatusCode::OK) .status(StatusCode::OK)
@ -98,7 +101,7 @@ pub struct RegistryError {
detail: serde_json::Value, detail: serde_json::Value,
} }
async fn blob_check( async fn check_blob_exists(
Path((_repository_name, raw_digest)): Path<(String, String)>, Path((_repository_name, raw_digest)): Path<(String, String)>,
) -> impl IntoResponse { ) -> impl IntoResponse {
let digest = raw_digest.strip_prefix("sha256:").unwrap(); let digest = raw_digest.strip_prefix("sha256:").unwrap();
@ -124,7 +127,7 @@ async fn get_blob(
Ok(stream_body) Ok(stream_body)
} }
async fn blob_upload(Path(repository_name): Path<String>) -> impl IntoResponse { async fn create_upload(Path(repository_name): Path<String>) -> impl IntoResponse {
let uuid = gen_alphanumeric(16); let uuid = gen_alphanumeric(16);
tokio::fs::File::create(PathBuf::from(REGISTRY_PATH).join("uploads").join(&uuid)) tokio::fs::File::create(PathBuf::from(REGISTRY_PATH).join("uploads").join(&uuid))
.await .await
@ -144,7 +147,7 @@ async fn blob_upload(Path(repository_name): Path<String>) -> impl IntoResponse {
use futures::StreamExt; use futures::StreamExt;
async fn handle_upload( async fn patch_upload(
Path((repository_name, uuid)): Path<(String, String)>, Path((repository_name, uuid)): Path<(String, String)>,
mut stream: BodyStream, mut stream: BodyStream,
) -> impl IntoResponse { ) -> impl IntoResponse {
@ -185,7 +188,7 @@ struct UploadParams {
digest: String, digest: String,
} }
async fn put_handler( async fn put_upload(
Path((repository_name, uuid)): Path<(String, String)>, Path((repository_name, uuid)): Path<(String, String)>,
Query(params): Query<UploadParams>, Query(params): Query<UploadParams>,
mut stream: BodyStream, mut stream: BodyStream,