mirror of
https://github.com/osukey/osukey.git
synced 2025-05-17 03:27:21 +09:00
Merge pull request #15740 from peppy/realm-ruleset-setting-short-name
Switch realm ruleset configuration to use ruleset's `ShortName` as key
This commit is contained in:
commit
fe9a03c032
@ -1,8 +1,6 @@
|
|||||||
// Copyright (c) ppy Pty Ltd <contact@ppy.sh>. Licensed under the MIT Licence.
|
// 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.
|
// See the LICENCE file in the repository root for full licence text.
|
||||||
|
|
||||||
using System;
|
|
||||||
using osu.Game.Database;
|
|
||||||
using Realms;
|
using Realms;
|
||||||
|
|
||||||
#nullable enable
|
#nullable enable
|
||||||
@ -10,13 +8,10 @@ using Realms;
|
|||||||
namespace osu.Game.Configuration
|
namespace osu.Game.Configuration
|
||||||
{
|
{
|
||||||
[MapTo(@"RulesetSetting")]
|
[MapTo(@"RulesetSetting")]
|
||||||
public class RealmRulesetSetting : RealmObject, IHasGuidPrimaryKey
|
public class RealmRulesetSetting : RealmObject
|
||||||
{
|
{
|
||||||
[PrimaryKey]
|
|
||||||
public Guid ID { get; set; } = Guid.NewGuid();
|
|
||||||
|
|
||||||
[Indexed]
|
[Indexed]
|
||||||
public int RulesetID { get; set; }
|
public string RulesetName { get; set; } = string.Empty;
|
||||||
|
|
||||||
[Indexed]
|
[Indexed]
|
||||||
public int Variant { get; set; }
|
public int Variant { get; set; }
|
||||||
|
@ -11,6 +11,7 @@ using osu.Framework.Input.Bindings;
|
|||||||
using osu.Framework.Logging;
|
using osu.Framework.Logging;
|
||||||
using osu.Framework.Platform;
|
using osu.Framework.Platform;
|
||||||
using osu.Framework.Statistics;
|
using osu.Framework.Statistics;
|
||||||
|
using osu.Game.Configuration;
|
||||||
using osu.Game.Input.Bindings;
|
using osu.Game.Input.Bindings;
|
||||||
using osu.Game.Models;
|
using osu.Game.Models;
|
||||||
using Realms;
|
using Realms;
|
||||||
@ -31,22 +32,25 @@ namespace osu.Game.Database
|
|||||||
/// </summary>
|
/// </summary>
|
||||||
public readonly string Filename;
|
public readonly string Filename;
|
||||||
|
|
||||||
|
private readonly IDatabaseContextFactory? efContextFactory;
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// Version history:
|
/// Version history:
|
||||||
/// 6 ~2021-10-18 First tracked version.
|
/// 6 ~2021-10-18 First tracked version.
|
||||||
/// 7 2021-10-18 Changed OnlineID fields to non-nullable to add indexing support.
|
/// 7 2021-10-18 Changed OnlineID fields to non-nullable to add indexing support.
|
||||||
/// 8 2021-10-29 Rebind scroll adjust keys to not have control modifier.
|
/// 8 2021-10-29 Rebind scroll adjust keys to not have control modifier.
|
||||||
/// 9 2021-11-04 Converted BeatmapMetadata.Author from string to RealmUser.
|
/// 9 2021-11-04 Converted BeatmapMetadata.Author from string to RealmUser.
|
||||||
|
/// 10 2021-11-22 Use ShortName instead of RulesetID for ruleset settings.
|
||||||
/// </summary>
|
/// </summary>
|
||||||
private const int schema_version = 9;
|
private const int schema_version = 10;
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// Lock object which is held during <see cref="BlockAllOperations"/> sections, blocking context creation during blocking periods.
|
/// Lock object which is held during <see cref="BlockAllOperations"/> sections, blocking context creation during blocking periods.
|
||||||
/// </summary>
|
/// </summary>
|
||||||
private readonly SemaphoreSlim contextCreationLock = new SemaphoreSlim(1);
|
private readonly SemaphoreSlim contextCreationLock = new SemaphoreSlim(1);
|
||||||
|
|
||||||
private static readonly GlobalStatistic<int> refreshes = GlobalStatistics.Get<int>("Realm", "Dirty Refreshes");
|
private static readonly GlobalStatistic<int> refreshes = GlobalStatistics.Get<int>(@"Realm", @"Dirty Refreshes");
|
||||||
private static readonly GlobalStatistic<int> contexts_created = GlobalStatistics.Get<int>("Realm", "Contexts (Created)");
|
private static readonly GlobalStatistic<int> contexts_created = GlobalStatistics.Get<int>(@"Realm", @"Contexts (Created)");
|
||||||
|
|
||||||
private readonly object contextLock = new object();
|
private readonly object contextLock = new object();
|
||||||
private Realm? context;
|
private Realm? context;
|
||||||
@ -56,14 +60,14 @@ namespace osu.Game.Database
|
|||||||
get
|
get
|
||||||
{
|
{
|
||||||
if (!ThreadSafety.IsUpdateThread)
|
if (!ThreadSafety.IsUpdateThread)
|
||||||
throw new InvalidOperationException($"Use {nameof(CreateContext)} when performing realm operations from a non-update thread");
|
throw new InvalidOperationException(@$"Use {nameof(CreateContext)} when performing realm operations from a non-update thread");
|
||||||
|
|
||||||
lock (contextLock)
|
lock (contextLock)
|
||||||
{
|
{
|
||||||
if (context == null)
|
if (context == null)
|
||||||
{
|
{
|
||||||
context = CreateContext();
|
context = CreateContext();
|
||||||
Logger.Log($"Opened realm \"{context.Config.DatabasePath}\" at version {context.Config.SchemaVersion}");
|
Logger.Log(@$"Opened realm ""{context.Config.DatabasePath}"" at version {context.Config.SchemaVersion}");
|
||||||
}
|
}
|
||||||
|
|
||||||
// creating a context will ensure our schema is up-to-date and migrated.
|
// creating a context will ensure our schema is up-to-date and migrated.
|
||||||
@ -72,13 +76,20 @@ namespace osu.Game.Database
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public RealmContextFactory(Storage storage, string filename)
|
/// <summary>
|
||||||
|
/// Construct a new instance of a realm context factory.
|
||||||
|
/// </summary>
|
||||||
|
/// <param name="storage">The game storage which will be used to create the realm backing file.</param>
|
||||||
|
/// <param name="filename">The filename to use for the realm backing file. A ".realm" extension will be added automatically if not specified.</param>
|
||||||
|
/// <param name="efContextFactory">An EF factory used only for migration purposes.</param>
|
||||||
|
public RealmContextFactory(Storage storage, string filename, IDatabaseContextFactory? efContextFactory = null)
|
||||||
{
|
{
|
||||||
this.storage = storage;
|
this.storage = storage;
|
||||||
|
this.efContextFactory = efContextFactory;
|
||||||
|
|
||||||
Filename = filename;
|
Filename = filename;
|
||||||
|
|
||||||
const string realm_extension = ".realm";
|
const string realm_extension = @".realm";
|
||||||
|
|
||||||
if (!Filename.EndsWith(realm_extension, StringComparison.Ordinal))
|
if (!Filename.EndsWith(realm_extension, StringComparison.Ordinal))
|
||||||
Filename += realm_extension;
|
Filename += realm_extension;
|
||||||
@ -232,10 +243,35 @@ namespace osu.Game.Database
|
|||||||
};
|
};
|
||||||
}
|
}
|
||||||
|
|
||||||
|
break;
|
||||||
|
|
||||||
|
case 10:
|
||||||
|
string rulesetSettingClassName = getMappedOrOriginalName(typeof(RealmRulesetSetting));
|
||||||
|
|
||||||
|
var oldSettings = migration.OldRealm.DynamicApi.All(rulesetSettingClassName);
|
||||||
|
var newSettings = migration.NewRealm.All<RealmRulesetSetting>().ToList();
|
||||||
|
|
||||||
|
for (int i = 0; i < newSettings.Count; i++)
|
||||||
|
{
|
||||||
|
dynamic? oldItem = oldSettings.ElementAt(i);
|
||||||
|
var newItem = newSettings.ElementAt(i);
|
||||||
|
|
||||||
|
long rulesetId = oldItem.RulesetID;
|
||||||
|
string? rulesetName = getRulesetShortNameFromLegacyID(rulesetId);
|
||||||
|
|
||||||
|
if (string.IsNullOrEmpty(rulesetName))
|
||||||
|
migration.NewRealm.Remove(newItem);
|
||||||
|
else
|
||||||
|
newItem.RulesetName = rulesetName;
|
||||||
|
}
|
||||||
|
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
private string? getRulesetShortNameFromLegacyID(long rulesetId) =>
|
||||||
|
efContextFactory?.Get().RulesetInfo.FirstOrDefault(r => r.ID == rulesetId)?.ShortName;
|
||||||
|
|
||||||
/// <summary>
|
/// <summary>
|
||||||
/// Flush any active contexts and block any further writes.
|
/// Flush any active contexts and block any further writes.
|
||||||
/// </summary>
|
/// </summary>
|
||||||
@ -250,7 +286,7 @@ namespace osu.Game.Database
|
|||||||
throw new ObjectDisposedException(nameof(RealmContextFactory));
|
throw new ObjectDisposedException(nameof(RealmContextFactory));
|
||||||
|
|
||||||
if (!ThreadSafety.IsUpdateThread)
|
if (!ThreadSafety.IsUpdateThread)
|
||||||
throw new InvalidOperationException($"{nameof(BlockAllOperations)} must be called from the update thread.");
|
throw new InvalidOperationException(@$"{nameof(BlockAllOperations)} must be called from the update thread.");
|
||||||
|
|
||||||
Logger.Log(@"Blocking realm operations.", LoggingTarget.Database);
|
Logger.Log(@"Blocking realm operations.", LoggingTarget.Database);
|
||||||
|
|
||||||
@ -274,7 +310,7 @@ namespace osu.Game.Database
|
|||||||
timeout -= sleep_length;
|
timeout -= sleep_length;
|
||||||
|
|
||||||
if (timeout < 0)
|
if (timeout < 0)
|
||||||
throw new TimeoutException("Took too long to acquire lock");
|
throw new TimeoutException(@"Took too long to acquire lock");
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
catch
|
catch
|
||||||
|
@ -188,7 +188,11 @@ namespace osu.Game
|
|||||||
|
|
||||||
dependencies.Cache(contextFactory = new DatabaseContextFactory(Storage));
|
dependencies.Cache(contextFactory = new DatabaseContextFactory(Storage));
|
||||||
|
|
||||||
dependencies.Cache(realmFactory = new RealmContextFactory(Storage, "client"));
|
runMigrations();
|
||||||
|
|
||||||
|
dependencies.Cache(RulesetStore = new RulesetStore(contextFactory, Storage));
|
||||||
|
|
||||||
|
dependencies.Cache(realmFactory = new RealmContextFactory(Storage, "client", contextFactory));
|
||||||
|
|
||||||
dependencies.CacheAs(Storage);
|
dependencies.CacheAs(Storage);
|
||||||
|
|
||||||
@ -203,8 +207,6 @@ namespace osu.Game
|
|||||||
|
|
||||||
Audio.Samples.PlaybackConcurrency = SAMPLE_CONCURRENCY;
|
Audio.Samples.PlaybackConcurrency = SAMPLE_CONCURRENCY;
|
||||||
|
|
||||||
runMigrations();
|
|
||||||
|
|
||||||
dependencies.Cache(SkinManager = new SkinManager(Storage, contextFactory, Host, Resources, Audio));
|
dependencies.Cache(SkinManager = new SkinManager(Storage, contextFactory, Host, Resources, Audio));
|
||||||
dependencies.CacheAs<ISkinSource>(SkinManager);
|
dependencies.CacheAs<ISkinSource>(SkinManager);
|
||||||
|
|
||||||
@ -227,7 +229,6 @@ namespace osu.Game
|
|||||||
|
|
||||||
var defaultBeatmap = new DummyWorkingBeatmap(Audio, Textures);
|
var defaultBeatmap = new DummyWorkingBeatmap(Audio, Textures);
|
||||||
|
|
||||||
dependencies.Cache(RulesetStore = new RulesetStore(contextFactory, Storage));
|
|
||||||
dependencies.Cache(fileStore = new FileStore(contextFactory, Storage));
|
dependencies.Cache(fileStore = new FileStore(contextFactory, Storage));
|
||||||
|
|
||||||
// ordering is important here to ensure foreign keys rules are not broken in ModelStore.Cleanup()
|
// ordering is important here to ensure foreign keys rules are not broken in ModelStore.Cleanup()
|
||||||
@ -456,7 +457,8 @@ namespace osu.Game
|
|||||||
{
|
{
|
||||||
Key = dkb.Key,
|
Key = dkb.Key,
|
||||||
Value = dkb.StringValue,
|
Value = dkb.StringValue,
|
||||||
RulesetID = dkb.RulesetID.Value,
|
// important: this RulesetStore must be the EF one.
|
||||||
|
RulesetName = RulesetStore.GetRuleset(dkb.RulesetID.Value).ShortName,
|
||||||
Variant = dkb.Variant ?? 0,
|
Variant = dkb.Variant ?? 0,
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
@ -20,16 +20,13 @@ namespace osu.Game.Rulesets.Configuration
|
|||||||
|
|
||||||
private List<RealmRulesetSetting> databasedSettings = new List<RealmRulesetSetting>();
|
private List<RealmRulesetSetting> databasedSettings = new List<RealmRulesetSetting>();
|
||||||
|
|
||||||
private readonly int rulesetId;
|
private readonly string rulesetName;
|
||||||
|
|
||||||
protected RulesetConfigManager(SettingsStore store, RulesetInfo ruleset, int? variant = null)
|
protected RulesetConfigManager(SettingsStore store, RulesetInfo ruleset, int? variant = null)
|
||||||
{
|
{
|
||||||
realmFactory = store?.Realm;
|
realmFactory = store?.Realm;
|
||||||
|
|
||||||
if (realmFactory != null && !ruleset.ID.HasValue)
|
rulesetName = ruleset.ShortName;
|
||||||
throw new InvalidOperationException("Attempted to add databased settings for a non-databased ruleset");
|
|
||||||
|
|
||||||
rulesetId = ruleset.ID ?? -1;
|
|
||||||
|
|
||||||
this.variant = variant ?? 0;
|
this.variant = variant ?? 0;
|
||||||
|
|
||||||
@ -43,7 +40,7 @@ namespace osu.Game.Rulesets.Configuration
|
|||||||
if (realmFactory != null)
|
if (realmFactory != null)
|
||||||
{
|
{
|
||||||
// As long as RulesetConfigCache exists, there is no need to subscribe to realm events.
|
// As long as RulesetConfigCache exists, there is no need to subscribe to realm events.
|
||||||
databasedSettings = realmFactory.Context.All<RealmRulesetSetting>().Where(b => b.RulesetID == rulesetId && b.Variant == variant).ToList();
|
databasedSettings = realmFactory.Context.All<RealmRulesetSetting>().Where(b => b.RulesetName == rulesetName && b.Variant == variant).ToList();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -68,7 +65,7 @@ namespace osu.Game.Rulesets.Configuration
|
|||||||
{
|
{
|
||||||
foreach (var c in changed)
|
foreach (var c in changed)
|
||||||
{
|
{
|
||||||
var setting = realm.All<RealmRulesetSetting>().First(s => s.RulesetID == rulesetId && s.Variant == variant && s.Key == c.ToString());
|
var setting = realm.All<RealmRulesetSetting>().First(s => s.RulesetName == rulesetName && s.Variant == variant && s.Key == c.ToString());
|
||||||
|
|
||||||
setting.Value = ConfigStore[c].ToString();
|
setting.Value = ConfigStore[c].ToString();
|
||||||
}
|
}
|
||||||
@ -94,7 +91,7 @@ namespace osu.Game.Rulesets.Configuration
|
|||||||
{
|
{
|
||||||
Key = lookup.ToString(),
|
Key = lookup.ToString(),
|
||||||
Value = bindable.Value.ToString(),
|
Value = bindable.Value.ToString(),
|
||||||
RulesetID = rulesetId,
|
RulesetName = rulesetName,
|
||||||
Variant = variant,
|
Variant = variant,
|
||||||
};
|
};
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user