| version 1.2, 2005/12/30 01:02:41 | version 1.60, 2009/07/31 22:46:07 | 
|  |  | 
| package Net::Telnet::Trango; | package Net::Telnet::Trango; | 
| # $RedRiver$ |  | 
| use strict; | # $RedRiver: Trango.pm,v 1.59 2009/07/31 21:44:33 andrew Exp $ | 
| use warnings; | use strict; | 
| use base 'Net::Telnet'; | use warnings; | 
|  | use base 'Net::Telnet'; | 
| =pod |  | 
|  | =pod | 
| =head1 NAME |  | 
|  | =head1 NAME | 
| Net::Telnet::Trango - Perl extension for accessing the Trango telnet interface |  | 
|  | Net::Telnet::Trango | 
| =head1 SYNOPSIS | - Perl extension for accessing the Trango telnet interface | 
|  |  | 
| use Net::Telnet::Trango; | =head1 SYNOPSIS | 
| my $t = new Net::Telnet::Trango ({ |  | 
| Host    => $fox, | use Net::Telnet::Trango; | 
| Timeout => 5, | my $t = new Net::Telnet::Trango ( Timeout => 5 ); | 
| }); |  | 
|  | $t->open( Host => $ap ) or die "Error connecting: $!"; | 
| my ($type, $version) = $t->open; |  | 
|  | $t->login('password') or die "Couldn't log in: $!"; | 
| unless (defined $type && defined $version) { |  | 
| die "Error connecting: $!"; | # Do whatever | 
| } |  | 
|  | $t->exit; | 
| $t->login('password') or die "Couldn't log in: $!"; | $t->close; | 
|  |  | 
| # Do whatever | =head1 DESCRIPTION | 
|  |  | 
| $t->exit; | Perl access to the telnet interface on Trango APs and SUs. | 
| $t->close; |  | 
|  | A handy feature is that it will parse the output from certain commands that is | 
| =head1 DESCRIPTION | in the format "[key1] value1 [key2] value2" and put those in a hashref that is | 
|  | returned.  This makes using the output from things like sysinfo very easy to | 
| Perl access to the telnet interface on Trango Foxes, SUs and APs. | do. | 
|  |  | 
| Another handy feature is that it will parse the output from certain commands that is in the format "[key1] value1 [key2] value2" and put those in a hashref that is returned.  This makes using the output from things like sysinfo very easy to do. | =head2 EXPORT | 
|  |  | 
| =head2 EXPORT | None | 
|  |  | 
| None | =head1 METHODS | 
|  |  | 
| =cut | =cut | 
|  |  | 
| our $VERSION = '0.01'; | our $VERSION = '0.05'; | 
|  |  | 
| my %PRIVATE = ( | my $EMPTY = q{}; | 
| is_connected => 0, | my $SPACE = q{ }; | 
| logged_in => 0, |  | 
| ); | =pod | 
|  |  | 
| =pod | =head2 B<new> - Creates a new Net::Telnet::Trango object. | 
|  |  | 
| =head1 METHODS | new([Options from Net::Telnet,] | 
|  | [Decode => 0,]); | 
| =head2 ACCESSORS |  | 
|  | Same as new from L<Net::Telnet> but sets the default Trango Prompt: | 
| =over | '/[\$#]>\s*\Z/' | 
|  |  | 
| =item Host | It also takes an optional parameter 'Decode'.  If not defined it | 
|  | defaults to 1, if it is set to 0, it will not decode the output and | 
| returns the name of the host that you are accessing | instead return a reference to an array of the lines that were returned | 
|  | from the command. | 
| =item firmware_version |  | 
|  | =cut | 
| returns the firmware version on the trango if available otherwise undef. |  | 
| Available after a successful open() | sub new { | 
| This is usually only set internally | my $class = shift; | 
|  |  | 
| =item host_type | my %args = (); | 
|  | if ( @_ == 1 ) { | 
| returns the type of host from the login banner for example M5830S or M5300S. | $args{'Host'} = shift; | 
| Available after a successful open() | } | 
| This is usually only set internally | else { | 
|  | %args = @_; | 
| =item is_connected | } | 
|  |  | 
| returns 1 after a successful open() otherwise undef | $args{'Prompt'} ||= '/[\$#]>\s*\r?\n?$/'; | 
| This is usually only set internally |  | 
|  | my $decode = $args{'Decode'}; | 
| =item logged_in | delete $args{'Decode'}; | 
|  |  | 
| returns 1 after a successful login() 0 if it failed and undef if | my $self = $class->SUPER::new(%args); | 
| login() was never called | bless $self if ref $self; | 
| This is usually only set internally |  | 
|  | $args{Decode}       = defined $decode ? $decode : 1; | 
| =item login_banner | $args{is_connected} = 0; | 
|  | $args{logged_in}    = 0; | 
| returns the banner that is displayed when first connected at login.  Only set after a successful open() |  | 
|  | *$self->{net_telnet_trango} = \%args; | 
| This is usually only set internally |  | 
|  | return $self; | 
| =item last_lines | } | 
|  |  | 
| returns the output from the last cmd() that was run as an array ref | #  _password <new password> <new password> | 
| This is usually only set internally | #  ? [command] | 
|  | #  apsearch <secs> <ch#> <h|v> [<ch#> <h|v>]... | 
| =back | #  arp -bcast <on|off> | 
|  | #  bcastscant <all|suid> <ch#> <h|v> [<ch#> <h|v> ... | 
| =head2 ALIASES | #  bye | 
|  | #  cf2cf ap [default|<size>] | 
| =over | #  date | 
|  | #  date <month> <day> <year> | 
| =item bye | #  freq scantable | 
|  | #  freq channeltable | 
| alias of exit() | #  freq writescan [<ch#> <h|v>] | 
|  | #  freq writechannel [<ch#> <freq>] ... | 
| =item reboot | #  freq <ch #> <h|v> | 
|  | #  help [command] | 
| alias of restart() | #  heater [<on temp> <off temp>] | 
|  | #  ipconfig [<new ip> <new subnet mask> <new gateway>] | 
| =back | #  linktest <suid> [<pkt len, bytes> [<# of pkts> [<# of cycle>]]] | 
|  | #  log [<# of entries, 1..179>] | 
| =head2 COMMANDS | #  log <sum> <# of entries, 1..179> | 
|  | #  logout | 
| Most of these are just shortcuts to C<cmd(String =E<gt> METHOD)>, as such they accept the same options as C<cmd()>.  Specifically they take a named paramater "args", for example: | #  opmode [ap [y]] | 
| C<tftpd(args =E<gt> 'on')> would enable tftpd | #  password | 
|  | #  ping <ip addr> | 
| =over | #  polar <h|v> | 
|  | #  power <setism|setunii> <max|min|<dBm>> | 
| =item tftpd | #  reboot | 
|  | #  restart | 
| Returns a hash ref of the decoded output from the command. | #  remarks [<str>] | 
|  | #  rfrxthreshold [<ism|unii> <-90|-85|-80|-75|-70|-65>] | 
| Also see enable_tftpd() and disable_tftpd() as those check for correct output | #  rfrxth [<ism|unii> <-90|-85|-80|-75|-70|-65>] | 
|  | #  sysinfo | 
| =item ver | #  set suid <id> | 
|  | #  set apid <id> | 
| Returns a hash ref of the decoded output from the command. | #  set baseid <id> | 
|  | #  set defaultopmode [<ap|su> <min,0..10>] | 
| =item sysinfo | #  set defaultopmode off | 
|  | #  set snmpcomm [<read | write | trap (id or setall)> <str>] | 
| Returns a hash ref of the decoded output from the command. | #  set mir [on|off] | 
|  | #  set mir threshold <kbps> | 
| =item exit | #  set rssitarget [<ism|unii> <dBm>] | 
|  | #  set serviceradius [<ism | unii> <miles>] | 
| exits the command session with the trango and closes the connection | #  ssrssi <ch #> <h|v> | 
|  | #  su [<suid>|all] | 
| =item reboot | #  su changechannel <all|suid> <ch#> <h|v> | 
|  | #  su ipconfig <suid> <new ip> <new subnet> <new gateway> | 
| reboots the trango and closes the connection | #  su [live|poweroff|priority] | 
|  | #  su <ping|info|status> <suid> | 
| =cut | #  su powerleveling <all|suid> | 
|  | #  su reboot <all|suid> | 
| #  _password <new password> <new password> | #  su restart <all|suid> | 
| #  ? [command] | #  su testrflink <all|suid> [r] | 
| #  apsearch <secs> <ch#> <h|v> [<ch#> <h|v>]... | #  su testrflink <setlen> [64..1600] | 
| #  arp -bcast <on|off> | #  su testrflink <aptx> [20..100] | 
| #  bcastscant <all|suid> <ch#> <h|v> [<ch#> <h|v> ... | #  su sw <suid|all> <sw #> <on|off> | 
| #  bye | #  sudb [dload | view] | 
| #  cf2cf ap [default|<size>] | #  sudb add <suid> pr <cir,kbps> <mir,kbps> <device id,hex> | 
| #  date | #  sudb add <suid> reg <cir,kbps> <mir,kbps> <device id,hex> | 
| #  date <month> <day> <year> | #  sudb delete <all|<suid>> | 
| #  freq scantable | #  sudb modify <suid> <cir|mir> <kbps> | 
| #  freq channeltable | #  sudb modify <suid> <su2su> <group id,hex> | 
| #  freq writescan [<ch#> <h|v>] | #  sudb view | 
| #  freq writechannel [<ch#> <freq>] ... | #  sulog [lastmins | sampleperiod <1..60>] | 
| #  freq <ch #> <h|v> | #  sulog [<# of entry,1..18>] | 
| #  help [command] | #  survey <ism|unii> <time, sec> <h|v> | 
| #  heater [<on temp> <off temp>] | #  sw [<sw #> <on|off>] | 
| #  ipconfig [<new ip> <new subnet mask> <new gateway>] | #  temp | 
| #  log [<# of entries, 1..179>] | #  tftpd [on|off] | 
| #  log <sum> <# of entries, 1..179> | #  time | 
| #  logout | #  time <hour> <min> <sec> | 
| #  opmode [ap [y]] | #  save <mainimage|fpgaimage> <current chksum> <new chksum> | 
| #  password | #  save <systemsetting|sudb> | 
| #  ping <ip addr> | #  updateflash <mainimage|fpgaimage> <current chksum> <new chksum> | 
| #  polar <h|v> | #  updateflash <systemsetting|sudb> | 
| #  power <setism|setunii> <max|min|<dBm>> |  | 
| #  reboot | =pod | 
| #  restart |  | 
| #  remarks [<str>] | =head1 ACCESSORS | 
| #  rfrxthreshold [<ism|unii> <-90|-85|-80|-75|-70|-65>] |  | 
| #  rfrxth [<ism|unii> <-90|-85|-80|-75|-70|-65>] | These are usually only set internally. | 
| #  sysinfo |  | 
| #  set suid <id> | =head2 B<firmware_version> - returns the firmware version | 
| #  set apid <id> |  | 
| #  set baseid <id> | Returns the firmware version if available, otherwise undef. | 
| #  set defaultopmode [<ap|su> <min,0..10>] |  | 
| #  set defaultopmode off | It should be available after a successful open(). | 
| #  set snmpcomm [<read | write | trap (id or setall)> <str>] |  | 
| #  set mir [on|off] | =head2 B<host_type> - return the type of host you are connected to. | 
| #  set mir threshold <kbps> |  | 
| #  set rssitarget [<ism|unii> <dBm>] | returns the type of host from the login banner for example M5830S or M5300S. | 
| #  set serviceradius [<ism | unii> <miles>] |  | 
| #  ssrssi <ch #> <h|v> | Should be available after a successful open(). | 
| #  su [<suid>|all] |  | 
| #  su changechannel <all|suid> <ch#> <h|v> | =head2 B<is_connected> - Status of the connection to host. | 
| #  su ipconfig <suid> <new ip> <new subnet> <new gateway> |  | 
| #  su [live|poweroff|priority] | returns 1 when connected, undef otherwise. | 
| #  su <ping|info|status> <suid> |  | 
| #  su powerleveling <all|suid> | =head2 B<logged_in> - Status of being logged in to the host. | 
| #  su reboot <all|suid> |  | 
| #  su restart <all|suid> | returns 1 after a successful login(), 0 if it failed and undef if | 
| #  su testrflink <all|suid> [r] | login() was never called. | 
| #  su testrflink <setlen> [64..1600] |  | 
| #  su testrflink <aptx> [20..100] | =head2 B<login_banner> - The banner when first connecting to the host. | 
| #  su sw <suid|all> <sw #> <on|off> |  | 
| #  sudb [dload | view] | returns the banner that is displayed when first connected at login. | 
| #  sudb add <suid> pr <cir,kbps> <mir,kbps> <device id,hex> | Only set after a successful open(). | 
| #  sudb add <suid> reg <cir,kbps> <mir,kbps> <device id,hex> |  | 
| #  sudb delete <all|<suid>> | =head2 B<last_lines> - The last lines of output from the last cmd(). | 
| #  sudb modify <suid> <cir|mir> <kbps> |  | 
| #  sudb modify <suid> <su2su> <group id,hex> | returns, as an array ref, the output from the last cmd() that was run. | 
| #  sudb view |  | 
| #  sulog [lastmins | sampleperiod <1..60>] | =head2 B<last_error> - A text output of the last error that was encountered. | 
| #  sulog [<# of entry,1..18>] |  | 
| #  survey <ism|unii> <time, sec> <h|v> | returns the last error reported.  Probably contains the last entry in | 
| #  sw [<sw #> <on|off>] | last_lines. | 
| #  temp |  | 
| #  tftpd [on|off] | =head1 ALIASES | 
| #  time |  | 
| #  time <hour> <min> <sec> | =head2 B<bye> - alias of exit() | 
| #  save <mainimage|fpgaimage> <current chksum> <new chksum> |  | 
| #  save <systemsetting|sudb> | Does the same as exit() | 
| #  updateflash <mainimage|fpgaimage> <current chksum> <new chksum> |  | 
| #  updateflash <systemsetting|sudb> | =head2 B<restart> - alias of reboot() | 
|  |  | 
|  | Does the same as reboot() | 
| my $success = 'Success.'; |  | 
| my %COMMANDS = ( | =head2 B<save_systemsetting> - alias of save_ss() | 
| tftpd       => { decode => 1, expect => $success }, |  | 
| ver         => { decode => 1 }, | Does the same as save_ss() | 
| sysinfo     => { decode => 1, expect => $success }, |  | 
| updateflash => { decode => 1, expect => $success }, | =head1 COMMANDS | 
| 'exit'      => { Prompt => '//', cmd_disconnects => 1 }, |  | 
| reboot      => { Prompt => '//', cmd_disconnects => 1 }, | Most of these are just shortcuts to C<cmd(String =E<gt> METHOD)>, | 
| ); | as such they accept the same options as C<cmd()>. | 
|  | Specifically they take a named paramater "args", for example: | 
| my %ALIASES = ( | C<tftpd(args =E<gt> 'on')> would enable tftpd | 
| bye     => 'exit', |  | 
| restart => 'reboot', | =head2 B<tftpd> - The output from the tftpd command | 
| ); |  | 
|  | Returns a hash ref of the decoded output from the | 
| my %ACCESS = map { $_ => 1 } qw( | command. | 
| firmware_version |  | 
| host_type | Also see enable_tftpd() and disable_tftpd() as those check that it was | 
| Host | successfully changed. | 
| is_connected |  | 
| logged_in | =head2 B<ver> - The output from the ver command | 
| login_banner |  | 
| Timeout | Returns a hash ref of the decoded output from the | 
| last_lines | command. | 
| ); |  | 
|  | =head2 B<sysinfo> - The output from the sysinfo command | 
| sub AUTOLOAD |  | 
| { | Returns a hash ref of the decoded output from the | 
| my $self = shift; | command. | 
|  |  | 
| my ($method) = (our $AUTOLOAD) =~ /^.*::(\w+)$/ | =head2 B<exit> - Exits the connection | 
| or die "Weird: $AUTOLOAD"; |  | 
|  | exits the command session with the Trango and closes | 
| if (exists $ALIASES{$method}) { | the connection | 
| $method = $ALIASES{$method}; |  | 
| return $self->$method(@_); | =head2 B<reboot> - Sends a reboot command | 
| } |  | 
|  | reboots the Trango and closes the connection | 
| if (exists $COMMANDS{$method}) { |  | 
| $COMMANDS{$method}{'String'} ||= $method; | =head2 B<reset> <all|0..2> - Sends a reset command | 
| return $self->cmd(%{ $COMMANDS{$method} }, @_); |  | 
| } | resets settings to default | 
|  |  | 
| if (exists $ACCESS{$method}) { | =head2 B<remarks> - Set or retrieve the remarks. | 
| my $prev = $PRIVATE{$method}; |  | 
| ($PRIVATE{$method}) = @_ if @_; | Takes an optional argument, which sets the remarks. | 
| return $prev; | If there is no argument, returns the current remarks. | 
| } |  | 
|  | my $old_remarks = $t->remarks(); | 
| $method = "SUPER::$method"; | $t->remarks($new_remarks); | 
| return $self->$method(@_); |  | 
| } | =head2 B<sulog> - The output from the sulog command | 
|  |  | 
| =pod | Returns an array ref of hashes containing each log | 
|  | line. | 
| =item new |  | 
|  | =head2 B<save_sudb> - saves the sudb | 
| =cut |  | 
|  | Returns true on success, undef on failure | 
| sub new |  | 
| { | =head2 B<syslog> - The output from the sulog command | 
| my $class = shift; |  | 
| my $args = shift || {}; | Returns a hashref of the output from the syslog command | 
|  |  | 
| $args->{'Timeout'} ||= 5; | =head2 B<pipe> - the pipe command | 
| $args->{'Prompt'}  ||= '/#> *$/'; |  | 
|  | Returns the output from the pipe command | 
| foreach my $key (keys %{ $args }) { |  | 
| $PRIVATE{$key} = $args->{$key}; | =head2 B<maclist> - retrieves the maclist | 
| } |  | 
|  | Returns the output from the maclist command | 
| my $self = $class->SUPER::new(%{ $args }); |  | 
| bless $self if ref $self; | =head2 B<maclist_reset> - resets the maclist. | 
|  |  | 
| return $self; | No useful output. | 
| } |  | 
|  | =head2 B<eth_link> - eth link command | 
| =pod |  | 
|  | Returns the output from the eth link command | 
| =item open |  | 
|  | This command seems to cause some weird issues.  It often will cause the | 
| =cut | command after it to appear to fail.  I am not sure why. | 
|  |  | 
| sub open | =head2 B<su_info> - gets the su info | 
| { |  | 
| my $self = shift; | Returns information about the SU. | 
|  |  | 
| unless ( $self->SUPER::open( | You need to pass in the $suid and it will return the info for that suid. | 
| #Host => $self->Host, |  | 
| #Errmode => 'return', | $t->su_info($suid); | 
| ) ) { |  | 
| #$! = "Couldn't connect to " . $self->Host . ":  $!"; | =head2 B<su_testrflink> - tests the RF Link to an su | 
| return undef; |  | 
| } | $t->su_testrflink($suid|'all'); | 
| #$self->dump_log('dump.log'); |  | 
|  | =head2 B<save_ss> - saves the config. | 
| ## Login to remote host. |  | 
| unless ($self->waitfor( | Returns 1 on success, undef on failure. | 
| -match => '/password: ?$/i', |  | 
| -errmode => "return", | =head2 B<set_baseid> - sets baseid | 
| ) ) { |  | 
| #$! = "problem connecting to host (" . $self->Host . "): " . | $t->set_baseid($baseid); | 
| #    $self->lastline; |  | 
| return undef; | =head2 B<set_suid> - sets baseid | 
| } |  | 
|  | $t->set_suid($baseid); | 
| $self->parse_login_banner($self->lastline); |  | 
|  | =head2 B<set_defaultopmode> - sets default opmode | 
| $self->is_connected(1); |  | 
|  | $t->set_defaultopmode(ap|su); | 
| return $self->is_connected; |  | 
| } | =head2 B<opmode> - sets or returns the opmode | 
|  |  | 
| =pod | $t->opmode([ap y|su y]); | 
|  |  | 
| =item login | =head2 B<freq> - sets or returns the freq | 
|  |  | 
| =cut | $channel = '11 v'; | 
|  | $t->freq([$channel]); | 
| sub login |  | 
| { | =head2 B<freq_writescan> - sets the freq writescan | 
| my $self = shift; |  | 
|  | $channels = '11 v 11 h 12 v 12 h'; | 
| unless ($self->is_connected) { | $t->freq_writescan($channels); | 
| $self->open or return undef; |  | 
| } | =head2 B<freq_scantable> - returns the freq scantable | 
|  |  | 
| my $password = shift; | $channels = $t->freq_scantable(); | 
|  | # now $channels eq '11 v 11 h 12 v 12 h'; | 
| $self->print($password); |  | 
| unless ($self->waitfor( |  | 
| -match => $self->prompt, | =cut | 
| -errmode => "return", |  | 
| ) ) { | my $success  = 'Success\\.'; | 
| #$! = "login ($self->Host) failed: " . $self->lastline; | my %COMMANDS = ( | 
| return undef; | _clear      => { String    => "\n" }, | 
| } | tftpd       => { decode    => 'all', expect => $success }, | 
|  | ver         => { decode    => 'all' }, | 
| $self->logged_in(1); | sysinfo     => { decode    => 'all', expect => $success }, | 
|  | updateflash => { decode    => 'all', expect => $success }, | 
| return $self->logged_in; | sulog       => { decode    => 'sulog', expect => $success }, | 
| } | 'exit'      => { no_prompt => 1, cmd_disconnects => 1 }, | 
|  | reboot      => { no_prompt => 1, cmd_disconnects => 1 }, | 
| =pod | 'reset'   => {}, | 
|  | remarks   => { decode => 'all', expect => $success }, | 
| =item parse_login_banner | save_sudb => { String => 'save sudb', expect => $success }, | 
|  | syslog  => { expect => $success }, | 
| =cut | 'pipe'  => {},      # XXX needs a special decode | 
|  | maclist => { decode => 'maclist' }, | 
| sub parse_login_banner | maclist_reset => { String => 'maclist reset', expect => 'done' }, | 
| { | eth_link      => { String => 'eth link',      expect => $success }, | 
| my $self = shift; | su_info => { String => 'su info', decode => 'all', expect => $success }, | 
|  | su_testrflink => | 
| if (@_) { | { String => 'su testrflink', decode => 'each', expect => $success }, | 
| $self->login_banner(@_); | save_ss    => { String => 'save ss', expect => $success }, | 
| } | set_baseid => { | 
|  | String => 'set baseid', | 
| my $banner = $self->login_banner; | decode => 'all', | 
|  | expect => $success | 
| my ($type, $ver) = $banner =~ | }, | 
| /Welcome to Trango Broadband Wireless (\S+)[\s-]+(.+)$/i; | set_suid => { | 
|  | String => 'set suid', | 
| $self->login_banner($banner); | decode => 'all', | 
| $self->host_type($type); | expect => $success | 
| $self->firmware_version($ver); | }, | 
|  | set_defaultopmode => { | 
| return 1; | String => 'set defaultopmode', | 
| } | decode => 'all', | 
|  | expect => $success | 
| =pod | }, | 
|  | opmode => { decode => 'all',  expect => $success }, | 
| =item enable_tftpd | freq   => { decode => 'freq', expect => $success }, | 
|  | freq_writescan => | 
| =cut | { String => 'freq writescan', decode => 'all', expect => $success }, | 
|  | freq_scantable => | 
| sub enable_tftpd | { String => 'freq scantable', decode => 'all', expect => $success }, | 
| { | arq => { decode => 'all' }, | 
| my $self = shift; | ); | 
|  |  | 
| my $vals = $self->tftpd( args => 'on' ); | my %ALIASES = ( | 
|  | bye               => 'exit', | 
| if ($vals->{'Tftpd'} eq 'listen') { | restart           => 'reboot', | 
| return $vals; | Host              => 'host', | 
| } else { | save_systemseting => 'save_ss', | 
| return undef; | ); | 
| } |  | 
| } | my %ACCESS = map { $_ => 1 } qw( | 
|  | firmware_version | 
| =pod | host_type | 
|  | is_connected | 
| =item disable_tftpd | logged_in | 
|  | login_banner | 
| =cut | Timeout | 
|  | last_lines | 
| sub disable_tftpd | last_vals | 
| { | last_error | 
| my $self = shift; | Decode | 
|  | ); | 
| my $vals = $self->tftpd( args => 'off' ); |  | 
|  | sub AUTOLOAD { | 
| if (ref $vals eq 'HASH' && $vals->{'Tftpd'} eq 'disabled') { | my $self = shift; | 
| return $vals; |  | 
| } else { | my ($method) = ( our $AUTOLOAD ) =~ /^.*::(\w+)$/ | 
| return undef; | or die "Weird: $AUTOLOAD"; | 
| } |  | 
| } | if ( exists $ALIASES{$method} ) { | 
|  | $method = $ALIASES{$method}; | 
| =pod | return $self->$method(@_); | 
|  | } | 
| =item cmd |  | 
|  | if ( exists $COMMANDS{$method} ) { | 
| =cut | my %cmd; | 
|  | foreach my $k ( keys %{ $COMMANDS{$method} } ) { | 
| sub cmd | $cmd{$k} = $COMMANDS{$method}{$k}; | 
| { | } | 
| my $self = shift; | $cmd{'String'} ||= $method; | 
|  | $cmd{'args'} .= $SPACE . shift if ( @_ == 1 ); | 
| my @valid_net_telnet_opts = qw( | return $self->cmd( %cmd, @_ ); | 
| String | } | 
| Output |  | 
| Cmd_remove_mode | if ( exists $ACCESS{$method} ) { | 
| Errmode | my $s    = *$self->{net_telnet_trango}; | 
| Input_record_separator | my $prev = $s->{$method}; | 
| Ors | ( $s->{$method} ) = @_ if @_; | 
| Output_record_separator | return $prev; | 
| Prompt | } | 
| Rs |  | 
| Timeout | $method = "SUPER::$method"; | 
| ); | return $self->$method(@_); | 
|  | } | 
| my %cfg; |  | 
| if (@_ == 2) { | =pod | 
| $cfg{'String'} = shift; |  | 
| } elsif (@_ > 2) { | =head2 B<open> - Open a connection to a Trango AP. | 
| %cfg = @_; |  | 
| } | Calls Net::Telnet::open() then makes sure you get a password prompt so | 
|  | you are ready to login() and parses the login banner so you can get | 
| $cfg{'Timeout'} ||= $self->Timeout; | host_type() and firmware_version() | 
|  |  | 
| unless ($cfg{'String'}) { | =cut | 
| #$! = "No command passed"; |  | 
| warn "No command passed\n"; | sub open { | 
| return undef; | my $self = shift; | 
| } |  | 
|  | unless ( $self->SUPER::open(@_) ) { | 
| unless ($self->is_connected) { | $self->last_error( "Couldn't connect to " . $self->host . ":  $!" ); | 
| #$! = "Not connected"; | return; | 
| warn "Not connected\n"; | } | 
| return undef; |  | 
| } | ## Get to login prompt | 
|  | unless ( | 
| unless ($self->logged_in) { | $self->waitfor( | 
| #$! = "Not logged in"; | -match   => '/password: ?$/i', | 
| warn "Not logged in\n"; | -errmode => "return", | 
| return undef; | ) | 
| } | ) | 
|  | { | 
|  | $self->last_error( "problem connecting to host (" | 
| my %cmd; | . $self->host . "): " | 
| foreach (@valid_net_telnet_opts) { | . $self->lastline ); | 
| if (exists $cfg{$_}) { | return; | 
| $cmd{$_} = $cfg{$_}; | } | 
| } |  | 
| } | $self->parse_login_banner( $self->lastline ); | 
| if ($cfg{'args'}) { |  | 
| $cmd{'String'} .= ' ' . $cfg{'args'}; | $self->is_connected(1); | 
| } |  | 
| my @lines = $self->SUPER::cmd(%cmd); | return $self->is_connected; | 
|  | } | 
| $self->last_lines(\@lines); |  | 
|  | =pod | 
| my $vals = 1; |  | 
| if ($cfg{'decode'}) { | =head2 B<login> - Login to the AP. | 
| $vals = _decode_lines(@lines); |  | 
| } | Calls open() if not already connected, then sends the password and sets | 
|  | logged_in() if successful | 
|  |  | 
| my $last = $self->lastline; | =cut | 
|  |  | 
| if ((not $cfg{'expect'}) || $last =~ /$cfg{'expect'}$/) { | sub login { | 
| if ($cfg{'cmd_disconnects'}) { | my $self = shift; | 
| $self->logged_in(0); |  | 
| $self->close; | unless ( $self->is_connected ) { | 
| $self->is_connected(0); | $self->open or return; | 
| } | } | 
|  |  | 
| if ($cfg{'decode'}) { | my $password = shift; | 
| return $vals; |  | 
| } else { | $self->print($password); | 
| return @lines; | unless ( | 
| } | $self->waitfor( | 
| } else { | -match   => $self->prompt, | 
| #$! = "Error with command ($cfg{'string'}): $last"; | -errmode => "return", | 
| return undef; | ) | 
| } | ) | 
| } | { | 
|  | $self->last_error( "login ($self->host) failed: " . $self->lastline ); | 
| #=item _decode_lines | return; | 
|  | } | 
| sub _decode_lines |  | 
| { | $self->logged_in(1); | 
| my @lines = @_; |  | 
|  | return $self->logged_in; | 
| my %conf; | } | 
|  |  | 
| my $key = ''; | =pod | 
| my $val = ''; |  | 
| my $in_key = 0; | =head2 B<parse_login_banner> - Converts the login_banner to something useful. | 
| my $in_val = 0; |  | 
|  | Takes a login banner (what you get when you first connect to the Trango) | 
| foreach my $line (@lines) { | or reads what is already in login_banner() then parses it and sets | 
| my @chars = split //, $line; | host_type() and firmware_version() as well as login_banner() | 
|  |  | 
| my $last_key = ''; | =cut | 
| foreach my $c (@chars) { |  | 
|  | sub parse_login_banner { | 
| if ($c eq '[' || $c eq "\r" || $c eq "\n") { | my $self = shift; | 
| if ($c eq '[') { |  | 
| $in_key = 1; | if (@_) { | 
| $in_val = 0; | $self->login_banner(@_); | 
| } else { | } | 
| $in_key = 0; |  | 
| $in_val = 0; | my $banner = $self->login_banner; | 
| } |  | 
|  | my ( $type, $sep1, $subtype, $sep2, $ver ) | 
| if ($key) { | = $banner | 
| $key =~ s/^\s+//; | =~ /Welcome to Trango Broadband Wireless,? (\S+)([\s-]+)(\S+)([\s-]+)(.+)$/i; | 
| $key =~ s/\s+$//; |  | 
|  | $type .= $sep1 . $subtype; | 
| $val =~ s/^\s+//; | $ver = $subtype . $sep2 . $ver; | 
| $val =~ s/\s+$//; |  | 
|  | $self->login_banner($banner); | 
| if ($key eq 'Checksum' && $last_key) { | $self->host_type($type); | 
| # Special case for these bastids. | $self->firmware_version($ver); | 
| my $new = $last_key; |  | 
| $new =~ s/\s+\S+$//; | return 1; | 
| $key = $new . " " . $key; | } | 
| } |  | 
|  | =pod | 
| $last_key = $key; |  | 
| $conf{$key} = $val; | =head2 B<linktest> - Link test to SU | 
| $key = ''; |  | 
| $val = ''; | linktest('suid'[, 'pkt len, bytes'[, '# of pkts'[, '# of cycles']]]); | 
| } |  | 
|  | Returns a hash reference to the results of the test | 
| } elsif ($c eq ']') { |  | 
| $in_val = 1; | =cut | 
| $in_key = 0; |  | 
| $c = shift @chars; | sub linktest { | 
|  | my $self = shift; | 
| } elsif ($in_key) { | my $suid = shift; | 
| $key .= $c; |  | 
|  | # These numbers are what I found as defaults when running the command | 
| } elsif ($in_val) { | my $pkt_len = shift || 1600; | 
| $val .= $c; | my $pkt_cnt = shift || 500; | 
| } | my $cycles  = shift || 10; | 
| } |  | 
| } | my %config = @_; | 
|  |  | 
| if (%conf) { | # * 2, one for the FromAP, one FromSU.  Then / 1000 to get to ms. | 
| return \%conf; | # XXX This might need to be changed, this makes the default timeout the | 
| } else { | # same as $pkt_len, and that might not be enough at slower speeds. | 
| return \@lines; | $config{Timeout} ||= int( ( $pkt_len * $pkt_cnt * $cycles * 2 ) / 1000 ); | 
| } |  | 
| } | my $string = join $SPACE, 'linktest', $suid, $pkt_len, $pkt_cnt, $cycles; | 
|  | return $self->cmd( | 
| 1; | %config, | 
| __END__ | String => $string, | 
|  | decode => 'linktest', | 
| =back | ); | 
|  |  | 
| =head1 SEE ALSO | } | 
|  |  | 
| If you have a web site set up for your module, mention it here. | =pod | 
|  |  | 
| Trango Documentation - http://www.trangobroadband.com/support/product_docs.htm | =head2 B<su_password> - Set the password on SUs connected to the AP. | 
|  |  | 
| L<Net::Telnet> | su_password('new_password'[, 'suid']) If no suid is specified, | 
|  | the default is "all". | 
| =head1 TODO |  | 
|  | $t->su_password('good_pass', 5); | 
| There are still a lot of commands that are not accessed directly.  If you call them (as cmd("command + args") or whatever) and it works, please send me examples that work and I will try to get it incorporated into the next version of the script. |  | 
|  | =cut | 
| I also want to be able to parse the different types of output from commands like su, sudb all and anything else that would be better available as a perl datastructure. |  | 
|  | sub su_password { | 
| =head1 AUTHOR | my $self     = shift; | 
|  | my $new_pass = shift || $EMPTY; | 
| Andrew Fresh E<lt>andrew@rraz.netE<gt> | my $su       = shift || 'all'; | 
|  |  | 
| =head1 COPYRIGHT AND LICENSE | unless ( defined $new_pass ) { | 
|  | $self->last_error("No new password"); | 
| Copyright (C) 2005 by Andrew Fresh |  | 
|  | #return; | 
| This library is free software; you can redistribute it and/or modify | } | 
| it under the same terms as Perl itself, either Perl version 5.8.7 or, |  | 
| at your option, any later version of Perl 5 you may have available. | return $self->cmd( | 
|  | String => 'su password ' | 
|  | . $su | 
| =cut | . $SPACE | 
|  | . $new_pass | 
|  | . $SPACE | 
|  | . $new_pass, | 
|  | expect => $success, | 
|  | ); | 
|  | } | 
|  |  | 
|  | =pod | 
|  |  | 
|  | =head2 B<ipconfig> - Change IP configuration | 
|  |  | 
|  | ipconfig( 'new_ip', 'new_subnet', 'new_gateway' ) | 
|  |  | 
|  | $t->ipconfig( '10.0.1.5', '255.255.255.0', '10.0.1.1' ); | 
|  |  | 
|  | =cut | 
|  |  | 
|  | sub ipconfig { | 
|  | my $self = shift; | 
|  |  | 
|  | my $string = join $SPACE, 'ipconfig', @_; | 
|  |  | 
|  | if ( @_ == 3 ) { | 
|  | $self->print($string); | 
|  | my @lines = $self->waitfor( Match => '/save\s+and\s+activate/', ); | 
|  | $self->print('y'); | 
|  |  | 
|  | $self->logged_in(0); | 
|  | $self->is_connected(0); | 
|  |  | 
|  | foreach my $line (@lines) { | 
|  | if ( $line =~ s/New \s configuration:\s+//xms ) { | 
|  | return _decode_lines($line); | 
|  | } | 
|  | } | 
|  |  | 
|  | return {}; | 
|  | } | 
|  |  | 
|  | # ipconfig [ <new ip> <new subnet> <new gateway> ] | 
|  | return $self->cmd( String => $string, expect => $success ); | 
|  | } | 
|  |  | 
|  | =pod | 
|  |  | 
|  | =head2 B<su_ipconfig> - Change IP configuration on SUs connected to the AP. | 
|  |  | 
|  | su_ipconfig( 'suid', 'new_ip', 'new_subnet', 'new_gateway' ) | 
|  |  | 
|  | $t->su_ipconfig( 5, '10.0.1.5', '255.255.255.0', '10.0.1.1' ); | 
|  |  | 
|  | =cut | 
|  |  | 
|  | sub su_ipconfig { | 
|  | my $self = shift; | 
|  |  | 
|  | my $suid        = shift; | 
|  | my $new_ip      = shift; | 
|  | my $new_subnet  = shift; | 
|  | my $new_gateway = shift; | 
|  |  | 
|  | if ( $suid =~ /\D/ ) { | 
|  | $self->last_error("Invalid suid '$suid'"); | 
|  | return; | 
|  | } | 
|  | unless ($new_ip) { | 
|  | $self->last_error("no new_ip passed"); | 
|  | return; | 
|  | } | 
|  | unless ($new_subnet) { | 
|  | $self->last_error("no new_subnet passed"); | 
|  | return; | 
|  | } | 
|  | unless ($new_gateway) { | 
|  | $self->last_error("no new_gateway passed"); | 
|  | return; | 
|  | } | 
|  |  | 
|  | # su ipconfig <suid> <new ip> <new subnet> <new gateway> | 
|  | return $self->cmd( | 
|  | String => 'su ipconfig ' | 
|  | . $suid | 
|  | . $SPACE | 
|  | . $new_ip | 
|  | . $SPACE | 
|  | . $new_subnet | 
|  | . $SPACE | 
|  | . $new_gateway, | 
|  | expect => $success, | 
|  | ); | 
|  | } | 
|  |  | 
|  | =pod | 
|  |  | 
|  | =head2 B<sudb_view> - Returns the output from the sudb view command | 
|  |  | 
|  | returns a reference to an array of hashes each containing these keys | 
|  | 'suid', 'su2su', 'type', 'cir', 'mir' and 'mac' | 
|  |  | 
|  | =cut | 
|  |  | 
|  | sub sudb_view { | 
|  | my $self = shift; | 
|  |  | 
|  | my $lines = $self->cmd( String => 'sudb view', expect => $success ) || []; | 
|  |  | 
|  | return unless @{$lines}; | 
|  |  | 
|  | my $s = *$self->{net_telnet_trango}; | 
|  | return $lines if !$s->{'Decode'}; | 
|  |  | 
|  | my @sus; | 
|  | foreach ( @{$lines} ) { | 
|  | next unless $_; | 
|  | if (/^ | 
|  | \[(\d+)\] | 
|  | \s+ | 
|  | [[:xdigit:]]{2} | 
|  | ([[:xdigit:]]) | 
|  | ([[:xdigit:]]) | 
|  | \s+ | 
|  | (\d+) | 
|  | \s+ | 
|  | (\d+) | 
|  | \s+ | 
|  | ([[:xdigit:]\s]+) | 
|  | $/ixms | 
|  | ) | 
|  | { | 
|  | my %s = ( | 
|  | suid  => $1, | 
|  | su2su => $2 ? $2 : undef, | 
|  | type  => $3 == 1 ? 'reg' : $3 == 5 ? 'pri' : $3, | 
|  | cir   => $4, | 
|  | mir   => $5, | 
|  | mac   => $6, | 
|  | ); | 
|  |  | 
|  | $s{'mac'} =~ s/\s//gxms; | 
|  | $s{'mac'} = uc( $s{'mac'} ); | 
|  |  | 
|  | push @sus, \%s; | 
|  | } | 
|  | } | 
|  |  | 
|  | return \@sus; | 
|  | } | 
|  |  | 
|  | =pod | 
|  |  | 
|  | =head2 B<sudb_add> - Adds an su to the sudb | 
|  |  | 
|  | Takes the following paramaters | 
|  |  | 
|  | suid : numeric, | 
|  | type : (reg|pr) | 
|  | cir  : numeric, | 
|  | mir  : numeric, | 
|  | mac  : Almost any format, it will be reformatted, | 
|  |  | 
|  | and returns true on success or undef otherwise. | 
|  |  | 
|  | $t->sudb_add($suid, 'reg', $cir, $mir, $mac); | 
|  |  | 
|  | You should save_sudb() after calling this, or your changes  will be lost | 
|  | when the AP is rebooted. | 
|  |  | 
|  | =cut | 
|  |  | 
|  | sub sudb_add { | 
|  | my $self = shift; | 
|  | my $suid = shift; | 
|  | my $type = shift; | 
|  | my $cir  = shift; | 
|  | my $mir  = shift; | 
|  | my $mac  = shift; | 
|  |  | 
|  | if ( $suid =~ /\D/ ) { | 
|  | $self->last_error("Invalid suid '$suid'"); | 
|  | return; | 
|  | } | 
|  |  | 
|  | unless ( lc($type) eq 'reg' || lc($type) eq 'pr' ) { | 
|  | $self->last_error("Invalid type '$type'"); | 
|  | return; | 
|  | } | 
|  |  | 
|  | if ( $cir =~ /\D/ ) { | 
|  | $self->last_error("Invalid CIR '$cir'"); | 
|  | return; | 
|  | } | 
|  |  | 
|  | if ( $mir =~ /\D/ ) { | 
|  | $self->last_error("Invalid MIR '$mir'"); | 
|  | return; | 
|  | } | 
|  |  | 
|  | my $new_mac = $mac; | 
|  | $new_mac =~ s/[^0-9A-Fa-f]//g; | 
|  | unless ( length $new_mac == 12 ) { | 
|  | $self->last_error("Invalid MAC '$mac'"); | 
|  | return; | 
|  | } | 
|  | $new_mac = join $SPACE, $new_mac =~ /../g; | 
|  |  | 
|  | my $string | 
|  | = 'sudb add ' | 
|  | . $suid | 
|  | . $SPACE | 
|  | . $type | 
|  | . $SPACE | 
|  | . $cir | 
|  | . $SPACE | 
|  | . $mir | 
|  | . $SPACE | 
|  | . $new_mac; | 
|  |  | 
|  | return $self->cmd( String => $string, expect => $success ); | 
|  | } | 
|  |  | 
|  | =pod | 
|  |  | 
|  | =head2 B<sudb_delete> - removes an su from the sudb | 
|  |  | 
|  | Takes either 'all' or the  suid of the su to delete | 
|  | and returns true on success or undef otherwise. | 
|  |  | 
|  | $t->sudb_delete($suid); | 
|  |  | 
|  | You should save_sudb() after calling this, or your changes  will be lost | 
|  | when the AP is rebooted. | 
|  |  | 
|  | =cut | 
|  |  | 
|  | sub sudb_delete { | 
|  | my $self = shift; | 
|  | my $suid = shift; | 
|  |  | 
|  | #if (lc($suid) ne 'all' || $suid =~ /\D/) { | 
|  | if ( $suid =~ /\D/ ) { | 
|  | $self->last_error("Invalid suid '$suid'"); | 
|  | return; | 
|  | } | 
|  |  | 
|  | return $self->cmd( String => 'sudb delete ' . $suid, expect => $success ); | 
|  | } | 
|  |  | 
|  | =pod | 
|  |  | 
|  | =head2 B<sudb_modify> - changes the su information in the sudb | 
|  |  | 
|  | Takes either the  suid of the su to change | 
|  | as well as what you are changing, either "cir, mir or su2su" | 
|  | and returns true on success or undef otherwise. | 
|  |  | 
|  | cir and mir also take a value to set the cir/mir to. | 
|  |  | 
|  | su2su takes a group id parameter that is in hex. | 
|  |  | 
|  | $t->sudb_modify($suid, 'cir', 512); | 
|  |  | 
|  | You should save_sudb() after calling this, or your changes  will be lost | 
|  | when the AP is rebooted. | 
|  |  | 
|  | =cut | 
|  |  | 
|  | sub sudb_modify { | 
|  | my $self  = shift; | 
|  | my $suid  = shift; | 
|  | my $opt   = shift; | 
|  | my $value = shift; | 
|  |  | 
|  | if ( $suid =~ /\D/ ) { | 
|  | $self->last_error("Invalid suid '$suid'"); | 
|  | return; | 
|  | } | 
|  |  | 
|  | if ( lc($opt) eq 'cir' or lc($opt) eq 'mir' ) { | 
|  | if ( $value =~ /\D/ ) { | 
|  | $self->last_error("Invalid $opt '$value'"); | 
|  | return; | 
|  | } | 
|  | } | 
|  | elsif ( lc($opt) eq 'su2su' ) { | 
|  | if ( $value =~ /[^0-9A-Za-f]/ ) { | 
|  | $self->last_error("Invalid MAC '$value'"); | 
|  | return; | 
|  | } | 
|  | } | 
|  | else { | 
|  | $self->last_error("Invalid option '$opt'"); | 
|  | return; | 
|  | } | 
|  |  | 
|  | my $string = 'sudb modify ' . $suid . $SPACE . $opt . $SPACE . $value; | 
|  |  | 
|  | return $self->cmd( String => $string, expect => $success ); | 
|  | } | 
|  |  | 
|  | =pod | 
|  |  | 
|  | =head2 B<enable_tftpd> - enable the TFTP server | 
|  |  | 
|  | runs C<tftpd(args =E<gt> 'on')> and makes sure that Tftpd is now 'listen'ing | 
|  |  | 
|  | =cut | 
|  |  | 
|  | sub enable_tftpd { | 
|  | my $self = shift; | 
|  |  | 
|  | my $vals = $self->tftpd( args => 'on' ); | 
|  |  | 
|  | if ( ref $vals eq 'HASH' && $vals->{'Tftpd'} eq 'listen' ) { | 
|  | return $vals; | 
|  | } | 
|  | else { | 
|  | return; | 
|  | } | 
|  | } | 
|  |  | 
|  | =pod | 
|  |  | 
|  | =head2 B<disable_tftpd> - disable the TFTP server | 
|  |  | 
|  | runs C<tftpd(args =E<gt> 'off')> and makes sure that Tftpd is now 'disabled' | 
|  |  | 
|  | =cut | 
|  |  | 
|  | sub disable_tftpd { | 
|  | my $self = shift; | 
|  |  | 
|  | my $vals = $self->tftpd( args => 'off' ); | 
|  |  | 
|  | if ( ref $vals eq 'HASH' && $vals->{'Tftpd'} eq 'disabled' ) { | 
|  | return $vals; | 
|  | } | 
|  | else { | 
|  | return; | 
|  | } | 
|  | } | 
|  |  | 
|  | =pod | 
|  |  | 
|  | =head2 B<cmd> - runs a command on the AP. | 
|  |  | 
|  | This does most of the work.  At the heart, it calls Net::Telnet::cmd() | 
|  | but it also does some special stuff for Trango. | 
|  |  | 
|  | Normally returns the last lines from from the command | 
|  |  | 
|  | If you are using this, rather than one of the "easy" methods above, | 
|  | you probably want to read through the source of this module to see how | 
|  | some of the other commands are called. | 
|  |  | 
|  | In addition to the Net::Telnet::cmd() options, it also accepts these: | 
|  |  | 
|  | I<decode> | 
|  | - if this is true, then it will send the output lines to _decode_lines() | 
|  | and then returns the decoded output | 
|  |  | 
|  | I<no_prompt> | 
|  | - if this is true, it does not wait for a prompt, so you are not stuck | 
|  | waiting for something that will never happen. | 
|  |  | 
|  | I<cmd_disconnects> | 
|  | - if this is true, it then sets logged_in() to false, then it will | 
|  | close() the connection and set is_connected() to false | 
|  |  | 
|  | I<expect> | 
|  | - if this is set (usually to 'Success.') it will check for that in the | 
|  | last line of output and if it does not, will return undef because the | 
|  | command probably failed | 
|  |  | 
|  | I<args> | 
|  | - a string containing the command line options that are passed to the | 
|  | command | 
|  |  | 
|  | $t->cmd( String => 'exit', no_prompt => 1, cmd_disconnects => 1 ); | 
|  |  | 
|  | =cut | 
|  |  | 
|  | sub cmd { | 
|  | my $self = shift; | 
|  | my $s    = *$self->{net_telnet_trango}; | 
|  |  | 
|  | my @valid_net_telnet_opts = qw( | 
|  | String | 
|  | Output | 
|  | Cmd_remove_mode | 
|  | Errmode | 
|  | Input_record_separator | 
|  | Ors | 
|  | Output_record_separator | 
|  | Prompt | 
|  | Rs | 
|  | Timeout | 
|  | ); | 
|  |  | 
|  | my %cfg; | 
|  | if ( @_ == 1 ) { | 
|  | $cfg{'String'} = shift; | 
|  | } | 
|  | elsif ( @_ > 1 ) { | 
|  | %cfg = @_; | 
|  | } | 
|  |  | 
|  | $cfg{'Timeout'} ||= $self->Timeout; | 
|  |  | 
|  | unless ( $cfg{'String'} ) { | 
|  | $self->last_error("No command passed"); | 
|  | return; | 
|  | } | 
|  |  | 
|  | unless ( $self->is_connected ) { | 
|  | $self->last_error("Not connected"); | 
|  | return; | 
|  | } | 
|  |  | 
|  | unless ( $self->logged_in ) { | 
|  | $self->last_error("Not logged in"); | 
|  | return; | 
|  | } | 
|  |  | 
|  | my %cmd; | 
|  | foreach (@valid_net_telnet_opts) { | 
|  | if ( exists $cfg{$_} ) { | 
|  | $cmd{$_} = $cfg{$_}; | 
|  | } | 
|  | } | 
|  | if ( $cfg{'args'} ) { | 
|  | $cmd{'String'} .= $SPACE . $cfg{'args'}; | 
|  | } | 
|  |  | 
|  | #print "Running cmd $cmd{String}\n"; | 
|  | my @lines; | 
|  | if ( $cfg{'no_prompt'} ) { | 
|  | $self->print( $cmd{'String'} ); | 
|  | @lines = $self->lastline; | 
|  | } | 
|  | else { | 
|  | @lines = $self->SUPER::cmd(%cmd); | 
|  | } | 
|  |  | 
|  | $self->last_lines( \@lines ); | 
|  |  | 
|  | my $last   = $self->lastline; | 
|  | my $prompt = $self->prompt; | 
|  | $prompt =~ s{^/}{}xms; | 
|  | $prompt =~ s{/[gixms]*$}{}xms; | 
|  | while ( @lines && $last =~ qr($prompt) ) { | 
|  | pop @lines; | 
|  | $last = $lines[-1]; | 
|  | } | 
|  | $self->last_error($EMPTY); | 
|  |  | 
|  | my $vals = 1; | 
|  | if ( $s->{'Decode'} && $cfg{'decode'} ) { | 
|  | if ( $cfg{'decode'} eq 'each' ) { | 
|  | $vals = _decode_each_line(@lines); | 
|  | } | 
|  | elsif ( $cfg{'decode'} eq 'sulog' ) { | 
|  | $vals = _decode_sulog(@lines); | 
|  | } | 
|  | elsif ( $cfg{'decode'} eq 'maclist' ) { | 
|  | $vals = _decode_maclist(@lines); | 
|  | if ( !$vals ) { | 
|  | $self->last_error("Error decoding maclist"); | 
|  | } | 
|  | } | 
|  | elsif ( $cfg{'decode'} eq 'linktest' ) { | 
|  | $vals = _decode_linktest(@lines); | 
|  | if ( !$vals ) { | 
|  | $self->last_error("Error decoding linktest"); | 
|  | } | 
|  | } | 
|  | elsif ( $cfg{'decode'} eq 'freq' ) { | 
|  | $vals = _decode_freq(@lines); | 
|  | } | 
|  | else { | 
|  | $vals = _decode_lines(@lines); | 
|  | } | 
|  | } | 
|  | if ( ref $vals eq 'HASH' ) { | 
|  | $vals->{_raw} = join q{}, @lines; | 
|  | } | 
|  | $self->last_vals($vals); | 
|  |  | 
|  | if ( ( not $cfg{'expect'} ) || $last =~ /$cfg{'expect'}$/ ) { | 
|  | if ( $cfg{'cmd_disconnects'} ) { | 
|  | $self->logged_in(0); | 
|  | $self->close; | 
|  | $self->is_connected(0); | 
|  | } | 
|  |  | 
|  | if ( $s->{'Decode'} && $cfg{'decode'} ) { | 
|  | return $vals; | 
|  | } | 
|  | else { | 
|  | return \@lines; | 
|  | } | 
|  | } | 
|  | else { | 
|  | my $err; | 
|  | if ( grep {/\[ERR\]/} @lines ) { | 
|  | $err = _decode_lines(@lines); | 
|  | } | 
|  |  | 
|  | if ( ref $err eq 'HASH' && $err->{ERR} ) { | 
|  | $self->last_error( $err->{ERR} ); | 
|  | } | 
|  | else { | 
|  | $self->last_error("Error with command ($cmd{'String'}): $last"); | 
|  | } | 
|  | return; | 
|  | } | 
|  | } | 
|  |  | 
|  | #=item _decode_lines | 
|  |  | 
|  | sub _decode_lines { | 
|  | my @lines = @_; | 
|  |  | 
|  | my %conf; | 
|  |  | 
|  | my $key = $EMPTY; | 
|  | my $val = undef; | 
|  | my @vals; | 
|  | my $in_key = 0; | 
|  | my $in_val = 1; | 
|  |  | 
|  | LINE: while ( my $line = shift @lines ) { | 
|  | next LINE if $line =~ /$success\Z/; | 
|  | next LINE if $line =~ /^ \*+ \s+ \d+ \s+ \*+ \Z/xms; | 
|  |  | 
|  | # Special decode for sysinfo on a TrangoLink 45 | 
|  | if ( $line =~ /^(.* Channel \s+ Table):\s*(.*)\Z/xms ) { | 
|  | my $key  = $1; | 
|  | my $note = $2; | 
|  |  | 
|  | my %vals; | 
|  | while ( $line = shift @lines ) { | 
|  | if ( $line =~ /^\Z/ ) { | 
|  | $conf{$key} = \%vals; | 
|  | $conf{$key}{note} = $note; | 
|  | next LINE; | 
|  | } | 
|  |  | 
|  | my $decoded = _decode_lines($line); | 
|  | if ($decoded) { | 
|  | %vals = ( %vals, %{$decoded} ); | 
|  | } | 
|  | } | 
|  | } | 
|  |  | 
|  | # Another special decode for the TrangoLink | 
|  | elsif ( | 
|  | $line =~ /^ | 
|  | RF \s Band \s \# | 
|  | (\d+) \s+ | 
|  | \( ([^\)]+) \) \s* | 
|  | (.*)$ | 
|  | /xms | 
|  | ) | 
|  | { | 
|  | my $num   = $1; | 
|  | my $band  = $2; | 
|  | my $extra = $3; | 
|  |  | 
|  | if ( $extra =~ /\[/ ) { | 
|  | my $decoded = _decode_lines($extra); | 
|  | $conf{'RF Band'}{$num} = $decoded; | 
|  | } | 
|  | else { | 
|  | $conf{'RF Band'}{$num}{$extra} = 1; | 
|  | } | 
|  | next LINE; | 
|  | } | 
|  |  | 
|  | my @chars = split //, $line; | 
|  |  | 
|  | my $last_key = $EMPTY; | 
|  | foreach my $c (@chars) { | 
|  |  | 
|  | if ( $c eq '[' || $c eq "\r" || $c eq "\n" ) { | 
|  | if ( $c eq '[' ) { | 
|  | $in_key = 1; | 
|  | $in_val = 0; | 
|  | } | 
|  | else { | 
|  | $in_key = 0; | 
|  | $in_val = 1; | 
|  | } | 
|  |  | 
|  | if ($key) { | 
|  | $key =~ s/^\s+//; | 
|  | $key =~ s/\s+$//; | 
|  |  | 
|  | if ($val) { | 
|  | $val =~ s/^\s+//; | 
|  | $val =~ s/\s+\.*$//; | 
|  | } | 
|  |  | 
|  | if ( $key eq 'Checksum' && $last_key ) { | 
|  |  | 
|  | # Special case for these bastids. | 
|  | my $new = $last_key; | 
|  | $new =~ s/\s+\S+$//; | 
|  | $key = $new . $SPACE . $key; | 
|  | } | 
|  |  | 
|  | $conf{$key} = $val; | 
|  | $last_key   = $key; | 
|  | $key        = $EMPTY; | 
|  | } | 
|  | elsif ($val) { | 
|  | push @vals, $val; | 
|  | } | 
|  | $val = $EMPTY; | 
|  |  | 
|  | } | 
|  | elsif ( $c eq ']' ) { | 
|  | $in_val = 1; | 
|  | $in_key = 0; | 
|  | $c      = shift @chars; | 
|  |  | 
|  | } | 
|  | elsif ($in_key) { | 
|  | $key .= $c; | 
|  |  | 
|  | } | 
|  | elsif ($in_val) { | 
|  | $val .= $c; | 
|  | } | 
|  | } | 
|  | } | 
|  |  | 
|  | unless ($key) { | 
|  | push @vals, $val; | 
|  | } | 
|  |  | 
|  | foreach my $val (@vals) { | 
|  | if ( defined $val && length $val ) { | 
|  | $val =~ s/^\s+//; | 
|  | $val =~ s/\s+\.*$//; | 
|  | } | 
|  | } | 
|  |  | 
|  | if ( @vals == 1 ) { | 
|  | $val = $vals[0]; | 
|  | } | 
|  | elsif (@vals) { | 
|  | $val = \@vals; | 
|  | } | 
|  | else { | 
|  | $val = undef; | 
|  | } | 
|  |  | 
|  | if (%conf) { | 
|  | $conf{_pre} = $val if $val; | 
|  | return \%conf; | 
|  | } | 
|  | else { | 
|  | return $val; | 
|  | } | 
|  | } | 
|  |  | 
|  | #=item _decode_each_line | 
|  |  | 
|  | sub _decode_each_line { | 
|  | my @lines = @_; | 
|  | my @decoded; | 
|  | foreach my $line (@lines) { | 
|  | my $decoded = _decode_lines($line); | 
|  | push @decoded, $decoded if defined $decoded && length $decoded; | 
|  | } | 
|  | return \@decoded; | 
|  | } | 
|  |  | 
|  | #=item _decode_linktest | 
|  |  | 
|  | sub _decode_linktest { | 
|  | my @lines = @_; | 
|  | my %decoded; | 
|  | foreach my $line (@lines) { | 
|  |  | 
|  | if ( $line =~ s/^(\d+) \s+ //xms ) { | 
|  | my $line_id = $1; | 
|  | my ( $tm, $rt ); | 
|  | if ( $line =~ s/\s+ (\d+ \s+ \w+) \s* $//xms ) { | 
|  | $rt = $1; | 
|  | } | 
|  | if ( $line =~ s/\s+ (\d+ \s+ \w+) \s* $//xms ) { | 
|  | $tm = $1; | 
|  | } | 
|  |  | 
|  | my $d = _decode_lines( $line . "\n" ); | 
|  | $decoded{tests}[$line_id]         = $d; | 
|  | $decoded{tests}[$line_id]{'time'} = $tm; | 
|  | $decoded{tests}[$line_id]{rate}   = $rt; | 
|  | } | 
|  |  | 
|  | else { | 
|  | my $d = _decode_lines( $line . "\n" ); | 
|  | if ($d) { | 
|  | while ( my ( $k, $v ) = each %{$d} ) { | 
|  | $decoded{$k} = $v; | 
|  | } | 
|  | } | 
|  | } | 
|  |  | 
|  | } | 
|  | return \%decoded; | 
|  | } | 
|  |  | 
|  | #=item _decode_sulog | 
|  |  | 
|  | sub _decode_sulog { | 
|  | my @lines = @_; | 
|  | my @decoded; | 
|  | my $last_tm; | 
|  | foreach my $line (@lines) { | 
|  | my $decoded = _decode_lines($line); | 
|  |  | 
|  | if ( defined $decoded ) { | 
|  | if ( $decoded->{'tm'} ) { | 
|  | $last_tm = $decoded->{'tm'}; | 
|  | next; | 
|  | } | 
|  | else { | 
|  | $decoded->{'tm'} = $last_tm; | 
|  | } | 
|  | next unless $last_tm; | 
|  |  | 
|  | push @decoded, $decoded if defined $decoded; | 
|  | } | 
|  | } | 
|  | return \@decoded; | 
|  | } | 
|  |  | 
|  | #=item _decode_maclist | 
|  |  | 
|  | sub _decode_maclist { | 
|  | my @lines = @_; | 
|  | my @decoded; | 
|  | my $total_entries = 0; | 
|  | my $current_tm    = 0; | 
|  | foreach my $line (@lines) { | 
|  | $line =~ s/\r?\n$//; | 
|  | my ( $mac, $loc, $tm ) = $line =~ / | 
|  | ([0-9a-fA-F ]{17})\s+ | 
|  | (.*)\s+ | 
|  | tm\s+ | 
|  | (\d+) | 
|  | /x; | 
|  |  | 
|  | if ($mac) { | 
|  | $mac =~ s/\s+//g; | 
|  | $loc =~ s/^\s+//; | 
|  | $loc =~ s/\s+$//; | 
|  |  | 
|  | my $suid = undef; | 
|  | if ( $loc =~ /suid\s+=\s+(\d+)/ ) { | 
|  | $suid = $1; | 
|  | $loc  = undef; | 
|  | } | 
|  |  | 
|  | push @decoded, | 
|  | { | 
|  | mac  => $mac, | 
|  | loc  => $loc, | 
|  | tm   => $tm, | 
|  | suid => $suid, | 
|  | }; | 
|  | } | 
|  | elsif ( $line =~ /(\d+)\s+entries/ ) { | 
|  | $total_entries = $1; | 
|  | } | 
|  | elsif ( $line =~ /current tm = (\d+)\s+sec/ ) { | 
|  | $current_tm = $1; | 
|  | } | 
|  | } | 
|  |  | 
|  | map { $_->{'cur_tm'} = $current_tm } @decoded; | 
|  |  | 
|  | if ( scalar @decoded == $total_entries ) { | 
|  | return \@decoded; | 
|  | } | 
|  | else { | 
|  | return; | 
|  | } | 
|  | } | 
|  |  | 
|  | #=item _decode_freq | 
|  |  | 
|  | sub _decode_freq { | 
|  | my @lines   = @_; | 
|  | my $decoded = _decode_lines(@lines); | 
|  |  | 
|  | if ( $decoded && $decoded->{ERR} ) { | 
|  | return $decoded; | 
|  | } | 
|  |  | 
|  | LINE: foreach my $line (@lines) { | 
|  | if (my ( $channel, $polarity, $freq ) | 
|  | = $line =~ / | 
|  | Ch \s+ \#(\d+) | 
|  | \s+ | 
|  | (\w+) | 
|  | \s+ | 
|  | \[ (\d+) \s+ MHz\] | 
|  | /ixms | 
|  | ) | 
|  | { | 
|  | $decoded = { | 
|  | channel   => $channel, | 
|  | polarity  => $polarity, | 
|  | frequency => $freq, | 
|  | }; | 
|  | last LINE; | 
|  | } | 
|  | } | 
|  | return $decoded; | 
|  | } | 
|  |  | 
|  | 1;    # End of Net::Telnet::Trango | 
|  | __END__ | 
|  |  | 
|  | =head1 SEE ALSO | 
|  |  | 
|  | Trango Documentation - | 
|  | L<http://www.trangobroadband.com/support/product_docs.htm> | 
|  |  | 
|  | L<Net::Telnet> | 
|  |  | 
|  | =head1 TODO | 
|  |  | 
|  | There are still a lot of commands that are not accessed directly.  If | 
|  | you call them (as cmd("command + args") or whatever) and it works, | 
|  | please send me examples that work and I will try to get it incorporated | 
|  | into the next version of the script. | 
|  |  | 
|  | I also want to be able to parse the different types of output from | 
|  | commands like su, sudb all and anything else that would be better | 
|  | available as a perl datastructure. | 
|  |  | 
|  | =head1 AUTHOR | 
|  |  | 
|  | Andrew Fresh E<lt>andrew@rraz.netE<gt> | 
|  |  | 
|  | =head1 SUPPORT | 
|  |  | 
|  | You can find documentation for this module with the perldoc command. | 
|  |  | 
|  | perldoc Net::Telnet::Trango | 
|  |  | 
|  | You can also look for information at: | 
|  |  | 
|  | =over 4 | 
|  |  | 
|  | =item * AnnoCPAN: Annotated CPAN documentation | 
|  |  | 
|  | L<http://annocpan.org/dist/Net-Telnet-Trango> | 
|  |  | 
|  | =item * CPAN Ratings | 
|  |  | 
|  | L<http://cpanratings.perl.org/d/Net-Telnet-Trango> | 
|  |  | 
|  | =item * RT: CPAN's request tracker | 
|  |  | 
|  | L<http://rt.cpan.org/NoAuth/Bugs.html?Dist=Net-Telnet-Trango> | 
|  |  | 
|  | =item * Search CPAN | 
|  |  | 
|  | L<http://search.cpan.org/dist/Net-Telnet-Trango> | 
|  |  | 
|  | =back | 
|  |  | 
|  | =head1 COPYRIGHT AND LICENSE | 
|  |  | 
|  | Copyright (C) 2005,2006,2007 by Andrew Fresh | 
|  |  | 
|  | This program is free software; you can redistribute it and/or modify it | 
|  | under the same terms as Perl itself. | 
|  |  | 
|  | =cut |