X-Git-Url: http://dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FDXChannel.pm;h=33d353dbb84e2bb748c52d080b50b7e46c5c4f47;hb=6975c4b4c8b210af067efab767bc1656786f70f2;hp=f577ded847405cbcfbac279f4f2b0ab7327ee828;hpb=30dbf70f84b53174005810f64f546d2181e1a8c6;p=spider.git diff --git a/perl/DXChannel.pm b/perl/DXChannel.pm index f577ded8..33d353db 100644 --- a/perl/DXChannel.pm +++ b/perl/DXChannel.pm @@ -29,6 +29,7 @@ use Msg; use DXM; use DXUtil; use DXDebug; +use Filter; use Carp; use strict; @@ -73,7 +74,16 @@ use vars qw(%channels %valid); annfilter => '5,Announce Filter', wwvfilter => '5,WWV Filter', spotfilter => '5,Spot Filter', + inannfilter => '5,Input Ann Filter', + inwwvfilter => '5,Input WWV Filter', + inspotfilter => '5,Input Spot Filter', passwd => '9,Passwd List,parray', + pingint => '9,Ping Interval ', + nopings => '9,Ping Obs Count', + lastping => '9,Ping last sent,atime', + pingrec => '9,Pings no rec', + pingtime => '9,Ping totaltime', + pingave => '0,Ping ave time', ); # object destruction @@ -89,6 +99,9 @@ sub DESTROY undef $self->{annfilter}; undef $self->{wwvfilter}; undef $self->{spotfilter}; + undef $self->{inannfilter}; + undef $self->{inwwvfilter}; + undef $self->{inspotfilter}; undef $self->{passwd}; } @@ -113,6 +126,12 @@ sub alloc $self->{oldstate} = 0; $self->{lang} = $main::lang if !$self->{lang}; $self->{func} = ""; + + # get the filters + $self->{spotfilter} = Filter::read_in('spots', $call, 0); + $self->{wwvfilter} = Filter::read_in('wwv', $call, 0); + $self->{annfilter} = Filter::read_in('ann', $call, 0); + bless $self, $pkg; return $channels{$call} = $self; } @@ -152,6 +171,13 @@ sub del delete $channels{$self->{call}}; } +# is it a bbs +sub is_bbs +{ + my $self = shift; + return $self->{sort} eq 'B'; +} + # is it an ak1a cluster ? sub is_ak1a { @@ -179,13 +205,17 @@ sub send_now { my $self = shift; my $conn = $self->{conn}; + return unless $conn; my $sort = shift; my $call = $self->{call}; for (@_) { chomp; - $conn->send_now("$sort$call|$_") if $conn; - dbg('chan', "-> $sort $call $_") if $conn; + my @lines = split /\n/; + for (@lines) { + $conn->send_now("$sort$call|$_"); + dbg('chan', "-> $sort $call $_"); + } } $self->{t} = time; } @@ -197,12 +227,16 @@ sub send # this is always later and always data { my $self = shift; my $conn = $self->{conn}; + return unless $conn; my $call = $self->{call}; for (@_) { chomp; - $conn->send_later("D$call|$_") if $conn; - dbg('chan', "-> D $call $_") if $conn; + my @lines = split /\n/; + for (@lines) { + $conn->send_later("D$call|$_"); + dbg('chan', "-> D $call $_"); + } } $self->{t} = time; }