feat: Use async connect to redis

1 files changed, 8 insertions, 6 deletions

diff --git a/src/main.rs b/src/main.rs
index 9e03850..1925d1e 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -33,7 +33,7 @@ use serde::{Serialize};
 use handlebars::Handlebars;
 use sqlx::Connection;
 use crate::datastructures::{Config, FormData};
-use redis::Commands;
+use redis::AsyncCommands;
 
 const COOKIE_LENGTH: usize = 45;
 
@@ -105,8 +105,9 @@ async fn cmd_authenticate_cookie(
         return Ok(false)
     }
 
-    // TODO: use async connection to redis
-    let mut conn = redis::Client::open("redis://127.0.0.1/")?;
+    let redis_conn = redis::Client::open("redis://127.0.0.1/")?;
+    let mut conn = redis_conn.get_async_connection().await?;
+
 
     for cookie in cookies.split(';').map(|x| x.trim()) {
         let (key, value) = cookie.split_once('=').unwrap();
@@ -126,7 +127,7 @@ async fn cmd_authenticate_cookie(
                 break
             }
 
-            if let Ok(r) = conn.get::<_, String>(format!("cgit_auth_{}", key)) {
+            if let Ok(r) = conn.get::<_, String>(format!("cgit_auth_{}", key)).await {
                 if r == value {
                     return Ok(true)
                 }
@@ -174,8 +175,9 @@ async fn cmd_authenticate_post(
         let value = rand_str(COOKIE_LENGTH);
 
         // TODO: same here
-        let mut conn = redis::Client::open("redis://127.0.0.1/")?;
-        conn.set_ex::<_, _, i32>(format!("cgit_auth_{}", key), &value, cfg.cookie_ttl as usize)?;
+        let redis_conn = redis::Client::open("redis://127.0.0.1/")?;
+        let mut conn = redis_conn.get_async_connection().await?;
+        conn.set_ex::<_, _, i32>(format!("cgit_auth_{}", key), &value, cfg.cookie_ttl as usize).await?;
 
         let cookie_value = base64::encode(format!("{};{}", key, value));