X-Git-Url: http://dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FDXProt.pm;h=09c00b26502ff8de7b3edabd54a25e23e3b6a834;hb=95a03441d20680a914673d1b6bbf46c0d673ad4c;hp=06cf1007c5c34eaa7f536ce2f782a5ec01fe1bed;hpb=febdc9bd8f6cd065d217ba089fab4361e9980f35;p=spider.git diff --git a/perl/DXProt.pm b/perl/DXProt.pm index 06cf1007..09c00b26 100644 --- a/perl/DXProt.pm +++ b/perl/DXProt.pm @@ -35,7 +35,7 @@ use Route::Node; use strict; use vars qw($me $pc11_max_age $pc23_max_age - $last_hour %pings %rcmds + $last_hour $last10 %eph %pings %rcmds %nodehops $baddx $badspotter $badnode $censorpc $allowzero $decode_dk0wcy $send_opernam @checklist); @@ -52,6 +52,7 @@ $censorpc = 1; # Do a BadWords::check on text fields and reject things $baddx = new DXHash "baddx"; $badspotter = new DXHash "badspotter"; $badnode = new DXHash "badnode"; +$last10 = time; @checklist = ( @@ -191,6 +192,12 @@ sub init sub new { my $self = DXChannel::alloc(@_); + + # add this node to the table, the values get filled in later + my $pkg = shift; + my $call = shift; + $main::routeroot->add($call, '0000', Route::here(1)) if $call ne $main::mycall; + return $self; } @@ -252,9 +259,6 @@ sub start # send info to all logged in thingies $self->tell_login('loginn'); - # add this node to the table, the values get filled in later - $main::routeroot->add($call); - Log('DXProt', "$call connected"); } @@ -431,11 +435,13 @@ sub normal if ($to ne $field[7]) { $to = $field[7]; $node = Route::Node::get($to); - $dxchan = $node->dxchan; - if ($node->dxchan && $dxchan->is_clx) { - route(undef, $to, pc84($main::mycall, $to, $main::mycall, $cmd)); - } else { - route(undef, $to, pc34($main::mycall, $to, $cmd)); + if ($node) { + $dxchan = $node->dxchan; + if ($dxchan && $dxchan->is_clx) { + route(undef, $to, pc84($main::mycall, $to, $main::mycall, $cmd)); + } else { + route(undef, $to, pc34($main::mycall, $to, $cmd)); + } } } $user->lastoper($main::systime); @@ -524,24 +530,21 @@ sub normal # general checks my $dxchan; + my $ncall = $field[1]; my $newline = "PC16^"; - if ($field[1] eq $main::mycall || $field[2] eq $main::mycall) { + if ($ncall 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!"); + $dxchan = DXChannel->get($ncall); + if ($dxchan && $dxchan ne $self) { + dbg('chan', "PCPROT: PC16 from $self->{call} trying to alter locally connected $ncall, ignored!"); return; } - if (($dxchan = DXChannel->get($field[1])) && $dxchan != $self) { - dbg('chan', "PCPROT: $field[1] connected locally"); - return; - } - - my $node = Route::Node::get($field[1]); - unless ($node) { - dbg('chan', "PCPROT: Node $field[1] not in config"); + my $parent = Route::Node::get($ncall); + unless ($parent) { + dbg('chan', "PCPROT: Node $ncall not in config"); return; } my $i; @@ -551,14 +554,22 @@ sub normal next unless $call && $conf && defined $here && is_callsign($call); $conf = $conf eq '*'; - push @rout, $node->add_user($call, Route::here($here)|Route::conf($conf)); + my $r = Route::User::get($call); + my $flags = Route::here($here)|Route::conf($conf); + + if ($r && $r->flags != $flags) { + $r->$flags($flags); + push @rout, $r; + } elsif (!$r) { + push @rout, $parent->add_user($call, $flags); + } # add this station to the user database, if required $call =~ s/-\d+$//o; # remove ssid for users my $user = DXUser->get_current($call); $user = DXUser->new($call) if !$user; - $user->homenode($node->call) if !$user->homenode; - $user->node($node->call); + $user->homenode($parent->call) if !$user->homenode; + $user->node($parent->call); $user->lastin($main::systime) unless DXChannel->get($call); $user->put; } @@ -567,34 +578,31 @@ sub normal # queue up any messages (look for privates only) DXMsg::queue_msg(1) if $self->state eq 'normal'; - dbg('route', "B/C PC16 on $field[1] for: " . join(',', map{$_->call} @rout)) if @rout; - $self->route_pc16($node, @rout) if @rout; + $self->route_pc16($parent, @rout) if @rout; return; } if ($pcno == 17) { # remove a user my $dxchan; - if ($field[1] eq $main::mycall || $field[2] eq $main::mycall) { + my $ncall = $field[2]; + my $ucall = $field[1]; + if ($ncall 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!"); + $dxchan = DXChannel->get($ncall); + if ($dxchan && $dxchan ne $self) { + dbg('chan', "PCPROT: PC17 from $self->{call} trying to alter locally connected $ncall, ignored!"); return; } - if ($dxchan = DXChannel->get($field[1])) { - dbg('chan', "PCPROT: $field[1] connected locally"); + my $parent = Route::Node::get($ncall); + unless ($parent) { + dbg('chan', "PCPROT: Route::Node $ncall not in config"); return; } - - my $node = Route::Node::get($field[2]); - unless ($node) { - dbg('chan', "PCPROT: Route::Node $field[2] not in config"); - return; - } - my @rout = $node->del_user($field[1]); - dbg('route', "B/C PC17 on $field[2] for: $field[1]"); - $self->route_pc17($node, @rout) if @rout; + my $r = Route::User::get($ucall); + my @rout = $parent->del_user($ucall) if $r; + $self->route_pc17($parent, @rout) if @rout; return; } @@ -602,12 +610,13 @@ sub normal $self->state('init'); # first clear out any nodes on this dxchannel - my $node = Route::Node::get($self->{call}); + my $parent = Route::Node::get($self->{call}); my @rout; - for ($node->nodes) { - push @rout, $_->del_node; + for ($parent->nodes) { + my $r = Route::Node::get($_); + push @rout, $r->del_node if $r; } - $self->route_pc21(@rout, $node); + $self->route_pc21(@rout, $parent); $self->send_local_config(); $self->send(pc20()); return; # we don't pass these on @@ -619,7 +628,7 @@ sub normal # new routing list my @rout; - my $node = Route::Node::get($self->{call}); + my $parent = Route::Node::get($self->{call}); # parse the PC19 for ($i = 1; $i < $#field-1; $i += 4) { @@ -634,13 +643,24 @@ sub normal next if length $call < 3; # min 3 letter callsigns # update it if required - if ($node->call eq $call && !$node->version) { - $node->version($ver); - $node->flags(Route::here($here)|Route::conf($conf)); - push @rout, $node; - } elsif ($node->call ne $call) { - my $r = $node->add($call, $ver, Route::here($here)|Route::conf($conf)); + my $r; + my $flags = Route::here($here)|Route::conf($conf); + if ($parent->call eq $call && ($parent->version ne $ver || $parent->flags != $flags)) { + $parent->version($ver); + $parent->flags($flags); + push @rout, $parent; + } elsif ($parent->call ne $call) { + next if $call eq $main::mycall || $call eq $self->{call}; + + my $r = $parent->add($call, $ver, Route::here($here)|Route::conf($conf)); push @rout, $r if $r; + } else { + $r = Route::Node::get($call); + if ($r && ($r->version ne $ver || $r->flags != $flags)) { + $r->version($ver); + $r->flags(Route::here($here)|Route::conf($conf)); + push @rout, $r; + } } # unbusy and stop and outgoing mail (ie if somehow we receive another PC19 without a disconnect) @@ -661,8 +681,6 @@ sub normal $user->put; } - dbg('route', "B/C PC19 for: " . join(',', map{$_->call} @rout)) if @rout; - $self->route_pc19(@rout) if @rout; return; } @@ -677,7 +695,7 @@ sub normal if ($pcno == 21) { # delete a cluster from the list my $call = uc $field[1]; my @rout; - my $node = Route::Node::get($call); + my $parent = Route::Node::get($self->{call}); if ($call ne $main::mycall) { # don't allow malicious buggers to disconnect me! if ($call eq $self->{call}) { @@ -686,8 +704,8 @@ sub normal } # routing objects - if ($node) { - push @rout, $node->del_node($call); + if ($parent) { + push @rout, $parent->del_node($call); } else { dbg('chan', "PCPROT: Route::Node $call not in config"); } @@ -695,8 +713,6 @@ sub normal dbg('chan', "PCPROT: I WILL _NOT_ be disconnected!"); return; } - dbg('route', "B/C PC21 for: " . join(',', (map{$_->call} @rout))) if @rout; - $self->route_pc21(@rout) if @rout; return; } @@ -1060,9 +1076,13 @@ sub normal # NOTE - don't arrive here UNLESS YOU WANT this lump of protocol to be # REBROADCAST!!!! # - - unless ($self->{isolate}) { - broadcast_ak1a($line, $self); # send it to everyone but me + + if (eph_dup($line)) { + dbg('chan', "PCPROT: Ephemeral dup, dropped"); + } else { + unless ($self->{isolate}) { + broadcast_ak1a($line, $self); # send it to everyone but me + } } } @@ -1083,7 +1103,9 @@ sub process # send a pc50 out on this channel $dxchan->{pc50_t} = $main::systime unless exists $dxchan->{pc50_t}; if ($t >= $dxchan->{pc50_t} + $DXProt::pc50_interval) { - $dxchan->send(pc50(scalar DXChannel::get_all_users)); + my $s = pc50(scalar DXChannel::get_all_users); + eph_dup($s); + $dxchan->send($s); $dxchan->{pc50_t} = $t; } @@ -1098,14 +1120,17 @@ sub process } } } + + # every ten seconds + if ($t - $last10 >= 10) { + # clean out ephemera + + eph_clean(); + + $last10 = $t; + } - my $key; - my $val; - my $cutoff; if ($main::systime - 3600 > $last_hour) { -# Spot::process; -# Geomag::process; -# AnnTalk::process; $last_hour = $main::systime; } } @@ -1367,27 +1392,33 @@ sub send_local_config my $self = shift; my $n; my @nodes; - my @localcalls; - my @remotecalls; - + my @localnodes; + my @remotenodes; + + dbg('trace', 'DXProt::send_local_config'); + # send our nodes if ($self->{isolate}) { - @localcalls = ( $main::mycall ); + @localnodes = ( $main::routeroot ); } else { # create a list of all the nodes that are not connected to this connection # and are not themselves isolated, this to make sure that isolated nodes # don't appear outside of this node - my @dxchan = grep { $_->call ne $main::mycall && $_->call ne $self->{call} && !$_->{isolate} } DXChannel::get_all_nodes(); - @localcalls = map { $_->{call} } @dxchan if @dxchan; - @remotecalls = map {my $r = Route::Node::get($_); $r ? $r->rnodes(@localcalls, $main::mycall, $self->{call}) : () } @localcalls if @localcalls; - unshift @localcalls, $main::mycall; + my @dxchan = grep { $_->call ne $main::mycall && $_->call ne $self->{call} } DXChannel::get_all_nodes(); + @localnodes = map { Route::Node::get($_->{call}) or die "connot find node $_->{call}" } @dxchan if @dxchan; + my @intcalls = map { $_->nodes } @localnodes if @localnodes; + my $ref = Route::Node::get($self->{call}); + my @rnodes = $ref->nodes; + for my $n (@intcalls) { + push @remotenodes, Route::Node::get($n) unless grep $n eq $_, @rnodes; + } + unshift @localnodes, $main::routeroot; } - @nodes = map {my $r = Route::Node::get($_); $r ? $r : ()} (@localcalls, @remotecalls); - send_route($self, \&pc19, scalar @nodes, @nodes); + send_route($self, \&pc19, scalar(@localnodes)+scalar(@remotenodes), @localnodes, @remotenodes); # get all the users connected on the above nodes and send them out - foreach $n (@nodes) { + foreach $n (@localnodes, @remotenodes) { send_route($self, \&pc16, 1, $n, map {my $r = Route::User::get($_); $r ? ($r) : ()} $n->users); } } @@ -1688,7 +1719,7 @@ sub send_route $routeit = adjust_hops($self, $line); # adjust its hop count by node name next unless $routeit; } - $self->send($routeit) unless $self->{isolate} || $self->{isolate}; + $self->send($routeit); } } } @@ -1732,5 +1763,27 @@ sub route_pc21 broadcast_route($self, \&pc21, scalar @_, @_); } +sub eph_dup +{ + my $s = shift; + + # chop the end off + $s =~ s/\^H\d\d?\^?~?$//; + return 1 if exists $eph{$s}; + $eph{$s} = $main::systime; + return undef; +} + +sub eph_clean +{ + my ($key, $val); + + while (($key, $val) = each %eph) { + if ($main::systime - $val > 90) { + delete $eph{$key}; + } + } +} + 1; __END__