Style improvements.

backend/src/Migrations/RebuildOptions.cs

@@ -5,6 +5,8 @@
 //  All rights reserved. Licensed under the MIT license.
 // ==========================================================================
 
+using System;
+
 namespace Migrations
 {
     public sealed class RebuildOptions
@@ -22,5 +24,12 @@ namespace Migrations
         public bool Rules { get; set; }
 
         public bool Schemas { get; set; }
+
+        public int BatchSize { get; set; } = 100;
+
+        public int CalculateBatchSize()
+        {
+            return Math.Max(10, Math.Min(1000, BatchSize));
+        }
     }
 }

backend/src/Migrations/RebuildRunner.cs

@@ -41,25 +41,27 @@ namespace Migrations
 
         public async Task RunAsync(CancellationToken ct)
         {
+            var batchSize = rebuildOptions.CalculateBatchSize();
+
             if (rebuildOptions.Apps)
             {
-                await rebuilder.RebuildAppsAsync(ct);
+                await rebuilder.RebuildAppsAsync(batchSize, ct);
             }
 
             if (rebuildOptions.Schemas)
             {
-                await rebuilder.RebuildSchemasAsync(ct);
+                await rebuilder.RebuildSchemasAsync(batchSize, ct);
             }
 
             if (rebuildOptions.Rules)
             {
-                await rebuilder.RebuildRulesAsync(ct);
+                await rebuilder.RebuildRulesAsync(batchSize, ct);
             }
 
             if (rebuildOptions.Assets)
             {
-                await rebuilder.RebuildAssetsAsync(ct);
+                await rebuilder.RebuildAssetsAsync(batchSize, ct);
-                await rebuilder.RebuildAssetFoldersAsync(ct);
+                await rebuilder.RebuildAssetFoldersAsync(batchSize, ct);
             }
 
             if (rebuildOptions.AssetFiles)
@@ -69,7 +71,7 @@ namespace Migrations
 
             if (rebuildOptions.Contents)
             {
-                await rebuilder.RebuildContentAsync(ct);
+                await rebuilder.RebuildContentAsync(batchSize, ct);
             }
 
             if (rebuildOptions.Indexes)

backend/src/Migrations/RebuilderExtensions.cs

@@ -18,34 +18,34 @@ namespace Migrations
 {
     public static class RebuilderExtensions
     {
-        public static Task RebuildAppsAsync(this Rebuilder rebuilder, CancellationToken ct = default)
+        public static Task RebuildAppsAsync(this Rebuilder rebuilder, int batchSize, CancellationToken ct = default)
         {
-            return rebuilder.RebuildAsync<AppDomainObject, AppDomainObject.State>("^app\\-", ct);
+            return rebuilder.RebuildAsync<AppDomainObject, AppDomainObject.State>("^app\\-", batchSize, ct);
         }
 
-        public static Task RebuildSchemasAsync(this Rebuilder rebuilder, CancellationToken ct = default)
+        public static Task RebuildSchemasAsync(this Rebuilder rebuilder, int batchSize, CancellationToken ct = default)
         {
-            return rebuilder.RebuildAsync<SchemaDomainObject, SchemaDomainObject.State>("^schema\\-", ct);
+            return rebuilder.RebuildAsync<SchemaDomainObject, SchemaDomainObject.State>("^schema\\-", batchSize, ct);
         }
 
-        public static Task RebuildRulesAsync(this Rebuilder rebuilder, CancellationToken ct = default)
+        public static Task RebuildRulesAsync(this Rebuilder rebuilder, int batchSize, CancellationToken ct = default)
         {
-            return rebuilder.RebuildAsync<RuleDomainObject, RuleDomainObject.State>("^rule\\-", ct);
+            return rebuilder.RebuildAsync<RuleDomainObject, RuleDomainObject.State>("^rule\\-", batchSize, ct);
         }
 
-        public static Task RebuildAssetsAsync(this Rebuilder rebuilder, CancellationToken ct = default)
+        public static Task RebuildAssetsAsync(this Rebuilder rebuilder, int batchSize, CancellationToken ct = default)
         {
-            return rebuilder.RebuildAsync<AssetDomainObject, AssetDomainObject.State>("^asset\\-", ct);
+            return rebuilder.RebuildAsync<AssetDomainObject, AssetDomainObject.State>("^asset\\-", batchSize, ct);
         }
 
-        public static Task RebuildAssetFoldersAsync(this Rebuilder rebuilder, CancellationToken ct = default)
+        public static Task RebuildAssetFoldersAsync(this Rebuilder rebuilder, int batchSize, CancellationToken ct = default)
         {
-            return rebuilder.RebuildAsync<AssetFolderDomainObject, AssetFolderDomainObject.State>("^assetFolder\\-", ct);
+            return rebuilder.RebuildAsync<AssetFolderDomainObject, AssetFolderDomainObject.State>("^assetFolder\\-", batchSize, ct);
         }
 
-        public static Task RebuildContentAsync(this Rebuilder rebuilder, CancellationToken ct = default)
+        public static Task RebuildContentAsync(this Rebuilder rebuilder, int batchSize, CancellationToken ct = default)
         {
-            return rebuilder.RebuildAsync<ContentDomainObject, ContentDomainObject.State>("^content\\-", ct);
+            return rebuilder.RebuildAsync<ContentDomainObject, ContentDomainObject.State>("^content\\-", batchSize, ct);
         }
     }
 }

backend/src/Squidex.Domain.Apps.Entities/Assets/BackupAssets.cs

@@ -21,6 +21,7 @@ namespace Squidex.Domain.Apps.Entities.Assets
 {
     public sealed class BackupAssets : IBackupHandler
     {
+        private const int BatchSize = 100;
         private const string TagsFile = "AssetTags.json";
         private readonly HashSet<DomainId> assetIds = new HashSet<DomainId>();
         private readonly HashSet<DomainId> assetFolderIds = new HashSet<DomainId>();
@@ -101,12 +102,12 @@ namespace Squidex.Domain.Apps.Entities.Assets
 
             if (assetIds.Count > 0)
             {
-                await rebuilder.InsertManyAsync<AssetDomainObject, AssetDomainObject.State>(assetIds);
+                await rebuilder.InsertManyAsync<AssetDomainObject, AssetDomainObject.State>(assetIds, BatchSize);
             }
 
             if (assetFolderIds.Count > 0)
             {
-                await rebuilder.InsertManyAsync<AssetFolderDomainObject, AssetFolderDomainObject.State>(assetFolderIds);
+                await rebuilder.InsertManyAsync<AssetFolderDomainObject, AssetFolderDomainObject.State>(assetFolderIds, BatchSize);
             }
         }
 

backend/src/Squidex.Domain.Apps.Entities/Backup/RestoreGrain.cs

@@ -1,4 +1,4 @@
-// ==========================================================================
+// ==========================================================================
 //  Squidex Headless CMS
 // ==========================================================================
 //  Copyright (c) Squidex UG (haftungsbeschraenkt)
@@ -356,7 +356,7 @@ namespace Squidex.Domain.Apps.Entities.Backup
 
             var batchBlock = new BatchBlock<(string, Envelope<IEvent>)>(BatchSize, new GroupingDataflowBlockOptions
             {
-                BoundedCapacity = BatchSize
+                BoundedCapacity = BatchSize * 2
             });
 
             batchBlock.LinkTo(writeBlock, new DataflowLinkOptions

backend/src/Squidex.Domain.Apps.Entities/Contents/BackupContents.cs

@@ -24,6 +24,7 @@ namespace Squidex.Domain.Apps.Entities.Contents
 {
     public sealed class BackupContents : IBackupHandler
     {
+        private const int BatchSize = 100;
         private delegate void ObjectSetter(IReadOnlyDictionary<string, IJsonValue> obj, string key, IJsonValue value);
 
         private const string UrlsFile = "Urls.json";
@@ -216,7 +217,7 @@ namespace Squidex.Domain.Apps.Entities.Contents
 
             if (ids.Any())
             {
-                await rebuilder.InsertManyAsync<ContentDomainObject, ContentDomainObject.State>(ids);
+                await rebuilder.InsertManyAsync<ContentDomainObject, ContentDomainObject.State>(ids, BatchSize);
             }
         }
 

backend/src/Squidex.Infrastructure/Commands/Rebuilder.cs

@@ -19,8 +19,6 @@ using Squidex.Infrastructure.States;
 
 namespace Squidex.Infrastructure.Commands
 {
-    public delegate Task IdSource(Func<DomainId, Task> add);
-
     public class Rebuilder
     {
         private readonly ILocalCache localCache;
@@ -51,7 +49,7 @@ namespace Squidex.Infrastructure.Commands
             this.localCache = localCache;
         }
 
-        public virtual async Task RebuildAsync<T, TState>(string filter, CancellationToken ct) where T : DomainObject<TState> where TState : class, IDomainState<TState>, new()
+        public virtual async Task RebuildAsync<T, TState>(string filter, int batchSize, CancellationToken ct = default) where T : DomainObject<TState> where TState : class, IDomainState<TState>, new()
         {
             var store = serviceProvider.GetRequiredService<IStore<TState>>();
 
@@ -65,12 +63,13 @@ namespace Squidex.Infrastructure.Commands
 
                     await target(id);
                 }
-            }, ct);
+            }, batchSize, ct);
         }
 
-        public virtual async Task InsertManyAsync<T, TState>(IEnumerable<DomainId> source, CancellationToken ct = default) where T : DomainObject<TState> where TState : class, IDomainState<TState>, new()
+        public virtual async Task InsertManyAsync<T, TState>(IEnumerable<DomainId> source, int batchSize, CancellationToken ct = default) where T : DomainObject<TState> where TState : class, IDomainState<TState>, new()
         {
             Guard.NotNull(source, nameof(source));
+            Guard.Between(batchSize, 1, 1000, nameof(batchSize));
 
             var store = serviceProvider.GetRequiredService<IStore<TState>>();
 
@@ -80,15 +79,13 @@ namespace Squidex.Infrastructure.Commands
                 {
                     await target(id);
                 }
-            }, ct);
+            }, batchSize, ct);
         }
 
-        private async Task InsertManyAsync<T, TState>(IStore<TState> store, IdSource source, CancellationToken ct = default) where T : DomainObject<TState> where TState : class, IDomainState<TState>, new()
+        private async Task InsertManyAsync<T, TState>(IStore<TState> store, Func<Func<DomainId, Task>, Task> source, int batchSize, CancellationToken ct = default) where T : DomainObject<TState> where TState : class, IDomainState<TState>, new()
         {
             var parallelism = Environment.ProcessorCount;
 
-            const int BatchSize = 100;
-
             var workerBlock = new ActionBlock<DomainId[]>(async ids =>
             {
                 try
@@ -127,9 +124,9 @@ namespace Squidex.Infrastructure.Commands
                 BoundedCapacity = parallelism
             });
 
-            var batchBlock = new BatchBlock<DomainId>(BatchSize, new GroupingDataflowBlockOptions
+            var batchBlock = new BatchBlock<DomainId>(batchSize, new GroupingDataflowBlockOptions
             {
-                BoundedCapacity = BatchSize
+                BoundedCapacity = batchSize
             });
 
             batchBlock.LinkTo(workerBlock, new DataflowLinkOptions

backend/src/Squidex/Areas/IdentityServer/Views/Account/AccessDenied.cshtml

@@ -1,6 +1,4 @@
 @{
-    ViewBag.ThemeColor = "white";
-
     ViewBag.Title = T.Get("users.accessDenied.title");
 }
 

backend/src/Squidex/Areas/IdentityServer/Views/Account/Consent.cshtml

@@ -1,9 +1,6 @@
 @model Squidex.Areas.IdentityServer.Controllers.Account.ConsentVM
 
 @{
-    ViewBag.ThemeColor = "white";
-    ViewBag.ThemeSize = "profile-lg";
-
     ViewBag.Title = T.Get("users.consent.title");
 }
 

backend/src/Squidex/Areas/IdentityServer/Views/Account/LockedOut.cshtml

@@ -1,6 +1,4 @@
 @{
-    ViewBag.ThemeColor = "white";
-
     ViewBag.Title = T.Get("users.lockedOutTitle");
 }
 

backend/src/Squidex/Areas/IdentityServer/Views/Account/Login.cshtml

@@ -1,8 +1,6 @@
 @model Squidex.Areas.IdentityServer.Controllers.Account.LoginVM
 
 @{
-    ViewBag.ThemeColor = "white";
-
     var action = Model.IsLogin ? T.Get("common.login") : T.Get("common.signup");
 
     ViewBag.Title = action;

backend/src/Squidex/Areas/IdentityServer/Views/Account/LogoutCompleted.cshtml

@@ -1,6 +1,4 @@
 @{
-    ViewBag.ThemeColor = "white";
-
     ViewBag.Title = T.Get("users.logout.title");
 }
 

backend/src/Squidex/Areas/IdentityServer/Views/Error/Error.cshtml

@@ -1,8 +1,6 @@
 @model Squidex.Areas.IdentityServer.Controllers.Error.ErrorVM
 
 @{
-    ViewBag.ThemeColor = "white";
-
     ViewBag.Title = T.Get("users.error.title");
 }
 
@@ -11,9 +9,9 @@
 <h1 class="splash-h1">@T.Get("users.error.headline")</h1>
 
 <p class="splash-text">
-    @if (Model.ErrorMessage != null)
+    @if (Model.Error?.ErrorDescription != null)
     {
-        @Model.ErrorMessage
+        @Model.Error.ErrorDescription
     }
     else
     {

backend/src/Squidex/Areas/IdentityServer/Views/Profile/Profile.cshtml

@@ -1,9 +1,6 @@
 @model Squidex.Areas.IdentityServer.Controllers.Profile.ProfileVM
 
 @{
-    ViewBag.ThemeColor = "white";
-    ViewBag.ThemeSize = "profile-lg";
-
     ViewBag.Title = T.Get("users.profile.title");
 
     void RenderValidation(string field)
@@ -279,7 +276,7 @@
     }
 
     document.addEventListener('click',
-        function(event) {
+        function (event) {
             if (event.target.className.indexOf('remove-item') >= 0) {
                 event.target.parentNode.parentNode.remove();
 

backend/src/Squidex/Areas/IdentityServer/Views/Setup/Setup.cshtml

@@ -1,9 +1,6 @@
 @model Squidex.Areas.IdentityServer.Controllers.Setup.SetupVM
 
 @{
-    ViewBag.ThemeColor = "gray";
-    ViewBag.ThemeSize = "profile-lg";
-
     ViewBag.Title = T.Get("setup.title");
 
     void RenderValidation(string field)
@@ -68,15 +65,13 @@
     }
 }
 
-<div class="card">
+<h1>@T.Get("setup.headline")</h1>
-    <div class="card-body">
-        <h1>@T.Get("setup.headline")</h1>
 
-        <img style="height: 250px" class="mt-2 mb-2" src="@Url.RootContentUrl("~/squid.svg?title=Welcome&text=Welcome%20to%20the%20Installation%20Process&face=happy")" />
+<img style="height: 250px" class="mt-2 mb-2" src="@Url.RootContentUrl("~/squid.svg?title=Welcome&text=Welcome%20to%20the%20Installation%20Process&face=happy")" />
 
-        <small class="form-text text-muted mt-2 mb-2">@T.Get("setup.hint")</small>
+<small class="form-text text-muted mt-2 mb-2">@T.Get("setup.hint")</small>
 
-        <div class="profile-section">
+<div class="profile-section">
     <h2>@T.Get("setup.rules.headline")</h2>
 
     @if (Model.IsValidHttps)
@@ -115,11 +110,11 @@
     {
         RenderRuleAsWarning(T.Get("setup.ruleFolder.warning"));
     }
-        </div>
+</div>
 
-        <hr />
+<hr />
 
-        <div class="profile-section">
+<div class="profile-section">
     <h2>@T.Get("setup.createUser.headline")</h2>
 
     @if (Model.HasExternalLogin)
@@ -190,12 +185,4 @@
             @T.Get("setup.createUser.failure")
         </div>
     }
-        </div>
-    </div>
-</div>
-
-<div class="text-center mt-4 mb-2">
-    <small class="text-muted">
-        @T.Get("setup.madeBy")<br />@T.Get("setup.madeByCopyright")
-    </small>
 </div>

backend/src/Squidex/Areas/IdentityServer/Views/_Layout.cshtml

@@ -17,12 +17,22 @@
         @await RenderSectionAsync("header")
     }
 </head>
-<body class="@ViewBag.ThemeColor">
+<body class="profile">
-    <div class="profile @ViewBag.ThemeSize">
+    <div class="profile-container">
         <img class="profile-logo" alt="@T.Get("common.product")S" title="@T.Get("common.product")" src="@Url.RootContentUrl("~/images/logo.svg")" />
 
+        <div class="profile-card card">
+            <div class="profile-card-body card-body">
                 @RenderBody()
             </div>
+        </div>
+
+        <div class="profile-footer text-center mt-4 mb-2">
+            <small class="text-muted">
+                @T.Get("setup.madeBy")<br />@T.Get("setup.madeByCopyright")
+            </small>
+        </div>
+    </div>
 
     <environment names="Development">
         <script type="text/javascript" src="https://localhost:3000/shims.js"></script>