=================================================================== RCS file: /cvs/openbsd/OpenBSDTorrents/ServerTorrents.pl,v retrieving revision 1.11 retrieving revision 1.19 diff -u -r1.11 -r1.19 --- openbsd/OpenBSDTorrents/ServerTorrents.pl 2005/05/02 21:26:04 1.11 +++ openbsd/OpenBSDTorrents/ServerTorrents.pl 2005/05/21 01:48:03 1.19 @@ -1,15 +1,15 @@ #!/usr/bin/perl -T -#$Id: ServerTorrents.pl,v 1.11 2005/05/02 20:26:04 andrew Exp $ +#$Id: ServerTorrents.pl,v 1.19 2005/05/21 00:48:03 andrew Exp $ use strict; use warnings; use diagnostics; -use BT::OBTMetaInfo; use LWP::UserAgent; use Time::Local; use lib 'lib'; use OpenBSDTorrents; +use BT::MetaInfo::Cached; %ENV = (); @@ -57,20 +57,28 @@ my ($name, $year, $mon, $mday, $hour, $min) = /^(.*)-(\d{4})-(\d{2})-(\d{2})-(\d{2})(\d{2})/; - my $time = "$year.$mon.$mday $hour:$min"; + my $t; + eval { + $t = BT::MetaInfo::Cached->new( + $OBT->{DIR_TORRENT} . '/' . $_, + { + cache_root => + $OBT->{DIR_HOME} . '/FileCache' + } + ); + }; - $mon--; + if ($@) { + warn "Error reading torrent $_\n"; + next; + } - my $epoch = timegm(0,$min,$hour,$mday,$mon,$year); + my $epoch = $t->creation_date; $files{$name}{$epoch} = { file => $_, - year => $year, - mon => $mon, - mday => $mday, - hour => $hour, - min => $min, - time => $time, + details => $t, + name => $name, epoch => $epoch, }; @@ -84,17 +92,16 @@ foreach my $epoch ( sort { $b <=> $a } keys %{ $files{$name} } ) { #print "\t$epoch\n"; my $torrent = $files{$name}{$epoch}{file}; - unless (exists $server_torrents{$torrent} ) { - #my $time = - # $files{$name}{$epoch}{year} . '-' . - # $files{$name}{$epoch}{mon} . '-' . - # $files{$name}{$epoch}{mday} . ' ' . - # $files{$name}{$epoch}{hour} . ':' . - # $files{$name}{$epoch}{min} . ':00'; - - Upload_Torrent($torrent, $files{$name}{$epoch}{time}); - } - next; + + my $hash = $files{$name}{$epoch}{'details'}->info_hash; + $hash = unpack("H*", $hash); + + next if ( + exists $server_torrents{$torrent} && + $server_torrents{$torrent} eq $hash + ); + + Upload_Torrent($files{$name}{$epoch}); } } @@ -111,21 +118,28 @@ sub Upload_Torrent { - my $file = shift; - my $time = shift; + my $torrent = shift; + my $t = $torrent->{'details'}; + my $file = $torrent->{'file'}; print "Uploading $file\n"; - my $t; - eval { $t = BT::OBTMetaInfo->new("$OBT->{DIR_TORRENT}/$file"); }; - if ($@) { - warn "Error reading torrent $file\n"; - return undef; - } - my $size = $t->total_size; + my ($sec, $min, $hour, $mday, $mon, $year, $wday, $yday) = + gmtime($t->creation_date); + $year += 1900; + $mon++; + my $time = sprintf "%04d.%02d.%02d %02d:%02d", + $year, $mon, $mday, $hour, $min; - my $i; + ($sec, $min, $hour, $mday, $mon, $year, $wday, $yday) = + localtime($t->creation_date); + $year += 1900; + $mon++; + my $sql_time = sprintf "%04d-%02d-%02d %02d:%02d", + $year, $mon, $mday, $hour, $min; + + my $i = 0; while ($size > 1024) { $size /= 1024; $i++; @@ -148,7 +162,7 @@ torrent => [ $OBT->{DIR_TORRENT} . "/$file" ], url => "/torrents/$file", filename => $filename, - filedate => $time, + filedate => $sql_time, info => $comment, hash => '', autoset => 'enabled', # -> checked="checked"