admin/twenty
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

add more logs to cleaning command (#12219)

Browse Source
This commit is contained in:
Etienne
2025-05-22 15:25:19 +02:00
committed by GitHub
parent 79b4b3f783
commit aeee04415d
1 changed files with 13 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
packages/twenty-server/src/database/commands/upgrade-version-command/0-54/0-54-clean-not-found-files.command.ts
View File

@ -57,6 +57,7 @@ export class CleanNotFoundFilesCommand extends ActiveOrSuspendedWorkspacesMigrat
} }
private async checkIfFileIsFound(path: string, workspaceId: string) { private async checkIfFileIsFound(path: string, workspaceId: string) {
this.logger.log(`Checking if file is found ${path}`);
if (path.startsWith('https://')) return true; // seed data if (path.startsWith('https://')) return true; // seed data
try { try {
@ -70,14 +71,18 @@ export class CleanNotFoundFilesCommand extends ActiveOrSuspendedWorkspacesMigrat
error instanceof FileStorageException && error instanceof FileStorageException &&
error.code === FileStorageExceptionCode.FILE_NOT_FOUND error.code === FileStorageExceptionCode.FILE_NOT_FOUND
) { ) {
this.logger.log(`File not found`);
return false; return false;
} }
} }
this.logger.log(`File found`);
return true; return true;
} }
private async cleanWorkspaceLogo(workspaceId: string, dryRun: boolean) { private async cleanWorkspaceLogo(workspaceId: string, dryRun: boolean) {
this.logger.log(`Cleaning workspace logo for workspace ${workspaceId}`);
const workspace = await this.workspaceRepository.findOneOrFail({ const workspace = await this.workspaceRepository.findOneOrFail({
where: { where: {
id: workspaceId, id: workspaceId,
@ -86,7 +91,7 @@ export class CleanNotFoundFilesCommand extends ActiveOrSuspendedWorkspacesMigrat
if (!isNonEmptyString(workspace.logo)) return; if (!isNonEmptyString(workspace.logo)) return;
this.logger.log('Processing workspace logo for workspace', workspace.id); this.logger.log(`Processing workspace logo for workspace ${workspace.id}`);
const isFileFound = await this.checkIfFileIsFound( const isFileFound = await this.checkIfFileIsFound(
workspace.logo, workspace.logo,
@ -106,6 +111,7 @@ export class CleanNotFoundFilesCommand extends ActiveOrSuspendedWorkspacesMigrat
} }
private async softDeleteAttachments(workspaceId: string, dryRun: boolean) { private async softDeleteAttachments(workspaceId: string, dryRun: boolean) {
this.logger.log(`Cleaning attachments for workspace ${workspaceId}`);
const attachmentRepository = const attachmentRepository =
await this.twentyORMGlobalManager.getRepositoryForWorkspace<AttachmentWorkspaceEntity>( await this.twentyORMGlobalManager.getRepositoryForWorkspace<AttachmentWorkspaceEntity>(
workspaceId, workspaceId,
@ -124,7 +130,7 @@ export class CleanNotFoundFilesCommand extends ActiveOrSuspendedWorkspacesMigrat
const attachmentIdsToSoftDeleteChunk = await Promise.all( const attachmentIdsToSoftDeleteChunk = await Promise.all(
attachmentsChunk.map(async (attachment) => { attachmentsChunk.map(async (attachment) => {
this.logger.log('Processing attachment', attachment.id); this.logger.log(`Processing attachment ${attachment.id}`);
const isFileFound = await this.checkIfFileIsFound( const isFileFound = await this.checkIfFileIsFound(
attachment.fullPath, attachment.fullPath,
workspaceId, workspaceId,
@ -153,6 +159,9 @@ export class CleanNotFoundFilesCommand extends ActiveOrSuspendedWorkspacesMigrat
workspaceId: string, workspaceId: string,
dryRun: boolean, dryRun: boolean,
) { ) {
this.logger.log(
`Cleaning workspace members avatarUrl for workspace ${workspaceId}`,
);
const workspaceMemberRepository = const workspaceMemberRepository =
await this.twentyORMGlobalManager.getRepositoryForWorkspace<WorkspaceMemberWorkspaceEntity>( await this.twentyORMGlobalManager.getRepositoryForWorkspace<WorkspaceMemberWorkspaceEntity>(
workspaceId, workspaceId,
@ -167,7 +176,7 @@ export class CleanNotFoundFilesCommand extends ActiveOrSuspendedWorkspacesMigrat
const workspaceMemberIdsToUpdate: string[] = []; const workspaceMemberIdsToUpdate: string[] = [];
for (const workspaceMember of workspaceMembers) { for (const workspaceMember of workspaceMembers) {
this.logger.log('Processing workspaceMember', workspaceMember.id); this.logger.log(`Processing workspaceMember ${workspaceMember.id}`);
const isFileFound = await this.checkIfFileIsFound( const isFileFound = await this.checkIfFileIsFound(
workspaceMember.avatarUrl, workspaceMember.avatarUrl,
@ -192,6 +201,7 @@ export class CleanNotFoundFilesCommand extends ActiveOrSuspendedWorkspacesMigrat
} }
private async cleanPeopleAvatarUrl(workspaceId: string, dryRun: boolean) { private async cleanPeopleAvatarUrl(workspaceId: string, dryRun: boolean) {
this.logger.log(`Cleaning people avatarUrl for workspace ${workspaceId}`);
const personRepository = const personRepository =
await this.twentyORMGlobalManager.getRepositoryForWorkspace<PersonWorkspaceEntity>( await this.twentyORMGlobalManager.getRepositoryForWorkspace<PersonWorkspaceEntity>(
workspaceId, workspaceId,