TriggerManager
Contains methods for triggering the automated workflow.
using Relativity.Logging;
using System;
using System.Runtime.CompilerServices;
using System.Threading.Tasks;
namespace Relativity.DataExchange.Service
{
public class TriggerManager
{
private readonly IKeplerProxy _keplerProxy;
private readonly ILog _logger;
public TriggerManager(ILog logger, IKeplerProxy keplerProxy)
{
_logger = logger;
_keplerProxy = keplerProxy;
}
[AsyncStateMachine(typeof(<AttemptSendingTriggerAsync>d__3))]
public Task AttemptSendingTriggerAsync(int workspaceId, bool hasErrors, Version relativityVersion)
{
<AttemptSendingTriggerAsync>d__3 stateMachine = default(<AttemptSendingTriggerAsync>d__3);
stateMachine.<>t__builder = AsyncTaskMethodBuilder.Create();
stateMachine.<>4__this = this;
stateMachine.workspaceId = workspaceId;
stateMachine.hasErrors = hasErrors;
stateMachine.relativityVersion = relativityVersion;
stateMachine.<>1__state = -1;
stateMachine.<>t__builder.Start(ref stateMachine);
return stateMachine.<>t__builder.Task;
}
[AsyncStateMachine(typeof(<SendTriggerAsync>d__4))]
private Task SendTriggerAsync(int workSpaceId, string triggerName, string state)
{
<SendTriggerAsync>d__4 stateMachine = default(<SendTriggerAsync>d__4);
stateMachine.<>t__builder = AsyncTaskMethodBuilder.Create();
stateMachine.<>4__this = this;
stateMachine.workSpaceId = workSpaceId;
stateMachine.triggerName = triggerName;
stateMachine.state = state;
stateMachine.<>1__state = -1;
stateMachine.<>t__builder.Start(ref stateMachine);
return stateMachine.<>t__builder.Task;
}
}
}