inc/vlcPlayer.php

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