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

MongoDB provider improvements

Browse source
This commit is contained in:
Sipke Schoorstra 2021-03-11 22:50:50 +01:00
parent 422203ac36
commit 044caf533f
5 changed files with 12 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/persistence/Elsa.Persistence.MongoDb/Options/ElsaMongoDbOptions.cs
View file

@ -3,6 +3,6 @@ namespace Elsa.Persistence.MongoDb.Options
public class ElsaMongoDbOptions
{
public string? ConnectionString { get; set; }
public string? Db { get; set; }
public string? DatabaseName { get; set; }
}
}

7
src/persistence/Elsa.Persistence.MongoDb/Services/ElsaMongoDbContext.cs
View file

@ -1,3 +1,4 @@
using System;
using Elsa.Models;
using Elsa.Persistence.MongoDb.Options;
using Microsoft.Extensions.Options;
@ -11,7 +12,11 @@ namespace Elsa.Persistence.MongoDb.Services
{
var connectionString = options.Value.ConnectionString;
var mongoClient = new MongoClient(connectionString);
var databaseName = options.Value.Db is not null and not "" ? options.Value.Db : MongoUrl.Create(connectionString).DatabaseName;
var databaseName = options.Value.DatabaseName is not null and not "" ? options.Value.DatabaseName : MongoUrl.Create(connectionString).DatabaseName;
if (databaseName == null)
throw new Exception("Please specify a database name, either via the connection string or via the DatabaseName setting.");
MongoDatabase = mongoClient.GetDatabase(databaseName);
}

1
src/samples/dashboard/ElsaDashboard.Samples.Monolith/ElsaDashboard.Samples.Monolith.csproj
View file

@ -19,6 +19,7 @@
<ProjectReference Include="..\..\..\dashboards\blazor\ElsaDashboard.Application\ElsaDashboard.Application.csproj" />
<ProjectReference Include="..\..\..\dashboards\blazor\ElsaDashboard.Backend\ElsaDashboard.Backend.csproj" />
<ProjectReference Include="..\..\..\persistence\Elsa.Persistence.EntityFramework\Elsa.Persistence.EntityFramework.Sqlite\Elsa.Persistence.EntityFramework.Sqlite.csproj" />
<ProjectReference Include="..\..\..\persistence\Elsa.Persistence.MongoDb\Elsa.Persistence.MongoDb.csproj" />
<ProjectReference Include="..\..\..\persistence\Elsa.Persistence.YesSql\Elsa.Persistence.YesSql.csproj" />
<ProjectReference Include="..\..\..\server\Elsa.Server.Api\Elsa.Server.Api.csproj" />
<ProjectReference Include="..\ElsaDashboard.Samples.WebAssembly\ElsaDashboard.Samples.WebAssembly.csproj" />

4
src/samples/dashboard/ElsaDashboard.Samples.Monolith/Startup.cs
View file

@ -3,6 +3,7 @@ using System.Net.Http.Headers;
using Elsa;
using Elsa.Persistence.EntityFramework.Core.Extensions;
using Elsa.Persistence.EntityFramework.Sqlite;
using Elsa.Persistence.MongoDb.Extensions;
using ElsaDashboard.Backend.Extensions;
using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Hosting;
@ -31,7 +32,8 @@ namespace ElsaDashboard.Samples.Monolith
services
.AddElsa(options => options
//.UseYesSqlPersistence()
.UseEntityFrameworkPersistence(ef => ef.UseSqlite())
.UseMongoDbPersistence(mongo => mongo.ConnectionString = "mongodb://localhost/elsa")
//.UseEntityFrameworkPersistence(ef => ef.UseSqlite())
.AddConsoleActivities()
.AddHttpActivities(elsaSection.GetSection("Http").Bind)
.AddEmailActivities(elsaSection.GetSection("Smtp").Bind)

2
test/integration/Elsa.Core.IntegrationTests/Autofixture/HostBuilderWithElsaSampleWorkflowAndMongoDbAttribute.cs
View file

@ -19,7 +19,7 @@ namespace Elsa.Core.IntegrationTests.Autofixture
.AddElsa(elsa => {
elsa.UseMongoDbPersistence(opts => {
opts.ConnectionString = "mongodb://localhost:27017";
opts.Db = "IntegrationTests";
opts.DatabaseName = "IntegrationTests";
});
elsa.AddActivity<UserTask>();
elsa.AddWorkflow<PersistableWorkflow>();