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 {
sub finish
{
+ dbg("DXQSL finished");
+ $dbm->sync if $dbm;
undef $dbm;
+ untie %u;
}
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;
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];
- unshift @{$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
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;