enderpearl 0.1.10

Async proxy for Minecraft and HTTP traffic with automated server wake-up.
Documentation 
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

use crate::EnderError;
use crate::core::{routes, types::EnderConfig};
use crate::errors::Result;
use refractium::Refractium;
use std::convert;
use std::net::SocketAddr;

pub struct EnderRouter {
    inner: Refractium,
}

impl EnderRouter {
    /// Creates a new `EnderRouter` from the given configuration.
    ///
    /// # Errors
    ///
    /// Returns an error if route mapping fails or the `Refractium` engine cannot be built.
    pub fn new(config: &EnderConfig) -> Result<Self> {
        let (tcp_routes, udp_routes) = routes::map_to_refractium(config)?;

        let inner = Refractium::builder()
            .routes(tcp_routes, udp_routes)
            .peek_config(config.peek_buffer_size, config.peek_timeout_ms)
            .build()
            .map_err(EnderError::Refractium)?;

        Ok(Self { inner })
    }

    /// Starts the proxy on the given address (TCP + UDP).
    ///
    /// # Errors
    ///
    /// Returns an error if the server cannot bind or encounters a fatal runtime error.
    pub async fn serve(self, addr: SocketAddr) -> Result<()> {
        self.inner.run_both(addr).await.map_err(convert::Into::into)
    }
}