Add cancellation support to async methods

Introduce calls to `cancellationToken.ThrowIfCancellationRequested()` in various methods across the `XperienceCommunity.DataContext` namespace to ensure operations respect cancellation requests. Updated methods include `FirstOrDefaultAsync` and `ToListAsync` in `ContentItemContext.cs`, `PageContentContext.cs`, and `ReusableSchemaContext.cs`, as well as `ExecuteQueryAsync` in `ContentQueryExecutor.cs`, `PageContentQueryExecutor.cs`, and `ReusableSchemaExecutor.cs`. These changes improve the responsiveness and resource management of the application.

src/XperienceCommunity.DataContext/ContentItemContext.cs

@@ -63,6 +63,8 @@ public ContentItemContext(IWebsiteChannelContext websiteChannelContext,
         public async Task<T?> FirstOrDefaultAsync(Expression<Func<T, bool>> predicate,
             CancellationToken cancellationToken = default)
         {
+            cancellationToken.ThrowIfCancellationRequested();
+
             var queryBuilder = BuildQuery(predicate, topN: 1);
 
             var queryOptions = CreateQueryOptions();
@@ -134,6 +136,8 @@ public IDataContext<T> Take(int count)
         /// <returns>A task that represents the asynchronous operation. The task result contains the content items.</returns>
         public async Task<IEnumerable<T>> ToListAsync(CancellationToken cancellationToken = default)
         {
+            cancellationToken.ThrowIfCancellationRequested();
+
             ValidateQuery();
 
             var queryBuilder = BuildQuery(_query?.Expression!);

src/XperienceCommunity.DataContext/ContentQueryExecutor.cs

@@ -26,6 +26,8 @@ public ContentQueryExecutor(ILogger<ContentQueryExecutor<T>> logger, IContentQue
         public async Task<IEnumerable<T>> ExecuteQueryAsync(ContentItemQueryBuilder queryBuilder,
             ContentQueryExecutionOptions queryOptions, CancellationToken cancellationToken)
         {
+            cancellationToken.ThrowIfCancellationRequested();
+
             try
             {
                 var results = await _queryExecutor.GetMappedResult<T>(queryBuilder, queryOptions,
@@ -40,6 +42,8 @@ public async Task<IEnumerable<T>> ExecuteQueryAsync(ContentItemQueryBuilder quer
                 {
                     foreach (var processor in _processors.OrderBy(x=> x.Order))
                     {
+                        cancellationToken.ThrowIfCancellationRequested();
+
                         await processor.ProcessAsync(result, cancellationToken);
                     }
                 }

src/XperienceCommunity.DataContext/PageContentContext.cs

@@ -45,6 +45,8 @@ public PageContentContext(IProgressiveCache cache, PageContentQueryExecutor<T> p
         public async Task<T?> FirstOrDefaultAsync(Expression<Func<T, bool>> predicate,
             CancellationToken cancellationToken = default)
         {
+            cancellationToken.ThrowIfCancellationRequested();
+
             var queryBuilder = BuildQuery(predicate, topN: 1);
 
             var queryOptions = CreateQueryOptions();
@@ -121,6 +123,8 @@ public IDataContext<T> Take(int count)
         [return: NotNull]
         public async Task<IEnumerable<T>> ToListAsync(CancellationToken cancellationToken = default)
         {
+            cancellationToken.ThrowIfCancellationRequested();
+
             ValidateQuery();
 
             var queryBuilder = BuildQuery(_query?.Expression!);

src/XperienceCommunity.DataContext/PageContentQueryExecutor.cs

@@ -29,6 +29,8 @@ public async Task<IEnumerable<T>> ExecuteQueryAsync(ContentItemQueryBuilder quer
         {
             try
             {
+                cancellationToken.ThrowIfCancellationRequested();
+
                 var results = await _queryExecutor.GetMappedWebPageResult<T>(queryBuilder, queryOptions,
                     cancellationToken: cancellationToken);
 
@@ -41,6 +43,8 @@ public async Task<IEnumerable<T>> ExecuteQueryAsync(ContentItemQueryBuilder quer
                 {
                     foreach (var processor in _processors.OrderBy(x => x.Order))
                     {
+                        cancellationToken.ThrowIfCancellationRequested();
+
                         await processor.ProcessAsync(result, cancellationToken);
                     }
                 }

src/XperienceCommunity.DataContext/ReusableSchemaContext.cs

@@ -57,6 +57,8 @@ public ReusableSchemaContext(IWebsiteChannelContext websiteChannelContext,
         public async Task<T?> FirstOrDefaultAsync(Expression<Func<T, bool>> predicate,
             CancellationToken cancellationToken = default)
         {
+            cancellationToken.ThrowIfCancellationRequested();
+
             var queryBuilder = BuildQuery(predicate, 1);
 
             var queryOptions = CreateQueryOptions();
@@ -126,7 +128,10 @@ public IDataContext<T> Take(int count)
         /// <returns>A task that represents the asynchronous operation. The task result contains the content items.</returns>
         public async Task<IEnumerable<T>> ToListAsync(CancellationToken cancellationToken = default)
         {
+            cancellationToken.ThrowIfCancellationRequested();
+
             ValidateQuery();
+
             var queryBuilder = BuildQuery(_query?.Expression!);
 
             var queryOptions = CreateQueryOptions();

src/XperienceCommunity.DataContext/ReusableSchemaExecutor.cs

@@ -23,6 +23,8 @@ public async Task<IEnumerable<T>> ExecuteQueryAsync(ContentItemQueryBuilder quer
         {
             try
             {
+                cancellationToken.ThrowIfCancellationRequested();
+
                 var results = await _queryExecutor.GetMappedResult<T>(queryBuilder, queryOptions,
                     cancellationToken: cancellationToken);