From 6334b9cdfc47bd85b2ce236572e08406324d25cd Mon Sep 17 00:00:00 2001 From: Steve Kemp Date: Mon, 12 Nov 2012 21:00:16 +0000 Subject: Initial dump of code. --- worker/tests/README | 15 +++++++++++++++ worker/tests/ftp.rb | 51 +++++++++++++++++++++++++++++++++++++++++++++++++ worker/tests/http.rb | 20 +++++++++++++++++++ worker/tests/https.rb | 20 +++++++++++++++++++ worker/tests/jabber.rb | 51 +++++++++++++++++++++++++++++++++++++++++++++++++ worker/tests/ldap.rb | 41 +++++++++++++++++++++++++++++++++++++++ worker/tests/ping.rb | 36 ++++++++++++++++++++++++++++++++++ worker/tests/rsync.rb | 48 ++++++++++++++++++++++++++++++++++++++++++++++ worker/tests/smtp.rb | 52 ++++++++++++++++++++++++++++++++++++++++++++++++++ worker/tests/ssh.rb | 50 ++++++++++++++++++++++++++++++++++++++++++++++++ 10 files changed, 384 insertions(+) create mode 100644 worker/tests/README create mode 100644 worker/tests/ftp.rb create mode 100644 worker/tests/http.rb create mode 100644 worker/tests/https.rb create mode 100644 worker/tests/jabber.rb create mode 100644 worker/tests/ldap.rb create mode 100755 worker/tests/ping.rb create mode 100644 worker/tests/rsync.rb create mode 100644 worker/tests/smtp.rb create mode 100755 worker/tests/ssh.rb (limited to 'worker/tests') diff --git a/worker/tests/README b/worker/tests/README new file mode 100644 index 0000000..f40031b --- /dev/null +++ b/worker/tests/README @@ -0,0 +1,15 @@ + + This directory contains the protocol-tests. + + For the protocol "XXX" we must have: + + - The file called XXX.rb + + - The definition of the single method XXX_test + + The test will make use of "target_host", and "test_port" (other keys may be optionally + used) and will return the single result: + + false: The test failed. + + true: The test succeeded. \ No newline at end of file diff --git a/worker/tests/ftp.rb b/worker/tests/ftp.rb new file mode 100644 index 0000000..cd0e754 --- /dev/null +++ b/worker/tests/ftp.rb @@ -0,0 +1,51 @@ +require 'timeout' + + +# +# Run an FTP test. +# +# +# Return value +# TRUE: The host is up +# +# FALSE: The host is not up +# +def ftp_test ( params ) + + # + # Get the hostname & port to test against. + # + host = params['target_host'] + port = params['test_port'] + + puts "FTP testing host #{host}:#{port}" + + + begin + timeout(3) do + + begin + socket = TCPSocket.new( host, port ) + socket.puts( "QUIT") + + banner = socket.gets(nil) + banner = banner[0,20] + + socket.close() + + if ( banner =~ /^220/ ) + puts "FTP alive: #{banner}" + return true + end + rescue + puts "FTP exception on host #{host}:#{port} - #{$!}" + return false + end + end + rescue Timeout::Error => e + puts "TIMEOUT: #{e}" + return false + end + + return false +end diff --git a/worker/tests/http.rb b/worker/tests/http.rb new file mode 100644 index 0000000..56163c8 --- /dev/null +++ b/worker/tests/http.rb @@ -0,0 +1,20 @@ + +# +# Run a HTTP test. +# +# +# Return value +# TRUE: The host is up +# +# FALSE: The host is not up +# +def http_test( params ) + + # + # Get the URL to fetch. + # + host = params['target_host'] + + puts "HTTP FAILED - TODO - IMPLEMENT" + return false +end diff --git a/worker/tests/https.rb b/worker/tests/https.rb new file mode 100644 index 0000000..b905d79 --- /dev/null +++ b/worker/tests/https.rb @@ -0,0 +1,20 @@ + +# +# Run a HTTPS test. +# +# +# Return value +# TRUE: The host is up +# +# FALSE: The host is not up +# +def https_test( params ) + + # + # Get the URL to poll. + # + host = params['target_host'] + + puts "HTTPS FAILED - TODO - IMPLEMENT" + return false +end diff --git a/worker/tests/jabber.rb b/worker/tests/jabber.rb new file mode 100644 index 0000000..5caeb5b --- /dev/null +++ b/worker/tests/jabber.rb @@ -0,0 +1,51 @@ +require 'timeout' + + +# +# Run a Jabber test. +# +# +# Return value +# TRUE: The host is up +# +# FALSE: The host is not up +# +def jabber_test ( params ) + + # + # Get the hostname & port to test against. + # + host = params['target_host'] + port = 5222 + + puts "Jabber testing host #{host}:#{port}" + + + begin + timeout(3) do + + begin + socket = TCPSocket.new( host, port ) + socket.puts( "QUIT") + + banner = socket.gets(nil) + banner = banner[0,20] + + socket.close() + + if ( banner =~ /xml version/i ) + puts "Jabber alive: #{banner}" + return true + end + rescue + puts "Jabber exception on host #{host}:#{port} - #{$!}" + return false + end + end + rescue Timeout::Error => e + puts "TIMEOUT: #{e}" + return false + end + + return false +end diff --git a/worker/tests/ldap.rb b/worker/tests/ldap.rb new file mode 100644 index 0000000..4570f66 --- /dev/null +++ b/worker/tests/ldap.rb @@ -0,0 +1,41 @@ +require 'timeout' + + +# +# Run an LDAP test. +# +# +# Return value +# TRUE: The host is up +# +# FALSE: The host is not up +# +def ldap_test ( params ) + + # + # Get the hostname & port to test against. + # + host = params['target_host'] + port = params['test_port'] + + puts "LDAP testing host #{host}:#{port}" + + + begin + timeout(3) do + + begin + socket = TCPSocket.new( host, port ) + socket.close() + return true + rescue + puts "LDAP exception on host #{host}:#{port} - #{$!}" + return false + end + end + rescue Timeout::Error => e + puts "TIMEOUT: #{e}" + return false + end + return false +end diff --git a/worker/tests/ping.rb b/worker/tests/ping.rb new file mode 100755 index 0000000..72769a6 --- /dev/null +++ b/worker/tests/ping.rb @@ -0,0 +1,36 @@ + +# +# Run a PING test. +# +# +# Return value +# TRUE: The host is up +# +# FALSE: The host is not up +# +def ping_test( params ) + + # + # Find the binary + # + binary = nil + binary = "./util/multi-ping" if ( File.exists?( "./util/multi-ping" ) ) + binary = "../util/multi-ping" if ( File.exists?( "../util/multi-ping" ) ) + + if ( binary.nil? ) + puts "Failed to find 'multi-ping'" + exit 1 + end + + # + # Is it IPv6 or IPv4a + # + host = params['target_host'] + if ( system( "#{binary} #{host}" ) == true ) + puts "PING OK" + return true + else + puts "PING FAILED" + return false + end +end diff --git a/worker/tests/rsync.rb b/worker/tests/rsync.rb new file mode 100644 index 0000000..2c781d8 --- /dev/null +++ b/worker/tests/rsync.rb @@ -0,0 +1,48 @@ +require 'timeout' + + +# +# Run an rsync test. +# +# +# Return value +# TRUE: The host is up +# +# FALSE: The host is not up +# +def rsync_test ( params ) + + # + # Get the hostname + # + host = params['target_host'] + port = 873 + + puts "rsync testing host #{host}:#{port}" + + + begin + timeout(3) do + + begin + socket = TCPSocket.new( host, port ) + socket.puts( "QUIT") + banner = socket.gets(nil) + socket.close() + + banner = banner[0,20] + if ( banner =~ /rsyncd/i ) + puts "rsync alive: #{banner}" + return true + end + rescue + puts "Exception on host #{host}:#{port} - #{$!}" + return false + end + end + rescue Timeout::Error => e + puts "TIMEOUT: #{e}" + return false + end + return false +end diff --git a/worker/tests/smtp.rb b/worker/tests/smtp.rb new file mode 100644 index 0000000..66da545 --- /dev/null +++ b/worker/tests/smtp.rb @@ -0,0 +1,52 @@ +require 'timeout' + + +# +# Run an SMTP test. +# +# +# Return value +# TRUE: The host is up +# +# FALSE: The host is not up +# +def smtp_test ( params ) + + # + # Get the hostname & port to test against. + # + host = params['target_host'] + port = 25 + + puts "SMTP testing host #{host}:#{port}" + + + begin + timeout(3) do + + begin + socket = TCPSocket.new( host, port ) + socket.puts( "QUIT\n\n") + + banner = socket.gets(nil) + banner = banner[0,20] + + socket.close() + + if ( banner =~ /SMTP/i ) + puts "SMTP alive: #{banner}" + return true + end + rescue + puts "SMTP exception on host #{host}:#{port} - #{$!}" + return false + end + end + rescue Timeout::Error => e + + puts "SMTP TIMEOUT: #{e}" + return false + end + puts "SMTP Misc Failure" + return false +end diff --git a/worker/tests/ssh.rb b/worker/tests/ssh.rb new file mode 100755 index 0000000..4264c8e --- /dev/null +++ b/worker/tests/ssh.rb @@ -0,0 +1,50 @@ +require 'timeout' + + +# +# Run an SSH test. +# +# +# Return value +# TRUE: The host is up +# +# FALSE: The host is not up +# +def ssh_test ( params ) + + # + # Get the hostname & port to test against. + # + host = params['target_host'] + port = params['test_port'] + + puts "SSH testing host #{host}:#{port}" + + + begin + timeout(3) do + + begin + socket = TCPSocket.new( host, port ) + socket.puts( "QUIT") + + banner = socket.gets(nil) + banner = banner[0,20] + socket.close() + + if ( banner =~ /ssh/i ) + puts "SSH alive: #{banner}" + return true + end + rescue + puts "SSH exception on host #{host}:#{port} - #{$!}" + return false + end + end + rescue Timeout::Error => e + puts "TIMEOUT: #{e}" + return false + end + + return false +end -- cgit v1.2.3