98 lines
2.8 KiB
Python
98 lines
2.8 KiB
Python
# -*- coding: utf-8 -*-
|
|
import threading
|
|
from printers import printPink,printRed,printGreen
|
|
from multiprocessing.dummy import Pool
|
|
from Queue import Queue
|
|
import re
|
|
import time
|
|
import threading
|
|
from threading import Thread
|
|
from rsynclib import *
|
|
import sys
|
|
import socket
|
|
socket.setdefaulttimeout(10)
|
|
sys.path.append("../")
|
|
|
|
class rsync_burp(object):
|
|
|
|
def __init__(self,c):
|
|
self.config=c
|
|
self.lock=threading.Lock()
|
|
self.result=[]
|
|
self.sp=Queue()
|
|
|
|
def get_ver(self,host):
|
|
debugging = 0
|
|
r = rsync(host)
|
|
r.set_debuglevel(debugging)
|
|
return r.server_protocol_version
|
|
|
|
|
|
def rsync_connect(self,ip,port):
|
|
creak=0
|
|
try:
|
|
ver=self.get_ver(ip)# get rsync moudle
|
|
fp = socket.create_connection((ip, port), timeout=8)
|
|
fp.recv(99)
|
|
|
|
fp.sendall(ver.strip('\r\n')+'\n')
|
|
time.sleep(3)
|
|
fp.sendall('\n')
|
|
resp = fp.recv(99)
|
|
|
|
modules = []
|
|
for line in resp.split('\n'):
|
|
#print line
|
|
modulename = line[:line.find(' ')]
|
|
if modulename:
|
|
if modulename !='@RSYNCD:':
|
|
self.lock.acquire()
|
|
printGreen("%s rsync at %s find a module:%s\r\n" %(ip,port,modulename))
|
|
self.result.append("%s rsync at %s find a module:%s\r\n" %(ip,port,modulename))
|
|
#print "find %s module in %s at %s" %(modulename,ip,port)
|
|
self.lock.release()
|
|
modules.append(modulename)
|
|
|
|
except Exception,e:
|
|
print e
|
|
pass
|
|
return creak
|
|
|
|
|
|
def rsync_creak(self,ip,port):
|
|
try:
|
|
self.rsync_connect(ip,port)
|
|
except Exception,e:
|
|
print e
|
|
|
|
|
|
def run(self,ipdict,pinglist,threads,file):
|
|
if len(ipdict['rsync']):
|
|
printPink("crack rsync now...")
|
|
print "[*] start crack rsync %s" % time.ctime()
|
|
starttime=time.time()
|
|
|
|
pool=Pool(threads)
|
|
|
|
for ip in ipdict['rsync']:
|
|
pool.apply_async(func=self.rsync_creak,args=(str(ip).split(':')[0],int(str(ip).split(':')[1])))
|
|
pool.close()
|
|
pool.join()
|
|
|
|
print "[*] stop rsync serice %s" % time.ctime()
|
|
print "[*] crack rsync done,it has Elapsed time:%s " % (time.time()-starttime)
|
|
|
|
for i in xrange(len(self.result)):
|
|
self.config.write_file(contents=self.result[i],file=file)
|
|
|
|
|
|
if __name__ == '__main__':
|
|
from comm.config import *
|
|
c=config()
|
|
ipdict={'rsync': ['103.228.69.151:873']}
|
|
pinglist=['103.228.69.151']
|
|
test=rsync_burp(c)
|
|
test.run(ipdict,pinglist,50,file="../result/test")
|
|
|
|
|