(#173) WIP: Cosmos changes to counteract breaking changes in EF 9.x.

Author: Adrian Hall

src/CommunityToolkit.Datasync.Server.EntityFrameworkCore/BaseEntityTableData.cs

@@ -10,7 +10,6 @@ namespace CommunityToolkit.Datasync.Server.EntityFrameworkCore;
 /// <summary>
 /// The base class for all the Entity Framework Core based table data classes.
 /// </summary>
-[Index(nameof(UpdatedAt), nameof(Deleted))]
 public abstract class BaseEntityTableData : ITableData
 {
     /// <inheritdoc />

src/CommunityToolkit.Datasync.Server.EntityFrameworkCore/EntityTableData.cs

@@ -2,6 +2,7 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 // See the LICENSE file in the project root for more information.
 
+using Microsoft.EntityFrameworkCore;
 using System.ComponentModel.DataAnnotations;
 using System.ComponentModel.DataAnnotations.Schema;
 
@@ -11,6 +12,7 @@ namespace CommunityToolkit.Datasync.Server.EntityFrameworkCore;
 /// A version of the <see cref="BaseEntityTableData"/> that is compatible with
 /// most of the Entity Framework Core drivers.
 /// </summary>
+[Index(nameof(UpdatedAt), nameof(Deleted))]
 public class EntityTableData : BaseEntityTableData
 {
     /// <inheritdoc />

src/CommunityToolkit.Datasync.Server.EntityFrameworkCore/EntityTableRepository.cs

@@ -138,7 +138,7 @@ public virtual async ValueTask CreateAsync(TEntity entity, CancellationToken can
         await WrapExceptionAsync(entity.Id, async () =>
         {
             // We do not use Any() here because it is not supported by all providers (e.g. Cosmos)
-            if (DataSet.Count(x => x.Id == entity.Id) > 0)
+            if ((await DataSet.CountAsync(x => x.Id == entity.Id, cancellationToken)) > 0)
             {
                 throw new HttpException((int)HttpStatusCode.Conflict) { Payload = await GetEntityAsync(entity.Id, cancellationToken).ConfigureAwait(false) };
             }