ACZ fixes and RT v198.1.0

OpenDreamClient/Rendering/ClientScreenOverlaySystem.cs

@@ -1,28 +1,28 @@
 using OpenDreamShared.Rendering;
 
-namespace OpenDreamClient.Rendering {
-    sealed class ClientScreenOverlaySystem : SharedScreenOverlaySystem {
-        public HashSet<EntityUid> ScreenObjects = new();
+namespace OpenDreamClient.Rendering;
 
-        [Dependency] private IEntityManager _entityManager = default!;
+internal sealed class ClientScreenOverlaySystem : SharedScreenOverlaySystem {
+    public HashSet<EntityUid> ScreenObjects = new();
 
-        public override void Initialize() {
-            SubscribeNetworkEvent<AddScreenObjectEvent>(OnAddScreenObject);
-            SubscribeNetworkEvent<RemoveScreenObjectEvent>(OnRemoveScreenObject);
-        }
+    [Dependency] private readonly IEntityManager _entityManager = default!;
 
-        public override void Shutdown() {
-            ScreenObjects.Clear();
-        }
+    public override void Initialize() {
+        SubscribeNetworkEvent<AddScreenObjectEvent>(OnAddScreenObject);
+        SubscribeNetworkEvent<RemoveScreenObjectEvent>(OnRemoveScreenObject);
+    }
+
+    public override void Shutdown() {
+        ScreenObjects.Clear();
+    }
 
-        private void OnAddScreenObject(AddScreenObjectEvent e) {
-            EntityUid ent = _entityManager.GetEntity(e.ScreenObject);
-            ScreenObjects.Add(ent);
-        }
+    private void OnAddScreenObject(AddScreenObjectEvent e) {
+        EntityUid ent = _entityManager.GetEntity(e.ScreenObject);
+        ScreenObjects.Add(ent);
+    }
 
-        private void OnRemoveScreenObject(RemoveScreenObjectEvent e) {
-            EntityUid ent = _entityManager.GetEntity(e.ScreenObject);
-            ScreenObjects.Remove(ent);
-        }
+    private void OnRemoveScreenObject(RemoveScreenObjectEvent e) {
+        EntityUid ent = _entityManager.GetEntity(e.ScreenObject);
+        ScreenObjects.Remove(ent);
     }
 }

OpenDreamPackaging/DreamPackaging.cs

@@ -1,5 +1,6 @@
 using Robust.Packaging;
 using Robust.Packaging.AssetProcessing;
+using Robust.Packaging.AssetProcessing.Passes;
 
 namespace OpenDreamPackaging;
 
@@ -19,13 +20,21 @@ public static async Task WriteResources(
 
         var inputPass = graph.Input;
 
-        await RobustClientPackaging.WriteClientResources(
-            contentDir,
+        await RobustSharedPackaging.WriteContentAssemblies(
             inputPass,
-            cancel);
+            contentDir,
+            "Content.Client",
+            new[] { "OpenDreamClient", "OpenDreamShared" },
+            cancel: cancel);
 
         await RobustClientPackaging.WriteClientResources(contentDir, inputPass, cancel);
 
+        WriteRscResources(dreamRootDir, resources, inputPass);
+
+        inputPass.InjectFinished();
+    }
+
+    public static void WriteRscResources(string dreamRootDir, string[] resources, AssetPassPipe inputPass) {
         for (var i = 0; i < resources.Length; i++) {
             var resource = resources[i].Replace('\\', Path.DirectorySeparatorChar);
             // The game client only knows a resource ID, so that's what we name the files.
@@ -35,7 +44,5 @@ await RobustClientPackaging.WriteClientResources(
 
             inputPass.InjectFileFromDisk(path, diskPath);
         }
-
-        inputPass.InjectFinished();
     }
 }

OpenDreamRuntime/DreamAczProvider.cs

@@ -0,0 +1,43 @@
+using System.Linq;
+using System.Threading;
+using System.Threading.Tasks;
+using OpenDreamPackaging;
+using Robust.Packaging;
+using Robust.Packaging.AssetProcessing;
+using Robust.Server.ServerStatus;
+
+namespace OpenDreamRuntime;
+
+public sealed class DreamAczProvider : IMagicAczProvider, IFullHybridAczProvider {
+    private readonly IDependencyCollection _dependencies;
+    private readonly string _rootPath;
+    private readonly string[] _resources;
+
+    public DreamAczProvider(IDependencyCollection dependencies, string rootPath, string[] resources) {
+        _dependencies = dependencies;
+        _rootPath = rootPath;
+        _resources = resources;
+    }
+
+    public async Task Package(AssetPass pass, IPackageLogger logger, CancellationToken cancel) {
+        var contentDir = DefaultMagicAczProvider.FindContentRootPath(_dependencies);
+
+        await DreamPackaging.WriteResources(contentDir, _rootPath, _resources, pass, logger, cancel);
+    }
+
+    public Task Package(AssetPass hybridPackageInput, AssetPass output, IPackageLogger logger, CancellationToken cancel) {
+        var clientAssetGraph = new RobustClientAssetGraph();
+        var resourceInput = clientAssetGraph.Input;
+        output.AddDependency(clientAssetGraph.Output);
+        output.AddDependency(hybridPackageInput);
+
+        AssetGraph.CalculateGraph(
+            clientAssetGraph.AllPasses.Concat(new[] { hybridPackageInput, output }).ToArray(),
+            logger);
+
+        DreamPackaging.WriteRscResources(_rootPath, _resources, resourceInput);
+        resourceInput.InjectFinished();
+
+        return Task.CompletedTask;
+    }
+}

OpenDreamRuntime/DreamManager.cs

@@ -116,7 +116,7 @@ public bool LoadJson(string? jsonPath) {
             }
 
             _compiledJson = json;
-            var rootPath = Path.GetDirectoryName(jsonPath)!;
+            var rootPath = Path.GetFullPath(Path.GetDirectoryName(jsonPath)!);
             var resources = _compiledJson.Resources ?? Array.Empty<string>();
             _dreamResourceManager.Initialize(rootPath, resources);
             if(!string.IsNullOrEmpty(_compiledJson.Interface) && !_dreamResourceManager.DoesFileExist(_compiledJson.Interface))
@@ -146,9 +146,9 @@ public bool LoadJson(string? jsonPath) {
 
             _dreamMapManager.LoadMaps(_compiledJson.Maps);
 
-            _statusHost.SetMagicAczProvider(new DreamMagicAczProvider(
-                _dependencyCollection, rootPath, resources
-            ));
+            var aczProvider = new DreamAczProvider(_dependencyCollection, rootPath, resources);
+            _statusHost.SetMagicAczProvider(aczProvider);
+            _statusHost.SetFullHybridAczProvider(aczProvider);
 
             return true;
         }

OpenDreamRuntime/EntryPoint.cs

@@ -25,10 +25,6 @@ public sealed class EntryPoint : GameServer {
         private DreamCommandSystem? _commandSystem;
 
         public override void Init() {
-            IoCManager.Resolve<IStatusHost>().SetMagicAczProvider(new DefaultMagicAczProvider(
-                new DefaultMagicAczInfo("Content.Client", new[] {"OpenDreamClient", "OpenDreamShared"}),
-                IoCManager.Resolve<IDependencyCollection>()));
-
             IComponentFactory componentFactory = IoCManager.Resolve<IComponentFactory>();
             componentFactory.DoAutoRegistrations();
 

OpenDreamRuntime/Rendering/ServerScreenOverlaySystem.cs

@@ -1,39 +1,24 @@
 using OpenDreamRuntime.Objects.Types;
 using OpenDreamShared.Rendering;
 using Robust.Server.GameStates;
-using Robust.Shared.Player;
 
-namespace OpenDreamRuntime.Rendering {
-    public sealed class ServerScreenOverlaySystem : SharedScreenOverlaySystem {
-        private readonly Dictionary<ICommonSession, HashSet<EntityUid>> _sessionToScreenObjects = new();
-        [Dependency] private readonly IEntityManager _entityManager = default!;
+namespace OpenDreamRuntime.Rendering;
 
-        public override void Initialize() {
-            SubscribeLocalEvent<ExpandPvsEvent>(HandleExpandPvsEvent);
-        }
+public sealed class ServerScreenOverlaySystem : SharedScreenOverlaySystem {
+    [Dependency] private readonly IEntityManager _entityManager = default!;
+    [Dependency] private readonly PvsOverrideSystem _pvsOverride = default!;
 
-        public void AddScreenObject(DreamConnection connection, DreamObjectMovable screenObject) {
-            if (!_sessionToScreenObjects.TryGetValue(connection.Session, out var objects)) {
-                objects = new HashSet<EntityUid>();
-                _sessionToScreenObjects.Add(connection.Session, objects);
-            }
+    public void AddScreenObject(DreamConnection connection, DreamObjectMovable screenObject) {
+        _pvsOverride.AddForceSend(screenObject.Entity, connection.Session);
 
-            objects.Add(screenObject.Entity);
-            NetEntity ent = _entityManager.GetNetEntity(screenObject.Entity);
-            RaiseNetworkEvent(new AddScreenObjectEvent(ent), connection.Session.ConnectedClient);
-        }
+        NetEntity ent = _entityManager.GetNetEntity(screenObject.Entity);
+        RaiseNetworkEvent(new AddScreenObjectEvent(ent), connection.Session.ConnectedClient);
+    }
 
-        public void RemoveScreenObject(DreamConnection connection, DreamObjectMovable screenObject) {
-            _sessionToScreenObjects[connection.Session].Remove(screenObject.Entity);
-            NetEntity ent = _entityManager.GetNetEntity(screenObject.Entity);
-            RaiseNetworkEvent(new RemoveScreenObjectEvent(ent), connection.Session.ConnectedClient);
-        }
+    public void RemoveScreenObject(DreamConnection connection, DreamObjectMovable screenObject) {
+        _pvsOverride.RemoveForceSend(screenObject.Entity, connection.Session);
 
-        private void HandleExpandPvsEvent(ref ExpandPvsEvent e) {
-            if (_sessionToScreenObjects.TryGetValue(e.Session, out var objects)) {
-                e.Entities ??= new(objects.Count);
-                e.Entities.AddRange(objects);
-            }
-        }
+        NetEntity ent = _entityManager.GetNetEntity(screenObject.Entity);
+        RaiseNetworkEvent(new RemoveScreenObjectEvent(ent), connection.Session.ConnectedClient);
     }
 }