10

我的客户通过标头中的令牌进行授权Authorization，每个请求都需要检查该令牌。如果此标头丢失或找不到对应的用户，我想返回 HTTP 代码Unauthorized，否则我想正常处理请求。

目前我有很多重复的代码，因为我在每个请求处理程序中检查这个标头。actix 文档在第一段中建议可以halt request processing to return a response early. 如何做到这一点？

由于我还没有找到实现此行为的示例，因此我尝试提出自己的中间件函数，但无法编译。

我已经将返回值装箱以克服返回两种不同类型 (ServiceResponse和Map) 的问题，所以在如何有条件地返回不同类型的期货？不是问题。更重要的是，我不知道哪些类型的 trait 实现需要作为该wrap_fn函数的返回值。我现在拥有的那些不起作用。

App::new()
    .wrap(Cors::new().allowed_origin("http://localhost:8080"))
    .register_data(state.clone())
    .service(
        web::scope("/routing")
            .wrap_fn(|req, srv| {
                let unauth: Box<dyn IntoFuture<Item = ServiceResponse>> = Box::new(ServiceResponse::new(req.into_parts().0, HttpResponse::Unauthorized().finish()));
                let auth_header = req.headers().get("Authorization");
                match auth_header {
                    None => unauth,
                    Some(value) => {
                        let token = value.to_str().unwrap();
                        let mut users = state.users.lock().unwrap();
                        let user_state = users.iter_mut().find(|x| x.auth.token == token);
                        match user_state {
                            None => unauth,
                            Some(user) => {
                                Box::new(srv.call(req).map(|res| res))
                            }
                        }
                    }
                }
            })
            .route("/closest", web::get().to(routing::find_closest))
            .route("/fsp", web::post().to(routing::fsp))
            .route("/preference", web::get().to(routing::get_preference))
            .route("/preference", web::post().to(routing::set_preference))
            .route("/find_preference", web::post().to(routing::find_preference))
            .route("/reset", web::post().to(routing::reset_data)),
    )
    .bind("0.0.0.0:8000")
    .expect("Can not bind to port 8000")
    .run()
    .expect("Could not start sever");

我在编译时遇到了两个错误。

1.

error[E0191]: the value of the associated types `Future` (from the trait `futures::future::IntoFuture`), `Error` (from the trait `futures::future::IntoFuture`) must be specified
  --> src/server/mod.rs:36:41
   |
36 |                         let unauth: Box<dyn IntoFuture<Item = ServiceResponse>> =
   |                                         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
   |                                         |
   |                                         associated type `Future` must be specified
   |                                         associated type `Error` must be specified

2.

error[E0277]: the trait bound `dyn futures::future::IntoFuture<Item = actix_web::service::ServiceResponse>: futures::future::Future` is not satisfied
  --> src/server/mod.rs:35:22
   |
35 |                     .wrap_fn(|req, srv| {
   |                      ^^^^^^^ the trait `futures::future::Future` is not implemented for `dyn futures::future::IntoFuture<Item = actix_web::service::ServiceResponse>`
   |
   = note: required because of the requirements on the impl of `futures::future::Future` for `std::boxed::Box<dyn futures::future::IntoFuture<Item = actix_web::service::ServiceResponse>>`
4

2 回答 2

12

您可以创建自己的类型，为它Authorized实现并在应检查授权的处理程序中FromRequest定义为参数。Authorized

简化示例：

use actix_web::dev::Payload;
use actix_web::error::ErrorUnauthorized;
use actix_web::{web, App, Error, FromRequest, HttpRequest, HttpResponse, HttpServer};

fn main() {
    HttpServer::new(move || App::new().route("/", web::to(index)))
        .bind("127.0.0.1:3000")
        .expect("Can not bind to '127.0.0.1:3000'")
        .run()
        .unwrap();
}

fn index(_: Authorized) -> HttpResponse {
    HttpResponse::Ok().body("authorized")
}

struct Authorized;

impl FromRequest for Authorized {
    type Error = Error;
    type Future = Result<Self, Error>;
    type Config = ();

    fn from_request(req: &HttpRequest, _: &mut Payload) -> Self::Future {
        if is_authorized(req) {
            Ok(Authorized)
        } else {
            Err(ErrorUnauthorized("not authorized"))?
        }
    }
}

fn is_authorized(req: &HttpRequest) -> bool {
    if let Some(value) = req.headers().get("authorized") {
        // actual implementation that checks header here
        dbg!(value);
        true
    } else {
        false
    }
}

此代码产生：

$ curl localhost:3000
not authorized⏎
$ curl localhost:3000 -H 'Authorized: i am root'
authorized⏎

你可能可以用中间件做同样的事情，但我还没有理解中间件抽象。此外，您可能希望向处理程序提供有用的信息，例如用户名：

struct Authorized {
    username: String
}
于 2019-09-23T21:08:17.653 回答
3

我参加聚会有点晚了，但从 Actix 中间件中做到这一点的最佳方法是使用futures::future::Either. 你可以在这里看到它是如何使用的：https ://github.com/actix/examples/blob/master/middleware/src/redirect.rs 。

的左侧Either将是一个 Future，它将响应传递到链中的下一个阶段。HttpResponse如果您希望尽早返回响应，右侧将是响应（通常是）。

于 2020-11-07T18:08:05.287 回答