src/Validation/gen/Extensions/IncrementalValuesProviderExtensions.cs - main - githubmirror/aspnetcore

src/Validation/gen/Extensions/IncrementalValuesProviderExtensions.cs
138 строк4 KB
Javier Calvarro Nelson
[Validation] Support generated `ValidatableTypeAttribute` for Blazor (#63115)
08 авг 2025, 23:33
08 авг 2025, 23:33a0991ea
// Licensed to the .NET Foundation under one or more agreements.
// The .NET Foundation licenses this file to you under the MIT license.

using System.Collections.Generic;
using System.Collections.Immutable;
using System.Linq;
using Microsoft.CodeAnalysis;

namespace Microsoft.Extensions.Validation;

internal static class IncrementalValuesProviderExtensions
{
    public static IncrementalValuesProvider<TSource> Distinct<TSource>(this IncrementalValuesProvider<TSource> source, IEqualityComparer<TSource> comparer)
    {
        return source
            .Collect()
            .WithComparer(ImmutableArrayEqualityComparer<TSource>.Instance)
            .SelectMany((values, cancellationToken) =>
            {
                if (values.IsEmpty)
                {
                    return values;
                }

                var results = ImmutableArray.CreateBuilder<TSource>(values.Length);
                HashSet<TSource> set = new(comparer);

                foreach (var value in values)
                {
                    if (set.Add(value))
                    {
                        results.Add(value);
                    }
                }

                return results.DrainToImmutable();
            });
    }

    public static IncrementalValuesProvider<T> Concat<T>(
        this IncrementalValuesProvider<ImmutableArray<T>> first,
        IncrementalValuesProvider<ImmutableArray<T>> second)
    {
        return first.Collect()
            .Combine(second.Collect())
            .SelectMany((tuple, _) =>
            {
                if (tuple.Left.IsEmpty && tuple.Right.IsEmpty)
                {
                    return [];
                }

                var results = ImmutableArray.CreateBuilder<T>(tuple.Left.Length + tuple.Right.Length);
                for (var i = 0; i < tuple.Left.Length; i++)
                {
                    results.AddRange(tuple.Left[i]);
                }
                for (var i = 0; i < tuple.Right.Length; i++)
                {
                    results.AddRange(tuple.Right[i]);
                }
                return results.DrainToImmutable();
            });
    }

    public static IncrementalValuesProvider<T> Concat<T>(
        this IncrementalValuesProvider<ImmutableArray<T>> first,
        IncrementalValuesProvider<T> second)
    {
        return first.Collect()
            .Combine(second.Collect())
            .SelectMany((tuple, _) =>
            {
                if (tuple.Left.IsEmpty)
                {
                    return tuple.Right;
                }

                var results = ImmutableArray.CreateBuilder<T>(tuple.Left.Length + tuple.Right.Length);
                for (var i = 0; i < tuple.Left.Length; i++)
                {
                    results.AddRange(tuple.Left[i]);
                }
                for (var i = 0; i < tuple.Right.Length; i++)
                {
                    results.AddRange(tuple.Right[i]);
                }
                return results.DrainToImmutable();
            });
    }

    private sealed class ImmutableArrayEqualityComparer<T> : IEqualityComparer<ImmutableArray<T>>
    {
        public static readonly ImmutableArrayEqualityComparer<T> Instance = new();

        public bool Equals(ImmutableArray<T> x, ImmutableArray<T> y)
        {
            if (x.IsDefault)
            {
                return y.IsDefault;
            }
            else if (y.IsDefault)
            {
                return false;
            }

            if (x.Length != y.Length)
            {
                return false;
            }

            for (var i = 0; i < x.Length; i++)
            {
                if (!EqualityComparer<T>.Default.Equals(x[i], y[i]))
                {
                    return false;
                }
            }

            return true;
        }

        public int GetHashCode(ImmutableArray<T> obj)
        {
            if (obj.IsDefault)
            {
                return 0;
            }
            var hashCode = -450793227;
            foreach (var item in obj)
            {
                hashCode = (hashCode * -1521134295) + EqualityComparer<T>.Default.GetHashCode(item);
            }

            return hashCode;
        }
    }
}