X-Git-Url: http://dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FRoute%2FNode.pm;h=f80e58e324ce5c8e19050d6b03537602fee12777;hb=b9dffeff7239952814342dad19db3a51def6fab7;hp=2fee0acd40042365d5d494679c6b8cc6ac2aa435;hpb=fdc49835d7dc5573453567bd41e52c5e580ad8e7;p=spider.git

diff --git a/perl/Route/Node.pm b/perl/Route/Node.pm
index 2fee0acd..f80e58e3 100644
--- a/perl/Route/Node.pm
+++ b/perl/Route/Node.pm
@@ -10,35 +10,230 @@ package Route::Node;
 
 use DXDebug;
 use Route;
+use Route::User;
 
 use strict;
 
-use vars qw(%list %valid @ISA $me);
+use vars qw(%list %valid @ISA $max $filterdef);
 @ISA = qw(Route);
 
 %valid = (
-		  dxchancall => '0,DXChannel Calls,parray',
 		  parent => '0,Parent Calls,parray',
+		  nodes => '0,Nodes,parray',
+		  users => '0,Users,parray',
+		  usercount => '0,User Count',
 		  version => '0,Version',
+		  handle_xml => '0,Using XML,yesno',
+		  lastmsg => '0,Last Route Msg,atime',
+		  lastid => '0,Last Route MsgID',
 );
 
+$filterdef = $Route::filterdef;
 %list = ();
+$max = 0;
 
-sub init
+sub count
 {
-	$me = Route::Node->new(@_);
+	my $n = scalar (keys %list);
+	$max = $n if $n > $max;
+	return $n;
 }
 
+sub max
+{
+	count();
+	return $max;
+}
+
+#
+# this routine handles the possible adding of an entry in the routing
+# table. It will only add an entry if it is new. It may have all sorts of
+# other side effects which may include fixing up other links.
+#
+# It will return a node object if (and only if) it is a completely new
+# object with that callsign. The upper layers are expected to do something
+# sensible with this!
+#
+# called as $parent->add(call, dxchan, version, flags) 
+#
+
+sub add
+{
+	my $parent = shift;
+	my $call = uc shift;
+	confess "Route::add trying to add $call to myself" if $call eq $parent->{call};
+	my $self = get($call);
+	if ($self) {
+		$self->_addparent($parent);
+		$parent->_addnode($self);
+		return undef;
+	}
+	$self = $parent->new($call, @_);
+	$parent->_addnode($self);
+	return $self;
+}
+
+#
+# this routine is the opposite of 'add' above.
+#
+# It will return an object if (and only if) this 'del' will remove
+# this object completely
+#
+
+sub del
+{
+	my $self = shift;
+	my $pref = shift;
+
+	# delete parent from this call's parent list
+	$pref->_delnode($self);
+    $self->_delparent($pref);
+	my @nodes;
+	my $ncall = $self->{call};
+	
+	# is this the last connection, I have no parents anymore?
+	unless (@{$self->{parent}}) {
+		foreach my $rcall (@{$self->{nodes}}) {
+			next if grep $rcall eq $_, @_;
+			my $r = Route::Node::get($rcall);
+			push @nodes, $r->del($self, $ncall, @_) if $r;
+		}
+		$self->_del_users;
+		delete $list{$self->{call}};
+		push @nodes, $self;
+	}
+	return @nodes;
+}
+
+# this deletes this node completely by grabbing the parents
+# and deleting me from them
+sub delete
+{
+	my $self = shift;
+	my @out;
+	
+	$self->_del_users;
+	foreach my $call (@{$self->{parent}}) {
+		my $parent = Route::Node::get($call);
+		push @out, $parent->del($self) if $parent;
+	}
+	return @out;
+}
+
+sub del_nodes
+{
+	my $parent = shift;
+	my @out;
+	foreach my $rcall (@{$parent->{nodes}}) {
+		my $r = get($rcall);
+		push @out, $r->del($parent, $parent->{call}, @_) if $r;
+	}
+	return @out;
+}
+
+sub _del_users
+{
+	my $self = shift;
+	for (@{$self->{users}}) {
+		my $ref = Route::User::get($_);
+		$ref->del($self) if $ref;
+	}
+	$self->{users} = [];
+}
+
+# add a user to this node
+sub add_user
+{
+	my $self = shift;
+	my $ucall = shift;
+
+	confess "Trying to add NULL User call to routing tables" unless $ucall;
+
+	my $uref = Route::User::get($ucall);
+	my @out;
+	if ($uref) {
+		@out = $uref->addparent($self);
+	} else {
+		$uref = Route::User->new($ucall, $self->{call}, @_);
+		@out = $uref;
+	}
+	$self->_adduser($uref);
+	$self->{usercount} = scalar @{$self->{users}};
+
+	return @out;
+}
+
+# delete a user from this node
+sub del_user
+{
+	my $self = shift;
+	my $ref = shift;
+	my @out;
+	
+	if ($ref) {
+		@out = $self->_deluser($ref);
+		$ref->del($self);
+	} else {
+		confess "tried to delete non-existant $ref->{call} from $self->{call}";
+	}
+	$self->{usercount} = scalar @{$self->{users}};
+	return @out;
+}
+
+sub usercount
+{
+	my $self = shift;
+	if (@_ && @{$self->{users}} == 0) {
+		$self->{usercount} = shift;
+	}
+	return $self->{usercount};
+}
+
+sub users
+{
+	my $self = shift;
+	return @{$self->{users}};
+}
+
+sub nodes
+{
+	my $self = shift;
+	return @{$self->{nodes}};
+}
+
+sub parents
+{
+	my $self = shift;
+	return @{$self->{parent}};
+}
+
+sub rnodes
+{
+	my $self = shift;
+	my @out;
+	foreach my $call (@{$self->{nodes}}) {
+		next if grep $call eq $_, @_;
+		push @out, $call;
+		my $r = get($call);
+		push @out, $r->rnodes($call, @_) if $r;
+	}
+	return @out;
+}
+
+
 sub new
 {
 	my $pkg = shift;
 	my $call = uc shift;
+	
 	confess "already have $call in $pkg" if $list{$call};
 	
 	my $self = $pkg->SUPER::new($call);
-	$self->{dxchancall} = [ ];
-	$self->{parent} = [ ];
+	$self->{parent} = ref $pkg ? [ $pkg->{call} ] : [ ];
 	$self->{version} = shift;
+	$self->{flags} = shift;
+	$self->{users} = [];
+	$self->{nodes} = [];
 	
 	$list{$call} = $self;
 	
@@ -49,31 +244,80 @@ sub get
 {
 	my $call = shift;
 	$call = shift if ref $call;
-	return $list{uc $call};
+	my $ref = $list{uc $call};
+	dbg("Failed to get Node $call" ) if !$ref && isdbg('routerr');
+	return $ref;
 }
 
-sub adddxchan
+sub get_all
+{
+	return values %list;
+}
+
+sub _addparent
+{
+	my $self = shift;
+    return $self->_addlist('parent', @_);
+}
+
+sub _delparent
+{
+	my $self = shift;
+    return $self->_dellist('parent', @_);
+}
+
+
+sub _addnode
 {
 	my $self = shift;
-    $self->_addlist('dxchancall', @_);
+    return $self->_addlist('nodes', @_);
 }
 
-sub deldxchan
+sub _delnode
 {
 	my $self = shift;
-    $self->_dellist('dxchancall', @_);
+    return $self->_dellist('nodes', @_);
 }
 
-sub addparent
+
+sub _adduser
 {
 	my $self = shift;
-    $self->_addlist('parent', @_);
+    return $self->_addlist('users', @_);
 }
 
-sub delparent
+sub _deluser
 {
 	my $self = shift;
-    $self->_dellist('parent', @_);
+    return $self->_dellist('users', @_);
+}
+
+sub DESTROY
+{
+	my $self = shift;
+	my $pkg = ref $self;
+	my $call = $self->{call} || "Unknown";
+	
+	dbg("destroying $pkg with $call") if isdbg('routelow');
+}
+
+#
+# generic AUTOLOAD for accessors
+#
+
+sub AUTOLOAD
+{
+	no strict;
+	my $name = $AUTOLOAD;
+	return if $name =~ /::DESTROY$/;
+	$name =~ s/^.*:://o;
+  
+	confess "Non-existant field '$AUTOLOAD'" unless $valid{$name} || $Route::valid{$name};
+
+	# this clever line of code creates a subroutine which takes over from autoload
+	# from OO Perl - Conway
+        *$AUTOLOAD = sub {$_[0]->{$name} = $_[1] if @_ > 1; return $_[0]->{$name}};
+        goto &$AUTOLOAD;
 }
 
 1;