X-Git-Url: http://gb7djk.dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FDXProt.pm;h=e7bda8bc5f5fe9ce82c1b9660813da17d3fea980;hb=4a653ce0cd9140d4a7878cdf8ee835841ca039eb;hp=1f2a642809e31b97637b3ea5b24e22fe74dcfd86;hpb=c5e90df0d93d141f8687556a708068521b9b8f77;p=spider.git diff --git a/perl/DXProt.pm b/perl/DXProt.pm index 1f2a6428..e7bda8bc 100644 --- a/perl/DXProt.pm +++ b/perl/DXProt.pm @@ -70,7 +70,7 @@ $baddxfn = "$main::data/baddx.pl"; [ qw(c c n n) ], # pc25 [ qw(f m d t m c c bc) ], # pc26 [ qw(d n n n n m c c bc) ], # pc27 - [ qw(c c c c d t p m bp n p bp bc) ], # pc28 + [ qw(c c m c d t p m bp n p bp bc) ], # pc28 [ qw(c c n m) ], # pc29 [ qw(c c n) ], # pc30 [ qw(c c n) ], # pc31 @@ -211,11 +211,18 @@ sub start $self->{consort} = $line; # save the connection type $self->{here} = 1; + # get the output filters + $self->{spotsfilter} = Filter::read_in('spots', $call, 0) || Filter::read_in('spots', 'node_default', 0); + $self->{wwvfilter} = Filter::read_in('wwv', $call, 0) || Filter::read_in('wwv', 'node_default', 0); + $self->{wcyfilter} = Filter::read_in('wcy', $call, 0) || Filter::read_in('wcy', 'node_default', 0); + $self->{annfilter} = Filter::read_in('ann', $call, 0) || Filter::read_in('ann', 'node_default', 0) ; + + # 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->{inwcyfilter} = Filter::read_in('wcy', $call, 1); - $self->{inannfilter} = Filter::read_in('ann', $call, 1); + $self->{inspotsfilter} = Filter::read_in('spots', $call, 1) || Filter::read_in('spots', 'node_default', 1); + $self->{inwwvfilter} = Filter::read_in('wwv', $call, 1) || Filter::read_in('wwv', 'node_default', 1); + $self->{inwcyfilter} = Filter::read_in('wcy', $call, 1) || Filter::read_in('wcy', 'node_default', 1); + $self->{inannfilter} = Filter::read_in('ann', $call, 1) || Filter::read_in('ann', 'node_default', 1); # set unbuffered and no echo $self->send_now('B',"0"); @@ -272,7 +279,7 @@ sub normal # check for and dump bad protocol messages my $n = check($pcno, @field); if ($n) { - dbg('chan', "bad field $n, dumped (" . parray($checklist[$pcno-10]) . ")"); + dbg('chan', "PCPROT: bad field $n, dumped (" . parray($checklist[$pcno-10]) . ")"); return; } @@ -291,7 +298,7 @@ sub normal if ($censorpc) { my @bad; if (@bad = BadWords::check($field[3])) { - dbg('chan', "Bad words: @bad, dropped" ); + dbg('chan', "PCPROT: Bad words: @bad, dropped" ); return; } } @@ -326,7 +333,7 @@ sub normal # if this is a 'nodx' node then ignore it if (grep $field[7] =~ /^$_/, @DXProt::nodx_node) { - dbg('chan', "Bad DXNode, dropped"); + dbg('chan', "PCPROT: Bad DXNode, dropped"); return; } @@ -334,26 +341,26 @@ sub normal my $d = cltounix($field[3], $field[4]); # bang out (and don't pass on) if date is invalid or the spot is too old (or too young) if (!$d || ($pcno == 11 && ($d < $main::systime - $pc11_max_age || $d > $main::systime + 900))) { - dbg('chan', "Spot ignored, invalid date or out of range ($field[3] $field[4])\n"); + dbg('chan', "PCPROT: Spot ignored, invalid date or out of range ($field[3] $field[4])\n"); return; } # is it 'baddx' if (grep $field[2] eq $_, @baddx) { - dbg('chan', "Bad DX spot, ignored"); + dbg('chan', "PCPROT: Bad DX spot, ignored"); return; } # do some de-duping $field[5] =~ s/^\s+//; # take any leading blanks off if (Spot::dup($field[1], $field[2], $d, $field[5])) { - dbg('chan', "Duplicate Spot ignored\n"); + dbg('chan', "PCPROT: Duplicate Spot ignored\n"); return; } if ($censorpc) { my @bad; if (@bad = BadWords::check($field[5])) { - dbg('chan', "Bad words: @bad, dropped" ); + dbg('chan', "PCPROT: Bad words: @bad, dropped" ); return; } } @@ -430,14 +437,14 @@ sub normal # announce duplicate checking $field[3] =~ s/^\s+//; # remove leading blanks if (AnnTalk::dup($field[1], $field[2], $field[3])) { - dbg('chan', "Duplicate Announce ignored"); + dbg('chan', "PCPROT: Duplicate Announce ignored"); return; } if ($censorpc) { my @bad; if (@bad = BadWords::check($field[3])) { - dbg('chan', "Bad words: @bad, dropped" ); + dbg('chan', "PCPROT: Bad words: @bad, dropped" ); return; } } @@ -446,9 +453,23 @@ sub normal # global ann filtering on INPUT if ($self->{inannfilter}) { - my ($filter, $hops) = Filter::it($self->{inannfilter}, @field[1..6], $self->{call} ); + my ($ann_dxcc, $ann_itu, $ann_cq, $org_dxcc, $org_itu, $org_cq) = (0..0); + my @dxcc = Prefix::extract($field[1]); + if (@dxcc > 0) { + $ann_dxcc = $dxcc[1]->dxcc; + $ann_itu = $dxcc[1]->itu; + $ann_cq = $dxcc[1]->cq(); + } + @dxcc = Prefix::extract($field[5]); + if (@dxcc > 0) { + $org_dxcc = $dxcc[1]->dxcc; + $org_itu = $dxcc[1]->itu; + $org_cq = $dxcc[1]->cq(); + } + my ($filter, $hops) = $self->{inannfilter}->it(@field[1..6], $self->{call}, + $ann_dxcc, $ann_itu, $ann_cq, $org_dxcc, $org_itu, $org_cq); unless ($filter) { - dbg('chan', "Rejected by filter"); + dbg('chan', "PCPROT: Rejected by filter"); return; } } @@ -479,27 +500,49 @@ sub normal # add it to the node table if it isn't present and it's # connected locally $node = DXNode->new($dxchan, $field[1], 0, 1, 5400); - broadcast_ak1a(pc19($dxchan, $node), $dxchan, $self) unless $dxchan->{isolate}; + dbg('chan', "PCPROT: $field[1] no PC19 yet, autovivified as node"); +# broadcast_ak1a(pc19($dxchan, $node), $dxchan, $self) unless $dxchan->{isolate}; } - return unless $node; # ignore if havn't seen a PC19 for this one yet - return unless $node->isa('DXNode'); + if ($field[1] eq $main::mycall || $field[2] eq $main::mycall) { + dbg('chan', "PCPROT: trying to alter config on this node from outside!"); + return; + } + if ($field[2] eq $main::myalias && DXChannel->get($field[1])) { + dbg('chan', "PCPROT: trying to connect sysop from outside!"); + return; + } + unless ($node) { + dbg('chan', "PCPROT: Node $field[1] not in config"); + return; + } + unless ($node->isa('DXNode')) { + dbg('chan', "PCPROT: $field[1] is not a node"); + return; + } if ($node->dxchan != $self) { - dbg('chan', "LOOP: $field[1] came in on wrong channel"); + dbg('chan', "PCPROT: $field[1] came in on wrong channel"); return; } if (($dxchan = DXChannel->get($field[1])) && $dxchan != $self) { - dbg('chan', "LOOP: $field[1] connected locally"); + dbg('chan', "PCPROT: $field[1] connected locally"); return; } my $i; for ($i = 2; $i < $#field; $i++) { my ($call, $confmode, $here) = $field[$i] =~ /^(\S+) (\S) (\d)/o; - next if !$call || length $call < 3 || length $call > 8; - next if !$confmode; - $call = uc $call; - next if DXCluster->get_exact($call); # we already have this (loop?) + next unless $call && $confmode && defined $here && is_callsign($call); + my $ref = DXCluster->get_exact($call); + if ($ref) { + if ($ref->isa('DXNode')) { + dbg('chan', "PCPROT: $call is a node"); + next; + } + my $rcall = $ref->mynode->call; + dbg('chan', "PCPROT: already have $call on $rcall"); + next; + } $confmode = $confmode eq '*'; DXNodeuser->new($self, $node, $call, $confmode, $here); @@ -526,21 +569,40 @@ sub normal # add it to the node table if it isn't present and it's # connected locally $node = DXNode->new($dxchan, $field[2], 0, 1, 5400); - broadcast_ak1a(pc19($dxchan, $node), $dxchan, $self) unless $dxchan->{isolate}; + dbg('chan', "PCPROT: $field[2] no PC19 yet, autovivified as node"); +# broadcast_ak1a(pc19($dxchan, $node), $dxchan, $self) unless $dxchan->{isolate}; + } + if ($field[1] eq $main::mycall || $field[2] eq $main::mycall) { + dbg('chan', "PCPROT: trying to alter config on this node from outside!"); + return; + } + if ($field[1] eq $main::myalias && DXChannel->get($field[1])) { + dbg('chan', "PCPROT: trying to disconnect sysop from outside!"); + return; + } + unless ($node) { + dbg('chan', "PCPROT: Node $field[2] not in config"); + return; + } + unless ($node->isa('DXNode')) { + dbg('chan', "PCPROT: $field[2] is not a node"); return; } - return unless $node; - return unless $node->isa('DXNode'); if ($node->dxchan != $self) { - dbg('chan', "LOOP: $field[2] came in on wrong channel"); + dbg('chan', "PCPROT: $field[2] came in on wrong channel"); return; } if (($dxchan = DXChannel->get($field[2])) && $dxchan != $self) { - dbg('chan', "LOOP: $field[2] connected locally"); + dbg('chan', "PCPROT: $field[2] connected locally"); return; } my $ref = DXCluster->get_exact($field[1]); - $ref->del() if $ref; + if ($ref) { + $ref->del; + } else { + dbg('chan', "PCPROT: $field[1] not known" ); + return; + } last SWITCH; } @@ -567,6 +629,7 @@ sub normal my $call = uc $field[$i+1]; my $confmode = $field[$i+2]; my $ver = $field[$i+3]; + next unless defined $here && defined $confmode && is_callsign($call); $ver = 5400 if !$ver && $allowzero; @@ -575,13 +638,14 @@ sub normal if ($node) { my $dxchan; if (($dxchan = DXChannel->get($call)) && $dxchan != $self) { - dbg('chan', "LOOP: $call connected locally"); + dbg('chan', "PCPROT: $call connected locally"); } if ($node->dxchan != $self) { - dbg('chan', "LOOP: $call come in on wrong channel"); + dbg('chan', "PCPROT: $call come in on wrong channel"); next; } - dbg('chan', "already have $call"); + my $rcall = $node->mynode->call; + dbg('chan', "PCPROT: already have $call on $rcall"); next; } @@ -631,24 +695,31 @@ sub normal if ($call ne $main::mycall) { # don't allow malicious buggers to disconnect me! my $node = DXCluster->get_exact($call); if ($node) { + unless ($node->isa('DXNode')) { + dbg('chan', "PCPROT: $call is not a node"); + return; + } if ($call eq $self->{call}) { - dbg('chan', "LOOP: Trying to disconnect myself with PC21"); + dbg('chan', "PCPROT: Trying to disconnect myself with PC21"); return; } if ($node->dxchan != $self) { - dbg('chan', "LOOP: $call come in on wrong channel"); + dbg('chan', "PCPROT: $call come in on wrong channel"); return; } my $dxchan; if ($dxchan = DXChannel->get($call)) { - dbg('chan', "LOOP: $call connected locally"); + dbg('chan', "PCPROT: $call connected locally"); return; } $node->del(); } else { - dbg('chan', "$call not in table, dropped"); + dbg('chan', "PCPROT: $call not in table, dropped"); return; } + } else { + dbg('chan', "PCPROT: I WILL _NOT_ be disconnected!"); + return; } last SWITCH; } @@ -676,11 +747,11 @@ sub normal my ($r) = $field[6] =~ /R=(\d+)/; $r = 0 unless $r; if (($pcno == 23 && $d < $main::systime - $pc23_max_age) || $d > $main::systime + 1500 || $field[2] < 0 || $field[2] > 23) { - dbg('chan', "WWV Date ($field[1] $field[2]) out of range"); + dbg('chan', "PCPROT: WWV Date ($field[1] $field[2]) out of range"); return; } if (Geomag::dup($d,$sfi,$k,$i,$field[6])) { - dbg('chan', "Dup WWV Spot ignored\n"); + dbg('chan', "PCPROT: Dup WWV Spot ignored\n"); return; } $field[7] =~ s/-\d+$//o; # remove spotter's ssid @@ -715,7 +786,7 @@ sub normal return; } if ($field[2] eq $main::mycall) { - dbg('chan', "Trying to merge to myself, ignored"); + dbg('chan', "PCPROT: Trying to merge to myself, ignored"); return; } @@ -777,7 +848,7 @@ sub normal } else { my $ref = DXUser->get_current($field[1]); if ($ref && $ref->is_clx) { - route($field[1], pc84($field[2], $field[1], $field[2], $field[3])); + $self->route($field[1], pc84($field[2], $field[1], $field[2], $field[3])); } else { $self->route($field[1], $line); } @@ -800,7 +871,7 @@ sub normal } else { my $ref = DXUser->get_current($field[1]); if ($ref && $ref->is_clx) { - route($field[1], pc85($field[2], $field[1], $field[2], $field[3])); + $self->route($field[1], pc85($field[2], $field[1], $field[2], $field[3])); } else { $self->route($field[1], $line); } @@ -815,18 +886,17 @@ sub normal } if ($pcno == 39) { # incoming disconnect - $self->disconnect(1); + if ($field[1] eq $self->{call}) { + $self->disconnect(1); + } else { + dbg('chan', "PCPROT: came in on wrong channel"); + } return; } if ($pcno == 41) { # user info # add this station to the user database, if required my $user = DXUser->get_current($field[1]); - if (!$user) { - # then try without an SSID - $field[1] =~ s/-\d+$//o; - $user = DXUser->get_current($field[1]); - } $user = DXUser->new($field[1]) if !$user; if ($field[2] == 1) { @@ -918,12 +988,12 @@ sub normal # do some de-duping my $d = cltounix($field[1], sprintf("%02d18Z", $field[2])); if (($pcno == 23 && $d < $main::systime - $pc23_max_age) || $d > $main::systime + 1500 || $field[2] < 0 || $field[2] > 23) { - dbg('chan', "WCY Date ($field[1] $field[2]) out of range"); + dbg('chan', "PCPROT: WCY Date ($field[1] $field[2]) out of range"); return; } @field = map { unpad($_) } @field; if (WCY::dup($d,@field[3..7])) { - dbg('chan', "Dup WCY Spot ignored\n"); + dbg('chan', "PCPROT: Dup WCY Spot ignored\n"); return; } @@ -970,7 +1040,7 @@ sub normal if ($ref && $ref->is_clx) { $self->route($field[1], $line); } else { - route($field[1], pc34($field[2], $field[1], $field[4])); + $self->route($field[1], pc34($field[2], $field[1], $field[4])); } } return; @@ -998,7 +1068,7 @@ sub normal if ($ref && $ref->is_clx) { $self->route($field[1], $line); } else { - route($field[1], pc35($field[2], $field[1], $field[4])); + $self->route($field[1], pc35($field[2], $field[1], $field[4])); } } return; @@ -1117,8 +1187,8 @@ sub send_dx_spot my $routeit; my ($filter, $hops); - if ($dxchan->{spotfilter}) { - ($filter, $hops) = Filter::it($dxchan->{spotfilter}, @_, $self->{call} ); + if ($dxchan->{spotsfilter}) { + ($filter, $hops) = $dxchan->{spotsfilter}->it(@_, $self->{call} ); next unless $filter; } @@ -1155,6 +1225,19 @@ sub send_wwv_spot my $line = shift; my @dxchan = DXChannel->get_all(); my $dxchan; + my ($wwv_dxcc, $wwv_itu, $wwv_cq, $org_dxcc, $org_itu, $org_cq) = (0..0); + my @dxcc = Prefix::extract($_[7]); + if (@dxcc > 0) { + $wwv_dxcc = $dxcc[1]->dxcc; + $wwv_itu = $dxcc[1]->itu; + $wwv_cq = $dxcc[1]->cq; + } + @dxcc = Prefix::extract($_[8]); + if (@dxcc > 0) { + $org_dxcc = $dxcc[1]->dxcc; + $org_itu = $dxcc[1]->itu; + $org_cq = $dxcc[1]->cq; + } # 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 @@ -1163,7 +1246,7 @@ sub send_wwv_spot my ($filter, $hops); if ($dxchan->{wwvfilter}) { - ($filter, $hops) = Filter::it($dxchan->{wwvfilter}, @_, $self->{call} ); + ($filter, $hops) = $dxchan->{wwvfilter}->it(@_, $self->{call}, $wwv_dxcc, $wwv_itu, $wwv_cq, $org_dxcc, $org_itu, $org_cq); next unless $filter; } if ($dxchan->is_node) { @@ -1199,6 +1282,19 @@ sub send_wcy_spot my $line = shift; my @dxchan = DXChannel->get_all(); my $dxchan; + my ($wcy_dxcc, $wcy_itu, $wcy_cq, $org_dxcc, $org_itu, $org_cq) = (0..0); + my @dxcc = Prefix::extract($_[11]); + if (@dxcc > 0) { + $wcy_dxcc = $dxcc[1]->dxcc; + $wcy_itu = $dxcc[1]->itu; + $wcy_cq = $dxcc[1]->cq; + } + @dxcc = Prefix::extract($_[12]); + if (@dxcc > 0) { + $org_dxcc = $dxcc[1]->dxcc; + $org_itu = $dxcc[1]->itu; + $org_cq = $dxcc[1]->cq; + } # 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 @@ -1207,10 +1303,10 @@ sub send_wcy_spot my ($filter, $hops); if ($dxchan->{wcyfilter}) { - ($filter, $hops) = Filter::it($dxchan->{wcyfilter}, @_, $self->{call} ); + ($filter, $hops) = $dxchan->{wcyfilter}->it(@_, $self->{call}, $wcy_dxcc, $wcy_itu, $wcy_cq, $org_dxcc, $org_itu, $org_cq); next unless $filter; } - if ($dxchan->is_clx || $dxchan->is_spider) { + if ($dxchan->is_clx || $dxchan->is_spider || $dxchan->is_dxnet) { next if $dxchan == $self; if ($hops) { $routeit = $line; @@ -1258,10 +1354,25 @@ sub send_announce $target = "WX"; $to = ''; } - $target = "All" if !$target; + $target = "ALL" if !$target; Log('ann', $target, $_[0], $text); + # obtain country codes etc + my ($ann_dxcc, $ann_itu, $ann_cq, $org_dxcc, $org_itu, $org_cq) = (0..0); + my @dxcc = Prefix::extract($_[0]); + if (@dxcc > 0) { + $ann_dxcc = $dxcc[1]->dxcc; + $ann_itu = $dxcc[1]->itu; + $ann_cq = $dxcc[1]->cq; + } + @dxcc = Prefix::extract($_[4]); + if (@dxcc > 0) { + $org_dxcc = $dxcc[1]->dxcc; + $org_itu = $dxcc[1]->itu; + $org_cq = $dxcc[1]->cq; + } + # 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) { @@ -1269,7 +1380,7 @@ sub send_announce my ($filter, $hops); if ($dxchan->{annfilter}) { - ($filter, $hops) = Filter::it($dxchan->{annfilter}, @_, $self->{call} ); + ($filter, $hops) = $dxchan->{annfilter}->it(@_, $self->{call}, $ann_dxcc, $ann_itu, $ann_cq, $org_dxcc, $org_itu, $org_cq); next unless $filter; } if ($dxchan->is_node && $_[1] ne $main::mycall) { # i.e not specifically routed to me @@ -1355,7 +1466,7 @@ sub route my ($self, $call, $line) = @_; if (ref $self && $call eq $self->{call}) { - dbg('chan', "Trying to route back to source, dropped"); + dbg('chan', "PCPROT: Trying to route back to source, dropped"); return; } @@ -1364,12 +1475,20 @@ sub route unless ($dxchan) { my $cl = DXCluster->get_exact($call); $dxchan = $cl->dxchan if $cl; + if (ref $dxchan) { + if (ref $self && $dxchan eq $self) { + dbg('chan', "PCPROT: Trying to route back to source, dropped"); + return; + } + } } if ($dxchan) { my $routeit = adjust_hops($dxchan, $line); # adjust its hop count by node name if ($routeit) { $dxchan->send($routeit); } + } else { + dbg('chan', "PCPROT: No route available, dropped"); } } @@ -1439,7 +1558,7 @@ sub broadcast_list if ($sort eq 'dx') { next unless $dxchan->{dx}; - ($filter) = Filter::it($dxchan->{spotfilter}, @{$fref}) if ref $fref; + ($filter) = $dxchan->{spotsfilter}->it(@{$fref}) if ref $fref; next unless $filter; } next if $sort eq 'ann' && !$dxchan->{ann};