X-Git-Url: http://gb7djk.dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FThingy%2FHello.pm;h=97abd14e58ba2dc9c78d5a35cffdf74705bf861b;hb=27b6e9691f9985830388bbb8fc0a04357fa4f11f;hp=ed3e5b5cc68f7c5e607ab77b83c771657e0bd16c;hpb=d737a53dd9247a0b3c57852dd605047d241beb47;p=spider.git diff --git a/perl/Thingy/Hello.pm b/perl/Thingy/Hello.pm index ed3e5b5c..97abd14e 100644 --- a/perl/Thingy/Hello.pm +++ b/perl/Thingy/Hello.pm @@ -33,14 +33,20 @@ $verify_on_login = 1; # make sure that a HELLO coming from sub gen_Aranea { my $thing = shift; + my $dxchan = shift; + unless ($thing->{Aranea}) { - $thing->add_auth; - - $thing->{sw} ||= 'DXSp'; - $thing->{v} ||= $main::version; - $thing->{b} ||= $main::build; + if ($thing->{user}) { + $thing->{h} ||= $dxchan->here; + } else { + $thing->add_auth; + $thing->{sw} ||= 'DXSp'; + $thing->{v} ||= $main::version; + $thing->{b} ||= $main::build; + $thing->{h} ||= $main::me->here; + } - $thing->{Aranea} = Aranea::genmsg($thing, [qw(sw v b s auth)]); + $thing->{Aranea} = Aranea::genmsg($thing, [qw(sw h v b s auth)]); } return $thing->{Aranea}; } @@ -61,7 +67,7 @@ sub handle if ($node eq $origin) { # for directly connected calls - if ($verify_on_login) { + if ($verify_on_login && !$thing->{user}) { my $pp = $dxchan->user->passphrase; unless ($pp) { dbglog('err', "Thingy::Hello::handle: verify on and $origin has no passphrase"); @@ -76,7 +82,7 @@ sub handle } } if ($dxchan->{state} ne 'normal') { - $nref = $main::routeroot->add($origin, $thing->{v}, 1); + $nref = $main::routeroot->add($origin, $thing->{v}, $thing->{h}); push @{$thing->{pc19n}}, $nref if $nref; $dxchan->start($dxchan->{conn}->{csort}, $dxchan->{conn}->{outbound} ? 'O' : 'A'); if ($dxchan->{outbound}) { @@ -84,11 +90,12 @@ sub handle $thing->send($dxchan); # broadcast our configuration to the world - $thing = Thingy::Rt->new_lcf; + $thing = Thingy::Rt->new_cf; $thing->broadcast; } } $nref = Route::Node::get($origin); + $nref->np(1); } else { # for otherwise connected calls, that come in relayed from other nodes @@ -98,6 +105,7 @@ sub handle my $v = $thing->{user} ? undef : $thing->{v}; $nref = Route::Node->new($origin, $v, 1); push @{$thing->{pc19n}}, $nref; + $nref->np(1); } } @@ -105,16 +113,25 @@ sub handle if (my $user = $thing->{user}) { my $ur = Route::get($user); unless ($ur) { - my $uref = DXUser->get_current($user); + my @ref; + my $uref = DXUser->get_current($user) || Thingy::Hello::_upd_user_rec($user, $origin)->put; if ($uref->is_node || $uref->is_aranea) { - my $u = $nref->add($user, $thing->{v}, 1); - push @{$thing->{pc19n}}, $u if $u; + push @ref, $nref->add($user, $thing->{v}, $thing->{h}); + push @{$thing->{pc19n}}, @ref if @ref; + do $_->np(1) for @ref; } else { $thing->{pc16n} = $nref; - $thing->{pc16u} = [$nref->add_user($user, 1)]; + push @ref, $nref->add_user($user, $thing->{h}); + $thing->{pc16u} = \@ref if @ref; } } + } else { + $nref->version($thing->{v}) unless $nref->version; + $nref->build($thing->{b}) unless $nref->build; + $nref->sw($thing->{sw}) unless $nref->sw; + $nref->here($thing->{h}) if exists $thing->{h}; } + RouteDB::update($origin, $node, $thing->{hopsaway}); RouteDB::update($thing->{user}, $node, $thing->{hopsaway}) if $thing->{user};