lifegpc/eh-downloader
1
0
Fork 0
mirror of https://github.com/lifegpc/eh-downloader.git synced 2026-06-06 05:38:44 +08:00
Code Issues Packages Projects Releases Wiki Activity

Update task render

Browse Source
This commit is contained in:
lifegpc
2023-07-22 15:11:32 +08:00
parent 12d64ae9ca
commit 6766362d39
17 changed files with 191 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
task_manager.ts
View File

@@ -27,13 +27,15 @@ import {
export class AlreadyClosedError extends Error {
}
export class RecoverableError extends Error {}
type EventMap = {
current_cfg_updated: ConfigType;
new_task: Task;
task_started: Task;
task_finished: Task;
task_progress: TaskProgress;
task_error: { task: Task; error: string };
task_error: { task: Task; error: string; fatal: boolean };
task_updated: Task;
};
@@ -189,6 +191,7 @@ export class TaskManager extends EventTarget {
async check_running_tasks() {
this.#check_closed();
const removed_task: number[] = [];
const fataled_task: number[] = [];
for (const [id, task] of this.running_tasks) {
const status = await promiseState(task.task);
if (status.status == PromiseStatus.Fulfilled && status.value) {
@@ -198,10 +201,13 @@ export class TaskManager extends EventTarget {
} else if (status.status == PromiseStatus.Rejected) {
if (status.reason && !this.aborted) {
console.log(status.reason);
const fatal = !(status.reason instanceof RecoverableError);
this.dispatchEvent("task_error", {
task: task.base,
error: status.reason.toString(),
fatal,
});
if (fatal) fataled_task.push(id);
}
removed_task.push(id);
}
@@ -209,6 +215,9 @@ export class TaskManager extends EventTarget {
for (const id of removed_task) {
this.running_tasks.delete(id);
}
for (const id of fataled_task) {
await this.db.delete_task_by_id(id);
}
}
close() {
if (this.#closed) {