Skip to content

Commit d05c5ad

Browse files
committed
Check for mod updates after queue finishes
1 parent 76c414c commit d05c5ad

2 files changed

Lines changed: 7 additions & 3 deletions

File tree

frontend/src/lib/store/actionQueue.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@ export const hasPendingProfileChange = writable(false);
1313

1414
const queuedActionsInternal = writable<QueuedAction<unknown>[]>([]);
1515
export const queuedMods = derived(queuedActionsInternal, (actions) => actions.map((a) => ({ ...a, func: undefined })));
16-
const modActionsQueue = queue((task: () => Promise<unknown>, cb) => {
16+
export const modActionsQueue = queue((task: () => Promise<unknown>, cb) => {
1717
const complete = (e?: Error) => {
1818
queuedActionsInternal.set(get(queuedActionsInternal).filter((a) => a.func !== task));
1919
cb(e);
@@ -22,7 +22,7 @@ const modActionsQueue = queue((task: () => Promise<unknown>, cb) => {
2222
task().then(() => complete()).catch(complete);
2323
});
2424

25-
modActionsQueue.empty(() => {
25+
modActionsQueue.drain(() => {
2626
if(!get(queueAutoStart)) {
2727
modActionsQueue.pause();
2828
}

frontend/src/lib/store/ficsitCLIStore.ts

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ import { isLaunchingGame } from './generalStore';
44
import { ignoredUpdates } from './settingsStore';
55
import { binding, bindingTwoWay } from './wailsStoreBindings';
66

7-
import { queuedMods } from '$lib/store/actionQueue';
7+
import { modActionsQueue, queuedMods } from '$lib/store/actionQueue';
88
import { bytesToAppropriate, secondsToAppropriate } from '$lib/utils/dataFormats';
99
import { setIntervalImmediate } from '$lib/utils/interval';
1010
import { progressStats } from '$lib/utils/progress';
@@ -93,6 +93,10 @@ export async function checkForUpdates() {
9393

9494
setIntervalImmediate(() => checkForUpdates().catch(console.error), 1000 * 60 * 5); // Check for updates every 5 minutes
9595

96+
modActionsQueue.drain(() => {
97+
checkForUpdates().catch(console.error);
98+
});
99+
96100
export const progressTitle = derived(progress, ($progress) => {
97101
if (!$progress) return '';
98102
switch ($progress.action) {

0 commit comments

Comments
 (0)