Add support for creating, joining, and parting osu!web rooms via interop

SampleMultiplayerClient/MultiplayerClient.cs

@@ -61,15 +61,14 @@ public MultiplayerClient(HubConnection connection, int userId)
 
         public MultiplayerRoom? Room { get; private set; }
 
+        public Task<MultiplayerRoom> CreateRoom(MultiplayerRoom room)
+            => connection.InvokeAsync<MultiplayerRoom>(nameof(IMultiplayerServer.CreateRoom), room);
+
         public async Task<MultiplayerRoom> JoinRoom(long roomId)
-        {
-            return await JoinRoomWithPassword(roomId, string.Empty);
-        }
+            => await JoinRoomWithPassword(roomId, string.Empty);
 
         public async Task<MultiplayerRoom> JoinRoomWithPassword(long roomId, string? password = null)
-        {
-            return Room = await connection.InvokeAsync<MultiplayerRoom>(nameof(IMultiplayerServer.JoinRoomWithPassword), roomId, password ?? string.Empty);
-        }
+            => Room = await connection.InvokeAsync<MultiplayerRoom>(nameof(IMultiplayerServer.JoinRoomWithPassword), roomId, password ?? string.Empty);
 
         public async Task LeaveRoom()
         {

osu.Server.Spectator.Tests/Multiplayer/MultiplayerTest.cs

@@ -16,6 +16,7 @@
 using osu.Server.Spectator.Database.Models;
 using osu.Server.Spectator.Entities;
 using osu.Server.Spectator.Hubs.Multiplayer;
+using osu.Server.Spectator.Services;
 
 namespace osu.Server.Spectator.Tests.Multiplayer
 {
@@ -130,13 +131,16 @@ protected MultiplayerTest()
             loggerFactoryMock.Setup(factory => factory.CreateLogger(It.IsAny<string>()))
                              .Returns(new Mock<ILogger>().Object);
 
+            var legacyIOMock = new Mock<ILegacyIO>();
+
             Hub = new TestMultiplayerHub(
                 loggerFactoryMock.Object,
                 Rooms,
                 UserStates,
                 DatabaseFactory.Object,
                 new ChatFilters(DatabaseFactory.Object),
-                hubContext.Object);
+                hubContext.Object,
+                legacyIOMock.Object);
             Hub.Groups = Groups.Object;
             Hub.Clients = Clients.Object;
 

osu.Server.Spectator.Tests/Multiplayer/TestMultiplayerHub.cs

@@ -6,6 +6,7 @@
 using osu.Server.Spectator.Database;
 using osu.Server.Spectator.Entities;
 using osu.Server.Spectator.Hubs.Multiplayer;
+using osu.Server.Spectator.Services;
 
 namespace osu.Server.Spectator.Tests.Multiplayer
 {
@@ -19,8 +20,9 @@ public TestMultiplayerHub(
             EntityStore<MultiplayerClientState> users,
             IDatabaseFactory databaseFactory,
             ChatFilters chatFilters,
-            IHubContext<MultiplayerHub> hubContext)
-            : base(loggerFactory, rooms, users, databaseFactory, chatFilters, hubContext)
+            IHubContext<MultiplayerHub> hubContext,
+            ILegacyIO legacyIO)
+            : base(loggerFactory, rooms, users, databaseFactory, chatFilters, hubContext, legacyIO)
         {
         }
 

osu.Server.Spectator.sln.DotSettings

@@ -354,6 +354,7 @@
 	<s:String x:Key="/Default/CodeStyle/Naming/CSharpNaming/Abbreviations/=HUD/@EntryIndexedValue">HUD</s:String>
 	<s:String x:Key="/Default/CodeStyle/Naming/CSharpNaming/Abbreviations/=ID/@EntryIndexedValue">ID</s:String>
 	<s:String x:Key="/Default/CodeStyle/Naming/CSharpNaming/Abbreviations/=IL/@EntryIndexedValue">IL</s:String>
+	<s:String x:Key="/Default/CodeStyle/Naming/CSharpNaming/Abbreviations/=IO/@EntryIndexedValue">IO</s:String>
 	<s:String x:Key="/Default/CodeStyle/Naming/CSharpNaming/Abbreviations/=IOS/@EntryIndexedValue">IOS</s:String>
 	<s:String x:Key="/Default/CodeStyle/Naming/CSharpNaming/Abbreviations/=IP/@EntryIndexedValue">IP</s:String>
 	<s:String x:Key="/Default/CodeStyle/Naming/CSharpNaming/Abbreviations/=IPC/@EntryIndexedValue">IPC</s:String>

osu.Server.Spectator/AppSettings.cs

@@ -34,6 +34,9 @@ public static class AppSettings
         public static string DatabaseUser { get; }
         public static string DatabasePort { get; }
 
+        public static string LegacyIODomain { get; }
+        public static string SharedInteropSecret { get; }
+
         static AppSettings()
         {
             SaveReplays = Environment.GetEnvironmentVariable("SAVE_REPLAYS") == "1";
@@ -53,6 +56,14 @@ static AppSettings()
             DatabaseHost = Environment.GetEnvironmentVariable("DB_HOST") ?? "localhost";
             DatabaseUser = Environment.GetEnvironmentVariable("DB_USER") ?? "osuweb";
             DatabasePort = Environment.GetEnvironmentVariable("DB_PORT") ?? "3306";
+
+            LegacyIODomain = Environment.GetEnvironmentVariable("LEGACY_IO_DOMAIN")
+                             ?? throw new InvalidOperationException("LEGACY_IO_DOMAIN environment variable not set. "
+                                                                    + "Please set the value of this variable to the root URL of the osu-web instance to which legacy IO call should be submitted.");
+
+            SharedInteropSecret = Environment.GetEnvironmentVariable("SHARED_INTEROP_SECRET")
+                                  ?? throw new InvalidOperationException("SHARED_INTEROP_SECRET environment variable not set. "
+                                                                         + "Please set the value of this variable to the value of the same environment variable that the target osu-web instance specifies in `.env`.");
         }
     }
 }

osu.Server.Spectator/Extensions/ServiceCollectionExtensions.cs

@@ -8,6 +8,7 @@
 using osu.Server.Spectator.Hubs.Metadata;
 using osu.Server.Spectator.Hubs.Multiplayer;
 using osu.Server.Spectator.Hubs.Spectator;
+using osu.Server.Spectator.Services;
 using osu.Server.Spectator.Storage;
 using StackExchange.Redis;
 
@@ -17,7 +18,9 @@ public static class ServiceCollectionExtensions
     {
         public static IServiceCollection AddHubEntities(this IServiceCollection serviceCollection)
         {
-            return serviceCollection.AddSingleton<EntityStore<SpectatorClientState>>()
+            return serviceCollection.AddHttpClient()
+                                    .AddTransient<ILegacyIO, LegacyIO>()
+                                    .AddSingleton<EntityStore<SpectatorClientState>>()
                                     .AddSingleton<EntityStore<MultiplayerClientState>>()
                                     .AddSingleton<EntityStore<ServerMultiplayerRoom>>()
                                     .AddSingleton<EntityStore<ConnectionState>>()

osu.Server.Spectator/Hubs/Multiplayer/MultiplayerHub.cs

@@ -16,6 +16,7 @@
 using osu.Server.Spectator.Database.Models;
 using osu.Server.Spectator.Entities;
 using osu.Server.Spectator.Extensions;
+using osu.Server.Spectator.Services;
 
 namespace osu.Server.Spectator.Hubs.Multiplayer
 {
@@ -25,34 +26,44 @@ public class MultiplayerHub : StatefulUserHub<IMultiplayerClient, MultiplayerCli
         protected readonly MultiplayerHubContext HubContext;
         private readonly IDatabaseFactory databaseFactory;
         private readonly ChatFilters chatFilters;
+        private readonly ILegacyIO legacyIO;
 
         public MultiplayerHub(
             ILoggerFactory loggerFactory,
             EntityStore<ServerMultiplayerRoom> rooms,
             EntityStore<MultiplayerClientState> users,
             IDatabaseFactory databaseFactory,
             ChatFilters chatFilters,
-            IHubContext<MultiplayerHub> hubContext)
+            IHubContext<MultiplayerHub> hubContext,
+            ILegacyIO legacyIO)
             : base(loggerFactory, users)
         {
             Rooms = rooms;
             this.databaseFactory = databaseFactory;
             this.chatFilters = chatFilters;
+            this.legacyIO = legacyIO;
             HubContext = new MultiplayerHubContext(hubContext, rooms, users, databaseFactory, loggerFactory);
         }
 
+        public async Task<MultiplayerRoom> CreateRoom(MultiplayerRoom room)
+        {
+            Log($"{Context.GetUserId()} creating room");
+            return await JoinRoomWithPassword(await legacyIO.CreateRoom(Context.GetUserId(), room), room.Settings.Password);
+        }
+
         public Task<MultiplayerRoom> JoinRoom(long roomId) => JoinRoomWithPassword(roomId, string.Empty);
 
         public async Task<MultiplayerRoom> JoinRoomWithPassword(long roomId, string password)
         {
             Log($"Attempting to join room {roomId}");
 
-            bool isRestricted;
             using (var db = databaseFactory.GetInstance())
-                isRestricted = await db.IsUserRestrictedAsync(Context.GetUserId());
+            {
+                if (await db.IsUserRestrictedAsync(Context.GetUserId()))
+                    throw new InvalidStateException("Can't join a room when restricted.");
+            }
 
-            if (isRestricted)
-                throw new InvalidStateException("Can't join a room when restricted.");
+            await legacyIO.JoinRoom(roomId, Context.GetUserId());
 
             using (var userUsage = await GetOrCreateLocalUserState())
             {
@@ -720,8 +731,8 @@ private async Task removeDatabaseUser(MultiplayerRoom room, MultiplayerRoomUser
 
         protected override async Task CleanUpState(MultiplayerClientState state)
         {
-            await leaveRoom(state, true);
             await base.CleanUpState(state);
+            await leaveRoom(state, true);
         }
 
         private async Task setNewHost(MultiplayerRoom room, MultiplayerRoomUser newHost)
@@ -883,6 +894,8 @@ private async Task<ItemUsage<ServerMultiplayerRoom>> getLocalUserRoom(Multiplaye
 
         private async Task leaveRoom(MultiplayerClientState state, bool wasKick)
         {
+            await legacyIO.PartRoom(state.CurrentRoomID, state.UserId);
+
             using (var roomUsage = await getLocalUserRoom(state))
                 await leaveRoom(state, roomUsage, wasKick);
         }

osu.Server.Spectator/Services/ILegacyIO.cs

@@ -0,0 +1,33 @@
+// Copyright (c) ppy Pty Ltd <[email protected]>. Licensed under the MIT Licence.
+// See the LICENCE file in the repository root for full licence text.
+
+using System.Threading.Tasks;
+using osu.Game.Online.Multiplayer;
+
+namespace osu.Server.Spectator.Services
+{
+    public interface ILegacyIO
+    {
+        /// <summary>
+        /// Creates an osu!web Room.
+        /// </summary>
+        /// <param name="userId">The ID of the user that wants to create the room.</param>
+        /// <param name="room">The room.</param>
+        /// <returns>The room's ID.</returns>
+        Task<long> CreateRoom(int userId, MultiplayerRoom room);
+
+        /// <summary>
+        /// Joins an osu!web Room.
+        /// </summary>
+        /// <param name="roomId">The ID of the room to join.</param>
+        /// <param name="userId">The ID of the user wanting to join the room.</param>
+        Task JoinRoom(long roomId, int userId);
+
+        /// <summary>
+        /// Parts an osu!web Room.
+        /// </summary>
+        /// <param name="roomId">The ID of the room to part.</param>
+        /// <param name="userId">The ID of the user wanting to part the room.</param>
+        Task PartRoom(long roomId, int userId);
+    }
+}