From 8fa90ab0a3915df0bcd9255df05f812de825fc48 Mon Sep 17 00:00:00 2001 From: Thomas Trompette Date: Fri, 26 Jul 2024 18:21:35 +0200 Subject: [PATCH] Delete cache version on reset db --- .../src/database/commands/data-seed-dev-workspace.command.ts | 3 +++ .../workspace-cache-version.service.ts | 4 ++++ 2 files changed, 7 insertions(+) diff --git a/packages/twenty-server/src/database/commands/data-seed-dev-workspace.command.ts b/packages/twenty-server/src/database/commands/data-seed-dev-workspace.command.ts index f7d5475ee9a5..57cf1fa56a49 100644 --- a/packages/twenty-server/src/database/commands/data-seed-dev-workspace.command.ts +++ b/packages/twenty-server/src/database/commands/data-seed-dev-workspace.command.ts @@ -27,6 +27,7 @@ import { InjectCacheStorage } from 'src/engine/integrations/cache-storage/decora import { CacheStorageNamespace } from 'src/engine/integrations/cache-storage/types/cache-storage-namespace.enum'; import { DataSourceService } from 'src/engine/metadata-modules/data-source/data-source.service'; import { ObjectMetadataService } from 'src/engine/metadata-modules/object-metadata/object-metadata.service'; +import { WorkspaceCacheVersionService } from 'src/engine/metadata-modules/workspace-cache-version/workspace-cache-version.service'; import { WorkspaceDataSourceService } from 'src/engine/workspace-datasource/workspace-datasource.service'; import { viewPrefillData } from 'src/engine/workspace-manager/standard-objects-prefill-data/view'; import { WorkspaceSyncMetadataService } from 'src/engine/workspace-manager/workspace-sync-metadata/workspace-sync-metadata.service'; @@ -48,6 +49,7 @@ export class DataSeedWorkspaceCommand extends CommandRunner { private readonly objectMetadataService: ObjectMetadataService, @InjectCacheStorage(CacheStorageNamespace.WorkspaceSchema) private readonly workspaceSchemaCache: CacheStorageService, + private readonly workspaceCacheVersionService: WorkspaceCacheVersionService, ) { super(); } @@ -56,6 +58,7 @@ export class DataSeedWorkspaceCommand extends CommandRunner { try { for (const workspaceId of this.workspaceIds) { await this.workspaceSchemaCache.flush(); + await this.workspaceCacheVersionService.deleteVersion(workspaceId); await rawDataSource.initialize(); diff --git a/packages/twenty-server/src/engine/metadata-modules/workspace-cache-version/workspace-cache-version.service.ts b/packages/twenty-server/src/engine/metadata-modules/workspace-cache-version/workspace-cache-version.service.ts index 347dc81a0927..8b0bfb8c2a10 100644 --- a/packages/twenty-server/src/engine/metadata-modules/workspace-cache-version/workspace-cache-version.service.ts +++ b/packages/twenty-server/src/engine/metadata-modules/workspace-cache-version/workspace-cache-version.service.ts @@ -35,4 +35,8 @@ export class WorkspaceCacheVersionService { return workspaceCacheVersion?.version ?? null; } + + async deleteVersion(workspaceId: string): Promise { + await this.workspaceCacheVersionRepository.delete({ workspaceId }); + } }