Fix PgVector ReloadTypesAsync compatibility with newer Npgsql

dotnet/src/VectorData/PgVector/PostgresCollection.cs

@@ -518,7 +518,7 @@ private async Task InternalCreateCollectionAsync(bool ifNotExists, CancellationT
 
             if (!extensionAlreadyExisted)
             {
-                await connection.ReloadTypesAsync().ConfigureAwait(false);
+                await PostgresUtils.ReloadTypesAsyncCompat(connection, cancellationToken).ConfigureAwait(false);
             }
 
             batch.BatchCommands.Clear();

dotnet/src/VectorData/PgVector/PostgresUtils.cs

@@ -1,6 +1,11 @@
 // Copyright (c) Microsoft. All rights reserved.
 
+using System;
 using System.Collections.Generic;
+using System.Collections.Concurrent;
+using System.Diagnostics.CodeAnalysis;
+using System.Reflection;
+using System.Threading;
 using System.Threading.Tasks;
 using Microsoft.Extensions.VectorData;
 using Npgsql;
@@ -10,6 +15,8 @@ namespace Microsoft.SemanticKernel.Connectors.PgVector;
 
 internal static class PostgresUtils
 {
+    private static readonly ConcurrentDictionary<Type, MethodInfo?> s_reloadTypesAsyncWithTokenMethods = new();
+
     /// <summary>
     /// Wraps an <see cref="IAsyncEnumerable{T}"/> in an <see cref="IAsyncEnumerable{T}"/> that will throw a <see cref="VectorStoreException"/>
     /// if an exception is thrown while iterating over the original enumerator.
@@ -72,4 +79,34 @@ internal static NpgsqlDataSource CreateDataSource(string connectionString)
         sourceBuilder.UseVector();
         return sourceBuilder.Build();
     }
+
+    internal static Task ReloadTypesAsyncCompat(object connection, CancellationToken cancellationToken = default)
+    {
+        Verify.NotNull(connection);
+
+        MethodInfo? reloadTypesWithToken = GetReloadTypesAsyncMethod(connection.GetType());
+        if (reloadTypesWithToken is null)
+        {
+            throw new MissingMethodException("No compatible ReloadTypesAsync overload found.");
+        }
+
+        object?[] parameters = reloadTypesWithToken.GetParameters().Length == 0 ? [] : [cancellationToken];
+        return (Task)reloadTypesWithToken.Invoke(connection, parameters)!;
+    }
+
+    private static MethodInfo? GetReloadTypesAsyncMethod(Type connectionType)
+        => s_reloadTypesAsyncWithTokenMethods.GetOrAdd(connectionType, static type => CreateReloadTypesAsyncMethod(type));
+
+    [UnconditionalSuppressMessage("Trimming", "IL2070", Justification = "Best-effort runtime compatibility probe for optional API shape.")]
+    private static MethodInfo? CreateReloadTypesAsyncMethod(Type connectionType)
+    {
+        MethodInfo? method = connectionType.GetMethod("ReloadTypesAsync", [typeof(CancellationToken)]);
+        if (method is not null && method.ReturnType == typeof(Task))
+        {
+            return method;
+        }
+
+        method = connectionType.GetMethod("ReloadTypesAsync", Type.EmptyTypes);
+        return method is not null && method.ReturnType == typeof(Task) ? method : null;
+    }
 }