blob: 49557271477883b80408a95cea5d934954403cbb [file] [log] [blame]
Guido van Rossum4b8c6ea2000-02-04 15:39:30 +00001"""An FTP client class and some helper functions.
2
Barry Warsaw100d81e2000-09-01 06:09:23 +00003Based on RFC 959: File Transfer Protocol (FTP), by J. Postel and J. Reynolds
Guido van Rossum1115ab21992-11-04 15:51:30 +00004
Guido van Rossumd2560b01996-05-28 23:41:25 +00005Example:
6
7>>> from ftplib import FTP
8>>> ftp = FTP('ftp.python.org') # connect to host, default port
Guido van Rossum24a64342001-12-28 20:54:55 +00009>>> ftp.login() # default, i.e.: user anonymous, passwd anonymous@
Guido van Rossum2f3941d1997-10-07 14:49:56 +000010'230 Guest login ok, access restrictions apply.'
Guido van Rossumd2560b01996-05-28 23:41:25 +000011>>> ftp.retrlines('LIST') # list directory contents
12total 9
13drwxr-xr-x 8 root wheel 1024 Jan 3 1994 .
14drwxr-xr-x 8 root wheel 1024 Jan 3 1994 ..
15drwxr-xr-x 2 root wheel 1024 Jan 3 1994 bin
16drwxr-xr-x 2 root wheel 1024 Jan 3 1994 etc
17d-wxrwxr-x 2 ftp wheel 1024 Sep 5 13:43 incoming
18drwxr-xr-x 2 root wheel 1024 Nov 17 1993 lib
19drwxr-xr-x 6 1094 wheel 1024 Sep 13 19:07 pub
20drwxr-xr-x 3 root wheel 1024 Jan 3 1994 usr
21-rw-r--r-- 1 root root 312 Aug 1 1994 welcome.msg
Guido van Rossum2f3941d1997-10-07 14:49:56 +000022'226 Transfer complete.'
Guido van Rossumd2560b01996-05-28 23:41:25 +000023>>> ftp.quit()
Guido van Rossum2f3941d1997-10-07 14:49:56 +000024'221 Goodbye.'
Tim Peters88869f92001-01-14 23:36:06 +000025>>>
Guido van Rossumd2560b01996-05-28 23:41:25 +000026
27A nice test that reveals some of the network dialogue would be:
28python ftplib.py -d localhost -l -p -l
Guido van Rossum4b8c6ea2000-02-04 15:39:30 +000029"""
Guido van Rossumc567c601992-11-05 22:22:37 +000030
Tim Peters88869f92001-01-14 23:36:06 +000031#
Guido van Rossum98d9fd32000-02-28 15:12:25 +000032# Changes and improvements suggested by Steve Majewski.
33# Modified by Jack to work on the mac.
34# Modified by Siebren to support docstrings and PASV.
Christian Heimes1af737c2008-01-23 08:24:23 +000035# Modified by Phil Schwartz to add storbinary and storlines callbacks.
Guido van Rossum98d9fd32000-02-28 15:12:25 +000036#
Guido van Rossumc567c601992-11-05 22:22:37 +000037
Guido van Rossum1115ab21992-11-04 15:51:30 +000038import os
39import sys
Guido van Rossum1115ab21992-11-04 15:51:30 +000040
Guido van Rossumb6775db1994-08-01 11:34:53 +000041# Import SOCKS module if it exists, else standard socket module socket
42try:
Tim Peters88869f92001-01-14 23:36:06 +000043 import SOCKS; socket = SOCKS; del SOCKS # import SOCKS as socket
44 from socket import getfqdn; socket.getfqdn = getfqdn; del getfqdn
Guido van Rossumb6775db1994-08-01 11:34:53 +000045except ImportError:
Tim Peters88869f92001-01-14 23:36:06 +000046 import socket
Georg Brandlf78e02b2008-06-10 17:40:04 +000047from socket import _GLOBAL_DEFAULT_TIMEOUT
Guido van Rossumb6775db1994-08-01 11:34:53 +000048
Skip Montanaroeccd02a2001-01-20 23:34:12 +000049__all__ = ["FTP","Netrc"]
Guido van Rossum1115ab21992-11-04 15:51:30 +000050
Guido van Rossumd3166071993-05-24 14:16:22 +000051# Magic number from <socket.h>
Tim Peters88869f92001-01-14 23:36:06 +000052MSG_OOB = 0x1 # Process data out of band
Guido van Rossumd3166071993-05-24 14:16:22 +000053
54
Guido van Rossumc567c601992-11-05 22:22:37 +000055# The standard FTP server control port
Guido van Rossum1115ab21992-11-04 15:51:30 +000056FTP_PORT = 21
Guido van Rossum1115ab21992-11-04 15:51:30 +000057
58
Guido van Rossum21974791992-11-06 13:34:17 +000059# Exception raised when an error or invalid response is received
Fred Drake227b1202000-08-17 05:06:49 +000060class Error(Exception): pass
Tim Peters88869f92001-01-14 23:36:06 +000061class error_reply(Error): pass # unexpected [123]xx reply
62class error_temp(Error): pass # 4xx errors
63class error_perm(Error): pass # 5xx errors
64class error_proto(Error): pass # response does not begin with [1-5]
Guido van Rossum1115ab21992-11-04 15:51:30 +000065
66
Guido van Rossum21974791992-11-06 13:34:17 +000067# All exceptions (hopefully) that may be raised here and that aren't
68# (always) programming errors on our side
Christian Heimes33fe8092008-04-13 13:53:33 +000069all_errors = (Error, IOError, EOFError)
Guido van Rossum21974791992-11-06 13:34:17 +000070
71
Guido van Rossum1115ab21992-11-04 15:51:30 +000072# Line terminators (we always output CRLF, but accept any of CRLF, CR, LF)
73CRLF = '\r\n'
74
Guido van Rossum1115ab21992-11-04 15:51:30 +000075# The class itself
76class FTP:
77
Tim Peters88869f92001-01-14 23:36:06 +000078 '''An FTP client class.
Guido van Rossumd2560b01996-05-28 23:41:25 +000079
Guido van Rossumd8faa362007-04-27 19:54:29 +000080 To create a connection, call the class using these arguments:
81 host, user, passwd, acct, timeout
82
83 The first four arguments are all strings, and have default value ''.
84 timeout must be numeric and defaults to None if not passed,
85 meaning that no timeout will be set on any ftp socket(s)
86 If a timeout is passed, then this is now the default timeout for all ftp
87 socket operations for this instance.
88
Tim Peters88869f92001-01-14 23:36:06 +000089 Then use self.connect() with optional host and port argument.
Guido van Rossumd2560b01996-05-28 23:41:25 +000090
Tim Peters88869f92001-01-14 23:36:06 +000091 To download a file, use ftp.retrlines('RETR ' + filename),
92 or ftp.retrbinary() with slightly different arguments.
93 To upload a file, use ftp.storlines() or ftp.storbinary(),
94 which have an open file as argument (see their definitions
95 below for details).
96 The download/upload functions first issue appropriate TYPE
97 and PORT or PASV commands.
Guido van Rossum52b89762007-07-17 20:45:57 +000098 '''
Guido van Rossumd2560b01996-05-28 23:41:25 +000099
Fred Drake9c98a422001-02-28 21:46:37 +0000100 debugging = 0
101 host = ''
102 port = FTP_PORT
103 sock = None
104 file = None
105 welcome = None
106 passiveserver = 1
Brett Cannon6733d702007-10-08 19:48:15 +0000107 encoding = "latin1"
Fred Drake9c98a422001-02-28 21:46:37 +0000108
Tim Peters88869f92001-01-14 23:36:06 +0000109 # Initialization method (called by class instantiation).
110 # Initialize host to localhost, port to standard ftp port
111 # Optional arguments are host (for connect()),
112 # and user, passwd, acct (for login())
Georg Brandlf78e02b2008-06-10 17:40:04 +0000113 def __init__(self, host='', user='', passwd='', acct='',
114 timeout=_GLOBAL_DEFAULT_TIMEOUT):
Guido van Rossumd8faa362007-04-27 19:54:29 +0000115 self.timeout = timeout
Tim Peters88869f92001-01-14 23:36:06 +0000116 if host:
Fred Drake9c98a422001-02-28 21:46:37 +0000117 self.connect(host)
Guido van Rossumd8faa362007-04-27 19:54:29 +0000118 if user:
119 self.login(user, passwd, acct)
Guido van Rossum52fc1f61993-06-17 12:38:10 +0000120
Georg Brandlf78e02b2008-06-10 17:40:04 +0000121 def connect(self, host='', port=0, timeout=-999):
Martin v. Löwis4eb59402001-07-26 13:37:33 +0000122 '''Connect to host. Arguments are:
Guido van Rossumd8faa362007-04-27 19:54:29 +0000123 - host: hostname to connect to (string, default previous host)
124 - port: port to connect to (integer, default previous port)
125 '''
126 if host != '':
127 self.host = host
128 if port > 0:
129 self.port = port
Georg Brandlf78e02b2008-06-10 17:40:04 +0000130 if timeout != -999:
Guido van Rossumd8faa362007-04-27 19:54:29 +0000131 self.timeout = timeout
132 self.sock = socket.create_connection((self.host, self.port), self.timeout)
133 self.af = self.sock.family
Guido van Rossum52b89762007-07-17 20:45:57 +0000134 self.file = self.sock.makefile('r', encoding=self.encoding)
Martin v. Löwis4eb59402001-07-26 13:37:33 +0000135 self.welcome = self.getresp()
136 return self.welcome
Guido van Rossum1115ab21992-11-04 15:51:30 +0000137
Tim Peters88869f92001-01-14 23:36:06 +0000138 def getwelcome(self):
139 '''Get the welcome message from the server.
140 (this is read and squirreled away by connect())'''
141 if self.debugging:
Guido van Rossumbe19ed72007-02-09 05:37:30 +0000142 print('*welcome*', self.sanitize(self.welcome))
Tim Peters88869f92001-01-14 23:36:06 +0000143 return self.welcome
Guido van Rossum1115ab21992-11-04 15:51:30 +0000144
Tim Peters88869f92001-01-14 23:36:06 +0000145 def set_debuglevel(self, level):
146 '''Set the debugging level.
147 The required argument level means:
148 0: no debugging output (default)
149 1: print commands and responses but not body text etc.
150 2: also print raw lines read and sent before stripping CR/LF'''
151 self.debugging = level
152 debug = set_debuglevel
Guido van Rossum1115ab21992-11-04 15:51:30 +0000153
Tim Peters88869f92001-01-14 23:36:06 +0000154 def set_pasv(self, val):
155 '''Use passive or active mode for data transfers.
156 With a false argument, use the normal PORT mode,
157 With a true argument, use the PASV command.'''
158 self.passiveserver = val
Guido van Rossumd2560b01996-05-28 23:41:25 +0000159
Tim Peters88869f92001-01-14 23:36:06 +0000160 # Internal: "sanitize" a string for printing
161 def sanitize(self, s):
162 if s[:5] == 'pass ' or s[:5] == 'PASS ':
163 i = len(s)
164 while i > 5 and s[i-1] in '\r\n':
165 i = i-1
166 s = s[:5] + '*'*(i-5) + s[i:]
Walter Dörwald70a6b492004-02-12 17:35:32 +0000167 return repr(s)
Guido van Rossumebaf1041995-05-05 15:54:14 +0000168
Tim Peters88869f92001-01-14 23:36:06 +0000169 # Internal: send one line to the server, appending CRLF
170 def putline(self, line):
171 line = line + CRLF
Guido van Rossumbe19ed72007-02-09 05:37:30 +0000172 if self.debugging > 1: print('*put*', self.sanitize(line))
Guido van Rossum52b89762007-07-17 20:45:57 +0000173 self.sock.sendall(line.encode(self.encoding))
Guido van Rossum1115ab21992-11-04 15:51:30 +0000174
Tim Peters88869f92001-01-14 23:36:06 +0000175 # Internal: send one command to the server (through putline())
176 def putcmd(self, line):
Guido van Rossumbe19ed72007-02-09 05:37:30 +0000177 if self.debugging: print('*cmd*', self.sanitize(line))
Tim Peters88869f92001-01-14 23:36:06 +0000178 self.putline(line)
Guido van Rossum1115ab21992-11-04 15:51:30 +0000179
Tim Peters88869f92001-01-14 23:36:06 +0000180 # Internal: return one line from the server, stripping CRLF.
181 # Raise EOFError if the connection is closed
182 def getline(self):
183 line = self.file.readline()
184 if self.debugging > 1:
Guido van Rossumbe19ed72007-02-09 05:37:30 +0000185 print('*get*', self.sanitize(line))
Tim Peters88869f92001-01-14 23:36:06 +0000186 if not line: raise EOFError
187 if line[-2:] == CRLF: line = line[:-2]
188 elif line[-1:] in CRLF: line = line[:-1]
189 return line
Guido van Rossum1115ab21992-11-04 15:51:30 +0000190
Tim Peters88869f92001-01-14 23:36:06 +0000191 # Internal: get a response from the server, which may possibly
192 # consist of multiple lines. Return a single string with no
193 # trailing CRLF. If the response consists of multiple lines,
194 # these are separated by '\n' characters in the string
195 def getmultiline(self):
196 line = self.getline()
197 if line[3:4] == '-':
198 code = line[:3]
199 while 1:
200 nextline = self.getline()
201 line = line + ('\n' + nextline)
202 if nextline[:3] == code and \
203 nextline[3:4] != '-':
204 break
205 return line
Guido van Rossum1115ab21992-11-04 15:51:30 +0000206
Tim Peters88869f92001-01-14 23:36:06 +0000207 # Internal: get a response from the server.
208 # Raise various errors if the response indicates an error
209 def getresp(self):
210 resp = self.getmultiline()
Guido van Rossumbe19ed72007-02-09 05:37:30 +0000211 if self.debugging: print('*resp*', self.sanitize(resp))
Tim Peters88869f92001-01-14 23:36:06 +0000212 self.lastresp = resp[:3]
213 c = resp[:1]
Raymond Hettingerc88a6c72005-04-05 04:31:09 +0000214 if c in ('1', '2', '3'):
215 return resp
Tim Peters88869f92001-01-14 23:36:06 +0000216 if c == '4':
Collin Winterce36ad82007-08-30 01:19:48 +0000217 raise error_temp(resp)
Tim Peters88869f92001-01-14 23:36:06 +0000218 if c == '5':
Collin Winterce36ad82007-08-30 01:19:48 +0000219 raise error_perm(resp)
220 raise error_proto(resp)
Guido van Rossum1115ab21992-11-04 15:51:30 +0000221
Tim Peters88869f92001-01-14 23:36:06 +0000222 def voidresp(self):
223 """Expect a response beginning with '2'."""
224 resp = self.getresp()
225 if resp[0] != '2':
Collin Winterce36ad82007-08-30 01:19:48 +0000226 raise error_reply(resp)
Tim Peters88869f92001-01-14 23:36:06 +0000227 return resp
Guido van Rossumc567c601992-11-05 22:22:37 +0000228
Tim Peters88869f92001-01-14 23:36:06 +0000229 def abort(self):
230 '''Abort a file transfer. Uses out-of-band data.
231 This does not follow the procedure from the RFC to send Telnet
232 IP and Synch; that doesn't seem to work with the servers I've
233 tried. Instead, just send the ABOR command as OOB data.'''
234 line = 'ABOR' + CRLF
Guido van Rossumbe19ed72007-02-09 05:37:30 +0000235 if self.debugging > 1: print('*put urgent*', self.sanitize(line))
Martin v. Löwise12454f2002-02-16 23:06:19 +0000236 self.sock.sendall(line, MSG_OOB)
Tim Peters88869f92001-01-14 23:36:06 +0000237 resp = self.getmultiline()
238 if resp[:3] not in ('426', '226'):
Collin Winterce36ad82007-08-30 01:19:48 +0000239 raise error_proto(resp)
Guido van Rossumd3166071993-05-24 14:16:22 +0000240
Tim Peters88869f92001-01-14 23:36:06 +0000241 def sendcmd(self, cmd):
242 '''Send a command and return the response.'''
243 self.putcmd(cmd)
244 return self.getresp()
Guido van Rossum1115ab21992-11-04 15:51:30 +0000245
Tim Peters88869f92001-01-14 23:36:06 +0000246 def voidcmd(self, cmd):
247 """Send a command and expect a response beginning with '2'."""
248 self.putcmd(cmd)
249 return self.voidresp()
Guido van Rossumc567c601992-11-05 22:22:37 +0000250
Tim Peters88869f92001-01-14 23:36:06 +0000251 def sendport(self, host, port):
252 '''Send a PORT command with the current host and the given
253 port number.
254 '''
Eric S. Raymondc95bf692001-02-09 10:06:47 +0000255 hbytes = host.split('.')
Walter Dörwald70a6b492004-02-12 17:35:32 +0000256 pbytes = [repr(port/256), repr(port%256)]
Tim Peters88869f92001-01-14 23:36:06 +0000257 bytes = hbytes + pbytes
Eric S. Raymondc95bf692001-02-09 10:06:47 +0000258 cmd = 'PORT ' + ','.join(bytes)
Tim Peters88869f92001-01-14 23:36:06 +0000259 return self.voidcmd(cmd)
Guido van Rossum1115ab21992-11-04 15:51:30 +0000260
Martin v. Löwisa43c2f82001-07-24 20:34:08 +0000261 def sendeprt(self, host, port):
Martin v. Löwis4eb59402001-07-26 13:37:33 +0000262 '''Send a EPRT command with the current host and the given port number.'''
263 af = 0
264 if self.af == socket.AF_INET:
265 af = 1
266 if self.af == socket.AF_INET6:
267 af = 2
268 if af == 0:
Collin Winterce36ad82007-08-30 01:19:48 +0000269 raise error_proto('unsupported address family')
Walter Dörwald70a6b492004-02-12 17:35:32 +0000270 fields = ['', repr(af), host, repr(port), '']
Neal Norwitz7ce734c2002-05-31 14:13:04 +0000271 cmd = 'EPRT ' + '|'.join(fields)
Martin v. Löwis4eb59402001-07-26 13:37:33 +0000272 return self.voidcmd(cmd)
Martin v. Löwisa43c2f82001-07-24 20:34:08 +0000273
Tim Peters88869f92001-01-14 23:36:06 +0000274 def makeport(self):
Martin v. Löwis4eb59402001-07-26 13:37:33 +0000275 '''Create a new socket and send a PORT command for it.'''
Martin v. Löwis2ad25692001-07-31 08:40:21 +0000276 msg = "getaddrinfo returns an empty list"
Martin v. Löwis322c0d12001-10-07 08:53:32 +0000277 sock = None
Martin v. Löwis4eb59402001-07-26 13:37:33 +0000278 for res in socket.getaddrinfo(None, 0, self.af, socket.SOCK_STREAM, 0, socket.AI_PASSIVE):
279 af, socktype, proto, canonname, sa = res
280 try:
281 sock = socket.socket(af, socktype, proto)
282 sock.bind(sa)
Guido van Rossumb940e112007-01-10 16:19:56 +0000283 except socket.error as msg:
Martin v. Löwis322c0d12001-10-07 08:53:32 +0000284 if sock:
285 sock.close()
Martin v. Löwis4eb59402001-07-26 13:37:33 +0000286 sock = None
287 continue
288 break
289 if not sock:
Collin Winterce36ad82007-08-30 01:19:48 +0000290 raise socket.error(msg)
Martin v. Löwis4eb59402001-07-26 13:37:33 +0000291 sock.listen(1)
292 port = sock.getsockname()[1] # Get proper port
293 host = self.sock.getsockname()[0] # Get proper host
294 if self.af == socket.AF_INET:
295 resp = self.sendport(host, port)
296 else:
297 resp = self.sendeprt(host, port)
298 return sock
Martin v. Löwisa43c2f82001-07-24 20:34:08 +0000299
300 def makepasv(self):
Martin v. Löwis4eb59402001-07-26 13:37:33 +0000301 if self.af == socket.AF_INET:
302 host, port = parse227(self.sendcmd('PASV'))
303 else:
304 host, port = parse229(self.sendcmd('EPSV'), self.sock.getpeername())
305 return host, port
Guido van Rossum1115ab21992-11-04 15:51:30 +0000306
Tim Peters88869f92001-01-14 23:36:06 +0000307 def ntransfercmd(self, cmd, rest=None):
308 """Initiate a transfer over the data connection.
Barry Warsaw100d81e2000-09-01 06:09:23 +0000309
Tim Peters88869f92001-01-14 23:36:06 +0000310 If the transfer is active, send a port command and the
311 transfer command, and accept the connection. If the server is
312 passive, send a pasv command, connect to it, and start the
313 transfer command. Either way, return the socket for the
314 connection and the expected size of the transfer. The
315 expected size may be None if it could not be determined.
Barry Warsaw100d81e2000-09-01 06:09:23 +0000316
Tim Peters88869f92001-01-14 23:36:06 +0000317 Optional `rest' argument can be a string that is sent as the
Christian Heimes1af737c2008-01-23 08:24:23 +0000318 argument to a REST command. This is essentially a server
Tim Peters88869f92001-01-14 23:36:06 +0000319 marker used to tell the server to skip over any data up to the
320 given marker.
321 """
322 size = None
323 if self.passiveserver:
Martin v. Löwisa43c2f82001-07-24 20:34:08 +0000324 host, port = self.makepasv()
Guido van Rossumcd16bf62007-06-13 18:07:49 +0000325 conn = socket.create_connection((host, port), self.timeout)
Tim Peters88869f92001-01-14 23:36:06 +0000326 if rest is not None:
327 self.sendcmd("REST %s" % rest)
328 resp = self.sendcmd(cmd)
Thomas Wouters89f507f2006-12-13 04:49:30 +0000329 # Some servers apparently send a 200 reply to
330 # a LIST or STOR command, before the 150 reply
331 # (and way before the 226 reply). This seems to
332 # be in violation of the protocol (which only allows
333 # 1xx or error messages for LIST), so we just discard
334 # this response.
335 if resp[0] == '2':
Thomas Wouters9fe394c2007-02-05 01:24:16 +0000336 resp = self.getresp()
Tim Peters88869f92001-01-14 23:36:06 +0000337 if resp[0] != '1':
Collin Winterce36ad82007-08-30 01:19:48 +0000338 raise error_reply(resp)
Tim Peters88869f92001-01-14 23:36:06 +0000339 else:
340 sock = self.makeport()
341 if rest is not None:
342 self.sendcmd("REST %s" % rest)
343 resp = self.sendcmd(cmd)
Thomas Wouters89f507f2006-12-13 04:49:30 +0000344 # See above.
345 if resp[0] == '2':
Thomas Wouters9fe394c2007-02-05 01:24:16 +0000346 resp = self.getresp()
Tim Peters88869f92001-01-14 23:36:06 +0000347 if resp[0] != '1':
Collin Winterce36ad82007-08-30 01:19:48 +0000348 raise error_reply(resp)
Tim Peters88869f92001-01-14 23:36:06 +0000349 conn, sockaddr = sock.accept()
350 if resp[:3] == '150':
351 # this is conditional in case we received a 125
352 size = parse150(resp)
353 return conn, size
Fred Drake4de02d91997-01-10 18:26:09 +0000354
Tim Peters88869f92001-01-14 23:36:06 +0000355 def transfercmd(self, cmd, rest=None):
Guido van Rossumb6aca6a2001-10-16 19:45:52 +0000356 """Like ntransfercmd() but returns only the socket."""
Tim Peters88869f92001-01-14 23:36:06 +0000357 return self.ntransfercmd(cmd, rest)[0]
Guido van Rossumc567c601992-11-05 22:22:37 +0000358
Tim Peters88869f92001-01-14 23:36:06 +0000359 def login(self, user = '', passwd = '', acct = ''):
360 '''Login, default anonymous.'''
361 if not user: user = 'anonymous'
362 if not passwd: passwd = ''
363 if not acct: acct = ''
364 if user == 'anonymous' and passwd in ('', '-'):
Tim Peterse4418602002-02-16 07:34:19 +0000365 # If there is no anonymous ftp password specified
366 # then we'll just use anonymous@
367 # We don't send any other thing because:
368 # - We want to remain anonymous
369 # - We want to stop SPAM
370 # - We don't want to let ftp sites to discriminate by the user,
371 # host or country.
Guido van Rossumc33e0772001-12-28 20:54:28 +0000372 passwd = passwd + 'anonymous@'
Tim Peters88869f92001-01-14 23:36:06 +0000373 resp = self.sendcmd('USER ' + user)
374 if resp[0] == '3': resp = self.sendcmd('PASS ' + passwd)
375 if resp[0] == '3': resp = self.sendcmd('ACCT ' + acct)
376 if resp[0] != '2':
Collin Winterce36ad82007-08-30 01:19:48 +0000377 raise error_reply(resp)
Tim Peters88869f92001-01-14 23:36:06 +0000378 return resp
Guido van Rossumc567c601992-11-05 22:22:37 +0000379
Tim Peters88869f92001-01-14 23:36:06 +0000380 def retrbinary(self, cmd, callback, blocksize=8192, rest=None):
Christian Heimes1af737c2008-01-23 08:24:23 +0000381 """Retrieve data in binary mode. A new port is created for you.
Barry Warsaw100d81e2000-09-01 06:09:23 +0000382
Christian Heimes1af737c2008-01-23 08:24:23 +0000383 Args:
384 cmd: A RETR command.
385 callback: A single parameter callable to be called on each
386 block of data read.
387 blocksize: The maximum number of bytes to read from the
388 socket at one time. [default: 8192]
389 rest: Passed to transfercmd(). [default: None]
Guido van Rossum1115ab21992-11-04 15:51:30 +0000390
Christian Heimes1af737c2008-01-23 08:24:23 +0000391 Returns:
392 The response code.
Tim Peters88869f92001-01-14 23:36:06 +0000393 """
394 self.voidcmd('TYPE I')
395 conn = self.transfercmd(cmd, rest)
396 while 1:
397 data = conn.recv(blocksize)
398 if not data:
399 break
400 callback(data)
401 conn.close()
402 return self.voidresp()
Guido van Rossum1115ab21992-11-04 15:51:30 +0000403
Tim Peters88869f92001-01-14 23:36:06 +0000404 def retrlines(self, cmd, callback = None):
Christian Heimes1af737c2008-01-23 08:24:23 +0000405 """Retrieve data in line mode. A new port is created for you.
406
407 Args:
408 cmd: A RETR, LIST, NLST, or MLSD command.
409 callback: An optional single parameter callable that is called
410 for each line with the trailing CRLF stripped.
411 [default: print_line()]
412
413 Returns:
414 The response code.
415 """
Raymond Hettingere874fc32002-05-12 05:53:51 +0000416 if callback is None: callback = print_line
Tim Peters88869f92001-01-14 23:36:06 +0000417 resp = self.sendcmd('TYPE A')
418 conn = self.transfercmd(cmd)
Guido van Rossum52b89762007-07-17 20:45:57 +0000419 fp = conn.makefile('r', encoding=self.encoding)
Tim Peters88869f92001-01-14 23:36:06 +0000420 while 1:
421 line = fp.readline()
Guido van Rossumbe19ed72007-02-09 05:37:30 +0000422 if self.debugging > 2: print('*retr*', repr(line))
Tim Peters88869f92001-01-14 23:36:06 +0000423 if not line:
424 break
425 if line[-2:] == CRLF:
426 line = line[:-2]
427 elif line[-1:] == '\n':
428 line = line[:-1]
429 callback(line)
430 fp.close()
431 conn.close()
432 return self.voidresp()
Guido van Rossumc567c601992-11-05 22:22:37 +0000433
Christian Heimes1af737c2008-01-23 08:24:23 +0000434 def storbinary(self, cmd, fp, blocksize=8192, callback=None):
435 """Store a file in binary mode. A new port is created for you.
436
437 Args:
438 cmd: A STOR command.
439 fp: A file-like object with a read(num_bytes) method.
440 blocksize: The maximum data size to read from fp and send over
441 the connection at once. [default: 8192]
442 callback: An optional single parameter callable that is called on
443 on each block of data after it is sent. [default: None]
444
445 Returns:
446 The response code.
447 """
Tim Peters88869f92001-01-14 23:36:06 +0000448 self.voidcmd('TYPE I')
449 conn = self.transfercmd(cmd)
450 while 1:
451 buf = fp.read(blocksize)
452 if not buf: break
Martin v. Löwise12454f2002-02-16 23:06:19 +0000453 conn.sendall(buf)
Christian Heimes1af737c2008-01-23 08:24:23 +0000454 if callback: callback(buf)
Tim Peters88869f92001-01-14 23:36:06 +0000455 conn.close()
456 return self.voidresp()
Guido van Rossumc567c601992-11-05 22:22:37 +0000457
Christian Heimes1af737c2008-01-23 08:24:23 +0000458 def storlines(self, cmd, fp, callback=None):
459 """Store a file in line mode. A new port is created for you.
460
461 Args:
462 cmd: A STOR command.
463 fp: A file-like object with a readline() method.
464 callback: An optional single parameter callable that is called on
465 on each line after it is sent. [default: None]
466
467 Returns:
468 The response code.
469 """
Tim Peters88869f92001-01-14 23:36:06 +0000470 self.voidcmd('TYPE A')
471 conn = self.transfercmd(cmd)
472 while 1:
473 buf = fp.readline()
474 if not buf: break
475 if buf[-2:] != CRLF:
476 if buf[-1] in CRLF: buf = buf[:-1]
477 buf = buf + CRLF
Martin v. Löwise12454f2002-02-16 23:06:19 +0000478 conn.sendall(buf)
Christian Heimes1af737c2008-01-23 08:24:23 +0000479 if callback: callback(buf)
Tim Peters88869f92001-01-14 23:36:06 +0000480 conn.close()
481 return self.voidresp()
Guido van Rossum0eaa74b1996-01-25 18:37:21 +0000482
Tim Peters88869f92001-01-14 23:36:06 +0000483 def acct(self, password):
484 '''Send new account name.'''
485 cmd = 'ACCT ' + password
486 return self.voidcmd(cmd)
Guido van Rossumc567c601992-11-05 22:22:37 +0000487
Tim Peters88869f92001-01-14 23:36:06 +0000488 def nlst(self, *args):
489 '''Return a list of files in a given directory (default the current).'''
490 cmd = 'NLST'
491 for arg in args:
492 cmd = cmd + (' ' + arg)
493 files = []
494 self.retrlines(cmd, files.append)
495 return files
Guido van Rossumae3b3a31993-11-30 13:43:54 +0000496
Tim Peters88869f92001-01-14 23:36:06 +0000497 def dir(self, *args):
498 '''List a directory in long form.
499 By default list current directory to stdout.
500 Optional last argument is callback function; all
501 non-empty arguments before it are concatenated to the
502 LIST command. (This *should* only be used for a pathname.)'''
503 cmd = 'LIST'
504 func = None
505 if args[-1:] and type(args[-1]) != type(''):
506 args, func = args[:-1], args[-1]
507 for arg in args:
508 if arg:
509 cmd = cmd + (' ' + arg)
510 self.retrlines(cmd, func)
Guido van Rossumc567c601992-11-05 22:22:37 +0000511
Tim Peters88869f92001-01-14 23:36:06 +0000512 def rename(self, fromname, toname):
513 '''Rename a file.'''
514 resp = self.sendcmd('RNFR ' + fromname)
515 if resp[0] != '3':
Collin Winterce36ad82007-08-30 01:19:48 +0000516 raise error_reply(resp)
Tim Peters88869f92001-01-14 23:36:06 +0000517 return self.voidcmd('RNTO ' + toname)
Guido van Rossuma61bdeb1995-10-11 17:36:31 +0000518
Tim Peters88869f92001-01-14 23:36:06 +0000519 def delete(self, filename):
520 '''Delete a file.'''
521 resp = self.sendcmd('DELE ' + filename)
522 if resp[:3] in ('250', '200'):
523 return resp
524 elif resp[:1] == '5':
Collin Winterce36ad82007-08-30 01:19:48 +0000525 raise error_perm(resp)
Tim Peters88869f92001-01-14 23:36:06 +0000526 else:
Collin Winterce36ad82007-08-30 01:19:48 +0000527 raise error_reply(resp)
Guido van Rossum02cf5821993-05-17 08:00:02 +0000528
Tim Peters88869f92001-01-14 23:36:06 +0000529 def cwd(self, dirname):
530 '''Change to a directory.'''
531 if dirname == '..':
532 try:
533 return self.voidcmd('CDUP')
Guido van Rossumb940e112007-01-10 16:19:56 +0000534 except error_perm as msg:
Martin v. Löwisb5255112002-03-10 15:59:58 +0000535 if msg.args[0][:3] != '500':
536 raise
Tim Peters88869f92001-01-14 23:36:06 +0000537 elif dirname == '':
538 dirname = '.' # does nothing, but could return error
539 cmd = 'CWD ' + dirname
540 return self.voidcmd(cmd)
Guido van Rossum17ed1ae1993-06-01 13:21:04 +0000541
Tim Peters88869f92001-01-14 23:36:06 +0000542 def size(self, filename):
543 '''Retrieve the size of a file.'''
Christian Heimes1af737c2008-01-23 08:24:23 +0000544 # The SIZE command is defined in RFC-3659
Tim Peters88869f92001-01-14 23:36:06 +0000545 resp = self.sendcmd('SIZE ' + filename)
546 if resp[:3] == '213':
Guido van Rossumb6aca6a2001-10-16 19:45:52 +0000547 s = resp[3:].strip()
548 try:
549 return int(s)
Guido van Rossum1f74cb32001-10-17 17:21:47 +0000550 except (OverflowError, ValueError):
Guido van Rossume2a383d2007-01-15 16:59:06 +0000551 return int(s)
Guido van Rossumc567c601992-11-05 22:22:37 +0000552
Tim Peters88869f92001-01-14 23:36:06 +0000553 def mkd(self, dirname):
554 '''Make a directory, return its full pathname.'''
555 resp = self.sendcmd('MKD ' + dirname)
556 return parse257(resp)
Guido van Rossum98245091998-02-19 21:15:44 +0000557
Tim Peters88869f92001-01-14 23:36:06 +0000558 def rmd(self, dirname):
559 '''Remove a directory.'''
560 return self.voidcmd('RMD ' + dirname)
Guido van Rossum1115ab21992-11-04 15:51:30 +0000561
Tim Peters88869f92001-01-14 23:36:06 +0000562 def pwd(self):
563 '''Return current working directory.'''
564 resp = self.sendcmd('PWD')
565 return parse257(resp)
Guido van Rossum17ed1ae1993-06-01 13:21:04 +0000566
Tim Peters88869f92001-01-14 23:36:06 +0000567 def quit(self):
568 '''Quit, and close the connection.'''
569 resp = self.voidcmd('QUIT')
570 self.close()
571 return resp
572
573 def close(self):
574 '''Close the connection without assuming anything about it.'''
Fred Drake9c98a422001-02-28 21:46:37 +0000575 if self.file:
576 self.file.close()
577 self.sock.close()
578 self.file = self.sock = None
Guido van Rossumc567c601992-11-05 22:22:37 +0000579
580
Guido van Rossumacfb82a1997-10-22 20:49:52 +0000581_150_re = None
Fred Drake4de02d91997-01-10 18:26:09 +0000582
583def parse150(resp):
Tim Peters88869f92001-01-14 23:36:06 +0000584 '''Parse the '150' response for a RETR request.
585 Returns the expected transfer size or None; size is not guaranteed to
586 be present in the 150 message.
587 '''
588 if resp[:3] != '150':
Collin Winterce36ad82007-08-30 01:19:48 +0000589 raise error_reply(resp)
Tim Peters88869f92001-01-14 23:36:06 +0000590 global _150_re
591 if _150_re is None:
592 import re
593 _150_re = re.compile("150 .* \((\d+) bytes\)", re.IGNORECASE)
594 m = _150_re.match(resp)
Guido van Rossumb6aca6a2001-10-16 19:45:52 +0000595 if not m:
596 return None
597 s = m.group(1)
598 try:
599 return int(s)
Guido van Rossum1f74cb32001-10-17 17:21:47 +0000600 except (OverflowError, ValueError):
Guido van Rossume2a383d2007-01-15 16:59:06 +0000601 return int(s)
Fred Drake4de02d91997-01-10 18:26:09 +0000602
603
Guido van Rossum70297d32001-08-17 17:24:29 +0000604_227_re = None
605
Guido van Rossumd2560b01996-05-28 23:41:25 +0000606def parse227(resp):
Tim Peters88869f92001-01-14 23:36:06 +0000607 '''Parse the '227' response for a PASV request.
608 Raises error_proto if it does not contain '(h1,h2,h3,h4,p1,p2)'
609 Return ('host.addr.as.numbers', port#) tuple.'''
Guido van Rossumd2560b01996-05-28 23:41:25 +0000610
Tim Peters88869f92001-01-14 23:36:06 +0000611 if resp[:3] != '227':
Collin Winterce36ad82007-08-30 01:19:48 +0000612 raise error_reply(resp)
Guido van Rossum70297d32001-08-17 17:24:29 +0000613 global _227_re
614 if _227_re is None:
615 import re
616 _227_re = re.compile(r'(\d+),(\d+),(\d+),(\d+),(\d+),(\d+)')
617 m = _227_re.search(resp)
618 if not m:
Collin Winterce36ad82007-08-30 01:19:48 +0000619 raise error_proto(resp)
Guido van Rossum70297d32001-08-17 17:24:29 +0000620 numbers = m.groups()
Eric S. Raymondc95bf692001-02-09 10:06:47 +0000621 host = '.'.join(numbers[:4])
622 port = (int(numbers[4]) << 8) + int(numbers[5])
Tim Peters88869f92001-01-14 23:36:06 +0000623 return host, port
Guido van Rossumd2560b01996-05-28 23:41:25 +0000624
625
Martin v. Löwisa43c2f82001-07-24 20:34:08 +0000626def parse229(resp, peer):
627 '''Parse the '229' response for a EPSV request.
628 Raises error_proto if it does not contain '(|||port|)'
629 Return ('host.addr.as.numbers', port#) tuple.'''
630
Raymond Hettingerc88a6c72005-04-05 04:31:09 +0000631 if resp[:3] != '229':
Collin Winterce36ad82007-08-30 01:19:48 +0000632 raise error_reply(resp)
Neal Norwitz7ce734c2002-05-31 14:13:04 +0000633 left = resp.find('(')
Collin Winterce36ad82007-08-30 01:19:48 +0000634 if left < 0: raise error_proto(resp)
Neal Norwitz7ce734c2002-05-31 14:13:04 +0000635 right = resp.find(')', left + 1)
Martin v. Löwisa43c2f82001-07-24 20:34:08 +0000636 if right < 0:
Collin Winterce36ad82007-08-30 01:19:48 +0000637 raise error_proto(resp) # should contain '(|||port|)'
Raymond Hettingerc88a6c72005-04-05 04:31:09 +0000638 if resp[left + 1] != resp[right - 1]:
Collin Winterce36ad82007-08-30 01:19:48 +0000639 raise error_proto(resp)
Walter Dörwalda401ae42002-06-03 10:41:45 +0000640 parts = resp[left + 1:right].split(resp[left+1])
Raymond Hettingerc88a6c72005-04-05 04:31:09 +0000641 if len(parts) != 5:
Collin Winterce36ad82007-08-30 01:19:48 +0000642 raise error_proto(resp)
Martin v. Löwisa43c2f82001-07-24 20:34:08 +0000643 host = peer[0]
Neal Norwitz7ce734c2002-05-31 14:13:04 +0000644 port = int(parts[3])
Martin v. Löwisa43c2f82001-07-24 20:34:08 +0000645 return host, port
646
647
Guido van Rossumc567c601992-11-05 22:22:37 +0000648def parse257(resp):
Tim Peters88869f92001-01-14 23:36:06 +0000649 '''Parse the '257' response for a MKD or PWD request.
650 This is a response to a MKD or PWD request: a directory name.
651 Returns the directoryname in the 257 reply.'''
Guido van Rossumd2560b01996-05-28 23:41:25 +0000652
Tim Peters88869f92001-01-14 23:36:06 +0000653 if resp[:3] != '257':
Collin Winterce36ad82007-08-30 01:19:48 +0000654 raise error_reply(resp)
Tim Peters88869f92001-01-14 23:36:06 +0000655 if resp[3:5] != ' "':
656 return '' # Not compliant to RFC 959, but UNIX ftpd does this
657 dirname = ''
658 i = 5
659 n = len(resp)
660 while i < n:
661 c = resp[i]
662 i = i+1
663 if c == '"':
664 if i >= n or resp[i] != '"':
665 break
666 i = i+1
667 dirname = dirname + c
668 return dirname
Guido van Rossum1115ab21992-11-04 15:51:30 +0000669
Guido van Rossum2f3941d1997-10-07 14:49:56 +0000670
Guido van Rossumae3b3a31993-11-30 13:43:54 +0000671def print_line(line):
Tim Peters88869f92001-01-14 23:36:06 +0000672 '''Default retrlines callback to print a line.'''
Guido van Rossumbe19ed72007-02-09 05:37:30 +0000673 print(line)
Guido van Rossumae3b3a31993-11-30 13:43:54 +0000674
Guido van Rossum2f3941d1997-10-07 14:49:56 +0000675
Guido van Rossumd2560b01996-05-28 23:41:25 +0000676def ftpcp(source, sourcename, target, targetname = '', type = 'I'):
Tim Peters88869f92001-01-14 23:36:06 +0000677 '''Copy file from one FTP-instance to another.'''
678 if not targetname: targetname = sourcename
679 type = 'TYPE ' + type
680 source.voidcmd(type)
681 target.voidcmd(type)
682 sourcehost, sourceport = parse227(source.sendcmd('PASV'))
683 target.sendport(sourcehost, sourceport)
684 # RFC 959: the user must "listen" [...] BEFORE sending the
685 # transfer request.
686 # So: STOR before RETR, because here the target is a "user".
687 treply = target.sendcmd('STOR ' + targetname)
688 if treply[:3] not in ('125', '150'): raise error_proto # RFC 959
689 sreply = source.sendcmd('RETR ' + sourcename)
690 if sreply[:3] not in ('125', '150'): raise error_proto # RFC 959
691 source.voidresp()
692 target.voidresp()
Guido van Rossum1115ab21992-11-04 15:51:30 +0000693
Tim Peters88869f92001-01-14 23:36:06 +0000694
Guido van Rossum56d1e3a1997-03-14 04:16:54 +0000695class Netrc:
Tim Peters88869f92001-01-14 23:36:06 +0000696 """Class to parse & provide access to 'netrc' format files.
Fred Drake475d51d1997-06-24 22:02:54 +0000697
Tim Peters88869f92001-01-14 23:36:06 +0000698 See the netrc(4) man page for information on the file format.
Guido van Rossum56d1e3a1997-03-14 04:16:54 +0000699
Tim Peters88869f92001-01-14 23:36:06 +0000700 WARNING: This class is obsolete -- use module netrc instead.
Guido van Rossumc822a451998-12-22 16:49:16 +0000701
Tim Peters88869f92001-01-14 23:36:06 +0000702 """
703 __defuser = None
704 __defpasswd = None
705 __defacct = None
Guido van Rossum56d1e3a1997-03-14 04:16:54 +0000706
Tim Peters88869f92001-01-14 23:36:06 +0000707 def __init__(self, filename=None):
Raymond Hettinger094662a2002-06-01 01:29:16 +0000708 if filename is None:
Raymond Hettinger54f02222002-06-01 14:18:47 +0000709 if "HOME" in os.environ:
Tim Peters88869f92001-01-14 23:36:06 +0000710 filename = os.path.join(os.environ["HOME"],
711 ".netrc")
712 else:
Collin Winterce36ad82007-08-30 01:19:48 +0000713 raise IOError("specify file to load or set $HOME")
Tim Peters88869f92001-01-14 23:36:06 +0000714 self.__hosts = {}
715 self.__macros = {}
716 fp = open(filename, "r")
717 in_macro = 0
718 while 1:
719 line = fp.readline()
720 if not line: break
Eric S. Raymondc95bf692001-02-09 10:06:47 +0000721 if in_macro and line.strip():
Tim Peters88869f92001-01-14 23:36:06 +0000722 macro_lines.append(line)
723 continue
724 elif in_macro:
725 self.__macros[macro_name] = tuple(macro_lines)
726 in_macro = 0
Eric S. Raymondc95bf692001-02-09 10:06:47 +0000727 words = line.split()
Tim Peters88869f92001-01-14 23:36:06 +0000728 host = user = passwd = acct = None
729 default = 0
730 i = 0
731 while i < len(words):
732 w1 = words[i]
733 if i+1 < len(words):
734 w2 = words[i + 1]
735 else:
736 w2 = None
737 if w1 == 'default':
738 default = 1
739 elif w1 == 'machine' and w2:
Eric S. Raymondc95bf692001-02-09 10:06:47 +0000740 host = w2.lower()
Tim Peters88869f92001-01-14 23:36:06 +0000741 i = i + 1
742 elif w1 == 'login' and w2:
743 user = w2
744 i = i + 1
745 elif w1 == 'password' and w2:
746 passwd = w2
747 i = i + 1
748 elif w1 == 'account' and w2:
749 acct = w2
750 i = i + 1
751 elif w1 == 'macdef' and w2:
752 macro_name = w2
753 macro_lines = []
754 in_macro = 1
755 break
756 i = i + 1
757 if default:
758 self.__defuser = user or self.__defuser
759 self.__defpasswd = passwd or self.__defpasswd
760 self.__defacct = acct or self.__defacct
761 if host:
Raymond Hettinger54f02222002-06-01 14:18:47 +0000762 if host in self.__hosts:
Tim Peters88869f92001-01-14 23:36:06 +0000763 ouser, opasswd, oacct = \
764 self.__hosts[host]
765 user = user or ouser
766 passwd = passwd or opasswd
767 acct = acct or oacct
768 self.__hosts[host] = user, passwd, acct
769 fp.close()
Guido van Rossum56d1e3a1997-03-14 04:16:54 +0000770
Tim Peters88869f92001-01-14 23:36:06 +0000771 def get_hosts(self):
772 """Return a list of hosts mentioned in the .netrc file."""
773 return self.__hosts.keys()
Guido van Rossum8ca84201998-03-26 20:56:10 +0000774
Tim Peters88869f92001-01-14 23:36:06 +0000775 def get_account(self, host):
776 """Returns login information for the named host.
Guido van Rossum8ca84201998-03-26 20:56:10 +0000777
Tim Peters88869f92001-01-14 23:36:06 +0000778 The return value is a triple containing userid,
779 password, and the accounting field.
Guido van Rossum8ca84201998-03-26 20:56:10 +0000780
Tim Peters88869f92001-01-14 23:36:06 +0000781 """
Eric S. Raymondc95bf692001-02-09 10:06:47 +0000782 host = host.lower()
Tim Peters88869f92001-01-14 23:36:06 +0000783 user = passwd = acct = None
Raymond Hettinger54f02222002-06-01 14:18:47 +0000784 if host in self.__hosts:
Tim Peters88869f92001-01-14 23:36:06 +0000785 user, passwd, acct = self.__hosts[host]
786 user = user or self.__defuser
787 passwd = passwd or self.__defpasswd
788 acct = acct or self.__defacct
789 return user, passwd, acct
Guido van Rossum8ca84201998-03-26 20:56:10 +0000790
Tim Peters88869f92001-01-14 23:36:06 +0000791 def get_macros(self):
792 """Return a list of all defined macro names."""
793 return self.__macros.keys()
Guido van Rossum8ca84201998-03-26 20:56:10 +0000794
Tim Peters88869f92001-01-14 23:36:06 +0000795 def get_macro(self, macro):
796 """Return a sequence of lines which define a named macro."""
797 return self.__macros[macro]
Guido van Rossum56d1e3a1997-03-14 04:16:54 +0000798
Fred Drake475d51d1997-06-24 22:02:54 +0000799
Tim Peters88869f92001-01-14 23:36:06 +0000800
Guido van Rossum1115ab21992-11-04 15:51:30 +0000801def test():
Tim Peters88869f92001-01-14 23:36:06 +0000802 '''Test program.
Raymond Hettingerc88a6c72005-04-05 04:31:09 +0000803 Usage: ftp [-d] [-r[file]] host [-l[dir]] [-d[dir]] [-p] [file] ...
804
805 -d dir
806 -l list
807 -p password
808 '''
809
810 if len(sys.argv) < 2:
Guido van Rossumbe19ed72007-02-09 05:37:30 +0000811 print(test.__doc__)
Raymond Hettingerc88a6c72005-04-05 04:31:09 +0000812 sys.exit(0)
Guido van Rossumd2560b01996-05-28 23:41:25 +0000813
Tim Peters88869f92001-01-14 23:36:06 +0000814 debugging = 0
815 rcfile = None
816 while sys.argv[1] == '-d':
817 debugging = debugging+1
818 del sys.argv[1]
819 if sys.argv[1][:2] == '-r':
820 # get name of alternate ~/.netrc file:
821 rcfile = sys.argv[1][2:]
822 del sys.argv[1]
823 host = sys.argv[1]
824 ftp = FTP(host)
825 ftp.set_debuglevel(debugging)
826 userid = passwd = acct = ''
827 try:
828 netrc = Netrc(rcfile)
829 except IOError:
830 if rcfile is not None:
831 sys.stderr.write("Could not open account file"
832 " -- using anonymous login.")
833 else:
834 try:
835 userid, passwd, acct = netrc.get_account(host)
836 except KeyError:
837 # no account for host
838 sys.stderr.write(
839 "No account -- using anonymous login.")
840 ftp.login(userid, passwd, acct)
841 for file in sys.argv[2:]:
842 if file[:2] == '-l':
843 ftp.dir(file[2:])
844 elif file[:2] == '-d':
845 cmd = 'CWD'
846 if file[2:]: cmd = cmd + ' ' + file[2:]
847 resp = ftp.sendcmd(cmd)
848 elif file == '-p':
849 ftp.set_pasv(not ftp.passiveserver)
850 else:
851 ftp.retrbinary('RETR ' + file, \
852 sys.stdout.write, 1024)
853 ftp.quit()
Guido van Rossum221ec0b1995-08-04 04:39:30 +0000854
855
856if __name__ == '__main__':
Tim Peters88869f92001-01-14 23:36:06 +0000857 test()