< Summary

Information

Class:	Elsa.Workflows.Runtime.StoreWorkflowExecutionLogSink
Assembly:	Elsa.Workflows.Runtime
File(s):	/home/runner/work/elsa-core/elsa-core/src/modules/Elsa.Workflows.Runtime/Services/StoreWorkflowExecutionLogSink.cs

Line coverage

85%

Branch coverage

50%

Method coverage

Feature is only available for sponsors

Metrics

Method	Branch coverage	Crap Score	Cyclomatic complexity	Line coverage
.ctor(...)	100%	1	1	100%
PersistExecutionLogsAsync()	50%	2	2	83.33%

#	Line	Line coverage
	`1`	`using Elsa.Mediator.Contracts;`
	`2`	`using Elsa.Workflows.Runtime.Entities;`
	`3`	`using Elsa.Workflows.Runtime.Notifications;`
	`4`	`using Open.Linq.AsyncExtensions;`
	`5`
	`6`	`namespace Elsa.Workflows.Runtime;`
	`7`
	`8`	`/// <summary>`
	`9`	`/// This implementation saves <see cref="WorkflowExecutionLogRecord"/> directly through the store.`
	`10`	`/// </summary>`
437	`11`	`public class StoreWorkflowExecutionLogSink(IWorkflowExecutionLogStore store, ILogRecordExtractor<WorkflowExecutionLogRec`
	`12`	`{`
	`13`	`/// <inheritdoc />`
	`14`	`public async Task PersistExecutionLogsAsync(WorkflowExecutionContext context, CancellationToken cancellationToken)`
	`15`	`{`
466	`16`	`var records = await extractor.ExtractLogRecordsAsync(context).ToList();`
	`17`
466	`18`	`if(records.Count == 0)`
0	`19`	`return;`
	`20`
466	`21`	`await store.AddManyAsync(records, context.CancellationToken);`
466	`22`	`await notificationSender.SendAsync(new WorkflowExecutionLogUpdated(context), context.CancellationToken);`
466	`23`	`}`
	`24`	`}`