X-Git-Url: https://git.draconx.ca/gitweb/mpdhacks.git/blobdiff_plain/e49c1f846176562de0978ba1cd445b50b1094a2d..4fec499ce726a2dad91c05e2cd69566b31d9d15a:/mpdmenu.pl

diff --git a/mpdmenu.pl b/mpdmenu.pl
index 3a84f78..526772a 100755
--- a/mpdmenu.pl
+++ b/mpdmenu.pl
@@ -18,7 +18,6 @@ use Encode::Locale qw(decode_argv);
 decode_argv(Encode::FB_CROAK);
 binmode(STDOUT, ":utf8");
 
-use IO::Socket::INET6;
 use Getopt::Long qw(:config gnu_getopt);
 use Scalar::Util qw(reftype);
 use List::Util qw(any max);
@@ -36,8 +35,6 @@ use constant {
 my $SELF = "$FindBin::Bin/$FindBin::Script";
 
 my $MUSIC = $ENV{MUSIC}    // "/srv/music";
-my $host  = $ENV{MPD_HOST} // "localhost";
-my $port  = $ENV{MPD_PORT} // "6600";
 my $sock;
 
 my ($albumid, $trackid);
@@ -45,14 +42,6 @@ my ($topmenu, $menu);
 my $mode = "top";
 my %artistids;
 
-# Submit a command to the MPD server; each argument to this function
-# is quoted and sent as a single argument to MPD.
-sub mpd_exec {
-	my $cmd = join(' ', map { MPD::escape } @_);
-
-	print $sock "$cmd\n";
-}
-
 sub fvwm_cmd_unquoted {
 	print join(' ', @_), "\n";
 }
@@ -284,7 +273,7 @@ sub get_tracks_by_work_mbid {
 	my $entry;
 
 	foreach my $mbid (@_) {
-		mpd_exec("search", "(MUSICBRAINZ_WORKID == \"$mbid\")");
+		MPD::exec("search", "(MUSICBRAINZ_WORKID == \"$mbid\")");
 		while (<$sock>) {
 			last if (/^OK/);
 			die($_) if (/^ACK/);
@@ -313,13 +302,13 @@ sub get_tracks_by_work_mbid {
 # Currently tracks are considered "related" if their associated recordings
 # have at least one work in common.
 sub get_tracks_by_track_mbid {
-	my ($mbid) = @_;
+	my ($mbid, $tagname) = (@_, "MUSICBRAINZ_RELEASETRACKID");
 	my %source;
 	my %matches;
 	my $entry;
 
 	return \%matches unless ($mbid);
-	mpd_exec("search", "(MUSICBRAINZ_RELEASETRACKID == \"$mbid\")");
+	MPD::exec("search", "(MUSICBRAINZ_RELEASETRACKID == \"$mbid\")");
 	while (<$sock>) {
 		last if (/^OK/);
 		die($_) if (/^ACK/);
@@ -351,7 +340,7 @@ sub get_tracks_by_release_mbid {
 	my $entry;
 
 	return \%matches unless ($mbid);
-	mpd_exec("search", "(MUSICBRAINZ_ALBUMID == \"$mbid\")");
+	MPD::exec("search", "(MUSICBRAINZ_ALBUMID == \"$mbid\")");
 	while (<$sock>) {
 		last if (/^OK/);
 		die($_) if (/^ACK/);
@@ -383,7 +372,7 @@ sub get_releases_by_artist_mbid {
 	my $entry;
 
 	foreach my $mbid (@_) {
-		mpd_exec("search", "(MUSICBRAINZ_ARTISTID == \"$mbid\")");
+		MPD::exec("search", "(MUSICBRAINZ_ARTISTID == \"$mbid\")");
 		while (<$sock>) {
 			last if (/^OK/);
 			die($_) if (/^ACK/);
@@ -409,7 +398,7 @@ sub get_ids_by_filename {
 	my ($file) = @_;
 	my @results = ();
 
-	mpd_exec("playlistfind", "file", $file);
+	MPD::exec("playlistfind", "file", $file);
 	while (<$sock>) {
 		last if (/^OK/);
 		die($_) if (/^ACK/);
@@ -488,8 +477,8 @@ EOF
 }
 
 GetOptions(
-	'host|h=s'    => \$host,
-	'port|p=s'    => \$port,
+	'host|h=s'    => \$MPD::host,
+	'port|p=s'    => \$MPD::port,
 	'menu|m=s'    => \$menu,
 
 	'artist-id=s' => sub { $artistids{$_[1]} = 1; $mode = "artist"; },
@@ -509,21 +498,9 @@ unless (defined $menu) {
 $topmenu //= $menu;
 
 # Connect to MPD.
-$sock = new IO::Socket::INET6(
-	PeerAddr => $host,
-	PeerPort => $port,
-	Proto => 'tcp',
-	Timeout => 2
-) or die("could not open socket: $!.\n");
-binmode($sock, ":utf8");
-
-die("could not connect to MPD: $!.\n")
-	if (!(<$sock> =~ /^OK MPD ([0-9]+)\.([0-9]+)\.([0-9]+)$/));
-
-die("MPD version $1.$2.$3 insufficient.\n")
-	if (  ($1 <  MPD_MJR_MIN)
-	   || ($1 == MPD_MJR_MIN && $2 <  MPD_MNR_MIN)
-	   || ($1 == MPD_MJR_MIN && $2 == MPD_MNR_MIN && $3 < MPD_REV_MIN));
+$sock = MPD::connect();
+die("MPD version $MPD::major.$MPD::minor.$MPD::revision insufficient.")
+	unless MPD::min_version(MPD_MJR_MIN, MPD_MNR_MIN, MPD_REV_MIN);
 
 if ($mode eq "top") {
 	my %current;
@@ -531,7 +508,7 @@ if ($mode eq "top") {
 
 	$menu //= "MenuMPD";
 
-	mpd_exec("status");
+	MPD::exec("status");
 	while (<$sock>) {
 		last if (/^OK/);
 		die($_) if (/^ACK/);
@@ -541,7 +518,7 @@ if ($mode eq "top") {
 		}
 	}
 
-	mpd_exec("currentsong");
+	MPD::exec("currentsong");
 	while (<$sock>) {
 		last if (/^OK/);
 		die($_) if (/^ACK/);