| version 1.14, 2005/05/04 01:11:59 |
version 1.19, 2005/06/01 18:52:14 |
|
|
| use diagnostics; |
use diagnostics; |
| |
|
| use Time::Local; |
use Time::Local; |
| |
use Fcntl ':flock'; |
| |
|
| use lib 'lib'; |
use lib 'lib'; |
| use OpenBSDTorrents; |
use OpenBSDTorrents; |
| use BT::OBTMetaInfo; |
use BT::MetaInfo::Cached; |
| |
|
| %ENV = (); |
%ENV = (); |
| |
|
| 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 $t; |
my $t; |
| eval { $t = BT::OBTMetaInfo->new( $torrent ); }; |
eval { |
| |
$t = BT::MetaInfo::Cached->new( |
| |
$torrent, |
| |
{ |
| |
cache_root => |
| |
$OBT->{DIR_HOME} . '/FileCache' |
| |
} |
| |
); |
| |
}; |
| |
|
| if ($@) { |
if ($@) { |
| warn "Error reading torrent $torrent\n"; |
warn "Error reading torrent $torrent\n"; |
|
|
| 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}) { |
|
|
| } |
} |
| |
|
| |
|
| #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}; |
| my $dir = $keep{$name}{$hash}{dir }; |
# my $dir = $keep{$name}{$hash}{dir }; |
| 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) |
| or die "Couldn't rename '$file': $!"; |
# or die "Couldn't rename '$file': $!"; |
| |
# |
| |
# my $name = $keep{$name}{$hash}{name}; |
| |
# my $epoch = $keep{$name}{$hash}{epoch}; |
| |
# |
| |
# if (exists $files{txt}{$name}{$epoch}) { |
| |
# my $m_file = $files{txt}{$name}{$epoch}{file}; |
| |
# my $m_dir = $files{txt}{$name}{$epoch}{dir }; |
| |
# rename( |
| |
# "$m_dir/$m_file", |
| |
# $OBT->{DIR_TORRENT} . "/" . $m_file |
| |
# ) or die "Couldn't rename '$m_file': $!"; |
| |
# } |
| |
# } |
| |
# } |
| |
#} |
| |
|
| my $name = $keep{$name}{$hash}{name}; |
sub Process_Dir |
| my $epoch = $keep{$name}{$hash}{epoch}; |
{ |
| |
my $basedir = shift; |
| |
|
| if (exists $files{txt}{$name}{$epoch}) { |
my ($dirs, $files) = Get_Files_and_Dirs($basedir); |
| my $m_file = $files{txt}{$name}{$epoch}{file}; |
if (@$files) { |
| my $m_dir = $files{txt}{$name}{$epoch}{dir }; |
my $dir = $basedir; |
| rename( |
$dir =~ s/^$OBT->{DIR_FTP}\///; |
| "$m_dir/$m_file", |
my $torrent = Name_Torrent($dir); |
| $OBT->{DIR_TORRENT} . "/" . $m_file |
$torrent =~ s/-.*$//; |
| ) or die "Couldn't rename '$m_file': $!"; |
$Possible_Torrents{$torrent} = 1; |
| } |
} |
| } |
|
| } |
foreach my $subdir (@$dirs) { |
| |
next if $subdir eq '.'; |
| |
next if $subdir eq '..'; |
| |
Process_Dir("$basedir/$subdir") |
| |
} |
| } |
} |
| |
|