use Carp;
use strict;
-use vars qw($me $pc11_max_age $pc11_dup_age $pc23_dup_age
- %spotdup %wwvdup $last_hour %pings %rcmds
+use vars qw($me $pc11_max_age $pc23_max_age $pc11_dup_age $pc23_dup_age
+ %spotdup %wwvdup $last_hour %pings %rcmds
%nodehops @baddx $baddxfn $pc12_dup_age
- %anndup $allowzero);
+ %anndup $allowzero $pc12_dup_lth $decode_dk0wcy);
$me = undef; # the channel id for this cluster
+$decode_dk0wcy = undef; # if set use this callsign to decode announces from the EU WWV data beacon
$pc11_max_age = 1*3600; # the maximum age for an incoming 'real-time' pc11
+$pc23_max_age = 1*3600; # the maximum age for an incoming 'real-time' pc23
$pc11_dup_age = 24*3600; # the maximum time to keep the spot dup list for
$pc23_dup_age = 24*3600; # the maximum time to keep the wwv dup list for
-$pc12_dup_age = 24*3600; # the maximum time to keep the ann dup list for
+$pc12_dup_age = 12*3600; # the maximum time to keep the ann dup list for
+$pc12_dup_lth = 72; # the length of ANN text to save for deduping
%spotdup = (); # the pc11 and 26 dup hash
%wwvdup = (); # the pc23 and 27 dup hash
%anndup = (); # the PC12 dup hash
$self->{consort} = $line; # save the connection type
$self->{here} = 1;
- # get the filters
- $self->{spotfilter} = Filter::read_in('spots', $call);
- $self->{wwvfilter} = Filter::read_in('wwv', $call);
- $self->{annfilter} = Filter::read_in('ann', $call);
+ # get the INPUT filters (these only pertain to Clusters)
+ $self->{inspotfilter} = Filter::read_in('spots', $call, 1);
+ $self->{inwwvfilter} = Filter::read_in('wwv', $call, 1);
+ $self->{inannfilter} = Filter::read_in('ann', $call, 1);
# set unbuffered and no echo
$self->send_now('B',"0");
my ($pcno) = $field[0] =~ /^PC(\d\d)/; # just get the number
return unless $pcno;
return if $pcno < 10 || $pcno > 51;
-
+
+ # dump bad protocol messages unless it is a PC29
+ if ($line =~ /\%[0-9A-F][0-9A-F]/o && $pcno != 29) {
+ dbg('chan', "CORRUPT protocol message - dumped");
+ return;
+ }
+
# local processing 1
my $pcr;
eval {
# store it away
my $spotter = $field[6];
- $spotter =~ s/-\d+$//o; # strip off the ssid from the spotter
+ $spotter =~ s/-[\@\d]+$//o; # strip off the ssid from the spotter
# do some de-duping
my $freq = $field[1] - 0;
dbg('chan', "Bad DX spot, ignored");
return;
}
+
+ # are any of the crucial fields invalid?
+ if ($field[2] =~ /[a-z]/ || $field[6] =~ /[a-z]/ || $field[7] =~ /[a-z]/) {
+ dbg('chan', "Spot contains lower case callsigns, rejected");
+ return;
+ }
my @spot = Spot::add($freq, $field[2], $d, $text, $spotter, $field[7]);
}
if ($pcno == 12) { # announces
- # announce duplicate checking
- my $text = uc unpad($field[3]);
+ # announce duplicate checking
+ my $text = substr(uc unpad($field[3]), 0, $pc12_dup_lth);
my $dupkey = $field[1].$field[2].$text.$field[4].$field[6];
if ($anndup{$dupkey}) {
dbg('chan', "Duplicate Announce ignored\n");
}
$anndup{$dupkey} = $main::systime;
- # global ann filtering
- my ($filter, $hops) = Filter::it($self->{annfilter}, @field[1..6], $self->{call} ) if $self->{annfilter};
- if ($self->{annfilter} && !$filter) {
- dbg('chan', "Rejected by filter");
- return;
- }
-
if ($field[2] eq '*' || $field[2] eq $main::mycall) {
- # strip leading and trailing stuff
- my $text = unpad($field[3]);
- my $target;
- my $to = 'To ';
- my @list;
-
- if ($field[4] eq '*') { # sysops
- $target = "SYSOP";
- @list = map { $_->priv >= 5 ? $_ : () } get_all_users();
- } elsif ($field[4] gt ' ') { # speciality list handling
- my ($name) = split /\./, $field[4];
- $target = "$name"; # put the rest in later (if bothered)
- }
-
- if ($field[6] eq '1') {
- $target = "WX";
- $to = '';
+ # global ann filtering on INPUT
+ if ($self->{inannfilter}) {
+ my ($filter, $hops) = Filter::it($self->{inannfilter}, @field[1..6], $self->{call} );
+ unless ($filter) {
+ dbg('chan', "Rejected by filter");
+ return;
+ }
}
- $target = "All" if !$target;
+
+ # send it
+ $self->send_announce($line, @field[1..6]);
- if (@list > 0) {
- broadcast_list("$to$target de $field[1]: $text", 'ann', undef, @list);
- } else {
- broadcast_users("$target de $field[1]: $text", 'ann', undef);
+ if ($decode_dk0wcy && $field[1] eq $decode_dk0wcy) {
+ my ($hour, $k, $next, $a, $r, $sfi, $alarm) = $field[3] =~ /^Aurora Beacon\s+(\d+)UTC,\s+Kiel\s+K=(\d+),.*ed\s+K=(\d+),\s+A=(\d+),\s+R=(\d+),\s+SFI=(\d+),.*larm:\s+(\w+)/;
+ $alarm = ($alarm =~ /^Y/i) ? ', Aurora in DE' : '';
+ my $wwv = Geomag::update($main::systime, $hour, $sfi, $a, $k, "R=$r, Next K=$next$alarm", $decode_dk0wcy, $field[5], $r);
}
- Log('ann', $target, $field[1], $text);
return if $field[2] eq $main::mycall; # it's routed to me
} else {
$user->put;
}
- # queue up any messages
- DXMsg::queue_msg(0) if $self->state eq 'normal';
return if $newline eq "PC19^";
# add hop count
$self->send_local_config();
$self->send(pc22());
$self->state('normal');
-
- # queue mail
- DXMsg::queue_msg(0);
-
return;
}
if ($pcno == 22) {
$self->state('normal');
-
- # queue mail
- DXMsg::queue_msg(0);
return;
}
-
+
if ($pcno == 23 || $pcno == 27) { # WWV info
# route 'foreign' pc27s
my $sfi = unpad($field[3]);
my $k = unpad($field[4]);
my $i = unpad($field[5]);
+ my ($r) = $field[6] =~ /R=(\d+)/;
+ $r = 0 unless $r;
my $dupkey = "$d.$sfi$k$i";
if ($wwvdup{$dupkey}) {
dbg('chan', "Dup WWV Spot ignored\n");
return;
}
- if ($d > $main::systime + 900 || $field[2] < 0 || $field[2] > 23) {
+ if (($pcno == 23 && $d < $main::systime - $pc23_max_age) || $d > $main::systime + 900 || $field[2] < 0 || $field[2] > 23) {
dbg('chan', "WWV Date ($field[1] $field[2]) out of range");
return;
}
$wwvdup{$dupkey} = $d;
$field[6] =~ s/-\d+$//o; # remove spotter's ssid
- my $wwv = Geomag::update($d, $field[2], $sfi, $k, $i, @field[6..8]);
+ my $wwv = Geomag::update($d, $field[2], $sfi, $k, $i, @field[6..8], $r);
- my $r;
+ my $rep;
eval {
- $r = Local::wwv($self, $field[1], $field[2], $sfi, $k, $i, @field[6..8]);
+ $rep = Local::wwv($self, $field[1], $field[2], $sfi, $k, $i, @field[6..8], $r);
};
# dbg('local', "Local::wwv2 error $@") if $@;
- return if $r;
+ return if $rep;
# DON'T be silly and send on PC27s!
return if $pcno == 27;
# spots
if ($field[3] > 0) {
- my @in = reverse Spot::search(1, undef, undef, 0, $field[3]-1);
+ my @in = reverse Spot::search(1, undef, undef, 0, $field[3]);
my $in;
foreach $in (@in) {
$self->send(pc26(@{$in}[0..4], $field[2]));
# taking into account filtering and so on
foreach $dxchan (@dxchan) {
my $routeit;
- my ($filter, $hops) = Filter::it($dxchan->{spotfilter}, @_, $self->{call} ) if $dxchan->{spotfilter};
+ my ($filter, $hops);
+
+ if ($dxchan->{spotfilter}) {
+ ($filter, $hops) = Filter::it($dxchan->{spotfilter}, @_, $self->{call} );
+ next unless $filter;
+ }
+
if ($dxchan->is_ak1a) {
next if $dxchan == $self;
if ($hops) {
$dxchan->send($routeit) if $routeit;
} else {
$dxchan->send($routeit) unless $dxchan->{isolate} || $self->{isolate};
-
}
} elsif ($dxchan->is_user && $dxchan->{dx}) {
my $buf = Spot::formatb($_[0], $_[1], $_[2], $_[3], $_[4]);
$buf .= "\a\a" if $dxchan->{beep};
if ($dxchan->{state} eq 'prompt' || $dxchan->{state} eq 'convers') {
- $dxchan->send($buf) if !$hops || ($hops && $filter);
+ $dxchan->send($buf);
} else {
- $dxchan->delay($buf) if !$hops || ($hops && $filter);
+ $dxchan->delay($buf);
}
}
}
# taking into account filtering and so on
foreach $dxchan (@dxchan) {
my $routeit;
- my ($filter, $hops) = Filter::it($dxchan->{wwvfilter}, @_, $self->{call} ) if $dxchan->{wwvfilter};
+ my ($filter, $hops);
+
+ if ($dxchan->{spotfilter}) {
+ ($filter, $hops) = Filter::it($dxchan->{wwvfilter}, @_, $self->{call} );
+ next unless $filter;
+ }
if ($dxchan->is_ak1a) {
next if $dxchan == $self;
if ($hops) {
my $buf = "WWV de $_[6] <$_[1]>: SFI=$_[2], A=$_[3], K=$_[4], $_[5]";
$buf .= "\a\a" if $dxchan->{beep};
if ($dxchan->{state} eq 'prompt' || $dxchan->{state} eq 'convers') {
- $dxchan->send($buf) if !$hops || ($hops && $filter);
+ $dxchan->send($buf);
+ } else {
+ $dxchan->delay($buf);
+ }
+ }
+ }
+}
+
+# send an announce
+sub send_announce
+{
+ my $self = shift;
+ my $line = shift;
+ my @dxchan = DXChannel->get_all();
+ my $dxchan;
+ my $text = unpad($_[2]);
+ my $target;
+ my $to = 'To ';
+
+ if ($_[3] eq '*') { # sysops
+ $target = "SYSOP";
+ } elsif ($_[3] gt ' ') { # speciality list handling
+ my ($name) = split /\./, $_[3];
+ $target = "$name"; # put the rest in later (if bothered)
+ }
+
+ if ($_[5] eq '1') {
+ $target = "WX";
+ $to = '';
+ }
+ $target = "All" if !$target;
+
+ Log('ann', $target, $_[0], $text);
+
+ # send it if it isn't the except list and isn't isolated and still has a hop count
+ # taking into account filtering and so on
+ foreach $dxchan (@dxchan) {
+ my $routeit;
+ my ($filter, $hops);
+
+ if ($dxchan->{annfilter}) {
+ ($filter, $hops) = Filter::it($dxchan->{annfilter}, @_, $self->{call} );
+ return unless $filter;
+ }
+ if ($dxchan->is_ak1a) {
+ next if $dxchan == $self;
+ if ($hops) {
+ $routeit = $line;
+ $routeit =~ s/\^H\d+\^\~$/\^H$hops\^\~/;
+ } else {
+ $routeit = adjust_hops($dxchan, $line); # adjust its hop count by node name
+ next unless $routeit;
+ }
+ if ($filter) {
+ $dxchan->send($routeit) if $routeit;
+ } else {
+ $dxchan->send($routeit) unless $dxchan->{isolate} || $self->{isolate};
+
+ }
+ } elsif ($dxchan->is_user && $dxchan->{ann}) {
+ next if $target eq 'SYSOP' && $dxchan->{priv} < 5;
+ my $buf = "$to$target de $_[0]: $text";
+ $buf .= "\a\a" if $dxchan->{beep};
+ if ($dxchan->{state} eq 'prompt' || $dxchan->{state} eq 'convers') {
+ $dxchan->send($buf);
} else {
- $dxchan->delay($buf) if !$hops || ($hops && $filter);
+ $dxchan->delay($buf);
}
}
}