signipserver.pl

#!/usr/bin/perl

use strict;
use warnings;
use Fcntl;
use Data::Dumper;
use lib "/opt/led-alpha-sign-msg-server/lib";
use Sign;
use Sign::TextFile;
use Sign::StringFile;
use Sign::MessageUtil qw(mode fancylines lines string flash_text show_time show_day_of_week show_date);
use AnyEvent;
use AnyEvent::HTTPD;
use IO::Socket::INET;

our %alert_status = ();

my @hosts = @ARGV;
my $http_port = 8081;
my @signs = ();
my @fhs = ();
my $fh = "";

die "You didn't give me any ip:port combinations!\n" unless @hosts;

foreach my $fn (@hosts) {
    my ( $host, $port ) = split ":", $fn;

    $fh = IO::Socket::INET->new(
        Proto    => "tcp",
        PeerAddr => $host,
        PeerPort => $port
    )
    or die "can't connect to port $port on $host: $!";
    push @signs, Sign->new($fh,"ip");
    push @fhs, $fh;
}

bootstrap_signs();

run_service($http_port);

for my $fh (@fhs) {
    $fh->close();
}

sub bootstrap_signs {

    foreach my $sign (@signs) {

	$sign->sync_time();

	my %files = ();

	$sign->configure_files(
	    'A' => Sign::TextFile->new(mode("HOLD")),
	);

	$sign->clear_priority_text_file_text();
    }

}

sub update_priority_message {

    my @alerts_to_show = sort keys %alert_status;

    if (@alerts_to_show) {
	foreach my $sign (@signs) {
	    #$sign->set_priority_text_file_text(mode("HOLD"), lines(map { flash_text($_) } @alerts_to_show));
	    $sign->set_priority_text_file_text(mode("HOLD"), lines(map { $_} @alerts_to_show));
	}
    }
    else {
	foreach my $sign (@signs) {
	    $sign->clear_priority_text_file_text();
	}
    }

}

sub run_service {
    my ($http_port) = @_;

    my $httpd = AnyEvent::HTTPD->new(port => $http_port);

    $httpd->reg_cb(
        '' => sub {
            my ($httpd, $req) = @_;

            unless ($req->method eq 'POST') {
                $req->respond([ 405, "Method not allowed", { 'Content-Type' => 'text/plain' }, 'Please POST to me' ]);
                return;
            }

            my $result = handle_request($req);

            if ($result) {
                $req->respond([ 200, "OK", { 'Content-Type' => 'text/plain' }, 'OK' ]);
            }
            else {
                $req->respond([ 500, "Not OK", { 'Content-Type' => 'text/plain' }, 'Not OK' ]);
            }
        },
    );

    $httpd->run;
}

sub handle_request {
    my ($req) = @_;

    my $url = $req->url;

    unless ($url->path eq '/') {
        return 0;
    }

    my %params = $req->vars;
    my $new_active = $params{active};
    my $message = $params{message};

    if ($new_active) {
        $alert_status{$message} = 1;
    }
    else {
        delete $alert_status{$message};
    }

    update_priority_message();

    return 1;
}