danvics/zerobyte
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 1

refactor: await config updates to avoid race condition on later mount

Browse source
This commit is contained in:
Nicolas Meienberger 2025-12-18 17:35:37 +01:00
parent 99f14e7094
commit 68efe8a3cc
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
app/server/modules/lifecycle/startup.ts
View file

@ -17,7 +17,7 @@ const ensureLatestConfigurationSchema = async () => {
const volumes = await db.query.volumesTable.findMany({}); const volumes = await db.query.volumesTable.findMany({});
for (const volume of volumes) { for (const volume of volumes) {
volumeService.updateVolume(volume.name, volume).catch((err) => { await volumeService.updateVolume(volume.name, volume).catch((err) => {
logger.error(`Failed to update volume ${volume.name}: ${err}`); logger.error(`Failed to update volume ${volume.name}: ${err}`);
}); });
} }
@ -25,7 +25,7 @@ const ensureLatestConfigurationSchema = async () => {
const repositories = await db.query.repositoriesTable.findMany({}); const repositories = await db.query.repositoriesTable.findMany({});
for (const repo of repositories) { for (const repo of repositories) {
repositoriesService.updateRepository(repo.name, {}).catch((err) => { await repositoriesService.updateRepository(repo.name, {}).catch((err) => {
logger.error(`Failed to update repository ${repo.name}: ${err}`); logger.error(`Failed to update repository ${repo.name}: ${err}`);
}); });
} }
@ -33,7 +33,7 @@ const ensureLatestConfigurationSchema = async () => {
const notifications = await db.query.notificationDestinationsTable.findMany({}); const notifications = await db.query.notificationDestinationsTable.findMany({});
for (const notification of notifications) { for (const notification of notifications) {
notificationsService.updateDestination(notification.id, notification).catch((err) => { await notificationsService.updateDestination(notification.id, notification).catch((err) => {
logger.error(`Failed to update notification destination ${notification.id}: ${err}`); logger.error(`Failed to update notification destination ${notification.id}: ${err}`);
}); });
} }