use crate::bindings::sockets::network::{ErrorCode, Ipv4Address, Ipv6Address};
use crate::TrappableError;
use std::future::Future;
use std::net::SocketAddr;
use std::pin::Pin;
use std::sync::Arc;
pub struct Network {
pub socket_addr_check: SocketAddrCheck,
pub allow_ip_name_lookup: bool,
}
impl Network {
pub async fn check_socket_addr(
&self,
addr: SocketAddr,
reason: SocketAddrUse,
) -> std::io::Result<()> {
self.socket_addr_check.check(addr, reason).await
}
}
#[derive(Clone)]
pub struct SocketAddrCheck(
pub(crate) Arc<
dyn Fn(SocketAddr, SocketAddrUse) -> Pin<Box<dyn Future<Output = bool> + Send + Sync>>
+ Send
+ Sync,
>,
);
impl SocketAddrCheck {
pub async fn check(&self, addr: SocketAddr, reason: SocketAddrUse) -> std::io::Result<()> {
if (self.0)(addr, reason).await {
Ok(())
} else {
Err(std::io::Error::new(
std::io::ErrorKind::PermissionDenied,
"An address was not permitted by the socket address check.",
))
}
}
}
impl Default for SocketAddrCheck {
fn default() -> Self {
Self(Arc::new(|_, _| Box::pin(async { false })))
}
}
#[derive(Clone, Copy, Debug)]
pub enum SocketAddrUse {
TcpBind,
TcpConnect,
UdpBind,
UdpConnect,
UdpOutgoingDatagram,
}
pub type SocketResult<T> = Result<T, SocketError>;
pub type SocketError = TrappableError<ErrorCode>;
impl From<wasmtime::component::ResourceTableError> for SocketError {
fn from(error: wasmtime::component::ResourceTableError) -> Self {
Self::trap(error)
}
}
impl From<std::io::Error> for SocketError {
fn from(error: std::io::Error) -> Self {
ErrorCode::from(error).into()
}
}
impl From<rustix::io::Errno> for SocketError {
fn from(error: rustix::io::Errno) -> Self {
ErrorCode::from(error).into()
}
}
#[derive(Copy, Clone)]
pub enum SocketAddressFamily {
Ipv4,
Ipv6,
}
pub(crate) fn to_ipv4_addr(addr: Ipv4Address) -> std::net::Ipv4Addr {
let (x0, x1, x2, x3) = addr;
std::net::Ipv4Addr::new(x0, x1, x2, x3)
}
pub(crate) fn from_ipv4_addr(addr: std::net::Ipv4Addr) -> Ipv4Address {
let [x0, x1, x2, x3] = addr.octets();
(x0, x1, x2, x3)
}
pub(crate) fn to_ipv6_addr(addr: Ipv6Address) -> std::net::Ipv6Addr {
let (x0, x1, x2, x3, x4, x5, x6, x7) = addr;
std::net::Ipv6Addr::new(x0, x1, x2, x3, x4, x5, x6, x7)
}
pub(crate) fn from_ipv6_addr(addr: std::net::Ipv6Addr) -> Ipv6Address {
let [x0, x1, x2, x3, x4, x5, x6, x7] = addr.segments();
(x0, x1, x2, x3, x4, x5, x6, x7)
}