version 1.14, 2005/05/04 01:11:59 |
version 1.16, 2005/05/05 02:09:43 |
|
|
use diagnostics; |
use diagnostics; |
|
|
use Time::Local; |
use Time::Local; |
|
use Fcntl ':flock'; |
|
|
use lib 'lib'; |
use lib 'lib'; |
use OpenBSDTorrents; |
use OpenBSDTorrents; |
|
|
|
|
use YAML; |
use YAML; |
|
|
justme(); |
#justme(); |
|
|
my $Name_Filter = shift || ''; |
my $Name_Filter = shift || ''; |
if ($Name_Filter =~ /^(\w*)$/) { |
if ($Name_Filter =~ /^(\w*)$/) { |
|
|
die "Invalid filter: $Name_Filter"; |
die "Invalid filter: $Name_Filter"; |
} |
} |
|
|
|
my %Possible_Torrents; |
|
Process_Dir($OBT->{DIR_FTP}); |
|
|
my %files; |
my %files; |
|
my %keep; |
|
my @delete; |
foreach my $DIR ($OBT->{DIR_NEW_TORRENT}, $OBT->{DIR_TORRENT}) { |
foreach my $DIR ($OBT->{DIR_NEW_TORRENT}, $OBT->{DIR_TORRENT}) { |
opendir DIR, $DIR |
opendir DIR, $DIR |
or die "Couldn't opendir $DIR: $!"; |
or die "Couldn't opendir $DIR: $!"; |
|
|
epoch => $epoch, |
epoch => $epoch, |
}; |
}; |
|
|
|
unless (exists $Possible_Torrents{$name}) { |
|
print "Would remove $_\n"; |
|
push @delete, $files{$ext}{$name}{$epoch}; |
|
} |
} |
} |
closedir DIR; |
closedir DIR; |
} |
} |
|
|
my %keep; |
|
my @delete; |
|
foreach my $name (keys %{ $files{torrent} }) { |
foreach my $name (keys %{ $files{torrent} }) { |
next unless $name =~ /^$Name_Filter/; |
next unless $name =~ /^$Name_Filter/; |
print "Checking $name\n"; |
print "Checking $name\n"; |
|
|
next; |
next; |
} |
} |
|
|
|
my $meta_file = $torrent; |
|
$meta_file =~ s/\.torrent$/.$OBT->{META_EXT}/; |
|
|
|
my $hash = undef; |
|
if (-e $meta_file) { |
|
#print "Reading meta file: $meta_file\n"; |
|
open my $meta, $meta_file |
|
or die "Couldn't open $meta_file: $!"; |
|
flock($meta, LOCK_SH); |
|
binmode $meta; |
|
|
|
$hash = do { local $/; <$meta> }; |
|
|
|
flock($meta, LOCK_UN); |
|
close $meta; |
|
} else { |
|
|
my $t; |
my $t; |
eval { $t = BT::OBTMetaInfo->new( $torrent ); }; |
eval { $t = BT::OBTMetaInfo->new( $torrent ); }; |
|
|
|
|
next; |
next; |
} |
} |
|
|
my $hash = $t->info_hash_cached($torrent); |
$hash = $t->info_hash_cached($torrent); |
$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}) { |
|
|
} |
} |
} |
} |
} |
} |
|
|
|
sub Process_Dir |
|
{ |
|
my $basedir = shift; |
|
|
|
my ($dirs, $files) = Get_Files_and_Dirs($basedir); |
|
if (@$files) { |
|
my $dir = $basedir; |
|
$dir =~ s/^$OBT->{DIR_FTP}\///; |
|
my $torrent = Name_Torrent($dir); |
|
$torrent =~ s/-.*$//; |
|
$Possible_Torrents{$torrent} = 1; |
|
} |
|
|
|
foreach my $subdir (@$dirs) { |
|
next if $subdir eq '.'; |
|
next if $subdir eq '..'; |
|
Process_Dir("$basedir/$subdir") |
|
} |
|
} |
|
|