gorb/backend
5
0
Fork 1
Code Issues 14 Pull requests Projects Releases Packages 1 Wiki Activity Actions

fix: get cache correctly from redis
Some checks failed
ci/woodpecker/push/build-and-publish Pipeline failed
Details
ci/woodpecker/push/publish-docs Pipeline failed
Details

Browse source
This commit is contained in:
Radical 2025-07-20 20:25:15 +02:00
parent eb7e5503de
commit 8a58774359
4 changed files with 14 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

6
src/api/v1/channels/mod.rs
View file

@ -1,11 +1,13 @@
use std::sync::Arc; use std::sync::Arc;
use axum::{ use axum::{
middleware::from_fn_with_state, routing::{any, delete, get, patch}, Router Router,
middleware::from_fn_with_state,
routing::{any, delete, get, patch},
}; };
//use socketioxide::SocketIo; //use socketioxide::SocketIo;
use crate::{api::v1::auth::CurrentUser, AppState}; use crate::{AppState, api::v1::auth::CurrentUser};
mod uuid; mod uuid;

3
src/api/v1/guilds/uuid/channels.rs
View file

@ -35,8 +35,9 @@ pub async fn get(
if let Ok(cache_hit) = app_state if let Ok(cache_hit) = app_state
.get_cache_key(format!("{guild_uuid}_channels")) .get_cache_key(format!("{guild_uuid}_channels"))
.await .await
&& let Ok(channels) = serde_json::from_str::<Vec<Channel>>(&cache_hit)
{ {
return Ok((StatusCode::OK, Json(cache_hit)).into_response()); return Ok((StatusCode::OK, Json(channels)).into_response());
} }
let channels = Channel::fetch_all(&app_state.pool, guild_uuid).await?; let channels = Channel::fetch_all(&app_state.pool, guild_uuid).await?;

6
src/api/v1/guilds/uuid/roles/mod.rs
View file

@ -35,8 +35,10 @@ pub async fn get(
Member::check_membership(&mut conn, uuid, guild_uuid).await?; Member::check_membership(&mut conn, uuid, guild_uuid).await?;
if let Ok(cache_hit) = app_state.get_cache_key(format!("{guild_uuid}_roles")).await { if let Ok(cache_hit) = app_state.get_cache_key(format!("{guild_uuid}_roles")).await
return Ok((StatusCode::OK, Json(cache_hit)).into_response()); && let Ok(roles) = serde_json::from_str::<Vec<Role>>(&cache_hit)
{
return Ok((StatusCode::OK, Json(roles)).into_response());
} }
let roles = Role::fetch_all(&mut conn, guild_uuid).await?; let roles = Role::fetch_all(&mut conn, guild_uuid).await?;

6
src/api/v1/guilds/uuid/roles/uuid.rs
View file

@ -27,8 +27,10 @@ pub async fn get(
Member::check_membership(&mut conn, uuid, guild_uuid).await?; Member::check_membership(&mut conn, uuid, guild_uuid).await?;
if let Ok(cache_hit) = app_state.get_cache_key(format!("{role_uuid}")).await { if let Ok(cache_hit) = app_state.get_cache_key(format!("{role_uuid}")).await
return Ok((StatusCode::OK, Json(cache_hit)).into_response()); && let Ok(role) = serde_json::from_str::<Role>(&cache_hit)
{
return Ok((StatusCode::OK, Json(role)).into_response());
} }
let role = Role::fetch_one(&mut conn, role_uuid).await?; let role = Role::fetch_one(&mut conn, role_uuid).await?;