From 9d90a72131153d53d751505aab883047cd0645c7 Mon Sep 17 00:00:00 2001 From: Vika Date: Mon, 17 May 2021 09:21:54 +0300 Subject: Added setting store per-user --- src/database/mod.rs | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) (limited to 'src/database/mod.rs') diff --git a/src/database/mod.rs b/src/database/mod.rs index 943a1ad..98c2cae 100644 --- a/src/database/mod.rs +++ b/src/database/mod.rs @@ -160,6 +160,12 @@ pub trait Storage: Clone + Send + Sync { /// Deletes a post from the database irreversibly. 'nuff said. Must be idempotent. async fn delete_post<'a>(&self, url: &'a str) -> Result<()>; + + /// Gets a setting from the setting store and passes the result. + async fn get_setting<'a>(&self, setting: &'a str, user: &'a str) -> Result; + + /// Commits a setting to the setting store. + async fn set_setting<'a>(&self, setting: &'a str, user: &'a str, value: &'a str) -> Result<()>; } #[cfg(test)] @@ -220,6 +226,11 @@ mod tests { assert_eq!(chans[0], MicropubChannel { uid: "https://fireburn.ru/feeds/main".to_string(), name: "Main Page".to_string() }); } + async fn test_backend_settings(backend: Backend) { + backend.set_setting("site_name", "https://fireburn.ru/", "Vika's Hideout").await.unwrap(); + assert_eq!(backend.get_setting("site_name", "https://fireburn.ru/").await.unwrap(), "Vika's Hideout"); + } + #[async_std::test] async fn test_redis_storage_basic_operations() { let redis_instance = get_redis_instance().await; @@ -232,4 +243,11 @@ mod tests { let backend = super::RedisStorage::new(redis_instance.uri().to_string()).await.unwrap(); test_backend_get_channel_list(backend).await; } + + #[async_std::test] + async fn test_redis_settings() { + let redis_instance = get_redis_instance().await; + let backend = super::RedisStorage::new(redis_instance.uri().to_string()).await.unwrap(); + test_backend_settings(backend).await; + } } -- cgit 1.4.1