UBERF-8150: Update to fresh mongo (#6603)

Signed-off-by: Andrey Sobolev <haiodo@gmail.com>
This commit is contained in:
Andrey Sobolev
2024-09-17 23:26:46 +07:00
committed by GitHub
parent f24524058c
commit d38df9c600
29 changed files with 162 additions and 111 deletions
+9 -7
View File
@@ -86,7 +86,7 @@ import core, {
} from '@hcengineering/core'
import { consoleModelLogger, type MigrateOperation } from '@hcengineering/model'
import contact from '@hcengineering/model-contact'
import { getMongoClient, getWorkspaceDB } from '@hcengineering/mongo'
import { getMongoClient, getWorkspaceDB, shutdown } from '@hcengineering/mongo'
import type { StorageAdapter, StorageAdapterEx } from '@hcengineering/server-core'
import { deepEqual } from 'fast-equals'
import { createWriteStream, readFileSync } from 'fs'
@@ -205,6 +205,7 @@ export function devTool (
}
client.close()
console.log(`closing database connection to '${uri}'...`)
await shutdown()
}
async function withStorage (mongodbUri: string, f: (storageAdapter: StorageAdapter) => Promise<any>): Promise<void> {
@@ -552,11 +553,12 @@ export function devTool (
const measureCtx = new MeasureMetricsContext('upgrade', {})
for (const ws of workspaces) {
try {
const logger = cmd.console
? consoleModelLogger
: new FileModelLogger(path.join(cmd.logs, `${ws.workspace}.log`))
console.warn('UPGRADING', ws.workspaceName)
const logger = cmd.console
? consoleModelLogger
: new FileModelLogger(path.join(cmd.logs, `${ws.workspace}.log`))
try {
await upgradeWorkspace(
measureCtx,
version,
@@ -577,10 +579,10 @@ export function devTool (
attempts: 0
})
} catch (err: any) {
console.error(err)
toolCtx.error('failed to upgrade', { err, workspace: ws.workspace, workspaceName: ws.workspaceName })
continue
}
}
console.log('upgrade done')
})
})