Struct Server 

pub struct Server { /* private fields */ }

Implementations

impl Server

pub fn bind(addr: SocketAddr) -> Self

Examples found in repository

examples/admin_demo.rs (line 72)

async fn main() -> std::io::Result<()> {
    let db = Db::memory().await.expect("db connect");
    db.execute(
        "CREATE TABLE users (
            id INTEGER PRIMARY KEY AUTOINCREMENT,
            name TEXT NOT NULL,
            is_admin INTEGER NOT NULL
        )",
    )
    .await
    .expect("create schema");

    User {
        id: 0,
        name: "Alice".into(),
        is_admin: false,
    }
    .create(&db)
    .await
    .expect("seed alice");
    User {
        id: 0,
        name: "Bob".into(),
        is_admin: true,
    }
    .create(&db)
    .await
    .expect("seed bob");

    let router = with_defaults(Router::new()).wrap(authenticate);
    let router = admin::register::<User>(router, &db);

    let addr: SocketAddr = ([127, 0, 0, 1], 3000).into();
    eprintln!("admin demo: hit /admin/users with `Authorization: Bearer dev-admin` header");
    Server::bind(addr).serve_router(router).await
}

examples/homepage.rs (line 78)

async fn main() -> std::io::Result<()> {
    let addr: SocketAddr = ([127, 0, 0, 1], 3000).into();
    let router = with_defaults(Router::new())
        .get("/whoami", |req, _params| async move {
            let id = req
                .ctx()
                .get::<RequestId>()
                .map(|r| r.0.to_string())
                .unwrap_or_else(|| "unknown".into());
            Ok::<Response, Error>(text(format!("your request id is req-{id}\n")))
        })
        .get("/me", |req, _params| async move {
            let id = require_auth(req.ctx())?;
            Ok::<Response, Error>(text(format!("hello {}\n", id.user_id)))
        })
        .get("/admin-only", |req, _params| async move {
            let id = require_admin(req.ctx())?;
            Ok::<Response, Error>(text(format!("hello admin {}\n", id.user_id)))
        })
        .get("/crash", |_req, _params| async {
            Err::<Response, Error>(Error::Internal("simulated failure".into()))
        })
        .get("/unauth", |_req, _params| async {
            Err::<Response, Error>(Error::Unauthorized)
        })
        .wrap(request_id)
        .wrap(authenticate)
        .wrap(logger);
    Server::bind(addr).serve_router(router).await
}

pub async fn serve<F, Fut>(self, handler: F) -> Result<()>

where F: Fn(Request) -> Fut + Clone + Send + Sync + 'static, Fut: Future<Output = Response> + Send + 'static,

pub async fn serve_router(self, router: Router) -> Result<()>

Examples found in repository

examples/admin_demo.rs (line 72)

async fn main() -> std::io::Result<()> {
    let db = Db::memory().await.expect("db connect");
    db.execute(
        "CREATE TABLE users (
            id INTEGER PRIMARY KEY AUTOINCREMENT,
            name TEXT NOT NULL,
            is_admin INTEGER NOT NULL
        )",
    )
    .await
    .expect("create schema");

    User {
        id: 0,
        name: "Alice".into(),
        is_admin: false,
    }
    .create(&db)
    .await
    .expect("seed alice");
    User {
        id: 0,
        name: "Bob".into(),
        is_admin: true,
    }
    .create(&db)
    .await
    .expect("seed bob");

    let router = with_defaults(Router::new()).wrap(authenticate);
    let router = admin::register::<User>(router, &db);

    let addr: SocketAddr = ([127, 0, 0, 1], 3000).into();
    eprintln!("admin demo: hit /admin/users with `Authorization: Bearer dev-admin` header");
    Server::bind(addr).serve_router(router).await
}

examples/homepage.rs (line 78)

async fn main() -> std::io::Result<()> {
    let addr: SocketAddr = ([127, 0, 0, 1], 3000).into();
    let router = with_defaults(Router::new())
        .get("/whoami", |req, _params| async move {
            let id = req
                .ctx()
                .get::<RequestId>()
                .map(|r| r.0.to_string())
                .unwrap_or_else(|| "unknown".into());
            Ok::<Response, Error>(text(format!("your request id is req-{id}\n")))
        })
        .get("/me", |req, _params| async move {
            let id = require_auth(req.ctx())?;
            Ok::<Response, Error>(text(format!("hello {}\n", id.user_id)))
        })
        .get("/admin-only", |req, _params| async move {
            let id = require_admin(req.ctx())?;
            Ok::<Response, Error>(text(format!("hello admin {}\n", id.user_id)))
        })
        .get("/crash", |_req, _params| async {
            Err::<Response, Error>(Error::Internal("simulated failure".into()))
        })
        .get("/unauth", |_req, _params| async {
            Err::<Response, Error>(Error::Unauthorized)
        })
        .wrap(request_id)
        .wrap(authenticate)
        .wrap(logger);
    Server::bind(addr).serve_router(router).await
}