Struct reth_rpc_layer::AuthLayer

pub struct AuthLayer<V> { /* private fields */ }

This is an Http middleware layer that acts as an interceptor for Authorization headers. Incoming requests are dispatched to an inner AuthValidator. Invalid requests are blocked and the validator’s error response is returned. Valid requests are instead dispatched to the next layer along the chain.

How to integrate

async fn build_layered_rpc_server() {
    use jsonrpsee::server::ServerBuilder;
    use reth_rpc_layer::{AuthLayer, JwtAuthValidator, JwtSecret};
    use std::net::SocketAddr;

    const AUTH_PORT: u32 = 8551;
    const AUTH_ADDR: &str = "0.0.0.0";
    const AUTH_SECRET: &str =
        "f79ae8046bc11c9927afe911db7143c51a806c4a537cc08e0d37140b0192f430";

    let addr = format!("{AUTH_ADDR}:{AUTH_PORT}");
    let secret = JwtSecret::from_hex(AUTH_SECRET).unwrap();
    let validator = JwtAuthValidator::new(secret);
    let layer = AuthLayer::new(validator);
    let middleware = tower::ServiceBuilder::default().layer(layer);

    let _server = ServerBuilder::default()
        .set_http_middleware(middleware)
        .build(addr.parse::<SocketAddr>().unwrap())
        .await
        .unwrap();
}

Implementations

impl<V> AuthLayer<V>

pub const fn new(validator: V) -> Self

Creates an instance of AuthLayer. validator is a generic trait able to validate requests (see AuthValidator).

Trait Implementations

impl<S, V> Layer<S> for AuthLayer<V>

where V: Clone,

type Service = AuthService<S, V>

The wrapped service

fn layer(&self, inner: S) -> Self::Service

Wrap the given service with the middleware, returning a new service that has been decorated with the middleware.

Layout

Note: Unable to compute type layout, possibly due to this type having generic parameters. Layout can only be computed for concrete, fully-instantiated types.