Management new

.dockerignore

@@ -7,4 +7,5 @@ Benchmarks
 Diagrams
 .vscode
 **/node_modules
+**/wwwroot
 .github

.vscode/settings.json

@@ -11,10 +11,11 @@
     "git.ignoreLimitWarning": true,
     "dotnet-test-explorer.testProjectPath":"Specifications/**/*.csproj",
     "dotnet-test-explorer.treeMode": "full",
-    "dotnet-test-explorer.runInParallel": true,
+    "dotnet-test-explorer.runInParallel": false,
     "dotnet-test-explorer.showCodeLens": true,
     "dotnet-test-explorer.autoExpandTree": true,
     "cSpell.words": [
+        "fluentui",
         "Grpc",
         "Protobuf"
     ]

Docker/Development/Dockerfile

@@ -14,6 +14,17 @@ WORKDIR /app/Source/Server
 RUN dotnet restore
 RUN dotnet publish -c "Release" -p:Version=${VERSION} -p:RuntimeIdentifier="linux-${TARGETARCH/amd64/x64}" -o out
 
+# Web Build
+FROM node:14.2.0 AS web-build
+WORKDIR /app
+
+COPY Source/Management.Web ./Source/Management.Web
+
+WORKDIR /app/Source/Management.Web
+
+RUN yarn
+RUN yarn build
+
 # Runtime Image
 FROM mcr.microsoft.com/dotnet/aspnet:6.0
 SHELL ["/bin/bash", "-c"]
@@ -25,6 +36,7 @@ ENV DOLITTLE__RUNTIME__EVENTSTORE__BACKWARDSCOMPATIBILITY__VERSION="V7"
 WORKDIR /app
 COPY --from=dotnet-build /app/Source/Server/out ./
 COPY --from=dotnet-build /app/Source/Server/.dolittle ./.dolittle
+COPY --from=web-build /app/Source/Management.Web/wwwroot ./wwwroot
 
 # Install MongoDB dependencies
 RUN apt-get update \

Docker/Production/Dockerfile

@@ -1,3 +1,4 @@
+
 # DotNet Build
 FROM --platform=$BUILDPLATFORM mcr.microsoft.com/dotnet/sdk:6.0 AS dotnet-build
 SHELL ["/bin/bash", "-c"]
@@ -14,6 +15,17 @@ WORKDIR /app/Source/Server
 RUN dotnet restore
 RUN dotnet publish -c "Release" -p:Version=${VERSION} -p:RuntimeIdentifier="linux-${TARGETARCH/amd64/x64}" -o out
 
+# Web Build
+FROM node:14.2.0 AS web-build
+WORKDIR /app
+
+COPY Source/Management.Web ./Source/Management.Web
+
+WORKDIR /app/Source/Management.Web
+
+RUN yarn
+RUN yarn build
+
 # Runtime Image
 FROM mcr.microsoft.com/dotnet/aspnet:6.0
 SHELL ["/bin/bash", "-c"]
@@ -22,7 +34,7 @@ ENV Logging__Console__FormatterName=""
 
 WORKDIR /app
 COPY --from=dotnet-build /app/Source/Server/out ./
-COPY --from=dotnet-build /app/Source/Server/.dolittle ./.dolittle
+COPY --from=web-build /app/Source/Management.Web/wwwroot ./wwwroot
 COPY Docker/Production/.dolittle ./.dolittle
 
 EXPOSE 9700 50052 50053 51052

Source/Events.Processing/EventHandlers/EventHandler.cs

@@ -144,6 +144,23 @@ public async Task<Try<IDictionary<TenantId, Try<StreamPosition>>>> ReprocessAllE
         {
             return ex;
         }
+
+        async Task ValidateFilter()
+        {
+            _logger.ValidatingFilter(FilterDefinition.TargetStream);
+            var filterValidationResults = await _filterValidator.Validate(GetFilterProcessor, _cancellationTokenSource.Token).ConfigureAwait(false);
+
+            if (filterValidationResults.Any(_ => !_.Value.Succeeded))
+            {
+                var firstFailedValidation = filterValidationResults.First(_ => !_.Value.Succeeded).Value;
+                _logger.FilterValidationFailed(FilterDefinition.TargetStream, firstFailedValidation.FailureReason);
+                throw new FilterValidationFailed(FilterDefinition.TargetStream, firstFailedValidation.FailureReason);
+            }
+
+            var filteredStreamDefinition = new StreamDefinition(FilterDefinition);
+            _logger.PersistingStreamDefinition(filteredStreamDefinition.StreamId);
+            await _streamDefinitions.Persist(Scope, filteredStreamDefinition, _cancellationTokenSource.Token).ConfigureAwait(false);
+        }
     }
 
     /// <inheritdoc/>

Source/Management.GraphQL/EventHandlers/EventHandler.cs

@@ -0,0 +1,29 @@
+// Copyright (c) Dolittle. All rights reserved.
+// Licensed under the MIT license. See LICENSE file in the project root for full license information.
+
+using System;
+using System.Collections.Generic;
+
+namespace Dolittle.Runtime.Management.GraphQL.EventHandlers
+{
+    /// <summary>
+    /// Represents an event handler and its current state.
+    /// </summary>
+    public class EventHandler
+    {
+        /// <summary>
+        /// Gets the unique identifier of the <see cref="EventHandler"/>
+        /// </summary>
+        public Guid Id { get; set; }
+
+        /// <summary>
+        /// Gets the scope the unique handler works on.
+        /// </summary>
+        public Guid Scope { get; set; }
+
+        /// <summary>
+        /// Gets the collection of <see cref="EventHandlerStatusPerTenant">statuses per tenant</see>.
+        /// </summary>
+        public IEnumerable<EventHandlerStatusForTenant> StatusPerTenant { get; set; }
+    }
+}

Source/Management.GraphQL/EventHandlers/EventHandlerStatusForTenant.cs

@@ -0,0 +1,33 @@
+// Copyright (c) Dolittle. All rights reserved.
+// Licensed under the MIT license. See LICENSE file in the project root for full license information.
+
+using System;
+
+namespace Dolittle.Runtime.Management.GraphQL.EventHandlers
+{
+    /// <summary>
+    /// Represents the status for a specific <see cref="EventHandler"/> for a specific tenant.
+    /// </summary>
+    public class EventHandlerStatusForTenant
+    {
+        /// <summary>
+        /// Gets or sets the identifier of the tenant.
+        /// </summary>
+        public Guid TenantId { get; set; }
+
+        /// <summary>
+        /// Gets or sets the last committed event sequence number.
+        /// </summary>
+        public int LastCommittedEventSequenceNumber { get; set; }
+
+        /// <summary>
+        /// Gets or sets the filter position.
+        /// </summary>
+        public int FilterPosition { get; set; }
+
+        /// <summary>
+        /// Gets or sets the vent processor position.
+        /// </summary>
+        public int EventProcessorPosition { get; set; }
+    }
+}

Source/Management.GraphQL/EventHandlers/EventHandlers.cs

@@ -0,0 +1,81 @@
+// Copyright (c) Dolittle. All rights reserved.
+// Licensed under the MIT license. See LICENSE file in the project root for full license information.
+
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading.Tasks;
+using Dolittle.Runtime.ApplicationModel;
+using Dolittle.Runtime.DependencyInversion;
+using Dolittle.Runtime.Events.Processing.EventHandlers;
+using Dolittle.Runtime.Events.Store;
+using Dolittle.Runtime.Execution;
+using Dolittle.Runtime.Tenancy;
+
+namespace Dolittle.Runtime.Management.GraphQL.EventHandlers
+{
+    /// <summary>
+    /// Represents an API endpoint for working with event handlers.
+    /// </summary>
+    public class EventHandlers
+    {
+        readonly IEventHandlers _eventHandlers;
+        readonly IExecutionContextManager _executionContextManager;
+        readonly IContainer _container;
+        readonly ITenants _tenants;
+
+        /// <summary>
+        /// Initializes a new instance of <see cref="EventHandlers"/>.
+        /// </summary>
+        /// <param name="eventHandlers">The runtime <see cref="IEventHandlers"/>.</param>
+        /// <param name="executionContextManager">The <see cref="IExecutionContextManager"/> for working with execution context.</param>
+        /// <param name="container">The <see cref="IContainer"/> for service location.</param>
+        /// <param name="tenants">The <see cref="ITenants"/> of the runtime.</param>
+        public EventHandlers(
+            IEventHandlers eventHandlers,
+            IExecutionContextManager executionContextManager,
+            IContainer container,
+            ITenants tenants)
+        {
+            _eventHandlers = eventHandlers;
+            _executionContextManager = executionContextManager;
+            _container = container;
+            _tenants = tenants;
+        }
+
+        /// <summary>
+        /// Get all event handlers and their statuses.
+        /// </summary>
+        public async Task<IEnumerable<EventHandler>> All()
+        {
+            var lastCommittedEventSequenceNumberPerTenant = new Dictionary<TenantId, EventLogSequenceNumber>();
+
+            var tasks = _tenants.All.Select(async tenant =>
+            {
+                _executionContextManager.CurrentFor(Microservice.NotSet, tenant);
+                var eventStore = _container.Get<FactoryFor<IEventStore>>()();
+                lastCommittedEventSequenceNumberPerTenant[tenant] = await eventStore.GetLastCommittedEventSequenceNumber().ConfigureAwait(false);
+            });
+            await Task.WhenAll(tasks).ConfigureAwait(false);
+
+            return _eventHandlers.All.Select(_ =>
+            {
+                var query = from filter in _.FilterStreamProcessor.StreamProcessorsPerTenant
+                            join eventProcessor in _.EventProcessorStreamProcessor.StreamProcessorsPerTenant on filter.Key equals eventProcessor.Key
+                            select new EventHandlerStatusForTenant
+                            {
+                                TenantId = filter.Key,
+                                LastCommittedEventSequenceNumber = (int)lastCommittedEventSequenceNumberPerTenant[filter.Key].Value,
+                                FilterPosition = (int)filter.Value.CurrentState.Position.Value,
+                                EventProcessorPosition = (int)eventProcessor.Value.CurrentState.Position.Value
+                            };
+
+                return new EventHandler
+                {
+                    Id = _.EventProcessor,
+                    Scope = _.Scope,
+                    StatusPerTenant = query.ToArray()
+                };
+            });
+        }
+    }
+}

Source/Management.GraphQL/GraphQLEndpoints.cs

@@ -0,0 +1,29 @@
+// Copyright (c) Dolittle. All rights reserved.
+// Licensed under the MIT license. See LICENSE file in the project root for full license information.
+
+using HotChocolate.Execution.Configuration;
+using Microsoft.Extensions.DependencyInjection;
+
+namespace Dolittle.Runtime.Management.GraphQL
+{
+    /// <summary>
+    /// Represents extension methods for working with exposing the GraphQL endpoints for management.
+    /// </summary>
+    public static class GraphQLEndpoints
+    {
+        /// <summary>
+        /// Adds the GraphQL API for management to the HotChocolate GraphQL builder.
+        /// </summary>
+        /// <param name="graphQLBuilder"><see cref="IRequestExecutorBuilder"/> to add to.</param>
+        /// <returns><see cref="IRequestExecutorBuilder"/> for continuation.</returns>
+        public static IRequestExecutorBuilder AddManagementAPI(this IRequestExecutorBuilder graphQLBuilder)
+        {
+            graphQLBuilder.AddQueryType(_ => _
+                .Name("Query")
+                    .AddSubObject<EventHandlers.EventHandlers>("eventHandlers")
+                    .AddSubObject<Tenancy.Tenants>("tenancy")
+            );
+            return graphQLBuilder;
+        }
+    }
+}

Source/Management.GraphQL/Management.GraphQL.csproj

@@ -0,0 +1,18 @@
+<Project Sdk="Microsoft.NET.Sdk">
+    <Import Project="../../default.props"/>
+
+    <PropertyGroup>
+        <AssemblyName>Dolittle.Runtime.Management.GraphQL</AssemblyName>
+        <RootNamespace>Dolittle.Runtime.Management.GraphQL</RootNamespace>
+    </PropertyGroup>
+
+    <ItemGroup>
+        <PackageReference Include="HotChocolate.AspNetCore" Version="$(HotChocolateVersion)" />
+    </ItemGroup>
+
+    <ItemGroup>
+        <ProjectReference Include="../Tenancy/Tenancy.csproj"/>
+        <ProjectReference Include="../Events.Processing/Events.Processing.csproj"/>
+    </ItemGroup>
+
+</Project>

Source/Management.GraphQL/ObjectFieldExtensions.cs

@@ -0,0 +1,30 @@
+// Copyright (c) Dolittle. All rights reserved.
+// Licensed under the MIT license. See LICENSE file in the project root for full license information.
+
+using System;
+using HotChocolate.Types;
+using Microsoft.Extensions.DependencyInjection;
+
+namespace Dolittle.Runtime.Management.GraphQL
+{
+    /// <summary>
+    /// Extension methods for <see cref="IObjectTypeDescriptor"/> and fields.
+    /// </summary>
+    public static class ObjectFieldExtensions
+    {
+        public static IServiceProvider ServiceProvider { get; set; }
+
+        /// <summary>
+        /// Add a sub field on a type, such as a Query / Mutation root object with a given name that will resolve to the given type.
+        /// </summary>
+        /// <param name="parent">Parent type (Query/Mutation).</param>
+        /// <param name="name">Name of the field.</param>
+        /// <typeparam name="T">Type that the field should resolve to.</typeparam>
+        /// <returns><see cref="IObjectTypeDescriptor"/> for continuation.</returns>
+        public static IObjectTypeDescriptor AddSubObject<T>(this IObjectTypeDescriptor parent, string name)
+        {
+            parent.Field(name).Type(typeof(EventHandlers.EventHandlers)).Resolve(_ => ServiceProvider.GetService<T>());
+            return parent;
+        }
+    }
+}

Source/Management.GraphQL/Tenancy/Tenants.cs

@@ -0,0 +1,32 @@
+// Copyright (c) Dolittle. All rights reserved.
+// Licensed under the MIT license. See LICENSE file in the project root for full license information.
+
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using Dolittle.Runtime.Tenancy;
+
+namespace Dolittle.Runtime.Management.GraphQL.Tenancy
+{
+    /// <summary>
+    /// Represents an API for getting all tenants.
+    /// </summary>
+    public class Tenants
+    {
+        readonly ITenants _tenants;
+
+        /// <summary>
+        /// Initializes a new instance of <see cref="Tenants"/>.
+        /// </summary>
+        /// <param name="tenants">The runtime <see cref="ITenants"/>.</param>
+        public Tenants(ITenants tenants)
+        {
+            _tenants = tenants;
+        }
+
+        /// <summary>
+        /// Gets all the tenants registered with the runtime.
+        /// </summary>
+        public IEnumerable<Guid> All() => _tenants.All.Select(_ => _.Value);
+    }
+}