LobbyManager.php

<?php

	// Lobby Manager

/**
 * 
 */
require_once ('User.php');

class LobbyManager 
{
	
	protected $db;
	private $lobby;

	function __construct()
	{
		$this->db = $this->dbConnect();
	}

	private function dbConnect() {

		try {
			$db = new PDO('mysql:host=localhost;dbname='.DB_NAME, DB_USERNAME, DB_PASSWORD);
			$db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
			return $db;
		} catch (PDOException $e) {
			//echo $e->getMessage();
			return $e->getMessage();
		}

	}

	public function userInLobby($email){
		$sql = "SELECT `userID` FROM `lobby` WHERE lobby.userID=(SELECT `userID` FROM `users` WHERE users.email=".$this->db->quote($email).")";
		try {
			$result = $this->db->query($sql);
			$data = $result->fetch(PDO::FETCH_ASSOC);
			if($data) return true;
			return false;
		} catch (PDOException $e){
			return $e->getMessage();
		}
	}

	public function removeUserFromLobby($email){
		$email = $this->db->quote($email);
		$sql = "DELETE FROM `lobby` WHERE userID=(SELECT userID from `users` WHERE users.email=".$email.")";
		try {
			$result = $this->db->query($sql);
		} catch (PDOException $e) {
			return $e->getMessage();
		}
	}

	// Return a list of users in the lobby
	public function getLobby(){
		$sql = "SELECT lobby.userID as userID, users.name as name, users.role as role, users.email as email FROM lobby JOIN `users` ON users.userID=lobby.userID";
		//$sql = "SELECT * FROM `lobby`";
		$result = $this->db->query($sql);
		//preDump($result);
		//$data = $result->fetch(PDO::FETCH_ASSOC);
		$data = $result->fetchAll(PDO::FETCH_CLASS, "User");
		if ($data) {
			return $data;
		} 
		return false;
	}

	// Add a user to the lobby
	public function addUser($email){
		$sql = "INSERT INTO `lobby`(`userID`) VALUES ((SELECT `userID` FROM `users` WHERE users.email=".$this->db->quote($email)."))";
		try {
			$result = $this->db->query($sql);
		} catch (PDOException $e) {
			return $e->getMessage();
		}
	}


}

?>