File Coverage

blib/lib/App/MPDSync.pm

Criterion	Covered	Total	%
statement	18	65	27.6
branch	0	10	0.0
condition			n/a
subroutine	6	13	46.1
pod	0	6	0.0
total	24	94	25.5

package App::MPDSync;

use strict;
use warnings;
use 5.010;

our $VERSION = '0.02';

use Getopt::Long;
use Net::MPD;
use Proc::Daemon;

sub new {
  my ($class, @options) = @_;

  my $self = bless {
    from    => '',
    to      => 'localhost',
    daemon  => 1,
    verbose => 0,
    source  => undef,
    @options,
  }, $class;
}

sub parse_options {
  my ($self, @args) = @_;

  local @ARGV = @args;

  Getopt::Long::Configure('bundling');
  Getopt::Long::GetOptions(
    'D|daemon!' => \$self->{daemon},
    'V|version' => \&show_version,
    'f|from=s'  => \$self->{from},
    't|to=s'    => \$self->{to},
    'h|help'    => \&show_help,
    'v|verbose' => \$self->{verbose},
  );
}

sub vprint {
  my ($self, @message) = @_;
  say @message if $self->{verbose};
}

sub show_help {
  print <<'HELP';
Usage: mpd-sync [options] --from source [--to dest]

Options:
  -f,--from     Source MPD instance (required)
  -t,--to       Destination MPD instance (default localhost)
  -v,--verbose  Be noisy
  --no-daemon   Do not fork to background
  -V,--version  Show version and exit
  -h,--help     Show this help and exit
HELP

  exit;
}

sub show_version {
  say "mpd-sync (App::MPDSync) version $VERSION";
  exit;
}

sub execute {
  my ($self) = @_;

  local @SIG{qw{ INT TERM HUP }} = sub {
    exit 0;
  };

  unless ($self->{from}) {
    say STDERR 'Source MPD not provided';
    show_help;
  }

  my $source = Net::MPD->connect($self->{from});

  if ($self->{daemon}) {
    $self->vprint('Forking to background');
    Proc::Daemon::Init;
  }

  {
    $self->vprint('Syncrhonizing initial playlist');

    my $dest = Net::MPD->connect($self->{to});
    $dest->stop;
    $dest->clear;
    $dest->add($_->{uri}) for $source->playlist_info;

    $source->update_status;
    $dest->play;
    $dest->seek($source->song, int $source->elapsed);
  }

  while (1) {
    $source->idle('playlist');

    $self->vprint('Source playlist changed');

    $source->update_status;
    my @playlist = $source->playlist_info;

    my $dest = Net::MPD->connect($self->{to});
    foreach my $item ($dest->playlist_info) {
      if (@playlist) {
        if ($item->{uri} eq $playlist[0]{uri}) {
          shift @playlist;
        } else {
          $self->vprint("Removing $item->{uri} from destination playlist");
          $dest->delete_id($item->{Id});
        }
      } else {
        $self->vprint('Out of entries from source!');
      }
    }

    foreach (@playlist) {
      $self->vprint("Adding $_->{uri} to destination");
      $dest->add($_->{uri});
    }
  }
}

1;
__END__