1
0
mirror of https://github.com/ppy/osu.git synced 2024-12-17 08:02:54 +08:00
osu-lazer/osu.Game/Screens/OnlinePlay/Components/RoomManager.cs

Ignoring revisions in .git-blame-ignore-revs. Click here to bypass and see the normal blame view.

158 lines
4.4 KiB
C#
Raw Normal View History

2020-12-18 23:15:41 +08:00
// Copyright (c) ppy Pty Ltd <contact@ppy.sh>. Licensed under the MIT Licence.
// See the LICENCE file in the repository root for full licence text.
2022-06-17 15:37:17 +08:00
#nullable disable
2020-12-18 23:15:41 +08:00
using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using osu.Framework.Allocation;
using osu.Framework.Bindables;
using osu.Framework.Development;
2020-12-18 23:15:41 +08:00
using osu.Framework.Graphics;
using osu.Framework.Logging;
using osu.Game.Online.API;
2020-12-25 12:38:11 +08:00
using osu.Game.Online.Rooms;
2020-12-18 23:15:41 +08:00
namespace osu.Game.Screens.OnlinePlay.Components
2020-12-18 23:15:41 +08:00
{
public partial class RoomManager : Component, IRoomManager
2020-12-18 23:15:41 +08:00
{
public event Action RoomsUpdated;
private readonly BindableList<Room> rooms = new BindableList<Room>();
public IBindableList<Room> Rooms => rooms;
protected IBindable<Room> JoinedRoom => joinedRoom;
private readonly Bindable<Room> joinedRoom = new Bindable<Room>();
2020-12-18 23:15:41 +08:00
[Resolved]
private IAPIProvider api { get; set; }
public RoomManager()
2020-12-18 23:15:41 +08:00
{
RelativeSizeAxes = Axes.Both;
}
protected override void Dispose(bool isDisposing)
{
base.Dispose(isDisposing);
PartRoom();
}
public virtual void CreateRoom(Room room, Action<Room> onSuccess = null, Action<string> onError = null)
{
room.Host.Value = api.LocalUser.Value;
var req = new CreateRoomRequest(room);
req.Success += result =>
{
joinedRoom.Value = room;
2020-12-18 23:15:41 +08:00
2021-08-16 12:04:06 +08:00
AddOrUpdateRoom(result);
room.CopyFrom(result); // Also copy back to the source model, since this is likely to have been stored elsewhere.
2020-12-18 23:15:41 +08:00
2021-08-17 08:40:25 +08:00
// The server may not contain all properties (such as password), so invoke success with the given room.
onSuccess?.Invoke(room);
2020-12-18 23:15:41 +08:00
};
req.Failure += exception =>
{
onError?.Invoke(req.Response?.Error ?? exception.Message);
2020-12-18 23:15:41 +08:00
};
api.Queue(req);
}
private JoinRoomRequest currentJoinRoomRequest;
public virtual void JoinRoom(Room room, string password = null, Action<Room> onSuccess = null, Action<string> onError = null)
2020-12-18 23:15:41 +08:00
{
currentJoinRoomRequest?.Cancel();
2021-07-13 13:27:07 +08:00
currentJoinRoomRequest = new JoinRoomRequest(room, password);
2020-12-18 23:15:41 +08:00
currentJoinRoomRequest.Success += () =>
{
joinedRoom.Value = room;
2020-12-18 23:15:41 +08:00
onSuccess?.Invoke(room);
};
currentJoinRoomRequest.Failure += exception =>
{
2021-09-14 13:10:55 +08:00
if (exception is OperationCanceledException)
return;
onError?.Invoke(exception.Message);
2020-12-18 23:15:41 +08:00
};
api.Queue(currentJoinRoomRequest);
}
2020-12-19 01:02:04 +08:00
public virtual void PartRoom()
2020-12-18 23:15:41 +08:00
{
currentJoinRoomRequest?.Cancel();
2020-12-21 14:38:20 +08:00
if (JoinedRoom.Value == null)
2020-12-18 23:15:41 +08:00
return;
api.Queue(new PartRoomRequest(joinedRoom.Value));
joinedRoom.Value = null;
2020-12-18 23:15:41 +08:00
}
private readonly HashSet<long> ignoredRooms = new HashSet<long>();
2020-12-18 23:15:41 +08:00
public void AddOrUpdateRoom(Room room)
2020-12-18 23:15:41 +08:00
{
Debug.Assert(ThreadSafety.IsUpdateThread);
Debug.Assert(room.RoomID.Value != null);
if (ignoredRooms.Contains(room.RoomID.Value.Value))
return;
try
2020-12-18 23:15:41 +08:00
{
2021-08-16 12:04:06 +08:00
var existing = rooms.FirstOrDefault(e => e.RoomID.Value == room.RoomID.Value);
if (existing == null)
rooms.Add(room);
else
existing.CopyFrom(room);
2020-12-18 23:15:41 +08:00
}
catch (Exception ex)
2020-12-18 23:15:41 +08:00
{
Logger.Error(ex, $"Failed to update room: {room.Name.Value}.");
2020-12-18 23:15:41 +08:00
ignoredRooms.Add(room.RoomID.Value.Value);
rooms.Remove(room);
2020-12-18 23:15:41 +08:00
}
notifyRoomsUpdated();
2020-12-18 23:15:41 +08:00
}
public void RemoveRoom(Room room)
{
Debug.Assert(ThreadSafety.IsUpdateThread);
rooms.Remove(room);
notifyRoomsUpdated();
}
2020-12-19 01:02:04 +08:00
public void ClearRooms()
{
Debug.Assert(ThreadSafety.IsUpdateThread);
rooms.Clear();
notifyRoomsUpdated();
}
private void notifyRoomsUpdated()
{
Scheduler.AddOnce(invokeRoomsUpdated);
void invokeRoomsUpdated() => RoomsUpdated?.Invoke();
}
2020-12-18 23:15:41 +08:00
}
}