add abp script to elsa

aspnet-core/modules/elsa/LINGYUN.Abp.Elsa/LINGYUN/Abp/Elsa/AbpElsaModule.cs

@@ -1,6 +1,7 @@
 using Elsa;
 using Elsa.Services;
 using LINGYUN.Abp.Elsa.Localization;
+using LINGYUN.Abp.Elsa.Scripting.JavaScript;
 using Microsoft.Extensions.DependencyInjection;
 using Microsoft.Extensions.Options;
 using Newtonsoft.Json;
@@ -26,7 +27,8 @@ public class AbpElsaModule : AbpModule
     {
         var builder = context.Services.GetPreConfigureActions<ElsaOptionsBuilder>();
 
-        context.Services.AddElsa(options =>
+        context.Services
+            .AddElsa(options =>
             {
                 options.AddCustomTenantAccessor<AbpTenantAccessor>();
                 options.AddConsoleActivities();
@@ -44,10 +46,9 @@ public class AbpElsaModule : AbpModule
                 });
 
                 builder.Configure(options);
-        });
+            })
-
+            .AddNotificationHandlers(typeof(ConfigureJavaScriptEngine))
-        context.Services.Replace<IIdGenerator, AbpElsaIdGenerator>(ServiceLifetime.Singleton);
+            .Replace<IIdGenerator, AbpElsaIdGenerator>(ServiceLifetime.Singleton);
-        context.Services.Replace<IWorkflowRunner, AbpWorkflowRunner>(ServiceLifetime.Scoped);
 
         Configure<AbpLocalizationOptions>(options =>
         {

aspnet-core/modules/elsa/LINGYUN.Abp.Elsa/LINGYUN/Abp/Elsa/Scripting/JavaScript/ConfigureJavaScriptEngine.cs

@@ -0,0 +1,177 @@
+using Elsa.Scripting.JavaScript.Events;
+using Elsa.Scripting.JavaScript.Messages;
+using MediatR;
+using Microsoft.Extensions.Localization;
+using Microsoft.Extensions.Options;
+using System;
+using System.Collections.Generic;
+using System.Threading;
+using System.Threading.Tasks;
+using Volo.Abp.Authorization.Permissions;
+using Volo.Abp.Guids;
+using Volo.Abp.Localization;
+using Volo.Abp.MultiTenancy;
+using Volo.Abp.Settings;
+using Volo.Abp.Timing;
+
+namespace LINGYUN.Abp.Elsa.Scripting.JavaScript;
+
+public class ConfigureJavaScriptEngine : INotificationHandler<EvaluatingJavaScriptExpression>, INotificationHandler<RenderingTypeScriptDefinitions>
+{
+    private readonly IClock _clock;
+    private readonly ICurrentTenant _currentTenant;
+    private readonly AbpLocalizationOptions _localizationOptions;
+    private readonly IStringLocalizerFactory _localizerFactory;
+    private readonly IGuidGenerator _guidGenerator;
+    private readonly ISettingProvider _settingProvider;
+    private readonly IPermissionChecker _permissionChecker;
+
+    public ConfigureJavaScriptEngine(
+        IClock clock,
+        ICurrentTenant currentTenant,
+        IOptions<AbpLocalizationOptions> localizationOptions,
+        IStringLocalizerFactory localizerFactory,
+        IGuidGenerator guidGenerator,
+        ISettingProvider settingProvider,
+        IPermissionChecker permissionChecker)
+    {
+        _clock = clock;
+        _currentTenant = currentTenant;
+        _localizationOptions = localizationOptions.Value;
+        _localizerFactory = localizerFactory;
+        _guidGenerator = guidGenerator;
+        _settingProvider = settingProvider;
+        _permissionChecker = permissionChecker;
+    }
+
+    public Task Handle(RenderingTypeScriptDefinitions notification, CancellationToken cancellationToken)
+    {
+        var output = notification.Output;
+
+        output.AppendLine("declare interface Clock {");
+        output.AppendLine("  now(): DateTime;");
+        output.AppendLine("  normalize(dateTime: DateTime): DateTime;");
+        output.AppendLine("}");
+
+        output.AppendLine("declare interface CurrentTenant {");
+        output.AppendLine("  id(): string;");
+        output.AppendLine("  name(): string;");
+        output.AppendLine("}");
+
+        output.AppendLine("declare interface Utils {");
+        output.AppendLine("  guid(): string;");
+        output.AppendLine("}");
+
+        output.AppendLine("declare interface Localization {");
+        output.AppendLine("  localize(key: string, resourceName?: string): string;");
+        output.AppendLine("}");
+
+        output.AppendLine("declare interface Setting {");
+        output.AppendLine("  get(name: string): any;");
+        output.AppendLine("  getNumber(name: string): number;");
+        output.AppendLine("  getBoolean(name: string): boolean;");
+        output.AppendLine("}");
+
+        output.AppendLine("declare interface Auth {");
+        output.AppendLine("  isGranted(name: string): boolean;");
+        output.AppendLine("  isAnyGranted(names: string[]): boolean;");
+        output.AppendLine("  areAllGranted(names: string[]): boolean;");
+        output.AppendLine("}");
+
+        output.AppendLine("declare interface Abp {");
+        output.AppendLine(" clock: Clock;");
+        output.AppendLine(" currentTenant: CurrentTenant;");
+        output.AppendLine(" utils: Utils;");
+        output.AppendLine(" localization: Localization;");
+        output.AppendLine(" setting: Setting;");
+        output.AppendLine(" auth: Auth;");
+        output.AppendLine("}");
+
+        output.AppendLine("declare const abp: Abp;");
+
+        return Task.CompletedTask;
+    }
+
+    public Task Handle(EvaluatingJavaScriptExpression notification, CancellationToken cancellationToken)
+    {
+        var engine = notification.Engine;
+
+        var abpFunctions = new Dictionary<string, object>();
+
+        var clockModel = new Dictionary<string, object?>
+        {
+            ["now"] = (Func<object?>)(() => _clock.Now),
+            ["normalize"] = (Func<DateTime, DateTime>)((date) => _clock.Normalize(date))
+        };
+        abpFunctions["clock"] = clockModel;
+
+        var currentTenantModel = new Dictionary<string, object?>
+        {
+            ["id"] = (Func<object?>)(() => _currentTenant.Id?.ToString()),
+            ["name"] = (Func<object?>)(() => _currentTenant.Name)
+        };
+        abpFunctions["currentTenant"] = currentTenantModel;
+
+        var utilsModel = new Dictionary<string, object?>
+        {
+            ["guid"] = (Func<object?>)(() => _guidGenerator.Create().ToString())
+        };
+        abpFunctions["utils"] = utilsModel;
+
+        var localizationModel = new Dictionary<string, object?>
+        {
+            ["localize"] = ((Func<string, string?, string>)((key, resourceName) =>
+            {
+                resourceName ??= LocalizationResourceNameAttribute.GetName(typeof(DefaultResource));
+                IStringLocalizer? localizer = null;
+
+                foreach (var resource in _localizationOptions.Resources.Values)
+                {
+                    if (string.Equals(resourceName, resource.ResourceName, StringComparison.InvariantCultureIgnoreCase))
+                    {
+                        localizer = _localizerFactory.Create(resource.ResourceType);
+                        break;
+                    }
+                }
+
+                if (localizer == null)
+                {
+                    return key;
+                }
+
+                return localizer[key];
+            }))
+        };
+        abpFunctions["localization"] = localizationModel;
+
+        var settingModel = new Dictionary<string, object?>
+        {
+            ["get"] = (Func<string, object?>)((name) => _settingProvider.GetOrNullAsync(name).GetAwaiter().GetResult()),
+            ["getNumber"] = (Func<string, int>)((name) => _settingProvider.GetAsync(name, 0).GetAwaiter().GetResult()),
+            ["getBoolean"] = (Func<string, bool>)((name) => _settingProvider.GetAsync(name, false).GetAwaiter().GetResult())
+        };
+        abpFunctions["setting"] = settingModel;
+
+        var authModel = new Dictionary<string, object?>
+        {
+            ["isGranted"] = (Func<string, bool>)((name) => _permissionChecker.IsGrantedAsync(name).GetAwaiter().GetResult()),
+            ["isAnyGranted"] = (Func<string[], bool>)((names) =>
+            {
+                var anyGrantResult = _permissionChecker.IsGrantedAsync(names).GetAwaiter().GetResult();
+
+                return !anyGrantResult.AllProhibited;
+            }),
+            ["areAllGranted"] = (Func<string[], bool>)((names) =>
+            {
+                var anyGrantResult = _permissionChecker.IsGrantedAsync(names).GetAwaiter().GetResult();
+
+                return anyGrantResult.AllGranted;
+            })
+        };
+        abpFunctions["auth"] = authModel;
+
+        engine.SetValue("abp", abpFunctions);
+
+        return Task.CompletedTask;
+    }
+}

aspnet-core/modules/elsa/LINGYUN.Abp.Elsa/LINGYUN/Abp/Elsa/Scripting/Liquid/ConfigureLiquidEngine.cs

@@ -0,0 +1,63 @@
+using Elsa.Scripting.Liquid.Messages;
+using Fluid;
+using Fluid.Values;
+using MediatR;
+using Microsoft.Extensions.Localization;
+using Microsoft.Extensions.Options;
+using System.Threading;
+using System.Threading.Tasks;
+using Volo.Abp.Authorization.Permissions;
+using Volo.Abp.Guids;
+using Volo.Abp.Localization;
+using Volo.Abp.MultiTenancy;
+using Volo.Abp.Settings;
+using Volo.Abp.Timing;
+
+namespace LINGYUN.Abp.Elsa.Scripting.Liquid;
+public class ConfigureLiquidEngine : INotificationHandler<EvaluatingLiquidExpression>
+{
+    private readonly IClock _clock;
+    private readonly ICurrentTenant _currentTenant;
+    private readonly AbpLocalizationOptions _localizationOptions;
+    private readonly IStringLocalizerFactory _localizerFactory;
+    private readonly IGuidGenerator _guidGenerator;
+    private readonly ISettingProvider _settingProvider;
+    private readonly IPermissionChecker _permissionChecker;
+
+    public ConfigureLiquidEngine(
+        IClock clock,
+        ICurrentTenant currentTenant,
+        IOptions<AbpLocalizationOptions> localizationOptions,
+        IStringLocalizerFactory localizerFactory,
+        IGuidGenerator guidGenerator,
+        ISettingProvider settingProvider,
+        IPermissionChecker permissionChecker)
+    {
+        _clock = clock;
+        _currentTenant = currentTenant;
+        _localizationOptions = localizationOptions.Value;
+        _localizerFactory = localizerFactory;
+        _guidGenerator = guidGenerator;
+        _settingProvider = settingProvider;
+        _permissionChecker = permissionChecker;
+    }
+
+    public Task Handle(EvaluatingLiquidExpression notification, CancellationToken cancellationToken)
+    {
+        var context = notification.TemplateContext;
+        var options = context.Options;
+
+        options.Scope.SetValue("Abp", new ObjectValue(new LiquidAbpAccessor()));
+
+        options.MemberAccessStrategy.Register<LiquidAbpAccessor, FluidValue>((_, name) =>
+        {
+            return name switch
+            {
+                nameof(IClock.Now) => new DateTimeValue(_clock.Now),
+                _ => NilValue.Instance
+            };
+        });
+
+        return Task.CompletedTask;
+    }
+}

aspnet-core/modules/elsa/LINGYUN.Abp.Elsa/LINGYUN/Abp/Elsa/Scripting/Liquid/LiquidAbpAccessor.cs

@@ -0,0 +1,5 @@
+namespace LINGYUN.Abp.Elsa.Scripting.Liquid;
+
+public class LiquidAbpAccessor
+{
+}

aspnet-core/services/LY.MicroService.WorkflowManagement.HttpApi.Host/WorkflowManagementHttpApiHostModule.Configure.cs

@@ -159,14 +159,15 @@ public partial class WorkflowManagementHttpApiHostModule
 
     private void ConfigureEndpoints()
     {
-        Configure<AbpEndpointRouterOptions>(options =>
+        // 不需要
-        {
+        //Configure<AbpEndpointRouterOptions>(options =>
-            options.EndpointConfigureActions.Add(
+        //{
-                (context) =>
+        //    options.EndpointConfigureActions.Add(
-                {
+        //        (context) =>
-                    context.Endpoints.MapFallbackToPage("/_Host");
+        //        {
-                });
+        //            context.Endpoints.MapFallbackToPage("/_Host");
-        });
+        //        });
+        //});
     }
 
     private void ConfigureDistributedLock(IServiceCollection services, IConfiguration configuration)