Session.php

<?php 

namespace BaseXClient;

/*
 * PHP client for BaseX.
* Works with BaseX 7.0 and later
*
* Documentation: http://docs.basex.org/wiki/Clients
*
* (C) BaseX Team 2005-12, BSD License
*/
class Session {
	/* Class variables.*/
	var $socket, $info, $buffer, $bpos, $bsize;

	/* see readme.txt */
	function __construct($h, $p, $user, $pw) {
		// create server connection
		$this->socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
		if(!@socket_connect($this->socket, $h, $p)) {
			throw new \Exception("Can't communicate with server.");
		}

		// receive timestamp
		$ts = $this->readString();

		// send username and hashed password/timestamp
		$md5 = hash("md5", hash("md5", $pw).$ts);
		socket_write($this->socket, $user.chr(0).$md5.chr(0));

		// receives success flag
		if(socket_read($this->socket, 1) != chr(0)) {
			throw new \Exception("Access denied.");
		}
	}

	/* see readme.txt */
	public function execute($com) {
		// send command to server
		socket_write($this->socket, $com.chr(0));

		// receive result
		$result = $this->receive();
		$this->info = $this->readString();
		if($this->ok() != True) {
			throw new \Exception($this->info);
		}
		return $result;
	}

	/* Returns the query object.*/
	public function query($q) {
		return new Query($this, $q);
	}

	/* see readme.txt */
	public function create($name, $input) {
		$this->sendCmd(8, $path, $input);
	}

	/* see readme.txt */
	public function add($path, $input) {
		$this->sendCmd(9, $path, $input);
	}

	/* see readme.txt */
	public function replace($path, $input) {
		$this->sendCmd(12, $path, $input);
	}

	/* see readme.txt */
	public function store($path, $input) {
		$this->sendCmd(13, $path, $input);
	}

	/* see readme.txt */
	public function info() {
		return $this->info;
	}

	/* see readme.txt */
	public function close() {
		socket_write($this->socket, "exit".chr(0));
		socket_close($this->socket);
	}

	/* Initializes the byte transfer */
	private function init() {
		$this->bpos = 0;
		$this->bsize = 0;
	}

	/* Receives a string from the socket. */
	public function readString() {
		$com = "";
		while(($d = $this->read()) != chr(0)) {
			$com .= $d;
		}
		return $com;
	}

	/* Returns a single byte from the socket. */
	private function read() {
		if($this->bpos == $this->bsize) {
			$this->bsize = socket_recv($this->socket, $this->buffer, 4096, 0);
			$this->bpos = 0;
		}
		return $this->buffer[$this->bpos++];
	}

	/* see readme.txt */
	private function sendCmd($code, $arg, $input) {
		socket_write($this->socket, chr($code).$arg.chr(0).$input.chr(0));
		$this->info = $this->receive();
		if($this->ok() != True) {
			throw new \Exception($this->info);
		}
	}

	/* Sends the str. */
	public function send($str) {
		socket_write($this->socket, $str.chr(0));
	}

	/* Returns success check. */
	public function ok() {
		return $this->read() == chr(0);
	}

	/* Returns the result. */
	public function receive() {
		$this->init();
		return $this->readString();
	}
}


?>