Background processes migrated.

src/Squidex.Domain.Apps.Entities/Contents/ContentScheduler.cs → src/Squidex.Domain.Apps.Entities/Contents/ContentSchedulerGrain.cs

@@ -5,24 +5,26 @@
 //  All rights reserved. Licensed under the MIT license.
 // ==========================================================================
 
+using System;
 using System.Threading.Tasks;
 using NodaTime;
+using Orleans;
+using Orleans.Runtime;
 using Squidex.Domain.Apps.Entities.Contents.Commands;
 using Squidex.Domain.Apps.Entities.Contents.Repositories;
 using Squidex.Infrastructure;
 using Squidex.Infrastructure.Commands;
-using Squidex.Infrastructure.Timers;
+using Squidex.Infrastructure.Tasks;
 
 namespace Squidex.Domain.Apps.Entities.Contents
 {
-    public sealed class ContentScheduler : IRunnable
+    public sealed class ContentSchedulerGrain : Grain, IContentSchedulerGrain, IRemindable
     {
-        private readonly CompletionTimer timer;
         private readonly IContentRepository contentRepository;
         private readonly ICommandBus commandBus;
         private readonly IClock clock;
 
-        public ContentScheduler(
+        public ContentSchedulerGrain(
             IContentRepository contentRepository,
             ICommandBus commandBus,
             IClock clock)
@@ -34,15 +36,24 @@ namespace Squidex.Domain.Apps.Entities.Contents
             this.contentRepository = contentRepository;
             this.commandBus = commandBus;
             this.clock = clock;
+        }
+
+        public override Task OnActivateAsync()
+        {
+            DelayDeactivation(TimeSpan.FromDays(1));
+
+            RegisterOrUpdateReminder("Default", TimeSpan.Zero, TimeSpan.FromMinutes(10));
+            RegisterTimer(x => PublishAsync(), null, TimeSpan.Zero, TimeSpan.FromSeconds(10));
 
-            timer = new CompletionTimer(5000, x => PublishAsync());
+            return Task.FromResult(true);
         }
 
-        public void Run()
+        public Task ActivateAsync()
         {
+            return TaskHelper.Done;
         }
 
-        private Task PublishAsync()
+        public Task PublishAsync()
         {
             var now = clock.GetCurrentInstant();
 
@@ -53,5 +64,10 @@ namespace Squidex.Domain.Apps.Entities.Contents
                 return commandBus.PublishAsync(command);
             });
         }
+
+        public Task ReceiveReminder(string reminderName, TickStatus status)
+        {
+            return TaskHelper.Done;
+        }
     }
 }

src/Squidex.Domain.Apps.Entities/Contents/Guards/GuardContent.cs

@@ -5,7 +5,6 @@
 //  All rights reserved. Licensed under the MIT license.
 // ==========================================================================
 
-using System;
 using NodaTime;
 using Squidex.Domain.Apps.Core.Contents;
 using Squidex.Domain.Apps.Entities.Contents.Commands;

src/Squidex.Domain.Apps.Entities/Contents/IContentSchedulerGrain.cs

@@ -0,0 +1,15 @@
+// ==========================================================================
+//  Squidex Headless CMS
+// ==========================================================================
+//  Copyright (c) Squidex UG (haftungsbeschraenkt)
+//  All rights reserved. Licensed under the MIT license.
+// ==========================================================================
+
+using Squidex.Infrastructure.Orleans;
+
+namespace Squidex.Domain.Apps.Entities.Contents
+{
+    public interface IContentSchedulerGrain : IBackgroundGrain
+    {
+    }
+}

src/Squidex.Domain.Apps.Entities/Rules/IRuleDequeuerGrain.cs

@@ -0,0 +1,15 @@
+// ==========================================================================
+//  Squidex Headless CMS
+// ==========================================================================
+//  Copyright (c) Squidex UG (haftungsbeschraenkt)
+//  All rights reserved. Licensed under the MIT license.
+// ==========================================================================
+
+using Squidex.Infrastructure.Orleans;
+
+namespace Squidex.Domain.Apps.Entities.Rules
+{
+    public interface IRuleDequeuerGrain : IBackgroundGrain
+    {
+    }
+}

src/Squidex.Domain.Apps.Entities/Rules/RuleDequeuer.cs → src/Squidex.Domain.Apps.Entities/Rules/RuleDequeuerGrain.cs

@@ -7,31 +7,30 @@
 
 using System;
 using System.Collections.Concurrent;
-using System.Threading;
 using System.Threading.Tasks;
 using System.Threading.Tasks.Dataflow;
 using NodaTime;
+using Orleans;
+using Orleans.Runtime;
 using Squidex.Domain.Apps.Core.HandleRules;
 using Squidex.Domain.Apps.Core.Rules;
 using Squidex.Domain.Apps.Entities.Rules.Repositories;
 using Squidex.Infrastructure;
 using Squidex.Infrastructure.Log;
 using Squidex.Infrastructure.Tasks;
-using Squidex.Infrastructure.Timers;
 
 namespace Squidex.Domain.Apps.Entities.Rules
 {
-    public class RuleDequeuer : DisposableObjectBase, IRunnable
+    public class RuleDequeuerGrain : Grain, IRuleDequeuerGrain, IRemindable
     {
         private readonly ITargetBlock<IRuleEventEntity> requestBlock;
         private readonly IRuleEventRepository ruleEventRepository;
         private readonly RuleService ruleService;
-        private readonly CompletionTimer timer;
         private readonly ConcurrentDictionary<Guid, bool> executing = new ConcurrentDictionary<Guid, bool>();
         private readonly IClock clock;
         private readonly ISemanticLog log;
 
-        public RuleDequeuer(RuleService ruleService, IRuleEventRepository ruleEventRepository, ISemanticLog log, IClock clock)
+        public RuleDequeuerGrain(RuleService ruleService, IRuleEventRepository ruleEventRepository, ISemanticLog log, IClock clock)
         {
             Guard.NotNull(ruleEventRepository, nameof(ruleEventRepository));
             Guard.NotNull(ruleService, nameof(ruleService));
@@ -48,37 +47,37 @@ namespace Squidex.Domain.Apps.Entities.Rules
             requestBlock =
                 new PartitionedActionBlock<IRuleEventEntity>(HandleAsync, x => x.Job.AggregateId.GetHashCode(),
                     new ExecutionDataflowBlockOptions { MaxDegreeOfParallelism = 32, BoundedCapacity = 32 });
-
-            timer = new CompletionTimer(5000, QueryAsync);
         }
 
-        protected override void DisposeObject(bool disposing)
+        public override Task OnActivateAsync()
         {
-            if (disposing)
+            DelayDeactivation(TimeSpan.FromDays(1));
-            {
-                timer.StopAsync().Wait();
 
-                requestBlock.Complete();
+            RegisterOrUpdateReminder("Default", TimeSpan.Zero, TimeSpan.FromMinutes(10));
-                requestBlock.Completion.Wait();
+            RegisterTimer(x => QueryAsync(), null, TimeSpan.Zero, TimeSpan.FromSeconds(10));
-            }
+
+            return Task.FromResult(true);
         }
 
-        public void Run()
+        public override Task OnDeactivateAsync()
         {
+            requestBlock.Complete();
+
+            return requestBlock.Completion;
         }
 
-        public void Next()
+        public Task ActivateAsync()
         {
-            timer.SkipCurrentDelay();
+            return TaskHelper.Done;
         }
 
-        private async Task QueryAsync(CancellationToken ct)
+        public async Task QueryAsync()
         {
             try
             {
                 var now = clock.GetCurrentInstant();
 
-                await ruleEventRepository.QueryPendingAsync(now, requestBlock.SendAsync, ct);
+                await ruleEventRepository.QueryPendingAsync(now, requestBlock.SendAsync);
             }
             catch (Exception ex)
             {
@@ -153,5 +152,10 @@ namespace Squidex.Domain.Apps.Entities.Rules
 
             return null;
         }
+
+        public Task ReceiveReminder(string reminderName, TickStatus status)
+        {
+            return TaskHelper.Done;
+        }
     }
 }

src/Squidex.Domain.Apps.Entities/Squidex.Domain.Apps.Entities.csproj

@@ -14,6 +14,7 @@
     <ProjectReference Include="..\Squidex.Shared\Squidex.Shared.csproj" />
   </ItemGroup>
   <ItemGroup>
+    <PackageReference Include="Microsoft.Orleans.OrleansCodeGenerator.Build" Version="2.0.0-beta3" />
     <PackageReference Include="NodaTime" Version="2.2.3" />
     <PackageReference Include="RefactoringEssentials" Version="5.6.0" />
     <PackageReference Include="StyleCop.Analyzers" Version="1.0.2" />

src/Squidex.Domain.Apps.Entities/SquidexEntities.cs

@@ -0,0 +1,16 @@
+// ==========================================================================
+//  Squidex Headless CMS
+// ==========================================================================
+//  Copyright (c) Squidex UG (haftungsbeschraenkt)
+//  All rights reserved. Licensed under the MIT license.
+// ==========================================================================
+
+using System.Reflection;
+
+namespace Squidex.Domain.Apps.Entities
+{
+    public sealed class SquidexEntities
+    {
+        public static readonly Assembly Assembly = typeof(SquidexEntities).Assembly;
+    }
+}

src/Squidex.Infrastructure.MongoDb/MongoDb/BsonJsonConvention.cs

@@ -11,7 +11,6 @@ using System.Reflection;
 using MongoDB.Bson.Serialization;
 using MongoDB.Bson.Serialization.Conventions;
 using Newtonsoft.Json;
-using Newtonsoft.Json.Linq;
 
 namespace Squidex.Infrastructure.MongoDb
 {

src/Squidex.Infrastructure.MongoDb/MongoDb/MongoRepositoryBase.cs

@@ -68,13 +68,16 @@ namespace Squidex.Infrastructure.MongoDb
         {
             return new Lazy<IMongoCollection<TEntity>>(() =>
             {
-                var databaseCollection = mongoDatabase.GetCollection<TEntity>(
+                return Task.Run(async () =>
-                    CollectionName(),
+                {
-                    CollectionSettings() ?? new MongoCollectionSettings());
+                    var databaseCollection = mongoDatabase.GetCollection<TEntity>(
+                        CollectionName(),
+                        CollectionSettings() ?? new MongoCollectionSettings());
 
-                SetupCollectionAsync(databaseCollection).Wait();
+                    await SetupCollectionAsync(databaseCollection).ConfigureAwait(false);
 
-                return databaseCollection;
+                    return databaseCollection;
+                }).Result;
             });
         }
 

src/Squidex.Infrastructure/EventSourcing/Grains/EventConsumerGrain.cs

@@ -71,7 +71,7 @@ namespace Squidex.Infrastructure.EventSourcing.Grains
 
             eventConsumer = eventConsumerFactory(this.GetPrimaryKeyString());
 
-            persistence = store.WithSnapshots<EventConsumerGrain, EventConsumerState, string>(this.GetPrimaryKeyString(), s => state = s);
+            persistence = store.WithSnapshots<EventConsumerState, string>(GetType(), this.GetPrimaryKeyString(), s => state = s);
 
             return persistence.ReadAsync();
         }
@@ -81,7 +81,7 @@ namespace Squidex.Infrastructure.EventSourcing.Grains
             return new RetrySubscription(eventStore, new WrapperSubscription(this.AsReference<IEventConsumerGrain>(), scheduler), streamFilter, position);
         }
 
-        public virtual Task<Immutable<EventConsumerInfo>> GetStateAsync()
+        public Task<Immutable<EventConsumerInfo>> GetStateAsync()
         {
             return Task.FromResult(state.ToInfo(this.eventConsumer.Name).AsImmutable());
         }

src/Squidex.Infrastructure/EventSourcing/Grains/EventConsumerManagerGrain.cs

@@ -14,10 +14,11 @@ using Orleans;
 using Orleans.Concurrency;
 using Orleans.Core;
 using Orleans.Runtime;
+using Squidex.Infrastructure.Tasks;
 
 namespace Squidex.Infrastructure.EventSourcing.Grains
 {
-    public class EventConsumerManagerGrain : Grain, IEventConsumerManagerGrain
+    public class EventConsumerManagerGrain : Grain, IEventConsumerManagerGrain, IRemindable
     {
         private readonly IEnumerable<IEventConsumer> eventConsumers;
 
@@ -37,17 +38,12 @@ namespace Squidex.Infrastructure.EventSourcing.Grains
             this.eventConsumers = eventConsumers;
         }
 
-        public Task ReceiveReminder(string reminderName, TickStatus status)
-        {
-            return ActivateAsync();
-        }
-
         public override Task OnActivateAsync()
         {
             DelayDeactivation(TimeSpan.FromDays(1));
 
-            // RegisterOrUpdateReminder("Default", TimeSpan.Zero, TimeSpan.FromMinutes(10));
+            RegisterOrUpdateReminder("Default", TimeSpan.Zero, TimeSpan.FromMinutes(10));
-            //  RegisterTimer(x => ActivateAsync(), null, TimeSpan.Zero, TimeSpan.FromSeconds(10));
+            RegisterTimer(x => WakeUpAsync(null), null, TimeSpan.Zero, TimeSpan.FromSeconds(10));
 
             return Task.FromResult(true);
         }
@@ -73,14 +69,16 @@ namespace Squidex.Infrastructure.EventSourcing.Grains
             return Task.WhenAll(tasks);
         }
 
-        public Task<Immutable<List<EventConsumerInfo>>> GetConsumersAsync()
+        public async Task<Immutable<List<EventConsumerInfo>>> GetConsumersAsync()
         {
             var tasks =
                 eventConsumers
                     .Select(c => GrainFactory.GetGrain<IEventConsumerGrain>(c.Name))
                     .Select(c => c.GetStateAsync());
 
-            return Task.WhenAll(tasks).ContinueWith(x => new Immutable<List<EventConsumerInfo>>(x.Result.Select(r => r.Value).ToList()));
+            var consumerInfos = await Task.WhenAll(tasks);
+
+            return new Immutable<List<EventConsumerInfo>>(consumerInfos.Select(r => r.Value).ToList());
         }
 
         public Task ResetAsync(string consumerName)
@@ -103,5 +101,10 @@ namespace Squidex.Infrastructure.EventSourcing.Grains
 
             return eventConsumer.StopAsync();
         }
+
+        public Task ReceiveReminder(string reminderName, TickStatus status)
+        {
+            return TaskHelper.Done;
+        }
     }
 }

src/Squidex.Infrastructure/EventSourcing/Grains/IEventConsumerGrain.cs

@@ -7,17 +7,15 @@
 
 using System;
 using System.Threading.Tasks;
-using Orleans;
 using Orleans.Concurrency;
+using Squidex.Infrastructure.Orleans;
 
 namespace Squidex.Infrastructure.EventSourcing.Grains
 {
-    public interface IEventConsumerGrain : IGrainWithStringKey
+    public interface IEventConsumerGrain : IBackgroundGrain
     {
         Task<Immutable<EventConsumerInfo>> GetStateAsync();
 
-        Task ActivateAsync();
-
         Task StopAsync();
 
         Task StartAsync();

src/Squidex.Infrastructure/EventSourcing/Grains/IEventConsumerManagerGrain.cs

@@ -7,15 +7,13 @@
 
 using System.Collections.Generic;
 using System.Threading.Tasks;
-using Orleans;
 using Orleans.Concurrency;
+using Squidex.Infrastructure.Orleans;
 
 namespace Squidex.Infrastructure.EventSourcing.Grains
 {
-    public interface IEventConsumerManagerGrain : IGrainWithStringKey
+    public interface IEventConsumerManagerGrain : IBackgroundGrain
     {
-        Task ActivateAsync();
-
         Task WakeUpAsync(string streamName);
 
         Task StopAsync(string consumerName);

src/Squidex.Infrastructure/EventSourcing/Grains/EventConsumerBootstrap.cs → src/Squidex.Infrastructure/Orleans/Bootstrap.cs

@@ -1,21 +1,20 @@
 // ==========================================================================
 //  Squidex Headless CMS
 // ==========================================================================
-//  Copyright (c) Squidex UG (haftungsbeschränkt)
+//  Copyright (c) Squidex UG (haftungsbeschraenkt)
 //  All rights reserved. Licensed under the MIT license.
 // ==========================================================================
 
 using Orleans;
-using Orleans.Runtime;
 using Squidex.Infrastructure.Tasks;
 
-namespace Squidex.Infrastructure.EventSourcing.Grains
+namespace Squidex.Infrastructure.Orleans
 {
-    public sealed class EventConsumerBootstrap : IRunnable
+    public sealed class Bootstrap<T> : IRunnable where T : IBackgroundGrain
     {
         private readonly IGrainFactory grainFactory;
 
-        public EventConsumerBootstrap(IGrainFactory grainFactory)
+        public Bootstrap(IGrainFactory grainFactory)
         {
             Guard.NotNull(grainFactory, nameof(grainFactory));
 
@@ -24,7 +23,7 @@ namespace Squidex.Infrastructure.EventSourcing.Grains
 
         public void Run()
         {
-            var grain = grainFactory.GetGrain<IEventConsumerManagerGrain>("Default");
+            var grain = grainFactory.GetGrain<T>("Default");
 
             grain.ActivateAsync().Forget();
         }

src/Squidex.Infrastructure/Orleans/IBackgroundGrain.cs

@@ -0,0 +1,17 @@
+// ==========================================================================
+//  Squidex Headless CMS
+// ==========================================================================
+//  Copyright (c) Squidex UG (haftungsbeschraenkt)
+//  All rights reserved. Licensed under the MIT license.
+// ==========================================================================
+
+using System.Threading.Tasks;
+using Orleans;
+
+namespace Squidex.Infrastructure.Orleans
+{
+    public interface IBackgroundGrain : IGrainWithStringKey
+    {
+        Task ActivateAsync();
+    }
+}

src/Squidex/Areas/Api/Controllers/EventConsumers/EventConsumersController.cs

@@ -26,10 +26,10 @@ namespace Squidex.Areas.Api.Controllers.EventConsumers
     {
         private readonly IEventConsumerManagerGrain eventConsumerManagerGrain;
 
-        public EventConsumersController(ICommandBus commandBus, IClusterClient orleans)
+        public EventConsumersController(ICommandBus commandBus, IGrainFactory grainFactory)
             : base(commandBus)
         {
-            eventConsumerManagerGrain = orleans.GetGrain<IEventConsumerManagerGrain>("Default");
+            eventConsumerManagerGrain = grainFactory.GetGrain<IEventConsumerManagerGrain>("Default");
         }
 
         [HttpGet]

src/Squidex/Config/Domain/InfrastructureServices.cs

@@ -23,10 +23,15 @@ using Squidex.Infrastructure.States;
 using Squidex.Infrastructure.UsageTracking;
 using Squidex.Pipeline;
 
+#pragma warning disable RECS0092 // Convert field to readonly
+
 namespace Squidex.Config.Domain
 {
     public static class InfrastructureServices
     {
+        private static ILogChannel console = new ConsoleLogChannel();
+        private static ILogChannel file;
+
         public static void AddMyInfrastructureServices(this IServiceCollection services, IConfiguration config)
         {
             if (config.GetValue<bool>("logging:human"))
@@ -42,11 +47,14 @@ namespace Squidex.Config.Domain
 
             if (!string.IsNullOrWhiteSpace(loggingFile))
             {
-                services.AddSingletonAs(new FileChannel(loggingFile))
+                services.AddSingletonAs(file ?? (file = new FileChannel(loggingFile)))
                     .As<ILogChannel>()
                     .As<IInitializable>();
             }
 
+            services.AddSingletonAs(console)
+                .As<ILogChannel>();
+
             services.AddSingletonAs(c => new ApplicationInfoLogAppender(typeof(Program).Assembly, Guid.NewGuid()))
                 .As<ILogAppender>();
 
@@ -59,9 +67,6 @@ namespace Squidex.Config.Domain
             services.AddSingletonAs<DebugLogChannel>()
                 .As<ILogChannel>();
 
-            services.AddSingletonAs<ConsoleLogChannel>()
-                .As<ILogChannel>();
-
             services.AddSingletonAs<SemanticLog>()
                 .As<ISemanticLog>();
 

src/Squidex/Config/Domain/ReadServices.cs

@@ -27,6 +27,7 @@ using Squidex.Infrastructure;
 using Squidex.Infrastructure.Assets;
 using Squidex.Infrastructure.EventSourcing;
 using Squidex.Infrastructure.EventSourcing.Grains;
+using Squidex.Infrastructure.Orleans;
 using Squidex.Infrastructure.States;
 using Squidex.Pipeline;
 
@@ -36,18 +37,13 @@ namespace Squidex.Config.Domain
     {
         public static void AddMyReadServices(this IServiceCollection services, IConfiguration config)
         {
-            var consumeEvents = config.GetOptionalValue("eventStore:consume", false);
+            services.AddSingletonAs<StateFactory>()
-
+                .As<IStateFactory>()
-            if (consumeEvents)
+                .As<IInitializable>();
-            {
-                services.AddSingletonAs<RuleDequeuer>()
-                    .As<IRunnable>();
-                services.AddSingletonAs<ContentScheduler>()
-                    .As<IRunnable>();
 
-                services.AddSingletonAs<EventConsumerBootstrap>()
+            services.AddSingletonAs<OrleansEventNotifier>()
-                    .As<IRunnable>();
+                .As<IEventNotifier>()
-            }
+                .As<IInitializable>();
 
             var exposeSourceUrl = config.GetOptionalValue("assetStore:exposeSourceUrl", true);
 
@@ -57,9 +53,6 @@ namespace Squidex.Config.Domain
                     exposeSourceUrl))
                 .As<IGraphQLUrlGenerator>();
 
-            services.AddSingletonAs<StateFactory>()
-                .As<IStateFactory>().As<IInitializable>();
-
             services.AddSingletonAs(c => c.GetService<IOptions<MyUsageOptions>>()?.Value?.Plans.OrEmpty());
 
             services.AddSingletonAs<CachingGraphQLService>()
@@ -113,8 +106,14 @@ namespace Squidex.Config.Domain
             services.AddSingletonAs<WebhookActionHandler>()
                 .As<IRuleActionHandler>();
 
-            services.AddSingletonAs<OrleansEventNotifier>()
+            services.AddSingletonAs<Bootstrap<IRuleDequeuerGrain>>()
-                .As<IEventNotifier>().As<IInitializable>();
+                .As<IRunnable>();
+
+            services.AddSingletonAs<Bootstrap<IContentSchedulerGrain>>()
+                .As<IRunnable>();
+
+            services.AddSingletonAs<Bootstrap<IEventConsumerManagerGrain>>()
+                .As<IRunnable>();
 
             services.AddSingletonAs<RuleEnqueuer>()
                 .As<IEventConsumer>();

src/Squidex/Config/Orleans/ClientWrapper.cs

@@ -8,6 +8,7 @@
 using System;
 using Orleans;
 using Orleans.Runtime.Configuration;
+using Squidex.Domain.Apps.Entities;
 using Squidex.Infrastructure;
 
 namespace Squidex.Config.Orleans
@@ -28,6 +29,7 @@ namespace Squidex.Config.Orleans
                 .UseDashboard()
                 .ConfigureApplicationParts(builder =>
                 {
+                    builder.AddApplicationPart(SquidexEntities.Assembly);
                     builder.AddApplicationPart(SquidexInfrastructure.Assembly);
                 })
                 .UseStaticGatewayListProvider(options =>

src/Squidex/Config/Orleans/SiloServices.cs

@@ -11,10 +11,7 @@ using System.Net;
 using Microsoft.Extensions.Configuration;
 using Microsoft.Extensions.DependencyInjection;
 using Orleans;
-using Orleans.Runtime;
 using Orleans.Runtime.Configuration;
-using Squidex.Infrastructure;
-using Squidex.Infrastructure.EventSourcing.Grains;
 
 namespace Squidex.Config.Orleans
 {

src/Squidex/Config/Orleans/SiloWrapper.cs

@@ -11,6 +11,7 @@ using Microsoft.Extensions.Configuration;
 using Orleans;
 using Orleans.Hosting;
 using Orleans.Runtime.Configuration;
+using Squidex.Domain.Apps.Entities;
 using Squidex.Infrastructure;
 using Squidex.Infrastructure.Log.Adapter;
 
@@ -38,20 +39,21 @@ namespace Squidex.Config.Orleans
         public SiloWrapper(IConfiguration configuration)
         {
             silo = SiloHostBuilder.CreateDefault()
-               .UseConfiguration(ClusterConfiguration.LocalhostPrimarySilo(33333))
+               .UseConfiguration(ClusterConfiguration.LocalhostPrimarySilo(33333).WithDashboard())
                .UseContentRoot(Directory.GetCurrentDirectory())
                .UseDashboard(options =>
                {
                    options.HostSelf = false;
                })
-               .ConfigureApplicationParts(builder =>
-               {
-                   builder.AddApplicationPart(SquidexInfrastructure.Assembly);
-               })
                .ConfigureLogging(builder =>
                {
                    builder.AddSemanticLog();
                })
+               .ConfigureApplicationParts(builder =>
+               {
+                   builder.AddApplicationPart(SquidexEntities.Assembly);
+                   builder.AddApplicationPart(SquidexInfrastructure.Assembly);
+               })
                .ConfigureServices((context, services) =>
                {
                    services.AddAppSiloServices(context.Configuration);
@@ -79,12 +81,5 @@ namespace Squidex.Config.Orleans
         {
             silo.StopAsync().Wait();
         }
-
-        private static string GetEnvironment()
-        {
-            var environment = Environment.GetEnvironmentVariable("ASPNETCORE_ENVIRONMENT");
-
-            return environment ?? "Development";
-        }
     }
 }

src/Squidex/WebStartup.cs

@@ -54,7 +54,6 @@ namespace Squidex
             app.ConfigurePortal();
             app.ConfigureOrleansDashboard();
             app.ConfigureIdentityServer();
-
             app.ConfigureFrontend();
         }
     }

tests/Squidex.Domain.Apps.Entities.Tests/Rules/RuleDequeuerTests.cs

@@ -27,13 +27,13 @@ namespace Squidex.Domain.Apps.Entities.Rules
         private readonly IRuleEventRepository ruleEventRepository = A.Fake<IRuleEventRepository>();
         private readonly Instant now = SystemClock.Instance.GetCurrentInstant();
         private readonly RuleService ruleService = A.Fake<RuleService>();
-        private readonly RuleDequeuer sut;
+        private readonly RuleDequeuerGrain sut;
 
         public RuleDequeuerTests()
         {
             A.CallTo(() => clock.GetCurrentInstant()).Returns(now);
 
-            sut = new RuleDequeuer(
+            sut = new RuleDequeuerGrain(
                 ruleService,
                 ruleEventRepository,
                 log,

tools/Migrate_01/Migrations/RebuildAssets.cs

@@ -5,8 +5,6 @@
 //  All rights reserved. Licensed under the MIT license.
 // ==========================================================================
 
-using System.Collections.Generic;
-using System.Linq;
 using System.Threading.Tasks;
 using Squidex.Infrastructure.Migrations;