120 lines
3.9 KiB
C#
120 lines
3.9 KiB
C#
using Dalamud.Plugin;
|
|
using Dalamud.Plugin.Ipc;
|
|
using LightlessSync.Interop.Ipc.Framework;
|
|
using LightlessSync.Services;
|
|
using LightlessSync.Services.Mediator;
|
|
using Microsoft.Extensions.Logging;
|
|
|
|
namespace LightlessSync.Interop.Ipc;
|
|
|
|
public sealed class IpcCallerMoodles : IpcServiceBase
|
|
{
|
|
private static readonly IpcServiceDescriptor MoodlesDescriptor = new("Moodles", "Moodles", new Version(0, 0, 0, 0));
|
|
|
|
private readonly ICallGateSubscriber<int> _moodlesApiVersion;
|
|
private readonly ICallGateSubscriber<nint, object> _moodlesOnChange;
|
|
private readonly ICallGateSubscriber<nint, string> _moodlesGetStatus;
|
|
private readonly ICallGateSubscriber<nint, string, object> _moodlesSetStatus;
|
|
private readonly ICallGateSubscriber<nint, object> _moodlesRevertStatus;
|
|
private readonly ILogger<IpcCallerMoodles> _logger;
|
|
private readonly DalamudUtilService _dalamudUtil;
|
|
private readonly LightlessMediator _lightlessMediator;
|
|
|
|
public IpcCallerMoodles(ILogger<IpcCallerMoodles> logger, IDalamudPluginInterface pi, DalamudUtilService dalamudUtil,
|
|
LightlessMediator lightlessMediator) : base(logger, lightlessMediator, pi, MoodlesDescriptor)
|
|
{
|
|
_logger = logger;
|
|
_dalamudUtil = dalamudUtil;
|
|
_lightlessMediator = lightlessMediator;
|
|
|
|
_moodlesApiVersion = pi.GetIpcSubscriber<int>("Moodles.Version");
|
|
_moodlesOnChange = pi.GetIpcSubscriber<nint, object>("Moodles.StatusManagerModified");
|
|
_moodlesGetStatus = pi.GetIpcSubscriber<nint, string>("Moodles.GetStatusManagerByPtrV2");
|
|
_moodlesSetStatus = pi.GetIpcSubscriber<nint, string, object>("Moodles.SetStatusManagerByPtrV2");
|
|
_moodlesRevertStatus = pi.GetIpcSubscriber<nint, object>("Moodles.ClearStatusManagerByPtrV2");
|
|
|
|
_moodlesOnChange.Subscribe(OnMoodlesChange);
|
|
|
|
CheckAPI();
|
|
}
|
|
|
|
private void OnMoodlesChange(nint address)
|
|
{
|
|
_lightlessMediator.Publish(new MoodlesMessage(address));
|
|
}
|
|
|
|
protected override void Dispose(bool disposing)
|
|
{
|
|
base.Dispose(disposing);
|
|
if (!disposing)
|
|
{
|
|
return;
|
|
}
|
|
|
|
_moodlesOnChange.Unsubscribe(OnMoodlesChange);
|
|
}
|
|
|
|
public async Task<string?> GetStatusAsync(nint address)
|
|
{
|
|
if (!APIAvailable) return null;
|
|
|
|
try
|
|
{
|
|
return await _dalamudUtil.RunOnFrameworkThread(() => _moodlesGetStatus.InvokeFunc(address)).ConfigureAwait(false);
|
|
|
|
}
|
|
catch (Exception e)
|
|
{
|
|
_logger.LogWarning(e, "Could not Get Moodles Status");
|
|
return null;
|
|
}
|
|
}
|
|
|
|
public async Task SetStatusAsync(nint pointer, string status)
|
|
{
|
|
if (!APIAvailable) return;
|
|
try
|
|
{
|
|
await _dalamudUtil.RunOnFrameworkThread(() => _moodlesSetStatus.InvokeAction(pointer, status)).ConfigureAwait(false);
|
|
}
|
|
catch (Exception e)
|
|
{
|
|
_logger.LogWarning(e, "Could not Set Moodles Status");
|
|
}
|
|
}
|
|
|
|
public async Task RevertStatusAsync(nint pointer)
|
|
{
|
|
if (!APIAvailable) return;
|
|
try
|
|
{
|
|
await _dalamudUtil.RunOnFrameworkThread(() => _moodlesRevertStatus.InvokeAction(pointer)).ConfigureAwait(false);
|
|
}
|
|
catch (Exception e)
|
|
{
|
|
_logger.LogWarning(e, "Could not Set Moodles Status");
|
|
}
|
|
}
|
|
|
|
protected override IpcConnectionState EvaluateState()
|
|
{
|
|
var state = base.EvaluateState();
|
|
if (state != IpcConnectionState.Available)
|
|
{
|
|
return state;
|
|
}
|
|
|
|
try
|
|
{
|
|
return _moodlesApiVersion.InvokeFunc() >= 4
|
|
? IpcConnectionState.Available
|
|
: IpcConnectionState.VersionMismatch;
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
_logger.LogDebug(ex, "Failed to query Moodles API version");
|
|
return IpcConnectionState.Error;
|
|
}
|
|
}
|
|
}
|