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

Call async methods when in an async method

Browse source
This commit is contained in:
sergergood 2024-12-16 22:57:11 +03:00
parent cb6a7dfc11
commit 311b792f9b
15 changed files with 29 additions and 29 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/common/Elsa.Testing.Shared.Component/Services/SignalManager.cs
View file

@ -25,7 +25,7 @@ public class SignalManager
await Task.WhenAny(taskCompletionSource.Task, Task.Delay(millisecondsTimeout, cancellationTokenSource.Token));
cancellationTokenSource.Token.ThrowIfCancellationRequested();
_signals.TryRemove(signal, out _);
return taskCompletionSource.Task.Result;
return await taskCompletionSource.Task;
}
catch (OperationCanceledException)
{

4
src/modules/Elsa.Workflows.Api/Endpoints/WorkflowDefinitions/BulkDelete/Endpoint.cs
View file

@ -19,9 +19,9 @@ internal class BulkDelete(IWorkflowDefinitionManager workflowDefinitionManager,
public override async Task<Response> ExecuteAsync(Request request, CancellationToken cancellationToken)
{
var authorizationResult = authorizationService.AuthorizeAsync(User, new NotReadOnlyResource(), AuthorizationPolicies.NotReadOnlyPolicy);
var authorizationResult = await authorizationService.AuthorizeAsync(User, new NotReadOnlyResource(), AuthorizationPolicies.NotReadOnlyPolicy);
if (!authorizationResult.Result.Succeeded)
if (!authorizationResult.Succeeded)
{
await SendForbiddenAsync(cancellationToken);
return null!;

4
src/modules/Elsa.Workflows.Api/Endpoints/WorkflowDefinitions/BulkDeleteVersions/Endpoint.cs
View file

@ -19,9 +19,9 @@ internal class BulkDeleteVersions(IWorkflowDefinitionManager workflowDefinitionM
public override async Task<Response> ExecuteAsync(Request request, CancellationToken cancellationToken)
{
var authorizationResult = authorizationService.AuthorizeAsync(User, new NotReadOnlyResource(), AuthorizationPolicies.NotReadOnlyPolicy);
var authorizationResult = await authorizationService.AuthorizeAsync(User, new NotReadOnlyResource(), AuthorizationPolicies.NotReadOnlyPolicy);
if (!authorizationResult.Result.Succeeded)
if (!authorizationResult.Succeeded)
{
await SendForbiddenAsync(cancellationToken);
return null!;

4
src/modules/Elsa.Workflows.Api/Endpoints/WorkflowDefinitions/BulkPublish/Endpoint.cs
View file

@ -21,9 +21,9 @@ internal class BulkPublish(IWorkflowDefinitionStore store, IWorkflowDefinitionPu
public override async Task<Response> ExecuteAsync(Request request, CancellationToken cancellationToken)
{
var authorizationResult = authorizationService.AuthorizeAsync(User, new NotReadOnlyResource(), AuthorizationPolicies.NotReadOnlyPolicy);
var authorizationResult = await authorizationService.AuthorizeAsync(User, new NotReadOnlyResource(), AuthorizationPolicies.NotReadOnlyPolicy);
if (!authorizationResult.Result.Succeeded)
if (!authorizationResult.Succeeded)
{
await SendForbiddenAsync(cancellationToken);
return null!;

4
src/modules/Elsa.Workflows.Api/Endpoints/WorkflowDefinitions/BulkRetract/Endpoint.cs
View file

@ -21,9 +21,9 @@ internal class BulkRetract(IWorkflowDefinitionStore store, IWorkflowDefinitionPu
public override async Task<Response> ExecuteAsync(Request request, CancellationToken cancellationToken)
{
var authorizationResult = authorizationService.AuthorizeAsync(User, new NotReadOnlyResource(), AuthorizationPolicies.NotReadOnlyPolicy);
var authorizationResult = await authorizationService.AuthorizeAsync(User, new NotReadOnlyResource(), AuthorizationPolicies.NotReadOnlyPolicy);
if (!authorizationResult.Result.Succeeded)
if (!authorizationResult.Succeeded)
{
await SendForbiddenAsync(cancellationToken);
return null!;

4
src/modules/Elsa.Workflows.Api/Endpoints/WorkflowDefinitions/Delete/Endpoint.cs
View file

@ -33,9 +33,9 @@ internal class Delete(IWorkflowDefinitionManager workflowDefinitionManager, IAut
return;
}
var authorizationResult = authorizationService.AuthorizeAsync(User, new NotReadOnlyResource(definition), AuthorizationPolicies.NotReadOnlyPolicy);
var authorizationResult = await authorizationService.AuthorizeAsync(User, new NotReadOnlyResource(definition), AuthorizationPolicies.NotReadOnlyPolicy);
if (!authorizationResult.Result.Succeeded)
if (!authorizationResult.Succeeded)
{
await SendForbiddenAsync(cancellationToken);
return;

4
src/modules/Elsa.Workflows.Api/Endpoints/WorkflowDefinitions/DeleteVersion/Endpoint.cs
View file

@ -19,9 +19,9 @@ internal class DeleteVersion(IWorkflowDefinitionManager workflowDefinitionManage
public override async Task HandleAsync(Request request, CancellationToken cancellationToken)
{
var authorizationResult = authorizationService.AuthorizeAsync(User, new NotReadOnlyResource(), AuthorizationPolicies.NotReadOnlyPolicy);
var authorizationResult = await authorizationService.AuthorizeAsync(User, new NotReadOnlyResource(), AuthorizationPolicies.NotReadOnlyPolicy);
if (!authorizationResult.Result.Succeeded)
if (!authorizationResult.Succeeded)
{
await SendForbiddenAsync(cancellationToken);
return;

4
src/modules/Elsa.Workflows.Api/Endpoints/WorkflowDefinitions/Import/Endpoint.cs
View file

@ -45,9 +45,9 @@ internal class Import : ElsaEndpoint<WorkflowDefinitionModel>
var result = await ImportSingleWorkflowDefinitionAsync(model, cancellationToken);
var definition = result.WorkflowDefinition;
var authorizationResult = _authorizationService.AuthorizeAsync(User, new NotReadOnlyResource(definition), AuthorizationPolicies.NotReadOnlyPolicy);
var authorizationResult = await _authorizationService.AuthorizeAsync(User, new NotReadOnlyResource(definition), AuthorizationPolicies.NotReadOnlyPolicy);
if (!authorizationResult.Result.Succeeded)
if (!authorizationResult.Succeeded)
{
await SendForbiddenAsync(cancellationToken);
return;

4
src/modules/Elsa.Workflows.Api/Endpoints/WorkflowDefinitions/ImportFiles/Endpoint.cs
View file

@ -49,9 +49,9 @@ internal class ImportFiles : ElsaEndpoint<WorkflowDefinitionModel>
/// <inheritdoc />
public override async Task HandleAsync(WorkflowDefinitionModel model, CancellationToken cancellationToken)
{
var authorizationResult = _authorizationService.AuthorizeAsync(User, new NotReadOnlyResource(), AuthorizationPolicies.NotReadOnlyPolicy);
var authorizationResult = await _authorizationService.AuthorizeAsync(User, new NotReadOnlyResource(), AuthorizationPolicies.NotReadOnlyPolicy);
if (!authorizationResult.Result.Succeeded)
if (!authorizationResult.Succeeded)
{
await SendForbiddenAsync(cancellationToken);
return;

4
src/modules/Elsa.Workflows.Api/Endpoints/WorkflowDefinitions/Post/Endpoint.cs
View file

@ -56,9 +56,9 @@ internal class Post(
draft.DefinitionId = definitionId;
}
var authorizationResult = authorizationService.AuthorizeAsync(User, new NotReadOnlyResource(draft), AuthorizationPolicies.NotReadOnlyPolicy);
var authorizationResult = await authorizationService.AuthorizeAsync(User, new NotReadOnlyResource(draft), AuthorizationPolicies.NotReadOnlyPolicy);
if (!authorizationResult.Result.Succeeded)
if (!authorizationResult.Succeeded)
{
await SendForbiddenAsync(cancellationToken);
return;

4
src/modules/Elsa.Workflows.Api/Endpoints/WorkflowDefinitions/Publish/Endpoint.cs
View file

@ -35,9 +35,9 @@ internal class Publish(IWorkflowDefinitionStore store, IWorkflowDefinitionPublis
return;
}
var authorizationResult = authorizationService.AuthorizeAsync(User, new NotReadOnlyResource(definition), AuthorizationPolicies.NotReadOnlyPolicy);
var authorizationResult = await authorizationService.AuthorizeAsync(User, new NotReadOnlyResource(definition), AuthorizationPolicies.NotReadOnlyPolicy);
if (!authorizationResult.Result.Succeeded)
if (!authorizationResult.Succeeded)
{
await SendForbiddenAsync(cancellationToken);
return;

4
src/modules/Elsa.Workflows.Api/Endpoints/WorkflowDefinitions/Retract/Endpoint.cs
View file

@ -36,9 +36,9 @@ internal class Retract(IWorkflowDefinitionStore store, IWorkflowDefinitionPublis
return;
}
var authorizationResult = authorizationService.AuthorizeAsync(User, new NotReadOnlyResource(definition), AuthorizationPolicies.NotReadOnlyPolicy);
var authorizationResult = await authorizationService.AuthorizeAsync(User, new NotReadOnlyResource(definition), AuthorizationPolicies.NotReadOnlyPolicy);
if (!authorizationResult.Result.Succeeded)
if (!authorizationResult.Succeeded)
{
await SendForbiddenAsync(cancellationToken);
return;

4
src/modules/Elsa.Workflows.Api/Endpoints/WorkflowDefinitions/UpdateReferences/Endpoint.cs
View file

@ -36,9 +36,9 @@ internal class UpdateReferences(IWorkflowReferenceUpdater workflowReferenceUpdat
return;
}
var authorizationResult = authorizationService.AuthorizeAsync(User, new NotReadOnlyResource(definition), AuthorizationPolicies.NotReadOnlyPolicy);
var authorizationResult = await authorizationService.AuthorizeAsync(User, new NotReadOnlyResource(definition), AuthorizationPolicies.NotReadOnlyPolicy);
if (!authorizationResult.Result.Succeeded)
if (!authorizationResult.Succeeded)
{
await SendForbiddenAsync(cancellationToken);
return;

4
src/modules/Elsa.Workflows.Api/Endpoints/WorkflowDefinitions/Version/Delete.cs
View file

@ -42,9 +42,9 @@ public class DeleteVersion(IWorkflowDefinitionManager workflowDefinitionManager,
return;
}
var authorizationResult = authorizationService.AuthorizeAsync(User, new NotReadOnlyResource(definition), AuthorizationPolicies.NotReadOnlyPolicy);
var authorizationResult = await authorizationService.AuthorizeAsync(User, new NotReadOnlyResource(definition), AuthorizationPolicies.NotReadOnlyPolicy);
if (!authorizationResult.Result.Succeeded)
if (!authorizationResult.Succeeded)
{
await SendForbiddenAsync(cancellationToken);
return;

4
src/modules/Elsa.Workflows.Api/Endpoints/WorkflowDefinitions/Version/Revert.cs
View file

@ -39,9 +39,9 @@ internal class RevertVersion(IWorkflowDefinitionManager workflowDefinitionManage
return;
}
var authorizationResult = authorizationService.AuthorizeAsync(User, new NotReadOnlyResource(definition), AuthorizationPolicies.NotReadOnlyPolicy);
var authorizationResult = await authorizationService.AuthorizeAsync(User, new NotReadOnlyResource(definition), AuthorizationPolicies.NotReadOnlyPolicy);
if (!authorizationResult.Result.Succeeded)
if (!authorizationResult.Succeeded)
{
await SendForbiddenAsync(cancellationToken);
return;