#!/usr/bin/perl -w
use strict;

# run a command and tee its output into the RT log
# for use with rtfm maintainer scripts

use Getopt::Std;
use IPC::Open3;
use IO::Select;
use File::Basename;
use Symbol;
use POSIX ":sys_wait_h";

use lib "/usr/local/share/request-tracker3.8/lib";
use lib "/usr/share/request-tracker3.8/lib";

require RT;

RT::LoadConfig();

my $config = RT->Config;
$config->Set(LogToScreen => 'error');

RT::InitLogging();

my %opts;
getopts('n:', \%opts) or usage();

sub usage {
    print STDERR <<EOF;
Usage: $0 [-n <name>] -- <command> [argument] [...]
EOF
    exit 1;
}


my $cmd = join(" ", @ARGV);

my $cmdname = exists $opts{n} ? $opts{n} : basename $ARGV[0];

$RT::Logger->notice(qq{running $cmd as "$cmdname"\n});

my ($child_out, $child_in, $child_err) = ("","",gensym);
my $pid = open3($child_in, $child_out, $child_err, @ARGV);

my $s = IO::Select->new;
$s->add($child_out);
$s->add($child_err);

while ($s->handles and my @ready = $s->can_read(10)) {
    for my $fh (@ready) {
        my $ret = sysread($fh, my $buf, 1024);
        if (not defined $ret) {
            die("sysread failed: $!");
        }
        if ($ret == 0) {
            $s->remove($fh);
            next;
        }
        print STDERR $buf if $fh eq $child_err;
        print $buf if $fh eq $child_out;

        my $function = ($fh eq $child_err ? "error" : "notice");
        for (split(/\n/, $buf)) {
            s/^\t*/ /;
            $RT::Logger->$function("$cmdname: $_")
        }
    }
}

my $i = 0;
do {
    if (waitpid($pid, WNOHANG) > 0) {
        my $ret = $?;
        exit $ret >> 8;
    }
    sleep 1;
} while ($i++ < 5);

