1
0
mirror of https://github.com/ppy/osu synced 2024-12-28 18:02:53 +00:00
osu/osu.Game/Screens/Multi/RoomManager.cs

338 lines
10 KiB
C#
Raw Normal View History

// 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.
2018-12-20 11:58:34 +00:00
using System;
using System.Collections.Generic;
using System.Diagnostics;
2018-12-12 10:04:11 +00:00
using System.Linq;
using System.Threading.Tasks;
using osu.Framework.Allocation;
2019-02-21 10:04:31 +00:00
using osu.Framework.Bindables;
using osu.Framework.Graphics;
using osu.Framework.Graphics.Containers;
2018-12-12 10:04:11 +00:00
using osu.Framework.Logging;
using osu.Game.Beatmaps;
using osu.Game.Online;
using osu.Game.Online.API;
using osu.Game.Online.Multiplayer;
2018-12-12 10:04:11 +00:00
using osu.Game.Rulesets;
using osu.Game.Screens.Multi.Lounge.Components;
namespace osu.Game.Screens.Multi
{
public class RoomManager : CompositeDrawable, IRoomManager
{
2018-12-27 16:45:19 +00:00
public event Action RoomsUpdated;
2019-01-07 09:50:27 +00:00
private readonly BindableList<Room> rooms = new BindableList<Room>();
public Bindable<bool> InitialRoomsReceived { get; } = new Bindable<bool>();
2019-01-07 09:50:27 +00:00
public IBindableList<Room> Rooms => rooms;
public double TimeBetweenListingPolls
{
get => listingPollingComponent.TimeBetweenPolls;
set => listingPollingComponent.TimeBetweenPolls = value;
}
public double TimeBetweenSelectionPolls
{
get => selectionPollingComponent.TimeBetweenPolls;
set => selectionPollingComponent.TimeBetweenPolls = value;
}
2019-02-08 05:57:51 +00:00
[Resolved]
private RulesetStore rulesets { get; set; }
2019-02-08 04:02:17 +00:00
[Resolved]
private BeatmapManager beatmaps { get; set; }
2018-12-12 10:04:11 +00:00
[Resolved]
private IAPIProvider api { get; set; }
2018-12-12 10:04:11 +00:00
[Resolved]
private Bindable<Room> selectedRoom { get; set; }
private readonly ListingPollingComponent listingPollingComponent;
private readonly SelectionPollingComponent selectionPollingComponent;
private Room joinedRoom;
2018-12-12 10:04:11 +00:00
public RoomManager()
{
RelativeSizeAxes = Axes.Both;
InternalChildren = new Drawable[]
{
listingPollingComponent = new ListingPollingComponent
{
InitialRoomsReceived = { BindTarget = InitialRoomsReceived },
RoomsReceived = onListingReceived
},
2020-02-27 11:05:12 +00:00
selectionPollingComponent = new SelectionPollingComponent { RoomReceived = onSelectedRoomReceived }
};
}
2018-12-26 11:12:51 +00:00
protected override void Dispose(bool isDisposing)
{
base.Dispose(isDisposing);
PartRoom();
}
public void CreateRoom(Room room, Action<Room> onSuccess = null, Action<string> onError = null)
{
2019-02-21 09:56:34 +00:00
room.Host.Value = api.LocalUser.Value;
2018-12-12 10:04:11 +00:00
var req = new CreateRoomRequest(room);
2018-12-26 11:32:01 +00:00
req.Success += result =>
{
2019-02-08 06:20:11 +00:00
joinedRoom = room;
update(room, result);
addRoom(room);
2018-12-27 16:45:19 +00:00
2019-02-08 06:20:11 +00:00
RoomsUpdated?.Invoke();
onSuccess?.Invoke(room);
2018-12-26 11:32:01 +00:00
};
2018-12-26 09:38:58 +00:00
req.Failure += exception =>
{
if (req.Result != null)
onError?.Invoke(req.Result.Error);
else
Logger.Log($"Failed to create the room: {exception}", level: LogLevel.Important);
};
2018-12-20 11:58:34 +00:00
2018-12-12 10:04:11 +00:00
api.Queue(req);
}
2018-12-20 11:58:34 +00:00
private JoinRoomRequest currentJoinRoomRequest;
public void JoinRoom(Room room, Action<Room> onSuccess = null, Action<string> onError = null)
2018-12-20 11:58:34 +00:00
{
currentJoinRoomRequest?.Cancel();
currentJoinRoomRequest = new JoinRoomRequest(room);
2019-10-30 05:41:54 +00:00
2018-12-20 11:58:34 +00:00
currentJoinRoomRequest.Success += () =>
{
2019-02-08 06:20:11 +00:00
joinedRoom = room;
onSuccess?.Invoke(room);
2018-12-20 11:58:34 +00:00
};
currentJoinRoomRequest.Failure += exception =>
{
2019-10-30 05:38:06 +00:00
if (!(exception is OperationCanceledException))
Logger.Log($"Failed to join room: {exception}", level: LogLevel.Important);
onError?.Invoke(exception.ToString());
};
2018-12-20 11:58:34 +00:00
api.Queue(currentJoinRoomRequest);
}
public void PartRoom()
{
2019-10-30 05:41:54 +00:00
currentJoinRoomRequest?.Cancel();
if (joinedRoom == null)
2018-12-20 11:58:34 +00:00
return;
api.Queue(new PartRoomRequest(joinedRoom));
joinedRoom = null;
2018-12-20 11:58:34 +00:00
}
private readonly HashSet<int> ignoredRooms = new HashSet<int>();
/// <summary>
/// Invoked when the listing of all <see cref="Room"/>s is received from the server.
/// </summary>
/// <param name="listing">The listing.</param>
2020-02-27 11:05:12 +00:00
private void onListingReceived(List<Room> listing)
{
// Remove past matches
foreach (var r in rooms.ToList())
{
if (listing.All(e => e.RoomID.Value != r.RoomID.Value))
rooms.Remove(r);
}
for (int i = 0; i < listing.Count; i++)
{
if (selectedRoom.Value?.RoomID?.Value == listing[i].RoomID.Value)
{
// The listing request contains less data than the selection request, so data from the selection request is always preferred while the room is selected.
continue;
}
var room = listing[i];
Debug.Assert(room.RoomID.Value != null);
if (ignoredRooms.Contains(room.RoomID.Value.Value))
continue;
room.Position.Value = i;
2020-06-26 15:16:16 +00:00
try
{
update(room, room);
addRoom(room);
2020-06-26 15:16:16 +00:00
}
catch (Exception ex)
{
Logger.Error(ex, $"Failed to update room: {room.Name.Value}.");
ignoredRooms.Add(room.RoomID.Value.Value);
rooms.Remove(room);
2020-06-26 15:16:16 +00:00
}
}
2018-12-12 10:04:11 +00:00
RoomsUpdated?.Invoke();
}
/// <summary>
/// Invoked when a <see cref="Room"/> is received from the server.
/// </summary>
/// <param name="toUpdate">The received <see cref="Room"/>.</param>
2020-02-27 11:05:12 +00:00
private void onSelectedRoomReceived(Room toUpdate)
{
foreach (var room in rooms)
{
if (room.RoomID.Value == toUpdate.RoomID.Value)
{
toUpdate.Position.Value = room.Position.Value;
update(room, toUpdate);
break;
}
}
2018-12-12 10:04:11 +00:00
}
2018-12-26 11:32:01 +00:00
/// <summary>
/// Updates a local <see cref="Room"/> with a remote copy.
/// </summary>
/// <param name="local">The local <see cref="Room"/> to update.</param>
/// <param name="remote">The remote <see cref="Room"/> to update with.</param>
private void update(Room local, Room remote)
2018-12-12 10:04:11 +00:00
{
2018-12-26 11:32:01 +00:00
foreach (var pi in remote.Playlist)
pi.MapObjects(beatmaps, rulesets);
2018-12-26 13:14:49 +00:00
2018-12-27 04:30:36 +00:00
local.CopyFrom(remote);
2018-12-12 10:04:11 +00:00
}
2018-12-26 11:32:01 +00:00
/// <summary>
/// Adds a <see cref="Room"/> to the list of available rooms.
/// </summary>
2019-04-25 08:36:17 +00:00
/// <param name="room">The <see cref="Room"/> to add.</param>
2018-12-26 11:32:01 +00:00
private void addRoom(Room room)
{
2018-12-26 11:32:01 +00:00
var existing = rooms.FirstOrDefault(e => e.RoomID.Value == room.RoomID.Value);
if (existing == null)
rooms.Add(room);
else
existing.CopyFrom(room);
}
private class SelectionPollingComponent : PollingComponent
{
public Action<Room> RoomReceived;
[Resolved]
private IAPIProvider api { get; set; }
[Resolved]
private Bindable<Room> selectedRoom { get; set; }
[BackgroundDependencyLoader]
private void load()
{
selectedRoom.BindValueChanged(_ =>
{
if (IsLoaded)
PollImmediately();
});
}
private GetRoomRequest pollReq;
protected override Task Poll()
{
if (!api.IsLoggedIn)
return base.Poll();
if (selectedRoom.Value?.RoomID.Value == null)
return base.Poll();
var tcs = new TaskCompletionSource<bool>();
pollReq?.Cancel();
pollReq = new GetRoomRequest(selectedRoom.Value.RoomID.Value.Value);
pollReq.Success += result =>
{
RoomReceived?.Invoke(result);
tcs.SetResult(true);
};
pollReq.Failure += _ => tcs.SetResult(false);
api.Queue(pollReq);
return tcs.Task;
}
}
private class ListingPollingComponent : PollingComponent
{
public Action<List<Room>> RoomsReceived;
public readonly Bindable<bool> InitialRoomsReceived = new Bindable<bool>();
[Resolved]
private IAPIProvider api { get; set; }
[Resolved]
private Bindable<FilterCriteria> currentFilter { get; set; }
[BackgroundDependencyLoader]
private void load()
{
currentFilter.BindValueChanged(_ =>
{
InitialRoomsReceived.Value = false;
if (IsLoaded)
PollImmediately();
});
}
private GetRoomsRequest pollReq;
protected override Task Poll()
{
if (!api.IsLoggedIn)
return base.Poll();
var tcs = new TaskCompletionSource<bool>();
pollReq?.Cancel();
pollReq = new GetRoomsRequest(currentFilter.Value.StatusFilter, currentFilter.Value.RoomCategoryFilter);
pollReq.Success += result =>
{
InitialRoomsReceived.Value = true;
RoomsReceived?.Invoke(result);
tcs.SetResult(true);
};
pollReq.Failure += _ => tcs.SetResult(false);
api.Queue(pollReq);
return tcs.Task;
}
}
}
}