#!/usr/bin/perl
# This Source Code Form is subject to the terms of the Mozilla Public
# License, v. 2.0. If a copy of the MPL was not distributed with this
# file, You can obtain one at http://mozilla.org/MPL/2.0/.
#
# This Source Code Form is "Incompatible With Secondary Licenses", as
# defined by the Mozilla Public License, v. 2.0.

use 5.10.1;
use strict;
use warnings;

use File::Basename;
use File::Spec;
BEGIN {
    require lib;
    my $dir = File::Spec->rel2abs(File::Spec->catdir(dirname(__FILE__), '..'));
    lib->import($dir, File::Spec->catdir($dir, 'lib'), File::Spec->catdir($dir, qw(local lib perl5)));
}

use Bugzilla::DaemonControl qw(catch_signal);
use Future;
use IO::Async::Loop;
use IO::Async::Protocol::LineStream;
use IO::Handle;

$ENV{LOGGING_PORT} //= 5880;

STDOUT->autoflush(1);

my $loop = IO::Async::Loop->new;
my $on_stream = sub {
    my ($stream) = @_;
    my $protocol = IO::Async::Protocol::LineStream->new(
        transport    => $stream,
        on_read_line => sub {
            my ( $self, $line ) = @_;
            say $line;
        },
    );
    $loop->add($protocol);
};
my @signals = qw( TERM INT KILL );

$loop->listen(
    host      => '127.0.0.1',
    service   => $ENV{LOGGING_PORT},
    socktype  => 'stream',
    on_stream => $on_stream,
)->get;

exit Future->wait_any(map { catch_signal($_, 0) } @signals)->get;