fixed duplicate spot, always make clean ending
[spider.git] / perl / QSL.pm
index d7dc8b2c0fced88746f56db95bd98de9c994160c..3d228d39685992166ec292c8b42a3c221b362ec4 100644 (file)
@@ -14,15 +14,10 @@ use DB_File;
 use DXDebug;
 use Prefix;
 
-use vars qw($VERSION $BRANCH);
-$VERSION = sprintf( "%d.%03d", q$Revision$ =~ /(\d+)\.(\d+)/ );
-$BRANCH = sprintf( "%d.%03d", q$Revision$ =~ /\d+\.\d+\.(\d+)\.(\d+)/  || (0,0));
-$main::build += $VERSION;
-$main::branch += $BRANCH;
-
-use vars qw($qslfn $dbm);
+use vars qw($qslfn $dbm $maxentries);
 $qslfn = 'qsl';
 $dbm = undef;
+$maxentries = 50;
 
 sub init
 {
@@ -43,6 +38,7 @@ sub init
        }
        import Storable qw(nfreeze freeze thaw);
        my %u;
+       undef $dbm;
        if ($mode) {
                $dbm = tie (%u, 'DB_File', $ufn, O_CREAT|O_RDWR, 0666, $DB_BTREE) or confess "can't open qsl file: $qslfn ($!)";
        } else {
@@ -62,7 +58,7 @@ sub new
        return bless [uc $call, []], $pkg;
 }
 
-# the format of each entry is [manager, times found, last time]
+# the format of each entry is [manager, times found, last time, last reporter]
 sub update
 {
        return unless $dbm;
@@ -71,19 +67,24 @@ sub update
        my $t = shift;
        my $by = shift;
        my $changed;
-                       
+
+       return unless length $line && $line =~ /\b(?:QSL|VIA)\b/i;
        foreach my $man (split /\b/, uc $line) {
                my $tok;
                
-               if (is_callsign($man)) {
+               if (is_callsign($man) && !is_qra($man)) {
                        my @pre = Prefix::extract($man);
                        $tok = $man if @pre && $pre[0] ne 'Q';
                } elsif ($man =~ /^BUR/) {
                        $tok = 'BUREAU';
+               } elsif ($man =~ /^LOTW/) {
+                       $tok = 'LOTW';
                } elsif ($man eq 'HC' || $man =~ /^HOM/ || $man =~ /^DIR/) {
                        $tok = 'HOME CALL';
                } elsif ($man =~ /^QRZ/) {
                        $tok = 'QRZ.com';
+               } else {
+                       next;
                }
                if ($tok) {
                        my ($r) = grep {$_->[0] eq $tok} @{$self->[1]};
@@ -99,6 +100,8 @@ sub update
                                unshift @{$self->[1]}, $r;
                                $changed++;
                        }
+                       # prune the number of entries
+                       pop @{$self->[1]} while (@{$self->[1]} > $maxentries);
                }
        }
        $self->put if $changed;
@@ -112,9 +115,17 @@ sub get
        
        my $r = $dbm->get($key, $value);
        return undef if $r;
-       return thaw($value);
+       my $v;
+       eval { $v = thaw($value) };
+       if ($@) {
+               LogDbg("Error thawing DXQSL key '$key' (now deleted): $@");
+               eval {$dbm->del($key)};
+               return undef;
+       }
+       return $v;
 }
 
+
 sub put
 {
        return unless $dbm;
@@ -124,4 +135,9 @@ sub put
        $dbm->put($key, $value);
 }
 
+sub active
+{
+       return $dbm;
+}
+
 1;