Shell/SSH/HttpProxy.pm

package Shell::SSH;
use strict;
use warnings;
use base qw( Shell );
our($VERSION, $AUTOLOAD);

$VERSION = '0.01';

use Data::Dumper;
use IPC::Run qw( start pump finish timeout );

# debugging
# $ENV{IPCRUNDEBUG} = 2;

# using corkscrew to get through certain http proxies
my $corkscrew = '/usr/local/bin/corkscrew';
# good tunnels might be:
my $tunnels = [
  'proxy.nida.ac.th:8080',   # Thailand
  '210.0.200.211:80',         # Hong Kong    (ssh1 only)
  '200.27.152.3:80',          # Chile
];

local *IN;
local *OUT;
local *ERR;

$Shell::hasHandler = 1;

sub new {
  print "new\n";
  my $class = shift;
  my $self = { @_ };
  bless $self, $class;
  $self->_init();
  $self->_start();
  return $self;
}

sub DESTROY { }

sub AUTOLOAD {
  my $self = shift;
  print "==================AUTO\n";
  exit;
    shift if ref $_[0] && $_[0]->isa( 'Shell' );
    #my $cmd = $AUTOLOAD;
    my $cmd = shift;
    print "cmd: $cmd\n";
    $cmd =~ s/^.*:://;
    print "===========COMMAND: $cmd", "\n";
}

sub _init {
  print "_init\n";
  my $self = shift;

    #$self->{isHandler} = 1;

    $self->{options}{proxy_host} = $tunnels->[0]
      if $self->{options}{proxy_enabled} && !$self->{options}{proxy_host};
  
    $self->{method} ||= 'ssh';
  
    if ($self->{options}{proxy_enabled} && $self->{options}{proxy_host}) {
      my @proxy = split(/:/, $self->{options}{proxy_host});
      $self->{proxy}{host} = $proxy[0];
      if ($proxy[1]) {
        $self->{proxy}{port} = $proxy[1];
      }
      $self->{proxy}{port} ||= 80;
    }

}


sub _start {
  print "_start\n";
  my $self = shift;

  my @cmd = ();
  die "please supply method" if (!$self->{method});
  die "please supply target" if (!$self->{target});
  
  if ($self->{proxy}) {
    push @cmd, '-o', "ProxyCommand $corkscrew $self->{proxy}{host} $self->{proxy}{port} " . '%h %p';
  }
  
  push @cmd, $self->{method};
  push @cmd, @{$self->{args}} if ($self->{args});
  push @cmd, $self->{target} if ($self->{target});

  my $cmd = join(" ", @cmd);
  #print "command: ", $cmd, "\n";

  $self->{handle} = start
     \@cmd,
        '<pipe', \*IN,
        '>pipe', \*OUT,
        '2>pipe', \*ERR,
        timeout( 3 )
     or die "could not open IPC::Run - handle: $?" ;
  
}

sub _stop {
  my $self = shift;
  finish $self->{handle};
}

sub _read_output {
  my $self = shift;
  $self->{buffer} = [];
  while (<OUT>) {
    chomp();
    push @{$self->{buffer}}, $_;
  }
}

sub run {
  my $self = shift;
  my $rcommand = shift;
  print IN $rcommand;
  close IN;
  $self->_read_output();
}

sub get_output {
  my $self = shift;
  return $self->{buffer};
}

sub disconnect {
  my $self = shift;
  $self->_stop();
}

1;
1	joko	1.1	package Shell::SSH;
2			use strict;
3			use warnings;
4			use base qw( Shell );
5			our($VERSION, $AUTOLOAD);
6
7			$VERSION = '0.01';
8
9			use Data::Dumper;
10			use IPC::Run qw( start pump finish timeout );
11
12			# debugging
13			# $ENV{IPCRUNDEBUG} = 2;
14
15			# using corkscrew to get through certain http proxies
16			my $corkscrew = '/usr/local/bin/corkscrew';
17			# good tunnels might be:
18			my $tunnels = [
19			'proxy.nida.ac.th:8080', # Thailand
20			'210.0.200.211:80', # Hong Kong (ssh1 only)
21			'200.27.152.3:80', # Chile
22			];
23
24			local *IN;
25			local *OUT;
26			local *ERR;
27
28			$Shell::hasHandler = 1;
29
30			sub new {
31			print "new\n";
32			my $class = shift;
33			my $self = { @_ };
34			bless $self, $class;
35			$self->_init();
36			$self->_start();
37			return $self;
38			}
39
40			sub DESTROY { }
41
42			sub AUTOLOAD {
43			my $self = shift;
44			print "==================AUTO\n";
45			exit;
46			shift if ref $_[0] && $_[0]->isa( 'Shell' );
47			#my $cmd = $AUTOLOAD;
48			my $cmd = shift;
49			print "cmd: $cmd\n";
50			$cmd =~ s/^.*:://;
51			print "===========COMMAND: $cmd", "\n";
52			}
53
54			sub _init {
55			print "_init\n";
56			my $self = shift;
57
58			#$self->{isHandler} = 1;
59
60			$self->{options}{proxy_host} = $tunnels->[0]
61			if $self->{options}{proxy_enabled} && !$self->{options}{proxy_host};
62
63			$self->{method} \|\|= 'ssh';
64
65			if ($self->{options}{proxy_enabled} && $self->{options}{proxy_host}) {
66			my @proxy = split(/:/, $self->{options}{proxy_host});
67			$self->{proxy}{host} = $proxy[0];
68			if ($proxy[1]) {
69			$self->{proxy}{port} = $proxy[1];
70			}
71			$self->{proxy}{port} \|\|= 80;
72			}
73
74			}
75
76
77			sub _start {
78			print "_start\n";
79			my $self = shift;
80
81			my @cmd = ();
82			die "please supply method" if (!$self->{method});
83			die "please supply target" if (!$self->{target});
84
85			if ($self->{proxy}) {
86			push @cmd, '-o', "ProxyCommand $corkscrew $self->{proxy}{host} $self->{proxy}{port} " . '%h %p';
87			}
88
89			push @cmd, $self->{method};
90			push @cmd, @{$self->{args}} if ($self->{args});
91			push @cmd, $self->{target} if ($self->{target});
92
93			my $cmd = join(" ", @cmd);
94			#print "command: ", $cmd, "\n";
95
96			$self->{handle} = start
97			\@cmd,
98			'<pipe', \*IN,
99			'>pipe', \*OUT,
100			'2>pipe', \*ERR,
101			timeout( 3 )
102			or die "could not open IPC::Run - handle: $?" ;
103
104			}
105
106			sub _stop {
107			my $self = shift;
108			finish $self->{handle};
109			}
110
111			sub _read_output {
112			my $self = shift;
113			$self->{buffer} = [];
114			while (<OUT>) {
115			chomp();
116			push @{$self->{buffer}}, $_;
117			}
118			}
119
120			sub run {
121			my $self = shift;
122			my $rcommand = shift;
123			print IN $rcommand;
124			close IN;
125			$self->_read_output();
126			}
127
128			sub get_output {
129			my $self = shift;
130			return $self->{buffer};
131			}
132
133			sub disconnect {
134			my $self = shift;
135			$self->_stop();
136			}
137
138			1;
MailToCvsAdmin">MailToCvsAdmin	ViewVC Help
Powered by ViewVC 1.1.26