# Net::FTP.pm
#
-# Copyright (c) 1995 Graham Barr <Graham.Barr@tiuk.ti.com>. All rights
-# reserved. This program is free software; you can redistribute it and/or
+# Copyright (c) 1995-8 Graham Barr <gbarr@pobox.com>. All rights reserved.
+# This program is free software; you can redistribute it and/or
# modify it under the same terms as Perl itself.
+#
+# Documentation (at end) improved 1996 by Nathan Torkington <gnat@frii.com>.
package Net::FTP;
-=head1 NAME
+require 5.001;
-Net::FTP - FTP Client class
+use strict;
+use vars qw(@ISA $VERSION);
+use Carp;
-=head1 SYNOPSIS
+use Socket 1.3;
+use IO::Socket;
+use Time::Local;
+use Net::Cmd;
+use Net::Config;
+use Fcntl qw(O_WRONLY O_RDONLY O_APPEND O_CREAT O_TRUNC);
+# use AutoLoader qw(AUTOLOAD);
- use Net::FTP;
-
- $ftp = Net::FTP->new("some.host.name");
- $ftp->login("anonymous","me@here.there");
- $ftp->cwd("/pub");
- $ftp->get("that.file");
- $ftp->quit;
+$VERSION = "2.65"; # $Id: //depot/libnet/Net/FTP.pm#68 $
+@ISA = qw(Exporter Net::Cmd IO::Socket::INET);
-=head1 DESCRIPTION
+# Someday I will "use constant", when I am not bothered to much about
+# compatability with older releases of perl
-C<Net::FTP> is a class implementing a simple FTP client in Perl as described
-in RFC959
+use vars qw($TELNET_IAC $TELNET_IP $TELNET_DM);
+($TELNET_IAC,$TELNET_IP,$TELNET_DM) = (255,244,242);
-C<Net::FTP> provides methods that will perform various operations. These methods
-could be split into groups depending the level of interface the user requires.
+# Name is too long for AutoLoad, it clashes with pasv_xfer
+sub pasv_xfer_unique {
+ my($sftp,$sfile,$dftp,$dfile) = @_;
+ $sftp->pasv_xfer($sfile,$dftp,$dfile,1);
+}
-=head1 CONSTRUCTOR
+BEGIN {
+ # make a constant so code is fast'ish
+ my $is_os390 = $^O eq 'os390';
+ *trEBCDIC = sub () { $is_os390 }
+}
-=over 4
+1;
+# Having problems with AutoLoader
+#__END__
-=item new (HOST [,OPTIONS])
+sub new
+{
+ my $pkg = shift;
+ my $peer = shift;
+ my %arg = @_;
-This is the constructor for a new Net::SMTP object. C<HOST> is the
-name of the remote host to which a FTP connection is required.
+ my $host = $peer;
+ my $fire = undef;
+ my $fire_type = undef;
-C<OPTIONS> are passed in a hash like fasion, using key and value pairs.
-Possible options are:
+ if(exists($arg{Firewall}) || Net::Config->requires_firewall($peer))
+ {
+ $fire = $arg{Firewall}
+ || $ENV{FTP_FIREWALL}
+ || $NetConfig{ftp_firewall}
+ || undef;
-B<Firewall> - The name of a machine which acts as a FTP firewall. This can be
-overridden by an environment variable C<FTP_FIREWALL>. If specified, and the
-given host cannot be directly connected to, then the
-connection is made to the firwall machine and the string C<@hostname> is
-appended to the login identifier.
+ if(defined $fire)
+ {
+ $peer = $fire;
+ delete $arg{Port};
+ $fire_type = $arg{FirewallType}
+ || $ENV{FTP_FIREWALL_TYPE}
+ || undef;
+ }
+ }
-B<Port> - The port number to connect to on the remote machine for the
-FTP connection
+ my $ftp = $pkg->SUPER::new(PeerAddr => $peer,
+ PeerPort => $arg{Port} || 'ftp(21)',
+ Proto => 'tcp',
+ Timeout => defined $arg{Timeout}
+ ? $arg{Timeout}
+ : 120
+ ) or return undef;
-B<Timeout> - Set a timeout value (defaults to 120)
+ ${*$ftp}{'net_ftp_host'} = $host; # Remote hostname
+ ${*$ftp}{'net_ftp_type'} = 'A'; # ASCII/binary/etc mode
+ ${*$ftp}{'net_ftp_blksize'} = abs($arg{'BlockSize'} || 10240);
-B<Debug> - Debug level
+ ${*$ftp}{'net_ftp_firewall'} = $fire
+ if(defined $fire);
+ ${*$ftp}{'net_ftp_firewall_type'} = $fire_type
+ if(defined $fire_type);
-B<Passive> - If set to I<true> then all data transfers will be done using
-passive mode. This is required for some I<dumb> servers.
+ ${*$ftp}{'net_ftp_passive'} = int
+ exists $arg{Passive}
+ ? $arg{Passive}
+ : exists $ENV{FTP_PASSIVE}
+ ? $ENV{FTP_PASSIVE}
+ : defined $fire
+ ? $NetConfig{ftp_ext_passive}
+ : $NetConfig{ftp_int_passive}; # Whew! :-)
-=back
+ $ftp->hash(exists $arg{Hash} ? $arg{Hash} : 0, 1024);
-=head1 METHODS
+ $ftp->autoflush(1);
-Unless otherwise stated all methods return either a I<true> or I<false>
-value, with I<true> meaning that the operation was a success. When a method
-states that it returns a value, falure will be returned as I<undef> or an
-empty list.
+ $ftp->debug(exists $arg{Debug} ? $arg{Debug} : undef);
-=over 4
+ unless ($ftp->response() == CMD_OK)
+ {
+ $ftp->close();
+ $@ = $ftp->message;
+ undef $ftp;
+ }
-=item login ([LOGIN [,PASSWORD [, ACCOUNT] ] ])
+ $ftp;
+}
-Log into the remote FTP server with the given login information. If
-no arguments are given then the C<Net::FTP> uses the C<Net::Netrc>
-package to lookup the login information for the connected host.
-If no information is found then a login of I<anonymous> is used.
-If no password is given and the login is I<anonymous> then the users
-Email address will be used for a password.
+##
+## User interface methods
+##
-If the connection is via a firewall then the C<authorize> method will
-be called with no arguments.
+sub hash {
+ my $ftp = shift; # self
-=item authorize ( [AUTH [, RESP]])
+ my($h,$b) = @_;
+ unless($h) {
+ delete ${*$ftp}{'net_ftp_hash'};
+ return [\*STDERR,0];
+ }
+ ($h,$b) = (ref($h)? $h : \*STDERR, $b || 1024);
+ select((select($h), $|=1)[0]);
+ $b = 512 if $b < 512;
+ ${*$ftp}{'net_ftp_hash'} = [$h, $b];
+}
-This is a protocol used by some firewall ftp proxies. It is used
-to authorise the user to send data out. If both arguments are not specified
-then C<authorize> uses C<Net::Netrc> to do a lookup.
+sub quit
+{
+ my $ftp = shift;
-=item type (TYPE [, ARGS])
+ $ftp->_QUIT;
+ $ftp->close;
+}
-This method will send the TYPE command to the remote FTP server
-to change the type of data transfer. The return value is the previous
-value.
+sub DESTROY {}
-=item ascii ([ARGS]) binary([ARGS]) ebcdic([ARGS]) byte([ARGS])
+sub ascii { shift->type('A',@_); }
+sub binary { shift->type('I',@_); }
-Synonyms for C<type> with the first arguments set correctly
+sub ebcdic
+{
+ carp "TYPE E is unsupported, shall default to I";
+ shift->type('E',@_);
+}
-B<NOTE> ebcdic and byte are not fully supported.
+sub byte
+{
+ carp "TYPE L is unsupported, shall default to I";
+ shift->type('L',@_);
+}
-=item rename ( OLDNAME, NEWNAME )
+# Allow the user to send a command directly, BE CAREFUL !!
-Rename a file on the remote FTP server from C<OLDNAME> to C<NEWNAME>. This
-is done by sending the RNFR and RNTO commands.
+sub quot
+{
+ my $ftp = shift;
+ my $cmd = shift;
-=item delete ( FILENAME )
+ $ftp->command( uc $cmd, @_);
+ $ftp->response();
+}
-Send a request to the server to delete C<FILENAME>.
+sub site
+{
+ my $ftp = shift;
-=item cwd ( [ DIR ] )
+ $ftp->command("SITE", @_);
+ $ftp->response();
+}
-Change the current working directory to C<DIR>, or / if not given.
+sub mdtm
+{
+ my $ftp = shift;
+ my $file = shift;
-=item cdup ()
+ # Server Y2K bug workaround
+ #
+ # sigh; some idiotic FTP servers use ("19%d",tm.tm_year) instead of
+ # ("%d",tm.tm_year+1900). This results in an extra digit in the
+ # string returned. To account for this we allow an optional extra
+ # digit in the year. Then if the first two digits are 19 we use the
+ # remainder, otherwise we subtract 1900 from the whole year.
+
+ $ftp->_MDTM($file) && $ftp->message =~ /((\d\d)(\d\d\d?))(\d\d)(\d\d)(\d\d)(\d\d)(\d\d)/
+ ? timegm($8,$7,$6,$5,$4-1,$2 eq '19' ? $3 : ($1-1900))
+ : undef;
+}
-Change directory to the parent of the current directory.
+sub size {
+ my $ftp = shift;
+ my $file = shift;
+ my $io;
+ if($ftp->supported("SIZE")) {
+ return $ftp->_SIZE($file)
+ ? ($ftp->message =~ /(\d+)$/)[0]
+ : undef;
+ }
+ elsif($ftp->supported("STAT")) {
+ my @msg;
+ return undef
+ unless $ftp->_STAT($file) && (@msg = $ftp->message) == 3;
+ my $line;
+ foreach $line (@msg) {
+ return (split(/\s+/,$line))[4]
+ if $line =~ /^[-rwx]{10}/
+ }
+ }
+ else {
+ my @files = $ftp->dir($file);
+ if(@files) {
+ return (split(/\s+/,$1))[4]
+ if $files[0] =~ /^([-rwx]{10}.*)$/;
+ }
+ }
+ undef;
+}
-=item pwd ()
+sub login {
+ my($ftp,$user,$pass,$acct) = @_;
+ my($ok,$ruser,$fwtype);
-Returns the full pathname of the current directory.
+ unless (defined $user) {
+ require Net::Netrc;
-=item rmdir ( DIR )
+ my $rc = Net::Netrc->lookup(${*$ftp}{'net_ftp_host'});
-Remove the directory with the name C<DIR>.
+ ($user,$pass,$acct) = $rc->lpa()
+ if ($rc);
+ }
-=item mkdir ( DIR [, RECURSE ])
+ $user ||= "anonymous";
+ $ruser = $user;
-Create a new directory with the name C<DIR>. If C<RECURSE> is I<true> then
-C<mkdir> will attempt to create all the directories in the given path.
+ $fwtype = ${*$ftp}{'net_ftp_firewall_type'}
+ || $NetConfig{'ftp_firewall_type'}
+ || 0;
-Returns the full pathname to the new directory.
+ if ($fwtype && defined ${*$ftp}{'net_ftp_firewall'}) {
+ if ($fwtype == 1 || $fwtype == 7) {
+ $user .= '@' . ${*$ftp}{'net_ftp_host'};
+ }
+ else {
+ require Net::Netrc;
-=item ls ( [ DIR ] )
+ my $rc = Net::Netrc->lookup(${*$ftp}{'net_ftp_firewall'});
-Get a directory listing of C<DIR>, or the current directory.
+ my($fwuser,$fwpass,$fwacct) = $rc ? $rc->lpa() : ();
-Returns a reference to a list of lines returned from the server.
+ if ($fwtype == 5) {
+ $user = join('@',$user,$fwuser,${*$ftp}{'net_ftp_host'});
+ $pass = $pass . '@' . $fwpass;
+ }
+ else {
+ if ($fwtype == 2) {
+ $user .= '@' . ${*$ftp}{'net_ftp_host'};
+ }
+ elsif ($fwtype == 6) {
+ $fwuser .= '@' . ${*$ftp}{'net_ftp_host'};
+ }
-=item dir ( [ DIR ] )
+ $ok = $ftp->_USER($fwuser);
-Get a directory listing of C<DIR>, or the current directory in long format.
+ return 0 unless $ok == CMD_OK || $ok == CMD_MORE;
-Returns a reference to a list of lines returned from the server.
+ $ok = $ftp->_PASS($fwpass || "");
-=item get ( REMOTE_FILE [, LOCAL_FILE ] )
+ return 0 unless $ok == CMD_OK || $ok == CMD_MORE;
-Get C<REMOTE_FILE> from the server and store locally. C<LOCAL_FILE> may be
-a filename or a filehandle. If not specified the the file will be stored in
-the current directory with the same leafname as the remote file.
+ $ok = $ftp->_ACCT($fwacct)
+ if defined($fwacct);
-Returns C<LOCAL_FILE>, or the generated local file name if C<LOCAL_FILE>
-is not given.
+ if ($fwtype == 3) {
+ $ok = $ftp->command("SITE",${*$ftp}{'net_ftp_host'})->response;
+ }
+ elsif ($fwtype == 4) {
+ $ok = $ftp->command("OPEN",${*$ftp}{'net_ftp_host'})->response;
+ }
-=item put ( LOCAL_FILE [, REMOTE_FILE ] )
+ return 0 unless $ok == CMD_OK || $ok == CMD_MORE;
+ }
+ }
+ }
-Put a file on the remote server. C<LOCAL_FILE> may be a name or a filehandle.
-If C<LOCAL_FILE> is a filehandle then C<REMOTE_FILE> must be specified. If
-C<REMOTE_FILE> is not specified then the file will be stored in the current
-directory with the same leafname as C<LOCAL_FILE>.
+ $ok = $ftp->_USER($user);
-Returns C<REMOTE_FILE>, or the generated remote filename if C<REMOTE_FILE>
-is not given.
+ # Some dumb firewalls don't prefix the connection messages
+ $ok = $ftp->response()
+ if ($ok == CMD_OK && $ftp->code == 220 && $user =~ /\@/);
-=item put_unique ( LOCAL_FILE [, REMOTE_FILE ] )
+ if ($ok == CMD_MORE) {
+ unless(defined $pass) {
+ require Net::Netrc;
-Same as put but uses the C<STOU> command.
+ my $rc = Net::Netrc->lookup(${*$ftp}{'net_ftp_host'}, $ruser);
-Returns the name of the file on the server.
+ ($ruser,$pass,$acct) = $rc->lpa()
+ if ($rc);
-=item append ( LOCAL_FILE [, REMOTE_FILE ] )
+ $pass = '-anonymous@'
+ if (!defined $pass && (!defined($ruser) || $ruser =~ /^anonymous/o));
+ }
-Same as put but appends to the file on the remote server.
+ $ok = $ftp->_PASS($pass || "");
+ }
-Returns C<REMOTE_FILE>, or the generated remote filename if C<REMOTE_FILE>
-is not given.
+ $ok = $ftp->_ACCT($acct)
+ if (defined($acct) && ($ok == CMD_MORE || $ok == CMD_OK));
-=item unique_name ()
+ if ($fwtype == 7 && $ok == CMD_OK && defined ${*$ftp}{'net_ftp_firewall'}) {
+ my($f,$auth,$resp) = _auth_id($ftp);
+ $ftp->authorize($auth,$resp) if defined($resp);
+ }
-Returns the name of the last file stored on the server using the
-C<STOU> command.
+ $ok == CMD_OK;
+}
-=item mdtm ( FILE )
+sub account
+{
+ @_ == 2 or croak 'usage: $ftp->account( ACCT )';
+ my $ftp = shift;
+ my $acct = shift;
+ $ftp->_ACCT($acct) == CMD_OK;
+}
-Returns the I<modification time> of the given file
+sub _auth_id {
+ my($ftp,$auth,$resp) = @_;
-=item size ( FILE )
+ unless(defined $resp)
+ {
+ require Net::Netrc;
-Returns the size in bytes for the given file.
+ $auth ||= eval { (getpwuid($>))[0] } || $ENV{NAME};
-=back
+ my $rc = Net::Netrc->lookup(${*$ftp}{'net_ftp_firewall'}, $auth)
+ || Net::Netrc->lookup(${*$ftp}{'net_ftp_firewall'});
-The following methods can return different results depending on
-how they are called. If the user explicitly calls either
-of the C<pasv> or C<port> methods then these methods will
-return a I<true> or I<false> value. If the user does not
-call either of these methods then the result will be a
-reference to a C<Net::FTP::dataconn> based object.
+ ($auth,$resp) = $rc->lpa()
+ if ($rc);
+ }
+ ($ftp,$auth,$resp);
+}
-=over 4
+sub authorize
+{
+ @_ >= 1 || @_ <= 3 or croak 'usage: $ftp->authorize( [AUTH [, RESP]])';
-=item nlst ( [ DIR ] )
+ my($ftp,$auth,$resp) = &_auth_id;
-Send a C<NLST> command to the server, with an optional parameter.
+ my $ok = $ftp->_AUTH($auth || "");
-=item list ( [ DIR ] )
+ $ok = $ftp->_RESP($resp || "")
+ if ($ok == CMD_MORE);
-Same as C<nlst> but using the C<LIST> command
+ $ok == CMD_OK;
+}
-=item retr ( FILE )
+sub rename
+{
+ @_ == 3 or croak 'usage: $ftp->rename(FROM, TO)';
-Begin the retrieval of a file called C<FILE> from the remote server.
+ my($ftp,$from,$to) = @_;
-=item stor ( FILE )
+ $ftp->_RNFR($from)
+ && $ftp->_RNTO($to);
+}
-Tell the server that you wish to store a file. C<FILE> is the
-name of the new file that should be created.
+sub type
+{
+ my $ftp = shift;
+ my $type = shift;
+ my $oldval = ${*$ftp}{'net_ftp_type'};
-=item stou ( FILE )
+ return $oldval
+ unless (defined $type);
-Same as C<stor> but using the C<STOU> command. The name of the unique
-file which was created on the server will be avalaliable via the C<unique_name>
-method after the data connection has been closed.
+ return undef
+ unless ($ftp->_TYPE($type,@_));
-=item appe ( FILE )
+ ${*$ftp}{'net_ftp_type'} = join(" ",$type,@_);
-Tell the server that we want to append some data to the end of a file
-called C<FILE>. If this file does not exist then create it.
+ $oldval;
+}
-=back
+sub abort
+{
+ my $ftp = shift;
-If for some reason you want to have complete control over the data connection,
-this includes generating it and calling the C<response> method when required,
-then the user can use these methods to do so.
+ send($ftp,pack("CCC", $TELNET_IAC, $TELNET_IP, $TELNET_IAC),MSG_OOB);
-However calling these methods only affects the use of the methods above that
-can return a data connection. They have no effect on methods C<get>, C<put>,
-C<put_unique> and those that do not require data connections.
+ $ftp->command(pack("C",$TELNET_DM) . "ABOR");
-=over 4
+ ${*$ftp}{'net_ftp_dataconn'}->close()
+ if defined ${*$ftp}{'net_ftp_dataconn'};
-=item port ( [ PORT ] )
+ $ftp->response();
-Send a C<PORT> command to the server. If C<PORT> is specified then it is sent
-to the server. If not the a listen socket is created and the correct information
-sent to the server.
+ $ftp->status == CMD_OK;
+}
-=item pasv ()
+sub get
+{
+ my($ftp,$remote,$local,$where) = @_;
-Tell the server to go into passive mode. Returns the text that represents the
-port on which the server is listening, this text is in a suitable form to
-sent to another ftp server using the C<port> method.
+ my($loc,$len,$buf,$resp,$data);
+ local *FD;
-=back
+ my $localfd = ref($local) || ref(\$local) eq "GLOB";
-The following methods can be used to transfer files between two remote
-servers, providing that these two servers can connect directly to each other.
+ ($local = $remote) =~ s#^.*/##
+ unless(defined $local);
-=over 4
+ croak("Bad remote filename '$remote'\n")
+ if $remote =~ /[\r\n]/s;
-=item pasv_xfer ( SRC_FILE, DEST_SERVER [, DEST_FILE ] )
+ ${*$ftp}{'net_ftp_rest'} = $where
+ if ($where);
-This method will do a file transfer between two remote ftp servers. If
-C<DEST_FILE> is omitted then the leaf name of C<SRC_FILE> will be used.
+ delete ${*$ftp}{'net_ftp_port'};
+ delete ${*$ftp}{'net_ftp_pasv'};
-=item pasv_wait ( NON_PASV_SERVER )
+ $data = $ftp->retr($remote) or
+ return undef;
-This method can be used to wait for a transfer to complete between a passive
-server and a non-passive server. The method should be called on the passive
-server with the C<Net::FTP> object for the non-passive server passed as an
-argument.
+ if($localfd)
+ {
+ $loc = $local;
+ }
+ else
+ {
+ $loc = \*FD;
-=item abort ()
+ unless(sysopen($loc, $local, O_CREAT | O_WRONLY | ($where ? O_APPEND : O_TRUNC)))
+ {
+ carp "Cannot open Local file $local: $!\n";
+ $data->abort;
+ return undef;
+ }
+ }
-Abort the current data transfer.
+ if($ftp->type eq 'I' && !binmode($loc))
+ {
+ carp "Cannot binmode Local file $local: $!\n";
+ $data->abort;
+ close($loc) unless $localfd;
+ return undef;
+ }
-=item quit ()
+ $buf = '';
+ my($count,$hashh,$hashb,$ref) = (0);
-Send the QUIT command to the remote FTP server and close the socket connection.
+ ($hashh,$hashb) = @$ref
+ if($ref = ${*$ftp}{'net_ftp_hash'});
-=back
+ my $blksize = ${*$ftp}{'net_ftp_blksize'};
-=head2 Methods for the adventurous
+ while(1)
+ {
+ last unless $len = $data->read($buf,$blksize);
-C<Net::FTP> inherits from C<Net::Cmd> so methods defined in C<Net::Cmd> may
-be used to send commands to the remote FTP server.
+ if (trEBCDIC && $ftp->type ne 'I')
+ {
+ $buf = $ftp->toebcdic($buf);
+ $len = length($buf);
+ }
-=over 4
+ if($hashh) {
+ $count += $len;
+ print $hashh "#" x (int($count / $hashb));
+ $count %= $hashb;
+ }
+ my $written = syswrite($loc,$buf,$len);
+ unless(defined($written) && $written == $len)
+ {
+ carp "Cannot write to Local file $local: $!\n";
+ $data->abort;
+ close($loc)
+ unless $localfd;
+ return undef;
+ }
+ }
-=item quot (CMD [,ARGS])
+ print $hashh "\n" if $hashh;
-Send a command, that Net::FTP does not directly support, to the remote
-server and wait for a response.
+ unless ($localfd)
+ {
+ unless (close($loc))
+ {
+ carp "Cannot close file $local (perhaps disk space) $!\n";
+ return undef;
+ }
+ }
-Returns most significant digit of the response code.
+ unless ($data->close()) # implied $ftp->response
+ {
+ carp "Unable to close datastream";
+ return undef;
+ }
-B<WARNING> This call should only be used on commands that do not require
-data connections. Misuse of this method can hang the connection.
+ return $local;
+}
-=back
+sub cwd
+{
+ @_ == 1 || @_ == 2 or croak 'usage: $ftp->cwd( [ DIR ] )';
-=head1 THE dataconn CLASS
+ my($ftp,$dir) = @_;
-Some of the methods defined in C<Net::FTP> return an object which will
-be derived from this class.The dataconn class itself is derived from
-the C<IO::Socket::INET> class, so any normal IO operations can be performed.
-However the following methods are defined in the dataconn class and IO should
-be performed using these.
+ $dir = "/" unless defined($dir) && $dir =~ /\S/;
-=over 4
+ $dir eq ".."
+ ? $ftp->_CDUP()
+ : $ftp->_CWD($dir);
+}
-=item read ( BUFFER, SIZE [, TIMEOUT ] )
+sub cdup
+{
+ @_ == 1 or croak 'usage: $ftp->cdup()';
+ $_[0]->_CDUP;
+}
-Read C<SIZE> bytes of data from the server and place it into C<BUFFER>, also
-performing any <CRLF> translation necessary. C<TIMEOUT> is optional, if not
-given the the timeout value from the command connection will be used.
+sub pwd
+{
+ @_ == 1 || croak 'usage: $ftp->pwd()';
+ my $ftp = shift;
-Returns the number of bytes read before any <CRLF> translation.
+ $ftp->_PWD();
+ $ftp->_extract_path;
+}
-=item write ( BUFFER, SIZE [, TIMEOUT ] )
+# rmdir( $ftp, $dir, [ $recurse ] )
+#
+# Removes $dir on remote host via FTP.
+# $ftp is handle for remote host
+#
+# If $recurse is TRUE, the directory and deleted recursively.
+# This means all of its contents and subdirectories.
+#
+# Initial version contributed by Dinkum Software
+#
+sub rmdir
+{
+ @_ == 2 || @_ == 3 or croak('usage: $ftp->rmdir( DIR [, RECURSE ] )');
-Write C<SIZE> bytes of data from C<BUFFER> to the server, also
-performing any <CRLF> translation necessary. C<TIMEOUT> is optional, if not
-given the the timeout value from the command connection will be used.
+ # Pick off the args
+ my ($ftp, $dir, $recurse) = @_ ;
+ my $ok;
-Returns the number of bytes written before any <CRLF> translation.
+ return $ok
+ if $ok = $ftp->_RMD( $dir ) or !$recurse;
-=item abort ()
+ # Try to delete the contents
+ # Get a list of all the files in the directory
+ my $filelist = $ftp->ls($dir);
-Abort the current data transfer.
+ return undef
+ unless $filelist && @$filelist; # failed, it is probably not a directory
-=item close ()
+ # Go thru and delete each file or the directory
+ my $file;
+ foreach $file (map { m,/, ? $_ : "$dir/$_" } @$filelist)
+ {
+ next # successfully deleted the file
+ if $ftp->delete($file);
+
+ # Failed to delete it, assume its a directory
+ # Recurse and ignore errors, the final rmdir() will
+ # fail on any errors here
+ return $ok
+ unless $ok = $ftp->rmdir($file, 1) ;
+ }
-Close the data connection and get a response from the FTP server. Returns
-I<true> if the connection was closed sucessfully and the first digit of
-the response from the server was a '2'.
+ # Directory should be empty
+ # Try to remove the directory again
+ # Pass results directly to caller
+ # If any of the prior deletes failed, this
+ # rmdir() will fail because directory is not empty
+ return $ftp->_RMD($dir) ;
+}
-=back
+sub restart
+{
+ @_ == 2 || croak 'usage: $ftp->restart( BYTE_OFFSET )';
-=head1 AUTHOR
+ my($ftp,$where) = @_;
-Graham Barr <Graham.Barr@tiuk.ti.com>
+ ${*$ftp}{'net_ftp_rest'} = $where;
-=head1 REVISION
+ return undef;
+}
-$Revision: 2.8 $
-$Date: 1996/09/05 06:53:58 $
-The VERSION is derived from the revision by changing each number after the
-first dot into a 2 digit number so
+sub mkdir
+{
+ @_ == 2 || @_ == 3 or croak 'usage: $ftp->mkdir( DIR [, RECURSE ] )';
- Revision 1.8 => VERSION 1.08
- Revision 1.2.3 => VERSION 1.0203
+ my($ftp,$dir,$recurse) = @_;
-=head1 SEE ALSO
+ $ftp->_MKD($dir) || $recurse or
+ return undef;
-L<Net::Netrc>
-L<Net::Cmd>
+ my $path = $dir;
-=head1 CREDITS
+ unless($ftp->ok)
+ {
+ my @path = split(m#(?=/+)#, $dir);
-Henry Gabryjelski <henryg@WPI.EDU> - for the suggestion of creating directories
-recursively.
+ $path = "";
-=head1 COPYRIGHT
+ while(@path)
+ {
+ $path .= shift @path;
-Copyright (c) 1995 Graham Barr. All rights reserved. This program is free
-software; you can redistribute it and/or modify it under the same terms
-as Perl itself.
+ $ftp->_MKD($path);
-=cut
+ $path = $ftp->_extract_path($path);
+ }
-require 5.001;
+ # If the creation of the last element was not sucessful, see if we
+ # can cd to it, if so then return path
-use strict;
-use vars qw(@ISA $VERSION);
-use Carp;
+ unless($ftp->ok)
+ {
+ my($status,$message) = ($ftp->status,$ftp->message);
+ my $pwd = $ftp->pwd;
+
+ if($pwd && $ftp->cwd($dir))
+ {
+ $path = $dir;
+ $ftp->cwd($pwd);
+ }
+ else
+ {
+ undef $path;
+ }
+ $ftp->set_status($status,$message);
+ }
+ }
-use Socket 1.3;
-use IO::Socket;
-use Time::Local;
-use Net::Cmd;
-use Net::Telnet qw(TELNET_IAC TELNET_IP TELNET_DM);
+ $path;
+}
-$VERSION = do{my @r=(q$Revision: 2.8 $=~/(\d+)/g);sprintf "%d."."%02d"x$#r,@r};
-@ISA = qw(Exporter Net::Cmd IO::Socket::INET);
+sub delete
+{
+ @_ == 2 || croak 'usage: $ftp->delete( FILENAME )';
-sub new
+ $_[0]->_DELE($_[1]);
+}
+
+sub put { shift->_store_cmd("stor",@_) }
+sub put_unique { shift->_store_cmd("stou",@_) }
+sub append { shift->_store_cmd("appe",@_) }
+
+sub nlst { shift->_data_cmd("NLST",@_) }
+sub list { shift->_data_cmd("LIST",@_) }
+sub retr { shift->_data_cmd("RETR",@_) }
+sub stor { shift->_data_cmd("STOR",@_) }
+sub stou { shift->_data_cmd("STOU",@_) }
+sub appe { shift->_data_cmd("APPE",@_) }
+
+sub _store_cmd
{
- my $pkg = shift;
- my $peer = shift;
- my %arg = @_;
+ my($ftp,$cmd,$local,$remote) = @_;
+ my($loc,$sock,$len,$buf);
+ local *FD;
- my $host = $peer;
- my $fire = undef;
+ my $localfd = ref($local) || ref(\$local) eq "GLOB";
- unless(defined inet_aton($peer))
+ unless(defined $remote)
{
- $fire = $ENV{FTP_FIREWALL} || $arg{Firewall} || undef;
- if(defined $fire)
+ croak 'Must specify remote filename with stream input'
+ if $localfd;
+
+ require File::Basename;
+ $remote = File::Basename::basename($local);
+ }
+
+ croak("Bad remote filename '$remote'\n")
+ if $remote =~ /[\r\n]/s;
+
+ if($localfd)
+ {
+ $loc = $local;
+ }
+ else
+ {
+ $loc = \*FD;
+
+ unless(sysopen($loc, $local, O_RDONLY))
{
- $peer = $fire;
- delete $arg{Port};
+ carp "Cannot open Local file $local: $!\n";
+ return undef;
}
}
- my $ftp = $pkg->SUPER::new(PeerAddr => $peer,
- PeerPort => $arg{Port} || 'ftp(21)',
- Proto => 'tcp',
- Timeout => defined $arg{Timeout}
- ? $arg{Timeout}
- : 120
- ) or return undef;
+ if($ftp->type eq 'I' && !binmode($loc))
+ {
+ carp "Cannot binmode Local file $local: $!\n";
+ return undef;
+ }
+
+ delete ${*$ftp}{'net_ftp_port'};
+ delete ${*$ftp}{'net_ftp_pasv'};
- ${*$ftp}{'net_ftp_passive'} = $arg{Passive} || 0; # Always use pasv mode
- ${*$ftp}{'net_ftp_host'} = $host; # Remote hostname
- ${*$ftp}{'net_ftp_type'} = 'A'; # ASCII/binary/etc mode
+ $sock = $ftp->_data_cmd($cmd, $remote) or
+ return undef;
- ${*$ftp}{'net_ftp_firewall'} = $fire
- if defined $fire;
+ my $blksize = ${*$ftp}{'net_ftp_blksize'};
- $ftp->autoflush(1);
+ my($count,$hashh,$hashb,$ref) = (0);
- $ftp->debug(exists $arg{Debug} ? $arg{Debug} : undef);
+ ($hashh,$hashb) = @$ref
+ if($ref = ${*$ftp}{'net_ftp_hash'});
- unless ($ftp->response() == CMD_OK)
+ while(1)
{
- $ftp->SUPER::close();
- undef $ftp;
- }
+ last unless $len = sysread($loc,$buf="",$blksize);
- $ftp;
-}
+ if (trEBCDIC && $ftp->type ne 'I')
+ {
+ $buf = $ftp->toascii($buf);
+ $len = length($buf);
+ }
-##
-## User interface methods
-##
+ if($hashh) {
+ $count += $len;
+ print $hashh "#" x (int($count / $hashb));
+ $count %= $hashb;
+ }
-sub quit
-{
- my $ftp = shift;
+ my $wlen;
+ unless(defined($wlen = $sock->write($buf,$len)) && $wlen == $len)
+ {
+ $sock->abort;
+ close($loc)
+ unless $localfd;
+ print $hashh "\n" if $hashh;
+ return undef;
+ }
+ }
- $ftp->_QUIT
- && $ftp->SUPER::close;
-}
+ print $hashh "\n" if $hashh;
-sub close
-{
- my $ftp = shift;
+ close($loc)
+ unless $localfd;
- ref($ftp)
- && defined fileno($ftp)
- && $ftp->quit;
-}
+ $sock->close() or
+ return undef;
-sub DESTROY { shift->close }
+ if ('STOU' eq uc $cmd and $ftp->message =~ m/unique\s+file\s*name\s*:\s*(.*)\)|"(.*)"/)
+ {
+ require File::Basename;
+ $remote = File::Basename::basename($+)
+ }
-sub ascii { shift->type('A',@_); }
-sub binary { shift->type('I',@_); }
-
-sub ebcdic
-{
- carp "TYPE E is unsupported, shall default to I";
- shift->type('E',@_);
+ return $remote;
}
-sub byte
+sub port
{
- carp "TYPE L is unsupported, shall default to I";
- shift->type('L',@_);
-}
+ @_ == 1 || @_ == 2 or croak 'usage: $ftp->port([PORT])';
-# Allow the user to send a command directly, BE CAREFUL !!
+ my($ftp,$port) = @_;
+ my $ok;
-sub quot
-{
- my $ftp = shift;
- my $cmd = shift;
+ delete ${*$ftp}{'net_ftp_intern_port'};
- $ftp->command( uc $cmd, @_);
- $ftp->response();
-}
+ unless(defined $port)
+ {
+ # create a Listen socket at same address as the command socket
-sub mdtm
-{
- my $ftp = shift;
- my $file = shift;
+ ${*$ftp}{'net_ftp_listen'} ||= IO::Socket::INET->new(Listen => 5,
+ Proto => 'tcp',
+ Timeout => $ftp->timeout,
+ LocalAddr => $ftp->sockhost,
+ );
- return undef
- unless $ftp->_MDTM($file);
+ my $listen = ${*$ftp}{'net_ftp_listen'};
- my @gt = reverse ($ftp->message =~ /(\d{4})(\d\d)(\d\d)(\d\d)(\d\d)(\d\d)/);
- $gt[5] -= 1;
- timegm(@gt);
-}
+ my($myport, @myaddr) = ($listen->sockport, split(/\./,$listen->sockhost));
-sub size
-{
- my $ftp = shift;
- my $file = shift;
+ $port = join(',', @myaddr, $myport >> 8, $myport & 0xff);
- $ftp->_SIZE($file)
- ? ($ftp->message =~ /(\d+)/)[0]
- : undef;
-}
+ ${*$ftp}{'net_ftp_intern_port'} = 1;
+ }
-sub login
-{
- my($ftp,$user,$pass,$acct) = @_;
- my($ok,$ruser);
+ $ok = $ftp->_PORT($port);
- unless (defined $user)
- {
- require Net::Netrc;
+ ${*$ftp}{'net_ftp_port'} = $port;
- my $rc = Net::Netrc->lookup(${*$ftp}{'net_ftp_host'});
+ $ok;
+}
- ($user,$pass,$acct) = $rc->lpa()
- if ($rc);
- }
+sub ls { shift->_list_cmd("NLST",@_); }
+sub dir { shift->_list_cmd("LIST",@_); }
+
+sub pasv
+{
+ @_ == 1 or croak 'usage: $ftp->pasv()';
- $user ||= "anonymous";
- $ruser = $user;
+ my $ftp = shift;
- if(defined ${*$ftp}{'net_ftp_firewall'})
- {
- $user .= "@" . ${*$ftp}{'net_ftp_host'};
- }
+ delete ${*$ftp}{'net_ftp_intern_port'};
- $ok = $ftp->_USER($user);
+ $ftp->_PASV && $ftp->message =~ /(\d+(,\d+)+)/
+ ? ${*$ftp}{'net_ftp_pasv'} = $1
+ : undef;
+}
- # Some dumb firewall's don't prefix the connection messages
- $ok = $ftp->response()
- if($ok == CMD_OK && $ftp->code == 220 && $user =~ /\@/);
+sub unique_name
+{
+ my $ftp = shift;
+ ${*$ftp}{'net_ftp_unique'} || undef;
+}
- if ($ok == CMD_MORE)
- {
- unless(defined $pass)
- {
- require Net::Netrc;
+sub supported {
+ @_ == 2 or croak 'usage: $ftp->supported( CMD )';
+ my $ftp = shift;
+ my $cmd = uc shift;
+ my $hash = ${*$ftp}{'net_ftp_supported'} ||= {};
- my $rc = Net::Netrc->lookup(${*$ftp}{'net_ftp_host'}, $ruser);
+ return $hash->{$cmd}
+ if exists $hash->{$cmd};
- ($ruser,$pass,$acct) = $rc->lpa()
- if ($rc);
+ return $hash->{$cmd} = 0
+ unless $ftp->_HELP($cmd);
- $pass = "-" . (getpwuid($>))[0] . "@"
- if (!defined $pass && $ruser =~ /^anonymous/o);
+ my $text = $ftp->message;
+ if($text =~ /following\s+commands/i) {
+ $text =~ s/^.*\n//;
+ while($text =~ /(\*?)(\w+)(\*?)/sg) {
+ $hash->{"\U$2"} = !length("$1$3");
+ }
+ }
+ else {
+ $hash->{$cmd} = $text !~ /unimplemented/i;
}
- $ok = $ftp->_PASS($pass || "");
- }
-
- $ok = $ftp->_ACCT($acct || "")
- if ($ok == CMD_MORE);
+ $hash->{$cmd} ||= 0;
+}
- $ftp->authorize()
- if($ok == CMD_OK && defined ${*$ftp}{'net_ftp_firewall'});
+##
+## Deprecated methods
+##
- $ok == CMD_OK;
+sub lsl
+{
+ carp "Use of Net::FTP::lsl deprecated, use 'dir'"
+ if $^W;
+ goto &dir;
}
-sub authorize
+sub authorise
{
- @_ >= 1 || @_ <= 3 or croak 'usage: $ftp->authorize( [AUTH [, RESP]])';
-
- my($ftp,$auth,$resp) = @_;
-
- unless(defined $resp)
- {
- require Net::Netrc;
-
- $auth ||= (getpwuid($>))[0];
+ carp "Use of Net::FTP::authorise deprecated, use 'authorize'"
+ if $^W;
+ goto &authorize;
+}
- my $rc = Net::Netrc->lookup(${*$ftp}{'net_ftp_firewall'}, $auth)
- || Net::Netrc->lookup(${*$ftp}{'net_ftp_firewall'});
- ($auth,$resp) = $rc->lpa()
- if($rc);
- }
+##
+## Private methods
+##
- my $ok = $ftp->_AUTH($auth || "");
+sub _extract_path
+{
+ my($ftp, $path) = @_;
- $ok = $ftp->_RESP($resp || "")
- if ($ok == CMD_MORE);
+ # This tries to work both with and without the quote doubling
+ # convention (RFC 959 requires it, but the first 3 servers I checked
+ # didn't implement it). It will fail on a server which uses a quote in
+ # the message which isn't a part of or surrounding the path.
+ $ftp->ok &&
+ $ftp->message =~ /(?:^|\s)\"(.*)\"(?:$|\s)/ &&
+ ($path = $1) =~ s/\"\"/\"/g;
- $ok == CMD_OK;
+ $path;
}
-sub rename
+##
+## Communication methods
+##
+
+sub _dataconn
{
- @_ == 3 or croak 'usage: $ftp->rename(FROM, TO)';
+ my $ftp = shift;
+ my $data = undef;
+ my $pkg = "Net::FTP::" . $ftp->type;
- my($ftp,$from,$to) = @_;
+ eval "require " . $pkg;
- $ftp->_RNFR($from)
- && $ftp->_RNTO($to);
-}
+ $pkg =~ s/ /_/g;
-sub type
-{
- my $ftp = shift;
- my $type = shift;
- my $oldval = ${*$ftp}{'net_ftp_type'};
+ delete ${*$ftp}{'net_ftp_dataconn'};
- return $oldval
- unless (defined $type);
+ if(defined ${*$ftp}{'net_ftp_pasv'})
+ {
+ my @port = split(/,/,${*$ftp}{'net_ftp_pasv'});
- return undef
- unless ($ftp->_TYPE($type,@_));
+ $data = $pkg->new(PeerAddr => join(".",@port[0..3]),
+ PeerPort => $port[4] * 256 + $port[5],
+ Proto => 'tcp'
+ );
+ }
+ elsif(defined ${*$ftp}{'net_ftp_listen'})
+ {
+ $data = ${*$ftp}{'net_ftp_listen'}->accept($pkg);
+ close(delete ${*$ftp}{'net_ftp_listen'});
+ }
- ${*$ftp}{'net_ftp_type'} = join(" ",$type,@_);
+ if($data)
+ {
+ ${*$data} = "";
+ $data->timeout($ftp->timeout);
+ ${*$ftp}{'net_ftp_dataconn'} = $data;
+ ${*$data}{'net_ftp_cmd'} = $ftp;
+ ${*$data}{'net_ftp_blksize'} = ${*$ftp}{'net_ftp_blksize'};
+ }
- $oldval;
+ $data;
}
-sub abort
+sub _list_cmd
{
my $ftp = shift;
+ my $cmd = uc shift;
- send($ftp,pack("CC",TELNET_IAC,TELNET_IP),0);
- send($ftp,pack("C", TELNET_IAC),MSG_OOB);
- send($ftp,pack("C", TELNET_DM),0);
+ delete ${*$ftp}{'net_ftp_port'};
+ delete ${*$ftp}{'net_ftp_pasv'};
- $ftp->command("ABOR");
+ my $data = $ftp->_data_cmd($cmd,@_);
- defined ${*$ftp}{'net_ftp_dataconn'}
- ? ${*$ftp}{'net_ftp_dataconn'}->close()
- : $ftp->response();
+ return
+ unless(defined $data);
- $ftp->response()
- if $ftp->status == CMD_REJECT;
+ require Net::FTP::A;
+ bless $data, "Net::FTP::A"; # Force ASCII mode
- $ftp->status == CMD_OK;
-}
+ my $databuf = '';
+ my $buf = '';
+ my $blksize = ${*$ftp}{'net_ftp_blksize'};
-sub get
-{
- my($ftp,$remote,$local,$where) = @_;
+ while($data->read($databuf,$blksize)) {
+ $buf .= $databuf;
+ }
- my($loc,$len,$buf,$resp,$localfd,$data);
- local *FD;
+ my $list = [ split(/\n/,$buf) ];
- $localfd = ref($local) ? fileno($local)
- : undef;
+ $data->close();
- ($local = $remote) =~ s#^.*/##
- unless(defined $local);
+ if (trEBCDIC)
+ {
+ for (@$list) { $_ = $ftp->toebcdic($_) }
+ }
- ${*$ftp}{'net_ftp_rest'} = $where
- if ($where);
+ wantarray ? @{$list}
+ : $list;
+}
- delete ${*$ftp}{'net_ftp_port'};
- delete ${*$ftp}{'net_ftp_pasv'};
+sub _data_cmd
+{
+ my $ftp = shift;
+ my $cmd = uc shift;
+ my $ok = 1;
+ my $where = delete ${*$ftp}{'net_ftp_rest'} || 0;
+ my $arg;
- $data = $ftp->retr($remote) or
- return undef;
+ for $arg (@_) {
+ croak("Bad argument '$arg'\n")
+ if $arg =~ /[\r\n]/s;
+ }
- if(defined $localfd)
- {
- $loc = $local;
- }
- else
+ if(${*$ftp}{'net_ftp_passive'} &&
+ !defined ${*$ftp}{'net_ftp_pasv'} &&
+ !defined ${*$ftp}{'net_ftp_port'})
{
- $loc = \*FD;
+ my $data = undef;
+
+ $ok = defined $ftp->pasv;
+ $ok = $ftp->_REST($where)
+ if $ok && $where;
- unless(($where) ? open($loc,">>$local") : open($loc,">$local"))
+ if($ok)
{
- carp "Cannot open Local file $local: $!\n";
- $data->abort;
- return undef;
+ $ftp->command($cmd,@_);
+ $data = $ftp->_dataconn();
+ $ok = CMD_INFO == $ftp->response();
+ if($ok)
+ {
+ $data->reading
+ if $data && $cmd =~ /RETR|LIST|NLST/;
+ return $data
+ }
+ $data->_close
+ if $data;
}
+ return undef;
}
- if ($ftp->binary && !binmode($loc))
- {
- carp "Cannot binmode Local file $local: $!\n";
- return undef;
- }
- $buf = '';
+ $ok = $ftp->port
+ unless (defined ${*$ftp}{'net_ftp_port'} ||
+ defined ${*$ftp}{'net_ftp_pasv'});
- do
- {
- $len = $data->read($buf,1024);
- }
- while($len > 0 && syswrite($loc,$buf,$len) == $len);
+ $ok = $ftp->_REST($where)
+ if $ok && $where;
- close($loc)
- unless defined $localfd;
-
- $data->close(); # implied $ftp->response
+ return undef
+ unless $ok;
- return $local;
-}
+ $ftp->command($cmd,@_);
-sub cwd
-{
- @_ == 2 || @_ == 3 or croak 'usage: $ftp->cwd( [ DIR ] )';
+ return 1
+ if(defined ${*$ftp}{'net_ftp_pasv'});
- my($ftp,$dir) = @_;
+ $ok = CMD_INFO == $ftp->response();
- $dir ||= "/";
+ return $ok
+ unless exists ${*$ftp}{'net_ftp_intern_port'};
- $dir eq ".."
- ? $ftp->_CDUP()
- : $ftp->_CWD($dir);
-}
+ if($ok) {
+ my $data = $ftp->_dataconn();
-sub cdup
-{
- @_ == 1 or croak 'usage: $ftp->cdup()';
- $_[0]->_CDUP;
+ $data->reading
+ if $data && $cmd =~ /RETR|LIST|NLST/;
+
+ return $data;
+ }
+
+
+ close(delete ${*$ftp}{'net_ftp_listen'});
+
+ return undef;
}
-sub pwd
+##
+## Over-ride methods (Net::Cmd)
+##
+
+sub debug_text { $_[2] =~ /^(pass|resp|acct)/i ? "$1 ....\n" : $_[2]; }
+
+sub command
{
- @_ == 1 || croak 'usage: $ftp->pwd()';
my $ftp = shift;
- $ftp->_PWD();
- $ftp->_extract_path;
+ delete ${*$ftp}{'net_ftp_port'};
+ $ftp->SUPER::command(@_);
}
-sub rmdir
+sub response
{
- @_ == 2 || croak 'usage: $ftp->rmdir( DIR )';
+ my $ftp = shift;
+ my $code = $ftp->SUPER::response();
+
+ delete ${*$ftp}{'net_ftp_pasv'}
+ if ($code != CMD_MORE && $code != CMD_INFO);
- $_[0]->_RMD($_[1]);
+ $code;
}
-sub mkdir
+sub parse_response
{
- @_ == 2 || @_ == 3 or croak 'usage: $ftp->mkdir( DIR [, RECURSE ] )';
+ return ($1, $2 eq "-")
+ if $_[1] =~ s/^(\d\d\d)(.?)//o;
- my($ftp,$dir,$recurse) = @_;
+ my $ftp = shift;
- $ftp->_MKD($dir) || $recurse or
- return undef;
+ # Darn MS FTP server is a load of CRAP !!!!
+ return ()
+ unless ${*$ftp}{'net_cmd_code'} + 0;
- my $path = undef;
- unless($ftp->ok)
- {
- my @path = split(m#(?=/+)#, $dir);
+ (${*$ftp}{'net_cmd_code'},1);
+}
- $path = "";
+##
+## Allow 2 servers to talk directly
+##
- while(@path)
- {
- $path .= shift @path;
+sub pasv_xfer {
+ my($sftp,$sfile,$dftp,$dfile,$unique) = @_;
- $ftp->_MKD($path);
- $path = $ftp->_extract_path($path);
+ ($dfile = $sfile) =~ s#.*/##
+ unless(defined $dfile);
+
+ my $port = $sftp->pasv or
+ return undef;
+
+ $dftp->port($port) or
+ return undef;
- # 521 means directory already exists
- last
- unless $ftp->ok || $ftp->code == 521;
+ return undef
+ unless($unique ? $dftp->stou($dfile) : $dftp->stor($dfile));
+
+ unless($sftp->retr($sfile) && $sftp->response == CMD_INFO) {
+ $sftp->retr($sfile);
+ $dftp->abort;
+ $dftp->response();
+ return undef;
}
- }
- $ftp->_extract_path($path);
+ $dftp->pasv_wait($sftp);
}
-sub delete
+sub pasv_wait
{
- @_ == 2 || croak 'usage: $ftp->delete( FILENAME )';
+ @_ == 2 or croak 'usage: $ftp->pasv_wait(NON_PASV_FTP)';
- $_[0]->_DELE($_[1]);
+ my($ftp, $non_pasv) = @_;
+ my($file,$rin,$rout);
+
+ vec($rin='',fileno($ftp),1) = 1;
+ select($rout=$rin, undef, undef, undef);
+
+ $ftp->response();
+ $non_pasv->response();
+
+ return undef
+ unless $ftp->ok() && $non_pasv->ok();
+
+ return $1
+ if $ftp->message =~ /unique file name:\s*(\S*)\s*\)/;
+
+ return $1
+ if $non_pasv->message =~ /unique file name:\s*(\S*)\s*\)/;
+
+ return 1;
}
-sub put { shift->_store_cmd("stor",@_) }
-sub put_unique { shift->_store_cmd("stou",@_) }
-sub append { shift->_store_cmd("appe",@_) }
+sub cmd { shift->command(@_)->response() }
-sub nlst { shift->_data_cmd("NLST",@_) }
-sub list { shift->_data_cmd("LIST",@_) }
-sub retr { shift->_data_cmd("RETR",@_) }
-sub stor { shift->_data_cmd("STOR",@_) }
-sub stou { shift->_data_cmd("STOU",@_) }
-sub appe { shift->_data_cmd("APPE",@_) }
+########################################
+#
+# RFC959 commands
+#
-sub _store_cmd
-{
- my($ftp,$cmd,$local,$remote) = @_;
- my($loc,$sock,$len,$buf,$localfd);
- local *FD;
+sub _ABOR { shift->command("ABOR")->response() == CMD_OK }
+sub _CDUP { shift->command("CDUP")->response() == CMD_OK }
+sub _NOOP { shift->command("NOOP")->response() == CMD_OK }
+sub _PASV { shift->command("PASV")->response() == CMD_OK }
+sub _QUIT { shift->command("QUIT")->response() == CMD_OK }
+sub _DELE { shift->command("DELE",@_)->response() == CMD_OK }
+sub _CWD { shift->command("CWD", @_)->response() == CMD_OK }
+sub _PORT { shift->command("PORT",@_)->response() == CMD_OK }
+sub _RMD { shift->command("RMD", @_)->response() == CMD_OK }
+sub _MKD { shift->command("MKD", @_)->response() == CMD_OK }
+sub _PWD { shift->command("PWD", @_)->response() == CMD_OK }
+sub _TYPE { shift->command("TYPE",@_)->response() == CMD_OK }
+sub _RNTO { shift->command("RNTO",@_)->response() == CMD_OK }
+sub _RESP { shift->command("RESP",@_)->response() == CMD_OK }
+sub _MDTM { shift->command("MDTM",@_)->response() == CMD_OK }
+sub _SIZE { shift->command("SIZE",@_)->response() == CMD_OK }
+sub _HELP { shift->command("HELP",@_)->response() == CMD_OK }
+sub _STAT { shift->command("STAT",@_)->response() == CMD_OK }
+sub _APPE { shift->command("APPE",@_)->response() == CMD_INFO }
+sub _LIST { shift->command("LIST",@_)->response() == CMD_INFO }
+sub _NLST { shift->command("NLST",@_)->response() == CMD_INFO }
+sub _RETR { shift->command("RETR",@_)->response() == CMD_INFO }
+sub _STOR { shift->command("STOR",@_)->response() == CMD_INFO }
+sub _STOU { shift->command("STOU",@_)->response() == CMD_INFO }
+sub _RNFR { shift->command("RNFR",@_)->response() == CMD_MORE }
+sub _REST { shift->command("REST",@_)->response() == CMD_MORE }
+sub _USER { shift->command("user",@_)->response() } # A certain brain dead firewall :-)
+sub _PASS { shift->command("PASS",@_)->response() }
+sub _ACCT { shift->command("ACCT",@_)->response() }
+sub _AUTH { shift->command("AUTH",@_)->response() }
- $localfd = ref($local) ? fileno($local)
- : undef;
+sub _ALLO { shift->unsupported(@_) }
+sub _SMNT { shift->unsupported(@_) }
+sub _MODE { shift->unsupported(@_) }
+sub _SYST { shift->unsupported(@_) }
+sub _STRU { shift->unsupported(@_) }
+sub _REIN { shift->unsupported(@_) }
- unless(defined $remote)
- {
- croak 'Must specify remote filename with stream input'
- if defined $localfd;
+1;
- ($remote = $local) =~ s%.*/%%;
- }
+__END__
- if(defined $localfd)
- {
- $loc = $local;
- }
- else
- {
- $loc = \*FD;
+=head1 NAME
- unless(open($loc,"<$local"))
- {
- carp "Cannot open Local file $local: $!\n";
- return undef;
- }
- if ($ftp->binary && !binmode($loc))
- {
- carp "Cannot binmode Local file $local: $!\n";
- return undef;
- }
- }
+Net::FTP - FTP Client class
- delete ${*$ftp}{'net_ftp_port'};
- delete ${*$ftp}{'net_ftp_pasv'};
+=head1 SYNOPSIS
- $sock = $ftp->_data_cmd($cmd, $remote) or
- return undef;
+ use Net::FTP;
- do
- {
- $len = sysread($loc,$buf="",1024);
- }
- while($len && $sock->write($buf,$len) == $len);
+ $ftp = Net::FTP->new("some.host.name", Debug => 0);
+ $ftp->login("anonymous",'-anonymous@');
+ $ftp->cwd("/pub");
+ $ftp->get("that.file");
+ $ftp->quit;
- close($loc)
- unless defined $localfd;
+=head1 DESCRIPTION
- $sock->close();
+C<Net::FTP> is a class implementing a simple FTP client in Perl as
+described in RFC959. It provides wrappers for a subset of the RFC959
+commands.
+
+=head1 OVERVIEW
+
+FTP stands for File Transfer Protocol. It is a way of transferring
+files between networked machines. The protocol defines a client
+(whose commands are provided by this module) and a server (not
+implemented in this module). Communication is always initiated by the
+client, and the server responds with a message and a status code (and
+sometimes with data).
+
+The FTP protocol allows files to be sent to or fetched from the
+server. Each transfer involves a B<local file> (on the client) and a
+B<remote file> (on the server). In this module, the same file name
+will be used for both local and remote if only one is specified. This
+means that transferring remote file C</path/to/file> will try to put
+that file in C</path/to/file> locally, unless you specify a local file
+name.
+
+The protocol also defines several standard B<translations> which the
+file can undergo during transfer. These are ASCII, EBCDIC, binary,
+and byte. ASCII is the default type, and indicates that the sender of
+files will translate the ends of lines to a standard representation
+which the receiver will then translate back into their local
+representation. EBCDIC indicates the file being transferred is in
+EBCDIC format. Binary (also known as image) format sends the data as
+a contiguous bit stream. Byte format transfers the data as bytes, the
+values of which remain the same regardless of differences in byte size
+between the two machines (in theory - in practice you should only use
+this if you really know what you're doing).
- ($remote) = $ftp->message =~ /unique file name:\s*(\S*)\s*\)/
- if ('STOU' eq uc $cmd);
+=head1 CONSTRUCTOR
- return $remote;
-}
+=over 4
-sub port
-{
- @_ == 1 || @_ == 2 or croak 'usage: $ftp->port([PORT])';
+=item new (HOST [,OPTIONS])
- my($ftp,$port) = @_;
- my $ok;
+This is the constructor for a new Net::FTP object. C<HOST> is the
+name of the remote host to which an FTP connection is required.
- delete ${*$ftp}{'net_ftp_intern_port'};
+C<OPTIONS> are passed in a hash like fashion, using key and value pairs.
+Possible options are:
- unless(defined $port)
- {
- # create a Listen socket at same address as the command socket
+B<Firewall> - The name of a machine which acts as an FTP firewall. This can be
+overridden by an environment variable C<FTP_FIREWALL>. If specified, and the
+given host cannot be directly connected to, then the
+connection is made to the firewall machine and the string C<@hostname> is
+appended to the login identifier. This kind of setup is also refered to
+as an ftp proxy.
- ${*$ftp}{'net_ftp_listen'} ||= IO::Socket::INET->new(Listen => 5,
- Proto => 'tcp',
- LocalAddr => $ftp->sockhost,
- );
-
- my $listen = ${*$ftp}{'net_ftp_listen'};
+B<FirewallType> - The type of firewall running on the machine indicated by
+B<Firewall>. This can be overridden by an environment variable
+C<FTP_FIREWALL_TYPE>. For a list of permissible types, see the description of
+ftp_firewall_type in L<Net::Config>.
- my($myport, @myaddr) = ($listen->sockport, split(/\./,$listen->sockhost));
+B<BlockSize> - This is the block size that Net::FTP will use when doing
+transfers. (defaults to 10240)
- $port = join(',', @myaddr, $myport >> 8, $myport & 0xff);
+B<Port> - The port number to connect to on the remote machine for the
+FTP connection
- ${*$ftp}{'net_ftp_intern_port'} = 1;
- }
+B<Timeout> - Set a timeout value (defaults to 120)
- $ok = $ftp->_PORT($port);
+B<Debug> - debug level (see the debug method in L<Net::Cmd>)
- ${*$ftp}{'net_ftp_port'} = $port;
+B<Passive> - If set to a non-zero value then all data transfers will be done
+using passive mode. This is not usually required except for some I<dumb>
+servers, and some firewall configurations. This can also be set by the
+environment variable C<FTP_PASSIVE>.
- $ok;
-}
+B<Hash> - If given a reference to a file handle (e.g., C<\*STDERR>),
+print hash marks (#) on that filehandle every 1024 bytes. This
+simply invokes the C<hash()> method for you, so that hash marks
+are displayed for all transfers. You can, of course, call C<hash()>
+explicitly whenever you'd like.
-sub ls { shift->_list_cmd("NLST",@_); }
-sub dir { shift->_list_cmd("LIST",@_); }
+If the constructor fails undef will be returned and an error message will
+be in $@
-sub pasv
-{
- @_ == 1 or croak 'usage: $ftp->pasv()';
+=back
- my $ftp = shift;
+=head1 METHODS
- delete ${*$ftp}{'net_ftp_intern_port'};
+Unless otherwise stated all methods return either a I<true> or I<false>
+value, with I<true> meaning that the operation was a success. When a method
+states that it returns a value, failure will be returned as I<undef> or an
+empty list.
- $ftp->_PASV && $ftp->message =~ /(\d+(,\d+)+)/
- ? ${*$ftp}{'net_ftp_pasv'} = $1
- : undef;
-}
+=over 4
-sub unique_name
-{
- my $ftp = shift;
- ${*$ftp}{'net_ftp_unique'} || undef;
-}
+=item login ([LOGIN [,PASSWORD [, ACCOUNT] ] ])
-##
-## Depreciated methods
-##
+Log into the remote FTP server with the given login information. If
+no arguments are given then the C<Net::FTP> uses the C<Net::Netrc>
+package to lookup the login information for the connected host.
+If no information is found then a login of I<anonymous> is used.
+If no password is given and the login is I<anonymous> then I<anonymous@>
+will be used for password.
-sub lsl
-{
- carp "Use of Net::FTP::lsl depreciated, use 'dir'"
- if $^W;
- goto &dir;
-}
+If the connection is via a firewall then the C<authorize> method will
+be called with no arguments.
-sub authorise
-{
- carp "Use of Net::FTP::authorise depreciated, use 'authorize'"
- if $^W;
- goto &authorize;
-}
+=item authorize ( [AUTH [, RESP]])
+This is a protocol used by some firewall ftp proxies. It is used
+to authorise the user to send data out. If both arguments are not specified
+then C<authorize> uses C<Net::Netrc> to do a lookup.
-##
-## Private methods
-##
+=item site (ARGS)
-sub _extract_path
-{
- my($ftp, $path) = @_;
+Send a SITE command to the remote server and wait for a response.
- $ftp->ok &&
- $ftp->message =~ /\s\"(.*)\"\s/o &&
- ($path = $1) =~ s/\"\"/\"/g;
+Returns most significant digit of the response code.
- $path;
-}
+=item type (TYPE [, ARGS])
-##
-## Communication methods
-##
+This method will send the TYPE command to the remote FTP server
+to change the type of data transfer. The return value is the previous
+value.
-sub _dataconn
-{
- my $ftp = shift;
- my $data = undef;
- my $pkg = "Net::FTP::" . $ftp->type;
+=item ascii ([ARGS]) binary([ARGS]) ebcdic([ARGS]) byte([ARGS])
- $pkg =~ s/ /_/g;
+Synonyms for C<type> with the first arguments set correctly
- delete ${*$ftp}{'net_ftp_dataconn'};
+B<NOTE> ebcdic and byte are not fully supported.
- if(defined ${*$ftp}{'net_ftp_pasv'})
- {
- my @port = split(/,/,${*$ftp}{'net_ftp_pasv'});
+=item rename ( OLDNAME, NEWNAME )
- $data = $pkg->new(PeerAddr => join(".",@port[0..3]),
- PeerPort => $port[4] * 256 + $port[5],
- Proto => 'tcp'
- );
- }
- elsif(defined ${*$ftp}{'net_ftp_listen'})
- {
- $data = ${*$ftp}{'net_ftp_listen'}->accept($pkg);
- close(delete ${*$ftp}{'net_ftp_listen'});
- }
+Rename a file on the remote FTP server from C<OLDNAME> to C<NEWNAME>. This
+is done by sending the RNFR and RNTO commands.
- if($data)
- {
- ${*$data} = "";
- $data->timeout($ftp->timeout);
- ${*$ftp}{'net_ftp_dataconn'} = $data;
- ${*$data}{'net_ftp_cmd'} = $ftp;
- }
+=item delete ( FILENAME )
- $data;
-}
+Send a request to the server to delete C<FILENAME>.
-sub _list_cmd
-{
- my $ftp = shift;
- my $cmd = uc shift;
+=item cwd ( [ DIR ] )
- delete ${*$ftp}{'net_ftp_port'};
- delete ${*$ftp}{'net_ftp_pasv'};
+Attempt to change directory to the directory given in C<$dir>. If
+C<$dir> is C<"..">, the FTP C<CDUP> command is used to attempt to
+move up one directory. If no directory is given then an attempt is made
+to change the directory to the root directory.
- my $data = $ftp->_data_cmd($cmd,@_);
+=item cdup ()
- return undef
- unless(defined $data);
+Change directory to the parent of the current directory.
- bless $data, "Net::FTP::A"; # Force ASCII mode
+=item pwd ()
- my $databuf = '';
- my $buf = '';
+Returns the full pathname of the current directory.
- while($data->read($databuf,1024))
- {
- $buf .= $databuf;
- }
+=item restart ( WHERE )
- my $list = [ split(/\n/,$buf) ];
+Set the byte offset at which to begin the next data transfer. Net::FTP simply
+records this value and uses it when during the next data transfer. For this
+reason this method will not return an error, but setting it may cause
+a subsequent data transfer to fail.
- $data->close();
+=item rmdir ( DIR )
+
+Remove the directory with the name C<DIR>.
+
+=item mkdir ( DIR [, RECURSE ])
+
+Create a new directory with the name C<DIR>. If C<RECURSE> is I<true> then
+C<mkdir> will attempt to create all the directories in the given path.
+
+Returns the full pathname to the new directory.
+
+=item ls ( [ DIR ] )
+
+Get a directory listing of C<DIR>, or the current directory.
+
+In an array context, returns a list of lines returned from the server. In
+a scalar context, returns a reference to a list.
+
+=item dir ( [ DIR ] )
+
+Get a directory listing of C<DIR>, or the current directory in long format.
+
+In an array context, returns a list of lines returned from the server. In
+a scalar context, returns a reference to a list.
+
+=item get ( REMOTE_FILE [, LOCAL_FILE [, WHERE]] )
+
+Get C<REMOTE_FILE> from the server and store locally. C<LOCAL_FILE> may be
+a filename or a filehandle. If not specified, the file will be stored in
+the current directory with the same leafname as the remote file.
+
+If C<WHERE> is given then the first C<WHERE> bytes of the file will
+not be transfered, and the remaining bytes will be appended to
+the local file if it already exists.
+
+Returns C<LOCAL_FILE>, or the generated local file name if C<LOCAL_FILE>
+is not given. If an error was encountered undef is returned.
+
+=item put ( LOCAL_FILE [, REMOTE_FILE ] )
+
+Put a file on the remote server. C<LOCAL_FILE> may be a name or a filehandle.
+If C<LOCAL_FILE> is a filehandle then C<REMOTE_FILE> must be specified. If
+C<REMOTE_FILE> is not specified then the file will be stored in the current
+directory with the same leafname as C<LOCAL_FILE>.
+
+Returns C<REMOTE_FILE>, or the generated remote filename if C<REMOTE_FILE>
+is not given.
+
+B<NOTE>: If for some reason the transfer does not complete and an error is
+returned then the contents that had been transfered will not be remove
+automatically.
+
+=item put_unique ( LOCAL_FILE [, REMOTE_FILE ] )
+
+Same as put but uses the C<STOU> command.
+
+Returns the name of the file on the server.
+
+=item append ( LOCAL_FILE [, REMOTE_FILE ] )
+
+Same as put but appends to the file on the remote server.
+
+Returns C<REMOTE_FILE>, or the generated remote filename if C<REMOTE_FILE>
+is not given.
+
+=item unique_name ()
+
+Returns the name of the last file stored on the server using the
+C<STOU> command.
+
+=item mdtm ( FILE )
+
+Returns the I<modification time> of the given file
+
+=item size ( FILE )
+
+Returns the size in bytes for the given file as stored on the remote server.
+
+B<NOTE>: The size reported is the size of the stored file on the remote server.
+If the file is subsequently transfered from the server in ASCII mode
+and the remote server and local machine have different ideas about
+"End Of Line" then the size of file on the local machine after transfer
+may be different.
+
+=item supported ( CMD )
+
+Returns TRUE if the remote server supports the given command.
+
+=item hash ( [FILEHANDLE_GLOB_REF],[ BYTES_PER_HASH_MARK] )
+
+Called without parameters, or with the first argument false, hash marks
+are suppressed. If the first argument is true but not a reference to a
+file handle glob, then \*STDERR is used. The second argument is the number
+of bytes per hash mark printed, and defaults to 1024. In all cases the
+return value is a reference to an array of two: the filehandle glob reference
+and the bytes per hash mark.
- wantarray ? @{$list}
- : $list;
-}
+=back
-sub _data_cmd
-{
- my $ftp = shift;
- my $cmd = uc shift;
- my $ok = 1;
- my $where = delete ${*$ftp}{'net_ftp_rest'} || 0;
+The following methods can return different results depending on
+how they are called. If the user explicitly calls either
+of the C<pasv> or C<port> methods then these methods will
+return a I<true> or I<false> value. If the user does not
+call either of these methods then the result will be a
+reference to a C<Net::FTP::dataconn> based object.
- if(${*$ftp}{'net_ftp_passive'} &&
- !defined ${*$ftp}{'net_ftp_pasv'} &&
- !defined ${*$ftp}{'net_ftp_port'})
- {
- my $data = undef;
+=over 4
- $ok = defined $ftp->pasv;
- $ok = $ftp->_REST($where)
- if $ok && $where;
+=item nlst ( [ DIR ] )
- if($ok)
- {
- $ftp->command($cmd,@_);
- $data = $ftp->_dataconn();
- $ok = CMD_INFO == $ftp->response();
- }
- return $ok ? $data
- : undef;
- }
+Send an C<NLST> command to the server, with an optional parameter.
- $ok = $ftp->port
- unless (defined ${*$ftp}{'net_ftp_port'} ||
- defined ${*$ftp}{'net_ftp_pasv'});
+=item list ( [ DIR ] )
- $ok = $ftp->_REST($where)
- if $ok && $where;
+Same as C<nlst> but using the C<LIST> command
- return undef
- unless $ok;
+=item retr ( FILE )
- $ftp->command($cmd,@_);
+Begin the retrieval of a file called C<FILE> from the remote server.
- return 1
- if(defined ${*$ftp}{'net_ftp_pasv'});
+=item stor ( FILE )
- $ok = CMD_INFO == $ftp->response();
+Tell the server that you wish to store a file. C<FILE> is the
+name of the new file that should be created.
- return $ok
- unless exists ${*$ftp}{'net_ftp_intern_port'};
+=item stou ( FILE )
- $ok ? $ftp->_dataconn()
- : undef;
-}
+Same as C<stor> but using the C<STOU> command. The name of the unique
+file which was created on the server will be available via the C<unique_name>
+method after the data connection has been closed.
-##
-## Over-ride methods (Net::Cmd)
-##
+=item appe ( FILE )
-sub debug_text { $_[2] =~ /^(pass|resp)/i ? "$1 ....\n" : $_[2]; }
+Tell the server that we want to append some data to the end of a file
+called C<FILE>. If this file does not exist then create it.
-sub command
-{
- my $ftp = shift;
+=back
- delete ${*$ftp}{'net_ftp_port'};
- $ftp->SUPER::command(@_);
-}
+If for some reason you want to have complete control over the data connection,
+this includes generating it and calling the C<response> method when required,
+then the user can use these methods to do so.
-sub response
-{
- my $ftp = shift;
- my $code = $ftp->SUPER::response();
+However calling these methods only affects the use of the methods above that
+can return a data connection. They have no effect on methods C<get>, C<put>,
+C<put_unique> and those that do not require data connections.
- delete ${*$ftp}{'net_ftp_pasv'}
- if ($code != CMD_MORE && $code != CMD_INFO);
+=over 4
- $code;
-}
+=item port ( [ PORT ] )
-##
-## Allow 2 servers to talk directly
-##
+Send a C<PORT> command to the server. If C<PORT> is specified then it is sent
+to the server. If not, then a listen socket is created and the correct information
+sent to the server.
-sub pasv_xfer
-{
- my($sftp,$sfile,$dftp,$dfile) = @_;
+=item pasv ()
- ($dfile = $sfile) =~ s#.*/##
- unless(defined $dfile);
+Tell the server to go into passive mode. Returns the text that represents the
+port on which the server is listening, this text is in a suitable form to
+sent to another ftp server using the C<port> method.
- my $port = $sftp->pasv or
- return undef;
+=back
- unless($dftp->port($port) && $sftp->retr($sfile) && $dftp->stou($dfile))
- {
- $sftp->abort;
- $dftp->abort;
- return undef;
- }
+The following methods can be used to transfer files between two remote
+servers, providing that these two servers can connect directly to each other.
- $dftp->pasv_wait($sftp);
-}
+=over 4
-sub pasv_wait
-{
- @_ == 2 or croak 'usage: $ftp->pasv_wait(NON_PASV_FTP)';
+=item pasv_xfer ( SRC_FILE, DEST_SERVER [, DEST_FILE ] )
- my($ftp, $non_pasv) = @_;
- my($file,$rin,$rout);
+This method will do a file transfer between two remote ftp servers. If
+C<DEST_FILE> is omitted then the leaf name of C<SRC_FILE> will be used.
- vec($rin,fileno($ftp),1) = 1;
- select($rout=$rin, undef, undef, undef);
+=item pasv_xfer_unique ( SRC_FILE, DEST_SERVER [, DEST_FILE ] )
- $ftp->response();
- $non_pasv->response();
+Like C<pasv_xfer> but the file is stored on the remote server using
+the STOU command.
- return undef
- unless $ftp->ok() && $non_pasv->ok();
+=item pasv_wait ( NON_PASV_SERVER )
- return $1
- if $ftp->message =~ /unique file name:\s*(\S*)\s*\)/;
+This method can be used to wait for a transfer to complete between a passive
+server and a non-passive server. The method should be called on the passive
+server with the C<Net::FTP> object for the non-passive server passed as an
+argument.
- return $1
- if $non_pasv->message =~ /unique file name:\s*(\S*)\s*\)/;
+=item abort ()
- return 1;
-}
+Abort the current data transfer.
-sub cmd { shift->command(@_)->responce() }
+=item quit ()
-########################################
-#
-# RFC959 commands
-#
+Send the QUIT command to the remote FTP server and close the socket connection.
-sub _ABOR { shift->command("ABOR")->response() == CMD_OK }
-sub _CDUP { shift->command("CDUP")->response() == CMD_OK }
-sub _NOOP { shift->command("NOOP")->response() == CMD_OK }
-sub _PASV { shift->command("PASV")->response() == CMD_OK }
-sub _QUIT { shift->command("QUIT")->response() == CMD_OK }
-sub _DELE { shift->command("DELE",@_)->response() == CMD_OK }
-sub _CWD { shift->command("CWD", @_)->response() == CMD_OK }
-sub _PORT { shift->command("PORT",@_)->response() == CMD_OK }
-sub _RMD { shift->command("RMD", @_)->response() == CMD_OK }
-sub _MKD { shift->command("MKD", @_)->response() == CMD_OK }
-sub _PWD { shift->command("PWD", @_)->response() == CMD_OK }
-sub _TYPE { shift->command("TYPE",@_)->response() == CMD_OK }
-sub _RNTO { shift->command("RNTO",@_)->response() == CMD_OK }
-sub _ACCT { shift->command("ACCT",@_)->response() == CMD_OK }
-sub _RESP { shift->command("RESP",@_)->response() == CMD_OK }
-sub _MDTM { shift->command("MDTM",@_)->response() == CMD_OK }
-sub _SIZE { shift->command("SIZE",@_)->response() == CMD_OK }
-sub _APPE { shift->command("APPE",@_)->response() == CMD_INFO }
-sub _LIST { shift->command("LIST",@_)->response() == CMD_INFO }
-sub _NLST { shift->command("NLST",@_)->response() == CMD_INFO }
-sub _RETR { shift->command("RETR",@_)->response() == CMD_INFO }
-sub _STOR { shift->command("STOR",@_)->response() == CMD_INFO }
-sub _STOU { shift->command("STOU",@_)->response() == CMD_INFO }
-sub _RNFR { shift->command("RNFR",@_)->response() == CMD_MORE }
-sub _REST { shift->command("REST",@_)->response() == CMD_MORE }
-sub _USER { shift->command("user",@_)->response() } # A certain brain dead firewall :-)
-sub _PASS { shift->command("PASS",@_)->response() }
-sub _AUTH { shift->command("AUTH",@_)->response() }
+=back
-sub _ALLO { shift->unsupported(@_) }
-sub _SMNT { shift->unsupported(@_) }
-sub _HELP { shift->unsupported(@_) }
-sub _MODE { shift->unsupported(@_) }
-sub _SITE { shift->unsupported(@_) }
-sub _SYST { shift->unsupported(@_) }
-sub _STAT { shift->unsupported(@_) }
-sub _STRU { shift->unsupported(@_) }
-sub _REIN { shift->unsupported(@_) }
+=head2 Methods for the adventurous
-##
-## Generic data connection package
-##
+C<Net::FTP> inherits from C<Net::Cmd> so methods defined in C<Net::Cmd> may
+be used to send commands to the remote FTP server.
-package Net::FTP::dataconn;
+=over 4
-use Carp;
-use vars qw(@ISA $timeout);
-use Net::Cmd;
+=item quot (CMD [,ARGS])
-@ISA = qw(IO::Socket::INET);
+Send a command, that Net::FTP does not directly support, to the remote
+server and wait for a response.
-sub abort
-{
- my $data = shift;
- my $ftp = ${*$data}{'net_ftp_cmd'};
+Returns most significant digit of the response code.
- $ftp->abort; # this will close me
-}
+B<WARNING> This call should only be used on commands that do not require
+data connections. Misuse of this method can hang the connection.
-sub close
-{
- my $data = shift;
- my $ftp = ${*$data}{'net_ftp_cmd'};
+=back
- $data->SUPER::close();
+=head1 THE dataconn CLASS
- delete ${*$ftp}{'net_ftp_dataconn'}
- if exists ${*$ftp}{'net_ftp_dataconn'} &&
- $data == ${*$ftp}{'net_ftp_dataconn'};
+Some of the methods defined in C<Net::FTP> return an object which will
+be derived from this class.The dataconn class itself is derived from
+the C<IO::Socket::INET> class, so any normal IO operations can be performed.
+However the following methods are defined in the dataconn class and IO should
+be performed using these.
- $ftp->response() == CMD_OK &&
- $ftp->message =~ /unique file name:\s*(\S*)\s*\)/ &&
- (${*$ftp}{'net_ftp_unique'} = $1);
+=over 4
- $ftp->status == CMD_OK;
-}
+=item read ( BUFFER, SIZE [, TIMEOUT ] )
-sub _select
-{
- my $data = shift;
- local *timeout = \$_[0]; shift;
- my $rw = shift;
+Read C<SIZE> bytes of data from the server and place it into C<BUFFER>, also
+performing any <CRLF> translation necessary. C<TIMEOUT> is optional, if not
+given, the timeout value from the command connection will be used.
- my($rin,$win);
+Returns the number of bytes read before any <CRLF> translation.
- return 1 unless $timeout;
+=item write ( BUFFER, SIZE [, TIMEOUT ] )
- $rin = '';
- vec($rin,fileno($data),1) = 1;
+Write C<SIZE> bytes of data from C<BUFFER> to the server, also
+performing any <CRLF> translation necessary. C<TIMEOUT> is optional, if not
+given, the timeout value from the command connection will be used.
- $win = $rw ? undef : $rin;
- $rin = undef unless $rw;
+Returns the number of bytes written before any <CRLF> translation.
- my $nfound = select($rin, $win, undef, $timeout);
+=item bytes_read ()
- croak "select: $!"
- if $nfound < 0;
+Returns the number of bytes read so far.
- return $nfound;
-}
+=item abort ()
-sub can_read
-{
- my $data = shift;
- local *timeout = \$_[0];
+Abort the current data transfer.
- $data->_select($timeout,1);
-}
+=item close ()
-sub can_write
-{
- my $data = shift;
- local *timeout = \$_[0];
+Close the data connection and get a response from the FTP server. Returns
+I<true> if the connection was closed successfully and the first digit of
+the response from the server was a '2'.
- $data->_select($timeout,0);
-}
+=back
-sub cmd
-{
- my $ftp = shift;
+=head1 UNIMPLEMENTED
- ${*$ftp}{'net_ftp_cmd'};
-}
+The following RFC959 commands have not been implemented:
+=over 4
-@Net::FTP::L::ISA = qw(Net::FTP::I);
-@Net::FTP::E::ISA = qw(Net::FTP::I);
+=item B<ALLO>
-##
-## Package to read/write on ASCII data connections
-##
+Allocates storage for the file to be transferred.
-package Net::FTP::A;
+=item B<SMNT>
-use vars qw(@ISA $buf);
-use Carp;
+Mount a different file system structure without changing login or
+accounting information.
-@ISA = qw(Net::FTP::dataconn);
+=item B<HELP>
-sub read
-{
- my $data = shift;
- local *buf = \$_[0]; shift;
- my $size = shift || croak 'read($buf,$size,[$offset])';
- my $offset = shift || 0;
- my $timeout = $data->timeout;
+Ask the server for "helpful information" (that's what the RFC says) on
+the commands it accepts.
- croak "Bad offset"
- if($offset < 0);
+=item B<MODE>
- $offset = length $buf
- if($offset > length $buf);
+Specifies transfer mode (stream, block or compressed) for file to be
+transferred.
- ${*$data} ||= "";
- my $l = 0;
+=item B<SYST>
- READ:
- {
- $data->can_read($timeout) or
- croak "Timeout";
+Request remote server system identification.
- my $n = sysread($data, ${*$data}, $size, length ${*$data});
+=item B<STAT>
- return $n
- unless($n >= 0);
+Request remote server status.
- ${*$data} =~ s/(\015)?(?!\012)\Z//so;
- my $lf = $1 || "";
+=item B<STRU>
- ${*$data} =~ s/\015\012/\n/sgo;
+Specifies file structure for file to be transferred.
- substr($buf,$offset) = ${*$data};
+=item B<REIN>
- $l += length(${*$data});
- $offset += length(${*$data});
+Reinitialize the connection, flushing all I/O and account information.
- ${*$data} = $lf;
-
- redo READ
- if($l == 0 && $n > 0);
+=back
- if($n == 0 && $l == 0)
- {
- substr($buf,$offset) = ${*$data};
- ${*$data} = "";
- }
- }
+=head1 REPORTING BUGS
- return $l;
-}
+When reporting bugs/problems please include as much information as possible.
+It may be difficult for me to reproduce the problem as almost every setup
+is different.
-sub write
-{
- my $data = shift;
- local *buf = \$_[0]; shift;
- my $size = shift || croak 'write($buf,$size,[$timeout])';
- my $timeout = @_ ? shift : $data->timeout;
+A small script which yields the problem will probably be of help. It would
+also be useful if this script was run with the extra options C<Debug => 1>
+passed to the constructor, and the output sent with the bug report. If you
+cannot include a small script then please include a Debug trace from a
+run of your program which does yield the problem.
- $data->can_write($timeout) or
- croak "Timeout";
+=head1 AUTHOR
- # What is previous pkt ended in \015 or not ??
+Graham Barr <gbarr@pobox.com>
- my $tmp;
- ($tmp = $buf) =~ s/(?!\015)\012/\015\012/sg;
+=head1 SEE ALSO
- my $len = $size + length($tmp) - length($buf);
- my $wrote = syswrite($data, $tmp, $len);
+L<Net::Netrc>
+L<Net::Cmd>
- if($wrote >= 0)
- {
- $wrote = $wrote == $len ? $size
- : $len - $wrote
- }
+ftp(1), ftpd(8), RFC 959
+http://www.cis.ohio-state.edu/htbin/rfc/rfc959.html
- return $wrote;
-}
+=head1 USE EXAMPLES
-##
-## Package to read/write on BINARY data connections
-##
+For an example of the use of Net::FTP see
-package Net::FTP::I;
+=over 4
-use vars qw(@ISA $buf);
-use Carp;
+=item http://www.csh.rit.edu/~adam/Progs/autoftp-2.0.tar.gz
-@ISA = qw(Net::FTP::dataconn);
+C<autoftp> is a program that can retrieve, send, or list files via
+the FTP protocol in a non-interactive manner.
-sub read
-{
- my $data = shift;
- local *buf = \$_[0]; shift;
- my $size = shift || croak 'read($buf,$size,[$timeout])';
- my $timeout = @_ ? shift : $data->timeout;
+=back
- $data->can_read($timeout) or
- croak "Timeout";
+=head1 CREDITS
- my $n = sysread($data, $buf, $size);
+Henry Gabryjelski <henryg@WPI.EDU> - for the suggestion of creating directories
+recursively.
- $n;
-}
+Nathan Torkington <gnat@frii.com> - for some input on the documentation.
-sub write
-{
- my $data = shift;
- local *buf = \$_[0]; shift;
- my $size = shift || croak 'write($buf,$size,[$timeout])';
- my $timeout = @_ ? shift : $data->timeout;
+Roderick Schertler <roderick@gate.net> - for various inputs
- $data->can_write($timeout) or
- croak "Timeout";
+=head1 COPYRIGHT
- syswrite($data, $buf, $size);
-}
+Copyright (c) 1995-1998 Graham Barr. All rights reserved.
+This program is free software; you can redistribute it and/or modify it
+under the same terms as Perl itself.
+=for html <hr>
-1;
+I<$Id: //depot/libnet/Net/FTP.pm#68 $>
+=cut