X-Git-Url: http://www.dxcluster.org/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FDXChannel.pm;h=7d835171d5d88ff9edc2e2db94a913f82698ba83;hb=7432cb12ce865030c8b0315a30764e0088a59102;hp=cfa3d150fe1b3f3ff6220135e81dd6264480fbcd;hpb=6b6a8002929017b6d4217f68fa492a2d728ee1fe;p=spider.git diff --git a/perl/DXChannel.pm b/perl/DXChannel.pm index cfa3d150..7d835171 100644 --- a/perl/DXChannel.pm +++ b/perl/DXChannel.pm @@ -29,25 +29,38 @@ use Msg; use DXUtil; use DXM; use DXDebug; +use Carp; + +use strict; +use vars qw(%channels %valid); %channels = undef; %valid = ( - call => 'Callsign', - conn => 'Msg Connection ref', - user => 'DXUser ref', - t => 'Time', - priv => 'Privilege', - state => 'Current State', - oldstate => 'Last State', - list => 'Dependant DXChannels list', - name => 'User Name', - connsort => 'Connection Type' + call => '0,Callsign', + conn => '9,Msg Conn ref', + user => '9,DXUser ref', + startt => '0,Start Time,atime', + t => '9,Time,atime', + pc50_t => '9,Last PC50 Time,atime', + priv => '9,Privilege', + state => '0,Current State', + oldstate => '5,Last State', + list => '9,Dep Chan List', + name => '0,User Name', + consort => '9,Connection Type', + sort => '9,Type of Channel', + wwv => '0,Want WWV,yesno', + talk => '0,Want Talk,yesno', + ann => '0,Want Announce,yesno', + here => '0,Here?,yesno', + confmode => '0,In Conference?,yesno', + dx => '0,DX Spots,yesno', + redirect => '0,Redirect messages to', ); - # create a new channel object [$obj = DXChannel->new($call, $msg_conn_obj, $user_obj)] -sub new +sub alloc { my ($pkg, $call, $conn, $user) = @_; my $self = {}; @@ -56,7 +69,7 @@ sub new $self->{call} = $call; $self->{conn} = $conn if defined $conn; # if this isn't defined then it must be a list $self->{user} = $user if defined $user; - $self->{t} = time; + $self->{startt} = $self->{t} = time; $self->{state} = 0; $self->{oldstate} = 0; bless $self, $pkg; @@ -96,6 +109,19 @@ sub del delete $channels{$self->{call}}; } +# is it an ak1a cluster ? +sub is_ak1a +{ + my $self = shift; + return $self->{sort} eq 'A'; +} + +# is it a user? +sub is_user +{ + my $self = shift; + return $self->{sort} eq 'U'; +} # handle out going messages, immediately without waiting for the select to drop # this could, in theory, block @@ -103,25 +129,16 @@ sub send_now { my $self = shift; my $conn = $self->{conn}; - - # is this a list of channels ? - if (!defined $conn) { - die "tried to send_now to an invalid channel list" if !defined $self->{list}; - my $lself; - foreach $lself (@$self->{list}) { - $lself->send_now(@_); # it's recursive :-) - } - } else { - my $sort = shift; - my $call = $self->{call}; - my $line; + my $sort = shift; + my $call = $self->{call}; + my $line; - foreach $line (@_) { - chomp $line; - dbg('chan', "-> $sort $call $line\n"); - $conn->send_now("$sort$call|$line"); - } + foreach $line (@_) { + chomp $line; + dbg('chan', "-> $sort $call $line\n") if $conn; + $conn->send_now("$sort$call|$line") if $conn; } + $self->{t} = time; } # @@ -131,24 +148,15 @@ sub send # this is always later and always data { my $self = shift; my $conn = $self->{conn}; - - # is this a list of channels ? - if (!defined $conn) { - die "tried to send to an invalid channel list" if !defined $self->{list}; - my $lself; - foreach $lself (@$self->{list}) { - $lself->send(@_); # here as well :-) :-) - } - } else { - my $call = $self->{call}; - my $line; - - foreach $line (@_) { - chomp $line; - dbg('chan', "-> D $call $line\n"); - $conn->send_later("D$call|$line"); - } + my $call = $self->{call}; + my $line; + + foreach $line (@_) { + chomp $line; + dbg('chan', "-> D $call $line\n") if $conn; + $conn->send_later("D$call|$line") if $conn; } + $self->{t} = time; } # send a file (always later) @@ -202,15 +210,15 @@ sub field_prompt return $valid{$ele}; } +no strict; sub AUTOLOAD { my $self = shift; my $name = $AUTOLOAD; - return if $name =~ /::DESTROY$/; $name =~ s/.*:://o; - die "Non-existant field '$AUTOLOAD'" if !$valid{$name}; + confess "Non-existant field '$AUTOLOAD'" if !$valid{$name}; @_ ? $self->{$name} = shift : $self->{$name} ; }