diff --git a/README.md b/README.md index 47ca354..5d01bb3 100644 --- a/README.md +++ b/README.md @@ -14,7 +14,6 @@ ## To do -- Разделить очередь задач и текущую задачу - Собирать статистику по количеству экшенов в час - Автоматизировать повышение уровня войск - Автоматизировать развитие деревни diff --git a/src/Action/CompleteTaskAction.ts b/src/Action/CompleteTaskAction.ts index 8bf8b3b..7300a20 100644 --- a/src/Action/CompleteTaskAction.ts +++ b/src/Action/CompleteTaskAction.ts @@ -5,6 +5,6 @@ import { Task } from '../Queue/TaskQueue'; @registerAction export class CompleteTaskAction extends ActionController { async run(args: Args, task: Task): Promise { - this.scheduler.completeTask(task.id); + this.scheduler.removeTask(task.id); } } diff --git a/src/Action/UpgradeResourceToLevel.ts b/src/Action/UpgradeResourceToLevel.ts index b277ca9..ae03e7c 100644 --- a/src/Action/UpgradeResourceToLevel.ts +++ b/src/Action/UpgradeResourceToLevel.ts @@ -22,7 +22,7 @@ export class UpgradeResourceToLevel extends ActionController { const allUpgraded = deposits.reduce((memo, dep) => memo && dep.level >= requiredLevel, true); if (allUpgraded) { - this.scheduler.completeTask(task.id); + this.scheduler.removeTask(task.id); return; } diff --git a/src/Executor.ts b/src/Executor.ts index 917b9d6..3fadb92 100644 --- a/src/Executor.ts +++ b/src/Executor.ts @@ -99,7 +99,7 @@ export class Executor { await taskController.run(task); } else { this.logger.warn('TASK NOT FOUND', task.name); - this.scheduler.completeTask(task.id); + this.scheduler.removeTask(task.id); } } @@ -108,8 +108,7 @@ export class Executor { if (err instanceof AbortTaskError) { this.logger.warn('ABORT TASK', task.id); - this.scheduler.completeTask(task.id); - this.scheduler.clearActions(); + this.scheduler.removeTask(task.id); return; } diff --git a/src/Scheduler.ts b/src/Scheduler.ts index 20e7534..4541d64 100644 --- a/src/Scheduler.ts +++ b/src/Scheduler.ts @@ -70,11 +70,6 @@ export class Scheduler { } } - completeTask(taskId: TaskId) { - this.taskQueue.remove(taskId); - this.actionQueue.clear(); - } - removeTask(taskId: TaskId) { this.taskQueue.remove(taskId); this.actionQueue.clear();