2023-02-15 14:00:27 +01:00
|
|
|
use tvix_store::blobservice::SledBlobService;
|
|
|
|
use tvix_store::chunkservice::SledChunkService;
|
|
|
|
use tvix_store::directoryservice::SledDirectoryService;
|
|
|
|
use tvix_store::nar::NonCachingNARCalculationService;
|
|
|
|
use tvix_store::pathinfoservice::SledPathInfoService;
|
2023-01-02 14:37:08 +01:00
|
|
|
use tvix_store::proto::blob_service_server::BlobServiceServer;
|
|
|
|
use tvix_store::proto::directory_service_server::DirectoryServiceServer;
|
|
|
|
use tvix_store::proto::path_info_service_server::PathInfoServiceServer;
|
2023-02-15 14:00:27 +01:00
|
|
|
use tvix_store::proto::GRPCBlobServiceWrapper;
|
|
|
|
use tvix_store::proto::GRPCDirectoryServiceWrapper;
|
|
|
|
use tvix_store::proto::GRPCPathInfoServiceWrapper;
|
2022-12-28 16:40:28 +01:00
|
|
|
|
2022-11-26 02:14:02 +01:00
|
|
|
#[cfg(feature = "reflection")]
|
2023-01-02 14:37:08 +01:00
|
|
|
use tvix_store::proto::FILE_DESCRIPTOR_SET;
|
2022-11-26 02:14:02 +01:00
|
|
|
|
2022-12-28 16:40:28 +01:00
|
|
|
use clap::Parser;
|
|
|
|
use tonic::{transport::Server, Result};
|
2022-12-28 17:17:53 +01:00
|
|
|
use tracing::{info, Level};
|
2022-12-28 16:40:28 +01:00
|
|
|
|
|
|
|
#[derive(Parser)]
|
|
|
|
#[command(author, version, about, long_about = None)]
|
|
|
|
struct Cli {
|
|
|
|
#[clap(long, short = 'l')]
|
|
|
|
listen_address: Option<String>,
|
2022-12-28 17:17:53 +01:00
|
|
|
|
|
|
|
#[clap(long)]
|
|
|
|
log_level: Option<Level>,
|
2022-12-28 16:40:28 +01:00
|
|
|
}
|
|
|
|
|
|
|
|
#[tokio::main]
|
|
|
|
async fn main() -> Result<(), Box<dyn std::error::Error>> {
|
|
|
|
let cli = Cli::parse();
|
|
|
|
let listen_address = cli
|
|
|
|
.listen_address
|
2023-01-02 12:13:45 +01:00
|
|
|
.unwrap_or_else(|| "[::]:8000".to_string())
|
2022-12-28 16:40:28 +01:00
|
|
|
.parse()
|
|
|
|
.unwrap();
|
|
|
|
|
2022-12-28 17:17:53 +01:00
|
|
|
let level = cli.log_level.unwrap_or(Level::INFO);
|
|
|
|
let subscriber = tracing_subscriber::fmt().with_max_level(level).finish();
|
|
|
|
tracing::subscriber::set_global_default(subscriber).ok();
|
|
|
|
|
2022-11-26 02:14:02 +01:00
|
|
|
let mut server = Server::builder();
|
|
|
|
|
2023-02-15 14:00:27 +01:00
|
|
|
let blob_service = SledBlobService::new("blobs.sled".into())?;
|
|
|
|
let chunk_service = SledChunkService::new("chunks.sled".into())?;
|
|
|
|
let directory_service = SledDirectoryService::new("directories.sled".into())?;
|
|
|
|
let path_info_service = SledPathInfoService::new("pathinfo.sled".into())?;
|
|
|
|
|
|
|
|
let nar_calculation_service = NonCachingNARCalculationService::new(
|
|
|
|
blob_service.clone(),
|
|
|
|
chunk_service.clone(),
|
|
|
|
directory_service.clone(),
|
|
|
|
);
|
2022-12-28 16:40:28 +01:00
|
|
|
|
2022-11-26 02:14:02 +01:00
|
|
|
let mut router = server
|
2023-02-15 14:00:27 +01:00
|
|
|
.add_service(BlobServiceServer::new(GRPCBlobServiceWrapper::new(
|
|
|
|
blob_service,
|
|
|
|
chunk_service,
|
|
|
|
)))
|
|
|
|
.add_service(DirectoryServiceServer::new(
|
|
|
|
GRPCDirectoryServiceWrapper::from(directory_service),
|
|
|
|
))
|
|
|
|
.add_service(PathInfoServiceServer::new(GRPCPathInfoServiceWrapper::new(
|
|
|
|
path_info_service,
|
|
|
|
nar_calculation_service,
|
|
|
|
)));
|
2022-11-26 02:14:02 +01:00
|
|
|
|
|
|
|
#[cfg(feature = "reflection")]
|
|
|
|
{
|
|
|
|
let reflection_svc = tonic_reflection::server::Builder::configure()
|
|
|
|
.register_encoded_file_descriptor_set(FILE_DESCRIPTOR_SET)
|
|
|
|
.build()?;
|
|
|
|
router = router.add_service(reflection_svc);
|
|
|
|
}
|
|
|
|
|
2022-12-28 17:17:53 +01:00
|
|
|
info!("tvix-store listening on {}", listen_address);
|
2022-11-26 02:14:02 +01:00
|
|
|
|
|
|
|
router.serve(listen_address).await?;
|
2022-12-28 16:40:28 +01:00
|
|
|
|
|
|
|
Ok(())
|
2022-11-11 23:48:24 +01:00
|
|
|
}
|