package Net::SSH;
use strict;
-use vars qw($VERSION @ISA @EXPORT_OK $ssh $DEBUG);
+use vars qw($VERSION @ISA @EXPORT_OK $ssh $equalspace $DEBUG @ssh_options);
use Exporter;
+use POSIX ":sys_wait_h";
use IO::File;
+use IO::Select;
use IPC::Open2;
use IPC::Open3;
@ISA = qw(Exporter);
@EXPORT_OK = qw( ssh issh ssh_cmd sshopen2 sshopen3 );
-$VERSION = '0.04';
+$VERSION = '0.08';
$DEBUG = 0;
issh('user@hostname', $command);
ssh_cmd('user@hostname', $command);
+ ssh_cmd( {
+ user => 'user',
+ host => 'host.name',
+ command => 'command',
+ args => [ '-arg1', '-arg2' ],
+ stdin_string => "string\n",
+ } );
sshopen2('user@hostname', $reader, $writer, $command);
Simple wrappers around ssh commands.
+For an all-perl implementation that does not require the system B<ssh> command,
+see L<Net::SSH::Perl> instead.
+
=head1 SUBROUTINES
=over 4
sub ssh {
my($host, @command) = @_;
- my @cmd = ($ssh, '-o', 'BatchMode=yes', $host, @command);
+ @ssh_options = &_ssh_options unless @ssh_options;
+ my @cmd = ($ssh, @ssh_options, $host, @command);
warn "[Net::SSH::ssh] executing ". join(' ', @cmd). "\n"
if $DEBUG;
system(@cmd);
=item ssh_cmd [USER@]HOST, COMMAND [, ARGS ... ]
-Calls ssh in batch mode. Dies if data occurs on the error stream. Warns
-of data on the output stream.
+=item ssh_cmd OPTIONS_HASHREF
+
+Calls ssh in batch mode. Throws a fatal error if data occurs on the command's
+STDERR. Returns any data from the command's STDOUT.
+
+If using the hashref-style of passing arguments, possible keys are:
+
+ user (optional)
+ host (requried)
+ command (required)
+ args (optional, arrayref)
+ stdin_string (optional) - written to the command's STDIN
=cut
sub ssh_cmd {
- my($host, @command) = @_;
+ my($host, $stdin_string, @command);
+ if ( ref($_[0]) ) {
+ my $opt = shift;
+ $host = $opt->{host};
+ $host = $opt->{user}. '@'. $host if exists $opt->{user};
+ @command = ( $opt->{command} );
+ push @command, @{ $opt->{args} } if exists $opt->{args};
+ $stdin_string = $opt->{stdin_string};
+ } else {
+ ($host, @command) = @_;
+ undef $stdin_string;
+ }
my $reader = IO::File->new();
my $writer = IO::File->new();
- my $error = IO::File->new();
-
- sshopen3( $host, $reader, $writer, $error, @command ) or die $!;
+ my $error = IO::File->new();
+
+ my $pid = sshopen3( $host, $writer, $reader, $error, @command ) or die $!;
+
+ print $writer $stdin_string if defined $stdin_string;
+ close $writer;
+
+ my $select = new IO::Select;
+ foreach ( $reader, $error ) { $select->add($_); }
+
+ my($output_stream, $error_stream) = ('', '');
+ while ( $select->count ) {
+ my @handles = $select->can_read;
+ foreach my $handle ( @handles ) {
+ my $buffer = '';
+ my $bytes = sysread($handle, $buffer, 4096);
+ if ( !defined($bytes) ) {
+ waitpid($pid, WNOHANG);
+ die "[Net::SSH::ssh_cmd] $!"
+ };
+ $select->remove($handle) if !$bytes;
+ if ( $handle eq $reader ) {
+ $output_stream .= $buffer;
+ } elsif ( $handle eq $error ) {
+ $error_stream .= $buffer;
+ }
+ }
- local $/ = undef;
- my $output_stream = <$writer>;
- my $error_stream = <$error>;
- if ( length $error_stream ) {
- die "[Net:SSH::ssh_cmd] STDERR $error_stream";
- }
- if ( length $output_stream ) {
- warn "[Net::SSH::ssh_cmd] STDOUT $output_stream";
}
+ waitpid($pid, WNOHANG);
+
+ die "$error_stream" if length($error_stream);
+
+ return $output_stream;
+
}
=item sshopen2 [USER@]HOST, READER, WRITER, COMMAND [, ARGS ... ]
sub sshopen2 {
my($host, $reader, $writer, @command) = @_;
- open2($reader, $writer, $ssh, '-o', 'BatchMode=yes', $host, @command);
+ @ssh_options = &_ssh_options unless @ssh_options;
+ open2($reader, $writer, $ssh, @ssh_options, $host, @command);
}
=item sshopen3 HOST, WRITER, READER, ERROR, COMMAND [, ARGS ... ]
sub sshopen3 {
my($host, $writer, $reader, $error, @command) = @_;
- open3($writer, $reader, $error, $ssh, '-o', 'BatchMode=yes', $host, @command);
+ @ssh_options = &_ssh_options unless @ssh_options;
+ open3($writer, $reader, $error, $ssh, @ssh_options, $host, @command);
}
sub _yesno {
$x =~ /^y/i;
}
+sub _ssh_options {
+ my $reader = IO::File->new();
+ my $writer = IO::File->new();
+ my $error = IO::File->new();
+ open3($writer, $reader, $error, $ssh, '-V');
+ my $ssh_version = <$error>;
+ chomp($ssh_version);
+ if ( $ssh_version =~ /.*OpenSSH[-|_](\w+)\./ && $1 == 1 ) {
+ $equalspace = " ";
+ } else {
+ $equalspace = "=";
+ }
+ my @options = ( '-o', 'BatchMode'.$equalspace.'yes' );
+ if ( $ssh_version =~ /.*OpenSSH[-|_](\w+)\./ && $1 > 1 ) {
+ unshift @options, '-T';
+ }
+ @options;
+}
+
=back
=head1 EXAMPLE
A: See L<perlfaq8/"How do I avoid zombies on a Unix system">, L<IPC::Open2>,
L<IPC::Open3> and L<perlfunc/waitpid>.
-=head1 AUTHOR
+=head1 AUTHORS
Ivan Kohler <ivan-netssh_pod@420.am>
-=head1 CREDITS
+John Harrison <japh@in-ta.net> contributed an example for the documentation.
- John Harrison <japh@in-ta.net> contributed an example for the documentation.
+Martin Langhoff <martin@cwa.co.nz> contributed the ssh_cmd command, and
+Jeff Finucane <jeff@cmh.net> updated it and took care of the 0.04 release.
+
+Anthony Awtrey <tony@awtrey.com> contributed a fix for those still using
+OpenSSH v1.
=head1 COPYRIGHT
-Copyright (c) 2000 Ivan Kohler.
-Copyright (c) 2000 Silicon Interactive Software Design.
-Copyright (c) 2000 Freeside Internet Services, LLC
+Copyright (c) 2004 Ivan Kohler.
+Copyright (c) 2002 Freeside Internet Services, LLC
All rights reserved.
This program is free software; you can redistribute it and/or modify it under
the same terms as Perl itself.
=head1 SEE ALSO
+For an all-perl implementation that does not require the system B<ssh> command,
+see L<Net::SSH::Perl> instead.
+
ssh-keygen(1), ssh(1), L<IO::File>, L<IPC::Open2>, L<IPC::Open3>
=cut