diff options
Diffstat (limited to 'modules/php_musicbrainz/mbWebService.php')
| -rw-r--r-- | modules/php_musicbrainz/mbWebService.php | 189 |
1 files changed, 189 insertions, 0 deletions
diff --git a/modules/php_musicbrainz/mbWebService.php b/modules/php_musicbrainz/mbWebService.php new file mode 100644 index 00000000..8d5a3b09 --- /dev/null +++ b/modules/php_musicbrainz/mbWebService.php @@ -0,0 +1,189 @@ +<?php + interface IWebService { + function get ( $entity, $id, $include, $filter, $version = '1' ); + function post( $entity, $id, $data, $version = '1' ); + } + + class mbWebService implements IWebService { + private $host; + private $port; + private $pathPrefix; + private $lastError; + private $fSock; + private $lastResponse = ""; + private $lastHeaders = array(); + + function mbWebService( $host="musicbrainz.org", $port=80, $pathPrefix="/ws" ) { + $this->host = $host; + $this->port = $port; + $this->pathPrefix = $pathPrefix; + $this->fSock = -1; + } + + function connect() { + $this->fSock = fsockopen( $this->host, $this->port, $errno, $this->lastError, 30 ); + + if ( $this->fSock == false ) { + $this->fSock = -1; + return false; + } + + return true; + } + + function close() { + if ( $this->fSock != -1 ) { + fclose($this->fSock); + $this->fSock = -1; + return true; + } + else { + $this->lastError = "Trying to close closed socket."; + return false; + } + } + + function parseHeaders( $string ) { + $lines = explode( "\n", $string ); + $this->lastHeaders = array(); + + foreach ( $lines as $key => $line ) { + // Status line + if ( $key == 0 ) { + if ( !preg_match( "/^HTTP\/(\d+)\.(\d+) (\d+) .+$/", $line, $matches ) ) { + $this->lastHeader = array(); + return false; + } + else { + $this->lastHeaders['HTTP_major_version'] = $matches[1]; + $this->lastHeaders['HTTP_minor_version'] = $matches[2]; + $this->lastHeaders['HTTP_status'] = $matches[3]; + } + } + // Empty line + else if ( $line == "\r" ) { + $new_string = ""; + for ( $i = $key+1; $i < sizeof($lines); $i++ ) + $new_string .= $lines[$i] . "\n"; + return $new_string; + } + // Not a header + else if ( !preg_match( "/^([^:]+): (.+)\r$/", $line, $matches ) ) { + $this->lastHeaders = array(); + return false; + } + // A header + else + $this->lastHeaders[$matches[1]] = $matches[2]; + } + + $this->lastHeaders = array(); + return false; + } + + function getHeaders() { + return $this->lastHeaders; + } + + function sendRequest( $string, $post_data='' ) { + if ( $this->fSock == -1 ) { + $this->lastError = "Trying to write to closed socket."; + return false; + } + + fwrite( $this->fSock, $string . "\r\n" ); + fwrite( $this->fSock, "Host: " . $this->host . "\r\n" ); + fwrite( $this->fSock, "Accept: */*\r\n" ); + fwrite( $this->fSock, "User-Agent: phpMbQuery\r\n" ); + //fwrite( $this->fSock, "Keep-Alive: 60\r\n" ); + //fwrite( $this->fSock, "Connection: keep-alive\r\n" ); + fwrite( $this->fSock, "Connection: close\r\n\r\n" ); + fwrite( $this->fSock, $post_data . "\r\n\r\n" ); + + return true; + } + + function getResponse() { + if ( $this->fSock == -1 ) { + $this->lastError = "Trying to read from closed socket."; + return false; + } + + $buffer = ""; + + while ( !feof($this->fSock) ) + $buffer .= fread( $this->fSock, 4096 ); + + if ( !$this->parseHeaders($buffer) ) + return $buffer; + + return $this->parseHeaders($buffer); + } + + function get( $entity, $uid, $includes, $filters, $version="1" ) { + $params = array(); + $params['type'] = "xml"; + + if ( is_array($includes) ) { + $inc_string = ""; + foreach ( $includes as $inc ) { + if ( $inc_string != "" ) + $inc_string .= " "; + $inc_string .= $inc; + } + if ( $inc_string != "" ) + $params['inc'] = $inc_string; + } + + if ( is_array($filters) ) { + foreach ( $filters as $filter => $value ) + $params[$filter] = $value; + } + + $URI = $this->pathPrefix . "/" . $version . "/" . $entity . "/" . $uid . "?" . $this->build_query( $params ); + + if ( $this->fSock == -1 && !$this->connect() ) + return false; + + $this->sendRequest( "GET $URI HTTP/1.1" ); + $this->lastResponse = $this->getResponse(); + $this->close(); + + if ( isset($this->lastHeaders['HTTP_status']) && $this->lastHeaders['HTTP_status'] != 200 ) + return false; + + return $this->lastResponse; + } + + function post( $entity, $id, $data, $version = '1' ) { + $URI = $this->pathPrefix . '/' . $version . '/' . $entity . '/' . $id; + if ( $this->fSock == -1 && !$this->connect() ) + return false; + + $this->sendRequest( "POST $URI HTTP/1.1", $data ); + $this->lastResponse = $this->getResponse(); + $this->close(); + + if ( isset($this->lastHeaders['HTTP_status']) && $this->lastHeaders['HTTP_status'] != 200 ) + return false; + + return $this->lastResponse; + } + + function build_query( $array ) { + $first = true; + $query_string = ""; + + if ( !is_array($array) || sizeof($array) == 0 ) + return ""; + + foreach ( $array as $key => $value ) { + $query_string .= ($first?"":"&") . "$key=" . urlencode($value); + if ( $first ) + $first = false; + } + + return $query_string; + } + } +?> |