Refactor persistance related IO to separate module.

Author: G8XSU

ldk-server/src/api/list_forwarded_payments.rs

@@ -1,6 +1,6 @@
 use crate::api::error::LdkServerError;
 use crate::api::error::LdkServerErrorCode::InternalServerError;
-use crate::io::{
+use crate::io::persist::{
 	FORWARDED_PAYMENTS_PERSISTENCE_PRIMARY_NAMESPACE,
 	FORWARDED_PAYMENTS_PERSISTENCE_SECONDARY_NAMESPACE,
 };

ldk-server/src/api/list_payments.rs

@@ -1,6 +1,8 @@
 use crate::api::error::LdkServerError;
 use crate::api::error::LdkServerErrorCode::InternalServerError;
-use crate::io::{PAYMENTS_PERSISTENCE_PRIMARY_NAMESPACE, PAYMENTS_PERSISTENCE_SECONDARY_NAMESPACE};
+use crate::io::persist::{
+	PAYMENTS_PERSISTENCE_PRIMARY_NAMESPACE, PAYMENTS_PERSISTENCE_SECONDARY_NAMESPACE,
+};
 use crate::service::Context;
 use bytes::Bytes;
 use ldk_server_protos::api::{ListPaymentsRequest, ListPaymentsResponse};

ldk-server/src/io/mod.rs

@@ -1,11 +1,2 @@
-pub(crate) mod paginated_kv_store;
-pub(crate) mod sqlite_store;
+pub(crate) mod persist;
 pub(crate) mod utils;
-
-/// The forwarded payments will be persisted under this prefix.
-pub(crate) const FORWARDED_PAYMENTS_PERSISTENCE_PRIMARY_NAMESPACE: &str = "forwarded_payments";
-pub(crate) const FORWARDED_PAYMENTS_PERSISTENCE_SECONDARY_NAMESPACE: &str = "";
-
-/// The payments will be persisted under this prefix.
-pub(crate) const PAYMENTS_PERSISTENCE_PRIMARY_NAMESPACE: &str = "payments";
-pub(crate) const PAYMENTS_PERSISTENCE_SECONDARY_NAMESPACE: &str = "";

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

@@ -0,0 +1,10 @@
+pub(crate) mod paginated_kv_store;
+pub(crate) mod sqlite_store;
+
+/// The forwarded payments will be persisted under this prefix.
+pub(crate) const FORWARDED_PAYMENTS_PERSISTENCE_PRIMARY_NAMESPACE: &str = "forwarded_payments";
+pub(crate) const FORWARDED_PAYMENTS_PERSISTENCE_SECONDARY_NAMESPACE: &str = "";
+
+/// The payments will be persisted under this prefix.
+pub(crate) const PAYMENTS_PERSISTENCE_PRIMARY_NAMESPACE: &str = "payments";
+pub(crate) const PAYMENTS_PERSISTENCE_SECONDARY_NAMESPACE: &str = "";

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

@@ -1,4 +1,4 @@
-use crate::io::paginated_kv_store::{ListResponse, PaginatedKVStore};
+use crate::io::persist::paginated_kv_store::{ListResponse, PaginatedKVStore};
 use crate::io::utils::check_namespace_key_validity;
 use ldk_node::lightning::types::string::PrintableString;
 use rusqlite::{named_params, Connection};

ldk-server/src/io/sqlite_store/mod.rs renamed to ldk-server/src/io/persist/sqlite_store/mod.rs

@@ -13,9 +13,9 @@ use tokio::signal::unix::SignalKind;
 use hyper::server::conn::http1;
 use hyper_util::rt::TokioIo;
 
-use crate::io::paginated_kv_store::PaginatedKVStore;
-use crate::io::sqlite_store::SqliteStore;
-use crate::io::{
+use crate::io::persist::paginated_kv_store::PaginatedKVStore;
+use crate::io::persist::sqlite_store::SqliteStore;
+use crate::io::persist::{
 	FORWARDED_PAYMENTS_PERSISTENCE_PRIMARY_NAMESPACE,
 	FORWARDED_PAYMENTS_PERSISTENCE_SECONDARY_NAMESPACE, PAYMENTS_PERSISTENCE_PRIMARY_NAMESPACE,
 	PAYMENTS_PERSISTENCE_SECONDARY_NAMESPACE,

ldk-server/src/main.rs

@@ -30,7 +30,7 @@ use crate::api::open_channel::{handle_open_channel, OPEN_CHANNEL_PATH};
 use crate::api::update_channel_config::{
 	handle_update_channel_config_request, UPDATE_CHANNEL_CONFIG_PATH,
 };
-use crate::io::paginated_kv_store::PaginatedKVStore;
+use crate::io::persist::paginated_kv_store::PaginatedKVStore;
 use crate::util::proto_adapter::to_error_response;
 use std::future::Future;
 use std::pin::Pin;