Class: Listener

Inherits:

Object

• Object
• Listener

Includes:

StreamListener

Defined in:

lib/node_db.rb

Instance Method Summary

• #init_attr ⇒ Object
• #init_service_attr ⇒ Object
• #init_snmp_attr ⇒ Object
• #init_snmptrap_attr ⇒ Object
• #init_syslog_attr ⇒ Object
• #init_wmi_attr ⇒ Object
• #tag_end(name) ⇒ Object
• #tag_start(name, attributes) ⇒ Object
• #text(text) ⇒ Object

Instance Method Details

#init_attr ⇒ Object

# File 'lib/node_db.rb', line 1906

def init_attr()
            @uuid=nil
		@ip=nil
		@ipv6=nil
		@mask=nil
		@mask6=nil
		@mac=nil
		@dns_name=nil
		@netbios_name=nil
		@status=1
		@avail_sev=UNMANAGED
		@snmp_sev=UNMANAGED
		@custom_sev=UNMANAGED
		@trap_sev=UNMANAGED
		@service_sev=UNMANAGED
		@wmi_sev=UNMANAGED
		@syslog_sev=UNMANAGED
		@jmx_sev=UNMANAGED
@x=0
		@y=0
		@icon=nil
		@description=nil
		@snmp_version=nil
		@snmp_port=nil
		@snmp_timeout=nil
		@snmp_retry=nil
		@type=nil
		@os=nil
		@map=nil
		@name=nil
		@dns_domain=nil
		@netbios_domain=nil
		@node_size=nil
		@map_bg_type=nil
		@map_bg_data=nil
		@custom_monitor=nil
		@inherit_from_global=nil
end

#init_service_attr ⇒ Object

# File 'lib/node_db.rb', line 1870

def init_service_attr()
@protocol=nil
@port=nil
@service_name=nil
@monitor=nil
@service_sev=nil
end

#init_snmp_attr ⇒ Object

# File 'lib/node_db.rb', line 1878

def init_snmp_attr()
@snmp_state=nil
@oid_ref=nil
@snmp_oper=nil
@snmp_threshold=nil
@oid_sev=nil
end

#init_snmptrap_attr ⇒ Object

# File 'lib/node_db.rb', line 1894

def init_snmptrap_attr()
@snmptrap_state=nil
@snmptrap_ref=nil
@trapsev=nil
end

#init_syslog_attr ⇒ Object

# File 'lib/node_db.rb', line 1900

def init_syslog_attr()
@syslog_state=nil
@syslog_ref=nil
@syslog_sev=nil
end

#init_wmi_attr ⇒ Object

# File 'lib/node_db.rb', line 1886

def init_wmi_attr()
@wmi_state=nil
@wmi_ref=nil
@wmi_oper=nil
@wmi_value=nil
@wmi_sev=nil
end

#tag_end(name) ⇒ Object

# File 'lib/node_db.rb', line 2201

def tag_end(name)
#      puts "End #{name}"

		if name == "Host"
			#puts @ip, @mask.to_i, @map, @mac, @dns_name, @netbios_name, @port, @status.to_i, @x.to_i, @y.to_i, @icon, @description, @type, @os
			nnode=Host.new(@ip, @mask.to_i, @ipv6, @mask6.to_i, @map, @mac, @dns_name, @netbios_name, @services, @status.to_i, @x.to_i, @y.to_i, @icon, @description, @type, @os, @uuid)
			if @name != Node::NONAME_PROPERTY
nnod.name = @name
			end
			
			nnode.set_severities(@avail_sev.to_i, @snmp_sev.to_i, @custom_sev.to_i, @trap_sev.to_i, @service_sev.to_i, @wmi_sev.to_i, @syslog_sev.to_i, @jmx_sev.to_i)
 nnode.snmp_version=@snmp_version
 nnode.snmp_port=@snmp_port
 nnode.snmp_timeout=@snmp_timeout
 nnode.snmp_retry=@snmp_retry

			nnode.reload
			$host[@ip]=nnode
			if defined?(@snmp_monitor) && (@snmp_monitor != nil)
@snmp_monitor.each do |mon,tab|
	oidref, state, oper, threshold, sev = mon, tab[0], tab[1], tab[2], tab[3]
	$host[@ip].add_snmp_monitoring(state.to_i(), oidref, oper.to_i(), threshold, sev.to_i())
end
			end

			if defined?(@wmi_monitor) && (@wmi_monitor != nil)
@wmi_monitor.each do |mon,tab|
	wmiref, state, oper, val, sev = mon, tab[0], tab[1], tab[2], tab[3]
	$host[@ip].add_wmi_monitoring(state.to_i(), wmiref, oper.to_i(), val, sev.to_i())
end
			end

			if defined?(@snmptrap_monitor) && (@snmptrap_monitor != nil)
@snmptrap_monitor.each do |mon,tab|
	snmptrap_ref, state, trapsev = mon, tab[0], tab[1]
	$host[@ip].add_snmptrap_monitoring(state.to_i(), snmptrap_ref, trapsev.to_i())
end
			end
			if defined?(@custom_monitor) && (@custom_monitor != nil)
@custom_monitor.each do |name,tab|
	state, param, sev = tab[0], tab[1], tab[2]
	$host[@ip].add_custom_monitoring(state.to_i(), name, param, sev.to_i())
end
			end      
			if defined?(@syslog_monitor) && (@syslog_monitor != nil)
@syslog_monitor.each do |ref,tab|
	state, sev = tab[0], tab[1]
	$host[@ip].add_syslog_monitoring(state.to_i(), ref, sev.to_i())
end
			end
			#we update network host list
			#we assume here networks are already loaded
			$network[@map].add_host(nnode)
			$network[@map].update_status()
			return
		end
		if name == "Network"
			#puts @ip, @mask
			#we assume here first network loaded is root network ROOTMAPADDR
			if @ip==ROOTMAPADDR && $network != nil && $network[@ip]!=nil
#we already have a root map network node
			else
 nnode=Network.new(@ip, @mask.to_i, @ipv6, @mask6.to_i, @map, @services, @status.to_i, @x.to_i, @y.to_i, @icon, @description, @type, @os, @name, @dns_domain, @netbios_domain, @uuid)
 nnode.snmp_version=@snmp_version
 nnode.snmp_port=@snmp_port
 nnode.snmp_timeout=@snmp_timeout
 nnode.snmp_retry=@snmp_retry

 if @node_size != nil && isInteger(@node_size)
  nnode.node_size=@node_size.to_i()
 end
 if @map_bg_type != ""
  nnode.map_bg_type=@map_bg_type
  nnode.map_bg_data=@map_bg_data
 end
 nnode.set_inherit_conf(i2b(@inherit_from_global))
 nnode.reload
 $network[@ip]=nnode
			end
  return
		end
		if name == "services"
			init_service_attr()
		end
		if name == "service"
			@service_name="?" unless @service_name != nil
			@monitor=1 unless @monitor != nil
			@services["#{@protocol}/#{@port}"] = Service.new(@protocol, @port, @service_name, @monitor, @service_sev) unless @services == nil
		end
		#for each snmp_monitor under block
		if name == "snmp"
			if defined?(@oid_ref) && (@oid_ref != nil)
@snmp_monitor["#{@oid_ref}"]=[@snmp_state, @snmp_oper, @snmp_threshold, @oid_sev]
			end
			init_snmp_attr()
		end
		#for each wmi_monitor under block
		if name == "wmi"
			if defined?(@wmi_ref) && (@wmi_ref != nil)
@wmi_monitor["#{@wmi_ref}"]=[@wmi_state, @wmi_oper, @wmi_value, @wmi_sev]
			end
			init_wmi_attr()
		end
		
		#for each snmptrap_monitor under block
		if name == "snmptrap"
			if defined?(@snmptrap_ref) && (@snmptrap_ref != nil)
@snmptrap_monitor["#{@snmptrap_ref}"]=[@snmptrap_state, @trapsev]
			end
			init_snmptrap_attr()
		end
		#for each syslog_monitor under block
		if name == "syslog"
			if defined?(@syslog_ref) && (@syslog_ref != nil)
@syslog_monitor["#{@syslog_ref}"]=[@syslog_state, @syslog_sev]
			end
			init_syslog_attr()
		end
end

#tag_start(name, attributes) ⇒ Object

# File 'lib/node_db.rb', line 1944

def tag_start(name, attributes)
  #puts "Start #{name}"
		#test if tag is a new node
		if name == "Host" || name == "Network"
			init_attr()
		elsif name == "services"
			@services=Hash.new
		elsif name == "service"
			init_service_attr()
		elsif name == "snmp_monitor"
			@snmp_monitor=Hash.new
		elsif name == "wmi_monitor"
			@wmi_monitor=Hash.new
		elsif name == "snmptrap_monitor"
			@snmptrap_monitor=Hash.new
		elsif name == "snmptrap"
			init_snmptrap_attr()
		elsif name == "syslog_monitor"
			@syslog_monitor=Hash.new
		elsif name == "syslog"
			init_syslog_attr()
		end
  @tag=name
end

#text(text) ⇒ Object

# File 'lib/node_db.rb', line 1968

def text(text)
	if @tag == "uuid"
		@uuid=text
		return
	end
               if @tag == "ip"
		@ip=text
		return
	end
               if @tag == "ipv6"
		@ipv6=text
		return
	end
	if @tag == "mask"
		@mask=text
		return	
	end
	if @tag == "mask6"
		@mask6=text
		return	
	end
	if @tag == "mac"
		@mac=text
		return
	end
	if @tag == "dns_name"
		@dns_name=text
		return
	end
	if @tag == "netbios_name"
		@netbios_name=text
		return
	end
	if @tag == "protocol"
		@protocol=text
		return
	end
	if @tag == "port"
		@port=text
		return
	end
	if @tag == "monitor"
		@monitor=text
		return
	end
	if @tag == "service_sev"
		@service_sev=text
		return
	end
	if @tag == "status"
		@status=text
		return
	end
	if @tag == "avail_sev"
		@avail_sev=text
		return
	end
	if @tag == "snmp_sev"
		@snmp_sev=text
		return
	end
	if @tag == "custom_sev"
		@custom_sev=text
		return
	end
	if @tag == "trap_sev"
		@trap_sev=text
		return
	end
	if @tag == "service_sev"
		@service_sev=text
		return
	end
	if @tag == "wmi_sev"
		@wmi_sev=text
		return
	end
	if @tag == "syslog_sev"
		@syslog_sev=text
		return
	end
	if @tag == "jmx_sev"
		@jmx_sev=text
		return
	end
   if @tag == "x"
		@x=text
		return
	end
	if @tag == "y"
		@y=text
		return
	end
	if @tag == "icon"
		@icon=text
		return
	end
	if @tag == "description"
		@description=text
		return
	end
	if @tag == "snmp_version"
		@snmp_version=text
		return
	end
	if @tag == "snmp_port"
		@snmp_port=text
		return
	end
	if @tag == "snmp_timeout"
		@snmp_timeout=text
		return
	end
	if @tag == "snmp_retry"
		@snmp_retry=text
		return
	end
	if @tag == "type"
		@type=text
		return
	end
	if @tag == "os"
		@os=text
		return
	end
	if @tag == "map"
		@map=text
		return
	end
	if @tag == "name"
		@name=text
		return
	end
	if @tag == "dns_domain"
		@dns_domain=text
		return
	end
	if @tag == "netbios_domain"
		@netbios_domain=text
		return
	end
	if @tag == "node_size"
		@node_size=text
		return
	end
	if @tag == "map_bg_type"
		@map_bg_type=text
		return
	end
	if @tag == "map_bg_data"
		if @map_bg_type == "color"
			@map_bg_data=text.split
		else
			@map_bg_data=text
		end
		return
	end
	if @tag == "inherit_from_global"
		@inherit_from_global=text
		return
	end
	if @tag == "snmp_state"
		@snmp_state=text
		return
	end
	if @tag == "oid_ref"
		@oid_ref=text
		return
	end
	if @tag == "snmp_oper"
		@snmp_oper=text
		return
	end
	if @tag == "snmp_threshold"
		@snmp_threshold=text
		return
	end
	if @tag == "oid_sev"
		@oid_sev=text
		return
	end
	if @tag == "wmi_state"
		@wmi_state=text
		return
	end
	if @tag == "wmi_ref"
		@wmi_ref=text
		return
	end
	if @tag == "wmi_oper"
		@wmi_oper=text
		return
	end
	if @tag == "wmi_value"
		@wmi_value=text
		return
	end
	if @tag == "wmi_sev"
		@wmi_sev=text
		return
	end		
	if @tag == "snmptrap_state"
		@snmptrap_state=text
		return
	end
	if @tag == "snmptrap_ref"
		@snmptrap_ref=text
		return
	end
	if @tag == "trapsev"
		@trapsev=text
		return
	end
	if @tag == "custom_monitor"
		@custom_monitor=text
		return
	end
	if @tag == "syslog_state"
		@syslog_state=text
		return
	end
	if @tag == "syslog_ref"
		@syslog_ref=text
		return
	end
	if @tag == "syslog_sev"
		@syslog_sev=text
		return
	end
	if text.chomp != ""
		puts "Unknown xml tag #{@tag} value #{text.chomp}"
	end
end