elsa-core/src/samples/persistence/Elsa.Samples.Persistence.EntityFramework/Program.cs
2021-02-11 10:23:00 +01:00

49 lines
1.9 KiB
C#

using System;
using System.Threading.Tasks;
using Elsa.Persistence;
using Elsa.Persistence.EntityFramework.Core.Extensions;
using Elsa.Persistence.EntityFramework.Sqlite;
using Elsa.Persistence.Specifications.WorkflowInstances;
using Elsa.Services;
using Microsoft.EntityFrameworkCore;
using Microsoft.Extensions.DependencyInjection;
namespace Elsa.Samples.Persistence.EntityFramework
{
class Program
{
private static async Task Main()
{
// Create a service container with Elsa services.
var services = new ServiceCollection()
.AddElsa(options => options
// Configure Elsa to use the Entity Framework Core persistence provider using Sqlite.
.UseEntityFrameworkPersistence(ef => ef.UseSqlite())
.AddConsoleActivities()
.AddWorkflow<HelloWorld>())
.AddAutoMapperProfiles<Program>()
.BuildServiceProvider();
// Run startup actions (not needed when registering Elsa with a Host).
var startupRunner = services.GetRequiredService<IStartupRunner>();
await startupRunner.StartupAsync();
// Get a workflow runner.
var workflowRunner = services.GetRequiredService<IWorkflowRunner>();
// Run the workflow.
var workflowInstance = await workflowRunner.RunWorkflowAsync<HelloWorld>();
// Get a reference to the workflow instance store.
var store = services.GetRequiredService<IWorkflowInstanceStore>();
// Count the number of workflow instances of HelloWorld.
var count = await store.CountAsync(new WorkflowDefinitionIdSpecification(nameof(HelloWorld)));
Console.WriteLine(count);
var loadedWorkflowInstance = await store.FindByIdAsync(workflowInstance.Id);
Console.WriteLine(loadedWorkflowInstance);
}
}
}