chiark / gitweb /
3c570734a10df8d1658adb06a082992d1c934ed9
[profile] / bin / disorder-notify
1 #! /usr/bin/perl -w
2
3 use autodie qw{:all};
4 use strict;
5
6 use DisOrder;
7 use File::FcntlLock;
8 use POSIX qw{:errno_h :fcntl_h};
9
10 ###--------------------------------------------------------------------------
11 ### Configuration.
12
13 my %C = (config => "$ENV{HOME}/.disorder/passwd",
14          lockdir => "$ENV{HOME}/.disorder/",
15          mixer => "Master,0");
16
17 my $TITLE = "DisOrder";
18 my $VARIANT = "default";
19 if (-l $C{config} && (my $t = readlink $C{config}) =~ /^passwd\.(.*)$/)
20   { $VARIANT = $1; $TITLE .= " ($1)"; }
21
22 ###--------------------------------------------------------------------------
23 ### Random utilities.
24
25 sub run_discard_output (@) {
26   my $kid = fork();
27   if (!$kid) {
28     open STDOUT, ">/dev/null" or die "open /dev/null: $!";
29     exec @_;
30   }
31   waitpid $kid, 0;
32   if ($?) {
33     my $st;
34     if ($? >= 256) { $st = sprintf "rc = %d", $? >> 8; }
35     else { $st = sprintf "signal %d", $?; }
36     die "$_[0] failed ($st)";
37   }
38 }
39
40 sub notify ($$) {
41   my ($head, $body) = @_;
42
43   $body =~ s:\&:&:g;
44   $body =~ s:\<:&lt;:g;
45   $body =~ s:\>:&gt;:g;
46
47   ##print "****************\n$head\n\n$body\n"; return;
48
49   run_discard_output "notify-send",
50     "-c", "DisOrder", "-i", "audio-volume-high", "-t", "5000",
51     $head, $body;
52 }
53
54 sub try_unlink ($) {
55   my ($f) = @_;
56   eval { unlink $f; };
57   die $@ if $@ and $@->errno != ENOENT;
58 }
59
60 ###--------------------------------------------------------------------------
61 ### Locking protocol.
62
63 my $LKFILE = "$C{lockdir}/disorder-notify-$VARIANT.lock";
64 my $LKFH;
65
66 sub locked_by () {
67
68   ## Try to open the lock file.  If it's not there, then obviously it's not
69   ## locked.
70   my $fh;
71   eval { open $fh, "<", $LKFILE; };
72   if ($@) {
73     return undef if $@->errno == ENOENT;
74     die $@;
75   }
76
77   ## Take out a non-exclusive lock on the lock file.
78   my $lk = new File::FcntlLock;
79   $lk->l_type(F_RDLCK); $lk->l_whence(SEEK_SET);
80   $lk->l_start(0); $lk->l_len(0);
81   if ($lk->lock($fh, F_SETLK)) { close $fh; return undef; }
82
83   ## Read the pid of the current lock-holder.
84   chomp (my $pid = (readline $fh) // "<unknown>");
85   close $fh;
86   return $pid;
87 }
88
89 sub claim_lock () {
90   sysopen my $fh, $LKFILE, O_CREAT | O_WRONLY;
91
92   my $lk = new File::FcntlLock;
93   $lk->l_type(F_WRLCK); $lk->l_whence(SEEK_SET);
94   $lk->l_start(0); $lk->l_len(0);
95   if (!$lk->lock($fh, F_SETLK)) {
96     return undef if $! == EAGAIN;
97     die "failed to lock `$LKFILE': $!";
98   }
99
100   truncate $fh, 0;
101   print $fh "$$\n";
102   flush $fh;
103   $LKFH = $fh;
104   1;
105 }
106
107 ###--------------------------------------------------------------------------
108 ### DisOrder utilities.
109
110 sub get_state0 ($) {
111   my ($sk) = @_;
112   my %st = ();
113
114   LINE: for (;;) {
115     my @f = split_fields readline $sk;
116     if ($f[1] ne "state") { last LINE; }
117     elsif ($f[2] eq "enable_random") { $st{random} = 1; }
118     elsif ($f[2] eq "disable_random") { $st{random} = 0; }
119     elsif ($f[2] eq "enable_play") { $st{play} = 1; }
120     elsif ($f[2] eq "disable_play") { $st{play} = 0; }
121     elsif ($f[2] eq "resume") { $st{pause} = 0; }
122     elsif ($f[2] eq "pause") { $st{pause} = 1; }
123   }
124   return \%st;
125 }
126
127 sub get_state () {
128   my $sk = connect_to_server $C{config};
129   send_command0 $sk, "log";
130   my $st = get_state0 $sk;
131   close $sk;
132   return $st;
133 }
134
135 sub decode_track_name ($\%) {
136   my ($sk, $info) = @_;
137   return unless exists $info->{track};
138   my $track = $info->{track};
139   for my $i ("artist", "album", "title") {
140     my @f = split_fields send_command $sk, "part", $track, "display", "$i";
141     $info->{$i} = $f[0];
142   }
143 }
144
145 sub fmt_duration ($) {
146   my ($n) = @_;
147   return sprintf "%d:%02d", int $n/60, $n%60;
148 }
149
150 sub format_now_playing (\%) {
151   my ($info) = @_;
152   exists $info->{track} or return "Nothing.";
153   my $r = "$info->{artist}: ‘$info->{title}’";
154   $r .= ", from ‘$info->{album}’" if $info->{album};
155   exists $info->{sofar} && exists $info->{length} and
156     $r .= sprintf " (%s/%s)",
157       fmt_duration $info->{sofar}, fmt_duration $info->{length};
158   $r .= "\n(chosen by $info->{submitter})" if exists $info->{submitter};
159   return $r;
160 }
161
162 sub get_now_playing ($) {
163   my ($sk) = @_;
164   my $r = send_command $sk, "playing";
165   defined $r or return {};
166   my %info = split_fields $r;
167   decode_track_name $sk, %info;
168   exists $info{sofar} and
169     $info{length} = send_command $sk, "length", $info{track};
170   return \%info;
171 }
172
173 sub watch_and_notify0 ($) {
174   my ($now_playing) = @_;
175
176   my $sk = connect_to_server $C{config}, 1;
177   my $sk_log = connect_to_server $C{config}, 1;
178
179   send_command0 $sk_log, "log";
180   my $st = get_state0 $sk_log;
181   my $msg = "playing " . ($st->{play} ? "enabled" : "disabled");
182   $msg .= "; random play " . ($st->{random} ? "enabled" : "disabled");
183   $msg .= "; " . ($st->{pause} ? "paused" : "playing");
184   notify "$TITLE state", "Connected: $msg";
185   if ($st->{play} && $now_playing) {
186     my $info = get_now_playing $sk;
187     notify "$TITLE: Now playing", format_now_playing %$info;
188   }
189
190   fcntl $sk_log, F_SETFL, (fcntl $sk_log, F_GETFL, 0) | O_NONBLOCK;
191   my $buffer = "";
192   my @lines = ();
193   my $rdin = ""; vec($rdin, (fileno $sk_log), 1) = 1;
194
195   WATCH: for (;;) {
196     for my $line (@lines) {
197       my @f = split_fields $line;
198       if ($f[1] eq "state") {
199         my $msg = undef;
200         if ($f[2] eq "disable_random") { $msg = "Random play disabled"; }
201         elsif ($f[2] eq "enable_random") { $msg = "Random play enabled"; }
202         elsif ($f[2] eq "disable_play") { $msg = "Playing disabled"; }
203         elsif ($f[2] eq "enable_play") { $msg = "Playing enabled"; }
204         elsif ($f[2] eq "pause") { $msg = "Paused"; }
205         elsif ($f[2] eq "resume") { $msg = "Playing"; }
206         notify "$TITLE state", $msg if defined $msg;
207       } elsif ($f[1] eq "playing") {
208         my %info;
209         $info{track} = $f[2];
210         $info{submitter} = $f[3] if @f > 3;
211         decode_track_name $sk, %info;
212         notify "$TITLE: Now playing", format_now_playing %info;
213       } elsif ($f[1] eq "scratched") {
214         my %info;
215         $info{track} = $f[2];
216         decode_track_name $sk, %info;
217         notify "$TITLE: Scratched by $f[3]", format_now_playing %info;
218       }
219     }
220
221     last WATCH unless $sk_log;
222     select my $rdout = $rdin, undef, undef, undef;
223     READ: for (;;) {
224       my ($b, $n);
225       eval { $n = sysread $sk_log, $b, 4096; };
226       if ($@ && $@->errno == EAGAIN) { last READ; }
227       elsif ($@) { die $@; }
228       elsif (!$n) { close $sk_log; $sk_log = undef; }
229       else { $buffer .= $b; }
230     }
231
232     @lines = split /\n/, $buffer, -1;
233     $buffer = pop @lines;
234   }
235
236   notify "$TITLE state", "Lost connection";
237
238   close $sk;
239   close $sk_log if defined $sk_log;
240 }
241
242 sub watch_and_notify ($) {
243   my ($now_playing) = @_;
244
245   claim_lock or exit 1;
246
247   for (;;) {
248     eval { watch_and_notify0 $now_playing; };
249     $now_playing = 1;
250     sleep 5;
251   }
252 }
253
254 ###--------------------------------------------------------------------------
255 ### User-facing operations.
256
257 my %OP;
258
259 $OP{"volume-up"} =
260   sub { run_discard_output "amixer", "sset", $C{mixer}, "5\%+"; };
261 $OP{"volume-down"} =
262   sub { run_discard_output "amixer", "sset", $C{mixer}, "5\%-"; };
263
264 $OP{"scratch"} = sub {
265   my $sk = connect_to_server $C{config};
266   send_command $sk, "scratch";
267   close $sk;
268 };
269
270 $OP{"enable/disable"} = sub {
271   my $st = get_state;
272   my $sk = connect_to_server $C{config};
273   if ($st->{play}) { send_command $sk, "disable"; }
274   else { send_command $sk, "enable"; }
275   close $sk;
276 };
277
278 $OP{"play/pause"} = sub {
279   my $st = get_state;
280   my $sk = connect_to_server $C{config};
281   if (!$st->{play}) {
282     send_command $sk, "enable";
283     if ($st->{pause}) { send_command $sk, "resume"; }
284   } else {
285     if ($st->{pause}) { send_command $sk, "resume"; }
286     else { send_command $sk, "pause"; }
287   }
288   close $sk;
289 };
290
291 $OP{"watch"} = sub {
292   if (defined (my $lkpid = locked_by)) {
293     print STDERR "$0: already watched by pid $lkpid\n";
294     exit 2;
295   }
296   watch_and_notify 1;
297 };
298
299 $OP{"now-playing"} = sub {
300   my $sk = connect_to_server $C{config};
301   my $info = get_now_playing $sk;
302   close $sk;
303   print format_now_playing %$info;
304   print "\n";
305 };
306
307 $OP{"notify-now-playing"} = sub {
308   my $sk = connect_to_server $C{config};
309   my $info = get_now_playing $sk;
310   close $sk;
311   notify "$TITLE: Now playing", format_now_playing %$info;
312   unless (defined locked_by) {
313     fork and exit 0;
314     watch_and_notify 0;
315   }
316 };
317
318 $OP{"next-config"} = sub {
319   (my $dir = $C{config}) =~ s:/[^/]*$::;
320   my (@conf, $curr, $conf, $min);
321
322   if (-l $C{config} && (my $t = readlink $C{config}) =~ /^passwd\.(.*)$/)
323     { $curr = $1; }
324
325   opendir my $dh, +$dir;
326   FILE: while (my $f = readdir $dh)
327     { push @conf, $1 if $f =~ /^passwd\.(.*[^~])$/; }
328
329   for (my $i = 0; $i < @conf; $i++) {
330     $min = $conf[$i] if (!defined $min) || $conf[$i] lt $min;
331     $conf = $conf[$i]
332       if ((!defined $curr) || $curr lt $conf[$i]) &&
333          ((!defined $conf) || $conf[$i] lt $conf);
334   }
335   $conf = $min unless defined $conf;
336
337   try_unlink "$dir/passwd.new";
338   symlink "passwd.$conf", "$dir/passwd.new";
339   rename "$dir/passwd.new", "$dir/passwd";
340   notify "DisOrder configuration", "Switched to `$conf'";
341 };
342
343 ###--------------------------------------------------------------------------
344 ### Main program.
345
346 if (@ARGV != 1) { print STDERR "usage: $0 OP\n"; exit 2; }
347 my $op = $ARGV[0];
348 if (!exists $OP{$op}) { print STDERR "$0: unknown op `$op'\n"; exit 2; }
349 $OP{$op}();
350
351 ###----- That's all, folks --------------------------------------------------