av/travian
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix building full queue handler

Browse Source
This commit is contained in:
Anton Vakhrushev 2020-04-12 20:55:44 +03:00
parent 9fdc573746
commit 29b55158d6
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/Scheduler.ts
View File

@ -11,6 +11,7 @@ import { SendOnAdventureTask } from './Task/SendOnAdventureTask';
import { GameState } from './Storage/GameState'; import { GameState } from './Storage/GameState';
import { BalanceHeroResourcesTask } from './Task/BalanceHeroResourcesTask'; import { BalanceHeroResourcesTask } from './Task/BalanceHeroResourcesTask';
import { Logger } from './Logger'; import { Logger } from './Logger';
import { BuildBuildingTask } from './Task/BuildBuildingTask';
export class Scheduler { export class Scheduler {
private readonly version: string; private readonly version: string;
@ -126,6 +127,10 @@ export class Scheduler {
if (err instanceof BuildingQueueFullError) { if (err instanceof BuildingQueueFullError) {
this.logger.warn('BUILDING QUEUE FULL, TRY ALL AFTER', err.seconds); this.logger.warn('BUILDING QUEUE FULL, TRY ALL AFTER', err.seconds);
this.taskQueue.modify(
t => t.name === BuildBuildingTask.name && t.args.villageId === err.villageId,
t => t.withTime(timestamp() + err.seconds)
);
this.taskQueue.modify( this.taskQueue.modify(
t => t.name === UpgradeBuildingTask.name && t.args.villageId === err.villageId, t => t.name === UpgradeBuildingTask.name && t.args.villageId === err.villageId,
t => t.withTime(timestamp() + err.seconds) t => t.withTime(timestamp() + err.seconds)