rsinetd 0.2.2

A port proxy, replacement of rinetd. Because async-std use epoll rather than select, RsInetd may handle higher throughput than rinetd.
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
39
40
41

use anyhow::anyhow;
use anyhow::Result;
use std::net::IpAddr;

#[derive(Clone)]
pub struct Rule {
    pub listen: IpAddr,
    pub lport: u16,
    pub target: String,
    pub tport: u16,
}

impl Rule {
    pub fn parse() -> Result<Vec<Rule>> {
        parse_rule()
    }
}

fn parse_rule() -> Result<Vec<Rule>> {
    let conf: Vec<String> = crate::config::open_conf_file()?
        .lines()
        .map(|s| s.trim())
        .filter(|s| !s.starts_with("#") && s.len() > 0)
        .map(|s| s.into())
        .collect();
    let mut rules = vec![];
    for line in conf {
        let cols: Vec<&str> = line.split_whitespace().collect();
        if cols.len() != 4 {
            return Err(anyhow!("Syntax error in config file: {}", line));
        }
        let rule = Rule {
            listen: cols[0].parse()?,
            lport: cols[1].parse()?,
            target: cols[2].into(),
            tport: cols[3].parse()?,
        };
        rules.push(rule);
    }
    Ok(rules)
}