X-Git-Url: https://git.phdru.name/?a=blobdiff_plain;f=m_lib%2Fnet%2Fftp%2Fftpscan.py;h=ebff998f72a2c1c50ef0bd03bc537674a18618b4;hb=d6dfcc1897238d60dcde474d5030ef12679ccac8;hp=f12ef3e1af1e170ecc22e84ce9347aa9278a5ba4;hpb=c0a3ca4a622dadfa767404da3c366443bab0f791;p=m_lib.git diff --git a/m_lib/net/ftp/ftpscan.py b/m_lib/net/ftp/ftpscan.py index f12ef3e..ebff998 100755 --- a/m_lib/net/ftp/ftpscan.py +++ b/m_lib/net/ftp/ftpscan.py @@ -3,8 +3,9 @@ from __future__ import print_function +import codecs import ftplib -from m_lib.net.ftp.ftpparse import ftpparse +from .ftpparse import ftpparse class FtpScanError(Exception): pass @@ -61,7 +62,7 @@ class ReconnectingFTPCallWrapper: class ReconnectingFTPWrapper: ReconnectingFTPCallWrapperClass = ReconnectingFTPCallWrapper - def __init__(self, ftp, ftp_server, ftp_port=None, login=None, password=None, ftp_dir='/', tree=None): + def __init__(self, ftp, ftp_server, ftp_port=0, login=None, password=None, ftp_dir='/', tree=None): self._ftp = ftp self._ftp_server = ftp_server self._ftp_port = ftp_port @@ -121,7 +122,7 @@ def _traverse_ftp(ftp, tree, ftp_dir): ftp.cwd("..") -def ftpscan1(ftp_server, ftp_port=None, login=None, password=None, +def ftpscan1(ftp_server, ftp_port=0, login=None, password=None, ftp_dir='/', passive=None, FTPClass=ftplib.FTP, reconnect=False, ReconnectingFTPWrapperClass=ReconnectingFTPWrapper): """Recursive FTP scan using one-by-one directory traversing. It is slow @@ -135,7 +136,7 @@ def ftpscan1(ftp_server, ftp_port=None, login=None, password=None, ftp = ReconnectingFTPWrapperClass(ftp, ftp_server, ftp_port, login, password, ftp_dir, tree) ftp.connect(ftp_server, ftp_port) ftp.login(login, password) - if ftp_dir <> '/': + if ftp_dir != '/': ftp.cwd(ftp_dir) _traverse_ftp(ftp, tree, ftp_dir) @@ -144,7 +145,7 @@ def ftpscan1(ftp_server, ftp_port=None, login=None, password=None, return tree -def ftpscanrecursive(ftp_server, ftp_port=None, login=None, password=None, +def ftpscanrecursive(ftp_server, ftp_port=0, login=None, password=None, ftp_dir='/', passive=None, FTPClass=ftplib.FTP, reconnect=False): """ Recursive FTP scan using fast LIST -R command. Not all servers supports @@ -155,7 +156,7 @@ def ftpscanrecursive(ftp_server, ftp_port=None, login=None, password=None, ftp.set_pasv(passive) ftp.connect(ftp_server, ftp_port) ftp.login(login, password) - if ftp_dir <> '/': + if ftp_dir != '/': ftp.cwd(ftp_dir) lines = [] @@ -165,7 +166,7 @@ def ftpscanrecursive(ftp_server, ftp_port=None, login=None, password=None, # The server does not implement LIST -R and # treats -R as a name of a directory (-: ftp.quit() - raise FtpScanError, "the server does not implement recursive listing" + raise FtpScanError("the server does not implement recursive listing") ftp.quit() tree = [] @@ -178,7 +179,7 @@ def ftpscanrecursive(ftp_server, ftp_port=None, login=None, password=None, tree.append((current_dir, files)) if line[:2] == "./": line = line[1:] # remove leading dot - elif line[0] <> '/': + elif line[0] != '/': line = '/' + line current_dir = line[:-1] files = [] @@ -193,12 +194,12 @@ def ftpscanrecursive(ftp_server, ftp_port=None, login=None, password=None, tree.append((current_dir, files)) if len(tree) == 1: - raise FtpScanError, "the server ignores -R in LIST" + raise FtpScanError("the server ignores -R in LIST") return tree -def ftpscan(ftp_server, ftp_port=None, login=None, password=None, +def ftpscan(ftp_server, ftp_port=0, login=None, password=None, ftp_dir='/', passive=None, FTPClass=ftplib.FTP): try: return ftpscanrecursive(ftp_server, ftp_port, login, password, ftp_dir, passive, FTPClass) @@ -221,7 +222,7 @@ def test(ftp_server, func, passive=None, reconnect=False): print(stop_time - start_time) logfname = "%s.list" % ftp_server - log = open(logfname, 'w') + log = codecs.open(logfname, 'w', encoding='utf-8') for ftp_dir, files in tree: if ftp_dir == ftpscan_error_mark: