add moodles integration (temporary)

MareSynchronos/PlayerData/Data/CharacterData.cs

@@ -2,8 +2,6 @@
 
 using MareSynchronos.API.Data.Enum;
 
-using System.Text;
-
 namespace MareSynchronos.PlayerData.Data;
 
 public class CharacterData
@@ -16,6 +14,7 @@ public class CharacterData
     public string HeelsData { get; set; } = string.Empty;
     public string HonorificData { get; set; } = string.Empty;
     public string ManipulationString { get; set; } = string.Empty;
+    public string MoodlesData { get; set; } = string.Empty;
 
     public API.Data.CharacterData ToAPI()
     {
@@ -44,17 +43,8 @@ public class CharacterData
             ManipulationData = ManipulationString,
             HeelsData = HeelsData,
             CustomizePlusData = CustomizePlusScale.ToDictionary(d => d.Key, d => d.Value),
-            HonorificData = HonorificData
+            HonorificData = HonorificData,
+            PalettePlusData = MoodlesData
         };
     }
-
-    public override string ToString()
-    {
-        StringBuilder stringBuilder = new();
-        foreach (var fileReplacement in FileReplacements.SelectMany(k => k.Value).OrderBy(a => a.GamePaths.First(), StringComparer.Ordinal))
-        {
-            stringBuilder.Append(fileReplacement).AppendLine();
-        }
-        return stringBuilder.ToString();
-    }
 }

MareSynchronos/PlayerData/Data/PlayerChanges.cs

@@ -8,5 +8,6 @@ public enum PlayerChanges
     Customize = 4,
     Heels = 5,
     Honorific = 7,
-    ForcedRedraw = 8,
+    Moodles = 8,
+    ForcedRedraw = 9,
 }

MareSynchronos/PlayerData/Factories/PlayerDataFactory.cs

@@ -207,6 +207,10 @@ public class PlayerDataFactory
         _logger.LogDebug("Honorific is now: {data}", previousData.HonorificData);
         previousData.HeelsData = await getHeelsOffset.ConfigureAwait(false);
         _logger.LogDebug("Heels is now: {heels}", previousData.HeelsData);
+        if (objectKind == ObjectKind.Player)
+        {
+            previousData.MoodlesData = await _ipcManager.Moodles.GetStatusAsync(playerRelatedObject.Address).ConfigureAwait(false) ?? string.Empty;
+        }
 
         if (previousData.FileReplacements.TryGetValue(objectKind, out HashSet<FileReplacement>? fileReplacements))
         {

MareSynchronos/PlayerData/Handlers/PairHandler.cs

@@ -334,6 +334,10 @@ public sealed class PairHandler : DisposableMediatorSubscriberBase
                         }
                         break;
 
+                    case PlayerChanges.Moodles:
+                        await _ipcManager.Moodles.SetStatusAsync(handler.Address, charaData.PalettePlusData).ConfigureAwait(false);
+                        break;
+
                     case PlayerChanges.ForcedRedraw:
                         await _ipcManager.Penumbra.RedrawAsync(Logger, handler, applicationId, token).ConfigureAwait(false);
                         break;
@@ -555,6 +559,8 @@ public sealed class PairHandler : DisposableMediatorSubscriberBase
             tempHandler.CompareNameAndThrow(name);
             Logger.LogDebug("[{applicationId}] Restoring Honorific for {alias}/{name}", applicationId, OnlineUser.User.AliasOrUID, name);
             await _ipcManager.Honorific.ClearTitleAsync(address).ConfigureAwait(false);
+            Logger.LogDebug("[{applicationId}] Restoring Moodles for {alias}/{name}", applicationId, OnlineUser.User.AliasOrUID, name);
+            await _ipcManager.Moodles.RevertStatusAsync(address).ConfigureAwait(false);
         }
         else if (objectKind == ObjectKind.MinionOrMount)
         {

MareSynchronos/PlayerData/Pairs/OptionalPluginWarning.cs

@@ -5,4 +5,5 @@ public record OptionalPluginWarning
     public bool ShownHeelsWarning { get; set; } = false;
     public bool ShownCustomizePlusWarning { get; set; } = false;
     public bool ShownHonorificWarning { get; set; } = false;
+    public bool ShownMoodlesWarning { get; set; } = false;
 }

MareSynchronos/PlayerData/Services/CacheCreationService.cs

@@ -20,6 +20,7 @@ public sealed class CacheCreationService : DisposableMediatorSubscriberBase
     private readonly Dictionary<ObjectKind, GameObjectHandler> _playerRelatedObjects = [];
     private Task? _cacheCreationTask;
     private CancellationTokenSource _honorificCts = new();
+    private CancellationTokenSource _moodlesCts = new();
     private bool _isZoning = false;
     private readonly Dictionary<ObjectKind, CancellationTokenSource> _glamourerCts = new();
 
@@ -108,6 +109,16 @@ public sealed class CacheCreationService : DisposableMediatorSubscriberBase
                 HonorificChanged();
             }
         });
+        Mediator.Subscribe<MoodlesMessage>(this, (msg) =>
+        {
+            if (_isZoning) return;
+            var changedType = _playerRelatedObjects.FirstOrDefault(f => f.Value.Address == msg.Address);
+            if (!default(KeyValuePair<ObjectKind, GameObjectHandler>).Equals(changedType) && changedType.Key == ObjectKind.Player)
+            {
+                Logger.LogDebug("Received Moodles change, updating player");
+                MoodlesChanged();
+            }
+        });
         Mediator.Subscribe<PenumbraModSettingChangedMessage>(this, async (msg) =>
         {
             Logger.LogDebug("Received Penumbra Mod settings change, updating player");
@@ -162,6 +173,21 @@ public sealed class CacheCreationService : DisposableMediatorSubscriberBase
             await AddPlayerCacheToCreate().ConfigureAwait(false);
         }, token);
     }
+
+    private void MoodlesChanged()
+    {
+        _moodlesCts?.Cancel();
+        _moodlesCts?.Dispose();
+        _moodlesCts = new();
+        var token = _moodlesCts.Token;
+
+        _ = Task.Run(async () =>
+        {
+            await Task.Delay(TimeSpan.FromSeconds(2), token).ConfigureAwait(false);
+            await AddPlayerCacheToCreate().ConfigureAwait(false);
+        }, token);
+    }
+
     private void ProcessCacheCreation()
     {
         if (_isZoning) return;