395 lines
11 KiB
C#
395 lines
11 KiB
C#
|
using Dalamud.Plugin;
|
||
|
|
using Dalamud.Plugin.Ipc;
|
||
|
|
using Dalamud.Plugin.Services;
|
||
|
|
|
||
|
|
namespace Glamourer.Api.Helpers;
|
||
|
|
|
||
|
|
/// <summary>
|
||
|
|
/// Specialized disposable Subscriber for Events.<para />
|
||
|
|
/// Subscriptions are wrapped to be individually exception-safe.<para/>
|
||
|
|
/// Can be enabled and disabled.<para/>
|
||
|
|
/// </summary>
|
||
|
|
public sealed class EventSubscriber : IDisposable
|
||
|
|
{
|
||
|
|
private readonly string _label;
|
||
|
|
private readonly IPluginLog _log;
|
||
|
|
private readonly Dictionary<Action, Action> _delegates = new();
|
||
|
|
private ICallGateSubscriber<object?>? _subscriber;
|
||
|
|
private bool _disabled;
|
||
|
|
|
||
|
|
public EventSubscriber(IDalamudPluginInterface pi, string label, params Action[] actions)
|
||
|
|
{
|
||
|
|
_label = label;
|
||
|
|
_log = PluginLogHelper.GetLog(pi);
|
||
|
|
try
|
||
|
|
{
|
||
|
|
_subscriber = pi.GetIpcSubscriber<object?>(label);
|
||
|
|
foreach (var action in actions)
|
||
|
|
Event += action;
|
||
|
|
|
||
|
|
_disabled = false;
|
||
|
|
}
|
||
|
|
catch (Exception e)
|
||
|
|
{
|
||
|
|
_log.Error($"Error registering IPC Subscriber for {label}\n{e}");
|
||
|
|
_subscriber = null;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/// <summary>
|
||
|
|
/// Enable all currently subscribed actions registered with this EventSubscriber.
|
||
|
|
/// Does nothing if it is already enabled.
|
||
|
|
/// </summary>
|
||
|
|
public void Enable()
|
||
|
|
{
|
||
|
|
if (_disabled && _subscriber != null)
|
||
|
|
{
|
||
|
|
foreach (var action in _delegates.Values)
|
||
|
|
_subscriber.Subscribe(action);
|
||
|
|
|
||
|
|
_disabled = false;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/// <summary>
|
||
|
|
/// Disable all subscribed actions registered with this EventSubscriber.
|
||
|
|
/// Does nothing if it is already disabled.
|
||
|
|
/// Does not forget the actions, only disables them.
|
||
|
|
/// </summary>
|
||
|
|
public void Disable()
|
||
|
|
{
|
||
|
|
if (!_disabled)
|
||
|
|
{
|
||
|
|
if (_subscriber != null)
|
||
|
|
foreach (var action in _delegates.Values)
|
||
|
|
_subscriber.Unsubscribe(action);
|
||
|
|
|
||
|
|
_disabled = true;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/// <summary>
|
||
|
|
/// Add or remove an action to the IPC event, if it is valid.
|
||
|
|
/// </summary>
|
||
|
|
public event Action Event
|
||
|
|
{
|
||
|
|
add
|
||
|
|
{
|
||
|
|
if (_subscriber != null && !_delegates.ContainsKey(value))
|
||
|
|
{
|
||
|
|
void Action()
|
||
|
|
{
|
||
|
|
try
|
||
|
|
{
|
||
|
|
value();
|
||
|
|
}
|
||
|
|
catch (Exception e)
|
||
|
|
{
|
||
|
|
_log.Error($"Exception invoking IPC event {_label}:\n{e}");
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
if (_delegates.TryAdd(value, Action) && !_disabled)
|
||
|
|
_subscriber.Subscribe(Action);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
remove
|
||
|
|
{
|
||
|
|
if (_subscriber != null && _delegates.Remove(value, out var action))
|
||
|
|
_subscriber.Unsubscribe(action);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public void Dispose()
|
||
|
|
{
|
||
|
|
Disable();
|
||
|
|
_subscriber = null;
|
||
|
|
_delegates.Clear();
|
||
|
|
}
|
||
|
|
|
||
|
|
~EventSubscriber()
|
||
|
|
=> Dispose();
|
||
|
|
}
|
||
|
|
|
||
|
|
/// <summary><inheritdoc cref="EventSubscriber"/> </summary>
|
||
|
|
public sealed class EventSubscriber<T1> : IDisposable
|
||
|
|
{
|
||
|
|
private readonly string _label;
|
||
|
|
private readonly IPluginLog _log;
|
||
|
|
private readonly Dictionary<Action<T1>, Action<T1>> _delegates = new();
|
||
|
|
private ICallGateSubscriber<T1, object?>? _subscriber;
|
||
|
|
private bool _disabled;
|
||
|
|
|
||
|
|
public EventSubscriber(IDalamudPluginInterface pi, string label, params Action<T1>[] actions)
|
||
|
|
{
|
||
|
|
_label = label;
|
||
|
|
_log = PluginLogHelper.GetLog(pi);
|
||
|
|
try
|
||
|
|
{
|
||
|
|
_subscriber = pi.GetIpcSubscriber<T1, object?>(label);
|
||
|
|
foreach (var action in actions)
|
||
|
|
Event += action;
|
||
|
|
|
||
|
|
_disabled = false;
|
||
|
|
}
|
||
|
|
catch (Exception e)
|
||
|
|
{
|
||
|
|
_log.Error($"Error registering IPC Subscriber for {label}\n{e}");
|
||
|
|
_subscriber = null;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/// <summary><inheritdoc cref="EventSubscriber.Enable"/> </summary>
|
||
|
|
public void Enable()
|
||
|
|
{
|
||
|
|
if (_disabled && _subscriber != null)
|
||
|
|
{
|
||
|
|
foreach (var action in _delegates.Values)
|
||
|
|
_subscriber.Subscribe(action);
|
||
|
|
|
||
|
|
_disabled = false;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/// <summary><inheritdoc cref="EventSubscriber.Disable"/> </summary>
|
||
|
|
public void Disable()
|
||
|
|
{
|
||
|
|
if (!_disabled)
|
||
|
|
{
|
||
|
|
if (_subscriber != null)
|
||
|
|
foreach (var action in _delegates.Values)
|
||
|
|
_subscriber.Unsubscribe(action);
|
||
|
|
|
||
|
|
_disabled = true;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/// <summary><inheritdoc cref="EventSubscriber.Event"/> </summary>
|
||
|
|
public event Action<T1> Event
|
||
|
|
{
|
||
|
|
add
|
||
|
|
{
|
||
|
|
if (_subscriber != null && !_delegates.ContainsKey(value))
|
||
|
|
{
|
||
|
|
void Action(T1 a)
|
||
|
|
{
|
||
|
|
try
|
||
|
|
{
|
||
|
|
value(a);
|
||
|
|
}
|
||
|
|
catch (Exception e)
|
||
|
|
{
|
||
|
|
_log.Error($"Exception invoking IPC event {_label}:\n{e}");
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
if (_delegates.TryAdd(value, Action) && !_disabled)
|
||
|
|
_subscriber.Subscribe(Action);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
remove
|
||
|
|
{
|
||
|
|
if (_subscriber != null && _delegates.Remove(value, out var action))
|
||
|
|
_subscriber.Unsubscribe(action);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public void Dispose()
|
||
|
|
{
|
||
|
|
Disable();
|
||
|
|
_subscriber = null;
|
||
|
|
_delegates.Clear();
|
||
|
|
}
|
||
|
|
|
||
|
|
~EventSubscriber()
|
||
|
|
=> Dispose();
|
||
|
|
}
|
||
|
|
|
||
|
|
/// <summary><inheritdoc cref="EventSubscriber"/> </summary>
|
||
|
|
public sealed class EventSubscriber<T1, T2> : IDisposable
|
||
|
|
{
|
||
|
|
private readonly string _label;
|
||
|
|
private readonly IPluginLog _log;
|
||
|
|
private readonly Dictionary<Action<T1, T2>, Action<T1, T2>> _delegates = new();
|
||
|
|
private ICallGateSubscriber<T1, T2, object?>? _subscriber;
|
||
|
|
private bool _disabled;
|
||
|
|
|
||
|
|
public EventSubscriber(IDalamudPluginInterface pi, string label, params Action<T1, T2>[] actions)
|
||
|
|
{
|
||
|
|
_label = label;
|
||
|
|
_log = PluginLogHelper.GetLog(pi);
|
||
|
|
try
|
||
|
|
{
|
||
|
|
_subscriber = pi.GetIpcSubscriber<T1, T2, object?>(label);
|
||
|
|
foreach (var action in actions)
|
||
|
|
Event += action;
|
||
|
|
|
||
|
|
_disabled = false;
|
||
|
|
}
|
||
|
|
catch (Exception e)
|
||
|
|
{
|
||
|
|
_log.Error($"Error registering IPC Subscriber for {label}\n{e}");
|
||
|
|
_subscriber = null;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/// <summary><inheritdoc cref="EventSubscriber.Enable"/> </summary>
|
||
|
|
public void Enable()
|
||
|
|
{
|
||
|
|
if (_disabled && _subscriber != null)
|
||
|
|
{
|
||
|
|
foreach (var action in _delegates.Values)
|
||
|
|
_subscriber.Subscribe(action);
|
||
|
|
|
||
|
|
_disabled = false;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/// <summary><inheritdoc cref="EventSubscriber.Disable"/> </summary>
|
||
|
|
public void Disable()
|
||
|
|
{
|
||
|
|
if (!_disabled)
|
||
|
|
{
|
||
|
|
if (_subscriber != null)
|
||
|
|
foreach (var action in _delegates.Values)
|
||
|
|
_subscriber.Unsubscribe(action);
|
||
|
|
|
||
|
|
_disabled = true;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/// <summary><inheritdoc cref="EventSubscriber.Event"/> </summary>
|
||
|
|
public event Action<T1, T2> Event
|
||
|
|
{
|
||
|
|
add
|
||
|
|
{
|
||
|
|
if (_subscriber != null && !_delegates.ContainsKey(value))
|
||
|
|
{
|
||
|
|
void Action(T1 a, T2 b)
|
||
|
|
{
|
||
|
|
try
|
||
|
|
{
|
||
|
|
value(a, b);
|
||
|
|
}
|
||
|
|
catch (Exception e)
|
||
|
|
{
|
||
|
|
_log.Error($"Exception invoking IPC event {_label}:\n{e}");
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
if (_delegates.TryAdd(value, Action) && !_disabled)
|
||
|
|
_subscriber.Subscribe(Action);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
remove
|
||
|
|
{
|
||
|
|
if (_subscriber != null && _delegates.Remove(value, out var action))
|
||
|
|
_subscriber.Unsubscribe(action);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public void Dispose()
|
||
|
|
{
|
||
|
|
Disable();
|
||
|
|
_subscriber = null;
|
||
|
|
_delegates.Clear();
|
||
|
|
}
|
||
|
|
|
||
|
|
~EventSubscriber()
|
||
|
|
=> Dispose();
|
||
|
|
}
|
||
|
|
|
||
|
|
/// <summary><inheritdoc cref="EventSubscriber"/> </summary>
|
||
|
|
public sealed class EventSubscriber<T1, T2, T3> : IDisposable
|
||
|
|
{
|
||
|
|
private readonly string _label;
|
||
|
|
private readonly IPluginLog _log;
|
||
|
|
private readonly Dictionary<Action<T1, T2, T3>, Action<T1, T2, T3>> _delegates = new();
|
||
|
|
private ICallGateSubscriber<T1, T2, T3, object?>? _subscriber;
|
||
|
|
private bool _disabled;
|
||
|
|
|
||
|
|
public EventSubscriber(IDalamudPluginInterface pi, string label, params Action<T1, T2, T3>[] actions)
|
||
|
|
{
|
||
|
|
_label = label;
|
||
|
|
_log = PluginLogHelper.GetLog(pi);
|
||
|
|
try
|
||
|
|
{
|
||
|
|
_subscriber = pi.GetIpcSubscriber<T1, T2, T3, object?>(label);
|
||
|
|
foreach (var action in actions)
|
||
|
|
Event += action;
|
||
|
|
|
||
|
|
_disabled = false;
|
||
|
|
}
|
||
|
|
catch (Exception e)
|
||
|
|
{
|
||
|
|
_log.Error($"Error registering IPC Subscriber for {label}\n{e}");
|
||
|
|
_subscriber = null;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/// <summary><inheritdoc cref="EventSubscriber.Enable"/> </summary>
|
||
|
|
public void Enable()
|
||
|
|
{
|
||
|
|
if (_disabled && _subscriber != null)
|
||
|
|
{
|
||
|
|
foreach (var action in _delegates.Values)
|
||
|
|
_subscriber.Subscribe(action);
|
||
|
|
|
||
|
|
_disabled = false;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/// <summary><inheritdoc cref="EventSubscriber.Disable"/> </summary>
|
||
|
|
public void Disable()
|
||
|
|
{
|
||
|
|
if (!_disabled)
|
||
|
|
{
|
||
|
|
if (_subscriber != null)
|
||
|
|
foreach (var action in _delegates.Values)
|
||
|
|
_subscriber.Unsubscribe(action);
|
||
|
|
|
||
|
|
_disabled = true;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
/// <summary><inheritdoc cref="EventSubscriber.Event"/> </summary>
|
||
|
|
public event Action<T1, T2, T3> Event
|
||
|
|
{
|
||
|
|
add
|
||
|
|
{
|
||
|
|
if (_subscriber != null && !_delegates.ContainsKey(value))
|
||
|
|
{
|
||
|
|
void Action(T1 a, T2 b, T3 c)
|
||
|
|
{
|
||
|
|
try
|
||
|
|
{
|
||
|
|
value(a, b, c);
|
||
|
|
}
|
||
|
|
catch (Exception e)
|
||
|
|
{
|
||
|
|
_log.Error($"Exception invoking IPC event {_label}:\n{e}");
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
if (_delegates.TryAdd(value, Action) && !_disabled)
|
||
|
|
_subscriber.Subscribe(Action);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
remove
|
||
|
|
{
|
||
|
|
if (_subscriber != null && _delegates.Remove(value, out var action))
|
||
|
|
_subscriber.Unsubscribe(action);
|
||
|
|
}
|
||
|
|
}
|
||
|
|
|
||
|
|
public void Dispose()
|
||
|
|
{
|
||
|
|
Disable();
|
||
|
|
_subscriber = null;
|
||
|
|
_delegates.Clear();
|
||
|
|
}
|
||
|
|
|
||
|
|
~EventSubscriber()
|
||
|
|
=> Dispose();
|
||
|
|
}
|