start persistent session storage implementation

mm2src/kdf_walletconnect/Cargo.toml

@@ -8,6 +8,7 @@ async-trait = "0.1.52"
 base64 = "0.21.2"
 chrono = { version = "0.4.23", "features" = ["serde"] }
 common = { path = "../common" }
+db_common = { path = "../db_common" }
 derive_more = "0.99"
 enum_derives = { path = "../derives/enum_derives" }
 futures = { version = "0.3", package = "futures", features = [

mm2src/kdf_walletconnect/src/lib.rs

@@ -5,6 +5,7 @@ mod inbound_message;
 mod metadata;
 #[allow(unused)] mod pairing;
 mod session;
+mod storage;
 
 use chain::{build_required_namespaces,
             cosmos::{cosmos_get_accounts_impl, CosmosAccount},

mm2src/kdf_walletconnect/src/storage/mod.rs

@@ -0,0 +1,26 @@
+use async_trait::async_trait;
+use mm2_err_handle::prelude::MmResult;
+use relay_rpc::{domain::Topic, rpc::params::session::SettleNamespaces};
+
+use crate::session::Session;
+
+pub(crate) mod sqlite;
+pub(crate) mod wasm;
+
+pub(crate) const SESSION_STORAGE_TABLE_NAME: &str = "kdf_wc_session_storage";
+
+#[derive(Debug, thiserror::Error)]
+pub(crate) enum WalletConnectStorageError {
+    #[error("Table Error: {0}")]
+    TableError(String),
+}
+
+#[async_trait]
+pub(crate) trait WalletConnectStorageOps {
+    fn init(&self) -> MmResult<(), WalletConnectStorageError>;
+    fn save_session(&self, session: &Session) -> MmResult<(), WalletConnectStorageError>;
+    fn get_all_sessions(&self) -> MmResult<Vec<Session>, WalletConnectStorageError>;
+    fn delete_session(&self, topic: &Topic) -> MmResult<(), WalletConnectStorageError>;
+    fn update_namespace(&self, topic: &Topic, namespace: SettleNamespaces) -> MmResult<(), WalletConnectStorageError>;
+    fn update_expiry(&self, expiry: u64) -> MmResult<(), WalletConnectStorageError>;
+}

mm2src/kdf_walletconnect/src/storage/sqlite.rs

@@ -0,0 +1,10 @@
+use db_common::sqlite::validate_table_name;
+use mm2_err_handle::prelude::MmResult;
+
+use super::{WalletConnectStorageError, SESSION_STORAGE_TABLE_NAME};
+
+fn validate_sql_table_name() -> MmResult<String, WalletConnectStorageError> {
+    validate_table_name(SESSION_STORAGE_TABLE_NAME)
+        .map_err(|err| WalletConnectStorageError::TableError(err.to_string()))?;
+    Ok(SESSION_STORAGE_TABLE_NAME.to_owned())
+}