fixes an issue with transient data handling

This commit is contained in:
rootdarkarchon
2023-02-02 17:42:50 +01:00
parent ede62fabae
commit 9d4d919f0d
5 changed files with 38 additions and 10 deletions

View File

@@ -272,6 +272,12 @@ public class CharacterDataFactory
previousData.CustomizePlusScale = _ipcManager.GetCustomizePlusScale(); previousData.CustomizePlusScale = _ipcManager.GetCustomizePlusScale();
previousData.PalettePlusPalette = _ipcManager.PalettePlusBuildPalette(); previousData.PalettePlusPalette = _ipcManager.PalettePlusBuildPalette();
Logger.Debug("== Static Replacements ==");
foreach (var item in previousData.FileReplacements[objectKind])
{
Logger.Debug(item.ToString());
}
Logger.Debug("Handling transient update for " + objectKind); Logger.Debug("Handling transient update for " + objectKind);
_transientResourceManager.ClearTransientPaths(charaPointer, previousData.FileReplacements[objectKind].SelectMany(c => c.GamePaths).ToList()); _transientResourceManager.ClearTransientPaths(charaPointer, previousData.FileReplacements[objectKind].SelectMany(c => c.GamePaths).ToList());
@@ -281,15 +287,16 @@ public class CharacterDataFactory
ManageSemiTransientData(objectKind, charaPointer); ManageSemiTransientData(objectKind, charaPointer);
var resolvedTransientPaths = GetFileReplacementsFromPaths(); var resolvedTransientPaths = GetFileReplacementsFromPaths();
Logger.Debug("== Transient Replacements ==");
foreach (var replacement in resolvedTransientPaths.Select(c => new FileReplacement(c.Value, c.Key, _fileCacheManager))) foreach (var replacement in resolvedTransientPaths.Select(c => new FileReplacement(c.Value, c.Key, _fileCacheManager)))
{ {
Logger.Debug(replacement.ToString());
previousData.FileReplacements[objectKind].Add(replacement); previousData.FileReplacements[objectKind].Add(replacement);
} }
foreach (var item in previousData.FileReplacements[objectKind]) _transientResourceManager.CleanSemiTransientResources(objectKind, previousData.FileReplacements[objectKind].ToList());
{
Logger.Debug(item.ToString());
}
st.Stop(); st.Stop();
Logger.Verbose("Building " + objectKind + " Data took " + st.ElapsedMilliseconds + "ms"); Logger.Verbose("Building " + objectKind + " Data took " + st.ElapsedMilliseconds + "ms");

View File

@@ -17,7 +17,7 @@ public class CacheCreationService : MediatorSubscriberBase, IDisposable
private Dictionary<ObjectKind, GameObjectHandler> _cachesToCreate = new(); private Dictionary<ObjectKind, GameObjectHandler> _cachesToCreate = new();
private CharacterData _lastCreatedData = new(); private CharacterData _lastCreatedData = new();
private CancellationTokenSource cts = new(); private CancellationTokenSource cts = new();
private List<GameObjectHandler> _playerRelatedObjects; private List<GameObjectHandler> _playerRelatedObjects = new();
public unsafe CacheCreationService(MareMediator mediator, CharacterDataFactory characterDataFactory, IpcManager ipcManager, public unsafe CacheCreationService(MareMediator mediator, CharacterDataFactory characterDataFactory, IpcManager ipcManager,
ApiController apiController, DalamudUtil dalamudUtil) : base(mediator) ApiController apiController, DalamudUtil dalamudUtil) : base(mediator)
@@ -35,14 +35,15 @@ public class CacheCreationService : MediatorSubscriberBase, IDisposable
Mediator.Subscribe<CustomizePlusMessage>(this, (msg) => CustomizePlusChanged((CustomizePlusMessage)msg)); Mediator.Subscribe<CustomizePlusMessage>(this, (msg) => CustomizePlusChanged((CustomizePlusMessage)msg));
Mediator.Subscribe<HeelsOffsetMessage>(this, (msg) => HeelsOffsetChanged((HeelsOffsetMessage)msg)); Mediator.Subscribe<HeelsOffsetMessage>(this, (msg) => HeelsOffsetChanged((HeelsOffsetMessage)msg));
Mediator.Subscribe<PalettePlusMessage>(this, (msg) => PalettePlusChanged((PalettePlusMessage)msg)); Mediator.Subscribe<PalettePlusMessage>(this, (msg) => PalettePlusChanged((PalettePlusMessage)msg));
Mediator.Subscribe<PenumbraModSettingChangedMessage>(this, (msg) => _cachesToCreate.Add(ObjectKind.Player, _playerRelatedObjects.First(p => p.ObjectKind == ObjectKind.Player)));
_playerRelatedObjects = new List<GameObjectHandler>() _playerRelatedObjects.AddRange(new List<GameObjectHandler>()
{ {
new(Mediator, ObjectKind.Player, () => dalamudUtil.PlayerPointer), new(Mediator, ObjectKind.Player, () => dalamudUtil.PlayerPointer),
new(Mediator, ObjectKind.MinionOrMount, () => (IntPtr)((Character*)dalamudUtil.PlayerPointer)->CompanionObject), new(Mediator, ObjectKind.MinionOrMount, () => (IntPtr)((Character*)dalamudUtil.PlayerPointer)->CompanionObject),
new(Mediator, ObjectKind.Pet, () => dalamudUtil.GetPet()), new(Mediator, ObjectKind.Pet, () => dalamudUtil.GetPet()),
new(Mediator, ObjectKind.Companion, () => dalamudUtil.GetCompanion()), new(Mediator, ObjectKind.Companion, () => dalamudUtil.GetCompanion()),
}; });
} }
private void PalettePlusChanged(PalettePlusMessage msg) private void PalettePlusChanged(PalettePlusMessage msg)
@@ -103,6 +104,8 @@ public class CacheCreationService : MediatorSubscriberBase, IDisposable
{ {
Logger.Debug("Cache Creation stored until previous creation finished"); Logger.Debug("Cache Creation stored until previous creation finished");
} }
Mediator.Publish(new PlayerRelatedObjectPointerUpdateMessage(_playerRelatedObjects.Select(f => f.CurrentAddress).ToArray()));
} }
public override void Dispose() public override void Dispose()

View File

@@ -37,6 +37,7 @@ public class IpcManager : MediatorSubscriberBase, IDisposable
private readonly FuncSubscriber<string, string, Dictionary<string, string>, string, int, PenumbraApiEc> _penumbraAddTemporaryMod; private readonly FuncSubscriber<string, string, Dictionary<string, string>, string, int, PenumbraApiEc> _penumbraAddTemporaryMod;
private readonly FuncSubscriber<string[], string[], (string[], string[][])> _penumbraResolvePaths; private readonly FuncSubscriber<string[], string[], (string[], string[][])> _penumbraResolvePaths;
private readonly FuncSubscriber<bool> _penumbraEnabled; private readonly FuncSubscriber<bool> _penumbraEnabled;
private readonly EventSubscriber<ModSettingChange, string, string, bool> _penumbraModSettingChanged;
private readonly EventSubscriber<nint, string, string> _penumbraGameObjectResourcePathResolved; private readonly EventSubscriber<nint, string, string> _penumbraGameObjectResourcePathResolved;
private readonly ICallGateSubscriber<string> _heelsGetApiVersion; private readonly ICallGateSubscriber<string> _heelsGetApiVersion;
@@ -84,6 +85,11 @@ public class IpcManager : MediatorSubscriberBase, IDisposable
_penumbraAssignTemporaryCollection = Penumbra.Api.Ipc.AssignTemporaryCollection.Subscriber(pi); _penumbraAssignTemporaryCollection = Penumbra.Api.Ipc.AssignTemporaryCollection.Subscriber(pi);
_penumbraResolvePaths = Penumbra.Api.Ipc.ResolvePlayerPaths.Subscriber(pi); _penumbraResolvePaths = Penumbra.Api.Ipc.ResolvePlayerPaths.Subscriber(pi);
_penumbraEnabled = Penumbra.Api.Ipc.GetEnabledState.Subscriber(pi); _penumbraEnabled = Penumbra.Api.Ipc.GetEnabledState.Subscriber(pi);
_penumbraModSettingChanged = Penumbra.Api.Ipc.ModSettingChanged.Subscriber(pi, (change, arg1, arg, b) =>
{
if (change == ModSettingChange.EnableState)
Mediator.Publish(new PenumbraModSettingChangedMessage());
});
_penumbraGameObjectResourcePathResolved = Penumbra.Api.Ipc.GameObjectResourcePathResolved.Subscriber(pi, (ptr, arg1, arg2) => ResourceLoaded((IntPtr)ptr, arg1, arg2)); _penumbraGameObjectResourcePathResolved = Penumbra.Api.Ipc.GameObjectResourcePathResolved.Subscriber(pi, (ptr, arg1, arg2) => ResourceLoaded((IntPtr)ptr, arg1, arg2));
@@ -258,6 +264,7 @@ public class IpcManager : MediatorSubscriberBase, IDisposable
ActionQueue.Clear(); ActionQueue.Clear();
_penumbraModSettingChanged.Dispose();
_penumbraGameObjectResourcePathResolved.Dispose(); _penumbraGameObjectResourcePathResolved.Dispose();
_penumbraDispose.Dispose(); _penumbraDispose.Dispose();
_penumbraInit.Dispose(); _penumbraInit.Dispose();

View File

@@ -1,6 +1,7 @@
using MareSynchronos.API.Data.Enum; using MareSynchronos.API.Data.Enum;
using MareSynchronos.MareConfiguration; using MareSynchronos.MareConfiguration;
using MareSynchronos.Mediator; using MareSynchronos.Mediator;
using MareSynchronos.Models;
using MareSynchronos.Utils; using MareSynchronos.Utils;
using System.Collections.Concurrent; using System.Collections.Concurrent;
@@ -83,11 +84,21 @@ public class TransientResourceManager : MediatorSubscriberBase, IDisposable
} }
} }
public void CleanSemiTransientResources(ObjectKind objectKind) public void CleanSemiTransientResources(ObjectKind objectKind, List<FileReplacement>? fileReplacement = null)
{ {
if (SemiTransientResources.ContainsKey(objectKind)) if (SemiTransientResources.ContainsKey(objectKind))
{
if (fileReplacement == null)
{ {
SemiTransientResources[objectKind].Clear(); SemiTransientResources[objectKind].Clear();
return;
}
foreach (var replacement in fileReplacement.Where(p => !p.HasFileReplacement).SelectMany(p => p.GamePaths).ToList())
{
SemiTransientResources[objectKind].RemoveWhere(p => string.Equals(p, replacement, StringComparison.OrdinalIgnoreCase));
}
} }
} }

View File

@@ -3,7 +3,7 @@
<PropertyGroup> <PropertyGroup>
<Authors></Authors> <Authors></Authors>
<Company></Company> <Company></Company>
<Version>0.7.14</Version> <Version>0.7.15</Version>
<Description></Description> <Description></Description>
<Copyright></Copyright> <Copyright></Copyright>
<PackageProjectUrl>https://github.com/Penumbra-Sync/client</PackageProjectUrl> <PackageProjectUrl>https://github.com/Penumbra-Sync/client</PackageProjectUrl>