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

store blobs in sha256 directory

Browse source
This commit is contained in:
Ilion Beyst 2022-06-17 19:01:40 +02:00
parent dde0bc820e
commit b90b3d3635
1 changed files with 6 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -62,7 +62,7 @@ async fn blob_check(
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();
let blob_path = PathBuf::from(REGISTRY_PATH).join(&digest); let blob_path = PathBuf::from(REGISTRY_PATH).join("sha256").join(&digest);
if blob_path.exists() { if blob_path.exists() {
StatusCode::OK StatusCode::OK
} else { } else {
@ -162,9 +162,9 @@ async fn put_handler(
} }
let digest = params.digest.strip_prefix("sha256:").unwrap(); let digest = params.digest.strip_prefix("sha256:").unwrap();
// TODO: check the digest // TODO: check the digest
let target_path = PathBuf::from(REGISTRY_PATH).join(&digest); let target_path = PathBuf::from(REGISTRY_PATH).join("sha256").join(&digest);
tokio::fs::rename(&upload_path, &target_path).await.unwrap(); tokio::fs::rename(&upload_path, &target_path).await.unwrap();
println!("DIGEST {}", digest);
Response::builder() Response::builder()
.status(StatusCode::CREATED) .status(StatusCode::CREATED)
.header( .header(
@ -182,7 +182,9 @@ async fn put_manifest(
Path((repository_name, reference)): Path<(String, String)>, Path((repository_name, reference)): Path<(String, String)>,
mut stream: BodyStream, mut stream: BodyStream,
) -> impl IntoResponse { ) -> impl IntoResponse {
let repository_dir = PathBuf::from(REGISTRY_PATH).join(&repository_name); let repository_dir = PathBuf::from(REGISTRY_PATH)
.join("manifests")
.join(&repository_name);
tokio::fs::create_dir_all(&repository_dir).await.unwrap(); tokio::fs::create_dir_all(&repository_dir).await.unwrap();