feat(lfs): support FastCDC media transport (#2178)

* feat(lfs): support FastCDC media transport

Signed-off-by: Henry Guo <marshawcoco@gmail.com>

* fix(storage): preserve object lookup errors

Signed-off-by: Henry Guo <marshawcoco@gmail.com>

* fix(lfs): defer HTTP response construction for errors

Signed-off-by: Henry Guo <marshawcoco@gmail.com>

---------

Signed-off-by: Henry Guo <marshawcoco@gmail.com>

Author: marshawcoco

Cargo.lock

@@ -29,6 +29,9 @@ rand = { workspace = true, features = ["thread_rng"] }
 serde = { workspace = true, features = ["derive"] }
 serde_json = { workspace = true }
 sha1 = { workspace = true }
+sha2 = { workspace = true, optional = true }
+tempfile = { workspace = true, optional = true }
+thiserror = { workspace = true, optional = true }
 tracing = { workspace = true }
 uuid = { workspace = true, features = ["v4"] }
 reqwest = { workspace = true, features = ["json", "stream"] }
@@ -43,9 +46,11 @@ tokio-util = { workspace = true }
 rkyv = { workspace = true }
 
 [features]
+fastcdc = ["dep:sha2", "dep:tempfile", "dep:thiserror"]
 migrate = ["jupiter/migrate"]
 
 [dev-dependencies]
+sea-orm = { workspace = true }
 axum = { workspace = true }
 jupiter-migrate = { workspace = true }
 orion-client = { workspace = true }

ceres/Cargo.toml

@@ -14,6 +14,11 @@ use crate::lfs::{
 };
 
 impl LfsApplicationService {
+    #[cfg(feature = "fastcdc")]
+    pub fn media_service(&self) -> &jupiter::service::lfs_service::LfsService {
+        &self.ctx.storage().lfs_service
+    }
+
     pub async fn lfs_retrieve_lock(&self, query: LockListQuery) -> Result<LockList, GitLFSError> {
         handler::lfs_retrieve_lock(self.ctx.storage().lfs_db_storage(), query).await
     }