4c3ba46ba3
Add multiple additional helpers such as: - `path_to_name`: derive the basename of a given path - `derive_nar_ca_path_info`: derive the `PathInfo` for a content addressed NAR which isolates further the tree walking feature and the ingestion feature. Additionally, we don't `expect` anymore and propagate properly ingestion errors up. Change-Id: I60edb5b633911c58ade7e19f5002e6f75f90e262 Reviewed-on: https://cl.tvl.fyi/c/depot/+/10574 Reviewed-by: flokli <flokli@flokli.de> Tested-by: BuildkiteCI Autosubmit: raitobezarius <tvl@lahfa.xyz>
35 lines
1 KiB
Rust
35 lines
1 KiB
Rust
use std::sync::Arc;
|
|
|
|
use tvix_castore::{
|
|
blobservice::{self, BlobService},
|
|
directoryservice::{self, DirectoryService},
|
|
};
|
|
|
|
use crate::pathinfoservice::{self, PathInfoService};
|
|
|
|
/// Construct the three store handles from their addrs.
|
|
pub async fn construct_services(
|
|
blob_service_addr: impl AsRef<str>,
|
|
directory_service_addr: impl AsRef<str>,
|
|
path_info_service_addr: impl AsRef<str>,
|
|
) -> std::io::Result<(
|
|
Arc<dyn BlobService>,
|
|
Arc<dyn DirectoryService>,
|
|
Box<dyn PathInfoService>,
|
|
)> {
|
|
let blob_service: Arc<dyn BlobService> = blobservice::from_addr(blob_service_addr.as_ref())
|
|
.await?
|
|
.into();
|
|
let directory_service: Arc<dyn DirectoryService> =
|
|
directoryservice::from_addr(directory_service_addr.as_ref())
|
|
.await?
|
|
.into();
|
|
let path_info_service = pathinfoservice::from_addr(
|
|
path_info_service_addr.as_ref(),
|
|
blob_service.clone(),
|
|
directory_service.clone(),
|
|
)
|
|
.await?;
|
|
|
|
Ok((blob_service, directory_service, path_info_service))
|
|
}
|