| version 1.2, 2005/11/16 05:26:37 | version 1.8, 2005/11/17 20:20:59 | 
|  |  | 
| #!/usr/bin/perl | #!/usr/bin/perl | 
| # $RedRiver: update_trango.pl,v 1.1 2005/11/16 03:28:42 andrew Exp $ | # $RedRiver: update_trango.pl,v 1.7 2005/11/17 20:09:45 andrew Exp $ | 
| ######################################################################## | ######################################################################## | 
| # update_trango.pl *** Updates trango foxes with a new firmware | # update_trango.pl *** Updates trango foxes with a new firmware | 
| # | # | 
|  |  | 
|  |  | 
| use Net::Telnet; | use Net::Telnet; | 
| use Net::TFTP; | use Net::TFTP; | 
| use YAML; | use Fcntl ':flock'; # import LOCK_* constants | 
|  | #use YAML; | 
|  | use constant LOG_SAVE => 1; | 
|  |  | 
| my @Foxes = ( |  | 
| '10.100.3.8', |  | 
| #  '10.100.3.11', |  | 
| #  '10.100.3.12', |  | 
| #  '10.100.3.13', |  | 
| ); |  | 
|  |  | 
| my $password = 'password'; | my $config_file = shift || 'update_trango.conf'; | 
|  | my $max_tries = 1; | 
|  |  | 
| my $new_file  = 'fsu53_2p0a2H0003D05101403.s19'; |  | 
| my $new_ver   = 'FSU 1p06H0003D04111001'; |  | 
| my $new_cksum = 'x1D28DCC4'; |  | 
|  |  | 
| my $max_tries = 3; |  | 
|  |  | 
|  |  | 
|  |  | 
|  |  | 
|  |  | 
|  | my $log_file =  GetLogName('UT'); | 
|  | my $MYLOG;  # file handle for logging so we don't have to close and open it all the time | 
|  | END { | 
|  | if ($MYLOG) { | 
|  | mylog("Closing log ($log_file)"); | 
|  | close $MYLOG; | 
|  | } | 
|  | } | 
|  |  | 
| foreach my $fox (@Foxes) { |  | 
| print "getting temp from Fox: $fox\n"; | mylog("Reading config file '$config_file'", LOG_SAVE); | 
|  | my $conf = read_conf($config_file); | 
|  |  | 
|  | mylog("  Hardware Type: $conf->{'type'}", LOG_SAVE); | 
|  | mylog("  File Name:     $conf->{'file_name'}", LOG_SAVE); | 
|  | mylog("  File Size:     $conf->{'file_size'}", LOG_SAVE); | 
|  | mylog("  File Checksum: $conf->{'file_cksum'}", LOG_SAVE); | 
|  | mylog("  FW Version:    $conf->{'ver'}", LOG_SAVE); | 
|  | mylog("  FW Checksum:   $conf->{'cksum'}", LOG_SAVE); | 
|  | mylog("", LOG_SAVE); | 
|  |  | 
|  |  | 
|  |  | 
|  |  | 
|  |  | 
|  |  | 
|  | foreach my $fox (@{ $conf->{'ips'} }) { | 
|  | mylog("Updating: $fox", LOG_SAVE); | 
|  |  | 
| ## Connect and login. | ## Connect and login. | 
| my $host = new Net::Telnet (Timeout => 5, | my $host = new Net::Telnet (Timeout => 5, | 
| Prompt => '/#> *$/'); | Prompt => '/#> *$/'); | 
| $host->open($fox); | mylog("Connecting to $fox"); | 
|  | unless ( $host->open( Host => $fox, Errmode => 'return') ) { | 
|  | mylog("Couldn't connect to $fox.  Connection timed out.", LOG_SAVE); | 
|  | next; | 
|  | } | 
| $host->dump_log('dump.log'); | $host->dump_log('dump.log'); | 
|  |  | 
| ## Login to remote host. | ## Login to remote host. | 
| $host->waitfor( | unless ($host->waitfor( | 
| -match => '/password: ?$/i', | -match => '/password: ?$/i', | 
| -errmode => "return", | -errmode => "return", | 
| ) or die "problem connecting to host ($fox): ", $host->lastline; | ) ) { | 
| $host->print($password); | mylog("problem connecting to host ($fox): " . $host->lastline, LOG_SAVE); | 
| $host->waitfor( | next; | 
|  | } | 
|  |  | 
|  | my $login_banner = $host->lastline; | 
|  | my ($type, $version) = $login_banner =~ | 
|  | /Welcome to Trango Broadband Wireless (\w+)-(.+)$/i; | 
|  |  | 
|  | if ($type ne $conf->{'type'}) { | 
|  | mylog("Wrong type of unit ('$type' should be '$conf->{'type'}')", LOG_SAVE); | 
|  | $host->close; | 
|  | next; | 
|  | } | 
|  |  | 
|  | if ($version eq $conf->{'ver'}) { | 
|  | mylog("Already up to date with firmware version '$version'", LOG_SAVE); | 
|  | $host->close; | 
|  | next; | 
|  | } | 
|  |  | 
|  | mylog("Logging in"); | 
|  | $host->print($conf->{'password'}); | 
|  | unless ($host->waitfor( | 
| -match => $host->prompt, | -match => $host->prompt, | 
| -errmode => "return", | -errmode => "return", | 
| ) or die "login ($fox) failed: ", $host->lastline; | ) ) { | 
|  | mylog("login ($fox) failed: " . $host->lastline); | 
|  | next; | 
|  | } | 
|  |  | 
|  |  | 
|  | mylog("Sending commands"); | 
| ## Send commands | ## Send commands | 
| if ( upload($host, $new_file) ) { | if ( upload($host, $fox, $conf->{'file_name'}) ) { | 
| $host->send('reboot'); | mylog("Rebooting"); | 
|  | $host->print("reboot\n"); | 
|  | $host->getline; | 
| } else { | } else { | 
| $host->send('exit'); | mylog("Exiting"); | 
|  | $host->print("exit\n"); | 
|  | $host->getline; | 
| } | } | 
| $host->close; | $host->close; | 
|  | mylog("", LOG_SAVE); | 
| } | } | 
|  |  | 
| sub upload | sub upload | 
| { | { | 
| my $host = shift; | my $host = shift; | 
|  | my $fox  = shift; | 
| my $file = shift; | my $file = shift; | 
|  |  | 
|  | mylog("Getting current version"); | 
| my $ver = get_ver($host); | my $ver = get_ver($host); | 
|  |  | 
| if ( | if ( | 
| $ver->{'Firmware Version'} eq $new_ver && | $ver->{'Firmware Version'}  eq $conf->{'ver'} && | 
| $ver->{'Checksum'}         eq $new_cksum | $ver->{'Firmware Checksum'} eq $conf->{'cksum'} | 
| ) { | ) { | 
| print "Already updated!"; | mylog("Already updated!", LOG_SAVE); | 
| return 1; | return 1; | 
| } | } | 
|  |  | 
| my $try = 0; | my $try = 0; | 
| while (1) { | while (1) { | 
|  | if ($try >= $max_tries) { | 
|  | mylog("Couldn't update in $max_tries tries!"); | 
|  | return undef; | 
|  | } | 
| $try++; | $try++; | 
|  |  | 
|  | #sysinfo($host); | 
|  |  | 
|  | mylog("Enabling TFTPd"); | 
| enable_tftpd($host) || die "Couldn't enable tftpd"; | enable_tftpd($host) || die "Couldn't enable tftpd"; | 
|  |  | 
|  | mylog("Uploading file ($file)"); | 
| # use tftp to push the file up | # use tftp to push the file up | 
|  | my $tftp = Net::TFTP->new($fox, Mode => 'octet'); | 
|  |  | 
|  | $tftp->put($file, $file) | 
|  | or die "Error uploading: " . $tftp->error; | 
|  |  | 
| # waitfor some sort of output | # waitfor some sort of output | 
| # make sure it says 'Success.' otherwise error | # make sure it says 'Success.' otherwise error | 
|  | #print "LAST: " . $host->lastline; | 
|  | #my @lines = $host->getlines; | 
|  | #print Dump \@lines; | 
|  |  | 
|  | mylog("Checking upload ($conf->{'file_cksum'})"); | 
| my $results = check_tftpd($host); | my $results = check_tftpd($host); | 
| # check the 'File Length' against ??? | # check the 'File Length' against ??? | 
|  | if ( $results->{'File Checksum'} ne $conf->{'file_cksum'}) { | 
|  | mylog("File checksum does not match config file!", LOG_SAVE); | 
|  | next; | 
|  | } | 
|  | mylog("File checksum ($results->{'File Checksum'}) " . | 
|  | "matches ($conf->{'file_cksum'})"); | 
|  |  | 
| # 'updateflash mainimage $old_cksum $new_cksum' | if ($results->{'File Length'}   !~ /^$conf->{'file_size'} bytes/) { | 
| # OR | mylog("File length does not match config file!", LOG_SAVE); | 
| # 'save mainimage [current firmware checksum] [new firmware checksum]' | next; | 
| # waitfor a prompt, look at the end of the output for 'Success.' otherwise | } | 
| # error. | mylog("File length ($results->{'File Length'}) " . | 
| # decode_lines to get 'Checksum' to see if it matches $new_cksum | "matches ($conf->{'file_size'})"); | 
|  |  | 
| $ver = get_ver($host); |  | 
| # check versions |  | 
|  |  | 
|  |  | 
| if ($try >= $max_tries) { | if ( uc($results->{'File Name'}) ne uc($conf->{'file_name'}) ) { | 
| warn "Couldn't update in $max_tries tries!"; | mylog("File name does not match config file!", LOG_SAVE); | 
| return undef; | next; | 
| } | } | 
|  | mylog("File name ($results->{'File Name'}) " . | 
|  | "matches ($conf->{'file_name'})"); | 
|  |  | 
|  | mylog("Updating flash (new checksum '$conf->{'cksum'}')"); | 
|  | $results = updateflash( | 
|  | $host, $ver->{'Firmware Checksum'}, $conf->{'cksum'} | 
|  | ) or die "Couldn't update flash: " . $host->lastline; | 
|  | unless ( | 
|  | defined $results->{'Checksum'} && | 
|  | $results->{'Checksum'} eq $conf->{'cksum'} | 
|  | ) { | 
|  | mylog("Saved checksum does not match config file!", LOG_SAVE); | 
|  | next; | 
|  | } | 
|  | mylog("Uploaded checksum ($results->{'Checksum'}) " . | 
|  | "matches ($conf->{'cksum'})"); | 
|  |  | 
|  | mylog("Successfully updated!", LOG_SAVE); | 
|  | return 1; | 
| } | } | 
| } | } | 
|  |  | 
|  |  | 
| { | { | 
| my $host = shift; | my $host = shift; | 
|  |  | 
| my $vals = cmd($host, 'tftpd on'); | my $vals = cmd($host, 'tftpd on', 'Success.'); | 
|  |  | 
| if ($vals->{'Tftpd'} eq 'listen') { | if ($vals->{'Tftpd'} eq 'listen') { | 
| return 1; | return $vals; | 
| } else { | } else { | 
| return undef; | return undef; | 
| } | } | 
|  |  | 
| sub check_tftpd | sub check_tftpd | 
| { | { | 
| my $host = shift; | my $host = shift; | 
| return cmd($host, 'tftpd'); | return cmd($host, 'tftpd', 'Success.'); | 
| } | } | 
|  |  | 
|  | sub sysinfo | 
|  | { | 
|  | my $host = shift; | 
|  | return cmd($host, 'sysinfo', 'Success.'); | 
|  | } | 
|  |  | 
|  | sub updateflash | 
|  | { | 
|  | my $host = shift; | 
|  | my $old = shift; | 
|  | my $new = shift; | 
|  |  | 
|  | return undef unless $new; | 
|  |  | 
|  | return cmd($host, "updateflash mainimage $old $new", 'Success.', 90); | 
|  | } | 
|  |  | 
| sub cmd | sub cmd | 
| { | { | 
| my $host   = shift; | my $host   = shift; | 
| my $string = shift; | my $string = shift; | 
|  | my $expect_last = shift; | 
|  | my $timeout = shift || 5; | 
|  |  | 
| my @lines = $host->cmd($string); | my @lines = $host->cmd(String => $string, Timeout => $timeout); | 
|  |  | 
| my $vals = decode_lines(@lines); | my $vals = decode_lines(@lines); | 
| return $vals; |  | 
|  | my $last = $host->lastline; | 
|  |  | 
|  | unless ($expect_last) { | 
|  | return $vals; | 
|  | } | 
|  |  | 
|  | if ($last =~ /$expect_last$/) { | 
|  | return $vals; | 
|  | } else { | 
|  | warn "Error with command ($string): $last"; | 
|  | return undef; | 
|  | } | 
| } | } | 
|  |  | 
| sub decode_lines | sub decode_lines | 
| { | { | 
| ### XXX ver has 2 Checksums.  one for FPGA and one for Firmware.  DOH! |  | 
| my @lines = @_; | my @lines = @_; | 
|  |  | 
| my %conf; | my %conf; | 
|  |  | 
| foreach my $line (@lines) { | foreach my $line (@lines) { | 
| my @chars = split //, $line; | my @chars = split //, $line; | 
|  |  | 
|  | my $last_key = ''; | 
| foreach my $c (@chars) { | foreach my $c (@chars) { | 
| next if $c eq "\r"; |  | 
| next if $c eq "\n"; |  | 
|  |  | 
| if ($c eq '[') { | if ($c eq '[' || $c eq "\r" || $c eq "\n") { | 
| $in_key = 1; | if ($c eq '[') { | 
| $in_val = 0; | $in_key = 1; | 
|  | $in_val = 0; | 
|  | } else { | 
|  | $in_key = 0; | 
|  | $in_val = 0; | 
|  | } | 
|  |  | 
| if ($key) { | if ($key) { | 
|  | $key =~ s/^\s+//; | 
|  | $key =~ s/\s+$//; | 
|  |  | 
|  | $val =~ s/^\s+//; | 
| $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 . " " . $key; | 
|  | } | 
|  |  | 
|  | $last_key = $key; | 
| $conf{$key} = $val; | $conf{$key} = $val; | 
| $key = ''; | $key = ''; | 
| $val = ''; | $val = ''; | 
|  |  | 
| } | } | 
| } | } | 
| } | } | 
| print Dump \%conf; | #print Dump \%conf; | 
|  |  | 
| if (%conf) { | if (%conf) { | 
| return \%conf; | return \%conf; | 
|  |  | 
| } | } | 
| } | } | 
|  |  | 
|  | sub read_conf | 
|  | { | 
|  | my $file = shift; | 
|  | my %conf; | 
|  | my $in_ip_list = 0; | 
|  | open my $fh, $file or die "Couldn't open file $file: $!"; | 
|  | while (<$fh>) { | 
|  | chomp; | 
|  | next if /^#/; | 
|  | next if /^$/; | 
|  | if ($in_ip_list) { | 
|  | if (/^(\d{1,3}\.\d{1,3}\.\d{1,3}\.)(\d{1,3})-(\d{1,3})/) { | 
|  | push @{ $conf{'ips'} }, $1 . $_ for ($2..$3); | 
|  | } else { | 
|  | push @{ $conf{'ips'} }, $_; | 
|  | } | 
|  | } else { | 
|  | my ($key, $val) = split /\s+/, $_, 2; | 
|  |  | 
|  | if (lc($key) eq 'ips') { | 
|  | $in_ip_list = 1; | 
|  | next; | 
|  | } | 
|  |  | 
|  | $conf{ lc($key) } = $val; | 
|  | } | 
|  | } | 
|  | close $fh; | 
|  |  | 
|  | #print Dump \%conf; | 
|  | foreach ( | 
|  | 'password', | 
|  | 'file_name', 'file_size', 'file_cksum', | 
|  | 'ver', 'cksum', 'ips', | 
|  | ) { | 
|  | die "No $_ specified in config file!" | 
|  | if (not exists $conf{$_}); | 
|  | } | 
|  |  | 
|  | #print Dump \%conf; | 
|  | #exit; | 
|  | return \%conf; | 
|  | } | 
|  |  | 
|  | sub mylog | 
|  | { | 
|  | my $thing = shift; | 
|  | chomp $thing; | 
|  | my $save = shift; | 
|  |  | 
|  | print $thing, "\n"; | 
|  |  | 
|  | if (defined $save && $save == LOG_SAVE) { | 
|  | unless ($MYLOG) { | 
|  | open ($MYLOG, '>>', $log_file) | 
|  | or die "Couldn't open logfile!\n"; | 
|  | my $ofh = select $MYLOG; | 
|  | $|=1; | 
|  | select $ofh; | 
|  | mylog("Opened log ($log_file)"); | 
|  | } | 
|  |  | 
|  | flock($MYLOG, LOCK_EX); | 
|  | print $MYLOG (scalar gmtime), "\t", $thing, "\n" | 
|  | or die "Couldn't print to MYLOG: $!"; | 
|  | flock($MYLOG, LOCK_UN); | 
|  | } | 
|  | } | 
|  |  | 
|  | sub GetLogName | 
|  | { | 
|  | my $prefix  = shift || die "Invalid prefix passed for log"; | 
|  |  | 
|  | my $logdate = GetLogDate(); | 
|  | my $logver  = 0; | 
|  | my $logname; | 
|  |  | 
|  | do { | 
|  | $logname = $prefix . $logdate . sprintf("%02d", $logver) . '.log'; | 
|  | $logver++; | 
|  | } until (not -e $logname); | 
|  |  | 
|  | return $logname; | 
|  | } | 
|  |  | 
|  | sub GetLogDate | 
|  | { | 
|  | my ($sec,$min,$hour,$mday,$mon,$year,,,) = localtime(); | 
|  |  | 
|  | $mon++; | 
|  | $year += 1900; | 
|  |  | 
|  | if ($min  < 10) { $min  = "0$min"  } | 
|  | if ($sec  < 10) { $sec  = "0$sec"  } | 
|  | if ($hour < 10) { $hour = "0$hour" } | 
|  | if ($mday < 10) { $mday = "0$mday" } | 
|  | if ($mon  < 10) { $mon  = "0$mon"  } | 
|  |  | 
|  | my $time = $year . $mon . $mday; | 
|  |  | 
|  | return $time; | 
|  | } |