NarKampen/dbFiles/OnlineGames.php

<?php
/* Games.php */ 
	$hostname = 'localhost';
	$username = 'narKampen';
	$pass = 'narKampenPassword';
	$database = 'narKampen';
	
	$conn = new mysqli($hostname, $username, $pass, $database);
	if (!$conn) {
		die("Connection Failed. ". mysqli_connect_error());
	}
	mysqli_set_charset($conn,'utf8');
	
	$userId = $conn->real_escape_string($_POST['userId']);
	$callFunction = $conn->real_escape_string($_POST['f']);
	$gameId = $conn->real_escape_string($_POST['gameId']);
	$userName = $conn->real_escape_string($_POST['userName']);
	
	if ($callFunction === "list"){	
		$sql = "SELECT * FROM game WHERE id IN (SELECT gameId FROM gamePlayers WHERE playerId = $userId)";
		$result = $conn->query($sql);

		if ($result->num_rows > 0) {
			$returnArray = array();
			$i = 0;
			while ($data = $result->fetch_assoc()) {
				foreach ($data as $key => $value) {
					$returnArray[$i][$key] = $value;
				}
				$i++;
			}
			echo json_encode($returnArray);
			
		} else {
			echo "No games found for user";
		}
	} else if ($callFunction === "decline"){
		$sql = "UPDATE gamePlayers SET status = 'DECLINED' WHERE gameId = $gameId AND playerId = (SELECT id from users WHERE username = '$userName')";
		$result = $conn->query($sql);
		if (!$result) {
			echo "UPDATE player status failed " . $conn->error;
		} else {
			$sql = "SELECT count(*) as c FROM gamePlayers WHERE gameId = $gameId AND status NOT LIKE 'DECLINED'";
			$result = $conn->query($sql);
			while ($data = $result->fetch_assoc()) {
				if ($data['c'] == 1) { // Alla utom den som startade spelet har nekat, sätt status till declined på game
					$sql = "UPDATE game SET status = 'DECLINED' WHERE id = $gameId";
					$result = $conn->query($sql);
					if (!$result) {
						echo "UPDATE game status failed " . $conn->error;
					}
				}
			}
		}
	} else if ($callFunction === "accept") {
		$sql = "UPDATE gamePlayers SET status = 'ACCEPTED' WHERE gameId = $gameId AND playerId = (SELECT id from users WHERE username = '$userName')";
		$result = $conn->query($sql);
		if (!$result) {
			echo $conn->error;
		} else {
			$sql = "SELECT * FROM gamePlayers WHERE gameId = $gameId";
			$result = $conn->query($sql);
			$done = true;
			while ($data = $result->fetch_assoc()) {
				if ($data['status'] != "ACCEPTED") {
					echo $data['status'];
					$done = false;
				}
			}
			if ($done) {
				$sql = "UPDATE game SET status = 'ACTIVE' WHERE id = $gameId";
				$result = $conn->query($sql);
				if (!$result) {
					echo "updating game status active failed " . $conn->error;
				}
			}
		}
	} else if ($callFunction === "SetLastPlayed") {
		$sql = "UPDATE game SET lastPlayedDate = NOW() WHERE id = $gameId";
		$result = $conn->query($sql);
		if (!$result) {
			echo "Updating lastPlayedDate failed " . $conn->error; 
		}
	} else if ($callFunction === "SetQuestionsLost") {
		$questionsLost = $_POST['questionsLost'];
		$sql = "UPDATE gamePlayers SET questionsLost = $questionsLost WHERE gameId = $gameId AND playerId = (SELECT id from users WHERE name = '$userName')";
		$result = $conn->query($sql);
		if (!$result) {
			echo "Updating questionsLost resulted in error: " . $conn->error;
		}
	} else if ($callFunction === "DeleteGame") {
		$sql = "DELETE FROM game WHERE id = $gameId";
		$result = $conn->query($sql);
		if (!$result) {
			echo "Failed to delete game with id $gameId - error: " . $conn->error;
		}
		
		$sql = "DELETE FROM gamePlayers WHERE gameId = $gameId";
		$result = $conn->query($sql);
		if (!$result) {
			echo "Failed to delete gamePlayers with id $gameId - error: " . $conn->error;
		}	
	} else if ($callFunction === "CurrentPlayer") {
		$sql = "SELECT currentPlayer FROM game WHERE id = $gameId";
		$result = $conn->query($sql);
		if (!$result) {
			echo "Failed to get current player for game with id $gameId";
		} else {
			if ($result->num_rows > 0) {
				$returnArray = array();
				$i = 0;
				while ($data = $result->fetch_assoc()) {
					$currentPlayer = $data['currentPlayer'];
				}
				echo $currentPlayer;
			}
		}
		
	} else if ($callFunction === "SetCurrentPlayer") {
		$currentPlayer = $_POST['currentPlayer'];
		$sql = "UPDATE game SET currentPlayer = '$currentPlayer' WHERE id = $gameId";
		$result = $conn->query($sql);
		if (!$result) {
			echo "Failed to update current player for game with id $gameId - error: " . $conn->error;
		}
	} else if ($callFunction === "GetPlayerPoints") {
		$sql = "SELECT userLockedQuestions FROM game WHERE gameId = $gameId AND playerId = (SELECT id FROM users WHERE name = '$userName')";
		$result = $conn->query($sql);
		$data = $result->fetch_assoc();
		
		echo $data['userLockedQuestions'];
	} else if ($callFunction === "SetFinishedDate") {
		$finishedDate = $_POST['finishedDate'];
		$sql = "UPDATE game SET finishedDate = '$finishedDate' WHERE id = $gameId";
		$result = $conn->query($sql);
		if (!$result) {
			echo "Failed to update current player for game with id $gameId - error: " . $conn->error;
		}
	} else if ($callFunction === "SetRound") {
		$round = $_POST['round'];
		$sql = "UPDATE game SET round = '$round' WHERE id = $gameId";
		$result = $conn->query($sql);
		if (!$result) {
			echo "Failed to update current player for game with id $gameId - error: " . $conn->error;
		}
	} else if ($callFunction === "GetRound") {
		$sql = "SELECT round FROM game WHERE id = $gameId";
		$result = $conn->query($sql);
		$data = $result->fetch_assoc();
		
		echo $data['round'];
	} else if ($callFunction === "GetPlayers") {
		$sql = "SELECT username, userLockedQuestions FROM gamePlayers INNER JOIN users ON users.id = gamePlayers.playerId WHERE gameId = $gameId";
		$result = $conn->query($sql);
		$returnArray = array();
		$i = 0;
		while ($data = $result->fetch_assoc()) {
			foreach ($data as $key => $value) {
				$returnArray[$i][$key] = $value;
			}
			$i++;
		}
		echo json_encode($returnArray);
	} else if ($callFunction === "GetQuestionsLost") {
		$userName = $_POST['userName'];
		$sql = "SELECT questionsLost FROM gamePlayers WHERE gameId = $gameId AND playerId = (SELECT id from users WHERE username = '$userName')";
		$result = $conn->query($sql);
		$data = $result->fetch_assoc();
		
		echo $data['questionsLost'];
	}
	
	
	$conn->close();
	
?>