actix/examples
1
0
Fork 0
mirror of https://github.com/actix/examples synced 2025-06-26 17:17:42 +02:00
Code Issues Releases Wiki Activity

chore: update db-redis redis dep

Browse Source
This commit is contained in:
Rob Ede
2024-12-28 20:25:06 +00:00
parent f6955a278a
commit 0633fd447b
5 changed files with 30 additions and 36 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
databases/redis/Cargo.toml
View File

@ -5,8 +5,7 @@ edition = "2021"
[dependencies]
actix-web.workspace = true
env_logger.workspace = true
log.workspace = true
redis = { version = "0.25", features = ["tokio-comp", "connection-manager"] }
redis = { workspace = true, features = ["tokio-comp", "connection-manager"] }
serde.workspace = true
tracing.workspace = true

26
databases/redis/src/main.rs
View File

@ -3,6 +3,20 @@ use std::io;
use actix_web::{error, middleware, web, App, HttpResponse, HttpServer, Responder};
use serde::Deserialize;
async fn get_from_cache(redis: web::Data<redis::Client>) -> actix_web::Result<impl Responder> {
let mut conn = redis
.get_connection_manager()
.await
.map_err(error::ErrorInternalServerError)?;
let res = redis::Cmd::mget(&["my_domain:one", "my_domain:two", "my_domain:three"])
.query_async::<Vec<String>>(&mut conn)
.await
.map_err(error::ErrorInternalServerError)?;
Ok(HttpResponse::Ok().json(res))
}
#[derive(Deserialize)]
pub struct CacheInfo {
one: String,
@ -24,7 +38,7 @@ async fn cache_stuff(
("my_domain:two", info.two),
("my_domain:three", info.three),
])
.query_async::<_, String>(&mut conn)
.query_async::<String>(&mut conn)
.await
.map_err(error::ErrorInternalServerError)?;
@ -43,7 +57,7 @@ async fn del_stuff(redis: web::Data<redis::Client>) -> actix_web::Result<impl Re
.map_err(error::ErrorInternalServerError)?;
let res = redis::Cmd::del(&["my_domain:one", "my_domain:two", "my_domain:three"])
.query_async::<_, usize>(&mut conn)
.query_async::<usize>(&mut conn)
.await
.map_err(error::ErrorInternalServerError)?;
@ -51,7 +65,7 @@ async fn del_stuff(redis: web::Data<redis::Client>) -> actix_web::Result<impl Re
if res == 3 {
Ok(HttpResponse::Ok().body("successfully deleted values"))
} else {
log::error!("deleted {res} keys");
tracing::error!("deleted {res} keys");
Ok(HttpResponse::InternalServerError().finish())
}
}
@ -60,19 +74,21 @@ async fn del_stuff(redis: web::Data<redis::Client>) -> actix_web::Result<impl Re
async fn main() -> io::Result<()> {
env_logger::init_from_env(env_logger::Env::new().default_filter_or("info"));
log::info!("starting HTTP server at http://localhost:8080");
tracing::info!("starting HTTP server at http://localhost:8080");
let redis = redis::Client::open("redis://127.0.0.1:6379").unwrap();
HttpServer::new(move || {
App::new()
.app_data(web::Data::new(redis.clone()))
.wrap(middleware::Logger::default())
.service(
web::resource("/stuff")
.route(web::get().to(get_from_cache))
.route(web::post().to(cache_stuff))
.route(web::delete().to(del_stuff)),
)
.wrap(middleware::NormalizePath::trim())
.wrap(middleware::Logger::default())
})
.workers(2)
.bind(("127.0.0.1", 8080))?