1
0
mirror of https://github.com/actix/examples synced 2025-02-25 18:42:50 +01:00

chore: fix mut warning

This commit is contained in:
Rob Ede 2025-02-24 03:10:00 +00:00
parent a5e7b63fe0
commit 9a295b310a
No known key found for this signature in database
GPG Key ID: 97C636207D3EF933
2 changed files with 18 additions and 16 deletions

View File

@ -7,6 +7,7 @@
"autoclean", "autoclean",
"autoreload", "autoreload",
"binstall", "binstall",
"casbin",
"chrono", "chrono",
"deadpool", "deadpool",
"dotenv", "dotenv",

View File

@ -1,22 +1,23 @@
use std::io; use std::io;
use actix_web::{middleware, web, App, HttpRequest, HttpResponse, HttpServer}; use actix_web::{middleware, web, App, HttpResponse, HttpServer};
use casbin::{CoreApi, DefaultModel, Enforcer, FileAdapter, RbacApi}; use casbin::{CoreApi, DefaultModel, Enforcer, FileAdapter, RbacApi};
use tokio::sync::RwLock;
/// simple handle /// simple handle
async fn success(enforcer: web::Data<RwLock<Enforcer>>, req: HttpRequest) -> HttpResponse { async fn success(enforcer: web::Data<Enforcer>) -> HttpResponse {
let mut e = enforcer.write().await; assert_eq!(
println!("{req:?}"); vec!["data2_admin"],
assert_eq!(vec!["data2_admin"], e.get_roles_for_user("alice", None)); enforcer.get_roles_for_user("alice", None)
);
HttpResponse::Ok().body("Success: alice is data2_admin.") HttpResponse::Ok().body("Success: alice is data2_admin.")
} }
async fn fail(enforcer: web::Data<RwLock<Enforcer>>, req: HttpRequest) -> HttpResponse { async fn fail(enforcer: web::Data<Enforcer>) -> HttpResponse {
let mut e = enforcer.write().await; assert_eq!(
println!("{req:?}"); vec!["data1_admin"],
assert_eq!(vec!["data1_admin"], e.get_roles_for_user("alice", None)); enforcer.get_roles_for_user("alice", None)
);
HttpResponse::Ok().body("Fail: alice is not data1_admin.") // In fact, it can't be displayed. HttpResponse::Ok().body("Fail: alice is not data1_admin.") // In fact, it can't be displayed.
} }
@ -30,18 +31,18 @@ async fn main() -> io::Result<()> {
.unwrap(); .unwrap();
let adapter = FileAdapter::new("rbac/rbac_policy.csv"); let adapter = FileAdapter::new("rbac/rbac_policy.csv");
let e = Enforcer::new(model, adapter).await.unwrap(); let enforcer = Enforcer::new(model, adapter).await.unwrap();
let e = web::Data::new(RwLock::new(e)); // wrap enforcer into actix-state let enforcer = web::Data::new(enforcer);
//move is necessary to give closure below ownership of counter // move is necessary to give closure below ownership of data
HttpServer::new(move || { HttpServer::new(move || {
App::new() App::new()
.app_data(e.clone()) // <- create app with shared state .app_data(enforcer.clone()) // <- create app with shared data
// enable logger
.wrap(middleware::Logger::default())
// register simple handler, handle all methods // register simple handler, handle all methods
.service(web::resource("/success").to(success)) .service(web::resource("/success").to(success))
.service(web::resource("/fail").to(fail)) .service(web::resource("/fail").to(fail))
// enable logger
.wrap(middleware::Logger::default())
}) })
.bind(("127.0.0.1", 8080))? .bind(("127.0.0.1", 8080))?
.run() .run()