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

Remove BlockingActivityTypeSpecification

Browse source 
This isn't used internally anymore and also does not translate easily to EF Core's provider implementation without storing blocking activities separately like bookmarks
This commit is contained in:
Sipke Schoorstra 2021-06-20 13:56:28 +02:00
parent 980af069b9
commit f174b1e98c
2 changed files with 0 additions and 21 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
src/core/Elsa.Core/Persistence/Specifications/WorkflowInstances/BlockingActivityTypeSpecification.cs
View file

@ -1,14 +0,0 @@
using System;
using System.Linq;
using System.Linq.Expressions;
using Elsa.Models;
namespace Elsa.Persistence.Specifications.WorkflowInstances
{
public class BlockingActivityTypeSpecification : Specification<WorkflowInstance>
{
public string ActivityType { get; }
public BlockingActivityTypeSpecification(string activityType) => ActivityType = activityType;
public override Expression<Func<WorkflowInstance, bool>> ToExpression() => instance => instance.BlockingActivities.Any(x => x.ActivityType == ActivityType);
}
}

7
src/persistence/Elsa.Persistence.YesSql/Stores/YesSqlWorkflowInstanceStore.cs
View file

@ -33,7 +33,6 @@ namespace Elsa.Persistence.YesSql.Stores
EntityIdSpecification<WorkflowInstance> spec => Query<WorkflowInstanceIndex>(session, x => x.InstanceId == spec.Id),
WorkflowInstanceIdSpecification spec => Query<WorkflowInstanceIndex>(session, x => x.InstanceId == spec.Id),
WorkflowInstanceIdsSpecification spec => Query<WorkflowInstanceIndex>(session, x => x.InstanceId.IsIn(spec.WorkflowInstanceIds)),
BlockingActivityTypeSpecification spec => Query<WorkflowInstanceBlockingActivitiesIndex>(session, x => x.ActivityType == spec.ActivityType),
_ => AutoMapSpecification<WorkflowInstanceIndex>(session, specification)
};
@ -41,12 +40,6 @@ namespace Elsa.Persistence.YesSql.Stores
{
switch (specification)
{
case BlockingActivityTypeSpecification:
{
var indexedQuery = query.With<WorkflowInstanceBlockingActivitiesIndex>();
var expression = orderBy.OrderByExpression.ConvertType<WorkflowInstance, WorkflowInstanceDocument>().ConvertType<WorkflowInstanceDocument, WorkflowInstanceBlockingActivitiesIndex>();
return orderBy.SortDirection == SortDirection.Ascending ? indexedQuery.OrderBy(expression) : indexedQuery.OrderByDescending(expression);
}
default:
{
var indexedQuery = query.With<WorkflowInstanceIndex>();