websocket.users.php

<?php

interface IWebSocketUser{
	public function __construct($socket, WebSocketServer $server);
	
	public function getId();
	
	public function getProtocolVersion();
	public function setProtocolVersion($version);
	public function getResource();
	public function setResource($resource);
	
	public function isAdmin();
	
	public function hasHandshaked();
	public function setHandshaked();
	
	public function getHeaders();
	public function setHeaders($headers);
	
	public function getLastMessage();
	public function addMessage(IWebSocketMessage $msg);
	
	public function getSocket();
	
	public function getServerInstance();
}

/**
 * TODO: Getters and setters
 *
 * @author Chris
 *
 */
class WebSocketUser implements IWebSocketUser{
	protected $id;
	
	private $socket;
	private $resource;
	private $ip;
	
	private $handshaked = false;
	
	private $protocol = 0;
	
	/**
	 * 
	 * Enter description here ...
	 * @var WebSocketMessage
	 */
	private $message;
	private $headers = array();
	private $cookies = array();
	
	private $isAdmin = false;
	
	private $_server;
	
	public function __construct($socket, WebSocketServer $server){
		$this->socket = $socket;
		
		$address = '';
		socket_getpeername($socket, &$address);
		
		$this->ip = $address;
		$this->id = uniqid("u-");
		
		$this->_server = $server;
	}
	
	public function getId(){
		return $this->id;
	}
	
	public function getHeaders(){
		return $this->headers;
	}
	
	public function setHeaders($headers){		
		$this->headers = $headers;
		
		if(array_key_exists("Cookie", $this->headers)){
		 	$this->_cookies = WebSocketFunctions::cookie_parse($this->headers['Cookie']);
		}else $this->_cookies = array();
		
		$this->isAdmin = array_key_exists('Admin-Key', $this->headers) 
			&& $this->headers['Admin-Key'] == $this->getServerInstance()->getAdminKey();
		
		// Incorrect admin-key
		if($this->isAdmin == false && array_key_exists('Admin-Key', $this->headers))
			throw new WebSocketNotAuthorizedException($this);	 
		
	}
	
	public function createMessage($data){
		if($this->protocol == WebSocketProtocolVersions::HIXIE_76)
			return WebSocketMessage76::create($data);
		else return WebSocketMessage::create($data);
	}
	
	public function hasHandshaked(){
		return $this->handshaked;
	}
	
	public function setHandshaked(){
		$this->handshaked = true;
	}
	
	public function getProtocolVersion(){
		return $this->protocol;
	}
	
	public function getCookies(){
		return $this->_cookies;
	}
	
	public function setProtocolVersion($version){
		$this->protocol = $version;
	}

	public function getResource(){
		return $this->resource;		
	}
	
	public function setResource($resource){
		$this->resource = $resource;
	}

	public function isAdmin(){
		return $this->isAdmin;
	}
	
	public function getLastMessage(){
		return $this->message;
	}
	
	public function getSocket(){
		return $this->socket;
	}
	
	public function addMessage(IWebSocketMessage $msg){
		$this->message = $msg;
	}
	
	public function getServerInstance(){
		return $this->_server;
	}
}