wieerwill/platform
1
0
Fork 0
mirror of https://github.com/hcengineering/platform.git synced 2025-04-08 00:52:30 +00:00
Code Issues Actions 5 Packages Projects Releases Wiki Activity

Reduce stat calls from sync blob (#6890)

Browse Source 
Signed-off-by: Denis Bykhov <bykhov.denis@gmail.com>
This commit is contained in:
Denis Bykhov 2024-10-11 23:55:29 +05:00 committed by Andrey Sobolev
parent 416c4aeae9
commit 15aab67620
No known key found for this signature in database
GPG Key ID: BD80F68D68D8F7F2
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
server/server-storage/src/aggregator.ts
View File

@ -55,10 +55,12 @@ export class AggregatorStorageAdapter implements StorageAdapter, StorageAdapterE
let current: Blob | undefined = ( let current: Blob | undefined = (
await this.dbAdapter.find<Blob>(ctx, workspaceId, DOMAIN_BLOB, { _id: objectName as Ref<Blob> }, { limit: 1 }) await this.dbAdapter.find<Blob>(ctx, workspaceId, DOMAIN_BLOB, { _id: objectName as Ref<Blob> }, { limit: 1 })
).shift() ).shift()
let updated = false
if (current === undefined && providerId !== undefined) { if (current === undefined && providerId !== undefined) {
current = await this.adapters.get(providerId)?.stat(ctx, workspaceId, objectName) current = await this.adapters.get(providerId)?.stat(ctx, workspaceId, objectName)
if (current !== undefined) { if (current !== undefined) {
current.provider = providerId current.provider = providerId
updated = true
} }
} }
@ -66,10 +68,10 @@ export class AggregatorStorageAdapter implements StorageAdapter, StorageAdapterE
if (provider === undefined) { if (provider === undefined) {
throw new NoSuchKeyError('No such provider found') throw new NoSuchKeyError('No such provider found')
} }
const stat = await provider.stat(ctx, workspaceId, objectName) const stat = updated ? current : await provider.stat(ctx, workspaceId, objectName)
if (stat !== undefined) { if (stat !== undefined) {
stat.provider = providerId ?? current?.provider ?? this.defaultAdapter stat.provider = providerId ?? current?.provider ?? this.defaultAdapter
if (current !== undefined) { if (current !== undefined && !updated) {
await this.dbAdapter.clean(ctx, workspaceId, DOMAIN_BLOB, [current._id]) await this.dbAdapter.clean(ctx, workspaceId, DOMAIN_BLOB, [current._id])
} }
await this.dbAdapter.upload<Blob>(ctx, workspaceId, DOMAIN_BLOB, [stat]) await this.dbAdapter.upload<Blob>(ctx, workspaceId, DOMAIN_BLOB, [stat])