Added workflowrunner extensions

This commit is contained in:
Cameron Cowen 2021-05-27 08:08:32 +01:00
parent c2b7727f59
commit 5e47d49352

View file

@ -0,0 +1,31 @@
using Elsa.Activities.File.Bookmarks;
using Elsa.Activities.File.Models;
using Elsa.Dispatch;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
namespace Elsa.Activities.File.Extensions
{
public static class WorkflowRunnerExtensions
{
const string _activityType = nameof(WatchDirectory);
public static async Task TriggerFileSystemChangedWorkflowsAsync(this IWorkflowDispatcher workflowDispatcher,
string directory,
WatcherChangeTypes changeType,
string fileName,
string fullPath,
CancellationToken cancellationToken = default)
{
var input = new FileSystemChanged(changeType, directory, fileName, fullPath);
var bookmark = new FileSystemChangedBookmark(changeType, directory);
var trigger = new FileSystemChangedBookmark(changeType, directory);
await workflowDispatcher.DispatchAsync(new TriggerWorkflowsRequest(_activityType, bookmark, trigger, input), cancellationToken);
}
}
}