source: gutenbach/debian/lib/sipbmp3-filter @ ba06c7f

#!/usr/athena/bin/perl
# Play the data on STDIN as an audio file
#
# $Id: sipbmp3-filter,v 1.16 2008-09-27 09:00:41 root Exp $
# $Source: /tmp/tmp.UFBNno9997/RCS/sipbmp3-filter,v $
#
# TODO
# ----
# Make this structured code. It's a mess.
# Repeat what we just played for EXT files too
# Support HTTP Auth on ogg streams
# License, cleanup and package
#
# Jered Floyd <jered@mit.edu> takes very little credit for this code

use Getopt::Std;

use Image::ExifTool qw(ImageInfo);
use File::Spec::Functions;
use LWP::UserAgent;
use Data::Dumper;

my $ua = new LWP::UserAgent;

close(STDERR);
open(STDERR, ">>", "/tmp/sipbmp3.log") or warn "Couldn't open log: $!";

$ENV{"TERM"}="vt100";

print STDERR "STDERR FROM SPOOL FILTER\n";

# set real uid to be effective uid
$< = $>;

# Select the correct output device and set the volume
#system("amixer -q set Headphone 100\% unmute");

# The command line we get from lpd is (no spaces between options and args):
#  -C lpr -C class
#  -A LPRng internal identifier
#  -H originating host
#  -J lpr -J jobname (default: list of files)
#  -L lpr -U username
#  -P logname
#  -Q queuename (lpr -Q)
#  -Z random user-specified options
#  -a printcap af (accounting file name)
#  -d printcap sd entry (spool dir)
#  -e print job data file name (currently being processed)
#  -h print job originiating host (same as -H)
#  -j job number in spool queue
#  -k print job control file name
#  -l printcap pl (page length)
#  -n user name (same as -L)
#  -s printcap sf (status file)
#  -w printcap pw (page width)
#  -x printcap px (page x dimension)
#  -y printcap py (page y dimension)
# accounting file name

# All the filter_options from lpd
getopt('ACFHJLPQRZacdefhijklnprswxy', \%opts);

# Status messages at start of playback
open(ZEPHYR, '|/usr/athena/bin/zwrite -d -n -c sipb-auto -i ' .
  'sipbmp3@zsr -s "SIPB LPR music spooler"');
print(ZEPHYR "User $opts{'n'} on host $opts{'H'} is playing:\n");

# So, the file we're currently processing is "-d/-e".

# Read the metadata information from the file.
my ($filepath) = catfile($opts{'d'}, $opts{'e'});
my ($fileinfo) = ImageInfo($filepath);
my ($magic) = $fileinfo->{FileType};

if ($magic) {
    printf(ZEPHYR "A file of type %s.", $magic);
    foreach my $key (sort keys %$fileinfo) {
        printf(ZEPHYR "%s: %s\n", $key, $fileinfo->{$key});
    }
}
elsif (-T $filepath) {
    $filepath = resolve_external_reference($filepath, \%opts);
}
close(ZEPHYR);
play_mplayer_audio($filepath, \%opts);

# Play an external stream reference
sub resolve_external_reference {
    # Retrieve those command line opts.
    my ($filepath, $opts) = @_;

    my $format, $uri, $userpass;

    if (<STDIN> =~ /^(\S+)/) {
        $uri=$1;

        my $response = $ua->head($uri);
        
        $contenttype=($response->content_type() or "unknown");
        
        if ($contenttype eq "audio/mpeg") { $format="MP3" }
        elsif ($contenttype eq "application/x-ogg") { $format="OGG" }
        elsif ($contenttype eq "application/ogg") { $format="OGG" }
        elsif ($contenttype eq "audio/x-scpls") { $format="SHOUTCAST" }
        else {
            print ZEPHYR
                "Unknown Content-Type $contenttype for URI $uri\n";
            close(ZEPHYR);
        }
    } else {
        print ZEPHYR "Couldn't read URI for external reference\n";
        close(ZEPHYR);
        return $filepath;
    }

    if ($format eq "SHOUTCAST") {
        print ZEPHYR "Shoutcast playlist...\n";
        #Don't close ZEPHYR yet, will print the name of the stream if available
        return &get_shoutcast($uri);
    } elsif ($format eq "MP3") {
    } elsif ($format eq "OGG") {
    } else {
      print ZEPHYR "Unrecognized stream format: $format\n";
    }
    return $uri;
}

# Process a Shoutcast playlist
# get_shoutcast(URI)
sub get_shoutcast {
  my $uri = shift(@_);
  
  my $response = $ua->get($uri);

  foreach (split("\n", $response->content())) {
      if (/^File\d+=(\S+)/) {
          push(@uris, $1);
      }
      if (/^Title\d+=(.+)$/) {
          push(@titles, $1);
      }
  }
  
  # choose a random server
  $server = int(rand scalar(@uris));
  # print the name of the stream if available
  print ZEPHYR "$titles[$server]\n";
  return $uris[$server];
}

sub play_mplayer_audio {
    my ($filepath, $opts) = @_;

    # Prepare to write status:
    open(ZEPHYR, '|/usr/athena/bin/zwrite -d -n -c sipb-auto -i ' .
         'sipbmp3@zsr -s "SIPB LPR music spooler"');
    
    # fork for mpg123
    my $pid = open(MP3STATUS, "-|");
    unless (defined $pid) {
        print ZEPHYR "Couldn't fork: $!\n";
        close(ZEPHYR);
        return;
    }
    
    if ($pid) { #parent
        # Check if there were any errors
        if ($_ = <MP3STATUS>) {
            print ZEPHYR "Playback completed with the following errors:\n";
            print ZEPHYR $_;
            while (<MP3STATUS>) {
                print ZEPHYR $_;
            }
        } else {
            print ZEPHYR "Playback completed successfully.\n";
        }
        close(MP3STATUS) || print ZEPHYR "mplayer exited $?\n";
        
        close(ZEPHYR);
    }
  else { # child
      # redirect STDERR to STDOUT
      open STDERR, '>&STDOUT';
      # make sure that mplayer doesn't try to intepret the file as keyboard input
      close(STDIN);
      open(STDIN, "/dev/null");
      #print STDERR Dumper([qw|/usr/bin/mplayer -nolirc -ao alsa -quiet|, $filepath]);
      exec(qw|/usr/bin/mplayer -nolirc -ao alsa -quiet|, $filepath) ||
          die "Couldn't exec";
  }
}

# ID3 comments often have useless crap because tools like iTunes were
# written by drooling idiots
sub filter_comment {
  my $comment = shift(@_);

  if ($comment =~ /^engiTunes_CDDB/) {
    return undef;
  }
  return $comment;
}