6
StarHorizon_Public/Content.Server/Maps/MapMigrationSystem.cs
2025-11-05 11:11:22 +03:00

112 lines
3.6 KiB
C#

using System.Diagnostics.CodeAnalysis;
using System.IO;
using System.Linq;
using Robust.Shared.ContentPack;
using Robust.Shared.EntitySerialization.Systems;
using Robust.Shared.Map.Events;
using Robust.Shared.Prototypes;
using Robust.Shared.Serialization.Markdown;
using Robust.Shared.Serialization.Markdown.Mapping;
using Robust.Shared.Serialization.Markdown.Value;
using Robust.Shared.Utility;
namespace Content.Server.Maps;
/// <summary>
/// Performs basic map migration operations by listening for engine <see cref="MapLoaderSystem"/> events.
/// </summary>
public sealed class MapMigrationSystem : EntitySystem
{
#pragma warning disable CS0414
[Dependency] private readonly IPrototypeManager _protoMan = default!;
#pragma warning restore CS0414
[Dependency] private readonly IResourceManager _resMan = default!;
private static readonly string[] MigrationFiles = { "/migration.yml", "/nf_migration.yml", "/sh_migration.yml" }; // Frontier: use array of migration files
public override void Initialize()
{
base.Initialize();
SubscribeLocalEvent<BeforeEntityReadEvent>(OnBeforeReadEvent);
#if DEBUG
if (!TryReadFiles(out var mappings)) // Frontier: TryReadFile<TryReadFiles
return;
// Verify that all of the entries map to valid entity prototypes.
// Delta-V: use list of migrations
foreach (var mapping in mappings)
{
foreach (var node in mapping.Values)
{
var newId = ((ValueDataNode)node).Value;
if (!string.IsNullOrEmpty(newId) && newId != "null")
DebugTools.Assert(_protoMan.HasIndex<EntityPrototype>(newId),
$"{newId} is not an entity prototype.");
}
}
// End Delta-V
#endif
}
// Frontier: wrap single file reader
private bool TryReadFiles([NotNullWhen(true)] out List<MappingDataNode>? mappings)
{
mappings = null;
if (MigrationFiles.Count() <= 0)
return false;
foreach (var migrationFile in MigrationFiles)
{
if (!TryReadFile(migrationFile, out var mapping))
continue;
mappings ??= new();
mappings.Add(mapping);
}
return mappings != null && mappings.Count > 0;
}
// End Frontier
private bool TryReadFile(string migrationFile, [NotNullWhen(true)] out MappingDataNode? mappings) // Frontier: add migrationFile
{
mappings = null;
var path = new ResPath(migrationFile); // Frontier: MigrationFile<migrationFile
if (!_resMan.TryContentFileRead(path, out var stream))
return false;
using var reader = new StreamReader(stream, EncodingHelpers.UTF8);
var documents = DataNodeParser.ParseYamlStream(reader).FirstOrDefault();
if (documents == null)
return false;
mappings = (MappingDataNode) documents.Root;
return true;
}
private void OnBeforeReadEvent(BeforeEntityReadEvent ev)
{
if (!TryReadFiles(out var mappings))
return;
// Delta-V: apply a set of mappings
foreach (var mapping in mappings)
{
foreach (var (key, value) in mapping)
{
if (value is not ValueDataNode valueNode)
continue;
if (string.IsNullOrWhiteSpace(valueNode.Value) || valueNode.Value == "null")
ev.DeletedPrototypes.Add(key);
else
ev.RenamedPrototypes.Add(key, valueNode.Value);
}
}
// End Delta-V
}
}