dolittle/DotNET.SDK

Method TryAddConventionHandlerMethods has 42 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    bool TryAddConventionHandlerMethods(
        IEnumerable<MethodInfo> methods,
        EventHandlerId eventHandlerId,
        IEventTypes eventTypes,
        CreateTypedHandleMethod createTypedHandlerMethod,

Method CheckApplyInvocationsInOnMethods has 42 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    static void CheckApplyInvocationsInOnMethods(SyntaxNodeAnalysisContext context, INamedTypeSymbol aggregateType)
    {
        var onMethods = aggregateType
            .GetMembers()
            .Where(member => member.Name.Equals("On"))

Method InvokeAsync has 42 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public async Task InvokeAsync(HttpContext context)
    {
        if (_client is not { IsConnected: true })
        {
            DolittleClientNotReady();

Method On has 40 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    async Task On(ProjectedEvent projectedEvent, IContext context)
    {
        var firstEvent = _projection is null;
        if (firstEvent)
        {

Method Perform has 40 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public async Task<HandshakeResult> Perform(uint attemptNum, TimeSpan timeSpent, Version headVersion, IClientBuildResults buildResults, CancellationToken cancellationToken)
    {
        try
        {
            var contractsVersion = Contracts.VersionInfo.CurrentVersion.ToVersion();

Method Build has 40 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public static IUnregisteredEventHandlers Build(IModel model, IEventTypes eventTypes, IClientBuildResults buildResults)
    {
        var eventHandlers = new UniqueBindings<EventHandlerModelId, IEventHandler>();
        foreach (var (identifier, builder) in model.GetProcessorBuilderBindings<ConventionTypeEventHandlerBuilder>())
        {

Identical blocks of code found in 2 locations. Consider refactoring.

Open

    async Task Apply100Stupid(EventSourceId eventSource)
    {
        for (var i = 0; i < 99; i++)
        {
            await _aggregates.Get<AnAggregateRoot>(eventSource).Perform(_ => _.DoSomething()).ConfigureAwait(false);

• Read up
  Read up

Identical blocks of code found in 2 locations. Consider refactoring.

Open

    async Task Apply100Stupid(EventSourceId eventSource)
    {
        for (var i = 0; i < 99; i++)
        {
            await _aggregates.Get<AnAggregateRoot>(eventSource).Perform(_ => _.DoSomething()).ConfigureAwait(false);

• Read up
  Read up

Method OnReceivedRequest has 39 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    async Task OnReceivedRequest(IReverseCallHandler<TRequest, TResponse> handler, TRequest request, CancellationToken cancellationToken)
    {
        try
        {
            var requestContext = _protocol.GetRequestContextFrom(request);

Method TryAddDecoratedHandlerMethods has 38 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    bool TryAddDecoratedHandlerMethods(
        IEnumerable<MethodInfo> methods,
        EventHandlerId eventHandlerId,
        CreateUntypedHandleMethod createUntypedHandlerMethod,
        IDictionary<EventType, IEventHandlerMethod> eventTypesToMethods,

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    [Benchmark]
    public Task Applying100EventsWithNothingToReplay()
    {
        return Task.WhenAll(
            Apply100Events("aggregate1"),

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    [Benchmark]
    public Task Applying1Event100TimesWithNothingToReplay()
    {
        return Task.WhenAll(
            Apply100Stupid("aggregate1"),

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    public static IUnregisteredAggregateRoots Build(IModel model, IClientBuildResults buildResults)
    {
        var bindings = model.GetTypeBindings<AggregateRootType, AggregateRootId>().ToArray();
        foreach (var binding in bindings)
        {

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

using System;
using Dolittle.SDK.Tenancy;
using Microsoft.Extensions.Logging;

namespace Dolittle.SDK.Resources.Internal;

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

using System;
using Microsoft.Extensions.Logging;

namespace Dolittle.SDK.Events.Internal;

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

    public static IUnregisteredEventTypes Build(IModel model, IClientBuildResults buildResults)
    {
        var bindings = model.GetTypeBindings<EventType, EventTypeId>().ToArray();
        foreach (var binding in bindings)
        {

• Read up
  Read up

Method CheckOnMethods has 37 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    static HashSet<ITypeSymbol> CheckOnMethods(SyntaxNodeAnalysisContext context, INamedTypeSymbol aggregateType)
    {
        var members = aggregateType.GetMembers();
        var onMethods = members.Where(_ => _.Name.Equals("On")).OfType<IMethodSymbol>().ToArray();
        var eventTypesHandled = new HashSet<ITypeSymbol>(SymbolEqualityComparer.Default);

Method TryTo has 37 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public static bool TryTo<TArtifact, TId>(this PbArtifact source, [NotNullWhen(true)] out TArtifact? artifact, [NotNullWhen(false)] out Exception? error)
        where TArtifact : Artifact<TId>
        where TId : ArtifactId
    {
        artifact = default;

Method Deserialize has 36 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public T Deserialize(BsonDeserializationContext context, BsonDeserializationArgs args)
    {
        var bsonReader = context.Reader;
        var actualType = args.NominalType;
        var bsonType = bsonReader.GetCurrentBsonType();

Method CreateDependencies has 36 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    async Task CreateDependencies(
        IPerformMethodCalls methodCaller,
        DolittleClientConfiguration config,
        ILoggerFactory loggerFactory,
        ExecutionContext executionContext,