portls 0.3.0

Modern cross-platform port inspector - ls for network ports
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
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103

pub mod proc_fd;
pub mod proc_parser;

use std::fs;
use std::net::IpAddr;

use anyhow::Result;

use crate::types::{PortInfo, Protocol};
use proc_fd::build_inode_to_process_map;
use proc_parser::{parse_proc_net_file, RawSocket, SocketState};

#[derive(Clone, Copy)]
enum FilterMode {
    Listening,
    Established,
    All,
}

pub fn get_listening_ports() -> Result<Vec<PortInfo>> {
    get_ports(FilterMode::Listening)
}

pub fn get_all_connections() -> Result<Vec<PortInfo>> {
    get_ports(FilterMode::All)
}

pub fn get_established_connections() -> Result<Vec<PortInfo>> {
    get_ports(FilterMode::Established)
}

fn is_remote_zero(socket: &RawSocket) -> bool {
    socket.remote_port == 0
        && match socket.remote_addr {
            IpAddr::V4(addr) => addr.is_unspecified(),
            IpAddr::V6(addr) => addr.is_unspecified(),
        }
}

fn should_include(socket: &RawSocket, mode: FilterMode, is_udp: bool) -> bool {
    match mode {
        FilterMode::All => true,
        FilterMode::Listening => {
            if is_udp {
                is_remote_zero(socket)
            } else {
                socket.state == SocketState::Listen
            }
        }
        FilterMode::Established => {
            if is_udp {
                !is_remote_zero(socket)
            } else {
                socket.state == SocketState::Established
            }
        }
    }
}

fn get_ports(mode: FilterMode) -> Result<Vec<PortInfo>> {
    let inode_map = build_inode_to_process_map()?;
    let mut ports = Vec::new();

    for (path, protocol) in [
        ("/proc/net/tcp", Protocol::Tcp),
        ("/proc/net/tcp6", Protocol::Tcp),
        ("/proc/net/udp", Protocol::Udp),
        ("/proc/net/udp6", Protocol::Udp),
    ] {
        let is_udp = protocol == Protocol::Udp;

        if let Ok(content) = fs::read_to_string(path) {
            let sockets = parse_proc_net_file(&content);

            for socket in sockets {
                if !should_include(&socket, mode, is_udp) {
                    continue;
                }

                if let Some(process_info) = inode_map.get(&socket.inode) {
                    let remote = if is_remote_zero(&socket) {
                        None
                    } else {
                        Some(format!("{}:{}", socket.remote_addr, socket.remote_port))
                    };

                    ports.push(PortInfo {
                        port: socket.local_port,
                        protocol,
                        pid: process_info.pid,
                        process_name: process_info.name.clone(),
                        address: format!("{}:{}", socket.local_addr, socket.local_port),
                        remote_address: remote,
                        container: None,
                        service_name: None,
                    });
                }
            }
        }
    }

    Ok(ports)
}