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

Incremental work on GraphQL

Browse source
This commit is contained in:
Sipke Schoorstra 2019-11-22 23:07:31 +01:00
parent ac3ea9573f
commit baef007e2b
43 changed files with 549 additions and 52 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
Samples.sln
View file

@ -118,6 +118,14 @@ Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "Sample21", "src\samples\Sam
EndProject
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Elsa.Dashboard.Web", "src\dashboard\Elsa.Dashboard.Web\Elsa.Dashboard.Web.csproj", "{AE0363D2-3630-4CDD-86A1-7D6A717361BD}"
EndProject
Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "server", "server", "{849F4EC1-2694-4D29-ABBA-A63E01700F27}"
EndProject
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Elsa.Server.GraphQL", "src\server\Elsa.Server.GraphQL\Elsa.Server.GraphQL.csproj", "{9E3B1169-6E3F-4885-9CAF-9BD6D7D8A2A5}"
EndProject
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Elsa.Server.Host", "src\server\Elsa.Server.Host\Elsa.Server.Host.csproj", "{9CB171C8-7490-4D4C-A7B9-97B553444D12}"
EndProject
Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Elsa.Server.Core", "src\server\Elsa.Server.Core\Elsa.Server.Core.csproj", "{6B672FE5-4D5E-4D17-A616-6DDB1F973F8F}"
EndProject
Global
GlobalSection(SolutionConfigurationPlatforms) = preSolution
Debug|Any CPU = Debug|Any CPU
@ -300,6 +308,18 @@ Global
{AE0363D2-3630-4CDD-86A1-7D6A717361BD}.Debug|Any CPU.Build.0 = Debug|Any CPU
{AE0363D2-3630-4CDD-86A1-7D6A717361BD}.Release|Any CPU.ActiveCfg = Release|Any CPU
{AE0363D2-3630-4CDD-86A1-7D6A717361BD}.Release|Any CPU.Build.0 = Release|Any CPU
{9E3B1169-6E3F-4885-9CAF-9BD6D7D8A2A5}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{9E3B1169-6E3F-4885-9CAF-9BD6D7D8A2A5}.Debug|Any CPU.Build.0 = Debug|Any CPU
{9E3B1169-6E3F-4885-9CAF-9BD6D7D8A2A5}.Release|Any CPU.ActiveCfg = Release|Any CPU
{9E3B1169-6E3F-4885-9CAF-9BD6D7D8A2A5}.Release|Any CPU.Build.0 = Release|Any CPU
{9CB171C8-7490-4D4C-A7B9-97B553444D12}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{9CB171C8-7490-4D4C-A7B9-97B553444D12}.Debug|Any CPU.Build.0 = Debug|Any CPU
{9CB171C8-7490-4D4C-A7B9-97B553444D12}.Release|Any CPU.ActiveCfg = Release|Any CPU
{9CB171C8-7490-4D4C-A7B9-97B553444D12}.Release|Any CPU.Build.0 = Release|Any CPU
{6B672FE5-4D5E-4D17-A616-6DDB1F973F8F}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
{6B672FE5-4D5E-4D17-A616-6DDB1F973F8F}.Debug|Any CPU.Build.0 = Debug|Any CPU
{6B672FE5-4D5E-4D17-A616-6DDB1F973F8F}.Release|Any CPU.ActiveCfg = Release|Any CPU
{6B672FE5-4D5E-4D17-A616-6DDB1F973F8F}.Release|Any CPU.Build.0 = Release|Any CPU
EndGlobalSection
GlobalSection(SolutionProperties) = preSolution
HideSolutionNode = FALSE
@ -356,6 +376,10 @@ Global
{9B238B75-5A68-48B1-973A-59F0EFAB0A8B} = {5E5E1E84-DDBC-40D6-B891-0D563A15A44A}
{6BA81F4E-2B17-4C7B-ACB1-6588B0315582} = {5E5E1E84-DDBC-40D6-B891-0D563A15A44A}
{AE0363D2-3630-4CDD-86A1-7D6A717361BD} = {0DF567E8-2A21-4A1C-90E8-025F1EC615F3}
{849F4EC1-2694-4D29-ABBA-A63E01700F27} = {DA71CDAA-8DD3-4D5F-9FBD-8E4B37A2D925}
{9E3B1169-6E3F-4885-9CAF-9BD6D7D8A2A5} = {849F4EC1-2694-4D29-ABBA-A63E01700F27}
{9CB171C8-7490-4D4C-A7B9-97B553444D12} = {849F4EC1-2694-4D29-ABBA-A63E01700F27}
{6B672FE5-4D5E-4D17-A616-6DDB1F973F8F} = {849F4EC1-2694-4D29-ABBA-A63E01700F27}
EndGlobalSection
GlobalSection(ExtensibilityGlobals) = postSolution
SolutionGuid = {8B0975FD-7050-48B0-88C5-48C33378E158}

1
Samples.sln.DotSettings
View file

@ -1,6 +1,7 @@
<wpf:ResourceDictionary xml:space="preserve" xmlns:x="http://schemas.microsoft.com/winfx/2006/xaml" xmlns:s="clr-namespace:System;assembly=mscorlib" xmlns:ss="urn:shemas-jetbrains-com:settings-storage-xaml" xmlns:wpf="http://schemas.microsoft.com/winfx/2006/xaml/presentation">
<s:Boolean x:Key="/Default/CodeStyle/CodeFormatting/CSharpFormat/WRAP_LINES/@EntryValue">False</s:Boolean>
<s:String x:Key="/Default/CodeStyle/Naming/CSharpNaming/Abbreviations/=EF/@EntryIndexedValue">EF</s:String>
<s:String x:Key="/Default/CodeStyle/Naming/CSharpNaming/Abbreviations/=QL/@EntryIndexedValue">QL</s:String>
<s:Boolean x:Key="/Default/Environment/SettingsMigration/IsMigratorApplied/=JetBrains_002EReSharper_002EPsi_002ECSharp_002ECodeStyle_002ECSharpKeepExistingMigration/@EntryIndexedValue">True</s:Boolean>
<s:Boolean x:Key="/Default/Environment/SettingsMigration/IsMigratorApplied/=JetBrains_002EReSharper_002EPsi_002ECSharp_002ECodeStyle_002ECSharpPlaceEmbeddedOnSameLineMigration/@EntryIndexedValue">True</s:Boolean>
<s:Boolean x:Key="/Default/Environment/SettingsMigration/IsMigratorApplied/=JetBrains_002EReSharper_002EPsi_002ECSharp_002ECodeStyle_002ECSharpUseContinuousIndentInsideBracesMigration/@EntryIndexedValue">True</s:Boolean>

3
src/activities/Elsa.Activities.Email/Extensions/ServiceCollectionExtensions.cs
View file

@ -2,10 +2,9 @@ using System;
using Elsa.Activities.Email.Activities;
using Elsa.Activities.Email.Options;
using Elsa.Activities.Email.Services;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Options;
namespace Elsa.Activities.Email.Extensions
namespace Microsoft.Extensions.DependencyInjection
{
public static class ServiceCollectionExtensions
{

3
src/activities/Elsa.Activities.Http/Extensions/ApplicationBuilderExtensions.cs
View file

@ -1,9 +1,8 @@
using Elsa.Activities.Http.Middleware;
using Elsa.Activities.Http.RequestHandlers.Handlers;
using Elsa.Activities.Http.Services;
using Microsoft.AspNetCore.Builder;
namespace Elsa.Activities.Http.Extensions
namespace Microsoft.AspNetCore.Builder
{
public static class ApplicationBuilderExtensions
{

3
src/activities/Elsa.Activities.Http/Extensions/HttpActivitiesServiceCollectionExtensions.cs
View file

@ -9,11 +9,10 @@ using Elsa.Extensions;
using Elsa.Scripting.Liquid.Extensions;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc.Infrastructure;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.DependencyInjection.Extensions;
using Microsoft.Extensions.Options;
namespace Elsa.Activities.Http.Extensions
namespace Microsoft.Extensions.DependencyInjection
{
public static class HttpActivitiesServiceCollectionExtensions
{

3
src/activities/Elsa.Activities.Timers/Extensions/ServiceCollectionExtensions.cs
View file

@ -2,10 +2,9 @@ using System;
using Elsa.Activities.Timers.Activities;
using Elsa.Activities.Timers.HostedServices;
using Elsa.Activities.Timers.Options;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Options;
namespace Elsa.Activities.Timers.Extensions
namespace Microsoft.Extensions.DependencyInjection
{
public static class ServiceCollectionExtensions
{

4
src/dashboard/Elsa.Dashboard.Web/Startup.cs
View file

@ -1,8 +1,4 @@
using Elsa.Activities.Email.Extensions;
using Elsa.Activities.Http.Extensions;
using Elsa.Activities.Timers.Extensions;
using Elsa.Dashboard.Extensions;
using Elsa.Persistence.MongoDb.Extensions;
using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Hosting;
using Microsoft.Extensions.Configuration;

1
src/dashboard/Elsa.Dashboard/Elsa.Dashboard.csproj
View file

@ -37,6 +37,7 @@
<ItemGroup>
<ProjectReference Include="..\..\core\Elsa.Abstractions\Elsa.Abstractions.csproj" />
<ProjectReference Include="..\..\core\Elsa.Core\Elsa.Core.csproj" />
<ProjectReference Include="..\..\server\Elsa.Server.Core\Elsa.Server.Core.csproj" />
<ProjectReference Include="..\Elsa.WorkflowDesigner\Elsa.WorkflowDesigner.csproj" />
</ItemGroup>

17
src/dashboard/Elsa.Dashboard/Extensions/DashboardServiceCollectionExtensions.cs
View file

@ -23,11 +23,12 @@ namespace Elsa.Dashboard.Extensions
Action<ElsaBuilder> configure = default
)
{
var configuration = new ElsaBuilder(services);
var builder = new ElsaBuilder(services);
services.AddControllersWithViews();
configuration.WithElsaDashboard();
configure?.Invoke(configuration);
services.AddElsaManagement();
builder.WithElsaDashboard();
configure?.Invoke(builder);
var optionsBuilder = services.AddOptions<ElsaDashboardOptions>();
options?.Invoke(optionsBuilder);
@ -51,17 +52,9 @@ namespace Elsa.Dashboard.Extensions
var services = builder.Services;
services
.AddSingleton<IIdGenerator, IdGenerator>()
.AddSingleton<IWorkflowSerializerProvider, WorkflowSerializerProvider>()
.AddSingleton<IWorkflowSerializer, WorkflowSerializer>()
.TryAddProvider<ITokenFormatter, JsonTokenFormatter>(ServiceLifetime.Singleton)
.TryAddProvider<ITokenFormatter, YamlTokenFormatter>(ServiceLifetime.Singleton)
.TryAddProvider<ITokenFormatter, XmlTokenFormatter>(ServiceLifetime.Singleton)
.AddHttpContextAccessor()
.AddScoped<IWorkflowPublisher, WorkflowPublisher>()
.AddScoped<INotifier, Notifier>()
.AddScoped<NotifierFilter>()
.AddAutoMapperProfile<WorkflowDefinitionProfile>(ServiceLifetime.Singleton);
.AddScoped<NotifierFilter>();
services.AddScoped(
sp =>

6
src/persistence/Elsa.Persistence.MongoDb/Extensions/ServiceCollectionExtensions.cs
View file

@ -1,16 +1,18 @@
using System;
using Elsa;
using Elsa.Models;
using Elsa.Persistence;
using Elsa.Persistence.MongoDb;
using Elsa.Persistence.MongoDb.Serialization;
using Elsa.Persistence.MongoDb.Services;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using MongoDB.Bson;
using MongoDb.Bson.NodaTime;
using MongoDB.Bson.Serialization;
using MongoDB.Bson.Serialization.Conventions;
using MongoDB.Driver;
namespace Elsa.Persistence.MongoDb.Extensions
namespace Microsoft.Extensions.DependencyInjection
{
public static class ServiceCollectionExtensions
{

1
src/samples/Sample05/Program.cs
View file

@ -1,6 +1,5 @@
using System.Threading.Tasks;
using Elsa.Activities.Console.Extensions;
using Elsa.Activities.Timers.Extensions;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
using Microsoft.Extensions.Logging;

3
src/samples/Sample06/Startup.cs
View file

@ -1,5 +1,4 @@
using Elsa.Activities.Http.Extensions;
using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Hosting;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;

5
src/samples/Sample07/Startup.cs
View file

@ -1,7 +1,4 @@
using Elsa.Activities.Email.Extensions;
using Elsa.Activities.Http.Extensions;
using Elsa.Activities.Timers.Extensions;
using Elsa.Runtime;
using Elsa.Runtime;
using Microsoft.AspNetCore.Builder;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;

5
src/samples/Sample08/Startup.cs
View file

@ -1,7 +1,4 @@
using Elsa.Activities.Email.Extensions;
using Elsa.Activities.Http.Extensions;
using Elsa.Activities.MassTransit.Extensions;
using Elsa.Activities.Timers.Extensions;
using Elsa.Activities.MassTransit.Extensions;
using Elsa.Runtime;
using Microsoft.AspNetCore.Builder;
using Microsoft.Extensions.Configuration;

1
src/samples/Sample15/Program.cs
View file

@ -5,7 +5,6 @@ using Elsa.Activities.Console.Extensions;
using Elsa.Extensions;
using Elsa.Models;
using Elsa.Persistence;
using Elsa.Persistence.MongoDb.Extensions;
using Elsa.Runtime;
using Elsa.Services;
using Microsoft.Extensions.Configuration;

4
src/samples/Sample16/Startup.cs
View file

@ -1,8 +1,4 @@
using Elsa.Activities.Email.Extensions;
using Elsa.Activities.Http.Extensions;
using Elsa.Activities.Timers.Extensions;
using Elsa.Dashboard.Extensions;
using Elsa.Persistence.MongoDb.Extensions;
using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Hosting;
using Microsoft.Extensions.Configuration;

3
src/samples/Sample18/Program.cs
View file

@ -1,9 +1,6 @@
using System.IO;
using System.Net.Mail;
using System.Threading.Tasks;
using Elsa.Activities.Console.Extensions;
using Elsa.Activities.Email.Extensions;
using Elsa.Activities.Timers.Extensions;
using Elsa.Services;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;

3
src/samples/Sample19/Startup.cs
View file

@ -1,6 +1,3 @@
using Elsa.Activities.Email.Extensions;
using Elsa.Activities.Http.Extensions;
using Elsa.Activities.Timers.Extensions;
using Elsa.Dashboard.Extensions;
using Elsa.Persistence.EntityFrameworkCore.Extensions;
using Microsoft.AspNetCore.Builder;

3
src/samples/Sample21/Startup.cs
View file

@ -1,9 +1,6 @@
using System;
using System.Collections.Specialized;
using Elsa.Activities.Email.Extensions;
using Elsa.Activities.Http.Extensions;
using Elsa.Activities.MassTransit.Extensions;
using Elsa.Activities.Timers.Extensions;
using Elsa.Runtime;
using GreenPipes;
using MassTransit;

1
src/scripting/Elsa.Scripting.JavaScript/Handlers/DateTimeScriptEngineConfigurator.cs
View file

@ -5,7 +5,6 @@ using System.Threading.Tasks;
using Elsa.Scripting.JavaScript.Messages;
using MediatR;
using NodaTime;
using NodaTime.Text;
namespace Elsa.Scripting.JavaScript.Handlers
{

24
src/server/Elsa.Server.Core/Elsa.Server.Core.csproj Normal file
View file

@ -0,0 +1,24 @@
<Project Sdk="Microsoft.NET.Sdk">
<PropertyGroup>
<TargetFramework>netstandard2.0</TargetFramework>
<LangVersion>latest</LangVersion>
<PackageVersion>1.0.0</PackageVersion>
<Authors>Elsa Contributors</Authors>
<Description>
Elsa is a set of workflow libraries and tools that enable super-fast workflowing capabilities in any .NET Core application.
This package provides services to manage workflows, such as serialization and versioning.
</Description>
<Copyright>2019</Copyright>
<PackageProjectUrl>https://github.com/elsa-workflows/elsa-core</PackageProjectUrl>
<RepositoryUrl>https://github.com/elsa-workflows/elsa-core</RepositoryUrl>
<RepositoryType>GitHub</RepositoryType>
<PackageTags>elsa, workflows</PackageTags>
<PackageIcon>icon.png</PackageIcon>
</PropertyGroup>
<ItemGroup>
<ProjectReference Include="..\..\core\Elsa\Elsa.csproj" />
</ItemGroup>
</Project>

23
src/server/Elsa.Server.Core/Extensions/ServiceCollectionExtensions.cs Normal file
View file

@ -0,0 +1,23 @@
using Elsa.AutoMapper.Extensions;
using Elsa.Mapping;
using Elsa.Serialization;
using Elsa.Serialization.Formatters;
using Elsa.Services;
namespace Microsoft.Extensions.DependencyInjection
{
public static class ServiceCollectionExtensions
{
public static IServiceCollection AddElsaManagement(this IServiceCollection services)
{
return services.AddSingleton<IIdGenerator, IdGenerator>()
.AddSingleton<IWorkflowSerializerProvider, WorkflowSerializerProvider>()
.AddSingleton<IWorkflowSerializer, WorkflowSerializer>()
.TryAddProvider<ITokenFormatter, JsonTokenFormatter>(ServiceLifetime.Singleton)
.TryAddProvider<ITokenFormatter, YamlTokenFormatter>(ServiceLifetime.Singleton)
.TryAddProvider<ITokenFormatter, XmlTokenFormatter>(ServiceLifetime.Singleton)
.AddScoped<IWorkflowPublisher, WorkflowPublisher>()
.AddAutoMapperProfile<WorkflowDefinitionProfile>(ServiceLifetime.Singleton);
}
}
}

BIN
src/server/Elsa.Server.Core/icon.png Normal file
View file

Binary file not shown.
Side by side

After

Width:  |  Height:  |  Size: 16 KiB

18
src/server/Elsa.Server.GraphQL/Elsa.Server.GraphQL.csproj Normal file
View file

@ -0,0 +1,18 @@
<Project Sdk="Microsoft.NET.Sdk">
<PropertyGroup>
<TargetFramework>netstandard2.0</TargetFramework>
</PropertyGroup>
<ItemGroup>
<PackageReference Include="GraphQL" Version="3.0.0-preview-1271" />
<PackageReference Include="GraphQL.Server.Transports.AspNetCore" Version="3.5.0-alpha0027" />
<PackageReference Include="Microsoft.AspNetCore.Server.IIS" Version="2.2.6" />
<PackageReference Include="Microsoft.AspNetCore.Server.Kestrel" Version="2.2.0" />
</ItemGroup>
<ItemGroup>
<ProjectReference Include="..\..\core\Elsa\Elsa.csproj" />
</ItemGroup>
</Project>

45
src/server/Elsa.Server.GraphQL/ElsaMutation.cs Normal file
View file

@ -0,0 +1,45 @@
using System.Linq;
using Elsa.Models;
using Elsa.Server.GraphQL.Models;
using Elsa.Server.GraphQL.Types;
using Elsa.Services;
using GraphQL.Types;
namespace Elsa.Server.GraphQL
{
public class ElsaMutation : ObjectGraphType
{
public ElsaMutation(IWorkflowPublisher publisher, IIdGenerator idGenerator)
{
FieldAsync<WorkflowDefinitionVersionType>(
"defineWorkflow",
"Create a new workflow definitions",
new QueryArguments(new QueryArgument<NonNullGraphType<WorkflowDefinitionInputType>> { Name = "workflowDefinition" }),
async context =>
{
var model = context.GetArgument<WorkflowDefinitionInputModel>("workflowDefinition");
var publish = model.Publish;
var workflowDefinition = new WorkflowDefinitionVersion(
idGenerator.Generate(),
model.Id ?? idGenerator.Generate(),
1,
model.Name,
model.Description,
model.Activities.Select(x => x.ToActivityDefinition()),
model.Connections,
model.IsSingleton,
model.IsDisabled,
new Variables()
);
if (publish)
await publisher.PublishAsync(workflowDefinition, context.CancellationToken);
else
await publisher.SaveDraftAsync(workflowDefinition, context.CancellationToken);
return workflowDefinition;
});
}
}
}

27
src/server/Elsa.Server.GraphQL/ElsaQuery.cs Normal file
View file

@ -0,0 +1,27 @@
using System.Threading.Tasks;
using Elsa.Models;
using Elsa.Persistence;
using Elsa.Server.GraphQL.Types;
using GraphQL.Types;
namespace Elsa.Server.GraphQL
{
public class ElsaQuery : ObjectGraphType
{
private readonly IWorkflowDefinitionStore workflowDefinitionStore;
public ElsaQuery(IWorkflowDefinitionStore workflowDefinitionStore)
{
this.workflowDefinitionStore = workflowDefinitionStore;
FieldAsync<ListGraphType<WorkflowDefinitionVersionType>>("workflowDefinitions", resolve: ResolveWorkflowDefinitions);
}
private async Task<object> ResolveWorkflowDefinitions(ResolveFieldContext<object> context)
{
var items = await workflowDefinitionStore.ListAsync(VersionOptions.All, context.CancellationToken);
return items;
}
}
}

14
src/server/Elsa.Server.GraphQL/ElsaSchema.cs Normal file
View file

@ -0,0 +1,14 @@
using System;
using GraphQL.Types;
namespace Elsa.Server.GraphQL
{
public class ElsaSchema : Schema
{
public ElsaSchema(ElsaQuery query, ElsaMutation mutation, IServiceProvider serviceProvider) : base(serviceProvider)
{
Query = query;
Mutation = mutation;
}
}
}

12
src/server/Elsa.Server.GraphQL/Extensions/GraphQLApplicationBuilderExtensions.cs Normal file
View file

@ -0,0 +1,12 @@
using Elsa.Server.GraphQL;
namespace Microsoft.AspNetCore.Builder
{
public static class GraphQLApplicationBuilderExtensions
{
public static IApplicationBuilder UseElsaGraphQL(this IApplicationBuilder app)
{
return app.UseGraphQL<ElsaSchema>();
}
}
}

33
src/server/Elsa.Server.GraphQL/Extensions/GraphQLServiceCollectionExtensions.cs Normal file
View file

@ -0,0 +1,33 @@
using System;
using Elsa;
using Elsa.AutoMapper.Extensions;
using Elsa.Mapping;
using Elsa.Serialization;
using Elsa.Serialization.Formatters;
using Elsa.Server.GraphQL;
using Elsa.Services;
using GraphQL.Server;
namespace Microsoft.Extensions.DependencyInjection
{
public static class GraphQLServiceCollectionExtensions
{
public static ElsaBuilder AddGraphQL(this ElsaBuilder builder, Action<GraphQLOptions> configure = null)
{
var services = builder.Services;
services
.AddScoped<ElsaSchema>()
.AddLogging();
var graphQLOptions = new GraphQLOptions();
configure?.Invoke(graphQLOptions);
services
.AddGraphQL(graphQLOptions)
.AddGraphTypes(ServiceLifetime.Scoped);
return builder;
}
}
}

32
src/server/Elsa.Server.GraphQL/Models/ActivityDefinitionInputModel.cs Normal file
View file

@ -0,0 +1,32 @@
using Elsa.Models;
using Newtonsoft.Json.Linq;
namespace Elsa.Server.GraphQL.Models
{
public class ActivityDefinitionInputModel
{
public string Id { get; set; }
public string Type { get; set; }
public string Name { get; set; }
public string DisplayName { get; set; }
public string Description { get; set; }
public int Left { get; set; }
public int Top { get; set; }
public string State { get; set; }
public ActivityDefinition ToActivityDefinition()
{
return new ActivityDefinition
{
Id = Id,
Type = Type,
Name = Name,
DisplayName = DisplayName,
Description = Description,
Top = Top,
Left = Left,
State = JObject.Parse(State ?? "{}")
};
}
}
}

17
src/server/Elsa.Server.GraphQL/Models/WorkflowDefinitionInputModel.cs Normal file
View file

@ -0,0 +1,17 @@
using System.Collections.Generic;
using Elsa.Models;
namespace Elsa.Server.GraphQL.Models
{
public class WorkflowDefinitionInputModel
{
public string Id { get; set; }
public string Name { get; set; }
public string Description { get; set; }
public bool IsSingleton { get; set; }
public bool IsDisabled { get; set; }
public bool Publish { get; set; }
public IReadOnlyCollection<ActivityDefinitionInputModel> Activities { get; set; }
public IReadOnlyCollection<ConnectionDefinition> Connections { get; set; }
}
}

21
src/server/Elsa.Server.GraphQL/Types/ActivityDefinitionInputType.cs Normal file
View file

@ -0,0 +1,21 @@
using Elsa.Server.GraphQL.Models;
using GraphQL.Types;
namespace Elsa.Server.GraphQL.Types
{
public class ActivityDefinitionInputType : ObjectGraphType<ActivityDefinitionInputModel>
{
public ActivityDefinitionInputType()
{
Name = "ActivityDefinitionInput";
Field(x => x.Type).Description("The activity type name.");
Field(x => x.Description).Description("A description for the activity");
Field(x => x.Name).Description("A name for the activity. Named activities make it easy to be referenced from workflow expressions.");
Field(x => x.State).Description("The state of the activity in JSON format.");
Field(x => x.DisplayName).Description("A display name for this activity to display in workflow designers.");
Field(x => x.Left).Description("The X coordinate of the activity when displayed in workflow designers.");
Field(x => x.Top).Description("The Y coordinate of the activity when displayed in workflow designers.");
}
}
}

21
src/server/Elsa.Server.GraphQL/Types/ActivityDefinitionType.cs Normal file
View file

@ -0,0 +1,21 @@
using Elsa.Models;
using GraphQL.Types;
namespace Elsa.Server.GraphQL.Types
{
public class ActivityDefinitionType : ObjectGraphType<ActivityDefinition>
{
public ActivityDefinitionType()
{
Name = "ActivityDefinition";
Field(x => x.Type).Description("The activity type name.");
Field(x => x.Description).Description("A description for the activity");
Field(x => x.Name).Description("A name for the activity. Named activities make it easy to be referenced from workflow expressions.");
Field(x => x.State).Description("The state of the activity");
Field(x => x.DisplayName, type: typeof(string)).Description("A display name for this activity to display in workflow designers.");
Field(x => x.Left).Description("The X coordinate of the activity when displayed in workflow designers.");
Field(x => x.Top).Description("The Y coordinate of the activity when displayed in workflow designers.");
}
}
}

17
src/server/Elsa.Server.GraphQL/Types/ConnectionDefinitionType.cs Normal file
View file

@ -0,0 +1,17 @@
using Elsa.Models;
using GraphQL.Types;
namespace Elsa.Server.GraphQL.Types
{
public class ConnectionDefinitionType : ObjectGraphType<ConnectionDefinition>
{
public ConnectionDefinitionType()
{
Name = "ConnectionDefinition";
Field(x => x.SourceActivityId).Description("The source activity ID to connect from.");
Field(x => x.Outcome).Description("The source activity outcome to connect from.");
Field(x => x.DestinationActivityId).Description("The destination activity ID to connect to.");
}
}
}

22
src/server/Elsa.Server.GraphQL/Types/WorkflowDefinitionInputType.cs Normal file
View file

@ -0,0 +1,22 @@
using Elsa.Server.GraphQL.Models;
using GraphQL.Types;
namespace Elsa.Server.GraphQL.Types
{
public class WorkflowDefinitionInputType : InputObjectGraphType<WorkflowDefinitionInputModel>
{
public WorkflowDefinitionInputType()
{
Name = "WorkflowDefinitionInput";
Field(x => x.Id).Description("The ID you wish to assign the workflow. Id no value is specified, an ID will be generated.");
Field(x => x.Name).Description("The name of the workflow");
Field(x => x.Description).Description("The description of the workflow.");
Field(x => x.IsDisabled).Description("Whether the workflow should be disabled or not.");
Field(x => x.IsSingleton).Description("Whether the workflow should act as a singleton or not. When true, only one instance can execute at any given time.");
Field(x => x.Publish).Description("Whether the workflow should be published. If set to false, the workflow will be saved as a draft.");
Field(x => x.Activities, type: typeof(ListGraphType<ActivityDefinitionType>)).Description("A list of activities for the workflow.");
Field(x => x.Connections, type: typeof(ListGraphType<ConnectionDefinitionType>)).Description("A list of connections between activities on the workflow.");
}
}
}

25
src/server/Elsa.Server.GraphQL/Types/WorkflowDefinitionVersionType.cs Normal file
View file

@ -0,0 +1,25 @@
using Elsa.Models;
using GraphQL.Types;
namespace Elsa.Server.GraphQL.Types
{
public class WorkflowDefinitionVersionType : ObjectGraphType<WorkflowDefinitionVersion>
{
public WorkflowDefinitionVersionType()
{
Name = "WorkflowDefinitionVersion";
Field(x => x.Id).Description("The version ID of the workflow.");
Field(x => x.DefinitionId).Description("The ID of the workflow");
Field(x => x.Version).Description("The version of the workflow.");
Field(x => x.Name).Description("The name of the workflow.");
Field(x => x.Description).Description("The description of the workflow.");
Field(x => x.IsDisabled).Description("Whether the workflow is enabled or not.");
Field(x => x.IsLatest).Description("Whether this is the latest version of the workflow.");
Field(x => x.IsPublished).Description("Whether the workflow is published or not.");
Field(x => x.IsSingleton).Description("Whether the workflow acts as a singleton or not. When true, only one instance can execute at any given time.");
Field(x => x.Activities, type: typeof(ListGraphType<ActivityDefinitionType>)).Description("A list of activities for the workflow.");
Field(x => x.Connections, type: typeof(ListGraphType<ConnectionDefinitionType>)).Description("A list of connections between activities on the workflow.");
}
}
}

BIN
src/server/Elsa.Server.GraphQL/icon.png Normal file
View file

Binary file not shown.
Side by side

After

Width:  |  Height:  |  Size: 16 KiB

19
src/server/Elsa.Server.Host/Elsa.Server.Host.csproj Normal file
View file

@ -0,0 +1,19 @@
<Project Sdk="Microsoft.NET.Sdk.Web">
<PropertyGroup>
<TargetFramework>netcoreapp3.0</TargetFramework>
</PropertyGroup>
<ItemGroup>
<ProjectReference Include="..\..\persistence\Elsa.Persistence.MongoDb\Elsa.Persistence.MongoDb.csproj" />
<ProjectReference Include="..\Elsa.Server.Core\Elsa.Server.Core.csproj" />
<ProjectReference Include="..\Elsa.Server.GraphQL\Elsa.Server.GraphQL.csproj" />
</ItemGroup>
<ItemGroup>
<PackageReference Include="GraphQL.Server.Ui.GraphiQL" Version="3.4.0" />
<PackageReference Include="GraphQL.Server.Ui.Playground" Version="3.4.0" />
<PackageReference Include="GraphQL.Server.Ui.Voyager" Version="3.4.0" />
</ItemGroup>
</Project>

17
src/server/Elsa.Server.Host/Program.cs Normal file
View file

@ -0,0 +1,17 @@
using Microsoft.AspNetCore.Hosting;
using Microsoft.Extensions.Hosting;
namespace Elsa.Server.Host
{
public class Program
{
public static void Main(string[] args)
{
CreateHostBuilder(args).Build().Run();
}
public static IHostBuilder CreateHostBuilder(string[] args) =>
Microsoft.Extensions.Hosting.Host.CreateDefaultBuilder(args)
.ConfigureWebHostDefaults(webBuilder => { webBuilder.UseStartup<Startup>(); });
}
}

26
src/server/Elsa.Server.Host/Properties/launchSettings.json Normal file
View file

@ -0,0 +1,26 @@
{
"iisSettings": {
"windowsAuthentication": false,
"anonymousAuthentication": true,
"iisExpress": {
"applicationUrl": "http://localhost:16398"
}
},
"profiles": {
"IIS Express": {
"commandName": "IISExpress",
"launchBrowser": false,
"environmentVariables": {
"ASPNETCORE_ENVIRONMENT": "Development"
}
},
"Elsa.Server.Host": {
"commandName": "Project",
"launchBrowser": false,
"applicationUrl": "http://localhost:16398",
"environmentVariables": {
"ASPNETCORE_ENVIRONMENT": "Development"
}
}
}
}

68
src/server/Elsa.Server.Host/Startup.cs Normal file
View file

@ -0,0 +1,68 @@
using GraphQL.Server.Ui.GraphiQL;
using GraphQL.Server.Ui.Playground;
using GraphQL.Server.Ui.Voyager;
using Microsoft.AspNetCore.Builder;
using Microsoft.AspNetCore.Hosting;
using Microsoft.AspNetCore.Server.Kestrel.Core;
using Microsoft.Extensions.Configuration;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Hosting;
namespace Elsa.Server.Host
{
public class Startup
{
public Startup(IWebHostEnvironment environment, IConfiguration configuration)
{
Environment = environment;
Configuration = configuration;
}
public IWebHostEnvironment Environment { get; }
public IConfiguration Configuration { get; }
public void ConfigureServices(IServiceCollection services)
{
var elsaSection = Configuration.GetSection("Elsa");
services
.AddElsa(elsa => elsa
.AddMongoDbStores(Configuration, "ElsaServer", "MongoDb")
.AddGraphQL(options => Configuration.GetSection("GraphQL").Bind(options)))
.AddHttpActivities(options => options.Bind(elsaSection.GetSection("Http")))
.AddEmailActivities(options => options.Bind(elsaSection.GetSection("Smtp")))
.AddTimerActivities(options => options.Bind(elsaSection.GetSection("BackgroundRunner")))
.AddElsaManagement();
EnableSynchronousIO(services);
}
public void Configure(IApplicationBuilder app)
{
if (Environment.IsDevelopment())
{
app.UseDeveloperExceptionPage();
}
app.UseHttpActivities();
app.UseElsaGraphQL();
app.UseGraphQLPlayground(new GraphQLPlaygroundOptions());
app.UseGraphiQLServer(new GraphiQLOptions());
app.UseGraphQLVoyager(new GraphQLVoyagerOptions());
}
private void EnableSynchronousIO(IServiceCollection services)
{
// Workaround until GraphQL can swap off Newtonsoft.Json and onto the new MS one.
// Depending on whether you're using IIS or Kestrel, the code required is different.
// See: https://github.com/graphql-dotnet/graphql-dotnet/issues/1116
// kestrel
services.Configure<KestrelServerOptions>(options => { options.AllowSynchronousIO = true; });
// IIS
services.Configure<IISServerOptions>(options => { options.AllowSynchronousIO = true; });
}
}
}

9
src/server/Elsa.Server.Host/appsettings.Development.json Normal file
View file

@ -0,0 +1,9 @@
{
"Logging": {
"LogLevel": {
"Default": "Debug",
"System": "Information",
"Microsoft": "Information"
}
}
}

17
src/server/Elsa.Server.Host/appsettings.json Normal file
View file

@ -0,0 +1,17 @@
{
"Logging": {
"LogLevel": {
"Default": "Information",
"Microsoft": "Warning",
"Microsoft.Hosting.Lifetime": "Information"
}
},
"AllowedHosts": "*",
"ConnectionStrings": {
"MongoDb": "mongodb://localhost"
},
"GraphQL": {
"ExposeExceptions": true,
"SetFieldMiddleware": false
}
}