1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143
//! # micro_http_async //! ## What is it for? //! //! A small, lightweight crate using async to serve web pages or webapis with high performance and low overhead. //! //! ## How do I use it? //! //! Firstly, install the crate and dependencies: //! //! ``` //! [dependencies] //! micro_http_async = "*" //! tokio = "1.1" //! ``` //! This crate is designed to abstract away many of the low level code required to run a safe, asynchrynous web server //! //! Here is a small example which shows how to route, use asynchrynous callbacks and load webpage templates from HTML files. //! //! For the HTML files included, please go to the [repository](https://github.com/dimitribobkov/micro-http-async/) and check the `templates` folder. //! //! Static files also included. //! //! To run the included example (which is the example seen below), run `cargo run --example hello_world`, and visit [127.0.0.1:8080](http://127.0.0.1:8080) //! //! Please note this is probably not the final API //! //! **Example** //! ``` //! /// Small example to show the functionings of the crate. Read the comments to see how everything //! /// functions //! //! use micro_http_async::HttpServer; //! use micro_http_async::Request; //! use micro_http_async::HtmlConstructor; //! use micro_http_async::Vars; //! use micro_http_async::Variable; //! use micro_http_async::Response; //! //! /// # main handler //! /// //! /// main handler is a test to test our route and function callbacks work //! /// //! /// And it does! //! /// //! /// The way it works is that we run test_handler when we recieve a connection. //! /// //! /// Then, this handler manipulates the request (for post info, or other info etc) //! /// //! /// after, we return the response as a string. It is then served to the user. //! /// //! /// The syntax is a bit weird but if it works it works. I'll try fix it :') //! /// //! /// It should return a pinned box future result that implements send //! fn main_handler(request: Request) -> std::pin::Pin<Box<dyn std::future::Future<Output = Result<String, String>> + Send>>{ //! println!("REQ: {:?}", request.raw_request); //! // We wrap the return_str as a future, so we can return it for our routing system to call await on //! // This works better than making the whole function a future, since doing that causes race errors. //! // By returning a Pinned Boxed future, we define it as a future so it works. Just looks a bit odd //! let return_future = async move { //! let mut vars = Vars::new(); //! let test_string = "This string will be outputted dynamically to the web page!".to_string(); //! //! vars.insert("test_var".to_string(), Variable::String(test_string)); //! //! // This part will check we have a get request parameter with "name" //! // If we do, we will set a dynamic variable to the key value. //! // It will show how to handle get request parameters //! if request.get_request.contains_key("name"){ //! let name = format!("Hello, {}!", request.get_request.get("name").unwrap().to_string()); //! vars.insert("name".to_string(), Variable::String(name)); //! }else{ //! vars.insert("name".to_string(), Variable::String("".to_string())); //! } //! //! //! let page = HtmlConstructor::construct_page(Response::from(200), "./templates/index.html", vars).await; //! //! Ok(page) //! }; //! //! return Box::pin(return_future); //! } //! //! //! /// We have to define a custom error handler, which defines what to do when we have a 404 //! /// //! /// Not doing this WILL result in an unrecoverable panic. //! fn error_handler(request: Request) -> std::pin::Pin<Box<dyn std::future::Future<Output = Result<String, String>> + Send>>{ //! println!("Connection error!"); //! //! println!("Get: {:?}", request.raw_request); //! let return_future = async move { //! let mut vars = Vars::new(); //! let test_string = format!("Could not load webpage at <code>127.0.0.1:8080{}</code>", request.uri); //! vars.insert("uri".to_string(), Variable::String(test_string)); //! //! let page = HtmlConstructor::construct_page(Response::ClientErr, "./templates/err.html", vars).await; //! //! Ok(page) //! }; //! //! return Box::pin(return_future); //! } //! //! /// # main //! /// //! /// Does what it says, just sets up the server and routes //! /// //! /// then listens for incoming connections //! #[tokio::main] //! pub async fn main() { //! let mut http_server = HttpServer::new("127.0.0.1", "8080").await.expect("Error binding to IP/Port"); //! //! // must be placed on heap so it can be allocated at runtime (alternative is static) //! http_server.routes.add_route("/".to_string(), Box::pin(main_handler)).await; //! http_server.routes.add_route("err".to_string(), Box::pin(error_handler)).await; //! //! http_server.listen().await; //! } //! ``` //! //! This crate aims only to simplify webapi or lightweight web creation - not intended to run full scale web apps like chatrooms //! or other high intensity applications. It implements a simple asynchrynous routing system (Made using hashmaps for speed and efficiency) //! as well as asynchrynous file loading and more. //! //! The demo above uses 0% CPU under no load, and less than 10mb of memory under usage #![doc(test(attr(deny(warnings))))] #![doc(test(no_crate_inject))] mod server; mod connection; mod routes; mod request; mod html_loader; mod response; pub use server::HttpServer; pub use connection::Connection; pub use routes::Routes; pub use request::{Request, HttpMethod}; pub use html_loader::{Variable, HtmlConstructor, FileLoader, Vars}; pub use response::Response; pub use routes::DataType;