Skip to content

Commit 6736ca7

Browse files
authored
Update clean view command + add dry run to favorite backfill (#7268)
Clean favorites associated with activities
1 parent c1db435 commit 6736ca7

File tree

4 files changed

+31
-15
lines changed

4 files changed

+31
-15
lines changed

packages/twenty-server/src/database/commands/upgrade-version/0-31/0-31-backfill-workspace-favorites.command.ts

+18-6
Original file line numberDiff line numberDiff line change
@@ -51,6 +51,7 @@ export class BackfillWorkspaceFavoritesCommand extends ActiveWorkspacesCommandRu
5151
await this.createViewWorkspaceFavorites(
5252
workspaceId,
5353
activeWorkspaceIndexViews.map((view) => view.id),
54+
_options.dryRun ?? false,
5455
);
5556

5657
this.logger.log(
@@ -117,6 +118,7 @@ export class BackfillWorkspaceFavoritesCommand extends ActiveWorkspacesCommandRu
117118
private async createViewWorkspaceFavorites(
118119
workspaceId: string,
119120
viewIds: string[],
121+
dryRun: boolean,
120122
) {
121123
const favoriteRepository =
122124
await this.twentyORMGlobalManager.getRepositoryForWorkspace<FavoriteWorkspaceEntity>(
@@ -125,6 +127,7 @@ export class BackfillWorkspaceFavoritesCommand extends ActiveWorkspacesCommandRu
125127
);
126128

127129
let nextFavoritePosition = await favoriteRepository.count();
130+
let createdFavorites = 0;
128131

129132
for (const viewId of viewIds) {
130133
const existingFavorites = await favoriteRepository.find({
@@ -137,14 +140,23 @@ export class BackfillWorkspaceFavoritesCommand extends ActiveWorkspacesCommandRu
137140
continue;
138141
}
139142

140-
await favoriteRepository.insert(
141-
favoriteRepository.create({
142-
viewId,
143-
position: nextFavoritePosition,
144-
}),
145-
);
143+
if (!dryRun) {
144+
await favoriteRepository.insert(
145+
favoriteRepository.create({
146+
viewId,
147+
position: nextFavoritePosition,
148+
}),
149+
);
150+
}
146151

152+
createdFavorites++;
147153
nextFavoritePosition++;
148154
}
155+
156+
this.logger.log(
157+
chalk.green(
158+
`Found ${createdFavorites} favorites to backfill in workspace ${workspaceId}.`,
159+
),
160+
);
149161
}
150162
}
Original file line numberDiff line numberDiff line change
@@ -11,13 +11,15 @@ import {
1111
import { Workspace } from 'src/engine/core-modules/workspace/workspace.entity';
1212
import { ObjectMetadataEntity } from 'src/engine/metadata-modules/object-metadata/object-metadata.entity';
1313
import { TwentyORMGlobalManager } from 'src/engine/twenty-orm/twenty-orm-global.manager';
14+
import { STANDARD_OBJECT_IDS } from 'src/engine/workspace-manager/workspace-sync-metadata/constants/standard-object-ids';
1415
import { ViewWorkspaceEntity } from 'src/modules/view/standard-objects/view.workspace-entity';
1516

1617
@Command({
17-
name: 'upgrade-0.31:clean-views-with-deleted-object-metadata',
18-
description: 'Clean views with deleted object metadata',
18+
name: 'upgrade-0.31:clean-views-associated-with-outdated-objects',
19+
description:
20+
'Clean views associated with deleted object metadata or activities',
1921
})
20-
export class CleanViewsWithDeletedObjectMetadataCommand extends ActiveWorkspacesCommandRunner {
22+
export class CleanViewsAssociatedWithOutdatedObjectsCommand extends ActiveWorkspacesCommandRunner {
2123
constructor(
2224
@InjectRepository(Workspace, 'core')
2325
protected readonly workspaceRepository: Repository<Workspace>,
@@ -88,7 +90,9 @@ export class CleanViewsWithDeletedObjectMetadataCommand extends ActiveWorkspaces
8890
});
8991

9092
const validObjectMetadataIds = new Set(
91-
objectMetadataEntities.map((entity) => entity.id),
93+
objectMetadataEntities
94+
.filter((entity) => entity.standardId !== STANDARD_OBJECT_IDS.activity)
95+
.map((entity) => entity.id),
9296
);
9397

9498
const viewIdsToDelete = allViews

packages/twenty-server/src/database/commands/upgrade-version/0-31/0-31-upgrade-version.command.ts

+3-3
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ import { Repository } from 'typeorm';
66
import { ActiveWorkspacesCommandRunner } from 'src/database/commands/active-workspaces.command';
77
import { AddIndexKeyToTasksAndNotesViewsCommand } from 'src/database/commands/upgrade-version/0-31/0-31-add-index-key-to-tasks-and-notes-views.command';
88
import { BackfillWorkspaceFavoritesCommand } from 'src/database/commands/upgrade-version/0-31/0-31-backfill-workspace-favorites.command';
9-
import { CleanViewsWithDeletedObjectMetadataCommand } from 'src/database/commands/upgrade-version/0-31/0-31-clean-views-with-deleted-object-metadata.command';
9+
import { CleanViewsAssociatedWithOutdatedObjectsCommand } from 'src/database/commands/upgrade-version/0-31/0-31-clean-views-associated-with-outdated-objects.command';
1010
import { Workspace } from 'src/engine/core-modules/workspace/workspace.entity';
1111
import { SyncWorkspaceMetadataCommand } from 'src/engine/workspace-manager/workspace-sync-metadata/commands/sync-workspace-metadata.command';
1212

@@ -24,7 +24,7 @@ export class UpgradeTo0_31Command extends ActiveWorkspacesCommandRunner {
2424
protected readonly workspaceRepository: Repository<Workspace>,
2525
private readonly syncWorkspaceMetadataCommand: SyncWorkspaceMetadataCommand,
2626
private readonly backfillWorkspaceFavoritesCommand: BackfillWorkspaceFavoritesCommand,
27-
private readonly cleanViewsWithDeletedObjectMetadataCommand: CleanViewsWithDeletedObjectMetadataCommand,
27+
private readonly cleanViewsAssociatedWithOutdatedObjectsCommand: CleanViewsAssociatedWithOutdatedObjectsCommand,
2828
private readonly addIndexKeyToTasksAndNotesViewsCommand: AddIndexKeyToTasksAndNotesViewsCommand,
2929
) {
3030
super(workspaceRepository);
@@ -43,7 +43,7 @@ export class UpgradeTo0_31Command extends ActiveWorkspacesCommandRunner {
4343
},
4444
workspaceIds,
4545
);
46-
await this.cleanViewsWithDeletedObjectMetadataCommand.executeActiveWorkspacesCommand(
46+
await this.cleanViewsAssociatedWithOutdatedObjectsCommand.executeActiveWorkspacesCommand(
4747
passedParam,
4848
options,
4949
workspaceIds,

packages/twenty-server/src/database/commands/upgrade-version/0-31/0-31-upgrade-version.module.ts

+2-2
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ import { TypeOrmModule } from '@nestjs/typeorm';
33

44
import { AddIndexKeyToTasksAndNotesViewsCommand } from 'src/database/commands/upgrade-version/0-31/0-31-add-index-key-to-tasks-and-notes-views.command';
55
import { BackfillWorkspaceFavoritesCommand } from 'src/database/commands/upgrade-version/0-31/0-31-backfill-workspace-favorites.command';
6-
import { CleanViewsWithDeletedObjectMetadataCommand } from 'src/database/commands/upgrade-version/0-31/0-31-clean-views-with-deleted-object-metadata.command';
6+
import { CleanViewsAssociatedWithOutdatedObjectsCommand } from 'src/database/commands/upgrade-version/0-31/0-31-clean-views-associated-with-outdated-objects.command';
77
import { UpgradeTo0_31Command } from 'src/database/commands/upgrade-version/0-31/0-31-upgrade-version.command';
88
import { Workspace } from 'src/engine/core-modules/workspace/workspace.entity';
99
import { ObjectMetadataEntity } from 'src/engine/metadata-modules/object-metadata/object-metadata.entity';
@@ -18,7 +18,7 @@ import { WorkspaceSyncMetadataCommandsModule } from 'src/engine/workspace-manage
1818
providers: [
1919
UpgradeTo0_31Command,
2020
BackfillWorkspaceFavoritesCommand,
21-
CleanViewsWithDeletedObjectMetadataCommand,
21+
CleanViewsAssociatedWithOutdatedObjectsCommand,
2222
AddIndexKeyToTasksAndNotesViewsCommand,
2323
],
2424
})

0 commit comments

Comments
 (0)