Support for caching session store

[lmpn]

So I landed in this lovely crate after browsing into the tower-session.
I've been trying to use this crate to replicate the tower-sessions's example regarding the CachingSessionStore.
I've achieved to use the normal store which is nice however I was trying to use Redis as cache.

A snippet of what I'm trying to do:

        let deletion_task = tokio::task::spawn(
            session_store
                .clone()
                .continuously_delete_expired(tokio::time::Duration::from_secs(60)),
        );
        session_store.migrate().await?;
        let cache_session_store = RedisStore::new(cpool);
        let caching_store = CachingSessionStore::new(cache_session_store, session_store.clone());
        let session_layer = SessionManagerLayer::new(caching_store)
            .with_secure(false)
            .with_expiry(Expiry::OnInactivity(
                tower_sessions::cookie::time::Duration::days(1),
            ));
        let backend = AuthPgPool::new(self.pool.clone());
        let auth_layer = AuthManagerLayerBuilder::new(backend, session_layer).build();

The main question is: can this be done or is it not available?

Edit: I've pretty much adjust the SQLite from the examples and plugged the CachingStore

[maxcountryman]

I think we might be missing some context: is the snippet you mentioned not working?

Are you maybe asking about using a cache with the user backend separately?

[lmpn]

The snippet works but when I try to login using the auth session it blocks (on redis I suppose)

I would like to rewrite the approach mentioned in the tower-sessions example(https://docs.rs/tower-sessions/latest/tower_sessions/#layered-caching) using Axum-login

[maxcountryman]

I'm not sure if this is what you meant, but something like this seems to be working for me:

diff --git a/examples/sqlite/Cargo.toml b/examples/sqlite/Cargo.toml
index 0874b35..cc37c39 100644
--- a/examples/sqlite/Cargo.toml
+++ b/examples/sqlite/Cargo.toml
@@ -21,5 +21,6 @@ tokio = { version = "1.34.0", features = ["full"] }
 tower = "0.4.13"
 tracing-subscriber = { version = "0.3.18", features = ["env-filter"] }
 tower-sessions = { version = "0.10.0", default-features = false }
+tower-sessions-redis-store = { version = "0.10.0" }
 tower-sessions-sqlx-store = { version = "0.10.0", features = ["sqlite"] }
 thiserror = "1.0.56"
diff --git a/examples/sqlite/src/web/app.rs b/examples/sqlite/src/web/app.rs
index 9421fcf..698ab7b 100644
--- a/examples/sqlite/src/web/app.rs
+++ b/examples/sqlite/src/web/app.rs
@@ -7,6 +7,11 @@ use axum_messages::MessagesManagerLayer;
 use sqlx::SqlitePool;
 use time::Duration;
 use tokio::{signal, task::AbortHandle};
+use tower_sessions::CachingSessionStore;
+use tower_sessions_redis_store::{
+    fred::{clients::RedisPool, interfaces::ClientLike, types::RedisConfig},
+    RedisStore,
+};
 use tower_sessions_sqlx_store::SqliteStore;
 
 use crate::{
@@ -31,16 +36,24 @@ impl App {
         //
         // This uses `tower-sessions` to establish a layer that will provide the session
         // as a request extension.
-        let session_store = SqliteStore::new(self.db.clone());
-        session_store.migrate().await?;
+        let sqlite_store = SqliteStore::new(self.db.clone());
+        sqlite_store.migrate().await?;
 
         let deletion_task = tokio::task::spawn(
-            session_store
+            sqlite_store
                 .clone()
                 .continuously_delete_expired(tokio::time::Duration::from_secs(60)),
         );
 
-        let session_layer = SessionManagerLayer::new(session_store)
+        let pool = RedisPool::new(RedisConfig::default(), None, None, None, 6)?;
+
+        let redis_conn = pool.connect();
+        pool.wait_for_connect().await?;
+        let redis_store = RedisStore::new(pool);
+
+        let caching_store = CachingSessionStore::new(redis_store, sqlite_store);
+
+        let session_layer = SessionManagerLayer::new(caching_store)
             .with_secure(false)
             .with_expiry(Expiry::OnInactivity(Duration::days(1)));
 
@@ -66,6 +79,9 @@ impl App {
 
         deletion_task.await??;
 
+        // TODO: Pass through graceful shutdown.
+        redis_conn.await??;
+
         Ok(())
     }
 }

[lmpn]

I'm sorry if I wasn't clear.
My issue was that I forgot to call RedisPool::connect 😳
After add that connect my code worked as I expected!
Thank you for answering!!

[maxcountryman]

Glad we could figure it out.