Jayden/AFFiNE-Mirror
0
0
Fork 0
mirror of https://github.com/toeverything/AFFiNE.git synced 2026-08-18 10:31:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

chore: cleanup logs

Browse Source
This commit is contained in:
DarkSky
2026-07-15 12:42:07 +08:00
parent a6b00a93c0
commit 0c7be44499
1 changed files with 23 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
packages/backend/server/src/core/storage/blob-job.ts
+23 -10
View File
@@ -62,6 +62,14 @@ export class StorageBlobJob {
private readonly db: PrismaClient private readonly db: PrismaClient
) {} ) {}
private autoLog(message: string, shouldDetail: boolean) {
if (shouldDetail) {
this.logger.log(message);
} else {
this.logger.verbose(message);
}
}
async enqueueBackfillMissingBlobMetadata(workspaceId: string, limit = 1000) { async enqueueBackfillMissingBlobMetadata(workspaceId: string, limit = 1000) {
await this.queue.add('backendRuntime.backfillMissingBlobMetadata', { await this.queue.add('backendRuntime.backfillMissingBlobMetadata', {
workspaceId, workspaceId,
@@ -381,8 +389,9 @@ export class StorageBlobJob {
this.event.emitAsync('workspace.blobs.updated', { workspaceId }) this.event.emitAsync('workspace.blobs.updated', { workspaceId })
) )
); );
this.logger.log( this.autoLog(
`executed blob cleanup run=${runId} deleted=${result.deletedObjects} skipped=${result.skippedStillReferenced} failed=${result.failed}` `executed blob cleanup run=${runId} deleted=${result.deletedObjects} skipped=${result.skippedStillReferenced} failed=${result.failed}`,
Boolean(result.failed)
); );
} }
@@ -441,8 +450,9 @@ export class StorageBlobJob {
this.event.emitAsync('workspace.blobs.updated', { workspaceId }) this.event.emitAsync('workspace.blobs.updated', { workspaceId })
) )
); );
this.logger.log( this.autoLog(
`backfilled blob metadata workspace=${workspaceId}${context.sid === undefined ? '' : ` sid=${context.sid}`} upserted=${result.upsertedMetadata} scanned=${result.scannedObjects}` `backfilled blob metadata workspace=${workspaceId}${context.sid === undefined ? '' : ` sid=${context.sid}`} upserted=${result.upsertedMetadata} scanned=${result.scannedObjects}`,
Boolean(result.upsertedMetadata)
); );
if (!result.nextCursor) { if (!result.nextCursor) {
break; break;
@@ -460,8 +470,9 @@ export class StorageBlobJob {
workspaceId, workspaceId,
limit limit
); );
this.logger.log( this.autoLog(
`rebuilt doc blob refs workspace=${workspaceId}${context.sid === undefined ? '' : ` sid=${context.sid}`} parsed=${result.parsedDocs} failed=${result.failedDocs}` `rebuilt doc blob refs workspace=${workspaceId}${context.sid === undefined ? '' : ` sid=${context.sid}`} parsed=${result.parsedDocs} failed=${result.failedDocs}`,
Boolean(result.failedDocs)
); );
if (!result.nextCursor) { if (!result.nextCursor) {
break; break;
@@ -481,8 +492,9 @@ export class StorageBlobJob {
gracePeriodDays, gracePeriodDays,
limit limit
); );
this.logger.log( this.autoLog(
`planned blob cleanup workspace=${workspaceId}${context.sid === undefined ? '' : ` sid=${context.sid}`} run=${result.runId} candidates=${result.candidatesMarked} scanned=${result.scannedBlobs}` `planned blob cleanup workspace=${workspaceId}${context.sid === undefined ? '' : ` sid=${context.sid}`} run=${result.runId} candidates=${result.candidatesMarked} scanned=${result.scannedBlobs}`,
Boolean(result.candidatesMarked)
); );
if (!result.nextCursor) { if (!result.nextCursor) {
break; break;
@@ -506,8 +518,9 @@ export class StorageBlobJob {
this.event.emitAsync('workspace.blobs.updated', { workspaceId }) this.event.emitAsync('workspace.blobs.updated', { workspaceId })
) )
); );
this.logger.log( this.autoLog(
`executed blob cleanup run=${runId} deleted=${result.deletedObjects} skipped=${result.skippedStillReferenced} failed=${result.failed}` `executed blob cleanup run=${runId} deleted=${result.deletedObjects} skipped=${result.skippedStillReferenced} failed=${result.failed}`,
Boolean(result.failed)
); );
const progressed = const progressed =