dolittle/DotNET.SDK

Class ConventionProjectionBuilder has 21 methods (exceeds 20 allowed). Consider refactoring.

Open

public class ConventionProjectionBuilder<TProjection> : ICanTryBuildProjection
    where TProjection : ReadModel, new()
{
    readonly ProjectionModelId _identifier;
    const string MethodName = "On";

Method Handle has 53 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public async Task Handle(IReverseCallHandler<TRequest, TResponse> handler, CancellationToken cancellationToken)
    {
        ThrowIfConnectionNotEstablished();
        ThrowIfAlreadyStartedHandling();
        lock (_handleLock)

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

Open

    static void CheckProjectionAttributePresent(SyntaxNodeAnalysisContext context, INamedTypeSymbol projectionClass)
    {
        var hasAttribute = projectionClass.GetAttributes()
            .Any(attribute => attribute.AttributeClass?.ToDisplayString().Equals(DolittleTypes.ProjectionAttribute, StringComparison.Ordinal) == true);

• Read up
  Read up

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

Open

    static void CheckAggregateRootAttributePresent(SyntaxNodeAnalysisContext context, INamedTypeSymbol aggregateClass)
    {
        var hasAttribute = aggregateClass.GetAttributes()
            .Any(attribute => attribute.AttributeClass?.ToDisplayString().Equals(DolittleTypes.AggregateRootAttribute, StringComparison.Ordinal) == true);

• Read up
  Read up

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

Open

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

Method RunProcessorForeverUntilCancelledWithGracefulDisconnect has 52 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    async Task RunProcessorForeverUntilCancelledWithGracefulDisconnect<TIdentifier, TClientMessage, TServerMessage, TRegisterArguments, TRegisterResponse,
        TRequest, TResponse>(
        IEventProcessor<TIdentifier, TRegisterArguments, TRequest, TResponse> eventProcessor,
        IAmAReverseCallProtocol<TClientMessage, TServerMessage, TRegisterArguments, TRegisterResponse, TRequest, TResponse> protocol,
        CancellationToken shutdownToken)

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

Open

    public override void IterationSetup()
    {
        base.IterationSetup();
        var client = GetConnectedClient(_ => _
            .WithEventTypes(_ => _.Register<AnEvent>().Register<LastEvent>())

• Read up
  Read up

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

Open

    public override void IterationSetup()
    {
        base.IterationSetup();
        var client = GetConnectedClient(_ => _
            .WithEventTypes(_ => _.Register<AnEvent>().Register<LastEvent>())

• Read up
  Read up

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

Open

    public override void IterationSetup()
    {
        base.IterationSetup();
        var client = GetConnectedClient(_ => _
            .WithEventTypes(_ => _.Register<AnEvent>().Register<LastEvent>())

• Read up
  Read up

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

Open

    static ProjectionSignature<TProjection> ResponseTypeReturn(MethodInfo method, ProjectionParametersType parametersType)
    {
        return parametersType switch
        {
            ProjectionParametersType.EventOnly

• Read up
  Read up

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

Open

    static ProjectionSignature<TProjection> VoidReturnType(MethodInfo method, ProjectionParametersType parametersType)
    {
        return parametersType switch
        {
            ProjectionParametersType.EventOnly

• Read up
  Read up

Method TryToExecutionContext has 49 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public static bool TryToExecutionContext(this PbExecutionContext source, out ExecutionContext executionContext, [NotNullWhen(false)] out Exception? error)
    {
        executionContext = default;

        if (source == default)

Method Connect has 48 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public async Task<IDolittleClient> Connect(DolittleClientConfiguration configuration, CancellationToken cancellationToken = default)
    {
        if (IsConnected)
        {
            throw new CannotConnectDolittleClientMultipleTimes();

Method TryAddConventionOnMethods has 47 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    bool TryAddConventionOnMethods(
        ProjectionModelId identifier,
        IEnumerable<MethodInfo> methods,
        IEventTypes eventTypes,
        IDictionary<EventType, IProjectionMethod<TProjection>> eventTypesToMethods,

Method ProcessSubscriptionRequest has 47 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    async Task<SubscribeResponse> ProcessSubscriptionRequest(Subscription subscription, SubscriptionRequest request, CancellationToken cancellationToken)
    {
        SubscribeResponse response = null;
        await _retryEventSubscription(subscription, _logger, async () =>
        {

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

Open

using Dolittle.SDK.Common.ClientSetup;

namespace Dolittle.SDK.Events.Filters.Builders.Partitioned;

/// <summary>

• Read up
  Read up

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

Open

using Dolittle.SDK.Common.ClientSetup;

namespace Dolittle.SDK.Events.Filters.Builders.Unpartitioned;

/// <summary>

• Read up
  Read up

Method TryConvert has 45 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    bool TryConvert(
        Runtime.Events.Contracts.CommittedAggregateEvents.Types.CommittedAggregateEvent source,
        EventSourceId eventSourceId,
        AggregateRootId aggregateRootId,
        [NotNullWhen(true)] out CommittedAggregateEvent? result,

Method TryAddDecoratedOnMethods has 44 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    bool TryAddDecoratedOnMethods(
        ProjectionModelId identifier,
        IEnumerable<MethodInfo> methods,
        IDictionary<EventType, IProjectionMethod<TProjection>> eventTypesToMethods,
        IClientBuildResults buildResults)

Method ReceiveAsync has 43 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    public async Task ReceiveAsync(IContext context)
    {
        try
        {
            switch (context.Message)