Class: LinuxPorts

Inherits:

PortsInfo

• Object
• PortsInfo
• LinuxPorts

Defined in:

lib/resources/port.rb

Overview

extract port information from netstat

Instance Attribute Summary

Attributes inherited from PortsInfo

#inspec

Instance Method Summary

• #info ⇒ Object
• #parse_net_address(net_addr, protocol) ⇒ Object
• #parse_netstat_line(line) ⇒ Object

Methods inherited from PortsInfo

#initialize

Constructor Details

This class inherits a constructor from PortsInfo

Instance Method Details

#info ⇒ Object

# File 'lib/resources/port.rb', line 174

def info
  cmd = inspec.command('netstat -tulpen')
  return nil if cmd.exit_status.to_i != 0

  ports = []
  # parse all lines
  cmd.stdout.each_line do |line|
    port_info = parse_netstat_line(line)

    # only push protocols we are interested in
    next unless %w{tcp tcp6 udp udp6}.include?(port_info[:protocol])
    ports.push(port_info)
  end
  ports
end

#parse_net_address(net_addr, protocol) ⇒ Object

# File 'lib/resources/port.rb', line 190

def parse_net_address(net_addr, protocol)
  if protocol.eql?('tcp6') || protocol.eql?('udp6')
    # prep for URI parsing, parse ip6 port
    ip6 = /^(\S+):(\d+)$/.match(net_addr)
    ip6addr = ip6[1]
    ip6addr = '::' if /^:::$/.match(ip6addr)
    # build uri
    ip_addr = URI("addr://[#{ip6addr}]:#{ip6[2]}")
    # replace []
    host = ip_addr.host[1..ip_addr.host.size-2]
    port = ip_addr.port
  else
    ip_addr = URI('addr://'+net_addr)
    host = ip_addr.host
    port = ip_addr.port
  end
  [host, port]
rescue URI::InvalidURIError => e
  warn "Could not parse #{net_addr}, #{e}"
  nil
end

#parse_netstat_line(line) ⇒ Object

# File 'lib/resources/port.rb', line 212

def parse_netstat_line(line)
  # parse each line
  # 1 - Proto, 2 - Recv-Q, 3 - Send-Q, 4 - Local Address, 5 - Foreign Address, 6 - State, 7 - Inode, 8 - PID/Program name
  parsed = /^(\S+)\s+(\S+)\s+(\S+)\s+(\S+)\s+(\S+)\s+(\S+)\s+(\S+)\s+(\S+)\s+(\S+)/.match(line)

  return {} if parsed.nil? || line.match(/^proto/i)

  # parse ip4 and ip6 addresses
  protocol = parsed[1].downcase

  # detect protocol if not provided
  protocol += '6' if parsed[4].count(':') > 1 && %w{tcp udp}.include?(protocol)

  # extract host and port information
  host, port = parse_net_address(parsed[4], protocol)

  # extract PID
  process = parsed[9].split('/')
  pid = process[0]
  pid = pid.to_i if /^\d+$/.match(pid)
  process = process[1]

  # map data
  {
    port: port,
    address: host,
    protocol: protocol,
    process: process,
    pid: pid,
  }
end