Questionable/Questionable/External/AutoDutyIpc.cs

using Dalamud.Plugin;
using Dalamud.Plugin.Ipc;
using Dalamud.Plugin.Ipc.Exceptions;
using Microsoft.Extensions.Logging;
using Questionable.Controller.Steps;
using Questionable.Data;

namespace Questionable.External;

internal sealed class AutoDutyIpc
{
    private readonly Configuration _configuration;
    private readonly TerritoryData _territoryData;
    private readonly ILogger<AutoDutyIpc> _logger;
    private readonly ICallGateSubscriber<uint,bool> _contentHasPath;
    private readonly ICallGateSubscriber<uint,int,bool,object> _run;
    private readonly ICallGateSubscriber<bool> _isStopped;

    public AutoDutyIpc(IDalamudPluginInterface pluginInterface, Configuration configuration, TerritoryData territoryData, ILogger<AutoDutyIpc> logger)
    {
        _configuration = configuration;
        _territoryData = territoryData;
        _logger = logger;
        _contentHasPath = pluginInterface.GetIpcSubscriber<uint, bool>("AutoDuty.ContentHasPath");
        _run = pluginInterface.GetIpcSubscriber<uint, int, bool, object>("AutoDuty.Run");
        _isStopped = pluginInterface.GetIpcSubscriber<bool>("AutoDuty.IsStopped");
    }

    public bool IsConfiguredToRunContent(uint? cfcId, bool autoDutyEnabled)
    {
        if (cfcId == null)
            return false;

        if (!_configuration.Duties.RunInstancedContentWithAutoDuty)
            return false;

        if (_configuration.Duties.BlacklistedDutyCfcIds.Contains(cfcId.Value))
            return false;

        if (_configuration.Duties.WhitelistedDutyCfcIds.Contains(cfcId.Value) &&
            _territoryData.TryGetContentFinderCondition(cfcId.Value, out _))
            return true;

        return autoDutyEnabled && HasPath(cfcId.Value);
    }

    public bool HasPath(uint cfcId)
    {
        if (!_territoryData.TryGetContentFinderCondition(cfcId, out var cfcData))
            return false;

        try
        {
            return _contentHasPath.InvokeFunc(cfcData.TerritoryId);
        }
        catch (IpcError e)
        {
            _logger.LogWarning("Unable to query AutoDuty for path in territory {TerritoryType}: {Message}", cfcData.TerritoryId, e.Message);
            return false;
        }
    }

    public void StartInstance(uint cfcId)
    {
        if (!_territoryData.TryGetContentFinderCondition(cfcId, out var cfcData))
            throw new TaskException($"Unknown ContentFinderConditionId {cfcId}");

        try
        {
            _run.InvokeAction(cfcData.TerritoryId, 1, true);
        }
        catch (IpcError e)
        {
            throw new TaskException($"Unable to run content with AutoDuty: {e.Message}", e);
        }
    }

    public bool IsStopped()
    {
        try
        {
            return _isStopped.InvokeFunc();
        }
        catch (IpcError)
        {
            return true;
        }
    }
}