diff --git a/src/OpenIddict.EntityFramework/Stores/OpenIddictApplicationStore.cs b/src/OpenIddict.EntityFramework/Stores/OpenIddictApplicationStore.cs index 19b29cee..56fb1800 100644 --- a/src/OpenIddict.EntityFramework/Stores/OpenIddictApplicationStore.cs +++ b/src/OpenIddict.EntityFramework/Stores/OpenIddictApplicationStore.cs @@ -5,6 +5,7 @@ */ using System; +using System.Collections.Generic; using System.Collections.Immutable; using System.Data.Entity; using System.Linq; @@ -108,7 +109,7 @@ namespace OpenIddict.EntityFramework throw new ArgumentNullException(nameof(query)); } - return query.Invoke(Applications).LongCountAsync(); + return query(Applications).LongCountAsync(); } /// @@ -169,18 +170,18 @@ namespace OpenIddict.EntityFramework throw new ArgumentNullException(nameof(application)); } - Task ListAuthorizationsAsync() + Task> ListAuthorizationsAsync() { return (from authorization in Authorizations.Include(authorization => authorization.Tokens) where authorization.Application.Id.Equals(application.Id) - select authorization).ToArrayAsync(cancellationToken); + select authorization).ToListAsync(cancellationToken); } - Task ListTokensAsync() + Task> ListTokensAsync() { return (from token in Tokens where token.Application.Id.Equals(application.Id) - select token).ToArrayAsync(cancellationToken); + select token).ToListAsync(cancellationToken); } // Remove all the authorizations associated with the application and @@ -242,7 +243,7 @@ namespace OpenIddict.EntityFramework throw new ArgumentNullException(nameof(query)); } - return query.Invoke(Applications).SingleOrDefaultAsync(cancellationToken); + return query(Applications).SingleOrDefaultAsync(cancellationToken); } /// @@ -262,7 +263,7 @@ namespace OpenIddict.EntityFramework throw new ArgumentNullException(nameof(query)); } - return ImmutableArray.Create(await query.Invoke(Applications).ToArrayAsync(cancellationToken)); + return ImmutableArray.CreateRange(await query(Applications).ToListAsync(cancellationToken)); } /// diff --git a/src/OpenIddict.EntityFramework/Stores/OpenIddictAuthorizationStore.cs b/src/OpenIddict.EntityFramework/Stores/OpenIddictAuthorizationStore.cs index fca131b7..2b713ae9 100644 --- a/src/OpenIddict.EntityFramework/Stores/OpenIddictAuthorizationStore.cs +++ b/src/OpenIddict.EntityFramework/Stores/OpenIddictAuthorizationStore.cs @@ -5,6 +5,7 @@ */ using System; +using System.Collections.Generic; using System.Collections.Immutable; using System.Data.Entity; using System.Linq; @@ -108,7 +109,7 @@ namespace OpenIddict.EntityFramework throw new ArgumentNullException(nameof(query)); } - return query.Invoke(Authorizations).LongCountAsync(); + return query(Authorizations).LongCountAsync(); } /// @@ -169,11 +170,11 @@ namespace OpenIddict.EntityFramework throw new ArgumentNullException(nameof(authorization)); } - Task ListTokensAsync() + Task> ListTokensAsync() { return (from token in Tokens where token.Application.Id.Equals(authorization.Id) - select token).ToArrayAsync(cancellationToken); + select token).ToListAsync(cancellationToken); } // Remove all the tokens associated with the application. @@ -255,7 +256,7 @@ namespace OpenIddict.EntityFramework throw new ArgumentNullException(nameof(query)); } - return query.Invoke(Authorizations).SingleOrDefaultAsync(cancellationToken); + return query(Authorizations).SingleOrDefaultAsync(cancellationToken); } /// @@ -275,7 +276,7 @@ namespace OpenIddict.EntityFramework throw new ArgumentNullException(nameof(query)); } - return ImmutableArray.Create(await query.Invoke(Authorizations).ToArrayAsync(cancellationToken)); + return ImmutableArray.CreateRange(await query(Authorizations).ToListAsync(cancellationToken)); } /// diff --git a/src/OpenIddict.EntityFramework/Stores/OpenIddictScopeStore.cs b/src/OpenIddict.EntityFramework/Stores/OpenIddictScopeStore.cs index 4435a21b..3a7a78ba 100644 --- a/src/OpenIddict.EntityFramework/Stores/OpenIddictScopeStore.cs +++ b/src/OpenIddict.EntityFramework/Stores/OpenIddictScopeStore.cs @@ -89,7 +89,7 @@ namespace OpenIddict.EntityFramework throw new ArgumentNullException(nameof(query)); } - return query.Invoke(Scopes).LongCountAsync(); + return query(Scopes).LongCountAsync(); } /// @@ -167,7 +167,7 @@ namespace OpenIddict.EntityFramework throw new ArgumentNullException(nameof(query)); } - return query.Invoke(Scopes).SingleOrDefaultAsync(cancellationToken); + return query(Scopes).SingleOrDefaultAsync(cancellationToken); } /// @@ -187,7 +187,7 @@ namespace OpenIddict.EntityFramework throw new ArgumentNullException(nameof(query)); } - return ImmutableArray.Create(await query.Invoke(Scopes).ToArrayAsync(cancellationToken)); + return ImmutableArray.CreateRange(await query(Scopes).ToListAsync(cancellationToken)); } /// diff --git a/src/OpenIddict.EntityFramework/Stores/OpenIddictTokenStore.cs b/src/OpenIddict.EntityFramework/Stores/OpenIddictTokenStore.cs index 8ea87721..824afbf1 100644 --- a/src/OpenIddict.EntityFramework/Stores/OpenIddictTokenStore.cs +++ b/src/OpenIddict.EntityFramework/Stores/OpenIddictTokenStore.cs @@ -108,7 +108,7 @@ namespace OpenIddict.EntityFramework throw new ArgumentNullException(nameof(query)); } - return query.Invoke(Tokens).LongCountAsync(); + return query(Tokens).LongCountAsync(); } /// @@ -240,7 +240,7 @@ namespace OpenIddict.EntityFramework throw new ArgumentNullException(nameof(query)); } - return query.Invoke(Tokens).SingleOrDefaultAsync(cancellationToken); + return query(Tokens).SingleOrDefaultAsync(cancellationToken); } /// @@ -292,7 +292,7 @@ namespace OpenIddict.EntityFramework throw new ArgumentNullException(nameof(query)); } - return ImmutableArray.Create(await query.Invoke(Tokens).ToArrayAsync(cancellationToken)); + return ImmutableArray.CreateRange(await query(Tokens).ToListAsync(cancellationToken)); } /// diff --git a/src/OpenIddict.EntityFrameworkCore/Stores/OpenIddictApplicationStore.cs b/src/OpenIddict.EntityFrameworkCore/Stores/OpenIddictApplicationStore.cs index 86e8516a..924b51cd 100644 --- a/src/OpenIddict.EntityFrameworkCore/Stores/OpenIddictApplicationStore.cs +++ b/src/OpenIddict.EntityFrameworkCore/Stores/OpenIddictApplicationStore.cs @@ -5,6 +5,7 @@ */ using System; +using System.Collections.Generic; using System.Collections.Immutable; using System.Linq; using System.Threading; @@ -108,7 +109,7 @@ namespace OpenIddict.EntityFrameworkCore throw new ArgumentNullException(nameof(query)); } - return query.Invoke(Applications).LongCountAsync(); + return query(Applications).LongCountAsync(); } /// @@ -169,18 +170,18 @@ namespace OpenIddict.EntityFrameworkCore throw new ArgumentNullException(nameof(application)); } - Task ListAuthorizationsAsync() + Task> ListAuthorizationsAsync() { return (from authorization in Authorizations.Include(authorization => authorization.Tokens) where authorization.Application.Id.Equals(application.Id) - select authorization).ToArrayAsync(cancellationToken); + select authorization).ToListAsync(cancellationToken); } - Task ListTokensAsync() + Task> ListTokensAsync() { return (from token in Tokens where token.Application.Id.Equals(application.Id) - select token).ToArrayAsync(cancellationToken); + select token).ToListAsync(cancellationToken); } // Remove all the authorizations associated with the application and @@ -242,7 +243,7 @@ namespace OpenIddict.EntityFrameworkCore throw new ArgumentNullException(nameof(query)); } - return query.Invoke(Applications).SingleOrDefaultAsync(cancellationToken); + return query(Applications).SingleOrDefaultAsync(cancellationToken); } /// @@ -262,7 +263,7 @@ namespace OpenIddict.EntityFrameworkCore throw new ArgumentNullException(nameof(query)); } - return ImmutableArray.Create(await query.Invoke(Applications).ToArrayAsync(cancellationToken)); + return ImmutableArray.CreateRange(await query(Applications).ToListAsync(cancellationToken)); } /// diff --git a/src/OpenIddict.EntityFrameworkCore/Stores/OpenIddictAuthorizationStore.cs b/src/OpenIddict.EntityFrameworkCore/Stores/OpenIddictAuthorizationStore.cs index a2bc9741..8e37979d 100644 --- a/src/OpenIddict.EntityFrameworkCore/Stores/OpenIddictAuthorizationStore.cs +++ b/src/OpenIddict.EntityFrameworkCore/Stores/OpenIddictAuthorizationStore.cs @@ -5,6 +5,7 @@ */ using System; +using System.Collections.Generic; using System.Collections.Immutable; using System.Linq; using System.Threading; @@ -108,7 +109,7 @@ namespace OpenIddict.EntityFrameworkCore throw new ArgumentNullException(nameof(query)); } - return query.Invoke(Authorizations).LongCountAsync(); + return query(Authorizations).LongCountAsync(); } /// @@ -169,11 +170,11 @@ namespace OpenIddict.EntityFrameworkCore throw new ArgumentNullException(nameof(authorization)); } - Task ListTokensAsync() + Task> ListTokensAsync() { return (from token in Tokens where token.Application.Id.Equals(authorization.Id) - select token).ToArrayAsync(cancellationToken); + select token).ToListAsync(cancellationToken); } // Remove all the tokens associated with the application. @@ -226,7 +227,7 @@ namespace OpenIddict.EntityFrameworkCore select authorization; } - return ImmutableArray.Create(await Query(Authorizations, Applications).ToArrayAsync(cancellationToken)); + return ImmutableArray.CreateRange(await Query(Authorizations, Applications).ToListAsync(cancellationToken)); } /// @@ -297,7 +298,7 @@ namespace OpenIddict.EntityFrameworkCore throw new ArgumentNullException(nameof(query)); } - return query.Invoke(Authorizations).SingleOrDefaultAsync(cancellationToken); + return query(Authorizations).SingleOrDefaultAsync(cancellationToken); } /// @@ -317,7 +318,7 @@ namespace OpenIddict.EntityFrameworkCore throw new ArgumentNullException(nameof(query)); } - return ImmutableArray.Create(await query.Invoke(Authorizations).ToArrayAsync(cancellationToken)); + return ImmutableArray.CreateRange(await query(Authorizations).ToListAsync(cancellationToken)); } /// diff --git a/src/OpenIddict.EntityFrameworkCore/Stores/OpenIddictScopeStore.cs b/src/OpenIddict.EntityFrameworkCore/Stores/OpenIddictScopeStore.cs index 11876fbf..78a4faff 100644 --- a/src/OpenIddict.EntityFrameworkCore/Stores/OpenIddictScopeStore.cs +++ b/src/OpenIddict.EntityFrameworkCore/Stores/OpenIddictScopeStore.cs @@ -89,7 +89,7 @@ namespace OpenIddict.EntityFrameworkCore throw new ArgumentNullException(nameof(query)); } - return query.Invoke(Scopes).LongCountAsync(); + return query(Scopes).LongCountAsync(); } /// @@ -167,7 +167,7 @@ namespace OpenIddict.EntityFrameworkCore throw new ArgumentNullException(nameof(query)); } - return query.Invoke(Scopes).SingleOrDefaultAsync(cancellationToken); + return query(Scopes).SingleOrDefaultAsync(cancellationToken); } /// @@ -187,7 +187,7 @@ namespace OpenIddict.EntityFrameworkCore throw new ArgumentNullException(nameof(query)); } - return ImmutableArray.Create(await query.Invoke(Scopes).ToArrayAsync(cancellationToken)); + return ImmutableArray.CreateRange(await query(Scopes).ToListAsync(cancellationToken)); } /// diff --git a/src/OpenIddict.EntityFrameworkCore/Stores/OpenIddictTokenStore.cs b/src/OpenIddict.EntityFrameworkCore/Stores/OpenIddictTokenStore.cs index e946374a..999785b9 100644 --- a/src/OpenIddict.EntityFrameworkCore/Stores/OpenIddictTokenStore.cs +++ b/src/OpenIddict.EntityFrameworkCore/Stores/OpenIddictTokenStore.cs @@ -108,7 +108,7 @@ namespace OpenIddict.EntityFrameworkCore throw new ArgumentNullException(nameof(query)); } - return query.Invoke(Tokens).LongCountAsync(); + return query(Tokens).LongCountAsync(); } /// @@ -203,7 +203,7 @@ namespace OpenIddict.EntityFrameworkCore select token; } - return ImmutableArray.Create(await Query(Applications, Tokens).ToArrayAsync(cancellationToken)); + return ImmutableArray.CreateRange(await Query(Applications, Tokens).ToListAsync(cancellationToken)); } /// @@ -237,7 +237,7 @@ namespace OpenIddict.EntityFrameworkCore select token; } - return ImmutableArray.Create(await Query(Authorizations, Tokens).ToArrayAsync(cancellationToken)); + return ImmutableArray.CreateRange(await Query(Authorizations, Tokens).ToListAsync(cancellationToken)); } /// @@ -308,7 +308,7 @@ namespace OpenIddict.EntityFrameworkCore throw new ArgumentNullException(nameof(query)); } - return query.Invoke(Tokens).SingleOrDefaultAsync(cancellationToken); + return query(Tokens).SingleOrDefaultAsync(cancellationToken); } /// @@ -360,7 +360,7 @@ namespace OpenIddict.EntityFrameworkCore throw new ArgumentNullException(nameof(query)); } - return ImmutableArray.Create(await query.Invoke(Tokens).ToArrayAsync(cancellationToken)); + return ImmutableArray.CreateRange(await query(Tokens).ToListAsync(cancellationToken)); } ///