Skip to content

Commit 5d33871

Browse files
Fixes
1 parent c7b0be3 commit 5d33871

File tree

2 files changed

+26
-1
lines changed

2 files changed

+26
-1
lines changed

backend/src/Squidex.Domain.Apps.Entities/Rules/RuleQueueWriter.cs

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,9 @@ public async Task<bool> WriteAsync(DomainId appId, JobResult result)
2626
Guard.NotNull(result);
2727

2828
// We do not want to handle events without a job in the normal flow.
29-
if (result.Job == null || result.Rule == null || result.SkipReason != SkipReason.None)
29+
if (result.Job == null ||
30+
result.Rule == null ||
31+
result.SkipReason is not(SkipReason.None or SkipReason.Disabled))
3032
{
3133
return false;
3234
}

backend/tests/Squidex.Domain.Apps.Entities.Tests/Rules/RuleQueueWriterTests.cs

Lines changed: 23 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -115,6 +115,29 @@ public async Task Should_enqueue_success()
115115
Assert.Equal(new[] { result.Job.Value }, writes);
116116
}
117117

118+
[Fact]
119+
public async Task Should_enqueue_disabled()
120+
{
121+
var result = new JobResult
122+
{
123+
SkipReason = SkipReason.Disabled,
124+
EnrichedEvent = new EnrichedManualEvent(),
125+
EnrichmentError = null,
126+
Job = new CreateFlowInstanceRequest<FlowEventContext>
127+
{
128+
Context = new FlowEventContext(),
129+
Definition = new FlowDefinition(),
130+
DefinitionId = Guid.NewGuid().ToString(),
131+
OwnerId = Guid.NewGuid().ToString(),
132+
},
133+
Rule = CreateRule(),
134+
};
135+
136+
var writes = await EnqueueAndFlushAsync(result);
137+
138+
Assert.Equal(new[] { result.Job.Value }, writes);
139+
}
140+
118141
[Fact]
119142
public async Task Should_write_batched()
120143
{

0 commit comments

Comments
 (0)