hcengineering/platform
1
0
Fork 0
mirror of https://github.com/hcengineering/platform.git synced 2024-12-23 11:31:57 +03:00
Code Issues Actions 3 Packages Projects Releases Wiki Activity

UBERF-5932: Fix account upgrade (#4912)

Browse Source
This commit is contained in:
Andrey Sobolev 2024-03-09 22:14:13 +07:00 committed by GitHub
parent 1ff82a9c15
commit c72300b777
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 32 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
packages/platform/src/resource.ts
View File

@ -79,6 +79,7 @@ async function loadPlugin (id: Plugin): Promise<Resources> {
plugin: id
})
pluginLoader = monitor(status, getLocation(id)()).then(async (plugin) => {
return await retryLoading(async () => {
try {
// In case of ts-node, we have a bit different import structure, so let's check for it.
if (typeof plugin.default === 'object') {
@ -91,11 +92,29 @@ async function loadPlugin (id: Plugin): Promise<Resources> {
throw err
}
})
})
loading.set(id, pluginLoader)
}
return await pluginLoader
}
async function retryLoading (op: () => Promise<Resources>): Promise<Resources> {
let lastErr: any
for (let i = 0; i < 3; i++) {
try {
return await op()
} catch (err: any) {
if (/Loading chunk [\d]+ failed/.test(err.message)) {
// Do not report on console and try to load again.
// After a short delay
await new Promise((resolve) => setTimeout(resolve, 50))
}
lastErr = err
}
}
throw lastErr
}
const cachedResource = new Map<string, any>()
/**

7
server/account/src/index.ts
View File

@ -771,18 +771,17 @@ export async function upgradeWorkspace (
}
const versionStr = versionToString(version)
const currentVersion = await db.collection<Workspace>(WORKSPACE_COLLECTION).findOne({ workspace: ws.workspace })
console.log(
`${forceUpdate ? 'force-' : ''}upgrade from "${
currentVersion?.version !== undefined ? versionToString(currentVersion.version) : ''
ws?.version !== undefined ? versionToString(ws.version) : ''
}" to "${versionStr}"`
)
if (currentVersion?.version !== undefined && !forceUpdate && versionStr === versionToString(currentVersion.version)) {
if (ws?.version !== undefined && !forceUpdate && versionStr === versionToString(ws.version)) {
return versionStr
}
await db.collection(WORKSPACE_COLLECTION).updateOne(
{ workspace: ws.workspace },
{ _id: ws._id },
{
$set: { version }
}