<?php
// Copyright: 2006 Regents of the University of California,
// Partnership for Interdisciplinary Studies of Coastal Oceans
// http://www.piscoweb.org
// 
// This program is free software; you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation; either version 2 of the License, or
// (at your option) any later version.
// 
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU General Public License for more details.
// 
// You should have received a copy of the GNU General Public License
// along with this program; if not, write to the Free Software
// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA
// 02111-1307  USA
class metacatClient {
	
	var $metacatUrl;
	//A file that the server has r/w access to
	var $cookieJar = './cookiejar';
	//Status messages sent back from metacat, getMessages()
	var $messages;

	//Constructor is run when oject is instanciated
	function metacatClient( $url ) {
		$this->metacatUrl = $url;
	}//END Constructor
		
	function login( $username, $password ) {	
		$post_data_array = array (
			'action'	=>	'login',
			'qformat'	=>	'xml',
			'username'	=>	$username,
			'password'	=>	$password
		);
		$response = $this->_request( $post_data_array );
		if(strpos($response, "<login>")) {
			return 1;
		}else{
			return 0;
		}
	}//END login
	
	function logout() {
		$post_data_array = array (
			'action'	=>	'logout',
			'qformat'	=>	'xml',	
		);
		$response = $this->_request( $post_data_array );
		if(strpos($response, "<logout>")) {
			return 1;
		}else{
			return 0;
		}
	}//END logout
	
	function loginAndSetBrowserCookies($username, $password) {
		//There could be multiple people logging in, so more than one cookieJar referenced by username is needed.
		$this->cookieJar = '/tmp/metacatPHPClientCookies/'.$username;
		//Now that the cookieJar has a new path, we can use our standard methods 
		$this->login($username, $password);
		//Set browser cookies from $this->cookieJar using fopen(...path..) or by parsing 
		//$this->getMessages() for metacat's xml response
		//Delete that cookieJar to be safe
		//return true if login == true && rm cookieJar == true
	}
	
	function setCookieJarFromBrowser() {
		//Get session cookie from browser
		//Write it to $this->cookieJar 
	}
		
	function read( $docid ) {
		$post_data_array = array (
			'action'	=>	'read',
			'qformat'	=>	'xml',
			'docid'		=>  $docid
		);
		$response = $this->_request( $post_data_array );
		if(strpos($response, "<error>")) {
			return 0;
		}else{
			return $response;
		}
	}//END read
	
	/**
	 *	Pass a docid without revision, or pisco_data.1.1
	 *	becomes pisco_data.1
	*/
	function getNewestDocId( $docidWithoutRevision ) {
		$pieces = explode(".", $docidWithoutRevision);
		if (count($pieces) > 2) {
			$this->_setMessages("You included the revision number. Changing $docidWithoutRevision to ".$pieces[0].".".$pieces[1]);
		}
		$docidWithoutRevision = $pieces[0].".".$pieces[1];
		$xml = $this->read($docidWithoutRevision);
		if(!$xml) {
			$this->_setMessages('No package with this docId found');
			return false;
		}
		
		$packageIdParser = new PackageIdParser();
		$xml_parser = xml_parser_create();
		xml_set_object($xml_parser,&$packageIdParser); 
		xml_set_element_handler($xml_parser, "startElement", "endElement");
		xml_parse($xml_parser, $xml, true);
		xml_parser_free($xml_parser);
		
		if($packageId = $packageIdParser->packageId) {
			return $packageId;
		}else{
			$this->_setMessages('No packageId found.');
			return false;
		}
	}
	
	function squery( $pathquery_doc ) {
		$post_data_array = array (
			'action'	=>	'squery',
			'qformat'	=>	'xml',
			'query'		=>  $pathquery_doc
		);
		$response = $this->_request( $post_data_array );
		if($response) {
			return $response;
		}else{
			return 0;
		}
	}//END squery

	function insert( $docid, $doctext ) {
		$post_data_array = array (
			'action'	=>	'insert',
			'docid'		=>  $docid,
			'doctext'	=>	$doctext
		);
		$response = $this->_request( $post_data_array );
		if(strpos($response, "<success>")) {
			return 1;
		}else{
			return 0;
		}
	}//END insert
	
	function update( $docid, $doctext ) {
		$post_data_array = array (
			'action'	=>	'update',
			'docid'		=>  $docid,
			'doctext'	=>	$doctext
		);
		$response = $this->_request( $post_data_array );
		if(strpos($response, "<success>")) {
			return 1;
		}else{
			return 0;
		}
	}//END update
	
	function delete( $docid ) {
		$post_data_array = array (
			'action'	=>	'delete',
			'docid'		=>  $docid,
		);
		$response = $this->_request( $post_data_array );
		if(strpos($response, "<success>")) {
			return 1;
		}else{
			return 0;
		}
	}//END delete
	
	function getMessages() {
		return $this->messages;
	}//END getMessages
	
	function _setMessages( $response ) {
		$this->messages .= " \n ".$response;
	}//END _set_messages
	
	function _request( $post_data_array ) {
		$request = curl_init();
		curl_setopt($request, CURLOPT_URL, $this->metacatUrl);
		curl_setopt($request, CURLOPT_COOKIEFILE, $this->cookieJar);
		curl_setopt($request, CURLOPT_COOKIEJAR, $this->cookieJar);
		curl_setopt($request, CURLOPT_POST, true);
		curl_setopt($request, CURLOPT_RETURNTRANSFER, true);
		curl_setopt($request, CURLOPT_USERAGENT, 'PHP metacat client (version 1.0)');
		
		$post_data = $this->_encode_post_data($post_data_array);
		curl_setopt ($request, CURLOPT_POSTFIELDS, $post_data);
		$response = curl_exec($request);
		$this->_setMessages($response);
		return $response;
	}//END _request
	
	function _encode_post_data( $post_data_array ) {
		foreach($post_data_array as $arg => $value) {	
			$post_data_array[$arg] = $arg."=".urlencode($value);
		}
		$post_data = implode('&', $post_data_array);
		return $post_data;
	}//END _encode_post_data
	
		
}

class PackageIdParser {
	var $packageId;
	
	function startElement($parser, $name, $attrs) {
		if($name == "EML:EML") {
			$this->packageId = $attrs['PACKAGEID'];
		}
	}

	function endElement($parser, $name) {
	}
}

?>