Commit

Author:

Hash:

Timestamp:

+4 -10 +/-4 browse

Kevin Schoon [me@kevinschoon.com]

9ebfbeccedc21ecfb0342c0e33dd001a2012fa73

Sun, 13 Apr 2025 12:00:38 +0000 (6 months ago)

.
1diff --git a/src/axum/paths.rs b/src/axum/paths.rs
2index 66ac9b1..da82db5 100644
3--- a/src/axum/paths.rs
4+++ b/src/axum/paths.rs
5 @@ -18,7 +18,7 @@ where
6 async fn from_request_parts(parts: &mut Parts, state: &S) -> Result<Self, Self::Rejection> {
7 match axum::extract::Path::<Digest>::from_request_parts(parts, state).await {
8 Ok(value) => Ok(Self(value.0)),
9- Err(e) => Err(Error::Code(Code::DigestInvalid, None)),
10+ Err(_) => Err(Error::Code(Code::DigestInvalid, None)),
11 }
12 }
13 }
14 diff --git a/src/oci_interface.rs b/src/oci_interface.rs
15index 3721a9d..9c63cb3 100644
16--- a/src/oci_interface.rs
17+++ b/src/oci_interface.rs
18 @@ -48,10 +48,6 @@ impl OciInterface {
19 Ok(blob_addr.address())
20 }
21
22- pub async fn list_tags(&self, namespace: &Namespace) -> Result<TagList, Error> {
23- todo!()
24- }
25-
26 pub async fn new_blob(&self, namespace: &Namespace) -> Result<Uuid, Error> {
27 let uuid = Uuid::new_v4();
28 self.store()
29 @@ -161,9 +157,7 @@ impl OciInterface {
30 let manifest_embedded_data = manifest.config().data();
31 if let Some(manifest_embedded_data) = manifest_embedded_data {
32 // let manifest_str = manifest.to_string_pretty().unwrap();
33- let decoded = BASE64_STANDARD
34- .decode(manifest_embedded_data)
35- .unwrap();
36+ let decoded = BASE64_STANDARD.decode(manifest_embedded_data).unwrap();
37 self.storage
38 .inner()
39 .write_all(
40 diff --git a/src/storage.rs b/src/storage.rs
41index 37e2a2c..e97ad41 100644
42--- a/src/storage.rs
43+++ b/src/storage.rs
44 @@ -4,7 +4,7 @@ use bytes::Bytes;
45 use futures::{Stream, stream::BoxStream};
46
47 use crate::{
48- address::{Address, Addressable},
49+ address::Addressable,
50 storage_fs::FileSystem,
51 };
52
53 diff --git a/src/storage_fs.rs b/src/storage_fs.rs
54index 401c2ea..0674487 100644
55--- a/src/storage_fs.rs
56+++ b/src/storage_fs.rs
57 @@ -8,7 +8,7 @@ use futures::StreamExt;
58 use tokio::io::AsyncWriteExt;
59
60 use crate::{
61- address::{Address, Addressable},
62+ address::Addressable,
63 storage::{Error, InnerStream, StorageIface},
64 };
65