diff --git a/src/persistence/Elsa.Persistence.YesSql/Documents/SuspendedWorkflowBlockingActivityDocument.cs b/src/persistence/Elsa.Persistence.YesSql/Documents/SuspendedWorkflowBlockingActivityDocument.cs deleted file mode 100644 index 1969da871..000000000 --- a/src/persistence/Elsa.Persistence.YesSql/Documents/SuspendedWorkflowBlockingActivityDocument.cs +++ /dev/null @@ -1,21 +0,0 @@ -using NodaTime; - -namespace Elsa.Persistence.YesSql.Documents -{ - public class SuspendedWorkflowBlockingActivityDocument : YesSqlDocument - { - - public string EntityId { get; set; } = default!; - - public string InstanceId { get; set; } = default!; - public string DefinitionId { get; set; } = default!; - public int Version { get; set; } - public string? CorrelationId { get; set; } - public string? ContextId { get; set; } - public string? TenantId { get; set; } - public Instant CreatedAt { get; set; } - public Instant? LastExecutedAt { get; set; } - public string ActivityId { get; set; } = default!; - public string ActivityType { get; set; } = default!; - } -} \ No newline at end of file diff --git a/src/persistence/Elsa.Persistence.YesSql/Extensions/YesSqlSpecificationExtensions.cs b/src/persistence/Elsa.Persistence.YesSql/Extensions/YesSqlSpecificationExtensions.cs deleted file mode 100644 index 2702b507a..000000000 --- a/src/persistence/Elsa.Persistence.YesSql/Extensions/YesSqlSpecificationExtensions.cs +++ /dev/null @@ -1,24 +0,0 @@ -using Elsa.Persistence.Specifications; -using YesSql; -using YesSql.Indexes; - -namespace Elsa.Persistence.YesSql.Extensions -{ - public static class YesSqlSpecificationExtensions - { - public static IQuery Apply(this IQuery queryable, ISpecification specification) where T : class where TIndex : IIndex where TDocument : class => - queryable.Where(specification.ToExpression().ConvertType().ConvertType()); - - public static IQuery Apply(this IQuery queryable, IOrderBy? specification) where TIndex : IIndex where T : class where TDocument : class - { - if (specification == null) - return queryable; - - var orderByExpression = specification.OrderByExpression.ConvertType().ConvertType(); - return specification.SortDirection == SortDirection.Ascending ? queryable.OrderBy(orderByExpression) : queryable.OrderByDescending(orderByExpression); - } - - public static IQuery Apply(this IQuery queryable, IPaging? specification) where TIndex : IIndex where TDocument : class => - specification == null ? queryable : (IQuery) queryable.Skip(specification.Skip).Take(specification.Take); - } -} \ No newline at end of file