7 use Getopt::Long qw{:config gnu_compat bundling
8 require_order no_getopt_compat};
9 use POSIX qw{:errno_h :fcntl_h :sys_wait_h};
13 (my $PROG = $0) =~ s:^.*/::;
15 sub mumble ($) { print STDERR ";; $_[0]\n" if $DEBUG; }
18 my $file = $CONFFILE // "$ENV{HOME}/.disorder/passwd", my $conf;
20 if (-f $file || defined $CONFFILE)
21 { $conf = load_config $file; }
23 $conf = { connect => ["-unix", "/var/lib/disorder/private/socket"],
24 username => ["root"], password => ["hunoz"] };
26 return connect_to_server %$conf;
33 my $STATE = "off"; # `off', `on', `killed'
34 my $WANT = "off"; # `off', `on', `pause'
41 my $kid = waitpid -1, WNOHANG;
44 mumble "player exited (st = $?)";
45 $PID = undef; $STATE = "off";
46 if ($WANT eq "on" && $RESTARTTIME > $NOW) { $WAKETIME = $RESTARTTIME; }
51 $SIG{TERM} = $SIG{INT} = sub {
52 kill "TERM", $PID if defined $PID;
59 $WAKETIME = $NOW < $RESTARTTIME ? $RESTARTTIME : undef;
64 if ($WANT eq "on") { $WANT = "pause"; $WAKETIME = $NOW + $PAUSETIME; }
69 ##mumble "state = $STATE ($PID)";
70 ##mumble "want = $WANT ($WAKETIME <=> $NOW)";
72 if ($WANT eq "pause" && $NOW >= $WAKETIME) {
73 $WANT = "off"; $WAKETIME = undef;
74 mumble "pause time up: stopping" if $STATE eq "on";
77 if ($WANT eq "on" && $STATE eq "off" &&
78 (!defined($WAKETIME) || $NOW >= $WAKETIME)) {
80 if (!$kid) { exec @ARGV; }
81 $STATE = "on"; $PID = $kid; $RESTARTTIME = $NOW + $CRASHTIME;
82 mumble "player wanted but not running: started pid $kid";
83 } elsif ($WANT eq "off" && $STATE eq "on") {
86 mumble "player running but not wanted: killed pid $PID";
93 my $pause, my $track = 0;
95 my $rdin = ""; vec($rdin, fileno($sk), 1) = 1;
96 my $buffer = "", my @lines = ();
100 my $r = send_command $sk, "playing";
104 fcntl $sk, F_SETFL, (fcntl $sk, F_GETFL, 0) | O_NONBLOCK;
107 if (!$sk) { mumble "eof from server"; last WATCH; }
111 $nfd = select my $rdout = $rdin, undef, undef,
112 defined($WAKETIME) ? $WAKETIME - $NOW : 60;
114 if ($@ && $@->errno == EINTR) { next SEL; }
115 elsif ($@) { mumble "error from select: " . $@->errno; last WATCH; }
118 eval { print $sk "."; flush $sk; };
119 if ($@) { mumble "error from write: " . $@->errno; last WATCH; }
124 eval { $n = sysread $sk, $b, 4096; };
125 if ($@ && $@->errno == EAGAIN) { last READ; }
126 elsif ($@ && $@->errno == EINTR) { next READ; }
127 elsif ($@) { mumble "error from read: " . $@->errno; last WATCH; }
128 elsif (!$n) { close $sk; $sk = undef; last READ; }
129 else { $buffer .= $b; }
132 @lines = split /\n/, $buffer, -1;
133 $buffer = pop @lines;
136 for my $line (@lines) {
137 my @f = split_fields $line;
138 if ($f[1] eq "state") {
139 if ($f[2] eq "pause") { mumble "paused"; $pause = 1; }
140 elsif ($f[2] eq "resume") { mumble "unpaused"; $pause = 0; }
141 } elsif ($f[1] eq "playing") { mumble "track started"; $track = 1; }
142 elsif ($f[1] eq "completed") { mumble "track finished"; $track = 0; }
147 if ($track && !$pause) { start; } else { pause; }
154 print $fh "usage: $PROG [-d] [-u CONFIG] [--] COMMAND ARGS...\n";
161 Command-line options:
162 -h, --help Show this help text
163 -u, --user-config Set user configuration file
169 "h|help" => sub { help; exit 0; },
170 "d|debug" => \$DEBUG,
171 "u|user-config=s" => \$CONFFILE
173 @ARGV > 0 or $bad = 1;
174 if ($bad) { usage *STDERR; exit 2; }
177 eval { watch_status; }; mumble "watcher exited: $@";