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>] [rbn]\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;
my $wantrtty = 1;
my $wantpsk = 1;
my $wantbeacon = 1;
-my $override;
+my $wantdx = 1;
+my $wantraw = 0;
my $showrbn;
-
-while (@ARGV) {
- my $arg = shift;
-
- ++$dbg if $arg =~ /^deb/i;
- ++$showstats if $arg =~ /^stat/i;
- ++$showrbn if $arg =~ /^rbn/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 $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,
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 $!" unless $sock;
+say "ADMIN,connected" if $dbg;
print $sock "$mycall\r\n";
-say "admin,call sent" if $dbg;
+say "ADMIN,call sent" if $dbg;
my %d;
my %spot;
while (<$sock>) {
chomp;
my $tim = time;
-
+
# parse line
- my (undef, undef, $origin, $qrg, $call, $mode, $s, $m, $spd, $u, $sort, $t) = split /[:\s]+/;
- if ($t) {
+ say "RAW,$_" if $wantraw;
+
+ 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
++$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 || $showrbn;
+ 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
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 {
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;
$spot{$sp} = $tim;
}
} else {
- say "data,$_" if $dbg;
+ say "DATA,$_" if $dbg && !$wantraw;
}
periodic:
++$count;
}
}
- say "admin,rbn cache: $removed removed $count remain" if $dbg;
+ say "ADMIN,rbn cache: $removed removed $count remain" if $dbg;
$count = $removed = 0;
while (my ($k,$v) = each %spot) {
if ($tim-$v > $minspottime*2) {
++$count;
}
}
- say "admin,spot cache: $removed removed $count remain" if $dbg;
+ say "ADMIN,spot cache: $removed removed $count remain" if $dbg;
say join(',', "STAT", $noraw, $norbn, $nospot) if $showstats;
$noraw = $norbn = $nospot = 0;
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' 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
+
projects / spider.git / blobdiff