dope-net 0.10.0

use std::io;
use std::io::{Error, ErrorKind};
use std::net::SocketAddr;
use std::path::PathBuf;

use crate::Transport;
use crate::option::SocketOption;
use dope_core::driver::DriverContext;
use dope_core::io::fd::Fd;
use dope_core::io::socket::addr::Addr;

pub mod listener {
    #[derive(Clone, Copy, Default)]
    pub struct Config;
}

pub mod stream {
    #[derive(Clone, Copy, Default)]
    pub struct Config {
        pub recv_buffer_size: Option<usize>,
        pub send_buffer_size: Option<usize>,
    }
}

pub struct Unix;

impl Transport for Unix {
    type Addr = PathBuf;
    type StreamConfig = stream::Config;
    type ListenerConfig = listener::Config;

    fn to_sock_addr(addr: &PathBuf) -> io::Result<Addr> {
        Addr::from_unix_path(addr)
    }

    fn socket_params(_addr: &PathBuf) -> (i32, i32, i32) {
        (libc::AF_UNIX, libc::SOCK_STREAM, 0)
    }

    fn bind_listener_slot<'d>(
        _driver: &mut DriverContext<'_, 'd>,
        _addr: &PathBuf,
        backlog: i32,
        _config: &listener::Config,
    ) -> io::Result<(Fd<'d>, SocketAddr)> {
        if backlog <= 0 {
            return Err(Error::new(ErrorKind::InvalidInput, "backlog must be > 0"));
        }
        Err(Error::new(
            ErrorKind::Unsupported,
            "dope: unix listener fixed-slot bootstrap not yet wired",
        ))
    }

    fn submit_stream_config(
        driver: &mut DriverContext<'_, '_>,
        config: stream::Config,
        fd: &Fd<'_>,
    ) {
        SocketOption::submit_all(
            [
                config.recv_buffer_size.map(SocketOption::RecvBuffer),
                config.send_buffer_size.map(SocketOption::SendBuffer),
            ],
            driver,
            fd,
        );
    }
}