NarKampen/Assets/Scripts/Database/OnlineDatabase.cs

using System.Collections;
using System.Collections.Generic;
using UnityEngine;
using Mono.Data.Sqlite;
using System.Data;
using System;
using UnityEngine.Networking;
using System.IO;
using System.Text;

public class OnlineDatabase : MonoBehaviour {
    private const string onlineQuestionsUrl = "narkampen.nordh.xyz/narKampen/dbFiles/Question.php";
    private const string serverUrl = "narkampen.nordh.xyz/narKampen/dbFiles/";
    string gameMode;
    int winAmount = -1;

    public GameObject questionCardPrefab;

    private static OnlineDatabase instance;
    public static OnlineDatabase Instance { get { return instance; } }

    private void Awake() {
        if (instance == null) {
            instance = this;
        }
    }

    internal List<CategoryPanel.Category> GetCategories(List<CategoryPanel.Category> list, int gameId) {
        WWWForm form = new WWWForm();
        form.AddField("gameId", gameId);

        string response = CallOnlineDatabaseWithResponse("Categories.php", form);

        response = "{\"categoryList\" :  " + response + " }";

        Categories categories = new Categories();
        JsonUtility.FromJsonOverwrite(response, categories);

        foreach (Category c in categories.categoryList) {
            CategoryPanel.Category cat = new CategoryPanel.Category();

            cat.color = new Color32((byte)c.r, (byte)c.g, (byte)c.b, (byte)c.a);
            cat.name = c.name;
            cat.id = c.id;
            cat.questionCount = c.count;

            list.Add(cat);
        }
        return list;
    }

    internal int SetupNewOnlineGame(int limitPerQuestion, int limitPerPlayer, int toWin, List<InviteSearchResult> inviteUsers, List<int> selectedCategories) {
        List<int> playerIds = new List<int>();
        inviteUsers.ForEach(i => playerIds.Add(i.GetId()));
        int currentUser = Database.Instance.GetSignedInUser().Key;
        playerIds.Add(currentUser);

        var form = new WWWForm();
        form.AddField("currentUser", currentUser);
        form.AddField("winNumber", toWin);
        form.AddField("limitPerQuestion", limitPerQuestion);
        form.AddField("limitPerPlayer", limitPerPlayer);
        form.AddField("playerIds", String.Join(",", playerIds));
        form.AddField("categoryIds", String.Join(",", selectedCategories));

        string response = CallOnlineDatabaseWithResponse("NewOnlineGame.php", form);

        if (response.Equals("")) {
            Debug.Log("Expected gameId in response for creating new game but did not get one");
        }

        if (Int32.TryParse(response, out int newGameId)) {
            return newGameId; 
        } else {
            Debug.Log("Failed to get new game id with response " + response);
            return -1;
        }

    }

    [Serializable]
    public class Question {
        public string question;
        public string answer;
        public string id;
        public string category;
        public string categoryName;
        public int r;
        public int g;
        public int b;
        public int a;
    }

    [Serializable]
    public class Questions {
        public List<Question> questionsList = new List<Question>();
    }

    [Serializable]
    public class PlayerInfo {
        public string username;
        public string status;
    }

    [Serializable]
    public class PlayerInfos {
        public List<PlayerInfo> playerInfoList = new List<PlayerInfo>();
    }

    [Serializable]
    public class GamePlayerInfo {
        public string username;
        public string userLockedQuestions;
    }

    [Serializable]
    public class GamePlayerInfos {
        public List<GamePlayerInfo> gamePlayerInfoList = new List<GamePlayerInfo>();
    }



    [Serializable]
    public class Category {
        public int r;
        public int g;
        public int b;
        public int a;
        public int id;
        public string name;
        public int count;
    }

    [Serializable]
    public class Categories {
        public List<Category> categoryList = new List<Category>();
    }

    [Serializable]
    public class OnlineGame {
        public string id;
        public string winNumber;
        public string answerTimer;
        public string roundTimeLimit;
        public string currentPlayer;
        public string round;
        public string startDate;
        public string lastPlayedDate;
        public string finishedDate;
        public string status;
        public string playerToAct;
    }

    [Serializable]
    public class OnlineGames {
        public List<OnlineGame> onlineGamesList = new List<OnlineGame>();
    }

    [Serializable]
    public class UserName {
        public string id;
        public string username;
    }

    [Serializable]
    public class UserNames {
        public List<UserName> usernamesList = new List<UserName>();
    }

    private void CallDatabase(string filename, WWWForm formData) {
        string postUrl = serverUrl + filename;

        UnityWebRequest www = UnityWebRequest.Post(postUrl, formData);
        www.SendWebRequest();

        if (www.isNetworkError || www.isHttpError) {
            Debug.Log(www.error);
        } else {
            while (!www.isDone) {
            }
        }
    }

    private string CallOnlineDatabaseWithResponse(string filename, WWWForm formData) {
        string postUrl = serverUrl + filename;

        UnityWebRequest www = UnityWebRequest.Post(postUrl, formData);
        www.SendWebRequest();

        if (www.isNetworkError || www.isHttpError) {
            Debug.Log(www.error);
        } else {
            while (!www.isDone) {
            }
        }

        return www.downloadHandler.text;
    }

    string questionString = "";
    string answerString = "";
    string idString = "";
    string categoryString = "";

    public string QuestionString { get => questionString; set => questionString = value; }

    internal void SendGameOverMessage(int gameId, List<KeyValuePair<string, int>> players, string currentPlayer)
    {
        string message = "Den som van var " + currentPlayer + "!"; //TODO
        string title = "Spelet slut!";                              //TODO 

        WWWForm form = new WWWForm();
        form.AddField("gameId", gameId);
        form.AddField("message", message);
        form.AddField("title", title);
        form.AddField("winningPlayer", currentPlayer);
        form.AddField("messageType", "gameFinishedMessage");

        int index = 0;
        foreach (KeyValuePair<String, int> player in players) {
            form.AddField("player" + index++, player.Key);
        }

        CallDatabase("FCMMessageing.php", form);
    }

    private void Start() {
        if (instance == null) {
            instance = this;
        }
    }

    internal void SetLastPlayedDate(int gameId) {

        WWWForm form = new WWWForm();
        form.AddField("gameId", gameId);
        form.AddField("f", "SetLastPlayed");
        string response = CallOnlineDatabaseWithResponse("OnlineGames.php", form);

        if (!response.Equals("")) {
            Debug.Log(response);
        }
    }

    internal void SetGameFinished(int gameId, string gameMode)
    {
        WWWForm formData = new WWWForm();
        formData.AddField("gameId", gameId);
        formData.AddField("f", "GameFinished");

        CallDatabase("OnlineGames.php", formData);
    }

    internal void DeclineOnlineGame(string userName, int gameId) {
        WWWForm formData = new WWWForm();
        formData.AddField("userId", -1);
        formData.AddField("f", "decline");
        formData.AddField("gameId", gameId);
        formData.AddField("userName", userName);

        CallDatabase("OnlineGames.php", formData);
    }

    internal void AcceptOnlineGame(string userName, int gameId) {
        WWWForm formData = new WWWForm();
        formData.AddField("userId", -1);
        formData.AddField("f", "accept");
        formData.AddField("gameId", gameId);
        formData.AddField("userName", userName);

        string response = CallOnlineDatabaseWithResponse("OnlineGames.php", formData);
        if (!response.Equals("")) {
            Debug.Log(response);
        }
    }

//TODO Försök att ta bort alla utom 1 databas anrop i denna
    internal List<OnlineGameScript> GetOnlineGames(int userId, string userName, GameObject prefab) {

        WWWForm formData = new WWWForm();
        formData.AddField("userId", userId);
        formData.AddField("f", "list");
        formData.AddField("gameId", -1);
        formData.AddField("userName", userName);

        string response = CallOnlineDatabaseWithResponse("OnlineGames.php", formData);

        if (response.Equals("No games found for user") || response.Equals("")) {
            return null;
        }

        response = "{\"onlineGamesList\" :  " + response + " }";

        OnlineGames og = new OnlineGames();
        JsonUtility.FromJsonOverwrite(response, og);

        GameObject onlineGameObject;
        OnlineGameScript ogs = null;
        List<OnlineGameScript> games = new List<OnlineGameScript>();
        foreach (OnlineGame game in og.onlineGamesList) {
            onlineGameObject = Instantiate(prefab, new Vector2(0, 0), Quaternion.identity) as GameObject;
            ogs = onlineGameObject.GetComponent<OnlineGameScript>();
            ogs.CurrentPlayer = game.currentPlayer;
            ogs.SetGameStatus(game.status);
            Int32.TryParse(game.id, out int gameId);
            List<KeyValuePair<string, string>> playerInfos = GetGameInfo(gameId);
            if (game.status.Equals("PENDING")) {
                string extraInfo = "";
                foreach (KeyValuePair<string, string> s in playerInfos) {
                    if (s.Value.Equals("WAITING") && s.Key.Equals(userName, StringComparison.InvariantCultureIgnoreCase)) {
                        ogs.SetGameStatus("INVITED");
                        extraInfo += s.Key + ",";
                    } else if (s.Value.EndsWith("WAITING")) {
                        extraInfo += s.Key + ",";
                    }
                }
                extraInfo = extraInfo.TrimEnd(',');
                ogs.SetGameStatusText(extraInfo);

            } else if (game.status.Equals("OTHERS_TURN")) {
                ogs.SetGameStatusText(game.playerToAct);
            } else if (game.status.Equals("ACTIVE")) {
                ogs.SetGameStatusText(game.playerToAct);
            } else {
                ogs.SetGameStatusText();
            }

            ogs.SetId(game.id);
            ogs.SetWinNumber(game.winNumber);
            ogs.SetAnswerTimer(game.answerTimer);
            ogs.SetRoundTimeLimit(game.roundTimeLimit);
            ogs.SetRound(game.round);
            ogs.StartDate = game.startDate;
            ogs.LastPlayedDate = game.lastPlayedDate;

            games.Add(ogs);
            ogs.PlayerInfos = playerInfos;
        }

        return games;
    }

    internal List<KeyValuePair<string, string>> GetGameInfo(int gameId) {
        List<KeyValuePair<string, string>> returnList = new List<KeyValuePair<string, string>>();

        WWWForm form = new WWWForm();
        form.AddField("f", "GetGameInfo");
        form.AddField("gameId", gameId);

        string response = CallOnlineDatabaseWithResponse("OnlineGameInfo.php", form);

        response = "{\"playerInfoList\" : " + response + " }";
        PlayerInfos pi = new PlayerInfos();
        JsonUtility.FromJsonOverwrite(response, pi);

        foreach (PlayerInfo p in pi.playerInfoList) {
            KeyValuePair<string, string> player = new KeyValuePair<string, string>(p.username, p.status);
            returnList.Add(player);
        }

        return returnList;
    }

    internal void SetQuestionsLost(int gameId, string playerName, int questionsLost) {
        WWWForm form = new WWWForm();
        form.AddField("f", "SetQuestionsLost");
        form.AddField("questionsLost", questionsLost);
        form.AddField("userName", playerName);
        form.AddField("gameId", gameId);

        string response = CallOnlineDatabaseWithResponse("OnlineGames.php", form);

        if (!response.Equals("")) {
            Debug.Log(response);
        }
    }

    internal void RemoveGame(int gameId) {
        WWWForm form = new WWWForm();
        form.AddField("f", "DeleteGame");
        form.AddField("gameId", gameId);

        string response = CallOnlineDatabaseWithResponse("OnlineGames.php", form);

        if (!response.Equals("")) {
            Debug.Log(response);
        }
    }

    public string GetCurrentPlayer(int gameId) {
        WWWForm form = new WWWForm();
        form.AddField("f", "CurrentPlayer");
        form.AddField("gameId", gameId);

        string response = CallOnlineDatabaseWithResponse("OnlineGames.php", form);
        if (response.Equals("")) {
            Debug.Log("Something wrong with current player for game with id: " + gameId);
        }
        return response;
    }

    public void SetCurrentPlayer(int gameId, string currentPlayer) {
        WWWForm form = new WWWForm();
        form.AddField("f", "SetCurrentPlayer");
        form.AddField("gameId", gameId);
        form.AddField("userName", currentPlayer);

        string response = CallOnlineDatabaseWithResponse("OnlineGames.php", form);

        if (!response.Equals("")) {
            Debug.Log(response);
        }
        
    }

    internal int GetPlayerPoints(int gameId, string playerName) {
        WWWForm form = new WWWForm();
        form.AddField("f", "GetPlayerPoints");
        form.AddField("gameId", gameId);
        form.AddField("userName", playerName);

        string response = CallOnlineDatabaseWithResponse("OnlineGames.php", form);
        if (response.Equals("")) {
            Debug.Log("Something wrong with current player for game with id: " + gameId);
        }
        Int32.TryParse(response, out int playerPoints);
        return playerPoints;
    }

    internal void SetFinishedDate(int gameId, string finishedDate) {
        WWWForm form = new WWWForm();
        form.AddField("f", "SetFinishedDate");
        form.AddField("gameId", gameId);
        form.AddField("finishedDate", finishedDate);

        string response = CallOnlineDatabaseWithResponse("OnlineGames.php", form);

        if (!response.Equals("")) {
            Debug.Log(response);
        }
    }

    internal void SetRoundValue(int gameId, int round) {
        WWWForm form = new WWWForm();
        form.AddField("f", "SetRound");
        form.AddField("gameId", gameId);
        form.AddField("round", round);

        string response = CallOnlineDatabaseWithResponse("OnlineGames.php", form);

        if (!response.Equals("")) {
            Debug.Log(response);
        }
    }

    internal int GetRoundValue(int gameId) {
        WWWForm form = new WWWForm();
        form.AddField("f", "GetRound");
        form.AddField("gameId", gameId);

        string response = CallOnlineDatabaseWithResponse("OnlineGames.php", form);
        if (response.Equals("")) {
            Debug.Log("Something wrong with getting round for game with id: " + gameId);
        }
        Int32.TryParse(response, out int round);
        return round;
    }

    internal List<KeyValuePair<string, int>> GetPlayersForGame(int gameId) {
        WWWForm form = new WWWForm();
        form.AddField("f", "GetPlayers");
        form.AddField("gameId", gameId);

        string response = CallOnlineDatabaseWithResponse("OnlineGames.php", form);
        if (response.Equals("")) {
            Debug.Log("Something wrong with getting players from game with id: " + gameId);
        }

        response = response = "{\"gamePlayerInfoList\" : " + response + " }";
        GamePlayerInfos gpi = new GamePlayerInfos();
        JsonUtility.FromJsonOverwrite(response, gpi);

        List<KeyValuePair<string, int>> returnList = new List<KeyValuePair<string, int>>();
        foreach (GamePlayerInfo p in gpi.gamePlayerInfoList) {
            Int32.TryParse(p.userLockedQuestions, out int points);
            KeyValuePair<string, int> player = new KeyValuePair<string, int>(p.username, points);
            returnList.Add(player);
        }

        return returnList;
    }

    public string AnswerString { get => answerString; set => answerString = value; }
    public string IdString { get => idString; set => idString = value; }
    public string CategoryString { get => categoryString; set => categoryString = value; }

    internal int GetQuestionsLost(int gameId, string playerName) {
        WWWForm form = new WWWForm();
        form.AddField("f", "GetQuestionsLost");
        form.AddField("userName", playerName);
        form.AddField("gameId", gameId);

        string response = CallOnlineDatabaseWithResponse("OnlineGames.php", form);
        if (response.Equals("")) {
            Debug.Log("Something wrong with getting questions lost from game with id: " + gameId + " and playername " + playerName);
        }
        Int32.TryParse(response, out int questionsLost);
        return questionsLost;
    }

    internal int GetWinCondition(int gameId) {
        if (winAmount == -1) {
            WWWForm form = new WWWForm();
            form.AddField("gameId", gameId);
            form.AddField("f", "GetWinCondition");

            string response = CallOnlineDatabaseWithResponse("OnlineGames.php", form);

            Int32.TryParse(response, out this.winAmount);

        }
        return this.winAmount;
    }

    public NewQuestionData newQuestionData;

    public NewQuestionData GetNewQuestion(List<int> userAnsweredQuestions, string userName) {
        int gameId = GameObject.Find("GameManager").GetComponent<GameManagerScript>().GameId;

        Question q = GetQuestionData(gameId, userAnsweredQuestions);

        Color32 categoryColor = new Color32((byte)q.r, (byte)q.g, (byte)q.b, (byte)q.a);
        //            Color32 questionCategoryColor = new Color32((byte)q.r, (byte)q.g, (byte)q.b, (byte)q.a);

        Int32.TryParse(q.category, out int categoryId);
        Int32.TryParse(q.id, out int questionId);

        NewQuestionData questionData = new NewQuestionData(q.answer, q.question, q.categoryName, categoryId, questionId, categoryColor);

        return questionData;
    }

    public void SavePlayersQuestion(List<int> questionsToSave, string playerNameValue, int gameId) {
        WWWForm form = new WWWForm();
        form.AddField("f", "SavePlayerQuestions");
        form.AddField("gameId", gameId);
        form.AddField("questionsToSave", String.Join(",",questionsToSave));
        form.AddField("userName", playerNameValue);

        string response = CallOnlineDatabaseWithResponse("OnlineGames.php", form);

        if (!response.Equals("")) {
            Debug.Log(response);
        }
    }

    public List<NewQuestionData> GetPlayerQuestions(int gameId, string playerName) {
        List<NewQuestionData> questions = new List<NewQuestionData>();
        WWWForm form = new WWWForm();
        form.AddField("f", "PlayerQuestions");
        form.AddField("gameId", gameId);
        form.AddField("userName", playerName);

        string response = CallOnlineDatabaseWithResponse("OnlineGameInfo.php", form);
        response = "{\"questionsList\" : " + response + "}";
        
        Questions ql = new Questions();

        JsonUtility.FromJsonOverwrite(response, ql);

        foreach (Question q in ql.questionsList) {
            /*GameObject question = Instantiate(questionCardPrefab, new Vector2(0, 0), Quaternion.identity) as GameObject;
            NewQuestionData qc = question.GetComponent<NewQuestionData>();
            */
            Color categoryColor = new Color(q.r, q.g, q.b, q.a);
//            Color32 questionCategoryColor = new Color32((byte)q.r, (byte)q.g, (byte)q.b, (byte)q.a);

            Int32.TryParse(q.category, out int categoryId);
            Int32.TryParse(q.id, out int questionId);

            NewQuestionData questionData = new NewQuestionData(q.answer, q.question, q.categoryName, categoryId, questionId, categoryColor);

            questions.Add(questionData);
        }
        
        return questions;
    }

    private Question GetQuestionData(int gameId, List<int> answeredQuestions) {
        WWWForm form = new WWWForm();
        form.AddField("gameId", gameId);
        form.AddField("answeredQuestions", String.Join(",", answeredQuestions));

        string response = CallOnlineDatabaseWithResponse("Question.php", form);
        
        // Show result

        response = "{\"questionsList\" : [ " + response + " ]}";

        Questions qe = new Questions();
        JsonUtility.FromJsonOverwrite(response, qe);
        
        return qe.questionsList[0];
    }

    public List<UserName> GetUsersToInvite(string searchString) {
        string postUrl = "narkampen.nordh.xyz/narKampen/dbFiles/PlayerSearch.php?";
        postUrl += "search=" + UnityWebRequest.EscapeURL(searchString);

        UserNames uNames = new UserNames();
        UnityWebRequest www = UnityWebRequest.Get(postUrl);
        www.SendWebRequest();

        if (www.isNetworkError || www.isHttpError) {
            Debug.Log(www.error);
        } else {
            while (!www.isDone) {
            }
            // Show result
            string jsonData = www.downloadHandler.text;

            if (!jsonData.Equals("")) {
                jsonData = "{\"usernamesList\" :  " + jsonData + " }";

                JsonUtility.FromJsonOverwrite(jsonData, uNames);
            }
        }
        // TODO handle empty
        return uNames.usernamesList;
    }

    internal void SendNextPlayerMessage(int gameId, String nextPlayer)
    {
        WWWForm form = new WWWForm();
        form.AddField("gameId", gameId);
        form.AddField("playerName", nextPlayer);
        form.AddField("title", LocalizationManager.Instance.GetText("FCM_NEXT_PLAYER_TITLE"));
        List<KeyValuePair<string, int>> players = OnlineDatabase.Instance.GetPlayersForGame(gameId);
        StringBuilder sb = new StringBuilder();
        foreach (KeyValuePair<String, int> player in players)
        {
            sb.AppendLine(player.Key + " (" + player.Value + ")");
        }
        String message = String.Format(LocalizationManager.Instance.GetText("FCM_NEXT_PLAYER_MESSAGE"),sb.ToString());
        form.AddField("message", message);
        form.AddField("type", "FCMNextPlayer");
        
        //string response = CallOnlineDatabaseWithResponse("FCMNextPlayer.php", form);
        CallDatabase("FCMMessageing.php", form);
    }

    internal void SendInviteForNewGame(int gameId, List<String> Players, String inviter) {
        WWWForm form = new WWWForm();
        form.AddField("gameId", gameId);
        int index = 0;

        foreach(String player in Players) {
            form.AddField("player" + index++, player);
        }

        form.AddField("title", LocalizationManager.Instance.GetText("FCM_NEW_GAME_TITLE"));
        form.AddField("message", String.Format(LocalizationManager.Instance.GetText("FCM_NEW_GAME_MESSAGE"), inviter));
        form.AddField("type", "InviteMessage");
        CallDatabase("FCMMessageing.php", form);
    }

    
    internal void UpdatePlayerToken(int userId, string myToken)
    {
        WWWForm form = new WWWForm();
        form.AddField("userId", userId);
        form.AddField("token", myToken);
        form.AddField("f", "UpdatePlayerToken");

        CallDatabase("OnlineGames.php", form);
    }

    
    internal List<string> FindRandomPlayer() {
        List<string> returnValue = new List<string>();
        WWWForm form = new WWWForm();
        form.AddField("f", "FindRandomPlayer");

        String response = CallOnlineDatabaseWithResponse("", form);
        
        //TODO FIX ME

        return returnValue;
    }


}