using System.Collections; using System.Collections.Generic; using Firebase; using Firebase.Database; using Firebase.Extensions; using TMPro; using UnityEngine; using System; using Newtonsoft.Json; using Newtonsoft.Json.Linq; using System.Linq; public class RoomManager : MonoBehaviour { public List playerLabels = new List(); private RoomState currentState; private Room myRoom = null; private List players; public float propositionTime = 60; public float votingTime = 20; private float propositionCurrentTime = 0; private float votingCurrentTime = 0; /// /// Contain the infos about the current displayed question (during votes) /// private Question currentQuestion; private List questions; /// /// When this is equal to questions.Count, go to score page /// private int numberOfQuestionVoted = 0; DatabaseReference realtimeDB; /// /// TextMeshPro that show the value of the current rooom code /// public TextMeshProUGUI roomCodeLabel; private void Awake() { FirebaseInitializer.Instance.onFirebaseReady += Initialize; currentState = RoomState.None; } private void Start() { propositionCurrentTime = propositionTime; votingCurrentTime = votingTime; DisableAllPlayerLabels(); currentState = RoomState.WaitingForPlayers; } private void DisableAllPlayerLabels() { for (int i = 0; i < playerLabels.Count; i++) { playerLabels[i].text = $"Waiting for P{i + 1}"; } } private void OnApplicationQuit() { realtimeDB.Child("rooms").Child(myRoom.code).RemoveValueAsync(); Debug.Log($"delete room {myRoom.code}"); myRoom = null; } private void Initialize() { FirebaseInitializer.Instance.onFirebaseReady -= Initialize; realtimeDB = FirebaseDatabase.DefaultInstance.RootReference; Debug.Log("Realtime DB initialized"); CreateNewRoom(); } /// /// Check all the rooms in the server and give back the number already taken /// private void WhichCodesAreAlreadyUsed(Action> callback_OnCodesChecked) { List alreadyUsedCodes = new List(); realtimeDB.Child("rooms").GetValueAsync().ContinueWithOnMainThread(task => { if (task.IsFaulted) { Debug.LogException(task.Exception); } else if (task.IsCompleted) { DataSnapshot snapshot = task.Result; List onlineRooms = JsonUtility.FromJson>(snapshot.GetRawJsonValue()); foreach (Room r in onlineRooms) { alreadyUsedCodes.Add(int.Parse(r.code)); } } callback_OnCodesChecked?.Invoke(alreadyUsedCodes); }); } /// /// Automatically called at start of game /// [ContextMenu("Create New Room")] public void CreateNewRoom() { WhichCodesAreAlreadyUsed(codes => { Room newRoom = new Room(GenerateRandomAvailableCode(codes).ToString("D4")); myRoom = newRoom; try { string JSON = JsonUtility.ToJson(newRoom); realtimeDB.Child("rooms").Child(newRoom.code).SetRawJsonValueAsync(JSON).ContinueWithOnMainThread(task => { //then subscribe to it realtimeDB.Child("rooms").Child(newRoom.code).ValueChanged += OnRoomUpdate; roomCodeLabel.text = myRoom.code; Debug.Log($"room {myRoom.code} has been created on the server"); }); } catch (Exception e) { Debug.LogException(e); } }); } /// /// Generate a code between 0 and 1000 that is not in the list /// /// the list of code you don"t want to get /// private int GenerateRandomAvailableCode(List _impossibleCodes) { int random = UnityEngine.Random.Range(0, 1000); while (_impossibleCodes.Contains(random)) { Debug.Log($"{random} is already taken, choosing another room code", this); random = UnityEngine.Random.Range(0, 1000); } return random; } private void DisplayRoomCode() { } public void PlayerSendProposition(Proposition _proposition) { } /// /// Called when the first player clicked "Start" /// public void HostStartGame() { } /// /// Start the proposition timer /// public void StartPropositionTimer() { } /// /// Automatically called when the proposition timer has finished /// public void PropositionTimerFinished() { } /// /// Start the voting timer /// public void StartVotingTimer() { } /// /// Automatically called when the voting timer has finished /// public void VotingTimerFinished() { } /// /// Automatically called when a proposition is updated (someone has voted or a picture has been proposed) /// public void OnPropositionUpdate() { } /// /// Will generate a question with a prompt and two owners /// public void GenerateQuestion() { } /// /// Generate all the player pairs /// (players should not play against themself. /// (players should not play twice with the same person) /// public void GenerateCouples() { } /// /// Automatically called when something change in your room /// private void OnRoomUpdate(object sender, ValueChangedEventArgs value) { Debug.Log("coucou"); if (value.DatabaseError != null) { Debug.LogError(value.DatabaseError.Message); return; } string JSON = value.Snapshot.GetRawJsonValue(); Debug.Log(JSON); try { myRoom = JsonConvert.DeserializeObject(JSON); } catch (Exception ex) { Debug.LogException(ex); } Debug.Log("caca"); switch (currentState) { case RoomState.WaitingForPlayers: Debug.Log("prout"); UpdateConnectedPlayerList(myRoom.GetPlayerList()); break; default: break; } } /// /// Update the player labels on the WaitingForPlayer page /// /// private void UpdateConnectedPlayerList(List _players) { Debug.Log($"players count = {_players.Count}"); for (int i = 0; i < _players.Count; i++) { Debug.Log($"player {i} = {_players[i].name}"); playerLabels[i].text = _players[i].name; } } [ContextMenu("Fake Player Connection")] private void FakePlayerConnection() { Player temp = new Player("Momo"); temp.id = Guid.NewGuid().ToString(); temp.SetName("Momo"); } } public enum RoomState { None, WaitingForPlayers, WaitingForPropositions, ShowPropositions, ShowVoters, Score }