Use `DateTime.UtcNow` in `TokenCleanupService`.

Resolve #10956

modules/identityserver/src/Volo.Abp.IdentityServer.Domain/Volo/Abp/IdentityServer/Tokens/TokenCleanupService.cs

@@ -1,9 +1,9 @@
-using System.Threading.Tasks;
+using System;
+using System.Threading.Tasks;
 using Microsoft.Extensions.Options;
 using Volo.Abp.DependencyInjection;
 using Volo.Abp.IdentityServer.Devices;
 using Volo.Abp.IdentityServer.Grants;
-using Volo.Abp.Timing;
 using Volo.Abp.Uow;
 
 namespace Volo.Abp.IdentityServer.Tokens
@@ -12,43 +12,32 @@ namespace Volo.Abp.IdentityServer.Tokens
     {
         protected IPersistentGrantRepository PersistentGrantRepository { get; }
         protected IDeviceFlowCodesRepository DeviceFlowCodesRepository { get; }
-        protected IClock Clock { get; }
         protected TokenCleanupOptions Options { get; }
 
         public TokenCleanupService(
             IPersistentGrantRepository persistentGrantRepository,
             IDeviceFlowCodesRepository deviceFlowCodesRepository,
-            IClock clock,
             IOptions<TokenCleanupOptions> options)
         {
             PersistentGrantRepository = persistentGrantRepository;
             DeviceFlowCodesRepository = deviceFlowCodesRepository;
-            Clock = clock;
             Options = options.Value;
         }
 
         public virtual async Task CleanAsync()
         {
-            await RemoveGrantsAsync()
+            await RemoveGrantsAsync();
-                ;
-            
             await RemoveDeviceCodesAsync();
         }
 
         [UnitOfWork]
         protected virtual async Task RemoveGrantsAsync()
         {
-            for (int i = 0; i < Options.CleanupLoopCount; i++)
+            for (var i = 0; i < Options.CleanupLoopCount; i++)
             {
-                var persistentGrants = await PersistentGrantRepository
+                var persistentGrants = await PersistentGrantRepository.GetListByExpirationAsync(DateTime.UtcNow, Options.CleanupBatchSize);
-                    .GetListByExpirationAsync(Clock.Now, Options.CleanupBatchSize);
 
-                //TODO: Can be optimized if the repository implements the batch deletion
+                await PersistentGrantRepository.DeleteManyAsync(persistentGrants);
-                foreach (var persistentGrant in persistentGrants)
-                {
-                    await PersistentGrantRepository
-                        .DeleteAsync(persistentGrant);
-                }
 
                 //No need to continue to query if it gets more than max items.
                 if (persistentGrants.Count < Options.CleanupBatchSize)
@@ -60,17 +49,11 @@ namespace Volo.Abp.IdentityServer.Tokens
 
         protected virtual async Task RemoveDeviceCodesAsync()
         {
-            for (int i = 0; i < Options.CleanupLoopCount; i++)
+            for (var i = 0; i < Options.CleanupLoopCount; i++)
             {
-                var deviceFlowCodeses = await DeviceFlowCodesRepository
+                var deviceFlowCodeses = await DeviceFlowCodesRepository.GetListByExpirationAsync(DateTime.UtcNow, Options.CleanupBatchSize);
-                    .GetListByExpirationAsync(Clock.Now, Options.CleanupBatchSize);
 
-                //TODO: Can be optimized if the repository implements the batch deletion
+                await DeviceFlowCodesRepository.DeleteManyAsync(deviceFlowCodeses);
-                foreach (var deviceFlowCodes in deviceFlowCodeses)
-                {
-                    await DeviceFlowCodesRepository
-                        .DeleteAsync(deviceFlowCodes);
-                }
 
                 //No need to continue to query if it gets more than max items.
                 if (deviceFlowCodeses.Count < Options.CleanupBatchSize)
@@ -80,4 +63,4 @@ namespace Volo.Abp.IdentityServer.Tokens
             }
         }
     }
-}
+}