Difference between revisions of "Commands.pl"
m |
({{legacy}}) |
||
Line 1: | Line 1: | ||
+ | {{#security:*|dev}}{{#security:view|*}}{{legacy}} | ||
+ | <perl> | ||
#!/usr/bin/perl | #!/usr/bin/perl | ||
− | |||
use Net::SCP::Expect; | use Net::SCP::Expect; | ||
Line 280: | Line 281: | ||
} | } | ||
} | } | ||
+ | </perl> |
Revision as of 06:52, 27 April 2007
{{#security:*|dev}}{{#security:view|*}}
<perl>
- !/usr/bin/perl
use Net::SCP::Expect;
- Get initial IP from local wiki log
$::IP = ; if (wikiRawPage($::wiki, $::wikilog) =~ /^.+to ([0-9]+\.[0-9]+\.[0-9]+\.[0-9]+)/sm) { $::IP = $1; logAdd "Last IP obtained from Network Log: $::IP"; }
sub command {
my $command = shift; $command =~ /(.+?)(\((.+)\))?$/; my ($title, $args) = ( $1, $2 ); my $article;
# pon/poff if ($title eq 'ppp') { $article = `ifconfig` } elsif ($title eq 'pon') { `pon`; $article = `tail -n 1 /var/log/syslog|grep pppd`; } elsif ($title eq 'poff') { `poff`; $article = `tail -n 3 /var/log/syslog|grep pppd`; }
# syslog elsif ($title eq 'syslog') { $article = `tail -n 50 /var/log/syslog` }
# peer log elsif ($title eq 'peerlog') { $article = qx( tail -n 50 ../$peer.log ) }
# reboot elsif ($title eq 'reboot') { $article = `shutdown -r now` }
# shutdown elsif ($title eq 'shutdown') { $article = `halt` }
# ps elsif ($title eq 'env') { $^V =~ m/(.)(.)(.)/; my $ver = ord($1).'.'.ord($2).'.'.ord($3); $cmd =~ /^(.+?)\s+(.+)/; $article = "Environment:\nOS:\t$^O\nPERL:\t$1 ($ver)\nDaemon:\t$2\n\n"; $article .= "Current instances of $::peer:\n"; $article .= qx( ps aux|grep "$::daemon\[:] $::peer" ); }
# fileSync elsif ($title eq 'fileSync') { $article = 'Manually executing fileSync()...'; spawn 'fileSync'; }
# wikiSync elsif ($title eq 'wikiSync') { $article = 'Manually executing wikiSync()...'; spawn 'wikiSync'; }
# wikiBackup elsif ($title eq 'wikiBackup') { $article = 'Manually executing wikiBackup()...'; spawn 'wikiBackup', 'od', 'wiki', lc $::peer if $::peer eq 'Bender'; spawn 'wikiBackup', 'closet', 'wiki', lc $::peer if $::peer eq 'Gir'; spawn 'wikiBackup', 'ea', 'meridian', lc $::peer if $::peer eq 'helios'; }
# peerBackup elsif ($title eq 'peerBackup') { $article = 'Manually executing peerBackup()...'; spawn 'peerBackup'; }
# serverBackup elsif ($title eq 'serverBackup') { $article = 'Manually executing serverBackup()...'; spawn 'serverBackup'; }
# scpBackups elsif ($title eq 'scpBackups') { $article = 'Manually executing scpBackups()...'; spawn 'scpBackups', 'od', 'gir.peerix.org' if $::peer eq 'Bender'; spawn 'scpBackups', 'gir', 'organicdesign.co.nz' if $::peer eq 'Gir'; spawn 'scpBackups', 'ma', 'organicdesign.co.nz' if $::peer eq 'helios'; }
# swfCompile elsif ($title eq 'swfCompile') { $article = swfCompile() }
# Restart # - For some reason it fucks up if it doesn't wait for a minute # - 2005-12-09 tried closing handles and server->shutdown(SHUT_RDWR) but made no difference elsif ($title eq 'restart') { restart() }
elsif ($title eq 'stop') { logAdd "$daemon is stopping"; killChildren(); exit; }
else { logAdd $article = "Unknown command: $command" }
return $article; }
- Restart the peer
sub restart { logAdd "$daemon is restarting using: $::cmd"; killChildren(); exec "sleep 1; $::cmd"; }
- Kill all processes related to this peer
sub killChildren { for ( split /\n/, qx( ps x|grep "$::daemon\[:] $::peer" ) ) { if ( /^\s*([0-9]+).+?\d+:\d\d\s*(.+)/ and $1 != $$ ) { qx( kill $1 ); logAdd "Kill $2 ($1)"; } } logAdd "Kill $0 ($$)"; }
- Backup wiki LocalFS cache
sub peerBackup { my $file = '/var/www/wiki/peer.tgz'; qx(tar -czf $file ./); my $size = int([stat $file]->[7]/104857.6+0.5)/10; my $comment = "Peer Backup: $file ($size\MB)"; logAdd $comment; wikiPageAppend($::wiki, $::wikilog, "\n*".localtime()." : $comment", $comment); }
- Backup the server image
- - this backup can be unpacked over a minimal debian install, or even over our VPS's default redhat install
- - use [[Debian Conversion]] notes for unpacking process
sub serverBackup { my $name = '/server-image-'.strftime('%Y-%m-%d', localtime).'.t7z'; my $incl = '/bin /var /etc /srv /sbin /root /lost+found /lib /usr'; my $excl = ; $excl .= " --exclude='$_'" for ( '/var/backups/*.gz', '/var/tmp/*', '/var/www/*', '/var/peerd', '/var/cache/apt/archives/*.deb', '/var/log/*.gz', '/var/run/mail/*', '/var/log/apache2/*', '/var/log/wtmp*', '/var/log/auth.*', '/var/log/mysql*', '/var/lib/mysql/wiki', '/var/lib/mysql/ib*'); qx(rm -R $name); qx(tar pcf - $incl $excl | 7za a -si -t7z -m0=lzma -mx=9 $name); my $hash = $1 if qx(md5sum $name) =~ /^(\S+)/; my $size = int([stat "$name"]->[7]/1048576+0.5); my $comment = "Server image created: $name (size:$size\MB hash:$hash)"; logAdd $comment; wikiPageAppend($::wiki, $::wikilog, "\n*".localtime()." : $comment", $comment); }
- Backup wiki database
sub wikiBackup { my $lpf = shift; my $db = shift; my $user = shift; my $name = "$lpf-wiki-db-".strftime('%Y-%m-%d', localtime); my $ext = '.t7z'; chdir '..'; mkdir $name; if ($lpf eq 'od') { qx(cp -R /var/www/od $name/od); qx(rm -fr $name/od/wiki/tmp); qx(rm -fr $name/od/wiki/bin/*); qx(rm -fr $name/od/wiki/images/temp); qx(rm -fr $name/od/wiki/images/math); qx(rm -fr $name/od/wiki/images/thumb); } else { qx(cp -R /var/www/wiki/images $name/images) } qx(cp -R /var/www/azzuro/wiki $name/azzuro) if $::peer eq 'helios'; qx(mysqldump $db -u $user --password='$::pwd1' > $name/$db.sql); qx(rm $name$ext); qx(tar pcf - $name | 7za a -md=32m -si -t7z -m0=lzma -mx=9 $name$ext); qx(rm -R $name); chmod($::peer eq 'helios' ? 0666 : 0600, "$name$ext"); my $hash = $1 if qx(md5sum $name$ext) =~ /^(\S+)/; my $size = int([stat "$name$ext"]->[7]/104857.6+0.5)/10; my $comment = "Wiki Backup: $name$ext (size:$size\MB hash:$hash)"; chdir 'peer'; logAdd $comment; wikiPageAppend($::wiki, $::wikilog, "\n*".localtime()." : $comment", $comment); }
- Transfer the days backup over SSH using SCP
sub scpBackups { my $lpf = shift; if ($#_>0) { spawn 'scpBackups', $lpf, $_ for @_ } else { my $domain = shift; my $name = $lpf.'-wiki-db-'.strftime("%Y-%m-%d", localtime).'.t7z'; my $lp = lc $::peer; logAdd "scp ../$name $lp\@$domain:/home/$lp"; my $scp = new Net::SCP::Expect( host => $domain, user => $lp, password => $::pwd1, auto_yes => 1, preserve => 1 ); $scp->scp("../$name", "/home/$lp"); my $comment = "$name transferred to $domain"; wikiPageAppend($::wiki, $::wikilog, "\n*".localtime()." : $comment", $comment); } logAdd "Exit."; }
- Clear sandbox
sub clearSandbox { wikiPageEdit( $::wiki, $_, '
', "Clearing sandbox: $_" ) for @_;
}
- update IP with zoneedit.com/namecheap.com if changed
sub dynamicDNS { my $routerIP = shift; my $routerModel = shift; my $domain = shift; my @subDomains = @_;
while (1) {
# Get external IP from local router depending on make and model my $lasti = $::IP; my $i = '0.0.0.0'; if ($routerModel eq 'Dynalink:RTA230') { my $url = "http://admin:$::pwd2\@$routerIP/wancfg.cmd?action=view"; $i = $1 if $::client->get($url)->content =~ /(\d+\.\d+\.\d+\.\d+)/; } elsif ($routerModel eq 'LinkSys:WAG54G') { my $url = "http://admin:$::pwd2\@$routerIP/Status_Router.asp"; $i = $1 if $::client->get($url)->content =~ /IP Address.+?(\d+\.\d+\.\d+\.\d+)/sm; } elsif ($routerModel eq 'Dlink:DSL-G604T') { my $url = "http://admin:$::pwd2\@$routerIP/cgi-bin/webcm"; my %form = ( getpage => '../html/status/deviceinfofile.htm', 'var:mycon' => 'connection0', 'var:conid' => 'encaps0' ); $i = $1 if $::client->post($url,\%form)->content =~ /IP Address.+?IP Address.+?(\d+\.\d+\.\d+\.\d+)/sm; }
# Log if the IP has just become 0.0.0.0 if ( ($lasti ne '0.0.0.0') && ($i eq '0.0.0.0') ) { logAdd 'External IP address has changed to 0.0.0.0' }
# If IP changed, update DNS servers if ( ($i ne '0.0.0.0') && ($i ne $::IP) ) { my $comment; my $tries = 5; while ($tries > 0) { sleep 300 if $tries-- < 5; $comment = "External IP has changed to $i"; my @succeeded = (); my @failed = (); wikiLogin('http://www.organicdesign.co.nz/wiki/index.php',$::peer,$::pwd1); for my $subDomain (@subDomains) { my $url = $domain =~ /\.co\.nz$/ ? "http://ADunkley:$::pwd3\@dynamic.zoneedit.com/auth/dynamic.html?host=$subDomain.$domain" : "http://dynamicdns.park-your-domain.com/update?host=$subDomain&domain=$domain&password=$::pwd3"; $::client->get($url)->is_success ? push(@succeeded,"$subDomain.$domain") : push(@failed,"$subDomain.$domain"); } if (($#failed >= 0) && ($tries == 0)) { $comment .= ', DNS updates failed!'; wikiPageAppend( 'http://www.organicdesign.co.nz/wiki/index.php', 'user_talk:nad', "\n----\n$comment.\n\nThese domains failed:\n*".join("\n*",@failed)."\n:--~~"."~~\n", "Sorry to bother you, but I need help updating some domains :-/" ); } $tries = 0 if $#failed < 0; }
# update the IP log on the wiki logAdd $comment; wikiPageAppend($::wiki, $::wikilog, "\n*".localtime()." : $comment", $comment);
$::IP = $i; }
sleep 10; } } </perl>