92ceba22577940c41cbba51faa732bd29834d1ef
[spider.git] / perl / Route / Node.pm
1 #
2 # Node routing routines
3 #
4 # Copyright (c) 2001 Dirk Koopman G1TLH
5 #
6 # $Id$
7
8
9 package Route::Node;
10
11 use DXDebug;
12 use Route;
13 use Route::User;
14
15 use strict;
16
17 use vars qw($VERSION $BRANCH);
18 $VERSION = sprintf( "%d.%03d", q$Revision$ =~ /(\d+)\.(\d+)/ );
19 $BRANCH = sprintf( "%d.%03d", q$Revision$ =~ /\d+\.\d+\.(\d+)\.(\d+)/  || (0,0));
20 $main::build += $VERSION;
21 $main::branch += $BRANCH;
22
23 use vars qw(%list %valid @ISA $max $filterdef);
24 @ISA = qw(Route);
25
26 %valid = (
27                   dxchan => '0,Visible on DXChans,parray',
28                   nodes => '0,Nodes,parray',
29                   users => '0,Users,parray',
30                   usercount => '0,User Count',
31                   version => '0,Version',
32                   np => '0,Using New Prot,yesno',
33                   lid => '0,Last Msgid',
34 );
35
36 $filterdef = $Route::filterdef;
37 %list = ();
38 $max = 0;
39
40 sub count
41 {
42         my $n = scalar (keys %list);
43         $max = $n if $n > $max;
44         return $n;
45 }
46
47 sub max
48 {
49         count();
50         return $max;
51 }
52
53 #
54 # this routine handles the possible adding of an entry in the routing
55 # table. It will only add an entry if it is new. It may have all sorts of
56 # other side effects which may include fixing up other links.
57 #
58 # It will return a node object if (and only if) it is a completely new
59 # object with that callsign. The upper layers are expected to do something
60 # sensible with this!
61 #
62 # called as $dxchan->add(call, dxchan, version, flags) 
63 #
64
65 sub add
66 {
67         my $dxchan = shift;
68         my $call = uc shift;
69         confess "Route::add trying to add $call to myself" if $call eq $dxchan->{call};
70         my $self = get($call);
71         if ($self) {
72                 $self->_adddxchan($dxchan);
73                 $dxchan->_addnode($self);
74                 return undef;
75         }
76         $self = $dxchan->new($call, @_);
77         $dxchan->_addnode($self);
78         return $self;
79 }
80
81 #
82 # this routine is the opposite of 'add' above.
83 #
84 # It will return an object if (and only if) this 'del' will remove
85 # this object completely
86 #
87
88 sub del
89 {
90         my $self = shift;
91         my $pref = shift;
92
93         # delete dxchan from this call's dxchan list
94         $pref->_delnode($self);
95     $self->_deldxchan($pref);
96         my @nodes;
97         my $ncall = $self->{call};
98         
99         # is this the last connection, I have no dxchan anymore?
100         unless (@{$self->{dxchan}}) {
101                 foreach my $rcall (@{$self->{nodes}}) {
102                         next if grep $rcall eq $_, @_;
103                         my $r = Route::Node::get($rcall);
104                         push @nodes, $r->del($self, $ncall, @_) if $r;
105                 }
106                 $self->_del_users;
107                 delete $list{$self->{call}};
108                 push @nodes, $self;
109         }
110         return @nodes;
111 }
112
113 sub del_nodes
114 {
115         my $dxchan = shift;
116         my @out;
117         foreach my $rcall (@{$dxchan->{nodes}}) {
118                 my $r = get($rcall);
119                 push @out, $r->del($dxchan, $dxchan->{call}, @_) if $r;
120         }
121         return @out;
122 }
123
124 sub _del_users
125 {
126         my $self = shift;
127         for (@{$self->{users}}) {
128                 my $ref = Route::User::get($_);
129                 $ref->del($self) if $ref;
130         }
131         $self->{users} = [];
132 }
133
134 # add a user to this node
135 sub add_user
136 {
137         my $self = shift;
138         my $ucall = shift;
139
140         confess "Trying to add NULL User call to routing tables" unless $ucall;
141
142         my $uref = Route::User::get($ucall);
143         my @out;
144         if ($uref) {
145                 @out = $uref->adddxchan($self);
146         } else {
147                 $uref = Route::User->new($ucall, $self->{call}, @_);
148                 @out = $uref;
149         }
150         $self->_adduser($uref);
151         $self->{usercount} = scalar @{$self->{users}};
152
153         return @out;
154 }
155
156 # delete a user from this node
157 sub del_user
158 {
159         my $self = shift;
160         my $ref = shift;
161         my @out;
162         
163         if ($ref) {
164                 @out = $self->_deluser($ref);
165                 $ref->del($self);
166         } else {
167                 confess "tried to delete non-existant $ref->{call} from $self->{call}";
168         }
169         $self->{usercount} = scalar @{$self->{users}};
170         return @out;
171 }
172
173 sub usercount
174 {
175         my $self = shift;
176         if (@_ && @{$self->{users}} == 0) {
177                 $self->{usercount} = shift;
178         }
179         return $self->{usercount};
180 }
181
182 sub users
183 {
184         my $self = shift;
185         return @{$self->{users}};
186 }
187
188 sub nodes
189 {
190         my $self = shift;
191         return @{$self->{nodes}};
192 }
193
194 sub rnodes
195 {
196         my $self = shift;
197         my @out;
198         foreach my $call (@{$self->{nodes}}) {
199                 next if grep $call eq $_, @_;
200                 push @out, $call;
201                 my $r = get($call);
202                 push @out, $r->rnodes($call, @_) if $r;
203         }
204         return @out;
205 }
206
207
208 sub new
209 {
210         my $pkg = shift;
211         my $call = uc shift;
212         
213         confess "already have $call in $pkg" if $list{$call};
214         
215         my $self = $pkg->SUPER::new($call);
216         $self->{dxchan} = ref $pkg ? [ $pkg->{call} ] : [ ];
217         $self->{version} = shift;
218         $self->{flags} = shift;
219         $self->{users} = [];
220         $self->{nodes} = [];
221         $self->{lid} = 0;
222         
223         $list{$call} = $self;
224         
225         return $self;
226 }
227
228 sub get
229 {
230         my $call = shift;
231         $call = shift if ref $call;
232         my $ref = $list{uc $call};
233         dbg("Failed to get Node $call" ) if !$ref && isdbg('routerr');
234         return $ref;
235 }
236
237 sub get_all
238 {
239         return values %list;
240 }
241
242
243 sub _adduser
244 {
245         my $self = shift;
246     return $self->_addlist('users', @_);
247 }
248
249 sub _deluser
250 {
251         my $self = shift;
252     return $self->_dellist('users', @_);
253 }
254
255 sub DESTROY
256 {
257         my $self = shift;
258         my $pkg = ref $self;
259         my $call = $self->{call} || "Unknown";
260         
261         dbg("destroying $pkg with $call") if isdbg('routelow');
262 }
263
264 #
265 # generic AUTOLOAD for accessors
266 #
267
268 sub AUTOLOAD
269 {
270         no strict;
271         my $name = $AUTOLOAD;
272         return if $name =~ /::DESTROY$/;
273         $name =~ s/^.*:://o;
274   
275         confess "Non-existant field '$AUTOLOAD'" unless $valid{$name} || $Route::valid{$name};
276
277         # this clever line of code creates a subroutine which takes over from autoload
278         # from OO Perl - Conway
279         *$AUTOLOAD = sub {$_[0]->{$name} = $_[1] if @_ > 1; return $_[0]->{$name}};
280         goto &$AUTOLOAD;
281 }
282
283 1;
284