Add Send+Sync trait bounds for PaginatedKVStore.

Author: G8XSU

ldk-server/src/io/persist/paginated_kv_store.rs

@@ -26,7 +26,7 @@ use std::io;
 /// [`KVStore`]: ldk_node::lightning::util::persist::KVStore
 /// [`KVSTORE_NAMESPACE_KEY_ALPHABET`]: ldk_node::lightning::util::persist::KVSTORE_NAMESPACE_KEY_ALPHABET
 /// [`KVSTORE_NAMESPACE_KEY_MAX_LEN`]: ldk_node::lightning::util::persist::KVSTORE_NAMESPACE_KEY_MAX_LEN
-pub trait PaginatedKVStore {
+pub trait PaginatedKVStore: Send + Sync {
 	/// Returns the data stored for the given `primary_namespace`, `secondary_namespace`, and `key`.
 	///
 	/// Returns an [`ErrorKind::NotFound`] if the given `key` could not be found in the given

ldk-server/src/main.rs

@@ -92,7 +92,7 @@ fn main() {
 		},
 	};
 
-	let paginated_store =
+	let paginated_store: Arc<dyn PaginatedKVStore> =
 		Arc::new(match SqliteStore::new(PathBuf::from(config_file.storage_dir_path), None, None) {
 			Ok(store) => store,
 			Err(e) => {
@@ -240,7 +240,7 @@ fn main() {
 					match res {
 						Ok((stream, _)) => {
 							let io_stream = TokioIo::new(stream);
-							let node_service = NodeService::new(Arc::clone(&node), Arc::clone(&paginated_store) as Arc<dyn PaginatedKVStore + Send + Sync>);
+							let node_service = NodeService::new(Arc::clone(&node), Arc::clone(&paginated_store));
 							runtime.spawn(async move {
 								if let Err(err) = http1::Builder::new().serve_connection(io_stream, node_service).await {
 									eprintln!("Failed to serve connection: {}", err);

ldk-server/src/service.rs

@@ -39,20 +39,18 @@ use std::sync::Arc;
 #[derive(Clone)]
 pub struct NodeService {
 	node: Arc<Node>,
-	paginated_kv_store: Arc<dyn PaginatedKVStore + Send + Sync>,
+	paginated_kv_store: Arc<dyn PaginatedKVStore>,
 }
 
 impl NodeService {
-	pub(crate) fn new(
-		node: Arc<Node>, paginated_kv_store: Arc<dyn PaginatedKVStore + Send + Sync>,
-	) -> Self {
+	pub(crate) fn new(node: Arc<Node>, paginated_kv_store: Arc<dyn PaginatedKVStore>) -> Self {
 		Self { node, paginated_kv_store }
 	}
 }
 
 pub(crate) struct Context {
 	pub(crate) node: Arc<Node>,
-	pub(crate) paginated_kv_store: Arc<dyn PaginatedKVStore + Send + Sync>,
+	pub(crate) paginated_kv_store: Arc<dyn PaginatedKVStore>,
 }
 
 impl Service<Request<Incoming>> for NodeService {