MirrorSave
/
budibase
mirror of https://github.com/Budibase/budibase.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Changing how latest migration is determined.

This commit is contained in:
mike12345567 2024-06-06 17:26:37 +01:00
parent e86eb7082d
commit a4e646fc64
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
packages/server/src/appMigrations/index.ts
View File

@ -15,18 +15,15 @@ export type AppMigration = {
} }
export function getLatestEnabledMigrationId(migrations?: AppMigration[]) { export function getLatestEnabledMigrationId(migrations?: AppMigration[]) {
const enabledMigrations: AppMigration[] = [] let latestMigrationId: string | undefined
for (let migration of migrations || MIGRATIONS) { for (let migration of migrations || MIGRATIONS) {
// if a migration is disabled, all migrations after it are disabled // if a migration is disabled, all migrations after it are disabled
if (migration.disabled) { if (migration.disabled) {
break break
} }
enabledMigrations.push(migration) latestMigrationId = migration.id
} }
return enabledMigrations return latestMigrationId
.map(m => m.id)
.sort()
.reverse()[0]
} }
function getTimestamp(versionId: string) { function getTimestamp(versionId: string) {
@ -41,7 +38,10 @@ export async function checkMissingMigrations(
const currentVersion = await getAppMigrationVersion(appId) const currentVersion = await getAppMigrationVersion(appId)
const latestMigration = getLatestEnabledMigrationId() const latestMigration = getLatestEnabledMigrationId()
if (getTimestamp(currentVersion) < getTimestamp(latestMigration)) { if (
latestMigration &&
getTimestamp(currentVersion) < getTimestamp(latestMigration)
) {
await queue.add( await queue.add(
{ {
appId, appId,