mirror of
https://github.com/vincentmli/bpfire.git
synced 2026-04-24 09:52:58 +02:00
8e58bd3706
git-svn-id: http://svn.ipfire.org/svn/ipfire/trunk@610 ea5c0bd1-69bd-2848-81d8-4f18e57aeed8
485 lines
9.8 KiB
Perl
485 lines
9.8 KiB
Perl
#!/usr/bin/perl -w
|
|
|
|
require "/opt/pakfire/etc/pakfire.conf";
|
|
|
|
use File::Basename;
|
|
use File::Copy;
|
|
use LWP::UserAgent;
|
|
use Net::Ping;
|
|
|
|
package Pakfire;
|
|
|
|
sub message {
|
|
my $message = shift;
|
|
print "$message\n";
|
|
logger("$message");
|
|
}
|
|
|
|
sub logger {
|
|
my $log = shift;
|
|
system("logger -t pakfire \"$log\"");
|
|
}
|
|
|
|
sub pinghost {
|
|
my $host = shift;
|
|
|
|
$p = Net::Ping->new();
|
|
if ($p->ping($host)) {
|
|
logger("$host is alive.");
|
|
return 1;
|
|
} else {
|
|
logger("$host is dead.");
|
|
return 0;
|
|
}
|
|
$p->close();
|
|
}
|
|
|
|
sub fetchfile {
|
|
my $file = shift;
|
|
my $host = shift;
|
|
my (@server, $proto);
|
|
|
|
use File::Basename;
|
|
|
|
if ("$host" eq "") {
|
|
@server = selectmirror();
|
|
$proto = $server[0];
|
|
$host = $server[1];
|
|
$file = "$server[2]/$file";
|
|
}
|
|
|
|
logger("Trying to get $file from $host ($proto).");
|
|
|
|
$bfile = basename("$file");
|
|
|
|
my $ua = LWP::UserAgent->new;
|
|
$ua->agent("Pakfire/$Conf::version");
|
|
#$ua->timeout(5);
|
|
#$ua->env_proxy;
|
|
|
|
my $response = $ua->get("http://$host/$file");
|
|
if ($response->is_success) {
|
|
if (open(FILE, ">$Conf::cachedir/$bfile")) {
|
|
print FILE $response->content;
|
|
close(FILE);
|
|
} else {
|
|
message("Could not open $Conf::cachedir/$bfile for writing.");
|
|
}
|
|
logger("$host sends file: $file.");
|
|
return 1;
|
|
}
|
|
else {
|
|
my $log = $response->status_line;
|
|
logger("$log");
|
|
return 0;
|
|
}
|
|
}
|
|
|
|
sub testhost {
|
|
my $host = shift;
|
|
|
|
my $ua = LWP::UserAgent->new;
|
|
$ua->agent('Pakfire/2.1');
|
|
$ua->timeout(5);
|
|
# $ua->env_proxy;
|
|
|
|
my $response = $ua->get("http://$host/dummy");
|
|
if ($response->is_success) {
|
|
logger("$host answers my request.");
|
|
return 1;
|
|
}
|
|
else {
|
|
my $log = $response->status_line;
|
|
logger("Server does not work properly: $log");
|
|
return 0;
|
|
}
|
|
}
|
|
|
|
sub getmirrors {
|
|
use File::Copy;
|
|
|
|
logger("Try to get a mirror list.");
|
|
|
|
fetchfile("lists/$Conf::version-server-list", "$Conf::mainserver");
|
|
move("$Conf::cachedir/$Conf::version-server-list", "$Conf::dbdir/lists/$Conf::version-server-list");
|
|
}
|
|
|
|
sub selectmirror {
|
|
### Check if there is a current server list and read it.
|
|
# If there is no list try to get one.
|
|
my $count = 0;
|
|
while (!(open(FILE, "<$Conf::dbdir/lists/$Conf::version-server-list")) && ($count lt 5)) {
|
|
$count++;
|
|
getmirrors();
|
|
}
|
|
if ($count == 5) {
|
|
message("Could not find or download a server list.");
|
|
exit 1;
|
|
}
|
|
my @lines = <FILE>;
|
|
close(FILE);
|
|
|
|
### Count the number of the servers in the list
|
|
my $scount = 0;
|
|
foreach (@lines) {
|
|
$scount++;
|
|
}
|
|
logger("$scount servers found in list.");
|
|
|
|
### Choose a random server and test if it is online
|
|
# If the check fails try a new server.
|
|
# This will never give up.
|
|
my $found = 0;
|
|
my $servers = 0;
|
|
while ($found == 0) {
|
|
$server = int(rand($scount) + 1);
|
|
$servers = 0;
|
|
my ($line, $proto, $path, $host);
|
|
my @templine;
|
|
foreach $line (@lines) {
|
|
$servers++;
|
|
if ($servers eq $server) {
|
|
@templine = split(/\;/, $line);
|
|
$proto = $templine[0];
|
|
$host = $templine[1];
|
|
$path = $templine[2];
|
|
if (pinghost("$host")) {
|
|
$found = 1;
|
|
return ($proto, $host, $path);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
sub dbgetlist {
|
|
### Update the database if the file is older than one day.
|
|
# If you pass &Pakfire::dbgetlist(force) the list will be downloaded.
|
|
# Usage is always with an argument.
|
|
my $force = shift;
|
|
my $age;
|
|
|
|
use File::Copy;
|
|
|
|
if ( -e "$Conf::dbdir/lists/packages_list.db" ) {
|
|
my @stat = stat("$Conf::dbdir/lists/packages_list.db");
|
|
my $time = time();
|
|
$age = $time - $stat[9];
|
|
} else {
|
|
# Force an update.
|
|
$age = "86401";
|
|
}
|
|
|
|
if (("$age" gt 86400) || ("$force" eq "force")) {
|
|
cleanup();
|
|
fetchfile("lists/packages_list.db", "");
|
|
move("$Conf::cachedir/packages_list.db", "$Conf::dbdir/lists/packages_list.db");
|
|
}
|
|
}
|
|
|
|
sub dblist {
|
|
### This subroutine lists the packages.
|
|
# You may also pass a filter: &Pakfire::dblist(filter)
|
|
# Usage is always with two arguments.
|
|
# filter may be: all, notinstalled, installed
|
|
my $filter = shift;
|
|
my $forweb = shift;
|
|
|
|
### Make sure that the list is not outdated.
|
|
dbgetlist("noforce");
|
|
|
|
open(FILE, "<$Conf::dbdir/lists/packages_list.db");
|
|
my @db = <FILE>;
|
|
close(FILE);
|
|
|
|
my $line;
|
|
my @templine;
|
|
foreach $line (sort @db) {
|
|
@templine = split(/\;/,$line);
|
|
### filter here...
|
|
if ("$forweb" eq "forweb") {
|
|
print "<option value=\"$templine[0]\">$templine[1]</option>\n";
|
|
} else {
|
|
print "$templine[0] $templine[1]\n";
|
|
}
|
|
}
|
|
}
|
|
|
|
sub resolvedeps {
|
|
my $pak = shift;
|
|
|
|
getmetafile("$pak");
|
|
|
|
message("\n## Resolving dependencies for $pak...");
|
|
|
|
open(FILE, "<$Conf::dbdir/meta/meta-$pak");
|
|
my @file = <FILE>;
|
|
close(FILE);
|
|
|
|
my $line;
|
|
my (@templine, @deps, @tempdeps);
|
|
foreach $line (@file) {
|
|
@templine = split(/\: /,$line);
|
|
if ("$templine[0]" eq "Dependencies") {
|
|
@deps = split(/ /, $templine[1]);
|
|
}
|
|
}
|
|
chomp (@deps);
|
|
foreach (@deps) {
|
|
if ($_) {
|
|
message("### Found dependency: $_");
|
|
push(@tempdeps,$_);
|
|
}
|
|
}
|
|
|
|
#my @tempdeps = @deps;
|
|
foreach (@tempdeps) {
|
|
if ($_) {
|
|
my @newdeps = resolvedeps("$_");
|
|
foreach(@newdeps) {
|
|
unless (($_ eq " ") || ($_ eq "")) {
|
|
message("### Found dependency: $_");
|
|
push(@deps,$_);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
chomp (@deps);
|
|
return @deps;
|
|
}
|
|
|
|
sub cleanup {
|
|
my $dir = shift;
|
|
my $path;
|
|
|
|
if ( "$dir" eq "meta" ) {
|
|
$path = "$Conf::dbdir/meta";
|
|
} elsif ( "$dir" eq "tmp" ) {
|
|
$path = "$Conf::tmpdir";
|
|
}
|
|
chdir("$path");
|
|
opendir(DIR,".");
|
|
my @files = readdir(DIR);
|
|
closedir(DIR);
|
|
foreach (@files) {
|
|
unless (($_ eq ".") || ($_ eq "..")) {
|
|
system("rm -rf $_");
|
|
}
|
|
}
|
|
}
|
|
|
|
sub getmetafile {
|
|
my $pak = shift;
|
|
|
|
logger("Going to download meta-$pak.");
|
|
|
|
unless ( -e "$Conf::dbdir/meta/meta-$pak") {
|
|
fetchfile("meta/meta-$pak", "");
|
|
move("$Conf::cachedir/meta-$pak", "$Conf::dbdir/meta/meta-$pak");
|
|
}
|
|
|
|
open(FILE, "<$Conf::dbdir/meta/meta-$pak");
|
|
my @line = <FILE>;
|
|
close(FILE);
|
|
|
|
open(FILE, ">$Conf::dbdir/meta/meta-$pak");
|
|
foreach (@line) {
|
|
my $string = $_;
|
|
$string =~ s/\r\n/\n/g;
|
|
print FILE $string;
|
|
}
|
|
close(FILE);
|
|
return 1;
|
|
}
|
|
|
|
sub getsize {
|
|
my $pak = shift;
|
|
|
|
getmetafile("$pak");
|
|
|
|
open(FILE, "<$Conf::dbdir/meta/meta-$pak");
|
|
my @file = <FILE>;
|
|
close(FILE);
|
|
|
|
my $line;
|
|
my @templine;
|
|
foreach $line (@file) {
|
|
@templine = split(/\: /,$line);
|
|
if ("$templine[0]" eq "Size") {
|
|
chomp($templine[1]);
|
|
return $templine[1];
|
|
}
|
|
}
|
|
}
|
|
|
|
sub addsizes { ## Still not working
|
|
my @paks = shift;
|
|
|
|
my $paksize;
|
|
my $totalsize = 0;
|
|
foreach (@paks) {
|
|
$paksize = getsize("$_");
|
|
$totalsize = ($totalsize + $paksize) ;
|
|
}
|
|
return $totalsize;
|
|
}
|
|
|
|
sub decryptpak {
|
|
my $pak = shift;
|
|
|
|
cleanup("tmp");
|
|
|
|
my $file = getpak("$pak", "noforce");
|
|
|
|
my $return = system("gpg -d < $Conf::cachedir/$file | tar xj -C $Conf::tmpdir/");
|
|
|
|
logger("Decryption process returned the following: $return");
|
|
if ($return == 1) { exit 1; }
|
|
}
|
|
|
|
sub getpak {
|
|
my $pak = shift;
|
|
my $force = shift;
|
|
|
|
getmetafile("$pak");
|
|
|
|
open(FILE, "<$Conf::dbdir/meta/meta-$pak");
|
|
my @file = <FILE>;
|
|
close(FILE);
|
|
|
|
my $line;
|
|
my $file;
|
|
my @templine;
|
|
foreach $line (@file) {
|
|
@templine = split(/\: /,$line);
|
|
if ("$templine[0]" eq "File") {
|
|
chomp($templine[1]);
|
|
$file = $templine[1];
|
|
}
|
|
}
|
|
|
|
unless ($file) {
|
|
message("No filename given in meta-file. Please phone the developers.");
|
|
exit 1;
|
|
}
|
|
|
|
#message("\n## Downloading $file...");
|
|
|
|
unless ( "$force" eq "force" ) {
|
|
if ( -e "$Conf::cachedir/$file" ) {
|
|
return $file;
|
|
}
|
|
}
|
|
|
|
fetchfile("paks/$file", "");
|
|
return $file;
|
|
}
|
|
|
|
sub setuppak {
|
|
my $pak = shift;
|
|
|
|
message("We are going to install: $pak");
|
|
|
|
decryptpak("$pak");
|
|
|
|
my $return = system("cd $Conf::tmpdir && ./install.sh >> $Conf::logdir/install-$pak.log 2>&1");
|
|
if ($return == 0) {
|
|
move("$Conf::tmpdir/ROOTFILES", "$Conf::dbdir/rootfiles/$pak");
|
|
cleanup("tmp");
|
|
message("Setup completed. Congratulations!");
|
|
} else {
|
|
message("Setup returned: $return. Sorry. Please search our forum to find a solution for this problem.");
|
|
exit $return;
|
|
}
|
|
return $return;
|
|
}
|
|
|
|
sub updatepak {
|
|
my $pak = shift;
|
|
|
|
message("We are going to update: $pak");
|
|
|
|
decryptpak("$pak");
|
|
|
|
my $return = system("cd $Conf::tmpdir && ./update.sh >> $Conf::logdir/update-$pak.log 2>&1");
|
|
if ($return == 0) {
|
|
move("$Conf::tmpdir/ROOTFILES", "$Conf::dbdir/rootfiles/$pak");
|
|
cleanup("tmp");
|
|
message("Update completed. Congratulations!");
|
|
} else {
|
|
message("Setup returned: $return. Sorry. Please search our forum to find a solution for this problem.");
|
|
exit $return;
|
|
}
|
|
return $return;
|
|
}
|
|
|
|
sub removepak {
|
|
my $pak = shift;
|
|
|
|
message("We are going to uninstall: $pak");
|
|
|
|
decryptpak("$pak");
|
|
|
|
my $return = system("cd $Conf::tmpdir && ./uninstall.sh >> $Conf::logdir/uninstall-$pak.log 2>&1");
|
|
if ($return == 0) {
|
|
open(FILE, "<$Conf::dbdir/rootfiles/$pak");
|
|
my @file = <FILE>;
|
|
close(FILE);
|
|
foreach (@file) {
|
|
my $line = $_;
|
|
chomp($line);
|
|
system("echo \"Removing: $line\" >> $Conf::logdir/uninstall-$pak.log 2>&1");
|
|
system("cd / && rm -rf $line >> $Conf::logdir/uninstall-$pak.log 2>&1");
|
|
}
|
|
unlink("$Conf::dbdir/rootfiles/$pak");
|
|
cleanup("tmp");
|
|
message("Uninstall completed. Congratulations!");
|
|
} else {
|
|
message("Setup returned: $return. Sorry. Please search our forum to find a solution for this problem.");
|
|
exit $return;
|
|
}
|
|
return $return;
|
|
}
|
|
|
|
sub beautifysize {
|
|
my $size = shift;
|
|
$size = $size / 1024;
|
|
my $unit;
|
|
|
|
if ($size > 1023) {
|
|
$size = ($size / 1024);
|
|
$unit = "MB";
|
|
} else {
|
|
$unit = "KB";
|
|
}
|
|
$size = sprintf("%.2f" , $size);
|
|
my $string = "$size $unit";
|
|
return $string;
|
|
}
|
|
|
|
sub makeuuid {
|
|
unless ( -e "$Conf::dbdir/uuid" ) {
|
|
message("Creating a random key...");
|
|
open(FILE, "</proc/sys/kernel/random/uuid");
|
|
my @line = <FILE>;
|
|
close(FILE);
|
|
|
|
open(FILE, ">$Conf::dbdir/uuid");
|
|
foreach (@line) {
|
|
print FILE $_;
|
|
}
|
|
close(FILE);
|
|
}
|
|
}
|
|
|
|
sub senduuid {
|
|
unless("$Conf::uuid") {
|
|
$Conf::uuid = `cat $Conf::dbdir/uuid`;
|
|
}
|
|
logger("Sending my uuid: $Conf::uuid");
|
|
fetchfile("cgi-bin/counter?ver=$Conf::version&uuid=$Conf::uuid", "$Conf::mainserver");
|
|
system("rm -f $Conf::cachedir/counter.cgi* 2>/dev/null");
|
|
}
|
|
|
|
1;
|