glax/Tranga
2
0
Fork 0
Code

Fixed empty returns if some value were null

Browse Source
This commit is contained in:
glax 2023-05-24 23:52:40 +02:00
parent fc89537f63
commit d6e75fda31
1 changed files with 72 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

94
Tranga-API/Program.cs
View File

@ -82,23 +82,45 @@ app.MapDelete("/Tasks/Delete", (string taskType, string? connectorName, string?
app.MapGet("/Tasks/Get", (string taskType, string? connectorName, string? searchString) => app.MapGet("/Tasks/Get", (string taskType, string? connectorName, string? searchString) =>
{ {
TrangaTask.Task task = Enum.Parse<TrangaTask.Task>(taskType); try
if (searchString is null) {
return taskManager.GetAllTasks().Where(tTask => tTask.task == task && tTask.connectorName == connectorName); TrangaTask.Task task = Enum.Parse<TrangaTask.Task>(taskType);
else if (searchString is null || connectorName is null)
return taskManager.GetAllTasks().Where(tTask => return taskManager.GetAllTasks().Where(tTask => tTask.task == task);
tTask.task == task && tTask.connectorName == connectorName && tTask.ToString() else
.Contains(searchString, StringComparison.InvariantCultureIgnoreCase)); return taskManager.GetAllTasks().Where(tTask =>
tTask.task == task && tTask.connectorName == connectorName && tTask.ToString()
.Contains(searchString, StringComparison.InvariantCultureIgnoreCase));
}
catch (ArgumentException)
{
return Array.Empty<TrangaTask>();
}
}); });
app.MapPost("/Tasks/Start", (string taskType, string? connectorName, string? publicationId) => app.MapPost("/Tasks/Start", (string taskType, string? connectorName, string? publicationId) =>
{ {
TrangaTask.Task pTask = Enum.Parse<TrangaTask.Task>(taskType); try
TrangaTask? task = taskManager.GetAllTasks().FirstOrDefault(tTask => {
tTask.task == pTask && tTask.publication?.internalId == publicationId && tTask.connectorName == connectorName); TrangaTask.Task pTask = Enum.Parse<TrangaTask.Task>(taskType);
if (task is null) TrangaTask? task = null;
if (connectorName is null || publicationId is null)
task = taskManager.GetAllTasks().FirstOrDefault(tTask =>
tTask.task == pTask);
else
task = taskManager.GetAllTasks().FirstOrDefault(tTask =>
tTask.task == pTask && tTask.publication?.internalId == publicationId &&
tTask.connectorName == connectorName);
if (task is null)
return;
taskManager.ExecuteTaskNow(task);
}
catch (ArgumentException)
{
return; return;
taskManager.ExecuteTaskNow(task); }
}); });
app.MapGet("/Tasks/GetRunningTasks", app.MapGet("/Tasks/GetRunningTasks",
@ -109,22 +131,50 @@ app.MapGet("/Queue/GetList",
app.MapPost("/Queue/Enqueue", (string taskType, string? connectorName, string? publicationId) => app.MapPost("/Queue/Enqueue", (string taskType, string? connectorName, string? publicationId) =>
{ {
TrangaTask.Task pTask = Enum.Parse<TrangaTask.Task>(taskType); try
TrangaTask? task = taskManager.GetAllTasks().FirstOrDefault(tTask => {
tTask.task == pTask && tTask.publication?.internalId == publicationId && tTask.connectorName == connectorName); TrangaTask.Task pTask = Enum.Parse<TrangaTask.Task>(taskType);
if (task is null) TrangaTask? task = null;
if (connectorName is null || publicationId is null)
task = taskManager.GetAllTasks().FirstOrDefault(tTask =>
tTask.task == pTask);
else
task = taskManager.GetAllTasks().FirstOrDefault(tTask =>
tTask.task == pTask && tTask.publication?.internalId == publicationId &&
tTask.connectorName == connectorName);
if (task is null)
return;
taskManager.AddTaskToQueue(task);
}
catch (ArgumentException)
{
return; return;
taskManager.AddTaskToQueue(task); }
}); });
app.MapDelete("/Queue/Dequeue", (string taskType, string? connectorName, string? publicationId) => app.MapDelete("/Queue/Dequeue", (string taskType, string? connectorName, string? publicationId) =>
{ {
TrangaTask.Task pTask = Enum.Parse<TrangaTask.Task>(taskType); try
TrangaTask? task = taskManager.GetAllTasks().FirstOrDefault(tTask => {
tTask.task == pTask && tTask.publication?.internalId == publicationId && tTask.connectorName == connectorName); TrangaTask.Task pTask = Enum.Parse<TrangaTask.Task>(taskType);
if (task is null) TrangaTask? task = null;
if (connectorName is null || publicationId is null)
task = taskManager.GetAllTasks().FirstOrDefault(tTask =>
tTask.task == pTask);
else
task = taskManager.GetAllTasks().FirstOrDefault(tTask =>
tTask.task == pTask && tTask.publication?.internalId == publicationId &&
tTask.connectorName == connectorName);
if (task is null)
return;
taskManager.RemoveTaskFromQueue(task);
}
catch (ArgumentException)
{
return; return;
taskManager.RemoveTaskFromQueue(task); }
}); });
app.MapGet("/Settings/Get", () => taskManager.settings); app.MapGet("/Settings/Get", () => taskManager.settings);