SemianiakaVY/elsa-core
1
0
Fork 0
Code Issues Pull requests Actions 1 Packages Projects Releases Wiki Activity

Added intialenumeratefiles activity and extensions

Browse source
This commit is contained in:
Cameron Cowen 2021-06-16 01:19:10 +01:00
parent 1ceca22b5c
commit d2f79bedd3
4 changed files with 149 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

48
src/activities/Elsa.Activities.File/Activities/EnumeratreFiles/EnumerateFiles.cs Normal file
View file

@ -0,0 +1,48 @@
using Elsa.ActivityResults;
using Elsa.Attributes;
using Elsa.Services;
using Elsa.Services.Models;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace Elsa.Activities.File
{
[Action(Category = "File",
Description = "Enumerates files in a given folder",
Outcomes = new[] { OutcomeNames.Done })]
public class EnumerateFiles : Activity
{
[ActivityInput(Hint = "Path of the folder to enumerate files.")]
public string Path { get; set; }
[ActivityInput(Hint = "Pattern for files to return.")]
public string Pattern { get; set; }
[ActivityInput(Hint = "Ignore inaccessible files.", Label = "Ignore Inaccessible")]
public bool IgnoreInaccessible { get; set; } = true;
[ActivityInput(Hint = "Set case sensitivity.", Label = "Match Casing")]
public MatchCasing MatchCasing { get; set; } = MatchCasing.CaseInsensitive;
[ActivityInput(Hint = "Return files from sub directories", Label = "Sub Directories")]
public bool SubDirectories { get; set; } = false;
protected override IActivityExecutionResult OnExecute(ActivityExecutionContext context)
{
if (string.IsNullOrWhiteSpace(Pattern))
return Done(Directory.EnumerateFiles(Path));
EnumerationOptions options = new EnumerationOptions()
{
IgnoreInaccessible = IgnoreInaccessible,
MatchCasing = MatchCasing,
RecurseSubdirectories = SubDirectories
};
return Done(Directory.EnumerateFiles(Path, Pattern, options));
}
}
}

46
src/activities/Elsa.Activities.File/Activities/EnumeratreFiles/EnumerateFilesBuilderExtensions.cs Normal file
View file

@ -0,0 +1,46 @@
using Elsa.Builders;
using Elsa.Services.Models;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Runtime.CompilerServices;
using System.Text;
using System.Threading.Tasks;
namespace Elsa.Activities.File.Activities.EnumeratreFiles
{
public static class EnumerateFilesBuilderExtensions
{
public static IActivityBuilder EnumerateFiles(this IBuilder builder, Action<ISetupActivity<EnumerateFiles>> setup, [CallerLineNumber] int lineNumber = default, [CallerFilePath] string? sourceFile = default) => builder.Then(setup, null, lineNumber, sourceFile);
public static IActivityBuilder EnumerateFiles(this IBuilder builder, Func<ActivityExecutionContext, ValueTask<string>> path, [CallerLineNumber] int lineNumber = default, [CallerFilePath] string? sourceFile = default) =>
builder.EnumerateFiles(activity => activity
.Set(x => x.Path, path),
lineNumber,
sourceFile);
public static IActivityBuilder EnumerateFiles(this IBuilder builder, Func<ActivityExecutionContext, string> path, [CallerLineNumber] int lineNumber = default, [CallerFilePath] string? sourceFile = default) =>
builder.EnumerateFiles(activity => activity
.Set(x => x.Path, path),
lineNumber,
sourceFile);
public static IActivityBuilder EnumerateFiles(this IBuilder builder, Func<ValueTask<string>> path, [CallerLineNumber] int lineNumber = default, [CallerFilePath] string? sourceFile = default) =>
builder.EnumerateFiles(activity => activity
.Set(x => x.Path, path),
lineNumber,
sourceFile);
public static IActivityBuilder EnumerateFiles(this IBuilder builder, Func<string> path, [CallerLineNumber] int lineNumber = default, [CallerFilePath] string? sourceFile = default) =>
builder.EnumerateFiles(activity => activity
.Set(x => x.Path, path),
lineNumber,
sourceFile);
public static IActivityBuilder EnumerateFiles(this IBuilder builder, string path, [CallerLineNumber] int lineNumber = default, [CallerFilePath] string? sourceFile = default) =>
builder.EnumerateFiles(activity => activity
.Set(x => x.Path, path),
lineNumber,
sourceFile);
}
}

54
src/activities/Elsa.Activities.File/Activities/EnumeratreFiles/EnumerateFilesExtensions.cs Normal file
View file

@ -0,0 +1,54 @@
using Elsa.Builders;
using Elsa.Services.Models;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
namespace Elsa.Activities.File.Activities.EnumeratreFiles
{
public static class EnumerateFilesExtensions
{
#region Path
public static ISetupActivity<EnumerateFiles> WithPath(this ISetupActivity<EnumerateFiles> setup, Func<ActivityExecutionContext, ValueTask<string>> path) => setup.Set(x => x.Path, path);
public static ISetupActivity<EnumerateFiles> WithPath(this ISetupActivity<EnumerateFiles> setup, Func<ActivityExecutionContext, string> path) => setup.Set(x => x.Path, path);
public static ISetupActivity<EnumerateFiles> WithPath(this ISetupActivity<EnumerateFiles> setup, Func<ValueTask<string>> path) => setup.Set(x => x.Path, path);
public static ISetupActivity<EnumerateFiles> WithPath(this ISetupActivity<EnumerateFiles> setup, Func<string> path) => setup.Set(x => x.Path, path);
public static ISetupActivity<EnumerateFiles> WithPath(this ISetupActivity<EnumerateFiles> setup, string path) => setup.Set(x => x.Path, path);
#endregion
#region Pattern
public static ISetupActivity<EnumerateFiles> WithPattern(this ISetupActivity<EnumerateFiles> setup, Func<ActivityExecutionContext, ValueTask<string>> pattern) => setup.Set(x => x.Pattern, pattern);
public static ISetupActivity<EnumerateFiles> WithPattern(this ISetupActivity<EnumerateFiles> setup, Func<ActivityExecutionContext, string> pattern) => setup.Set(x => x.Pattern, pattern);
public static ISetupActivity<EnumerateFiles> WithPattern(this ISetupActivity<EnumerateFiles> setup, Func<ValueTask<string>> pattern) => setup.Set(x => x.Pattern, pattern);
public static ISetupActivity<EnumerateFiles> WithPattern(this ISetupActivity<EnumerateFiles> setup, Func<string> pattern) => setup.Set(x => x.Pattern, pattern);
public static ISetupActivity<EnumerateFiles> WithPattern(this ISetupActivity<EnumerateFiles> setup, string pattern) => setup.Set(x => x.Pattern, pattern);
#endregion
#region IgnoreInaccessible
public static ISetupActivity<EnumerateFiles> WithIgnoreInaccessible(this ISetupActivity<EnumerateFiles> setup, Func<ActivityExecutionContext, ValueTask<bool>> ignoreInaccessible) => setup.Set(x => x.IgnoreInaccessible, ignoreInaccessible);
public static ISetupActivity<EnumerateFiles> WithIgnoreInaccessible(this ISetupActivity<EnumerateFiles> setup, Func<ActivityExecutionContext, bool> ignoreInaccessible) => setup.Set(x => x.IgnoreInaccessible, ignoreInaccessible);
public static ISetupActivity<EnumerateFiles> WithIgnoreInaccessible(this ISetupActivity<EnumerateFiles> setup, Func<ValueTask<bool>> ignoreInaccessible) => setup.Set(x => x.IgnoreInaccessible, ignoreInaccessible);
public static ISetupActivity<EnumerateFiles> WithIgnoreInaccessible(this ISetupActivity<EnumerateFiles> setup, Func<bool> ignoreInaccessible) => setup.Set(x => x.IgnoreInaccessible, ignoreInaccessible);
public static ISetupActivity<EnumerateFiles> WithIgnoreInaccessible(this ISetupActivity<EnumerateFiles> setup, bool ignoreInaccessible) => setup.Set(x => x.IgnoreInaccessible, ignoreInaccessible);
#endregion
#region MatchCasing
public static ISetupActivity<EnumerateFiles> WithMatchCasing(this ISetupActivity<EnumerateFiles> setup, Func<ActivityExecutionContext, ValueTask<MatchCasing>> matchCasing) => setup.Set(x => x.MatchCasing, matchCasing);
public static ISetupActivity<EnumerateFiles> WithMatchCasing(this ISetupActivity<EnumerateFiles> setup, Func<ActivityExecutionContext, MatchCasing> matchCasing) => setup.Set(x => x.MatchCasing, matchCasing);
public static ISetupActivity<EnumerateFiles> WithMatchCasing(this ISetupActivity<EnumerateFiles> setup, Func<ValueTask<MatchCasing>> matchCasing) => setup.Set(x => x.MatchCasing, matchCasing);
public static ISetupActivity<EnumerateFiles> WithMatchCasing(this ISetupActivity<EnumerateFiles> setup, Func<MatchCasing> matchCasing) => setup.Set(x => x.MatchCasing, matchCasing);
public static ISetupActivity<EnumerateFiles> WithMatchCasing(this ISetupActivity<EnumerateFiles> setup, MatchCasing matchCasing) => setup.Set(x => x.MatchCasing, matchCasing);
#endregion
#region SubDirectories
public static ISetupActivity<EnumerateFiles> WithSubDirectories(this ISetupActivity<EnumerateFiles> setup, Func<ActivityExecutionContext, ValueTask<bool>> subDirectories) => setup.Set(x => x.SubDirectories, subDirectories);
public static ISetupActivity<EnumerateFiles> WithSubDirectories(this ISetupActivity<EnumerateFiles> setup, Func<ActivityExecutionContext, bool> subDirectories) => setup.Set(x => x.SubDirectories, subDirectories);
public static ISetupActivity<EnumerateFiles> WithSubDirectories(this ISetupActivity<EnumerateFiles> setup, Func<ValueTask<bool>> subDirectories) => setup.Set(x => x.SubDirectories, subDirectories);
public static ISetupActivity<EnumerateFiles> WithSubDirectories(this ISetupActivity<EnumerateFiles> setup, Func<bool> subDirectories) => setup.Set(x => x.SubDirectories, subDirectories);
public static ISetupActivity<EnumerateFiles> WithSubDirectories(this ISetupActivity<EnumerateFiles> setup, bool subDirectories) => setup.Set(x => x.SubDirectories, subDirectories);
#endregion
}
}

1
src/activities/Elsa.Activities.File/Extensions/ServiceCollectionExtensions.cs
View file

@ -20,6 +20,7 @@ namespace Microsoft.Extensions.DependencyInjection
throw new ArgumentNullException(nameof(builder));
builder.AddActivity<DeleteFile>()
.AddActivity<EnumerateFiles>()
.AddActivity<FileExists>()
.AddActivity<OutFile>()
.AddActivity<ReadFile>()