version 1.15, 2005/05/04 01:48:35 |
version 1.26, 2009/10/20 20:04:28 |
|
|
#!/usr/bin/perl -T |
#!/usr/bin/perl -T |
#$Id$ |
#$RedRiver: CurrentTorrents.pl,v 1.25 2008/11/14 18:18:31 andrew Exp $ |
use strict; |
use strict; |
use warnings; |
use warnings; |
use diagnostics; |
use diagnostics; |
|
|
use Time::Local; |
use Time::Local; |
|
use Fcntl ':flock'; |
|
use File::Basename; |
|
#use YAML; |
|
|
use lib 'lib'; |
use lib 'lib'; |
use OpenBSDTorrents; |
use OpenBSDTorrents; |
use BT::OBTMetaInfo; |
use BT::MetaInfo::Cached; |
|
|
%ENV = (); |
%ENV = (); |
|
|
use YAML; |
|
|
|
#justme(); |
#justme(); |
|
|
my $Name_Filter = shift || ''; |
my $Name_Filter = shift || ''; |
|
|
} else { |
} else { |
die "Invalid character in $_: $!"; |
die "Invalid character in $_: $!"; |
} |
} |
my ($name, $year, $mon, $mday, $hour, $min) = |
my $epoch = 0; |
/^(.*)-(\d{4})-(\d{2})-(\d{2})-(\d{2})(\d{2})/; |
my $name = basename($_, '.torrent'); |
|
|
$mon--; |
if (my ($base, $year, $mon, $mday, $hour, $min) = |
my $epoch = timegm(0,$min,$hour,$mday,$mon,$year); |
/^(.*)-(\d{4})-(\d{2})-(\d{2})-(\d{2})(\d{2})/) { |
|
|
|
$mon--; |
|
$epoch = timegm(0,$min,$hour,$mday,$mon,$year); |
|
$name = $base; |
|
} |
|
|
#print "Adding $_\n"; |
#print "Adding $_\n"; |
|
|
$files{$ext}{$name}{$epoch} = { |
$files{$ext}{$name}{$epoch} = { |
|
|
dir => $DIR, |
dir => $DIR, |
path => "$DIR/$_", |
path => "$DIR/$_", |
ext => $ext, |
ext => $ext, |
year => $year, |
#year => $year, |
mon => $mon, |
#mon => $mon, |
mday => $mday, |
#mday => $mday, |
hour => $hour, |
#hour => $hour, |
min => $min, |
#min => $min, |
name => $name, |
name => $name, |
epoch => $epoch, |
epoch => $epoch, |
}; |
}; |
|
|
unless (exists $Possible_Torrents{$name}) { |
if ( |
|
$name =~ m/\A $OBT->{BASENAME} /xms && |
|
! exists $Possible_Torrents{$name} |
|
) { |
print "Would remove $_\n"; |
print "Would remove $_\n"; |
push @delete, $files{$ext}{$name}{$epoch}; |
push @delete, $files{$ext}{$name}{$epoch}; |
} |
} |
|
|
closedir DIR; |
closedir DIR; |
} |
} |
|
|
foreach my $name (keys %{ $files{torrent} }) { |
#print Dump \%files; |
|
foreach my $name (sort keys %{ $files{torrent} }) { |
next unless $name =~ /^$Name_Filter/; |
next unless $name =~ /^$Name_Filter/; |
print "Checking $name\n"; |
#print "Checking $name\n"; |
|
|
foreach my $epoch ( sort { $b <=> $a } keys %{ $files{torrent}{$name} } ) { |
foreach my $epoch ( sort { $b <=> $a } keys %{ $files{torrent}{$name} } ) { |
#print "\t$epoch\n"; |
#print "\t$epoch\n"; |
|
|
next; |
next; |
} |
} |
|
|
|
|
my $t; |
my $t; |
eval { $t = BT::OBTMetaInfo->new( $torrent ); }; |
eval { |
|
$t = BT::MetaInfo::Cached->new( |
|
$torrent, |
|
{ |
|
cache_root => '/tmp/OBTFileCache' |
|
#$OBT->{DIR_HOME} . '/FileCache' |
|
} |
|
); |
|
}; |
|
|
if ($@) { |
if ($@) { |
warn "Error reading torrent $torrent\n"; |
warn "Error reading torrent $torrent\n"; |
|
push @delete, $files{torrent}{$name}{$epoch}; |
|
delete $files{torrent}{$name}{$epoch}; |
next; |
next; |
} |
} |
|
|
$files{torrent}{$name}{$epoch}{comment} = $t->{comment}; |
$files{torrent}{$name}{$epoch}{comment} = $t->{comment}; |
my ($path) = $t->{comment} =~ /Files from ([^\n]+)\n/s; |
my ($path) = $t->{comment} =~ /($OBT->{BASENAME}\/[^\n]+)\n/s; |
|
|
unless (-d $OBT->{DIR_FTP} . "/$path") { |
unless (-e $OBT->{DIR_FTP} . "/$path") { |
#print "Deleting $files{torrent}{$name}{$epoch}{file} the path doesn't exist.\n"; |
print "Deleting $files{torrent}{$name}{$epoch}{file} the path ($path) doesn't exist.\n"; |
push @delete, $files{torrent}{$name}{$epoch}; |
push @delete, $files{torrent}{$name}{$epoch}; |
delete $files{torrent}{$name}{$epoch}; |
delete $files{torrent}{$name}{$epoch}; |
next; |
next; |
} |
} |
|
|
my $hash = $t->info_hash_cached($torrent); |
my $hash = $t->info_hash; |
$hash = unpack("H*", $hash); |
$hash = unpack("H*", $hash); |
|
|
|
undef $t; |
|
|
$files{torrent}{$name}{$epoch}{info_hash} = $hash; |
$files{torrent}{$name}{$epoch}{info_hash} = $hash; |
|
|
undef $t; |
|
|
|
if (exists $keep{$name}) { |
if (exists $keep{$name}) { |
if (exists $keep{$name}{$hash}) { |
if (exists $keep{$name}{$hash}) { |
|
if ( $keep{$name}{$hash}{epoch} == $epoch ) { |
|
next; |
|
} |
|
print "Removing [$name] [$hash]\n\t", |
|
$keep{$name}{$hash}{path}, |
|
"\n"; |
push @delete, $keep{$name}{$hash}; |
push @delete, $keep{$name}{$hash}; |
delete $files{torrent}{ |
delete $files{torrent}{ |
$keep{$name}{$hash}{name} |
$keep{$name}{$hash}{name} |
|
|
}; |
}; |
$keep{$name}{$hash} = |
$keep{$name}{$hash} = |
$files{torrent}{$name}{$epoch}; |
$files{torrent}{$name}{$epoch}; |
|
print "Keeping additional instance of [$name] [$hash]\n\t", |
|
$keep{$name}{$hash}{path}, |
|
"\n"; |
} else { |
} else { |
|
print "Removing old [$name] [$hash]\n"; |
|
if ( $keep{$name}{$hash}{path} ) { |
|
print "\t", $keep{$name}{$hash}{path}, |
|
"\n"; |
|
} |
push @delete, $files{torrent}{$name}{$epoch}; |
push @delete, $files{torrent}{$name}{$epoch}; |
delete $files{torrent}{$name}{$epoch}; |
delete $files{torrent}{$name}{$epoch}; |
} |
} |
} else { |
} else { |
|
print "Keeping first instance of $name [$hash]\n\t", |
|
$files{torrent}{$name}{$epoch}{path}, |
|
"\n"; |
$keep{$name}{$hash} = |
$keep{$name}{$hash} = |
$files{torrent}{$name}{$epoch}; |
$files{torrent}{$name}{$epoch}; |
|
|
|
|
} |
} |
|
|
#print Dump \%files, \%keep, \@delete; |
#print Dump \%files, \%keep, \@delete; |
|
#exit; |
|
|
foreach (@delete) { |
foreach (@delete) { |
print "Deleting '$_->{path}'\n"; |
print "Deleting '$_->{path}'\n"; |
|
|
#print Dump \%keep; |
#print Dump \%keep; |
foreach my $name (keys %keep) { |
foreach my $name (keys %keep) { |
foreach my $hash (keys %{ $keep{$name} }) { |
foreach my $hash (keys %{ $keep{$name} }) { |
my $file = $keep{$name}{$hash}{file}; |
my $file = $keep{$name}{$hash}{file} || q{}; |
my $dir = $keep{$name}{$hash}{dir }; |
my $dir = $keep{$name}{$hash}{dir } || q{}; |
if ($dir eq $OBT->{DIR_NEW_TORRENT}) { |
if ($dir eq $OBT->{DIR_NEW_TORRENT}) { |
print "Moving $file to current torrents\n"; |
print "Moving $file to current torrents\n"; |
rename("$dir/$file", $OBT->{DIR_TORRENT} . "/" . $file) |
rename("$dir/$file", $OBT->{DIR_TORRENT} . "/" . $file) |
|
|
my $torrent = Name_Torrent($dir); |
my $torrent = Name_Torrent($dir); |
$torrent =~ s/-.*$//; |
$torrent =~ s/-.*$//; |
$Possible_Torrents{$torrent} = 1; |
$Possible_Torrents{$torrent} = 1; |
|
foreach my $file (@$files) { |
|
if ($file =~ /$INSTALL_ISO_REGEX/) { |
|
$torrent = Name_Torrent("$dir/$file"); |
|
$torrent =~ s/-.*$//; |
|
$Possible_Torrents{$torrent} = 1; |
|
} |
|
} |
} |
} |
|
|
foreach my $subdir (@$dirs) { |
foreach my $subdir (@$dirs) { |