forked from axiom-team/astrXbian
72 lines
2.1 KiB
PHP
72 lines
2.1 KiB
PHP
<?php
|
|
|
|
chdir('..');
|
|
require_once ("includes/vars.php");
|
|
require_once ("includes/functions.php");
|
|
|
|
class snapcast {
|
|
|
|
private $connection;
|
|
private $ip;
|
|
private $port;
|
|
|
|
public function __construct($ip, $port) {
|
|
$this->port = $port;
|
|
$this->ip = $ip;
|
|
}
|
|
|
|
public function __destruct() {
|
|
$this->close_connection();
|
|
}
|
|
|
|
private function open_connection() {
|
|
if ($this->is_connected()) {
|
|
return true;
|
|
}
|
|
logger::trace("SNAPCAST", "Connecting to ".$this->ip.':'.$this->port);
|
|
$this->connection = @stream_socket_client('tcp://'.$this->ip.':'.$this->port);
|
|
if ($this->is_connected()) {
|
|
stream_set_timeout($this->connection, 65535);
|
|
stream_set_blocking($this->connection, true);
|
|
return true;
|
|
}
|
|
logger::warn("SNAPCAST", "Snapcast connection failed");
|
|
return false;
|
|
}
|
|
|
|
private function close_connection() {
|
|
if ($this->is_connected()) {
|
|
stream_socket_shutdown($this->connection, STREAM_SHUT_RDWR);
|
|
}
|
|
}
|
|
|
|
private function is_connected() {
|
|
return (isset($this->connection) && is_resource($this->connection));
|
|
}
|
|
|
|
public function do_command($json) {
|
|
if ($this->open_connection()) {
|
|
logger::trace("SNAPCAST", "Sending ",$json);
|
|
// For some reason, fputs strips the final } off the string
|
|
fputs($this->connection, $json."}\n", strlen($json)+2);
|
|
$got = fgets($this->connection);
|
|
return $got;
|
|
} else {
|
|
return $this->errorjson('Could not connect to snapcast server');
|
|
}
|
|
$this->close_connection();
|
|
}
|
|
|
|
private function errorjson($msg) {
|
|
$retval = array('error' => $msg);
|
|
return json_encode($retval);
|
|
}
|
|
}
|
|
|
|
$server = new snapcast($prefs['snapcast_server'], $prefs['snapcast_port']);
|
|
$json = file_get_contents("php://input");
|
|
$output = $server->do_command($json);
|
|
logger::debug("SNAPCAST", "Output is",$output);
|
|
header('Content-Type: application/json; charset=utf-8');
|
|
print $output;
|
|
?>
|