inc/mpdPlayer.php

   1 <?php
   2
   3 error_log( "Using MPD backend: ". $c->daemon_type );
   4 class mpdConnection {
   5   var $active;            // Once it actually is...
   6   var $mpd;
   7   var $status;
   8
   9   /**
  10   * Create a minimally initialised connection object
  11   */
  12   function mpdConnection() {
  13     $this->active = false;
  14     $this->mpd = false;
  15     $this->status = array();
  16   }
  17
  18   /**
  19   * Connect to the remote mpd
  20   */
  21   function Connect() {
  22     global $c;
  23
  24     $this->mpd = stream_socket_client($c->mpd['connection'], $errno, $errstr, 2);
  25     $result = fgets($this->mpd, 8192);
  26     $this->active = true;
  27   }
  28
  29   /**
  30   * Do a question/response pair with the daemon
  31   */
  32   function Daemon( $say ) {
  33     if ( ! $this->active ) $this->Connect();
  34
  35     $say .= "\n";
  36     fwrite($this->mpd, $say );
  37
  38     $result = "";
  39     while ( ! feof($this->mpd) ) {
  40       $line = fgets($this->mpd, 8192);
  41       if ( strncmp($line, 'OK', 2) == "0" ) break;
  42       $result .= $line;
  43       if ( strncmp($line, 'ACK', 3) == "0" ) break;
  44     }
  45
  46     return $result;
  47   }
  48
  49   /**
  50   * Query the MPD about it's current status
  51   */
  52   function UpdateStatus() {
  53     $status = split( "\n", $this->Daemon( "status" ) );
  54     foreach( $status AS $k => $v ) {
  55       list( $key, $value ) = preg_split( '/:\s*/', $v, 2);
  56       $this->status[$key] = $value;
  57     }
  58   }
  59
  60
  61   /**
  62   * Play a track.  If the current status is 'stop' then we
  63   * first clear the playlist and after tell mpd to play.
  64   */
  65   function Play( $track ) {
  66     global $c;
  67
  68     $this->UpdateStatus();
  69     $stopped = ( $this->status['state'] == 'stop' );
  70
  71     $track = str_replace( $c->mpd['prefix'], '', $track);
  72
  73     $result = $this->Daemon("add $track");
  74     if ( preg_match( '/ACK.*not found/', $result, $matches ) ) {
  75       $result = $this->Daemon("update $track");
  76       sleep(1);
  77       for( $counter=0; $this->UpdateStatus() && isset($this->status['updating_db']) && $counter++ < 10; sleep(1) );
  78       $result = $this->Daemon("add $track");
  79     }
  80     if ( $stopped ) $this->Daemon( sprintf('play %d', $this->status['playlistlength']) );
  81   }
  82
  83
  84   /**
  85   * Query the MPD about it's current playlist and position
  86   */
  87   function GetCurrent() {
  88     global $c;
  89
  90     $this->UpdateStatus();
  91     $songnow = (object) array();
  92     if ( $this->status['state'] == 'stop' ) return $songnow;
  93
  94     $current = split( "\n", $this->Daemon( "currentsong" ) );
  95     foreach( $current AS $k => $v ) {
  96       list( $key, $value ) = preg_split( '/:\s*/', $v, 2);
  97       if ( $key == 'file' ) {
  98         $songnow->track = $c->mpd['prefix'] . $value;
  99         break;
 100       }
 101     }
 102     if ( $this->status['state'] == 'play' ) {
 103       $seconds_in = preg_replace( '/:.*$/', '', $this->status['time']);
 104       $songnow->started = date( 'Y-m-d H:i:s', time() - $seconds_in );
 105     }
 106     return $songnow;
 107   }
 108
 109   /**
 110   * Query the MPD about it's current playlist and position
 111   */
 112   function GetQueue() {
 113     global $c;
 114
 115     $this->UpdateStatus();
 116     $next = $this->status['song'] + 1;
 117     $this->queue = array();
 118
 119     $filename = "";
 120
 121     $playlist = split( "\n", $this->Daemon( "playlistinfo" ) );
 122     foreach( $playlist AS $k => $v ) {
 123       list( $key, $value ) = preg_split( '/:\s*/', $v, 2);
 124
 125       switch( $key ) {
 126         case 'file':
 127           $filename = $c->mpd['prefix'] . $value;
 128           break;
 129         case 'Pos':
 130           $pos = $value - $next;
 131           if ( $pos >= 0 ) {
 132             $this->queue[$pos] = $filename;
 133           }
 134           break;
 135       }
 136     }
 137
 138     return $this->queue;
 139   }
 140
 141 }
 142
 143 $GLOBALS["mpd"] = new mpdConnection();
 144
 145
 146
 147
 148
 149 /******************************************************************
 150 * The actual API the web interface calls is then very simple...
 151 ******************************************************************/
 152
 153 /**
 154 * Queue a file for playing
 155 */
 156 function daemon_play_track( $path ) {
 157   global $mpd;
 158   error_log("adorno: DBG: Trying to play '$path'");
 159   $mpd->Play( $path );
 160 }
 161
 162
 163 /**
 164 * Get a list of the files currently queued for the future
 165 */
 166 function daemon_get_queue() {
 167   global $mpd;
 168   $q = $mpd->GetQueue();
 169   return $q;
 170 }
 171
 172
 173 /**
 174 * Get the currently playing track and it's starting time
 175 */
 176 function daemon_current_track() {
 177   global $mpd;
 178   return $mpd->GetCurrent();
 179 }
 180
 181
 182 /**
 183 * Get the currently playing track and it's starting time
 184 */
 185 function daemon_other_command( $action, $track ) {
 186   global $mpd;
 187   switch( $action ) {
 188     case 'pause':
 189       $mpd->Daemon($action);
 190       break;
 191     case 'next':
 192       $mpd->Daemon($action);
 193       break;
 194     default:
 195       error_log("adorno: ERROR: Unsupported command '$action'" );
 196   }
 197
 198   return true;
 199 }