X-Git-Url: http://dxcluster.org/gitweb/gitweb.cgi?a=blobdiff_plain;ds=sidebyside;f=perl%2Frbn.pl;h=2a72dd8e39b0ea37f6bf3ea970b2d0daf7840df7;hb=0de1a272bd43c887020d9e03a4f56f44ab4bb080;hp=e6c65844fc40b2534578cd7ab6811be5f30143ac;hpb=cdbbd92df8c561a71858766dbd2dd497d1dd0b5c;p=spider.git

diff --git a/perl/rbn.pl b/perl/rbn.pl
index e6c65844..2a72dd8e 100755
--- a/perl/rbn.pl
+++ b/perl/rbn.pl
@@ -9,12 +9,13 @@ use strict;
 use 5.10.1;
 use IO::Socket::IP -register;
 use Math::Round qw(nearest);
+use Getopt::Long;
+use Pod::Usage;
 
 my $host = 'telnet.reversebeacon.net';
 my $port = 7000;
-my $mycall = shift or die "usage:rbn.pl <callsign> [debug] [stats] [cw] [rtty] [psk] [beacon] [<time between repeat spots in minutes>]\n"; 
 
-my $minspottime = 30*60;		# minimum length of time between successive spots
+my $minspottime = 60*60;		# minimum length of time between successive identical spots
 my $showstats;					# show RBN and Spot stats
 
 my $attempts;
@@ -24,26 +25,45 @@ my $wantcw = 1;
 my $wantrtty = 1;
 my $wantpsk = 1;
 my $wantbeacon = 1;
-my $override; 
-	
-while (@ARGV) {
-	my $arg = shift;
-
-	++$dbg if $arg =~ /^deb/i;
-	++$showstats if $arg =~ /^stat/i;
-	$minspottime = $arg * 60 if $arg =~ /^\d+$/;
-	if (!$override && $arg =~ /^cw|rtty|psk|beacon$/i) {
-		$override = 1;
-		$wantcw = $wantrtty = $wantpsk = $wantbeacon = 0;
-	}
-	++$wantcw if $arg =~ /^cw$/i;
-	++$wantpsk if $arg =~ /^psk$/i;
-	++$wantrtty if $arg =~ /^rtty$/i;
-	++$wantbeacon if $arg =~ /^beacon$/i;
-}
+my $wantdx = 1;
+my $wantraw = 0;
+my $showrbn;
+my $help = 0;
+my $man = 0;
+my $mycall;
+
+#Getopt::Long::Configure( qw(auto_abbrev) );
+GetOptions('host=s' => \$host,
+		   'port=i' => \$port,
+		   'debug' => \$dbg,
+		   'rbn' => \$showrbn,
+		   'stats' => \$showstats,
+		   'raw' => \$wantraw,
+		   'repeattime|rt=i' => sub { $minspottime = $_[1] * 60 },
+		   'want=s' => sub {
+			   my ($name, $value) = @_;
+			   $wantcw = $wantrtty = $wantpsk = $wantbeacon = $wantdx = 0;
+			   for (split /[:,\|]/, $value) {
+				   ++$wantcw if /^cw$/i;
+				   ++$wantpsk if /^psk$/i;
+				   ++$wantrtty if /^rtty$/i;
+				   ++$wantbeacon if /^beacon$/i;
+				   ++$wantdx if /^dx$/i;
+			   }
+		   },
+		   'help|?' => \$help,
+		   'man' => \$man,
+		   '<>' => sub { $mycall = shift },
+		  ) or pod2usage(2);
+
+$mycall ||= shift;
+
+pod2usage(1) if $help || !$mycall;
+pod2usage(-exitval => 0, -verbose => 2) if $man;
+
 
 for ($attempts = 1; $attempts <= 5; ++$attempts) {
-	say "admin,connecting to $host $port.. (attempt $attempts) " if $dbg;
+	say "ADMIN,connecting to $host $port.. (attempt $attempts) " if $dbg;
 	$sock = IO::Socket::IP->new(
 								PeerHost => $host,
 								PeerPort => $port,
@@ -52,10 +72,12 @@ for ($attempts = 1; $attempts <= 5; ++$attempts) {
 	last if $sock;
 }
 
-die "admin,Cannot connect to $host:$port after 5 attempts $!" unless $sock;
-say "admin,connected" if $dbg;
+die "ADMIN,Cannot connect to $host:$port after 5 attempts $!\n" unless $sock;
+say "ADMIN,connected" if $dbg;
+$sock->timeout(0);
+
 print $sock "$mycall\r\n";
-say "admin,call sent" if $dbg;
+say "ADMIN,call $mycall sent" if $dbg;
 
 my %d;
 my %spot;
@@ -68,41 +90,17 @@ my $nospot = 0;
 while (<$sock>) {
 	chomp;
 	my $tim = time;
-	
-	# periodic clearing out of the two caches
-	if ($tim % 60 == 0 && $last != $tim) {
-		my $count = 0;
-		my $removed = 0;
-		
-		while (my ($k,$v) = each %d) {
-			if ($tim-$v > 60) {
-				delete $d{$k};
-				++$removed
-			} else {
-				++$count;
-			}
-		}
-		say "admin,rbn cache: $removed removed $count remain" if $dbg;
-		$count = $removed = 0;
-		while (my ($k,$v) = each %spot) {
-			if ($tim-$v > $minspottime*2) {
-				delete $spot{$k};
-				++$removed;
-			} else {
-				++$count;
-			}
-		}
-		say "admin,spot cache: $removed removed $count remain" if $dbg;
 
-		say join(',', "STAT", $noraw, $norbn, $nospot) if $showstats;
-		$noraw = $norbn = $nospot = 0;
+	# parse line
+	say "RAW,$_" if $wantraw;
 
-		$last = $tim;
+	if (/call:/) {
+		print $sock "$mycall\r\n";
+		say "ADMIN,call $mycall sent" if $dbg;
 	}
 
-	# parse line
-	my (undef, undef, $origin, $qrg, $call, $mode, $s, $m, $spd, $u, $sort, $t) = split /[:\s]+/;
-	if ($t) {
+	my (undef, undef, $origin, $qrg, $call, $mode, $s, $m, $spd, $u, $sort, $t, $tx) = split /[:\s]+/;
+	if ($t || $tx) {
 
 		# We have an RBN data line, dedupe it very simply on time, ignore QRG completely.
 		# This works because the skimmers are NTP controlled (or should be) and will receive
@@ -111,11 +109,21 @@ while (<$sock>) {
 		++$noraw;
 		next if $d{$p};
 
+		# fix up times for things like 'NXDXF B' etc
+		if ($tx && $t != /^\d{4}Z$/) {
+			if ($tx =~ /^\d{4}Z$/) {
+				$t = $tx;
+			} else {
+				say "ERR,$_";
+				next;
+			}
+		}
+
 		# new RBN input
 		$d{$p} = $tim;
 		++$norbn;
 		$qrg = sprintf('%.1f', nearest(.1, $qrg));     # to nearest 100Hz (to catch the odd multiple decpl QRG [eg '7002.07']).
-		say join(',', "RBN", $origin, $qrg, $call, $mode, $s, $m, $spd, $u, $sort, $t) if $dbg;
+		say join(',', "RBN", $origin, $qrg, $call, $mode, $s, $m, $spd, $u, $sort, $t) if !$wantraw && ($dbg || $showrbn);
 
 		# Determine whether to "SPOT" it based on whether we have not seen it before (near this QRG) or,
 		# if we have, has it been a "while" since the last time we spotted it? If it has been spotted
@@ -124,13 +132,16 @@ while (<$sock>) {
 		my $sp = "$call|$nqrg";		  # hopefully the skimmers will be calibrated at least this well! 
 		my $ts = $spot{$sp};
 		
-		if (!$ts || $tim - $ts >= $minspottime) {
+		if (!$ts || ($minspottime > 0 && $tim - $ts >= $minspottime)) {
 			if ($wantbeacon && $sort =~ /^BEA/) {
 				;
 			} else {
-				next if !$wantcw  && $mode =~ /^CW/;
-				next if !$wantrtty && $mode =~ /^RTTY/;
-				next if !$wantpsk && $mode =~ /^PSK/;
+				# Haven't used a perl 'goto' like this ever!
+				# Clearly I need to use an event driven framework :-) 
+				goto periodic if !$wantcw  && $mode =~ /^CW/;
+				goto periodic if !$wantrtty && $mode =~ /^RTTY/;
+				goto periodic if !$wantpsk && $mode =~ /^PSK/;
+				goto periodic if !$wantdx && $mode =~ /^DX/;
 			}
 
 			++$nospot;
@@ -139,10 +150,130 @@ while (<$sock>) {
 			$spot{$sp} = $tim;
 		}
 	} else {
-		say "data,$_" if $dbg;
+		say "DATA,$_" if $dbg && !$wantraw;
+	}
+
+ periodic:
+	# periodic clearing out of the two caches
+	if (($tim % 60 == 0 && $tim > $last) || ($last && $tim >= $last + 60)) {
+		my $count = 0;
+		my $removed = 0;
+		
+		while (my ($k,$v) = each %d) {
+			if ($tim-$v > 60) {
+				delete $d{$k};
+				++$removed
+			} else {
+				++$count;
+			}
+		}
+		say "ADMIN,rbn cache: $removed removed $count remain" if $dbg;
+		$count = $removed = 0;
+		while (my ($k,$v) = each %spot) {
+			if ($tim-$v > $minspottime*2) {
+				delete $spot{$k};
+				++$removed;
+			} else {
+				++$count;
+			}
+		}
+		say "ADMIN,spot cache: $removed removed $count remain" if $dbg;
+
+		say join(',', "STAT", $noraw, $norbn, $nospot) if $showstats;
+		$noraw = $norbn = $nospot = 0;
+
+		$last = int($tim / 60) * 60;
 	}
 }
 
 
 close $sock;
 exit 0;
+
+__END__
+
+=head1 NAME
+
+rbn.pl - an experimental RBN filter program that
+
+=head1 SYNOPSIS
+
+rbn.pl [options] <your callsign> 
+
+=head1 OPTIONS
+
+=over 8
+
+=item B<-help>
+
+Print a brief help message and exits.
+
+=item B<-man>
+
+Prints the manual page and exits.
+
+=item B<-host>=telnet.reversebeacon.net 
+
+As default, this program will connect to C<telnet.reversebeacon.net>. Use this argument to change that.
+
+=item B<-port>=7000
+
+As default, this program will connect to port 7000. Use this argument to change that to some other port.
+
+=item B<-want>=cw,rtty,psk,beacon,dx
+
+The program will print all spots in all classes in the 'mode/calling' column [cw, rtty, psk, beacon, dx]. You can choose one or more of
+these classes if you want specific types of spots.
+
+=item B<-stats>
+
+Print a comma separated line of statistics once a minute which consists of:
+
+STAT,E<lt>raw RBN spotsE<gt>,E<lt>de-duped RBN spotsE<gt>,E<lt>new spotsE<gt>
+
+=item B<-repeattime=60>
+
+A cache of callsigns and QRGs is kept. If a SPOT comes in after B<repeattime> minutes then it re-emitted
+but with a RESPOT tag instead. Set this argument to 0 (or less) if you do not want any repeats. 
+
+=item B<-rbn>
+
+Show the de-duplicated RBN lines as they come in.
+
+=item B<-raw>
+
+Show the raw RBN lines as they come in.
+
+=back
+
+=head1 DESCRIPTION
+
+B<This program> connects (as default) to RBN C<telnet.reversebeacon.net:7000> and parses the raw output
+which it deduplicates and then outputs unique spots. It is possible to select one or more types of spot. 
+
+The output is the RBN spot line which has been separated out into a comma separated list. One line per spot.
+
+Like this:
+
+  SPOT,DK3UA-#,3560.0,DL6ZB,CW,27,dB,26,WPM,CQ,2152Z
+  SPOT,WB6BEE-#,14063.0,KD6SX,CW,24,dB,15,WPM,CQ,2152Z
+  RESPOT,S50ARX-#,1811.5,OM0CS,CW,37,dB,19,WPM,CQ,2152Z
+  SPOT,DF4UE-#,3505.0,TA1PT,CW,11,dB,23,WPM,CQ,2152Z
+  SPOT,AA4VV-#,14031.0,TF3Y,CW,16,dB,22,WPM,CQ,2152Z
+  SPOT,SK3W-#,3600.0,OK0EN,CW,13,dB,11,WPM,BEACON,2152Z
+  STAT,263,64,27
+
+If the -raw flag is set then these lines will be interspersed with the raw line from the RBN source, prefixed 
+with "RAW,". For example:
+
+  RAW,DX de PJ2A-#:    14025.4  IP0TRC         CW    16 dB  31 WPM  CQ      1307Z
+  RAW,DX de PJ2A-#:    10118.9  K1JD           CW     2 dB  28 WPM  CQ      1307Z
+  RAW,DX de K2PO-#:     1823.4  HL5IV          CW     8 dB  22 WPM  CQ      1307Z
+  SPOT,K2PO-#,1823.4,HL5IV,CW,8,dB,22,WPM,CQ,1307Z
+  RAW,DX de LZ7AA-#:   14036.6  HA8GZ          CW     7 dB  27 WPM  CQ      1307Z
+  RAW,DX de DF4UE-#:   14012.0  R7KM           CW    32 dB  33 WPM  CQ      1307Z
+  RAW,DX de G7SOZ-#:   14012.2  R7KM           CW    17 dB  31 WPM  CQ      1307Z
+
+
+=cut
+