fixup! Add Api impl for ListForwardedPayments.

ldk-server/Cargo.toml

@@ -16,6 +16,4 @@ ldk-server-protos = { path = "../ldk-server-protos" }
 bytes = "1.4.0"
 hex = { package = "hex-conservative", version = "0.2.1", default-features = false }
 rusqlite = { version = "0.31.0", features = ["bundled"] }
-
-[dev-dependencies]
 rand = "0.8.5"

ldk-server/src/api/list_forwarded_payments.rs

@@ -3,6 +3,7 @@ use crate::io::{
 	FORWARDED_PAYMENTS_PERSISTENCE_SECONDARY_NAMESPACE,
 };
 use crate::service::Context;
+use bytes::Bytes;
 use ldk_server_protos::api::{ListForwardedPaymentsRequest, ListForwardedPaymentsResponse};
 use ldk_server_protos::types::{ForwardedPayment, PageToken};
 use prost::Message;
@@ -33,15 +34,15 @@ pub(crate) fn handle_list_forwarded_payments_request(
 				&key,
 			)
 			.map_err(|_| ldk_node::NodeError::ConnectionFailed)?;
-		let forwarded_payment = ForwardedPayment::decode(&forwarded_payment_bytes)
+		let forwarded_payment = ForwardedPayment::decode(Bytes::from(forwarded_payment_bytes))
 			.map_err(|_| ldk_node::NodeError::ConnectionFailed)?;
 		forwarded_payments.push(forwarded_payment);
 	}
 	let response = ListForwardedPaymentsResponse {
 		forwarded_payments,
 		next_page_token: list_response
 			.next_page_token
-			.map(|(token, index)| Some(PageToken { token, index })),
+			.map(|(token, index)| PageToken { token, index }),
 	};
 	Ok(response)
 }

ldk-server/src/main.rs

@@ -173,7 +173,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>);
+							let node_service = NodeService::new(Arc::clone(&node), Arc::clone(&paginated_store) as Arc<dyn PaginatedKVStore + Send + Sync>);
 							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

@@ -36,7 +36,9 @@ pub struct NodeService {
 }
 
 impl NodeService {
-	pub(crate) fn new(node: Arc<Node>, paginated_kv_store: Arc<dyn PaginatedKVStore>) -> Self {
+	pub(crate) fn new(
+		node: Arc<Node>, paginated_kv_store: Arc<dyn PaginatedKVStore + Send + Sync>,
+	) -> Self {
 		Self { context: Arc::new(Context { node, paginated_kv_store }) }
 	}
 }