//! Essentials helper functions and types for application registration. use actix_http::http::Method; use futures::Future; pub use actix_http::Response as HttpResponse; pub use bytes::{Bytes, BytesMut}; pub use futures::channel::oneshot::Canceled; use crate::error::Error; use crate::extract::FromRequest; use crate::handler::{AsyncFactory, Factory}; use crate::resource::Resource; use crate::responder::Responder; use crate::route::Route; use crate::scope::Scope; use crate::service::WebService; pub use crate::config::ServiceConfig; pub use crate::data::Data; pub use crate::request::HttpRequest; pub use crate::types::*; /// Create resource for a specific path. /// /// Resources may have variable path segments. For example, a /// resource with the path `/a/{name}/c` would match all incoming /// requests with paths such as `/a/b/c`, `/a/1/c`, or `/a/etc/c`. /// /// A variable segment is specified in the form `{identifier}`, /// where the identifier can be used later in a request handler to /// access the matched value for that segment. This is done by /// looking up the identifier in the `Params` object returned by /// `HttpRequest.match_info()` method. /// /// By default, each segment matches the regular expression `[^{}/]+`. /// /// You can also specify a custom regex in the form `{identifier:regex}`: /// /// For instance, to route `GET`-requests on any route matching /// `/users/{userid}/{friend}` and store `userid` and `friend` in /// the exposed `Params` object: /// /// ```rust /// # extern crate actix_web; /// use actix_web::{web, App, HttpResponse}; /// /// fn main() { /// let app = App::new().service( /// web::resource("/users/{userid}/{friend}") /// .route(web::get().to(|| HttpResponse::Ok())) /// .route(web::head().to(|| HttpResponse::MethodNotAllowed())) /// ); /// } /// ``` pub fn resource(path: &str) -> Resource { Resource::new(path) } /// Configure scope for common root path. /// /// Scopes collect multiple paths under a common path prefix. /// Scope path can contain variable path segments as resources. /// /// ```rust /// use actix_web::{web, App, HttpResponse}; /// /// fn main() { /// let app = App::new().service( /// web::scope("/{project_id}") /// .service(web::resource("/path1").to(|| HttpResponse::Ok())) /// .service(web::resource("/path2").to(|| HttpResponse::Ok())) /// .service(web::resource("/path3").to(|| HttpResponse::MethodNotAllowed())) /// ); /// } /// ``` /// /// In the above example, three routes get added: /// * /{project_id}/path1 /// * /{project_id}/path2 /// * /{project_id}/path3 /// pub fn scope(path: &str) -> Scope { Scope::new(path) } /// Create *route* without configuration. pub fn route() -> Route { Route::new() } /// Create *route* with `GET` method guard. /// /// ```rust /// use actix_web::{web, App, HttpResponse}; /// /// fn main() { /// let app = App::new().service( /// web::resource("/{project_id}") /// .route(web::get().to(|| HttpResponse::Ok())) /// ); /// } /// ``` /// /// In the above example, one `GET` route get added: /// * /{project_id} /// pub fn get() -> Route { method(Method::GET) } /// Create *route* with `POST` method guard. /// /// ```rust /// use actix_web::{web, App, HttpResponse}; /// /// fn main() { /// let app = App::new().service( /// web::resource("/{project_id}") /// .route(web::post().to(|| HttpResponse::Ok())) /// ); /// } /// ``` /// /// In the above example, one `POST` route get added: /// * /{project_id} /// pub fn post() -> Route { method(Method::POST) } /// Create *route* with `PUT` method guard. /// /// ```rust /// use actix_web::{web, App, HttpResponse}; /// /// fn main() { /// let app = App::new().service( /// web::resource("/{project_id}") /// .route(web::put().to(|| HttpResponse::Ok())) /// ); /// } /// ``` /// /// In the above example, one `PUT` route get added: /// * /{project_id} /// pub fn put() -> Route { method(Method::PUT) } /// Create *route* with `PATCH` method guard. /// /// ```rust /// use actix_web::{web, App, HttpResponse}; /// /// fn main() { /// let app = App::new().service( /// web::resource("/{project_id}") /// .route(web::patch().to(|| HttpResponse::Ok())) /// ); /// } /// ``` /// /// In the above example, one `PATCH` route get added: /// * /{project_id} /// pub fn patch() -> Route { method(Method::PATCH) } /// Create *route* with `DELETE` method guard. /// /// ```rust /// use actix_web::{web, App, HttpResponse}; /// /// fn main() { /// let app = App::new().service( /// web::resource("/{project_id}") /// .route(web::delete().to(|| HttpResponse::Ok())) /// ); /// } /// ``` /// /// In the above example, one `DELETE` route get added: /// * /{project_id} /// pub fn delete() -> Route { method(Method::DELETE) } /// Create *route* with `HEAD` method guard. /// /// ```rust /// use actix_web::{web, App, HttpResponse}; /// /// fn main() { /// let app = App::new().service( /// web::resource("/{project_id}") /// .route(web::head().to(|| HttpResponse::Ok())) /// ); /// } /// ``` /// /// In the above example, one `HEAD` route get added: /// * /{project_id} /// pub fn head() -> Route { method(Method::HEAD) } /// Create *route* and add method guard. /// /// ```rust /// use actix_web::{web, http, App, HttpResponse}; /// /// fn main() { /// let app = App::new().service( /// web::resource("/{project_id}") /// .route(web::method(http::Method::GET).to(|| HttpResponse::Ok())) /// ); /// } /// ``` /// /// In the above example, one `GET` route get added: /// * /{project_id} /// pub fn method(method: Method) -> Route { Route::new().method(method) } /// Create a new route and add handler. /// /// ```rust /// use actix_web::{web, App, HttpResponse}; /// /// fn index() -> HttpResponse { /// unimplemented!() /// } /// /// App::new().service( /// web::resource("/").route( /// web::to(index)) /// ); /// ``` pub fn to(handler: F) -> Route where F: Factory + 'static, I: FromRequest + 'static, R: Responder + 'static, { Route::new().to(handler) } /// Create a new route and add async handler. /// /// ```rust /// use actix_web::{web, App, HttpResponse, Error}; /// /// async fn index() -> Result { /// Ok(HttpResponse::Ok().finish()) /// } /// /// App::new().service(web::resource("/").route( /// web::to_async(index)) /// ); /// ``` pub fn to_async(handler: F) -> Route where F: AsyncFactory, I: FromRequest + 'static, R: Future + 'static, U: Responder + 'static, { Route::new().to_async(handler) } /// Create raw service for a specific path. /// /// ```rust /// use actix_web::{dev, web, guard, App, Error, HttpResponse}; /// /// async fn my_service(req: dev::ServiceRequest) -> Result { /// Ok(req.into_response(HttpResponse::Ok().finish())) /// } /// /// fn main() { /// let app = App::new().service( /// web::service("/users/*") /// .guard(guard::Header("content-type", "text/plain")) /// .finish(my_service) /// ); /// } /// ``` pub fn service(path: &str) -> WebService { WebService::new(path) } /// Execute blocking function on a thread pool, returns future that resolves /// to result of the function execution. pub fn block(f: F) -> impl Future> where F: FnOnce() -> R + Send + 'static, R: Send + 'static, { actix_threadpool::run(f) }