Mark cfg(test) and fix builds.

Author: G8XSU

rust/api/src/kv_store.rs

@@ -4,8 +4,11 @@ use crate::types::{
 	ListKeyVersionsRequest, ListKeyVersionsResponse, PutObjectRequest, PutObjectResponse,
 };
 use async_trait::async_trait;
+#[cfg(test)]
 use bytes::Bytes;
+#[cfg(test)]
 use rand::distributions::Alphanumeric;
+#[cfg(test)]
 use rand::{thread_rng, Rng};
 
 pub const GLOBAL_VERSION_KEY: &str = "global_version";
@@ -74,6 +77,7 @@ macro_rules! define_kv_store_tests {
 }
 
 #[async_trait]
+#[cfg(test)]
 pub(crate) trait KvStoreTestSuite {
 	type Store: KvStore + 'static;
 
@@ -555,12 +559,14 @@ pub(crate) trait KvStoreTestSuite {
 	}
 }
 
+#[cfg(test)]
 pub struct TestContext<'a> {
 	kv_store: &'a dyn KvStore,
 	user_token: String,
 	store_id: String,
 }
 
+#[cfg(test)]
 impl<'a> TestContext<'a> {
 	pub fn new(kv_store: &'a dyn KvStore) -> Self {
 		let store_id: String = (0..7).map(|_| thread_rng().sample(Alphanumeric) as char).collect();
@@ -621,6 +627,7 @@ impl<'a> TestContext<'a> {
 	}
 }
 
+#[cfg(test)]
 fn kv(key: &str, value: &str, version: i64) -> KeyValue {
 	KeyValue { key: key.to_string(), version, value: Bytes::from(value.to_string()) }
 }

rust/server/src/main.rs

@@ -1,5 +1,3 @@
-use hyper::service::Service;
-use prost::Message;
 use std::net::SocketAddr;
 
 use tokio::net::TcpListener;
@@ -9,10 +7,9 @@ use hyper::server::conn::http1;
 use hyper_util::rt::TokioIo;
 
 use crate::vss_service::VssService;
-use api::auth::NoopAuthorizer;
+use api::auth::{Authorizer, NoopAuthorizer};
 use api::kv_store::KvStore;
 use impls::postgres_store::PostgresBackendImpl;
-use std::str::FromStr;
 use std::sync::Arc;
 
 pub(crate) mod vss_service;
@@ -51,7 +48,7 @@ fn main() {
 					match res {
 						Ok((stream, _)) => {
 							let io_stream = TokioIo::new(stream);
-							let vss_service = VssService::new(Arc::clone(&store) as Arc<dyn KvStore>,authorizer );
+							let vss_service = VssService::new(Arc::clone(&store) as Arc<dyn KvStore>, Arc::clone(&authorizer) as Arc<dyn Authorizer>);
 							runtime.spawn(async move {
 								if let Err(err) = http1::Builder::new().serve_connection(io_stream, vss_service).await {
 									eprintln!("Failed to serve connection: {}", err);