foo/network-rail-updater
1
0
Fork 0
Code Issues Pull Requests Projects Releases 1 Wiki Activity

logging better

Browse Source
This commit is contained in:
Matthew Slowe 2021-01-24 14:32:02 +00:00
parent d1d0157bc5
commit 415451a8fb
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
update-berths.pl
View File

@ -39,7 +39,7 @@ sub handle($$) {
}; };
if ($data) { if ($data) {
# _debug( "[$topic] " . summary($data) ); _debug( "[$topic] " . summary($data) );
foreach (@{$data}) { foreach (@{$data}) {
process_message($_); process_message($_);
} }
@ -66,13 +66,13 @@ sub process_message($) {
clear_berth($inner{area_id}, $inner{from}); clear_berth($inner{area_id}, $inner{from});
set_berth($inner{area_id}, $inner{to}, $inner{descr}); set_berth($inner{area_id}, $inner{to}, $inner{descr});
# "STEP: $inner{area_id} $inner{to} := $inner{descr} at $inner{time}\n"; _debug( "STEP: $inner{area_id} $inner{to} := $inner{descr} at $inner{time}" );
} elsif($type eq 'CB_MSG') { } elsif($type eq 'CB_MSG') {
clear_berth($inner{area_id}, $inner{from}); clear_berth($inner{area_id}, $inner{from});
# "CLEAR: $inner{area_id} $inner{from} at $inner{time}\n"; _debug( "CLEAR: $inner{area_id} $inner{from} at $inner{time}" );
} elsif($type eq 'CC_MSG') { } elsif($type eq 'CC_MSG') {
set_berth($inner{area_id}, $inner{to}, $inner{descr}); set_berth($inner{area_id}, $inner{to}, $inner{descr});
# "INTERPOSE: $inner{area_id} $inner{to} := $inner{descr} at $inner{time}\n"; _debug( "INTERPOSE: $inner{area_id} $inner{to} := $inner{descr} at $inner{time}" );
} else { } else {
# print "SKIPPING MESSAGE\n"; # print "SKIPPING MESSAGE\n";
} }
@ -112,8 +112,10 @@ $mqtt = Net::MQTT::Simple->new($ENV{MQTT_SERVER}) or die "Failed to connect to m
$mqtt->subscribe( $mqtt->subscribe(
"$ENV{MQTT_MONITOR}" => sub { "$ENV{MQTT_MONITOR}" => sub {
my ($topic, $message) = @_; my ($topic, $message) = @_;
_debug("--> $topic");
handle($topic, $message); handle($topic, $message);
}, },
); );
_debug("Ready to receive messages");
$mqtt->run(); $mqtt->run();