Compare commits
No commits in common. "81134390f7d1876ad7218d8da0f3e2e07fc64224" and "4e2ce97cd26d5171d6a1390deb46abe35a177363" have entirely different histories.
81134390f7
...
4e2ce97cd2
@ -38,7 +38,7 @@ RenderSettings:
|
|||||||
m_ReflectionIntensity: 1
|
m_ReflectionIntensity: 1
|
||||||
m_CustomReflection: {fileID: 0}
|
m_CustomReflection: {fileID: 0}
|
||||||
m_Sun: {fileID: 705507994}
|
m_Sun: {fileID: 705507994}
|
||||||
m_IndirectSpecularColor: {r: 0.18018535, g: 0.22559482, b: 0.30677685, a: 1}
|
m_IndirectSpecularColor: {r: 0.18028378, g: 0.22571412, b: 0.30692285, a: 1}
|
||||||
m_UseRadianceAmbientProbe: 0
|
m_UseRadianceAmbientProbe: 0
|
||||||
--- !u!157 &3
|
--- !u!157 &3
|
||||||
LightmapSettings:
|
LightmapSettings:
|
||||||
@ -10050,7 +10050,7 @@ MonoBehaviour:
|
|||||||
m_OnCullStateChanged:
|
m_OnCullStateChanged:
|
||||||
m_PersistentCalls:
|
m_PersistentCalls:
|
||||||
m_Calls: []
|
m_Calls: []
|
||||||
m_Sprite: {fileID: 21300000, guid: c61e5b2ecf71bd44fa029b05c6f7d0b2, type: 3}
|
m_Sprite: {fileID: 21300000, guid: 40956548d757c3c44b9ffe9e7317cc56, type: 3}
|
||||||
m_Type: 0
|
m_Type: 0
|
||||||
m_PreserveAspect: 0
|
m_PreserveAspect: 0
|
||||||
m_FillCenter: 1
|
m_FillCenter: 1
|
||||||
|
@ -7,9 +7,6 @@
|
|||||||
using Newtonsoft.Json;
|
using Newtonsoft.Json;
|
||||||
using System.Linq;
|
using System.Linq;
|
||||||
using Google.MiniJSON;
|
using Google.MiniJSON;
|
||||||
using Firebase.Storage;
|
|
||||||
using System.Security.Policy;
|
|
||||||
using System.Threading.Tasks;
|
|
||||||
|
|
||||||
public class RoomManager : MonoBehaviour
|
public class RoomManager : MonoBehaviour
|
||||||
{
|
{
|
||||||
@ -142,14 +139,12 @@ private void ResetAllPlayerLabels()
|
|||||||
|
|
||||||
private void OnApplicationQuit()
|
private void OnApplicationQuit()
|
||||||
{
|
{
|
||||||
Debug.Log($"delete realtimeDB room {myRoom.code}");
|
Debug.Log($"delete room {myRoom.code}");
|
||||||
realtimeDB.Child("rooms").Child(myRoom.code).RemoveValueAsync().ContinueWithOnMainThread(task =>
|
realtimeDB.Child("rooms").Child(myRoom.code).RemoveValueAsync().ContinueWithOnMainThread(task =>
|
||||||
{
|
{
|
||||||
Debug.Log($"room {myRoom.code} has been deleted");
|
Debug.Log($"room {myRoom.code} has been deleted");
|
||||||
myRoom = null;
|
myRoom = null;
|
||||||
});
|
});
|
||||||
Debug.Log($"delete files of room {myRoom.code}");
|
|
||||||
DeleteRoomFiles();
|
|
||||||
}
|
}
|
||||||
|
|
||||||
private void Initialize()
|
private void Initialize()
|
||||||
@ -157,23 +152,53 @@ private void Initialize()
|
|||||||
FirebaseInitializer.Instance.onFirebaseReady -= Initialize;
|
FirebaseInitializer.Instance.onFirebaseReady -= Initialize;
|
||||||
realtimeDB = FirebaseDatabase.DefaultInstance.RootReference;
|
realtimeDB = FirebaseDatabase.DefaultInstance.RootReference;
|
||||||
Debug.Log("Realtime DB initialized");
|
Debug.Log("Realtime DB initialized");
|
||||||
CleanOldRooms();
|
|
||||||
CreateNewRoom();
|
CreateNewRoom();
|
||||||
}
|
}
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// Check all the rooms in the server and give back the number already taken
|
/// Check all the rooms in the server and give back the number already taken
|
||||||
/// </summary>
|
/// </summary>
|
||||||
|
|
||||||
private void WhichCodesAreAlreadyUsed(Action<List<int>> callback_OnCodesChecked)
|
private void WhichCodesAreAlreadyUsed(Action<List<int>> callback_OnCodesChecked)
|
||||||
{
|
{
|
||||||
QueryRoomsInDatabase(onlineRooms =>
|
Debug.Log("Checking other rooms to get which codes are already used", this);
|
||||||
|
List<int> alreadyUsedCodes = new List<int>();
|
||||||
|
try
|
||||||
{
|
{
|
||||||
List<int> alreadyUsedCodes = onlineRooms.Select(room => int.Parse(room.code)).ToList();
|
realtimeDB.Child("rooms").GetValueAsync().ContinueWithOnMainThread(task =>
|
||||||
Debug.Log($"Codes {string.Join(", ", alreadyUsedCodes)} are already used by other parties", this);
|
{
|
||||||
|
Debug.Log("looking into the online rooms", this);
|
||||||
|
if (task.IsFaulted)
|
||||||
|
{
|
||||||
|
Debug.LogException(task.Exception);
|
||||||
|
}
|
||||||
|
else if (task.IsCompleted)
|
||||||
|
{
|
||||||
|
DataSnapshot snapshot = task.Result;
|
||||||
|
if (snapshot.Value != null)
|
||||||
|
{
|
||||||
|
string JSON = snapshot.GetRawJsonValue();
|
||||||
|
Debug.Log($"found some rooms :\n{JSON}", this);
|
||||||
|
Dictionary<string, Room> onlineRooms = JsonConvert.DeserializeObject<Dictionary<string, Room>>(JSON);
|
||||||
|
foreach (Room r in onlineRooms.Values)
|
||||||
|
{
|
||||||
|
Debug.Log($"Code {r.code} is already used by another party", this);
|
||||||
|
alreadyUsedCodes.Add(int.Parse(r.code));
|
||||||
|
}
|
||||||
|
}
|
||||||
|
else
|
||||||
|
{
|
||||||
|
Debug.Log($"Your party is the first one!", this);
|
||||||
|
}
|
||||||
|
}
|
||||||
callback_OnCodesChecked?.Invoke(alreadyUsedCodes);
|
callback_OnCodesChecked?.Invoke(alreadyUsedCodes);
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
catch (Exception ex)
|
||||||
|
{
|
||||||
|
Debug.LogException(ex);
|
||||||
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// Automatically called at start of game
|
/// Automatically called at start of game
|
||||||
@ -229,6 +254,7 @@ public void HostHasStartedGame()
|
|||||||
waitingForPlayersPage.SetActive(false);
|
waitingForPlayersPage.SetActive(false);
|
||||||
endOfPropositionDate = DateTime.Now.AddSeconds(propositionTime);
|
endOfPropositionDate = DateTime.Now.AddSeconds(propositionTime);
|
||||||
|
|
||||||
|
|
||||||
propositionLabelsByID.Clear();
|
propositionLabelsByID.Clear();
|
||||||
|
|
||||||
//display only correct numbers of labels
|
//display only correct numbers of labels
|
||||||
@ -427,106 +453,4 @@ private void UpdateConnectedPlayerList(List<Player> _players)
|
|||||||
waitingForPlayersLabels[i].text = orderedPlayers[i].name;
|
waitingForPlayersLabels[i].text = orderedPlayers[i].name;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
private void QueryRoomsInDatabase(Action<List<Room>> callback)
|
|
||||||
{
|
|
||||||
Debug.Log("Querying rooms from the database", this);
|
|
||||||
realtimeDB.Child("rooms").GetValueAsync().ContinueWithOnMainThread(task =>
|
|
||||||
{
|
|
||||||
if (task.IsFaulted)
|
|
||||||
{
|
|
||||||
Debug.LogException(task.Exception);
|
|
||||||
callback?.Invoke(new List<Room>());
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
DataSnapshot snapshot = task.Result;
|
|
||||||
if (snapshot.Value != null)
|
|
||||||
{
|
|
||||||
string JSON = snapshot.GetRawJsonValue();
|
|
||||||
Debug.Log($"Found some rooms:\n{JSON}", this);
|
|
||||||
Dictionary<string, Room> onlineRooms = JsonConvert.DeserializeObject<Dictionary<string, Room>>(JSON);
|
|
||||||
callback?.Invoke(onlineRooms.Values.ToList());
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
Debug.Log("No rooms found in the database", this);
|
|
||||||
callback?.Invoke(new List<Room>());
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
|
|
||||||
private void CleanOldRooms()
|
|
||||||
{
|
|
||||||
QueryRoomsInDatabase(onlineRooms =>
|
|
||||||
{
|
|
||||||
DateTime oneHourLater = DateTime.Now.AddHours(1);
|
|
||||||
|
|
||||||
foreach (Room r in onlineRooms)
|
|
||||||
{
|
|
||||||
if (DateTime.FromOADate(r.creationDate) < oneHourLater)
|
|
||||||
{
|
|
||||||
Debug.Log($"Room {r.code} has been created at {DateTime.FromOADate(r.creationDate)} and it's more than one hour old. Deleting it");
|
|
||||||
realtimeDB.Child("rooms").Child(r.code).RemoveValueAsync().ContinueWithOnMainThread(task =>
|
|
||||||
{
|
|
||||||
if (task.IsFaulted)
|
|
||||||
{
|
|
||||||
Debug.LogException(task.Exception);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
Debug.Log($"Room {r.code} has been deleted");
|
|
||||||
});
|
|
||||||
}
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
private async Task<bool> DoesPathExistAsync(StorageReference storageReference)
|
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
|
||||||
await storageReference.GetMetadataAsync();
|
|
||||||
return true; // Path exists
|
|
||||||
}
|
|
||||||
catch (StorageException ex)
|
|
||||||
{
|
|
||||||
if (ex.ErrorCode == StorageException.ErrorObjectNotFound)
|
|
||||||
{
|
|
||||||
return false; // Path does not exist
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
Debug.LogException(ex);
|
|
||||||
return false; // Handle other errors as needed
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
private async void DeleteRoomFiles()
|
|
||||||
{
|
|
||||||
string roomCode = myRoom.code; //save it in case room has been deleted during you check files
|
|
||||||
|
|
||||||
StorageReference roomFolder = FirebaseStorage.DefaultInstance.RootReference.Child(roomCode);
|
|
||||||
|
|
||||||
bool pathExists = await DoesPathExistAsync(roomFolder);
|
|
||||||
|
|
||||||
if (pathExists)
|
|
||||||
{
|
|
||||||
_ = roomFolder.DeleteAsync().ContinueWithOnMainThread(task =>
|
|
||||||
{
|
|
||||||
if (task.IsCanceled || task.IsFaulted)
|
|
||||||
{
|
|
||||||
Debug.LogException(task.Exception);
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
Debug.Log($"Files of Room {roomCode} have been deleted");
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
else
|
|
||||||
{
|
|
||||||
Debug.Log($"Path for Room {roomCode} does not exist, nothing to delete");
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user