Files: terminate task
This commit is contained in:
parent
b0e4cbc618
commit
be87b5bef9
@ -1957,9 +1957,9 @@ public class FileStorageService //: IFileStorageService
|
||||
return _fileOperationsManager.GetOperationResults(_authContext.CurrentAccount.ID);
|
||||
}
|
||||
|
||||
public List<FileOperationResult> TerminateTasks()
|
||||
public List<FileOperationResult> TerminateTasks(string id = null)
|
||||
{
|
||||
return _fileOperationsManager.CancelOperations(_authContext.CurrentAccount.ID);
|
||||
return _fileOperationsManager.CancelOperations(_authContext.CurrentAccount.ID, id);
|
||||
}
|
||||
|
||||
public async Task<List<FileOperationResult>> BulkDownloadAsync(Dictionary<JsonElement, string> folders, Dictionary<JsonElement, string> files)
|
||||
|
@ -90,10 +90,10 @@ public class FileOperationsManager
|
||||
return results;
|
||||
}
|
||||
|
||||
public List<FileOperationResult> CancelOperations(Guid userId)
|
||||
public List<FileOperationResult> CancelOperations(Guid userId, string id = null)
|
||||
{
|
||||
var operations = _tasks.GetAllTasks()
|
||||
.Where(t => new Guid(t[FileOperation.Owner]) == userId);
|
||||
.Where(t => (string.IsNullOrEmpty(id) || t.Id == id) && new Guid(t[FileOperation.Owner]) == userId);
|
||||
|
||||
foreach (var o in operations)
|
||||
{
|
||||
|
@ -241,10 +241,10 @@ public class OperationController : ApiControllerBase
|
||||
/// <httpMethod>PUT</httpMethod>
|
||||
/// <collection>list</collection>
|
||||
[AllowAnonymous]
|
||||
[HttpPut("fileops/terminate")]
|
||||
public async IAsyncEnumerable<FileOperationDto> TerminateTasks()
|
||||
[HttpPut("fileops/terminate/{id?}")]
|
||||
public async IAsyncEnumerable<FileOperationDto> TerminateTasks(string id = null)
|
||||
{
|
||||
var tasks = _fileStorageService.TerminateTasks();
|
||||
var tasks = _fileStorageService.TerminateTasks(id);
|
||||
|
||||
foreach (var e in tasks)
|
||||
{
|
||||
|
Loading…
Reference in New Issue
Block a user