inc/vlcPlayer.php

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