headline: RBN set/seeme

[spider.git] / perl / QSL.pm

diff --git a/perl/QSL.pm b/perl/QSL.pm
index c1beca63dd2f2dfbaa3bd24661304d4e68cba1cf..ec5512216f563ffe9929bad57253d9d87851799f 100644 (file)
--- a/perl/QSL.pm
+++ b/perl/QSL.pm
@@ -8,38 +8,35 @@
 package QSL;
 
 use strict;
-use DXVars;
+use SysVar;
 use DXUtil;
 use DB_File;
 use DXDebug;
+use Prefix;
+use DXJSON;
+use Data::Structure::Util qw(unbless);
 
-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);
-$qslfn = 'qsl';
+use vars qw($qslfn $dbm $maxentries);
+$qslfn = 'dxqsl';
 $dbm = undef;
+$maxentries = 50;
+
+my %u;
+my $json;
+
+localdata_mv("$qslfn.v1j");
 
 sub init
 {
        my $mode = shift;
-       my $ufn = "$main::root/data/$qslfn.v1";
+       my $ufn = localdata("$qslfn.v1j");
 
-       eval {
-               require Storable;
-       };
+       $json = DXJSON->new;
+       
+       Prefix::load() unless Prefix::loaded();
+
+       finish() if $dbm;
        
-       if ($@) {
-               dbg("Storable appears to be missing");
-               dbg("In order to use the QSL feature you must");
-               dbg("load Storable from CPAN");
-               return undef;
-       }
-       import Storable qw(nfreeze thaw);
-       my %u;
        if ($mode) {
                $dbm = tie (%u, 'DB_File', $ufn, O_CREAT|O_RDWR, 0666, $DB_BTREE) or confess "can't open qsl file: $qslfn ($!)";
        } else {
@@ -50,7 +47,10 @@ sub init
 
 sub finish
 {
+       dbg("DXQSL finished");
+       $dbm->sync;
        undef $dbm;
+       untie %u;
 }
 
 sub new
@@ -59,7 +59,9 @@ sub new
        return bless [uc $call, []], $pkg;
 }
 
-# the format of each entry is [manager, times found, last time]
+# called $self->update(comment, time, spotter)
+# $self has the callsign as the first argument in an array of array references
+# the format of each entry is [manager, times found, last time, last reporter]
 sub update
 {
        return unless $dbm;
@@ -67,23 +69,45 @@ sub update
        my $line = shift;
        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;
                
-       my @tok = map {/^BUR/ || is_callsign($_) ? $_ : ()} split(/\b/, uc $line);
-       foreach my $man (@tok) {
-               $man = 'BUREAU' if $man =~ /^BUR/;
-               my ($r) = grep {$_->[0] eq $man} @{$self->[1]};
-               if ($r) {
-                       $r->[1]++;
-                       if ($t > $r->[2]) {
-                               $r->[2] = $t;
-                               $r->[3] = $by;
-                       }
+               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 {
-                       $r = [$man, 1, $t, $by];
-                       push @{$self->[1]}, $r;
+                       next;
+               }
+               if ($tok) {
+                       my ($r) = grep {$_->[0] eq $tok} @{$self->[1]};
+                       if ($r) {
+                               $r->[1]++;
+                               if ($t > $r->[2]) {
+                                       $r->[2] = $t;
+                                       $r->[3] = $by;
+                               }
+                               $changed++;
+                       } else {
+                               $r = [$tok, 1, $t, $by];
+                               unshift @{$self->[1]}, $r;
+                               $changed++;
+                       }
+                       # prune the number of entries
+                       pop @{$self->[1]} while (@{$self->[1]} > $maxentries);
                }
        }
-       $self->put;
+       $self->put if $changed;
 }
 
 sub get
@@ -94,16 +118,43 @@ sub get
        
        my $r = $dbm->get($key, $value);
        return undef if $r;
-       return thaw($value);
+       return decode($value);
 }
 
+
 sub put
 {
        return unless $dbm;
        my $self = shift;
        my $key = $self->[0];
-       my $value = nfreeze($self);
+       my $value = encode($self);
        $dbm->put($key, $value);
 }
 
+sub remove_files
+{
+       unlink "$main::data/$qslfn.v1j";
+       unlink "$main::local_data/$qslfn.v1j";
+}
+
+# thaw the user
+sub decode
+{
+       return $json->decode($_[0], __PACKAGE__);
+}
+
+# freeze the user
+sub encode
+{
+       return $json->encode($_[0]);
+}
+
+sub END
+{
+       if ($dbm) {
+               dbg "DXQSL ENDing";
+               finish();
+       }
+}
+
 1;