Compare commits
No commits in common. "553a77320db86e8596b1729837ee03a0cef88458" and "d659a269870a637122ee253641c70e7da206ecc4" have entirely different histories.
553a77320d
...
d659a26987
@ -37,7 +37,7 @@ public static class Tranga_Cli
|
|||||||
switch (menu)
|
switch (menu)
|
||||||
{
|
{
|
||||||
case 1:
|
case 1:
|
||||||
PrintTasks(taskManager.GetAllTasks());
|
PrintTasks(taskManager);
|
||||||
Console.WriteLine("Press any key.");
|
Console.WriteLine("Press any key.");
|
||||||
Console.ReadKey();
|
Console.ReadKey();
|
||||||
menu = 0;
|
menu = 0;
|
||||||
@ -61,14 +61,8 @@ public static class Tranga_Cli
|
|||||||
Console.ReadKey();
|
Console.ReadKey();
|
||||||
menu = 0;
|
menu = 0;
|
||||||
break;
|
break;
|
||||||
case 4:
|
|
||||||
ExecuteTask(taskManager);
|
|
||||||
Console.WriteLine("Press any key.");
|
|
||||||
Console.ReadKey();
|
|
||||||
menu = 0;
|
|
||||||
break;
|
|
||||||
default:
|
default:
|
||||||
selection = Menu(taskManager, folderPath);
|
selection = Menu(folderPath);
|
||||||
switch (selection)
|
switch (selection)
|
||||||
{
|
{
|
||||||
case ConsoleKey.L:
|
case ConsoleKey.L:
|
||||||
@ -80,9 +74,6 @@ public static class Tranga_Cli
|
|||||||
case ConsoleKey.D:
|
case ConsoleKey.D:
|
||||||
menu = 3;
|
menu = 3;
|
||||||
break;
|
break;
|
||||||
case ConsoleKey.E:
|
|
||||||
menu = 4;
|
|
||||||
break;
|
|
||||||
default:
|
default:
|
||||||
menu = 0;
|
menu = 0;
|
||||||
break;
|
break;
|
||||||
@ -90,65 +81,40 @@ public static class Tranga_Cli
|
|||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
taskManager.Shutdown();
|
||||||
if (taskManager.GetAllTasks().Any(task => task.isBeingExecuted))
|
|
||||||
{
|
|
||||||
Console.WriteLine("Force quit (Even with running tasks?) y/N");
|
|
||||||
selection = Console.ReadKey().Key;
|
|
||||||
taskManager.Shutdown(selection == ConsoleKey.Y);
|
|
||||||
}else
|
|
||||||
taskManager.Shutdown(false);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
private static ConsoleKey Menu(TaskManager taskManager, string folderPath)
|
private static ConsoleKey Menu(string folderPath)
|
||||||
{
|
{
|
||||||
int taskCount = taskManager.GetAllTasks().Length;
|
|
||||||
int taskRunningCount = taskManager.GetAllTasks().Count(task => task.isBeingExecuted);
|
|
||||||
Console.Clear();
|
Console.Clear();
|
||||||
Console.WriteLine($"Download Folder: {folderPath} Tasks (Running/Total): {taskRunningCount}/{taskCount}");
|
Console.WriteLine($"Download Folder: {folderPath}");
|
||||||
Console.WriteLine("Select Option:");
|
Console.WriteLine("Select Option:");
|
||||||
Console.WriteLine("L: List tasks");
|
Console.WriteLine("L: List tasks");
|
||||||
Console.WriteLine("C: Create Task");
|
Console.WriteLine("C: Create Task");
|
||||||
Console.WriteLine("D: Delete Task");
|
Console.WriteLine("D: Delete Task");
|
||||||
Console.WriteLine("E: Execute Task now");
|
|
||||||
Console.WriteLine("Q: Exit with saving");
|
Console.WriteLine("Q: Exit with saving");
|
||||||
ConsoleKey selection = Console.ReadKey().Key;
|
ConsoleKey selection = Console.ReadKey().Key;
|
||||||
Console.WriteLine();
|
Console.WriteLine();
|
||||||
return selection;
|
return selection;
|
||||||
}
|
}
|
||||||
|
|
||||||
private static void PrintTasks(TrangaTask[] tasks)
|
private static int PrintTasks(TaskManager taskManager)
|
||||||
{
|
{
|
||||||
int taskCount = tasks.Length;
|
|
||||||
int taskRunningCount = tasks.Count(task => task.isBeingExecuted);
|
|
||||||
Console.Clear();
|
Console.Clear();
|
||||||
int tIndex = 0;
|
|
||||||
Console.WriteLine($"Tasks (Running/Total): {taskRunningCount}/{taskCount}");
|
|
||||||
foreach(TrangaTask trangaTask in tasks)
|
|
||||||
Console.WriteLine($"{tIndex++}: {trangaTask.task} - {trangaTask.reoccurrence} - {trangaTask.publication?.sortName} - {trangaTask.connectorName} - {trangaTask.lastExecuted} - {(trangaTask.isBeingExecuted ? "Running" : "Waiting")}");
|
|
||||||
}
|
|
||||||
|
|
||||||
private static void ExecuteTask(TaskManager taskManager)
|
|
||||||
{
|
|
||||||
TrangaTask[] tasks = taskManager.GetAllTasks();
|
TrangaTask[] tasks = taskManager.GetAllTasks();
|
||||||
PrintTasks(tasks);
|
int tIndex = 0;
|
||||||
|
Console.WriteLine("Tasks:");
|
||||||
Console.WriteLine($"Select Task (0-{tasks.Length - 1}):");
|
foreach(TrangaTask trangaTask in tasks)
|
||||||
|
Console.WriteLine($"{tIndex++}: {trangaTask.task} - {trangaTask.reoccurrence} - {trangaTask.publication?.sortName} - {trangaTask.connectorName} - {trangaTask.lastExecuted}");
|
||||||
string? selectedTask = Console.ReadLine();
|
return tasks.Length;
|
||||||
while(selectedTask is null || selectedTask.Length < 1)
|
|
||||||
selectedTask = Console.ReadLine();
|
|
||||||
int selectedTaskIndex = Convert.ToInt32(selectedTask);
|
|
||||||
|
|
||||||
taskManager.ExecuteTaskNow(tasks[selectedTaskIndex]);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
private static void RemoveTask(TaskManager taskManager)
|
private static void RemoveTask(TaskManager taskManager)
|
||||||
{
|
{
|
||||||
TrangaTask[] tasks = taskManager.GetAllTasks();
|
int length = PrintTasks(taskManager);
|
||||||
PrintTasks(tasks);
|
|
||||||
|
|
||||||
Console.WriteLine($"Select Task (0-{tasks.Length - 1}):");
|
TrangaTask[] tasks = taskManager.GetAllTasks();
|
||||||
|
Console.WriteLine($"Select Task (0-{length}):");
|
||||||
|
|
||||||
string? selectedTask = Console.ReadLine();
|
string? selectedTask = Console.ReadLine();
|
||||||
while(selectedTask is null || selectedTask.Length < 1)
|
while(selectedTask is null || selectedTask.Length < 1)
|
||||||
|
@ -7,10 +7,6 @@ public static class TaskExecutor
|
|||||||
Connector? connector = connectors.FirstOrDefault(c => c.name == trangaTask.connectorName);
|
Connector? connector = connectors.FirstOrDefault(c => c.name == trangaTask.connectorName);
|
||||||
if (connector is null)
|
if (connector is null)
|
||||||
throw new ArgumentException($"Connector {trangaTask.connectorName} is not a known connector.");
|
throw new ArgumentException($"Connector {trangaTask.connectorName} is not a known connector.");
|
||||||
|
|
||||||
if (trangaTask.isBeingExecuted)
|
|
||||||
return;
|
|
||||||
trangaTask.isBeingExecuted = true;
|
|
||||||
trangaTask.lastExecuted = DateTime.Now;
|
trangaTask.lastExecuted = DateTime.Now;
|
||||||
|
|
||||||
switch (trangaTask.task)
|
switch (trangaTask.task)
|
||||||
@ -25,8 +21,6 @@ public static class TaskExecutor
|
|||||||
UpdatePublications(connector, chapterCollection);
|
UpdatePublications(connector, chapterCollection);
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
|
|
||||||
trangaTask.isBeingExecuted = false;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
private static void UpdatePublications(Connector connector, Dictionary<Publication, List<Chapter>> chapterCollection)
|
private static void UpdatePublications(Connector connector, Dictionary<Publication, List<Chapter>> chapterCollection)
|
||||||
|
@ -34,15 +34,6 @@ public class TaskManager
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public void ExecuteTaskNow(TrangaTask task)
|
|
||||||
{
|
|
||||||
Task t = new Task(() =>
|
|
||||||
{
|
|
||||||
TaskExecutor.Execute(this.connectors, task, this._chapterCollection);
|
|
||||||
});
|
|
||||||
t.Start();
|
|
||||||
}
|
|
||||||
|
|
||||||
public void AddTask(TrangaTask.Task task, string connectorName, Publication? publication, TimeSpan reoccurrence,
|
public void AddTask(TrangaTask.Task task, string connectorName, Publication? publication, TimeSpan reoccurrence,
|
||||||
string language = "")
|
string language = "")
|
||||||
{
|
{
|
||||||
@ -85,21 +76,13 @@ public class TaskManager
|
|||||||
return this._chapterCollection.Keys.ToArray();
|
return this._chapterCollection.Keys.ToArray();
|
||||||
}
|
}
|
||||||
|
|
||||||
public void Shutdown(bool force = false)
|
public void Shutdown()
|
||||||
{
|
{
|
||||||
_continueRunning = false;
|
_continueRunning = false;
|
||||||
ExportTasks(Directory.GetCurrentDirectory());
|
ExportTasks(Directory.GetCurrentDirectory());
|
||||||
|
|
||||||
if(force)
|
|
||||||
Environment.Exit(_allTasks.Count(task => task.isBeingExecuted));
|
|
||||||
|
|
||||||
//Wait for tasks to finish
|
|
||||||
while(_allTasks.Any(task => task.isBeingExecuted))
|
|
||||||
Thread.Sleep(10);
|
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
private HashSet<TrangaTask> ImportTasks(string importFolderPath)
|
public HashSet<TrangaTask> ImportTasks(string importFolderPath)
|
||||||
{
|
{
|
||||||
string filePath = Path.Join(importFolderPath, "tasks.json");
|
string filePath = Path.Join(importFolderPath, "tasks.json");
|
||||||
if (!File.Exists(filePath))
|
if (!File.Exists(filePath))
|
||||||
@ -115,7 +98,7 @@ public class TaskManager
|
|||||||
return importTasks.ToHashSet();
|
return importTasks.ToHashSet();
|
||||||
}
|
}
|
||||||
|
|
||||||
private void ExportTasks(string exportFolderPath)
|
public void ExportTasks(string exportFolderPath)
|
||||||
{
|
{
|
||||||
string filePath = Path.Join(exportFolderPath, "tasks.json");
|
string filePath = Path.Join(exportFolderPath, "tasks.json");
|
||||||
string toWrite = JsonConvert.SerializeObject(_allTasks.ToArray());
|
string toWrite = JsonConvert.SerializeObject(_allTasks.ToArray());
|
||||||
|
@ -1,6 +1,4 @@
|
|||||||
using Newtonsoft.Json;
|
namespace Tranga;
|
||||||
|
|
||||||
namespace Tranga;
|
|
||||||
|
|
||||||
public class TrangaTask
|
public class TrangaTask
|
||||||
{
|
{
|
||||||
@ -10,7 +8,6 @@ public class TrangaTask
|
|||||||
public Task task { get; }
|
public Task task { get; }
|
||||||
public Publication? publication { get; }
|
public Publication? publication { get; }
|
||||||
public string language { get; }
|
public string language { get; }
|
||||||
[JsonIgnore]public bool isBeingExecuted { get; set; }
|
|
||||||
|
|
||||||
public TrangaTask(string connectorName, Task task, Publication? publication, TimeSpan reoccurrence, string language = "")
|
public TrangaTask(string connectorName, Task task, Publication? publication, TimeSpan reoccurrence, string language = "")
|
||||||
{
|
{
|
||||||
|
Loading…
Reference in New Issue
Block a user