feat: get sync tasks support filter by repoId

vrcd-community · Aug 30, 2024 · 71b340b · 71b340b
1 parent 8a4bc3d
commit 71b340b
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/VPMReposSynchronizer.Core/Services/RepoSync/RepoSyncTaskService.cs b/VPMReposSynchronizer.Core/Services/RepoSync/RepoSyncTaskService.cs
@@ -67,9 +67,10 @@ await defaultDbContext.SyncTasks
                 .SetProperty(task => task.EndTime, endTime => currentDateTime));
     }
 
-    public async ValueTask<SyncTaskEntity[]> GetSyncTasksAsync(int offset = 0, int limit = 20)
+    public async ValueTask<SyncTaskEntity[]> GetSyncTasksAsync(int offset = 0, int limit = 20, string? repoId = null)
     {
         return await defaultDbContext.SyncTasks
+            .Where(task => repoId == null || task.RepoId == repoId)
             .OrderByDescending(task => task.Id)
             .Skip(offset)
             .Take(limit)

diff --git a/VPMReposSynchronizer.Entry/Controllers/SyncTaskController.cs b/VPMReposSynchronizer.Entry/Controllers/SyncTaskController.cs
@@ -18,9 +18,9 @@ public class SyncTaskController(
     IMapper mapper) : ControllerBase
 {
     [HttpGet]
-    public async Task<SyncTaskPublic[]> Index([Range(0, int.MaxValue)] int offset = 0, [Range(1, 100)] int limit = 20)
+    public async Task<SyncTaskPublic[]> Index([Range(0, int.MaxValue)] int offset = 0, [Range(1, 100)] int limit = 20, string? repoId = null)
     {
-        var syncTasks = await repoSyncTaskService.GetSyncTasksAsync(offset, limit);
+        var syncTasks = await repoSyncTaskService.GetSyncTasksAsync(offset, limit, repoId);
 
         return mapper.Map<SyncTaskPublic[]>(syncTasks);
     }